The Chronicle Engine

\n \n

\n\n\n\n`;\n}\n\nconst app = new Hono();\n\napp.post(\"/api\", async (c) => {\n await dbInitializationPromise;\n\n const openai = new OpenAI();\n const action = c.req.query(\"action\");\n const body = await c.req.json();\n\n try {\n switch (action) {\n case \"start\": {\n const { genre } = body;\n if (!genre) return c.json({ error: \"A genre must be stipulated.\" }, 400);\n\n const messages = [\n { role: \"system\", content: INITIAL_PROMPT },\n { role: \"user\", content: `Inaugurate a story within the \"${genre}\" genre.` },\n ];\n\n const completion = await openai.chat.completions.create({\n model: \"gpt-4o\",\n messages: messages,\n temperature: 0.8,\n response_format: { type: \"json_object\" },\n });\n\n const content = completion.choices[0].message.content;\n let result;\n try {\n result = extractJson(content);\n } catch (parseError) {\n console.error(\"JSON parsing failed for AI response:\", content, parseError);\n throw new Error(\"The Chronicler's response lacked the expected structure. Please endeavor again.\");\n }\n\n if (!result.story || !Array.isArray(result.choices) || result.choices.length === 0) {\n throw new Error(\"The AI's initial narrative was incomplete or malformed.\");\n }\n\n const chronicleId = crypto.randomUUID();\n const now = new Date().toISOString();\n\n await sqlite.execute({\n sql: `INSERT INTO chronicles (id, title, genre, lastUpdated) VALUES (:id, :title, :genre, :lastUpdated)`,\n args: {\n id: chronicleId,\n title: result.story.substring(0, 50) + \"...\",\n genre: genre,\n lastUpdated: now,\n },\n });\n\n const userEntryId = crypto.randomUUID();\n await sqlite.execute({\n sql:\n `INSERT INTO chronicle_entries (id, chronicleId, role, content, createdAt, sequence) VALUES (:id, :chronicleId, :role, :content, :createdAt, :sequence)`,\n args: {\n id: userEntryId,\n chronicleId: chronicleId,\n role: \"user\",\n content: `Start story in \"${genre}\" genre`,\n createdAt: now,\n sequence: 0,\n },\n });\n\n const assistantEntryId = crypto.randomUUID();\n await sqlite.execute({\n sql:\n `INSERT INTO chronicle_entries (id, chronicleId, role, content, createdAt, sequence) VALUES (:id, :chronicleId, :role, :content, :createdAt, :sequence)`,\n args: {\n id: assistantEntryId,\n chronicleId: chronicleId,\n role: \"assistant\",\n content: JSON.stringify(result),\n createdAt: now,\n sequence: 1,\n },\n });\n\n return c.json(\n {\n id: chronicleId,\n story: result.story,\n choices: result.choices,\n title: result.story.substring(0, 50) + \"...\",\n },\n 200,\n );\n }\n\n case \"continue\": {\n const { chronicleId, choice } = body;\n if (!chronicleId || !choice) return c.json({ error: \"Both chronicle ID and a choice are requisite.\" }, 400);\n\n const { rows: chronicleRows } = await sqlite.execute({\n sql: `SELECT * FROM chronicles WHERE id = :id`,\n args: { id: chronicleId },\n });\n\n if (chronicleRows.length === 0) return c.json({ error: \"The designated chronicle was not discovered.\" }, 404);\n\n const chronicle = chronicleRows[0] as Chronicle;\n\n const { rows: currentEntriesDb } = await sqlite.execute({\n sql: `SELECT role, content FROM chronicle_entries WHERE chronicleId = :chronicleId ORDER BY sequence ASC`,\n args: { chronicleId: chronicleId },\n });\n\n const messages = [{ role: \"system\", content: CONTINUATION_PROMPT }];\n messages.push(...currentEntriesDb.map(entry => ({\n role: entry.role,\n content: entry.content,\n })));\n messages.push({ role: \"user\", content: `My selection is: \"${choice}\"` });\n\n const completion = await openai.chat.completions.create({\n model: \"gpt-4o\",\n messages: messages,\n temperature: 0.8,\n response_format: { type: \"json_object\" },\n });\n\n const content = completion.choices[0].message.content;\n let result;\n try {\n result = extractJson(content);\n } catch (parseError) {\n console.error(\"JSON parsing failed for AI response (continue):\", content, parseError);\n const ambiguityMessages = [{ role: \"system\", content: AMBIGUITY_PROMPT }];\n ambiguityMessages.push(...messages);\n ambiguityMessages.push({\n role: \"user\",\n content:\n `My selection was \"${choice}\". The previous response was malformed: ${content}. Please re-interpret and continue.`,\n });\n\n const ambiguityCompletion = await openai.chat.completions.create({\n model: \"gpt-4o\",\n messages: ambiguityMessages,\n temperature: 0.9,\n response_format: { type: \"json_object\" },\n });\n const ambiguityContent = ambiguityCompletion.choices[0].message.content;\n result = extractJson(ambiguityContent);\n console.warn(\"Recovered from malformed JSON with ambiguity prompt. Reason:\", result.reason);\n if (!result.story || !Array.isArray(result.choices)) {\n throw new Error(\"The Chronicler encountered a profound conceptual disjunction and cannot proceed.\");\n }\n }\n\n if (!result.story || !Array.isArray(result.choices) || result.choices.length === 0) {\n throw new Error(\"The AI's subsequent narrative was incomplete or malformed.\");\n }\n\n const now = new Date().toISOString();\n const { rows: maxSequenceRow } = await sqlite.execute({\n sql: `SELECT MAX(sequence) as max_sequence FROM chronicle_entries WHERE chronicleId = :chronicleId`,\n args: { chronicleId: chronicleId },\n });\n const currentMaxSequence = (maxSequenceRow[0] as { max_sequence: number }).max_sequence || -1;\n\n const newUserEntryId = crypto.randomUUID();\n await sqlite.execute({\n sql:\n `INSERT INTO chronicle_entries (id, chronicleId, role, content, createdAt, sequence) VALUES (:id, :chronicleId, :role, :content, :createdAt, :sequence)`,\n args: {\n id: newUserEntryId,\n chronicleId: chronicleId,\n role: \"user\",\n content: choice,\n createdAt: now,\n sequence: currentMaxSequence + 1,\n },\n });\n\n const newAssistantEntryId = crypto.randomUUID();\n await sqlite.execute({\n sql:\n `INSERT INTO chronicle_entries (id, chronicleId, role, content, createdAt, sequence) VALUES (:id, :chronicleId, :role, :content, :createdAt, :sequence)`,\n args: {\n id: newAssistantEntryId,\n chronicleId: chronicleId,\n role: \"assistant\",\n content: JSON.stringify(result),\n createdAt: now,\n sequence: currentMaxSequence + 2,\n },\n });\n\n let chronicleTitle = chronicle.title;\n if (chronicleTitle.endsWith(\"...\")) {\n const firstStoryEntryResult = await sqlite.execute({\n sql:\n `SELECT content FROM chronicle_entries WHERE chronicleId = :chronicleId AND role = 'assistant' ORDER BY sequence ASC LIMIT 1`,\n args: { chronicleId: chronicleId },\n });\n if (firstStoryEntryResult.rows.length > 0) {\n const firstStoryContent = JSON.parse((firstStoryEntryResult.rows[0] as { content: string }).content);\n const storyBeginning = firstStoryContent.story.substring(0, 50);\n chronicleTitle = storyBeginning + \"...\";\n }\n }\n\n await sqlite.execute({\n sql: `UPDATE chronicles SET lastUpdated = :lastUpdated, title = :title WHERE id = :id`,\n args: {\n lastUpdated: now,\n title: chronicleTitle,\n id: chronicleId,\n },\n });\n\n return c.json({ story: result.story, choices: result.choices }, 200);\n }\n\n default:\n return c.json({ error: \"The specified action is not recognized.\" }, 400);\n }\n } catch (error: any) {\n console.error(\"Server-side processing error:\", error);\n return c.json({ error: error.message || \"An unforeseen conceptual anomaly occurred.\" }, 500);\n }\n});\n\napp.get(\"/api\", async (c) => {\n await dbInitializationPromise;\n\n const action = c.req.query(\"action\");\n try {\n switch (action) {\n case \"list\": {\n const { rows } = await sqlite.execute(\n `SELECT id, title, genre, lastUpdated FROM chronicles ORDER BY lastUpdated DESC`,\n );\n return c.json(rows, 200);\n }\n case \"load\": {\n const id = c.req.query(\"id\");\n if (!id) return c.json({ error: \"A chronicle identifier is requisite.\" }, 400);\n\n const { rows: chronicleRows } = await sqlite.execute({\n sql: `SELECT id, title, genre, lastUpdated FROM chronicles WHERE id = :id`,\n args: { id: id },\n });\n if (chronicleRows.length === 0) return c.json({ error: \"The designated chronicle was not discovered.\" }, 404);\n\n const chronicle = chronicleRows[0] as Chronicle;\n\n const { rows: entriesRows } = await sqlite.execute({\n sql: `SELECT role, content FROM chronicle_entries WHERE chronicleId = :chronicleId ORDER BY sequence ASC`,\n args: { chronicleId: id },\n });\n\n return c.json({ ...chronicle, entries: entriesRows }, 200);\n }\n default:\n return c.json({ error: \"The stipulated GET action is not recognized.\" }, 400);\n }\n } catch (error: any) {\n console.error(\"Server-side GET processing error:\", error);\n return c.json({ error: error.message || \"An unforeseen conceptual anomaly occurred.\" }, 500);\n }\n});\n\napp.delete(\"/api\", async (c) => {\n await dbInitializationPromise;\n\n const action = c.req.query(\"action\");\n try {\n switch (action) {\n case \"delete\": {\n const id = c.req.query(\"id\");\n if (!id) return c.json({ error: \"A chronicle identifier is requisite for deletion.\" }, 400);\n await sqlite.execute({\n sql: `DELETE FROM chronicles WHERE id = :id`,\n args: { id: id },\n });\n return c.json({ message: \"Chronicle successfully expunged.\" }, 200);\n }\n default:\n return c.json({ error: \"The stipulated DELETE action is not recognized.\" }, 400);\n }\n } catch (error: any) {\n console.error(\"Server-side DELETE processing error:\", error);\n return c.json({ error: error.message || \"An unforeseen conceptual anomaly occurred during deletion.\" }, 500);\n }\n});\n\napp.get(\"/\", async (c) => {\n const url = new URL(c.req.url);\n const sourceUrl = `https://${url.hostname}${url.pathname}`;\n return c.html(generateHtml(sourceUrl));\n});\n\nexport default app.fetch;","deleted","label",[99],"permalink","https://www.val.town/x/join/chronicle/code/main.tsx","extension","actionData","errors"]