Integrate stream-start and stream-end signaling in worker.py and add /api/log/stream-start endpoint.

local_worker/worker.py

@@ -284,6 +284,19 @@ def send_voice_words(words):
     except Exception as e:
         print(f"[Sync] Error sending voice words to cloud: {e}")
 
+def notify_stream_start():
+    """Notify backend that the stream has started"""
+    headers = {"x-api-key": API_KEY}
+    url = f"{API_URL}/api/log/stream-start"
+    try:
+        response = requests.post(url, headers=headers, timeout=5)
+        if response.status_code == 200:
+            print("[Sync] Sent stream-start signal.")
+        else:
+            print(f"[Sync] Failed to send stream-start. Status: {response.status_code}")
+    except Exception as e:
+        print(f"[Sync] Error sending stream-start: {e}")
+
 def notify_stream_end():
     """Notify backend that the stream has ended"""
     headers = {"x-api-key": API_KEY}
@@ -570,6 +583,9 @@ if __name__ == "__main__":
     t_chat.start()
     t_sender.start()
     
+    # Notify backend that stream has started
+    notify_stream_start()
+    
     # 3. Start Audio Capture (Blocks main thread)
     try:
         if CAPTURE_METHOD == "stream":
@@ -580,6 +596,9 @@ if __name__ == "__main__":
             print(f"[Error] Unknown CAPTURE_METHOD '{CAPTURE_METHOD}'. Choose 'stream' or 'microphone'.")
     except KeyboardInterrupt:
         print("\n[Shutting Down] Gracefully stopping threads...")
+    finally:
+        # Notify backend that stream has ended
+        notify_stream_end()
         stop_flag.set()
         time.sleep(1)
         print("[Shutting Down] Done.")

server/server.js

@@ -21,6 +21,7 @@ import {
   getStreamMessageTimestamps,
   getModActionsSummaryRaw,
   syncActiveStream,
+  getOrStartActiveStream,
   getModeratorProfilesData,
   getActiveStream,
   getPendingBackfillStreams,
@@ -224,6 +225,17 @@ app.post('/api/log/mod-action', authenticateWorker, async (req, res) => {
   }
 });
 
+// Explicit start stream command
+app.post('/api/log/stream-start', authenticateWorker, async (req, res) => {
+  try {
+    const stream = await getOrStartActiveStream();
+    res.json({ success: true, streamId: stream ? stream.id : null });
+  } catch (err) {
+    console.error('[API Error] /api/log/stream-start:', err);
+    res.status(500).json({ error: 'Internal Server Error' });
+  }
+});
+
 // Explicit end stream command
 app.post('/api/log/stream-end', authenticateWorker, async (req, res) => {
   try {