\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. Get the name of your Attio workspace and set it as `ATTIO_WORKSPACE_NAME` in\n this val's Environment variables in the left sidebar\n5. Set `SALES_LIST_ID` to the ID of your Sales List in this val's Environment variables in the left sidebar\n6. Go to [`setup.ts`](./setup.ts) and click run to set up the events database\n and Attio webhook\n7. 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.\n",[],[314],{"_105":322,"_95":323,"_155":324,"_157":-5,"_158":139,"_159":325,"_161":22,"_107":326,"_101":32,"_163":308,"_165":327,"_166":22,"_167":-5,"_168":328,"_99":329},"001f349c-8a89-11f0-b998-0224a6c84d84","TODO.md","001f356e-8a89-11f0-b998-0224a6c84d84",407,["D",1757098146561],"- [ ] edit readme\n - [ ] screenshots\n- [ ] change responsible_actor to string in AttioEntryStateData\n- [ ] screen recording with a talk through\n- [ ] clean up codebase, comments, etc\n- [ ] config.ts\n",[],[323],{"_105":331,"_95":332,"_155":333,"_157":-5,"_158":139,"_159":334,"_161":22,"_107":335,"_101":336,"_163":337,"_165":338,"_166":22,"_167":-5,"_168":339,"_99":340},"0025686c-8a89-11f0-ade8-0224a6c84d84","alert.ts","0198f872-ab3d-72d6-8b63-561fc22f3cce",408,["D",1757098146561],15,"interval","import { getRecentMessages, markAsAlerted } from \"./database/sqlite.ts\";\nimport { buildSlackPayload, slack } from \"./shared/slack.ts\";\nimport type { AttioMessage } from \"./types/index.ts\";\n\n// 30 minutes\nconst DEBOUNCE_TIME = 30 * 60 * 1000;\nconst DEBOUNCE_ACTIVE = false;\n\nexport default async function () {\n const recentMessages = await getRecentMessages();\n\n if (!recentMessages.length) {\n console.log(\"No recent messages, exiting\");\n return;\n }\n\n if (\n (recentMessages[0].timestamp as number) > Date.now() - DEBOUNCE_TIME &&\n DEBOUNCE_ACTIVE\n ) {\n console.log(\"Within debounce period, exiting\");\n return;\n } else {\n console.log(\"Within debounce period, continuing\");\n }\n\n const messages: AttioMessage[] = recentMessages\n .map((m) => m.message)\n .map((m) => JSON.parse(m));\n\n if (!messages.length) {\n console.log(\"No messages, exiting\");\n return;\n }\n\n await slack(buildSlackPayload(\"Sales events\", messages));\n\n await markAsAlerted(\n recentMessages.map((m) => m.id as number),\n \"attio_messages\",\n );\n\n await markAsAlerted(\n recentMessages.map((m) => m.id as number),\n \"attio_events\",\n );\n}\n",[],[332],{"_105":342,"_95":343,"_155":344,"_157":-5,"_158":139,"_159":223,"_161":22,"_107":345,"_101":160,"_163":177,"_165":346,"_166":22,"_167":-5,"_168":347,"_99":348},"3bcdea0a-8823-11f0-9fb9-0224a6c84d84","auth.ts","0198f872-ab3d-72d6-8b63-5bdcd7504b62",["D",1756834535667],"import { getAttioWebhookSecret } from \"./attio/webhook.ts\";\n\nexport const auth = async (c, next) => {\n const webhookSignature =\n c.req.header(\"Attio-Signature\") || 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};\n",[],[343],{"_105":350,"_95":351,"_155":352,"_157":-5,"_158":139,"_159":160,"_161":22,"_107":353,"_101":32,"_163":308,"_165":354,"_166":22,"_167":-5,"_168":355,"_99":356},"12c49be4-853b-11f0-a916-0224a6c84d84","biome.json","0198f872-ab3d-72d6-8b63-5f9702bfbbfd",["D",1756514921283],"{\n \"$schema\": \"https://biomejs.dev/schemas/2.2.2/schema.json\",\n \"vcs\": {\n \"enabled\": false,\n \"clientKind\": \"git\",\n \"useIgnoreFile\": false\n },\n \"files\": {\n \"ignoreUnknown\": false\n },\n \"formatter\": {\n \"enabled\": true,\n \"indentStyle\": \"space\",\n \"indentWidth\": 3\n },\n \"linter\": {\n \"enabled\": true,\n \"rules\": {\n \"recommended\": true\n }\n },\n \"javascript\": {\n \"formatter\": {\n \"quoteStyle\": \"double\"\n }\n },\n \"assist\": {\n \"enabled\": true,\n \"actions\": {\n \"source\": {\n \"organizeImports\": \"on\"\n }\n }\n }\n}\n",[],[351],{"_105":358,"_95":359,"_155":360,"_157":-5,"_158":139,"_159":361,"_161":22,"_107":362,"_101":32,"_163":177,"_165":363,"_166":22,"_167":-5,"_168":364,"_99":365},"0081df16-8a89-11f0-831d-0224a6c84d84","config.ts","0081dfc0-8a89-11f0-831d-0224a6c84d84",417,["D",1757098146561],"type Config = {\n workspaceName: string;\n lists: {\n listId: string;\n notificationHeader: string;\n }[];\n};\n\nexport const config: Config = {\n workspaceName: Deno.env.get(\"ATTIO_WORKSPACE_NAME\") as string,\n lists: [\n {\n listId: Deno.env.get(\"SALES_LIST_ID\") as string,\n notificationHeader: \"Sales List Events\",\n },\n ],\n};\n",[],[359],{"_105":367,"_95":368,"_155":369,"_157":-5,"_158":139,"_159":370,"_161":22,"_107":371,"_101":176,"_163":308,"_165":372,"_166":22,"_167":-5,"_168":373,"_99":374},"2e22c8c2-8a16-11f0-a900-0224a6c84d84","deno.json","0198f872-ab3d-72d6-8b63-6353ba459a40",378,["D",1757048831631],"{\n \"$schema\": \"https://raw.githubusercontent.com/denoland/deno/348900b8b79f4a434cab4c74b3bc8d4d2fa8ee74/cli/schemas/config-file.v1.json\",\n \"compilerOptions\": {\n \"lib\": [\n \"dom\",\n \"dom.iterable\",\n \"dom.asynciterable\",\n \"deno.ns\",\n \"deno.unstable\"\n ],\n \"noImplicitAny\": false,\n \"strict\": false,\n \"types\": [\"https://www.val.town/types/valtown.d.ts\"]\n },\n \"experimental\": {\n \"unstable-node-globals\": true,\n \"unstable-sloppy-imports\": true,\n \"unstable-temporal\": true,\n \"unstable-worker-options\": true\n },\n \"imports\": {\n \"@biomejs/biome\": \"npm:@biomejs/biome@^2.0.0\",\n \"@gabriel/ts-pattern\": \"jsr:@gabriel/ts-pattern@^5.8.0\",\n \"@valtown/sdk\": \"jsr:@valtown/sdk@^1.13.0\",\n \"attio-js\": \"npm:attio-js@^0.1.1\",\n \"microdiff\": \"npm:microdiff@^1.5.0\",\n \"text-title-case\": \"npm:text-title-case@^1.2.4\"\n },\n \"lint\": {\n \"files\": {\n \"include\": [\"deno:/https/esm.town/**/*\"]\n },\n \"rules\": {\n \"exclude\": [\"no-explicit-any\"]\n }\n },\n \"lock\": false,\n \"nodeModulesDir\": \"auto\"\n}\n",[],[368],{"_105":376,"_95":377,"_155":378,"_157":-5,"_158":139,"_159":379,"_161":22,"_107":380,"_101":381,"_163":177,"_165":382,"_166":22,"_167":-5,"_168":383,"_99":384},"004bf8b0-8a89-11f0-a113-0224a6c84d84","enrich-entry.ts","b92a9868-8869-11f0-9963-0224a6c84d84",414,["D",1757098146814],14,"import { match } from \"jsr:@gabriel/ts-pattern\";\nimport { getActorName, getRecord, getRecordName } from \"./attio/utils.ts\";\nimport type { WebhookActor } from \"./attio/webhook-payload-types.ts\";\nimport type {\n ActorReferenceAttribute,\n AttioAttribute,\n AttioEntryStateData,\n AttioListEntry,\n CheckboxAttribute,\n CurrencyAttribute,\n DateAttribute,\n DomainAttribute,\n EmailAddressAttribute,\n InteractionAttribute,\n LocationAttribute,\n NumberAttribute,\n PersonalNameAttribute,\n PhoneNumberAttribute,\n RatingAttribute,\n RecordReferenceAttribute,\n SelectAttribute,\n StatusAttribute,\n TextAttribute,\n TimestampAttribute,\n} from \"./types/index.ts\";\n\nexport async function enrichEntry(\n entry: AttioListEntry,\n event_type:\n | \"list-entry.created\"\n | \"list-entry.updated\"\n | \"list-entry.deleted\"\n | \"initialization\",\n responsible_actor?: WebhookActor,\n): Promise {\n const { parent_record_id, parent_object } = entry;\n\n const record = await getRecord({\n object_id: parent_object,\n record_id: parent_record_id,\n });\n\n const formattedEntryValues: { [key: string]: string | null } = {};\n\n for (const attribute of Object.keys(entry.entry_values)) {\n const attributeValues: AttioAttribute[] = entry.entry_values[attribute];\n if (attributeValues.length > 0) {\n const formattedValue = await formatAttributeValue(attributeValues[0]);\n console.log(\"formattedValue\", formattedValue);\n formattedEntryValues[attribute] = formattedValue;\n } else {\n formattedEntryValues[attribute] = null;\n }\n }\n\n const recordName = getRecordName(record);\n\n let responsibleActor: string | null;\n switch (event_type) {\n case \"initialization\":\n responsibleActor = null;\n break;\n case \"list-entry.created\":\n responsibleActor = formattedEntryValues.created_by;\n break;\n case \"list-entry.updated\":\n case \"list-entry.deleted\":\n responsibleActor = await getActorName(responsible_actor);\n break;\n }\n\n return {\n list_id: entry.id.list_id,\n entry_id: entry.id.entry_id,\n record_name: recordName,\n object: parent_object,\n entry_values: formattedEntryValues,\n responsible_actor: responsibleActor,\n };\n}\n\nexport async function formatAttributeValue(\n attributeValue: AttioAttribute,\n): Promise {\n return await match(attributeValue)\n .with({ attribute_type: \"status\" }, (m) => statusValue(m))\n .with({ attribute_type: \"text\" }, (m) => textValue(m))\n .with(\n { attribute_type: \"record-reference\" },\n async (m) => await recordReferenceValue(m),\n )\n .with(\n { attribute_type: \"actor-reference\" },\n async (m) => await actorReferenceValue(m),\n )\n .with({ attribute_type: \"select\" }, (m) => selectValue(m))\n .with({ attribute_type: \"date\" }, (m) => dateValue(m))\n .with({ attribute_type: \"timestamp\" }, (m) => timestampValue(m))\n .with({ attribute_type: \"rating\" }, (m) => ratingValue(m))\n .with({ attribute_type: \"currency\" }, (m) => currencyValue(m))\n .with({ attribute_type: \"domain\" }, (m) => domainValue(m))\n .with({ attribute_type: \"email-address\" }, (m) => emailAddressValue(m))\n .with({ attribute_type: \"interaction\" }, (m) => interactionValue(m))\n .with({ attribute_type: \"location\" }, (m) => locationValue(m))\n .with({ attribute_type: \"personal-name\" }, (m) => personalNameValue(m))\n .with({ attribute_type: \"number\" }, (m) => numberValue(m))\n .with({ attribute_type: \"phone-number\" }, (m) => phoneNumberValue(m))\n .with({ attribute_type: \"checkbox\" }, (m) => checkboxValue(m))\n .exhaustive();\n}\n\nfunction statusValue(statusAttribute: StatusAttribute) {\n return statusAttribute.status.title;\n}\n\nfunction textValue(textAttribute: TextAttribute) {\n return textAttribute.value;\n}\n\nasync function recordReferenceValue(\n recordReferenceAttribute: RecordReferenceAttribute,\n) {\n return getRecordName(\n await getRecord({\n object_id: recordReferenceAttribute.target_object,\n record_id: recordReferenceAttribute.target_record_id,\n }),\n );\n}\n\nasync function actorReferenceValue(\n actorReferenceAttribute: ActorReferenceAttribute,\n) {\n return await getActorName({\n type: actorReferenceAttribute.referenced_actor_type,\n id: actorReferenceAttribute.referenced_actor_id,\n });\n}\n\nfunction selectValue(selectAttribute: SelectAttribute) {\n return selectAttribute.option.title;\n}\n\nfunction dateValue(dateAttribute: DateAttribute) {\n return dateAttribute.value;\n}\n\nfunction timestampValue(timestampAttribute: TimestampAttribute) {\n return timestampAttribute.value;\n}\n\nfunction ratingValue(ratingAttribute: RatingAttribute) {\n return ratingAttribute.value.toString();\n}\n\nfunction currencyValue(currencyAttribute: CurrencyAttribute) {\n return Intl.NumberFormat(\"en-US\", {\n style: \"currency\",\n currency: currencyAttribute.currency_code,\n }).format(Number(currencyAttribute.currency_value));\n}\n\nfunction domainValue(domainAttribute: DomainAttribute) {\n return domainAttribute.domain;\n}\n\nfunction emailAddressValue(emailAddressAttribute: EmailAddressAttribute) {\n return emailAddressAttribute.email_address;\n}\n\nfunction interactionValue(interactionAttribute: InteractionAttribute) {\n return `${interactionAttribute.interaction_type} - ${interactionAttribute.interaction_at}`;\n}\n\nfunction locationValue(locationAttribute: LocationAttribute) {\n return locationAttribute.locality; // TODO: Make this formatting more robust\n}\n\nfunction personalNameValue(personalNameAttribute: PersonalNameAttribute) {\n return personalNameAttribute.full_name;\n}\n\nfunction numberValue(numberAttribute: NumberAttribute) {\n return numberAttribute.value.toString();\n}\n\nfunction phoneNumberValue(phoneNumberAttribute: PhoneNumberAttribute) {\n return phoneNumberAttribute.original_phone_number;\n}\n\nfunction checkboxValue(checkboxAttribute: CheckboxAttribute) {\n return checkboxAttribute.value.toString();\n}\n",[],[377],{"_105":386,"_95":387,"_155":388,"_157":-5,"_158":139,"_159":389,"_161":22,"_107":390,"_101":391,"_163":177,"_165":392,"_166":22,"_167":-5,"_168":393,"_99":394},"0035deae-8a89-11f0-a712-0224a6c84d84","handle-webhook.ts","add16062-8870-11f0-b5f8-0224a6c84d84",411,["D",1757098146704],41,"import { match, P } from \"jsr:@gabriel/ts-pattern\";\nimport diff, { type Difference } from \"npm:microdiff\";\nimport {\n getActorName,\n getComment,\n getEntry,\n getRecord,\n getRecordName,\n} from \"./attio/utils.ts\";\nimport type {\n AttioWebhookEvent,\n CommentEvent,\n ListEntryCreatedEvent,\n ListEntryDeletedEvent,\n ListEntryEvent,\n ListEntryUpdatedEvent,\n} from \"./attio/webhook-payload-types.ts\";\nimport {\n getEntryStatePair,\n insertAttioEntry,\n insertAttioEvent,\n insertAttioMessage,\n} from \"./database/sqlite.ts\";\nimport { enrichEntry } from \"./enrich-entry.ts\";\nimport type {\n AttioEntryStateData,\n CommentMessage,\n CreateEntryMessage,\n DeleteEntryMessage,\n UpdateEntryMessage,\n} from \"./types/index.ts\";\n\nexport async function handleWebhookEvent(\n webhookEvent: AttioWebhookEvent,\n): Promise {\n console.log(\n `event type of data passed to handleWebhook ${webhookEvent.event_type}`,\n );\n\n return await match(webhookEvent)\n .with(\n {\n event_type: P.when((event_type) =>\n event_type.startsWith(\"list-entry.\"),\n ),\n },\n async (event: ListEntryEvent) => {\n console.log(\"handling list entry event\");\n\n const action = event.event_type.split(\".\")[1] as\n | \"created\"\n | \"updated\"\n | \"deleted\";\n\n const { id: event_id } = await insertAttioEvent(event);\n\n console.log(\"event_id\", event_id);\n\n if (action === \"deleted\") {\n return await handleEntryDeletedEvent(\n event as ListEntryDeletedEvent,\n event_id,\n );\n }\n\n const entry = await getEntry(event.id);\n\n if (!entry) {\n throw new Error(\n `Entry not found for event ${event.event_type} with id ${event.id.entry_id}`,\n );\n }\n\n const enrichedEntry = await enrichEntry(\n entry,\n event.event_type,\n event.actor,\n );\n\n if (action === \"created\") {\n return await handleEntryCreatedEvent(\n event as ListEntryCreatedEvent,\n event_id,\n enrichedEntry,\n );\n }\n\n if (action === \"updated\") {\n return await handleEntryUpdatedEvent(\n event as ListEntryUpdatedEvent,\n event_id,\n enrichedEntry,\n );\n }\n },\n )\n .with(\n {\n event_type: P.when((event_type) =>\n event_type.startsWith(\"comment.\"),\n ),\n },\n async (event: CommentEvent) => await handleCommentEvent(event),\n )\n .otherwise(async (event) => {\n await insertAttioEvent(event);\n return `Attio event type not supported: ${event.event_type}`;\n });\n}\n\nasync function handleEntryDeletedEvent(\n event: ListEntryDeletedEvent,\n event_id: number,\n) {\n console.log(\"deleting entry\");\n const record = await getRecord({\n object_id: event.parent_object_id,\n record_id: event.parent_record_id,\n });\n const recordName = getRecordName(record);\n const actor = await getActorName(event.actor);\n\n const message: DeleteEntryMessage = {\n action: \"deleted\",\n target: \"entry\",\n record_name: recordName,\n record_id: event.parent_record_id,\n actor,\n };\n\n await insertAttioMessage(event_id, JSON.stringify(message));\n return `deleted entry (${event.id.entry_id})`;\n}\n\nasync function handleEntryCreatedEvent(\n event: ListEntryCreatedEvent,\n event_id: number,\n enrichedEntry: AttioEntryStateData,\n) {\n console.log(\"creating entry\");\n await insertAttioEntry(\n enrichedEntry.entry_id,\n event.id.list_id,\n enrichedEntry,\n );\n const message: CreateEntryMessage = {\n action: \"created\",\n target: \"entry\",\n record_name: enrichedEntry.record_name,\n record_id: event.parent_record_id,\n actor: enrichedEntry.responsible_actor,\n };\n await insertAttioMessage(event_id, JSON.stringify(message));\n return `created entry (${enrichedEntry.entry_id})`;\n}\n\nasync function handleEntryUpdatedEvent(\n event: ListEntryUpdatedEvent,\n event_id: number,\n enrichedEntry: AttioEntryStateData,\n) {\n console.log(\"updating entry\");\n await insertAttioEntry(\n enrichedEntry.entry_id,\n event.id.list_id,\n enrichedEntry,\n );\n const updatePair = await getEntryStatePair(enrichedEntry.entry_id);\n\n // console.log(\"updatePair\", updatePair);\n\n const updates = diff(\n (JSON.parse(updatePair[1].state_data) as AttioEntryStateData)\n .entry_values,\n (JSON.parse(updatePair[0].state_data) as AttioEntryStateData)\n .entry_values,\n );\n\n // console.log(\"updates\", updates);\n\n for (const update of updates) {\n console.log(\"update\", update);\n\n const getValue = (update: Difference, key: \"oldValue\" | \"value\") => {\n const value =\n update.type === \"CHANGE\"\n ? update[key]\n : `Update type: ${update.type} not implemented`;\n console.log(\"value\", value);\n return value;\n };\n\n const message: UpdateEntryMessage = {\n action: \"updated\",\n target: \"entry\",\n record_name: enrichedEntry.record_name,\n record_id: event.parent_record_id,\n attribute_name: update.path[0] as string,\n actor: enrichedEntry.responsible_actor,\n oldState: getValue(update, \"oldValue\"),\n newState: getValue(update, \"value\"),\n };\n\n console.log(\"message\", message);\n\n await insertAttioMessage(event_id, JSON.stringify(message));\n }\n\n return `updated entry (${enrichedEntry.entry_id})`;\n}\n\nasync function handleCommentEvent(event: CommentEvent) {\n console.log(\"handling comment event\");\n const { id: event_id } = await insertAttioEvent(event);\n const action = event.event_type.split(\".\")[1] as\n | \"created\"\n | \"resolved\"\n | \"unresolved\"\n | \"deleted\";\n\n const record = await getRecord({\n object_id: event.object_id,\n record_id: event.record_id,\n });\n\n const recordName = getRecordName(record);\n const comment = await getComment(event.id.comment_id);\n const actor = await getActorName(event.actor);\n const commentText = comment.content_plaintext;\n\n const message: CommentMessage = {\n action,\n target: \"comment\",\n record_name: recordName,\n record_id: event.record_id,\n actor,\n comment_text: commentText,\n comment_id: event.id.comment_id,\n };\n\n await insertAttioMessage(event_id, JSON.stringify(message));\n return `handled comment event (${event.id.comment_id})`;\n}\n",[],[387],{"_105":396,"_95":397,"_155":398,"_157":-5,"_158":139,"_159":399,"_161":22,"_107":400,"_101":241,"_163":177,"_165":401,"_166":22,"_167":-5,"_168":402,"_99":403},"737dc944-89bc-11f0-8387-0224a6c84d84","initialize-entries.ts","b918d7a4-8869-11f0-9de8-0224a6c84d84",290,["D",1757010293284],"import { enrichEntry } from \"./enrich-entry.ts\";\nimport type { AttioEntryStateData, AttioListEntry } from \"./types/index.ts\";\n\nexport async function getInitialListState({\n list_id,\n apiKey,\n options = {},\n}: {\n list_id: string;\n apiKey: string;\n options?: RequestInit;\n}): Promise {\n const url = `https://api.attio.com/v2/lists/${list_id}/entries/query`;\n\n const baseOptions = {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${apiKey}`,\n \"Content-Type\": \"application/json\",\n },\n body: \"{}\",\n };\n\n try {\n const response = await fetch(url, { ...baseOptions, ...options });\n const { data } = (await response.json()) as { data: AttioListEntry[] };\n const enrichedData = await Promise.all(\n data.map((entry) => enrichEntry(entry, \"initialization\")),\n );\n return enrichedData;\n } catch (error) {\n console.error(error);\n }\n}\n",[],[397],{"_105":405,"_95":406,"_155":407,"_157":-5,"_158":139,"_159":408,"_161":22,"_107":409,"_101":241,"_163":177,"_165":410,"_166":22,"_167":-5,"_168":411,"_99":412},"c6bdd196-8898-11f0-b86d-0224a6c84d84","openai.ts","0198f872-ab3d-72d6-8b63-66ef3d40bf76",248,["D",1756885019880],"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 {\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 not include any timestamps.\n Output Slack valid markdown surrounded by backtics.`,\n },\n {\n role: \"user\",\n content: events.join(\"\\n\"),\n },\n ],\n });\n\n return parseMarkdown(resp.choices[0].message.content);\n}\n",[],[406],{"_105":414,"_95":415,"_155":416,"_157":-5,"_158":139,"_159":417,"_161":22,"_107":418,"_101":419,"_163":177,"_165":420,"_166":22,"_167":-5,"_168":421,"_99":422},"003b14dc-8a89-11f0-8251-0224a6c84d84","setup.ts","0198f872-ab3d-72d6-8b63-6d6407da82f4",412,["D",1757098146735],31,"import { createWebhook } from \"./attio/webhook.ts\";\nimport { config } from \"./config.ts\";\nimport { createTables } from \"./database/schema.ts\";\nimport { insertAttioEntry } from \"./database/sqlite.ts\";\nimport { getInitialListState } from \"./initialize-entries.ts\";\n\nconst { lists } = config;\n\ntry {\n await createTables();\n console.log(\"Tables created\");\n} catch (error) {\n console.error(\"Error creating tables\", error);\n}\n\ntry {\n await createWebhook();\n console.log(\"Webhook created\");\n} catch (error) {\n console.error(\"Error creating webhook\", error);\n}\n\nfor (const list of lists) {\n try {\n const initialEntries = await getInitialListState({\n list_id: list.listId,\n apiKey: Deno.env.get(\"ATTIO_API_KEY\") as string,\n });\n await Promise.all(\n initialEntries.map((entry) =>\n insertAttioEntry(entry.entry_id, list.listId, entry),\n ),\n );\n console.log(\"Entries initialized\");\n } catch (error) {\n console.error(\"Error initializing entries\", error);\n }\n}\n",[],[415],{"_105":424,"_95":193,"_155":425,"_157":-5,"_158":139,"_159":426,"_161":22,"_107":427,"_101":381,"_163":428,"_165":429,"_166":22,"_167":-5,"_168":430,"_99":431},"e66a3c18-8a6f-11f0-82a1-0224a6c84d84","0198f872-ab3d-72d6-8b63-7a839a611511",394,["D",1757087365999],"http","import { Hono } from \"npm:hono\";\nimport type { AttioWebhookPayload } from \"./attio/webhook-payload-types.ts\";\nimport { auth } from \"./auth.ts\";\nimport { handleWebhookEvent } from \"./handle-webhook.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()) as AttioWebhookPayload;\n\n for (const event of data.events) {\n await handleWebhookEvent(event);\n }\n\n return c.json(\"ok\");\n});\n\napp.onError((err: unknown) => Promise.reject(err));\n\nexport default app.fetch;\n",[],[193],"files",[153,170,181,191,201,208,217,228,235,245,256,263,273,284,291,302,312,321,330,341,349,357,366,375,385,395,404,413,423],"counts",{"_436":32,"_437":176,"_438":160,"_439":187},"pulls","branches","forks","envVars","contents",[442,445,448],{"_105":171,"_95":172,"_155":173,"_157":156,"_158":139,"_159":174,"_161":22,"_107":443,"_101":176,"_163":177,"_165":178,"_166":22,"_167":-5,"_99":444},["D",1757087365919],[100,172],{"_105":182,"_95":183,"_155":184,"_157":156,"_158":139,"_159":185,"_161":22,"_107":446,"_101":187,"_163":177,"_165":188,"_166":22,"_167":-5,"_99":447},["D",1757010293079],[100,183],{"_105":192,"_95":193,"_155":194,"_157":156,"_158":139,"_159":195,"_161":22,"_107":449,"_101":160,"_163":177,"_165":197,"_166":22,"_167":-5,"_99":450},["D",1756834535542],[100,193],{"_105":154,"_95":100,"_155":156,"_157":-5,"_158":139,"_159":160,"_161":22,"_107":452,"_101":32,"_163":164,"_165":-5,"_166":22,"_167":-5,"_99":453},["D",1756514921283],[100],"upstreamProject",{"_105":456,"_95":96,"_113":457,"_114":-5,"_111":112,"_23":458},"dbd66352-785a-11f0-814d-0224a6c84d84","Get debounced summaries of updates from Attio in Slack",{"_93":459,"_131":460},"stevekrouse","https://images.clerk.dev/uploaded/img_2PqHa2Gsy93xQrjh2w78Xu0cChW.jpeg","upstreamBranch",{"_105":142,"_107":463,"_464":465,"_95":43,"_140":106,"_101":466,"_141":467,"_143":468,"_469":470,"_109":-5,"_150":22,"_111":112,"_149":94,"_16":120,"_148":96},["D",1756498797190],"updatedAt",["D",1757524966685],36,"dbdc0d5c-785a-11f0-814d-0224a6c84d84",340,"lockfileKey","1757524976194-esm.town_v_nbbaier_attio-slack-summaries@36-main","emptyEnvVars","isNew","flags",[],"routes/_app.x.$handle.$name.branch.$branch.version.$version.code.$",{"_93":94,"_95":96,"_97":98,"_101":102,"_99":100,"_103":477,"_151":482,"_432":570,"_308":571,"_440":573,"_580":581,"_584":585,"_586":-5,"_587":32,"_588":381,"_589":590},{"_105":106,"_95":96,"_107":478,"_109":-5,"_110":22,"_111":112,"_113":-5,"_114":-5,"_14":115,"_116":-5,"_117":22,"_118":-5,"_119":32,"_16":120,"_121":122,"_123":122,"_124":125,"_126":125,"_127":125,"_128":122,"_129":122,"_23":479,"_133":480,"_136":481,"_150":22},["D",1756498797190],{"_93":94,"_131":132},{"_93":94,"_135":132},{"_101":138,"_95":98,"_105":139,"_140":106,"_141":142,"_143":144,"_145":112,"_146":106,"_147":120,"_148":96,"_149":94},[483,495,504,513,522,528,531,534,537,540,543,546,549,552,555,558,561,564,567],{"_105":154,"_95":100,"_155":156,"_157":-5,"_158":139,"_159":160,"_161":22,"_107":162,"_101":32,"_163":164,"_165":-5,"_166":22,"_167":-5,"_168":484,"_99":494},[485,488,491],{"_105":171,"_95":172,"_155":173,"_157":156,"_158":139,"_159":174,"_161":22,"_107":175,"_101":176,"_163":177,"_165":178,"_166":22,"_167":-5,"_168":486,"_99":487},[],[100,172],{"_105":182,"_95":183,"_155":184,"_157":156,"_158":139,"_159":185,"_161":22,"_107":186,"_101":187,"_163":177,"_165":188,"_166":22,"_167":-5,"_168":489,"_99":490},[],[100,183],{"_105":192,"_95":193,"_155":194,"_157":156,"_158":139,"_159":195,"_161":22,"_107":196,"_101":160,"_163":177,"_165":197,"_166":22,"_167":-5,"_168":492,"_99":493},[],[100,193],[100],{"_105":202,"_95":203,"_155":204,"_157":-5,"_158":139,"_159":205,"_161":22,"_107":206,"_101":32,"_163":164,"_165":-5,"_166":22,"_167":-5,"_168":496,"_99":503},[497,500],{"_105":209,"_95":210,"_155":211,"_157":204,"_158":139,"_159":212,"_161":22,"_107":213,"_101":32,"_163":177,"_165":214,"_166":22,"_167":-5,"_168":498,"_99":499},[],[203,210],{"_105":218,"_95":219,"_155":220,"_157":204,"_158":139,"_159":221,"_161":22,"_107":222,"_101":223,"_163":177,"_165":224,"_166":22,"_167":-5,"_168":501,"_99":502},[],[203,219],[203],{"_105":229,"_95":230,"_155":231,"_157":-5,"_158":139,"_159":232,"_161":22,"_107":233,"_101":32,"_163":164,"_165":-5,"_166":22,"_167":-5,"_168":505,"_99":512},[506,509],{"_105":236,"_95":237,"_155":238,"_157":231,"_158":139,"_159":239,"_161":22,"_107":240,"_101":241,"_163":177,"_165":242,"_166":22,"_167":-5,"_168":507,"_99":508},[],[230,237],{"_105":246,"_95":247,"_155":248,"_157":231,"_158":139,"_159":249,"_161":22,"_107":250,"_101":251,"_163":177,"_165":252,"_166":22,"_167":-5,"_168":510,"_99":511},[],[230,247],[230],{"_105":257,"_95":258,"_155":259,"_157":-5,"_158":139,"_159":260,"_161":22,"_107":261,"_101":32,"_163":164,"_165":-5,"_166":22,"_167":-5,"_168":514,"_99":521},[515,518],{"_105":264,"_95":265,"_155":266,"_157":259,"_158":139,"_159":267,"_161":22,"_107":268,"_101":269,"_163":177,"_165":270,"_166":22,"_167":-5,"_168":516,"_99":517},[],[258,265],{"_105":274,"_95":275,"_155":276,"_157":259,"_158":139,"_159":277,"_161":22,"_107":278,"_101":279,"_163":177,"_165":280,"_166":22,"_167":-5,"_168":519,"_99":520},[],[258,275],[258],{"_105":285,"_95":286,"_155":287,"_157":-5,"_158":139,"_159":288,"_161":22,"_107":289,"_101":32,"_163":164,"_165":-5,"_166":22,"_167":-5,"_168":523,"_99":527},[524],{"_105":292,"_95":293,"_155":294,"_157":287,"_158":139,"_159":295,"_161":22,"_107":296,"_101":297,"_163":177,"_165":298,"_166":22,"_167":-5,"_168":525,"_99":526},[],[286,293],[286],{"_105":303,"_95":304,"_155":305,"_157":-5,"_158":139,"_159":102,"_161":22,"_107":306,"_101":307,"_163":308,"_165":309,"_166":22,"_167":-5,"_168":529,"_99":530},[],[304],{"_105":313,"_95":314,"_155":315,"_157":-5,"_158":139,"_159":316,"_161":22,"_107":317,"_101":187,"_163":308,"_165":318,"_166":22,"_167":-5,"_168":532,"_99":533},[],[314],{"_105":322,"_95":323,"_155":324,"_157":-5,"_158":139,"_159":325,"_161":22,"_107":326,"_101":32,"_163":308,"_165":327,"_166":22,"_167":-5,"_168":535,"_99":536},[],[323],{"_105":331,"_95":332,"_155":333,"_157":-5,"_158":139,"_159":334,"_161":22,"_107":335,"_101":336,"_163":337,"_165":338,"_166":22,"_167":-5,"_168":538,"_99":539},[],[332],{"_105":342,"_95":343,"_155":344,"_157":-5,"_158":139,"_159":223,"_161":22,"_107":345,"_101":160,"_163":177,"_165":346,"_166":22,"_167":-5,"_168":541,"_99":542},[],[343],{"_105":350,"_95":351,"_155":352,"_157":-5,"_158":139,"_159":160,"_161":22,"_107":353,"_101":32,"_163":308,"_165":354,"_166":22,"_167":-5,"_168":544,"_99":545},[],[351],{"_105":358,"_95":359,"_155":360,"_157":-5,"_158":139,"_159":361,"_161":22,"_107":362,"_101":32,"_163":177,"_165":363,"_166":22,"_167":-5,"_168":547,"_99":548},[],[359],{"_105":367,"_95":368,"_155":369,"_157":-5,"_158":139,"_159":370,"_161":22,"_107":371,"_101":176,"_163":308,"_165":372,"_166":22,"_167":-5,"_168":550,"_99":551},[],[368],{"_105":376,"_95":377,"_155":378,"_157":-5,"_158":139,"_159":379,"_161":22,"_107":380,"_101":381,"_163":177,"_165":382,"_166":22,"_167":-5,"_168":553,"_99":554},[],[377],{"_105":386,"_95":387,"_155":388,"_157":-5,"_158":139,"_159":389,"_161":22,"_107":390,"_101":391,"_163":177,"_165":392,"_166":22,"_167":-5,"_168":556,"_99":557},[],[387],{"_105":396,"_95":397,"_155":398,"_157":-5,"_158":139,"_159":399,"_161":22,"_107":400,"_101":241,"_163":177,"_165":401,"_166":22,"_167":-5,"_168":559,"_99":560},[],[397],{"_105":405,"_95":406,"_155":407,"_157":-5,"_158":139,"_159":408,"_161":22,"_107":409,"_101":241,"_163":177,"_165":410,"_166":22,"_167":-5,"_168":562,"_99":563},[],[406],{"_105":414,"_95":415,"_155":416,"_157":-5,"_158":139,"_159":417,"_161":22,"_107":418,"_101":419,"_163":177,"_165":420,"_166":22,"_167":-5,"_168":565,"_99":566},[],[415],{"_105":424,"_95":193,"_155":425,"_157":-5,"_158":139,"_159":426,"_161":22,"_107":427,"_101":381,"_163":428,"_165":429,"_166":22,"_167":-5,"_168":568,"_99":569},[],[193],[483,485,488,491,495,497,500,504,506,509,513,515,518,522,524,528,531,534,537,540,543,546,549,552,555,558,561,564,567],{"_105":154,"_95":100,"_155":156,"_157":-5,"_158":139,"_159":160,"_161":22,"_107":452,"_101":32,"_163":164,"_165":-5,"_166":22,"_167":-5,"_99":572},[100],[574,576,578],{"_105":171,"_95":172,"_155":173,"_157":156,"_158":139,"_159":174,"_161":22,"_107":443,"_101":176,"_163":177,"_165":178,"_166":22,"_167":-5,"_99":575},[100,172],{"_105":182,"_95":183,"_155":184,"_157":156,"_158":139,"_159":185,"_161":22,"_107":446,"_101":187,"_163":177,"_165":188,"_166":22,"_167":-5,"_99":577},[100,183],{"_105":192,"_95":193,"_155":194,"_157":156,"_158":139,"_159":195,"_161":22,"_107":449,"_101":160,"_163":177,"_165":197,"_166":22,"_167":-5,"_99":579},[100,193],"upstream",{"_105":142,"_107":582,"_464":583,"_95":43,"_140":106,"_101":466,"_141":467,"_143":468,"_469":470,"_109":-5,"_150":22,"_111":112,"_149":94,"_16":120,"_148":96},["D",1756498797190],["D",1757524966685],"showCompareCallout",true,"pull","ahead","behind","templates",[],"actionData","errors"]