fluencelabs/examples
1
0
Fork 0
mirror of https://github.com/fluencelabs/examples synced 2025-06-27 00:31:34 +00:00
Code Issues Projects Releases Wiki Activity

clean up

Browse Source
This commit is contained in:
boneyard93501
2021-07-19 20:17:16 -05:00
parent 4a5c527059
commit 87e56de10a
6 changed files with 22 additions and 274 deletions
Download Patch File Download Diff File Expand all files Collapse all files

47
aqua-examples/price-oracle/air-scripts/get_crypto_prices.get_prices_par.air
View File

@ -1,47 +0,0 @@
(xor
(seq
(seq
(seq
(seq
(call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-)
(call %init_peer_id% ("getDataSrv" "payload") [] payload)
)
(call %init_peer_id% ("getDataSrv" "ns_pairs") [] ns_pairs)
)
(fold ns_pairs p
(par
(seq
(seq
(call -relay- ("op" "noop") [])
(xor
(seq
(call p.$.node! ("op" "string_to_b58") [p.$.node!] k)
(fold payload d
(seq
(seq
(call p.$.node! ("peer" "timestamp_ms") [] ts_ms)
(call p.$.node! (p.$.service_id! "price_getter") [d.$.coin! d.$.currency! ts_ms] $prices)
)
(next d)
)
)
)
(seq
(call -relay- ("op" "noop") [])
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1])
)
)
)
(call %init_peer_id% ("op" "noop") [])
)
(next p)
)
)
)
(xor
(call %init_peer_id% ("callbackSrv" "response") [$prices])
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 2])
)
)
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 3])
)

39
aqua-examples/price-oracle/air-scripts/get_crypto_prices.get_prices_par_2.air
View File

@ -1,39 +0,0 @@
(xor
(seq
(seq
(seq
(call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-)
(call %init_peer_id% ("getDataSrv" "payload") [] payload)
)
(fold payload p
(par
(seq
(seq
(call -relay- ("op" "noop") [])
(xor
(seq
(seq
(call p.$.node! ("op" "string_to_b58") [p.$.node!] k)
(call p.$.node! ("peer" "timestamp_ms") [] ts_ms)
)
(call p.$.node! (p.$.service_id! "price_getter") [p.$.coin! p.$.currency! ts_ms] $prices)
)
(seq
(call -relay- ("op" "noop") [])
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1])
)
)
)
(call %init_peer_id% ("op" "noop") [])
)
(next p)
)
)
)
(xor
(call %init_peer_id% ("callbackSrv" "response") [$prices])
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 2])
)
)
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 3])
)

47
aqua-examples/price-oracle/air-scripts/get_crypto_prices.get_prices_seq.air
View File

@ -1,47 +0,0 @@
(xor
(seq
(seq
(seq
(seq
(call %init_peer_id% ("getDataSrv" "-relay-") [] -relay-)
(call %init_peer_id% ("getDataSrv" "payloads") [] payloads)
)
(call %init_peer_id% ("getDataSrv" "ns_pairs") [] ns_pairs)
)
(fold ns_pairs p
(seq
(seq
(seq
(call -relay- ("op" "noop") [])
(xor
(seq
(call p.$.node! ("op" "string_to_b58") [p.$.node!] k)
(fold payloads d
(seq
(seq
(call p.$.node! ("peer" "timestamp_ms") [] ts_ms)
(call p.$.node! (p.$.service_id! "price_getter") [d.$.coin! d.$.currency! ts_ms] $prices)
)
(next d)
)
)
)
(seq
(call -relay- ("op" "noop") [])
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 1])
)
)
)
(call -relay- ("op" "noop") [])
)
(next p)
)
)
)
(xor
(call %init_peer_id% ("callbackSrv" "response") [$prices])
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 2])
)
)
(call %init_peer_id% ("errorHandlingSrv" "error") [%last_error% 3])
)