First Server Test | Next Update: Change Commands to Attributes

DX86/DX86.cs

@@ -155,6 +155,7 @@ namespace DX86
             catch (Exception ex)
             {
                 ms.Error("[DX86] Error handling client: " + ex.Message);
+                ms.Debug("[DX86] Stack Trace: " + ex.StackTrace);
             }
             finally
             {

DX86/Modules/MessageSender.cs

@@ -37,6 +37,11 @@ public class MessageSender
     }
     
     
+    public async void Debug(string message)
+    {
+        Console.ForegroundColor = ConsoleColor.Green;
+        this.Send($"[{DateTime.Now}] [DEBUG] {message}");
+    }
     public async void Log(string message)
     {
         Console.ForegroundColor = ConsoleColor.Gray;
@@ -76,6 +81,8 @@ public class MessageSender
         int i = 0;
         foreach (var s in messageHistory)
         {
+            if (s.Contains("[DEBUG]"))
+                Console.ForegroundColor = ConsoleColor.Green;
             if (s.Contains("[INFO ]"))
                 Console.ForegroundColor = ConsoleColor.Gray;
             if (s.Contains("[WARN ]"))

DX86/TcpServer.cs

@@ -12,6 +12,7 @@ public abstract class TcpServer
     protected MessageSender ms;
     private DX86 dx86;
     public List<string> optionsList;
+    public Dictionary<TcpClient, string> LoggedInClients { get; }
 
     
     public TcpServer(string address, int port, MessageSender ms)
@@ -28,6 +29,7 @@ public abstract class TcpServer
     }
 
 
+
     private async Task RunServer()
     {
         ms.Log("[DX86] Starting server.");

Library/Server.cs

@@ -69,8 +69,8 @@ public class Server
         // Create the JSON request
         var request = new JsonRequest
         {
-            Id = requestId,
+            cmd = command,
-            Command = command
+            cid = requestId
         };
 
         string jsonString = JsonSerializer.Serialize(request);
@@ -92,8 +92,8 @@ public class Server
 
     private class JsonRequest
     {
-        public string Id { get; set; }
+        public string cmd { get; set; }
-        public string Command { get; set; }
+        public string cid { get; set; }
     }
 
     private class JsonResponse
@@ -119,9 +119,9 @@ public class Server
 
         // Implement logic to get a worker by ID or code
         if (id != null)
-            commandResult = ExecuteCommandAsync(".get worker byid " + id).Result;
+            commandResult = ExecuteCommandAsync("get worker byid " + id).Result;
         else
-            commandResult = ExecuteCommandAsync(".get worker bycode " + id).Result;
+            commandResult = ExecuteCommandAsync("get worker bycode " + id).Result;
         
         // Deserialize the command result to an Employee object
         try
@@ -140,7 +140,7 @@ public class Server
     public Task<string> Login(string username, string password)
     {
         // Implement login logic
-        var commandResult = ExecuteCommandAsync(".login " + username + " " + password).Result;
+        var commandResult = ExecuteCommandAsync("login " + username + " " + password).Result;
         if (commandResult == "success")
         {
             return Task.FromResult("Success");
@@ -151,7 +151,7 @@ public class Server
     public Task<string> Logout()
     {
         // Implement logout logic
-        var commandResult = ExecuteCommandAsync(".logout").Result;
+        var commandResult = ExecuteCommandAsync("logout").Result;
         if (commandResult == "success")
         {
             return Task.FromResult("Success");
@@ -161,7 +161,7 @@ public class Server
 
     public Task<string> clockIn(Employee employee)
     {
-        var commandResult = ExecuteCommandAsync(".clockin ").Result;
+        var commandResult = ExecuteCommandAsync("clock in").Result;
         if (commandResult == "success")
         {
             return Task.FromResult("Success");
@@ -170,7 +170,7 @@ public class Server
     }
     public Task<string> clockOut(Employee employee)
     {
-        var commandResult = ExecuteCommandAsync(".clockout ").Result;
+        var commandResult = ExecuteCommandAsync("clock out").Result;
         if (commandResult == "success")
         {
             return Task.FromResult("Success");
@@ -182,7 +182,7 @@ public class Server
     }
     public Task<string> clockBreak(Employee employee)
     {
-        var commandResult = ExecuteCommandAsync(".clockbreak").Result;
+        var commandResult = ExecuteCommandAsync("clock break").Result;
         if (commandResult == "success")
         {
             return Task.FromResult("Success");

Server/BackendServer.cs

@@ -1,8 +1,16 @@
 using System.Net.Sockets;
+using System.Text.Json;
 using DX86.Modules;
+using MySqlX.XDevAPI;
 
 namespace Server;
 
+class JsonMessage
+{
+    public string cmd { get; set; }
+    public string cid { get; set; }
+}
+
 public class BackendServer : DX86.TcpServer
 {
     CommandManager commandManager;
@@ -31,24 +39,42 @@ public class BackendServer : DX86.TcpServer
     protected override void MessageReceivedEvent(TcpClient client, string message)
     {
         ms.Log("[BACKENDSERVER] Message received from client: " + message);
-        if (message.StartsWith("."))
+        // format json recieved
+        JsonMessage? jsonMessage;
+        if (message.StartsWith("{") && message.EndsWith("}"))
         {
-            handleCommand(cmd: message, client: client);
+            try
-            
+            {
+                jsonMessage = JsonSerializer.Deserialize<JsonMessage>(message);
+                if (jsonMessage != null)
+                {
+                    ms.Log("[BACKENDSERVER] JSON Message received: cmd=" + jsonMessage.cmd + ", cid=" + jsonMessage.cid);
+                    handleCommand(cmd: jsonMessage.cmd, cid: jsonMessage.cid, client: client);
                 }
             }
+            catch (JsonException ex)
+            {
+                ms.Log("[BACKENDSERVER] Error parsing JSON: " + ex.Message);
+            }
+        }
+        
+    }
 
     protected override void ClientDisconnectEvent(TcpClient client)
     {
         throw new NotImplementedException();
     }
 
-    private void handleCommand(string cmd, TcpClient client)
+    private void handleCommand(string cmd, string cid, TcpClient client)
     {
         string[] args = cmd.Split(' ');
-        string command = args[0].Substring(1); // Remove the leading dot
+        string command = args[0]; // Remove the leading dot
         string[] commandArgs = args.Skip(1).ToArray(); // Get the arguments after the command
+        foreach (var commandArg in commandArgs)
+        {
+            ms.Debug("[BACKENDSERVER] Command argument: " + commandArg);
+        }
         
-        commandManager.ExecuteCommand(executor:command, args:commandArgs, client:client, clientSocket:this);
+        commandManager.ExecuteCommand(executor:command, args:commandArgs, client:client, clientSocket:this, cid: cid);
     }
 }

Server/CommandManager.cs

@@ -1,5 +1,6 @@
 using System.Net.Sockets;
 using System.Reflection;
+using System.Text.Json;
 using DX86;
 using Server.Commands;
 
@@ -32,15 +33,22 @@ public class CommandManager
         }
     }
 
-    public void ExecuteCommand(string executor, TcpClient? client = null, TcpServer? clientSocket = null, params string[] args)
+    public void ExecuteCommand(string executor, TcpClient? client = null, TcpServer? clientSocket = null, string cid = "", params string[] args)
     {
         if (_commands.TryGetValue(executor, out var command))
         {
-            command.Exec(args:args, client:client, clientSocket:clientSocket);
+            JsonMessage returnMessage = new JsonMessage();
+            returnMessage.cid = cid;
+            returnMessage.cmd = command.Exec(args:args, client:client, clientSocket:clientSocket);
+
+            string sendClientMessage = JsonSerializer.Serialize(returnMessage);
+            
+            clientSocket.SendMessageAsync(client:client, message:sendClientMessage+"\n");
+            //clientSocket.SendMessageAsync(client:client, message:command.Exec(args:args, client:client, clientSocket:clientSocket));
         }
         else
         {
-            Console.WriteLine($"Command '{executor}' not found.");
+            Program.messageSender.Log($"[COMMANDMANAGER] Command '{executor}' not found.");
         }
     }
 }

Server/Commands/ClockCommand.cs

@@ -0,0 +1,6 @@
+namespace Server.Commands;
+
+public class ClockCommand
+{
+    
+}

Server/Commands/GetCommand.cs

@@ -0,0 +1,6 @@
+namespace Server.Commands;
+
+public class GetCommand
+{
+    
+}

Server/Commands/HelpCommand.cs

@@ -6,19 +6,21 @@ namespace Server.Commands;
 public class HelpCommand : ICommand
 {
     public string Executor { get; }
+
     public HelpCommand()
     {
         Executor = "help";
     }
-    public void Exec(string[] args, TcpClient? client = null, TcpServer? clientSocket = null)
+    public string Exec(string[] args, TcpClient? client = null, TcpServer? clientSocket = null)
     {
-        clientSocket.SendMessageAsync(client, "" +
+        return 
             "Available commands:\n" +
             "1. help - Show this help message\n" +
             "2. exit - Exit the server\n" +
             "3. user - User management\n" +
             "4. settings - Server settings\n" +
             "5. start - Start the server\n" +
-            "6. stop - Stop the server\n");
+            "6. stop - Stop the server\n"
+            ;
     }
 }

Server/Commands/ICommand.cs

@@ -6,5 +6,5 @@ namespace Server.Commands;
 public interface ICommand
 {
     string Executor { get; }
-    public void Exec(string[] args, TcpClient? client = null, TcpServer? clientSocket = null);
+    public string Exec(string[] args, TcpClient? client, TcpServer? clientSocket);
 }

Server/Commands/LoginCommand.cs

@@ -0,0 +1,34 @@
+using System.Net.Sockets;
+using DX86;
+using MySqlX.XDevAPI;
+
+namespace Server.Commands;
+
+public class LoginCommand : ICommand
+{
+    public string Executor { get; }
+    
+    public LoginCommand()
+    {
+        Executor = "login";
+    }
+    public string Exec(string[] args, TcpClient? client, TcpServer? clientSocket)
+    {
+
+        if (args[0] == "test" && args[1] == "test")
+        {
+            if (client != null)
+            {
+                //clientSocket?.SendMessageAsync(client, "Login successful");
+                clientSocket?.LoggedInClients.Add(client, "test");
+                return "Login successful";
+            }
+        }
+        else
+        {
+            if (client != null) return "Invalid credentials";
+        }
+
+        return "No client provided or invalid credentials";
+    }
+}

Server/Commands/LogoutCommand.cs

@@ -0,0 +1,30 @@
+using System.Net.Sockets;
+using DX86;
+
+namespace Server.Commands;
+
+public class LogoutCommand : ICommand
+{
+    public string Executor { get; }
+    public LogoutCommand()
+    {
+        Executor = "logout";
+    }
+    public string Exec(string[] args, TcpClient? client = null, TcpServer? clientSocket = null)
+    {
+        if (clientSocket == null && client == null)
+            return "Please provide a valid client or clientSocket.";
+        
+        if (client != null && clientSocket != null && clientSocket.LoggedInClients.ContainsKey(client))
+        {
+            clientSocket.LoggedInClients.Remove(client);
+            //clientSocket.SendMessageAsync(client, "Success");
+            return "Logout successful.";
+        }
+        else
+        {
+            //clientSocket?.SendMessageAsync(client, "Logout failed. You are not logged in.");
+            return "Logout failed. You are not logged in.";
+        }
+    }
+}