3.2 Real-time Communication

The system implements real-time communication through Server-Sent Events:

@app.route("/", methods=["GET"])
def send_query():
    data = request.args.get("data", "")
    global output, user_input, stop_stream, input_requested
    input_requested = False
    stop_stream = False
    output.clear()
    user_input = data

    def generate():
        global stop_stream, input_requested
        last_length = 0
        while True:
            if len(output) > last_length:
                for x in output[last_length:]:
                    yield f"data: {json.dumps({'type': 'output', 'data': x})}\n\n".encode()
                last_length = len(output)

Features:

1. Event Streaming: Implements SSE

2. State Management: Tracks output state

3. Error Handling: Manages stream errors

4. Response Formatting: Formats JSON responses

5. Connection Management: Handles client connections