Add mutex locks to prevent db transaction conflicts

pkg/modules/paymaster/reputation.go

@@ -4,6 +4,7 @@ package paymaster
 
 import (
 	"errors"
+	"sync"
 
 	mapset "github.com/deckarep/golang-set/v2"
 	"github.com/dgraph-io/badger/v3"
@@ -15,12 +16,14 @@ import (
 // UserOperation.
 type Reputation struct {
 	db *badger.DB
+	mu *sync.Mutex
 }
 
 // New returns an instance of a Reputation object to track and appropriately process userOps by paymaster
 // status.
 func New(db *badger.DB) *Reputation {
-	return &Reputation{db}
+	mu := &sync.Mutex{}
+	return &Reputation{db, mu}
 }
 
 // CheckStatus returns a UserOpHandler that is used by the Client to determine if the userOp is allowed based
@@ -37,7 +40,9 @@ func (r *Reputation) CheckStatus() modules.UserOpHandlerFunc {
 				return nil
 			}
 
+			r.mu.Lock()
 			status, err := getStatus(txn, paymaster)
+			r.mu.Unlock()
 			if err != nil {
 				return err
 			}
@@ -62,6 +67,8 @@ func (r *Reputation) IncOpsSeen() modules.UserOpHandlerFunc {
 				return nil
 			}
 
+			r.mu.Lock()
+			defer r.mu.Unlock()
 			return incrementOpsSeenByPaymaster(txn, paymaster)
 		})
 	}
@@ -87,6 +94,8 @@ func (r *Reputation) IncOpsIncluded() modules.BatchHandlerFunc {
 				}
 			}
 
+			r.mu.Lock()
+			defer r.mu.Unlock()
 			return incrementOpsIncludedByPaymasters(txn, c, ps.ToSlice()...)
 		})
 	}

pkg/modules/relay/relayer.go

@@ -6,6 +6,7 @@ import (
 	"fmt"
 	"math/big"
 	"net/http"
+	"sync"
 	"time"
 
 	"github.com/dgraph-io/badger/v3"
@@ -45,6 +46,7 @@ type Relayer struct {
 	bannedThreshold  int
 	bannedTimeWindow time.Duration
 	waitTimeout      time.Duration
+	mu               *sync.Mutex
 }
 
 // New initializes a new EOA relayer for sending batches to the EntryPoint with IP throttling protection.
@@ -66,6 +68,7 @@ func New(
 		bannedThreshold:  DefaultBanThreshold,
 		bannedTimeWindow: DefaultBanTimeWindow,
 		waitTimeout:      DefaultWaitTimeout,
+		mu:               &sync.Mutex{},
 	}
 }
 
@@ -185,6 +188,8 @@ func (r *Relayer) MapUserOpHashToClientID() gin.HandlerFunc {
 				return err
 			}
 
+			r.mu.Lock()
+			defer r.mu.Unlock()
 			return incrementOpsSeenByClientID(txn, cid, r.bannedTimeWindow)
 		})
 		if err != nil {
@@ -260,6 +265,8 @@ func (r *Relayer) SendUserOperation() modules.BatchHandlerFunc {
 
 			hashes := getUserOpHashesFromOps(ctx.EntryPoint, ctx.ChainID, ctx.Batch...)
 			del = append([]string{}, hashes...)
+			r.mu.Lock()
+			defer r.mu.Unlock()
 			return incrementOpsIncludedByUserOpHashes(txn, r.bannedTimeWindow, hashes...)
 		})
 		if err != nil {