ascom-alpaca-core 0.1.3

Framework-agnostic ASCOM Alpaca protocol types and traits for Rust — all 10 device types, no HTTP framework required
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54

use std::collections::HashMap;

/// Push-based client activity tracker.
///
/// The consumer provides timestamps — the crate has no clock dependency.
pub struct ClientTracker {
    clients: HashMap<u32, u64>,
}

impl ClientTracker {
    pub fn new() -> Self {
        Self {
            clients: HashMap::new(),
        }
    }

    /// Records client activity at the given timestamp.
    pub fn record_activity(&mut self, client_id: u32, timestamp: u64) {
        self.clients.insert(client_id, timestamp);
    }

    /// Returns client IDs that have not been seen since `now - timeout`.
    pub fn check_timeouts(&mut self, now: u64, timeout: u64) -> Vec<u32> {
        let threshold = now.saturating_sub(timeout);
        let timed_out: Vec<u32> = self
            .clients
            .iter()
            .filter(|(_, &last_seen)| last_seen < threshold)
            .map(|(&id, _)| id)
            .collect();

        for &id in &timed_out {
            self.clients.remove(&id);
        }

        timed_out
    }

    /// Returns whether a client is currently tracked.
    pub fn is_connected(&self, client_id: u32) -> bool {
        self.clients.contains_key(&client_id)
    }

    /// Removes a client from tracking.
    pub fn disconnect(&mut self, client_id: u32) {
        self.clients.remove(&client_id);
    }
}

impl Default for ClientTracker {
    fn default() -> Self {
        Self::new()
    }
}