[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_249":250,"_251":252},"routes/_app.x.$handle.$name",{"_100":99,"_32":45,"_109":90,"_27":110,"_13":14,"_111":-5,"_11":112,"_113":114,"_115":116,"_117":118,"_119":120,"_20":-5,"_121":-5,"_122":-5,"_123":25,"_124":125,"_126":59,"_127":-5,"_128":-5,"_129":130},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":57,"_58":59,"_60":-5,"_61":-5,"_62":63,"_64":65,"_66":67,"_68":69,"_70":71,"_72":-5,"_73":74,"_75":74,"_76":77,"_78":77,"_79":77,"_80":74,"_81":74,"_82":83,"_84":85,"_86":87,"_88":25},"version",35,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","run.ts","latestPath","fileId","c25bf25a-9b6f-11f1-b373-1607ee4eb77e","name","fileType","script","content","import nodemailer from \"npm:nodemailer\";\nimport { blob } from \"https://esm.town/v/std/blob/main.ts\";\nimport { httpEndpoint } from \"https://esm.town/v/std/utils/index.ts\";\nimport { generateMailContent, generatePageCards } from \"./llm.ts\";\nimport type { Task } from \"./db.ts\";\n\n/** Recipient for all scheduled-task output (page links, reminders, failures). */\nexport const TO = \"you@example.com\";\n\nconst transporter = nodemailer.createTransport({\n service: \"gmail\",\n auth: {\n user: Deno.env.get(\"GMAIL_USER\"),\n pass: Deno.env.get(\"GMAIL_PASS\"),\n },\n});\n\n/** Send an email via Gmail SMTP to the recipient in `TO`. */\nexport async function sendMail(opts: { subject: string; text: string }): Promise {\n await transporter.sendMail({\n from: Deno.env.get(\"GMAIL_USER\"),\n to: TO,\n subject: opts.subject,\n text: opts.text,\n });\n}\n\n/**\n * Outcome of running a task via `executeTask`.\n * `url` is set only for page-output tasks that produced a viewable page.\n * `error` is set only when the run failed.\n */\nexport interface TaskResult {\n ok: boolean;\n url?: string;\n error?: string;\n}\n\n/**\n * Run a single task through the same generation path the cron uses\n * (mail or page via the LLM, then email / blob store + email).\n *\n * IMPORTANT: this is a pure execution — it does NOT consume the task.\n * It leaves `status` and `run_at` untouched, so the scheduled run still\n * fires normally and recurrence is not advanced. Callers decide whether\n * to mark the task done/error and reschedule.\n */\nexport async function executeTask(task: Task): Promise {\n try {\n if (task.output === \"mail\") {\n const { subject, content } = await generateMailContent(\n task.task,\n task.repeat,\n task.run_at,\n );\n await sendMail({ subject, text: content });\n return { ok: true };\n }\n // page output\n const { subject, cards } = await generatePageCards(\n task.task,\n task.repeat,\n task.run_at,\n );\n const key = crypto.randomUUID().replaceAll(\"-\", \"\");\n await blob.setJSON(key, cards);\n const base = (await httpEndpoint(\"/main.ts\")).replace(/\\/+$/, \"\");\n const url = `${base}/s/${key}`;\n await sendMail({ subject, text: `Your page is ready. View it here:\\n\\n${url}` });\n return { ok: true, url };\n } catch (err) {\n return {\n ok: false,\n error: err instanceof Error ? err.message : String(err),\n };\n }\n}\n","import nodemailer from \"npm:nodemailer\";\nimport { blob } from \"https://esm.town/v/std/blob/main.ts\";\nimport { httpEndpoint } from \"https://esm.town/v/std/utils/index.ts\";\nimport { generateMailContent, generatePageCards } from \"./llm.ts\";\nimport type { Task } from \"./db.ts\";\n\n/** Recipient for all scheduled-task output (page links, reminders, failures). */\nexport const TO = \"akarokan.97@gmail.com\";\n\nconst transporter = nodemailer.createTransport({\n service: \"gmail\",\n auth: {\n user: Deno.env.get(\"GMAIL_USER\"),\n pass: Deno.env.get(\"GMAIL_PASS\"),\n },\n});\n\n/** Send an email via Gmail SMTP to the recipient in `TO`. */\nexport async function sendMail(\n opts: { subject: string; text: string },\n): Promise {\n await transporter.sendMail({\n from: Deno.env.get(\"GMAIL_USER\"),\n to: TO,\n subject: opts.subject,\n text: opts.text,\n });\n}\n\n/**\n * Outcome of running a task via `executeTask`.\n * `url` is set only for page-output tasks that produced a viewable page.\n * `error` is set only when the run failed.\n */\nexport interface TaskResult {\n ok: boolean;\n url?: string;\n error?: string;\n}\n\n/**\n * Run a single task through the same generation path the cron uses\n * (mail or page via the LLM, then email / blob store + email).\n *\n * IMPORTANT: this is a pure execution — it does NOT consume the task.\n * It leaves `status` and `run_at` untouched, so the scheduled run still\n * fires normally and recurrence is not advanced. Callers decide whether\n * to mark the task done/error and reschedule.\n */\nexport async function executeTask(task: Task): Promise {\n try {\n if (task.output === \"mail\") {\n const { subject, content } = await generateMailContent(\n task.task,\n task.repeat,\n task.run_at,\n );\n await sendMail({ subject, text: content });\n return { ok: true };\n }\n // page output\n const { subject, cards } = await generatePageCards(\n task.task,\n task.repeat,\n task.run_at,\n );\n const key = crypto.randomUUID().replaceAll(\"-\", \"\");\n await blob.setJSON(key, cards);\n const base = (await httpEndpoint(\"/main.ts\")).replace(/\\/+$/, \"\");\n const url = `${base}/s/${key}`;\n await sendMail({\n subject,\n text: `Your page is ready. View it here:\\n\\n${url}`,\n });\n return { ok: true, url };\n } catch (err) {\n return {\n ok: false,\n error: err instanceof Error ? err.message : String(err),\n };\n }\n}","createdAt",["D",1787105194107],"branchVersion","branchId","7cc41e5b-7347-409f-bdd2-d6cabae85cc2","id","b6c508ed-5367-4c80-adf4-89148338dcf2","scheduler",["D",1787102792105],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Aylık takvim todo + mail bildirimleri | SQLite, cron, nodemailer","imageUrl","36451bfa-e5dd-4ea2-8063-aefa91faa516","pinnedFileId","02883800-9b6d-11f1-8f0e-1607ee4eb77e","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","01a0178b-157e-745d-828e-eb11a1cff70a","tursoName","b6c508ed53674c80adf489148338dcf2","tursoHostname","b6c508ed53674c80adf489148338dcf2-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789534231467],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_100":99,"_108":104},"org",{"_100":99,"_101":102,"_103":104,"_18":55,"_105":106,"_107":25},"branch",{"_13":89,"_32":90,"_43":42,"_91":44,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":45,"_98":99},"isOwned",78,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","user9823475","handle","displayName","okan akar","avatar","https://lh3.googleusercontent.com/a/ACg8ocKVv87Cs_fECuMIhkwYWxOb1IWIAtks8lzjYrrflQ1fhtYr6A=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_43":44,"_32":45,"_38":244,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":57,"_58":59,"_60":-5,"_61":-5,"_62":63,"_64":65,"_66":67,"_68":69,"_70":245,"_72":-5,"_73":74,"_75":74,"_76":77,"_78":77,"_79":77,"_80":74,"_81":74,"_82":246,"_84":247,"_86":248,"_88":25},"tree",[211,212,213,214,215,216,217,218],"files",[211,212,213,214,215,216,217,218],"counts",{"_201":63,"_202":198,"_203":63,"_204":205,"_206":207},"contents",[131,132,133,134,135,136,137,138],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":193,"_32":194,"_30":195,"_142":-5,"_41":42,"_40":196,"_144":25,"_38":197,"_13":198,"_33":20,"_35":199,"_24":25,"_147":-5,"_27":200},{"_43":184,"_32":185,"_30":186,"_142":-5,"_41":42,"_40":187,"_144":25,"_38":188,"_13":189,"_33":190,"_35":191,"_24":25,"_147":-5,"_27":192},{"_43":177,"_32":178,"_30":179,"_142":-5,"_41":42,"_40":180,"_144":25,"_38":181,"_13":158,"_33":34,"_35":182,"_24":25,"_147":-5,"_27":183},{"_43":170,"_32":171,"_30":172,"_142":-5,"_41":42,"_40":173,"_144":25,"_38":174,"_13":158,"_33":34,"_35":175,"_24":25,"_147":-5,"_27":176},{"_43":161,"_32":162,"_30":57,"_142":-5,"_41":42,"_40":163,"_144":25,"_38":164,"_13":165,"_33":166,"_35":167,"_24":25,"_147":168,"_27":169},{"_43":153,"_32":154,"_30":155,"_142":-5,"_41":42,"_40":156,"_144":25,"_38":157,"_13":158,"_33":20,"_35":159,"_24":25,"_147":-5,"_27":160},{"_43":149,"_32":28,"_30":31,"_142":-5,"_41":42,"_40":14,"_144":25,"_38":150,"_13":151,"_33":34,"_35":37,"_24":25,"_147":-5,"_27":152},{"_43":139,"_32":140,"_30":141,"_142":-5,"_41":42,"_40":143,"_144":25,"_38":145,"_13":63,"_33":34,"_35":146,"_24":25,"_147":-5,"_27":148},"1cc2dca6-703d-4f1d-9d99-ee9d2fb92a2c","test.js","1862c610-9b70-11f1-ade9-1607ee4eb77e","parentId",29,"latest",["D",1787104117289],"// Test Now buttons: run a task immediately and show the outcome on its row,\n// without consuming the task (status/run_at are left untouched by the server).\ndocument.addEventListener(\"DOMContentLoaded\", () => {\n // The form page is behind APP_SECRET (passed as ?secret=...), so reuse it\n // on the test requests made from this page.\n const secret = new URLSearchParams(window.location.search).get(\"secret\") || \"\";\n\n for (const btn of document.querySelectorAll(\"button.test\")) {\n btn.addEventListener(\"click\", async () => {\n const id = btn.dataset.id;\n const out = document.getElementById(\"test-result-\" + id);\n if (!out) return;\n\n btn.disabled = true;\n const label = btn.textContent;\n btn.textContent = \"Testing…\";\n out.className = \"test-result\";\n out.textContent = \"Running…\";\n\n const qs = secret ? \"?secret=\" + encodeURIComponent(secret) : \"\";\n try {\n const resp = await fetch(\"/test/\" + id + qs, { method: \"POST\" });\n const data = await resp.json().catch(() => ({}));\n if (resp.ok && data.url) {\n out.className = \"test-result\";\n out.innerHTML =\n 'Open result page ↗';\n } else if (resp.ok && data.error) {\n out.className = \"test-result res-error\";\n out.textContent = \"Error: \" + data.error;\n } else if (resp.ok) {\n out.className = \"test-result res-ok\";\n out.textContent = \"Sent — check your email.\";\n } else {\n out.className = \"test-result res-error\";\n out.textContent = (data && data.error) ? data.error : \"Test failed (\" + resp.status + \").\";\n }\n } catch (e) {\n out.className = \"test-result res-error\";\n out.textContent = \"Error: \" + e.message;\n } finally {\n btn.disabled = false;\n btn.textContent = label;\n }\n });\n }\n});\n","label",[140],"f7ada0a5-5c7a-4e7e-9357-488cf5d18c51",["D",1787105194107],3,[28],"ebdffb2c-a0f0-4159-9c89-c52714c1cf12","page.html","36b394bc-9b6d-11f1-aee4-1607ee4eb77e",21,["D",1787103496712],2,"\n\n\n\n\nYour Page\n\n\n\n

Your scheduled page

\n\n\n\n",[154],"a2a5d2b7-f05e-491c-8778-e13f829d2e09","main.ts",30,["D",1787104140287],11,"http","import { Hono } from \"npm:hono\";\nimport { readFile } from \"https://esm.town/v/std/utils/index.ts\";\nimport { blob } from \"https://esm.town/v/std/blob/main.ts\";\nimport { parseTask } from \"./llm.ts\";\nimport { insertTask, listTasks, getTask, deleteTask, type Task } from \"./db.ts\";\nimport { executeTask } from \"./run.ts\";\n\nconst SECRET = Deno.env.get(\"APP_SECRET\");\n\nconst app = new Hono();\napp.onError((err) => Promise.reject(err));\n\nconst CSS = `\n * { box-sizing: border-box; }\n body { margin:0; font-family:system-ui,-apple-system,\"Segoe UI\",Roboto,sans-serif; background:#f5f6f8; color:#1c1e21; }\n .wrap { max-width:720px; margin:0 auto; padding:24px 16px 64px; }\n h1 { font-size:24px; margin:0 0 4px; }\n .sub { color:#6b7280; margin:0 0 20px; }\n form.schedule { display:flex; flex-direction:column; gap:10px; margin-bottom:24px; }\n textarea { width:100%; min-height:120px; padding:14px; font-size:16px; border:1px solid #d1d5db; border-radius:10px; resize:vertical; font-family:inherit; }\n textarea:focus { outline:2px solid #2563eb; outline-offset:-1px; }\n button { border:none; border-radius:10px; padding:12px 18px; font-size:16px; font-weight:600; cursor:pointer; }\n button[type=submit] { background:#2563eb; color:#fff; }\n button[type=submit]:hover { background:#1d4ed8; }\n .confirm { background:#ecfdf5; border:1px solid #a7f3d0; color:#065f46; padding:14px 16px; border-radius:10px; margin-bottom:24px; }\n .confirm code { background:#d1fae5; padding:1px 6px; border-radius:6px; }\n h2 { font-size:18px; margin:28px 0 12px; }\n .empty { color:#6b7280; }\n .table { width:100%; border-collapse:collapse; background:#fff; border:1px solid #e5e7eb; border-radius:10px; overflow:hidden; }\n .table th, .table td { text-align:left; padding:10px 12px; border-bottom:1px solid #eef0f3; vertical-align:top; }\n .table th { background:#f9fafb; font-size:12px; text-transform:uppercase; letter-spacing:.04em; color:#6b7280; }\n .table tr:last-child td { border-bottom:none; }\n .table .task { font-weight:500; }\n .badge { display:inline-block; padding:2px 8px; border-radius:999px; font-size:12px; font-weight:600; white-space:nowrap; }\n .b-page { background:#eef2ff; color:#4338ca; }\n .b-mail { background:#fef3c7; color:#92400e; }\n .b-pending { background:#f3f4f6; color:#374151; }\n .b-done { background:#ecfdf5; color:#065f46; }\n .b-error { background:#fee2e2; color:#991b1b; }\n .actions { display:flex; gap:8px; align-items:center; flex-wrap:wrap; }\n button.test { background:#eef2ff; color:#4338ca; padding:6px 10px; font-size:13px; border-radius:8px; }\n button.test:hover { background:#e0e7ff; }\n button.test:disabled { opacity:.6; cursor:progress; }\n .del { background:#fee2e2; color:#b91c1c; padding:6px 10px; font-size:13px; border-radius:8px; }\n .del:hover { background:#fecaca; }\n .test-result { margin-top:6px; font-size:12px; line-height:1.4; }\n .test-result.res-error { color:#b91c1c; }\n .test-result.res-ok { color:#065f46; }\n a.res-link { color:#2563eb; font-weight:600; word-break:break-all; }\n .nowrap { white-space:nowrap; }\n .right { text-align:right; }\n @media (max-width:560px){\n .table thead { display:none; }\n .table, .table tbody, .table tr, .table td { display:block; width:100%; }\n .table tr { border:1px solid #e5e7eb; border-radius:10px; margin-bottom:10px; padding:8px 12px; }\n .table td { border:none; padding:4px 0; }\n .table td::before { content:attr(data-label); display:block; font-size:11px; text-transform:uppercase; letter-spacing:.04em; color:#6b7280; margin-bottom:2px; }\n }\n`;\n\nfunction badge(cls: string, label: string): string {\n return `${label}`;\n}\n\n/**\n * The form page and task-managing routes are protected by a shared APP_SECRET,\n * passed as the `secret` query parameter. When the secret is unset on the\n * server, access is denied by default (fail closed).\n */\nfunction authorized(secretQuery: string | null): boolean {\n if (!SECRET) return false;\n if (!secretQuery || secretQuery.length !== SECRET.length) return false;\n // constant-time comparison\n let diff = 0;\n for (let i = 0; i < SECRET.length; i++) diff |= secretQuery.charCodeAt(i) ^ SECRET.charCodeAt(i);\n return diff === 0;\n}\n\nasync function renderPage(confirmHtml: string): Promise {\n return `\n\n\nTask Scheduler\n\n

Task Scheduler

Describe a task in plain language — when, how often, and what to do.

\n${confirmHtml}\n\n

Scheduled tasks

\n${await tasksTable()}\n

`;\n}\n\nasync function tasksTable(): Promise {\n const tasks = await listTasks();\n if (tasks.length === 0) {\n return `

No tasks yet. Schedule one above.

`;\n }\n const rows = tasks.map((t) => {\n const out = t.output === \"page\"\n ? badge(\"b-page\", \"page\")\n : badge(\"b-mail\", \"mail\");\n const status = t.status === \"done\"\n ? badge(\"b-done\", \"done\")\n : t.status === \"error\"\n ? badge(\"b-error\", \"error\")\n : badge(\"b-pending\", \"pending\");\n return `\n ${esc(fmt(t.run_at))}\n ${esc(t.task)}\n ${out}\n ${status}\n \n

\n \n \n

\n \n `;\n }).join(\"\");\n return `\n \n ${rows}

Run at	Task	Output	Status

`;\n}\n\nfunction fmt(iso: string): string {\n const d = new Date(iso);\n if (isNaN(d.getTime())) return iso;\n return d.toLocaleString(undefined, {\n month: \"short\", day: \"numeric\", hour: \"numeric\", minute: \"2-digit\",\n });\n}\n\napp.get(\"/\", async (c) => {\n const secret = c.req.query(\"secret\");\n if (!authorized(secret)) return c.text(\"Unauthorized\", 401);\n const added = Number(c.req.query(\"added\"));\n let confirmHtml = \"\";\n if (added) {\n const t = await getTask(added);\n if (t) {\n confirmHtml =\n `

Task scheduled ✓
` +\n `Run at ${esc(fmt(t.run_at))} · ` +\n `${esc(t.task)} · output: ${esc(t.output)}

`;\n }\n }\n return c.html(await renderPage(confirmHtml));\n});\n\napp.post(\"/\", async (c) => {\n const secret = c.req.query(\"secret\");\n if (!authorized(secret)) return c.text(\"Unauthorized\", 401);\n const body = await c.req.parseBody();\n const t = String(body.t ?? \"\").trim();\n if (!t) return c.redirect(`/?secret=${encodeURIComponent(secret ?? \"\")}`);\n const parsed = await parseTask(t, new Date());\n const id = await insertTask(parsed);\n return c.redirect(`/?added=${id}&secret=${encodeURIComponent(secret ?? \"\")}`);\n});\n\napp.post(\"/delete/:id\", async (c) => {\n const secret = c.req.query(\"secret\");\n if (!authorized(secret)) return c.text(\"Unauthorized\", 401);\n const id = Number(c.req.param(\"id\"));\n if (id) await deleteTask(id);\n return c.redirect(`/?secret=${encodeURIComponent(secret ?? \"\")}`);\n});\n\n// Test Now: run a task immediately via the same path the cron uses.\n// This does NOT consume the task — status/run_at/recurrence are untouched,\n// so the task still fires normally at its scheduled time.\napp.post(\"/test/:id\", async (c) => {\n const secret = c.req.query(\"secret\");\n if (!authorized(secret)) return c.json({ error: \"Unauthorized\" }, 401);\n const id = Number(c.req.param(\"id\"));\n if (!id) return c.json({ error: \"Invalid task id\" }, 400);\n const task = await getTask(id);\n if (!task) return c.json({ error: \"Task not found\" }, 404);\n const result = await executeTask(task);\n if (result.ok) return c.json({ url: result.url ?? null });\n return c.json({ error: result.error ?? \"Failed\" });\n});\n\n// Static client script wiring the Test buttons.\napp.get(\"/test.js\", async () => {\n const js = await readFile(\"/test.js\");\n return new Response(js, {\n headers: { \"content-type\": \"text/javascript; charset=utf-8\" },\n });\n});\n\n// Generated pages stay public so links shared via email open without the secret.\napp.get(\"/s/:key\", async (c) => {\n const key = c.req.param(\"key\");\n try {\n const cards: unknown = await blob.getJSON(key);\n const template = await readFile(\"/page.html\");\n const html = template.replace(\"__CARDS_JSON__\", JSON.stringify(cards));\n return c.html(html);\n } catch {\n return c.text(\"Page not found\", 404);\n }\n});\n\nfunction esc(s: string): string {\n return s.replace(/[&<>\"']/g, (ch) =>\n ({ \"&\": \"&\", \"<\": \"<\", \">\": \">\", '\"': \""\", \"'\": \"'\" })[ch]!\n );\n}\n\nexport default app.fetch;\n","task-scheduler",[162],"dd4f966e-ade4-45ad-a370-123ec1aa4836","llm.ts","36ae7afe-9b6d-11f1-aee4-1607ee4eb77e",22,["D",1787103506894],"import { OpenAI } from \"https://esm.town/v/std/openai/main.ts\";\n\nconst openai = new OpenAI();\nconst MODEL = \"gpt-5.4-nano\";\n\nexport interface ParsedTask {\n run_at: string;\n repeat: \"none\" | \"daily\" | \"weekly\";\n task: string;\n output: \"mail\" | \"page\";\n}\n\nexport interface Card {\n title: string;\n type: \"list\" | \"text\";\n content: string[];\n}\n\n/**\n * Turn a plain-language instruction into a scheduled task.\n * Relative times are resolved against `now` (passed into the prompt).\n */\nexport async function parseTask(instruction: string, now: Date): Promise {\n const completion = await openai.chat.completions.create({\n model: MODEL,\n max_completion_tokens: 200,\n messages: [\n {\n role: \"system\",\n content:\n \"You convert a plain-language instruction into a scheduled task.\\n\" +\n `Current time: ${now.toISOString()} (ISO 8601 UTC). ` +\n \"Resolve relative times (e.g. \\\"in 5 minutes\\\", \\\"tomorrow at 8am\\\") into that UTC ISO timestamp.\\n\" +\n 'Answer with ONLY valid JSON matching: {\"run_at\":\"\",\"repeat\":\"none|daily|weekly\",\"task\":\"\",\"output\":\"mail|page\"}\\n' +\n 'Set \"repeat\" to \"daily\" for every day, \"weekly\" for every week, otherwise \"none\".\\n' +\n 'Set \"output\" to \"page\" if the instruction mentions a site, page, or link, or asks to create/show/see anything visual (report, checklist, board, list of links, graph). ' +\n 'Be aggressive about choosing \"page\" when words like \"page\", \"site\", \"link\", \"URL\", \"checklist\", or \"report\" appear. ' +\n 'Only set \"output\" to \"mail\" for simple text reminders, pings, or notifications.',\n },\n { role: \"user\", content: instruction },\n ],\n });\n const text = completion.choices[0].message.content ?? \"\";\n return JSON.parse(text) as ParsedTask;\n}\n\n/** Shared schedule context used to phrase email subjects. */\nfunction scheduleContext(task: string, repeat: string, runAt: string): string {\n return `Task: \"${task}\"\\nRepeat: ${repeat}\\nScheduled for: ${runAt} (ISO UTC)`;\n}\n\n/**\n * Normalize a subject from the LLM into \"Title | Schedule note | Val\".\n * Trims, drops empties, and guarantees the \"Val\" suffix.\n */\nexport function normalizeSubject(raw: string): string {\n const parts = raw\n .split(\"|\")\n .map((s) => s.trim())\n .filter((s) => s.length > 0);\n if (parts.length === 0) return `Task | Val`;\n if (parts[parts.length - 1].toLowerCase() !== \"val\") parts.push(\"Val\");\n return parts.slice(0, 3).join(\" | \");\n}\n\n/** Generate the subject + plain text body for a mail-output task. */\nexport async function generateMailContent(\n task: string,\n repeat: string,\n runAt: string,\n): Promise<{ subject: string; content: string }> {\n const completion = await openai.chat.completions.create({\n model: MODEL,\n max_completion_tokens: 600,\n messages: [\n {\n role: \"system\",\n content:\n \"You generate an email for a scheduled task.\\n\" +\n `${scheduleContext(task, repeat, runAt)}\\n` +\n 'Answer with ONLY valid JSON matching: {\"subject\":\"Title | Schedule note | Val\",\"content\":\"the email body\"}\\n' +\n '\"subject\" has exactly three parts separated by \" | \", ending with \"Val\". ' +\n 'Part 1 is a short name for the thing itself (e.g. \"To do list\"). ' +\n \"Part 2 is a human-readable schedule note phrased for THIS schedule: for a one-off use a date/time like \\\"Scheduled for 19.08 03:36\\\"; \" +\n 'for a recurring task use something like \"Daily at 8am\", \"Every Monday\", or \"Weekly\".\\n' +\n '\"content\" is the full body as plain text. If it is a checklist, use \"- item\" lines.',\n },\n { role: \"user\", content: task },\n ],\n });\n const text = completion.choices[0].message.content ?? \"\";\n const parsed = JSON.parse(text) as { subject?: string; content?: string };\n return {\n subject: normalizeSubject(parsed.subject ?? \"\"),\n content: parsed.content ?? \"\",\n };\n}\n\n/** Generate the subject + structured cards for a page-output task. */\nexport async function generatePageCards(\n task: string,\n repeat: string,\n runAt: string,\n): Promise<{ subject: string; cards: Card[] }> {\n const completion = await openai.chat.completions.create({\n model: MODEL,\n max_completion_tokens: 1000,\n messages: [\n {\n role: \"system\",\n content:\n \"You generate a page for a scheduled task.\\n\" +\n `${scheduleContext(task, repeat, runAt)}\\n` +\n 'Answer with ONLY valid JSON matching: {\"subject\":\"Title | Schedule note | Val\",\"cards\":[{\"title\":\"...\",\"type\":\"list|text\",\"content\":[\"...\"]}]}\\n' +\n '\"subject\" has exactly three parts separated by \" | \", ending with \"Val\". ' +\n 'Part 1 is a short name for the thing itself. ' +\n 'Part 2 is a human-readable schedule note phrased for THIS schedule (date/time for a one-off, \"Daily\"/\"Every Monday\" etc. for recurring).\\n' +\n 'Use \"type\":\"list\" for checklists and put each item as a separate string in \"content\". ' +\n 'Use \"type\":\"text\" for prose and put each paragraph as a separate string in \"content\".',\n },\n { role: \"user\", content: task },\n ],\n });\n const text = completion.choices[0].message.content ?? \"\";\n const parsed = JSON.parse(text) as { subject?: string; cards?: Card[] };\n return {\n subject: normalizeSubject(parsed.subject ?? \"\"),\n cards: parsed.cards ?? [],\n };\n}\n",[171],"e56b47fa-a982-4da2-814b-02f9ba547b19","db.ts","36a8cd0c-9b6d-11f1-aee4-1607ee4eb77e",16,["D",1787103477998],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nexport interface Task {\n id: number;\n run_at: string;\n repeat: \"none\" | \"daily\" | \"weekly\";\n task: string;\n output: \"mail\" | \"page\";\n status: \"pending\" | \"done\" | \"error\";\n}\n\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS tasks (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n run_at TEXT NOT NULL,\n repeat TEXT NOT NULL DEFAULT 'none',\n task TEXT NOT NULL,\n output TEXT NOT NULL DEFAULT 'mail',\n status TEXT NOT NULL DEFAULT 'pending'\n)`);\n\nexport async function insertTask(t: {\n run_at: string;\n repeat: string;\n task: string;\n output: string;\n}): Promise {\n const res = await sqlite.execute({\n sql: \"INSERT INTO tasks (run_at, repeat, task, output, status) VALUES (?, ?, ?, ?, 'pending')\",\n args: [t.run_at, t.repeat, t.task, t.output],\n });\n return Number(res.lastInsertRowid);\n}\n\n/** All pending tasks whose run_at has passed. */\nexport async function getDueTasks(): Promise {\n const res = await sqlite.execute({\n sql: \"SELECT * FROM tasks WHERE status = 'pending' AND run_at <= ?\",\n args: [new Date().toISOString()],\n });\n return res.rows as Task[];\n}\n\nexport async function updateTask(\n id: number,\n status: \"pending\" | \"done\" | \"error\",\n runAt: string,\n): Promise {\n await sqlite.execute({\n sql: \"UPDATE tasks SET status = ?, run_at = ? WHERE id = ?\",\n args: [status, runAt, id],\n });\n}\n\n/** All tasks, ordered by when they fire, earliest first. */\nexport async function listTasks(): Promise {\n const res = await sqlite.execute(\"SELECT * FROM tasks ORDER BY run_at ASC\");\n return res.rows as Task[];\n}\n\nexport async function getTask(id: number): Promise {\n const res = await sqlite.execute({\n sql: \"SELECT * FROM tasks WHERE id = ?\",\n args: [id],\n });\n return (res.rows as Task[])[0];\n}\n\nexport async function deleteTask(id: number): Promise {\n await sqlite.execute({ sql: \"DELETE FROM tasks WHERE id = ?\", args: [id] });\n}\n",[178],"29b913f9-bedc-4ff5-b36e-a6e3b4dcfeca","cron.ts","36ba2304-9b6d-11f1-aee4-1607ee4eb77e",34,["D",1787105129031],6,"interval","import { getDueTasks, updateTask } from \"./db.ts\";\nimport { executeTask, sendMail } from \"./run.ts\";\n\nconst DAY = 24 * 60 * 60 * 1000;\n\n/** Compute the next run_at for a repeating task, or null if it's a one-off. */\nexport function nextRunAt(repeat: string, now: Date): string | null {\n if (repeat === \"daily\") return new Date(now.getTime() + DAY).toISOString();\n if (repeat === \"weekly\") return new Date(now.getTime() + 7 * DAY).toISOString();\n return null;\n}\n\nexport default async function (interval: Interval) {\n const due = await getDueTasks();\n for (const row of due) {\n const now = new Date();\n const result = await executeTask(row);\n if (result.ok) {\n const next = nextRunAt(row.repeat, now);\n await updateTask(row.id, next ? \"pending\" : \"done\", next ?? row.run_at);\n } else {\n console.error(\"Task failed:\", row.id, result.error);\n await updateTask(row.id, \"error\", row.run_at);\n try {\n await sendMail({\n subject: \"Scheduled task failed\",\n text:\n `Scheduled task #${row.id} (\"${row.task}\") failed:\\n\\n` +\n result.error,\n });\n } catch (emailErr) {\n console.error(\"Failed to send failure email:\", emailErr);\n }\n }\n }\n}\n",[185],"f7f640a0-5b11-4b6c-8cf0-607f55b94c93","README.md","6ba67bc6-9b6d-11f1-acc3-1607ee4eb77e",26,["D",1787103600307],1,"# Task Scheduler\n\nAn LLM-powered task scheduler on Val Town. Type a plain-language instruction; it's parsed by OpenAI into a scheduled task, stored in SQLite, and executed by a every-minute cron that delivers the result by email or as a hosted page.\n\nLive at **https://task-scheduler.val.run/**\n\n## How it works\n\n```\n/?t=... ──► LLM parses into {\"run_at\",\"repeat\",\"task\",\"output\"} ──► SQLite `tasks`\n ──► cron (every minute)\n ├─ mail → generate text → std/email\n └─ page → cards JSON → blob → email link → /s/{key}\n```\n\n### 1. Database (`db.ts`)\nSQLite table `tasks`:\n`id`, `run_at` (ISO timestamp), `repeat` (`none`/`daily`/`weekly`), `task`, `output` (`mail`/`page`), `status` (`pending`/`done`/`error`).\n\n### 2. HTTP endpoint (`main.ts`)\n- `GET /?t=` — parses the instruction with OpenAI (`std/openai`, model `gpt-5.4-nano`, using `max_completion_tokens`). The current UTC time is passed into the prompt so \"in 5 minutes\" / \"tomorrow at 8am\" resolve correctly. `output` is `page` when the instruction mentions a site/page/link (or is visual), else `mail`. Inserts the task and returns a confirmation page.\n- `GET /s/{key}` — serves a saved page.\n\n### 3. Cron (`cron.ts`)\nRuns every minute (`* * * * *` UTC). Finds `status = pending AND run_at <= now`. For each:\n- `mail` → generate content with OpenAI, send via `std/email`.\n- `page` → generate `{\"cards\":[{title,type:\"list\"|\"text\",content:[...]}]}`, embed into the self-contained page template, store under a random blob key, email only the `/s/{key}` link.\n- Then mark `done`, or compute the next `run_at` if it repeats daily/weekly.\n- On any failure: mark `error` and email the message.\n- Email subjects are LLM-generated as three pipe-separated parts, e.g. `To do list | Scheduled for 19.08 03:36 | Val` — the LLM phrases the middle schedule note per task (date/time for one-offs, \"Daily at 8am\" / \"Every Monday\" for recurring).\n\n## Page design (`page.html`)\nVertical list of cards. Clicking a card expands/collapses it. `list` cards render one checkbox per item — checked items show strikethrough, persisted in `localStorage` per card. Clicking anywhere on a checklist row toggles that item's checkbox; checkboxes are custom-styled to match the dark theme (accent fill + white check when checked).\n\n## Files\n| File | Type | Purpose |\n| --- | --- | --- |\n| `main.ts` | http | Title/parse endpoint + `/s/{key}` page server |\n| `db.ts` | script | SQLite helpers |\n| `llm.ts` | script | OpenAI helpers (parse task, generate mail/page content) |\n| `cron.ts` | interval | Every-minute scheduler |\n| `page.html` | file | Card page template |\n| `README.md` | file | This doc |\n\n## Usage\n```text\n/?t=remind me in 5 minutes to drink water\n/?t=daily at 8am send me a weather summary\n/?t=every week make a page with a checklist for my project kickoff\n```\n\n## Setup\nNo environment variables required — `std/openai` and `std/email` use Val Town's built-in credentials (the `valtown` token is injected automatically). Just remix or deploy the val.\n",[194],"pulls","branches","forks","envVars",{"_208":151,"_210":63},"connections",{"_208":63,"_209":63},"count","unfilledCount","emptyCount",{"_43":193,"_32":194,"_30":195,"_142":-5,"_41":42,"_40":196,"_144":25,"_38":241,"_13":198,"_33":20,"_35":199,"_24":25,"_147":-5,"_220":242,"_27":243},{"_43":184,"_32":185,"_30":186,"_142":-5,"_41":42,"_40":187,"_144":25,"_38":238,"_13":189,"_33":190,"_35":191,"_24":25,"_147":-5,"_220":239,"_27":240},{"_43":177,"_32":178,"_30":179,"_142":-5,"_41":42,"_40":180,"_144":25,"_38":235,"_13":158,"_33":34,"_35":182,"_24":25,"_147":-5,"_220":236,"_27":237},{"_43":170,"_32":171,"_30":172,"_142":-5,"_41":42,"_40":173,"_144":25,"_38":232,"_13":158,"_33":34,"_35":175,"_24":25,"_147":-5,"_220":233,"_27":234},{"_43":161,"_32":162,"_30":57,"_142":-5,"_41":42,"_40":163,"_144":25,"_38":229,"_13":165,"_33":166,"_35":167,"_24":25,"_147":168,"_220":230,"_27":231},{"_43":153,"_32":154,"_30":155,"_142":-5,"_41":42,"_40":156,"_144":25,"_38":226,"_13":158,"_33":20,"_35":159,"_24":25,"_147":-5,"_220":227,"_27":228},{"_43":149,"_32":28,"_30":31,"_142":-5,"_41":42,"_40":14,"_144":25,"_38":223,"_13":151,"_33":34,"_35":37,"_24":25,"_147":-5,"_220":224,"_27":225},{"_43":139,"_32":140,"_30":141,"_142":-5,"_41":42,"_40":143,"_144":25,"_38":219,"_13":63,"_33":34,"_35":146,"_24":25,"_147":-5,"_220":221,"_27":222},["D",1787104117289],"children",[],[140],["D",1787105194107],[],[28],["D",1787103496712],[],[154],["D",1787104140287],[],[162],["D",1787103506894],[],[171],["D",1787103477998],[],[178],["D",1787105129031],[],[185],["D",1787103600307],[],[194],["D",1787102792105],["D",1789534231467],{"_100":99,"_108":104},{"_100":99,"_101":102,"_103":104,"_18":55,"_105":106,"_107":25},{"_13":89,"_32":90,"_43":42,"_91":44,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":45,"_98":99},"ctx",{"_82":-5,"_128":282,"_283":284,"_285":286,"_287":25,"_288":25,"_289":25,"_290":59,"_291":-5,"_292":-7,"_293":-7,"_294":63,"_295":25,"_296":25,"_297":-5,"_298":25,"_299":25,"_300":25,"_301":-5},"ENV",{"_253":254,"_255":256,"_257":90,"_258":259,"_260":261,"_262":263,"_264":265,"_266":267,"_268":269,"_270":271,"_272":273,"_274":275,"_276":277,"_278":279,"_280":281},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v35