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 */ 3422db1728SEd Tanous inline std::string getTransferProtocolTypeFromUri(const std::string& imageUri) 359e319cf0SAnna Platash { 36d32c4fa9SEd Tanous boost::urls::error_code ec; 37d32c4fa9SEd Tanous boost::urls::url_view url = 38d32c4fa9SEd Tanous boost::urls::parse_uri(boost::string_view(imageUri), ec); 39d32c4fa9SEd Tanous if (ec) 409e319cf0SAnna Platash { 41d32c4fa9SEd Tanous return "None"; 42d32c4fa9SEd Tanous } 43d32c4fa9SEd Tanous boost::string_view scheme = url.scheme(); 449e319cf0SAnna Platash if (scheme == "smb") 459e319cf0SAnna Platash { 469e319cf0SAnna Platash return "CIFS"; 479e319cf0SAnna Platash } 4822db1728SEd Tanous if (scheme == "https") 499e319cf0SAnna Platash { 509e319cf0SAnna Platash return "HTTPS"; 519e319cf0SAnna Platash } 52d32c4fa9SEd Tanous 539e319cf0SAnna Platash return "None"; 549e319cf0SAnna Platash } 55107077deSPrzemyslaw Czarnowski 56107077deSPrzemyslaw Czarnowski /** 57107077deSPrzemyslaw Czarnowski * @brief Read all known properties from VM object interfaces 58107077deSPrzemyslaw Czarnowski */ 5922db1728SEd Tanous inline void 60*711ac7a9SEd Tanous vmParseInterfaceObject(const dbus::utility::DBusInteracesMap& interface, 618d1b46d7Szhanghch05 const std::shared_ptr<bmcweb::AsyncResp>& aResp) 62107077deSPrzemyslaw Czarnowski { 63*711ac7a9SEd Tanous for (const auto& [interface, values] : interface) 64107077deSPrzemyslaw Czarnowski { 65*711ac7a9SEd Tanous if (interface == "xyz.openbmc_project.VirtualMedia.MountPoint") 66107077deSPrzemyslaw Czarnowski { 67*711ac7a9SEd Tanous for (const auto& [property, value] : values) 68107077deSPrzemyslaw Czarnowski { 69*711ac7a9SEd Tanous if (property == "EndpointId") 70107077deSPrzemyslaw Czarnowski { 71107077deSPrzemyslaw Czarnowski const std::string* endpointIdValue = 72*711ac7a9SEd Tanous std::get_if<std::string>(&value); 73*711ac7a9SEd Tanous if (endpointIdValue == nullptr) 74107077deSPrzemyslaw Czarnowski { 75*711ac7a9SEd Tanous continue; 76*711ac7a9SEd Tanous } 77107077deSPrzemyslaw Czarnowski if (!endpointIdValue->empty()) 78107077deSPrzemyslaw Czarnowski { 79107077deSPrzemyslaw Czarnowski // Proxy mode 80*711ac7a9SEd Tanous aResp->res 81*711ac7a9SEd Tanous .jsonValue["Oem"]["OpenBMC"]["WebSocketEndpoint"] = 82d04ba325SPrzemyslaw Czarnowski *endpointIdValue; 83107077deSPrzemyslaw Czarnowski aResp->res.jsonValue["TransferProtocolType"] = "OEM"; 84107077deSPrzemyslaw Czarnowski } 85107077deSPrzemyslaw Czarnowski } 86*711ac7a9SEd Tanous if (property == "ImageURL") 87107077deSPrzemyslaw Czarnowski { 88107077deSPrzemyslaw Czarnowski const std::string* imageUrlValue = 89*711ac7a9SEd Tanous std::get_if<std::string>(&value); 90107077deSPrzemyslaw Czarnowski if (imageUrlValue && !imageUrlValue->empty()) 91107077deSPrzemyslaw Czarnowski { 92da4784d8SPrzemyslaw Czarnowski std::filesystem::path filePath = *imageUrlValue; 93da4784d8SPrzemyslaw Czarnowski if (!filePath.has_filename()) 94da4784d8SPrzemyslaw Czarnowski { 959e319cf0SAnna Platash // this will handle https share, which not 969e319cf0SAnna Platash // necessarily has to have filename given. 97da4784d8SPrzemyslaw Czarnowski aResp->res.jsonValue["ImageName"] = ""; 98da4784d8SPrzemyslaw Czarnowski } 99da4784d8SPrzemyslaw Czarnowski else 100da4784d8SPrzemyslaw Czarnowski { 1019e319cf0SAnna Platash aResp->res.jsonValue["ImageName"] = 1029e319cf0SAnna Platash filePath.filename(); 103da4784d8SPrzemyslaw Czarnowski } 104da4784d8SPrzemyslaw Czarnowski 105da4784d8SPrzemyslaw Czarnowski aResp->res.jsonValue["Image"] = *imageUrlValue; 1069e319cf0SAnna Platash aResp->res.jsonValue["TransferProtocolType"] = 1079e319cf0SAnna Platash getTransferProtocolTypeFromUri(*imageUrlValue); 1089e319cf0SAnna Platash 109107077deSPrzemyslaw Czarnowski aResp->res.jsonValue["ConnectedVia"] = "URI"; 110107077deSPrzemyslaw Czarnowski } 111107077deSPrzemyslaw Czarnowski } 112*711ac7a9SEd Tanous if (property == "WriteProtected") 1139e319cf0SAnna Platash { 114*711ac7a9SEd Tanous const bool* writeProtectedValue = std::get_if<bool>(&value); 1159e319cf0SAnna Platash if (writeProtectedValue) 1169e319cf0SAnna Platash { 1179e319cf0SAnna Platash aResp->res.jsonValue["WriteProtected"] = 1189e319cf0SAnna Platash *writeProtectedValue; 1199e319cf0SAnna Platash } 1209e319cf0SAnna Platash } 1219e319cf0SAnna Platash } 122107077deSPrzemyslaw Czarnowski } 123*711ac7a9SEd Tanous if (interface == "xyz.openbmc_project.VirtualMedia.Process") 124*711ac7a9SEd Tanous { 125*711ac7a9SEd Tanous for (const auto& [property, value] : values) 126*711ac7a9SEd Tanous { 127*711ac7a9SEd Tanous if (property == "Active") 128*711ac7a9SEd Tanous { 129*711ac7a9SEd Tanous const bool* activeValue = std::get_if<bool>(&value); 130*711ac7a9SEd Tanous if (!activeValue) 131*711ac7a9SEd Tanous { 132*711ac7a9SEd Tanous BMCWEB_LOG_DEBUG << "Value Active not found"; 133*711ac7a9SEd Tanous return; 134*711ac7a9SEd Tanous } 135*711ac7a9SEd Tanous aResp->res.jsonValue["Inserted"] = *activeValue; 136*711ac7a9SEd Tanous 137*711ac7a9SEd Tanous if (*activeValue == true) 138*711ac7a9SEd Tanous { 139*711ac7a9SEd Tanous aResp->res.jsonValue["ConnectedVia"] = "Applet"; 140*711ac7a9SEd Tanous } 141*711ac7a9SEd Tanous } 142*711ac7a9SEd Tanous } 143*711ac7a9SEd Tanous } 144107077deSPrzemyslaw Czarnowski } 145107077deSPrzemyslaw Czarnowski } 146107077deSPrzemyslaw Czarnowski 147107077deSPrzemyslaw Czarnowski /** 148107077deSPrzemyslaw Czarnowski * @brief Fill template for Virtual Media Item. 149107077deSPrzemyslaw Czarnowski */ 15022db1728SEd Tanous inline nlohmann::json vmItemTemplate(const std::string& name, 151107077deSPrzemyslaw Czarnowski const std::string& resName) 152107077deSPrzemyslaw Czarnowski { 153107077deSPrzemyslaw Czarnowski nlohmann::json item; 15422db1728SEd Tanous 15522db1728SEd Tanous std::string id = "/redfish/v1/Managers/"; 15622db1728SEd Tanous id += name; 15722db1728SEd Tanous id += "/VirtualMedia/"; 15822db1728SEd Tanous id += resName; 15922db1728SEd Tanous item["@odata.id"] = std::move(id); 16022db1728SEd Tanous 161d04ba325SPrzemyslaw Czarnowski item["@odata.type"] = "#VirtualMedia.v1_3_0.VirtualMedia"; 162107077deSPrzemyslaw Czarnowski item["Name"] = "Virtual Removable Media"; 163107077deSPrzemyslaw Czarnowski item["Id"] = resName; 164107077deSPrzemyslaw Czarnowski item["WriteProtected"] = true; 165107077deSPrzemyslaw Czarnowski item["MediaTypes"] = {"CD", "USBStick"}; 166107077deSPrzemyslaw Czarnowski item["TransferMethod"] = "Stream"; 167d04ba325SPrzemyslaw Czarnowski item["Oem"]["OpenBMC"]["@odata.type"] = 168d04ba325SPrzemyslaw Czarnowski "#OemVirtualMedia.v1_0_0.VirtualMedia"; 169107077deSPrzemyslaw Czarnowski 170107077deSPrzemyslaw Czarnowski return item; 171107077deSPrzemyslaw Czarnowski } 172107077deSPrzemyslaw Czarnowski 173107077deSPrzemyslaw Czarnowski /** 174107077deSPrzemyslaw Czarnowski * @brief Fills collection data 175107077deSPrzemyslaw Czarnowski */ 17622db1728SEd Tanous inline void getVmResourceList(std::shared_ptr<bmcweb::AsyncResp> aResp, 177107077deSPrzemyslaw Czarnowski const std::string& service, 178107077deSPrzemyslaw Czarnowski const std::string& name) 179107077deSPrzemyslaw Czarnowski { 180107077deSPrzemyslaw Czarnowski BMCWEB_LOG_DEBUG << "Get available Virtual Media resources."; 181107077deSPrzemyslaw Czarnowski crow::connections::systemBus->async_method_call( 182*711ac7a9SEd Tanous [name, 183*711ac7a9SEd Tanous aResp{std::move(aResp)}](const boost::system::error_code ec, 184*711ac7a9SEd Tanous dbus::utility::ManagedObjectType& subtree) { 185107077deSPrzemyslaw Czarnowski if (ec) 186107077deSPrzemyslaw Czarnowski { 187107077deSPrzemyslaw Czarnowski BMCWEB_LOG_DEBUG << "DBUS response error"; 188107077deSPrzemyslaw Czarnowski return; 189107077deSPrzemyslaw Czarnowski } 190107077deSPrzemyslaw Czarnowski nlohmann::json& members = aResp->res.jsonValue["Members"]; 191107077deSPrzemyslaw Czarnowski members = nlohmann::json::array(); 192107077deSPrzemyslaw Czarnowski 193107077deSPrzemyslaw Czarnowski for (const auto& object : subtree) 194107077deSPrzemyslaw Czarnowski { 195107077deSPrzemyslaw Czarnowski nlohmann::json item; 1962dfd18efSEd Tanous std::string path = object.first.filename(); 1972dfd18efSEd Tanous if (path.empty()) 198107077deSPrzemyslaw Czarnowski { 199107077deSPrzemyslaw Czarnowski continue; 200107077deSPrzemyslaw Czarnowski } 201107077deSPrzemyslaw Czarnowski 20222db1728SEd Tanous std::string id = "/redfish/v1/Managers/"; 20322db1728SEd Tanous id += name; 20422db1728SEd Tanous id += "/VirtualMedia/"; 20522db1728SEd Tanous id += path; 206107077deSPrzemyslaw Czarnowski 20722db1728SEd Tanous item["@odata.id"] = std::move(id); 208107077deSPrzemyslaw Czarnowski members.emplace_back(std::move(item)); 209107077deSPrzemyslaw Czarnowski } 210107077deSPrzemyslaw Czarnowski aResp->res.jsonValue["Members@odata.count"] = members.size(); 211107077deSPrzemyslaw Czarnowski }, 212107077deSPrzemyslaw Czarnowski service, "/xyz/openbmc_project/VirtualMedia", 213107077deSPrzemyslaw Czarnowski "org.freedesktop.DBus.ObjectManager", "GetManagedObjects"); 214107077deSPrzemyslaw Czarnowski } 215107077deSPrzemyslaw Czarnowski 216107077deSPrzemyslaw Czarnowski /** 217107077deSPrzemyslaw Czarnowski * @brief Fills data for specific resource 218107077deSPrzemyslaw Czarnowski */ 21922db1728SEd Tanous inline void getVmData(const std::shared_ptr<bmcweb::AsyncResp>& aResp, 220107077deSPrzemyslaw Czarnowski const std::string& service, const std::string& name, 221107077deSPrzemyslaw Czarnowski const std::string& resName) 222107077deSPrzemyslaw Czarnowski { 223107077deSPrzemyslaw Czarnowski BMCWEB_LOG_DEBUG << "Get Virtual Media resource data."; 224107077deSPrzemyslaw Czarnowski 225107077deSPrzemyslaw Czarnowski crow::connections::systemBus->async_method_call( 226107077deSPrzemyslaw Czarnowski [resName, name, aResp](const boost::system::error_code ec, 227*711ac7a9SEd Tanous dbus::utility::ManagedObjectType& subtree) { 228107077deSPrzemyslaw Czarnowski if (ec) 229107077deSPrzemyslaw Czarnowski { 230107077deSPrzemyslaw Czarnowski BMCWEB_LOG_DEBUG << "DBUS response error"; 231e13c2760SPrzemyslaw Czarnowski 232107077deSPrzemyslaw Czarnowski return; 233107077deSPrzemyslaw Czarnowski } 234107077deSPrzemyslaw Czarnowski 235107077deSPrzemyslaw Czarnowski for (auto& item : subtree) 236107077deSPrzemyslaw Czarnowski { 2372dfd18efSEd Tanous std::string thispath = item.first.filename(); 2382dfd18efSEd Tanous if (thispath.empty()) 239107077deSPrzemyslaw Czarnowski { 240107077deSPrzemyslaw Czarnowski continue; 241107077deSPrzemyslaw Czarnowski } 242107077deSPrzemyslaw Czarnowski 2432dfd18efSEd Tanous if (thispath != resName) 244107077deSPrzemyslaw Czarnowski { 245107077deSPrzemyslaw Czarnowski continue; 246107077deSPrzemyslaw Czarnowski } 247107077deSPrzemyslaw Czarnowski 2481a6258dcSPrzemyslaw Czarnowski // "Legacy"/"Proxy" 2491a6258dcSPrzemyslaw Czarnowski auto mode = item.first.parent_path(); 2501a6258dcSPrzemyslaw Czarnowski // "VirtualMedia" 2511a6258dcSPrzemyslaw Czarnowski auto type = mode.parent_path(); 2521a6258dcSPrzemyslaw Czarnowski if (mode.filename().empty() || type.filename().empty()) 2531a6258dcSPrzemyslaw Czarnowski { 2541a6258dcSPrzemyslaw Czarnowski continue; 2551a6258dcSPrzemyslaw Czarnowski } 2561a6258dcSPrzemyslaw Czarnowski 2571a6258dcSPrzemyslaw Czarnowski if (type.filename() != "VirtualMedia") 2581a6258dcSPrzemyslaw Czarnowski { 2591a6258dcSPrzemyslaw Czarnowski continue; 2601a6258dcSPrzemyslaw Czarnowski } 2611a6258dcSPrzemyslaw Czarnowski 262107077deSPrzemyslaw Czarnowski aResp->res.jsonValue = vmItemTemplate(name, resName); 26322db1728SEd Tanous std::string actionsId = "/redfish/v1/Managers/"; 26422db1728SEd Tanous actionsId += name; 26522db1728SEd Tanous actionsId += "/VirtualMedia/"; 26622db1728SEd Tanous actionsId += resName; 26722db1728SEd Tanous actionsId += "/Actions"; 268107077deSPrzemyslaw Czarnowski 269e13c2760SPrzemyslaw Czarnowski // Check if dbus path is Legacy type 2701a6258dcSPrzemyslaw Czarnowski if (mode.filename() == "Legacy") 271e13c2760SPrzemyslaw Czarnowski { 272e13c2760SPrzemyslaw Czarnowski aResp->res.jsonValue["Actions"]["#VirtualMedia.InsertMedia"] 273e13c2760SPrzemyslaw Czarnowski ["target"] = 27422db1728SEd Tanous actionsId + "/VirtualMedia.InsertMedia"; 275e13c2760SPrzemyslaw Czarnowski } 276e13c2760SPrzemyslaw Czarnowski 277107077deSPrzemyslaw Czarnowski vmParseInterfaceObject(item.second, aResp); 278107077deSPrzemyslaw Czarnowski 279e13c2760SPrzemyslaw Czarnowski aResp->res.jsonValue["Actions"]["#VirtualMedia.EjectMedia"] 280e13c2760SPrzemyslaw Czarnowski ["target"] = 28122db1728SEd Tanous actionsId + "/VirtualMedia.EjectMedia"; 282e13c2760SPrzemyslaw Czarnowski 283107077deSPrzemyslaw Czarnowski return; 284107077deSPrzemyslaw Czarnowski } 285107077deSPrzemyslaw Czarnowski 286107077deSPrzemyslaw Czarnowski messages::resourceNotFound( 287d04ba325SPrzemyslaw Czarnowski aResp->res, "#VirtualMedia.v1_3_0.VirtualMedia", resName); 288107077deSPrzemyslaw Czarnowski }, 289107077deSPrzemyslaw Czarnowski service, "/xyz/openbmc_project/VirtualMedia", 290107077deSPrzemyslaw Czarnowski "org.freedesktop.DBus.ObjectManager", "GetManagedObjects"); 291107077deSPrzemyslaw Czarnowski } 292107077deSPrzemyslaw Czarnowski 293e13c2760SPrzemyslaw Czarnowski /** 294c6f4e017SAgata Olender * @brief Transfer protocols supported for InsertMedia action. 295c6f4e017SAgata Olender * 296c6f4e017SAgata Olender */ 297c6f4e017SAgata Olender enum class TransferProtocol 298c6f4e017SAgata Olender { 299c6f4e017SAgata Olender https, 300c6f4e017SAgata Olender smb, 301c6f4e017SAgata Olender invalid 302c6f4e017SAgata Olender }; 303c6f4e017SAgata Olender 304c6f4e017SAgata Olender /** 305c6f4e017SAgata Olender * @brief Function extracts transfer protocol type from URI. 306c6f4e017SAgata Olender * 307c6f4e017SAgata Olender */ 30822db1728SEd Tanous inline std::optional<TransferProtocol> 309c6f4e017SAgata Olender getTransferProtocolFromUri(const std::string& imageUri) 310c6f4e017SAgata Olender { 311d32c4fa9SEd Tanous boost::urls::error_code ec; 312d32c4fa9SEd Tanous boost::urls::url_view url = 313d32c4fa9SEd Tanous boost::urls::parse_uri(boost::string_view(imageUri), ec); 314d32c4fa9SEd Tanous if (ec) 3159e319cf0SAnna Platash { 316d32c4fa9SEd Tanous return {}; 317d32c4fa9SEd Tanous } 318d32c4fa9SEd Tanous 319d32c4fa9SEd Tanous boost::string_view scheme = url.scheme(); 3209e319cf0SAnna Platash if (scheme == "smb") 321c6f4e017SAgata Olender { 322c6f4e017SAgata Olender return TransferProtocol::smb; 323c6f4e017SAgata Olender } 32481ce609eSEd Tanous if (scheme == "https") 325c6f4e017SAgata Olender { 326c6f4e017SAgata Olender return TransferProtocol::https; 327c6f4e017SAgata Olender } 32822db1728SEd Tanous if (!scheme.empty()) 329c6f4e017SAgata Olender { 330c6f4e017SAgata Olender return TransferProtocol::invalid; 331c6f4e017SAgata Olender } 3329e319cf0SAnna Platash 3339e319cf0SAnna Platash return {}; 334c6f4e017SAgata Olender } 335c6f4e017SAgata Olender 336c6f4e017SAgata Olender /** 337c6f4e017SAgata Olender * @brief Function convert transfer protocol from string param. 338c6f4e017SAgata Olender * 339c6f4e017SAgata Olender */ 34022db1728SEd Tanous inline std::optional<TransferProtocol> getTransferProtocolFromParam( 341c6f4e017SAgata Olender const std::optional<std::string>& transferProtocolType) 342c6f4e017SAgata Olender { 343c6f4e017SAgata Olender if (transferProtocolType == std::nullopt) 344c6f4e017SAgata Olender { 345c6f4e017SAgata Olender return {}; 346c6f4e017SAgata Olender } 347c6f4e017SAgata Olender 348c6f4e017SAgata Olender if (*transferProtocolType == "CIFS") 349c6f4e017SAgata Olender { 350c6f4e017SAgata Olender return TransferProtocol::smb; 351c6f4e017SAgata Olender } 352c6f4e017SAgata Olender 353c6f4e017SAgata Olender if (*transferProtocolType == "HTTPS") 354c6f4e017SAgata Olender { 355c6f4e017SAgata Olender return TransferProtocol::https; 356c6f4e017SAgata Olender } 357c6f4e017SAgata Olender 358c6f4e017SAgata Olender return TransferProtocol::invalid; 359c6f4e017SAgata Olender } 360c6f4e017SAgata Olender 361c6f4e017SAgata Olender /** 362c6f4e017SAgata Olender * @brief Function extends URI with transfer protocol type. 363c6f4e017SAgata Olender * 364c6f4e017SAgata Olender */ 36522db1728SEd Tanous inline std::string 366c6f4e017SAgata Olender getUriWithTransferProtocol(const std::string& imageUri, 367c6f4e017SAgata Olender const TransferProtocol& transferProtocol) 368c6f4e017SAgata Olender { 369c6f4e017SAgata Olender if (transferProtocol == TransferProtocol::smb) 370c6f4e017SAgata Olender { 371c6f4e017SAgata Olender return "smb://" + imageUri; 372c6f4e017SAgata Olender } 373c6f4e017SAgata Olender 374c6f4e017SAgata Olender if (transferProtocol == TransferProtocol::https) 375c6f4e017SAgata Olender { 376c6f4e017SAgata Olender return "https://" + imageUri; 377c6f4e017SAgata Olender } 378c6f4e017SAgata Olender 379c6f4e017SAgata Olender return imageUri; 380c6f4e017SAgata Olender } 381c6f4e017SAgata Olender 382c6f4e017SAgata Olender /** 383c6f4e017SAgata Olender * @brief Function validate parameters of insert media request. 384c6f4e017SAgata Olender * 385c6f4e017SAgata Olender */ 38622db1728SEd Tanous inline bool 38722db1728SEd Tanous validateParams(crow::Response& res, std::string& imageUrl, 388c6f4e017SAgata Olender const std::optional<bool>& inserted, 389c6f4e017SAgata Olender const std::optional<std::string>& transferMethod, 390c6f4e017SAgata Olender const std::optional<std::string>& transferProtocolType) 391c6f4e017SAgata Olender { 392c6f4e017SAgata Olender BMCWEB_LOG_DEBUG << "Validation started"; 393c6f4e017SAgata Olender // required param imageUrl must not be empty 394c6f4e017SAgata Olender if (imageUrl.empty()) 395c6f4e017SAgata Olender { 396c6f4e017SAgata Olender BMCWEB_LOG_ERROR << "Request action parameter Image is empty."; 397c6f4e017SAgata Olender 39822db1728SEd Tanous messages::propertyValueFormatError(res, "<empty>", "Image"); 399c6f4e017SAgata Olender 400c6f4e017SAgata Olender return false; 401c6f4e017SAgata Olender } 402c6f4e017SAgata Olender 403c6f4e017SAgata Olender // optional param inserted must be true 404c6f4e017SAgata Olender if ((inserted != std::nullopt) && (*inserted != true)) 405c6f4e017SAgata Olender { 406c6f4e017SAgata Olender BMCWEB_LOG_ERROR 407c6f4e017SAgata Olender << "Request action optional parameter Inserted must be true."; 408c6f4e017SAgata Olender 40922db1728SEd Tanous messages::actionParameterNotSupported(res, "Inserted", "InsertMedia"); 410c6f4e017SAgata Olender 411c6f4e017SAgata Olender return false; 412c6f4e017SAgata Olender } 413c6f4e017SAgata Olender 414c6f4e017SAgata Olender // optional param transferMethod must be stream 415c6f4e017SAgata Olender if ((transferMethod != std::nullopt) && (*transferMethod != "Stream")) 416c6f4e017SAgata Olender { 417c6f4e017SAgata Olender BMCWEB_LOG_ERROR << "Request action optional parameter " 418c6f4e017SAgata Olender "TransferMethod must be Stream."; 419c6f4e017SAgata Olender 42022db1728SEd Tanous messages::actionParameterNotSupported(res, "TransferMethod", 42122db1728SEd Tanous "InsertMedia"); 422c6f4e017SAgata Olender 423c6f4e017SAgata Olender return false; 424c6f4e017SAgata Olender } 425c6f4e017SAgata Olender 426c6f4e017SAgata Olender std::optional<TransferProtocol> uriTransferProtocolType = 427c6f4e017SAgata Olender getTransferProtocolFromUri(imageUrl); 428c6f4e017SAgata Olender 429c6f4e017SAgata Olender std::optional<TransferProtocol> paramTransferProtocolType = 430c6f4e017SAgata Olender getTransferProtocolFromParam(transferProtocolType); 431c6f4e017SAgata Olender 432c6f4e017SAgata Olender // ImageUrl does not contain valid protocol type 433c6f4e017SAgata Olender if (*uriTransferProtocolType == TransferProtocol::invalid) 434c6f4e017SAgata Olender { 435c6f4e017SAgata Olender BMCWEB_LOG_ERROR << "Request action parameter ImageUrl must " 436c6f4e017SAgata Olender "contain specified protocol type from list: " 437c6f4e017SAgata Olender "(smb, https)."; 438c6f4e017SAgata Olender 43922db1728SEd Tanous messages::resourceAtUriInUnknownFormat(res, imageUrl); 440c6f4e017SAgata Olender 441c6f4e017SAgata Olender return false; 442c6f4e017SAgata Olender } 443c6f4e017SAgata Olender 444c6f4e017SAgata Olender // transferProtocolType should contain value from list 445c6f4e017SAgata Olender if (*paramTransferProtocolType == TransferProtocol::invalid) 446c6f4e017SAgata Olender { 447c6f4e017SAgata Olender BMCWEB_LOG_ERROR << "Request action parameter TransferProtocolType " 448c6f4e017SAgata Olender "must be provided with value from list: " 449c6f4e017SAgata Olender "(CIFS, HTTPS)."; 450c6f4e017SAgata Olender 45122db1728SEd Tanous messages::propertyValueNotInList(res, *transferProtocolType, 45222db1728SEd Tanous "TransferProtocolType"); 453c6f4e017SAgata Olender return false; 454c6f4e017SAgata Olender } 455c6f4e017SAgata Olender 456c6f4e017SAgata Olender // valid transfer protocol not provided either with URI nor param 457c6f4e017SAgata Olender if ((uriTransferProtocolType == std::nullopt) && 458c6f4e017SAgata Olender (paramTransferProtocolType == std::nullopt)) 459c6f4e017SAgata Olender { 460c6f4e017SAgata Olender BMCWEB_LOG_ERROR << "Request action parameter ImageUrl must " 461c6f4e017SAgata Olender "contain specified protocol type or param " 462c6f4e017SAgata Olender "TransferProtocolType must be provided."; 463c6f4e017SAgata Olender 46422db1728SEd Tanous messages::resourceAtUriInUnknownFormat(res, imageUrl); 465c6f4e017SAgata Olender 466c6f4e017SAgata Olender return false; 467c6f4e017SAgata Olender } 468c6f4e017SAgata Olender 469c6f4e017SAgata Olender // valid transfer protocol provided both with URI and param 470c6f4e017SAgata Olender if ((paramTransferProtocolType != std::nullopt) && 471c6f4e017SAgata Olender (uriTransferProtocolType != std::nullopt)) 472c6f4e017SAgata Olender { 473c6f4e017SAgata Olender // check if protocol is the same for URI and param 474c6f4e017SAgata Olender if (*paramTransferProtocolType != *uriTransferProtocolType) 475c6f4e017SAgata Olender { 476c6f4e017SAgata Olender BMCWEB_LOG_ERROR << "Request action parameter " 477c6f4e017SAgata Olender "TransferProtocolType must contain the " 478c6f4e017SAgata Olender "same protocol type as protocol type " 479c6f4e017SAgata Olender "provided with param imageUrl."; 480c6f4e017SAgata Olender 48122db1728SEd Tanous messages::actionParameterValueTypeError(res, *transferProtocolType, 48222db1728SEd Tanous "TransferProtocolType", 48322db1728SEd Tanous "InsertMedia"); 484c6f4e017SAgata Olender 485c6f4e017SAgata Olender return false; 486c6f4e017SAgata Olender } 487c6f4e017SAgata Olender } 488c6f4e017SAgata Olender 489c6f4e017SAgata Olender // validation passed 490c6f4e017SAgata Olender // add protocol to URI if needed 491c6f4e017SAgata Olender if (uriTransferProtocolType == std::nullopt) 492c6f4e017SAgata Olender { 49322db1728SEd Tanous imageUrl = 49422db1728SEd Tanous getUriWithTransferProtocol(imageUrl, *paramTransferProtocolType); 495c6f4e017SAgata Olender } 496c6f4e017SAgata Olender 497c6f4e017SAgata Olender return true; 498c6f4e017SAgata Olender } 499c6f4e017SAgata Olender 5001214b7e7SGunnar Mills template <typename T> 5011214b7e7SGunnar Mills static void secureCleanup(T& value) 502988fb7b2SAdrian Ambrożewicz { 503988fb7b2SAdrian Ambrożewicz auto raw = const_cast<typename T::value_type*>(value.data()); 504988fb7b2SAdrian Ambrożewicz explicit_bzero(raw, value.size() * sizeof(*raw)); 505988fb7b2SAdrian Ambrożewicz } 506988fb7b2SAdrian Ambrożewicz 507988fb7b2SAdrian Ambrożewicz class Credentials 508988fb7b2SAdrian Ambrożewicz { 509988fb7b2SAdrian Ambrożewicz public: 510988fb7b2SAdrian Ambrożewicz Credentials(std::string&& user, std::string&& password) : 511988fb7b2SAdrian Ambrożewicz userBuf(std::move(user)), passBuf(std::move(password)) 5121214b7e7SGunnar Mills {} 513988fb7b2SAdrian Ambrożewicz 514988fb7b2SAdrian Ambrożewicz ~Credentials() 515988fb7b2SAdrian Ambrożewicz { 516988fb7b2SAdrian Ambrożewicz secureCleanup(userBuf); 517988fb7b2SAdrian Ambrożewicz secureCleanup(passBuf); 518988fb7b2SAdrian Ambrożewicz } 519988fb7b2SAdrian Ambrożewicz 520988fb7b2SAdrian Ambrożewicz const std::string& user() 521988fb7b2SAdrian Ambrożewicz { 522988fb7b2SAdrian Ambrożewicz return userBuf; 523988fb7b2SAdrian Ambrożewicz } 524988fb7b2SAdrian Ambrożewicz 525988fb7b2SAdrian Ambrożewicz const std::string& password() 526988fb7b2SAdrian Ambrożewicz { 527988fb7b2SAdrian Ambrożewicz return passBuf; 528988fb7b2SAdrian Ambrożewicz } 529988fb7b2SAdrian Ambrożewicz 530988fb7b2SAdrian Ambrożewicz Credentials() = delete; 531988fb7b2SAdrian Ambrożewicz Credentials(const Credentials&) = delete; 532988fb7b2SAdrian Ambrożewicz Credentials& operator=(const Credentials&) = delete; 533988fb7b2SAdrian Ambrożewicz 53422db1728SEd Tanous private: 535988fb7b2SAdrian Ambrożewicz std::string userBuf; 536988fb7b2SAdrian Ambrożewicz std::string passBuf; 537988fb7b2SAdrian Ambrożewicz }; 538988fb7b2SAdrian Ambrożewicz 539988fb7b2SAdrian Ambrożewicz class CredentialsProvider 540988fb7b2SAdrian Ambrożewicz { 541988fb7b2SAdrian Ambrożewicz public: 5421214b7e7SGunnar Mills template <typename T> 5431214b7e7SGunnar Mills struct Deleter 544988fb7b2SAdrian Ambrożewicz { 545988fb7b2SAdrian Ambrożewicz void operator()(T* buff) const 546988fb7b2SAdrian Ambrożewicz { 547988fb7b2SAdrian Ambrożewicz if (buff) 548988fb7b2SAdrian Ambrożewicz { 549988fb7b2SAdrian Ambrożewicz secureCleanup(*buff); 550988fb7b2SAdrian Ambrożewicz delete buff; 551988fb7b2SAdrian Ambrożewicz } 552988fb7b2SAdrian Ambrożewicz } 553988fb7b2SAdrian Ambrożewicz }; 554988fb7b2SAdrian Ambrożewicz 555988fb7b2SAdrian Ambrożewicz using Buffer = std::vector<char>; 556988fb7b2SAdrian Ambrożewicz using SecureBuffer = std::unique_ptr<Buffer, Deleter<Buffer>>; 557988fb7b2SAdrian Ambrożewicz // Using explicit definition instead of std::function to avoid implicit 558988fb7b2SAdrian Ambrożewicz // conversions eg. stack copy instead of reference 559988fb7b2SAdrian Ambrożewicz using FormatterFunc = void(const std::string& username, 560988fb7b2SAdrian Ambrożewicz const std::string& password, Buffer& dest); 561988fb7b2SAdrian Ambrożewicz 562988fb7b2SAdrian Ambrożewicz CredentialsProvider(std::string&& user, std::string&& password) : 563988fb7b2SAdrian Ambrożewicz credentials(std::move(user), std::move(password)) 5641214b7e7SGunnar Mills {} 565988fb7b2SAdrian Ambrożewicz 566988fb7b2SAdrian Ambrożewicz const std::string& user() 567988fb7b2SAdrian Ambrożewicz { 568988fb7b2SAdrian Ambrożewicz return credentials.user(); 569988fb7b2SAdrian Ambrożewicz } 570988fb7b2SAdrian Ambrożewicz 571988fb7b2SAdrian Ambrożewicz const std::string& password() 572988fb7b2SAdrian Ambrożewicz { 573988fb7b2SAdrian Ambrożewicz return credentials.password(); 574988fb7b2SAdrian Ambrożewicz } 575988fb7b2SAdrian Ambrożewicz 57681ce609eSEd Tanous SecureBuffer pack(FormatterFunc formatter) 577988fb7b2SAdrian Ambrożewicz { 578988fb7b2SAdrian Ambrożewicz SecureBuffer packed{new Buffer{}}; 579988fb7b2SAdrian Ambrożewicz if (formatter) 580988fb7b2SAdrian Ambrożewicz { 581988fb7b2SAdrian Ambrożewicz formatter(credentials.user(), credentials.password(), *packed); 582988fb7b2SAdrian Ambrożewicz } 583988fb7b2SAdrian Ambrożewicz 584988fb7b2SAdrian Ambrożewicz return packed; 585988fb7b2SAdrian Ambrożewicz } 586988fb7b2SAdrian Ambrożewicz 587988fb7b2SAdrian Ambrożewicz private: 588988fb7b2SAdrian Ambrożewicz Credentials credentials; 589988fb7b2SAdrian Ambrożewicz }; 590988fb7b2SAdrian Ambrożewicz 591988fb7b2SAdrian Ambrożewicz // Wrapper for boost::async_pipe ensuring proper pipe cleanup 5921214b7e7SGunnar Mills template <typename Buffer> 5931214b7e7SGunnar Mills class Pipe 594988fb7b2SAdrian Ambrożewicz { 595988fb7b2SAdrian Ambrożewicz public: 596988fb7b2SAdrian Ambrożewicz using unix_fd = sdbusplus::message::unix_fd; 597988fb7b2SAdrian Ambrożewicz 598988fb7b2SAdrian Ambrożewicz Pipe(boost::asio::io_context& io, Buffer&& buffer) : 599988fb7b2SAdrian Ambrożewicz impl(io), buffer{std::move(buffer)} 6001214b7e7SGunnar Mills {} 601988fb7b2SAdrian Ambrożewicz 602988fb7b2SAdrian Ambrożewicz ~Pipe() 603988fb7b2SAdrian Ambrożewicz { 604988fb7b2SAdrian Ambrożewicz // Named pipe needs to be explicitly removed 605988fb7b2SAdrian Ambrożewicz impl.close(); 606988fb7b2SAdrian Ambrożewicz } 607988fb7b2SAdrian Ambrożewicz 608988fb7b2SAdrian Ambrożewicz unix_fd fd() 609988fb7b2SAdrian Ambrożewicz { 610988fb7b2SAdrian Ambrożewicz return unix_fd{impl.native_source()}; 611988fb7b2SAdrian Ambrożewicz } 612988fb7b2SAdrian Ambrożewicz 613988fb7b2SAdrian Ambrożewicz template <typename WriteHandler> 61481ce609eSEd Tanous void asyncWrite(WriteHandler&& handler) 615988fb7b2SAdrian Ambrożewicz { 616988fb7b2SAdrian Ambrożewicz impl.async_write_some(data(), std::forward<WriteHandler>(handler)); 617988fb7b2SAdrian Ambrożewicz } 618988fb7b2SAdrian Ambrożewicz 619988fb7b2SAdrian Ambrożewicz private: 620988fb7b2SAdrian Ambrożewicz // Specialization for pointer types 621988fb7b2SAdrian Ambrożewicz template <typename B = Buffer> 622988fb7b2SAdrian Ambrożewicz typename std::enable_if<boost::has_dereference<B>::value, 623988fb7b2SAdrian Ambrożewicz boost::asio::const_buffer>::type 624988fb7b2SAdrian Ambrożewicz data() 625988fb7b2SAdrian Ambrożewicz { 626988fb7b2SAdrian Ambrożewicz return boost::asio::buffer(*buffer); 627988fb7b2SAdrian Ambrożewicz } 628988fb7b2SAdrian Ambrożewicz 629988fb7b2SAdrian Ambrożewicz template <typename B = Buffer> 630988fb7b2SAdrian Ambrożewicz typename std::enable_if<!boost::has_dereference<B>::value, 631988fb7b2SAdrian Ambrożewicz boost::asio::const_buffer>::type 632988fb7b2SAdrian Ambrożewicz data() 633988fb7b2SAdrian Ambrożewicz { 634988fb7b2SAdrian Ambrożewicz return boost::asio::buffer(buffer); 635988fb7b2SAdrian Ambrożewicz } 636988fb7b2SAdrian Ambrożewicz 637988fb7b2SAdrian Ambrożewicz const std::string name; 638988fb7b2SAdrian Ambrożewicz boost::process::async_pipe impl; 639988fb7b2SAdrian Ambrożewicz Buffer buffer; 640988fb7b2SAdrian Ambrożewicz }; 641988fb7b2SAdrian Ambrożewicz 642e13c2760SPrzemyslaw Czarnowski /** 643e13c2760SPrzemyslaw Czarnowski * @brief Function transceives data with dbus directly. 644e13c2760SPrzemyslaw Czarnowski * 645e13c2760SPrzemyslaw Czarnowski * All BMC state properties will be retrieved before sending reset request. 646e13c2760SPrzemyslaw Czarnowski */ 64722db1728SEd Tanous inline void doMountVmLegacy(const std::shared_ptr<bmcweb::AsyncResp>& asyncResp, 648e13c2760SPrzemyslaw Czarnowski const std::string& service, const std::string& name, 649988fb7b2SAdrian Ambrożewicz const std::string& imageUrl, const bool rw, 650988fb7b2SAdrian Ambrożewicz std::string&& userName, std::string&& password) 651e13c2760SPrzemyslaw Czarnowski { 652988fb7b2SAdrian Ambrożewicz using SecurePipe = Pipe<CredentialsProvider::SecureBuffer>; 653988fb7b2SAdrian Ambrożewicz constexpr const size_t secretLimit = 1024; 654988fb7b2SAdrian Ambrożewicz 655988fb7b2SAdrian Ambrożewicz std::shared_ptr<SecurePipe> secretPipe; 656168e20c1SEd Tanous dbus::utility::DbusVariantType unixFd = -1; 657988fb7b2SAdrian Ambrożewicz 658988fb7b2SAdrian Ambrożewicz if (!userName.empty() || !password.empty()) 659988fb7b2SAdrian Ambrożewicz { 660988fb7b2SAdrian Ambrożewicz // Encapsulate in safe buffer 661988fb7b2SAdrian Ambrożewicz CredentialsProvider credentials(std::move(userName), 662988fb7b2SAdrian Ambrożewicz std::move(password)); 663988fb7b2SAdrian Ambrożewicz 664988fb7b2SAdrian Ambrożewicz // Payload must contain data + NULL delimiters 665988fb7b2SAdrian Ambrożewicz if (credentials.user().size() + credentials.password().size() + 2 > 666988fb7b2SAdrian Ambrożewicz secretLimit) 667988fb7b2SAdrian Ambrożewicz { 668988fb7b2SAdrian Ambrożewicz BMCWEB_LOG_ERROR << "Credentials too long to handle"; 669988fb7b2SAdrian Ambrożewicz messages::unrecognizedRequestBody(asyncResp->res); 670988fb7b2SAdrian Ambrożewicz return; 671988fb7b2SAdrian Ambrożewicz } 672988fb7b2SAdrian Ambrożewicz 673988fb7b2SAdrian Ambrożewicz // Pack secret 67422db1728SEd Tanous auto secret = credentials.pack( 67522db1728SEd Tanous [](const auto& user, const auto& pass, auto& buff) { 676988fb7b2SAdrian Ambrożewicz std::copy(user.begin(), user.end(), std::back_inserter(buff)); 677988fb7b2SAdrian Ambrożewicz buff.push_back('\0'); 678988fb7b2SAdrian Ambrożewicz std::copy(pass.begin(), pass.end(), std::back_inserter(buff)); 679988fb7b2SAdrian Ambrożewicz buff.push_back('\0'); 680988fb7b2SAdrian Ambrożewicz }); 681988fb7b2SAdrian Ambrożewicz 682988fb7b2SAdrian Ambrożewicz // Open pipe 683988fb7b2SAdrian Ambrożewicz secretPipe = std::make_shared<SecurePipe>( 68422db1728SEd Tanous crow::connections::systemBus->get_io_context(), std::move(secret)); 685988fb7b2SAdrian Ambrożewicz unixFd = secretPipe->fd(); 686988fb7b2SAdrian Ambrożewicz 687988fb7b2SAdrian Ambrożewicz // Pass secret over pipe 68881ce609eSEd Tanous secretPipe->asyncWrite( 689f5b16f03SVikram Bodireddy [asyncResp](const boost::system::error_code& ec, std::size_t) { 690988fb7b2SAdrian Ambrożewicz if (ec) 691988fb7b2SAdrian Ambrożewicz { 692988fb7b2SAdrian Ambrożewicz BMCWEB_LOG_ERROR << "Failed to pass secret: " << ec; 693988fb7b2SAdrian Ambrożewicz messages::internalError(asyncResp->res); 694988fb7b2SAdrian Ambrożewicz } 695988fb7b2SAdrian Ambrożewicz }); 696988fb7b2SAdrian Ambrożewicz } 697988fb7b2SAdrian Ambrożewicz 698e13c2760SPrzemyslaw Czarnowski crow::connections::systemBus->async_method_call( 699988fb7b2SAdrian Ambrożewicz [asyncResp, secretPipe](const boost::system::error_code ec, 700988fb7b2SAdrian Ambrożewicz bool success) { 701e13c2760SPrzemyslaw Czarnowski if (ec) 702e13c2760SPrzemyslaw Czarnowski { 703e13c2760SPrzemyslaw Czarnowski BMCWEB_LOG_ERROR << "Bad D-Bus request error: " << ec; 704e13c2760SPrzemyslaw Czarnowski messages::internalError(asyncResp->res); 705d6da5bebSAdrian Ambrożewicz } 706d6da5bebSAdrian Ambrożewicz else if (!success) 707d6da5bebSAdrian Ambrożewicz { 708d6da5bebSAdrian Ambrożewicz BMCWEB_LOG_ERROR << "Service responded with error"; 709d6da5bebSAdrian Ambrożewicz messages::generalError(asyncResp->res); 710e13c2760SPrzemyslaw Czarnowski } 711e13c2760SPrzemyslaw Czarnowski }, 712e13c2760SPrzemyslaw Czarnowski service, "/xyz/openbmc_project/VirtualMedia/Legacy/" + name, 713988fb7b2SAdrian Ambrożewicz "xyz.openbmc_project.VirtualMedia.Legacy", "Mount", imageUrl, rw, 714988fb7b2SAdrian Ambrożewicz unixFd); 715e13c2760SPrzemyslaw Czarnowski } 716e13c2760SPrzemyslaw Czarnowski 717e13c2760SPrzemyslaw Czarnowski /** 718e13c2760SPrzemyslaw Czarnowski * @brief Function transceives data with dbus directly. 719e13c2760SPrzemyslaw Czarnowski * 720e13c2760SPrzemyslaw Czarnowski * All BMC state properties will be retrieved before sending reset request. 721e13c2760SPrzemyslaw Czarnowski */ 72222db1728SEd Tanous inline void doVmAction(const std::shared_ptr<bmcweb::AsyncResp>& asyncResp, 723e13c2760SPrzemyslaw Czarnowski const std::string& service, const std::string& name, 724e13c2760SPrzemyslaw Czarnowski bool legacy) 725e13c2760SPrzemyslaw Czarnowski { 726e13c2760SPrzemyslaw Czarnowski 727e13c2760SPrzemyslaw Czarnowski // Legacy mount requires parameter with image 728e13c2760SPrzemyslaw Czarnowski if (legacy) 729e13c2760SPrzemyslaw Czarnowski { 730e13c2760SPrzemyslaw Czarnowski crow::connections::systemBus->async_method_call( 731e13c2760SPrzemyslaw Czarnowski [asyncResp](const boost::system::error_code ec) { 732e13c2760SPrzemyslaw Czarnowski if (ec) 733e13c2760SPrzemyslaw Czarnowski { 734e13c2760SPrzemyslaw Czarnowski BMCWEB_LOG_ERROR << "Bad D-Bus request error: " << ec; 735e13c2760SPrzemyslaw Czarnowski 736e13c2760SPrzemyslaw Czarnowski messages::internalError(asyncResp->res); 737e13c2760SPrzemyslaw Czarnowski return; 738e13c2760SPrzemyslaw Czarnowski } 739e13c2760SPrzemyslaw Czarnowski }, 740e13c2760SPrzemyslaw Czarnowski service, "/xyz/openbmc_project/VirtualMedia/Legacy/" + name, 741e13c2760SPrzemyslaw Czarnowski "xyz.openbmc_project.VirtualMedia.Legacy", "Unmount"); 742e13c2760SPrzemyslaw Czarnowski } 743e13c2760SPrzemyslaw Czarnowski else // proxy 744e13c2760SPrzemyslaw Czarnowski { 745e13c2760SPrzemyslaw Czarnowski crow::connections::systemBus->async_method_call( 746e13c2760SPrzemyslaw Czarnowski [asyncResp](const boost::system::error_code ec) { 747e13c2760SPrzemyslaw Czarnowski if (ec) 748e13c2760SPrzemyslaw Czarnowski { 749e13c2760SPrzemyslaw Czarnowski BMCWEB_LOG_ERROR << "Bad D-Bus request error: " << ec; 750e13c2760SPrzemyslaw Czarnowski 751e13c2760SPrzemyslaw Czarnowski messages::internalError(asyncResp->res); 752e13c2760SPrzemyslaw Czarnowski return; 753e13c2760SPrzemyslaw Czarnowski } 754e13c2760SPrzemyslaw Czarnowski }, 755e13c2760SPrzemyslaw Czarnowski service, "/xyz/openbmc_project/VirtualMedia/Proxy/" + name, 756e13c2760SPrzemyslaw Czarnowski "xyz.openbmc_project.VirtualMedia.Proxy", "Unmount"); 757e13c2760SPrzemyslaw Czarnowski } 758e13c2760SPrzemyslaw Czarnowski } 759e13c2760SPrzemyslaw Czarnowski 76098be3e39SEd Tanous struct InsertMediaActionParams 76198be3e39SEd Tanous { 76298be3e39SEd Tanous std::string imageUrl; 76398be3e39SEd Tanous std::optional<std::string> userName; 76498be3e39SEd Tanous std::optional<std::string> password; 76598be3e39SEd Tanous std::optional<std::string> transferMethod; 76698be3e39SEd Tanous std::optional<std::string> transferProtocolType; 76798be3e39SEd Tanous std::optional<bool> writeProtected = true; 76898be3e39SEd Tanous std::optional<bool> inserted; 76998be3e39SEd Tanous }; 77098be3e39SEd Tanous 77122db1728SEd Tanous inline void requestNBDVirtualMediaRoutes(App& app) 772107077deSPrzemyslaw Czarnowski { 7730fda0f12SGeorge Liu BMCWEB_ROUTE( 7740fda0f12SGeorge Liu app, 7750fda0f12SGeorge Liu "/redfish/v1/Managers/<str>/VirtualMedia/<str>/Actions/VirtualMedia.InsertMedia") 776ed398213SEd Tanous .privileges(redfish::privileges::postVirtualMedia) 77722db1728SEd Tanous .methods(boost::beast::http::verb::post)( 77822db1728SEd Tanous [](const crow::Request& req, 77922db1728SEd Tanous const std::shared_ptr<bmcweb::AsyncResp>& asyncResp, 78022db1728SEd Tanous const std::string& name, const std::string& resName) { 78122db1728SEd Tanous if (name != "bmc") 782107077deSPrzemyslaw Czarnowski { 78322db1728SEd Tanous messages::resourceNotFound(asyncResp->res, 78422db1728SEd Tanous "VirtualMedia.Insert", resName); 785107077deSPrzemyslaw Czarnowski 786107077deSPrzemyslaw Czarnowski return; 787107077deSPrzemyslaw Czarnowski } 78898be3e39SEd Tanous InsertMediaActionParams actionParams; 78998be3e39SEd Tanous 79098be3e39SEd Tanous // Read obligatory parameters (url of 79198be3e39SEd Tanous // image) 79298be3e39SEd Tanous if (!json_util::readJson( 79398be3e39SEd Tanous req, asyncResp->res, "Image", actionParams.imageUrl, 79498be3e39SEd Tanous "WriteProtected", actionParams.writeProtected, 79598be3e39SEd Tanous "UserName", actionParams.userName, "Password", 79698be3e39SEd Tanous actionParams.password, "Inserted", 79798be3e39SEd Tanous actionParams.inserted, "TransferMethod", 79898be3e39SEd Tanous actionParams.transferMethod, "TransferProtocolType", 79998be3e39SEd Tanous actionParams.transferProtocolType)) 80098be3e39SEd Tanous { 80198be3e39SEd Tanous BMCWEB_LOG_DEBUG << "Image is not provided"; 80298be3e39SEd Tanous return; 80398be3e39SEd Tanous } 80498be3e39SEd Tanous 80598be3e39SEd Tanous bool paramsValid = validateParams( 80698be3e39SEd Tanous asyncResp->res, actionParams.imageUrl, 80798be3e39SEd Tanous actionParams.inserted, actionParams.transferMethod, 80898be3e39SEd Tanous actionParams.transferProtocolType); 80998be3e39SEd Tanous 81098be3e39SEd Tanous if (paramsValid == false) 81198be3e39SEd Tanous { 81298be3e39SEd Tanous return; 81398be3e39SEd Tanous } 814107077deSPrzemyslaw Czarnowski 81522db1728SEd Tanous crow::connections::systemBus->async_method_call( 81698be3e39SEd Tanous [asyncResp, actionParams, 81722db1728SEd Tanous resName](const boost::system::error_code ec, 81898be3e39SEd Tanous const GetObjectType& getObjectType) mutable { 81922db1728SEd Tanous if (ec) 82022db1728SEd Tanous { 82122db1728SEd Tanous BMCWEB_LOG_ERROR 82222db1728SEd Tanous << "ObjectMapper::GetObject call failed: " 82322db1728SEd Tanous << ec; 82422db1728SEd Tanous messages::internalError(asyncResp->res); 825107077deSPrzemyslaw Czarnowski 82622db1728SEd Tanous return; 82722db1728SEd Tanous } 82822db1728SEd Tanous std::string service = getObjectType.begin()->first; 82922db1728SEd Tanous BMCWEB_LOG_DEBUG << "GetObjectType: " << service; 83022db1728SEd Tanous 83122db1728SEd Tanous crow::connections::systemBus->async_method_call( 83298be3e39SEd Tanous [service, resName, actionParams, 83322db1728SEd Tanous asyncResp](const boost::system::error_code ec, 834*711ac7a9SEd Tanous dbus::utility::ManagedObjectType& 835*711ac7a9SEd Tanous subtree) mutable { 83622db1728SEd Tanous if (ec) 83722db1728SEd Tanous { 83822db1728SEd Tanous BMCWEB_LOG_DEBUG << "DBUS response error"; 83922db1728SEd Tanous 84022db1728SEd Tanous return; 84122db1728SEd Tanous } 84222db1728SEd Tanous 84322db1728SEd Tanous for (const auto& object : subtree) 84422db1728SEd Tanous { 84522db1728SEd Tanous const std::string& path = 84622db1728SEd Tanous static_cast<const std::string&>( 84722db1728SEd Tanous object.first); 84822db1728SEd Tanous 84922db1728SEd Tanous std::size_t lastIndex = path.rfind('/'); 85022db1728SEd Tanous if (lastIndex == std::string::npos) 85122db1728SEd Tanous { 85222db1728SEd Tanous continue; 85322db1728SEd Tanous } 85422db1728SEd Tanous 85522db1728SEd Tanous lastIndex += 1; 85622db1728SEd Tanous 85722db1728SEd Tanous if (path.substr(lastIndex) == resName) 85822db1728SEd Tanous { 85922db1728SEd Tanous lastIndex = path.rfind("Proxy"); 86022db1728SEd Tanous if (lastIndex != std::string::npos) 86122db1728SEd Tanous { 86222db1728SEd Tanous // Not possible in proxy mode 86322db1728SEd Tanous BMCWEB_LOG_DEBUG 86422db1728SEd Tanous << "InsertMedia not " 86522db1728SEd Tanous "allowed in proxy mode"; 86622db1728SEd Tanous messages::resourceNotFound( 86722db1728SEd Tanous asyncResp->res, 86822db1728SEd Tanous "VirtualMedia.InsertMedia", 86922db1728SEd Tanous resName); 87022db1728SEd Tanous 87122db1728SEd Tanous return; 87222db1728SEd Tanous } 87322db1728SEd Tanous 87422db1728SEd Tanous lastIndex = path.rfind("Legacy"); 87522db1728SEd Tanous if (lastIndex == std::string::npos) 87622db1728SEd Tanous { 87722db1728SEd Tanous continue; 87822db1728SEd Tanous } 87922db1728SEd Tanous 88022db1728SEd Tanous // manager is irrelevant for 88122db1728SEd Tanous // VirtualMedia dbus calls 88298be3e39SEd Tanous doMountVmLegacy( 88398be3e39SEd Tanous asyncResp, service, resName, 88498be3e39SEd Tanous actionParams.imageUrl, 88598be3e39SEd Tanous !(*actionParams.writeProtected), 88698be3e39SEd Tanous std::move(*actionParams.userName), 88798be3e39SEd Tanous std::move(*actionParams.password)); 88822db1728SEd Tanous 88922db1728SEd Tanous return; 89022db1728SEd Tanous } 89122db1728SEd Tanous } 89222db1728SEd Tanous BMCWEB_LOG_DEBUG << "Parent item not found"; 89322db1728SEd Tanous messages::resourceNotFound( 89422db1728SEd Tanous asyncResp->res, "VirtualMedia", resName); 89522db1728SEd Tanous }, 89622db1728SEd Tanous service, "/xyz/openbmc_project/VirtualMedia", 89722db1728SEd Tanous "org.freedesktop.DBus.ObjectManager", 89822db1728SEd Tanous "GetManagedObjects"); 89922db1728SEd Tanous }, 90022db1728SEd Tanous "xyz.openbmc_project.ObjectMapper", 90122db1728SEd Tanous "/xyz/openbmc_project/object_mapper", 90222db1728SEd Tanous "xyz.openbmc_project.ObjectMapper", "GetObject", 90322db1728SEd Tanous "/xyz/openbmc_project/VirtualMedia", 90422db1728SEd Tanous std::array<const char*, 0>()); 90522db1728SEd Tanous }); 90622db1728SEd Tanous 9070fda0f12SGeorge Liu BMCWEB_ROUTE( 9080fda0f12SGeorge Liu app, 9090fda0f12SGeorge Liu "/redfish/v1/Managers/<str>/VirtualMedia/<str>/Actions/VirtualMedia.EjectMedia") 910ed398213SEd Tanous .privileges(redfish::privileges::postVirtualMedia) 91122db1728SEd Tanous .methods(boost::beast::http::verb::post)( 91298be3e39SEd Tanous [](const crow::Request&, 91322db1728SEd Tanous const std::shared_ptr<bmcweb::AsyncResp>& asyncResp, 91422db1728SEd Tanous const std::string& name, const std::string& resName) { 915107077deSPrzemyslaw Czarnowski if (name != "bmc") 916107077deSPrzemyslaw Czarnowski { 91722db1728SEd Tanous messages::resourceNotFound(asyncResp->res, 91822db1728SEd Tanous "VirtualMedia.Eject", resName); 91922db1728SEd Tanous 92022db1728SEd Tanous return; 92122db1728SEd Tanous } 92222db1728SEd Tanous 92322db1728SEd Tanous crow::connections::systemBus->async_method_call( 92498be3e39SEd Tanous [asyncResp, resName](const boost::system::error_code ec, 92522db1728SEd Tanous const GetObjectType& getObjectType) { 92622db1728SEd Tanous if (ec) 92722db1728SEd Tanous { 92822db1728SEd Tanous BMCWEB_LOG_ERROR 92922db1728SEd Tanous << "ObjectMapper::GetObject call failed: " 93022db1728SEd Tanous << ec; 93122db1728SEd Tanous messages::internalError(asyncResp->res); 93222db1728SEd Tanous 93322db1728SEd Tanous return; 93422db1728SEd Tanous } 93522db1728SEd Tanous std::string service = getObjectType.begin()->first; 93622db1728SEd Tanous BMCWEB_LOG_DEBUG << "GetObjectType: " << service; 93722db1728SEd Tanous 93822db1728SEd Tanous crow::connections::systemBus->async_method_call( 93998be3e39SEd Tanous [resName, service, asyncResp{asyncResp}]( 94022db1728SEd Tanous const boost::system::error_code ec, 941*711ac7a9SEd Tanous dbus::utility::ManagedObjectType& subtree) { 94222db1728SEd Tanous if (ec) 94322db1728SEd Tanous { 94422db1728SEd Tanous BMCWEB_LOG_DEBUG << "DBUS response error"; 94522db1728SEd Tanous 94622db1728SEd Tanous return; 94722db1728SEd Tanous } 94822db1728SEd Tanous 94922db1728SEd Tanous for (const auto& object : subtree) 95022db1728SEd Tanous { 95122db1728SEd Tanous const std::string& path = 95222db1728SEd Tanous static_cast<const std::string&>( 95322db1728SEd Tanous object.first); 95422db1728SEd Tanous 95522db1728SEd Tanous std::size_t lastIndex = path.rfind('/'); 95622db1728SEd Tanous if (lastIndex == std::string::npos) 95722db1728SEd Tanous { 95822db1728SEd Tanous continue; 95922db1728SEd Tanous } 96022db1728SEd Tanous 96122db1728SEd Tanous lastIndex += 1; 96222db1728SEd Tanous 96322db1728SEd Tanous if (path.substr(lastIndex) == resName) 96422db1728SEd Tanous { 96522db1728SEd Tanous lastIndex = path.rfind("Proxy"); 96622db1728SEd Tanous if (lastIndex != std::string::npos) 96722db1728SEd Tanous { 96822db1728SEd Tanous // Proxy mode 96922db1728SEd Tanous doVmAction(asyncResp, service, 97022db1728SEd Tanous resName, false); 97122db1728SEd Tanous } 97222db1728SEd Tanous 97322db1728SEd Tanous lastIndex = path.rfind("Legacy"); 97422db1728SEd Tanous if (lastIndex != std::string::npos) 97522db1728SEd Tanous { 97622db1728SEd Tanous // Legacy mode 97722db1728SEd Tanous doVmAction(asyncResp, service, 97822db1728SEd Tanous resName, true); 97922db1728SEd Tanous } 98022db1728SEd Tanous 98122db1728SEd Tanous return; 98222db1728SEd Tanous } 98322db1728SEd Tanous } 98422db1728SEd Tanous BMCWEB_LOG_DEBUG << "Parent item not found"; 98522db1728SEd Tanous messages::resourceNotFound( 98622db1728SEd Tanous asyncResp->res, "VirtualMedia", resName); 98722db1728SEd Tanous }, 98822db1728SEd Tanous service, "/xyz/openbmc_project/VirtualMedia", 98922db1728SEd Tanous "org.freedesktop.DBus.ObjectManager", 99022db1728SEd Tanous "GetManagedObjects"); 99122db1728SEd Tanous }, 99222db1728SEd Tanous "xyz.openbmc_project.ObjectMapper", 99322db1728SEd Tanous "/xyz/openbmc_project/object_mapper", 99422db1728SEd Tanous "xyz.openbmc_project.ObjectMapper", "GetObject", 99522db1728SEd Tanous "/xyz/openbmc_project/VirtualMedia", 99622db1728SEd Tanous std::array<const char*, 0>()); 99722db1728SEd Tanous }); 99822db1728SEd Tanous BMCWEB_ROUTE(app, "/redfish/v1/Managers/<str>/VirtualMedia/") 999ed398213SEd Tanous .privileges(redfish::privileges::getVirtualMediaCollection) 100022db1728SEd Tanous .methods(boost::beast::http::verb::get)( 100122db1728SEd Tanous [](const crow::Request& /* req */, 100222db1728SEd Tanous const std::shared_ptr<bmcweb::AsyncResp>& asyncResp, 100322db1728SEd Tanous const std::string& name) { 100422db1728SEd Tanous if (name != "bmc") 100522db1728SEd Tanous { 100622db1728SEd Tanous messages::resourceNotFound(asyncResp->res, "VirtualMedia", 100722db1728SEd Tanous name); 1008107077deSPrzemyslaw Czarnowski 1009107077deSPrzemyslaw Czarnowski return; 1010107077deSPrzemyslaw Czarnowski } 1011107077deSPrzemyslaw Czarnowski 10128d1b46d7Szhanghch05 asyncResp->res.jsonValue["@odata.type"] = 1013107077deSPrzemyslaw Czarnowski "#VirtualMediaCollection.VirtualMediaCollection"; 10148d1b46d7Szhanghch05 asyncResp->res.jsonValue["Name"] = "Virtual Media Services"; 10158d1b46d7Szhanghch05 asyncResp->res.jsonValue["@odata.id"] = 1016d6c414f3SPrzemyslaw Czarnowski "/redfish/v1/Managers/" + name + "/VirtualMedia"; 1017107077deSPrzemyslaw Czarnowski 1018107077deSPrzemyslaw Czarnowski crow::connections::systemBus->async_method_call( 1019107077deSPrzemyslaw Czarnowski [asyncResp, name](const boost::system::error_code ec, 1020107077deSPrzemyslaw Czarnowski const GetObjectType& getObjectType) { 1021107077deSPrzemyslaw Czarnowski if (ec) 1022107077deSPrzemyslaw Czarnowski { 102322db1728SEd Tanous BMCWEB_LOG_ERROR 102422db1728SEd Tanous << "ObjectMapper::GetObject call failed: " 1025107077deSPrzemyslaw Czarnowski << ec; 1026107077deSPrzemyslaw Czarnowski messages::internalError(asyncResp->res); 1027107077deSPrzemyslaw Czarnowski 1028107077deSPrzemyslaw Czarnowski return; 1029107077deSPrzemyslaw Czarnowski } 1030107077deSPrzemyslaw Czarnowski std::string service = getObjectType.begin()->first; 1031107077deSPrzemyslaw Czarnowski BMCWEB_LOG_DEBUG << "GetObjectType: " << service; 1032107077deSPrzemyslaw Czarnowski 1033107077deSPrzemyslaw Czarnowski getVmResourceList(asyncResp, service, name); 1034107077deSPrzemyslaw Czarnowski }, 1035107077deSPrzemyslaw Czarnowski "xyz.openbmc_project.ObjectMapper", 1036107077deSPrzemyslaw Czarnowski "/xyz/openbmc_project/object_mapper", 1037107077deSPrzemyslaw Czarnowski "xyz.openbmc_project.ObjectMapper", "GetObject", 103822db1728SEd Tanous "/xyz/openbmc_project/VirtualMedia", 103922db1728SEd Tanous std::array<const char*, 0>()); 104022db1728SEd Tanous }); 1041107077deSPrzemyslaw Czarnowski 104222db1728SEd Tanous BMCWEB_ROUTE(app, "/redfish/v1/Managers/<str>/VirtualMedia/<str>/") 1043ed398213SEd Tanous .privileges(redfish::privileges::getVirtualMedia) 104422db1728SEd Tanous .methods(boost::beast::http::verb::get)( 104522db1728SEd Tanous [](const crow::Request& /* req */, 104622db1728SEd Tanous const std::shared_ptr<bmcweb::AsyncResp>& asyncResp, 104722db1728SEd Tanous const std::string& name, const std::string& resName) { 1048107077deSPrzemyslaw Czarnowski if (name != "bmc") 1049107077deSPrzemyslaw Czarnowski { 105022db1728SEd Tanous messages::resourceNotFound(asyncResp->res, "VirtualMedia", 105122db1728SEd Tanous resName); 1052107077deSPrzemyslaw Czarnowski 1053107077deSPrzemyslaw Czarnowski return; 1054107077deSPrzemyslaw Czarnowski } 1055107077deSPrzemyslaw Czarnowski 1056107077deSPrzemyslaw Czarnowski crow::connections::systemBus->async_method_call( 105722db1728SEd Tanous [asyncResp, name, 105822db1728SEd Tanous resName](const boost::system::error_code ec, 1059107077deSPrzemyslaw Czarnowski const GetObjectType& getObjectType) { 1060107077deSPrzemyslaw Czarnowski if (ec) 1061107077deSPrzemyslaw Czarnowski { 106222db1728SEd Tanous BMCWEB_LOG_ERROR 106322db1728SEd Tanous << "ObjectMapper::GetObject call failed: " 1064107077deSPrzemyslaw Czarnowski << ec; 1065107077deSPrzemyslaw Czarnowski messages::internalError(asyncResp->res); 1066107077deSPrzemyslaw Czarnowski 1067107077deSPrzemyslaw Czarnowski return; 1068107077deSPrzemyslaw Czarnowski } 1069107077deSPrzemyslaw Czarnowski std::string service = getObjectType.begin()->first; 1070107077deSPrzemyslaw Czarnowski BMCWEB_LOG_DEBUG << "GetObjectType: " << service; 1071107077deSPrzemyslaw Czarnowski 1072107077deSPrzemyslaw Czarnowski getVmData(asyncResp, service, name, resName); 1073107077deSPrzemyslaw Czarnowski }, 1074107077deSPrzemyslaw Czarnowski "xyz.openbmc_project.ObjectMapper", 1075107077deSPrzemyslaw Czarnowski "/xyz/openbmc_project/object_mapper", 1076107077deSPrzemyslaw Czarnowski "xyz.openbmc_project.ObjectMapper", "GetObject", 107722db1728SEd Tanous "/xyz/openbmc_project/VirtualMedia", 107822db1728SEd Tanous std::array<const char*, 0>()); 107922db1728SEd Tanous }); 1080107077deSPrzemyslaw Czarnowski } 1081107077deSPrzemyslaw Czarnowski 1082107077deSPrzemyslaw Czarnowski } // namespace redfish 1083