Function test_handle_uplink

chirpstack/src/maccommand/mod.rs:175–241

()

    #[tokio::test]
    async fn test_handle_uplink() {
        let region_conf = lrwn::region::get(lrwn::region::CommonName::EU868, false, false);
        let region_conf = Arc::new(region_conf);

        let upfs = UplinkFrameSet {
            uplink_set_id: Uuid::nil(),
            dr: 0,
            ch: 0,
            phy_payload: lrwn::PhyPayload {
                mhdr: lrwn::MHDR {
                    f_type: lrwn::FType::UnconfirmedDataUp,
                    major: lrwn::Major::LoRaWANR1,
                },
                payload: lrwn::Payload::MACPayload(lrwn::MACPayload {
                    fhdr: Default::default(),
                    f_port: None,
                    frm_payload: None,
                }),
                mic: Some([0, 0, 0, 0]),
            },
            tx_info: Default::default(),
            rx_info_set: Default::default(),
            gateway_private_up_map: Default::default(),
            gateway_private_down_map: Default::default(),
            gateway_tenant_id_map: Default::default(),
            gateway_downlink_priority_map: HashMap::new(),
            region_common_name: lrwn::region::CommonName::EU868,
            region_config_id: "eu868".into(),
            roaming_meta_data: None,
        };

        let t: tenant::Tenant = Default::default();
        let app: application::Application = Default::default();
        let dp: device_profile::DeviceProfile = Default::default();
        let mut dev = device::Device {
            dev_eui: EUI64::from_be_bytes([1, 2, 3, 4, 5, 6, 7, 8]),
            device_session: Some(
                internal::DeviceSession {
                    ..Default::default()
                }
                .into(),
            ),
            ..Default::default()
        };

        // must respond
        let cmds = lrwn::MACCommandSet::new(vec![lrwn::MACCommand::RxTimingSetupAns]);

        let (resp, must_respond) =
            handle_uplink(&upfs, &cmds, &t, &app, &dp, &mut dev, region_conf.clone())
                .await
                .unwrap();
        assert_eq!(0, resp.len());
        assert!(must_respond);

        // mac-commands disabled
        let mut conf = (*config::get()).clone();
        conf.network.mac_commands_disabled = true;