coerce 0.3.1-prerelease2

Async actor runtime and distributed systems framework
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

use crate::actor::{ActorId, ActorState};
use crate::remote::system::RemoteActorSystem;

#[derive(Debug, Eq, PartialEq)]
pub enum ActorStoreErr {
    StoreUnavailable,
    InvalidConfig,
    Other(String),
}

impl ActorStoreErr {
    pub fn from_str(s: impl ToString) -> ActorStoreErr {
        ActorStoreErr::Other(s.to_string())
    }
}

#[async_trait]
pub trait ActorStore {
    async fn get(&mut self, actor_id: ActorId) -> Result<Option<ActorState>, ActorStoreErr>;

    async fn put(&mut self, actor: &ActorState) -> Result<(), ActorStoreErr>;

    async fn remove(&mut self, actor_id: ActorId) -> Result<bool, ActorStoreErr>;

    fn clone(&self) -> Box<dyn ActorStore + Sync + Send>;
}

#[async_trait]
pub trait StatefulActor {
    async fn save(&mut self, _ctx: RemoteActorSystem) {
        trace!(target: "StatefulActor", "attempting to save actor state");
    }
}

// #[async_trait]
// impl<A: Actor> StatefulActor for A
// where
//     A: TryTo<ActorState>,
//     A: TryFrom<ActorState>,
// {
//
// }

// pub trait TryTo<T> {
//     type Error;
//
//     fn try_to(&self) -> Result<T, Self::Error>;
// }
//
// impl<A: Actor> TryFrom<ActorState> for A where A: DeserializeOwned {
//     type Error = ();
//
//     fn try_from(value: ActorState) -> Result<Self, Self::Error> {
//         match serde_json::from_slice(&value.state) {
//             Ok(a) => Ok(a),
//             _ => Err(())
//         }
//     }
// }
//
// impl<A: Actor> TryTo<ActorState> for A where A: Serialize {
//     type Error = ();
//
//     fn try_to(&self) -> Result<ActorState, Self::Error> {
//         let state = serde_json::to_string(&self);
//         if let Ok(state) = state {
//             Err(())
//         } else {
//             Err(())
//         }
//     }
// }