Method _handle

chirpstack/src/downlink/data_fns.rs:35–72

(pl: backend::XmitDataReqPayload, dl_meta: backend::DLMetaData)

    }

    async fn _handle(pl: backend::XmitDataReqPayload, dl_meta: backend::DLMetaData) -> Result<()> {
        let mut uplink_rx_info = roaming::dl_meta_data_to_uplink_rx_info(&dl_meta)?;
        uplink_rx_info.sort_by(|a, b| {
            if a.snr == b.snr {
                return a.rssi.partial_cmp(&b.rssi).unwrap();
            }
            b.snr.partial_cmp(&a.snr).unwrap()
        });

        if uplink_rx_info.is_empty() {
            return Err(anyhow!("DLMetaData is not set"));
        }

        let rf_region = uplink_rx_info[0]
            .metadata
            .get("rf_region")
            .cloned()
            .unwrap_or_default();
        let region_common_name = CommonName::from_str(&rf_region)?;
        let region_config_id = region::get_region_config_id(region_common_name)?;

        let mut ctx = Data {
            region_config_id,
            uplink_rx_info,
            xmit_data_req: pl,
            dl_meta_data: dl_meta,
            downlink_frame: gw::DownlinkFrame {
                downlink_id: rand::rng().random(),
                ..Default::default()
            },
        };

        ctx.set_downlink_frame()?;
        ctx.save_downlink_frame().await?;
        ctx.send_downlink_frame().await?;

        Ok(())
    }

    fn set_downlink_frame(&mut self) -> Result<()> {
        trace!("Setting DownlinkFrame parameters");