mirror of
https://github.com/fluencelabs/examples
synced 2025-06-28 17:21:33 +00:00
update aqua
This commit is contained in:
@ -3,7 +3,7 @@
|
|||||||
* This file is auto-generated. Do not edit manually: changes may be erased.
|
* This file is auto-generated. Do not edit manually: changes may be erased.
|
||||||
* Generated by Aqua compiler: https://github.com/fluencelabs/aqua/.
|
* Generated by Aqua compiler: https://github.com/fluencelabs/aqua/.
|
||||||
* If you find any bugs, please write an issue on GitHub: https://github.com/fluencelabs/aqua/issues
|
* If you find any bugs, please write an issue on GitHub: https://github.com/fluencelabs/aqua/issues
|
||||||
* Aqua version: 0.4.0-235
|
* Aqua version: 0.5.0-247
|
||||||
*
|
*
|
||||||
*/
|
*/
|
||||||
import { Fluence, FluencePeer } from '@fluencelabs/fluence';
|
import { Fluence, FluencePeer } from '@fluencelabs/fluence';
|
||||||
@ -86,8 +86,21 @@ export function registerMyOp(...args: any) {
|
|||||||
// Functions
|
// Functions
|
||||||
|
|
||||||
|
|
||||||
export function add_one(value: number, node: string, service_id: string, config?: {ttl?: number}): Promise<number>;
|
export function add_one(
|
||||||
export function add_one(peer: FluencePeer, value: number, node: string, service_id: string, config?: {ttl?: number}): Promise<number>;
|
value: number,
|
||||||
|
node: string,
|
||||||
|
service_id: string,
|
||||||
|
config?: {ttl?: number}
|
||||||
|
): Promise<number>;
|
||||||
|
|
||||||
|
export function add_one(
|
||||||
|
peer: FluencePeer,
|
||||||
|
value: number,
|
||||||
|
node: string,
|
||||||
|
service_id: string,
|
||||||
|
config?: {ttl?: number}
|
||||||
|
): Promise<number>;
|
||||||
|
|
||||||
export function add_one(...args: any) {
|
export function add_one(...args: any) {
|
||||||
|
|
||||||
let script = `
|
let script = `
|
||||||
@ -172,8 +185,19 @@ 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<number>;
|
export function add_one_three_times(
|
||||||
export function add_one_three_times(peer: FluencePeer, value: number, ns_tuples: { node_id: string; service_id: string; }[], config?: {ttl?: number}): Promise<number>;
|
value: number,
|
||||||
|
ns_tuples: { node_id: string; service_id: string; }[],
|
||||||
|
config?: {ttl?: number}
|
||||||
|
): Promise<number>;
|
||||||
|
|
||||||
|
export function add_one_three_times(
|
||||||
|
peer: FluencePeer,
|
||||||
|
value: number,
|
||||||
|
ns_tuples: { node_id: string; service_id: string; }[],
|
||||||
|
config?: {ttl?: number}
|
||||||
|
): Promise<number>;
|
||||||
|
|
||||||
export function add_one_three_times(...args: any) {
|
export function add_one_three_times(...args: any) {
|
||||||
|
|
||||||
let script = `
|
let script = `
|
||||||
@ -273,15 +297,25 @@ 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<number[]>;
|
export function add_one_par(
|
||||||
export function add_one_par(peer: FluencePeer, value: number, ns_tuples: { node_id: string; service_id: string; }[], config?: {ttl?: number}): Promise<number[]>;
|
value: number,
|
||||||
|
ns_tuples: { node_id: string; service_id: string; }[],
|
||||||
|
config?: {ttl?: number}
|
||||||
|
): Promise<number[]>;
|
||||||
|
|
||||||
|
export function add_one_par(
|
||||||
|
peer: FluencePeer,
|
||||||
|
value: number,
|
||||||
|
ns_tuples: { node_id: string; service_id: string; }[],
|
||||||
|
config?: {ttl?: number}
|
||||||
|
): Promise<number[]>;
|
||||||
|
|
||||||
export function add_one_par(...args: any) {
|
export function add_one_par(...args: any) {
|
||||||
|
|
||||||
let script = `
|
let script = `
|
||||||
(xor
|
(xor
|
||||||
(seq
|
(seq
|
||||||
(seq
|
(seq
|
||||||
(seq
|
|
||||||
(seq
|
(seq
|
||||||
(seq
|
(seq
|
||||||
(call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-)
|
(call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-)
|
||||||
@ -289,6 +323,11 @@ export function add_one_par(...args: any) {
|
|||||||
)
|
)
|
||||||
(call %init_peer_id% ("getDataSrv" "ns_tuples") [] ns_tuples)
|
(call %init_peer_id% ("getDataSrv" "ns_tuples") [] ns_tuples)
|
||||||
)
|
)
|
||||||
|
(new $res
|
||||||
|
(seq
|
||||||
|
(seq
|
||||||
|
(par
|
||||||
|
(seq
|
||||||
(fold ns_tuples ns
|
(fold ns_tuples ns
|
||||||
(par
|
(par
|
||||||
(seq
|
(seq
|
||||||
@ -313,11 +352,18 @@ export function add_one_par(...args: any) {
|
|||||||
(next ns)
|
(next ns)
|
||||||
)
|
)
|
||||||
)
|
)
|
||||||
|
(call %init_peer_id% ("op" "noop") [])
|
||||||
|
)
|
||||||
|
(null)
|
||||||
)
|
)
|
||||||
(call %init_peer_id% ("op" "identity") [$res.$.[2]!])
|
(call %init_peer_id% ("op" "identity") [$res.$.[2]!])
|
||||||
)
|
)
|
||||||
|
(call %init_peer_id% ("op" "identity") [$res] res-fix)
|
||||||
|
)
|
||||||
|
)
|
||||||
|
)
|
||||||
(xor
|
(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])
|
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 2])
|
||||||
)
|
)
|
||||||
)
|
)
|
||||||
@ -361,19 +407,32 @@ 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<number[]>;
|
export function add_one_par_alt(
|
||||||
export function add_one_par_alt(peer: FluencePeer, payload: { node_id: string; service_id: string; value: number; }[], config?: {ttl?: number}): Promise<number[]>;
|
payload: { node_id: string; service_id: string; value: number; }[],
|
||||||
|
config?: {ttl?: number}
|
||||||
|
): Promise<number[]>;
|
||||||
|
|
||||||
|
export function add_one_par_alt(
|
||||||
|
peer: FluencePeer,
|
||||||
|
payload: { node_id: string; service_id: string; value: number; }[],
|
||||||
|
config?: {ttl?: number}
|
||||||
|
): Promise<number[]>;
|
||||||
|
|
||||||
export function add_one_par_alt(...args: any) {
|
export function add_one_par_alt(...args: any) {
|
||||||
|
|
||||||
let script = `
|
let script = `
|
||||||
(xor
|
(xor
|
||||||
(seq
|
(seq
|
||||||
(seq
|
|
||||||
(seq
|
(seq
|
||||||
(seq
|
(seq
|
||||||
(call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-)
|
(call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-)
|
||||||
(call %init_peer_id% ("getDataSrv" "payload") [] payload)
|
(call %init_peer_id% ("getDataSrv" "payload") [] payload)
|
||||||
)
|
)
|
||||||
|
(new $res
|
||||||
|
(seq
|
||||||
|
(seq
|
||||||
|
(par
|
||||||
|
(seq
|
||||||
(fold payload vns
|
(fold payload vns
|
||||||
(par
|
(par
|
||||||
(seq
|
(seq
|
||||||
@ -398,11 +457,18 @@ export function add_one_par_alt(...args: any) {
|
|||||||
(next vns)
|
(next vns)
|
||||||
)
|
)
|
||||||
)
|
)
|
||||||
|
(call %init_peer_id% ("op" "noop") [])
|
||||||
|
)
|
||||||
|
(null)
|
||||||
)
|
)
|
||||||
(call %init_peer_id% ("op" "identity") [$res.$.[2]!])
|
(call %init_peer_id% ("op" "identity") [$res.$.[2]!])
|
||||||
)
|
)
|
||||||
|
(call %init_peer_id% ("op" "identity") [$res] res-fix)
|
||||||
|
)
|
||||||
|
)
|
||||||
|
)
|
||||||
(xor
|
(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])
|
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 2])
|
||||||
)
|
)
|
||||||
)
|
)
|
||||||
|
Reference in New Issue
Block a user