feat(backend): make payment retry attempts configurable via env

- Closes #3017 - rename config variable to a proper name
interledger · Oct 14, 2024 · d68d833 · d68d833
1 parent 254784c
commit d68d833
Show file tree

Hide file tree

Showing 4 changed files with 9 additions and 4 deletions.
diff --git a/packages/backend/src/config/app.ts b/packages/backend/src/config/app.ts
@@ -187,7 +187,8 @@ export const Config = {
     'INCOMING_PAYMENT_EXPIRY_MAX_MS',
     2592000000
   ), // 30 days
-  enableSpspPaymentPointers: envBool('ENABLE_SPSP_PAYMENT_POINTERS', true)
+  enableSpspPaymentPointers: envBool('ENABLE_SPSP_PAYMENT_POINTERS', true),
+  maxOutgoingPaymentRetryAttempts: envInt('MAX_OUTGOING_PAYMENT_RETRY_ATTEMPTS', 5)
 }
 
 function parseRedisTlsConfig(

diff --git a/packages/backend/src/index.ts b/packages/backend/src/index.ts
@@ -464,6 +464,7 @@ export function initIocContainer(
 
   container.singleton('outgoingPaymentService', async (deps) => {
     return await createOutgoingPaymentService({
+      config: await deps.use('config'),
       logger: await deps.use('logger'),
       knex: await deps.use('knex'),
       accountingService: await deps.use('accountingService'),

diff --git a/packages/backend/src/open_payments/payment/outgoing/service.ts b/packages/backend/src/open_payments/payment/outgoing/service.ts
@@ -42,6 +42,7 @@ import { QuoteService } from '../../quote/service'
 import { isQuoteError } from '../../quote/errors'
 import { Pagination, SortOrder } from '../../../shared/baseModel'
 import { FilterString } from '../../../shared/filters'
+import { IAppConfig } from '../../../config/app'
 
 export interface OutgoingPaymentService
   extends WalletAddressSubresourceService<OutgoingPayment> {
@@ -59,6 +60,7 @@ export interface OutgoingPaymentService
 }
 
 export interface ServiceDependencies extends BaseService {
+  config: IAppConfig
   knex: TransactionOrKnex
   accountingService: AccountingService
   receiverService: ReceiverService

diff --git a/packages/backend/src/open_payments/payment/outgoing/worker.ts b/packages/backend/src/open_payments/payment/outgoing/worker.ts
@@ -10,8 +10,6 @@ import { trace, Span } from '@opentelemetry/api'
 // First retry waits 10 seconds, second retry waits 20 (more) seconds, etc.
 export const RETRY_BACKOFF_SECONDS = 10
 
-const MAX_STATE_ATTEMPTS = 5
-
 // Returns the id of the processed payment (if any).
 export async function processPendingPayment(
   deps_: ServiceDependencies
@@ -94,7 +92,10 @@ async function onLifecycleError(
   const error = typeof err === 'string' ? err : err.message
   const stateAttempts = payment.stateAttempts + 1
 
-  if (stateAttempts < MAX_STATE_ATTEMPTS && isRetryableError(err)) {
+  if (
+    stateAttempts < deps.config.maxOutgoingPaymentRetryAttempts &&
+    isRetryableError(err)
+  ) {
     deps.logger.warn(
       { state: payment.state, error, stateAttempts },
       'payment lifecycle failed; retrying'