rest of the functions

Author: Xavrax

src/dx/publish/mod.rs

@@ -499,10 +499,13 @@ mod should {
                 ("norep".to_string(), "true".to_string()),
                 ("store".to_string(), "1".to_string()),
                 ("space-id".to_string(), "space_id".to_string()),
-                ("type".to_string(), "message_type".to_string()),
+                (
+                    "custom_message_type".to_string(),
+                    "message_type".to_string()
+                ),
                 ("meta".to_string(), "{\"k\":\"v\"}".to_string()),
                 ("ttl".to_string(), "50".to_string()),
-                ("seqn".to_string(), "1".to_string())
+                ("seqn".to_string(), "1".to_string()),
             ]),
             result.data.query_parameters
         );

src/dx/subscribe/event_dispatcher.rs

@@ -430,7 +430,7 @@ mod it_should {
                 channel: "test-channel".to_string(),
                 subscription: "test-channel".to_string(),
                 data: "Test message 1".to_string().into_bytes(),
-                r#type: None,
+                custom_message_type: None,
                 space_id: None,
                 decryption_error: None,
             }),
@@ -440,7 +440,7 @@ mod it_should {
                 channel: "test-channel".to_string(),
                 subscription: "test-channel".to_string(),
                 data: "Test signal 1".to_string().into_bytes(),
-                r#type: None,
+                custom_message_type: None,
                 space_id: None,
                 decryption_error: None,
             }),
@@ -459,7 +459,7 @@ mod it_should {
                 channel: "test-channel".to_string(),
                 subscription: "test-channel".to_string(),
                 data: "Test message 2".to_string().into_bytes(),
-                r#type: None,
+                custom_message_type: None,
                 space_id: None,
                 decryption_error: None,
             }),

src/dx/subscribe/event_engine/effects/emit_messages.rs

@@ -34,7 +34,7 @@ mod should {
             channel: "test".to_string(),
             subscription: "test-group".to_string(),
             data: vec![],
-            r#type: None,
+            custom_message_type: None,
             space_id: None,
             decryption_error: None,
         };

src/dx/subscribe/result.rs

@@ -257,11 +257,11 @@ pub struct Envelope {
     pub subscription: Option<String>,
 
     /// User provided message type (set only when [`publish`] called with
-    /// `r#type`).
+    /// `custom_message_type`).
     ///
     /// [`publish`]: crate::dx::publish
-    #[cfg_attr(feature = "serde", serde(rename = "mt"), serde(default))]
-    pub r#type: Option<String>,
+    #[cfg_attr(feature = "serde", serde(rename = "cmt"), serde(default))]
+    pub custom_message_type: Option<String>,
 
     /// Identifier of space into which message has been published (set only when
     /// [`publish`] called with `space_id`).

src/dx/subscribe/types.rs

@@ -470,10 +470,10 @@ pub struct Message {
     pub data: Vec<u8>,
 
     /// User provided message type (set only when [`publish`] called with
-    /// `r#type`).
+    /// `custom_message_type`).
     ///
     /// [`publish`]: crate::dx::publish
-    pub r#type: Option<String>,
+    pub custom_message_type: Option<String>,
 
     /// Identifier of space into which message has been published (set only when
     /// [`publish`] called with `space_id`).
@@ -1097,7 +1097,7 @@ impl TryFrom<Envelope> for Message {
                 channel: value.channel,
                 subscription,
                 data: value.payload.into(),
-                r#type: value.r#type,
+                custom_message_type: value.custom_message_type,
                 space_id: value.space_id,
                 decryption_error: None,
             })