Method get_proxy_state

gateway/src/debug_service.rs:111–147

(self)

    }

    async fn get_proxy_state(self) -> Result<DebugProxyStateResponse> {
        let state = self.state.lock();

        // Get all instances from ProxyState
        let instances: Vec<ProxyStateInstance> = state
            .state
            .instances
            .values()
            .map(|inst| {
                let reg_time = inst
                    .reg_time
                    .duration_since(std::time::UNIX_EPOCH)
                    .map(|d| d.as_secs())
                    .unwrap_or(0);
                ProxyStateInstance {
                    instance_id: inst.id.clone(),
                    app_id: inst.app_id.clone(),
                    ip: inst.ip.to_string(),
                    public_key: inst.public_key.clone(),
                    reg_time,
                }
            })
            .collect();

        // Get all allocated addresses
        let allocated_addresses: Vec<String> = state
            .state
            .allocated_addresses
            .iter()
            .map(|ip| ip.to_string())
            .collect();

        Ok(DebugProxyStateResponse {
            instances,
            allocated_addresses,
        })
    }
}

impl RpcCall<Proxy> for DebugRpcHandler {