Lab6 v2 server start stop

SpaceBattle.App/App.cs

@@ -0,0 +1,18 @@
+using Hwdtech;
+using SpaceBattle.Lib;
+
+public class App
+{
+    public static void Main(int[] args)
+    {
+        var NumberOfTreads = args[0];
+        new InitCommand().Execute();
+        Console.WriteLine("Запуск сервера\nСоздание и регистрация потоков...");
+        IoC.Resolve<Hwdtech.ICommand>("Game.Commands.StartServerCommand", NumberOfTreads).Execute();
+        Console.WriteLine("Потоки запущены\nДля завершения работы сервера нажмите любую клавишу");
+        Console.ReadKey();
+        Console.WriteLine("Завершение работы сервера. Закрытие потоков...");
+        IoC.Resolve<Hwdtech.ICommand>("Game.Commands.StopServerCommand");
+        Console.WriteLine("Все потоки закрыты. Завершение работы программы");
+    }
+}

SpaceBattle.Lib.Tests/SpaceBattle.Lib.Tests.csproj

@@ -31,7 +31,6 @@
 
   <ItemGroup>
     <ProjectReference Include="..\SpaceBattle.Lib\SpaceBattle.Lib.csproj" />
-    <ProjectReference Include="..\WebHttp\WebHttp.csproj" />
   </ItemGroup>
 
 </Project>

SpaceBattle.Lib.Tests/StartServerTest.cs

@@ -0,0 +1,28 @@
+using Hwdtech;
+using Hwdtech.Ioc;
+using Moq;
+
+namespace SpaceBattle.Lib.Test;
+
+public class StartServerTest
+{
+    public StartServerTest()
+    {
+        new InitScopeBasedIoCImplementationCommand().Execute();
+        IoC.Resolve<Hwdtech.ICommand>("Scopes.Current.Set", IoC.Resolve<object>("Scopes.New", IoC.Resolve<object>("Scopes.Root"))).Execute();
+        var a = new InitCommand();
+        a.Execute();
+    }
+    [Fact]
+    public void Start_Server_Test()
+    {
+        var startCommand = new Mock<ICommand>();
+        startCommand.Setup(cmd => cmd.Execute()).Verifiable();
+        IoC.Resolve<Hwdtech.ICommand>("IoC.Register", "Game.Commands.CreateAndStartThread", (object[] args) =>
+        {
+            return startCommand.Object;
+        }).Execute();
+        IoC.Resolve<ICommand>("Game.Commands.StartServerCommand", 5).Execute();
+        startCommand.Verify(cmd => cmd.Execute(), Times.Exactly(5));
+    }
+}

SpaceBattle.Lib.Tests/StopServerTest.cs

@@ -0,0 +1,70 @@
+using Hwdtech;
+using Hwdtech.Ioc;
+using Moq;
+
+namespace SpaceBattle.Lib.Test;
+
+public class StopServerTest
+{
+    public StopServerTest()
+    {
+        new InitScopeBasedIoCImplementationCommand().Execute();
+        IoC.Resolve<Hwdtech.ICommand>("Scopes.Current.Set", IoC.Resolve<object>("Scopes.New", IoC.Resolve<object>("Scopes.Root"))).Execute();
+
+        var logfilepath = Path.GetTempFileName();
+        IoC.Resolve<Hwdtech.ICommand>("IoC.Register", "GetLogFilePath", (object[] args) =>
+      {
+          return logfilepath;
+      }).Execute();
+        var a = new InitCommand();
+        a.Execute();
+    }
+
+    [Fact]
+
+    public void StopServer_Test()
+    {
+        var threadList = new List<int> { 1, 2, 3 };
+        var barrier = new Barrier(4);
+        var stopCommand = new Mock<ICommand>();
+        stopCommand.Setup(x => x.Execute()).Verifiable();
+        IoC.Resolve<Hwdtech.ICommand>("IoC.Register", "Game.Commands.GetThreadIDs", (object[] args) => { return threadList; }).Execute();
+
+        IoC.Resolve<Hwdtech.ICommand>("IoC.Register", "Game.Commands.StopServerBarrierRemove", (object[] args) =>
+        {
+            return () => { barrier.RemoveParticipant(); };
+        }).Execute();
+
+        IoC.Resolve<Hwdtech.ICommand>("IoC.Register", "Game.Commands.StopServerBarrierWait", (object[] args) =>
+        {
+            return new ActionCommand(() => { barrier.SignalAndWait(); });
+        }).Execute();
+
+        IoC.Resolve<Hwdtech.ICommand>("IoC.Register", "Game.Commands.SoftStopThread", (object[] args) =>
+        {
+            return new ActionCommand((Action)args[1]);
+        }).Execute();
+        IoC.Resolve<Hwdtech.ICommand>("IoC.Register", "Game.Commands.SendCommand", (object[] args) =>
+        {
+            return new ActionCommand(() =>
+            {
+                ((ICommand)args[1]).Execute();
+                stopCommand.Object.Execute();
+            });
+        }).Execute();
+
+        IoC.Resolve<ICommand>("Game.Commands.StopServerCommand").Execute();
+
+        Assert.Equal(1, barrier.CurrentPhaseNumber);
+        stopCommand.Verify(cmd => cmd.Execute(), Times.Exactly(3));
+    }
+
+    [Fact]
+    public void StopServer_TestwithExeption()
+    {
+        IoC.Resolve<ICommand>("Game.Commands.ExeptionHandler", new ActionCommand(() => { }), new Exception()).Execute();
+
+        var testString = "Error occurred in command: SpaceBattle.Lib.ActionCommand\nException: System.Exception: Exception of type 'System.Exception' was thrown.\n";
+        Assert.Equal(File.ReadAllText(IoC.Resolve<string>("GetLogFilePath")), testString);
+    }
+}

SpaceBattle.Lib/InitCommands.cs

@@ -0,0 +1,51 @@
+namespace SpaceBattle.Lib;
+using System.Linq;
+using Hwdtech;
+
+public class InitCommand : ICommand
+{
+    public void Execute()
+    {
+        IoC.Resolve<Hwdtech.ICommand>("IoC.Register", "Game.Commands.StartServerCommand", (object[] args) =>
+        {
+            var NumberOfThreads = (int)args[0];
+
+            return new ActionCommand(() =>
+            {
+                Enumerable.Range(0, NumberOfThreads).ToList().ForEach(i =>
+                {
+                    IoC.Resolve<ICommand>("Game.Commands.CreateAndStartThread").Execute();
+                });
+            });
+        }).Execute();
+
+        IoC.Resolve<Hwdtech.ICommand>("IoC.Register", "Game.Commands.ExeptionHandler", (object[] args) =>
+       {
+           var errorFile = IoC.Resolve<string>("GetLogFilePath");
+           return new ActionCommand(() =>
+           {
+               using (var sw = File.AppendText(errorFile))
+               {
+                   sw.WriteLine($"Error occurred in command: {args[0]}");
+                   sw.WriteLine($"Exception: {args[1]}");
+               }
+           });
+       }).Execute();
+
+        IoC.Resolve<Hwdtech.ICommand>("IoC.Register", "Game.Commands.StopServerCommand", (object[] args) =>
+        {
+            var ThreadList = IoC.Resolve<List<int>>("Game.Commands.GetThreadIDs");
+            return new ActionCommand(() =>
+            {
+                ThreadList.ForEach(thread_id =>
+                 {
+                     IoC.Resolve<ICommand>("Game.Commands.SendCommand", thread_id,
+                IoC.Resolve<ICommand>("Game.Commands.SoftStopThread", thread_id,
+                IoC.Resolve<Action>("Game.Commands.StopServerBarrierRemove"))).Execute();
+                 });
+
+                IoC.Resolve<ICommand>("Game.Commands.StopServerBarrierWait").Execute();
+            });
+        }).Execute();
+    }
+}