• Home
  • Line#
  • Scopes#
  • Navigate#
  • Raw
  • Download
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 #ifndef CLIENT_MSG_HANDLER_H
17 #define CLIENT_MSG_HANDLER_H
18 
19 #include "aggregator.h"
20 #include "msg_handler.h"
21 #include "uds_client.h"
22 
23 namespace OHOS {
24 namespace MMI {
25 typedef std::function<int32_t(const UDSClient&, NetPacket&)> ClientMsgFun;
26 class ClientMsgHandler final : public MsgHandler<MmiMessageId, ClientMsgFun> {
27 public:
28     ClientMsgHandler() = default;
29     DISALLOW_COPY_AND_MOVE(ClientMsgHandler);
30     ~ClientMsgHandler() override = default;
31 
32     void Init();
33     void InitProcessedCallback();
34     void OnMsgHandler(const UDSClient &client, NetPacket &pkt);
35 
36 protected:
37 #ifdef OHOS_BUILD_ENABLE_KEYBOARD
38     int32_t OnKeyEvent(const UDSClient &client, NetPacket &pkt);
39     int32_t OnKeyMonitor(const UDSClient &client, NetPacket &pkt);
40     int32_t OnPreKeyEvent(const UDSClient &client, NetPacket &pkt);
41 #endif // OHOS_BUILD_ENABLE_KEYBOARD
42 #if defined(OHOS_BUILD_ENABLE_POINTER) || defined(OHOS_BUILD_ENABLE_TOUCH)
43     int32_t OnPointerEvent(const UDSClient &client, NetPacket &pkt);
44     int32_t OnSubscribeLongPressEventCallback(const UDSClient& client, NetPacket& pkt);
45 #endif // OHOS_BUILD_ENABLE_POINTER || OHOS_BUILD_ENABLE_TOUCH
46 #ifdef OHOS_BUILD_ENABLE_KEYBOARD
47     int32_t OnSubscribeKeyEventCallback(const UDSClient &client, NetPacket &pkt);
48     int32_t OnSubscribeKeyMonitor(const UDSClient &client, NetPacket &pkt);
49 #endif // OHOS_BUILD_ENABLE_KEYBOARD
50 #ifdef OHOS_BUILD_ENABLE_SWITCH
51     int32_t OnSubscribeSwitchEventCallback(const UDSClient &client, NetPacket &pkt);
52 #endif // OHOS_BUILD_ENABLE_SWITCH
53     int32_t OnSubscribeTabletProximityCallback(const UDSClient &client, NetPacket &pkt);
54 #if defined(OHOS_BUILD_ENABLE_KEYBOARD) && (defined(OHOS_BUILD_ENABLE_INTERCEPTOR) || \
55     defined(OHOS_BUILD_ENABLE_MONITOR))
56     int32_t ReportKeyEvent(const UDSClient &client, NetPacket &pkt);
57 #endif // OHOS_BUILD_ENABLE_KEYBOARD && OHOS_BUILD_ENABLE_INTERCEPTOR || OHOS_BUILD_ENABLE_MONITOR
58 #if (defined(OHOS_BUILD_ENABLE_POINTER) || defined(OHOS_BUILD_ENABLE_TOUCH)) && \
59     (defined(OHOS_BUILD_ENABLE_INTERCEPTOR) || defined(OHOS_BUILD_ENABLE_MONITOR))
60     int32_t ReportPointerEvent(const UDSClient &client, NetPacket &pkt);
61 #endif // OHOS_BUILD_ENABLE_POINTER || OHOS_BUILD_ENABLE_TOUCH
62     int32_t NotifyBundleName(const UDSClient &client, NetPacket &pkt);
63     int32_t OnInputDevice(const UDSClient &client, NetPacket &pkt);
64     int32_t OnInputDeviceIds(const UDSClient &client, NetPacket &pkt);
65     int32_t OnSupportKeys(const UDSClient &client, NetPacket &pkt);
66     int32_t OnInputKeyboardType(const UDSClient &client, NetPacket &pkt);
67     int32_t OnDevListener(const UDSClient &client, NetPacket &pkt);
68     int32_t OnAnr(const UDSClient &client, NetPacket &pkt);
69     int32_t NotifyWindowStateError(const UDSClient& client, NetPacket& pkt);
70     int32_t OnSetInputDeviceAck(const UDSClient& client, NetPacket& pkt);
71     int32_t ReportDeviceConsumer(const UDSClient& client, NetPacket& pkt);
72     int32_t OnSubscribeInputActiveCallback(const UDSClient& client, NetPacket& pkt);
73 private:
74     static void OnDispatchEventProcessed(int32_t eventId, int64_t actionTime);
75 
76 private:
77     std::function<void(int32_t, int64_t)> dispatchCallback_ { nullptr };
78     int32_t lastEventId_ { 0 };
79     int32_t processedCount_ { 0 };
80     Aggregator aggregator_ {
81         [](int32_t intervalMs, int32_t repeatCount, std::function<void()> callback) -> int32_t {
82             return 0;
83         },
84         [](int32_t timerId) -> int32_t
85         {
86             return 0;
87         }
88     };
89 };
90 } // namespace MMI
91 } // namespace OHOS
92 #endif // CLIENT_MSG_HANDLER_H
93