feat(MessageEventArgs): detect legacy unicast messages

Author: richardschneider

Spike/Program.cs

@@ -51,13 +51,14 @@ static void Main(string[] args)
                 }
             };
 
+#if false
             var sd = new ServiceDiscovery(mdns);
             sd.Advertise(new ServiceProfile("x1", "_xservice._tcp", 5011));
             sd.Advertise(new ServiceProfile("x2", "_xservice._tcp", 666));
             var z1 = new ServiceProfile("z1", "_zservice._udp", 5012);
             z1.AddProperty("foo", "bar");
             sd.Advertise(z1);
-
+#endif
             mdns.Start();
             Console.ReadKey();
         }

src/MessageEventArgs.cs

@@ -24,6 +24,14 @@ public class MessageEventArgs : EventArgs
         ///   The endpoint from the message was received.
         /// </value>
         public IPEndPoint RemoteEndPoint { get; set; }
+
+        /// <summary>
+        ///   Determines if the sender is using legacy unicast DNS.
+        /// </summary>
+        /// <value>
+        ///   <b>false</b> if the sender is using port 5353.
+        /// </value>
+        public bool IsLegacyUnicast => RemoteEndPoint.Port != MulticastClient.MulticastPort;
     }
 }
 

src/MulticastClient.cs

@@ -19,7 +19,14 @@ class MulticastClient : IDisposable
     {
         static readonly ILog log = LogManager.GetLogger(typeof(MulticastClient));
 
-        const int MulticastPort = 5353;
+        /// <summary>
+        ///   The port number assigned to Multicast DNS.
+        /// </summary>
+        /// <value>
+        ///   Port number 5353.
+        /// </value>
+        public static readonly int MulticastPort = 5353;
+
         static readonly IPAddress MulticastAddressIp4 = IPAddress.Parse("224.0.0.251");
         static readonly IPAddress MulticastAddressIp6 = IPAddress.Parse("FF02::FB");
         static readonly IPEndPoint MdnsEndpointIp6 = new IPEndPoint(MulticastAddressIp6, MulticastPort);

test/MulticastServiceTest.cs

@@ -40,8 +40,12 @@ public void SendQuery()
             mdns.NetworkInterfaceDiscovered += (s, e) => ready.Set();
             mdns.QueryReceived += (s, e) =>
             {
-                msg = e.Message;
-                done.Set();
+                if ("some-service.local" == e.Message.Questions.First().Name)
+                {
+                    msg = e.Message;
+                    Assert.IsFalse(e.IsLegacyUnicast);
+                    done.Set();
+                }
             };
             try
             {