teamtalk 6.0.0

TeamTalk SDK for Rust
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
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80

use crate::events::Event;
use crate::types::ClientId;
use std::collections::HashMap;
use std::sync::{Arc, Mutex};
use std::time::SystemTime;

#[derive(Debug, Clone)]
pub struct ClientInfo {
    pub id: ClientId,
    pub label: Option<String>,
    pub state: crate::events::ConnectionState,
    pub last_event: Option<Event>,
    pub last_event_at: Option<SystemTime>,
}

#[derive(Clone, Default)]
pub struct ClientRegistry {
    inner: Arc<Mutex<HashMap<ClientId, ClientInfo>>>,
}

impl ClientRegistry {
    pub fn new() -> Self {
        Self::default()
    }

    pub fn register(&self, client: &crate::client::Client) {
        let info = ClientInfo {
            id: client.id(),
            label: client.label(),
            state: client.connection_state(),
            last_event: None,
            last_event_at: None,
        };
        let mut map = self.inner.lock().unwrap_or_else(|e| e.into_inner());
        map.insert(info.id, info);
    }

    pub fn unregister(&self, id: ClientId) {
        let mut map = self.inner.lock().unwrap_or_else(|e| e.into_inner());
        map.remove(&id);
    }

    pub fn update_event(&self, client: &crate::client::Client, event: Event) {
        let mut map = self.inner.lock().unwrap_or_else(|e| e.into_inner());
        let entry = map.entry(client.id()).or_insert(ClientInfo {
            id: client.id(),
            label: client.label(),
            state: client.connection_state(),
            last_event: None,
            last_event_at: None,
        });
        entry.label = client.label();
        entry.state = client.connection_state();
        entry.last_event = Some(event);
        entry.last_event_at = Some(SystemTime::now());
    }

    pub fn update_snapshot(&self, client: &crate::client::Client) {
        let mut map = self.inner.lock().unwrap_or_else(|e| e.into_inner());
        let entry = map.entry(client.id()).or_insert(ClientInfo {
            id: client.id(),
            label: client.label(),
            state: client.connection_state(),
            last_event: None,
            last_event_at: None,
        });
        entry.label = client.label();
        entry.state = client.connection_state();
    }

    pub fn list(&self) -> Vec<ClientInfo> {
        let map = self.inner.lock().unwrap_or_else(|e| e.into_inner());
        map.values().cloned().collect()
    }

    pub fn get(&self, id: ClientId) -> Option<ClientInfo> {
        let map = self.inner.lock().unwrap_or_else(|e| e.into_inner());
        map.get(&id).cloned()
    }
}