sendMessageQuery.ts

import { MessageType } from '@/components/Bot'
import { sendRequest } from '@/utils/index'

export type IncomingInput = {
    question: string
    history: MessageType[]
    overrideConfig?: Record<string, unknown>
    socketIOClientId?: string
}

export type MessageRequest = {
    chatflowid: string
    apiHost?: string
    body?: IncomingInput
    authToken?: string
}

export const sendMessageQuery = ({ chatflowid, apiHost = 'http://localhost:3000', body, authToken }: MessageRequest) =>
    sendRequest<any>({
        method: 'POST',
        url: `${apiHost}/api/v1/prediction/${chatflowid}`,
        body,
        authToken
    })

export const isStreamAvailableQuery = ({ chatflowid, apiHost = 'http://localhost:3000', authToken }: MessageRequest) =>
    sendRequest<any>({
        method: 'GET',
        url: `${apiHost}/api/v1/chatflows-streaming/${chatflowid}`,
        authToken
    })