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(); }