polywrap_resolvers 0.1.6-beta.2

Uri resolvers to achieve uri resolution in Polywrap Client
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

use core::fmt;
use std::sync::Arc;
use polywrap_core::{
    resolvers::{
        uri_resolution_context::{
            UriResolutionContext,
            UriPackageOrWrapper
        },
        uri_resolver_aggregator_base::UriResolverAggregatorBase,
        uri_resolver::UriResolver
    },
    uri::Uri,
    error::Error, invoker::Invoker
};

use crate::uri_resolver_wrapper::UriResolverWrapper;

pub struct ExtendableUriResolver {
    name: Option<String>
}

impl ExtendableUriResolver {
    pub fn new(name: Option<String>) -> Self {
        ExtendableUriResolver { name }
    }
}

impl UriResolverAggregatorBase for ExtendableUriResolver {
    fn get_resolver_name(&self) -> Option<String> {
        self.name.clone()
    }

    fn get_uri_resolvers(
        &self,
        _: &Uri,
        invoker: &dyn Invoker,
        resolution_context: &mut UriResolutionContext
    ) -> Result<Vec<Arc<dyn UriResolver>>, Error> {
        let implementations = invoker.get_implementations(
           &Uri::try_from("wrap://ens/uri-resolver.core.polywrap.eth")?
        )?;

        let resolvers = implementations.into_iter().filter_map(|implementation| {
            if !resolution_context.is_resolving(&implementation) {
                let wrapper = Arc::new(UriResolverWrapper::new(implementation));
                return Some(wrapper as Arc<dyn UriResolver>);
            }

            None
        }).collect::<Vec<Arc<dyn UriResolver>>>();

        Ok(resolvers)
    }

    fn get_step_description(
        &self,
        _: &Uri,
        _: &Result<UriPackageOrWrapper, Error>,
    ) -> String {
        if let Some(name) = self.get_resolver_name() {
            name
        } else {
            "ExtendableUriResolver".to_string()
        }
    }
}

impl UriResolver for ExtendableUriResolver {
    fn try_resolve_uri(
        &self, 
        uri: &Uri, 
        invoker: Arc<dyn Invoker>, 
        resolution_context: &mut UriResolutionContext
    ) -> Result<UriPackageOrWrapper, Error> {
        let resolvers = self.get_uri_resolvers(
            uri,
            invoker.as_ref(),
            resolution_context
        )?;

        if resolvers.is_empty() {
            let uri = UriPackageOrWrapper::Uri(uri.clone());
            return Ok(uri);
        }

        self.try_resolve_uri_with_resolvers(
            uri,
            invoker,
            resolvers,
            resolution_context
        )
    }
}

impl fmt::Debug for ExtendableUriResolver {
  fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
      write!(f, "ExtendableUriResolver", )
  }
}