Function update_gateway_metadata

chirpstack/src/uplink/mod.rs:370–417

(ufs: &mut UplinkFrameSet)

}

async fn update_gateway_metadata(ufs: &mut UplinkFrameSet) -> Result<()> {
    let conf = config::get();
    for rx_info in &mut ufs.rx_info_set {
        let gw_id = EUI64::from_str(&rx_info.gateway_id).context("Gateway ID")?;
        let gw_meta = match gateway::get_meta(&gw_id).await {
            Ok(v) => v,
            Err(e) => {
                if conf.gateway.allow_unknown_gateways
                    && let StorageError::NotFound(_) = e
                {
                    ufs.gateway_private_up_map.insert(gw_id, false);
                    ufs.gateway_private_down_map.insert(gw_id, false);
                    continue;
                }

                error!(
                    gateway_id = %gw_id,
                    error = %e.full(),
                    "Getting gateway meta-data failed"
                );
                continue;
            }
        };

        // Do not overwrite the location if it is already set. In case of a 'virtual' it is
        // possible that the location is already set in the RxInfo. Overwriting this with the
        // location of the 'virtual' gateway would mean we will get the wrong location.
        if rx_info.location.is_none() {
            rx_info.location = Some(common::Location {
                latitude: gw_meta.latitude,
                longitude: gw_meta.longitude,
                altitude: gw_meta.altitude as f64,
                ..Default::default()
            });
        }

        ufs.gateway_private_up_map
            .insert(gw_id, gw_meta.is_private_up);
        ufs.gateway_private_down_map
            .insert(gw_id, gw_meta.is_private_down);
        ufs.gateway_tenant_id_map
            .insert(gw_id, gw_meta.tenant_id.into());
        ufs.gateway_downlink_priority_map
            .insert(gw_id, gw_meta.downlink_priority as u32);
    }

    Ok(())
}

fn filter_rx_info_by_tenant_id(tenant_id: Uuid, uplink: &mut UplinkFrameSet) -> Result<()> {
    let force_gws_private = config::get_force_gws_private(&uplink.region_config_id)?;