IPC test

tests/js/index.test.ts

@@ -2,7 +2,8 @@ import * as wasm from "../../pkg/node/parquet_wasm";
 
 wasm.setPanicHook();
 
-import "./read-write.test";
 import "./ffi.test";
 import "./geo-metadata.test";
+import "./ipc.test";
+import "./read-write.test";
 import "./schema.test";

tests/js/ipc.test.ts

@@ -0,0 +1,20 @@
+import { tableFromArrays, tableToIPC } from "apache-arrow";
+import { setPanicHook, Table } from "../../pkg/node/parquet_wasm";
+import { it } from "vitest";
+import { writeFileSync } from "fs";
+
+setPanicHook();
+
+it("should read IPC stream correctly", async (t) => {
+  const table = tableFromArrays({
+    column: [
+      [1, 2],
+      [3, 4],
+    ],
+  });
+  console.log(table.schema);
+  const ipc = tableToIPC(table, "stream");
+  writeFileSync("data.arrows", ipc);
+
+  Table.fromIPCStream(ipc);
+});