[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_316":317,"_318":319},"routes/_app.x.$handle.$name",{"_11":12,"_13":14,"_15":16,"_17":18,"_38":-7,"_126":-5,"_19":127,"_128":129,"_130":131,"_132":133,"_134":135,"_21":136,"_137":-5,"_138":-5,"_139":24,"_140":141,"_142":90,"_143":-5,"_144":-5,"_145":146},"routes/_app.x.$handle.$name.branch.$branch.history_.$",{"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":22,"_23":24,"_25":26,"_27":28,"_29":24,"_30":-5},"handle","stevekrouse","name","attio-slack-summaries","branchName","main","path",".vtignore","project",{"_32":78,"_13":14,"_36":79,"_66":-5,"_80":24,"_81":82,"_83":82,"_84":85,"_86":-5,"_30":74,"_87":88,"_89":90,"_91":90,"_92":-5,"_93":26,"_40":41,"_94":-5,"_95":-5,"_96":-5,"_97":-5,"_98":99,"_100":99,"_101":102,"_103":102,"_104":102,"_105":99,"_106":99,"_52":107,"_108":109,"_110":111,"_112":24},"file",{"_70":71,"_13":18,"_72":21,"_73":24,"_77":-5},"isDirectory",false,"page",0,"history",[31],"hasNext","userId",{"_32":33,"_34":35,"_36":37,"_38":39,"_40":41,"_42":43,"_44":45,"_46":-5,"_47":-5,"_48":-5,"_49":-5,"_50":-5,"_51":-5,"_52":53,"_21":54,"_55":56,"_57":58,"_59":-5,"_60":-5,"_61":62},"id","c4b86640-8e6a-11f0-a4cc-0224a6c84d84","branchId","dbdc0d5c-785a-11f0-814d-0224a6c84d84","createdAt",["D",1757524966621],"version",340,"orgId","e81e7335-6d4c-4764-a902-d0962bbfa9f7","parentId","8e921e3e-7a02-11f0-8058-0224a6c84d84","incomingCommitId","b07a904a-8e65-11f0-8271-0224a6c84d84","aiChatMessageId","aiChatThreadId","aiChatThreadUserId","aiChatThreadTitle","source","clientLabel","user",{"_32":74,"_40":41,"_11":12,"_75":76},{"_70":71,"_13":18,"_72":21,"_73":24},"pull",{"_32":67,"_68":69},"merge",{"_34":64,"_13":16,"_38":65,"_66":-5},"revert","multiple","commits",[63],{"_32":33,"_34":35,"_36":37,"_38":39,"_40":41,"_42":43,"_44":45,"_46":-5,"_47":-5,"_48":-5,"_49":-5,"_50":-5,"_51":-5,"_52":53,"_21":54,"_55":56,"_57":58,"_59":-5},"881a5512-8515-11f0-b918-0224a6c84d84",36,"deletedAt","66a74e9a-8e6a-11f0-9b92-0224a6c84d84","title","Revamp of the template","fileId","c4b56c74-8e6a-11f0-a4cc-0224a6c84d84","fileType","deleted","a0bf3b31-15a5-4d5c-880e-4b1e22c9bc18","avatar","https://images.clerk.dev/uploaded/img_2PqHa2Gsy93xQrjh2w78Xu0cChW.jpeg","deletedAtVersion","dbd66352-785a-11f0-814d-0224a6c84d84",["D",1755099207883],"legacyEnvVars","privacy","public","httpPrivacy","description","Get debounced summaries of updates from Attio in Slack","imageUrl","pinnedFileId","0198a410-9925-735a-aaba-3c34a89d172d","pinPreview",true,"pinMigrated","screenshotVersion","likeCount","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_11":12,"_125":76},"org",{"_11":12,"_121":-5,"_75":76,"_30":74,"_122":123,"_124":24},"branch",{"_38":39,"_13":16,"_32":35,"_113":78,"_114":-5,"_115":-5,"_116":-5,"_117":-5,"_118":-5,"_119":14,"_120":12},"isOwned","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","tier","pro","canRestrictVals","profileImageUrl","adoptOrgId",{"_32":78,"_13":14,"_36":312,"_66":-5,"_80":24,"_81":82,"_83":82,"_84":85,"_86":-5,"_30":74,"_87":88,"_89":90,"_91":90,"_92":-5,"_93":26,"_40":41,"_94":-5,"_95":-5,"_96":-5,"_97":-5,"_98":99,"_100":99,"_101":102,"_103":102,"_104":102,"_105":99,"_106":99,"_52":313,"_108":314,"_110":315,"_112":24},"tree",[166,172,175,176,177,178,179,180,181,182,183],"files",[166,167,168,169,170,171,172,173,174,175,176,177,178,179,180,181,182,183],"counts",{"_154":26,"_155":156,"_157":158,"_159":160,"_161":162},"contents",[],{"_32":147,"_34":35,"_70":71,"_13":18,"_148":149,"_72":21,"_38":26,"_42":-5,"_36":150,"_151":39,"_152":-5,"_17":153},"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},"c4b56bca-8e6a-11f0-a4cc-0224a6c84d84","content",".git\n.gitignore\n.vscode\n.cursor\n.DS_Store\nnode_modules\nvendor\nCODE_REVIEW.md\ndeno.json\nbiome.json\ndev-helpers\nTODO.md\nAGENTS.md",["D",1757524966621],"branchVersion","label",[18],"pulls","branches",1,"forks",2,"envVars",{"_163":158,"_165":26},"connections",{"_163":26,"_164":26},"count","unfilledCount","emptyCount",{"_32":308,"_13":279,"_70":274,"_42":-5,"_34":35,"_151":39,"_186":90,"_36":309,"_38":26,"_72":268,"_148":-5,"_73":24,"_152":-5,"_191":310,"_17":311},{"_32":301,"_13":302,"_70":303,"_42":274,"_34":35,"_151":39,"_186":90,"_36":304,"_38":26,"_72":198,"_148":305,"_73":24,"_152":-5,"_191":306,"_17":307},{"_32":294,"_13":295,"_70":296,"_42":274,"_34":35,"_151":39,"_186":90,"_36":297,"_38":26,"_72":198,"_148":298,"_73":24,"_152":-5,"_191":299,"_17":300},{"_32":287,"_13":288,"_70":289,"_42":274,"_34":35,"_151":39,"_186":90,"_36":290,"_38":26,"_72":198,"_148":291,"_73":24,"_152":-5,"_191":292,"_17":293},{"_32":280,"_13":281,"_70":282,"_42":274,"_34":35,"_151":39,"_186":90,"_36":283,"_38":26,"_72":198,"_148":284,"_73":24,"_152":-5,"_191":285,"_17":286},{"_32":271,"_13":272,"_70":273,"_42":274,"_34":35,"_151":39,"_186":90,"_36":275,"_38":26,"_72":198,"_148":276,"_73":24,"_152":-5,"_191":277,"_17":278},{"_32":266,"_13":258,"_70":253,"_42":-5,"_34":35,"_151":39,"_186":90,"_36":267,"_38":26,"_72":268,"_148":-5,"_73":24,"_152":-5,"_191":269,"_17":270},{"_32":259,"_13":260,"_70":261,"_42":253,"_34":35,"_151":39,"_186":90,"_36":262,"_38":26,"_72":198,"_148":263,"_73":24,"_152":-5,"_191":264,"_17":265},{"_32":250,"_13":251,"_70":252,"_42":253,"_34":35,"_151":39,"_186":90,"_36":254,"_38":26,"_72":198,"_148":255,"_73":24,"_152":-5,"_191":256,"_17":257},{"_32":147,"_13":18,"_70":71,"_42":-5,"_34":35,"_151":39,"_186":90,"_36":247,"_38":26,"_72":21,"_148":149,"_73":24,"_152":-5,"_191":248,"_17":249},{"_32":240,"_13":241,"_70":242,"_42":-5,"_34":35,"_151":39,"_186":90,"_36":243,"_38":26,"_72":21,"_148":244,"_73":24,"_152":-5,"_191":245,"_17":246},{"_32":233,"_13":234,"_70":235,"_42":-5,"_34":35,"_151":39,"_186":90,"_36":236,"_38":26,"_72":21,"_148":237,"_73":24,"_152":-5,"_191":238,"_17":239},{"_32":225,"_13":226,"_70":227,"_42":-5,"_34":35,"_151":39,"_186":90,"_36":228,"_38":229,"_72":21,"_148":230,"_73":24,"_152":-5,"_191":231,"_17":232},{"_32":216,"_13":217,"_70":218,"_42":-5,"_34":35,"_151":39,"_186":90,"_36":219,"_38":220,"_72":221,"_148":222,"_73":24,"_152":-5,"_191":223,"_17":224},{"_32":209,"_13":210,"_70":211,"_42":-5,"_34":35,"_151":39,"_186":90,"_36":212,"_38":26,"_72":198,"_148":213,"_73":24,"_152":-5,"_191":214,"_17":215},{"_32":202,"_13":203,"_70":204,"_42":-5,"_34":35,"_151":39,"_186":90,"_36":205,"_38":158,"_72":198,"_148":206,"_73":24,"_152":-5,"_191":207,"_17":208},{"_32":194,"_13":195,"_70":196,"_42":-5,"_34":35,"_151":39,"_186":90,"_36":197,"_38":26,"_72":198,"_148":199,"_73":24,"_152":-5,"_191":200,"_17":201},{"_32":184,"_13":185,"_70":88,"_42":-5,"_34":35,"_151":39,"_186":90,"_36":187,"_38":188,"_72":189,"_148":190,"_73":24,"_152":-5,"_191":192,"_17":193},"c4b5d5d8-8e6a-11f0-a4cc-0224a6c84d84","webhook.ts","latest",["D",1757524966621],12,"http","import { Hono } from \"npm:hono\";\nimport { auth } from \"./core/auth.ts\";\nimport { handleWebhookEvent } from \"./core/webhook-handler.ts\";\nimport type { WebhookEvent, WebhookPayload } from \"./types.ts\";\n\nconst app = new Hono();\n\n// CUSTOMIZE: Add your list IDs here\nexport const listIds = [\n \"ea3b198f-859a-41fa-bb39-e0972cb71051\",\n];\n\nconst listIdSet = new Set(listIds);\n\napp.get(\"/\", (c) => c.text(\"Attio Slack Summaries: healthy\"));\n\napp.use(auth);\n\napp.post(\"/\", async (c) => {\n try {\n const data = (await c.req.json()) as WebhookPayload;\n console.log(`[Webhook] ${data.events.length} events received`);\n\n const relevantEvents = data.events.filter(\n (event): event is WebhookEvent => {\n if (\"list_id\" in event.id && event.id.list_id) {\n return listIdSet.has(event.id.list_id);\n }\n if (\"comment_id\" in event.id && event.list_id) {\n return listIdSet.has(event.list_id);\n }\n return false;\n },\n );\n\n for (const event of relevantEvents) {\n const result = await handleWebhookEvent(event);\n console.log(`[Webhook] Event ${event.event_type}: ${result}`);\n }\n\n return c.json(\"ok\");\n } catch (error) {\n console.error(\"[Webhook] Error processing request\", error);\n return c.json(\"Internal server error\", 500);\n }\n});\n\napp.onError((err: unknown) => Promise.reject(err));\n\nexport default app.fetch;","children",[],[185],"c4b5a7d4-8e6a-11f0-a4cc-0224a6c84d84","types.ts","c4b5a84c-8e6a-11f0-a4cc-0224a6c84d84",["D",1757524966621],"script","// CORE TYPES\n\nexport interface Actor {\n id: string | null;\n type: \"api-token\" | \"workspace-member\" | \"system\" | \"app\" | null;\n}\n\nexport interface Message {\n target: \"entry\" | \"comment\";\n listId: string;\n action: Action;\n recordName: string;\n recordId: string;\n actor: string;\n attributeName?: string;\n oldState?: string;\n newState?: string;\n updateType?: \"CREATE\" | \"REMOVE\" | \"CHANGE\";\n commentId?: string;\n commentText?: string;\n}\n\nexport const EventType = {\n ListEntryCreated: \"list-entry.created\",\n ListEntryUpdated: \"list-entry.updated\",\n ListEntryDeleted: \"list-entry.deleted\",\n CommentCreated: \"comment.created\",\n CommentResolved: \"comment.resolved\",\n CommentUnresolved: \"comment.unresolved\",\n CommentDeleted: \"comment.deleted\",\n} as const;\n\nexport type EventType = (typeof EventType)[keyof typeof EventType];\n\nexport const Action = {\n Created: \"created\",\n Updated: \"updated\",\n Deleted: \"deleted\",\n Resolved: \"resolved\",\n Unresolved: \"unresolved\",\n Initialized: \"initialized\",\n} as const;\n\nexport type Action = (typeof Action)[keyof typeof Action];\n\n// ATTIO ATTRIBUTE TYPES\n\ninterface AttioBaseAttributeValue {\n active_from: string;\n active_until: string | null;\n created_by_actor: Actor;\n attribute_type: string;\n}\n\nexport interface AttioTextValue extends AttioBaseAttributeValue {\n value: string;\n attribute_type: \"text\";\n}\n\nexport interface AttioStatusValue extends AttioBaseAttributeValue {\n status: { id: Record; title: string };\n attribute_type: \"status\";\n}\n\nexport interface AttioSelectValue extends AttioBaseAttributeValue {\n option: { id: Record; title: string };\n attribute_type: \"select\";\n}\n\nexport interface AttioCheckboxValue extends AttioBaseAttributeValue {\n value: boolean;\n attribute_type: \"checkbox\";\n}\n\nexport interface AttioCurrencyValue extends AttioBaseAttributeValue {\n currency_value: number;\n currency_code: string | null;\n attribute_type: \"currency\";\n}\n\nexport interface AttioNumberValue extends AttioBaseAttributeValue {\n value: number;\n attribute_type: \"number\";\n}\n\nexport interface AttioRatingValue extends AttioBaseAttributeValue {\n value: number;\n attribute_type: \"rating\";\n}\n\nexport interface AttioDateValue extends AttioBaseAttributeValue {\n value: string;\n attribute_type: \"date\";\n}\n\nexport interface AttioTimestampValue extends AttioBaseAttributeValue {\n value: string;\n attribute_type: \"timestamp\";\n}\n\nexport interface AttioPersonalNameValue extends AttioBaseAttributeValue {\n first_name: string;\n last_name: string;\n full_name: string;\n attribute_type: \"personal-name\";\n}\n\nexport interface AttioEmailAddressValue extends AttioBaseAttributeValue {\n email_address: string;\n attribute_type: \"email-address\";\n}\n\nexport interface AttioPhoneNumberValue extends AttioBaseAttributeValue {\n phone_number: string;\n attribute_type: \"phone-number\";\n}\n\nexport interface AttioActorReferenceValue extends AttioBaseAttributeValue {\n referenced_actor_id: string | null;\n attribute_type: \"actor-reference\";\n}\n\nexport interface AttioDomainValue extends AttioBaseAttributeValue {\n domain: string;\n attribute_type: \"domain\";\n}\n\nexport interface AttioLocationValue extends AttioBaseAttributeValue {\n attribute_type: \"location\";\n}\n\nexport interface AttioRecordReferenceValue extends AttioBaseAttributeValue {\n target_object: string;\n target_record_id: string;\n attribute_type: \"record-reference\";\n}\n\nexport interface AttioInteractionValue extends AttioBaseAttributeValue {\n interaction_type: string;\n attribute_type: \"interaction\";\n}\n\nexport type AttioAttributeValue =\n | AttioStatusValue\n | AttioSelectValue\n | AttioActorReferenceValue\n | AttioRecordReferenceValue\n | AttioCurrencyValue\n | AttioTextValue\n | AttioCheckboxValue\n | AttioDateValue\n | AttioTimestampValue\n | AttioNumberValue\n | AttioRatingValue\n | AttioPersonalNameValue\n | AttioEmailAddressValue\n | AttioPhoneNumberValue\n | AttioDomainValue\n | AttioLocationValue\n | AttioInteractionValue;\n\n// WEBHOOK TYPES\n\nexport interface WebhookEvent {\n event_type: EventType;\n id: {\n workspace_id: string;\n list_id?: string;\n entry_id?: string;\n comment_id?: string;\n };\n // List entry fields\n parent_record_id?: string;\n parent_object_id?: string;\n // Comment fields\n entry_id?: string;\n list_id?: string;\n record_id?: string;\n object_id?: string;\n // Common\n actor: Actor;\n}\n\nexport interface WebhookPayload {\n events: WebhookEvent[];\n}\n\n// ATTIO API TYPES\n\nexport interface AttioListEntry {\n id: { list_id: string; entry_id: string };\n parent_record_id: string;\n parent_object: string;\n entry_values: { [key: string]: AttioAttributeValue[] };\n}\n\nexport interface AttioRecord {\n id: { record_id: string };\n values: { [key: string]: AttioAttributeValue[] };\n}\n\nexport interface AttioComment {\n id: { comment_id: string };\n content_plaintext: string;\n entry_id: string;\n list_id: string;\n}\n\nexport interface AttioWorkspaceMember {\n first_name: string;\n last_name: string;\n}\n\nexport interface AttioList {\n id: { list_id: string };\n name: string;\n parent_object: string[];\n}\n\nexport interface AttioObject {\n singular_noun: string | null;\n}\n\nexport type AttioResource =\n | AttioComment\n | AttioRecord\n | AttioListEntry\n | AttioWorkspaceMember\n | AttioObject\n | AttioList;\n\n// STATE MANAGEMENT TYPES\n\nexport interface StateData {\n id: string;\n type: \"entry\" | \"comment\";\n action: Action;\n timestamp: number;\n listId: string;\n entryId: string;\n rawData: AttioListEntry | AttioComment;\n metadata: {\n recordId?: string;\n objectId?: string;\n actor?: Actor;\n };\n}\n\nexport interface StateRow {\n id: number;\n entryId: string;\n listId: string;\n timestamp: number;\n stateData: string;\n}\n",[],[195],"c4b5ce62-8e6a-11f0-a4cc-0224a6c84d84","slack.ts","0198a410-9925-735a-aaba-3788690b3b53",["D",1757524966621],"import type { KnownBlock } from \"npm:@slack/types\";\nimport { IncomingWebhook } from \"npm:@slack/webhook\";\nimport { titleCase } from \"npm:text-title-case\";\nimport type { Message } from \"./types.ts\";\n\n// Edit the sections below to customize how your Slack messages look.\n// Examples show what each setting controls.\n\n// MESSAGE APPEARANCE SETTINGS\n\nconst SLACK_CONFIG = {\n // How much of a comment to show before truncating\n maxCommentLength: 150, // \"Long comment text...\" after 150 chars\n\n // Whether to group changes by entry\n groupByEntry: true, // true = group changes per entry in a list\n\n // Whether to allow emojis in message headers\n allowEmojis: true, // true = \"📝 Updates\" vs false = \"Updates\"\n};\n\n// MESSAGE TEMPLATES\n\nconst MESSAGE_TEMPLATES = {\n // When someone creates a new entry: \"John added Acme Corp\"\n entryCreated: (actor: string, name: string) => `${actor} added ${name}`,\n\n // When someone deletes an entry: \"John removed Acme Corp\"\n entryDeleted: (actor: string, name: string) => `${actor} removed ${name}`,\n\n // When someone adds a comment: \"John commented: 'Great meeting!'\"\n commentAdded: (actor: string, text: string) => {\n const quotedText = text ? `\"${text}\"` : \"\";\n return `${actor} commented ${quotedText}`.trim();\n },\n\n // When someone deletes a comment: \"John deleted a comment\"\n commentDeleted: (actor: string) => `${actor} deleted a comment`,\n\n // When someone resolves a comment: \"John resolved a comment\"\n commentResolved: (actor: string) => `${actor} resolved a comment`,\n\n // When someone unresolves a comment: \"John unresolved a comment\"\n commentUnresolved: (actor: string) => `${actor} unresolved a comment`,\n\n // When a field changes: \"Status: Draft → Published\"\n fieldChanged: (field: string, oldValue: string, newValue: string) =>\n `*${field}*: ${oldValue} → ${newValue}`,\n\n // When a field is set for first time: \"Status set to Published\"\n fieldSet: (field: string, newValue: string) => `*${field}*: set to ${newValue}`,\n\n // When a field is cleared: \"Status unset\"\n fieldUnset: (field: string, oldValue: string) => `*${field}*: unset (was ${oldValue})`,\n};\n\n// LINK FORMATSv\n\nconst LINK_FORMATS = {\n // Link to a entry: clickable name that opens in Attio\n entry: (workspaceSlug: string, objectSlug: string, recordId: string, name: string) =>\n ``,\n\n // Link to a comment: clickable \"comment\" that opens in Attio\n comment: (workspaceSlug: string, commentId: string) =>\n ``,\n\n // Link to commented action: clickable \"commented\" that opens the comment\n commentAction: (workspaceSlug: string, commentId: string) =>\n ``,\n};\n\n// ADVANCED: System functions (don't edit unless you know what you're doing)\n\nlet webhookInstance: IncomingWebhook | null = null;\n\nfunction getWebhookInstance(): IncomingWebhook {\n if (!webhookInstance) {\n const webhookUrl = Deno.env.get(\"SLACK_WEBHOOK_URL\");\n if (!webhookUrl) throw new Error(\"SLACK_WEBHOOK_URL is not set\");\n webhookInstance = new IncomingWebhook(webhookUrl);\n }\n return webhookInstance;\n}\n\nexport async function slack(msg: { blocks: KnownBlock[] }) {\n await getWebhookInstance().send(msg);\n}\n\nexport function buildSlackPayload(\n header: string,\n workspaceSlug: string,\n objectSlug: string,\n messages: Message[],\n): { blocks: KnownBlock[] } {\n // Build the header\n const blocks: KnownBlock[] = [\n {\n type: \"header\",\n text: { type: \"plain_text\", text: header, emoji: SLACK_CONFIG.allowEmojis },\n },\n ];\n\n // Handle simple create/delete messages\n const simpleMessages = messages.filter(\n (msg) =>\n (msg.action === \"created\" || msg.action === \"deleted\") && msg.target === \"entry\",\n );\n\n if (simpleMessages.length > 0) {\n const simpleText = simpleMessages\n .map((msg) => {\n const recordLink = LINK_FORMATS.entry(\n workspaceSlug,\n objectSlug,\n msg.recordId,\n msg.recordName,\n );\n const template =\n msg.action === \"created\"\n ? MESSAGE_TEMPLATES.entryCreated\n : MESSAGE_TEMPLATES.entryDeleted;\n return `• ${template(msg.actor, recordLink)}`;\n })\n .join(\"\\n\");\n\n blocks.push({\n type: \"section\",\n text: { type: \"mrkdwn\", text: simpleText },\n });\n }\n\n // Handle updates and comments (grouped by entry if enabled)\n const entryMessages = messages.filter(\n (msg) => msg.action === \"updated\" || msg.target === \"comment\",\n );\n\n if (SLACK_CONFIG.groupByEntry) {\n const grouped = Object.groupBy(entryMessages, (msg) => msg.recordId);\n\n for (const [recordId, entryMsgs] of Object.entries(grouped)) {\n if (!entryMsgs?.length) continue;\n\n const entryLink = LINK_FORMATS.entry(\n workspaceSlug,\n objectSlug,\n recordId,\n entryMsgs[0].recordName,\n );\n\n const entryText = entryMsgs\n .map((msg) => {\n let content = \"\";\n\n if (msg.target === \"comment\") {\n content = formatCommentMessage(msg, workspaceSlug);\n } else if (msg.updateType) {\n const attribute = titleCase(msg.attributeName || \"\");\n content = formatUpdateMessage(\n msg.updateType,\n attribute,\n msg.oldState,\n msg.newState,\n );\n }\n\n return `• ${content}`;\n })\n .join(\"\\n\");\n\n blocks.push({\n type: \"section\",\n text: { type: \"mrkdwn\", text: `*${entryLink}*\\n${entryText}` },\n });\n }\n } else {\n const allText = entryMessages\n .map((msg) => {\n let content = \"\";\n\n if (msg.target === \"comment\") {\n content = formatCommentMessage(msg, workspaceSlug);\n } else if (msg.updateType) {\n const attribute = titleCase(msg.attributeName || \"\");\n content = formatUpdateMessage(\n msg.updateType,\n attribute,\n msg.oldState,\n msg.newState,\n );\n }\n\n return `• ${content}`;\n })\n .join(\"\\n\");\n\n if (allText) {\n blocks.push({\n type: \"section\",\n text: { type: \"mrkdwn\", text: allText },\n });\n }\n }\n\n return { blocks };\n}\n\nfunction formatCommentMessage(msg: Message, workspaceSlug: string): string {\n const truncatedText = msg.commentText\n ? truncate(msg.commentText, SLACK_CONFIG.maxCommentLength)\n : \"\";\n\n const { commentAction, comment } = LINK_FORMATS;\n const { commentAdded, commentDeleted, commentResolved, commentUnresolved } =\n MESSAGE_TEMPLATES;\n\n switch (msg.action) {\n case \"created\": {\n const actionLink = commentAction(workspaceSlug, msg.commentId || \"\");\n return commentAdded(msg.actor, truncatedText).replace(\"commented\", actionLink);\n }\n case \"deleted\":\n return commentDeleted(msg.actor);\n case \"resolved\": {\n const resolvedLink = comment(workspaceSlug, msg.commentId || \"\");\n return `${commentResolved(msg.actor).replace(\"comment\", resolvedLink)}`;\n }\n case \"unresolved\": {\n const unresolvedLink = comment(workspaceSlug, msg.commentId || \"\");\n return `${commentUnresolved(msg.actor).replace(\"comment\", unresolvedLink)}`;\n }\n default:\n return comment(workspaceSlug, msg.commentId || \"\");\n }\n}\n\nfunction formatUpdateMessage(\n updateType: \"CREATE\" | \"REMOVE\" | \"CHANGE\",\n attribute: string,\n oldValue: string = \"\",\n newValue: string = \"\",\n): string {\n const { fieldSet, fieldUnset, fieldChanged } = MESSAGE_TEMPLATES;\n switch (updateType) {\n case \"CREATE\":\n return fieldSet(attribute, newValue);\n case \"REMOVE\":\n return fieldUnset(attribute, oldValue);\n case \"CHANGE\":\n return fieldChanged(attribute, oldValue, newValue);\n default:\n return `*${attribute}* updated`;\n }\n}\n\nfunction truncate(s: string, maxChars: number): string {\n return s.length <= maxChars ? s : `${s.substring(0, maxChars - 3).trim()}...`;\n}\n",[],[203],"c4b598ac-8e6a-11f0-a4cc-0224a6c84d84","formatters.ts","c4b59924-8e6a-11f0-a4cc-0224a6c84d84",["D",1757524966621],"import diff, { type Difference } from \"npm:microdiff\";\nimport { getActorName, getRecord, getRecordName } from \"./core/api-client.ts\";\nimport type {\n AttioActorReferenceValue,\n AttioAttributeValue,\n AttioCheckboxValue,\n AttioCurrencyValue,\n AttioDateValue,\n AttioDomainValue,\n AttioEmailAddressValue,\n AttioInteractionValue,\n AttioLocationValue,\n AttioNumberValue,\n AttioPersonalNameValue,\n AttioPhoneNumberValue,\n AttioRatingValue,\n AttioRecordReferenceValue,\n AttioSelectValue,\n AttioStatusValue,\n AttioTextValue,\n AttioTimestampValue,\n Message,\n} from \"./types.ts\";\n\n// CUSTOMIZE: How Attio attributes display in Slack\n// Edit the formatters below to change how different attribute types\n// appear in your Slack messages. Examples show: input → output\n\n// TEXT & SELECTIONS\n\nconst textFormatters = {\n // Plain text values: \"Hello world\" → \"Hello world\"\n text: (av: AttioTextValue) => av.value,\n\n // Status values: Status object → \"Active\"\n status: (av: AttioStatusValue) => av.status.title,\n\n // Dropdown selections: Option object → \"Option Name\"\n select: (av: AttioSelectValue) => av.option.title,\n\n // Checkboxes: true → \"✅\", false → \"❌\"\n checkbox: (av: AttioCheckboxValue) => (av.value ? \"✅\" : \"❌\"),\n};\n\n// NUMBERS & CURRENCY\n\nconst numberFormatters = {\n // Currency: {value: 1000, code: \"USD\"} → \"$1,000.00\"\n currency: (av: AttioCurrencyValue) => {\n return new Intl.NumberFormat(\"en-US\", {\n style: \"currency\",\n currency: av.currency_code,\n }).format(Number(av.currency_value));\n },\n\n // Numbers: 1000 → \"1,000\"\n number: (av: AttioNumberValue) => av.value.toString(),\n\n // Ratings: 4 → \"4\" (could add stars: \"****\")\n rating: (av: AttioRatingValue) => av.value.toString(),\n};\n\n// DATES & TIME\n\nconst dateFormatters = {\n // Dates: \"2024-01-01\" → \"1/1/2024\"\n date: (av: AttioDateValue) =>\n av.value ? new Date(av.value).toLocaleDateString() : \"\",\n\n // Timestamps: \"2024-01-01T10:30:00Z\" → \"1/1/2024\"\n timestamp: (av: AttioTimestampValue) =>\n av.value ? new Date(av.value).toLocaleDateString() : \"\",\n};\n\n// PEOPLE, C CONTACTS\n\nconst peopleFormatters = {\n // Names: \"John Doe\" → \"John Doe\"\n \"personal-name\": (av: AttioPersonalNameValue) => {\n if (av.full_name) return av.full_name;\n },\n\n // Emails: \"john@example.com\" → \"john@example.com\"\n \"email-address\": (av: AttioEmailAddressValue) => av.email_address,\n\n // Phone numbers: \"+1234567890\" → \"+1234567890\"\n \"phone-number\": (av: AttioPhoneNumberValue) => av.phone_number,\n\n // Workspace members: User ID → \"John Doe\" (fetched from Attio)\n \"actor-reference\": async (av: AttioActorReferenceValue) => {\n try {\n return await getActorName(\"workspace-member\", av.referenced_actor_id);\n } catch {\n return av.referenced_actor_id;\n }\n },\n};\n\n// LINKS & LOCATIONS\n\nconst linkFormatters = {\n // Domains: \"example.com\" → \"example.com\"\n domain: (av: AttioDomainValue) => av.domain,\n\n // Locations: Address object → \"123 Main St, City, State\"\n location: (av: AttioLocationValue) => Object.values(av).filter(Boolean).join(\", \"),\n\n // Record references: Record ID → Record Name (fetched from Attio)\n \"record-reference\": async (av: AttioRecordReferenceValue) => {\n try {\n return getRecordName(\n await getRecord({\n objectId: av.target_object,\n recordId: av.target_record_id,\n }),\n );\n } catch {\n return av.target_record_id;\n }\n },\n\n // Interactions: Interaction type → \"meeting\", \"call\", etc.\n interaction: (av: AttioInteractionValue) => av.interaction_type,\n};\n\n// INTERNAL FUNCTIONS\n\ntype FormatterFunction = (attributeValue: T) => Promise | string;\n\n// Combine all formatters into one object for the system to use\nexport const valueFormatters: {\n [K in AttioAttributeValue[\"attribute_type\"]]: FormatterFunction<\n Extract\n >;\n} = {\n text: textFormatters.text,\n status: textFormatters.status,\n select: textFormatters.select,\n checkbox: textFormatters.checkbox,\n currency: numberFormatters.currency,\n number: numberFormatters.number,\n rating: numberFormatters.rating,\n date: dateFormatters.date,\n timestamp: dateFormatters.timestamp,\n \"personal-name\": peopleFormatters[\"personal-name\"],\n \"email-address\": peopleFormatters[\"email-address\"],\n \"phone-number\": peopleFormatters[\"phone-number\"],\n \"actor-reference\": peopleFormatters[\"actor-reference\"],\n domain: linkFormatters.domain,\n location: linkFormatters.location,\n \"record-reference\": linkFormatters[\"record-reference\"],\n interaction: linkFormatters.interaction,\n};\n\n// Internal function - formats a single attribute value\nasync function formatAttributeValue(attrValue: AttioAttributeValue): Promise {\n const formatter =\n valueFormatters[attrValue.attribute_type as keyof typeof valueFormatters];\n\n if (formatter) {\n return await (formatter as FormatterFunction)(attrValue);\n }\n\n const fallbackValue = Object.values(\n attrValue as unknown as Record,\n ).find(Boolean);\n return String(fallbackValue);\n}\n\n// Internal function - processes changes and creates messages (don't edit)\nexport async function processChangesToMessages(\n oldEntryValues: Record,\n newEntryValues: Record,\n recordName: string,\n recordId: string,\n actor: string,\n listId: string,\n): Promise {\n const changes: Difference[] = diff(oldEntryValues, newEntryValues);\n const changesByAttribute = new Map();\n\n for (const change of changes) {\n const attributeName = String(change.path[0]);\n if (!changesByAttribute.has(attributeName)) {\n changesByAttribute.set(attributeName, []);\n }\n const changes = changesByAttribute.get(attributeName);\n if (changes) {\n changes.push(change);\n }\n }\n\n const messages: Message[] = [];\n\n for (const [attributeName, attributeChanges] of changesByAttribute) {\n const changeTypes = new Set(attributeChanges.map((change) => change.type));\n\n if (changeTypes.size > 1) {\n throw new Error(\n `Multiple change types for ${attributeName}: ${Array.from(changeTypes).join(\n \", \",\n )}`,\n );\n }\n\n const oldState = changeTypes.has(\"CREATE\")\n ? \"\"\n : oldEntryValues[attributeName]?.[0]\n ? await formatAttributeValue(oldEntryValues[attributeName][0])\n : \"\";\n const newState = changeTypes.has(\"REMOVE\")\n ? \"\"\n : newEntryValues[attributeName]?.[0]\n ? await formatAttributeValue(newEntryValues[attributeName][0])\n : \"\";\n\n messages.push({\n target: \"entry\" as const,\n listId,\n action: \"updated\" as const,\n recordName,\n recordId,\n actor,\n attributeName,\n oldState,\n newState,\n updateType: Array.from(changeTypes)[0],\n });\n }\n\n return messages;\n}\n",[],[210],"c4b5cb92-8e6a-11f0-a4cc-0224a6c84d84","alert.ts","77d6a72a-785c-11f0-aa8c-0224a6c84d84",["D",1757524966621],24,"interval","import { processAlerts } from \"./core/alert-processor.ts\";\nimport { listIds } from \"./webhook.ts\";\n\nexport default async function () {\n await processAlerts(listIds);\n}\n",[],[217],"c4b5c926-8e6a-11f0-a4cc-0224a6c84d84","README.md","0198a410-9925-735a-aaba-2eb864dbe3ff",["D",1757524966621],14,"# Attio List Slack Notifications\n\nThis val sends customizable notifications about events on your Attio\n[lists](https://attio.com/help/reference/managing-your-data/lists) to Slack.\n\n📺 For a video overview of this val, see this\n[loom video](https://www.loom.com/share/fd01bfd797b84fb599ca16110bd8c5bc?sid=64b0a583-ed05-41d3-b0e8-248595f200ed).\n\n $\"Sample$ \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. Configure your lists in [`webhook.ts`](./webhook.ts):\n - Update the `listIds` array with your Attio list IDs\n - To find your list's id, navigate to the list and copy the path segment\n after `collection`:\n `https://app.attio.com//collection/`\n5. Run [`setup.ts`](./scripts/setup.ts) to set up the database and Attio webhook\n6. Run [`bootstrap.ts`](./scripts/bootstrap.ts) to initialize the database with\n the current state of your configured lists.\n7. Go trigger some Attio events and see the message in Slack! (If you want them\n faster, you can run [`alert.ts`](./alert.ts) manually.)\n\n## Documentation\n\n- [CUSTOMIZATION.md](./CUSTOMIZATION.md) - Details on customization options, ie\n Slack formatting\n- [DETAILS.md](./DETAILS.md) - Details on how the system works",[],[226],"c4b5914a-8e6a-11f0-a4cc-0224a6c84d84","DETAILS.md","c4b591b8-8e6a-11f0-a4cc-0224a6c84d84",["D",1757524966621],"# Details\n\nThe vals uses Attio webhooks to receive real-time notifications about changes to your [lists](https://attio.com/help/reference/managing-your-data/lists). Each webhook event triggers:\n\n1. **Event Reception** [`webhook.ts`](./webhook.ts) - Validates and filters incoming events\n2. **State Storage** [`webhook-handler.ts`](./core/webhook-handler.ts) - Stores current state in SQLite\n3. **Change Detection** [`alert-processor.ts`](./core/alert-processor.ts) - Compares states to detect changes\n4. **Message Generation** [`formatters.ts`](./formatters.ts) - Formats changes into human readable strings\n5. **Slack Delivery** [`slack.ts`](./slack.ts) - Sends formatted messages to Slack\n\nAttio webhooks return very thin events. They contain only IDs, not human-readable data or change details. In order to send human readable messages to Slack, we need do a lot of work to enrich the events with data fro the Attio API.\n\nThe most involved part in this codebase was figuring out how to transform these events into data that could be used to track the state of list entries and comments. I've accomplished this here by getting the state of the entry/comment when a webhook event comes in, storing that state in the database. We go from a webhook event that looks like this:\n\n```json\n{\n \"event_type\": \"list-entry.updated\",\n \"id\": {\n \"workspace_id\": \"d1cf50ae-67ee-4109-b25a-d6223d6a780f\",\n \"list_id\": \"ea3b198f-859a-41fa-bb39-e0972cb71051\",\n \"entry_id\": \"255c52fc-85e8-4d90-8127-c6b139e3ca37\",\n \"attribute_id\": \"a6336f45-006c-4f08-b371-14ee9546ebee\"\n },\n \"parent_object_id\": \"54439a10-8518-49e7-b268-41663063cdab\",\n \"parent_record_id\": \"6bc23aa2-5c5c-4341-949f-9177fd0e6bd5\",\n \"actor\": {\n \"type\": \"workspace-member\",\n \"id\": \"f2bbd1ae-29b5-4020-9590-f9afe2b4a276\"\n }\n}\n```\n\nTo a typescript state object that looks like this:\n\n```ts\n// Stored state includes complete API response\nconst stateData = {\n id: \"255c52fc-85e8-4d90-8127-c6b139e3ca37\",\n type: \"entry\",\n action: \"updated\",\n timestamp: 1757439109123,\n listId: \"ea3b198f-859a-41fa-bb39-e0972cb71051\",\n entryId: \"255c52fc-85e8-4d90-8127-c6b139e3ca37\",\n rawData: {\n // Stored state includes complete API response\n id: { ... },\n parent_record_id: \"6bc23aa2-5c5c-4341-949f-9177fd0e6bd5\",\n parent_object: \"companies\",\n created_at: \"2025-09-09T16:55:11.986000000Z\",\n entry_values: {\n // Crucially, includes data about the entry's attributes\n stage: [\n {\n active_from: \"2025-09-09T16:55:11.986000000Z\",\n active_until: null,\n created_by_actor: { ... },\n status: {\n id: { ... },\n title: \"Prospecting\",\n ...\n },\n attribute_type: \"status\",\n },\n ],\n // more attributes...\n },\n metadata: {...},\n}};\n```\n\nMessages are generated by comparing consecutive states to detect changes. Diffing and message generation is done at run-time when the cron job triggers. This cuts down on the complexity of the database schema (differences and messages are not stored). By storing the entire raw API response, we also get a rich set of data that can be used to customize notifications.\n\n## What will you get notifications about?\n\nCurrently, the system only tracks the state of two things: list entries and comments on those list entries. The Attio webhook is [set up](./core/auth.ts) to accept the following events:\n\n- `list-entry.created`\n- `list-entry.deleted`\n- `list-entry.updated`\n- `comment.created`\n- `comment.resolved`\n- `comment.unresolved`\n- `comment.deleted`\n\nThe logic of generating messages is not set up to handle states outside these two categories. The database is not set up to store data related to things other without _both_ a list id _and_ an entry id (see [here](./core/database.ts)).\n\nThis is especially relevant for comments. Attio comments can be associated with a record or a list entry (among other things). When a comment is added to a record, it is associated with the record, not the list entry. When a comment is added to a list entry, it is associated with the list entry, not the record. Because of this, **you will not see notifications for comments on records, even if those records are in a list you track**.\n\nSee this Attio help center [article](https://attio.com/help/reference/attio-101/attios-data-model/understanding-attio-data-model) for more on Attio's data model. See this Attio API [documentation](https://docs.attio.com/rest-api/overview) for more information on the types of events that Attio can send.\n\n## Appendix: Data flow diagram\n\nThe diagram below gives a more complete picture of how data flows through the system. \n $\"Sample$ ",[],[234],"c4b58db2-8e6a-11f0-a4cc-0224a6c84d84","CUSTOMIZATION.md","c4b58e20-8e6a-11f0-a4cc-0224a6c84d84",["D",1757524966621],"# Customization\n\nI have tried to organize the codebase for easy customization.\n\n- **User-facing files** (`formatters.ts`, `slack.ts`)\n- **Internal logic** is isolated in `core/` directory\n- **Type safety** ensures custom formatters match Attio attribute types\n\nThe sections below cover the customization options.\n\n## Customizing Attribute Formatters\n\nThe [`formatters.ts`](./formatters.ts) file controls how Attio attribute values appear in Slack messages. Formatters are functions that take an object of a type in `AttioAttributeValue` and return a `string`. Type-safety ensures that custom formatters match Attio attribute types. The formatter file is organized into sections for easy customization:\n\n**Text & Selections:**\n\n```typescript\nconst textFormatters = {\n text: (av: AttioTextValue) => av.value,\n status: (av: AttioStatusValue) => av.status.title,\n select: (av: AttioSelectValue) => av.option.title,\n checkbox: (av: AttioCheckboxValue) => av.value.toString(),\n};\n```\n\n**Numbers & Currency:**\n\n```typescript\nconst numberFormatters = {\n currency: (av: AttioCurrencyValue) => {\n return new Intl.NumberFormat(\"en-US\", {\n style: \"currency\",\n currency: av.currency_code,\n }).format(Number(av.currency_value));\n },\n number: (av: AttioNumberValue) => av.value.toString(),\n};\n```\n\n**Dates, People, Links, etc.** - Each category has its own section with examples showing input / output.\n\n## Customizing Slack Messages\n\nThe [`slack.ts`](./slack.ts) file controls Slack message appearance. See the file for more examples and details.\n\n**Message Settings:**\n\n```typescript\nconst SLACK_CONFIG = {\n maxCommentLength: 150, // Comment truncation\n groupByEntry: true, // Group changes by entry (as in the image above)\n allowEmojis: true, // Enable emoji in headers\n};\n```\n\n**Message Templates:**\n\n```typescript\nconst MESSAGE_TEMPLATES = {\n entryCreated: (actor: string, name: string) => `${actor} added ${name}`,\n entryDeleted: (actor: string, name: string) => `${actor} removed ${name}`,\n fieldChanged: (field: string, oldValue: string, newValue: string) =>\n `*${field}*: ${oldValue} → ${newValue}`,\n // ... more templates\n};\n```\n\n**Link Formats:**\n\n```typescript\nconst LINK_FORMATS = {\n entry: (\n workspaceSlug: string,\n objectSlug: string,\n recordId: string,\n name: string\n ) =>\n ``,\n // ... more link formats\n};\n```\n",[],[241],["D",1757524966621],[],[18],"c4b5a5ae-8e6a-11f0-a4cc-0224a6c84d84","setup.ts","c4b5a61c-8e6a-11f0-a4cc-0224a6c84d84","019934a6-bcde-714d-ac43-4b352d43a3b4",["D",1757524966621],"import { createWebhook } from \"../core/auth.ts\";\nimport { createTable } from \"../core/database.ts\";\n\nasync function setup() {\n let didCreateWebhook = false;\n let didCreateTable = false;\n\n try {\n await createWebhook();\n console.log(\"[Setup] Created Attio webhook successfully\");\n didCreateWebhook = true;\n } catch (error) {\n console.error(\"[Setup] Error creating webhook\", error);\n }\n\n try {\n await createTable();\n console.log(\"[Setup] Created database table successfully\");\n didCreateTable = true;\n } catch (error) {\n console.error(\"[Setup] Error creating tables\", error);\n }\n\n if (didCreateWebhook && didCreateTable) {\n console.log(\"[Setup] Completed. Run 'scripts/bootstrap.ts' to seed initial data.\");\n } else {\n console.error(\"[Setup] Failed. Please check the logs for errors.\");\n }\n}\n\nawait setup();\n",[],[258,251],"scripts","c4b5a216-8e6a-11f0-a4cc-0224a6c84d84","bootstrap.ts","c4b5a298-8e6a-11f0-a4cc-0224a6c84d84",["D",1757524966621],"import { sqlite } from \"https://esm.town/v/std/sqlite?v=6\";\nimport { insertAttioState } from \"../core/database.ts\";\nimport type { AttioActorReferenceValue, AttioListEntry, StateData } from \"../types.ts\";\nimport { listIds } from \"../webhook.ts\";\n\nconst apiKey = Deno.env.get(\"ATTIO_API_KEY\");\nif (!apiKey) throw new Error(\"ATTIO_API_KEY is not set\");\n\nasync function getInitialListState(\n listId: string,\n): Promise<{ entries: AttioListEntry[]; rawData: StateData[] }> {\n try {\n const response = await fetch(\n `https://api.attio.com/v2/lists/${listId}/entries/query`,\n {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${apiKey}`,\n \"Content-Type\": \"application/json\",\n },\n body: \"{}\",\n },\n );\n const { data } = (await response.json()) as { data: AttioListEntry[] };\n\n const rawData = data.map((entry) => ({\n id: entry.id.entry_id,\n type: \"entry\" as const,\n action: \"initialized\" as const,\n timestamp: Date.now(),\n listId,\n entryId: entry.id.entry_id,\n rawData: entry,\n metadata: {\n recordId: entry.parent_record_id,\n objectId: entry.parent_object,\n actor: entry.entry_values.created_by?.[0]\n ? {\n id:\n (entry.entry_values.created_by[0] as AttioActorReferenceValue)\n .referenced_actor_id || null,\n type: \"workspace-member\" as const,\n }\n : { id: null, type: \"system\" as const },\n },\n }));\n\n return { entries: data, rawData };\n } catch (error) {\n console.error(`Error fetching list ${listId}`, error);\n throw error;\n }\n}\n\nconsole.log(\"[Bootstrap] Starting process...\");\n\nfor (const listId of listIds) {\n const existsResult = await sqlite.execute({\n sql: `SELECT entry_id FROM attio_state WHERE list_id = ? limit 1`,\n args: [listId],\n });\n\n if (existsResult.rows.length > 0) {\n console.log(`[Bootstrap] List ${listId}: already in database (skipped)`);\n continue;\n }\n\n try {\n const { rawData } = await getInitialListState(listId);\n\n await Promise.all(\n rawData.map((state) => insertAttioState(state.entryId, listId, state)),\n );\n\n console.log(`[Bootstrap] List ${listId}: ${rawData.length} entries initialized`);\n } catch (error) {\n console.error(\n `[Bootstrap] Error initializing list ${listId}:`,\n error instanceof Error ? error.message : String(error),\n );\n }\n}\n\nconsole.log(\"[Bootstrap] Process completed\");\n",[],[258,260],"c4b5af0e-8e6a-11f0-a4cc-0224a6c84d84",["D",1757524966621],"directory",[173,174],[258],"c4b588d0-8e6a-11f0-a4cc-0224a6c84d84","webhook-handler.ts","c4b58948-8e6a-11f0-a4cc-0224a6c84d84","019934a6-bcde-714d-ac43-45d4c361f7bc",["D",1757524966621],"import type {\n Action,\n AttioComment,\n AttioListEntry,\n EventType,\n StateData,\n WebhookEvent,\n} from \"../types.ts\";\nimport { getComment, getEntry } from \"./api-client.ts\";\nimport { insertAttioState } from \"./database.ts\";\n\ntype EventHandler = (event: WebhookEvent) => Promise;\n\nasync function handleListEntryEvent(event: WebhookEvent): Promise {\n const action = event.event_type.split(\".\")[1] as Action;\n\n if (!event.id.list_id || !event.id.entry_id) {\n console.warn(\n `[Webhook] Missing list_id or entry_id for event ${event.event_type}:`,\n );\n return `Skipped ${action} entry - missing IDs`;\n }\n\n let entry: AttioListEntry | null = null;\n if (action !== \"deleted\") {\n try {\n entry = await getEntry({\n listId: event.id.list_id,\n entryId: event.id.entry_id,\n });\n } catch (error) {\n console.warn(`[Webhook] Failed to fetch entry for ${action} event:`, error);\n }\n }\n\n const rawState: StateData = {\n id: event.id.entry_id,\n type: \"entry\",\n action,\n timestamp: Date.now(),\n listId: event.id.list_id,\n entryId: event.id.entry_id,\n rawData:\n entry ||\n ({\n id: { list_id: event.id.list_id, entry_id: event.id.entry_id },\n parent_record_id: event.parent_record_id || \"\",\n parent_object: event.parent_object_id || \"\",\n entry_values: {},\n } as AttioListEntry),\n metadata: {\n recordId: event.parent_record_id,\n objectId: event.parent_object_id,\n actor: event.actor,\n },\n };\n\n await insertAttioState(event.id.entry_id, event.id.list_id, rawState);\n return `${action} entry (${event.id.entry_id})`;\n}\n\nasync function handleCommentEvent(event: WebhookEvent): Promise {\n if (!event.entry_id || !event.list_id) {\n return \"Skipping non-entry comment\";\n }\n\n if (!event.id.comment_id) {\n console.warn(`[Webhook] Missing comment_id for event ${event.event_type}:`);\n return \"Skipped comment - missing comment_id\";\n }\n\n const action = event.event_type.split(\".\")[1] as Action;\n const commentData: AttioComment =\n action === \"deleted\"\n ? {\n id: { comment_id: event.id.comment_id },\n content_plaintext: \"\",\n entry_id: event.entry_id,\n list_id: event.list_id,\n }\n : await getComment(event.id.comment_id);\n\n const rawState: StateData = {\n id: event.id.comment_id,\n type: \"comment\",\n action,\n timestamp: Date.now(),\n listId: event.list_id,\n entryId: event.entry_id,\n rawData: commentData,\n metadata: {\n recordId: event.record_id,\n objectId: event.object_id,\n actor: event.actor,\n },\n };\n\n await insertAttioState(event.entry_id, event.list_id, rawState);\n return `handled comment event (${event.id.comment_id})`;\n}\n\nconst EVENT_ROUTER: Record = {\n \"list-entry.created\": handleListEntryEvent,\n \"list-entry.updated\": handleListEntryEvent,\n \"list-entry.deleted\": handleListEntryEvent,\n \"comment.created\": handleCommentEvent,\n \"comment.resolved\": handleCommentEvent,\n \"comment.unresolved\": handleCommentEvent,\n \"comment.deleted\": handleCommentEvent,\n} as const;\n\nexport function handleWebhookEvent(event: WebhookEvent): Promise {\n const handler = EVENT_ROUTER[event.event_type as EventType];\n\n if (!handler)\n return Promise.resolve(`Attio event type not supported: ${event.event_type}`);\n\n return handler(event);\n}\n",[],[279,272],"core","c4b58560-8e6a-11f0-a4cc-0224a6c84d84","database.ts","c4b585ce-8e6a-11f0-a4cc-0224a6c84d84",["D",1757524966621],"import { type ResultSet, sqlite } from \"https://esm.town/v/std/sqlite\";\nimport type { StateData, StateRow } from \"../types.ts\";\n\nconst sqlToStateRow = (row: ResultSet[\"rows\"][number]): StateRow => ({\n id: row[0] as number,\n entryId: row[1] as string,\n listId: row[2] as string,\n timestamp: row[3] as number,\n stateData: row[4] as string,\n});\n\nexport async function createTable() {\n await sqlite.batch([\n \"DROP TABLE IF EXISTS attio_state\",\n `CREATE TABLE attio_state (\n id INTEGER PRIMARY KEY,\n entry_id TEXT NOT NULL,\n list_id TEXT NOT NULL,\n timestamp INTEGER NOT NULL,\n state_data TEXT NOT NULL\n )`,\n ]);\n}\n\nexport async function insertAttioState(\n entryId: string,\n listId: string,\n stateData: StateData,\n) {\n await sqlite.execute({\n sql: `INSERT INTO attio_state (entry_id, list_id, timestamp, state_data) VALUES (?, ?, ?, ?)`,\n args: [entryId, listId, Date.now(), JSON.stringify(stateData)],\n });\n}\n\nexport async function getStateRows(\n target: \"comment\" | \"entry\",\n listIds: string[],\n watermark: number,\n): Promise {\n const placeholders = listIds.map(() => \"?\").join(\",\");\n\n const newRowsResult = await sqlite.execute({\n sql: `SELECT id, entry_id as entryId, list_id as listId, timestamp, state_data as stateData\n FROM attio_state\n WHERE timestamp > ? AND list_id IN (${placeholders}) AND json_extract(state_data, '$.type') = ?\n ORDER BY timestamp ASC`,\n args: [watermark, ...listIds, target],\n });\n\n const newRows = newRowsResult.rows.map(sqlToStateRow);\n\n if (newRows.length === 0) return [];\n\n const affectedEntryIds = [...new Set(newRows.map((row) => row.entryId))];\n\n const headStates: StateRow[] = [];\n for (const entryId of affectedEntryIds) {\n const headResult = await sqlite.execute({\n sql: `SELECT id, entry_id as entryId, list_id as listId, timestamp, state_data as stateData\n FROM attio_state\n WHERE entry_id = ? AND timestamp <= ? AND json_extract(state_data, '$.type') = ?\n ORDER BY timestamp DESC\n LIMIT 1`,\n args: [entryId, watermark, target],\n });\n\n if (headResult.rows.length > 0) {\n headStates.push(sqlToStateRow(headResult.rows[0]));\n }\n }\n\n const allRows = [...headStates, ...newRows].sort((a, b) => a.timestamp - b.timestamp);\n\n return allRows;\n}\n",[],[279,281],"c4b581b4-8e6a-11f0-a4cc-0224a6c84d84","auth.ts","c4b5822c-8e6a-11f0-a4cc-0224a6c84d84",["D",1757524966621],"import { blob } from \"https://esm.town/v/std/blob\";\nimport { httpEndpoint } from \"https://esm.town/v/std/utils/index.ts\";\nimport { Attio } from \"npm:attio-js\";\nimport type { PostV2WebhooksEventTypeRequest } from \"npm:attio-js//models/operations/postv2webhooks\";\n\nconst attio = new Attio();\n\ntype AttioWebhookConfig = {\n data: {\n targetUrl: string;\n subscriptions: { eventType: string; filter: null }[];\n id: { workspaceId: string; webhookId: string };\n status: string;\n createdAt: string;\n secret: string;\n };\n};\n\nconst ATTIO_WEBHOOK_KEY = \"ATTIO_WEBHOOK\";\n\nconst getAttioWebhookSecret = async (): Promise =>\n ((await blob.getJSON(ATTIO_WEBHOOK_KEY)) as AttioWebhookConfig).data.secret;\n\nconst subscriptions = [\n \"list-entry.created\",\n \"list-entry.updated\",\n \"list-entry.deleted\",\n \"comment.created\",\n \"comment.resolved\",\n \"comment.unresolved\",\n \"comment.deleted\",\n].map((e) => ({\n eventType: e as PostV2WebhooksEventTypeRequest,\n filter: null,\n}));\n\nexport async function createWebhook() {\n const result = await attio.webhooks.create({\n data: { targetUrl: await httpEndpoint(\"webhook.ts\"), subscriptions },\n });\n await blob.setJSON(ATTIO_WEBHOOK_KEY, result);\n}\n\nexport const auth = async (\n c: {\n req: {\n header: (name: string) => string | undefined;\n text: () => Promise;\n };\n json: (data: string, status: number) => unknown;\n },\n next: () => Promise,\n): Promise => {\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) as Response;\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(\"HMAC\", key, encoder.encode(webhookBody));\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) as Response;\n\n await next();\n};\n",[],[279,288],"c4b57dcc-8e6a-11f0-a4cc-0224a6c84d84","api-client.ts","c4b57e3a-8e6a-11f0-a4cc-0224a6c84d84",["D",1757524966621],"import type {\n AttioComment,\n AttioList,\n AttioListEntry,\n AttioObject,\n AttioRecord,\n AttioResource,\n AttioWorkspaceMember,\n} from \"../types.ts\";\n\nconst apiKey = Deno.env.get(\"ATTIO_API_KEY\");\nif (!apiKey) throw new Error(\"ATTIO_API_KEY is not set\");\n\nconst baseUrl = \"https://api.attio.com/v2\";\nconst options: RequestInit = {\n method: \"GET\",\n headers: { Authorization: `Bearer ${apiKey}` },\n};\n\nconst cache: Record = {};\n\nasync function get(path: string, cacheKey?: string): Promise {\n const key = cacheKey || path;\n const cached = (cache[key] as T) || null;\n if (cached) return cached;\n\n const response = await fetch(`${baseUrl}${path}`, options);\n if (!response.ok) throw new Error(`API request failed: ${response.status}`);\n\n const data = ((await response.json()) as { data: T }).data;\n cache[key] = data;\n\n return data;\n}\n\nexport const getRecord = ({\n objectId,\n recordId,\n}: {\n objectId: string;\n recordId: string;\n}) =>\n get(\n `/objects/${objectId}/records/${recordId}`,\n `object-${objectId}-${recordId}`,\n );\n\nfunction getValueFromAttribute(attr: unknown): string | undefined {\n if (!attr || typeof attr !== \"object\") return undefined;\n const obj = attr as Record;\n const value = obj.value || obj.domain || obj.full_name || obj.email_address;\n return typeof value === \"string\" ? value : undefined;\n}\n\nexport function getRecordName(record: AttioRecord): string {\n const names = [\n getValueFromAttribute(record.values.name?.[0]),\n getValueFromAttribute(record.values.domains?.[0]),\n getValueFromAttribute(record.values.email_addresses?.[0]),\n ];\n\n const name = names.find(Boolean);\n return name ? name.toString().trim() : \"Unknown Name\";\n}\n\nexport const getEntry = ({ listId, entryId }: { listId: string; entryId: string }) =>\n get(\n `/lists/${listId}/entries/${entryId}`,\n `list-${listId}-${entryId}`,\n );\n\nexport async function getActorName(type: string, id: string): Promise {\n switch (type) {\n case \"system\":\n return \"System\";\n case \"app\":\n return \"App\";\n case \"workspace-member\": {\n const member = await get(\n `/workspace_members/${id}`,\n `workspace-member-${id}`,\n );\n return `${member.first_name} ${member.last_name}`.trim();\n }\n default:\n return \"API Token\";\n }\n}\n\nexport const getComment = (commentId: string) =>\n get(`/comments/${commentId}`, `comment-${commentId}`);\n\nexport async function getWorkspaceSlug(): Promise {\n const response = await fetch(`${baseUrl}/self`, options);\n if (!response.ok) throw new Error(`API request failed: ${response.status}`);\n const data = await response.json();\n return data.workspace_slug as string;\n}\n\nexport async function getListInfo(\n listId: string,\n): Promise<{ listName: string; objectName: string; objectSlug: string }> {\n const list = await get(`/lists/${listId}`, `list-${listId}`);\n const object = await get(\n `/objects/${list.parent_object[0]}`,\n `object-${list.parent_object[0]}`,\n );\n const objectSlug = object.singular_noun?.toLowerCase() || \"unknown\";\n\n return {\n listName: list.name,\n objectName: list.parent_object[0],\n objectSlug,\n };\n}\n",[],[279,295],"c4b5716a-8e6a-11f0-a4cc-0224a6c84d84","alert-processor.ts","c4b571e2-8e6a-11f0-a4cc-0224a6c84d84",["D",1757524966621],"import { blob } from \"https://esm.town/v/std/blob\";\nimport { processChangesToMessages } from \"../formatters.ts\";\nimport { buildSlackPayload, slack } from \"../slack.ts\";\nimport type {\n AttioComment,\n AttioListEntry,\n Message,\n StateData,\n StateRow,\n} from \"../types.ts\";\nimport {\n getActorName,\n getListInfo,\n getRecord,\n getRecordName,\n getWorkspaceSlug,\n} from \"./api-client.ts\";\nimport { getStateRows } from \"./database.ts\";\n\nconst WATERMARK = \"ATTIO_ALERT_WATERMARK\";\n\nasync function enrichMessageMetadata(\n objectId: string,\n recordId: string,\n actorType: string,\n actorId: string,\n): Promise<{ recordName: string; recordId: string; actor: string }> {\n const record = await getRecord({ objectId, recordId });\n const recordName = getRecordName(record);\n const actor = await getActorName(actorType, actorId);\n\n return {\n recordName,\n recordId: record.id.record_id,\n actor,\n };\n}\n\nasync function createBaseMessage(\n state: StateData,\n listId: string,\n target: \"entry\" | \"comment\",\n): Promise> {\n if (state.type !== \"entry\") {\n throw new Error(\"createBaseMessage only works with AttioListEntry data\");\n }\n\n const metadata = await enrichMessageMetadata(\n (state.rawData as AttioListEntry).parent_object,\n (state.rawData as AttioListEntry).parent_record_id,\n state.metadata.actor?.type || \"\",\n state.metadata.actor?.id || \"\",\n );\n\n return {\n target,\n listId,\n ...metadata,\n };\n}\n\nasync function processCommentRow(row: StateRow): Promise {\n const state = JSON.parse(row.stateData) as StateData;\n if (state.type !== \"comment\") return null;\n\n const commentData = state.rawData as AttioComment;\n const commentId = commentData.id.comment_id;\n const commentText = commentData.content_plaintext;\n\n const metadata = await enrichMessageMetadata(\n state.metadata.objectId || \"\",\n state.metadata.recordId || \"\",\n state.metadata.actor?.type || \"\",\n state.metadata.actor?.id || \"\",\n );\n\n return {\n target: \"comment\",\n listId: row.listId,\n action: state.action,\n ...metadata,\n commentId,\n commentText,\n };\n}\n\nasync function processEntryRow(\n row: StateRow,\n previousState: StateData | null,\n): Promise<{ messages: Message[]; state: StateData }> {\n const state = JSON.parse(row.stateData) as StateData;\n if (state.type !== \"entry\" || state.action === \"initialized\") {\n return { messages: [], state };\n }\n\n if (state.action === \"created\" || state.action === \"deleted\") {\n const baseMessage = await createBaseMessage(state, row.listId, \"entry\");\n const messages: Message[] = [\n {\n ...baseMessage,\n action: state.action,\n attributeName: \"Entry\",\n oldState: state.action === \"created\" ? \"\" : \"Present\",\n newState: state.action === \"created\" ? \"Created\" : \"\",\n updateType: state.action === \"created\"\n ? (\"CREATE\" as const)\n : (\"REMOVE\" as const),\n },\n ];\n return { messages, state };\n }\n\n if (state.action === \"updated\" && previousState) {\n if (previousState.type !== \"entry\" || state.type !== \"entry\") {\n throw new Error(\"Entry diffing only works with AttioListEntry data\");\n }\n\n const prevEntryValues =\n (previousState.rawData as AttioListEntry).entry_values;\n const curEntryValues = (state.rawData as AttioListEntry).entry_values;\n\n const baseMessage = await createBaseMessage(state, row.listId, \"entry\");\n const messages = await processChangesToMessages(\n prevEntryValues,\n curEntryValues,\n baseMessage.recordName,\n baseMessage.recordId,\n baseMessage.actor,\n row.listId,\n );\n return { messages, state };\n }\n\n return { messages: [], state };\n}\n\nasync function processStateRows(rows: StateRow[], type: \"comment\" | \"entry\") {\n if (type === \"comment\") {\n return (await Promise.all(rows.map(processCommentRow))).filter(\n (msg): msg is Message => msg !== null,\n );\n }\n\n const grouped = Object.groupBy(rows, (r) => r.entryId);\n const messages: Message[] = [];\n\n for (const entryRows of Object.values(grouped)) {\n if (!entryRows.length) continue;\n entryRows.sort((a, b) => a.timestamp - b.timestamp);\n let previous: StateData | null = null;\n for (const row of entryRows) {\n const { messages: rowMessages, state } = await processEntryRow(\n row,\n previous,\n );\n messages.push(...rowMessages);\n previous = state;\n }\n }\n return messages;\n}\n\nasync function getWatermark(): Promise {\n const watermark = await blob.getJSON(WATERMARK);\n return typeof watermark === \"number\" && Number.isFinite(watermark)\n ? watermark\n : 0;\n}\n\nexport async function processAlerts(listIds: string[], debug: boolean = false) {\n const watermark = debug ? 0 : await getWatermark();\n\n const comments = await getStateRows(\"comment\", listIds, watermark);\n const entries = await getStateRows(\"entry\", listIds, watermark);\n\n if (comments.length === 0 && entries.length === 0) return;\n\n const commentMessages = await processStateRows(comments, \"comment\");\n const entryMessages = await processStateRows(entries, \"entry\");\n const messages = [...commentMessages, ...entryMessages];\n\n if (debug) {\n console.log(\n `${commentMessages.length} comments, ${entryMessages.length} entries, ${messages.length} total`,\n );\n }\n\n if (messages.length > 0) {\n const workspaceSlug = await getWorkspaceSlug();\n const listInfo = await Promise.all(listIds.map(getListInfo));\n\n for (let i = 0; i < listIds.length; i++) {\n const { listName, objectSlug } = listInfo[i];\n const listMessages = messages.filter((msg) => msg.listId === listIds[i]);\n if (!listMessages.length) continue;\n\n console.log(\n `${\n debug ? \"Formatting\" : \"Sending\"\n } ${listMessages.length} messages for ${listName}`,\n );\n const payload = buildSlackPayload(\n `Events for ${listName}`,\n workspaceSlug,\n objectSlug,\n listMessages,\n );\n debug ? console.log(payload) : await slack(payload);\n }\n }\n\n if (!debug) {\n const maxTimestamp = Math.max(\n ...[...comments, ...entries].map((r) => r.timestamp),\n );\n await blob.setJSON(WATERMARK, maxTimestamp);\n }\n}",[],[279,302],"c4b5acd4-8e6a-11f0-a4cc-0224a6c84d84",["D",1757524966621],[167,168,169,170,171],[279],["D",1755099207883],{"_11":12,"_125":76},{"_11":12,"_121":-5,"_75":76,"_30":74,"_122":123,"_124":24},{"_38":39,"_13":16,"_32":35,"_113":78,"_114":-5,"_115":-5,"_116":-5,"_117":-5,"_118":-5,"_119":14,"_120":12},"ctx",{"_52":-5,"_144":349,"_350":351,"_352":353,"_354":24,"_355":24,"_356":24,"_357":90,"_358":-5,"_359":-7,"_360":-7,"_361":26,"_362":24,"_363":24,"_364":-5,"_365":24,"_366":24,"_367":24,"_368":-5},"ENV",{"_320":321,"_322":323,"_324":16,"_325":326,"_327":328,"_329":330,"_331":332,"_333":334,"_335":336,"_337":338,"_339":340,"_341":342,"_343":344,"_345":346,"_347":348},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","fdb67791413f4386b4dbf18f354029a617f6160f","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"]

History · .vtignore