feat(subscribe): add subscription list changed status

pubnub · Feb 8, 2024 · d5465f9 · d5465f9
1 parent 03b5201
commit d5465f9
Show file tree

Hide file tree

Showing 2 changed files with 32 additions and 2 deletions.
diff --git a/src/dx/subscribe/event_engine/state.rs b/src/dx/subscribe/event_engine/state.rs
@@ -231,7 +231,10 @@ impl SubscribeState {
                         input: SubscriptionInput::new(channels, channel_groups),
                         cursor: cursor.clone(),
                     }),
-                    None,
+                    Some(vec![EmitStatus(ConnectionStatus::SubscriptionChanged {
+                        channels: channels.clone(),
+                        channel_groups: channel_groups.clone(),
+                    })]),
                 ))
             }
             Self::ReceiveFailed { cursor, .. } => Some(self.transition_to(
@@ -290,7 +293,10 @@ impl SubscribeState {
                     input: SubscriptionInput::new(channels, channel_groups),
                     cursor: restore_cursor.clone(),
                 }),
-                None,
+                Some(vec![EmitStatus(ConnectionStatus::SubscriptionChanged {
+                    channels: channels.clone(),
+                    channel_groups: channel_groups.clone(),
+                })]),
             )),
             Self::ReceiveFailed { .. } => Some(self.transition_to(
                 Some(Self::Handshaking {

diff --git a/src/dx/subscribe/types.rs b/src/dx/subscribe/types.rs
@@ -146,6 +146,20 @@ pub enum ConnectionStatus {
 
     /// Unexpected disconnection.
     DisconnectedUnexpectedly(PubNubError),
+
+    /// List of channels and groups changed in subscription.
+    SubscriptionChanged {
+        /// List of channels used in subscription.
+        ///
+        /// Channels can be:
+        /// - regular channels
+        /// - channel metadata `id`s
+        /// - user metadata `id`s
+        channels: Option<Vec<String>>,
+
+        /// List of channel groups used in subscription.
+        channel_groups: Option<Vec<String>>,
+    },
 }
 
 /// Presence update information.
@@ -733,6 +747,16 @@ impl Debug for ConnectionStatus {
             ConnectionStatus::DisconnectedUnexpectedly(err) => {
                 write!(f, "DisconnectedUnexpectedly({err:?})")
             }
+            Self::SubscriptionChanged {
+                channels,
+                channel_groups,
+            } => {
+                write!(
+                    f,
+                    "SubscriptionChanged {{ channels: {channels:?}, \
+                    channel_groups: {channel_groups:?}  }}"
+                )
+            }
         }
     }
 }