Skip to content

Commit 2949517

Browse files
committed
improvement(polling): remove trigger.dev dispatch, use synchronous Redis-locked polling
1 parent 9ed0b82 commit 2949517

File tree

2 files changed

+0
-67
lines changed

2 files changed

+0
-67
lines changed

apps/sim/app/api/webhooks/poll/[provider]/route.ts

Lines changed: 0 additions & 33 deletions
Original file line numberDiff line numberDiff line change
@@ -1,11 +1,9 @@
11
import { createLogger } from '@sim/logger'
22
import { type NextRequest, NextResponse } from 'next/server'
33
import { verifyCronAuth } from '@/lib/auth/internal'
4-
import { isTriggerDevEnabled } from '@/lib/core/config/feature-flags'
54
import { acquireLock, releaseLock } from '@/lib/core/config/redis'
65
import { generateShortId } from '@/lib/core/utils/uuid'
76
import { pollProvider, VALID_POLLING_PROVIDERS } from '@/lib/webhooks/polling'
8-
import { providerPolling } from '@/background/provider-polling'
97

108
const logger = createLogger('PollingAPI')
119

@@ -30,37 +28,6 @@ export async function GET(
3028
return NextResponse.json({ error: `Unknown polling provider: ${provider}` }, { status: 404 })
3129
}
3230

33-
if (isTriggerDevEnabled) {
34-
try {
35-
const handle = await providerPolling.trigger(
36-
{ provider, requestId },
37-
{
38-
concurrencyKey: provider,
39-
tags: [`provider:${provider}`],
40-
}
41-
)
42-
43-
logger.info(`[${requestId}] Dispatched ${provider} polling to trigger.dev`, {
44-
runId: handle.id,
45-
})
46-
47-
return NextResponse.json({
48-
success: true,
49-
message: `${provider} polling dispatched`,
50-
requestId,
51-
runId: handle.id,
52-
status: 'dispatched',
53-
})
54-
} catch (triggerError) {
55-
logger.warn(
56-
`[${requestId}] Trigger.dev dispatch failed for ${provider}, falling back to synchronous polling`,
57-
{
58-
error: triggerError instanceof Error ? triggerError.message : String(triggerError),
59-
}
60-
)
61-
}
62-
}
63-
6431
const LOCK_KEY = `${provider}-polling-lock`
6532
let lockValue: string | undefined
6633

apps/sim/background/provider-polling.ts

Lines changed: 0 additions & 34 deletions
This file was deleted.

0 commit comments

Comments
 (0)