sia_storage 0.9.1

SDK for interacting with a Sia network indexer
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
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104

use std::sync::Arc;

use sia_core::signing::PublicKey;
use tokio::io::AsyncRead;

use crate::download::Download;
use crate::hosts::Hosts;
use crate::rhp4::Client;
use crate::time::Duration;
use crate::upload::{PackedUpload, upload_object};
use crate::{AppKey, DownloadError, DownloadOptions, Object, UploadError, UploadOptions};

pub struct MockUploader {
    hosts: Hosts<Client>,
    app_key: Arc<AppKey>,
}

impl MockUploader {
    pub fn new(hosts: MockHosts, app_key: Arc<AppKey>) -> Self {
        Self {
            hosts: hosts.inner,
            app_key,
        }
    }

    pub async fn upload<R: AsyncRead + Send + Sync + Unpin + 'static>(
        &self,
        object: Object,
        r: R,
        options: UploadOptions,
    ) -> Result<Object, UploadError> {
        upload_object(self.hosts.clone(), self.app_key.clone(), object, r, options).await
    }

    pub fn upload_packed(&self, options: UploadOptions) -> Result<PackedUpload, UploadError> {
        PackedUpload::new(self.hosts.clone(), self.app_key.clone(), options)
    }
}

pub struct MockDownloader {
    hosts: MockHosts,
    app_key: Arc<AppKey>,
}

impl MockDownloader {
    pub fn new(hosts: MockHosts, app_key: Arc<AppKey>) -> Self {
        Self { hosts, app_key }
    }

    pub fn download(
        &self,
        object: &Object,
        options: DownloadOptions,
    ) -> Result<impl tokio::io::AsyncRead + Unpin, DownloadError> {
        Download::new(
            object,
            self.hosts.inner.clone(),
            self.app_key.clone(),
            options,
        )
    }
}

#[derive(Clone)]
pub struct MockHosts {
    transport: Client,
    pub(crate) inner: Hosts<Client>,
}

impl MockHosts {
    pub fn new() -> Self {
        let transport = Client::new();
        let hosts = Hosts::new(transport.clone());
        Self {
            transport,
            inner: hosts,
        }
    }

    pub fn update(&self, hosts: Vec<crate::Host>, clear: bool) {
        self.inner.update(hosts, clear);
    }

    pub fn clear(&self) {
        self.transport.clear();
    }

    /// Sets the given hosts as "slow" - they will sleep for the specified duration
    /// before completing any write_sector or read_sector operation.
    pub fn set_slow_hosts(&self, hosts: impl IntoIterator<Item = PublicKey>, delay: Duration) {
        self.transport.set_slow_hosts(hosts, delay);
    }

    /// Clears all slow host settings.
    pub fn reset_slow_hosts(&self) {
        self.transport.reset_slow_hosts();
    }
}

impl Default for MockHosts {
    fn default() -> Self {
        Self::new()
    }
}