1 /*
2 * Copyright (c) 2023 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 #include "core/common/recorder/event_controller.h"
16
17 #include <algorithm>
18
19 #include "base/json/json_util.h"
20 #include "base/log/log_wrapper.h"
21 #include "base/thread/background_task_executor.h"
22 #include "core/common/recorder/node_data_cache.h"
23 #include "core/common/recorder/event_recorder.h"
24
25 namespace OHOS::Ace::Recorder {
Get()26 EventController& EventController::Get()
27 {
28 static EventController eventController;
29 return eventController;
30 }
31
Register(const std::string & config,const std::shared_ptr<UIEventObserver> & observer)32 void EventController::Register(const std::string& config, const std::shared_ptr<UIEventObserver>& observer)
33 {
34 UIEventClient client;
35 client.config.Init(config);
36 if (!client.config.IsEnable()) {
37 return;
38 }
39 client.observer = observer;
40 std::unique_lock<std::mutex> lock(cacheLock_);
41 clientList_.emplace_back(std::move(client));
42 NotifyConfigChange();
43 }
44
NotifyConfigChange()45 void EventController::NotifyConfigChange()
46 {
47 auto mergedConfig = std::make_shared<MergedConfig>();
48 EventSwitch eventSwitch;
49 for (auto&& client : clientList_) {
50 if (!client.config.IsEnable()) {
51 continue;
52 }
53 eventSwitch.pageEnable = eventSwitch.pageEnable || client.config.IsCategoryEnable(EventCategory::CATEGORY_PAGE);
54 eventSwitch.exposureEnable =
55 eventSwitch.exposureEnable || client.config.IsCategoryEnable(EventCategory::CATEGORY_EXPOSURE);
56 eventSwitch.componentEnable =
57 eventSwitch.componentEnable || client.config.IsCategoryEnable(EventCategory::CATEGORY_COMPONENT);
58 for (auto iter = client.config.GetConfig()->begin(); iter != client.config.GetConfig()->end(); iter++) {
59 auto nodeIt = mergedConfig->shareNodes.find(iter->first);
60 if (nodeIt != mergedConfig->shareNodes.end()) {
61 std::for_each(iter->second.shareNodes.begin(), iter->second.shareNodes.end(),
62 [&nodeIt](const std::list<std::string>::value_type& id) { nodeIt->second.emplace(id); });
63 } else {
64 std::unordered_set<std::string> nodeSet;
65 std::for_each(iter->second.shareNodes.begin(), iter->second.shareNodes.end(),
66 [&nodeSet](const std::list<std::string>::value_type& id) { nodeSet.emplace(id); });
67 mergedConfig->shareNodes.emplace(iter->first, std::move(nodeSet));
68 }
69
70 auto exposureIt = mergedConfig->exposureNodes.find(iter->first);
71 if (exposureIt != mergedConfig->exposureNodes.end()) {
72 std::for_each(iter->second.exposureCfgs.begin(), iter->second.exposureCfgs.end(),
73 [&exposureIt](
74 const std::list<ExposureCfg>::value_type& cfg) { exposureIt->second.emplace(cfg); });
75 } else {
76 std::unordered_set<ExposureCfg, ExposureCfgHash> exposureSet;
77 std::for_each(iter->second.exposureCfgs.begin(), iter->second.exposureCfgs.end(),
78 [&exposureSet](const std::list<ExposureCfg>::value_type& cfg) { exposureSet.emplace(cfg); });
79 mergedConfig->exposureNodes.emplace(iter->first, std::move(exposureSet));
80 }
81 }
82 }
83 NodeDataCache::Get().UpdateConfig(std::move(mergedConfig));
84 EventRecorder::Get().UpdateEventSwitch(eventSwitch);
85 }
86
Unregister(const std::shared_ptr<UIEventObserver> & observer)87 void EventController::Unregister(const std::shared_ptr<UIEventObserver>& observer)
88 {
89 std::unique_lock<std::mutex> lock(cacheLock_);
90 auto iter = std::remove_if(clientList_.begin(), clientList_.end(),
91 [&observer](UIEventClient client) { return client.observer == observer; });
92 bool change = iter != clientList_.end();
93 clientList_.erase(iter, clientList_.end());
94 if (change) {
95 NotifyConfigChange();
96 }
97 }
98
NotifyEvent(EventCategory category,int32_t eventType,const std::shared_ptr<std::unordered_map<std::string,std::string>> & eventParams)99 void EventController::NotifyEvent(EventCategory category, int32_t eventType,
100 const std::shared_ptr<std::unordered_map<std::string, std::string>>& eventParams)
101 {
102 {
103 std::unique_lock<std::mutex> lock(cacheLock_);
104 if (clientList_.empty()) {
105 return;
106 }
107 }
108 BackgroundTaskExecutor::GetInstance().PostTask([category, eventType, eventParams]() {
109 EventController::Get().NotifyEventSync(category, eventType, eventParams);
110 });
111 }
112
NotifyEventSync(EventCategory category,int32_t eventType,const std::shared_ptr<std::unordered_map<std::string,std::string>> & eventParams)113 void EventController::NotifyEventSync(EventCategory category, int32_t eventType,
114 const std::shared_ptr<std::unordered_map<std::string, std::string>>& eventParams)
115 {
116 std::unique_lock<std::mutex> lock(cacheLock_);
117 for (auto&& client : clientList_) {
118 if (client.config.IsEnable() && client.config.IsCategoryEnable(category)) {
119 client.observer->NotifyUIEvent(eventType, *eventParams);
120 }
121 }
122 }
123 } // namespace OHOS::Ace::Recorder
124