[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_165":166,"_167":168},"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",2,"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","notion.ts","latestPath","fileId","96554cc6-667a-11f1-8fc6-1607ee4eb77e","name","fileType","script","content","// 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","createdAt",["D",1781281211929],"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":161,"_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":162,"_77":163,"_79":164,"_81":24},"tree",[152,153],"files",[152,153],"counts",{"_141":59,"_142":136,"_143":59,"_144":145,"_146":147},"contents",[125,126],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_41":133,"_31":134,"_29":135,"_128":-5,"_39":40,"_38":136,"_129":24,"_36":137,"_13":59,"_32":138,"_34":139,"_23":24,"_131":-5,"_26":140},{"_41":127,"_31":27,"_29":30,"_128":-5,"_39":40,"_38":14,"_129":24,"_36":130,"_13":59,"_32":33,"_34":35,"_23":24,"_131":-5,"_26":132},"567338fe-ad2e-4e01-b1d2-c3fc4e83c736","parentId","latest",["D",1781281211929],"label",[27],"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",[134],"pulls","branches","forks","envVars",{"_148":150,"_151":59},"connections",{"_148":59,"_149":59},"count","unfilledCount",6,"emptyCount",{"_41":133,"_31":134,"_29":135,"_128":-5,"_39":40,"_38":136,"_129":24,"_36":158,"_13":59,"_32":138,"_34":139,"_23":24,"_131":-5,"_155":159,"_26":160},{"_41":127,"_31":27,"_29":30,"_128":-5,"_39":40,"_38":14,"_129":24,"_36":154,"_13":59,"_32":33,"_34":35,"_23":24,"_131":-5,"_155":156,"_26":157},["D",1781281211929],"children",[],[27],["D",1781281211649],[],[134],["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":198,"_199":200,"_201":202,"_203":24,"_204":24,"_205":24,"_206":120,"_207":-5,"_208":-7,"_209":-7,"_210":59,"_211":24,"_212":24,"_213":-5,"_214":24,"_215":24,"_216":24,"_217":-5},"ENV",{"_169":170,"_171":172,"_173":83,"_174":175,"_176":177,"_178":179,"_180":181,"_182":183,"_184":185,"_186":187,"_188":189,"_190":191,"_192":193,"_194":195,"_196":197},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","811aa22498c9b0b5a47e8d778de579cdb990f332","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 · v2