1 /*
2  * Copyright (c) 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 "event_log_wrapper.h"
17 #include "event_report.h"
18 
19 namespace OHOS {
20 namespace EventFwk {
21 namespace {
22 // event params
23 const std::string EVENT_PARAM_USER_ID = "USER_ID";
24 const std::string EVENT_PARAM_PID = "PID";
25 const std::string EVENT_PARAM_UID = "UID";
26 const std::string EVENT_PARAM_SUBSCRIBER_NUM = "SUBSCRIBER_NUM";
27 const std::string EVENT_PARAM_BUNDLE_NAME_OF_PUBLISHER = "BUNDLE_NAME_OF_PUBLISHER";
28 const std::string EVENT_PARAM_BUNDLE_NAME_OF_SUBSCRIBER = "BUNDLE_NAME_OF_SUBSCRIBER";
29 const std::string EVENT_PARAM_EVENT_NAME = "EVENT_NAME";
30 const std::string EVENT_PARAM_ABILITY_NAME = "ABILITY_NAME";
31 const std::string EVENT_PARAM_RESULT_CODE = "RESULT_CODE";
32 } // namespace
33 
SendHiSysEvent(const std::string & eventName,const EventInfo & eventInfo)34 void EventReport::SendHiSysEvent(const std::string &eventName, const EventInfo &eventInfo)
35 {
36 #ifndef HAS_HISYSEVENT_PART
37     EVENT_LOGD("Hisysevent is disabled");
38 #else
39     auto iter = cesSysEventFuncMap_.find(eventName);
40     if (iter == cesSysEventFuncMap_.end()) {
41         return;
42     }
43 
44     iter->second(eventInfo);
45 #endif
46 }
47 
48 #ifdef HAS_HISYSEVENT_PART
49 std::unordered_map<std::string, void (*)(const EventInfo& eventInfo)> EventReport::cesSysEventFuncMap_ = {
__anon7f9e31420202() 50     {ORDERED_EVENT_PROC_TIMEOUT, [](const EventInfo& eventInfo) {
51         InnerSendOrderedEventProcTimeoutEvent(eventInfo);
52     }},
__anon7f9e31420302() 53     {STATIC_EVENT_PROC_ERROR, [](const EventInfo& eventInfo) {
54         InnerSendStaticEventProcErrorEvent(eventInfo);
55     }},
__anon7f9e31420402() 56     {SUBSCRIBER_EXCEED_MAXIMUM, [](const EventInfo& eventInfo) {
57         InnerSendSubscriberExceedMaximumEvent(eventInfo);
58     }},
__anon7f9e31420502() 59     {PUBLISH_ERROR, [](const EventInfo& eventInfo) {
60         InnerSendPublishErrorEvent(eventInfo);
61     }},
__anon7f9e31420602() 62     {SUBSCRIBE, [](const EventInfo& eventInfo) {
63         InnerSendSubscribeEvent(eventInfo);
64     }},
__anon7f9e31420702() 65     {UNSUBSCRIBE, [](const EventInfo& eventInfo) {
66         InnerSendUnSubscribeEvent(eventInfo);
67     }},
__anon7f9e31420802() 68     {PUBLISH, [](const EventInfo& eventInfo) {
69         InnerSendPublishEvent(eventInfo);
70     }},
__anon7f9e31420902() 71     {STATIC_SUBSCRIBER_START, [](const EventInfo& eventInfo) {
72         InnerSendStaticSubStartEvent(eventInfo);
73     }},
__anon7f9e31420a02() 74     {STATIC_SUBSCRIBER_RUNTIME, [](const EventInfo& eventInfo) {
75         InnerSendStaticSubRunEvent(eventInfo);
76     }},
77 };
78 
InnerSendOrderedEventProcTimeoutEvent(const EventInfo & eventInfo)79 void EventReport::InnerSendOrderedEventProcTimeoutEvent(const EventInfo &eventInfo)
80 {
81     InnerEventWrite(
82         ORDERED_EVENT_PROC_TIMEOUT,
83         HiviewDFX::HiSysEvent::EventType::FAULT,
84         EVENT_PARAM_USER_ID, eventInfo.userId,
85         EVENT_PARAM_BUNDLE_NAME_OF_SUBSCRIBER, eventInfo.subscriberName,
86         EVENT_PARAM_PID, eventInfo.pid,
87         EVENT_PARAM_UID, eventInfo.uid,
88         EVENT_PARAM_EVENT_NAME, eventInfo.eventName);
89 }
90 
InnerSendStaticEventProcErrorEvent(const EventInfo & eventInfo)91 void EventReport::InnerSendStaticEventProcErrorEvent(const EventInfo &eventInfo)
92 {
93     InnerEventWrite(
94         STATIC_EVENT_PROC_ERROR,
95         HiviewDFX::HiSysEvent::EventType::FAULT,
96         EVENT_PARAM_USER_ID, eventInfo.userId,
97         EVENT_PARAM_BUNDLE_NAME_OF_PUBLISHER, eventInfo.publisherName,
98         EVENT_PARAM_BUNDLE_NAME_OF_SUBSCRIBER, eventInfo.subscriberName,
99         EVENT_PARAM_EVENT_NAME, eventInfo.eventName);
100 }
101 
InnerSendSubscriberExceedMaximumEvent(const EventInfo & eventInfo)102 void EventReport::InnerSendSubscriberExceedMaximumEvent(const EventInfo &eventInfo)
103 {
104     InnerEventWrite(
105         SUBSCRIBER_EXCEED_MAXIMUM,
106         HiviewDFX::HiSysEvent::EventType::FAULT,
107         EVENT_PARAM_USER_ID, eventInfo.userId,
108         EVENT_PARAM_EVENT_NAME, eventInfo.eventName,
109         EVENT_PARAM_SUBSCRIBER_NUM, eventInfo.subscriberNum);
110 }
111 
InnerSendPublishErrorEvent(const EventInfo & eventInfo)112 void EventReport::InnerSendPublishErrorEvent(const EventInfo &eventInfo)
113 {
114     InnerEventWrite(
115         PUBLISH_ERROR,
116         HiviewDFX::HiSysEvent::EventType::FAULT,
117         EVENT_PARAM_USER_ID, eventInfo.userId,
118         EVENT_PARAM_BUNDLE_NAME_OF_PUBLISHER, eventInfo.publisherName,
119         EVENT_PARAM_PID, eventInfo.pid,
120         EVENT_PARAM_UID, eventInfo.uid,
121         EVENT_PARAM_EVENT_NAME, eventInfo.eventName);
122 }
123 
InnerSendSubscribeEvent(const EventInfo & eventInfo)124 void EventReport::InnerSendSubscribeEvent(const EventInfo &eventInfo)
125 {
126     InnerEventWrite(
127         SUBSCRIBE,
128         HiviewDFX::HiSysEvent::EventType::STATISTIC,
129         EVENT_PARAM_USER_ID, eventInfo.userId,
130         EVENT_PARAM_BUNDLE_NAME_OF_SUBSCRIBER, eventInfo.subscriberName,
131         EVENT_PARAM_PID, eventInfo.pid,
132         EVENT_PARAM_UID, eventInfo.uid,
133         EVENT_PARAM_EVENT_NAME, eventInfo.eventName);
134 }
135 
InnerSendUnSubscribeEvent(const EventInfo & eventInfo)136 void EventReport::InnerSendUnSubscribeEvent(const EventInfo &eventInfo)
137 {
138     InnerEventWrite(
139         UNSUBSCRIBE,
140         HiviewDFX::HiSysEvent::EventType::STATISTIC,
141         EVENT_PARAM_USER_ID, eventInfo.userId,
142         EVENT_PARAM_BUNDLE_NAME_OF_SUBSCRIBER, eventInfo.subscriberName,
143         EVENT_PARAM_PID, eventInfo.pid,
144         EVENT_PARAM_UID, eventInfo.uid,
145         EVENT_PARAM_EVENT_NAME, eventInfo.eventName);
146 }
147 
InnerSendPublishEvent(const EventInfo & eventInfo)148 void EventReport::InnerSendPublishEvent(const EventInfo &eventInfo)
149 {
150     InnerEventWrite(
151         PUBLISH,
152         HiviewDFX::HiSysEvent::EventType::STATISTIC,
153         EVENT_PARAM_USER_ID, eventInfo.userId,
154         EVENT_PARAM_BUNDLE_NAME_OF_PUBLISHER, eventInfo.publisherName,
155         EVENT_PARAM_PID, eventInfo.pid,
156         EVENT_PARAM_UID, eventInfo.uid,
157         EVENT_PARAM_EVENT_NAME, eventInfo.eventName);
158 }
159 
InnerSendStaticSubStartEvent(const EventInfo & eventInfo)160 void EventReport::InnerSendStaticSubStartEvent(const EventInfo &eventInfo)
161 {
162     InnerEventWrite(
163         STATIC_SUBSCRIBER_START,
164         HiviewDFX::HiSysEvent::EventType::STATISTIC,
165         EVENT_PARAM_USER_ID, eventInfo.userId,
166         EVENT_PARAM_BUNDLE_NAME_OF_SUBSCRIBER, eventInfo.subscriberName,
167         EVENT_PARAM_ABILITY_NAME, eventInfo.publisherName,
168         EVENT_PARAM_PID, eventInfo.pid,
169         EVENT_PARAM_UID, eventInfo.uid,
170         EVENT_PARAM_EVENT_NAME, eventInfo.eventName);
171 }
172 
InnerSendStaticSubRunEvent(const EventInfo & eventInfo)173 void EventReport::InnerSendStaticSubRunEvent(const EventInfo &eventInfo)
174 {
175     InnerEventWrite(
176         STATIC_SUBSCRIBER_RUNTIME,
177         HiviewDFX::HiSysEvent::EventType::STATISTIC,
178         EVENT_PARAM_USER_ID, eventInfo.userId,
179         EVENT_PARAM_BUNDLE_NAME_OF_SUBSCRIBER, eventInfo.subscriberName,
180         EVENT_PARAM_ABILITY_NAME, eventInfo.publisherName,
181         EVENT_PARAM_PID, eventInfo.pid,
182         EVENT_PARAM_UID, eventInfo.uid,
183         EVENT_PARAM_RESULT_CODE, eventInfo.resultCode,
184         EVENT_PARAM_EVENT_NAME, eventInfo.eventName);
185 }
186 
187 template<typename... Types>
InnerEventWrite(const std::string & eventName,HiviewDFX::HiSysEvent::EventType type,Types...keyValues)188 void EventReport::InnerEventWrite(const std::string &eventName,
189     HiviewDFX::HiSysEvent::EventType type, Types... keyValues)
190 {
191     HiSysEventWrite(
192         HiviewDFX::HiSysEvent::Domain::COMMONEVENT,
193         eventName,
194         static_cast<HiviewDFX::HiSysEvent::EventType>(type),
195         keyValues...);
196 }
197 #endif
198 } // namespace EventFwk
199 } // namespace OHOS