[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_309":310,"_311":312},"routes/_app.x.$handle.$name",{"_98":97,"_33":47,"_106":88,"_28":107,"_13":14,"_108":-5,"_11":109,"_110":111,"_112":113,"_114":115,"_116":117,"_20":-5,"_118":-5,"_119":-5,"_120":27,"_121":122,"_123":25,"_124":-5,"_125":-5,"_126":127},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_45":46,"_33":47,"_40":48,"_49":-5,"_50":27,"_51":52,"_53":52,"_54":55,"_56":-5,"_18":57,"_58":59,"_60":25,"_61":25,"_62":-5,"_63":64,"_65":66,"_67":-5,"_68":-5,"_69":-5,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":81,"_82":83,"_84":85,"_86":27},"version",236,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":27,"_28":29,"_30":29},"file",{"_31":32,"_33":34,"_35":36,"_37":39,"_40":41,"_42":14,"_43":44,"_24":27},"previous",{"_31":32,"_33":34,"_35":36,"_37":38},"deleted",true,"deletedHere",false,"path","attio/hydrate.ts","latestPath","fileId","9d5becae-786a-11f0-8396-0224a6c84d84","name","hydrate.ts","fileType","script","content","import { Attio } from \"npm:attio-js\";\n// import pLimit from \"npm:p-limit\";\nimport type { AttioWebhookEvent } from \"./webhook-payload-types.ts\";\nimport { SAMPLE_EVENTS } from \"./hydrate.test.ts\";\n\nconst attio = new Attio();\n\nexport async function hydrate(event: AttioWebhookEvent) {\n if (event.event_type === \"comment.created\") {\n const record = getRecordName(await getRecord(event));\n\n const comment = await safe(() =>\n attio.comments.get({\n commentId: event.id.comment_id,\n })\n );\n const commentText = comment.data.content_plaintext;\n const actor = await getActorName(event.actor);\n\n return `${actor} commented on ${record}: ${truncate(commentText, 200)}`;\n } else if (event.event_type === \"record.created\") {\n const record = getRecordName(await getRecord(event.id));\n const actor = await getActorName(event.actor);\n return `${actor} created ${record}`;\n } else if (event.event_type === \"record.updated\") {\n const record = await getRecord(event.id);\n const actor = await getActorName(event.actor);\n let attribute = await getAttribute({ ...event.id, target: \"objects\" });\n const attributeName = attribute.title;\n const attributeSlug = attribute.apiSlug;\n const value = record.data.values[attributeSlug];\n\n const value = \"TODO\";\n return `${actor} updated ${\n getRecordName(record)\n }'s ${attributeName} to ${value}`;\n } else {\n console.log(\"Attio event type not supported\", event);\n }\n}\n\nconst cache = {};\nasync function getRecord({ object_id, record_id }) {\n const key = `record-${object_id}-${record_id}`;\n cache[key] ??= await safe(() =>\n attio.records.get({\n object: object_id,\n recordId: record_id,\n })\n );\n return cache[key];\n}\n\nfunction getRecordName(record: any) {\n // company name\n let name = record.data.values.name[0]?.value;\n if (name) return name;\n\n // person name\n name = record.data.values.name[0]?.full_name;\n if (name) return name;\n\n // person email\n const email = record.data.values.email_addresses[0]?.email_address;\n if (email) return email;\n\n console.dir(record, { depth: null });\n return \"Unknown\";\n}\n\nasync function getAttribute({\n attribute_id,\n target,\n object_id,\n}) {\n const key = `attribute-${attribute_id}-${target}-${object_id}`;\n cache[key] ??= await attio.attributes.get({\n attribute: attribute_id,\n target: \"objects\",\n identifier: object_id,\n });\n return attribute;\n}\n\nasync function getActorName({ type, id }: { type: string; id: string }) {\n if (type === \"system\") return \"System\";\n if (type === \"workspace-member\") {\n const key = \"TODO\";\n cache[key] ??= await attio.workspaceMembers.get({\n workspaceMemberId: id,\n });\n return cache[key].data.firstName + \" \" + cache[key].data.lastName;\n } else return \"API Token\";\n}\n\nfunction truncate(s: string, maxChars: number): string {\n if (s.length <= maxChars) return s;\n return s.slice(0, maxChars - 3) + \"...\";\n}\nasync function safe(apiCall: () => Promise): Promise {\n try {\n return await apiCall();\n } catch (error: any) {\n if (error?.rawValue !== undefined) {\n // console.log(\"Zod error\", error.message);\n return error.rawValue;\n }\n throw error;\n }\n}\n\nconsole.log(await hydrate(SAMPLE_EVENTS[4]));\n// console.log(await Promise.all(SAMPLE_EVENTS.map((event) => hydrate(event))));","import { Attio } from \"npm:attio-js\";\n// import pLimit from \"npm:p-limit\";\nimport type { AttioWebhookEvent } from \"./webhook-payload-types.ts\";\nimport { SAMPLE_EVENTS } from \"./hydrate.test.ts\";\n\nconst attio = new Attio();\n\nexport async function hydrate(event: AttioWebhookEvent) {\n if (event.event_type === \"comment.created\") {\n const record = getRecordName(await getRecord(event));\n\n const comment = await safe(() =>\n attio.comments.get({\n commentId: event.id.comment_id,\n })\n );\n const commentText = comment.data.content_plaintext;\n const actor = await getActorName(event.actor);\n\n return `${actor} commented on ${record}: ${truncate(commentText, 200)}`;\n } else if (event.event_type === \"record.created\") {\n const record = getRecordName(await getRecord(event.id));\n const actor = await getActorName(event.actor);\n return `${actor} created ${record}`;\n } else if (event.event_type === \"record.updated\") {\n const record = await getRecord(event.id);\n const actor = await getActorName(event.actor);\n let attribute = await getAttribute({ ...event.id, target: \"objects\" });\n const attributeName = attribute.title;\n const attributeSlug = attribute.apiSlug;\n const value = record.data.values[attributeSlug];\n return `${actor} updated ${\n getRecordName(record)\n }'s ${attributeName} to ${value}`;\n } else {\n console.log(\"Attio event type not supported\", event);\n }\n}\n\nconst cache = {};\nasync function getRecord({ object_id, record_id }) {\n const key = `record-${object_id}-${record_id}`;\n cache[key] ??= await safe(() =>\n attio.records.get({\n object: object_id,\n recordId: record_id,\n })\n );\n return cache[key];\n}\n\nfunction getRecordName(record: any) {\n // company name\n let name = record.data.values.name[0]?.value;\n if (name) return name;\n\n // person name\n name = record.data.values.name[0]?.full_name;\n if (name) return name;\n\n // person email\n const email = record.data.values.email_addresses[0]?.email_address;\n if (email) return email;\n\n console.dir(record, { depth: null });\n return \"Unknown\";\n}\n\nasync function getAttribute({\n attribute_id,\n target,\n object_id,\n}) {\n const key = `attribute-${attribute_id}-${target}-${object_id}`;\n cache[key] ??= await attio.attributes.get({\n attribute: attribute_id,\n target: \"objects\",\n identifier: object_id,\n });\n return attribute;\n}\n\nasync function getActorName({ type, id }: { type: string; id: string }) {\n if (type === \"system\") return \"System\";\n if (type === \"workspace-member\") {\n const key = \"TODO\";\n cache[key] ??= await attio.workspaceMembers.get({\n workspaceMemberId: id,\n });\n return cache[key].data.firstName + \" \" + cache[key].data.lastName;\n } else return \"API Token\";\n}\n\nfunction truncate(s: string, maxChars: number): string {\n if (s.length <= maxChars) return s;\n return s.slice(0, maxChars - 3) + \"...\";\n}\nasync function safe(apiCall: () => Promise): Promise {\n try {\n return await apiCall();\n } catch (error: any) {\n if (error?.rawValue !== undefined) {\n // console.log(\"Zod error\", error.message);\n return error.rawValue;\n }\n throw error;\n }\n}\n\nconsole.log(await hydrate(SAMPLE_EVENTS[4]));\n// console.log(await Promise.all(SAMPLE_EVENTS.map((event) => hydrate(event))));","createdAt",["D",1755203423196],"branchVersion","branchId","dbdc0d5c-785a-11f0-814d-0224a6c84d84","id","dbd66352-785a-11f0-814d-0224a6c84d84","attio-slack-summaries",["D",1755099207883],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Get debounced summaries of updates from Attio in Slack","imageUrl","a0bf3b31-15a5-4d5c-880e-4b1e22c9bc18","pinnedFileId","0198a410-9925-735a-aaba-3c34a89d172d","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","e81e7335-6d4c-4764-a902-d0962bbfa9f7","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_98":97,"_105":101},"org",{"_98":97,"_99":-5,"_100":101,"_18":57,"_102":103,"_104":27},"branch",{"_13":87,"_33":88,"_45":44,"_89":46,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":47,"_96":97},"isOwned",340,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","stevekrouse","handle","displayName","avatar","https://images.clerk.dev/uploaded/img_2PqHa2Gsy93xQrjh2w78Xu0cChW.jpeg","tier","pro","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_45":46,"_33":47,"_40":305,"_49":-5,"_50":27,"_51":52,"_53":52,"_54":55,"_56":-5,"_18":57,"_58":59,"_60":25,"_61":25,"_62":-5,"_63":64,"_65":66,"_67":-5,"_68":-5,"_69":-5,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":306,"_82":307,"_84":308,"_86":27},"tree",[230,235,236,237,238,239,240,241,242,243],"files",[230,231,232,233,234,235,236,237,238,239,240,241,242,243],"counts",{"_220":64,"_221":162,"_222":185,"_223":224,"_225":226},"contents",[128,129,130,131,132,133,134,135,136,137],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_45":213,"_33":214,"_31":215,"_140":-5,"_43":44,"_42":216,"_142":27,"_40":217,"_13":162,"_35":218,"_37":-5,"_24":27,"_147":-5,"_28":219},{"_45":205,"_33":206,"_31":207,"_140":-5,"_43":44,"_42":208,"_142":27,"_40":209,"_13":210,"_35":20,"_37":211,"_24":27,"_147":-5,"_28":212},{"_45":196,"_33":197,"_31":198,"_140":-5,"_43":44,"_42":199,"_142":27,"_40":200,"_13":201,"_35":202,"_37":203,"_24":27,"_147":-5,"_28":204},{"_45":188,"_33":189,"_31":190,"_140":-5,"_43":44,"_42":191,"_142":27,"_40":192,"_13":193,"_35":36,"_37":194,"_24":27,"_147":-5,"_28":195},{"_45":180,"_33":181,"_31":182,"_140":-5,"_43":44,"_42":183,"_142":27,"_40":184,"_13":185,"_35":36,"_37":186,"_24":27,"_147":-5,"_28":187},{"_45":173,"_33":174,"_31":175,"_140":-5,"_43":44,"_42":176,"_142":27,"_40":177,"_13":170,"_35":36,"_37":178,"_24":27,"_147":-5,"_28":179},{"_45":165,"_33":166,"_31":167,"_140":-5,"_43":44,"_42":168,"_142":27,"_40":169,"_13":170,"_35":36,"_37":171,"_24":27,"_147":-5,"_28":172},{"_45":157,"_33":158,"_31":159,"_140":-5,"_43":44,"_42":160,"_142":27,"_40":161,"_13":162,"_35":36,"_37":163,"_24":27,"_147":-5,"_28":164},{"_45":149,"_33":150,"_31":151,"_140":-5,"_43":44,"_42":152,"_142":27,"_40":153,"_13":154,"_35":36,"_37":155,"_24":27,"_147":-5,"_28":156},{"_45":138,"_33":139,"_31":59,"_140":-5,"_43":44,"_42":141,"_142":27,"_40":143,"_13":144,"_35":145,"_37":146,"_24":27,"_147":-5,"_28":148},"f55754a6-787f-11f0-8f0c-0224a6c84d84","webhook.ts","parentId",136,"latest",["D",1755115142067],11,"http","import { Hono } from \"npm:hono\";\nimport { auth } from \"./auth.ts\";\nimport { insertAttioEvent } from \"./sqlite.ts\";\n\nconst app = new Hono();\n\napp.get(\"/\", (c) => c.text(\"Attio Slack Summaries: healthy\"));\n\napp.use(auth);\n\napp.post(\"/\", async (c) => {\n const data = await c.req.json();\n console.log(data);\n\n insertAttioEvent(data);\n\n return c.json(\"ok\");\n});\n\napp.onError((err: any) => Promise.reject(err));\nexport default app.fetch;","label",[139],"38a84aa8-792f-11f0-b568-0224a6c84d84","sqlite.ts","751f833a-785c-11f0-b80f-0224a6c84d84",155,["D",1755190416930],10,"import { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\n\nexport async function createTable() {\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS attio_events (\n id INTEGER PRIMARY KEY,\n timestamp INTEGER NOT NULL,\n data TEXT NOT NULL,\n alerted INTEGER DEFAULT 0\n )\n `);\n}\n\nexport async function insertAttioEvent(data: any) {\n const timestamp = Date.now();\n await sqlite.execute(\n `INSERT INTO attio_events (timestamp, data) VALUES (?, ?)`,\n [timestamp, JSON.stringify(data)],\n );\n}\n\nexport async function getRecentEvents() {\n const result = await sqlite.execute(\n `SELECT * \n FROM attio_events \n WHERE alerted = 0\n ORDER BY timestamp \n DESC`,\n );\n return result.rows;\n}\n\nexport async function markAsAlerted(ids: number[]) {\n await sqlite.execute(\n `UPDATE attio_events SET alerted = 1 WHERE id in (${ids.join(\",\")})`,\n );\n}",[150],"1bafd862-785d-11f0-a994-0224a6c84d84","slack.ts","0198a410-9925-735a-aaba-3788690b3b53",24,["D",1755100174017],1,"import { IncomingWebhook } from \"npm:@slack/webhook\";\n\nexport async function slack(text: string) {\n if (!Deno.env.get(\"SLACK_WEBHOOK_URL\")) {\n throw new Error(\"SLACK_WEBHOOK_URL is not set\");\n }\n const webhook = new IncomingWebhook(Deno.env.get(\"SLACK_WEBHOOK_URL\"));\n await webhook.send({ text });\n}",[158],"a72baa0a-792b-11f0-b7b6-0224a6c84d84","setup.ts","73c97e68-785d-11f0-a4da-0224a6c84d84",139,["D",1755188884355],9,"import { createWebhook } from \"./attio/webhook.ts\";\nimport { createTable } from \"./sqlite.ts\";\n\nawait createTable();\nawait createWebhook();",[166],"251a15c8-786e-11f0-9680-0224a6c84d84","scratch.ts","b2dc168c-7863-11f0-9442-0224a6c84d84",96,["D",1755107491258],"// import { attio } from \"./attio.ts\";\n\n// try {\n// console.log(\n// await attio.comments.get({\n// commentId: \"39d13462-a3e7-4322-a5e3-574099782c7d\",\n// }),\n// );\n// } catch (e) {\n// console.log(e.rawValue);\n// }",[174],"ec017a6c-785c-11f0-b4b6-0224a6c84d84","openai.ts","ccc6aeb0-785c-11f0-b30e-0224a6c84d84",23,["D",1755100094020],2,"// summarize",[181],"0a201ec2-7880-11f0-9a36-0224a6c84d84","auth.ts","b3413efc-785b-11f0-b94a-0224a6c84d84",138,["D",1755115176939],7,"import { getAttioWebhookSecret } from \"./attio/webhook.ts\";\n\nexport const auth = async (c, next) => {\n const webhookSignature = c.req.header(\"Attio-Signature\") ||\n c.req.header(\"X-Attio-Signature\");\n const webhookBody = await c.req.text();\n const webhookSecret = await getAttioWebhookSecret();\n\n if (!webhookSignature || !webhookSecret) {\n return c.json(\"Unauthorized: Missing signature or secret\", 401);\n }\n\n const encoder = new TextEncoder();\n const key = await crypto.subtle.importKey(\n \"raw\",\n encoder.encode(webhookSecret),\n { name: \"HMAC\", hash: \"SHA-256\" },\n false,\n [\"sign\"],\n );\n\n const signature = await crypto.subtle.sign(\n \"HMAC\",\n key,\n encoder.encode(webhookBody),\n );\n\n const expectedSignature = Array.from(new Uint8Array(signature))\n .map((b) => b.toString(16).padStart(2, \"0\"))\n .join(\"\");\n\n if (webhookSignature !== expectedSignature) {\n return c.json(\"Unauthorized: Invalid signature\", 401);\n }\n\n await next();\n};",[189],"37c013e6-792f-11f0-82bc-0224a6c84d84","alert.ts","77d6a72a-785c-11f0-aa8c-0224a6c84d84",154,["D",1755190415412],13,"interval","import { slack } from \"./slack.ts\";\nimport { getRecentEvents, markAsAlerted } from \"./sqlite.ts\";\nimport { summarizeEvents } from \"./attio/hydrate.ts\";\n\n// 30 minutes\nconst DEBOUNCE_TIME = 30 * 60 * 1000;\n\nexport default async function () {\n const recentEvents = await getRecentEvents();\n if (!recentEvents.length) {\n console.log(\"No recent events, exiting\");\n return;\n }\n if (recentEvents[0].time as number > Date.now() - DEBOUNCE_TIME) {\n console.log(\"Within debounce period, exiting\");\n return;\n }\n\n const events = recentEvents.flatMap(\n (e) => JSON.parse(e.data as string).events,\n );\n const hydrated = await summarizeEvents(events);\n const text = hydrated.map((text) => `- ${text}`).join(\"\\n\");\n\n console.log(text);\n // TODO ai summary?\n\n await slack(text);\n\n await markAsAlerted(recentEvents.map((e) => e.id as number));\n}",[197],"2f46115e-785b-11f0-96c1-0224a6c84d84","README.md","0198a410-9925-735a-aaba-2eb864dbe3ff",4,["D",1755099347880],3,"# Attio Slack Summaries\n\n## Files\n\n- [`slack.ts`](./slack.ts) - Send Slack notification\n- [`test.ts`](./test.ts) - Test script to simulate a notification\n- [`webhook.ts`](./webhook.ts) - Receives webhooks from attio\n\n## Set up\n\n1. Remix this val\n2. [Get a Slack webhook](https://docs.val.town/integrations/slack/send-messages-to-slack/#1-create-a-slack-app--webhook)\n & set it as `SLACK_WEBHOOK_URL` in this val's Environment variables in the\n left sidebar\n3. Copy the HTTP endpoint of [`webhook.ts`](./webhook.ts)\n4. [Create an Attio webhook](https://app.attio.com/val-town/settings/developers/webhooks)\n with that endpoint",[206],"b9f4c89c-786d-11f0-808c-0224a6c84d84","attio","b8c1c6f0-786d-11f0-a0c2-0224a6c84d84",83,["D",1755107311499],"directory",[214],"pulls","branches","forks","envVars",{"_227":185,"_229":64},"connections",{"_227":64,"_228":64},"count","unfilledCount","emptyCount",{"_45":213,"_33":214,"_31":215,"_140":-5,"_43":44,"_42":216,"_142":27,"_40":302,"_13":162,"_35":218,"_37":-5,"_24":27,"_147":-5,"_245":303,"_28":304},{"_45":294,"_33":295,"_31":296,"_140":215,"_43":44,"_42":297,"_142":27,"_40":298,"_13":144,"_35":36,"_37":299,"_24":27,"_147":-5,"_245":300,"_28":301},{"_45":289,"_33":34,"_31":32,"_140":215,"_43":44,"_42":14,"_142":27,"_40":290,"_13":291,"_35":36,"_37":39,"_24":27,"_147":-5,"_245":292,"_28":293},{"_45":280,"_33":281,"_31":282,"_140":215,"_43":44,"_42":283,"_142":27,"_40":284,"_13":285,"_35":36,"_37":286,"_24":27,"_147":-5,"_245":287,"_28":288},{"_45":272,"_33":139,"_31":273,"_140":215,"_43":44,"_42":274,"_142":27,"_40":275,"_13":276,"_35":36,"_37":277,"_24":27,"_147":-5,"_245":278,"_28":279},{"_45":205,"_33":206,"_31":207,"_140":-5,"_43":44,"_42":208,"_142":27,"_40":269,"_13":210,"_35":20,"_37":211,"_24":27,"_147":-5,"_245":270,"_28":271},{"_45":196,"_33":197,"_31":198,"_140":-5,"_43":44,"_42":199,"_142":27,"_40":266,"_13":201,"_35":202,"_37":203,"_24":27,"_147":-5,"_245":267,"_28":268},{"_45":188,"_33":189,"_31":190,"_140":-5,"_43":44,"_42":191,"_142":27,"_40":263,"_13":193,"_35":36,"_37":194,"_24":27,"_147":-5,"_245":264,"_28":265},{"_45":180,"_33":181,"_31":182,"_140":-5,"_43":44,"_42":183,"_142":27,"_40":260,"_13":185,"_35":36,"_37":186,"_24":27,"_147":-5,"_245":261,"_28":262},{"_45":173,"_33":174,"_31":175,"_140":-5,"_43":44,"_42":176,"_142":27,"_40":257,"_13":170,"_35":36,"_37":178,"_24":27,"_147":-5,"_245":258,"_28":259},{"_45":165,"_33":166,"_31":167,"_140":-5,"_43":44,"_42":168,"_142":27,"_40":254,"_13":170,"_35":36,"_37":171,"_24":27,"_147":-5,"_245":255,"_28":256},{"_45":157,"_33":158,"_31":159,"_140":-5,"_43":44,"_42":160,"_142":27,"_40":251,"_13":162,"_35":36,"_37":163,"_24":27,"_147":-5,"_245":252,"_28":253},{"_45":149,"_33":150,"_31":151,"_140":-5,"_43":44,"_42":152,"_142":27,"_40":248,"_13":154,"_35":36,"_37":155,"_24":27,"_147":-5,"_245":249,"_28":250},{"_45":138,"_33":139,"_31":59,"_140":-5,"_43":44,"_42":141,"_142":27,"_40":244,"_13":144,"_35":145,"_37":146,"_24":27,"_147":-5,"_245":246,"_28":247},["D",1755115142067],"children",[],[139],["D",1755190416930],[],[150],["D",1755100174017],[],[158],["D",1755188884355],[],[166],["D",1755107491258],[],[174],["D",1755100094020],[],[181],["D",1755115176939],[],[189],["D",1755190415412],[],[197],["D",1755099347880],[],[206],"c69418a0-792b-11f0-9a18-0224a6c84d84","c725650c-785f-11f0-b725-0224a6c84d84",140,["D",1755188937050],28,"import { Attio } from \"npm:attio-js\";\nimport { PostV2WebhooksEventTypeRequest } from \"npm:attio-js//models/operations/postv2webhooks\";\nimport { blob } from \"https://esm.town/v/std/blob\";\nimport { httpEndpoint } from \"https://esm.town/v/std/utils/index.ts\";\n\nconst attio = new Attio();\n\nconst ATTIO_WEBHOOK_KEY = \"ATTIO_WEBHOOK\";\n\nexport async function getAttioWebhookSecret() {\n const webhook = await blob.getJSON(ATTIO_WEBHOOK_KEY) as any;\n return webhook.data.secret;\n}\n\nconst ALL_SUBSCRIPTIONS = Object.values(PostV2WebhooksEventTypeRequest)\n .map((eventType) => ({\n eventType,\n filter: null,\n }));\n\nexport async function createWebhook() {\n const result = await attio.webhooks.create({\n data: {\n targetUrl: await httpEndpoint(\"webhook.ts\"),\n subscriptions: ALL_SUBSCRIPTIONS,\n },\n });\n console.log(\"Created attio webhook\", result);\n await blob.setJSON(ATTIO_WEBHOOK_KEY, result);\n}",[],[214,139],"8f65bdba-7940-11f0-b4ce-0224a6c84d84","webhook-payload-types.ts","d5a47416-786d-11f0-8eba-0224a6c84d84",192,["D",1755197863902],5,"/**\n * Complete TypeScript types for all Attio webhook events\n * Based on Attio V2 Webhooks API\n */\n\n// ============================================================================\n// Base Types\n// ============================================================================\n\n/**\n * Actor type for webhook events\n */\nexport interface WebhookActor {\n type: \"workspace-member\" | \"api-token\" | \"system\";\n id: string;\n}\n\n/**\n * Base webhook event structure that all events extend\n */\nexport interface BaseWebhookEvent {\n event_type: string;\n id: {\n workspace_id: string;\n [key: string]: string;\n };\n actor?: WebhookActor;\n}\n\n// ============================================================================\n// Comment Events\n// ============================================================================\n\n/**\n * Comment created event\n */\nexport interface CommentCreatedEvent extends BaseWebhookEvent {\n event_type: \"comment.created\";\n id: {\n workspace_id: string;\n comment_id: string;\n };\n thread_id?: string;\n object_id?: string;\n record_id?: string;\n list_id?: string;\n entry_id?: string;\n}\n\n/**\n * Comment resolved event\n */\nexport interface CommentResolvedEvent extends BaseWebhookEvent {\n event_type: \"comment.resolved\";\n id: {\n workspace_id: string;\n comment_id: string;\n };\n thread_id?: string;\n object_id?: string;\n record_id?: string;\n list_id?: string;\n entry_id?: string;\n}\n\n/**\n * Comment unresolved event\n */\nexport interface CommentUnresolvedEvent extends BaseWebhookEvent {\n event_type: \"comment.unresolved\";\n id: {\n workspace_id: string;\n comment_id: string;\n };\n thread_id?: string;\n object_id?: string;\n record_id?: string;\n list_id?: string;\n entry_id?: string;\n}\n\n/**\n * Comment deleted event\n */\nexport interface CommentDeletedEvent extends BaseWebhookEvent {\n event_type: \"comment.deleted\";\n id: {\n workspace_id: string;\n comment_id: string;\n };\n thread_id?: string;\n object_id?: string;\n record_id?: string;\n list_id?: string;\n entry_id?: string;\n}\n\n// ============================================================================\n// List Events\n// ============================================================================\n\n/**\n * List created event\n */\nexport interface ListCreatedEvent extends BaseWebhookEvent {\n event_type: \"list.created\";\n id: {\n workspace_id: string;\n list_id: string;\n };\n}\n\n/**\n * List updated event\n */\nexport interface ListUpdatedEvent extends BaseWebhookEvent {\n event_type: \"list.updated\";\n id: {\n workspace_id: string;\n list_id: string;\n };\n}\n\n/**\n * List deleted event\n */\nexport interface ListDeletedEvent extends BaseWebhookEvent {\n event_type: \"list.deleted\";\n id: {\n workspace_id: string;\n list_id: string;\n };\n}\n\n// ============================================================================\n// List Attribute Events\n// ============================================================================\n\n/**\n * List attribute created event\n */\nexport interface ListAttributeCreatedEvent extends BaseWebhookEvent {\n event_type: \"list-attribute.created\";\n id: {\n workspace_id: string;\n list_id: string;\n attribute_id: string;\n };\n}\n\n/**\n * List attribute updated event\n */\nexport interface ListAttributeUpdatedEvent extends BaseWebhookEvent {\n event_type: \"list-attribute.updated\";\n id: {\n workspace_id: string;\n list_id: string;\n attribute_id: string;\n };\n}\n\n// ============================================================================\n// List Entry Events\n// ============================================================================\n\n/**\n * List entry created event (when a record is added to a list)\n */\nexport interface ListEntryCreatedEvent extends BaseWebhookEvent {\n event_type: \"list-entry.created\";\n id: {\n workspace_id: string;\n list_id: string;\n entry_id: string;\n };\n parent_object_id: string;\n parent_record_id: string;\n}\n\n/**\n * List entry updated event\n */\nexport interface ListEntryUpdatedEvent extends BaseWebhookEvent {\n event_type: \"list-entry.updated\";\n id: {\n workspace_id: string;\n list_id: string;\n entry_id: string;\n };\n parent_object_id: string;\n parent_record_id: string;\n}\n\n/**\n * List entry deleted event (when a record is removed from a list)\n */\nexport interface ListEntryDeletedEvent extends BaseWebhookEvent {\n event_type: \"list-entry.deleted\";\n id: {\n workspace_id: string;\n list_id: string;\n entry_id: string;\n };\n parent_object_id: string;\n parent_record_id: string;\n}\n\n// ============================================================================\n// Object Attribute Events\n// ============================================================================\n\n/**\n * Object attribute created event\n */\nexport interface ObjectAttributeCreatedEvent extends BaseWebhookEvent {\n event_type: \"object-attribute.created\";\n id: {\n workspace_id: string;\n object_id: string;\n attribute_id: string;\n };\n}\n\n/**\n * Object attribute updated event\n */\nexport interface ObjectAttributeUpdatedEvent extends BaseWebhookEvent {\n event_type: \"object-attribute.updated\";\n id: {\n workspace_id: string;\n object_id: string;\n attribute_id: string;\n };\n}\n\n// ============================================================================\n// Note Events\n// ============================================================================\n\n/**\n * Note created event\n */\nexport interface NoteCreatedEvent extends BaseWebhookEvent {\n event_type: \"note.created\";\n id: {\n workspace_id: string;\n note_id: string;\n };\n parent_object_id: string;\n parent_record_id: string;\n}\n\n/**\n * Note updated event (title changes only, body updates don't trigger webhooks)\n */\nexport interface NoteUpdatedEvent extends BaseWebhookEvent {\n event_type: \"note.updated\";\n id: {\n workspace_id: string;\n note_id: string;\n };\n parent_object_id: string;\n parent_record_id: string;\n}\n\n/**\n * Note deleted event\n */\nexport interface NoteDeletedEvent extends BaseWebhookEvent {\n event_type: \"note.deleted\";\n id: {\n workspace_id: string;\n note_id: string;\n };\n parent_object_id: string;\n parent_record_id: string;\n}\n\n// ============================================================================\n// Note Content Events\n// ============================================================================\n\n/**\n * Note content updated event\n */\nexport interface NoteContentUpdatedEvent extends BaseWebhookEvent {\n event_type: \"note-content.updated\";\n id: {\n workspace_id: string;\n note_id: string;\n };\n parent_object_id: string;\n parent_record_id: string;\n}\n\n// ============================================================================\n// Record Events\n// ============================================================================\n\n/**\n * Record created event\n */\nexport interface RecordCreatedEvent extends BaseWebhookEvent {\n event_type: \"record.created\";\n id: {\n workspace_id: string;\n object_id: string;\n record_id: string;\n };\n}\n\n/**\n * Record merged event\n */\nexport interface RecordMergedEvent extends BaseWebhookEvent {\n event_type: \"record.merged\";\n id: {\n workspace_id: string;\n object_id: string;\n record_id: string; // The record that survived the merge\n };\n duplicate_object_id: string;\n duplicate_record_id: string; // The record that was deleted in the merge\n}\n\n/**\n * Record updated event\n */\nexport interface RecordUpdatedEvent extends BaseWebhookEvent {\n event_type: \"record.updated\";\n id: {\n workspace_id: string;\n object_id: string;\n record_id: string;\n };\n}\n\n/**\n * Record deleted event\n */\nexport interface RecordDeletedEvent extends BaseWebhookEvent {\n event_type: \"record.deleted\";\n id: {\n workspace_id: string;\n object_id: string;\n record_id: string;\n };\n}\n\n// ============================================================================\n// Task Events\n// ============================================================================\n\n/**\n * Task created event\n */\nexport interface TaskCreatedEvent extends BaseWebhookEvent {\n event_type: \"task.created\";\n id: {\n workspace_id: string;\n task_id: string;\n };\n}\n\n/**\n * Task updated event (e.g., assignees or deadline changed)\n */\nexport interface TaskUpdatedEvent extends BaseWebhookEvent {\n event_type: \"task.updated\";\n id: {\n workspace_id: string;\n task_id: string;\n };\n}\n\n/**\n * Task deleted event\n */\nexport interface TaskDeletedEvent extends BaseWebhookEvent {\n event_type: \"task.deleted\";\n id: {\n workspace_id: string;\n task_id: string;\n };\n}\n\n// ============================================================================\n// Workspace Member Events\n// ============================================================================\n\n/**\n * Workspace member created event\n */\nexport interface WorkspaceMemberCreatedEvent extends BaseWebhookEvent {\n event_type: \"workspace-member.created\";\n id: {\n workspace_id: string;\n member_id: string;\n };\n}\n\n// ============================================================================\n// Union Types for All Events\n// ============================================================================\n\n/**\n * Union type of all comment events\n */\nexport type CommentEvent =\n | CommentCreatedEvent\n | CommentResolvedEvent\n | CommentUnresolvedEvent\n | CommentDeletedEvent;\n\n/**\n * Union type of all list events\n */\nexport type ListEvent =\n | ListCreatedEvent\n | ListUpdatedEvent\n | ListDeletedEvent;\n\n/**\n * Union type of all list attribute events\n */\nexport type ListAttributeEvent =\n | ListAttributeCreatedEvent\n | ListAttributeUpdatedEvent;\n\n/**\n * Union type of all list entry events\n */\nexport type ListEntryEvent =\n | ListEntryCreatedEvent\n | ListEntryUpdatedEvent\n | ListEntryDeletedEvent;\n\n/**\n * Union type of all object attribute events\n */\nexport type ObjectAttributeEvent =\n | ObjectAttributeCreatedEvent\n | ObjectAttributeUpdatedEvent;\n\n/**\n * Union type of all note events\n */\nexport type NoteEvent =\n | NoteCreatedEvent\n | NoteUpdatedEvent\n | NoteDeletedEvent\n | NoteContentUpdatedEvent;\n\n/**\n * Union type of all record events\n */\nexport type RecordEvent =\n | RecordCreatedEvent\n | RecordMergedEvent\n | RecordUpdatedEvent\n | RecordDeletedEvent;\n\n/**\n * Union type of all task events\n */\nexport type TaskEvent =\n | TaskCreatedEvent\n | TaskUpdatedEvent\n | TaskDeletedEvent;\n\n/**\n * Union type of all workspace member events\n */\nexport type WorkspaceMemberEvent = WorkspaceMemberCreatedEvent;\n\n/**\n * Union type of ALL Attio webhook events\n */\nexport type AttioWebhookEvent =\n | CommentEvent\n | ListEvent\n | ListAttributeEvent\n | ListEntryEvent\n | ObjectAttributeEvent\n | NoteEvent\n | RecordEvent\n | TaskEvent\n | WorkspaceMemberEvent;\n\n// ============================================================================\n// Type Guards\n// ============================================================================\n\n/**\n * Type guard to check if an event is a comment event\n */\nexport function isCommentEvent(\n event: AttioWebhookEvent,\n): event is CommentEvent {\n return event.event_type.startsWith(\"comment.\");\n}\n\n/**\n * Type guard to check if an event is a list event\n */\nexport function isListEvent(event: AttioWebhookEvent): event is ListEvent {\n return event.event_type.startsWith(\"list.\") &&\n !event.event_type.startsWith(\"list-\");\n}\n\n/**\n * Type guard to check if an event is a list attribute event\n */\nexport function isListAttributeEvent(\n event: AttioWebhookEvent,\n): event is ListAttributeEvent {\n return event.event_type.startsWith(\"list-attribute.\");\n}\n\n/**\n * Type guard to check if an event is a list entry event\n */\nexport function isListEntryEvent(\n event: AttioWebhookEvent,\n): event is ListEntryEvent {\n return event.event_type.startsWith(\"list-entry.\");\n}\n\n/**\n * Type guard to check if an event is an object attribute event\n */\nexport function isObjectAttributeEvent(\n event: AttioWebhookEvent,\n): event is ObjectAttributeEvent {\n return event.event_type.startsWith(\"object-attribute.\");\n}\n\n/**\n * Type guard to check if an event is a note event\n */\nexport function isNoteEvent(event: AttioWebhookEvent): event is NoteEvent {\n return event.event_type.startsWith(\"note.\");\n}\n\n/**\n * Type guard to check if an event is a note content event\n */\nexport function isNoteContentEvent(\n event: AttioWebhookEvent,\n): event is NoteContentUpdatedEvent {\n return event.event_type === \"note-content.updated\";\n}\n\n/**\n * Type guard to check if an event is a record event\n */\nexport function isRecordEvent(event: AttioWebhookEvent): event is RecordEvent {\n return event.event_type.startsWith(\"record.\");\n}\n\n/**\n * Type guard to check if an event is a task event\n */\nexport function isTaskEvent(event: AttioWebhookEvent): event is TaskEvent {\n return event.event_type.startsWith(\"task.\");\n}\n\n/**\n * Type guard to check if an event is a workspace member event\n */\nexport function isWorkspaceMemberEvent(\n event: AttioWebhookEvent,\n): event is WorkspaceMemberEvent {\n return event.event_type.startsWith(\"workspace-member.\");\n}\n\n// ============================================================================\n// Event Type Enum\n// ============================================================================\n\n/**\n * Enum of all webhook event types for easy reference\n */\nexport enum EventType {\n // Comment events\n COMMENT_CREATED = \"comment.created\",\n COMMENT_RESOLVED = \"comment.resolved\",\n COMMENT_UNRESOLVED = \"comment.unresolved\",\n COMMENT_DELETED = \"comment.deleted\",\n\n // List events\n LIST_CREATED = \"list.created\",\n LIST_UPDATED = \"list.updated\",\n LIST_DELETED = \"list.deleted\",\n\n // List attribute events\n LIST_ATTRIBUTE_CREATED = \"list-attribute.created\",\n LIST_ATTRIBUTE_UPDATED = \"list-attribute.updated\",\n\n // List entry events\n LIST_ENTRY_CREATED = \"list-entry.created\",\n LIST_ENTRY_UPDATED = \"list-entry.updated\",\n LIST_ENTRY_DELETED = \"list-entry.deleted\",\n\n // Object attribute events\n OBJECT_ATTRIBUTE_CREATED = \"object-attribute.created\",\n OBJECT_ATTRIBUTE_UPDATED = \"object-attribute.updated\",\n\n // Note events\n NOTE_CREATED = \"note.created\",\n NOTE_UPDATED = \"note.updated\",\n NOTE_DELETED = \"note.deleted\",\n NOTE_CONTENT_UPDATED = \"note-content.updated\",\n\n // Record events\n RECORD_CREATED = \"record.created\",\n RECORD_MERGED = \"record.merged\",\n RECORD_UPDATED = \"record.updated\",\n RECORD_DELETED = \"record.deleted\",\n\n // Task events\n TASK_CREATED = \"task.created\",\n TASK_UPDATED = \"task.updated\",\n TASK_DELETED = \"task.deleted\",\n\n // Workspace member events\n WORKSPACE_MEMBER_CREATED = \"workspace-member.created\",\n}\n\n// ============================================================================\n// Webhook Handler Type\n// ============================================================================\n\n/**\n * Generic webhook handler function type\n */\nexport type WebhookHandler = (\n event: T,\n) => Promise | void;\n\n/**\n * Map of event types to their corresponding handler functions\n */\nexport type WebhookHandlerMap = {\n [K in AttioWebhookEvent[\"event_type\"]]?: WebhookHandler<\n Extract\n >;\n};\n\n// ============================================================================\n// Utility Types\n// ============================================================================\n\n/**\n * Extract event by type\n */\nexport type ExtractEventByType = Extract<\n AttioWebhookEvent,\n { event_type: T }\n>;\n\n/**\n * Get the payload type for a specific event type\n */\nexport type EventPayload = ExtractEventByType;",[],[214,281],"80fe836c-794d-11f0-8dfb-0224a6c84d84",["D",1755203423196],99,[],[214,34],"636456f4-7940-11f0-b5c5-0224a6c84d84","hydrate.test.ts","5129c7ac-7932-11f0-8ded-0224a6c84d84",190,["D",1755197790077],"import type { AttioWebhookEvent } from \"./webhook-payload-types.ts\";\n\nexport const SAMPLE_EVENTS: AttioWebhookEvent[] = [\n {\n \"event_type\": \"comment.created\",\n \"id\": {\n \"workspace_id\": \"b6c564a6-2cf7-49ab-9320-dea013196bd7\",\n \"comment_id\": \"39d13462-a3e7-4322-a5e3-574099782c7d\",\n },\n \"thread_id\": \"39d13462-a3e7-4322-a5e3-574099782c7d\",\n \"object_id\": \"0b257c77-68a4-47cd-b084-25bf830204db\",\n \"record_id\": \"0088d6df-4df9-47c0-b04c-9b724c5327ad\",\n \"actor\": {\n \"type\": \"workspace-member\",\n \"id\": \"7eedb52b-3b35-4073-a156-59af67f4d493\",\n },\n },\n {\n \"event_type\": \"record.created\",\n \"id\": {\n \"workspace_id\": \"b6c564a6-2cf7-49ab-9320-dea013196bd7\",\n \"object_id\": \"a87cf74e-5ca1-4a8d-b8d3-fcca5413d4c3\",\n \"record_id\": \"ed71e000-a0e3-4059-afbd-258a6697d5e4\",\n },\n \"actor\": {\n \"type\": \"system\",\n },\n },\n {\n \"event_type\": \"record.created\",\n \"id\": {\n \"workspace_id\": \"b6c564a6-2cf7-49ab-9320-dea013196bd7\",\n \"object_id\": \"a87cf74e-5ca1-4a8d-b8d3-fcca5413d4c3\",\n \"record_id\": \"4eb07e10-88c6-465e-bf73-29b516fa5786\",\n },\n \"actor\": {\n \"type\": \"system\",\n },\n },\n {\n \"event_type\": \"record.created\",\n \"id\": {\n \"workspace_id\": \"b6c564a6-2cf7-49ab-9320-dea013196bd7\",\n \"object_id\": \"a87cf74e-5ca1-4a8d-b8d3-fcca5413d4c3\",\n \"record_id\": \"ab8f92e0-528c-4bc9-863c-cb995b2cf798\",\n },\n \"actor\": {\n \"type\": \"system\",\n },\n },\n {\n \"event_type\": \"record.updated\",\n \"id\": {\n \"workspace_id\": \"b6c564a6-2cf7-49ab-9320-dea013196bd7\",\n \"object_id\": \"a87cf74e-5ca1-4a8d-b8d3-fcca5413d4c3\",\n \"record_id\": \"caf853a3-3c29-408b-81da-18e067b97bf7\",\n \"attribute_id\": \"b2fe0f6b-f1a6-4e80-86e6-8d8675adb71f\",\n },\n \"actor\": {\n \"type\": \"system\",\n },\n },\n {\n \"event_type\": \"record.updated\",\n \"id\": {\n \"workspace_id\": \"b6c564a6-2cf7-49ab-9320-dea013196bd7\",\n \"object_id\": \"a87cf74e-5ca1-4a8d-b8d3-fcca5413d4c3\",\n \"record_id\": \"caf853a3-3c29-408b-81da-18e067b97bf7\",\n \"attribute_id\": \"8ea79f1e-4fff-4626-9beb-f652ae6d0fb0\",\n },\n \"actor\": {\n \"type\": \"system\",\n },\n },\n {\n \"event_type\": \"record.updated\",\n \"id\": {\n \"workspace_id\": \"b6c564a6-2cf7-49ab-9320-dea013196bd7\",\n \"object_id\": \"a87cf74e-5ca1-4a8d-b8d3-fcca5413d4c3\",\n \"record_id\": \"caf853a3-3c29-408b-81da-18e067b97bf7\",\n \"attribute_id\": \"27814d19-7cad-4e0e-8053-207a448d6280\",\n },\n \"actor\": {\n \"type\": \"system\",\n },\n },\n {\n \"event_type\": \"record.updated\",\n \"id\": {\n \"workspace_id\": \"b6c564a6-2cf7-49ab-9320-dea013196bd7\",\n \"object_id\": \"a87cf74e-5ca1-4a8d-b8d3-fcca5413d4c3\",\n \"record_id\": \"caf853a3-3c29-408b-81da-18e067b97bf7\",\n \"attribute_id\": \"5c7f7b39-7ecc-4e23-8826-e8515d80231c\",\n },\n \"actor\": {\n \"type\": \"system\",\n },\n },\n {\n \"event_type\": \"record.updated\",\n \"id\": {\n \"workspace_id\": \"b6c564a6-2cf7-49ab-9320-dea013196bd7\",\n \"object_id\": \"a87cf74e-5ca1-4a8d-b8d3-fcca5413d4c3\",\n \"record_id\": \"caf853a3-3c29-408b-81da-18e067b97bf7\",\n \"attribute_id\": \"741e2b16-dbea-400d-93de-338fa51df310\",\n },\n \"actor\": {\n \"type\": \"system\",\n },\n },\n {\n \"event_type\": \"record.updated\",\n \"id\": {\n \"workspace_id\": \"b6c564a6-2cf7-49ab-9320-dea013196bd7\",\n \"object_id\": \"a87cf74e-5ca1-4a8d-b8d3-fcca5413d4c3\",\n \"record_id\": \"caf853a3-3c29-408b-81da-18e067b97bf7\",\n \"attribute_id\": \"580a4cba-b2dd-4c33-b470-1de5e3108c6d\",\n },\n \"actor\": {\n \"type\": \"system\",\n },\n },\n];\n\n// console.log(await summarizeEvents(SAMPLE_EVENTS.slice(0, 1)));",[],[214,295],["D",1755107311499],[231,232,233,234],[214],["D",1755099207883],{"_98":97,"_105":101},{"_98":97,"_99":-5,"_100":101,"_18":57,"_102":103,"_104":27},{"_13":87,"_33":88,"_45":44,"_89":46,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":47,"_96":97},"ctx",{"_80":-5,"_125":342,"_343":344,"_345":346,"_347":27,"_348":27,"_349":27,"_350":25,"_351":-5,"_352":-7,"_353":-7,"_354":64,"_355":27,"_356":27,"_357":-5,"_358":27,"_359":27,"_360":27,"_361":-5},"ENV",{"_313":314,"_315":316,"_317":88,"_318":319,"_320":321,"_322":323,"_324":325,"_326":327,"_328":329,"_330":331,"_332":333,"_334":335,"_336":337,"_338":339,"_340":341},"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 · v236