feat(outlook): add outlook webhook provider (#874)

* feat(outlook): add outlook webhook provider

* remove useless files

* cron to one minute

* Update apps/sim/lib/webhooks/utils.ts

Co-authored-by: greptile-apps[bot] <165735046+greptile-apps[bot]@users.noreply.github.com>

* Update apps/sim/lib/webhooks/outlook-polling-service.ts

Co-authored-by: greptile-apps[bot] <165735046+greptile-apps[bot]@users.noreply.github.com>

* Update apps/sim/lib/webhooks/outlook-polling-service.ts

Co-authored-by: greptile-apps[bot] <165735046+greptile-apps[bot]@users.noreply.github.com>

* fix lint

* fix type error:

---------

Co-authored-by: greptile-apps[bot] <165735046+greptile-apps[bot]@users.noreply.github.com>

Author: icecrasher321

apps/sim/app/api/webhooks/poll/outlook/route.ts

@@ -0,0 +1,66 @@
+import { nanoid } from 'nanoid'
+import { type NextRequest, NextResponse } from 'next/server'
+import { verifyCronAuth } from '@/lib/auth/internal'
+import { Logger } from '@/lib/logs/console/logger'
+import { acquireLock, releaseLock } from '@/lib/redis'
+import { pollOutlookWebhooks } from '@/lib/webhooks/outlook-polling-service'
+
+const logger = new Logger('OutlookPollingAPI')
+
+export const dynamic = 'force-dynamic'
+export const maxDuration = 180 // Allow up to 3 minutes for polling to complete
+
+const LOCK_KEY = 'outlook-polling-lock'
+const LOCK_TTL_SECONDS = 180 // Same as maxDuration (3 min)
+
+export async function GET(request: NextRequest) {
+  const requestId = nanoid()
+  logger.info(`Outlook webhook polling triggered (${requestId})`)
+
+  let lockValue: string | undefined
+
+  try {
+    const authError = verifyCronAuth(request, 'Outlook webhook polling')
+    if (authError) {
+      return authError
+    }
+
+    lockValue = requestId // unique value to identify the holder
+    const locked = await acquireLock(LOCK_KEY, lockValue, LOCK_TTL_SECONDS)
+
+    if (!locked) {
+      return NextResponse.json(
+        {
+          success: true,
+          message: 'Polling already in progress – skipped',
+          requestId,
+          status: 'skip',
+        },
+        { status: 202 }
+      )
+    }
+
+    const results = await pollOutlookWebhooks()
+
+    return NextResponse.json({
+      success: true,
+      message: 'Outlook polling completed',
+      requestId,
+      status: 'completed',
+      ...results,
+    })
+  } catch (error) {
+    logger.error(`Error during Outlook polling (${requestId}):`, error)
+    return NextResponse.json(
+      {
+        success: false,
+        message: 'Outlook polling failed',
+        error: error instanceof Error ? error.message : 'Unknown error',
+        requestId,
+      },
+      { status: 500 }
+    )
+  } finally {
+    await releaseLock(LOCK_KEY).catch(() => {})
+  }
+}

apps/sim/app/api/webhooks/route.ts

@@ -266,6 +266,40 @@ export async function POST(request: NextRequest) {
     }
     // --- End Gmail specific logic ---
 
+    // --- Outlook webhook setup ---
+    if (savedWebhook && provider === 'outlook') {
+      logger.info(
+        `[${requestId}] Outlook provider detected. Setting up Outlook webhook configuration.`
+      )
+      try {
+        const { configureOutlookPolling } = await import('@/lib/webhooks/utils')
+        const success = await configureOutlookPolling(userId, savedWebhook, requestId)
+
+        if (!success) {
+          logger.error(`[${requestId}] Failed to configure Outlook polling`)
+          return NextResponse.json(
+            {
+              error: 'Failed to configure Outlook polling',
+              details: 'Please check your Outlook account permissions and try again',
+            },
+            { status: 500 }
+          )
+        }
+
+        logger.info(`[${requestId}] Successfully configured Outlook polling`)
+      } catch (err) {
+        logger.error(`[${requestId}] Error setting up Outlook webhook configuration`, err)
+        return NextResponse.json(
+          {
+            error: 'Failed to configure Outlook webhook',
+            details: err instanceof Error ? err.message : 'Unknown error',
+          },
+          { status: 500 }
+        )
+      }
+    }
+    // --- End Outlook specific logic ---
+
     const status = existingWebhooks.length > 0 ? 200 : 201
     return NextResponse.json({ webhook: savedWebhook }, { status })
   } catch (error: any) {

apps/sim/app/workspace/[workspaceId]/w/[workflowId]/components/workflow-block/components/sub-block/components/webhook/components/index.ts

@@ -5,6 +5,7 @@ export {
   GithubConfig,
   GmailConfig,
   MicrosoftTeamsConfig,
+  OutlookConfig,
   SlackConfig,
   StripeConfig,
   TelegramConfig,

apps/sim/app/workspace/[workspaceId]/w/[workflowId]/components/workflow-block/components/sub-block/components/webhook/components/providers/index.ts

@@ -4,6 +4,7 @@ export { GenericConfig } from './generic'
 export { GithubConfig } from './github'
 export { GmailConfig } from './gmail'
 export { MicrosoftTeamsConfig } from './microsoftteams'
+export { OutlookConfig } from './outlook'
 export { SlackConfig } from './slack'
 export { StripeConfig } from './stripe'
 export { TelegramConfig } from './telegram'