Debug Info

Email: ${email || 'Not logged in'}

Back to app

\n ${email ? '

Logout

' : '

'}\n \n \n `);\n});\n\n// Create new thread\napp.post(\"/api/threads\", async (c) => {\n const email = c.req.header('X-LastLogin-Email');\n if (!email) {\n return c.json({ error: \"Not authenticated\" }, 401);\n }\n\n const result = await sqlite.execute(\n `INSERT INTO \\`last-login-chat-threads\\` (user_email) VALUES (?)`,\n [email]\n );\n\n const now = new Date().toISOString();\n \n return c.json({ \n threadId: result.lastInsertRowId,\n id: result.lastInsertRowId,\n title: \"New Chat\",\n user_email: email,\n created_at: now,\n updated_at: now\n });\n});\n\n// Get messages for a thread\napp.get(\"/api/threads/:threadId/messages\", async (c) => {\n const email = c.req.header('X-LastLogin-Email');\n if (!email) {\n return c.json({ error: \"Not authenticated\" }, 401);\n }\n\n const threadId = c.req.param('threadId');\n \n // Verify thread belongs to user\n const { rows: threadRows } = await sqlite.execute(\n `SELECT id FROM \\`last-login-chat-threads\\` WHERE id = ? AND user_email = ?`,\n [threadId, email]\n );\n\n if (threadRows.length === 0) {\n return c.json({ error: \"Thread not found\" }, 404);\n }\n\n const { rows } = await sqlite.execute(\n `SELECT * FROM \\`last-login-chat-messages\\` WHERE thread_id = ? ORDER BY created_at ASC`,\n [threadId]\n );\n\n return c.json({ messages: rows });\n});\n\n// Send a message and get OpenAI response\napp.post(\"/api/threads/:threadId/messages\", async (c) => {\n const email = c.req.header('X-LastLogin-Email');\n if (!email) {\n return c.json({ error: \"Not authenticated\" }, 401);\n }\n\n const threadId = c.req.param('threadId');\n const { content } = await c.req.json();\n\n if (!content || content.trim().length === 0) {\n return c.json({ error: \"Message content is required\" }, 400);\n }\n\n // Verify thread belongs to user\n const { rows: threadRows } = await sqlite.execute(\n `SELECT id FROM \\`last-login-chat-threads\\` WHERE id = ? AND user_email = ?`,\n [threadId, email]\n );\n\n if (threadRows.length === 0) {\n return c.json({ error: \"Thread not found\" }, 404);\n }\n\n try {\n // Save user message\n const userMessageResult = await sqlite.execute(\n `INSERT INTO \\`last-login-chat-messages\\` (thread_id, role, content) VALUES (?, ?, ?)`,\n [threadId, 'user', content.trim()]\n );\n\n // Get conversation history for context\n const { rows: messageHistory } = await sqlite.execute(\n `SELECT role, content FROM \\`last-login-chat-messages\\` WHERE thread_id = ? ORDER BY created_at ASC`,\n [threadId]\n );\n\n // Prepare messages for OpenAI (limit to last 20 messages to avoid token limits)\n const messages = messageHistory.slice(-20).map(msg => ({\n role: msg.role as 'user' | 'assistant',\n content: msg.content\n }));\n\n // Get OpenAI response\n const completion = await openai.chat.completions.create({\n model: \"gpt-4o-mini\",\n messages: messages,\n max_tokens: 1000,\n temperature: 0.7,\n });\n\n const assistantResponse = completion.choices[0]?.message?.content;\n \n if (!assistantResponse) {\n throw new Error(\"No response from OpenAI\");\n }\n\n // Save assistant message\n const assistantMessageResult = await sqlite.execute(\n `INSERT INTO \\`last-login-chat-messages\\` (thread_id, role, content) VALUES (?, ?, ?)`,\n [threadId, 'assistant', assistantResponse]\n );\n\n // Update thread's updated_at timestamp\n await sqlite.execute(\n `UPDATE \\`last-login-chat-threads\\` SET updated_at = CURRENT_TIMESTAMP WHERE id = ?`,\n [threadId]\n );\n\n // Return both messages\n return c.json({\n userMessage: {\n id: userMessageResult.lastInsertRowId,\n thread_id: threadId,\n role: 'user',\n content: content.trim(),\n created_at: new Date().toISOString()\n },\n assistantMessage: {\n id: assistantMessageResult.lastInsertRowId,\n thread_id: threadId,\n role: 'assistant',\n content: assistantResponse,\n created_at: new Date().toISOString()\n }\n });\n\n } catch (error) {\n console.error('Error processing message:', error);\n return c.json({ error: \"Failed to process message\" }, 500);\n }\n});\n\nexport default lastlogin(app.fetch);","deleted","label",[168,149],"backend","permalink","https://www.val.town/x/stevekrouse/last-login-demo-1/code/backend/index.ts","extension","actionData","errors"]