Uh oh!
There was an error while loading. Please reload this page.
[ai] Return UIMessage[] from DurableAgent stream call - #760
[ai] Return UIMessage[] from DurableAgent stream call#760VaguelySerious wants to merge 1 commit into
Conversation
Signed-off-by: Peter Wielander <mittgfu@gmail.com>
The latest updates on your projects. Learn more about Vercel for GitHub.
|
|
🧪 E2E Test Results✅ All tests passed Summary
Details by Category✅ ▲ Vercel Production
❌ Some E2E test jobs failed:
Check the workflow run for details. |
No benchmark result files found in benchmark-results |
| if (part.type === 'text' && part.text) { | ||
| this.currentMessage.parts.push({ | ||
| type: 'text', | ||
| text: part.text, | ||
| }); | ||
| } else if (part.type === 'reasoning' && part.text) { |
There was a problem hiding this comment.
| if(part.type==='text'&&part.text){ | |
| this.currentMessage.parts.push({ | |
| type: 'text', | |
| text: part.text, | |
| }); | |
| }elseif(part.type==='reasoning'&&part.text){ | |
| if(part.type==='text'&&part.text!==undefined&&part.text!==null){ | |
| this.currentMessage.parts.push({ | |
| type: 'text', | |
| text: part.text, | |
| }); | |
| }elseif(part.type==='reasoning'&&part.text!==undefined&&part.text!==null){ |
Empty text and reasoning parts are silently dropped due to falsy check, potentially losing valid empty message content
| } as any); | ||
| } | ||
| break; | ||
There was a problem hiding this comment.
The 'source-url' and 'source-document' cases don't call finalizeCurrentPart() before adding the source, causing pending text/reasoning/tool-invocation parts to be skipped or added out of order
| // Process the chunk to accumulate messages | ||
| this.processChunk(chunk); | ||
| // Forward to the inner writable | ||
| const writer = this.innerWritable.getWriter(); | ||
| try { | ||
| await writer.write(chunk); |
There was a problem hiding this comment.
| // Process the chunk to accumulate messages | |
| this.processChunk(chunk); | |
| // Forward to the inner writable | |
| constwriter=this.innerWritable.getWriter(); | |
| try{ | |
| awaitwriter.write(chunk); | |
| // Forward to the inner writable first, then process | |
| constwriter=this.innerWritable.getWriter(); | |
| try{ | |
| awaitwriter.write(chunk); | |
| // Only process the chunk if the write succeeded | |
| this.processChunk(chunk); |
UIMessageAccumulator processes chunks before verifying they can be written to the inner stream, causing accumulated messages to include chunks that failed to write.
VaguelySerious
commented
Jan 12, 2026
Closed in favor of #768 |
No description provided.