Improve nodejs example

This commit is contained in:
Pavel Murygin 2021-09-07 03:22:08 +03:00
parent cc73c52025
commit 91b1b711aa
3 changed files with 34 additions and 12 deletions

View File

@ -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

View File

@ -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

View File

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