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 #include "ndk_app_event_watcher_proxy.h"
17
18 #include "app_event_observer_mgr.h"
19 #include "hilog/log.h"
20 #include "hiappevent_base.h"
21 #include "app_event_store.h"
22
23 #undef LOG_DOMAIN
24 #define LOG_DOMAIN 0xD002D07
25
26 #undef LOG_TAG
27 #define LOG_TAG "NdkWatcherProxy"
28
29 namespace OHOS {
30 namespace HiviewDFX {
31
NdkAppEventWatcherProxy(const std::string & name)32 NdkAppEventWatcherProxy::NdkAppEventWatcherProxy(const std::string &name)
33 : watcher_(std::make_shared<NdkAppEventWatcher>(name)) {}
34
SetTriggerCondition(int row,int size,int timeOut)35 int NdkAppEventWatcherProxy::SetTriggerCondition(int row, int size, int timeOut)
36 {
37 watcher_->SetTriggerCondition(row, size, timeOut);
38 return 0;
39 }
40
SetAppEventFilter(const char * domain,uint8_t eventTypes,const char * const * names,int namesLen)41 int NdkAppEventWatcherProxy::SetAppEventFilter(const char *domain, uint8_t eventTypes,
42 const char *const *names, int namesLen)
43 {
44 return watcher_->AddAppEventFilter(domain, eventTypes, names, namesLen);
45 }
46
SetWatcherOnTrigger(OH_HiAppEvent_OnTrigger onTrigger)47 int NdkAppEventWatcherProxy::SetWatcherOnTrigger(OH_HiAppEvent_OnTrigger onTrigger)
48 {
49 watcher_->SetOnTrigger(onTrigger);
50 return 0;
51 }
52
SetWatcherOnReceiver(OH_HiAppEvent_OnReceive onReceiver)53 int NdkAppEventWatcherProxy::SetWatcherOnReceiver(OH_HiAppEvent_OnReceive onReceiver)
54 {
55 watcher_->SetOnOnReceive(onReceiver);
56 return 0;
57 }
58
AddWatcher()59 int NdkAppEventWatcherProxy::AddWatcher()
60 {
61 AppEventObserverMgr::GetInstance().RegisterObserver(watcher_);
62 return 0;
63 }
64
TakeWatcherData(uint32_t size,OH_HiAppEvent_OnTake onTake)65 int NdkAppEventWatcherProxy::TakeWatcherData(uint32_t size, OH_HiAppEvent_OnTake onTake)
66 {
67 if (onTake == nullptr) {
68 HILOG_WARN(LOG_CORE, "onTake is nullptr");
69 return ErrorCode::ERROR_INVALID_PARAM_VALUE;
70 }
71 if (watcher_->GetSeq() == 0) {
72 HILOG_WARN(LOG_CORE, "failed to query events, the observer has not been added");
73 return ErrorCode::ERROR_WATCHER_NOT_ADDED;
74 }
75 std::vector<std::shared_ptr<AppEventPack>> events;
76 if (AppEventStore::GetInstance().TakeEvents(events, watcher_->GetSeq(), size) != 0) {
77 HILOG_WARN(LOG_CORE, "failed to query events, seq=%{public}" PRId64, watcher_->GetSeq());
78 return ErrorCode::ERROR_UNKNOWN;
79 }
80 std::vector<std::string> eventStrs(events.size());
81 std::vector<const char*> retEvents(events.size());
82 for (size_t t = 0; t < events.size(); ++t) {
83 eventStrs[t] = events[t]->GetEventStr();
84 retEvents[t] = eventStrs[t].c_str();
85 }
86 onTake(retEvents.data(), static_cast<int32_t>(eventStrs.size()));
87 return 0;
88 }
89
RemoveWatcher()90 int NdkAppEventWatcherProxy::RemoveWatcher()
91 {
92 int64_t watcherSeq = watcher_->GetSeq();
93 if (watcherSeq > 0) {
94 AppEventObserverMgr::GetInstance().UnregisterObserver(watcherSeq);
95 watcher_->SetSeq(0);
96 return 0;
97 }
98 return ErrorCode::ERROR_WATCHER_NOT_ADDED;
99 }
100 }
101 }