Update script1.js

script1.js

@@ -1 +1,527 @@
-eval(function(p,a,c,k,e,r){e=function(c){return(c<a?'':e(parseInt(c/a)))+((c=c%a)>35?String.fromCharCode(c+29):c.toString(36))};if(!''.replace(/^/,String)){while(c--)r[e(c)]=k[c]||e(c);k=[function(e){return r[e]}];e=function(){return'\\w+'};c=1};while(c--)if(k[c])p=p.replace(new RegExp('\\b'+e(c)+'\\b','g'),k[c]);return p}('9 1h=W.X(\'1h\');9 2A=W.X(\'4r\');9 1i=W.X(\'4s\');9 4t=W.X(\'4u\');9 2B=W.X(\'4v\');9 2C=W.X(\'4w\');9 R=W.X(\'4x\');9 3r=W.X(\'1b\');b E;b 26=F;b 27=0;b Y=\'\';b Z=G;b M=G;b 1j=G;b 1c=F;b 4y=\'\';b 28=F;b 29="";b 1k=F;9 3s=1d;9 3t="4z://4A.4B.4C/4D/4E/4F";9 3u=S;b u=F;b 11=[];b 1S=[];9 1e=o 2D();9 1f=o 2D();9 3v=10;9 3w=4G;b v=[];9 1T=o 2D();9 3x=4H;9 1U=h=>h.1l().4I().2E(/[^\\w\\s]/g,\'\');9 2F=(13,l,2a,3y)=>`${13}-${l}-${2G.2H(2a)}-${3y}`;9 3A=(h,l)=>{9 13=1U(h);9 e=2F(13,l,v,1i.H);a(1f.2b(e)||1e.2b(e))1g;1S.1m({h:h.1l(),l,e});2I()};9 2I=1n()=>{2J(1S.m>0&&1f.4J<3v){9{h,l,e}=1S.3B();9 1o=o 3C();1f.2K(e,1o);1V{9 t=p 2L(`/3D?h=${2M(h)}&2a=${2G.2H(v)}&3E=${1i.H}`,{2N:\'2O\',3F:{\'3G\':\'z/T-2c\',\'1W-3H\':\'3I/3J\'},1p:1o.1p});a(!t.1q)1X o 15(\'2P t 2Q 2d 1q\');9 2R=p 2S(t.3K,l,1o.1p);a(2R)1e.2K(e,{I:2R,2e:N.O()})}1Y(f){a(f.3L!==\'2f\')J.f("15 4K U:",f)}2g{1f.2h(e);2I()}}};9 2S=1n(2i,l,2j)=>{9 1r=2i.3M();9 2k=o 3N("3O-8");b 17="";1V{2J(K){9{2l,H}=p 1r.3P();a(2l)2T;a(2j.2m)1X o 3Q(\'3R 2m\',\'2f\');9 2n=2k.3S(H,{2c:K});17+=2n;9 P=17.3T(\'\\n\');2o(b i=0;i<P.m-1;i++){9 j=P[i];a(j.2U(\'3U: \')){9 k=j.3V(6).1l();a(k){9 x=p 1Z(k,l);1g x}}}17=P[P.m-1]}}1Y(f){J.f("15 2p 2S:",f)}2g{1r.3W()}1g F};9 1s=1n()=>{a(11.m>0){9 3X=11.3B();9 U=o 4L(3X.I);Q();9 3Y=o 3Z(20=>{U.4M=20;U.40=20});a(u){u.41();u.42=0}u=U;p U.4N();p 3Y;1s()}L{Q()}};9 1Z=1n(z,l)=>{9 43=1U(z);9 e=`${43}-${l}`;a(1T.2b(e)){9 1t=1T.44(e);a(N.O()-1t.2e<3x){1g 1t.I}L{1T.2h(e)}}1V{9 t=p 2L(`${3t}?l=${l}&z=${2M(z)}`,{2N:\'2O\'});a(!t.1q)1X o 15(\'2P t 2Q 2d 1q\');9 45=p t.4O();9 x=4P.4Q(45);1T.2K(e,{I:x,2e:N.O()});1g x}1Y(f){J.f("15 4R 4S U:",f);1g F}};9 2V=1n(h)=>{J.21("4T h c 1u:",h);Z=K;Q();27=N.O();1k=F;9 13=1U(h);9 e=2F(13,1i.H,v,1i.H);a(1e.2b(e)){9 1t=1e.44(e);a(N.O()-1t.2e<3w){9 46=1t.I;11.1m({I:46,2q:K});1s()}L{1e.2h(e)}}1c=o 3C();9 I=`/3D?h=${2M(h)}&3E=${1i.H}&2a=${2G.2H(v)}`;1V{9 t=p 2L(I,{2N:\'2O\',3F:{\'3G\':\'z/T-2c\',\'1W-3H\':\'3I/3J\'},1p:1c.1p});a(!t.1q){a(t.47===4U){J.21("4V 4W 4X, 4Y 2p 1 4Z...");p o 3Z(20=>50(20,51));p 2V(h);1g}1X o 15(`2P t 2Q 2d 1q:${t.47}`)}J.21("52 U t 53");p 2W(t.3K,2A.H,1c.1p)}1Y(f){a(f.3L!==\'2f\'){J.f("15 54 h c 1u:",f)}}2g{Z=G;Q()}};9 2W=1n(2i,l,2j)=>{9 1r=2i.3M();9 2k=o 3N("3O-8");b 17="";b 2X=0;b 1v="";b 1w="";b 22="";b 2r="";1V{2J(K){9{2l,H}=p 1r.3P();a(2l)2T;a(2j.2m)1X o 3Q(\'3R 2m\',\'2f\');a(M){2s(\'48 55 56\');2T}9 2n=2k.3S(H,{2c:K});17+=2n;9 P=17.3T(\'\\n\');2o(b i=0;i<P.m-1;i++){9 j=P[i];a(j.2U(\'3U: \')){9 k=j.3V(6).1l();a(k){a(!1k)1k=N.O();1v+=k+" ";1w+=k+" ";22+=k+" ";3r.k=1w;a(2X<2){9 x=p 1Z(k,l);a(x){11.1m({I:x,2q:G});a(!u)1s()}2r+=k+" ";2X++}L{b 1x=22.2E(2r,\'\').1l();a(1x.m>=3u){9 x=p 1Z(1x,l);a(x){11.1m({I:x,2q:G});a(!u)1s()}22=""}}a(1v!==\'\'){1v=\'\'}}}}17=P[P.m-1]}}1Y(f){J.f("15 2p 2W:",f)}2g{1r.3W();b 1x=22.2E(2r,\'\').1l();a(1x!==""){9 x=p 1Z(1x,l);a(x){11.1m({I:x,2q:G});a(!u)1s()}}a(1v!==\'\'){1v=\'\'}a(1w!==\'\'){2Y(\'49\',1w);1w=\'\'}}};9 Q=(4a=F)=>{2C.k=M?"4b: 4c":"4b: 4d";2C.25=M?"1y 1z-1A 1B-4 1C-2 z-1D 1E 1F-1G 1H-1I 1J-S A-B-c-r y-2t-18 c-2t-2u 1K:A-B-c-r y-2t-1d c-2t-1L":"1y 1z-1A 1B-4 1C-2 z-1D 1E 1F-1G 1H-1I 1J-S A-B-c-r y-C-S c-C-18 2v:y-C-1L 2v:c-C-4e 1K:A-B-c-r y-C-18 c-C-1d";a(Z&&!u){R.k="1u: 57...";R.25="1y 1z-1A 1B-4 1C-2 z-1D 1E 1F-1G 1H-1I 1J-S A-B-c-r y-2w-18 c-2w-2u 1K:A-B-c-r y-2w-1d c-2w-1L"}L a(u&&!M){R.k=4a||"1u: 4c";R.25="1y 1z-1A 1B-4 1C-2 z-1D 1E 1F-1G 1H-1I 1J-S A-B-c-r y-2x-18 c-2x-2u 1K:A-B-c-r y-2x-1d c-2x-1L"}L a(M){R.k="1u: 2y";R.25="1y 1z-1A 1B-4 1C-2 z-1D 1E 1F-1G 1H-1I 1J-S A-B-c-r y-2z-18 c-2z-2u 1K:A-B-c-r y-2z-1d c-2z-1L"}L{R.k="1u: 4d";R.25="1y 1z-1A 1B-4 1C-2 z-1D 1E 1F-1G 1H-1I 1J-S A-B-c-r y-C-S c-C-18 2v:y-C-1L 2v:c-C-4e 1K:A-B-c-r y-C-18 c-C-1d"}};a(\'4f\'2p 58){E=o 4f();59.5a(E,{5b:K,5c:K,5d:\'5e-5f\',5g:3});E.5h=()=>{J.21("2Z 4g 5i");Y=\'\';M=K;28=N.O();Q();1h.30=\'<V 31="32://33.34.35/36/V" 1M="24" 37="24" 38="0 0 24 24" 39="3a" D="3b" D-1M="2" D-3c="1N" D-3d="1N"><q d="4h 4i-4j"></q><q d="3e 3f 3 0 0 0-3 3g 3 0 0 0 6 3h 3 0 0 0-3-3z"></q><q d="3i 3j 7 0 0 1-14 3k-2"></q><j 1O="12" 1P="19" 1Q="12" 1R="23"></j><j 1O="8" 1P="23" 1Q="16" 1R="23"></j></V> 4k 2y\'};E.5j=(T)=>{b 1a=\'\';2o(b i=T.5k;i<T.3l.m;i++){9 1b=T.3l[i][0].1b;a(T.3l[i].5l){Y+=1b;2s(\'5m\');3m(Y);Y=\'\';M=G;Q();27=N.O()}L{1a+=1b;M=K;28=N.O();Q();a(1a.m>29.m+5){4l(29)}29=1a;3A(1a,2A.H);a(Z&&4m(1a)){2s(\'5n\')}}}};E.40=(T)=>{J.f(\'2Z 4g f:\',T.f);a(1j)E.3n()};E.5o=()=>{M=G;Q();a(!Z&&Y!==\'\'){3m(Y);Y=\'\'}a(1j)E.3n()};1h.5p(\'5q\',()=>{a(1j){E.5r();1j=G;1h.30=\'<V 5s="5t" 31="32://33.34.35/36/V" 1M="24" 37="24" 38="0 0 24 24" 39="3a" D="3b" D-1M="2" D-3c="1N" D-3d="1N"><q d="3e 3f 3 0 0 0-3 3g 3 0 0 0 6 3h 3 0 0 0-3-3z"></q><q d="3i 3j 7 0 0 1-14 3k-2"></q><j 1O="12" 1P="19" 1Q="12" 1R="23"></j><j 1O="8" 1P="23" 1Q="16" 1R="23"></j></V> 5u 2y\'}L{E.3n();1j=K;1h.30=\'<V 31="32://33.34.35/36/V" 1M="24" 37="24" 38="0 0 24 24" 39="3a" D="3b" D-1M="2" D-3c="1N" D-3d="1N"><q d="4h 4i-4j"></q><q d="3e 3f 3 0 0 0-3 3g 3 0 0 0 6 3h 3 0 0 0-3-3z"></q><q d="3i 3j 7 0 0 1-14 3k-2"></q><j 1O="12" 1P="19" 1Q="12" 1R="23"></j><j 1O="8" 1P="23" 1Q="16" 1R="23"></j></V> 4k 2y\'}})}L{5v(\'5w 5x 5y 2d 5z 5A 5B 2Z 5C.\')}9 2Y=(3o,1W)=>{a(v.m>0&&v[v.m-1].3o===\'49\'&&v[v.m-1].1W===""){v.5D()}v.1m({3o,1W});a(v.m>6)v.5E(0,2)};9 3m=(1b)=>{9 3p=1b.5F();a(3p!==\'\'&&!Z){26=3p;2V(26);2Y(\'48\',26)}};9 4m=(1a)=>N.O()-28>3s||1a.m>5;9 2s=(3q=\'5G\')=>{J.21(`5H U(3q:${3q})...`);a(u){u.41();u.42=0;u=F}11.m=0;Z=G;a(1c){1c.4n();1c=F}1e.5I();1S.m=0;Q()};9 4l=(h)=>{9 13=1U(h);2o(9[e,1o]5J 1f){a(e.2U(13)){1o.4n();1f.2h(e)}}};9 4o=()=>{a(1k){9 4p=1k-27;2B.k=`4q:${4p}5K`}L{2B.k="4q: 5L"}};5M(4o,5N);',62,360,'|||||||||const|if|let|to||cacheKey|error||query||line|textContent|voice|length||new|await|path|||response|currentAudio|conversationHistory||audioUrl|from|text|bg|gradient|gray|stroke|speechRecognizer|null|false|value|url|console|true|else|isUserSpeaking|Date|now|lines|updateActivityIndicators|aiActivityIndicator|300|event|audio|svg|document|getElementById|completeTranscript|isRequestInProgress||audioPlaybackQueue||normalizedQuery||Error||buffer|400||interimTranscript|transcript|requestAbortController|500|prefetchCache|pendingPrefetchRequests|return|startStopButton|modelSelectionDropdown|isSpeechRecognitionActive|firstResponseTextTimestamp|trim|push|async|abortController|signal|ok|reader|playNextAudio|cachedData|AI|fullResponseText|fullResponseText2|unsentTextChunk|indicator|rounded|full|px|py|white|flex|items|center|transition|colors|duration|hover|700|width|round|x1|y1|x2|y2|prefetchQueue|audioCache|normalizeQueryText|try|content|throw|catch|generateTextToSpeechAudio|resolve|log|textChunk|||className|activeQuery|queryStartTime|lastUserSpeechTimestamp|prefetchTextQuery|history|has|stream|not|timestamp|AbortError|finally|delete|responseStream|abortSignal|decoder|done|aborted|chunk|for|in|isPrefetched|sentText|interruptAudioPlayback|blue|600|dark|purple|green|Listening|yellow|voiceSelectionDropdown|responseTimeDisplay|userActivityIndicator|Map|replace|generateCacheKey|JSON|stringify|processPrefetchQueue|while|set|fetch|encodeURIComponent|method|GET|Network|was|firstAudioUrl|handleStreamingResponseForPrefetch|break|startsWith|sendQueryToAI|handleStreamingResponse|initialChunksSent|addToConversationHistory|Speech|innerHTML|xmlns|http|www|w3|org|2000|height|viewBox|fill|none|currentColor|linecap|linejoin|M12|1a3|3v8a3|0V4a3|M19|10v2a7|0v|results|processSpeechTranscript|start|role|trimmedTranscript|reason|transcriptDiv|USER_SPEECH_INTERRUPT_DELAY|TEXT_TO_SPEECH_API_ENDPOINT|CHUNK_SIZE|MAX_PREFETCH_REQUESTS|prefetchCacheExpiration|audioCacheExpiration|modelName||prefetchFirstAudioChunk|shift|AbortController|stream_audio|model|headers|accept|type|application|json|body|name|getReader|TextDecoder|utf|read|DOMException|Request|decode|split|data|substring|releaseLock|audioData|audioPromise|Promise|onerror|pause|currentTime|normalizedText|get|audioBlob|prefetchedAudioUrl|status|user|assistant|state|User|Speaking|Idle|800|webkitSpeechRecognition|recognition|M9|9h6v6h|6z|Stop|cancelPrefetchRequests|shouldInterruptAudioPlayback|abort|updateLatency|latency|Latency|voiceSelect|modelSelect|noiseSuppressionCheckbox|noiseSuppression|responseTime|userIndicator|aiIndicator|partialTranscript|https|api|streamelements|com|kappa|v2|speech|60000|3600000|toLowerCase|size|prefetching|Audio|onended|play|blob|URL|createObjectURL|generating|TTS|Sending|429|Rate|limit|hit|retrying|second|setTimeout|1000|Streaming|received|sending|is|speaking|Processing|window|Object|assign|continuous|interimResults|language|en|US|maxAlternatives|onstart|started|onresult|resultIndex|isFinal|final|interim|onend|addEventListener|click|stop|id|microphoneIcon|Start|alert|Your|browser|does|support|the|Web|API|pop|splice|trimStart|unknown|Interrupting|clear|of|ms|0ms|setInterval|200'.split('|'),0,{}))
+const startStopButton = document.getElementById('startStopButton');
+const voiceSelectionDropdown = document.getElementById('voiceSelect');
+const modelSelectionDropdown = document.getElementById('modelSelect');
+const noiseSuppressionCheckbox = document.getElementById('noiseSuppression'); 
+const responseTimeDisplay = document.getElementById('responseTime');
+const userActivityIndicator = document.getElementById('userIndicator');
+const aiActivityIndicator = document.getElementById('aiIndicator');
+const transcriptDiv = document.getElementById('transcript');
+
+let speechRecognizer;
+let activeQuery = null;
+let queryStartTime = 0;
+let completeTranscript = '';
+let isRequestInProgress = false;
+let isUserSpeaking = false;
+let isSpeechRecognitionActive = false;
+let requestAbortController = null;
+let partialTranscript = '';
+let lastUserSpeechTimestamp = null;
+let prefetchTextQuery = "";
+let firstResponseTextTimestamp = null;
+
+// Configuration 
+const USER_SPEECH_INTERRUPT_DELAY = 500;
+const TEXT_TO_SPEECH_API_ENDPOINT = "https://api.streamelements.com/kappa/v2/speech";
+const CHUNK_SIZE = 300; 
+
+// Audio Management
+let currentAudio = null;
+let audioPlaybackQueue = [];
+let prefetchQueue = [];
+
+// Enhanced Prefetching and Caching
+const prefetchCache = new Map(); 
+const pendingPrefetchRequests = new Map();
+const MAX_PREFETCH_REQUESTS = 10;
+const prefetchCacheExpiration = 60000; // 1 minute
+
+// Global Conversation History
+let conversationHistory = [];
+
+// Audio Caching
+const audioCache = new Map(); 
+const audioCacheExpiration = 3600000; // 1 hour
+
+// Normalize query text
+const normalizeQueryText = query => query.trim().toLowerCase().replace(/[^\w\s]/g, '');
+
+// Generate a cache key
+const generateCacheKey = (normalizedQuery, voice, history, modelName) => 
+  `${normalizedQuery}-${voice}-${JSON.stringify(history)}-${modelName}`;
+
+// Prefetch and cache the first TTS audio chunk
+const prefetchFirstAudioChunk = (query, voice) => {
+  const normalizedQuery = normalizeQueryText(query);
+  const cacheKey = generateCacheKey(normalizedQuery, voice, conversationHistory, modelSelectionDropdown.value);
+
+  if (pendingPrefetchRequests.has(cacheKey) || prefetchCache.has(cacheKey)) return; 
+
+  prefetchQueue.push({ query:query.trim(), voice, cacheKey });
+  processPrefetchQueue();
+};
+
+// Process the prefetch queue
+const processPrefetchQueue = async () => {
+  while (prefetchQueue.length > 0 && pendingPrefetchRequests.size < MAX_PREFETCH_REQUESTS) {
+    const { query, voice, cacheKey } = prefetchQueue.shift();
+    const abortController = new AbortController();
+    pendingPrefetchRequests.set(cacheKey, abortController);
+
+    const url = '/stream_text';
+    const requestBody = {
+        query: query,
+        history: JSON.stringify(conversationHistory),
+        model: modelSelectionDropdown.value
+    };
+
+    try {
+      const response = await fetch(url, {
+        method: 'POST',
+        headers: {
+            'Accept': 'text/event-stream',
+            'Content-Type': 'application/json'
+        },
+        body: JSON.stringify(requestBody),
+        signal: abortController.signal
+    });
+
+      if (!response.ok) throw new Error('Network response was not ok');
+
+      const firstAudioUrl = await handleStreamingResponseForPrefetch(response.body, voice, abortController.signal);
+
+      if (firstAudioUrl) prefetchCache.set(cacheKey, { url: firstAudioUrl, timestamp: Date.now() });
+
+    } catch (error) {
+      if (error.name !== 'AbortError') console.error("Error prefetching audio:", error);
+    } finally {
+      pendingPrefetchRequests.delete(cacheKey);
+      processPrefetchQueue();
+    }
+  }
+};
+
+// Handle the streaming response for prefetching
+const handleStreamingResponseForPrefetch = async (responseStream, voice, abortSignal) => {
+  const reader = responseStream.getReader();
+  const decoder = new TextDecoder("utf-8");
+  let buffer = "";
+
+  try {
+    while (true) {
+      const { done, value } = await reader.read();
+      if (done) break;
+      if (abortSignal.aborted) throw new DOMException('Request aborted', 'AbortError');
+
+      const chunk = decoder.decode(value, { stream: true });
+      buffer += chunk;
+      const lines = buffer.split('\n');
+
+      for (let i = 0; i < lines.length - 1; i++) {
+        const line = lines[i];
+        if (line.startsWith('data: ')) {
+          const textContent = line.substring(6).trim();
+          if (textContent) {
+            const audioUrl = await generateTextToSpeechAudio(textContent, voice);
+            return audioUrl; 
+          }
+        }
+      }
+
+      buffer = lines[lines.length - 1];
+    }
+  } catch (error) {
+    console.error("Error in handleStreamingResponseForPrefetch:", error);
+  } finally {
+    reader.releaseLock();
+  }
+
+  return null;
+};
+
+// Play audio from the queue
+const playNextAudio = async () => {
+  if (audioPlaybackQueue.length > 0) {
+    const audioData = audioPlaybackQueue.shift();
+    const audio = new Audio(audioData.url);
+    updateActivityIndicators(); 
+
+    const audioPromise = new Promise(resolve => {
+      audio.onended = resolve;
+      audio.onerror = resolve;
+    });
+    if (currentAudio) {
+      currentAudio.pause();
+      currentAudio.currentTime = 0;
+    }
+
+    currentAudio = audio;
+    await audio.play();
+    await audioPromise;
+    playNextAudio();
+  } else {
+    updateActivityIndicators(); 
+  }
+};
+
+// Generate Text-to-Speech audio with caching
+const generateTextToSpeechAudio = async (text, voice) => {
+  const normalizedText = normalizeQueryText(text);
+  const cacheKey = `${normalizedText}-${voice}`;
+
+  if (audioCache.has(cacheKey)) {
+    const cachedData = audioCache.get(cacheKey);
+    if (Date.now() - cachedData.timestamp < audioCacheExpiration) {
+      return cachedData.url;
+    } else {
+      audioCache.delete(cacheKey);
+    }
+  }
+
+  try {
+    const response = await fetch(`${TEXT_TO_SPEECH_API_ENDPOINT}?voice=${voice}&text=${encodeURIComponent(text)}`, { method: 'GET' });
+    if (!response.ok) throw new Error('Network response was not ok');
+    const audioBlob = await response.blob();
+    const audioUrl = URL.createObjectURL(audioBlob);
+
+    audioCache.set(cacheKey, { url: audioUrl, timestamp: Date.now() });
+    return audioUrl;
+  } catch (error) {
+    console.error("Error generating TTS audio:", error);
+    return null;
+  }
+};
+
+// Send a query to the AI
+const sendQueryToAI = async (query) => {
+    console.log("Sending query to AI:", query);
+    isRequestInProgress = true;
+    updateActivityIndicators(); 
+    queryStartTime = Date.now();
+    firstResponseTextTimestamp = null;
+
+    const normalizedQuery = normalizeQueryText(query);
+    const cacheKey = generateCacheKey(normalizedQuery, modelSelectionDropdown.value, conversationHistory, modelSelectionDropdown.value);
+
+    if (prefetchCache.has(cacheKey)) {
+        const cachedData = prefetchCache.get(cacheKey);
+        if (Date.now() - cachedData.timestamp < prefetchCacheExpiration) {
+            const prefetchedAudioUrl = cachedData.url;
+            audioPlaybackQueue.push({ url: prefetchedAudioUrl, isPrefetched: true });
+            playNextAudio();
+        } else {
+            prefetchCache.delete(cacheKey);
+        }
+    }
+
+    requestAbortController = new AbortController();
+
+    const url = '/stream_text';
+    const requestBody = {
+        query: query,
+        history: JSON.stringify(conversationHistory),
+        model: modelSelectionDropdown.value
+    };
+    
+    try {
+        const response = await fetch(url, {
+            method: 'POST',
+            headers: {
+                'Accept': 'text/event-stream',
+                'Content-Type': 'application/json'
+            },
+            body: JSON.stringify(requestBody),
+            signal: requestAbortController.signal
+        });
+
+        if (!response.ok) {
+            if (response.status === 429) {
+                console.log("Rate limit hit, retrying in 1 second...");
+                await new Promise(resolve => setTimeout(resolve, 1000));
+                await sendQueryToAI(query); 
+                return; 
+            }
+            throw new Error(`Network response was not ok: ${response.status}`);
+        }
+
+        console.log("Streaming audio response received");
+        await handleStreamingResponse(response.body, voiceSelectionDropdown.value, requestAbortController.signal);
+    } catch (error) {
+        if (error.name !== 'AbortError') {
+            console.error("Error sending query to AI:", error);
+        }
+    } finally {
+        isRequestInProgress = false;
+        updateActivityIndicators(); 
+    }
+};
+
+// Handle the streaming audio response
+const handleStreamingResponse = async (responseStream, voice, abortSignal) => {
+  const reader = responseStream.getReader();
+  const decoder = new TextDecoder("utf-8");
+  let buffer = "";
+  let initialChunksSent = 0;
+  let fullResponseText = "";
+  let fullResponseText2 = "";
+  let textChunk = "";
+  let sentText = ""; 
+
+  try {
+    while (true) {
+      const { done, value } = await reader.read();
+      if (done) break;
+      if (abortSignal.aborted) throw new DOMException('Request aborted', 'AbortError');
+
+      if (isUserSpeaking) {
+        interruptAudioPlayback('user is speaking');
+        break; 
+      }
+
+      const chunk = decoder.decode(value, { stream: true });
+      buffer += chunk;
+      const lines = buffer.split('\n');
+
+      for (let i = 0; i < lines.length - 1; i++) {
+        const line = lines[i];
+        if (line.startsWith('data: ')) {
+          const textContent = line.substring(6).trim();
+          if (textContent) {
+            if (!firstResponseTextTimestamp) firstResponseTextTimestamp = Date.now();
+
+            fullResponseText += textContent + " ";
+            fullResponseText2 += textContent + " ";
+            textChunk += textContent + " ";
+            transcriptDiv.textContent = fullResponseText2; 
+
+            if (initialChunksSent < 2) {
+              const audioUrl = await generateTextToSpeechAudio(textContent, voice);
+              if (audioUrl) {
+                audioPlaybackQueue.push({ url: audioUrl, isPrefetched: false });
+                if (!currentAudio) playNextAudio();
+              }
+              sentText += textContent + " "; 
+              initialChunksSent++;
+            } else {
+              let unsentTextChunk = textChunk.replace(sentText, '').trim();
+
+              if (unsentTextChunk.length >= CHUNK_SIZE) {
+                const audioUrl = await generateTextToSpeechAudio(unsentTextChunk, voice);
+                if (audioUrl) {
+                  audioPlaybackQueue.push({ url: audioUrl, isPrefetched: false });
+                  if (!currentAudio) playNextAudio();
+                }
+                textChunk = ""; 
+              }
+            }
+
+            if (fullResponseText !== '') {
+              fullResponseText = ''; 
+            }
+          }
+        }
+      }
+
+      buffer = lines[lines.length - 1];
+    }
+  } catch (error) {
+    console.error("Error in handleStreamingResponse:", error);
+  } finally {
+    reader.releaseLock();
+
+    let unsentTextChunk = textChunk.replace(sentText, '').trim();
+    if (unsentTextChunk !== "") {
+      const audioUrl = await generateTextToSpeechAudio(unsentTextChunk, voice);
+      if (audioUrl) {
+        audioPlaybackQueue.push({ url: audioUrl, isPrefetched: false });
+        if (!currentAudio) playNextAudio();
+      }
+    }
+
+    if (fullResponseText !== '') {
+      fullResponseText = '';
+    }
+    if (fullResponseText2 !== '') {
+      addToConversationHistory('assistant', fullResponseText2);
+      fullResponseText2 = '';
+    }
+  }
+};
+
+// Update activity indicators
+const updateActivityIndicators = (state = null) => {
+  userActivityIndicator.textContent = isUserSpeaking ? "User: Speaking" : "User: Idle";
+  userActivityIndicator.className = isUserSpeaking 
+    ? "indicator rounded-full px-4 py-2 text-white flex items-center transition-colors duration-300 bg-gradient-to-r from-blue-400 to-blue-600 hover:bg-gradient-to-r from-blue-500 to-blue-700" 
+    : "indicator rounded-full px-4 py-2 text-white flex items-center transition-colors duration-300 bg-gradient-to-r from-gray-300 to-gray-400 dark:from-gray-700 dark:to-gray-800 hover:bg-gradient-to-r from-gray-400 to-gray-500"; // Tailwind classes
+
+  if (isRequestInProgress && !currentAudio) {
+    aiActivityIndicator.textContent = "AI: Processing...";
+    aiActivityIndicator.className = "indicator rounded-full px-4 py-2 text-white flex items-center transition-colors duration-300 bg-gradient-to-r from-purple-400 to-purple-600 hover:bg-gradient-to-r from-purple-500 to-purple-700"; // Tailwind class for thinking
+  } else if (currentAudio && !isUserSpeaking) {
+    aiActivityIndicator.textContent = state || "AI: Speaking";
+    aiActivityIndicator.className = "indicator rounded-full px-4 py-2 text-white flex items-center transition-colors duration-300 bg-gradient-to-r from-green-400 to-green-600 hover:bg-gradient-to-r from-green-500 to-green-700"; // Tailwind class for speaking
+  } else if (isUserSpeaking) {
+    aiActivityIndicator.textContent = "AI: Listening";
+    aiActivityIndicator.className = "indicator rounded-full px-4 py-2 text-white flex items-center transition-colors duration-300 bg-gradient-to-r from-yellow-400 to-yellow-600 hover:bg-gradient-to-r from-yellow-500 to-yellow-700"; // Tailwind class for listening
+  } else {
+    aiActivityIndicator.textContent = "AI: Idle";
+    aiActivityIndicator.className = "indicator rounded-full px-4 py-2 text-white flex items-center transition-colors duration-300 bg-gradient-to-r from-gray-300 to-gray-400 dark:from-gray-700 dark:to-gray-800 hover:bg-gradient-to-r from-gray-400 to-gray-500"; // Tailwind classes
+  }
+};
+
+
+// Initialize speech recognition
+if ('webkitSpeechRecognition' in window) {
+  speechRecognizer = new webkitSpeechRecognition();
+  Object.assign(speechRecognizer, {
+    continuous: true,
+    interimResults: true,
+    language: 'en-US',
+    maxAlternatives: 3
+  });
+
+  speechRecognizer.onstart = () => {
+    console.log("Speech recognition started");
+    completeTranscript = '';
+    isUserSpeaking = true;
+    lastUserSpeechTimestamp = Date.now();
+    updateActivityIndicators(); 
+    startStopButton.innerHTML = '<svg xmlns="http://www.w3.org/2000/svg" width="24" height="24" viewBox="0 0 24 24" fill="none" stroke="currentColor" stroke-width="2" stroke-linecap="round" stroke-linejoin="round"><path d="M9 9h6v6h-6z"></path><path d="M12 1a3 3 0 0 0-3 3v8a3 3 0 0 0 6 0V4a3 3 0 0 0-3-3z"></path><path d="M19 10v2a7 7 0 0 1-14 0v-2"></path><line x1="12" y1="19" x2="12" y2="23"></line><line x1="8" y1="23" x2="16" y2="23"></line></svg> Stop Listening';
+  };
+
+  speechRecognizer.onresult = (event) => {
+    let interimTranscript = '';
+    for (let i = event.resultIndex; i < event.results.length; i++) {
+      const transcript = event.results[i][0].transcript;
+      if (event.results[i].isFinal) {
+        completeTranscript += transcript;
+        interruptAudioPlayback('final');
+        processSpeechTranscript(completeTranscript);
+        completeTranscript = '';
+        isUserSpeaking = false;
+        updateActivityIndicators(); 
+        queryStartTime = Date.now();
+      } else {
+        interimTranscript += transcript;
+        isUserSpeaking = true;
+        lastUserSpeechTimestamp = Date.now();
+        updateActivityIndicators(); 
+
+        if (interimTranscript.length > prefetchTextQuery.length + 5) {
+          cancelPrefetchRequests(prefetchTextQuery);
+        }
+        prefetchTextQuery = interimTranscript;
+        prefetchFirstAudioChunk(interimTranscript, voiceSelectionDropdown.value);
+
+        if (isRequestInProgress && shouldInterruptAudioPlayback(interimTranscript)) {
+          interruptAudioPlayback('interim');
+        }
+      }
+    }
+  };
+
+  speechRecognizer.onerror = (event) => {
+    console.error('Speech recognition error:', event.error);
+    if (isSpeechRecognitionActive) speechRecognizer.start();
+  };
+
+  speechRecognizer.onend = () => {
+    isUserSpeaking = false;
+    updateActivityIndicators(); 
+
+    if (!isRequestInProgress && completeTranscript !== '') {
+      processSpeechTranscript(completeTranscript);
+      completeTranscript = '';
+    }
+
+    if (isSpeechRecognitionActive) speechRecognizer.start();
+  };
+
+  startStopButton.addEventListener('click', () => {
+    if (isSpeechRecognitionActive) {
+      speechRecognizer.stop();
+      isSpeechRecognitionActive = false;
+      startStopButton.innerHTML = '<svg id="microphoneIcon" xmlns="http://www.w3.org/2000/svg" width="24" height="24" viewBox="0 0 24 24" fill="none" stroke="currentColor" stroke-width="2" stroke-linecap="round" stroke-linejoin="round"><path d="M12 1a3 3 0 0 0-3 3v8a3 3 0 0 0 6 0V4a3 3 0 0 0-3-3z"></path><path d="M19 10v2a7 7 0 0 1-14 0v-2"></path><line x1="12" y1="19" x2="12" y2="23"></line><line x1="8" y1="23" x2="16" y2="23"></line></svg> Start Listening';
+    } else {
+      speechRecognizer.start();
+      isSpeechRecognitionActive = true;
+      startStopButton.innerHTML = '<svg xmlns="http://www.w3.org/2000/svg" width="24" height="24" viewBox="0 0 24 24" fill="none" stroke="currentColor" stroke-width="2" stroke-linecap="round" stroke-linejoin="round"><path d="M9 9h6v6h-6z"></path><path d="M12 1a3 3 0 0 0-3 3v8a3 3 0 0 0 6 0V4a3 3 0 0 0-3-3z"></path><path d="M19 10v2a7 7 0 0 1-14 0v-2"></path><line x1="12" y1="19" x2="12" y2="23"></line><line x1="8" y1="23" x2="16" y2="23"></line></svg> Stop Listening';
+    }
+  });
+} else {
+  alert('Your browser does not support the Web Speech API.');
+}
+
+// Add to conversation history
+const addToConversationHistory = (role, content) => {
+  if (conversationHistory.length > 0 &&
+    conversationHistory[conversationHistory.length - 1].role === 'assistant' &&
+    conversationHistory[conversationHistory.length - 1].content === "") {
+    conversationHistory.pop();
+  }
+
+  conversationHistory.push({ role, content });
+
+  if (conversationHistory.length > 6) conversationHistory.splice(0, 2);
+};
+
+// Process the final speech transcript
+const processSpeechTranscript = (transcript) => {
+  const trimmedTranscript = transcript.trimStart();
+  if (trimmedTranscript !== '' && !isRequestInProgress) {
+    activeQuery = trimmedTranscript;
+    sendQueryToAI(activeQuery);
+    addToConversationHistory('user', activeQuery);
+  }
+};
+
+// Check if audio playback should be interrupted
+const shouldInterruptAudioPlayback = (interimTranscript) =>
+  Date.now() - lastUserSpeechTimestamp > USER_SPEECH_INTERRUPT_DELAY || interimTranscript.length > 5;
+
+// Interrupt audio playback
+const interruptAudioPlayback = (reason = 'unknown') => {
+  console.log(`Interrupting audio (reason: ${reason})...`);
+  if (currentAudio) {
+    currentAudio.pause();
+    currentAudio.currentTime = 0;
+    currentAudio = null;
+  }
+
+  audioPlaybackQueue.length = 0;
+  isRequestInProgress = false;
+
+  if (requestAbortController) {
+    requestAbortController.abort();
+    requestAbortController = null;
+  }
+
+  prefetchCache.clear();
+  prefetchQueue.length = 0; 
+  updateActivityIndicators();
+};
+
+// Cancel pending prefetch requests
+const cancelPrefetchRequests = (query) => {
+  const normalizedQuery = normalizeQueryText(query);
+
+  for (const [cacheKey, abortController] of pendingPrefetchRequests) {
+    if (cacheKey.startsWith(normalizedQuery)) {
+      abortController.abort();
+      pendingPrefetchRequests.delete(cacheKey);pendingPrefetchRequests.delete(cacheKey);
+    }
+  }
+};
+
+// Update latency display
+const updateLatency = () => {
+  if (firstResponseTextTimestamp) {
+    const latency = firstResponseTextTimestamp - queryStartTime;
+    responseTimeDisplay.textContent = `Latency: ${latency}ms`;
+  } else {
+    responseTimeDisplay.textContent = "Latency: 0ms";
+  }
+};
+
+setInterval(updateLatency, 200);