()
| 265 | |
| 266 | #[tokio::test] |
| 267 | async fn test_flush_queue() { |
| 268 | let _guard = test::prepare().await; |
| 269 | let dp = storage::device_profile::test::create_device_profile(None).await; |
| 270 | let d = storage::device::test::create_device( |
| 271 | EUI64::from_be_bytes([1, 2, 3, 4, 5, 6, 7, 8]), |
| 272 | dp.id.into(), |
| 273 | None, |
| 274 | ) |
| 275 | .await; |
| 276 | |
| 277 | // create |
| 278 | let mut qi = DeviceQueueItem { |
| 279 | dev_eui: d.dev_eui, |
| 280 | f_port: 10, |
| 281 | data: vec![0x01, 0x02, 0x03], |
| 282 | ..Default::default() |
| 283 | }; |
| 284 | qi = enqueue_item(qi).await.unwrap(); |
| 285 | |
| 286 | // flush |
| 287 | flush_for_dev_eui(&d.dev_eui).await.unwrap(); |
| 288 | assert!(delete_item(&qi.id).await.is_err()); |
| 289 | } |
| 290 | |
| 291 | #[tokio::test] |
| 292 | async fn test_flush_queue_non_pending() { |
nothing calls this directly
no test coverage detected