archive legacy postgres_driver rm unnecessary code

waku-org · Jul 25, 2024 · b9b4684 · b9b4684
1 parent 7090ba8
commit b9b4684
Showing 1 changed file with 12 additions and 21 deletions.
diff --git a/waku/waku_archive_legacy/driver/postgres_driver/postgres_driver.nim b/waku/waku_archive_legacy/driver/postgres_driver/postgres_driver.nim
@@ -812,19 +812,19 @@ method deleteOldestMessagesNotWithinLimit*(
   # if execRes.isErr():
   #   return err("error in deleteOldestMessagesNotWithinLimit: " & execRes.error)
 
-  execRes = await s.writeConnPool.pgQuery(
-    """DELETE FROM messages_lookup WHERE messageHash NOT IN
-                          (
-                        SELECT messageHash FROM messages ORDER BY timestamp DESC LIMIT ?
-                          );""",
-    @[$limit],
-  )
-  if execRes.isErr():
-    return err(
-      "error in deleteOldestMessagesNotWithinLimit messages_lookup: " & execRes.error
-    )
+  # execRes = await s.writeConnPool.pgQuery(
+  #   """DELETE FROM messages_lookup WHERE messageHash NOT IN
+  #                         (
+  #                       SELECT messageHash FROM messages ORDER BY timestamp DESC LIMIT ?
+  #                         );""",
+  #   @[$limit],
+  # )
+  # if execRes.isErr():
+  #   return err(
+  #     "error in deleteOldestMessagesNotWithinLimit messages_lookup: " & execRes.error
+  #   )
 
-  debug "end of deleteOldestMessagesNotWithinLimit"
+  # debug "end of deleteOldestMessagesNotWithinLimit"
   return ok()
 
 method close*(s: PostgresDriver): Future[ArchiveDriverResult[void]] {.async.} =
@@ -871,15 +871,6 @@ proc performWriteQuery*(
 
   return ok()
 
-  let partitionName = partition.getName()
-  ## Now delete rows from the messages_lookup table
-  let timeRange = partition.getTimeRange()
-  let deleteRowsQuery =
-    "DELETE FROM messages_lookup WHERE timestamp >= " & $timeRange.beginning &
-    " AND timestamp < " & $timeRange.`end`
-  (await self.performWriteQuery(deleteRowsQuery)).isOkOr:
-    return err(fmt"error in {deleteRowsQuery}: " & $error)
-
 method decreaseDatabaseSize*(
     driver: PostgresDriver, targetSizeInBytes: int64, forceRemoval: bool = false
 ): Future[ArchiveDriverResult[void]] {.async.} =