Publish push messages when a message is sent to a conversation.HEADmain

1 files changed, 12 insertions, 12 deletions

diff --git a/src/push/handlers/ping/test.rs b/src/push/handlers/ping/test.rs
index c985aaf..cc07ef0 100644
--- a/src/push/handlers/ping/test.rs
+++ b/src/push/handlers/ping/test.rs
@@ -26,7 +26,7 @@ async fn ping_without_subscriptions() {
             .sent()
             .into_iter()
             .filter(|publish| publish.message_eq(&Heartbeat::Heartbeat)
-                && publish.subscriptions.is_empty())
+                && publish.recipients.is_empty())
             .exactly_one()
             .is_ok()
     );
@@ -64,7 +64,7 @@ async fn ping() {
             .sent()
             .into_iter()
             .filter(|publish| publish.message_eq(&Heartbeat::Heartbeat)
-                && publish.subscriptions == subscriptions)
+                && publish.recipients == subscriptions)
             .exactly_one()
             .is_ok()
     );
@@ -110,7 +110,7 @@ async fn ping_multiple_subscriptions() {
             .sent()
             .into_iter()
             .filter(|publish| publish.message_eq(&Heartbeat::Heartbeat)
-                && publish.subscriptions == subscriptions)
+                && publish.recipients == subscriptions)
             .exactly_one()
             .is_ok()
     );
@@ -160,7 +160,7 @@ async fn ping_recipient_only() {
     assert!(
         sent.iter()
             .filter(|publish| publish.message_eq(&Heartbeat::Heartbeat)
-                && publish.subscriptions == recipient_subscriptions)
+                && publish.recipients == recipient_subscriptions)
             .exactly_one()
             .is_ok()
     );
@@ -169,7 +169,7 @@ async fn ping_recipient_only() {
     assert!(
         !sent
             .iter()
-            .any(|publish| publish.subscriptions.contains(&spectator_subscription))
+            .any(|publish| publish.recipients.contains(&spectator_subscription))
     );
 }
 
@@ -212,7 +212,7 @@ async fn ping_permanent_error() {
     assert!(
         sent.iter()
             .filter(|publish| publish.message_eq(&Heartbeat::Heartbeat)
-                && publish.subscriptions == subscriptions)
+                && publish.recipients == subscriptions)
             .exactly_one()
             .is_ok()
     );
@@ -230,7 +230,7 @@ async fn ping_permanent_error() {
     assert!(
         !sent
             .iter()
-            .any(|publish| publish.subscriptions.contains(&subscription))
+            .any(|publish| publish.recipients.contains(&subscription))
     );
 }
 
@@ -275,7 +275,7 @@ async fn ping_temporary_error() {
     assert!(
         sent.iter()
             .filter(|publish| publish.message_eq(&Heartbeat::Heartbeat)
-                && publish.subscriptions == subscriptions)
+                && publish.recipients == subscriptions)
             .exactly_one()
             .is_ok()
     );
@@ -293,7 +293,7 @@ async fn ping_temporary_error() {
     assert!(
         sent.iter()
             .filter(|publish| publish.message_eq(&Heartbeat::Heartbeat)
-                && publish.subscriptions == subscriptions)
+                && publish.recipients == subscriptions)
             .exactly_one()
             .is_ok()
     );
@@ -345,7 +345,7 @@ async fn ping_multiple_subscriptions_with_failure() {
             .sent()
             .iter()
             .filter(|publish| publish.message_eq(&Heartbeat::Heartbeat)
-                && publish.subscriptions == subscriptions)
+                && publish.recipients == subscriptions)
             .exactly_one()
             .is_ok()
     );
@@ -362,13 +362,13 @@ async fn ping_multiple_subscriptions_with_failure() {
     assert!(
         sent.iter()
             .filter(|publish| publish.message_eq(&Heartbeat::Heartbeat)
-                && publish.subscriptions == subscriptions)
+                && publish.recipients == subscriptions)
             .exactly_one()
             .is_ok()
     );
     assert!(
         !sent
             .iter()
-            .any(|publish| publish.subscriptions.contains(&failing))
+            .any(|publish| publish.recipients.contains(&failing))
     );
 }