steamkit-rs 0.1.0

Rust port of SteamKit2, a .NET library that aims to interoperate with the Steam network.
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

//! A server list provider that keeps the list in memory.

use std::time::SystemTime;

use async_trait::async_trait;
use tokio::sync::RwLock;

use crate::error::SteamError;

use super::i_server_list_provider::IServerListProvider;
use super::server_record::ServerRecord;

/// A server list provider that uses an in-memory list.
#[derive(Debug, Default)]
pub struct MemoryServerListProvider {
    servers: RwLock<Vec<ServerRecord>>,
    last_updated: RwLock<Option<SystemTime>>,
}

impl MemoryServerListProvider {
    /// Creates a new, empty provider.
    pub fn new() -> Self {
        MemoryServerListProvider::default()
    }
}

#[async_trait]
impl IServerListProvider for MemoryServerListProvider {
    /// When the list was last updated.
    async fn last_server_list_refresh(&self) -> Result<SystemTime, SteamError> {
        Ok(self
            .last_updated
            .read()
            .await
            .unwrap_or(SystemTime::UNIX_EPOCH))
    }

    /// Returns the stored server list.
    async fn fetch_server_list(&self) -> Result<Vec<ServerRecord>, SteamError> {
        Ok(self.servers.read().await.clone())
    }

    /// Stores the server list.
    async fn update_server_list(&self, endpoints: Vec<ServerRecord>) -> Result<(), SteamError> {
        *self.servers.write().await = endpoints;
        *self.last_updated.write().await = Some(SystemTime::now());

        Ok(())
    }
}