Update node example

This commit is contained in:
Pavel Murygin 2021-09-06 20:43:42 +03:00
parent 7fb2e540b2
commit cc73c52025
2 changed files with 22 additions and 47 deletions

View File

@ -3,7 +3,7 @@
* This file is auto-generated. Do not edit manually: changes may be erased. * This file is auto-generated. Do not edit manually: changes may be erased.
* Generated by Aqua compiler: https://github.com/fluencelabs/aqua/. * 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 * If you find any bugs, please write an issue on GitHub: https://github.com/fluencelabs/aqua/issues
* Aqua version: 0.2.0-SNAPSHOT * Aqua version: 0.2.2-SNAPSHOT
* *
*/ */
import { FluencePeer } from "@fluencelabs/fluence"; import { FluencePeer } from "@fluencelabs/fluence";
@ -16,47 +16,22 @@ import {
// Services // Services
export function registerCalc(service: { export interface CalcDef {
add: (n: number, callParams: CallParams<"n">) => Promise<void>; add: (n: number, callParams: CallParams<"n">) => Promise<void> | void;
divide: (n: number, callParams: CallParams<"n">) => Promise<void>; divide: (n: number, callParams: CallParams<"n">) => Promise<void> | void;
getResult: (callParams: CallParams<null>) => Promise<number>; getResult: (callParams: CallParams<null>) => Promise<number> | number;
multiply: (n: number, callParams: CallParams<"n">) => Promise<void>; multiply: (n: number, callParams: CallParams<"n">) => Promise<void> | void;
reset: (callParams: CallParams<null>) => Promise<void>; reset: (callParams: CallParams<null>) => Promise<void> | void;
subtract: (n: number, callParams: CallParams<"n">) => Promise<void>; subtract: (n: number, callParams: CallParams<"n">) => Promise<void> | void;
}): void; }
export function registerCalc(
serviceId: string, export function registerCalc(service: CalcDef): void;
service: { export function registerCalc(serviceId: string, service: CalcDef): void;
add: (n: number, callParams: CallParams<"n">) => Promise<void>; export function registerCalc(peer: FluencePeer, service: CalcDef): void;
divide: (n: number, callParams: CallParams<"n">) => Promise<void>;
getResult: (callParams: CallParams<null>) => Promise<number>;
multiply: (n: number, callParams: CallParams<"n">) => Promise<void>;
reset: (callParams: CallParams<null>) => Promise<void>;
subtract: (n: number, callParams: CallParams<"n">) => Promise<void>;
}
): void;
export function registerCalc(
peer: FluencePeer,
service: {
add: (n: number, callParams: CallParams<"n">) => Promise<void>;
divide: (n: number, callParams: CallParams<"n">) => Promise<void>;
getResult: (callParams: CallParams<null>) => Promise<number>;
multiply: (n: number, callParams: CallParams<"n">) => Promise<void>;
reset: (callParams: CallParams<null>) => Promise<void>;
subtract: (n: number, callParams: CallParams<"n">) => Promise<void>;
}
): void;
export function registerCalc( export function registerCalc(
peer: FluencePeer, peer: FluencePeer,
serviceId: string, serviceId: string,
service: { service: CalcDef
add: (n: number, callParams: CallParams<"n">) => Promise<void>;
divide: (n: number, callParams: CallParams<"n">) => Promise<void>;
getResult: (callParams: CallParams<null>) => Promise<number>;
multiply: (n: number, callParams: CallParams<"n">) => Promise<void>;
reset: (callParams: CallParams<null>) => Promise<void>;
subtract: (n: number, callParams: CallParams<"n">) => Promise<void>;
}
): void; ): void;
export function registerCalc(...args) { export function registerCalc(...args) {
let peer: FluencePeer; let peer: FluencePeer;

View File

@ -1,30 +1,30 @@
import { FluencePeer } from "@fluencelabs/fluence"; import { FluencePeer } from "@fluencelabs/fluence";
import { registerCalc, demoCalculation } from "./_aqua/calc"; import { registerCalc, CalcDef, demoCalculation } from "./_aqua/calc";
class Calc { class Calc implements CalcDef {
private _state: number = 0; private _state: number = 0;
async add(n: number) { add(n: number) {
this._state += n; this._state += n;
} }
async subtract(n: number) { subtract(n: number) {
this._state -= n; this._state -= n;
} }
async multiply(n: number) { multiply(n: number) {
this._state *= n; this._state *= n;
} }
async divide(n: number) { divide(n: number) {
this._state /= n; this._state /= n;
} }
async reset() { reset() {
this._state = 0; this._state = 0;
} }
async getResult() { getResult() {
return this._state; return this._state;
} }
} }