1 #include "config.h"
2
3 #include "lg2_commit.hpp"
4
5 #include <sys/syslog.h>
6
7 #include <nlohmann/json.hpp>
8 #include <phosphor-logging/commit.hpp>
9 #include <phosphor-logging/lg2.hpp>
10 #include <sdbusplus/async.hpp>
11 #include <sdbusplus/exception.hpp>
12 #include <xyz/openbmc_project/Logging/Create/client.hpp>
13 #include <xyz/openbmc_project/Logging/Entry/client.hpp>
14
15 namespace lg2
16 {
17 namespace details
18 {
19
20 using Create = sdbusplus::client::xyz::openbmc_project::logging::Create<>;
21 using Entry = sdbusplus::client::xyz::openbmc_project::logging::Entry<>;
22
23 /* Convert syslog severity to Entry::Level */
severity_from_syslog(int s)24 static auto severity_from_syslog(int s) -> Entry::Level
25 {
26 switch (s)
27 {
28 case LOG_DEBUG:
29 return Entry::Level::Debug;
30
31 case LOG_INFO:
32 return Entry::Level::Informational;
33
34 case LOG_NOTICE:
35 return Entry::Level::Notice;
36
37 case LOG_WARNING:
38 return Entry::Level::Warning;
39
40 case LOG_ERR:
41 return Entry::Level::Error;
42
43 case LOG_CRIT:
44 return Entry::Level::Critical;
45
46 case LOG_ALERT:
47 return Entry::Level::Alert;
48
49 case LOG_EMERG:
50 return Entry::Level::Emergency;
51 }
52 return Entry::Level::Emergency;
53 }
54
55 using AdditionalData_t = std::map<std::string, std::string>;
56
57 /* Create AdditionalData from the sdbusplus event json. */
data_from_json(sdbusplus::exception::generated_event_base & t)58 static auto data_from_json(sdbusplus::exception::generated_event_base& t)
59 -> AdditionalData_t
60 {
61 AdditionalData_t result{};
62
63 auto j = t.to_json()[t.name()];
64 for (const auto& item : j.items())
65 {
66 // Special cases for the "_SOURCE" fields, which contain debug
67 // information about the origin of the event.
68 if (item.key() == "_SOURCE")
69 {
70 for (const auto& source_item : item.value().items())
71 {
72 if (source_item.key() == "PID")
73 {
74 result.emplace("_PID", source_item.value().dump());
75 continue;
76 }
77 if (source_item.key() == "FILE")
78 {
79 result.emplace("_CODE_FILE", source_item.value());
80 continue;
81 }
82 if (source_item.key() == "FUNCTION")
83 {
84 result.emplace("_CODE_FUNC", source_item.value());
85 continue;
86 }
87 if (source_item.key() == "LINE")
88 {
89 result.emplace("_CODE_LINE", source_item.value().dump());
90 continue;
91 }
92 }
93 continue;
94 }
95
96 if (item.value().type() == nlohmann::json::value_t::string)
97 {
98 result.emplace(item.key(), item.value());
99 }
100 else
101 {
102 result.emplace(item.key(), item.value().dump());
103 }
104 }
105
106 return result;
107 }
108
extractEvent(sdbusplus::exception::generated_event_base && t)109 auto extractEvent(sdbusplus::exception::generated_event_base&& t)
110 -> std::tuple<std::string, Entry::Level, std::map<std::string, std::string>>
111 {
112 return {t.name(), severity_from_syslog(t.severity()), data_from_json(t)};
113 }
114
115 } // namespace details
116
commit(sdbusplus::exception::generated_event_base && t)117 auto commit(sdbusplus::exception::generated_event_base&& t)
118 -> sdbusplus::message::object_path
119 {
120 if constexpr (LG2_COMMIT_JOURNAL)
121 {
122 lg2::error("OPENBMC_MESSAGE_ID={DATA}", "DATA", t.to_json().dump());
123 }
124
125 if constexpr (LG2_COMMIT_DBUS)
126 {
127 using details::Create;
128
129 auto b = sdbusplus::bus::new_default();
130 auto m =
131 b.new_method_call(Create::default_service, Create::instance_path,
132 Create::interface, "Create");
133
134 m.append(t.name(), details::severity_from_syslog(t.severity()),
135 details::data_from_json(t));
136
137 auto reply = b.call(m);
138
139 return reply.unpack<sdbusplus::message::object_path>();
140 }
141
142 return {};
143 }
144
commit(sdbusplus::async::context & ctx,sdbusplus::exception::generated_event_base && t)145 auto commit(sdbusplus::async::context& ctx,
146 sdbusplus::exception::generated_event_base&& t)
147 -> sdbusplus::async::task<sdbusplus::message::object_path>
148 {
149 using details::Create;
150
151 if constexpr (LG2_COMMIT_JOURNAL)
152 {
153 lg2::error("OPENBMC_MESSAGE_ID={DATA}", "DATA", t.to_json().dump());
154 }
155
156 if constexpr (LG2_COMMIT_DBUS)
157 {
158 co_return co_await Create(ctx)
159 .service(Create::default_service)
160 .path(Create::instance_path)
161 .create(t.name(), details::severity_from_syslog(t.severity()),
162 details::data_from_json(t));
163 }
164 co_return {};
165 }
166
167 } // namespace lg2
168