Method start_roaming

chirpstack/src/uplink/join_fns.rs:104–160

(&mut self)

    }

    async fn start_roaming(&mut self) -> Result<()> {
        trace!("Starting passive-roaming");
        let rf_region = self
            .uplink_frame_set
            .region_common_name
            .to_string()
            .replace('_', "-");

        let mut pr_req = backend::PRStartReqPayload {
            phy_payload: self.uplink_frame_set.phy_payload.to_vec()?,
            ul_meta_data: backend::ULMetaData {
                dev_eui: self.join_request.dev_eui.to_vec(),
                ul_freq: Some((self.uplink_frame_set.tx_info.frequency as f64) / 1_000_000.0),
                data_rate: Some(self.uplink_frame_set.dr),
                recv_time: helpers::get_rx_timestamp_chrono(&self.uplink_frame_set.rx_info_set),
                rf_region: rf_region.clone(),
                gw_cnt: Some(self.uplink_frame_set.rx_info_set.len()),
                gw_info: roaming::rx_info_to_gw_info(
                    &rf_region,
                    &self.uplink_frame_set.rx_info_set,
                )?,
                ..Default::default()
            },
            ..Default::default()
        };

        #[cfg(test)]
        {
            pr_req.base.transaction_id = 1234;
        }

        let client = self.client.as_ref().unwrap();
        let async_receiver = match client.is_async() {
            false => None,
            true => Some(
                get_async_receiver(pr_req.base.transaction_id, client.get_async_timeout()).await?,
            ),
        };

        let resp = client
            .pr_start_req(backend::Role::SNS, &mut pr_req, async_receiver)
            .await?;

        if let Some(dl_meta) = &resp.dl_meta_data {
            downlink::roaming::PassiveRoamingDownlink::handle(
                self.uplink_frame_set.clone(),
                resp.phy_payload.clone(),
                dl_meta.clone(),
            )
            .await?;
        } else {
            return Err(anyhow!("DLMetaData is not set"));
        }

        self.pr_start_ans = Some(resp);
        Ok(())
    }