wake machine from API by machineId

notes/nugets.txt

@@ -5,5 +5,5 @@ dotnet pack /*--include-symbols*/
 
 # Server:
 dotnet nuget push NetworkResurrector.Server.PublishedLanguage.1.0.3.nupkg -k ***REMOVED*** -s https://toodle.ddns.net/public-nuget-server/nuget
-dotnet nuget push NetworkResurrector.Server.Wrapper.1.0.3.nupkg -k ***REMOVED*** -s https://toodle.ddns.net/public-nuget-server/nuget
+dotnet nuget push NetworkResurrector.Server.Wrapper.1.0.3.1.nupkg -k ***REMOVED*** -s https://toodle.ddns.net/public-nuget-server/nuget
 #######################################################################################################################################################

src/api/NetworkResurrector.Api.Application/CommandHandlers/WakeMachineHandler.cs

@@ -0,0 +1,35 @@
+using MediatR;
+using Microsoft.Extensions.Logging;
+using NetworkResurrector.Api.Domain.Repositories;
+using NetworkResurrector.Api.PublishedLanguage.Commands;
+using NetworkResurrector.Api.PublishedLanguage.Events;
+using NetworkResurrector.Server.Wrapper.Services;
+using System.Threading;
+using System.Threading.Tasks;
+
+namespace NetworkResurrector.Api.Application.CommandHandlers
+{
+    public class WakeMachineHandler : IRequestHandler<WakeMachine, MachineWaked>
+    {
+        private readonly ILogger<WakeMachineHandler> _logger;
+        private readonly IResurrectorService _resurrectorService;
+        private readonly INetworkRepository _repository;
+
+        public WakeMachineHandler(ILogger<WakeMachineHandler> logger, IResurrectorService resurrectorService, INetworkRepository repository)
+        {
+            _logger=logger;
+            _resurrectorService=resurrectorService;
+            _repository=repository;
+        }
+
+        public async Task<MachineWaked> Handle(WakeMachine command, CancellationToken cancellationToken)
+        {
+            var machine = await _repository.GetMachine(command.MachineId);
+
+            //log activity
+            var wakeResult = await _resurrectorService.Wake(machine.MACAddress);
+            var result = new MachineWaked(wakeResult.Success, wakeResult.Status);
+            return result;
+        }
+    }
+}

src/api/NetworkResurrector.Api.Application/NetworkResurrector.Api.Application.csproj

@@ -11,7 +11,7 @@
     <PackageReference Include="Microsoft.Extensions.DependencyInjection.Abstractions" Version="$(MicrosoftExtensionsPackageVersion)" />
     <PackageReference Include="Microsoft.Extensions.Logging.Abstractions" Version="$(MicrosoftExtensionsPackageVersion)" />
     <PackageReference Include="NDB.Application.DataContracts" Version="$(NDBApplicationPackageVersion)" />
-    <PackageReference Include="NetworkResurrector.Server.Wrapper" Version="1.0.3" />
+    <PackageReference Include="NetworkResurrector.Server.Wrapper" Version="1.0.3.1" />
   </ItemGroup>
 
   <ItemGroup>

src/api/NetworkResurrector.Api.Domain.Data/Repositories/NetworkRepository.cs

@@ -2,6 +2,7 @@
 using NetworkResurrector.Api.Domain.Data.DbContexts;
 using NetworkResurrector.Api.Domain.Entities;
 using NetworkResurrector.Api.Domain.Repositories;
+using System;
 using System.Threading.Tasks;
 
 namespace NetworkResurrector.Api.Domain.Data.Repositories
@@ -19,5 +20,14 @@ namespace NetworkResurrector.Api.Domain.Data.Repositories
         {
             return _dbContext.Machines.ToArrayAsync();
         }
+
+        public async Task<Machine> GetMachine(int machineId)
+        {
+            var machine = await _dbContext.Machines.FirstOrDefaultAsync(z => z.MachineId == machineId);
+            if (machine == null)
+                throw new Exception($"Machine with id {machineId} not found");
+
+            return machine;
+        }
     }
 }

src/api/NetworkResurrector.Api.Domain/Repositories/INetworkRepository.cs

@@ -6,5 +6,6 @@ namespace NetworkResurrector.Api.Domain.Repositories
     public interface INetworkRepository
     {
         Task<Machine[]> GetMachines();
+        Task<Machine> GetMachine(int machineId);
     }
 }

src/api/NetworkResurrector.Api.PublishedLanguage/Commands/PingMachine.cs

@@ -5,5 +5,6 @@ namespace NetworkResurrector.Api.PublishedLanguage.Commands
 {
     public class PingMachine : Command<MachinePinged>
     {
+        public int MachineId { get; set; }
     }
 }

src/api/NetworkResurrector.Api.PublishedLanguage/Commands/ShutdownMachine.cs

@@ -5,5 +5,6 @@ namespace NetworkResurrector.Api.PublishedLanguage.Commands
 {
     public class ShutdownMachine : Command<MachineShutdown>
     {
+        public int MachineId { get; set; }
     }
 }

src/api/NetworkResurrector.Api.PublishedLanguage/Commands/WakeMachine.cs

@@ -5,5 +5,6 @@ namespace NetworkResurrector.Api.PublishedLanguage.Commands
 {
     public class WakeMachine : Command<MachineWaked>
     {
+        public int MachineId { get; set; }
     }
 }

src/api/NetworkResurrector.Api.PublishedLanguage/Events/MachineWaked.cs

@@ -1,8 +1,4 @@
 namespace NetworkResurrector.Api.PublishedLanguage.Events
 {
-    public class MachineWaked
-    {
-        public bool Success { get; set; }
-        public string Status { get; set; }
-    }
+    public record MachineWaked(bool Success, string Status);
 }

src/api/NetworkResurrector.Api/Startup.cs

@@ -11,6 +11,7 @@ using NDB.Extensions.Swagger.Constants;
 using NDB.Security.Authentication.Identity;
 using NetworkResurrector.Api.Application;
 using NetworkResurrector.Api.Domain.Data;
+using NetworkResurrector.Server.Wrapper;
 using Newtonsoft.Json;
 using System.Reflection;
 
@@ -40,12 +41,14 @@ namespace NetworkResurrector.Api
             services.AddScoped(typeof(IPipelineBehavior<,>), typeof(RequestPostProcessorBehavior<,>));
 
             // AutoMapper
-            services.AddAutoMapper(
-                typeof(Application.Mappings.MappingProfile).Assembly);
+            services.AddAutoMapper(typeof(Application.Mappings.MappingProfile).Assembly);
 
             // Swagger
             services.AddSwagger("NetworkResurrector API", AuthorizationType.InhouseIdentity);
 
+            // Add network resurrector server services
+            services.UseResurrectorServices(_configuration.GetSection("NetworkResurrectorServer")["BaseAddress"]);
+
             // Data access
             services.AddDataAccess();
 

src/api/NetworkResurrector.Api/appsettings.json

@@ -15,5 +15,8 @@
   "IdentityServer": {
     //"BaseAddress": "http://localhost:5063/"
     "BaseAddress": "https://toodle.ddns.net/identity-server-api/"
+  },
+  "NetworkResurrectorServer": {
+    "BaseAddress": "http://localhost:5062"
   }
 }

src/server/NetworkResurrector.Server.Wrapper/NetworkResurrector.Server.Wrapper.csproj

@@ -6,6 +6,7 @@
     <PackageProjectUrl>https://dev.azure.com/tstanciu94/NetworkResurrector</PackageProjectUrl>
     <RepositoryUrl>https://dev.azure.com/tstanciu94/NetworkResurrector</RepositoryUrl>
     <RepositoryType>Git</RepositoryType>
+    <Version>1.0.3.1</Version>
   </PropertyGroup>
 
   <ItemGroup>

src/server/NetworkResurrector.Server.Wrapper/Services/IResurrectorService.cs

@@ -1,7 +1,11 @@
-namespace NetworkResurrector.Server.Wrapper.Services
+using NetworkResurrector.Server.PublishedLanguage.Events;
+using System.Threading.Tasks;
+
+namespace NetworkResurrector.Server.Wrapper.Services
 {
     public interface IResurrectorService
     {
-
+        Task<MachineWaked> Wake(string macAddress);
+        Task<MachinePinged> Ping(string ipAddressOrMachineName);
     }
 }