diff --git a/src/index.ts b/src/index.ts index b327b4a..0ef3e9e 100644 --- a/src/index.ts +++ b/src/index.ts @@ -11,15 +11,8 @@ import { mediaSchema } from '@/schema'; import { validateTurnstile } from '@/turnstile'; const app = new Hono(); + let eventId = 0; - -const fetcher = makeStandardFetcher(fetch); - -const providers = makeProviders({ - fetcher, - target: targets.NATIVE, -}); - async function writeSSEEvent( stream: Parameters['1']>['0'], event: string, @@ -62,6 +55,13 @@ app.get('/scrape', async (context) => { return context.text('An error has occurred!'); } + const fetcher = makeStandardFetcher(fetch); + + const providers = makeProviders({ + fetcher, + target: targets.NATIVE, + }); + return streamSSE(context, async (stream) => { const output = await providers.runAll({ media,