\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",[],[288],{"_105":296,"_95":100,"_156":297,"_158":-5,"_159":139,"_160":298,"_162":22,"_107":299,"_101":32,"_164":282,"_166":300,"_167":22,"_168":-5,"_169":301,"_99":302},"001f349c-8a89-11f0-b998-0224a6c84d84","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",[],[100],{"_105":304,"_95":305,"_156":306,"_158":-5,"_159":139,"_160":307,"_162":22,"_107":308,"_101":309,"_164":310,"_166":311,"_167":22,"_168":-5,"_169":312,"_99":313},"683c5606-8a8c-11f0-8832-0224a6c84d84","alert.ts","0198f872-ab3d-72d6-8b63-561fc22f3cce",432,["D",1757099609682],17,"interval","import { config } from \"./config.ts\";\nimport { 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 { lists, workspaceName } = config;\n const recentMessages = await getRecentMessages();\n\n for (const list of lists) {\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: {\n message: AttioMessage;\n message_id: number;\n event_id: number;\n }[] = recentMessages.map((m) => {\n const message = JSON.parse(m.message);\n return {\n message,\n message_id: m.id as number,\n event_id: m.event_id as number,\n };\n });\n\n const filteredMessages = messages.filter(\n (m) => m.message.list_id === list.listId,\n );\n\n if (!filteredMessages.length) {\n console.log(\"No messages, exiting\");\n return;\n }\n\n await slack(\n buildSlackPayload(\n list.notificationHeader,\n workspaceName,\n list.objectName,\n filteredMessages.map((m) => m.message),\n ),\n );\n\n await markAsAlerted(\n filteredMessages.map((m) => m.message_id as number),\n \"attio_messages\",\n );\n\n await markAsAlerted(\n filteredMessages.map((m) => m.event_id as number),\n \"attio_events\",\n );\n }\n}\n",[],[305],{"_105":315,"_95":316,"_156":317,"_158":-5,"_159":139,"_160":318,"_162":22,"_107":319,"_101":161,"_164":178,"_166":320,"_167":22,"_168":-5,"_169":321,"_99":322},"3bcdea0a-8823-11f0-9fb9-0224a6c84d84","auth.ts","0198f872-ab3d-72d6-8b63-5bdcd7504b62",34,["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",[],[316],{"_105":324,"_95":325,"_156":326,"_158":-5,"_159":139,"_160":327,"_162":22,"_107":328,"_101":270,"_164":178,"_166":329,"_167":22,"_168":-5,"_169":330,"_99":331},"80879602-8a8d-11f0-a24f-0224a6c84d84","config.ts","0081dfc0-8a89-11f0-831d-0224a6c84d84",442,["D",1757100079976],"export type ListConfig = {\n listId: string;\n notificationHeader: string;\n objectName: string;\n};\n\nexport type Config = {\n workspaceName: string;\n lists: ListConfig[];\n};\n\nexport const config: Config = {\n workspaceName: \"nbltd\",\n lists: [\n {\n listId: \"ea3b198f-859a-41fa-bb39-e0972cb71051\",\n notificationHeader: \"Sales List Events\",\n objectName: \"company\",\n },\n ],\n};\n",[],[325],{"_105":333,"_95":334,"_156":335,"_158":-5,"_159":139,"_160":336,"_162":22,"_107":337,"_101":338,"_164":178,"_166":339,"_167":22,"_168":-5,"_169":340,"_99":341},"a06aee42-8a8d-11f0-b12c-0224a6c84d84","enrich-entry.ts","b92a9868-8869-11f0-9963-0224a6c84d84",444,["D",1757100133470],15,"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 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",[],[334],{"_105":343,"_95":344,"_156":345,"_158":-5,"_159":139,"_160":346,"_162":22,"_107":347,"_101":348,"_164":178,"_166":349,"_167":22,"_168":-5,"_169":350,"_99":351},"b5c945ba-8a8b-11f0-a9b8-0224a6c84d84","handle-webhook.ts","add16062-8870-11f0-b5f8-0224a6c84d84",423,["D",1757099310169],42,"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 list_id: event.id.list_id,\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 list_id: event.id.list_id,\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 list_id: enrichedEntry.list_id,\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 list_id: event.list_id,\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",[],[344],{"_105":353,"_95":354,"_156":355,"_158":-5,"_159":139,"_160":356,"_162":22,"_107":357,"_101":358,"_164":178,"_166":359,"_167":22,"_168":-5,"_169":360,"_99":361},"80971dac-8a8d-11f0-807b-0224a6c84d84","initialize-entries.ts","b918d7a4-8869-11f0-9de8-0224a6c84d84",443,["D",1757100080081],6,"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 console.log(\"Getting initial list state for list\", list_id);\n\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",[],[354],{"_105":363,"_95":364,"_156":365,"_158":-5,"_159":139,"_160":366,"_162":22,"_107":367,"_101":368,"_164":178,"_166":369,"_167":22,"_168":-5,"_169":370,"_99":371},"c6bdd196-8898-11f0-b86d-0224a6c84d84","openai.ts","0198f872-ab3d-72d6-8b63-66ef3d40bf76",248,["D",1756885019880],3,"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",[],[364],{"_105":373,"_95":374,"_156":375,"_158":-5,"_159":139,"_160":376,"_162":22,"_107":377,"_101":378,"_164":178,"_166":379,"_167":22,"_168":-5,"_169":380,"_99":381},"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",[],[374],{"_105":383,"_95":194,"_156":384,"_158":-5,"_159":139,"_160":102,"_162":22,"_107":385,"_101":386,"_164":387,"_166":388,"_167":22,"_168":-5,"_169":389,"_99":390},"2e62bdba-8a8e-11f0-bcc2-0224a6c84d84","0198f872-ab3d-72d6-8b63-7a839a611511",["D",1757100371659],16,"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 console.log(\"Received webhook payload\", data);\n\n console.log(\"Received webhook events\", data.events.length);\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",[],[194],"files",[153,171,182,192,202,209,218,229,236,246,257,264,275,286,295,303,314,323,332,342,352,362,372,382],"counts",{"_395":32,"_396":177,"_397":161,"_398":188},"pulls","branches","forks","envVars","contents",[],{"_105":296,"_95":100,"_156":297,"_158":-5,"_159":139,"_160":298,"_162":22,"_107":402,"_101":32,"_164":282,"_166":300,"_167":22,"_168":-5,"_99":403},["D",1757098146561],[100],"upstreamProject",{"_105":406,"_95":96,"_113":407,"_114":-5,"_111":112,"_23":408},"dbd66352-785a-11f0-814d-0224a6c84d84","Get debounced summaries of updates from Attio in Slack",{"_93":409,"_131":410},"stevekrouse","https://images.clerk.dev/uploaded/img_2PqHa2Gsy93xQrjh2w78Xu0cChW.jpeg","upstreamBranch",{"_105":142,"_107":413,"_414":415,"_95":43,"_140":106,"_101":224,"_141":416,"_143":417,"_418":419,"_109":-5,"_150":22,"_111":112,"_149":94,"_16":120,"_148":96},["D",1756498797190],"updatedAt",["D",1757524966685],"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":426,"_151":431,"_391":504,"_282":505,"_399":507,"_508":509,"_512":513,"_514":-5,"_515":32,"_516":517,"_518":519},{"_105":106,"_95":96,"_107":427,"_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":428,"_133":429,"_136":430,"_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},[432,444,453,462,468,471,474,477,480,483,486,489,492,495,498,501],{"_105":154,"_95":155,"_156":157,"_158":-5,"_159":139,"_160":161,"_162":22,"_107":163,"_101":32,"_164":165,"_166":-5,"_167":22,"_168":-5,"_169":433,"_99":443},[434,437,440],{"_105":172,"_95":173,"_156":174,"_158":157,"_159":139,"_160":175,"_162":22,"_107":176,"_101":177,"_164":178,"_166":179,"_167":22,"_168":-5,"_169":435,"_99":436},[],[155,173],{"_105":183,"_95":184,"_156":185,"_158":157,"_159":139,"_160":186,"_162":22,"_107":187,"_101":188,"_164":178,"_166":189,"_167":22,"_168":-5,"_169":438,"_99":439},[],[155,184],{"_105":193,"_95":194,"_156":195,"_158":157,"_159":139,"_160":196,"_162":22,"_107":197,"_101":161,"_164":178,"_166":198,"_167":22,"_168":-5,"_169":441,"_99":442},[],[155,194],[155],{"_105":203,"_95":204,"_156":205,"_158":-5,"_159":139,"_160":206,"_162":22,"_107":207,"_101":32,"_164":165,"_166":-5,"_167":22,"_168":-5,"_169":445,"_99":452},[446,449],{"_105":210,"_95":211,"_156":212,"_158":205,"_159":139,"_160":213,"_162":22,"_107":214,"_101":32,"_164":178,"_166":215,"_167":22,"_168":-5,"_169":447,"_99":448},[],[204,211],{"_105":219,"_95":220,"_156":221,"_158":205,"_159":139,"_160":222,"_162":22,"_107":223,"_101":224,"_164":178,"_166":225,"_167":22,"_168":-5,"_169":450,"_99":451},[],[204,220],[204],{"_105":230,"_95":231,"_156":232,"_158":-5,"_159":139,"_160":233,"_162":22,"_107":234,"_101":32,"_164":165,"_166":-5,"_167":22,"_168":-5,"_169":454,"_99":461},[455,458],{"_105":237,"_95":238,"_156":239,"_158":232,"_159":139,"_160":240,"_162":22,"_107":241,"_101":242,"_164":178,"_166":243,"_167":22,"_168":-5,"_169":456,"_99":457},[],[231,238],{"_105":247,"_95":248,"_156":249,"_158":232,"_159":139,"_160":250,"_162":22,"_107":251,"_101":252,"_164":178,"_166":253,"_167":22,"_168":-5,"_169":459,"_99":460},[],[231,248],[231],{"_105":258,"_95":259,"_156":260,"_158":-5,"_159":139,"_160":261,"_162":22,"_107":262,"_101":32,"_164":165,"_166":-5,"_167":22,"_168":-5,"_169":463,"_99":467},[464],{"_105":265,"_95":266,"_156":267,"_158":260,"_159":139,"_160":268,"_162":22,"_107":269,"_101":270,"_164":178,"_166":271,"_167":22,"_168":-5,"_169":465,"_99":466},[],[259,266],[259],{"_105":276,"_95":277,"_156":278,"_158":-5,"_159":139,"_160":279,"_162":22,"_107":280,"_101":281,"_164":282,"_166":283,"_167":22,"_168":-5,"_169":469,"_99":470},[],[277],{"_105":287,"_95":288,"_156":289,"_158":-5,"_159":139,"_160":290,"_162":22,"_107":291,"_101":188,"_164":282,"_166":292,"_167":22,"_168":-5,"_169":472,"_99":473},[],[288],{"_105":296,"_95":100,"_156":297,"_158":-5,"_159":139,"_160":298,"_162":22,"_107":299,"_101":32,"_164":282,"_166":300,"_167":22,"_168":-5,"_169":475,"_99":476},[],[100],{"_105":304,"_95":305,"_156":306,"_158":-5,"_159":139,"_160":307,"_162":22,"_107":308,"_101":309,"_164":310,"_166":311,"_167":22,"_168":-5,"_169":478,"_99":479},[],[305],{"_105":315,"_95":316,"_156":317,"_158":-5,"_159":139,"_160":318,"_162":22,"_107":319,"_101":161,"_164":178,"_166":320,"_167":22,"_168":-5,"_169":481,"_99":482},[],[316],{"_105":324,"_95":325,"_156":326,"_158":-5,"_159":139,"_160":327,"_162":22,"_107":328,"_101":270,"_164":178,"_166":329,"_167":22,"_168":-5,"_169":484,"_99":485},[],[325],{"_105":333,"_95":334,"_156":335,"_158":-5,"_159":139,"_160":336,"_162":22,"_107":337,"_101":338,"_164":178,"_166":339,"_167":22,"_168":-5,"_169":487,"_99":488},[],[334],{"_105":343,"_95":344,"_156":345,"_158":-5,"_159":139,"_160":346,"_162":22,"_107":347,"_101":348,"_164":178,"_166":349,"_167":22,"_168":-5,"_169":490,"_99":491},[],[344],{"_105":353,"_95":354,"_156":355,"_158":-5,"_159":139,"_160":356,"_162":22,"_107":357,"_101":358,"_164":178,"_166":359,"_167":22,"_168":-5,"_169":493,"_99":494},[],[354],{"_105":363,"_95":364,"_156":365,"_158":-5,"_159":139,"_160":366,"_162":22,"_107":367,"_101":368,"_164":178,"_166":369,"_167":22,"_168":-5,"_169":496,"_99":497},[],[364],{"_105":373,"_95":374,"_156":375,"_158":-5,"_159":139,"_160":376,"_162":22,"_107":377,"_101":378,"_164":178,"_166":379,"_167":22,"_168":-5,"_169":499,"_99":500},[],[374],{"_105":383,"_95":194,"_156":384,"_158":-5,"_159":139,"_160":102,"_162":22,"_107":385,"_101":386,"_164":387,"_166":388,"_167":22,"_168":-5,"_169":502,"_99":503},[],[194],[432,434,437,440,444,446,449,453,455,458,462,464,468,471,474,477,480,483,486,489,492,495,498,501],{"_105":296,"_95":100,"_156":297,"_158":-5,"_159":139,"_160":298,"_162":22,"_107":402,"_101":32,"_164":282,"_166":300,"_167":22,"_168":-5,"_99":506},[100],[],"upstream",{"_105":142,"_107":510,"_414":511,"_95":43,"_140":106,"_101":224,"_141":416,"_143":417,"_418":419,"_109":-5,"_150":22,"_111":112,"_149":94,"_16":120,"_148":96},["D",1756498797190],["D",1757524966685],"showCompareCallout",true,"pull","ahead","behind",14,"templates",[],"actionData","errors"]