Method _handle

chirpstack/src/uplink/data_fns.rs:36–50

(ufs: UplinkFrameSet, mac_pl: lrwn::MACPayload)

    }

    async fn _handle(ufs: UplinkFrameSet, mac_pl: lrwn::MACPayload) -> Result<()> {
        let mut ctx = Data {
            uplink_frame_set: ufs,
            mac_payload: mac_pl,
            pr_device_sessions: Vec::new(),
        };

        ctx.filter_rx_info_by_public_only()?;
        ctx.get_pr_device_sessions().await?;
        ctx.start_pr_sessions().await?;
        ctx.forward_uplink_for_sessions().await?;
        ctx.save_pr_device_sessions().await?;

        Ok(())
    }

    fn filter_rx_info_by_public_only(&mut self) -> Result<()> {
        trace!("Filtering rx_info by public gateways only");