fluencelabs/aqua-playground
1
0
Fork 0
mirror of https://github.com/fluencelabs/aqua-playground synced 2025-06-24 18:51:59 +00:00
Code Issues Projects Releases Wiki Activity

update cli

Browse Source
This commit is contained in:
DieMyst
2021-06-15 13:14:39 +03:00
parent d5bf738f6c
commit 824b0b777e
24 changed files with 78 additions and 78 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
package-lock.json generated
View File

@ -5,9 +5,9 @@
"requires": true,
"dependencies": {
"@fluencelabs/aqua-cli": {
"version": "0.1.6-143",
"resolved": "https://registry.npmjs.org/@fluencelabs/aqua-cli/-/aqua-cli-0.1.6-143.tgz",
"integrity": "sha512-lphQale+0Yib63VvuSN3CoWWHbZukOQ82OihHVt06XXS2Uh/WurCqq8fc9Uo3YpqVWqbAbFtNvWVxp1Tjl7E4g==",
"version": "0.1.6-144",
"resolved": "https://registry.npmjs.org/@fluencelabs/aqua-cli/-/aqua-cli-0.1.6-144.tgz",
"integrity": "sha512-a+n7TElVrI1kLBYOTnKeOoH5CBqqyAjmca1cnN+cdDd2eapp6LKJaW80HmKaLte4jKvWFqb1gPdngbTWHbGoVQ==",
"dev": true
},
"@fluencelabs/aqua-lib": {

2
package.json
View File

@ -24,7 +24,7 @@
"compile-aqua:air": "aqua-cli -i ./aqua/ -o ./compiled-air -a"
},
"devDependencies": {
"@fluencelabs/aqua-cli": "^0.1.6-143",
"@fluencelabs/aqua-cli": "^0.1.6-144",
"@fluencelabs/aqua-lib": "^0.1.5",
"ts-node": "^9.1.1",
"typescript": "^4.2.4"

6
src/compiled/examples/assignment.ts
View File

@ -3,7 +3,7 @@
* This file is auto-generated. Do not edit manually: changes may be erased.
* Generated by Aqua compiler: https://github.com/fluencelabs/aqua/.
* If you find any bugs, please write an issue on GitHub: https://github.com/fluencelabs/aqua/issues
* Aqua version: 0.1.6-SNAPSHOT
* Aqua version: 0.1.6-144
*
*/
import { FluenceClient, PeerIdB58 } from '@fluencelabs/fluence';
@ -12,12 +12,12 @@ import { RequestFlow } from '@fluencelabs/fluence/dist/internal/RequestFlow';
export async function doSmth(client: FluenceClient, arg: {value:string}, ttlMsGeneratedArgument?: number): Promise<string[]> {
export async function doSmth(client: FluenceClient, arg: {value:string}, config?: {ttl?: number}): Promise<string[]> {
let request: RequestFlow;
const promise = new Promise<string[]>((resolve, reject) => {
request = new RequestFlowBuilder()
.disableInjections()
.withTTL(ttlMsGeneratedArgument || 5000)
.withTTL(config?.ttl || 5000)
.withRawScript(
`
(xor

6
src/compiled/examples/callArrow.ts
View File

@ -3,7 +3,7 @@
* This file is auto-generated. Do not edit manually: changes may be erased.
* Generated by Aqua compiler: https://github.com/fluencelabs/aqua/.
* If you find any bugs, please write an issue on GitHub: https://github.com/fluencelabs/aqua/issues
* Aqua version: 0.1.6-SNAPSHOT
* Aqua version: 0.1.6-144
*
*/
import { FluenceClient, PeerIdB58 } from '@fluencelabs/fluence';
@ -12,12 +12,12 @@ import { RequestFlow } from '@fluencelabs/fluence/dist/internal/RequestFlow';
export async function passFunctionAsArg(client: FluenceClient, node: string, str: string, c: (arg0: string) => string, ttlMsGeneratedArgument?: number): Promise<void> {
export async function passFunctionAsArg(client: FluenceClient, node: string, str: string, c: (arg0: string) => string, config?: {ttl?: number}): Promise<void> {
let request: RequestFlow;
const promise = new Promise<void>((resolve, reject) => {
request = new RequestFlowBuilder()
.disableInjections()
.withTTL(ttlMsGeneratedArgument || 5000)
.withTTL(config?.ttl || 5000)
.withRawScript(
`
(xor

6
src/compiled/examples/complex.ts
View File

@ -3,7 +3,7 @@
* This file is auto-generated. Do not edit manually: changes may be erased.
* Generated by Aqua compiler: https://github.com/fluencelabs/aqua/.
* If you find any bugs, please write an issue on GitHub: https://github.com/fluencelabs/aqua/issues
* Aqua version: 0.1.6-SNAPSHOT
* Aqua version: 0.1.6-144
*
*/
import { FluenceClient, PeerIdB58 } from '@fluencelabs/fluence';
@ -12,12 +12,12 @@ import { RequestFlow } from '@fluencelabs/fluence/dist/internal/RequestFlow';
export async function doStuff(client: FluenceClient, a: string, b: string, c: boolean, d: boolean, e: string[], g: string[], str: string, ttlMsGeneratedArgument?: number): Promise<string[]> {
export async function doStuff(client: FluenceClient, a: string, b: string, c: boolean, d: boolean, e: string[], g: string[], str: string, config?: {ttl?: number}): Promise<string[]> {
let request: RequestFlow;
const promise = new Promise<string[]>((resolve, reject) => {
request = new RequestFlowBuilder()
.disableInjections()
.withTTL(ttlMsGeneratedArgument || 5000)
.withTTL(config?.ttl || 5000)
.withRawScript(
`
(xor

6
src/compiled/examples/constants.ts
View File

@ -3,7 +3,7 @@
* This file is auto-generated. Do not edit manually: changes may be erased.
* Generated by Aqua compiler: https://github.com/fluencelabs/aqua/.
* If you find any bugs, please write an issue on GitHub: https://github.com/fluencelabs/aqua/issues
* Aqua version: 0.1.6-SNAPSHOT
* Aqua version: 0.1.6-144
*
*/
import { FluenceClient, PeerIdB58 } from '@fluencelabs/fluence';
@ -12,12 +12,12 @@ import { RequestFlow } from '@fluencelabs/fluence/dist/internal/RequestFlow';
export async function callConstant(client: FluenceClient, cb: (arg0: string) => void, ttlMsGeneratedArgument?: number): Promise<void> {
export async function callConstant(client: FluenceClient, cb: (arg0: string) => void, config?: {ttl?: number}): Promise<void> {
let request: RequestFlow;
const promise = new Promise<void>((resolve, reject) => {
request = new RequestFlowBuilder()
.disableInjections()
.withTTL(ttlMsGeneratedArgument || 5000)
.withTTL(config?.ttl || 5000)
.withRawScript(
`
(xor

6
src/compiled/examples/dataAlias.ts
View File

@ -3,7 +3,7 @@
* This file is auto-generated. Do not edit manually: changes may be erased.
* Generated by Aqua compiler: https://github.com/fluencelabs/aqua/.
* If you find any bugs, please write an issue on GitHub: https://github.com/fluencelabs/aqua/issues
* Aqua version: 0.1.6-SNAPSHOT
* Aqua version: 0.1.6-144
*
*/
import { FluenceClient, PeerIdB58 } from '@fluencelabs/fluence';
@ -12,12 +12,12 @@ import { RequestFlow } from '@fluencelabs/fluence/dist/internal/RequestFlow';
export async function getAliasedData(client: FluenceClient, ttlMsGeneratedArgument?: number): Promise<string> {
export async function getAliasedData(client: FluenceClient, config?: {ttl?: number}): Promise<string> {
let request: RequestFlow;
const promise = new Promise<string>((resolve, reject) => {
request = new RequestFlowBuilder()
.disableInjections()
.withTTL(ttlMsGeneratedArgument || 5000)
.withTTL(config?.ttl || 5000)
.withRawScript(
`
(xor

6
src/compiled/examples/example.ts
View File

@ -3,7 +3,7 @@
* This file is auto-generated. Do not edit manually: changes may be erased.
* Generated by Aqua compiler: https://github.com/fluencelabs/aqua/.
* If you find any bugs, please write an issue on GitHub: https://github.com/fluencelabs/aqua/issues
* Aqua version: 0.1.6-SNAPSHOT
* Aqua version: 0.1.6-144
*
*/
import { FluenceClient, PeerIdB58 } from '@fluencelabs/fluence';
@ -12,12 +12,12 @@ import { RequestFlow } from '@fluencelabs/fluence/dist/internal/RequestFlow';
export async function betterMessage(client: FluenceClient, relay: string, ttlMsGeneratedArgument?: number): Promise<void> {
export async function betterMessage(client: FluenceClient, relay: string, config?: {ttl?: number}): Promise<void> {
let request: RequestFlow;
const promise = new Promise<void>((resolve, reject) => {
request = new RequestFlowBuilder()
.disableInjections()
.withTTL(ttlMsGeneratedArgument || 5000)
.withTTL(config?.ttl || 5000)
.withRawScript(
`
(xor

6
src/compiled/examples/fldist-sample.ts
View File

@ -3,7 +3,7 @@
* This file is auto-generated. Do not edit manually: changes may be erased.
* Generated by Aqua compiler: https://github.com/fluencelabs/aqua/.
* If you find any bugs, please write an issue on GitHub: https://github.com/fluencelabs/aqua/issues
* Aqua version: 0.1.6-SNAPSHOT
* Aqua version: 0.1.6-144
*
*/
import { FluenceClient, PeerIdB58 } from '@fluencelabs/fluence';
@ -12,12 +12,12 @@ import { RequestFlow } from '@fluencelabs/fluence/dist/internal/RequestFlow';
export async function test(client: FluenceClient, node: string, ttlMsGeneratedArgument?: number): Promise<void> {
export async function test(client: FluenceClient, node: string, config?: {ttl?: number}): Promise<void> {
let request: RequestFlow;
const promise = new Promise<void>((resolve, reject) => {
request = new RequestFlowBuilder()
.disableInjections()
.withTTL(ttlMsGeneratedArgument || 5000)
.withTTL(config?.ttl || 5000)
.withRawScript(
`
(xor

10
src/compiled/examples/fold.ts
View File

@ -3,7 +3,7 @@
* This file is auto-generated. Do not edit manually: changes may be erased.
* Generated by Aqua compiler: https://github.com/fluencelabs/aqua/.
* If you find any bugs, please write an issue on GitHub: https://github.com/fluencelabs/aqua/issues
* Aqua version: 0.1.6-SNAPSHOT
* Aqua version: 0.1.6-144
*
*/
import { FluenceClient, PeerIdB58 } from '@fluencelabs/fluence';
@ -12,12 +12,12 @@ import { RequestFlow } from '@fluencelabs/fluence/dist/internal/RequestFlow';
export async function iterateAndPrint(client: FluenceClient, strings: string[], ttlMsGeneratedArgument?: number): Promise<void> {
export async function iterateAndPrint(client: FluenceClient, strings: string[], config?: {ttl?: number}): Promise<void> {
let request: RequestFlow;
const promise = new Promise<void>((resolve, reject) => {
request = new RequestFlowBuilder()
.disableInjections()
.withTTL(ttlMsGeneratedArgument || 5000)
.withTTL(config?.ttl || 5000)
.withRawScript(
`
(xor
@ -62,12 +62,12 @@ export async function iterateAndPrint(client: FluenceClient, strings: string[],
export async function iterateAndPrintParallel(client: FluenceClient, nodes: string[], c: (arg0: {external_addresses:string[]}) => void, ttlMsGeneratedArgument?: number): Promise<void> {
export async function iterateAndPrintParallel(client: FluenceClient, nodes: string[], c: (arg0: {external_addresses:string[]}) => void, config?: {ttl?: number}): Promise<void> {
let request: RequestFlow;
const promise = new Promise<void>((resolve, reject) => {
request = new RequestFlowBuilder()
.disableInjections()
.withTTL(ttlMsGeneratedArgument || 5000)
.withTTL(config?.ttl || 5000)
.withRawScript(
`
(xor

6
src/compiled/examples/foldJoin.ts
View File

@ -3,7 +3,7 @@
* This file is auto-generated. Do not edit manually: changes may be erased.
* Generated by Aqua compiler: https://github.com/fluencelabs/aqua/.
* If you find any bugs, please write an issue on GitHub: https://github.com/fluencelabs/aqua/issues
* Aqua version: 0.1.6-SNAPSHOT
* Aqua version: 0.1.6-144
*
*/
import { FluenceClient, PeerIdB58 } from '@fluencelabs/fluence';
@ -12,12 +12,12 @@ import { RequestFlow } from '@fluencelabs/fluence/dist/internal/RequestFlow';
export async function getTwoResults(client: FluenceClient, relay: string, ttlMsGeneratedArgument?: number): Promise<number[]> {
export async function getTwoResults(client: FluenceClient, relay: string, config?: {ttl?: number}): Promise<number[]> {
let request: RequestFlow;
const promise = new Promise<number[]>((resolve, reject) => {
request = new RequestFlowBuilder()
.disableInjections()
.withTTL(ttlMsGeneratedArgument || 5000)
.withTTL(config?.ttl || 5000)
.withRawScript(
`
(xor

6
src/compiled/examples/func.ts
View File

@ -3,7 +3,7 @@
* This file is auto-generated. Do not edit manually: changes may be erased.
* Generated by Aqua compiler: https://github.com/fluencelabs/aqua/.
* If you find any bugs, please write an issue on GitHub: https://github.com/fluencelabs/aqua/issues
* Aqua version: 0.1.6-SNAPSHOT
* Aqua version: 0.1.6-144
*
*/
import { FluenceClient, PeerIdB58 } from '@fluencelabs/fluence';
@ -12,12 +12,12 @@ import { RequestFlow } from '@fluencelabs/fluence/dist/internal/RequestFlow';
export async function testFunc(client: FluenceClient, ttlMsGeneratedArgument?: number): Promise<string> {
export async function testFunc(client: FluenceClient, config?: {ttl?: number}): Promise<string> {
let request: RequestFlow;
const promise = new Promise<string>((resolve, reject) => {
request = new RequestFlowBuilder()
.disableInjections()
.withTTL(ttlMsGeneratedArgument || 5000)
.withTTL(config?.ttl || 5000)
.withRawScript(
`
(xor

6
src/compiled/examples/helloWorld.ts
View File

@ -3,7 +3,7 @@
* This file is auto-generated. Do not edit manually: changes may be erased.
* Generated by Aqua compiler: https://github.com/fluencelabs/aqua/.
* If you find any bugs, please write an issue on GitHub: https://github.com/fluencelabs/aqua/issues
* Aqua version: 0.1.6-SNAPSHOT
* Aqua version: 0.1.6-144
*
*/
import { FluenceClient, PeerIdB58 } from '@fluencelabs/fluence';
@ -12,12 +12,12 @@ import { RequestFlow } from '@fluencelabs/fluence/dist/internal/RequestFlow';
export async function helloWorld(client: FluenceClient, name: string, ttlMsGeneratedArgument?: number): Promise<string> {
export async function helloWorld(client: FluenceClient, name: string, config?: {ttl?: number}): Promise<string> {
let request: RequestFlow;
const promise = new Promise<string>((resolve, reject) => {
request = new RequestFlowBuilder()
.disableInjections()
.withTTL(ttlMsGeneratedArgument || 5000)
.withTTL(config?.ttl || 5000)
.withRawScript(
`
(xor

10
src/compiled/examples/if.ts
View File

@ -3,7 +3,7 @@
* This file is auto-generated. Do not edit manually: changes may be erased.
* Generated by Aqua compiler: https://github.com/fluencelabs/aqua/.
* If you find any bugs, please write an issue on GitHub: https://github.com/fluencelabs/aqua/issues
* Aqua version: 0.1.6-SNAPSHOT
* Aqua version: 0.1.6-144
*
*/
import { FluenceClient, PeerIdB58 } from '@fluencelabs/fluence';
@ -12,12 +12,12 @@ import { RequestFlow } from '@fluencelabs/fluence/dist/internal/RequestFlow';
export async function ifElseCall(client: FluenceClient, condition: boolean, ttlMsGeneratedArgument?: number): Promise<void> {
export async function ifElseCall(client: FluenceClient, condition: boolean, config?: {ttl?: number}): Promise<void> {
let request: RequestFlow;
const promise = new Promise<void>((resolve, reject) => {
request = new RequestFlowBuilder()
.disableInjections()
.withTTL(ttlMsGeneratedArgument || 5000)
.withTTL(config?.ttl || 5000)
.withRawScript(
`
(xor
@ -71,12 +71,12 @@ export async function ifElseCall(client: FluenceClient, condition: boolean, ttlM
export async function ifElseNumCall(client: FluenceClient, condition: number, ttlMsGeneratedArgument?: number): Promise<void> {
export async function ifElseNumCall(client: FluenceClient, condition: number, config?: {ttl?: number}): Promise<void> {
let request: RequestFlow;
const promise = new Promise<void>((resolve, reject) => {
request = new RequestFlowBuilder()
.disableInjections()
.withTTL(ttlMsGeneratedArgument || 5000)
.withTTL(config?.ttl || 5000)
.withRawScript(
`
(xor

10
src/compiled/examples/nestedFuncs.ts
View File

@ -3,7 +3,7 @@
* This file is auto-generated. Do not edit manually: changes may be erased.
* Generated by Aqua compiler: https://github.com/fluencelabs/aqua/.
* If you find any bugs, please write an issue on GitHub: https://github.com/fluencelabs/aqua/issues
* Aqua version: 0.1.6-SNAPSHOT
* Aqua version: 0.1.6-144
*
*/
import { FluenceClient, PeerIdB58 } from '@fluencelabs/fluence';
@ -12,12 +12,12 @@ import { RequestFlow } from '@fluencelabs/fluence/dist/internal/RequestFlow';
export async function a(client: FluenceClient, b: string, ttlMsGeneratedArgument?: number): Promise<string> {
export async function a(client: FluenceClient, b: string, config?: {ttl?: number}): Promise<string> {
let request: RequestFlow;
const promise = new Promise<string>((resolve, reject) => {
request = new RequestFlowBuilder()
.disableInjections()
.withTTL(ttlMsGeneratedArgument || 5000)
.withTTL(config?.ttl || 5000)
.withRawScript(
`
(xor
@ -70,12 +70,12 @@ export async function a(client: FluenceClient, b: string, ttlMsGeneratedArgument
export async function d(client: FluenceClient, e: string, ttlMsGeneratedArgument?: number): Promise<string> {
export async function d(client: FluenceClient, e: string, config?: {ttl?: number}): Promise<string> {
let request: RequestFlow;
const promise = new Promise<string>((resolve, reject) => {
request = new RequestFlowBuilder()
.disableInjections()
.withTTL(ttlMsGeneratedArgument || 5000)
.withTTL(config?.ttl || 5000)
.withRawScript(
`
(xor

10
src/compiled/examples/on.ts
View File

@ -3,7 +3,7 @@
* This file is auto-generated. Do not edit manually: changes may be erased.
* Generated by Aqua compiler: https://github.com/fluencelabs/aqua/.
* If you find any bugs, please write an issue on GitHub: https://github.com/fluencelabs/aqua/issues
* Aqua version: 0.1.6-SNAPSHOT
* Aqua version: 0.1.6-144
*
*/
import { FluenceClient, PeerIdB58 } from '@fluencelabs/fluence';
@ -12,12 +12,12 @@ import { RequestFlow } from '@fluencelabs/fluence/dist/internal/RequestFlow';
export async function getPeerExternalAddresses(client: FluenceClient, otherNodePeerId: string, ttlMsGeneratedArgument?: number): Promise<string[]> {
export async function getPeerExternalAddresses(client: FluenceClient, otherNodePeerId: string, config?: {ttl?: number}): Promise<string[]> {
let request: RequestFlow;
const promise = new Promise<string[]>((resolve, reject) => {
request = new RequestFlowBuilder()
.disableInjections()
.withTTL(ttlMsGeneratedArgument || 5000)
.withTTL(config?.ttl || 5000)
.withRawScript(
`
(xor
@ -85,12 +85,12 @@ export async function getPeerExternalAddresses(client: FluenceClient, otherNodeP
export async function getDistantAddresses(client: FluenceClient, target: string, viaNode: string, ttlMsGeneratedArgument?: number): Promise<string[]> {
export async function getDistantAddresses(client: FluenceClient, target: string, viaNode: string, config?: {ttl?: number}): Promise<string[]> {
let request: RequestFlow;
const promise = new Promise<string[]>((resolve, reject) => {
request = new RequestFlowBuilder()
.disableInjections()
.withTTL(ttlMsGeneratedArgument || 5000)
.withTTL(config?.ttl || 5000)
.withRawScript(
`
(xor

6
src/compiled/examples/option.ts
View File

@ -3,7 +3,7 @@
* This file is auto-generated. Do not edit manually: changes may be erased.
* Generated by Aqua compiler: https://github.com/fluencelabs/aqua/.
* If you find any bugs, please write an issue on GitHub: https://github.com/fluencelabs/aqua/issues
* Aqua version: 0.1.6-SNAPSHOT
* Aqua version: 0.1.6-144
*
*/
import { FluenceClient, PeerIdB58 } from '@fluencelabs/fluence';
@ -12,12 +12,12 @@ import { RequestFlow } from '@fluencelabs/fluence/dist/internal/RequestFlow';
export async function useOptional(client: FluenceClient, opt: string | null, ttlMsGeneratedArgument?: number): Promise<string> {
export async function useOptional(client: FluenceClient, opt: string | null, config?: {ttl?: number}): Promise<string> {
let request: RequestFlow;
const promise = new Promise<string>((resolve, reject) => {
request = new RequestFlowBuilder()
.disableInjections()
.withTTL(ttlMsGeneratedArgument || 5000)
.withTTL(config?.ttl || 5000)
.withRawScript(
`
(xor

6
src/compiled/examples/par.ts
View File

@ -3,7 +3,7 @@
* This file is auto-generated. Do not edit manually: changes may be erased.
* Generated by Aqua compiler: https://github.com/fluencelabs/aqua/.
* If you find any bugs, please write an issue on GitHub: https://github.com/fluencelabs/aqua/issues
* Aqua version: 0.1.6-SNAPSHOT
* Aqua version: 0.1.6-144
*
*/
import { FluenceClient, PeerIdB58 } from '@fluencelabs/fluence';
@ -12,12 +12,12 @@ import { RequestFlow } from '@fluencelabs/fluence/dist/internal/RequestFlow';
export async function parFunc(client: FluenceClient, node: string, c: (arg0: {external_addresses:string[]}) => void, ttlMsGeneratedArgument?: number): Promise<void> {
export async function parFunc(client: FluenceClient, node: string, c: (arg0: {external_addresses:string[]}) => void, config?: {ttl?: number}): Promise<void> {
let request: RequestFlow;
const promise = new Promise<void>((resolve, reject) => {
request = new RequestFlowBuilder()
.disableInjections()
.withTTL(ttlMsGeneratedArgument || 5000)
.withTTL(config?.ttl || 5000)
.withRawScript(
`
(xor

6
src/compiled/examples/println.ts
View File

@ -3,7 +3,7 @@
* This file is auto-generated. Do not edit manually: changes may be erased.
* Generated by Aqua compiler: https://github.com/fluencelabs/aqua/.
* If you find any bugs, please write an issue on GitHub: https://github.com/fluencelabs/aqua/issues
* Aqua version: 0.1.6-SNAPSHOT
* Aqua version: 0.1.6-144
*
*/
import { FluenceClient, PeerIdB58 } from '@fluencelabs/fluence';
@ -12,12 +12,12 @@ import { RequestFlow } from '@fluencelabs/fluence/dist/internal/RequestFlow';
export async function print(client: FluenceClient, str: string, ttlMsGeneratedArgument?: number): Promise<void> {
export async function print(client: FluenceClient, str: string, config?: {ttl?: number}): Promise<void> {
let request: RequestFlow;
const promise = new Promise<void>((resolve, reject) => {
request = new RequestFlowBuilder()
.disableInjections()
.withTTL(ttlMsGeneratedArgument || 5000)
.withTTL(config?.ttl || 5000)
.withRawScript(
`
(xor

6
src/compiled/examples/stream.ts
View File

@ -3,7 +3,7 @@
* This file is auto-generated. Do not edit manually: changes may be erased.
* Generated by Aqua compiler: https://github.com/fluencelabs/aqua/.
* If you find any bugs, please write an issue on GitHub: https://github.com/fluencelabs/aqua/issues
* Aqua version: 0.1.6-SNAPSHOT
* Aqua version: 0.1.6-144
*
*/
import { FluenceClient, PeerIdB58 } from '@fluencelabs/fluence';
@ -12,12 +12,12 @@ import { RequestFlow } from '@fluencelabs/fluence/dist/internal/RequestFlow';
export async function checkStreams(client: FluenceClient, ch: string[], ttlMsGeneratedArgument?: number): Promise<string[]> {
export async function checkStreams(client: FluenceClient, ch: string[], config?: {ttl?: number}): Promise<string[]> {
let request: RequestFlow;
const promise = new Promise<string[]>((resolve, reject) => {
request = new RequestFlowBuilder()
.disableInjections()
.withTTL(ttlMsGeneratedArgument || 5000)
.withTTL(config?.ttl || 5000)
.withRawScript(
`
(xor

6
src/compiled/examples/topology.ts
View File

@ -3,7 +3,7 @@
* This file is auto-generated. Do not edit manually: changes may be erased.
* Generated by Aqua compiler: https://github.com/fluencelabs/aqua/.
* If you find any bugs, please write an issue on GitHub: https://github.com/fluencelabs/aqua/issues
* Aqua version: 0.1.6-SNAPSHOT
* Aqua version: 0.1.6-144
*
*/
import { FluenceClient, PeerIdB58 } from '@fluencelabs/fluence';
@ -12,12 +12,12 @@ import { RequestFlow } from '@fluencelabs/fluence/dist/internal/RequestFlow';
export async function topologyTest(client: FluenceClient, me: string, myRelay: string, friend: string, friendRelay: string, ttlMsGeneratedArgument?: number): Promise<string> {
export async function topologyTest(client: FluenceClient, me: string, myRelay: string, friend: string, friendRelay: string, config?: {ttl?: number}): Promise<string> {
let request: RequestFlow;
const promise = new Promise<string>((resolve, reject) => {
request = new RequestFlowBuilder()
.disableInjections()
.withTTL(ttlMsGeneratedArgument || 5000)
.withTTL(config?.ttl || 5000)
.withRawScript(
`
(xor

14
src/compiled/examples/via.ts
View File

@ -3,7 +3,7 @@
* This file is auto-generated. Do not edit manually: changes may be erased.
* Generated by Aqua compiler: https://github.com/fluencelabs/aqua/.
* If you find any bugs, please write an issue on GitHub: https://github.com/fluencelabs/aqua/issues
* Aqua version: 0.1.6-SNAPSHOT
* Aqua version: 0.1.6-144
*
*/
import { FluenceClient, PeerIdB58 } from '@fluencelabs/fluence';
@ -12,12 +12,12 @@ import { RequestFlow } from '@fluencelabs/fluence/dist/internal/RequestFlow';
export async function viaArr(client: FluenceClient, node_id: string, viaAr: string[], ttlMsGeneratedArgument?: number): Promise<{external_addresses:string[]}> {
export async function viaArr(client: FluenceClient, node_id: string, viaAr: string[], config?: {ttl?: number}): Promise<{external_addresses:string[]}> {
let request: RequestFlow;
const promise = new Promise<{external_addresses:string[]}>((resolve, reject) => {
request = new RequestFlowBuilder()
.disableInjections()
.withTTL(ttlMsGeneratedArgument || 5000)
.withTTL(config?.ttl || 5000)
.withRawScript(
`
(xor
@ -113,12 +113,12 @@ h.on('getDataSrv', 'viaAr', () => {return viaAr;});
export async function viaStream(client: FluenceClient, node_id: string, viaStr: string[], ttlMsGeneratedArgument?: number): Promise<{external_addresses:string[]}> {
export async function viaStream(client: FluenceClient, node_id: string, viaStr: string[], config?: {ttl?: number}): Promise<{external_addresses:string[]}> {
let request: RequestFlow;
const promise = new Promise<{external_addresses:string[]}>((resolve, reject) => {
request = new RequestFlowBuilder()
.disableInjections()
.withTTL(ttlMsGeneratedArgument || 5000)
.withTTL(config?.ttl || 5000)
.withRawScript(
`
(xor
@ -222,12 +222,12 @@ h.on('getDataSrv', 'viaStr', () => {return viaStr;});
export async function viaOpt(client: FluenceClient, relay: string, node_id: string, viaOpt: string | null, ttlMsGeneratedArgument?: number): Promise<{external_addresses:string[]}> {
export async function viaOpt(client: FluenceClient, relay: string, node_id: string, viaOpt: string | null, config?: {ttl?: number}): Promise<{external_addresses:string[]}> {
let request: RequestFlow;
const promise = new Promise<{external_addresses:string[]}>((resolve, reject) => {
request = new RequestFlowBuilder()
.disableInjections()
.withTTL(ttlMsGeneratedArgument || 5000)
.withTTL(config?.ttl || 5000)
.withRawScript(
`
(xor

2
src/examples/assignment.ts
View File

@ -3,5 +3,5 @@ import {passFunctionAsArg} from "../compiled/examples/callArrow";
import {doSmth} from "../compiled/examples/assignment";
export async function assignmentCall(client: FluenceClient): Promise<string[]> {
return await doSmth(client, {value: "abc"})
return await doSmth(client, {value: "abc"}, {ttl: 6000})
}

2
src/examples/topologyCall.ts
View File

@ -13,5 +13,5 @@ export async function topologyCall(client: FluenceClient, client2: FluenceClient
return {}
})
return await topologyTest(client, client.selfPeerId, client.relayPeerId!, client2.selfPeerId, client2.relayPeerId!)
return await topologyTest(client, client.selfPeerId, client.relayPeerId!, client2.selfPeerId, client2.relayPeerId!, {ttl: 10000})
}