rename PING/PONG to STATUS/STATUS_REPLY

1 files changed, 9 insertions, 9 deletions

diff --git a/src/transport/p2p.rs b/src/transport/p2p.rs
index fcf961e..7a92407 100644
--- a/src/transport/p2p.rs
+++ b/src/transport/p2p.rs
@@ -1438,7 +1438,7 @@ mod tests {
 
     use super::*;
     use crate::document::replica::Epoch;
-    use crate::transport::{HeadsSummary, Keepalive};
+    use crate::transport::{HeadsSummary, Status};
 
     /// Memory ports are process-wide.
     static NEXT_PORT: AtomicU64 = AtomicU64::new(40_000);
@@ -1481,8 +1481,8 @@ mod tests {
         memory_node_with(true, Vec::new(), false)
     }
 
-    fn ping() -> ParsedMessage {
-        ParsedMessage::Ping(Keepalive {
+    fn status() -> ParsedMessage {
+        ParsedMessage::Status(Status {
             heads: HeadsSummary::of(Vec::new()),
             epoch: Epoch::GENESIS,
             epoch_seq: 3,
@@ -1522,13 +1522,13 @@ mod tests {
             b.resolve_seed(&a_address.to_string()).await.unwrap(),
             a.local_id()
         );
-        b.send_message(a.local_id(), &ping()).await.unwrap();
+        b.send_message(a.local_id(), &status()).await.unwrap();
         let (from, message) = at_a.recv().await.unwrap();
         assert_eq!(from, b.local_id());
-        assert!(matches!(message, ParsedMessage::Ping(keepalive) if keepalive.epoch_seq == 3));
+        assert!(matches!(message, ParsedMessage::Status(status) if status.epoch_seq == 3));
 
         // a knows no address of b, but b's connection is there.
-        a.send_message(b.local_id(), &ping()).await.unwrap();
+        a.send_message(b.local_id(), &status()).await.unwrap();
         let (from, _) = at_b.recv().await.unwrap();
         assert_eq!(from, a.local_id());
 
@@ -1588,7 +1588,7 @@ mod tests {
         let (a, b) = (Arc::new(a), Arc::new(b));
         let _at_a = received(Arc::clone(&a));
         b.resolve_seed(&a_address.to_string()).await.unwrap();
-        b.send_message(a.local_id(), &ping()).await.unwrap();
+        b.send_message(a.local_id(), &status()).await.unwrap();
         let b_id = b.local_id().to_owned();
         assert!(
             eventually(|| a.locations(&b_id) == [b_address.to_string()]).await,
@@ -1665,7 +1665,7 @@ mod tests {
 
         let (a, _) = memory_node();
         assert_eq!(a.resolve_seed(&relayed).await.unwrap(), b.local_id());
-        a.send_message(b.local_id(), &ping()).await.unwrap();
+        a.send_message(b.local_id(), &status()).await.unwrap();
         let (from, _) = at_b.recv().await.unwrap();
         assert_eq!(from, a.local_id());
         assert!(a.connection(b.local_id()).is_some());
@@ -1808,7 +1808,7 @@ mod tests {
             .public()
             .to_peer_id()
             .to_string();
-        assert!(b.send_message(&stranger, &ping()).await.is_err());
+        assert!(b.send_message(&stranger, &status()).await.is_err());
         assert!(b.resolve_seed(&stranger).await.is_err());
         assert_eq!(b.connection(&stranger), None);
     }