Forker/OpenNoodl
1
0
Fork 0
mirror of https://github.com/The-Low-Code-Foundation/OpenNoodl.git synced 2026-01-10 14:22:53 +01:00
Code Issues Actions Packages Projects Releases 1 Wiki Activity

Changed AI API call error conditions

Browse Source
This commit is contained in:
Richard Osborne
2024-05-02 17:13:27 +02:00
parent 2ed053ec75
commit ecf124d43d
1 changed files with 9 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

25
packages/noodl-editor/src/editor/src/models/AiAssistant/context/ai-api.ts
View File

@@ -38,13 +38,14 @@ async function directChatOpenAi({ messages, provider, abortController, onEnd, on
stream: true
}),
async onopen(response) {
if (response.ok && response.headers.get('content-type') === EventStreamContentType) {
const contentType = response.headers.get('content-type') || '';
if (response.ok && contentType.includes('text/event-stream')) {
return; // everything's good
} else if (response.status >= 400 && response.status < 500 && response.status !== 429) {
// client-side errors are usually non-retriable:
throw 'FatalError';
} else {
throw 'RetriableError';
// If status is not OK or content type is unexpected, throw the response body
const errorMessage = await response.text(); // Await the response body text
const errorDetails = `HTTP ${response.status} - ${response.statusText}: ${errorMessage}`;
throw errorDetails; // Throw the raw error string
}
},
onmessage(ev) {
@@ -70,18 +71,10 @@ async function directChatOpenAi({ messages, provider, abortController, onEnd, on
onEnd && onEnd();
},
onerror(err) {
const errText = err.toString();
if (['FatalError'].includes(errText)) {
throw err; // rethrow to stop the operation
} else if (['RetriableError'].includes(errText)) {
if (tries <= 0) {
throw `Apologies, OpenAI is currently facing heavy traffic, causing delays in processing requests. Please be patient and try again later.`;
}
tries--;
} else {
// do nothing to automatically retry. You can also
// return a specific retry interval here.
if (tries <= 0) {
throw err; // Just rethrow the error directly
}
tries--;
}
});