fix(streaming-api): fix streaming api

[Sg312]

Summary

Fix streaming api for new executor and fix non agent block outputs in deployed chats

Type of Change

• Bug fix

Testing

Manual

Checklist

• Code follows project style guidelines
• Self-reviewed my changes
• Tests added/updated and passing
• No new warnings introduced
• I confirm that I have read and agree to the terms outlined in the Contributor License Agreement (CLA)

[vercel]

The latest updates on your projects. Learn more about Vercel for GitHub.

1 Skipped Deployment

Project	Deployment	Preview	Comments	Updated (UTC)
docs	Skipped			Nov 7, 2025 10:34pm

[greptile-apps]

Greptile Overview

Greptile Summary

This PR fixes streaming API functionality by adding support for deployed workflow execution with proper output selection and formatting.

Key Changes:

• Added resolveOutputIds function in workflow execution route to convert block names to UUIDs for deployed workflows
• Integrated createStreamingResponse for non-draft executions, enabling proper streaming for deployed chat workflows
• Enhanced chat streaming hook to handle outputConfigs, extracting and formatting specific block outputs in final responses
• Fixed MDX documentation formatting issues with escaped brackets in JSON examples

Implementation:
The PR splits execution paths: draft workflows use console log streaming (existing behavior), while deployed workflows now use the new streaming API that properly handles selected outputs through the createStreamingResponse function. The resolveOutputIds function handles multiple output ID formats (UUID-based, dot notation, block names) and normalizes them for the executor.

Confidence Score: 4/5

• Safe to merge with minor considerations around edge case handling
• The implementation is solid with proper fallback handling and logging. Score reflects the complexity of the resolveOutputIds function which handles multiple formats and edge cases. While the logic appears sound, the multiple conditional branches increase cognitive complexity and could benefit from additional test coverage for edge cases like blocks with special characters in names or ambiguous output ID formats.
• Pay closer attention to apps/sim/app/api/workflows/[id]/execute/route.ts - specifically the resolveOutputIds function's block name matching logic

Important Files Changed

File Analysis

Filename	Score	Overview
apps/sim/app/api/workflows/[id]/execute/route.ts	4/5	Added streaming API response for deployed workflows with new resolveOutputIds function to handle block name to UUID resolution
apps/sim/app/chat/hooks/use-chat-streaming.ts	4/5	Enhanced final event handling with outputConfigs support, formatting outputs from specific blocks and paths in chat responses

Sequence Diagram

sequenceDiagram
    participant Client as Chat Client
    participant API as /api/workflows/[id]/execute
    participant Streaming as createStreamingResponse
    participant Executor as executeWorkflow
    participant Hook as useChatStreaming

    Client->>API: POST with trigger=chat & streaming
    API->>API: Load deployed workflow state
    API->>API: resolveOutputIds(selectedOutputs, blocks)
    Note over API: Converts block names to UUIDs
    API->>Streaming: createStreamingResponse(config)
    Streaming->>Executor: executeWorkflow(workflow, streamConfig)
    
    loop For each streaming block
        Executor->>Streaming: onStream(blockId, stream)
        Streaming->>Client: SSE chunk events
        Client->>Hook: handleStreamedResponse
        Hook->>Hook: Accumulate text chunks
    end
    
    Executor->>Streaming: onBlockComplete(blockId, output)
    Note over Streaming: Extract selected outputs by path
    Streaming->>Client: SSE chunk with formatted output
    
    Streaming->>Streaming: Build minimal result with selected outputs
    Streaming->>Client: SSE final event with output data
    Client->>Hook: Process final event
    Hook->>Hook: Extract values using outputConfigs
    Hook->>Hook: Format outputs (JSON/string)
    Hook->>Hook: Combine accumulated text + formatted outputs
    Hook->>Client: Update message with final content

Loading

_{8 files reviewed, no comments}

_{Edit Code Review Agent Settings | Greptile}