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 */ 3467df073bSEd Tanous inline std::string getTransferProtocolTypeFromUri(const std::string& imageUri) 3567df073bSEd Tanous { 3667df073bSEd Tanous boost::urls::result<boost::urls::url_view> url = 3767df073bSEd Tanous boost::urls::parse_uri(boost::string_view(imageUri)); 3867df073bSEd Tanous if (!url) 3967df073bSEd Tanous { 4067df073bSEd Tanous return "None"; 4167df073bSEd Tanous } 4267df073bSEd Tanous boost::string_view scheme = url->scheme(); 4367df073bSEd Tanous if (scheme == "smb") 4467df073bSEd Tanous { 4567df073bSEd Tanous return "CIFS"; 4667df073bSEd Tanous } 4767df073bSEd Tanous if (scheme == "https") 4867df073bSEd Tanous { 4967df073bSEd Tanous return "HTTPS"; 5067df073bSEd Tanous } 5167df073bSEd Tanous 5267df073bSEd Tanous return "None"; 5367df073bSEd Tanous } 54107077deSPrzemyslaw Czarnowski 55107077deSPrzemyslaw Czarnowski /** 56107077deSPrzemyslaw Czarnowski * @brief Read all known properties from VM object interfaces 57107077deSPrzemyslaw Czarnowski */ 5822db1728SEd Tanous inline void 59711ac7a9SEd Tanous vmParseInterfaceObject(const dbus::utility::DBusInteracesMap& interface, 608d1b46d7Szhanghch05 const std::shared_ptr<bmcweb::AsyncResp>& aResp) 61107077deSPrzemyslaw Czarnowski { 62711ac7a9SEd Tanous for (const auto& [interface, values] : interface) 63107077deSPrzemyslaw Czarnowski { 64711ac7a9SEd Tanous if (interface == "xyz.openbmc_project.VirtualMedia.MountPoint") 65107077deSPrzemyslaw Czarnowski { 66711ac7a9SEd Tanous for (const auto& [property, value] : values) 67107077deSPrzemyslaw Czarnowski { 68711ac7a9SEd Tanous if (property == "EndpointId") 69107077deSPrzemyslaw Czarnowski { 70107077deSPrzemyslaw Czarnowski const std::string* endpointIdValue = 71711ac7a9SEd Tanous std::get_if<std::string>(&value); 72711ac7a9SEd Tanous if (endpointIdValue == nullptr) 73107077deSPrzemyslaw Czarnowski { 74711ac7a9SEd Tanous continue; 75711ac7a9SEd Tanous } 76107077deSPrzemyslaw Czarnowski if (!endpointIdValue->empty()) 77107077deSPrzemyslaw Czarnowski { 78107077deSPrzemyslaw Czarnowski // Proxy mode 79711ac7a9SEd Tanous aResp->res 80711ac7a9SEd Tanous .jsonValue["Oem"]["OpenBMC"]["WebSocketEndpoint"] = 81d04ba325SPrzemyslaw Czarnowski *endpointIdValue; 82107077deSPrzemyslaw Czarnowski aResp->res.jsonValue["TransferProtocolType"] = "OEM"; 83107077deSPrzemyslaw Czarnowski } 84107077deSPrzemyslaw Czarnowski } 85711ac7a9SEd Tanous if (property == "ImageURL") 86107077deSPrzemyslaw Czarnowski { 87107077deSPrzemyslaw Czarnowski const std::string* imageUrlValue = 88711ac7a9SEd Tanous std::get_if<std::string>(&value); 8926f6976fSEd Tanous if (imageUrlValue != nullptr && !imageUrlValue->empty()) 90107077deSPrzemyslaw Czarnowski { 91da4784d8SPrzemyslaw Czarnowski std::filesystem::path filePath = *imageUrlValue; 92da4784d8SPrzemyslaw Czarnowski if (!filePath.has_filename()) 93da4784d8SPrzemyslaw Czarnowski { 949e319cf0SAnna Platash // this will handle https share, which not 959e319cf0SAnna Platash // necessarily has to have filename given. 96da4784d8SPrzemyslaw Czarnowski aResp->res.jsonValue["ImageName"] = ""; 97da4784d8SPrzemyslaw Czarnowski } 98da4784d8SPrzemyslaw Czarnowski else 99da4784d8SPrzemyslaw Czarnowski { 1009e319cf0SAnna Platash aResp->res.jsonValue["ImageName"] = 1019e319cf0SAnna Platash filePath.filename(); 102da4784d8SPrzemyslaw Czarnowski } 103da4784d8SPrzemyslaw Czarnowski 104da4784d8SPrzemyslaw Czarnowski aResp->res.jsonValue["Image"] = *imageUrlValue; 1059e319cf0SAnna Platash aResp->res.jsonValue["TransferProtocolType"] = 1069e319cf0SAnna Platash getTransferProtocolTypeFromUri(*imageUrlValue); 1079e319cf0SAnna Platash 108107077deSPrzemyslaw Czarnowski aResp->res.jsonValue["ConnectedVia"] = "URI"; 109107077deSPrzemyslaw Czarnowski } 110107077deSPrzemyslaw Czarnowski } 111711ac7a9SEd Tanous if (property == "WriteProtected") 1129e319cf0SAnna Platash { 113711ac7a9SEd Tanous const bool* writeProtectedValue = std::get_if<bool>(&value); 114e662eae8SEd Tanous if (writeProtectedValue != nullptr) 1159e319cf0SAnna Platash { 1169e319cf0SAnna Platash aResp->res.jsonValue["WriteProtected"] = 1179e319cf0SAnna Platash *writeProtectedValue; 1189e319cf0SAnna Platash } 1199e319cf0SAnna Platash } 1209e319cf0SAnna Platash } 121107077deSPrzemyslaw Czarnowski } 122711ac7a9SEd Tanous if (interface == "xyz.openbmc_project.VirtualMedia.Process") 123711ac7a9SEd Tanous { 124711ac7a9SEd Tanous for (const auto& [property, value] : values) 125711ac7a9SEd Tanous { 126711ac7a9SEd Tanous if (property == "Active") 127711ac7a9SEd Tanous { 128711ac7a9SEd Tanous const bool* activeValue = std::get_if<bool>(&value); 129e662eae8SEd Tanous if (activeValue == nullptr) 130711ac7a9SEd Tanous { 131711ac7a9SEd Tanous BMCWEB_LOG_DEBUG << "Value Active not found"; 132711ac7a9SEd Tanous return; 133711ac7a9SEd Tanous } 134711ac7a9SEd Tanous aResp->res.jsonValue["Inserted"] = *activeValue; 135711ac7a9SEd Tanous 136e05aec50SEd Tanous if (*activeValue) 137711ac7a9SEd Tanous { 138711ac7a9SEd Tanous aResp->res.jsonValue["ConnectedVia"] = "Applet"; 139711ac7a9SEd Tanous } 140711ac7a9SEd Tanous } 141711ac7a9SEd Tanous } 142711ac7a9SEd Tanous } 143107077deSPrzemyslaw Czarnowski } 144107077deSPrzemyslaw Czarnowski } 145107077deSPrzemyslaw Czarnowski 146107077deSPrzemyslaw Czarnowski /** 147107077deSPrzemyslaw Czarnowski * @brief Fill template for Virtual Media Item. 148107077deSPrzemyslaw Czarnowski */ 14922db1728SEd Tanous inline nlohmann::json vmItemTemplate(const std::string& name, 150107077deSPrzemyslaw Czarnowski const std::string& resName) 151107077deSPrzemyslaw Czarnowski { 152107077deSPrzemyslaw Czarnowski nlohmann::json item; 15322db1728SEd Tanous 15422db1728SEd Tanous std::string id = "/redfish/v1/Managers/"; 15522db1728SEd Tanous id += name; 15622db1728SEd Tanous id += "/VirtualMedia/"; 15722db1728SEd Tanous id += resName; 15822db1728SEd Tanous item["@odata.id"] = std::move(id); 15922db1728SEd Tanous 160d04ba325SPrzemyslaw Czarnowski item["@odata.type"] = "#VirtualMedia.v1_3_0.VirtualMedia"; 161107077deSPrzemyslaw Czarnowski item["Name"] = "Virtual Removable Media"; 162107077deSPrzemyslaw Czarnowski item["Id"] = resName; 163107077deSPrzemyslaw Czarnowski item["WriteProtected"] = true; 164107077deSPrzemyslaw Czarnowski item["MediaTypes"] = {"CD", "USBStick"}; 165107077deSPrzemyslaw Czarnowski item["TransferMethod"] = "Stream"; 166d04ba325SPrzemyslaw Czarnowski item["Oem"]["OpenBMC"]["@odata.type"] = 167d04ba325SPrzemyslaw Czarnowski "#OemVirtualMedia.v1_0_0.VirtualMedia"; 168107077deSPrzemyslaw Czarnowski 169107077deSPrzemyslaw Czarnowski return item; 170107077deSPrzemyslaw Czarnowski } 171107077deSPrzemyslaw Czarnowski 172107077deSPrzemyslaw Czarnowski /** 173107077deSPrzemyslaw Czarnowski * @brief Fills collection data 174107077deSPrzemyslaw Czarnowski */ 17522db1728SEd Tanous inline void getVmResourceList(std::shared_ptr<bmcweb::AsyncResp> aResp, 176107077deSPrzemyslaw Czarnowski const std::string& service, 177107077deSPrzemyslaw Czarnowski const std::string& name) 178107077deSPrzemyslaw Czarnowski { 179107077deSPrzemyslaw Czarnowski BMCWEB_LOG_DEBUG << "Get available Virtual Media resources."; 180107077deSPrzemyslaw Czarnowski crow::connections::systemBus->async_method_call( 181711ac7a9SEd Tanous [name, 182711ac7a9SEd Tanous aResp{std::move(aResp)}](const boost::system::error_code ec, 183711ac7a9SEd Tanous dbus::utility::ManagedObjectType& subtree) { 184107077deSPrzemyslaw Czarnowski if (ec) 185107077deSPrzemyslaw Czarnowski { 186107077deSPrzemyslaw Czarnowski BMCWEB_LOG_DEBUG << "DBUS response error"; 187107077deSPrzemyslaw Czarnowski return; 188107077deSPrzemyslaw Czarnowski } 189107077deSPrzemyslaw Czarnowski nlohmann::json& members = aResp->res.jsonValue["Members"]; 190107077deSPrzemyslaw Czarnowski members = nlohmann::json::array(); 191107077deSPrzemyslaw Czarnowski 192107077deSPrzemyslaw Czarnowski for (const auto& object : subtree) 193107077deSPrzemyslaw Czarnowski { 194107077deSPrzemyslaw Czarnowski nlohmann::json item; 1952dfd18efSEd Tanous std::string path = object.first.filename(); 1962dfd18efSEd Tanous if (path.empty()) 197107077deSPrzemyslaw Czarnowski { 198107077deSPrzemyslaw Czarnowski continue; 199107077deSPrzemyslaw Czarnowski } 200107077deSPrzemyslaw Czarnowski 20122db1728SEd Tanous std::string id = "/redfish/v1/Managers/"; 20222db1728SEd Tanous id += name; 20322db1728SEd Tanous id += "/VirtualMedia/"; 20422db1728SEd Tanous id += path; 205107077deSPrzemyslaw Czarnowski 20622db1728SEd Tanous item["@odata.id"] = std::move(id); 207107077deSPrzemyslaw Czarnowski members.emplace_back(std::move(item)); 208107077deSPrzemyslaw Czarnowski } 209107077deSPrzemyslaw Czarnowski aResp->res.jsonValue["Members@odata.count"] = members.size(); 210107077deSPrzemyslaw Czarnowski }, 211107077deSPrzemyslaw Czarnowski service, "/xyz/openbmc_project/VirtualMedia", 212107077deSPrzemyslaw Czarnowski "org.freedesktop.DBus.ObjectManager", "GetManagedObjects"); 213107077deSPrzemyslaw Czarnowski } 214107077deSPrzemyslaw Czarnowski 215107077deSPrzemyslaw Czarnowski /** 216107077deSPrzemyslaw Czarnowski * @brief Fills data for specific resource 217107077deSPrzemyslaw Czarnowski */ 21822db1728SEd Tanous inline void getVmData(const std::shared_ptr<bmcweb::AsyncResp>& aResp, 219107077deSPrzemyslaw Czarnowski const std::string& service, const std::string& name, 220107077deSPrzemyslaw Czarnowski const std::string& resName) 221107077deSPrzemyslaw Czarnowski { 222107077deSPrzemyslaw Czarnowski BMCWEB_LOG_DEBUG << "Get Virtual Media resource data."; 223107077deSPrzemyslaw Czarnowski 224107077deSPrzemyslaw Czarnowski crow::connections::systemBus->async_method_call( 225914e2d5dSEd Tanous [resName, name, 226914e2d5dSEd Tanous aResp](const boost::system::error_code ec, 227914e2d5dSEd Tanous const 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 235914e2d5dSEd Tanous for (const 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 */ 30867df073bSEd Tanous inline std::optional<TransferProtocol> 30967df073bSEd Tanous getTransferProtocolFromUri(const std::string& imageUri) 31067df073bSEd Tanous { 31167df073bSEd Tanous boost::urls::result<boost::urls::url_view> url = 31267df073bSEd Tanous boost::urls::parse_uri(boost::string_view(imageUri)); 31367df073bSEd Tanous if (!url) 31467df073bSEd Tanous { 31567df073bSEd Tanous return {}; 31667df073bSEd Tanous } 31767df073bSEd Tanous 31867df073bSEd Tanous boost::string_view scheme = url->scheme(); 31967df073bSEd Tanous if (scheme == "smb") 32067df073bSEd Tanous { 32167df073bSEd Tanous return TransferProtocol::smb; 32267df073bSEd Tanous } 32367df073bSEd Tanous if (scheme == "https") 32467df073bSEd Tanous { 32567df073bSEd Tanous return TransferProtocol::https; 32667df073bSEd Tanous } 32767df073bSEd Tanous if (!scheme.empty()) 32867df073bSEd Tanous { 32967df073bSEd Tanous return TransferProtocol::invalid; 33067df073bSEd Tanous } 33167df073bSEd Tanous 33267df073bSEd Tanous return {}; 33367df073bSEd Tanous } 334c6f4e017SAgata Olender 335c6f4e017SAgata Olender /** 336c6f4e017SAgata Olender * @brief Function convert transfer protocol from string param. 337c6f4e017SAgata Olender * 338c6f4e017SAgata Olender */ 33922db1728SEd Tanous inline std::optional<TransferProtocol> getTransferProtocolFromParam( 340c6f4e017SAgata Olender const std::optional<std::string>& transferProtocolType) 341c6f4e017SAgata Olender { 342c6f4e017SAgata Olender if (transferProtocolType == std::nullopt) 343c6f4e017SAgata Olender { 344c6f4e017SAgata Olender return {}; 345c6f4e017SAgata Olender } 346c6f4e017SAgata Olender 347c6f4e017SAgata Olender if (*transferProtocolType == "CIFS") 348c6f4e017SAgata Olender { 349c6f4e017SAgata Olender return TransferProtocol::smb; 350c6f4e017SAgata Olender } 351c6f4e017SAgata Olender 352c6f4e017SAgata Olender if (*transferProtocolType == "HTTPS") 353c6f4e017SAgata Olender { 354c6f4e017SAgata Olender return TransferProtocol::https; 355c6f4e017SAgata Olender } 356c6f4e017SAgata Olender 357c6f4e017SAgata Olender return TransferProtocol::invalid; 358c6f4e017SAgata Olender } 359c6f4e017SAgata Olender 360c6f4e017SAgata Olender /** 361c6f4e017SAgata Olender * @brief Function extends URI with transfer protocol type. 362c6f4e017SAgata Olender * 363c6f4e017SAgata Olender */ 36422db1728SEd Tanous inline std::string 365c6f4e017SAgata Olender getUriWithTransferProtocol(const std::string& imageUri, 366c6f4e017SAgata Olender const TransferProtocol& transferProtocol) 367c6f4e017SAgata Olender { 368c6f4e017SAgata Olender if (transferProtocol == TransferProtocol::smb) 369c6f4e017SAgata Olender { 370c6f4e017SAgata Olender return "smb://" + imageUri; 371c6f4e017SAgata Olender } 372c6f4e017SAgata Olender 373c6f4e017SAgata Olender if (transferProtocol == TransferProtocol::https) 374c6f4e017SAgata Olender { 375c6f4e017SAgata Olender return "https://" + imageUri; 376c6f4e017SAgata Olender } 377c6f4e017SAgata Olender 378c6f4e017SAgata Olender return imageUri; 379c6f4e017SAgata Olender } 380c6f4e017SAgata Olender 381c6f4e017SAgata Olender /** 382c6f4e017SAgata Olender * @brief Function validate parameters of insert media request. 383c6f4e017SAgata Olender * 384c6f4e017SAgata Olender */ 38522db1728SEd Tanous inline bool 38622db1728SEd Tanous validateParams(crow::Response& res, std::string& imageUrl, 387c6f4e017SAgata Olender const std::optional<bool>& inserted, 388c6f4e017SAgata Olender const std::optional<std::string>& transferMethod, 389c6f4e017SAgata Olender const std::optional<std::string>& transferProtocolType) 390c6f4e017SAgata Olender { 391c6f4e017SAgata Olender BMCWEB_LOG_DEBUG << "Validation started"; 392c6f4e017SAgata Olender // required param imageUrl must not be empty 393c6f4e017SAgata Olender if (imageUrl.empty()) 394c6f4e017SAgata Olender { 395c6f4e017SAgata Olender BMCWEB_LOG_ERROR << "Request action parameter Image is empty."; 396c6f4e017SAgata Olender 39722db1728SEd Tanous messages::propertyValueFormatError(res, "<empty>", "Image"); 398c6f4e017SAgata Olender 399c6f4e017SAgata Olender return false; 400c6f4e017SAgata Olender } 401c6f4e017SAgata Olender 402c6f4e017SAgata Olender // optional param inserted must be true 403e05aec50SEd Tanous if ((inserted != std::nullopt) && !*inserted) 404c6f4e017SAgata Olender { 405c6f4e017SAgata Olender BMCWEB_LOG_ERROR 406c6f4e017SAgata Olender << "Request action optional parameter Inserted must be true."; 407c6f4e017SAgata Olender 40822db1728SEd Tanous messages::actionParameterNotSupported(res, "Inserted", "InsertMedia"); 409c6f4e017SAgata Olender 410c6f4e017SAgata Olender return false; 411c6f4e017SAgata Olender } 412c6f4e017SAgata Olender 413c6f4e017SAgata Olender // optional param transferMethod must be stream 414c6f4e017SAgata Olender if ((transferMethod != std::nullopt) && (*transferMethod != "Stream")) 415c6f4e017SAgata Olender { 416c6f4e017SAgata Olender BMCWEB_LOG_ERROR << "Request action optional parameter " 417c6f4e017SAgata Olender "TransferMethod must be Stream."; 418c6f4e017SAgata Olender 41922db1728SEd Tanous messages::actionParameterNotSupported(res, "TransferMethod", 42022db1728SEd Tanous "InsertMedia"); 421c6f4e017SAgata Olender 422c6f4e017SAgata Olender return false; 423c6f4e017SAgata Olender } 424c6f4e017SAgata Olender 425c6f4e017SAgata Olender std::optional<TransferProtocol> uriTransferProtocolType = 426c6f4e017SAgata Olender getTransferProtocolFromUri(imageUrl); 427c6f4e017SAgata Olender 428c6f4e017SAgata Olender std::optional<TransferProtocol> paramTransferProtocolType = 429c6f4e017SAgata Olender getTransferProtocolFromParam(transferProtocolType); 430c6f4e017SAgata Olender 431c6f4e017SAgata Olender // ImageUrl does not contain valid protocol type 432c6f4e017SAgata Olender if (*uriTransferProtocolType == TransferProtocol::invalid) 433c6f4e017SAgata Olender { 434c6f4e017SAgata Olender BMCWEB_LOG_ERROR << "Request action parameter ImageUrl must " 435c6f4e017SAgata Olender "contain specified protocol type from list: " 436c6f4e017SAgata Olender "(smb, https)."; 437c6f4e017SAgata Olender 43822db1728SEd Tanous messages::resourceAtUriInUnknownFormat(res, imageUrl); 439c6f4e017SAgata Olender 440c6f4e017SAgata Olender return false; 441c6f4e017SAgata Olender } 442c6f4e017SAgata Olender 443c6f4e017SAgata Olender // transferProtocolType should contain value from list 444c6f4e017SAgata Olender if (*paramTransferProtocolType == TransferProtocol::invalid) 445c6f4e017SAgata Olender { 446c6f4e017SAgata Olender BMCWEB_LOG_ERROR << "Request action parameter TransferProtocolType " 447c6f4e017SAgata Olender "must be provided with value from list: " 448c6f4e017SAgata Olender "(CIFS, HTTPS)."; 449c6f4e017SAgata Olender 45022db1728SEd Tanous messages::propertyValueNotInList(res, *transferProtocolType, 45122db1728SEd Tanous "TransferProtocolType"); 452c6f4e017SAgata Olender return false; 453c6f4e017SAgata Olender } 454c6f4e017SAgata Olender 455c6f4e017SAgata Olender // valid transfer protocol not provided either with URI nor param 456c6f4e017SAgata Olender if ((uriTransferProtocolType == std::nullopt) && 457c6f4e017SAgata Olender (paramTransferProtocolType == std::nullopt)) 458c6f4e017SAgata Olender { 459c6f4e017SAgata Olender BMCWEB_LOG_ERROR << "Request action parameter ImageUrl must " 460c6f4e017SAgata Olender "contain specified protocol type or param " 461c6f4e017SAgata Olender "TransferProtocolType must be provided."; 462c6f4e017SAgata Olender 46322db1728SEd Tanous messages::resourceAtUriInUnknownFormat(res, imageUrl); 464c6f4e017SAgata Olender 465c6f4e017SAgata Olender return false; 466c6f4e017SAgata Olender } 467c6f4e017SAgata Olender 468c6f4e017SAgata Olender // valid transfer protocol provided both with URI and param 469c6f4e017SAgata Olender if ((paramTransferProtocolType != std::nullopt) && 470c6f4e017SAgata Olender (uriTransferProtocolType != std::nullopt)) 471c6f4e017SAgata Olender { 472c6f4e017SAgata Olender // check if protocol is the same for URI and param 473c6f4e017SAgata Olender if (*paramTransferProtocolType != *uriTransferProtocolType) 474c6f4e017SAgata Olender { 475c6f4e017SAgata Olender BMCWEB_LOG_ERROR << "Request action parameter " 476c6f4e017SAgata Olender "TransferProtocolType must contain the " 477c6f4e017SAgata Olender "same protocol type as protocol type " 478c6f4e017SAgata Olender "provided with param imageUrl."; 479c6f4e017SAgata Olender 48022db1728SEd Tanous messages::actionParameterValueTypeError(res, *transferProtocolType, 48122db1728SEd Tanous "TransferProtocolType", 48222db1728SEd Tanous "InsertMedia"); 483c6f4e017SAgata Olender 484c6f4e017SAgata Olender return false; 485c6f4e017SAgata Olender } 486c6f4e017SAgata Olender } 487c6f4e017SAgata Olender 488c6f4e017SAgata Olender // validation passed 489c6f4e017SAgata Olender // add protocol to URI if needed 490c6f4e017SAgata Olender if (uriTransferProtocolType == std::nullopt) 491c6f4e017SAgata Olender { 49222db1728SEd Tanous imageUrl = 49322db1728SEd Tanous getUriWithTransferProtocol(imageUrl, *paramTransferProtocolType); 494c6f4e017SAgata Olender } 495c6f4e017SAgata Olender 496c6f4e017SAgata Olender return true; 497c6f4e017SAgata Olender } 498c6f4e017SAgata Olender 4991214b7e7SGunnar Mills template <typename T> 5001214b7e7SGunnar Mills static void secureCleanup(T& value) 501988fb7b2SAdrian Ambrożewicz { 5024ecc618fSEd Tanous // NOLINTNEXTLINE(cppcoreguidelines-pro-type-const-cast) 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; 533ecd6a3a2SEd Tanous Credentials(Credentials&&) = delete; 534ecd6a3a2SEd Tanous Credentials& operator=(Credentials&&) = delete; 535988fb7b2SAdrian Ambrożewicz 53622db1728SEd Tanous private: 537988fb7b2SAdrian Ambrożewicz std::string userBuf; 538988fb7b2SAdrian Ambrożewicz std::string passBuf; 539988fb7b2SAdrian Ambrożewicz }; 540988fb7b2SAdrian Ambrożewicz 541988fb7b2SAdrian Ambrożewicz class CredentialsProvider 542988fb7b2SAdrian Ambrożewicz { 543988fb7b2SAdrian Ambrożewicz public: 5441214b7e7SGunnar Mills template <typename T> 5451214b7e7SGunnar Mills struct Deleter 546988fb7b2SAdrian Ambrożewicz { 547988fb7b2SAdrian Ambrożewicz void operator()(T* buff) const 548988fb7b2SAdrian Ambrożewicz { 549988fb7b2SAdrian Ambrożewicz if (buff) 550988fb7b2SAdrian Ambrożewicz { 551988fb7b2SAdrian Ambrożewicz secureCleanup(*buff); 552988fb7b2SAdrian Ambrożewicz delete buff; 553988fb7b2SAdrian Ambrożewicz } 554988fb7b2SAdrian Ambrożewicz } 555988fb7b2SAdrian Ambrożewicz }; 556988fb7b2SAdrian Ambrożewicz 557988fb7b2SAdrian Ambrożewicz using Buffer = std::vector<char>; 558988fb7b2SAdrian Ambrożewicz using SecureBuffer = std::unique_ptr<Buffer, Deleter<Buffer>>; 559988fb7b2SAdrian Ambrożewicz // Using explicit definition instead of std::function to avoid implicit 560988fb7b2SAdrian Ambrożewicz // conversions eg. stack copy instead of reference 561988fb7b2SAdrian Ambrożewicz using FormatterFunc = void(const std::string& username, 562988fb7b2SAdrian Ambrożewicz const std::string& password, Buffer& dest); 563988fb7b2SAdrian Ambrożewicz 564988fb7b2SAdrian Ambrożewicz CredentialsProvider(std::string&& user, std::string&& password) : 565988fb7b2SAdrian Ambrożewicz credentials(std::move(user), std::move(password)) 5661214b7e7SGunnar Mills {} 567988fb7b2SAdrian Ambrożewicz 568988fb7b2SAdrian Ambrożewicz const std::string& user() 569988fb7b2SAdrian Ambrożewicz { 570988fb7b2SAdrian Ambrożewicz return credentials.user(); 571988fb7b2SAdrian Ambrożewicz } 572988fb7b2SAdrian Ambrożewicz 573988fb7b2SAdrian Ambrożewicz const std::string& password() 574988fb7b2SAdrian Ambrożewicz { 575988fb7b2SAdrian Ambrożewicz return credentials.password(); 576988fb7b2SAdrian Ambrożewicz } 577988fb7b2SAdrian Ambrożewicz 57881ce609eSEd Tanous SecureBuffer pack(FormatterFunc formatter) 579988fb7b2SAdrian Ambrożewicz { 580988fb7b2SAdrian Ambrożewicz SecureBuffer packed{new Buffer{}}; 581e662eae8SEd Tanous if (formatter != nullptr) 582988fb7b2SAdrian Ambrożewicz { 583988fb7b2SAdrian Ambrożewicz formatter(credentials.user(), credentials.password(), *packed); 584988fb7b2SAdrian Ambrożewicz } 585988fb7b2SAdrian Ambrożewicz 586988fb7b2SAdrian Ambrożewicz return packed; 587988fb7b2SAdrian Ambrożewicz } 588988fb7b2SAdrian Ambrożewicz 589988fb7b2SAdrian Ambrożewicz private: 590988fb7b2SAdrian Ambrożewicz Credentials credentials; 591988fb7b2SAdrian Ambrożewicz }; 592988fb7b2SAdrian Ambrożewicz 593988fb7b2SAdrian Ambrożewicz // Wrapper for boost::async_pipe ensuring proper pipe cleanup 5941214b7e7SGunnar Mills template <typename Buffer> 5951214b7e7SGunnar Mills class Pipe 596988fb7b2SAdrian Ambrożewicz { 597988fb7b2SAdrian Ambrożewicz public: 598988fb7b2SAdrian Ambrożewicz using unix_fd = sdbusplus::message::unix_fd; 599988fb7b2SAdrian Ambrożewicz 600988fb7b2SAdrian Ambrożewicz Pipe(boost::asio::io_context& io, Buffer&& buffer) : 601988fb7b2SAdrian Ambrożewicz impl(io), buffer{std::move(buffer)} 6021214b7e7SGunnar Mills {} 603988fb7b2SAdrian Ambrożewicz 604988fb7b2SAdrian Ambrożewicz ~Pipe() 605988fb7b2SAdrian Ambrożewicz { 606988fb7b2SAdrian Ambrożewicz // Named pipe needs to be explicitly removed 607988fb7b2SAdrian Ambrożewicz impl.close(); 608988fb7b2SAdrian Ambrożewicz } 609988fb7b2SAdrian Ambrożewicz 610ecd6a3a2SEd Tanous Pipe(const Pipe&) = delete; 611ecd6a3a2SEd Tanous Pipe(Pipe&&) = delete; 612ecd6a3a2SEd Tanous Pipe& operator=(const Pipe&) = delete; 613ecd6a3a2SEd Tanous Pipe& operator=(Pipe&&) = delete; 614ecd6a3a2SEd Tanous 615988fb7b2SAdrian Ambrożewicz unix_fd fd() 616988fb7b2SAdrian Ambrożewicz { 617988fb7b2SAdrian Ambrożewicz return unix_fd{impl.native_source()}; 618988fb7b2SAdrian Ambrożewicz } 619988fb7b2SAdrian Ambrożewicz 620988fb7b2SAdrian Ambrożewicz template <typename WriteHandler> 62181ce609eSEd Tanous void asyncWrite(WriteHandler&& handler) 622988fb7b2SAdrian Ambrożewicz { 623988fb7b2SAdrian Ambrożewicz impl.async_write_some(data(), std::forward<WriteHandler>(handler)); 624988fb7b2SAdrian Ambrożewicz } 625988fb7b2SAdrian Ambrożewicz 626988fb7b2SAdrian Ambrożewicz private: 627988fb7b2SAdrian Ambrożewicz // Specialization for pointer types 628988fb7b2SAdrian Ambrożewicz template <typename B = Buffer> 629988fb7b2SAdrian Ambrożewicz typename std::enable_if<boost::has_dereference<B>::value, 630988fb7b2SAdrian Ambrożewicz boost::asio::const_buffer>::type 631988fb7b2SAdrian Ambrożewicz data() 632988fb7b2SAdrian Ambrożewicz { 633988fb7b2SAdrian Ambrożewicz return boost::asio::buffer(*buffer); 634988fb7b2SAdrian Ambrożewicz } 635988fb7b2SAdrian Ambrożewicz 636988fb7b2SAdrian Ambrożewicz template <typename B = Buffer> 637988fb7b2SAdrian Ambrożewicz typename std::enable_if<!boost::has_dereference<B>::value, 638988fb7b2SAdrian Ambrożewicz boost::asio::const_buffer>::type 639988fb7b2SAdrian Ambrożewicz data() 640988fb7b2SAdrian Ambrożewicz { 641988fb7b2SAdrian Ambrożewicz return boost::asio::buffer(buffer); 642988fb7b2SAdrian Ambrożewicz } 643988fb7b2SAdrian Ambrożewicz 644988fb7b2SAdrian Ambrożewicz const std::string name; 645988fb7b2SAdrian Ambrożewicz boost::process::async_pipe impl; 646988fb7b2SAdrian Ambrożewicz Buffer buffer; 647988fb7b2SAdrian Ambrożewicz }; 648988fb7b2SAdrian Ambrożewicz 649e13c2760SPrzemyslaw Czarnowski /** 650e13c2760SPrzemyslaw Czarnowski * @brief Function transceives data with dbus directly. 651e13c2760SPrzemyslaw Czarnowski * 652e13c2760SPrzemyslaw Czarnowski * All BMC state properties will be retrieved before sending reset request. 653e13c2760SPrzemyslaw Czarnowski */ 65422db1728SEd Tanous inline void doMountVmLegacy(const std::shared_ptr<bmcweb::AsyncResp>& asyncResp, 655e13c2760SPrzemyslaw Czarnowski const std::string& service, const std::string& name, 656988fb7b2SAdrian Ambrożewicz const std::string& imageUrl, const bool rw, 657988fb7b2SAdrian Ambrożewicz std::string&& userName, std::string&& password) 658e13c2760SPrzemyslaw Czarnowski { 659988fb7b2SAdrian Ambrożewicz using SecurePipe = Pipe<CredentialsProvider::SecureBuffer>; 660988fb7b2SAdrian Ambrożewicz constexpr const size_t secretLimit = 1024; 661988fb7b2SAdrian Ambrożewicz 662988fb7b2SAdrian Ambrożewicz std::shared_ptr<SecurePipe> secretPipe; 663168e20c1SEd Tanous dbus::utility::DbusVariantType unixFd = -1; 664988fb7b2SAdrian Ambrożewicz 665988fb7b2SAdrian Ambrożewicz if (!userName.empty() || !password.empty()) 666988fb7b2SAdrian Ambrożewicz { 667988fb7b2SAdrian Ambrożewicz // Encapsulate in safe buffer 668988fb7b2SAdrian Ambrożewicz CredentialsProvider credentials(std::move(userName), 669988fb7b2SAdrian Ambrożewicz std::move(password)); 670988fb7b2SAdrian Ambrożewicz 671988fb7b2SAdrian Ambrożewicz // Payload must contain data + NULL delimiters 672988fb7b2SAdrian Ambrożewicz if (credentials.user().size() + credentials.password().size() + 2 > 673988fb7b2SAdrian Ambrożewicz secretLimit) 674988fb7b2SAdrian Ambrożewicz { 675988fb7b2SAdrian Ambrożewicz BMCWEB_LOG_ERROR << "Credentials too long to handle"; 676988fb7b2SAdrian Ambrożewicz messages::unrecognizedRequestBody(asyncResp->res); 677988fb7b2SAdrian Ambrożewicz return; 678988fb7b2SAdrian Ambrożewicz } 679988fb7b2SAdrian Ambrożewicz 680988fb7b2SAdrian Ambrożewicz // Pack secret 68122db1728SEd Tanous auto secret = credentials.pack( 68222db1728SEd Tanous [](const auto& user, const auto& pass, auto& buff) { 683988fb7b2SAdrian Ambrożewicz std::copy(user.begin(), user.end(), std::back_inserter(buff)); 684988fb7b2SAdrian Ambrożewicz buff.push_back('\0'); 685988fb7b2SAdrian Ambrożewicz std::copy(pass.begin(), pass.end(), std::back_inserter(buff)); 686988fb7b2SAdrian Ambrożewicz buff.push_back('\0'); 687988fb7b2SAdrian Ambrożewicz }); 688988fb7b2SAdrian Ambrożewicz 689988fb7b2SAdrian Ambrożewicz // Open pipe 690988fb7b2SAdrian Ambrożewicz secretPipe = std::make_shared<SecurePipe>( 69122db1728SEd Tanous crow::connections::systemBus->get_io_context(), std::move(secret)); 692988fb7b2SAdrian Ambrożewicz unixFd = secretPipe->fd(); 693988fb7b2SAdrian Ambrożewicz 694988fb7b2SAdrian Ambrożewicz // Pass secret over pipe 69581ce609eSEd Tanous secretPipe->asyncWrite( 696f5b16f03SVikram Bodireddy [asyncResp](const boost::system::error_code& ec, std::size_t) { 697988fb7b2SAdrian Ambrożewicz if (ec) 698988fb7b2SAdrian Ambrożewicz { 699988fb7b2SAdrian Ambrożewicz BMCWEB_LOG_ERROR << "Failed to pass secret: " << ec; 700988fb7b2SAdrian Ambrożewicz messages::internalError(asyncResp->res); 701988fb7b2SAdrian Ambrożewicz } 702988fb7b2SAdrian Ambrożewicz }); 703988fb7b2SAdrian Ambrożewicz } 704988fb7b2SAdrian Ambrożewicz 705e13c2760SPrzemyslaw Czarnowski crow::connections::systemBus->async_method_call( 706988fb7b2SAdrian Ambrożewicz [asyncResp, secretPipe](const boost::system::error_code ec, 707988fb7b2SAdrian Ambrożewicz bool success) { 708e13c2760SPrzemyslaw Czarnowski if (ec) 709e13c2760SPrzemyslaw Czarnowski { 710e13c2760SPrzemyslaw Czarnowski BMCWEB_LOG_ERROR << "Bad D-Bus request error: " << ec; 711e13c2760SPrzemyslaw Czarnowski messages::internalError(asyncResp->res); 712d6da5bebSAdrian Ambrożewicz } 713d6da5bebSAdrian Ambrożewicz else if (!success) 714d6da5bebSAdrian Ambrożewicz { 715d6da5bebSAdrian Ambrożewicz BMCWEB_LOG_ERROR << "Service responded with error"; 716d6da5bebSAdrian Ambrożewicz messages::generalError(asyncResp->res); 717e13c2760SPrzemyslaw Czarnowski } 718e13c2760SPrzemyslaw Czarnowski }, 719e13c2760SPrzemyslaw Czarnowski service, "/xyz/openbmc_project/VirtualMedia/Legacy/" + name, 720988fb7b2SAdrian Ambrożewicz "xyz.openbmc_project.VirtualMedia.Legacy", "Mount", imageUrl, rw, 721988fb7b2SAdrian Ambrożewicz unixFd); 722e13c2760SPrzemyslaw Czarnowski } 723e13c2760SPrzemyslaw Czarnowski 724e13c2760SPrzemyslaw Czarnowski /** 725e13c2760SPrzemyslaw Czarnowski * @brief Function transceives data with dbus directly. 726e13c2760SPrzemyslaw Czarnowski * 727e13c2760SPrzemyslaw Czarnowski * All BMC state properties will be retrieved before sending reset request. 728e13c2760SPrzemyslaw Czarnowski */ 72922db1728SEd Tanous inline void doVmAction(const std::shared_ptr<bmcweb::AsyncResp>& asyncResp, 730e13c2760SPrzemyslaw Czarnowski const std::string& service, const std::string& name, 731e13c2760SPrzemyslaw Czarnowski bool legacy) 732e13c2760SPrzemyslaw Czarnowski { 733e13c2760SPrzemyslaw Czarnowski 734e13c2760SPrzemyslaw Czarnowski // Legacy mount requires parameter with image 735e13c2760SPrzemyslaw Czarnowski if (legacy) 736e13c2760SPrzemyslaw Czarnowski { 737e13c2760SPrzemyslaw Czarnowski crow::connections::systemBus->async_method_call( 738e13c2760SPrzemyslaw Czarnowski [asyncResp](const boost::system::error_code ec) { 739e13c2760SPrzemyslaw Czarnowski if (ec) 740e13c2760SPrzemyslaw Czarnowski { 741e13c2760SPrzemyslaw Czarnowski BMCWEB_LOG_ERROR << "Bad D-Bus request error: " << ec; 742e13c2760SPrzemyslaw Czarnowski 743e13c2760SPrzemyslaw Czarnowski messages::internalError(asyncResp->res); 744e13c2760SPrzemyslaw Czarnowski return; 745e13c2760SPrzemyslaw Czarnowski } 746e13c2760SPrzemyslaw Czarnowski }, 747e13c2760SPrzemyslaw Czarnowski service, "/xyz/openbmc_project/VirtualMedia/Legacy/" + name, 748e13c2760SPrzemyslaw Czarnowski "xyz.openbmc_project.VirtualMedia.Legacy", "Unmount"); 749e13c2760SPrzemyslaw Czarnowski } 750e13c2760SPrzemyslaw Czarnowski else // proxy 751e13c2760SPrzemyslaw Czarnowski { 752e13c2760SPrzemyslaw Czarnowski crow::connections::systemBus->async_method_call( 753e13c2760SPrzemyslaw Czarnowski [asyncResp](const boost::system::error_code ec) { 754e13c2760SPrzemyslaw Czarnowski if (ec) 755e13c2760SPrzemyslaw Czarnowski { 756e13c2760SPrzemyslaw Czarnowski BMCWEB_LOG_ERROR << "Bad D-Bus request error: " << ec; 757e13c2760SPrzemyslaw Czarnowski 758e13c2760SPrzemyslaw Czarnowski messages::internalError(asyncResp->res); 759e13c2760SPrzemyslaw Czarnowski return; 760e13c2760SPrzemyslaw Czarnowski } 761e13c2760SPrzemyslaw Czarnowski }, 762e13c2760SPrzemyslaw Czarnowski service, "/xyz/openbmc_project/VirtualMedia/Proxy/" + name, 763e13c2760SPrzemyslaw Czarnowski "xyz.openbmc_project.VirtualMedia.Proxy", "Unmount"); 764e13c2760SPrzemyslaw Czarnowski } 765e13c2760SPrzemyslaw Czarnowski } 766e13c2760SPrzemyslaw Czarnowski 76798be3e39SEd Tanous struct InsertMediaActionParams 76898be3e39SEd Tanous { 76998be3e39SEd Tanous std::string imageUrl; 77098be3e39SEd Tanous std::optional<std::string> userName; 77198be3e39SEd Tanous std::optional<std::string> password; 77298be3e39SEd Tanous std::optional<std::string> transferMethod; 77398be3e39SEd Tanous std::optional<std::string> transferProtocolType; 77498be3e39SEd Tanous std::optional<bool> writeProtected = true; 77598be3e39SEd Tanous std::optional<bool> inserted; 77698be3e39SEd Tanous }; 77798be3e39SEd Tanous 77822db1728SEd Tanous inline void requestNBDVirtualMediaRoutes(App& app) 779107077deSPrzemyslaw Czarnowski { 7800fda0f12SGeorge Liu BMCWEB_ROUTE( 7810fda0f12SGeorge Liu app, 7820fda0f12SGeorge Liu "/redfish/v1/Managers/<str>/VirtualMedia/<str>/Actions/VirtualMedia.InsertMedia") 783ed398213SEd Tanous .privileges(redfish::privileges::postVirtualMedia) 78422db1728SEd Tanous .methods(boost::beast::http::verb::post)( 78522db1728SEd Tanous [](const crow::Request& req, 78622db1728SEd Tanous const std::shared_ptr<bmcweb::AsyncResp>& asyncResp, 78722db1728SEd Tanous const std::string& name, const std::string& resName) { 78822db1728SEd Tanous if (name != "bmc") 789107077deSPrzemyslaw Czarnowski { 79022db1728SEd Tanous messages::resourceNotFound(asyncResp->res, 79122db1728SEd Tanous "VirtualMedia.Insert", resName); 792107077deSPrzemyslaw Czarnowski 793107077deSPrzemyslaw Czarnowski return; 794107077deSPrzemyslaw Czarnowski } 79598be3e39SEd Tanous InsertMediaActionParams actionParams; 79698be3e39SEd Tanous 79798be3e39SEd Tanous // Read obligatory parameters (url of 79898be3e39SEd Tanous // image) 799*15ed6780SWilly Tu if (!json_util::readJsonAction( 80098be3e39SEd Tanous req, asyncResp->res, "Image", actionParams.imageUrl, 80198be3e39SEd Tanous "WriteProtected", actionParams.writeProtected, 80298be3e39SEd Tanous "UserName", actionParams.userName, "Password", 80398be3e39SEd Tanous actionParams.password, "Inserted", 80498be3e39SEd Tanous actionParams.inserted, "TransferMethod", 80598be3e39SEd Tanous actionParams.transferMethod, "TransferProtocolType", 80698be3e39SEd Tanous actionParams.transferProtocolType)) 80798be3e39SEd Tanous { 80898be3e39SEd Tanous BMCWEB_LOG_DEBUG << "Image is not provided"; 80998be3e39SEd Tanous return; 81098be3e39SEd Tanous } 81198be3e39SEd Tanous 81298be3e39SEd Tanous bool paramsValid = validateParams( 81398be3e39SEd Tanous asyncResp->res, actionParams.imageUrl, 81498be3e39SEd Tanous actionParams.inserted, actionParams.transferMethod, 81598be3e39SEd Tanous 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( 82398be3e39SEd Tanous [asyncResp, actionParams, 82422db1728SEd Tanous resName](const boost::system::error_code ec, 82598be3e39SEd Tanous const GetObjectType& getObjectType) mutable { 82622db1728SEd Tanous if (ec) 82722db1728SEd Tanous { 82822db1728SEd Tanous BMCWEB_LOG_ERROR 82922db1728SEd Tanous << "ObjectMapper::GetObject call failed: " 83022db1728SEd Tanous << ec; 83122db1728SEd Tanous messages::internalError(asyncResp->res); 832107077deSPrzemyslaw Czarnowski 83322db1728SEd Tanous return; 83422db1728SEd Tanous } 83522db1728SEd Tanous std::string service = getObjectType.begin()->first; 83622db1728SEd Tanous BMCWEB_LOG_DEBUG << "GetObjectType: " << service; 83722db1728SEd Tanous 83822db1728SEd Tanous crow::connections::systemBus->async_method_call( 83998be3e39SEd Tanous [service, resName, actionParams, 84022db1728SEd Tanous asyncResp](const boost::system::error_code ec, 841711ac7a9SEd Tanous dbus::utility::ManagedObjectType& 842711ac7a9SEd Tanous subtree) mutable { 84322db1728SEd Tanous if (ec) 84422db1728SEd Tanous { 84522db1728SEd Tanous BMCWEB_LOG_DEBUG << "DBUS response error"; 84622db1728SEd Tanous 84722db1728SEd Tanous return; 84822db1728SEd Tanous } 84922db1728SEd Tanous 85022db1728SEd Tanous for (const auto& object : subtree) 85122db1728SEd Tanous { 85222db1728SEd Tanous const std::string& path = 85322db1728SEd Tanous static_cast<const std::string&>( 85422db1728SEd Tanous object.first); 85522db1728SEd Tanous 85622db1728SEd Tanous std::size_t lastIndex = path.rfind('/'); 85722db1728SEd Tanous if (lastIndex == std::string::npos) 85822db1728SEd Tanous { 85922db1728SEd Tanous continue; 86022db1728SEd Tanous } 86122db1728SEd Tanous 86222db1728SEd Tanous lastIndex += 1; 86322db1728SEd Tanous 86422db1728SEd Tanous if (path.substr(lastIndex) == resName) 86522db1728SEd Tanous { 86622db1728SEd Tanous lastIndex = path.rfind("Proxy"); 86722db1728SEd Tanous if (lastIndex != std::string::npos) 86822db1728SEd Tanous { 86922db1728SEd Tanous // Not possible in proxy mode 87022db1728SEd Tanous BMCWEB_LOG_DEBUG 87122db1728SEd Tanous << "InsertMedia not " 87222db1728SEd Tanous "allowed in proxy mode"; 87322db1728SEd Tanous messages::resourceNotFound( 87422db1728SEd Tanous asyncResp->res, 87522db1728SEd Tanous "VirtualMedia.InsertMedia", 87622db1728SEd Tanous resName); 87722db1728SEd Tanous 87822db1728SEd Tanous return; 87922db1728SEd Tanous } 88022db1728SEd Tanous 88122db1728SEd Tanous lastIndex = path.rfind("Legacy"); 88222db1728SEd Tanous if (lastIndex == std::string::npos) 88322db1728SEd Tanous { 88422db1728SEd Tanous continue; 88522db1728SEd Tanous } 88622db1728SEd Tanous 88722db1728SEd Tanous // manager is irrelevant for 88822db1728SEd Tanous // VirtualMedia dbus calls 88998be3e39SEd Tanous doMountVmLegacy( 89098be3e39SEd Tanous asyncResp, service, resName, 89198be3e39SEd Tanous actionParams.imageUrl, 89298be3e39SEd Tanous !(*actionParams.writeProtected), 89398be3e39SEd Tanous std::move(*actionParams.userName), 89498be3e39SEd Tanous std::move(*actionParams.password)); 89522db1728SEd Tanous 89622db1728SEd Tanous return; 89722db1728SEd Tanous } 89822db1728SEd Tanous } 89922db1728SEd Tanous BMCWEB_LOG_DEBUG << "Parent item not found"; 90022db1728SEd Tanous messages::resourceNotFound( 90122db1728SEd Tanous asyncResp->res, "VirtualMedia", resName); 90222db1728SEd Tanous }, 90322db1728SEd Tanous service, "/xyz/openbmc_project/VirtualMedia", 90422db1728SEd Tanous "org.freedesktop.DBus.ObjectManager", 90522db1728SEd Tanous "GetManagedObjects"); 90622db1728SEd Tanous }, 90722db1728SEd Tanous "xyz.openbmc_project.ObjectMapper", 90822db1728SEd Tanous "/xyz/openbmc_project/object_mapper", 90922db1728SEd Tanous "xyz.openbmc_project.ObjectMapper", "GetObject", 91022db1728SEd Tanous "/xyz/openbmc_project/VirtualMedia", 91122db1728SEd Tanous std::array<const char*, 0>()); 91222db1728SEd Tanous }); 91322db1728SEd Tanous 9140fda0f12SGeorge Liu BMCWEB_ROUTE( 9150fda0f12SGeorge Liu app, 9160fda0f12SGeorge Liu "/redfish/v1/Managers/<str>/VirtualMedia/<str>/Actions/VirtualMedia.EjectMedia") 917ed398213SEd Tanous .privileges(redfish::privileges::postVirtualMedia) 91822db1728SEd Tanous .methods(boost::beast::http::verb::post)( 91998be3e39SEd Tanous [](const crow::Request&, 92022db1728SEd Tanous const std::shared_ptr<bmcweb::AsyncResp>& asyncResp, 92122db1728SEd Tanous const std::string& name, const std::string& resName) { 922107077deSPrzemyslaw Czarnowski if (name != "bmc") 923107077deSPrzemyslaw Czarnowski { 92422db1728SEd Tanous messages::resourceNotFound(asyncResp->res, 92522db1728SEd Tanous "VirtualMedia.Eject", resName); 92622db1728SEd Tanous 92722db1728SEd Tanous return; 92822db1728SEd Tanous } 92922db1728SEd Tanous 93022db1728SEd Tanous crow::connections::systemBus->async_method_call( 93198be3e39SEd Tanous [asyncResp, resName](const boost::system::error_code ec, 93222db1728SEd Tanous const GetObjectType& getObjectType) { 93322db1728SEd Tanous if (ec) 93422db1728SEd Tanous { 93522db1728SEd Tanous BMCWEB_LOG_ERROR 93622db1728SEd Tanous << "ObjectMapper::GetObject call failed: " 93722db1728SEd Tanous << ec; 93822db1728SEd Tanous messages::internalError(asyncResp->res); 93922db1728SEd Tanous 94022db1728SEd Tanous return; 94122db1728SEd Tanous } 94222db1728SEd Tanous std::string service = getObjectType.begin()->first; 94322db1728SEd Tanous BMCWEB_LOG_DEBUG << "GetObjectType: " << service; 94422db1728SEd Tanous 94522db1728SEd Tanous crow::connections::systemBus->async_method_call( 94698be3e39SEd Tanous [resName, service, asyncResp{asyncResp}]( 94722db1728SEd Tanous const boost::system::error_code ec, 948711ac7a9SEd Tanous dbus::utility::ManagedObjectType& subtree) { 94922db1728SEd Tanous if (ec) 95022db1728SEd Tanous { 95122db1728SEd Tanous BMCWEB_LOG_DEBUG << "DBUS response error"; 95222db1728SEd Tanous 95322db1728SEd Tanous return; 95422db1728SEd Tanous } 95522db1728SEd Tanous 95622db1728SEd Tanous for (const auto& object : subtree) 95722db1728SEd Tanous { 95822db1728SEd Tanous const std::string& path = 95922db1728SEd Tanous static_cast<const std::string&>( 96022db1728SEd Tanous object.first); 96122db1728SEd Tanous 96222db1728SEd Tanous std::size_t lastIndex = path.rfind('/'); 96322db1728SEd Tanous if (lastIndex == std::string::npos) 96422db1728SEd Tanous { 96522db1728SEd Tanous continue; 96622db1728SEd Tanous } 96722db1728SEd Tanous 96822db1728SEd Tanous lastIndex += 1; 96922db1728SEd Tanous 97022db1728SEd Tanous if (path.substr(lastIndex) == resName) 97122db1728SEd Tanous { 97222db1728SEd Tanous lastIndex = path.rfind("Proxy"); 97322db1728SEd Tanous if (lastIndex != std::string::npos) 97422db1728SEd Tanous { 97522db1728SEd Tanous // Proxy mode 97622db1728SEd Tanous doVmAction(asyncResp, service, 97722db1728SEd Tanous resName, false); 97822db1728SEd Tanous } 97922db1728SEd Tanous 98022db1728SEd Tanous lastIndex = path.rfind("Legacy"); 98122db1728SEd Tanous if (lastIndex != std::string::npos) 98222db1728SEd Tanous { 98322db1728SEd Tanous // Legacy mode 98422db1728SEd Tanous doVmAction(asyncResp, service, 98522db1728SEd Tanous resName, true); 98622db1728SEd Tanous } 98722db1728SEd Tanous 98822db1728SEd Tanous return; 98922db1728SEd Tanous } 99022db1728SEd Tanous } 99122db1728SEd Tanous BMCWEB_LOG_DEBUG << "Parent item not found"; 99222db1728SEd Tanous messages::resourceNotFound( 99322db1728SEd Tanous asyncResp->res, "VirtualMedia", resName); 99422db1728SEd Tanous }, 99522db1728SEd Tanous service, "/xyz/openbmc_project/VirtualMedia", 99622db1728SEd Tanous "org.freedesktop.DBus.ObjectManager", 99722db1728SEd Tanous "GetManagedObjects"); 99822db1728SEd Tanous }, 99922db1728SEd Tanous "xyz.openbmc_project.ObjectMapper", 100022db1728SEd Tanous "/xyz/openbmc_project/object_mapper", 100122db1728SEd Tanous "xyz.openbmc_project.ObjectMapper", "GetObject", 100222db1728SEd Tanous "/xyz/openbmc_project/VirtualMedia", 100322db1728SEd Tanous std::array<const char*, 0>()); 100422db1728SEd Tanous }); 100522db1728SEd Tanous BMCWEB_ROUTE(app, "/redfish/v1/Managers/<str>/VirtualMedia/") 1006ed398213SEd Tanous .privileges(redfish::privileges::getVirtualMediaCollection) 100722db1728SEd Tanous .methods(boost::beast::http::verb::get)( 100822db1728SEd Tanous [](const crow::Request& /* req */, 100922db1728SEd Tanous const std::shared_ptr<bmcweb::AsyncResp>& asyncResp, 101022db1728SEd Tanous const std::string& name) { 101122db1728SEd Tanous if (name != "bmc") 101222db1728SEd Tanous { 101322db1728SEd Tanous messages::resourceNotFound(asyncResp->res, "VirtualMedia", 101422db1728SEd Tanous name); 1015107077deSPrzemyslaw Czarnowski 1016107077deSPrzemyslaw Czarnowski return; 1017107077deSPrzemyslaw Czarnowski } 1018107077deSPrzemyslaw Czarnowski 10198d1b46d7Szhanghch05 asyncResp->res.jsonValue["@odata.type"] = 1020107077deSPrzemyslaw Czarnowski "#VirtualMediaCollection.VirtualMediaCollection"; 10218d1b46d7Szhanghch05 asyncResp->res.jsonValue["Name"] = "Virtual Media Services"; 10228d1b46d7Szhanghch05 asyncResp->res.jsonValue["@odata.id"] = 1023d6c414f3SPrzemyslaw Czarnowski "/redfish/v1/Managers/" + name + "/VirtualMedia"; 1024107077deSPrzemyslaw Czarnowski 1025107077deSPrzemyslaw Czarnowski crow::connections::systemBus->async_method_call( 1026107077deSPrzemyslaw Czarnowski [asyncResp, name](const boost::system::error_code ec, 1027107077deSPrzemyslaw Czarnowski const GetObjectType& getObjectType) { 1028107077deSPrzemyslaw Czarnowski if (ec) 1029107077deSPrzemyslaw Czarnowski { 103022db1728SEd Tanous BMCWEB_LOG_ERROR 103122db1728SEd Tanous << "ObjectMapper::GetObject call failed: " 1032107077deSPrzemyslaw Czarnowski << ec; 1033107077deSPrzemyslaw Czarnowski messages::internalError(asyncResp->res); 1034107077deSPrzemyslaw Czarnowski 1035107077deSPrzemyslaw Czarnowski return; 1036107077deSPrzemyslaw Czarnowski } 1037107077deSPrzemyslaw Czarnowski std::string service = getObjectType.begin()->first; 1038107077deSPrzemyslaw Czarnowski BMCWEB_LOG_DEBUG << "GetObjectType: " << service; 1039107077deSPrzemyslaw Czarnowski 1040107077deSPrzemyslaw Czarnowski getVmResourceList(asyncResp, service, name); 1041107077deSPrzemyslaw Czarnowski }, 1042107077deSPrzemyslaw Czarnowski "xyz.openbmc_project.ObjectMapper", 1043107077deSPrzemyslaw Czarnowski "/xyz/openbmc_project/object_mapper", 1044107077deSPrzemyslaw Czarnowski "xyz.openbmc_project.ObjectMapper", "GetObject", 104522db1728SEd Tanous "/xyz/openbmc_project/VirtualMedia", 104622db1728SEd Tanous std::array<const char*, 0>()); 104722db1728SEd Tanous }); 1048107077deSPrzemyslaw Czarnowski 104922db1728SEd Tanous BMCWEB_ROUTE(app, "/redfish/v1/Managers/<str>/VirtualMedia/<str>/") 1050ed398213SEd Tanous .privileges(redfish::privileges::getVirtualMedia) 105122db1728SEd Tanous .methods(boost::beast::http::verb::get)( 105222db1728SEd Tanous [](const crow::Request& /* req */, 105322db1728SEd Tanous const std::shared_ptr<bmcweb::AsyncResp>& asyncResp, 105422db1728SEd Tanous const std::string& name, const std::string& resName) { 1055107077deSPrzemyslaw Czarnowski if (name != "bmc") 1056107077deSPrzemyslaw Czarnowski { 105722db1728SEd Tanous messages::resourceNotFound(asyncResp->res, "VirtualMedia", 105822db1728SEd Tanous resName); 1059107077deSPrzemyslaw Czarnowski 1060107077deSPrzemyslaw Czarnowski return; 1061107077deSPrzemyslaw Czarnowski } 1062107077deSPrzemyslaw Czarnowski 1063107077deSPrzemyslaw Czarnowski crow::connections::systemBus->async_method_call( 106422db1728SEd Tanous [asyncResp, name, 106522db1728SEd Tanous resName](const boost::system::error_code ec, 1066107077deSPrzemyslaw Czarnowski const GetObjectType& getObjectType) { 1067107077deSPrzemyslaw Czarnowski if (ec) 1068107077deSPrzemyslaw Czarnowski { 106922db1728SEd Tanous BMCWEB_LOG_ERROR 107022db1728SEd Tanous << "ObjectMapper::GetObject call failed: " 1071107077deSPrzemyslaw Czarnowski << ec; 1072107077deSPrzemyslaw Czarnowski messages::internalError(asyncResp->res); 1073107077deSPrzemyslaw Czarnowski 1074107077deSPrzemyslaw Czarnowski return; 1075107077deSPrzemyslaw Czarnowski } 1076107077deSPrzemyslaw Czarnowski std::string service = getObjectType.begin()->first; 1077107077deSPrzemyslaw Czarnowski BMCWEB_LOG_DEBUG << "GetObjectType: " << service; 1078107077deSPrzemyslaw Czarnowski 1079107077deSPrzemyslaw Czarnowski getVmData(asyncResp, service, name, resName); 1080107077deSPrzemyslaw Czarnowski }, 1081107077deSPrzemyslaw Czarnowski "xyz.openbmc_project.ObjectMapper", 1082107077deSPrzemyslaw Czarnowski "/xyz/openbmc_project/object_mapper", 1083107077deSPrzemyslaw Czarnowski "xyz.openbmc_project.ObjectMapper", "GetObject", 108422db1728SEd Tanous "/xyz/openbmc_project/VirtualMedia", 108522db1728SEd Tanous std::array<const char*, 0>()); 108622db1728SEd Tanous }); 1087107077deSPrzemyslaw Czarnowski } 1088107077deSPrzemyslaw Czarnowski 1089107077deSPrzemyslaw Czarnowski } // namespace redfish 1090