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 18b9d36b47SEd Tanous #include <account_service.hpp> 197e860f15SJohn Edward Broadbent #include <app.hpp> 20988fb7b2SAdrian Ambrożewicz #include <boost/process/async_pipe.hpp> 21988fb7b2SAdrian Ambrożewicz #include <boost/type_traits/has_dereference.hpp> 229e319cf0SAnna Platash #include <boost/url/url_view.hpp> 2345ca1b86SEd Tanous #include <query.hpp> 24ed398213SEd Tanous #include <registries/privilege_registry.hpp> 25b9d36b47SEd Tanous #include <utils/json_utils.hpp> 26107077deSPrzemyslaw Czarnowski 27107077deSPrzemyslaw Czarnowski namespace redfish 28107077deSPrzemyslaw Czarnowski { 299e319cf0SAnna Platash /** 309e319cf0SAnna Platash * @brief Function extracts transfer protocol name from URI. 319e319cf0SAnna Platash */ 3267df073bSEd Tanous inline std::string getTransferProtocolTypeFromUri(const std::string& imageUri) 3367df073bSEd Tanous { 3467df073bSEd Tanous boost::urls::result<boost::urls::url_view> url = 3567df073bSEd Tanous boost::urls::parse_uri(boost::string_view(imageUri)); 3667df073bSEd Tanous if (!url) 3767df073bSEd Tanous { 3867df073bSEd Tanous return "None"; 3967df073bSEd Tanous } 4067df073bSEd Tanous boost::string_view scheme = url->scheme(); 4167df073bSEd Tanous if (scheme == "smb") 4267df073bSEd Tanous { 4367df073bSEd Tanous return "CIFS"; 4467df073bSEd Tanous } 4567df073bSEd Tanous if (scheme == "https") 4667df073bSEd Tanous { 4767df073bSEd Tanous return "HTTPS"; 4867df073bSEd Tanous } 4967df073bSEd Tanous 5067df073bSEd Tanous return "None"; 5167df073bSEd Tanous } 52107077deSPrzemyslaw Czarnowski 53107077deSPrzemyslaw Czarnowski /** 54107077deSPrzemyslaw Czarnowski * @brief Read all known properties from VM object interfaces 55107077deSPrzemyslaw Czarnowski */ 5622db1728SEd Tanous inline void 57711ac7a9SEd Tanous vmParseInterfaceObject(const dbus::utility::DBusInteracesMap& interface, 588d1b46d7Szhanghch05 const std::shared_ptr<bmcweb::AsyncResp>& aResp) 59107077deSPrzemyslaw Czarnowski { 60711ac7a9SEd Tanous for (const auto& [interface, values] : interface) 61107077deSPrzemyslaw Czarnowski { 62711ac7a9SEd Tanous if (interface == "xyz.openbmc_project.VirtualMedia.MountPoint") 63107077deSPrzemyslaw Czarnowski { 64711ac7a9SEd Tanous for (const auto& [property, value] : values) 65107077deSPrzemyslaw Czarnowski { 66711ac7a9SEd Tanous if (property == "EndpointId") 67107077deSPrzemyslaw Czarnowski { 68107077deSPrzemyslaw Czarnowski const std::string* endpointIdValue = 69711ac7a9SEd Tanous std::get_if<std::string>(&value); 70711ac7a9SEd Tanous if (endpointIdValue == nullptr) 71107077deSPrzemyslaw Czarnowski { 72711ac7a9SEd Tanous continue; 73711ac7a9SEd Tanous } 74107077deSPrzemyslaw Czarnowski if (!endpointIdValue->empty()) 75107077deSPrzemyslaw Czarnowski { 76107077deSPrzemyslaw Czarnowski // Proxy mode 77711ac7a9SEd Tanous aResp->res 78711ac7a9SEd Tanous .jsonValue["Oem"]["OpenBMC"]["WebSocketEndpoint"] = 79d04ba325SPrzemyslaw Czarnowski *endpointIdValue; 80107077deSPrzemyslaw Czarnowski aResp->res.jsonValue["TransferProtocolType"] = "OEM"; 81107077deSPrzemyslaw Czarnowski } 82107077deSPrzemyslaw Czarnowski } 83711ac7a9SEd Tanous if (property == "ImageURL") 84107077deSPrzemyslaw Czarnowski { 85107077deSPrzemyslaw Czarnowski const std::string* imageUrlValue = 86711ac7a9SEd Tanous std::get_if<std::string>(&value); 8726f6976fSEd Tanous if (imageUrlValue != nullptr && !imageUrlValue->empty()) 88107077deSPrzemyslaw Czarnowski { 89da4784d8SPrzemyslaw Czarnowski std::filesystem::path filePath = *imageUrlValue; 90da4784d8SPrzemyslaw Czarnowski if (!filePath.has_filename()) 91da4784d8SPrzemyslaw Czarnowski { 929e319cf0SAnna Platash // this will handle https share, which not 939e319cf0SAnna Platash // necessarily has to have filename given. 94da4784d8SPrzemyslaw Czarnowski aResp->res.jsonValue["ImageName"] = ""; 95da4784d8SPrzemyslaw Czarnowski } 96da4784d8SPrzemyslaw Czarnowski else 97da4784d8SPrzemyslaw Czarnowski { 989e319cf0SAnna Platash aResp->res.jsonValue["ImageName"] = 999e319cf0SAnna Platash filePath.filename(); 100da4784d8SPrzemyslaw Czarnowski } 101da4784d8SPrzemyslaw Czarnowski 102da4784d8SPrzemyslaw Czarnowski aResp->res.jsonValue["Image"] = *imageUrlValue; 1039e319cf0SAnna Platash aResp->res.jsonValue["TransferProtocolType"] = 1049e319cf0SAnna Platash getTransferProtocolTypeFromUri(*imageUrlValue); 1059e319cf0SAnna Platash 106107077deSPrzemyslaw Czarnowski aResp->res.jsonValue["ConnectedVia"] = "URI"; 107107077deSPrzemyslaw Czarnowski } 108107077deSPrzemyslaw Czarnowski } 109711ac7a9SEd Tanous if (property == "WriteProtected") 1109e319cf0SAnna Platash { 111711ac7a9SEd Tanous const bool* writeProtectedValue = std::get_if<bool>(&value); 112e662eae8SEd Tanous if (writeProtectedValue != nullptr) 1139e319cf0SAnna Platash { 1149e319cf0SAnna Platash aResp->res.jsonValue["WriteProtected"] = 1159e319cf0SAnna Platash *writeProtectedValue; 1169e319cf0SAnna Platash } 1179e319cf0SAnna Platash } 1189e319cf0SAnna Platash } 119107077deSPrzemyslaw Czarnowski } 120711ac7a9SEd Tanous if (interface == "xyz.openbmc_project.VirtualMedia.Process") 121711ac7a9SEd Tanous { 122711ac7a9SEd Tanous for (const auto& [property, value] : values) 123711ac7a9SEd Tanous { 124711ac7a9SEd Tanous if (property == "Active") 125711ac7a9SEd Tanous { 126711ac7a9SEd Tanous const bool* activeValue = std::get_if<bool>(&value); 127e662eae8SEd Tanous if (activeValue == nullptr) 128711ac7a9SEd Tanous { 129711ac7a9SEd Tanous BMCWEB_LOG_DEBUG << "Value Active not found"; 130711ac7a9SEd Tanous return; 131711ac7a9SEd Tanous } 132711ac7a9SEd Tanous aResp->res.jsonValue["Inserted"] = *activeValue; 133711ac7a9SEd Tanous 134e05aec50SEd Tanous if (*activeValue) 135711ac7a9SEd Tanous { 136711ac7a9SEd Tanous aResp->res.jsonValue["ConnectedVia"] = "Applet"; 137711ac7a9SEd Tanous } 138711ac7a9SEd Tanous } 139711ac7a9SEd Tanous } 140711ac7a9SEd Tanous } 141107077deSPrzemyslaw Czarnowski } 142107077deSPrzemyslaw Czarnowski } 143107077deSPrzemyslaw Czarnowski 144107077deSPrzemyslaw Czarnowski /** 145107077deSPrzemyslaw Czarnowski * @brief Fill template for Virtual Media Item. 146107077deSPrzemyslaw Czarnowski */ 14722db1728SEd Tanous inline nlohmann::json vmItemTemplate(const std::string& name, 148107077deSPrzemyslaw Czarnowski const std::string& resName) 149107077deSPrzemyslaw Czarnowski { 150107077deSPrzemyslaw Czarnowski nlohmann::json item; 15122db1728SEd Tanous 15222db1728SEd Tanous std::string id = "/redfish/v1/Managers/"; 15322db1728SEd Tanous id += name; 15422db1728SEd Tanous id += "/VirtualMedia/"; 15522db1728SEd Tanous id += resName; 15622db1728SEd Tanous item["@odata.id"] = std::move(id); 15722db1728SEd Tanous 158d04ba325SPrzemyslaw Czarnowski item["@odata.type"] = "#VirtualMedia.v1_3_0.VirtualMedia"; 159107077deSPrzemyslaw Czarnowski item["Name"] = "Virtual Removable Media"; 160107077deSPrzemyslaw Czarnowski item["Id"] = resName; 161107077deSPrzemyslaw Czarnowski item["WriteProtected"] = true; 162107077deSPrzemyslaw Czarnowski item["MediaTypes"] = {"CD", "USBStick"}; 163107077deSPrzemyslaw Czarnowski item["TransferMethod"] = "Stream"; 164d04ba325SPrzemyslaw Czarnowski item["Oem"]["OpenBMC"]["@odata.type"] = 165d04ba325SPrzemyslaw Czarnowski "#OemVirtualMedia.v1_0_0.VirtualMedia"; 166107077deSPrzemyslaw Czarnowski 167107077deSPrzemyslaw Czarnowski return item; 168107077deSPrzemyslaw Czarnowski } 169107077deSPrzemyslaw Czarnowski 170107077deSPrzemyslaw Czarnowski /** 171107077deSPrzemyslaw Czarnowski * @brief Fills collection data 172107077deSPrzemyslaw Czarnowski */ 17322db1728SEd Tanous inline void getVmResourceList(std::shared_ptr<bmcweb::AsyncResp> aResp, 174107077deSPrzemyslaw Czarnowski const std::string& service, 175107077deSPrzemyslaw Czarnowski const std::string& name) 176107077deSPrzemyslaw Czarnowski { 177107077deSPrzemyslaw Czarnowski BMCWEB_LOG_DEBUG << "Get available Virtual Media resources."; 178107077deSPrzemyslaw Czarnowski crow::connections::systemBus->async_method_call( 179711ac7a9SEd Tanous [name, 180711ac7a9SEd Tanous aResp{std::move(aResp)}](const boost::system::error_code ec, 181711ac7a9SEd Tanous dbus::utility::ManagedObjectType& subtree) { 182107077deSPrzemyslaw Czarnowski if (ec) 183107077deSPrzemyslaw Czarnowski { 184107077deSPrzemyslaw Czarnowski BMCWEB_LOG_DEBUG << "DBUS response error"; 185107077deSPrzemyslaw Czarnowski return; 186107077deSPrzemyslaw Czarnowski } 187107077deSPrzemyslaw Czarnowski nlohmann::json& members = aResp->res.jsonValue["Members"]; 188107077deSPrzemyslaw Czarnowski members = nlohmann::json::array(); 189107077deSPrzemyslaw Czarnowski 190107077deSPrzemyslaw Czarnowski for (const auto& object : subtree) 191107077deSPrzemyslaw Czarnowski { 192107077deSPrzemyslaw Czarnowski nlohmann::json item; 1932dfd18efSEd Tanous std::string path = object.first.filename(); 1942dfd18efSEd Tanous if (path.empty()) 195107077deSPrzemyslaw Czarnowski { 196107077deSPrzemyslaw Czarnowski continue; 197107077deSPrzemyslaw Czarnowski } 198107077deSPrzemyslaw Czarnowski 19922db1728SEd Tanous std::string id = "/redfish/v1/Managers/"; 20022db1728SEd Tanous id += name; 20122db1728SEd Tanous id += "/VirtualMedia/"; 20222db1728SEd Tanous id += path; 203107077deSPrzemyslaw Czarnowski 20422db1728SEd Tanous item["@odata.id"] = std::move(id); 205107077deSPrzemyslaw Czarnowski members.emplace_back(std::move(item)); 206107077deSPrzemyslaw Czarnowski } 207107077deSPrzemyslaw Czarnowski aResp->res.jsonValue["Members@odata.count"] = members.size(); 208107077deSPrzemyslaw Czarnowski }, 209107077deSPrzemyslaw Czarnowski service, "/xyz/openbmc_project/VirtualMedia", 210107077deSPrzemyslaw Czarnowski "org.freedesktop.DBus.ObjectManager", "GetManagedObjects"); 211107077deSPrzemyslaw Czarnowski } 212107077deSPrzemyslaw Czarnowski 213107077deSPrzemyslaw Czarnowski /** 214107077deSPrzemyslaw Czarnowski * @brief Fills data for specific resource 215107077deSPrzemyslaw Czarnowski */ 21622db1728SEd Tanous inline void getVmData(const std::shared_ptr<bmcweb::AsyncResp>& aResp, 217107077deSPrzemyslaw Czarnowski const std::string& service, const std::string& name, 218107077deSPrzemyslaw Czarnowski const std::string& resName) 219107077deSPrzemyslaw Czarnowski { 220107077deSPrzemyslaw Czarnowski BMCWEB_LOG_DEBUG << "Get Virtual Media resource data."; 221107077deSPrzemyslaw Czarnowski 222107077deSPrzemyslaw Czarnowski crow::connections::systemBus->async_method_call( 223914e2d5dSEd Tanous [resName, name, 224914e2d5dSEd Tanous aResp](const boost::system::error_code ec, 225914e2d5dSEd Tanous const dbus::utility::ManagedObjectType& subtree) { 226107077deSPrzemyslaw Czarnowski if (ec) 227107077deSPrzemyslaw Czarnowski { 228107077deSPrzemyslaw Czarnowski BMCWEB_LOG_DEBUG << "DBUS response error"; 229e13c2760SPrzemyslaw Czarnowski 230107077deSPrzemyslaw Czarnowski return; 231107077deSPrzemyslaw Czarnowski } 232107077deSPrzemyslaw Czarnowski 233914e2d5dSEd Tanous for (const auto& item : subtree) 234107077deSPrzemyslaw Czarnowski { 2352dfd18efSEd Tanous std::string thispath = item.first.filename(); 2362dfd18efSEd Tanous if (thispath.empty()) 237107077deSPrzemyslaw Czarnowski { 238107077deSPrzemyslaw Czarnowski continue; 239107077deSPrzemyslaw Czarnowski } 240107077deSPrzemyslaw Czarnowski 2412dfd18efSEd Tanous if (thispath != resName) 242107077deSPrzemyslaw Czarnowski { 243107077deSPrzemyslaw Czarnowski continue; 244107077deSPrzemyslaw Czarnowski } 245107077deSPrzemyslaw Czarnowski 2461a6258dcSPrzemyslaw Czarnowski // "Legacy"/"Proxy" 2471a6258dcSPrzemyslaw Czarnowski auto mode = item.first.parent_path(); 2481a6258dcSPrzemyslaw Czarnowski // "VirtualMedia" 2491a6258dcSPrzemyslaw Czarnowski auto type = mode.parent_path(); 2501a6258dcSPrzemyslaw Czarnowski if (mode.filename().empty() || type.filename().empty()) 2511a6258dcSPrzemyslaw Czarnowski { 2521a6258dcSPrzemyslaw Czarnowski continue; 2531a6258dcSPrzemyslaw Czarnowski } 2541a6258dcSPrzemyslaw Czarnowski 2551a6258dcSPrzemyslaw Czarnowski if (type.filename() != "VirtualMedia") 2561a6258dcSPrzemyslaw Czarnowski { 2571a6258dcSPrzemyslaw Czarnowski continue; 2581a6258dcSPrzemyslaw Czarnowski } 2591a6258dcSPrzemyslaw Czarnowski 260107077deSPrzemyslaw Czarnowski aResp->res.jsonValue = vmItemTemplate(name, resName); 26122db1728SEd Tanous std::string actionsId = "/redfish/v1/Managers/"; 26222db1728SEd Tanous actionsId += name; 26322db1728SEd Tanous actionsId += "/VirtualMedia/"; 26422db1728SEd Tanous actionsId += resName; 26522db1728SEd Tanous actionsId += "/Actions"; 266107077deSPrzemyslaw Czarnowski 267e13c2760SPrzemyslaw Czarnowski // Check if dbus path is Legacy type 2681a6258dcSPrzemyslaw Czarnowski if (mode.filename() == "Legacy") 269e13c2760SPrzemyslaw Czarnowski { 270e13c2760SPrzemyslaw Czarnowski aResp->res.jsonValue["Actions"]["#VirtualMedia.InsertMedia"] 271e13c2760SPrzemyslaw Czarnowski ["target"] = 27222db1728SEd Tanous actionsId + "/VirtualMedia.InsertMedia"; 273e13c2760SPrzemyslaw Czarnowski } 274e13c2760SPrzemyslaw Czarnowski 275107077deSPrzemyslaw Czarnowski vmParseInterfaceObject(item.second, aResp); 276107077deSPrzemyslaw Czarnowski 277002d39b4SEd Tanous aResp->res 278002d39b4SEd Tanous .jsonValue["Actions"]["#VirtualMedia.EjectMedia"]["target"] = 27922db1728SEd Tanous actionsId + "/VirtualMedia.EjectMedia"; 280e13c2760SPrzemyslaw Czarnowski 281107077deSPrzemyslaw Czarnowski return; 282107077deSPrzemyslaw Czarnowski } 283107077deSPrzemyslaw Czarnowski 284107077deSPrzemyslaw Czarnowski messages::resourceNotFound( 285d04ba325SPrzemyslaw Czarnowski aResp->res, "#VirtualMedia.v1_3_0.VirtualMedia", resName); 286107077deSPrzemyslaw Czarnowski }, 287107077deSPrzemyslaw Czarnowski service, "/xyz/openbmc_project/VirtualMedia", 288107077deSPrzemyslaw Czarnowski "org.freedesktop.DBus.ObjectManager", "GetManagedObjects"); 289107077deSPrzemyslaw Czarnowski } 290107077deSPrzemyslaw Czarnowski 291e13c2760SPrzemyslaw Czarnowski /** 292c6f4e017SAgata Olender * @brief Transfer protocols supported for InsertMedia action. 293c6f4e017SAgata Olender * 294c6f4e017SAgata Olender */ 295c6f4e017SAgata Olender enum class TransferProtocol 296c6f4e017SAgata Olender { 297c6f4e017SAgata Olender https, 298c6f4e017SAgata Olender smb, 299c6f4e017SAgata Olender invalid 300c6f4e017SAgata Olender }; 301c6f4e017SAgata Olender 302c6f4e017SAgata Olender /** 303c6f4e017SAgata Olender * @brief Function extracts transfer protocol type from URI. 304c6f4e017SAgata Olender * 305c6f4e017SAgata Olender */ 30667df073bSEd Tanous inline std::optional<TransferProtocol> 307ace85d60SEd Tanous getTransferProtocolFromUri(const boost::urls::url_view& imageUri) 30867df073bSEd Tanous { 309ace85d60SEd Tanous boost::string_view scheme = imageUri.scheme(); 31067df073bSEd Tanous if (scheme == "smb") 31167df073bSEd Tanous { 31267df073bSEd Tanous return TransferProtocol::smb; 31367df073bSEd Tanous } 31467df073bSEd Tanous if (scheme == "https") 31567df073bSEd Tanous { 31667df073bSEd Tanous return TransferProtocol::https; 31767df073bSEd Tanous } 31867df073bSEd Tanous if (!scheme.empty()) 31967df073bSEd Tanous { 32067df073bSEd Tanous return TransferProtocol::invalid; 32167df073bSEd Tanous } 32267df073bSEd Tanous 32367df073bSEd Tanous return {}; 32467df073bSEd Tanous } 325c6f4e017SAgata Olender 326c6f4e017SAgata Olender /** 327c6f4e017SAgata Olender * @brief Function convert transfer protocol from string param. 328c6f4e017SAgata Olender * 329c6f4e017SAgata Olender */ 33022db1728SEd Tanous inline std::optional<TransferProtocol> getTransferProtocolFromParam( 331c6f4e017SAgata Olender const std::optional<std::string>& transferProtocolType) 332c6f4e017SAgata Olender { 333c6f4e017SAgata Olender if (transferProtocolType == std::nullopt) 334c6f4e017SAgata Olender { 335c6f4e017SAgata Olender return {}; 336c6f4e017SAgata Olender } 337c6f4e017SAgata Olender 338c6f4e017SAgata Olender if (*transferProtocolType == "CIFS") 339c6f4e017SAgata Olender { 340c6f4e017SAgata Olender return TransferProtocol::smb; 341c6f4e017SAgata Olender } 342c6f4e017SAgata Olender 343c6f4e017SAgata Olender if (*transferProtocolType == "HTTPS") 344c6f4e017SAgata Olender { 345c6f4e017SAgata Olender return TransferProtocol::https; 346c6f4e017SAgata Olender } 347c6f4e017SAgata Olender 348c6f4e017SAgata Olender return TransferProtocol::invalid; 349c6f4e017SAgata Olender } 350c6f4e017SAgata Olender 351c6f4e017SAgata Olender /** 352c6f4e017SAgata Olender * @brief Function extends URI with transfer protocol type. 353c6f4e017SAgata Olender * 354c6f4e017SAgata Olender */ 35522db1728SEd Tanous inline std::string 356c6f4e017SAgata Olender getUriWithTransferProtocol(const std::string& imageUri, 357c6f4e017SAgata Olender const TransferProtocol& transferProtocol) 358c6f4e017SAgata Olender { 359c6f4e017SAgata Olender if (transferProtocol == TransferProtocol::smb) 360c6f4e017SAgata Olender { 361c6f4e017SAgata Olender return "smb://" + imageUri; 362c6f4e017SAgata Olender } 363c6f4e017SAgata Olender 364c6f4e017SAgata Olender if (transferProtocol == TransferProtocol::https) 365c6f4e017SAgata Olender { 366c6f4e017SAgata Olender return "https://" + imageUri; 367c6f4e017SAgata Olender } 368c6f4e017SAgata Olender 369c6f4e017SAgata Olender return imageUri; 370c6f4e017SAgata Olender } 371c6f4e017SAgata Olender 372c6f4e017SAgata Olender /** 373c6f4e017SAgata Olender * @brief Function validate parameters of insert media request. 374c6f4e017SAgata Olender * 375c6f4e017SAgata Olender */ 37622db1728SEd Tanous inline bool 37722db1728SEd Tanous validateParams(crow::Response& res, std::string& imageUrl, 378c6f4e017SAgata Olender const std::optional<bool>& inserted, 379c6f4e017SAgata Olender const std::optional<std::string>& transferMethod, 380c6f4e017SAgata Olender const std::optional<std::string>& transferProtocolType) 381c6f4e017SAgata Olender { 382c6f4e017SAgata Olender BMCWEB_LOG_DEBUG << "Validation started"; 383c6f4e017SAgata Olender // required param imageUrl must not be empty 384c6f4e017SAgata Olender if (imageUrl.empty()) 385c6f4e017SAgata Olender { 386c6f4e017SAgata Olender BMCWEB_LOG_ERROR << "Request action parameter Image is empty."; 387c6f4e017SAgata Olender 38822db1728SEd Tanous messages::propertyValueFormatError(res, "<empty>", "Image"); 389c6f4e017SAgata Olender 390c6f4e017SAgata Olender return false; 391c6f4e017SAgata Olender } 392c6f4e017SAgata Olender 393c6f4e017SAgata Olender // optional param inserted must be true 394e05aec50SEd Tanous if ((inserted != std::nullopt) && !*inserted) 395c6f4e017SAgata Olender { 396c6f4e017SAgata Olender BMCWEB_LOG_ERROR 397c6f4e017SAgata Olender << "Request action optional parameter Inserted must be true."; 398c6f4e017SAgata Olender 39922db1728SEd Tanous messages::actionParameterNotSupported(res, "Inserted", "InsertMedia"); 400c6f4e017SAgata Olender 401c6f4e017SAgata Olender return false; 402c6f4e017SAgata Olender } 403c6f4e017SAgata Olender 404c6f4e017SAgata Olender // optional param transferMethod must be stream 405c6f4e017SAgata Olender if ((transferMethod != std::nullopt) && (*transferMethod != "Stream")) 406c6f4e017SAgata Olender { 407c6f4e017SAgata Olender BMCWEB_LOG_ERROR << "Request action optional parameter " 408c6f4e017SAgata Olender "TransferMethod must be Stream."; 409c6f4e017SAgata Olender 41022db1728SEd Tanous messages::actionParameterNotSupported(res, "TransferMethod", 41122db1728SEd Tanous "InsertMedia"); 412c6f4e017SAgata Olender 413c6f4e017SAgata Olender return false; 414c6f4e017SAgata Olender } 415ace85d60SEd Tanous boost::urls::result<boost::urls::url_view> url = 416ace85d60SEd Tanous boost::urls::parse_uri(boost::string_view(imageUrl)); 417ace85d60SEd Tanous if (!url) 418ace85d60SEd Tanous { 419*9bc55699SMichal Orzel messages::actionParameterValueFormatError(res, imageUrl, "Image", 420*9bc55699SMichal Orzel "InsertMedia"); 421*9bc55699SMichal Orzel return false; 422ace85d60SEd Tanous } 423c6f4e017SAgata Olender std::optional<TransferProtocol> uriTransferProtocolType = 424ace85d60SEd Tanous getTransferProtocolFromUri(*url); 425c6f4e017SAgata Olender 426c6f4e017SAgata Olender std::optional<TransferProtocol> paramTransferProtocolType = 427c6f4e017SAgata Olender getTransferProtocolFromParam(transferProtocolType); 428c6f4e017SAgata Olender 429c6f4e017SAgata Olender // ImageUrl does not contain valid protocol type 430c6f4e017SAgata Olender if (*uriTransferProtocolType == TransferProtocol::invalid) 431c6f4e017SAgata Olender { 432c6f4e017SAgata Olender BMCWEB_LOG_ERROR << "Request action parameter ImageUrl must " 433c6f4e017SAgata Olender "contain specified protocol type from list: " 434c6f4e017SAgata Olender "(smb, https)."; 435c6f4e017SAgata Olender 436ace85d60SEd Tanous messages::resourceAtUriInUnknownFormat(res, *url); 437c6f4e017SAgata Olender 438c6f4e017SAgata Olender return false; 439c6f4e017SAgata Olender } 440c6f4e017SAgata Olender 441c6f4e017SAgata Olender // transferProtocolType should contain value from list 442c6f4e017SAgata Olender if (*paramTransferProtocolType == TransferProtocol::invalid) 443c6f4e017SAgata Olender { 444c6f4e017SAgata Olender BMCWEB_LOG_ERROR << "Request action parameter TransferProtocolType " 445c6f4e017SAgata Olender "must be provided with value from list: " 446c6f4e017SAgata Olender "(CIFS, HTTPS)."; 447c6f4e017SAgata Olender 44822db1728SEd Tanous messages::propertyValueNotInList(res, *transferProtocolType, 44922db1728SEd Tanous "TransferProtocolType"); 450c6f4e017SAgata Olender return false; 451c6f4e017SAgata Olender } 452c6f4e017SAgata Olender 453c6f4e017SAgata Olender // valid transfer protocol not provided either with URI nor param 454c6f4e017SAgata Olender if ((uriTransferProtocolType == std::nullopt) && 455c6f4e017SAgata Olender (paramTransferProtocolType == std::nullopt)) 456c6f4e017SAgata Olender { 457c6f4e017SAgata Olender BMCWEB_LOG_ERROR << "Request action parameter ImageUrl must " 458c6f4e017SAgata Olender "contain specified protocol type or param " 459c6f4e017SAgata Olender "TransferProtocolType must be provided."; 460c6f4e017SAgata Olender 461ace85d60SEd Tanous messages::resourceAtUriInUnknownFormat(res, *url); 462c6f4e017SAgata Olender 463c6f4e017SAgata Olender return false; 464c6f4e017SAgata Olender } 465c6f4e017SAgata Olender 466c6f4e017SAgata Olender // valid transfer protocol provided both with URI and param 467c6f4e017SAgata Olender if ((paramTransferProtocolType != std::nullopt) && 468c6f4e017SAgata Olender (uriTransferProtocolType != std::nullopt)) 469c6f4e017SAgata Olender { 470c6f4e017SAgata Olender // check if protocol is the same for URI and param 471c6f4e017SAgata Olender if (*paramTransferProtocolType != *uriTransferProtocolType) 472c6f4e017SAgata Olender { 473c6f4e017SAgata Olender BMCWEB_LOG_ERROR << "Request action parameter " 474c6f4e017SAgata Olender "TransferProtocolType must contain the " 475c6f4e017SAgata Olender "same protocol type as protocol type " 476c6f4e017SAgata Olender "provided with param imageUrl."; 477c6f4e017SAgata Olender 47822db1728SEd Tanous messages::actionParameterValueTypeError(res, *transferProtocolType, 47922db1728SEd Tanous "TransferProtocolType", 48022db1728SEd Tanous "InsertMedia"); 481c6f4e017SAgata Olender 482c6f4e017SAgata Olender return false; 483c6f4e017SAgata Olender } 484c6f4e017SAgata Olender } 485c6f4e017SAgata Olender 486c6f4e017SAgata Olender // validation passed 487c6f4e017SAgata Olender // add protocol to URI if needed 488c6f4e017SAgata Olender if (uriTransferProtocolType == std::nullopt) 489c6f4e017SAgata Olender { 49022db1728SEd Tanous imageUrl = 49122db1728SEd Tanous getUriWithTransferProtocol(imageUrl, *paramTransferProtocolType); 492c6f4e017SAgata Olender } 493c6f4e017SAgata Olender 494c6f4e017SAgata Olender return true; 495c6f4e017SAgata Olender } 496c6f4e017SAgata Olender 4971214b7e7SGunnar Mills template <typename T> 4981214b7e7SGunnar Mills static void secureCleanup(T& value) 499988fb7b2SAdrian Ambrożewicz { 5004ecc618fSEd Tanous // NOLINTNEXTLINE(cppcoreguidelines-pro-type-const-cast) 501988fb7b2SAdrian Ambrożewicz auto raw = const_cast<typename T::value_type*>(value.data()); 502988fb7b2SAdrian Ambrożewicz explicit_bzero(raw, value.size() * sizeof(*raw)); 503988fb7b2SAdrian Ambrożewicz } 504988fb7b2SAdrian Ambrożewicz 505988fb7b2SAdrian Ambrożewicz class Credentials 506988fb7b2SAdrian Ambrożewicz { 507988fb7b2SAdrian Ambrożewicz public: 508988fb7b2SAdrian Ambrożewicz Credentials(std::string&& user, std::string&& password) : 509988fb7b2SAdrian Ambrożewicz userBuf(std::move(user)), passBuf(std::move(password)) 5101214b7e7SGunnar Mills {} 511988fb7b2SAdrian Ambrożewicz 512988fb7b2SAdrian Ambrożewicz ~Credentials() 513988fb7b2SAdrian Ambrożewicz { 514988fb7b2SAdrian Ambrożewicz secureCleanup(userBuf); 515988fb7b2SAdrian Ambrożewicz secureCleanup(passBuf); 516988fb7b2SAdrian Ambrożewicz } 517988fb7b2SAdrian Ambrożewicz 518988fb7b2SAdrian Ambrożewicz const std::string& user() 519988fb7b2SAdrian Ambrożewicz { 520988fb7b2SAdrian Ambrożewicz return userBuf; 521988fb7b2SAdrian Ambrożewicz } 522988fb7b2SAdrian Ambrożewicz 523988fb7b2SAdrian Ambrożewicz const std::string& password() 524988fb7b2SAdrian Ambrożewicz { 525988fb7b2SAdrian Ambrożewicz return passBuf; 526988fb7b2SAdrian Ambrożewicz } 527988fb7b2SAdrian Ambrożewicz 528988fb7b2SAdrian Ambrożewicz Credentials() = delete; 529988fb7b2SAdrian Ambrożewicz Credentials(const Credentials&) = delete; 530988fb7b2SAdrian Ambrożewicz Credentials& operator=(const Credentials&) = delete; 531ecd6a3a2SEd Tanous Credentials(Credentials&&) = delete; 532ecd6a3a2SEd Tanous Credentials& operator=(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{}}; 579e662eae8SEd Tanous if (formatter != nullptr) 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 608ecd6a3a2SEd Tanous Pipe(const Pipe&) = delete; 609ecd6a3a2SEd Tanous Pipe(Pipe&&) = delete; 610ecd6a3a2SEd Tanous Pipe& operator=(const Pipe&) = delete; 611ecd6a3a2SEd Tanous Pipe& operator=(Pipe&&) = delete; 612ecd6a3a2SEd Tanous 613988fb7b2SAdrian Ambrożewicz unix_fd fd() 614988fb7b2SAdrian Ambrożewicz { 615988fb7b2SAdrian Ambrożewicz return unix_fd{impl.native_source()}; 616988fb7b2SAdrian Ambrożewicz } 617988fb7b2SAdrian Ambrożewicz 618988fb7b2SAdrian Ambrożewicz template <typename WriteHandler> 61981ce609eSEd Tanous void asyncWrite(WriteHandler&& handler) 620988fb7b2SAdrian Ambrożewicz { 621988fb7b2SAdrian Ambrożewicz impl.async_write_some(data(), std::forward<WriteHandler>(handler)); 622988fb7b2SAdrian Ambrożewicz } 623988fb7b2SAdrian Ambrożewicz 624988fb7b2SAdrian Ambrożewicz private: 625988fb7b2SAdrian Ambrożewicz // Specialization for pointer types 626988fb7b2SAdrian Ambrożewicz template <typename B = Buffer> 627988fb7b2SAdrian Ambrożewicz typename std::enable_if<boost::has_dereference<B>::value, 628988fb7b2SAdrian Ambrożewicz boost::asio::const_buffer>::type 629988fb7b2SAdrian Ambrożewicz data() 630988fb7b2SAdrian Ambrożewicz { 631988fb7b2SAdrian Ambrożewicz return boost::asio::buffer(*buffer); 632988fb7b2SAdrian Ambrożewicz } 633988fb7b2SAdrian Ambrożewicz 634988fb7b2SAdrian Ambrożewicz template <typename B = Buffer> 635988fb7b2SAdrian Ambrożewicz typename std::enable_if<!boost::has_dereference<B>::value, 636988fb7b2SAdrian Ambrożewicz boost::asio::const_buffer>::type 637988fb7b2SAdrian Ambrożewicz data() 638988fb7b2SAdrian Ambrożewicz { 639988fb7b2SAdrian Ambrożewicz return boost::asio::buffer(buffer); 640988fb7b2SAdrian Ambrożewicz } 641988fb7b2SAdrian Ambrożewicz 642988fb7b2SAdrian Ambrożewicz const std::string name; 643988fb7b2SAdrian Ambrożewicz boost::process::async_pipe impl; 644988fb7b2SAdrian Ambrożewicz Buffer buffer; 645988fb7b2SAdrian Ambrożewicz }; 646988fb7b2SAdrian Ambrożewicz 647e13c2760SPrzemyslaw Czarnowski /** 648e13c2760SPrzemyslaw Czarnowski * @brief Function transceives data with dbus directly. 649e13c2760SPrzemyslaw Czarnowski * 650e13c2760SPrzemyslaw Czarnowski * All BMC state properties will be retrieved before sending reset request. 651e13c2760SPrzemyslaw Czarnowski */ 65222db1728SEd Tanous inline void doMountVmLegacy(const std::shared_ptr<bmcweb::AsyncResp>& asyncResp, 653e13c2760SPrzemyslaw Czarnowski const std::string& service, const std::string& name, 654988fb7b2SAdrian Ambrożewicz const std::string& imageUrl, const bool rw, 655988fb7b2SAdrian Ambrożewicz std::string&& userName, std::string&& password) 656e13c2760SPrzemyslaw Czarnowski { 657988fb7b2SAdrian Ambrożewicz using SecurePipe = Pipe<CredentialsProvider::SecureBuffer>; 658988fb7b2SAdrian Ambrożewicz constexpr const size_t secretLimit = 1024; 659988fb7b2SAdrian Ambrożewicz 660988fb7b2SAdrian Ambrożewicz std::shared_ptr<SecurePipe> secretPipe; 661168e20c1SEd Tanous dbus::utility::DbusVariantType unixFd = -1; 662988fb7b2SAdrian Ambrożewicz 663988fb7b2SAdrian Ambrożewicz if (!userName.empty() || !password.empty()) 664988fb7b2SAdrian Ambrożewicz { 665988fb7b2SAdrian Ambrożewicz // Encapsulate in safe buffer 666988fb7b2SAdrian Ambrożewicz CredentialsProvider credentials(std::move(userName), 667988fb7b2SAdrian Ambrożewicz std::move(password)); 668988fb7b2SAdrian Ambrożewicz 669988fb7b2SAdrian Ambrożewicz // Payload must contain data + NULL delimiters 670988fb7b2SAdrian Ambrożewicz if (credentials.user().size() + credentials.password().size() + 2 > 671988fb7b2SAdrian Ambrożewicz secretLimit) 672988fb7b2SAdrian Ambrożewicz { 673988fb7b2SAdrian Ambrożewicz BMCWEB_LOG_ERROR << "Credentials too long to handle"; 674988fb7b2SAdrian Ambrożewicz messages::unrecognizedRequestBody(asyncResp->res); 675988fb7b2SAdrian Ambrożewicz return; 676988fb7b2SAdrian Ambrożewicz } 677988fb7b2SAdrian Ambrożewicz 678988fb7b2SAdrian Ambrożewicz // Pack secret 67922db1728SEd Tanous auto secret = credentials.pack( 68022db1728SEd Tanous [](const auto& user, const auto& pass, auto& buff) { 681988fb7b2SAdrian Ambrożewicz std::copy(user.begin(), user.end(), std::back_inserter(buff)); 682988fb7b2SAdrian Ambrożewicz buff.push_back('\0'); 683988fb7b2SAdrian Ambrożewicz std::copy(pass.begin(), pass.end(), std::back_inserter(buff)); 684988fb7b2SAdrian Ambrożewicz buff.push_back('\0'); 685988fb7b2SAdrian Ambrożewicz }); 686988fb7b2SAdrian Ambrożewicz 687988fb7b2SAdrian Ambrożewicz // Open pipe 688988fb7b2SAdrian Ambrożewicz secretPipe = std::make_shared<SecurePipe>( 68922db1728SEd Tanous crow::connections::systemBus->get_io_context(), std::move(secret)); 690988fb7b2SAdrian Ambrożewicz unixFd = secretPipe->fd(); 691988fb7b2SAdrian Ambrożewicz 692988fb7b2SAdrian Ambrożewicz // Pass secret over pipe 69381ce609eSEd Tanous secretPipe->asyncWrite( 694f5b16f03SVikram Bodireddy [asyncResp](const boost::system::error_code& ec, std::size_t) { 695988fb7b2SAdrian Ambrożewicz if (ec) 696988fb7b2SAdrian Ambrożewicz { 697988fb7b2SAdrian Ambrożewicz BMCWEB_LOG_ERROR << "Failed to pass secret: " << ec; 698988fb7b2SAdrian Ambrożewicz messages::internalError(asyncResp->res); 699988fb7b2SAdrian Ambrożewicz } 700988fb7b2SAdrian Ambrożewicz }); 701988fb7b2SAdrian Ambrożewicz } 702988fb7b2SAdrian Ambrożewicz 703e13c2760SPrzemyslaw Czarnowski crow::connections::systemBus->async_method_call( 704988fb7b2SAdrian Ambrożewicz [asyncResp, secretPipe](const boost::system::error_code ec, 705988fb7b2SAdrian Ambrożewicz bool success) { 706e13c2760SPrzemyslaw Czarnowski if (ec) 707e13c2760SPrzemyslaw Czarnowski { 708e13c2760SPrzemyslaw Czarnowski BMCWEB_LOG_ERROR << "Bad D-Bus request error: " << ec; 709e13c2760SPrzemyslaw Czarnowski messages::internalError(asyncResp->res); 710d6da5bebSAdrian Ambrożewicz } 711d6da5bebSAdrian Ambrożewicz else if (!success) 712d6da5bebSAdrian Ambrożewicz { 713d6da5bebSAdrian Ambrożewicz BMCWEB_LOG_ERROR << "Service responded with error"; 714d6da5bebSAdrian Ambrożewicz messages::generalError(asyncResp->res); 715e13c2760SPrzemyslaw Czarnowski } 716e13c2760SPrzemyslaw Czarnowski }, 717e13c2760SPrzemyslaw Czarnowski service, "/xyz/openbmc_project/VirtualMedia/Legacy/" + name, 718988fb7b2SAdrian Ambrożewicz "xyz.openbmc_project.VirtualMedia.Legacy", "Mount", imageUrl, rw, 719988fb7b2SAdrian Ambrożewicz unixFd); 720e13c2760SPrzemyslaw Czarnowski } 721e13c2760SPrzemyslaw Czarnowski 722e13c2760SPrzemyslaw Czarnowski /** 723e13c2760SPrzemyslaw Czarnowski * @brief Function transceives data with dbus directly. 724e13c2760SPrzemyslaw Czarnowski * 725e13c2760SPrzemyslaw Czarnowski * All BMC state properties will be retrieved before sending reset request. 726e13c2760SPrzemyslaw Czarnowski */ 72722db1728SEd Tanous inline void doVmAction(const std::shared_ptr<bmcweb::AsyncResp>& asyncResp, 728e13c2760SPrzemyslaw Czarnowski const std::string& service, const std::string& name, 729e13c2760SPrzemyslaw Czarnowski bool legacy) 730e13c2760SPrzemyslaw Czarnowski { 731e13c2760SPrzemyslaw Czarnowski 732e13c2760SPrzemyslaw Czarnowski // Legacy mount requires parameter with image 733e13c2760SPrzemyslaw Czarnowski if (legacy) 734e13c2760SPrzemyslaw Czarnowski { 735e13c2760SPrzemyslaw Czarnowski crow::connections::systemBus->async_method_call( 736e13c2760SPrzemyslaw Czarnowski [asyncResp](const boost::system::error_code ec) { 737e13c2760SPrzemyslaw Czarnowski if (ec) 738e13c2760SPrzemyslaw Czarnowski { 739e13c2760SPrzemyslaw Czarnowski BMCWEB_LOG_ERROR << "Bad D-Bus request error: " << ec; 740e13c2760SPrzemyslaw Czarnowski 741e13c2760SPrzemyslaw Czarnowski messages::internalError(asyncResp->res); 742e13c2760SPrzemyslaw Czarnowski return; 743e13c2760SPrzemyslaw Czarnowski } 744e13c2760SPrzemyslaw Czarnowski }, 745e13c2760SPrzemyslaw Czarnowski service, "/xyz/openbmc_project/VirtualMedia/Legacy/" + name, 746e13c2760SPrzemyslaw Czarnowski "xyz.openbmc_project.VirtualMedia.Legacy", "Unmount"); 747e13c2760SPrzemyslaw Czarnowski } 748e13c2760SPrzemyslaw Czarnowski else // proxy 749e13c2760SPrzemyslaw Czarnowski { 750e13c2760SPrzemyslaw Czarnowski crow::connections::systemBus->async_method_call( 751e13c2760SPrzemyslaw Czarnowski [asyncResp](const boost::system::error_code ec) { 752e13c2760SPrzemyslaw Czarnowski if (ec) 753e13c2760SPrzemyslaw Czarnowski { 754e13c2760SPrzemyslaw Czarnowski BMCWEB_LOG_ERROR << "Bad D-Bus request error: " << ec; 755e13c2760SPrzemyslaw Czarnowski 756e13c2760SPrzemyslaw Czarnowski messages::internalError(asyncResp->res); 757e13c2760SPrzemyslaw Czarnowski return; 758e13c2760SPrzemyslaw Czarnowski } 759e13c2760SPrzemyslaw Czarnowski }, 760e13c2760SPrzemyslaw Czarnowski service, "/xyz/openbmc_project/VirtualMedia/Proxy/" + name, 761e13c2760SPrzemyslaw Czarnowski "xyz.openbmc_project.VirtualMedia.Proxy", "Unmount"); 762e13c2760SPrzemyslaw Czarnowski } 763e13c2760SPrzemyslaw Czarnowski } 764e13c2760SPrzemyslaw Czarnowski 76598be3e39SEd Tanous struct InsertMediaActionParams 76698be3e39SEd Tanous { 76798be3e39SEd Tanous std::string imageUrl; 76898be3e39SEd Tanous std::optional<std::string> userName; 76998be3e39SEd Tanous std::optional<std::string> password; 77098be3e39SEd Tanous std::optional<std::string> transferMethod; 77198be3e39SEd Tanous std::optional<std::string> transferProtocolType; 77298be3e39SEd Tanous std::optional<bool> writeProtected = true; 77398be3e39SEd Tanous std::optional<bool> inserted; 77498be3e39SEd Tanous }; 77598be3e39SEd Tanous 77622db1728SEd Tanous inline void requestNBDVirtualMediaRoutes(App& app) 777107077deSPrzemyslaw Czarnowski { 7780fda0f12SGeorge Liu BMCWEB_ROUTE( 7790fda0f12SGeorge Liu app, 7800fda0f12SGeorge Liu "/redfish/v1/Managers/<str>/VirtualMedia/<str>/Actions/VirtualMedia.InsertMedia") 781ed398213SEd Tanous .privileges(redfish::privileges::postVirtualMedia) 78222db1728SEd Tanous .methods(boost::beast::http::verb::post)( 78345ca1b86SEd Tanous [&app](const crow::Request& req, 78422db1728SEd Tanous const std::shared_ptr<bmcweb::AsyncResp>& asyncResp, 78522db1728SEd Tanous const std::string& name, const std::string& resName) { 7863ba00073SCarson Labrado if (!redfish::setUpRedfishRoute(app, req, asyncResp)) 78745ca1b86SEd Tanous { 78845ca1b86SEd Tanous return; 78945ca1b86SEd Tanous } 79022db1728SEd Tanous if (name != "bmc") 791107077deSPrzemyslaw Czarnowski { 792002d39b4SEd Tanous messages::resourceNotFound(asyncResp->res, "VirtualMedia.Insert", 793002d39b4SEd Tanous resName); 794107077deSPrzemyslaw Czarnowski 795107077deSPrzemyslaw Czarnowski return; 796107077deSPrzemyslaw Czarnowski } 79798be3e39SEd Tanous InsertMediaActionParams actionParams; 79898be3e39SEd Tanous 79998be3e39SEd Tanous // Read obligatory parameters (url of 80098be3e39SEd Tanous // image) 80115ed6780SWilly Tu if (!json_util::readJsonAction( 80298be3e39SEd Tanous req, asyncResp->res, "Image", actionParams.imageUrl, 803002d39b4SEd Tanous "WriteProtected", actionParams.writeProtected, "UserName", 804002d39b4SEd Tanous actionParams.userName, "Password", actionParams.password, 805002d39b4SEd Tanous "Inserted", actionParams.inserted, "TransferMethod", 80698be3e39SEd Tanous actionParams.transferMethod, "TransferProtocolType", 80798be3e39SEd Tanous actionParams.transferProtocolType)) 80898be3e39SEd Tanous { 80998be3e39SEd Tanous BMCWEB_LOG_DEBUG << "Image is not provided"; 81098be3e39SEd Tanous return; 81198be3e39SEd Tanous } 81298be3e39SEd Tanous 81398be3e39SEd Tanous bool paramsValid = validateParams( 814002d39b4SEd Tanous asyncResp->res, actionParams.imageUrl, actionParams.inserted, 815002d39b4SEd Tanous actionParams.transferMethod, actionParams.transferProtocolType); 81698be3e39SEd Tanous 817e05aec50SEd Tanous if (!paramsValid) 81898be3e39SEd Tanous { 81998be3e39SEd Tanous return; 82098be3e39SEd Tanous } 821107077deSPrzemyslaw Czarnowski 82222db1728SEd Tanous crow::connections::systemBus->async_method_call( 823002d39b4SEd Tanous [asyncResp, actionParams, resName]( 824002d39b4SEd Tanous const boost::system::error_code ec, 825002d39b4SEd Tanous const dbus::utility::MapperGetObject& getObjectType) mutable { 82622db1728SEd Tanous if (ec) 82722db1728SEd Tanous { 828002d39b4SEd Tanous BMCWEB_LOG_ERROR << "ObjectMapper::GetObject call failed: " 82922db1728SEd Tanous << ec; 83022db1728SEd Tanous messages::internalError(asyncResp->res); 831107077deSPrzemyslaw Czarnowski 83222db1728SEd Tanous return; 83322db1728SEd Tanous } 83422db1728SEd Tanous std::string service = getObjectType.begin()->first; 83522db1728SEd Tanous BMCWEB_LOG_DEBUG << "GetObjectType: " << service; 83622db1728SEd Tanous 83722db1728SEd Tanous crow::connections::systemBus->async_method_call( 83898be3e39SEd Tanous [service, resName, actionParams, 83922db1728SEd Tanous asyncResp](const boost::system::error_code ec, 840002d39b4SEd Tanous dbus::utility::ManagedObjectType& subtree) mutable { 84122db1728SEd Tanous if (ec) 84222db1728SEd Tanous { 84322db1728SEd Tanous BMCWEB_LOG_DEBUG << "DBUS response error"; 84422db1728SEd Tanous 84522db1728SEd Tanous return; 84622db1728SEd Tanous } 84722db1728SEd Tanous 84822db1728SEd Tanous for (const auto& object : subtree) 84922db1728SEd Tanous { 85022db1728SEd Tanous const std::string& path = 851002d39b4SEd Tanous static_cast<const std::string&>(object.first); 85222db1728SEd Tanous 85322db1728SEd Tanous std::size_t lastIndex = path.rfind('/'); 85422db1728SEd Tanous if (lastIndex == std::string::npos) 85522db1728SEd Tanous { 85622db1728SEd Tanous continue; 85722db1728SEd Tanous } 85822db1728SEd Tanous 85922db1728SEd Tanous lastIndex += 1; 86022db1728SEd Tanous 86122db1728SEd Tanous if (path.substr(lastIndex) == resName) 86222db1728SEd Tanous { 86322db1728SEd Tanous lastIndex = path.rfind("Proxy"); 86422db1728SEd Tanous if (lastIndex != std::string::npos) 86522db1728SEd Tanous { 86622db1728SEd Tanous // Not possible in proxy mode 867002d39b4SEd Tanous BMCWEB_LOG_DEBUG << "InsertMedia not " 86822db1728SEd Tanous "allowed in proxy mode"; 86922db1728SEd Tanous messages::resourceNotFound( 870002d39b4SEd Tanous asyncResp->res, "VirtualMedia.InsertMedia", 87122db1728SEd Tanous resName); 87222db1728SEd Tanous 87322db1728SEd Tanous return; 87422db1728SEd Tanous } 87522db1728SEd Tanous 87622db1728SEd Tanous lastIndex = path.rfind("Legacy"); 87722db1728SEd Tanous if (lastIndex == std::string::npos) 87822db1728SEd Tanous { 87922db1728SEd Tanous continue; 88022db1728SEd Tanous } 88122db1728SEd Tanous 88222db1728SEd Tanous // manager is irrelevant for 88322db1728SEd Tanous // VirtualMedia dbus calls 884002d39b4SEd Tanous doMountVmLegacy(asyncResp, service, resName, 88598be3e39SEd Tanous actionParams.imageUrl, 88698be3e39SEd Tanous !(*actionParams.writeProtected), 88798be3e39SEd Tanous std::move(*actionParams.userName), 88898be3e39SEd Tanous std::move(*actionParams.password)); 88922db1728SEd Tanous 89022db1728SEd Tanous return; 89122db1728SEd Tanous } 89222db1728SEd Tanous } 89322db1728SEd Tanous BMCWEB_LOG_DEBUG << "Parent item not found"; 894002d39b4SEd Tanous messages::resourceNotFound(asyncResp->res, "VirtualMedia", 895002d39b4SEd Tanous resName); 89622db1728SEd Tanous }, 89722db1728SEd Tanous service, "/xyz/openbmc_project/VirtualMedia", 898002d39b4SEd Tanous "org.freedesktop.DBus.ObjectManager", "GetManagedObjects"); 89922db1728SEd Tanous }, 90022db1728SEd Tanous "xyz.openbmc_project.ObjectMapper", 90122db1728SEd Tanous "/xyz/openbmc_project/object_mapper", 90222db1728SEd Tanous "xyz.openbmc_project.ObjectMapper", "GetObject", 903002d39b4SEd Tanous "/xyz/openbmc_project/VirtualMedia", std::array<const char*, 0>()); 90422db1728SEd Tanous }); 90522db1728SEd Tanous 9060fda0f12SGeorge Liu BMCWEB_ROUTE( 9070fda0f12SGeorge Liu app, 9080fda0f12SGeorge Liu "/redfish/v1/Managers/<str>/VirtualMedia/<str>/Actions/VirtualMedia.EjectMedia") 909ed398213SEd Tanous .privileges(redfish::privileges::postVirtualMedia) 91022db1728SEd Tanous .methods(boost::beast::http::verb::post)( 91145ca1b86SEd Tanous [&app](const crow::Request& req, 91222db1728SEd Tanous const std::shared_ptr<bmcweb::AsyncResp>& asyncResp, 91322db1728SEd Tanous const std::string& name, const std::string& resName) { 9143ba00073SCarson Labrado if (!redfish::setUpRedfishRoute(app, req, asyncResp)) 91545ca1b86SEd Tanous { 91645ca1b86SEd Tanous return; 91745ca1b86SEd Tanous } 918107077deSPrzemyslaw Czarnowski if (name != "bmc") 919107077deSPrzemyslaw Czarnowski { 920002d39b4SEd Tanous messages::resourceNotFound(asyncResp->res, "VirtualMedia.Eject", 921002d39b4SEd Tanous resName); 92222db1728SEd Tanous 92322db1728SEd Tanous return; 92422db1728SEd Tanous } 92522db1728SEd Tanous 92622db1728SEd Tanous crow::connections::systemBus->async_method_call( 927002d39b4SEd Tanous [asyncResp, 928002d39b4SEd Tanous resName](const boost::system::error_code ec, 929b9d36b47SEd Tanous const dbus::utility::MapperGetObject& getObjectType) { 93022db1728SEd Tanous if (ec) 93122db1728SEd Tanous { 932002d39b4SEd Tanous BMCWEB_LOG_ERROR << "ObjectMapper::GetObject call failed: " 93322db1728SEd Tanous << ec; 93422db1728SEd Tanous messages::internalError(asyncResp->res); 93522db1728SEd Tanous 93622db1728SEd Tanous return; 93722db1728SEd Tanous } 93822db1728SEd Tanous std::string service = getObjectType.begin()->first; 93922db1728SEd Tanous BMCWEB_LOG_DEBUG << "GetObjectType: " << service; 94022db1728SEd Tanous 94122db1728SEd Tanous crow::connections::systemBus->async_method_call( 94298be3e39SEd Tanous [resName, service, asyncResp{asyncResp}]( 94322db1728SEd Tanous const boost::system::error_code ec, 944711ac7a9SEd Tanous dbus::utility::ManagedObjectType& subtree) { 94522db1728SEd Tanous if (ec) 94622db1728SEd Tanous { 94722db1728SEd Tanous BMCWEB_LOG_DEBUG << "DBUS response error"; 94822db1728SEd Tanous 94922db1728SEd Tanous return; 95022db1728SEd Tanous } 95122db1728SEd Tanous 95222db1728SEd Tanous for (const auto& object : subtree) 95322db1728SEd Tanous { 95422db1728SEd Tanous const std::string& path = 955002d39b4SEd Tanous static_cast<const std::string&>(object.first); 95622db1728SEd Tanous 95722db1728SEd Tanous std::size_t lastIndex = path.rfind('/'); 95822db1728SEd Tanous if (lastIndex == std::string::npos) 95922db1728SEd Tanous { 96022db1728SEd Tanous continue; 96122db1728SEd Tanous } 96222db1728SEd Tanous 96322db1728SEd Tanous lastIndex += 1; 96422db1728SEd Tanous 96522db1728SEd Tanous if (path.substr(lastIndex) == resName) 96622db1728SEd Tanous { 96722db1728SEd Tanous lastIndex = path.rfind("Proxy"); 96822db1728SEd Tanous if (lastIndex != std::string::npos) 96922db1728SEd Tanous { 97022db1728SEd Tanous // Proxy mode 971002d39b4SEd Tanous doVmAction(asyncResp, service, resName, false); 97222db1728SEd Tanous } 97322db1728SEd Tanous 97422db1728SEd Tanous lastIndex = path.rfind("Legacy"); 97522db1728SEd Tanous if (lastIndex != std::string::npos) 97622db1728SEd Tanous { 97722db1728SEd Tanous // Legacy mode 978002d39b4SEd Tanous doVmAction(asyncResp, service, resName, true); 97922db1728SEd Tanous } 98022db1728SEd Tanous 98122db1728SEd Tanous return; 98222db1728SEd Tanous } 98322db1728SEd Tanous } 98422db1728SEd Tanous BMCWEB_LOG_DEBUG << "Parent item not found"; 985002d39b4SEd Tanous messages::resourceNotFound(asyncResp->res, "VirtualMedia", 986002d39b4SEd Tanous resName); 98722db1728SEd Tanous }, 98822db1728SEd Tanous service, "/xyz/openbmc_project/VirtualMedia", 989002d39b4SEd Tanous "org.freedesktop.DBus.ObjectManager", "GetManagedObjects"); 99022db1728SEd Tanous }, 99122db1728SEd Tanous "xyz.openbmc_project.ObjectMapper", 99222db1728SEd Tanous "/xyz/openbmc_project/object_mapper", 99322db1728SEd Tanous "xyz.openbmc_project.ObjectMapper", "GetObject", 994002d39b4SEd Tanous "/xyz/openbmc_project/VirtualMedia", std::array<const char*, 0>()); 99522db1728SEd Tanous }); 99622db1728SEd Tanous BMCWEB_ROUTE(app, "/redfish/v1/Managers/<str>/VirtualMedia/") 997ed398213SEd Tanous .privileges(redfish::privileges::getVirtualMediaCollection) 99822db1728SEd Tanous .methods(boost::beast::http::verb::get)( 99945ca1b86SEd Tanous [&app](const crow::Request& req, 100022db1728SEd Tanous const std::shared_ptr<bmcweb::AsyncResp>& asyncResp, 100122db1728SEd Tanous const std::string& name) { 10023ba00073SCarson Labrado if (!redfish::setUpRedfishRoute(app, req, asyncResp)) 100345ca1b86SEd Tanous { 100445ca1b86SEd Tanous return; 100545ca1b86SEd Tanous } 100622db1728SEd Tanous if (name != "bmc") 100722db1728SEd Tanous { 1008002d39b4SEd Tanous messages::resourceNotFound(asyncResp->res, "VirtualMedia", name); 1009107077deSPrzemyslaw Czarnowski 1010107077deSPrzemyslaw Czarnowski return; 1011107077deSPrzemyslaw Czarnowski } 1012107077deSPrzemyslaw Czarnowski 10138d1b46d7Szhanghch05 asyncResp->res.jsonValue["@odata.type"] = 1014107077deSPrzemyslaw Czarnowski "#VirtualMediaCollection.VirtualMediaCollection"; 10158d1b46d7Szhanghch05 asyncResp->res.jsonValue["Name"] = "Virtual Media Services"; 10168d1b46d7Szhanghch05 asyncResp->res.jsonValue["@odata.id"] = 1017d6c414f3SPrzemyslaw Czarnowski "/redfish/v1/Managers/" + name + "/VirtualMedia"; 1018107077deSPrzemyslaw Czarnowski 1019107077deSPrzemyslaw Czarnowski crow::connections::systemBus->async_method_call( 1020002d39b4SEd Tanous [asyncResp, 1021002d39b4SEd Tanous name](const boost::system::error_code ec, 1022b9d36b47SEd Tanous const dbus::utility::MapperGetObject& getObjectType) { 1023107077deSPrzemyslaw Czarnowski if (ec) 1024107077deSPrzemyslaw Czarnowski { 1025002d39b4SEd Tanous BMCWEB_LOG_ERROR << "ObjectMapper::GetObject call failed: " 1026107077deSPrzemyslaw Czarnowski << ec; 1027107077deSPrzemyslaw Czarnowski messages::internalError(asyncResp->res); 1028107077deSPrzemyslaw Czarnowski 1029107077deSPrzemyslaw Czarnowski return; 1030107077deSPrzemyslaw Czarnowski } 1031107077deSPrzemyslaw Czarnowski std::string service = getObjectType.begin()->first; 1032107077deSPrzemyslaw Czarnowski BMCWEB_LOG_DEBUG << "GetObjectType: " << service; 1033107077deSPrzemyslaw Czarnowski 1034107077deSPrzemyslaw Czarnowski getVmResourceList(asyncResp, service, name); 1035107077deSPrzemyslaw Czarnowski }, 1036107077deSPrzemyslaw Czarnowski "xyz.openbmc_project.ObjectMapper", 1037107077deSPrzemyslaw Czarnowski "/xyz/openbmc_project/object_mapper", 1038107077deSPrzemyslaw Czarnowski "xyz.openbmc_project.ObjectMapper", "GetObject", 1039002d39b4SEd Tanous "/xyz/openbmc_project/VirtualMedia", 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)( 104545ca1b86SEd Tanous [&app](const crow::Request& req, 104622db1728SEd Tanous const std::shared_ptr<bmcweb::AsyncResp>& asyncResp, 104722db1728SEd Tanous const std::string& name, const std::string& resName) { 10483ba00073SCarson Labrado if (!redfish::setUpRedfishRoute(app, req, asyncResp)) 104945ca1b86SEd Tanous { 105045ca1b86SEd Tanous return; 105145ca1b86SEd Tanous } 1052107077deSPrzemyslaw Czarnowski if (name != "bmc") 1053107077deSPrzemyslaw Czarnowski { 1054002d39b4SEd Tanous messages::resourceNotFound(asyncResp->res, "VirtualMedia", resName); 1055107077deSPrzemyslaw Czarnowski 1056107077deSPrzemyslaw Czarnowski return; 1057107077deSPrzemyslaw Czarnowski } 1058107077deSPrzemyslaw Czarnowski 1059107077deSPrzemyslaw Czarnowski crow::connections::systemBus->async_method_call( 1060002d39b4SEd Tanous [asyncResp, name, 1061002d39b4SEd Tanous resName](const boost::system::error_code ec, 1062b9d36b47SEd Tanous const dbus::utility::MapperGetObject& getObjectType) { 1063107077deSPrzemyslaw Czarnowski if (ec) 1064107077deSPrzemyslaw Czarnowski { 1065002d39b4SEd Tanous BMCWEB_LOG_ERROR << "ObjectMapper::GetObject call failed: " 1066107077deSPrzemyslaw Czarnowski << ec; 1067107077deSPrzemyslaw Czarnowski messages::internalError(asyncResp->res); 1068107077deSPrzemyslaw Czarnowski 1069107077deSPrzemyslaw Czarnowski return; 1070107077deSPrzemyslaw Czarnowski } 1071107077deSPrzemyslaw Czarnowski std::string service = getObjectType.begin()->first; 1072107077deSPrzemyslaw Czarnowski BMCWEB_LOG_DEBUG << "GetObjectType: " << service; 1073107077deSPrzemyslaw Czarnowski 1074107077deSPrzemyslaw Czarnowski getVmData(asyncResp, service, name, resName); 1075107077deSPrzemyslaw Czarnowski }, 1076107077deSPrzemyslaw Czarnowski "xyz.openbmc_project.ObjectMapper", 1077107077deSPrzemyslaw Czarnowski "/xyz/openbmc_project/object_mapper", 1078107077deSPrzemyslaw Czarnowski "xyz.openbmc_project.ObjectMapper", "GetObject", 1079002d39b4SEd Tanous "/xyz/openbmc_project/VirtualMedia", std::array<const char*, 0>()); 108022db1728SEd Tanous }); 1081107077deSPrzemyslaw Czarnowski } 1082107077deSPrzemyslaw Czarnowski 1083107077deSPrzemyslaw Czarnowski } // namespace redfish 1084