extend_bmc/dotnet/led_state · 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"
          }
        ]
      }
    ]
  }
}
private static async Task<LedState> GetRedfishLedState(Credential creds, string address)
{
    string payloadHeader = $"authorization:Basic {Convert.ToBase64String(Encoding.UTF8.GetBytes(creds.Login + ':' + creds.Password))}";

    ImmutableArray<string> systemMembers = await GetMembers("/redfish/v1/Chassis/", payloadHeader, address, creds.Port);
    if (!systemMembers.Any())
    {
        return LedState.Unknown;
    }

    string path = systemMembers[0];

    string? ledState = await TryGetStringPropertyFromPage(path, "IndicatorLED", payloadHeader, address, creds.Port);

    return GetLedState(ledState ?? string.Empty);
}
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;
}
private static async Task<string?> TryGetStringPropertyFromPage(string path, string propertyName, string authHeader, string ip, int port)
{
    string? data = await TryGetJsonPage(path, authHeader, ip, port);

    if (data is null)
    {
        return null;
    }

    try
    {
        string? value = null;
        string[] props = propertyName.Split("__");

        foreach (string p in props)
        {
            JObject page = JObject.Parse(data);
            JToken? obj = page.GetValue(p);

            if (obj is not null)
            {
                data = obj.ToString();
                value = data;
            }
        }

        return value?.Trim();
    }
    catch
    {
        return null;
    }
}