mirror of
https://github.com/fluencelabs/aqua-playground
synced 2025-06-22 05:01:35 +00:00
56 lines
1.7 KiB
TypeScript
56 lines
1.7 KiB
TypeScript
![]() |
import { FluenceClient, PeerIdB58 } from '@fluencelabs/fluence';
|
||
|
import { RequestFlowBuilder } from '@fluencelabs/fluence/dist/api.unstable';
|
||
|
|
||
|
|
||
|
|
||
|
export async function helloWorld(client: FluenceClient, name: string): Promise<string> {
|
||
|
let request;
|
||
|
const promise = new Promise<string>((resolve, reject) => {
|
||
|
request = new RequestFlowBuilder()
|
||
|
.withRawScript(
|
||
|
`
|
||
|
(xor
|
||
|
(seq
|
||
|
(seq
|
||
|
(seq
|
||
|
(call %init_peer_id% ("getDataSrv" "name") [] name)
|
||
|
(call %init_peer_id% ("getDataSrv" "relay") [] relay)
|
||
|
)
|
||
|
(call %init_peer_id% ("service-id" "addNameToHello") [name] res)
|
||
|
)
|
||
|
(call %init_peer_id% ("callbackSrv" "response") [res])
|
||
|
)
|
||
|
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error%])
|
||
|
)
|
||
|
|
||
|
`,
|
||
|
)
|
||
|
.configHandler((h) => {
|
||
|
h.on('getDataSrv', 'relay', () => {
|
||
|
return client.relayPeerId;
|
||
|
});
|
||
|
h.on('getRelayService', 'hasReleay', () => {// Not Used
|
||
|
return client.relayPeerId !== undefined;
|
||
|
});
|
||
|
h.on('getDataSrv', 'name', () => {return name;});
|
||
|
h.on('callbackSrv', 'response', (args) => {
|
||
|
const [res] = args;
|
||
|
resolve(res);
|
||
|
});
|
||
|
|
||
|
h.on('errorHandlingSrv', 'error', (args) => {
|
||
|
// assuming error is the single argument
|
||
|
const [err] = args;
|
||
|
reject(err);
|
||
|
});
|
||
|
})
|
||
|
.handleScriptError(reject)
|
||
|
.handleTimeout(() => {
|
||
|
reject('Request timed out');
|
||
|
})
|
||
|
.build();
|
||
|
});
|
||
|
await client.initiateFlow(request);
|
||
|
return promise;
|
||
|
}
|
||
|
|