The Chronicle Engine

\n \n

\n\n\n\n`;\n}\n\nconst app = new Hono();\nlet dbInitialized = false;\n\n// Middleware to ensure database is initialized\napp.use(async (c, next) => {\n if (!dbInitialized) {\n await initializeDatabase();\n dbInitialized = true;\n }\n await next();\n});\n\n// API Endpoints\napp.post(\"/api\", async (c) => {\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 // Attempt to recover or provide a more specific error for the user\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 newChronicle: Chronicle = {\n id: chronicleId,\n title: result.story.substring(0, 50) + \"...\", // Use first part of story as temp title\n genre: genre,\n entries: [{ role: \"user\", content: `Start story in \"${genre}\" genre` }, {\n role: \"assistant\",\n content: JSON.stringify(result),\n }],\n lastUpdated: new Date().toISOString(),\n };\n\n await sqlite.execute({\n sql:\n `INSERT INTO chronicles (id, title, genre, entries, lastUpdated) VALUES (:id, :title, :genre, :entries, :lastUpdated)`,\n args: {\n id: newChronicle.id,\n title: newChronicle.title,\n genre: newChronicle.genre,\n entries: JSON.stringify(newChronicle.entries),\n lastUpdated: newChronicle.lastUpdated,\n },\n });\n\n return c.json(\n { id: newChronicle.id, story: result.story, choices: result.choices, title: newChronicle.title },\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 } = await sqlite.execute({\n sql: `SELECT * FROM chronicles WHERE id = :id`,\n args: { id: chronicleId },\n });\n\n if (rows.length === 0) return c.json({ error: \"The designated chronicle was not discovered.\" }, 404);\n\n const chronicle = rows[0] as Chronicle;\n const currentEntries = JSON.parse(chronicle.entries as string);\n\n const messages = [{ role: \"system\", content: CONTINUATION_PROMPT }];\n messages.push(...currentEntries);\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 // Attempt to use ambiguity prompt for recovery\n const ambiguityMessages = [{ role: \"system\", content: AMBIGUITY_PROMPT }];\n ambiguityMessages.push(...currentEntries);\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 currentEntries.push({ role: \"user\", content: `My selection is: \"${choice}\"` });\n currentEntries.push({ role: \"assistant\", content: JSON.stringify(result) });\n\n // Update the chronicle's title based on its first actual story segment, if not already set\n let chronicleTitle = chronicle.title;\n if (chronicleTitle.endsWith(\"...\")) { // Check if it's the temporary title\n // Find the first actual story part in entries and use its beginning\n const firstStoryEntry = currentEntries.find(entry =>\n entry.role === \"assistant\" && JSON.parse(entry.content).story\n );\n if (firstStoryEntry) {\n const storyBeginning = JSON.parse(firstStoryEntry.content).story.substring(0, 50);\n chronicleTitle = storyBeginning + \"...\";\n }\n }\n\n await sqlite.execute({\n sql: `UPDATE chronicles SET entries = :entries, lastUpdated = :lastUpdated, title = :title WHERE id = :id`,\n args: {\n entries: JSON.stringify(currentEntries),\n lastUpdated: new Date().toISOString(),\n title: chronicleTitle, // Update title if it was temporary\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 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 const { rows } = await sqlite.execute({\n sql: `SELECT * FROM chronicles WHERE id = :id`,\n args: { id: id },\n });\n if (rows.length === 0) return c.json({ error: \"The designated chronicle was not discovered.\" }, 404);\n return c.json(rows[0], 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 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\n// Serve HTML for all other GET requests (e.g., initial page load)\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",[98],"permalink","https://www.val.town/x/join/untitled-2418/code/main.tsx","extension","actionData","errors"]