From e61bc8b9d4c37f7a47bc63e7e2c24bce0a71b754 Mon Sep 17 00:00:00 2001 From: boneyard93501 <4523011+boneyard93501@users.noreply.github.com> Date: Thu, 2 Dec 2021 14:08:41 -0600 Subject: [PATCH] update aqua --- .../client-peer/src/compiled-aqua/adder.ts | 176 ++++++++++++------ 1 file changed, 121 insertions(+), 55 deletions(-) diff --git a/quickstart/4-composing-services-with-aqua/client-peer/src/compiled-aqua/adder.ts b/quickstart/4-composing-services-with-aqua/client-peer/src/compiled-aqua/adder.ts index 77185b9..7f46fc5 100644 --- a/quickstart/4-composing-services-with-aqua/client-peer/src/compiled-aqua/adder.ts +++ b/quickstart/4-composing-services-with-aqua/client-peer/src/compiled-aqua/adder.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.4.0-235 + * Aqua version: 0.5.0-247 * */ import { Fluence, FluencePeer } from '@fluencelabs/fluence'; @@ -86,12 +86,25 @@ export function registerMyOp(...args: any) { // Functions -export function add_one(value: number, node: string, service_id: string, config?: {ttl?: number}): Promise; -export function add_one(peer: FluencePeer, value: number, node: string, service_id: string, config?: {ttl?: number}): Promise; +export function add_one( + value: number, + node: string, + service_id: string, + config?: {ttl?: number} +): Promise; + +export function add_one( + peer: FluencePeer, + value: number, + node: string, + service_id: string, + config?: {ttl?: number} +): Promise; + export function add_one(...args: any) { let script = ` - (xor + (xor (seq (seq (seq @@ -172,12 +185,23 @@ export function add_one(...args: any) { -export function add_one_three_times(value: number, ns_tuples: { node_id: string; service_id: string; }[], config?: {ttl?: number}): Promise; -export function add_one_three_times(peer: FluencePeer, value: number, ns_tuples: { node_id: string; service_id: string; }[], config?: {ttl?: number}): Promise; +export function add_one_three_times( + value: number, + ns_tuples: { node_id: string; service_id: string; }[], + config?: {ttl?: number} +): Promise; + +export function add_one_three_times( + peer: FluencePeer, + value: number, + ns_tuples: { node_id: string; service_id: string; }[], + config?: {ttl?: number} +): Promise; + export function add_one_three_times(...args: any) { let script = ` - (xor + (xor (seq (seq (seq @@ -273,51 +297,73 @@ export function add_one_three_times(...args: any) { -export function add_one_par(value: number, ns_tuples: { node_id: string; service_id: string; }[], config?: {ttl?: number}): Promise; -export function add_one_par(peer: FluencePeer, value: number, ns_tuples: { node_id: string; service_id: string; }[], config?: {ttl?: number}): Promise; +export function add_one_par( + value: number, + ns_tuples: { node_id: string; service_id: string; }[], + config?: {ttl?: number} +): Promise; + +export function add_one_par( + peer: FluencePeer, + value: number, + ns_tuples: { node_id: string; service_id: string; }[], + config?: {ttl?: number} +): Promise; + export function add_one_par(...args: any) { let script = ` - (xor + (xor (seq (seq (seq (seq - (seq - (call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-) - (call %init_peer_id% ("getDataSrv" "value") [] value) - ) - (call %init_peer_id% ("getDataSrv" "ns_tuples") [] ns_tuples) + (call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-) + (call %init_peer_id% ("getDataSrv" "value") [] value) ) - (fold ns_tuples ns - (par - (seq + (call %init_peer_id% ("getDataSrv" "ns_tuples") [] ns_tuples) + ) + (new $res + (seq + (seq + (par (seq - (seq - (call -relay- ("op" "noop") []) - (xor + (fold ns_tuples ns + (par (seq - (call -relay- ("op" "noop") []) - (call ns.$.node_id! (ns.$.service_id! "add_one") [value] $res) - ) - (seq - (call -relay- ("op" "noop") []) - (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1]) + (seq + (seq + (call -relay- ("op" "noop") []) + (xor + (seq + (call -relay- ("op" "noop") []) + (call ns.$.node_id! (ns.$.service_id! "add_one") [value] $res) + ) + (seq + (call -relay- ("op" "noop") []) + (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1]) + ) + ) + ) + (call -relay- ("op" "noop") []) + ) + (call %init_peer_id% ("op" "noop") []) ) + (next ns) ) ) - (call -relay- ("op" "noop") []) + (call %init_peer_id% ("op" "noop") []) ) - (call %init_peer_id% ("op" "noop") []) + (null) ) - (next ns) + (call %init_peer_id% ("op" "identity") [$res.$.[2]!]) ) + (call %init_peer_id% ("op" "identity") [$res] res-fix) ) ) - (call %init_peer_id% ("op" "identity") [$res.$.[2]!]) ) (xor - (call %init_peer_id% ("callbackSrv" "response") [$res]) + (call %init_peer_id% ("callbackSrv" "response") [res-fix]) (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 2]) ) ) @@ -361,48 +407,68 @@ export function add_one_par(...args: any) { -export function add_one_par_alt(payload: { node_id: string; service_id: string; value: number; }[], config?: {ttl?: number}): Promise; -export function add_one_par_alt(peer: FluencePeer, payload: { node_id: string; service_id: string; value: number; }[], config?: {ttl?: number}): Promise; +export function add_one_par_alt( + payload: { node_id: string; service_id: string; value: number; }[], + config?: {ttl?: number} +): Promise; + +export function add_one_par_alt( + peer: FluencePeer, + payload: { node_id: string; service_id: string; value: number; }[], + config?: {ttl?: number} +): Promise; + export function add_one_par_alt(...args: any) { let script = ` - (xor + (xor (seq (seq (seq + (call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-) + (call %init_peer_id% ("getDataSrv" "payload") [] payload) + ) + (new $res (seq - (call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-) - (call %init_peer_id% ("getDataSrv" "payload") [] payload) - ) - (fold payload vns - (par - (seq + (seq + (par (seq - (seq - (call -relay- ("op" "noop") []) - (xor + (fold payload vns + (par (seq - (call -relay- ("op" "noop") []) - (call vns.$.node_id! (vns.$.service_id! "add_one") [vns.$.value!] $res) - ) - (seq - (call -relay- ("op" "noop") []) - (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1]) + (seq + (seq + (call -relay- ("op" "noop") []) + (xor + (seq + (call -relay- ("op" "noop") []) + (call vns.$.node_id! (vns.$.service_id! "add_one") [vns.$.value!] $res) + ) + (seq + (call -relay- ("op" "noop") []) + (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1]) + ) + ) + ) + (call -relay- ("op" "noop") []) + ) + (call %init_peer_id% ("op" "noop") []) ) + (next vns) ) ) - (call -relay- ("op" "noop") []) + (call %init_peer_id% ("op" "noop") []) ) - (call %init_peer_id% ("op" "noop") []) + (null) ) - (next vns) + (call %init_peer_id% ("op" "identity") [$res.$.[2]!]) ) + (call %init_peer_id% ("op" "identity") [$res] res-fix) ) ) - (call %init_peer_id% ("op" "identity") [$res.$.[2]!]) ) (xor - (call %init_peer_id% ("callbackSrv" "response") [$res]) + (call %init_peer_id% ("callbackSrv" "response") [res-fix]) (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 2]) ) )