Skip to content

Commit

Permalink
fix event sourcing bug [goreleaser] #2410
Browse files Browse the repository at this point in the history
  • Loading branch information
trajan0x committed Apr 2, 2024
1 parent 1ea21df commit dcd7e8c
Showing 1 changed file with 15 additions and 0 deletions.
15 changes: 15 additions & 0 deletions services/rfq/relayer/service/handlers.go
Original file line number Diff line number Diff line change
Expand Up @@ -285,6 +285,21 @@ func (q *QuoteRequestHandler) handleProofPosted(ctx context.Context, _ trace.Spa
return nil
}

// make sure relayer hasn't already proved. This is neeeded in case of an abrupt halt in event sourcing
// note: this assumes caller has already checked the sender is the relayer.
bs, err := q.Origin.Bridge.BridgeStatuses(&bind.CallOpts{Context: ctx}, request.TransactionID)
if err != nil {
return fmt.Errorf("could not get bridge status: %w", err)
}

Check warning on line 293 in services/rfq/relayer/service/handlers.go

View check run for this annotation

Codecov / codecov/patch

services/rfq/relayer/service/handlers.go#L290-L293

Added lines #L290 - L293 were not covered by tests

if bs == fastbridge.RelayerProved.Int() {
err = q.db.UpdateQuoteRequestStatus(ctx, request.TransactionID, reldb.ClaimPending)
if err != nil {
return fmt.Errorf("could not update request status: %w", err)
}
return nil

Check warning on line 300 in services/rfq/relayer/service/handlers.go

View check run for this annotation

Codecov / codecov/patch

services/rfq/relayer/service/handlers.go#L295-L300

Added lines #L295 - L300 were not covered by tests
}

canClaim, err := q.Origin.Bridge.CanClaim(&bind.CallOpts{Context: ctx}, request.TransactionID, q.RelayerAddress)
if err != nil {
return fmt.Errorf("could not check if can claim: %w", err)
Expand Down

0 comments on commit dcd7e8c

Please sign in to comment.