Function event_stream

AppData/app.py:503–525

Server-Sent Events endpoint for real-time updates

()

@app.route('/api/events')
def event_stream():
    """Server-Sent Events endpoint for real-time updates"""
    def generate():
        try:
            while True:
                try:
                    # Wait for events with timeout
                    event = event_queue.get(timeout=30)
                    yield f"data: {json.dumps(event)}\n\n"
                except queue.Empty:
                    # Send heartbeat to keep connection alive
                    yield f"data: {json.dumps({'type': 'heartbeat'})}\n\n"
                except Exception as e:
                    yield f"data: {json.dumps({'type': 'error', 'message': str(e)})}\n\n"
                    break
        except GeneratorExit:
            pass
    
    return Response(generate(), mimetype='text/plain', headers={
        'Cache-Control': 'no-cache',
        'Connection': 'keep-alive',
        'Access-Control-Allow-Origin': '*'
    })

@app.route('/api/graph/stream', methods=['POST'])
def graph_stream():