.post('/:integration/fetch', zValidator('param', z.object({ integration: z.string().min(1) })), async (ctx) => {
const { integration } = ctx.req.valid('param')
const instance = await ctx.env.HistoryIngestion.create({
id: integration,
params: { integrationId: integration },
})
await ctx.env.Jobs.put(
`workflow:${integration}`,
JSON.stringify({ instance: instance.id, status: 'pending', progress: 0, startedAt: Date.now() }),
)
return ctx.json({ success: true }, 202)
})
.post('/:integration/fetch', zValidator('param', z.object({ integration: z.string().min(1) })), async (ctx) => {
const { integration } = ctx.req.valid('param')
const instance = await ctx.env.HistoryIngestion.create({
id: integration,
params: { integrationId: integration },
})
await ctx.env.Jobs.put(
`workflow:${integration}`,
JSON.stringify({ instance: instance.id, status: 'pending', progress: 0, startedAt: Date.now() }),
)
return ctx.json({ success: true }, 202)
})