fluencelabs/aqua-playground
1
0
Fork 0
mirror of https://github.com/fluencelabs/aqua-playground synced 2025-03-15 19:51:13 +00:00
Code Issues Projects Releases Wiki Activity

tests

Browse Source
This commit is contained in:
DieMyst 2022-10-03 18:15:29 +03:00
parent 34ba399881
commit e34f10a27a
52 changed files with 1917 additions and 659 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1293
package-lock.json generated
View File

File diff suppressed because it is too large Load Diff

2
package.json
View File

@ -42,7 +42,7 @@
}, },
"dependencies": { "dependencies": {
"@fluencelabs/aqua-dht-ts": "0.1.38", "@fluencelabs/aqua-dht-ts": "0.1.38",
"@fluencelabs/fluence": "0.25.2", "@fluencelabs/fluence": "^0.25.2-bump-avm-c577d66-50-1",
"@fluencelabs/fluence-network-environment": "1.0.13", "@fluencelabs/fluence-network-environment": "1.0.13",
"deep-equal": "^2.0.5" "deep-equal": "^2.0.5"
}, },

2
src/compiled/examples/aliases.ts
View File

@ -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.7.4-336 * Aqua version: 0.7.6-SNAPSHOT
* *
*/ */
import { Fluence, FluencePeer } from '@fluencelabs/fluence'; import { Fluence, FluencePeer } from '@fluencelabs/fluence';

2
src/compiled/examples/assignment.ts
View File

@ -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.7.4-336 * Aqua version: 0.7.6-SNAPSHOT
* *
*/ */
import { Fluence, FluencePeer } from '@fluencelabs/fluence'; import { Fluence, FluencePeer } from '@fluencelabs/fluence';

2
src/compiled/examples/callArrow.ts
View File

@ -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.7.4-336 * Aqua version: 0.7.6-SNAPSHOT
* *
*/ */
import { Fluence, FluencePeer } from '@fluencelabs/fluence'; import { Fluence, FluencePeer } from '@fluencelabs/fluence';

46
src/compiled/examples/canon.ts
View File

@ -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.7.5-SNAPSHOT * Aqua version: 0.7.6-SNAPSHOT
* *
*/ */
import { Fluence, FluencePeer } from '@fluencelabs/fluence'; import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@ -95,40 +95,66 @@ export function bugLng79(...args: any) {
(seq (seq
(seq (seq
(call %init_peer_id% ("ser" "getRecord") [] $stream) (call %init_peer_id% ("ser" "getRecord") [] $stream)
(canon %init_peer_id% $stream #stream_canon) (new $stream_test
(seq
(fold $stream s
(seq
(seq
(seq
(call %init_peer_id% ("math" "add") [0 1] incr_idx)
(ap s $stream_test)
)
(canon %init_peer_id% $stream_test #stream_iter_canon)
)
(xor
(match #stream_iter_canon.length incr_idx
(null)
)
(next s)
)
)
(never)
)
(canon %init_peer_id% $stream_test #stream_result_canon)
)
)
) )
(ap #stream_canon.$.[0].relay_id! $stream_canon_flatten) (ap #stream_result_canon.$.[0].relay_id! stream_result_canon_flatten)
) )
(call -relay- ("op" "noop") []) (call -relay- ("op" "noop") [])
) )
(fold $stream_canon_flatten -via-peer- (fold stream_result_canon_flatten -via-peer-
(seq (seq
(call -via-peer- ("op" "noop") []) (call -via-peer- ("op" "noop") [])
(next -via-peer-) (next -via-peer-)
) )
)
)
) )
(xor (xor
(seq (seq
(seq (seq
(call #stream_canon.$.[0].peer_id! ("math" "add") [1 1] add) (call #stream_result_canon.$.[0].peer_id! ("math" "add") [1 1] add)
(fold $stream_canon_flatten -via-peer- (fold stream_result_canon_flatten -via-peer-
(seq (seq
(next -via-peer-) (next -via-peer-)
(call -via-peer- ("op" "noop") []) (call -via-peer- ("op" "noop") [])
) )
)
)
) )
(call -relay- ("op" "noop") []) (call -relay- ("op" "noop") [])
) )
(seq (seq
(seq (seq
(fold $stream_canon_flatten -via-peer- (fold stream_result_canon_flatten -via-peer-
(seq (seq
(call -via-peer- ("op" "noop") []) (call -via-peer- ("op" "noop") [])
(next -via-peer-) (next -via-peer-)
) )
)
)
(call -relay- ("op" "noop") []) (call -relay- ("op" "noop") [])
) )
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1]) (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1])

12
src/compiled/examples/closures.ts
View File

@ -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.7.4-336 * Aqua version: 0.7.6-SNAPSHOT
* *
*/ */
import { Fluence, FluencePeer } from '@fluencelabs/fluence'; import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@ -114,7 +114,7 @@ export function closureBig(...args: any) {
(ap p2Info.$.external_addresses.[0]! $p2Id-0) (ap p2Info.$.external_addresses.[0]! $p2Id-0)
) )
) )
(call %init_peer_id% ("op" "identity") [$p2Id-0] p2Id-fix) (canon %init_peer_id% $p2Id-0 #p2Id-fix)
) )
) )
) )
@ -145,7 +145,7 @@ export function closureBig(...args: any) {
(ap p2Info-0.$.external_addresses.[0]! $p2Id) (ap p2Info-0.$.external_addresses.[0]! $p2Id)
) )
) )
(call peer2 ("op" "identity") [$p2Id] p2Id-fix-0) (canon peer2 $p2Id #p2Id-fix-0)
) )
) )
(call -relay- ("op" "noop") []) (call -relay- ("op" "noop") [])
@ -157,7 +157,7 @@ export function closureBig(...args: any) {
) )
) )
(xor (xor
(call %init_peer_id% ("callbackSrv" "response") [p2Id-fix.$.[0]! p2Id-fix-0.$.[0]!]) (call %init_peer_id% ("callbackSrv" "response") [#p2Id-fix.$.[0]! #p2Id-fix-0.$.[0]!])
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 5]) (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 5])
) )
) )
@ -237,12 +237,12 @@ export function lng58Bug(...args: any) {
(ap "ok" $status-0) (ap "ok" $status-0)
) )
) )
(call %init_peer_id% ("op" "identity") [$status] status-fix) (canon %init_peer_id% $status #status-fix)
) )
) )
) )
(xor (xor
(call %init_peer_id% ("callbackSrv" "response") [status-fix.$.[0]!]) (call %init_peer_id% ("callbackSrv" "response") [#status-fix.$.[0]!])
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1]) (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1])
) )
) )

2
src/compiled/examples/co.ts
View File

@ -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.7.4-336 * Aqua version: 0.7.6-SNAPSHOT
* *
*/ */
import { Fluence, FluencePeer } from '@fluencelabs/fluence'; import { Fluence, FluencePeer } from '@fluencelabs/fluence';

165
src/compiled/examples/collectionSugar.ts
View File

@ -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.7.5-SNAPSHOT * Aqua version: 0.7.6-SNAPSHOT
* *
*/ */
import { Fluence, FluencePeer } from '@fluencelabs/fluence'; import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@ -142,23 +142,28 @@ export function streamSugar(...args: any) {
(seq (seq
(seq (seq
(seq (seq
(ap 1 $stream-inline) (seq
(ap 2 $stream-inline) (ap 1 $stream-inline)
(ap 2 $stream-inline)
)
(ap n $stream-inline)
) )
(ap n $stream-inline) (ap 4 $stream-inline-0)
) )
(ap 4 $stream-inline-0) (ap 5 $stream-inline-0)
) )
(ap 5 $stream-inline-0) (ap m $stream-inline-0)
) )
(ap m $stream-inline-0) (canon %init_peer_id% $stream-inline-0 #stream-inline-0_canon)
) )
(fold $stream-inline-0 i-0 (fold #stream-inline-0_canon i-0
(seq (seq
(ap i-0 $str) (ap i-0 $str)
(next i-0) (next i-0)
) )
) (null)
)
) )
(canon %init_peer_id% $stream-inline #arr-fix) (canon %init_peer_id% $stream-inline #arr-fix)
) )
@ -328,7 +333,9 @@ export function optionSugar(...args: any) {
(ap i-0 $str) (ap i-0 $str)
(next i-0) (next i-0)
) )
) (null)
)
) )
(new $option-inline-3 (new $option-inline-3
(seq (seq
@ -348,7 +355,9 @@ export function optionSugar(...args: any) {
(ap i-1 $str) (ap i-1 $str)
(next i-1) (next i-1)
) )
) (null)
)
) )
(canon %init_peer_id% $str #str-fix) (canon %init_peer_id% $str #str-fix)
) )
@ -443,127 +452,6 @@ export function optionSugar(...args: any) {
} }
export type EmptySugarResult = [number[], string[], string[], string[], number | null, number[], string | null]
export function emptySugar(
config?: {ttl?: number}
): Promise<EmptySugarResult>;
export function emptySugar(
peer: FluencePeer,
config?: {ttl?: number}
): Promise<EmptySugarResult>;
export function emptySugar(...args: any) {
let script = `
(xor
(seq
(seq
(call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-)
(new $strStream
(seq
(new $strArr
(seq
(new $numOp
(call %init_peer_id% ("op" "identity") [[]] #numOp-fix)
)
(call %init_peer_id% ("op" "identity") [[]] #strArr-fix)
)
)
(call %init_peer_id% ("op" "identity") [[]] #strStream-fix)
)
)
)
(xor
(call %init_peer_id% ("callbackSrv" "response") [[] [] [] $strEmptyStream [] [] []])
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1])
)
)
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 2])
)
`
return callFunction(
args,
{
"functionName" : "emptySugar",
"arrow" : {
"tag" : "arrow",
"domain" : {
"tag" : "labeledProduct",
"fields" : {
}
},
"codomain" : {
"tag" : "unlabeledProduct",
"items" : [
{
"tag" : "array",
"type" : {
"tag" : "scalar",
"name" : "u32"
}
},
{
"tag" : "array",
"type" : {
"tag" : "scalar",
"name" : "string"
}
},
{
"tag" : "array",
"type" : {
"tag" : "scalar",
"name" : "string"
}
},
{
"tag" : "array",
"type" : {
"tag" : "scalar",
"name" : "string"
}
},
{
"tag" : "option",
"type" : {
"tag" : "scalar",
"name" : "u32"
}
},
{
"tag" : "array",
"type" : {
"tag" : "scalar",
"name" : "u32"
}
},
{
"tag" : "option",
"type" : {
"tag" : "scalar",
"name" : "string"
}
}
]
}
},
"names" : {
"relay" : "-relay-",
"getDataSrv" : "getDataSrv",
"callbackSrv" : "callbackSrv",
"responseSrv" : "callbackSrv",
"responseFnName" : "response",
"errorHandlingSrv" : "errorHandlingSrv",
"errorFnName" : "error"
}
},
script
)
}
export function getNeighbours( export function getNeighbours(
config?: {ttl?: number} config?: {ttl?: number}
@ -668,7 +556,8 @@ export function bugLNG59(...args: any) {
(call -via-peer- ("op" "noop") []) (call -via-peer- ("op" "noop") [])
(next -via-peer-) (next -via-peer-)
) )
)
)
) )
(xor (xor
(seq (seq
@ -679,7 +568,8 @@ export function bugLNG59(...args: any) {
(next -via-peer-) (next -via-peer-)
(call -via-peer- ("op" "noop") []) (call -via-peer- ("op" "noop") [])
) )
)
)
) )
(call -relay- ("op" "noop") []) (call -relay- ("op" "noop") [])
) )
@ -690,7 +580,8 @@ export function bugLNG59(...args: any) {
(call -via-peer- ("op" "noop") []) (call -via-peer- ("op" "noop") [])
(next -via-peer-) (next -via-peer-)
) )
)
)
(call -relay- ("op" "noop") []) (call -relay- ("op" "noop") [])
) )
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1]) (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1])
@ -803,7 +694,9 @@ export function arraySugar(...args: any) {
(ap i-0 $str) (ap i-0 $str)
(next i-0) (next i-0)
) )
) (null)
)
) )
(canon %init_peer_id% $str #str-fix) (canon %init_peer_id% $str #str-fix)
) )

14
src/compiled/examples/complex.ts
View File

@ -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.7.4-336 * Aqua version: 0.7.6-SNAPSHOT
* *
*/ */
import { Fluence, FluencePeer } from '@fluencelabs/fluence'; import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@ -193,12 +193,16 @@ export function doStuff(...args: any) {
) )
(next gEl-0) (next gEl-0)
) )
) (null)
)
(call b ("some-id" "t") [eEl-0] $stream) (call b ("some-id" "t") [eEl-0] $stream)
) )
(next eEl-0) (next eEl-0)
) )
) (null)
)
(call -relay- ("op" "noop") []) (call -relay- ("op" "noop") [])
) )
(seq (seq
@ -233,12 +237,12 @@ export function doStuff(...args: any) {
) )
(call %init_peer_id% ("some-id" "multiline") [a b c] $stream) (call %init_peer_id% ("some-id" "multiline") [a b c] $stream)
) )
(call %init_peer_id% ("op" "identity") [$stream] stream-fix) (canon %init_peer_id% $stream #stream-fix)
) )
) )
) )
(xor (xor
(call %init_peer_id% ("callbackSrv" "response") [stream-fix]) (call %init_peer_id% ("callbackSrv" "response") [#stream-fix])
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 6]) (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 6])
) )
) )

6
src/compiled/examples/constants.ts
View File

@ -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.7.4-336 * Aqua version: 0.7.6-SNAPSHOT
* *
*/ */
import { Fluence, FluencePeer } from '@fluencelabs/fluence'; import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@ -237,12 +237,12 @@ export function callConstant(...args: any) {
(call %init_peer_id% ("test" "createStr") [5] $res) (call %init_peer_id% ("test" "createStr") [5] $res)
(call %init_peer_id% ("op" "identity") ["default-str"] $res) (call %init_peer_id% ("op" "identity") ["default-str"] $res)
) )
(call %init_peer_id% ("op" "identity") [$res] res-fix) (canon %init_peer_id% $res #res-fix)
) )
) )
) )
(xor (xor
(call %init_peer_id% ("callbackSrv" "response") [res-fix]) (call %init_peer_id% ("callbackSrv" "response") [#res-fix])
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1]) (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1])
) )
) )

2
src/compiled/examples/dataAlias.ts
View File

@ -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.7.4-336 * Aqua version: 0.7.6-SNAPSHOT
* *
*/ */
import { Fluence, FluencePeer } from '@fluencelabs/fluence'; import { Fluence, FluencePeer } from '@fluencelabs/fluence';

2
src/compiled/examples/example.ts
View File

@ -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.7.4-336 * Aqua version: 0.7.6-SNAPSHOT
* *
*/ */
import { Fluence, FluencePeer } from '@fluencelabs/fluence'; import { Fluence, FluencePeer } from '@fluencelabs/fluence';

39
src/compiled/examples/fold.ts
View File

@ -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.7.4-336 * Aqua version: 0.7.6-SNAPSHOT
* *
*/ */
import { Fluence, FluencePeer } from '@fluencelabs/fluence'; import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@ -44,7 +44,9 @@ export function iterateAndPrint(...args: any) {
(call %init_peer_id% ("println-service-id" "print") [s-0]) (call %init_peer_id% ("println-service-id" "print") [s-0])
(next s-0) (next s-0)
) )
) (null)
)
) )
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1]) (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1])
) )
@ -111,7 +113,7 @@ export function iterateAndPrintParallel(...args: any) {
) )
(par (par
(fold nodes s-0 (fold nodes s-0
(par (seq
(seq (seq
(call -relay- ("op" "noop") []) (call -relay- ("op" "noop") [])
(xor (xor
@ -121,25 +123,18 @@ export function iterateAndPrintParallel(...args: any) {
(call -relay- ("op" "noop") []) (call -relay- ("op" "noop") [])
) )
(xor (xor
(seq (call %init_peer_id% ("callbackSrv" "c") [ads])
(call %init_peer_id% ("callbackSrv" "c") [ads]) (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1])
(call -relay- ("op" "noop") [])
)
(seq
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1])
(call -relay- ("op" "noop") [])
)
) )
) )
(seq (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 2])
(call -relay- ("op" "noop") [])
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 2])
)
) )
) )
(next s-0) (next s-0)
) )
) (null)
)
(null) (null)
) )
) )
@ -307,22 +302,24 @@ export function forBug499(...args: any) {
(new $array-inline (new $array-inline
(seq (seq
(ap "" $array-inline) (ap "" $array-inline)
(call %init_peer_id% ("op" "identity") [$array-inline] array-inline-0) (canon %init_peer_id% $array-inline #array-inline-0)
) )
) )
(fold array-inline-0 i-0 (fold #array-inline-0 i-0
(seq (seq
(ap 5 $numbers) (ap 5 $numbers)
(next i-0) (next i-0)
) )
) (null)
)
) )
(call %init_peer_id% ("op" "identity") [$numbers] numbers-fix) (canon %init_peer_id% $numbers #numbers-fix)
) )
) )
) )
(xor (xor
(call %init_peer_id% ("callbackSrv" "response") [numbers-fix]) (call %init_peer_id% ("callbackSrv" "response") [#numbers-fix])
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1]) (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1])
) )
) )

124
src/compiled/examples/foldJoin.ts
View File

@ -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.7.4-336 * Aqua version: 0.7.6-SNAPSHOT
* *
*/ */
import { Fluence, FluencePeer } from '@fluencelabs/fluence'; import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@ -50,34 +50,114 @@ export function getTwoResults(...args: any) {
(seq (seq
(seq (seq
(seq (seq
(call node ("kad" "neighborhood") [%init_peer_id% [] []] nodes) (seq
(par (seq
(fold nodes n-0 (seq
(par (call node ("kad" "neighborhood") [%init_peer_id% [] []] nodes)
(seq (par
(xor (fold nodes n-0
(xor
(call n-0 ("peer" "timestamp_sec") [] $res)
(call n-0 ("op" "noop") [])
)
(seq (seq
(call -relay- ("op" "noop") []) (xor
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1]) (xor
(call n-0 ("peer" "timestamp_sec") [] $res)
(call n-0 ("op" "noop") [])
)
(seq
(seq
(call -relay- ("op" "noop") [])
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1])
)
(call -relay- ("op" "noop") [])
)
)
(next n-0)
) )
) (null)
(call node ("op" "noop") [])
)
(null)
)
)
(new $res_test
(seq
(fold $res s
(seq
(seq
(seq
(call node ("math" "add") [0 1] incr_idx)
(ap s $res_test)
)
(canon node $res_test #res_iter_canon)
)
(xor
(match #res_iter_canon.length incr_idx
(null)
)
(next s)
)
)
(never)
)
(canon node $res_test #res_result_canon)
) )
(next n-0)
) )
) )
(null) (call node ("op" "identity") [#res_result_canon.$.[0]!])
)
(new $res_test-0
(seq
(fold $res s
(seq
(seq
(seq
(call node ("math" "add") [1 1] incr_idx)
(ap s $res_test-0)
)
(canon node $res_test-0 #res_iter_canon)
)
(xor
(match #res_iter_canon.length incr_idx
(null)
)
(next s)
)
)
(never)
)
(canon node $res_test-0 #res_result_canon-0)
)
) )
) )
(call node ("op" "identity") [$res.$.[0]!]) (call node ("op" "identity") [#res_result_canon-0.$.[1]!])
)
(new $res_test-1
(seq
(fold $res s
(seq
(seq
(seq
(call node ("math" "add") [2 1] incr_idx)
(ap s $res_test-1)
)
(canon node $res_test-1 #res_iter_canon)
)
(xor
(match #res_iter_canon.length incr_idx
(null)
)
(next s)
)
)
(never)
)
(canon node $res_test-1 #res_result_canon-1)
)
) )
(call node ("op" "identity") [$res.$.[1]!])
) )
(call node ("op" "identity") [$res.$.[2]!]) (call node ("op" "identity") [#res_result_canon-1.$.[2]!])
) )
(call -relay- ("op" "noop") []) (call -relay- ("op" "noop") [])
) )
@ -87,12 +167,12 @@ export function getTwoResults(...args: any) {
) )
) )
) )
(call %init_peer_id% ("op" "identity") [$res] res-fix) (canon %init_peer_id% $res #res-fix)
) )
) )
) )
(xor (xor
(call %init_peer_id% ("callbackSrv" "response") [res-fix]) (call %init_peer_id% ("callbackSrv" "response") [#res-fix])
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 3]) (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 3])
) )
) )

2
src/compiled/examples/func.ts
View File

@ -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.7.4-336 * Aqua version: 0.7.6-SNAPSHOT
* *
*/ */
import { Fluence, FluencePeer } from '@fluencelabs/fluence'; import { Fluence, FluencePeer } from '@fluencelabs/fluence';

34
src/compiled/examples/funcs.ts
View File

@ -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.7.4-336 * Aqua version: 0.7.6-SNAPSHOT
* *
*/ */
import { Fluence, FluencePeer } from '@fluencelabs/fluence'; import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@ -151,7 +151,7 @@ export function main(...args: any) {
) )
(ap 19 $array-inline) (ap 19 $array-inline)
) )
(call %init_peer_id% ("op" "identity") [$array-inline] array-inline-0) (canon %init_peer_id% $array-inline #array-inline-0)
) )
) )
) )
@ -159,7 +159,7 @@ export function main(...args: any) {
) )
(call %init_peer_id% ("math" "add") [getJ 2] add) (call %init_peer_id% ("math" "add") [getJ 2] add)
) )
(call %init_peer_id% ("a" "getJ") [array-inline-0.$.[add]!] idx1) (call %init_peer_id% ("a" "getJ") [#array-inline-0.$.[add]!] idx1)
) )
(par (par
(seq (seq
@ -172,7 +172,7 @@ export function main(...args: any) {
) )
) )
) )
(call %init_peer_id% ("math" "add") [array-inline-0.$.[add-1]! array-inline-0.$.[sub-0]!] add-0) (call %init_peer_id% ("math" "add") [#array-inline-0.$.[add-1]! #array-inline-0.$.[sub-0]!] add-0)
) )
(call %init_peer_id% ("math" "sub") [add-0 3] sub) (call %init_peer_id% ("math" "sub") [add-0 3] sub)
) )
@ -182,16 +182,16 @@ export function main(...args: any) {
(seq (seq
(par (par
(call %init_peer_id% ("math" "add") [idx1 idx2] add-4) (call %init_peer_id% ("math" "add") [idx1 idx2] add-4)
(call %init_peer_id% ("a" "getJ") [array-inline-0.$.[2]!] some) (call %init_peer_id% ("a" "getJ") [#array-inline-0.$.[2]!] some)
) )
(call %init_peer_id% ("math" "add") [add-4 some] add-3) (call %init_peer_id% ("math" "add") [add-4 some] add-3)
) )
(call %init_peer_id% ("a" "getJ") [array-inline-0.$.[3]!] some-0) (call %init_peer_id% ("a" "getJ") [#array-inline-0.$.[3]!] some-0)
) )
) )
(call %init_peer_id% ("math" "add") [add-3 some-0] add-2) (call %init_peer_id% ("math" "add") [add-3 some-0] add-2)
) )
(call %init_peer_id% ("a" "getJ") [array-inline-0.$.[add-2]!] getJ-2) (call %init_peer_id% ("a" "getJ") [#array-inline-0.$.[add-2]!] getJ-2)
) )
(xor (xor
(call %init_peer_id% ("callbackSrv" "response") [getJ-2]) (call %init_peer_id% ("callbackSrv" "response") [getJ-2])
@ -344,7 +344,7 @@ export function calc2(...args: any) {
) )
(ap 19 $array-inline) (ap 19 $array-inline)
) )
(call %init_peer_id% ("op" "identity") [$array-inline] array-inline-0) (canon %init_peer_id% $array-inline #array-inline-0)
) )
) )
) )
@ -388,7 +388,7 @@ export function calc2(...args: any) {
(call %init_peer_id% ("math" "sub") [sub-4 3] sub-3) (call %init_peer_id% ("math" "sub") [sub-4 3] sub-3)
) )
(xor (xor
(call %init_peer_id% ("callbackSrv" "response") [array-inline-0.$.[sub-3]!]) (call %init_peer_id% ("callbackSrv" "response") [#array-inline-0.$.[sub-3]!])
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1]) (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1])
) )
) )
@ -533,7 +533,7 @@ export function ifCalc(...args: any) {
) )
(ap 19 $array-inline) (ap 19 $array-inline)
) )
(call %init_peer_id% ("op" "identity") [$array-inline] array-inline-0) (canon %init_peer_id% $array-inline #array-inline-0)
) )
) )
(xor (xor
@ -561,7 +561,7 @@ export function ifCalc(...args: any) {
) )
(call %init_peer_id% ("math" "add") [sub-1 getJ-1] add-0) (call %init_peer_id% ("math" "add") [sub-1 getJ-1] add-0)
) )
(call %init_peer_id% ("math" "sub") [array-inline-0.$.[add-0]! 2] sub-0) (call %init_peer_id% ("math" "sub") [#array-inline-0.$.[add-0]! 2] sub-0)
) )
) )
(call %init_peer_id% ("cmp" "gt") [add sub-0] gt) (call %init_peer_id% ("cmp" "gt") [add sub-0] gt)
@ -573,12 +573,12 @@ export function ifCalc(...args: any) {
(ap 2 $res) (ap 2 $res)
) )
) )
(call %init_peer_id% ("op" "identity") [$res] res-fix) (canon %init_peer_id% $res #res-fix)
) )
) )
) )
(xor (xor
(call %init_peer_id% ("callbackSrv" "response") [res-fix.$.[0]!]) (call %init_peer_id% ("callbackSrv" "response") [#res-fix.$.[0]!])
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1]) (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1])
) )
) )
@ -707,7 +707,7 @@ export function calc(...args: any) {
) )
(ap 19 $array-inline) (ap 19 $array-inline)
) )
(call %init_peer_id% ("op" "identity") [$array-inline] array-inline-0) (canon %init_peer_id% $array-inline #array-inline-0)
) )
) )
) )
@ -722,17 +722,17 @@ export function calc(...args: any) {
(new $array-inline-1 (new $array-inline-1
(seq (seq
(ap num $array-inline-1) (ap num $array-inline-1)
(call %init_peer_id% ("op" "identity") [$array-inline-1] array-inline-1-0) (canon %init_peer_id% $array-inline-1 #array-inline-1-0)
) )
) )
) )
(xor (xor
(call %init_peer_id% ("callbackSrv" "log") ["calc 2" array-inline-1-0]) (call %init_peer_id% ("callbackSrv" "log") ["calc 2" #array-inline-1-0])
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1]) (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1])
) )
) )
(xor (xor
(call %init_peer_id% ("callbackSrv" "response") [array-inline-0.$.[num]!]) (call %init_peer_id% ("callbackSrv" "response") [#array-inline-0.$.[num]!])
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 2]) (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 2])
) )
) )

2
src/compiled/examples/helloWorld.ts
View File

@ -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.7.4-336 * Aqua version: 0.7.6-SNAPSHOT
* *
*/ */
import { Fluence, FluencePeer } from '@fluencelabs/fluence'; import { Fluence, FluencePeer } from '@fluencelabs/fluence';

6
src/compiled/examples/if.ts
View File

@ -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.7.4-336 * Aqua version: 0.7.6-SNAPSHOT
* *
*/ */
import { Fluence, FluencePeer } from '@fluencelabs/fluence'; import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@ -107,12 +107,12 @@ export function ifCorrectXorWrap(...args: any) {
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1]) (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1])
) )
) )
(call %init_peer_id% ("op" "identity") [$service_id] service_id-fix) (canon %init_peer_id% $service_id #service_id-fix)
) )
) )
) )
(xor (xor
(call %init_peer_id% ("callbackSrv" "response") [service_id-fix.$.[0]!]) (call %init_peer_id% ("callbackSrv" "response") [#service_id-fix.$.[0]!])
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 2]) (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 2])
) )
) )

2
src/compiled/examples/imports_exports/declare.ts
View File

@ -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.7.4-336 * Aqua version: 0.7.6-SNAPSHOT
* *
*/ */
import { Fluence, FluencePeer } from '@fluencelabs/fluence'; import { Fluence, FluencePeer } from '@fluencelabs/fluence';

2
src/compiled/examples/imports_exports/exports.ts
View File

@ -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.7.4-336 * Aqua version: 0.7.6-SNAPSHOT
* *
*/ */
import { Fluence, FluencePeer } from '@fluencelabs/fluence'; import { Fluence, FluencePeer } from '@fluencelabs/fluence';

2
src/compiled/examples/imports_exports/gen/OneMore.ts
View File

@ -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.7.4-336 * Aqua version: 0.7.6-SNAPSHOT
* *
*/ */
import { Fluence, FluencePeer } from '@fluencelabs/fluence'; import { Fluence, FluencePeer } from '@fluencelabs/fluence';

6
src/compiled/examples/imports_exports/import2.ts
View File

@ -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.7.4-336 * Aqua version: 0.7.6-SNAPSHOT
* *
*/ */
import { Fluence, FluencePeer } from '@fluencelabs/fluence'; import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@ -41,12 +41,12 @@ export function barfoo(...args: any) {
(ap "I am MyFooBar foo" $res) (ap "I am MyFooBar foo" $res)
(ap " I am MyFooBar bar" $res) (ap " I am MyFooBar bar" $res)
) )
(call %init_peer_id% ("op" "identity") [$res] res-fix) (canon %init_peer_id% $res #res-fix)
) )
) )
) )
(xor (xor
(call %init_peer_id% ("callbackSrv" "response") [res-fix]) (call %init_peer_id% ("callbackSrv" "response") [#res-fix])
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1]) (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1])
) )
) )

2
src/compiled/examples/imports_exports/import3.ts
View File

@ -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.7.4-336 * Aqua version: 0.7.6-SNAPSHOT
* *
*/ */
import { Fluence, FluencePeer } from '@fluencelabs/fluence'; import { Fluence, FluencePeer } from '@fluencelabs/fluence';

2
src/compiled/examples/imports_exports/imports.ts
View File

@ -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.7.4-336 * Aqua version: 0.7.6-SNAPSHOT
* *
*/ */
import { Fluence, FluencePeer } from '@fluencelabs/fluence'; import { Fluence, FluencePeer } from '@fluencelabs/fluence';

2
src/compiled/examples/imports_exports/subImport.ts
View File

@ -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.7.4-336 * Aqua version: 0.7.6-SNAPSHOT
* *
*/ */
import { Fluence, FluencePeer } from '@fluencelabs/fluence'; import { Fluence, FluencePeer } from '@fluencelabs/fluence';

156
src/compiled/examples/join.ts
View File

@ -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.7.4-336 * Aqua version: 0.7.6-SNAPSHOT
* *
*/ */
import { Fluence, FluencePeer } from '@fluencelabs/fluence'; import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@ -50,21 +50,46 @@ export function joinIdxLocal(...args: any) {
(seq (seq
(par (par
(fold nodes node-0 (fold nodes node-0
(par (seq
(ap node-0 $nodes2) (ap node-0 $nodes2)
(next node-0) (next node-0)
) )
) (null)
)
(null) (null)
) )
(call %init_peer_id% ("op" "noop") [$nodes2.$.[idx]! nodes]) (new $nodes2_test
(seq
(fold $nodes2 s
(seq
(seq
(seq
(call %init_peer_id% ("math" "add") [idx 1] incr_idx)
(ap s $nodes2_test)
)
(canon %init_peer_id% $nodes2_test #nodes2_iter_canon)
)
(xor
(match #nodes2_iter_canon.length incr_idx
(null)
)
(next s)
)
)
(never)
)
(canon %init_peer_id% $nodes2_test #nodes2_result_canon)
)
)
) )
(call %init_peer_id% ("op" "identity") [$nodes2] nodes2-fix) (canon %init_peer_id% $nodes2 #nodes2-fix)
) )
) )
) )
(xor (xor
(call %init_peer_id% ("callbackSrv" "response") [nodes2-fix]) (call %init_peer_id% ("callbackSrv" "response") [#nodes2-fix])
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1]) (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1])
) )
) )
@ -154,23 +179,48 @@ export function joinIdxRelay(...args: any) {
(seq (seq
(par (par
(fold nodes node-0 (fold nodes node-0
(par (seq
(ap node-0 $nodes2) (ap node-0 $nodes2)
(next node-0) (next node-0)
) )
) (null)
)
(null) (null)
) )
(call -relay- ("op" "noop") [$nodes2.$.[idx]! nodes]) (new $nodes2_test
(seq
(fold $nodes2 s
(seq
(seq
(seq
(call -relay- ("math" "add") [idx 1] incr_idx)
(ap s $nodes2_test)
)
(canon -relay- $nodes2_test #nodes2_iter_canon)
)
(xor
(match #nodes2_iter_canon.length incr_idx
(null)
)
(next s)
)
)
(never)
)
(canon -relay- $nodes2_test #nodes2_result_canon)
)
)
) )
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1]) (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1])
) )
(call %init_peer_id% ("op" "identity") [$nodes2] nodes2-fix) (canon %init_peer_id% $nodes2 #nodes2-fix)
) )
) )
) )
(xor (xor
(call %init_peer_id% ("callbackSrv" "response") [nodes2-fix]) (call %init_peer_id% ("callbackSrv" "response") [#nodes2-fix])
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 2]) (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 2])
) )
) )
@ -260,40 +310,88 @@ export function joinIdx(...args: any) {
(seq (seq
(par (par
(fold nodes node-0 (fold nodes node-0
(par (seq
(seq (seq
(seq (call -relay- ("op" "noop") [])
(xor
(seq
(seq
(call node-0 ("peer" "identify") [] $infos)
(ap node-0 $nodes2)
)
(call -relay- ("op" "noop") [])
)
(seq (seq
(call -relay- ("op" "noop") []) (call -relay- ("op" "noop") [])
(xor (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1])
(seq
(call node-0 ("peer" "identify") [] $infos)
(ap node-0 $nodes2)
)
(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 node-0) (next node-0)
) )
) (null)
)
(null) (null)
) )
(call %init_peer_id% ("op" "noop") [$infos.$.[idx]! $nodes2.$.[idx]!]) (par
(new $infos_test
(seq
(fold $infos s
(seq
(seq
(seq
(call %init_peer_id% ("math" "add") [idx 1] incr_idx)
(ap s $infos_test)
)
(canon %init_peer_id% $infos_test #infos_iter_canon)
)
(xor
(match #infos_iter_canon.length incr_idx
(null)
)
(next s)
)
)
(never)
)
(canon %init_peer_id% $infos_test #infos_result_canon)
)
)
(new $nodes2_test
(seq
(fold $nodes2 s
(seq
(seq
(seq
(call %init_peer_id% ("math" "add") [idx 1] incr_idx)
(ap s $nodes2_test)
)
(canon %init_peer_id% $nodes2_test #nodes2_iter_canon)
)
(xor
(match #nodes2_iter_canon.length incr_idx
(null)
)
(next s)
)
)
(never)
)
(canon %init_peer_id% $nodes2_test #nodes2_result_canon)
)
)
)
) )
(call %init_peer_id% ("op" "identity") [$infos] infos-fix) (canon %init_peer_id% $infos #infos-fix)
) )
) )
) )
) )
(xor (xor
(call %init_peer_id% ("callbackSrv" "response") [infos-fix]) (call %init_peer_id% ("callbackSrv" "response") [#infos-fix])
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 2]) (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 2])
) )
) )

2
src/compiled/examples/math.ts
View File

@ -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.7.4-336 * Aqua version: 0.7.6-SNAPSHOT
* *
*/ */
import { Fluence, FluencePeer } from '@fluencelabs/fluence'; import { Fluence, FluencePeer } from '@fluencelabs/fluence';

6
src/compiled/examples/multiReturn.ts
View File

@ -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.7.4-336 * Aqua version: 0.7.6-SNAPSHOT
* *
*/ */
import { Fluence, FluencePeer } from '@fluencelabs/fluence'; import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@ -144,12 +144,12 @@ export function multiReturnFunc(...args: any) {
) )
(ap str $res) (ap str $res)
) )
(call %init_peer_id% ("op" "identity") [$res] res-fix) (canon %init_peer_id% $res #res-fix)
) )
) )
) )
(xor (xor
(call %init_peer_id% ("callbackSrv" "response") [res-fix 5 "some-str" somethingToReturn smthOption n]) (call %init_peer_id% ("callbackSrv" "response") [#res-fix 5 "some-str" somethingToReturn smthOption n])
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1]) (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1])
) )
) )

2
src/compiled/examples/nestedData.ts
View File

@ -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.7.4-336 * Aqua version: 0.7.6-SNAPSHOT
* *
*/ */
import { Fluence, FluencePeer } from '@fluencelabs/fluence'; import { Fluence, FluencePeer } from '@fluencelabs/fluence';

2
src/compiled/examples/nestedFuncs.ts
View File

@ -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.7.4-336 * Aqua version: 0.7.6-SNAPSHOT
* *
*/ */
import { Fluence, FluencePeer } from '@fluencelabs/fluence'; import { Fluence, FluencePeer } from '@fluencelabs/fluence';

2
src/compiled/examples/on.ts
View File

@ -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.7.4-336 * Aqua version: 0.7.6-SNAPSHOT
* *
*/ */
import { Fluence, FluencePeer } from '@fluencelabs/fluence'; import { Fluence, FluencePeer } from '@fluencelabs/fluence';

10
src/compiled/examples/option.ts
View File

@ -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.7.4-336 * Aqua version: 0.7.6-SNAPSHOT
* *
*/ */
import { Fluence, FluencePeer } from '@fluencelabs/fluence'; import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@ -148,12 +148,12 @@ export function returnNone(...args: any) {
(new $result (new $result
(seq (seq
(call %init_peer_id% ("op" "noop") []) (call %init_peer_id% ("op" "noop") [])
(call %init_peer_id% ("op" "identity") [$result] result-fix) (canon %init_peer_id% $result #result-fix)
) )
) )
) )
(xor (xor
(call %init_peer_id% ("callbackSrv" "response") [result-fix]) (call %init_peer_id% ("callbackSrv" "response") [#result-fix])
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1]) (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1])
) )
) )
@ -293,7 +293,9 @@ export function useOptional(...args: any) {
(call %init_peer_id% ("test2" "getStr2") [i-0]) (call %init_peer_id% ("test2" "getStr2") [i-0])
(next i-0) (next i-0)
) )
) (null)
)
) )
(xor (xor
(call %init_peer_id% ("callbackSrv" "response") [res.$.[0]!]) (call %init_peer_id% ("callbackSrv" "response") [res.$.[0]!])

18
src/compiled/examples/options/option_gen.ts
View File

@ -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.7.4-336 * Aqua version: 0.7.6-SNAPSHOT
* *
*/ */
import { Fluence, FluencePeer } from '@fluencelabs/fluence'; import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@ -84,10 +84,10 @@ export function checkEmpty(...args: any) {
(seq (seq
(call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-) (call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-)
(new $valueEmpty (new $valueEmpty
(call %init_peer_id% ("op" "identity") [$valueEmpty] valueEmpty-fix) (canon %init_peer_id% $valueEmpty #valueEmpty-fix)
) )
) )
(call %init_peer_id% ("opt_str" "checkOption") [valueEmpty-fix] res) (call %init_peer_id% ("opt_str" "checkOption") [#valueEmpty-fix] res)
) )
(xor (xor
(call %init_peer_id% ("callbackSrv" "response") [res]) (call %init_peer_id% ("callbackSrv" "response") [res])
@ -152,11 +152,11 @@ export function emptyString(...args: any) {
(seq (seq
(call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-) (call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-)
(new $valueEmpty (new $valueEmpty
(call %init_peer_id% ("op" "identity") [$valueEmpty] valueEmpty-fix) (canon %init_peer_id% $valueEmpty #valueEmpty-fix)
) )
) )
(xor (xor
(call %init_peer_id% ("callbackSrv" "response") [valueEmpty-fix]) (call %init_peer_id% ("callbackSrv" "response") [#valueEmpty-fix])
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1]) (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1])
) )
) )
@ -229,11 +229,11 @@ export function checkNoneEmpty(...args: any) {
(new $valueEmpty (new $valueEmpty
(seq (seq
(ap str $valueEmpty) (ap str $valueEmpty)
(call %init_peer_id% ("op" "identity") [$valueEmpty] valueEmpty-fix) (canon %init_peer_id% $valueEmpty #valueEmpty-fix)
) )
) )
) )
(call %init_peer_id% ("opt_str" "checkOption") [valueEmpty-fix] res) (call %init_peer_id% ("opt_str" "checkOption") [#valueEmpty-fix] res)
) )
(xor (xor
(call %init_peer_id% ("callbackSrv" "response") [res]) (call %init_peer_id% ("callbackSrv" "response") [res])
@ -308,12 +308,12 @@ export function stringAsOption(...args: any) {
(new $valueEmpty (new $valueEmpty
(seq (seq
(ap str $valueEmpty) (ap str $valueEmpty)
(call %init_peer_id% ("op" "identity") [$valueEmpty] valueEmpty-fix) (canon %init_peer_id% $valueEmpty #valueEmpty-fix)
) )
) )
) )
(xor (xor
(call %init_peer_id% ("callbackSrv" "response") [valueEmpty-fix]) (call %init_peer_id% ("callbackSrv" "response") [#valueEmpty-fix])
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1]) (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1])
) )
) )

81
src/compiled/examples/par.ts
View File

@ -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.7.4-336 * Aqua version: 0.7.6-SNAPSHOT
* *
*/ */
import { Fluence, FluencePeer } from '@fluencelabs/fluence'; import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@ -212,9 +212,9 @@ export function testTimeout(...args: any) {
(call -relay- ("op" "noop") []) (call -relay- ("op" "noop") [])
(xor (xor
(par (par
(fold nodes node-0 (seq
(par (seq
(seq (fold nodes node-0
(seq (seq
(xor (xor
(call node-0 ("peer" "identify") [] $results) (call node-0 ("peer" "identify") [] $results)
@ -223,12 +223,14 @@ export function testTimeout(...args: any) {
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1]) (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1])
) )
) )
(call -relay- ("op" "noop") []) (next node-0)
) )
(call %init_peer_id% ("op" "noop") []) (null)
)
(next node-0) )
(call -relay- ("op" "noop") [])
) )
(call %init_peer_id% ("op" "noop") [])
) )
(null) (null)
) )
@ -236,28 +238,77 @@ export function testTimeout(...args: any) {
) )
) )
(par (par
(call %init_peer_id% ("op" "noop") [$results.$.[999]!]) (new $results_test
(seq
(fold $results s
(seq
(seq
(seq
(call %init_peer_id% ("math" "add") [999 1] incr_idx)
(ap s $results_test)
)
(canon %init_peer_id% $results_test #results_iter_canon)
)
(xor
(match #results_iter_canon.length incr_idx
(null)
)
(next s)
)
)
(never)
)
(canon %init_peer_id% $results_test #results_result_canon)
)
)
(call %init_peer_id% ("peer" "timeout") [400 "timeout"] $timeout) (call %init_peer_id% ("peer" "timeout") [400 "timeout"] $timeout)
) )
) )
(xor (xor
(match $timeout [] (seq
(ap "ok" $status) (canon %init_peer_id% $timeout #timeout_canon)
(match #timeout_canon []
(ap "ok" $status)
)
) )
(seq (seq
(call %init_peer_id% ("op" "identity") [$timeout.$.[0]!] push-to-stream-33) (new $timeout_test
(ap push-to-stream-33 $status) (seq
(fold $timeout s
(seq
(seq
(seq
(call %init_peer_id% ("math" "add") [0 1] incr_idx)
(ap s $timeout_test)
)
(canon %init_peer_id% $timeout_test #timeout_iter_canon)
)
(xor
(match #timeout_iter_canon.length incr_idx
(null)
)
(next s)
)
)
(never)
)
(canon %init_peer_id% $timeout_test #timeout_result_canon)
)
)
(ap #timeout_result_canon.$.[0]! $status)
) )
) )
) )
) )
) )
(call %init_peer_id% ("op" "identity") [$status] status-fix) (canon %init_peer_id% $status #status-fix)
) )
) )
) )
(xor (xor
(call %init_peer_id% ("callbackSrv" "response") [status-fix.$.[0]!]) (call %init_peer_id% ("callbackSrv" "response") [#status-fix.$.[0]!])
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 3]) (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 3])
) )
) )

109
src/compiled/examples/passArgs.ts
View File

@ -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.7.4-336 * Aqua version: 0.7.6-SNAPSHOT
* *
*/ */
import { Fluence, FluencePeer } from '@fluencelabs/fluence'; import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@ -95,22 +95,47 @@ export function wait(...args: any) {
(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" "successful") [] successful-iter)
(call %init_peer_id% ("getDataSrv" "successful") [] successful-iter) )
) (fold successful-iter successful-item-0
(fold successful-iter successful-item-0 (seq
(seq (ap successful-item-0 $successful)
(ap successful-item-0 $successful) (next successful-item-0)
(next successful-item-0) )
) (null)
)
)
)
(call %init_peer_id% ("getDataSrv" "n") [] n)
)
(par
(call %init_peer_id% ("math" "sub") [n 1] sub)
(new $successful_test
(seq
(fold $successful s
(seq
(seq
(seq
(call %init_peer_id% ("math" "add") [sub 1] incr_idx)
(ap s $successful_test)
)
(canon %init_peer_id% $successful_test #successful_iter_canon)
)
(xor
(match #successful_iter_canon.length incr_idx
(null)
)
(next s)
)
)
(never)
)
(canon %init_peer_id% $successful_test #successful_result_canon)
) )
(call %init_peer_id% ("getDataSrv" "n") [] n)
) )
(call %init_peer_id% ("math" "sub") [n 1] sub)
) )
(call %init_peer_id% ("op" "noop") [$successful.$.[sub]!])
) )
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1]) (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1])
) )
@ -181,23 +206,51 @@ export function bugLNG60(...args: any) {
(new $successful (new $successful
(seq (seq
(seq (seq
(seq (new $array-inline
(new $array-inline (seq
(seq (ap node $array-inline)
(ap node $array-inline) (canon %init_peer_id% $array-inline #array-inline-0)
(call %init_peer_id% ("op" "identity") [$array-inline] array-inline-0) )
) )
) (fold #array-inline-0 n-0
(fold array-inline-0 n-0 (seq
(seq (ap true $successful)
(ap true $successful) (next n-0)
(next n-0) )
) (null)
)
)
(par
(seq
(call %init_peer_id% ("math" "sub") [1 1] sub)
(call %init_peer_id% ("op" "noop") [])
)
(new $successful_test
(seq
(fold $successful s
(seq
(seq
(seq
(call %init_peer_id% ("math" "add") [sub 1] incr_idx)
(ap s $successful_test)
)
(canon %init_peer_id% $successful_test #successful_iter_canon)
)
(xor
(match #successful_iter_canon.length incr_idx
(null)
)
(next s)
)
)
(never)
)
(canon %init_peer_id% $successful_test #successful_result_canon)
) )
) )
(call %init_peer_id% ("math" "sub") [1 1] sub)
) )
(call %init_peer_id% ("op" "noop") [$successful.$.[sub]!])
) )
) )
) )

2
src/compiled/examples/println.ts
View File

@ -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.7.4-336 * Aqua version: 0.7.6-SNAPSHOT
* *
*/ */
import { Fluence, FluencePeer } from '@fluencelabs/fluence'; import { Fluence, FluencePeer } from '@fluencelabs/fluence';

6
src/compiled/examples/pushToStream.ts
View File

@ -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.7.4-336 * Aqua version: 0.7.6-SNAPSHOT
* *
*/ */
import { Fluence, FluencePeer } from '@fluencelabs/fluence'; import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@ -82,12 +82,12 @@ export function get_results(...args: any) {
) )
(ap str $results) (ap str $results)
) )
(call %init_peer_id% ("op" "identity") [$results] results-fix) (canon %init_peer_id% $results #results-fix)
) )
) )
) )
(xor (xor
(call %init_peer_id% ("callbackSrv" "response") [results-fix]) (call %init_peer_id% ("callbackSrv" "response") [#results-fix])
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1]) (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1])
) )
) )

19
src/compiled/examples/recursiveStreams.ts
View File

@ -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.7.4-336 * Aqua version: 0.7.6-SNAPSHOT
* *
*/ */
import { Fluence, FluencePeer } from '@fluencelabs/fluence'; import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@ -78,8 +78,11 @@ export function recursiveStream(...args: any) {
(new $result (new $result
(seq (seq
(seq (seq
(ap "yes" $loop) (seq
(fold $loop l-0 (ap "yes" $loop)
(canon %init_peer_id% $loop #loop_canon)
)
(fold #loop_canon l-0
(seq (seq
(seq (seq
(xor (xor
@ -95,17 +98,19 @@ export function recursiveStream(...args: any) {
) )
(next l-0) (next l-0)
) )
) (null)
)
) )
(call %init_peer_id% ("op" "identity") [$result] result-fix) (canon %init_peer_id% $result #result-fix)
) )
) )
(call %init_peer_id% ("op" "identity") [$loop] loop-fix) (canon %init_peer_id% $loop #loop-fix)
) )
) )
) )
(xor (xor
(call %init_peer_id% ("callbackSrv" "response") [result-fix loop-fix]) (call %init_peer_id% ("callbackSrv" "response") [#result-fix #loop-fix])
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 2]) (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 2])
) )
) )

2
src/compiled/examples/returnLiteral.ts
View File

@ -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.7.4-336 * Aqua version: 0.7.6-SNAPSHOT
* *
*/ */
import { Fluence, FluencePeer } from '@fluencelabs/fluence'; import { Fluence, FluencePeer } from '@fluencelabs/fluence';

22
src/compiled/examples/stream.ts
View File

@ -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.7.4-336 * Aqua version: 0.7.6-SNAPSHOT
* *
*/ */
import { Fluence, FluencePeer } from '@fluencelabs/fluence'; import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@ -80,11 +80,11 @@ export function returnNone(...args: any) {
(seq (seq
(call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-) (call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-)
(new $valueNone (new $valueNone
(call %init_peer_id% ("op" "identity") [$valueNone] valueNone-fix) (canon %init_peer_id% $valueNone #valueNone-fix)
) )
) )
(xor (xor
(call %init_peer_id% ("callbackSrv" "response") [valueNone-fix]) (call %init_peer_id% ("callbackSrv" "response") [#valueNone-fix])
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1]) (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1])
) )
) )
@ -149,11 +149,11 @@ export function stringNone(...args: any) {
(seq (seq
(call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-) (call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-)
(new $valueNone (new $valueNone
(call %init_peer_id% ("op" "identity") [$valueNone] valueNone-fix) (canon %init_peer_id% $valueNone #valueNone-fix)
) )
) )
(xor (xor
(call %init_peer_id% ("callbackSrv" "response") [valueNone-fix]) (call %init_peer_id% ("callbackSrv" "response") [#valueNone-fix])
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1]) (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1])
) )
) )
@ -218,9 +218,9 @@ export function returnNil(...args: any) {
(seq (seq
(seq (seq
(call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-) (call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-)
(call %init_peer_id% ("op" "identity") [$valueNil] push-to-stream-7) (canon %init_peer_id% $valueNil #push-to-stream-7)
) )
(ap push-to-stream-7 $relayNil) (ap #push-to-stream-7 $relayNil)
) )
(xor (xor
(call %init_peer_id% ("callbackSrv" "response") [$relayNil]) (call %init_peer_id% ("callbackSrv" "response") [$relayNil])
@ -368,14 +368,16 @@ export function checkStreams(...args: any) {
(call %init_peer_id% ("stringer-id" "returnString") [b-0] $stream) (call %init_peer_id% ("stringer-id" "returnString") [b-0] $stream)
(next b-0) (next b-0)
) )
) (null)
)
) )
(call %init_peer_id% ("op" "identity") [$stream] stream-fix) (canon %init_peer_id% $stream #stream-fix)
) )
) )
) )
(xor (xor
(call %init_peer_id% ("callbackSrv" "response") [stream-fix]) (call %init_peer_id% ("callbackSrv" "response") [#stream-fix])
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1]) (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1])
) )
) )

10
src/compiled/examples/streamArgs.ts
View File

@ -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.7.4-336 * Aqua version: 0.7.6-SNAPSHOT
* *
*/ */
import { Fluence, FluencePeer } from '@fluencelabs/fluence'; import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@ -97,7 +97,9 @@ export function append_records(...args: any) {
(ap srum-item-0 $srum) (ap srum-item-0 $srum)
(next srum-item-0) (next srum-item-0)
) )
) (null)
)
) )
(call %init_peer_id% ("test-service" "get_records") [peer] $srum) (call %init_peer_id% ("test-service" "get_records") [peer] $srum)
) )
@ -173,12 +175,12 @@ export function retrieve_records(...args: any) {
(new $records (new $records
(seq (seq
(call %init_peer_id% ("test-service" "get_records") [peer] $records) (call %init_peer_id% ("test-service" "get_records") [peer] $records)
(call %init_peer_id% ("op" "identity") [$records] records-fix) (canon %init_peer_id% $records #records-fix)
) )
) )
) )
(xor (xor
(call %init_peer_id% ("callbackSrv" "response") [records-fix]) (call %init_peer_id% ("callbackSrv" "response") [#records-fix])
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1]) (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1])
) )
) )

2
src/compiled/examples/streamCallback.ts
View File

@ -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.7.4-336 * Aqua version: 0.7.6-SNAPSHOT
* *
*/ */
import { Fluence, FluencePeer } from '@fluencelabs/fluence'; import { Fluence, FluencePeer } from '@fluencelabs/fluence';

166
src/compiled/examples/streamCan.ts
View File

@ -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.7.5-SNAPSHOT * Aqua version: 0.7.6-SNAPSHOT
* *
*/ */
import { Fluence, FluencePeer } from '@fluencelabs/fluence'; import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@ -258,14 +258,37 @@ export function returnCanStream(...args: any) {
(seq (seq
(seq (seq
(ap "ok" $status) (ap "ok" $status)
(canon %init_peer_id% $status #status_canon) (new $status_test
(seq
(fold $status s
(seq
(seq
(seq
(call %init_peer_id% ("math" "add") [0 1] incr_idx)
(ap s $status_test)
)
(canon %init_peer_id% $status_test #status_iter_canon)
)
(xor
(match #status_iter_canon.length incr_idx
(null)
)
(next s)
)
)
(never)
)
(canon %init_peer_id% $status_test #status_result_canon)
)
)
) )
(canon %init_peer_id% $status #status-fix) (canon %init_peer_id% $status #status-fix)
) )
) )
) )
(xor (xor
(call %init_peer_id% ("callbackSrv" "response") [#status_canon.$.[0]!]) (call %init_peer_id% ("callbackSrv" "response") [#status_result_canon.$.[0]!])
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1]) (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1])
) )
) )
@ -332,7 +355,30 @@ export function bugLNG63_2(...args: any) {
(seq (seq
(seq (seq
(ap "ok" $status) (ap "ok" $status)
(canon %init_peer_id% $status #status_canon) (new $status_test
(seq
(fold $status s
(seq
(seq
(seq
(call %init_peer_id% ("math" "add") [0 1] incr_idx)
(ap s $status_test)
)
(canon %init_peer_id% $status_test #status_iter_canon)
)
(xor
(match #status_iter_canon.length incr_idx
(null)
)
(next s)
)
)
(never)
)
(canon %init_peer_id% $status_test #status_result_canon)
)
)
) )
(canon %init_peer_id% $status #status-fix) (canon %init_peer_id% $status #status-fix)
) )
@ -342,7 +388,7 @@ export function bugLNG63_2(...args: any) {
(seq (seq
(seq (seq
(ap #status-fix.$.[0]! $array-inline) (ap #status-fix.$.[0]! $array-inline)
(ap #status_canon.$.[0]! $array-inline) (ap #status_result_canon.$.[0]! $array-inline)
) )
(canon %init_peer_id% $array-inline #array-inline-0) (canon %init_peer_id% $array-inline #array-inline-0)
) )
@ -362,7 +408,7 @@ export function bugLNG63_2(...args: any) {
) )
) )
(xor (xor
(call %init_peer_id% ("callbackSrv" "response") [#status_canon.$.[0]! #status-fix #array-inline-1-0]) (call %init_peer_id% ("callbackSrv" "response") [#status_result_canon.$.[0]! #status-fix #array-inline-1-0])
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1]) (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1])
) )
) )
@ -441,14 +487,37 @@ export function bugLNG63(...args: any) {
(seq (seq
(seq (seq
(ap "ok" $status) (ap "ok" $status)
(canon %init_peer_id% $status #status_canon) (new $status_test
(seq
(fold $status s
(seq
(seq
(seq
(call %init_peer_id% ("math" "add") [0 1] incr_idx)
(ap s $status_test)
)
(canon %init_peer_id% $status_test #status_iter_canon)
)
(xor
(match #status_iter_canon.length incr_idx
(null)
)
(next s)
)
)
(never)
)
(canon %init_peer_id% $status_test #status_result_canon)
)
)
) )
(canon %init_peer_id% $status #status-fix) (canon %init_peer_id% $status #status-fix)
) )
) )
) )
(xor (xor
(call %init_peer_id% ("callbackSrv" "response") [#status_canon.$.[0]!]) (call %init_peer_id% ("callbackSrv" "response") [#status_result_canon.$.[0]!])
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1]) (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1])
) )
) )
@ -515,7 +584,30 @@ export function returnMultipleStreamResults(...args: any) {
(seq (seq
(seq (seq
(ap "ok" $status) (ap "ok" $status)
(canon %init_peer_id% $status #status_canon) (new $status_test
(seq
(fold $status s
(seq
(seq
(seq
(call %init_peer_id% ("math" "add") [0 1] incr_idx)
(ap s $status_test)
)
(canon %init_peer_id% $status_test #status_iter_canon)
)
(xor
(match #status_iter_canon.length incr_idx
(null)
)
(next s)
)
)
(never)
)
(canon %init_peer_id% $status_test #status_result_canon)
)
)
) )
(canon %init_peer_id% $status #status-fix) (canon %init_peer_id% $status #status-fix)
) )
@ -525,7 +617,7 @@ export function returnMultipleStreamResults(...args: any) {
(seq (seq
(seq (seq
(ap #status-fix.$.[0]! $array-inline) (ap #status-fix.$.[0]! $array-inline)
(ap #status_canon.$.[0]! $array-inline) (ap #status_result_canon.$.[0]! $array-inline)
) )
(canon %init_peer_id% $array-inline #array-inline-0) (canon %init_peer_id% $array-inline #array-inline-0)
) )
@ -545,7 +637,7 @@ export function returnMultipleStreamResults(...args: any) {
) )
) )
(xor (xor
(call %init_peer_id% ("callbackSrv" "response") [#status_canon.$.[0]! #status-fix #array-inline-0 #array-inline-1-0]) (call %init_peer_id% ("callbackSrv" "response") [#status_result_canon.$.[0]! #status-fix #array-inline-0 #array-inline-1-0])
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1]) (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1])
) )
) )
@ -637,7 +729,30 @@ export function bugLNG63_3(...args: any) {
(seq (seq
(seq (seq
(ap "ok" $status) (ap "ok" $status)
(canon %init_peer_id% $status #status_canon) (new $status_test
(seq
(fold $status s
(seq
(seq
(seq
(call %init_peer_id% ("math" "add") [0 1] incr_idx)
(ap s $status_test)
)
(canon %init_peer_id% $status_test #status_iter_canon)
)
(xor
(match #status_iter_canon.length incr_idx
(null)
)
(next s)
)
)
(never)
)
(canon %init_peer_id% $status_test #status_result_canon)
)
)
) )
(ap 2 $num) (ap 2 $num)
) )
@ -649,9 +764,32 @@ export function bugLNG63_3(...args: any) {
(call %init_peer_id% ("op" "array_length") [$status] array_length) (call %init_peer_id% ("op" "array_length") [$status] array_length)
(ap array_length $array-inline) (ap array_length $array-inline)
) )
(canon %init_peer_id% $num #num_canon) (new $num_test
(seq
(fold $num s
(seq
(seq
(seq
(call %init_peer_id% ("math" "add") [0 1] incr_idx)
(ap s $num_test)
)
(canon %init_peer_id% $num_test #num_iter_canon)
)
(xor
(match #num_iter_canon.length incr_idx
(null)
)
(next s)
)
)
(never)
)
(canon %init_peer_id% $num_test #num_result_canon)
)
)
) )
(ap #num_canon.$.[0]! $array-inline) (ap #num_result_canon.$.[0]! $array-inline)
) )
(canon %init_peer_id% $array-inline #array-inline-0) (canon %init_peer_id% $array-inline #array-inline-0)
) )

20
src/compiled/examples/streamRestriction.ts
View File

@ -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.7.4-336 * Aqua version: 0.7.6-SNAPSHOT
* *
*/ */
import { Fluence, FluencePeer } from '@fluencelabs/fluence'; import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@ -47,13 +47,15 @@ export function streamFold(...args: any) {
(ap n-0 $res) (ap n-0 $res)
(next n-0) (next n-0)
) )
) (null)
(call %init_peer_id% ("op" "identity") [$res] res-fix)
)
(canon %init_peer_id% $res #res-fix)
) )
) )
) )
(xor (xor
(call %init_peer_id% ("callbackSrv" "response") [res-fix]) (call %init_peer_id% ("callbackSrv" "response") [#res-fix])
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1]) (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1])
) )
) )
@ -137,16 +139,18 @@ export function streamRes(...args: any) {
(ap n-0 $res-0) (ap n-0 $res-0)
(next n-0) (next n-0)
) )
) (null)
(call %init_peer_id% ("op" "identity") [$res-0] res-fix-0)
)
(canon %init_peer_id% $res-0 #res-fix-0)
) )
) )
(call %init_peer_id% ("op" "identity") [$res] res-fix) (canon %init_peer_id% $res #res-fix)
) )
) )
) )
(xor (xor
(call %init_peer_id% ("callbackSrv" "response") [res-fix res-fix-0]) (call %init_peer_id% ("callbackSrv" "response") [#res-fix #res-fix-0])
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1]) (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1])
) )
) )

6
src/compiled/examples/streamResults.ts
View File

@ -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.7.4-336 * Aqua version: 0.7.6-SNAPSHOT
* *
*/ */
import { Fluence, FluencePeer } from '@fluencelabs/fluence'; import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@ -180,12 +180,12 @@ export function use_name2(...args: any) {
) )
(ap results-2.$.field! $results) (ap results-2.$.field! $results)
) )
(call %init_peer_id% ("op" "identity") [$results] results-fix) (canon %init_peer_id% $results #results-fix)
) )
) )
) )
(xor (xor
(call %init_peer_id% ("callbackSrv" "response") [results-fix]) (call %init_peer_id% ("callbackSrv" "response") [#results-fix])
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1]) (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1])
) )
) )

2
src/compiled/examples/subImportUsage.ts
View File

@ -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.7.4-336 * Aqua version: 0.7.6-SNAPSHOT
* *
*/ */
import { Fluence, FluencePeer } from '@fluencelabs/fluence'; import { Fluence, FluencePeer } from '@fluencelabs/fluence';

84
src/compiled/examples/topology.ts
View File

@ -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.7.4-336 * Aqua version: 0.7.6-SNAPSHOT
* *
*/ */
import { Fluence, FluencePeer } from '@fluencelabs/fluence'; import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@ -221,36 +221,58 @@ export function topologyBug427(...args: any) {
(seq (seq
(par (par
(fold peers peer-0 (fold peers peer-0
(par (seq
(seq (seq
(seq (call -relay- ("op" "noop") [])
(xor
(seq
(call peer-0 ("op" "identity") ["some string"] $results)
(call -relay- ("op" "noop") [])
)
(seq (seq
(call -relay- ("op" "noop") []) (call -relay- ("op" "noop") [])
(xor (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1])
(call peer-0 ("op" "identity") ["some string"] $results)
(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 peer-0) (next peer-0)
) )
) (null)
)
(null) (null)
) )
(call %init_peer_id% ("op" "noop") [$results.$.[1]!]) (new $results_test
(seq
(fold $results s
(seq
(seq
(seq
(call %init_peer_id% ("math" "add") [1 1] incr_idx)
(ap s $results_test)
)
(canon %init_peer_id% $results_test #results_iter_canon)
)
(xor
(match #results_iter_canon.length incr_idx
(null)
)
(next s)
)
)
(never)
)
(canon %init_peer_id% $results_test #results_result_canon)
)
)
) )
(call %init_peer_id% ("op" "identity") [$results] results-fix) (canon %init_peer_id% $results #results-fix)
) )
) )
) )
(xor (xor
(call %init_peer_id% ("callbackSrv" "response") [results-fix]) (call %init_peer_id% ("callbackSrv" "response") [#results-fix])
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 2]) (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 2])
) )
) )
@ -352,17 +374,25 @@ export function topologyBug205(...args: any) {
(xor (xor
(seq (seq
(par (par
(fold $nodes n-0 (seq
(par (canon node_id $nodes #nodes_canon)
(xor (fold #nodes_canon n-0
(call n-0 ("peer" "identify") []) (seq
(seq (xor
(call -relay- ("op" "noop") []) (call n-0 ("peer" "identify") [])
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 2]) (seq
(seq
(call -relay- ("op" "noop") [])
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 2])
)
(call -relay- ("op" "noop") [])
)
) )
(next n-0)
) )
(next n-0) (null)
)
)
) )
(null) (null)
) )
@ -374,12 +404,12 @@ export function topologyBug205(...args: any) {
) )
) )
) )
(call %init_peer_id% ("op" "identity") [$nodes] nodes-fix) (canon %init_peer_id% $nodes #nodes-fix)
) )
) )
) )
(xor (xor
(call %init_peer_id% ("callbackSrv" "response") [nodes-fix]) (call %init_peer_id% ("callbackSrv" "response") [#nodes-fix])
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 4]) (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 4])
) )
) )

6
src/compiled/examples/tryCatch.ts
View File

@ -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.7.4-336 * Aqua version: 0.7.6-SNAPSHOT
* *
*/ */
import { Fluence, FluencePeer } from '@fluencelabs/fluence'; import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@ -148,12 +148,12 @@ export function tryCatchTest(...args: any) {
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1]) (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1])
) )
) )
(call %init_peer_id% ("op" "identity") [$f] f-fix) (canon %init_peer_id% $f #f-fix)
) )
) )
) )
(xor (xor
(call %init_peer_id% ("callbackSrv" "response") [f-fix]) (call %init_peer_id% ("callbackSrv" "response") [#f-fix])
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 2]) (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 2])
) )
) )

6
src/compiled/examples/tryOtherwise.ts
View File

@ -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.7.4-336 * Aqua version: 0.7.6-SNAPSHOT
* *
*/ */
import { Fluence, FluencePeer } from '@fluencelabs/fluence'; import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@ -142,12 +142,12 @@ export function tryOtherwiseTest(...args: any) {
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1]) (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1])
) )
) )
(call %init_peer_id% ("op" "identity") [$f] f-fix) (canon %init_peer_id% $f #f-fix)
) )
) )
) )
(xor (xor
(call %init_peer_id% ("callbackSrv" "response") [f-fix.$.[0]!]) (call %init_peer_id% ("callbackSrv" "response") [#f-fix.$.[0]!])
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 2]) (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 2])
) )
) )

58
src/compiled/examples/via.ts
View File

@ -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.7.4-336 * Aqua version: 0.7.6-SNAPSHOT
* *
*/ */
import { Fluence, FluencePeer } from '@fluencelabs/fluence'; import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@ -54,7 +54,8 @@ export function viaArr(...args: any) {
(call -via-peer- ("op" "noop") []) (call -via-peer- ("op" "noop") [])
(next -via-peer-) (next -via-peer-)
) )
)
)
) )
(xor (xor
(seq (seq
@ -65,7 +66,8 @@ export function viaArr(...args: any) {
(next -via-peer-) (next -via-peer-)
(call -via-peer- ("op" "noop") []) (call -via-peer- ("op" "noop") [])
) )
)
)
) )
(call -relay- ("op" "noop") []) (call -relay- ("op" "noop") [])
) )
@ -76,7 +78,8 @@ export function viaArr(...args: any) {
(call -via-peer- ("op" "noop") []) (call -via-peer- ("op" "noop") [])
(next -via-peer-) (next -via-peer-)
) )
)
)
(call -relay- ("op" "noop") []) (call -relay- ("op" "noop") [])
) )
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1]) (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1])
@ -180,48 +183,56 @@ export function viaStream(...args: any) {
(seq (seq
(seq (seq
(seq (seq
(call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-) (seq
(call %init_peer_id% ("getDataSrv" "node_id") [] node_id) (call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-)
) (call %init_peer_id% ("getDataSrv" "node_id") [] node_id)
(call %init_peer_id% ("getDataSrv" "viaStr") [] viaStr-iter) )
) (call %init_peer_id% ("getDataSrv" "viaStr") [] viaStr-iter)
(fold viaStr-iter viaStr-item-0
(seq
(ap viaStr-item-0 $viaStr)
(next viaStr-item-0)
) )
(fold viaStr-iter viaStr-item-0
(seq
(ap viaStr-item-0 $viaStr)
(next viaStr-item-0)
)
(null)
)
) )
(canon %init_peer_id% $viaStr #viaStr_canon)
) )
(call -relay- ("op" "noop") []) (call -relay- ("op" "noop") [])
) )
(fold $viaStr -via-peer- (fold #viaStr_canon -via-peer-
(seq (seq
(call -via-peer- ("op" "noop") []) (call -via-peer- ("op" "noop") [])
(next -via-peer-) (next -via-peer-)
) )
)
)
) )
(xor (xor
(seq (seq
(seq (seq
(call node_id ("peer" "identify") [] p) (call node_id ("peer" "identify") [] p)
(fold $viaStr -via-peer- (fold #viaStr_canon -via-peer-
(seq (seq
(next -via-peer-) (next -via-peer-)
(call -via-peer- ("op" "noop") []) (call -via-peer- ("op" "noop") [])
) )
)
)
) )
(call -relay- ("op" "noop") []) (call -relay- ("op" "noop") [])
) )
(seq (seq
(seq (seq
(fold $viaStr -via-peer- (fold #viaStr_canon -via-peer-
(seq (seq
(call -via-peer- ("op" "noop") []) (call -via-peer- ("op" "noop") [])
(next -via-peer-) (next -via-peer-)
) )
)
)
(call -relay- ("op" "noop") []) (call -relay- ("op" "noop") [])
) )
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1]) (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1])
@ -341,7 +352,8 @@ export function viaOpt(...args: any) {
(call -via-peer- ("op" "noop") []) (call -via-peer- ("op" "noop") [])
(next -via-peer-) (next -via-peer-)
) )
)
)
) )
(xor (xor
(seq (seq
@ -352,7 +364,8 @@ export function viaOpt(...args: any) {
(next -via-peer-) (next -via-peer-)
(call -via-peer- ("op" "noop") []) (call -via-peer- ("op" "noop") [])
) )
)
)
) )
(call -relay- ("op" "noop") []) (call -relay- ("op" "noop") [])
) )
@ -363,7 +376,8 @@ export function viaOpt(...args: any) {
(call -via-peer- ("op" "noop") []) (call -via-peer- ("op" "noop") [])
(next -via-peer-) (next -via-peer-)
) )
)
)
(call -relay- ("op" "noop") []) (call -relay- ("op" "noop") [])
) )
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1]) (call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1])

2
src/config.ts
View File

@ -100,4 +100,4 @@ export const localConfig = {
"Local service error, ret_code is 1, error message is '\"Service with id 'unex' not found (function getStr)\"'", "Local service error, ret_code is 1, error message is '\"Service with id 'unex' not found (function getStr)\"'",
}; };
export const { config, isEphemeral } = setConfig(process.env.FLUENCE_ENV); export const { config, isEphemeral } = setConfig("ephemeral");