tudor.stanciu
/
network-resurrector
mirror of https://dev.azure.com/tstanciu94/NetworkResurrector/_git/NetworkResurrector
1
0
Fork 0
Code Issues 1 Packages Projects Releases Wiki Activity

WakeMachineHandler fix

master
Tudor Stanciu 2022-01-17 19:22:31 +02:00
parent 9af7aea208
commit 7be1fd6a69
2 changed files with 32 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
src/api/NetworkResurrector.Api.Application/CommandHandlers/PingMachineHandler.cs
View File

@ -1,9 +1,11 @@
using MediatR; using MediatR;
using Microsoft.Extensions.Logging; using Microsoft.Extensions.Logging;
using NetworkResurrector.Api.Domain.Constants;
using NetworkResurrector.Api.Domain.Repositories; using NetworkResurrector.Api.Domain.Repositories;
using NetworkResurrector.Api.PublishedLanguage.Commands; using NetworkResurrector.Api.PublishedLanguage.Commands;
using NetworkResurrector.Api.PublishedLanguage.Events; using NetworkResurrector.Api.PublishedLanguage.Events;
using NetworkResurrector.Server.Wrapper.Services; using NetworkResurrector.Server.Wrapper.Services;
using System;
using System.Threading; using System.Threading;
using System.Threading.Tasks; using System.Threading.Tasks;
@ -26,11 +28,22 @@ namespace NetworkResurrector.Api.Application.CommandHandlers
{ {
_logger.LogDebug($"Start pinging machine {command.MachineId}"); _logger.LogDebug($"Start pinging machine {command.MachineId}");
var machine = await _repository.GetMachine(command.MachineId); var machine = await _repository.GetMachine(command.MachineId);
var powerConfiguration = await _repository.GetPowerActionConfiguration(command.MachineId, PowerActions.PING);
//log activity //log activity
var pingResult = await _resurrectorService.Ping(machine.IPv4Address ?? machine.MachineName);
var result = new MachinePinged(pingResult.Success, pingResult.Status); MachinePinged result;
_logger.LogDebug($"Machine {command.MachineId} pinging finished. Success: {result.Success}; Status: {result.Status}"); switch (powerConfiguration.Performer.PerformerCode)
{
case PowerActionPerformers.NETWORK_RESURRECTOR_SERVER:
var pingResult = await _resurrectorService.Ping(machine.IPv4Address ?? machine.MachineName);
result = new MachinePinged(pingResult.Success, pingResult.Status);
_logger.LogDebug($"Machine {command.MachineId} pinging finished. Success: {result.Success}; Status: {result.Status}");
break;
default:
throw new Exception($"Power action performer {powerConfiguration.Performer.PerformerCode} is not implemented.");
}
return result; return result;
} }

19
src/api/NetworkResurrector.Api.Application/CommandHandlers/WakeMachineHandler.cs
View File

@ -1,9 +1,11 @@
using MediatR; using MediatR;
using Microsoft.Extensions.Logging; using Microsoft.Extensions.Logging;
using NetworkResurrector.Api.Domain.Constants;
using NetworkResurrector.Api.Domain.Repositories; using NetworkResurrector.Api.Domain.Repositories;
using NetworkResurrector.Api.PublishedLanguage.Commands; using NetworkResurrector.Api.PublishedLanguage.Commands;
using NetworkResurrector.Api.PublishedLanguage.Events; using NetworkResurrector.Api.PublishedLanguage.Events;
using NetworkResurrector.Server.Wrapper.Services; using NetworkResurrector.Server.Wrapper.Services;
using System;
using System.Threading; using System.Threading;
using System.Threading.Tasks; using System.Threading.Tasks;
@ -26,11 +28,22 @@ namespace NetworkResurrector.Api.Application.CommandHandlers
{ {
_logger.LogDebug($"Start waking up machine {command.MachineId}"); _logger.LogDebug($"Start waking up machine {command.MachineId}");
var machine = await _repository.GetMachine(command.MachineId); var machine = await _repository.GetMachine(command.MachineId);
var powerConfiguration = await _repository.GetPowerActionConfiguration(command.MachineId, PowerActions.WAKE);
//log activity //log activity
var wakeResult = await _resurrectorService.Wake(machine.MACAddress);
var result = new MachineWaked(wakeResult.Success, wakeResult.Status); MachineWaked result;
_logger.LogDebug($"Machine {command.MachineId} wake up finished. Success: {result.Success}; Status: {result.Status}"); switch (powerConfiguration.Performer.PerformerCode)
{
case PowerActionPerformers.NETWORK_RESURRECTOR_SERVER:
var wakeResult = await _resurrectorService.Wake(machine.MACAddress);
result = new MachineWaked(wakeResult.Success, wakeResult.Status);
_logger.LogDebug($"Machine {command.MachineId} wake up finished. Success: {result.Success}; Status: {result.Status}");
break;
default:
throw new Exception($"Power action performer {powerConfiguration.Performer.PerformerCode} is not implemented.");
}
return result; return result;
} }