/*
 * Copyright (c) 2021-2022 Huawei Device Co., Ltd.
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

#include "input_event_handler.h"
#include <cstdio>
#include <cstring>
#include <functional>
#include <vector>
#include <cinttypes>
#include <sys/stat.h>
#include <unistd.h>
#include "bytrace.h"
#include "input_device_manager.h"
#include "interceptor_manager_global.h"
#include "mmi_func_callback.h"
#include "mouse_event_handler.h"
#include "s_input.h"
#include "time_cost_chk.h"
#include "timer_manager.h"
#include "touch_transform_point_manager.h"
#include "util.h"

namespace OHOS {
namespace MMI {
    namespace {
        constexpr OHOS::HiviewDFX::HiLogLabel LABEL = { LOG_CORE, MMI_LOG_DOMAIN, "InputEventHandler" };
    }

InputEventHandler::InputEventHandler()
{
    udsServer_ = nullptr;
    notifyDeviceChange_ = nullptr;
}

InputEventHandler::~InputEventHandler() {}

void InputEventHandler::Init(UDSServer& udsServer)
{
    udsServer_ = &udsServer;
    MsgCallback funs[] = {
        {
            MmiMessageId::LIBINPUT_EVENT_DEVICE_ADDED,
            MsgCallbackBind1(&InputEventHandler::OnEventDeviceAdded, this)
        },
        {
            MmiMessageId::LIBINPUT_EVENT_DEVICE_REMOVED,
            MsgCallbackBind1(&InputEventHandler::OnEventDeviceRemoved, this)
        },
        {
            MmiMessageId::LIBINPUT_EVENT_KEYBOARD_KEY,
            MsgCallbackBind1(&InputEventHandler::OnEventKey, this)
        },
        {
            MmiMessageId::LIBINPUT_EVENT_POINTER_MOTION,
            MsgCallbackBind1(&InputEventHandler::OnEventPointer, this)
        },
        {
            MmiMessageId::LIBINPUT_EVENT_POINTER_MOTION_ABSOLUTE,
            MsgCallbackBind1(&InputEventHandler::OnEventPointer, this)
        },
        {
            MmiMessageId::LIBINPUT_EVENT_POINTER_BUTTON,
            MsgCallbackBind1(&InputEventHandler::OnEventPointer, this)
        },
        {
            MmiMessageId::LIBINPUT_EVENT_POINTER_AXIS,
            MsgCallbackBind1(&InputEventHandler::OnEventPointer, this)
        },
        {
            MmiMessageId::LIBINPUT_EVENT_TOUCH_DOWN,
            MsgCallbackBind1(&InputEventHandler::OnEventTouch, this)
        },
        {
            MmiMessageId::LIBINPUT_EVENT_TOUCH_UP,
            MsgCallbackBind1(&InputEventHandler::OnEventTouch, this)
        },
        {
            MmiMessageId::LIBINPUT_EVENT_TOUCH_MOTION,
            MsgCallbackBind1(&InputEventHandler::OnEventTouch, this)
        },
        {
            MmiMessageId::LIBINPUT_EVENT_TOUCH_CANCEL,
            MsgCallbackBind1(&InputEventHandler::OnEventTouch, this)
        },
        {
            MmiMessageId::LIBINPUT_EVENT_TOUCH_FRAME,
            MsgCallbackBind1(&InputEventHandler::OnEventTouch, this)
        },
        {
            MmiMessageId::LIBINPUT_EVENT_TOUCHPAD_DOWN,
            MsgCallbackBind1(&InputEventHandler::OnEventTouchpad, this)
        },
        {
            MmiMessageId::LIBINPUT_EVENT_TOUCHPAD_UP,
            MsgCallbackBind1(&InputEventHandler::OnEventTouchpad, this)
        },
        {
            MmiMessageId::LIBINPUT_EVENT_TOUCHPAD_MOTION,
            MsgCallbackBind1(&InputEventHandler::OnEventTouchpad, this)
        },
        {
            MmiMessageId::LIBINPUT_EVENT_GESTURE_SWIPE_BEGIN,
            MsgCallbackBind1(&InputEventHandler::OnEventGesture, this)
        },
        {
            MmiMessageId::LIBINPUT_EVENT_GESTURE_SWIPE_UPDATE,
            MsgCallbackBind1(&InputEventHandler::OnEventGesture, this)
        },
        {
            MmiMessageId::LIBINPUT_EVENT_GESTURE_SWIPE_END,
            MsgCallbackBind1(&InputEventHandler::OnEventGesture, this)
        },
        {
            MmiMessageId::LIBINPUT_EVENT_GESTURE_PINCH_BEGIN,
            MsgCallbackBind1(&InputEventHandler::OnEventGesture, this)
        },
        {
            MmiMessageId::LIBINPUT_EVENT_GESTURE_PINCH_UPDATE,
            MsgCallbackBind1(&InputEventHandler::OnEventGesture, this)
        },
        {
            MmiMessageId::LIBINPUT_EVENT_GESTURE_PINCH_END,
            MsgCallbackBind1(&InputEventHandler::OnEventGesture, this)
        },
    };
    for (auto &item : funs) {
        CHKC(RegistrationEvent(item), EVENT_REG_FAIL);
    }
    return;
}

void InputEventHandler::OnEvent(void *event)
{
    CHKPV(event);
    std::lock_guard<std::mutex> lock(mu_);
    auto *lpMmiEvent = static_cast<multimodal_libinput_event *>(event);
    CHKPV(lpMmiEvent);
    auto *lpEvent = lpMmiEvent->event;
    CHKPV(lpEvent);
    if (initSysClock_ != 0 && lastSysClock_ == 0) {
        MMI_LOGE("Event not handled. id:%{public}" PRId64 ",eventType:%{public}d,initSysClock:%{public}" PRId64,
                 idSeed_, eventType_, initSysClock_);
    }

    eventType_ = libinput_event_get_type(lpEvent);
    auto tid = GetThisThreadIdOfLL();
    initSysClock_ = GetSysClockTime();
    lastSysClock_ = 0;
    idSeed_ += 1;
    const uint64_t maxUInt64 = (std::numeric_limits<uint64_t>::max)() - 1;
    if (idSeed_ >= maxUInt64) {
        MMI_LOGE("Invaild value. id:%{public}" PRId64, idSeed_);
        idSeed_ = 1;
        return;
    }

    MMI_LOGD("Event reporting. id:%{public}" PRId64 ",tid:%{public}" PRId64 ",eventType:%{public}d,"
             "initSysClock:%{public}" PRId64, idSeed_, tid, eventType_, initSysClock_);

    OnEventHandler(*lpMmiEvent);
    lastSysClock_ = GetSysClockTime();
    int64_t lostTime = lastSysClock_ - initSysClock_;
    MMI_LOGD("Event handling completed. id:%{public}" PRId64 ",lastSynClock:%{public}" PRId64
             ",lostTime:%{public}" PRId64, idSeed_, lastSysClock_, lostTime);
}

int32_t InputEventHandler::OnEventHandler(const multimodal_libinput_event& ev)
{
    CHKPR(ev.event, ERROR_NULL_POINTER);
    auto type = libinput_event_get_type(ev.event);
    TimeCostChk chk("InputEventHandler::OnEventHandler", "overtime 1000(us)", MAX_INPUT_EVENT_TIME, type);
    auto callback = GetMsgCallback(static_cast<MmiMessageId>(type));
    if (callback == nullptr) {
        MMI_LOGE("Unknown event type:%{public}d,errCode:%{public}d", type, UNKNOWN_EVENT);
        return UNKNOWN_EVENT;
    }
    auto ret = (*callback)(ev);
    if (ret != 0) {
        MMI_LOGE("Event handling failed. type:%{public}d,ret:%{public}d,errCode:%{public}d",
                 type, ret, EVENT_CONSUM_FAIL);
        return ret;
    }
    return ret;
}

void InputEventHandler::OnCheckEventReport()
{
    std::lock_guard<std::mutex> lock(mu_);
    if (initSysClock_ == 0 || lastSysClock_ != 0) {
        return;
    }
    constexpr uint64_t MAX_DID_TIME = 1000 * 1000 * 3;
    auto curSysClock = GetSysClockTime();
    auto lostTime = curSysClock - initSysClock_;
    if (lostTime < MAX_DID_TIME) {
        return;
    }
    MMI_LOGE("Event not responding. id:%{public}" PRId64 ",eventType:%{public}d,initSysClock:%{public}" PRId64 ","
             "lostTime:%{public}" PRId64, idSeed_, eventType_, initSysClock_, lostTime);
}

UDSServer* InputEventHandler::GetUDSServer()
{
    return udsServer_;
}

int32_t InputEventHandler::AddInputEventFilter(sptr<IEventFilter> filter)
{
    return eventDispatch_.AddInputEventFilter(filter);
}

int32_t InputEventHandler::OnEventDeviceAdded(const multimodal_libinput_event& ev)
{
    CHKPR(ev.event, ERROR_NULL_POINTER);
    auto device = libinput_event_get_device(ev.event);
    InputDevMgr->OnInputDeviceAdded(device);
    return RET_OK;
}
int32_t InputEventHandler::OnEventDeviceRemoved(const multimodal_libinput_event& ev)
{
    CHKPR(ev.event, ERROR_NULL_POINTER);
    auto device = libinput_event_get_device(ev.event);
    InputDevMgr->OnInputDeviceRemoved(device);
    return RET_OK;
}

void InputEventHandler::AddHandleTimer(int32_t timeout)
{
    timerId_ = TimerMgr->AddTimer(timeout, 1, [this]() {
        MMI_LOGD("enter");
        if (this->keyEvent_->GetKeyAction() == KeyEvent::KEY_ACTION_UP) {
            MMI_LOGD("key up");
            return;
        }
        int64_t sysStartProcessTime = GetSysClockTime();
        auto ret = eventDispatch_.DispatchKeyEventPid(*(this->udsServer_), this->keyEvent_, sysStartProcessTime);
        if (ret != RET_OK) {
            MMI_LOGE("KeyEvent dispatch failed. ret:%{public}d,errCode:%{public}d", ret, KEY_EVENT_DISP_FAIL);
        }
        constexpr int32_t triggerTime = 100;
        this->AddHandleTimer(triggerTime);
        MMI_LOGD("leave");
    });
}

int32_t InputEventHandler::OnEventKey(const multimodal_libinput_event& ev)
{
    CHKPR(ev.event, ERROR_NULL_POINTER);
    CHKPR(udsServer_, ERROR_NULL_POINTER);
    int64_t sysStartProcessTime = GetSysClockTime();
    if (keyEvent_ == nullptr) {
        keyEvent_ = KeyEvent::Create();
    }

    auto packageResult = eventPackage_.PackageKeyEvent(ev.event, keyEvent_);
    if (packageResult == MULTIDEVICE_SAME_EVENT_MARK) {
        MMI_LOGD("The same event reported by multi_device should be discarded");
        return RET_OK;
    }
    if (packageResult != RET_OK) {
        MMI_LOGE("KeyEvent package failed. ret:%{public}d,errCode:%{public}d", packageResult, KEY_EVENT_PKG_FAIL);
        return KEY_EVENT_PKG_FAIL;
    }

    int32_t keyId = keyEvent_->GetId();
    std::string keyEventString = "OnKeyEvent";
    StartAsyncTrace(BYTRACE_TAG_MULTIMODALINPUT, keyEventString, keyId);
    keyEventString = "service report keyId=" + std::to_string(keyId);
    BYTRACE_NAME(BYTRACE_TAG_MULTIMODALINPUT, keyEventString);

    auto ret = eventDispatch_.DispatchKeyEventPid(*udsServer_, keyEvent_, sysStartProcessTime);
    if (ret != RET_OK) {
        MMI_LOGE("KeyEvent dispatch failed. ret:%{public}d,errCode:%{public}d", ret, KEY_EVENT_DISP_FAIL);
        return KEY_EVENT_DISP_FAIL;
    }
    if (keyEvent_->GetKeyCode() == KeyEvent::KEYCODE_VOLUME_UP ||
        keyEvent_->GetKeyCode() == KeyEvent::KEYCODE_VOLUME_DOWN) {
        if (!TimerMgr->IsExist(timerId_) && keyEvent_->GetKeyAction() == KeyEvent::KEY_ACTION_DOWN) {
            AddHandleTimer();
            MMI_LOGD("add a timer");
        }
        if (keyEvent_->GetKeyAction() == KeyEvent::KEY_ACTION_UP && TimerMgr->IsExist(timerId_)) {
            TimerMgr->RemoveTimer(timerId_);
            timerId_ = -1;
        }
    }

    MMI_LOGD("keyCode:%{public}d,action:%{public}d", keyEvent_->GetKeyCode(), keyEvent_->GetKeyAction());
    return RET_OK;
}

int32_t InputEventHandler::OnEventPointer(const multimodal_libinput_event& ev)
{
    CHKPR(ev.event, ERROR_NULL_POINTER);
    return OnMouseEventHandler(ev.event);
}

int32_t InputEventHandler::OnEventTouchSecond(struct libinput_event *event)
{
    MMI_LOGD("Enter");
    CHKPR(event, ERROR_NULL_POINTER);
    auto type = libinput_event_get_type(event);
    if (type == LIBINPUT_EVENT_TOUCH_CANCEL || type == LIBINPUT_EVENT_TOUCH_FRAME) {
        MMI_LOGI("This touch event is canceled type:%{public}d", type);
        return RET_OK;
    }
    auto point = TouchTransformPointManger->OnLibinputTouchEvent(event);
    CHKPR(point, ERROR_NULL_POINTER);
    int32_t pointerId = point->GetId();
    std::string touchEvent = "OnEventTouch";
    StartAsyncTrace(BYTRACE_TAG_MULTIMODALINPUT, touchEvent, pointerId);
    eventDispatch_.HandlePointerEvent(point);
    if (type == LIBINPUT_EVENT_TOUCH_UP) {
        point->RemovePointerItem(point->GetPointerId());
        MMI_LOGD("This touch event is up remove this finger");
        if (point->GetPointersIdList().empty()) {
            MMI_LOGD("This touch event is final finger up remove this finger");
            point->Reset();
        }
        return RET_OK;
    }
    MMI_LOGD("Leave");
    return RET_OK;
}

int32_t InputEventHandler::OnEventTouchPadSecond(struct libinput_event *event)
{
    MMI_LOGD("Enter");
    CHKPR(event, ERROR_NULL_POINTER);

    auto point = TouchTransformPointManger->OnLibinputTouchPadEvent(event);
    if (point == nullptr) {
        MMI_LOGW("PointerEvent is null");
        return RET_OK;
    }
    eventDispatch_.HandlePointerEvent(point);
    auto type = libinput_event_get_type(event);
    if (type == LIBINPUT_EVENT_TOUCHPAD_UP) {
        point->RemovePointerItem(point->GetPointerId());
        MMI_LOGD("This touch pad event is up remove this finger");
        if (point->GetPointersIdList().empty()) {
            MMI_LOGD("This touch pad event is final finger up remove this finger");
            point->Reset();
        }
        return RET_OK;
    }
    MMI_LOGD("Leave");
    return RET_OK;
}

int32_t InputEventHandler::OnEventTouch(const multimodal_libinput_event& ev)
{
    CHKPR(ev.event, ERROR_NULL_POINTER);
    SInput::LoginfoPackagingTool(ev.event);
    return OnEventTouchSecond(ev.event);
}

int32_t InputEventHandler::OnEventTouchpad(const multimodal_libinput_event& ev)
{
    OnEventTouchPadSecond(ev.event);
    return RET_OK;
}

int32_t InputEventHandler::OnGestureEvent(struct libinput_event *event)
{
    CHKPR(event, ERROR_NULL_POINTER);
    auto pointer = TouchTransformPointManger->OnTouchPadGestrueEvent(event);
    if (pointer == nullptr) {
        MMI_LOGE("Gesture event package failed, errCode:%{public}d", GESTURE_EVENT_PKG_FAIL);
        return GESTURE_EVENT_PKG_FAIL;
    }
    MMI_LOGD("GestrueEvent package, eventType:%{public}d,actionTime:%{public}" PRId64 ","
             "action:%{public}d,actionStartTime:%{public}" PRId64 ","
             "pointerAction:%{public}d,sourceType:%{public}d,"
             "PinchAxisValue:%{public}.2f",
             pointer->GetEventType(), pointer->GetActionTime(),
             pointer->GetAction(), pointer->GetActionStartTime(),
             pointer->GetPointerAction(), pointer->GetSourceType(),
             pointer->GetAxisValue(PointerEvent::AXIS_TYPE_PINCH));

    PointerEvent::PointerItem item;
    pointer->GetPointerItem(pointer->GetPointerId(), item);
    MMI_LOGD("Item:DownTime:%{public}" PRId64 ",IsPressed:%{public}s,"
             "GlobalX:%{public}d,GlobalY:%{public}d,LocalX:%{public}d,LocalY:%{public}d,"
             "Width:%{public}d,Height:%{public}d",
             item.GetDownTime(), (item.IsPressed() ? "true" : "false"),
             item.GetGlobalX(), item.GetGlobalY(), item.GetLocalX(), item.GetLocalY(),
             item.GetWidth(), item.GetHeight());

    int32_t ret = eventDispatch_.HandlePointerEvent(pointer);
    if (ret != RET_OK) {
        MMI_LOGE("Gesture event dispatch failed, errCode:%{public}d", GESTURE_EVENT_DISP_FAIL);
        return GESTURE_EVENT_DISP_FAIL;
    }
    return RET_OK;
}

int32_t InputEventHandler::OnEventGesture(const multimodal_libinput_event& ev)
{
    CHKPR(ev.event, ERROR_NULL_POINTER);
    OnGestureEvent(ev.event);
    return RET_OK;
}

int32_t InputEventHandler::OnMouseEventHandler(struct libinput_event *event)
{
    CHKPR(event, ERROR_NULL_POINTER);

    // 更新 全局 鼠标事件 数据
    MouseEventHdr->Normalize(event);

    auto pointerEvent = MouseEventHdr->GetPointerEvent();
    if (pointerEvent == nullptr) {
        MMI_LOGE("MouseEvent is NULL");
        return RET_ERR;
    }

    // 处理 按键 + 鼠标
    if (keyEvent_ == nullptr) {
        keyEvent_ = KeyEvent::Create();
    }
    CHKPR(keyEvent_, ERROR_NULL_POINTER);
    if (keyEvent_ != nullptr) {
        std::vector<int32_t> pressedKeys = keyEvent_->GetPressedKeys();
        if (pressedKeys.empty()) {
            MMI_LOGI("Pressed keys is empty");
        } else {
            for (int32_t keyCode : pressedKeys) {
                MMI_LOGI("Pressed keyCode:%{public}d", keyCode);
            }
        }
        pointerEvent->SetPressedKeys(pressedKeys);
    }
    int32_t pointerId = keyEvent_->GetId();
    const std::string pointerEventstring = "OnEventPointer";
    StartAsyncTrace(BYTRACE_TAG_MULTIMODALINPUT, pointerEventstring, pointerId);
    // 派发
    eventDispatch_.HandlePointerEvent(pointerEvent);
    // 返回值 代表是 鼠标事件有没有处理过， 不关心成功与失败
    return RET_OK;
}

int32_t InputEventHandler::OnMouseEventEndTimerHandler(std::shared_ptr<PointerEvent> pointerEvent)
{
    CHKPR(pointerEvent, ERROR_NULL_POINTER);
    // Mouse Axis Data
    MMI_LOGI("MouseEvent Normalization Results, PointerAction:%{public}d,PointerId:%{public}d,"
             "SourceType:%{public}d,ButtonId:%{public}d,"
             "VerticalAxisValue:%{public}lf,HorizontalAxisValue:%{public}lf",
             pointerEvent->GetPointerAction(), pointerEvent->GetPointerId(), pointerEvent->GetSourceType(),
             pointerEvent->GetButtonId(), pointerEvent->GetAxisValue(PointerEvent::AXIS_TYPE_SCROLL_VERTICAL),
             pointerEvent->GetAxisValue(PointerEvent::AXIS_TYPE_SCROLL_HORIZONTAL));
    PointerEvent::PointerItem item;
    CHKR(pointerEvent->GetPointerItem(pointerEvent->GetPointerId(), item), PARAM_INPUT_FAIL, RET_ERR);
    MMI_LOGI("MouseEvent Item Normalization Results, DownTime:%{public}" PRId64 ",IsPressed:%{public}d,"
             "GlobalX:%{public}d,GlobalY:%{public}d,LocalX:%{public}d,LocalY:%{public}d,"
             "Width:%{public}d,Height:%{public}d,Pressure:%{public}d",
             item.GetDownTime(), static_cast<int32_t>(item.IsPressed()), item.GetGlobalX(), item.GetGlobalY(),
             item.GetLocalX(), item.GetLocalY(), item.GetWidth(), item.GetHeight(), item.GetPressure());

    eventDispatch_.HandlePointerEvent(pointerEvent);
    return RET_OK;
}

bool InputEventHandler::SendMsg(const int32_t fd, NetPacket& pkt) const
{
    CHKPF(udsServer_);
    return udsServer_->SendMsg(fd, pkt);
}
} // namespace MMI
} // namespace OHOS