From 2721021f7b20831388d9ea7b3ea0797e3efdfdac Mon Sep 17 00:00:00 2001
From: Sofia <sofia@teascade.net>
Date: Thu, 16 Jul 2026 16:46:24 +0300
Subject: [PATCH] Fix reliable messages, again

---
 src/connections.rs | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/src/connections.rs b/src/connections.rs
index 8c56cbf..688b4c3 100644
--- a/src/connections.rs
+++ b/src/connections.rs
@@ -333,13 +333,13 @@ impl<T: std::fmt::Debug + Clone + Serialize + DeserializeOwned + Send + Sync + '
                         // already seen
                         println!("{:?}", conn.reliable_queue);
                         println!("{:?}", msgs.ack);
-                        conn.reliable_queue.retain(|v| v.message_id >= msgs.ack);
+                        conn.reliable_queue.retain(|v| v.message_id > msgs.ack);
 
                         // Process all messages that have not been previously seen
                         // before, that is to say the connection's ack value is
                         // lower than the message's id
                         for reliable_msg in &msgs.reliable {
-                            if reliable_msg.message_id >= conn.ack {
+                            if reliable_msg.message_id > conn.ack {
                                 messages.push(PeerMessage::Message(
                                     conn.clone(),
                                     reliable_msg.message.clone(),
@@ -531,7 +531,7 @@ impl<T: Clone> Connection<T> {
             last_recv_close: Instant::now(),
             closing_since: Instant::now(),
 
-            message_counter: 0,
+            message_counter: 1,
             ack: 0,
             reliable_queue: Vec::new(),
             last_msg_send: Instant::now() - Duration::from_hours(1),