Merge pull request #2453 from fluidity-money/develop-add-last-check-w…

…orker-server-failsafe Rename table to be more specific
fluidity-money · Dec 14, 2023 · 1b80aa3 · 1b80aa3
2 parents efef2a2 + fbdbb78
commit 1b80aa3
Show file tree

Hide file tree

Showing 3 changed files with 11 additions and 3 deletions.
diff --git a/database/101-up-postgres/20231214173441-failsafe_rename_transaction_hash_index.sql b/database/101-up-postgres/20231214173441-failsafe_rename_transaction_hash_index.sql
@@ -0,0 +1,8 @@
+
+-- migrate:up
+
+ALTER TABLE failsafe_transaction_hash RENAME TO failsafe_transaction_hash_log_index;
+
+-- migrate:down
+
+ALTER TABLE failsafe_transaction_hash_log_index RENAME TO failsafe_transaction_hash;
diff --git a/lib/databases/postgres/failsafe/failsafe.go b/lib/databases/postgres/failsafe/failsafe.go
@@ -7,7 +7,7 @@ package failsafe
 // Context to use for when failsafe acquisition goes wrong
 const Context = "POSTGRES/FAILSAFE"
 
-// TableFailsafeTransactionHashIndex to be used as the final check before
+// TableFailsafeTransactionHashLogIndex to be used as the final check before
 // a side effectful action where duplication could possibly happen at the
 // infra level
-const TableFailsafeTransactionHashIndex = "failsafe_transaction_hash_index"
+const TableFailsafeTransactionHashLogIndex = "failsafe_transaction_hash_log_index"
diff --git a/lib/databases/postgres/failsafe/transaction_hash_index.go b/lib/databases/postgres/failsafe/transaction_hash_index.go
@@ -33,7 +33,7 @@ func CommitTransactionHashIndex(transactionHash ethereum.Hash, logIndex misc.Big
 			$3
 		)`,
 
-		TableFailsafeTransactionHashIndex,
+		TableFailsafeTransactionHashLogIndex,
 	)
 
 	workerId := util.GetWorkerId()
-Original file line number
+Diff line change
@@ Expand Up @@
     			$3
     		)`,
-    		TableFailsafeTransactionHashIndex,
+    		TableFailsafeTransactionHashLogIndex,
     	)
     	workerId := util.GetWorkerId()
@@ Expand Down @@