logos-messaging/logos-messaging-nim
1
0
Fork 0
mirror of https://github.com/logos-messaging/logos-messaging-nim.git synced 2026-01-07 16:33:08 +00:00
Code Issues Packages Projects Releases Wiki Activity

deploy: 37c0b199e411492b4a241ad7f8b6679b5524ebd6

Browse Source
This commit is contained in:
LNSD 2022-09-28 12:41:35 +00:00
parent cdcb8cbd22
commit a04ebd6fa1
26 changed files with 36 additions and 45 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
tests/v2/test_jsonrpc_waku.nim
View File

@ -14,7 +14,6 @@ import
libp2p/protocols/pubsub/rpc/message libp2p/protocols/pubsub/rpc/message
import import
../../waku/v1/node/rpc/hexstrings, ../../waku/v1/node/rpc/hexstrings,
../../waku/v2/node/storage/message/message_store,
../../waku/v2/node/storage/message/waku_store_queue, ../../waku/v2/node/storage/message/waku_store_queue,
../../waku/v2/node/wakunode2, ../../waku/v2/node/wakunode2,
../../waku/v2/node/jsonrpc/[store_api, ../../waku/v2/node/jsonrpc/[store_api,

4
tests/v2/test_message_store_queue.nim
View File

@ -6,12 +6,10 @@ import
testutils/unittests, testutils/unittests,
nimcrypto/hash nimcrypto/hash
import import
../../waku/v2/node/storage/message/message_store,
../../waku/v2/node/storage/message/waku_store_queue, ../../waku/v2/node/storage/message/waku_store_queue,
../../waku/v2/protocol/waku_message, ../../waku/v2/protocol/waku_message,
../../waku/v2/protocol/waku_store, ../../waku/v2/protocol/waku_store,
../../waku/v2/utils/time, ../../waku/v2/utils/time
../../waku/v2/utils/pagination
# Helper functions # Helper functions

3
tests/v2/test_message_store_queue_pagination.nim
View File

@ -9,8 +9,7 @@ import
../../waku/v2/node/storage/message/waku_store_queue, ../../waku/v2/node/storage/message/waku_store_queue,
../../waku/v2/protocol/waku_store, ../../waku/v2/protocol/waku_store,
../../waku/v2/protocol/waku_message, ../../waku/v2/protocol/waku_message,
../../waku/v2/utils/time, ../../waku/v2/utils/time
../../waku/v2/utils/pagination
const const

2
tests/v2/test_message_store_sqlite.nim
View File

@ -12,8 +12,8 @@ import
../../waku/v2/node/storage/message/message_retention_policy_capacity, ../../waku/v2/node/storage/message/message_retention_policy_capacity,
../../waku/v2/node/storage/sqlite, ../../waku/v2/node/storage/sqlite,
../../waku/v2/protocol/waku_message, ../../waku/v2/protocol/waku_message,
../../waku/v2/protocol/waku_store/pagination,
../../waku/v2/utils/time, ../../waku/v2/utils/time,
../../waku/v2/utils/pagination,
./utils ./utils

2
tests/v2/test_message_store_sqlite_query.nim
View File

@ -9,8 +9,8 @@ import
../../waku/v2/node/storage/message/sqlite_store, ../../waku/v2/node/storage/message/sqlite_store,
../../waku/v2/node/storage/sqlite, ../../waku/v2/node/storage/sqlite,
../../waku/v2/protocol/waku_message, ../../waku/v2/protocol/waku_message,
../../waku/v2/protocol/waku_store/pagination,
../../waku/v2/utils/time, ../../waku/v2/utils/time,
../../waku/v2/utils/pagination,
./utils ./utils

2
tests/v2/test_waku_store.nim
View File

@ -12,11 +12,9 @@ import
../../waku/v2/protocol/waku_message, ../../waku/v2/protocol/waku_message,
../../waku/v2/protocol/waku_store, ../../waku/v2/protocol/waku_store,
../../waku/v2/node/storage/sqlite, ../../waku/v2/node/storage/sqlite,
../../waku/v2/node/storage/message/message_store,
../../waku/v2/node/storage/message/waku_store_queue, ../../waku/v2/node/storage/message/waku_store_queue,
../../waku/v2/node/storage/message/sqlite_store, ../../waku/v2/node/storage/message/sqlite_store,
../../waku/v2/node/peer_manager/peer_manager, ../../waku/v2/node/peer_manager/peer_manager,
../../waku/v2/utils/pagination,
../../waku/v2/utils/time, ../../waku/v2/utils/time,
../test_helpers ../test_helpers

1
tests/v2/test_waku_store_rpc_codec.nim
View File

@ -9,7 +9,6 @@ import
import import
../../waku/v2/protocol/waku_message, ../../waku/v2/protocol/waku_message,
../../waku/v2/protocol/waku_store, ../../waku/v2/protocol/waku_store,
../../waku/v2/utils/pagination,
../../waku/v2/utils/time ../../waku/v2/utils/time
const const

2
tests/v2/test_wakunode_store.nim
View File

@ -15,7 +15,6 @@ import
libp2p/protocols/pubsub/gossipsub libp2p/protocols/pubsub/gossipsub
import import
../../waku/v2/node/storage/sqlite, ../../waku/v2/node/storage/sqlite,
../../waku/v2/node/storage/message/message_store,
../../waku/v2/node/storage/message/sqlite_store, ../../waku/v2/node/storage/message/sqlite_store,
../../waku/v2/node/storage/message/waku_store_queue, ../../waku/v2/node/storage/message/waku_store_queue,
../../waku/v2/protocol/waku_message, ../../waku/v2/protocol/waku_message,
@ -23,7 +22,6 @@ import
../../waku/v2/protocol/waku_filter, ../../waku/v2/protocol/waku_filter,
../../waku/v2/node/peer_manager/peer_manager, ../../waku/v2/node/peer_manager/peer_manager,
../../waku/v2/utils/peers, ../../waku/v2/utils/peers,
../../waku/v2/utils/pagination,
../../waku/v2/utils/time, ../../waku/v2/utils/time,
../../waku/v2/node/wakunode2 ../../waku/v2/node/wakunode2

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

@ -4,7 +4,7 @@ import
std/[options,tables], std/[options,tables],
eth/keys, eth/keys,
../../protocol/waku_message, ../../protocol/waku_message,
../../utils/pagination, ../../protocol/waku_store/pagination,
../../utils/time ../../utils/time
type type

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

@ -4,10 +4,9 @@ import
std/[options, json], std/[options, json],
eth/keys, eth/keys,
../../../v1/node/rpc/hexstrings, ../../../v1/node/rpc/hexstrings,
../../protocol/waku_store,
../../protocol/waku_message, ../../protocol/waku_message,
../../protocol/waku_store,
../../utils/time, ../../utils/time,
../../utils/pagination,
../waku_payload, ../waku_payload,
./jsonrpc_types ./jsonrpc_types

1
waku/v2/node/jsonrpc/store_api.nim
View File

@ -8,7 +8,6 @@ import
../wakunode2, ../wakunode2,
../../protocol/waku_store, ../../protocol/waku_store,
../../utils/time, ../../utils/time,
../../utils/pagination,
./jsonrpc_types, ./jsonrpc_types,
./jsonrpc_utils ./jsonrpc_utils

4
waku/v2/node/storage/message/dual_message_store.nim
View File

@ -6,10 +6,10 @@ import
chronicles chronicles
import import
../../../protocol/waku_message, ../../../protocol/waku_message,
../../../utils/pagination, ../../../protocol/waku_store/pagination,
../../../protocol/waku_store/message_store,
../../../utils/time, ../../../utils/time,
../sqlite, ../sqlite,
./message_store,
./waku_store_queue, ./waku_store_queue,
./sqlite_store ./sqlite_store

2
waku/v2/node/storage/message/message_retention_policy.nim
View File

@ -3,7 +3,7 @@
import import
stew/results stew/results
import import
./message_store ../../../protocol/waku_store/message_store
type RetentionPolicyResult*[T] = Result[T, string] type RetentionPolicyResult*[T] = Result[T, string]

2
waku/v2/node/storage/message/message_retention_policy_capacity.nim
View File

@ -4,7 +4,7 @@ import
stew/results, stew/results,
chronicles chronicles
import import
./message_store, ../../../protocol/waku_store/message_store,
./message_retention_policy ./message_retention_policy
logScope: logScope:

2
waku/v2/node/storage/message/message_retention_policy_time.nim
View File

@ -6,8 +6,8 @@ import
chronicles, chronicles,
chronos chronos
import import
../../../protocol/waku_store/message_store,
../../../utils/time, ../../../utils/time,
./message_store,
./message_retention_policy ./message_retention_policy
logScope: logScope:

4
waku/v2/node/storage/message/queue_store/index.nim
View File

@ -5,8 +5,8 @@ import
nimcrypto/sha2 nimcrypto/sha2
import import
../../../../protocol/waku_message, ../../../../protocol/waku_message,
../../../../utils/time, ../../../../protocol/waku_store/pagination,
../../../../utils/pagination ../../../../utils/time
type Index* = object type Index* = object

4
waku/v2/node/storage/message/queue_store/queue_store.nim
View File

@ -7,9 +7,9 @@ import
import import
../../../../protocol/waku_message, ../../../../protocol/waku_message,
../../../../protocol/waku_store/rpc, ../../../../protocol/waku_store/rpc,
../../../../utils/pagination, ../../../../protocol/waku_store/pagination,
../../../../protocol/waku_store/message_store,
../../../../utils/time, ../../../../utils/time,
../message_store,
./index ./index

2
waku/v2/node/storage/message/sqlite_store/queries.nim
View File

@ -7,7 +7,7 @@ import
import import
../../sqlite, ../../sqlite,
../../../../protocol/waku_message, ../../../../protocol/waku_message,
../../../../utils/pagination, ../../../../protocol/waku_store/pagination,
../../../../utils/time ../../../../utils/time

4
waku/v2/node/storage/message/sqlite_store/sqlite_store.nim
View File

@ -8,10 +8,10 @@ import
chronicles chronicles
import import
../../../../protocol/waku_message, ../../../../protocol/waku_message,
../../../../utils/pagination, ../../../../protocol/waku_store/pagination,
../../../../protocol/waku_store/message_store,
../../../../utils/time, ../../../../utils/time,
../../sqlite, ../../sqlite,
../message_store,
./queries ./queries
logScope: logScope:

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

@ -25,7 +25,6 @@ import
../utils/[peers, requests, wakuenr], ../utils/[peers, requests, wakuenr],
./peer_manager/peer_manager, ./peer_manager/peer_manager,
./storage/message/waku_store_queue, ./storage/message/waku_store_queue,
./storage/message/message_store,
./storage/message/message_retention_policy, ./storage/message/message_retention_policy,
./storage/message/message_retention_policy_capacity, ./storage/message/message_retention_policy_capacity,
./storage/message/message_retention_policy_time, ./storage/message/message_retention_policy_time,
@ -819,7 +818,6 @@ when isMainModule:
./wakunode2_setup_rpc, ./wakunode2_setup_rpc,
./wakunode2_setup_sql_migrations, ./wakunode2_setup_sql_migrations,
./storage/sqlite, ./storage/sqlite,
./storage/message/message_store,
./storage/message/dual_message_store, ./storage/message/dual_message_store,
./storage/message/sqlite_store, ./storage/message/sqlite_store,
./storage/peer/waku_peer_storage ./storage/peer/waku_peer_storage

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

@ -1,9 +1,13 @@
import import
./waku_store/protocol, ./waku_store/protocol,
./waku_store/rpc, ./waku_store/rpc,
./waku_store/rpc_codec ./waku_store/rpc_codec,
./waku_store/pagination,
./waku_store/message_store
export export
protocol, protocol,
rpc, rpc,
rpc_codec rpc_codec,
pagination,
message_store

6
waku/v2/node/storage/message/message_store.nim → waku/v2/protocol/waku_store/message_store.nim
View File

@ -7,9 +7,9 @@ import
std/[options, times], std/[options, times],
stew/results stew/results
import import
../../../protocol/waku_message, ../waku_message,
../../../utils/time, ./pagination,
../../../utils/pagination ../../utils/time
type type

4
waku/v2/utils/pagination.nim → waku/v2/protocol/waku_store/pagination.nim
View File

@ -5,8 +5,8 @@ import
stew/byteutils, stew/byteutils,
nimcrypto/sha2 nimcrypto/sha2
import import
../protocol/waku_message, ../waku_message,
./time ../../utils/time
const const
MaxPageSize*: uint64 = 100 MaxPageSize*: uint64 = 100

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

@ -15,17 +15,17 @@ import
libp2p/stream/connection, libp2p/stream/connection,
metrics metrics
import import
../../node/storage/message/message_store,
../../node/storage/message/message_retention_policy, ../../node/storage/message/message_retention_policy,
../../node/storage/message/waku_store_queue, ../../node/storage/message/waku_store_queue,
../../node/peer_manager/peer_manager, ../../node/peer_manager/peer_manager,
../../utils/time, ../../utils/time,
../../utils/pagination,
../../utils/requests, ../../utils/requests,
../waku_message, ../waku_message,
../waku_swap/waku_swap, ../waku_swap/waku_swap,
./rpc, ./rpc,
./rpc_codec ./rpc_codec,
./pagination,
./message_store
declarePublicGauge waku_store_messages, "number of historical messages", ["type"] declarePublicGauge waku_store_messages, "number of historical messages", ["type"]

4
waku/v2/protocol/waku_store/rpc.nim
View File

@ -4,8 +4,8 @@ import
nimcrypto/hash nimcrypto/hash
import import
../waku_message, ../waku_message,
../../utils/pagination, ../../utils/time,
../../utils/time ./pagination
type type

4
waku/v2/protocol/waku_store/rpc_codec.nim
View File

@ -7,9 +7,9 @@ import
import import
../waku_message, ../waku_message,
../../utils/protobuf, ../../utils/protobuf,
../../utils/pagination,
../../utils/time, ../../utils/time,
./rpc ./rpc,
./pagination
const MaxRpcSize* = MaxPageSize * MaxWakuMessageSize + 64*1024 # We add a 64kB safety buffer for protocol overhead const MaxRpcSize* = MaxPageSize * MaxWakuMessageSize + 64*1024 # We add a 64kB safety buffer for protocol overhead