coerce 0.8.6

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

use crate::util::{GetStatusRequest, SetStatusRequest, TestActor, TestActorStatus};
use coerce::actor::context::ActorContext;

use coerce::actor::message::{Handler, Message, MessageWrapErr};
use coerce::actor::scheduler::ActorType::Tracked;

use coerce::actor::{ActorRef, ActorRefErr, ToActorId};
use coerce::remote::system::builder::RemoteSystemConfigBuilder;

use coerce::remote::RemoteActorRef;

#[macro_use]
extern crate async_trait;

#[macro_use]
extern crate serde;

mod util;

struct NotSerialisable;

impl Message for NotSerialisable {
    type Result = ();
}

#[async_trait]
impl Handler<NotSerialisable> for TestActor {
    async fn handle(&mut self, _: NotSerialisable, _: &mut ActorContext) {}
}

fn remote_handlers(builder: &mut RemoteSystemConfigBuilder) -> &mut RemoteSystemConfigBuilder {
    builder.with_handler::<TestActor, GetStatusRequest>("TestActor.GetStatusRequest")
}

#[tokio::test]
pub async fn test_remote_actor_err() {
    util::create_trace_logger();
    let node_1 = util::create_cluster_node(1, "localhost:30101", None, |handlers| {
        remote_handlers(handlers)
    })
    .await;

    let node_2 =
        util::create_cluster_node(2, "localhost:30201", Some("localhost:30101"), |handlers| {
            remote_handlers(handlers)
        })
        .await;

    let actor_id = "test_actor".to_actor_id();
    let local_ref = node_1
        .actor_system()
        .new_actor(actor_id.clone(), TestActor::new(), Tracked)
        .await
        .expect("create TestActor on node=1");

    let _ = local_ref.notify(SetStatusRequest {
        status: TestActorStatus::Active,
    });

    let actor_ref = ActorRef::from(RemoteActorRef::<TestActor>::new(
        actor_id.clone(),
        node_1.node_id(),
        node_2.clone(),
    ));

    let status = actor_ref.send(GetStatusRequest).await;
    assert!(status.is_ok());

    let _ = local_ref.stop().await;

    let status = actor_ref.send(GetStatusRequest).await;
    assert_eq!(status.unwrap_err(), ActorRefErr::NotFound(actor_id.clone()));

    let status = actor_ref.send(NotSerialisable).await;
    assert_eq!(
        status.unwrap_err(),
        ActorRefErr::Serialisation(MessageWrapErr::NotTransmittable)
    );

    let status = actor_ref
        .send(SetStatusRequest {
            status: TestActorStatus::Inactive,
        })
        .await;

    assert_eq!(
        status.unwrap_err(),
        ActorRefErr::NotSupported {
            actor_id,
            message_type: "test_remote_actor_err::util::SetStatusRequest".to_string(),
            actor_type: "test_remote_actor_err::util::TestActor".to_string()
        }
    );
}