bitcoind-cache 0.1.1

Alternative storage for bitcoind block data
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

use crate::store::{AsyncStoreResult, Store, StoreError};
use reqwest::Body;

#[derive(Clone)]
pub struct HttpStore {
    host: String,
}

impl HttpStore {
    pub fn new(host: String) -> Self {
        Self { host }
    }
}

impl Store for HttpStore {
    fn get_object(&self, filename: String) -> AsyncStoreResult<Option<Vec<u8>>> {
        Box::pin(async move {
            match reqwest::get(format!("{}/{}", self.host, filename)).await {
                Ok(response) => {
                    if response.status().is_success() {
                        match response.bytes().await {
                            Ok(content) => Ok(Some(content.to_vec())),
                            Err(e) => Err(StoreError::Reqwest(e)),
                        }
                    } else {
                        Ok(None)
                    }
                }
                Err(e) => Err(StoreError::Reqwest(e)),
            }
        })
    }

    fn put_object<'a>(&'a self, filename: String, content: &'a [u8]) -> AsyncStoreResult<()> {
        Box::pin(async move {
            let body = content.to_vec();
            let body: Body = body.into();
            let client = reqwest::Client::new();
            client
                .put(format!("{}/{}", self.host, filename))
                .body(body)
                .send()
                .await
                .map(|_| ())
                .map_err(StoreError::Reqwest)
        })
    }
}