Merge branch 'release/0.9.116'

aklivity · Jan 9, 2025 · 6e6780e · 6e6780e
2 parents d93dacf + ea8d35f
commit 6e6780e
Show file tree

Hide file tree

Showing 189 changed files with 4,305 additions and 1,701 deletions.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -2,7 +2,23 @@
 
 ## [Unreleased](https://github.com/aklivity/zilla/tree/HEAD)
 
-[Full Changelog](https://github.com/aklivity/zilla/compare/0.9.114...HEAD)
+[Full Changelog](https://github.com/aklivity/zilla/compare/0.9.115...HEAD)
+
+**Fixed bugs:**
+
+- Zilla is unresponsive sometimes & the app logs Stopped but accepts the CRUD requests [\#1312](https://github.com/aklivity/zilla/issues/1312)
+- Asyncapi kafka header extraction expression don’t match zilla yaml expressions  [\#1138](https://github.com/aklivity/zilla/issues/1138)
+
+**Merged pull requests:**
+
+- Minor bug fixes in zstream [\#1364](https://github.com/aklivity/zilla/pull/1364) ([akrambek](https://github.com/akrambek))
+- fix: kafka header extraction expression in composite zilla.yaml [\#1362](https://github.com/aklivity/zilla/pull/1362) ([ankitk-me](https://github.com/ankitk-me))
+- Support GSS encrypt request decoding as part of psql 14.15 client [\#1361](https://github.com/aklivity/zilla/pull/1361) ([akrambek](https://github.com/akrambek))
+- Zfunction and Zstream support [\#1354](https://github.com/aklivity/zilla/pull/1354) ([akrambek](https://github.com/akrambek))
+
+## [0.9.115](https://github.com/aklivity/zilla/tree/0.9.115) (2024-12-26)
+
+[Full Changelog](https://github.com/aklivity/zilla/compare/0.9.114...0.9.115)
 
 **Merged pull requests:**
 

diff --git a/build/flyweight-maven-plugin/pom.xml b/build/flyweight-maven-plugin/pom.xml
@@ -8,7 +8,7 @@
   <parent>
     <groupId>io.aklivity.zilla</groupId>
     <artifactId>build</artifactId>
-    <version>0.9.115</version>
+    <version>0.9.116</version>
     <relativePath>../pom.xml</relativePath>
   </parent>
 

diff --git a/build/pom.xml b/build/pom.xml
@@ -8,7 +8,7 @@
   <parent>
     <groupId>io.aklivity.zilla</groupId>
     <artifactId>zilla</artifactId>
-    <version>0.9.115</version>
+    <version>0.9.116</version>
     <relativePath>../pom.xml</relativePath>
   </parent>
 

diff --git a/cloud/docker-image/pom.xml b/cloud/docker-image/pom.xml
@@ -8,7 +8,7 @@
   <parent>
     <groupId>io.aklivity.zilla</groupId>
     <artifactId>cloud</artifactId>
-    <version>0.9.115</version>
+    <version>0.9.116</version>
     <relativePath>../pom.xml</relativePath>
   </parent>
 

diff --git a/cloud/helm-chart/pom.xml b/cloud/helm-chart/pom.xml
@@ -8,7 +8,7 @@
   <parent>
     <groupId>io.aklivity.zilla</groupId>
     <artifactId>cloud</artifactId>
-    <version>0.9.115</version>
+    <version>0.9.116</version>
     <relativePath>../pom.xml</relativePath>
   </parent>
 

diff --git a/cloud/pom.xml b/cloud/pom.xml
@@ -8,7 +8,7 @@
   <parent>
     <groupId>io.aklivity.zilla</groupId>
     <artifactId>zilla</artifactId>
-    <version>0.9.115</version>
+    <version>0.9.116</version>
     <relativePath>../pom.xml</relativePath>
   </parent>
 

diff --git a/conf/pom.xml b/conf/pom.xml
@@ -8,7 +8,7 @@
   <parent>
     <groupId>io.aklivity.zilla</groupId>
     <artifactId>zilla</artifactId>
-    <version>0.9.115</version>
+    <version>0.9.116</version>
     <relativePath>../pom.xml</relativePath>
   </parent>
 

diff --git a/incubator/binding-amqp.spec/pom.xml b/incubator/binding-amqp.spec/pom.xml
@@ -8,7 +8,7 @@
   <parent>
     <groupId>io.aklivity.zilla</groupId>
     <artifactId>incubator</artifactId>
-    <version>0.9.115</version>
+    <version>0.9.116</version>
     <relativePath>../pom.xml</relativePath>
   </parent>
 

diff --git a/incubator/binding-amqp/pom.xml b/incubator/binding-amqp/pom.xml
@@ -8,7 +8,7 @@
   <parent>
     <groupId>io.aklivity.zilla</groupId>
     <artifactId>incubator</artifactId>
-    <version>0.9.115</version>
+    <version>0.9.116</version>
     <relativePath>../pom.xml</relativePath>
   </parent>
 

diff --git a/incubator/binding-pgsql-kafka.spec/pom.xml b/incubator/binding-pgsql-kafka.spec/pom.xml
@@ -8,7 +8,7 @@
   <parent>
     <groupId>io.aklivity.zilla</groupId>
     <artifactId>incubator</artifactId>
-    <version>0.9.115</version>
+    <version>0.9.116</version>
     <relativePath>../pom.xml</relativePath>
   </parent>
 

diff --git a/incubator/binding-pgsql-kafka/pom.xml b/incubator/binding-pgsql-kafka/pom.xml
@@ -8,7 +8,7 @@
   <parent>
     <groupId>io.aklivity.zilla</groupId>
     <artifactId>incubator</artifactId>
-    <version>0.9.115</version>
+    <version>0.9.116</version>
     <relativePath>../pom.xml</relativePath>
   </parent>
 

diff --git a/incubator/binding-pgsql.spec/pom.xml b/incubator/binding-pgsql.spec/pom.xml
@@ -8,7 +8,7 @@
   <parent>
     <groupId>io.aklivity.zilla</groupId>
     <artifactId>incubator</artifactId>
-    <version>0.9.115</version>
+    <version>0.9.116</version>
     <relativePath>../pom.xml</relativePath>
   </parent>
 

diff --git a/.../pgsql/alter.stream.add.column/client.rpt → ...pplication/gss.encrypt.request/client.rpt b/.../pgsql/alter.stream.add.column/client.rpt → ...pplication/gss.encrypt.request/client.rpt
@@ -17,39 +17,15 @@ connect "zilla://streams/app0"
     option zilla:window 8192
     option zilla:transmission "duplex"
 
-
 write zilla:begin.ext ${pgsql:beginEx()
                               .typeId(zilla:id("pgsql"))
-                              .parameter("user", "zillabase")
+                              .parameter("user", "root")
                               .parameter("database", "dev")
                               .parameter("application_name", "psql")
                               .parameter("client_encoding", "UTF8")
                               .build()}
 
 connected
 
-write zilla:data.ext ${pgsql:dataEx()
-                              .typeId(zilla:id("pgsql"))
-                               .query()
-                                .build()
-                              .build()}
-write "ALTER STREAM cities ADD COLUMN zip INT;"
-      [0x00]
-write flush
-
-read advised zilla:flush ${pgsql:flushEx()
-                              .typeId(zilla:id("pgsql"))
-                              .completion()
-                                .tag("ALTER_STREAM")
-                                .build()
-                              .build()}
-
-read advised zilla:flush ${pgsql:flushEx()
-                              .typeId(zilla:id("pgsql"))
-                              .ready()
-                                .status("IDLE")
-                                .build()
-                              .build()}
-
-write close
 read closed
+write close
diff --git a/.../pgsql/alter.stream.add.column/server.rpt → ...pplication/gss.encrypt.request/server.rpt b/.../pgsql/alter.stream.add.column/server.rpt → ...pplication/gss.encrypt.request/server.rpt
@@ -13,44 +13,23 @@
 # specific language governing permissions and limitations under the License.
 #
 
-accept "zilla://streams/app0"
+property serverAddress "zilla://streams/app0"
+
+accept ${serverAddress}
     option zilla:window 8192
     option zilla:transmission "duplex"
 
 accepted
 
 read zilla:begin.ext ${pgsql:beginEx()
                               .typeId(zilla:id("pgsql"))
-                              .parameter("user", "zillabase")
+                              .parameter("user", "root")
                               .parameter("database", "dev")
                               .parameter("application_name", "psql")
                               .parameter("client_encoding", "UTF8")
                               .build()}
 
 connected
 
-read zilla:data.ext ${pgsql:dataEx()
-                              .typeId(zilla:id("pgsql"))
-                              .query()
-                                .build()
-                              .build()}
-read  "ALTER STREAM cities ADD COLUMN zip INT;"
-      [0x00]
-
-write advise zilla:flush ${pgsql:flushEx()
-                              .typeId(zilla:id("pgsql"))
-                              .completion()
-                                .tag("ALTER_STREAM")
-                                .build()
-                              .build()}
-
-write notify CREATE_TOPIC_COMPLETED
-
-write advise zilla:flush ${pgsql:flushEx()
-                              .typeId(zilla:id("pgsql"))
-                              .ready()
-                                .status("IDLE")
-                                .build()
-                              .build()}
-read closed
 write close
+read closed
diff --git a/...ipts/io/aklivity/zilla/specs/binding/pgsql/streams/network/gss.encrypt.request/client.rpt b/...ipts/io/aklivity/zilla/specs/binding/pgsql/streams/network/gss.encrypt.request/client.rpt
@@ -0,0 +1,85 @@
+#
+# Copyright 2021-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.
+#
+
+property networkConnectWindow 8192
+
+connect "zilla://streams/net0"
+  option zilla:window ${networkConnectWindow}
+  option zilla:transmission "duplex"
+  option zilla:byteorder "network"
+
+connected
+
+write 8                                 # length
+      [0x04 0xd2 0x16 0x30]             # gss encrypt request code
+
+read [0x4e]
+
+write 8                                 # length
+      [0x04 0xd2 0x16 0x2f]             # ssl request code
+
+read [0x4e]
+
+write 75                                # length
+      3s                                # major version
+      0s                                # minor version
+      "user" [0x00]                     # name
+      "root" [0x00]                     # value
+      "database" [0x00]                 # name
+      "dev" [0x00]                      # value
+      "application_name" [0x00]         # name
+      "psql" [0x00]                     # value
+      "client_encoding" [0x00]          # name
+      "UTF8" [0x00]                     # value
+      [0x00]                            # end of parameters
+
+read [0x52]                             # type R
+     8                                  # length
+     0                                  # authentication type
+
+read [0x4b]                             # type K
+     12                                 # length
+     0                                  # pid
+     0                                  # key
+
+read [0x53]                                 # type S
+     25                                     # length
+     "client_encoding" [0x00]               # name
+     "UTF8" [0x00]                          # value
+
+read [0x53]                                 # type S
+     35                                     # length
+     "standard_conforming_strings" [0x00]   # name
+     [0x6f 0x6e 0x00]                       # value
+
+read [0x53]                                 # type S
+     25                                     # length
+     "server_version" [0x00]                # name
+     "9.1.0" [0x00]                         # value
+
+read [0x53]                                 # type S
+     27                                     # length
+     "application_name" [0x00]              # name
+     "zilla" [0x00]                         # value
+
+read [0x5a]                             # type Z
+     5                                  # length
+     [0x49]                             # status
+
+read [0x58]                             # type X
+     4                                  # length
+
+read closed
+write close
diff --git a/...ipts/io/aklivity/zilla/specs/binding/pgsql/streams/network/gss.encrypt.request/server.rpt b/...ipts/io/aklivity/zilla/specs/binding/pgsql/streams/network/gss.encrypt.request/server.rpt
@@ -0,0 +1,87 @@
+#
+# Copyright 2021-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.
+#
+
+property networkAcceptWindow 8192
+
+accept "zilla://streams/net0"
+  option zilla:window ${networkAcceptWindow}
+  option zilla:transmission "duplex"
+  option zilla:byteorder "network"
+
+accepted
+
+connected
+
+read 8                                 # length
+     [0x04 0xd2 0x16 0x30]             # gss encrypt request code
+
+write [0x4e]
+
+read 8                                 # length
+     [0x04 0xd2 0x16 0x2f]             # ssl request code
+
+write [0x4e]
+
+read  75                                # length
+      3s                                # major version
+      0s                                # minor version
+      "user" [0x00]                     # name
+      "root" [0x00]                     # value
+      "database" [0x00]                 # name
+      "dev" [0x00]                      # value
+      "application_name" [0x00]         # name
+      "psql" [0x00]                     # value
+      "client_encoding" [0x00]          # name
+      "UTF8" [0x00]                     # value
+      [0x00]                            # end of parameters
+
+write [0x52]                             # type R
+      8                                  # length
+      0                                  # authentication type
+
+write [0x4b]                             # type K
+      12                                 # length
+      0                                  # pid
+      0                                  # key
+
+write [0x53]                                 # type S
+      25                                     # length
+      "client_encoding" [0x00]               # name
+      "UTF8" [0x00]                          # value
+
+write [0x53]                                 # type S
+      35                                     # length
+      "standard_conforming_strings" [0x00]   # name
+      [0x6f 0x6e 0x00]                       # value
+
+write [0x53]                                 # type S
+      25                                     # length
+      "server_version" [0x00]                # name
+      "9.1.0" [0x00]                         # value
+
+write [0x53]                                 # type S
+      27                                     # length
+      "application_name" [0x00]              # name
+      "zilla" [0x00]                         # value
+
+write [0x5a]                             # type Z
+      5                                  # length
+      [0x49]                             # status
+
+write [0x58]                             # type X
+      4                                  # length
+
+write close
+read closed