Struct TunnelConnection 

pub struct TunnelConnection {
    pub tunnel_id: String,
    pub ws_sender: WsSender,
    pub pending_requests: DashMap<String, PendingRequest>,
    pub created_at: DateTime<Utc>,
    pub last_activity: RwLock<DateTime<Utc>>,
    pub source_ip: String,
}

Represents an active tunnel connection from a local agent

Fields

tunnel_id: String

Unique tunnel identifier

ws_sender: WsSender

WebSocket sender for sending messages to the agent

pending_requests: DashMap<String, PendingRequest>

Pending HTTP requests awaiting responses

created_at: DateTime<Utc>

Creation timestamp

last_activity: RwLock<DateTime<Utc>>

Last activity timestamp

source_ip: String

Source IP address

Implementations

impl TunnelConnection

pub fn new(tunnel_id: String, ws_sender: WsSender, source_ip: String) -> Self

Create a new tunnel connection

pub async fn send_encrypted( &self, message_type: u8, encrypted: Vec<u8>, ) -> Result<()>

Send a data message through the tunnel (already encrypted)

pub fn register_request(&self, request_id: String) -> Receiver<DataMessage>

Register a pending request and get a receiver for the response

pub fn register_streaming_request( &self, request_id: String, ) -> Receiver<DataMessage>

Register a streaming request (for SSE) and get a receiver for chunks

pub fn complete_request(&self, request_id: &str, response: DataMessage) -> bool

Complete a pending request with a response

pub async fn send_chunk(&self, request_id: &str, chunk: DataMessage) -> bool

Send a chunk to a streaming request (returns false if request not found or not streaming)

pub fn complete_streaming_request(&self, request_id: &str)

Complete a streaming request (removes it from pending)

pub fn cancel_all_requests(&self)

Cancel all pending requests (called on disconnect)