From decd4cdf0aca3abec90e06530208bbc5a955ff62 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?dni=20=E2=9A=A1?= <office@dnilabs.com>
Date: Fri, 16 Feb 2024 13:47:52 +0100
Subject: [PATCH] chore: remove listener dict (#2279)

---
 lnbits/core/tasks.py |  5 +----
 lnbits/tasks.py      | 27 +--------------------------
 2 files changed, 2 insertions(+), 30 deletions(-)

diff --git a/lnbits/core/tasks.py b/lnbits/core/tasks.py
index 166580f9a..0294fe6f9 100644
--- a/lnbits/core/tasks.py
+++ b/lnbits/core/tasks.py
@@ -18,16 +18,13 @@ from lnbits.core.services import (
 )
 from lnbits.settings import get_wallet_class, settings
 from lnbits.tasks import (
-    SseListenersDict,
     create_permanent_task,
     create_task,
     register_invoice_listener,
     send_push_notification,
 )
 
-api_invoice_listeners: Dict[str, asyncio.Queue] = SseListenersDict(
-    "api_invoice_listeners"
-)
+api_invoice_listeners: Dict[str, asyncio.Queue] = {}
 
 
 def register_killswitch():
diff --git a/lnbits/tasks.py b/lnbits/tasks.py
index 3a565449d..074737124 100644
--- a/lnbits/tasks.py
+++ b/lnbits/tasks.py
@@ -58,32 +58,7 @@ async def send_push_promise(a, b) -> None:
     pass
 
 
-class SseListenersDict(dict):
-    """
-    A dict of sse listeners.
-    """
-
-    def __init__(self, name: Optional[str] = None):
-        self.name = name or f"sse_listener_{str(uuid.uuid4())[:8]}"
-
-    def __setitem__(self, key, value):
-        assert isinstance(key, str), f"{key} is not a string"
-        assert isinstance(value, asyncio.Queue), f"{value} is not an asyncio.Queue"
-        logger.trace(f"sse: adding listener {key} to {self.name}. len = {len(self)+1}")
-        return super().__setitem__(key, value)
-
-    def __delitem__(self, key):
-        logger.trace(f"sse: removing listener from {self.name}. len = {len(self)-1}")
-        return super().__delitem__(key)
-
-    _RaiseKeyError = object()  # singleton for no-default behavior
-
-    def pop(self, key, v=_RaiseKeyError) -> None:
-        logger.trace(f"sse: removing listener from {self.name}. len = {len(self)-1}")
-        return super().pop(key)
-
-
-invoice_listeners: Dict[str, asyncio.Queue] = SseListenersDict("invoice_listeners")
+invoice_listeners: Dict[str, asyncio.Queue] = {}
 
 
 # TODO: name should not be optional