xref: /openbmc/telemetry/src/metric.cpp (revision 6ccfcbf54c3c808d99e754013008b2d7291dc347)

#include "metric.hpp"

#include "interfaces/types.hpp"
#include "utils/transform.hpp"

#include <algorithm>

Metric::Metric(std::vector<std::shared_ptr<interfaces::Sensor>> sensors,
               std::string operationType, std::string id,
               std::string metadata) :
    sensors(std::move(sensors)),
    operationType(std::move(operationType)), id(std::move(id)),
    metadata(std::move(metadata))
{}

void Metric::initialize()
{
    readings = std::vector<MetricValue>(sensors.size(),
                                        MetricValue{id, metadata, 0., 0u});

    for (auto& sensor : sensors)
    {
        sensor->registerForUpdates(weak_from_this());
    }
}

const std::vector<MetricValue>& Metric::getReadings() const
{
    return readings;
}

void Metric::sensorUpdated(interfaces::Sensor& sensor, uint64_t timestamp)
{
    MetricValue& mv = findMetric(sensor);
    mv.timestamp = timestamp;
}

void Metric::sensorUpdated(interfaces::Sensor& sensor, uint64_t timestamp,
                           double value)
{
    MetricValue& mv = findMetric(sensor);
    mv.timestamp = timestamp;
    mv.value = value;
}

MetricValue& Metric::findMetric(interfaces::Sensor& sensor)
{
    auto it =
        std::find_if(sensors.begin(), sensors.end(),
                     [&sensor](const auto& s) { return s.get() == &sensor; });
    auto index = std::distance(sensors.begin(), it);
    return readings.at(index);
}

nlohmann::json Metric::to_json() const
{
    auto sensorPaths = utils::transform(
        sensors, [](const auto& sensor) -> sdbusplus::message::object_path {
            return sdbusplus::message::object_path(sensor->id().service + ":" +
                                                   sensor->id().path);
        });
    return LabeledReadingParameter::to_json(ReadingParameters::value_type(
        std::move(sensorPaths), operationType, id, metadata));
}