aboutsummaryrefslogtreecommitdiff
path: root/azalea-client/src/ping.rs
diff options
context:
space:
mode:
authormat <github@matdoes.dev>2021-12-15 23:10:55 -0600
committermat <github@matdoes.dev>2021-12-15 23:10:55 -0600
commit9642558f8f8d983a7087f15d68be8cf07a85f0c2 (patch)
tree5f0a967f005cd5db510a13ab290c8ad6669b25aa /azalea-client/src/ping.rs
parent72aefe871ca4983431b1a0b707b472e73ffea836 (diff)
downloadazalea-drasl-9642558f8f8d983a7087f15d68be8cf07a85f0c2.tar.xz
azalea
Diffstat (limited to 'azalea-client/src/ping.rs')
-rw-r--r--azalea-client/src/ping.rs44
1 files changed, 44 insertions, 0 deletions
diff --git a/azalea-client/src/ping.rs b/azalea-client/src/ping.rs
new file mode 100644
index 00000000..87ccdf66
--- /dev/null
+++ b/azalea-client/src/ping.rs
@@ -0,0 +1,44 @@
+///! Ping Minecraft servers.
+use azalea_protocol::{
+ connect::HandshakeConnection,
+ packets::{
+ handshake::client_intention_packet::ClientIntentionPacket,
+ status::{
+ clientbound_status_response_packet::ClientboundStatusResponsePacket,
+ serverbound_status_request_packet::ServerboundStatusRequestPacket, StatusPacket,
+ },
+ ConnectionProtocol, PROTOCOL_VERSION,
+ },
+ resolver, ServerAddress,
+};
+
+pub async fn ping_server(
+ address: &ServerAddress,
+) -> Result<ClientboundStatusResponsePacket, String> {
+ let resolved_address = resolver::resolve_address(address).await?;
+
+ let mut conn = HandshakeConnection::new(&resolved_address).await?;
+
+ // send the client intention packet and switch to the status state
+ conn.write(
+ ClientIntentionPacket {
+ protocol_version: PROTOCOL_VERSION,
+ hostname: address.host.clone(),
+ port: address.port,
+ intention: ConnectionProtocol::Status,
+ }
+ .get(),
+ )
+ .await;
+ let mut conn = conn.status();
+
+ // send the empty status request packet
+ conn.write(ServerboundStatusRequestPacket {}.get()).await;
+
+ let packet = conn.read().await.unwrap();
+
+ match packet {
+ StatusPacket::ClientboundStatusResponsePacket(p) => Ok(*p),
+ _ => Err("Invalid packet type".to_string()),
+ }
+}