Function generate

AppData/app.py:505–519

()

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',