mirror of
https://github.com/fluencelabs/examples
synced 2025-04-25 02:32:16 +00:00
Extract aqua function out of yaml files
This commit is contained in:
parent
dcae5836d2
commit
6fa979a651
7
.github/check_connection.aqua
vendored
Normal file
7
.github/check_connection.aqua
vendored
Normal file
@ -0,0 +1,7 @@
|
||||
service Op:
|
||||
noop() ->
|
||||
|
||||
func check_connection() -> string:
|
||||
on HOST_PEER_ID:
|
||||
Op.noop()
|
||||
<- "ok"
|
8
.github/deploy.aqua
vendored
Normal file
8
.github/deploy.aqua
vendored
Normal file
@ -0,0 +1,8 @@
|
||||
service CallParameters:
|
||||
call_parameters() -> string
|
||||
|
||||
func call(service_id: string) -> string:
|
||||
on HOST_PEER_ID:
|
||||
CallParameters service_id
|
||||
r <- CallParameters.call_parameters()
|
||||
<- r
|
12
.github/workflows/check-connection.yml
vendored
12
.github/workflows/check-connection.yml
vendored
@ -70,17 +70,9 @@ jobs:
|
||||
run: |
|
||||
set -x
|
||||
NODE="/ip4/127.0.0.1/tcp/4310/ws/p2p/12D3KooWKEprYXUXqoV5xSBeyqrWLpQLLH4PXfvVkDJtmcqmh5V3"
|
||||
INPUT=$GITHUB_WORKSPACE/.github/check_connection.aqua
|
||||
|
||||
echo "
|
||||
service Op:
|
||||
noop() ->
|
||||
|
||||
func check_connection() -> string:
|
||||
on HOST_PEER_ID:
|
||||
Op.noop()
|
||||
<- "ok"
|
||||
" > /tmp/check_connection.aqua
|
||||
RESULT=$(aqua run --addr ${{ matrix.node }} --sk qqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqo= -f 'check_connection()' --input /tmp/call.aqua)
|
||||
RESULT=$(aqua run --addr ${{ matrix.node }} --sk qqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqo= -f 'check_connection()' --input $INPUT)
|
||||
|
||||
if [ "$RESULT" -neq "ok" ]; then
|
||||
echo "Failed to connect to ${{ matrix.node }}"
|
||||
|
13
.github/workflows/check-deploy.yml
vendored
13
.github/workflows/check-deploy.yml
vendored
@ -53,18 +53,9 @@ jobs:
|
||||
set -x
|
||||
NODE="/ip4/127.0.0.1/tcp/4310/ws/p2p/12D3KooWKEprYXUXqoV5xSBeyqrWLpQLLH4PXfvVkDJtmcqmh5V3"
|
||||
SERVICE_ID=`./deploy.sh $NODE`
|
||||
INPUT=$GITHUB_WORKSPACE/.github/deploy.aqua
|
||||
|
||||
echo "
|
||||
service CallParameters:
|
||||
call_parameters() -> string
|
||||
|
||||
func call(service_id: string) -> string:
|
||||
on HOST_PEER_ID:
|
||||
CallParameters service_id
|
||||
r <- CallParameters.call_parameters()
|
||||
<- r
|
||||
" > /tmp/call.aqua
|
||||
RESULT=$(aqua run --addr $NODE --sk qqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqo= -f 'call(service_id)' -d '{"service_id": "'$SERVICE_ID'"}' --input /tmp/call.aqua)
|
||||
RESULT=$(aqua run --addr $NODE --sk qqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqo= -f 'call(service_id)' -d '{"service_id": "'$SERVICE_ID'"}' --input $INPUT)
|
||||
|
||||
EXPECTED_PEER_ID=$(echo -e "$RESULT" | sed -n '1p' | grep -o '12D3.*')
|
||||
RESULT_PEER_ID=$(echo -e "$RESULT" | sed -n '2p' | tr -d \")
|
||||
|
Loading…
x
Reference in New Issue
Block a user