mirror of
https://github.com/vercel/workflow.git
synced 2026-09-14 19:59:43 +08:00
Peter Wielander
21 lines
573 B
TypeScript
21 lines
573 B
TypeScript
import { createWebhook } from 'workflow';
|
|
|
|
async function processPayload(body: string) {
|
|
'use step';
|
|
return JSON.parse(body) as Record<string, unknown>;
|
|
}
|
|
|
|
export async function webhookWorkflow(endpointId: string) {
|
|
'use workflow';
|
|
|
|
// createWebhook() does not accept a token — one is always generated for you.
|
|
// Use waitForHook() in tests to discover the token.
|
|
using webhook = createWebhook();
|
|
|
|
const request = await webhook;
|
|
const body = await request.text();
|
|
const parsed = await processPayload(body);
|
|
|
|
return { endpointId, received: parsed };
|
|
}
|