\n \n \n

…

\n\n\n\n`;\n",[171],"37796647-2ec4-403f-9828-4a853be7fe05",["D",1781281212333],"// The classification pipeline: fetch page -> guard -> classify -> write back.\nimport { classify } from \"./classify.ts\";\nimport { getTagOptions, notion, plainText } from \"./notion.ts\";\n\nexport interface ProcessResult {\n pageId: string;\n status: \"processed\" | \"skipped\";\n reason?: string;\n practiceable?: boolean;\n tags?: string[];\n candidates?: string[];\n}\n\n// Best-effort in-flight lock: /capture's inline run and the page.created\n// webhook delivery for the same new page usually land on the same warm\n// isolate, as do rapid properties_updated events. Module state dedupes those;\n// the post-classify re-check below narrows the cross-isolate window.\nconst inFlight = new Set();\n\nexport async function processPage(\n pageId: string,\n opts: { note?: string; force?: boolean } = {},\n): Promise {\n if (inFlight.has(pageId)) return { pageId, status: \"skipped\", reason: \"in-flight\" };\n inFlight.add(pageId);\n try {\n return await processPageInner(pageId, opts);\n } finally {\n inFlight.delete(pageId);\n }\n}\n\nasync function processPageInner(\n pageId: string,\n opts: { note?: string; force?: boolean },\n): Promise {\n const page = await notion(\"GET\", `/pages/${pageId}`);\n\n const title = plainText(page.properties[\"Quote/Insight\"]?.title);\n if (!title.trim()) {\n // She's likely still typing — page.properties_updated will re-deliver once\n // the title lands, so skipping here loses nothing.\n return { pageId, status: \"skipped\", reason: \"empty-title\" };\n }\n\n // Idempotency guard: Status is set by this worker and only by this worker on\n // unprocessed pages, so a non-empty Status means we already ran.\n if (!opts.force && page.properties[\"Status\"]?.select) {\n return { pageId, status: \"skipped\", reason: \"already-processed\" };\n }\n\n const tagOptions = await getTagOptions();\n const result = await classify(title, opts.note, tagOptions);\n\n // The classify call took seconds — re-check the guard so a concurrent run\n // (other isolate, near-simultaneous webhook deliveries) doesn't double-write.\n if (!opts.force) {\n const fresh = await notion(\"GET\", `/pages/${pageId}`);\n if (fresh.properties[\"Status\"]?.select) {\n return { pageId, status: \"skipped\", reason: \"processed-concurrently\" };\n }\n }\n\n const existingTags: string[] = (page.properties[\"Tags\"]?.multi_select ?? [])\n .map((t: { name: string }) => t.name);\n const mergedTags = [...new Set([...existingTags, ...result.tags])];\n\n const properties: Record = {\n \"Practiceable\": { checkbox: result.practiceable },\n \"Status\": { select: { name: result.practiceable ? \"Practiceable\" : \"Captured\" } },\n \"Tags\": { multi_select: mergedTags.map((name) => ({ name })) },\n };\n if (result.practiceable) {\n // One rich_text item per candidate (Notion caps each text item at 2000\n // chars). The candidate text is bounded before the newline separator is\n // appended, so the app's split-on-newline parsing can never merge two\n // candidates.\n properties[\"Candidate If-Thens\"] = {\n rich_text: result.candidate_if_thens.map((c, i) => ({\n text: {\n content: `${i + 1}. ${c.slice(0, 1900)}` +\n (i < result.candidate_if_thens.length - 1 ? \"\\n\" : \"\"),\n },\n })),\n };\n properties[\"Rep Count\"] = { number: 0 };\n properties[\"Rep Target\"] = { number: 5 };\n // Epoch ms gives natural FIFO ordering; set a small number manually in\n // Notion to jump an item up the queue.\n properties[\"Queue Order\"] = { number: Date.now() };\n }\n\n await notion(\"PATCH\", `/pages/${pageId}`, { properties });\n\n return {\n pageId,\n status: \"processed\",\n practiceable: result.practiceable,\n tags: mergedTags,\n candidates: result.candidate_if_thens,\n };\n}\n",[109],"860b58e4-ca51-413a-a9e8-e250f810a15c",["D",1781282852085],"// Notion API helpers. Runs on Val Town (Deno).\nexport const NOTION_VERSION = \"2025-09-03\";\n\n// Errors that will fail the same way on every retry — the webhook handler\n// returns 200 for these so Notion doesn't redeliver (and re-bill Claude).\nexport class PermanentError extends Error {}\n\nexport const isPermanent = (err: unknown): boolean => {\n if (err instanceof PermanentError) return true;\n const status = (err as { status?: number })?.status;\n return typeof status === \"number\" && status < 500 && status !== 429;\n};\n\nexport const env = (key: string): string => {\n const v = Deno.env.get(key);\n if (!v) throw new Error(`Missing env var: ${key}`);\n return v;\n};\n\nexport async function notion(\n method: string,\n path: string,\n body?: unknown,\n attempt = 0,\n): Promise {\n const res = await fetch(`https://api.notion.com/v1${path}`, {\n method,\n headers: {\n Authorization: `Bearer ${env(\"NOTION_TOKEN\")}`,\n \"Notion-Version\": NOTION_VERSION,\n \"Content-Type\": \"application/json\",\n },\n body: body ? JSON.stringify(body) : undefined,\n });\n if (res.status === 429 && attempt < 4) {\n const wait = Number(res.headers.get(\"Retry-After\") ?? 1) * 1000;\n await new Promise((r) => setTimeout(r, wait));\n return notion(method, path, body, attempt + 1);\n }\n const json = await res.json();\n if (!res.ok) {\n throw Object.assign(\n new Error(`${method} ${path} -> ${res.status}: ${json.message ?? JSON.stringify(json)}`),\n { status: res.status },\n );\n }\n return json;\n}\n\nexport const plainText = (richText: Array<{ plain_text: string }> | undefined): string =>\n (richText ?? []).map((t) => t.plain_text).join(\"\");\n\n// --- App-facing helpers (the Reps web app talks to the worker, never to\n// Notion directly — the integration token stays server-side) ---\n\nexport interface Learning {\n id: string;\n title: string;\n ifThen: string;\n candidates: string[];\n repCount: number;\n repTarget: number;\n}\n\nexport function parseLearning(page: any): Learning {\n const candidatesRaw = plainText(page.properties[\"Candidate If-Thens\"]?.rich_text);\n return {\n id: page.id,\n title: plainText(page.properties[\"Quote/Insight\"]?.title),\n ifThen: plainText(page.properties[\"If-Then\"]?.rich_text),\n candidates: candidatesRaw\n .split(\"\\n\")\n .map((line: string) => line.replace(/^\\d+\\.\\s*/, \"\").trim())\n .filter(Boolean),\n repCount: page.properties[\"Rep Count\"]?.number ?? 0,\n repTarget: page.properties[\"Rep Target\"]?.number ?? 5,\n };\n}\n\nexport async function queryOneLearning(filter: unknown, sorts?: unknown): Promise {\n const res = await notion(\"POST\", `/data_sources/${env(\"NOTION_DATA_SOURCE_ID\")}/query`, {\n filter,\n ...(sorts ? { sorts } : {}),\n page_size: 1,\n });\n return res.results.length ? parseLearning(res.results[0]) : null;\n}\n\nexport const queryActive = (): Promise =>\n queryOneLearning({ property: \"Status\", select: { equals: \"Active\" } });\n\nexport const queryNextPracticeable = (): Promise =>\n queryOneLearning({ property: \"Status\", select: { equals: \"Practiceable\" } }, [\n { property: \"Queue Order\", direction: \"ascending\" },\n { timestamp: \"created_time\", direction: \"ascending\" },\n ]);\n\nexport async function getTagOptions(): Promise {\n const ds = await notion(\"GET\", `/data_sources/${env(\"NOTION_DATA_SOURCE_ID\")}`);\n const options = ds.properties?.[\"Tags\"]?.multi_select?.options;\n if (!options) throw new PermanentError(\"Tags property missing or not multi_select on data source\");\n return options.map((o: { name: string }) => o.name);\n}\n\nexport async function createLearningPage(\n text: string,\n note?: string,\n url?: string,\n): Promise {\n const properties: Record = {\n \"Quote/Insight\": { title: [{ text: { content: text.slice(0, 2000) } }] },\n };\n // URL is a pre-existing property on the Learning database (predates this\n // system) — not part of the knowing-doing schema additions.\n if (url) properties[\"URL\"] = { url };\n const page = await notion(\"POST\", \"/pages\", {\n parent: { type: \"data_source_id\", data_source_id: env(\"NOTION_DATA_SOURCE_ID\") },\n properties,\n children: note\n ? [{\n object: \"block\",\n type: \"paragraph\",\n paragraph: { rich_text: [{ text: { content: note.slice(0, 2000) } }] },\n }]\n : [],\n });\n return page.id;\n}\n",[90],"0ae9e14f-1554-478c-a4dd-fe8f9e95ee47",["D",1781285466538],"// HTTP entry point. Routes:\n// POST /webhook Notion integration webhook (page.created / page.properties_updated)\n// POST /capture iOS Shortcut: { text, note?, url? } -> create page + classify inline\n// POST /process secret-gated manual run: { page_id, force? }\n// GET /verification secret-gated: returns the Notion webhook verification token\n// GET / health\nimport { blob } from \"https://esm.town/v/std/blob\";\nimport { CAPTURE_HTML } from \"./capture-ui.ts\";\nimport { ICON_PNG_B64, ICON_REPS_PNG_B64 } from \"./icon.ts\";\nimport {\n createLearningPage,\n env,\n isPermanent,\n notion,\n queryActive,\n queryNextPracticeable,\n} from \"./notion.ts\";\nimport { processPage } from \"./process.ts\";\nimport { REPS_HTML } from \"./reps-ui.ts\";\nimport { SHORTCUT_B64 } from \"./shortcut-file.ts\";\n\n// Namespaced: std/blob keys are shared across all of the account's vals.\nconst VERIFICATION_KEY = \"knowing-doing:notion-webhook-verification-token\";\n\nconst json = (data: unknown, status = 200) =>\n new Response(JSON.stringify(data), {\n status,\n headers: { \"Content-Type\": \"application/json\" },\n });\n\nfunction safeEqual(a: string, b: string): boolean {\n const enc = new TextEncoder();\n const ab = enc.encode(a), bb = enc.encode(b);\n if (ab.length !== bb.length) return false;\n let diff = 0;\n for (let i = 0; i < ab.length; i++) diff |= ab[i] ^ bb[i];\n return diff === 0;\n}\n\nasync function hmacHex(key: string, body: string): Promise {\n const k = await crypto.subtle.importKey(\n \"raw\",\n new TextEncoder().encode(key),\n { name: \"HMAC\", hash: \"SHA-256\" },\n false,\n [\"sign\"],\n );\n const sig = await crypto.subtle.sign(\"HMAC\", k, new TextEncoder().encode(body));\n return [...new Uint8Array(sig)].map((b) => b.toString(16).padStart(2, \"0\")).join(\"\");\n}\n\nconst authorized = (req: Request): boolean => {\n const secret = req.headers.get(\"X-Capture-Secret\") ?? \"\";\n return secret.length > 0 && safeEqual(secret, env(\"CAPTURE_SECRET\"));\n};\n\nasync function handleWebhook(req: Request): Promise {\n const raw = await req.text();\n let body: any;\n try {\n body = JSON.parse(raw);\n } catch (_) {\n return json({ error: \"invalid json\" }, 400);\n }\n\n const stored = await blob.getJSON(VERIFICATION_KEY) as { token: string } | undefined;\n\n // One-time verification handshake: Notion POSTs { verification_token } when\n // the subscription is created. Accept it only while no token is stored (or\n // when explicitly authorized with the capture secret, for re-subscribing) —\n // otherwise anyone could overwrite the token and sign forged events.\n if (body.verification_token) {\n if (stored?.token && !authorized(req)) {\n console.warn(\"Rejected handshake: token already stored\");\n return json({ error: \"already verified\" }, 409);\n }\n await blob.setJSON(VERIFICATION_KEY, { token: body.verification_token });\n console.log(\"Stored Notion verification token\");\n return json({ ok: true });\n }\n\n // Fail closed: ongoing deliveries are only processed once the handshake has\n // happened, and every delivery must carry a valid HMAC signature. Log every\n // rejection — silent 4xx/5xx here would make delivery problems invisible.\n if (!stored?.token) {\n console.warn(`webhook delivery rejected (no stored token): type=${body.type}`);\n return json({ error: \"webhook not verified yet\" }, 503);\n }\n const sig = (req.headers.get(\"X-Notion-Signature\") ?? \"\").replace(/^sha256=/, \"\");\n const expected = await hmacHex(stored.token, raw);\n if (!safeEqual(sig, expected)) {\n console.warn(`webhook delivery rejected (bad signature): type=${body.type}`);\n return json({ error: \"bad signature\" }, 401);\n }\n console.log(`webhook delivery: type=${body.type} entity=${body.entity?.id ?? \"?\"}`);\n\n const relevant =\n (body.type === \"page.created\" || body.type === \"page.properties_updated\") &&\n body.entity?.type === \"page\" &&\n body.data?.parent?.data_source_id?.replaceAll(\"-\", \"\") ===\n env(\"NOTION_DATA_SOURCE_ID\").replaceAll(\"-\", \"\");\n if (!relevant) return json({ ok: true, ignored: body.type ?? \"unknown\" });\n\n try {\n const result = await processPage(body.entity.id);\n console.log(`webhook ${body.type}:`, JSON.stringify(result));\n return json(result);\n } catch (err) {\n // Permanent failures get a 200 so Notion stops redelivering (each retry\n // would re-run the full classification); transient ones get a 500 so\n // Notion's backoff retries them.\n console.error(`webhook ${body.type} failed:`, err);\n if (isPermanent(err)) return json({ ok: false, permanent: true, error: String(err) });\n return json({ error: String(err) }, 500);\n }\n}\n\nasync function handleCapture(req: Request): Promise {\n if (!authorized(req)) return json({ error: \"unauthorized\" }, 401);\n const body = await req.json().catch(() => ({}));\n let text = (body.text ?? \"\").toString().trim();\n if (!text) return json({ error: \"text required\" }, 400);\n let note = (body.note ?? \"\").toString().trim() || undefined;\n let url = (body.url ?? \"\").toString().trim() || undefined;\n\n // Link-only share (URL with no stated learning): the URL goes in the URL\n // property; the note — the owner's actual takeaway — becomes the learning.\n // Without a note it's a bookmark, and the classifier is told so rather than\n // left to confabulate if-thens from a URL slug.\n if (!url && /^https?:\\/\\/\\S+$/i.test(text)) {\n url = text;\n text = note ?? text;\n note = note ? undefined : \"link-only capture: no learning stated by the owner\";\n }\n\n const pageId = await createLearningPage(text, note, url);\n const result = await processPage(pageId, { note });\n const summary = result.practiceable\n ? `Practiceable ✓ — ${result.candidates?.length ?? 0} if-thens drafted`\n : \"Captured (not practiceable)\";\n return json({ ...result, summary });\n}\n\nexport default async function (req: Request): Promise {\n const { pathname } = new URL(req.url);\n try {\n if (req.method === \"POST\" && pathname === \"/webhook\") return await handleWebhook(req);\n if (req.method === \"POST\" && pathname === \"/capture\") return await handleCapture(req);\n if (req.method === \"POST\" && pathname === \"/process\") {\n if (!authorized(req)) return json({ error: \"unauthorized\" }, 401);\n const body = await req.json().catch(() => ({}));\n if (!body.page_id) return json({ error: \"page_id required\" }, 400);\n return json(await processPage(body.page_id, { force: !!body.force }));\n }\n if (req.method === \"GET\" && pathname === \"/verification\") {\n if (!authorized(req)) return json({ error: \"unauthorized\" }, 401);\n const stored = await blob.getJSON(VERIFICATION_KEY) as { token: string } | undefined;\n return json({ verification_token: stored?.token ?? null });\n }\n if (req.method === \"GET\" && (pathname === \"/app\" || pathname === \"/\")) {\n return new Response(CAPTURE_HTML, {\n headers: { \"Content-Type\": \"text/html; charset=utf-8\" },\n });\n }\n if (req.method === \"GET\" && pathname === \"/reps\") {\n return new Response(REPS_HTML, {\n headers: { \"Content-Type\": \"text/html; charset=utf-8\" },\n });\n }\n if (req.method === \"GET\" && (pathname === \"/icon.png\" || pathname === \"/icon-reps.png\")) {\n const b64 = pathname === \"/icon.png\" ? ICON_PNG_B64 : ICON_REPS_PNG_B64;\n return new Response(Uint8Array.from(atob(b64), (c) => c.charCodeAt(0)), {\n headers: { \"Content-Type\": \"image/png\", \"Cache-Control\": \"public, max-age=86400\" },\n });\n }\n if (req.method === \"GET\" && pathname === \"/health\") {\n return json({ ok: true, service: \"knowing-doing worker\" });\n }\n // Signed share-sheet Shortcut. Key-gated via query param because the file\n // embeds the capture secret and this val is public.\n if (req.method === \"GET\" && pathname === \"/shortcut\") {\n const key = new URL(req.url).searchParams.get(\"key\") ?? \"\";\n if (!key || !safeEqual(key, env(\"CAPTURE_SECRET\"))) return json({ error: \"unauthorized\" }, 401);\n return new Response(Uint8Array.from(atob(SHORTCUT_B64), (c) => c.charCodeAt(0)), {\n headers: {\n \"Content-Type\": \"application/octet-stream\",\n \"Content-Disposition\": 'attachment; filename=\"Capture Learning.shortcut\"',\n },\n });\n }\n\n // --- Reps app API (token stays server-side; gated by the capture secret) ---\n if (req.method === \"GET\" && pathname === \"/focus\") {\n if (!authorized(req)) return json({ error: \"unauthorized\" }, 401);\n const active = await queryActive();\n const next = active ? null : await queryNextPracticeable();\n return json({ active, next });\n }\n if (req.method === \"POST\" && (pathname === \"/rep\" || pathname === \"/retire\")) {\n if (!authorized(req)) return json({ error: \"unauthorized\" }, 401);\n const body = await req.json().catch(() => ({}));\n if (!body.page_id || typeof body.count !== \"number\") {\n return json({ error: \"page_id and count required\" }, 400);\n }\n const properties: Record = { \"Rep Count\": { number: body.count } };\n if (pathname === \"/retire\") {\n properties[\"Status\"] = { select: { name: \"Internalized\" } };\n }\n await notion(\"PATCH\", `/pages/${body.page_id}`, { properties });\n return json({ ok: true });\n }\n if (req.method === \"POST\" && pathname === \"/promote\") {\n if (!authorized(req)) return json({ error: \"unauthorized\" }, 401);\n const body = await req.json().catch(() => ({}));\n if (!body.page_id || !body.if_then) return json({ error: \"page_id and if_then required\" }, 400);\n // Exactly one Active at a time, enforced server-side.\n const active = await queryActive();\n if (active && active.id !== body.page_id) {\n return json({ error: \"active-exists\", active }, 409);\n }\n await notion(\"PATCH\", `/pages/${body.page_id}`, {\n properties: {\n \"If-Then\": { rich_text: [{ text: { content: String(body.if_then).slice(0, 2000) } }] },\n \"Status\": { select: { name: \"Active\" } },\n },\n });\n return json({ ok: true });\n }\n return json({ error: \"not found\" }, 404);\n } catch (err) {\n console.error(`${req.method} ${pathname} failed:`, err);\n return json({ error: String(err) }, 500);\n }\n}\n",[75],"6477200c-88c5-4d81-b8a7-22b265d8bc08",["D",1781282853144],"// 180x180 apple-touch-icon, generated by scripts (amber dot on #0B0B0E).\nexport const ICON_PNG_B64 =\n \"iVBORw0KGgoAAAANSUhEUgAAALQAAAC0CAIAAACyr5FlAAAJIElEQVR42u2dT2hUWRaHs2863cZOZ+zYsWJbgVSMdKIxMamkk0o0amIyJiOipKURF1FEBcV/BKUb6RhxEwVxUBcSiOJExmDTCxeB4FbcuJBxMRsXsxA3gzBIM3R/UkNG7Bg1XVTuq/rgt6g/7957zqnv3Xfuffe+Kvjoo0KlZlWBIVDCoYRDCYcSDiUcSjiUcCjhUMKhhEMp4VDCoYRDCYcSDiUcSjiUcCjhUMKhlHAo4VDCoYRDCYcSDiUcSjiUcCjhUEo4lHAo4VDCoYRDCYcSDiUcSjiUcCjhUEo4Cj/+pOxPi6vKSxoSpamasq76WF9y+fbWFTtT8YH2V+IFb/mQrziAwziYIhQUjtwEIv5l8bqq0u6G8l0dFQd6E0M7Vp3dXXtxb93Vg/VjRxpvHm+aOJm8PdSMeMFbPuQrDuAwDqYIBSlOJVSVJ6AU5DYTiVhJR20Z/cHh/pX8zPze/PxTw20PRtf/46+bnl7vfn6j98XE1pd3+v57t//Xn/6CeMFbPuQrDuAwDqYIBSlOJVRFhVRL5blNSW7CwVWguXopF4ij26pHB9fcOpGcHkk9vrzx2XjPDAQfKgpSnEqoigqplsppgoZoTjgiIPr8zrplg92VnOLjx5run2v/57Wu//y9b35AvE1USLVUThM0RHM0StPCEai+Wlq8aW2M5IBz+u7plkeXOv/9tz9nlonfiyZoiOZolKYxADOEIyAt+ayIYcW+LZX8Qj//8M2TK5vnfe2Y9xWHRmkaAzADYzBJOBZetRVLGEfQt0+eaiF5zCYTvxcGYAbGYBKGCceC6YvPi+jGyQoZdj68sCHjicW80xGMwSQMwzyMFI5sq6q8hPHk+T2r751p/dfYlhCweF2YhGGYh5GYKhzZ07qq0v09iWuHGjhHs5xefFAignkYiakYLBzZmNfqqC07vr164mSSwWSYWLwujMRUDMbsyM2YRQmOxYs+7aqPff/t14wLno33hE9GWpiKwZiN8bggHJlXcdGinsbyH7+rmRpuezGxNSpkpIXBmI3xuIAjwpHhPoOwMkScHkm9vNMXLTLSwmyMxwUciUr/URCJPIMOmdOO4P4y2R9FMtLCeFzAEdyJRP4RAThI5bhg0y1HtM94o//AEdzBKeHIwKiVVJ+ELnJ5xhz5B+7gVPjj24LAZ7r29yQYCkZobPKe4xecwrXA58fCheOLz4sG2uPXDjVEYj5jHvMfuIaDIc+vhwvHprWx83tWP7ywIffISAvXcBA3heOD77Ue3VZ970xrsLPjGZlfx0HcDPb+bYhwLPmsaFdHxdiRxgDvqGX8/hxu4myY6z9ChCNVU3Z2d20OX1DeuLjgLC4Lx3ut9tu3pXLyVEsg6zOysP4DZ3E5wPWFBQHmoaODaxZ8TVeW14/hcoCZaVhwxL8sPtCb+PmHb/KHjLRwGcdDW78eFhyddcs4h55c2ZxvcOAyjuO+cLx1J9Jgd+Xd0y05PHydY1iL47gf1P6ogOBorl5K3v7oUme+kZEWjuM+QRCOWe7L70zFx481ZWEnUpjCcdwnCOHczQ8FjkSs5Oi26vvn2vOTjLRwnyAQCuF4c9EGGVlO3mP7oLtxBCGcpR4FgVxTBtrjt04k82Tia44JMYJAKAK5shQEMr1xuH/l9Egqn8lIiyAQikAmPIKAY11VKYn648sbhYMgEIpAFokFAUd3Q/nVg/U5ttxr3ovECAUBEY7/JRy7OipuDzXn4dzXrLNhhIKAhJB2FIQwMXqgNzE13CYZaREKAhLCVOnCw1FVXjK0Y9WD0fVikRahICAhrD1eeDgaEq+y0by6R//OO/gEhLAIx6t1Xxf31j293i0WaREKAhLC2rCFh6OrPkZ+/vxGr1ikRSgICGERjsK+5PKxI405s6EtI1viCAhhEY7C7a0rbh5vyoF9sBncT0tACItwFO5MxSdOJp3keH2qg4AQFuEoHGiP3x5qlonXRUAIi3AIh3B4WfGyYkJqQupQ1qGsk2BOgjl97vS5N9688eYte2/Zu9jHxT4uE3SZoAuMXWDsAmO3Jrg1wU1NbmpyO6TbId1I7UZqH8HgIxh8eIsPb/GxTz72yQfG+cA4HzXpoyZ9SK0PqRUOH2/t4619ML4Pxs/42jD/UkM4Zpd/xiMcc8m/8RKOd2Sm/gGgcMwu/zpUON6x9tg/HRaOuRaJ+XflwjHXUo/vv/16argtB/bT4gKO4E44izaiDUfhx5901cd+/K5meiT1y2SEBy8Yjws4gjvh3JePNhxo8aJPexrLz+6uJbgR7T8wG+NxAUdwJxJhjwYcqLhoEWHltKNbjlz+gcGYjfG4gCNRiXlk4Ej3H3TIXLBJ6CI0fsFUDMZsjI9KnxE9ONL5B6kcqT5DwUjMf2AkpmIwZkciz4gwHDPj2/09iWuHGh5e2BDs/DqGYR5GYmr4o9bcgSM9PzbQHj+/Z/W9M60B3p/DJAzDPIwMfKYrB+FIz69vWhs7uq167Egj52gg6z8wA2MwCcMwL+TZ8VyGY+b+7a6OCoaIk6daFnz9GAZgBsZgUrD3WvMIjvT6j1RN2b4tlaODaxgXPLmyOcuJCM3RKE1jAGZgTJjrM/IRjpn1hXTjB3oT/EJ3T7c8utSZhf1RNEFDNEejNI0BAa72E47/r1/vrFs22F1J3z5+rOn+uXYGkxlPR6iQaqmcJmiI5mg0tLXjwvHW/VHN1Ut3puJkhZzTt04kp0dSjy9vfDbeM+8rDgUpTiVURYVUS+U0QUNB7UQSjvedMUvESjpqyxhPHu5fySl+9WD97aHmqeG2B6PrSR6fXu9+fqP3xcTWl3f6ZqDhBW/5kK84gMM4mCIUpDiVUBUVUi2VR25eSzhmoYQ+f11VaXdDOeMIkoOhHav4mS/ureP3Zth583jTxMkkPz/iBW/5kK84gMM4mCIUpDiVUFVuM5FfcLwBCleBqvKShkQpw4qu+lhfcvn21hVcIOgPEC94y4d8xQEcxsEUyRMg8hoOJRxKOJRwKOFQwqGEQwmHEg4lHEoJhxIOJRxKOJRwKOFQwqGEQwmHEg6lhEMJhxIOJRxKOJRwKOFQwqGEQwmHEg6lhEMJhxIOJRxKOJRwKOFQwqGEQwmHUsKhhEP9Ef0GBB/Sv1vRJ9EAAAAASUVORK5CYII=\";\n\n// 180x180 icon for the Reps app (5 dots, 3 filled).\nexport const ICON_REPS_PNG_B64 =\n \"iVBORw0KGgoAAAANSUhEUgAAALQAAAC0CAIAAACyr5FlAAACtElEQVR42u3aPy8DYQDHcbvEapCIRGogBolE0rBgkxDBxG5iYvIGjGaJidHGC/BKzHY7fkkTguLaesS1n+Qz9M9zz/Dc967X9oaGh0egrSFLgDgQB+JAHIgDcSAOxIE4EAeIA3EgDsSBOBAH4kAciANxgDgQB+JAHIgDcSAOxIE4EAeIA3EgDsSBOBAH4kAciANxIA4QB+JAHIgDcSAOxIE4EAfiAHEgDsSBOBAH4kAciANxIA4QB+JAHIgDcSAOxIE4EAfiQBwgDsSBOBAH4kAcDGgc0xOjy3PjW0uTuyuNyIM8zYuDObM43pY4y3q8M3u2P3951Lw+WYw8yNO8mLe6Xu46ztyytzrVVu+rXW7m34+jOTN2sDF9frhwd7p8f7H2eL35dLMdeZCneTFvZUCGDcLM3+y83ndkuZmLxJHly3GWYy5r+ny73VbeyoAM62it6zhzxf3X3V4sN3OROHLizeGVRXy4Wv9qlVsyIMMyuOK5uo4zd7T/Ot2L5WYuFUc+mHP6/eb4+3AsZnA26deZP+/CLgb8/cxF4sjxlLNuPp6rrHJLBmeTHw/EOs5cffd0sRfLzVwqjnzly4V9xUPw9UDMJtmw/2b+sG9+a2TpmUvFkZNtvvjl8r76QmdwNvnxLF3HmcXxzu5KI9dr+fpXfaEzOJtkw/6bWRziEIePFR8rLkhdkPoq66usH8H8CPavfiH187mfz/3x5o83f9n7y97NPm72cZug2wTdYIw4EAfiQByIA3EgDhAH4kAciANxIA7EgTgQB+JAHCAOxIE4EAfiQByIA3EgDsQB4kAciANxIA7EgTgQB+JAHCAOxIE4EAfiQByIA3EgDsSBOEAciANxIA7EgTgQB+JAHIgDxIE4EAfiQByIA3EgDsSBOEAciANxIA7EgTgQB+JAHIiDAfcCKYNo6QQbwTYAAAAASUVORK5CYII=\";\n",[141],"b72f7ac5-3f6d-4b35-a37d-7de97b0e5d7f",["D",1781285466898],"// Claude classification: practiceable-or-not, tags, and 3 candidate if-thens.\nimport Anthropic from \"npm:@anthropic-ai/sdk@0.104.1\";\nimport { env, PermanentError } from \"./notion.ts\";\n\nexport interface Classification {\n practiceable: boolean;\n reasoning: string;\n tags: string[];\n candidate_if_thens: string[];\n}\n\nconst SCHEMA = {\n type: \"object\",\n properties: {\n practiceable: { type: \"boolean\" },\n reasoning: { type: \"string\" },\n tags: { type: \"array\", items: { type: \"string\" } },\n candidate_if_thens: { type: \"array\", items: { type: \"string\" } },\n },\n required: [\"practiceable\", \"reasoning\", \"tags\", \"candidate_if_thens\"],\n additionalProperties: false,\n} as const;\n\nfunction contexts(): string[] {\n try {\n const parsed = JSON.parse(env(\"CONTEXTS\"));\n if (Array.isArray(parsed) && parsed.length) return parsed;\n } catch (_) { /* fall through */ }\n throw new Error(\"CONTEXTS env var must be a JSON array of strings\");\n}\n\nconst systemPrompt = () => `You classify entries from a personal learning log and, when an entry is practiceable, draft implementation intentions (Gollwitzer if-then plans).\n\nThe log owner is ${Deno.env.get(\"PERSONA\") ?? \"a busy professional\"}. Her recurring daily contexts — the cues her if-then plans must anchor to whenever plausible:\n${contexts().map((c) => `- ${c}`).join(\"\\n\")}\n\n## Practiceable or not\nAn entry is PRACTICEABLE only if it implies a small behavior she could deliberately perform repeatedly, triggered by a recurring cue in her life. Not practiceable: facts, frames/mental models with no action, quotes she liked, open questions, observations, and one-time tasks or purchases (setting up a bin once is a todo, not practice). An entry that is only a URL or link reference with no learning stated in her own words is NOT practiceable — never infer a behavior from a link slug or title alone.\n\n## Tags\nPick 1-3 tags from the provided list that fit the entry. Use them EXACTLY as written — never invent, merge, or re-case tags. If nothing fits well, return an empty tags array.\n\n## Candidate if-thens (only when practiceable)\nDraft exactly 3, each a single sentence of the form \"When → I \".\n- Cues must be concrete, recurring moments — prefer her real contexts above; a cue native to the learning's domain is fine when it fits better.\n- The action must be completable in under two minutes and be a direct enactment of the learning, not a reminder to think about it.\n- The 3 candidates must use 3 distinct cues, so she has a genuine choice.\nWhen not practiceable, return an empty candidate_if_thens array.\n\nBe honest in reasoning (1-2 sentences). Err toward NOT practiceable when the entry is a frame or insight without a repeatable behavior.`;\n\nexport async function classify(\n title: string,\n note: string | undefined,\n tagOptions: string[],\n): Promise {\n const client = new Anthropic({ apiKey: env(\"ANTHROPIC_API_KEY\") });\n const response = await client.messages.create({\n model: \"claude-sonnet-4-6\",\n // Generous budget so truncation can never void the structured-output\n // validity guarantee. Thinking stays off: classification + three short\n // sentences doesn't need it, and webhook deliveries must finish before\n // Notion's delivery timeout.\n max_tokens: 8000,\n thinking: { type: \"disabled\" },\n output_config: {\n effort: \"low\",\n format: { type: \"json_schema\", schema: SCHEMA },\n },\n system: systemPrompt(),\n messages: [{\n role: \"user\",\n content: `Available tags:\\n${tagOptions.join(\", \")}\\n\\nLearning entry: \"${title}\"${note ? `\\n\\nHer note on capture: \"${note}\"` : \"\"}`,\n }],\n });\n\n // Structured output is only guaranteed valid JSON on a clean finish.\n // Truncation/refusal would fail identically on every retry — permanent.\n if (response.stop_reason !== \"end_turn\") {\n throw new PermanentError(`Classification stopped early: ${response.stop_reason}`);\n }\n const text = response.content.find((b: { type: string }) => b.type === \"text\") as\n | { type: \"text\"; text: string }\n | undefined;\n if (!text) throw new PermanentError(\"No text block in Claude response\");\n\n let parsed: Classification;\n try {\n parsed = JSON.parse(text.text);\n } catch (_) {\n const match = text.text.match(/\\{[\\s\\S]*\\}/);\n if (!match) throw new PermanentError(`Unparseable classification: ${text.text.slice(0, 200)}`);\n parsed = JSON.parse(match[0]);\n }\n\n // Defensive normalization: tags constrained to real options, if-thens to 3.\n // json_schema can't enforce array lengths, so degrade gracefully instead of\n // throwing on a delivery path: fewer than 3 candidates is still useful; zero\n // candidates means it wasn't really practiceable.\n const valid = new Set(tagOptions);\n parsed.tags = (parsed.tags ?? []).filter((t) => valid.has(t)).slice(0, 3);\n parsed.candidate_if_thens = parsed.practiceable\n ? (parsed.candidate_if_thens ?? []).filter((c) => c?.trim()).slice(0, 3)\n : [];\n if (parsed.practiceable && parsed.candidate_if_thens.length === 0) {\n parsed.practiceable = false;\n }\n return parsed;\n}\n",[100],"b1acca21-db16-413a-acc0-758f94a36975",["D",1781282852722],"// The capture \"app\": a single dark-mode page served by this worker, installed\n// to the iPhone home screen via Safari's Add to Home Screen (standalone, no\n// browser chrome). No secrets in this file — the capture secret is entered\n// once on-device and kept in localStorage.\nexport const CAPTURE_HTML = `\n\n\n\n\n\n\n\n\n\nCapture\n\n\n\n

Capture learning

\n\n\n

\n Capture secret (asked once, stored on this device)\n \n

\n \n \n

\n Reps →\n

\n\n\n`;\n",[132],"pulls","branches","forks","envVars",{"_338":119,"_340":20},"connections",{"_338":20,"_339":20},"count","unfilledCount","emptyCount",{"_44":327,"_13":132,"_73":131,"_54":-5,"_46":47,"_296":158,"_297":282,"_48":371,"_50":51,"_76":91,"_299":329,"_78":24,"_301":-5,"_350":372,"_264":373},{"_44":323,"_13":100,"_73":99,"_54":-5,"_46":47,"_296":211,"_297":282,"_48":368,"_50":84,"_76":91,"_299":325,"_78":24,"_301":-5,"_350":369,"_264":370},{"_44":319,"_13":141,"_73":140,"_54":-5,"_46":47,"_296":174,"_297":282,"_48":365,"_50":51,"_76":91,"_299":321,"_78":24,"_301":-5,"_350":366,"_264":367},{"_44":315,"_13":75,"_73":74,"_54":-5,"_46":47,"_296":204,"_297":282,"_48":362,"_50":112,"_76":77,"_299":317,"_78":24,"_301":-5,"_350":363,"_264":364},{"_44":311,"_13":90,"_73":89,"_54":-5,"_46":47,"_296":151,"_297":282,"_48":359,"_50":51,"_76":91,"_299":313,"_78":24,"_301":-5,"_350":360,"_264":361},{"_44":307,"_13":109,"_73":108,"_54":-5,"_46":47,"_296":103,"_297":282,"_48":356,"_50":20,"_76":91,"_299":309,"_78":24,"_301":-5,"_350":357,"_264":358},{"_44":303,"_13":171,"_73":170,"_54":-5,"_46":47,"_296":165,"_297":282,"_48":353,"_50":20,"_76":91,"_299":305,"_78":24,"_301":-5,"_350":354,"_264":355},{"_44":295,"_13":201,"_73":200,"_54":-5,"_46":47,"_296":195,"_297":282,"_48":349,"_50":20,"_76":91,"_299":300,"_78":24,"_301":-5,"_350":351,"_264":352},["D",1781284610132],"children",[],[201],["D",1781282852904],[],[171],["D",1781281212333],[],[109],["D",1781282852085],[],[90],["D",1781285466538],[],[75],["D",1781282853144],[],[141],["D",1781285466898],[],[100],["D",1781282852722],[],[132],["D",1781281211245],{"_11":12,"_263":81},{"_11":12,"_258":259,"_80":81,"_25":79,"_260":261,"_262":24},{"_50":211,"_13":16,"_44":47,"_250":216,"_251":-5,"_252":-5,"_253":-5,"_254":-5,"_255":-5,"_256":14,"_257":12},"ctx",{"_62":-5,"_284":411,"_412":413,"_414":415,"_416":24,"_417":24,"_418":24,"_419":282,"_420":-5,"_421":-7,"_422":-7,"_423":20,"_424":24,"_425":24,"_426":-5,"_427":24,"_428":24,"_429":24,"_430":-5},"ENV",{"_382":383,"_384":385,"_386":16,"_387":388,"_389":390,"_391":392,"_393":394,"_395":396,"_397":398,"_399":400,"_401":402,"_403":404,"_405":406,"_407":408,"_409":410},"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"]

History