fixed and tested attio webhook lifecycle

Author: waleedlatif1

apps/sim/lib/webhooks/processor.ts

@@ -979,16 +979,18 @@ export async function queueWebhookExecution(
       const triggerId = providerConfig.triggerId as string | undefined
 
       if (triggerId && triggerId !== 'attio_webhook') {
-        const { isAttioPayloadMatch } = await import('@/triggers/attio/utils')
+        const { isAttioPayloadMatch, getAttioEvent } = await import('@/triggers/attio/utils')
         if (!isAttioPayloadMatch(triggerId, body)) {
-          const eventType = body?.event_type as string | undefined
+          const event = getAttioEvent(body)
+          const eventType = event?.event_type as string | undefined
           logger.debug(
             `[${options.requestId}] Attio event mismatch for trigger ${triggerId}. Event: ${eventType}. Skipping execution.`,
             {
               webhookId: foundWebhook.id,
               workflowId: foundWorkflow.id,
               triggerId,
               receivedEvent: eventType,
+              bodyKeys: Object.keys(body),
             }
           )
           return NextResponse.json({ status: 'skipped', reason: 'event_type_mismatch' })

apps/sim/lib/webhooks/provider-subscriptions.ts

@@ -1093,7 +1093,12 @@ export async function createAttioWebhookSubscription(
 
     attioLogger.info(
       `[${requestId}] Successfully created webhook in Attio for webhook ${webhookData.id}.`,
-      { attioWebhookId: webhookId }
+      {
+        attioWebhookId: webhookId,
+        targetUrl: notificationUrl,
+        subscriptionCount: subscriptions.length,
+        status: data.status,
+      }
     )
 
     return { externalId: webhookId, webhookSecret: secret || '' }

apps/sim/lib/webhooks/utils.server.ts

@@ -1291,6 +1291,49 @@ export async function formatWebhookInput(
     }
   }
 
+  if (foundWebhook.provider === 'attio') {
+    const {
+      extractAttioRecordData,
+      extractAttioRecordUpdatedData,
+      extractAttioRecordMergedData,
+      extractAttioNoteData,
+      extractAttioTaskData,
+      extractAttioCommentData,
+      extractAttioListEntryData,
+      extractAttioListEntryUpdatedData,
+      extractAttioGenericData,
+    } = await import('@/triggers/attio/utils')
+
+    const providerConfig = (foundWebhook.providerConfig as Record<string, any>) || {}
+    const triggerId = providerConfig.triggerId as string | undefined
+
+    if (triggerId === 'attio_record_updated') {
+      return extractAttioRecordUpdatedData(body)
+    }
+    if (triggerId === 'attio_record_merged') {
+      return extractAttioRecordMergedData(body)
+    }
+    if (triggerId === 'attio_record_created' || triggerId === 'attio_record_deleted') {
+      return extractAttioRecordData(body)
+    }
+    if (triggerId?.startsWith('attio_note_')) {
+      return extractAttioNoteData(body)
+    }
+    if (triggerId?.startsWith('attio_task_')) {
+      return extractAttioTaskData(body)
+    }
+    if (triggerId?.startsWith('attio_comment_')) {
+      return extractAttioCommentData(body)
+    }
+    if (triggerId === 'attio_list_entry_updated') {
+      return extractAttioListEntryUpdatedData(body)
+    }
+    if (triggerId === 'attio_list_entry_created' || triggerId === 'attio_list_entry_deleted') {
+      return extractAttioListEntryData(body)
+    }
+    return extractAttioGenericData(body)
+  }
+
   return body
 }
 

apps/sim/triggers/attio/utils.ts

@@ -290,6 +290,15 @@ export const TRIGGER_EVENT_MAP: Record<string, string[]> = {
   attio_list_entry_deleted: ['list-entry.deleted'],
 }
 
+/**
+ * Extracts the first event from an Attio webhook payload.
+ * Attio wraps events in an `events` array: `{ webhook_id, events: [{ event_type, id, ... }] }`.
+ */
+export function getAttioEvent(body: Record<string, unknown>): Record<string, unknown> | undefined {
+  const events = body.events as Array<Record<string, unknown>> | undefined
+  return events?.[0]
+}
+
 /**
  * Checks if an Attio webhook payload matches a trigger.
  */
@@ -298,11 +307,155 @@ export function isAttioPayloadMatch(triggerId: string, body: Record<string, unkn
     return true
   }
 
-  const eventType = body.event_type as string | undefined
+  const event = getAttioEvent(body)
+  const eventType = event?.event_type as string | undefined
   if (!eventType) {
     return false
   }
 
   const acceptedEvents = TRIGGER_EVENT_MAP[triggerId]
   return acceptedEvents ? acceptedEvents.includes(eventType) : false
 }
+
+/**
+ * Extracts formatted data from an Attio record event payload.
+ * Used for record.created, record.deleted triggers.
+ */
+export function extractAttioRecordData(body: Record<string, unknown>): Record<string, unknown> {
+  const event = getAttioEvent(body) ?? {}
+  const id = (event.id as Record<string, unknown>) ?? {}
+  return {
+    eventType: event.event_type ?? null,
+    workspaceId: id.workspace_id ?? null,
+    objectId: id.object_id ?? null,
+    recordId: id.record_id ?? null,
+  }
+}
+
+/**
+ * Extracts formatted data from an Attio record.updated event payload.
+ */
+export function extractAttioRecordUpdatedData(
+  body: Record<string, unknown>
+): Record<string, unknown> {
+  const event = getAttioEvent(body) ?? {}
+  const id = (event.id as Record<string, unknown>) ?? {}
+  return {
+    eventType: event.event_type ?? null,
+    workspaceId: id.workspace_id ?? null,
+    objectId: id.object_id ?? null,
+    recordId: id.record_id ?? null,
+    attributeId: id.attribute_id ?? null,
+  }
+}
+
+/**
+ * Extracts formatted data from an Attio record.merged event payload.
+ */
+export function extractAttioRecordMergedData(
+  body: Record<string, unknown>
+): Record<string, unknown> {
+  const event = getAttioEvent(body) ?? {}
+  const id = (event.id as Record<string, unknown>) ?? {}
+  return {
+    eventType: event.event_type ?? null,
+    workspaceId: id.workspace_id ?? null,
+    objectId: id.object_id ?? null,
+    recordId: id.record_id ?? null,
+    duplicateObjectId: (event.duplicate_object_id as string) ?? null,
+    duplicateRecordId: (event.duplicate_record_id as string) ?? null,
+  }
+}
+
+/**
+ * Extracts formatted data from an Attio note event payload.
+ */
+export function extractAttioNoteData(body: Record<string, unknown>): Record<string, unknown> {
+  const event = getAttioEvent(body) ?? {}
+  const id = (event.id as Record<string, unknown>) ?? {}
+  return {
+    eventType: event.event_type ?? null,
+    workspaceId: id.workspace_id ?? null,
+    noteId: id.note_id ?? null,
+    parentObjectId: (event.parent_object_id as string) ?? null,
+    parentRecordId: (event.parent_record_id as string) ?? null,
+  }
+}
+
+/**
+ * Extracts formatted data from an Attio task event payload.
+ */
+export function extractAttioTaskData(body: Record<string, unknown>): Record<string, unknown> {
+  const event = getAttioEvent(body) ?? {}
+  const id = (event.id as Record<string, unknown>) ?? {}
+  return {
+    eventType: event.event_type ?? null,
+    workspaceId: id.workspace_id ?? null,
+    taskId: id.task_id ?? null,
+  }
+}
+
+/**
+ * Extracts formatted data from an Attio comment event payload.
+ */
+export function extractAttioCommentData(body: Record<string, unknown>): Record<string, unknown> {
+  const event = getAttioEvent(body) ?? {}
+  const id = (event.id as Record<string, unknown>) ?? {}
+  return {
+    eventType: event.event_type ?? null,
+    workspaceId: id.workspace_id ?? null,
+    threadId: (event.thread_id as string) ?? null,
+    commentId: id.comment_id ?? null,
+    objectId: (event.object_id as string) ?? null,
+    recordId: (event.record_id as string) ?? null,
+    listId: (event.list_id as string) ?? null,
+    entryId: (event.entry_id as string) ?? null,
+  }
+}
+
+/**
+ * Extracts formatted data from an Attio list-entry event payload.
+ * Used for list-entry.created, list-entry.deleted triggers.
+ */
+export function extractAttioListEntryData(body: Record<string, unknown>): Record<string, unknown> {
+  const event = getAttioEvent(body) ?? {}
+  const id = (event.id as Record<string, unknown>) ?? {}
+  return {
+    eventType: event.event_type ?? null,
+    workspaceId: id.workspace_id ?? null,
+    listId: id.list_id ?? null,
+    entryId: id.entry_id ?? null,
+  }
+}
+
+/**
+ * Extracts formatted data from an Attio list-entry.updated event payload.
+ */
+export function extractAttioListEntryUpdatedData(
+  body: Record<string, unknown>
+): Record<string, unknown> {
+  const event = getAttioEvent(body) ?? {}
+  const id = (event.id as Record<string, unknown>) ?? {}
+  return {
+    eventType: event.event_type ?? null,
+    workspaceId: id.workspace_id ?? null,
+    listId: id.list_id ?? null,
+    entryId: id.entry_id ?? null,
+    attributeId: id.attribute_id ?? null,
+  }
+}
+
+/**
+ * Extracts formatted data from a generic Attio webhook payload.
+ * Passes through the first event with camelCase field mapping.
+ */
+export function extractAttioGenericData(body: Record<string, unknown>): Record<string, unknown> {
+  const event = getAttioEvent(body) ?? {}
+  const id = (event.id as Record<string, unknown>) ?? {}
+  return {
+    eventType: event.event_type ?? null,
+    id,
+    parentObjectId: (event.parent_object_id as string) ?? null,
+    parentRecordId: (event.parent_record_id as string) ?? null,
+  }
+}