ibkr-agent-gateway 0.5.2

Unofficial local-first CLI and MCP gateway for Interactive Brokers workflows.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39

//! Sidecar heartbeat handling.

use super::{RelaySession, RelaySessionId, SidecarId};
use crate::internal::domain::{ErrorCode, GatewayError};
use schemars::JsonSchema;
use serde::{Deserialize, Serialize};
use time::OffsetDateTime;

/// Heartbeat sent by a paired sidecar.
#[derive(Clone, Debug, Eq, PartialEq, Serialize, Deserialize, JsonSchema)]
pub struct SidecarHeartbeat {
    /// Sidecar id.
    pub sidecar_id: SidecarId,
    /// Relay session id.
    pub relay_session_id: RelaySessionId,
    /// Sidecar observed timestamp.
    #[schemars(with = "String")]
    #[serde(with = "time::serde::rfc3339")]
    pub observed_at: OffsetDateTime,
}

/// Applies a heartbeat to an existing session after binding checks.
pub fn apply_heartbeat(
    session: &mut RelaySession,
    heartbeat: &SidecarHeartbeat,
) -> Result<(), GatewayError> {
    if session.sidecar_id != heartbeat.sidecar_id
        || session.relay_session_id != heartbeat.relay_session_id
    {
        return Err(GatewayError::new(
            ErrorCode::SidecarSessionInvalid,
            "Sidecar heartbeat does not match the relay session binding",
            false,
            Some("Re-pair the sidecar before forwarding broker requests".to_string()),
        ));
    }
    session.heartbeat_at = heartbeat.observed_at;
    Ok(())
}