mirror of
https://github.com/telemt/telemt.git
synced 2026-04-14 17:14:09 +03:00
09f56dede2
Reduce clippy warnings from54 to16 by fixing mechanical issues: - collapsible_if: collapse nested if-let chains with let-chains - clone_on_copy: remove unnecessary .clone() on Copy types - manual_clamp: replace .max().min() with .clamp() - unnecessary_cast: remove redundant type casts - collapsible_else_if: flatten else-if chains - contains_vs_iter_any: replace .iter().any() with .contains() - unnecessary_closure: replace .or_else(|| x) with .or(x) - useless_conversion: remove redundant .into() calls - is_none_or: replace .map_or(true, ...) with .is_none_or(...) - while_let_loop: convert loop with if-let-break to while-let Remaining16 warnings are design-level issues (too_many_arguments, await_holding_lock, type_complexity, new_ret_no_self) that require architectural changes to fix.
81 lines
2.0 KiB
Rust
81 lines
2.0 KiB
Rust
//! Time Sync
|
|
|
|
use std::time::Duration;
|
|
use chrono::{DateTime, Utc};
|
|
use tracing::{debug, warn, error};
|
|
|
|
#[allow(dead_code)]
|
|
const TIME_SYNC_URL: &str = "https://core.telegram.org/getProxySecret";
|
|
#[allow(dead_code)]
|
|
const MAX_TIME_SKEW_SECS: i64 = 30;
|
|
|
|
/// Time sync result
|
|
#[derive(Debug, Clone)]
|
|
#[allow(dead_code)]
|
|
pub struct TimeSyncResult {
|
|
pub server_time: DateTime<Utc>,
|
|
pub local_time: DateTime<Utc>,
|
|
pub skew_secs: i64,
|
|
pub is_skewed: bool,
|
|
}
|
|
|
|
/// Check time synchronization with Telegram servers
|
|
#[allow(dead_code)]
|
|
pub async fn check_time_sync() -> Option<TimeSyncResult> {
|
|
let client = reqwest::Client::builder()
|
|
.timeout(Duration::from_secs(10))
|
|
.build()
|
|
.ok()?;
|
|
|
|
let response = client.get(TIME_SYNC_URL).send().await.ok()?;
|
|
|
|
// Get Date header
|
|
let date_header = response.headers().get("date")?;
|
|
let date_str = date_header.to_str().ok()?;
|
|
|
|
// Parse date
|
|
let server_time = DateTime::parse_from_rfc2822(date_str)
|
|
.ok()?
|
|
.with_timezone(&Utc);
|
|
|
|
let local_time = Utc::now();
|
|
let skew_secs = (local_time - server_time).num_seconds();
|
|
let is_skewed = skew_secs.abs() > MAX_TIME_SKEW_SECS;
|
|
|
|
let result = TimeSyncResult {
|
|
server_time,
|
|
local_time,
|
|
skew_secs,
|
|
is_skewed,
|
|
};
|
|
|
|
if is_skewed {
|
|
warn!(
|
|
server = %server_time,
|
|
local = %local_time,
|
|
skew = skew_secs,
|
|
"Time skew detected"
|
|
);
|
|
} else {
|
|
debug!(skew = skew_secs, "Time sync OK");
|
|
}
|
|
|
|
Some(result)
|
|
}
|
|
|
|
/// Background time sync task
|
|
#[allow(dead_code)]
|
|
pub async fn time_sync_task(check_interval: Duration) -> ! {
|
|
loop {
|
|
if let Some(result) = check_time_sync().await
|
|
&& result.is_skewed
|
|
{
|
|
error!(
|
|
"System clock is off by {} seconds. Please sync your clock.",
|
|
result.skew_secs
|
|
);
|
|
}
|
|
|
|
tokio::time::sleep(check_interval).await;
|
|
}
|
|
} |