Fix quickstart examples

js-sdk-examples/hello-world/aqua/hello-world.aqua

@@ -0,0 +1,5 @@
+service HelloWorld("hello-world"):
+    hello(str: string)
+
+func sayHello():
+    HelloWorld.hello("Hello, world!")

js-sdk-examples/hello-world/package.json

@@ -0,0 +1,23 @@
+{
+  "name": "hello-world",
+  "version": "1.0.0",
+  "description": "",
+  "main": "index.js",
+  "scripts": {
+    "exec": "node -r ts-node/register src/index.ts",
+    "compile-aqua": "aqua --import . -i ./aqua/ -o ./src/_aqua",
+    "watch-aqua": "chokidar \"**/*.aqua\" -c \"npm run compile-aqua\""
+  },
+  "author": "",
+  "license": "ISC",
+  "devDependencies": {
+    "@fluencelabs/aqua": "^0.3.0-222",
+    "chokidar-cli": "^3.0.0",
+    "ts-node": "^10.2.1",
+    "typescript": "^4.4.2"
+  },
+  "dependencies": {
+    "@fluencelabs/fluence": "0.11.0",
+    "@fluencelabs/fluence-network-environment": "1.0.10"
+  }
+}

js-sdk-examples/hello-world/src/_aqua/hello-world.ts

@@ -0,0 +1,139 @@
+/**
+ *
+ * This file is auto-generated. Do not edit manually: changes may be erased.
+ * Generated by Aqua compiler: https://github.com/fluencelabs/aqua/. 
+ * If you find any bugs, please write an issue on GitHub: https://github.com/fluencelabs/aqua/issues
+ * Aqua version: 0.3.0-222
+ *
+ */
+import { FluencePeer } from '@fluencelabs/fluence';
+import {
+    ResultCodes,
+    RequestFlow,
+    RequestFlowBuilder,
+    CallParams,
+} from '@fluencelabs/fluence/dist/internal/compilerSupport/v1';
+
+
+// Services
+
+ export interface HelloWorldDef {
+     hello: (str: string, callParams: CallParams<'str'>) => void;
+ }
+
+ export function registerHelloWorld(service: HelloWorldDef): void;
+export function registerHelloWorld(serviceId: string, service: HelloWorldDef): void;
+export function registerHelloWorld(peer: FluencePeer, service: HelloWorldDef): void;
+export function registerHelloWorld(peer: FluencePeer, serviceId: string, service: HelloWorldDef): void;
+ export function registerHelloWorld(...args) {
+    let peer: FluencePeer;
+    let serviceId;
+    let service;
+    if (args[0] instanceof FluencePeer) {
+        peer = args[0];
+    } else {
+        peer = FluencePeer.default;
+    }
+
+    if (typeof args[0] === 'string') {
+        serviceId = args[0];
+    } else if (typeof args[1] === 'string') {
+        serviceId = args[1];
+    }  
+ else {
+     serviceId = "hello-world"
+}
+
+    if (!(args[0] instanceof FluencePeer) && typeof args[0] === 'object') {
+        service = args[0];
+    } else if (typeof args[1] === 'object') {
+        service = args[1];
+    } else {
+        service = args[2];
+    }
+
+      peer.internals.callServiceHandler.use((req, resp, next) => {
+          if (req.serviceId !== serviceId) {
+              next();
+              return;
+          }
+  
+          
+ if (req.fnName === 'hello') {
+     
+ const callParams = {
+     ...req.particleContext,
+     tetraplets: {
+         str: req.tetraplets[0]
+     },
+ };
+ resp.retCode = ResultCodes.success;
+ service.hello(req.args[0], callParams); resp.result = {}
+
+ }
+    
+  
+          next();
+      });
+ }
+      
+
+// Functions
+
+ export function sayHello(config?: {ttl?: number}) : Promise<void>;
+ export function sayHello(peer: FluencePeer, config?: {ttl?: number}) : Promise<void>;
+ export function sayHello(...args) {
+     let peer: FluencePeer;
+     
+     let config;
+     if (args[0] instanceof FluencePeer) {
+         peer = args[0];
+         config = args[1];
+     } else {
+         peer = FluencePeer.default;
+         config = args[0];
+     }
+    
+     let request: RequestFlow;
+     const promise = new Promise<void>((resolve, reject) => {
+         const r = new RequestFlowBuilder()
+                 .disableInjections()
+                 .withRawScript(
+                     `
+     (xor
+ (seq
+  (call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-)
+  (call %init_peer_id% ("hello-world" "hello") ["Hello, world!"])
+ )
+ (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1])
+)
+
+                 `,
+                 )
+                 .configHandler((h) => {
+                     h.on('getDataSrv', '-relay-', () => {
+                    return peer.connectionInfo.connectedRelay ;
+                });
+                
+                h.onEvent('callbackSrv', 'response', (args) => {
+  
+});
+
+                h.onEvent('errorHandlingSrv', 'error', (args) => {
+                    const [err] = args;
+                    reject(err);
+                });
+            })
+            .handleScriptError(reject)
+            .handleTimeout(() => {
+                reject('Request timed out for sayHello');
+            })
+        if(config && config.ttl) {
+            r.withTTL(config.ttl)
+        }
+        request = r.build();
+    });
+    peer.internals.initiateFlow(request!);
+    return Promise.race([promise, Promise.resolve()]);
+}
+      

js-sdk-examples/hello-world/src/index.ts

@@ -0,0 +1,18 @@
+import { FluencePeer } from "@fluencelabs/fluence";
+import { registerHelloWorld, sayHello } from "./_aqua/hello-world";
+
+async function main() {
+  await FluencePeer.default.init();
+
+  registerHelloWorld({
+    hello: async (str) => {
+      console.log(str);
+    },
+  });
+
+  await sayHello();
+
+  await FluencePeer.default.uninit();
+}
+
+main();

js-sdk-examples/hello-world/tsconfig.json

@@ -0,0 +1,7 @@
+{
+  "compilerOptions": {
+    "target": "ES2015",
+    "module": "CommonJS",
+    "skipLibCheck": true
+  }
+}