From bb728cb3b51090eefae4aa352a3e3ffb27692d8f Mon Sep 17 00:00:00 2001 From: DieMyst Date: Tue, 18 May 2021 17:44:13 +0300 Subject: [PATCH] add ts file --- src/compiled/example.ts | 75 +++++++++++++++++++++++++++++++++++++++++ 1 file changed, 75 insertions(+) create mode 100644 src/compiled/example.ts diff --git a/src/compiled/example.ts b/src/compiled/example.ts new file mode 100644 index 0000000..78eabe5 --- /dev/null +++ b/src/compiled/example.ts @@ -0,0 +1,75 @@ +/** + * + * 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.1.1-SNAPSHOT + * + */ +import { FluenceClient, PeerIdB58 } from '@fluencelabs/fluence'; +import { RequestFlowBuilder } from '@fluencelabs/fluence/dist/api.unstable'; + + + +export async function betterMessage(client: FluenceClient, relay: string): Promise { + let request; + const promise = new Promise((resolve, reject) => { + request = new RequestFlowBuilder() + .disableInjections() + .withRawScript( + ` +(xor + (seq + (seq + (seq + (seq + (seq + (call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-) + (call %init_peer_id% ("getDataSrv" "relay") [] relay) + ) + (call -relay- ("op" "identity") []) + ) + (xor + (call relay ("peer" "is_connected") [relay] isOnline) + (seq + (call -relay- ("op" "identity") []) + (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1]) + ) + ) + ) + (call -relay- ("op" "identity") []) + ) + (xor + (match isOnline true + (call %init_peer_id% ("test" "doSomething") []) + ) + (null) + ) + ) + (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 2]) +) + + `, + ) + .configHandler((h) => { + h.on('getDataSrv', '-relay-', () => { + return client.relayPeerId!; + }); + h.on('getDataSrv', 'relay', () => {return relay;}); + + h.onEvent('errorHandlingSrv', 'error', (args) => { + // assuming error is the single argument + const [err] = args; + reject(err); + }); + }) + .handleScriptError(reject) + .handleTimeout(() => { + reject('Request timed out for betterMessage'); + }) + .build(); + }); + await client.initiateFlow(request); + return Promise.race([promise, Promise.resolve()]); +} + \ No newline at end of file