feat(buffer): add Buffer integration with posts, channels, and ideas (#5637)

* feat(buffer): add Buffer integration with posts, channels, and ideas

* fix(buffer): return clear tool error when account lookup yields no account

* fix(buffer): default schedulingType server-side so basic-mode blocks never fail validation

* fix(buffer): probe Content-Type for extensionless media URLs so videos are not sent as images

* feat(buffer): add get_ideas and get_idea_groups tools, harden media URL classification

* fix(buffer): guard missing post on PostActionSuccess responses

Author: waleedlatif1

apps/docs/components/icons.tsx

@@ -2533,6 +2533,24 @@ l57 -85 -48 -124 c-203 -517 -79 -930 346 -1155 159 -85 441 -71 585 28 l111
   )
 }
 
+export function BufferIcon(props: SVGProps<SVGSVGElement>) {
+  return (
+    <svg
+      {...props}
+      viewBox='0 0 86.7 97.9'
+      fill='currentColor'
+      role='img'
+      xmlns='http://www.w3.org/2000/svg'
+    >
+      <path
+        fillRule='evenodd'
+        clipRule='evenodd'
+        d='M0,22.3L43.1,0l43.6,22.3L43.1,44.8L0,22.3z M43.1,83.1l-29.4-16L0,74.5l43.1,23.4l43.6-23.4l-13.9-7.4 L43.1,83.1z M13.7,42l29.4,14.5L72.9,42l13.9,6.8L43.1,69.9L0,48.7L13.7,42z'
+      />
+    </svg>
+  )
+}
+
 export function Mem0Icon(props: SVGProps<SVGSVGElement>) {
   return (
     <svg

apps/docs/components/ui/icon-mapping.ts

@@ -27,6 +27,7 @@ import {
   BrexIcon,
   BrightDataIcon,
   BrowserUseIcon,
+  BufferIcon,
   CalComIcon,
   CalendlyIcon,
   CirclebackIcon,
@@ -264,6 +265,7 @@ export const blockTypeToIconMap: Record<string, IconComponent> = {
   brex: BrexIcon,
   brightdata: BrightDataIcon,
   browser_use: BrowserUseIcon,
+  buffer: BufferIcon,
   calcom: CalComIcon,
   calendly: CalendlyIcon,
   circleback: CirclebackIcon,

apps/docs/content/docs/en/integrations/buffer.mdx

@@ -25,6 +25,7 @@
     "brex",
     "brightdata",
     "browser_use",
+    "buffer",
     "calcom",
     "calendly",
     "circleback",

apps/docs/content/docs/en/integrations/meta.json

@@ -0,0 +1,69 @@
+import { createLogger } from '@sim/logger'
+import { getErrorMessage } from '@sim/utils/errors'
+import { type NextRequest, NextResponse } from 'next/server'
+import { bufferCreatePostContract } from '@/lib/api/contracts/tools/buffer'
+import { getValidationErrorMessage, parseRequest } from '@/lib/api/server'
+import { checkInternalAuth } from '@/lib/auth/hybrid'
+import { generateRequestId } from '@/lib/core/utils/request'
+import { withRouteHandler } from '@/lib/core/utils/with-route-handler'
+import { forwardPostMutation } from '@/app/api/tools/buffer/server-utils'
+
+export const dynamic = 'force-dynamic'
+
+const logger = createLogger('BufferCreatePostAPI')
+
+export const POST = withRouteHandler(async (request: NextRequest) => {
+  const requestId = generateRequestId()
+
+  try {
+    const authResult = await checkInternalAuth(request, { requireWorkflowId: false })
+    if (!authResult.success || !authResult.userId) {
+      logger.warn(`[${requestId}] Unauthorized Buffer create post attempt`, {
+        error: authResult.error || 'Missing userId',
+      })
+      return NextResponse.json(
+        { success: false, error: authResult.error || 'Unauthorized' },
+        { status: 401 }
+      )
+    }
+
+    const parsed = await parseRequest(
+      bufferCreatePostContract,
+      request,
+      {},
+      {
+        validationErrorResponse: (error) => {
+          logger.warn(`[${requestId}] Invalid request data`, { errors: error.issues })
+          return NextResponse.json(
+            {
+              success: false,
+              error: getValidationErrorMessage(error, 'Invalid request data'),
+            },
+            { status: 400 }
+          )
+        },
+      }
+    )
+    if (!parsed.success) return parsed.response
+    const body = parsed.data.body
+
+    return await forwardPostMutation({
+      apiKey: body.apiKey,
+      channelId: body.channelId,
+      text: body.text,
+      mode: body.mode,
+      schedulingType: body.schedulingType,
+      dueAt: body.dueAt,
+      saveToDraft: body.saveToDraft,
+      media: body.media,
+      mediaAltText: body.mediaAltText,
+      userId: authResult.userId,
+      requestId,
+      logger,
+    })
+  } catch (error) {
+    const message = getErrorMessage(error, 'Failed to create post')
+    logger.error(`[${requestId}] Buffer create post failed`, { error: message })
+    return NextResponse.json({ success: false, error: message }, { status: 500 })
+  }
+})

apps/sim/app/api/tools/buffer/create-post/route.ts

@@ -0,0 +1,69 @@
+import { createLogger } from '@sim/logger'
+import { getErrorMessage } from '@sim/utils/errors'
+import { type NextRequest, NextResponse } from 'next/server'
+import { bufferEditPostContract } from '@/lib/api/contracts/tools/buffer'
+import { getValidationErrorMessage, parseRequest } from '@/lib/api/server'
+import { checkInternalAuth } from '@/lib/auth/hybrid'
+import { generateRequestId } from '@/lib/core/utils/request'
+import { withRouteHandler } from '@/lib/core/utils/with-route-handler'
+import { forwardPostMutation } from '@/app/api/tools/buffer/server-utils'
+
+export const dynamic = 'force-dynamic'
+
+const logger = createLogger('BufferEditPostAPI')
+
+export const POST = withRouteHandler(async (request: NextRequest) => {
+  const requestId = generateRequestId()
+
+  try {
+    const authResult = await checkInternalAuth(request, { requireWorkflowId: false })
+    if (!authResult.success || !authResult.userId) {
+      logger.warn(`[${requestId}] Unauthorized Buffer edit post attempt`, {
+        error: authResult.error || 'Missing userId',
+      })
+      return NextResponse.json(
+        { success: false, error: authResult.error || 'Unauthorized' },
+        { status: 401 }
+      )
+    }
+
+    const parsed = await parseRequest(
+      bufferEditPostContract,
+      request,
+      {},
+      {
+        validationErrorResponse: (error) => {
+          logger.warn(`[${requestId}] Invalid request data`, { errors: error.issues })
+          return NextResponse.json(
+            {
+              success: false,
+              error: getValidationErrorMessage(error, 'Invalid request data'),
+            },
+            { status: 400 }
+          )
+        },
+      }
+    )
+    if (!parsed.success) return parsed.response
+    const body = parsed.data.body
+
+    return await forwardPostMutation({
+      apiKey: body.apiKey,
+      postId: body.postId,
+      text: body.text,
+      mode: body.mode,
+      schedulingType: body.schedulingType,
+      dueAt: body.dueAt,
+      saveToDraft: body.saveToDraft,
+      media: body.media,
+      mediaAltText: body.mediaAltText,
+      userId: authResult.userId,
+      requestId,
+      logger,
+    })
+  } catch (error) {
+    const message = getErrorMessage(error, 'Failed to edit post')
+    logger.error(`[${requestId}] Buffer edit post failed`, { error: message })
+    return NextResponse.json({ success: false, error: message }, { status: 500 })
+  }
+})