1 #include "dbus_to_event_handler.hpp"
2 
3 #include "libpldmresponder/pdr.hpp"
4 
5 #include <phosphor-logging/lg2.hpp>
6 
7 PHOSPHOR_LOG2_USING;
8 
9 namespace pldm
10 {
11 using namespace pldm::responder;
12 using namespace pldm::responder::pdr;
13 using namespace pldm::responder::pdr_utils;
14 using namespace pldm::utils;
15 using namespace sdbusplus::bus::match::rules;
16 
17 namespace state_sensor
18 {
19 const std::vector<uint8_t> pdrTypes{PLDM_STATE_SENSOR_PDR};
20 
21 DbusToPLDMEvent::DbusToPLDMEvent(
22     int mctp_fd, uint8_t mctp_eid, pldm::InstanceIdDb& instanceIdDb,
23     pldm::requester::Handler<pldm::requester::Request>* handler) :
24     mctp_fd(mctp_fd),
25     mctp_eid(mctp_eid), instanceIdDb(instanceIdDb), handler(handler)
26 {}
27 
28 void DbusToPLDMEvent::sendEventMsg(uint8_t eventType,
29                                    const std::vector<uint8_t>& eventDataVec)
30 {
31     auto instanceId = instanceIdDb.next(mctp_eid);
32     std::vector<uint8_t> requestMsg(sizeof(pldm_msg_hdr) +
33                                     PLDM_PLATFORM_EVENT_MESSAGE_MIN_REQ_BYTES +
34                                     eventDataVec.size());
35     auto request = reinterpret_cast<pldm_msg*>(requestMsg.data());
36 
37     auto rc = encode_platform_event_message_req(
38         instanceId, 1 /*formatVersion*/, TERMINUS_ID /*tId*/, eventType,
39         eventDataVec.data(), eventDataVec.size(), request,
40         eventDataVec.size() + PLDM_PLATFORM_EVENT_MESSAGE_MIN_REQ_BYTES);
41     if (rc != PLDM_SUCCESS)
42     {
43         instanceIdDb.free(mctp_eid, instanceId);
44         error("Failed to encode_platform_event_message_req, rc = {RC}", "RC",
45               rc);
46         return;
47     }
48 
49     auto platformEventMessageResponseHandler =
50         [](mctp_eid_t /*eid*/, const pldm_msg* response, size_t respMsgLen) {
51         if (response == nullptr || !respMsgLen)
52         {
53             error("Failed to receive response for platform event message");
54             return;
55         }
56         uint8_t completionCode{};
57         uint8_t status{};
58         auto rc = decode_platform_event_message_resp(response, respMsgLen,
59                                                      &completionCode, &status);
60         if (rc || completionCode)
61         {
62             error(
63                 "Failed to decode_platform_event_message_resp: rc = {RC}, cc = {CC}",
64                 "RC", rc, "CC", static_cast<unsigned>(completionCode));
65         }
66     };
67 
68     rc = handler->registerRequest(
69         mctp_eid, instanceId, PLDM_PLATFORM, PLDM_PLATFORM_EVENT_MESSAGE,
70         std::move(requestMsg), std::move(platformEventMessageResponseHandler));
71     if (rc)
72     {
73         error("Failed to send the platform event message");
74     }
75 }
76 
77 void DbusToPLDMEvent::sendStateSensorEvent(SensorId sensorId,
78                                            const DbusObjMaps& dbusMaps)
79 {
80     // Encode PLDM platform event msg to indicate a state sensor change.
81     // DSP0248_1.2.0 Table 19
82     if (!dbusMaps.contains(sensorId))
83     {
84         // this is not an error condition, if we end up here
85         // that means that the sensor with the sensor id has
86         // custom behaviour(or probably an oem sensor) in
87         // sending events that cannot be captured via standard
88         // dbus-json infastructure
89         return;
90     }
91 
92     size_t sensorEventSize = PLDM_SENSOR_EVENT_DATA_MIN_LENGTH + 1;
93     const auto& [dbusMappings, dbusValMaps] = dbusMaps.at(sensorId);
94     for (uint8_t offset = 0; offset < dbusMappings.size(); ++offset)
95     {
96         std::vector<uint8_t> sensorEventDataVec{};
97         sensorEventDataVec.resize(sensorEventSize);
98         auto eventData = reinterpret_cast<struct pldm_sensor_event_data*>(
99             sensorEventDataVec.data());
100         eventData->sensor_id = sensorId;
101         eventData->sensor_event_class_type = PLDM_STATE_SENSOR_STATE;
102         eventData->event_class[0] = offset;
103         eventData->event_class[1] = PLDM_SENSOR_UNKNOWN;
104         eventData->event_class[2] = PLDM_SENSOR_UNKNOWN;
105 
106         const auto& dbusMapping = dbusMappings[offset];
107         const auto& dbusValueMapping = dbusValMaps[offset];
108         auto stateSensorMatch = std::make_unique<sdbusplus::bus::match_t>(
109             pldm::utils::DBusHandler::getBus(),
110             propertiesChanged(dbusMapping.objectPath.c_str(),
111                               dbusMapping.interface.c_str()),
112             [this, sensorEventDataVec, dbusValueMapping, dbusMapping, sensorId,
113              offset](auto& msg) mutable {
114             DbusChangedProps props{};
115             std::string intf;
116             uint8_t previousState = PLDM_SENSOR_UNKNOWN;
117             msg.read(intf, props);
118             if (!props.contains(dbusMapping.propertyName))
119             {
120                 return;
121             }
122             for (const auto& itr : dbusValueMapping)
123             {
124                 bool findValue = false;
125                 if (dbusMapping.propertyType == "string")
126                 {
127                     std::string src = std::get<std::string>(itr.second);
128                     std::string dst = std::get<std::string>(
129                         props.at(dbusMapping.propertyName));
130 
131                     auto values = pldm::utils::split(src, "||", " ");
132                     for (auto& value : values)
133                     {
134                         if (value == dst)
135                         {
136                             findValue = true;
137                             break;
138                         }
139                     }
140                 }
141                 else
142                 {
143                     findValue = itr.second == props.at(dbusMapping.propertyName)
144                                     ? true
145                                     : false;
146                 }
147 
148                 if (findValue)
149                 {
150                     auto eventData =
151                         reinterpret_cast<struct pldm_sensor_event_data*>(
152                             sensorEventDataVec.data());
153                     eventData->event_class[1] = itr.first;
154                     if (sensorCacheMap.contains(sensorId) &&
155                         sensorCacheMap[sensorId][offset] != PLDM_SENSOR_UNKNOWN)
156                     {
157                         previousState = sensorCacheMap[sensorId][offset];
158                     }
159                     else
160                     {
161                         previousState = itr.first;
162                     }
163                     eventData->event_class[2] = previousState;
164                     this->sendEventMsg(PLDM_SENSOR_EVENT, sensorEventDataVec);
165                     updateSensorCacheMaps(sensorId, offset, previousState);
166                     break;
167                 }
168             }
169         });
170         stateSensorMatchs.emplace_back(std::move(stateSensorMatch));
171     }
172 }
173 
174 void DbusToPLDMEvent::listenSensorEvent(const pdr_utils::Repo& repo,
175                                         const DbusObjMaps& dbusMaps)
176 {
177     const std::map<Type, sensorEvent> sensorHandlers = {
178         {PLDM_STATE_SENSOR_PDR,
179          [this](SensorId sensorId, const DbusObjMaps& dbusMaps) {
180         this->sendStateSensorEvent(sensorId, dbusMaps);
181     }}};
182 
183     pldm_state_sensor_pdr* pdr = nullptr;
184     std::unique_ptr<pldm_pdr, decltype(&pldm_pdr_destroy)> sensorPdrRepo(
185         pldm_pdr_init(), pldm_pdr_destroy);
186     if (!sensorPdrRepo)
187     {
188         throw std::runtime_error("Unable to instantiate sensor PDR repository");
189     }
190 
191     for (auto pdrType : pdrTypes)
192     {
193         Repo sensorPDRs(sensorPdrRepo.get());
194         getRepoByType(repo, sensorPDRs, pdrType);
195         if (sensorPDRs.empty())
196         {
197             return;
198         }
199 
200         PdrEntry pdrEntry{};
201         auto pdrRecord = sensorPDRs.getFirstRecord(pdrEntry);
202         while (pdrRecord)
203         {
204             pdr = reinterpret_cast<pldm_state_sensor_pdr*>(pdrEntry.data);
205             SensorId sensorId = LE16TOH(pdr->sensor_id);
206             if (sensorHandlers.contains(pdrType))
207             {
208                 sensorHandlers.at(pdrType)(sensorId, dbusMaps);
209             }
210 
211             pdrRecord = sensorPDRs.getNextRecord(pdrRecord, pdrEntry);
212         }
213     }
214 }
215 
216 } // namespace state_sensor
217 } // namespace pldm
218