LEGACY DISCOVERY ENGINE

Initializing...

\n\n

\n \n \n\n

\n \n

The Discovery Session

\n I will not write your book yet. First, I must learn your voice.\n We will start with anchoring, then move to memory funneling.\n

\n \n

\n \n \n \n

\n\n

\n \n \n

\n \n

\n\n

\n\n \n\n`;\n}\n\n// ============================================================================\n// 4. BACKEND LOGIC\n// ============================================================================\n\nconst app = new Hono();\nconst openai = new OpenAI();\n\nasync function processInput(state: SessionState, newText: string) {\n // 1. Determine Context\n const context = JSON.stringify({\n themes: state.vault.themes,\n syntax: state.vault.syntaxProfile,\n last_turn: newText,\n });\n\n const prompts = getSystemPrompts(state.baseVoice, state.phase, context);\n\n // 2. Always Run Archivist (To tag data)\n const archivistRes = await openai.chat.completions.create({\n model: \"gpt-4o\",\n messages: [\n { role: \"system\", content: prompts.ARCHIVIST },\n { role: \"user\", content: newText },\n ],\n response_format: { type: \"json_object\" },\n });\n const archivistData = JSON.parse(archivistRes.choices[0].message.content);\n\n // 3. Logic Gate: Investigator vs Ghostwriter\n let investigatorQuestion = \"\";\n let ghostwriterText = null;\n\n if (state.phase === \"MIMICRY_TEST\") {\n // RUN GHOSTWRITER\n const writerRes = await openai.chat.completions.create({\n model: \"gpt-4o\",\n messages: [\n { role: \"system\", content: prompts.GHOSTWRITER },\n {\n role: \"user\",\n content:\n `REWRITE THIS STORY FRAGMENT IN THE USER'S VOICE: ${newText}`,\n },\n ],\n });\n ghostwriterText = writerRes.choices[0].message.content;\n\n // Reset to gathering after test\n state.phase = \"GATHERING\";\n } else {\n // RUN INVESTIGATOR\n const invRes = await openai.chat.completions.create({\n model: \"gpt-4o\",\n messages: [\n { role: \"system\", content: prompts.INVESTIGATOR },\n { role: \"user\", content: `USER ANSWER: ${newText}` },\n ],\n response_format: { type: \"json_object\" },\n });\n const invData = JSON.parse(invRes.choices[0].message.content);\n investigatorQuestion = invData.question;\n }\n\n // 4. State Transition Logic\n state.turnCount++;\n\n // Transition Phase based on turns\n if (state.phase === \"ANCHORING\" && state.turnCount > 1) {\n state.phase = \"GATHERING\";\n } else if (state.phase === \"GATHERING\" && state.turnCount === 4) {\n // Trigger test on turn 4\n state.phase = \"MIMICRY_TEST\";\n }\n\n return {\n archivistData,\n investigatorQuestion,\n ghostwriterText,\n nextPhase: state.phase,\n };\n}\n\n// --- ROUTES ---\n\napp.post(\"/api/init\", async (c) => {\n const { topic, voice } = await c.req.json();\n const id = `session_${Date.now()}`;\n\n const state: SessionState = {\n id,\n baseVoice: voice,\n phase: \"ANCHORING\", // Start with Anchoring, not writing\n turnCount: 0,\n transcript: [],\n manuscript: [],\n vault: { entities: {}, themes: [], syntaxProfile: [] },\n lastUpdate: Date.now(),\n };\n\n // Pre-seed with the first question (generated manually for speed/reliability)\n state.transcript.push({\n role: \"ai\",\n text:\n \"Before we begin the story, I need to anchor us in the present. Where are you sitting right now? Describe the room and the light.\",\n });\n\n await blob.setJSON(id, state);\n return c.json({ id });\n});\n\napp.post(\"/api/chat\", async (c) => {\n const { id, text } = await c.req.json();\n const state = await blob.getJSON(id);\n if (!state) return c.json({ error: \"Not found\" }, 404);\n\n state.transcript.push({ role: \"user\", text });\n state.lastUpdate = Date.now(); // Signal the stream to pick it up\n\n await blob.setJSON(id, state);\n return c.json({ ok: true });\n});\n\napp.get(\"/api/stream/:id\", async (c) => {\n const id = c.req.param(\"id\");\n\n return streamSSE(c, async (stream) => {\n // On connect, send the initial system message if it exists\n const initState = await blob.getJSON(id);\n if (initState && initState.turnCount === 0) {\n await stream.writeSSE({\n data: JSON.stringify({ type: \"phase_update\", phase: \"ANCHORING\" }),\n });\n await stream.writeSSE({\n data: JSON.stringify({\n type: \"investigator\",\n question: initState.transcript[0].text,\n }),\n });\n }\n\n const start = Date.now();\n let lastProcessedIndex = initState ? initState.transcript.length - 1 : 0;\n\n while (Date.now() - start < 50000) {\n const state = await blob.getJSON(id);\n\n if (!state) {\n await stream.writeSSE({\n data: JSON.stringify({ type: \"error\", msg: \"Session expired\" }),\n });\n break;\n }\n\n // Check for new USER message\n if (state.transcript.length > lastProcessedIndex + 1) {\n const lastMsg = state.transcript[state.transcript.length - 1];\n\n if (lastMsg.role === \"user\") {\n lastProcessedIndex = state.transcript.length - 1;\n\n // Process\n const result = await processInput(state, lastMsg.text);\n\n // Update State Metadata\n if (result.archivistData.syntax_notes) {\n state.vault.syntaxProfile.push(result.archivistData.syntax_notes);\n }\n state.vault.entities = {\n ...state.vault.entities,\n ...(result.archivistData.entities || {}),\n };\n\n await blob.setJSON(id, state);\n\n // Stream Results\n await stream.writeSSE({\n data: JSON.stringify({\n type: \"phase_update\",\n phase: result.nextPhase,\n }),\n });\n\n await stream.writeSSE({\n data: JSON.stringify({ type: \"archivist\", data: state.vault }),\n });\n\n // If Ghostwriter ran (Mimicry Test)\n if (result.ghostwriterText) {\n await stream.writeSSE({\n data: JSON.stringify({\n type: \"ghostwriter\",\n text: result.ghostwriterText,\n }),\n });\n // After test, ask a follow up to get back to gathering\n await stream.writeSSE({\n data: JSON.stringify({\n type: \"investigator\",\n question:\n \"How did that sound? Let's go back to the memory. What happened next?\",\n }),\n });\n } else {\n // Normal Investigator Question\n await stream.writeSSE({\n data: JSON.stringify({\n type: \"investigator\",\n question: result.investigatorQuestion,\n }),\n });\n }\n }\n }\n\n await stream.writeSSE({ data: \"ping\" });\n await new Promise((r) => setTimeout(r, 1000));\n }\n });\n});\n\nexport default async function (req: Request) {\n const url = new URL(req.url);\n if (url.pathname.includes(\"/api/\")) {\n const newUrl = new URL(url.toString());\n newUrl.pathname = url.pathname.slice(url.pathname.indexOf(\"/api/\"));\n return app.fetch(new Request(newUrl, req));\n }\n return new Response(generateHtml(url.toString()), {\n headers: { \"Content-Type\": \"text/html\" },\n });\n}","deleted","label",[99],"permalink","https://www.val.town/x/volt/lifelines/code/main.ts","extension","actionData","errors"]