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> 27*168e20c1SEd Tanous #include <dbus_utility.hpp> 281214b7e7SGunnar Mills #include <error_messages.hpp> 2928afb49cSJunLin Chen #include <event_service_store.hpp> 301214b7e7SGunnar Mills #include <http_client.hpp> 3128afb49cSJunLin Chen #include <persistent_data.hpp> 32fc76b8acSEd Tanous #include <random.hpp> 334bbf237fSAppaRao Puli #include <server_sent_events.hpp> 341214b7e7SGunnar Mills #include <utils/json_utils.hpp> 351214b7e7SGunnar Mills 36b52664e2SAppaRao Puli #include <cstdlib> 37b52664e2SAppaRao Puli #include <ctime> 381bf712bcSAyushi Smriti #include <fstream> 39b52664e2SAppaRao Puli #include <memory> 4026702d01SEd Tanous #include <span> 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 { 1302558979cSP 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 503*168e20c1SEd Tanous void filterAndSendReports(const std::string& id, 504*168e20c1SEd Tanous const dbus::utility::DbusVariantType& var) 505156d6b00SAppaRao Puli { 506c0353249SWludzik, Jozef std::string mrdUri = telemetry::metricReportDefinitionUri + ("/" + id); 507156d6b00SAppaRao Puli 508156d6b00SAppaRao Puli // Empty list means no filter. Send everything. 509156d6b00SAppaRao Puli if (metricReportDefinitions.size()) 510156d6b00SAppaRao Puli { 511156d6b00SAppaRao Puli if (std::find(metricReportDefinitions.begin(), 512156d6b00SAppaRao Puli metricReportDefinitions.end(), 513c0353249SWludzik, Jozef mrdUri) == metricReportDefinitions.end()) 514156d6b00SAppaRao Puli { 515156d6b00SAppaRao Puli return; 516156d6b00SAppaRao Puli } 517156d6b00SAppaRao Puli } 518156d6b00SAppaRao Puli 519c0353249SWludzik, Jozef nlohmann::json msg; 520c0353249SWludzik, Jozef if (!telemetry::fillReport(msg, id, var)) 521156d6b00SAppaRao Puli { 522c0353249SWludzik, Jozef BMCWEB_LOG_ERROR << "Failed to fill the MetricReport for DBus " 523c0353249SWludzik, Jozef "Report with id " 524c0353249SWludzik, Jozef << id; 525c0353249SWludzik, Jozef return; 526156d6b00SAppaRao Puli } 527156d6b00SAppaRao Puli 52871f52d96SEd Tanous this->sendEvent( 52971f52d96SEd Tanous msg.dump(2, ' ', true, nlohmann::json::error_handler_t::replace)); 530156d6b00SAppaRao Puli } 531156d6b00SAppaRao Puli 532fe44eb0bSAyushi Smriti void updateRetryConfig(const uint32_t retryAttempts, 533fe44eb0bSAyushi Smriti const uint32_t retryTimeoutInterval) 534fe44eb0bSAyushi Smriti { 53562de0c68SAppaRao Puli if (conn != nullptr) 53662de0c68SAppaRao Puli { 537fe44eb0bSAyushi Smriti conn->setRetryConfig(retryAttempts, retryTimeoutInterval); 538fe44eb0bSAyushi Smriti } 53962de0c68SAppaRao Puli } 540fe44eb0bSAyushi Smriti 541fe44eb0bSAyushi Smriti void updateRetryPolicy() 542fe44eb0bSAyushi Smriti { 54362de0c68SAppaRao Puli if (conn != nullptr) 54462de0c68SAppaRao Puli { 545fe44eb0bSAyushi Smriti conn->setRetryPolicy(retryPolicy); 546fe44eb0bSAyushi Smriti } 54762de0c68SAppaRao Puli } 548fe44eb0bSAyushi Smriti 54996330b99SSunitha Harish uint64_t getEventSeqNum() 55096330b99SSunitha Harish { 55196330b99SSunitha Harish return eventSeqNum; 55296330b99SSunitha Harish } 55396330b99SSunitha Harish 554b52664e2SAppaRao Puli private: 5550b4bdd93SAppaRao Puli uint64_t eventSeqNum; 556b52664e2SAppaRao Puli std::string host; 557b52664e2SAppaRao Puli std::string port; 558b52664e2SAppaRao Puli std::string path; 559b52664e2SAppaRao Puli std::string uriProto; 5604bbf237fSAppaRao Puli std::shared_ptr<crow::HttpClient> conn = nullptr; 5614bbf237fSAppaRao Puli std::shared_ptr<crow::ServerSentEvents> sseConn = nullptr; 562b52664e2SAppaRao Puli }; 563b52664e2SAppaRao Puli 564b52664e2SAppaRao Puli class EventServiceManager 565b52664e2SAppaRao Puli { 566b52664e2SAppaRao Puli private: 5677d1cc387SAppaRao Puli bool serviceEnabled; 5687d1cc387SAppaRao Puli uint32_t retryAttempts; 5697d1cc387SAppaRao Puli uint32_t retryTimeoutInterval; 5707d1cc387SAppaRao Puli 5719f616dd1SEd Tanous EventServiceManager() 572b52664e2SAppaRao Puli { 5731bf712bcSAyushi Smriti // Load config from persist store. 5741bf712bcSAyushi Smriti initConfig(); 575b52664e2SAppaRao Puli } 576b52664e2SAppaRao Puli 5772558979cSP Dheeraj Srujan Kumar std::streampos redfishLogFilePosition{0}; 5789f616dd1SEd Tanous size_t noOfEventLogSubscribers{0}; 5799f616dd1SEd Tanous size_t noOfMetricReportSubscribers{0}; 580156d6b00SAppaRao Puli std::shared_ptr<sdbusplus::bus::match::match> matchTelemetryMonitor; 581b52664e2SAppaRao Puli boost::container::flat_map<std::string, std::shared_ptr<Subscription>> 582b52664e2SAppaRao Puli subscriptionsMap; 583b52664e2SAppaRao Puli 5849f616dd1SEd Tanous uint64_t eventId{1}; 58596330b99SSunitha Harish 586b52664e2SAppaRao Puli public: 5879f616dd1SEd Tanous EventServiceManager(const EventServiceManager&) = delete; 5889f616dd1SEd Tanous EventServiceManager& operator=(const EventServiceManager&) = delete; 5899f616dd1SEd Tanous EventServiceManager(EventServiceManager&&) = delete; 5909f616dd1SEd Tanous EventServiceManager& operator=(EventServiceManager&&) = delete; 5919f616dd1SEd Tanous 592b52664e2SAppaRao Puli static EventServiceManager& getInstance() 593b52664e2SAppaRao Puli { 594b52664e2SAppaRao Puli static EventServiceManager handler; 595b52664e2SAppaRao Puli return handler; 596b52664e2SAppaRao Puli } 597b52664e2SAppaRao Puli 5981bf712bcSAyushi Smriti void initConfig() 5991bf712bcSAyushi Smriti { 60028afb49cSJunLin Chen loadOldBehavior(); 6011bf712bcSAyushi Smriti 60228afb49cSJunLin Chen persistent_data::EventServiceConfig eventServiceConfig = 60328afb49cSJunLin Chen persistent_data::EventServiceStore::getInstance() 60428afb49cSJunLin Chen .getEventServiceConfig(); 6051bf712bcSAyushi Smriti 60628afb49cSJunLin Chen serviceEnabled = eventServiceConfig.enabled; 60728afb49cSJunLin Chen retryAttempts = eventServiceConfig.retryAttempts; 60828afb49cSJunLin Chen retryTimeoutInterval = eventServiceConfig.retryTimeoutInterval; 6091bf712bcSAyushi Smriti 61028afb49cSJunLin Chen for (const auto& it : persistent_data::EventServiceStore::getInstance() 61128afb49cSJunLin Chen .subscriptionsConfigMap) 6121bf712bcSAyushi Smriti { 61328afb49cSJunLin Chen std::shared_ptr<persistent_data::UserSubscription> newSub = 61428afb49cSJunLin Chen it.second; 6154bbf237fSAppaRao Puli 6161bf712bcSAyushi Smriti std::string host; 6171bf712bcSAyushi Smriti std::string urlProto; 6181bf712bcSAyushi Smriti std::string port; 6191bf712bcSAyushi Smriti std::string path; 62028afb49cSJunLin Chen bool status = validateAndSplitUrl(newSub->destinationUrl, urlProto, 62128afb49cSJunLin Chen host, port, path); 6221bf712bcSAyushi Smriti 6231bf712bcSAyushi Smriti if (!status) 6241bf712bcSAyushi Smriti { 6251bf712bcSAyushi Smriti BMCWEB_LOG_ERROR 6261bf712bcSAyushi Smriti << "Failed to validate and split destination url"; 6271bf712bcSAyushi Smriti continue; 6281bf712bcSAyushi Smriti } 6291bf712bcSAyushi Smriti std::shared_ptr<Subscription> subValue = 6301bf712bcSAyushi Smriti std::make_shared<Subscription>(host, port, path, urlProto); 6311bf712bcSAyushi Smriti 63228afb49cSJunLin Chen subValue->id = newSub->id; 63328afb49cSJunLin Chen subValue->destinationUrl = newSub->destinationUrl; 63428afb49cSJunLin Chen subValue->protocol = newSub->protocol; 63528afb49cSJunLin Chen subValue->retryPolicy = newSub->retryPolicy; 63628afb49cSJunLin Chen subValue->customText = newSub->customText; 63728afb49cSJunLin Chen subValue->eventFormatType = newSub->eventFormatType; 63828afb49cSJunLin Chen subValue->subscriptionType = newSub->subscriptionType; 63928afb49cSJunLin Chen subValue->registryMsgIds = newSub->registryMsgIds; 64028afb49cSJunLin Chen subValue->registryPrefixes = newSub->registryPrefixes; 64128afb49cSJunLin Chen subValue->resourceTypes = newSub->resourceTypes; 64228afb49cSJunLin Chen subValue->httpHeaders = newSub->httpHeaders; 64328afb49cSJunLin Chen subValue->metricReportDefinitions = newSub->metricReportDefinitions; 6441bf712bcSAyushi Smriti 64528afb49cSJunLin Chen if (subValue->id.empty()) 6461bf712bcSAyushi Smriti { 6471bf712bcSAyushi Smriti BMCWEB_LOG_ERROR << "Failed to add subscription"; 6481bf712bcSAyushi Smriti } 64928afb49cSJunLin Chen subscriptionsMap.insert(std::pair(subValue->id, subValue)); 65028afb49cSJunLin Chen 65128afb49cSJunLin Chen updateNoOfSubscribersCount(); 65228afb49cSJunLin Chen 65328afb49cSJunLin Chen #ifndef BMCWEB_ENABLE_REDFISH_DBUS_LOG_ENTRIES 6542558979cSP Dheeraj Srujan Kumar 6552558979cSP Dheeraj Srujan Kumar cacheRedfishLogFile(); 6562558979cSP Dheeraj Srujan Kumar 65728afb49cSJunLin Chen #endif 65828afb49cSJunLin Chen // Update retry configuration. 65928afb49cSJunLin Chen subValue->updateRetryConfig(retryAttempts, retryTimeoutInterval); 66028afb49cSJunLin Chen subValue->updateRetryPolicy(); 6611bf712bcSAyushi Smriti } 6621bf712bcSAyushi Smriti return; 6631bf712bcSAyushi Smriti } 6641bf712bcSAyushi Smriti 66528afb49cSJunLin Chen void loadOldBehavior() 666b52664e2SAppaRao Puli { 66728afb49cSJunLin Chen std::ifstream eventConfigFile(eventServiceFile); 66828afb49cSJunLin Chen if (!eventConfigFile.good()) 6691bf712bcSAyushi Smriti { 67028afb49cSJunLin Chen BMCWEB_LOG_DEBUG << "Old eventService config not exist"; 67128afb49cSJunLin Chen return; 67228afb49cSJunLin Chen } 67328afb49cSJunLin Chen auto jsonData = nlohmann::json::parse(eventConfigFile, nullptr, false); 67428afb49cSJunLin Chen if (jsonData.is_discarded()) 6754bbf237fSAppaRao Puli { 67628afb49cSJunLin Chen BMCWEB_LOG_ERROR << "Old eventService config parse error."; 67728afb49cSJunLin Chen return; 67828afb49cSJunLin Chen } 67928afb49cSJunLin Chen 68028afb49cSJunLin Chen for (const auto& item : jsonData.items()) 68128afb49cSJunLin Chen { 68228afb49cSJunLin Chen if (item.key() == "Configuration") 68328afb49cSJunLin Chen { 68428afb49cSJunLin Chen persistent_data::EventServiceStore::getInstance() 68528afb49cSJunLin Chen .getEventServiceConfig() 68628afb49cSJunLin Chen .fromJson(item.value()); 68728afb49cSJunLin Chen } 68828afb49cSJunLin Chen else if (item.key() == "Subscriptions") 68928afb49cSJunLin Chen { 69028afb49cSJunLin Chen for (const auto& elem : item.value()) 69128afb49cSJunLin Chen { 69228afb49cSJunLin Chen std::shared_ptr<persistent_data::UserSubscription> 69328afb49cSJunLin Chen newSubscription = 69428afb49cSJunLin Chen persistent_data::UserSubscription::fromJson(elem, 69528afb49cSJunLin Chen true); 69628afb49cSJunLin Chen if (newSubscription == nullptr) 69728afb49cSJunLin Chen { 69828afb49cSJunLin Chen BMCWEB_LOG_ERROR << "Problem reading subscription " 69928afb49cSJunLin Chen "from old persistent store"; 7004bbf237fSAppaRao Puli continue; 7014bbf237fSAppaRao Puli } 7021bf712bcSAyushi Smriti 70328afb49cSJunLin Chen std::uniform_int_distribution<uint32_t> dist(0); 70428afb49cSJunLin Chen bmcweb::OpenSSLGenerator gen; 7051bf712bcSAyushi Smriti 70628afb49cSJunLin Chen std::string id; 7071bf712bcSAyushi Smriti 70828afb49cSJunLin Chen int retry = 3; 70928afb49cSJunLin Chen while (retry) 7101bf712bcSAyushi Smriti { 71128afb49cSJunLin Chen id = std::to_string(dist(gen)); 71228afb49cSJunLin Chen if (gen.error()) 7137d1cc387SAppaRao Puli { 71428afb49cSJunLin Chen retry = 0; 71528afb49cSJunLin Chen break; 71628afb49cSJunLin Chen } 71728afb49cSJunLin Chen newSubscription->id = id; 71828afb49cSJunLin Chen auto inserted = 71928afb49cSJunLin Chen persistent_data::EventServiceStore::getInstance() 72028afb49cSJunLin Chen .subscriptionsConfigMap.insert( 72128afb49cSJunLin Chen std::pair(id, newSubscription)); 72228afb49cSJunLin Chen if (inserted.second) 72328afb49cSJunLin Chen { 72428afb49cSJunLin Chen break; 72528afb49cSJunLin Chen } 72628afb49cSJunLin Chen --retry; 7277d1cc387SAppaRao Puli } 7287d1cc387SAppaRao Puli 72928afb49cSJunLin Chen if (retry <= 0) 73028afb49cSJunLin Chen { 73128afb49cSJunLin Chen BMCWEB_LOG_ERROR 73228afb49cSJunLin Chen << "Failed to generate random number from old " 73328afb49cSJunLin Chen "persistent store"; 73428afb49cSJunLin Chen continue; 73528afb49cSJunLin Chen } 73628afb49cSJunLin Chen } 73728afb49cSJunLin Chen } 73828afb49cSJunLin Chen 73928afb49cSJunLin Chen persistent_data::getConfig().writeData(); 74028afb49cSJunLin Chen std::remove(eventServiceFile); 74128afb49cSJunLin Chen BMCWEB_LOG_DEBUG << "Remove old eventservice config"; 74228afb49cSJunLin Chen } 74328afb49cSJunLin Chen } 74428afb49cSJunLin Chen 74528afb49cSJunLin Chen void updateSubscriptionData() 74628afb49cSJunLin Chen { 74728afb49cSJunLin Chen persistent_data::EventServiceStore::getInstance() 74828afb49cSJunLin Chen .eventServiceConfig.enabled = serviceEnabled; 74928afb49cSJunLin Chen persistent_data::EventServiceStore::getInstance() 75028afb49cSJunLin Chen .eventServiceConfig.retryAttempts = retryAttempts; 75128afb49cSJunLin Chen persistent_data::EventServiceStore::getInstance() 75228afb49cSJunLin Chen .eventServiceConfig.retryTimeoutInterval = retryTimeoutInterval; 75328afb49cSJunLin Chen 75428afb49cSJunLin Chen persistent_data::getConfig().writeData(); 75528afb49cSJunLin Chen } 75628afb49cSJunLin Chen 75728afb49cSJunLin Chen void setEventServiceConfig(const persistent_data::EventServiceConfig& cfg) 7587d1cc387SAppaRao Puli { 7597d1cc387SAppaRao Puli bool updateConfig = false; 760fe44eb0bSAyushi Smriti bool updateRetryCfg = false; 7617d1cc387SAppaRao Puli 76228afb49cSJunLin Chen if (serviceEnabled != cfg.enabled) 7637d1cc387SAppaRao Puli { 76428afb49cSJunLin Chen serviceEnabled = cfg.enabled; 7657d1cc387SAppaRao Puli if (serviceEnabled && noOfMetricReportSubscribers) 7667d1cc387SAppaRao Puli { 7677d1cc387SAppaRao Puli registerMetricReportSignal(); 7687d1cc387SAppaRao Puli } 7697d1cc387SAppaRao Puli else 7707d1cc387SAppaRao Puli { 7717d1cc387SAppaRao Puli unregisterMetricReportSignal(); 7727d1cc387SAppaRao Puli } 7737d1cc387SAppaRao Puli updateConfig = true; 7747d1cc387SAppaRao Puli } 7757d1cc387SAppaRao Puli 77628afb49cSJunLin Chen if (retryAttempts != cfg.retryAttempts) 7777d1cc387SAppaRao Puli { 77828afb49cSJunLin Chen retryAttempts = cfg.retryAttempts; 7797d1cc387SAppaRao Puli updateConfig = true; 780fe44eb0bSAyushi Smriti updateRetryCfg = true; 7817d1cc387SAppaRao Puli } 7827d1cc387SAppaRao Puli 78328afb49cSJunLin Chen if (retryTimeoutInterval != cfg.retryTimeoutInterval) 7847d1cc387SAppaRao Puli { 78528afb49cSJunLin Chen retryTimeoutInterval = cfg.retryTimeoutInterval; 7867d1cc387SAppaRao Puli updateConfig = true; 787fe44eb0bSAyushi Smriti updateRetryCfg = true; 7887d1cc387SAppaRao Puli } 7897d1cc387SAppaRao Puli 7907d1cc387SAppaRao Puli if (updateConfig) 7917d1cc387SAppaRao Puli { 7927d1cc387SAppaRao Puli updateSubscriptionData(); 7937d1cc387SAppaRao Puli } 794fe44eb0bSAyushi Smriti 795fe44eb0bSAyushi Smriti if (updateRetryCfg) 796fe44eb0bSAyushi Smriti { 797fe44eb0bSAyushi Smriti // Update the changed retry config to all subscriptions 798fe44eb0bSAyushi Smriti for (const auto& it : 799fe44eb0bSAyushi Smriti EventServiceManager::getInstance().subscriptionsMap) 800fe44eb0bSAyushi Smriti { 801fe44eb0bSAyushi Smriti std::shared_ptr<Subscription> entry = it.second; 802fe44eb0bSAyushi Smriti entry->updateRetryConfig(retryAttempts, retryTimeoutInterval); 803fe44eb0bSAyushi Smriti } 804fe44eb0bSAyushi Smriti } 8057d1cc387SAppaRao Puli } 8067d1cc387SAppaRao Puli 8077d1cc387SAppaRao Puli void updateNoOfSubscribersCount() 8087d1cc387SAppaRao Puli { 8097d1cc387SAppaRao Puli size_t eventLogSubCount = 0; 8107d1cc387SAppaRao Puli size_t metricReportSubCount = 0; 8117d1cc387SAppaRao Puli for (const auto& it : subscriptionsMap) 8127d1cc387SAppaRao Puli { 8137d1cc387SAppaRao Puli std::shared_ptr<Subscription> entry = it.second; 8147d1cc387SAppaRao Puli if (entry->eventFormatType == eventFormatType) 8157d1cc387SAppaRao Puli { 8167d1cc387SAppaRao Puli eventLogSubCount++; 8177d1cc387SAppaRao Puli } 8187d1cc387SAppaRao Puli else if (entry->eventFormatType == metricReportFormatType) 8197d1cc387SAppaRao Puli { 8207d1cc387SAppaRao Puli metricReportSubCount++; 8217d1cc387SAppaRao Puli } 8227d1cc387SAppaRao Puli } 8237d1cc387SAppaRao Puli 8247d1cc387SAppaRao Puli noOfEventLogSubscribers = eventLogSubCount; 8257d1cc387SAppaRao Puli if (noOfMetricReportSubscribers != metricReportSubCount) 8267d1cc387SAppaRao Puli { 8277d1cc387SAppaRao Puli noOfMetricReportSubscribers = metricReportSubCount; 8287d1cc387SAppaRao Puli if (noOfMetricReportSubscribers) 8297d1cc387SAppaRao Puli { 8307d1cc387SAppaRao Puli registerMetricReportSignal(); 8317d1cc387SAppaRao Puli } 8327d1cc387SAppaRao Puli else 8337d1cc387SAppaRao Puli { 8347d1cc387SAppaRao Puli unregisterMetricReportSignal(); 8357d1cc387SAppaRao Puli } 8367d1cc387SAppaRao Puli } 8377d1cc387SAppaRao Puli } 8387d1cc387SAppaRao Puli 839b52664e2SAppaRao Puli std::shared_ptr<Subscription> getSubscription(const std::string& id) 840b52664e2SAppaRao Puli { 841b52664e2SAppaRao Puli auto obj = subscriptionsMap.find(id); 842b52664e2SAppaRao Puli if (obj == subscriptionsMap.end()) 843b52664e2SAppaRao Puli { 844b52664e2SAppaRao Puli BMCWEB_LOG_ERROR << "No subscription exist with ID:" << id; 845b52664e2SAppaRao Puli return nullptr; 846b52664e2SAppaRao Puli } 847b52664e2SAppaRao Puli std::shared_ptr<Subscription> subValue = obj->second; 848b52664e2SAppaRao Puli return subValue; 849b52664e2SAppaRao Puli } 850b52664e2SAppaRao Puli 851b5a76932SEd Tanous std::string addSubscription(const std::shared_ptr<Subscription>& subValue, 8521bf712bcSAyushi Smriti const bool updateFile = true) 853b52664e2SAppaRao Puli { 854fc76b8acSEd Tanous 855fc76b8acSEd Tanous std::uniform_int_distribution<uint32_t> dist(0); 856fc76b8acSEd Tanous bmcweb::OpenSSLGenerator gen; 857fc76b8acSEd Tanous 858b52664e2SAppaRao Puli std::string id; 859b52664e2SAppaRao Puli 860b52664e2SAppaRao Puli int retry = 3; 861b52664e2SAppaRao Puli while (retry) 862b52664e2SAppaRao Puli { 863fc76b8acSEd Tanous id = std::to_string(dist(gen)); 864fc76b8acSEd Tanous if (gen.error()) 865fc76b8acSEd Tanous { 866fc76b8acSEd Tanous retry = 0; 867fc76b8acSEd Tanous break; 868fc76b8acSEd Tanous } 869b52664e2SAppaRao Puli auto inserted = subscriptionsMap.insert(std::pair(id, subValue)); 870b52664e2SAppaRao Puli if (inserted.second) 871b52664e2SAppaRao Puli { 872b52664e2SAppaRao Puli break; 873b52664e2SAppaRao Puli } 874b52664e2SAppaRao Puli --retry; 87523a21a1cSEd Tanous } 876b52664e2SAppaRao Puli 877b52664e2SAppaRao Puli if (retry <= 0) 878b52664e2SAppaRao Puli { 879b52664e2SAppaRao Puli BMCWEB_LOG_ERROR << "Failed to generate random number"; 880abb93cddSEd Tanous return ""; 881b52664e2SAppaRao Puli } 882b52664e2SAppaRao Puli 88328afb49cSJunLin Chen std::shared_ptr<persistent_data::UserSubscription> newSub = 88428afb49cSJunLin Chen std::make_shared<persistent_data::UserSubscription>(); 88528afb49cSJunLin Chen newSub->id = id; 88628afb49cSJunLin Chen newSub->destinationUrl = subValue->destinationUrl; 88728afb49cSJunLin Chen newSub->protocol = subValue->protocol; 88828afb49cSJunLin Chen newSub->retryPolicy = subValue->retryPolicy; 88928afb49cSJunLin Chen newSub->customText = subValue->customText; 89028afb49cSJunLin Chen newSub->eventFormatType = subValue->eventFormatType; 89128afb49cSJunLin Chen newSub->subscriptionType = subValue->subscriptionType; 89228afb49cSJunLin Chen newSub->registryMsgIds = subValue->registryMsgIds; 89328afb49cSJunLin Chen newSub->registryPrefixes = subValue->registryPrefixes; 89428afb49cSJunLin Chen newSub->resourceTypes = subValue->resourceTypes; 89528afb49cSJunLin Chen newSub->httpHeaders = subValue->httpHeaders; 89628afb49cSJunLin Chen newSub->metricReportDefinitions = subValue->metricReportDefinitions; 89728afb49cSJunLin Chen persistent_data::EventServiceStore::getInstance() 89828afb49cSJunLin Chen .subscriptionsConfigMap.emplace(newSub->id, newSub); 89928afb49cSJunLin Chen 9007d1cc387SAppaRao Puli updateNoOfSubscribersCount(); 9011bf712bcSAyushi Smriti 9021bf712bcSAyushi Smriti if (updateFile) 9031bf712bcSAyushi Smriti { 904b52664e2SAppaRao Puli updateSubscriptionData(); 9051bf712bcSAyushi Smriti } 9067f4eb588SAppaRao Puli 9077f4eb588SAppaRao Puli #ifndef BMCWEB_ENABLE_REDFISH_DBUS_LOG_ENTRIES 9082558979cSP Dheeraj Srujan Kumar if (redfishLogFilePosition != 0) 9097f4eb588SAppaRao Puli { 9102558979cSP Dheeraj Srujan Kumar cacheRedfishLogFile(); 9117f4eb588SAppaRao Puli } 9127f4eb588SAppaRao Puli #endif 913fe44eb0bSAyushi Smriti // Update retry configuration. 914fe44eb0bSAyushi Smriti subValue->updateRetryConfig(retryAttempts, retryTimeoutInterval); 915fe44eb0bSAyushi Smriti subValue->updateRetryPolicy(); 916fe44eb0bSAyushi Smriti 917b52664e2SAppaRao Puli return id; 918b52664e2SAppaRao Puli } 919b52664e2SAppaRao Puli 920b52664e2SAppaRao Puli bool isSubscriptionExist(const std::string& id) 921b52664e2SAppaRao Puli { 922b52664e2SAppaRao Puli auto obj = subscriptionsMap.find(id); 923b52664e2SAppaRao Puli if (obj == subscriptionsMap.end()) 924b52664e2SAppaRao Puli { 925b52664e2SAppaRao Puli return false; 926b52664e2SAppaRao Puli } 927b52664e2SAppaRao Puli return true; 928b52664e2SAppaRao Puli } 929b52664e2SAppaRao Puli 930b52664e2SAppaRao Puli void deleteSubscription(const std::string& id) 931b52664e2SAppaRao Puli { 932b52664e2SAppaRao Puli auto obj = subscriptionsMap.find(id); 933b52664e2SAppaRao Puli if (obj != subscriptionsMap.end()) 934b52664e2SAppaRao Puli { 935b52664e2SAppaRao Puli subscriptionsMap.erase(obj); 93628afb49cSJunLin Chen auto obj2 = persistent_data::EventServiceStore::getInstance() 93728afb49cSJunLin Chen .subscriptionsConfigMap.find(id); 93828afb49cSJunLin Chen persistent_data::EventServiceStore::getInstance() 93928afb49cSJunLin Chen .subscriptionsConfigMap.erase(obj2); 9407d1cc387SAppaRao Puli updateNoOfSubscribersCount(); 941b52664e2SAppaRao Puli updateSubscriptionData(); 942b52664e2SAppaRao Puli } 943b52664e2SAppaRao Puli } 944b52664e2SAppaRao Puli 945b52664e2SAppaRao Puli size_t getNumberOfSubscriptions() 946b52664e2SAppaRao Puli { 947b52664e2SAppaRao Puli return subscriptionsMap.size(); 948b52664e2SAppaRao Puli } 949b52664e2SAppaRao Puli 950b52664e2SAppaRao Puli std::vector<std::string> getAllIDs() 951b52664e2SAppaRao Puli { 952b52664e2SAppaRao Puli std::vector<std::string> idList; 953b52664e2SAppaRao Puli for (const auto& it : subscriptionsMap) 954b52664e2SAppaRao Puli { 955b52664e2SAppaRao Puli idList.emplace_back(it.first); 956b52664e2SAppaRao Puli } 957b52664e2SAppaRao Puli return idList; 958b52664e2SAppaRao Puli } 959b52664e2SAppaRao Puli 960b52664e2SAppaRao Puli bool isDestinationExist(const std::string& destUrl) 961b52664e2SAppaRao Puli { 962b52664e2SAppaRao Puli for (const auto& it : subscriptionsMap) 963b52664e2SAppaRao Puli { 964b52664e2SAppaRao Puli std::shared_ptr<Subscription> entry = it.second; 965b52664e2SAppaRao Puli if (entry->destinationUrl == destUrl) 966b52664e2SAppaRao Puli { 967b52664e2SAppaRao Puli BMCWEB_LOG_ERROR << "Destination exist already" << destUrl; 968b52664e2SAppaRao Puli return true; 969b52664e2SAppaRao Puli } 970b52664e2SAppaRao Puli } 971b52664e2SAppaRao Puli return false; 972b52664e2SAppaRao Puli } 9730b4bdd93SAppaRao Puli 9740b4bdd93SAppaRao Puli void sendTestEventLog() 9750b4bdd93SAppaRao Puli { 9760b4bdd93SAppaRao Puli for (const auto& it : this->subscriptionsMap) 9770b4bdd93SAppaRao Puli { 9780b4bdd93SAppaRao Puli std::shared_ptr<Subscription> entry = it.second; 9790b4bdd93SAppaRao Puli entry->sendTestEventLog(); 9800b4bdd93SAppaRao Puli } 9810b4bdd93SAppaRao Puli } 982e9a14131SAppaRao Puli 98396330b99SSunitha Harish void sendEvent(const nlohmann::json& eventMessageIn, 98496330b99SSunitha Harish const std::string& origin, const std::string& resType) 98596330b99SSunitha Harish { 98696330b99SSunitha Harish nlohmann::json eventRecord = nlohmann::json::array(); 98796330b99SSunitha Harish nlohmann::json eventMessage = eventMessageIn; 98896330b99SSunitha Harish // MemberId is 0 : since we are sending one event record. 98996330b99SSunitha Harish uint64_t memberId = 0; 99096330b99SSunitha Harish 99196330b99SSunitha Harish nlohmann::json event = { 99296330b99SSunitha Harish {"EventId", eventId}, 99396330b99SSunitha Harish {"MemberId", memberId}, 9947c8c4058STejas Patil {"EventTimestamp", crow::utility::getDateTimeOffsetNow().first}, 99596330b99SSunitha Harish {"OriginOfCondition", origin}}; 99696330b99SSunitha Harish for (nlohmann::json::iterator it = event.begin(); it != event.end(); 99796330b99SSunitha Harish ++it) 99896330b99SSunitha Harish { 99996330b99SSunitha Harish eventMessage[it.key()] = it.value(); 100096330b99SSunitha Harish } 100196330b99SSunitha Harish eventRecord.push_back(eventMessage); 100296330b99SSunitha Harish 100396330b99SSunitha Harish for (const auto& it : this->subscriptionsMap) 100496330b99SSunitha Harish { 100596330b99SSunitha Harish std::shared_ptr<Subscription> entry = it.second; 100696330b99SSunitha Harish bool isSubscribed = false; 100796330b99SSunitha Harish // Search the resourceTypes list for the subscription. 100896330b99SSunitha Harish // If resourceTypes list is empty, don't filter events 100996330b99SSunitha Harish // send everything. 101096330b99SSunitha Harish if (entry->resourceTypes.size()) 101196330b99SSunitha Harish { 10123174e4dfSEd Tanous for (const auto& resource : entry->resourceTypes) 101396330b99SSunitha Harish { 101496330b99SSunitha Harish if (resType == resource) 101596330b99SSunitha Harish { 101696330b99SSunitha Harish BMCWEB_LOG_INFO << "ResourceType " << resource 101796330b99SSunitha Harish << " found in the subscribed list"; 101896330b99SSunitha Harish isSubscribed = true; 101996330b99SSunitha Harish break; 102096330b99SSunitha Harish } 102196330b99SSunitha Harish } 102296330b99SSunitha Harish } 102396330b99SSunitha Harish else // resourceTypes list is empty. 102496330b99SSunitha Harish { 102596330b99SSunitha Harish isSubscribed = true; 102696330b99SSunitha Harish } 102796330b99SSunitha Harish if (isSubscribed) 102896330b99SSunitha Harish { 102996330b99SSunitha Harish nlohmann::json msgJson = { 103096330b99SSunitha Harish {"@odata.type", "#Event.v1_4_0.Event"}, 103196330b99SSunitha Harish {"Name", "Event Log"}, 103296330b99SSunitha Harish {"Id", eventId}, 103396330b99SSunitha Harish {"Events", eventRecord}}; 103471f52d96SEd Tanous entry->sendEvent(msgJson.dump( 103571f52d96SEd Tanous 2, ' ', true, nlohmann::json::error_handler_t::replace)); 103696330b99SSunitha Harish eventId++; // increament the eventId 103796330b99SSunitha Harish } 103896330b99SSunitha Harish else 103996330b99SSunitha Harish { 104096330b99SSunitha Harish BMCWEB_LOG_INFO << "Not subscribed to this resource"; 104196330b99SSunitha Harish } 104296330b99SSunitha Harish } 104396330b99SSunitha Harish } 10445738de59SAsmitha Karunanithi void sendBroadcastMsg(const std::string& broadcastMsg) 10455738de59SAsmitha Karunanithi { 10465738de59SAsmitha Karunanithi for (const auto& it : this->subscriptionsMap) 10475738de59SAsmitha Karunanithi { 10485738de59SAsmitha Karunanithi std::shared_ptr<Subscription> entry = it.second; 10495738de59SAsmitha Karunanithi nlohmann::json msgJson = { 10507c8c4058STejas Patil {"Timestamp", crow::utility::getDateTimeOffsetNow().first}, 10515738de59SAsmitha Karunanithi {"OriginOfCondition", "/ibm/v1/HMC/BroadcastService"}, 10525738de59SAsmitha Karunanithi {"Name", "Broadcast Message"}, 10535738de59SAsmitha Karunanithi {"Message", broadcastMsg}}; 105471f52d96SEd Tanous entry->sendEvent(msgJson.dump( 105571f52d96SEd Tanous 2, ' ', true, nlohmann::json::error_handler_t::replace)); 10565738de59SAsmitha Karunanithi } 10575738de59SAsmitha Karunanithi } 105896330b99SSunitha Harish 10597f4eb588SAppaRao Puli #ifndef BMCWEB_ENABLE_REDFISH_DBUS_LOG_ENTRIES 10602558979cSP Dheeraj Srujan Kumar 10612558979cSP Dheeraj Srujan Kumar void resetRedfishFilePosition() 10627f4eb588SAppaRao Puli { 10632558979cSP Dheeraj Srujan Kumar // Control would be here when Redfish file is created. 10642558979cSP Dheeraj Srujan Kumar // Reset File Position as new file is created 10652558979cSP Dheeraj Srujan Kumar redfishLogFilePosition = 0; 10662558979cSP Dheeraj Srujan Kumar 10672558979cSP Dheeraj Srujan Kumar return; 10682558979cSP Dheeraj Srujan Kumar } 10692558979cSP Dheeraj Srujan Kumar 10702558979cSP Dheeraj Srujan Kumar void cacheRedfishLogFile() 10712558979cSP Dheeraj Srujan Kumar { 10722558979cSP Dheeraj Srujan Kumar // Open the redfish file and read till the last record. 10732558979cSP Dheeraj Srujan Kumar 10747f4eb588SAppaRao Puli std::ifstream logStream(redfishEventLogFile); 10757f4eb588SAppaRao Puli if (!logStream.good()) 10767f4eb588SAppaRao Puli { 10777f4eb588SAppaRao Puli BMCWEB_LOG_ERROR << " Redfish log file open failed \n"; 10787f4eb588SAppaRao Puli return; 10797f4eb588SAppaRao Puli } 10807f4eb588SAppaRao Puli std::string logEntry; 10817f4eb588SAppaRao Puli while (std::getline(logStream, logEntry)) 10827f4eb588SAppaRao Puli { 10832558979cSP Dheeraj Srujan Kumar redfishLogFilePosition = logStream.tellg(); 10847f4eb588SAppaRao Puli } 10852558979cSP Dheeraj Srujan Kumar 10862558979cSP Dheeraj Srujan Kumar BMCWEB_LOG_DEBUG << "Next Log Position : " << redfishLogFilePosition; 10877f4eb588SAppaRao Puli } 10887f4eb588SAppaRao Puli 10897f4eb588SAppaRao Puli void readEventLogsFromFile() 10907f4eb588SAppaRao Puli { 10917f4eb588SAppaRao Puli std::ifstream logStream(redfishEventLogFile); 10927f4eb588SAppaRao Puli if (!logStream.good()) 10937f4eb588SAppaRao Puli { 10947f4eb588SAppaRao Puli BMCWEB_LOG_ERROR << " Redfish log file open failed"; 10957f4eb588SAppaRao Puli return; 10967f4eb588SAppaRao Puli } 10977f4eb588SAppaRao Puli 10987f4eb588SAppaRao Puli std::vector<EventLogObjectsType> eventRecords; 10997f4eb588SAppaRao Puli 11007f4eb588SAppaRao Puli std::string logEntry; 11012558979cSP Dheeraj Srujan Kumar 11022558979cSP Dheeraj Srujan Kumar // Get the read pointer to the next log to be read. 11032558979cSP Dheeraj Srujan Kumar logStream.seekg(redfishLogFilePosition); 11042558979cSP Dheeraj Srujan Kumar 11057f4eb588SAppaRao Puli while (std::getline(logStream, logEntry)) 11067f4eb588SAppaRao Puli { 11072558979cSP Dheeraj Srujan Kumar // Update Pointer position 11082558979cSP Dheeraj Srujan Kumar redfishLogFilePosition = logStream.tellg(); 11092558979cSP Dheeraj Srujan Kumar 11102558979cSP Dheeraj Srujan Kumar std::string idStr; 11112558979cSP Dheeraj Srujan Kumar if (!event_log::getUniqueEntryID(logEntry, idStr)) 11127f4eb588SAppaRao Puli { 11137f4eb588SAppaRao Puli continue; 11147f4eb588SAppaRao Puli } 11157f4eb588SAppaRao Puli 11162558979cSP Dheeraj Srujan Kumar if (!serviceEnabled || !noOfEventLogSubscribers) 11177f4eb588SAppaRao Puli { 11182558979cSP Dheeraj Srujan Kumar // If Service is not enabled, no need to compute 11192558979cSP Dheeraj Srujan Kumar // the remaining items below. 11202558979cSP Dheeraj Srujan Kumar // But, Loop must continue to keep track of Timestamp 11217f4eb588SAppaRao Puli continue; 11227f4eb588SAppaRao Puli } 11237f4eb588SAppaRao Puli 11247f4eb588SAppaRao Puli std::string timestamp; 11257f4eb588SAppaRao Puli std::string messageID; 11265e715de6SAppaRao Puli std::vector<std::string> messageArgs; 11277f4eb588SAppaRao Puli if (event_log::getEventLogParams(logEntry, timestamp, messageID, 11287f4eb588SAppaRao Puli messageArgs) != 0) 11297f4eb588SAppaRao Puli { 11307f4eb588SAppaRao Puli BMCWEB_LOG_DEBUG << "Read eventLog entry params failed"; 11317f4eb588SAppaRao Puli continue; 11327f4eb588SAppaRao Puli } 11337f4eb588SAppaRao Puli 11347f4eb588SAppaRao Puli std::string registryName; 11357f4eb588SAppaRao Puli std::string messageKey; 11367f4eb588SAppaRao Puli event_log::getRegistryAndMessageKey(messageID, registryName, 11377f4eb588SAppaRao Puli messageKey); 11387f4eb588SAppaRao Puli if (registryName.empty() || messageKey.empty()) 11397f4eb588SAppaRao Puli { 11407f4eb588SAppaRao Puli continue; 11417f4eb588SAppaRao Puli } 11427f4eb588SAppaRao Puli 11437f4eb588SAppaRao Puli eventRecords.emplace_back(idStr, timestamp, messageID, registryName, 11447f4eb588SAppaRao Puli messageKey, messageArgs); 11457f4eb588SAppaRao Puli } 11467f4eb588SAppaRao Puli 11472558979cSP Dheeraj Srujan Kumar if (!serviceEnabled || !noOfEventLogSubscribers) 11482558979cSP Dheeraj Srujan Kumar { 11492558979cSP Dheeraj Srujan Kumar BMCWEB_LOG_DEBUG << "EventService disabled or no Subscriptions."; 11502558979cSP Dheeraj Srujan Kumar return; 11512558979cSP Dheeraj Srujan Kumar } 11522558979cSP Dheeraj Srujan Kumar 11532558979cSP Dheeraj Srujan Kumar if (eventRecords.empty()) 11542558979cSP Dheeraj Srujan Kumar { 11552558979cSP Dheeraj Srujan Kumar // No Records to send 11562558979cSP Dheeraj Srujan Kumar BMCWEB_LOG_DEBUG << "No log entries available to be transferred."; 11572558979cSP Dheeraj Srujan Kumar return; 11582558979cSP Dheeraj Srujan Kumar } 11592558979cSP Dheeraj Srujan Kumar 11607f4eb588SAppaRao Puli for (const auto& it : this->subscriptionsMap) 11617f4eb588SAppaRao Puli { 11627f4eb588SAppaRao Puli std::shared_ptr<Subscription> entry = it.second; 11637f4eb588SAppaRao Puli if (entry->eventFormatType == "Event") 11647f4eb588SAppaRao Puli { 11657f4eb588SAppaRao Puli entry->filterAndSendEventLogs(eventRecords); 11667f4eb588SAppaRao Puli } 11677f4eb588SAppaRao Puli } 11687f4eb588SAppaRao Puli } 11697f4eb588SAppaRao Puli 11707f4eb588SAppaRao Puli static void watchRedfishEventLogFile() 11717f4eb588SAppaRao Puli { 11726a9f85f9SAppaRao Puli if (!inotifyConn) 11737f4eb588SAppaRao Puli { 11747f4eb588SAppaRao Puli return; 11757f4eb588SAppaRao Puli } 11767f4eb588SAppaRao Puli 11777f4eb588SAppaRao Puli static std::array<char, 1024> readBuffer; 11787f4eb588SAppaRao Puli 11797f4eb588SAppaRao Puli inotifyConn->async_read_some( 11807f4eb588SAppaRao Puli boost::asio::buffer(readBuffer), 11817f4eb588SAppaRao Puli [&](const boost::system::error_code& ec, 11827f4eb588SAppaRao Puli const std::size_t& bytesTransferred) { 11837f4eb588SAppaRao Puli if (ec) 11847f4eb588SAppaRao Puli { 11857f4eb588SAppaRao Puli BMCWEB_LOG_ERROR << "Callback Error: " << ec.message(); 11867f4eb588SAppaRao Puli return; 11877f4eb588SAppaRao Puli } 11887f4eb588SAppaRao Puli std::size_t index = 0; 1189b792cc56SAppaRao Puli while ((index + iEventSize) <= bytesTransferred) 11907f4eb588SAppaRao Puli { 11917f4eb588SAppaRao Puli struct inotify_event event; 1192b792cc56SAppaRao Puli std::memcpy(&event, &readBuffer[index], iEventSize); 1193b792cc56SAppaRao Puli if (event.wd == dirWatchDesc) 1194b792cc56SAppaRao Puli { 1195b792cc56SAppaRao Puli if ((event.len == 0) || 1196b792cc56SAppaRao Puli (index + iEventSize + event.len > bytesTransferred)) 1197b792cc56SAppaRao Puli { 1198b792cc56SAppaRao Puli index += (iEventSize + event.len); 1199b792cc56SAppaRao Puli continue; 1200b792cc56SAppaRao Puli } 1201b792cc56SAppaRao Puli 1202b792cc56SAppaRao Puli std::string fileName(&readBuffer[index + iEventSize], 1203b792cc56SAppaRao Puli event.len); 1204b792cc56SAppaRao Puli if (std::strcmp(fileName.c_str(), "redfish") != 0) 1205b792cc56SAppaRao Puli { 1206b792cc56SAppaRao Puli index += (iEventSize + event.len); 1207b792cc56SAppaRao Puli continue; 1208b792cc56SAppaRao Puli } 1209b792cc56SAppaRao Puli 1210b792cc56SAppaRao Puli BMCWEB_LOG_DEBUG 1211b792cc56SAppaRao Puli << "Redfish log file created/deleted. event.name: " 1212b792cc56SAppaRao Puli << fileName; 1213b792cc56SAppaRao Puli if (event.mask == IN_CREATE) 1214b792cc56SAppaRao Puli { 1215b792cc56SAppaRao Puli if (fileWatchDesc != -1) 1216b792cc56SAppaRao Puli { 1217b792cc56SAppaRao Puli BMCWEB_LOG_DEBUG 1218016761afSAppaRao Puli << "Remove and Add inotify watcher on " 1219016761afSAppaRao Puli "redfish event log file"; 1220016761afSAppaRao Puli // Remove existing inotify watcher and add 1221016761afSAppaRao Puli // with new redfish event log file. 1222016761afSAppaRao Puli inotify_rm_watch(inotifyFd, fileWatchDesc); 1223016761afSAppaRao Puli fileWatchDesc = -1; 1224b792cc56SAppaRao Puli } 1225b792cc56SAppaRao Puli 1226b792cc56SAppaRao Puli fileWatchDesc = inotify_add_watch( 1227b792cc56SAppaRao Puli inotifyFd, redfishEventLogFile, IN_MODIFY); 1228b792cc56SAppaRao Puli if (fileWatchDesc == -1) 1229b792cc56SAppaRao Puli { 1230b792cc56SAppaRao Puli BMCWEB_LOG_ERROR 1231b792cc56SAppaRao Puli << "inotify_add_watch failed for " 1232b792cc56SAppaRao Puli "redfish log file."; 1233b792cc56SAppaRao Puli return; 1234b792cc56SAppaRao Puli } 1235b792cc56SAppaRao Puli 1236b792cc56SAppaRao Puli EventServiceManager::getInstance() 12372558979cSP Dheeraj Srujan Kumar .resetRedfishFilePosition(); 1238b792cc56SAppaRao Puli EventServiceManager::getInstance() 1239b792cc56SAppaRao Puli .readEventLogsFromFile(); 1240b792cc56SAppaRao Puli } 1241b792cc56SAppaRao Puli else if ((event.mask == IN_DELETE) || 1242b792cc56SAppaRao Puli (event.mask == IN_MOVED_TO)) 1243b792cc56SAppaRao Puli { 1244b792cc56SAppaRao Puli if (fileWatchDesc != -1) 1245b792cc56SAppaRao Puli { 1246b792cc56SAppaRao Puli inotify_rm_watch(inotifyFd, fileWatchDesc); 1247b792cc56SAppaRao Puli fileWatchDesc = -1; 1248b792cc56SAppaRao Puli } 1249b792cc56SAppaRao Puli } 1250b792cc56SAppaRao Puli } 1251b792cc56SAppaRao Puli else if (event.wd == fileWatchDesc) 1252b792cc56SAppaRao Puli { 1253b792cc56SAppaRao Puli if (event.mask == IN_MODIFY) 12547f4eb588SAppaRao Puli { 12557f4eb588SAppaRao Puli EventServiceManager::getInstance() 12567f4eb588SAppaRao Puli .readEventLogsFromFile(); 12577f4eb588SAppaRao Puli } 1258b792cc56SAppaRao Puli } 1259b792cc56SAppaRao Puli index += (iEventSize + event.len); 12607f4eb588SAppaRao Puli } 12617f4eb588SAppaRao Puli 12627f4eb588SAppaRao Puli watchRedfishEventLogFile(); 12637f4eb588SAppaRao Puli }); 12647f4eb588SAppaRao Puli } 12657f4eb588SAppaRao Puli 12667f4eb588SAppaRao Puli static int startEventLogMonitor(boost::asio::io_context& ioc) 12677f4eb588SAppaRao Puli { 126823a21a1cSEd Tanous inotifyConn.emplace(ioc); 1269b792cc56SAppaRao Puli inotifyFd = inotify_init1(IN_NONBLOCK); 1270b792cc56SAppaRao Puli if (inotifyFd == -1) 12717f4eb588SAppaRao Puli { 12727f4eb588SAppaRao Puli BMCWEB_LOG_ERROR << "inotify_init1 failed."; 12737f4eb588SAppaRao Puli return -1; 12747f4eb588SAppaRao Puli } 1275b792cc56SAppaRao Puli 1276b792cc56SAppaRao Puli // Add watch on directory to handle redfish event log file 1277b792cc56SAppaRao Puli // create/delete. 1278b792cc56SAppaRao Puli dirWatchDesc = inotify_add_watch(inotifyFd, redfishEventLogDir, 1279b792cc56SAppaRao Puli IN_CREATE | IN_MOVED_TO | IN_DELETE); 1280b792cc56SAppaRao Puli if (dirWatchDesc == -1) 12817f4eb588SAppaRao Puli { 12827f4eb588SAppaRao Puli BMCWEB_LOG_ERROR 1283b792cc56SAppaRao Puli << "inotify_add_watch failed for event log directory."; 12847f4eb588SAppaRao Puli return -1; 12857f4eb588SAppaRao Puli } 12867f4eb588SAppaRao Puli 1287b792cc56SAppaRao Puli // Watch redfish event log file for modifications. 1288b792cc56SAppaRao Puli fileWatchDesc = 1289b792cc56SAppaRao Puli inotify_add_watch(inotifyFd, redfishEventLogFile, IN_MODIFY); 1290b792cc56SAppaRao Puli if (fileWatchDesc == -1) 1291b792cc56SAppaRao Puli { 1292b792cc56SAppaRao Puli BMCWEB_LOG_ERROR 1293b792cc56SAppaRao Puli << "inotify_add_watch failed for redfish log file."; 1294b792cc56SAppaRao Puli // Don't return error if file not exist. 1295b792cc56SAppaRao Puli // Watch on directory will handle create/delete of file. 1296b792cc56SAppaRao Puli } 1297b792cc56SAppaRao Puli 12987f4eb588SAppaRao Puli // monitor redfish event log file 1299b792cc56SAppaRao Puli inotifyConn->assign(inotifyFd); 13007f4eb588SAppaRao Puli watchRedfishEventLogFile(); 13017f4eb588SAppaRao Puli 13027f4eb588SAppaRao Puli return 0; 13037f4eb588SAppaRao Puli } 13047f4eb588SAppaRao Puli 13057f4eb588SAppaRao Puli #endif 1306c0353249SWludzik, Jozef void getReadingsForReport(sdbusplus::message::message& msg) 1307156d6b00SAppaRao Puli { 1308c0353249SWludzik, Jozef sdbusplus::message::object_path path(msg.get_path()); 1309c0353249SWludzik, Jozef std::string id = path.filename(); 1310c0353249SWludzik, Jozef if (id.empty()) 1311156d6b00SAppaRao Puli { 1312c0353249SWludzik, Jozef BMCWEB_LOG_ERROR << "Failed to get Id from path"; 1313156d6b00SAppaRao Puli return; 1314156d6b00SAppaRao Puli } 1315156d6b00SAppaRao Puli 1316c0353249SWludzik, Jozef std::string interface; 1317*168e20c1SEd Tanous std::vector<std::pair<std::string, dbus::utility::DbusVariantType>> 1318c0353249SWludzik, Jozef props; 1319c0353249SWludzik, Jozef std::vector<std::string> invalidProps; 1320c0353249SWludzik, Jozef msg.read(interface, props, invalidProps); 1321c0353249SWludzik, Jozef 1322c0353249SWludzik, Jozef auto found = 1323c0353249SWludzik, Jozef std::find_if(props.begin(), props.end(), 1324c0353249SWludzik, Jozef [](const auto& x) { return x.first == "Readings"; }); 1325c0353249SWludzik, Jozef if (found == props.end()) 1326156d6b00SAppaRao Puli { 1327c0353249SWludzik, Jozef BMCWEB_LOG_INFO << "Failed to get Readings from Report properties"; 1328156d6b00SAppaRao Puli return; 1329156d6b00SAppaRao Puli } 1330156d6b00SAppaRao Puli 1331*168e20c1SEd Tanous const dbus::utility::DbusVariantType& readings = found->second; 1332156d6b00SAppaRao Puli for (const auto& it : 1333156d6b00SAppaRao Puli EventServiceManager::getInstance().subscriptionsMap) 1334156d6b00SAppaRao Puli { 1335c0353249SWludzik, Jozef Subscription& entry = *it.second.get(); 1336c0353249SWludzik, Jozef if (entry.eventFormatType == metricReportFormatType) 1337156d6b00SAppaRao Puli { 1338c0353249SWludzik, Jozef entry.filterAndSendReports(id, readings); 1339156d6b00SAppaRao Puli } 1340156d6b00SAppaRao Puli } 1341156d6b00SAppaRao Puli } 1342156d6b00SAppaRao Puli 1343156d6b00SAppaRao Puli void unregisterMetricReportSignal() 1344156d6b00SAppaRao Puli { 13457d1cc387SAppaRao Puli if (matchTelemetryMonitor) 13467d1cc387SAppaRao Puli { 1347156d6b00SAppaRao Puli BMCWEB_LOG_DEBUG << "Metrics report signal - Unregister"; 1348156d6b00SAppaRao Puli matchTelemetryMonitor.reset(); 1349156d6b00SAppaRao Puli matchTelemetryMonitor = nullptr; 1350156d6b00SAppaRao Puli } 13517d1cc387SAppaRao Puli } 1352156d6b00SAppaRao Puli 1353156d6b00SAppaRao Puli void registerMetricReportSignal() 1354156d6b00SAppaRao Puli { 13557d1cc387SAppaRao Puli if (!serviceEnabled || matchTelemetryMonitor) 1356156d6b00SAppaRao Puli { 13577d1cc387SAppaRao Puli BMCWEB_LOG_DEBUG << "Not registering metric report signal."; 1358156d6b00SAppaRao Puli return; 1359156d6b00SAppaRao Puli } 1360156d6b00SAppaRao Puli 1361156d6b00SAppaRao Puli BMCWEB_LOG_DEBUG << "Metrics report signal - Register"; 1362c0353249SWludzik, Jozef std::string matchStr = "type='signal',member='PropertiesChanged'," 1363c0353249SWludzik, Jozef "interface='org.freedesktop.DBus.Properties'," 1364c0353249SWludzik, Jozef "arg0=xyz.openbmc_project.Telemetry.Report"; 1365156d6b00SAppaRao Puli 1366156d6b00SAppaRao Puli matchTelemetryMonitor = std::make_shared<sdbusplus::bus::match::match>( 1367156d6b00SAppaRao Puli *crow::connections::systemBus, matchStr, 1368156d6b00SAppaRao Puli [this](sdbusplus::message::message& msg) { 1369156d6b00SAppaRao Puli if (msg.is_method_error()) 1370156d6b00SAppaRao Puli { 1371156d6b00SAppaRao Puli BMCWEB_LOG_ERROR << "TelemetryMonitor Signal error"; 1372156d6b00SAppaRao Puli return; 1373156d6b00SAppaRao Puli } 1374156d6b00SAppaRao Puli 1375c0353249SWludzik, Jozef getReadingsForReport(msg); 1376156d6b00SAppaRao Puli }); 1377156d6b00SAppaRao Puli } 13781bf712bcSAyushi Smriti 13791bf712bcSAyushi Smriti bool validateAndSplitUrl(const std::string& destUrl, std::string& urlProto, 13801bf712bcSAyushi Smriti std::string& host, std::string& port, 13811bf712bcSAyushi Smriti std::string& path) 13821bf712bcSAyushi Smriti { 13831bf712bcSAyushi Smriti // Validate URL using regex expression 13841bf712bcSAyushi Smriti // Format: <protocol>://<host>:<port>/<path> 13851bf712bcSAyushi Smriti // protocol: http/https 13861bf712bcSAyushi Smriti const std::regex urlRegex( 13871bf712bcSAyushi Smriti "(http|https)://([^/\\x20\\x3f\\x23\\x3a]+):?([0-9]*)(/" 13881bf712bcSAyushi Smriti "([^\\x20\\x23\\x3f]*\\x3f?([^\\x20\\x23\\x3f])*)?)"); 13891bf712bcSAyushi Smriti std::cmatch match; 13901bf712bcSAyushi Smriti if (!std::regex_match(destUrl.c_str(), match, urlRegex)) 13911bf712bcSAyushi Smriti { 13921bf712bcSAyushi Smriti BMCWEB_LOG_INFO << "Dest. url did not match "; 13931bf712bcSAyushi Smriti return false; 13941bf712bcSAyushi Smriti } 13951bf712bcSAyushi Smriti 13961bf712bcSAyushi Smriti urlProto = std::string(match[1].first, match[1].second); 13971bf712bcSAyushi Smriti if (urlProto == "http") 13981bf712bcSAyushi Smriti { 13991bf712bcSAyushi Smriti #ifndef BMCWEB_INSECURE_ENABLE_HTTP_PUSH_STYLE_EVENTING 14001bf712bcSAyushi Smriti return false; 14011bf712bcSAyushi Smriti #endif 14021bf712bcSAyushi Smriti } 14031bf712bcSAyushi Smriti 14041bf712bcSAyushi Smriti host = std::string(match[2].first, match[2].second); 14051bf712bcSAyushi Smriti port = std::string(match[3].first, match[3].second); 14061bf712bcSAyushi Smriti path = std::string(match[4].first, match[4].second); 14071bf712bcSAyushi Smriti if (port.empty()) 14081bf712bcSAyushi Smriti { 14091bf712bcSAyushi Smriti if (urlProto == "http") 14101bf712bcSAyushi Smriti { 14111bf712bcSAyushi Smriti port = "80"; 14121bf712bcSAyushi Smriti } 14131bf712bcSAyushi Smriti else 14141bf712bcSAyushi Smriti { 14151bf712bcSAyushi Smriti port = "443"; 14161bf712bcSAyushi Smriti } 14171bf712bcSAyushi Smriti } 14181bf712bcSAyushi Smriti if (path.empty()) 14191bf712bcSAyushi Smriti { 14201bf712bcSAyushi Smriti path = "/"; 14211bf712bcSAyushi Smriti } 14221bf712bcSAyushi Smriti return true; 14231bf712bcSAyushi Smriti } 142423a21a1cSEd Tanous }; 1425b52664e2SAppaRao Puli 1426b52664e2SAppaRao Puli } // namespace redfish 1427