Flowise

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

8
const getAllNodeConfigs = async (requestBody: any) => {
9
    try {
10
        const appServer = getRunningExpressApp()
11
        const nodes = [{ data: requestBody }] as IReactFlowNode[]
12
        const dbResponse = findAvailableConfigs(nodes, appServer.nodesPool.componentCredentials)
13
        return dbResponse
14
    } catch (error) {
15
        throw new InternalFlowiseError(
16
            StatusCodes.INTERNAL_SERVER_ERROR,
17
            `Error: nodeConfigsService.getAllNodeConfigs - ${getErrorMessage(error)}`
18
        )
19
    }
20
}
21

22
export default {
23
    getAllNodeConfigs
24
}
25