fix: use tx

ethersphere · Jul 10, 2023 · 65b17bf · 65b17bf
1 parent 6493036
commit 65b17bf
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/pkg/storer/reserve.go b/pkg/storer/reserve.go
@@ -150,8 +150,8 @@ func (db *DB) evictionWorker(ctx context.Context) {
 						"total_evicted", evicted,
 					)
 
-					err = db.Execute(ctx, func(st internal.Storage) error {
-						return st.IndexStore().Delete(&expiredBatchItem{BatchID: batchID})
+					err = db.Execute(ctx, func(tx internal.Storage) error {
+						return tx.IndexStore().Delete(&expiredBatchItem{BatchID: batchID})
 					})
 					if err != nil {
 						db.logger.Error(err, "delete expired batch", "batch", hex.EncodeToString(batchID))
@@ -324,7 +324,7 @@ func (db *DB) EvictBatch(ctx context.Context, batchID []byte) error {
 	}
 
 	err := db.Execute(ctx, func(tx internal.Storage) error {
-		return db.repo.IndexStore().Put(&expiredBatchItem{BatchID: batchID})
+		return tx.IndexStore().Put(&expiredBatchItem{BatchID: batchID})
 	})
 	if err != nil {
 		return fmt.Errorf("save expired batch: %w", err)