Function setup

chirpstack/src/backend/roaming.rs:21–66

()

    LazyLock::new(|| RwLock::new(HashMap::new()));

pub async fn setup() -> Result<()> {
    info!("Setting up roaming clients");
    let conf = config::get();

    for s in &conf.roaming.servers {
        let span = span!(Level::INFO, "setup", net_id  = %s.net_id);
        let _guard = span.enter();

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

        info!(
            passive_roaming_lifetime = ?s.passive_roaming_lifetime,
            server = %server,
            async_timeout = ?s.async_timeout,
            "Configuring roaming client"
        );

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

        set(&s.net_id, c).await;
    }

    Ok(())
}

pub async fn set(net_id: &NetID, c: Client) {
    let mut clients_w = CLIENTS.write().await;