From 7f22cec45276abf56856916781fce9510b1fdd9a Mon Sep 17 00:00:00 2001
From: ramforth <ramforth@noreply.localhost>
Date: Mon, 17 Nov 2025 15:55:18 +0100
Subject: [PATCH] Swapping mapping for websocket return traffic

---
 chat_listener.py    | 3 ++-
 listener_manager.py | 3 ++-
 2 files changed, 4 insertions(+), 2 deletions(-)

diff --git a/chat_listener.py b/chat_listener.py
index c440c57..6d498df 100644
--- a/chat_listener.py
+++ b/chat_listener.py
@@ -2,8 +2,9 @@ from twitchio.ext import commands
 from twitchio.web import AiohttpAdapter
 
 class TwitchBot(commands.Bot):
-    def __init__(self, access_token: str, client_id: str, client_secret: str, bot_id: str, channel_name: str, websocket_manager):
+    def __init__(self, access_token: str, client_id: str, client_secret: str, bot_id: str, channel_name: str, websocket_manager, owner_id: int):
         self.websocket_manager = websocket_manager
+        self.owner_id = owner_id
         
         # Configure the internal web adapter to use a non-standard, high port
         # to avoid conflicts during development and hot-reloading.
diff --git a/listener_manager.py b/listener_manager.py
index 165f024..c264fe1 100644
--- a/listener_manager.py
+++ b/listener_manager.py
@@ -30,7 +30,8 @@ class ListenerManager:
             client_id=settings.TWITCH_CLIENT_ID,
             client_secret=settings.TWITCH_CLIENT_SECRET,
             bot_id=user.platform_user_id,
-            websocket_manager=websocket_manager
+            websocket_manager=websocket_manager,
+            owner_id=user.id
         )
         task = asyncio.create_task(bot.start())
         self.active_listeners[user.id] = task