deleting entries fixes if script restarts

cowprotocol · Aug 13, 2024 · ea28651 · ea28651
1 parent e89681f
commit ea28651
Show file tree

Hide file tree

Showing 3 changed files with 13 additions and 4 deletions.
diff --git a/raw_token_imbalances.log b/raw_token_imbalances.log
diff --git a/src/sql/delete_entries_max_block.sql b/src/sql/delete_entries_max_block.sql
@@ -2,10 +2,10 @@ BEGIN;
 
 DELETE FROM raw_token_imbalances
 WHERE chain_name = :chain_name 
-AND block_number = :block_number;
+AND block_number >= :block_number;
 
 DELETE FROM slippage_prices
 WHERE chain_name = :chain_name
-AND block_number = :block_number;
+AND block_number >= :block_number;
 
 COMMIT;
diff --git a/src/sql/select_max_block.sql b/src/sql/select_max_block.sql
@@ -1,2 +1,11 @@
-SELECT MAX(block_number) FROM raw_token_imbalances
-WHERE chain_name = :chain_name;
+SELECT 
+    MIN(max_block_number) AS min_max_block_number
+FROM (
+    SELECT MAX(block_number) AS max_block_number 
+    FROM raw_token_imbalances
+    WHERE chain_name = :chain_name
+    UNION ALL
+    SELECT MAX(block_number) AS max_block_number 
+    FROM slippage_prices
+    WHERE chain_name = :chain_name
+) AS max_blocks;