fix

internal/db/expiry.go

@@ -10,11 +10,11 @@ import (
 	"go.mongodb.org/mongo-driver/mongo/options"
 )
 
-func (db *Database) FindExpiredDelegations(ctx context.Context, btcTipHeight uint64, limit int64) ([]model.TimeLockDocument, error) {
+func (db *Database) FindExpiredDelegations(ctx context.Context, btcTipHeight uint64) ([]model.TimeLockDocument, error) {
 	client := db.client.Database(db.dbName).Collection(model.TimeLockCollection)
 	filter := bson.M{"expire_height": bson.M{"$lte": btcTipHeight}}
 
-	opts := options.Find().SetLimit(limit) // to prevent large result sets
+	opts := options.Find().SetLimit(db.cfg.MaxPaginationLimit) // to prevent large result sets
 	cursor, err := client.Find(ctx, filter, opts)
 	if err != nil {
 		return nil, err

internal/db/interface.go

@@ -11,7 +11,7 @@ import (
 type DbInterface interface {
 	Ping(ctx context.Context) error
 	FindExpiredDelegations(
-		ctx context.Context, btcTipHeight uint64, limit int64,
+		ctx context.Context, btcTipHeight uint64,
 	) ([]model.TimeLockDocument, error)
 	DeleteExpiredDelegation(
 		ctx context.Context, id primitive.ObjectID,

internal/services/pollers.go

@@ -78,10 +78,7 @@ func (s *Service) processExpiredDelegations(ctx context.Context) *types.Error {
 
 	// Process a single batch of expired delegations without pagination.
 	// Since we delete each delegation after processing it, pagination is not needed.
-	// Delegations are deleted to prevent duplicate processing in subsequent poller runs.
-	// The batch size is configured via ExpiryChecker.BatchSize in the config.
-	limit := s.cfg.Pollers.ExpiryChecker.BatchSize
-	expiredDelegations, err := s.db.FindExpiredDelegations(ctx, uint64(btcTip), limit)
+	expiredDelegations, err := s.db.FindExpiredDelegations(ctx, uint64(btcTip))
 	if err != nil {
 		log.Error().Err(err).Msg("Error finding expired delegations")
 		return types.NewInternalServiceError(err)