nexus-common 0.4.1

Nexus common utils
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

use crate::db::RedisOps;
use crate::types::DynError;
use pubky_app_specs::PubkyId;
use serde::{Deserialize, Serialize};

/// Represents a homeserver with its public key, URL, and cursor.
#[derive(Serialize, Deserialize, Debug)]
pub struct Homeserver {
    pub id: PubkyId,
    pub cursor: String,
}

impl RedisOps for Homeserver {}

impl Homeserver {
    pub async fn new(id: PubkyId) -> Result<Self, Box<dyn std::error::Error + Sync + Send>> {
        let hs = Homeserver {
            id,
            cursor: "0000000000000".to_string(),
        };
        // Store homeserver with initial cursor in Index
        hs.put_to_index().await?;
        Ok(hs)
    }

    /// Retrieves the homeserver from Redis.
    pub async fn get_from_index(id: &str) -> Result<Option<Self>, DynError> {
        if let Some(homeserver) = Self::try_from_index_json(&[id], None).await? {
            return Ok(Some(homeserver));
        }
        Ok(None)
    }

    /// Stores the homeserver in Redis.
    pub async fn put_to_index(&self) -> Result<(), DynError> {
        self.put_index_json(&[&self.id], None, None).await?;
        Ok(())
    }

    pub async fn from_config(homeserver: PubkyId) -> Result<Homeserver, DynError> {
        // Attempt to load the homeserver cursor from Redis
        match Homeserver::get_from_index(&homeserver).await? {
            Some(hs) => Ok(hs),
            None => {
                // Create a new Homeserver instance with default cursor
                Homeserver::new(homeserver).await
            }
        }
    }
}