mahler-core 0.21.0

An automated job orchestration library that builds and executes dynamic workflows
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

use std::sync::Arc;

use crate::errors::ExtractionError;
use crate::system::System;
use crate::task::{Context, FromSystem};

/// Extracts a shared system resource
///
/// This extractor will look for a resource of type `<R>` for the [Worker](`crate::worker::Worker`) and
/// provides read-only access to a resource reference if it exists.
///
/// # Example
///
/// Multiple `Res` extractors can be used in the same handler, but since `Worker` indexes resources
/// by `TypeId`, extracting the same resource twice will result in two references of the same
/// resource.
///
/// ```rust,no_run
/// use mahler::{
///     extract::Res,
///     task::{Handler, update},
///     worker::{Worker, Ready}
/// };
/// use serde::{Serialize, Deserialize};
///
/// // A shared resource type
/// struct MyConnection {/* ... */};
///
/// // Another resource
/// struct MyConfig {/* ... */};
///
/// #[derive(Serialize,Deserialize)]
/// struct SystemState {/* ... */};
///
/// fn multiple_resources(conn: Res<MyConnection>, config: Res<MyConfig>) {
///     // a reference to the resources configured in the Worker below
///     // can be access within the Job handler
/// }
///
/// let mut worker: Worker<SystemState, Ready> = Worker::new()
///     .job("/{foo}/{bar}", update(multiple_resources))
///     .resource(MyConnection {/* .. */})
///     .resource(MyConfig {/* .. */})
///     .initial_state(SystemState {/* ... */})
///     .unwrap();
/// ```
///
/// There is nothing that prevents you from making a resource editable behind a `RwLock` (for
/// instance), however, this may interfere with workflow execution.
///
/// ```rust,no_run
/// use tokio::sync::RwLock;
/// use std::ops::Deref;
/// use mahler::{
///     extract::{View, Res},
///     task::{Handler, update, with_io, IO},
///     worker::{Worker, Ready}
/// };
/// use serde::{Serialize, Deserialize};
///
/// // An editable resource
/// struct MyConfig(RwLock<String>);
/// impl MyConfig {
///     pub fn new(s: impl Into<String>) -> Self {
///         MyConfig(RwLock::new(s.into()))
///     }
/// }
///
/// impl Deref for MyConfig {
///     type Target = RwLock<String>;
///
///     fn deref(&self) -> &Self::Target {
///         &self.0
///     }
/// }
///
/// #[derive(Serialize, Deserialize)]
/// struct SystemState {/* ... */};
///
/// fn edit_resources(view: View<i32>, config: Res<MyConfig>) -> IO<i32> {
///     // update view
///     with_io(view, |view| async move {
///         if let Some(config) = config.as_ref() {
///             // this is possible but it may interfere with the workflow execution
///             // if there are multiple writers running concurrently
///             let mut conf = config.write().await;
///             *conf = String::from("bar");
///         }
///
///         Ok(view)
///     })
/// }
///
/// let worker: Worker<SystemState, Ready> = Worker::new()
///     .job("/{foo}/{bar}", update(edit_resources))
///     .resource(MyConfig::new("foo"))
///     .initial_state(SystemState {/* ... */})
///     .unwrap();
/// ```
#[derive(Debug, Clone)]
pub struct Res<R>(Option<Arc<R>>);

impl<R> Res<R> {
    /// Returns a reference to the resource wrapped in an Option
    ///
    /// Returns None if the resource is not defined on the system
    pub fn as_ref(&self) -> Option<&R> {
        self.0.as_deref()
    }
}

impl<R: Send + Sync + 'static> FromSystem for Res<R> {
    type Error = ExtractionError;

    fn from_system(system: &System, _: &Context) -> Result<Self, Self::Error> {
        let arc = system.resource::<R>();
        Ok(Res(arc))
    }
}