1107077deSPrzemyslaw Czarnowski /* 2107077deSPrzemyslaw Czarnowski // Copyright (c) 2018 Intel Corporation 3107077deSPrzemyslaw Czarnowski // 4107077deSPrzemyslaw Czarnowski // Licensed under the Apache License, Version 2.0 (the "License"); 5107077deSPrzemyslaw Czarnowski // you may not use this file except in compliance with the License. 6107077deSPrzemyslaw Czarnowski // You may obtain a copy of the License at 7107077deSPrzemyslaw Czarnowski // 8107077deSPrzemyslaw Czarnowski // http://www.apache.org/licenses/LICENSE-2.0 9107077deSPrzemyslaw Czarnowski // 10107077deSPrzemyslaw Czarnowski // Unless required by applicable law or agreed to in writing, software 11107077deSPrzemyslaw Czarnowski // distributed under the License is distributed on an "AS IS" BASIS, 12107077deSPrzemyslaw Czarnowski // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 13107077deSPrzemyslaw Czarnowski // See the License for the specific language governing permissions and 14107077deSPrzemyslaw Czarnowski // limitations under the License. 15107077deSPrzemyslaw Czarnowski */ 16107077deSPrzemyslaw Czarnowski #pragma once 17107077deSPrzemyslaw Czarnowski 187e860f15SJohn Edward Broadbent #include <app.hpp> 19107077deSPrzemyslaw Czarnowski #include <boost/container/flat_map.hpp> 20988fb7b2SAdrian Ambrożewicz #include <boost/process/async_pipe.hpp> 21988fb7b2SAdrian Ambrożewicz #include <boost/type_traits/has_dereference.hpp> 22107077deSPrzemyslaw Czarnowski #include <utils/json_utils.hpp> 23107077deSPrzemyslaw Czarnowski // for GetObjectType and ManagedObjectType 24ed398213SEd Tanous 25e13c2760SPrzemyslaw Czarnowski #include <account_service.hpp> 269e319cf0SAnna Platash #include <boost/url/url_view.hpp> 27ed398213SEd Tanous #include <registries/privilege_registry.hpp> 28107077deSPrzemyslaw Czarnowski 29107077deSPrzemyslaw Czarnowski namespace redfish 30107077deSPrzemyslaw Czarnowski { 319e319cf0SAnna Platash /** 329e319cf0SAnna Platash * @brief Function extracts transfer protocol name from URI. 339e319cf0SAnna Platash */ 34*67df073bSEd Tanous #ifdef NEW_BOOST_URL 35*67df073bSEd Tanous inline std::string getTransferProtocolTypeFromUri(const std::string& imageUri) 36*67df073bSEd Tanous { 37*67df073bSEd Tanous boost::urls::result<boost::urls::url_view> url = 38*67df073bSEd Tanous boost::urls::parse_uri(boost::string_view(imageUri)); 39*67df073bSEd Tanous if (!url) 40*67df073bSEd Tanous { 41*67df073bSEd Tanous return "None"; 42*67df073bSEd Tanous } 43*67df073bSEd Tanous boost::string_view scheme = url->scheme(); 44*67df073bSEd Tanous if (scheme == "smb") 45*67df073bSEd Tanous { 46*67df073bSEd Tanous return "CIFS"; 47*67df073bSEd Tanous } 48*67df073bSEd Tanous if (scheme == "https") 49*67df073bSEd Tanous { 50*67df073bSEd Tanous return "HTTPS"; 51*67df073bSEd Tanous } 52*67df073bSEd Tanous 53*67df073bSEd Tanous return "None"; 54*67df073bSEd Tanous } 55*67df073bSEd Tanous #else 5622db1728SEd Tanous inline std::string getTransferProtocolTypeFromUri(const std::string& imageUri) 579e319cf0SAnna Platash { 58d32c4fa9SEd Tanous boost::urls::error_code ec; 59d32c4fa9SEd Tanous boost::urls::url_view url = 60d32c4fa9SEd Tanous boost::urls::parse_uri(boost::string_view(imageUri), ec); 61d32c4fa9SEd Tanous if (ec) 629e319cf0SAnna Platash { 63d32c4fa9SEd Tanous return "None"; 64d32c4fa9SEd Tanous } 65d32c4fa9SEd Tanous boost::string_view scheme = url.scheme(); 669e319cf0SAnna Platash if (scheme == "smb") 679e319cf0SAnna Platash { 689e319cf0SAnna Platash return "CIFS"; 699e319cf0SAnna Platash } 7022db1728SEd Tanous if (scheme == "https") 719e319cf0SAnna Platash { 729e319cf0SAnna Platash return "HTTPS"; 739e319cf0SAnna Platash } 74d32c4fa9SEd Tanous 759e319cf0SAnna Platash return "None"; 769e319cf0SAnna Platash } 77*67df073bSEd Tanous #endif 78107077deSPrzemyslaw Czarnowski 79107077deSPrzemyslaw Czarnowski /** 80107077deSPrzemyslaw Czarnowski * @brief Read all known properties from VM object interfaces 81107077deSPrzemyslaw Czarnowski */ 8222db1728SEd Tanous inline void 83711ac7a9SEd Tanous vmParseInterfaceObject(const dbus::utility::DBusInteracesMap& interface, 848d1b46d7Szhanghch05 const std::shared_ptr<bmcweb::AsyncResp>& aResp) 85107077deSPrzemyslaw Czarnowski { 86711ac7a9SEd Tanous for (const auto& [interface, values] : interface) 87107077deSPrzemyslaw Czarnowski { 88711ac7a9SEd Tanous if (interface == "xyz.openbmc_project.VirtualMedia.MountPoint") 89107077deSPrzemyslaw Czarnowski { 90711ac7a9SEd Tanous for (const auto& [property, value] : values) 91107077deSPrzemyslaw Czarnowski { 92711ac7a9SEd Tanous if (property == "EndpointId") 93107077deSPrzemyslaw Czarnowski { 94107077deSPrzemyslaw Czarnowski const std::string* endpointIdValue = 95711ac7a9SEd Tanous std::get_if<std::string>(&value); 96711ac7a9SEd Tanous if (endpointIdValue == nullptr) 97107077deSPrzemyslaw Czarnowski { 98711ac7a9SEd Tanous continue; 99711ac7a9SEd Tanous } 100107077deSPrzemyslaw Czarnowski if (!endpointIdValue->empty()) 101107077deSPrzemyslaw Czarnowski { 102107077deSPrzemyslaw Czarnowski // Proxy mode 103711ac7a9SEd Tanous aResp->res 104711ac7a9SEd Tanous .jsonValue["Oem"]["OpenBMC"]["WebSocketEndpoint"] = 105d04ba325SPrzemyslaw Czarnowski *endpointIdValue; 106107077deSPrzemyslaw Czarnowski aResp->res.jsonValue["TransferProtocolType"] = "OEM"; 107107077deSPrzemyslaw Czarnowski } 108107077deSPrzemyslaw Czarnowski } 109711ac7a9SEd Tanous if (property == "ImageURL") 110107077deSPrzemyslaw Czarnowski { 111107077deSPrzemyslaw Czarnowski const std::string* imageUrlValue = 112711ac7a9SEd Tanous std::get_if<std::string>(&value); 11326f6976fSEd Tanous if (imageUrlValue != nullptr && !imageUrlValue->empty()) 114107077deSPrzemyslaw Czarnowski { 115da4784d8SPrzemyslaw Czarnowski std::filesystem::path filePath = *imageUrlValue; 116da4784d8SPrzemyslaw Czarnowski if (!filePath.has_filename()) 117da4784d8SPrzemyslaw Czarnowski { 1189e319cf0SAnna Platash // this will handle https share, which not 1199e319cf0SAnna Platash // necessarily has to have filename given. 120da4784d8SPrzemyslaw Czarnowski aResp->res.jsonValue["ImageName"] = ""; 121da4784d8SPrzemyslaw Czarnowski } 122da4784d8SPrzemyslaw Czarnowski else 123da4784d8SPrzemyslaw Czarnowski { 1249e319cf0SAnna Platash aResp->res.jsonValue["ImageName"] = 1259e319cf0SAnna Platash filePath.filename(); 126da4784d8SPrzemyslaw Czarnowski } 127da4784d8SPrzemyslaw Czarnowski 128da4784d8SPrzemyslaw Czarnowski aResp->res.jsonValue["Image"] = *imageUrlValue; 1299e319cf0SAnna Platash aResp->res.jsonValue["TransferProtocolType"] = 1309e319cf0SAnna Platash getTransferProtocolTypeFromUri(*imageUrlValue); 1319e319cf0SAnna Platash 132107077deSPrzemyslaw Czarnowski aResp->res.jsonValue["ConnectedVia"] = "URI"; 133107077deSPrzemyslaw Czarnowski } 134107077deSPrzemyslaw Czarnowski } 135711ac7a9SEd Tanous if (property == "WriteProtected") 1369e319cf0SAnna Platash { 137711ac7a9SEd Tanous const bool* writeProtectedValue = std::get_if<bool>(&value); 1389e319cf0SAnna Platash if (writeProtectedValue) 1399e319cf0SAnna Platash { 1409e319cf0SAnna Platash aResp->res.jsonValue["WriteProtected"] = 1419e319cf0SAnna Platash *writeProtectedValue; 1429e319cf0SAnna Platash } 1439e319cf0SAnna Platash } 1449e319cf0SAnna Platash } 145107077deSPrzemyslaw Czarnowski } 146711ac7a9SEd Tanous if (interface == "xyz.openbmc_project.VirtualMedia.Process") 147711ac7a9SEd Tanous { 148711ac7a9SEd Tanous for (const auto& [property, value] : values) 149711ac7a9SEd Tanous { 150711ac7a9SEd Tanous if (property == "Active") 151711ac7a9SEd Tanous { 152711ac7a9SEd Tanous const bool* activeValue = std::get_if<bool>(&value); 153711ac7a9SEd Tanous if (!activeValue) 154711ac7a9SEd Tanous { 155711ac7a9SEd Tanous BMCWEB_LOG_DEBUG << "Value Active not found"; 156711ac7a9SEd Tanous return; 157711ac7a9SEd Tanous } 158711ac7a9SEd Tanous aResp->res.jsonValue["Inserted"] = *activeValue; 159711ac7a9SEd Tanous 160711ac7a9SEd Tanous if (*activeValue == true) 161711ac7a9SEd Tanous { 162711ac7a9SEd Tanous aResp->res.jsonValue["ConnectedVia"] = "Applet"; 163711ac7a9SEd Tanous } 164711ac7a9SEd Tanous } 165711ac7a9SEd Tanous } 166711ac7a9SEd Tanous } 167107077deSPrzemyslaw Czarnowski } 168107077deSPrzemyslaw Czarnowski } 169107077deSPrzemyslaw Czarnowski 170107077deSPrzemyslaw Czarnowski /** 171107077deSPrzemyslaw Czarnowski * @brief Fill template for Virtual Media Item. 172107077deSPrzemyslaw Czarnowski */ 17322db1728SEd Tanous inline nlohmann::json vmItemTemplate(const std::string& name, 174107077deSPrzemyslaw Czarnowski const std::string& resName) 175107077deSPrzemyslaw Czarnowski { 176107077deSPrzemyslaw Czarnowski nlohmann::json item; 17722db1728SEd Tanous 17822db1728SEd Tanous std::string id = "/redfish/v1/Managers/"; 17922db1728SEd Tanous id += name; 18022db1728SEd Tanous id += "/VirtualMedia/"; 18122db1728SEd Tanous id += resName; 18222db1728SEd Tanous item["@odata.id"] = std::move(id); 18322db1728SEd Tanous 184d04ba325SPrzemyslaw Czarnowski item["@odata.type"] = "#VirtualMedia.v1_3_0.VirtualMedia"; 185107077deSPrzemyslaw Czarnowski item["Name"] = "Virtual Removable Media"; 186107077deSPrzemyslaw Czarnowski item["Id"] = resName; 187107077deSPrzemyslaw Czarnowski item["WriteProtected"] = true; 188107077deSPrzemyslaw Czarnowski item["MediaTypes"] = {"CD", "USBStick"}; 189107077deSPrzemyslaw Czarnowski item["TransferMethod"] = "Stream"; 190d04ba325SPrzemyslaw Czarnowski item["Oem"]["OpenBMC"]["@odata.type"] = 191d04ba325SPrzemyslaw Czarnowski "#OemVirtualMedia.v1_0_0.VirtualMedia"; 192107077deSPrzemyslaw Czarnowski 193107077deSPrzemyslaw Czarnowski return item; 194107077deSPrzemyslaw Czarnowski } 195107077deSPrzemyslaw Czarnowski 196107077deSPrzemyslaw Czarnowski /** 197107077deSPrzemyslaw Czarnowski * @brief Fills collection data 198107077deSPrzemyslaw Czarnowski */ 19922db1728SEd Tanous inline void getVmResourceList(std::shared_ptr<bmcweb::AsyncResp> aResp, 200107077deSPrzemyslaw Czarnowski const std::string& service, 201107077deSPrzemyslaw Czarnowski const std::string& name) 202107077deSPrzemyslaw Czarnowski { 203107077deSPrzemyslaw Czarnowski BMCWEB_LOG_DEBUG << "Get available Virtual Media resources."; 204107077deSPrzemyslaw Czarnowski crow::connections::systemBus->async_method_call( 205711ac7a9SEd Tanous [name, 206711ac7a9SEd Tanous aResp{std::move(aResp)}](const boost::system::error_code ec, 207711ac7a9SEd Tanous dbus::utility::ManagedObjectType& subtree) { 208107077deSPrzemyslaw Czarnowski if (ec) 209107077deSPrzemyslaw Czarnowski { 210107077deSPrzemyslaw Czarnowski BMCWEB_LOG_DEBUG << "DBUS response error"; 211107077deSPrzemyslaw Czarnowski return; 212107077deSPrzemyslaw Czarnowski } 213107077deSPrzemyslaw Czarnowski nlohmann::json& members = aResp->res.jsonValue["Members"]; 214107077deSPrzemyslaw Czarnowski members = nlohmann::json::array(); 215107077deSPrzemyslaw Czarnowski 216107077deSPrzemyslaw Czarnowski for (const auto& object : subtree) 217107077deSPrzemyslaw Czarnowski { 218107077deSPrzemyslaw Czarnowski nlohmann::json item; 2192dfd18efSEd Tanous std::string path = object.first.filename(); 2202dfd18efSEd Tanous if (path.empty()) 221107077deSPrzemyslaw Czarnowski { 222107077deSPrzemyslaw Czarnowski continue; 223107077deSPrzemyslaw Czarnowski } 224107077deSPrzemyslaw Czarnowski 22522db1728SEd Tanous std::string id = "/redfish/v1/Managers/"; 22622db1728SEd Tanous id += name; 22722db1728SEd Tanous id += "/VirtualMedia/"; 22822db1728SEd Tanous id += path; 229107077deSPrzemyslaw Czarnowski 23022db1728SEd Tanous item["@odata.id"] = std::move(id); 231107077deSPrzemyslaw Czarnowski members.emplace_back(std::move(item)); 232107077deSPrzemyslaw Czarnowski } 233107077deSPrzemyslaw Czarnowski aResp->res.jsonValue["Members@odata.count"] = members.size(); 234107077deSPrzemyslaw Czarnowski }, 235107077deSPrzemyslaw Czarnowski service, "/xyz/openbmc_project/VirtualMedia", 236107077deSPrzemyslaw Czarnowski "org.freedesktop.DBus.ObjectManager", "GetManagedObjects"); 237107077deSPrzemyslaw Czarnowski } 238107077deSPrzemyslaw Czarnowski 239107077deSPrzemyslaw Czarnowski /** 240107077deSPrzemyslaw Czarnowski * @brief Fills data for specific resource 241107077deSPrzemyslaw Czarnowski */ 24222db1728SEd Tanous inline void getVmData(const std::shared_ptr<bmcweb::AsyncResp>& aResp, 243107077deSPrzemyslaw Czarnowski const std::string& service, const std::string& name, 244107077deSPrzemyslaw Czarnowski const std::string& resName) 245107077deSPrzemyslaw Czarnowski { 246107077deSPrzemyslaw Czarnowski BMCWEB_LOG_DEBUG << "Get Virtual Media resource data."; 247107077deSPrzemyslaw Czarnowski 248107077deSPrzemyslaw Czarnowski crow::connections::systemBus->async_method_call( 249914e2d5dSEd Tanous [resName, name, 250914e2d5dSEd Tanous aResp](const boost::system::error_code ec, 251914e2d5dSEd Tanous const dbus::utility::ManagedObjectType& subtree) { 252107077deSPrzemyslaw Czarnowski if (ec) 253107077deSPrzemyslaw Czarnowski { 254107077deSPrzemyslaw Czarnowski BMCWEB_LOG_DEBUG << "DBUS response error"; 255e13c2760SPrzemyslaw Czarnowski 256107077deSPrzemyslaw Czarnowski return; 257107077deSPrzemyslaw Czarnowski } 258107077deSPrzemyslaw Czarnowski 259914e2d5dSEd Tanous for (const auto& item : subtree) 260107077deSPrzemyslaw Czarnowski { 2612dfd18efSEd Tanous std::string thispath = item.first.filename(); 2622dfd18efSEd Tanous if (thispath.empty()) 263107077deSPrzemyslaw Czarnowski { 264107077deSPrzemyslaw Czarnowski continue; 265107077deSPrzemyslaw Czarnowski } 266107077deSPrzemyslaw Czarnowski 2672dfd18efSEd Tanous if (thispath != resName) 268107077deSPrzemyslaw Czarnowski { 269107077deSPrzemyslaw Czarnowski continue; 270107077deSPrzemyslaw Czarnowski } 271107077deSPrzemyslaw Czarnowski 2721a6258dcSPrzemyslaw Czarnowski // "Legacy"/"Proxy" 2731a6258dcSPrzemyslaw Czarnowski auto mode = item.first.parent_path(); 2741a6258dcSPrzemyslaw Czarnowski // "VirtualMedia" 2751a6258dcSPrzemyslaw Czarnowski auto type = mode.parent_path(); 2761a6258dcSPrzemyslaw Czarnowski if (mode.filename().empty() || type.filename().empty()) 2771a6258dcSPrzemyslaw Czarnowski { 2781a6258dcSPrzemyslaw Czarnowski continue; 2791a6258dcSPrzemyslaw Czarnowski } 2801a6258dcSPrzemyslaw Czarnowski 2811a6258dcSPrzemyslaw Czarnowski if (type.filename() != "VirtualMedia") 2821a6258dcSPrzemyslaw Czarnowski { 2831a6258dcSPrzemyslaw Czarnowski continue; 2841a6258dcSPrzemyslaw Czarnowski } 2851a6258dcSPrzemyslaw Czarnowski 286107077deSPrzemyslaw Czarnowski aResp->res.jsonValue = vmItemTemplate(name, resName); 28722db1728SEd Tanous std::string actionsId = "/redfish/v1/Managers/"; 28822db1728SEd Tanous actionsId += name; 28922db1728SEd Tanous actionsId += "/VirtualMedia/"; 29022db1728SEd Tanous actionsId += resName; 29122db1728SEd Tanous actionsId += "/Actions"; 292107077deSPrzemyslaw Czarnowski 293e13c2760SPrzemyslaw Czarnowski // Check if dbus path is Legacy type 2941a6258dcSPrzemyslaw Czarnowski if (mode.filename() == "Legacy") 295e13c2760SPrzemyslaw Czarnowski { 296e13c2760SPrzemyslaw Czarnowski aResp->res.jsonValue["Actions"]["#VirtualMedia.InsertMedia"] 297e13c2760SPrzemyslaw Czarnowski ["target"] = 29822db1728SEd Tanous actionsId + "/VirtualMedia.InsertMedia"; 299e13c2760SPrzemyslaw Czarnowski } 300e13c2760SPrzemyslaw Czarnowski 301107077deSPrzemyslaw Czarnowski vmParseInterfaceObject(item.second, aResp); 302107077deSPrzemyslaw Czarnowski 303e13c2760SPrzemyslaw Czarnowski aResp->res.jsonValue["Actions"]["#VirtualMedia.EjectMedia"] 304e13c2760SPrzemyslaw Czarnowski ["target"] = 30522db1728SEd Tanous actionsId + "/VirtualMedia.EjectMedia"; 306e13c2760SPrzemyslaw Czarnowski 307107077deSPrzemyslaw Czarnowski return; 308107077deSPrzemyslaw Czarnowski } 309107077deSPrzemyslaw Czarnowski 310107077deSPrzemyslaw Czarnowski messages::resourceNotFound( 311d04ba325SPrzemyslaw Czarnowski aResp->res, "#VirtualMedia.v1_3_0.VirtualMedia", resName); 312107077deSPrzemyslaw Czarnowski }, 313107077deSPrzemyslaw Czarnowski service, "/xyz/openbmc_project/VirtualMedia", 314107077deSPrzemyslaw Czarnowski "org.freedesktop.DBus.ObjectManager", "GetManagedObjects"); 315107077deSPrzemyslaw Czarnowski } 316107077deSPrzemyslaw Czarnowski 317e13c2760SPrzemyslaw Czarnowski /** 318c6f4e017SAgata Olender * @brief Transfer protocols supported for InsertMedia action. 319c6f4e017SAgata Olender * 320c6f4e017SAgata Olender */ 321c6f4e017SAgata Olender enum class TransferProtocol 322c6f4e017SAgata Olender { 323c6f4e017SAgata Olender https, 324c6f4e017SAgata Olender smb, 325c6f4e017SAgata Olender invalid 326c6f4e017SAgata Olender }; 327c6f4e017SAgata Olender 328c6f4e017SAgata Olender /** 329c6f4e017SAgata Olender * @brief Function extracts transfer protocol type from URI. 330c6f4e017SAgata Olender * 331c6f4e017SAgata Olender */ 332*67df073bSEd Tanous #ifdef NEW_BOOST_URL 333*67df073bSEd Tanous inline std::optional<TransferProtocol> 334*67df073bSEd Tanous getTransferProtocolFromUri(const std::string& imageUri) 335*67df073bSEd Tanous { 336*67df073bSEd Tanous boost::urls::result<boost::urls::url_view> url = 337*67df073bSEd Tanous boost::urls::parse_uri(boost::string_view(imageUri)); 338*67df073bSEd Tanous if (!url) 339*67df073bSEd Tanous { 340*67df073bSEd Tanous return {}; 341*67df073bSEd Tanous } 342*67df073bSEd Tanous 343*67df073bSEd Tanous boost::string_view scheme = url->scheme(); 344*67df073bSEd Tanous if (scheme == "smb") 345*67df073bSEd Tanous { 346*67df073bSEd Tanous return TransferProtocol::smb; 347*67df073bSEd Tanous } 348*67df073bSEd Tanous if (scheme == "https") 349*67df073bSEd Tanous { 350*67df073bSEd Tanous return TransferProtocol::https; 351*67df073bSEd Tanous } 352*67df073bSEd Tanous if (!scheme.empty()) 353*67df073bSEd Tanous { 354*67df073bSEd Tanous return TransferProtocol::invalid; 355*67df073bSEd Tanous } 356*67df073bSEd Tanous 357*67df073bSEd Tanous return {}; 358*67df073bSEd Tanous } 359*67df073bSEd Tanous #else 36022db1728SEd Tanous inline std::optional<TransferProtocol> 361c6f4e017SAgata Olender getTransferProtocolFromUri(const std::string& imageUri) 362c6f4e017SAgata Olender { 363d32c4fa9SEd Tanous boost::urls::error_code ec; 364d32c4fa9SEd Tanous boost::urls::url_view url = 365d32c4fa9SEd Tanous boost::urls::parse_uri(boost::string_view(imageUri), ec); 366d32c4fa9SEd Tanous if (ec) 3679e319cf0SAnna Platash { 368d32c4fa9SEd Tanous return {}; 369d32c4fa9SEd Tanous } 370d32c4fa9SEd Tanous 371d32c4fa9SEd Tanous boost::string_view scheme = url.scheme(); 3729e319cf0SAnna Platash if (scheme == "smb") 373c6f4e017SAgata Olender { 374c6f4e017SAgata Olender return TransferProtocol::smb; 375c6f4e017SAgata Olender } 37681ce609eSEd Tanous if (scheme == "https") 377c6f4e017SAgata Olender { 378c6f4e017SAgata Olender return TransferProtocol::https; 379c6f4e017SAgata Olender } 38022db1728SEd Tanous if (!scheme.empty()) 381c6f4e017SAgata Olender { 382c6f4e017SAgata Olender return TransferProtocol::invalid; 383c6f4e017SAgata Olender } 3849e319cf0SAnna Platash 3859e319cf0SAnna Platash return {}; 386c6f4e017SAgata Olender } 387*67df073bSEd Tanous #endif 388c6f4e017SAgata Olender 389c6f4e017SAgata Olender /** 390c6f4e017SAgata Olender * @brief Function convert transfer protocol from string param. 391c6f4e017SAgata Olender * 392c6f4e017SAgata Olender */ 39322db1728SEd Tanous inline std::optional<TransferProtocol> getTransferProtocolFromParam( 394c6f4e017SAgata Olender const std::optional<std::string>& transferProtocolType) 395c6f4e017SAgata Olender { 396c6f4e017SAgata Olender if (transferProtocolType == std::nullopt) 397c6f4e017SAgata Olender { 398c6f4e017SAgata Olender return {}; 399c6f4e017SAgata Olender } 400c6f4e017SAgata Olender 401c6f4e017SAgata Olender if (*transferProtocolType == "CIFS") 402c6f4e017SAgata Olender { 403c6f4e017SAgata Olender return TransferProtocol::smb; 404c6f4e017SAgata Olender } 405c6f4e017SAgata Olender 406c6f4e017SAgata Olender if (*transferProtocolType == "HTTPS") 407c6f4e017SAgata Olender { 408c6f4e017SAgata Olender return TransferProtocol::https; 409c6f4e017SAgata Olender } 410c6f4e017SAgata Olender 411c6f4e017SAgata Olender return TransferProtocol::invalid; 412c6f4e017SAgata Olender } 413c6f4e017SAgata Olender 414c6f4e017SAgata Olender /** 415c6f4e017SAgata Olender * @brief Function extends URI with transfer protocol type. 416c6f4e017SAgata Olender * 417c6f4e017SAgata Olender */ 41822db1728SEd Tanous inline std::string 419c6f4e017SAgata Olender getUriWithTransferProtocol(const std::string& imageUri, 420c6f4e017SAgata Olender const TransferProtocol& transferProtocol) 421c6f4e017SAgata Olender { 422c6f4e017SAgata Olender if (transferProtocol == TransferProtocol::smb) 423c6f4e017SAgata Olender { 424c6f4e017SAgata Olender return "smb://" + imageUri; 425c6f4e017SAgata Olender } 426c6f4e017SAgata Olender 427c6f4e017SAgata Olender if (transferProtocol == TransferProtocol::https) 428c6f4e017SAgata Olender { 429c6f4e017SAgata Olender return "https://" + imageUri; 430c6f4e017SAgata Olender } 431c6f4e017SAgata Olender 432c6f4e017SAgata Olender return imageUri; 433c6f4e017SAgata Olender } 434c6f4e017SAgata Olender 435c6f4e017SAgata Olender /** 436c6f4e017SAgata Olender * @brief Function validate parameters of insert media request. 437c6f4e017SAgata Olender * 438c6f4e017SAgata Olender */ 43922db1728SEd Tanous inline bool 44022db1728SEd Tanous validateParams(crow::Response& res, std::string& imageUrl, 441c6f4e017SAgata Olender const std::optional<bool>& inserted, 442c6f4e017SAgata Olender const std::optional<std::string>& transferMethod, 443c6f4e017SAgata Olender const std::optional<std::string>& transferProtocolType) 444c6f4e017SAgata Olender { 445c6f4e017SAgata Olender BMCWEB_LOG_DEBUG << "Validation started"; 446c6f4e017SAgata Olender // required param imageUrl must not be empty 447c6f4e017SAgata Olender if (imageUrl.empty()) 448c6f4e017SAgata Olender { 449c6f4e017SAgata Olender BMCWEB_LOG_ERROR << "Request action parameter Image is empty."; 450c6f4e017SAgata Olender 45122db1728SEd Tanous messages::propertyValueFormatError(res, "<empty>", "Image"); 452c6f4e017SAgata Olender 453c6f4e017SAgata Olender return false; 454c6f4e017SAgata Olender } 455c6f4e017SAgata Olender 456c6f4e017SAgata Olender // optional param inserted must be true 457c6f4e017SAgata Olender if ((inserted != std::nullopt) && (*inserted != true)) 458c6f4e017SAgata Olender { 459c6f4e017SAgata Olender BMCWEB_LOG_ERROR 460c6f4e017SAgata Olender << "Request action optional parameter Inserted must be true."; 461c6f4e017SAgata Olender 46222db1728SEd Tanous messages::actionParameterNotSupported(res, "Inserted", "InsertMedia"); 463c6f4e017SAgata Olender 464c6f4e017SAgata Olender return false; 465c6f4e017SAgata Olender } 466c6f4e017SAgata Olender 467c6f4e017SAgata Olender // optional param transferMethod must be stream 468c6f4e017SAgata Olender if ((transferMethod != std::nullopt) && (*transferMethod != "Stream")) 469c6f4e017SAgata Olender { 470c6f4e017SAgata Olender BMCWEB_LOG_ERROR << "Request action optional parameter " 471c6f4e017SAgata Olender "TransferMethod must be Stream."; 472c6f4e017SAgata Olender 47322db1728SEd Tanous messages::actionParameterNotSupported(res, "TransferMethod", 47422db1728SEd Tanous "InsertMedia"); 475c6f4e017SAgata Olender 476c6f4e017SAgata Olender return false; 477c6f4e017SAgata Olender } 478c6f4e017SAgata Olender 479c6f4e017SAgata Olender std::optional<TransferProtocol> uriTransferProtocolType = 480c6f4e017SAgata Olender getTransferProtocolFromUri(imageUrl); 481c6f4e017SAgata Olender 482c6f4e017SAgata Olender std::optional<TransferProtocol> paramTransferProtocolType = 483c6f4e017SAgata Olender getTransferProtocolFromParam(transferProtocolType); 484c6f4e017SAgata Olender 485c6f4e017SAgata Olender // ImageUrl does not contain valid protocol type 486c6f4e017SAgata Olender if (*uriTransferProtocolType == TransferProtocol::invalid) 487c6f4e017SAgata Olender { 488c6f4e017SAgata Olender BMCWEB_LOG_ERROR << "Request action parameter ImageUrl must " 489c6f4e017SAgata Olender "contain specified protocol type from list: " 490c6f4e017SAgata Olender "(smb, https)."; 491c6f4e017SAgata Olender 49222db1728SEd Tanous messages::resourceAtUriInUnknownFormat(res, imageUrl); 493c6f4e017SAgata Olender 494c6f4e017SAgata Olender return false; 495c6f4e017SAgata Olender } 496c6f4e017SAgata Olender 497c6f4e017SAgata Olender // transferProtocolType should contain value from list 498c6f4e017SAgata Olender if (*paramTransferProtocolType == TransferProtocol::invalid) 499c6f4e017SAgata Olender { 500c6f4e017SAgata Olender BMCWEB_LOG_ERROR << "Request action parameter TransferProtocolType " 501c6f4e017SAgata Olender "must be provided with value from list: " 502c6f4e017SAgata Olender "(CIFS, HTTPS)."; 503c6f4e017SAgata Olender 50422db1728SEd Tanous messages::propertyValueNotInList(res, *transferProtocolType, 50522db1728SEd Tanous "TransferProtocolType"); 506c6f4e017SAgata Olender return false; 507c6f4e017SAgata Olender } 508c6f4e017SAgata Olender 509c6f4e017SAgata Olender // valid transfer protocol not provided either with URI nor param 510c6f4e017SAgata Olender if ((uriTransferProtocolType == std::nullopt) && 511c6f4e017SAgata Olender (paramTransferProtocolType == std::nullopt)) 512c6f4e017SAgata Olender { 513c6f4e017SAgata Olender BMCWEB_LOG_ERROR << "Request action parameter ImageUrl must " 514c6f4e017SAgata Olender "contain specified protocol type or param " 515c6f4e017SAgata Olender "TransferProtocolType must be provided."; 516c6f4e017SAgata Olender 51722db1728SEd Tanous messages::resourceAtUriInUnknownFormat(res, imageUrl); 518c6f4e017SAgata Olender 519c6f4e017SAgata Olender return false; 520c6f4e017SAgata Olender } 521c6f4e017SAgata Olender 522c6f4e017SAgata Olender // valid transfer protocol provided both with URI and param 523c6f4e017SAgata Olender if ((paramTransferProtocolType != std::nullopt) && 524c6f4e017SAgata Olender (uriTransferProtocolType != std::nullopt)) 525c6f4e017SAgata Olender { 526c6f4e017SAgata Olender // check if protocol is the same for URI and param 527c6f4e017SAgata Olender if (*paramTransferProtocolType != *uriTransferProtocolType) 528c6f4e017SAgata Olender { 529c6f4e017SAgata Olender BMCWEB_LOG_ERROR << "Request action parameter " 530c6f4e017SAgata Olender "TransferProtocolType must contain the " 531c6f4e017SAgata Olender "same protocol type as protocol type " 532c6f4e017SAgata Olender "provided with param imageUrl."; 533c6f4e017SAgata Olender 53422db1728SEd Tanous messages::actionParameterValueTypeError(res, *transferProtocolType, 53522db1728SEd Tanous "TransferProtocolType", 53622db1728SEd Tanous "InsertMedia"); 537c6f4e017SAgata Olender 538c6f4e017SAgata Olender return false; 539c6f4e017SAgata Olender } 540c6f4e017SAgata Olender } 541c6f4e017SAgata Olender 542c6f4e017SAgata Olender // validation passed 543c6f4e017SAgata Olender // add protocol to URI if needed 544c6f4e017SAgata Olender if (uriTransferProtocolType == std::nullopt) 545c6f4e017SAgata Olender { 54622db1728SEd Tanous imageUrl = 54722db1728SEd Tanous getUriWithTransferProtocol(imageUrl, *paramTransferProtocolType); 548c6f4e017SAgata Olender } 549c6f4e017SAgata Olender 550c6f4e017SAgata Olender return true; 551c6f4e017SAgata Olender } 552c6f4e017SAgata Olender 5531214b7e7SGunnar Mills template <typename T> 5541214b7e7SGunnar Mills static void secureCleanup(T& value) 555988fb7b2SAdrian Ambrożewicz { 5564ecc618fSEd Tanous // NOLINTNEXTLINE(cppcoreguidelines-pro-type-const-cast) 557988fb7b2SAdrian Ambrożewicz auto raw = const_cast<typename T::value_type*>(value.data()); 558988fb7b2SAdrian Ambrożewicz explicit_bzero(raw, value.size() * sizeof(*raw)); 559988fb7b2SAdrian Ambrożewicz } 560988fb7b2SAdrian Ambrożewicz 561988fb7b2SAdrian Ambrożewicz class Credentials 562988fb7b2SAdrian Ambrożewicz { 563988fb7b2SAdrian Ambrożewicz public: 564988fb7b2SAdrian Ambrożewicz Credentials(std::string&& user, std::string&& password) : 565988fb7b2SAdrian Ambrożewicz userBuf(std::move(user)), passBuf(std::move(password)) 5661214b7e7SGunnar Mills {} 567988fb7b2SAdrian Ambrożewicz 568988fb7b2SAdrian Ambrożewicz ~Credentials() 569988fb7b2SAdrian Ambrożewicz { 570988fb7b2SAdrian Ambrożewicz secureCleanup(userBuf); 571988fb7b2SAdrian Ambrożewicz secureCleanup(passBuf); 572988fb7b2SAdrian Ambrożewicz } 573988fb7b2SAdrian Ambrożewicz 574988fb7b2SAdrian Ambrożewicz const std::string& user() 575988fb7b2SAdrian Ambrożewicz { 576988fb7b2SAdrian Ambrożewicz return userBuf; 577988fb7b2SAdrian Ambrożewicz } 578988fb7b2SAdrian Ambrożewicz 579988fb7b2SAdrian Ambrożewicz const std::string& password() 580988fb7b2SAdrian Ambrożewicz { 581988fb7b2SAdrian Ambrożewicz return passBuf; 582988fb7b2SAdrian Ambrożewicz } 583988fb7b2SAdrian Ambrożewicz 584988fb7b2SAdrian Ambrożewicz Credentials() = delete; 585988fb7b2SAdrian Ambrożewicz Credentials(const Credentials&) = delete; 586988fb7b2SAdrian Ambrożewicz Credentials& operator=(const Credentials&) = delete; 587ecd6a3a2SEd Tanous Credentials(Credentials&&) = delete; 588ecd6a3a2SEd Tanous Credentials& operator=(Credentials&&) = delete; 589988fb7b2SAdrian Ambrożewicz 59022db1728SEd Tanous private: 591988fb7b2SAdrian Ambrożewicz std::string userBuf; 592988fb7b2SAdrian Ambrożewicz std::string passBuf; 593988fb7b2SAdrian Ambrożewicz }; 594988fb7b2SAdrian Ambrożewicz 595988fb7b2SAdrian Ambrożewicz class CredentialsProvider 596988fb7b2SAdrian Ambrożewicz { 597988fb7b2SAdrian Ambrożewicz public: 5981214b7e7SGunnar Mills template <typename T> 5991214b7e7SGunnar Mills struct Deleter 600988fb7b2SAdrian Ambrożewicz { 601988fb7b2SAdrian Ambrożewicz void operator()(T* buff) const 602988fb7b2SAdrian Ambrożewicz { 603988fb7b2SAdrian Ambrożewicz if (buff) 604988fb7b2SAdrian Ambrożewicz { 605988fb7b2SAdrian Ambrożewicz secureCleanup(*buff); 606988fb7b2SAdrian Ambrożewicz delete buff; 607988fb7b2SAdrian Ambrożewicz } 608988fb7b2SAdrian Ambrożewicz } 609988fb7b2SAdrian Ambrożewicz }; 610988fb7b2SAdrian Ambrożewicz 611988fb7b2SAdrian Ambrożewicz using Buffer = std::vector<char>; 612988fb7b2SAdrian Ambrożewicz using SecureBuffer = std::unique_ptr<Buffer, Deleter<Buffer>>; 613988fb7b2SAdrian Ambrożewicz // Using explicit definition instead of std::function to avoid implicit 614988fb7b2SAdrian Ambrożewicz // conversions eg. stack copy instead of reference 615988fb7b2SAdrian Ambrożewicz using FormatterFunc = void(const std::string& username, 616988fb7b2SAdrian Ambrożewicz const std::string& password, Buffer& dest); 617988fb7b2SAdrian Ambrożewicz 618988fb7b2SAdrian Ambrożewicz CredentialsProvider(std::string&& user, std::string&& password) : 619988fb7b2SAdrian Ambrożewicz credentials(std::move(user), std::move(password)) 6201214b7e7SGunnar Mills {} 621988fb7b2SAdrian Ambrożewicz 622988fb7b2SAdrian Ambrożewicz const std::string& user() 623988fb7b2SAdrian Ambrożewicz { 624988fb7b2SAdrian Ambrożewicz return credentials.user(); 625988fb7b2SAdrian Ambrożewicz } 626988fb7b2SAdrian Ambrożewicz 627988fb7b2SAdrian Ambrożewicz const std::string& password() 628988fb7b2SAdrian Ambrożewicz { 629988fb7b2SAdrian Ambrożewicz return credentials.password(); 630988fb7b2SAdrian Ambrożewicz } 631988fb7b2SAdrian Ambrożewicz 63281ce609eSEd Tanous SecureBuffer pack(FormatterFunc formatter) 633988fb7b2SAdrian Ambrożewicz { 634988fb7b2SAdrian Ambrożewicz SecureBuffer packed{new Buffer{}}; 635988fb7b2SAdrian Ambrożewicz if (formatter) 636988fb7b2SAdrian Ambrożewicz { 637988fb7b2SAdrian Ambrożewicz formatter(credentials.user(), credentials.password(), *packed); 638988fb7b2SAdrian Ambrożewicz } 639988fb7b2SAdrian Ambrożewicz 640988fb7b2SAdrian Ambrożewicz return packed; 641988fb7b2SAdrian Ambrożewicz } 642988fb7b2SAdrian Ambrożewicz 643988fb7b2SAdrian Ambrożewicz private: 644988fb7b2SAdrian Ambrożewicz Credentials credentials; 645988fb7b2SAdrian Ambrożewicz }; 646988fb7b2SAdrian Ambrożewicz 647988fb7b2SAdrian Ambrożewicz // Wrapper for boost::async_pipe ensuring proper pipe cleanup 6481214b7e7SGunnar Mills template <typename Buffer> 6491214b7e7SGunnar Mills class Pipe 650988fb7b2SAdrian Ambrożewicz { 651988fb7b2SAdrian Ambrożewicz public: 652988fb7b2SAdrian Ambrożewicz using unix_fd = sdbusplus::message::unix_fd; 653988fb7b2SAdrian Ambrożewicz 654988fb7b2SAdrian Ambrożewicz Pipe(boost::asio::io_context& io, Buffer&& buffer) : 655988fb7b2SAdrian Ambrożewicz impl(io), buffer{std::move(buffer)} 6561214b7e7SGunnar Mills {} 657988fb7b2SAdrian Ambrożewicz 658988fb7b2SAdrian Ambrożewicz ~Pipe() 659988fb7b2SAdrian Ambrożewicz { 660988fb7b2SAdrian Ambrożewicz // Named pipe needs to be explicitly removed 661988fb7b2SAdrian Ambrożewicz impl.close(); 662988fb7b2SAdrian Ambrożewicz } 663988fb7b2SAdrian Ambrożewicz 664ecd6a3a2SEd Tanous Pipe(const Pipe&) = delete; 665ecd6a3a2SEd Tanous Pipe(Pipe&&) = delete; 666ecd6a3a2SEd Tanous Pipe& operator=(const Pipe&) = delete; 667ecd6a3a2SEd Tanous Pipe& operator=(Pipe&&) = delete; 668ecd6a3a2SEd Tanous 669988fb7b2SAdrian Ambrożewicz unix_fd fd() 670988fb7b2SAdrian Ambrożewicz { 671988fb7b2SAdrian Ambrożewicz return unix_fd{impl.native_source()}; 672988fb7b2SAdrian Ambrożewicz } 673988fb7b2SAdrian Ambrożewicz 674988fb7b2SAdrian Ambrożewicz template <typename WriteHandler> 67581ce609eSEd Tanous void asyncWrite(WriteHandler&& handler) 676988fb7b2SAdrian Ambrożewicz { 677988fb7b2SAdrian Ambrożewicz impl.async_write_some(data(), std::forward<WriteHandler>(handler)); 678988fb7b2SAdrian Ambrożewicz } 679988fb7b2SAdrian Ambrożewicz 680988fb7b2SAdrian Ambrożewicz private: 681988fb7b2SAdrian Ambrożewicz // Specialization for pointer types 682988fb7b2SAdrian Ambrożewicz template <typename B = Buffer> 683988fb7b2SAdrian Ambrożewicz typename std::enable_if<boost::has_dereference<B>::value, 684988fb7b2SAdrian Ambrożewicz boost::asio::const_buffer>::type 685988fb7b2SAdrian Ambrożewicz data() 686988fb7b2SAdrian Ambrożewicz { 687988fb7b2SAdrian Ambrożewicz return boost::asio::buffer(*buffer); 688988fb7b2SAdrian Ambrożewicz } 689988fb7b2SAdrian Ambrożewicz 690988fb7b2SAdrian Ambrożewicz template <typename B = Buffer> 691988fb7b2SAdrian Ambrożewicz typename std::enable_if<!boost::has_dereference<B>::value, 692988fb7b2SAdrian Ambrożewicz boost::asio::const_buffer>::type 693988fb7b2SAdrian Ambrożewicz data() 694988fb7b2SAdrian Ambrożewicz { 695988fb7b2SAdrian Ambrożewicz return boost::asio::buffer(buffer); 696988fb7b2SAdrian Ambrożewicz } 697988fb7b2SAdrian Ambrożewicz 698988fb7b2SAdrian Ambrożewicz const std::string name; 699988fb7b2SAdrian Ambrożewicz boost::process::async_pipe impl; 700988fb7b2SAdrian Ambrożewicz Buffer buffer; 701988fb7b2SAdrian Ambrożewicz }; 702988fb7b2SAdrian Ambrożewicz 703e13c2760SPrzemyslaw Czarnowski /** 704e13c2760SPrzemyslaw Czarnowski * @brief Function transceives data with dbus directly. 705e13c2760SPrzemyslaw Czarnowski * 706e13c2760SPrzemyslaw Czarnowski * All BMC state properties will be retrieved before sending reset request. 707e13c2760SPrzemyslaw Czarnowski */ 70822db1728SEd Tanous inline void doMountVmLegacy(const std::shared_ptr<bmcweb::AsyncResp>& asyncResp, 709e13c2760SPrzemyslaw Czarnowski const std::string& service, const std::string& name, 710988fb7b2SAdrian Ambrożewicz const std::string& imageUrl, const bool rw, 711988fb7b2SAdrian Ambrożewicz std::string&& userName, std::string&& password) 712e13c2760SPrzemyslaw Czarnowski { 713988fb7b2SAdrian Ambrożewicz using SecurePipe = Pipe<CredentialsProvider::SecureBuffer>; 714988fb7b2SAdrian Ambrożewicz constexpr const size_t secretLimit = 1024; 715988fb7b2SAdrian Ambrożewicz 716988fb7b2SAdrian Ambrożewicz std::shared_ptr<SecurePipe> secretPipe; 717168e20c1SEd Tanous dbus::utility::DbusVariantType unixFd = -1; 718988fb7b2SAdrian Ambrożewicz 719988fb7b2SAdrian Ambrożewicz if (!userName.empty() || !password.empty()) 720988fb7b2SAdrian Ambrożewicz { 721988fb7b2SAdrian Ambrożewicz // Encapsulate in safe buffer 722988fb7b2SAdrian Ambrożewicz CredentialsProvider credentials(std::move(userName), 723988fb7b2SAdrian Ambrożewicz std::move(password)); 724988fb7b2SAdrian Ambrożewicz 725988fb7b2SAdrian Ambrożewicz // Payload must contain data + NULL delimiters 726988fb7b2SAdrian Ambrożewicz if (credentials.user().size() + credentials.password().size() + 2 > 727988fb7b2SAdrian Ambrożewicz secretLimit) 728988fb7b2SAdrian Ambrożewicz { 729988fb7b2SAdrian Ambrożewicz BMCWEB_LOG_ERROR << "Credentials too long to handle"; 730988fb7b2SAdrian Ambrożewicz messages::unrecognizedRequestBody(asyncResp->res); 731988fb7b2SAdrian Ambrożewicz return; 732988fb7b2SAdrian Ambrożewicz } 733988fb7b2SAdrian Ambrożewicz 734988fb7b2SAdrian Ambrożewicz // Pack secret 73522db1728SEd Tanous auto secret = credentials.pack( 73622db1728SEd Tanous [](const auto& user, const auto& pass, auto& buff) { 737988fb7b2SAdrian Ambrożewicz std::copy(user.begin(), user.end(), std::back_inserter(buff)); 738988fb7b2SAdrian Ambrożewicz buff.push_back('\0'); 739988fb7b2SAdrian Ambrożewicz std::copy(pass.begin(), pass.end(), std::back_inserter(buff)); 740988fb7b2SAdrian Ambrożewicz buff.push_back('\0'); 741988fb7b2SAdrian Ambrożewicz }); 742988fb7b2SAdrian Ambrożewicz 743988fb7b2SAdrian Ambrożewicz // Open pipe 744988fb7b2SAdrian Ambrożewicz secretPipe = std::make_shared<SecurePipe>( 74522db1728SEd Tanous crow::connections::systemBus->get_io_context(), std::move(secret)); 746988fb7b2SAdrian Ambrożewicz unixFd = secretPipe->fd(); 747988fb7b2SAdrian Ambrożewicz 748988fb7b2SAdrian Ambrożewicz // Pass secret over pipe 74981ce609eSEd Tanous secretPipe->asyncWrite( 750f5b16f03SVikram Bodireddy [asyncResp](const boost::system::error_code& ec, std::size_t) { 751988fb7b2SAdrian Ambrożewicz if (ec) 752988fb7b2SAdrian Ambrożewicz { 753988fb7b2SAdrian Ambrożewicz BMCWEB_LOG_ERROR << "Failed to pass secret: " << ec; 754988fb7b2SAdrian Ambrożewicz messages::internalError(asyncResp->res); 755988fb7b2SAdrian Ambrożewicz } 756988fb7b2SAdrian Ambrożewicz }); 757988fb7b2SAdrian Ambrożewicz } 758988fb7b2SAdrian Ambrożewicz 759e13c2760SPrzemyslaw Czarnowski crow::connections::systemBus->async_method_call( 760988fb7b2SAdrian Ambrożewicz [asyncResp, secretPipe](const boost::system::error_code ec, 761988fb7b2SAdrian Ambrożewicz bool success) { 762e13c2760SPrzemyslaw Czarnowski if (ec) 763e13c2760SPrzemyslaw Czarnowski { 764e13c2760SPrzemyslaw Czarnowski BMCWEB_LOG_ERROR << "Bad D-Bus request error: " << ec; 765e13c2760SPrzemyslaw Czarnowski messages::internalError(asyncResp->res); 766d6da5bebSAdrian Ambrożewicz } 767d6da5bebSAdrian Ambrożewicz else if (!success) 768d6da5bebSAdrian Ambrożewicz { 769d6da5bebSAdrian Ambrożewicz BMCWEB_LOG_ERROR << "Service responded with error"; 770d6da5bebSAdrian Ambrożewicz messages::generalError(asyncResp->res); 771e13c2760SPrzemyslaw Czarnowski } 772e13c2760SPrzemyslaw Czarnowski }, 773e13c2760SPrzemyslaw Czarnowski service, "/xyz/openbmc_project/VirtualMedia/Legacy/" + name, 774988fb7b2SAdrian Ambrożewicz "xyz.openbmc_project.VirtualMedia.Legacy", "Mount", imageUrl, rw, 775988fb7b2SAdrian Ambrożewicz unixFd); 776e13c2760SPrzemyslaw Czarnowski } 777e13c2760SPrzemyslaw Czarnowski 778e13c2760SPrzemyslaw Czarnowski /** 779e13c2760SPrzemyslaw Czarnowski * @brief Function transceives data with dbus directly. 780e13c2760SPrzemyslaw Czarnowski * 781e13c2760SPrzemyslaw Czarnowski * All BMC state properties will be retrieved before sending reset request. 782e13c2760SPrzemyslaw Czarnowski */ 78322db1728SEd Tanous inline void doVmAction(const std::shared_ptr<bmcweb::AsyncResp>& asyncResp, 784e13c2760SPrzemyslaw Czarnowski const std::string& service, const std::string& name, 785e13c2760SPrzemyslaw Czarnowski bool legacy) 786e13c2760SPrzemyslaw Czarnowski { 787e13c2760SPrzemyslaw Czarnowski 788e13c2760SPrzemyslaw Czarnowski // Legacy mount requires parameter with image 789e13c2760SPrzemyslaw Czarnowski if (legacy) 790e13c2760SPrzemyslaw Czarnowski { 791e13c2760SPrzemyslaw Czarnowski crow::connections::systemBus->async_method_call( 792e13c2760SPrzemyslaw Czarnowski [asyncResp](const boost::system::error_code ec) { 793e13c2760SPrzemyslaw Czarnowski if (ec) 794e13c2760SPrzemyslaw Czarnowski { 795e13c2760SPrzemyslaw Czarnowski BMCWEB_LOG_ERROR << "Bad D-Bus request error: " << ec; 796e13c2760SPrzemyslaw Czarnowski 797e13c2760SPrzemyslaw Czarnowski messages::internalError(asyncResp->res); 798e13c2760SPrzemyslaw Czarnowski return; 799e13c2760SPrzemyslaw Czarnowski } 800e13c2760SPrzemyslaw Czarnowski }, 801e13c2760SPrzemyslaw Czarnowski service, "/xyz/openbmc_project/VirtualMedia/Legacy/" + name, 802e13c2760SPrzemyslaw Czarnowski "xyz.openbmc_project.VirtualMedia.Legacy", "Unmount"); 803e13c2760SPrzemyslaw Czarnowski } 804e13c2760SPrzemyslaw Czarnowski else // proxy 805e13c2760SPrzemyslaw Czarnowski { 806e13c2760SPrzemyslaw Czarnowski crow::connections::systemBus->async_method_call( 807e13c2760SPrzemyslaw Czarnowski [asyncResp](const boost::system::error_code ec) { 808e13c2760SPrzemyslaw Czarnowski if (ec) 809e13c2760SPrzemyslaw Czarnowski { 810e13c2760SPrzemyslaw Czarnowski BMCWEB_LOG_ERROR << "Bad D-Bus request error: " << ec; 811e13c2760SPrzemyslaw Czarnowski 812e13c2760SPrzemyslaw Czarnowski messages::internalError(asyncResp->res); 813e13c2760SPrzemyslaw Czarnowski return; 814e13c2760SPrzemyslaw Czarnowski } 815e13c2760SPrzemyslaw Czarnowski }, 816e13c2760SPrzemyslaw Czarnowski service, "/xyz/openbmc_project/VirtualMedia/Proxy/" + name, 817e13c2760SPrzemyslaw Czarnowski "xyz.openbmc_project.VirtualMedia.Proxy", "Unmount"); 818e13c2760SPrzemyslaw Czarnowski } 819e13c2760SPrzemyslaw Czarnowski } 820e13c2760SPrzemyslaw Czarnowski 82198be3e39SEd Tanous struct InsertMediaActionParams 82298be3e39SEd Tanous { 82398be3e39SEd Tanous std::string imageUrl; 82498be3e39SEd Tanous std::optional<std::string> userName; 82598be3e39SEd Tanous std::optional<std::string> password; 82698be3e39SEd Tanous std::optional<std::string> transferMethod; 82798be3e39SEd Tanous std::optional<std::string> transferProtocolType; 82898be3e39SEd Tanous std::optional<bool> writeProtected = true; 82998be3e39SEd Tanous std::optional<bool> inserted; 83098be3e39SEd Tanous }; 83198be3e39SEd Tanous 83222db1728SEd Tanous inline void requestNBDVirtualMediaRoutes(App& app) 833107077deSPrzemyslaw Czarnowski { 8340fda0f12SGeorge Liu BMCWEB_ROUTE( 8350fda0f12SGeorge Liu app, 8360fda0f12SGeorge Liu "/redfish/v1/Managers/<str>/VirtualMedia/<str>/Actions/VirtualMedia.InsertMedia") 837ed398213SEd Tanous .privileges(redfish::privileges::postVirtualMedia) 83822db1728SEd Tanous .methods(boost::beast::http::verb::post)( 83922db1728SEd Tanous [](const crow::Request& req, 84022db1728SEd Tanous const std::shared_ptr<bmcweb::AsyncResp>& asyncResp, 84122db1728SEd Tanous const std::string& name, const std::string& resName) { 84222db1728SEd Tanous if (name != "bmc") 843107077deSPrzemyslaw Czarnowski { 84422db1728SEd Tanous messages::resourceNotFound(asyncResp->res, 84522db1728SEd Tanous "VirtualMedia.Insert", resName); 846107077deSPrzemyslaw Czarnowski 847107077deSPrzemyslaw Czarnowski return; 848107077deSPrzemyslaw Czarnowski } 84998be3e39SEd Tanous InsertMediaActionParams actionParams; 85098be3e39SEd Tanous 85198be3e39SEd Tanous // Read obligatory parameters (url of 85298be3e39SEd Tanous // image) 85398be3e39SEd Tanous if (!json_util::readJson( 85498be3e39SEd Tanous req, asyncResp->res, "Image", actionParams.imageUrl, 85598be3e39SEd Tanous "WriteProtected", actionParams.writeProtected, 85698be3e39SEd Tanous "UserName", actionParams.userName, "Password", 85798be3e39SEd Tanous actionParams.password, "Inserted", 85898be3e39SEd Tanous actionParams.inserted, "TransferMethod", 85998be3e39SEd Tanous actionParams.transferMethod, "TransferProtocolType", 86098be3e39SEd Tanous actionParams.transferProtocolType)) 86198be3e39SEd Tanous { 86298be3e39SEd Tanous BMCWEB_LOG_DEBUG << "Image is not provided"; 86398be3e39SEd Tanous return; 86498be3e39SEd Tanous } 86598be3e39SEd Tanous 86698be3e39SEd Tanous bool paramsValid = validateParams( 86798be3e39SEd Tanous asyncResp->res, actionParams.imageUrl, 86898be3e39SEd Tanous actionParams.inserted, actionParams.transferMethod, 86998be3e39SEd Tanous actionParams.transferProtocolType); 87098be3e39SEd Tanous 87198be3e39SEd Tanous if (paramsValid == false) 87298be3e39SEd Tanous { 87398be3e39SEd Tanous return; 87498be3e39SEd Tanous } 875107077deSPrzemyslaw Czarnowski 87622db1728SEd Tanous crow::connections::systemBus->async_method_call( 87798be3e39SEd Tanous [asyncResp, actionParams, 87822db1728SEd Tanous resName](const boost::system::error_code ec, 87998be3e39SEd Tanous const GetObjectType& getObjectType) mutable { 88022db1728SEd Tanous if (ec) 88122db1728SEd Tanous { 88222db1728SEd Tanous BMCWEB_LOG_ERROR 88322db1728SEd Tanous << "ObjectMapper::GetObject call failed: " 88422db1728SEd Tanous << ec; 88522db1728SEd Tanous messages::internalError(asyncResp->res); 886107077deSPrzemyslaw Czarnowski 88722db1728SEd Tanous return; 88822db1728SEd Tanous } 88922db1728SEd Tanous std::string service = getObjectType.begin()->first; 89022db1728SEd Tanous BMCWEB_LOG_DEBUG << "GetObjectType: " << service; 89122db1728SEd Tanous 89222db1728SEd Tanous crow::connections::systemBus->async_method_call( 89398be3e39SEd Tanous [service, resName, actionParams, 89422db1728SEd Tanous asyncResp](const boost::system::error_code ec, 895711ac7a9SEd Tanous dbus::utility::ManagedObjectType& 896711ac7a9SEd Tanous subtree) mutable { 89722db1728SEd Tanous if (ec) 89822db1728SEd Tanous { 89922db1728SEd Tanous BMCWEB_LOG_DEBUG << "DBUS response error"; 90022db1728SEd Tanous 90122db1728SEd Tanous return; 90222db1728SEd Tanous } 90322db1728SEd Tanous 90422db1728SEd Tanous for (const auto& object : subtree) 90522db1728SEd Tanous { 90622db1728SEd Tanous const std::string& path = 90722db1728SEd Tanous static_cast<const std::string&>( 90822db1728SEd Tanous object.first); 90922db1728SEd Tanous 91022db1728SEd Tanous std::size_t lastIndex = path.rfind('/'); 91122db1728SEd Tanous if (lastIndex == std::string::npos) 91222db1728SEd Tanous { 91322db1728SEd Tanous continue; 91422db1728SEd Tanous } 91522db1728SEd Tanous 91622db1728SEd Tanous lastIndex += 1; 91722db1728SEd Tanous 91822db1728SEd Tanous if (path.substr(lastIndex) == resName) 91922db1728SEd Tanous { 92022db1728SEd Tanous lastIndex = path.rfind("Proxy"); 92122db1728SEd Tanous if (lastIndex != std::string::npos) 92222db1728SEd Tanous { 92322db1728SEd Tanous // Not possible in proxy mode 92422db1728SEd Tanous BMCWEB_LOG_DEBUG 92522db1728SEd Tanous << "InsertMedia not " 92622db1728SEd Tanous "allowed in proxy mode"; 92722db1728SEd Tanous messages::resourceNotFound( 92822db1728SEd Tanous asyncResp->res, 92922db1728SEd Tanous "VirtualMedia.InsertMedia", 93022db1728SEd Tanous resName); 93122db1728SEd Tanous 93222db1728SEd Tanous return; 93322db1728SEd Tanous } 93422db1728SEd Tanous 93522db1728SEd Tanous lastIndex = path.rfind("Legacy"); 93622db1728SEd Tanous if (lastIndex == std::string::npos) 93722db1728SEd Tanous { 93822db1728SEd Tanous continue; 93922db1728SEd Tanous } 94022db1728SEd Tanous 94122db1728SEd Tanous // manager is irrelevant for 94222db1728SEd Tanous // VirtualMedia dbus calls 94398be3e39SEd Tanous doMountVmLegacy( 94498be3e39SEd Tanous asyncResp, service, resName, 94598be3e39SEd Tanous actionParams.imageUrl, 94698be3e39SEd Tanous !(*actionParams.writeProtected), 94798be3e39SEd Tanous std::move(*actionParams.userName), 94898be3e39SEd Tanous std::move(*actionParams.password)); 94922db1728SEd Tanous 95022db1728SEd Tanous return; 95122db1728SEd Tanous } 95222db1728SEd Tanous } 95322db1728SEd Tanous BMCWEB_LOG_DEBUG << "Parent item not found"; 95422db1728SEd Tanous messages::resourceNotFound( 95522db1728SEd Tanous asyncResp->res, "VirtualMedia", resName); 95622db1728SEd Tanous }, 95722db1728SEd Tanous service, "/xyz/openbmc_project/VirtualMedia", 95822db1728SEd Tanous "org.freedesktop.DBus.ObjectManager", 95922db1728SEd Tanous "GetManagedObjects"); 96022db1728SEd Tanous }, 96122db1728SEd Tanous "xyz.openbmc_project.ObjectMapper", 96222db1728SEd Tanous "/xyz/openbmc_project/object_mapper", 96322db1728SEd Tanous "xyz.openbmc_project.ObjectMapper", "GetObject", 96422db1728SEd Tanous "/xyz/openbmc_project/VirtualMedia", 96522db1728SEd Tanous std::array<const char*, 0>()); 96622db1728SEd Tanous }); 96722db1728SEd Tanous 9680fda0f12SGeorge Liu BMCWEB_ROUTE( 9690fda0f12SGeorge Liu app, 9700fda0f12SGeorge Liu "/redfish/v1/Managers/<str>/VirtualMedia/<str>/Actions/VirtualMedia.EjectMedia") 971ed398213SEd Tanous .privileges(redfish::privileges::postVirtualMedia) 97222db1728SEd Tanous .methods(boost::beast::http::verb::post)( 97398be3e39SEd Tanous [](const crow::Request&, 97422db1728SEd Tanous const std::shared_ptr<bmcweb::AsyncResp>& asyncResp, 97522db1728SEd Tanous const std::string& name, const std::string& resName) { 976107077deSPrzemyslaw Czarnowski if (name != "bmc") 977107077deSPrzemyslaw Czarnowski { 97822db1728SEd Tanous messages::resourceNotFound(asyncResp->res, 97922db1728SEd Tanous "VirtualMedia.Eject", resName); 98022db1728SEd Tanous 98122db1728SEd Tanous return; 98222db1728SEd Tanous } 98322db1728SEd Tanous 98422db1728SEd Tanous crow::connections::systemBus->async_method_call( 98598be3e39SEd Tanous [asyncResp, resName](const boost::system::error_code ec, 98622db1728SEd Tanous const GetObjectType& getObjectType) { 98722db1728SEd Tanous if (ec) 98822db1728SEd Tanous { 98922db1728SEd Tanous BMCWEB_LOG_ERROR 99022db1728SEd Tanous << "ObjectMapper::GetObject call failed: " 99122db1728SEd Tanous << ec; 99222db1728SEd Tanous messages::internalError(asyncResp->res); 99322db1728SEd Tanous 99422db1728SEd Tanous return; 99522db1728SEd Tanous } 99622db1728SEd Tanous std::string service = getObjectType.begin()->first; 99722db1728SEd Tanous BMCWEB_LOG_DEBUG << "GetObjectType: " << service; 99822db1728SEd Tanous 99922db1728SEd Tanous crow::connections::systemBus->async_method_call( 100098be3e39SEd Tanous [resName, service, asyncResp{asyncResp}]( 100122db1728SEd Tanous const boost::system::error_code ec, 1002711ac7a9SEd Tanous dbus::utility::ManagedObjectType& subtree) { 100322db1728SEd Tanous if (ec) 100422db1728SEd Tanous { 100522db1728SEd Tanous BMCWEB_LOG_DEBUG << "DBUS response error"; 100622db1728SEd Tanous 100722db1728SEd Tanous return; 100822db1728SEd Tanous } 100922db1728SEd Tanous 101022db1728SEd Tanous for (const auto& object : subtree) 101122db1728SEd Tanous { 101222db1728SEd Tanous const std::string& path = 101322db1728SEd Tanous static_cast<const std::string&>( 101422db1728SEd Tanous object.first); 101522db1728SEd Tanous 101622db1728SEd Tanous std::size_t lastIndex = path.rfind('/'); 101722db1728SEd Tanous if (lastIndex == std::string::npos) 101822db1728SEd Tanous { 101922db1728SEd Tanous continue; 102022db1728SEd Tanous } 102122db1728SEd Tanous 102222db1728SEd Tanous lastIndex += 1; 102322db1728SEd Tanous 102422db1728SEd Tanous if (path.substr(lastIndex) == resName) 102522db1728SEd Tanous { 102622db1728SEd Tanous lastIndex = path.rfind("Proxy"); 102722db1728SEd Tanous if (lastIndex != std::string::npos) 102822db1728SEd Tanous { 102922db1728SEd Tanous // Proxy mode 103022db1728SEd Tanous doVmAction(asyncResp, service, 103122db1728SEd Tanous resName, false); 103222db1728SEd Tanous } 103322db1728SEd Tanous 103422db1728SEd Tanous lastIndex = path.rfind("Legacy"); 103522db1728SEd Tanous if (lastIndex != std::string::npos) 103622db1728SEd Tanous { 103722db1728SEd Tanous // Legacy mode 103822db1728SEd Tanous doVmAction(asyncResp, service, 103922db1728SEd Tanous resName, true); 104022db1728SEd Tanous } 104122db1728SEd Tanous 104222db1728SEd Tanous return; 104322db1728SEd Tanous } 104422db1728SEd Tanous } 104522db1728SEd Tanous BMCWEB_LOG_DEBUG << "Parent item not found"; 104622db1728SEd Tanous messages::resourceNotFound( 104722db1728SEd Tanous asyncResp->res, "VirtualMedia", resName); 104822db1728SEd Tanous }, 104922db1728SEd Tanous service, "/xyz/openbmc_project/VirtualMedia", 105022db1728SEd Tanous "org.freedesktop.DBus.ObjectManager", 105122db1728SEd Tanous "GetManagedObjects"); 105222db1728SEd Tanous }, 105322db1728SEd Tanous "xyz.openbmc_project.ObjectMapper", 105422db1728SEd Tanous "/xyz/openbmc_project/object_mapper", 105522db1728SEd Tanous "xyz.openbmc_project.ObjectMapper", "GetObject", 105622db1728SEd Tanous "/xyz/openbmc_project/VirtualMedia", 105722db1728SEd Tanous std::array<const char*, 0>()); 105822db1728SEd Tanous }); 105922db1728SEd Tanous BMCWEB_ROUTE(app, "/redfish/v1/Managers/<str>/VirtualMedia/") 1060ed398213SEd Tanous .privileges(redfish::privileges::getVirtualMediaCollection) 106122db1728SEd Tanous .methods(boost::beast::http::verb::get)( 106222db1728SEd Tanous [](const crow::Request& /* req */, 106322db1728SEd Tanous const std::shared_ptr<bmcweb::AsyncResp>& asyncResp, 106422db1728SEd Tanous const std::string& name) { 106522db1728SEd Tanous if (name != "bmc") 106622db1728SEd Tanous { 106722db1728SEd Tanous messages::resourceNotFound(asyncResp->res, "VirtualMedia", 106822db1728SEd Tanous name); 1069107077deSPrzemyslaw Czarnowski 1070107077deSPrzemyslaw Czarnowski return; 1071107077deSPrzemyslaw Czarnowski } 1072107077deSPrzemyslaw Czarnowski 10738d1b46d7Szhanghch05 asyncResp->res.jsonValue["@odata.type"] = 1074107077deSPrzemyslaw Czarnowski "#VirtualMediaCollection.VirtualMediaCollection"; 10758d1b46d7Szhanghch05 asyncResp->res.jsonValue["Name"] = "Virtual Media Services"; 10768d1b46d7Szhanghch05 asyncResp->res.jsonValue["@odata.id"] = 1077d6c414f3SPrzemyslaw Czarnowski "/redfish/v1/Managers/" + name + "/VirtualMedia"; 1078107077deSPrzemyslaw Czarnowski 1079107077deSPrzemyslaw Czarnowski crow::connections::systemBus->async_method_call( 1080107077deSPrzemyslaw Czarnowski [asyncResp, name](const boost::system::error_code ec, 1081107077deSPrzemyslaw Czarnowski const GetObjectType& getObjectType) { 1082107077deSPrzemyslaw Czarnowski if (ec) 1083107077deSPrzemyslaw Czarnowski { 108422db1728SEd Tanous BMCWEB_LOG_ERROR 108522db1728SEd Tanous << "ObjectMapper::GetObject call failed: " 1086107077deSPrzemyslaw Czarnowski << ec; 1087107077deSPrzemyslaw Czarnowski messages::internalError(asyncResp->res); 1088107077deSPrzemyslaw Czarnowski 1089107077deSPrzemyslaw Czarnowski return; 1090107077deSPrzemyslaw Czarnowski } 1091107077deSPrzemyslaw Czarnowski std::string service = getObjectType.begin()->first; 1092107077deSPrzemyslaw Czarnowski BMCWEB_LOG_DEBUG << "GetObjectType: " << service; 1093107077deSPrzemyslaw Czarnowski 1094107077deSPrzemyslaw Czarnowski getVmResourceList(asyncResp, service, name); 1095107077deSPrzemyslaw Czarnowski }, 1096107077deSPrzemyslaw Czarnowski "xyz.openbmc_project.ObjectMapper", 1097107077deSPrzemyslaw Czarnowski "/xyz/openbmc_project/object_mapper", 1098107077deSPrzemyslaw Czarnowski "xyz.openbmc_project.ObjectMapper", "GetObject", 109922db1728SEd Tanous "/xyz/openbmc_project/VirtualMedia", 110022db1728SEd Tanous std::array<const char*, 0>()); 110122db1728SEd Tanous }); 1102107077deSPrzemyslaw Czarnowski 110322db1728SEd Tanous BMCWEB_ROUTE(app, "/redfish/v1/Managers/<str>/VirtualMedia/<str>/") 1104ed398213SEd Tanous .privileges(redfish::privileges::getVirtualMedia) 110522db1728SEd Tanous .methods(boost::beast::http::verb::get)( 110622db1728SEd Tanous [](const crow::Request& /* req */, 110722db1728SEd Tanous const std::shared_ptr<bmcweb::AsyncResp>& asyncResp, 110822db1728SEd Tanous const std::string& name, const std::string& resName) { 1109107077deSPrzemyslaw Czarnowski if (name != "bmc") 1110107077deSPrzemyslaw Czarnowski { 111122db1728SEd Tanous messages::resourceNotFound(asyncResp->res, "VirtualMedia", 111222db1728SEd Tanous resName); 1113107077deSPrzemyslaw Czarnowski 1114107077deSPrzemyslaw Czarnowski return; 1115107077deSPrzemyslaw Czarnowski } 1116107077deSPrzemyslaw Czarnowski 1117107077deSPrzemyslaw Czarnowski crow::connections::systemBus->async_method_call( 111822db1728SEd Tanous [asyncResp, name, 111922db1728SEd Tanous resName](const boost::system::error_code ec, 1120107077deSPrzemyslaw Czarnowski const GetObjectType& getObjectType) { 1121107077deSPrzemyslaw Czarnowski if (ec) 1122107077deSPrzemyslaw Czarnowski { 112322db1728SEd Tanous BMCWEB_LOG_ERROR 112422db1728SEd Tanous << "ObjectMapper::GetObject call failed: " 1125107077deSPrzemyslaw Czarnowski << ec; 1126107077deSPrzemyslaw Czarnowski messages::internalError(asyncResp->res); 1127107077deSPrzemyslaw Czarnowski 1128107077deSPrzemyslaw Czarnowski return; 1129107077deSPrzemyslaw Czarnowski } 1130107077deSPrzemyslaw Czarnowski std::string service = getObjectType.begin()->first; 1131107077deSPrzemyslaw Czarnowski BMCWEB_LOG_DEBUG << "GetObjectType: " << service; 1132107077deSPrzemyslaw Czarnowski 1133107077deSPrzemyslaw Czarnowski getVmData(asyncResp, service, name, resName); 1134107077deSPrzemyslaw Czarnowski }, 1135107077deSPrzemyslaw Czarnowski "xyz.openbmc_project.ObjectMapper", 1136107077deSPrzemyslaw Czarnowski "/xyz/openbmc_project/object_mapper", 1137107077deSPrzemyslaw Czarnowski "xyz.openbmc_project.ObjectMapper", "GetObject", 113822db1728SEd Tanous "/xyz/openbmc_project/VirtualMedia", 113922db1728SEd Tanous std::array<const char*, 0>()); 114022db1728SEd Tanous }); 1141107077deSPrzemyslaw Czarnowski } 1142107077deSPrzemyslaw Czarnowski 1143107077deSPrzemyslaw Czarnowski } // namespace redfish 1144