\\${title} // APEIRON

\\${children}

\n \n \n \n );\n `;\n await sqlite.execute({\n sql:\n `INSERT OR REPLACE INTO ${TABLES.KERNEL} (name, code) VALUES ('ui', ?)`,\n args: [ui],\n });\n },\n\n formatSlug: (s: string) =>\n (s || \"\").toLowerCase().trim().replace(/[^\\w\\s-]/g, \"\").replace(\n /[\\s_-]+/g,\n \"-\",\n ).replace(/^-+|-+$/g, \"\") || Math.random().toString(36).slice(2, 6),\n getLevel: (pts: number) => Math.floor(Math.log2((pts || 0) + 1)),\n async hash(str: string) {\n const buf = await crypto.subtle.digest(\n \"SHA-256\",\n new TextEncoder().encode(str),\n );\n return Array.from(new Uint8Array(buf)).map((b) =>\n b.toString(16).padStart(2, \"0\")\n ).join(\"\");\n },\n};\n\n// --- 3. AI HANDLER (Failover List) ---\nconst AI = {\n genAI: new GoogleGenerativeAI(Deno.env.get(\"GEMINI_API_KEY\") || \"\"),\n\n parseModelName(input: string): string {\n const name = input.match(/[a-zA-Z]+/g)?.join(\" \") || \"Unknown\";\n const digits = input.match(/\\d/g)?.join(\"\") || \"\";\n const ver = digits.length > 0\n ? digits[0] + (digits.length > 1 ? \".\" + digits.slice(1) : \"\")\n : \"\";\n return `${name} ${ver}`.trim();\n },\n\n async query(\n system: string,\n prompt: string,\n step = 0,\n ): Promise<{ data: string; model: string }> {\n const endpoints = [\n { type: \"sdk\", model: \"gemini-1.5-pro\" },\n { type: \"sdk\", model: \"gemini-1.5-flash\" },\n { type: \"fetch\", url: \"https://text.pollinations.ai/\", model: \"mistral\" },\n {\n type: \"fetch\",\n url: \"https://enter.pollinations.ai/\",\n model: \"mistral\",\n },\n ];\n const ep = endpoints[step];\n if (!ep) {\n return { data: \"Error: All API endpoints exhausted.\", model: \"None\" };\n }\n\n try {\n if (ep.type === \"sdk\") {\n const model = this.genAI.getGenerativeModel({\n model: ep.model,\n systemInstruction: system,\n });\n const res = await model.generateContent(prompt);\n return {\n data: res.response.text(),\n model: this.parseModelName(ep.model),\n };\n } else {\n const res = await fetch(ep.url!, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n messages: [{ role: \"system\", content: system }, {\n role: \"user\",\n content: prompt,\n }],\n model: ep.model,\n }),\n });\n const text = await res.text();\n if (!res.ok) throw new Error();\n return {\n data: text,\n model: `Pollinations ${this.parseModelName(ep.model)}`,\n };\n }\n } catch (e) {\n return this.query(system, prompt, step + 1);\n }\n },\n};\n\n// --- 4. SERVER ORCHESTRATOR ---\nconst app = new Hono();\n\napp.get(\"/\", async (c) => {\n await DB.init();\n const id = getCookie(c, \"apeiron_session\");\n const user = id\n ? (await sqlite.execute({\n sql: `SELECT * FROM ${TABLES.USERS} WHERE id = ?`,\n args: [id],\n })).rows[0]\n : null;\n const q = [\n { n: \"Bio-Logic\", i: \"Architecture grown from algorithmic code.\" },\n { n: \"Deep Sea\", i: \"Thermal server havens.\" },\n { n: \"Orbital\", i: \"Satellite junk arbitrage.\" },\n ];\n\n const logic =\n (await sqlite.execute({\n sql: `SELECT code FROM ${TABLES.KERNEL} WHERE name='ui'`,\n args: [],\n })).rows[0][0];\n const AsyncFunction = Object.getPrototypeOf(async function () {}).constructor;\n const scope: any = { UI: {} };\n await (new AsyncFunction(\"scope\", \"IDENTITY\", \"DB\", logic))(\n scope,\n IDENTITY,\n DB,\n );\n\n return c.html(\n await scope.UI.Layout({\n title: \"Nexus\",\n user,\n children: (\n

\n { \n const btn=document.getElementById('btn'); btn.disabled=true; btn.innerText='Manifesting...';\n const res=await fetch('/create',{method:'POST',body:new FormData(document.getElementById('mf'))});\n const d=await res.json(); if(d.id) {\n const poll = async () => {\n const r=await fetch('/api/status/'+d.id);\n const st=await r.json();\n document.getElementById('status').innerText = st.description;\n if(st.success) location.href = st.path;\n else setTimeout(poll, 5000);\n };\n poll();\n }\n })();\"\n class=\"space-y-8\"\n >\n \n

\n Ready\n

\n \n Manifest\n \n

\n \n

\n {q.map((i) => (\n \n

{i.n}

{i.i}

\n ))}\n \n \n ),\n }),\n );\n});\n\napp.post(\"/create\", async (c) => {\n const { idea } = await c.req.parseBody();\n const id = crypto.randomUUID();\n const uid = getCookie(c, \"apeiron_session\");\n await sqlite.execute({\n sql:\n `INSERT INTO ${TABLES.REQUESTS} (id, status, description, creator_id) VALUES (?, 'INIT', ?, ?)`,\n args: [id, idea as string, uid || null],\n });\n return c.json({ id });\n});\n\napp.get(\"/api/status/:id\", async (c) => {\n const res = await sqlite.execute({\n sql: `SELECT * FROM ${TABLES.REQUESTS} WHERE id=?`,\n args: [c.req.param(\"id\")],\n });\n const row = res.rows[0];\n if (!row || row[5] === 1) {\n return c.json({\n success: !!row?.[5],\n path: row?.[3],\n description: row?.[2],\n });\n }\n\n if (row[1] === \"INIT\") {\n const ai = await AI.query(\n 'Architect. JSON only: {\"name\":\"\", \"slug\":\"\", \"desc\":\"\"}',\n `Plan: ${row[2]}`,\n );\n const meta = JSON.parse(ai.data.replace(/```[a-z]*|\\n```/gi, \"\"));\n const slug = DB.formatSlug(meta.slug || meta.name);\n const path = `/s/${slug}/core/index.html`;\n await sqlite.execute({\n sql:\n `INSERT OR IGNORE INTO ${TABLES.SITES} (name, slug, idea, description) VALUES (?, ?, ?, ?)`,\n args: [meta.name, slug, row[2], meta.desc],\n });\n await sqlite.execute({\n sql:\n `INSERT OR IGNORE INTO ${TABLES.PAGES} (path, site_id, folder, title, generated) VALUES (?, (SELECT id FROM ${TABLES.SITES} WHERE slug=?), 'core', ?, 0)`,\n args: [path, slug, meta.name],\n });\n await sqlite.execute({\n sql:\n `UPDATE ${TABLES.REQUESTS} SET status='BODY', description='Writing Content...', path=? WHERE id=?`,\n args: [path, c.req.param(\"id\")],\n });\n } else if (row[1] === \"BODY\") {\n const path = row[3];\n const site =\n (await sqlite.execute({\n sql: `SELECT id, name, idea FROM ${TABLES.SITES} WHERE slug=?`,\n args: [path.split(\"/\")[2]],\n })).rows[0];\n const ai = await AI.query(\n \"Architect. HTML Body only.\",\n `Write content for ${site[1]}. Context: ${site[2]}`,\n );\n await sqlite.execute({\n sql: `UPDATE ${TABLES.PAGES} SET html = ?, generated = 1 WHERE path = ?`,\n args: [ai.data, path],\n });\n await sqlite.execute({\n sql:\n `UPDATE ${TABLES.REQUESTS} SET status='DONE', description='Stabilized', success=1 WHERE id=?`,\n args: [c.req.param(\"id\")],\n });\n }\n return c.json({ success: false, description: row[2] });\n});\n\napp.get(\"/s\", async (c) => {\n const page = parseInt(c.req.query(\"page\") || \"0\");\n const res = await sqlite.execute({\n sql:\n `SELECT name, slug, description FROM ${TABLES.SITES} ORDER BY ts DESC LIMIT 10 OFFSET ?`,\n args: [page * 10],\n });\n const logic =\n (await sqlite.execute({\n sql: `SELECT code FROM ${TABLES.KERNEL} WHERE name='ui'`,\n args: [],\n })).rows[0][0];\n const scope: any = { UI: {} };\n await (new (Object.getPrototypeOf(async function () {}).constructor)(\n \"scope\",\n \"IDENTITY\",\n \"DB\",\n logic,\n ))(scope, IDENTITY, DB);\n return c.html(\n await scope.UI.Layout({\n title: \"Sites\",\n children: (\n

\n {res.rows.map((s) => (\n \n

{s[0]}

{s[2]}

\n \n ))}\n

\n ),\n }),\n );\n});\n\napp.get(\"/s/:slug/:folder/:page\", async (c) => {\n const path = c.req.path.replace(/\\/+$/, \"\");\n const node =\n (await sqlite.execute({\n sql: `SELECT html FROM ${TABLES.PAGES} WHERE path=? AND generated=1`,\n args: [path],\n })).rows[0];\n const logic =\n (await sqlite.execute({\n sql: `SELECT code FROM ${TABLES.KERNEL} WHERE name='ui'`,\n args: [],\n })).rows[0][0];\n const scope: any = { UI: {} };\n await (new (Object.getPrototypeOf(async function () {}).constructor)(\n \"scope\",\n \"IDENTITY\",\n \"DB\",\n logic,\n ))(scope, IDENTITY, DB);\n return c.html(\n await scope.UI.Layout({\n title: \"Page\",\n children: (\n \n ),\n }),\n );\n});\n\napp.get(\"/db\", async (c) => {\n const data: any = {};\n for (const t of Object.values(TABLES)) {\n data[t] =\n (await sqlite.execute({ sql: `SELECT * FROM ${t} LIMIT 10`, args: [] }))\n .rows;\n }\n return c.html(\n \n \n {Object.entries(data).map(([n, r]: any) => (\n

{n}

\n \n {r.map((row: any) => (\n {Object.values(row).map((v) => )}\n ))}\n

{String(v)}

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