Basic console commands in cedserver

Server/Application.cs

@@ -5,6 +5,7 @@ namespace CentrED.Server;
 
 public class Application
 {
+    private static CEDServer _cedServer;
     public static void Main(string[] args)
     {
         var assemblyName = Assembly.GetExecutingAssembly().GetName();
@@ -16,9 +17,14 @@ public static void Main(string[] args)
         try
         {
             var config = ConfigRoot.Init(args);
-            var server = new CEDServer(config);
-            AppDomain.CurrentDomain.ProcessExit += (_, _) => server.Save();
-            server.Run();
+            _cedServer = new CEDServer(config);
+            AppDomain.CurrentDomain.ProcessExit += (_, _) => _cedServer.Save();
+            new Thread(HandleConsoleInput)
+            {
+                IsBackground = true,
+                Name = "Console Input"
+            }.Start();
+            _cedServer.Run();
         }
         catch (Exception e)
         {
@@ -36,4 +42,27 @@ public static string GetCurrentExecutable()
     {
         return AppDomain.CurrentDomain.FriendlyName;
     }
+
+    public static async void HandleConsoleInput()
+    {
+        while (true)
+        {
+            string input;
+            try
+            {
+                input = Console.ReadLine()?.Trim();
+            }
+            catch(Exception e)
+            {
+                Console.WriteLine("Console input error!");
+                Console.WriteLine(e);
+                return;
+            }
+            if (string.IsNullOrEmpty(input))
+            {
+                continue;
+            }
+            _cedServer.PushCommand(input);
+        }
+    }
 }

Server/CEDServer.cs

@@ -21,6 +21,8 @@ public class CEDServer : ILogging, IDisposable
     private readonly ConcurrentQueue<NetState<CEDServer>> _connectedQueue = new();
     private readonly ConcurrentQueue<NetState<CEDServer>> _toDispose = new();
     private readonly ConcurrentQueue<NetState<CEDServer>> _flushPending = new();
+
+    private readonly ConcurrentQueue<string> _commandQueue = new();
 
     public DateTime StartTime = DateTime.Now;
     private DateTime _lastFlush = DateTime.Now;
@@ -170,6 +172,7 @@ public void Run()
 
                 AutoSave();
                 AutoBackup();
+                ProcessCommands();
 
                 Thread.Sleep(1);
             } while (!Quit);
@@ -289,14 +292,56 @@ private void Backup()
                     Directory.Move(backupDir, $"{Config.AutoBackup.Directory}/Backup{i + 1}");
         }
         backupDir = $"{Config.AutoBackup.Directory}/Backup1";
-        Directory.CreateDirectory(backupDir);
 
         Landscape.Backup(backupDir);
 
         Send(new ServerStatePacket(ServerState.Running));
         LogInfo("Automatic backup finished.");
     }
 
+    public void PushCommand(string command)
+    {
+        _commandQueue.Enqueue(command);
+    }
+
+    private void ProcessCommands()
+    {
+        while (_commandQueue.TryDequeue(out var command))
+        {
+            try
+            {
+                var parts = command.Split(' ', 2);
+                switch (parts)
+                {
+                    case ["save"]:
+                        Console.Write("Saving...");
+                        Landscape.Flush();
+                        Console.WriteLine("Done");
+                        break;
+                    case ["save", string dir]:
+                        Console.Write($"Saving to {dir}...");
+                        Landscape.Backup(dir);
+                        Console.WriteLine("Done");
+                        break;
+                    default: PrintHelp(); break;
+                }
+                ;
+            }
+            catch (Exception e)
+            {
+                LogError($"Error processing command: {command}");
+                LogError(e.ToString());
+            }
+        }
+    }
+
+    private void PrintHelp()
+    {
+        Console.WriteLine("Supported commands:");
+        Console.WriteLine("save");
+        Console.WriteLine("save <dir>"); 
+    }
+
     public void Dispose()
     {
         Listener.Dispose();

Server/Map/ServerLandscape.cs

@@ -273,6 +273,7 @@ public void Flush()
 
     public void Backup(string backupDir)
     {
+        Directory.CreateDirectory(backupDir);
         foreach (var fs in new[] { _map, _staidx, _statics })
         {
             FileInfo fi = new FileInfo(fs.Name);