From 533b4f19fb350ad2680cc7cefa5d86617fec87a8 Mon Sep 17 00:00:00 2001
From: Victor Castell <0x@vcastellm.xyz>
Date: Wed, 11 Dec 2024 14:33:58 +0000
Subject: [PATCH] maybe fix
---
aggsender/db/aggsender_db_storage.go | 20 +++++++++++++++++++-
1 file changed, 19 insertions(+), 1 deletion(-)
diff --git a/aggsender/db/aggsender_db_storage.go b/aggsender/db/aggsender_db_storage.go
index 02c6d8767..6d1854688 100644
--- a/aggsender/db/aggsender_db_storage.go
+++ b/aggsender/db/aggsender_db_storage.go
@@ -182,10 +182,28 @@ func (a *AggSenderSQLStorage) moveCertificateToHistoryOrDelete(tx db.Querier,
// DeleteCertificate deletes a certificate from the storage
func (a *AggSenderSQLStorage) DeleteCertificate(ctx context.Context, certificateID common.Hash) error {
- if err := deleteCertificate(tx, certificateID); err != nil {
+ tx, err := db.NewTx(ctx, a.db)
+ if err != nil {
return err
}
+ defer func() {
+ if err != nil {
+ if errRllbck := tx.Rollback(); errRllbck != nil {
+ a.logger.Errorf(errWhileRollbackFormat, errRllbck)
+ }
+ }
+ }()
+
+ if err = deleteCertificate(tx, certificateID); err != nil {
+ return err
+ }
+
+ if err = tx.Commit(); err != nil {
+ return err
+ }
+
a.logger.Debugf("deleted certificate - CertificateID: %s", certificateID)
+
return nil
}