test(jco): add test for stream lift of list<u8>

Author: vados-cosmonic

crates/test-components/src/bin/stream_tx.rs

@@ -110,6 +110,10 @@ impl bindings::exports::jco::test_components::get_stream_async::Guest for Compon
         stream_values_async(vals)
     }
 
+    async fn get_stream_list_u8(vals: Vec<Vec<u8>>) -> Result<StreamReader<Vec<u8>>, String> {
+        stream_values_async(vals)
+    }
+
     async fn get_stream_list_string(
         vals: Vec<Vec<String>>,
     ) -> Result<StreamReader<Vec<String>>, String> {

crates/test-components/wit/all.wit

@@ -65,7 +65,7 @@ interface get-stream-async {
 
     get-stream-variant: async func(vals: list<example-variant>) -> result<stream<example-variant>, string>;
 
-    //get-stream-list-u8: async func(vals: list<list<u8>>) -> result<stream<list<u8>>, string>;
+    get-stream-list-u8: async func(vals: list<list<u8>>) -> result<stream<list<u8>>, string>;
     get-stream-list-string: async func(vals: list<list<string>>) -> result<stream<list<string>>, string>;
     get-stream-list-record: async func(vals: list<list<example-record>>) -> result<stream<list<example-record>>, string>;
     get-stream-fixed-list-u32: async func(vals: list<list<u32, 5>>) -> result<stream<list<u32, 5>>, string>;

packages/jco/test/p3/stream.js

@@ -220,6 +220,24 @@ suite("stream<T> lifts", () => {
         });
     });
 
+    test("list<u8>", async () => {
+        assert.instanceOf(instance["jco:test-components/get-stream-async"].getStreamListU8, AsyncFunction);
+        let vals = [[0x01, 0x02, 0x03, 0x04, 0x05], new Uint8Array([0x05, 0x04, 0x03, 0x02, 0x01]), []];
+        let stream = await instance["jco:test-components/get-stream-async"].getStreamListU8(vals);
+        await checkStreamValues({
+            stream,
+            vals,
+            typeName: "list<u8>",
+            assertEqFn: assert.deepEqual,
+            expectedValues: [
+                // TODO: wit type representation smoothing mismatch
+                vals[0],
+                [...vals[1]],
+                [],
+            ],
+        });
+    });
+
     test("list<string>", async () => {
         assert.instanceOf(instance["jco:test-components/get-stream-async"].getStreamListString, AsyncFunction);
         let vals = [["first", "second", "third"], []];
@@ -234,7 +252,7 @@ suite("stream<T> lifts", () => {
             [0, 0, 0, 0, 0],
         ];
         let stream = await instance["jco:test-components/get-stream-async"].getStreamFixedListU32(vals);
-        await checkStreamValues({ stream, vals, typeName: "list<string>", assertEqFn: assert.deepEqual });
+        await checkStreamValues({ stream, vals, typeName: "list<u32, 5>", assertEqFn: assert.deepEqual });
         // TODO: test misuse of fixed length list
     });