blah

frontend/src/lib/components/VideoInput.svelte

@@ -12,7 +12,7 @@
   let videoFrameCallbackId: number;
   const WIDTH = 512;
   const HEIGHT = 512;
-  const THROTTLE_FPS = 10;
+  const THROTTLE_FPS = 6;
 
   onDestroy(() => {
     if (videoFrameCallbackId) videoEl.cancelVideoFrameCallback(videoFrameCallbackId);

frontend/src/lib/lcmLive.ts

@@ -41,6 +41,7 @@ export const lcmLiveActions = {
                             const userId = data.userId;
                             lcmLiveStatus.set(LCMLiveStatus.CONNECTED);
                             streamId.set(userId);
+                            resolve(userId);
                             break;
                         case "timeout":
                             console.log("timeout");

frontend/src/lib/store.ts

@@ -1,4 +1,7 @@
 
-import { writable, type Writable } from 'svelte/store';
+import {
+    writable, type Writable, get
+} from 'svelte/store';
 
 export const pipelineValues = writable({} as Record<string, any>);
+export const getPipelineValues = () => get(pipelineValues);

frontend/src/routes/+page.svelte

@@ -15,7 +15,7 @@
     onFrameChangeStore,
     MediaStreamStatusEnum
   } from '$lib/mediaStream';
-  import { pipelineValues } from '$lib/store';
+  import { getPipelineValues } from '$lib/store';
 
   let pipelineParams: FieldProps[];
   let pipelineInfo: PipelineInfo;
@@ -33,17 +33,8 @@
     isImageMode = pipelineInfo.input_mode.default === PipelineMode.IMAGE;
     maxQueueSize = settings.max_queue_size;
     pipelineParams = pipelineParams.filter((e) => e?.disabled !== true);
-    console.log('PARAMS', pipelineParams);
-    console.log('SETTINGS', pipelineInfo);
   }
-  console.log('isImageMode', isImageMode);
 
-  $: {
-    console.log('lcmLiveState', $lcmLiveStatus);
-  }
-  $: {
-    console.log('mediaStreamState', $mediaStreamStatus);
-  }
   // send Webcam stream to LCM if image mode
   $: {
     if (
@@ -51,7 +42,7 @@
       $lcmLiveStatus === LCMLiveStatus.CONNECTED &&
       $mediaStreamStatus === MediaStreamStatusEnum.CONNECTED
     ) {
-      lcmLiveActions.send($pipelineValues);
+      lcmLiveActions.send(getPipelineValues());
       lcmLiveActions.send($onFrameChangeStore.blob);
     }
   }
@@ -67,13 +58,16 @@
   //     lcmLiveActions.send($pipelineValues);
   //   }
   // }
+  let disabled = false;
   async function toggleLcmLive() {
     if (!isLCMRunning) {
       if (isImageMode) {
         await mediaStreamActions.enumerateDevices();
         await mediaStreamActions.start();
       }
+      disabled = true;
       await lcmLiveActions.start();
+      disabled = false;
     } else {
       if (isImageMode) {
         mediaStreamActions.stop();
@@ -126,7 +120,7 @@
     </header>
     <PipelineOptions {pipelineParams}></PipelineOptions>
     <div class="flex gap-3">
-      <Button on:click={toggleLcmLive}>
+      <Button on:click={toggleLcmLive} {disabled}>
         {#if isLCMRunning}
           Stop
         {:else}

user_queue.py

@@ -42,6 +42,13 @@ class UserData:
             return None
 
     def delete_user(self, user_id: UUID):
+        user_session = self.data_content[user_id]
+        queue = user_session["queue"]
+        while not queue.empty():
+            try:
+                queue.get_nowait()
+            except asyncio.QueueEmpty:
+                continue
         if user_id in self.data_content:
             del self.data_content[user_id]