11import { createLogger } from '@sim/logger'
22import { type NextRequest , NextResponse } from 'next/server'
33import { verifyCronAuth } from '@/lib/auth/internal'
4- import { isTriggerDevEnabled } from '@/lib/core/config/feature-flags'
54import { acquireLock , releaseLock } from '@/lib/core/config/redis'
65import { generateShortId } from '@/lib/core/utils/uuid'
76import { pollProvider , VALID_POLLING_PROVIDERS } from '@/lib/webhooks/polling'
8- import { providerPolling } from '@/background/provider-polling'
97
108const 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
0 commit comments