Make use of zfunction and zstream in streampay

cli/src/main/java/io/aklivity/zillabase/cli/config/ZillabaseAdminConfig.java

@@ -103,7 +103,14 @@ public final class ZillabaseAdminConfig
           http_server:
             type: http
             kind: server
+            options:
+              access-control:
+                policy: cross-origin
             routes:
+              - when:
+                  - headers:
+                      upgrade: websocket
+                exit: ws_server
               - when:
                   - headers:
                       :scheme: http
@@ -141,48 +148,48 @@ public final class ZillabaseAdminConfig
                 exit: apicurio_http_client
               - when:
                   - headers:
-                      :method: PUT
                       :scheme: http
                       :authority: localhost:7184
-                      :path: /v1/asyncapis/{id}
+                      :path: /v1/auth/sso/providers
                 with:
                   headers:
                     overrides:
-                      :authority: ${{env.APICURIO_HOST}}:${{env.APICURIO_PORT}}
-                      :path: /apis/registry/v2/groups/${{env.REGISTRY_GROUP_ID}}/artifacts/${params.id}
-                exit: apicurio_http_client
+                      :authority: ${{env.AUTH_ADMIN_HOST}}:${{env.AUTH_ADMIN_PORT}}
+                exit: auth_http_client
               - when:
                   - headers:
-                      :method: DELETE
                       :scheme: http
                       :authority: localhost:7184
-                      :path: /v1/asyncapis/{id}
+                      :path: /v1/auth/sso/providers/*
                 with:
                   headers:
                     overrides:
-                      :authority: ${{env.APICURIO_HOST}}:${{env.APICURIO_PORT}}
-                      :path: /apis/registry/v2/groups/${{env.REGISTRY_GROUP_ID}}/artifacts/${params.id}
-                exit: apicurio_http_client
+                      :authority: ${{env.AUTH_ADMIN_HOST}}:${{env.AUTH_ADMIN_PORT}}
+                exit: auth_http_client
               - when:
                   - headers:
                       :scheme: http
                       :authority: localhost:7184
-                      :path: /v1/sso
+                      :path: /v1/auth/users
                 with:
                   headers:
                     overrides:
-                      :authority: ${{env.SSO_ADMIN_HOST}}:${{env.SSO_ADMIN_PORT}}
-                exit: sso_http_client
+                      :authority: ${{env.AUTH_ADMIN_HOST}}:${{env.AUTH_ADMIN_PORT}}
+                exit: auth_http_client
               - when:
                   - headers:
                       :scheme: http
                       :authority: localhost:7184
-                      :path: /v1/sso/*
+                      :path: /v1/auth/users/*
                 with:
                   headers:
                     overrides:
-                      :authority: ${{env.SSO_ADMIN_HOST}}:${{env.SSO_ADMIN_PORT}}
-                exit: sso_http_client
+                      :authority: ${{env.AUTH_ADMIN_HOST}}:${{env.AUTH_ADMIN_PORT}}
+                exit: auth_http_client
+              - when:
+                  - headers:
+                      :path: /v1/storage/*
+                exit: http_filesystem_proxy
           config_http_client:
             type: http
             kind: client
@@ -203,16 +210,54 @@ public final class ZillabaseAdminConfig
             options:
               host: ${{env.APICURIO_HOST}}
               port: ${{env.APICURIO_PORT}}
-          sso_http_client:
+          auth_http_client:
             type: http
             kind: client
-            exit: sso_tcp_client
-          sso_tcp_client:
+            exit: auth_tcp_client
+          auth_tcp_client:
             type: tcp
             kind: client
             options:
-              host: ${{env.SSO_ADMIN_HOST}}
-              port: ${{env.SSO_ADMIN_PORT}}
+              host: ${{env.AUTH_ADMIN_HOST}}
+              port: ${{env.AUTH_ADMIN_PORT}}
+          http_filesystem_proxy:
+            type: http-filesystem
+            kind: proxy
+            routes:
+              - when:
+                  - method: GET
+                    path: /v1/storage/buckets
+                  - method: POST
+                    path: /v1/storage/buckets/{bucket}
+                  - method: DELETE
+                    path: /v1/storage/buckets/{bucket}
+                exit: filesystem_server
+                with:
+                  directory: ${params.bucket}
+              - when:
+                  - method: GET
+                    path: /v1/storage/objects/{bucket}/{path}
+                  - method: GET
+                    path: /v1/storage/objects/{bucket}
+                  - method: POST
+                    path: /v1/storage/objects/{bucket}/{path}
+                  - method: PUT
+                    path: /v1/storage/objects/{bucket}/{path}
+                  - method: DELETE
+                    path: /v1/storage/objects/{bucket}/{path}
+                exit: filesystem_server
+                with:
+                  directory: ${params.bucket}
+                  path: ${params.path}
+          ws_server:
+            type: ws
+            kind: server
+            exit: pgsql_server
+          filesystem_server:
+            type: filesystem
+            kind: server
+            options:
+              location: /var/storage/
         telemetry:
           exporters:
             stdout_logs_exporter:

cli/src/main/java/io/aklivity/zillabase/cli/config/ZillabaseApicurioConfig.java

@@ -16,10 +16,11 @@
 
 public final class ZillabaseApicurioConfig
 {
-    private static final String DEFAULT_APICURIO_TAG = "2.6.x-release";
-    private static final String DEFAULT_APICURIO_URL = "http://apicurio.zillabase.dev:8080";
+    private static final String DEFAULT_APICURIO_TAG = "3.0.4";
     private static final String DEFAULT_APICURIO_GROUP_ID = "default";
 
+    public static final String DEFAULT_APICURIO_URL = "http://apicurio.zillabase.dev:8080";
+
     public String tag = DEFAULT_APICURIO_TAG;
     public String url = DEFAULT_APICURIO_URL;
     public String groupId = DEFAULT_APICURIO_GROUP_ID;

cli/src/main/java/io/aklivity/zillabase/cli/config/ZillabaseSsoConfig.java → cli/src/main/java/io/aklivity/zillabase/cli/config/ZillabaseAuthConfig.java

@@ -16,11 +16,11 @@
 
 import io.aklivity.zillabase.cli.internal.Zillabase;
 
-public final class ZillabaseSsoConfig
+public final class ZillabaseAuthConfig
 {
-    private static final String DEFAULT_SSO_TAG = Zillabase.version();
-    public static final int DEFAULT_SSO_PORT = 7185;
-    public static final String DEFAULT_SSO_HOST = "sso.zillabase.dev";
+    private static final String DEFAULT_AUTH_TAG = Zillabase.version();
+    public static final int DEFAULT_AUTH_PORT = 7185;
+    public static final String DEFAULT_AUTH_HOST = "auth.zillabase.dev";
 
-    public String tag = DEFAULT_SSO_TAG;
+    public String tag = DEFAULT_AUTH_TAG;
 }

cli/src/main/java/io/aklivity/zillabase/cli/config/ZillabaseConfig.java

@@ -22,6 +22,6 @@ public final class ZillabaseConfig
     public ZillabaseRisingWaveConfig risingwave = new ZillabaseRisingWaveConfig();
     public ZillabaseZillaConfig zilla = new ZillabaseZillaConfig();
     public ZillabaseKeycloakConfig keycloak = new ZillabaseKeycloakConfig();
-    public ZillabaseSsoConfig sso = new ZillabaseSsoConfig();
+    public ZillabaseAuthConfig auth = new ZillabaseAuthConfig();
     public ZillabaseUdfConfig udf = new ZillabaseUdfConfig();
 }

cli/src/main/java/io/aklivity/zillabase/cli/config/ZillabaseZillaConfig.java

@@ -18,7 +18,7 @@
 
 public class ZillabaseZillaConfig
 {
-    public static final String DEFAULT_ZILLA_TAG = "0.9.105";
+    public static final String DEFAULT_ZILLA_TAG = "0.9.114";
 
     private static final List<ZillabaseZillaPortConfig> DEFAULT_PORT_LIST = List.of(
         new ZillabaseZillaPortConfig()

cli/src/main/java/io/aklivity/zillabase/cli/internal/ZillabaseCli.java

@@ -19,14 +19,12 @@
 import com.github.rvesse.airline.help.Help;
 
 import io.aklivity.zillabase.cli.internal.commands.asyncapi.ZillabaseAsyncapiCommand;
-import io.aklivity.zillabase.cli.internal.commands.asyncapi.add.ZillabaseAsyncapiAddCommand;
 import io.aklivity.zillabase.cli.internal.commands.asyncapi.list.ZillabaseAsyncapiListCommand;
-import io.aklivity.zillabase.cli.internal.commands.asyncapi.remove.ZillabaseAsyncapiRemoveCommand;
 import io.aklivity.zillabase.cli.internal.commands.asyncapi.show.ZillabaseAsyncapiShowCommand;
 import io.aklivity.zillabase.cli.internal.commands.config.ZillabaseConfigCommand;
 import io.aklivity.zillabase.cli.internal.commands.config.add.ZillabaseConfigAddCommand;
-import io.aklivity.zillabase.cli.internal.commands.config.list.ZillabaseConfigListCommand;
 import io.aklivity.zillabase.cli.internal.commands.config.remove.ZillabaseConfigRemoveCommand;
+import io.aklivity.zillabase.cli.internal.commands.config.show.ZillabaseConfigShowCommand;
 import io.aklivity.zillabase.cli.internal.commands.init.ZillabaseInitCommand;
 import io.aklivity.zillabase.cli.internal.commands.migration.ZillabaseMigrationCommand;
 import io.aklivity.zillabase.cli.internal.commands.migration.add.ZillabaseMigrationAddCommand;
@@ -49,10 +47,8 @@
             defaultCommand = ZillabaseAsyncapiCommand.Help.class,
             commands =
             {
-                ZillabaseAsyncapiAddCommand.class,
                 ZillabaseAsyncapiListCommand.class,
-                ZillabaseAsyncapiShowCommand.class,
-                ZillabaseAsyncapiRemoveCommand.class
+                ZillabaseAsyncapiShowCommand.class
             }),
         @Group(
             name = "config",
@@ -61,7 +57,7 @@
             commands =
             {
                 ZillabaseConfigAddCommand.class,
-                ZillabaseConfigListCommand.class,
+                ZillabaseConfigShowCommand.class,
                 ZillabaseConfigRemoveCommand.class
             }),
         @Group(

cli/src/main/java/io/aklivity/zillabase/cli/internal/asyncapi/AsyncapiSpecRegisterResponse.java

@@ -0,0 +1,20 @@
+/*
+ * Copyright 2024 Aklivity Inc
+ *
+ * Licensed under the Aklivity Community License (the "License"); you may not use
+ * this file except in compliance with the License.  You may obtain a copy of the
+ * License at
+ *
+ *   https://www.aklivity.io/aklivity-community-license/
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+ * WARRANTIES OF ANY KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations under the License.
+ */
+package io.aklivity.zillabase.cli.internal.asyncapi;
+
+public class AsyncapiSpecRegisterResponse
+{
+    public String id;
+}