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

ResurrectorAgentService

master
Tudor Stanciu 2022-01-14 01:48:08 +02:00
parent 9d892ba1e8
commit e1bcfc01c0
2 changed files with 17 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/agent/NetworkResurrector.Agent.Wrapper/Services/IResurrectorAgentService.cs
View File

@ -1,6 +1,11 @@
namespace NetworkResurrector.Agent.Wrapper.Services using NetworkResurrector.Agent.PublishedLanguage.Dto;
using NetworkResurrector.Agent.PublishedLanguage.Events;
using System.Threading.Tasks;
namespace NetworkResurrector.Agent.Wrapper.Services
{ {
public interface IResurrectorAgentService public interface IResurrectorAgentService
{ {
Task<ShutdownResult> Shutdown(string ipAddressOrMachineName, int agentPort, ActionOwner actionOwner = null, ActionOptions actionOptions = null);
} }
} }

14
src/agent/NetworkResurrector.Agent.Wrapper/Services/ResurrectorAgentService.cs
View File

@ -1,5 +1,6 @@
using NDB.Extensions.Http; using NDB.Extensions.Http;
using NetworkResurrector.Agent.PublishedLanguage.Commands; using NetworkResurrector.Agent.PublishedLanguage.Commands;
using NetworkResurrector.Agent.PublishedLanguage.Dto;
using NetworkResurrector.Agent.PublishedLanguage.Events; using NetworkResurrector.Agent.PublishedLanguage.Events;
using NetworkResurrector.Agent.Wrapper.Constants; using NetworkResurrector.Agent.Wrapper.Constants;
using System; using System;
@ -16,15 +17,22 @@ namespace NetworkResurrector.Agent.Wrapper.Services
public ResurrectorAgentService(HttpClient httpClient) public ResurrectorAgentService(HttpClient httpClient)
{ {
httpClient.BaseAddress = new Uri("");
httpClient.DefaultRequestHeaders.Accept.Add(new MediaTypeWithQualityHeaderValue(_contentType)); httpClient.DefaultRequestHeaders.Accept.Add(new MediaTypeWithQualityHeaderValue(_contentType));
_httpClient = httpClient; _httpClient = httpClient;
} }
public async Task<ShutdownResult> Shutdown(string ipAddressOrMachineName) private void SetHttpClientBaseAddress(string ipAddressOrMachineName, int agentPort)
{ {
var body = new Shutdown(); var baseAddress = $"http://{ipAddressOrMachineName}:{agentPort}";
_httpClient.BaseAddress = new Uri(baseAddress);
}
public async Task<ShutdownResult> Shutdown(string ipAddressOrMachineName, int agentPort, ActionOwner actionOwner = null, ActionOptions actionOptions = null)
{
SetHttpClientBaseAddress(ipAddressOrMachineName, agentPort);
var body = new Shutdown { Owner = actionOwner, Options = actionOptions };
var result = await _httpClient.ExecutePostRequest<ShutdownResult, Shutdown>(ApiRoutes.Shutdown, body); var result = await _httpClient.ExecutePostRequest<ShutdownResult, Shutdown>(ApiRoutes.Shutdown, body);
return result; return result;
} }