mirror of
https://github.com/fluencelabs/aqua-playground
synced 2025-03-15 02:10:51 +00:00
16 lines
574 B
Plaintext
16 lines
574 B
Plaintext
import "@fluencelabs/aqua-dht/pubsub.aqua"
|
|
import "@fluencelabs/aqua-dht/dht.aqua"
|
|
import "@fluencelabs/aqua-lib/builtin.aqua"
|
|
|
|
export getNeighbours, initTopicAndSubscribe, findSubscribers
|
|
|
|
func put_value(initial_peer: string, value: string) -> string:
|
|
initTopicAndSubscribe(initial_peer, "some-const3", value, nil, nil)
|
|
<- "OK"
|
|
|
|
func registerKeyPutValue(node_id: string, key: string, value: string, relay_id: ?string, service_id: ?string) -> []string:
|
|
nodes <- getNeighbours(key, node_id)
|
|
for n <- nodes par:
|
|
on n:
|
|
t <- Peer.timestamp_sec()
|
|
<- nodes |