Function test_get_next_device_queue_item

chirpstack/src/downlink/data.rs:2737–3034

()

    #[tokio::test]
    async fn test_get_next_device_queue_item() {
        let _guard = test::prepare().await;

        let t = tenant::create(tenant::Tenant {
            name: "test-tenant".into(),
            ..Default::default()
        })
        .await
        .unwrap();

        let dp = device_profile::create(device_profile::DeviceProfile {
            name: "dp".into(),
            tenant_id: Some(t.id),
            relay_params: Some(fields::RelayParams {
                is_relay: true,
                ..Default::default()
            }),
            ..Default::default()
        })
        .await
        .unwrap();

        let app = application::create(application::Application {
            name: "test-app".into(),
            tenant_id: t.id,
            ..Default::default()
        })
        .await
        .unwrap();

        let d = device::create(device::Device {
            dev_eui: EUI64::from_be_bytes([1, 1, 1, 1, 1, 1, 1, 1]),
            name: "dev".into(),
            application_id: app.id,
            device_profile_id: dp.id,
            ..Default::default()
        })
        .await
        .unwrap();

        let ds = internal::DeviceSession {
            n_f_cnt_down: 10,
            a_f_cnt_down: 10,
            ..Default::default()
        };

        struct Test {
            name: String,
            max_payload_size: usize,
            queue_items: Vec<device_queue::DeviceQueueItem>,
            expected_queue_item: Option<device_queue::DeviceQueueItem>,
            expected_ack_event: Option<integration_pb::AckEvent>,
            expected_log_event: Option<integration_pb::LogEvent>,
        }

        let qi_id = Uuid::new_v4();

        let tests = vec![