fluencelabs/examples
1
0
Fork 0
mirror of https://github.com/fluencelabs/examples synced 2025-04-25 02:32:16 +00:00
Code Issues Projects Releases Wiki Activity

update with workers, aqua

Browse Source
This commit is contained in:
boneyard93501 2023-04-24 14:03:44 -05:00
parent 21dbd53fd6
commit 26e8938dc5
3 changed files with 38 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
marine-examples/greeting/.fluence/aqua/workers.aqua
View File

@ -9,9 +9,23 @@ data GetWorkersInfoDealsDefaultWorker:
data GetWorkersInfoDeals: data GetWorkersInfoDeals:
defaultWorker: GetWorkersInfoDealsDefaultWorker defaultWorker: GetWorkersInfoDealsDefaultWorker
data GetWorkersInfoHostsDefaultWorkerInstallationSpells:
hostId: string
spellId: string
workerId: string
data GetWorkersInfoHostsDefaultWorker:
definition: string
installationSpells: []GetWorkersInfoHostsDefaultWorkerInstallationSpells
timestamp: string
relayId: string
data GetWorkersInfoHosts:
defaultWorker: GetWorkersInfoHostsDefaultWorker
data GetWorkersInfo: data GetWorkersInfo:
deals: GetWorkersInfoDeals deals: GetWorkersInfoDeals
hosts: ?u8 hosts: GetWorkersInfoHosts
func getWorkersInfo() -> GetWorkersInfo: func getWorkersInfo() -> GetWorkersInfo:
<- GetWorkersInfo(deals=GetWorkersInfoDeals(defaultWorker=GetWorkersInfoDealsDefaultWorker(definition="bafkreienjhwj727gvxpxr4aa4m3xhi76sgwtehpi5kousma7d6phioegbi",timestamp="2023-04-24T06:11:21.896Z",dealIdOriginal="0xD78f25dE9f0D73aa0c1C009CB99D1A9B2078934f",dealId="d78f25de9f0d73aa0c1c009cb99d1a9b2078934f",chainNetwork="testnet",chainNetworkId=1313161555)),hosts=nil) <- GetWorkersInfo(deals=GetWorkersInfoDeals(defaultWorker=GetWorkersInfoDealsDefaultWorker(definition="bafkreienjhwj727gvxpxr4aa4m3xhi76sgwtehpi5kousma7d6phioegbi",timestamp="2023-04-24T05:54:59.215Z",dealIdOriginal="0x4CE2CC9d7f7EdCb32679a5154761cd55eA4DAEF3",dealId="4ce2cc9d7f7edcb32679a5154761cd55ea4daef3",chainNetwork="testnet",chainNetworkId=1313161555)),hosts=GetWorkersInfoHosts(defaultWorker=GetWorkersInfoHostsDefaultWorker(definition="bafkreig2qgnju5l6tqmwx2a6nufxboyh5nqslxgy657vmuus73xhuzvkey",installationSpells=[GetWorkersInfoHostsDefaultWorkerInstallationSpells(hostId="12D3KooWAKNos2KogexTXhrkMZzFYpLHuWJ4PgoAhurSAv7o5CWA",spellId="efa3c54b-28e8-4f4e-8683-f618edb1bead",workerId="12D3KooWRyAh6agnPhQJaYEScTtZqLo44RN3cSSEmqgamymzzJpM")],timestamp="2023-04-24T18:20:44.516Z",relayId="12D3KooWJ4bTHirdTFNZpCS72TAzwtdmavTBkkEXtzo6wHL25CtE")))

9
marine-examples/greeting/.fluence/workers.yaml
View File

@ -13,3 +13,12 @@ deals:
dealId: 4ce2cc9d7f7edcb32679a5154761cd55ea4daef3 dealId: 4ce2cc9d7f7edcb32679a5154761cd55ea4daef3
chainNetwork: testnet chainNetwork: testnet
chainNetworkId: 1313161555 chainNetworkId: 1313161555
hosts:
defaultWorker:
definition: bafkreig2qgnju5l6tqmwx2a6nufxboyh5nqslxgy657vmuus73xhuzvkey
installation_spells:
- host_id: 12D3KooWAKNos2KogexTXhrkMZzFYpLHuWJ4PgoAhurSAv7o5CWA
spell_id: efa3c54b-28e8-4f4e-8683-f618edb1bead
worker_id: 12D3KooWRyAh6agnPhQJaYEScTtZqLo44RN3cSSEmqgamymzzJpM
timestamp: 2023-04-24T18:20:44.516Z
relayId: 12D3KooWJ4bTHirdTFNZpCS72TAzwtdmavTBkkEXtzo6wHL25CtE

14
marine-examples/greeting/src/aqua/main.aqua
View File

@ -8,15 +8,27 @@ import "@fluencelabs/spell/spell_service.aqua"
import "workers.aqua" import "workers.aqua"
import "services.aqua" import "services.aqua"
export greeting, greetings_seq, greetings_par export greeting, greetings_seq, greetings_par, tester
service Console("run-console"):
print(msg: []?string)
service Console2("run-console"):
print(msg: string)
func getWorkers() -> []Record: func getWorkers() -> []Record:
workersInfo <- getWorkersInfo() workersInfo <- getWorkersInfo()
dealId = workersInfo.deals.defaultWorker.dealId dealId = workersInfo.deals.defaultWorker.dealId
workersOp, err <- resolveSubnetwork(dealId) workersOp, err <- resolveSubnetwork(dealId)
Console.print([err])
<- workersOp! <- workersOp!
func tester():
workersInfo <- getWorkersInfo()
dealId = workersInfo.deals.defaultWorker.dealId
-- workersOp, err <- resolveSubnetwork(dealId)
Console2.print("tester")
func greeting(arg: string) -> string: func greeting(arg: string) -> string:
on HOST_PEER_ID: on HOST_PEER_ID: