mirror of
https://github.com/logos-messaging/logos-messaging-nim.git
synced 2026-01-02 14:03:06 +00:00
chore: fix unused and deprecated imports (#3368)
This commit is contained in:
parent
ccb4ed51db
commit
6ebb49a14b
@ -1,6 +1,6 @@
|
||||
{.used.}
|
||||
|
||||
import std/strutils, stew/[results, byteutils], testutils/unittests
|
||||
import std/strutils, results, stew/byteutils, testutils/unittests
|
||||
import waku/common/base64
|
||||
|
||||
suite "Waku Common - stew base64 wrapper":
|
||||
|
||||
@ -2,7 +2,7 @@
|
||||
|
||||
import
|
||||
std/[os, options],
|
||||
stew/results,
|
||||
results,
|
||||
stew/shims/net as stewNet,
|
||||
testutils/unittests,
|
||||
confutils,
|
||||
|
||||
@ -1,6 +1,6 @@
|
||||
{.used.}
|
||||
|
||||
import std/options, stew/results, stew/shims/net, testutils/unittests
|
||||
import std/options, results, stew/shims/net, testutils/unittests
|
||||
import waku/common/enr, ../testlib/wakucore
|
||||
|
||||
suite "nim-eth ENR - builder and typed record":
|
||||
|
||||
@ -1,6 +1,6 @@
|
||||
{.used.}
|
||||
|
||||
import testutils/unittests, stew/results
|
||||
import testutils/unittests, results
|
||||
import waku/common/utils/parse_size_units
|
||||
|
||||
suite "Size serialization test":
|
||||
|
||||
@ -10,7 +10,7 @@
|
||||
|
||||
import testutils/unittests
|
||||
import chronos, libp2p/stream/connection
|
||||
import std/[sequtils, options, tables]
|
||||
import std/[options, tables]
|
||||
|
||||
import ../../waku/common/rate_limit/request_limiter
|
||||
import ../../waku/common/rate_limit/timed_map
|
||||
|
||||
@ -10,7 +10,7 @@
|
||||
|
||||
import testutils/unittests
|
||||
import chronos, libp2p/stream/connection
|
||||
import std/[sequtils, options]
|
||||
import std/options
|
||||
|
||||
import ../../waku/common/rate_limit/request_limiter
|
||||
import ../../waku/common/rate_limit/timed_map
|
||||
|
||||
@ -1,6 +1,6 @@
|
||||
{.used.}
|
||||
|
||||
import std/[strutils, os], stew/results, testutils/unittests
|
||||
import std/[strutils, os], results, testutils/unittests
|
||||
import waku/common/databases/db_sqlite {.all.}, ../waku_archive/archive_utils
|
||||
|
||||
template sourceDir(): string =
|
||||
|
||||
@ -1,17 +1,9 @@
|
||||
{.used.}
|
||||
|
||||
import
|
||||
std/options,
|
||||
testutils/unittests,
|
||||
chronos,
|
||||
web3,
|
||||
stew/byteutils,
|
||||
stint,
|
||||
strutils,
|
||||
tests/testlib/testasync
|
||||
import std/options, testutils/unittests, chronos, web3, stint, tests/testlib/testasync
|
||||
|
||||
import
|
||||
waku/[node/peer_manager, waku_core],
|
||||
waku/node/peer_manager,
|
||||
waku/incentivization/[rpc, eligibility_manager],
|
||||
../waku_rln_relay/[utils_onchain, utils]
|
||||
|
||||
|
||||
@ -1,17 +1,6 @@
|
||||
import
|
||||
std/options,
|
||||
testutils/unittests,
|
||||
chronos,
|
||||
web3,
|
||||
stew/byteutils,
|
||||
stint,
|
||||
strutils,
|
||||
tests/testlib/testasync
|
||||
import std/options, testutils/unittests, chronos, web3
|
||||
|
||||
import
|
||||
waku/[node/peer_manager, waku_core],
|
||||
waku/incentivization/[rpc, reputation_manager],
|
||||
waku/waku_lightpush_legacy/rpc
|
||||
import waku/incentivization/reputation_manager, waku/waku_lightpush_legacy/rpc
|
||||
|
||||
suite "Waku Incentivization PoC Reputation":
|
||||
var manager {.threadvar.}: ReputationManager
|
||||
|
||||
@ -1,4 +1,4 @@
|
||||
import std/options, stew/results, libp2p/peerstore
|
||||
import std/options, results
|
||||
|
||||
import
|
||||
waku/node/peer_manager/[waku_peer_store, peer_store/waku_peer_storage],
|
||||
|
||||
@ -6,7 +6,6 @@ import
|
||||
testutils/unittests,
|
||||
chronos,
|
||||
chronicles,
|
||||
os,
|
||||
libp2p/[peerstore, crypto/crypto]
|
||||
|
||||
import
|
||||
|
||||
@ -1,31 +1,24 @@
|
||||
{.used.}
|
||||
|
||||
import
|
||||
std/[options, tables, sequtils, tempfiles, strutils],
|
||||
std/[options, tempfiles],
|
||||
stew/shims/net as stewNet,
|
||||
testutils/unittests,
|
||||
chronos,
|
||||
chronicles,
|
||||
std/strformat,
|
||||
os,
|
||||
libp2p/[peerstore, crypto/crypto]
|
||||
libp2p/crypto/crypto
|
||||
|
||||
import
|
||||
waku/[
|
||||
waku_core,
|
||||
node/peer_manager,
|
||||
node/waku_node,
|
||||
waku_filter_v2,
|
||||
waku_filter_v2/client,
|
||||
waku_filter_v2/subscriptions,
|
||||
waku_lightpush_legacy,
|
||||
waku_lightpush_legacy/common,
|
||||
waku_lightpush_legacy/client,
|
||||
waku_lightpush_legacy/protocol_metrics,
|
||||
waku_lightpush_legacy/rpc,
|
||||
waku_rln_relay,
|
||||
],
|
||||
../testlib/[assertions, common, wakucore, wakunode, testasync, futures, testutils],
|
||||
../testlib/[wakucore, wakunode, testasync, futures],
|
||||
../resources/payloads
|
||||
|
||||
suite "Waku Legacy Lightpush - End To End":
|
||||
|
||||
@ -14,14 +14,11 @@ import
|
||||
node/peer_manager,
|
||||
waku_core,
|
||||
waku_store_legacy,
|
||||
waku_store_legacy/client,
|
||||
waku_archive_legacy,
|
||||
waku_archive_legacy/driver/sqlite_driver,
|
||||
common/databases/db_sqlite,
|
||||
],
|
||||
../waku_store_legacy/store_utils,
|
||||
../waku_archive_legacy/archive_utils,
|
||||
../testlib/[common, wakucore, wakunode, testasync, futures, testutils]
|
||||
../testlib/[wakucore, wakunode, testasync, testutils]
|
||||
|
||||
suite "Waku Store - End to End - Sorted Archive":
|
||||
var pubsubTopic {.threadvar.}: PubsubTopic
|
||||
|
||||
@ -1,27 +1,16 @@
|
||||
{.used.}
|
||||
|
||||
import
|
||||
std/[options, tables, sequtils, tempfiles, strutils],
|
||||
std/[options, tempfiles],
|
||||
stew/shims/net as stewNet,
|
||||
testutils/unittests,
|
||||
chronos,
|
||||
chronicles,
|
||||
std/strformat,
|
||||
os,
|
||||
libp2p/[peerstore, crypto/crypto]
|
||||
libp2p/crypto/crypto
|
||||
|
||||
import
|
||||
waku/[
|
||||
waku_core,
|
||||
node/peer_manager,
|
||||
node/waku_node,
|
||||
waku_filter_v2,
|
||||
waku_filter_v2/client,
|
||||
waku_filter_v2/subscriptions,
|
||||
waku_lightpush,
|
||||
waku_rln_relay,
|
||||
],
|
||||
../testlib/[assertions, common, wakucore, wakunode, testasync, futures, testutils],
|
||||
waku/[waku_core, node/peer_manager, node/waku_node, waku_lightpush, waku_rln_relay],
|
||||
../testlib/[wakucore, wakunode, testasync, futures],
|
||||
../resources/payloads
|
||||
|
||||
const PublishedToOnePeer = 1
|
||||
|
||||
@ -13,14 +13,8 @@ import
|
||||
eth/p2p/discoveryv5/enr
|
||||
|
||||
import
|
||||
waku/[
|
||||
waku_node,
|
||||
discovery/waku_discv5,
|
||||
waku_peer_exchange,
|
||||
node/peer_manager,
|
||||
waku_relay/protocol,
|
||||
waku_core,
|
||||
],
|
||||
waku/
|
||||
[waku_node, discovery/waku_discv5, waku_peer_exchange, node/peer_manager, waku_core],
|
||||
../waku_peer_exchange/utils,
|
||||
../testlib/[wakucore, wakunode, testasync]
|
||||
|
||||
|
||||
@ -18,18 +18,15 @@ import
|
||||
waku_core,
|
||||
node/peer_manager,
|
||||
node/waku_node,
|
||||
waku_enr/sharding,
|
||||
discovery/waku_discv5,
|
||||
waku_filter_v2/common,
|
||||
waku_relay/protocol,
|
||||
],
|
||||
../testlib/
|
||||
[wakucore, wakunode, testasync, testutils, assertions, comparisons, futures],
|
||||
../testlib/[wakucore, wakunode, testasync, testutils, comparisons],
|
||||
../waku_enr/utils,
|
||||
../waku_archive/archive_utils,
|
||||
../waku_discv5/utils,
|
||||
./peer_manager/peer_store/utils,
|
||||
./utils
|
||||
./peer_manager/peer_store/utils
|
||||
|
||||
const DEFAULT_PROTOCOLS: seq[string] =
|
||||
@["/ipfs/id/1.0.0", "/libp2p/autonat/1.0.0", "/libp2p/circuit/relay/0.2.0/hop"]
|
||||
|
||||
@ -1,7 +1,7 @@
|
||||
{.used.}
|
||||
|
||||
import
|
||||
std/[options, sequtils, algorithm, sets],
|
||||
std/[options, sequtils, sets],
|
||||
stew/shims/net as stewNet,
|
||||
testutils/unittests,
|
||||
chronos,
|
||||
@ -15,14 +15,11 @@ import
|
||||
waku_core,
|
||||
waku_core/message/digest,
|
||||
waku_store,
|
||||
waku_store/client,
|
||||
waku_archive,
|
||||
waku_archive/driver/sqlite_driver,
|
||||
common/databases/db_sqlite,
|
||||
],
|
||||
../waku_store/store_utils,
|
||||
../waku_archive/archive_utils,
|
||||
../testlib/[common, wakucore, wakunode, testasync, futures, testutils]
|
||||
../testlib/[wakucore, wakunode, testasync, testutils]
|
||||
|
||||
suite "Waku Store - End to End - Sorted Archive":
|
||||
var pubsubTopic {.threadvar.}: PubsubTopic
|
||||
|
||||
@ -1,6 +1,6 @@
|
||||
{.used.}
|
||||
|
||||
import std/[sets, random], stew/[results, byteutils], testutils/unittests
|
||||
import std/[sets, random], results, stew/byteutils, testutils/unittests
|
||||
import waku/waku_core, waku/waku_api/message_cache, ./testlib/wakucore
|
||||
|
||||
randomize()
|
||||
|
||||
@ -1,7 +1,7 @@
|
||||
{.used.}
|
||||
|
||||
import
|
||||
std/[options, sequtils, times, sugar, net],
|
||||
std/[sequtils, times, sugar, net],
|
||||
stew/shims/net as stewNet,
|
||||
testutils/unittests,
|
||||
chronos,
|
||||
@ -27,7 +27,6 @@ import
|
||||
waku_relay/protocol,
|
||||
waku_filter_v2/common,
|
||||
waku_store/common,
|
||||
waku_lightpush/common,
|
||||
waku_peer_exchange,
|
||||
waku_metadata,
|
||||
],
|
||||
|
||||
@ -9,12 +9,8 @@ import
|
||||
libp2p/multiaddress,
|
||||
testutils/unittests
|
||||
import
|
||||
waku/[
|
||||
node/peer_manager/peer_manager,
|
||||
node/peer_manager/waku_peer_store,
|
||||
waku_node,
|
||||
waku_core/peers,
|
||||
],
|
||||
waku/
|
||||
[node/peer_manager/peer_manager, node/peer_manager/waku_peer_store, waku_core/peers],
|
||||
./testlib/wakucore
|
||||
|
||||
suite "Extended nim-libp2p Peer Store":
|
||||
|
||||
@ -4,10 +4,8 @@ import
|
||||
std/[sequtils, options],
|
||||
stew/shims/net,
|
||||
testutils/unittests,
|
||||
chronicles,
|
||||
chronos,
|
||||
libp2p/peerid,
|
||||
libp2p/crypto/crypto,
|
||||
libp2p/protocols/pubsub/gossipsub
|
||||
|
||||
import waku/waku_core, waku/waku_node, ./testlib/wakucore, ./testlib/wakunode
|
||||
|
||||
@ -3,7 +3,8 @@
|
||||
import
|
||||
std/[sequtils, tables],
|
||||
stew/shims/net,
|
||||
stew/[base32, results],
|
||||
results,
|
||||
stew/base32,
|
||||
testutils/unittests,
|
||||
chronicles,
|
||||
chronos,
|
||||
|
||||
@ -1,6 +1,6 @@
|
||||
{.used.}
|
||||
|
||||
import std/[options, sequtils], stew/results, testutils/unittests
|
||||
import std/[options, sequtils], results, testutils/unittests
|
||||
import waku/waku_core, waku/waku_enr, ./testlib/wakucore
|
||||
|
||||
suite "Waku ENR - Capabilities bitfield":
|
||||
|
||||
@ -1,7 +1,6 @@
|
||||
{.used.}
|
||||
|
||||
import
|
||||
std/options,
|
||||
stew/shims/net as stewNet,
|
||||
testutils/unittests,
|
||||
chronos,
|
||||
|
||||
@ -1,6 +1,6 @@
|
||||
{.used.}
|
||||
|
||||
import std/tables, stew/[results, byteutils], testutils/unittests
|
||||
import std/tables, results, stew/byteutils, testutils/unittests
|
||||
import
|
||||
waku/[
|
||||
common/protobuf,
|
||||
|
||||
@ -17,9 +17,7 @@ import
|
||||
libp2p/nameresolving/mockresolver,
|
||||
eth/p2p/discoveryv5/enr
|
||||
import
|
||||
waku/[waku_core, waku_node, node/peer_manager, waku_relay, waku_peer_exchange],
|
||||
./testlib/wakucore,
|
||||
./testlib/wakunode
|
||||
waku/[waku_core, waku_node, node/peer_manager], ./testlib/wakucore, ./testlib/wakunode
|
||||
|
||||
suite "WakuNode":
|
||||
asyncTest "Protocol matcher works as expected":
|
||||
|
||||
@ -9,9 +9,9 @@ type Instr {.union.} = object
|
||||
proc mockImpl*(target, replacement: pointer) =
|
||||
# YOLO who needs alignment
|
||||
#doAssert (cast[ByteAddress](target) and ByteAddress(0x07)) == 0
|
||||
var page = cast[pointer](cast[ByteAddress](target) and (not 0xfff))
|
||||
var page = cast[pointer](cast[uint](target) and (not 0xfff))
|
||||
doAssert mprotect(page, 4096, PROT_WRITE or PROT_EXEC) == 0
|
||||
let rel = cast[ByteAddress](replacement) - cast[ByteAddress](target) - 5
|
||||
let rel = cast[uint](replacement) - cast[uint](target) - 5
|
||||
var instr = Instr(
|
||||
bytes: [
|
||||
0xe9.byte,
|
||||
|
||||
@ -1,6 +1,7 @@
|
||||
import
|
||||
std/[options, times],
|
||||
stew/[results, byteutils],
|
||||
results,
|
||||
stew/byteutils,
|
||||
stew/shims/net,
|
||||
chronos,
|
||||
libp2p/switch,
|
||||
|
||||
@ -1,6 +1,6 @@
|
||||
import
|
||||
std/options,
|
||||
stew/results,
|
||||
results,
|
||||
stew/shims/net,
|
||||
chronos,
|
||||
libp2p/switch,
|
||||
|
||||
@ -1,13 +1,12 @@
|
||||
{.used.}
|
||||
|
||||
import std/options, stew/results, chronos, libp2p/crypto/crypto
|
||||
import std/options, results, chronos, libp2p/crypto/crypto
|
||||
|
||||
import
|
||||
waku/[
|
||||
node/peer_manager,
|
||||
waku_core,
|
||||
waku_archive,
|
||||
waku_archive/common,
|
||||
waku_archive/driver/sqlite_driver,
|
||||
waku_archive/driver/sqlite_driver/migrations,
|
||||
common/databases/db_sqlite,
|
||||
|
||||
@ -1,6 +1,6 @@
|
||||
{.used.}
|
||||
|
||||
import std/options, stew/results, testutils/unittests
|
||||
import std/options, results, testutils/unittests
|
||||
import
|
||||
waku/[
|
||||
waku_archive,
|
||||
|
||||
@ -1,6 +1,6 @@
|
||||
{.used.}
|
||||
|
||||
import std/[times, random], stew/byteutils, testutils/unittests, nimcrypto
|
||||
import std/random, testutils/unittests
|
||||
import waku/waku_core, waku/waku_archive/driver/queue_driver/index
|
||||
|
||||
var rng = initRand()
|
||||
|
||||
@ -9,7 +9,6 @@ import
|
||||
waku_archive/driver/queue_driver/index,
|
||||
waku_core,
|
||||
],
|
||||
../testlib/common,
|
||||
../testlib/wakucore
|
||||
|
||||
proc getTestQueueDriver(numMessages: int): QueueDriver =
|
||||
|
||||
@ -2,12 +2,7 @@
|
||||
|
||||
import std/sequtils, testutils/unittests, chronos
|
||||
import
|
||||
waku/[
|
||||
common/databases/db_sqlite,
|
||||
waku_archive,
|
||||
waku_archive/driver/sqlite_driver,
|
||||
waku_core,
|
||||
],
|
||||
waku/[waku_archive, waku_archive/driver/sqlite_driver, waku_core],
|
||||
../waku_archive/archive_utils,
|
||||
../testlib/wakucore
|
||||
|
||||
|
||||
@ -4,13 +4,7 @@ import
|
||||
std/[options, sequtils, random, algorithm], testutils/unittests, chronos, chronicles
|
||||
|
||||
import
|
||||
waku/[
|
||||
common/databases/db_sqlite,
|
||||
waku_archive,
|
||||
waku_archive/driver/sqlite_driver,
|
||||
waku_core,
|
||||
waku_core/message/digest,
|
||||
],
|
||||
waku/[waku_archive, waku_core, waku_core/message/digest],
|
||||
../testlib/common,
|
||||
../testlib/wakucore,
|
||||
../waku_archive/archive_utils
|
||||
|
||||
@ -1,13 +1,11 @@
|
||||
{.used.}
|
||||
|
||||
import std/[sequtils, times], stew/results, testutils/unittests, chronos
|
||||
import std/[sequtils, times], results, testutils/unittests, chronos
|
||||
import
|
||||
waku/[
|
||||
common/databases/db_sqlite,
|
||||
waku_core,
|
||||
waku_core/message/digest,
|
||||
waku_archive,
|
||||
waku_archive/driver/sqlite_driver,
|
||||
waku_archive/retention_policy,
|
||||
waku_archive/retention_policy/retention_policy_capacity,
|
||||
waku_archive/retention_policy/retention_policy_size,
|
||||
|
||||
@ -4,12 +4,10 @@ import std/[options, sequtils], testutils/unittests, chronos, libp2p/crypto/cryp
|
||||
|
||||
import
|
||||
waku/[
|
||||
common/databases/db_sqlite,
|
||||
common/databases/db_postgres/dbconn,
|
||||
common/paging,
|
||||
waku_core,
|
||||
waku_core/message/digest,
|
||||
waku_archive/driver/sqlite_driver,
|
||||
waku_archive,
|
||||
],
|
||||
../waku_archive/archive_utils,
|
||||
|
||||
@ -1,6 +1,6 @@
|
||||
{.used.}
|
||||
|
||||
import std/options, stew/results, testutils/unittests
|
||||
import std/options, results, testutils/unittests
|
||||
import
|
||||
waku/waku_archive_legacy,
|
||||
waku/waku_archive_legacy/driver/queue_driver/queue_driver {.all.},
|
||||
|
||||
@ -2,12 +2,10 @@
|
||||
|
||||
import std/sequtils, testutils/unittests, chronos
|
||||
import
|
||||
waku/common/databases/db_sqlite,
|
||||
waku/waku_archive_legacy,
|
||||
waku/waku_archive_legacy/driver/sqlite_driver,
|
||||
waku/waku_core,
|
||||
../waku_archive_legacy/archive_utils,
|
||||
../testlib/common,
|
||||
../testlib/wakucore
|
||||
|
||||
suite "SQLite driver":
|
||||
|
||||
@ -4,9 +4,7 @@ import
|
||||
std/[options, sequtils, random, algorithm], testutils/unittests, chronos, chronicles
|
||||
|
||||
import
|
||||
waku/common/databases/db_sqlite,
|
||||
waku/waku_archive_legacy,
|
||||
waku/waku_archive_legacy/driver/sqlite_driver,
|
||||
waku/waku_core,
|
||||
waku/waku_core/message/digest,
|
||||
../testlib/common,
|
||||
|
||||
@ -1,21 +1,13 @@
|
||||
{.used.}
|
||||
|
||||
import
|
||||
std/[options, sequtils],
|
||||
testutils/unittests,
|
||||
chronicles,
|
||||
chronos,
|
||||
libp2p/crypto/crypto
|
||||
import std/[options, sequtils], testutils/unittests, chronos, libp2p/crypto/crypto
|
||||
|
||||
import
|
||||
waku/common/databases/db_sqlite,
|
||||
waku/common/paging,
|
||||
waku/waku_core,
|
||||
waku/waku_core/message/digest,
|
||||
waku/waku_archive_legacy/driver/sqlite_driver,
|
||||
waku/waku_archive_legacy,
|
||||
../waku_archive_legacy/archive_utils,
|
||||
../testlib/common,
|
||||
../testlib/wakucore
|
||||
|
||||
suite "Waku Archive - message handling":
|
||||
|
||||
@ -1,7 +1,7 @@
|
||||
{.used.}
|
||||
|
||||
import
|
||||
stew/results,
|
||||
results,
|
||||
testutils/unittests,
|
||||
libp2p/multiaddress,
|
||||
libp2p/peerid,
|
||||
|
||||
@ -2,7 +2,7 @@
|
||||
|
||||
import
|
||||
std/[sequtils, algorithm],
|
||||
stew/results,
|
||||
results,
|
||||
stew/shims/net,
|
||||
chronos,
|
||||
chronicles,
|
||||
|
||||
@ -1,6 +1,5 @@
|
||||
import
|
||||
std/options,
|
||||
stew/results,
|
||||
stew/shims/net,
|
||||
chronos,
|
||||
libp2p/crypto/crypto as libp2p_keys,
|
||||
|
||||
@ -1,15 +1,13 @@
|
||||
import
|
||||
std/options,
|
||||
sequtils,
|
||||
stew/results,
|
||||
results,
|
||||
stew/shims/net,
|
||||
chronos,
|
||||
libp2p/crypto/crypto as libp2p_keys,
|
||||
eth/keys as eth_keys
|
||||
|
||||
import
|
||||
waku/[waku_core/topics, waku_enr, discovery/waku_discv5, waku_enr/sharding],
|
||||
../testlib/[common, wakucore]
|
||||
import waku/[waku_enr, discovery/waku_discv5, waku_enr/sharding], ../testlib/wakucore
|
||||
|
||||
proc newTestEnrRecord*(
|
||||
privKey: libp2p_keys.PrivateKey,
|
||||
|
||||
@ -1,13 +1,6 @@
|
||||
{.used.}
|
||||
|
||||
import
|
||||
std/[options, tables, sequtils, strutils, json],
|
||||
testutils/unittests,
|
||||
stew/[results, byteutils],
|
||||
chronos,
|
||||
chronicles,
|
||||
os,
|
||||
libp2p/peerstore
|
||||
import std/[options, sequtils, json], testutils/unittests, results, chronos
|
||||
|
||||
import
|
||||
waku/node/[peer_manager, waku_node],
|
||||
|
||||
@ -1,25 +1,18 @@
|
||||
{.used.}
|
||||
|
||||
import
|
||||
std/[options, tables, sequtils, strutils, json],
|
||||
std/[options, tables, json],
|
||||
testutils/unittests,
|
||||
stew/[results, byteutils],
|
||||
results,
|
||||
chronos,
|
||||
chronicles,
|
||||
os,
|
||||
libp2p/peerstore
|
||||
|
||||
import
|
||||
waku/[
|
||||
node/peer_manager,
|
||||
waku_core,
|
||||
common/rate_limit/setting,
|
||||
common/rate_limit/token_bucket,
|
||||
],
|
||||
waku/waku_filter_v2/[common, client, subscriptions, protocol, rpc_codec],
|
||||
../testlib/[wakucore, testasync, testutils, futures, sequtils],
|
||||
./waku_filter_utils,
|
||||
../resources/payloads
|
||||
waku/[node/peer_manager, waku_core],
|
||||
waku/waku_filter_v2/[common, client, subscriptions, protocol],
|
||||
../testlib/[wakucore, testasync, futures],
|
||||
./waku_filter_utils
|
||||
|
||||
type AFilterClient = ref object of RootObj
|
||||
clientSwitch*: Switch
|
||||
|
||||
@ -1,4 +1,4 @@
|
||||
import std/[options, tables, sets, sequtils, algorithm], chronos, chronicles, os
|
||||
import std/[options, tables, sets, algorithm], chronos, chronicles, os
|
||||
|
||||
import
|
||||
waku/[
|
||||
|
||||
@ -1,6 +1,6 @@
|
||||
{.used.}
|
||||
|
||||
import std/options, chronicles, chronos, libp2p/crypto/crypto
|
||||
import std/options, chronos, libp2p/crypto/crypto
|
||||
|
||||
import
|
||||
waku/node/peer_manager,
|
||||
|
||||
@ -1,11 +1,6 @@
|
||||
{.used.}
|
||||
|
||||
import
|
||||
std/[options, strscans],
|
||||
testutils/unittests,
|
||||
chronicles,
|
||||
chronos,
|
||||
libp2p/crypto/crypto
|
||||
import std/[options, strscans], testutils/unittests, chronos, libp2p/crypto/crypto
|
||||
|
||||
import
|
||||
waku/[
|
||||
@ -15,7 +10,7 @@ import
|
||||
waku_lightpush/client,
|
||||
waku_lightpush/protocol_metrics,
|
||||
],
|
||||
../testlib/[assertions, wakucore, testasync, futures, testutils],
|
||||
../testlib/[assertions, wakucore, testasync, futures],
|
||||
./lightpush_utils,
|
||||
../resources/[pubsub_topics, content_topics, payloads]
|
||||
|
||||
|
||||
@ -1,24 +1,11 @@
|
||||
{.used.}
|
||||
|
||||
import
|
||||
std/[options, strscans],
|
||||
testutils/unittests,
|
||||
chronicles,
|
||||
chronos,
|
||||
libp2p/crypto/crypto
|
||||
import std/options, testutils/unittests, chronos, libp2p/crypto/crypto
|
||||
|
||||
import
|
||||
waku/[
|
||||
node/peer_manager,
|
||||
common/rate_limit/setting,
|
||||
waku_core,
|
||||
waku_lightpush,
|
||||
waku_lightpush/client,
|
||||
waku_lightpush/protocol_metrics,
|
||||
],
|
||||
../testlib/[assertions, wakucore, testasync, futures, testutils],
|
||||
./lightpush_utils,
|
||||
../resources/[pubsub_topics, content_topics, payloads]
|
||||
waku/[node/peer_manager, waku_core, waku_lightpush, waku_lightpush/client],
|
||||
../testlib/wakucore,
|
||||
./lightpush_utils
|
||||
|
||||
suite "Rate limited push service":
|
||||
asyncTest "push message with rate limit not violated":
|
||||
|
||||
@ -1,10 +1,9 @@
|
||||
{.used.}
|
||||
|
||||
import std/options, chronicles, chronos, libp2p/crypto/crypto
|
||||
import std/options, chronos, libp2p/crypto/crypto
|
||||
|
||||
import
|
||||
waku/node/peer_manager,
|
||||
waku/waku_core,
|
||||
waku/waku_lightpush_legacy,
|
||||
waku/waku_lightpush_legacy/[client, common],
|
||||
waku/common/rate_limit/setting,
|
||||
|
||||
@ -1,11 +1,6 @@
|
||||
{.used.}
|
||||
|
||||
import
|
||||
std/[options, strscans],
|
||||
testutils/unittests,
|
||||
chronicles,
|
||||
chronos,
|
||||
libp2p/crypto/crypto
|
||||
import std/[options, strscans], testutils/unittests, chronos, libp2p/crypto/crypto
|
||||
|
||||
import
|
||||
waku/[
|
||||
@ -16,9 +11,8 @@ import
|
||||
waku_lightpush_legacy/common,
|
||||
waku_lightpush_legacy/protocol_metrics,
|
||||
waku_lightpush_legacy/rpc,
|
||||
waku_lightpush_legacy/rpc_codec,
|
||||
],
|
||||
../testlib/[assertions, wakucore, testasync, futures, testutils],
|
||||
../testlib/[assertions, wakucore, testasync, futures],
|
||||
./lightpush_utils,
|
||||
../resources/[pubsub_topics, content_topics, payloads]
|
||||
|
||||
|
||||
@ -1,27 +1,17 @@
|
||||
{.used.}
|
||||
|
||||
import
|
||||
std/[options, strscans],
|
||||
testutils/unittests,
|
||||
chronicles,
|
||||
chronos,
|
||||
libp2p/crypto/crypto
|
||||
import std/options, testutils/unittests, chronos, libp2p/crypto/crypto
|
||||
|
||||
import
|
||||
waku/[
|
||||
node/peer_manager,
|
||||
common/rate_limit/setting,
|
||||
waku_core,
|
||||
waku_lightpush_legacy,
|
||||
waku_lightpush_legacy/client,
|
||||
waku_lightpush_legacy/common,
|
||||
waku_lightpush_legacy/protocol_metrics,
|
||||
waku_lightpush_legacy/rpc,
|
||||
waku_lightpush_legacy/rpc_codec,
|
||||
],
|
||||
../testlib/[assertions, wakucore, testasync, futures, testutils],
|
||||
./lightpush_utils,
|
||||
../resources/[pubsub_topics, content_topics, payloads]
|
||||
../testlib/wakucore,
|
||||
./lightpush_utils
|
||||
|
||||
suite "Rate limited push service":
|
||||
asyncTest "push message with rate limit not violated":
|
||||
|
||||
@ -1,11 +1,10 @@
|
||||
{.used.}
|
||||
|
||||
import
|
||||
std/[options, sequtils, tables, net],
|
||||
std/[options, sequtils, net],
|
||||
testutils/unittests,
|
||||
chronos,
|
||||
chronicles,
|
||||
libp2p/[switch, peerId, crypto/crypto, multistream, muxers/muxer],
|
||||
libp2p/[switch, peerId, crypto/crypto],
|
||||
eth/[keys, p2p/discoveryv5/enr]
|
||||
|
||||
import
|
||||
@ -18,14 +17,11 @@ import
|
||||
waku_peer_exchange/rpc_codec,
|
||||
waku_peer_exchange/protocol,
|
||||
node/peer_manager,
|
||||
waku_relay/protocol,
|
||||
waku_relay,
|
||||
waku_core,
|
||||
waku_core/message/codec,
|
||||
common/enr/builder,
|
||||
waku_enr/sharding,
|
||||
],
|
||||
../testlib/[wakucore, wakunode, simple_mock, assertions],
|
||||
../testlib/[wakucore, wakunode, assertions],
|
||||
./utils.nim
|
||||
|
||||
suite "Waku Peer Exchange":
|
||||
|
||||
@ -1,10 +1,11 @@
|
||||
import
|
||||
unittest,
|
||||
stew/[shims/net, results, byteutils],
|
||||
results,
|
||||
stew/[shims/net, byteutils],
|
||||
nimcrypto/sha2,
|
||||
libp2p/protocols/pubsub/rpc/messages
|
||||
|
||||
import waku/waku_relay/message_id, ../testlib/sequtils
|
||||
import waku/waku_relay/message_id
|
||||
|
||||
suite "Message ID Provider":
|
||||
test "Non-empty string":
|
||||
|
||||
@ -1,13 +1,12 @@
|
||||
{.used.}
|
||||
|
||||
import
|
||||
std/[options, sequtils, strutils, strformat],
|
||||
std/[options, strformat],
|
||||
stew/shims/net as stewNet,
|
||||
testutils/unittests,
|
||||
chronicles,
|
||||
chronos,
|
||||
libp2p/protocols/pubsub/[pubsub, gossipsub],
|
||||
libp2p/[multihash, stream/connection, switch],
|
||||
libp2p/[stream/connection, switch],
|
||||
./crypto_utils,
|
||||
std/json
|
||||
|
||||
@ -19,7 +18,7 @@ import
|
||||
waku_core,
|
||||
waku_core/message/codec,
|
||||
],
|
||||
../testlib/[wakucore, testasync, testutils, futures, sequtils],
|
||||
../testlib/[wakucore, testasync, futures, sequtils],
|
||||
./utils,
|
||||
../resources/payloads
|
||||
|
||||
|
||||
@ -4,7 +4,6 @@ import
|
||||
std/[strutils, sequtils, tempfiles],
|
||||
stew/byteutils,
|
||||
stew/shims/net as stewNet,
|
||||
testutils/unittests,
|
||||
chronos,
|
||||
libp2p/switch,
|
||||
libp2p/protocols/pubsub/pubsub
|
||||
@ -23,8 +22,7 @@ import
|
||||
],
|
||||
../waku_store/store_utils,
|
||||
../waku_archive/archive_utils,
|
||||
../testlib/[wakucore, wakunode, testasync, futures],
|
||||
../resources/payloads
|
||||
../testlib/[wakucore, futures]
|
||||
|
||||
proc noopRawHandler*(): WakuRelayHandler =
|
||||
var handler: WakuRelayHandler
|
||||
|
||||
@ -3,8 +3,9 @@
|
||||
{.push raises: [].}
|
||||
|
||||
import
|
||||
std/[options, os, osproc, sequtils, deques, streams, strutils, tempfiles, strformat],
|
||||
stew/[results, byteutils],
|
||||
std/[options, sequtils, deques],
|
||||
results,
|
||||
stew/byteutils,
|
||||
testutils/unittests,
|
||||
chronos,
|
||||
chronicles,
|
||||
@ -16,19 +17,15 @@ import
|
||||
|
||||
import
|
||||
waku/[
|
||||
waku_node,
|
||||
node/waku_node,
|
||||
waku_rln_relay,
|
||||
waku_rln_relay/protocol_types,
|
||||
waku_rln_relay/constants,
|
||||
waku_rln_relay/contract,
|
||||
waku_rln_relay/rln,
|
||||
waku_rln_relay/conversion_utils,
|
||||
waku_rln_relay/group_manager/on_chain/group_manager,
|
||||
],
|
||||
../testlib/[wakucore, wakunode, common],
|
||||
./utils_onchain,
|
||||
./utils
|
||||
../testlib/wakucore,
|
||||
./utils_onchain
|
||||
|
||||
suite "Onchain group manager":
|
||||
# We run Anvil
|
||||
|
||||
@ -4,7 +4,7 @@
|
||||
|
||||
import
|
||||
testutils/unittests,
|
||||
stew/results,
|
||||
results,
|
||||
options,
|
||||
waku/[
|
||||
waku_rln_relay/protocol_types,
|
||||
|
||||
@ -2,7 +2,7 @@
|
||||
|
||||
{.push raises: [].}
|
||||
|
||||
import stew/results, stint
|
||||
import results
|
||||
|
||||
import
|
||||
./rln/waku_rln_relay_utils,
|
||||
|
||||
@ -17,7 +17,6 @@ import
|
||||
waku_rln_relay/protocol_metrics,
|
||||
waku_keystore,
|
||||
],
|
||||
../testlib/common,
|
||||
./rln/waku_rln_relay_utils
|
||||
|
||||
suite "Waku rln relay":
|
||||
|
||||
@ -1,4 +1,4 @@
|
||||
import web3, chronos, options, stint, stew/byteutils
|
||||
import web3, chronos, stew/byteutils
|
||||
|
||||
proc deployContract*(
|
||||
web3: Web3, code: string, gasPrice = 0, contractInput = ""
|
||||
|
||||
@ -3,8 +3,9 @@
|
||||
{.push raises: [].}
|
||||
|
||||
import
|
||||
std/[options, os, osproc, sequtils, deques, streams, strutils, tempfiles, strformat],
|
||||
stew/[results, byteutils],
|
||||
std/[options, os, osproc, deques, streams, strutils, tempfiles, strformat],
|
||||
results,
|
||||
stew/byteutils,
|
||||
testutils/unittests,
|
||||
chronos,
|
||||
chronicles,
|
||||
|
||||
@ -1,10 +1,9 @@
|
||||
{.used.}
|
||||
|
||||
import std/options, chronos, chronicles, libp2p/crypto/crypto
|
||||
import std/options, chronos
|
||||
|
||||
import
|
||||
waku/[node/peer_manager, waku_core, waku_store, waku_store/client],
|
||||
../testlib/[common, wakucore]
|
||||
waku/[node/peer_manager, waku_store, waku_store/client], ../testlib/[common, wakucore]
|
||||
|
||||
proc newTestWakuStore*(
|
||||
switch: Switch, handler: StoreQueryRequestHandler
|
||||
|
||||
@ -1,10 +1,10 @@
|
||||
{.used.}
|
||||
|
||||
import std/options, testutils/unittests, chronos, chronicles, libp2p/crypto/crypto
|
||||
import std/options, testutils/unittests, chronos, libp2p/crypto/crypto
|
||||
|
||||
import
|
||||
waku/[node/peer_manager, waku_core, waku_store, waku_store/client, common/paging],
|
||||
../testlib/[common, wakucore, testasync, futures],
|
||||
../testlib/[wakucore, testasync, futures],
|
||||
./store_utils
|
||||
|
||||
suite "Store Client":
|
||||
|
||||
@ -1,6 +1,6 @@
|
||||
{.used.}
|
||||
|
||||
import std/options, testutils/unittests, chronos, chronicles, libp2p/crypto/crypto
|
||||
import std/options, testutils/unittests, chronos, libp2p/crypto/crypto
|
||||
|
||||
import
|
||||
waku/[
|
||||
@ -12,7 +12,7 @@ import
|
||||
waku_store/client,
|
||||
waku_store/common,
|
||||
],
|
||||
../testlib/[common, wakucore],
|
||||
../testlib/wakucore,
|
||||
./store_utils
|
||||
|
||||
suite "Waku Store - query handler":
|
||||
|
||||
@ -18,10 +18,8 @@ import
|
||||
common/paging,
|
||||
waku_core,
|
||||
waku_core/message/digest,
|
||||
waku_core/subscription,
|
||||
node/peer_manager,
|
||||
waku_archive,
|
||||
waku_archive/driver/sqlite_driver,
|
||||
waku_filter_v2,
|
||||
waku_filter_v2/client,
|
||||
waku_store,
|
||||
|
||||
@ -1,6 +1,6 @@
|
||||
{.used.}
|
||||
|
||||
import std/options, chronos, chronicles, libp2p/crypto/crypto
|
||||
import std/options, chronos
|
||||
|
||||
import
|
||||
waku/[node/peer_manager, waku_core, waku_store_legacy, waku_store_legacy/client],
|
||||
|
||||
@ -1,6 +1,6 @@
|
||||
{.used.}
|
||||
|
||||
import std/options, testutils/unittests, chronos, chronicles, libp2p/crypto/crypto
|
||||
import std/options, testutils/unittests, chronos, libp2p/crypto/crypto
|
||||
|
||||
import
|
||||
waku/[
|
||||
@ -10,7 +10,7 @@ import
|
||||
waku_store_legacy/client,
|
||||
common/paging,
|
||||
],
|
||||
../testlib/[common, wakucore, testasync, futures],
|
||||
../testlib/[wakucore, testasync, futures],
|
||||
./store_utils
|
||||
|
||||
suite "Store Client":
|
||||
|
||||
@ -9,7 +9,6 @@ import
|
||||
waku_store_legacy/rpc,
|
||||
waku_store_legacy/rpc_codec,
|
||||
],
|
||||
../testlib/common,
|
||||
../testlib/wakucore
|
||||
|
||||
procSuite "Waku Store - RPC codec":
|
||||
|
||||
@ -1,6 +1,6 @@
|
||||
{.used.}
|
||||
|
||||
import std/options, testutils/unittests, chronos, chronicles, libp2p/crypto/crypto
|
||||
import testutils/unittests, chronos, libp2p/crypto/crypto
|
||||
|
||||
import
|
||||
waku/[
|
||||
@ -10,7 +10,7 @@ import
|
||||
waku_store_legacy,
|
||||
waku_store_legacy/client,
|
||||
],
|
||||
../testlib/[common, wakucore],
|
||||
../testlib/wakucore,
|
||||
./store_utils
|
||||
|
||||
suite "Waku Store - query handler legacy":
|
||||
|
||||
@ -3,7 +3,6 @@
|
||||
import
|
||||
std/net,
|
||||
testutils/unittests,
|
||||
chronicles,
|
||||
chronos,
|
||||
libp2p/crypto/crypto,
|
||||
libp2p/peerid,
|
||||
|
||||
@ -1,4 +1,4 @@
|
||||
import std/[options, random], chronos, chronicles
|
||||
import std/[options, random], chronos
|
||||
|
||||
import
|
||||
waku/[
|
||||
|
||||
@ -1,11 +1,7 @@
|
||||
{.used.}
|
||||
|
||||
import
|
||||
std/[options, sets, random, math],
|
||||
testutils/unittests,
|
||||
chronos,
|
||||
libp2p/crypto/crypto,
|
||||
stew/byteutils
|
||||
std/[options, sets, random, math], testutils/unittests, chronos, libp2p/crypto/crypto
|
||||
|
||||
import
|
||||
../../waku/[
|
||||
|
||||
@ -4,7 +4,6 @@ import std/[options, random], testutils/unittests, chronos
|
||||
|
||||
import
|
||||
../../waku/waku_core,
|
||||
../../waku/waku_core/message/digest,
|
||||
../../waku/waku_store_sync/common,
|
||||
../../waku/waku_store_sync/storage/seq_storage,
|
||||
./sync_utils
|
||||
|
||||
@ -1,7 +1,7 @@
|
||||
{.used.}
|
||||
|
||||
import
|
||||
std/[sequtils, strformat, net],
|
||||
std/[sequtils, net],
|
||||
stew/shims/net,
|
||||
testutils/unittests,
|
||||
presto,
|
||||
|
||||
@ -13,10 +13,7 @@ import
|
||||
waku_node,
|
||||
node/waku_node as waku_node2,
|
||||
waku_api/rest/server,
|
||||
waku_api/rest/client,
|
||||
waku_api/rest/responses,
|
||||
waku_api/rest/debug/handlers as debug_api,
|
||||
waku_api/rest/debug/client as debug_api_client,
|
||||
],
|
||||
../testlib/common,
|
||||
../testlib/wakucore,
|
||||
|
||||
@ -1,6 +1,6 @@
|
||||
{.used.}
|
||||
|
||||
import stew/results, stew/byteutils, testutils/unittests, json_serialization
|
||||
import results, stew/byteutils, testutils/unittests, json_serialization
|
||||
import waku/waku_api/rest/serdes, waku/waku_api/rest/debug/types
|
||||
|
||||
suite "Waku v2 REST API - Debug - serialization":
|
||||
|
||||
@ -1,7 +1,6 @@
|
||||
{.used.}
|
||||
|
||||
import
|
||||
std/os,
|
||||
chronos/timer,
|
||||
stew/byteutils,
|
||||
stew/shims/net,
|
||||
|
||||
@ -23,7 +23,6 @@ import
|
||||
node/health_monitor,
|
||||
],
|
||||
../testlib/common,
|
||||
../testlib/testutils,
|
||||
../testlib/wakucore,
|
||||
../testlib/wakunode
|
||||
|
||||
|
||||
@ -26,8 +26,7 @@ import
|
||||
common/rate_limit/setting,
|
||||
],
|
||||
../testlib/wakucore,
|
||||
../testlib/wakunode,
|
||||
../testlib/testutils
|
||||
../testlib/wakunode
|
||||
|
||||
proc testWakuNode(): WakuNode =
|
||||
let
|
||||
|
||||
@ -1,6 +1,6 @@
|
||||
{.used.}
|
||||
|
||||
import stew/[results, byteutils], chronicles, unittest2, json_serialization
|
||||
import results, stew/byteutils, unittest2, json_serialization
|
||||
import waku/[common/base64, waku_api/rest/serdes, waku_api/rest/relay/types, waku_core]
|
||||
|
||||
suite "Waku v2 Rest API - Relay - serialization":
|
||||
|
||||
@ -1,6 +1,6 @@
|
||||
{.used.}
|
||||
|
||||
import stew/[results, byteutils], chronicles, unittest2, json_serialization
|
||||
import results, stew/byteutils, chronicles, unittest2, json_serialization
|
||||
import waku/waku_api/rest/serdes, waku/waku_api/rest/debug/types
|
||||
|
||||
# TODO: Decouple this test suite from the `debug_api` module by defining
|
||||
|
||||
@ -23,6 +23,7 @@ requires "nim >= 2.0.8",
|
||||
"web3",
|
||||
"presto",
|
||||
"regex",
|
||||
"results",
|
||||
"db_connector",
|
||||
"minilru",
|
||||
"quic"
|
||||
|
||||
@ -1,6 +1,5 @@
|
||||
import
|
||||
std/[times, strutils, asyncnet, os, sequtils, sets, strformat],
|
||||
regex,
|
||||
std/[times, strutils, os, sets, strformat],
|
||||
results,
|
||||
chronos,
|
||||
chronos/threadsync,
|
||||
|
||||
@ -8,7 +8,6 @@ import
|
||||
libp2p/builders,
|
||||
libp2p/nameresolving/nameresolver,
|
||||
libp2p/transports/wstransport,
|
||||
libp2p/protocols/connectivity/relay/client,
|
||||
libp2p/protocols/connectivity/relay/relay
|
||||
import
|
||||
../waku_enr,
|
||||
|
||||
@ -38,7 +38,6 @@ import
|
||||
../waku_rln_relay,
|
||||
../waku_store,
|
||||
../waku_filter_v2,
|
||||
../factory/networks_config,
|
||||
../factory/node_factory,
|
||||
../factory/internal_config,
|
||||
../factory/external_config,
|
||||
|
||||
@ -1,6 +1,6 @@
|
||||
import std/options
|
||||
|
||||
import waku/incentivization/[rpc, eligibility_manager]
|
||||
import waku/incentivization/rpc
|
||||
|
||||
proc init*(T: type EligibilityStatus, isEligible: bool): T =
|
||||
if isEligible:
|
||||
|
||||
@ -1,6 +1,6 @@
|
||||
import std/[options, sets], chronos, web3, stew/byteutils, stint, results, chronicles
|
||||
|
||||
import waku/incentivization/rpc, tests/waku_rln_relay/[utils_onchain, utils]
|
||||
import waku/incentivization/rpc, tests/waku_rln_relay/utils_onchain
|
||||
|
||||
const SimpleTransferGasUsed = Quantity(21000)
|
||||
const TxReceiptQueryTimeout = 3.seconds
|
||||
|
||||
@ -1,5 +1,5 @@
|
||||
import std/options
|
||||
import ../common/protobuf, ../waku_core, ./rpc
|
||||
import ../common/protobuf, ./rpc
|
||||
|
||||
# Codec for EligibilityProof
|
||||
|
||||
|
||||
@ -15,8 +15,6 @@ import
|
||||
libp2p/protocols/ping,
|
||||
libp2p/protocols/pubsub/gossipsub,
|
||||
libp2p/protocols/pubsub/rpc/messages,
|
||||
libp2p/protocols/connectivity/autonat/client,
|
||||
libp2p/protocols/connectivity/autonat/service,
|
||||
libp2p/builders,
|
||||
libp2p/transports/transport,
|
||||
libp2p/transports/tcptransport,
|
||||
@ -50,8 +48,7 @@ import
|
||||
../waku_rln_relay,
|
||||
./config,
|
||||
./peer_manager,
|
||||
../common/rate_limit/setting,
|
||||
../discovery/autonat_service
|
||||
../common/rate_limit/setting
|
||||
|
||||
declarePublicCounter waku_node_messages, "number of messages received", ["type"]
|
||||
declarePublicHistogram waku_histogram_message_size,
|
||||
|
||||
@ -1,13 +1,8 @@
|
||||
{.push raises: [].}
|
||||
|
||||
import
|
||||
chronicles,
|
||||
json_serialization,
|
||||
json_serialization/std/options,
|
||||
presto/[route, client],
|
||||
stew/byteutils
|
||||
import chronicles, json_serialization, presto/[route, client], stew/byteutils
|
||||
|
||||
import ../serdes, ../responses, ../rest_serdes, ./types
|
||||
import ../serdes, ../rest_serdes, ./types
|
||||
|
||||
export types
|
||||
|
||||
|
||||
@ -2,7 +2,7 @@
|
||||
|
||||
import
|
||||
chronicles, json_serialization, json_serialization/std/options, presto/[route, client]
|
||||
import ../serdes, ../responses, ../rest_serdes, ./types
|
||||
import ../serdes, ../rest_serdes, ./types
|
||||
|
||||
export types
|
||||
|
||||
|
||||
@ -2,20 +2,12 @@
|
||||
|
||||
import
|
||||
json,
|
||||
std/sets,
|
||||
stew/byteutils,
|
||||
strformat,
|
||||
chronicles,
|
||||
json_serialization,
|
||||
json_serialization/std/options,
|
||||
presto/[route, client, common]
|
||||
import
|
||||
../../../common/base64,
|
||||
../../../waku_core,
|
||||
../serdes,
|
||||
../responses,
|
||||
../rest_serdes,
|
||||
./types
|
||||
import ../../../common/base64, ../serdes, ../rest_serdes, ./types
|
||||
|
||||
export types
|
||||
|
||||
|
||||
@ -1,8 +1,7 @@
|
||||
{.push raises: [].}
|
||||
|
||||
import
|
||||
chronicles, json_serialization, json_serialization/std/options, presto/[route, client]
|
||||
import ./types, ../serdes, ../responses, ../rest_serdes, waku/node/health_monitor
|
||||
import chronicles, json_serialization, presto/[route, client]
|
||||
import ./types, ../serdes, ../rest_serdes, waku/node/health_monitor
|
||||
|
||||
logScope:
|
||||
topics = "waku node rest health_api"
|
||||
|
||||
@ -1,15 +1,7 @@
|
||||
{.push raises: [].}
|
||||
|
||||
import
|
||||
json,
|
||||
std/sets,
|
||||
stew/byteutils,
|
||||
strformat,
|
||||
chronicles,
|
||||
json_serialization,
|
||||
json_serialization/std/options,
|
||||
presto/[route, client, common]
|
||||
import ../../../waku_core, ../serdes, ../responses, ../rest_serdes, ./types
|
||||
import chronicles, json_serialization, presto/[route, client, common]
|
||||
import ../serdes, ../rest_serdes, ./types
|
||||
|
||||
export types
|
||||
|
||||
|
||||
@ -1,13 +1,7 @@
|
||||
{.push raises: [].}
|
||||
|
||||
import
|
||||
std/sets,
|
||||
stew/byteutils,
|
||||
chronicles,
|
||||
json_serialization,
|
||||
json_serialization/std/options,
|
||||
presto/[route, client, common]
|
||||
import ../../../waku_core, ../serdes, ../responses, ../rest_serdes, ./types
|
||||
import stew/byteutils, chronicles, json_serialization, presto/[route, client, common]
|
||||
import ../../../waku_core, ../serdes, ../rest_serdes, ./types
|
||||
|
||||
export types
|
||||
|
||||
|
||||
@ -1,6 +1,5 @@
|
||||
{.push raises: [].}
|
||||
|
||||
import stew/byteutils
|
||||
import ../../../waku_core
|
||||
|
||||
type Index* = object
|
||||
|
||||
@ -7,12 +7,7 @@ import
|
||||
libp2p/peerid,
|
||||
libp2p/stream/connection,
|
||||
stew/shims/sets
|
||||
import
|
||||
../waku_core,
|
||||
../utils/tableutils,
|
||||
../common/rate_limit/setting,
|
||||
../node/peer_manager,
|
||||
./common
|
||||
import ../waku_core, ../utils/tableutils, ../node/peer_manager
|
||||
|
||||
logScope:
|
||||
topics = "waku filter subscriptions"
|
||||
|
||||
Some files were not shown because too many files have changed in this diff Show More
Loading…
x
Reference in New Issue
Block a user