client reset

src/App.svelte

@@ -9,6 +9,7 @@
   import Encounters from './lib/components/Pages/Encounters.svelte';
   import Pictuary from './lib/components/Pages/Pictuary.svelte';
   import type { HuggingFaceLibs, GradioLibs, GradioClient } from './lib/types';
+  import { setQwenClientResetter } from './lib/utils/qwenTimeout';
   
   // These will be loaded from window after HF libs are loaded
   let hfAuth: HuggingFaceLibs | null = $state(null);
@@ -118,6 +119,17 @@
       );
       
       authStore.setBannerMessage("");
+      
+      // Set up qwen client reset function
+      setQwenClientResetter(async () => {
+        console.log('🔄 Resetting qwen client connection...');
+        const opts = hfToken ? { hf_token: hfToken } : {};
+        qwenClient = await gradioClient.Client.connect(
+          "Qwen/Qwen3-Demo",
+          opts
+        );
+      });
+      
     } catch (err) {
       console.error(err);
       authStore.setBannerMessage(`❌ Failed to connect: ${err}`);

src/lib/utils/qwenTimeout.ts

@@ -1,6 +1,13 @@
 import pRetry, { AbortError } from 'p-retry';
 import pTimeout from 'p-timeout';
 
+// Global reference to reset qwen client
+let qwenClientResetter: (() => Promise<void>) | null = null;
+
+export function setQwenClientResetter(resetFn: () => Promise<void>) {
+  qwenClientResetter = resetFn;
+}
+
 export async function withQwenTimeout<T>(
   fn: () => Promise<T>,
   { totalTimeout = 70_000, retries = 2 } = {}
@@ -10,9 +17,26 @@ export async function withQwenTimeout<T>(
       try {
         return await pTimeout(fn(), { milliseconds: totalTimeout });
       } catch (error) {
+        // Check if this is a session/connection error that requires client reset
+        const errorMessage = (error as any)?.message || error?.toString() || '';
+        const isSessionError = errorMessage.includes('Session not found') || 
+                              errorMessage.includes('network error') ||
+                              errorMessage.includes('ERR_HTTP2_PROTOCOL_ERROR') ||
+                              errorMessage.includes('Connection errored out');
+
+        if (isSessionError && qwenClientResetter) {
+          console.log('🔄 Qwen client session error detected, resetting client...');
+          try {
+            await qwenClientResetter();
+            console.log('✅ Qwen client reset successfully');
+          } catch (resetError) {
+            console.error('❌ Failed to reset qwen client:', resetError);
+          }
+        }
+
         // Convert non-Error objects to proper Error objects for p-retry
         if (error && typeof error === 'object' && !(error instanceof Error)) {
-          const errorMessage = error.message || error.toString() || 'Network connection error';
+          const errorMessage = (error as any).message || error.toString() || 'Network connection error';
           throw new Error(errorMessage);
         }
         throw error;