Function createWebhook

packages/server/src/controllers/webhook/index.ts:17–165

(req: Request, res: Response, next: NextFunction)

import logger from '../../utils/logger'

const createWebhook = async (req: Request, res: Response, next: NextFunction) => {
    try {
        if (typeof req.params === 'undefined' || !req.params.id) {
            throw new InternalFlowiseError(StatusCodes.PRECONDITION_FAILED, `Error: webhookController.createWebhook - id not provided!`)
        }

        const workspaceId = req.user?.activeWorkspaceId

        // For form-encoded requests, unwrap JSON encoded in a `payload` field (e.g. GitHub webhooks)
        // so $webhook.body.* resolves against the actual payload fields.
        const contentType = (req.headers['content-type'] ?? '').toLowerCase()
        let body = req.body
        if (contentType.startsWith('application/x-www-form-urlencoded') && typeof body?.payload === 'string') {
            try {
                body = JSON.parse(body.payload)
            } catch {
                // leave body as-is if payload isn't valid JSON
            }
        }

        const isResume = body?.humanInput != null

        const { responseMode, callbackUrl, callbackSecret } = await webhookService.validateWebhookChatflow(
            req.params.id,
            workspaceId,
            body,
            req.method,
            req.headers,
            req.query,
            (req as any).rawBody,
            isResume ? { skipFieldValidation: true } : undefined
        )

        // Namespace the webhook payload so $webhook.body.*, $webhook.headers.*, $webhook.query.* can coexist
        req.body = {
            webhook: {
                body,
                headers: redactSensitiveHeaders(req.headers as Record<string, any>),
                query: req.query
            }
        }

        const { humanInput, chatId: bodyChatId, sessionId } = body ?? {}
        if (humanInput != null) req.body.humanInput = humanInput
        if (bodyChatId != null) req.body.chatId = bodyChatId
        if (sessionId != null) req.body.sessionId = sessionId

        const executionChatId: string = (bodyChatId as string | undefined) ?? uuidv4()
        req.body.chatId = executionChatId

        // Mirror this execution's events to any UI panels currently listening to this flow.
        try {
            await getWebhookListenerRegistry().bindExecution(req.params.id, executionChatId)
        } catch (err) {
            logger.warn(`[webhookController] Failed to bind webhook listeners: ${getErrorMessage(err)}`)
        }

        if (responseMode === 'stream') {