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

add stream restrictions test

Browse Source
This commit is contained in:
DieMyst
2021-11-15 16:15:29 +03:00
parent 8c494d0cc6
commit 3ac764440f
50 changed files with 501 additions and 351 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
aqua/examples/streamRestriction.aqua Normal file
View File

@ -0,0 +1,10 @@
func streamFold(arr: []string) -> []string:
res: *string
for n <- arr:
res <<- n
<- res
func streamRes(arr: []string) -> []string, []string:
res: *string
res2 <- streamFold(arr)
<- res, res2

7
src/__test__/examples.spec.ts
View File

@ -32,6 +32,7 @@ import { config } from '../config';
import {closuresCall} from "../examples/closures";
import {streamCanCall} from "../examples/streamCan";
import {streamCallbackCall} from "../examples/streamCallback";
import {streamResCall} from "../examples/streamRestrictionsCall";
var selfPeerId: string;
var peer2: FluencePeer;
@ -70,6 +71,12 @@ describe('Testing examples', () => {
expect(callArrowResult).toBe('Hello, callArrow call!');
});
it('streamRestrictions.aqua', async () => {
let streamResResult = await streamResCall();
expect(streamResResult).toBe([[], ["a", "b", "c"]]);
});
it('fold.aqua', async () => {
let foldCallResult = await foldCall();
expect(foldCallResult).toStrictEqual(config.externalAddressesRelay1);

14
src/compiled/dht/dht-example.ts
View File

@ -3,7 +3,7 @@
* This file is auto-generated. Do not edit manually: changes may be erased.
* Generated by Aqua compiler: https://github.com/fluencelabs/aqua/.
* If you find any bugs, please write an issue on GitHub: https://github.com/fluencelabs/aqua/issues
* Aqua version: 0.4.1-SNAPSHOT
* Aqua version: 0.5.0-SNAPSHOT
*
*/
import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@ -320,10 +320,6 @@ export function findSubscribers(...args: any) {
let script = `
(xor
(seq
(seq
(seq
(seq
(seq
(seq
(seq
@ -334,8 +330,12 @@ export function findSubscribers(...args: any) {
)
(call %init_peer_id% ("getDataSrv" "topic") [] topic)
)
(new $res
(seq
(seq
(seq
(seq
(call -relay- ("op" "noop") [])
)
(xor
(seq
(call node_id ("op" "string_to_b58") [topic] k)
@ -388,6 +388,8 @@ export function findSubscribers(...args: any) {
)
)
)
)
)
(call -relay- ("op" "noop") [])
)
(xor

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.
* Generated by Aqua compiler: https://github.com/fluencelabs/aqua/.
* If you find any bugs, please write an issue on GitHub: https://github.com/fluencelabs/aqua/issues
* Aqua version: 0.4.1-SNAPSHOT
* Aqua version: 0.5.0-SNAPSHOT
*
*/
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.
* Generated by Aqua compiler: https://github.com/fluencelabs/aqua/.
* If you find any bugs, please write an issue on GitHub: https://github.com/fluencelabs/aqua/issues
* Aqua version: 0.4.1-SNAPSHOT
* Aqua version: 0.5.0-SNAPSHOT
*
*/
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.
* Generated by Aqua compiler: https://github.com/fluencelabs/aqua/.
* If you find any bugs, please write an issue on GitHub: https://github.com/fluencelabs/aqua/issues
* Aqua version: 0.4.1-SNAPSHOT
* Aqua version: 0.5.0-SNAPSHOT
*
*/
import { Fluence, FluencePeer } from '@fluencelabs/fluence';

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

@ -3,7 +3,7 @@
* This file is auto-generated. Do not edit manually: changes may be erased.
* Generated by Aqua compiler: https://github.com/fluencelabs/aqua/.
* If you find any bugs, please write an issue on GitHub: https://github.com/fluencelabs/aqua/issues
* Aqua version: 0.4.1-SNAPSHOT
* Aqua version: 0.5.0-SNAPSHOT
*
*/
import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@ -241,6 +241,8 @@ export function closureBig(...args: any) {
(null)
)
)
(new $p2Id0
(seq
(xor
(match "in" "in"
(xor
@ -256,10 +258,15 @@ export function closureBig(...args: any) {
(ap p2Info.$.external_addresses.[0]! $p2Id0)
)
)
(call %init_peer_id% ("op" "identity") [$p2Id0.$.[0]!] p2Id-fix)
)
)
)
(call -relay- ("op" "noop") [])
)
(xor
(new $p2Id
(seq
(seq
(call -relay- ("op" "noop") [])
(xor
@ -284,6 +291,9 @@ export function closureBig(...args: any) {
)
)
)
(call peer2 ("op" "identity") [$p2Id.$.[0]!] p2Id-fix0)
)
)
(seq
(call -relay- ("op" "noop") [])
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 4])
@ -293,7 +303,7 @@ export function closureBig(...args: any) {
(call -relay- ("op" "noop") [])
)
(xor
(call %init_peer_id% ("callbackSrv" "response") [$p2Id0.$.[0]! $p2Id.$.[0]!])
(call %init_peer_id% ("callbackSrv" "response") [p2Id-fix p2Id-fix0])
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 5])
)
)

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.
* Generated by Aqua compiler: https://github.com/fluencelabs/aqua/.
* If you find any bugs, please write an issue on GitHub: https://github.com/fluencelabs/aqua/issues
* Aqua version: 0.4.1-SNAPSHOT
* Aqua version: 0.5.0-SNAPSHOT
*
*/
import { Fluence, FluencePeer } from '@fluencelabs/fluence';

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

@ -3,7 +3,7 @@
* This file is auto-generated. Do not edit manually: changes may be erased.
* Generated by Aqua compiler: https://github.com/fluencelabs/aqua/.
* If you find any bugs, please write an issue on GitHub: https://github.com/fluencelabs/aqua/issues
* Aqua version: 0.4.1-SNAPSHOT
* Aqua version: 0.5.0-SNAPSHOT
*
*/
import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@ -90,10 +90,6 @@ export function doStuff(...args: any) {
(seq
(seq
(seq
(seq
(seq
(seq
(seq
(seq
(seq
(seq
@ -114,6 +110,12 @@ export function doStuff(...args: any) {
)
(call %init_peer_id% ("getDataSrv" "str") [] str)
)
(new $stream
(seq
(seq
(seq
(seq
(seq
(par
(par
(seq
@ -133,7 +135,6 @@ export function doStuff(...args: any) {
)
)
)
)
(call -relay- ("op" "noop") [])
)
(xor
@ -183,8 +184,12 @@ export function doStuff(...args: any) {
)
(call %init_peer_id% ("some-id" "multiline") [a b c] $stream)
)
(call %init_peer_id% ("op" "identity") [$stream] stream-fix)
)
)
)
(xor
(call %init_peer_id% ("callbackSrv" "response") [$stream])
(call %init_peer_id% ("callbackSrv" "response") [stream-fix])
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 4])
)
)

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

@ -3,7 +3,7 @@
* This file is auto-generated. Do not edit manually: changes may be erased.
* Generated by Aqua compiler: https://github.com/fluencelabs/aqua/.
* If you find any bugs, please write an issue on GitHub: https://github.com/fluencelabs/aqua/issues
* Aqua version: 0.4.1-SNAPSHOT
* Aqua version: 0.5.0-SNAPSHOT
*
*/
import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@ -95,16 +95,21 @@ export function callConstant(...args: any) {
let script = `
(xor
(seq
(seq
(seq
(call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-)
(new $res
(seq
(seq
(call %init_peer_id% ("test" "createStr") [5] $res)
)
(call %init_peer_id% ("op" "identity") ["default-str"] $res)
)
(call %init_peer_id% ("op" "identity") [$res] res-fix)
)
)
)
(xor
(call %init_peer_id% ("callbackSrv" "response") [$res])
(call %init_peer_id% ("callbackSrv" "response") [res-fix])
(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.
* Generated by Aqua compiler: https://github.com/fluencelabs/aqua/.
* If you find any bugs, please write an issue on GitHub: https://github.com/fluencelabs/aqua/issues
* Aqua version: 0.4.1-SNAPSHOT
* Aqua version: 0.5.0-SNAPSHOT
*
*/
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.
* Generated by Aqua compiler: https://github.com/fluencelabs/aqua/.
* If you find any bugs, please write an issue on GitHub: https://github.com/fluencelabs/aqua/issues
* Aqua version: 0.4.1-SNAPSHOT
* Aqua version: 0.5.0-SNAPSHOT
*
*/
import { Fluence, FluencePeer } from '@fluencelabs/fluence';

2
src/compiled/examples/fldist-sample.ts
View File

@ -3,7 +3,7 @@
* This file is auto-generated. Do not edit manually: changes may be erased.
* Generated by Aqua compiler: https://github.com/fluencelabs/aqua/.
* If you find any bugs, please write an issue on GitHub: https://github.com/fluencelabs/aqua/issues
* Aqua version: 0.4.1-SNAPSHOT
* Aqua version: 0.5.0-SNAPSHOT
*
*/
import { Fluence, FluencePeer } from '@fluencelabs/fluence';

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

@ -3,7 +3,7 @@
* This file is auto-generated. Do not edit manually: changes may be erased.
* Generated by Aqua compiler: https://github.com/fluencelabs/aqua/.
* If you find any bugs, please write an issue on GitHub: https://github.com/fluencelabs/aqua/issues
* Aqua version: 0.4.1-SNAPSHOT
* Aqua version: 0.5.0-SNAPSHOT
*
*/
import { Fluence, FluencePeer } from '@fluencelabs/fluence';

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

@ -3,7 +3,7 @@
* This file is auto-generated. Do not edit manually: changes may be erased.
* Generated by Aqua compiler: https://github.com/fluencelabs/aqua/.
* If you find any bugs, please write an issue on GitHub: https://github.com/fluencelabs/aqua/issues
* Aqua version: 0.4.1-SNAPSHOT
* Aqua version: 0.5.0-SNAPSHOT
*
*/
import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@ -59,17 +59,20 @@ export function getTwoResults(...args: any) {
let script = `
(xor
(seq
(seq
(seq
(seq
(seq
(call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-)
(call %init_peer_id% ("getDataSrv" "relay") [] relay)
)
(new $res
(seq
(seq
(seq
(call -relay- ("op" "noop") [])
)
(xor
(seq
(seq
(seq
(seq
(call relay ("kad" "neighborhood") [%init_peer_id% [] []] nodes)
@ -94,6 +97,10 @@ export function getTwoResults(...args: any) {
)
(call relay ("op" "identity") [$res.$.[0]!])
)
(call relay ("op" "identity") [$res.$.[1]!])
)
(call relay ("op" "identity") [$res.$.[2]!])
)
(seq
(call -relay- ("op" "noop") [])
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1])
@ -102,8 +109,12 @@ export function getTwoResults(...args: any) {
)
(call -relay- ("op" "noop") [])
)
(call %init_peer_id% ("op" "identity") [$res] res-fix)
)
)
)
(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])
)
)

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.
* Generated by Aqua compiler: https://github.com/fluencelabs/aqua/.
* If you find any bugs, please write an issue on GitHub: https://github.com/fluencelabs/aqua/issues
* Aqua version: 0.4.1-SNAPSHOT
* Aqua version: 0.5.0-SNAPSHOT
*
*/
import { Fluence, FluencePeer } from '@fluencelabs/fluence';

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.
* Generated by Aqua compiler: https://github.com/fluencelabs/aqua/.
* If you find any bugs, please write an issue on GitHub: https://github.com/fluencelabs/aqua/issues
* Aqua version: 0.4.1-SNAPSHOT
* Aqua version: 0.5.0-SNAPSHOT
*
*/
import { Fluence, FluencePeer } from '@fluencelabs/fluence';

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

@ -3,7 +3,7 @@
* This file is auto-generated. Do not edit manually: changes may be erased.
* Generated by Aqua compiler: https://github.com/fluencelabs/aqua/.
* If you find any bugs, please write an issue on GitHub: https://github.com/fluencelabs/aqua/issues
* Aqua version: 0.4.1-SNAPSHOT
* Aqua version: 0.5.0-SNAPSHOT
*
*/
import { Fluence, FluencePeer } from '@fluencelabs/fluence';

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.
* Generated by Aqua compiler: https://github.com/fluencelabs/aqua/.
* If you find any bugs, please write an issue on GitHub: https://github.com/fluencelabs/aqua/issues
* Aqua version: 0.4.1-SNAPSHOT
* Aqua version: 0.5.0-SNAPSHOT
*
*/
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.
* Generated by Aqua compiler: https://github.com/fluencelabs/aqua/.
* If you find any bugs, please write an issue on GitHub: https://github.com/fluencelabs/aqua/issues
* Aqua version: 0.4.1-SNAPSHOT
* Aqua version: 0.5.0-SNAPSHOT
*
*/
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.
* Generated by Aqua compiler: https://github.com/fluencelabs/aqua/.
* If you find any bugs, please write an issue on GitHub: https://github.com/fluencelabs/aqua/issues
* Aqua version: 0.4.1-SNAPSHOT
* Aqua version: 0.5.0-SNAPSHOT
*
*/
import { Fluence, FluencePeer } from '@fluencelabs/fluence';

13
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.
* Generated by Aqua compiler: https://github.com/fluencelabs/aqua/.
* If you find any bugs, please write an issue on GitHub: https://github.com/fluencelabs/aqua/issues
* Aqua version: 0.4.1-SNAPSHOT
* Aqua version: 0.5.0-SNAPSHOT
*
*/
import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@ -72,16 +72,21 @@ export function barfoo(...args: any) {
let script = `
(xor
(seq
(seq
(seq
(call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-)
(new $res
(seq
(seq
(ap "I am MyFooBar foo" $res)
)
(ap " I am MyFooBar bar" $res)
)
(call %init_peer_id% ("op" "identity") [$res] res-fix)
)
)
)
(xor
(call %init_peer_id% ("callbackSrv" "response") [$res])
(call %init_peer_id% ("callbackSrv" "response") [res-fix])
(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.
* Generated by Aqua compiler: https://github.com/fluencelabs/aqua/.
* If you find any bugs, please write an issue on GitHub: https://github.com/fluencelabs/aqua/issues
* Aqua version: 0.4.1-SNAPSHOT
* Aqua version: 0.5.0-SNAPSHOT
*
*/
import { Fluence, FluencePeer } from '@fluencelabs/fluence';

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

@ -3,7 +3,7 @@
* This file is auto-generated. Do not edit manually: changes may be erased.
* Generated by Aqua compiler: https://github.com/fluencelabs/aqua/.
* If you find any bugs, please write an issue on GitHub: https://github.com/fluencelabs/aqua/issues
* Aqua version: 0.4.1-SNAPSHOT
* Aqua version: 0.5.0-SNAPSHOT
*
*/
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.
* Generated by Aqua compiler: https://github.com/fluencelabs/aqua/.
* If you find any bugs, please write an issue on GitHub: https://github.com/fluencelabs/aqua/issues
* Aqua version: 0.4.1-SNAPSHOT
* Aqua version: 0.5.0-SNAPSHOT
*
*/
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.
* Generated by Aqua compiler: https://github.com/fluencelabs/aqua/.
* If you find any bugs, please write an issue on GitHub: https://github.com/fluencelabs/aqua/issues
* Aqua version: 0.4.1-SNAPSHOT
* Aqua version: 0.5.0-SNAPSHOT
*
*/
import { Fluence, FluencePeer } from '@fluencelabs/fluence';

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

@ -3,7 +3,7 @@
* This file is auto-generated. Do not edit manually: changes may be erased.
* Generated by Aqua compiler: https://github.com/fluencelabs/aqua/.
* If you find any bugs, please write an issue on GitHub: https://github.com/fluencelabs/aqua/issues
* Aqua version: 0.4.1-SNAPSHOT
* Aqua version: 0.5.0-SNAPSHOT
*
*/
import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@ -144,10 +144,6 @@ export function multiReturnFunc(...args: any) {
let script = `
(xor
(seq
(seq
(seq
(seq
(seq
(seq
(seq
@ -157,8 +153,13 @@ export function multiReturnFunc(...args: any) {
)
(call %init_peer_id% ("getDataSrv" "smthOption") [] smthOption)
)
(new $res
(seq
(seq
(seq
(seq
(seq
(call %init_peer_id% ("multiret-test" "retStr") ["some-str"] $res)
)
(call %init_peer_id% ("multiret-test" "retStr") ["random-str"] $res)
)
(call %init_peer_id% ("multiret-test" "retStr") ["some-str"] str)
@ -167,8 +168,12 @@ export function multiReturnFunc(...args: any) {
)
(ap str $res)
)
(call %init_peer_id% ("op" "identity") [$res] res-fix)
)
)
)
(xor
(call %init_peer_id% ("callbackSrv" "response") [$res 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])
)
)

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.
* Generated by Aqua compiler: https://github.com/fluencelabs/aqua/.
* If you find any bugs, please write an issue on GitHub: https://github.com/fluencelabs/aqua/issues
* Aqua version: 0.4.1-SNAPSHOT
* Aqua version: 0.5.0-SNAPSHOT
*
*/
import { Fluence, FluencePeer } from '@fluencelabs/fluence';

2
src/compiled/examples/new-api-full.ts
View File

@ -3,7 +3,7 @@
* This file is auto-generated. Do not edit manually: changes may be erased.
* Generated by Aqua compiler: https://github.com/fluencelabs/aqua/.
* If you find any bugs, please write an issue on GitHub: https://github.com/fluencelabs/aqua/issues
* Aqua version: 0.4.1-SNAPSHOT
* Aqua version: 0.5.0-SNAPSHOT
*
*/
import { Fluence, FluencePeer } from '@fluencelabs/fluence';

2
src/compiled/examples/new-api.ts
View File

@ -3,7 +3,7 @@
* This file is auto-generated. Do not edit manually: changes may be erased.
* Generated by Aqua compiler: https://github.com/fluencelabs/aqua/.
* If you find any bugs, please write an issue on GitHub: https://github.com/fluencelabs/aqua/issues
* Aqua version: 0.4.1-SNAPSHOT
* Aqua version: 0.5.0-SNAPSHOT
*
*/
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.
* Generated by Aqua compiler: https://github.com/fluencelabs/aqua/.
* If you find any bugs, please write an issue on GitHub: https://github.com/fluencelabs/aqua/issues
* Aqua version: 0.4.1-SNAPSHOT
* Aqua version: 0.5.0-SNAPSHOT
*
*/
import { Fluence, FluencePeer } from '@fluencelabs/fluence';

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

@ -3,7 +3,7 @@
* This file is auto-generated. Do not edit manually: changes may be erased.
* Generated by Aqua compiler: https://github.com/fluencelabs/aqua/.
* If you find any bugs, please write an issue on GitHub: https://github.com/fluencelabs/aqua/issues
* Aqua version: 0.4.1-SNAPSHOT
* Aqua version: 0.5.0-SNAPSHOT
*
*/
import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@ -253,10 +253,15 @@ export function returnNone(...args: any) {
(seq
(seq
(call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-)
(new $result
(seq
(call %init_peer_id% ("op" "noop") [])
(call %init_peer_id% ("op" "identity") [$result] result-fix)
)
)
)
(xor
(call %init_peer_id% ("callbackSrv" "response") [$result])
(call %init_peer_id% ("callbackSrv" "response") [result-fix])
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1])
)
)

30
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.
* Generated by Aqua compiler: https://github.com/fluencelabs/aqua/.
* If you find any bugs, please write an issue on GitHub: https://github.com/fluencelabs/aqua/issues
* Aqua version: 0.4.1-SNAPSHOT
* Aqua version: 0.5.0-SNAPSHOT
*
*/
import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@ -59,10 +59,15 @@ export function emptyString(...args: any) {
let script = `
(xor
(seq
(seq
(call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-)
(new $valueEmpty
(call %init_peer_id% ("op" "identity") [$valueEmpty] valueEmpty-fix)
)
)
(xor
(call %init_peer_id% ("callbackSrv" "response") [$valueEmpty])
(call %init_peer_id% ("callbackSrv" "response") [valueEmpty-fix])
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1])
)
)
@ -100,10 +105,15 @@ export function checkEmpty(...args: any) {
let script = `
(xor
(seq
(seq
(seq
(call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-)
(call %init_peer_id% ("opt_str" "checkOption") [$valueEmpty] res)
(new $valueEmpty
(call %init_peer_id% ("op" "identity") [$valueEmpty] valueEmpty-fix)
)
)
(call %init_peer_id% ("opt_str" "checkOption") [valueEmpty-fix] res)
)
(xor
(call %init_peer_id% ("callbackSrv" "response") [res])
@ -150,10 +160,15 @@ export function stringAsOption(...args: any) {
(call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-)
(call %init_peer_id% ("getDataSrv" "str") [] str)
)
(new $valueEmpty
(seq
(ap str $valueEmpty)
(call %init_peer_id% ("op" "identity") [$valueEmpty] valueEmpty-fix)
)
)
)
(xor
(call %init_peer_id% ("callbackSrv" "response") [$valueEmpty])
(call %init_peer_id% ("callbackSrv" "response") [valueEmpty-fix])
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1])
)
)
@ -204,9 +219,14 @@ export function checkNoneEmpty(...args: any) {
(call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-)
(call %init_peer_id% ("getDataSrv" "str") [] str)
)
(new $valueEmpty
(seq
(ap str $valueEmpty)
(call %init_peer_id% ("op" "identity") [$valueEmpty] valueEmpty-fix)
)
(call %init_peer_id% ("opt_str" "checkOption") [$valueEmpty] res)
)
)
(call %init_peer_id% ("opt_str" "checkOption") [valueEmpty-fix] res)
)
(xor
(call %init_peer_id% ("callbackSrv" "response") [res])

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

@ -3,7 +3,7 @@
* This file is auto-generated. Do not edit manually: changes may be erased.
* Generated by Aqua compiler: https://github.com/fluencelabs/aqua/.
* If you find any bugs, please write an issue on GitHub: https://github.com/fluencelabs/aqua/issues
* Aqua version: 0.4.1-SNAPSHOT
* Aqua version: 0.5.0-SNAPSHOT
*
*/
import { Fluence, FluencePeer } from '@fluencelabs/fluence';

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

@ -3,7 +3,7 @@
* This file is auto-generated. Do not edit manually: changes may be erased.
* Generated by Aqua compiler: https://github.com/fluencelabs/aqua/.
* If you find any bugs, please write an issue on GitHub: https://github.com/fluencelabs/aqua/issues
* Aqua version: 0.4.1-SNAPSHOT
* Aqua version: 0.5.0-SNAPSHOT
*
*/
import { Fluence, FluencePeer } from '@fluencelabs/fluence';

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.
* Generated by Aqua compiler: https://github.com/fluencelabs/aqua/.
* If you find any bugs, please write an issue on GitHub: https://github.com/fluencelabs/aqua/issues
* Aqua version: 0.4.1-SNAPSHOT
* Aqua version: 0.5.0-SNAPSHOT
*
*/
import { Fluence, FluencePeer } from '@fluencelabs/fluence';

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

@ -3,7 +3,7 @@
* This file is auto-generated. Do not edit manually: changes may be erased.
* Generated by Aqua compiler: https://github.com/fluencelabs/aqua/.
* If you find any bugs, please write an issue on GitHub: https://github.com/fluencelabs/aqua/issues
* Aqua version: 0.4.1-SNAPSHOT
* Aqua version: 0.5.0-SNAPSHOT
*
*/
import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@ -53,19 +53,24 @@ export function get_results(...args: any) {
let script = `
(xor
(seq
(seq
(seq
(seq
(call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-)
(new $results
(seq
(seq
(seq
(ap "hello" $results)
)
(call %init_peer_id% ("pop" "get_str") [] str)
)
(ap str $results)
)
(call %init_peer_id% ("op" "identity") [$results] results-fix)
)
)
)
(xor
(call %init_peer_id% ("callbackSrv" "response") [$results])
(call %init_peer_id% ("callbackSrv" "response") [results-fix])
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1])
)
)

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.
* Generated by Aqua compiler: https://github.com/fluencelabs/aqua/.
* If you find any bugs, please write an issue on GitHub: https://github.com/fluencelabs/aqua/issues
* Aqua version: 0.4.1-SNAPSHOT
* Aqua version: 0.5.0-SNAPSHOT
*
*/
import { Fluence, FluencePeer } from '@fluencelabs/fluence';

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

@ -3,7 +3,7 @@
* This file is auto-generated. Do not edit manually: changes may be erased.
* Generated by Aqua compiler: https://github.com/fluencelabs/aqua/.
* If you find any bugs, please write an issue on GitHub: https://github.com/fluencelabs/aqua/issues
* Aqua version: 0.4.1-SNAPSHOT
* Aqua version: 0.5.0-SNAPSHOT
*
*/
import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@ -59,10 +59,15 @@ export function returnNone(...args: any) {
let script = `
(xor
(seq
(seq
(call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-)
(new $valueNone
(call %init_peer_id% ("op" "identity") [$valueNone] valueNone-fix)
)
)
(xor
(call %init_peer_id% ("callbackSrv" "response") [$valueNone])
(call %init_peer_id% ("callbackSrv" "response") [valueNone-fix])
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1])
)
)
@ -100,10 +105,15 @@ export function stringNone(...args: any) {
let script = `
(xor
(seq
(seq
(call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-)
(new $valueNone
(call %init_peer_id% ("op" "identity") [$valueNone] valueNone-fix)
)
)
(xor
(call %init_peer_id% ("callbackSrv" "response") [$valueNone])
(call %init_peer_id% ("callbackSrv" "response") [valueNone-fix])
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1])
)
)
@ -229,16 +239,17 @@ export function checkStreams(...args: any) {
let script = `
(xor
(seq
(seq
(seq
(seq
(seq
(call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-)
(call %init_peer_id% ("getDataSrv" "ch") [] ch)
)
(new $stream
(seq
(seq
(seq
(call %init_peer_id% ("stringer-id" "returnString") ["first"] $stream)
)
(call %init_peer_id% ("stringer-id" "returnString") ["second"] $stream)
)
(fold ch b
@ -248,8 +259,12 @@ export function checkStreams(...args: any) {
)
)
)
(call %init_peer_id% ("op" "identity") [$stream] stream-fix)
)
)
)
(xor
(call %init_peer_id% ("callbackSrv" "response") [$stream])
(call %init_peer_id% ("callbackSrv" "response") [stream-fix])
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1])
)
)

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

@ -3,7 +3,7 @@
* This file is auto-generated. Do not edit manually: changes may be erased.
* Generated by Aqua compiler: https://github.com/fluencelabs/aqua/.
* If you find any bugs, please write an issue on GitHub: https://github.com/fluencelabs/aqua/issues
* Aqua version: 0.4.1-SNAPSHOT
* Aqua version: 0.5.0-SNAPSHOT
*
*/
import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@ -129,10 +129,15 @@ export function retrieve_records(...args: any) {
(call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-)
(call %init_peer_id% ("getDataSrv" "peer") [] peer)
)
(call %init_peer_id% ("test-service" "get_records") [peer] $records)
(new $records
(seq
(call %init_peer_id% ("test-service" "get_records") [peer] $records0)
(call %init_peer_id% ("op" "identity") [$records] records-fix)
)
)
)
(xor
(call %init_peer_id% ("callbackSrv" "response") [$records])
(call %init_peer_id% ("callbackSrv" "response") [records-fix])
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1])
)
)

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

@ -3,7 +3,7 @@
* This file is auto-generated. Do not edit manually: changes may be erased.
* Generated by Aqua compiler: https://github.com/fluencelabs/aqua/.
* If you find any bugs, please write an issue on GitHub: https://github.com/fluencelabs/aqua/issues
* Aqua version: 0.4.1-SNAPSHOT
* Aqua version: 0.5.0-SNAPSHOT
*
*/
import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@ -27,11 +27,13 @@ export function someFunc(...args: any) {
(xor
(seq
(call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-)
(new $ifaces
(xor
(call %init_peer_id% ("callbackSrv" "cb") [$ifaces])
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1])
)
)
)
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 2])
)
`

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

@ -3,7 +3,7 @@
* This file is auto-generated. Do not edit manually: changes may be erased.
* Generated by Aqua compiler: https://github.com/fluencelabs/aqua/.
* If you find any bugs, please write an issue on GitHub: https://github.com/fluencelabs/aqua/issues
* Aqua version: 0.4.1-SNAPSHOT
* Aqua version: 0.5.0-SNAPSHOT
*
*/
import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@ -31,10 +31,15 @@ export function toOpt(...args: any) {
(call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-)
(call %init_peer_id% ("getDataSrv" "s") [] s)
)
(new $str
(seq
(ap s $str)
(call %init_peer_id% ("op" "identity") [$str] str-fix)
)
)
)
(xor
(call %init_peer_id% ("callbackSrv" "response") [$str])
(call %init_peer_id% ("callbackSrv" "response") [str-fix])
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1])
)
)
@ -82,23 +87,27 @@ export function accumRes(...args: any) {
(seq
(seq
(seq
(seq
(seq
(seq
(seq
(seq
(call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-)
(new $str
(seq
(ap "a" $str)
(call %init_peer_id% ("op" "identity") [$str] str-fix)
)
(call %init_peer_id% ("op" "identity") [$str] push-to-stream-10)
)
(ap push-to-stream-10 $res_accum)
)
(ap str-fix $res_accum)
)
(new $str0
(seq
(ap "b" $str0)
(call %init_peer_id% ("op" "identity") [$str0] str-fix0)
)
(call %init_peer_id% ("op" "identity") [$str0] push-to-stream-20)
)
(ap push-to-stream-20 $res_accum)
)
(ap str-fix0 $res_accum)
)
(call %init_peer_id% ("op" "identity") [[]] push-to-stream-12)
)

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

@ -3,7 +3,7 @@
* This file is auto-generated. Do not edit manually: changes may be erased.
* Generated by Aqua compiler: https://github.com/fluencelabs/aqua/.
* If you find any bugs, please write an issue on GitHub: https://github.com/fluencelabs/aqua/issues
* Aqua version: 0.4.1-SNAPSHOT
* Aqua version: 0.5.0-SNAPSHOT
*
*/
import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@ -112,19 +112,20 @@ export function use_name2(...args: any) {
let script = `
(xor
(seq
(seq
(seq
(seq
(seq
(seq
(seq
(seq
(call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-)
(call %init_peer_id% ("getDataSrv" "name") [] name)
)
(new $results
(seq
(seq
(seq
(seq
(seq
(seq
(call %init_peer_id% ("get-dt" "get_dt") [name] results0)
)
(ap results0.$.field! $results)
)
(call %init_peer_id% ("get-dt" "get_dt") [name] results1)
@ -135,8 +136,12 @@ export function use_name2(...args: any) {
)
(ap results2.$.field! $results)
)
(call %init_peer_id% ("op" "identity") [$results] results-fix)
)
)
)
(xor
(call %init_peer_id% ("callbackSrv" "response") [$results])
(call %init_peer_id% ("callbackSrv" "response") [results-fix])
(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.
* Generated by Aqua compiler: https://github.com/fluencelabs/aqua/.
* If you find any bugs, please write an issue on GitHub: https://github.com/fluencelabs/aqua/issues
* Aqua version: 0.4.1-SNAPSHOT
* Aqua version: 0.5.0-SNAPSHOT
*
*/
import { Fluence, FluencePeer } from '@fluencelabs/fluence';

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

@ -3,7 +3,7 @@
* This file is auto-generated. Do not edit manually: changes may be erased.
* Generated by Aqua compiler: https://github.com/fluencelabs/aqua/.
* If you find any bugs, please write an issue on GitHub: https://github.com/fluencelabs/aqua/issues
* Aqua version: 0.4.1-SNAPSHOT
* Aqua version: 0.5.0-SNAPSHOT
*
*/
import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@ -206,8 +206,6 @@ export function topologyBug205(...args: any) {
let script = `
(xor
(seq
(seq
(seq
(seq
(seq
(seq
@ -216,8 +214,12 @@ export function topologyBug205(...args: any) {
)
(call %init_peer_id% ("getDataSrv" "n2") [] n2)
)
(new $nodes
(seq
(seq
(seq
(seq
(call -relay- ("op" "noop") [])
)
(xor
(seq
(call node_id ("op" "identity") [n2] a)
@ -251,8 +253,14 @@ export function topologyBug205(...args: any) {
)
)
)
(call -relay- ("op" "noop") [])
)
(call %init_peer_id% ("op" "identity") [$nodes] nodes-fix)
)
)
)
(xor
(call %init_peer_id% ("callbackSrv" "response") [$nodes])
(call %init_peer_id% ("callbackSrv" "response") [nodes-fix])
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 4])
)
)

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

@ -3,7 +3,7 @@
* This file is auto-generated. Do not edit manually: changes may be erased.
* Generated by Aqua compiler: https://github.com/fluencelabs/aqua/.
* If you find any bugs, please write an issue on GitHub: https://github.com/fluencelabs/aqua/issues
* Aqua version: 0.4.1-SNAPSHOT
* Aqua version: 0.5.0-SNAPSHOT
*
*/
import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@ -89,16 +89,17 @@ export function tryCatchTest(...args: any) {
let script = `
(xor
(seq
(seq
(seq
(seq
(seq
(call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-)
(call %init_peer_id% ("getDataSrv" "node_id") [] node_id)
)
(new $f
(seq
(seq
(seq
(call -relay- ("op" "noop") [])
)
(xor
(seq
(call -relay- ("op" "noop") [])
@ -121,8 +122,12 @@ export function tryCatchTest(...args: any) {
)
(call -relay- ("op" "noop") [])
)
(call %init_peer_id% ("op" "identity") [$f] f-fix)
)
)
)
(xor
(call %init_peer_id% ("callbackSrv" "response") [$f])
(call %init_peer_id% ("callbackSrv" "response") [f-fix])
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 2])
)
)

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

@ -3,7 +3,7 @@
* This file is auto-generated. Do not edit manually: changes may be erased.
* Generated by Aqua compiler: https://github.com/fluencelabs/aqua/.
* If you find any bugs, please write an issue on GitHub: https://github.com/fluencelabs/aqua/issues
* Aqua version: 0.4.1-SNAPSHOT
* Aqua version: 0.5.0-SNAPSHOT
*
*/
import { Fluence, FluencePeer } from '@fluencelabs/fluence';
@ -89,16 +89,17 @@ export function tryOtherwiseTest(...args: any) {
let script = `
(xor
(seq
(seq
(seq
(seq
(seq
(call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-)
(call %init_peer_id% ("getDataSrv" "node_id") [] node_id)
)
(new $f
(seq
(seq
(seq
(call -relay- ("op" "noop") [])
)
(xor
(seq
(call -relay- ("op" "noop") [])
@ -115,8 +116,12 @@ export function tryOtherwiseTest(...args: any) {
)
(call -relay- ("op" "noop") [])
)
(call %init_peer_id% ("op" "identity") [$f.$.[0]!] f-fix)
)
)
)
(xor
(call %init_peer_id% ("callbackSrv" "response") [$f.$.[0]!])
(call %init_peer_id% ("callbackSrv" "response") [f-fix])
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 2])
)
)

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

@ -3,7 +3,7 @@
* This file is auto-generated. Do not edit manually: changes may be erased.
* Generated by Aqua compiler: https://github.com/fluencelabs/aqua/.
* If you find any bugs, please write an issue on GitHub: https://github.com/fluencelabs/aqua/issues
* Aqua version: 0.4.1-SNAPSHOT
* Aqua version: 0.5.0-SNAPSHOT
*
*/
import { Fluence, FluencePeer } from '@fluencelabs/fluence';

2
src/config.ts
View File

@ -22,4 +22,4 @@ export const testNetConfig = {
tryCatchError: "Local service error, ret_code is 1, error message is '\"Service with id 'unex' not found (function getStr)\"'"
}
export const config = testNetConfig
export const config = krasnodarConfig

6
src/examples/streamRestrictionsCall.ts Normal file
View File

@ -0,0 +1,6 @@
import { FluencePeer } from '@fluencelabs/fluence';
import { streamRes } from '../compiled/examples/streamRestriction';
export async function streamResCall(): Promise<any> {
return await streamRes(["a", "b", "c"]);
}