fluencelabs/aqua-playground
1
0
Fork 0
mirror of https://github.com/fluencelabs/aqua-playground synced 2025-06-22 22:21:33 +00:00
Code Issues Projects Releases Wiki Activity

update aqua and fluence-js

Browse Source
This commit is contained in:
DieMyst
2021-04-23 17:21:58 +03:00
parent 35498536f4
commit 93a9d0e27d
17 changed files with 432 additions and 188 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
aqua/constants.aqua Normal file
View File

@ -0,0 +1,14 @@
import "println.aqua"
const c = "hello"
-- a question mark means that this constant could be rewritten before this definition
const c ?= "default string"
const a = 1
func printConstant():
if a == 1:
print(c)
else:
print(c)

189
package-lock.json generated
View File

@ -5,22 +5,22 @@
"requires": true,
"dependencies": {
"@fluencelabs/aqua-cli": {
"version": "0.1.1-83",
"resolved": "https://registry.npmjs.org/@fluencelabs/aqua-cli/-/aqua-cli-0.1.1-83.tgz",
"integrity": "sha512-qTpYEzbIuzZswn09ORwHpP4PLmm5y+eo1ep6kZfCBUGAbFcwoZn8hRVGE2miwxRK2/Xec0BT2Krmazdtf8MGoA==",
"version": "0.1.1-90",
"resolved": "https://registry.npmjs.org/@fluencelabs/aqua-cli/-/aqua-cli-0.1.1-90.tgz",
"integrity": "sha512-WKAElL9BQ2pX6f6RZx5isum4BrkbG6mBagszY7qchO9cigyUiq5GLWT82EBbbH8XTIbIdmERC9t5vZzyT1BDcA==",
"dev": true
},
"@fluencelabs/aquamarine-interpreter": {
"version": "0.7.9",
"resolved": "https://registry.npmjs.org/@fluencelabs/aquamarine-interpreter/-/aquamarine-interpreter-0.7.9.tgz",
"integrity": "sha512-VXbHm0d05XMjTSzOTcb+spVRrIuMcrw8/3dl197wH0jx1C3Wou+vAapQLvGNcKzqDhktPOOzJTE4UARYd0lFMw=="
"version": "0.8.2",
"resolved": "https://registry.npmjs.org/@fluencelabs/aquamarine-interpreter/-/aquamarine-interpreter-0.8.2.tgz",
"integrity": "sha512-WYn3fO3dy/ZTS2DnjpEv59RAFTuPosO65jejb/2QRAbZId4KiaCxma0yvFC6P0j2qoAxCDTRdbKrNZGXzjddYQ=="
},
"@fluencelabs/fluence": {
"version": "0.9.39",
"resolved": "https://registry.npmjs.org/@fluencelabs/fluence/-/fluence-0.9.39.tgz",
"integrity": "sha512-djrS4upd4oYJkpF4cS6vw4UJon/UFY/zw/2MeD/Qc1f13rg+Vg2RfoTkPZvtaQ+3O8SXU4okbt3KOdKvfaulZw==",
"version": "0.9.43",
"resolved": "https://registry.npmjs.org/@fluencelabs/fluence/-/fluence-0.9.43.tgz",
"integrity": "sha512-7n+BM1IOLqdF8xZBqybjwUC1jeyQfuzrrMeAVfXvaS5gNuB6sz9fJiknqOZNiOZkQG2KfG3YLO5V6kM9QNupeQ==",
"requires": {
"@fluencelabs/aquamarine-interpreter": "0.7.9",
"@fluencelabs/aquamarine-interpreter": "0.8.2",
"async": "3.2.0",
"base64-js": "1.3.1",
"bs58": "4.0.1",
@ -160,9 +160,9 @@
"integrity": "sha512-5tXH6Bx/kNGd3MgffdmP4dy2Z+G4eaXw0SE81Tq3BNadtnMR5/ySMzX4SLEzHJzSmPNn4HIdpQsBvXMUykr58w=="
},
"@types/node": {
"version": "14.14.37",
"resolved": "https://registry.npmjs.org/@types/node/-/node-14.14.37.tgz",
"integrity": "sha512-XYmBiy+ohOR4Lh5jE379fV2IU+6Jn4g5qASinhitfyO71b/sCo6MKsMLF5tc7Zf2CE8hViVQyYSobJNke8OvUw=="
"version": "14.14.41",
"resolved": "https://registry.npmjs.org/@types/node/-/node-14.14.41.tgz",
"integrity": "sha512-dueRKfaJL4RTtSa7bWeTK1M+VH+Gns73oCgzvYfHZywRCoPSd8EkXBL0mZ9unPTveBn+D9phZBaxuzpwjWkW0g=="
},
"@types/retry": {
"version": "0.12.0",
@ -771,9 +771,9 @@
"integrity": "sha512-v+dm9bNVfOYsY1OrhaCrmyOcYoSeVvbt+hHZ0Au+T+p1y+0Uyj9aMaGIeUTT6xdpRbWzDeYKvfOslPhggQMcsg=="
},
"get-stream": {
"version": "6.0.0",
"resolved": "https://registry.npmjs.org/get-stream/-/get-stream-6.0.0.tgz",
"integrity": "sha512-A1B3Bh1UmL0bidM/YX2NsCOTnGJePL9rO/M+Mw3m9f2gUpfokS0hi5Eah0WSUEWZdZhIZtMjkIYS7mDfOqNHbg=="
"version": "6.0.1",
"resolved": "https://registry.npmjs.org/get-stream/-/get-stream-6.0.1.tgz",
"integrity": "sha512-ts6Wi+2j3jQjqi70w5AlN8DFnkSwC+MqmxEzdEALB2qXZYV3X/b1CTfgPLGJNMeAWxdPfU8FO1ms3NUfaHCPYg=="
},
"getpass": {
"version": "0.1.7",
@ -1223,25 +1223,66 @@
}
},
"it-pb-rpc": {
"version": "0.1.9",
"resolved": "https://registry.npmjs.org/it-pb-rpc/-/it-pb-rpc-0.1.9.tgz",
"integrity": "sha512-IMPXz+a+lUEclV5qIlT/1WAjCMIZyqQtMRaKaL8cwgvH2P5LtMJlrbNZr3b4VEONK1H6mqAV1upfMTSSBSrOqA==",
"version": "0.1.11",
"resolved": "https://registry.npmjs.org/it-pb-rpc/-/it-pb-rpc-0.1.11.tgz",
"integrity": "sha512-1Yvae7LNHNM/WzxWT7OyHqwpA7DZoGos22JioMZ5H6i9iExQf71NHE0phHKEfkJdWLo7SRqPLLbqs2zaeKCwPA==",
"requires": {
"is-buffer": "^2.0.4",
"it-handshake": "^1.0.2",
"it-length-prefixed": "^3.1.0"
"is-buffer": "^2.0.5",
"it-handshake": "^2.0.0",
"it-length-prefixed": "^5.0.2"
},
"dependencies": {
"it-length-prefixed": {
"version": "3.1.0",
"resolved": "https://registry.npmjs.org/it-length-prefixed/-/it-length-prefixed-3.1.0.tgz",
"integrity": "sha512-E5GwT6qfZEwh3/XThyYwgjKJ4/hxvTC9kdbj3gxXDeUDKtC7+K2T647sPeX7xDEWqunsnoQyvOrjoHPegaT3uw==",
"bl": {
"version": "5.0.0",
"resolved": "https://registry.npmjs.org/bl/-/bl-5.0.0.tgz",
"integrity": "sha512-8vxFNZ0pflFfi0WXA3WQXlj6CaMEwsmh63I1CNp0q+wWv8sD0ARx1KovSQd0l2GkwrMIOyedq0EF1FxI+RCZLQ==",
"requires": {
"@types/bl": "^2.1.0",
"bl": "^4.0.2",
"buffer": "^5.5.0",
"varint": "^5.0.0"
"buffer": "^6.0.3",
"inherits": "^2.0.4",
"readable-stream": "^3.4.0"
}
},
"buffer": {
"version": "6.0.3",
"resolved": "https://registry.npmjs.org/buffer/-/buffer-6.0.3.tgz",
"integrity": "sha512-FTiCpNxtwiZZHEZbcbTIcZjERVICn9yq/pDFkTl95/AxzD1naBctN7YO68riM/gLSDY7sdrMby8hofADYuuqOA==",
"requires": {
"base64-js": "^1.3.1",
"ieee754": "^1.2.1"
}
},
"it-handshake": {
"version": "2.0.0",
"resolved": "https://registry.npmjs.org/it-handshake/-/it-handshake-2.0.0.tgz",
"integrity": "sha512-K4q+mz8aLlCK3vTjtgNdHC9c/JbuOATsfogarjMsLcBZC5vYfKbX3Gq3AWcCdjIsIrPqzTlhPKSxl64LJkrt2w==",
"requires": {
"it-pushable": "^1.4.0",
"it-reader": "^3.0.0",
"p-defer": "^3.0.0"
}
},
"it-length-prefixed": {
"version": "5.0.2",
"resolved": "https://registry.npmjs.org/it-length-prefixed/-/it-length-prefixed-5.0.2.tgz",
"integrity": "sha512-SqAURaKKsjYbROIdTjW3UtqGrdZo1SHnkbeYYp7JwC5P0IIy7r4C0xNkmK2Va/fBmvXA++hMdDON9+2zesQlUA==",
"requires": {
"bl": "^5.0.0",
"buffer": "^6.0.3",
"varint": "^6.0.0"
}
},
"it-reader": {
"version": "3.0.0",
"resolved": "https://registry.npmjs.org/it-reader/-/it-reader-3.0.0.tgz",
"integrity": "sha512-NxR40odATeaBmSefn6Xn43DplYvn2KtEKQzn4jrTRuPYXMky5M4e+KQ7aTJh0k0vkytLyeenGO1I1GXlGm4laQ==",
"requires": {
"bl": "^5.0.0"
}
},
"varint": {
"version": "6.0.0",
"resolved": "https://registry.npmjs.org/varint/-/varint-6.0.0.tgz",
"integrity": "sha512-cXEIW6cfr15lFv563k4GuVuW/fiwjknytD37jIOLSdSWuOI6WnO/oKwmP2FQTU2l01LP8/M5TSAJpzUaGe3uWg=="
}
}
},
@ -2060,9 +2101,9 @@
}
},
"uint8arrays": {
"version": "2.1.4",
"resolved": "https://registry.npmjs.org/uint8arrays/-/uint8arrays-2.1.4.tgz",
"integrity": "sha512-Q/Ys2JhFWpZkw8Hi2Zz7NFpVDH8avK9k2NjYKdOHoOAn5dTtOSNT9xMtaQz5D4kWVPOGKte8CAroEIdTzvF9AA==",
"version": "2.1.5",
"resolved": "https://registry.npmjs.org/uint8arrays/-/uint8arrays-2.1.5.tgz",
"integrity": "sha512-CSR7AO+4AHUeSOnZ/NBNCElDeWfRh9bXtOck27083kc7SznmmHIhNEkEOCQOn0wvrIMjS3IH0TNLR16vuc46mA==",
"requires": {
"multibase": "^4.0.1"
}
@ -2096,9 +2137,9 @@
}
},
"uint8arrays": {
"version": "2.1.4",
"resolved": "https://registry.npmjs.org/uint8arrays/-/uint8arrays-2.1.4.tgz",
"integrity": "sha512-Q/Ys2JhFWpZkw8Hi2Zz7NFpVDH8avK9k2NjYKdOHoOAn5dTtOSNT9xMtaQz5D4kWVPOGKte8CAroEIdTzvF9AA==",
"version": "2.1.5",
"resolved": "https://registry.npmjs.org/uint8arrays/-/uint8arrays-2.1.5.tgz",
"integrity": "sha512-CSR7AO+4AHUeSOnZ/NBNCElDeWfRh9bXtOck27083kc7SznmmHIhNEkEOCQOn0wvrIMjS3IH0TNLR16vuc46mA==",
"requires": {
"multibase": "^4.0.1"
}
@ -2124,9 +2165,9 @@
}
},
"uint8arrays": {
"version": "2.1.4",
"resolved": "https://registry.npmjs.org/uint8arrays/-/uint8arrays-2.1.4.tgz",
"integrity": "sha512-Q/Ys2JhFWpZkw8Hi2Zz7NFpVDH8avK9k2NjYKdOHoOAn5dTtOSNT9xMtaQz5D4kWVPOGKte8CAroEIdTzvF9AA==",
"version": "2.1.5",
"resolved": "https://registry.npmjs.org/uint8arrays/-/uint8arrays-2.1.5.tgz",
"integrity": "sha512-CSR7AO+4AHUeSOnZ/NBNCElDeWfRh9bXtOck27083kc7SznmmHIhNEkEOCQOn0wvrIMjS3IH0TNLR16vuc46mA==",
"requires": {
"multibase": "^4.0.1"
}
@ -2335,9 +2376,9 @@
"integrity": "sha512-fexhUFFPTGV8ybAtSIGbV6gOkSv8UtRbDBnAyLQw4QPKkgNlsH2ByPGtMUqdWkos6YCRmAqViwgZrJc/mRDzZQ=="
},
"object-inspect": {
"version": "1.9.0",
"resolved": "https://registry.npmjs.org/object-inspect/-/object-inspect-1.9.0.tgz",
"integrity": "sha512-i3Bp9iTqwhaLZBxGkRfo5ZbE07BQRT7MGu8+nNgwW9ItGp1TzCTw2DLEoWwjClxBjOFI/hWljTAmYGCEwmtnOw=="
"version": "1.10.2",
"resolved": "https://registry.npmjs.org/object-inspect/-/object-inspect-1.10.2.tgz",
"integrity": "sha512-gz58rdPpadwztRrPjZE9DZLOABUpTGdcANUgOwBFO1C+HZZhePoP83M65WGDmbpwFYJSWqavbl4SgDn4k8RYTA=="
},
"object-keys": {
"version": "1.1.1",
@ -2581,9 +2622,9 @@
"integrity": "sha1-Ywn04OX6kT7BxpMHrjZLSzd8nns="
},
"private-ip": {
"version": "2.2.0",
"resolved": "https://registry.npmjs.org/private-ip/-/private-ip-2.2.0.tgz",
"integrity": "sha512-2bPfzZfESxwPE+b8RezesOdnSwcLlnem3U0dV/5ayqbWZHI/bq63WlQR3dOSnLYNp13+h2ZJ894WPSUcqQqaAg==",
"version": "2.2.1",
"resolved": "https://registry.npmjs.org/private-ip/-/private-ip-2.2.1.tgz",
"integrity": "sha512-jN1WT/br/VNW9xEcwHr6DjtOKxQ5qOIqmh7o+co2TWgq56pZJw99iO3UT1tWdfgsQiyK9FqG4ji3ykwpjFqITA==",
"requires": {
"ip-regex": "^4.3.0",
"netmask": "^2.0.2"
@ -2610,9 +2651,9 @@
},
"dependencies": {
"@types/node": {
"version": "13.13.48",
"resolved": "https://registry.npmjs.org/@types/node/-/node-13.13.48.tgz",
"integrity": "sha512-z8wvSsgWQzkr4sVuMEEOvwMdOQjiRY2Y/ZW4fDfjfe3+TfQrZqFKOthBgk2RnVEmtOKrkwdZ7uTvsxTBLjKGDQ=="
"version": "13.13.50",
"resolved": "https://registry.npmjs.org/@types/node/-/node-13.13.50.tgz",
"integrity": "sha512-y7kkh+hX/0jZNxMyBR/6asG0QMSaPSzgeVK63dhWHl4QAXCQB8lExXmzLL6SzmOgKHydtawpMnNhlDbv7DXPEA=="
}
}
},
@ -2622,34 +2663,14 @@
"integrity": "sha512-YVCvdhxWNDP8/nJDyXLuM+UFsuPk4+1PB7WGPVDzm3HTHbzFLxQYeW2iZpS4mmnXrQJGBzt230t/BbEb7PrQaw=="
},
"protons": {
"version": "2.0.0",
"resolved": "https://registry.npmjs.org/protons/-/protons-2.0.0.tgz",
"integrity": "sha512-BTrE9D6/d1NGis+0D8TqAO1THdn4evHQhfjapA0NUaRH4+ecJJcbqaF7TE/DKv5czE9VB/TeOllBOmCyJhHnhg==",
"version": "2.0.1",
"resolved": "https://registry.npmjs.org/protons/-/protons-2.0.1.tgz",
"integrity": "sha512-FlmPorLEeCEDPu+uIn0Qardgiy5XqVA4IyNTz9wb9c0e2U7BEXdRcIbx64r09o4Abtf+4B7mkTtMbsIXMxZzKw==",
"requires": {
"protocol-buffers-schema": "^3.3.1",
"signed-varint": "^2.0.1",
"uint8arrays": "^1.0.0",
"uint8arrays": "^2.1.3",
"varint": "^5.0.0"
},
"dependencies": {
"multibase": {
"version": "3.1.2",
"resolved": "https://registry.npmjs.org/multibase/-/multibase-3.1.2.tgz",
"integrity": "sha512-bpklWHs70LO3smJUHOjcnzGceJJvn9ui0Vau6Za0B/GBepaXswmW8Ufea0uD9pROf/qCQ4N4lZ3sf3U+SNf0tw==",
"requires": {
"@multiformats/base-x": "^4.0.1",
"web-encoding": "^1.0.6"
}
},
"uint8arrays": {
"version": "1.1.0",
"resolved": "https://registry.npmjs.org/uint8arrays/-/uint8arrays-1.1.0.tgz",
"integrity": "sha512-cLdlZ6jnFczsKf5IH1gPHTtcHtPGho5r4CvctohmQjw8K7Q3gFdfIGHxSTdTaCKrL4w09SsPRJTqRS0drYeszA==",
"requires": {
"multibase": "^3.0.0",
"web-encoding": "^1.0.2"
}
}
}
},
"psl": {
@ -2849,9 +2870,9 @@
}
},
"stream-to-it": {
"version": "0.2.2",
"resolved": "https://registry.npmjs.org/stream-to-it/-/stream-to-it-0.2.2.tgz",
"integrity": "sha512-waULBmQpVdr6TkDzci6t1P7dIaSZ0bHC1TaPXDUeJC5PpSK7U3T0H0Zeo/LWUnd6mnhXOmGGDKAkjUCHw5IOng==",
"version": "0.2.3",
"resolved": "https://registry.npmjs.org/stream-to-it/-/stream-to-it-0.2.3.tgz",
"integrity": "sha512-xaK9EjPtLox5rrC7YLSBXSanTtUJN/lzJlMFvy9VaROmnyvy0U/X6m2uMhXPJRn3g3M9uOSIzTszW7BPiWSg9w==",
"requires": {
"get-iterator": "^1.0.2"
}
@ -2965,9 +2986,9 @@
"dev": true
},
"uint8arrays": {
"version": "2.1.4",
"resolved": "https://registry.npmjs.org/uint8arrays/-/uint8arrays-2.1.4.tgz",
"integrity": "sha512-Q/Ys2JhFWpZkw8Hi2Zz7NFpVDH8avK9k2NjYKdOHoOAn5dTtOSNT9xMtaQz5D4kWVPOGKte8CAroEIdTzvF9AA==",
"version": "2.1.5",
"resolved": "https://registry.npmjs.org/uint8arrays/-/uint8arrays-2.1.5.tgz",
"integrity": "sha512-CSR7AO+4AHUeSOnZ/NBNCElDeWfRh9bXtOck27083kc7SznmmHIhNEkEOCQOn0wvrIMjS3IH0TNLR16vuc46mA==",
"requires": {
"multibase": "^4.0.1"
},
@ -3064,9 +3085,9 @@
}
},
"web-encoding": {
"version": "1.1.4",
"resolved": "https://registry.npmjs.org/web-encoding/-/web-encoding-1.1.4.tgz",
"integrity": "sha512-EJn3rQ/blHgaOTG8XvxGsZXTCyw9p1RAaDI/L0W3jjJRvW25F8uRshacU4h49wc9Fj0JlKU+oyOKm40HDAj75w==",
"version": "1.1.5",
"resolved": "https://registry.npmjs.org/web-encoding/-/web-encoding-1.1.5.tgz",
"integrity": "sha512-HYLeVCdJ0+lBYV2FvNZmv3HJ2Nt0QYXqZojk3d9FJOLkwnuhzM9tmamh8d7HPM8QqjKH8DeHkFTx+CFlWpZZDA==",
"requires": {
"@zxing/text-encoding": "0.9.0",
"util": "^0.12.3"
@ -3107,9 +3128,9 @@
}
},
"ws": {
"version": "7.4.4",
"resolved": "https://registry.npmjs.org/ws/-/ws-7.4.4.tgz",
"integrity": "sha512-Qm8k8ojNQIMx7S+Zp8u/uHOx7Qazv3Yv4q68MiWWWOJhiwG5W3x7iqmRtJo8xxrciZUY4vRxUTJCKuRnF28ZZw=="
"version": "7.4.5",
"resolved": "https://registry.npmjs.org/ws/-/ws-7.4.5.tgz",
"integrity": "sha512-xzyu3hFvomRfXKH8vOFMU3OguG6oOvhXMo3xsGy3xWExqaM2dxBbVxuD99O7m3ZUFMvvscsZDqxfgMaRr/Nr1g=="
},
"xml2js": {
"version": "0.4.23",

4
package.json
View File

@ -22,12 +22,12 @@
"compile-aqua:air": "aqua-cli -i ./aqua/ -o ./compiled-air -a"
},
"devDependencies": {
"@fluencelabs/aqua-cli": "^0.1.1-83",
"@fluencelabs/aqua-cli": "^0.1.1-90",
"ts-node": "^9.1.1",
"typescript": "^4.2.4"
},
"dependencies": {
"@fluencelabs/fluence": "0.9.39",
"@fluencelabs/fluence": "0.9.43",
"@fluencelabs/fluence-network-environment": "1.0.8"
},
"description": "Minimal template for aquamarine project."

14
src/compiled/builtin.ts
View File

@ -1,3 +1,10 @@
/**
*
* 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
*
*/
import { FluenceClient, PeerIdB58 } from '@fluencelabs/fluence';
import { RequestFlowBuilder } from '@fluencelabs/fluence/dist/api.unstable';
@ -7,6 +14,7 @@ export async function id(client: FluenceClient): Promise<void> {
let request;
const promise = new Promise<void>((resolve, reject) => {
request = new RequestFlowBuilder()
.disableInjections()
.withRawScript(
`
(xor
@ -21,14 +29,14 @@ export async function id(client: FluenceClient): Promise<void> {
)
.configHandler((h) => {
h.on('getDataSrv', 'relay', () => {
return client.relayPeerId;
return client.relayPeerId!;
});
h.on('getRelayService', 'hasReleay', () => {// Not Used
return client.relayPeerId !== undefined;
});
h.on('errorHandlingSrv', 'error', (args) => {
h.onEvent('errorHandlingSrv', 'error', (args) => {
// assuming error is the single argument
const [err] = args;
reject(err);
@ -36,7 +44,7 @@ export async function id(client: FluenceClient): Promise<void> {
})
.handleScriptError(reject)
.handleTimeout(() => {
reject('Request timed out');
reject('Request timed out for id');
})
.build();
});

32
src/compiled/callArrow.ts
View File

@ -1,3 +1,10 @@
/**
*
* 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
*
*/
import { FluenceClient, PeerIdB58 } from '@fluencelabs/fluence';
import { RequestFlowBuilder } from '@fluencelabs/fluence/dist/api.unstable';
@ -7,13 +14,14 @@ export async function print(client: FluenceClient, str: string): Promise<void> {
let request;
const promise = new Promise<void>((resolve, reject) => {
request = new RequestFlowBuilder()
.disableInjections()
.withRawScript(
`
(xor
(seq
(seq
(call %init_peer_id% ("getDataSrv" "str") [] str)
(call %init_peer_id% ("getDataSrv" "relay") [] relay)
(call %init_peer_id% ("getDataSrv" "str") [] str)
)
(call %init_peer_id% ("println-service-id" "print") [str])
)
@ -24,14 +32,14 @@ export async function print(client: FluenceClient, str: string): Promise<void> {
)
.configHandler((h) => {
h.on('getDataSrv', 'relay', () => {
return client.relayPeerId;
return client.relayPeerId!;
});
h.on('getRelayService', 'hasReleay', () => {// Not Used
return client.relayPeerId !== undefined;
});
h.on('getDataSrv', 'str', () => {return str;});
h.on('errorHandlingSrv', 'error', (args) => {
h.onEvent('errorHandlingSrv', 'error', (args) => {
// assuming error is the single argument
const [err] = args;
reject(err);
@ -39,7 +47,7 @@ export async function print(client: FluenceClient, str: string): Promise<void> {
})
.handleScriptError(reject)
.handleTimeout(() => {
reject('Request timed out');
reject('Request timed out for print');
})
.build();
});
@ -53,6 +61,7 @@ export async function id(client: FluenceClient): Promise<void> {
let request;
const promise = new Promise<void>((resolve, reject) => {
request = new RequestFlowBuilder()
.disableInjections()
.withRawScript(
`
(xor
@ -67,14 +76,14 @@ export async function id(client: FluenceClient): Promise<void> {
)
.configHandler((h) => {
h.on('getDataSrv', 'relay', () => {
return client.relayPeerId;
return client.relayPeerId!;
});
h.on('getRelayService', 'hasReleay', () => {// Not Used
return client.relayPeerId !== undefined;
});
h.on('errorHandlingSrv', 'error', (args) => {
h.onEvent('errorHandlingSrv', 'error', (args) => {
// assuming error is the single argument
const [err] = args;
reject(err);
@ -82,7 +91,7 @@ export async function id(client: FluenceClient): Promise<void> {
})
.handleScriptError(reject)
.handleTimeout(() => {
reject('Request timed out');
reject('Request timed out for id');
})
.build();
});
@ -96,13 +105,14 @@ export async function passFunctionAsArg(client: FluenceClient, node: string, c:
let request;
const promise = new Promise<void>((resolve, reject) => {
request = new RequestFlowBuilder()
.disableInjections()
.withRawScript(
`
(xor
(seq
(seq
(call %init_peer_id% ("getDataSrv" "node") [] node)
(call %init_peer_id% ("getDataSrv" "relay") [] relay)
(call %init_peer_id% ("getDataSrv" "node") [] node)
)
(seq
(seq
@ -134,7 +144,7 @@ export async function passFunctionAsArg(client: FluenceClient, node: string, c:
)
.configHandler((h) => {
h.on('getDataSrv', 'relay', () => {
return client.relayPeerId;
return client.relayPeerId!;
});
h.on('getRelayService', 'hasReleay', () => {// Not Used
return client.relayPeerId !== undefined;
@ -142,7 +152,7 @@ export async function passFunctionAsArg(client: FluenceClient, node: string, c:
h.on('getDataSrv', 'node', () => {return node;});
h.on('callbackSrv', 'c', (args) => {return c(args[0]);});
h.on('errorHandlingSrv', 'error', (args) => {
h.onEvent('errorHandlingSrv', 'error', (args) => {
// assuming error is the single argument
const [err] = args;
reject(err);
@ -150,7 +160,7 @@ h.on('callbackSrv', 'c', (args) => {return c(args[0]);});
})
.handleScriptError(reject)
.handleTimeout(() => {
reject('Request timed out');
reject('Request timed out for passFunctionAsArg');
})
.build();
});

52
src/compiled/complex.ts
View File

@ -1,3 +1,10 @@
/**
*
* 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
*
*/
import { FluenceClient, PeerIdB58 } from '@fluencelabs/fluence';
import { RequestFlowBuilder } from '@fluencelabs/fluence/dist/api.unstable';
@ -7,14 +14,15 @@ export async function helloWorld(client: FluenceClient, name: string): Promise<s
let request;
const promise = new Promise<string>((resolve, reject) => {
request = new RequestFlowBuilder()
.disableInjections()
.withRawScript(
`
(xor
(seq
(seq
(seq
(call %init_peer_id% ("getDataSrv" "name") [] name)
(call %init_peer_id% ("getDataSrv" "relay") [] relay)
(call %init_peer_id% ("getDataSrv" "name") [] name)
)
(call %init_peer_id% ("service-id" "addNameToHello") [name] res)
)
@ -27,18 +35,18 @@ export async function helloWorld(client: FluenceClient, name: string): Promise<s
)
.configHandler((h) => {
h.on('getDataSrv', 'relay', () => {
return client.relayPeerId;
return client.relayPeerId!;
});
h.on('getRelayService', 'hasReleay', () => {// Not Used
return client.relayPeerId !== undefined;
});
h.on('getDataSrv', 'name', () => {return name;});
h.on('callbackSrv', 'response', (args) => {
h.onEvent('callbackSrv', 'response', (args) => {
const [res] = args;
resolve(res);
});
h.on('errorHandlingSrv', 'error', (args) => {
h.onEvent('errorHandlingSrv', 'error', (args) => {
// assuming error is the single argument
const [err] = args;
reject(err);
@ -46,7 +54,7 @@ export async function helloWorld(client: FluenceClient, name: string): Promise<s
})
.handleScriptError(reject)
.handleTimeout(() => {
reject('Request timed out');
reject('Request timed out for helloWorld');
})
.build();
});
@ -60,13 +68,14 @@ export async function print(client: FluenceClient, str: string): Promise<void> {
let request;
const promise = new Promise<void>((resolve, reject) => {
request = new RequestFlowBuilder()
.disableInjections()
.withRawScript(
`
(xor
(seq
(seq
(call %init_peer_id% ("getDataSrv" "str") [] str)
(call %init_peer_id% ("getDataSrv" "relay") [] relay)
(call %init_peer_id% ("getDataSrv" "str") [] str)
)
(call %init_peer_id% ("println-service-id" "print") [str])
)
@ -77,14 +86,14 @@ export async function print(client: FluenceClient, str: string): Promise<void> {
)
.configHandler((h) => {
h.on('getDataSrv', 'relay', () => {
return client.relayPeerId;
return client.relayPeerId!;
});
h.on('getRelayService', 'hasReleay', () => {// Not Used
return client.relayPeerId !== undefined;
});
h.on('getDataSrv', 'str', () => {return str;});
h.on('errorHandlingSrv', 'error', (args) => {
h.onEvent('errorHandlingSrv', 'error', (args) => {
// assuming error is the single argument
const [err] = args;
reject(err);
@ -92,7 +101,7 @@ export async function print(client: FluenceClient, str: string): Promise<void> {
})
.handleScriptError(reject)
.handleTimeout(() => {
reject('Request timed out');
reject('Request timed out for print');
})
.build();
});
@ -106,6 +115,7 @@ export async function id(client: FluenceClient): Promise<void> {
let request;
const promise = new Promise<void>((resolve, reject) => {
request = new RequestFlowBuilder()
.disableInjections()
.withRawScript(
`
(xor
@ -120,14 +130,14 @@ export async function id(client: FluenceClient): Promise<void> {
)
.configHandler((h) => {
h.on('getDataSrv', 'relay', () => {
return client.relayPeerId;
return client.relayPeerId!;
});
h.on('getRelayService', 'hasReleay', () => {// Not Used
return client.relayPeerId !== undefined;
});
h.on('errorHandlingSrv', 'error', (args) => {
h.onEvent('errorHandlingSrv', 'error', (args) => {
// assuming error is the single argument
const [err] = args;
reject(err);
@ -135,7 +145,7 @@ export async function id(client: FluenceClient): Promise<void> {
})
.handleScriptError(reject)
.handleTimeout(() => {
reject('Request timed out');
reject('Request timed out for id');
})
.build();
});
@ -149,6 +159,7 @@ export async function testFunc(client: FluenceClient): Promise<string> {
let request;
const promise = new Promise<string>((resolve, reject) => {
request = new RequestFlowBuilder()
.disableInjections()
.withRawScript(
`
(xor
@ -166,18 +177,18 @@ export async function testFunc(client: FluenceClient): Promise<string> {
)
.configHandler((h) => {
h.on('getDataSrv', 'relay', () => {
return client.relayPeerId;
return client.relayPeerId!;
});
h.on('getRelayService', 'hasReleay', () => {// Not Used
return client.relayPeerId !== undefined;
});
h.on('callbackSrv', 'response', (args) => {
h.onEvent('callbackSrv', 'response', (args) => {
const [res] = args;
resolve(res);
});
h.on('errorHandlingSrv', 'error', (args) => {
h.onEvent('errorHandlingSrv', 'error', (args) => {
// assuming error is the single argument
const [err] = args;
reject(err);
@ -185,7 +196,7 @@ export async function testFunc(client: FluenceClient): Promise<string> {
})
.handleScriptError(reject)
.handleTimeout(() => {
reject('Request timed out');
reject('Request timed out for testFunc');
})
.build();
});
@ -199,13 +210,14 @@ export async function doStuff(client: FluenceClient, a: string): Promise<void> {
let request;
const promise = new Promise<void>((resolve, reject) => {
request = new RequestFlowBuilder()
.disableInjections()
.withRawScript(
`
(xor
(seq
(seq
(call %init_peer_id% ("getDataSrv" "a") [] a)
(call %init_peer_id% ("getDataSrv" "relay") [] relay)
(call %init_peer_id% ("getDataSrv" "a") [] a)
)
(par
(par
@ -225,14 +237,14 @@ export async function doStuff(client: FluenceClient, a: string): Promise<void> {
)
.configHandler((h) => {
h.on('getDataSrv', 'relay', () => {
return client.relayPeerId;
return client.relayPeerId!;
});
h.on('getRelayService', 'hasReleay', () => {// Not Used
return client.relayPeerId !== undefined;
});
h.on('getDataSrv', 'a', () => {return a;});
h.on('errorHandlingSrv', 'error', (args) => {
h.onEvent('errorHandlingSrv', 'error', (args) => {
// assuming error is the single argument
const [err] = args;
reject(err);
@ -240,7 +252,7 @@ export async function doStuff(client: FluenceClient, a: string): Promise<void> {
})
.handleScriptError(reject)
.handleTimeout(() => {
reject('Request timed out');
reject('Request timed out for doStuff');
})
.build();
});

106
src/compiled/constants.ts Normal file
View File

@ -0,0 +1,106 @@
/**
*
* 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
*
*/
import { FluenceClient, PeerIdB58 } from '@fluencelabs/fluence';
import { RequestFlowBuilder } from '@fluencelabs/fluence/dist/api.unstable';
export async function print(client: FluenceClient, str: string): Promise<void> {
let request;
const promise = new Promise<void>((resolve, reject) => {
request = new RequestFlowBuilder()
.disableInjections()
.withRawScript(
`
(xor
(seq
(seq
(call %init_peer_id% ("getDataSrv" "relay") [] relay)
(call %init_peer_id% ("getDataSrv" "str") [] str)
)
(call %init_peer_id% ("println-service-id" "print") [str])
)
(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', 'str', () => {return str;});
h.onEvent('errorHandlingSrv', 'error', (args) => {
// assuming error is the single argument
const [err] = args;
reject(err);
});
})
.handleScriptError(reject)
.handleTimeout(() => {
reject('Request timed out for print');
})
.build();
});
await client.initiateFlow(request);
return Promise.race([promise, Promise.resolve()]);
}
export async function printConstant(client: FluenceClient): Promise<void> {
let request;
const promise = new Promise<void>((resolve, reject) => {
request = new RequestFlowBuilder()
.disableInjections()
.withRawScript(
`
(xor
(seq
(call %init_peer_id% ("getDataSrv" "relay") [] relay)
(xor
(match 1 1
(call %init_peer_id% ("println-service-id" "print") ["hello"])
)
(call %init_peer_id% ("println-service-id" "print") ["hello"])
)
)
(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.onEvent('errorHandlingSrv', 'error', (args) => {
// assuming error is the single argument
const [err] = args;
reject(err);
});
})
.handleScriptError(reject)
.handleTimeout(() => {
reject('Request timed out for printConstant');
})
.build();
});
await client.initiateFlow(request);
return Promise.race([promise, Promise.resolve()]);
}

16
src/compiled/dataAlias.ts
View File

@ -1,3 +1,10 @@
/**
*
* 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
*
*/
import { FluenceClient, PeerIdB58 } from '@fluencelabs/fluence';
import { RequestFlowBuilder } from '@fluencelabs/fluence/dist/api.unstable';
@ -7,6 +14,7 @@ export async function getAliasedData(client: FluenceClient): Promise<string> {
let request;
const promise = new Promise<string>((resolve, reject) => {
request = new RequestFlowBuilder()
.disableInjections()
.withRawScript(
`
(xor
@ -24,18 +32,18 @@ export async function getAliasedData(client: FluenceClient): Promise<string> {
)
.configHandler((h) => {
h.on('getDataSrv', 'relay', () => {
return client.relayPeerId;
return client.relayPeerId!;
});
h.on('getRelayService', 'hasReleay', () => {// Not Used
return client.relayPeerId !== undefined;
});
h.on('callbackSrv', 'response', (args) => {
h.onEvent('callbackSrv', 'response', (args) => {
const [res] = args;
resolve(res);
});
h.on('errorHandlingSrv', 'error', (args) => {
h.onEvent('errorHandlingSrv', 'error', (args) => {
// assuming error is the single argument
const [err] = args;
reject(err);
@ -43,7 +51,7 @@ export async function getAliasedData(client: FluenceClient): Promise<string> {
})
.handleScriptError(reject)
.handleTimeout(() => {
reject('Request timed out');
reject('Request timed out for getAliasedData');
})
.build();
});

43
src/compiled/fold.ts
View File

@ -1,3 +1,10 @@
/**
*
* 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
*
*/
import { FluenceClient, PeerIdB58 } from '@fluencelabs/fluence';
import { RequestFlowBuilder } from '@fluencelabs/fluence/dist/api.unstable';
@ -7,13 +14,14 @@ export async function print(client: FluenceClient, str: string): Promise<void> {
let request;
const promise = new Promise<void>((resolve, reject) => {
request = new RequestFlowBuilder()
.disableInjections()
.withRawScript(
`
(xor
(seq
(seq
(call %init_peer_id% ("getDataSrv" "str") [] str)
(call %init_peer_id% ("getDataSrv" "relay") [] relay)
(call %init_peer_id% ("getDataSrv" "str") [] str)
)
(call %init_peer_id% ("println-service-id" "print") [str])
)
@ -24,14 +32,14 @@ export async function print(client: FluenceClient, str: string): Promise<void> {
)
.configHandler((h) => {
h.on('getDataSrv', 'relay', () => {
return client.relayPeerId;
return client.relayPeerId!;
});
h.on('getRelayService', 'hasReleay', () => {// Not Used
return client.relayPeerId !== undefined;
});
h.on('getDataSrv', 'str', () => {return str;});
h.on('errorHandlingSrv', 'error', (args) => {
h.onEvent('errorHandlingSrv', 'error', (args) => {
// assuming error is the single argument
const [err] = args;
reject(err);
@ -39,7 +47,7 @@ export async function print(client: FluenceClient, str: string): Promise<void> {
})
.handleScriptError(reject)
.handleTimeout(() => {
reject('Request timed out');
reject('Request timed out for print');
})
.build();
});
@ -53,6 +61,7 @@ export async function id(client: FluenceClient): Promise<void> {
let request;
const promise = new Promise<void>((resolve, reject) => {
request = new RequestFlowBuilder()
.disableInjections()
.withRawScript(
`
(xor
@ -67,14 +76,14 @@ export async function id(client: FluenceClient): Promise<void> {
)
.configHandler((h) => {
h.on('getDataSrv', 'relay', () => {
return client.relayPeerId;
return client.relayPeerId!;
});
h.on('getRelayService', 'hasReleay', () => {// Not Used
return client.relayPeerId !== undefined;
});
h.on('errorHandlingSrv', 'error', (args) => {
h.onEvent('errorHandlingSrv', 'error', (args) => {
// assuming error is the single argument
const [err] = args;
reject(err);
@ -82,7 +91,7 @@ export async function id(client: FluenceClient): Promise<void> {
})
.handleScriptError(reject)
.handleTimeout(() => {
reject('Request timed out');
reject('Request timed out for id');
})
.build();
});
@ -96,13 +105,14 @@ export async function iterateAndPrint(client: FluenceClient, strings: string[]):
let request;
const promise = new Promise<void>((resolve, reject) => {
request = new RequestFlowBuilder()
.disableInjections()
.withRawScript(
`
(xor
(seq
(seq
(call %init_peer_id% ("getDataSrv" "strings") [] strings)
(call %init_peer_id% ("getDataSrv" "relay") [] relay)
(call %init_peer_id% ("getDataSrv" "strings") [] strings)
)
(fold strings s
(seq
@ -118,14 +128,14 @@ export async function iterateAndPrint(client: FluenceClient, strings: string[]):
)
.configHandler((h) => {
h.on('getDataSrv', 'relay', () => {
return client.relayPeerId;
return client.relayPeerId!;
});
h.on('getRelayService', 'hasReleay', () => {// Not Used
return client.relayPeerId !== undefined;
});
h.on('getDataSrv', 'strings', () => {return strings;});
h.on('errorHandlingSrv', 'error', (args) => {
h.onEvent('errorHandlingSrv', 'error', (args) => {
// assuming error is the single argument
const [err] = args;
reject(err);
@ -133,7 +143,7 @@ export async function iterateAndPrint(client: FluenceClient, strings: string[]):
})
.handleScriptError(reject)
.handleTimeout(() => {
reject('Request timed out');
reject('Request timed out for iterateAndPrint');
})
.build();
});
@ -147,13 +157,14 @@ export async function iterateAndPrintParallel(client: FluenceClient, nodes: stri
let request;
const promise = new Promise<void>((resolve, reject) => {
request = new RequestFlowBuilder()
.disableInjections()
.withRawScript(
`
(xor
(seq
(seq
(call %init_peer_id% ("getDataSrv" "nodes") [] nodes)
(call %init_peer_id% ("getDataSrv" "relay") [] relay)
(call %init_peer_id% ("getDataSrv" "nodes") [] nodes)
)
(fold nodes s
(par
@ -178,15 +189,15 @@ export async function iterateAndPrintParallel(client: FluenceClient, nodes: stri
)
.configHandler((h) => {
h.on('getDataSrv', 'relay', () => {
return client.relayPeerId;
return client.relayPeerId!;
});
h.on('getRelayService', 'hasReleay', () => {// Not Used
return client.relayPeerId !== undefined;
});
h.on('getDataSrv', 'nodes', () => {return nodes;});
h.on('callbackSrv', 'c', (args) => {return c(args[0]);});
h.on('callbackSrv', 'c', (args) => {c(args[0]); return {};});
h.on('errorHandlingSrv', 'error', (args) => {
h.onEvent('errorHandlingSrv', 'error', (args) => {
// assuming error is the single argument
const [err] = args;
reject(err);
@ -194,7 +205,7 @@ h.on('callbackSrv', 'c', (args) => {return c(args[0]);});
})
.handleScriptError(reject)
.handleTimeout(() => {
reject('Request timed out');
reject('Request timed out for iterateAndPrintParallel');
})
.build();
});

16
src/compiled/func.ts
View File

@ -1,3 +1,10 @@
/**
*
* 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
*
*/
import { FluenceClient, PeerIdB58 } from '@fluencelabs/fluence';
import { RequestFlowBuilder } from '@fluencelabs/fluence/dist/api.unstable';
@ -7,6 +14,7 @@ export async function testFunc(client: FluenceClient): Promise<string> {
let request;
const promise = new Promise<string>((resolve, reject) => {
request = new RequestFlowBuilder()
.disableInjections()
.withRawScript(
`
(xor
@ -24,18 +32,18 @@ export async function testFunc(client: FluenceClient): Promise<string> {
)
.configHandler((h) => {
h.on('getDataSrv', 'relay', () => {
return client.relayPeerId;
return client.relayPeerId!;
});
h.on('getRelayService', 'hasReleay', () => {// Not Used
return client.relayPeerId !== undefined;
});
h.on('callbackSrv', 'response', (args) => {
h.onEvent('callbackSrv', 'response', (args) => {
const [res] = args;
resolve(res);
});
h.on('errorHandlingSrv', 'error', (args) => {
h.onEvent('errorHandlingSrv', 'error', (args) => {
// assuming error is the single argument
const [err] = args;
reject(err);
@ -43,7 +51,7 @@ export async function testFunc(client: FluenceClient): Promise<string> {
})
.handleScriptError(reject)
.handleTimeout(() => {
reject('Request timed out');
reject('Request timed out for testFunc');
})
.build();
});

18
src/compiled/helloWorld.ts
View File

@ -1,3 +1,10 @@
/**
*
* 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
*
*/
import { FluenceClient, PeerIdB58 } from '@fluencelabs/fluence';
import { RequestFlowBuilder } from '@fluencelabs/fluence/dist/api.unstable';
@ -7,14 +14,15 @@ export async function helloWorld(client: FluenceClient, name: string): Promise<s
let request;
const promise = new Promise<string>((resolve, reject) => {
request = new RequestFlowBuilder()
.disableInjections()
.withRawScript(
`
(xor
(seq
(seq
(seq
(call %init_peer_id% ("getDataSrv" "name") [] name)
(call %init_peer_id% ("getDataSrv" "relay") [] relay)
(call %init_peer_id% ("getDataSrv" "name") [] name)
)
(call %init_peer_id% ("service-id" "addNameToHello") [name] res)
)
@ -27,18 +35,18 @@ export async function helloWorld(client: FluenceClient, name: string): Promise<s
)
.configHandler((h) => {
h.on('getDataSrv', 'relay', () => {
return client.relayPeerId;
return client.relayPeerId!;
});
h.on('getRelayService', 'hasReleay', () => {// Not Used
return client.relayPeerId !== undefined;
});
h.on('getDataSrv', 'name', () => {return name;});
h.on('callbackSrv', 'response', (args) => {
h.onEvent('callbackSrv', 'response', (args) => {
const [res] = args;
resolve(res);
});
h.on('errorHandlingSrv', 'error', (args) => {
h.onEvent('errorHandlingSrv', 'error', (args) => {
// assuming error is the single argument
const [err] = args;
reject(err);
@ -46,7 +54,7 @@ export async function helloWorld(client: FluenceClient, name: string): Promise<s
})
.handleScriptError(reject)
.handleTimeout(() => {
reject('Request timed out');
reject('Request timed out for helloWorld');
})
.build();
});

34
src/compiled/if.ts
View File

@ -1,3 +1,10 @@
/**
*
* 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
*
*/
import { FluenceClient, PeerIdB58 } from '@fluencelabs/fluence';
import { RequestFlowBuilder } from '@fluencelabs/fluence/dist/api.unstable';
@ -7,13 +14,14 @@ export async function print(client: FluenceClient, str: string): Promise<void> {
let request;
const promise = new Promise<void>((resolve, reject) => {
request = new RequestFlowBuilder()
.disableInjections()
.withRawScript(
`
(xor
(seq
(seq
(call %init_peer_id% ("getDataSrv" "str") [] str)
(call %init_peer_id% ("getDataSrv" "relay") [] relay)
(call %init_peer_id% ("getDataSrv" "str") [] str)
)
(call %init_peer_id% ("println-service-id" "print") [str])
)
@ -24,14 +32,14 @@ export async function print(client: FluenceClient, str: string): Promise<void> {
)
.configHandler((h) => {
h.on('getDataSrv', 'relay', () => {
return client.relayPeerId;
return client.relayPeerId!;
});
h.on('getRelayService', 'hasReleay', () => {// Not Used
return client.relayPeerId !== undefined;
});
h.on('getDataSrv', 'str', () => {return str;});
h.on('errorHandlingSrv', 'error', (args) => {
h.onEvent('errorHandlingSrv', 'error', (args) => {
// assuming error is the single argument
const [err] = args;
reject(err);
@ -39,7 +47,7 @@ export async function print(client: FluenceClient, str: string): Promise<void> {
})
.handleScriptError(reject)
.handleTimeout(() => {
reject('Request timed out');
reject('Request timed out for print');
})
.build();
});
@ -53,13 +61,14 @@ export async function ifElseCall(client: FluenceClient, condition: boolean): Pro
let request;
const promise = new Promise<void>((resolve, reject) => {
request = new RequestFlowBuilder()
.disableInjections()
.withRawScript(
`
(xor
(seq
(seq
(call %init_peer_id% ("getDataSrv" "condition") [] condition)
(call %init_peer_id% ("getDataSrv" "relay") [] relay)
(call %init_peer_id% ("getDataSrv" "condition") [] condition)
)
(xor
(match condition true
@ -75,14 +84,14 @@ export async function ifElseCall(client: FluenceClient, condition: boolean): Pro
)
.configHandler((h) => {
h.on('getDataSrv', 'relay', () => {
return client.relayPeerId;
return client.relayPeerId!;
});
h.on('getRelayService', 'hasReleay', () => {// Not Used
return client.relayPeerId !== undefined;
});
h.on('getDataSrv', 'condition', () => {return condition;});
h.on('errorHandlingSrv', 'error', (args) => {
h.onEvent('errorHandlingSrv', 'error', (args) => {
// assuming error is the single argument
const [err] = args;
reject(err);
@ -90,7 +99,7 @@ export async function ifElseCall(client: FluenceClient, condition: boolean): Pro
})
.handleScriptError(reject)
.handleTimeout(() => {
reject('Request timed out');
reject('Request timed out for ifElseCall');
})
.build();
});
@ -104,13 +113,14 @@ export async function ifElseNumCall(client: FluenceClient, condition: number): P
let request;
const promise = new Promise<void>((resolve, reject) => {
request = new RequestFlowBuilder()
.disableInjections()
.withRawScript(
`
(xor
(seq
(seq
(call %init_peer_id% ("getDataSrv" "condition") [] condition)
(call %init_peer_id% ("getDataSrv" "relay") [] relay)
(call %init_peer_id% ("getDataSrv" "condition") [] condition)
)
(xor
(match condition 1
@ -126,14 +136,14 @@ export async function ifElseNumCall(client: FluenceClient, condition: number): P
)
.configHandler((h) => {
h.on('getDataSrv', 'relay', () => {
return client.relayPeerId;
return client.relayPeerId!;
});
h.on('getRelayService', 'hasReleay', () => {// Not Used
return client.relayPeerId !== undefined;
});
h.on('getDataSrv', 'condition', () => {return condition;});
h.on('errorHandlingSrv', 'error', (args) => {
h.onEvent('errorHandlingSrv', 'error', (args) => {
// assuming error is the single argument
const [err] = args;
reject(err);
@ -141,7 +151,7 @@ export async function ifElseNumCall(client: FluenceClient, condition: number): P
})
.handleScriptError(reject)
.handleTimeout(() => {
reject('Request timed out');
reject('Request timed out for ifElseNumCall');
})
.build();
});

40
src/compiled/on.ts
View File

@ -1,3 +1,10 @@
/**
*
* 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
*
*/
import { FluenceClient, PeerIdB58 } from '@fluencelabs/fluence';
import { RequestFlowBuilder } from '@fluencelabs/fluence/dist/api.unstable';
@ -7,6 +14,7 @@ export async function id(client: FluenceClient): Promise<void> {
let request;
const promise = new Promise<void>((resolve, reject) => {
request = new RequestFlowBuilder()
.disableInjections()
.withRawScript(
`
(xor
@ -21,14 +29,14 @@ export async function id(client: FluenceClient): Promise<void> {
)
.configHandler((h) => {
h.on('getDataSrv', 'relay', () => {
return client.relayPeerId;
return client.relayPeerId!;
});
h.on('getRelayService', 'hasReleay', () => {// Not Used
return client.relayPeerId !== undefined;
});
h.on('errorHandlingSrv', 'error', (args) => {
h.onEvent('errorHandlingSrv', 'error', (args) => {
// assuming error is the single argument
const [err] = args;
reject(err);
@ -36,7 +44,7 @@ export async function id(client: FluenceClient): Promise<void> {
})
.handleScriptError(reject)
.handleTimeout(() => {
reject('Request timed out');
reject('Request timed out for id');
})
.build();
});
@ -50,6 +58,7 @@ export async function getPeerExternalAddresses(client: FluenceClient, otherNodeP
let request;
const promise = new Promise<string[]>((resolve, reject) => {
request = new RequestFlowBuilder()
.disableInjections()
.withRawScript(
`
(xor
@ -57,8 +66,8 @@ export async function getPeerExternalAddresses(client: FluenceClient, otherNodeP
(seq
(seq
(seq
(call %init_peer_id% ("getDataSrv" "otherNodePeerId") [] otherNodePeerId)
(call %init_peer_id% ("getDataSrv" "relay") [] relay)
(call %init_peer_id% ("getDataSrv" "otherNodePeerId") [] otherNodePeerId)
)
(seq
(call relay ("op" "identity") [])
@ -76,18 +85,18 @@ export async function getPeerExternalAddresses(client: FluenceClient, otherNodeP
)
.configHandler((h) => {
h.on('getDataSrv', 'relay', () => {
return client.relayPeerId;
return client.relayPeerId!;
});
h.on('getRelayService', 'hasReleay', () => {// Not Used
return client.relayPeerId !== undefined;
});
h.on('getDataSrv', 'otherNodePeerId', () => {return otherNodePeerId;});
h.on('callbackSrv', 'response', (args) => {
h.onEvent('callbackSrv', 'response', (args) => {
const [res] = args;
resolve(res);
});
h.on('errorHandlingSrv', 'error', (args) => {
h.onEvent('errorHandlingSrv', 'error', (args) => {
// assuming error is the single argument
const [err] = args;
reject(err);
@ -95,7 +104,7 @@ export async function getPeerExternalAddresses(client: FluenceClient, otherNodeP
})
.handleScriptError(reject)
.handleTimeout(() => {
reject('Request timed out');
reject('Request timed out for getPeerExternalAddresses');
})
.build();
});
@ -109,6 +118,7 @@ export async function getDistantAddresses(client: FluenceClient, target: string,
let request;
const promise = new Promise<string[]>((resolve, reject) => {
request = new RequestFlowBuilder()
.disableInjections()
.withRawScript(
`
(xor
@ -118,10 +128,10 @@ export async function getDistantAddresses(client: FluenceClient, target: string,
(seq
(seq
(seq
(call %init_peer_id% ("getDataSrv" "target") [] target)
(call %init_peer_id% ("getDataSrv" "viaNode") [] viaNode)
)
(call %init_peer_id% ("getDataSrv" "relay") [] relay)
(call %init_peer_id% ("getDataSrv" "target") [] target)
)
(call %init_peer_id% ("getDataSrv" "viaNode") [] viaNode)
)
(seq
(seq
@ -144,19 +154,19 @@ export async function getDistantAddresses(client: FluenceClient, target: string,
)
.configHandler((h) => {
h.on('getDataSrv', 'relay', () => {
return client.relayPeerId;
return client.relayPeerId!;
});
h.on('getRelayService', 'hasReleay', () => {// Not Used
return client.relayPeerId !== undefined;
});
h.on('getDataSrv', 'target', () => {return target;});
h.on('getDataSrv', 'viaNode', () => {return viaNode;});
h.on('callbackSrv', 'response', (args) => {
h.onEvent('callbackSrv', 'response', (args) => {
const [res] = args;
resolve(res);
});
h.on('errorHandlingSrv', 'error', (args) => {
h.onEvent('errorHandlingSrv', 'error', (args) => {
// assuming error is the single argument
const [err] = args;
reject(err);
@ -164,7 +174,7 @@ h.on('getDataSrv', 'viaNode', () => {return viaNode;});
})
.handleScriptError(reject)
.handleTimeout(() => {
reject('Request timed out');
reject('Request timed out for getDistantAddresses');
})
.build();
});

25
src/compiled/par.ts
View File

@ -1,3 +1,10 @@
/**
*
* 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
*
*/
import { FluenceClient, PeerIdB58 } from '@fluencelabs/fluence';
import { RequestFlowBuilder } from '@fluencelabs/fluence/dist/api.unstable';
@ -7,6 +14,7 @@ export async function id(client: FluenceClient): Promise<void> {
let request;
const promise = new Promise<void>((resolve, reject) => {
request = new RequestFlowBuilder()
.disableInjections()
.withRawScript(
`
(xor
@ -21,14 +29,14 @@ export async function id(client: FluenceClient): Promise<void> {
)
.configHandler((h) => {
h.on('getDataSrv', 'relay', () => {
return client.relayPeerId;
return client.relayPeerId!;
});
h.on('getRelayService', 'hasReleay', () => {// Not Used
return client.relayPeerId !== undefined;
});
h.on('errorHandlingSrv', 'error', (args) => {
h.onEvent('errorHandlingSrv', 'error', (args) => {
// assuming error is the single argument
const [err] = args;
reject(err);
@ -36,7 +44,7 @@ export async function id(client: FluenceClient): Promise<void> {
})
.handleScriptError(reject)
.handleTimeout(() => {
reject('Request timed out');
reject('Request timed out for id');
})
.build();
});
@ -50,13 +58,14 @@ export async function parFunc(client: FluenceClient, node: string, c: (arg0: {ex
let request;
const promise = new Promise<void>((resolve, reject) => {
request = new RequestFlowBuilder()
.disableInjections()
.withRawScript(
`
(xor
(seq
(seq
(call %init_peer_id% ("getDataSrv" "node") [] node)
(call %init_peer_id% ("getDataSrv" "relay") [] relay)
(call %init_peer_id% ("getDataSrv" "node") [] node)
)
(par
(par
@ -82,15 +91,15 @@ export async function parFunc(client: FluenceClient, node: string, c: (arg0: {ex
)
.configHandler((h) => {
h.on('getDataSrv', 'relay', () => {
return client.relayPeerId;
return client.relayPeerId!;
});
h.on('getRelayService', 'hasReleay', () => {// Not Used
return client.relayPeerId !== undefined;
});
h.on('getDataSrv', 'node', () => {return node;});
h.on('callbackSrv', 'c', (args) => {return c(args[0]);});
h.on('callbackSrv', 'c', (args) => {c(args[0]); return {};});
h.on('errorHandlingSrv', 'error', (args) => {
h.onEvent('errorHandlingSrv', 'error', (args) => {
// assuming error is the single argument
const [err] = args;
reject(err);
@ -98,7 +107,7 @@ h.on('callbackSrv', 'c', (args) => {return c(args[0]);});
})
.handleScriptError(reject)
.handleTimeout(() => {
reject('Request timed out');
reject('Request timed out for parFunc');
})
.build();
});

16
src/compiled/println.ts
View File

@ -1,3 +1,10 @@
/**
*
* 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
*
*/
import { FluenceClient, PeerIdB58 } from '@fluencelabs/fluence';
import { RequestFlowBuilder } from '@fluencelabs/fluence/dist/api.unstable';
@ -7,13 +14,14 @@ export async function print(client: FluenceClient, str: string): Promise<void> {
let request;
const promise = new Promise<void>((resolve, reject) => {
request = new RequestFlowBuilder()
.disableInjections()
.withRawScript(
`
(xor
(seq
(seq
(call %init_peer_id% ("getDataSrv" "str") [] str)
(call %init_peer_id% ("getDataSrv" "relay") [] relay)
(call %init_peer_id% ("getDataSrv" "str") [] str)
)
(call %init_peer_id% ("println-service-id" "print") [str])
)
@ -24,14 +32,14 @@ export async function print(client: FluenceClient, str: string): Promise<void> {
)
.configHandler((h) => {
h.on('getDataSrv', 'relay', () => {
return client.relayPeerId;
return client.relayPeerId!;
});
h.on('getRelayService', 'hasReleay', () => {// Not Used
return client.relayPeerId !== undefined;
});
h.on('getDataSrv', 'str', () => {return str;});
h.on('errorHandlingSrv', 'error', (args) => {
h.onEvent('errorHandlingSrv', 'error', (args) => {
// assuming error is the single argument
const [err] = args;
reject(err);
@ -39,7 +47,7 @@ export async function print(client: FluenceClient, str: string): Promise<void> {
})
.handleScriptError(reject)
.handleTimeout(() => {
reject('Request timed out');
reject('Request timed out for print');
})
.build();
});

1
src/parCall.ts
View File

@ -3,6 +3,7 @@ import {parFunc} from "./compiled/par";
export async function parCall(client: FluenceClient) {
registerServiceFunction(client, "parservice-id", "call", (args: any[], _) => {
console.log("hello from parservice-id")
return `hello`
})