torrust-actix 4.2.15

A rich, fast and efficient Bittorrent Tracker.
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

use crate::cache::enums::cache_error::CacheError;
use crate::cache::structs::cache_connector_redis::CacheConnectorRedis;
use crate::tracker::structs::info_hash::InfoHash;

impl CacheConnectorRedis {
    /// Build a Redis connector.  No socket is opened here — connections are
    /// created on demand inside each cache operation and dropped afterwards.
    pub async fn connect(url: &str, prefix: &str, split_peers: bool) -> Result<Self, CacheError> {
        let client = redis::Client::open(url)
            .map_err(|e| CacheError::ConnectionError(format!("Failed to create Redis client: {e}")))?;
        Ok(Self {
            client,
            prefix: prefix.to_string(),
            split_peers,
        })
    }

    /// Builds the cache key for a torrent's peer counts (`<prefix>t:<info_hash>`).
    pub(crate) fn torrent_key(&self, info_hash: &InfoHash) -> String {
        format!("{}t:{}", self.prefix, info_hash)
    }
}