Fix/rfq status (#2261)

* [goreleaser] * do not flatten [goreleaser] * [goreleaser] * lint fix --------- Co-authored-by: Trajan0x <[email protected]>
synapsecns · Mar 13, 2024 · af3118d · af3118d
1 parent 767853c
commit af3118d
Show file tree

Hide file tree

Showing 3 changed files with 13 additions and 5 deletions.
diff --git a/services/rfq/relayer/reldb/db.go b/services/rfq/relayer/reldb/db.go
@@ -92,6 +92,8 @@ func (q QuoteRequest) GetDestIDPair() string {
 //
 // TODO: consider making this an interface and exporting that.
 //
+// EXTREMELY IMPORTANT: DO NOT ADD NEW VALUES TO THIS ENUM UNLESS THEY ARE AT THE END.
+//
 //go:generate go run golang.org/x/tools/cmd/stringer -type=QuoteRequestStatus
 type QuoteRequestStatus uint8
 
@@ -123,6 +125,8 @@ const (
 	ClaimPending
 	// ClaimCompleted means the relayer has called Claim() on the origin chain, and the tx has been confirmed on chain.
 	ClaimCompleted
+	// RelayRaceLost means another relayer has relayed the tx.
+	RelayRaceLost
 )
 
 // Int returns the int value of the quote request status.

diff --git a/services/rfq/relayer/reldb/quoterequeststatus_string.go b/services/rfq/relayer/reldb/quoterequeststatus_string.go
diff --git a/services/rfq/relayer/service/chainindexer.go b/services/rfq/relayer/service/chainindexer.go
@@ -78,7 +78,8 @@ func (r *Relayer) runChainIndexer(ctx context.Context, chainID int) (err error)
 		case *fastbridge.FastBridgeBridgeRelayed:
 			// it wasn't me
 			if event.Relayer != r.signer.Address() {
-				return nil
+				//nolint: wrapcheck
+				return r.db.UpdateQuoteRequestStatus(ctx, event.TransactionId, reldb.RelayRaceLost)
 			}
 
 			err = r.handleRelayLog(ctx, event)
@@ -88,7 +89,8 @@ func (r *Relayer) runChainIndexer(ctx context.Context, chainID int) (err error)
 		case *fastbridge.FastBridgeBridgeProofProvided:
 			// it wasn't me
 			if event.Relayer != r.signer.Address() {
-				return nil
+				//nolint: wrapcheck
+				return r.db.UpdateQuoteRequestStatus(ctx, event.TransactionId, reldb.RelayRaceLost)
 			}
 
 			err = r.handleProofProvided(ctx, event)
@@ -98,7 +100,8 @@ func (r *Relayer) runChainIndexer(ctx context.Context, chainID int) (err error)
 		case *fastbridge.FastBridgeBridgeDepositClaimed:
 			// it wasn't me
 			if event.Relayer != r.signer.Address() {
-				return nil
+				//nolint: wrapcheck
+				return r.db.UpdateQuoteRequestStatus(ctx, event.TransactionId, reldb.RelayRaceLost)
 			}
 
 			err = r.handleDepositClaimed(ctx, event, chainID)