flake.nix

@@ -125,7 +125,6 @@
               Group = cfg.group;
               ExecStart =
                 "${cfg.package}/bin/quiclime";
-              Restart = "on-failure";
             };
 
             environment = {

src/main.rs

@@ -16,7 +16,7 @@ use tokio::{
 };
 
 use crate::{
-    netty::{WriteExtNetty, ReadExtNetty},
+    netty::WriteExtNetty,
     proto::{ClientboundControlMessage, ServerboundControlMessage},
 };
 
@@ -279,18 +279,6 @@ async fn politely_disconnect(
                 .await?;
             connection.write_varint(buf.len() as i32).await?;
             connection.write_all(&buf).await?;
-            let packet = netty::read_packet(&mut connection).await?;
-            let mut packet = packet.as_slice();
-            let id = packet.read_varint()?;
-            if id != 1 {
-                return Err(anyhow!("Packet isn't a Ping Request(0x01), but {:#04x}", id));
-            }
-            let payload = packet.read_long()?;
-            let mut buf = Vec::with_capacity(1 + 8);
-            buf.write_varint(1).await?;
-            buf.write_u64(payload).await?;
-            connection.write_varint(buf.len() as i32).await?;
-            connection.write_all(&buf).await?;
         }
         netty::HandshakeType::Login => {
             let _ = netty::read_packet(&mut connection).await?;

src/netty.rs

@@ -39,12 +39,6 @@ pub trait ReadExtNetty: Read {
         Ok(u16::from_be_bytes(buf))
     }
 
-    fn read_long(&mut self) -> Result<u64, NettyReadError> {
-        let mut buf = [0u8; 8];
-        self.read_exact(&mut buf)?;
-        Ok(u64::from_be_bytes(buf))
-    }
-
     fn read_string(&mut self) -> Result<String, NettyReadError> {
         let len = self.read_varint()?;
         let mut buf = vec![0u8; len as usize];