routing: add context to reloadPayment method
This commit is contained in:
1 file changed
+3
-4
@@ -250,7 +250,7 @@ lifecycle:
|
|||||||
}
|
}
|
||||||
|
|
||||||
// We update the payment state on every iteration.
|
// We update the payment state on every iteration.
|
||||||
currentPayment, ps, err := p.reloadPayment()
|
currentPayment, ps, err := p.reloadPayment(cleanupCtx)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return exitWithErr(err)
|
return exitWithErr(err)
|
||||||
}
|
}
|
||||||
@@ -1163,11 +1163,10 @@ func (p *paymentLifecycle) reloadInflightAttempts(
|
|||||||
}
|
}
|
||||||
|
|
||||||
// reloadPayment returns the latest payment found in the db (control tower).
|
// reloadPayment returns the latest payment found in the db (control tower).
|
||||||
func (p *paymentLifecycle) reloadPayment() (paymentsdb.DBMPPayment,
|
func (p *paymentLifecycle) reloadPayment(
|
||||||
|
ctx context.Context) (paymentsdb.DBMPPayment,
|
||||||
*paymentsdb.MPPaymentState, error) {
|
*paymentsdb.MPPaymentState, error) {
|
||||||
|
|
||||||
ctx := context.TODO()
|
|
||||||
|
|
||||||
// Read the db to get the latest state of the payment.
|
// Read the db to get the latest state of the payment.
|
||||||
payment, err := p.router.cfg.Control.FetchPayment(ctx, p.identifier)
|
payment, err := p.router.cfg.Control.FetchPayment(ctx, p.identifier)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
|||||||
Reference in new issue
Block a user