chore: Trying to fix the pipeline

sedaprotocol · Oct 2, 2023 · e622242 · e622242
1 parent cc6311e
commit e622242
Show file tree

Hide file tree

Showing 5 changed files with 23 additions and 9 deletions.
diff --git a/libs/as-sdk-integration-tests/src/http.test.ts b/libs/as-sdk-integration-tests/src/http.test.ts
@@ -6,13 +6,14 @@ import { PromiseStatus } from '../../../dist/libs/vm/src/types/vm-promise';
 
 const mockHttpFetch = jest.fn();
 
+jest.setTimeout(30_000);
+
 const TestVmAdapter = jest.fn().mockImplementation(() => {
   return { httpFetch: mockHttpFetch };
 });
 
 describe('Http', () => {
   it('Test SDK HTTP Rejection', async () => {
-
     const wasmBinary = await readFile('dist/libs/as-sdk-integration-tests/debug.wasm');
     const result = await callVm({
       args: ['testHttpRejection'],

diff --git a/libs/vm/src/vm-imports.ts b/libs/vm/src/vm-imports.ts
@@ -16,14 +16,18 @@ export default class VmImports {
   }
 
   httpFetch(action: number, actionLength: number) {
+    console.log("HTTP Action called");
     const rawAction = new Uint8Array(
       this.memory?.buffer.slice(action, action + actionLength) ?? []
     );
     const messageRaw = Buffer.from(rawAction).toString('utf-8');
 
+    console.log('HTTP Action called with ', messageRaw);
+
     try {
       const message: HttpFetchAction = JSON.parse(messageRaw);
       this.callResult = this.workerToHost.callActionOnHost(message);
+      console.log('We got a result: ', this.callResult);
       return this.callResult.length;
     } catch (error) {
       console.error(`@httpFetch: ${messageRaw}`, error);

diff --git a/libs/vm/src/vm.test.ts b/libs/vm/src/vm.test.ts
@@ -7,6 +7,8 @@ import { PromiseStatus } from "../../../dist/libs/vm/src/types/vm-promise";
 
 const mockHttpFetch = jest.fn();
 
+jest.setTimeout(10_000);
+
 const TestVmAdapter = jest.fn().mockImplementation(() => {
   return { httpFetch: mockHttpFetch };
 });

diff --git a/libs/vm/src/vm.ts b/libs/vm/src/vm.ts
@@ -34,7 +34,9 @@ export async function executeVm(callData: VmCallData, notifierBuffer: SharedArra
     const memory = instance.exports.memory;
     vmImports.setMemory(memory as WebAssembly.Memory);
 
+    console.log("Starting WASI");
     const exitCode = wasi.start(instance);
+    console.log("exit: ", exitCode);
 
     return {
       exitCode,
@@ -44,6 +46,7 @@ export async function executeVm(callData: VmCallData, notifierBuffer: SharedArra
       resultAsString: new TextDecoder().decode(vmImports.result),
     }
   } catch (err) {
+    console.log('Exception thrown', err);
     console.error(`
       @executeWasm
       Exception threw: ${err}

diff --git a/libs/vm/src/worker.ts b/libs/vm/src/worker.ts
@@ -7,15 +7,19 @@ import {
 } from './types/worker-messages.js';
 
 parentPort?.on('message', async function (event) {
-  const message: WorkerMessage = event;
+  try {
+    const message: WorkerMessage = event;
 
-  if (message.type === WorkerMessageType.VmCall) {
-    const result = await executeVm(message.callData, message.notifierBuffer);
-    const response: VmResultWorkerMessage = {
-      result,
-      type: WorkerMessageType.VmResult,
-    };
+    if (message.type === WorkerMessageType.VmCall) {
+      const result = await executeVm(message.callData, message.notifierBuffer);
+      const response: VmResultWorkerMessage = {
+        result,
+        type: WorkerMessageType.VmResult,
+      };
 
-    parentPort?.postMessage(response);
+      parentPort?.postMessage(response);
+    }
+  } catch (error) {
+    console.error("@worker:message, error thrown: ", error);
   }
 });