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

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

    PowerConsumerInfo? powerConsumerInfo = new()
    {
        Consumers = [],
    };

    foreach (string chassis in chassisMembers)
    {
        if (string.IsNullOrWhiteSpace(chassis))
        {
            continue;
        }

        string powerChassis = chassis + (chassis.EndsWith('/') ? "Power/" : "/Power/");

        string? powerRaw = await TryGetJsonPage(powerChassis, payloadHeader, address, creds.Port);
        if (string.IsNullOrWhiteSpace(powerRaw))
        {
            continue;
        }

        try
        {
            List<DevicePowerConsumer>? consumers = ProcessPowerStatus(powerRaw);
            if (consumers is not null)
            {
                powerConsumerInfo.Consumers.AddRange(consumers);
            }
        }
        catch (Exception ex)
        {
            Console.WriteLine("Ex while try get powerConsumers from device {0} {1}", address, ex);
        }
    }

    if (powerConsumerInfo.Consumers is not null)
    {
        powerConsumerInfo.TotalUsage = powerConsumerInfo.Consumers.Sum(c => c.ConsumerUsage);
    }

    return powerConsumerInfo;
}
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 List<DevicePowerConsumer>? ProcessPowerStatus(string powerRaw)
{
    List<DevicePowerConsumer> retData = [];

    try
    {
        PowerStatusResponse? parsedObject = JsonConvert.DeserializeObject<PowerStatusResponse>(powerRaw);
        if (parsedObject == null)
        {
            return retData;
        }

        int pcl = parsedObject.PowerControl != null ? parsedObject.PowerControl.Count : 0;
        int psl = parsedObject.PowerSupplies != null ? parsedObject.PowerSupplies.Count : 0;
        int threshold = pcl >= psl ? pcl : psl;
        for (int a = 0; a < threshold; a++)
        {
            PowerSupply curControl = parsedObject.PowerControl != null && parsedObject.PowerControl.Count > a ? parsedObject.PowerControl[a] : new PowerSupply();
            PowerSupply curSupply = parsedObject.PowerSupplies != null && parsedObject.PowerSupplies.Count > a ? parsedObject.PowerSupplies[a] : new PowerSupply();
            retData.Add(BuildState(curControl, curSupply));
        }
    }
    catch (Exception ex)
    {
        Console.WriteLine("Exception while parse power usage {0}", ex);
    }

    return retData;
}