feat(backend): use cache when fetching outgoing payment in worker

interledger · Dec 2, 2024 · 3848d02 · 3848d02
1 parent 5de6208
commit 3848d02
Showing 1 changed file with 11 additions and 1 deletion.
diff --git a/packages/backend/src/open_payments/payment/outgoing/worker.ts b/packages/backend/src/open_payments/payment/outgoing/worker.ts
@@ -75,7 +75,7 @@ async function getPendingPayment(
           [RETRY_BACKOFF_SECONDS, now]
         )
     })
-    .withGraphFetched('[walletAddress, quote.asset]')
+    .withGraphFetched('quote')
   stopTimer()
   return payments[0]
 }
@@ -89,6 +89,16 @@ async function handlePaymentLifecycle(
     return
   }
 
+  const [paymentWalletAddress, quoteAsset] = await Promise.all([
+    deps.walletAddressService.get(payment.walletAddressId),
+    deps.assetService.get(payment.quote.assetId)
+  ])
+
+  payment.walletAddress = paymentWalletAddress
+  if (quoteAsset) {
+    payment.quote.asset = quoteAsset
+  }
+
   const stopTimer = deps.telemetry.startTimer('handle_sending_ms', {
     callName: 'OutoingPaymentWorker:handleSending'
   })