Method _handle

chirpstack/src/uplink/join.rs:86–144

(ufs: UplinkFrameSet)

    }

    async fn _handle(ufs: UplinkFrameSet) -> Result<()> {
        let mut ctx = JoinRequest {
            uplink_frame_set: ufs,
            relay_context: None,
            js_client: None,
            join_request: None,
            device: None,
            application: None,
            tenant: None,
            device_profile: None,
            device_keys: None,
            join_accept: None,
            device_info: None,
            relay_rx_info: None,
            f_nwk_s_int_key: None,
            s_nwk_s_int_key: None,
            nwk_s_enc_key: None,
            app_s_key: None,
            js_session_key_id: vec![],
        };

        ctx.get_join_request_payload()?;

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

        ctx.get_device_data_or_try_pr_roaming().await?;
        ctx.get_device_keys_or_js_client().await?; // used to validate MIC + if we need external JS
        ctx.set_device_info()?;
        ctx.validate_region_config_id()?;
        ctx.filter_rx_info_by_tenant()?;
        ctx.abort_on_device_is_disabled()?;
        ctx.abort_on_relay_only_comm()?;
        ctx.log_uplink_frame_set().await?;
        ctx.abort_on_otaa_is_disabled()?;
        ctx.set_random_dev_addr()?;
        if ctx.js_client.is_some() {
            // Using join-server
            ctx.get_join_accept_from_js().await?;
        } else {
            // Using internal keys
            ctx.validate_mic().await?;
            ctx.validate_dev_nonce_and_get_device_keys().await?;
            ctx.construct_join_accept_and_set_keys()?;
        }
        ctx.log_uplink_meta().await?;
        ctx.set_device_session().await?;
        ctx.flush_device_queue().await?;
        ctx.set_device_mode().await?;
        ctx.update_device().await?;
        ctx.start_downlink_join_accept_flow().await?;
        ctx.send_join_event().await?;

        Ok(())