libvault 0.2.2

the libvault is modified from RustyVault
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
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158

use super::{Backend, Field, Operation, field::IntoFieldArc, request::Request, response::Response};
use crate::{context::Context, errors::RvError};
use std::{collections::HashMap, fmt, future::Future, pin::Pin, sync::Arc};

pub type PathOperationFuture<'a> =
    Pin<Box<dyn Future<Output = Result<Option<Response>, RvError>> + Send + 'a>>;
type PathOperationHandler =
    dyn for<'a> Fn(&'a dyn Backend, &'a mut Request) -> PathOperationFuture<'a> + Send + Sync;

#[derive(Debug, Clone)]
pub struct Path {
    pub ctx: Arc<Context>,
    pub pattern: String,
    pub fields: HashMap<String, Arc<Field>>,
    pub operations: Vec<PathOperation>,
    pub help: String,
}

impl Default for Path {
    fn default() -> Self {
        Self {
            ctx: Arc::new(Context::new()),
            pattern: String::new(),
            fields: HashMap::new(),
            operations: Vec::new(),
            help: String::new(),
        }
    }
}

#[derive(Debug, Clone, Default)]
pub struct PathBuilder {
    path: Path,
}

impl PathBuilder {
    pub fn new() -> Self {
        Self::default()
    }

    pub fn context(mut self, ctx: Arc<Context>) -> Self {
        self.path.ctx = ctx;
        self
    }

    pub fn pattern(mut self, pattern: impl Into<String>) -> Self {
        self.path.pattern = pattern.into();
        self
    }

    pub fn help(mut self, help: impl Into<String>) -> Self {
        self.path.help = help.into();
        self
    }

    pub fn fields(mut self, fields: HashMap<String, Arc<Field>>) -> Self {
        self.path.fields = fields;
        self
    }

    pub fn field<F>(mut self, name: impl Into<String>, field: F) -> Self
    where
        F: IntoFieldArc,
    {
        self.path.fields.insert(name.into(), field.into_field_arc());
        self
    }

    pub fn operations(mut self, operations: Vec<PathOperation>) -> Self {
        self.path.operations = operations;
        self
    }

    pub fn operation<H>(mut self, op: Operation, handler: H) -> Self
    where
        H: for<'a> Fn(&'a dyn Backend, &'a mut Request) -> PathOperationFuture<'a>
            + Send
            + Sync
            + 'static,
    {
        self.path
            .operations
            .push(PathOperation::with_handler(op, handler));
        self
    }

    pub fn operation_entry(mut self, operation: PathOperation) -> Self {
        self.path.operations.push(operation);
        self
    }

    pub fn build(self) -> Path {
        self.path
    }
}

#[derive(Clone)]
pub struct PathOperation {
    pub op: Operation,
    pub handler: Arc<PathOperationHandler>,
}

impl fmt::Debug for PathOperation {
    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
        f.debug_struct("PathOperation")
            .field("op", &self.op)
            .finish()
    }
}

impl PathOperation {
    pub fn with_handler<H>(op: Operation, handler: H) -> Self
    where
        H: for<'a> Fn(&'a dyn Backend, &'a mut Request) -> PathOperationFuture<'a>
            + Send
            + Sync
            + 'static,
    {
        Self {
            op,
            handler: Arc::new(handler),
        }
    }
}

impl Path {
    pub fn new(pattern: &str) -> Self {
        Self {
            pattern: pattern.to_string(),
            ..Self::default()
        }
    }

    pub fn builder() -> PathBuilder {
        PathBuilder::new()
    }

    pub fn get_field(&self, key: &str) -> Option<Arc<Field>> {
        self.fields.get(key).cloned()
    }
}

impl PathOperation {
    pub fn new() -> Self {
        Self {
            op: Operation::Read,
            handler: Arc::new(|_backend, _req| Box::pin(async move { Ok(None) })),
        }
    }

    pub async fn handle_request(
        &self,
        backend: &dyn Backend,
        req: &mut Request,
    ) -> Result<Option<Response>, RvError> {
        (self.handler)(backend, req).await
    }
}