waku-org/nwaku
1
0
Fork 0
mirror of https://github.com/waku-org/nwaku.git synced 2025-02-15 16:36:43 +00:00
Code Issues Packages Projects Releases Wiki Activity

deploy: 32a8ffb86744012b9cedb0e6945d85e21560d56b

Browse Source
This commit is contained in:
staheri14 2021-07-16 22:46:39 +00:00
parent 2f074a7a5c
commit a52d6f7406
4 changed files with 38 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
vendor/nim-libbacktrace/vendor/libbacktrace-upstream/libtool vendored
View File

@ -2,7 +2,7 @@
# libtool - Provide generalized library-building support services. # libtool - Provide generalized library-building support services.
# Generated automatically by config.status (libbacktrace) version-unused # Generated automatically by config.status (libbacktrace) version-unused
# Libtool was configured on host fv-az275-660: # Libtool was configured on host fv-az173-722:
# NOTE: Changes made to this file will be lost: look at ltmain.sh. # NOTE: Changes made to this file will be lost: look at ltmain.sh.
# #
# Copyright (C) 1996, 1997, 1998, 1999, 2000, 2001, 2003, 2004, 2005, # Copyright (C) 1996, 1997, 1998, 1999, 2000, 2001, 2003, 2004, 2005,

2
waku/v2/node/jsonrpc/jsonrpc_utils.nim
View File

@ -61,7 +61,7 @@ proc toWakuRelayMessage*(message: WakuMessage, symkey: Option[SymKey], privateKe
let let
keyInfo = if symkey.isSome(): KeyInfo(kind: Symmetric, symKey: symkey.get()) keyInfo = if symkey.isSome(): KeyInfo(kind: Symmetric, symKey: symkey.get())
elif privateKey.isSome(): KeyInfo(kind: Asymmetric, privKey: privateKey.get()) elif privateKey.isSome(): KeyInfo(kind: Asymmetric, privKey: privateKey.get())
else: KeyInfo(kind: None) else: KeyInfo(kind: KeyKind.None)
decoded = decodePayload(message, keyInfo) decoded = decodePayload(message, keyInfo)
WakuRelayMessage(payload: decoded.get().payload, WakuRelayMessage(payload: decoded.get().payload,

25
waku/v2/protocol/waku_store/waku_store.nim
View File

@ -4,21 +4,36 @@
{.push raises: [Defect].} {.push raises: [Defect].}
# Group by std, external then internal imports
import import
# std imports
std/[tables, times, sequtils, algorithm, options], std/[tables, times, sequtils, algorithm, options],
# external imports
bearssl, bearssl,
chronos, chronicles, metrics, stew/[results, byteutils, endians2], chronicles,
chronos,
libp2p/crypto/crypto, libp2p/crypto/crypto,
libp2p/protocols/protocol, libp2p/protocols/protocol,
libp2p/protobuf/minprotobuf, libp2p/protobuf/minprotobuf,
libp2p/stream/connection, libp2p/stream/connection,
metrics,
stew/[results, byteutils],
# internal imports
../../node/storage/message/message_store, ../../node/storage/message/message_store,
../waku_swap/waku_swap, ../../node/peer_manager/peer_manager,
./waku_store_types,
../../utils/requests, ../../utils/requests,
../../node/peer_manager/peer_manager ../waku_swap/waku_swap,
./waku_store_types
export waku_store_types, message_store
# export all modules whose types are used in public functions/types
export
options,
chronos,
bearssl,
minprotobuf,
peer_manager,
waku_store_types
declarePublicGauge waku_store_messages, "number of historical messages", ["type"] declarePublicGauge waku_store_messages, "number of historical messages", ["type"]
declarePublicGauge waku_store_peers, "number of store peers" declarePublicGauge waku_store_peers, "number of store peers"

21
waku/v2/protocol/waku_store/waku_store_types.nim
View File

@ -1,17 +1,28 @@
## Types for waku_store protocol. ## Types for waku_store protocol.
# Group by std, external then internal imports
import import
# external imports
bearssl, bearssl,
libp2p/peerinfo, libp2p/peerinfo,
libp2p/protocols/protocol, libp2p/protocols/protocol,
../waku_swap/waku_swap_types, stew/results,
../waku_message, # internal imports
../../node/storage/message/message_store, ../../node/storage/message/message_store,
../../utils/pagination, ../../utils/pagination,
../../node/peer_manager/peer_manager ../../node/peer_manager/peer_manager,
../waku_swap/waku_swap_types,
../waku_message
export waku_message # export all modules whose types are used in public functions/types
export pagination export
bearssl,
results,
peer_manager,
waku_swap_types,
message_store,
waku_message,
pagination
# Constants required for pagination ------------------------------------------- # Constants required for pagination -------------------------------------------
const MaxPageSize* = uint64(100) # Maximum number of waku messages in each page const MaxPageSize* = uint64(100) # Maximum number of waku messages in each page