From 396a57018d6b97e41f39e056b81de92c5817d3bc Mon Sep 17 00:00:00 2001 From: Pavel Murygin Date: Fri, 18 Jun 2021 18:31:16 +0300 Subject: [PATCH] update package versions --- aqua/app.aqua | 2 +- package-lock.json | 66 ++++----- package.json | 4 +- src/_aqua/app.js | 346 ++++++++++++++++++++++------------------------ 4 files changed, 204 insertions(+), 214 deletions(-) diff --git a/aqua/app.aqua b/aqua/app.aqua index ee17a05..4e70746 100644 --- a/aqua/app.aqua +++ b/aqua/app.aqua @@ -17,7 +17,7 @@ func askAllAndSend(peer: PeerId): modules <- Dist.list_modules() services <- Srv.list() collectServiceInterfaces(peer, services) - DashboardEvent.collectPeerInfo(peer, ident, services, blueprints, modules) + -- DashboardEvent.collectPeerInfo(peer, ident, services, blueprints, modules) func findAndAskNeighboursSchema(relayPeerId: PeerId, clientId: PeerId): diff --git a/package-lock.json b/package-lock.json index ce4db0d..22c2455 100644 --- a/package-lock.json +++ b/package-lock.json @@ -998,9 +998,9 @@ } }, "@fluencelabs/aqua-cli": { - "version": "0.1.5-142", - "resolved": "https://registry.npmjs.org/@fluencelabs/aqua-cli/-/aqua-cli-0.1.5-142.tgz", - "integrity": "sha512-22BhF9j44FPTUc3JM6tGRz0SnyMthJM05cIuS98mHYTTTPU7i0jOS0dl/V7BYzSBJBAwEmZLA1Z/3bGr9PUBEA==", + "version": "0.1.6-149", + "resolved": "https://registry.npmjs.org/@fluencelabs/aqua-cli/-/aqua-cli-0.1.6-149.tgz", + "integrity": "sha512-CTKZKYLTapmuTh6J2e9rhwqs2SpifhfAqabYTwdWPuOER+W9w+7RY/rRvy9kaENT8i1fQsmY/5zTrbyUHfOPIQ==", "dev": true }, "@fluencelabs/aqua-lib": { @@ -1010,9 +1010,9 @@ "dev": true }, "@fluencelabs/avm": { - "version": "0.9.12", - "resolved": "https://registry.npmjs.org/@fluencelabs/avm/-/avm-0.9.12.tgz", - "integrity": "sha512-NCRGJafLa1Zs98IIOIALrPUoOEjesITsB9of2/r+IDgGKunf0NjI2/tqU5pK+37ye/qro5W+FJsHyseDh7zSDQ==", + "version": "0.10.5", + "resolved": "https://registry.npmjs.org/@fluencelabs/avm/-/avm-0.10.5.tgz", + "integrity": "sha512-R65qY8PeVdlF27UDlcODTnxSBfEbiqXivHWoM62e7mZYr4T/lcZEklqMPOkRrymJWs7y/zP/D8N7zxecDNLBOA==", "requires": { "base64-js": "1.5.1" }, @@ -1025,11 +1025,11 @@ } }, "@fluencelabs/fluence": { - "version": "0.9.47", - "resolved": "https://registry.npmjs.org/@fluencelabs/fluence/-/fluence-0.9.47.tgz", - "integrity": "sha512-NueaISvOvE1dDoeyfDcVmcDteXLyMbhb/hU7Z9O+5rJEvMYo2CzhIGAQo9bTDFLNBoamXFJdpqV3iLBn/kRs9Q==", + "version": "0.9.53", + "resolved": "https://registry.npmjs.org/@fluencelabs/fluence/-/fluence-0.9.53.tgz", + "integrity": "sha512-DxazRumUWM4idI55ZSbfI26lRm5tvrgBYPa4XwPmxSbjgkLE5OjZ+sUStesMiUSst6ROQkwMM4v8BK7WqAyMuw==", "requires": { - "@fluencelabs/avm": "0.9.12", + "@fluencelabs/avm": "0.10.5", "async": "3.2.0", "base64-js": "1.3.1", "bs58": "4.0.1", @@ -1053,13 +1053,13 @@ "integrity": "sha512-TetSwl2PnLEoxkP/lr3MFpqSRKFO02PJMyjeN2TQbUUviQyfYLpL/IQFocaQZc0fRzOQWVg65aqSStHtA3rB6w==" }, "@motrix/nat-api": { - "version": "0.3.1", - "resolved": "https://registry.npmjs.org/@motrix/nat-api/-/nat-api-0.3.1.tgz", - "integrity": "sha512-mUsW8BlSK4bE5kjC5H4oQPjnXXuiRtE2V26tzW/AOroXl5CuhMEr9EDrr+wUFvDHlDwK4B0uSOBa8yILr6AfbQ==", + "version": "0.3.2", + "resolved": "https://registry.npmjs.org/@motrix/nat-api/-/nat-api-0.3.2.tgz", + "integrity": "sha512-T3LSHnEUULbSU1o1zCZZ1ul8l8Jm98f0fz/0BeF7DhNvrV63YllLCD4vUR9hFZWu/+WTIVPnbH8dBK5Ckuveuw==", "requires": { "async": "^3.2.0", - "debug": "^4.1.1", - "default-gateway": "^6.0.1", + "debug": "^4.3.1", + "default-gateway": "^6.0.3", "request": "^2.88.2", "unordered-array-remove": "^1.0.2", "xml2js": "^0.4.23" @@ -1074,9 +1074,9 @@ } }, "execa": { - "version": "5.0.1", - "resolved": "https://registry.npmjs.org/execa/-/execa-5.0.1.tgz", - "integrity": "sha512-4hFTjFbFzQa3aCLobpbPJR/U+VoL1wdV5ozOWjeet0AWDeYr9UFGM1eUFWHX+VtOWFq4p0xXUXfW1YxUaP4fpw==", + "version": "5.1.1", + "resolved": "https://registry.npmjs.org/execa/-/execa-5.1.1.tgz", + "integrity": "sha512-8uSpZZocAZRBAPIEINJj3Lo9HyGitllczc27Eh5YYojjMFMn8yHMDMaUHE2Jqfq05D/wucwI4JGURyXt1vchyg==", "requires": { "cross-spawn": "^7.0.3", "get-stream": "^6.0.0", @@ -8082,9 +8082,9 @@ }, "dependencies": { "cids": { - "version": "1.1.6", - "resolved": "https://registry.npmjs.org/cids/-/cids-1.1.6.tgz", - "integrity": "sha512-5P+Jas2bVpjiHibp/SOwKY+v7JhAjTChaAZN+vCIrsWXn/JZV0frX22Vp5zZgEyJRPco79pX+yNQ2S3LkRukHQ==", + "version": "1.1.7", + "resolved": "https://registry.npmjs.org/cids/-/cids-1.1.7.tgz", + "integrity": "sha512-dlh+K0hMwFAFFjWQ2ZzxOhgGVNVREPdmk8cqHFui2U4sOodcemLMxdE5Ujga4cDcDQhWfldEPThkfu6KWBt1eA==", "requires": { "multibase": "^4.0.1", "multicodec": "^3.0.1", @@ -8406,9 +8406,9 @@ }, "dependencies": { "cids": { - "version": "1.1.6", - "resolved": "https://registry.npmjs.org/cids/-/cids-1.1.6.tgz", - "integrity": "sha512-5P+Jas2bVpjiHibp/SOwKY+v7JhAjTChaAZN+vCIrsWXn/JZV0frX22Vp5zZgEyJRPco79pX+yNQ2S3LkRukHQ==", + "version": "1.1.7", + "resolved": "https://registry.npmjs.org/cids/-/cids-1.1.7.tgz", + "integrity": "sha512-dlh+K0hMwFAFFjWQ2ZzxOhgGVNVREPdmk8cqHFui2U4sOodcemLMxdE5Ujga4cDcDQhWfldEPThkfu6KWBt1eA==", "requires": { "multibase": "^4.0.1", "multicodec": "^3.0.1", @@ -9154,9 +9154,9 @@ }, "dependencies": { "cids": { - "version": "1.1.6", - "resolved": "https://registry.npmjs.org/cids/-/cids-1.1.6.tgz", - "integrity": "sha512-5P+Jas2bVpjiHibp/SOwKY+v7JhAjTChaAZN+vCIrsWXn/JZV0frX22Vp5zZgEyJRPco79pX+yNQ2S3LkRukHQ==", + "version": "1.1.7", + "resolved": "https://registry.npmjs.org/cids/-/cids-1.1.7.tgz", + "integrity": "sha512-dlh+K0hMwFAFFjWQ2ZzxOhgGVNVREPdmk8cqHFui2U4sOodcemLMxdE5Ujga4cDcDQhWfldEPThkfu6KWBt1eA==", "requires": { "multibase": "^4.0.1", "multicodec": "^3.0.1", @@ -10590,9 +10590,9 @@ }, "dependencies": { "cids": { - "version": "1.1.6", - "resolved": "https://registry.npmjs.org/cids/-/cids-1.1.6.tgz", - "integrity": "sha512-5P+Jas2bVpjiHibp/SOwKY+v7JhAjTChaAZN+vCIrsWXn/JZV0frX22Vp5zZgEyJRPco79pX+yNQ2S3LkRukHQ==", + "version": "1.1.7", + "resolved": "https://registry.npmjs.org/cids/-/cids-1.1.7.tgz", + "integrity": "sha512-dlh+K0hMwFAFFjWQ2ZzxOhgGVNVREPdmk8cqHFui2U4sOodcemLMxdE5Ujga4cDcDQhWfldEPThkfu6KWBt1eA==", "requires": { "multibase": "^4.0.1", "multicodec": "^3.0.1", @@ -15643,9 +15643,9 @@ "dev": true }, "ws": { - "version": "7.4.6", - "resolved": "https://registry.npmjs.org/ws/-/ws-7.4.6.tgz", - "integrity": "sha512-YmhHDO4MzaDLB+M9ym/mDA5z0naX8j7SIlT8f8z+I0VtzsRbekxEutHSme7NPS2qE8StCYQNUnfWdXta/Yu85A==" + "version": "7.5.0", + "resolved": "https://registry.npmjs.org/ws/-/ws-7.5.0.tgz", + "integrity": "sha512-6ezXvzOZupqKj4jUqbQ9tXuJNo+BR2gU8fFRk3XCP3e0G6WT414u5ELe6Y0vtp7kmSJ3F7YWObSNr1ESsgi4vw==" }, "xml2js": { "version": "0.4.23", diff --git a/package.json b/package.json index 6a30e0c..30d681d 100644 --- a/package.json +++ b/package.json @@ -30,7 +30,7 @@ }, "homepage": "https://github.com/fluencelabs/fluence-admin#readme", "dependencies": { - "@fluencelabs/fluence": "0.9.47", + "@fluencelabs/fluence": "0.9.53", "@fluencelabs/fluence-network-environment": "1.0.9", "css-spinners": "^1.0.1", "tachyons": "^4.12.0", @@ -39,7 +39,7 @@ "devDependencies": { "@babel/core": "^7.11.6", "@babel/preset-env": "^7.11.5", - "@fluencelabs/aqua-cli": "^0.1.5-142", + "@fluencelabs/aqua-cli": "^0.1.6-149", "@fluencelabs/aqua-lib": "^0.1.5", "@types/yup": "^0.29.11", "babel-loader": "^8.1.0", diff --git a/src/_aqua/app.js b/src/_aqua/app.js index 0c0cab8..bb1c1db 100644 --- a/src/_aqua/app.js +++ b/src/_aqua/app.js @@ -1,15 +1,13 @@ /** * * 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 * Aqua version: 0.1.5-142 * */ import { RequestFlowBuilder } from '@fluencelabs/fluence/dist/api.unstable'; - - export async function collectServiceInterfaces(client, peer, services) { let request; const promise = new Promise((resolve, reject) => { @@ -57,9 +55,13 @@ export async function collectServiceInterfaces(client, peer, services) { h.on('getDataSrv', '-relay-', () => { return client.relayPeerId; }); - h.on('getDataSrv', 'peer', () => {return peer;}); -h.on('getDataSrv', 'services', () => {return services;}); - + h.on('getDataSrv', 'peer', () => { + return peer; + }); + h.on('getDataSrv', 'services', () => { + return services; + }); + h.onEvent('errorHandlingSrv', 'error', (args) => { // assuming error is the single argument const [err] = args; @@ -75,8 +77,6 @@ h.on('getDataSrv', 'services', () => {return services;}); await client.initiateFlow(request); return Promise.race([promise, Promise.resolve()]); } - - export async function askAllAndSend(client, peer) { let request; @@ -91,54 +91,51 @@ export async function askAllAndSend(client, peer) { (seq (seq (seq - (seq - (call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-) - (call %init_peer_id% ("getDataSrv" "peer") [] peer) - ) - (call -relay- ("op" "identity") []) - ) - (xor - (seq - (seq - (seq - (call peer ("peer" "identify") [] ident) - (call peer ("dist" "list_blueprints") [] blueprints) - ) - (call peer ("dist" "list_modules") [] modules) - ) - (call peer ("srv" "list") [] services) - ) - (seq - (call -relay- ("op" "identity") []) - (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1]) - ) + (call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-) + (call %init_peer_id% ("getDataSrv" "peer") [] peer) ) + (call -relay- ("op" "identity") []) ) - (call -relay- ("op" "identity") []) - ) - (fold services srv - (par + (xor (seq (seq (seq - (call -relay- ("op" "identity") []) - (xor - (call peer ("srv" "get_interface") [srv.$.id!] info) - (seq - (call -relay- ("op" "identity") []) - (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 2]) - ) - ) + (call peer ("peer" "identify") [] ident) + (call peer ("dist" "list_blueprints") [] blueprints) ) - (call -relay- ("op" "identity") []) + (call peer ("dist" "list_modules") [] modules) ) - (call %init_peer_id% ("event" "collectServiceInterface") [peer srv.$.id! info.$.interface!]) + (call peer ("srv" "list") [] services) + ) + (seq + (call -relay- ("op" "identity") []) + (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1]) ) - (next srv) ) ) + (call -relay- ("op" "identity") []) + ) + (fold services srv + (par + (seq + (seq + (seq + (call -relay- ("op" "identity") []) + (xor + (call peer ("srv" "get_interface") [srv.$.id!] info) + (seq + (call -relay- ("op" "identity") []) + (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 2]) + ) + ) + ) + (call -relay- ("op" "identity") []) + ) + (call %init_peer_id% ("event" "collectServiceInterface") [peer srv.$.id! info.$.interface!]) + ) + (next srv) + ) ) - (call %init_peer_id% ("event" "collectPeerInfo") [peer ident services blueprints modules]) ) (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 3]) ) @@ -149,8 +146,10 @@ export async function askAllAndSend(client, peer) { h.on('getDataSrv', '-relay-', () => { return client.relayPeerId; }); - h.on('getDataSrv', 'peer', () => {return peer;}); - + h.on('getDataSrv', 'peer', () => { + return peer; + }); + h.onEvent('errorHandlingSrv', 'error', (args) => { // assuming error is the single argument const [err] = args; @@ -166,8 +165,6 @@ export async function askAllAndSend(client, peer) { await client.initiateFlow(request); return Promise.race([promise, Promise.resolve()]); } - - export async function findAndAskNeighboursSchema(client, relayPeerId, clientId) { let request; @@ -200,45 +197,42 @@ export async function findAndAskNeighboursSchema(client, relayPeerId, clientId) (seq (seq (seq - (seq - (xor + (xor + (seq (seq (seq - (seq - (call n2 ("peer" "identify") [] ident) - (call n2 ("dist" "list_blueprints") [] blueprints) - ) - (call n2 ("dist" "list_modules") [] modules) + (call n2 ("peer" "identify") [] ident) + (call n2 ("dist" "list_blueprints") [] blueprints) ) - (call n2 ("srv" "list") [] services) - ) - (seq - (call -relay- ("op" "identity") []) - (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1]) + (call n2 ("dist" "list_modules") [] modules) ) + (call n2 ("srv" "list") [] services) + ) + (seq + (call -relay- ("op" "identity") []) + (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1]) ) - (call -relay- ("op" "identity") []) ) - (fold services srv - (par + (call -relay- ("op" "identity") []) + ) + (fold services srv + (par + (seq (seq - (seq - (xor - (call n2 ("srv" "get_interface") [srv.$.id!] info) - (seq - (call -relay- ("op" "identity") []) - (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 2]) - ) + (xor + (call n2 ("srv" "get_interface") [srv.$.id!] info) + (seq + (call -relay- ("op" "identity") []) + (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 2]) ) - (call -relay- ("op" "identity") []) ) - (call n ("event" "collectServiceInterface") [n2 srv.$.id! info.$.interface!]) + (call -relay- ("op" "identity") []) ) - (next srv) + (call n ("event" "collectServiceInterface") [n2 srv.$.id! info.$.interface!]) ) + (next srv) ) ) - (call n ("event" "collectPeerInfo") [n2 ident services blueprints modules]) ) (next n2) ) @@ -283,9 +277,13 @@ export async function findAndAskNeighboursSchema(client, relayPeerId, clientId) h.on('getDataSrv', '-relay-', () => { return client.relayPeerId; }); - h.on('getDataSrv', 'relayPeerId', () => {return relayPeerId;}); -h.on('getDataSrv', 'clientId', () => {return clientId;}); - + h.on('getDataSrv', 'relayPeerId', () => { + return relayPeerId; + }); + h.on('getDataSrv', 'clientId', () => { + return clientId; + }); + h.onEvent('errorHandlingSrv', 'error', (args) => { // assuming error is the single argument const [err] = args; @@ -301,8 +299,6 @@ h.on('getDataSrv', 'clientId', () => {return clientId;}); await client.initiateFlow(request); return Promise.race([promise, Promise.resolve()]); } - - export async function getAll(client, relayPeerId, knownPeers) { let request; @@ -326,100 +322,94 @@ export async function getAll(client, relayPeerId, knownPeers) { (seq (seq (seq - (seq - (call -relay- ("op" "identity") []) - (xor - (seq - (seq - (seq - (call relayPeerId ("peer" "identify") [] ident) - (call relayPeerId ("dist" "list_blueprints") [] blueprints) - ) - (call relayPeerId ("dist" "list_modules") [] modules) - ) - (call relayPeerId ("srv" "list") [] services) - ) - (seq - (call -relay- ("op" "identity") []) - (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1]) - ) - ) - ) (call -relay- ("op" "identity") []) - ) - (fold services srv - (par + (xor (seq (seq (seq - (call -relay- ("op" "identity") []) - (xor - (call relayPeerId ("srv" "get_interface") [srv.$.id!] info) - (seq - (call -relay- ("op" "identity") []) - (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 2]) - ) - ) + (call relayPeerId ("peer" "identify") [] ident) + (call relayPeerId ("dist" "list_blueprints") [] blueprints) ) - (call -relay- ("op" "identity") []) + (call relayPeerId ("dist" "list_modules") [] modules) ) - (call %init_peer_id% ("event" "collectServiceInterface") [relayPeerId srv.$.id! info.$.interface!]) + (call relayPeerId ("srv" "list") [] services) + ) + (seq + (call -relay- ("op" "identity") []) + (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1]) ) - (next srv) ) ) + (call -relay- ("op" "identity") []) + ) + (fold services srv + (par + (seq + (seq + (seq + (call -relay- ("op" "identity") []) + (xor + (call relayPeerId ("srv" "get_interface") [srv.$.id!] info) + (seq + (call -relay- ("op" "identity") []) + (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 2]) + ) + ) + ) + (call -relay- ("op" "identity") []) + ) + (call %init_peer_id% ("event" "collectServiceInterface") [relayPeerId srv.$.id! info.$.interface!]) + ) + (next srv) + ) ) - (call %init_peer_id% ("event" "collectPeerInfo") [relayPeerId ident services blueprints modules]) ) (fold knownPeers peer (par (seq (seq (seq - (seq - (call -relay- ("op" "identity") []) - (xor - (seq - (seq - (seq - (call peer ("peer" "identify") [] ident0) - (call peer ("dist" "list_blueprints") [] blueprints0) - ) - (call peer ("dist" "list_modules") [] modules0) - ) - (call peer ("srv" "list") [] services0) - ) - (seq - (call -relay- ("op" "identity") []) - (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 3]) - ) - ) - ) (call -relay- ("op" "identity") []) - ) - (fold services0 srv0 - (par + (xor (seq (seq (seq - (call -relay- ("op" "identity") []) - (xor - (call peer ("srv" "get_interface") [srv0.$.id!] info0) - (seq - (call -relay- ("op" "identity") []) - (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 4]) - ) - ) + (call peer ("peer" "identify") [] ident0) + (call peer ("dist" "list_blueprints") [] blueprints0) ) - (call -relay- ("op" "identity") []) + (call peer ("dist" "list_modules") [] modules0) ) - (call %init_peer_id% ("event" "collectServiceInterface") [peer srv0.$.id! info0.$.interface!]) + (call peer ("srv" "list") [] services0) + ) + (seq + (call -relay- ("op" "identity") []) + (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 3]) ) - (next srv0) ) ) + (call -relay- ("op" "identity") []) + ) + (fold services0 srv0 + (par + (seq + (seq + (seq + (call -relay- ("op" "identity") []) + (xor + (call peer ("srv" "get_interface") [srv0.$.id!] info0) + (seq + (call -relay- ("op" "identity") []) + (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 4]) + ) + ) + ) + (call -relay- ("op" "identity") []) + ) + (call %init_peer_id% ("event" "collectServiceInterface") [peer srv0.$.id! info0.$.interface!]) + ) + (next srv0) + ) ) - (call %init_peer_id% ("event" "collectPeerInfo") [peer ident0 services0 blueprints0 modules0]) ) (next peer) ) @@ -440,45 +430,42 @@ export async function getAll(client, relayPeerId, knownPeers) { (seq (seq (seq - (seq - (xor + (xor + (seq (seq (seq - (seq - (call n2 ("peer" "identify") [] ident1) - (call n2 ("dist" "list_blueprints") [] blueprints1) - ) - (call n2 ("dist" "list_modules") [] modules1) + (call n2 ("peer" "identify") [] ident1) + (call n2 ("dist" "list_blueprints") [] blueprints1) ) - (call n2 ("srv" "list") [] services1) - ) - (seq - (call -relay- ("op" "identity") []) - (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 5]) + (call n2 ("dist" "list_modules") [] modules1) ) + (call n2 ("srv" "list") [] services1) + ) + (seq + (call -relay- ("op" "identity") []) + (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 5]) ) - (call -relay- ("op" "identity") []) ) - (fold services1 srv1 - (par + (call -relay- ("op" "identity") []) + ) + (fold services1 srv1 + (par + (seq (seq - (seq - (xor - (call n2 ("srv" "get_interface") [srv1.$.id!] info1) - (seq - (call -relay- ("op" "identity") []) - (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 6]) - ) + (xor + (call n2 ("srv" "get_interface") [srv1.$.id!] info1) + (seq + (call -relay- ("op" "identity") []) + (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 6]) ) - (call -relay- ("op" "identity") []) ) - (call n ("event" "collectServiceInterface") [n2 srv1.$.id! info1.$.interface!]) + (call -relay- ("op" "identity") []) ) - (next srv1) + (call n ("event" "collectServiceInterface") [n2 srv1.$.id! info1.$.interface!]) ) + (next srv1) ) ) - (call n ("event" "collectPeerInfo") [n2 ident1 services1 blueprints1 modules1]) ) (next n2) ) @@ -523,9 +510,13 @@ export async function getAll(client, relayPeerId, knownPeers) { h.on('getDataSrv', '-relay-', () => { return client.relayPeerId; }); - h.on('getDataSrv', 'relayPeerId', () => {return relayPeerId;}); -h.on('getDataSrv', 'knownPeers', () => {return knownPeers;}); - + h.on('getDataSrv', 'relayPeerId', () => { + return relayPeerId; + }); + h.on('getDataSrv', 'knownPeers', () => { + return knownPeers; + }); + h.onEvent('errorHandlingSrv', 'error', (args) => { // assuming error is the single argument const [err] = args; @@ -541,4 +532,3 @@ h.on('getDataSrv', 'knownPeers', () => {return knownPeers;}); await client.initiateFlow(request); return Promise.race([promise, Promise.resolve()]); } - \ No newline at end of file