xref: /openbmc/bmcweb/features/redfish/include/event_service_manager.hpp (revision 2558979c8b57a25ed8a4e676d3bf2a762d749056)
1b52664e2SAppaRao Puli /*
2b52664e2SAppaRao Puli // Copyright (c) 2020 Intel Corporation
3b52664e2SAppaRao Puli //
4b52664e2SAppaRao Puli // Licensed under the Apache License, Version 2.0 (the "License");
5b52664e2SAppaRao Puli // you may not use this file except in compliance with the License.
6b52664e2SAppaRao Puli // You may obtain a copy of the License at
7b52664e2SAppaRao Puli //
8b52664e2SAppaRao Puli //      http://www.apache.org/licenses/LICENSE-2.0
9b52664e2SAppaRao Puli //
10b52664e2SAppaRao Puli // Unless required by applicable law or agreed to in writing, software
11b52664e2SAppaRao Puli // distributed under the License is distributed on an "AS IS" BASIS,
12b52664e2SAppaRao Puli // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13b52664e2SAppaRao Puli // See the License for the specific language governing permissions and
14b52664e2SAppaRao Puli // limitations under the License.
15b52664e2SAppaRao Puli */
16b52664e2SAppaRao Puli #pragma once
17c0353249SWludzik, Jozef #include "metric_report.hpp"
187f4eb588SAppaRao Puli #include "registries.hpp"
197f4eb588SAppaRao Puli #include "registries/base_message_registry.hpp"
207f4eb588SAppaRao Puli #include "registries/openbmc_message_registry.hpp"
21b304bd79SP Dheeraj Srujan Kumar #include "registries/task_event_message_registry.hpp"
227f4eb588SAppaRao Puli 
237f4eb588SAppaRao Puli #include <sys/inotify.h>
24b52664e2SAppaRao Puli 
25fb4fd5d4SZhenfei Tai #include <boost/asio/io_context.hpp>
26b52664e2SAppaRao Puli #include <boost/container/flat_map.hpp>
271214b7e7SGunnar Mills #include <error_messages.hpp>
2828afb49cSJunLin Chen #include <event_service_store.hpp>
291214b7e7SGunnar Mills #include <http_client.hpp>
3028afb49cSJunLin Chen #include <persistent_data.hpp>
31fc76b8acSEd Tanous #include <random.hpp>
324bbf237fSAppaRao Puli #include <server_sent_events.hpp>
331214b7e7SGunnar Mills #include <utils/json_utils.hpp>
341214b7e7SGunnar Mills 
35b52664e2SAppaRao Puli #include <cstdlib>
36b52664e2SAppaRao Puli #include <ctime>
371bf712bcSAyushi Smriti #include <fstream>
38b52664e2SAppaRao Puli #include <memory>
3926702d01SEd Tanous #include <span>
40b52664e2SAppaRao Puli #include <variant>
41b52664e2SAppaRao Puli 
42b52664e2SAppaRao Puli namespace redfish
43b52664e2SAppaRao Puli {
44156d6b00SAppaRao Puli 
45156d6b00SAppaRao Puli using ReadingsObjType =
4693f5d7c7SWludzik, Jozef     std::vector<std::tuple<std::string, std::string, double, int32_t>>;
47156d6b00SAppaRao Puli 
48156d6b00SAppaRao Puli static constexpr const char* eventFormatType = "Event";
49156d6b00SAppaRao Puli static constexpr const char* metricReportFormatType = "MetricReport";
50156d6b00SAppaRao Puli 
511bf712bcSAyushi Smriti static constexpr const char* eventServiceFile =
521bf712bcSAyushi Smriti     "/var/lib/bmcweb/eventservice_config.json";
531bf712bcSAyushi Smriti 
547f4eb588SAppaRao Puli namespace message_registries
557f4eb588SAppaRao Puli {
5626702d01SEd Tanous inline std::span<const MessageEntry>
57b304bd79SP Dheeraj Srujan Kumar     getRegistryFromPrefix(const std::string& registryName)
58b304bd79SP Dheeraj Srujan Kumar {
59b304bd79SP Dheeraj Srujan Kumar     if (task_event::header.registryPrefix == registryName)
60b304bd79SP Dheeraj Srujan Kumar     {
6126702d01SEd Tanous         return {task_event::registry};
62b304bd79SP Dheeraj Srujan Kumar     }
63b304bd79SP Dheeraj Srujan Kumar     if (openbmc::header.registryPrefix == registryName)
64b304bd79SP Dheeraj Srujan Kumar     {
6526702d01SEd Tanous         return {openbmc::registry};
66b304bd79SP Dheeraj Srujan Kumar     }
67b304bd79SP Dheeraj Srujan Kumar     if (base::header.registryPrefix == registryName)
68b304bd79SP Dheeraj Srujan Kumar     {
6926702d01SEd Tanous         return {base::registry};
70b304bd79SP Dheeraj Srujan Kumar     }
7126702d01SEd Tanous     return {openbmc::registry};
72b304bd79SP Dheeraj Srujan Kumar }
734642bf8fSGeorge Liu } // namespace message_registries
74b304bd79SP Dheeraj Srujan Kumar 
754642bf8fSGeorge Liu #ifndef BMCWEB_ENABLE_REDFISH_DBUS_LOG_ENTRIES
764642bf8fSGeorge Liu static std::optional<boost::asio::posix::stream_descriptor> inotifyConn;
774642bf8fSGeorge Liu static constexpr const char* redfishEventLogDir = "/var/log";
784642bf8fSGeorge Liu static constexpr const char* redfishEventLogFile = "/var/log/redfish";
794642bf8fSGeorge Liu static constexpr const size_t iEventSize = sizeof(inotify_event);
804642bf8fSGeorge Liu static int inotifyFd = -1;
814642bf8fSGeorge Liu static int dirWatchDesc = -1;
824642bf8fSGeorge Liu static int fileWatchDesc = -1;
834642bf8fSGeorge Liu 
844642bf8fSGeorge Liu // <ID, timestamp, RedfishLogId, registryPrefix, MessageId, MessageArgs>
854642bf8fSGeorge Liu using EventLogObjectsType =
864642bf8fSGeorge Liu     std::tuple<std::string, std::string, std::string, std::string, std::string,
874642bf8fSGeorge Liu                std::vector<std::string>>;
884642bf8fSGeorge Liu 
894642bf8fSGeorge Liu namespace message_registries
904642bf8fSGeorge Liu {
917f4eb588SAppaRao Puli static const Message*
927f4eb588SAppaRao Puli     getMsgFromRegistry(const std::string& messageKey,
9326702d01SEd Tanous                        const std::span<const MessageEntry>& registry)
947f4eb588SAppaRao Puli {
9526702d01SEd Tanous     std::span<const MessageEntry>::iterator messageIt =
9626702d01SEd Tanous         std::find_if(registry.begin(), registry.end(),
977f4eb588SAppaRao Puli                      [&messageKey](const MessageEntry& messageEntry) {
987f4eb588SAppaRao Puli                          return !messageKey.compare(messageEntry.first);
997f4eb588SAppaRao Puli                      });
10026702d01SEd Tanous     if (messageIt != registry.end())
1017f4eb588SAppaRao Puli     {
1027f4eb588SAppaRao Puli         return &messageIt->second;
1037f4eb588SAppaRao Puli     }
1047f4eb588SAppaRao Puli 
1057f4eb588SAppaRao Puli     return nullptr;
1067f4eb588SAppaRao Puli }
1077f4eb588SAppaRao Puli 
1087f4eb588SAppaRao Puli static const Message* formatMessage(const std::string_view& messageID)
1097f4eb588SAppaRao Puli {
1107f4eb588SAppaRao Puli     // Redfish MessageIds are in the form
1117f4eb588SAppaRao Puli     // RegistryName.MajorVersion.MinorVersion.MessageKey, so parse it to find
1127f4eb588SAppaRao Puli     // the right Message
1137f4eb588SAppaRao Puli     std::vector<std::string> fields;
1147f4eb588SAppaRao Puli     fields.reserve(4);
1157f4eb588SAppaRao Puli     boost::split(fields, messageID, boost::is_any_of("."));
1167f4eb588SAppaRao Puli     if (fields.size() != 4)
1177f4eb588SAppaRao Puli     {
1187f4eb588SAppaRao Puli         return nullptr;
1197f4eb588SAppaRao Puli     }
1207f4eb588SAppaRao Puli     std::string& registryName = fields[0];
1217f4eb588SAppaRao Puli     std::string& messageKey = fields[3];
1227f4eb588SAppaRao Puli 
1237f4eb588SAppaRao Puli     // Find the right registry and check it for the MessageKey
124b304bd79SP Dheeraj Srujan Kumar     return getMsgFromRegistry(messageKey, getRegistryFromPrefix(registryName));
1257f4eb588SAppaRao Puli }
1267f4eb588SAppaRao Puli } // namespace message_registries
1277f4eb588SAppaRao Puli 
1287f4eb588SAppaRao Puli namespace event_log
1297f4eb588SAppaRao Puli {
130*2558979cSP Dheeraj Srujan Kumar inline bool getUniqueEntryID(const std::string& logEntry, std::string& entryID)
1317f4eb588SAppaRao Puli {
1327f4eb588SAppaRao Puli     static time_t prevTs = 0;
1337f4eb588SAppaRao Puli     static int index = 0;
1347f4eb588SAppaRao Puli 
1357f4eb588SAppaRao Puli     // Get the entry timestamp
1367f4eb588SAppaRao Puli     std::time_t curTs = 0;
1377f4eb588SAppaRao Puli     std::tm timeStruct = {};
1387f4eb588SAppaRao Puli     std::istringstream entryStream(logEntry);
1397f4eb588SAppaRao Puli     if (entryStream >> std::get_time(&timeStruct, "%Y-%m-%dT%H:%M:%S"))
1407f4eb588SAppaRao Puli     {
1417f4eb588SAppaRao Puli         curTs = std::mktime(&timeStruct);
1427f4eb588SAppaRao Puli         if (curTs == -1)
1437f4eb588SAppaRao Puli         {
1447f4eb588SAppaRao Puli             return false;
1457f4eb588SAppaRao Puli         }
1467f4eb588SAppaRao Puli     }
1477f4eb588SAppaRao Puli     // If the timestamp isn't unique, increment the index
1487f4eb588SAppaRao Puli     index = (curTs == prevTs) ? index + 1 : 0;
1497f4eb588SAppaRao Puli 
1507f4eb588SAppaRao Puli     // Save the timestamp
1517f4eb588SAppaRao Puli     prevTs = curTs;
1527f4eb588SAppaRao Puli 
1537f4eb588SAppaRao Puli     entryID = std::to_string(curTs);
1547f4eb588SAppaRao Puli     if (index > 0)
1557f4eb588SAppaRao Puli     {
1567f4eb588SAppaRao Puli         entryID += "_" + std::to_string(index);
1577f4eb588SAppaRao Puli     }
1587f4eb588SAppaRao Puli     return true;
1597f4eb588SAppaRao Puli }
1607f4eb588SAppaRao Puli 
16123a21a1cSEd Tanous inline int getEventLogParams(const std::string& logEntry,
16223a21a1cSEd Tanous                              std::string& timestamp, std::string& messageID,
1635e715de6SAppaRao Puli                              std::vector<std::string>& messageArgs)
1647f4eb588SAppaRao Puli {
1657f4eb588SAppaRao Puli     // The redfish log format is "<Timestamp> <MessageId>,<MessageArgs>"
1667f4eb588SAppaRao Puli     // First get the Timestamp
167f23b7296SEd Tanous     size_t space = logEntry.find_first_of(' ');
1687f4eb588SAppaRao Puli     if (space == std::string::npos)
1697f4eb588SAppaRao Puli     {
1707f4eb588SAppaRao Puli         return -EINVAL;
1717f4eb588SAppaRao Puli     }
1727f4eb588SAppaRao Puli     timestamp = logEntry.substr(0, space);
1737f4eb588SAppaRao Puli     // Then get the log contents
174f23b7296SEd Tanous     size_t entryStart = logEntry.find_first_not_of(' ', space);
1757f4eb588SAppaRao Puli     if (entryStart == std::string::npos)
1767f4eb588SAppaRao Puli     {
1777f4eb588SAppaRao Puli         return -EINVAL;
1787f4eb588SAppaRao Puli     }
1797f4eb588SAppaRao Puli     std::string_view entry(logEntry);
1807f4eb588SAppaRao Puli     entry.remove_prefix(entryStart);
1817f4eb588SAppaRao Puli     // Use split to separate the entry into its fields
1827f4eb588SAppaRao Puli     std::vector<std::string> logEntryFields;
1837f4eb588SAppaRao Puli     boost::split(logEntryFields, entry, boost::is_any_of(","),
1847f4eb588SAppaRao Puli                  boost::token_compress_on);
1857f4eb588SAppaRao Puli     // We need at least a MessageId to be valid
1867f4eb588SAppaRao Puli     if (logEntryFields.size() < 1)
1877f4eb588SAppaRao Puli     {
1887f4eb588SAppaRao Puli         return -EINVAL;
1897f4eb588SAppaRao Puli     }
1907f4eb588SAppaRao Puli     messageID = logEntryFields[0];
1917f4eb588SAppaRao Puli 
1927f4eb588SAppaRao Puli     // Get the MessageArgs from the log if there are any
1937f4eb588SAppaRao Puli     if (logEntryFields.size() > 1)
1947f4eb588SAppaRao Puli     {
1957f4eb588SAppaRao Puli         std::string& messageArgsStart = logEntryFields[1];
1967f4eb588SAppaRao Puli         // If the first string is empty, assume there are no MessageArgs
1977f4eb588SAppaRao Puli         if (!messageArgsStart.empty())
1987f4eb588SAppaRao Puli         {
1995e715de6SAppaRao Puli             messageArgs.assign(logEntryFields.begin() + 1,
2005e715de6SAppaRao Puli                                logEntryFields.end());
2017f4eb588SAppaRao Puli         }
2027f4eb588SAppaRao Puli     }
2037f4eb588SAppaRao Puli 
2047f4eb588SAppaRao Puli     return 0;
2057f4eb588SAppaRao Puli }
2067f4eb588SAppaRao Puli 
20723a21a1cSEd Tanous inline void getRegistryAndMessageKey(const std::string& messageID,
2087f4eb588SAppaRao Puli                                      std::string& registryName,
2097f4eb588SAppaRao Puli                                      std::string& messageKey)
2107f4eb588SAppaRao Puli {
2117f4eb588SAppaRao Puli     // Redfish MessageIds are in the form
2127f4eb588SAppaRao Puli     // RegistryName.MajorVersion.MinorVersion.MessageKey, so parse it to find
2137f4eb588SAppaRao Puli     // the right Message
2147f4eb588SAppaRao Puli     std::vector<std::string> fields;
2157f4eb588SAppaRao Puli     fields.reserve(4);
2167f4eb588SAppaRao Puli     boost::split(fields, messageID, boost::is_any_of("."));
2177f4eb588SAppaRao Puli     if (fields.size() == 4)
2187f4eb588SAppaRao Puli     {
2197f4eb588SAppaRao Puli         registryName = fields[0];
2207f4eb588SAppaRao Puli         messageKey = fields[3];
2217f4eb588SAppaRao Puli     }
2227f4eb588SAppaRao Puli }
2237f4eb588SAppaRao Puli 
22423a21a1cSEd Tanous inline int formatEventLogEntry(const std::string& logEntryID,
2257f4eb588SAppaRao Puli                                const std::string& messageID,
2265e715de6SAppaRao Puli                                const std::vector<std::string>& messageArgs,
22723a21a1cSEd Tanous                                std::string timestamp,
228b5a76932SEd Tanous                                const std::string& customText,
2297f4eb588SAppaRao Puli                                nlohmann::json& logEntryJson)
2307f4eb588SAppaRao Puli {
2317f4eb588SAppaRao Puli     // Get the Message from the MessageRegistry
2327f4eb588SAppaRao Puli     const message_registries::Message* message =
2337f4eb588SAppaRao Puli         message_registries::formatMessage(messageID);
2347f4eb588SAppaRao Puli 
2357f4eb588SAppaRao Puli     std::string msg;
2367f4eb588SAppaRao Puli     std::string severity;
2377f4eb588SAppaRao Puli     if (message != nullptr)
2387f4eb588SAppaRao Puli     {
2397f4eb588SAppaRao Puli         msg = message->message;
2407f4eb588SAppaRao Puli         severity = message->severity;
2417f4eb588SAppaRao Puli     }
2427f4eb588SAppaRao Puli 
2437f4eb588SAppaRao Puli     // Fill the MessageArgs into the Message
2447f4eb588SAppaRao Puli     int i = 0;
2457f4eb588SAppaRao Puli     for (const std::string& messageArg : messageArgs)
2467f4eb588SAppaRao Puli     {
2477f4eb588SAppaRao Puli         std::string argStr = "%" + std::to_string(++i);
2487f4eb588SAppaRao Puli         size_t argPos = msg.find(argStr);
2497f4eb588SAppaRao Puli         if (argPos != std::string::npos)
2507f4eb588SAppaRao Puli         {
2517f4eb588SAppaRao Puli             msg.replace(argPos, argStr.length(), messageArg);
2527f4eb588SAppaRao Puli         }
2537f4eb588SAppaRao Puli     }
2547f4eb588SAppaRao Puli 
2557f4eb588SAppaRao Puli     // Get the Created time from the timestamp. The log timestamp is in
2567f4eb588SAppaRao Puli     // RFC3339 format which matches the Redfish format except for the
2577f4eb588SAppaRao Puli     // fractional seconds between the '.' and the '+', so just remove them.
258f23b7296SEd Tanous     std::size_t dot = timestamp.find_first_of('.');
259f23b7296SEd Tanous     std::size_t plus = timestamp.find_first_of('+');
2607f4eb588SAppaRao Puli     if (dot != std::string::npos && plus != std::string::npos)
2617f4eb588SAppaRao Puli     {
2627f4eb588SAppaRao Puli         timestamp.erase(dot, plus - dot);
2637f4eb588SAppaRao Puli     }
2647f4eb588SAppaRao Puli 
2657f4eb588SAppaRao Puli     // Fill in the log entry with the gathered data
2667f4eb588SAppaRao Puli     logEntryJson = {{"EventId", logEntryID},
2677f4eb588SAppaRao Puli                     {"EventType", "Event"},
2687f4eb588SAppaRao Puli                     {"Severity", std::move(severity)},
2697f4eb588SAppaRao Puli                     {"Message", std::move(msg)},
270f23b7296SEd Tanous                     {"MessageId", messageID},
271f23b7296SEd Tanous                     {"MessageArgs", messageArgs},
2727f4eb588SAppaRao Puli                     {"EventTimestamp", std::move(timestamp)},
2737f4eb588SAppaRao Puli                     {"Context", customText}};
2747f4eb588SAppaRao Puli     return 0;
2757f4eb588SAppaRao Puli }
2767f4eb588SAppaRao Puli 
2777f4eb588SAppaRao Puli } // namespace event_log
2787f4eb588SAppaRao Puli #endif
2797f4eb588SAppaRao Puli 
28023a21a1cSEd Tanous inline bool isFilterQuerySpecialChar(char c)
28107941a88SAyushi Smriti {
28207941a88SAyushi Smriti     switch (c)
28307941a88SAyushi Smriti     {
28407941a88SAyushi Smriti         case '(':
28507941a88SAyushi Smriti         case ')':
28607941a88SAyushi Smriti         case '\'':
28707941a88SAyushi Smriti             return true;
28807941a88SAyushi Smriti         default:
28907941a88SAyushi Smriti             return false;
29007941a88SAyushi Smriti     }
29107941a88SAyushi Smriti }
29207941a88SAyushi Smriti 
29323a21a1cSEd Tanous inline bool
29423a21a1cSEd Tanous     readSSEQueryParams(std::string sseFilter, std::string& formatType,
29507941a88SAyushi Smriti                        std::vector<std::string>& messageIds,
29607941a88SAyushi Smriti                        std::vector<std::string>& registryPrefixes,
297144b6318SAppaRao Puli                        std::vector<std::string>& metricReportDefinitions)
29807941a88SAyushi Smriti {
29907941a88SAyushi Smriti     sseFilter.erase(std::remove_if(sseFilter.begin(), sseFilter.end(),
30007941a88SAyushi Smriti                                    isFilterQuerySpecialChar),
30107941a88SAyushi Smriti                     sseFilter.end());
30207941a88SAyushi Smriti 
30307941a88SAyushi Smriti     std::vector<std::string> result;
30407941a88SAyushi Smriti     boost::split(result, sseFilter, boost::is_any_of(" "),
30507941a88SAyushi Smriti                  boost::token_compress_on);
30607941a88SAyushi Smriti 
30707941a88SAyushi Smriti     BMCWEB_LOG_DEBUG << "No of tokens in SEE query: " << result.size();
30807941a88SAyushi Smriti 
30907941a88SAyushi Smriti     constexpr uint8_t divisor = 4;
31007941a88SAyushi Smriti     constexpr uint8_t minTokenSize = 3;
31107941a88SAyushi Smriti     if (result.size() % divisor != minTokenSize)
31207941a88SAyushi Smriti     {
31307941a88SAyushi Smriti         BMCWEB_LOG_ERROR << "Invalid SSE filter specified.";
31407941a88SAyushi Smriti         return false;
31507941a88SAyushi Smriti     }
31607941a88SAyushi Smriti 
31707941a88SAyushi Smriti     for (std::size_t i = 0; i < result.size(); i += divisor)
31807941a88SAyushi Smriti     {
31907941a88SAyushi Smriti         std::string& key = result[i];
32007941a88SAyushi Smriti         std::string& op = result[i + 1];
32107941a88SAyushi Smriti         std::string& value = result[i + 2];
32207941a88SAyushi Smriti 
32307941a88SAyushi Smriti         if ((i + minTokenSize) < result.size())
32407941a88SAyushi Smriti         {
3254e0453b1SGunnar Mills             std::string& separator = result[i + minTokenSize];
32607941a88SAyushi Smriti             // SSE supports only "or" and "and" in query params.
3274e0453b1SGunnar Mills             if ((separator != "or") && (separator != "and"))
32807941a88SAyushi Smriti             {
32907941a88SAyushi Smriti                 BMCWEB_LOG_ERROR
33007941a88SAyushi Smriti                     << "Invalid group operator in SSE query parameters";
33107941a88SAyushi Smriti                 return false;
33207941a88SAyushi Smriti             }
33307941a88SAyushi Smriti         }
33407941a88SAyushi Smriti 
33507941a88SAyushi Smriti         // SSE supports only "eq" as per spec.
33607941a88SAyushi Smriti         if (op != "eq")
33707941a88SAyushi Smriti         {
33807941a88SAyushi Smriti             BMCWEB_LOG_ERROR
33907941a88SAyushi Smriti                 << "Invalid assignment operator in SSE query parameters";
34007941a88SAyushi Smriti             return false;
34107941a88SAyushi Smriti         }
34207941a88SAyushi Smriti 
34307941a88SAyushi Smriti         BMCWEB_LOG_DEBUG << key << " : " << value;
34407941a88SAyushi Smriti         if (key == "EventFormatType")
34507941a88SAyushi Smriti         {
34607941a88SAyushi Smriti             formatType = value;
34707941a88SAyushi Smriti         }
34807941a88SAyushi Smriti         else if (key == "MessageId")
34907941a88SAyushi Smriti         {
35007941a88SAyushi Smriti             messageIds.push_back(value);
35107941a88SAyushi Smriti         }
35207941a88SAyushi Smriti         else if (key == "RegistryPrefix")
35307941a88SAyushi Smriti         {
35407941a88SAyushi Smriti             registryPrefixes.push_back(value);
35507941a88SAyushi Smriti         }
35607941a88SAyushi Smriti         else if (key == "MetricReportDefinition")
35707941a88SAyushi Smriti         {
35807941a88SAyushi Smriti             metricReportDefinitions.push_back(value);
35907941a88SAyushi Smriti         }
36007941a88SAyushi Smriti         else
36107941a88SAyushi Smriti         {
36207941a88SAyushi Smriti             BMCWEB_LOG_ERROR << "Invalid property(" << key
36307941a88SAyushi Smriti                              << ")in SSE filter query.";
36407941a88SAyushi Smriti             return false;
36507941a88SAyushi Smriti         }
36607941a88SAyushi Smriti     }
36707941a88SAyushi Smriti     return true;
36807941a88SAyushi Smriti }
36907941a88SAyushi Smriti 
37028afb49cSJunLin Chen class Subscription : public persistent_data::UserSubscription
371b52664e2SAppaRao Puli {
372b52664e2SAppaRao Puli   public:
373b52664e2SAppaRao Puli     Subscription(const Subscription&) = delete;
374b52664e2SAppaRao Puli     Subscription& operator=(const Subscription&) = delete;
375b52664e2SAppaRao Puli     Subscription(Subscription&&) = delete;
376b52664e2SAppaRao Puli     Subscription& operator=(Subscription&&) = delete;
377b52664e2SAppaRao Puli 
378b52664e2SAppaRao Puli     Subscription(const std::string& inHost, const std::string& inPort,
379b52664e2SAppaRao Puli                  const std::string& inPath, const std::string& inUriProto) :
3800b4bdd93SAppaRao Puli         eventSeqNum(1),
3810b4bdd93SAppaRao Puli         host(inHost), port(inPort), path(inPath), uriProto(inUriProto)
382b52664e2SAppaRao Puli     {
3837adb85acSSunitha Harish         // Subscription constructor
384b52664e2SAppaRao Puli     }
3854bbf237fSAppaRao Puli 
38623e64207SEd Tanous     Subscription(const std::shared_ptr<boost::beast::tcp_stream>& adaptor) :
3874bbf237fSAppaRao Puli         eventSeqNum(1)
3884bbf237fSAppaRao Puli     {
3894bbf237fSAppaRao Puli         sseConn = std::make_shared<crow::ServerSentEvents>(adaptor);
3904bbf237fSAppaRao Puli     }
3914bbf237fSAppaRao Puli 
3929f616dd1SEd Tanous     ~Subscription() = default;
393b52664e2SAppaRao Puli 
394b52664e2SAppaRao Puli     void sendEvent(const std::string& msg)
395b52664e2SAppaRao Puli     {
3967adb85acSSunitha Harish         if (conn == nullptr)
3974bbf237fSAppaRao Puli         {
3987adb85acSSunitha Harish             // create the HttpClient connection
3997adb85acSSunitha Harish             conn = std::make_shared<crow::HttpClient>(
4007adb85acSSunitha Harish                 crow::connections::systemBus->get_io_context(), id, host, port,
4017adb85acSSunitha Harish                 path, httpHeaders);
402b52664e2SAppaRao Puli         }
403b52664e2SAppaRao Puli 
4047adb85acSSunitha Harish         conn->sendData(msg);
4057adb85acSSunitha Harish         eventSeqNum++;
4067adb85acSSunitha Harish 
4074bbf237fSAppaRao Puli         if (sseConn != nullptr)
4084bbf237fSAppaRao Puli         {
4094bbf237fSAppaRao Puli             sseConn->sendData(eventSeqNum, msg);
4104bbf237fSAppaRao Puli         }
4114bbf237fSAppaRao Puli     }
4124bbf237fSAppaRao Puli 
4130b4bdd93SAppaRao Puli     void sendTestEventLog()
4140b4bdd93SAppaRao Puli     {
4150b4bdd93SAppaRao Puli         nlohmann::json logEntryArray;
4160b4bdd93SAppaRao Puli         logEntryArray.push_back({});
4170b4bdd93SAppaRao Puli         nlohmann::json& logEntryJson = logEntryArray.back();
4180b4bdd93SAppaRao Puli 
4197c8c4058STejas Patil         logEntryJson = {
4207c8c4058STejas Patil             {"EventId", "TestID"},
4210b4bdd93SAppaRao Puli             {"EventType", "Event"},
4220b4bdd93SAppaRao Puli             {"Severity", "OK"},
4230b4bdd93SAppaRao Puli             {"Message", "Generated test event"},
4244a0bf539SManojkiran Eda             {"MessageId", "OpenBMC.0.2.TestEventLog"},
4250b4bdd93SAppaRao Puli             {"MessageArgs", nlohmann::json::array()},
4267c8c4058STejas Patil             {"EventTimestamp", crow::utility::getDateTimeOffsetNow().first},
4270b4bdd93SAppaRao Puli             {"Context", customText}};
4280b4bdd93SAppaRao Puli 
4290b4bdd93SAppaRao Puli         nlohmann::json msg = {{"@odata.type", "#Event.v1_4_0.Event"},
4300b4bdd93SAppaRao Puli                               {"Id", std::to_string(eventSeqNum)},
4310b4bdd93SAppaRao Puli                               {"Name", "Event Log"},
4320b4bdd93SAppaRao Puli                               {"Events", logEntryArray}};
4330b4bdd93SAppaRao Puli 
43471f52d96SEd Tanous         this->sendEvent(
43571f52d96SEd Tanous             msg.dump(2, ' ', true, nlohmann::json::error_handler_t::replace));
4360b4bdd93SAppaRao Puli     }
4370b4bdd93SAppaRao Puli 
4387f4eb588SAppaRao Puli #ifndef BMCWEB_ENABLE_REDFISH_DBUS_LOG_ENTRIES
4397f4eb588SAppaRao Puli     void filterAndSendEventLogs(
4407f4eb588SAppaRao Puli         const std::vector<EventLogObjectsType>& eventRecords)
4417f4eb588SAppaRao Puli     {
4427f4eb588SAppaRao Puli         nlohmann::json logEntryArray;
4437f4eb588SAppaRao Puli         for (const EventLogObjectsType& logEntry : eventRecords)
4447f4eb588SAppaRao Puli         {
4457f4eb588SAppaRao Puli             const std::string& idStr = std::get<0>(logEntry);
4467f4eb588SAppaRao Puli             const std::string& timestamp = std::get<1>(logEntry);
4477f4eb588SAppaRao Puli             const std::string& messageID = std::get<2>(logEntry);
4487f4eb588SAppaRao Puli             const std::string& registryName = std::get<3>(logEntry);
4497f4eb588SAppaRao Puli             const std::string& messageKey = std::get<4>(logEntry);
4505e715de6SAppaRao Puli             const std::vector<std::string>& messageArgs = std::get<5>(logEntry);
4517f4eb588SAppaRao Puli 
4527f4eb588SAppaRao Puli             // If registryPrefixes list is empty, don't filter events
4537f4eb588SAppaRao Puli             // send everything.
4547f4eb588SAppaRao Puli             if (registryPrefixes.size())
4557f4eb588SAppaRao Puli             {
4567f4eb588SAppaRao Puli                 auto obj = std::find(registryPrefixes.begin(),
4577f4eb588SAppaRao Puli                                      registryPrefixes.end(), registryName);
4587f4eb588SAppaRao Puli                 if (obj == registryPrefixes.end())
4597f4eb588SAppaRao Puli                 {
4607f4eb588SAppaRao Puli                     continue;
4617f4eb588SAppaRao Puli                 }
4627f4eb588SAppaRao Puli             }
4637f4eb588SAppaRao Puli 
4647f4eb588SAppaRao Puli             // If registryMsgIds list is empty, don't filter events
4657f4eb588SAppaRao Puli             // send everything.
4667f4eb588SAppaRao Puli             if (registryMsgIds.size())
4677f4eb588SAppaRao Puli             {
4687f4eb588SAppaRao Puli                 auto obj = std::find(registryMsgIds.begin(),
4697f4eb588SAppaRao Puli                                      registryMsgIds.end(), messageKey);
4707f4eb588SAppaRao Puli                 if (obj == registryMsgIds.end())
4717f4eb588SAppaRao Puli                 {
4727f4eb588SAppaRao Puli                     continue;
4737f4eb588SAppaRao Puli                 }
4747f4eb588SAppaRao Puli             }
4757f4eb588SAppaRao Puli 
4767f4eb588SAppaRao Puli             logEntryArray.push_back({});
4777f4eb588SAppaRao Puli             nlohmann::json& bmcLogEntry = logEntryArray.back();
4787f4eb588SAppaRao Puli             if (event_log::formatEventLogEntry(idStr, messageID, messageArgs,
4797f4eb588SAppaRao Puli                                                timestamp, customText,
4807f4eb588SAppaRao Puli                                                bmcLogEntry) != 0)
4817f4eb588SAppaRao Puli             {
4827f4eb588SAppaRao Puli                 BMCWEB_LOG_DEBUG << "Read eventLog entry failed";
4837f4eb588SAppaRao Puli                 continue;
4847f4eb588SAppaRao Puli             }
4857f4eb588SAppaRao Puli         }
4867f4eb588SAppaRao Puli 
4877f4eb588SAppaRao Puli         if (logEntryArray.size() < 1)
4887f4eb588SAppaRao Puli         {
4897f4eb588SAppaRao Puli             BMCWEB_LOG_DEBUG << "No log entries available to be transferred.";
4907f4eb588SAppaRao Puli             return;
4917f4eb588SAppaRao Puli         }
4927f4eb588SAppaRao Puli 
4937f4eb588SAppaRao Puli         nlohmann::json msg = {{"@odata.type", "#Event.v1_4_0.Event"},
4947f4eb588SAppaRao Puli                               {"Id", std::to_string(eventSeqNum)},
4957f4eb588SAppaRao Puli                               {"Name", "Event Log"},
4967f4eb588SAppaRao Puli                               {"Events", logEntryArray}};
4977f4eb588SAppaRao Puli 
49871f52d96SEd Tanous         this->sendEvent(
49971f52d96SEd Tanous             msg.dump(2, ' ', true, nlohmann::json::error_handler_t::replace));
5007f4eb588SAppaRao Puli     }
5017f4eb588SAppaRao Puli #endif
5027f4eb588SAppaRao Puli 
503c0353249SWludzik, Jozef     void filterAndSendReports(
504c0353249SWludzik, Jozef         const std::string& id,
505c0353249SWludzik, Jozef         const std::variant<telemetry::TimestampReadings>& var)
506156d6b00SAppaRao Puli     {
507c0353249SWludzik, Jozef         std::string mrdUri = telemetry::metricReportDefinitionUri + ("/" + id);
508156d6b00SAppaRao Puli 
509156d6b00SAppaRao Puli         // Empty list means no filter. Send everything.
510156d6b00SAppaRao Puli         if (metricReportDefinitions.size())
511156d6b00SAppaRao Puli         {
512156d6b00SAppaRao Puli             if (std::find(metricReportDefinitions.begin(),
513156d6b00SAppaRao Puli                           metricReportDefinitions.end(),
514c0353249SWludzik, Jozef                           mrdUri) == metricReportDefinitions.end())
515156d6b00SAppaRao Puli             {
516156d6b00SAppaRao Puli                 return;
517156d6b00SAppaRao Puli             }
518156d6b00SAppaRao Puli         }
519156d6b00SAppaRao Puli 
520c0353249SWludzik, Jozef         nlohmann::json msg;
521c0353249SWludzik, Jozef         if (!telemetry::fillReport(msg, id, var))
522156d6b00SAppaRao Puli         {
523c0353249SWludzik, Jozef             BMCWEB_LOG_ERROR << "Failed to fill the MetricReport for DBus "
524c0353249SWludzik, Jozef                                 "Report with id "
525c0353249SWludzik, Jozef                              << id;
526c0353249SWludzik, Jozef             return;
527156d6b00SAppaRao Puli         }
528156d6b00SAppaRao Puli 
52971f52d96SEd Tanous         this->sendEvent(
53071f52d96SEd Tanous             msg.dump(2, ' ', true, nlohmann::json::error_handler_t::replace));
531156d6b00SAppaRao Puli     }
532156d6b00SAppaRao Puli 
533fe44eb0bSAyushi Smriti     void updateRetryConfig(const uint32_t retryAttempts,
534fe44eb0bSAyushi Smriti                            const uint32_t retryTimeoutInterval)
535fe44eb0bSAyushi Smriti     {
53662de0c68SAppaRao Puli         if (conn != nullptr)
53762de0c68SAppaRao Puli         {
538fe44eb0bSAyushi Smriti             conn->setRetryConfig(retryAttempts, retryTimeoutInterval);
539fe44eb0bSAyushi Smriti         }
54062de0c68SAppaRao Puli     }
541fe44eb0bSAyushi Smriti 
542fe44eb0bSAyushi Smriti     void updateRetryPolicy()
543fe44eb0bSAyushi Smriti     {
54462de0c68SAppaRao Puli         if (conn != nullptr)
54562de0c68SAppaRao Puli         {
546fe44eb0bSAyushi Smriti             conn->setRetryPolicy(retryPolicy);
547fe44eb0bSAyushi Smriti         }
54862de0c68SAppaRao Puli     }
549fe44eb0bSAyushi Smriti 
55096330b99SSunitha Harish     uint64_t getEventSeqNum()
55196330b99SSunitha Harish     {
55296330b99SSunitha Harish         return eventSeqNum;
55396330b99SSunitha Harish     }
55496330b99SSunitha Harish 
555b52664e2SAppaRao Puli   private:
5560b4bdd93SAppaRao Puli     uint64_t eventSeqNum;
557b52664e2SAppaRao Puli     std::string host;
558b52664e2SAppaRao Puli     std::string port;
559b52664e2SAppaRao Puli     std::string path;
560b52664e2SAppaRao Puli     std::string uriProto;
5614bbf237fSAppaRao Puli     std::shared_ptr<crow::HttpClient> conn = nullptr;
5624bbf237fSAppaRao Puli     std::shared_ptr<crow::ServerSentEvents> sseConn = nullptr;
563b52664e2SAppaRao Puli };
564b52664e2SAppaRao Puli 
565b52664e2SAppaRao Puli class EventServiceManager
566b52664e2SAppaRao Puli {
567b52664e2SAppaRao Puli   private:
5687d1cc387SAppaRao Puli     bool serviceEnabled;
5697d1cc387SAppaRao Puli     uint32_t retryAttempts;
5707d1cc387SAppaRao Puli     uint32_t retryTimeoutInterval;
5717d1cc387SAppaRao Puli 
5729f616dd1SEd Tanous     EventServiceManager()
573b52664e2SAppaRao Puli     {
5741bf712bcSAyushi Smriti         // Load config from persist store.
5751bf712bcSAyushi Smriti         initConfig();
576b52664e2SAppaRao Puli     }
577b52664e2SAppaRao Puli 
578*2558979cSP Dheeraj Srujan Kumar     std::streampos redfishLogFilePosition{0};
5799f616dd1SEd Tanous     size_t noOfEventLogSubscribers{0};
5809f616dd1SEd Tanous     size_t noOfMetricReportSubscribers{0};
581156d6b00SAppaRao Puli     std::shared_ptr<sdbusplus::bus::match::match> matchTelemetryMonitor;
582b52664e2SAppaRao Puli     boost::container::flat_map<std::string, std::shared_ptr<Subscription>>
583b52664e2SAppaRao Puli         subscriptionsMap;
584b52664e2SAppaRao Puli 
5859f616dd1SEd Tanous     uint64_t eventId{1};
58696330b99SSunitha Harish 
587b52664e2SAppaRao Puli   public:
5889f616dd1SEd Tanous     EventServiceManager(const EventServiceManager&) = delete;
5899f616dd1SEd Tanous     EventServiceManager& operator=(const EventServiceManager&) = delete;
5909f616dd1SEd Tanous     EventServiceManager(EventServiceManager&&) = delete;
5919f616dd1SEd Tanous     EventServiceManager& operator=(EventServiceManager&&) = delete;
5929f616dd1SEd Tanous 
593b52664e2SAppaRao Puli     static EventServiceManager& getInstance()
594b52664e2SAppaRao Puli     {
595b52664e2SAppaRao Puli         static EventServiceManager handler;
596b52664e2SAppaRao Puli         return handler;
597b52664e2SAppaRao Puli     }
598b52664e2SAppaRao Puli 
5991bf712bcSAyushi Smriti     void initConfig()
6001bf712bcSAyushi Smriti     {
60128afb49cSJunLin Chen         loadOldBehavior();
6021bf712bcSAyushi Smriti 
60328afb49cSJunLin Chen         persistent_data::EventServiceConfig eventServiceConfig =
60428afb49cSJunLin Chen             persistent_data::EventServiceStore::getInstance()
60528afb49cSJunLin Chen                 .getEventServiceConfig();
6061bf712bcSAyushi Smriti 
60728afb49cSJunLin Chen         serviceEnabled = eventServiceConfig.enabled;
60828afb49cSJunLin Chen         retryAttempts = eventServiceConfig.retryAttempts;
60928afb49cSJunLin Chen         retryTimeoutInterval = eventServiceConfig.retryTimeoutInterval;
6101bf712bcSAyushi Smriti 
61128afb49cSJunLin Chen         for (const auto& it : persistent_data::EventServiceStore::getInstance()
61228afb49cSJunLin Chen                                   .subscriptionsConfigMap)
6131bf712bcSAyushi Smriti         {
61428afb49cSJunLin Chen             std::shared_ptr<persistent_data::UserSubscription> newSub =
61528afb49cSJunLin Chen                 it.second;
6164bbf237fSAppaRao Puli 
6171bf712bcSAyushi Smriti             std::string host;
6181bf712bcSAyushi Smriti             std::string urlProto;
6191bf712bcSAyushi Smriti             std::string port;
6201bf712bcSAyushi Smriti             std::string path;
62128afb49cSJunLin Chen             bool status = validateAndSplitUrl(newSub->destinationUrl, urlProto,
62228afb49cSJunLin Chen                                               host, port, path);
6231bf712bcSAyushi Smriti 
6241bf712bcSAyushi Smriti             if (!status)
6251bf712bcSAyushi Smriti             {
6261bf712bcSAyushi Smriti                 BMCWEB_LOG_ERROR
6271bf712bcSAyushi Smriti                     << "Failed to validate and split destination url";
6281bf712bcSAyushi Smriti                 continue;
6291bf712bcSAyushi Smriti             }
6301bf712bcSAyushi Smriti             std::shared_ptr<Subscription> subValue =
6311bf712bcSAyushi Smriti                 std::make_shared<Subscription>(host, port, path, urlProto);
6321bf712bcSAyushi Smriti 
63328afb49cSJunLin Chen             subValue->id = newSub->id;
63428afb49cSJunLin Chen             subValue->destinationUrl = newSub->destinationUrl;
63528afb49cSJunLin Chen             subValue->protocol = newSub->protocol;
63628afb49cSJunLin Chen             subValue->retryPolicy = newSub->retryPolicy;
63728afb49cSJunLin Chen             subValue->customText = newSub->customText;
63828afb49cSJunLin Chen             subValue->eventFormatType = newSub->eventFormatType;
63928afb49cSJunLin Chen             subValue->subscriptionType = newSub->subscriptionType;
64028afb49cSJunLin Chen             subValue->registryMsgIds = newSub->registryMsgIds;
64128afb49cSJunLin Chen             subValue->registryPrefixes = newSub->registryPrefixes;
64228afb49cSJunLin Chen             subValue->resourceTypes = newSub->resourceTypes;
64328afb49cSJunLin Chen             subValue->httpHeaders = newSub->httpHeaders;
64428afb49cSJunLin Chen             subValue->metricReportDefinitions = newSub->metricReportDefinitions;
6451bf712bcSAyushi Smriti 
64628afb49cSJunLin Chen             if (subValue->id.empty())
6471bf712bcSAyushi Smriti             {
6481bf712bcSAyushi Smriti                 BMCWEB_LOG_ERROR << "Failed to add subscription";
6491bf712bcSAyushi Smriti             }
65028afb49cSJunLin Chen             subscriptionsMap.insert(std::pair(subValue->id, subValue));
65128afb49cSJunLin Chen 
65228afb49cSJunLin Chen             updateNoOfSubscribersCount();
65328afb49cSJunLin Chen 
65428afb49cSJunLin Chen #ifndef BMCWEB_ENABLE_REDFISH_DBUS_LOG_ENTRIES
655*2558979cSP Dheeraj Srujan Kumar 
656*2558979cSP Dheeraj Srujan Kumar             cacheRedfishLogFile();
657*2558979cSP Dheeraj Srujan Kumar 
65828afb49cSJunLin Chen #endif
65928afb49cSJunLin Chen             // Update retry configuration.
66028afb49cSJunLin Chen             subValue->updateRetryConfig(retryAttempts, retryTimeoutInterval);
66128afb49cSJunLin Chen             subValue->updateRetryPolicy();
6621bf712bcSAyushi Smriti         }
6631bf712bcSAyushi Smriti         return;
6641bf712bcSAyushi Smriti     }
6651bf712bcSAyushi Smriti 
66628afb49cSJunLin Chen     void loadOldBehavior()
667b52664e2SAppaRao Puli     {
66828afb49cSJunLin Chen         std::ifstream eventConfigFile(eventServiceFile);
66928afb49cSJunLin Chen         if (!eventConfigFile.good())
6701bf712bcSAyushi Smriti         {
67128afb49cSJunLin Chen             BMCWEB_LOG_DEBUG << "Old eventService config not exist";
67228afb49cSJunLin Chen             return;
67328afb49cSJunLin Chen         }
67428afb49cSJunLin Chen         auto jsonData = nlohmann::json::parse(eventConfigFile, nullptr, false);
67528afb49cSJunLin Chen         if (jsonData.is_discarded())
6764bbf237fSAppaRao Puli         {
67728afb49cSJunLin Chen             BMCWEB_LOG_ERROR << "Old eventService config parse error.";
67828afb49cSJunLin Chen             return;
67928afb49cSJunLin Chen         }
68028afb49cSJunLin Chen 
68128afb49cSJunLin Chen         for (const auto& item : jsonData.items())
68228afb49cSJunLin Chen         {
68328afb49cSJunLin Chen             if (item.key() == "Configuration")
68428afb49cSJunLin Chen             {
68528afb49cSJunLin Chen                 persistent_data::EventServiceStore::getInstance()
68628afb49cSJunLin Chen                     .getEventServiceConfig()
68728afb49cSJunLin Chen                     .fromJson(item.value());
68828afb49cSJunLin Chen             }
68928afb49cSJunLin Chen             else if (item.key() == "Subscriptions")
69028afb49cSJunLin Chen             {
69128afb49cSJunLin Chen                 for (const auto& elem : item.value())
69228afb49cSJunLin Chen                 {
69328afb49cSJunLin Chen                     std::shared_ptr<persistent_data::UserSubscription>
69428afb49cSJunLin Chen                         newSubscription =
69528afb49cSJunLin Chen                             persistent_data::UserSubscription::fromJson(elem,
69628afb49cSJunLin Chen                                                                         true);
69728afb49cSJunLin Chen                     if (newSubscription == nullptr)
69828afb49cSJunLin Chen                     {
69928afb49cSJunLin Chen                         BMCWEB_LOG_ERROR << "Problem reading subscription "
70028afb49cSJunLin Chen                                             "from old persistent store";
7014bbf237fSAppaRao Puli                         continue;
7024bbf237fSAppaRao Puli                     }
7031bf712bcSAyushi Smriti 
70428afb49cSJunLin Chen                     std::uniform_int_distribution<uint32_t> dist(0);
70528afb49cSJunLin Chen                     bmcweb::OpenSSLGenerator gen;
7061bf712bcSAyushi Smriti 
70728afb49cSJunLin Chen                     std::string id;
7081bf712bcSAyushi Smriti 
70928afb49cSJunLin Chen                     int retry = 3;
71028afb49cSJunLin Chen                     while (retry)
7111bf712bcSAyushi Smriti                     {
71228afb49cSJunLin Chen                         id = std::to_string(dist(gen));
71328afb49cSJunLin Chen                         if (gen.error())
7147d1cc387SAppaRao Puli                         {
71528afb49cSJunLin Chen                             retry = 0;
71628afb49cSJunLin Chen                             break;
71728afb49cSJunLin Chen                         }
71828afb49cSJunLin Chen                         newSubscription->id = id;
71928afb49cSJunLin Chen                         auto inserted =
72028afb49cSJunLin Chen                             persistent_data::EventServiceStore::getInstance()
72128afb49cSJunLin Chen                                 .subscriptionsConfigMap.insert(
72228afb49cSJunLin Chen                                     std::pair(id, newSubscription));
72328afb49cSJunLin Chen                         if (inserted.second)
72428afb49cSJunLin Chen                         {
72528afb49cSJunLin Chen                             break;
72628afb49cSJunLin Chen                         }
72728afb49cSJunLin Chen                         --retry;
7287d1cc387SAppaRao Puli                     }
7297d1cc387SAppaRao Puli 
73028afb49cSJunLin Chen                     if (retry <= 0)
73128afb49cSJunLin Chen                     {
73228afb49cSJunLin Chen                         BMCWEB_LOG_ERROR
73328afb49cSJunLin Chen                             << "Failed to generate random number from old "
73428afb49cSJunLin Chen                                "persistent store";
73528afb49cSJunLin Chen                         continue;
73628afb49cSJunLin Chen                     }
73728afb49cSJunLin Chen                 }
73828afb49cSJunLin Chen             }
73928afb49cSJunLin Chen 
74028afb49cSJunLin Chen             persistent_data::getConfig().writeData();
74128afb49cSJunLin Chen             std::remove(eventServiceFile);
74228afb49cSJunLin Chen             BMCWEB_LOG_DEBUG << "Remove old eventservice config";
74328afb49cSJunLin Chen         }
74428afb49cSJunLin Chen     }
74528afb49cSJunLin Chen 
74628afb49cSJunLin Chen     void updateSubscriptionData()
74728afb49cSJunLin Chen     {
74828afb49cSJunLin Chen         persistent_data::EventServiceStore::getInstance()
74928afb49cSJunLin Chen             .eventServiceConfig.enabled = serviceEnabled;
75028afb49cSJunLin Chen         persistent_data::EventServiceStore::getInstance()
75128afb49cSJunLin Chen             .eventServiceConfig.retryAttempts = retryAttempts;
75228afb49cSJunLin Chen         persistent_data::EventServiceStore::getInstance()
75328afb49cSJunLin Chen             .eventServiceConfig.retryTimeoutInterval = retryTimeoutInterval;
75428afb49cSJunLin Chen 
75528afb49cSJunLin Chen         persistent_data::getConfig().writeData();
75628afb49cSJunLin Chen     }
75728afb49cSJunLin Chen 
75828afb49cSJunLin Chen     void setEventServiceConfig(const persistent_data::EventServiceConfig& cfg)
7597d1cc387SAppaRao Puli     {
7607d1cc387SAppaRao Puli         bool updateConfig = false;
761fe44eb0bSAyushi Smriti         bool updateRetryCfg = false;
7627d1cc387SAppaRao Puli 
76328afb49cSJunLin Chen         if (serviceEnabled != cfg.enabled)
7647d1cc387SAppaRao Puli         {
76528afb49cSJunLin Chen             serviceEnabled = cfg.enabled;
7667d1cc387SAppaRao Puli             if (serviceEnabled && noOfMetricReportSubscribers)
7677d1cc387SAppaRao Puli             {
7687d1cc387SAppaRao Puli                 registerMetricReportSignal();
7697d1cc387SAppaRao Puli             }
7707d1cc387SAppaRao Puli             else
7717d1cc387SAppaRao Puli             {
7727d1cc387SAppaRao Puli                 unregisterMetricReportSignal();
7737d1cc387SAppaRao Puli             }
7747d1cc387SAppaRao Puli             updateConfig = true;
7757d1cc387SAppaRao Puli         }
7767d1cc387SAppaRao Puli 
77728afb49cSJunLin Chen         if (retryAttempts != cfg.retryAttempts)
7787d1cc387SAppaRao Puli         {
77928afb49cSJunLin Chen             retryAttempts = cfg.retryAttempts;
7807d1cc387SAppaRao Puli             updateConfig = true;
781fe44eb0bSAyushi Smriti             updateRetryCfg = true;
7827d1cc387SAppaRao Puli         }
7837d1cc387SAppaRao Puli 
78428afb49cSJunLin Chen         if (retryTimeoutInterval != cfg.retryTimeoutInterval)
7857d1cc387SAppaRao Puli         {
78628afb49cSJunLin Chen             retryTimeoutInterval = cfg.retryTimeoutInterval;
7877d1cc387SAppaRao Puli             updateConfig = true;
788fe44eb0bSAyushi Smriti             updateRetryCfg = true;
7897d1cc387SAppaRao Puli         }
7907d1cc387SAppaRao Puli 
7917d1cc387SAppaRao Puli         if (updateConfig)
7927d1cc387SAppaRao Puli         {
7937d1cc387SAppaRao Puli             updateSubscriptionData();
7947d1cc387SAppaRao Puli         }
795fe44eb0bSAyushi Smriti 
796fe44eb0bSAyushi Smriti         if (updateRetryCfg)
797fe44eb0bSAyushi Smriti         {
798fe44eb0bSAyushi Smriti             // Update the changed retry config to all subscriptions
799fe44eb0bSAyushi Smriti             for (const auto& it :
800fe44eb0bSAyushi Smriti                  EventServiceManager::getInstance().subscriptionsMap)
801fe44eb0bSAyushi Smriti             {
802fe44eb0bSAyushi Smriti                 std::shared_ptr<Subscription> entry = it.second;
803fe44eb0bSAyushi Smriti                 entry->updateRetryConfig(retryAttempts, retryTimeoutInterval);
804fe44eb0bSAyushi Smriti             }
805fe44eb0bSAyushi Smriti         }
8067d1cc387SAppaRao Puli     }
8077d1cc387SAppaRao Puli 
8087d1cc387SAppaRao Puli     void updateNoOfSubscribersCount()
8097d1cc387SAppaRao Puli     {
8107d1cc387SAppaRao Puli         size_t eventLogSubCount = 0;
8117d1cc387SAppaRao Puli         size_t metricReportSubCount = 0;
8127d1cc387SAppaRao Puli         for (const auto& it : subscriptionsMap)
8137d1cc387SAppaRao Puli         {
8147d1cc387SAppaRao Puli             std::shared_ptr<Subscription> entry = it.second;
8157d1cc387SAppaRao Puli             if (entry->eventFormatType == eventFormatType)
8167d1cc387SAppaRao Puli             {
8177d1cc387SAppaRao Puli                 eventLogSubCount++;
8187d1cc387SAppaRao Puli             }
8197d1cc387SAppaRao Puli             else if (entry->eventFormatType == metricReportFormatType)
8207d1cc387SAppaRao Puli             {
8217d1cc387SAppaRao Puli                 metricReportSubCount++;
8227d1cc387SAppaRao Puli             }
8237d1cc387SAppaRao Puli         }
8247d1cc387SAppaRao Puli 
8257d1cc387SAppaRao Puli         noOfEventLogSubscribers = eventLogSubCount;
8267d1cc387SAppaRao Puli         if (noOfMetricReportSubscribers != metricReportSubCount)
8277d1cc387SAppaRao Puli         {
8287d1cc387SAppaRao Puli             noOfMetricReportSubscribers = metricReportSubCount;
8297d1cc387SAppaRao Puli             if (noOfMetricReportSubscribers)
8307d1cc387SAppaRao Puli             {
8317d1cc387SAppaRao Puli                 registerMetricReportSignal();
8327d1cc387SAppaRao Puli             }
8337d1cc387SAppaRao Puli             else
8347d1cc387SAppaRao Puli             {
8357d1cc387SAppaRao Puli                 unregisterMetricReportSignal();
8367d1cc387SAppaRao Puli             }
8377d1cc387SAppaRao Puli         }
8387d1cc387SAppaRao Puli     }
8397d1cc387SAppaRao Puli 
840b52664e2SAppaRao Puli     std::shared_ptr<Subscription> getSubscription(const std::string& id)
841b52664e2SAppaRao Puli     {
842b52664e2SAppaRao Puli         auto obj = subscriptionsMap.find(id);
843b52664e2SAppaRao Puli         if (obj == subscriptionsMap.end())
844b52664e2SAppaRao Puli         {
845b52664e2SAppaRao Puli             BMCWEB_LOG_ERROR << "No subscription exist with ID:" << id;
846b52664e2SAppaRao Puli             return nullptr;
847b52664e2SAppaRao Puli         }
848b52664e2SAppaRao Puli         std::shared_ptr<Subscription> subValue = obj->second;
849b52664e2SAppaRao Puli         return subValue;
850b52664e2SAppaRao Puli     }
851b52664e2SAppaRao Puli 
852b5a76932SEd Tanous     std::string addSubscription(const std::shared_ptr<Subscription>& subValue,
8531bf712bcSAyushi Smriti                                 const bool updateFile = true)
854b52664e2SAppaRao Puli     {
855fc76b8acSEd Tanous 
856fc76b8acSEd Tanous         std::uniform_int_distribution<uint32_t> dist(0);
857fc76b8acSEd Tanous         bmcweb::OpenSSLGenerator gen;
858fc76b8acSEd Tanous 
859b52664e2SAppaRao Puli         std::string id;
860b52664e2SAppaRao Puli 
861b52664e2SAppaRao Puli         int retry = 3;
862b52664e2SAppaRao Puli         while (retry)
863b52664e2SAppaRao Puli         {
864fc76b8acSEd Tanous             id = std::to_string(dist(gen));
865fc76b8acSEd Tanous             if (gen.error())
866fc76b8acSEd Tanous             {
867fc76b8acSEd Tanous                 retry = 0;
868fc76b8acSEd Tanous                 break;
869fc76b8acSEd Tanous             }
870b52664e2SAppaRao Puli             auto inserted = subscriptionsMap.insert(std::pair(id, subValue));
871b52664e2SAppaRao Puli             if (inserted.second)
872b52664e2SAppaRao Puli             {
873b52664e2SAppaRao Puli                 break;
874b52664e2SAppaRao Puli             }
875b52664e2SAppaRao Puli             --retry;
87623a21a1cSEd Tanous         }
877b52664e2SAppaRao Puli 
878b52664e2SAppaRao Puli         if (retry <= 0)
879b52664e2SAppaRao Puli         {
880b52664e2SAppaRao Puli             BMCWEB_LOG_ERROR << "Failed to generate random number";
881abb93cddSEd Tanous             return "";
882b52664e2SAppaRao Puli         }
883b52664e2SAppaRao Puli 
88428afb49cSJunLin Chen         std::shared_ptr<persistent_data::UserSubscription> newSub =
88528afb49cSJunLin Chen             std::make_shared<persistent_data::UserSubscription>();
88628afb49cSJunLin Chen         newSub->id = id;
88728afb49cSJunLin Chen         newSub->destinationUrl = subValue->destinationUrl;
88828afb49cSJunLin Chen         newSub->protocol = subValue->protocol;
88928afb49cSJunLin Chen         newSub->retryPolicy = subValue->retryPolicy;
89028afb49cSJunLin Chen         newSub->customText = subValue->customText;
89128afb49cSJunLin Chen         newSub->eventFormatType = subValue->eventFormatType;
89228afb49cSJunLin Chen         newSub->subscriptionType = subValue->subscriptionType;
89328afb49cSJunLin Chen         newSub->registryMsgIds = subValue->registryMsgIds;
89428afb49cSJunLin Chen         newSub->registryPrefixes = subValue->registryPrefixes;
89528afb49cSJunLin Chen         newSub->resourceTypes = subValue->resourceTypes;
89628afb49cSJunLin Chen         newSub->httpHeaders = subValue->httpHeaders;
89728afb49cSJunLin Chen         newSub->metricReportDefinitions = subValue->metricReportDefinitions;
89828afb49cSJunLin Chen         persistent_data::EventServiceStore::getInstance()
89928afb49cSJunLin Chen             .subscriptionsConfigMap.emplace(newSub->id, newSub);
90028afb49cSJunLin Chen 
9017d1cc387SAppaRao Puli         updateNoOfSubscribersCount();
9021bf712bcSAyushi Smriti 
9031bf712bcSAyushi Smriti         if (updateFile)
9041bf712bcSAyushi Smriti         {
905b52664e2SAppaRao Puli             updateSubscriptionData();
9061bf712bcSAyushi Smriti         }
9077f4eb588SAppaRao Puli 
9087f4eb588SAppaRao Puli #ifndef BMCWEB_ENABLE_REDFISH_DBUS_LOG_ENTRIES
909*2558979cSP Dheeraj Srujan Kumar         if (redfishLogFilePosition != 0)
9107f4eb588SAppaRao Puli         {
911*2558979cSP Dheeraj Srujan Kumar             cacheRedfishLogFile();
9127f4eb588SAppaRao Puli         }
9137f4eb588SAppaRao Puli #endif
914fe44eb0bSAyushi Smriti         // Update retry configuration.
915fe44eb0bSAyushi Smriti         subValue->updateRetryConfig(retryAttempts, retryTimeoutInterval);
916fe44eb0bSAyushi Smriti         subValue->updateRetryPolicy();
917fe44eb0bSAyushi Smriti 
918b52664e2SAppaRao Puli         return id;
919b52664e2SAppaRao Puli     }
920b52664e2SAppaRao Puli 
921b52664e2SAppaRao Puli     bool isSubscriptionExist(const std::string& id)
922b52664e2SAppaRao Puli     {
923b52664e2SAppaRao Puli         auto obj = subscriptionsMap.find(id);
924b52664e2SAppaRao Puli         if (obj == subscriptionsMap.end())
925b52664e2SAppaRao Puli         {
926b52664e2SAppaRao Puli             return false;
927b52664e2SAppaRao Puli         }
928b52664e2SAppaRao Puli         return true;
929b52664e2SAppaRao Puli     }
930b52664e2SAppaRao Puli 
931b52664e2SAppaRao Puli     void deleteSubscription(const std::string& id)
932b52664e2SAppaRao Puli     {
933b52664e2SAppaRao Puli         auto obj = subscriptionsMap.find(id);
934b52664e2SAppaRao Puli         if (obj != subscriptionsMap.end())
935b52664e2SAppaRao Puli         {
936b52664e2SAppaRao Puli             subscriptionsMap.erase(obj);
93728afb49cSJunLin Chen             auto obj2 = persistent_data::EventServiceStore::getInstance()
93828afb49cSJunLin Chen                             .subscriptionsConfigMap.find(id);
93928afb49cSJunLin Chen             persistent_data::EventServiceStore::getInstance()
94028afb49cSJunLin Chen                 .subscriptionsConfigMap.erase(obj2);
9417d1cc387SAppaRao Puli             updateNoOfSubscribersCount();
942b52664e2SAppaRao Puli             updateSubscriptionData();
943b52664e2SAppaRao Puli         }
944b52664e2SAppaRao Puli     }
945b52664e2SAppaRao Puli 
946b52664e2SAppaRao Puli     size_t getNumberOfSubscriptions()
947b52664e2SAppaRao Puli     {
948b52664e2SAppaRao Puli         return subscriptionsMap.size();
949b52664e2SAppaRao Puli     }
950b52664e2SAppaRao Puli 
951b52664e2SAppaRao Puli     std::vector<std::string> getAllIDs()
952b52664e2SAppaRao Puli     {
953b52664e2SAppaRao Puli         std::vector<std::string> idList;
954b52664e2SAppaRao Puli         for (const auto& it : subscriptionsMap)
955b52664e2SAppaRao Puli         {
956b52664e2SAppaRao Puli             idList.emplace_back(it.first);
957b52664e2SAppaRao Puli         }
958b52664e2SAppaRao Puli         return idList;
959b52664e2SAppaRao Puli     }
960b52664e2SAppaRao Puli 
961b52664e2SAppaRao Puli     bool isDestinationExist(const std::string& destUrl)
962b52664e2SAppaRao Puli     {
963b52664e2SAppaRao Puli         for (const auto& it : subscriptionsMap)
964b52664e2SAppaRao Puli         {
965b52664e2SAppaRao Puli             std::shared_ptr<Subscription> entry = it.second;
966b52664e2SAppaRao Puli             if (entry->destinationUrl == destUrl)
967b52664e2SAppaRao Puli             {
968b52664e2SAppaRao Puli                 BMCWEB_LOG_ERROR << "Destination exist already" << destUrl;
969b52664e2SAppaRao Puli                 return true;
970b52664e2SAppaRao Puli             }
971b52664e2SAppaRao Puli         }
972b52664e2SAppaRao Puli         return false;
973b52664e2SAppaRao Puli     }
9740b4bdd93SAppaRao Puli 
9750b4bdd93SAppaRao Puli     void sendTestEventLog()
9760b4bdd93SAppaRao Puli     {
9770b4bdd93SAppaRao Puli         for (const auto& it : this->subscriptionsMap)
9780b4bdd93SAppaRao Puli         {
9790b4bdd93SAppaRao Puli             std::shared_ptr<Subscription> entry = it.second;
9800b4bdd93SAppaRao Puli             entry->sendTestEventLog();
9810b4bdd93SAppaRao Puli         }
9820b4bdd93SAppaRao Puli     }
983e9a14131SAppaRao Puli 
98496330b99SSunitha Harish     void sendEvent(const nlohmann::json& eventMessageIn,
98596330b99SSunitha Harish                    const std::string& origin, const std::string& resType)
98696330b99SSunitha Harish     {
98796330b99SSunitha Harish         nlohmann::json eventRecord = nlohmann::json::array();
98896330b99SSunitha Harish         nlohmann::json eventMessage = eventMessageIn;
98996330b99SSunitha Harish         // MemberId is 0 : since we are sending one event record.
99096330b99SSunitha Harish         uint64_t memberId = 0;
99196330b99SSunitha Harish 
99296330b99SSunitha Harish         nlohmann::json event = {
99396330b99SSunitha Harish             {"EventId", eventId},
99496330b99SSunitha Harish             {"MemberId", memberId},
9957c8c4058STejas Patil             {"EventTimestamp", crow::utility::getDateTimeOffsetNow().first},
99696330b99SSunitha Harish             {"OriginOfCondition", origin}};
99796330b99SSunitha Harish         for (nlohmann::json::iterator it = event.begin(); it != event.end();
99896330b99SSunitha Harish              ++it)
99996330b99SSunitha Harish         {
100096330b99SSunitha Harish             eventMessage[it.key()] = it.value();
100196330b99SSunitha Harish         }
100296330b99SSunitha Harish         eventRecord.push_back(eventMessage);
100396330b99SSunitha Harish 
100496330b99SSunitha Harish         for (const auto& it : this->subscriptionsMap)
100596330b99SSunitha Harish         {
100696330b99SSunitha Harish             std::shared_ptr<Subscription> entry = it.second;
100796330b99SSunitha Harish             bool isSubscribed = false;
100896330b99SSunitha Harish             // Search the resourceTypes list for the subscription.
100996330b99SSunitha Harish             // If resourceTypes list is empty, don't filter events
101096330b99SSunitha Harish             // send everything.
101196330b99SSunitha Harish             if (entry->resourceTypes.size())
101296330b99SSunitha Harish             {
10133174e4dfSEd Tanous                 for (const auto& resource : entry->resourceTypes)
101496330b99SSunitha Harish                 {
101596330b99SSunitha Harish                     if (resType == resource)
101696330b99SSunitha Harish                     {
101796330b99SSunitha Harish                         BMCWEB_LOG_INFO << "ResourceType " << resource
101896330b99SSunitha Harish                                         << " found in the subscribed list";
101996330b99SSunitha Harish                         isSubscribed = true;
102096330b99SSunitha Harish                         break;
102196330b99SSunitha Harish                     }
102296330b99SSunitha Harish                 }
102396330b99SSunitha Harish             }
102496330b99SSunitha Harish             else // resourceTypes list is empty.
102596330b99SSunitha Harish             {
102696330b99SSunitha Harish                 isSubscribed = true;
102796330b99SSunitha Harish             }
102896330b99SSunitha Harish             if (isSubscribed)
102996330b99SSunitha Harish             {
103096330b99SSunitha Harish                 nlohmann::json msgJson = {
103196330b99SSunitha Harish                     {"@odata.type", "#Event.v1_4_0.Event"},
103296330b99SSunitha Harish                     {"Name", "Event Log"},
103396330b99SSunitha Harish                     {"Id", eventId},
103496330b99SSunitha Harish                     {"Events", eventRecord}};
103571f52d96SEd Tanous                 entry->sendEvent(msgJson.dump(
103671f52d96SEd Tanous                     2, ' ', true, nlohmann::json::error_handler_t::replace));
103796330b99SSunitha Harish                 eventId++; // increament the eventId
103896330b99SSunitha Harish             }
103996330b99SSunitha Harish             else
104096330b99SSunitha Harish             {
104196330b99SSunitha Harish                 BMCWEB_LOG_INFO << "Not subscribed to this resource";
104296330b99SSunitha Harish             }
104396330b99SSunitha Harish         }
104496330b99SSunitha Harish     }
10455738de59SAsmitha Karunanithi     void sendBroadcastMsg(const std::string& broadcastMsg)
10465738de59SAsmitha Karunanithi     {
10475738de59SAsmitha Karunanithi         for (const auto& it : this->subscriptionsMap)
10485738de59SAsmitha Karunanithi         {
10495738de59SAsmitha Karunanithi             std::shared_ptr<Subscription> entry = it.second;
10505738de59SAsmitha Karunanithi             nlohmann::json msgJson = {
10517c8c4058STejas Patil                 {"Timestamp", crow::utility::getDateTimeOffsetNow().first},
10525738de59SAsmitha Karunanithi                 {"OriginOfCondition", "/ibm/v1/HMC/BroadcastService"},
10535738de59SAsmitha Karunanithi                 {"Name", "Broadcast Message"},
10545738de59SAsmitha Karunanithi                 {"Message", broadcastMsg}};
105571f52d96SEd Tanous             entry->sendEvent(msgJson.dump(
105671f52d96SEd Tanous                 2, ' ', true, nlohmann::json::error_handler_t::replace));
10575738de59SAsmitha Karunanithi         }
10585738de59SAsmitha Karunanithi     }
105996330b99SSunitha Harish 
10607f4eb588SAppaRao Puli #ifndef BMCWEB_ENABLE_REDFISH_DBUS_LOG_ENTRIES
1061*2558979cSP Dheeraj Srujan Kumar 
1062*2558979cSP Dheeraj Srujan Kumar     void resetRedfishFilePosition()
10637f4eb588SAppaRao Puli     {
1064*2558979cSP Dheeraj Srujan Kumar         // Control would be here when Redfish file is created.
1065*2558979cSP Dheeraj Srujan Kumar         // Reset File Position as new file is created
1066*2558979cSP Dheeraj Srujan Kumar         redfishLogFilePosition = 0;
1067*2558979cSP Dheeraj Srujan Kumar 
1068*2558979cSP Dheeraj Srujan Kumar         return;
1069*2558979cSP Dheeraj Srujan Kumar     }
1070*2558979cSP Dheeraj Srujan Kumar 
1071*2558979cSP Dheeraj Srujan Kumar     void cacheRedfishLogFile()
1072*2558979cSP Dheeraj Srujan Kumar     {
1073*2558979cSP Dheeraj Srujan Kumar         // Open the redfish file and read till the last record.
1074*2558979cSP Dheeraj Srujan Kumar 
10757f4eb588SAppaRao Puli         std::ifstream logStream(redfishEventLogFile);
10767f4eb588SAppaRao Puli         if (!logStream.good())
10777f4eb588SAppaRao Puli         {
10787f4eb588SAppaRao Puli             BMCWEB_LOG_ERROR << " Redfish log file open failed \n";
10797f4eb588SAppaRao Puli             return;
10807f4eb588SAppaRao Puli         }
10817f4eb588SAppaRao Puli         std::string logEntry;
10827f4eb588SAppaRao Puli         while (std::getline(logStream, logEntry))
10837f4eb588SAppaRao Puli         {
1084*2558979cSP Dheeraj Srujan Kumar             redfishLogFilePosition = logStream.tellg();
10857f4eb588SAppaRao Puli         }
1086*2558979cSP Dheeraj Srujan Kumar 
1087*2558979cSP Dheeraj Srujan Kumar         BMCWEB_LOG_DEBUG << "Next Log Position : " << redfishLogFilePosition;
10887f4eb588SAppaRao Puli     }
10897f4eb588SAppaRao Puli 
10907f4eb588SAppaRao Puli     void readEventLogsFromFile()
10917f4eb588SAppaRao Puli     {
10927f4eb588SAppaRao Puli         std::ifstream logStream(redfishEventLogFile);
10937f4eb588SAppaRao Puli         if (!logStream.good())
10947f4eb588SAppaRao Puli         {
10957f4eb588SAppaRao Puli             BMCWEB_LOG_ERROR << " Redfish log file open failed";
10967f4eb588SAppaRao Puli             return;
10977f4eb588SAppaRao Puli         }
10987f4eb588SAppaRao Puli 
10997f4eb588SAppaRao Puli         std::vector<EventLogObjectsType> eventRecords;
11007f4eb588SAppaRao Puli 
11017f4eb588SAppaRao Puli         std::string logEntry;
1102*2558979cSP Dheeraj Srujan Kumar 
1103*2558979cSP Dheeraj Srujan Kumar         // Get the read pointer to the next log to be read.
1104*2558979cSP Dheeraj Srujan Kumar         logStream.seekg(redfishLogFilePosition);
1105*2558979cSP Dheeraj Srujan Kumar 
11067f4eb588SAppaRao Puli         while (std::getline(logStream, logEntry))
11077f4eb588SAppaRao Puli         {
1108*2558979cSP Dheeraj Srujan Kumar             // Update Pointer position
1109*2558979cSP Dheeraj Srujan Kumar             redfishLogFilePosition = logStream.tellg();
1110*2558979cSP Dheeraj Srujan Kumar 
1111*2558979cSP Dheeraj Srujan Kumar             std::string idStr;
1112*2558979cSP Dheeraj Srujan Kumar             if (!event_log::getUniqueEntryID(logEntry, idStr))
11137f4eb588SAppaRao Puli             {
11147f4eb588SAppaRao Puli                 continue;
11157f4eb588SAppaRao Puli             }
11167f4eb588SAppaRao Puli 
1117*2558979cSP Dheeraj Srujan Kumar             if (!serviceEnabled || !noOfEventLogSubscribers)
11187f4eb588SAppaRao Puli             {
1119*2558979cSP Dheeraj Srujan Kumar                 // If Service is not enabled, no need to compute
1120*2558979cSP Dheeraj Srujan Kumar                 // the remaining items below.
1121*2558979cSP Dheeraj Srujan Kumar                 // But, Loop must continue to keep track of Timestamp
11227f4eb588SAppaRao Puli                 continue;
11237f4eb588SAppaRao Puli             }
11247f4eb588SAppaRao Puli 
11257f4eb588SAppaRao Puli             std::string timestamp;
11267f4eb588SAppaRao Puli             std::string messageID;
11275e715de6SAppaRao Puli             std::vector<std::string> messageArgs;
11287f4eb588SAppaRao Puli             if (event_log::getEventLogParams(logEntry, timestamp, messageID,
11297f4eb588SAppaRao Puli                                              messageArgs) != 0)
11307f4eb588SAppaRao Puli             {
11317f4eb588SAppaRao Puli                 BMCWEB_LOG_DEBUG << "Read eventLog entry params failed";
11327f4eb588SAppaRao Puli                 continue;
11337f4eb588SAppaRao Puli             }
11347f4eb588SAppaRao Puli 
11357f4eb588SAppaRao Puli             std::string registryName;
11367f4eb588SAppaRao Puli             std::string messageKey;
11377f4eb588SAppaRao Puli             event_log::getRegistryAndMessageKey(messageID, registryName,
11387f4eb588SAppaRao Puli                                                 messageKey);
11397f4eb588SAppaRao Puli             if (registryName.empty() || messageKey.empty())
11407f4eb588SAppaRao Puli             {
11417f4eb588SAppaRao Puli                 continue;
11427f4eb588SAppaRao Puli             }
11437f4eb588SAppaRao Puli 
11447f4eb588SAppaRao Puli             eventRecords.emplace_back(idStr, timestamp, messageID, registryName,
11457f4eb588SAppaRao Puli                                       messageKey, messageArgs);
11467f4eb588SAppaRao Puli         }
11477f4eb588SAppaRao Puli 
1148*2558979cSP Dheeraj Srujan Kumar         if (!serviceEnabled || !noOfEventLogSubscribers)
1149*2558979cSP Dheeraj Srujan Kumar         {
1150*2558979cSP Dheeraj Srujan Kumar             BMCWEB_LOG_DEBUG << "EventService disabled or no Subscriptions.";
1151*2558979cSP Dheeraj Srujan Kumar             return;
1152*2558979cSP Dheeraj Srujan Kumar         }
1153*2558979cSP Dheeraj Srujan Kumar 
1154*2558979cSP Dheeraj Srujan Kumar         if (eventRecords.empty())
1155*2558979cSP Dheeraj Srujan Kumar         {
1156*2558979cSP Dheeraj Srujan Kumar             // No Records to send
1157*2558979cSP Dheeraj Srujan Kumar             BMCWEB_LOG_DEBUG << "No log entries available to be transferred.";
1158*2558979cSP Dheeraj Srujan Kumar             return;
1159*2558979cSP Dheeraj Srujan Kumar         }
1160*2558979cSP Dheeraj Srujan Kumar 
11617f4eb588SAppaRao Puli         for (const auto& it : this->subscriptionsMap)
11627f4eb588SAppaRao Puli         {
11637f4eb588SAppaRao Puli             std::shared_ptr<Subscription> entry = it.second;
11647f4eb588SAppaRao Puli             if (entry->eventFormatType == "Event")
11657f4eb588SAppaRao Puli             {
11667f4eb588SAppaRao Puli                 entry->filterAndSendEventLogs(eventRecords);
11677f4eb588SAppaRao Puli             }
11687f4eb588SAppaRao Puli         }
11697f4eb588SAppaRao Puli     }
11707f4eb588SAppaRao Puli 
11717f4eb588SAppaRao Puli     static void watchRedfishEventLogFile()
11727f4eb588SAppaRao Puli     {
11736a9f85f9SAppaRao Puli         if (!inotifyConn)
11747f4eb588SAppaRao Puli         {
11757f4eb588SAppaRao Puli             return;
11767f4eb588SAppaRao Puli         }
11777f4eb588SAppaRao Puli 
11787f4eb588SAppaRao Puli         static std::array<char, 1024> readBuffer;
11797f4eb588SAppaRao Puli 
11807f4eb588SAppaRao Puli         inotifyConn->async_read_some(
11817f4eb588SAppaRao Puli             boost::asio::buffer(readBuffer),
11827f4eb588SAppaRao Puli             [&](const boost::system::error_code& ec,
11837f4eb588SAppaRao Puli                 const std::size_t& bytesTransferred) {
11847f4eb588SAppaRao Puli                 if (ec)
11857f4eb588SAppaRao Puli                 {
11867f4eb588SAppaRao Puli                     BMCWEB_LOG_ERROR << "Callback Error: " << ec.message();
11877f4eb588SAppaRao Puli                     return;
11887f4eb588SAppaRao Puli                 }
11897f4eb588SAppaRao Puli                 std::size_t index = 0;
1190b792cc56SAppaRao Puli                 while ((index + iEventSize) <= bytesTransferred)
11917f4eb588SAppaRao Puli                 {
11927f4eb588SAppaRao Puli                     struct inotify_event event;
1193b792cc56SAppaRao Puli                     std::memcpy(&event, &readBuffer[index], iEventSize);
1194b792cc56SAppaRao Puli                     if (event.wd == dirWatchDesc)
1195b792cc56SAppaRao Puli                     {
1196b792cc56SAppaRao Puli                         if ((event.len == 0) ||
1197b792cc56SAppaRao Puli                             (index + iEventSize + event.len > bytesTransferred))
1198b792cc56SAppaRao Puli                         {
1199b792cc56SAppaRao Puli                             index += (iEventSize + event.len);
1200b792cc56SAppaRao Puli                             continue;
1201b792cc56SAppaRao Puli                         }
1202b792cc56SAppaRao Puli 
1203b792cc56SAppaRao Puli                         std::string fileName(&readBuffer[index + iEventSize],
1204b792cc56SAppaRao Puli                                              event.len);
1205b792cc56SAppaRao Puli                         if (std::strcmp(fileName.c_str(), "redfish") != 0)
1206b792cc56SAppaRao Puli                         {
1207b792cc56SAppaRao Puli                             index += (iEventSize + event.len);
1208b792cc56SAppaRao Puli                             continue;
1209b792cc56SAppaRao Puli                         }
1210b792cc56SAppaRao Puli 
1211b792cc56SAppaRao Puli                         BMCWEB_LOG_DEBUG
1212b792cc56SAppaRao Puli                             << "Redfish log file created/deleted. event.name: "
1213b792cc56SAppaRao Puli                             << fileName;
1214b792cc56SAppaRao Puli                         if (event.mask == IN_CREATE)
1215b792cc56SAppaRao Puli                         {
1216b792cc56SAppaRao Puli                             if (fileWatchDesc != -1)
1217b792cc56SAppaRao Puli                             {
1218b792cc56SAppaRao Puli                                 BMCWEB_LOG_DEBUG
1219016761afSAppaRao Puli                                     << "Remove and Add inotify watcher on "
1220016761afSAppaRao Puli                                        "redfish event log file";
1221016761afSAppaRao Puli                                 // Remove existing inotify watcher and add
1222016761afSAppaRao Puli                                 // with new redfish event log file.
1223016761afSAppaRao Puli                                 inotify_rm_watch(inotifyFd, fileWatchDesc);
1224016761afSAppaRao Puli                                 fileWatchDesc = -1;
1225b792cc56SAppaRao Puli                             }
1226b792cc56SAppaRao Puli 
1227b792cc56SAppaRao Puli                             fileWatchDesc = inotify_add_watch(
1228b792cc56SAppaRao Puli                                 inotifyFd, redfishEventLogFile, IN_MODIFY);
1229b792cc56SAppaRao Puli                             if (fileWatchDesc == -1)
1230b792cc56SAppaRao Puli                             {
1231b792cc56SAppaRao Puli                                 BMCWEB_LOG_ERROR
1232b792cc56SAppaRao Puli                                     << "inotify_add_watch failed for "
1233b792cc56SAppaRao Puli                                        "redfish log file.";
1234b792cc56SAppaRao Puli                                 return;
1235b792cc56SAppaRao Puli                             }
1236b792cc56SAppaRao Puli 
1237b792cc56SAppaRao Puli                             EventServiceManager::getInstance()
1238*2558979cSP Dheeraj Srujan Kumar                                 .resetRedfishFilePosition();
1239b792cc56SAppaRao Puli                             EventServiceManager::getInstance()
1240b792cc56SAppaRao Puli                                 .readEventLogsFromFile();
1241b792cc56SAppaRao Puli                         }
1242b792cc56SAppaRao Puli                         else if ((event.mask == IN_DELETE) ||
1243b792cc56SAppaRao Puli                                  (event.mask == IN_MOVED_TO))
1244b792cc56SAppaRao Puli                         {
1245b792cc56SAppaRao Puli                             if (fileWatchDesc != -1)
1246b792cc56SAppaRao Puli                             {
1247b792cc56SAppaRao Puli                                 inotify_rm_watch(inotifyFd, fileWatchDesc);
1248b792cc56SAppaRao Puli                                 fileWatchDesc = -1;
1249b792cc56SAppaRao Puli                             }
1250b792cc56SAppaRao Puli                         }
1251b792cc56SAppaRao Puli                     }
1252b792cc56SAppaRao Puli                     else if (event.wd == fileWatchDesc)
1253b792cc56SAppaRao Puli                     {
1254b792cc56SAppaRao Puli                         if (event.mask == IN_MODIFY)
12557f4eb588SAppaRao Puli                         {
12567f4eb588SAppaRao Puli                             EventServiceManager::getInstance()
12577f4eb588SAppaRao Puli                                 .readEventLogsFromFile();
12587f4eb588SAppaRao Puli                         }
1259b792cc56SAppaRao Puli                     }
1260b792cc56SAppaRao Puli                     index += (iEventSize + event.len);
12617f4eb588SAppaRao Puli                 }
12627f4eb588SAppaRao Puli 
12637f4eb588SAppaRao Puli                 watchRedfishEventLogFile();
12647f4eb588SAppaRao Puli             });
12657f4eb588SAppaRao Puli     }
12667f4eb588SAppaRao Puli 
12677f4eb588SAppaRao Puli     static int startEventLogMonitor(boost::asio::io_context& ioc)
12687f4eb588SAppaRao Puli     {
126923a21a1cSEd Tanous         inotifyConn.emplace(ioc);
1270b792cc56SAppaRao Puli         inotifyFd = inotify_init1(IN_NONBLOCK);
1271b792cc56SAppaRao Puli         if (inotifyFd == -1)
12727f4eb588SAppaRao Puli         {
12737f4eb588SAppaRao Puli             BMCWEB_LOG_ERROR << "inotify_init1 failed.";
12747f4eb588SAppaRao Puli             return -1;
12757f4eb588SAppaRao Puli         }
1276b792cc56SAppaRao Puli 
1277b792cc56SAppaRao Puli         // Add watch on directory to handle redfish event log file
1278b792cc56SAppaRao Puli         // create/delete.
1279b792cc56SAppaRao Puli         dirWatchDesc = inotify_add_watch(inotifyFd, redfishEventLogDir,
1280b792cc56SAppaRao Puli                                          IN_CREATE | IN_MOVED_TO | IN_DELETE);
1281b792cc56SAppaRao Puli         if (dirWatchDesc == -1)
12827f4eb588SAppaRao Puli         {
12837f4eb588SAppaRao Puli             BMCWEB_LOG_ERROR
1284b792cc56SAppaRao Puli                 << "inotify_add_watch failed for event log directory.";
12857f4eb588SAppaRao Puli             return -1;
12867f4eb588SAppaRao Puli         }
12877f4eb588SAppaRao Puli 
1288b792cc56SAppaRao Puli         // Watch redfish event log file for modifications.
1289b792cc56SAppaRao Puli         fileWatchDesc =
1290b792cc56SAppaRao Puli             inotify_add_watch(inotifyFd, redfishEventLogFile, IN_MODIFY);
1291b792cc56SAppaRao Puli         if (fileWatchDesc == -1)
1292b792cc56SAppaRao Puli         {
1293b792cc56SAppaRao Puli             BMCWEB_LOG_ERROR
1294b792cc56SAppaRao Puli                 << "inotify_add_watch failed for redfish log file.";
1295b792cc56SAppaRao Puli             // Don't return error if file not exist.
1296b792cc56SAppaRao Puli             // Watch on directory will handle create/delete of file.
1297b792cc56SAppaRao Puli         }
1298b792cc56SAppaRao Puli 
12997f4eb588SAppaRao Puli         // monitor redfish event log file
1300b792cc56SAppaRao Puli         inotifyConn->assign(inotifyFd);
13017f4eb588SAppaRao Puli         watchRedfishEventLogFile();
13027f4eb588SAppaRao Puli 
13037f4eb588SAppaRao Puli         return 0;
13047f4eb588SAppaRao Puli     }
13057f4eb588SAppaRao Puli 
13067f4eb588SAppaRao Puli #endif
1307c0353249SWludzik, Jozef     void getReadingsForReport(sdbusplus::message::message& msg)
1308156d6b00SAppaRao Puli     {
1309c0353249SWludzik, Jozef         sdbusplus::message::object_path path(msg.get_path());
1310c0353249SWludzik, Jozef         std::string id = path.filename();
1311c0353249SWludzik, Jozef         if (id.empty())
1312156d6b00SAppaRao Puli         {
1313c0353249SWludzik, Jozef             BMCWEB_LOG_ERROR << "Failed to get Id from path";
1314156d6b00SAppaRao Puli             return;
1315156d6b00SAppaRao Puli         }
1316156d6b00SAppaRao Puli 
1317c0353249SWludzik, Jozef         std::string interface;
1318c0353249SWludzik, Jozef         std::vector<
1319c0353249SWludzik, Jozef             std::pair<std::string, std::variant<telemetry::TimestampReadings>>>
1320c0353249SWludzik, Jozef             props;
1321c0353249SWludzik, Jozef         std::vector<std::string> invalidProps;
1322c0353249SWludzik, Jozef         msg.read(interface, props, invalidProps);
1323c0353249SWludzik, Jozef 
1324c0353249SWludzik, Jozef         auto found =
1325c0353249SWludzik, Jozef             std::find_if(props.begin(), props.end(),
1326c0353249SWludzik, Jozef                          [](const auto& x) { return x.first == "Readings"; });
1327c0353249SWludzik, Jozef         if (found == props.end())
1328156d6b00SAppaRao Puli         {
1329c0353249SWludzik, Jozef             BMCWEB_LOG_INFO << "Failed to get Readings from Report properties";
1330156d6b00SAppaRao Puli             return;
1331156d6b00SAppaRao Puli         }
1332156d6b00SAppaRao Puli 
1333c0353249SWludzik, Jozef         const std::variant<telemetry::TimestampReadings>& readings =
1334c0353249SWludzik, Jozef             found->second;
1335156d6b00SAppaRao Puli         for (const auto& it :
1336156d6b00SAppaRao Puli              EventServiceManager::getInstance().subscriptionsMap)
1337156d6b00SAppaRao Puli         {
1338c0353249SWludzik, Jozef             Subscription& entry = *it.second.get();
1339c0353249SWludzik, Jozef             if (entry.eventFormatType == metricReportFormatType)
1340156d6b00SAppaRao Puli             {
1341c0353249SWludzik, Jozef                 entry.filterAndSendReports(id, readings);
1342156d6b00SAppaRao Puli             }
1343156d6b00SAppaRao Puli         }
1344156d6b00SAppaRao Puli     }
1345156d6b00SAppaRao Puli 
1346156d6b00SAppaRao Puli     void unregisterMetricReportSignal()
1347156d6b00SAppaRao Puli     {
13487d1cc387SAppaRao Puli         if (matchTelemetryMonitor)
13497d1cc387SAppaRao Puli         {
1350156d6b00SAppaRao Puli             BMCWEB_LOG_DEBUG << "Metrics report signal - Unregister";
1351156d6b00SAppaRao Puli             matchTelemetryMonitor.reset();
1352156d6b00SAppaRao Puli             matchTelemetryMonitor = nullptr;
1353156d6b00SAppaRao Puli         }
13547d1cc387SAppaRao Puli     }
1355156d6b00SAppaRao Puli 
1356156d6b00SAppaRao Puli     void registerMetricReportSignal()
1357156d6b00SAppaRao Puli     {
13587d1cc387SAppaRao Puli         if (!serviceEnabled || matchTelemetryMonitor)
1359156d6b00SAppaRao Puli         {
13607d1cc387SAppaRao Puli             BMCWEB_LOG_DEBUG << "Not registering metric report signal.";
1361156d6b00SAppaRao Puli             return;
1362156d6b00SAppaRao Puli         }
1363156d6b00SAppaRao Puli 
1364156d6b00SAppaRao Puli         BMCWEB_LOG_DEBUG << "Metrics report signal - Register";
1365c0353249SWludzik, Jozef         std::string matchStr = "type='signal',member='PropertiesChanged',"
1366c0353249SWludzik, Jozef                                "interface='org.freedesktop.DBus.Properties',"
1367c0353249SWludzik, Jozef                                "arg0=xyz.openbmc_project.Telemetry.Report";
1368156d6b00SAppaRao Puli 
1369156d6b00SAppaRao Puli         matchTelemetryMonitor = std::make_shared<sdbusplus::bus::match::match>(
1370156d6b00SAppaRao Puli             *crow::connections::systemBus, matchStr,
1371156d6b00SAppaRao Puli             [this](sdbusplus::message::message& msg) {
1372156d6b00SAppaRao Puli                 if (msg.is_method_error())
1373156d6b00SAppaRao Puli                 {
1374156d6b00SAppaRao Puli                     BMCWEB_LOG_ERROR << "TelemetryMonitor Signal error";
1375156d6b00SAppaRao Puli                     return;
1376156d6b00SAppaRao Puli                 }
1377156d6b00SAppaRao Puli 
1378c0353249SWludzik, Jozef                 getReadingsForReport(msg);
1379156d6b00SAppaRao Puli             });
1380156d6b00SAppaRao Puli     }
13811bf712bcSAyushi Smriti 
13821bf712bcSAyushi Smriti     bool validateAndSplitUrl(const std::string& destUrl, std::string& urlProto,
13831bf712bcSAyushi Smriti                              std::string& host, std::string& port,
13841bf712bcSAyushi Smriti                              std::string& path)
13851bf712bcSAyushi Smriti     {
13861bf712bcSAyushi Smriti         // Validate URL using regex expression
13871bf712bcSAyushi Smriti         // Format: <protocol>://<host>:<port>/<path>
13881bf712bcSAyushi Smriti         // protocol: http/https
13891bf712bcSAyushi Smriti         const std::regex urlRegex(
13901bf712bcSAyushi Smriti             "(http|https)://([^/\\x20\\x3f\\x23\\x3a]+):?([0-9]*)(/"
13911bf712bcSAyushi Smriti             "([^\\x20\\x23\\x3f]*\\x3f?([^\\x20\\x23\\x3f])*)?)");
13921bf712bcSAyushi Smriti         std::cmatch match;
13931bf712bcSAyushi Smriti         if (!std::regex_match(destUrl.c_str(), match, urlRegex))
13941bf712bcSAyushi Smriti         {
13951bf712bcSAyushi Smriti             BMCWEB_LOG_INFO << "Dest. url did not match ";
13961bf712bcSAyushi Smriti             return false;
13971bf712bcSAyushi Smriti         }
13981bf712bcSAyushi Smriti 
13991bf712bcSAyushi Smriti         urlProto = std::string(match[1].first, match[1].second);
14001bf712bcSAyushi Smriti         if (urlProto == "http")
14011bf712bcSAyushi Smriti         {
14021bf712bcSAyushi Smriti #ifndef BMCWEB_INSECURE_ENABLE_HTTP_PUSH_STYLE_EVENTING
14031bf712bcSAyushi Smriti             return false;
14041bf712bcSAyushi Smriti #endif
14051bf712bcSAyushi Smriti         }
14061bf712bcSAyushi Smriti 
14071bf712bcSAyushi Smriti         host = std::string(match[2].first, match[2].second);
14081bf712bcSAyushi Smriti         port = std::string(match[3].first, match[3].second);
14091bf712bcSAyushi Smriti         path = std::string(match[4].first, match[4].second);
14101bf712bcSAyushi Smriti         if (port.empty())
14111bf712bcSAyushi Smriti         {
14121bf712bcSAyushi Smriti             if (urlProto == "http")
14131bf712bcSAyushi Smriti             {
14141bf712bcSAyushi Smriti                 port = "80";
14151bf712bcSAyushi Smriti             }
14161bf712bcSAyushi Smriti             else
14171bf712bcSAyushi Smriti             {
14181bf712bcSAyushi Smriti                 port = "443";
14191bf712bcSAyushi Smriti             }
14201bf712bcSAyushi Smriti         }
14211bf712bcSAyushi Smriti         if (path.empty())
14221bf712bcSAyushi Smriti         {
14231bf712bcSAyushi Smriti             path = "/";
14241bf712bcSAyushi Smriti         }
14251bf712bcSAyushi Smriti         return true;
14261bf712bcSAyushi Smriti     }
142723a21a1cSEd Tanous };
1428b52664e2SAppaRao Puli 
1429b52664e2SAppaRao Puli } // namespace redfish
1430