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

deploy: f02c9305aefd44bf5eb9d0cc74084d44da519139

Browse Source
This commit is contained in:
LNSD 2022-09-15 19:47:57 +00:00
parent 7b378b4f86
commit 6b2e01f7ab
3 changed files with 39 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
waku/v2/node/storage/message/message_store.nim
View File

@ -46,4 +46,16 @@ method getMessagesByHistoryQuery*(
ascendingOrder = true
): MessageStoreResult[MessageStorePage] {.base.} = discard
# Store manipulation
method getMessagesCount*(ms: MessageStore): MessageStoreResult[int64] {.base.} = discard
method getOldestMessageTimestamp*(ms: MessageStore): MessageStoreResult[Timestamp] {.base.} = discard
method getNewestMessageTimestamp*(ms: MessageStore): MessageStoreResult[Timestamp] {.base.} = discard
method deleteMessagesOlderThanTimestamp*(ms: MessageStore, ts: Timestamp): MessageStoreResult[void] {.base.} = discard
method deleteOldestMessagesNotWithinLimit*(ms: MessageStore, limit: int): MessageStoreResult[void] {.base.} = discard

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

@ -158,3 +158,16 @@ method getMessagesByHistoryQuery*(
method getMessagesCount*(s: SqliteStore): MessageStoreResult[int64] =
s.db.getMessageCount()
method getOldestMessageTimestamp*(s: SqliteStore): MessageStoreResult[Timestamp] =
s.db.selectOldestReceiverTimestamp()
method getNewestMessageTimestamp*(s: SqliteStore): MessageStoreResult[Timestamp] =
s.db.selectnewestReceiverTimestamp()
method deleteMessagesOlderThanTimestamp*(s: SqliteStore, ts: Timestamp): MessageStoreResult[void] =
s.db.deleteMessagesOlderThanTimestamp(ts)
method deleteOldestMessagesNotWithinLimit*(s: SqliteStore, limit: int): MessageStoreResult[void] =
s.db.deleteOldestMessagesNotWithinLimit(limit)

14
waku/v2/node/storage/message/waku_store_queue.nim
View File

@ -430,3 +430,17 @@ method getMessagesByHistoryQuery*(
method getMessagesCount*(s: StoreQueueRef): MessageStoreResult[int64] =
ok(int64(s.len()))
method getOldestMessageTimestamp*(s: StoreQueueRef): MessageStoreResult[Timestamp] =
s.first().map(proc(msg: IndexedWakuMessage): Timestamp = msg.index.receiverTime)
method getNewestMessageTimestamp*(s: StoreQueueRef): MessageStoreResult[Timestamp] =
s.last().map(proc(msg: IndexedWakuMessage): Timestamp = msg.index.receiverTime)
method deleteMessagesOlderThanTimestamp*(s: StoreQueueRef, ts: Timestamp): MessageStoreResult[void] =
# TODO: Implement this message_store method
err("interface method not implemented")
method deleteOldestMessagesNotWithinLimit*(s: StoreQueueRef, limit: int): MessageStoreResult[void] =
# TODO: Implement this message_store method
err("interface method not implemented")