From f99b9e982449df4fe7f8dcabd12e93fbf818e11b Mon Sep 17 00:00:00 2001 From: kiwiidb Date: Thu, 15 Jun 2023 12:15:00 +0200 Subject: [PATCH] payment finalizer: never break loop --- rabbitmq/rabbitmq.go | 21 --------------------- 1 file changed, 21 deletions(-) diff --git a/rabbitmq/rabbitmq.go b/rabbitmq/rabbitmq.go index 14354e1..579c074 100644 --- a/rabbitmq/rabbitmq.go +++ b/rabbitmq/rabbitmq.go @@ -8,7 +8,6 @@ import ( "io" "os" "sync" - "time" "github.com/getAlby/lndhub.go/db/models" "github.com/getsentry/sentry-go" @@ -167,33 +166,13 @@ func (client *DefaultClient) FinalizeInitializedPayments(ctx context.Context, sv client.logger.Infof("Payment finalizer: Found %d pending invoices", len(pendingInvoices)) - ticker := time.NewTicker(time.Hour) - defer ticker.Stop() - client.logger.Info("Starting payment finalizer rabbitmq consumer") for { - // Shortcircuit if no pending invoices are left - if len(pendingInvoices) == 0 { - client.logger.Info("Payment finalizer: Resolved all pending payments, exiting payment finalizer routine") - - return nil - } - select { case <-ctx.Done(): return context.Canceled - case <-ticker.C: - invoices, err := getInvoicesTable(ctx) - if err != nil { - return err - } - - pendingInvoices = invoices - - client.logger.Infof("Payment finalizer: Found %d pending invoices", len(pendingInvoices)) - case delivery, ok := <-deliveryChan: if !ok { return err