Method _handle_schedule_next_queue_item

chirpstack/src/downlink/data.rs:290–348

(downlink_id: u32, dev: device::Device)

    }

    async fn _handle_schedule_next_queue_item(downlink_id: u32, dev: device::Device) -> Result<()> {
        trace!("Handle schedule next-queue item flow");

        let (dev, app, ten, dp) = get_all_device_data(dev.dev_eui).await?;
        let (rc, rn) = {
            let ds = dev.get_device_session()?;
            (
                region::get(&ds.region_config_id)?,
                config::get_region_network(&ds.region_config_id)?,
            )
        };

        let mut ctx = Data {
            relay_context: None,
            uplink_frame_set: None,
            tenant: ten,
            application: app,
            device_profile: dp,
            device: dev,
            network_conf: rn,
            region_conf: rc,
            must_send: false,
            must_ack: false,
            mac_commands: vec![],
            downlink_gateway: None,
            downlink_frame: gw::DownlinkFrame {
                downlink_id,
                ..Default::default()
            },
            downlink_frame_items: vec![],
            immediately: false,
            device_queue_item: None,
            more_device_queue_items: false,
        };

        ctx.select_downlink_gateway(false)?;
        if ctx._is_class_c() {
            ctx.class_c_update_scheduler_run_after().await?;
            ctx.check_for_first_uplink()?;
            ctx.set_immediately()?;
            ctx.set_tx_info_for_rx2()?;
        }
        if ctx._is_class_b() {
            ctx.set_tx_info_for_class_b_and_update_scheduler_run_after()
                .await?;
        }
        if ctx._is_class_a() {
            return Err(anyhow!("Invalid device-class"));
        }
        ctx.get_next_device_queue_item(false).await?;
        if ctx._something_to_send() {
            ctx.set_phy_payloads()?;
            ctx.update_device_queue_item().await?;
            ctx.save_downlink_frame().await?;
            ctx.send_downlink_frame().await?;
        }

        Ok(())