From 97565fde02687fa57e1c1b2a1ec9c820140a847b Mon Sep 17 00:00:00 2001
From: ben <ben@arc.wales>
Date: Wed, 7 Dec 2022 10:21:45 +0000
Subject: [PATCH 1/2] Adds PoS websocket endpoint

Receives all payments to a pos
---
 lnbits/extensions/tpos/tasks.py | 12 +++++++++++-
 1 file changed, 11 insertions(+), 1 deletion(-)

diff --git a/lnbits/extensions/tpos/tasks.py b/lnbits/extensions/tpos/tasks.py
index 6369bbc7..d590762d 100644
--- a/lnbits/extensions/tpos/tasks.py
+++ b/lnbits/extensions/tpos/tasks.py
@@ -3,7 +3,7 @@ import asyncio
 from loguru import logger
 
 from lnbits.core.models import Payment
-from lnbits.core.services import create_invoice, pay_invoice
+from lnbits.core.services import create_invoice, pay_invoice, websocketUpdater
 from lnbits.helpers import get_current_extension_name
 from lnbits.tasks import register_invoice_listener
 
@@ -26,6 +26,16 @@ async def on_invoice_paid(payment: Payment) -> None:
     tpos = await get_tpos(payment.extra.get("tposId"))
     tipAmount = payment.extra.get("tipAmount")
 
+    strippedPayment = {
+        "amount":payment.amount,
+        "fee":payment.fee,
+        "checking_id":payment.checking_id,
+        "payment_hash":payment.payment_hash,
+        "bolt11":payment.bolt11,
+    }
+
+    await websocketUpdater(payment.extra.get("tposId"), str(strippedPayment))
+
     if tipAmount is None:
         # no tip amount
         return

From 44d74351639056981077b726f0a7eb421b33b7dc Mon Sep 17 00:00:00 2001
From: ben <ben@arc.wales>
Date: Wed, 7 Dec 2022 10:42:48 +0000
Subject: [PATCH 2/2] format

---
 lnbits/extensions/tpos/tasks.py | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

diff --git a/lnbits/extensions/tpos/tasks.py b/lnbits/extensions/tpos/tasks.py
index d590762d..6eb1d5d1 100644
--- a/lnbits/extensions/tpos/tasks.py
+++ b/lnbits/extensions/tpos/tasks.py
@@ -27,11 +27,11 @@ async def on_invoice_paid(payment: Payment) -> None:
     tipAmount = payment.extra.get("tipAmount")
 
     strippedPayment = {
-        "amount":payment.amount,
-        "fee":payment.fee,
-        "checking_id":payment.checking_id,
-        "payment_hash":payment.payment_hash,
-        "bolt11":payment.bolt11,
+        "amount": payment.amount,
+        "fee": payment.fee,
+        "checking_id": payment.checking_id,
+        "payment_hash": payment.payment_hash,
+        "bolt11": payment.bolt11,
     }
 
     await websocketUpdater(payment.extra.get("tposId"), str(strippedPayment))