extend_bmc/dotnet/power_off · dev · Bergen.It / ems-sdk · Mos.Hub

{
  "device": {
    "device_id": "test",
    "connectors": [
      {
        "address": "192.168.1.55",
        "credentials": [
          {
            "login": "root",
            "password": "1qaz@WSX",
            "port": 443,
            "protocol": "CONNECTOR_PROTOCOL_REDFISH"
          }
        ]
      }
    ]
  },
  "mode": "BMC_POWER_OFF_MODE_STANDARD"
}
{
  {
    "ResetType": "ForceOff"
  }
}
private async Task<OperationResult> PowerOffRedfish(Credential creds, string address)
{
    string payloadHeader = $"authorization:Basic {Convert.ToBase64String(Encoding.UTF8.GetBytes(creds.Login + ':' + creds.Password))}";

    string bodyTemplate = @$"{{""ResetType"": ""ForceOff""}}";

    ImmutableArray<string> members = await GetMembers("/redfish/v1/Systems/", payloadHeader, address, creds.Port);

    if (!members.Any())
    {
        return new()
        {
            Output = "Members page not found",
            State = OperationState.Failed
        };
    }

    string actionPath = members[0];

    if (!actionPath.EndsWith('/'))
    {
        actionPath += '/';
    }

    actionPath += "Actions/ComputerSystem.Reset";

    RedfishOperationResult result = await TryPost(actionPath, payloadHeader, address, creds.Port, bodyTemplate);

    return new()
    {
        Output = result.Success
            ? result.Result
            : result.Error,
        State = result.Success ? OperationState.Success : OperationState.Failed,
    };
}
private static async Task<string?> TryGetJsonPage(string path, string authHeader, string ip, int port)
{
    try
    {
        string uri = (port == 80 || port / 100 == 50 ? "http" : "https") + "://" + ip + ':' + port + path;

        HttpRequestMessage httpRequestMessage = new()
        {
            RequestUri = new(uri),
        };

        string[] headers = authHeader.Split(':', 2);

        if (headers.Length == 2)
        {
            httpRequestMessage.Headers.Add(headers[0], headers[1]);
        }

        HttpClient httpClient = new(new HttpClientHandler()
        {
            ServerCertificateCustomValidationCallback = (message, cert, chain, errors) => true,
            AllowAutoRedirect = false,
        })
        {
            Timeout = TimeSpan.FromSeconds(100)
        };

        using HttpResponseMessage httpResponseMessage = await httpClient.SendAsync(httpRequestMessage);

        string result = await httpResponseMessage.Content.ReadAsStringAsync();

        if (httpResponseMessage.IsSuccessStatusCode)
        {
            return result;
        }
    }
    catch
    {
        return null;
    }

    return null;
}
public async Task<RedfishOperationResult> TryPost(string path, string authHeader, string ip, int port, string body)
{
    string uri = (port == 80 ? "http" : "https") + "://" + ip + ':' + port + path;

    try
    {
        HttpRequestMessage httpRequestMessage = new()
        {
            RequestUri = new(uri),
            Method = HttpMethod.Post,
            Content = new StringContent(body)
        };

        httpRequestMessage.Content.Headers.ContentType = new(MediaTypeNames.Application.Json);

        string[] headerValues = authHeader.Split(':', 2);

        if (headerValues.Length == 2)
        {
            httpRequestMessage.Headers.TryAddWithoutValidation(headerValues[0], headerValues[1]);
        }

        HttpClient httpClient = new(new HttpClientHandler()
        {
            ServerCertificateCustomValidationCallback = (message, cert, chain, errors) => true,
            AllowAutoRedirect = false,
        })
        {
            Timeout = TimeSpan.FromSeconds(100)
        };

        using HttpResponseMessage httpResponseMessage = await httpClient.SendAsync(httpRequestMessage);

        int statusCode = (int)httpResponseMessage.StatusCode;

        string result = await httpResponseMessage.Content.ReadAsStringAsync();

        if (statusCode >= 200 && statusCode < 300 && (!result.Contains("\"error\"") || result.Contains(".Success\"")))
        {
            return new(result, string.Empty, true, string.Empty);
        }
        else
        {
            return new(string.Empty, result, false, string.Empty);
        }
    }
    catch (Exception ex)
    {
        Console.WriteLine("Error while patch to device {0}, {1}", uri, ex);

        return new(string.Empty, ex.Message, false, string.Empty);
    }
}