From 6c199dae5e7d12c4b00d375de23d0d2ef046ffc8 Mon Sep 17 00:00:00 2001 From: Pavel Murygin Date: Fri, 22 Oct 2021 09:46:17 +0300 Subject: [PATCH] Update fluence-js to 14.2 and aqua to 0.4.0-235 --- client/package-lock.json | 253 +++-- client/package.json | 4 +- client/src/_aqua/app.ts | 1959 +++++++++++++++++--------------------- 3 files changed, 1018 insertions(+), 1198 deletions(-) diff --git a/client/package-lock.json b/client/package-lock.json index 0b8ad32..1e62d35 100644 --- a/client/package-lock.json +++ b/client/package-lock.json @@ -8,7 +8,7 @@ "name": "fluent-pad", "version": "0.1.0", "dependencies": { - "@fluencelabs/fluence": "0.12.0", + "@fluencelabs/fluence": "^0.14.2", "@fluencelabs/fluence-network-environment": "^1.0.10", "@testing-library/jest-dom": "^5.11.9", "@testing-library/react": "^11.2.5", @@ -29,7 +29,7 @@ "web-vitals": "^0.2.4" }, "devDependencies": { - "@fluencelabs/aqua": "^0.3.0-226", + "@fluencelabs/aqua": "^0.4.0-235", "@fluencelabs/aqua-lib": "^0.1.14", "@types/lodash": "^4.14.168", "chokidar-cli": "^3.0.0" @@ -1553,14 +1553,16 @@ } }, "node_modules/@fluencelabs/aqua": { - "version": "0.3.0-226", - "resolved": "https://registry.npmjs.org/@fluencelabs/aqua/-/aqua-0.3.0-226.tgz", - "integrity": "sha512-9o0TdgsVNcBvifqo7VqIkN62P9EReE0LUxgWG1rGHi9yxJiGElvEBvrVUzqShffF66Ene7VGEe85lhFIGCfDgg==", + "version": "0.4.0-235", + "resolved": "https://registry.npmjs.org/@fluencelabs/aqua/-/aqua-0.4.0-235.tgz", + "integrity": "sha512-tbbHG3dhlwcSzlHMPoV4/MLW6JE00q3hiyznjLh+aW91ovBAXuWe5C1n9CKeRiJtYz3yIQCn2l3arI/PvzLx9Q==", "dev": true, + "dependencies": { + "@fluencelabs/fluence": "0.12.1" + }, "bin": { "aqua": "index.js", - "aqua-cli": "error.js", - "aqua-j": "index-java.js" + "aqua-cli": "error.js" } }, "node_modules/@fluencelabs/aqua-lib": { @@ -1569,37 +1571,11 @@ "integrity": "sha512-H2Q4gIvociUxc4J2mwmH0D+mrU2N2Z+enKCHgBCanMVEE2wZDsZ80GTbDKsQjEq+gpqbnJIk8lJBYW6lyvLJTg==", "dev": true }, - "node_modules/@fluencelabs/avm": { - "version": "0.14.4", - "resolved": "https://registry.npmjs.org/@fluencelabs/avm/-/avm-0.14.4.tgz", - "integrity": "sha512-XyR+1H5k0CAc+mDHOkl81viX8XeW1Yqbw793xbsfUfju5bUb/hqk+gHv3q8lAFdbrCG5P45gdOT08a5RNODZaQ==", - "dependencies": { - "base64-js": "1.5.1" - } - }, - "node_modules/@fluencelabs/avm/node_modules/base64-js": { - "version": "1.5.1", - "resolved": "https://registry.npmjs.org/base64-js/-/base64-js-1.5.1.tgz", - "integrity": "sha512-AKpaYlHn8t4SVbOHCy+b5+KKgvR4vrsD8vbvrbiQJps7fKDTkjkDry6ji0rUJjC0kzbNePLwzxq8iypo41qeWA==", - "funding": [ - { - "type": "github", - "url": "https://github.com/sponsors/feross" - }, - { - "type": "patreon", - "url": "https://www.patreon.com/feross" - }, - { - "type": "consulting", - "url": "https://feross.org/support" - } - ] - }, - "node_modules/@fluencelabs/fluence": { - "version": "0.12.0", - "resolved": "https://registry.npmjs.org/@fluencelabs/fluence/-/fluence-0.12.0.tgz", - "integrity": "sha512-eYg3CflqeqlWUoaXXXUBxls7Pzjytp1nkHZWoe39bL7poF20T1BuTovNWo/jTWma5HS4L1FaAGGRNaMcN0wFHQ==", + "node_modules/@fluencelabs/aqua/node_modules/@fluencelabs/fluence": { + "version": "0.12.1", + "resolved": "https://registry.npmjs.org/@fluencelabs/fluence/-/fluence-0.12.1.tgz", + "integrity": "sha512-JrMKMHjYILAHQsLLd5H0fLt/UMZv+/PQYxJYe6h9HFyJlZrN1bUV+EcZnUw1u3DZE5k/RXBx0udfmkahggwrqA==", + "dev": true, "dependencies": { "@chainsafe/libp2p-noise": "4.0.0", "@fluencelabs/avm": "0.14.4", @@ -1615,34 +1591,56 @@ "libp2p-websockets": "0.16.1", "loglevel": "1.7.0", "multiaddr": "10.0.0", - "noble-ed25519": "^1.2.5", "peer-id": "0.15.3", "uuid": "8.3.0" } }, + "node_modules/@fluencelabs/avm": { + "version": "0.14.4", + "resolved": "https://registry.npmjs.org/@fluencelabs/avm/-/avm-0.14.4.tgz", + "integrity": "sha512-XyR+1H5k0CAc+mDHOkl81viX8XeW1Yqbw793xbsfUfju5bUb/hqk+gHv3q8lAFdbrCG5P45gdOT08a5RNODZaQ==", + "dev": true, + "dependencies": { + "base64-js": "1.5.1" + } + }, + "node_modules/@fluencelabs/fluence": { + "version": "0.14.2", + "resolved": "https://registry.npmjs.org/@fluencelabs/fluence/-/fluence-0.14.2.tgz", + "integrity": "sha512-Cf5Ii6dpVSSi839jB7H0Y9k07xncYdHiTNKp4LlPg6inXuy2OPb2E7qF5DXlMM9O1dBb/UJTa4jZlQDsgWriiQ==", + "dependencies": { + "@chainsafe/libp2p-noise": "4.0.0", + "@fluencelabs/avm": "0.15.4", + "async": "3.2.0", + "base64-js": "1.5.1", + "bs58": "4.0.1", + "cids": "0.8.1", + "it-length-prefixed": "3.0.1", + "it-pipe": "1.1.0", + "libp2p": "0.32.3", + "libp2p-crypto": "0.19.7", + "libp2p-mplex": "0.10.4", + "libp2p-websockets": "0.16.1", + "loglevel": "1.7.0", + "multiaddr": "10.0.0", + "peer-id": "0.15.3", + "rxjs": "^7.3.0", + "ts-pattern": "^3.3.3", + "uuid": "8.3.0" + } + }, "node_modules/@fluencelabs/fluence-network-environment": { "version": "1.0.10", "resolved": "https://registry.npmjs.org/@fluencelabs/fluence-network-environment/-/fluence-network-environment-1.0.10.tgz", "integrity": "sha512-aaWZDDFIIasSTgdFdw1KEz+boZMSn7pXffUENZNLX4DrP11rC3AEX4c8GnIJQbWqGsouOFZOPna2DSG6o2rLNQ==" }, - "node_modules/@fluencelabs/fluence/node_modules/base64-js": { - "version": "1.5.1", - "resolved": "https://registry.npmjs.org/base64-js/-/base64-js-1.5.1.tgz", - "integrity": "sha512-AKpaYlHn8t4SVbOHCy+b5+KKgvR4vrsD8vbvrbiQJps7fKDTkjkDry6ji0rUJjC0kzbNePLwzxq8iypo41qeWA==", - "funding": [ - { - "type": "github", - "url": "https://github.com/sponsors/feross" - }, - { - "type": "patreon", - "url": "https://www.patreon.com/feross" - }, - { - "type": "consulting", - "url": "https://feross.org/support" - } - ] + "node_modules/@fluencelabs/fluence/node_modules/@fluencelabs/avm": { + "version": "0.15.4", + "resolved": "https://registry.npmjs.org/@fluencelabs/avm/-/avm-0.15.4.tgz", + "integrity": "sha512-NLZDq83ocJ1Helm0D8kPMSSkjxH0y+Tujg0px773zjIShbh3jgiJOjAW1xCYgTt9K0LqepjP0bWX4/8nUZfr7g==", + "dependencies": { + "base64-js": "1.5.1" + } }, "node_modules/@hapi/address": { "version": "2.1.4", @@ -4933,9 +4931,23 @@ } }, "node_modules/base64-js": { - "version": "1.3.1", - "resolved": "https://registry.npmjs.org/base64-js/-/base64-js-1.3.1.tgz", - "integrity": "sha512-mLQ4i2QO1ytvGWFWmcngKO//JXAQueZvwEKtjgQFM4jIK0kU+ytMfplL8j+n5mspOfjHwoAg+9yhb7BwAHm36g==" + "version": "1.5.1", + "resolved": "https://registry.npmjs.org/base64-js/-/base64-js-1.5.1.tgz", + "integrity": "sha512-AKpaYlHn8t4SVbOHCy+b5+KKgvR4vrsD8vbvrbiQJps7fKDTkjkDry6ji0rUJjC0kzbNePLwzxq8iypo41qeWA==", + "funding": [ + { + "type": "github", + "url": "https://github.com/sponsors/feross" + }, + { + "type": "patreon", + "url": "https://www.patreon.com/feross" + }, + { + "type": "consulting", + "url": "https://feross.org/support" + } + ] }, "node_modules/batch": { "version": "0.6.1", @@ -15084,11 +15096,6 @@ "resolved": "https://registry.npmjs.org/tslib/-/tslib-2.1.0.tgz", "integrity": "sha512-hcVC3wYEziELGGmEEXue7D75zbwIIVUMWAVbHItGPx0ziyXxrOMQx4rQEVEV45Ut/1IotuEvwqPopzIOkDMf0A==" }, - "node_modules/noble-ed25519": { - "version": "1.2.5", - "resolved": "https://registry.npmjs.org/noble-ed25519/-/noble-ed25519-1.2.5.tgz", - "integrity": "sha512-7vst+4UhM5QU3jJ3pUqPMKBCOePrxBojmoQa59qcSnYvjFF/T4jqb4WISlfslcWyBw7G5H9V/acpcAxMd8DzUQ==" - }, "node_modules/node-addon-api": { "version": "2.0.2", "resolved": "https://registry.npmjs.org/node-addon-api/-/node-addon-api-2.0.2.tgz", @@ -19184,6 +19191,19 @@ "aproba": "^1.1.1" } }, + "node_modules/rxjs": { + "version": "7.4.0", + "resolved": "https://registry.npmjs.org/rxjs/-/rxjs-7.4.0.tgz", + "integrity": "sha512-7SQDi7xeTMCJpqViXh8gL/lebcwlp3d831F05+9B44A4B0WfsEwUQHR64gsH1kvJ+Ep/J9K2+n1hVl1CsGN23w==", + "dependencies": { + "tslib": "~2.1.0" + } + }, + "node_modules/rxjs/node_modules/tslib": { + "version": "2.1.0", + "resolved": "https://registry.npmjs.org/tslib/-/tslib-2.1.0.tgz", + "integrity": "sha512-hcVC3wYEziELGGmEEXue7D75zbwIIVUMWAVbHItGPx0ziyXxrOMQx4rQEVEV45Ut/1IotuEvwqPopzIOkDMf0A==" + }, "node_modules/safe-buffer": { "version": "5.2.1", "resolved": "https://registry.npmjs.org/safe-buffer/-/safe-buffer-5.2.1.tgz", @@ -21416,6 +21436,11 @@ "resolved": "https://registry.npmjs.org/tryer/-/tryer-1.0.1.tgz", "integrity": "sha512-c3zayb8/kWWpycWYg87P71E1S1ZL6b6IJxfb5fvsUgsf0S2MVGaDhDXXjDMpdCpfWXqptc+4mXwmiy1ypXqRAA==" }, + "node_modules/ts-pattern": { + "version": "3.3.3", + "resolved": "https://registry.npmjs.org/ts-pattern/-/ts-pattern-3.3.3.tgz", + "integrity": "sha512-Z5EFi6g6wyX3uDFHqxF5W5c5h663oZg9O6aOiAT7fqNu0HPSfCxtHzrQ7SblTy738Mrg2Ezorky8H5aUOm8Pvg==" + }, "node_modules/ts-pnp": { "version": "1.2.0", "resolved": "https://registry.npmjs.org/ts-pnp/-/ts-pnp-1.2.0.tgz", @@ -25010,10 +25035,39 @@ } }, "@fluencelabs/aqua": { - "version": "0.3.0-226", - "resolved": "https://registry.npmjs.org/@fluencelabs/aqua/-/aqua-0.3.0-226.tgz", - "integrity": "sha512-9o0TdgsVNcBvifqo7VqIkN62P9EReE0LUxgWG1rGHi9yxJiGElvEBvrVUzqShffF66Ene7VGEe85lhFIGCfDgg==", - "dev": true + "version": "0.4.0-235", + "resolved": "https://registry.npmjs.org/@fluencelabs/aqua/-/aqua-0.4.0-235.tgz", + "integrity": "sha512-tbbHG3dhlwcSzlHMPoV4/MLW6JE00q3hiyznjLh+aW91ovBAXuWe5C1n9CKeRiJtYz3yIQCn2l3arI/PvzLx9Q==", + "dev": true, + "requires": { + "@fluencelabs/fluence": "0.12.1" + }, + "dependencies": { + "@fluencelabs/fluence": { + "version": "0.12.1", + "resolved": "https://registry.npmjs.org/@fluencelabs/fluence/-/fluence-0.12.1.tgz", + "integrity": "sha512-JrMKMHjYILAHQsLLd5H0fLt/UMZv+/PQYxJYe6h9HFyJlZrN1bUV+EcZnUw1u3DZE5k/RXBx0udfmkahggwrqA==", + "dev": true, + "requires": { + "@chainsafe/libp2p-noise": "4.0.0", + "@fluencelabs/avm": "0.14.4", + "async": "3.2.0", + "base64-js": "1.5.1", + "bs58": "4.0.1", + "cids": "0.8.1", + "it-length-prefixed": "3.0.1", + "it-pipe": "1.1.0", + "libp2p": "0.32.3", + "libp2p-crypto": "0.19.7", + "libp2p-mplex": "0.10.4", + "libp2p-websockets": "0.16.1", + "loglevel": "1.7.0", + "multiaddr": "10.0.0", + "peer-id": "0.15.3", + "uuid": "8.3.0" + } + } + } }, "@fluencelabs/aqua-lib": { "version": "0.1.14", @@ -25025,24 +25079,18 @@ "version": "0.14.4", "resolved": "https://registry.npmjs.org/@fluencelabs/avm/-/avm-0.14.4.tgz", "integrity": "sha512-XyR+1H5k0CAc+mDHOkl81viX8XeW1Yqbw793xbsfUfju5bUb/hqk+gHv3q8lAFdbrCG5P45gdOT08a5RNODZaQ==", + "dev": true, "requires": { "base64-js": "1.5.1" - }, - "dependencies": { - "base64-js": { - "version": "1.5.1", - "resolved": "https://registry.npmjs.org/base64-js/-/base64-js-1.5.1.tgz", - "integrity": "sha512-AKpaYlHn8t4SVbOHCy+b5+KKgvR4vrsD8vbvrbiQJps7fKDTkjkDry6ji0rUJjC0kzbNePLwzxq8iypo41qeWA==" - } } }, "@fluencelabs/fluence": { - "version": "0.12.0", - "resolved": "https://registry.npmjs.org/@fluencelabs/fluence/-/fluence-0.12.0.tgz", - "integrity": "sha512-eYg3CflqeqlWUoaXXXUBxls7Pzjytp1nkHZWoe39bL7poF20T1BuTovNWo/jTWma5HS4L1FaAGGRNaMcN0wFHQ==", + "version": "0.14.2", + "resolved": "https://registry.npmjs.org/@fluencelabs/fluence/-/fluence-0.14.2.tgz", + "integrity": "sha512-Cf5Ii6dpVSSi839jB7H0Y9k07xncYdHiTNKp4LlPg6inXuy2OPb2E7qF5DXlMM9O1dBb/UJTa4jZlQDsgWriiQ==", "requires": { "@chainsafe/libp2p-noise": "4.0.0", - "@fluencelabs/avm": "0.14.4", + "@fluencelabs/avm": "0.15.4", "async": "3.2.0", "base64-js": "1.5.1", "bs58": "4.0.1", @@ -25055,15 +25103,19 @@ "libp2p-websockets": "0.16.1", "loglevel": "1.7.0", "multiaddr": "10.0.0", - "noble-ed25519": "^1.2.5", "peer-id": "0.15.3", + "rxjs": "^7.3.0", + "ts-pattern": "^3.3.3", "uuid": "8.3.0" }, "dependencies": { - "base64-js": { - "version": "1.5.1", - "resolved": "https://registry.npmjs.org/base64-js/-/base64-js-1.5.1.tgz", - "integrity": "sha512-AKpaYlHn8t4SVbOHCy+b5+KKgvR4vrsD8vbvrbiQJps7fKDTkjkDry6ji0rUJjC0kzbNePLwzxq8iypo41qeWA==" + "@fluencelabs/avm": { + "version": "0.15.4", + "resolved": "https://registry.npmjs.org/@fluencelabs/avm/-/avm-0.15.4.tgz", + "integrity": "sha512-NLZDq83ocJ1Helm0D8kPMSSkjxH0y+Tujg0px773zjIShbh3jgiJOjAW1xCYgTt9K0LqepjP0bWX4/8nUZfr7g==", + "requires": { + "base64-js": "1.5.1" + } } } }, @@ -27651,9 +27703,9 @@ } }, "base64-js": { - "version": "1.3.1", - "resolved": "https://registry.npmjs.org/base64-js/-/base64-js-1.3.1.tgz", - "integrity": "sha512-mLQ4i2QO1ytvGWFWmcngKO//JXAQueZvwEKtjgQFM4jIK0kU+ytMfplL8j+n5mspOfjHwoAg+9yhb7BwAHm36g==" + "version": "1.5.1", + "resolved": "https://registry.npmjs.org/base64-js/-/base64-js-1.5.1.tgz", + "integrity": "sha512-AKpaYlHn8t4SVbOHCy+b5+KKgvR4vrsD8vbvrbiQJps7fKDTkjkDry6ji0rUJjC0kzbNePLwzxq8iypo41qeWA==" }, "batch": { "version": "0.6.1", @@ -35695,11 +35747,6 @@ } } }, - "noble-ed25519": { - "version": "1.2.5", - "resolved": "https://registry.npmjs.org/noble-ed25519/-/noble-ed25519-1.2.5.tgz", - "integrity": "sha512-7vst+4UhM5QU3jJ3pUqPMKBCOePrxBojmoQa59qcSnYvjFF/T4jqb4WISlfslcWyBw7G5H9V/acpcAxMd8DzUQ==" - }, "node-addon-api": { "version": "2.0.2", "resolved": "https://registry.npmjs.org/node-addon-api/-/node-addon-api-2.0.2.tgz", @@ -38966,6 +39013,21 @@ "aproba": "^1.1.1" } }, + "rxjs": { + "version": "7.4.0", + "resolved": "https://registry.npmjs.org/rxjs/-/rxjs-7.4.0.tgz", + "integrity": "sha512-7SQDi7xeTMCJpqViXh8gL/lebcwlp3d831F05+9B44A4B0WfsEwUQHR64gsH1kvJ+Ep/J9K2+n1hVl1CsGN23w==", + "requires": { + "tslib": "~2.1.0" + }, + "dependencies": { + "tslib": { + "version": "2.1.0", + "resolved": "https://registry.npmjs.org/tslib/-/tslib-2.1.0.tgz", + "integrity": "sha512-hcVC3wYEziELGGmEEXue7D75zbwIIVUMWAVbHItGPx0ziyXxrOMQx4rQEVEV45Ut/1IotuEvwqPopzIOkDMf0A==" + } + } + }, "safe-buffer": { "version": "5.2.1", "resolved": "https://registry.npmjs.org/safe-buffer/-/safe-buffer-5.2.1.tgz", @@ -40795,6 +40857,11 @@ "resolved": "https://registry.npmjs.org/tryer/-/tryer-1.0.1.tgz", "integrity": "sha512-c3zayb8/kWWpycWYg87P71E1S1ZL6b6IJxfb5fvsUgsf0S2MVGaDhDXXjDMpdCpfWXqptc+4mXwmiy1ypXqRAA==" }, + "ts-pattern": { + "version": "3.3.3", + "resolved": "https://registry.npmjs.org/ts-pattern/-/ts-pattern-3.3.3.tgz", + "integrity": "sha512-Z5EFi6g6wyX3uDFHqxF5W5c5h663oZg9O6aOiAT7fqNu0HPSfCxtHzrQ7SblTy738Mrg2Ezorky8H5aUOm8Pvg==" + }, "ts-pnp": { "version": "1.2.0", "resolved": "https://registry.npmjs.org/ts-pnp/-/ts-pnp-1.2.0.tgz", diff --git a/client/package.json b/client/package.json index 225aa66..64578b0 100644 --- a/client/package.json +++ b/client/package.json @@ -3,7 +3,7 @@ "version": "0.1.0", "private": true, "dependencies": { - "@fluencelabs/fluence": "0.12.0", + "@fluencelabs/fluence": "^0.14.2", "@fluencelabs/fluence-network-environment": "^1.0.10", "@testing-library/jest-dom": "^5.11.9", "@testing-library/react": "^11.2.5", @@ -54,7 +54,7 @@ ] }, "devDependencies": { - "@fluencelabs/aqua": "^0.3.0-226", + "@fluencelabs/aqua": "^0.4.0-235", "@fluencelabs/aqua-lib": "^0.1.14", "@types/lodash": "^4.14.168", "chokidar-cli": "^3.0.0" diff --git a/client/src/_aqua/app.ts b/client/src/_aqua/app.ts index e61f433..ae77078 100644 --- a/client/src/_aqua/app.ts +++ b/client/src/_aqua/app.ts @@ -1,1161 +1,914 @@ /** * * 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.3.0-226 + * Aqua version: 0.4.0-235 * */ import { Fluence, FluencePeer } from '@fluencelabs/fluence'; import { - ResultCodes, - RequestFlow, - RequestFlowBuilder, CallParams, -} from '@fluencelabs/fluence/dist/internal/compilerSupport/v1'; + callFunction, + registerService, +} from '@fluencelabs/fluence/dist/internal/compilerSupport/v2'; // Services - export interface UserStatusDef { - notifyOnline: (userPeerId: string, isOnline: boolean, callParams: CallParams<'userPeerId' | 'isOnline'>) => void; -notifyUserAdded: (currentUser: {name:string;peer_id:string;relay_id:string}, isOnline: boolean, callParams: CallParams<'currentUser' | 'isOnline'>) => void; -notifyUserRemoved: (userPeerId: string, callParams: CallParams<'userPeerId'>) => void; - } - - export function registerUserStatus(service: UserStatusDef): void; +export interface UserStatusDef { + notifyOnline: (userPeerId: string, isOnline: boolean, callParams: CallParams<'userPeerId' | 'isOnline'>) => void | Promise; +notifyUserAdded: (currentUser: { name: string; peer_id: string; relay_id: string; }, isOnline: boolean, callParams: CallParams<'currentUser' | 'isOnline'>) => void | Promise; +notifyUserRemoved: (userPeerId: string, callParams: CallParams<'userPeerId'>) => void | Promise; +} +export function registerUserStatus(service: UserStatusDef): void; export function registerUserStatus(serviceId: string, service: UserStatusDef): void; export function registerUserStatus(peer: FluencePeer, service: UserStatusDef): void; export function registerUserStatus(peer: FluencePeer, serviceId: string, service: UserStatusDef): void; - export function registerUserStatus(...args: any) { - let peer: FluencePeer; - let serviceId: any; - let service: any; - if (FluencePeer.isInstance(args[0])) { - peer = args[0]; - } else { - peer = Fluence.getPeer(); - } + - if (typeof args[0] === 'string') { - serviceId = args[0]; - } else if (typeof args[1] === 'string') { - serviceId = args[1]; - } - else { - serviceId = "fluence/fluent-pad/status" +export function registerUserStatus(...args: any) { + registerService( + args, + { + "defaultServiceId" : "fluence/fluent-pad/status", + "functions" : [ + { + "functionName" : "notifyOnline", + "argDefs" : [ + { + "name" : "userPeerId", + "argType" : { + "tag" : "primitive" + } + }, + { + "name" : "isOnline", + "argType" : { + "tag" : "primitive" + } + } + ], + "returnType" : { + "tag" : "void" + } + }, + { + "functionName" : "notifyUserAdded", + "argDefs" : [ + { + "name" : "currentUser", + "argType" : { + "tag" : "primitive" + } + }, + { + "name" : "isOnline", + "argType" : { + "tag" : "primitive" + } + } + ], + "returnType" : { + "tag" : "void" + } + }, + { + "functionName" : "notifyUserRemoved", + "argDefs" : [ + { + "name" : "userPeerId", + "argType" : { + "tag" : "primitive" + } + } + ], + "returnType" : { + "tag" : "void" + } + } + ] +} + ); } - - // Figuring out which overload is the service. - // If the first argument is not Fluence Peer and it is an object, then it can only be the service def - // If the first argument is peer, we are checking further. The second argument might either be - // an object, that it must be the service object - // or a string, which is the service id. In that case the service is the third argument - if (!(FluencePeer.isInstance(args[0])) && typeof args[0] === 'object') { - service = args[0]; - } else if (typeof args[1] === 'object') { - service = args[1]; - } else { - service = args[2]; - } - - peer.internals.callServiceHandler.use((req, resp, next) => { - if (req.serviceId !== serviceId) { - next(); - return; - } - - - if (req.fnName === 'notifyOnline') { - - const callParams = { - ...req.particleContext, - tetraplets: { - userPeerId: req.tetraplets[0],isOnline: req.tetraplets[1] - }, - }; - resp.retCode = ResultCodes.success; - service.notifyOnline(req.args[0], req.args[1], callParams); resp.result = {} - - } - - - - if (req.fnName === 'notifyUserAdded') { - - const callParams = { - ...req.particleContext, - tetraplets: { - currentUser: req.tetraplets[0],isOnline: req.tetraplets[1] - }, - }; - resp.retCode = ResultCodes.success; - service.notifyUserAdded(req.args[0], req.args[1], callParams); resp.result = {} - - } - - - - if (req.fnName === 'notifyUserRemoved') { - - const callParams = { - ...req.particleContext, - tetraplets: { - userPeerId: req.tetraplets[0] - }, - }; - resp.retCode = ResultCodes.success; - service.notifyUserRemoved(req.args[0], callParams); resp.result = {} - - } - - - next(); - }); - } - export interface TextStateDef { - notifyTextUpdate: (changes: string, isAuthorized: boolean, callParams: CallParams<'changes' | 'isAuthorized'>) => void; - } - - export function registerTextState(service: TextStateDef): void; +export interface TextStateDef { + notifyTextUpdate: (changes: string, isAuthorized: boolean, callParams: CallParams<'changes' | 'isAuthorized'>) => void | Promise; +} +export function registerTextState(service: TextStateDef): void; export function registerTextState(serviceId: string, service: TextStateDef): void; export function registerTextState(peer: FluencePeer, service: TextStateDef): void; export function registerTextState(peer: FluencePeer, serviceId: string, service: TextStateDef): void; - export function registerTextState(...args: any) { - let peer: FluencePeer; - let serviceId: any; - let service: any; - if (FluencePeer.isInstance(args[0])) { - peer = args[0]; - } else { - peer = Fluence.getPeer(); - } + - if (typeof args[0] === 'string') { - serviceId = args[0]; - } else if (typeof args[1] === 'string') { - serviceId = args[1]; - } - else { - serviceId = "fluence/fluent-pad/text-state" +export function registerTextState(...args: any) { + registerService( + args, + { + "defaultServiceId" : "fluence/fluent-pad/text-state", + "functions" : [ + { + "functionName" : "notifyTextUpdate", + "argDefs" : [ + { + "name" : "changes", + "argType" : { + "tag" : "primitive" + } + }, + { + "name" : "isAuthorized", + "argType" : { + "tag" : "primitive" + } + } + ], + "returnType" : { + "tag" : "void" + } + } + ] +} + ); } - - // Figuring out which overload is the service. - // If the first argument is not Fluence Peer and it is an object, then it can only be the service def - // If the first argument is peer, we are checking further. The second argument might either be - // an object, that it must be the service object - // or a string, which is the service id. In that case the service is the third argument - if (!(FluencePeer.isInstance(args[0])) && typeof args[0] === 'object') { - service = args[0]; - } else if (typeof args[1] === 'object') { - service = args[1]; - } else { - service = args[2]; - } - - peer.internals.callServiceHandler.use((req, resp, next) => { - if (req.serviceId !== serviceId) { - next(); - return; - } - - - if (req.fnName === 'notifyTextUpdate') { - - const callParams = { - ...req.particleContext, - tetraplets: { - changes: req.tetraplets[0],isAuthorized: req.tetraplets[1] - }, - }; - resp.retCode = ResultCodes.success; - service.notifyTextUpdate(req.args[0], req.args[1], callParams); resp.result = {} - - } - - - next(); - }); - } - export interface AppConfigDef { - getApp: (callParams: CallParams) => {history:{peer_id:string;service_id:string};user_list:{peer_id:string;service_id:string}}; - } - - export function registerAppConfig(service: AppConfigDef): void; +export interface AppConfigDef { + getApp: (callParams: CallParams) => { history: { peer_id: string; service_id: string; }; user_list: { peer_id: string; service_id: string; }; } | Promise<{ history: { peer_id: string; service_id: string; }; user_list: { peer_id: string; service_id: string; }; }>; +} +export function registerAppConfig(service: AppConfigDef): void; export function registerAppConfig(serviceId: string, service: AppConfigDef): void; export function registerAppConfig(peer: FluencePeer, service: AppConfigDef): void; export function registerAppConfig(peer: FluencePeer, serviceId: string, service: AppConfigDef): void; - export function registerAppConfig(...args: any) { - let peer: FluencePeer; - let serviceId: any; - let service: any; - if (FluencePeer.isInstance(args[0])) { - peer = args[0]; - } else { - peer = Fluence.getPeer(); - } + - if (typeof args[0] === 'string') { - serviceId = args[0]; - } else if (typeof args[1] === 'string') { - serviceId = args[1]; - } - else { - serviceId = "fluence/get-config" +export function registerAppConfig(...args: any) { + registerService( + args, + { + "defaultServiceId" : "fluence/get-config", + "functions" : [ + { + "functionName" : "getApp", + "argDefs" : [ + ], + "returnType" : { + "tag" : "primitive" + } + } + ] +} + ); } - - // Figuring out which overload is the service. - // If the first argument is not Fluence Peer and it is an object, then it can only be the service def - // If the first argument is peer, we are checking further. The second argument might either be - // an object, that it must be the service object - // or a string, which is the service id. In that case the service is the third argument - if (!(FluencePeer.isInstance(args[0])) && typeof args[0] === 'object') { - service = args[0]; - } else if (typeof args[1] === 'object') { - service = args[1]; - } else { - service = args[2]; - } - - peer.internals.callServiceHandler.use((req, resp, next) => { - if (req.serviceId !== serviceId) { - next(); - return; - } - - - if (req.fnName === 'getApp') { - - const callParams = { - ...req.particleContext, - tetraplets: { - - }, - }; - resp.retCode = ResultCodes.success; - resp.result = service.getApp(callParams) - - } - - - next(); - }); - } - // Functions + +export type AddEntryResult = { entry_id: number; err_msg: string; ret_code: number; } +export function addEntry(entry: string, config?: {ttl?: number}): Promise; +export function addEntry(peer: FluencePeer, entry: string, config?: {ttl?: number}): Promise; +export function addEntry(...args: any) { - export function addEntry(entry: string, config?: {ttl?: number}) : Promise<{entry_id:number;err_msg:string;ret_code:number}>; - export function addEntry(peer: FluencePeer, entry: string, config?: {ttl?: number}) : Promise<{entry_id:number;err_msg:string;ret_code:number}>; - export function addEntry(...args: any) { - let peer: FluencePeer; - let entry: any; - let config: any; - if (FluencePeer.isInstance(args[0])) { - peer = args[0]; - entry = args[1]; -config = args[2]; - } else { - peer = Fluence.getPeer(); - entry = args[0]; -config = args[1]; - } - - let request: RequestFlow; - const promise = new Promise<{entry_id:number;err_msg:string;ret_code:number}>((resolve, reject) => { - const r = new RequestFlowBuilder() - .disableInjections() - .withRawScript( - ` - (xor - (seq - (seq - (seq - (seq - (seq - (seq - (seq - (seq - (seq - (seq - (seq - (seq - (seq - (call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-) - (call %init_peer_id% ("getDataSrv" "entry") [] entry) - ) - (call %init_peer_id% ("fluence/get-config" "getApp") [] app) - ) - (call %init_peer_id% ("fluence/get-config" "getApp") [] app0) - ) - (call -relay- ("op" "noop") []) - ) - (xor - (seq - (call -relay- ("op" "noop") []) - (call app0.$.user_list.peer_id! (app0.$.user_list.service_id! "is_authenticated") [] res0) - ) - (seq - (seq - (call -relay- ("op" "noop") []) - (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1]) - ) - (call -relay- ("op" "noop") []) - ) - ) - ) - (xor - (call app.$.history.peer_id! (app.$.history.service_id! "add") [entry res0.$.is_authenticated!] res) - (seq - (call -relay- ("op" "noop") []) - (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 2]) - ) - ) - ) - (call -relay- ("op" "noop") []) - ) - (call %init_peer_id% ("fluence/get-config" "getApp") [] app1) - ) - (call -relay- ("op" "noop") []) - ) - (xor - (seq - (call -relay- ("op" "noop") []) - (call app1.$.user_list.peer_id! (app1.$.user_list.service_id! "get_users") [] allUsers) - ) - (seq - (call -relay- ("op" "noop") []) - (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 3]) - ) - ) - ) - (call -relay- ("op" "noop") []) - ) - (fold allUsers.$.users! user - (par - (seq - (call -relay- ("op" "noop") []) - (xor - (mismatch user.$.peer_id! %init_peer_id% - (xor - (seq - (call user.$.relay_id! ("op" "noop") []) - (xor - (call user.$.peer_id! ("fluence/fluent-pad/text-state" "notifyTextUpdate") [entry res0.$.is_authenticated!]) - (seq - (seq - (seq - (call user.$.relay_id! ("op" "noop") []) - (call -relay- ("op" "noop") []) - ) - (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 4]) - ) - (call -relay- ("op" "noop") []) - ) - ) - ) - (seq - (seq - (call user.$.relay_id! ("op" "noop") []) - (call -relay- ("op" "noop") []) - ) - (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 5]) - ) - ) - ) - (null) - ) - ) - (seq - (call -relay- ("op" "noop") []) - (next user) - ) - ) - ) - ) - (xor - (call %init_peer_id% ("callbackSrv" "response") [res]) - (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 6]) - ) - ) - (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 7]) -) - - `, - ) - .configHandler((h) => { - h.on('getDataSrv', '-relay-', () => { - return peer.getStatus().relayPeerId; - }); - h.on('getDataSrv', 'entry', () => {return entry;}); - h.onEvent('callbackSrv', 'response', (args) => { - const [res] = args; - resolve(res); -}); - - h.onEvent('errorHandlingSrv', 'error', (args) => { - const [err] = args; - reject(err); - }); - }) - .handleScriptError(reject) - .handleTimeout(() => { - reject('Request timed out for addEntry'); - }) - if(config && config.ttl) { - r.withTTL(config.ttl) + let script = ` + (xor + (seq + (seq + (seq + (seq + (seq + (seq + (seq + (seq + (seq + (seq + (seq + (seq + (seq + (call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-) + (call %init_peer_id% ("getDataSrv" "entry") [] entry) + ) + (call %init_peer_id% ("fluence/get-config" "getApp") [] app) + ) + (call %init_peer_id% ("fluence/get-config" "getApp") [] app0) + ) + (call -relay- ("op" "noop") []) + ) + (xor + (seq + (call -relay- ("op" "noop") []) + (call app0.$.user_list.peer_id! (app0.$.user_list.service_id! "is_authenticated") [] res0) + ) + (seq + (seq + (call -relay- ("op" "noop") []) + (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1]) + ) + (call -relay- ("op" "noop") []) + ) + ) + ) + (xor + (call app.$.history.peer_id! (app.$.history.service_id! "add") [entry res0.$.is_authenticated!] res) + (seq + (call -relay- ("op" "noop") []) + (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 2]) + ) + ) + ) + (call -relay- ("op" "noop") []) + ) + (call %init_peer_id% ("fluence/get-config" "getApp") [] app1) + ) + (call -relay- ("op" "noop") []) + ) + (xor + (seq + (call -relay- ("op" "noop") []) + (call app1.$.user_list.peer_id! (app1.$.user_list.service_id! "get_users") [] allUsers) + ) + (seq + (call -relay- ("op" "noop") []) + (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 3]) + ) + ) + ) + (call -relay- ("op" "noop") []) + ) + (fold allUsers.$.users! user + (par + (seq + (call -relay- ("op" "noop") []) + (xor + (mismatch user.$.peer_id! %init_peer_id% + (xor + (seq + (call user.$.relay_id! ("op" "noop") []) + (xor + (call user.$.peer_id! ("fluence/fluent-pad/text-state" "notifyTextUpdate") [entry res0.$.is_authenticated!]) + (seq + (seq + (seq + (call user.$.relay_id! ("op" "noop") []) + (call -relay- ("op" "noop") []) + ) + (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 4]) + ) + (call -relay- ("op" "noop") []) + ) + ) + ) + (seq + (seq + (call user.$.relay_id! ("op" "noop") []) + (call -relay- ("op" "noop") []) + ) + (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 5]) + ) + ) + ) + (null) + ) + ) + (seq + (call -relay- ("op" "noop") []) + (next user) + ) + ) + ) + ) + (xor + (call %init_peer_id% ("callbackSrv" "response") [res]) + (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 6]) + ) + ) + (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 7]) + ) + ` + return callFunction( + args, + { + "functionName" : "addEntry", + "returnType" : { + "tag" : "primitive" + }, + "argDefs" : [ + { + "name" : "entry", + "argType" : { + "tag" : "primitive" + } } - request = r.build(); - }); - peer.internals.initiateFlow(request!); - return promise; + ], + "names" : { + "relay" : "-relay-", + "getDataSrv" : "getDataSrv", + "callbackSrv" : "callbackSrv", + "responseSrv" : "callbackSrv", + "responseFnName" : "response", + "errorHandlingSrv" : "errorHandlingSrv", + "errorFnName" : "error" + } +}, + script + ) } - + +export type GetHistoryResult = { entries: { body: string; id: number; }[]; err_msg: string; ret_code: number; } +export function getHistory(config?: {ttl?: number}): Promise; +export function getHistory(peer: FluencePeer, config?: {ttl?: number}): Promise; +export function getHistory(...args: any) { - export function getHistory(config?: {ttl?: number}) : Promise<{entries:{body:string;id:number}[];err_msg:string;ret_code:number}>; - export function getHistory(peer: FluencePeer, config?: {ttl?: number}) : Promise<{entries:{body:string;id:number}[];err_msg:string;ret_code:number}>; - export function getHistory(...args: any) { - let peer: FluencePeer; - - let config: any; - if (FluencePeer.isInstance(args[0])) { - peer = args[0]; - config = args[1]; - } else { - peer = Fluence.getPeer(); - config = args[0]; - } - - let request: RequestFlow; - const promise = new Promise<{entries:{body:string;id:number}[];err_msg:string;ret_code:number}>((resolve, reject) => { - const r = new RequestFlowBuilder() - .disableInjections() - .withRawScript( - ` - (xor - (seq - (seq - (seq - (seq - (seq - (seq - (seq - (call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-) - (call %init_peer_id% ("fluence/get-config" "getApp") [] app) - ) - (call %init_peer_id% ("fluence/get-config" "getApp") [] app0) - ) - (call -relay- ("op" "noop") []) - ) - (xor - (seq - (call -relay- ("op" "noop") []) - (call app0.$.user_list.peer_id! (app0.$.user_list.service_id! "is_authenticated") [] res0) - ) - (seq - (seq - (call -relay- ("op" "noop") []) - (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1]) - ) - (call -relay- ("op" "noop") []) - ) - ) + let script = ` + (xor + (seq + (seq + (seq + (seq + (seq + (seq + (seq + (call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-) + (call %init_peer_id% ("fluence/get-config" "getApp") [] app) + ) + (call %init_peer_id% ("fluence/get-config" "getApp") [] app0) + ) + (call -relay- ("op" "noop") []) + ) + (xor + (seq + (call -relay- ("op" "noop") []) + (call app0.$.user_list.peer_id! (app0.$.user_list.service_id! "is_authenticated") [] res0) + ) + (seq + (seq + (call -relay- ("op" "noop") []) + (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1]) + ) + (call -relay- ("op" "noop") []) + ) + ) + ) + (xor + (call app.$.history.peer_id! (app.$.history.service_id! "get_all") [res0.$.is_authenticated!] res) + (seq + (call -relay- ("op" "noop") []) + (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 2]) + ) + ) + ) + (call -relay- ("op" "noop") []) + ) + (xor + (call %init_peer_id% ("callbackSrv" "response") [res]) + (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 3]) + ) + ) + (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 4]) + ) + ` + return callFunction( + args, + { + "functionName" : "getHistory", + "returnType" : { + "tag" : "primitive" + }, + "argDefs" : [ + ], + "names" : { + "relay" : "-relay-", + "getDataSrv" : "getDataSrv", + "callbackSrv" : "callbackSrv", + "responseSrv" : "callbackSrv", + "responseFnName" : "response", + "errorHandlingSrv" : "errorHandlingSrv", + "errorFnName" : "error" + } +}, + script ) - (xor - (call app.$.history.peer_id! (app.$.history.service_id! "get_all") [res0.$.is_authenticated!] res) - (seq - (call -relay- ("op" "noop") []) - (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 2]) - ) - ) - ) - (call -relay- ("op" "noop") []) - ) - (xor - (call %init_peer_id% ("callbackSrv" "response") [res]) - (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 3]) - ) - ) - (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 4]) -) +} - `, - ) - .configHandler((h) => { - h.on('getDataSrv', '-relay-', () => { - return peer.getStatus().relayPeerId; - }); - - h.onEvent('callbackSrv', 'response', (args) => { - const [res] = args; - resolve(res); -}); +export type InitAfterJoinArgMe = { name: string; peer_id: string; relay_id: string; } - h.onEvent('errorHandlingSrv', 'error', (args) => { - const [err] = args; - reject(err); - }); - }) - .handleScriptError(reject) - .handleTimeout(() => { - reject('Request timed out for getHistory'); - }) - if(config && config.ttl) { - r.withTTL(config.ttl) +export function initAfterJoin(me: InitAfterJoinArgMe, config?: {ttl?: number}): Promise<{ name: string; peer_id: string; relay_id: string; }[]>; +export function initAfterJoin(peer: FluencePeer, me: InitAfterJoinArgMe, config?: {ttl?: number}): Promise<{ name: string; peer_id: string; relay_id: string; }[]>; +export function initAfterJoin(...args: any) { + + let script = ` + (xor + (seq + (seq + (seq + (seq + (seq + (seq + (seq + (call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-) + (call %init_peer_id% ("getDataSrv" "me") [] me) + ) + (call %init_peer_id% ("fluence/get-config" "getApp") [] app) + ) + (call -relay- ("op" "noop") []) + ) + (xor + (seq + (call -relay- ("op" "noop") []) + (call app.$.user_list.peer_id! (app.$.user_list.service_id! "get_users") [] allUsers) + ) + (seq + (call -relay- ("op" "noop") []) + (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1]) + ) + ) + ) + (call -relay- ("op" "noop") []) + ) + (fold allUsers.$.users! user + (par + (seq + (seq + (seq + (call -relay- ("op" "noop") []) + (xor + (call user.$.relay_id! ("peer" "is_connected") [user.$.peer_id!] isOnline) + (seq + (call -relay- ("op" "noop") []) + (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 2]) + ) + ) + ) + (call -relay- ("op" "noop") []) + ) + (par + (seq + (call -relay- ("op" "noop") []) + (xor + (match isOnline true + (xor + (xor + (call user.$.peer_id! ("fluence/fluent-pad/status" "notifyUserAdded") [me true]) + (seq + (seq + (seq + (call user.$.relay_id! ("op" "noop") []) + (call -relay- ("op" "noop") []) + ) + (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 3]) + ) + (call -relay- ("op" "noop") []) + ) + ) + (seq + (seq + (call user.$.relay_id! ("op" "noop") []) + (call -relay- ("op" "noop") []) + ) + (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 4]) + ) + ) + ) + (null) + ) + ) + (seq + (call -relay- ("op" "noop") []) + (call %init_peer_id% ("fluence/fluent-pad/status" "notifyUserAdded") [user isOnline]) + ) + ) + ) + (seq + (call -relay- ("op" "noop") []) + (next user) + ) + ) + ) + ) + (xor + (call %init_peer_id% ("callbackSrv" "response") [allUsers.$.users!]) + (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 5]) + ) + ) + (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 6]) + ) + ` + return callFunction( + args, + { + "functionName" : "initAfterJoin", + "returnType" : { + "tag" : "primitive" + }, + "argDefs" : [ + { + "name" : "me", + "argType" : { + "tag" : "primitive" + } } - request = r.build(); - }); - peer.internals.initiateFlow(request!); - return promise; + ], + "names" : { + "relay" : "-relay-", + "getDataSrv" : "getDataSrv", + "callbackSrv" : "callbackSrv", + "responseSrv" : "callbackSrv", + "responseFnName" : "response", + "errorHandlingSrv" : "errorHandlingSrv", + "errorFnName" : "error" + } +}, + script + ) } - + - export function initAfterJoin(me: {name:string;peer_id:string;relay_id:string}, config?: {ttl?: number}) : Promise<{name:string;peer_id:string;relay_id:string}[]>; - export function initAfterJoin(peer: FluencePeer, me: {name:string;peer_id:string;relay_id:string}, config?: {ttl?: number}) : Promise<{name:string;peer_id:string;relay_id:string}[]>; - export function initAfterJoin(...args: any) { - let peer: FluencePeer; - let me: any; - let config: any; - if (FluencePeer.isInstance(args[0])) { - peer = args[0]; - me = args[1]; -config = args[2]; - } else { - peer = Fluence.getPeer(); - me = args[0]; -config = args[1]; - } - - let request: RequestFlow; - const promise = new Promise<{name:string;peer_id:string;relay_id:string}[]>((resolve, reject) => { - const r = new RequestFlowBuilder() - .disableInjections() - .withRawScript( - ` - (xor - (seq - (seq - (seq - (seq - (seq - (seq - (seq - (call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-) - (call %init_peer_id% ("getDataSrv" "me") [] me) - ) - (call %init_peer_id% ("fluence/get-config" "getApp") [] app) - ) - (call -relay- ("op" "noop") []) - ) - (xor - (seq - (call -relay- ("op" "noop") []) - (call app.$.user_list.peer_id! (app.$.user_list.service_id! "get_users") [] allUsers) - ) - (seq - (call -relay- ("op" "noop") []) - (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1]) - ) - ) +export function updateOnlineStatuses(config?: {ttl?: number}): Promise; +export function updateOnlineStatuses(peer: FluencePeer, config?: {ttl?: number}): Promise; +export function updateOnlineStatuses(...args: any) { + + let script = ` + (xor + (seq + (seq + (seq + (seq + (seq + (call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-) + (call %init_peer_id% ("fluence/get-config" "getApp") [] app) + ) + (call -relay- ("op" "noop") []) + ) + (xor + (seq + (call -relay- ("op" "noop") []) + (call app.$.user_list.peer_id! (app.$.user_list.service_id! "get_users") [] allUsers) + ) + (seq + (call -relay- ("op" "noop") []) + (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1]) + ) + ) + ) + (call -relay- ("op" "noop") []) + ) + (fold allUsers.$.users! user + (par + (seq + (seq + (seq + (seq + (seq + (call -relay- ("op" "noop") []) + (call user.$.relay_id! ("op" "noop") []) + ) + (xor + (call user.$.peer_id! ("peer" "is_connected") [user.$.peer_id!] isOnline) + (seq + (seq + (seq + (call user.$.relay_id! ("op" "noop") []) + (call -relay- ("op" "noop") []) + ) + (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 2]) + ) + (call -relay- ("op" "noop") []) + ) + ) + ) + (call user.$.relay_id! ("op" "noop") []) + ) + (call -relay- ("op" "noop") []) + ) + (call %init_peer_id% ("fluence/fluent-pad/status" "notifyOnline") [user.$.peer_id! isOnline]) + ) + (seq + (call -relay- ("op" "noop") []) + (next user) + ) + ) + ) + ) + (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 3]) + ) + ` + return callFunction( + args, + { + "functionName" : "updateOnlineStatuses", + "returnType" : { + "tag" : "void" + }, + "argDefs" : [ + ], + "names" : { + "relay" : "-relay-", + "getDataSrv" : "getDataSrv", + "callbackSrv" : "callbackSrv", + "responseSrv" : "callbackSrv", + "responseFnName" : "response", + "errorHandlingSrv" : "errorHandlingSrv", + "errorFnName" : "error" + } +}, + script ) - (call -relay- ("op" "noop") []) - ) - (fold allUsers.$.users! user - (par - (seq - (seq - (seq - (call -relay- ("op" "noop") []) - (xor - (call user.$.relay_id! ("peer" "is_connected") [user.$.peer_id!] isOnline) - (seq - (call -relay- ("op" "noop") []) - (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 2]) - ) - ) - ) - (call -relay- ("op" "noop") []) - ) - (par - (seq - (call -relay- ("op" "noop") []) - (xor - (match isOnline true - (xor - (xor - (call user.$.peer_id! ("fluence/fluent-pad/status" "notifyUserAdded") [me true]) - (seq - (seq - (seq - (call user.$.relay_id! ("op" "noop") []) - (call -relay- ("op" "noop") []) - ) - (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 3]) - ) - (call -relay- ("op" "noop") []) - ) - ) - (seq - (seq - (call user.$.relay_id! ("op" "noop") []) - (call -relay- ("op" "noop") []) - ) - (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 4]) - ) - ) - ) - (null) - ) - ) - (seq - (call -relay- ("op" "noop") []) - (call %init_peer_id% ("fluence/fluent-pad/status" "notifyUserAdded") [user isOnline]) - ) - ) - ) - (seq - (call -relay- ("op" "noop") []) - (next user) - ) +} + + + +export function getUserList(config?: {ttl?: number}): Promise<{ name: string; peer_id: string; relay_id: string; }[]>; +export function getUserList(peer: FluencePeer, config?: {ttl?: number}): Promise<{ name: string; peer_id: string; relay_id: string; }[]>; +export function getUserList(...args: any) { + + let script = ` + (xor + (seq + (seq + (seq + (seq + (seq + (call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-) + (call %init_peer_id% ("fluence/get-config" "getApp") [] app) + ) + (call -relay- ("op" "noop") []) + ) + (xor + (seq + (call -relay- ("op" "noop") []) + (call app.$.user_list.peer_id! (app.$.user_list.service_id! "get_users") [] allUsers) + ) + (seq + (call -relay- ("op" "noop") []) + (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1]) + ) + ) + ) + (call -relay- ("op" "noop") []) + ) + (xor + (call %init_peer_id% ("callbackSrv" "response") [allUsers.$.users!]) + (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 2]) + ) + ) + (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 3]) + ) + ` + return callFunction( + args, + { + "functionName" : "getUserList", + "returnType" : { + "tag" : "primitive" + }, + "argDefs" : [ + ], + "names" : { + "relay" : "-relay-", + "getDataSrv" : "getDataSrv", + "callbackSrv" : "callbackSrv", + "responseSrv" : "callbackSrv", + "responseFnName" : "response", + "errorHandlingSrv" : "errorHandlingSrv", + "errorFnName" : "error" + } +}, + script ) - ) - ) - (xor - (call %init_peer_id% ("callbackSrv" "response") [allUsers.$.users!]) - (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 5]) - ) - ) - (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 6]) -) +} - `, - ) - .configHandler((h) => { - h.on('getDataSrv', '-relay-', () => { - return peer.getStatus().relayPeerId; - }); - h.on('getDataSrv', 'me', () => {return me;}); - h.onEvent('callbackSrv', 'response', (args) => { - const [res] = args; - resolve(res); -}); + - h.onEvent('errorHandlingSrv', 'error', (args) => { - const [err] = args; - reject(err); - }); - }) - .handleScriptError(reject) - .handleTimeout(() => { - reject('Request timed out for initAfterJoin'); - }) - if(config && config.ttl) { - r.withTTL(config.ttl) +export function leave(config?: {ttl?: number}): Promise; +export function leave(peer: FluencePeer, config?: {ttl?: number}): Promise; +export function leave(...args: any) { + + let script = ` + (xor + (seq + (seq + (seq + (seq + (seq + (seq + (seq + (seq + (seq + (call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-) + (call %init_peer_id% ("fluence/get-config" "getApp") [] app) + ) + (call -relay- ("op" "noop") []) + ) + (xor + (seq + (call -relay- ("op" "noop") []) + (call app.$.user_list.peer_id! (app.$.user_list.service_id! "leave") [%init_peer_id%] res) + ) + (seq + (call -relay- ("op" "noop") []) + (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1]) + ) + ) + ) + (call -relay- ("op" "noop") []) + ) + (call %init_peer_id% ("fluence/get-config" "getApp") [] app0) + ) + (call -relay- ("op" "noop") []) + ) + (xor + (seq + (call -relay- ("op" "noop") []) + (call app0.$.user_list.peer_id! (app0.$.user_list.service_id! "get_users") [] allUsers) + ) + (seq + (call -relay- ("op" "noop") []) + (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 2]) + ) + ) + ) + (call -relay- ("op" "noop") []) + ) + (fold allUsers.$.users! user + (par + (seq + (call user.$.relay_id! ("op" "noop") []) + (xor + (call user.$.peer_id! ("fluence/fluent-pad/status" "notifyUserRemoved") [%init_peer_id%]) + (seq + (seq + (call user.$.relay_id! ("op" "noop") []) + (call -relay- ("op" "noop") []) + ) + (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 3]) + ) + ) + ) + (seq + (call -relay- ("op" "noop") []) + (next user) + ) + ) + ) + ) + (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 4]) + ) + ` + return callFunction( + args, + { + "functionName" : "leave", + "returnType" : { + "tag" : "void" + }, + "argDefs" : [ + ], + "names" : { + "relay" : "-relay-", + "getDataSrv" : "getDataSrv", + "callbackSrv" : "callbackSrv", + "responseSrv" : "callbackSrv", + "responseFnName" : "response", + "errorHandlingSrv" : "errorHandlingSrv", + "errorFnName" : "error" + } +}, + script + ) +} + +export type JoinArgUser = { name: string; peer_id: string; relay_id: string; } +export type JoinResult = { err_msg: string; ret_code: number; } +export function join(user: JoinArgUser, config?: {ttl?: number}): Promise; +export function join(peer: FluencePeer, user: JoinArgUser, config?: {ttl?: number}): Promise; +export function join(...args: any) { + + let script = ` + (xor + (seq + (seq + (seq + (seq + (seq + (seq + (call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-) + (call %init_peer_id% ("getDataSrv" "user") [] user) + ) + (call %init_peer_id% ("fluence/get-config" "getApp") [] app) + ) + (call -relay- ("op" "noop") []) + ) + (xor + (seq + (call -relay- ("op" "noop") []) + (call app.$.user_list.peer_id! (app.$.user_list.service_id! "join") [user] res) + ) + (seq + (call -relay- ("op" "noop") []) + (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1]) + ) + ) + ) + (call -relay- ("op" "noop") []) + ) + (xor + (call %init_peer_id% ("callbackSrv" "response") [res]) + (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 2]) + ) + ) + (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 3]) + ) + ` + return callFunction( + args, + { + "functionName" : "join", + "returnType" : { + "tag" : "primitive" + }, + "argDefs" : [ + { + "name" : "user", + "argType" : { + "tag" : "primitive" + } } - request = r.build(); - }); - peer.internals.initiateFlow(request!); - return promise; + ], + "names" : { + "relay" : "-relay-", + "getDataSrv" : "getDataSrv", + "callbackSrv" : "callbackSrv", + "responseSrv" : "callbackSrv", + "responseFnName" : "response", + "errorHandlingSrv" : "errorHandlingSrv", + "errorFnName" : "error" + } +}, + script + ) } - + +export type AuthResult = { err_msg: string; is_authenticated: boolean; ret_code: number; } +export function auth(config?: {ttl?: number}): Promise; +export function auth(peer: FluencePeer, config?: {ttl?: number}): Promise; +export function auth(...args: any) { - export function updateOnlineStatuses(config?: {ttl?: number}) : Promise; - export function updateOnlineStatuses(peer: FluencePeer, config?: {ttl?: number}) : Promise; - export function updateOnlineStatuses(...args: any) { - let peer: FluencePeer; - - let config: any; - if (FluencePeer.isInstance(args[0])) { - peer = args[0]; - config = args[1]; - } else { - peer = Fluence.getPeer(); - config = args[0]; - } - - let request: RequestFlow; - const promise = new Promise((resolve, reject) => { - const r = new RequestFlowBuilder() - .disableInjections() - .withRawScript( - ` - (xor - (seq - (seq - (seq - (seq - (seq - (call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-) - (call %init_peer_id% ("fluence/get-config" "getApp") [] app) - ) - (call -relay- ("op" "noop") []) + let script = ` + (xor + (seq + (seq + (seq + (seq + (seq + (call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-) + (call %init_peer_id% ("fluence/get-config" "getApp") [] app) + ) + (call -relay- ("op" "noop") []) + ) + (xor + (seq + (call -relay- ("op" "noop") []) + (call app.$.user_list.peer_id! (app.$.user_list.service_id! "is_authenticated") [] res) + ) + (seq + (call -relay- ("op" "noop") []) + (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1]) + ) + ) + ) + (call -relay- ("op" "noop") []) + ) + (xor + (call %init_peer_id% ("callbackSrv" "response") [res]) + (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 2]) + ) + ) + (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 3]) + ) + ` + return callFunction( + args, + { + "functionName" : "auth", + "returnType" : { + "tag" : "primitive" + }, + "argDefs" : [ + ], + "names" : { + "relay" : "-relay-", + "getDataSrv" : "getDataSrv", + "callbackSrv" : "callbackSrv", + "responseSrv" : "callbackSrv", + "responseFnName" : "response", + "errorHandlingSrv" : "errorHandlingSrv", + "errorFnName" : "error" + } +}, + script ) - (xor - (seq - (call -relay- ("op" "noop") []) - (call app.$.user_list.peer_id! (app.$.user_list.service_id! "get_users") [] allUsers) - ) - (seq - (call -relay- ("op" "noop") []) - (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1]) - ) - ) - ) - (call -relay- ("op" "noop") []) - ) - (fold allUsers.$.users! user - (par - (seq - (seq - (seq - (seq - (seq - (call -relay- ("op" "noop") []) - (call user.$.relay_id! ("op" "noop") []) - ) - (xor - (call user.$.peer_id! ("peer" "is_connected") [user.$.peer_id!] isOnline) - (seq - (seq - (seq - (call user.$.relay_id! ("op" "noop") []) - (call -relay- ("op" "noop") []) - ) - (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 2]) - ) - (call -relay- ("op" "noop") []) - ) - ) - ) - (call user.$.relay_id! ("op" "noop") []) - ) - (call -relay- ("op" "noop") []) - ) - (call %init_peer_id% ("fluence/fluent-pad/status" "notifyOnline") [user.$.peer_id! isOnline]) - ) - (seq - (call -relay- ("op" "noop") []) - (next user) - ) - ) - ) - ) - (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 3]) -) - - `, - ) - .configHandler((h) => { - h.on('getDataSrv', '-relay-', () => { - return peer.getStatus().relayPeerId; - }); - - h.onEvent('callbackSrv', 'response', (args) => { - -}); - - h.onEvent('errorHandlingSrv', 'error', (args) => { - const [err] = args; - reject(err); - }); - }) - .handleScriptError(reject) - .handleTimeout(() => { - reject('Request timed out for updateOnlineStatuses'); - }) - if(config && config.ttl) { - r.withTTL(config.ttl) - } - request = r.build(); - }); - peer.internals.initiateFlow(request!); - return Promise.race([promise, Promise.resolve()]); } - - - - export function getUserList(config?: {ttl?: number}) : Promise<{name:string;peer_id:string;relay_id:string}[]>; - export function getUserList(peer: FluencePeer, config?: {ttl?: number}) : Promise<{name:string;peer_id:string;relay_id:string}[]>; - export function getUserList(...args: any) { - let peer: FluencePeer; - - let config: any; - if (FluencePeer.isInstance(args[0])) { - peer = args[0]; - config = args[1]; - } else { - peer = Fluence.getPeer(); - config = args[0]; - } - - let request: RequestFlow; - const promise = new Promise<{name:string;peer_id:string;relay_id:string}[]>((resolve, reject) => { - const r = new RequestFlowBuilder() - .disableInjections() - .withRawScript( - ` - (xor - (seq - (seq - (seq - (seq - (seq - (call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-) - (call %init_peer_id% ("fluence/get-config" "getApp") [] app) - ) - (call -relay- ("op" "noop") []) - ) - (xor - (seq - (call -relay- ("op" "noop") []) - (call app.$.user_list.peer_id! (app.$.user_list.service_id! "get_users") [] allUsers) - ) - (seq - (call -relay- ("op" "noop") []) - (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1]) - ) - ) - ) - (call -relay- ("op" "noop") []) - ) - (xor - (call %init_peer_id% ("callbackSrv" "response") [allUsers.$.users!]) - (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 2]) - ) - ) - (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 3]) -) - - `, - ) - .configHandler((h) => { - h.on('getDataSrv', '-relay-', () => { - return peer.getStatus().relayPeerId; - }); - - h.onEvent('callbackSrv', 'response', (args) => { - const [res] = args; - resolve(res); -}); - - h.onEvent('errorHandlingSrv', 'error', (args) => { - const [err] = args; - reject(err); - }); - }) - .handleScriptError(reject) - .handleTimeout(() => { - reject('Request timed out for getUserList'); - }) - if(config && config.ttl) { - r.withTTL(config.ttl) - } - request = r.build(); - }); - peer.internals.initiateFlow(request!); - return promise; -} - - - - export function leave(config?: {ttl?: number}) : Promise; - export function leave(peer: FluencePeer, config?: {ttl?: number}) : Promise; - export function leave(...args: any) { - let peer: FluencePeer; - - let config: any; - if (FluencePeer.isInstance(args[0])) { - peer = args[0]; - config = args[1]; - } else { - peer = Fluence.getPeer(); - config = args[0]; - } - - let request: RequestFlow; - const promise = new Promise((resolve, reject) => { - const r = new RequestFlowBuilder() - .disableInjections() - .withRawScript( - ` - (xor - (seq - (seq - (seq - (seq - (seq - (seq - (seq - (seq - (seq - (call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-) - (call %init_peer_id% ("fluence/get-config" "getApp") [] app) - ) - (call -relay- ("op" "noop") []) - ) - (xor - (seq - (call -relay- ("op" "noop") []) - (call app.$.user_list.peer_id! (app.$.user_list.service_id! "leave") [%init_peer_id%] res) - ) - (seq - (call -relay- ("op" "noop") []) - (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1]) - ) - ) - ) - (call -relay- ("op" "noop") []) - ) - (call %init_peer_id% ("fluence/get-config" "getApp") [] app0) - ) - (call -relay- ("op" "noop") []) - ) - (xor - (seq - (call -relay- ("op" "noop") []) - (call app0.$.user_list.peer_id! (app0.$.user_list.service_id! "get_users") [] allUsers) - ) - (seq - (call -relay- ("op" "noop") []) - (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 2]) - ) - ) - ) - (call -relay- ("op" "noop") []) - ) - (fold allUsers.$.users! user - (par - (seq - (call user.$.relay_id! ("op" "noop") []) - (xor - (call user.$.peer_id! ("fluence/fluent-pad/status" "notifyUserRemoved") [%init_peer_id%]) - (seq - (seq - (call user.$.relay_id! ("op" "noop") []) - (call -relay- ("op" "noop") []) - ) - (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 3]) - ) - ) - ) - (seq - (call -relay- ("op" "noop") []) - (next user) - ) - ) - ) - ) - (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 4]) -) - - `, - ) - .configHandler((h) => { - h.on('getDataSrv', '-relay-', () => { - return peer.getStatus().relayPeerId; - }); - - h.onEvent('callbackSrv', 'response', (args) => { - -}); - - h.onEvent('errorHandlingSrv', 'error', (args) => { - const [err] = args; - reject(err); - }); - }) - .handleScriptError(reject) - .handleTimeout(() => { - reject('Request timed out for leave'); - }) - if(config && config.ttl) { - r.withTTL(config.ttl) - } - request = r.build(); - }); - peer.internals.initiateFlow(request!); - return Promise.race([promise, Promise.resolve()]); -} - - - - export function join(user: {name:string;peer_id:string;relay_id:string}, config?: {ttl?: number}) : Promise<{err_msg:string;ret_code:number}>; - export function join(peer: FluencePeer, user: {name:string;peer_id:string;relay_id:string}, config?: {ttl?: number}) : Promise<{err_msg:string;ret_code:number}>; - export function join(...args: any) { - let peer: FluencePeer; - let user: any; - let config: any; - if (FluencePeer.isInstance(args[0])) { - peer = args[0]; - user = args[1]; -config = args[2]; - } else { - peer = Fluence.getPeer(); - user = args[0]; -config = args[1]; - } - - let request: RequestFlow; - const promise = new Promise<{err_msg:string;ret_code:number}>((resolve, reject) => { - const r = new RequestFlowBuilder() - .disableInjections() - .withRawScript( - ` - (xor - (seq - (seq - (seq - (seq - (seq - (seq - (call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-) - (call %init_peer_id% ("getDataSrv" "user") [] user) - ) - (call %init_peer_id% ("fluence/get-config" "getApp") [] app) - ) - (call -relay- ("op" "noop") []) - ) - (xor - (seq - (call -relay- ("op" "noop") []) - (call app.$.user_list.peer_id! (app.$.user_list.service_id! "join") [user] res) - ) - (seq - (call -relay- ("op" "noop") []) - (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1]) - ) - ) - ) - (call -relay- ("op" "noop") []) - ) - (xor - (call %init_peer_id% ("callbackSrv" "response") [res]) - (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 2]) - ) - ) - (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 3]) -) - - `, - ) - .configHandler((h) => { - h.on('getDataSrv', '-relay-', () => { - return peer.getStatus().relayPeerId; - }); - h.on('getDataSrv', 'user', () => {return user;}); - h.onEvent('callbackSrv', 'response', (args) => { - const [res] = args; - resolve(res); -}); - - h.onEvent('errorHandlingSrv', 'error', (args) => { - const [err] = args; - reject(err); - }); - }) - .handleScriptError(reject) - .handleTimeout(() => { - reject('Request timed out for join'); - }) - if(config && config.ttl) { - r.withTTL(config.ttl) - } - request = r.build(); - }); - peer.internals.initiateFlow(request!); - return promise; -} - - - - export function auth(config?: {ttl?: number}) : Promise<{err_msg:string;is_authenticated:boolean;ret_code:number}>; - export function auth(peer: FluencePeer, config?: {ttl?: number}) : Promise<{err_msg:string;is_authenticated:boolean;ret_code:number}>; - export function auth(...args: any) { - let peer: FluencePeer; - - let config: any; - if (FluencePeer.isInstance(args[0])) { - peer = args[0]; - config = args[1]; - } else { - peer = Fluence.getPeer(); - config = args[0]; - } - - let request: RequestFlow; - const promise = new Promise<{err_msg:string;is_authenticated:boolean;ret_code:number}>((resolve, reject) => { - const r = new RequestFlowBuilder() - .disableInjections() - .withRawScript( - ` - (xor - (seq - (seq - (seq - (seq - (seq - (call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-) - (call %init_peer_id% ("fluence/get-config" "getApp") [] app) - ) - (call -relay- ("op" "noop") []) - ) - (xor - (seq - (call -relay- ("op" "noop") []) - (call app.$.user_list.peer_id! (app.$.user_list.service_id! "is_authenticated") [] res) - ) - (seq - (call -relay- ("op" "noop") []) - (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1]) - ) - ) - ) - (call -relay- ("op" "noop") []) - ) - (xor - (call %init_peer_id% ("callbackSrv" "response") [res]) - (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 2]) - ) - ) - (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 3]) -) - - `, - ) - .configHandler((h) => { - h.on('getDataSrv', '-relay-', () => { - return peer.getStatus().relayPeerId; - }); - - h.onEvent('callbackSrv', 'response', (args) => { - const [res] = args; - resolve(res); -}); - - h.onEvent('errorHandlingSrv', 'error', (args) => { - const [err] = args; - reject(err); - }); - }) - .handleScriptError(reject) - .handleTimeout(() => { - reject('Request timed out for auth'); - }) - if(config && config.ttl) { - r.withTTL(config.ttl) - } - request = r.build(); - }); - peer.internals.initiateFlow(request!); - return promise; -} -