Fix delete tables in block extractor

Author: ufoscout

src/evm-block-extractor/src/database/big_query_db_client.rs

@@ -274,6 +274,7 @@ impl DatabaseClient for BigQueryDbClient {
         delete_table(BQ_BLOCKS_TABLE_ID.to_owned()).await?;
         delete_table(BQ_TRANSACTIONS_TABLE_ID.to_owned()).await?;
         delete_table(BQ_KEY_VALUE_TABLE_ID.to_owned()).await?;
+        delete_table(BQ_CERTIFIED_BLOCKS_TABLE_ID.to_owned()).await?;
 
         self.create_tables_if_not_present().await
     }

src/evm-block-extractor/src/database/postgres_db_client.rs

@@ -76,9 +76,11 @@ impl DatabaseClient for PostgresDbClient {
 
     async fn clear(&self) -> anyhow::Result<()> {
         log::warn!("Postgres tables are being cleared");
-        sqlx::query("TRUNCATE TABLE EVM_BLOCK, EVM_TRANSACTION, EVM_KEY_VALUE_DATA")
-            .execute(&self.pool)
-            .await?;
+        sqlx::query(
+            "TRUNCATE TABLE EVM_BLOCK, EVM_TRANSACTION, EVM_KEY_VALUE_DATA, CERTIFIED_EVM_BLOCK",
+        )
+        .execute(&self.pool)
+        .await?;
 
         Ok(())
     }

src/evm-block-extractor/tests/tests/database_client_it.rs

@@ -560,23 +560,45 @@ async fn test_insert_and_fetch_last_block_certified_data() {
             data: block_2,
         };
 
-        db_client
-            .insert_certified_block_data(result_1.clone())
-            .await
-            .unwrap();
-        assert_eq!(
-            result_1,
-            db_client.get_last_certified_block_data().await.unwrap()
-        );
+        // There should be no certified block when the database is empty
+        {
+            // Act
+            let certified_data = db_client.get_last_certified_block_data().await;
 
-        db_client
-            .insert_certified_block_data(result_2.clone())
-            .await
-            .unwrap();
-        assert_eq!(
-            result_2,
-            db_client.get_last_certified_block_data().await.unwrap()
-        );
+            // Assert
+            assert!(certified_data.is_err());
+        }
+
+        // Insert certified blocks
+        {
+            db_client
+                .insert_certified_block_data(result_1.clone())
+                .await
+                .unwrap();
+            assert_eq!(
+                result_1,
+                db_client.get_last_certified_block_data().await.unwrap()
+            );
+
+            db_client
+                .insert_certified_block_data(result_2.clone())
+                .await
+                .unwrap();
+            assert_eq!(
+                result_2,
+                db_client.get_last_certified_block_data().await.unwrap()
+            );
+        }
+
+        // There should be no certified blocks when the database is cleared
+        {
+            // Act
+            db_client.clear().await.unwrap();
+            let certified_data = db_client.get_last_certified_block_data().await;
+
+            // Assert
+            assert!(certified_data.is_err());
+        }
     })
     .await;
 }