Update app.js

app.js

@@ -21,7 +21,7 @@ app.use(express.static(path.join(__dirname, 'public')));
 // --- LOGGER HELPER ---
 const log = {
     info: (msg, id = "SYS") => console.log(`[${new Date().toISOString()}] [INFO] [${id}] ${msg}`),
-    warn: (msg, id = "SYS") => console.warn(`[${new Date().toISOString()}] ⚠️ [WARN][${id}] ${msg}`),
+    warn: (msg, id = "SYS") => console.warn(`[${new Date().toISOString()}] ⚠️[WARN][${id}] ${msg}`),
     error: (msg, err, id = "SYS") => console.error(`[${new Date().toISOString()}] ❌ [ERROR] [${id}] ${msg}`, err?.message || err, err?.stack || "")
 };
 
@@ -77,13 +77,14 @@ async function initDB() {
             
             const rowsToUpsert = toSync.map(id => {
                 const chat = memoryChats[id];
+                if (!chat) return null;
                 chat.updatedAt = new Date().toISOString();
                 return {
                     id: chat.id, title: chat.title, totalTokens: chat.totalTokens,
                     inputTokens: chat.inputTokens, outputTokens: chat.outputTokens,
                     messages: chat.messages, updatedAt: chat.updatedAt
                 };
-            });
+            }).filter(Boolean);
 
             if (rowsToUpsert.length > 0) {
                 const { error } = await supabase.from('chats').upsert(rowsToUpsert);
@@ -237,7 +238,6 @@ app.post('/api/chats/:id/stream', async (req, res) => {
         
         historicalMessages.push({ role: "user", content: contentBlock });
 
-        // THE FIX: Uncapped Token limit for Claude 3.7 to allow massive reasoning + coding
         const commandMaxTokens = model.includes("claude") ? 64000 : 8192;
 
         const command = new ConverseStreamCommand({
@@ -245,10 +245,6 @@ app.post('/api/chats/:id/stream', async (req, res) => {
             system:[{ text: system_prompt || CLAUDE_SYSTEM_PROMPT }],
             messages: historicalMessages,
             inferenceConfig: { maxTokens: commandMaxTokens, temperature: 1 },
-           /* additionalModelRequestFields: model.includes("claude") ? { 
-                thinking: { type: "adaptive" } 
-            } : undefined
-            */
         });
 
         const response = await bedrockClient.send(command, { abortSignal: abortController.signal });
@@ -265,7 +261,6 @@ app.post('/api/chats/:id/stream', async (req, res) => {
                     safeWrite(delta.text);
                 }
             }
-            // Log exactly why it stopped (e.g. max_tokens vs end_turn)
             if (chunk.messageStop) {
                 log.info(`Stream stopped. Reason: ${chunk.messageStop.stopReason}`, id);
             }
@@ -306,4 +301,6 @@ app.post('/api/chats/:id/stream', async (req, res) => {
     }
 });
 
-app.listen(PORT, '0.0.0.0', () => log.info(`AI Server live on http://localhost:${PORT}`));
+app.listen(PORT, '0.0.0.0', () => log.info(`AI Server live on http://localhost:${PORT}`));
+
+// --- HTML FRONTEND ENDS HERE (Served via res.send or specific index.html if needed) ---