send tcp pings via packet sender

Co-authored-by: Eskil Queseth <eskilq@kth.se>

1 files changed, 3 insertions, 3 deletions

diff --git a/mumd/src/network/tcp.rs b/mumd/src/network/tcp.rs
index 3fc36a3..f86447b 100644
--- a/mumd/src/network/tcp.rs
+++ b/mumd/src/network/tcp.rs
@@ -82,14 +82,14 @@ async fn authenticate(sink: Arc<Mutex<TcpSender>>, username: String) {
     sink.lock().unwrap().send(msg.into()).await.unwrap();
 }
 
-//TODO move somewhere else (main?) and send through packet_sender
-async fn send_pings(sink: Arc<Mutex<TcpSender>>, delay_seconds: u64) {
+async fn send_pings(packet_sender: mpsc::UnboundedSender<ControlPacket<Serverbound>>,
+                    delay_seconds: u64) {
     let mut interval = time::interval(Duration::from_secs(delay_seconds));
     loop {
         interval.tick().await;
         trace!("Sending ping");
         let msg = msgs::Ping::new();
-        sink.lock().unwrap().send(msg.into()).await.unwrap();
+        packet_sender.send(msg.into()).unwrap();
     }
 }