Update scripts/chat.js

scripts/chat.js

@@ -1,4 +1,12 @@
-// scripts/chat.js
+// scripts/chat.js -- Final version with conversation history
+
+// This array will store the entire conversation history.
+let conversationHistory = [
+    {
+        role: 'system',
+        content: 'You are a friendly and helpful streaming assistant for an app called StreamAI. A user is asking a question. Keep your responses concise and focused on recommending movies, TV shows, or streaming content.'
+    }
+];
 
 export function initChat() {
     const sendBtn = document.getElementById('send-btn');
@@ -11,54 +19,61 @@ export function initChat() {
     }
 }
 
-// In scripts/chat.js
-
 async function sendMessage() {
     const userInput = document.getElementById('user-input');
     const chatMessages = document.getElementById('chat-messages');
     const userMessageText = userInput.value.trim();
     if (userMessageText === '') return;
 
-    // Create and add the user's message bubble
+    // Add user message to the UI
     const userBubble = document.createElement('div');
     userBubble.className = 'chat-bubble user-bubble p-4 fade-in';
     userBubble.innerHTML = `<p>${userMessageText}</p>`;
     chatMessages.appendChild(userBubble);
+    
+    // Add user message to our history array
+    conversationHistory.push({ role: 'user', content: userMessageText });
+    
     userInput.value = '';
     chatMessages.scrollTop = chatMessages.scrollHeight;
 
-    // Create the AI's response bubble
+    // Add a placeholder for the AI's response
     const aiBubble = document.createElement('div');
     aiBubble.className = 'chat-bubble ai-bubble p-4 fade-in';
     aiBubble.innerHTML = '<div class="typing-indicator"><span></span><span></span><span></span></div>';
     chatMessages.appendChild(aiBubble);
     chatMessages.scrollTop = chatMessages.scrollHeight;
     
-    // --- THIS IS THE CRUCIAL UPDATE ---
-    // This now points to your new worker's chat endpoint.
     const workerUrl = 'https://streamai-backend-v2.smplushypermedia.workers.dev/api/chat';
 
     try {
         const response = await fetch(workerUrl, {
             method: 'POST',
             headers: { 'Content-Type': 'application/json' },
-            body: JSON.stringify({ prompt: userMessageText }),
+            // Send the ENTIRE conversation history to the worker
+            body: JSON.stringify({ messages: conversationHistory }),
         });
         if (!response.ok) throw new Error(`Network response was not ok. Status: ${response.status}`);
 
-        // Handle the streaming response from Gemini
         const reader = response.body.getReader();
         const decoder = new TextDecoder();
         aiBubble.innerHTML = ''; // Clear the typing indicator
         const aiParagraph = document.createElement('p');
         aiBubble.appendChild(aiParagraph);
-
+        
+        let aiResponseText = "";
         while (true) {
             const { done, value } = await reader.read();
             if (done) break;
-            aiParagraph.textContent += decoder.decode(value, { stream: true });
+            const chunk = decoder.decode(value, { stream: true });
+            aiResponseText += chunk;
+            aiParagraph.textContent = aiResponseText; // Update the UI as the stream comes in
             chatMessages.scrollTop = chatMessages.scrollHeight;
         }
+
+        // Add the final, complete AI response to our history
+        conversationHistory.push({ role: 'model', content: aiResponseText });
+
     } catch (error) {
         aiBubble.innerHTML = `<p class="text-red-400">Error: Could not connect to the AI assistant. ${error.message}</p>`;
     }