[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_245":246,"_247":248},"routes/_app.x.$handle.$name",{"_96":95,"_32":44,"_105":86,"_27":53,"_13":14,"_106":-5,"_11":107,"_108":109,"_110":111,"_112":113,"_114":115,"_20":-5,"_116":-5,"_117":-5,"_118":48,"_119":120,"_121":25,"_122":-5,"_123":-5,"_124":125},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_42":43,"_32":44,"_37":45,"_46":-5,"_47":48,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":57,"_58":25,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":-5,"_66":-5,"_67":-5,"_68":-5,"_69":70,"_71":70,"_72":73,"_74":73,"_75":73,"_76":70,"_77":70,"_78":79,"_80":81,"_82":83,"_84":48},"version",96,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":36,"_37":38,"_39":14,"_40":41,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",true,"deletedHere","path","gcal.ts","latestPath","fileId","0681eb9a-88ee-11f1-9e9d-1607ee4eb77e","name","fileType","script","content","// gcal.ts\n// Minimal Google Calendar client authenticated with a service-account JWT,\n// signed using the Web Crypto API (crypto.subtle) instead of the googleapis\n// or google-auth-library npm packages. This keeps the val dependency-free --\n// nothing here depends on an npm package's Deno/Pyodide compatibility.\n\nconst CALENDAR_SCOPE = \"https://www.googleapis.com/auth/calendar.events\";\nconst TOKEN_URL = \"https://oauth2.googleapis.com/token\";\n\nfunction base64url(bytes: ArrayBuffer | Uint8Array): string {\n const arr = bytes instanceof Uint8Array ? bytes : new Uint8Array(bytes);\n let str = \"\";\n for (const b of arr) str += String.fromCharCode(b);\n return btoa(str).replace(/\\+/g, \"-\").replace(/\\//g, \"_\").replace(/=+$/, \"\");\n}\n\nfunction pemToArrayBuffer(pem: string): ArrayBuffer {\n const clean = pem\n .replace(/-----BEGIN PRIVATE KEY-----/, \"\")\n .replace(/-----END PRIVATE KEY-----/, \"\")\n .replace(/\\s/g, \"\");\n const binary = atob(clean);\n const bytes = new Uint8Array(binary.length);\n for (let i = 0; i < binary.length; i++) bytes[i] = binary.charCodeAt(i);\n return bytes.buffer;\n}\n\ninterface ServiceAccount {\n client_email: string;\n private_key: string;\n}\n\nfunction loadServiceAccount(): ServiceAccount {\n const json = Deno.env.get(\"GOOGLE_CREDENTIALS_JSON\");\n if (!json) throw new Error(\"GOOGLE_CREDENTIALS_JSON is not set.\");\n return JSON.parse(json) as ServiceAccount;\n}\n\nasync function getAccessToken(): Promise {\n const sa = loadServiceAccount();\n const now = Math.floor(Date.now() / 1000);\n\n const header = { alg: \"RS256\", typ: \"JWT\" };\n const claims = {\n iss: sa.client_email,\n scope: CALENDAR_SCOPE,\n aud: TOKEN_URL,\n iat: now,\n exp: now + 3600,\n };\n\n const encoder = new TextEncoder();\n const signingInput = `${base64url(encoder.encode(JSON.stringify(header)))}.` +\n `${base64url(encoder.encode(JSON.stringify(claims)))}`;\n\n const key = await crypto.subtle.importKey(\n \"pkcs8\",\n pemToArrayBuffer(sa.private_key),\n { name: \"RSASSA-PKCS1-v1_5\", hash: \"SHA-256\" },\n false,\n [\"sign\"],\n );\n\n const signature = await crypto.subtle.sign(\n \"RSASSA-PKCS1-v1_5\",\n key,\n encoder.encode(signingInput),\n );\n\n const jwt = `${signingInput}.${base64url(signature)}`;\n\n const res = await fetch(TOKEN_URL, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/x-www-form-urlencoded\" },\n body: new URLSearchParams({\n grant_type: \"urn:ietf:params:oauth:grant-type:jwt-bearer\",\n assertion: jwt,\n }),\n });\n\n if (!res.ok) {\n throw new Error(\n `Google token exchange failed: ${res.status} ${await res.text()}`,\n );\n }\n const data = (await res.json()) as { access_token: string };\n return data.access_token;\n}\n\nfunction calendarId(): string {\n return Deno.env.get(\"GCAL_CALENDAR_ID\") || \"primary\";\n}\n\nexport function formatIsoDate(d: Date): string {\n const y = d.getUTCFullYear();\n const m = String(d.getUTCMonth() + 1).padStart(2, \"0\");\n const day = String(d.getUTCDate()).padStart(2, \"0\");\n return `${y}-${m}-${day}`;\n}\n\nfunction addDays(d: Date, days: number): Date {\n return new Date(d.getTime() + days * 24 * 60 * 60 * 1000);\n}\n\nfunction eventBody(taskName: string, deadlineDate: Date) {\n return {\n summary: `🚨 ${taskName}`,\n start: { date: formatIsoDate(deadlineDate), timeZone: \"Europe/Bucharest\" },\n end: {\n date: formatIsoDate(addDays(deadlineDate, 1)),\n timeZone: \"Europe/Bucharest\",\n },\n colorId: \"11\", // Tomato / Deep Red\n };\n}\n\ninterface GcalHttpError extends Error {\n status?: number;\n}\n\nexport async function createGcalEvent(\n taskName: string,\n deadlineDate: Date,\n): Promise {\n const token = await getAccessToken();\n const res = await fetch(\n `https://www.googleapis.com/calendar/v3/calendars/${\n encodeURIComponent(calendarId())\n }/events`,\n {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${token}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify(eventBody(taskName, deadlineDate)),\n },\n );\n if (!res.ok) {\n throw new Error(\n `GCal create event failed: ${res.status} ${await res.text()}`,\n );\n }\n const data = (await res.json()) as { id: string };\n return data.id;\n}\n\nexport async function updateGcalEvent(\n eventId: string,\n taskName: string,\n deadlineDate: Date,\n): Promise {\n const token = await getAccessToken();\n const res = await fetch(\n `https://www.googleapis.com/calendar/v3/calendars/${\n encodeURIComponent(calendarId())\n }/events/${encodeURIComponent(eventId)}`,\n {\n method: \"PUT\",\n headers: {\n Authorization: `Bearer ${token}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify(eventBody(taskName, deadlineDate)),\n },\n );\n if (!res.ok) {\n const err: GcalHttpError = new Error(\n `GCal update event failed: ${res.status} ${await res.text()}`,\n );\n err.status = res.status;\n throw err;\n }\n}\n\nexport async function deleteGcalEvent(eventId: string): Promise {\n const token = await getAccessToken();\n const res = await fetch(\n `https://www.googleapis.com/calendar/v3/calendars/${\n encodeURIComponent(calendarId())\n }/events/${encodeURIComponent(eventId)}`,\n { method: \"DELETE\", headers: { Authorization: `Bearer ${token}` } },\n );\n // 404/410 mean it's already gone -- safe to ignore, mirrors the Python original.\n if (!res.ok && res.status !== 404 && res.status !== 410) {\n throw new Error(\n `GCal delete event failed: ${res.status} ${await res.text()}`,\n );\n }\n}","createdAt",["D",1786299935458],"branchVersion","branchId","d5c6d970-01f8-476c-8131-97a3f2dfda37","id","0334be82-201a-42b6-9fc5-d568200d551d","todoist-webhook",["D",1785014870875],"deletedAt","legacyEnvVars",false,"privacy","public","httpPrivacy","description","","imageUrl","e18335fe-6041-4f4c-bba1-4a304afb2a2c","pinnedFileId","b07ce340-886f-11f1-9e2e-1607ee4eb77e","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019f95b4-236c-7362-a248-36bfd5d26630","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_96":95,"_104":100},"org",{"_96":95,"_97":98,"_99":100,"_18":55,"_101":102,"_103":48},"branch",{"_13":85,"_32":86,"_42":41,"_87":43,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":44,"_94":95},"isOwned",100,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","alexaiexperiments","handle","displayName","Croitor Emanuel-Alexandru","avatar","https://avatars.githubusercontent.com/u/184514375?v=4","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_42":43,"_32":44,"_37":241,"_46":-5,"_47":48,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":57,"_58":25,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":-5,"_66":-5,"_67":-5,"_68":-5,"_69":70,"_71":70,"_72":73,"_74":73,"_75":73,"_76":70,"_77":70,"_78":242,"_80":243,"_82":244,"_84":48},"tree",[208,209,210,211,212,213,214,215],"files",[208,209,210,211,212,213,214,215],"counts",{"_197":62,"_198":199,"_200":62,"_201":202,"_203":204},"contents",[126,127,128,129,130,131,132,133],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_42":190,"_32":191,"_30":192,"_136":-5,"_40":41,"_39":148,"_138":48,"_37":193,"_13":194,"_33":34,"_35":195,"_24":48,"_143":-5,"_27":196},{"_42":183,"_32":184,"_30":185,"_136":-5,"_40":41,"_39":172,"_138":48,"_37":186,"_13":187,"_33":34,"_35":188,"_24":48,"_143":-5,"_27":189},{"_42":177,"_32":178,"_30":179,"_136":-5,"_40":41,"_39":165,"_138":25,"_37":180,"_13":62,"_33":34,"_35":181,"_24":48,"_143":-5,"_27":182},{"_42":169,"_32":170,"_30":171,"_136":-5,"_40":41,"_39":172,"_138":48,"_37":173,"_13":174,"_33":34,"_35":175,"_24":48,"_143":-5,"_27":176},{"_42":162,"_32":163,"_30":164,"_136":-5,"_40":41,"_39":165,"_138":25,"_37":166,"_13":62,"_33":34,"_35":167,"_24":48,"_143":-5,"_27":168},{"_42":153,"_32":154,"_30":155,"_136":-5,"_40":41,"_39":156,"_138":48,"_37":157,"_13":158,"_33":159,"_35":160,"_24":48,"_143":-5,"_27":161},{"_42":145,"_32":146,"_30":147,"_136":-5,"_40":41,"_39":148,"_138":48,"_37":149,"_13":150,"_33":34,"_35":151,"_24":48,"_143":-5,"_27":152},{"_42":134,"_32":135,"_30":57,"_136":-5,"_40":41,"_39":137,"_138":25,"_37":139,"_13":140,"_33":141,"_35":142,"_24":48,"_143":-5,"_27":144},"e5219738-7aa2-4474-bff7-5180559c90f7","webhook.ts","parentId",92,"latest",["D",1786299857247],13,"http","// webhook.ts -- set this file's trigger to HTTP in the Val Town UI.\n//\n// Routes:\n// POST /webhook/todoist real-time trigger, verified via Todoist's HMAC signature\n// GET /health lightweight uptime check\n// GET / plain status text\n//\n// On a qualifying event this handler can run up to two independent\n// automations:\n// - the execute-label rescan (automation.ts), on the same event set as\n// before\n// - the instant emoji classification (emoji-automation.ts), only when\n// the task in the payload carries the literal \"{emoji}\" marker\n\nimport { runAutomationSafely } from \"./automation.ts\";\nimport {\n EMOJI_MARKER,\n processInstantEmojiClassification,\n} from \"./emoji-automation.ts\";\n\n// Events that can affect which tasks carry EXECUTE_LABEL or need a due-date rollover.\nconst EXECUTE_LABEL_EVENTS = new Set([\n \"item:added\",\n \"item:updated\",\n \"item:uncompleted\",\n]);\n\n// Events on which it's worth checking a task's content for the {emoji} marker.\nconst EMOJI_MARKER_EVENTS = new Set([\"item:added\", \"item:updated\"]);\n\nasync function verifyTodoistSignature(\n rawBody: string,\n signatureHeader: string | null,\n): Promise {\n const clientSecret = Deno.env.get(\"TODOIST_CLIENT_SECRET\");\n if (!clientSecret || !signatureHeader) return false;\n\n const key = await crypto.subtle.importKey(\n \"raw\",\n new TextEncoder().encode(clientSecret),\n { name: \"HMAC\", hash: \"SHA-256\" },\n false,\n [\"sign\"],\n );\n const signature = await crypto.subtle.sign(\n \"HMAC\",\n key,\n new TextEncoder().encode(rawBody),\n );\n const bytes = new Uint8Array(signature);\n let binary = \"\";\n for (const b of bytes) binary += String.fromCharCode(b);\n const computed = btoa(binary);\n\n if (computed.length !== signatureHeader.length) return false;\n let diff = 0;\n for (let i = 0; i < computed.length; i++) {\n diff |= computed.charCodeAt(i) ^ signatureHeader.charCodeAt(i);\n }\n return diff === 0;\n}\n\nexport default async function (req: Request): Promise {\n const url = new URL(req.url);\n\n if (req.method === \"GET\" && url.pathname === \"/health\") {\n return Response.json({\n status: \"ok\",\n time: new Date().toLocaleString(\"en-US\", {\n timeZone: \"Europe/Bucharest\",\n }),\n });\n }\n\n if (req.method === \"GET\" && url.pathname === \"/\") {\n return new Response(\"Todoist Processor is running.\");\n }\n\n if (req.method === \"POST\" && url.pathname === \"/webhook/todoist\") {\n const rawBody = await req.text();\n const signature = req.headers.get(\"X-Todoist-Hmac-SHA256\");\n\n if (!Deno.env.get(\"TODOIST_CLIENT_SECRET\")) {\n console.error(\n \"Webhook: rejected, TODOIST_CLIENT_SECRET is not configured.\",\n );\n return Response.json({ error: \"Server misconfiguration\" }, {\n status: 500,\n });\n }\n\n if (!(await verifyTodoistSignature(rawBody, signature))) {\n console.warn(\n \"Webhook: rejected request with invalid or missing HMAC signature.\",\n );\n return Response.json({ error: \"Invalid signature\" }, { status: 401 });\n }\n\n let payload: Record;\n try {\n payload = rawBody ? JSON.parse(rawBody) : {};\n } catch {\n console.warn(\"Webhook: rejected request with unparsable JSON body.\");\n return Response.json({ error: \"Invalid JSON\" }, { status: 400 });\n }\n\n const eventName = (payload.event_name as string) || \"unknown\";\n const eventData = payload.event_data as\n | Record\n | undefined;\n console.log(\n `Webhook received: event_name=${eventName}` +\n (eventData\n ? `, task_id=${eventData.id ?? \"?\"}, content=${\n JSON.stringify(eventData.content ?? \"?\")\n }`\n : \"\"),\n );\n\n const isExecuteLabelEvent = EXECUTE_LABEL_EVENTS.has(eventName);\n const isEmojiMarkerEvent = EMOJI_MARKER_EVENTS.has(eventName) &&\n typeof eventData?.content === \"string\" &&\n (eventData.content as string).includes(EMOJI_MARKER);\n\n if (!isExecuteLabelEvent && !isEmojiMarkerEvent) {\n console.log(`Webhook: ignoring irrelevant event '${eventName}'.`);\n return Response.json({ status: \"ignored\", event_name: eventName });\n }\n\n const results: Record = { event_name: eventName };\n\n if (isExecuteLabelEvent) {\n results.execute_label = await runAutomationSafely(`webhook:${eventName}`);\n }\n\n if (isEmojiMarkerEvent) {\n const taskId = eventData?.id != null ? String(eventData.id) : \"\";\n results.emoji = taskId\n ? await processInstantEmojiClassification(taskId)\n : { status: \"error\", message: \"Webhook payload missing task id.\" };\n }\n\n return Response.json(results);\n }\n\n return Response.json({ error: \"Not found\" }, { status: 404 });\n}","label",[135],"718175be-03c6-4da2-b563-f60fc2fa5a0d","todoist.ts","fa109186-88ed-11f1-987b-1607ee4eb77e",91,["D",1786299831404],24,"// todoist.ts\n// Thin fetch-based client for the Todoist REST API (api/v1).\n// https://developer.todoist.com/api/v1/\n//\n// Deliberately dependency-free: no npm SDK, just fetch + the env token.\n// Covers what's needed for both automations:\n// - \"execute 🌥\" auto-scheduling: GET /tasks (literal `label` match,\n// cursor-paginated) and POST /tasks/{id} to update a due date.\n// - emoji classification: GET /tasks with no filter (all active tasks,\n// used to both find candidates and resolve parent_id chains for the\n// checklist-exclusion check in-memory), GET /tasks/{id} (single task,\n// used by the instant webhook path, including its own parent lookups),\n// and POST /tasks/{id} to prepend the classified emoji to content.\n\nconst TODOIST_BASE = \"https://api.todoist.com/api/v1\";\n\nfunction authHeaders(): HeadersInit {\n const token = Deno.env.get(\"TODOIST_API_TOKEN\");\n if (!token) throw new Error(\"TODOIST_API_TOKEN is not set.\");\n return { Authorization: `Bearer ${token}` };\n}\n\nexport interface TodoistDue {\n date: string; // \"YYYY-MM-DD\" or a full ISO datetime string\n is_recurring?: boolean;\n string?: string;\n timezone?: string | null;\n}\n\nexport interface TodoistTask {\n id: string;\n content: string;\n due: TodoistDue | null;\n /** Direct parent task id, or null/absent for a top-level task -- used\n * to walk up the ancestor chain for the 📋-checklist exclusion check. */\n parent_id?: string | null;\n [key: string]: unknown;\n}\n\ninterface PaginatedResponse {\n results: T[];\n next_cursor: string | null;\n}\n\nasync function paginate(\n path: string,\n params: Record,\n): Promise {\n const items: T[] = [];\n let cursor: string | null = null;\n\n do {\n const url = new URL(`${TODOIST_BASE}${path}`);\n for (const [k, v] of Object.entries(params)) url.searchParams.set(k, v);\n url.searchParams.set(\"limit\", \"200\");\n if (cursor) url.searchParams.set(\"cursor\", cursor);\n\n const res = await fetch(url.toString(), { headers: authHeaders() });\n if (!res.ok) {\n throw new Error(\n `Todoist GET ${path} failed: ${res.status} ${await res.text()}`,\n );\n }\n const data = (await res.json()) as PaginatedResponse;\n items.push(...data.results);\n cursor = data.next_cursor;\n } while (cursor);\n\n return items;\n}\n\n/** Mirrors get_tasks(label=...) -- a literal match against a label name, not the filter DSL. */\nexport async function getTasksByLabel(label: string): Promise {\n return paginate(\"/tasks\", { label });\n}\n\n/** All active tasks visible to this token, across every project -- no filter applied.\n * Used by the emoji sweep, which needs to look at everything to find tasks\n * still missing a category label. */\nexport async function getAllActiveTasks(): Promise {\n return paginate(\"/tasks\", {});\n}\n\n/** Fetches a single task fresh from the API. Used by the instant webhook\n * path so it acts on the task's current state rather than trusting a\n * webhook payload snapshot that may be stale or incomplete. */\nexport async function getTask(taskId: string): Promise {\n const res = await fetch(`${TODOIST_BASE}/tasks/${taskId}`, {\n headers: authHeaders(),\n });\n if (!res.ok) {\n throw new Error(\n `Todoist GET /tasks/${taskId} failed: ${res.status} ${await res.text()}`,\n );\n }\n return (await res.json()) as TodoistTask;\n}\n\nexport interface TaskUpdateFields {\n due_date?: string;\n content?: string;\n}\n\nexport async function updateTask(\n taskId: string,\n fields: TaskUpdateFields,\n): Promise {\n console.log(\n `[todoist] POST /tasks/${taskId} body=${JSON.stringify(fields)}`,\n );\n\n const res = await fetch(`${TODOIST_BASE}/tasks/${taskId}`, {\n method: \"POST\",\n headers: {\n ...authHeaders(),\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify(fields),\n });\n\n const rawText = await res.text();\n console.log(`[todoist] POST /tasks/${taskId} -> ${res.status} ${rawText}`);\n\n if (!res.ok) {\n throw new Error(\n `Todoist update task ${taskId} failed: ${res.status} ${rawText}`,\n );\n }\n\n // The endpoint is documented to echo back the updated task. Some Todoist\n // API versions have returned 204 No Content for updates instead, so this\n // stays defensive rather than assuming a body is always present.\n if (!rawText) return {} as TodoistTask;\n try {\n return JSON.parse(rawText) as TodoistTask;\n } catch {\n console.warn(\n `[todoist] Could not parse JSON response for task ${taskId} update.`,\n );\n return {} as TodoistTask;\n }\n}",[146],"123aff8e-09fe-47e6-b6f5-089f10a0962a","sweep.ts","e8876156-88ed-11f1-bdc3-1607ee4eb77e",94,["D",1786299913530],9,"interval","// sweep.ts -- set this file's trigger to Cron in the Val Town UI, interval: every 15 minutes.\n//\n// Safety net: catches any webhook delivery Todoist failed to make, and\n// guarantees the \"execute 🌥\" 9 PM rollover happens even on a day with zero\n// Todoist activity. 15 minutes is the fastest interval the free plan allows.\n\nimport { runAutomationSafely } from \"./automation.ts\";\n\nexport default async function (interval: Interval) {\n console.log(\n `Cron sweep starting. Last run: ${\n interval.lastRunAt?.toISOString() ?? \"never\"\n }`,\n );\n const result = await runAutomationSafely(\"cron\");\n console.log(\"Cron sweep result:\", JSON.stringify(result));\n}",[154],"a65f7dd1-2da9-4b39-8556-2688c069ed59","gemini.ts","fb4f0350-8cff-11f1-8a64-1607ee4eb77e",72,["D",1785516648586],"// gemini.ts\n//\n// Dependency-free Gemini REST client (mirrors the style of todoist.ts --\n// no SDK, just fetch). This file knows nothing about Todoist or emoji\n// categories; it only knows how to call generateContent with a given\n// model + key and how to retry across a configured list of models/keys.\n// classifier.ts builds the actual classification prompt on top of this.\n//\n// Retry/cycling behaviour (per spec):\n// 1. Try the current model with key #1.\n// 2. On ANY failure (network error, non-2xx response, or the caller's\n// parseResponse callback rejecting the content as invalid) retry the\n// SAME model with the next key.\n// 3. Once every key has failed for a model, move to the next model and\n// start again from key #1.\n// 4. If every model x key combination fails, throw GeminiExhaustedError\n// with the full attempt log -- callers should surface this rather\n// than swallow it.\n//\n// Timing note: Val Town's free-plan execution timeout is 1 minute per val\n// run (see https://www.val.town/limits), and both the cron sweep and the\n// webhook handler share that ceiling. classifier.ts requests\n// thinkingLevel \"medium\" (see below), which adds real latency on top of\n// a plain non-thinking call -- FETCH_TIMEOUT_MS is set generously enough\n// to let that finish normally rather than falsely timing out a\n// legitimately-in-progress response. In practice, actual failures (bad\n// key, rate limit, quota) return fast because auth/quota checks happen\n// before the model starts reasoning, so a realistic retry chain is much\n// faster than the worst case. But if you configure many keys and Gemini\n// is genuinely hanging (not erroring) on most of them, a full exhaustion\n// chain can still exceed the 60s ceiling -- that's a platform limit this\n// file can't route around. Upgrading to Pro (10 min execution timeout)\n// removes the pressure if that scenario matters to you.\n//\n// Model note: Gemini 3-series models are explicitly tuned around the\n// default temperature of 1.0 -- Google's own docs warn that forcing it\n// lower \"may lead to unexpected behavior, such as looping or degraded\n// performance.\" So unlike a lot of older classification-prompt advice,\n// this file does NOT default temperature to 0; it leaves it unset\n// unless a caller explicitly opts in.\n\nconst GEMINI_BASE = \"https://generativelanguage.googleapis.com/v1beta\";\n\nconst DEFAULT_MODEL_PRIORITY = [\"gemini-3.6-flash\", \"gemini-3.5-flash\"];\n\nconst FETCH_TIMEOUT_MS = 12_000; // per attempt -- generous enough for medium-thinking on a small batch\nconst BASE_BACKOFF_MS = 200;\nconst MAX_BACKOFF_MS = 800;\n\nexport interface GeminiConfig {\n /** Ordered priority list, e.g. [\"gemini-3.6-flash\", \"gemini-3.5-flash\"]. */\n models: string[];\n /** Keys to cycle through, in order, for whichever model is currently active. */\n apiKeys: string[];\n}\n\nexport type ThinkingLevel = \"minimal\" | \"low\" | \"medium\" | \"high\";\n\nexport interface GeminiCallOptions {\n systemInstruction?: string;\n /** Gemini generationConfig.responseSchema -- pass together with responseMimeType. */\n responseSchema?: unknown;\n /** Gemini generationConfig.responseMimeType, e.g. \"application/json\" for a schema-constrained object/array. */\n responseMimeType?: string;\n /** Left unset by default -- see the \"Model note\" above on why this file doesn't default to 0. */\n temperature?: number;\n maxOutputTokens?: number;\n /** generationConfig.thinkingConfig.thinkingLevel. \"medium\" is supported on\n * Flash-tier Gemini 3 models per ai.google.dev/gemini-api/docs/gemini-3.\n * Do not combine with the legacy thinkingBudget field -- Gemini returns\n * a 400 if both are present. */\n thinkingLevel?: ThinkingLevel;\n}\n\nexport interface GeminiAttemptFailure {\n model: string;\n keyIndex: number; // 0-based\n status?: number;\n message: string;\n}\n\nexport class GeminiExhaustedError extends Error {\n attempts: GeminiAttemptFailure[];\n constructor(attempts: GeminiAttemptFailure[]) {\n const detail = attempts\n .map((a) => `${a.model} key#${a.keyIndex + 1}${a.status ? ` (${a.status})` : \"\"}: ${a.message}`)\n .join(\"; \");\n super(`All Gemini models/keys exhausted after ${attempts.length} attempt(s): ${detail}`);\n this.name = \"GeminiExhaustedError\";\n this.attempts = attempts;\n }\n}\n\n/** Reads GEMINI_API_KEYS (comma-separated) and, optionally, GEMINI_MODELS\n * (comma-separated, overrides the built-in priority order) from the\n * environment. Keeping the keys/model order in env vars rather than\n * hardcoded arrays means adding a key or reordering models is a Val Town\n * environment-variable edit, not a code change. */\nexport function loadGeminiConfigFromEnv(): GeminiConfig {\n const keysRaw = Deno.env.get(\"GEMINI_API_KEYS\") ?? \"\";\n const apiKeys = keysRaw.split(\",\").map((k) => k.trim()).filter(Boolean);\n\n const modelsRaw = Deno.env.get(\"GEMINI_MODELS\");\n const models = modelsRaw\n ? modelsRaw.split(\",\").map((m) => m.trim()).filter(Boolean)\n : DEFAULT_MODEL_PRIORITY;\n\n return { apiKeys, models };\n}\n\nfunction sleep(ms: number): Promise {\n return new Promise((resolve) => setTimeout(resolve, ms));\n}\n\nasync function callOnce(\n model: string,\n apiKey: string,\n prompt: string,\n options: GeminiCallOptions,\n): Promise {\n const generationConfig: Record = {\n maxOutputTokens: options.maxOutputTokens ?? 200,\n };\n if (options.temperature !== undefined) {\n generationConfig.temperature = options.temperature;\n }\n if (options.responseMimeType) {\n generationConfig.responseMimeType = options.responseMimeType;\n }\n if (options.responseSchema) {\n generationConfig.responseSchema = options.responseSchema;\n }\n if (options.thinkingLevel) {\n generationConfig.thinkingConfig = { thinkingLevel: options.thinkingLevel };\n }\n\n const body: Record = {\n contents: [{ role: \"user\", parts: [{ text: prompt }] }],\n generationConfig,\n };\n if (options.systemInstruction) {\n body.systemInstruction = { parts: [{ text: options.systemInstruction }] };\n }\n\n let res: Response;\n try {\n res = await fetch(`${GEMINI_BASE}/models/${model}:generateContent`, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n \"x-goog-api-key\": apiKey,\n },\n body: JSON.stringify(body),\n signal: AbortSignal.timeout(FETCH_TIMEOUT_MS),\n });\n } catch (e) {\n throw new Error(`network error calling ${model}: ${e instanceof Error ? e.message : e}`);\n }\n\n const rawText = await res.text();\n\n if (!res.ok) {\n const err = new Error(`${model} responded ${res.status}: ${rawText.slice(0, 300)}`);\n (err as Error & { status?: number }).status = res.status;\n throw err;\n }\n\n let data: {\n candidates?: { content?: { parts?: { text?: string }[] } }[];\n };\n try {\n data = JSON.parse(rawText);\n } catch {\n throw new Error(`${model} returned unparsable JSON`);\n }\n\n const text = data.candidates?.[0]?.content?.parts?.[0]?.text;\n if (typeof text !== \"string\" || !text.trim()) {\n throw new Error(`${model} returned an empty/unexpected response shape`);\n }\n return text.trim();\n}\n\n/**\n * Calls Gemini with the model x key retry/cycling described above.\n * `parseResponse` both parses AND validates the raw text -- throwing\n * inside it (e.g. because the model didn't return one of the expected\n * values) is treated exactly like a transport failure and advances to\n * the next key/model, so callers get one retry loop that covers both\n * \"Gemini errored\" and \"Gemini answered but the answer was garbage\".\n */\nexport async function callGeminiWithRetry(\n config: GeminiConfig,\n prompt: string,\n parseResponse: (rawText: string) => T,\n options: GeminiCallOptions = {},\n): Promise {\n if (config.models.length === 0) {\n throw new Error(\"GeminiConfig.models is empty -- set GEMINI_MODELS or check DEFAULT_MODEL_PRIORITY.\");\n }\n if (config.apiKeys.length === 0) {\n throw new Error(\"GeminiConfig.apiKeys is empty -- set GEMINI_API_KEYS in the environment.\");\n }\n\n const attempts: GeminiAttemptFailure[] = [];\n let attemptNumber = 0;\n\n for (const model of config.models) {\n for (let keyIndex = 0; keyIndex < config.apiKeys.length; keyIndex++) {\n if (attemptNumber > 0) {\n const backoff = Math.min(BASE_BACKOFF_MS * 2 ** (attemptNumber - 1), MAX_BACKOFF_MS);\n await sleep(backoff);\n }\n attemptNumber++;\n\n const apiKey = config.apiKeys[keyIndex];\n try {\n const rawText = await callOnce(model, apiKey, prompt, options);\n return parseResponse(rawText);\n } catch (e) {\n const status = (e as Error & { status?: number })?.status;\n const message = e instanceof Error ? e.message : String(e);\n attempts.push({ model, keyIndex, status, message });\n console.warn(\n `[gemini] ${model} key#${keyIndex + 1} failed${status ? ` (${status})` : \"\"}: ${message}`,\n );\n }\n }\n }\n\n throw new GeminiExhaustedError(attempts);\n}",[163],"76715d65-5286-4ab1-a47e-f03e18bc801c","emoji-automation.ts","fb4eb404-8cff-11f1-8a64-1607ee4eb77e",93,["D",1786299883631],3,"// emoji-automation.ts\n//\n// Automation #2: classify every task's content into exactly one of the\n// CATEGORIES (categories.ts) using Gemini (classifier.ts / gemini.ts) and\n// prepend the result to the task's own content (e.g. \"Fix login bug\" ->\n// \"⚒️ Fix login bug\") -- no Todoist label involved.\n//\n// Two entry points share the same classify-then-update step\n// (classifyBatch) so the retry/apply logic only exists once:\n//\n// - processEmojiSweep() / runEmojiSweepSafely(): the cron batch path.\n// Finds every task missing a category emoji, excludes anything under\n// a 📋 checklist, and works through a bounded number of them per\n// tick in batches of BATCH_SIZE (see below).\n// - processInstantEmojiClassification(taskId): the webhook path. Fires\n// when a task is saved with the literal \"{emoji}\" marker in its\n// content, so on-the-spot testing doesn't require waiting for the\n// next cron tick. Calls the exact same classifyBatch with a batch of\n// one. Saving \"{emoji_all}\" instead runs the full sweep on demand.\n//\n// Locking: the cron sweep is wrapped in its own blob lock (same\n// mechanism as automation.ts's execute-label lock, different key) to\n// stop two overlapping cron ticks from re-scanning the same backlog. The\n// instant webhook path deliberately does NOT take that lock -- it only\n// ever touches the one task named in the webhook payload, so the worst\n// case of a rare overlap with an in-flight sweep is a duplicate\n// (harmless, idempotent-ish -- see computeNewContent) classification of\n// that task, and the whole point of the marker is fast, unblocked\n// feedback while testing.\n\nimport {\n getAllActiveTasks,\n getTask,\n TodoistTask,\n updateTask,\n} from \"./todoist.ts\";\nimport {\n CATEGORY_EMOJIS,\n hasEmojiPrefix,\n hasUncompletablePrefix,\n isChecklistRoot,\n stripUncompletablePrefix,\n} from \"./categories.ts\";\nimport { classifyTasksBatch } from \"./classifier.ts\";\nimport { loadGeminiConfigFromEnv } from \"./gemini.ts\";\nimport { AutomationResult, withBlobLock } from \"./automation.ts\";\n\n// Test markers, accepted with either single or double braces because both\n// get typed in practice ({{emoji}} is the natural thing to write, and\n// stripping only the inner {emoji} used to leave a stray \"{}\" behind).\n// {emoji} -> classify just this task, now\n// {emoji_all} -> run the whole cron sweep now, across every task\nexport const EMOJI_MARKER = \"{emoji}\";\nexport const EMOJI_ALL_MARKER = \"{emoji_all}\";\n\nconst EMOJI_MARKER_RE = /\\{{1,2}\\s*emoji\\s*\\}{1,2}/i;\nconst EMOJI_ALL_MARKER_RE = /\\{{1,2}\\s*emoji_all\\s*\\}{1,2}/i;\nconst ANY_MARKER_RE = /\\{{1,2}\\s*emoji(_all)?\\s*\\}{1,2}/i;\nconst ANY_MARKER_GLOBAL_RE = new RegExp(ANY_MARKER_RE.source, \"gi\");\n\nexport function hasEmojiMarker(content: string): boolean {\n return EMOJI_MARKER_RE.test(content);\n}\n\nexport function hasEmojiAllMarker(content: string): boolean {\n return EMOJI_ALL_MARKER_RE.test(content);\n}\n\nfunction stripMarkers(content: string): string {\n if (!ANY_MARKER_RE.test(content)) return content;\n return content.replace(ANY_MARKER_GLOBAL_RE, \"\").replace(/\\s{2,}/g, \" \")\n .trim();\n}\n\n/** Strips any category emoji this automation may have already prepended\n * (defense against double-prefixing if the sweep and an instant\n * classification ever race on the same task -- see the file header). */\nfunction stripAnyExistingCategoryPrefix(content: string): string {\n const trimmed = content.trimStart();\n for (const emoji of CATEGORY_EMOJIS) {\n if (trimmed.startsWith(emoji)) return trimmed.slice(emoji.length).trim();\n }\n return trimmed;\n}\n\nfunction computeNewContent(originalContent: string, emoji: string): string {\n // \"* \" has to stay in first position or Todoist stops treating the task\n // as uncompletable, so the emoji goes after it, not before it.\n const prefix = hasUncompletablePrefix(originalContent) ? \"* \" : \"\";\n const body = stripAnyExistingCategoryPrefix(\n stripMarkers(stripUncompletablePrefix(originalContent)),\n );\n // Guard a task whose *entire* content was the marker (e.g. a bare\n // \"{emoji}\" test task): don't leave the task blank, just the emoji.\n return body ? `${prefix}${emoji} ${body}` : `${prefix}${emoji}`;\n}\n\nasync function applyClassification(\n task: TodoistTask,\n emoji: string,\n): Promise {\n await updateTask(task.id, {\n content: computeNewContent(task.content, emoji),\n });\n}\n\n// --- Checklist-root exclusion --------------------------------------------\n//\n// A task whose content starts with 📋, or that is a child/grandchild/...\n// of one, is reference material (a checklist), not actionable work --\n// it and its whole subtree are skipped. `lookupParent` abstracts over\n// how a parent task is found so the cron sweep (which already has every\n// active task in memory) can do this with zero extra API calls, while\n// the webhook path (which only has the one task) can look parents up\n// live, one at a time.\n\nconst MAX_ANCESTOR_DEPTH = 10;\n\nexport async function isUnderChecklistRoot(\n task: TodoistTask,\n lookupParent: (\n parentId: string,\n ) => TodoistTask | undefined | Promise,\n maxDepth = MAX_ANCESTOR_DEPTH,\n): Promise {\n let parentId = task.parent_id ?? undefined;\n for (let depth = 0; depth < maxDepth && parentId; depth++) {\n const parent = await lookupParent(parentId);\n if (!parent) return false; // can't resolve further -- fail open, don't block classification\n if (isChecklistRoot(parent.content)) return true;\n parentId = parent.parent_id ?? undefined;\n }\n return false;\n}\n\n// --- Shared classify-and-apply step --------------------------------------\n\nexport interface ClassifyOutcome {\n taskId: string;\n emoji: string;\n}\n\nexport interface ClassifyBatchResult {\n applied: ClassifyOutcome[];\n failed: { taskId: string; error: string }[];\n}\n\n/**\n * The one function both the cron sweep and the instant webhook path call:\n * classifies `tasks` (up to BATCH_SIZE of them) in a single Gemini call\n * and applies each result to Todoist. A batch of one task -- exactly\n * what the webhook path passes -- works the same way as a batch of five.\n */\nexport async function classifyBatch(\n tasks: TodoistTask[],\n): Promise {\n const applied: ClassifyOutcome[] = [];\n const failed: { taskId: string; error: string }[] = [];\n if (tasks.length === 0) return { applied, failed };\n\n const config = loadGeminiConfigFromEnv();\n const inputs = tasks.map((t) => ({\n id: t.id,\n content: stripMarkers(stripUncompletablePrefix(t.content)),\n }));\n\n let results: Map;\n try {\n results = await classifyTasksBatch(inputs, config);\n } catch (e) {\n // Whole batch failed (Gemini exhausted, or the response never came\n // back complete/valid after every retry) -- every task in it stays\n // unclassified and will be picked up again on the next sweep/trigger.\n const message = e instanceof Error ? e.message : String(e);\n console.error(\n `[emoji] Batch classification failed for ${tasks.length} task(s): ${message}`,\n );\n for (const t of tasks) failed.push({ taskId: t.id, error: message });\n return { applied, failed };\n }\n\n for (const task of tasks) {\n const emoji = results.get(task.id);\n if (!emoji) {\n // Shouldn't happen -- classifyTasksBatch only resolves once every\n // requested id has a valid emoji -- but never trust silently.\n failed.push({\n taskId: task.id,\n error: \"Gemini response omitted this task id\",\n });\n continue;\n }\n try {\n await applyClassification(task, emoji);\n applied.push({ taskId: task.id, emoji });\n } catch (e) {\n failed.push({\n taskId: task.id,\n error: e instanceof Error ? e.message : String(e),\n });\n }\n }\n\n return { applied, failed };\n}\n\nfunction chunk(items: T[], size: number): T[][] {\n const chunks: T[][] = [];\n for (let i = 0; i < items.length; i += size) {\n chunks.push(items.slice(i, i + size));\n }\n return chunks;\n}\n\nasync function forEachWithConcurrency(\n items: T[],\n limit: number,\n fn: (item: T) => Promise,\n): Promise {\n let nextIndex = 0;\n async function worker() {\n while (true) {\n const i = nextIndex++;\n if (i >= items.length) return;\n await fn(items[i]);\n }\n }\n const workers = Array.from({ length: Math.min(limit, items.length) }, worker);\n await Promise.all(workers);\n}\n\n// --- Cron path: batch sweep ---------------------------------------------\n//\n// Batch size of 5 per your spec. Val Town's free-plan execution timeout\n// is 1 minute per run (shared with whatever else runs in the same cron\n// tick -- see gemini.ts's header comment on timing), so this caps how\n// many batches one tick will attempt; anything past the cap rolls over\n// to the next 15-minute tick automatically (the sweep re-scans\n// everything, so nothing gets lost, just deferred).\n\nconst BATCH_SIZE = 5;\nconst MAX_BATCHES_PER_SWEEP = 2;\nconst SWEEP_BATCH_CONCURRENCY = 2;\n\nexport async function processEmojiSweep(): Promise {\n let allTasks: TodoistTask[];\n try {\n allTasks = await getAllActiveTasks();\n } catch (e) {\n console.error(\"Failed to fetch tasks for emoji sweep:\", e);\n return { status: \"error\", message: `Failed to fetch tasks: ${e}` };\n }\n\n const taskById = new Map(allTasks.map((t) => [t.id, t] as const));\n\n const needsClassification: TodoistTask[] = [];\n let checklistSkipped = 0;\n for (const task of allTasks) {\n if (hasEmojiPrefix(task.content)) continue;\n if (await isUnderChecklistRoot(task, (id) => taskById.get(id))) {\n checklistSkipped++;\n continue;\n }\n needsClassification.push(task);\n }\n\n const allBatches = chunk(needsClassification, BATCH_SIZE);\n const batches = allBatches.slice(0, MAX_BATCHES_PER_SWEEP);\n const processedCount = batches.reduce((n, b) => n + b.length, 0);\n const deferred = needsClassification.length - processedCount;\n\n let updatedCount = 0;\n let errorCount = 0;\n const log: string[] = [];\n const errors: string[] = [];\n\n await forEachWithConcurrency(\n batches,\n SWEEP_BATCH_CONCURRENCY,\n async (batch) => {\n const { applied, failed } = await classifyBatch(batch);\n for (const a of applied) {\n updatedCount++;\n const msg = `Task ${a.taskId} prefixed ${a.emoji}`;\n log.push(msg);\n console.log(`[emoji] ${msg}`);\n }\n for (const f of failed) {\n errorCount++;\n const msg = `Failed to classify task ${f.taskId}: ${f.error}`;\n errors.push(msg);\n console.error(`[emoji] ${msg}`);\n }\n },\n );\n\n return {\n status: \"success\",\n found: needsClassification.length,\n checklist_skipped: checklistSkipped,\n processed: processedCount,\n deferred,\n updated: updatedCount,\n failed: errorCount,\n log,\n errors,\n };\n}\n\nconst EMOJI_LOCK_KEY = \"todoist-processor:emoji-lock\";\nconst EMOJI_LOCK_TTL_MS = 3 * 60 * 1000; // see automation.ts's withBlobLock doc comment\n\nexport async function runEmojiSweepSafely(\n trigger: string,\n): Promise {\n return withBlobLock({\n lockKey: EMOJI_LOCK_KEY,\n ttlMs: EMOJI_LOCK_TTL_MS,\n trigger,\n run: processEmojiSweep,\n });\n}\n\n// --- Webhook path: instant single-task classification -------------------\n\n/**\n * Re-fetches `taskId` (rather than trusting the webhook payload, which\n * may be stale or a partial snapshot) and, if it still carries the\n * {emoji} marker and isn't excluded (already classified, or a checklist\n * item), runs it through the same classifyBatch as the sweep, as a batch\n * of one. Not lock-guarded -- see the file header for why that's fine.\n */\nexport async function processInstantEmojiClassification(\n taskId: string,\n): Promise {\n let task: TodoistTask;\n try {\n task = await getTask(taskId);\n } catch (e) {\n console.error(\n `Failed to fetch task ${taskId} for instant classification:`,\n e,\n );\n return { status: \"error\", message: `Failed to fetch task ${taskId}: ${e}` };\n }\n\n if (!hasEmojiMarker(task.content)) {\n // Re-fetched content no longer has the marker (already handled by a\n // prior delivery, or edited again before we got to it) -- no-op.\n return { status: \"skipped\", message: \"Marker no longer present on task.\" };\n }\n if (hasEmojiPrefix(task.content)) {\n return { status: \"skipped\", message: \"Task already starts with an emoji.\" };\n }\n\n const lookupParent = async (id: string): Promise => {\n try {\n return await getTask(id);\n } catch {\n return undefined;\n }\n };\n if (await isUnderChecklistRoot(task, lookupParent)) {\n return {\n status: \"skipped\",\n message:\n \"Task is under a 📋 checklist -- reference item, not classified.\",\n };\n }\n\n const { applied, failed } = await classifyBatch([task]);\n if (applied.length > 0) {\n console.log(\n `[emoji] Instant classification: task ${applied[0].taskId} prefixed ${\n applied[0].emoji\n }`,\n );\n return { status: \"success\", ...applied[0] };\n }\n const failure = failed[0];\n console.error(\n `[emoji] Instant classification failed for task ${taskId}: ${failure?.error}`,\n );\n return { status: \"error\", message: failure?.error ?? \"unknown error\" };\n}",[170],"8139d323-038e-4be5-af08-b82510088ef4","classifier.ts","fb4e85d8-8cff-11f1-8a64-1607ee4eb77e",["D",1785516648586],"// classifier.ts\n//\n// Domain glue: turns a batch of tasks' text content into category emoji\n// (categories.ts) using Gemini (gemini.ts). Knows nothing about Todoist\n// task objects, the {emoji} marker, or checklist exclusion -- just\n// \"given these id+content pairs, which emoji does each get\".\n//\n// Batched by design: one Gemini call classifies up to BATCH_SIZE tasks\n// (see emoji-automation.ts) at once, and the model is asked to answer\n// with id + emoji only -- never asked to echo back task content, so a\n// batch's output is a handful of short JSON objects rather than a\n// restatement of everything it was given.\n\nimport { CATEGORIES, CATEGORY_EMOJIS } from \"./categories.ts\";\nimport { callGeminiWithRetry, GeminiConfig } from \"./gemini.ts\";\n\nconst VALID_EMOJIS = CATEGORIES.map((c) => c.emoji);\n\nconst SYSTEM_INSTRUCTION =\n \"You are a strict classifier for a personal to-do list. For each task \" +\n \"given, choose exactly one category and output only its emoji -- never \" +\n \"the category name, never the task content, never any explanation. \" +\n \"If a task is genuinely ambiguous, pick the closest match rather than \" +\n \"omitting it.\";\n\nfunction buildBatchPrompt(tasks: { id: string; content: string }[]): string {\n const categoryLines = CATEGORIES\n .map((c) => `- \"${c.emoji}\" -- ${c.name}: ${c.description}`)\n .join(\"\\n\");\n const taskLines = tasks\n .map((t) => `- id=\"${t.id}\" content=${JSON.stringify(t.content)}`)\n .join(\"\\n\");\n\n return (\n `Categories:\\n${categoryLines}\\n\\n` +\n `Classify each task below into exactly one category. Respond with a ` +\n `JSON array with one object per task: {\"id\": , \"emoji\": }.\\n\\n` +\n `Tasks:\\n${taskLines}`\n );\n}\n\ninterface RawBatchItem {\n id?: unknown;\n emoji?: unknown;\n}\n\n/** Throws (rather than returning a partial result) if the response isn't\n * a clean JSON array, if any item's emoji isn't one of the 13 valid\n * category emoji, or if any requested id is missing from the response.\n * callGeminiWithRetry treats a thrown error here exactly like a\n * transport failure and moves on to the next key/model -- so an\n * incomplete-but-otherwise-valid-looking answer gets a real retry\n * rather than silently shipping partial results. */\nfunction parseBatchResponse(\n rawText: string,\n requestedIds: Set,\n): Map {\n let parsed: unknown;\n try {\n parsed = JSON.parse(rawText);\n } catch {\n throw new Error(\n `batch response was not valid JSON: ${rawText.slice(0, 200)}`,\n );\n }\n if (!Array.isArray(parsed)) {\n throw new Error(\n `batch response was not a JSON array: ${rawText.slice(0, 200)}`,\n );\n }\n\n const result = new Map();\n for (const raw of parsed as RawBatchItem[]) {\n if (typeof raw !== \"object\" || raw === null) continue;\n const { id, emoji } = raw;\n if (typeof id !== \"string\" || typeof emoji !== \"string\") continue;\n if (!requestedIds.has(id)) continue; // ignore ids we didn't ask about\n if (!CATEGORY_EMOJIS.has(emoji)) {\n throw new Error(\n `task ${id}: unrecognized emoji in batch response: ${\n JSON.stringify(emoji)\n }`,\n );\n }\n result.set(id, emoji);\n }\n\n const missing = [...requestedIds].filter((id) => !result.has(id));\n if (missing.length > 0) {\n throw new Error(\n `batch response missing ${missing.length}/${requestedIds.size} requested id(s): ${\n missing.join(\", \")\n }`,\n );\n }\n\n return result;\n}\n\n/**\n * Classifies a batch of up to a few tasks in a single Gemini call,\n * returning a map from task id to category emoji. Retries across every\n * configured model x key combination (see gemini.ts) if the call fails\n * OR if the response comes back incomplete/invalid. Works identically\n * for a \"batch\" of one, which is what the instant webhook path uses --\n * see emoji-automation.ts's classifyBatch, the single shared entry point\n * both the cron sweep and the webhook handler call into.\n */\nexport async function classifyTasksBatch(\n tasks: { id: string; content: string }[],\n config: GeminiConfig,\n): Promise> {\n const prompt = buildBatchPrompt(tasks);\n const requestedIds = new Set(tasks.map((t) => t.id));\n // Generous relative to actual need (each item is ~30-40 tokens of JSON)\n // so a full batch's visible output is never the bottleneck.\n const maxOutputTokens = 100 + 100 * tasks.length;\n\n return await callGeminiWithRetry(\n config,\n prompt,\n (rawText) => parseBatchResponse(rawText, requestedIds),\n {\n systemInstruction: SYSTEM_INSTRUCTION,\n responseMimeType: \"application/json\",\n responseSchema: {\n type: \"array\",\n items: {\n type: \"object\",\n properties: {\n id: { type: \"string\" },\n emoji: { type: \"string\", enum: VALID_EMOJIS },\n },\n required: [\"id\", \"emoji\"],\n propertyOrdering: [\"id\", \"emoji\"],\n },\n },\n thinkingLevel: \"medium\",\n maxOutputTokens,\n },\n );\n}",[178],"ae35309a-9ac0-48fd-8e0b-34c214c3429e","categories.ts","46861880-8ce3-11f1-bc88-1607ee4eb77e",["D",1786299883631],7,"// categories.ts\n//\n// The fixed set of top-level categories every task's content gets\n// classified into. `emoji` is the *exact* character(s) prepended to a\n// task's content and checked for to know a task has already been\n// classified. These must match your intent character-for-character\n// (including invisible variation-selector bytes some of these emoji\n// carry) -- if classification or detection ever looks like it's\n// misbehaving, diffing these against what you actually typed is the\n// first thing to check.\n//\n// NOTE: two categories carry a secondary tagging scheme in the source\n// spec that this file does NOT turn into anything extra:\n// - Action is meant to be paired with an energy tag (Deep Work 🔥,\n// Supervision/AI ⚡, or Grunt Work 🧊)\n// - Logistics' description mentions a 🚚 + 🗺️ split\n// The classifier only ever prepends one of the `emoji` values below.\n// Say the word if you'd like the energy sub-tags classified and applied\n// too.\n\nexport interface Category {\n name: string;\n emoji: string; // exact emoji character(s) prepended to task content\n description: string;\n}\n\nexport const CATEGORIES: Category[] = [\n {\n name: \"Action\",\n emoji: \"⚒️\",\n description:\n \"The Work. General execution -- the default for a concrete, doable task.\",\n },\n {\n name: \"JIRA\",\n emoji: \"🎟️\",\n description:\n \"Work Tickets. Technical tasks synced from the professional JIRA project.\",\n },\n {\n name: \"Experiments\",\n emoji: \"🧪\",\n description:\n 'Research Lab. Sandbox testing, hypotheses, \"discovery\" coding.',\n },\n {\n name: \"Evaluate\",\n emoji: \"⚖️\",\n // The source spec gave no elaboration beyond the name for this one --\n // filled in with a minimal, literal reading. Tighten this if\n // classification confuses it with Analysis.\n description: \"Weighing options or making a decision between alternatives.\",\n },\n {\n name: \"Analysis\",\n emoji: \"🧐\",\n description:\n \"Deep Dive. Investigative searching, sourcing, documenting complex info.\",\n },\n {\n name: \"Input\",\n emoji: \"📖\",\n description: \"Consumption. Reading articles, books, documentation.\",\n },\n {\n name: \"Output\",\n emoji: \"✍🏼\",\n description: \"Expression. Writing emails, essays, logs, research drafts.\",\n },\n {\n name: \"Sync\",\n emoji: \"📞\",\n description:\n \"Communicate. Meetings, calls, high-priority outbound messages.\",\n },\n {\n name: \"Logistics\",\n emoji: \"🧭\",\n description:\n \"Navigation. Trip planning, reservations, errand coordination.\",\n },\n {\n name: \"Admin\",\n emoji: \"⚙️\",\n description: \"Maintenance. Digital plumbing, backups, file management.\",\n },\n {\n name: \"Framework\",\n emoji: \"🏗️\",\n description:\n \"Architecture. Structural, uncompletable tasks that hold projects together.\",\n },\n {\n name: \"Milestone\",\n emoji: \"⛳\",\n description: \"Objectives. High-level goals or progress markers.\",\n },\n {\n name: \"Seed\",\n emoji: \"🌱\",\n // Added per your message; \"Seed\" is my best-guess name for this one --\n // rename freely if you had a different word in mind.\n description:\n \"Future Projects. An early-stage idea or seed not yet ready to act on.\",\n },\n];\n\nexport const CATEGORY_EMOJIS: Set = new Set(\n CATEGORIES.map((c) => c.emoji),\n);\n\n/** Manually-applied marker for a checklist/reference task -- NOT one of the\n * 13 classification categories, and never written by this automation.\n * A task under a 📋-prefixed ancestor (or prefixed with 📋 itself) is\n * treated as reference material and skipped entirely. */\nexport const CHECKLIST_ROOT_EMOJI = \"📋\";\n\n/** Todoist marks a task uncompletable with a literal \"* \" at the very\n * start of its content. That's formatting, not text, so every prefix\n * check below looks past it -- and anything this automation writes back\n * has to keep it in first position or the task becomes completable. */\nconst UNCOMPLETABLE_PREFIX_RE = /^\\*\\s+/;\n\nexport function stripUncompletablePrefix(content: string): string {\n return content.trimStart().replace(UNCOMPLETABLE_PREFIX_RE, \"\").trimStart();\n}\n\nexport function hasUncompletablePrefix(content: string): boolean {\n return UNCOMPLETABLE_PREFIX_RE.test(content.trimStart());\n}\n\n/** Deliberately matches ANY emoji, not just the category set: a task that\n * already opens with an emoji was labelled by hand (possibly with one\n * outside this list on purpose) and must be left exactly as it is. */\nconst LEADING_EMOJI_RE = /^\\p{Extended_Pictographic}/u;\n\n/** True if `content` already opens with an emoji of any kind -- meaning it\n * is already classified, hand-tagged, or a 📋 reference container, and in\n * all three cases must not be touched. */\nexport function hasEmojiPrefix(content: string): boolean {\n return LEADING_EMOJI_RE.test(stripUncompletablePrefix(content));\n}\n\n/** True if `content` is a 📋 checklist container. */\nexport function isChecklistRoot(content: string): boolean {\n return stripUncompletablePrefix(content).startsWith(CHECKLIST_ROOT_EMOJI);\n}",[184],"3c0b9ebd-71f7-44d7-88bd-cfc42f619283","automation.ts","f1eb719c-88ed-11f1-a9fb-1607ee4eb77e",["D",1786299831404],16,"// automation.ts\n//\n// Automation #1: auto-schedule any task carrying the \"execute 🌥\" label\n// to be due today (before 9 PM Bucharest time) or tomorrow (from 9 PM\n// onward). runAutomationSafely() wraps it behind a blob-backed lock so a\n// webhook firing at the same moment as the cron backup can never double-\n// process the same tasks. (A plain in-memory lock wouldn't be reliable\n// here: unlike a single gunicorn worker, Val Town may run concurrent\n// invocations on separate isolates that don't share memory, so the lock\n// has to live in shared storage instead.)\n//\n// The locking mechanism (withBlobLock) is generalized below so the emoji\n// classification automation (emoji-automation.ts) can reuse it without\n// duplicating the acquire/release/TTL logic -- see that file for the\n// second lock instance.\n\nimport { blob } from \"https://esm.town/v/std/blob/main.ts\";\nimport { getTasksByLabel, TodoistTask, updateTask } from \"./todoist.ts\";\n\nexport const EXECUTE_LABEL = \"execute 🌥\";\nconst ROLLOVER_HOUR = 21; // 9 PM local time\n\nexport type AutomationResult = Record;\n\n// --- Timezone helpers -------------------------------------------------\n\n/** Returns { year, month, day, hour } for `date`, as observed in Europe/Bucharest. */\nfunction getBucharestParts(date: Date) {\n const fmt = new Intl.DateTimeFormat(\"en-GB\", {\n timeZone: \"Europe/Bucharest\",\n year: \"numeric\",\n month: \"2-digit\",\n day: \"2-digit\",\n hour: \"2-digit\",\n hourCycle: \"h23\",\n });\n const parts = fmt.formatToParts(date);\n const map: Record = {};\n for (const p of parts) map[p.type] = p.value;\n return {\n year: parseInt(map.year, 10),\n month: parseInt(map.month, 10),\n day: parseInt(map.day, 10),\n hour: parseInt(map.hour, 10),\n };\n}\n\nfunction ymdToUtcDate(y: number, m: number, d: number): Date {\n return new Date(Date.UTC(y, m - 1, d));\n}\n\nfunction formatIsoDate(d: Date): string {\n const y = d.getUTCFullYear();\n const m = String(d.getUTCMonth() + 1).padStart(2, \"0\");\n const day = String(d.getUTCDate()).padStart(2, \"0\");\n return `${y}-${m}-${day}`;\n}\n\n/**\n * Returns the date that any task carrying EXECUTE_LABEL should be due on.\n * Before ROLLOVER_HOUR (9 PM) Bucharest time -> today. From ROLLOVER_HOUR\n * onward -> tomorrow. Cron triggers always run in UTC, so this recomputes\n * the real local hour on every call rather than trusting when the caller\n * happened to run -- correct across DST changes with zero extra config.\n */\nexport function getTargetDueDate(now: Date = new Date()): Date {\n const parts = getBucharestParts(now);\n let target = ymdToUtcDate(parts.year, parts.month, parts.day);\n if (parts.hour >= ROLLOVER_HOUR) {\n target = new Date(target.getTime() + 24 * 60 * 60 * 1000);\n }\n return target;\n}\n\nfunction extractDueDateStr(task: TodoistTask): string | null {\n if (!task.due || !task.due.date) return null;\n return task.due.date.split(\"T\")[0];\n}\n\n// --- Automation: \"execute 🌥\" auto-scheduling --------------------------\n\nexport async function processExecuteTodayLabel(): Promise {\n const targetDate = getTargetDueDate();\n const targetDateStr = formatIsoDate(targetDate);\n\n let updatedCount = 0;\n let alreadyCorrectCount = 0;\n let errorCount = 0;\n const errors: string[] = [];\n const logLines: string[] = [];\n\n let matchingTasks: TodoistTask[];\n try {\n matchingTasks = await getTasksByLabel(EXECUTE_LABEL);\n } catch (e) {\n console.error(\"Failed to fetch tasks for execute-label processing:\", e);\n return { status: \"error\", message: `Failed to fetch tasks: ${e}` };\n }\n\n for (const task of matchingTasks) {\n const currentDueStr = extractDueDateStr(task);\n if (currentDueStr === targetDateStr) {\n alreadyCorrectCount++;\n continue;\n }\n\n try {\n await updateTask(task.id, { due_date: targetDateStr });\n updatedCount++;\n const msg =\n `Task ${task.id} ('${task.content}') due date set to ${targetDateStr}`;\n logLines.push(msg);\n console.log(`[${EXECUTE_LABEL}] ${msg}`);\n } catch (e) {\n errorCount++;\n errors.push(`Failed to update task ${task.id}: ${e}`);\n console.error(`[${EXECUTE_LABEL}] Failed to update task ${task.id}:`, e);\n }\n }\n\n return {\n status: \"success\",\n target_date: targetDateStr,\n found: matchingTasks.length,\n updated: updatedCount,\n already_correct: alreadyCorrectCount,\n failed: errorCount,\n log: logLines,\n errors,\n };\n}\n\n// --- Orchestration ------------------------------------------------------\n\nexport async function runAutomation(): Promise {\n return await processExecuteTodayLabel();\n}\n\n// --- Shared blob-backed lock ---------------------------------------------\n//\n// Generalized so any automation can get the same crash-safe locking\n// without reimplementing it: a plain in-memory lock isn't reliable here\n// since Val Town may run concurrent invocations on isolates that don't\n// share memory. TTL is a stale-lock safety valve for a run that crashes\n// (or gets killed by Val Town's execution timeout) mid-way; 3 minutes\n// gives a comfortable 3x margin over the free plan's 1-minute execution\n// ceiling (see https://www.val.town/limits) while still self-healing\n// quickly if a lock is ever left stuck.\n\nexport interface WithBlobLockOptions {\n lockKey: string;\n ttlMs: number;\n trigger: string;\n run: () => Promise;\n}\n\ninterface LockState {\n lockedAt: number;\n trigger: string;\n}\n\nexport async function withBlobLock(\n { lockKey, ttlMs, trigger, run }: WithBlobLockOptions,\n): Promise {\n const existing = (await blob.getJSON(lockKey)) as LockState | undefined;\n const now = Date.now();\n\n if (existing && now - existing.lockedAt < ttlMs) {\n console.warn(\n `Automation run skipped (lock=${lockKey}, trigger=${trigger}): another run is in progress.`,\n );\n return {\n status: \"skipped\",\n trigger,\n message: \"An automation run was already in progress.\",\n };\n }\n\n await blob.setJSON(lockKey, { lockedAt: now, trigger } satisfies LockState);\n\n try {\n console.log(\n `Automation run started (lock=${lockKey}, trigger=${trigger}).`,\n );\n const result = await run();\n result.trigger = trigger;\n console.log(\n `Automation run finished (lock=${lockKey}, trigger=${trigger}).`,\n );\n return result;\n } catch (e) {\n console.error(\n `Automation run failed unexpectedly (lock=${lockKey}, trigger=${trigger}):`,\n e,\n );\n return { status: \"error\", trigger, message: String(e) };\n } finally {\n await blob.delete(lockKey);\n }\n}\n\nconst LOCK_KEY = \"todoist-processor:automation-lock\";\nconst LOCK_TTL_MS = 3 * 60 * 1000;\n\nexport async function runAutomationSafely(\n trigger: string,\n): Promise {\n return withBlobLock({\n lockKey: LOCK_KEY,\n ttlMs: LOCK_TTL_MS,\n trigger,\n run: runAutomation,\n });\n}",[191],"pulls","branches",2,"forks","envVars",{"_205":187,"_207":62},"connections",{"_205":62,"_206":62},"count","unfilledCount","emptyCount",{"_42":190,"_32":191,"_30":192,"_136":-5,"_40":41,"_39":148,"_138":48,"_37":238,"_13":194,"_33":34,"_35":195,"_24":48,"_143":-5,"_217":239,"_27":240},{"_42":183,"_32":184,"_30":185,"_136":-5,"_40":41,"_39":172,"_138":48,"_37":235,"_13":187,"_33":34,"_35":188,"_24":48,"_143":-5,"_217":236,"_27":237},{"_42":177,"_32":178,"_30":179,"_136":-5,"_40":41,"_39":165,"_138":25,"_37":232,"_13":62,"_33":34,"_35":181,"_24":48,"_143":-5,"_217":233,"_27":234},{"_42":169,"_32":170,"_30":171,"_136":-5,"_40":41,"_39":172,"_138":48,"_37":229,"_13":174,"_33":34,"_35":175,"_24":48,"_143":-5,"_217":230,"_27":231},{"_42":162,"_32":163,"_30":164,"_136":-5,"_40":41,"_39":165,"_138":25,"_37":226,"_13":62,"_33":34,"_35":167,"_24":48,"_143":-5,"_217":227,"_27":228},{"_42":153,"_32":154,"_30":155,"_136":-5,"_40":41,"_39":156,"_138":48,"_37":223,"_13":158,"_33":159,"_35":160,"_24":48,"_143":-5,"_217":224,"_27":225},{"_42":145,"_32":146,"_30":147,"_136":-5,"_40":41,"_39":148,"_138":48,"_37":220,"_13":150,"_33":34,"_35":151,"_24":48,"_143":-5,"_217":221,"_27":222},{"_42":134,"_32":135,"_30":57,"_136":-5,"_40":41,"_39":137,"_138":25,"_37":216,"_13":140,"_33":141,"_35":142,"_24":48,"_143":-5,"_217":218,"_27":219},["D",1786299857247],"children",[],[135],["D",1786299831404],[],[146],["D",1786299913530],[],[154],["D",1785516648586],[],[163],["D",1786299883631],[],[170],["D",1785516648586],[],[178],["D",1786299883631],[],[184],["D",1786299831404],[],[191],["D",1785014870875],{"_96":95,"_104":100},{"_96":95,"_97":98,"_99":100,"_18":55,"_101":102,"_103":48},{"_13":85,"_32":86,"_42":41,"_87":43,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":44,"_94":95},"ctx",{"_78":-5,"_123":278,"_279":280,"_281":282,"_283":48,"_284":48,"_285":48,"_286":25,"_287":-5,"_288":-7,"_289":-7,"_290":62,"_291":48,"_292":48,"_293":-5,"_294":48,"_295":48,"_296":48,"_297":-5},"ENV",{"_249":250,"_251":252,"_253":86,"_254":255,"_256":257,"_258":259,"_260":261,"_262":263,"_264":265,"_266":267,"_268":269,"_270":271,"_272":273,"_274":275,"_276":277},"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 · v96