Function run_scheduler_test

chirpstack/src/test/multicast_test.rs:233–255

(t: &MulticastTest)

}

async fn run_scheduler_test(t: &MulticastTest) {
    println!("> {}", t.name);

    integration::set_mock().await;
    gateway_backend::set_backend("eu868", Box::new(gateway_backend::mock::Backend {})).await;

    // overwrite multicast-group to deal with frame-counter increments
    multicast::update(t.multicast_group.clone()).await.unwrap();

    // set multicast-group queue
    multicast::flush_queue(&t.multicast_group.id).await.unwrap();
    for qi in &t.multicast_group_queue_items {
        let _ = downlink::multicast::enqueue(qi.clone()).await.unwrap();
    }

    downlink::scheduler::schedule_multicast_group_queue_batch(1)
        .await
        .unwrap();

    for assert in &t.assert {
        assert().await;
    }
}