1 /*
2  * Copyright (c) 2024 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 #ifndef OHOS_PACKAGE_COMMON_EVENT_H
17 #define OHOS_PACKAGE_COMMON_EVENT_H
18 
19 #include <functional>
20 #include <mutex>
21 #include <string>
22 #include <vector>
23 
24 #include "common_event_data.h"
25 #include "common_event_manager.h"
26 #include "common_event_subscribe_info.h"
27 #include "common_event_subscriber.h"
28 #include "matching_skills.h"
29 #include "system_ability_status_change_stub.h"
30 
31 namespace OHOS {
32 namespace DistributedHardware {
33 using OHOS::EventFwk::CommonEventData;
34 using OHOS::EventFwk::CommonEventSubscriber;
35 using OHOS::EventFwk::CommonEventSubscribeInfo;
36 using PackageEventCallback = std::function<void(std::string, std::string)>;
37 
38 class DmPackageEventSubscriber : public CommonEventSubscriber {
39 public:
DmPackageEventSubscriber(const CommonEventSubscribeInfo & subscribeInfo,const PackageEventCallback & callback,const std::vector<std::string> & eventNameVec)40     DmPackageEventSubscriber(const CommonEventSubscribeInfo &subscribeInfo, const PackageEventCallback &callback,
41         const std::vector<std::string> &eventNameVec) : CommonEventSubscriber(subscribeInfo),
42         eventNameVec_(eventNameVec), callback_(callback) {}
43     ~DmPackageEventSubscriber() override = default;
44     std::vector<std::string> GetSubscriberEventNameVec() const;
45     void OnReceiveEvent(const CommonEventData &data) override;
46 
47 private:
48     std::vector<std::string> eventNameVec_;
49     PackageEventCallback callback_;
50 };
51 
52 class DmPackageCommonEventManager {
53 public:
54     DmPackageCommonEventManager() = default;
55     ~DmPackageCommonEventManager();
56     bool SubscribePackageCommonEvent(const std::vector<std::string> &eventNameVec,
57         const PackageEventCallback &callback);
58     bool UnsubscribePackageCommonEvent();
59 
60 private:
61     std::vector<std::string> eventNameVec_;
62     bool eventValidFlag_ = false;
63     std::mutex evenSubscriberMutex_;
64     std::shared_ptr<DmPackageEventSubscriber> subscriber_ = nullptr;
65     sptr<ISystemAbilityStatusChange> statusChangeListener_ = nullptr;
66     int32_t counter_ = 0;
67 
68 private:
69     class SystemAbilityStatusChangeListener : public SystemAbilityStatusChangeStub {
70     public:
SystemAbilityStatusChangeListener(std::shared_ptr<DmPackageEventSubscriber> PackageSubscriber)71         explicit SystemAbilityStatusChangeListener(std::shared_ptr<DmPackageEventSubscriber> PackageSubscriber)
72             : changeSubscriber_(PackageSubscriber) {}
73         ~SystemAbilityStatusChangeListener() = default;
74         void OnAddSystemAbility(int32_t systemAbilityId, const std::string &deviceId) override;
75         void OnRemoveSystemAbility(int32_t systemAbilityId, const std::string &deviceId) override;
76 
77     private:
78         std::shared_ptr<DmPackageEventSubscriber> changeSubscriber_;
79     };
80 };
81 } // namespace DistributedHardware
82 } // namespace OHOS
83 #endif // OHOS_PACKAGE_COMMON_EVENT_H