add test for stream canonicalization

aqua/examples/streamCan.aqua

@@ -0,0 +1,23 @@
+func toOpt(s: string) -> ?string:
+  str: ?string
+  str <<- s
+  <- str
+
+-- func accumRes() -> *string:
+--   res_accum: *string
+--   a <- toOpt("a")
+--   res_accum <<- a
+--   res_accum <- toOpt("b")
+--   res_accum <<- nil
+--   <- res_accum
+
+func accumRes(a: string, b: string) -> []?string:
+  res_accum: *?string
+  str: ?string
+  str <<- a
+  str2: ?string
+  str2 <<- b
+  res_accum <<- str
+  res_accum <<- str2
+  res_accum <<- nil
+  <- res_accum

src/__test__/examples.spec.ts

@@ -32,6 +32,7 @@ import { genOptions } from '../examples/optionsCall';
 import { relays } from '../config';
 import {closuresCall} from "../examples/closures";
 import {topologyBug205} from "../compiled/examples/topology";
+import {streamCanCall} from "../examples/streamCan";
 
 var selfPeerId: string;
 var peer2: FluencePeer;
@@ -133,6 +134,11 @@ describe('Testing examples', () => {
         expect(returnNoneResult).toBe(null);
     });
 
+    it('streamCan.aqua', async () => {
+        let streamCanResult = await streamCanCall();
+        expect(streamCanResult).toBe([["a"], ["b"], []]);
+    });
+
     it('topology.aqua', async () => {
         let topologyResult = await topologyCall(peer2);
         expect(topologyResult).toBe('finish');

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.3.2-SNAPSHOT
+ * Aqua version: 0.4.0-SNAPSHOT
  *
  */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@@ -14,10 +14,6 @@ import {
 } from '@fluencelabs/fluence/dist/internal/compilerSupport/v2';
 
 
-function missingFields(obj: any, fields: string[]): string[] {
-    return fields.filter(f => !(f in obj))
-}
-
 // Services
 
 // Functions
@@ -32,44 +28,44 @@ export function put_value(...args: any) {
                      (seq
                       (seq
                        (seq
+                        (seq
+                         (call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-)
+                         (call %init_peer_id% ("getDataSrv" "initial_peer") [] initial_peer)
+                        )
+                        (call %init_peer_id% ("getDataSrv" "value") [] value)
+                       )
+                       (par
                         (seq
                          (seq
-                          (seq
-                           (seq
-                            (call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-)
-                            (call %init_peer_id% ("getDataSrv" "initial_peer") [] initial_peer)
-                           )
-                           (call %init_peer_id% ("getDataSrv" "value") [] value)
-                          )
                           (call -relay- ("op" "noop") [])
-                         )
+                          (xor
-                         (xor
+                           (seq
-                          (seq
+                            (call initial_peer ("op" "string_to_b58") ["some-const3"] k)
-                           (call initial_peer ("op" "string_to_b58") ["some-const3"] k)
+                            (call initial_peer ("kad" "neighborhood") [k [] []] nodes)
-                           (call initial_peer ("kad" "neighborhood") [k [] []] nodes)
+                           )
+                           (seq
+                            (call -relay- ("op" "noop") [])
+                            (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1])
+                           )
                           )
+                         )
+                         (call %init_peer_id% ("op" "noop") [])
+                        )
+                        (fold nodes n
+                         (par
                           (seq
                            (call -relay- ("op" "noop") [])
-                           (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1])
+                           (xor
-                          )
+                            (seq
-                         )
+                             (seq
-                        )
+                              (call n ("peer" "timestamp_sec") [] t)
-                        (call -relay- ("op" "noop") [])
+                              (call n ("aqua-dht" "register_key") ["some-const3" t false 0])
-                       )
+                             )
-                       (fold nodes n
+                             (call n ("aqua-dht" "put_value") ["some-const3" value t [] [] 0])
-                        (par
+                            )
-                         (xor
+                            (null)
-                          (seq
-                           (seq
-                            (call n ("peer" "timestamp_sec") [] t)
-                            (call n ("aqua-dht" "register_key") ["some-const3" t false 0])
                            )
-                           (call n ("aqua-dht" "put_value") ["some-const3" value t [] [] 0])
                           )
-                          (null)
-                         )
-                         (seq
-                          (call -relay- ("op" "noop") [])
                           (next n)
                          )
                         )
@@ -133,46 +129,46 @@ export function registerKeyPutValue(...args: any) {
                          (seq
                           (seq
                            (seq
-                            (seq
+                            (call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-)
-                             (seq
+                            (call %init_peer_id% ("getDataSrv" "node_id") [] node_id)
-                              (seq
-                               (call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-)
-                               (call %init_peer_id% ("getDataSrv" "node_id") [] node_id)
-                              )
-                              (call %init_peer_id% ("getDataSrv" "key") [] key)
-                             )
-                             (call %init_peer_id% ("getDataSrv" "value") [] value)
-                            )
-                            (call %init_peer_id% ("getDataSrv" "relay_id") [] relay_id)
                            )
-                           (call %init_peer_id% ("getDataSrv" "service_id") [] service_id)
+                           (call %init_peer_id% ("getDataSrv" "key") [] key)
-                          )
-                          (call -relay- ("op" "noop") [])
-                         )
-                         (xor
-                          (seq
-                           (call key ("op" "string_to_b58") [node_id] k)
-                           (call key ("kad" "neighborhood") [k [] []] nodes)
-                          )
-                          (seq
-                           (call -relay- ("op" "noop") [])
-                           (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1])
                           )
+                          (call %init_peer_id% ("getDataSrv" "value") [] value)
                          )
+                         (call %init_peer_id% ("getDataSrv" "relay_id") [] relay_id)
                         )
-                        (call -relay- ("op" "noop") [])
+                        (call %init_peer_id% ("getDataSrv" "service_id") [] service_id)
                        )
-                       (fold nodes n
+                       (par
-                        (par
+                        (seq
-                         (xor
-                          (call n ("peer" "timestamp_sec") [] t)
-                          (seq
-                           (call -relay- ("op" "noop") [])
-                           (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 2])
-                          )
-                         )
                          (seq
                           (call -relay- ("op" "noop") [])
+                          (xor
+                           (seq
+                            (call key ("op" "string_to_b58") [node_id] k)
+                            (call key ("kad" "neighborhood") [k [] []] nodes)
+                           )
+                           (seq
+                            (call -relay- ("op" "noop") [])
+                            (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1])
+                           )
+                          )
+                         )
+                         (call %init_peer_id% ("op" "noop") [])
+                        )
+                        (fold nodes n
+                         (par
+                          (seq
+                           (call -relay- ("op" "noop") [])
+                           (xor
+                            (call n ("peer" "timestamp_sec") [] t)
+                            (seq
+                             (call -relay- ("op" "noop") [])
+                             (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 2])
+                            )
+                           )
+                          )
                           (next n)
                          )
                         )
@@ -356,23 +352,32 @@ export function findSubscribers(...args: any) {
                           )
                           (call -relay- ("op" "noop") [])
                          )
-                         (fold nodes n
+                         (par
-                          (par
+                          (seq
-                           (seq
-                            (xor
-                             (seq
-                              (call n ("peer" "timestamp_sec") [] t)
-                              (call n ("aqua-dht" "get_values") [topic t] $res)
-                             )
-                             (null)
-                            )
-                            (call node_id ("op" "noop") [])
-                           )
                            (seq
                             (call -relay- ("op" "noop") [])
-                            (next n)
+                            (fold nodes n
+                             (par
+                              (seq
+                               (xor
+                                (seq
+                                 (call n ("peer" "timestamp_sec") [] t)
+                                 (call n ("aqua-dht" "get_values") [topic t] $res)
+                                )
+                                (null)
+                               )
+                               (call node_id ("op" "noop") [])
+                              )
+                              (seq
+                               (call -relay- ("op" "noop") [])
+                               (next n)
+                              )
+                             )
+                            )
                            )
+                           (call node_id ("op" "noop") [])
                           )
+                          (null)
                          )
                         )
                         (xor
@@ -442,49 +447,49 @@ export function initTopicAndSubscribe(...args: any) {
                         (seq
                          (seq
                           (seq
-                           (seq
+                           (call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-)
-                            (seq
+                           (call %init_peer_id% ("getDataSrv" "node_id") [] node_id)
-                             (seq
-                              (call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-)
-                              (call %init_peer_id% ("getDataSrv" "node_id") [] node_id)
-                             )
-                             (call %init_peer_id% ("getDataSrv" "topic") [] topic)
-                            )
-                            (call %init_peer_id% ("getDataSrv" "value") [] value)
-                           )
-                           (call %init_peer_id% ("getDataSrv" "relay_id") [] relay_id)
                           )
-                          (call %init_peer_id% ("getDataSrv" "service_id") [] service_id)
+                          (call %init_peer_id% ("getDataSrv" "topic") [] topic)
-                         )
-                         (call -relay- ("op" "noop") [])
-                        )
-                        (xor
-                         (seq
-                          (call node_id ("op" "string_to_b58") [topic] k)
-                          (call node_id ("kad" "neighborhood") [k [] []] nodes)
-                         )
-                         (seq
-                          (call -relay- ("op" "noop") [])
-                          (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1])
                          )
+                         (call %init_peer_id% ("getDataSrv" "value") [] value)
                         )
+                        (call %init_peer_id% ("getDataSrv" "relay_id") [] relay_id)
                        )
-                       (call -relay- ("op" "noop") [])
+                       (call %init_peer_id% ("getDataSrv" "service_id") [] service_id)
                       )
-                      (fold nodes n
+                      (par
-                       (par
+                       (seq
-                        (xor
-                         (seq
-                          (seq
-                           (call n ("peer" "timestamp_sec") [] t)
-                           (call n ("aqua-dht" "register_key") [topic t false 0])
-                          )
-                          (call n ("aqua-dht" "put_value") [topic value t relay_id service_id 0])
-                         )
-                         (null)
-                        )
                         (seq
                          (call -relay- ("op" "noop") [])
+                         (xor
+                          (seq
+                           (call node_id ("op" "string_to_b58") [topic] k)
+                           (call node_id ("kad" "neighborhood") [k [] []] nodes)
+                          )
+                          (seq
+                           (call -relay- ("op" "noop") [])
+                           (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1])
+                          )
+                         )
+                        )
+                        (call %init_peer_id% ("op" "noop") [])
+                       )
+                       (fold nodes n
+                        (par
+                         (seq
+                          (call -relay- ("op" "noop") [])
+                          (xor
+                           (seq
+                            (seq
+                             (call n ("peer" "timestamp_sec") [] t)
+                             (call n ("aqua-dht" "register_key") [topic t false 0])
+                            )
+                            (call n ("aqua-dht" "put_value") [topic value t relay_id service_id 0])
+                           )
+                           (null)
+                          )
+                         )
                          (next n)
                         )
                        )

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.3.2-SNAPSHOT
+ * Aqua version: 0.4.0-SNAPSHOT
  *
  */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@@ -14,15 +14,11 @@ import {
 } from '@fluencelabs/fluence/dist/internal/compilerSupport/v2';
 
 
-function missingFields(obj: any, fields: string[]): string[] {
-    return fields.filter(f => !(f in obj))
-}
-
 // Services
 
 export interface ComplexServiceDef {
-    call: (d: { otherValue: number; value: string; }, sd: { complex: { someNum: number; someStr: string; }; value: string; }, callParams: CallParams<'d' | 'sd'>) => { someNum: number; someStr: string; };
+    call: (d: { otherValue: number; value: string; }, sd: { complex: { someNum: number; someStr: string; }; value: string; }, callParams: CallParams<'d' | 'sd'>) => { someNum: number; someStr: string; } | Promise<{ someNum: number; someStr: string; }>;
-identity: (callParams: CallParams<null>) => { complex: { someNum: number; someStr: string; }; value: string; };
+identity: (callParams: CallParams<null>) => { complex: { someNum: number; someStr: string; }; value: string; } | Promise<{ complex: { someNum: number; someStr: string; }; value: string; }>;
 }
 export function registerComplexService(service: ComplexServiceDef): void;
 export function registerComplexService(serviceId: string, service: ComplexServiceDef): void;
@@ -74,8 +70,8 @@ export type DoSmthArgD = { otherValue: number; value: string; }
 export type DoSmthArgD2 = { otherValue: number; value: string; }
 export type DoSmthArgSd = { complex: { someNum: number; someStr: string; }; value: string; } 
 export type DoSmthResult = { complex: { otherValue: number; value: string; }; value: string; }
-export function doSmth(d: DoSmthArgD, d2: DoSmthArgD2, sd: DoSmthArgSd, c: (arg0: { someNum: number; someStr: string; }, arg1: { complex: { someNum: number; someStr: string; }; value: string; }, callParams: CallParams<'arg0' | 'arg1'>) => { complex: { otherValue: number; value: string; }; value: string; }, config?: {ttl?: number}): Promise<DoSmthResult>;
+export function doSmth(d: DoSmthArgD, d2: DoSmthArgD2, sd: DoSmthArgSd, c: (arg0: { someNum: number; someStr: string; }, arg1: { complex: { someNum: number; someStr: string; }; value: string; }, callParams: CallParams<'arg0' | 'arg1'>) => { complex: { otherValue: number; value: string; }; value: string; } | Promise<{ complex: { otherValue: number; value: string; }; value: string; }>, config?: {ttl?: number}): Promise<DoSmthResult>;
-export function doSmth(peer: FluencePeer, d: DoSmthArgD, d2: DoSmthArgD2, sd: DoSmthArgSd, c: (arg0: { someNum: number; someStr: string; }, arg1: { complex: { someNum: number; someStr: string; }; value: string; }, callParams: CallParams<'arg0' | 'arg1'>) => { complex: { otherValue: number; value: string; }; value: string; }, config?: {ttl?: number}): Promise<DoSmthResult>;
+export function doSmth(peer: FluencePeer, d: DoSmthArgD, d2: DoSmthArgD2, sd: DoSmthArgSd, c: (arg0: { someNum: number; someStr: string; }, arg1: { complex: { someNum: number; someStr: string; }; value: string; }, callParams: CallParams<'arg0' | 'arg1'>) => { complex: { otherValue: number; value: string; }; value: string; } | Promise<{ complex: { otherValue: number; value: string; }; value: string; }>, config?: {ttl?: number}): Promise<DoSmthResult>;
 export function doSmth(...args: any) {
 
     let script = `

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.3.2-SNAPSHOT
+ * Aqua version: 0.4.0-SNAPSHOT
  *
  */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@@ -14,15 +14,11 @@ import {
 } from '@fluencelabs/fluence/dist/internal/compilerSupport/v2';
 
 
-function missingFields(obj: any, fields: string[]): string[] {
-    return fields.filter(f => !(f in obj))
-}
-
 // Services
 
 export interface OpHaDef {
-    array: (a: string, b: string, callParams: CallParams<'a' | 'b'>) => string[];
+    array: (a: string, b: string, callParams: CallParams<'a' | 'b'>) => string[] | Promise<string[]>;
-identity: (a: string, callParams: CallParams<'a'>) => string;
+identity: (a: string, callParams: CallParams<'a'>) => string | Promise<string>;
 }
 export function registerOpHa(service: OpHaDef): void;
 export function registerOpHa(serviceId: string, service: OpHaDef): void;

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.3.2-SNAPSHOT
+ * Aqua version: 0.4.0-SNAPSHOT
  *
  */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@@ -14,17 +14,13 @@ import {
 } from '@fluencelabs/fluence/dist/internal/compilerSupport/v2';
 
 
-function missingFields(obj: any, fields: string[]): string[] {
-    return fields.filter(f => !(f in obj))
-}
-
 // Services
 
 // Functions
  
 
-export function passFunctionAsArg(node: string, str: string, c: (arg0: string, callParams: CallParams<'arg0'>) => string, config?: {ttl?: number}): Promise<void>;
+export function passFunctionAsArg(node: string, str: string, c: (arg0: string, callParams: CallParams<'arg0'>) => string | Promise<string>, config?: {ttl?: number}): Promise<void>;
-export function passFunctionAsArg(peer: FluencePeer, node: string, str: string, c: (arg0: string, callParams: CallParams<'arg0'>) => string, config?: {ttl?: number}): Promise<void>;
+export function passFunctionAsArg(peer: FluencePeer, node: string, str: string, c: (arg0: string, callParams: CallParams<'arg0'>) => string | Promise<string>, config?: {ttl?: number}): Promise<void>;
 export function passFunctionAsArg(...args: any) {
 
     let script = `

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.3.2-SNAPSHOT
+ * Aqua version: 0.4.0-SNAPSHOT
  *
  */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@@ -14,14 +14,10 @@ import {
 } from '@fluencelabs/fluence/dist/internal/compilerSupport/v2';
 
 
-function missingFields(obj: any, fields: string[]): string[] {
-    return fields.filter(f => !(f in obj))
-}
-
 // Services
 
 export interface CoServiceDef {
-    call: (callParams: CallParams<null>) => string;
+    call: (callParams: CallParams<null>) => string | Promise<string>;
 }
 export function registerCoService(service: CoServiceDef): void;
 export function registerCoService(serviceId: string, service: CoServiceDef): void;
@@ -51,8 +47,8 @@ export function registerCoService(...args: any) {
 // Functions
  
 
-export function coFunc(node: string, c: (arg0: { external_addresses: string[]; }, callParams: CallParams<'arg0'>) => void, config?: {ttl?: number}): Promise<void>;
+export function coFunc(node: string, c: (arg0: { external_addresses: string[]; }, callParams: CallParams<'arg0'>) => void | Promise<void>, config?: {ttl?: number}): Promise<void>;
-export function coFunc(peer: FluencePeer, node: string, c: (arg0: { external_addresses: string[]; }, callParams: CallParams<'arg0'>) => void, config?: {ttl?: number}): Promise<void>;
+export function coFunc(peer: FluencePeer, node: string, c: (arg0: { external_addresses: string[]; }, callParams: CallParams<'arg0'>) => void | Promise<void>, config?: {ttl?: number}): Promise<void>;
 export function coFunc(...args: any) {
 
     let script = `

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.3.2-SNAPSHOT
+ * Aqua version: 0.4.0-SNAPSHOT
  *
  */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@@ -14,15 +14,11 @@ import {
 } from '@fluencelabs/fluence/dist/internal/compilerSupport/v2';
 
 
-function missingFields(obj: any, fields: string[]): string[] {
-    return fields.filter(f => !(f in obj))
-}
-
 // Services
 
 export interface TestSDef {
-    multiline: (a: string, b: string, c: boolean, callParams: CallParams<'a' | 'b' | 'c'>) => string;
+    multiline: (a: string, b: string, c: boolean, callParams: CallParams<'a' | 'b' | 'c'>) => string | Promise<string>;
-t: (arg0: string, callParams: CallParams<'arg0'>) => string;
+t: (arg0: string, callParams: CallParams<'arg0'>) => string | Promise<string>;
 }
 export function registerTestS(service: TestSDef): void;
 export function registerTestS(serviceId: string, service: TestSDef): void;

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.3.2-SNAPSHOT
+ * Aqua version: 0.4.0-SNAPSHOT
  *
  */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@@ -14,14 +14,10 @@ import {
 } from '@fluencelabs/fluence/dist/internal/compilerSupport/v2';
 
 
-function missingFields(obj: any, fields: string[]): string[] {
-    return fields.filter(f => !(f in obj))
-}
-
 // Services
 
 export interface GetterDef {
-    createStr: (arg0: number, callParams: CallParams<'arg0'>) => string;
+    createStr: (arg0: number, callParams: CallParams<'arg0'>) => string | Promise<string>;
 }
 export function registerGetter(service: GetterDef): void;
 export function registerGetter(serviceId: string, service: GetterDef): void;
@@ -57,7 +53,7 @@ export function registerGetter(...args: any) {
 
 
 export interface OpODef {
-    identity: (arg0: string, callParams: CallParams<'arg0'>) => string;
+    identity: (arg0: string, callParams: CallParams<'arg0'>) => string | Promise<string>;
 }
 export function registerOpO(service: OpODef): void;
 export function registerOpO(serviceId: string, service: OpODef): void;

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.3.2-SNAPSHOT
+ * Aqua version: 0.4.0-SNAPSHOT
  *
  */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@@ -14,14 +14,10 @@ import {
 } from '@fluencelabs/fluence/dist/internal/compilerSupport/v2';
 
 
-function missingFields(obj: any, fields: string[]): string[] {
-    return fields.filter(f => !(f in obj))
-}
-
 // Services
 
 export interface NodeIdGetterDef {
-    get: (callParams: CallParams<null>) => { name: string; peerId: string; };
+    get: (callParams: CallParams<null>) => { name: string; peerId: string; } | Promise<{ name: string; peerId: string; }>;
 }
 export function registerNodeIdGetter(service: NodeIdGetterDef): void;
 export function registerNodeIdGetter(serviceId: string, service: NodeIdGetterDef): void;

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.3.2-SNAPSHOT
+ * Aqua version: 0.4.0-SNAPSHOT
  *
  */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@@ -14,14 +14,10 @@ import {
 } from '@fluencelabs/fluence/dist/internal/compilerSupport/v2';
 
 
-function missingFields(obj: any, fields: string[]): string[] {
-    return fields.filter(f => !(f in obj))
-}
-
 // Services
 
 export interface PeerDef {
-    is_connected: (arg0: string, callParams: CallParams<'arg0'>) => boolean;
+    is_connected: (arg0: string, callParams: CallParams<'arg0'>) => boolean | Promise<boolean>;
 }
 export function registerPeer(service: PeerDef): void;
 export function registerPeer(serviceId: string, service: PeerDef): void;
@@ -57,7 +53,7 @@ export function registerPeer(...args: any) {
 
 
 export interface OpDef {
-    identity: (callParams: CallParams<null>) => void;
+    identity: (callParams: CallParams<null>) => void | Promise<void>;
 }
 export function registerOp(service: OpDef): void;
 export function registerOp(serviceId: string, service: OpDef): void;
@@ -87,8 +83,8 @@ export function registerOp(...args: any) {
 
 
 export interface TestDef {
-    doSomething: (callParams: CallParams<null>) => boolean;
+    doSomething: (callParams: CallParams<null>) => boolean | Promise<boolean>;
-getUserList: (callParams: CallParams<null>) => { name: string; peer_id: string; relay_id: string; }[];
+getUserList: (callParams: CallParams<null>) => { name: string; peer_id: string; relay_id: string; }[] | Promise<{ name: string; peer_id: string; relay_id: string; }[]>;
 }
 export function registerTest(service: TestDef): void;
 export function registerTest(serviceId: string, service: TestDef): void;

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.3.2-SNAPSHOT
+ * Aqua version: 0.4.0-SNAPSHOT
  *
  */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@@ -14,14 +14,10 @@ import {
 } from '@fluencelabs/fluence/dist/internal/compilerSupport/v2';
 
 
-function missingFields(obj: any, fields: string[]): string[] {
-    return fields.filter(f => !(f in obj))
-}
-
 // Services
 
 export interface ReturnDef {
-    run: (arg0: { external_addresses: string[]; }, callParams: CallParams<'arg0'>) => void;
+    run: (arg0: { external_addresses: string[]; }, callParams: CallParams<'arg0'>) => void | Promise<void>;
 }
 export function registerReturn(service: ReturnDef): void;
 export function registerReturn(serviceId: string, service: ReturnDef): void;

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.3.2-SNAPSHOT
+ * Aqua version: 0.4.0-SNAPSHOT
  *
  */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@@ -14,10 +14,6 @@ import {
 } from '@fluencelabs/fluence/dist/internal/compilerSupport/v2';
 
 
-function missingFields(obj: any, fields: string[]): string[] {
-    return fields.filter(f => !(f in obj))
-}
-
 // Services
 
 // Functions
@@ -75,8 +71,8 @@ export function iterateAndPrint(...args: any) {
 
  
 
-export function iterateAndPrintParallel(nodes: string[], c: (arg0: { external_addresses: string[]; }, callParams: CallParams<'arg0'>) => void, config?: {ttl?: number}): Promise<void>;
+export function iterateAndPrintParallel(nodes: string[], c: (arg0: { external_addresses: string[]; }, callParams: CallParams<'arg0'>) => void | Promise<void>, config?: {ttl?: number}): Promise<void>;
-export function iterateAndPrintParallel(peer: FluencePeer, nodes: string[], c: (arg0: { external_addresses: string[]; }, callParams: CallParams<'arg0'>) => void, config?: {ttl?: number}): Promise<void>;
+export function iterateAndPrintParallel(peer: FluencePeer, nodes: string[], c: (arg0: { external_addresses: string[]; }, callParams: CallParams<'arg0'>) => void | Promise<void>, config?: {ttl?: number}): Promise<void>;
 export function iterateAndPrintParallel(...args: any) {
 
     let script = `
@@ -86,26 +82,29 @@ export function iterateAndPrintParallel(...args: any) {
                        (call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-)
                        (call %init_peer_id% ("getDataSrv" "nodes") [] nodes)
                       )
-                      (fold nodes s
+                      (par
-                       (par
+                       (fold nodes s
-                        (seq
+                        (par
-                         (call -relay- ("op" "noop") [])
+                         (seq
-                         (xor
+                          (call -relay- ("op" "noop") [])
-                          (seq
+                          (xor
                            (seq
-                            (call s ("peer" "identify") [] ads)
+                            (seq
-                            (call -relay- ("op" "noop") [])
+                             (call s ("peer" "identify") [] ads)
-                           )
+                             (call -relay- ("op" "noop") [])
-                           (xor
+                            )
-                            (call %init_peer_id% ("callbackSrv" "c") [ads])
+                            (xor
-                            (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1])
+                             (call %init_peer_id% ("callbackSrv" "c") [ads])
+                             (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1])
+                            )
                            )
+                           (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 2])
                           )
-                          (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 2])
                          )
+                         (next s)
                         )
-                        (next s)
                        )
+                       (null)
                       )
                      )
                      (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 3])

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.3.2-SNAPSHOT
+ * Aqua version: 0.4.0-SNAPSHOT
  *
  */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@@ -14,14 +14,10 @@ import {
 } from '@fluencelabs/fluence/dist/internal/compilerSupport/v2';
 
 
-function missingFields(obj: any, fields: string[]): string[] {
-    return fields.filter(f => !(f in obj))
-}
-
 // Services
 
 export interface Op2Def {
-    identity: (s: number, callParams: CallParams<'s'>) => void;
+    identity: (s: number, callParams: CallParams<'s'>) => void | Promise<void>;
 }
 export function registerOp2(service: Op2Def): void;
 export function registerOp2(serviceId: string, service: Op2Def): void;
@@ -82,17 +78,23 @@ export function getTwoResults(...args: any) {
                               (call relay ("op" "string_to_b58") [%init_peer_id%] k)
                               (call relay ("kad" "neighborhood") [k [] []] nodes)
                              )
-                             (fold nodes n
+                             (par
-                              (par
+                              (seq
-                               (seq
+                               (fold nodes n
-                                (xor
+                                (par
-                                 (call n ("peer" "timestamp_sec") [] $res)
+                                 (seq
-                                 (null)
+                                  (xor
+                                   (call n ("peer" "timestamp_sec") [] $res)
+                                   (null)
+                                  )
+                                  (call relay ("op" "noop") [])
+                                 )
+                                 (next n)
                                 )
-                                (call relay ("op" "noop") [])
                                )
-                               (next n)
+                               (call relay ("op" "noop") [])
                               )
+                              (null)
                              )
                             )
                             (call relay ("op" "identity") [$res.$.[0]!])

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.3.2-SNAPSHOT
+ * Aqua version: 0.4.0-SNAPSHOT
  *
  */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@@ -14,14 +14,10 @@ import {
 } from '@fluencelabs/fluence/dist/internal/compilerSupport/v2';
 
 
-function missingFields(obj: any, fields: string[]): string[] {
-    return fields.filter(f => !(f in obj))
-}
-
 // Services
 
 export interface TestSrvDef {
-    str: (callParams: CallParams<null>) => string;
+    str: (callParams: CallParams<null>) => string | Promise<string>;
 }
 export function registerTestSrv(service: TestSrvDef): void;
 export function registerTestSrv(serviceId: string, service: TestSrvDef): void;

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.3.2-SNAPSHOT
+ * Aqua version: 0.4.0-SNAPSHOT
  *
  */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@@ -14,14 +14,10 @@ import {
 } from '@fluencelabs/fluence/dist/internal/compilerSupport/v2';
 
 
-function missingFields(obj: any, fields: string[]): string[] {
-    return fields.filter(f => !(f in obj))
-}
-
 // Services
 
 export interface StringExtraDef {
-    addNameToHello: (arg0: string, callParams: CallParams<'arg0'>) => string;
+    addNameToHello: (arg0: string, callParams: CallParams<'arg0'>) => string | Promise<string>;
 }
 export function registerStringExtra(service: StringExtraDef): void;
 export function registerStringExtra(serviceId: string, service: StringExtraDef): void;

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.3.2-SNAPSHOT
+ * Aqua version: 0.4.0-SNAPSHOT
  *
  */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@@ -14,10 +14,6 @@ import {
 } from '@fluencelabs/fluence/dist/internal/compilerSupport/v2';
 
 
-function missingFields(obj: any, fields: string[]): string[] {
-    return fields.filter(f => !(f in obj))
-}
-
 // Services
 
 // Functions

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.3.2-SNAPSHOT
+ * Aqua version: 0.4.0-SNAPSHOT
  *
  */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@@ -14,14 +14,10 @@ import {
 } from '@fluencelabs/fluence/dist/internal/compilerSupport/v2';
 
 
-function missingFields(obj: any, fields: string[]): string[] {
-    return fields.filter(f => !(f in obj))
-}
-
 // Services
 
 export interface SuperFooDef {
-    small_foo: (callParams: CallParams<null>) => string;
+    small_foo: (callParams: CallParams<null>) => string | Promise<string>;
 }
 export function registerSuperFoo(service: SuperFooDef): void;
 export function registerSuperFoo(serviceId: string, service: SuperFooDef): void;

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.3.2-SNAPSHOT
+ * Aqua version: 0.4.0-SNAPSHOT
  *
  */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@@ -14,14 +14,10 @@ import {
 } from '@fluencelabs/fluence/dist/internal/compilerSupport/v2';
 
 
-function missingFields(obj: any, fields: string[]): string[] {
-    return fields.filter(f => !(f in obj))
-}
-
 // Services
 
 export interface MyExportSrvDef {
-    another_str: (callParams: CallParams<null>) => string;
+    another_str: (callParams: CallParams<null>) => string | Promise<string>;
 }
 export function registerMyExportSrv(service: MyExportSrvDef): void;
 export function registerMyExportSrv(serviceId: string, service: MyExportSrvDef): void;

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.3.2-SNAPSHOT
+ * Aqua version: 0.4.0-SNAPSHOT
  *
  */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@@ -14,14 +14,10 @@ import {
 } from '@fluencelabs/fluence/dist/internal/compilerSupport/v2';
 
 
-function missingFields(obj: any, fields: string[]): string[] {
-    return fields.filter(f => !(f in obj))
-}
-
 // Services
 
 export interface OneMoreDef {
-    more_call: (callParams: CallParams<null>) => void;
+    more_call: (callParams: CallParams<null>) => void | Promise<void>;
 }
 export function registerOneMore(serviceId: string, service: OneMoreDef): void;
 export function registerOneMore(peer: FluencePeer, serviceId: string, service: OneMoreDef): void;
@@ -31,7 +27,6 @@ export function registerOneMore(...args: any) {
     registerService(
         args,
         {
-    "defaultServiceId" : null,
     "functions" : [
         {
             "functionName" : "more_call",

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.3.2-SNAPSHOT
+ * Aqua version: 0.4.0-SNAPSHOT
  *
  */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@@ -14,10 +14,6 @@ import {
 } from '@fluencelabs/fluence/dist/internal/compilerSupport/v2';
 
 
-function missingFields(obj: any, fields: string[]): string[] {
-    return fields.filter(f => !(f in obj))
-}
-
 // Services
 
 // Functions

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.3.2-SNAPSHOT
+ * Aqua version: 0.4.0-SNAPSHOT
  *
  */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@@ -14,10 +14,6 @@ import {
 } from '@fluencelabs/fluence/dist/internal/compilerSupport/v2';
 
 
-function missingFields(obj: any, fields: string[]): string[] {
-    return fields.filter(f => !(f in obj))
-}
-
 // Services
 
 // Functions

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.3.2-SNAPSHOT
+ * Aqua version: 0.4.0-SNAPSHOT
  *
  */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@@ -14,24 +14,20 @@ import {
 } from '@fluencelabs/fluence/dist/internal/compilerSupport/v2';
 
 
-function missingFields(obj: any, fields: string[]): string[] {
-    return fields.filter(f => !(f in obj))
-}
-
 // Services
 
 export interface NoopDef {
-    array: (a: string, b: string | null, c: string | null, d: string | null, callParams: CallParams<'a' | 'b' | 'c' | 'd'>) => string[];
+    array: (a: string, b: string | null, c: string | null, d: string | null, callParams: CallParams<'a' | 'b' | 'c' | 'd'>) => string[] | Promise<string[]>;
-array_length: (array: string[], callParams: CallParams<'array'>) => number;
+array_length: (array: string[], callParams: CallParams<'array'>) => number | Promise<number>;
-bytes_from_b58: (b: string, callParams: CallParams<'b'>) => number[];
+bytes_from_b58: (b: string, callParams: CallParams<'b'>) => number[] | Promise<number[]>;
-bytes_to_b58: (bs: number[], callParams: CallParams<'bs'>) => string;
+bytes_to_b58: (bs: number[], callParams: CallParams<'bs'>) => string | Promise<string>;
-concat: (a: string[], b: string[] | null, c: string[] | null, d: string[] | null, callParams: CallParams<'a' | 'b' | 'c' | 'd'>) => string[];
+concat: (a: string[], b: string[] | null, c: string[] | null, d: string[] | null, callParams: CallParams<'a' | 'b' | 'c' | 'd'>) => string[] | Promise<string[]>;
-concat_strings: (a: string, b: string, callParams: CallParams<'a' | 'b'>) => string;
+concat_strings: (a: string, b: string, callParams: CallParams<'a' | 'b'>) => string | Promise<string>;
-identity: (s: string | null, callParams: CallParams<'s'>) => string | null;
+identity: (s: string | null, callParams: CallParams<'s'>) => string | null | Promise<string | null>;
-noop: (callParams: CallParams<null>) => void;
+noop: (callParams: CallParams<null>) => void | Promise<void>;
-sha256_string: (s: string, callParams: CallParams<'s'>) => string;
+sha256_string: (s: string, callParams: CallParams<'s'>) => string | Promise<string>;
-string_from_b58: (b: string, callParams: CallParams<'b'>) => string;
+string_from_b58: (b: string, callParams: CallParams<'b'>) => string | Promise<string>;
-string_to_b58: (s: string, callParams: CallParams<'s'>) => 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;
@@ -243,7 +239,7 @@ export function registerNoop(...args: any) {
 
 
 export interface MyExportSrvDef {
-    another_str: (callParams: CallParams<null>) => string;
+    another_str: (callParams: CallParams<null>) => string | Promise<string>;
 }
 export function registerMyExportSrv(service: MyExportSrvDef): void;
 export function registerMyExportSrv(serviceId: string, service: MyExportSrvDef): void;

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.3.2-SNAPSHOT
+ * Aqua version: 0.4.0-SNAPSHOT
  *
  */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@@ -14,14 +14,10 @@ import {
 } from '@fluencelabs/fluence/dist/internal/compilerSupport/v2';
 
 
-function missingFields(obj: any, fields: string[]): string[] {
-    return fields.filter(f => !(f in obj))
-}
-
 // Services
 
 export interface StringServiceDef {
-    concat: (a: string, b: string, callParams: CallParams<'a' | 'b'>) => string;
+    concat: (a: string, b: string, callParams: CallParams<'a' | 'b'>) => string | Promise<string>;
 }
 export function registerStringService(service: StringServiceDef): void;
 export function registerStringService(serviceId: string, service: StringServiceDef): void;

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.3.2-SNAPSHOT
+ * Aqua version: 0.4.0-SNAPSHOT
  *
  */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@@ -14,14 +14,10 @@ import {
 } from '@fluencelabs/fluence/dist/internal/compilerSupport/v2';
 
 
-function missingFields(obj: any, fields: string[]): string[] {
-    return fields.filter(f => !(f in obj))
-}
-
 // Services
 
 export interface SubServiceDef {
-    sub: (s: string, callParams: CallParams<'s'>) => { one: string; two: number; };
+    sub: (s: string, callParams: CallParams<'s'>) => { one: string; two: number; } | Promise<{ one: string; two: number; }>;
 }
 export function registerSubService(service: SubServiceDef): void;
 export function registerSubService(serviceId: string, service: SubServiceDef): void;

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.3.2-SNAPSHOT
+ * Aqua version: 0.4.0-SNAPSHOT
  *
  */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@@ -14,14 +14,10 @@ import {
 } from '@fluencelabs/fluence/dist/internal/compilerSupport/v2';
 
 
-function missingFields(obj: any, fields: string[]): string[] {
-    return fields.filter(f => !(f in obj))
-}
-
 // Services
 
 export interface GetStrDef {
-    retStr: (arg0: string, callParams: CallParams<'arg0'>) => string;
+    retStr: (arg0: string, callParams: CallParams<'arg0'>) => string | Promise<string>;
 }
 export function registerGetStr(service: GetStrDef): void;
 export function registerGetStr(serviceId: string, service: GetStrDef): void;
@@ -57,7 +53,7 @@ export function registerGetStr(...args: any) {
 
 
 export interface GetNumDef {
-    retNum: (callParams: CallParams<null>) => number;
+    retNum: (callParams: CallParams<null>) => number | Promise<number>;
 }
 export function registerGetNum(service: GetNumDef): void;
 export function registerGetNum(serviceId: string, service: GetNumDef): void;

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.3.2-SNAPSHOT
+ * Aqua version: 0.4.0-SNAPSHOT
  *
  */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@@ -14,14 +14,10 @@ import {
 } from '@fluencelabs/fluence/dist/internal/compilerSupport/v2';
 
 
-function missingFields(obj: any, fields: string[]): string[] {
-    return fields.filter(f => !(f in obj))
-}
-
 // Services
 
 export interface OpHDef {
-    identity: (s: string, callParams: CallParams<'s'>) => string;
+    identity: (s: string, callParams: CallParams<'s'>) => string | Promise<string>;
 }
 export function registerOpH(service: OpHDef): void;
 export function registerOpH(serviceId: string, service: OpHDef): void;

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.3.2-SNAPSHOT
+ * Aqua version: 0.4.0-SNAPSHOT
  *
  */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@@ -14,14 +14,10 @@ import {
 } from '@fluencelabs/fluence/dist/internal/compilerSupport/v2';
 
 
-function missingFields(obj: any, fields: string[]): string[] {
-    return fields.filter(f => !(f in obj))
-}
-
 // Services
 
 export interface ServiceWithDefaultIdDef {
-    hello: (s: string, callParams: CallParams<'s'>) => void;
+    hello: (s: string, callParams: CallParams<'s'>) => void | Promise<void>;
 }
 export function registerServiceWithDefaultId(service: ServiceWithDefaultIdDef): void;
 export function registerServiceWithDefaultId(serviceId: string, service: ServiceWithDefaultIdDef): void;
@@ -57,7 +53,7 @@ export function registerServiceWithDefaultId(...args: any) {
 
 
 export interface ServiceWithOUTDefaultIdDef {
-    hello: (s: string, callParams: CallParams<'s'>) => void;
+    hello: (s: string, callParams: CallParams<'s'>) => void | Promise<void>;
 }
 export function registerServiceWithOUTDefaultId(serviceId: string, service: ServiceWithOUTDefaultIdDef): void;
 export function registerServiceWithOUTDefaultId(peer: FluencePeer, serviceId: string, service: ServiceWithOUTDefaultIdDef): void;
@@ -67,7 +63,6 @@ export function registerServiceWithOUTDefaultId(...args: any) {
     registerService(
         args,
         {
-    "defaultServiceId" : null,
     "functions" : [
         {
             "functionName" : "hello",
@@ -91,11 +86,11 @@ export function registerServiceWithOUTDefaultId(...args: any) {
 
 
 export interface MoreMembersDef {
-    member1: (callParams: CallParams<null>) => void;
+    member1: (callParams: CallParams<null>) => void | Promise<void>;
-member2: (s1: string, callParams: CallParams<'s1'>) => void;
+member2: (s1: string, callParams: CallParams<'s1'>) => void | Promise<void>;
-member3: (s1: string, s2: string, callParams: CallParams<'s1' | 's2'>) => void;
+member3: (s1: string, s2: string, callParams: CallParams<'s1' | 's2'>) => void | Promise<void>;
-member4: (s1: string, s2: string, i: number, callParams: CallParams<'s1' | 's2' | 'i'>) => number;
+member4: (s1: string, s2: string, i: number, callParams: CallParams<'s1' | 's2' | 'i'>) => number | Promise<number>;
-member5: (s1: string, s2: string, i: number, callParams: CallParams<'s1' | 's2' | 'i'>) => number;
+member5: (s1: string, s2: string, i: number, callParams: CallParams<'s1' | 's2' | 'i'>) => number | Promise<number>;
 }
 export function registerMoreMembers(serviceId: string, service: MoreMembersDef): void;
 export function registerMoreMembers(peer: FluencePeer, serviceId: string, service: MoreMembersDef): void;
@@ -105,7 +100,6 @@ export function registerMoreMembers(...args: any) {
     registerService(
         args,
         {
-    "defaultServiceId" : null,
     "functions" : [
         {
             "functionName" : "member1",
@@ -209,8 +203,8 @@ export function registerMoreMembers(...args: any) {
 // Functions
  
 
-export function f1(callback: (arg0: string, arg1: number, callParams: CallParams<'arg0' | 'arg1'>) => void, config?: {ttl?: number}): Promise<void>;
+export function f1(callback: (arg0: string, arg1: number, callParams: CallParams<'arg0' | 'arg1'>) => void | Promise<void>, config?: {ttl?: number}): Promise<void>;
-export function f1(peer: FluencePeer, callback: (arg0: string, arg1: number, callParams: CallParams<'arg0' | 'arg1'>) => void, config?: {ttl?: number}): Promise<void>;
+export function f1(peer: FluencePeer, callback: (arg0: string, arg1: number, callParams: CallParams<'arg0' | 'arg1'>) => void | Promise<void>, config?: {ttl?: number}): Promise<void>;
 export function f1(...args: any) {
 
     let script = `
@@ -275,8 +269,8 @@ export function f1(...args: any) {
 
  
 
-export function f2(num: number, callback: (arg0: string, arg1: number, callParams: CallParams<'arg0' | 'arg1'>) => void, config?: {ttl?: number}): Promise<void>;
+export function f2(num: number, callback: (arg0: string, arg1: number, callParams: CallParams<'arg0' | 'arg1'>) => void | Promise<void>, config?: {ttl?: number}): Promise<void>;
-export function f2(peer: FluencePeer, num: number, callback: (arg0: string, arg1: number, callParams: CallParams<'arg0' | 'arg1'>) => void, config?: {ttl?: number}): Promise<void>;
+export function f2(peer: FluencePeer, num: number, callback: (arg0: string, arg1: number, callParams: CallParams<'arg0' | 'arg1'>) => void | Promise<void>, config?: {ttl?: number}): Promise<void>;
 export function f2(...args: any) {
 
     let script = `
@@ -350,8 +344,8 @@ export function f2(...args: any) {
 
  
 
-export function f3(num: number, callback: (arg0: string, arg1: number, callParams: CallParams<'arg0' | 'arg1'>) => void, config?: {ttl?: number}): Promise<string>;
+export function f3(num: number, callback: (arg0: string, arg1: number, callParams: CallParams<'arg0' | 'arg1'>) => void | Promise<void>, config?: {ttl?: number}): Promise<string>;
-export function f3(peer: FluencePeer, num: number, callback: (arg0: string, arg1: number, callParams: CallParams<'arg0' | 'arg1'>) => void, config?: {ttl?: number}): Promise<string>;
+export function f3(peer: FluencePeer, num: number, callback: (arg0: string, arg1: number, callParams: CallParams<'arg0' | 'arg1'>) => void | Promise<void>, config?: {ttl?: number}): Promise<string>;
 export function f3(...args: any) {
 
     let script = `
@@ -431,8 +425,8 @@ export function f3(...args: any) {
 
  
 
-export function callBackZeroArgs(callback: (callParams: CallParams<null>) => void, config?: {ttl?: number}): Promise<void>;
+export function callBackZeroArgs(callback: (callParams: CallParams<null>) => void | Promise<void>, config?: {ttl?: number}): Promise<void>;
-export function callBackZeroArgs(peer: FluencePeer, callback: (callParams: CallParams<null>) => void, config?: {ttl?: number}): Promise<void>;
+export function callBackZeroArgs(peer: FluencePeer, callback: (callParams: CallParams<null>) => void | Promise<void>, config?: {ttl?: number}): Promise<void>;
 export function callBackZeroArgs(...args: any) {
 
     let script = `

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.3.2-SNAPSHOT
+ * Aqua version: 0.4.0-SNAPSHOT
  *
  */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@@ -14,15 +14,11 @@ import {
 } from '@fluencelabs/fluence/dist/internal/compilerSupport/v2';
 
 
-function missingFields(obj: any, fields: string[]): string[] {
-    return fields.filter(f => !(f in obj))
-}
-
 // Services
 
 export interface HelloWorldDef {
-    getNumber: (callParams: CallParams<null>) => number;
+    getNumber: (callParams: CallParams<null>) => number | Promise<number>;
-sayHello: (s: string, callParams: CallParams<'s'>) => void;
+sayHello: (s: string, callParams: CallParams<'s'>) => void | Promise<void>;
 }
 export function registerHelloWorld(service: HelloWorldDef): void;
 export function registerHelloWorld(serviceId: string, service: HelloWorldDef): void;
@@ -66,8 +62,8 @@ export function registerHelloWorld(...args: any) {
 // Functions
  
 
-export function callMeBack(callback: (arg0: string, arg1: number, callParams: CallParams<'arg0' | 'arg1'>) => void, config?: {ttl?: number}): Promise<void>;
+export function callMeBack(callback: (arg0: string, arg1: number, callParams: CallParams<'arg0' | 'arg1'>) => void | Promise<void>, config?: {ttl?: number}): Promise<void>;
-export function callMeBack(peer: FluencePeer, callback: (arg0: string, arg1: number, callParams: CallParams<'arg0' | 'arg1'>) => void, config?: {ttl?: number}): Promise<void>;
+export function callMeBack(peer: FluencePeer, callback: (arg0: string, arg1: number, callParams: CallParams<'arg0' | 'arg1'>) => void | Promise<void>, config?: {ttl?: number}): Promise<void>;
 export function callMeBack(...args: any) {
 
     let script = `

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.3.2-SNAPSHOT
+ * Aqua version: 0.4.0-SNAPSHOT
  *
  */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@@ -14,10 +14,6 @@ import {
 } from '@fluencelabs/fluence/dist/internal/compilerSupport/v2';
 
 
-function missingFields(obj: any, fields: string[]): string[] {
-    return fields.filter(f => !(f in obj))
-}
-
 // Services
 
 // Functions

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.3.2-SNAPSHOT
+ * Aqua version: 0.4.0-SNAPSHOT
  *
  */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@@ -14,16 +14,12 @@ import {
 } from '@fluencelabs/fluence/dist/internal/compilerSupport/v2';
 
 
-function missingFields(obj: any, fields: string[]): string[] {
-    return fields.filter(f => !(f in obj))
-}
-
 // Services
 
 export interface SomeSDef {
-    getStr: (arg0: string | null, callParams: CallParams<'arg0'>) => string | null;
+    getStr: (arg0: string | null, callParams: CallParams<'arg0'>) => string | null | Promise<string | null>;
-getStr1: (callParams: CallParams<null>) => string | null;
+getStr1: (callParams: CallParams<null>) => string | null | Promise<string | null>;
-getStr2: (arg0: string, callParams: CallParams<'arg0'>) => string;
+getStr2: (arg0: string, callParams: CallParams<'arg0'>) => string | Promise<string>;
 }
 export function registerSomeS(service: SomeSDef): void;
 export function registerSomeS(serviceId: string, service: SomeSDef): void;

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.3.2-SNAPSHOT
+ * Aqua version: 0.4.0-SNAPSHOT
  *
  */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@@ -14,14 +14,10 @@ import {
 } from '@fluencelabs/fluence/dist/internal/compilerSupport/v2';
 
 
-function missingFields(obj: any, fields: string[]): string[] {
-    return fields.filter(f => !(f in obj))
-}
-
 // Services
 
 export interface OptionStringDef {
-    checkOption: (str: string | null, callParams: CallParams<'str'>) => string;
+    checkOption: (str: string | null, callParams: CallParams<'str'>) => string | Promise<string>;
 }
 export function registerOptionString(service: OptionStringDef): void;
 export function registerOptionString(serviceId: string, service: OptionStringDef): void;

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.3.2-SNAPSHOT
+ * Aqua version: 0.4.0-SNAPSHOT
  *
  */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@@ -14,14 +14,10 @@ import {
 } from '@fluencelabs/fluence/dist/internal/compilerSupport/v2';
 
 
-function missingFields(obj: any, fields: string[]): string[] {
-    return fields.filter(f => !(f in obj))
-}
-
 // Services
 
 export interface ParServiceDef {
-    call: (callParams: CallParams<null>) => string;
+    call: (callParams: CallParams<null>) => string | Promise<string>;
 }
 export function registerParService(service: ParServiceDef): void;
 export function registerParService(serviceId: string, service: ParServiceDef): void;
@@ -51,8 +47,8 @@ export function registerParService(...args: any) {
 // Functions
  
 
-export function parFunc(node: string, c: (arg0: { external_addresses: string[]; }, callParams: CallParams<'arg0'>) => void, config?: {ttl?: number}): Promise<void>;
+export function parFunc(node: string, c: (arg0: { external_addresses: string[]; }, callParams: CallParams<'arg0'>) => void | Promise<void>, config?: {ttl?: number}): Promise<void>;
-export function parFunc(peer: FluencePeer, node: string, c: (arg0: { external_addresses: string[]; }, callParams: CallParams<'arg0'>) => void, config?: {ttl?: number}): Promise<void>;
+export function parFunc(peer: FluencePeer, node: string, c: (arg0: { external_addresses: string[]; }, callParams: CallParams<'arg0'>) => void | Promise<void>, config?: {ttl?: number}): Promise<void>;
 export function parFunc(...args: any) {
 
     let script = `

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.3.2-SNAPSHOT
+ * Aqua version: 0.4.0-SNAPSHOT
  *
  */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@@ -14,14 +14,10 @@ import {
 } from '@fluencelabs/fluence/dist/internal/compilerSupport/v2';
 
 
-function missingFields(obj: any, fields: string[]): string[] {
-    return fields.filter(f => !(f in obj))
-}
-
 // Services
 
 export interface AquaDHTDef {
-    put_host_value: (key: string, value: string, service_id: string[], callParams: CallParams<'key' | 'value' | 'service_id'>) => string;
+    put_host_value: (key: string, value: string, service_id: string[], callParams: CallParams<'key' | 'value' | 'service_id'>) => string | Promise<string>;
 }
 export function registerAquaDHT(service: AquaDHTDef): void;
 export function registerAquaDHT(serviceId: string, service: AquaDHTDef): void;

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.3.2-SNAPSHOT
+ * Aqua version: 0.4.0-SNAPSHOT
  *
  */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@@ -14,14 +14,10 @@ import {
 } from '@fluencelabs/fluence/dist/internal/compilerSupport/v2';
 
 
-function missingFields(obj: any, fields: string[]): string[] {
-    return fields.filter(f => !(f in obj))
-}
-
 // Services
 
 export interface PrintlnDef {
-    print: (arg0: string, callParams: CallParams<'arg0'>) => void;
+    print: (arg0: string, callParams: CallParams<'arg0'>) => void | Promise<void>;
 }
 export function registerPrintln(service: PrintlnDef): void;
 export function registerPrintln(serviceId: string, service: PrintlnDef): void;

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.3.2-SNAPSHOT
+ * Aqua version: 0.4.0-SNAPSHOT
  *
  */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@@ -14,14 +14,10 @@ import {
 } from '@fluencelabs/fluence/dist/internal/compilerSupport/v2';
 
 
-function missingFields(obj: any, fields: string[]): string[] {
-    return fields.filter(f => !(f in obj))
-}
-
 // Services
 
 export interface OpADef {
-    get_str: (callParams: CallParams<null>) => string;
+    get_str: (callParams: CallParams<null>) => string | Promise<string>;
 }
 export function registerOpA(service: OpADef): void;
 export function registerOpA(serviceId: string, service: OpADef): void;

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.3.2-SNAPSHOT
+ * Aqua version: 0.4.0-SNAPSHOT
  *
  */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@@ -14,10 +14,6 @@ import {
 } from '@fluencelabs/fluence/dist/internal/compilerSupport/v2';
 
 
-function missingFields(obj: any, fields: string[]): string[] {
-    return fields.filter(f => !(f in obj))
-}
-
 // Services
 
 // Functions

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.3.2-SNAPSHOT
+ * Aqua version: 0.4.0-SNAPSHOT
  *
  */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@@ -14,14 +14,10 @@ import {
 } from '@fluencelabs/fluence/dist/internal/compilerSupport/v2';
 
 
-function missingFields(obj: any, fields: string[]): string[] {
-    return fields.filter(f => !(f in obj))
-}
-
 // Services
 
 export interface StringerDef {
-    returnString: (arg0: string, callParams: CallParams<'arg0'>) => string;
+    returnString: (arg0: string, callParams: CallParams<'arg0'>) => string | Promise<string>;
 }
 export function registerStringer(service: StringerDef): void;
 export function registerStringer(serviceId: string, service: StringerDef): void;

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.3.2-SNAPSHOT
+ * Aqua version: 0.4.0-SNAPSHOT
  *
  */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@@ -14,14 +14,10 @@ import {
 } from '@fluencelabs/fluence/dist/internal/compilerSupport/v2';
 
 
-function missingFields(obj: any, fields: string[]): string[] {
-    return fields.filter(f => !(f in obj))
-}
-
 // Services
 
 export interface TestServiceDef {
-    get_records: (key: string, callParams: CallParams<'key'>) => string[];
+    get_records: (key: string, callParams: CallParams<'key'>) => string[] | Promise<string[]>;
 }
 export function registerTestService(service: TestServiceDef): void;
 export function registerTestService(serviceId: string, service: TestServiceDef): void;

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.3.2-SNAPSHOT
+ * Aqua version: 0.4.0-SNAPSHOT
  *
  */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@@ -14,14 +14,10 @@ import {
 } from '@fluencelabs/fluence/dist/internal/compilerSupport/v2';
 
 
-function missingFields(obj: any, fields: string[]): string[] {
-    return fields.filter(f => !(f in obj))
-}
-
 // Services
 
 export interface DTGetterDef {
-    get_dt: (s: string, callParams: CallParams<'s'>) => { field: string; };
+    get_dt: (s: string, callParams: CallParams<'s'>) => { field: string; } | Promise<{ field: string; }>;
 }
 export function registerDTGetter(service: DTGetterDef): void;
 export function registerDTGetter(serviceId: string, service: DTGetterDef): void;

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.3.2-SNAPSHOT
+ * Aqua version: 0.4.0-SNAPSHOT
  *
  */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@@ -14,14 +14,10 @@ import {
 } from '@fluencelabs/fluence/dist/internal/compilerSupport/v2';
 
 
-function missingFields(obj: any, fields: string[]): string[] {
-    return fields.filter(f => !(f in obj))
-}
-
 // Services
 
 export interface ConcatSubsDef {
-    get_some: (s: string, sr: { one: string; two: number; }, callParams: CallParams<'s' | 'sr'>) => { one: string; two: number; };
+    get_some: (s: string, sr: { one: string; two: number; }, callParams: CallParams<'s' | 'sr'>) => { one: string; two: number; } | Promise<{ one: string; two: number; }>;
 }
 export function registerConcatSubs(service: ConcatSubsDef): void;
 export function registerConcatSubs(serviceId: string, service: ConcatSubsDef): void;

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.3.2-SNAPSHOT
+ * Aqua version: 0.4.0-SNAPSHOT
  *
  */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@@ -14,14 +14,10 @@ import {
 } from '@fluencelabs/fluence/dist/internal/compilerSupport/v2';
 
 
-function missingFields(obj: any, fields: string[]): string[] {
-    return fields.filter(f => !(f in obj))
-}
-
 // Services
 
 export interface TestoDef {
-    getString: (arg0: string, callParams: CallParams<'arg0'>) => string;
+    getString: (arg0: string, callParams: CallParams<'arg0'>) => string | Promise<string>;
 }
 export function registerTesto(service: TestoDef): void;
 export function registerTesto(serviceId: string, service: TestoDef): void;
@@ -57,7 +53,7 @@ export function registerTesto(...args: any) {
 
 
 export interface LocalPrintDef {
-    print: (arg0: string, callParams: CallParams<'arg0'>) => void;
+    print: (arg0: string, callParams: CallParams<'arg0'>) => void | Promise<void>;
 }
 export function registerLocalPrint(service: LocalPrintDef): void;
 export function registerLocalPrint(serviceId: string, service: LocalPrintDef): void;
@@ -200,3 +196,100 @@ export function topologyTest(...args: any) {
         script
     )
 }
+
+ 
+
+export function topologyBug205(node_id: string, n2: string | null, config?: {ttl?: number}): Promise<string[]>;
+export function topologyBug205(peer: FluencePeer, node_id: string, n2: string | null, config?: {ttl?: number}): Promise<string[]>;
+export function topologyBug205(...args: any) {
+
+    let script = `
+                        (xor
+                     (seq
+                      (seq
+                       (seq
+                        (seq
+                         (seq
+                          (seq
+                           (call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-)
+                           (call %init_peer_id% ("getDataSrv" "node_id") [] node_id)
+                          )
+                          (call %init_peer_id% ("getDataSrv" "n2") [] n2)
+                         )
+                         (call -relay- ("op" "noop") [])
+                        )
+                        (xor
+                         (seq
+                          (call node_id ("op" "identity") [n2] a)
+                          (ap a.$.[0]! $nodes)
+                         )
+                         (seq
+                          (call -relay- ("op" "noop") [])
+                          (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1])
+                         )
+                        )
+                       )
+                       (xor
+                        (par
+                         (fold $nodes n
+                          (par
+                           (xor
+                            (call n ("peer" "identify") [])
+                            (seq
+                             (call -relay- ("op" "noop") [])
+                             (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 2])
+                            )
+                           )
+                           (next n)
+                          )
+                         )
+                         (null)
+                        )
+                        (seq
+                         (call -relay- ("op" "noop") [])
+                         (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 3])
+                        )
+                       )
+                      )
+                      (xor
+                       (call %init_peer_id% ("callbackSrv" "response") [$nodes])
+                       (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 4])
+                      )
+                     )
+                     (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 5])
+                    )
+    `
+    return callFunction(
+        args,
+        {
+    "functionName" : "topologyBug205",
+    "returnType" : {
+        "tag" : "primitive"
+    },
+    "argDefs" : [
+        {
+            "name" : "node_id",
+            "argType" : {
+                "tag" : "primitive"
+            }
+        },
+        {
+            "name" : "n2",
+            "argType" : {
+                "tag" : "optional"
+            }
+        }
+    ],
+    "names" : {
+        "relay" : "-relay-",
+        "getDataSrv" : "getDataSrv",
+        "callbackSrv" : "callbackSrv",
+        "responseSrv" : "callbackSrv",
+        "responseFnName" : "response",
+        "errorHandlingSrv" : "errorHandlingSrv",
+        "errorFnName" : "error"
+    }
+},
+        script
+    )
+}

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.3.2-SNAPSHOT
+ * Aqua version: 0.4.0-SNAPSHOT
  *
  */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@@ -14,14 +14,10 @@ import {
 } from '@fluencelabs/fluence/dist/internal/compilerSupport/v2';
 
 
-function missingFields(obj: any, fields: string[]): string[] {
-    return fields.filter(f => !(f in obj))
-}
-
 // Services
 
 export interface UnexistedDef {
-    getStr: (callParams: CallParams<null>) => string;
+    getStr: (callParams: CallParams<null>) => string | Promise<string>;
 }
 export function registerUnexisted(service: UnexistedDef): void;
 export function registerUnexisted(serviceId: string, service: UnexistedDef): void;
@@ -51,7 +47,7 @@ export function registerUnexisted(...args: any) {
 
 
 export interface OpADef {
-    identity: (s: string, callParams: CallParams<'s'>) => string;
+    identity: (s: string, callParams: CallParams<'s'>) => string | Promise<string>;
 }
 export function registerOpA(service: OpADef): void;
 export function registerOpA(serviceId: string, service: OpADef): void;

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.3.2-SNAPSHOT
+ * Aqua version: 0.4.0-SNAPSHOT
  *
  */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@@ -14,14 +14,10 @@ import {
 } from '@fluencelabs/fluence/dist/internal/compilerSupport/v2';
 
 
-function missingFields(obj: any, fields: string[]): string[] {
-    return fields.filter(f => !(f in obj))
-}
-
 // Services
 
 export interface UnexistedDef {
-    getStr: (callParams: CallParams<null>) => string;
+    getStr: (callParams: CallParams<null>) => string | Promise<string>;
 }
 export function registerUnexisted(service: UnexistedDef): void;
 export function registerUnexisted(serviceId: string, service: UnexistedDef): void;
@@ -51,7 +47,7 @@ export function registerUnexisted(...args: any) {
 
 
 export interface OpEDef {
-    identity: (s: string, callParams: CallParams<'s'>) => string;
+    identity: (s: string, callParams: CallParams<'s'>) => string | Promise<string>;
 }
 export function registerOpE(service: OpEDef): void;
 export function registerOpE(serviceId: string, service: OpEDef): void;

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.3.2-SNAPSHOT
+ * Aqua version: 0.4.0-SNAPSHOT
  *
  */
 import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@@ -14,14 +14,10 @@ import {
 } from '@fluencelabs/fluence/dist/internal/compilerSupport/v2';
 
 
-function missingFields(obj: any, fields: string[]): string[] {
-    return fields.filter(f => !(f in obj))
-}
-
 // Services
 
 export interface CustomIdDef {
-    id: (s: string, callParams: CallParams<'s'>) => string;
+    id: (s: string, callParams: CallParams<'s'>) => string | Promise<string>;
 }
 export function registerCustomId(service: CustomIdDef): void;
 export function registerCustomId(serviceId: string, service: CustomIdDef): void;

src/examples/streamCan.ts

@@ -0,0 +1,5 @@
+import {accumRes} from "../compiled/examples/streamCan";
+
+export async function streamCanCall() {
+    return await accumRes("a", "b");
+}