jason/ThunderAI
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

added a log of the full raw AI response after streaming

Browse source
This commit is contained in:
Mic 2026-03-05 23:52:00 +01:00
parent c275625111
commit 50d8e8e41f
5 changed files with 11 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
js/workers/model-worker-anthropic.js
View file

@ -80,6 +80,7 @@ self.onmessage = async function(event) {
if (stopStreaming) { if (stopStreaming) {
stopStreaming = false; stopStreaming = false;
reader.cancel(); reader.cancel();
taLog.log("AI full response [STOPPED]: " + assistantResponseAccumulator);
conversationHistory.push({ role: 'assistant', content: assistantResponseAccumulator }); conversationHistory.push({ role: 'assistant', content: assistantResponseAccumulator });
assistantResponseAccumulator = ''; assistantResponseAccumulator = '';
postMessage({ type: 'tokensDone' }); postMessage({ type: 'tokensDone' });
@ -87,6 +88,7 @@ self.onmessage = async function(event) {
} }
const { done, value } = await reader.read(); const { done, value } = await reader.read();
if (done) { if (done) {
taLog.log("AI full response: " + assistantResponseAccumulator);
conversationHistory.push({ role: 'assistant', content: assistantResponseAccumulator }); conversationHistory.push({ role: 'assistant', content: assistantResponseAccumulator });
assistantResponseAccumulator = ''; assistantResponseAccumulator = '';
postMessage({ type: 'tokensDone' }); postMessage({ type: 'tokensDone' });
@ -138,6 +140,7 @@ self.onmessage = async function(event) {
break; break;
case 'message_stop': case 'message_stop':
taLog.log("AI full response: " + assistantResponseAccumulator);
conversationHistory.push({ role: 'assistant', content: assistantResponseAccumulator }); conversationHistory.push({ role: 'assistant', content: assistantResponseAccumulator });
assistantResponseAccumulator = ''; assistantResponseAccumulator = '';
postMessage({ type: 'tokensDone' }); postMessage({ type: 'tokensDone' });

2
js/workers/model-worker-google_gemini.js
View file

@ -79,6 +79,7 @@ self.onmessage = async function(event) {
if (stopStreaming) { if (stopStreaming) {
stopStreaming = false; stopStreaming = false;
reader.cancel(); reader.cancel();
taLog.log("AI full response [STOPPED]: " + assistantResponseAccumulator);
conversationHistory.push({ role: 'model', parts: [{"text": assistantResponseAccumulator}] }); conversationHistory.push({ role: 'model', parts: [{"text": assistantResponseAccumulator}] });
assistantResponseAccumulator = ''; assistantResponseAccumulator = '';
postMessage({ type: 'tokensDone' }); postMessage({ type: 'tokensDone' });
@ -86,6 +87,7 @@ self.onmessage = async function(event) {
} }
const { done, value } = await reader.read(); const { done, value } = await reader.read();
if (done) { if (done) {
taLog.log("AI full response: " + assistantResponseAccumulator);
conversationHistory.push({ role: 'model', parts: [{"text": assistantResponseAccumulator}] }); conversationHistory.push({ role: 'model', parts: [{"text": assistantResponseAccumulator}] });
assistantResponseAccumulator = ''; assistantResponseAccumulator = '';
postMessage({ type: 'tokensDone' }); postMessage({ type: 'tokensDone' });

2
js/workers/model-worker-ollama.js
View file

@ -81,6 +81,7 @@ self.onmessage = async function(event) {
if (stopStreaming) { if (stopStreaming) {
stopStreaming = false; stopStreaming = false;
reader.cancel(); reader.cancel();
taLog.log("AI full response [STOPPED]: " + assistantResponseAccumulator);
conversationHistory.push({ role: 'assistant', content: assistantResponseAccumulator }); conversationHistory.push({ role: 'assistant', content: assistantResponseAccumulator });
assistantResponseAccumulator = ''; assistantResponseAccumulator = '';
postMessage({ type: 'tokensDone' }); postMessage({ type: 'tokensDone' });
@ -89,6 +90,7 @@ self.onmessage = async function(event) {
} }
const { done, value } = await reader.read(); const { done, value } = await reader.read();
if (done) { if (done) {
taLog.log("AI full response: " + assistantResponseAccumulator);
conversationHistory.push({ role: 'assistant', content: assistantResponseAccumulator }); conversationHistory.push({ role: 'assistant', content: assistantResponseAccumulator });
assistantResponseAccumulator = ''; assistantResponseAccumulator = '';
postMessage({ type: 'tokensDone' }); postMessage({ type: 'tokensDone' });

2
js/workers/model-worker-openai_comp.js
View file

@ -79,6 +79,7 @@ self.onmessage = async function(event) {
if (stopStreaming) { if (stopStreaming) {
stopStreaming = false; stopStreaming = false;
reader.cancel(); reader.cancel();
taLog.log("AI full response [STOPPED]: " + assistantResponseAccumulator);
conversationHistory.push({ role: 'assistant', content: assistantResponseAccumulator }); conversationHistory.push({ role: 'assistant', content: assistantResponseAccumulator });
assistantResponseAccumulator = ''; assistantResponseAccumulator = '';
postMessage({ type: 'tokensDone' }); postMessage({ type: 'tokensDone' });
@ -86,6 +87,7 @@ self.onmessage = async function(event) {
} }
const { done, value } = await reader.read(); const { done, value } = await reader.read();
if (done) { if (done) {
taLog.log("AI full response: " + assistantResponseAccumulator);
conversationHistory.push({ role: 'assistant', content: assistantResponseAccumulator }); conversationHistory.push({ role: 'assistant', content: assistantResponseAccumulator });
assistantResponseAccumulator = ''; assistantResponseAccumulator = '';
postMessage({ type: 'tokensDone' }); postMessage({ type: 'tokensDone' });

2
js/workers/model-worker-openai_responses.js
View file

@ -90,6 +90,7 @@ self.onmessage = async function(event) {
if (stopStreaming) { if (stopStreaming) {
stopStreaming = false; stopStreaming = false;
reader.cancel(); reader.cancel();
taLog.log("AI full response [STOPPED]: " + assistantResponseAccumulator);
conversationHistory.push({ role: 'assistant', content: assistantResponseAccumulator }); conversationHistory.push({ role: 'assistant', content: assistantResponseAccumulator });
assistantResponseAccumulator = ''; assistantResponseAccumulator = '';
postMessage({ type: 'tokensDone' }); postMessage({ type: 'tokensDone' });
@ -97,6 +98,7 @@ self.onmessage = async function(event) {
} }
const { done, value } = await reader.read(); const { done, value } = await reader.read();
if (done) { if (done) {
taLog.log("AI full response: " + assistantResponseAccumulator);
conversationHistory.push({ role: 'assistant', content: assistantResponseAccumulator }); conversationHistory.push({ role: 'assistant', content: assistantResponseAccumulator });
assistantResponseAccumulator = ''; assistantResponseAccumulator = '';
postMessage({ type: 'tokensDone' }); postMessage({ type: 'tokensDone' });