coin distribution: fix infinity loop

ice-blockchain · Dec 28, 2023 · 5b8aef0 · 5b8aef0
1 parent 12278af
commit 5b8aef0
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 6 deletions.
diff --git a/coin-distribution/coin_distribution.go b/coin-distribution/coin_distribution.go
@@ -16,13 +16,13 @@ import (
 	"github.com/ice-blockchain/wintr/log"
 )
 
-func (d *databaseConfig) MustDisable(ctx context.Context, reason string) {
-	for err := d.Disable(ctx); err != nil; err = d.Disable(ctx) {
+func (d *databaseConfig) MustDisable(reason string) {
+	for err := d.Disable(context.Background()); err != nil; err = d.Disable(context.Background()) {
 		log.Error(errors.Wrap(err, "failed to disable coinDistributer"))
 		stdlibtime.Sleep(stdlibtime.Millisecond)
 	}
 
-	log.Error(sendCoinDistributionsProcessingStoppedDueToUnrecoverableFailureSlackMessage(ctx, reason),
+	log.Error(sendCoinDistributionsProcessingStoppedDueToUnrecoverableFailureSlackMessage(context.Background(), reason),
 		"failed to sendCoinDistributionsProcessingStoppedDueToUnrecoverableFailureSlackMessage")
 }
 

diff --git a/coin-distribution/processor.go b/coin-distribution/processor.go
@@ -228,7 +228,7 @@ func (proc *coinProcessor) Do(ctx context.Context, num int64) (*batch, error) {
 		if err2 := proc.BatchMarkRejected(ctx, num, data); err2 != nil {
 			log.Error(errors.Wrapf(err2, "worker [%v]: failed to mark batch %v as rejected", num, data.ID))
 		}
-		proc.MustDisable(ctx, err.Error())
+		proc.MustDisable(err.Error())
 
 		return data, err
 	}
@@ -338,7 +338,7 @@ func (proc *coinProcessor) Controller(ctx context.Context) {
 			err := proc.RunWorkers(ctx)
 			if err != nil {
 				log.Error(errors.Wrapf(err, "controller: worker(s) failed"))
-				proc.MustDisable(ctx, err.Error())
+				proc.MustDisable(err.Error())
 			} else if !proc.HasPendingTransactions(ctx, ethApiStatusNew) {
 				log.Error(errors.Wrapf(sendCurrentCoinDistributionsFinishedBeingSentToEthereumSlackMessage(ctx),
 					"failed to sendCurrentCoinDistributionsFinishedBeingSentToEthereumSlackMessage"))

diff --git a/coin-distribution/tracker.go b/coin-distribution/tracker.go
@@ -84,7 +84,7 @@ func (ct *coinTracker) ProcessTransactionsHashes(ctx context.Context, hashes []*
 		if err != nil {
 			msg = err.Error()
 		}
-		ct.MustDisable(ctx, fmt.Sprintf("some transactions failed: %v", msg))
+		ct.MustDisable(fmt.Sprintf("some transactions failed: %v", msg))
 		delete(statuses, ethTxStatusFailed)
 	}