[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_177":178,"_179":180},"routes/_app.x.$handle.$name",{"_93":92,"_31":43,"_102":83,"_26":103,"_13":14,"_104":-5,"_11":105,"_106":107,"_108":109,"_110":111,"_112":113,"_20":-5,"_114":-5,"_115":-5,"_116":24,"_117":118,"_119":120,"_121":-5,"_122":-5,"_123":124},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_41":42,"_31":43,"_36":44,"_45":-5,"_46":24,"_47":48,"_49":48,"_50":51,"_52":-5,"_18":53,"_54":-5,"_55":24,"_56":-5,"_57":-5,"_58":59,"_60":61,"_62":-5,"_63":-5,"_64":-5,"_65":-5,"_66":67,"_68":67,"_69":70,"_71":70,"_72":70,"_73":67,"_74":67,"_75":76,"_77":78,"_79":80,"_81":24},"version",3,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":-7,"_23":24,"_25":24,"_26":27,"_28":27},"file",{"_29":30,"_31":27,"_32":33,"_34":35,"_36":37,"_38":14,"_39":40,"_23":24},"previous","deleted",false,"deletedHere","path","classify.ts","latestPath","fileId","967122fc-667a-11f1-ad2a-1607ee4eb77e","name","fileType","script","content","// 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).\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 // Budget covers adaptive-thinking tokens AND the JSON output — truncation\n // would void the structured-output validity guarantee.\n max_tokens: 8000,\n thinking: { type: \"adaptive\" },\n output_config: {\n effort: \"medium\",\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","createdAt",["D",1781281212113],"branchVersion","branchId","2ef12ec3-3faf-4129-9c8b-f3ea5c93fbdd","id","50f9916c-793c-48cd-b705-41c0662a7715","knowing-doing",["D",1781281211245],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Knowing-doing gap classifier","imageUrl","4a2b72b2-2629-4189-98f7-d68aeb110ce5","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019ebc7e-05e6-76fa-ba38-91edd3ec3708","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_93":92,"_101":97},"org",{"_93":92,"_94":95,"_96":97,"_18":53,"_98":99,"_100":24},"branch",{"_13":82,"_31":83,"_41":40,"_84":42,"_85":-5,"_86":-5,"_87":-5,"_88":-5,"_89":-5,"_90":43,"_91":92},"isOwned",18,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","michellewalstra","handle","displayName","Michelle Walstra","avatar","https://lh3.googleusercontent.com/a/ACg8ocLOkcWLlsTGuTIohITFtm3V9V5XfTVmyzGxjJBLxzJJAHe6MkON6w=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_41":42,"_31":43,"_36":173,"_45":-5,"_46":24,"_47":48,"_49":48,"_50":51,"_52":-5,"_18":53,"_54":-5,"_55":24,"_56":-5,"_57":-5,"_58":59,"_60":61,"_62":-5,"_63":-5,"_64":-5,"_65":-5,"_66":67,"_68":67,"_69":70,"_71":70,"_72":70,"_73":67,"_74":67,"_75":174,"_77":175,"_79":176,"_81":24},"tree",[160,161,162],"files",[160,161,162],"counts",{"_149":59,"_150":141,"_151":59,"_152":153,"_154":155},"contents",[125,126,127],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_41":146,"_31":27,"_29":30,"_131":-5,"_39":40,"_38":14,"_133":24,"_36":147,"_13":59,"_32":33,"_34":35,"_23":24,"_136":-5,"_26":148},{"_41":138,"_31":139,"_29":140,"_131":-5,"_39":40,"_38":141,"_133":24,"_36":142,"_13":59,"_32":143,"_34":144,"_23":24,"_136":-5,"_26":145},{"_41":128,"_31":129,"_29":130,"_131":-5,"_39":40,"_38":132,"_133":24,"_36":134,"_13":59,"_32":33,"_34":135,"_23":24,"_136":-5,"_26":137},"567338fe-ad2e-4e01-b1d2-c3fc4e83c736","notion.ts","96554cc6-667a-11f1-8fc6-1607ee4eb77e","parentId",2,"latest",["D",1781281211929],"// 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\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","label",[129],"23e87d83-d6a3-4823-8013-a8e2f0f1fa81","main.ts","962e53a0-667a-11f1-a5e9-1607ee4eb77e",1,["D",1781281211649],"http","// 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 { createLearningPage, env, isPermanent } from \"./notion.ts\";\nimport { processPage } from \"./process.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.\n if (!stored?.token) return json({ error: \"webhook not verified yet\" }, 503);\n const sig = (req.headers.get(\"X-Notion-Signature\") ?? \"\").replace(/^sha256=/, \"\");\n const expected = await hmacHex(stored.token, raw);\n if (!safeEqual(sig, expected)) return json({ error: \"bad signature\" }, 401);\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 const text = (body.text ?? \"\").toString().trim();\n if (!text) return json({ error: \"text required\" }, 400);\n const note = (body.note ?? \"\").toString().trim() || undefined;\n const url = (body.url ?? \"\").toString().trim() || undefined;\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 === \"/\") {\n return json({ ok: true, service: \"knowing-doing worker\" });\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",[139],"8d662944-44d7-4642-983b-b96760564520",["D",1781281212113],[27],"pulls","branches","forks","envVars",{"_156":158,"_159":59},"connections",{"_156":59,"_157":59},"count","unfilledCount",6,"emptyCount",{"_41":146,"_31":27,"_29":30,"_131":-5,"_39":40,"_38":14,"_133":24,"_36":170,"_13":59,"_32":33,"_34":35,"_23":24,"_136":-5,"_164":171,"_26":172},{"_41":138,"_31":139,"_29":140,"_131":-5,"_39":40,"_38":141,"_133":24,"_36":167,"_13":59,"_32":143,"_34":144,"_23":24,"_136":-5,"_164":168,"_26":169},{"_41":128,"_31":129,"_29":130,"_131":-5,"_39":40,"_38":132,"_133":24,"_36":163,"_13":59,"_32":33,"_34":135,"_23":24,"_136":-5,"_164":165,"_26":166},["D",1781281211929],"children",[],[129],["D",1781281211649],[],[139],["D",1781281212113],[],[27],["D",1781281211245],{"_93":92,"_101":97},{"_93":92,"_94":95,"_96":97,"_18":53,"_98":99,"_100":24},{"_13":82,"_31":83,"_41":40,"_84":42,"_85":-5,"_86":-5,"_87":-5,"_88":-5,"_89":-5,"_90":43,"_91":92},"ctx",{"_75":-5,"_122":210,"_211":212,"_213":214,"_215":24,"_216":24,"_217":24,"_218":120,"_219":-5,"_220":-7,"_221":-7,"_222":59,"_223":24,"_224":24,"_225":-5,"_226":24,"_227":24,"_228":24,"_229":-5},"ENV",{"_181":182,"_183":184,"_185":83,"_186":187,"_188":189,"_190":191,"_192":193,"_194":195,"_196":197,"_198":199,"_200":201,"_202":203,"_204":205,"_206":207,"_208":209},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","fdb67791413f4386b4dbf18f354029a617f6160f","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 · v3