1 /*
2 * Copyright (c) 2021-2022 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 "common_event_manager.h"
17
18 #include "common_event.h"
19 #include "common_event_constant.h"
20 #include "event_log_wrapper.h"
21 #include "singleton.h"
22
23 namespace OHOS {
24 namespace EventFwk {
PublishCommonEvent(const CommonEventData & data)25 bool CommonEventManager::PublishCommonEvent(const CommonEventData &data)
26 {
27 CommonEventPublishInfo publishInfo;
28 return PublishCommonEventAsUser(data, publishInfo, nullptr, UNDEFINED_USER);
29 }
30
PublishCommonEventAsUser(const CommonEventData & data,const int32_t & userId)31 bool CommonEventManager::PublishCommonEventAsUser(const CommonEventData &data, const int32_t &userId)
32 {
33 CommonEventPublishInfo publishInfo;
34 return PublishCommonEventAsUser(data, publishInfo, nullptr, userId);
35 }
36
PublishCommonEvent(const CommonEventData & data,const CommonEventPublishInfo & publishInfo)37 bool CommonEventManager::PublishCommonEvent(const CommonEventData &data, const CommonEventPublishInfo &publishInfo)
38 {
39 return NewPublishCommonEvent(data, publishInfo) == ERR_OK ? true : false;
40 }
41
NewPublishCommonEvent(const CommonEventData & data,const CommonEventPublishInfo & publishInfo)42 int32_t CommonEventManager::NewPublishCommonEvent(const CommonEventData &data,
43 const CommonEventPublishInfo &publishInfo)
44 {
45 return NewPublishCommonEventAsUser(data, publishInfo, nullptr, UNDEFINED_USER);
46 }
47
PublishCommonEventAsUser(const CommonEventData & data,const CommonEventPublishInfo & publishInfo,const int32_t & userId)48 bool CommonEventManager::PublishCommonEventAsUser(const CommonEventData &data,
49 const CommonEventPublishInfo &publishInfo, const int32_t &userId)
50 {
51 return NewPublishCommonEventAsUser(data, publishInfo, userId) == ERR_OK ? true : false;
52 }
53
NewPublishCommonEventAsUser(const CommonEventData & data,const CommonEventPublishInfo & publishInfo,const int32_t & userId)54 int32_t CommonEventManager::NewPublishCommonEventAsUser(const CommonEventData &data,
55 const CommonEventPublishInfo &publishInfo, const int32_t &userId)
56 {
57 return NewPublishCommonEventAsUser(data, publishInfo, nullptr, userId);
58 }
59
PublishCommonEvent(const CommonEventData & data,const CommonEventPublishInfo & publishInfo,const std::shared_ptr<CommonEventSubscriber> & subscriber)60 bool CommonEventManager::PublishCommonEvent(const CommonEventData &data, const CommonEventPublishInfo &publishInfo,
61 const std::shared_ptr<CommonEventSubscriber> &subscriber)
62 {
63 return PublishCommonEventAsUser(data, publishInfo, subscriber, UNDEFINED_USER);
64 }
65
PublishCommonEventAsUser(const CommonEventData & data,const CommonEventPublishInfo & publishInfo,const std::shared_ptr<CommonEventSubscriber> & subscriber,const int32_t & userId)66 bool CommonEventManager::PublishCommonEventAsUser(const CommonEventData &data,
67 const CommonEventPublishInfo &publishInfo, const std::shared_ptr<CommonEventSubscriber> &subscriber,
68 const int32_t &userId)
69 {
70 EVENT_LOGI("enter");
71 return NewPublishCommonEventAsUser(data, publishInfo, subscriber, userId) == ERR_OK ? true : false;
72 }
73
NewPublishCommonEventAsUser(const CommonEventData & data,const CommonEventPublishInfo & publishInfo,const std::shared_ptr<CommonEventSubscriber> & subscriber,const int32_t & userId)74 int32_t CommonEventManager::NewPublishCommonEventAsUser(const CommonEventData &data,
75 const CommonEventPublishInfo &publishInfo, const std::shared_ptr<CommonEventSubscriber> &subscriber,
76 const int32_t &userId)
77 {
78 EVENT_LOGI("enter");
79 return DelayedSingleton<CommonEvent>::GetInstance()->PublishCommonEventAsUser(data, publishInfo, subscriber,
80 userId);
81 }
82
PublishCommonEvent(const CommonEventData & data,const CommonEventPublishInfo & publishInfo,const std::shared_ptr<CommonEventSubscriber> & subscriber,const uid_t & uid,const int32_t & callerToken)83 bool CommonEventManager::PublishCommonEvent(const CommonEventData &data, const CommonEventPublishInfo &publishInfo,
84 const std::shared_ptr<CommonEventSubscriber> &subscriber, const uid_t &uid, const int32_t &callerToken)
85 {
86 return PublishCommonEventAsUser(data, publishInfo, subscriber, uid, callerToken, UNDEFINED_USER);
87 }
88
PublishCommonEventAsUser(const CommonEventData & data,const CommonEventPublishInfo & publishInfo,const std::shared_ptr<CommonEventSubscriber> & subscriber,const uid_t & uid,const int32_t & callerToken,const int32_t & userId)89 bool CommonEventManager::PublishCommonEventAsUser(const CommonEventData &data,
90 const CommonEventPublishInfo &publishInfo, const std::shared_ptr<CommonEventSubscriber> &subscriber,
91 const uid_t &uid, const int32_t &callerToken, const int32_t &userId)
92 {
93 EVENT_LOGI("enter");
94 return DelayedSingleton<CommonEvent>::GetInstance()->PublishCommonEventAsUser(data, publishInfo, subscriber, uid,
95 callerToken, userId);
96 }
97
SubscribeCommonEvent(const std::shared_ptr<CommonEventSubscriber> & subscriber)98 bool CommonEventManager::SubscribeCommonEvent(const std::shared_ptr<CommonEventSubscriber> &subscriber)
99 {
100 return NewSubscribeCommonEvent(subscriber) == ERR_OK ? true : false;
101 }
102
NewSubscribeCommonEvent(const std::shared_ptr<CommonEventSubscriber> & subscriber)103 int32_t CommonEventManager::NewSubscribeCommonEvent(const std::shared_ptr<CommonEventSubscriber> &subscriber)
104 {
105 return DelayedSingleton<CommonEvent>::GetInstance()->SubscribeCommonEvent(subscriber);
106 }
107
UnSubscribeCommonEvent(const std::shared_ptr<CommonEventSubscriber> & subscriber)108 bool CommonEventManager::UnSubscribeCommonEvent(const std::shared_ptr<CommonEventSubscriber> &subscriber)
109 {
110 return NewUnSubscribeCommonEvent(subscriber) == ERR_OK ? true : false;
111 }
112
NewUnSubscribeCommonEvent(const std::shared_ptr<CommonEventSubscriber> & subscriber)113 int32_t CommonEventManager::NewUnSubscribeCommonEvent(const std::shared_ptr<CommonEventSubscriber> &subscriber)
114 {
115 return DelayedSingleton<CommonEvent>::GetInstance()->UnSubscribeCommonEvent(subscriber);
116 }
117
GetStickyCommonEvent(const std::string & event,CommonEventData & commonEventData)118 bool CommonEventManager::GetStickyCommonEvent(const std::string &event, CommonEventData &commonEventData)
119 {
120 return DelayedSingleton<CommonEvent>::GetInstance()->GetStickyCommonEvent(event, commonEventData);
121 }
122
Freeze(const uid_t & uid)123 bool CommonEventManager::Freeze(const uid_t &uid)
124 {
125 return DelayedSingleton<CommonEvent>::GetInstance()->Freeze(uid);
126 }
127
Unfreeze(const uid_t & uid)128 bool CommonEventManager::Unfreeze(const uid_t &uid)
129 {
130 return DelayedSingleton<CommonEvent>::GetInstance()->Unfreeze(uid);
131 }
132
UnfreezeAll()133 bool CommonEventManager::UnfreezeAll()
134 {
135 return DelayedSingleton<CommonEvent>::GetInstance()->UnfreezeAll();
136 }
137 } // namespace EventFwk
138 } // namespace OHOS