feat: use marine-js 0.7.2 (#321)

* use marine-js 0.5.0

* increace some timeouts

* increace some timeouts

* use latest marine + remove larger timeouts

* propagate CallParameters type

* use marine 0.7.2

* Temp use node 18 and 20

* Comment out node 20.x

---------

Co-authored-by: Anatoly Laskaris <github_me@nahsi.dev>

Author: ValeryAntopol

.github/workflows/tests.yml

@@ -37,8 +37,8 @@ jobs:
     strategy:
       matrix:
         node-version:
-          - 16.x
           - 18.x
+          # - 20.x
 
     steps:
       - name: Import secrets

packages/client/api/package.json

@@ -29,7 +29,7 @@
     },
     "devDependencies": {
         "@fluencelabs/avm": "0.43.1",
-        "@fluencelabs/marine-js": "0.3.45",
+        "@fluencelabs/marine-js": "0.7.2",
         "microbundle": "0.15.1",
         "dts-bundle-generator": "7.2.0"
     }

packages/client/js-client.node/package.json

@@ -25,7 +25,7 @@
         "@fluencelabs/js-peer": "0.9.1",
         "@fluencelabs/interfaces": "0.8.1",
         "@fluencelabs/avm": "0.43.1",
-        "@fluencelabs/marine-js": "0.3.45",
+        "@fluencelabs/marine-js": "0.7.2",
         "platform": "1.3.6"
     },
     "devDependencies": {

packages/client/js-client.web.standalone/package.json

@@ -23,7 +23,7 @@
     },
     "devDependencies": {
         "@fluencelabs/avm": "0.43.1",
-        "@fluencelabs/marine-js": "0.3.45",
+        "@fluencelabs/marine-js": "0.7.2",
         "@types/node": "16.11.59",
         "@types/jest": "28.1.0",
         "jest": "28.1.0",

packages/core/interfaces/package.json

@@ -51,6 +51,6 @@
     "devDependencies": {
         "@multiformats/multiaddr": "11.3.0",
         "@fluencelabs/avm": "0.43.1",
-        "@fluencelabs/marine-js": "0.3.45"
+        "@fluencelabs/marine-js": "0.7.2"
     }
 }

packages/core/js-peer/package.json

@@ -19,7 +19,7 @@
     "dependencies": {
         "@fluencelabs/interfaces": "0.8.1",
         "@fluencelabs/avm": "0.43.1",
-        "@fluencelabs/marine-js": "0.3.45",
+        "@fluencelabs/marine-js": "0.7.2",
         "multiformats": "11.0.1",
         "debug": "4.3.4",
         "async": "3.2.4",

packages/core/js-peer/src/jsPeer/FluencePeer.ts

@@ -25,6 +25,7 @@ import {
     ParticleExecutionStage,
     ParticleQueueItem,
 } from '../particle/Particle.js';
+import { defaultCallParameters } from "@fluencelabs/marine-js/dist/types"
 import { jsonify, isString } from '../util/utils.js';
 import { concatMap, filter, pipe, Subject, tap, Unsubscribable } from 'rxjs';
 import { defaultSigGuard, Sig } from '../services/Sig.js';
@@ -184,7 +185,7 @@ export abstract class FluencePeer {
                     new Error("Can't use avm: peer is not initialized");
                 }
 
-                const res = await this.marineHost.callService('avm', 'ast', [air], undefined);
+                const res = await this.marineHost.callService('avm', 'ast', [air], defaultCallParameters);
                 if (!isString(res)) {
                     throw new Error(`Call to avm:ast expected to return string. Actual return: ${res}`);
                 }
@@ -521,7 +522,8 @@ export abstract class FluencePeer {
         log_particle.trace('id %s. executing call service handler %j', particleId, req);
 
         if (this.marineHost && this.marineHost.hasService(req.serviceId)) {
-            const result = await this.marineHost.callService(req.serviceId, req.fnName, req.args, undefined);
+            // TODO build correct CallParameters instead of default ones
+            const result = await this.marineHost.callService(req.serviceId, req.fnName, req.args, defaultCallParameters);
 
             return {
                 retCode: ResultCodes.success,

packages/core/js-peer/src/jsPeer/avm.ts

@@ -16,6 +16,7 @@
 import type { CallResultsArray, InterpreterResult, RunParameters } from '@fluencelabs/avm';
 import { deserializeAvmResult, serializeAvmArgs } from '@fluencelabs/avm';
 import { IAvmRunner, IMarineHost, IWasmLoader } from '../marine/interfaces.js';
+import { defaultCallParameters } from "@fluencelabs/marine-js/dist/types"
 
 export class MarineBasedAvmRunner implements IAvmRunner {
     constructor(private marine: IMarineHost, private avmWasmLoader: IWasmLoader) {}
@@ -31,7 +32,7 @@ export class MarineBasedAvmRunner implements IAvmRunner {
 
         let avmCallResult: InterpreterResult | Error;
         try {
-            const res = await this.marine.callService('avm', 'invoke', args, undefined);
+            const res = await this.marine.callService('avm', 'invoke', args, defaultCallParameters);
             avmCallResult = deserializeAvmResult(res);
         } catch (e) {
             avmCallResult = e instanceof Error ? e : new Error((e as any).toString());

packages/core/js-peer/src/marine/interfaces.ts

@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 import { CallResultsArray, InterpreterResult, RunParameters } from '@fluencelabs/avm';
-import { IStartable, JSONArray, JSONObject } from '../util/commonTypes.js';
+import { IStartable, JSONArray, JSONObject, CallParameters } from '../util/commonTypes.js';
 import { Buffer } from 'buffer';
 // @ts-ignore
 import type { WorkerImplementation } from 'threads/dist/types/master';
@@ -45,7 +45,7 @@ export interface IMarineHost extends IStartable {
         serviceId: string,
         functionName: string,
         args: JSONArray | JSONObject,
-        callParams: any,
+        callParams: CallParameters,
     ): Promise<unknown>;
 }
 

packages/core/js-peer/src/marine/worker-script/index.ts

@@ -15,8 +15,8 @@
  */
 
 import { MarineService } from '@fluencelabs/marine-js/dist/MarineService';
-import type { Env, MarineServiceConfig } from '@fluencelabs/marine-js/dist/config';
-import type { JSONArray, JSONObject, LogMessage } from '@fluencelabs/marine-js/dist/types';
+import type { Env, MarineModuleConfig, MarineServiceConfig, ModuleDescriptor } from '@fluencelabs/marine-js/dist/config'
+import type { JSONArray, JSONObject, LogMessage, CallParameters } from '@fluencelabs/marine-js/dist/types';
 import { Buffer } from 'buffer';
 // @ts-ignore
 import { Observable, Subject } from 'threads/observable';
@@ -26,6 +26,26 @@ import { expose } from 'threads/worker';
 let marineServices = new Map<string, MarineService>();
 let controlModule: WebAssembly.Module | undefined;
 
+const createSimpleModuleDescriptor = (name: string, envs?: Env): ModuleDescriptor => {
+    return {
+        import_name: name,
+        config: {
+            logger_enabled: true,
+            logging_mask: 0,
+            wasi: {
+                envs: {...envs},
+                preopened_files: new Set(),
+                mapped_dirs: new Map,
+            }
+        }
+    }
+}
+const createSimpleMarineService = (name: string, env? : Env): MarineServiceConfig => {
+    return {
+        modules_config: [createSimpleModuleDescriptor(name, env)],
+    }
+}
+
 const onLogMessage = new Subject<LogMessage>();
 
 const asArray = (buf: SharedArrayBuffer | Buffer) => {
@@ -40,20 +60,20 @@ const toExpose = {
     createService: async (
         wasm: SharedArrayBuffer | Buffer,
         serviceId: string,
-        marineConfig?: MarineServiceConfig,
         envs?: Env,
     ): Promise<void> => {
         if (!controlModule) {
             throw new Error('MarineJS is not initialized. To initialize call `init` function');
         }
 
-        const service = await WebAssembly.compile(asArray(wasm));
+        const marineConfig = createSimpleMarineService(serviceId, envs);
+        const modules = {[serviceId]: new Uint8Array(wasm)}
         const srv = new MarineService(
             controlModule,
-            service,
             serviceId,
             onLogMessage.next.bind(onLogMessage),
             marineConfig,
+            modules,
             envs,
         );
         await srv.init();
@@ -67,7 +87,7 @@ const toExpose = {
         onLogMessage.complete();
     },
 
-    callService: (serviceId: string, functionName: string, args: JSONArray | JSONObject, callParams: any): unknown => {
+    callService: (serviceId: string, functionName: string, args: JSONArray | JSONObject, callParams: CallParameters): unknown => {
         const srv = marineServices.get(serviceId);
         if (!srv) {
             throw new Error(`service with id=${serviceId} not found`);