fix(sendblue): address review — status-aware webhook dedup, shared routing map, uniform output casing, api-key authType

Author: waleedlatif1

apps/docs/content/docs/en/triggers/sendblue.mdx

@@ -22,7 +22,7 @@ Trigger when an inbound iMessage or SMS is received in Sendblue
 
 | Parameter | Type | Description |
 | --------- | ---- | ----------- |
-| `accountEmail` | string | Email of the Sendblue account |
+| `account_email` | string | Email of the Sendblue account |
 | `content` | string | Message text content |
 | `media_url` | string | CDN link to attached media, if any |
 | `is_outbound` | boolean | True for outbound messages, false for inbound |
@@ -62,7 +62,7 @@ Trigger when an outbound message status changes (SENT, DELIVERED, ERROR) in Send
 
 | Parameter | Type | Description |
 | --------- | ---- | ----------- |
-| `accountEmail` | string | Email of the Sendblue account |
+| `account_email` | string | Email of the Sendblue account |
 | `content` | string | Message text content |
 | `media_url` | string | CDN link to attached media, if any |
 | `is_outbound` | boolean | True for outbound messages, false for inbound |

apps/sim/lib/integrations/integrations.json

@@ -12744,7 +12744,7 @@
       }
     ],
     "triggerCount": 2,
-    "authType": "none",
+    "authType": "api-key",
     "category": "tools",
     "integrationType": "communication",
     "tags": ["messaging", "automation", "webhooks"]

apps/sim/lib/webhooks/providers/sendblue.ts

@@ -6,31 +6,22 @@ import type {
   FormatInputResult,
   WebhookProviderHandler,
 } from '@/lib/webhooks/providers/types'
+import { SENDBLUE_TRIGGER_IS_OUTBOUND } from '@/triggers/sendblue/utils'
 
 const logger = createLogger('WebhookProvider:Sendblue')
 
-/**
- * Maps Sendblue trigger IDs to the expected value of the payload `is_outbound`
- * flag. Inbound messages are routed to the "message received" trigger and
- * outbound status callbacks to the "message status updated" trigger.
- */
-const TRIGGER_IS_OUTBOUND: Record<string, boolean> = {
-  sendblue_message_received: false,
-  sendblue_message_status_updated: true,
-}
-
 export const sendblueHandler: WebhookProviderHandler = {
   matchEvent({ body, webhook, requestId }: EventMatchContext): boolean {
     const providerConfig = getProviderConfig(webhook)
     const triggerId = providerConfig.triggerId as string | undefined
-    if (!triggerId || !(triggerId in TRIGGER_IS_OUTBOUND)) return true
+    if (!triggerId || !(triggerId in SENDBLUE_TRIGGER_IS_OUTBOUND)) return true
 
     if (!isRecord(body)) {
       logger.warn(`[${requestId}] Sendblue webhook payload was not an object`)
       return false
     }
 
-    const expected = TRIGGER_IS_OUTBOUND[triggerId]
+    const expected = SENDBLUE_TRIGGER_IS_OUTBOUND[triggerId]
     const isOutbound = body.is_outbound === true
     if (isOutbound !== expected) {
       logger.info(`[${requestId}] Sendblue event did not match trigger`, { triggerId, isOutbound })
@@ -43,14 +34,19 @@ export const sendblueHandler: WebhookProviderHandler = {
   extractIdempotencyId(body: unknown): string | null {
     if (!isRecord(body)) return null
     const handle = body.message_handle
-    return typeof handle === 'string' && handle.length > 0 ? handle : null
+    if (typeof handle !== 'string' || handle.length === 0) return null
+    // A single outbound message emits multiple status callbacks (e.g. SENT then
+    // DELIVERED) that share one message_handle, so the status is part of the key
+    // to keep distinct transitions from being deduped as retries.
+    const status = typeof body.status === 'string' && body.status.length > 0 ? body.status : null
+    return status ? `${handle}:${status}` : handle
   },
 
   async formatInput({ body }: FormatInputContext): Promise<FormatInputResult> {
     const b = isRecord(body) ? body : {}
     return {
       input: {
-        accountEmail: b.accountEmail ?? b.account_email ?? null,
+        account_email: b.accountEmail ?? b.account_email ?? null,
         content: b.content ?? null,
         media_url: b.media_url ?? null,
         is_outbound: b.is_outbound ?? null,

apps/sim/triggers/sendblue/utils.ts

@@ -3,6 +3,7 @@ import type { TriggerOutput } from '@/triggers/types'
 /**
  * Maps Sendblue trigger IDs to the expected value of the webhook payload's
  * `is_outbound` flag, used to route inbound vs. outbound status events.
+ * Imported by the webhook provider handler so routing lives in one place.
  */
 export const SENDBLUE_TRIGGER_IS_OUTBOUND: Record<string, boolean> = {
   sendblue_message_received: false,
@@ -38,7 +39,7 @@ export function sendblueSetupInstructions(eventType: string): string {
  */
 export function buildSendblueOutputs(): Record<string, TriggerOutput> {
   return {
-    accountEmail: { type: 'string', description: 'Email of the Sendblue account' },
+    account_email: { type: 'string', description: 'Email of the Sendblue account' },
     content: { type: 'string', description: 'Message text content' },
     media_url: { type: 'string', description: 'CDN link to attached media, if any' },
     is_outbound: { type: 'boolean', description: 'True for outbound messages, false for inbound' },

scripts/generate-docs.ts

@@ -535,6 +535,10 @@ async function buildToolDescriptionMap(): Promise<ToolMaps> {
  * 'api-key' if it uses a plain API key field, or 'none' otherwise.
  */
 function extractAuthType(blockContent: string): 'oauth' | 'api-key' | 'none' {
+  // Prefer the authoritative `authMode` declaration when present.
+  if (/authMode\s*:\s*AuthMode\.OAuth\b/.test(blockContent)) return 'oauth'
+  if (/authMode\s*:\s*AuthMode\.(?:ApiKey|BotToken)\b/.test(blockContent)) return 'api-key'
+  // Fall back to credential subBlock heuristics for blocks without authMode.
   if (/type\s*:\s*['"]oauth-input['"]/.test(blockContent)) return 'oauth'
   if (/\bid\s*:\s*['"](?:apiKey|api_key|accessToken)['"]/.test(blockContent)) return 'api-key'
   return 'none'