improve tests

This commit is contained in:
DieMyst
2021-06-12 12:03:46 +03:00
parent 7cc080df57
commit d5bf738f6c
24 changed files with 86 additions and 52 deletions

View File

@ -1,3 +1,5 @@
import "@fluencelabs/aqua-lib/builtin.aqua"
service Unexisted("unex"): service Unexisted("unex"):
getStr() -> string getStr() -> string
@ -15,5 +17,9 @@ func tryCatchTest(node_id: string) -> []string:
try: try:
f <- Unexisted.getStr() f <- Unexisted.getStr()
catch err: catch err:
c: *string
f <- OpA.identity(err.msg) f <- OpA.identity(err.msg)
-- check if the call takes place on the node
i <- Peer.identify()
f <- OpA.identity(i.external_addresses!)
<- f <- f

View File

@ -9,11 +9,11 @@ data LastError:
service OpE("op"): service OpE("op"):
identity(s: string) -> string identity(s: string) -> string
func tryOtherwiseTest(node_id: string) -> []string: func tryOtherwiseTest(node_id: string) -> string:
on node_id: on node_id:
f: *string f: *string
try: try:
f <- Unexisted.getStr() f <- Unexisted.getStr()
otherwise: otherwise:
f <- OpE.identity("error") f <- OpE.identity("error")
<- f <- f!

View File

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

View File

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

View File

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

View File

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

View File

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

View File

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

View File

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

View File

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

View File

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

View File

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

View File

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

View File

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

View File

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

View File

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

View File

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

View File

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

View File

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

View File

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

View File

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

View File

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

View File

@ -1,7 +1,7 @@
import {FluenceClient, registerServiceFunction} from "@fluencelabs/fluence"; import {FluenceClient, registerServiceFunction} from "@fluencelabs/fluence";
import {tryOtherwiseTest} from "../compiled/examples/tryOtherwise"; import {tryOtherwiseTest} from "../compiled/examples/tryOtherwise";
export async function tryOtherwiseCall(client: FluenceClient): Promise<string[]> { export async function tryOtherwiseCall(client: FluenceClient): Promise<string> {
return await tryOtherwiseTest(client, client.relayPeerId!) return await tryOtherwiseTest(client, client.relayPeerId!)
} }

View File

@ -127,9 +127,9 @@ const main = async () => {
checkCall("callArrow", callArrowResult, "Hello, callArrow call!", cb) checkCall("callArrow", callArrowResult, "Hello, callArrow call!", cb)
checkCall("foldCall", foldCallResult, ["/ip4/165.227.164.206/tcp/7001", "/ip4/165.227.164.206/tcp/9001/ws"], cb) checkCall("foldCall", foldCallResult, ['/ip4/164.90.171.139/tcp/7770', '/ip4/164.90.171.139/tcp/9990/ws'], cb)
checkCall("onCall", onCallResult, ["/ip4/165.227.164.206/tcp/7001", "/ip4/165.227.164.206/tcp/9001/ws"], cb) checkCall("onCall", onCallResult, ['/ip4/164.90.171.139/tcp/7770', '/ip4/164.90.171.139/tcp/9990/ws'], cb)
checkCall("parArrow", parCallResult, "hello", cb) checkCall("parArrow", parCallResult, "hello", cb)
@ -159,7 +159,9 @@ const main = async () => {
checkCall("tryOtherwiseCall", tryOtherwiseResult, "error", cb) checkCall("tryOtherwiseCall", tryOtherwiseResult, "error", cb)
checkCallBy("tryCatchCall", tryCatchResult, (res) => (res[0] as string).includes("Local service error: ret_code is 1024"), cb) checkCallBy("tryCatchCall", tryCatchResult, (res) => {
return (res[0] as string).includes("Error: Service with id 'unex' not found") && res[1] === '/ip4/164.90.171.139/tcp/7770'
}, cb)
if (success) { if (success) {
process.exit(0) process.exit(0)