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 17b52664e2SAppaRao Puli #include "node.hpp" 18e9a14131SAppaRao Puli #include "registries.hpp" 19e9a14131SAppaRao Puli #include "registries/base_message_registry.hpp" 20e9a14131SAppaRao Puli #include "registries/openbmc_message_registry.hpp" 21e9a14131SAppaRao Puli 22e9a14131SAppaRao Puli #include <sys/inotify.h> 23b52664e2SAppaRao Puli 24*fb4fd5d4SZhenfei Tai #include <boost/asio/io_context.hpp> 25b52664e2SAppaRao Puli #include <boost/container/flat_map.hpp> 26b52664e2SAppaRao Puli #include <cstdlib> 27b52664e2SAppaRao Puli #include <ctime> 28b52664e2SAppaRao Puli #include <error_messages.hpp> 291bf712bcSAyushi Smriti #include <fstream> 30b52664e2SAppaRao Puli #include <http_client.hpp> 31b52664e2SAppaRao Puli #include <memory> 32b52664e2SAppaRao Puli #include <utils/json_utils.hpp> 33b52664e2SAppaRao Puli #include <variant> 34b52664e2SAppaRao Puli 35b52664e2SAppaRao Puli namespace redfish 36b52664e2SAppaRao Puli { 37156d6b00SAppaRao Puli 38156d6b00SAppaRao Puli using ReadingsObjType = 39156d6b00SAppaRao Puli std::vector<std::tuple<std::string, std::string, double, std::string>>; 407d1cc387SAppaRao Puli using EventServiceConfig = std::tuple<bool, uint32_t, uint32_t>; 41156d6b00SAppaRao Puli 42156d6b00SAppaRao Puli static constexpr const char* eventFormatType = "Event"; 43156d6b00SAppaRao Puli static constexpr const char* metricReportFormatType = "MetricReport"; 44156d6b00SAppaRao Puli 451bf712bcSAyushi Smriti static constexpr const char* eventServiceFile = 461bf712bcSAyushi Smriti "/var/lib/bmcweb/eventservice_config.json"; 471bf712bcSAyushi Smriti 48e9a14131SAppaRao Puli #ifndef BMCWEB_ENABLE_REDFISH_DBUS_LOG_ENTRIES 49e9a14131SAppaRao Puli constexpr const char* redfishEventLogFile = "/var/log/redfish"; 50e9a14131SAppaRao Puli constexpr const uint32_t inotifyFileAction = IN_MODIFY; 51e9a14131SAppaRao Puli std::shared_ptr<boost::asio::posix::stream_descriptor> inotifyConn = nullptr; 52e9a14131SAppaRao Puli 53e9a14131SAppaRao Puli // <ID, timestamp, RedfishLogId, registryPrefix, MessageId, MessageArgs> 54e9a14131SAppaRao Puli using EventLogObjectsType = 55e9a14131SAppaRao Puli std::tuple<std::string, std::string, std::string, std::string, std::string, 56e9a14131SAppaRao Puli boost::beast::span<std::string>>; 57e9a14131SAppaRao Puli 58e9a14131SAppaRao Puli namespace message_registries 59e9a14131SAppaRao Puli { 60e9a14131SAppaRao Puli static const Message* 61e9a14131SAppaRao Puli getMsgFromRegistry(const std::string& messageKey, 62e9a14131SAppaRao Puli const boost::beast::span<const MessageEntry>& registry) 63e9a14131SAppaRao Puli { 64e9a14131SAppaRao Puli boost::beast::span<const MessageEntry>::const_iterator messageIt = 65e9a14131SAppaRao Puli std::find_if(registry.cbegin(), registry.cend(), 66e9a14131SAppaRao Puli [&messageKey](const MessageEntry& messageEntry) { 67e9a14131SAppaRao Puli return !messageKey.compare(messageEntry.first); 68e9a14131SAppaRao Puli }); 69e9a14131SAppaRao Puli if (messageIt != registry.cend()) 70e9a14131SAppaRao Puli { 71e9a14131SAppaRao Puli return &messageIt->second; 72e9a14131SAppaRao Puli } 73e9a14131SAppaRao Puli 74e9a14131SAppaRao Puli return nullptr; 75e9a14131SAppaRao Puli } 76e9a14131SAppaRao Puli 77e9a14131SAppaRao Puli static const Message* formatMessage(const std::string_view& messageID) 78e9a14131SAppaRao Puli { 79e9a14131SAppaRao Puli // Redfish MessageIds are in the form 80e9a14131SAppaRao Puli // RegistryName.MajorVersion.MinorVersion.MessageKey, so parse it to find 81e9a14131SAppaRao Puli // the right Message 82e9a14131SAppaRao Puli std::vector<std::string> fields; 83e9a14131SAppaRao Puli fields.reserve(4); 84e9a14131SAppaRao Puli boost::split(fields, messageID, boost::is_any_of(".")); 85e9a14131SAppaRao Puli if (fields.size() != 4) 86e9a14131SAppaRao Puli { 87e9a14131SAppaRao Puli return nullptr; 88e9a14131SAppaRao Puli } 89e9a14131SAppaRao Puli std::string& registryName = fields[0]; 90e9a14131SAppaRao Puli std::string& messageKey = fields[3]; 91e9a14131SAppaRao Puli 92e9a14131SAppaRao Puli // Find the right registry and check it for the MessageKey 93e9a14131SAppaRao Puli if (std::string(base::header.registryPrefix) == registryName) 94e9a14131SAppaRao Puli { 95e9a14131SAppaRao Puli return getMsgFromRegistry( 96e9a14131SAppaRao Puli messageKey, boost::beast::span<const MessageEntry>(base::registry)); 97e9a14131SAppaRao Puli } 98e9a14131SAppaRao Puli if (std::string(openbmc::header.registryPrefix) == registryName) 99e9a14131SAppaRao Puli { 100e9a14131SAppaRao Puli return getMsgFromRegistry( 101e9a14131SAppaRao Puli messageKey, 102e9a14131SAppaRao Puli boost::beast::span<const MessageEntry>(openbmc::registry)); 103e9a14131SAppaRao Puli } 104e9a14131SAppaRao Puli return nullptr; 105e9a14131SAppaRao Puli } 106e9a14131SAppaRao Puli } // namespace message_registries 107e9a14131SAppaRao Puli 108e9a14131SAppaRao Puli namespace event_log 109e9a14131SAppaRao Puli { 110e9a14131SAppaRao Puli bool getUniqueEntryID(const std::string& logEntry, std::string& entryID, 111e9a14131SAppaRao Puli const bool firstEntry = true) 112e9a14131SAppaRao Puli { 113e9a14131SAppaRao Puli static time_t prevTs = 0; 114e9a14131SAppaRao Puli static int index = 0; 115e9a14131SAppaRao Puli if (firstEntry) 116e9a14131SAppaRao Puli { 117e9a14131SAppaRao Puli prevTs = 0; 118e9a14131SAppaRao Puli } 119e9a14131SAppaRao Puli 120e9a14131SAppaRao Puli // Get the entry timestamp 121e9a14131SAppaRao Puli std::time_t curTs = 0; 122e9a14131SAppaRao Puli std::tm timeStruct = {}; 123e9a14131SAppaRao Puli std::istringstream entryStream(logEntry); 124e9a14131SAppaRao Puli if (entryStream >> std::get_time(&timeStruct, "%Y-%m-%dT%H:%M:%S")) 125e9a14131SAppaRao Puli { 126e9a14131SAppaRao Puli curTs = std::mktime(&timeStruct); 127e9a14131SAppaRao Puli if (curTs == -1) 128e9a14131SAppaRao Puli { 129e9a14131SAppaRao Puli return false; 130e9a14131SAppaRao Puli } 131e9a14131SAppaRao Puli } 132e9a14131SAppaRao Puli // If the timestamp isn't unique, increment the index 133e9a14131SAppaRao Puli index = (curTs == prevTs) ? index + 1 : 0; 134e9a14131SAppaRao Puli 135e9a14131SAppaRao Puli // Save the timestamp 136e9a14131SAppaRao Puli prevTs = curTs; 137e9a14131SAppaRao Puli 138e9a14131SAppaRao Puli entryID = std::to_string(curTs); 139e9a14131SAppaRao Puli if (index > 0) 140e9a14131SAppaRao Puli { 141e9a14131SAppaRao Puli entryID += "_" + std::to_string(index); 142e9a14131SAppaRao Puli } 143e9a14131SAppaRao Puli return true; 144e9a14131SAppaRao Puli } 145e9a14131SAppaRao Puli 146e9a14131SAppaRao Puli int getEventLogParams(const std::string& logEntry, std::string& timestamp, 147e9a14131SAppaRao Puli std::string& messageID, 148e9a14131SAppaRao Puli boost::beast::span<std::string>& messageArgs) 149e9a14131SAppaRao Puli { 150e9a14131SAppaRao Puli // The redfish log format is "<Timestamp> <MessageId>,<MessageArgs>" 151e9a14131SAppaRao Puli // First get the Timestamp 152e9a14131SAppaRao Puli size_t space = logEntry.find_first_of(" "); 153e9a14131SAppaRao Puli if (space == std::string::npos) 154e9a14131SAppaRao Puli { 155e9a14131SAppaRao Puli return -EINVAL; 156e9a14131SAppaRao Puli } 157e9a14131SAppaRao Puli timestamp = logEntry.substr(0, space); 158e9a14131SAppaRao Puli // Then get the log contents 159e9a14131SAppaRao Puli size_t entryStart = logEntry.find_first_not_of(" ", space); 160e9a14131SAppaRao Puli if (entryStart == std::string::npos) 161e9a14131SAppaRao Puli { 162e9a14131SAppaRao Puli return -EINVAL; 163e9a14131SAppaRao Puli } 164e9a14131SAppaRao Puli std::string_view entry(logEntry); 165e9a14131SAppaRao Puli entry.remove_prefix(entryStart); 166e9a14131SAppaRao Puli // Use split to separate the entry into its fields 167e9a14131SAppaRao Puli std::vector<std::string> logEntryFields; 168e9a14131SAppaRao Puli boost::split(logEntryFields, entry, boost::is_any_of(","), 169e9a14131SAppaRao Puli boost::token_compress_on); 170e9a14131SAppaRao Puli // We need at least a MessageId to be valid 171e9a14131SAppaRao Puli if (logEntryFields.size() < 1) 172e9a14131SAppaRao Puli { 173e9a14131SAppaRao Puli return -EINVAL; 174e9a14131SAppaRao Puli } 175e9a14131SAppaRao Puli messageID = logEntryFields[0]; 176e9a14131SAppaRao Puli 177e9a14131SAppaRao Puli // Get the MessageArgs from the log if there are any 178e9a14131SAppaRao Puli if (logEntryFields.size() > 1) 179e9a14131SAppaRao Puli { 180e9a14131SAppaRao Puli std::string& messageArgsStart = logEntryFields[1]; 181e9a14131SAppaRao Puli // If the first string is empty, assume there are no MessageArgs 182e9a14131SAppaRao Puli std::size_t messageArgsSize = 0; 183e9a14131SAppaRao Puli if (!messageArgsStart.empty()) 184e9a14131SAppaRao Puli { 185e9a14131SAppaRao Puli messageArgsSize = logEntryFields.size() - 1; 186e9a14131SAppaRao Puli } 187e9a14131SAppaRao Puli 188e9a14131SAppaRao Puli messageArgs = boost::beast::span(&messageArgsStart, messageArgsSize); 189e9a14131SAppaRao Puli } 190e9a14131SAppaRao Puli 191e9a14131SAppaRao Puli return 0; 192e9a14131SAppaRao Puli } 193e9a14131SAppaRao Puli 194e9a14131SAppaRao Puli void getRegistryAndMessageKey(const std::string& messageID, 195e9a14131SAppaRao Puli std::string& registryName, 196e9a14131SAppaRao Puli std::string& messageKey) 197e9a14131SAppaRao Puli { 198e9a14131SAppaRao Puli // Redfish MessageIds are in the form 199e9a14131SAppaRao Puli // RegistryName.MajorVersion.MinorVersion.MessageKey, so parse it to find 200e9a14131SAppaRao Puli // the right Message 201e9a14131SAppaRao Puli std::vector<std::string> fields; 202e9a14131SAppaRao Puli fields.reserve(4); 203e9a14131SAppaRao Puli boost::split(fields, messageID, boost::is_any_of(".")); 204e9a14131SAppaRao Puli if (fields.size() == 4) 205e9a14131SAppaRao Puli { 206e9a14131SAppaRao Puli registryName = fields[0]; 207e9a14131SAppaRao Puli messageKey = fields[3]; 208e9a14131SAppaRao Puli } 209e9a14131SAppaRao Puli } 210e9a14131SAppaRao Puli 211e9a14131SAppaRao Puli int formatEventLogEntry(const std::string& logEntryID, 212e9a14131SAppaRao Puli const std::string& messageID, 213e9a14131SAppaRao Puli const boost::beast::span<std::string>& messageArgs, 214e9a14131SAppaRao Puli std::string timestamp, const std::string customText, 215e9a14131SAppaRao Puli nlohmann::json& logEntryJson) 216e9a14131SAppaRao Puli { 217e9a14131SAppaRao Puli // Get the Message from the MessageRegistry 218e9a14131SAppaRao Puli const message_registries::Message* message = 219e9a14131SAppaRao Puli message_registries::formatMessage(messageID); 220e9a14131SAppaRao Puli 221e9a14131SAppaRao Puli std::string msg; 222e9a14131SAppaRao Puli std::string severity; 223e9a14131SAppaRao Puli if (message != nullptr) 224e9a14131SAppaRao Puli { 225e9a14131SAppaRao Puli msg = message->message; 226e9a14131SAppaRao Puli severity = message->severity; 227e9a14131SAppaRao Puli } 228e9a14131SAppaRao Puli 229e9a14131SAppaRao Puli // Fill the MessageArgs into the Message 230e9a14131SAppaRao Puli int i = 0; 231e9a14131SAppaRao Puli for (const std::string& messageArg : messageArgs) 232e9a14131SAppaRao Puli { 233e9a14131SAppaRao Puli std::string argStr = "%" + std::to_string(++i); 234e9a14131SAppaRao Puli size_t argPos = msg.find(argStr); 235e9a14131SAppaRao Puli if (argPos != std::string::npos) 236e9a14131SAppaRao Puli { 237e9a14131SAppaRao Puli msg.replace(argPos, argStr.length(), messageArg); 238e9a14131SAppaRao Puli } 239e9a14131SAppaRao Puli } 240e9a14131SAppaRao Puli 241e9a14131SAppaRao Puli // Get the Created time from the timestamp. The log timestamp is in 242e9a14131SAppaRao Puli // RFC3339 format which matches the Redfish format except for the 243e9a14131SAppaRao Puli // fractional seconds between the '.' and the '+', so just remove them. 244e9a14131SAppaRao Puli std::size_t dot = timestamp.find_first_of("."); 245e9a14131SAppaRao Puli std::size_t plus = timestamp.find_first_of("+"); 246e9a14131SAppaRao Puli if (dot != std::string::npos && plus != std::string::npos) 247e9a14131SAppaRao Puli { 248e9a14131SAppaRao Puli timestamp.erase(dot, plus - dot); 249e9a14131SAppaRao Puli } 250e9a14131SAppaRao Puli 251e9a14131SAppaRao Puli // Fill in the log entry with the gathered data 252e9a14131SAppaRao Puli logEntryJson = {{"EventId", logEntryID}, 253e9a14131SAppaRao Puli {"EventType", "Event"}, 254e9a14131SAppaRao Puli {"Severity", std::move(severity)}, 255e9a14131SAppaRao Puli {"Message", std::move(msg)}, 256e9a14131SAppaRao Puli {"MessageId", std::move(messageID)}, 257e9a14131SAppaRao Puli {"MessageArgs", std::move(messageArgs)}, 258e9a14131SAppaRao Puli {"EventTimestamp", std::move(timestamp)}, 259e9a14131SAppaRao Puli {"Context", customText}}; 260e9a14131SAppaRao Puli return 0; 261e9a14131SAppaRao Puli } 262e9a14131SAppaRao Puli 263e9a14131SAppaRao Puli } // namespace event_log 264ab41ea10SAppaRao Puli #endif 265e9a14131SAppaRao Puli 266b52664e2SAppaRao Puli class Subscription 267b52664e2SAppaRao Puli { 268b52664e2SAppaRao Puli public: 269b52664e2SAppaRao Puli std::string id; 270b52664e2SAppaRao Puli std::string destinationUrl; 271b52664e2SAppaRao Puli std::string protocol; 272b52664e2SAppaRao Puli std::string retryPolicy; 273b52664e2SAppaRao Puli std::string customText; 274b52664e2SAppaRao Puli std::string eventFormatType; 275b52664e2SAppaRao Puli std::string subscriptionType; 276b52664e2SAppaRao Puli std::vector<std::string> registryMsgIds; 277b52664e2SAppaRao Puli std::vector<std::string> registryPrefixes; 278b52664e2SAppaRao Puli std::vector<nlohmann::json> httpHeaders; // key-value pair 279156d6b00SAppaRao Puli std::vector<nlohmann::json> metricReportDefinitions; 280b52664e2SAppaRao Puli 281b52664e2SAppaRao Puli Subscription(const Subscription&) = delete; 282b52664e2SAppaRao Puli Subscription& operator=(const Subscription&) = delete; 283b52664e2SAppaRao Puli Subscription(Subscription&&) = delete; 284b52664e2SAppaRao Puli Subscription& operator=(Subscription&&) = delete; 285b52664e2SAppaRao Puli 286b52664e2SAppaRao Puli Subscription(const std::string& inHost, const std::string& inPort, 287b52664e2SAppaRao Puli const std::string& inPath, const std::string& inUriProto) : 2880b4bdd93SAppaRao Puli eventSeqNum(1), 2890b4bdd93SAppaRao Puli host(inHost), port(inPort), path(inPath), uriProto(inUriProto) 290b52664e2SAppaRao Puli { 291b52664e2SAppaRao Puli conn = std::make_shared<crow::HttpClient>( 2922a5689a7SAppaRao Puli crow::connections::systemBus->get_io_context(), host, port, path); 293b52664e2SAppaRao Puli } 294b52664e2SAppaRao Puli ~Subscription() 295b52664e2SAppaRao Puli { 296b52664e2SAppaRao Puli } 297b52664e2SAppaRao Puli 298b52664e2SAppaRao Puli void sendEvent(const std::string& msg) 299b52664e2SAppaRao Puli { 300b52664e2SAppaRao Puli std::vector<std::pair<std::string, std::string>> reqHeaders; 301b52664e2SAppaRao Puli for (const auto& header : httpHeaders) 302b52664e2SAppaRao Puli { 303b52664e2SAppaRao Puli for (const auto& item : header.items()) 304b52664e2SAppaRao Puli { 305b52664e2SAppaRao Puli std::string key = item.key(); 306b52664e2SAppaRao Puli std::string val = item.value(); 307b52664e2SAppaRao Puli reqHeaders.emplace_back(std::pair(key, val)); 308b52664e2SAppaRao Puli } 309b52664e2SAppaRao Puli } 310b52664e2SAppaRao Puli conn->setHeaders(reqHeaders); 3112a5689a7SAppaRao Puli conn->sendData(msg); 312b52664e2SAppaRao Puli } 313b52664e2SAppaRao Puli 3140b4bdd93SAppaRao Puli void sendTestEventLog() 3150b4bdd93SAppaRao Puli { 3160b4bdd93SAppaRao Puli nlohmann::json logEntryArray; 3170b4bdd93SAppaRao Puli logEntryArray.push_back({}); 3180b4bdd93SAppaRao Puli nlohmann::json& logEntryJson = logEntryArray.back(); 3190b4bdd93SAppaRao Puli 3200b4bdd93SAppaRao Puli logEntryJson = {{"EventId", "TestID"}, 3210b4bdd93SAppaRao Puli {"EventType", "Event"}, 3220b4bdd93SAppaRao Puli {"Severity", "OK"}, 3230b4bdd93SAppaRao Puli {"Message", "Generated test event"}, 3240b4bdd93SAppaRao Puli {"MessageId", "OpenBMC.0.1.TestEventLog"}, 3250b4bdd93SAppaRao Puli {"MessageArgs", nlohmann::json::array()}, 3260b4bdd93SAppaRao Puli {"EventTimestamp", crow::utility::dateTimeNow()}, 3270b4bdd93SAppaRao Puli {"Context", customText}}; 3280b4bdd93SAppaRao Puli 3290b4bdd93SAppaRao Puli nlohmann::json msg = {{"@odata.type", "#Event.v1_4_0.Event"}, 3300b4bdd93SAppaRao Puli {"Id", std::to_string(eventSeqNum)}, 3310b4bdd93SAppaRao Puli {"Name", "Event Log"}, 3320b4bdd93SAppaRao Puli {"Events", logEntryArray}}; 3330b4bdd93SAppaRao Puli 3340b4bdd93SAppaRao Puli this->sendEvent(msg.dump()); 3350b4bdd93SAppaRao Puli this->eventSeqNum++; 3360b4bdd93SAppaRao Puli } 3370b4bdd93SAppaRao Puli 338e9a14131SAppaRao Puli #ifndef BMCWEB_ENABLE_REDFISH_DBUS_LOG_ENTRIES 339e9a14131SAppaRao Puli void filterAndSendEventLogs( 340e9a14131SAppaRao Puli const std::vector<EventLogObjectsType>& eventRecords) 341e9a14131SAppaRao Puli { 342e9a14131SAppaRao Puli nlohmann::json logEntryArray; 343e9a14131SAppaRao Puli for (const EventLogObjectsType& logEntry : eventRecords) 344e9a14131SAppaRao Puli { 345e9a14131SAppaRao Puli const std::string& idStr = std::get<0>(logEntry); 346e9a14131SAppaRao Puli const std::string& timestamp = std::get<1>(logEntry); 347e9a14131SAppaRao Puli const std::string& messageID = std::get<2>(logEntry); 348e9a14131SAppaRao Puli const std::string& registryName = std::get<3>(logEntry); 349e9a14131SAppaRao Puli const std::string& messageKey = std::get<4>(logEntry); 350e9a14131SAppaRao Puli const boost::beast::span<std::string>& messageArgs = 351e9a14131SAppaRao Puli std::get<5>(logEntry); 352e9a14131SAppaRao Puli 353e9a14131SAppaRao Puli // If registryPrefixes list is empty, don't filter events 354e9a14131SAppaRao Puli // send everything. 355e9a14131SAppaRao Puli if (registryPrefixes.size()) 356e9a14131SAppaRao Puli { 357e9a14131SAppaRao Puli auto obj = std::find(registryPrefixes.begin(), 358e9a14131SAppaRao Puli registryPrefixes.end(), registryName); 359e9a14131SAppaRao Puli if (obj == registryPrefixes.end()) 360e9a14131SAppaRao Puli { 361e9a14131SAppaRao Puli continue; 362e9a14131SAppaRao Puli } 363e9a14131SAppaRao Puli } 364e9a14131SAppaRao Puli 365e9a14131SAppaRao Puli // If registryMsgIds list is empty, don't filter events 366e9a14131SAppaRao Puli // send everything. 367e9a14131SAppaRao Puli if (registryMsgIds.size()) 368e9a14131SAppaRao Puli { 369e9a14131SAppaRao Puli auto obj = std::find(registryMsgIds.begin(), 370e9a14131SAppaRao Puli registryMsgIds.end(), messageKey); 371e9a14131SAppaRao Puli if (obj == registryMsgIds.end()) 372e9a14131SAppaRao Puli { 373e9a14131SAppaRao Puli continue; 374e9a14131SAppaRao Puli } 375e9a14131SAppaRao Puli } 376e9a14131SAppaRao Puli 377e9a14131SAppaRao Puli logEntryArray.push_back({}); 378e9a14131SAppaRao Puli nlohmann::json& bmcLogEntry = logEntryArray.back(); 379e9a14131SAppaRao Puli if (event_log::formatEventLogEntry(idStr, messageID, messageArgs, 380e9a14131SAppaRao Puli timestamp, customText, 381e9a14131SAppaRao Puli bmcLogEntry) != 0) 382e9a14131SAppaRao Puli { 383e9a14131SAppaRao Puli BMCWEB_LOG_DEBUG << "Read eventLog entry failed"; 384e9a14131SAppaRao Puli continue; 385e9a14131SAppaRao Puli } 386e9a14131SAppaRao Puli } 387e9a14131SAppaRao Puli 388e9a14131SAppaRao Puli if (logEntryArray.size() < 1) 389e9a14131SAppaRao Puli { 390e9a14131SAppaRao Puli BMCWEB_LOG_DEBUG << "No log entries available to be transferred."; 391e9a14131SAppaRao Puli return; 392e9a14131SAppaRao Puli } 393e9a14131SAppaRao Puli 394e9a14131SAppaRao Puli nlohmann::json msg = {{"@odata.type", "#Event.v1_4_0.Event"}, 395e9a14131SAppaRao Puli {"Id", std::to_string(eventSeqNum)}, 396e9a14131SAppaRao Puli {"Name", "Event Log"}, 397e9a14131SAppaRao Puli {"Events", logEntryArray}}; 398e9a14131SAppaRao Puli 399e9a14131SAppaRao Puli this->sendEvent(msg.dump()); 400e9a14131SAppaRao Puli this->eventSeqNum++; 401e9a14131SAppaRao Puli } 402e9a14131SAppaRao Puli #endif 403e9a14131SAppaRao Puli 404156d6b00SAppaRao Puli void filterAndSendReports(const std::string& id, 405156d6b00SAppaRao Puli const std::string& readingsTs, 406156d6b00SAppaRao Puli const ReadingsObjType& readings) 407156d6b00SAppaRao Puli { 408156d6b00SAppaRao Puli std::string metricReportDef = 409156d6b00SAppaRao Puli "/redfish/v1/TelemetryService/MetricReportDefinitions/" + id; 410156d6b00SAppaRao Puli 411156d6b00SAppaRao Puli // Empty list means no filter. Send everything. 412156d6b00SAppaRao Puli if (metricReportDefinitions.size()) 413156d6b00SAppaRao Puli { 414156d6b00SAppaRao Puli if (std::find(metricReportDefinitions.begin(), 415156d6b00SAppaRao Puli metricReportDefinitions.end(), 416156d6b00SAppaRao Puli metricReportDef) == metricReportDefinitions.end()) 417156d6b00SAppaRao Puli { 418156d6b00SAppaRao Puli return; 419156d6b00SAppaRao Puli } 420156d6b00SAppaRao Puli } 421156d6b00SAppaRao Puli 422156d6b00SAppaRao Puli nlohmann::json metricValuesArray = nlohmann::json::array(); 423156d6b00SAppaRao Puli for (const auto& it : readings) 424156d6b00SAppaRao Puli { 425156d6b00SAppaRao Puli metricValuesArray.push_back({}); 426156d6b00SAppaRao Puli nlohmann::json& entry = metricValuesArray.back(); 427156d6b00SAppaRao Puli 428156d6b00SAppaRao Puli entry = {{"MetricId", std::get<0>(it)}, 429156d6b00SAppaRao Puli {"MetricProperty", std::get<1>(it)}, 430156d6b00SAppaRao Puli {"MetricValue", std::to_string(std::get<2>(it))}, 431156d6b00SAppaRao Puli {"Timestamp", std::get<3>(it)}}; 432156d6b00SAppaRao Puli } 433156d6b00SAppaRao Puli 434156d6b00SAppaRao Puli nlohmann::json msg = { 435156d6b00SAppaRao Puli {"@odata.id", "/redfish/v1/TelemetryService/MetricReports/" + id}, 436156d6b00SAppaRao Puli {"@odata.type", "#MetricReport.v1_3_0.MetricReport"}, 437156d6b00SAppaRao Puli {"Id", id}, 438156d6b00SAppaRao Puli {"Name", id}, 439156d6b00SAppaRao Puli {"Timestamp", readingsTs}, 440156d6b00SAppaRao Puli {"MetricReportDefinition", {{"@odata.id", metricReportDef}}}, 441156d6b00SAppaRao Puli {"MetricValues", metricValuesArray}}; 442156d6b00SAppaRao Puli 443156d6b00SAppaRao Puli this->sendEvent(msg.dump()); 444156d6b00SAppaRao Puli } 445156d6b00SAppaRao Puli 446b52664e2SAppaRao Puli private: 4470b4bdd93SAppaRao Puli uint64_t eventSeqNum; 448b52664e2SAppaRao Puli std::string host; 449b52664e2SAppaRao Puli std::string port; 450b52664e2SAppaRao Puli std::string path; 451b52664e2SAppaRao Puli std::string uriProto; 452b52664e2SAppaRao Puli std::shared_ptr<crow::HttpClient> conn; 453b52664e2SAppaRao Puli }; 454b52664e2SAppaRao Puli 4551bf712bcSAyushi Smriti static constexpr const bool defaultEnabledState = true; 4561bf712bcSAyushi Smriti static constexpr const uint32_t defaultRetryAttempts = 3; 4571bf712bcSAyushi Smriti static constexpr const uint32_t defaultRetryInterval = 30; 4581bf712bcSAyushi Smriti static constexpr const char* defaulEventFormatType = "Event"; 4591bf712bcSAyushi Smriti static constexpr const char* defaulSubscriptionType = "RedfishEvent"; 4601bf712bcSAyushi Smriti static constexpr const char* defaulRetryPolicy = "TerminateAfterRetries"; 4611bf712bcSAyushi Smriti 462b52664e2SAppaRao Puli class EventServiceManager 463b52664e2SAppaRao Puli { 464b52664e2SAppaRao Puli private: 4657d1cc387SAppaRao Puli bool serviceEnabled; 4667d1cc387SAppaRao Puli uint32_t retryAttempts; 4677d1cc387SAppaRao Puli uint32_t retryTimeoutInterval; 4687d1cc387SAppaRao Puli 469b52664e2SAppaRao Puli EventServiceManager(const EventServiceManager&) = delete; 470b52664e2SAppaRao Puli EventServiceManager& operator=(const EventServiceManager&) = delete; 471b52664e2SAppaRao Puli EventServiceManager(EventServiceManager&&) = delete; 472b52664e2SAppaRao Puli EventServiceManager& operator=(EventServiceManager&&) = delete; 473b52664e2SAppaRao Puli 4747d1cc387SAppaRao Puli EventServiceManager() : 4757d1cc387SAppaRao Puli noOfEventLogSubscribers(0), noOfMetricReportSubscribers(0) 476b52664e2SAppaRao Puli { 4771bf712bcSAyushi Smriti // Load config from persist store. 4781bf712bcSAyushi Smriti initConfig(); 479b52664e2SAppaRao Puli } 480b52664e2SAppaRao Puli 481e9a14131SAppaRao Puli std::string lastEventTStr; 4827d1cc387SAppaRao Puli size_t noOfEventLogSubscribers; 483156d6b00SAppaRao Puli size_t noOfMetricReportSubscribers; 484156d6b00SAppaRao Puli std::shared_ptr<sdbusplus::bus::match::match> matchTelemetryMonitor; 485b52664e2SAppaRao Puli boost::container::flat_map<std::string, std::shared_ptr<Subscription>> 486b52664e2SAppaRao Puli subscriptionsMap; 487b52664e2SAppaRao Puli 488b52664e2SAppaRao Puli public: 489b52664e2SAppaRao Puli static EventServiceManager& getInstance() 490b52664e2SAppaRao Puli { 491b52664e2SAppaRao Puli static EventServiceManager handler; 492b52664e2SAppaRao Puli return handler; 493b52664e2SAppaRao Puli } 494b52664e2SAppaRao Puli 4951bf712bcSAyushi Smriti void loadDefaultConfig() 4961bf712bcSAyushi Smriti { 4971bf712bcSAyushi Smriti serviceEnabled = defaultEnabledState; 4981bf712bcSAyushi Smriti retryAttempts = defaultRetryAttempts; 4991bf712bcSAyushi Smriti retryTimeoutInterval = defaultRetryInterval; 5001bf712bcSAyushi Smriti } 5011bf712bcSAyushi Smriti 5021bf712bcSAyushi Smriti void initConfig() 5031bf712bcSAyushi Smriti { 5041bf712bcSAyushi Smriti std::ifstream eventConfigFile(eventServiceFile); 5051bf712bcSAyushi Smriti if (!eventConfigFile.good()) 5061bf712bcSAyushi Smriti { 5071bf712bcSAyushi Smriti BMCWEB_LOG_DEBUG << "EventService config not exist"; 5081bf712bcSAyushi Smriti loadDefaultConfig(); 5091bf712bcSAyushi Smriti return; 5101bf712bcSAyushi Smriti } 5111bf712bcSAyushi Smriti auto jsonData = nlohmann::json::parse(eventConfigFile, nullptr, false); 5121bf712bcSAyushi Smriti if (jsonData.is_discarded()) 5131bf712bcSAyushi Smriti { 5141bf712bcSAyushi Smriti BMCWEB_LOG_ERROR << "EventService config parse error."; 5151bf712bcSAyushi Smriti loadDefaultConfig(); 5161bf712bcSAyushi Smriti return; 5171bf712bcSAyushi Smriti } 5181bf712bcSAyushi Smriti 5191bf712bcSAyushi Smriti nlohmann::json jsonConfig; 5201bf712bcSAyushi Smriti if (json_util::getValueFromJsonObject(jsonData, "Configuration", 5211bf712bcSAyushi Smriti jsonConfig)) 5221bf712bcSAyushi Smriti { 5231bf712bcSAyushi Smriti if (!json_util::getValueFromJsonObject(jsonConfig, "ServiceEnabled", 5241bf712bcSAyushi Smriti serviceEnabled)) 5251bf712bcSAyushi Smriti { 5261bf712bcSAyushi Smriti serviceEnabled = defaultEnabledState; 5271bf712bcSAyushi Smriti } 5281bf712bcSAyushi Smriti if (!json_util::getValueFromJsonObject( 5291bf712bcSAyushi Smriti jsonConfig, "DeliveryRetryAttempts", retryAttempts)) 5301bf712bcSAyushi Smriti { 5311bf712bcSAyushi Smriti retryAttempts = defaultRetryAttempts; 5321bf712bcSAyushi Smriti } 5331bf712bcSAyushi Smriti if (!json_util::getValueFromJsonObject( 5341bf712bcSAyushi Smriti jsonConfig, "DeliveryRetryIntervalSeconds", 5351bf712bcSAyushi Smriti retryTimeoutInterval)) 5361bf712bcSAyushi Smriti { 5371bf712bcSAyushi Smriti retryTimeoutInterval = defaultRetryInterval; 5381bf712bcSAyushi Smriti } 5391bf712bcSAyushi Smriti } 5401bf712bcSAyushi Smriti else 5411bf712bcSAyushi Smriti { 5421bf712bcSAyushi Smriti loadDefaultConfig(); 5431bf712bcSAyushi Smriti } 5441bf712bcSAyushi Smriti 5451bf712bcSAyushi Smriti nlohmann::json subscriptionsList; 5461bf712bcSAyushi Smriti if (!json_util::getValueFromJsonObject(jsonData, "Subscriptions", 5471bf712bcSAyushi Smriti subscriptionsList)) 5481bf712bcSAyushi Smriti { 5491bf712bcSAyushi Smriti BMCWEB_LOG_DEBUG << "EventService: Subscriptions not exist."; 5501bf712bcSAyushi Smriti return; 5511bf712bcSAyushi Smriti } 5521bf712bcSAyushi Smriti 5531bf712bcSAyushi Smriti for (nlohmann::json& jsonObj : subscriptionsList) 5541bf712bcSAyushi Smriti { 5551bf712bcSAyushi Smriti std::string protocol; 5561bf712bcSAyushi Smriti if (!json_util::getValueFromJsonObject(jsonObj, "Protocol", 5571bf712bcSAyushi Smriti protocol)) 5581bf712bcSAyushi Smriti { 5591bf712bcSAyushi Smriti BMCWEB_LOG_DEBUG << "Invalid subscription Protocol exist."; 5601bf712bcSAyushi Smriti continue; 5611bf712bcSAyushi Smriti } 5621bf712bcSAyushi Smriti std::string destination; 5631bf712bcSAyushi Smriti if (!json_util::getValueFromJsonObject(jsonObj, "Destination", 5641bf712bcSAyushi Smriti destination)) 5651bf712bcSAyushi Smriti { 5661bf712bcSAyushi Smriti BMCWEB_LOG_DEBUG << "Invalid subscription destination exist."; 5671bf712bcSAyushi Smriti continue; 5681bf712bcSAyushi Smriti } 5691bf712bcSAyushi Smriti std::string host; 5701bf712bcSAyushi Smriti std::string urlProto; 5711bf712bcSAyushi Smriti std::string port; 5721bf712bcSAyushi Smriti std::string path; 5731bf712bcSAyushi Smriti bool status = 5741bf712bcSAyushi Smriti validateAndSplitUrl(destination, urlProto, host, port, path); 5751bf712bcSAyushi Smriti 5761bf712bcSAyushi Smriti if (!status) 5771bf712bcSAyushi Smriti { 5781bf712bcSAyushi Smriti BMCWEB_LOG_ERROR 5791bf712bcSAyushi Smriti << "Failed to validate and split destination url"; 5801bf712bcSAyushi Smriti continue; 5811bf712bcSAyushi Smriti } 5821bf712bcSAyushi Smriti std::shared_ptr<Subscription> subValue = 5831bf712bcSAyushi Smriti std::make_shared<Subscription>(host, port, path, urlProto); 5841bf712bcSAyushi Smriti 5851bf712bcSAyushi Smriti subValue->destinationUrl = destination; 5861bf712bcSAyushi Smriti subValue->protocol = protocol; 5871bf712bcSAyushi Smriti if (!json_util::getValueFromJsonObject( 5881bf712bcSAyushi Smriti jsonObj, "DeliveryRetryPolicy", subValue->retryPolicy)) 5891bf712bcSAyushi Smriti { 5901bf712bcSAyushi Smriti subValue->retryPolicy = defaulRetryPolicy; 5911bf712bcSAyushi Smriti } 5921bf712bcSAyushi Smriti if (!json_util::getValueFromJsonObject(jsonObj, "EventFormatType", 5931bf712bcSAyushi Smriti subValue->eventFormatType)) 5941bf712bcSAyushi Smriti { 5951bf712bcSAyushi Smriti subValue->eventFormatType = defaulEventFormatType; 5961bf712bcSAyushi Smriti } 5971bf712bcSAyushi Smriti if (!json_util::getValueFromJsonObject(jsonObj, "SubscriptionType", 5981bf712bcSAyushi Smriti subValue->subscriptionType)) 5991bf712bcSAyushi Smriti { 6001bf712bcSAyushi Smriti subValue->subscriptionType = defaulSubscriptionType; 6011bf712bcSAyushi Smriti } 6021bf712bcSAyushi Smriti 6031bf712bcSAyushi Smriti json_util::getValueFromJsonObject(jsonObj, "Context", 6041bf712bcSAyushi Smriti subValue->customText); 6051bf712bcSAyushi Smriti json_util::getValueFromJsonObject(jsonObj, "MessageIds", 6061bf712bcSAyushi Smriti subValue->registryMsgIds); 6071bf712bcSAyushi Smriti json_util::getValueFromJsonObject(jsonObj, "RegistryPrefixes", 6081bf712bcSAyushi Smriti subValue->registryPrefixes); 6091bf712bcSAyushi Smriti json_util::getValueFromJsonObject(jsonObj, "HttpHeaders", 6101bf712bcSAyushi Smriti subValue->httpHeaders); 6111bf712bcSAyushi Smriti json_util::getValueFromJsonObject( 6121bf712bcSAyushi Smriti jsonObj, "MetricReportDefinitions", 6131bf712bcSAyushi Smriti subValue->metricReportDefinitions); 6141bf712bcSAyushi Smriti 6151bf712bcSAyushi Smriti std::string id = addSubscription(subValue, false); 6161bf712bcSAyushi Smriti if (id.empty()) 6171bf712bcSAyushi Smriti { 6181bf712bcSAyushi Smriti BMCWEB_LOG_ERROR << "Failed to add subscription"; 6191bf712bcSAyushi Smriti } 6201bf712bcSAyushi Smriti } 6211bf712bcSAyushi Smriti return; 6221bf712bcSAyushi Smriti } 6231bf712bcSAyushi Smriti 624b52664e2SAppaRao Puli void updateSubscriptionData() 625b52664e2SAppaRao Puli { 626b52664e2SAppaRao Puli // Persist the config and subscription data. 6271bf712bcSAyushi Smriti nlohmann::json jsonData; 6281bf712bcSAyushi Smriti 6291bf712bcSAyushi Smriti nlohmann::json& configObj = jsonData["Configuration"]; 6301bf712bcSAyushi Smriti configObj["ServiceEnabled"] = serviceEnabled; 6311bf712bcSAyushi Smriti configObj["DeliveryRetryAttempts"] = retryAttempts; 6321bf712bcSAyushi Smriti configObj["DeliveryRetryIntervalSeconds"] = retryTimeoutInterval; 6331bf712bcSAyushi Smriti 6341bf712bcSAyushi Smriti nlohmann::json& subListArray = jsonData["Subscriptions"]; 6351bf712bcSAyushi Smriti subListArray = nlohmann::json::array(); 6361bf712bcSAyushi Smriti 6371bf712bcSAyushi Smriti for (const auto& it : subscriptionsMap) 6381bf712bcSAyushi Smriti { 6391bf712bcSAyushi Smriti nlohmann::json entry; 6401bf712bcSAyushi Smriti std::shared_ptr<Subscription> subValue = it.second; 6411bf712bcSAyushi Smriti 6421bf712bcSAyushi Smriti entry["Context"] = subValue->customText; 6431bf712bcSAyushi Smriti entry["DeliveryRetryPolicy"] = subValue->retryPolicy; 6441bf712bcSAyushi Smriti entry["Destination"] = subValue->destinationUrl; 6451bf712bcSAyushi Smriti entry["EventFormatType"] = subValue->eventFormatType; 6461bf712bcSAyushi Smriti entry["HttpHeaders"] = subValue->httpHeaders; 6471bf712bcSAyushi Smriti entry["MessageIds"] = subValue->registryMsgIds; 6481bf712bcSAyushi Smriti entry["Protocol"] = subValue->protocol; 6491bf712bcSAyushi Smriti entry["RegistryPrefixes"] = subValue->registryPrefixes; 6501bf712bcSAyushi Smriti entry["SubscriptionType"] = subValue->subscriptionType; 6511bf712bcSAyushi Smriti entry["MetricReportDefinitions"] = 6521bf712bcSAyushi Smriti subValue->metricReportDefinitions; 6531bf712bcSAyushi Smriti 6541bf712bcSAyushi Smriti subListArray.push_back(entry); 6551bf712bcSAyushi Smriti } 6561bf712bcSAyushi Smriti 6571bf712bcSAyushi Smriti const std::string tmpFile(std::string(eventServiceFile) + "_tmp"); 6581bf712bcSAyushi Smriti std::ofstream ofs(tmpFile, std::ios::out); 6591bf712bcSAyushi Smriti const auto& writeData = jsonData.dump(); 6601bf712bcSAyushi Smriti ofs << writeData; 6611bf712bcSAyushi Smriti ofs.close(); 6621bf712bcSAyushi Smriti 6631bf712bcSAyushi Smriti BMCWEB_LOG_DEBUG << "EventService config updated to file."; 6641bf712bcSAyushi Smriti if (std::rename(tmpFile.c_str(), eventServiceFile) != 0) 6651bf712bcSAyushi Smriti { 6661bf712bcSAyushi Smriti BMCWEB_LOG_ERROR << "Error in renaming temporary file: " 6671bf712bcSAyushi Smriti << tmpFile.c_str(); 6681bf712bcSAyushi Smriti } 669b52664e2SAppaRao Puli } 670b52664e2SAppaRao Puli 6717d1cc387SAppaRao Puli EventServiceConfig getEventServiceConfig() 6727d1cc387SAppaRao Puli { 6737d1cc387SAppaRao Puli return {serviceEnabled, retryAttempts, retryTimeoutInterval}; 6747d1cc387SAppaRao Puli } 6757d1cc387SAppaRao Puli 6767d1cc387SAppaRao Puli void setEventServiceConfig(const EventServiceConfig& cfg) 6777d1cc387SAppaRao Puli { 6787d1cc387SAppaRao Puli bool updateConfig = false; 6797d1cc387SAppaRao Puli 6807d1cc387SAppaRao Puli if (serviceEnabled != std::get<0>(cfg)) 6817d1cc387SAppaRao Puli { 6827d1cc387SAppaRao Puli serviceEnabled = std::get<0>(cfg); 6837d1cc387SAppaRao Puli if (serviceEnabled && noOfMetricReportSubscribers) 6847d1cc387SAppaRao Puli { 6857d1cc387SAppaRao Puli registerMetricReportSignal(); 6867d1cc387SAppaRao Puli } 6877d1cc387SAppaRao Puli else 6887d1cc387SAppaRao Puli { 6897d1cc387SAppaRao Puli unregisterMetricReportSignal(); 6907d1cc387SAppaRao Puli } 6917d1cc387SAppaRao Puli updateConfig = true; 6927d1cc387SAppaRao Puli } 6937d1cc387SAppaRao Puli 6947d1cc387SAppaRao Puli if (retryAttempts != std::get<1>(cfg)) 6957d1cc387SAppaRao Puli { 6967d1cc387SAppaRao Puli retryAttempts = std::get<1>(cfg); 6977d1cc387SAppaRao Puli updateConfig = true; 6987d1cc387SAppaRao Puli } 6997d1cc387SAppaRao Puli 7007d1cc387SAppaRao Puli if (retryTimeoutInterval != std::get<2>(cfg)) 7017d1cc387SAppaRao Puli { 7027d1cc387SAppaRao Puli retryTimeoutInterval = std::get<2>(cfg); 7037d1cc387SAppaRao Puli updateConfig = true; 7047d1cc387SAppaRao Puli } 7057d1cc387SAppaRao Puli 7067d1cc387SAppaRao Puli if (updateConfig) 7077d1cc387SAppaRao Puli { 7087d1cc387SAppaRao Puli updateSubscriptionData(); 7097d1cc387SAppaRao Puli } 7107d1cc387SAppaRao Puli } 7117d1cc387SAppaRao Puli 7127d1cc387SAppaRao Puli void updateNoOfSubscribersCount() 7137d1cc387SAppaRao Puli { 7147d1cc387SAppaRao Puli size_t eventLogSubCount = 0; 7157d1cc387SAppaRao Puli size_t metricReportSubCount = 0; 7167d1cc387SAppaRao Puli for (const auto& it : subscriptionsMap) 7177d1cc387SAppaRao Puli { 7187d1cc387SAppaRao Puli std::shared_ptr<Subscription> entry = it.second; 7197d1cc387SAppaRao Puli if (entry->eventFormatType == eventFormatType) 7207d1cc387SAppaRao Puli { 7217d1cc387SAppaRao Puli eventLogSubCount++; 7227d1cc387SAppaRao Puli } 7237d1cc387SAppaRao Puli else if (entry->eventFormatType == metricReportFormatType) 7247d1cc387SAppaRao Puli { 7257d1cc387SAppaRao Puli metricReportSubCount++; 7267d1cc387SAppaRao Puli } 7277d1cc387SAppaRao Puli } 7287d1cc387SAppaRao Puli 7297d1cc387SAppaRao Puli noOfEventLogSubscribers = eventLogSubCount; 7307d1cc387SAppaRao Puli if (noOfMetricReportSubscribers != metricReportSubCount) 7317d1cc387SAppaRao Puli { 7327d1cc387SAppaRao Puli noOfMetricReportSubscribers = metricReportSubCount; 7337d1cc387SAppaRao Puli if (noOfMetricReportSubscribers) 7347d1cc387SAppaRao Puli { 7357d1cc387SAppaRao Puli registerMetricReportSignal(); 7367d1cc387SAppaRao Puli } 7377d1cc387SAppaRao Puli else 7387d1cc387SAppaRao Puli { 7397d1cc387SAppaRao Puli unregisterMetricReportSignal(); 7407d1cc387SAppaRao Puli } 7417d1cc387SAppaRao Puli } 7427d1cc387SAppaRao Puli } 7437d1cc387SAppaRao Puli 744b52664e2SAppaRao Puli std::shared_ptr<Subscription> getSubscription(const std::string& id) 745b52664e2SAppaRao Puli { 746b52664e2SAppaRao Puli auto obj = subscriptionsMap.find(id); 747b52664e2SAppaRao Puli if (obj == subscriptionsMap.end()) 748b52664e2SAppaRao Puli { 749b52664e2SAppaRao Puli BMCWEB_LOG_ERROR << "No subscription exist with ID:" << id; 750b52664e2SAppaRao Puli return nullptr; 751b52664e2SAppaRao Puli } 752b52664e2SAppaRao Puli std::shared_ptr<Subscription> subValue = obj->second; 753b52664e2SAppaRao Puli return subValue; 754b52664e2SAppaRao Puli } 755b52664e2SAppaRao Puli 7561bf712bcSAyushi Smriti std::string addSubscription(const std::shared_ptr<Subscription> subValue, 7571bf712bcSAyushi Smriti const bool updateFile = true) 758b52664e2SAppaRao Puli { 759b52664e2SAppaRao Puli std::srand(static_cast<uint32_t>(std::time(0))); 760b52664e2SAppaRao Puli std::string id; 761b52664e2SAppaRao Puli 762b52664e2SAppaRao Puli int retry = 3; 763b52664e2SAppaRao Puli while (retry) 764b52664e2SAppaRao Puli { 765b52664e2SAppaRao Puli id = std::to_string(std::rand()); 766b52664e2SAppaRao Puli auto inserted = subscriptionsMap.insert(std::pair(id, subValue)); 767b52664e2SAppaRao Puli if (inserted.second) 768b52664e2SAppaRao Puli { 769b52664e2SAppaRao Puli break; 770b52664e2SAppaRao Puli } 771b52664e2SAppaRao Puli --retry; 772b52664e2SAppaRao Puli }; 773b52664e2SAppaRao Puli 774b52664e2SAppaRao Puli if (retry <= 0) 775b52664e2SAppaRao Puli { 776b52664e2SAppaRao Puli BMCWEB_LOG_ERROR << "Failed to generate random number"; 777b52664e2SAppaRao Puli return std::string(""); 778b52664e2SAppaRao Puli } 779b52664e2SAppaRao Puli 7807d1cc387SAppaRao Puli updateNoOfSubscribersCount(); 7811bf712bcSAyushi Smriti 7821bf712bcSAyushi Smriti if (updateFile) 7831bf712bcSAyushi Smriti { 784b52664e2SAppaRao Puli updateSubscriptionData(); 7851bf712bcSAyushi Smriti } 786e9a14131SAppaRao Puli 787e9a14131SAppaRao Puli #ifndef BMCWEB_ENABLE_REDFISH_DBUS_LOG_ENTRIES 788e9a14131SAppaRao Puli if (lastEventTStr.empty()) 789e9a14131SAppaRao Puli { 790e9a14131SAppaRao Puli cacheLastEventTimestamp(); 791e9a14131SAppaRao Puli } 792e9a14131SAppaRao Puli #endif 793b52664e2SAppaRao Puli return id; 794b52664e2SAppaRao Puli } 795b52664e2SAppaRao Puli 796b52664e2SAppaRao Puli bool isSubscriptionExist(const std::string& id) 797b52664e2SAppaRao Puli { 798b52664e2SAppaRao Puli auto obj = subscriptionsMap.find(id); 799b52664e2SAppaRao Puli if (obj == subscriptionsMap.end()) 800b52664e2SAppaRao Puli { 801b52664e2SAppaRao Puli return false; 802b52664e2SAppaRao Puli } 803b52664e2SAppaRao Puli return true; 804b52664e2SAppaRao Puli } 805b52664e2SAppaRao Puli 806b52664e2SAppaRao Puli void deleteSubscription(const std::string& id) 807b52664e2SAppaRao Puli { 808b52664e2SAppaRao Puli auto obj = subscriptionsMap.find(id); 809b52664e2SAppaRao Puli if (obj != subscriptionsMap.end()) 810b52664e2SAppaRao Puli { 811b52664e2SAppaRao Puli subscriptionsMap.erase(obj); 8127d1cc387SAppaRao Puli updateNoOfSubscribersCount(); 813b52664e2SAppaRao Puli updateSubscriptionData(); 814b52664e2SAppaRao Puli } 815b52664e2SAppaRao Puli } 816b52664e2SAppaRao Puli 817b52664e2SAppaRao Puli size_t getNumberOfSubscriptions() 818b52664e2SAppaRao Puli { 819b52664e2SAppaRao Puli return subscriptionsMap.size(); 820b52664e2SAppaRao Puli } 821b52664e2SAppaRao Puli 822b52664e2SAppaRao Puli std::vector<std::string> getAllIDs() 823b52664e2SAppaRao Puli { 824b52664e2SAppaRao Puli std::vector<std::string> idList; 825b52664e2SAppaRao Puli for (const auto& it : subscriptionsMap) 826b52664e2SAppaRao Puli { 827b52664e2SAppaRao Puli idList.emplace_back(it.first); 828b52664e2SAppaRao Puli } 829b52664e2SAppaRao Puli return idList; 830b52664e2SAppaRao Puli } 831b52664e2SAppaRao Puli 832b52664e2SAppaRao Puli bool isDestinationExist(const std::string& destUrl) 833b52664e2SAppaRao Puli { 834b52664e2SAppaRao Puli for (const auto& it : subscriptionsMap) 835b52664e2SAppaRao Puli { 836b52664e2SAppaRao Puli std::shared_ptr<Subscription> entry = it.second; 837b52664e2SAppaRao Puli if (entry->destinationUrl == destUrl) 838b52664e2SAppaRao Puli { 839b52664e2SAppaRao Puli BMCWEB_LOG_ERROR << "Destination exist already" << destUrl; 840b52664e2SAppaRao Puli return true; 841b52664e2SAppaRao Puli } 842b52664e2SAppaRao Puli } 843b52664e2SAppaRao Puli return false; 844b52664e2SAppaRao Puli } 8450b4bdd93SAppaRao Puli 8460b4bdd93SAppaRao Puli void sendTestEventLog() 8470b4bdd93SAppaRao Puli { 8480b4bdd93SAppaRao Puli for (const auto& it : this->subscriptionsMap) 8490b4bdd93SAppaRao Puli { 8500b4bdd93SAppaRao Puli std::shared_ptr<Subscription> entry = it.second; 8510b4bdd93SAppaRao Puli entry->sendTestEventLog(); 8520b4bdd93SAppaRao Puli } 8530b4bdd93SAppaRao Puli } 854e9a14131SAppaRao Puli 855e9a14131SAppaRao Puli #ifndef BMCWEB_ENABLE_REDFISH_DBUS_LOG_ENTRIES 856e9a14131SAppaRao Puli void cacheLastEventTimestamp() 857e9a14131SAppaRao Puli { 858e9a14131SAppaRao Puli std::ifstream logStream(redfishEventLogFile); 859e9a14131SAppaRao Puli if (!logStream.good()) 860e9a14131SAppaRao Puli { 861e9a14131SAppaRao Puli BMCWEB_LOG_ERROR << " Redfish log file open failed \n"; 862e9a14131SAppaRao Puli return; 863e9a14131SAppaRao Puli } 864e9a14131SAppaRao Puli std::string logEntry; 865e9a14131SAppaRao Puli while (std::getline(logStream, logEntry)) 866e9a14131SAppaRao Puli { 867e9a14131SAppaRao Puli size_t space = logEntry.find_first_of(" "); 868e9a14131SAppaRao Puli if (space == std::string::npos) 869e9a14131SAppaRao Puli { 870e9a14131SAppaRao Puli // Shouldn't enter here but lets skip it. 871e9a14131SAppaRao Puli BMCWEB_LOG_DEBUG << "Invalid log entry found."; 872e9a14131SAppaRao Puli continue; 873e9a14131SAppaRao Puli } 874e9a14131SAppaRao Puli lastEventTStr = logEntry.substr(0, space); 875e9a14131SAppaRao Puli } 876e9a14131SAppaRao Puli BMCWEB_LOG_DEBUG << "Last Event time stamp set: " << lastEventTStr; 877e9a14131SAppaRao Puli } 878e9a14131SAppaRao Puli 879e9a14131SAppaRao Puli void readEventLogsFromFile() 880e9a14131SAppaRao Puli { 8817d1cc387SAppaRao Puli if (!serviceEnabled || !noOfEventLogSubscribers) 882e9a14131SAppaRao Puli { 8837d1cc387SAppaRao Puli BMCWEB_LOG_DEBUG << "EventService disabled or no Subscriptions."; 884e9a14131SAppaRao Puli return; 885e9a14131SAppaRao Puli } 886e9a14131SAppaRao Puli std::ifstream logStream(redfishEventLogFile); 887e9a14131SAppaRao Puli if (!logStream.good()) 888e9a14131SAppaRao Puli { 889e9a14131SAppaRao Puli BMCWEB_LOG_ERROR << " Redfish log file open failed"; 890e9a14131SAppaRao Puli return; 891e9a14131SAppaRao Puli } 892e9a14131SAppaRao Puli 893e9a14131SAppaRao Puli std::vector<EventLogObjectsType> eventRecords; 894e9a14131SAppaRao Puli 895e9a14131SAppaRao Puli bool startLogCollection = false; 896e9a14131SAppaRao Puli bool firstEntry = true; 897e9a14131SAppaRao Puli 898e9a14131SAppaRao Puli std::string logEntry; 899e9a14131SAppaRao Puli while (std::getline(logStream, logEntry)) 900e9a14131SAppaRao Puli { 901e9a14131SAppaRao Puli if (!startLogCollection) 902e9a14131SAppaRao Puli { 903e9a14131SAppaRao Puli if (boost::starts_with(logEntry, lastEventTStr)) 904e9a14131SAppaRao Puli { 905e9a14131SAppaRao Puli startLogCollection = true; 906e9a14131SAppaRao Puli } 907e9a14131SAppaRao Puli continue; 908e9a14131SAppaRao Puli } 909e9a14131SAppaRao Puli 910e9a14131SAppaRao Puli std::string idStr; 911e9a14131SAppaRao Puli if (!event_log::getUniqueEntryID(logEntry, idStr, firstEntry)) 912e9a14131SAppaRao Puli { 913e9a14131SAppaRao Puli continue; 914e9a14131SAppaRao Puli } 915e9a14131SAppaRao Puli firstEntry = false; 916e9a14131SAppaRao Puli 917e9a14131SAppaRao Puli std::string timestamp; 918e9a14131SAppaRao Puli std::string messageID; 919e9a14131SAppaRao Puli boost::beast::span<std::string> messageArgs; 920e9a14131SAppaRao Puli if (event_log::getEventLogParams(logEntry, timestamp, messageID, 921e9a14131SAppaRao Puli messageArgs) != 0) 922e9a14131SAppaRao Puli { 923e9a14131SAppaRao Puli BMCWEB_LOG_DEBUG << "Read eventLog entry params failed"; 924e9a14131SAppaRao Puli continue; 925e9a14131SAppaRao Puli } 926e9a14131SAppaRao Puli 927e9a14131SAppaRao Puli std::string registryName; 928e9a14131SAppaRao Puli std::string messageKey; 929e9a14131SAppaRao Puli event_log::getRegistryAndMessageKey(messageID, registryName, 930e9a14131SAppaRao Puli messageKey); 931e9a14131SAppaRao Puli if (registryName.empty() || messageKey.empty()) 932e9a14131SAppaRao Puli { 933e9a14131SAppaRao Puli continue; 934e9a14131SAppaRao Puli } 935e9a14131SAppaRao Puli 936e9a14131SAppaRao Puli lastEventTStr = timestamp; 937e9a14131SAppaRao Puli eventRecords.emplace_back(idStr, timestamp, messageID, registryName, 938e9a14131SAppaRao Puli messageKey, messageArgs); 939e9a14131SAppaRao Puli } 940e9a14131SAppaRao Puli 941e9a14131SAppaRao Puli for (const auto& it : this->subscriptionsMap) 942e9a14131SAppaRao Puli { 943e9a14131SAppaRao Puli std::shared_ptr<Subscription> entry = it.second; 944e9a14131SAppaRao Puli if (entry->eventFormatType == "Event") 945e9a14131SAppaRao Puli { 946e9a14131SAppaRao Puli entry->filterAndSendEventLogs(eventRecords); 947e9a14131SAppaRao Puli } 948e9a14131SAppaRao Puli } 949e9a14131SAppaRao Puli } 950e9a14131SAppaRao Puli 951e9a14131SAppaRao Puli static void watchRedfishEventLogFile() 952e9a14131SAppaRao Puli { 953e9a14131SAppaRao Puli if (inotifyConn == nullptr) 954e9a14131SAppaRao Puli { 955e9a14131SAppaRao Puli return; 956e9a14131SAppaRao Puli } 957e9a14131SAppaRao Puli 958e9a14131SAppaRao Puli static std::array<char, 1024> readBuffer; 959e9a14131SAppaRao Puli 960e9a14131SAppaRao Puli inotifyConn->async_read_some( 961e9a14131SAppaRao Puli boost::asio::buffer(readBuffer), 962e9a14131SAppaRao Puli [&](const boost::system::error_code& ec, 963e9a14131SAppaRao Puli const std::size_t& bytesTransferred) { 964e9a14131SAppaRao Puli if (ec) 965e9a14131SAppaRao Puli { 966e9a14131SAppaRao Puli BMCWEB_LOG_ERROR << "Callback Error: " << ec.message(); 967e9a14131SAppaRao Puli return; 968e9a14131SAppaRao Puli } 969e9a14131SAppaRao Puli std::size_t index = 0; 970e9a14131SAppaRao Puli while ((index + sizeof(inotify_event)) <= bytesTransferred) 971e9a14131SAppaRao Puli { 972e9a14131SAppaRao Puli struct inotify_event event; 973e9a14131SAppaRao Puli std::memcpy(&event, &readBuffer[index], 974e9a14131SAppaRao Puli sizeof(inotify_event)); 975e9a14131SAppaRao Puli if (event.mask == inotifyFileAction) 976e9a14131SAppaRao Puli { 977e9a14131SAppaRao Puli EventServiceManager::getInstance() 978e9a14131SAppaRao Puli .readEventLogsFromFile(); 979e9a14131SAppaRao Puli } 980e9a14131SAppaRao Puli index += (sizeof(inotify_event) + event.len); 981e9a14131SAppaRao Puli } 982e9a14131SAppaRao Puli 983e9a14131SAppaRao Puli watchRedfishEventLogFile(); 984e9a14131SAppaRao Puli }); 985e9a14131SAppaRao Puli } 986e9a14131SAppaRao Puli 987*fb4fd5d4SZhenfei Tai static int startEventLogMonitor(boost::asio::io_context& ioc) 988e9a14131SAppaRao Puli { 989e9a14131SAppaRao Puli inotifyConn = 990e9a14131SAppaRao Puli std::make_shared<boost::asio::posix::stream_descriptor>(ioc); 991e9a14131SAppaRao Puli int fd = inotify_init1(IN_NONBLOCK); 992e9a14131SAppaRao Puli if (fd == -1) 993e9a14131SAppaRao Puli { 994e9a14131SAppaRao Puli BMCWEB_LOG_ERROR << "inotify_init1 failed."; 995e9a14131SAppaRao Puli return -1; 996e9a14131SAppaRao Puli } 997e9a14131SAppaRao Puli auto wd = inotify_add_watch(fd, redfishEventLogFile, inotifyFileAction); 998e9a14131SAppaRao Puli if (wd == -1) 999e9a14131SAppaRao Puli { 1000e9a14131SAppaRao Puli BMCWEB_LOG_ERROR 1001e9a14131SAppaRao Puli << "inotify_add_watch failed for redfish log file."; 1002e9a14131SAppaRao Puli return -1; 1003e9a14131SAppaRao Puli } 1004e9a14131SAppaRao Puli 1005e9a14131SAppaRao Puli // monitor redfish event log file 1006e9a14131SAppaRao Puli inotifyConn->assign(fd); 1007e9a14131SAppaRao Puli watchRedfishEventLogFile(); 1008e9a14131SAppaRao Puli 1009e9a14131SAppaRao Puli return 0; 1010e9a14131SAppaRao Puli } 1011e9a14131SAppaRao Puli 1012e9a14131SAppaRao Puli #endif 1013156d6b00SAppaRao Puli 1014156d6b00SAppaRao Puli void getMetricReading(const std::string& service, 1015156d6b00SAppaRao Puli const std::string& objPath, const std::string& intf) 1016156d6b00SAppaRao Puli { 1017156d6b00SAppaRao Puli std::size_t found = objPath.find_last_of("/"); 1018156d6b00SAppaRao Puli if (found == std::string::npos) 1019156d6b00SAppaRao Puli { 1020156d6b00SAppaRao Puli BMCWEB_LOG_DEBUG << "Invalid objPath received"; 1021156d6b00SAppaRao Puli return; 1022156d6b00SAppaRao Puli } 1023156d6b00SAppaRao Puli 1024156d6b00SAppaRao Puli std::string idStr = objPath.substr(found + 1); 1025156d6b00SAppaRao Puli if (idStr.empty()) 1026156d6b00SAppaRao Puli { 1027156d6b00SAppaRao Puli BMCWEB_LOG_DEBUG << "Invalid ID in objPath"; 1028156d6b00SAppaRao Puli return; 1029156d6b00SAppaRao Puli } 1030156d6b00SAppaRao Puli 1031156d6b00SAppaRao Puli crow::connections::systemBus->async_method_call( 1032156d6b00SAppaRao Puli [idStr{std::move(idStr)}]( 1033156d6b00SAppaRao Puli const boost::system::error_code ec, 1034156d6b00SAppaRao Puli boost::container::flat_map< 1035156d6b00SAppaRao Puli std::string, std::variant<std::string, ReadingsObjType>>& 1036156d6b00SAppaRao Puli resp) { 1037156d6b00SAppaRao Puli if (ec) 1038156d6b00SAppaRao Puli { 1039156d6b00SAppaRao Puli BMCWEB_LOG_DEBUG 1040156d6b00SAppaRao Puli << "D-Bus call failed to GetAll metric readings."; 1041156d6b00SAppaRao Puli return; 1042156d6b00SAppaRao Puli } 1043156d6b00SAppaRao Puli 1044156d6b00SAppaRao Puli const std::string* timestampPtr = 1045156d6b00SAppaRao Puli std::get_if<std::string>(&resp["Timestamp"]); 1046156d6b00SAppaRao Puli if (!timestampPtr) 1047156d6b00SAppaRao Puli { 1048156d6b00SAppaRao Puli BMCWEB_LOG_DEBUG << "Failed to Get timestamp."; 1049156d6b00SAppaRao Puli return; 1050156d6b00SAppaRao Puli } 1051156d6b00SAppaRao Puli 1052156d6b00SAppaRao Puli ReadingsObjType* readingsPtr = 1053156d6b00SAppaRao Puli std::get_if<ReadingsObjType>(&resp["Readings"]); 1054156d6b00SAppaRao Puli if (!readingsPtr) 1055156d6b00SAppaRao Puli { 1056156d6b00SAppaRao Puli BMCWEB_LOG_DEBUG << "Failed to Get Readings property."; 1057156d6b00SAppaRao Puli return; 1058156d6b00SAppaRao Puli } 1059156d6b00SAppaRao Puli 1060156d6b00SAppaRao Puli if (!readingsPtr->size()) 1061156d6b00SAppaRao Puli { 1062156d6b00SAppaRao Puli BMCWEB_LOG_DEBUG << "No metrics report to be transferred"; 1063156d6b00SAppaRao Puli return; 1064156d6b00SAppaRao Puli } 1065156d6b00SAppaRao Puli 1066156d6b00SAppaRao Puli for (const auto& it : 1067156d6b00SAppaRao Puli EventServiceManager::getInstance().subscriptionsMap) 1068156d6b00SAppaRao Puli { 1069156d6b00SAppaRao Puli std::shared_ptr<Subscription> entry = it.second; 1070156d6b00SAppaRao Puli if (entry->eventFormatType == metricReportFormatType) 1071156d6b00SAppaRao Puli { 1072156d6b00SAppaRao Puli entry->filterAndSendReports(idStr, *timestampPtr, 1073156d6b00SAppaRao Puli *readingsPtr); 1074156d6b00SAppaRao Puli } 1075156d6b00SAppaRao Puli } 1076156d6b00SAppaRao Puli }, 1077156d6b00SAppaRao Puli service, objPath, "org.freedesktop.DBus.Properties", "GetAll", 1078156d6b00SAppaRao Puli intf); 1079156d6b00SAppaRao Puli } 1080156d6b00SAppaRao Puli 1081156d6b00SAppaRao Puli void unregisterMetricReportSignal() 1082156d6b00SAppaRao Puli { 10837d1cc387SAppaRao Puli if (matchTelemetryMonitor) 10847d1cc387SAppaRao Puli { 1085156d6b00SAppaRao Puli BMCWEB_LOG_DEBUG << "Metrics report signal - Unregister"; 1086156d6b00SAppaRao Puli matchTelemetryMonitor.reset(); 1087156d6b00SAppaRao Puli matchTelemetryMonitor = nullptr; 1088156d6b00SAppaRao Puli } 10897d1cc387SAppaRao Puli } 1090156d6b00SAppaRao Puli 1091156d6b00SAppaRao Puli void registerMetricReportSignal() 1092156d6b00SAppaRao Puli { 10937d1cc387SAppaRao Puli if (!serviceEnabled || matchTelemetryMonitor) 1094156d6b00SAppaRao Puli { 10957d1cc387SAppaRao Puli BMCWEB_LOG_DEBUG << "Not registering metric report signal."; 1096156d6b00SAppaRao Puli return; 1097156d6b00SAppaRao Puli } 1098156d6b00SAppaRao Puli 1099156d6b00SAppaRao Puli BMCWEB_LOG_DEBUG << "Metrics report signal - Register"; 1100156d6b00SAppaRao Puli std::string matchStr( 1101156d6b00SAppaRao Puli "type='signal',member='ReportUpdate', " 1102156d6b00SAppaRao Puli "interface='xyz.openbmc_project.MonitoringService.Report'"); 1103156d6b00SAppaRao Puli 1104156d6b00SAppaRao Puli matchTelemetryMonitor = std::make_shared<sdbusplus::bus::match::match>( 1105156d6b00SAppaRao Puli *crow::connections::systemBus, matchStr, 1106156d6b00SAppaRao Puli [this](sdbusplus::message::message& msg) { 1107156d6b00SAppaRao Puli if (msg.is_method_error()) 1108156d6b00SAppaRao Puli { 1109156d6b00SAppaRao Puli BMCWEB_LOG_ERROR << "TelemetryMonitor Signal error"; 1110156d6b00SAppaRao Puli return; 1111156d6b00SAppaRao Puli } 1112156d6b00SAppaRao Puli 1113156d6b00SAppaRao Puli std::string service = msg.get_sender(); 1114156d6b00SAppaRao Puli std::string objPath = msg.get_path(); 1115156d6b00SAppaRao Puli std::string intf = msg.get_interface(); 1116156d6b00SAppaRao Puli getMetricReading(service, objPath, intf); 1117156d6b00SAppaRao Puli }); 1118156d6b00SAppaRao Puli } 11191bf712bcSAyushi Smriti 11201bf712bcSAyushi Smriti bool validateAndSplitUrl(const std::string& destUrl, std::string& urlProto, 11211bf712bcSAyushi Smriti std::string& host, std::string& port, 11221bf712bcSAyushi Smriti std::string& path) 11231bf712bcSAyushi Smriti { 11241bf712bcSAyushi Smriti // Validate URL using regex expression 11251bf712bcSAyushi Smriti // Format: <protocol>://<host>:<port>/<path> 11261bf712bcSAyushi Smriti // protocol: http/https 11271bf712bcSAyushi Smriti const std::regex urlRegex( 11281bf712bcSAyushi Smriti "(http|https)://([^/\\x20\\x3f\\x23\\x3a]+):?([0-9]*)(/" 11291bf712bcSAyushi Smriti "([^\\x20\\x23\\x3f]*\\x3f?([^\\x20\\x23\\x3f])*)?)"); 11301bf712bcSAyushi Smriti std::cmatch match; 11311bf712bcSAyushi Smriti if (!std::regex_match(destUrl.c_str(), match, urlRegex)) 11321bf712bcSAyushi Smriti { 11331bf712bcSAyushi Smriti BMCWEB_LOG_INFO << "Dest. url did not match "; 11341bf712bcSAyushi Smriti return false; 11351bf712bcSAyushi Smriti } 11361bf712bcSAyushi Smriti 11371bf712bcSAyushi Smriti urlProto = std::string(match[1].first, match[1].second); 11381bf712bcSAyushi Smriti if (urlProto == "http") 11391bf712bcSAyushi Smriti { 11401bf712bcSAyushi Smriti #ifndef BMCWEB_INSECURE_ENABLE_HTTP_PUSH_STYLE_EVENTING 11411bf712bcSAyushi Smriti return false; 11421bf712bcSAyushi Smriti #endif 11431bf712bcSAyushi Smriti } 11441bf712bcSAyushi Smriti 11451bf712bcSAyushi Smriti host = std::string(match[2].first, match[2].second); 11461bf712bcSAyushi Smriti port = std::string(match[3].first, match[3].second); 11471bf712bcSAyushi Smriti path = std::string(match[4].first, match[4].second); 11481bf712bcSAyushi Smriti if (port.empty()) 11491bf712bcSAyushi Smriti { 11501bf712bcSAyushi Smriti if (urlProto == "http") 11511bf712bcSAyushi Smriti { 11521bf712bcSAyushi Smriti port = "80"; 11531bf712bcSAyushi Smriti } 11541bf712bcSAyushi Smriti else 11551bf712bcSAyushi Smriti { 11561bf712bcSAyushi Smriti port = "443"; 11571bf712bcSAyushi Smriti } 11581bf712bcSAyushi Smriti } 11591bf712bcSAyushi Smriti if (path.empty()) 11601bf712bcSAyushi Smriti { 11611bf712bcSAyushi Smriti path = "/"; 11621bf712bcSAyushi Smriti } 11631bf712bcSAyushi Smriti return true; 11641bf712bcSAyushi Smriti } 11651bf712bcSAyushi Smriti }; // namespace redfish 1166b52664e2SAppaRao Puli 1167b52664e2SAppaRao Puli } // namespace redfish 1168