aqua-playground/aqua/dht/dht-example.aqua

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, value, nil, nil)
    <- "OK"

func registerKeyPutValue(node_id: string, key: string, value: string, relay_id: ?string, service_id: ?string) -> []string:
  nodes <- getNeighbours(key)
  for n <- nodes par:
    on n:
      t <- Peer.timestamp_sec()
  <- nodes