\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`: `https://app.attio.com//collection/`\n5. (Optional) Customize attribute extractors in [`webhook.ts`](./webhook.ts):\n - Modify the `customExtractors` object to customize how\n attribute values are formatted in Slack messages\n - See the \"Customizing Attribute Extractors\" section below for details\n6. Go to [`setup.ts`](./scripts/setup.ts) and click run to set up the events\n database and Attio webhook\n7. Go to [`alert.ts`](./alert.ts) and click run to set up the\n cron job\n8. Go trigger some Attio events and see the message in Slack!\n\n## Adding a list\n\nIf you want to get notifications about more than one list from your workspace,\nsimply add the list ID to the `listIds` array in [`webhook.ts`](./webhook.ts).\n\nThen, go to [`bootstrap.ts`](./scripts/bootstrap.ts) and run the script. This will\ninitialize the new list in SQLite.\n\n## Customization & Extension\n\n### Customizing Attribute Extractors\n\nThis template provides a flexible system for customizing how Attio attribute values are formatted in Slack messages. You can override any of the built-in extractors or add custom formatting.\n\n#### Quick Start - Using the Webhook File\n\nThe easiest way to customize extractors is directly in the `webhook.ts` file:\n\n```typescript\n// webhook.ts\nexport const customExtractors: CustomExtractors = {\n // Add emojis to text values\n text: (value) => `✨ ${value.value} ✨`,\n\n // Format status with custom styling\n status: (value) => `🔸 ${value.status.title}`,\n\n // Format currency with custom symbols\n currency: (value) =>\n `💰 ${Intl.NumberFormat(\"en-US\", {\n style: \"currency\",\n currency: value.currency_code,\n }).format(Number(value.currency_value))}`,\n\n // Format dates with custom format\n date: (value) =>\n new Date(value.value).toLocaleDateString(\"en-US\", {\n year: \"numeric\",\n month: \"long\",\n day: \"numeric\",\n }),\n};\n```\n\n#### Available Attribute Types\n\nYou can customize any of these Attio attribute types:\n\n**Common Types:**\n\n- `text` - Simple text values\n- `status` - Status values with titles\n- `select` - Dropdown/select values with option titles\n- `date` - Date values\n- `timestamp` - Timestamp values\n- `rating` - Numeric rating values\n- `checkbox` - Boolean checkbox values\n- `currency` - Currency values with proper formatting\n- `record-reference` - References to other records (fetches record name)\n- `actor-reference` - References to users/actors (fetches actor name)\n\n**Uncommon Types:**\n\n- `domain` - Domain values\n- `email-address` - Email address values\n- `interaction` - Interaction values with type and timestamp\n- `location` - Location values with address formatting\n- `number` - Numeric values\n- `personal-name` - Personal name values\n- `phone-number` - Phone number values\n\n#### Advanced Customization\n\nFor more complex customizations, you can:\n\n1. **Override extractors programmatically:**\n\n ```typescript\n import { overrideExtractors } from \"./extractors/index.ts\";\n\n overrideExtractors({\n text: (value) => `✨ ${value.value} ✨`,\n });\n ```\n\n2. **Pass custom extractors to functions:**\n\n ```typescript\n import { handleWebhookEvent } from \"./services/webhook-handler.ts\";\n\n const customExtractors = {\n text: (value) => `Custom: ${value.value}`,\n };\n\n await handleWebhookEvent(event, listIds, customExtractors);\n ```\n\n3. **Use the bootstrap function with custom extractors:**\n\n ```typescript\n import { initialize } from \"./scripts/bootstrap.ts\";\n\n await initialize(customExtractors);\n ```\n\n### Template Examples\n\nHere are some common customization patterns you can use as templates:\n\n#### Basic Text Formatting\n\n```typescript\nexport const customExtractors: CustomExtractors = {\n text: (value) => `📝 ${value.value}`,\n status: (value) => `🔸 ${value.status.title}`,\n select: (value) => `📋 ${value.option.title}`,\n};\n```\n\n#### Currency and Number Formatting\n\n```typescript\nexport const customExtractors: CustomExtractors = {\n currency: (value) => `💰 $${value.currency_value.toLocaleString()}`,\n number: (value) => `🔢 ${value.value.toLocaleString()}`,\n rating: (value) => `⭐ ${value.value}/5`,\n};\n```\n\n#### Date and Time Formatting\n\n```typescript\nexport const customExtractors: CustomExtractors = {\n date: (value) => `📅 ${new Date(value.value).toLocaleDateString()}`,\n timestamp: (value) => `⏰ ${new Date(value.value).toLocaleString()}`,\n};\n```\n\n#### Boolean and Checkbox Formatting\n\n```typescript\nexport const customExtractors: CustomExtractors = {\n checkbox: (value) => (value.value ? \"✅ Yes\" : \"❌ No\"),\n};\n```\n\n#### Contact Information Formatting\n\n```typescript\nexport const customExtractors: CustomExtractors = {\n \"email-address\": (value) => `📧 ${value.email_address}`,\n \"phone-number\": (value) => `📞 ${value.original_phone_number}`,\n \"personal-name\": (value) => `👤 ${value.full_name}`,\n};\n```\n\n#### Location Formatting\n\n```typescript\nexport const customExtractors: CustomExtractors = {\n location: (value) => {\n const parts = [\n value.line_1,\n value.locality,\n value.region,\n value.country_code,\n ].filter(Boolean);\n return `📍 ${parts.join(\", \")}`;\n },\n domain: (value) => `🌐 ${value.domain}`,\n};\n```\n\n## Advanced Custom Formatting\n\n```typescript\nexport const customExtractors: CustomExtractors = {\n // Custom currency formatting with different symbols\n currency: (value) => {\n const symbol =\n value.currency_code === \"USD\"\n ? \"$\"\n : value.currency_code === \"EUR\"\n ? \"€\"\n : value.currency_code === \"GBP\"\n ? \"£\"\n : value.currency_code;\n return `${symbol}${Number(value.currency_value).toLocaleString()}`;\n },\n\n // Custom date formatting with relative time\n date: (value) => {\n const date = new Date(value.value);\n const now = new Date();\n const diffInDays = Math.floor(\n (now.getTime() - date.getTime()) / (1000 * 60 * 60 * 24)\n );\n\n if (diffInDays === 0) return `📅 Today`;\n if (diffInDays === 1) return `📅 Yesterday`;\n if (diffInDays < 7) return `📅 ${diffInDays} days ago`;\n\n return `📅 ${date.toLocaleDateString()}`;\n },\n\n // Custom status formatting with colors\n status: (value) => {\n const status = value.status.title.toLowerCase();\n if (status.includes(\"active\") || status.includes(\"open\"))\n return `🟢 ${value.status.title}`;\n if (status.includes(\"pending\") || status.includes(\"waiting\"))\n return `🟡 ${value.status.title}`;\n if (status.includes(\"closed\") || status.includes(\"completed\"))\n return `🔴 ${value.status.title}`;\n return `⚪ ${value.status.title}`;\n },\n};\n```\n\n### How to Use Template Examples\n\n1. Copy any of the examples above\n2. Paste them into your `webhook.ts` file, replacing the empty `customExtractors` object\n3. Uncomment and modify the extractors you want to customize\n4. Save the file and your customizations will be applied automatically\n\n### Adding Custom Attribute Formatters\n\nTo format custom Attio attribute types in your Slack messages, you can add them to the `customExtractors` object in `webhook.ts`:\n\n```typescript\n// webhook.ts\nexport const customExtractors: CustomExtractors = {\n // Add custom formatters for any attribute type\n \"custom-type\": (value) => value.customField,\n};\n```\n\nThe extractor system will automatically handle your custom formatters.\n\n### Customizing Message Format\n\nThe Slack message formatting is handled in `shared/slack.ts`. You can customize:\n\n- Message headers and structure\n- Link formatting\n- Text truncation\n- Message grouping logic\n\n### Adding New Event Types\n\nTo handle additional Attio webhook event types:\n\n1. Add the event type to `shared/types.ts`\n2. Update the webhook handler logic in `services/webhook-handler.ts`\n3. Add any new processing logic as needed\n\n### Database Schema Changes\n\nIf you need to modify the database schema:\n\n1. Update the table definitions in `services/sqlite.ts`\n2. Run the migration by executing `createTables()` in a script\n3. Update the corresponding TypeScript types in `shared/types.ts`\n\n### Environment Variables\n\nThe project uses these environment variables:\n\n- `ATTIO_API_KEY` - Your Attio API access token\n- `SLACK_WEBHOOK_URL` - Your Slack webhook URL\n\n### Error Handling\n\nThe project includes comprehensive error logging and graceful error handling throughout the webhook processing pipeline.\n\n## Deployment\n\n### Val Town Deployment\n\nThis project is designed to run on Val Town. To deploy:\n\n1. **Fork this val** on Val Town\n2. **Set environment variables** in the Val Town interface:\n - `ATTIO_API_KEY` - Your Attio API access token\n - `SLACK_WEBHOOK_URL` - Your Slack webhook URL\n3. **Run setup scripts** in order:\n - `scripts/setup.ts` - Creates database and webhook\n - `scripts/bootstrap.ts` - Seeds initial data\n4. **Set up the cron job** by running `alert.ts` and scheduling it\n5. **Test the webhook** by triggering some Attio events\n\n### Environment Variables\n\nRequired environment variables:\n\n- `ATTIO_API_KEY` - Attio API access token with read/write permissions\n- `SLACK_WEBHOOK_URL` - Slack incoming webhook URL\n\n### Health Monitoring\n\nThe application provides health check endpoints:\n\n- `GET /` - Basic health status\n- `GET /health` - Detailed health information\n\nMonitor these endpoints to ensure the service is running correctly.\n\n### Troubleshooting\n\n**Webhook not receiving events:**\n\n- Verify the webhook URL is correct in Attio\n- Check that the webhook is enabled for the right event types\n- Ensure the webhook secret is properly configured\n\n**Slack messages not appearing:**\n\n- Verify `SLACK_WEBHOOK_URL` is set correctly\n- Check Slack webhook permissions\n- Review logs for error messages\n\n**Database issues:**\n\n- Run `scripts/setup.ts` to recreate tables\n- Check Val Town SQLite storage limits\n- Verify database indexes are created properly\n\n## Project Structure\n\n```\nattio-slack-summaries/\n├── webhook.ts # Main HTTP endpoint - receives Attio webhooks\n├── alert.ts # Cron job - processes recent events & sends Slack summaries\n├── services/\n│ ├── alert-processor.ts # Alert processing logic\n│ ├── api-client.ts # Attio API client utilities\n│ ├── notifications.ts # Notification handling\n│ ├── sqlite.ts # Database operations - CRUD for webhook events & messages\n│ ├── webhook-auth.ts # Attio webhook management - creates/stores webhook configs\n│ └── webhook-handler.ts # Webhook event processing logic\n├── shared/\n│ ├── slack.ts # Slack integration - message formatting & webhook sending\n│ ├── enrich-state.ts # Data enrichment for CRM entries\n│ └── types.ts # Core application types and type definitions\n├── extractors/\n│ ├── index.ts # Attribute value extractors for all Attio types\n│ └── README.md # Documentation for the extractor system\n├── scripts/\n│ ├── setup.ts # One-time setup - creates DB tables & Attio webhook\n│ └── bootstrap.ts # Bootstrap script for initial setup\n└── dev-helpers/\n └── scratch.ts # Development utilities and testing helpers\n```\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 transformning these events into data that\ncould be used to track the state of entries in lists. I've accomplished this\nhere by storing the state of each entry in a SQLite database and then comparing\nsubsequent states to the previous state of the entry to determine the changes.\n\nThese state objects are then used to generate message objects that are also\nstored in the SQLite database. When the cron job runs, it takes these message\nobjects formats them into a nice payload and sends them to Slack.\n",[],[264],{"_105":273,"_95":274,"_156":275,"_158":-5,"_159":139,"_160":276,"_162":163,"_107":277,"_101":278,"_165":279,"_167":280,"_168":22,"_169":-5,"_170":281,"_99":282},"16fe32c4-8d01-11f0-a5bf-0224a6c84d84","alert.ts","01991ffd-643f-709d-8dee-d1ad9690adab",401,["D",1757369626845],15,"interval","import { processAlerts } from \"./core/alert-processor.ts\";\nimport { listIds } from \"./webhook.ts\";\n\nexport default async function () {\n await processAlerts(listIds);\n}\n",[],[274],{"_105":284,"_95":285,"_156":286,"_158":-5,"_159":139,"_160":287,"_162":22,"_107":288,"_101":289,"_165":179,"_167":290,"_168":22,"_169":-5,"_170":291,"_99":292},"cc708c8a-8d0e-11f0-82d8-0224a6c84d84","formatters.ts","16f54bc8-8d01-11f0-a71f-0224a6c84d84",457,["D",1757375514701],7,"import diff, { type Difference } from \"npm:microdiff\";\nimport { getActorName } 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// ==========================================\n// CUSTOMIZE: How Attio attributes display in Slack\n// ==========================================\n\n// Edit the formatters below to change how different attribute types\n// appear in your Slack messages. Examples show: input → output\n\n// ==========================================\n// TEXT & SELECTIONS\n// ==========================================\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 → \"true\", false → \"false\"\n checkbox: (av: AttioCheckboxValue) => av.value.toString(),\n};\n\n// ==========================================\n// NUMBERS & CURRENCY\n// ==========================================\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\" (add commas)\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// ==========================================\n// DATES & TIME\n// ==========================================\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// ==========================================\n// PEOPLE & CONTACTS\n// ==========================================\n\nconst peopleFormatters = {\n // Names: {first: \"John\", last: \"Doe\"} → \"John Doe\"\n \"personal-name\": (av: AttioPersonalNameValue) => {\n if (av.full_name) return av.full_name;\n return `${av.first_name ?? \"\"} ${av.last_name ?? \"\"}`.trim();\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// ==========================================\n// LINKS & LOCATIONS\n// ==========================================\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 ID (could fetch actual record name)\n \"record-reference\": (av: AttioRecordReferenceValue) => av.target_record_id,\n\n // Interactions: Interaction type → \"meeting\", \"call\", etc.\n interaction: (av: AttioInteractionValue) => av.interaction_type,\n};\n\n// ==========================================\n// ADVANCED: Don't edit below unless you know what you're doing\n// ==========================================\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 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 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",[],[285],{"_105":294,"_95":295,"_156":296,"_158":-5,"_159":139,"_160":297,"_162":22,"_107":298,"_101":299,"_165":179,"_167":300,"_168":22,"_169":-5,"_170":301,"_99":302},"cc46221a-8d0e-11f0-9cbc-0224a6c84d84","slack.ts","01991ffd-643f-709d-8def-026f57fa3f3c",451,["D",1757375514458],33,"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// ==========================================\n// MESSAGE APPEARANCE SETTINGS\n// ==========================================\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 record\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// ==========================================\n// MESSAGE TEMPLATES\n// ==========================================\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) => `*${field}* unset`,\n};\n\n// ==========================================\n// LINK FORMATSv\n// ==========================================\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// ==========================================\n// ADVANCED: System functions (don't edit unless you know what you're doing)\n// ==========================================\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 record if enabled)\n const entryMessages = messages.filter(\n (msg) => msg.action === \"updated\" || msg.target === \"comment\",\n );\n\n if (SLACK_CONFIG.groupByEntry) {\n const groupedByEntry = Object.groupBy(entryMessages, (msg) => msg.recordId);\n\n for (const [recordId, entryMsgs] of Object.entries(groupedByEntry)) {\n if (!entryMsgs?.length) continue;\n\n const firstMsg = entryMsgs[0];\n const entryLink = LINK_FORMATS.entry(\n workspaceSlug,\n objectSlug,\n recordId,\n firstMsg.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 // Don't group by record - show each message separately\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(\"a comment\", resolvedLink)}`;\n }\n case \"unresolved\": {\n const unresolvedLink = comment(workspaceSlug, msg.commentId || \"\");\n return `${commentUnresolved(msg.actor).replace(\"a 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);\n case \"CHANGE\":\n return fieldChanged(attribute, oldValue || \"\", newValue || \"\");\n default:\n return `*${attribute}* updated`;\n }\n}\n\nexport function truncate(s: string, maxChars: number): string {\n return s.length <= maxChars ? s : `${s.substring(0, maxChars - 3)}...`;\n}\n",[],[295],{"_105":304,"_95":305,"_156":306,"_158":-5,"_159":139,"_160":307,"_162":22,"_107":308,"_101":309,"_165":179,"_167":310,"_168":22,"_169":-5,"_170":311,"_99":312},"e546a914-8d05-11f0-b104-0224a6c84d84","types.ts","1617927e-8c2a-11f0-97fe-0224a6c84d84",430,["D",1757371690867],9,"// ==========================================\n// CORE TYPES - Template users might customize these\n// ==========================================\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\n// Action constants - used throughout the system\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// ==========================================\n// ATTIO ATTRIBUTE TYPES - Keep for formatter type safety\n// ==========================================\n\ninterface AttioBaseAttributeValue {\n active_from: string;\n active_until: string | null;\n created_by_actor: Actor;\n attribute_type: string;\n}\n\n// Text & Selection Types\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\n// Number & Currency Types\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\n// Date & Time Types\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\n// People & Contact Types\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\n// Link & Location Types\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\n// Union of all attribute types - core to formatter system\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// ==========================================\n// SIMPLIFIED WEBHOOK TYPES - Just what we need\n// ==========================================\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// ==========================================\n// INTERNAL TYPES - System use only, template users don't need to know these\n// ==========================================\n\n// Simplified API response types - just the fields we actually use\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\n// Minimal API types for what we actually fetch\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\n// Union type for API client generic function\nexport type AttioResource =\n | AttioComment\n | AttioRecord\n | AttioListEntry\n | AttioWorkspaceMember\n | AttioObject\n | AttioList;\n\n// State management types\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",[],[305],{"_105":314,"_95":100,"_156":315,"_158":-5,"_159":139,"_160":102,"_162":22,"_107":316,"_101":317,"_165":318,"_167":319,"_168":22,"_169":-5,"_170":320,"_99":321},"f320b896-8d0e-11f0-b3b7-0224a6c84d84","01991ffd-643f-709d-8def-21fc0fbcdd2e",["D",1757375579644],25,"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 \"3f828ca4-32b6-4adf-a354-e97609390dcf\",\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((event): event is WebhookEvent => {\n if (\"list_id\" in event.id && event.id.list_id) listIdSet.has(event.id.list_id);\n if (\"list_id\" in event && event.list_id) return listIdSet.has(event.list_id);\n return false;\n });\n\n console.log(\n `[Webhook] ${relevantEvents.length} relevant events (${data.events.length - relevantEvents.length} skipped)`,\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;\n",[],[100],"files",[153,172,183,193,203,213,224,231,241,252,262,272,283,293,303,313],"counts",{"_326":32,"_327":328,"_329":330,"_331":332},"pulls","branches",4,"forks",2,"envVars",{"_333":330,"_334":32},"count","emptyCount","contents",[],{"_105":314,"_95":100,"_156":315,"_158":-5,"_159":139,"_160":102,"_162":22,"_107":338,"_101":317,"_165":318,"_167":319,"_168":22,"_169":-5,"_99":339},["D",1757375579644],[100],"upstreamProject",{"_105":342,"_95":96,"_113":343,"_114":-5,"_111":112,"_23":344},"dbd66352-785a-11f0-814d-0224a6c84d84","Get debounced summaries of updates from Attio in Slack",{"_93":345,"_131":346},"stevekrouse","https://images.clerk.dev/uploaded/img_2PqHa2Gsy93xQrjh2w78Xu0cChW.jpeg","upstreamBranch",{"_105":142,"_107":349,"_350":351,"_95":352,"_140":106,"_101":144,"_141":353,"_143":317,"_354":355,"_109":-5,"_150":22,"_111":112,"_149":94,"_16":120,"_148":96},["D",1756514921181],"updatedAt",["D",1757448580380],"experimenting","881a5512-8515-11f0-b918-0224a6c84d84","lockfileKey","1757876878154-esm.town_v_nbbaier_attio-slack-summaries@581-experimenting","emptyEnvVars","isNew","flags",[],"routes/_app.x.$handle.$name.branch.$branch.version.$version.code.$",{"_93":94,"_95":96,"_97":98,"_101":102,"_99":100,"_103":362,"_151":367,"_322":416,"_258":417,"_335":419,"_420":421,"_424":-5,"_425":32,"_426":32,"_427":428},{"_105":106,"_95":96,"_107":363,"_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":364,"_133":365,"_136":366,"_150":22},["D",1756498797190],{"_93":94,"_131":132},{"_93":94,"_135":132,"_14":115},{"_101":138,"_95":98,"_105":139,"_140":106,"_141":142,"_143":144,"_145":112,"_146":106,"_147":120,"_148":96,"_149":94},[368,386,395,398,401,404,407,410,413],{"_105":154,"_95":155,"_156":157,"_158":-5,"_159":139,"_160":161,"_162":163,"_107":164,"_101":32,"_165":166,"_167":-5,"_168":22,"_169":-5,"_170":369,"_99":385},[370,373,376,379,382],{"_105":173,"_95":174,"_156":175,"_158":157,"_159":139,"_160":176,"_162":22,"_107":177,"_101":178,"_165":179,"_167":180,"_168":22,"_169":-5,"_170":371,"_99":372},[],[155,174],{"_105":184,"_95":185,"_156":186,"_158":157,"_159":139,"_160":187,"_162":22,"_107":188,"_101":189,"_165":179,"_167":190,"_168":22,"_169":-5,"_170":374,"_99":375},[],[155,185],{"_105":194,"_95":195,"_156":196,"_158":157,"_159":139,"_160":197,"_162":22,"_107":198,"_101":199,"_165":179,"_167":200,"_168":22,"_169":-5,"_170":377,"_99":378},[],[155,195],{"_105":204,"_95":205,"_156":206,"_158":157,"_159":139,"_160":207,"_162":22,"_107":208,"_101":209,"_165":179,"_167":210,"_168":22,"_169":-5,"_170":380,"_99":381},[],[155,205],{"_105":214,"_95":215,"_156":216,"_158":157,"_159":139,"_160":217,"_162":22,"_107":218,"_101":219,"_165":179,"_167":220,"_168":22,"_169":-5,"_170":383,"_99":384},[],[155,215],[155],{"_105":225,"_95":226,"_156":227,"_158":-5,"_159":139,"_160":228,"_162":163,"_107":229,"_101":32,"_165":166,"_167":-5,"_168":22,"_169":-5,"_170":387,"_99":394},[388,391],{"_105":232,"_95":233,"_156":234,"_158":227,"_159":139,"_160":235,"_162":22,"_107":236,"_101":237,"_165":179,"_167":238,"_168":22,"_169":-5,"_170":389,"_99":390},[],[226,233],{"_105":242,"_95":243,"_156":244,"_158":227,"_159":139,"_160":245,"_162":22,"_107":246,"_101":247,"_165":179,"_167":248,"_168":22,"_169":-5,"_170":392,"_99":393},[],[226,243],[226],{"_105":253,"_95":254,"_156":255,"_158":-5,"_159":139,"_160":256,"_162":22,"_107":257,"_101":209,"_165":258,"_167":259,"_168":22,"_169":-5,"_170":396,"_99":397},[],[254],{"_105":263,"_95":264,"_156":265,"_158":-5,"_159":139,"_160":266,"_162":22,"_107":267,"_101":268,"_165":258,"_167":269,"_168":22,"_169":-5,"_170":399,"_99":400},[],[264],{"_105":273,"_95":274,"_156":275,"_158":-5,"_159":139,"_160":276,"_162":163,"_107":277,"_101":278,"_165":279,"_167":280,"_168":22,"_169":-5,"_170":402,"_99":403},[],[274],{"_105":284,"_95":285,"_156":286,"_158":-5,"_159":139,"_160":287,"_162":22,"_107":288,"_101":289,"_165":179,"_167":290,"_168":22,"_169":-5,"_170":405,"_99":406},[],[285],{"_105":294,"_95":295,"_156":296,"_158":-5,"_159":139,"_160":297,"_162":22,"_107":298,"_101":299,"_165":179,"_167":300,"_168":22,"_169":-5,"_170":408,"_99":409},[],[295],{"_105":304,"_95":305,"_156":306,"_158":-5,"_159":139,"_160":307,"_162":22,"_107":308,"_101":309,"_165":179,"_167":310,"_168":22,"_169":-5,"_170":411,"_99":412},[],[305],{"_105":314,"_95":100,"_156":315,"_158":-5,"_159":139,"_160":102,"_162":22,"_107":316,"_101":317,"_165":318,"_167":319,"_168":22,"_169":-5,"_170":414,"_99":415},[],[100],[368,370,373,376,379,382,386,388,391,395,398,401,404,407,410,413],{"_105":314,"_95":100,"_156":315,"_158":-5,"_159":139,"_160":102,"_162":22,"_107":338,"_101":317,"_165":318,"_167":319,"_168":22,"_169":-5,"_99":418},[100],[],"upstream",{"_105":142,"_107":422,"_350":423,"_95":352,"_140":106,"_101":144,"_141":353,"_143":317,"_354":355,"_109":-5,"_150":22,"_111":112,"_149":94,"_16":120,"_148":96},["D",1756514921181],["D",1757448580380],"pull","ahead","behind","templates",[],"actionData","errors"]