1 /*
2 * Copyright (c) 2021-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 "multimodal_event_handler.h"
17
18 #include "event_log_helper.h"
19 #include "input_manager_impl.h"
20 #include "mmi_client.h"
21 #include "multimodal_input_connect_manager.h"
22 #include "proto.h"
23 #include "tablet_event_input_subscribe_manager.h"
24 #include "pre_monitor_manager.h"
25
26 #undef MMI_LOG_DOMAIN
27 #define MMI_LOG_DOMAIN MMI_LOG_HANDLER
28 #undef MMI_LOG_TAG
29 #define MMI_LOG_TAG "MultimodalEventHandler"
30
31 namespace OHOS {
32 namespace MMI {
OnConnected(const IfMMIClient & client)33 void OnConnected(const IfMMIClient& client)
34 {
35 CALL_DEBUG_ENTER;
36 InputMgrImpl.OnConnected();
37 INPUT_DEVICE_IMPL.OnConnected();
38 #ifdef OHOS_BUILD_ENABLE_KEYBOARD
39 KeyEventInputSubscribeMgr.OnConnected();
40 #endif // OHOS_BUILD_ENABLE_KEYBOARD
41 #ifdef OHOS_BUILD_ENABLE_SWITCH
42 SWITCH_EVENT_INPUT_SUBSCRIBE_MGR.OnConnected();
43 #endif // OHOS_BUILD_ENABLE_SWITCH
44 TABLET_EVENT_INPUT_SUBSCRIBE_MGR.OnConnected();
45 #ifdef OHOS_BUILD_ENABLE_MONITOR
46 IMonitorMgr.OnConnected();
47 PRE_MONITOR_MGR.OnConnected();
48 #endif // OHOS_BUILD_ENABLE_MONITOR
49 #ifdef OHOS_BUILD_ENABLE_INTERCEPTOR
50 InputInterMgr->OnConnected();
51 #endif // OHOS_BUILD_ENABLE_INTERCEPTOR
52 }
53
OnDisconnected(const IfMMIClient & client)54 void OnDisconnected(const IfMMIClient &client)
55 {
56 CALL_DEBUG_ENTER;
57 InputMgrImpl.OnDisconnected();
58 INPUT_DEVICE_IMPL.OnDisconnected();
59 #ifdef OHOS_BUILD_ENABLE_MONITOR
60 IMonitorMgr.OnDisconnected();
61 #endif // OHOS_BUILD_ENABLE_MONITOR
62 }
63
MultimodalEventHandler()64 MultimodalEventHandler::MultimodalEventHandler() {}
~MultimodalEventHandler()65 MultimodalEventHandler::~MultimodalEventHandler() {}
66
67 #ifdef OHOS_BUILD_ENABLE_KEYBOARD
SubscribeKeyEvent(const KeyEventInputSubscribeManager::SubscribeKeyEventInfo & subscribeInfo)68 int32_t MultimodalEventHandler::SubscribeKeyEvent(
69 const KeyEventInputSubscribeManager::SubscribeKeyEventInfo &subscribeInfo)
70 {
71 CALL_DEBUG_ENTER;
72 CHKPR(MULTIMODAL_INPUT_CONNECT_MGR, RET_ERR);
73 return MULTIMODAL_INPUT_CONNECT_MGR->SubscribeKeyEvent(subscribeInfo.GetSubscribeId(),
74 subscribeInfo.GetKeyOption());
75 }
76
UnsubscribeKeyEvent(int32_t subscribeId)77 int32_t MultimodalEventHandler::UnsubscribeKeyEvent(int32_t subscribeId)
78 {
79 CALL_DEBUG_ENTER;
80 CHKPR(MULTIMODAL_INPUT_CONNECT_MGR, RET_ERR);
81 return MULTIMODAL_INPUT_CONNECT_MGR->UnsubscribeKeyEvent(subscribeId);
82 }
83
SubscribeHotkey(const KeyEventInputSubscribeManager::SubscribeKeyEventInfo & subscribeInfo)84 int32_t MultimodalEventHandler::SubscribeHotkey(
85 const KeyEventInputSubscribeManager::SubscribeKeyEventInfo &subscribeInfo)
86 {
87 CHKPR(MULTIMODAL_INPUT_CONNECT_MGR, RET_ERR);
88 return MULTIMODAL_INPUT_CONNECT_MGR->SubscribeHotkey(
89 subscribeInfo.GetSubscribeId(), subscribeInfo.GetKeyOption());
90 }
91
UnsubscribeHotkey(int32_t subscribeId)92 int32_t MultimodalEventHandler::UnsubscribeHotkey(int32_t subscribeId)
93 {
94 CHKPR(MULTIMODAL_INPUT_CONNECT_MGR, RET_ERR);
95 return MULTIMODAL_INPUT_CONNECT_MGR->UnsubscribeHotkey(subscribeId);
96 }
97
SubscribeKeyMonitor(const KeyMonitorOption & keyOption)98 int32_t MultimodalEventHandler::SubscribeKeyMonitor(const KeyMonitorOption &keyOption)
99 {
100 CHKPR(MULTIMODAL_INPUT_CONNECT_MGR, RET_ERR);
101 return MULTIMODAL_INPUT_CONNECT_MGR->SubscribeKeyMonitor(keyOption);
102 }
103
UnsubscribeKeyMonitor(const KeyMonitorOption & keyOption)104 int32_t MultimodalEventHandler::UnsubscribeKeyMonitor(const KeyMonitorOption &keyOption)
105 {
106 CHKPR(MULTIMODAL_INPUT_CONNECT_MGR, RET_ERR);
107 return MULTIMODAL_INPUT_CONNECT_MGR->UnsubscribeKeyMonitor(keyOption);
108 }
109
InjectEvent(const std::shared_ptr<KeyEvent> keyEvent,bool isNativeInject)110 int32_t MultimodalEventHandler::InjectEvent(const std::shared_ptr<KeyEvent> keyEvent, bool isNativeInject)
111 {
112 CALL_DEBUG_ENTER;
113 CHKPR(keyEvent, ERROR_NULL_POINTER);
114 EndLogTraceId(keyEvent->GetId());
115 keyEvent->UpdateId();
116 LogTracer lt(keyEvent->GetId(), keyEvent->GetEventType(), keyEvent->GetKeyAction());
117 if (keyEvent->GetKeyCode() < 0) {
118 if (EventLogHelper::IsBetaVersion()) {
119 MMI_HILOGE("KeyCode is invalid:%{private}u", keyEvent->GetKeyCode());
120 }
121 return RET_ERR;
122 }
123 CHKPR(MULTIMODAL_INPUT_CONNECT_MGR, RET_ERR);
124 int32_t ret = MULTIMODAL_INPUT_CONNECT_MGR->InjectKeyEvent(keyEvent, isNativeInject);
125 if (ret != 0) {
126 MMI_HILOGE("Send to server failed, ret:%{public}d", ret);
127 return RET_ERR;
128 }
129 return RET_OK;
130 }
131 #endif // OHOS_BUILD_ENABLE_KEYBOARD
132
133 #ifdef OHOS_BUILD_ENABLE_SWITCH
SubscribeSwitchEvent(int32_t subscribeId,int32_t switchType)134 int32_t MultimodalEventHandler::SubscribeSwitchEvent(int32_t subscribeId, int32_t switchType)
135 {
136 CALL_DEBUG_ENTER;
137 CHKPR(MULTIMODAL_INPUT_CONNECT_MGR, RET_ERR);
138 return MULTIMODAL_INPUT_CONNECT_MGR->SubscribeSwitchEvent(subscribeId, switchType);
139 }
140
UnsubscribeSwitchEvent(int32_t subscribeId)141 int32_t MultimodalEventHandler::UnsubscribeSwitchEvent(int32_t subscribeId)
142 {
143 CALL_DEBUG_ENTER;
144 CHKPR(MULTIMODAL_INPUT_CONNECT_MGR, RET_ERR);
145 return MULTIMODAL_INPUT_CONNECT_MGR->UnsubscribeSwitchEvent(subscribeId);
146 }
147 #endif // OHOS_BUILD_ENABLE_SWITCH
148
SubscribeTabletProximity(int32_t subscribeId)149 int32_t MultimodalEventHandler::SubscribeTabletProximity(int32_t subscribeId)
150 {
151 CALL_DEBUG_ENTER;
152 CHKPR(MULTIMODAL_INPUT_CONNECT_MGR, RET_ERR);
153 return MULTIMODAL_INPUT_CONNECT_MGR->SubscribeTabletProximity(subscribeId);
154 }
155
UnsubscribetabletProximity(int32_t subscribeId)156 int32_t MultimodalEventHandler::UnsubscribetabletProximity(int32_t subscribeId)
157 {
158 CALL_DEBUG_ENTER;
159 CHKPR(MULTIMODAL_INPUT_CONNECT_MGR, RET_ERR);
160 return MULTIMODAL_INPUT_CONNECT_MGR->UnsubscribetabletProximity(subscribeId);
161 }
162
SubscribeLongPressEvent(int32_t subscribeId,const LongPressRequest & longPressRequest)163 int32_t MultimodalEventHandler::SubscribeLongPressEvent(int32_t subscribeId,
164 const LongPressRequest &longPressRequest)
165 {
166 CALL_DEBUG_ENTER;
167 CHKPR(MULTIMODAL_INPUT_CONNECT_MGR, RET_ERR);
168 return MULTIMODAL_INPUT_CONNECT_MGR->SubscribeLongPressEvent(subscribeId, longPressRequest);
169 }
170
UnsubscribeLongPressEvent(int32_t subscribeId)171 int32_t MultimodalEventHandler::UnsubscribeLongPressEvent(int32_t subscribeId)
172 {
173 CALL_DEBUG_ENTER;
174 CHKPR(MULTIMODAL_INPUT_CONNECT_MGR, RET_ERR);
175 return MULTIMODAL_INPUT_CONNECT_MGR->UnsubscribeLongPressEvent(subscribeId);
176 }
177
InitClient(EventHandlerPtr eventHandler)178 bool MultimodalEventHandler::InitClient(EventHandlerPtr eventHandler)
179 {
180 CALL_DEBUG_ENTER;
181 std::lock_guard<std::mutex> guard(mtx_);
182 if (client_ != nullptr) {
183 if (eventHandler != nullptr) {
184 client_->MarkIsEventHandlerChanged(eventHandler);
185 }
186 return true;
187 }
188 client_ = std::make_shared<MMIClient>();
189 client_->SetEventHandler(eventHandler);
190 client_->RegisterConnectedFunction(&OnConnected);
191 client_->RegisterDisconnectedFunction(&OnDisconnected);
192 if (!client_->Start()) {
193 client_ = nullptr;
194 MMI_HILOGE("The client fails to start");
195 return false;
196 }
197 EventHandlerPtr eventHandlerPtr = client_->GetEventHandler();
198 CHKPF(eventHandlerPtr);
199 if (!eventHandlerPtr->PostTask([this] { SetClientInfo(GetPid(), GetThisThreadId()); })) {
200 MMI_HILOGE("Send reconnect event failed");
201 return false;
202 }
203 return true;
204 }
205
GetMMIClient()206 MMIClientPtr MultimodalEventHandler::GetMMIClient()
207 {
208 std::lock_guard<std::mutex> guard(mtx_);
209 CHKPP(client_);
210 return client_->GetSharedPtr();
211 }
212
213 #if defined(OHOS_BUILD_ENABLE_POINTER) || defined(OHOS_BUILD_ENABLE_TOUCH)
InjectPointerEvent(std::shared_ptr<PointerEvent> pointerEvent,bool isNativeInject)214 int32_t MultimodalEventHandler::InjectPointerEvent(std::shared_ptr<PointerEvent> pointerEvent, bool isNativeInject)
215 {
216 CHKPR(pointerEvent, ERROR_NULL_POINTER);
217 EventLogHelper::PrintEventData(pointerEvent, MMI_LOG_HEADER);
218 CHKPR(MULTIMODAL_INPUT_CONNECT_MGR, RET_ERR);
219 int32_t ret = MULTIMODAL_INPUT_CONNECT_MGR->InjectPointerEvent(pointerEvent, isNativeInject);
220 if (ret != 0) {
221 MMI_HILOGE("Send to server failed, ret:%{public}d", ret);
222 return RET_ERR;
223 }
224 return RET_OK;
225 }
226 #endif // OHOS_BUILD_ENABLE_POINTER || OHOS_BUILD_ENABLE_TOUCH
227
228 #if defined(OHOS_BUILD_ENABLE_POINTER) || defined(OHOS_BUILD_ENABLE_TOUCH)
InjectTouchPadEvent(std::shared_ptr<PointerEvent> pointerEvent,const TouchpadCDG & touchpadCDG,bool isNativeInject)229 int32_t MultimodalEventHandler::InjectTouchPadEvent(std::shared_ptr<PointerEvent> pointerEvent,
230 const TouchpadCDG &touchpadCDG, bool isNativeInject)
231 {
232 CHKPR(pointerEvent, ERROR_NULL_POINTER);
233 EventLogHelper::PrintEventData(pointerEvent, MMI_LOG_HEADER);
234 CHKPR(MULTIMODAL_INPUT_CONNECT_MGR, RET_ERR);
235 int32_t ret = MULTIMODAL_INPUT_CONNECT_MGR->InjectTouchPadEvent(pointerEvent, touchpadCDG, isNativeInject);
236 if (ret != 0) {
237 MMI_HILOGE("Send to server failed, ret:%{public}d", ret);
238 return RET_ERR;
239 }
240 return RET_OK;
241 }
242 #endif // OHOS_BUILD_ENABLE_POINTER || OHOS_BUILD_ENABLE_TOUCH
243
244 #if defined(OHOS_BUILD_ENABLE_POINTER) && defined(OHOS_BUILD_ENABLE_POINTER_DRAWING)
MoveMouseEvent(int32_t offsetX,int32_t offsetY)245 int32_t MultimodalEventHandler::MoveMouseEvent(int32_t offsetX, int32_t offsetY)
246 {
247 CALL_DEBUG_ENTER;
248 CHKPR(MULTIMODAL_INPUT_CONNECT_MGR, RET_ERR);
249 int32_t ret = MULTIMODAL_INPUT_CONNECT_MGR->MoveMouseEvent(offsetX, offsetY);
250 if (ret != 0) {
251 MMI_HILOGE("Send to server failed, ret:%{public}d", ret);
252 return RET_ERR;
253 }
254 return RET_OK;
255 }
256 #endif // OHOS_BUILD_ENABLE_POINTER && OHOS_BUILD_ENABLE_POINTER_DRAWING
257
Authorize(bool isAuthorize)258 int32_t MultimodalEventHandler::Authorize(bool isAuthorize)
259 {
260 CHKPR(MULTIMODAL_INPUT_CONNECT_MGR, RET_ERR);
261 int32_t ret = MULTIMODAL_INPUT_CONNECT_MGR->Authorize(isAuthorize);
262 if (ret != RET_OK) {
263 MMI_HILOGE("Send to server failed, ret:%{public}d", ret);
264 return RET_ERR;
265 }
266 return RET_OK;
267 }
268
CancelInjection()269 int32_t MultimodalEventHandler::CancelInjection()
270 {
271 CHKPR(MULTIMODAL_INPUT_CONNECT_MGR, RET_ERR);
272 int32_t ret = MULTIMODAL_INPUT_CONNECT_MGR->CancelInjection();
273 if (ret != RET_OK) {
274 MMI_HILOGE("Send to server failed, ret:%{public}d", ret);
275 return RET_ERR;
276 }
277 return RET_OK;
278 }
279
SetClientInfo(int32_t pid,uint64_t readThreadId)280 int32_t MultimodalEventHandler::SetClientInfo(int32_t pid, uint64_t readThreadId)
281 {
282 CALL_DEBUG_ENTER;
283 CHKPR(MULTIMODAL_INPUT_CONNECT_MGR, RET_ERR);
284 return MULTIMODAL_INPUT_CONNECT_MGR->SetClientInfo(pid, readThreadId);
285 }
286 } // namespace MMI
287 } // namespace OHOS
288