From e57323870551bea5a63385fa46fdd7df73881402 Mon Sep 17 00:00:00 2001 From: Jacek Sieka Date: Mon, 6 Mar 2023 16:36:10 +0100 Subject: [PATCH] reexport public types (#872) --- libp2p/protocols/pubsub/floodsub.nim | 2 +- libp2p/protocols/pubsub/gossipsub.nim | 2 +- libp2p/protocols/pubsub/gossipsub/types.nim | 4 +++- libp2p/protocols/pubsub/peertable.nim | 2 ++ libp2p/protocols/pubsub/pubsub.nim | 3 ++- 5 files changed, 9 insertions(+), 4 deletions(-) diff --git a/libp2p/protocols/pubsub/floodsub.nim b/libp2p/protocols/pubsub/floodsub.nim index fd5f750452..c68aca8ea1 100644 --- a/libp2p/protocols/pubsub/floodsub.nim +++ b/libp2p/protocols/pubsub/floodsub.nim @@ -12,7 +12,7 @@ when (NimMajor, NimMinor) < (1, 4): else: {.push raises: [].} -import std/[sequtils, sets, hashes, tables] +import std/[sets, hashes, tables] import chronos, chronicles, metrics import ./pubsub, ./pubsubpeer, diff --git a/libp2p/protocols/pubsub/gossipsub.nim b/libp2p/protocols/pubsub/gossipsub.nim index 1ee60dbaa8..d9b4bc2c09 100644 --- a/libp2p/protocols/pubsub/gossipsub.nim +++ b/libp2p/protocols/pubsub/gossipsub.nim @@ -14,7 +14,7 @@ when (NimMajor, NimMinor) < (1, 4): else: {.push raises: [].} -import std/[tables, sets, options, sequtils] +import std/[sets, sequtils] import chronos, chronicles, metrics import ./pubsub, ./floodsub, diff --git a/libp2p/protocols/pubsub/gossipsub/types.nim b/libp2p/protocols/pubsub/gossipsub/types.nim index fdc5314a88..79d2634449 100644 --- a/libp2p/protocols/pubsub/gossipsub/types.nim +++ b/libp2p/protocols/pubsub/gossipsub/types.nim @@ -13,11 +13,13 @@ else: {.push raises: [].} import chronos -import std/[tables, sets] +import std/[options, tables, sets] import ".."/[floodsub, peertable, mcache, pubsubpeer] import "../rpc"/[messages] import "../../.."/[peerid, multiaddress, utility] +export options, tables, sets + const GossipSubCodec* = "/meshsub/1.1.0" GossipSubCodec_10* = "/meshsub/1.0.0" diff --git a/libp2p/protocols/pubsub/peertable.nim b/libp2p/protocols/pubsub/peertable.nim index c3e5e0fe4c..7818ded1c5 100644 --- a/libp2p/protocols/pubsub/peertable.nim +++ b/libp2p/protocols/pubsub/peertable.nim @@ -15,6 +15,8 @@ else: import std/[tables, sets] import ./pubsubpeer, ../../peerid +export tables, sets + type PeerTable* = Table[string, HashSet[PubSubPeer]] # topic string to peer map diff --git a/libp2p/protocols/pubsub/pubsub.nim b/libp2p/protocols/pubsub/pubsub.nim index 1cc8d9810f..2203f7754b 100644 --- a/libp2p/protocols/pubsub/pubsub.nim +++ b/libp2p/protocols/pubsub/pubsub.nim @@ -36,6 +36,7 @@ import metrics import stew/results export results +export tables, sets export PubSubPeer export PubSubObserver export protocol @@ -118,7 +119,7 @@ type anonymize*: bool ## if we omit fromPeer and seqno from RPC messages we send subscriptionValidator*: SubscriptionValidator # callback used to validate subscriptions topicsHigh*: int ## the maximum number of topics a peer is allowed to subscribe to - maxMessageSize*: int ##\ + maxMessageSize*: int ##\ ## the maximum raw message size we'll globally allow ## for finer tuning, check message size on topic validator ##