saddle-framework 0.3.36

The single business-facing facade for Saddle applications
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

//! Ordinary named calls borrow the original request and charge their private
//! future before constructing it. No alternate legacy allocation path exists.
use super::*;

macro_rules! named_storage {
    ($name:ident, $inner:ident, $operation:ident,
     $argument:ident: $input:ty, $output:ty, $validate:expr) => {
        pub fn $name<O: $operation>(
            &mut self,
            $argument: $input,
        ) -> impl Future<Output = Result<$output, QueryFailure<$input>>> + Send {
            saddle_admission::lazy_framework_future(move || {
                // Target rejection returns the same owned argument before any
                // future storage reservation or serial-scope transition.
                if let Err(error) = O::validate_parameters($validate, &self.target()) {
                    return Err(Err(QueryFailure::Target {
                        parameters: $argument,
                        error,
                    }));
                }
                if self.state.reserved_failure.lock().unwrap().is_some() {
                    return Err(Err(QueryFailure::Database(ScopeDatabaseError::State)));
                }
                let memory = self.framework_future_memory();
                let reporter = self.shared();
                saddle_admission::managed_framework_future(
                    &memory,
                    move || {
                        #[cfg(test)]
                        controls::inner_constructed();
                        self.$inner::<O>($argument)
                    },
                    |error| reporter.record_database_future_error_at_source(error),
                )
                .map_err(|_| Err(QueryFailure::Database(ScopeDatabaseError::Resource)))
            })
        }
    };
}

impl DatabaseRequest {
    named_storage!(named_write, named_write_inner, GeneratedOwnedWrite,
        parameters: O::NamedParameters, ManagedWriteResult, &parameters);
    named_storage!(named_rows, named_rows_inner, GeneratedOwnedQuery,
        parameters: O::NamedParameters,
        crate::database::Rows<O::Row, O::NamedRow>, &parameters);
    named_storage!(named_optional, named_optional_inner, GeneratedOwnedQuery,
        parameters: O::NamedParameters, Option<O::NamedRow>, &parameters);
    named_storage!(named_probe, named_probe_inner, GeneratedOwnedQuery,
        parameters: O::NamedParameters,
        crate::database::MatchCardinality<O::NamedRow>, &parameters);
    named_storage!(named_page, named_page_inner, GeneratedPageQuery,
        request: crate::database_rows::PageRequest<O>,
        crate::database_rows::Page<O>, &request.parameters);
}

#[cfg(test)]
mod controls;