Method set_phy_payloads_relay

chirpstack/src/downlink/data.rs:920–966

(&mut self)

    }

    fn set_phy_payloads_relay(&mut self) -> Result<()> {
        trace!("Set relay PhyPayloads");

        let relay_ctx = self.relay_context.as_ref().unwrap();
        let relay_ds = relay_ctx.device.get_device_session()?;

        for item in self.downlink_frame_items.iter_mut() {
            let mut relay_phy = lrwn::PhyPayload {
                mhdr: lrwn::MHDR {
                    f_type: lrwn::FType::UnconfirmedDataDown,
                    major: lrwn::Major::LoRaWANR1,
                },
                payload: lrwn::Payload::MACPayload(lrwn::MACPayload {
                    fhdr: lrwn::FHDR {
                        devaddr: relay_ctx.device.get_dev_addr()?,
                        f_cnt: relay_ds.get_a_f_cnt_down(),
                        f_ctrl: lrwn::FCtrl {
                            adr: !self.network_conf.adr_disabled,
                            ack: relay_ctx.must_ack,
                            ..Default::default()
                        },
                        f_opts: lrwn::MACCommandSet::new(vec![]),
                    },
                    f_port: None,
                    frm_payload: None,
                }),
                mic: None,
            };

            // Set MIC.
            // If this is an ACK, then FCntUp has already been incremented by one. If
            // this is not an ACK, then DownlinkDataMIC will zero out ConfFCnt.
            relay_phy.set_downlink_data_mic(
                relay_ds.mac_version().from_proto(),
                (relay_ctx.device.f_cnt_up as u32) - 1,
                &lrwn::AES128Key::from_slice(&relay_ds.s_nwk_s_int_key)?,
            )?;

            let relay_phy_b = relay_phy.to_vec()?;
            item.downlink_frame_item.phy_payload = relay_phy_b;
            self.downlink_frame
                .items
                .push(item.downlink_frame_item.clone());
        }

        Ok(())
    }

    async fn update_device_queue_item(&mut self) -> Result<()> {
        trace!("Updating device queue-item");