Flowise

1
import { Request } from 'express'
2
import { Server } from 'socket.io'
3
import { StatusCodes } from 'http-status-codes'
4
import { utilBuildChatflow } from '../../utils/buildChatflow'
5
import { InternalFlowiseError } from '../../errors/internalFlowiseError'
6
import { getErrorMessage } from '../../errors/utils'
7

8
const buildChatflow = async (fullRequest: Request, ioServer: Server) => {
9
    try {
10
        const dbResponse = await utilBuildChatflow(fullRequest, ioServer)
11
        return dbResponse
12
    } catch (error) {
13
        throw new InternalFlowiseError(
14
            StatusCodes.INTERNAL_SERVER_ERROR,
15
            `Error: predictionsServices.buildChatflow - ${getErrorMessage(error)}`
16
        )
17
    }
18
}
19

20
export default {
21
    buildChatflow
22
}
23