rename PING/PONG to STATUS/STATUS_REPLY

1 files changed, 11 insertions, 11 deletions

diff --git a/src/transport/mycelium/mod.rs b/src/transport/mycelium/mod.rs
index 354aebc..cf979e2 100644
--- a/src/transport/mycelium/mod.rs
+++ b/src/transport/mycelium/mod.rs
@@ -28,7 +28,7 @@ const INBOX_POLLS: usize = 2;
 /// (`post_timeout`).
 const REQUEST_TIMEOUT: Duration = Duration::from_secs(10);
 /// The slowest our Mycelium is expected to take a message body, in bytes per second:
-/// a large sync message gets more time than a PING, instead of failing (and being
+/// a large sync message gets more time than a STATUS, instead of failing (and being
 /// generated and sent whole again) at a fixed limit.
 const POST_MIN_RATE: u64 = 1 << 20;
 
@@ -552,7 +552,7 @@ pub(crate) enum TransportError {
 mod tests {
     use super::*;
     use crate::transport::{
-        BlobBody, BlobId, BlobMessage, Epoch, HeadsSummary, Keepalive, MAX_LISTED_HEADS,
+        BlobBody, BlobId, BlobMessage, Epoch, HeadsSummary, MAX_LISTED_HEADS, Status,
     };
     use automerge::ChangeHash;
 
@@ -571,7 +571,7 @@ mod tests {
     #[test]
     fn largest_keepalive_fits_in_one_chunk() {
         // A digest with a full sample: the most a keepalive carries.
-        let keepalive = Keepalive {
+        let status = Status {
             heads: HeadsSummary::of(
                 (0..=MAX_LISTED_HEADS as u8)
                     .map(|n| ChangeHash([n; 32]))
@@ -585,17 +585,17 @@ mod tests {
             ready: true,
             syncs_with_you: true,
         };
-        let payload = wire::encode(&ParsedMessage::Pong(keepalive.clone())).unwrap();
+        let payload = wire::encode(&ParsedMessage::StatusReply(status.clone())).unwrap();
         // Mycelium's message data: a length byte, the topic, then our payload.
         let size = 1 + TOPIC.len() + payload.len();
         assert!(
             size + 50 <= MYCELIUM_CHUNK,
-            "keepalive with {MAX_LISTED_HEADS} heads takes {size} bytes"
+            "STATUS with {MAX_LISTED_HEADS} heads takes {size} bytes"
         );
-        let ParsedMessage::Pong(decoded) = wire::decode(&payload).unwrap() else {
-            panic!("not a PONG");
+        let ParsedMessage::StatusReply(decoded) = wire::decode(&payload).unwrap() else {
+            panic!("not a STATUS_REPLY");
         };
-        assert_eq!(decoded.heads, keepalive.heads);
+        assert_eq!(decoded.heads, status.heads);
     }
 
     #[test]
@@ -648,17 +648,17 @@ mod tests {
 
     #[test]
     fn messages_round_trip_through_the_api_body() {
-        let keepalive = ParsedMessage::Ping(Keepalive {
+        let status = ParsedMessage::Status(Status {
             heads: HeadsSummary::of(vec![ChangeHash([1; 32])]),
             epoch: Epoch::GENESIS,
             epoch_seq: 0,
             ready: true,
             syncs_with_you: true,
         });
-        let encoded = encode_message("peer", &keepalive).unwrap();
+        let encoded = encode_message("peer", &status).unwrap();
         assert!(matches!(
             decode_message(&encoded.body).unwrap(),
-            ParsedMessage::Ping(_)
+            ParsedMessage::Status(_)
         ));
     }