Function get

chirpstack/src/backend/roaming.rs:73–121

(net_id: &NetID)

}

pub async fn get(net_id: &NetID) -> Result<Arc<Client>> {
    let mut clients_w = CLIENTS.write().await;

    if let Some(client) = clients_w.get(net_id) {
        return Ok(client.clone());
    }

    let conf = config::get();
    if conf.roaming.default.enabled {
        debug!(net_id = %net_id, "Configuring default roaming client");

        let server = if conf.roaming.default.server.is_empty() {
            format!(
                "https://{}{}",
                net_id, conf.roaming.resolve_net_id_domain_suffix,
            )
        } else {
            conf.roaming.default.server.clone()
        };

        let c = Client::new(ClientConfig {
            sender_id: conf.network.net_id.to_vec(),
            receiver_id: net_id.to_vec(),
            server,
            use_target_role_suffix: conf.roaming.default.use_target_role_suffix,
            ca_cert: conf.roaming.default.ca_cert.clone(),
            tls_cert: conf.roaming.default.tls_cert.clone(),
            tls_key: conf.roaming.default.tls_key.clone(),
            authorization: if conf.roaming.default.authorization_header.is_empty() {
                None
            } else {
                Some(conf.roaming.default.authorization_header.clone())
            },
            async_timeout: conf.roaming.default.async_timeout,
            request_log_sender: stream::backend_interfaces::get_log_sender().await,
        })?;

        let c = Arc::new(c);
        let c_out = c.clone();
        clients_w.insert(*net_id, c);

        return Ok(c_out);
    }

    Err(anyhow!(
        "Roaming client for net_id {} does not exist",
        net_id
    ))
}

pub fn get_passive_roaming_lifetime(net_id: NetID) -> Result<std::time::Duration> {
    let conf = config::get();