debug.ts 3.1 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495
  1. import { get, post, ssePost } from './base'
  2. import type { IOnCompleted, IOnData, IOnError, IOnFile, IOnMessageEnd, IOnMessageReplace, IOnThought } from './base'
  3. import type { ChatPromptConfig, CompletionPromptConfig } from '@/models/debug'
  4. import type { ModelModeType } from '@/types/app'
  5. import type { ModelParameterRule } from '@/app/components/header/account-setting/model-provider-page/declarations'
  6. export type AutomaticRes = {
  7. prompt: string
  8. variables: string[]
  9. opening_statement: string
  10. }
  11. export const sendChatMessage = async (appId: string, body: Record<string, any>, { onData, onCompleted, onThought, onFile, onError, getAbortController, onMessageEnd, onMessageReplace }: {
  12. onData: IOnData
  13. onCompleted: IOnCompleted
  14. onFile: IOnFile
  15. onThought: IOnThought
  16. onMessageEnd: IOnMessageEnd
  17. onMessageReplace: IOnMessageReplace
  18. onError: IOnError
  19. getAbortController?: (abortController: AbortController) => void
  20. }) => {
  21. return ssePost(`apps/${appId}/chat-messages`, {
  22. body: {
  23. ...body,
  24. response_mode: 'streaming',
  25. },
  26. }, { onData, onCompleted, onThought, onFile, onError, getAbortController, onMessageEnd, onMessageReplace })
  27. }
  28. export const stopChatMessageResponding = async (appId: string, taskId: string) => {
  29. return post(`apps/${appId}/chat-messages/${taskId}/stop`)
  30. }
  31. export const sendCompletionMessage = async (appId: string, body: Record<string, any>, { onData, onCompleted, onError, onMessageReplace }: {
  32. onData: IOnData
  33. onCompleted: IOnCompleted
  34. onError: IOnError
  35. onMessageReplace: IOnMessageReplace
  36. }) => {
  37. return ssePost(`apps/${appId}/completion-messages`, {
  38. body: {
  39. ...body,
  40. response_mode: 'streaming',
  41. },
  42. }, { onData, onCompleted, onError, onMessageReplace })
  43. }
  44. export const fetchSuggestedQuestions = (appId: string, messageId: string) => {
  45. return get(`apps/${appId}/chat-messages/${messageId}/suggested-questions`)
  46. }
  47. export const fetchConvesationMessages = (appId: string, conversation_id: string) => {
  48. return get(`apps/${appId}/chat-messages`, {
  49. params: {
  50. conversation_id,
  51. },
  52. })
  53. }
  54. export const generateRule = (body: Record<string, any>) => {
  55. return post<AutomaticRes>('/rule-generate', {
  56. body,
  57. })
  58. }
  59. export const fetchModelParams = (providerName: string, modelId: string) => {
  60. return get(`workspaces/current/model-providers/${providerName}/models/parameter-rules`, {
  61. params: {
  62. model: modelId,
  63. },
  64. }) as Promise<{ data: ModelParameterRule[] }>
  65. }
  66. export const fetchPromptTemplate = ({
  67. appMode,
  68. mode,
  69. modelName,
  70. hasSetDataSet,
  71. }: { appMode: string; mode: ModelModeType; modelName: string; hasSetDataSet: boolean }) => {
  72. return get<Promise<{ chat_prompt_config: ChatPromptConfig; completion_prompt_config: CompletionPromptConfig; stop: [] }>>('/app/prompt-templates', {
  73. params: {
  74. app_mode: appMode,
  75. model_mode: mode,
  76. model_name: modelName,
  77. has_context: hasSetDataSet,
  78. },
  79. })
  80. }
  81. export const fetchTextGenerationMessge = ({
  82. appId,
  83. messageId,
  84. }: { appId: string; messageId: string }) => {
  85. return get<Promise<{ message: [] }>>(`/apps/${appId}/messages/${messageId}`)
  86. }