diff options
Diffstat (limited to 'src/simtest/identity.rs')
| -rw-r--r-- | src/simtest/identity.rs | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/src/simtest/identity.rs b/src/simtest/identity.rs index ec5d665..b789bda 100644 --- a/src/simtest/identity.rs +++ b/src/simtest/identity.rs @@ -15,7 +15,7 @@ use crate::swarm::members; use crate::transport::identity::{WHO_LABEL, signed}; use crate::transport::sim::SimNet; use crate::transport::{ - Destination, HeadsSummary, IdentityProof, Keepalive, ParsedMessage, Transport, + Destination, HeadsSummary, IdentityProof, ParsedMessage, Status, Transport, }; const SOON: Duration = Duration::from_secs(20); @@ -97,8 +97,8 @@ async fn members_find_each_other_through_the_member_list() { } } -fn ping(node: &AppState) -> ParsedMessage { - ParsedMessage::Ping(Keepalive { +fn status(node: &AppState) -> ParsedMessage { + ParsedMessage::Status(Status { heads: HeadsSummary::of(Vec::new()), epoch: node.local_epoch(), epoch_seq: 0, @@ -129,7 +129,7 @@ async fn a_proof_holds_only_at_its_address() { who(&ghost, "sim:ghost", "sim:b"), ] { sim.net.inject("ghost", "a", &forged).await.unwrap(); - sim.net.inject("ghost", "a", &ping(&a)).await.unwrap(); + sim.net.inject("ghost", "a", &status(&a)).await.unwrap(); assert!(a.get_peer_state(&ghost.id()).await.is_none()); } let counts = a.transport.stats().identity.unwrap().counts; @@ -140,7 +140,7 @@ async fn a_proof_holds_only_at_its_address() { .inject("ghost", "a", &who(&ghost, "sim:ghost", "sim:a")) .await .unwrap(); - sim.net.inject("ghost", "a", &ping(&a)).await.unwrap(); + sim.net.inject("ghost", "a", &status(&a)).await.unwrap(); assert!(a.get_peer_state(&ghost.id()).await.is_some()); // Known by its node ID, not by its address. assert!(a.get_peer_state("ghost").await.is_none()); |