feat: add tag field to PublishedMessage (#26)

Author: Rakowskiii

relay_client/src/websocket.rs

@@ -2,7 +2,7 @@ use {
     self::connection::{connection_event_loop, ConnectionControl},
     crate::{error::Error, ConnectionOptions},
     relay_rpc::{
-        domain::{SubscriptionId, Topic},
+        domain::{MessageId, SubscriptionId, Topic},
         rpc::{
             BatchFetchMessages,
             BatchReceiveMessages,
@@ -74,8 +74,10 @@ mod stream;
 /// The message received from a subscription.
 #[derive(Debug)]
 pub struct PublishedMessage {
+    pub id: MessageId,
     pub topic: Topic,
     pub message: Arc<str>,
+    pub tag: u32,
     pub published_at: chrono::DateTime<chrono::Utc>,
     pub received_at: chrono::DateTime<chrono::Utc>,
 }
@@ -86,8 +88,10 @@ impl PublishedMessage {
         let now = chrono::Utc::now();
 
         Self {
+            id: request.id(),
             topic: data.topic.clone(),
             message: data.message.clone(),
+            tag: data.tag,
             // TODO: Set proper value once implemented.
             published_at: now,
             received_at: now,

relay_client/src/websocket/inbound.rs

@@ -35,6 +35,10 @@ where
         &self.data
     }
 
+    pub fn id(&self) -> MessageId {
+        self.id
+    }
+
     /// Sends the response back to the Relay. The value is a
     /// `Result<T::Response, T::Error>` (see [`RequestPayload`] trait for
     /// details).