(t: &Test)
| 789 | } |
| 790 | |
| 791 | async fn run_test(t: &Test) { |
| 792 | println!("> {}", t.name); |
| 793 | |
| 794 | reset_redis().await.unwrap(); |
| 795 | |
| 796 | integration::set_mock().await; |
| 797 | gateway_backend::set_backend("eu868", Box::new(gateway_backend::mock::Backend {})).await; |
| 798 | |
| 799 | integration::mock::reset().await; |
| 800 | gateway_backend::mock::reset().await; |
| 801 | device_queue::flush_for_dev_eui(&t.dev_eui_relay) |
| 802 | .await |
| 803 | .unwrap(); |
| 804 | device_queue::flush_for_dev_eui(&t.dev_eui_relay_ed) |
| 805 | .await |
| 806 | .unwrap(); |
| 807 | device::partial_update( |
| 808 | t.dev_eui_relay, |
| 809 | &device::DeviceChangeset { |
| 810 | device_session: Some( |
| 811 | t.device_session_relay |
| 812 | .as_ref() |
| 813 | .map(fields::DeviceSession::from) |
| 814 | .clone(), |
| 815 | ), |
| 816 | ..Default::default() |
| 817 | }, |
| 818 | ) |
| 819 | .await |
| 820 | .unwrap(); |
| 821 | device::partial_update( |
| 822 | t.dev_eui_relay_ed, |
| 823 | &device::DeviceChangeset { |
| 824 | device_session: Some( |
| 825 | t.device_session_relay_ed |
| 826 | .as_ref() |
| 827 | .map(fields::DeviceSession::from) |
| 828 | .clone(), |
| 829 | ), |
| 830 | ..Default::default() |
| 831 | }, |
| 832 | ) |
| 833 | .await |
| 834 | .unwrap(); |
| 835 | |
| 836 | for qi in &t.device_queue_items_relay_ed { |
| 837 | let _ = device_queue::enqueue_item(qi.clone()).await.unwrap(); |
| 838 | } |
| 839 | |
| 840 | uplink::handle_uplink( |
| 841 | CommonName::EU868, |
| 842 | "eu868", |
| 843 | Uuid::new_v4(), |
| 844 | gw::UplinkFrameSet { |
| 845 | phy_payload: t.phy_payload.to_vec().unwrap(), |
| 846 | tx_info: Some(t.tx_info.clone()), |
| 847 | rx_info: vec![t.rx_info.clone()], |
| 848 | }, |
no test coverage detected