fix payment-listener: await paymentNotify and paymentWrite queue

nanopay · Oct 8, 2024 · 5ec5851 · 5ec5851
1 parent fd3ec04
commit 5ec5851
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/src/durable/payment-listener.ts b/src/durable/payment-listener.ts
@@ -106,8 +106,8 @@ export class PaymentListener extends DurableObject<Env> {
 
 		payments.push(newPayment);
 
-		this.paymentNotify(newPayment, invoice.id);
-		this.paymentWrite(newPayment, invoice, service, webhooks);
+		await this.paymentNotify(newPayment, invoice.id);
+		await this.paymentWrite(newPayment, invoice, service, webhooks);
 
 		const paid_total = payments.reduce((acc, payment) => {
 			return acc + payment.amount;
@@ -133,7 +133,7 @@ export class PaymentListener extends DurableObject<Env> {
 
 	private async paymentWrite(payment: Payment, invoice: Invoice, service: Service, webhooks: Webhook[]) {
 		// Send the payment to the worker write to the db
-		this.env.PAYMENT_WRITE_QUEUE.send({
+		await this.env.PAYMENT_WRITE_QUEUE.send({
 			invoice,
 			service,
 			webhooks,