Function test_ping_timeout

crates/buttplug_tests/tests/test_server.rs:172–211

()

#[tokio::test]
async fn test_ping_timeout() {
  let server = ButtplugServerBuilder::default()
    .max_ping_time(100)
    .finish()
    .expect("Test, assuming infallible.");
  let recv = server.event_stream();
  pin_mut!(recv);
  let msg = RequestServerInfoV4::new(
    "Test Client",
    BUTTPLUG_CURRENT_API_MAJOR_VERSION,
    BUTTPLUG_CURRENT_API_MINOR_VERSION,
  );
  sleep(Duration::from_millis(150)).await;
  let reply = server
    .parse_checked_message(ButtplugCheckedClientMessageV4::RequestServerInfo(msg))
    .await;
  assert!(
    reply.is_ok(),
    "ping timer shouldn't start until handshake finished. {:?}",
    reply
  );
  sleep(Duration::from_millis(300)).await;
  let pingmsg = PingV0::default();
  let result = server
    .parse_checked_message(ButtplugCheckedClientMessageV4::Ping(pingmsg))
    .await;
  let err = result.unwrap_err();
  if !matches!(err.original_error(), ButtplugError::ButtplugPingError(_)) {
    panic!("Got wrong type of error back!");
  }
  // Check that we got an event back about the ping out.
  let msg = recv.next().await.expect("Test, assuming infallible.");
  if let ButtplugServerMessageVariant::V4(ButtplugServerMessageV4::Error(e)) = msg {
    if ErrorCode::ErrorPing != e.error_code() {
      panic!("Didn't get a ping error");
    }
  } else {
    panic!("Didn't get an error message back");
  }
}

#[tokio::test]
async fn test_device_stop_on_ping_timeout() {