Function test_handle_v2_app_time_req

chirpstack/src/applayer/clocksync.rs:315–461

()

    #[tokio::test]
    async fn test_handle_v2_app_time_req() {
        struct Test {
            name: String,
            rx_info: gw::UplinkRxInfo,
            req: clocksync::v2::AppTimeReqPayload,
            expected: Option<clocksync::v2::AppTimeAnsPayload>,
        }

        let tests = vec![
            Test {
                name: "device synced".into(),
                rx_info: gw::UplinkRxInfo {
                    time_since_gps_epoch: Some(Duration::from_secs(1234).into()),
                    ..Default::default()
                },
                req: clocksync::v2::AppTimeReqPayload {
                    device_time: 1234,
                    param: clocksync::v2::AppTimeReqPayloadParam {
                        token_req: 8,
                        ans_required: false,
                    },
                },
                expected: None,
            },
            Test {
                name: "device synced - ans required".into(),
                rx_info: gw::UplinkRxInfo {
                    time_since_gps_epoch: Some(Duration::from_secs(1234).into()),
                    ..Default::default()
                },
                req: clocksync::v2::AppTimeReqPayload {
                    device_time: 1234,
                    param: clocksync::v2::AppTimeReqPayloadParam {
                        token_req: 8,
                        ans_required: true,
                    },
                },
                expected: Some(clocksync::v2::AppTimeAnsPayload {
                    time_correction: 0,
                    param: clocksync::v2::AppTimeAnsPayloadParam { token_ans: 8 },
                }),
            },
            Test {
                name: "device not synced (positive correction)".into(),
                rx_info: gw::UplinkRxInfo {
                    time_since_gps_epoch: Some(Duration::from_secs(1234).into()),
                    ..Default::default()
                },
                req: clocksync::v2::AppTimeReqPayload {
                    device_time: 1200,
                    param: clocksync::v2::AppTimeReqPayloadParam {
                        token_req: 8,
                        ans_required: false,
                    },
                },
                expected: Some(clocksync::v2::AppTimeAnsPayload {
                    time_correction: 34,
                    param: clocksync::v2::AppTimeAnsPayloadParam { token_ans: 8 },