acts-next 0.14.5

a fast, tiny, extensiable workflow engine
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

pub mod data;
mod db;
mod query;

#[allow(clippy::module_inception)]
mod store;

#[cfg(test)]
mod tests;

use data::*;
pub use query::*;
use serde::{Deserialize, Serialize};
#[allow(unused_imports)]
pub use store::{Store, StoreKind};

use crate::{ActError, Result};
use std::{error::Error, sync::Arc};

fn map_db_err(err: impl Error) -> ActError {
    ActError::Store(err.to_string())
}

#[derive(Debug, Deserialize, Serialize)]
pub struct PageData<T> {
    pub count: usize,
    pub page_num: usize,
    pub page_count: usize,
    pub page_size: usize,
    pub rows: Vec<T>,
}

pub trait DbSet: Send + Sync {
    type Item;
    fn exists(&self, id: &str) -> Result<bool>;
    fn find(&self, id: &str) -> Result<Self::Item>;
    fn query(&self, query: &Query) -> Result<PageData<Self::Item>>;
    fn create(&self, data: &Self::Item) -> Result<bool>;
    fn update(&self, data: &Self::Item) -> Result<bool>;
    fn delete(&self, id: &str) -> Result<bool>;
}

/// Store adapter trait
/// Used to implement custom storage
///
/// # Example
/// ```no_run
/// use acts::{data::{Model, Proc, Task, Package, Message}, DbSet, StoreAdapter};
/// use std::sync::Arc;
/// struct TestStore;
/// impl StoreAdapter for TestStore {
///
///     fn models(&self) -> Arc<dyn DbSet<Item = Model>> {
///         todo!()
///     }
///     fn procs(&self) -> Arc<dyn DbSet<Item =Proc>> {
///         todo!()
///     }
///     fn tasks(&self) -> Arc<dyn DbSet<Item =Task>> {
///         todo!()
///     }
///     fn packages(&self) -> Arc<dyn DbSet<Item =Package>> {
///         todo!()
///     }
///     fn messages(&self) -> Arc<dyn DbSet<Item =Message>> {
///         todo!()
///     }
///     fn init(&self) {}
///     fn close(&self) {}
/// }
/// ```
pub trait StoreAdapter: Send + Sync {
    fn init(&self);

    fn models(&self) -> Arc<dyn DbSet<Item = Model>>;
    fn procs(&self) -> Arc<dyn DbSet<Item = Proc>>;
    fn tasks(&self) -> Arc<dyn DbSet<Item = Task>>;
    fn packages(&self) -> Arc<dyn DbSet<Item = Package>>;
    fn messages(&self) -> Arc<dyn DbSet<Item = Message>>;
    fn close(&self);
}