Method _handle

chirpstack/src/uplink/data.rs:85–154

(ufs: UplinkFrameSet)

    }

    pub async fn _handle(ufs: UplinkFrameSet) -> Result<()> {
        let mut ctx = Data {
            phy_payload: ufs.phy_payload.clone(),
            uplink_frame_set: ufs,
            relay_context: None,
            f_cnt_up_full: 0,
            reset: false,
            retransmission: false,
            tenant: None,
            device: None,
            device_profile: None,
            application: None,
            device_info: None,
            relay_rx_info: None,
            uplink_event: None,
            must_send_downlink: false,
            downlink_mac_commands: Vec::new(),
            device_changeset: Default::default(),
            region_conf: None,
        };

        ctx.handle_passive_roaming_device().await?;
        ctx.get_device_for_phy_payload().await?;
        ctx.get_device_data().await?;
        ctx.set_region_config()?;
        ctx.check_roaming_allowed()?;

        // Add dev_eui to span
        let span = tracing::Span::current();
        span.record("dev_eui", ctx.device.as_ref().unwrap().dev_eui.to_string());

        if !ctx._is_roaming() {
            // In case of roaming we do not know the gateways and therefore it must not be
            // filtered.
            ctx.filter_rx_info_by_tenant().await?;
        }
        ctx.set_device_info()?;
        ctx.set_region_config()?;
        if !ctx._is_roaming() {
            ctx.set_device_gateway_rx_info()?;
        }
        ctx.handle_retransmission_reset().await?;
        ctx.decrypt_f_opts_mac_commands()?;
        ctx.decrypt_frm_payload()?;
        ctx.log_uplink_frame_set().await?;
        ctx.set_adr()?;
        ctx.set_uplink_data_rate().await?;
        ctx.handle_class_b_beacon_locked().await?;
        ctx.log_uplink_meta().await?;
        ctx.reset_channels_on_activation_or_adr_ack_req()?;
        ctx.handle_mac_commands().await?;
        ctx.append_meta_data_to_uplink_history()?;
        ctx.send_uplink_event().await?;
        if ctx._is_applayer() {
            ctx.handle_applayer().await?;
        }
        ctx.detect_and_save_measurements().await?;
        ctx.sync_uplink_f_cnt()?;