mirror of https://github.com/waku-org/nwaku.git
49 lines
1.7 KiB
Nim
49 lines
1.7 KiB
Nim
import
|
|
json_rpc/rpcserver, options,
|
|
eth/[common, rlp, keys, p2p],
|
|
../../../protocol/v2/waku_protocol,
|
|
nimcrypto/[sysrand, hmac, sha2],
|
|
../waku_types
|
|
|
|
# Instead of using rlpx waku_protocol here, lets do mock waku2_protocol
|
|
# This should wrap GossipSub, not use EthereumNode here
|
|
|
|
# In Waku0/1 we use node.protocolState(Waku) a lot to get information
|
|
# Also keys to get priate key, etc
|
|
# Where is the equivalent in Waku/2?
|
|
# TODO: Extend to get access to protocol state and keys
|
|
#proc setupWakuRPC*(node: EthereumNode, keys: KeyStorage, rpcsrv: RpcServer) =
|
|
proc setupWakuRPC*(wakuProto: WakuProto, rpcsrv: RpcServer) =
|
|
|
|
# Seems easy enough, lets try to get this first
|
|
rpcsrv.rpc("waku_version") do() -> string:
|
|
## Returns string of the current Waku protocol version.
|
|
result = WakuSubCodec
|
|
|
|
# TODO: Implement symkey etc logic
|
|
rpcsrv.rpc("waku_publish") do(topic: string, message: string) -> bool:
|
|
let data = cast[seq[byte]](message)
|
|
# Assumes someone subscribing on this topic
|
|
#let wakuSub = wakuProto.switch.pubsub
|
|
let wakuSub = cast[WakuSub](wakuProto.switch.pubSub.get())
|
|
# XXX also future return type
|
|
discard wakuSub.publish(topic, data)
|
|
return true
|
|
#if not result:
|
|
# raise newException(ValueError, "Message could not be posted")
|
|
|
|
# TODO: Handler / Identifier logic
|
|
rpcsrv.rpc("waku_subscribe") do(topic: string) -> bool:
|
|
let wakuSub = cast[WakuSub](wakuProto.switch.pubSub.get())
|
|
|
|
# XXX: Hacky in-line handler
|
|
proc handler(topic: string, data: seq[byte]) {.async, gcsafe.} =
|
|
info "Hit subscribe handler", topic=topic, data=data
|
|
|
|
discard wakuSub.subscribe(topic, handler)
|
|
return true
|
|
#if not result:
|
|
# raise newException(ValueError, "Message could not be posted")
|
|
|
|
|