Split protocol testing into separate ITs for zilla dump command

incubator/command-dump/pom.xml

@@ -43,16 +43,32 @@
       <version>${project.version}</version>
       <scope>provided</scope>
     </dependency>
+    <dependency>
+      <groupId>${project.groupId}</groupId>
+      <artifactId>engine</artifactId>
+      <type>test-jar</type>
+      <version>${project.version}</version>
+      <scope>test</scope>
+    </dependency>
+    <dependency>
+      <groupId>junit</groupId>
+      <artifactId>junit</artifactId>
+      <scope>test</scope>
+    </dependency>
     <dependency>
       <groupId>${project.groupId}</groupId>
       <artifactId>command</artifactId>
       <version>${project.version}</version>
       <scope>provided</scope>
     </dependency>
     <dependency>
-      <groupId>io.aklivity.zilla</groupId>
-      <artifactId>binding-proxy.spec</artifactId>
-      <version>${project.version}</version>
+      <groupId>org.kaazing</groupId>
+      <artifactId>k3po.junit</artifactId>
+      <scope>test</scope>
+    </dependency>
+    <dependency>
+      <groupId>org.kaazing</groupId>
+      <artifactId>k3po.lang</artifactId>
       <scope>test</scope>
     </dependency>
     <dependency>
@@ -99,25 +115,26 @@
     </dependency>
     <dependency>
       <groupId>io.aklivity.zilla</groupId>
-      <artifactId>binding-amqp.spec</artifactId>
+      <artifactId>binding-proxy.spec</artifactId>
       <version>${project.version}</version>
       <scope>test</scope>
     </dependency>
     <dependency>
-      <groupId>org.junit.jupiter</groupId>
-      <artifactId>junit-jupiter-engine</artifactId>
+      <groupId>io.aklivity.zilla</groupId>
+      <artifactId>binding-amqp.spec</artifactId>
+      <version>${project.version}</version>
       <scope>test</scope>
     </dependency>
     <dependency>
-      <groupId>org.testcontainers</groupId>
-      <artifactId>testcontainers</artifactId>
-      <version>1.19.3</version>
+      <groupId>io.aklivity.zilla</groupId>
+      <artifactId>binding-tls.spec</artifactId>
+      <version>${project.version}</version>
       <scope>test</scope>
     </dependency>
     <dependency>
       <groupId>org.testcontainers</groupId>
-      <artifactId>junit-jupiter</artifactId>
-      <version>1.19.3</version>
+      <artifactId>testcontainers</artifactId>
+      <version>1.19.7</version>
       <scope>test</scope>
     </dependency>
     <dependency>
@@ -143,9 +160,9 @@
         <artifactId>license-maven-plugin</artifactId>
         <configuration>
           <excludes>
-            <exclude>src/test/resources/io/aklivity/zilla/runtime/command/dump/internal/airline/*.pcap</exclude>
-            <exclude>src/test/resources/io/aklivity/zilla/runtime/command/dump/internal/airline/*.txt</exclude>
-            <exclude>src/test/resources/io/aklivity/zilla/runtime/command/dump/internal/airline/engine/*</exclude>
+            <exclude>src/test/resources/io/aklivity/zilla/runtime/command/dump/internal/*.txt</exclude>
+            <exclude>**/keys</exclude>
+            <exclude>**/trust</exclude>
           </excludes>
         </configuration>
       </plugin>
@@ -164,6 +181,23 @@
         <groupId>org.moditect</groupId>
         <artifactId>moditect-maven-plugin</artifactId>
       </plugin>
+      <plugin>
+        <groupId>org.kaazing</groupId>
+        <artifactId>k3po-maven-plugin</artifactId>
+        <dependencies>
+          <dependency>
+            <groupId>${project.groupId}</groupId>
+            <artifactId>engine</artifactId>
+            <version>${project.version}</version>
+            <type>test-jar</type>
+          </dependency>
+          <dependency>
+            <groupId>${project.groupId}</groupId>
+            <artifactId>engine</artifactId>
+            <version>${project.version}</version>
+          </dependency>
+        </dependencies>
+      </plugin>
       <plugin>
         <groupId>org.apache.maven.plugins</groupId>
         <artifactId>maven-failsafe-plugin</artifactId>
@@ -227,6 +261,9 @@
           <include>**/zilla.lua</include>
         </includes>
       </resource>
+      <resource>
+        <directory>src/main/scripts</directory>
+      </resource>
     </resources>
   </build>
 </project>

incubator/command-dump/src/main/java/io/aklivity/zilla/runtime/command/dump/internal/airline/ZillaDumpCommand.java

@@ -191,7 +191,7 @@ public final class ZillaDumpCommand extends ZillaCommand
         hidden = true)
     public boolean exceptions;
 
-    boolean continuous = true;
+    public boolean continuous = true;
 
     private final FrameFW frameRO = new FrameFW();
     private final BeginFW beginRO = new BeginFW();

incubator/command-dump/src/main/scripts/io/aklivity/zilla/runtime/command/dump/binding/amqp/streams/application/connect.as.receiver.only/client.rpt

@@ -0,0 +1,40 @@
+#
+# Copyright 2021-2023 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.
+#
+
+connect "zilla://streams/app0"
+        option zilla:ephemeral "test"
+        option zilla:timestamps "false"
+        option zilla:window 8192
+        option zilla:transmission "duplex"
+
+write zilla:begin.ext ${amqp:beginEx()
+                              .typeId(zilla:id("amqp"))
+                              .address("clients")
+                              .capabilities("RECEIVE_ONLY")
+                              .senderSettleMode("SETTLED")
+                              .receiverSettleMode("FIRST")
+                              .build()}
+
+read zilla:begin.ext ${amqp:beginEx()
+                             .typeId(zilla:id("amqp"))
+                             .address("clients")
+                             .capabilities("RECEIVE_ONLY")
+                             .senderSettleMode("SETTLED")
+                             .receiverSettleMode("FIRST")
+                             .build()}
+connected
+
+write close
+read closed

incubator/command-dump/src/main/scripts/io/aklivity/zilla/runtime/command/dump/binding/amqp/streams/application/connect.as.receiver.only/server.rpt

@@ -0,0 +1,41 @@
+#
+# Copyright 2021-2023 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.
+#
+
+accept "zilla://streams/app0"
+  option zilla:timestamps "false"
+  option zilla:window 8192
+  option zilla:transmission "duplex"
+
+accepted
+
+read zilla:begin.ext ${amqp:beginEx()
+                             .typeId(zilla:id("amqp"))
+                             .address("clients")
+                             .capabilities("RECEIVE_ONLY")
+                             .senderSettleMode("SETTLED")
+                             .receiverSettleMode("FIRST")
+                             .build()}
+
+write zilla:begin.ext ${amqp:beginEx()
+                              .typeId(zilla:id("amqp"))
+                              .address("clients")
+                              .capabilities("RECEIVE_ONLY")
+                              .senderSettleMode("SETTLED")
+                              .receiverSettleMode("FIRST")
+                              .build()}
+connected
+
+read closed
+write close

incubator/command-dump/src/main/scripts/io/aklivity/zilla/runtime/command/dump/binding/amqp/streams/network/link/attach.as.receiver.only/client.rpt

@@ -0,0 +1,116 @@
+#
+# Copyright 2021-2023 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.
+#
+
+connect "zilla://streams/net0"
+  option zilla:ephemeral "test"
+  option zilla:timestamps "false"
+  option zilla:window 8192
+  option zilla:transmission "duplex"
+
+connected
+
+# header exchange
+write "AMQP" [0x00 0x01 0x00 0x00]
+read "AMQP" [0x00 0x01 0x00 0x00]
+
+# open frame exchange
+write [0x00 0x00 0x00 0x16]                                      # size = 22
+      [0x02]                                                     # doff = 2
+      [0x00]                                                     # type = AMQP (0)
+      [0x00 0x00]                                                # channel = 0
+      [0x00 0x53 0x10]                                           # performative = open (16)
+      [0xc0 0x09 0x01]                                           # list type (LIST1), length = 9, fields = 1
+      [0xa1 0x06] "client"                                       # container-id = "client"
+
+read [0x00 0x00 0x00 0x16]                                       # size = 22
+     [0x02]                                                      # doff = 2
+     [0x00]                                                      # type = AMQP (0)
+     [0x00 0x00]                                                 # channel = 0
+     [0x00 0x53 0x10]                                            # performative = open (16)
+     [0xc0 0x09 0x01]                                            # list type (LIST1), length = 9, fields = 1
+     [0xa1 0x06] "server"                                        # container-id = "server"
+
+# begin frame exchange
+write [0x00 0x00 0x00 0x1b]                                      # size = 27
+      [0x02]                                                     # doff = 2
+      [0x00]                                                     # type = AMQP (0)
+      [0x00 0x00]                                                # channel = 0
+      [0x00 0x53 0x11]                                           # performative = begin (17)
+      [0xc0 0x0e 0x04]                                           # list type (list8), length = 14, fields = 4
+      [0x40]                                                     # remote-channel = null
+      [0x52 0x01]                                                # next-outgoing-id = 1
+      [0x70 0x00 0x00 0x07 0xff]                                 # incoming-window = 2047
+      [0x70 0x7f 0xff 0xff 0xff]                                 # outgoing-window = 2147483647
+
+read [0x00 0x00 0x00 0x1d]                                       # size = 29
+     [0x02]                                                      # doff = 2
+     [0x00]                                                      # type = AMQP (0)
+     [0x00 0x00]                                                 # channel = 0
+     [0x00 0x53 0x11]                                            # performative = begin (17)
+     [0xc0 0x10 0x04]                                            # list type (list8), length = 16, fields = 4
+     [0x60 0x00 0x00]                                            # remote-channel = 0
+     [0x52 0x01]                                                 # next-outgoing-id = 1
+     [0x70 0x00 0x01 0x00 0x00]                                  # incoming-window = 65536
+     [0x70 0x7f 0xff 0xff 0xff]                                  # outgoing-window = 2147483647
+
+# attach frame exchange
+write [0x00 0x00 0x00 0x2a]                                      # size = 42
+      [0x02]                                                     # doff = 2
+      [0x00]                                                     # type = AMQP (0)
+      [0x00 0x00]                                                # channel = 0
+      [0x00 0x53 0x12]                                           # performative = attach (18)
+      [0xc0 0x1d 0x06]                                           # list type (list8), length = 29, fields = 6
+      [0xa1 0x05] "link1"                                        # name = "link1"
+      [0x43]                                                     # handle = 0
+      [0x41]                                                     # role = receiver
+      [0x50 0x01]                                                # snd-settle-mode = settled
+      [0x50 0x00]                                                # rcv-settle-mode = first
+      [0x00 0x53 0x28]                                           # source
+      [0xc0 0x0a 0x01]                                           # list type (list8), length = 10, fields = 1
+      [0xa1 0x07] "clients"                                      # address = "clients"
+
+read [0x00 0x00 0x00 0x31]                                       # size = 49
+     [0x02]                                                      # doff = 2
+     [0x00]                                                      # type = AMQP (0)
+     [0x00 0x00]                                                 # channel = 0
+     [0x00 0x53 0x12]                                            # performative = attach (18)
+     [0xc0 0x24 0x0a]                                            # list type (list8), length = 36, fields = 10
+     [0xa1 0x05] "link1"                                         # name = "link1"
+     [0x43]                                                      # handle = 0
+     [0x42]                                                      # role = sender
+     [0x50 0x01]                                                 # snd-settle-mode = settled
+     [0x50 0x00]                                                 # rcv-settle-mode = first
+     [0x00 0x53 0x28]                                            # source
+     [0xc0 0x0a 0x01]                                            # list type (list8), length = 10, fields = 1
+     [0xa1 0x07] "clients"                                       # address = "clients"
+     [0x00 0x53 0x29 0x45]                                       # target = empty list
+     [0x40]                                                      # unsettled = null
+     [0x40]                                                      # incomplete-unsettled = null (default = false)
+     [0x43]                                                      # initial-delivery-count = 0
+
+# flow frame
+write [0x00 0x00 0x00 0x1c]                                      # size = 28
+      [0x02]                                                     # doff = 2
+      [0x00]                                                     # type = AMQP (0)
+      [0x00 0x00]                                                # channel = 0
+      [0x00 0x53 0x13]                                           # performative = flow (19)
+      [0xc0 0x0f 0x04]                                           # list type (list8), length = 15, fields = 4
+      [0x52 0x01]                                                # next-incoming-id = 1
+      [0x70 0x00 0x00 0x07 0xff]                                 # incoming-window = 2047
+      [0x52 0x01]                                                # next-outgoing-id = 1
+      [0x70 0x7f 0xff 0xff 0xff]                                 # outgoing-window = 2147483647
+
+write close
+read closed