Refactor Broadcaster initialization and improve message processing

- Updated the Broadcaster class to use a more descriptive attribute name for initialization.
- Replaced the event instantiation with a direct import from gevent for clarity.
- Ensured consistent use of gevent.sleep for message processing delays.

Author: robin-rpr

utils/socket.py

@@ -3,9 +3,10 @@
 from utils.kafka import consumer, producer
 from flask import current_app as app
 from collections import defaultdict
+from gevent.event import Event
+from gevent.lock import RLock
 from flask_sock import Sock
 import gevent
-from gevent.lock import RLock
 import time
 import json
 
@@ -25,12 +26,12 @@ def __new__(cls, *args, **kwargs):
         return cls._instance
 
     def __init__(self):
-        if not hasattr(self, 'initialized'):
+        if not hasattr(self, 'init'):
             self.subscriptions = defaultdict(set)
-            self._stop_event = gevent.event.Event()
             self._broadcaster_greenlet = None
+            self._stop_event = Event()
             self._lock = RLock()
-            self.initialized = True
+            self.init = True
 
     def init_app(self, app):
         self.app = app
@@ -76,7 +77,7 @@ def _run(self):
                     # Reduce batch size and timeout for more frequent processing
                     msgs = consumer.consume(1000, timeout=0.1)
                     if not msgs:
-                        gevent.sleep(0.1)  # Use gevent.sleep instead of time.sleep
+                        gevent.sleep(0.1)
                         continue
 
                     # Process messages in smaller batches