features: add kill + monitor endpoints

app.py

@@ -39,6 +39,8 @@ def frame_processor(session_id: str):
         next_frame_time = time.time()
         
         while True:
+            if session_id not in sessions:
+                break
             # control framerate
             if time.time() >= next_frame_time:
                 ret, frame = cap.read()
@@ -115,5 +117,28 @@ def video_feed():
         
     return Response(stream_with_context(stream_mjpeg(session_id)), mimetype="multipart/x-mixed-replace; boundary=frame")
 
+@app.get("/sessions")
+def get_sessions():
+    global sessions
+    return {
+        "sessions": [session.id for session in sessions.values()]
+    }
+
+@app.get("/threads")
+def get_threads():
+    threads = threading.enumerate()
+    return {
+        "threads_count": len(threads)
+    }
+
+@app.get("/killall")
+def kill_all():
+    global sessions
+    sessions.clear()
+    for thread in threading.enumerate():
+        if thread is not threading.current_thread():
+            thread.join(0.1)
+    return {"status": "all sessions cleared and threads joined"}
+
 if __name__ == "__main__":
     app.run(host="0.0.0.0", port=PORT, threaded=True)