Persistent AI Journey

Connecting to journey stream...

\n \n \n

\n\n \n\n`;\n}\n\nexport default async function(req: Request) {\n const url = new URL(req.url);\n const action = url.searchParams.get(\"action\");\n\n if (req.method === \"POST\" && action === \"getJourney\") {\n try {\n const after_id = parseInt(url.searchParams.get(\"after_id\") || \"0\", 10);\n\n // FIX 1: Use sqlite.execute and get the first row from the 'rows' array\n const { rows: nextJourneyRows } = await sqlite.execute({\n sql: \"SELECT id, journey_data FROM journeys WHERE id > ? ORDER BY id ASC LIMIT 1\",\n args: [after_id],\n });\n const nextJourney = nextJourneyRows[0];\n\n if (nextJourney) {\n return new Response(\n JSON.stringify({\n id: nextJourney.id,\n journey: JSON.parse(nextJourney.journey_data).journey,\n }),\n { headers: { \"Content-Type\": \"application/json\" } },\n );\n }\n\n // FIX 2: Use sqlite.execute for the timestamp check\n const { rows: lastGenRows } = await sqlite.execute({\n sql: \"SELECT created_at FROM journeys ORDER BY id DESC LIMIT 1\",\n });\n const lastGen = lastGenRows[0];\n\n const thirtySeconds = 30 * 1000;\n const now = Date.now();\n\n if (lastGen && (now - lastGen.created_at < thirtySeconds)) {\n return new Response(\n JSON.stringify({\n status: \"wait\",\n retry_after: thirtySeconds - (now - lastGen.created_at),\n }),\n { headers: { \"Content-Type\": \"application/json\" } },\n );\n }\n\n const openai = new OpenAI();\n const completion = await openai.chat.completions.create({\n model: \"gpt-4o\",\n messages: [\n { role: \"system\", content: JOURNEY_GENERATOR_PROMPT },\n { role: \"user\", content: \"Generate a new visual conceptual journey based on the provided context.\" },\n ],\n temperature: 0.9,\n response_format: { type: \"json_object\" },\n });\n\n const journeyData = completion.choices[0].message.content;\n const parsedData = JSON.parse(journeyData);\n if (!parsedData.journey) throw new Error(\"AI response did not contain 'journey' key.\");\n\n const { lastInsertRowid } = await sqlite.execute({\n sql: \"INSERT INTO journeys (journey_data, created_at) VALUES (?, ?)\",\n args: [journeyData, now],\n });\n\n // FIX 3: Use sqlite.execute to get the count\n const { rows: countRows } = await sqlite.execute({ sql: \"SELECT COUNT(*) as count FROM journeys\" });\n const { count } = countRows[0];\n\n if (count > 10) {\n await sqlite.execute({\n sql: `DELETE FROM journeys WHERE id IN (SELECT id FROM journeys ORDER BY id ASC LIMIT ?)`,\n args: [count - 10],\n });\n }\n\n return new Response(\n JSON.stringify({\n id: lastInsertRowid,\n journey: parsedData.journey,\n }),\n { headers: { \"Content-Type\": \"application/json\" } },\n );\n } catch (error) {\n console.error(\"AI Journey Handler Error:\", error);\n return new Response(JSON.stringify({ error: \"The AI failed to generate or retrieve the journey.\" }), {\n status: 500,\n headers: { \"Content-Type\": \"application/json\" },\n });\n }\n }\n\n const sourceUrl = `https://${url.hostname}${url.pathname}`;\n return new Response(generateHtml(sourceUrl), { headers: { \"Content-Type\": \"text/html\" } });\n}","deleted","label","children",[],[99],"files",[150],"counts",{"_173":32,"_174":175,"_176":32,"_177":178},"pulls","branches",1,"forks","envVars",{"_179":32,"_180":32},"count","emptyCount","contents",[],"file",{"_104":151,"_95":99,"_152":153,"_154":-5,"_155":138,"_156":101,"_157":22,"_106":185,"_100":159,"_160":161,"_162":163,"_164":22,"_165":-5,"_98":186},["D",1751605283463],[99],"upstreamProject","upstreamBranch","emptyEnvVars","isNew","flags",[],"routes/_app.x.$handle.$name.branch.$branch.version.$version.code.$",{"_93":94,"_95":96,"_97":43,"_100":101,"_98":99,"_102":195,"_148":200,"_169":204,"_183":205,"_181":207,"_208":-5,"_209":22,"_210":-5,"_211":-5,"_212":-5,"_213":214},{"_104":105,"_95":96,"_106":196,"_108":-5,"_109":22,"_110":111,"_112":-5,"_113":-5,"_14":114,"_115":-5,"_116":22,"_117":-5,"_118":32,"_16":119,"_120":121,"_122":121,"_123":124,"_125":124,"_126":124,"_127":121,"_128":121,"_23":197,"_132":198,"_135":199,"_147":22},["D",1751603958789],{"_93":94,"_130":131},{"_93":94,"_134":131},{"_100":137,"_95":43,"_104":138,"_139":105,"_140":-5,"_141":-5,"_142":-5,"_143":-5,"_144":-5,"_145":96,"_146":94},[201],{"_104":151,"_95":99,"_152":153,"_154":-5,"_155":138,"_156":101,"_157":22,"_106":158,"_100":159,"_160":161,"_162":163,"_164":22,"_165":-5,"_166":202,"_98":203},[],[99],[201],{"_104":151,"_95":99,"_152":153,"_154":-5,"_155":138,"_156":101,"_157":22,"_106":185,"_100":159,"_160":161,"_162":163,"_164":22,"_165":-5,"_98":206},[99],[],"upstream","showCompareCallout","pull","ahead","behind","templates",[],"actionData","errors"]

join

wordstream