Aegis Counsel

\n \n

Welcome. This is a secure space for your thoughts. How are you feeling today?

\n \n

\n\n\n\n`;\n}\n\n// --- API ROUTING & BACKEND LOGIC ---\n\nconst app = new Hono();\nconst openai = new OpenAI();\n\n// Helper to get all boundaries from the database\nasync function getBoundaries() {\n const { results } = await sqlite.execute(\"SELECT id, topic FROM boundaries\");\n return results as { id: number, topic: string }[];\n}\n\n// Get Boundaries\napp.get(\"/boundaries\", async (c) => {\n const boundaries = await getBoundaries();\n return c.json(boundaries);\n});\n\n// Add Boundary\napp.post(\"/boundaries\", async (c) => {\n const { topic } = await c.req.json();\n if (!topic || typeof topic !== \"string\") {\n return c.json({ error: \"Invalid topic provided\" }, 400);\n }\n await sqlite.execute({\n sql: \"INSERT OR IGNORE INTO boundaries (topic) VALUES (:topic)\",\n args: { topic },\n });\n return c.json({ success: true }, 201);\n});\n\n// Delete Boundary\napp.delete(\"/boundaries/:id\", async (c) => {\n const id = c.req.param(\"id\");\n await sqlite.execute({ sql: \"DELETE FROM boundaries WHERE id = :id\", args: { id } });\n return c.json({ success: true });\n});\n\n// Start Session\napp.post(\"/session/start\", async (c) => {\n const now = new Date().toISOString();\n const { lastInsertRowid } = await sqlite.execute({\n sql: \"INSERT INTO sessions (started_at, transcript) VALUES (:now, :transcript)\",\n args: { now, transcript: \"[]\" },\n });\n return c.json({ sessionId: lastInsertRowid });\n});\n\n// End Session\napp.post(\"/session/end\", async (c) => {\n const { sessionId } = await c.req.json();\n const { results } = await sqlite.execute({\n sql: \"SELECT transcript FROM sessions WHERE id = :sessionId\",\n args: { sessionId },\n });\n const transcript = (results[0] as any)?.transcript;\n\n if (!transcript) {\n return c.json({ error: \"Session not found or empty\" }, 404);\n }\n \n const completion = await openai.chat.completions.create({\n model: \"gpt-4o\",\n messages: [\n { role: \"system\", content: SUMMARY_PROMPT },\n { role: \"user\", content: transcript }\n ],\n });\n\n const summary = completion.choices[0].message.content;\n\n await sqlite.execute({\n sql: \"UPDATE sessions SET summary = :summary, ended_at = :now WHERE id = :sessionId\",\n args: { summary, now: new Date().toISOString(), sessionId },\n });\n\n return c.json({ summary });\n});\n\n\n// Main Chat Endpoint\napp.post(\"/chat\", async (c) => {\n const { sessionId, message } = await c.req.json();\n if (!sessionId || !message) {\n return c.json({ error: \"Session ID and message are required\" }, 400);\n }\n\n // 1. Fetch current transcript and boundaries\n const { results: sessionResults } = await sqlite.execute({\n sql: \"SELECT transcript FROM sessions WHERE id = :sessionId\",\n args: { sessionId },\n });\n if (!sessionResults.length) {\n return c.json({ error: \"Session not found\" }, 404);\n }\n const history = JSON.parse((sessionResults[0] as any).transcript);\n const boundaries = await getBoundaries();\n const boundaryTopics = boundaries.map(b => b.topic).join(\", \") || \"None\";\n \n // 2. Generate AI response, retrying if the boundary guard catches a violation\n let counselorResponse = \"\";\n let violation = true;\n let attempts = 0;\n \n while(violation && attempts < 3) {\n attempts++;\n\n // 2a. Generate Counselor Response\n const counselorCompletion = await openai.chat.completions.create({\n model: \"gpt-4o\",\n messages: [\n { role: \"system\", content: COUNSELOR_PROMPT.replace(\"{boundaries}\", boundaryTopics).replace(\"{history}\", JSON.stringify(history.slice(-6))) },\n { role: \"user\", content: message }\n ],\n temperature: 0.7,\n });\n const proposedResponse = counselorCompletion.choices[0].message.content;\n\n // 2b. Check with Boundary Guardian\n const guardCompletion = await openai.chat.completions.create({\n model: \"gpt-4o\",\n messages: [{\n role: \"system\",\n content: BOUNDARY_GUARD_PROMPT.replace(\"{boundaries}\", boundaryTopics).replace(\"{response}\", proposedResponse)\n }],\n response_format: { type: \"json_object\" },\n });\n\n const guardDecision = JSON.parse(guardCompletion.choices[0].message.content);\n if (!guardDecision.violates) {\n violation = false;\n counselorResponse = proposedResponse;\n } else {\n console.log(`Boundary violation detected (Attempt ${attempts}): ${guardDecision.reason}`);\n }\n }\n\n if (violation) {\n counselorResponse = \"I seem to be having trouble formulating a response that respects your boundaries. Could you please rephrase your message?\";\n }\n \n // 3. Update and save transcript\n history.push({ role: \"user\", content: message });\n history.push({ role: \"assistant\", content: counselorResponse });\n await sqlite.execute({\n sql: \"UPDATE sessions SET transcript = :transcript WHERE id = :sessionId\",\n args: { transcript: JSON.stringify(history), sessionId },\n });\n\n return c.json({ reply: counselorResponse });\n});\n\n// --- MAIN EXPORT ---\n\nexport default async function(req: Request) {\n const url = new URL(req.url);\n if (url.pathname.startsWith(\"/api\")) {\n const apiPath = url.pathname.substring(4);\n const apiReq = new Request(new URL(apiPath, \"http://localhost\"), req);\n return app.fetch(apiReq);\n }\n \n // Serve the HTML for the root path\n const sourceUrl = `https://${url.hostname}${url.pathname}`;\n return new Response(generateHtml(sourceUrl), {\n headers: { \"Content-Type\": \"text/html\" },\n });\n}","deleted","label",[98],"permalink","https://www.val.town/x/realtime/Therapy/code/main.ts","extension","actionData","errors"]