relayrace lost bulletproof [goreleaser]

synapsecns · Jul 8, 2024 · 4afaee1 · 4afaee1
1 parent 03d95f9
commit 4afaee1
Show file tree

Hide file tree

Showing 2 changed files with 18 additions and 4 deletions.
diff --git a/services/rfq/relayer/reldb/base/quote.go b/services/rfq/relayer/reldb/base/quote.go
@@ -93,7 +93,7 @@ func (s Store) UpdateQuoteRequestStatus(ctx context.Context, id [32]byte, status
 	if prevStatus == nil {
 		req, err := s.GetQuoteRequestByID(ctx, id)
 		if err != nil {
-			return fmt.Errorf("could not get quote: %w", err)
+			return fmt.Errorf("could not get quote: %w", reldb.ErrNoQuoteForID)
 		}
 		prevStatus = &req.Status
 	}

diff --git a/services/rfq/relayer/service/chainindexer.go b/services/rfq/relayer/service/chainindexer.go
@@ -2,7 +2,9 @@ package service
 
 import (
 	"context"
+	"errors"
 	"fmt"
+	"strings"
 
 	"github.com/ethereum/go-ethereum/accounts/abi/bind"
 	"github.com/ethereum/go-ethereum/common"
@@ -85,7 +87,7 @@ func (r *Relayer) runChainIndexer(ctx context.Context, chainID int) (err error)
 			// it wasn't me
 			if event.Relayer != r.signer.Address() {
 				//nolint: wrapcheck
-				return r.db.UpdateQuoteRequestStatus(ctx, event.TransactionId, reldb.RelayRaceLost, nil)
+				return r.setRelayRaceLost(ctx, event.TransactionId)
 			}
 
 			err = r.handleRelayLog(ctx, event)
@@ -99,7 +101,7 @@ func (r *Relayer) runChainIndexer(ctx context.Context, chainID int) (err error)
 			// it wasn't me
 			if event.Relayer != r.signer.Address() {
 				//nolint: wrapcheck
-				return r.db.UpdateQuoteRequestStatus(ctx, event.TransactionId, reldb.RelayRaceLost, nil)
+				return r.setRelayRaceLost(ctx, event.TransactionId)
 			}
 
 			err = r.handleProofProvided(ctx, event)
@@ -113,7 +115,7 @@ func (r *Relayer) runChainIndexer(ctx context.Context, chainID int) (err error)
 			// it wasn't me
 			if event.Relayer != r.signer.Address() {
 				//nolint: wrapcheck
-				return r.db.UpdateQuoteRequestStatus(ctx, event.TransactionId, reldb.RelayRaceLost, nil)
+				return r.setRelayRaceLost(ctx, event.TransactionId)
 			}
 
 			err = r.handleDepositClaimed(ctx, event)
@@ -212,3 +214,15 @@ func (r *Relayer) handleDepositClaimed(ctx context.Context, event *fastbridge.Fa
 	}
 	return nil
 }
+
+func (r *Relayer) setRelayRaceLost(ctx context.Context, transactionID [32]byte) error {
+	err := r.db.UpdateQuoteRequestStatus(ctx, transactionID, reldb.RelayRaceLost, nil)
+	// quote does not exist, no need to update status
+	if err != nil && (errors.Is(err, reldb.ErrNoQuoteForID) || strings.Contains(err.Error(), reldb.ErrNoQuoteForID.Error())) {
+		return nil
+	}
+	if err != nil {
+		return fmt.Errorf("could not set relay race lost: %w", err)
+	}
+	return nil
+}