[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_231":232,"_233":234},"routes/_app.x.$handle.$name",{"_106":105,"_38":51,"_115":96,"_33":116,"_13":14,"_117":-5,"_11":118,"_119":120,"_121":122,"_123":124,"_125":126,"_26":-5,"_127":-5,"_128":-5,"_129":31,"_130":131,"_132":65,"_133":-5,"_134":-5,"_135":136},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":18,"_19":-5},"project",{"_49":50,"_38":51,"_44":52,"_53":-5,"_54":31,"_55":56,"_57":56,"_58":59,"_60":-5,"_19":61,"_62":63,"_64":65,"_66":-5,"_67":-5,"_68":69,"_70":71,"_72":73,"_74":75,"_76":77,"_78":-5,"_79":80,"_81":80,"_82":83,"_84":83,"_85":83,"_86":80,"_87":80,"_88":89,"_90":91,"_92":93,"_94":31},"version",51,"changes",[25],"aiChatInfo",{"_20":21,"_22":-5,"_23":-5,"_24":-5},"userId","aiChatMessageId","85f07e0d-f02f-4927-9b94-6558ef12733c","aiChatThreadId","aiChatThreadUserId","aiChatThreadTitle",{"_26":27,"_28":29,"_30":31,"_32":31,"_33":34,"_35":34},"file",{"_36":37,"_38":34,"_39":40,"_41":43,"_44":45,"_46":14,"_47":48,"_30":31},"previous",{"_36":37,"_38":34,"_39":40,"_41":42},"deleted",false,"deletedHere","path","db.ts","latestPath","fileId","36a8cd0c-9b6d-11f1-aee4-1607ee4eb77e","name","fileType","script","content","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","import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { addDays } from \"./time.ts\";\n\nexport type TaskStatus = \"open\" | \"done\" | \"moved\";\n\nexport interface Task {\n id: number;\n date: string; // YYYY-MM-DD (Berlin)\n text: string;\n position: number;\n status: TaskStatus;\n moved_to_id: number | null;\n moved_from_id: number | null;\n red_enabled: number; // 1 | 0\n created_at: string;\n}\n\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS tasks (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n date TEXT NOT NULL,\n text TEXT NOT NULL,\n position INTEGER NOT NULL DEFAULT 0,\n status TEXT NOT NULL DEFAULT 'open',\n moved_to_id INTEGER,\n moved_from_id INTEGER,\n red_enabled INTEGER NOT NULL DEFAULT 1,\n created_at TEXT NOT NULL\n)`);\n\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS settings (\n key TEXT PRIMARY KEY,\n value TEXT\n)`);\n\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS email_sent (\n day TEXT NOT NULL,\n time TEXT NOT NULL,\n PRIMARY KEY (day, time)\n)`);\n\nconst CREATE_TASK_SQL =\n `INSERT INTO tasks (date, text, position, status, moved_to_id, moved_from_id, red_enabled, created_at)\n VALUES (?, ?, ?, 'open', NULL, NULL, ?, ?)`;\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[0] as Task | undefined;\n}\n\nexport async function listTasksAll(): Promise {\n const res = await sqlite.execute(\"SELECT * FROM tasks ORDER BY date, position, id\");\n return res.rows as Task[];\n}\n\nexport async function insertTask(p: {\n date: string;\n text: string;\n red_enabled?: number;\n position?: number;\n}): Promise {\n const cnt = await sqlite.execute({\n sql: \"SELECT COUNT(*) AS c FROM tasks WHERE date = ?\",\n args: [p.date],\n });\n const c = Number((cnt.rows[0] as { c: number }).c ?? 0);\n const pos = p.position ?? c + 1;\n const res = await sqlite.execute({\n sql: CREATE_TASK_SQL,\n args: [p.date, p.text, pos, p.red_enabled ?? 1, new Date().toISOString()],\n });\n return Number(res.lastInsertRowid);\n}\n\n/** Flip a task between done and open. */\nexport async function toggleTask(id: number): Promise {\n const t = await getTask(id);\n if (!t) return;\n const ns: TaskStatus = t.status === \"done\" ? \"open\" : \"done\";\n await sqlite.execute({\n sql: \"UPDATE tasks SET status = ? WHERE id = ?\",\n args: [ns, id],\n });\n}\n\n/** Update text / red_enabled / position in place (no status change). */\nexport async function updateTaskInPlace(\n id: number,\n patch: { text?: string; red_enabled?: number; position?: number },\n): Promise {\n const sets: string[] = [];\n const args: (string | number)[] = [];\n if (patch.text !== undefined) {\n sets.push(\"text = ?\");\n args.push(patch.text);\n }\n if (patch.red_enabled !== undefined) {\n sets.push(\"red_enabled = ?\");\n args.push(patch.red_enabled);\n }\n if (patch.position !== undefined) {\n sets.push(\"position = ?\");\n args.push(patch.position);\n }\n if (!sets.length) return;\n args.push(id);\n await sqlite.execute({ sql: `UPDATE tasks SET ${sets.join(\", \")} WHERE id = ?`, args });\n}\n\n/**\n * Move a single task to another date: the original becomes `moved` (strike-out),\n * a fresh open copy is created on the new date. text/red overrides (optional)\n * are then applied to the copy.\n */\nexport async function moveTaskToDate(\n id: number,\n newDate: string,\n overrides: { text?: string; red_enabled?: number } = {},\n): Promise {\n const t = await getTask(id);\n if (!t || t.date === newDate) return;\n const copyId = await insertTask({\n date: newDate,\n text: overrides.text ?? t.text,\n red_enabled: overrides.red_enabled ?? t.red_enabled,\n });\n await sqlite.execute({\n sql: \"UPDATE tasks SET moved_from_id = ? WHERE id = ?\",\n args: [id, copyId],\n });\n await sqlite.execute({\n sql: \"UPDATE tasks SET status = 'moved', moved_to_id = ? WHERE id = ?\",\n args: [copyId, id],\n });\n}\n\nexport interface MovePair {\n orig: number;\n copy: number;\n}\n\nexport interface MoveRecord {\n from_date: string;\n to_date: string;\n pairs: MovePair[];\n}\n\nasync function saveLastMove(m: MoveRecord): Promise {\n await sqlite.execute({ sql: \"DELETE FROM settings WHERE key = ?\", args: [\"last_move\"] });\n await sqlite.execute({\n sql: \"INSERT INTO settings (key, value) VALUES (?, ?)\",\n args: [\"last_move\", JSON.stringify(m)],\n });\n}\n\nasync function getLastMove(): Promise {\n const res = await sqlite.execute({\n sql: \"SELECT value FROM settings WHERE key = ?\",\n args: [\"last_move\"],\n });\n const row = res.rows[0] as { value: string } | undefined;\n if (!row) return null;\n try {\n const v = JSON.parse(row.value);\n if (v && Array.isArray(v.pairs)) return v;\n } catch {\n /* ignore */\n }\n return null;\n}\n\n/**\n * \"Kalanları sonraki güne aktar\": copy every open task on `date` to\n * date+1, mark the originals moved. Records the batch for undo.\n */\nexport async function moveDayForward(date: string): Promise<{\n ok: boolean;\n count: number;\n to_date: string;\n}> {\n const all = await listTasksAll();\n const open = all\n .filter((t) => t.date === date && t.status === \"open\")\n .sort((a, b) => a.position - b.position || a.id - b.id);\n if (!open.length) return { ok: false, count: 0, to_date: addDays(date, 1) };\n\n const next = addDays(date, 1);\n const pairs: MovePair[] = [];\n for (const t of open) {\n const copyId = await insertTask({ date: next, text: t.text, red_enabled: t.red_enabled });\n await sqlite.execute({\n sql: \"UPDATE tasks SET moved_from_id = ? WHERE id = ?\",\n args: [t.id, copyId],\n });\n await sqlite.execute({\n sql: \"UPDATE tasks SET status = 'moved', moved_to_id = ? WHERE id = ?\",\n args: [copyId, t.id],\n });\n pairs.push({ orig: t.id, copy: copyId });\n }\n await saveLastMove({ from_date: date, to_date: next, pairs });\n return { ok: true, count: pairs.length, to_date: next };\n}\n\n/** Undo the last move-forward: delete the copies, restore originals to open. */\nexport async function undoLastMove(): Promise {\n const m = await getLastMove();\n if (!m) return false;\n for (const p of m.pairs) {\n await sqlite.execute({ sql: \"DELETE FROM tasks WHERE id = ?\", args: [p.copy] });\n await sqlite.execute({\n sql: \"UPDATE tasks SET status = 'open', moved_to_id = NULL WHERE id = ?\",\n args: [p.orig],\n });\n }\n await sqlite.execute({ sql: \"DELETE FROM settings WHERE key = ?\", args: [\"last_move\"] });\n return true;\n}\n\n/* ----------------------------- settings ----------------------------- */\n\nconst DEFAULT_TIMES = [\"09:00\", \"14:00\", \"21:00\"];\n\nexport async function getSettingsTimes(): Promise {\n const res = await sqlite.execute({\n sql: \"SELECT value FROM settings WHERE key = ?\",\n args: [\"notify_times\"],\n });\n const row = res.rows[0] as { value: string } | undefined;\n if (!row) return [...DEFAULT_TIMES];\n try {\n const v = JSON.parse(row.value);\n if (Array.isArray(v) && v.length) return v.filter((x) => typeof x === \"string\" && /^\\d{2}:\\d{2}$/.test(x));\n } catch {\n /* ignore */\n }\n return [...DEFAULT_TIMES];\n}\n\nexport async function setSettingsTimes(times: string[]): Promise {\n const clean = times.length ? times : [DEFAULT_TIMES[0]];\n await sqlite.execute({ sql: \"DELETE FROM settings WHERE key = ?\", args: [\"notify_times\"] });\n await sqlite.execute({\n sql: \"INSERT INTO settings (key, value) VALUES (?, ?)\",\n args: [\"notify_times\", JSON.stringify(clean)],\n });\n}\n\n/* --------------------------- email dedupe ---------------------------- */\n\nexport async function emailSent(day: string, time: string): Promise {\n const res = await sqlite.execute({\n sql: \"SELECT 1 AS x FROM email_sent WHERE day = ? AND time = ?\",\n args: [day, time],\n });\n return !!res.rows[0];\n}\n\nexport async function markEmail(day: string, time: string): Promise {\n await sqlite.execute({\n sql: \"INSERT OR IGNORE INTO email_sent (day, time) VALUES (?, ?)\",\n args: [day, time],\n });\n}\n","createdAt",["D",1789474258547],"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",{"_106":105,"_114":110},"org",{"_106":105,"_107":108,"_109":110,"_19":61,"_111":112,"_113":31},"branch",{"_13":95,"_38":96,"_49":48,"_97":50,"_98":-5,"_99":-5,"_100":-5,"_101":-5,"_102":-5,"_103":51,"_104":105},"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",{"_49":50,"_38":51,"_44":226,"_53":-5,"_54":31,"_55":56,"_57":56,"_58":59,"_60":-5,"_19":61,"_62":63,"_64":65,"_66":-5,"_67":-5,"_68":69,"_70":71,"_72":73,"_74":75,"_76":227,"_78":-5,"_79":80,"_81":80,"_82":83,"_84":83,"_85":83,"_86":80,"_87":80,"_88":228,"_90":229,"_92":230,"_94":31},"tree",[201,202,203,204,205,206],"files",[201,202,203,204,205,206],"counts",{"_191":69,"_192":188,"_193":69,"_194":195,"_196":197},"contents",[137,138,139,140,141,142],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_49":183,"_38":184,"_36":185,"_146":-5,"_47":48,"_46":186,"_148":31,"_44":187,"_13":188,"_39":26,"_41":189,"_30":31,"_151":-5,"_33":190},{"_49":174,"_38":175,"_36":176,"_146":-5,"_47":48,"_46":177,"_148":31,"_44":178,"_13":179,"_39":180,"_41":181,"_30":31,"_151":-5,"_33":182},{"_49":170,"_38":34,"_36":37,"_146":-5,"_47":48,"_46":14,"_148":31,"_44":171,"_13":172,"_39":40,"_41":43,"_30":31,"_151":-5,"_33":173},{"_49":161,"_38":162,"_36":63,"_146":-5,"_47":48,"_46":163,"_148":31,"_44":164,"_13":165,"_39":166,"_41":167,"_30":31,"_151":168,"_33":169},{"_49":153,"_38":154,"_36":155,"_146":-5,"_47":48,"_46":156,"_148":31,"_44":157,"_13":158,"_39":40,"_41":159,"_30":31,"_151":-5,"_33":160},{"_49":143,"_38":144,"_36":145,"_146":-5,"_47":48,"_46":147,"_148":31,"_44":149,"_13":69,"_39":40,"_41":150,"_30":31,"_151":-5,"_33":152},"df1fd52e-57fa-4c5f-bfac-aca6c22e8ee7","time.ts","78e945ce-b0fe-11f1-900b-1607ee4eb77e","parentId",50,"latest",["D",1789474242182],"/**\n * Timezone helpers. All scheduling / \"today\" logic runs on Europe/Berlin.\n * Dates are plain \"YYYY-MM-DD\" strings computed in the Berlin timezone.\n */\n\nexport const TZ = \"Europe/Berlin\";\n\n/** Today's date in Berlin as \"YYYY-MM-DD\". */\nexport function todayStr(d: Date = new Date()): string {\n return new Intl.DateTimeFormat(\"en-CA\", {\n timeZone: TZ,\n year: \"numeric\",\n month: \"2-digit\",\n day: \"2-digit\",\n }).format(d);\n}\n\n/** Current HH:MM in Berlin (24h). */\nexport function nowHM(d: Date = new Date()): string {\n const parts = new Intl.DateTimeFormat(\"en-GB\", {\n timeZone: TZ,\n hour: \"2-digit\",\n minute: \"2-digit\",\n hourCycle: \"h23\",\n }).formatToParts(d);\n const get = (t: string) => parts.find((p) => p.type === t)!.value.padStart(2, \"0\");\n return `${get(\"hour\")}:${get(\"minute\")}`;\n}\n\n/** Current year and month (1-12) in Berlin. */\nexport function currentMonth(): { y: number; m: number } {\n const p = new Intl.DateTimeFormat(\"en-CA\", {\n timeZone: TZ,\n year: \"numeric\",\n month: \"numeric\",\n }).formatToParts(new Date());\n const get = (t: string) => Number(partsGet(p, t));\n return { y: get(\"year\"), m: get(\"month\") };\n}\n\n/**\n * Add n days to a \"YYYY-MM-DD\" string. Pure date arithmetic via UTC so the\n * wall-clock date is unchanged across DST boundaries.\n */\nexport function addDays(dateStr: string, n: number): string {\n const [y, m, d] = dateStr.split(\"-\").map(Number);\n const dt = new Date(Date.UTC(y, m - 1, d + n));\n return dt.toISOString().slice(0, 10);\n}\n\nfunction partsGet(parts: Intl.DateTimeFormatPart[], t: string): string {\n return parts.find((p) => p.type === t)?.value ?? \"\";\n}\n","label",[144],"f91bffe7-081d-43e8-b3cb-7a580a764039","run.ts","c25bf25a-9b6f-11f1-b373-1607ee4eb77e",49,["D",1789474242125],11,"import nodemailer from \"npm:nodemailer\";\n\n/** Recipient for reminder emails. */\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/**\n * Send an email via Gmail SMTP to the recipient in `TO`.\n * Requires GMAIL_USER / GMAIL_PASS env vars (app password for Gmail).\n */\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",[154],"89f0e357-f351-4ce2-a59e-973c29c1667f","main.ts",38,["D",1787105568062],14,"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, secret: string | null): Promise {\n const qs = secret ? `?secret=${encodeURIComponent(secret)}` : \"\";\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(qs)}\n

`;\n}\n\nasync function tasksTable(qs: string): 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, secret));\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],"9b5babc2-6d02-4857-93dd-0c5403ea2029",["D",1789474258547],3,[34],"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",[175],"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",[184],"pulls","branches","forks","envVars",{"_198":172,"_200":69},"connections",{"_198":69,"_199":69},"count","unfilledCount","emptyCount",{"_49":183,"_38":184,"_36":185,"_146":-5,"_47":48,"_46":186,"_148":31,"_44":223,"_13":188,"_39":26,"_41":189,"_30":31,"_151":-5,"_208":224,"_33":225},{"_49":174,"_38":175,"_36":176,"_146":-5,"_47":48,"_46":177,"_148":31,"_44":220,"_13":179,"_39":180,"_41":181,"_30":31,"_151":-5,"_208":221,"_33":222},{"_49":170,"_38":34,"_36":37,"_146":-5,"_47":48,"_46":14,"_148":31,"_44":217,"_13":172,"_39":40,"_41":43,"_30":31,"_151":-5,"_208":218,"_33":219},{"_49":161,"_38":162,"_36":63,"_146":-5,"_47":48,"_46":163,"_148":31,"_44":214,"_13":165,"_39":166,"_41":167,"_30":31,"_151":168,"_208":215,"_33":216},{"_49":153,"_38":154,"_36":155,"_146":-5,"_47":48,"_46":156,"_148":31,"_44":211,"_13":158,"_39":40,"_41":159,"_30":31,"_151":-5,"_208":212,"_33":213},{"_49":143,"_38":144,"_36":145,"_146":-5,"_47":48,"_46":147,"_148":31,"_44":207,"_13":69,"_39":40,"_41":150,"_30":31,"_151":-5,"_208":209,"_33":210},["D",1789474242182],"children",[],[144],["D",1789474242125],[],[154],["D",1787105568062],[],[162],["D",1789474258547],[],[34],["D",1787105129031],[],[175],["D",1787103600307],[],[184],["D",1787102792105],["D",1789534231467],{"_106":105,"_114":110},{"_106":105,"_107":108,"_109":110,"_19":61,"_111":112,"_113":31},{"_13":95,"_38":96,"_49":48,"_97":50,"_98":-5,"_99":-5,"_100":-5,"_101":-5,"_102":-5,"_103":51,"_104":105},"ctx",{"_88":-5,"_134":264,"_265":266,"_267":268,"_269":31,"_270":31,"_271":31,"_272":65,"_273":-5,"_274":-7,"_275":-7,"_276":69,"_277":31,"_278":31,"_279":-5,"_280":31,"_281":31,"_282":31,"_283":-5},"ENV",{"_235":236,"_237":238,"_239":96,"_240":241,"_242":243,"_244":245,"_246":247,"_248":249,"_250":251,"_252":253,"_254":255,"_256":257,"_258":259,"_260":261,"_262":263},"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 · v51