torrust-actix 4.2.3

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
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

use crate::tracker::enums::updates_action::UpdatesAction;
use crate::tracker::structs::info_hash::InfoHash;
use crate::tracker::structs::torrent_entry::TorrentEntry;
use crate::tracker::structs::torrent_tracker::TorrentTracker;
use crate::tracker::structs::user_entry_item::UserEntryItem;
use crate::tracker::structs::user_id::UserId;
use async_trait::async_trait;
use sqlx::Error;
use std::collections::BTreeMap;
use std::sync::Arc;

#[async_trait]
pub trait DatabaseBackend: Send + Sync {
    async fn load_torrents(&self, tracker: Arc<TorrentTracker>) -> Result<(u64, u64), Error>;

    async fn load_whitelist(&self, tracker: Arc<TorrentTracker>) -> Result<u64, Error>;

    async fn load_blacklist(&self, tracker: Arc<TorrentTracker>) -> Result<u64, Error>;

    async fn load_keys(&self, tracker: Arc<TorrentTracker>) -> Result<u64, Error>;

    async fn load_users(&self, tracker: Arc<TorrentTracker>) -> Result<u64, Error>;

    async fn save_torrents(
        &self,
        tracker: Arc<TorrentTracker>,
        torrents: BTreeMap<InfoHash, (TorrentEntry, UpdatesAction)>,
    ) -> Result<(), Error>;

    async fn save_whitelist(
        &self,
        tracker: Arc<TorrentTracker>,
        whitelists: Vec<(InfoHash, UpdatesAction)>,
    ) -> Result<u64, Error>;

    async fn save_blacklist(
        &self,
        tracker: Arc<TorrentTracker>,
        blacklists: Vec<(InfoHash, UpdatesAction)>,
    ) -> Result<u64, Error>;

    async fn save_keys(
        &self,
        tracker: Arc<TorrentTracker>,
        keys: BTreeMap<InfoHash, (i64, UpdatesAction)>,
    ) -> Result<u64, Error>;

    async fn save_users(
        &self,
        tracker: Arc<TorrentTracker>,
        users: BTreeMap<UserId, (UserEntryItem, UpdatesAction)>,
    ) -> Result<(), Error>;

    async fn reset_seeds_peers(&self, tracker: Arc<TorrentTracker>) -> Result<(), Error>;
}