Class IpcClient

src/host/ipc/ipc_client.h:49–125

Qt-free port of the window-side of the Qt MessageHandler: decodes inbound messages (SetAvailableSymbols, GetObservedSymbols, PlotBufferContents, PlotBufferBegin/Chunk/End) into the IpcBufferModel + symbol list, and sends outbound requests (PlotBufferRequest, BufferRemoved). The transport is injected as oid::ITransport& so this is unit-testable against a fake transport with no live socket.

// is injected as oid::ITransport& so this is unit-testable against a fake
// transport with no live socket.
class IpcClient {
  public:
    IpcClient(oid::ITransport& transport, IpcBufferModel& model);

    // Drains all currently-available inbound messages into the model /
    // symbol list. Called once per frame. Never blocks the caller beyond
    // the transport's own bounded reads; catches std::runtime_error
    // (SocketTimeoutError) if a message header/body isn't fully available
    // yet.
    void poll();

    // Outbound (from the chrome):
    void request_plot(const std::string& variable_name);   // PlotBufferRequest
    void notify_removed(const std::string& variable_name); // BufferRemoved

    // Sends SessionStateChanged (type 7): a single JSON string, verbatim
    // (no parsing/validation here -- the caller owns the JSON shape).
    void send_session_state_changed(const std::string& json);

    // Sends ExportBufferRequest (type 5): variable name, export format, and
    // an 8-entry contrast vector. Mirrors the Qt sender
    // (MessageHandler::request_export_buffer): entries beyond `contrast`'s
    // size are padded with 0.0f, and only the first 8 entries of `contrast`
    // are sent (extras ignored), matching the wire's fixed 8-float layout.
    void send_export_buffer_request(const std::string& variable_name,
                                    int format,
                                    const std::vector<float>& contrast);

    // Registers the callback invoked when an inbound ApplySessionState
    // (type 6) message is decoded; called with the JSON string verbatim.
    // Not required to be set: if unset, the message is still fully
    // consumed from the transport (so the stream isn't left desynced) and
    // silently dropped.
    void
    set_session_state_callback(std::function<void(const std::string& json)> cb);

    // Registers the callback invoked when an inbound ExportSelectedBuffer
    // (type 8) message is decoded. ExportSelectedBuffer carries no payload
    // (mirrors the Qt side, which just emits exportSelectedBufferRequested()
    // with no arguments). Not required to be set.
    void set_export_selected_callback(std::function<void()> cb);

    // Latest available-symbols list (from SetAvailableSymbols); UiState
    // reads it.
    [[nodiscard]] const std::vector<std::string>& available_symbols() const;

    // Seed the previous-session buffers to auto-restore. On the next
    // SetAvailableSymbols, each entry that is available, not already loaded,
    // not expired (now < expiry) is re-requested via request_plot.
    // Idempotent.
    void set_restore_buffers(std::vector<oid::host::PreviousBuffer> buffers);

  private:
    void dispatch(oid::MessageType header);

    // Per-message-type handlers: each decodes (or applies) exactly one
    // oid::MessageType and fully consumes its wire payload.
    void handle_set_available_symbols();