Skip to content

Commit 051d67c

Browse files
authored
feat(store): info message after delete (#929)
1 parent e51001f commit 051d67c

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

waku/v2/node/storage/message/waku_message_store.nim

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -59,9 +59,10 @@ proc deleteOldest(db: WakuMessageStore): MessageStoreResult[void] =
5959
return err(res.error)
6060
db.numMessages = db.storeCapacity + db.deleteWindow # sqlite3 DELETE does not return the number of deleted rows; Ideally we would subtract the number of actually deleted messages. We could run a separate COUNT.
6161

62+
info "Oldest messages deleted from DB due to overflow.", storeCapacity=db.storeCapacity, maxStore=db.storeMaxLoad, deleteWindow=db.deleteWindow
6263
when defined(debug):
6364
let numMessages = messageCount(db.database).get() # requires another SELECT query, so only run in debug mode
64-
debug "Oldest messages deleted from DB due to overflow.", storeCapacity=db.storeCapacity, maxStore=db.storeMaxLoad, deleteWindow=db.deleteWindow, messagesLeft=numMessages
65+
debug "Number of messages left after delete operation.", messagesLeft=numMessages
6566

6667
# reduce the size of the DB file after the delete operation. See: https://www.sqlite.org/lang_vacuum.html
6768
let resVacuum = db.database.query("vacuum", proc(s: ptr sqlite3_stmt) = discard)

0 commit comments

Comments
 (0)