Flowise

1
import { StatusCodes } from 'http-status-codes'
2
import { findAvailableConfigs } from '../../utils'
3
import { IReactFlowObject } from '../../Interface'
4
import { getRunningExpressApp } from '../../utils/getRunningExpressApp'
5
import chatflowsService from '../chatflows'
6
import { InternalFlowiseError } from '../../errors/internalFlowiseError'
7
import { getErrorMessage } from '../../errors/utils'
8

9
const getSingleFlowConfig = async (chatflowId: string): Promise<any> => {
10
    try {
11
        const appServer = getRunningExpressApp()
12
        const chatflow = await chatflowsService.getChatflowById(chatflowId)
13
        if (!chatflow) {
14
            throw new InternalFlowiseError(StatusCodes.NOT_FOUND, `Chatflow ${chatflowId} not found in the database!`)
15
        }
16
        const flowData = chatflow.flowData
17
        const parsedFlowData: IReactFlowObject = JSON.parse(flowData)
18
        const nodes = parsedFlowData.nodes
19
        const dbResponse = findAvailableConfigs(nodes, appServer.nodesPool.componentCredentials)
20
        return dbResponse
21
    } catch (error) {
22
        throw new InternalFlowiseError(
23
            StatusCodes.INTERNAL_SERVER_ERROR,
24
            `Error: flowConfigService.getSingleFlowConfig - ${getErrorMessage(error)}`
25
        )
26
    }
27
}
28

29
export default {
30
    getSingleFlowConfig
31
}
32