1 /*
2 * Copyright (c) 2022-2025 Huawei Device Co., Ltd.
3 * Licensed under the Apache License, Version 2.0 (the "License");
4 * you may not use this file except in compliance with the License.
5 * You may obtain a copy of the License at
6 *
7 * http://www.apache.org/licenses/LICENSE-2.0
8 *
9 * Unless required by applicable law or agreed to in writing, software
10 * distributed under the License is distributed on an "AS IS" BASIS,
11 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12 * See the License for the specific language governing permissions and
13 * limitations under the License.
14 */
15
16 #include "plugin_listener_impl.h"
17
18 #include "anonymous_string.h"
19 #include "capability_info.h"
20 #include "capability_info_manager.h"
21 #include "dh_context.h"
22 #include "dh_utils_tool.h"
23 #include "distributed_hardware_errno.h"
24 #include "distributed_hardware_log.h"
25 #include "publisher.h"
26
27 namespace OHOS {
28 namespace DistributedHardware {
29 #undef DH_LOG_TAG
30 #define DH_LOG_TAG "PluginListenerImpl"
31
PluginHardware(const std::string & dhId,const std::string & attrs,const std::string & subtype)32 void PluginListenerImpl::PluginHardware(const std::string &dhId, const std::string &attrs, const std::string &subtype)
33 {
34 if (!IsIdLengthValid(dhId) || !IsMessageLengthValid(attrs)) {
35 return;
36 }
37 DHLOGI("plugin start, dhId: %{public}s", GetAnonyString(dhId).c_str());
38 std::vector<std::shared_ptr<CapabilityInfo>> capabilityInfos;
39 std::string deviceId = DHContext::GetInstance().GetDeviceInfo().deviceId;
40 std::string devName = DHContext::GetInstance().GetDeviceInfo().deviceName;
41 uint16_t devType = DHContext::GetInstance().GetDeviceInfo().deviceType;
42 std::shared_ptr<CapabilityInfo> dhCapabilityInfo =
43 std::make_shared<CapabilityInfo>(dhId, deviceId, devName, devType, dhType_, attrs, subtype);
44 capabilityInfos.push_back(dhCapabilityInfo);
45
46 CapabilityInfoManager::GetInstance()->AddCapability(capabilityInfos);
47 Publisher::GetInstance().PublishMessage(DHTopic::TOPIC_PHY_DEV_PLUGIN, dhId);
48 DHLOGI("plugin end, dhId: %{public}s", GetAnonyString(dhId).c_str());
49 }
50
UnPluginHardware(const std::string & dhId)51 void PluginListenerImpl::UnPluginHardware(const std::string &dhId)
52 {
53 if (!IsIdLengthValid(dhId)) {
54 return;
55 }
56 DHLOGI("unplugin start, dhId: %{public}s", GetAnonyString(dhId).c_str());
57 std::string deviceId = DHContext::GetInstance().GetDeviceInfo().deviceId;
58 std::shared_ptr<CapabilityInfo> capability = nullptr;
59 auto ret = CapabilityInfoManager::GetInstance()->GetCapability(deviceId, dhId, capability);
60 if ((ret != DH_FWK_SUCCESS) || (capability == nullptr)) {
61 DHLOGE("GetCapability failed, deviceId =%{public}s, dhId = %{public}s, errCode = %{public}d",
62 GetAnonyString(deviceId).c_str(), GetAnonyString(dhId).c_str(), ret);
63 return;
64 }
65 CapabilityInfoManager::GetInstance()->RemoveCapabilityInfoByKey(capability->GetKey());
66 DHLOGI("unplugin end, dhId: %{public}s", GetAnonyString(dhId).c_str());
67 }
68 } // namespace DistributedHardware
69 } // namespace OHOS
70