\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. [Get an Attio Access Token](https://app.attio.com/_/settings/developers/access-tokens)\n (with all read & write permissions) & set it as `ATTIO_API_KEY` in this val's\n Environment variables in the left sidebar\n4. Go to [`setup.ts`](./setup.ts) and click run to set up the events database\n and Attio webhook\n5. Go trigger some Attio events and see the message in Slack!\n\n## Files\n\n- [`attio/hydrate.ts`](./attio/hydrate.ts) - Converts raw webhook events into\n human-readable descriptions\n- [`attio/webhook.ts`](./attio/webhook.ts) - Attio webhook management and secret\n handling\n- [`attio/webhook-payload-types.ts`](./attio/webhook-payload-types.ts) -\n Complete TypeScript types for all Attio webhook events\n- [`alert.ts`](./alert.ts) - Cron job that processes recent events and sends\n Slack summaries\n- [`auth.ts`](./auth.ts) - Webhook signature verification middleware\n- [`openai.ts`](./openai.ts) - AI-powered event summarization using OpenAI\n- [`scratch.ts`](./scratch.ts) - Development scratchpad for testing functions\n- [`setup.ts`](./setup.ts) - One-time setup script to initialize database and\n Attio webhook\n- [`slack.ts`](./slack.ts) - Utility to send messages to Slack via webhook\n- [`sqlite.ts`](./sqlite.ts) - Database operations for storing and retrieving\n Attio events\n- [`webhook.ts`](./webhook.ts) - HTTP endpoint that receives webhooks from Attio\n\n## Attio webhooks\n\nAttio webhooks return thin events, which contain a bunch of IDs, but no\nhuman-readable data, such as:\n\n```json\n{\n event_type: \"record.merged\",\n id: {\n workspace_id: \"b6c564a6-2cf7-49ab-9320-dea013196bd7\",\n object_id: \"a87cf74e-5ca1-4a8d-b8d3-fcca5413d4c3\",\n record_id: \"d64ff9f2-d1f1-424c-8be6-e41129e35697\"\n },\n duplicate_object_id: \"a87cf74e-5ca1-4a8d-b8d3-fcca5413d4c3\",\n duplicate_record_id: \"112b5c78-1ffe-457a-8366-181b482888b4\",\n actor: { type: \"system\", id: null }\n }\n```\n\nThe trickiest part of this val was hydrating these events into human readable\nform, like \"Steve commented on OpenAI: they're using Val Town!\"\n\nAfter trying and failing (for hours!) to get LLMs to write this code for me, I\neventually bit the bullet and wrote it by hand. I only handled some of the more\ncommon event types, and left myself comments of other example events of types I\nhaven't handled yet.\n\nIn theory, Attio has a better way to handle this, analgous to\n[Stripe's method\nto fetch data for thin events](https://docs.stripe.com/event-destinations#fetch-data),\nbut I wasn't able to find it. If you figure it out, please send me a pull\nrequest or let me know at steve@val.town.",[],[198],{"_102":206,"_95":207,"_155":208,"_157":-5,"_158":136,"_159":135,"_160":161,"_104":209,"_99":32,"_163":210,"_165":211,"_166":22,"_167":-5,"_168":212,"_98":213},"41585432-8374-11f0-bdff-0224a6c84d84","alert.ts","0198eccd-f927-74a5-942c-717acf9dd398",["D",1756319578206],"interval","import { slack } from \"./slack.ts\";\nimport { getRecentEvents, markAsAlerted } from \"./sqlite.ts\";\nimport { hydrate } from \"./attio/hydrate.ts\";\nimport pSettle from \"npm:p-settle\";\nimport { summarizeEvents } from \"./openai.ts\";\nimport type { AttioWebhookEvent } from \"./attio/webhook-payload-types.ts\";\n\n// 30 minutes\nconst DEBOUNCE_TIME = 30 * 60 * 1000;\n\nconst BORING_SUBSTRINGS = [\n \"Connection strength to\",\n \"interaction to\",\n \"Connection strength (legacy) to\",\n];\n\nfunction isInteresting(event: string) {\n if (BORING_SUBSTRINGS.some((s) => event.includes(s))) {\n return false;\n } else {\n return true;\n }\n}\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\n console.log(`Hydrating ${events.length} events`);\n\n const settles = await pSettle(\n events.map((e) => () => hydrate(e)),\n { concurrency: 10 },\n );\n\n const errors = settles\n .filter((s) => s.isRejected);\n console.log(\"Errors\", errors);\n\n const fulfills = settles.filter((s) => s.isFulfilled);\n const values = fulfills.map((e) => e.value);\n console.log(\"Values\", values);\n\n const interestingValues = values.filter(isInteresting);\n console.log(\"Interesting values\", interestingValues);\n\n if (!interestingValues.length) {\n console.log(\"No interesting values, exiting\");\n return;\n }\n\n const text = await summarizeEvents(interestingValues);\n console.log(text);\n\n await slack(text);\n\n await markAsAlerted(recentEvents.map((e) => e.id as number));\n}",[],[207],{"_102":215,"_95":216,"_155":217,"_157":-5,"_158":136,"_159":135,"_160":161,"_104":218,"_99":32,"_163":175,"_165":219,"_166":22,"_167":-5,"_168":220,"_98":221},"415855ae-8374-11f0-bdff-0224a6c84d84","auth.ts","0198eccd-f927-74a5-942c-77faa4f65ec4",["D",1756319578206],"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};",[],[216],{"_102":223,"_95":224,"_155":225,"_157":-5,"_158":136,"_159":135,"_160":161,"_104":226,"_99":32,"_163":175,"_165":227,"_166":22,"_167":-5,"_168":228,"_98":229},"41585716-8374-11f0-bdff-0224a6c84d84","openai.ts","0198eccd-f927-74a5-942c-78b47321ad02",["D",1756319578206],"import { OpenAI } from \"https://esm.town/v/std/openai\";\n\nconst openai = new OpenAI();\n\nfunction parseMarkdown(text: string) {\n const match = text.match(/```(?:markdown|md|mrkdwn)?\\s*([\\s\\S]*?)\\s*```/);\n return match ? match[1].trim() : text;\n}\n\nexport async function summarizeEvents(events: string[]) {\n const resp = await openai.chat.completions.create({\n model: \"gpt-4.1\",\n messages: [{\n role: \"system\",\n content: `Filter and summarize a list of API events from Attio for Slack.\n Remove very low-level details.\n Group together and summarize events to the same resources.\n Do no include any timestamps.\n Output Slack valid mrkdwn surrounded by backtics.`,\n }, {\n role: \"user\",\n content: events.join(\"\\n\"),\n }],\n });\n\n return parseMarkdown(resp.choices[0].message.content);\n}\n\n// console.log(\n// await summarizeEvents([\n// {\n// status: \"fulfilled\",\n// value: \"System updated Google's Last email interaction to []\",\n// },\n// {\n// status: \"fulfilled\",\n// value:\n// `System updated Google's Connection strength (legacy) to [{\"active_from\":\"2025-08-14T17:01:36.709000000Z\",\"active_until\":null,\"created_by_actor\":{\"type\":\"system\",\"id\":null},\"value\":103.86797665221687,\"attribute_type\":\"number\"}]`,\n// },\n// {\n// status: \"fulfilled\",\n// value:\n// `System updated Google's Last interaction to [{\"active_from\":\"2025-08-14T17:01:36.709000000Z\",\"active_until\":null,\"created_by_actor\":{\"type\":\"system\",\"id\":null},\"interaction_type\":\"email\",\"interacted_at\":\"2025-08-14T16:57:15.000000000Z\",\"owner_actor\":{\"type\":\"workspace-member\",\"id\":\"f78c04c7-f58f-4d7c-a3c1-85be43d2f279\"},\"attribute_type\":\"interaction\"}]`,\n// },\n// ].map((x) => x.value)),\n// );",[],[224],{"_102":231,"_95":232,"_155":233,"_157":-5,"_158":136,"_159":135,"_160":161,"_104":234,"_99":32,"_163":175,"_165":235,"_166":22,"_167":-5,"_168":236,"_98":237},"41585dce-8374-11f0-bdff-0224a6c84d84","scratch.ts","0198eccd-f927-74a5-942c-7d1169968247",["D",1756319578206],"import { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\nimport { cache, hydrate } from \"./attio/hydrate.ts\";\nimport pSettle from \"npm:p-settle\";\n\nconst rows = (await sqlite.execute(\n `SELECT * \n FROM attio_events \n ORDER BY timestamp \n DESC`,\n)).rows;\n\nconst events = rows\n .flatMap((row) => JSON.parse(row.data as string).events)\n .slice(0, 20);\n\nconst eventTypes = new Set(events.map((e) => e?.event_type));\n\nconsole.log(eventTypes);\n\nlet result = (await pSettle(\n events.map((e) => () => hydrate(e)),\n { concurrency: 10 },\n)).map((x) => x.isFulfilled ? x.value : x);\n\nconsole.dir(\n result,\n { depth: null },\n);\n\n// export default () => Response.json(result);",[],[232],{"_102":239,"_95":240,"_155":241,"_157":-5,"_158":136,"_159":135,"_160":161,"_104":242,"_99":32,"_163":175,"_165":243,"_166":22,"_167":-5,"_168":244,"_98":245},"41585f54-8374-11f0-bdff-0224a6c84d84","setup.ts","0198eccd-f927-74a5-942c-8088a356652f",["D",1756319578206],"import { createWebhook } from \"./attio/webhook.ts\";\nimport { createTable } from \"./sqlite.ts\";\n\nawait createTable();\nawait createWebhook();",[],[240],{"_102":247,"_95":248,"_155":249,"_157":-5,"_158":136,"_159":135,"_160":161,"_104":250,"_99":32,"_163":175,"_165":251,"_166":22,"_167":-5,"_168":252,"_98":253},"415860da-8374-11f0-bdff-0224a6c84d84","slack.ts","0198eccd-f927-74a5-942c-86dd1178f396",["D",1756319578206],"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}",[],[248],{"_102":255,"_95":256,"_155":257,"_157":-5,"_158":136,"_159":135,"_160":161,"_104":258,"_99":32,"_163":175,"_165":259,"_166":22,"_167":-5,"_168":260,"_98":261},"41586238-8374-11f0-bdff-0224a6c84d84","sqlite.ts","0198eccd-f927-74a5-942c-8a3908052f62",["D",1756319578206],"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}",[],[256],{"_102":263,"_95":189,"_155":264,"_157":-5,"_158":136,"_159":135,"_160":161,"_104":265,"_99":32,"_163":266,"_165":267,"_166":22,"_167":-5,"_168":268,"_98":269},"415864e0-8374-11f0-bdff-0224a6c84d84","0198eccd-f927-74a5-942c-8eddc35afcf2",["D",1756319578206],"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;",[],[189],"files",[152,170,179,187,196,205,214,222,230,238,246,254,262],"counts",{"_274":32,"_275":135,"_276":32,"_277":278},"pulls","branches","forks","envVars",2,"contents",[281,284,287,290,293,296,299,302,305,308],{"_102":153,"_95":154,"_155":156,"_157":-5,"_158":136,"_159":135,"_160":161,"_104":282,"_99":32,"_163":164,"_165":-5,"_166":22,"_167":-5,"_98":283},["D",1756319578206],[154],{"_102":197,"_95":198,"_155":199,"_157":-5,"_158":136,"_159":135,"_160":161,"_104":285,"_99":32,"_163":201,"_165":202,"_166":22,"_167":-5,"_98":286},["D",1756319578206],[198],{"_102":206,"_95":207,"_155":208,"_157":-5,"_158":136,"_159":135,"_160":161,"_104":288,"_99":32,"_163":210,"_165":211,"_166":22,"_167":-5,"_98":289},["D",1756319578206],[207],{"_102":215,"_95":216,"_155":217,"_157":-5,"_158":136,"_159":135,"_160":161,"_104":291,"_99":32,"_163":175,"_165":219,"_166":22,"_167":-5,"_98":292},["D",1756319578206],[216],{"_102":223,"_95":224,"_155":225,"_157":-5,"_158":136,"_159":135,"_160":161,"_104":294,"_99":32,"_163":175,"_165":227,"_166":22,"_167":-5,"_98":295},["D",1756319578206],[224],{"_102":231,"_95":232,"_155":233,"_157":-5,"_158":136,"_159":135,"_160":161,"_104":297,"_99":32,"_163":175,"_165":235,"_166":22,"_167":-5,"_98":298},["D",1756319578206],[232],{"_102":239,"_95":240,"_155":241,"_157":-5,"_158":136,"_159":135,"_160":161,"_104":300,"_99":32,"_163":175,"_165":243,"_166":22,"_167":-5,"_98":301},["D",1756319578206],[240],{"_102":247,"_95":248,"_155":249,"_157":-5,"_158":136,"_159":135,"_160":161,"_104":303,"_99":32,"_163":175,"_165":251,"_166":22,"_167":-5,"_98":304},["D",1756319578206],[248],{"_102":255,"_95":256,"_155":257,"_157":-5,"_158":136,"_159":135,"_160":161,"_104":306,"_99":32,"_163":175,"_165":259,"_166":22,"_167":-5,"_98":307},["D",1756319578206],[256],{"_102":263,"_95":189,"_155":264,"_157":-5,"_158":136,"_159":135,"_160":161,"_104":309,"_99":32,"_163":266,"_165":267,"_166":22,"_167":-5,"_98":310},["D",1756319578206],[189],"upstreamProject",{"_102":144,"_95":96,"_110":313,"_111":-5,"_108":109,"_23":314},"Get debounced summaries of updates from Attio in Slack",{"_93":315,"_128":316},"stevekrouse","https://images.clerk.dev/uploaded/img_2PqHa2Gsy93xQrjh2w78Xu0cChW.jpeg","upstreamBranch",{"_102":139,"_104":319,"_320":321,"_95":43,"_137":144,"_99":322,"_138":-5,"_140":-5,"_323":324,"_106":-5,"_149":22,"_108":109,"_148":315,"_16":146,"_147":96},["D",1755099207883],"updatedAt",["D",1757524966621],340,"lockfileKey","1757524966902-esm.town_v_stevekrouse_attio-slack-summaries@340-main","emptyEnvVars","isNew","flags",[],"routes/_app.x.$handle.$name.environment-variables",{"_93":94,"_95":96,"_100":331,"_277":336},{"_102":103,"_95":96,"_104":332,"_106":-5,"_107":22,"_108":109,"_110":-5,"_111":-5,"_14":112,"_113":-5,"_114":22,"_115":-5,"_116":32,"_16":117,"_118":119,"_120":119,"_121":122,"_123":122,"_124":122,"_125":119,"_126":119,"_23":333,"_130":334,"_133":335,"_149":22},["D",1756319578206],{"_93":94,"_128":129},{"_93":94,"_132":129},{"_99":135,"_95":43,"_102":136,"_137":103,"_138":139,"_140":141,"_142":109,"_143":144,"_145":146,"_147":96,"_148":94},[337,344],{"_338":339,"_104":340,"_320":341,"_110":342,"_343":22},"key","ATTIO_API_KEY",["D",1756319578206],["D",1756319796848],"https://app.attio.com/_/settings/developers/access-tokens","isEmpty",{"_338":345,"_104":346,"_320":347,"_110":348,"_343":22},"SLACK_WEBHOOK_URL",["D",1756319578206],["D",1756319934169],"https://docs.val.town/integrations/slack/send-messages-to-slack/#1-create-a-slack-app--webhook","actionData","errors"]

charmaine

attio-slack-summaries

Environment variables