From 31bd6d71c02f253159d5836f355c7c1caf743a1f Mon Sep 17 00:00:00 2001 From: Ivan FB <128452529+Ivansete-status@users.noreply.github.com> Date: Sun, 9 Jun 2024 23:09:23 +0200 Subject: [PATCH] chore: Minor enhancements (#2789) * archive.nim: reduce the database report interval from 1 to 30 min This counts the number of rows with "select count(1) from messages" which is quite intense and we shouldn't run it every minute * aside cleanup --- apps/networkmonitor/networkmonitor_config.nim | 1 - waku/waku_archive/archive.nim | 2 +- waku/waku_archive/driver/sqlite_driver/sqlite_driver.nim | 2 -- 3 files changed, 1 insertion(+), 4 deletions(-) diff --git a/apps/networkmonitor/networkmonitor_config.nim b/apps/networkmonitor/networkmonitor_config.nim index d56a4941b..8e76b6f32 100644 --- a/apps/networkmonitor/networkmonitor_config.nim +++ b/apps/networkmonitor/networkmonitor_config.nim @@ -169,7 +169,6 @@ proc parseCmdArg*(T: type EthRpcUrl, s: string): T = var wsPattern = re2"^(wss?):\/\/((localhost)|([\w_-]+(?:(?:\.[\w_-]+)+)))(:[0-9]{1,5})?([\w.,@?^=%&:\/~+#-]*[\w@?^=%&\/~+#-])*" if regex.match(s, wsPattern): - echo "here" raise newException( ValueError, "Websocket RPC URL is not supported, Please use an HTTP URL" ) diff --git a/waku/waku_archive/archive.nim b/waku/waku_archive/archive.nim index fa395c62e..90a04e321 100644 --- a/waku/waku_archive/archive.nim +++ b/waku/waku_archive/archive.nim @@ -29,7 +29,7 @@ const WakuArchiveDefaultRetentionPolicyInterval* = chronos.minutes(30) # Metrics reporting - WakuArchiveDefaultMetricsReportInterval* = chronos.minutes(1) + WakuArchiveDefaultMetricsReportInterval* = chronos.minutes(30) # Message validation # 20 seconds maximum allowable sender timestamp "drift" diff --git a/waku/waku_archive/driver/sqlite_driver/sqlite_driver.nim b/waku/waku_archive/driver/sqlite_driver/sqlite_driver.nim index b817282f5..e9072ceef 100644 --- a/waku/waku_archive/driver/sqlite_driver/sqlite_driver.nim +++ b/waku/waku_archive/driver/sqlite_driver/sqlite_driver.nim @@ -94,8 +94,6 @@ method getMessagesV2*( maxPageSize = DefaultPageSize, ascendingOrder = true, ): Future[ArchiveDriverResult[seq[ArchiveRow]]] {.async, deprecated.} = - echo "here" - let cursor = cursor.map(toDbCursor) let rowsRes = s.db.selectMessagesByHistoryQueryWithLimit(