test: update chekov messaging tests

Signed-off-by: Simon Paitrault <simon.paitrault@gmail.com>

Cargo.toml

@@ -8,7 +8,7 @@ serde = { version = "1.0.117", features = ["derive"] }
 sqlx = { version = "0.6.2", features = ["chrono", "time", "uuid", "json", "offline", "runtime-actix-native-tls"] }
 async-trait = "0.1.51"
 serde_json = "1.0.68"
-actix = "0.12.0"
+actix = "0.13.0"
 futures = "0.3.17"
 log = "0.4.14"
 tokio = { version = "1.12.0", features = ["full"] }

crates/chekov/src/message.rs

@@ -48,7 +48,7 @@ pub struct EventMetadatas {
 
 #[doc(hidden)]
 #[derive(Debug, Clone, Message)]
-#[rtype(result = "Result(), ()>")]
+#[rtype(result = "Result<(), ()>")]
 pub struct EventEnvelope<E: Event> {
     pub event: E,
     pub meta: EventMetadatas,
@@ -65,55 +65,53 @@ pub struct ResolveAndApply(pub RecordedEvent);
 pub struct ResolveAndApplyMany(pub Vec<RecordedEvent>);
 
 #[derive(Message)]
-#[rtype("Result<Vec<RecordedEvent>, event_store::prelude::EventStoreError>")]
+#[rtype(result = "Result<Vec<RecordedEvent>, event_store::prelude::EventStoreError>")]
 pub(crate) struct ExecuteReader(pub(crate) event_store::prelude::Reader);
 
 #[derive(Message)]
-#[rtype(
-    "Result<
+#[rtype(result = "Result<
             std::pin::Pin<
                 Box<dyn futures::Stream<Item = Result<Vec<RecordedEvent>, EventStoreError>> + Send>,
             >,
             EventStoreError,
-        >"
-)]
+        >")]
 pub(crate) struct ExecuteStreamForward(pub(crate) String);
 
 #[derive(Message)]
-#[rtype("Result<Vec<Uuid>, event_store::prelude::EventStoreError>")]
+#[rtype(result = "Result<Vec<Uuid>, event_store::prelude::EventStoreError>")]
 pub(crate) struct ExecuteAppender(pub(crate) event_store::prelude::Appender);
 
 #[derive(Message)]
-#[rtype("Result<event_store::prelude::Stream, event_store::prelude::EventStoreError>")]
+#[rtype(result = "Result<event_store::prelude::Stream, event_store::prelude::EventStoreError>")]
 pub(crate) struct ExecuteStreamInfo(pub(crate) String);
 
 #[derive(Message)]
-#[rtype("u64")]
+#[rtype(result = "u64")]
 pub(crate) struct AggregateVersion;
 
 #[derive(Message)]
-#[rtype("A")]
+#[rtype(result = "A")]
 pub(crate) struct AggregateState<A: Aggregate>(pub(crate) PhantomData<A>);
 
 #[derive(Message, Debug)]
-#[rtype("()")]
+#[rtype(result = "()")]
 pub(crate) struct StartListening;
 
 #[derive(Message)]
-#[rtype("Addr<event_store::EventStore<S>>")]
+#[rtype(result = "Addr<event_store::EventStore<S>>")]
 pub(crate) struct GetEventStoreAddr<S: Storage> {
     pub(crate) _phantom: PhantomData<S>,
 }
 
 #[derive(Message)]
-#[rtype("Option<Addr<crate::aggregate::AggregateInstance<A>>>")]
+#[rtype(result = "Option<Addr<crate::aggregate::AggregateInstance<A>>>")]
 pub(crate) struct GetAggregateAddr<A: Aggregate> {
     pub(crate) identifier: String,
     pub(crate) _phantom: PhantomData<A>,
 }
 
 #[derive(Message)]
-#[rtype("Result<Addr<crate::aggregate::AggregateInstance<A>>, ()>")]
+#[rtype(result = "Result<Addr<crate::aggregate::AggregateInstance<A>>, ()>")]
 pub(crate) struct StartAggregate<A: Aggregate, APP: Application> {
     pub(crate) identifier: String,
     pub(crate) correlation_id: Option<Uuid>,
@@ -122,7 +120,7 @@ pub(crate) struct StartAggregate<A: Aggregate, APP: Application> {
 }
 
 #[derive(Message)]
-#[rtype("Result<(), ()>")]
+#[rtype(result = "Result<(), ()>")]
 pub(crate) struct ShutdownAggregate {
     pub(crate) identifier: String,
 }

crates/event_store-core/src/event/mod.rs

@@ -27,7 +27,7 @@ pub trait Event: Serialize + Send + std::convert::TryFrom<RecordedEvent> {
 
 /// A `RecordedEvent` represents an `Event` which have been append to a `Stream`
 #[derive(sqlx::FromRow, Debug, Clone, Message, Serialize)]
-#[rtype("()")]
+#[rtype(result = "()")]
 pub struct RecordedEvent {
     /// an incrementing and gapless integer used to order the event in a stream.
     #[sqlx(try_from = "i64")]

crates/event_store-core/src/event_bus/mod.rs

@@ -26,7 +26,7 @@ pub type BoxedStream = Pin<
 >;
 
 #[derive(Debug, Message)]
-#[rtype("()")]
+#[rtype(result = "()")]
 pub enum EventBusMessage {
     Notification(EventNotification),
     Events(String, Vec<RecordedEvent>),

crates/event_store/src/connection/mod.rs

@@ -21,7 +21,7 @@ mod messaging;
 pub use messaging::{Append, CreateStream, Read, StreamForward, StreamForwardResult, StreamInfo};
 
 #[derive(Message)]
-#[rtype("()")]
+#[rtype(result = "()")]
 // TODO: Remove this by a better subscription channel
 pub struct OpenNotificationChannel {
     pub(crate) sender: mpsc::UnboundedSender<EventBusMessage>,

crates/event_store/src/event/mod.rs

@@ -6,7 +6,7 @@ pub use crate::core::event::UnsavedEvent;
 pub use crate::core::event::UnsavedEventError;
 
 #[derive(Debug, Clone, Message)]
-#[rtype("()")]
+#[rtype(result = "()")]
 pub struct RecordedEvents {
     pub(crate) events: Vec<RecordedEvent>,
 }

crates/event_store/src/subscriptions/pub_sub.rs

@@ -37,15 +37,15 @@ impl PubSub {
 }
 
 #[derive(Message)]
-#[rtype("()")]
+#[rtype(result = "()")]
 struct Subscribe(Recipient<SubscriptionNotification>, String);
 
 #[derive(Message)]
-#[rtype("usize")]
+#[rtype(result = "usize")]
 struct GetSubscriberCountForStream(String);
 
 #[derive(Message)]
-#[rtype("()")]
+#[rtype(result = "()")]
 pub struct PubSubNotification {
     pub(crate) stream: String,
     pub(crate) events: Vec<RecordedEvent>,

crates/event_store/src/subscriptions/subscription.rs

@@ -14,11 +14,11 @@ use actix::prelude::*;
 use tracing::debug;
 
 #[derive(Debug, Message)]
-#[rtype("()")]
+#[rtype(result = "()")]
 struct Connect(pub Recipient<SubscriptionNotification>, SubscriptionOptions);
 
 #[derive(Debug, Message)]
-#[rtype("()")]
+#[rtype(result = "()")]
 pub struct CatchUp;
 
 #[derive(Debug)]

crates/event_store/src/subscriptions/supervisor.rs

@@ -85,7 +85,7 @@ impl<S: Storage> Handler<CreateSubscription<S>> for SubscriptionsSupervisor<S> {
 }
 
 #[derive(Message)]
-#[rtype("()")]
+#[rtype(result = "()")]
 pub struct Started;
 
 impl<S: Storage> Handler<Started> for SubscriptionsSupervisor<S> {
@@ -97,7 +97,7 @@ impl<S: Storage> Handler<Started> for SubscriptionsSupervisor<S> {
 }
 
 #[derive(Message)]
-#[rtype("()")]
+#[rtype(result = "()")]
 pub struct GoingDown;
 
 impl<S: Storage> Handler<GoingDown> for SubscriptionsSupervisor<S> {
@@ -109,7 +109,7 @@ impl<S: Storage> Handler<GoingDown> for SubscriptionsSupervisor<S> {
 }
 
 #[derive(Message)]
-#[rtype("()")]
+#[rtype(result = "()")]
 pub struct Down;
 
 impl<S: Storage> Handler<Down> for SubscriptionsSupervisor<S> {