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 new file mode 100644 index 000000000..aa3810d5c --- /dev/null +++ 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 index 690bc02d8..41ab4ff6a 100644 --- 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 index fa9c711bd..92884ba7d 100644 --- 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()