| | |
| | | import type { |
| | | IOnCompleted, |
| | | IOnData, |
| | | IOnError, |
| | | IOnFile, |
| | | IOnIterationFinished, |
| | | IOnIterationNext, |
| | | IOnIterationStarted, |
| | | IOnLoopFinished, |
| | | IOnLoopNext, |
| | | IOnLoopStarted, |
| | | IOnMessageEnd, |
| | | IOnMessageReplace, |
| | | IOnNodeFinished, |
| | | IOnNodeStarted, |
| | | IOnTTSChunk, |
| | | IOnTTSEnd, |
| | | IOnTextChunk, |
| | | IOnTextReplace, |
| | | IOnThought, |
| | | IOnWorkflowFinished, |
| | | IOnWorkflowStarted, |
| | | } from './base' |
| | | import type { IOnCompleted, IOnData, IOnError, IOnFile, IOnIterationFinished, IOnIterationNext, IOnIterationStarted, IOnMessageEnd, IOnMessageReplace, IOnNodeFinished, IOnNodeStarted, IOnTTSChunk, IOnTTSEnd, IOnTextChunk, IOnTextReplace, IOnThought, IOnWorkflowFinished, IOnWorkflowStarted } from './base' |
| | | import { |
| | | del as consoleDel, get as consoleGet, patch as consolePatch, post as consolePost, |
| | | delPublic as del, getPublic as get, patchPublic as patch, postPublic as post, ssePost, |
| | |
| | | onIterationStart, |
| | | onIterationNext, |
| | | onIterationFinish, |
| | | onLoopStart, |
| | | onLoopNext, |
| | | onLoopFinish, |
| | | onTextChunk, |
| | | onTextReplace, |
| | | }: { |
| | |
| | | onIterationStart: IOnIterationStarted |
| | | onIterationNext: IOnIterationNext |
| | | onIterationFinish: IOnIterationFinished |
| | | onLoopStart: IOnLoopStarted |
| | | onLoopNext: IOnLoopNext |
| | | onLoopFinish: IOnLoopFinished |
| | | onTextChunk: IOnTextChunk |
| | | onTextReplace: IOnTextReplace |
| | | }, |
| | |
| | | ...body, |
| | | response_mode: 'streaming', |
| | | }, |
| | | }, { |
| | | onNodeStarted, |
| | | onWorkflowStarted, |
| | | onWorkflowFinished, |
| | | isPublicAPI: !isInstalledApp, |
| | | onNodeFinished, |
| | | onIterationStart, |
| | | onIterationNext, |
| | | onIterationFinish, |
| | | onLoopStart, |
| | | onLoopNext, |
| | | onLoopFinish, |
| | | onTextChunk, |
| | | onTextReplace, |
| | | }) |
| | | }, { onNodeStarted, onWorkflowStarted, onWorkflowFinished, isPublicAPI: !isInstalledApp, onNodeFinished, onIterationStart, onIterationNext, onIterationFinish, onTextChunk, onTextReplace }) |
| | | } |
| | | |
| | | export const fetchAppInfo = async () => { |
| | |
| | | return (getAction('post', !isPublicAPI))(url, { body, header }, { needAllResponseContent: true }) |
| | | } |
| | | |
| | | export const fetchAccessToken = async (appCode: string, userId?: string) => { |
| | | export const fetchAccessToken = async (appCode: string) => { |
| | | const headers = new Headers() |
| | | headers.append('X-App-Code', appCode) |
| | | const url = userId ? `/passport?user_id=${encodeURIComponent(userId)}` : '/passport' |
| | | return get(url, { headers }) as Promise<{ access_token: string }> |
| | | return get('/passport', { headers }) as Promise<{ access_token: string }> |
| | | } |