fix: Adds logging in case there are issues with wasm packs

Author: thecodedrift

src/lib/lifecycle/chunk.ts

@@ -81,7 +81,7 @@ export const chunk: LifecycleExecutor = async (
 
         await callbacks.onResult(pack, result);
         logger.debug(
-          `[${requestId}] (${LIFECYCLE_ID}) pack ${pack.name} completed`
+          `[${requestId}] (${LIFECYCLE_ID}) pack ${pack.name} completed (captured: ${Object.keys(result.capture ?? {}).length})`
         );
       } else {
         logger.debug(

src/lib/lifecycle/post.ts

@@ -51,7 +51,7 @@ export const post: LifecycleExecutor = async (
 
       await callbacks.onResult(pack, result);
       logger.debug(
-        `[${requestId}] (${LIFECYCLE_ID}) pack ${pack.name} completed`
+        `[${requestId}] (${LIFECYCLE_ID}) pack ${pack.name} completed (captured: ${Object.keys(result.capture ?? {}).length})`
       );
     } else {
       logger.debug(

src/lib/lifecycle/pre.ts

@@ -41,14 +41,17 @@ export const pre: LifecycleExecutor = async (
 
     if (output) {
       const result = output?.json() as PluginOutput;
+      logger.debug(
+        `[${requestId}] (${LIFECYCLE_ID}) pack ${pack.name} DATA: ${JSON.stringify(result)}`
+      );
 
       if (result.context) {
         context[`${index}`] = result.context;
       }
 
       await callbacks.onResult(pack, result);
       logger.debug(
-        `[${requestId}] (${LIFECYCLE_ID}) pack ${pack.name} completed`
+        `[${requestId}] (${LIFECYCLE_ID}) pack ${pack.name} completed (captured: ${Object.keys(result.capture ?? {}).length})`
       );
     } else {
       logger.debug(

src/lib/sandbox.ts

@@ -41,9 +41,11 @@ export const run = async (
   logger.debug(`[${requestId}] making request`);
   const finalizedRequest = request.clone();
   finalizedRequest.headers.set("x-tskl-bypass", "1");
-  const rawResponse = await fetch(finalizedRequest);
   await pre;
 
+  // resolve the pre hooks as late as possible
+  const [rawResponse] = await Promise.all([fetch(finalizedRequest), pre]);
+
   // GZIP headers are being handled by undici and must be stripped
   const newHeaders: Array<[string, string]> = [...rawResponse.headers.entries()]
     .map(([key, value]) => {

test/packs.spec.ts

@@ -60,7 +60,7 @@ describe("Loading packs", () => {
     });
 
     const t = taskless("test", {
-      // logLevel: "debug",
+      logLevel: "debug",
       logging: true,
       log: {
         data: logData,
@@ -113,18 +113,18 @@ describe("Loading packs", () => {
     await t.flush();
 
     const log = logs[0];
-    // console.log(JSON.stringify(logs, null, 2));
+    console.log(JSON.stringify(logs, null, 2));
 
     expect(
       log.dimensions.some(
-        (d) => d.name === "testpack/testPre" && d.value === "preTest"
+        (d) => d.name === "testpack/testPre" && d.value === "test_pre_value"
       ),
       "Logs pre test capture"
     ).toBe(true);
 
     expect(
       log.dimensions.some(
-        (d) => d.name === "testpack/testPost" && d.value === "postTest"
+        (d) => d.name === "testpack/testPost" && d.value === "test_post_value"
       ),
       "Logs post test capture"
     ).toBe(true);

test/wasm/manifest.json

@@ -1,9 +1,18 @@
 {
   "schema": "pre2",
   "name": "testpack",
-  "version": "0.0.1",
-  "description": "Test pack, never published to prod",
-  "permissions": {},
-  "fields": [],
+  "version": "0.0.4",
+  "description": "Test / example pack, never published to prod",
+  "permissions": {
+    "body": true
+  },
+  "fields": [
+    {
+      "name": "testField",
+      "type": "string",
+      "description": "Test field that should exist in the lifecycle",
+      "default": "test_field_value"
+    }
+  ],
   "charts": []
 }