from flask import Flask, Response
import json
import time

app = Flask(__name__)

@app.route('/stream')
def stream():
    def event_stream():
        while True:
            # Get data from your workflow
            data = get_workflow_status()
            yield f"data: {json.dumps(data)}\n\n"
            time.sleep(1)
    
    return Response(event_stream(), mimetype="text/plain")

const eventSource = new EventSource('/stream');

eventSource.onmessage = function(event) {
    const data = JSON.parse(event.data);
    console.log('Received:', data);
};

eventSource.onerror = function(event) {
    console.error('SSE error:', event);
};

{
  "type": "status",
  "status": "running",
  "progress": 45,
  "message": "Processing step 3 of 7"
}

{
  "type": "result",
  "tool": "file_processor",
  "result": "File processed successfully",
  "timestamp": "2024-01-01T00:00:00Z"
}

{
  "type": "error",
  "error": "Tool execution failed",
  "details": "Connection timeout",
  "timestamp": "2024-01-01T00:00:00Z"
}

streaming:
  enabled: true
  max_connections: 100
  heartbeat_interval: 30
  buffer_size: 8192

const eventSource = new EventSource('/stream', {
  withCredentials: true,
  headers: {
    'Authorization': 'Bearer YOUR_TOKEN'
  }
});