summaryrefslogtreecommitdiff
path: root/redfish-core/lib/telemetry_service.hpp
blob: 5457530fbd2e9b9fcb01d71c46fc86251ac01506 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
#pragma once

#include "utils/telemetry_utils.hpp"

#include <app.hpp>
#include <dbus_utility.hpp>
#include <registries/privilege_registry.hpp>

namespace redfish
{

inline void handleTelemetryServiceGet(
    const crow::Request& /*req*/,
    const std::shared_ptr<bmcweb::AsyncResp>& asyncResp)
{
    asyncResp->res.jsonValue["@odata.type"] =
        "#TelemetryService.v1_2_1.TelemetryService";
    asyncResp->res.jsonValue["@odata.id"] = "/redfish/v1/TelemetryService";
    asyncResp->res.jsonValue["Id"] = "TelemetryService";
    asyncResp->res.jsonValue["Name"] = "Telemetry Service";

    asyncResp->res.jsonValue["MetricReportDefinitions"]["@odata.id"] =
        "/redfish/v1/TelemetryService/MetricReportDefinitions";
    asyncResp->res.jsonValue["MetricReports"]["@odata.id"] =
        "/redfish/v1/TelemetryService/MetricReports";
    asyncResp->res.jsonValue["Triggers"]["@odata.id"] =
        "/redfish/v1/TelemetryService/Triggers";

    crow::connections::systemBus->async_method_call(
        [asyncResp](
            const boost::system::error_code ec,
            const std::vector<
                std::pair<std::string, dbus::utility::DbusVariantType>>& ret) {
            if (ec == boost::system::errc::host_unreachable)
            {
                asyncResp->res.jsonValue["Status"]["State"] = "Absent";
                return;
            }
            if (ec)
            {
                BMCWEB_LOG_ERROR << "respHandler DBus error " << ec;
                messages::internalError(asyncResp->res);
                return;
            }

            asyncResp->res.jsonValue["Status"]["State"] = "Enabled";

            const size_t* maxReports = nullptr;
            const uint64_t* minInterval = nullptr;
            for (const auto& [key, var] : ret)
            {
                if (key == "MaxReports")
                {
                    maxReports = std::get_if<size_t>(&var);
                }
                else if (key == "MinInterval")
                {
                    minInterval = std::get_if<uint64_t>(&var);
                }
            }
            if (!maxReports || !minInterval)
            {
                BMCWEB_LOG_ERROR
                    << "Property type mismatch or property is missing";
                messages::internalError(asyncResp->res);
                return;
            }

            asyncResp->res.jsonValue["MaxReports"] = *maxReports;
            asyncResp->res.jsonValue["MinCollectionInterval"] =
                time_utils::toDurationString(std::chrono::milliseconds(
                    static_cast<time_t>(*minInterval)));
        },
        telemetry::service, "/xyz/openbmc_project/Telemetry/Reports",
        "org.freedesktop.DBus.Properties", "GetAll",
        "xyz.openbmc_project.Telemetry.ReportManager");
}

inline void requestRoutesTelemetryService(App& app)
{
    BMCWEB_ROUTE(app, "/redfish/v1/TelemetryService/")
        .privileges(redfish::privileges::getTelemetryService)
        .methods(boost::beast::http::verb::get)(handleTelemetryServiceGet);
}

} // namespace redfish