Function checkFlowValidation

packages/server/src/services/validation/index.ts:315–339

(flowId: string, workspaceId?: string)

}

const checkFlowValidation = async (flowId: string, workspaceId?: string): Promise<IValidationResult[]> => {
    try {
        const appServer = getRunningExpressApp()

        // Create query conditions with workspace filtering if provided
        const whereCondition: any = { id: flowId }
        if (workspaceId) whereCondition.workspaceId = workspaceId

        const flow = await appServer.AppDataSource.getRepository(ChatFlow).findOne({
            where: whereCondition
        })

        if (!flow) {
            throw new InternalFlowiseError(StatusCodes.NOT_FOUND, `Error: validationService.checkFlowValidation - flow not found!`)
        }

        const flowData: IReactFlowObject = JSON.parse(flow.flowData)
        return validateFlowData(flowData.nodes, flowData.edges, appServer.nodesPool.componentNodes)
    } catch (error) {
        throw new InternalFlowiseError(
            StatusCodes.INTERNAL_SERVER_ERROR,
            `Error: validationService.checkFlowValidation - ${getErrorMessage(error)}`
        )
    }
}

export default {
    checkFlowValidation