fix

src/app/search/web/page.jsx

@@ -5,66 +5,53 @@ import { MemoizedReactMarkdown } from '../../../components/MemoizedReactMarkdown
 export default function WebSearchPage({ searchParams }) {
   const [aiResponse, setAiResponse] = useState("");
   const [searchTerm, setSearchTerm] = useState()
+  const [text, setText] = useState('');
 
   useEffect(() => {
     setSearchTerm(searchParams.searchTerm)
   }, [searchParams])
 
+
+
+// Define the state for text
+
+
   useEffect(() => {
-    const controller = new AbortController();
-    const signal = controller.signal;
-  
-    async function fetchData() {
+    const handleSend = async () => {
+      const body = JSON.stringify({ question: searchTerm });
+      const controller = new AbortController();
       const response = await fetch('/api/llm', {
         method: 'POST',
         headers: { 'Content-Type': 'application/json' },
-        body: JSON.stringify({ question: searchTerm || "Seattle activities this weekend" }),
-        signal,
+        signal: controller.signal,
+        body
       });
-  
+
       if (!response.ok) {
-        throw new Error(`HTTP error! status: ${response.status}`);
-      } else {
-        const reader = response.body.getReader();
-        const decoder = new TextDecoder();
-        let text = '';
-  
-        while (true) {
-          const { value, done } = await reader.read();
-  
-          if (value) {
-            text += decoder.decode(value, {stream: true});
-            let boundary = text.indexOf('\n');
-
-            while (boundary !== -1) {
-              const jsonStr = text.slice(0, boundary);
-              text = text.slice(boundary + 1);
-              try {
-                const json = JSON.parse(jsonStr);
-                console.log(json);
-                setAiResponse(prevResponse => [...prevResponse, json]);
-              } catch (error) {
-                console.error("Failed to parse JSON", error);
-              }
+        return;
+      }
 
-              boundary = text.indexOf('\n');
-            }
-          }
-  
-          if (done) {
-            console.log("Stream complete");
-            break;
-          }
+      const reader = response.body.getReader();
+      const decoder = new TextDecoder();
+      let resultText = '';
+
+      while (true) {
+        const { value, done } = await reader.read();
+
+        if (done) {
+          break;
         }
+
+        const chunkValue = decoder.decode(value);
+        resultText += chunkValue;
       }
-    }
-  
-    fetchData().catch(error => {
-      console.error('Fetch failed: ', error);
-    });
-  
-    return () => controller.abort();
-  }, [searchParams, searchTerm]); 
+
+      setText(resultText);
+    };
+
+    handleSend();
+  }, []);
+
 
 
   console.log(aiResponse);

src/pages/api/llm.js

@@ -2,7 +2,6 @@ import { GoogleCustomSearch } from "openai-function-calling-tools";
 import { LLMError, LLMStream } from './stream';
 
 const handler = async (req, res) => {
-  console.log(req.body);
   try {
     const googleCustomSearch = new GoogleCustomSearch({
         apiKey: process.env.API_KEY,

src/pages/api/stream.js

@@ -68,7 +68,6 @@ export const LLMStream = async (
     async start(controller) {
       const onParse = async (event) => {
         if (event.type === 'event') {
-          console.log(event);
           const data = event.data;
           try {
             if (data === '[DONE]') {