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