Function handle_v2_app_time_req

chirpstack/src/applayer/clocksync.rs:107–154

(
    dev: &device::Device,
    dp: &device_profile::DeviceProfile,
    rx_info: &[gw::UplinkRxInfo],
    pl: clocksync::v2::AppTimeReqPayload,
)

}

async fn handle_v2_app_time_req(
    dev: &device::Device,
    dp: &device_profile::DeviceProfile,
    rx_info: &[gw::UplinkRxInfo],
    pl: clocksync::v2::AppTimeReqPayload,
) -> Result<()> {
    info!("Handling AppTimeReq");

    let now_time_since_gps = if let Some(t) = helpers::get_time_since_gps_epoch(rx_info) {
        chrono::Duration::from_std(t)?
    } else {
        helpers::get_rx_timestamp_chrono(rx_info).to_gps_time()
    };
    let dev_time_since_gps = chrono::Duration::seconds(pl.device_time.into());

    let time_diff = (now_time_since_gps - dev_time_since_gps).num_seconds();
    let time_correction: i32 = if time_diff < 0 {
        time_diff.try_into().unwrap_or(i32::MIN)
    } else {
        time_diff.try_into().unwrap_or(i32::MAX)
    };

    if time_diff == 0 && !pl.param.ans_required {
        return Ok(());
    }

    info!(
        time_correcrtion = time_correction,
        "Responding with AppTimeAns"
    );

    let ans = clocksync::v2::Payload::AppTimeAns(clocksync::v2::AppTimeAnsPayload {
        time_correction,
        param: clocksync::v2::AppTimeAnsPayloadParam {
            token_ans: pl.param.token_req,
        },
    });

    device_queue::enqueue_item(device_queue::DeviceQueueItem {
        dev_eui: dev.dev_eui,
        f_port: dp.app_layer_params.ts003_f_port.into(),
        data: ans.to_vec()?,
        ..Default::default()
    })
    .await?;

    Ok(())
}

#[cfg(test)]
mod test {