FLUX.

\n \n \n \n \n

\n {sites.rows.map((s) => (\n \n \n AGENT: {s[2] || \"VOID\"}\n \n

\n {s[0]}\n

\n \n ))}\n

\n \n \n \n Manifest\n \n \n

\n \n ),\n }),\n );\n});\n\n// --- RESOLVER ---\napp.get(\"/s/:slug/:page?\", async (c) => {\n const { slug, page } = c.req.param();\n if (slug === \"undefined\") return c.redirect(\"/\");\n const path = c.req.path.replace(/\\/+$/, \"\");\n const user = await Auth.getSession(c);\n const siteRes = await sqlite.execute({\n sql: `SELECT id, name, idea FROM ${TABLES.SITES} WHERE slug = ?`,\n args: [slug],\n });\n const site = siteRes.rows[0];\n if (!site) return c.redirect(\"/\");\n\n const nodeRes = await sqlite.execute({\n sql:\n `SELECT generating, generated, generating_at, html FROM ${TABLES.PAGES} WHERE path = ?`,\n args: [path],\n });\n const node = nodeRes.rows[0];\n\n if (node && node[1] === 1) { // generated == 1\n return c.html(\n await UI.Layout({\n title: site[1],\n user,\n children: (\n

\n \n

\n DNA: ${site[2]}\n \n Regen_Node\n \n

\n ),\n }),\n );\n }\n\n if (node && node[0] === 1) { // generating == 1\n const diff = (Date.now() - new Date(node[2] + \"Z\").getTime()) / 1000;\n if (diff < GENERATION_LOCK_SECONDS) {\n return c.html(\n \n LOCKED_FOR_SYNTHESIS: ${Math.round(GENERATION_LOCK_SECONDS - diff)}s\n ,\n );\n }\n }\n\n if (!c.req.query(\"sync\")) {\n return c.html(`\n \n

Syncing_Reality...

\n ${\n user\n ? ``\n : \"\"\n }\n \n \n `);\n }\n\n // BEGIN LOCK\n await sqlite.execute({\n sql:\n `INSERT INTO ${TABLES.PAGES} (path, site_id, generating, generating_at) VALUES (?, ?, 1, CURRENT_TIMESTAMP) ON CONFLICT(path) DO UPDATE SET generating=1, generating_at=CURRENT_TIMESTAMP`,\n args: [path, site[0]],\n });\n\n try {\n const steering = c.req.query(\"intent\") || \"\";\n let html = \"\";\n if (!page) {\n const raw = await AI.synthesize(\n 'JSON ARRAY ONLY: [{\"title\":\"\",\"slug\":\"\"}]',\n `Create 8 sub-nodes for ${site[1]}. DNA: ${\n site[2]\n }. Steering: ${steering}`,\n );\n const nodes = DB.parseArray(raw);\n html =\n `

${\n site[1]\n }

` +\n nodes.map((n: any) =>\n `${n.title}`\n ).join(\"\") + `

`;\n } else {\n html = await AI.synthesize(\n `Sophisticated HTML Body`,\n `Write node ${path}. Context: ${site[2]}. Agent Intent: ${steering}`,\n );\n if (html.includes('\"error\"')) throw new Error(\"CONGESTION\");\n }\n await sqlite.execute({\n sql:\n `UPDATE ${TABLES.PAGES} SET title = ?, html = ?, generating = 0, generated = 1, generating_at = NULL WHERE path = ?`,\n args: [site[1], html, path],\n });\n return c.redirect(path);\n } catch (e) {\n // UNLOCK ON FAILURE\n await sqlite.execute({\n sql: `UPDATE ${TABLES.PAGES} SET generating = 0 WHERE path = ?`,\n args: [path],\n });\n return c.html(\n \n Vibe_Congestion: ${e.message}\n
\n Retry_Manifestation\n ,\n );\n }\n});\n\napp.get(\"/regen\", async (c) => {\n const path = c.req.query(\"path\");\n if (!path) return c.redirect(\"/\");\n await sqlite.execute({\n sql: `DELETE FROM ${TABLES.PAGES} WHERE path = ?`,\n args: [decodeURIComponent(path)],\n });\n return c.redirect(decodeURIComponent(path) + \"?sync=1\");\n});\n\napp.post(\"/create\", async (c) => {\n const { idea } = await c.req.parseBody();\n const raw = await AI.synthesize(\n 'JSON: {\"name\":\"\",\"slug\":\"\"}',\n `Metadata for: ${idea}`,\n );\n const meta = JSON.parse(raw.replace(/```[a-z]*|\\n```/gi, \"\"));\n const slug = meta.slug || \"flux-\" + Math.random().toString(36).substring(7);\n await sqlite.execute({\n sql: `INSERT INTO ${TABLES.SITES} (name, slug, idea) VALUES (?, ?, ?)`,\n args: [meta.name || \"New Reality\", slug, idea],\n });\n return c.redirect(`/s/${slug}`);\n});\n\napp.get(\"/ideas-frame\", async (c) => {\n await DB.init();\n let q = await sqlite.execute(\n `SELECT * FROM ${TABLES.QUEUE} WHERE manifested = 0 LIMIT 10`,\n );\n return c.html(\n `\n ${\n q.rows.map((i) =>\n `

${\n i[1]\n }

${i[3]}

`\n ).join(\"\")\n }\n `,\n );\n});\n\nexport default app.fetch;","deleted","label",[99],"permalink","https://www.val.town/x/ziggyware/Save-to-db-working/code/main.ts","extension","actionData","errors"]