polywrap_resolvers 0.1.11

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

use core::fmt;
use polywrap_core::{error::Error, invoker::Invoker, uri::Uri};
use std::sync::{Arc, Mutex};

use polywrap_core::resolution::{
    uri_resolution_context::{UriPackageOrWrapper, UriResolutionContext},
    uri_resolver::UriResolver,
};

use crate::uri_resolver_aggregator_base::UriResolverAggregatorBase;

pub struct UriResolverAggregator {
    name: Option<String>,
    resolvers: Vec<Arc<dyn UriResolver>>,
}

impl UriResolverAggregator {
    pub fn new(resolvers: Vec<Arc<dyn UriResolver>>) -> Self {
        let resolvers = resolvers.into_iter().map(Arc::from).collect();
        Self {
            name: None,
            resolvers,
        }
    }

    pub fn resolver_name(mut self, name: &str) -> Self {
        self.name = Some(name.to_string());
        self
    }
}

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

        if let Ok(resolvers) = resolver_result {
            self.try_resolve_uri_with_resolvers(uri, invoker, resolvers, resolution_context)
        } else {
            //TODO: verify this case.
            Err(Error::ResolutionError(
                "Failed to get URI resolvers".to_string(),
            ))
        }
    }
}

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

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

    fn get_uri_resolvers(
        &self,
        _: &Uri,
        _: &dyn Invoker,
        _: Arc<Mutex<UriResolutionContext>>,
    ) -> Result<Vec<Arc<dyn UriResolver>>, Error> {
        Ok(self.resolvers.clone())
    }
}

impl fmt::Debug for UriResolverAggregator {
    fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
        write!(f, "UriResolverAggregator\nResolvers: {:?}", self.resolvers)
    }
}

impl From<Vec<Box<dyn UriResolver>>> for UriResolverAggregator {
    fn from(resolvers: Vec<Box<dyn UriResolver>>) -> Self {
        UriResolverAggregator::new(resolvers.into_iter().map(Arc::from).collect())
    }
}

impl From<Vec<Arc<dyn UriResolver>>> for UriResolverAggregator {
    fn from(resolvers: Vec<Arc<dyn UriResolver>>) -> Self {
        UriResolverAggregator::new(resolvers)
    }
}