eth-avatars 0.0.2

A library for fetching Ethereum avatars.
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

use async_trait::async_trait;

use super::super::http::Http;
use super::Ipfs;
use crate::{FetchError, Fetcher, Resource};

/**
* IpfsGateway is a rewriter that rewrites [`Resource::Ipfs`] to [`Resource::Http`] with a given gateway base_url.
*/
pub struct IpfsGateway {
    base_url: String,
}

impl IpfsGateway {
    pub fn new(base_url: impl Into<String>) -> Self {
        Self {
            base_url: base_url.into(),
        }
    }
}

#[async_trait]
impl Fetcher for IpfsGateway {
    type Locator = Ipfs;

    async fn fetch(&self, locator: &Ipfs) -> Result<Resource, FetchError> {
        let mut url = format!(
            "{}/{}/{}",
            self.base_url.trim_end_matches('/'),
            locator.schema,
            locator.cid
        );

        if let Some(path) = &locator.path {
            url.push('/');
            url.push_str(path.trim_start_matches('/'));
        }

        Ok(Http { url }.into())
    }
}

#[cfg(test)]
mod tests {
    use crate::{
        modules::{
            Fetcher,
            http::Http,
            ipfs::{Ipfs, gateway::IpfsGateway},
        },
        resource::Resource,
    };
    use std::str::FromStr;

    #[tokio::test]
    async fn redirects_ipfs_url() {
        let input: Ipfs = "ipfs://bafkreifnrjhkl7ccr2ifwn2n7ap6dh2way25a6w5x2szegvj5pt4b5nvfu"
            .parse()
            .unwrap();
        let gateway = IpfsGateway::new("https://ipfs.io/");
        let result = gateway.fetch(&input).await.unwrap();
        let result = match result {
            Resource::Http(x) => Some(x),
            _ => None,
        };
        assert_eq!(
            result.unwrap(),
            Http::from_str(
                "https://ipfs.io/ipfs/bafkreifnrjhkl7ccr2ifwn2n7ap6dh2way25a6w5x2szegvj5pt4b5nvfu"
            )
            .unwrap()
        );
    }
}