RFQ Relayer: check for db status mismatch (#2769)

* Feat: check for status mismatch * [goreleaser] --------- Co-authored-by: Trajan0x <[email protected]>
synapsecns · Jun 23, 2024 · d3ef268 · d3ef268
1 parent 87afd9b
commit d3ef268
Showing 1 changed file with 14 additions and 0 deletions.
diff --git a/services/rfq/relayer/service/statushandler.go b/services/rfq/relayer/service/statushandler.go
@@ -109,6 +109,20 @@ func (r *Relayer) mutexMiddleware(next func(ctx context.Context, span trace.Span
 		}
 		defer unlocker.Unlock()
 
+		// make sure the status has not changed since we last saw it
+		dbReq, err := r.db.GetQuoteRequestByID(ctx, req.TransactionID)
+		if err != nil {
+			return fmt.Errorf("could not get request: %w", err)
+		}
+		if dbReq.Status != req.Status {
+			span.SetAttributes(
+				attribute.Bool("status_changed", true),
+				attribute.String("db_status", dbReq.Status.String()),
+				attribute.String("handler_status", req.Status.String()),
+			)
+			return nil
+		}
+
 		return next(ctx, span, req)
 	}
 }