Function test_queue_item

chirpstack/src/storage/device_queue.rs:206–264

()

    #[tokio::test]
    async fn test_queue_item() {
        let _guard = test::prepare().await;
        let dp = storage::device_profile::test::create_device_profile(None).await;
        let d = storage::device::test::create_device(
            EUI64::from_be_bytes([1, 2, 3, 4, 5, 6, 7, 8]),
            dp.id.into(),
            None,
        )
        .await;

        // invalid fport
        let qi = DeviceQueueItem {
            dev_eui: d.dev_eui,
            f_port: 0,
            data: vec![0x01, 0x02, 0x03],
            ..Default::default()
        };
        assert!(enqueue_item(qi).await.is_err());

        let qi = DeviceQueueItem {
            dev_eui: d.dev_eui,
            f_port: 256,
            data: vec![0x01, 0x02, 0x03],
            ..Default::default()
        };
        assert!(enqueue_item(qi).await.is_err());

        // create
        let mut qi = DeviceQueueItem {
            dev_eui: d.dev_eui,
            f_port: 10,
            data: vec![0x01, 0x02, 0x03],
            ..Default::default()
        };
        qi = enqueue_item(qi).await.unwrap();

        // get
        let qi_get = get_item(&qi.id).await.unwrap();
        assert_eq!(qi, qi_get);

        // get for dev eui
        let queue = get_for_dev_eui(&d.dev_eui).await.unwrap();
        assert_eq!(qi, queue[0]);

        // next next queue item for dev eui
        let resp = get_next_for_dev_eui(&d.dev_eui).await.unwrap();
        assert_eq!(qi, resp.0);
        assert!(!resp.1);

        // update
        qi.is_pending = true;
        qi = update_item(qi).await.unwrap();
        let qi_get = get_item(&qi.id).await.unwrap();
        assert_eq!(qi, qi_get);

        // delete
        delete_item(&qi.id).await.unwrap();
        assert!(delete_item(&qi.id).await.is_err());