oops

Author: Per6

RiptideNetworking/RiptideNetworking/Connection.cs

@@ -180,7 +180,7 @@ public void ResetTimeout()
         /// <returns>For reliable, queued and notify messages, the sequence ID that the message was sent with. 0 for unreliable messages.</returns>
         public ushort Send(Message message)
         {
-			if(this is TcpConnection) message.SetSendHeader(MessageHeader.Unreliable, message.Id);
+			if(this is TcpConnection && message.Header.IsUserMessage()) message.SetSendHeader(MessageHeader.Unreliable, message.Id);
 			MessageSendMode sendMode = message.SetSendHeader();
 			if(message.BytesInUse >= Message.MaxSize) throw new Exception($"Message is too large to send {message.BytesInUse} with max of {Message.MaxSize}. Consider splitting it up or increasing Message.MaxPayloadSize at the cost of either reliability or resend attempts.");
             ushort sequenceId = 0;

RiptideNetworking/RiptideNetworking/Transports/IPeer.cs

@@ -41,6 +41,16 @@ public enum MessageHeader : byte
         ClientDisconnected,
     }
 
+	/// <summary>The functions for <see cref="MessageHeader"/>.</summary>
+	public static class MessageHeaderExtensions
+	{
+		/// <summary>Wether the <see cref="MessageHeader"/> is from the user.</summary>
+		/// <param name="header"></param>
+		public static bool IsUserMessage(this MessageHeader header) {
+			return header == MessageHeader.Unreliable || header == MessageHeader.Reliable || header == MessageHeader.Queued || header == MessageHeader.Notify;
+		}
+	}
+
     /// <summary>Defines methods, properties, and events which every transport's server <i>and</i> client must implement.</summary>
     public interface IPeer
     {