import type { IOnCompleted, IOnData, IOnError, IOnFile, IOnMessageEnd, IOnMessageReplace, IOnThought } from './base' import type { ModelParameterRule } from '@/app/components/header/account-setting/model-provider-page/declarations' import type { ChatPromptConfig, CompletionPromptConfig } from '@/models/debug' import type { AppModeEnum, ModelModeType } from '@/types/app' import { get, post, ssePost } from './base' export type BasicAppFirstRes = { prompt: string variables: string[] opening_statement: string error?: string } export type GenRes = { modified: string message?: string // tip for human variables?: string[] // only for basic app first time rule opening_statement?: string // only for basic app first time rule error?: string } export type ToolRecommendation = { requested_capability: string unconfigured_tools: Array<{ provider_id: string tool_name: string description: string }> configured_alternatives: Array<{ provider_id: string tool_name: string description: string }> recommendation: string } export type BackendNodeSpec = { id: string type: string title?: string config?: Record position?: { x: number, y: number } } export type BackendEdgeSpec = { source: string target: string sourceHandle?: string targetHandle?: string } export type FlowchartGenRes = { intent?: 'generate' | 'off_topic' | 'error' flowchart: string nodes?: BackendNodeSpec[] edges?: BackendEdgeSpec[] message?: string warnings?: string[] suggestions?: string[] tool_recommendations?: ToolRecommendation[] error?: string } export type CodeGenRes = { code: string language: string[] error?: string } export const sendChatMessage = async (appId: string, body: Record, { onData, onCompleted, onThought, onFile, onError, getAbortController, onMessageEnd, onMessageReplace }: { onData: IOnData onCompleted: IOnCompleted onFile: IOnFile onThought: IOnThought onMessageEnd: IOnMessageEnd onMessageReplace: IOnMessageReplace onError: IOnError getAbortController?: (abortController: AbortController) => void }) => { return ssePost(`apps/${appId}/chat-messages`, { body: { ...body, response_mode: 'streaming', }, }, { onData, onCompleted, onThought, onFile, onError, getAbortController, onMessageEnd, onMessageReplace }) } export const stopChatMessageResponding = async (appId: string, taskId: string) => { return post(`apps/${appId}/chat-messages/${taskId}/stop`) } export const sendCompletionMessage = async (appId: string, body: Record, { onData, onCompleted, onError, onMessageReplace }: { onData: IOnData onCompleted: IOnCompleted onError: IOnError onMessageReplace: IOnMessageReplace }) => { return ssePost(`apps/${appId}/completion-messages`, { body: { ...body, response_mode: 'streaming', }, }, { onData, onCompleted, onError, onMessageReplace }) } export const fetchSuggestedQuestions = (appId: string, messageId: string, getAbortController?: any) => { return get( `apps/${appId}/chat-messages/${messageId}/suggested-questions`, {}, { getAbortController, }, ) } export const fetchConversationMessages = (appId: string, conversation_id: string, getAbortController?: any) => { return get(`apps/${appId}/chat-messages`, { params: { conversation_id, }, }, { getAbortController, }) } export const generateBasicAppFirstTimeRule = (body: Record) => { return post('/rule-generate', { body, }) } export const generateRule = (body: Record) => { return post('/instruction-generate', { body, }) } export const generateFlowchart = (body: Record) => { return post('/flowchart-generate', { body, }) } export const fetchModelParams = (providerName: string, modelId: string) => { return get(`workspaces/current/model-providers/${providerName}/models/parameter-rules`, { params: { model: modelId, }, }) as Promise<{ data: ModelParameterRule[] }> } export const fetchPromptTemplate = ({ appMode, mode, modelName, hasSetDataSet, }: { appMode: AppModeEnum, mode: ModelModeType, modelName: string, hasSetDataSet: boolean }) => { return get>('/app/prompt-templates', { params: { app_mode: appMode, model_mode: mode, model_name: modelName, has_context: hasSetDataSet, }, }) } export const fetchTextGenerationMessage = ({ appId, messageId, }: { appId: string, messageId: string }) => { return get>(`/apps/${appId}/messages/${messageId}`) }