Send handshake successfully to a given server

Author: Aquerr

MCQuery-Lib/Connection.cs

@@ -1,21 +1,135 @@
-using System.Net.Sockets;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Net;
+using System.Net.Sockets;
+using System.Text;
 
-namespace MCQuery_Lib
+namespace MCQuery
 {
     public class Connection
     {
-        public Connection(string address, string port)
-        {
-            TcpClient client = new TcpClient(address, int.Parse(port));
+        private byte[] Magic = { 0xFE, 0xFD };
+        private byte Handshake = 0x09;
+        private byte Stat = 0x00;
+        private byte[] SessionID = { 0x01, 0x01, 0x01, 0x01 };
 
+        public Connection(string address, int port)
+        {
             try
             {
-             //   client.Connect();
+                string udpResponse = sendByUdp(address, port);
+
+                if (udpResponse.Equals(String.Empty))
+                {
+                    string tcpResponse = sendByTcp(address, port);
+
+                    if (tcpResponse.Equals(String.Empty)) throw new NotImplementedException();
+                }
+                else
+                {
+                    // Uses the IPEndPoint object to determine which of these two hosts responded.
+                    Console.WriteLine("This is the message you received " +
+                                                 udpResponse.ToString());
+                    Console.WriteLine("This message was sent from " +
+                                                address +
+                                                " on their port number " +
+                                                port.ToString());
+                }
             }
             catch (SocketException socketException)
             {
-                //TODO:Do something with exception...
+                throw new SocketException();
+            }
+        }
+
+        public Server getServer()
+        {
+            //TODO: Return server object with fetched data from the request.
+            return new Server("dummy", true);
+        }
+
+        public string sendByUdp(string address, int port)
+        {
+            try
+            {
+                //Check if address is a domain name.
+                if (isDomainAddress(address))
+                {
+                    address = getIpFromDomain(address);
+                }
+
+                UdpClient udpClient = new UdpClient();
+
+                udpClient.Connect(address, port);
+
+                List<byte> message = new List<byte>();
+                message.AddRange(Magic);
+                message.Add(Handshake);
+                message.Add(Stat);
+                message.AddRange(SessionID);
+
+                Byte[] handshakeMessage = message.ToArray().ToArray();
+
+                udpClient.Send(handshakeMessage, handshakeMessage.Length);
+
+                //IPEndPoint object will allow us to read datagrams sent from any source.
+                IPEndPoint RemoteIpEndPoint = new IPEndPoint(IPAddress.Parse(address), port);
+
+                // Blocks until a message returns on this socket from a remote host.
+                Byte[] receiveBytes = udpClient.Receive(ref RemoteIpEndPoint);
+                string returnData = Encoding.ASCII.GetString(receiveBytes);
+
+                udpClient.Close();
+
+                if (returnData.Equals(String.Empty))
+                {
+                    return String.Empty;
+                }
+                else
+                {
+                    return returnData;
+                }
+            }
+            catch (SocketException exception)
+            {
+                throw new SocketException();
+            }
+        }
+
+        private string getIpFromDomain(string address)
+        {
+            IPAddress[] addresses = Dns.GetHostAddresses(address);
+
+            return addresses[0].AddressFamily.ToString();
+        }
+
+        private bool isDomainAddress(string address)
+        {
+            try
+            {
+                IPHostEntry hostEntry = Dns.GetHostEntry(address);
+
+                if (hostEntry.HostName == address)
+                {
+                    return true;
+                }
+                else
+                {
+                    return false;
+                }
+            }
+            catch (Exception exception)
+            {
+                Console.WriteLine(exception.Message);
+                throw new SocketException();
             }
         }
+
+        public string sendByTcp(string address, int port)
+        {
+            //TODO: Implement sending packet by TCP.
+            return String.Empty;
+        }
     }
 }

MCQuery-Lib/MCQuery-Lib.csproj MCQuery-Lib/MCQuery.csproj

@@ -4,7 +4,7 @@
 using System.Text;
 using System.Threading.Tasks;
 
-namespace MCQuery_Lib
+namespace MCQuery
 {
     public class Request
     {

MCQuery-Lib/Request.cs

@@ -4,7 +4,7 @@
 using System.Text;
 using System.Threading.Tasks;
 
-namespace MCQuery_Lib
+namespace MCQuery
 {
     public class Server
     {

MCQuery-Lib/Server.cs

@@ -3,9 +3,9 @@ Microsoft Visual Studio Solution File, Format Version 12.00
 # Visual Studio 15
 VisualStudioVersion = 15.0.27130.2024
 MinimumVisualStudioVersion = 10.0.40219.1
-Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "MCQuery-Console", "MCQuery\MCQuery-Console.csproj", "{D2B7C12E-E5CC-4517-B07A-AE9AE9A0DDAD}"
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "MCQuery-Console", "MCQuery\MCQuery-Console.csproj", "{D2B7C12E-E5CC-4517-B07A-AE9AE9A0DDAD}"
 EndProject
-Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "MCQuery-Lib", "MCQuery-Lib\MCQuery-Lib.csproj", "{B439EF43-29DE-4490-9542-83111E9CF88B}"
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "MCQuery", "MCQuery-Lib\MCQuery.csproj", "{B439EF43-29DE-4490-9542-83111E9CF88B}"
 EndProject
 Global
 	GlobalSection(SolutionConfigurationPlatforms) = preSolution

MCQuery.sln

@@ -6,7 +6,7 @@
   </PropertyGroup>
 
   <ItemGroup>
-    <ProjectReference Include="..\MCQuery-Lib\MCQuery-Lib.csproj" />
+    <ProjectReference Include="..\MCQuery-Lib\MCQuery.csproj" />
   </ItemGroup>
 
 </Project>

MCQuery/MCQuery-Console.csproj

@@ -1,4 +1,5 @@
-using System;
+using MCQuery;
+using System;
 
 namespace MCQuery
 {
@@ -7,6 +8,26 @@ class Program
         static void Main(string[] args)
         {
             Console.WriteLine("Hello World!");
+
+            Console.WriteLine("Server IP Address: ");
+            string ipAddress = Console.ReadLine();
+
+            Console.WriteLine("Server Port: ");
+            string portString = Console.ReadLine();
+
+            int.TryParse(portString, out int port);
+
+            if (port != 0)
+            {
+                Connection connection = new Connection(ipAddress, port); //This should give us a challenge token needed for getting data from the sever.
+            }
+            else
+            {
+                Console.WriteLine("Wrong port number!");
+            }
+
+            Console.WriteLine("\n Press any key to continue...");
+            Console.Read();
         }
     }
 }