Join tests (#15)

2025-04-25 06:32:18 +00:00 · 2022-01-25 14:34:35 +03:00 · 2022-01-25 14:34:35 +03:00 · 5891a5703f
commit 5891a5703f
parent 8cc33b2daf
49 changed files with 117 additions and 417 deletions
--- a/aqua/examples/join.aqua
+++ b/aqua/examples/join.aqua
@ -0,0 +1,26 @@
+import "@fluencelabs/aqua-lib/builtin.aqua"
+
+func joinIdxLocal(idx: i16, nodes: []string) -> []string:
+    nodes2: *string
+    for node <- nodes par:
+        nodes2 <<- node
+    join nodes2[idx], nodes
+    <- nodes2
+
+func joinIdxRelay(idx: i16, nodes: []string) -> []string:
+    on HOST_PEER_ID:
+      nodes2: *string
+      for node <- nodes par:
+        nodes2 <<- node
+      join nodes2[idx], nodes
+    <- nodes2
+
+-- func joinIdx(idx: i16, nodes: []string) -> []Info:
+--     infos: *Info
+--     nodes2: *string
+--     for node <- nodes par:
+--       on node:
+--         infos <- Peer.identify()
+--         nodes2 <<- node
+--     join infos[idx], nodes2[idx]
+--     <- infos
--- a/src/test/examples.spec.ts
+++ b/src/test/examples.spec.ts
@ -33,6 +33,8 @@ import {closuresCall} from "../examples/closures";
 import {streamCanCall} from "../examples/streamCan";
 import {streamCallbackCall} from "../examples/streamCallback";
 import {streamResCall} from "../examples/streamRestrictionsCall";
+import {joinIdx} from "../compiled/examples/join";
+import {joinIdxCall, joinIdxLocalCall, joinIdxRelayCall} from "../examples/joinCall";

 var selfPeerId: string;
 var peer2: FluencePeer;
@ -44,11 +46,11 @@ const relays = config.relays

 describe('Testing examples', () => {
    beforeAll(async () => {
-        await Fluence.start({ connectTo: relays[0] });
+        await Fluence.start({ connectTo: relays[3] });
        selfPeerId = Fluence.getStatus().peerId;

        peer2 = new FluencePeer();
-        await peer2.start({ connectTo: relays[1] });
+        await peer2.start({ connectTo: relays[4] });

        // this could be called from `println.aqua`
        registerPrintln({
@ -252,6 +254,21 @@ describe('Testing examples', () => {
        expect(literalCallResult).toBe('some literal');
    });

+    it('join.aqua local', async () => {
+        let joinLocalCallResult = await joinIdxLocalCall();
+        expect(joinLocalCallResult.length).toBeGreaterThanOrEqual(2);
+    });
+
+    it('join.aqua relay', async () => {
+        let joinRelayCallResult = await joinIdxRelayCall();
+        expect(joinRelayCallResult.length).toBeGreaterThanOrEqual(2);
+    });
+
+    it('join.aqua network', async () => {
+        let joinCallResult = await joinIdxCall();
+        expect(joinCallResult.length).toBeGreaterThanOrEqual(2);
+    });
+
    it('multiReturn.aqua', async () => {
        let multiReturnResult = await multiReturnCall();
        expect(multiReturnResult).toEqual([
--- a/src/compiled/dht/dht-example.ts
+++ b/src/compiled/dht/dht-example.ts
@ -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.5.2-SNAPSHOT
+ * Aqua version: 0.5.3-SNAPSHOT
 *
 */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
--- a/src/compiled/examples/aliases.ts
+++ b/src/compiled/examples/aliases.ts
@ -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.5.2-SNAPSHOT
+ * Aqua version: 0.5.3-SNAPSHOT
 *
 */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
--- a/src/compiled/examples/assignment.ts
+++ b/src/compiled/examples/assignment.ts
@ -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.5.2-SNAPSHOT
+ * Aqua version: 0.5.3-SNAPSHOT
 *
 */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
--- a/src/compiled/examples/callArrow.ts
+++ b/src/compiled/examples/callArrow.ts
@ -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.5.2-SNAPSHOT
+ * Aqua version: 0.5.3-SNAPSHOT
 *
 */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
--- a/src/compiled/examples/closures.ts
+++ b/src/compiled/examples/closures.ts
@ -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.5.2-SNAPSHOT
+ * Aqua version: 0.5.3-SNAPSHOT
 *
 */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
--- a/src/compiled/examples/co.ts
+++ b/src/compiled/examples/co.ts
@ -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.5.2-SNAPSHOT
+ * Aqua version: 0.5.3-SNAPSHOT
 *
 */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
--- a/src/compiled/examples/complex.ts
+++ b/src/compiled/examples/complex.ts
@ -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.5.2-SNAPSHOT
+ * Aqua version: 0.5.3-SNAPSHOT
 *
 */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
--- a/src/compiled/examples/constants.ts
+++ b/src/compiled/examples/constants.ts
@ -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.5.2-SNAPSHOT
+ * Aqua version: 0.5.3-SNAPSHOT
 *
 */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
--- a/src/compiled/examples/dataAlias.ts
+++ b/src/compiled/examples/dataAlias.ts
@ -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.5.2-SNAPSHOT
+ * Aqua version: 0.5.3-SNAPSHOT
 *
 */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
--- a/src/compiled/examples/example.ts
+++ b/src/compiled/examples/example.ts
@ -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.5.2-SNAPSHOT
+ * Aqua version: 0.5.3-SNAPSHOT
 *
 */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
--- a/src/compiled/examples/fldist-sample.ts
+++ b/src/compiled/examples/fldist-sample.ts
@ -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.5.2-SNAPSHOT
+ * Aqua version: 0.5.3-SNAPSHOT
 *
 */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
--- a/src/compiled/examples/fold.ts
+++ b/src/compiled/examples/fold.ts
@ -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.5.2-SNAPSHOT
+ * Aqua version: 0.5.3-SNAPSHOT
 *
 */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
--- a/src/compiled/examples/foldJoin.ts
+++ b/src/compiled/examples/foldJoin.ts
@ -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.5.2-SNAPSHOT
+ * Aqua version: 0.5.3-SNAPSHOT
 *
 */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
--- a/src/compiled/examples/func.ts
+++ b/src/compiled/examples/func.ts
@ -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.5.2-SNAPSHOT
+ * Aqua version: 0.5.3-SNAPSHOT
 *
 */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
--- a/src/compiled/examples/helloWorld.ts
+++ b/src/compiled/examples/helloWorld.ts
@ -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.5.2-SNAPSHOT
+ * Aqua version: 0.5.3-SNAPSHOT
 *
 */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
--- a/src/compiled/examples/if.ts
+++ b/src/compiled/examples/if.ts
@ -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.5.2-SNAPSHOT
+ * Aqua version: 0.5.3-SNAPSHOT
 *
 */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
--- a/src/compiled/examples/imports_exports/declare.ts
+++ b/src/compiled/examples/imports_exports/declare.ts
@ -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.5.2-SNAPSHOT
+ * Aqua version: 0.5.3-SNAPSHOT
 *
 */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
--- a/src/compiled/examples/imports_exports/exports.ts
+++ b/src/compiled/examples/imports_exports/exports.ts
@ -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.5.2-SNAPSHOT
+ * Aqua version: 0.5.3-SNAPSHOT
 *
 */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
--- a/src/compiled/examples/imports_exports/gen/OneMore.ts
+++ b/src/compiled/examples/imports_exports/gen/OneMore.ts
@ -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.5.2-SNAPSHOT
+ * Aqua version: 0.5.3-SNAPSHOT
 *
 */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
--- a/src/compiled/examples/imports_exports/import2.ts
+++ b/src/compiled/examples/imports_exports/import2.ts
@ -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.5.2-SNAPSHOT
+ * Aqua version: 0.5.3-SNAPSHOT
 *
 */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
--- a/src/compiled/examples/imports_exports/import3.ts
+++ b/src/compiled/examples/imports_exports/import3.ts
@ -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.5.2-SNAPSHOT
+ * Aqua version: 0.5.3-SNAPSHOT
 *
 */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
--- a/src/compiled/examples/imports_exports/imports-empty.ts
+++ b/src/compiled/examples/imports_exports/imports-empty.ts
@ -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.5.2-SNAPSHOT
+ * Aqua version: 0.5.3-SNAPSHOT
 *
 */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@ -16,228 +16,6 @@ import {

 // Services

-export interface NoopDef {
-    array: (a: string, b: string, c: string, d: string, callParams: CallParams<'a' | 'b' | 'c' | 'd'>) => string[] | Promise<string[]>;
-    array_length: (array: string[], callParams: CallParams<'array'>) => number | Promise<number>;
-    bytes_from_b58: (b: string, callParams: CallParams<'b'>) => number[] | Promise<number[]>;
-    bytes_to_b58: (bs: number[], callParams: CallParams<'bs'>) => string | Promise<string>;
-    concat: (a: string[], b: string[], c: string[], d: string[], callParams: CallParams<'a' | 'b' | 'c' | 'd'>) => string[] | Promise<string[]>;
-    concat_strings: (a: string, b: string, callParams: CallParams<'a' | 'b'>) => string | Promise<string>;
-    identity: (s: string | null, callParams: CallParams<'s'>) => string | null | Promise<string | null>;
-    noop: (callParams: CallParams<null>) => void | Promise<void>;
-    sha256_string: (s: string, callParams: CallParams<'s'>) => string | Promise<string>;
-    string_from_b58: (b: string, callParams: CallParams<'b'>) => string | Promise<string>;
-    string_to_b58: (s: string, callParams: CallParams<'s'>) => string | Promise<string>;
-}
-export function registerNoop(service: NoopDef): void;
-export function registerNoop(serviceId: string, service: NoopDef): void;
-export function registerNoop(peer: FluencePeer, service: NoopDef): void;
-export function registerNoop(peer: FluencePeer, serviceId: string, service: NoopDef): void;
-       
-
-export function registerNoop(...args: any) {
-    registerService(
-        args,
-        {
-    "defaultServiceId" : "op",
-    "functions" : [
-        {
-            "functionName" : "array",
-            "argDefs" : [
-                {
-                    "name" : "a",
-                    "argType" : {
-                        "tag" : "primitive"
-                    }
-                },
-                {
-                    "name" : "b",
-                    "argType" : {
-                        "tag" : "primitive"
-                    }
-                },
-                {
-                    "name" : "c",
-                    "argType" : {
-                        "tag" : "primitive"
-                    }
-                },
-                {
-                    "name" : "d",
-                    "argType" : {
-                        "tag" : "primitive"
-                    }
-                }
-            ],
-            "returnType" : {
-                "tag" : "primitive"
-            }
-        },
-        {
-            "functionName" : "array_length",
-            "argDefs" : [
-                {
-                    "name" : "array",
-                    "argType" : {
-                        "tag" : "primitive"
-                    }
-                }
-            ],
-            "returnType" : {
-                "tag" : "primitive"
-            }
-        },
-        {
-            "functionName" : "bytes_from_b58",
-            "argDefs" : [
-                {
-                    "name" : "b",
-                    "argType" : {
-                        "tag" : "primitive"
-                    }
-                }
-            ],
-            "returnType" : {
-                "tag" : "primitive"
-            }
-        },
-        {
-            "functionName" : "bytes_to_b58",
-            "argDefs" : [
-                {
-                    "name" : "bs",
-                    "argType" : {
-                        "tag" : "primitive"
-                    }
-                }
-            ],
-            "returnType" : {
-                "tag" : "primitive"
-            }
-        },
-        {
-            "functionName" : "concat",
-            "argDefs" : [
-                {
-                    "name" : "a",
-                    "argType" : {
-                        "tag" : "primitive"
-                    }
-                },
-                {
-                    "name" : "b",
-                    "argType" : {
-                        "tag" : "primitive"
-                    }
-                },
-                {
-                    "name" : "c",
-                    "argType" : {
-                        "tag" : "primitive"
-                    }
-                },
-                {
-                    "name" : "d",
-                    "argType" : {
-                        "tag" : "primitive"
-                    }
-                }
-            ],
-            "returnType" : {
-                "tag" : "primitive"
-            }
-        },
-        {
-            "functionName" : "concat_strings",
-            "argDefs" : [
-                {
-                    "name" : "a",
-                    "argType" : {
-                        "tag" : "primitive"
-                    }
-                },
-                {
-                    "name" : "b",
-                    "argType" : {
-                        "tag" : "primitive"
-                    }
-                }
-            ],
-            "returnType" : {
-                "tag" : "primitive"
-            }
-        },
-        {
-            "functionName" : "identity",
-            "argDefs" : [
-                {
-                    "name" : "s",
-                    "argType" : {
-                        "tag" : "optional"
-                    }
-                }
-            ],
-            "returnType" : {
-                "tag" : "optional"
-            }
-        },
-        {
-            "functionName" : "noop",
-            "argDefs" : [
-            ],
-            "returnType" : {
-                "tag" : "void"
-            }
-        },
-        {
-            "functionName" : "sha256_string",
-            "argDefs" : [
-                {
-                    "name" : "s",
-                    "argType" : {
-                        "tag" : "primitive"
-                    }
-                }
-            ],
-            "returnType" : {
-                "tag" : "primitive"
-            }
-        },
-        {
-            "functionName" : "string_from_b58",
-            "argDefs" : [
-                {
-                    "name" : "b",
-                    "argType" : {
-                        "tag" : "primitive"
-                    }
-                }
-            ],
-            "returnType" : {
-                "tag" : "primitive"
-            }
-        },
-        {
-            "functionName" : "string_to_b58",
-            "argDefs" : [
-                {
-                    "name" : "s",
-                    "argType" : {
-                        "tag" : "primitive"
-                    }
-                }
-            ],
-            "returnType" : {
-                "tag" : "primitive"
-            }
-        }
-    ]
-}
-    );
-}
-      
-
-
 export interface MyExportSrvDef {
    another_str: (callParams: CallParams<null>) => string | Promise<string>;
 }
@ -317,153 +95,6 @@ export function some_str(...args: any) {

 

-export function some_string(
-    config?: {ttl?: number}
-): Promise<string>;
-
-export function some_string(
-    peer: FluencePeer,
-    config?: {ttl?: number}
-): Promise<string>;
-
-export function some_string(...args: any) {
-
-    let script = `
-                    (xor
-                     (seq
-                      (call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-)
-                      (xor
-                       (call %init_peer_id% ("callbackSrv" "response") ["some_string_func"])
-                       (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1])
-                      )
-                     )
-                     (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 2])
-                    )
-    `
-    return callFunction(
-        args,
-        {
-    "functionName" : "some_string",
-    "returnType" : {
-        "tag" : "primitive"
-    },
-    "argDefs" : [
-    ],
-    "names" : {
-        "relay" : "-relay-",
-        "getDataSrv" : "getDataSrv",
-        "callbackSrv" : "callbackSrv",
-        "responseSrv" : "callbackSrv",
-        "responseFnName" : "response",
-        "errorHandlingSrv" : "errorHandlingSrv",
-        "errorFnName" : "error"
-    }
-},
-        script
-    )
-}
-
- 
-
-export function decl_foo(
-    config?: {ttl?: number}
-): Promise<string>;
-
-export function decl_foo(
-    peer: FluencePeer,
-    config?: {ttl?: number}
-): Promise<string>;
-
-export function decl_foo(...args: any) {
-
-    let script = `
-                    (xor
-                     (seq
-                      (seq
-                       (call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-)
-                       (call %init_peer_id% ("super_foo" "small_foo") [] res1)
-                      )
-                      (xor
-                       (call %init_peer_id% ("callbackSrv" "response") [res1])
-                       (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1])
-                      )
-                     )
-                     (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 2])
-                    )
-    `
-    return callFunction(
-        args,
-        {
-    "functionName" : "decl_foo",
-    "returnType" : {
-        "tag" : "primitive"
-    },
-    "argDefs" : [
-    ],
-    "names" : {
-        "relay" : "-relay-",
-        "getDataSrv" : "getDataSrv",
-        "callbackSrv" : "callbackSrv",
-        "responseSrv" : "callbackSrv",
-        "responseFnName" : "response",
-        "errorHandlingSrv" : "errorHandlingSrv",
-        "errorFnName" : "error"
-    }
-},
-        script
-    )
-}
-
- 
-
-export function decl_bar(
-    config?: {ttl?: number}
-): Promise<string>;
-
-export function decl_bar(
-    peer: FluencePeer,
-    config?: {ttl?: number}
-): Promise<string>;
-
-export function decl_bar(...args: any) {
-
-    let script = `
-                    (xor
-                     (seq
-                      (call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-)
-                      (xor
-                       (call %init_peer_id% ("callbackSrv" "response") ["declare all bar"])
-                       (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1])
-                      )
-                     )
-                     (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 2])
-                    )
-    `
-    return callFunction(
-        args,
-        {
-    "functionName" : "decl_bar",
-    "returnType" : {
-        "tag" : "primitive"
-    },
-    "argDefs" : [
-    ],
-    "names" : {
-        "relay" : "-relay-",
-        "getDataSrv" : "getDataSrv",
-        "callbackSrv" : "callbackSrv",
-        "responseSrv" : "callbackSrv",
-        "responseFnName" : "response",
-        "errorHandlingSrv" : "errorHandlingSrv",
-        "errorFnName" : "error"
-    }
-},
-        script
-    )
-}
-
- 
-
 export function some_random_func(
    config?: {ttl?: number}
 ): Promise<string>;
--- a/src/compiled/examples/imports_exports/imports.ts
+++ b/src/compiled/examples/imports_exports/imports.ts
@ -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.5.2-SNAPSHOT
+ * Aqua version: 0.5.3-SNAPSHOT
 *
 */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
--- a/src/compiled/examples/imports_exports/subImport.ts
+++ b/src/compiled/examples/imports_exports/subImport.ts
@ -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.5.2-SNAPSHOT
+ * Aqua version: 0.5.3-SNAPSHOT
 *
 */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
--- a/src/compiled/examples/multiReturn.ts
+++ b/src/compiled/examples/multiReturn.ts
@ -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.5.2-SNAPSHOT
+ * Aqua version: 0.5.3-SNAPSHOT
 *
 */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
--- a/src/compiled/examples/nestedFuncs.ts
+++ b/src/compiled/examples/nestedFuncs.ts
@ -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.5.2-SNAPSHOT
+ * Aqua version: 0.5.3-SNAPSHOT
 *
 */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
--- a/src/compiled/examples/new-api-full.ts
+++ b/src/compiled/examples/new-api-full.ts
@ -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.5.2-SNAPSHOT
+ * Aqua version: 0.5.3-SNAPSHOT
 *
 */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
--- a/src/compiled/examples/new-api.ts
+++ b/src/compiled/examples/new-api.ts
@ -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.5.2-SNAPSHOT
+ * Aqua version: 0.5.3-SNAPSHOT
 *
 */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
--- a/src/compiled/examples/on.ts
+++ b/src/compiled/examples/on.ts
@ -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.5.2-SNAPSHOT
+ * Aqua version: 0.5.3-SNAPSHOT
 *
 */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
--- a/src/compiled/examples/option.ts
+++ b/src/compiled/examples/option.ts
@ -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.5.2-SNAPSHOT
+ * Aqua version: 0.5.3-SNAPSHOT
 *
 */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
--- a/src/compiled/examples/options/option_gen.ts
+++ b/src/compiled/examples/options/option_gen.ts
@ -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.5.2-SNAPSHOT
+ * Aqua version: 0.5.3-SNAPSHOT
 *
 */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
--- a/src/compiled/examples/par.ts
+++ b/src/compiled/examples/par.ts
@ -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.5.2-SNAPSHOT
+ * Aqua version: 0.5.3-SNAPSHOT
 *
 */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
--- a/src/compiled/examples/passArgs.ts
+++ b/src/compiled/examples/passArgs.ts
@ -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.5.2-SNAPSHOT
+ * Aqua version: 0.5.3-SNAPSHOT
 *
 */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
--- a/src/compiled/examples/println.ts
+++ b/src/compiled/examples/println.ts
@ -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.5.2-SNAPSHOT
+ * Aqua version: 0.5.3-SNAPSHOT
 *
 */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
--- a/src/compiled/examples/pushToStream.ts
+++ b/src/compiled/examples/pushToStream.ts
@ -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.5.2-SNAPSHOT
+ * Aqua version: 0.5.3-SNAPSHOT
 *
 */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
--- a/src/compiled/examples/returnLiteral.ts
+++ b/src/compiled/examples/returnLiteral.ts
@ -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.5.2-SNAPSHOT
+ * Aqua version: 0.5.3-SNAPSHOT
 *
 */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
--- a/src/compiled/examples/stream.ts
+++ b/src/compiled/examples/stream.ts
@ -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.5.2-SNAPSHOT
+ * Aqua version: 0.5.3-SNAPSHOT
 *
 */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
--- a/src/compiled/examples/streamArgs.ts
+++ b/src/compiled/examples/streamArgs.ts
@ -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.5.2-SNAPSHOT
+ * Aqua version: 0.5.3-SNAPSHOT
 *
 */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
--- a/src/compiled/examples/streamCallback.ts
+++ b/src/compiled/examples/streamCallback.ts
@ -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.5.2-SNAPSHOT
+ * Aqua version: 0.5.3-SNAPSHOT
 *
 */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
--- a/src/compiled/examples/streamCan.ts
+++ b/src/compiled/examples/streamCan.ts
@ -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.5.2-SNAPSHOT
+ * Aqua version: 0.5.3-SNAPSHOT
 *
 */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
--- a/src/compiled/examples/streamResults.ts
+++ b/src/compiled/examples/streamResults.ts
@ -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.5.2-SNAPSHOT
+ * Aqua version: 0.5.3-SNAPSHOT
 *
 */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
--- a/src/compiled/examples/subImportUsage.ts
+++ b/src/compiled/examples/subImportUsage.ts
@ -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.5.2-SNAPSHOT
+ * Aqua version: 0.5.3-SNAPSHOT
 *
 */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
--- a/src/compiled/examples/topology.ts
+++ b/src/compiled/examples/topology.ts
@ -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.5.2-SNAPSHOT
+ * Aqua version: 0.5.3-SNAPSHOT
 *
 */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
--- a/src/compiled/examples/tryCatch.ts
+++ b/src/compiled/examples/tryCatch.ts
@ -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.5.2-SNAPSHOT
+ * Aqua version: 0.5.3-SNAPSHOT
 *
 */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
--- a/src/compiled/examples/tryOtherwise.ts
+++ b/src/compiled/examples/tryOtherwise.ts
@ -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.5.2-SNAPSHOT
+ * Aqua version: 0.5.3-SNAPSHOT
 *
 */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
--- a/src/compiled/examples/via.ts
+++ b/src/compiled/examples/via.ts
@ -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.5.2-SNAPSHOT
+ * Aqua version: 0.5.3-SNAPSHOT
 *
 */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
--- a/src/examples/joinCall.ts
+++ b/src/examples/joinCall.ts
@ -0,0 +1,26 @@
+import {Fluence, FluencePeer} from '@fluencelabs/fluence';
+import {joinIdx, joinIdxLocal, joinIdxRelay} from "../compiled/examples/join";
+import { config } from '../config';
+
+const relays = config.relays
+
+export async function joinIdxCall() {
+    // join.aqua
+    const relayPeerId = Fluence.getPeer().getStatus().relayPeerId;
+
+    return await joinIdx(2, [relayPeerId, relays[2].peerId, relays[4].peerId]);
+}
+
+export async function joinIdxLocalCall() {
+    // join.aqua
+    const relayPeerId = Fluence.getPeer().getStatus().relayPeerId;
+
+    return await joinIdxLocal(2, [relayPeerId, relays[2].peerId, relays[4].peerId]);
+}
+
+export async function joinIdxRelayCall() {
+    // join.aqua
+    const relayPeerId = Fluence.getPeer().getStatus().relayPeerId;
+
+    return await joinIdxRelay(2, [relayPeerId, relays[2].peerId, relays[4].peerId]);
+}