Function chatflowCallback

packages/server/src/services/mcp-endpoint/index.ts:184–218

* Callback function for MCP tool execution * @return The tool response content, extracted from the utilBuildChatflow result

(
    chatflow: ChatFlow,
    chatId: string,
    req: Request,
    args: any
)

 * @return The tool response content, extracted from the utilBuildChatflow result
 */
async function chatflowCallback(
    chatflow: ChatFlow,
    chatId: string,
    req: Request,
    args: any
): Promise<{ content: { type: 'text'; text: string }[]; isError?: boolean }> {
    const inputType = getToolInputType(chatflow)
    const body = inputType === 'form' ? { form: args.form || {} } : { question: args.question || '' }
    const mockReq = createMockRequest({
        chatflowId: chatflow.id,
        body: {
            ...body,
            chatId
        },
        sourceRequest: req
    })

    const result = await utilBuildChatflow(mockReq, true, ChatType.MCP)

    // Extract the text response from the result
    let textContent: string
    if (typeof result === 'string') {
        textContent = result
    } else if (result?.text) {
        textContent = result.text
    } else if (result?.json) {
        textContent = JSON.stringify(result.json)
    } else {
        textContent = JSON.stringify(result)
    }

    return {
        content: [{ type: 'text' as const, text: textContent }]
    }
}

/**
 * Handle an InternalFlowiseError from getChatflowByIdAndVerifyToken.