feat: worker and chat_mod_worker now also sync roles to /api/log/roles on every message batch

local_worker/chat_mod_worker.py

@@ -233,16 +233,35 @@ def chat_sender():
         
         if messages:
             try:
+                # 1. Send messages
                 response = requests.post(url, json={"messages": messages}, headers=headers, timeout=5)
-                if response.status_code == 200:
-                    pass  # Success
-                else:
+                if response.status_code != 200:
                     print(f"[Chat Sender] Failed to sync messages. API returned status {response.status_code}")
             except Exception as e:
                 print(f"[Chat Sender] Network error sending messages: {e}")
+
+            try:
+                # 2. Send roles for users who have at least one badge
+                roles = [
+                    {
+                        "username": m["username"],
+                        "displayName": m.get("displayName", m["username"]),
+                        "isMod": m.get("isMod", False),
+                        "isSub": m.get("isSub", False),
+                        "isVip": m.get("isVip", False),
+                        "timestamp": m.get("timestamp")
+                    }
+                    for m in messages
+                    if m.get("isMod") or m.get("isSub") or m.get("isVip")
+                ]
+                if roles:
+                    requests.post(f"{API_URL}/api/log/roles", json={"roles": roles}, headers=headers, timeout=5)
+            except Exception as e:
+                print(f"[Chat Sender] Network error sending roles: {e}")
                 
         time.sleep(3)
 
+
 def mod_action_sender():
     """Periodically sends accumulated mod actions to backend API"""
     headers = {"x-api-key": API_KEY, "Content-Type": "application/json"}

local_worker/worker.py

@@ -208,18 +208,37 @@ def chat_sender():
         
         if messages:
             try:
+                # 1. Send messages
                 url = f"{API_URL}/api/log/messages"
                 response = requests.post(url, json={"messages": messages}, headers=headers, timeout=5)
-                if response.status_code == 200:
-                    pass # Success
-                else:
+                if response.status_code != 200:
                     print(f"[Chat Sender] Failed to sync messages. API returned status {response.status_code}")
             except Exception as e:
                 print(f"[Chat Sender] Network error sending messages: {e}")
+
+            try:
+                # 2. Send roles for users who have at least one badge
+                roles = [
+                    {
+                        "username": m["username"],
+                        "displayName": m.get("displayName", m["username"]),
+                        "isMod": m.get("isMod", False),
+                        "isSub": m.get("isSub", False),
+                        "isVip": m.get("isVip", False),
+                        "timestamp": m.get("timestamp")
+                    }
+                    for m in messages
+                    if m.get("isMod") or m.get("isSub") or m.get("isVip")
+                ]
+                if roles:
+                    requests.post(f"{API_URL}/api/log/roles", json={"roles": roles}, headers=headers, timeout=5)
+            except Exception as e:
+                print(f"[Chat Sender] Network error sending roles: {e}")
                 
         # Wait 5 seconds before next sync
         time.sleep(5)
 
+
 # =========================================================================
 # AUDIO TRANSCRIBER (WHISPER)
 # =========================================================================