diff --git a/echo-greeter/air-scripts/air_echo.clj b/echo-greeter/air-scripts/air_echo.clj deleted file mode 100644 index c398ae3..0000000 --- a/echo-greeter/air-scripts/air_echo.clj +++ /dev/null @@ -1,17 +0,0 @@ -(xor - (seq - (seq - (call relay ("op" "identity") []) - (call relay (echo_service "echo") [names] array_result) - ) - (seq - (call relay ("op" "identity") []) - ; (call %init_peer_id% (returnService "run") [array_result.$.[0]["echo"]]) - (call %init_peer_id% (returnService "run") [array_result]) - ) - ) - (seq - (call relay ("op" "identity") []) - (call %init_peer_id% (returnService "run") ["XOR FAILED: " %last_error%]) - ) -) diff --git a/echo-greeter/air-scripts/air_echo_greeting_fold_par.clj b/echo-greeter/air-scripts/air_echo_greeting_fold_par.clj deleted file mode 100644 index f1cc2fd..0000000 --- a/echo-greeter/air-scripts/air_echo_greeting_fold_par.clj +++ /dev/null @@ -1,27 +0,0 @@ -(xor - (seq - (seq - (call relay ("op" "identity") []) - (call node_1 (echo_service "echo") [names] array_result) - ) - (seq - (fold array_result item - (par - (seq - (call node_2 (greeting_service_1 "greeting") [item.$.["echo"]! greeter] $greeting_1_result) - (call node_3 (greeting_service_2 "greeting") [item.$.["echo"]! no_greeter] $greeting_2_result) - ) - (next item) - ) - ) - (seq - (call relay ("op" "identity") []) - (call %init_peer_id% (returnService "run") [$greeting_1_result $greeting_2_result]) - ) - ) - ) - (seq - (call relay ("op" "identity") []) - (call %init_peer_id% (returnService "run") ["XOR FAILED %last_error"]) - ) -) diff --git a/echo-greeter/air-scripts/air_echo_greeting_fold_seq.clj b/echo-greeter/air-scripts/air_echo_greeting_fold_seq.clj deleted file mode 100644 index 82f3bf5..0000000 --- a/echo-greeter/air-scripts/air_echo_greeting_fold_seq.clj +++ /dev/null @@ -1,37 +0,0 @@ -(xor - (seq - (seq - (call relay ("op" "identity") []) - (call node_1 (echo_service "echo") [names] array_result) - ) - (seq - (seq - (call relay ("op" "identity") []) - (call %init_peer_id% (returnService "run") [array_result]) - ) - (seq - (fold array_result item - (seq - (seq - (call relay ("op" "identity") []) - (call node_2 (greeting_service_1 "greeting") [item.$.["echo"]! greeter] $greeter_results) - ) - (seq - (call relay ("op" "identity") []) - (next item) - ) - ) - ) - (seq - (call relay ("op" "identity") []) - (call %init_peer_id% ("returnService" "run") [$greeter_results]) - ) - ) - ) - ) - (seq - (call relay ("op" "identity") []) - (call %init_peer_id% (returnService "run") ["XOR FAILED" %last_error%]) - ) -) - diff --git a/echo-greeter/air-scripts/air_echo_greeting_seq.clj b/echo-greeter/air-scripts/air_echo_greeting_seq.clj deleted file mode 100644 index 328e30f..0000000 --- a/echo-greeter/air-scripts/air_echo_greeting_seq.clj +++ /dev/null @@ -1,40 +0,0 @@ -(xor - (seq - (seq - (seq - (call relay ("op" "identity") []) - (call node_1 (echo_service "echo") [names] echo_result) - ) - (seq - (call relay ("op" "identity") []) - (call %init_peer_id% (returnService "run") [echo_result]) - ) - ) - (seq - (seq - (seq - (call relay ("op" "identity") []) - (call node_2 (greeting_service_1 "greeting") [echo_result.$.[0]["echo"]! greeter] greeter_result_0) - ) - (seq - (call relay ("op" "identity") []) - (call %init_peer_id% (returnService "run") [greeter_result_0]) - ) - ) - (seq - (seq - (call relay ("op" "identity") []) - (call node_3 (greeting_service_2 "greeting") [echo_result.$.[2]["echo"]! greeter] greeter_result_1) - ) - (seq - (call relay ("op" "identity") []) - (call %init_peer_id% (returnService "run") [greeter_result_1]) - ) - ) - ) - ) - (seq - (call relay ("op" "identity") []) - (call %init_peer_id% (returnService "run") ["XOR FAILED" %last_error%]) - ) -) \ No newline at end of file diff --git a/echo-greeter/air-scripts/air_greeting.clj b/echo-greeter/air-scripts/air_greeting.clj deleted file mode 100644 index 21af67b..0000000 --- a/echo-greeter/air-scripts/air_greeting.clj +++ /dev/null @@ -1,7 +0,0 @@ -(xor - (seq - (call relay (greeting_service "greeting") [name greeter] result) - (call %init_peer_id% (returnService "run") [result]) - ) - (call %init_peer_id% (returnService "run") [%last_error%]) -) \ No newline at end of file diff --git a/echo-greeter/aqua-compiled/echo_greeter.echo.air b/echo-greeter/aqua-compiled/echo_greeter.echo.air new file mode 100644 index 0000000..bd49b45 --- /dev/null +++ b/echo-greeter/aqua-compiled/echo_greeter.echo.air @@ -0,0 +1,40 @@ +(xor + (seq + (seq + (seq + (seq + (seq + (seq + (seq + (call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-) + (call %init_peer_id% ("getDataSrv" "names") [] names) + ) + (call %init_peer_id% ("getDataSrv" "node") [] node) + ) + (call %init_peer_id% ("getDataSrv" "echo_service") [] echo_service) + ) + (call -relay- ("op" "identity") []) + ) + (xor + (call node (echo_service "echo") [names] res) + (seq + (seq + (call -relay- ("op" "identity") []) + (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1]) + ) + (call -relay- ("op" "identity") []) + ) + ) + ) + (call -relay- ("op" "identity") []) + ) + (xor + (call %init_peer_id% ("callbackSrv" "response") [res]) + (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 2]) + ) + ) + (seq + (call -relay- ("op" "identity") []) + (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 3]) + ) +) diff --git a/echo-greeter/aqua-compiled/echo_greeter.echo_greeting_par.air b/echo-greeter/aqua-compiled/echo_greeter.echo_greeting_par.air new file mode 100644 index 0000000..49f4bb2 --- /dev/null +++ b/echo-greeter/aqua-compiled/echo_greeter.echo_greeting_par.air @@ -0,0 +1,68 @@ +(xor + (seq + (seq + (seq + (seq + (seq + (seq + (seq + (seq + (seq + (call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-) + (call %init_peer_id% ("getDataSrv" "names") [] names) + ) + (call %init_peer_id% ("getDataSrv" "greet") [] greet) + ) + (call %init_peer_id% ("getDataSrv" "echo_service") [] echo_service) + ) + (call %init_peer_id% ("getDataSrv" "greeting_services") [] greeting_services) + ) + (call -relay- ("op" "identity") []) + ) + (xor + (call echo_service.$.node! (echo_service.$.service_id! "echo") [names] echo_results) + (seq + (call -relay- ("op" "identity") []) + (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1]) + ) + ) + ) + (call -relay- ("op" "identity") []) + ) + (fold echo_results result + (par + (fold greeting_services greeting_service + (seq + (seq + (seq + (call -relay- ("op" "identity") []) + (xor + (seq + (call greeting_service.$.node! (greeting_service.$.service_id! "greeting") [result.$.echo! greet] $res) + (call greeting_service.$.node! ("op" "identity") [$res.$.[2]!]) + ) + (seq + (call -relay- ("op" "identity") []) + (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 2]) + ) + ) + ) + (call -relay- ("op" "identity") []) + ) + (next greeting_service) + ) + ) + (next result) + ) + ) + ) + (xor + (call %init_peer_id% ("callbackSrv" "response") [$res]) + (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 3]) + ) + ) + (seq + (call -relay- ("op" "identity") []) + (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 4]) + ) +) diff --git a/echo-greeter/aqua-compiled/echo_greeter.echo_greeting_seq.air b/echo-greeter/aqua-compiled/echo_greeter.echo_greeting_seq.air new file mode 100644 index 0000000..ec47131 --- /dev/null +++ b/echo-greeter/aqua-compiled/echo_greeter.echo_greeting_seq.air @@ -0,0 +1,54 @@ +(xor + (seq + (seq + (seq + (seq + (seq + (seq + (seq + (seq + (seq + (call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-) + (call %init_peer_id% ("getDataSrv" "names") [] names) + ) + (call %init_peer_id% ("getDataSrv" "greet") [] greet) + ) + (call %init_peer_id% ("getDataSrv" "node") [] node) + ) + (call %init_peer_id% ("getDataSrv" "echo_service_id") [] echo_service_id) + ) + (call %init_peer_id% ("getDataSrv" "greeting_service_id") [] greeting_service_id) + ) + (call -relay- ("op" "identity") []) + ) + (xor + (seq + (call node (echo_service_id "echo") [names] echo_names) + (fold echo_names result + (seq + (call node (greeting_service_id "greeting") [result.$.echo! greet] $res) + (next result) + ) + ) + ) + (seq + (seq + (call -relay- ("op" "identity") []) + (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1]) + ) + (call -relay- ("op" "identity") []) + ) + ) + ) + (call -relay- ("op" "identity") []) + ) + (xor + (call %init_peer_id% ("callbackSrv" "response") [$res]) + (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 2]) + ) + ) + (seq + (call -relay- ("op" "identity") []) + (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 3]) + ) +) diff --git a/echo-greeter/aqua-compiled/echo_greeter.greeting.air b/echo-greeter/aqua-compiled/echo_greeter.greeting.air new file mode 100644 index 0000000..0617057 --- /dev/null +++ b/echo-greeter/aqua-compiled/echo_greeter.greeting.air @@ -0,0 +1,43 @@ +(xor + (seq + (seq + (seq + (seq + (seq + (seq + (seq + (seq + (call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-) + (call %init_peer_id% ("getDataSrv" "name") [] name) + ) + (call %init_peer_id% ("getDataSrv" "greet") [] greet) + ) + (call %init_peer_id% ("getDataSrv" "node") [] node) + ) + (call %init_peer_id% ("getDataSrv" "greeting_service_id") [] greeting_service_id) + ) + (call -relay- ("op" "identity") []) + ) + (xor + (call node (greeting_service_id "greeting") [name greet] res) + (seq + (seq + (call -relay- ("op" "identity") []) + (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1]) + ) + (call -relay- ("op" "identity") []) + ) + ) + ) + (call -relay- ("op" "identity") []) + ) + (xor + (call %init_peer_id% ("callbackSrv" "response") [res]) + (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 2]) + ) + ) + (seq + (call -relay- ("op" "identity") []) + (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 3]) + ) +) diff --git a/echo-greeter/aqua-compiled/echo_greeter.ts b/echo-greeter/aqua-compiled/echo_greeter.ts new file mode 100644 index 0000000..714ba6d --- /dev/null +++ b/echo-greeter/aqua-compiled/echo_greeter.ts @@ -0,0 +1,300 @@ +/** + * + * This file is auto-generated. Do not edit manually: changes may be erased. + * Generated by Aqua compiler: https://github.com/fluencelabs/aqua/. + * If you find any bugs, please write an issue on GitHub: https://github.com/fluencelabs/aqua/issues + * Aqua version: 0.1.6-146 + * + */ +import { FluenceClient, PeerIdB58 } from '@fluencelabs/fluence'; +import { RequestFlowBuilder } from '@fluencelabs/fluence/dist/api.unstable'; +import { RequestFlow } from '@fluencelabs/fluence/dist/internal/RequestFlow'; + + + +export async function echo(client: FluenceClient, names: string[], node: string, echo_service: string, config?: {ttl?: number}): Promise<{echo:string}[]> { + let request: RequestFlow; + const promise = new Promise<{echo:string}[]>((resolve, reject) => { + request = new RequestFlowBuilder() + .disableInjections() + .withTTL(config?.ttl || 5000) + .withRawScript( + ` +(xor + (seq + (seq + (seq + (seq + (seq + (seq + (seq + (call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-) + (call %init_peer_id% ("getDataSrv" "names") [] names) + ) + (call %init_peer_id% ("getDataSrv" "node") [] node) + ) + (call %init_peer_id% ("getDataSrv" "echo_service") [] echo_service) + ) + (call -relay- ("op" "identity") []) + ) + (xor + (call node (echo_service "echo") [names] res) + (seq + (seq + (call -relay- ("op" "identity") []) + (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1]) + ) + (call -relay- ("op" "identity") []) + ) + ) + ) + (call -relay- ("op" "identity") []) + ) + (xor + (call %init_peer_id% ("callbackSrv" "response") [res]) + (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 2]) + ) + ) + (seq + (call -relay- ("op" "identity") []) + (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 3]) + ) +) + + `, + ) + .configHandler((h) => { + h.on('getDataSrv', '-relay-', () => { + return client.relayPeerId!; + }); + h.on('getDataSrv', 'names', () => {return names;}); +h.on('getDataSrv', 'node', () => {return node;}); +h.on('getDataSrv', 'echo_service', () => {return echo_service;}); + h.onEvent('callbackSrv', 'response', (args) => { + const [res] = args; + resolve(res); +}); + + h.onEvent('errorHandlingSrv', 'error', (args) => { + // assuming error is the single argument + const [err] = args; + reject(err); + }); + }) + .handleScriptError(reject) + .handleTimeout(() => { + reject('Request timed out for echo'); + }) + .build(); + }); + await client.initiateFlow(request!); + return promise; +} + + + +export async function echo_greeting_seq(client: FluenceClient, names: string[], greet: boolean, node: string, echo_service_id: string, greeting_service_id: string, config?: {ttl?: number}): Promise { + let request: RequestFlow; + const promise = new Promise((resolve, reject) => { + request = new RequestFlowBuilder() + .disableInjections() + .withTTL(config?.ttl || 5000) + .withRawScript( + ` +(xor + (seq + (seq + (seq + (seq + (seq + (seq + (seq + (seq + (seq + (call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-) + (call %init_peer_id% ("getDataSrv" "names") [] names) + ) + (call %init_peer_id% ("getDataSrv" "greet") [] greet) + ) + (call %init_peer_id% ("getDataSrv" "node") [] node) + ) + (call %init_peer_id% ("getDataSrv" "echo_service_id") [] echo_service_id) + ) + (call %init_peer_id% ("getDataSrv" "greeting_service_id") [] greeting_service_id) + ) + (call -relay- ("op" "identity") []) + ) + (xor + (seq + (call node (echo_service_id "echo") [names] echo_names) + (fold echo_names result + (seq + (call node ("service-id" "greeting") [result.$.echo! greet] $res) + (next result) + ) + ) + ) + (seq + (seq + (call -relay- ("op" "identity") []) + (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1]) + ) + (call -relay- ("op" "identity") []) + ) + ) + ) + (call -relay- ("op" "identity") []) + ) + (xor + (call %init_peer_id% ("callbackSrv" "response") [$res]) + (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 2]) + ) + ) + (seq + (call -relay- ("op" "identity") []) + (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 3]) + ) +) + + `, + ) + .configHandler((h) => { + h.on('getDataSrv', '-relay-', () => { + return client.relayPeerId!; + }); + h.on('getDataSrv', 'names', () => {return names;}); +h.on('getDataSrv', 'greet', () => {return greet;}); +h.on('getDataSrv', 'node', () => {return node;}); +h.on('getDataSrv', 'echo_service_id', () => {return echo_service_id;}); +h.on('getDataSrv', 'greeting_service_id', () => {return greeting_service_id;}); + h.onEvent('callbackSrv', 'response', (args) => { + const [res] = args; + resolve(res); +}); + + h.onEvent('errorHandlingSrv', 'error', (args) => { + // assuming error is the single argument + const [err] = args; + reject(err); + }); + }) + .handleScriptError(reject) + .handleTimeout(() => { + reject('Request timed out for echo_greeting_seq'); + }) + .build(); + }); + await client.initiateFlow(request!); + return promise; +} + + + +export async function echo_greeting_par(client: FluenceClient, names: string[], greet: boolean, echo_service: {names:string[];node:string;service_id:string}, greeting_services: {node:string;service_id:string}[], config?: {ttl?: number}): Promise { + let request: RequestFlow; + const promise = new Promise((resolve, reject) => { + request = new RequestFlowBuilder() + .disableInjections() + .withTTL(config?.ttl || 5000) + .withRawScript( + ` +(xor + (seq + (seq + (seq + (seq + (seq + (seq + (seq + (seq + (seq + (call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-) + (call %init_peer_id% ("getDataSrv" "names") [] names) + ) + (call %init_peer_id% ("getDataSrv" "greet") [] greet) + ) + (call %init_peer_id% ("getDataSrv" "echo_service") [] echo_service) + ) + (call %init_peer_id% ("getDataSrv" "greeting_services") [] greeting_services) + ) + (call -relay- ("op" "identity") []) + ) + (xor + (call echo_service.$.node! (echo_service.$.service_id! "echo") [names] echo_results) + (seq + (call -relay- ("op" "identity") []) + (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1]) + ) + ) + ) + (call -relay- ("op" "identity") []) + ) + (fold echo_results result + (par + (fold greeting_services greeting_service + (par + (seq + (call -relay- ("op" "identity") []) + (xor + (seq + (call greeting_service.$.node! (greeting_service.$.service_id! "greeting") [result.$.echo! greet] $res) + (call greeting_service.$.node! ("op" "identity") [$res.$.[19]!]) + ) + (seq + (call -relay- ("op" "identity") []) + (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 2]) + ) + ) + ) + (seq + (call -relay- ("op" "identity") []) + (next greeting_service) + ) + ) + ) + (next result) + ) + ) + ) + (xor + (call %init_peer_id% ("callbackSrv" "response") [$res]) + (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 3]) + ) + ) + (seq + (call -relay- ("op" "identity") []) + (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 4]) + ) +) + + `, + ) + .configHandler((h) => { + h.on('getDataSrv', '-relay-', () => { + return client.relayPeerId!; + }); + h.on('getDataSrv', 'names', () => {return names;}); +h.on('getDataSrv', 'greet', () => {return greet;}); +h.on('getDataSrv', 'echo_service', () => {return echo_service;}); +h.on('getDataSrv', 'greeting_services', () => {return greeting_services;}); + h.onEvent('callbackSrv', 'response', (args) => { + const [res] = args; + resolve(res); +}); + + h.onEvent('errorHandlingSrv', 'error', (args) => { + // assuming error is the single argument + const [err] = args; + reject(err); + }); + }) + .handleScriptError(reject) + .handleTimeout(() => { + reject('Request timed out for echo_greeting_par'); + }) + .build(); + }); + await client.initiateFlow(request!); + return promise; +} + \ No newline at end of file