Add some other stuff for work

CommonLibraryTests/Communication.cs

@@ -7,6 +7,10 @@
  */
 
 using System.IO;
+using System.Net;
+using System.Net.Sockets;
+using System.Text;
+using System.Threading;
 using System.Threading.Tasks;
 using Communication;
 using Microsoft.VisualStudio.TestTools.UnitTesting;
@@ -36,12 +40,52 @@ public async Task CommunicationsAsync()
             File.Delete(path);
         }
 
-        //[TestMethod]
-        //public async Task Untested()
-        //{
-        //    //var str = await HttpClientManager.CallSoapServiceAsync();
+        /// <summary>
+        /// Listeners the should respond with pong when pinged.
+        /// </summary>
+        [TestMethod]
+        public async Task ListenerShouldRespondWithPongWhenPinged()
+        {
+            // Arrange
+            const int port = 12345; // Example port
+            var listener = new Listener(port);
+            var cancellationTokenSource = new CancellationTokenSource();
+
+            // Start the listener in a separate task to simulate real-world usage
+            var listenerTask = Task.Run(() => listener.StartListening(cancellationTokenSource.Token));
+
+            // Wait for a brief moment to ensure the server is up and listening
+            await Task.Delay(1000);
+
+            // Act - Connect to the server and send a message
+            using (var client = new TcpClient("localhost", port))
+            {
+                var stream = client.GetStream();
+                byte[] requestMessage = Encoding.ASCII.GetBytes("PING");
+                stream.Write(requestMessage, 0, requestMessage.Length);
 
-        //    //Trace.WriteLine(str);
-        //}
+                // Read the response
+                byte[] buffer = new byte[1024];
+                int bytesRead = stream.Read(buffer, 0, buffer.Length);
+                string response = Encoding.ASCII.GetString(buffer, 0, bytesRead);
+
+                // Assert - Verify the response is "PONG"
+                Assert.AreEqual("PONG", response, "Expected response was not received.");
+            }
+
+            // Stop the listener after the test
+            cancellationTokenSource.Cancel();
+            await listenerTask;  // Ensure listener has finished
+
+            listener.StopListening();
+        }
     }
+
+    //[TestMethod]
+    //public async Task Untested()
+    //{
+    //    //var str = await HttpClientManager.CallSoapServiceAsync();
+
+    //    //Trace.WriteLine(str);
+    //}
 }

Communication/INetCom.cs

@@ -56,5 +56,12 @@ Task SaveFile(string filePath, IEnumerable<string> urls, IProgress<int> progress
         /// <returns>An HttpResponseMessage containing the response details.</returns>
         Task<string> SendMessageAsync(string url, string method, string body = null,
             string contentType = "application/json");
+
+        /// <summary>
+        /// Listeners the specified port.
+        /// </summary>
+        /// <param name="port">The port.</param>
+        /// <returns>Reference to the listener</returns>
+        Listener Listener(int port);
     }
 }

Communication/Listener.cs

@@ -0,0 +1,72 @@
+using System;
+using System.Net;
+using System.Net.Sockets;
+using System.Text;
+using System.Threading;
+
+namespace Communication
+{
+    public class Listener
+    {
+        private System.Net.Sockets.TcpListener tcpListener;
+        private bool isRunning;
+        private readonly int _port = 12345;
+
+        public Listener(int port)
+        {
+            _port = port;
+            tcpListener = new System.Net.Sockets.TcpListener(IPAddress.Any, port);
+        }
+
+        public void StartListening(CancellationToken cancellationToken)
+        {
+            isRunning = true;
+            tcpListener.Start();
+            Console.WriteLine($"Listening on port {_port}...");
+
+            while (isRunning)
+            {
+                if (cancellationToken.IsCancellationRequested)
+                {
+                    StopListening();
+                    return;
+                }
+
+                try
+                {
+                    if (tcpListener.Pending()) // Non-blocking accept
+                    {
+                        var client = tcpListener.AcceptTcpClient();
+                        ThreadPool.QueueUserWorkItem(HandleClient, client);
+                    }
+                }
+                catch (Exception ex)
+                {
+                    Console.WriteLine($"Error accepting connection: {ex.Message}");
+                }
+            }
+        }
+
+        public void StopListening()
+        {
+            isRunning = false;
+            tcpListener.Stop();
+            Console.WriteLine("Server stopped.");
+        }
+
+        private static void HandleClient(object obj)
+        {
+            var client = (TcpClient)obj;
+            var stream = client.GetStream();
+
+            // Respond with a simple message (acting as the "ping response")
+            string response = "PONG";
+            byte[] buffer = Encoding.ASCII.GetBytes(response);
+            stream.Write(buffer, 0, buffer.Length);
+
+            // Close the connection
+            client.Close();
+            Console.WriteLine("Responded to a ping.");
+        }
+    }
+}

Communication/NetCom.cs

@@ -76,5 +76,18 @@ public async Task<string> SendMessageAsync(string url, string method, string bod
                 throw new Exception("An error occurred while sending the HTTP request.", ex);
             }
         }
+
+        /// <inheritdoc />
+        /// <summary>
+        /// Listeners the specified port.
+        /// </summary>
+        /// <param name="port">The port.</param>
+        /// <returns>
+        /// Reference to the listener
+        /// </returns>
+        public Listener Listener(int port)
+        {
+            return new(port);
+        }
     }
 }