diff --git a/src/backend/src/modules/puterai/AIChatService.js b/src/backend/src/modules/puterai/AIChatService.js index 98156af0b..56857c305 100644 --- a/src/backend/src/modules/puterai/AIChatService.js +++ b/src/backend/src/modules/puterai/AIChatService.js @@ -598,6 +598,9 @@ class AIChatService extends BaseService { try { await ret.result.value.init_chat_stream({ chatStream }); } catch (e) { + this.errors.report('error during stream response', { + source: e, + }) stream.write(JSON.stringify({ type: 'error', message: e.message, diff --git a/src/backend/src/modules/puterai/lib/Streaming.js b/src/backend/src/modules/puterai/lib/Streaming.js index ad2e1f9ea..5bbfb8bff 100644 --- a/src/backend/src/modules/puterai/lib/Streaming.js +++ b/src/backend/src/modules/puterai/lib/Streaming.js @@ -49,6 +49,7 @@ class AIChatToolUseStream extends AIChatConstructStream { if ( this.buffer.trim() === '' ) { this.buffer = '{}'; } + if ( process.env.DEBUG ) console.log('BUFFER BEING PARSED', this.buffer); const str = JSON.stringify(objectAssignTop({ ...this.contentBlock, input: JSON.parse(this.buffer),