logos-messaging/logos-delivery
1
0
Fork 0
mirror of https://github.com/logos-messaging/logos-delivery.git synced 2026-03-22 00:43:09 +00:00
Code Issues Packages Projects Releases Wiki Activity

Remove filter parts from relay as this is obsolete (moved to WakuNode) (#132)

Browse Source
This commit is contained in:
Kim De Mey 2020-09-02 16:52:00 +02:00 committed by GitHub
parent 2717209f05
commit ea079cf7bd
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 3 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
waku/node/v2/wakunode2.nim
View File

@ -129,9 +129,6 @@ proc start*(node: WakuNode) {.async.} =
let storeProto = WakuStore.init() let storeProto = WakuStore.init()
node.switch.mount(storeProto) node.switch.mount(storeProto)
let wakuRelay = cast[WakuRelay](node.switch.pubSub.get())
wakuRelay.addFilter("store", storeProto.filter())
# TODO Get this from WakuNode obj # TODO Get this from WakuNode obj
let peerInfo = node.peerInfo let peerInfo = node.peerInfo
let id = peerInfo.peerId.pretty let id = peerInfo.peerId.pretty

11
waku/protocol/v2/waku_relay.nim
View File

@ -4,13 +4,11 @@
## Instead, it should likely be on top of GossipSub with a similar interface. ## Instead, it should likely be on top of GossipSub with a similar interface.
import import
std/[strutils, tables], std/strutils,
chronos, chronicles, metrics, chronos, chronicles, metrics,
libp2p/protocols/pubsub/[pubsub, pubsubpeer, floodsub, gossipsub], libp2p/protocols/pubsub/[pubsub, floodsub, gossipsub],
libp2p/protocols/pubsub/rpc/messages, libp2p/protocols/pubsub/rpc/messages,
libp2p/stream/connection, libp2p/stream/connection
../../node/v2/waku_types,
./filter
declarePublicGauge total_messages, "number of messages received" declarePublicGauge total_messages, "number of messages received"
@ -93,6 +91,3 @@ method stop*(w: WakuRelay) {.async.} =
await procCall GossipSub(w).stop() await procCall GossipSub(w).stop()
else: else:
await procCall FloodSub(w).stop() await procCall FloodSub(w).stop()
proc addFilter*(w: WakuRelay, name: string, filter: Filter) =
w.filters.subscribe(name, filter)