chore(test): add test for multiple typegate instances for wasmedge sync mode

Author: destifo

.ghjk/lock.json

@@ -1,6 +1,6 @@
 {
   "version": "0",
-  "platform": "x86_64-linux",
+  "platform": "aarch64-darwin",
   "moduleEntries": {
     "ports": {
       "version": "0",
@@ -470,7 +470,6 @@
             "dd83a99f49f3f0fba11cdd014ff718cc9539316b",
             "4d1916871a40b6ac730709f7721f740df192c84d",
             "4df902463d60efc5b8e760ea4899f6ab6df0f16e",
-            "88f6aa5ddb513712623d31a17096ea26286064da",
             "40d9babcd5c8e79379e58dbc2f2a967ef68fbb09",
             "5549508f1f5eddf9cb2465f07cf0c7603dc0c849",
             "5c041a4209ae50657ea5acacc26683688f2913a9",
@@ -885,25 +884,6 @@
           },
           "packageName": "node-gyp"
         },
-        "88f6aa5ddb513712623d31a17096ea26286064da": {
-          "version": "v2.4.0",
-          "port": {
-            "ty": "denoWorker@v1",
-            "name": "mold_ghrel",
-            "platforms": [
-              "aarch64-linux",
-              "x86_64-linux"
-            ],
-            "version": "0.1.0",
-            "deps": [
-              {
-                "name": "tar_aa"
-              }
-            ],
-            "moduleSpecifier": "https://raw.githubusercontent.com/metatypedev/ghjk/423d38e/ports/mold.ts"
-          },
-          "replaceLd": false
-        },
         "40d9babcd5c8e79379e58dbc2f2a967ef68fbb09": {
           "version": "3.8.18",
           "port": {

typegate/tests/runtimes/wasmedge/wasmedge_sync_test.ts

@@ -65,26 +65,26 @@ Meta.test(
     const port = metaTest.port;
     const gate = `http://localhost:${port}`;
 
-    await metaTest.should("work after deploying artifact to S3", async () => {
-      const s3 = new S3Client(syncConfig.s3);
-      assertEquals((await listObjects(s3, syncConfig.s3Bucket))?.length, 0);
-
-      const { serialized, typegate: gateResponseAdd } = await tgDeploy(tg, {
-        baseUrl: gate,
-        auth,
-        artifactsConfig: {
-          prismaMigration: {
-            globalAction: {
-              create: true,
-              reset: false,
-            },
-            migrationDir: "prisma-migrations",
+    const { serialized, typegate: gateResponseAdd } = await tgDeploy(tg, {
+      baseUrl: gate,
+      auth,
+      artifactsConfig: {
+        prismaMigration: {
+          globalAction: {
+            create: true,
+            reset: false,
           },
-          dir: cwd,
+          migrationDir: "prisma-migrations",
         },
-        typegraphPath: path.join(cwd, "wasmedge.ts"),
-        secrets: {},
-      });
+        dir: cwd,
+      },
+      typegraphPath: path.join(cwd, "wasmedge.ts"),
+      secrets: {},
+    });
+
+    await metaTest.should("work after deploying artifact to S3", async () => {
+      const s3 = new S3Client(syncConfig.s3);
+      assertEquals((await listObjects(s3, syncConfig.s3Bucket))?.length, 2);
 
       assertExists(serialized, "serialized has a value");
       assertEquals(gateResponseAdd, {
@@ -109,6 +109,41 @@ Meta.test(
         })
         .on(engine);
 
+      await engine.terminate();
+      s3.destroy();
+    });
+
+    await metaTest.should("work with multiple typegate instances", async () => {
+      const s3 = new S3Client(syncConfig.s3);
+
+      // typegraphs are pushed to s3 whenever pushed to a typegate
+      assertEquals((await listObjects(s3, syncConfig.s3Bucket))?.length, 3);
+
+      const engine = await metaTest.engineFromDeployed(serialized);
+
+      await gql`
+      query {
+        test_wasi_ts(a: 11, b: 12)
+      }
+    `
+        .expectData({
+          test_wasi_ts: 23,
+        })
+        .on(engine);
+
+      // second engine on the other typegate instance
+      const engine2 = await metaTest.engineFromDeployed(serialized);
+
+      await gql`
+        query {
+          test_wasi_ts(a: 15, b: 2)
+        }
+      `
+        .expectData({
+          test_wasi_ts: 17,
+        })
+        .on(engine2);
+
       const { typegate: gateResponseRem } = await tgRemove(tg, {
         baseUrl: gate,
         auth,
@@ -117,63 +152,8 @@ Meta.test(
       assertEquals(gateResponseRem, { data: { removeTypegraphs: true } });
 
       await engine.terminate();
+      await engine2.terminate();
       s3.destroy();
     });
   },
 );
-
-// Meta.test(
-//   {
-//     name: "WasmEdge Runtime typescript SDK: Multiple typegate instances",
-//     syncConfig,
-//     async setup() {
-//       await cleanUp();
-//     },
-//     async teardown() {
-//       await cleanUp();
-//     },
-//     port: true,
-//     multipleTypegates: 3,
-//   },
-//   async (metaTest) => {
-//     const port = metaTest.port;
-//     const gate = `http://localhost:${port}`;
-//     await metaTest.should("work with multiple typegate instances", async () => {
-//       const s3 = new S3Client(syncConfig.s3);
-//       assertEquals((await listObjects(s3, syncConfig.s3Bucket))?.length, 0);
-
-//       const { serialized, typegate: _gateResponseAdd } = await tgDeploy(tg, {
-//         baseUrl: gate,
-//         auth,
-//         artifactsConfig: {
-//           prismaMigration: {
-//             globalAction: {
-//               create: true,
-//               reset: false,
-//             },
-//             migrationDir: "prisma-migrations",
-//           },
-//           dir: cwd,
-//         },
-//         typegraphPath: path.join(cwd, "wasmedge.ts"),
-//         secrets: {},
-//       });
-
-//       assertEquals((await listObjects(s3, syncConfig.s3Bucket))?.length, 1);
-
-//       const engine = await metaTest.engineFromDeployed(serialized);
-
-//       await gql`
-//       query {
-//         test_wasi_ts(a: 11, b: 2)
-//       }
-//     `
-//         .expectData({
-//           test_wasi_ts: 13,
-//         })
-//         .on(engine);
-//       await engine.terminate();
-//       s3.destroy();
-//     });
-//   },
-// );