From 91b1b711aa73ee467ff2abf1a1669cf017d34ea5 Mon Sep 17 00:00:00 2001 From: Pavel Murygin Date: Tue, 7 Sep 2021 03:22:08 +0300 Subject: [PATCH] Improve nodejs example --- js-sdk/node-example/aqua/calc.aqua | 7 ------- js-sdk/node-example/aqua/demoCall.aqua | 11 ++++++++++ js-sdk/node-example/src/index.ts | 28 +++++++++++++++++++++----- 3 files changed, 34 insertions(+), 12 deletions(-) create mode 100644 js-sdk/node-example/aqua/demoCall.aqua diff --git a/js-sdk/node-example/aqua/calc.aqua b/js-sdk/node-example/aqua/calc.aqua index 0a2b22e..6ec06eb 100644 --- a/js-sdk/node-example/aqua/calc.aqua +++ b/js-sdk/node-example/aqua/calc.aqua @@ -6,10 +6,3 @@ service Calc("calc"): reset() getResult() -> f32 -func demoCalculation() -> f32: - Calc.add(10) - Calc.multiply(5) - Calc.subtract(8) - Calc.divide(6) - res <- Calc.getResult() - <- res diff --git a/js-sdk/node-example/aqua/demoCall.aqua b/js-sdk/node-example/aqua/demoCall.aqua new file mode 100644 index 0000000..d3e1b89 --- /dev/null +++ b/js-sdk/node-example/aqua/demoCall.aqua @@ -0,0 +1,11 @@ +const peer ?= "12D3KooWLBkw4Tz8bRoSriy5WEpHyWfU11jEK3b5yCa7FBRDRWH3" +const relay ?= "12D3KooWSD5PToNiLQwKDXsu8JSysCwUt8BVUJEqCHcDe7P5h45e" + +func demoCalculation() -> f32: + on peer via relay + Calc.add(10) + Calc.multiply(5) + Calc.subtract(8) + Calc.divide(6) + res <- Calc.getResult() + <- res \ No newline at end of file diff --git a/js-sdk/node-example/src/index.ts b/js-sdk/node-example/src/index.ts index 41c90dc..fd076f2 100644 --- a/js-sdk/node-example/src/index.ts +++ b/js-sdk/node-example/src/index.ts @@ -1,5 +1,6 @@ import { FluencePeer } from "@fluencelabs/fluence"; -import { registerCalc, CalcDef, demoCalculation } from "./_aqua/calc"; +import { krasnodar } from "@fluencelabs/fluence-network-environment"; +import { registerCalc, CalcDef } from "./_aqua/calc"; class Calc implements CalcDef { private _state: number = 0; @@ -29,14 +30,31 @@ class Calc implements CalcDef { } } +const keypress = async () => { + process.stdin.setRawMode(true); + return new Promise((resolve) => + process.stdin.once("data", () => { + process.stdin.setRawMode(false); + resolve(); + }) + ); +}; + async function main() { - await FluencePeer.default.init(); + await FluencePeer.default.init({ + connectTo: krasnodar[0], + }); registerCalc(new Calc()); - const res = await demoCalculation(); - - console.log("Calculation result is: ", res); + console.log("application started"); + console.log("peer id is: ", FluencePeer.default.connectionInfo.selfPeerId); + console.log( + "relay is: ", + FluencePeer.default.connectionInfo.connectedRelays[0] + ); + console.log("press any key to continue"); + await keypress(); await FluencePeer.default.uninit(); }