/*
 * Copyright (c) 2021-2025 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_manager.h"
#include "js_register_util.h"
#include "napi_constants.h"
#include "util_napi_error.h"

#undef MMI_LOG_TAG
#define MMI_LOG_TAG "JSRegisterModule"

namespace OHOS {
namespace MMI {
namespace {
constexpr size_t EVENT_NAME_LEN { 64 };
constexpr size_t PRE_KEYS_SIZE { 4 };
constexpr size_t AT_LEAST_ONE_PARAMETER { 1 };
constexpr size_t INPUT_PARAMETER_MIDDLE { 2 };
constexpr size_t INPUT_PARAMETER_MAX { 3 };
constexpr size_t KEY_MONITOR_EXPECT_N_PARAMS { 3 };
constexpr size_t FIRST_PARAMETER { 0 };
constexpr size_t SECOND_PARAMETER { 1 };
constexpr size_t THIRD_PARAMETER { 2 };
constexpr int32_t INVALID_SUBSCRIBER_ID { -1 };
constexpr int32_t OCCUPIED_BY_SYSTEM { -3 };
constexpr int32_t OCCUPIED_BY_OTHER { -4 };
constexpr int32_t BOOLEAN_TRUE { 1 };
constexpr int32_t BOOLEAN_FALSE { 0 };
constexpr int32_t BOOLEAN_NONE { -1 };
constexpr uint32_t DEFAULT_REFERENCE_COUNT { 1 };
} // namespace

static Callbacks callbacks = {};
static Callbacks hotkeyCallbacks = {};
std::mutex sCallBacksMutex;
static const std::vector<int32_t> pressKeyCodes = {
    KeyEvent::KEYCODE_ALT_LEFT,
    KeyEvent::KEYCODE_ALT_RIGHT,
    KeyEvent::KEYCODE_SHIFT_LEFT,
    KeyEvent::KEYCODE_SHIFT_RIGHT,
    KeyEvent::KEYCODE_CTRL_LEFT,
    KeyEvent::KEYCODE_CTRL_RIGHT
};
static const std::vector<int32_t> finalKeyCodes = {
    KeyEvent::KEYCODE_ALT_LEFT,
    KeyEvent::KEYCODE_ALT_RIGHT,
    KeyEvent::KEYCODE_SHIFT_LEFT,
    KeyEvent::KEYCODE_SHIFT_RIGHT,
    KeyEvent::KEYCODE_CTRL_LEFT,
    KeyEvent::KEYCODE_CTRL_RIGHT,
    KeyEvent::KEYCODE_META_LEFT,
    KeyEvent::KEYCODE_META_RIGHT
};
bool JsCommon::TypeOf(napi_env env, napi_value value, napi_valuetype type)
{
    napi_valuetype valueType = napi_undefined;
    CHKRF(napi_typeof(env, value, &valueType), TYPEOF);
    if (valueType != type) {
        return false;
    }
    return true;
}

void JsCommon::ThrowError(napi_env env, int32_t code)
{
    int32_t errorCode = std::abs(code);
    if (errorCode == COMMON_USE_SYSAPI_ERROR) {
        MMI_HILOGE("Non system applications use system API");
        THROWERR_CUSTOM(env, COMMON_USE_SYSAPI_ERROR, "Non system applications use system API");
    } else if (errorCode == COMMON_PERMISSION_CHECK_ERROR) {
        MMI_HILOGE("Shield api need ohos.permission.INPUT_CONTROL_DISPATCHING");
        THROWERR_API9(env, COMMON_PERMISSION_CHECK_ERROR, "shiled API", "ohos.permission.INPUT_CONTROL_DISPATCHING");
    } else {
        MMI_HILOGE("Dispatch control failed");
    }
}

static void EnvCleanUp(void *data)
{
    if (data == nullptr) {
        return;
    }
    KeyEventMonitorInfo *info = reinterpret_cast<KeyEventMonitorInfo *>(data);
    std::lock_guard<std::mutex> lock(info->envMutex_);
    info->env = nullptr;
}

napi_value GetHotkeyEventInfo(napi_env env, napi_callback_info info, sptr<KeyEventMonitorInfo> event,
    std::shared_ptr<KeyOption> keyOption)
{
    CALL_DEBUG_ENTER;
    CHKPP(event);
    CHKPP(keyOption);
    size_t argc = 3;
    napi_value argv[3] = { 0 };
    CHKRP(napi_get_cb_info(env, info, &argc, argv, nullptr, nullptr), GET_CB_INFO);
    napi_value receiveValue = nullptr;
    CHKRP(napi_get_named_property(env, argv[1], "preKeys", &receiveValue), GET_NAMED_PROPERTY);
    if (receiveValue == nullptr) {
        THROWERR_CUSTOM(env, COMMON_PARAMETER_ERROR, "PreKeys not found");
        return nullptr;
    }
    std::set<int32_t> preKeys;
    if (GetPreKeys(env, receiveValue, preKeys) == nullptr) {
        MMI_HILOGE("Get preKeys failed");
        return nullptr;
    }
    if (preKeys.size() > PRE_KEYS_SIZE) {
        MMI_HILOGE("PreKeys size invalid");
        THROWERR_CUSTOM(env, COMMON_PARAMETER_ERROR, "PreKeys size invalid");
        return nullptr;
    }
    MMI_HILOGD("PreKeys size:%{public}zu", preKeys.size());
    keyOption->SetPreKeys(preKeys);
    std::string subKeyNames = "";
    for (const auto &item : preKeys) {
        auto it = std::find(pressKeyCodes.begin(), pressKeyCodes.end(), item);
        if (it == pressKeyCodes.end()) {
            MMI_HILOGE("PreKeys is not expect");
            THROWERR_CUSTOM(env, COMMON_PARAMETER_ERROR, "PreKeys size invalid");
            return nullptr;
        }
        subKeyNames += std::to_string(item);
        subKeyNames += ",";
        MMI_HILOGD("PreKeys:%{private}d", item);
    }
    std::optional<int32_t> finalKeyOption = GetNamedPropertyInt32(env, argv[1], "finalKey");
    if (!finalKeyOption) {
        MMI_HILOGE("GetNamedPropertyInt32 failed");
        return nullptr;
    }
    int32_t finalKey = finalKeyOption.value();
    if (finalKey < 0) {
        MMI_HILOGE("FinalKey:%{private}d is less 0, can not process", finalKey);
        THROWERR_CUSTOM(env, COMMON_PARAMETER_ERROR, "FinalKey must be greater than or equal to 0");
        return nullptr;
    }
    auto it = std::find(finalKeyCodes.begin(), finalKeyCodes.end(), finalKey);
    if (it != finalKeyCodes.end()) {
        MMI_HILOGE("FinalKey is not expect");
        THROWERR_CUSTOM(env, COMMON_PARAMETER_ERROR, "FinalKey is not expect");
        return nullptr;
    }
    subKeyNames += std::to_string(finalKey);
    subKeyNames += ",";
    keyOption->SetFinalKey(finalKey);
    MMI_HILOGD("FinalKey:%{private}d", finalKey);

    bool isFinalKeyDown = true;
    subKeyNames += std::to_string(isFinalKeyDown);
    subKeyNames += ",";
    keyOption->SetFinalKeyDown(isFinalKeyDown);
    MMI_HILOGD("IsFinalKeyDown:%{private}d,", (isFinalKeyDown == true ? 1 : 0));

    int32_t finalKeyDownDuration = 0;
    subKeyNames += std::to_string(finalKeyDownDuration);
    subKeyNames += ",";
    keyOption->SetFinalKeyDownDuration(finalKeyDownDuration);

    bool isRepeat = true;
    if (!GetNamedPropertyBool(env, argv[1], "isRepeat", isRepeat)) {
        MMI_HILOGD("IsRepeat field is default");
    }
    subKeyNames += std::to_string(isRepeat);
    keyOption->SetRepeat(isRepeat);
    MMI_HILOGD("IsRepeat:%{public}s", (isRepeat ? "true" : "false"));
    event->eventType = subKeyNames;

    napi_value ret;
    CHKRP(napi_create_int32(env, RET_OK, &ret), CREATE_INT32);
    return ret;
}

napi_value GetEventInfoAPI9(napi_env env, napi_callback_info info, sptr<KeyEventMonitorInfo> event,
    std::shared_ptr<KeyOption> keyOption)
{
    CALL_DEBUG_ENTER;
    CHKPP(event);
    CHKPP(keyOption);
    size_t argc = 3;
    napi_value argv[3] = { 0 };
    CHKRP(napi_get_cb_info(env, info, &argc, argv, nullptr, nullptr), GET_CB_INFO);
    napi_value receiveValue = nullptr;
    CHKRP(napi_get_named_property(env, argv[1], "preKeys", &receiveValue), GET_NAMED_PROPERTY);
    if (receiveValue == nullptr) {
        THROWERR_CUSTOM(env, COMMON_PARAMETER_ERROR, "preKeys not found");
        return nullptr;
    }
    std::set<int32_t> preKeys;
    if (GetPreKeys(env, receiveValue, preKeys) == nullptr) {
        MMI_HILOGE("Get preKeys failed");
        return nullptr;
    }
    if (preKeys.size() > PRE_KEYS_SIZE) {
        MMI_HILOGE("PreKeys size invalid");
        THROWERR_CUSTOM(env, COMMON_PARAMETER_ERROR, "preKeys size invalid");
        return nullptr;
    }
    MMI_HILOGD("PreKeys size:%{public}zu", preKeys.size());
    keyOption->SetPreKeys(preKeys);
    std::string subKeyNames = "";
    for (const auto &item : preKeys) {
        subKeyNames += std::to_string(item);
        subKeyNames += ",";
        MMI_HILOGD("preKeys:%{private}d", item);
    }
    std::optional<int32_t> tempFinalKey = GetNamedPropertyInt32(env, argv[1], "finalKey");
    if (!tempFinalKey) {
        MMI_HILOGE("GetNamedPropertyInt32 failed");
        return nullptr;
    }
    int32_t finalKey = tempFinalKey.value();
    if (finalKey < 0) {
        MMI_HILOGE("finalKey:%{private}d is less 0, can not process", finalKey);
        THROWERR_CUSTOM(env, COMMON_PARAMETER_ERROR, "finalKey must be greater than or equal to 0");
        return nullptr;
    }
    subKeyNames += std::to_string(finalKey);
    subKeyNames += ",";
    keyOption->SetFinalKey(finalKey);
    MMI_HILOGD("FinalKey:%{private}d", finalKey);
    bool isFinalKeyDown;
    if (!GetNamedPropertyBool(env, argv[1], "isFinalKeyDown", isFinalKeyDown)) {
        MMI_HILOGE("GetNamedPropertyBool failed");
        return nullptr;
    }
    subKeyNames += std::to_string(isFinalKeyDown);
    subKeyNames += ",";
    keyOption->SetFinalKeyDown(isFinalKeyDown);
    MMI_HILOGD("IsFinalKeyDown:%{private}d,map_key:%{private}s",
        (isFinalKeyDown == true ? 1 : 0), subKeyNames.c_str());
    std::optional<int32_t> tempKeyDownDuration = GetNamedPropertyInt32(env, argv[1], "finalKeyDownDuration");
    if (!tempKeyDownDuration) {
        MMI_HILOGE("GetNamedPropertyInt32 failed");
        return nullptr;
    }
    int32_t finalKeyDownDuration = tempKeyDownDuration.value();
    if (finalKeyDownDuration < 0) {
        MMI_HILOGE("finalKeyDownDuration:%{public}d is less 0, can not process", finalKeyDownDuration);
        THROWERR_CUSTOM(env, COMMON_PARAMETER_ERROR, "finalKeyDownDuration must be greater than or equal to 0");
        return nullptr;
    }
    subKeyNames += std::to_string(finalKeyDownDuration);
    subKeyNames += ",";
    keyOption->SetFinalKeyDownDuration(finalKeyDownDuration);
    MMI_HILOGD("FinalKeyDownDuration:%{public}d", finalKeyDownDuration);
    bool isRepeat = true;
    if (!GetNamedPropertyBool(env, argv[1], "isRepeat", isRepeat)) {
        MMI_HILOGD("IsRepeat field is default");
    }
    subKeyNames += std::to_string(isRepeat);
    keyOption->SetRepeat(isRepeat);
    MMI_HILOGD("IsRepeat:%{public}s", (isRepeat ? "true" : "false"));
    event->eventType = subKeyNames;
    napi_value ret;
    CHKRP(napi_create_int32(env, RET_OK, &ret), CREATE_INT32);
    return ret;
}

static bool IsMatchKeyAction(bool isFinalKeydown, int32_t keyAction)
{
    CALL_DEBUG_ENTER;
    MMI_HILOGD("isFinalKeydown:%{public}d, keyAction:%{public}d", isFinalKeydown, keyAction);
    if (isFinalKeydown && keyAction == KeyEvent::KEY_ACTION_DOWN) {
        return true;
    }
    if (!isFinalKeydown && keyAction == KeyEvent::KEY_ACTION_UP) {
        return true;
    }
    MMI_HILOGE("isFinalKeydown not matched with keyAction");
    return false;
}

static bool MatchCombinationKeys(sptr<KeyEventMonitorInfo> monitorInfo, std::shared_ptr<KeyEvent> keyEvent)
{
    CALL_DEBUG_ENTER;
    CHKPF(monitorInfo);
    CHKPF(keyEvent);
    auto keyOption = monitorInfo->keyOption;
    CHKPF(keyOption);
    std::vector<KeyEvent::KeyItem> items = keyEvent->GetKeyItems();
    int32_t infoFinalKey = keyOption->GetFinalKey();
    int32_t keyEventFinalKey = keyEvent->GetKeyCode();
    bool isFinalKeydown = keyOption->IsFinalKeyDown();
    MMI_HILOGD("InfoFinalKey:%{private}d,keyEventFinalKey:%{private}d", infoFinalKey, keyEventFinalKey);
    if (infoFinalKey != keyEventFinalKey || items.size() > PRE_KEYS_SIZE ||
        !IsMatchKeyAction(isFinalKeydown, keyEvent->GetKeyAction())) {
        MMI_HILOGD("key Param invalid");
        return false;
    }
    std::set<int32_t> infoPreKeys = keyOption->GetPreKeys();
    int32_t infoSize = 0;
    for (auto it = infoPreKeys.begin(); it != infoPreKeys.end(); ++it) {
        if (*it >= 0) {
            infoSize++;
        }
    }
    int32_t count = 0;
    for (const auto &item : items) {
        if (item.GetKeyCode() == keyEventFinalKey) {
            continue;
        }
        auto iter = find(infoPreKeys.begin(), infoPreKeys.end(), item.GetKeyCode());
        if (iter == infoPreKeys.end()) {
            MMI_HILOGW("No keyCode in preKeys");
            return false;
        }
        count++;
    }
    MMI_HILOGD("kevEventSize:%{public}d, infoSize:%{public}d", count, infoSize);
    std::optional<KeyEvent::KeyItem> keyItem = keyEvent->GetKeyItem();
    if (!keyItem) {
        MMI_HILOGE("The keyItem is nullopt");
        return false;
    }
    auto downTime = keyItem->GetDownTime();
    auto upTime = keyEvent->GetActionTime();
    auto curDurationTime = keyOption->GetFinalKeyDownDuration();
    if (curDurationTime > 0 && (upTime - downTime >= (static_cast<int64_t>(curDurationTime) * 1000))) {
        MMI_HILOGE("Skip, upTime - downTime >= duration");
        return false;
    }
    return count == infoSize;
}

static void SubKeyEventCallback(std::shared_ptr<KeyEvent> keyEvent, const std::string& keyOptionKey)
{
    CALL_DEBUG_ENTER;
    CHKPV(keyEvent);
    std::list<sptr<KeyEventMonitorInfo>> info;
    {
        std::lock_guard guard(sCallBacksMutex);
        auto iter = callbacks.find(keyOptionKey);
        if (iter != callbacks.end()) {
            auto &list = iter->second;
            MMI_HILOGD("list size:%{public}zu", list.size());
            for (auto monitorInfo : list) {
                if (MatchCombinationKeys(monitorInfo, keyEvent)) {
                    info.push_back(monitorInfo);
                }
            }
        } else {
            MMI_HILOGE("No Matches found for SubKeyEventCallback");
        }
    }
    while (info.begin() != info.end()) {
        auto it = info.front();
        info.pop_front();
        EmitAsyncCallbackWork(it);
    }
}

static void SubHotkeyEventCallback(std::shared_ptr<KeyEvent> keyEvent)
{
    CALL_DEBUG_ENTER;
    CHKPV(keyEvent);
    std::list<sptr<KeyEventMonitorInfo>> info;
    {
        std::lock_guard guard(sCallBacksMutex);
        auto iter = hotkeyCallbacks.begin();
        while (iter != hotkeyCallbacks.end()) {
            auto &list = iter->second;
            ++iter;
            MMI_HILOGD("Callback list size:%{public}zu", list.size());
            auto infoIter = list.begin();
            while (infoIter != list.end()) {
                auto monitorInfo = *infoIter;
                if (MatchCombinationKeys(monitorInfo, keyEvent)) {
                    info.push_back(monitorInfo);
                }
                ++infoIter;
            }
        }
    }
    while (info.begin() != info.end()) {
        auto it = info.front();
        info.pop_front();
        EmitAsyncCallbackWork(it);
    }
}

std::string GenerateKeyOptionKey(const std::shared_ptr<KeyOption>& keyOption)
{
    CHKPS(keyOption);
    std::string subKeyNames;
    const std::set<int32_t>& preKeys = keyOption->GetPreKeys();
    int32_t finalKey = keyOption->GetFinalKey();
    bool isFinalKeyDown = keyOption->IsFinalKeyDown();
    int32_t finalKeyDownDuration = keyOption->GetFinalKeyDownDuration();
    bool isRepeat = keyOption->IsRepeat();
    for (const auto& key : preKeys) {
        subKeyNames.append(std::to_string(key)).append(",");
    }
    subKeyNames.append(std::to_string(finalKey)).append(",");
    subKeyNames.append(std::to_string(isFinalKeyDown)).append(",");
    subKeyNames.append(std::to_string(finalKeyDownDuration)).append(",");
    subKeyNames.append(std::to_string(isRepeat));
    return subKeyNames;
}

napi_value SubscribeKey(napi_env env, napi_callback_info info, sptr<KeyEventMonitorInfo> event,
    std::shared_ptr<KeyOption> keyOption)
{
    CALL_DEBUG_ENTER;
    CHKPP(event);
    CHKPP(keyOption);
    if (GetEventInfoAPI9(env, info, event, keyOption) == nullptr) {
        MMI_HILOGE("GetEventInfoAPI9 failed");
        return nullptr;
    }
    event->keyOption = keyOption;
    int32_t preSubscribeId = GetPreSubscribeId(callbacks, event);
    if (preSubscribeId < 0) {
        MMI_HILOGD("EventType:%{private}s, eventName:%{public}s", event->eventType.c_str(), event->name.c_str());
        int32_t subscribeId = -1;
        subscribeId = InputManager::GetInstance()->SubscribeKeyEvent(keyOption,
            [keyOption](std::shared_ptr<KeyEvent> keyEvent) {
                std::string keyOptionKey = GenerateKeyOptionKey(keyOption);
                SubKeyEventCallback(keyEvent, keyOptionKey);
            });
        if (subscribeId < 0) {
            MMI_HILOGE("SubscribeId invalid:%{public}d", subscribeId);
            return nullptr;
        }
        MMI_HILOGD("SubscribeId:%{public}d", subscribeId);
        event->subscribeId = subscribeId;
    } else {
        event->subscribeId = preSubscribeId;
    }
    if (AddEventCallback(env, callbacks, event) < 0) {
        MMI_HILOGE("AddEventCallback failed");
        return nullptr;
    }
    napi_value ret;
    CHKRP(napi_create_int32(env, RET_OK, &ret), CREATE_INT32);
    return ret;
}

napi_value SubscribeHotkey(napi_env env, napi_callback_info info, sptr<KeyEventMonitorInfo> event,
    std::shared_ptr<KeyOption> keyOption)
{
    CALL_DEBUG_ENTER;
    CHKPP(event);
    CHKPP(keyOption);
    if (GetHotkeyEventInfo(env, info, event, keyOption) == nullptr) {
        MMI_HILOGE("GetHotkeyEventInfo failed");
        return nullptr;
    }
    event->keyOption = keyOption;
    int32_t preSubscribeId = GetPreSubscribeId(hotkeyCallbacks, event);
    if (preSubscribeId < 0) {
        MMI_HILOGD("EventType:%{private}s, eventName:%{public}s", event->eventType.c_str(), event->name.c_str());
        int32_t subscribeId = -1;
        subscribeId = InputManager::GetInstance()->SubscribeHotkey(keyOption, SubHotkeyEventCallback);
        if (subscribeId == ERROR_UNSUPPORT) {
            MMI_HILOGE("SubscribeId invalid:%{public}d", subscribeId);
            THROWERR_CUSTOM(env, INPUT_DEVICE_NOT_SUPPORTED, "Hotkey occupied by other");
            return nullptr;
        }
        if (subscribeId == OCCUPIED_BY_SYSTEM) {
            MMI_HILOGE("SubscribeId invalid:%{public}d", subscribeId);
            THROWERR_CUSTOM(env, INPUT_OCCUPIED_BY_SYSTEM, "Hotkey occupied by system");
            return nullptr;
        }
        if (subscribeId == OCCUPIED_BY_OTHER) {
            MMI_HILOGE("SubscribeId invalid:%{public}d", subscribeId);
            THROWERR_CUSTOM(env, INPUT_OCCUPIED_BY_OTHER, "Hotkey occupied by other");
            return nullptr;
        }
        MMI_HILOGD("SubscribeId:%{public}d", subscribeId);
        event->subscribeId = subscribeId;
    } else {
        event->subscribeId = preSubscribeId;
    }
    if (AddEventCallback(env, hotkeyCallbacks, event) < 0) {
        MMI_HILOGE("AddEventCallback failed");
        THROWERR_CUSTOM(env, COMMON_PARAMETER_ERROR, "AddEventCallback failed");
        return nullptr;
    }
    napi_value ret;
    CHKRP(napi_create_int32(env, RET_OK, &ret), CREATE_INT32);
    return ret;
}

bool GetEventType(napi_env env, napi_callback_info info, sptr<KeyEventMonitorInfo> event, std::string &keyType)
{
    CALL_DEBUG_ENTER;
    size_t argc = 3;
    napi_value argv[3] = { 0 };
    CHKRF(napi_get_cb_info(env, info, &argc, argv, nullptr, nullptr), GET_CB_INFO);
    if (argc < INPUT_PARAMETER_MIDDLE) {
        MMI_HILOGE("Parameter number error argc:%{public}zu", argc);
        THROWERR_CUSTOM(env, COMMON_PARAMETER_ERROR, "parameter number error");
        return false;
    }
    if (!UtilNapi::TypeOf(env, argv[0], napi_string)) {
        MMI_HILOGE("The first parameter is not string");
        THROWERR_API9(env, COMMON_PARAMETER_ERROR, "type", "string");
        return false;
    }
    if (!UtilNapi::TypeOf(env, argv[1], napi_object)) {
        MMI_HILOGE("The second parameter is not napi_object");
        THROWERR_API9(env, COMMON_PARAMETER_ERROR, "keyOptions", "object");
        return false;
    }
    CHKPF(event);
    if (argc == INPUT_PARAMETER_MAX) {
        napi_valuetype valueType = napi_undefined;
        CHKRF(napi_typeof(env, argv[INPUT_PARAMETER_MIDDLE], &valueType), TYPEOF);
        if (valueType != napi_function) {
            MMI_HILOGE("The third parameter is not napi_function");
            THROWERR_API9(env, COMMON_PARAMETER_ERROR, "callback", "function");
            return false;
        }
        CHKRF(napi_create_reference(env, argv[INPUT_PARAMETER_MIDDLE], 1, &event->callback), REFERENCE_REF);
    } else {
        event->callback = nullptr;
    }

    char eventType[EVENT_NAME_LEN] = { 0 };
    size_t typeLen = 0;
    CHKRF(napi_get_value_string_utf8(env, argv[0], eventType, EVENT_NAME_LEN - 1, &typeLen), GET_VALUE_STRING_UTF8);
    keyType = eventType;
    if (keyType != SUBSCRIBE_TYPE && keyType != HOTKEY_SUBSCRIBE_TYPE) {
        MMI_HILOGE("Type is not key or hotkey");
        THROWERR_CUSTOM(env, COMMON_PARAMETER_ERROR, "Type must be key or hotkeyChange");
        return false;
    }
    return true;
}

static std::optional<std::string> ResolveEventType(napi_env env, napi_callback_info info)
{
    CALL_DEBUG_ENTER;
    size_t argc { KEY_MONITOR_EXPECT_N_PARAMS };
    napi_value argv[KEY_MONITOR_EXPECT_N_PARAMS] {};

    auto ret = napi_get_cb_info(env, info, &argc, argv, nullptr, nullptr);
    if (ret != napi_ok) {
        MMI_HILOGE("napi_get_cb_info fail");
        return std::nullopt;
    }
    if (argc < AT_LEAST_ONE_PARAMETER) {
        MMI_HILOGE("Type of subscription is required");
        THROWERR_CUSTOM(env, COMMON_PARAMETER_ERROR, "Type of subscription is required");
        return std::nullopt;
    }
    if (!UtilNapi::TypeOf(env, argv[FIRST_PARAMETER], napi_string)) {
        MMI_HILOGE("The first parameter is not string");
        return std::nullopt;
    }
    char eventType[EVENT_NAME_LEN] {};
    size_t typeLen { 0 };

    ret = napi_get_value_string_utf8(env, argv[0], eventType, sizeof(eventType), &typeLen);
    if (ret != napi_ok) {
        MMI_HILOGE("napi_get_value_string_utf8 fail");
        return std::nullopt;
    }
    return std::string(eventType);
}

static napi_value JsOn(napi_env env, napi_callback_info info)
{
    CALL_DEBUG_ENTER;
    auto etOpt = ResolveEventType(env, info);
    if (etOpt && (*etOpt == KEY_MONITOR_SUBSCRIBE_TYPE)) {
        JsInputConsumer::GetInstance()->SubscribeKeyMonitor(env, info);
        return nullptr;
    }
    sptr<KeyEventMonitorInfo> event = new (std::nothrow) KeyEventMonitorInfo(env);
    CHKPP(event);
    auto keyOption = std::make_shared<KeyOption>();
    std::string keyType;
    size_t argc = 3;
    napi_value argv[3] = { 0 };
    if (napi_get_cb_info(env, info, &argc, argv, nullptr, nullptr) != napi_ok) {
        MMI_HILOGE("GET_CB_INFO failed");
        return nullptr;
    }
    if (argc < INPUT_PARAMETER_MAX) {
        MMI_HILOGE("Parameter number error argc:%{public}zu", argc);
        THROWERR_CUSTOM(env, COMMON_PARAMETER_ERROR, "parameter number error");
        return nullptr;
    }
    if (!GetEventType(env, info, event, keyType)) {
        MMI_HILOGE("GetEventType fail, type must be key or hotkeyChange");
        return nullptr;
    }
    event->name = keyType;
    if (keyType == HOTKEY_SUBSCRIBE_TYPE) {
        if (SubscribeHotkey(env, info, event, keyOption) == nullptr) {
            MMI_HILOGE("SubscribeHotkey failed");
            return nullptr;
        }
    } else {
        if (SubscribeKey(env, info, event, keyOption) == nullptr) {
            MMI_HILOGE("SubscribeKey failed");
            return nullptr;
        }
    }
    return nullptr;
}

static napi_value JsOff(napi_env env, napi_callback_info info)
{
    CALL_DEBUG_ENTER;
    auto etOpt = ResolveEventType(env, info);
    if (etOpt && (*etOpt == KEY_MONITOR_SUBSCRIBE_TYPE)) {
        JsInputConsumer::GetInstance()->UnsubscribeKeyMonitor(env, info);
        return nullptr;
    }
    sptr<KeyEventMonitorInfo> event = new (std::nothrow) KeyEventMonitorInfo(env);
    CHKPP(event);
    auto keyOption = std::make_shared<KeyOption>();
    std::string keyType;
    if (!GetEventType(env, info, event, keyType)) {
        MMI_HILOGE("GetEventType fail, type must be key or hotkeyChange");
        return nullptr;
    }
    event->name = keyType;
    int32_t subscribeId = -1;
    if (keyType == HOTKEY_SUBSCRIBE_TYPE) {
        if (GetHotkeyEventInfo(env, info, event, keyOption) == nullptr) {
            MMI_HILOGE("GetHotkeyEventInfo failed");
            return nullptr;
        }
        if (DelEventCallback(env, hotkeyCallbacks, event, subscribeId) < 0) {
            MMI_HILOGE("DelEventCallback failed");
            return nullptr;
        }
        MMI_HILOGI("Unsubscribe hot key(%{public}d)", subscribeId);
        InputManager::GetInstance()->UnsubscribeHotkey(subscribeId);
    } else {
        if (GetEventInfoAPI9(env, info, event, keyOption) == nullptr) {
            MMI_HILOGE("GetEventInfoAPI9 failed");
            return nullptr;
        }
        if (DelEventCallback(env, callbacks, event, subscribeId) < 0) {
            MMI_HILOGE("DelEventCallback failed");
            return nullptr;
        }
        MMI_HILOGI("Unsubscribe key event(%{public}d)", subscribeId);
        InputManager::GetInstance()->UnsubscribeKeyEvent(subscribeId);
    }
    return nullptr;
}

static napi_value SetShieldStatus(napi_env env, napi_callback_info info)
{
    CALL_DEBUG_ENTER;
    size_t argc = 2;
    napi_value argv[2] = { 0 };
    CHKRP(napi_get_cb_info(env, info, &argc, argv, nullptr, nullptr), GET_CB_INFO);
    if (argc < INPUT_PARAMETER_MIDDLE) {
        MMI_HILOGE("At least two parameters is required");
        THROWERR_API9(env, COMMON_PARAMETER_ERROR, "shieldMode", "number");
        return nullptr;
    }
    if (!JsCommon::TypeOf(env, argv[0], napi_number)) {
        MMI_HILOGE("shieldMode parameter type is invalid");
        THROWERR_API9(env, COMMON_PARAMETER_ERROR, "shieldMode", "number");
        return nullptr;
    }
    int32_t shieldMode = 0;
    CHKRP(napi_get_value_int32(env, argv[0], &shieldMode), GET_VALUE_INT32);
    if (shieldMode < FACTORY_MODE || shieldMode > OOBE_MODE) {
        MMI_HILOGE("Undefined shield mode");
        THROWERR_CUSTOM(env, COMMON_PARAMETER_ERROR, "Shield mode does not exist");
        return nullptr;
    }

    if (!JsCommon::TypeOf(env, argv[1], napi_boolean)) {
        MMI_HILOGE("isShield parameter type is invalid");
        THROWERR_API9(env, COMMON_PARAMETER_ERROR, "isShield", "boolean");
        return nullptr;
    }
    bool isShield = true;
    CHKRP(napi_get_value_bool(env, argv[1], &isShield), GET_VALUE_BOOL);

    int32_t errCode = InputManager::GetInstance()->SetShieldStatus(shieldMode, isShield);
    JsCommon::ThrowError(env, errCode);
    napi_value result = nullptr;
    if (napi_get_undefined(env, &result) != napi_ok) {
        MMI_HILOGE("Get undefined result is failed");
        return nullptr;
    }
    return result;
}

static napi_value GetShieldStatus(napi_env env, napi_callback_info info)
{
    CALL_DEBUG_ENTER;
    size_t argc = 1;
    napi_value argv[1] = { 0 };
    CHKRP(napi_get_cb_info(env, info, &argc, argv, nullptr, nullptr), GET_CB_INFO);
    if (argc < 1) {
        MMI_HILOGE("At least 1 parameter is required");
        THROWERR_API9(env, COMMON_PARAMETER_ERROR, "shieldMode", "number");
        return nullptr;
    }
    if (!JsCommon::TypeOf(env, argv[0], napi_number)) {
        MMI_HILOGE("shieldMode parameter type is invalid");
        THROWERR_API9(env, COMMON_PARAMETER_ERROR, "shieldMode", "number");
        return nullptr;
    }
    int32_t shieldMode = 0;
    CHKRP(napi_get_value_int32(env, argv[0], &shieldMode), GET_VALUE_INT32);
    if (shieldMode < FACTORY_MODE || shieldMode > OOBE_MODE) {
        MMI_HILOGE("Undefined shield mode");
        THROWERR_CUSTOM(env, COMMON_PARAMETER_ERROR, "Shield mode does not exist");
        return nullptr;
    }
    bool isShield { false };
    auto errCode = InputManager::GetInstance()->GetShieldStatus(shieldMode, isShield);
    JsCommon::ThrowError(env, errCode);
    napi_value result = nullptr;
    NAPI_CALL(env, napi_get_boolean(env, isShield, &result));
    return result;
}

static napi_value GetAllSystemHotkeys(napi_env env, napi_callback_info info)
{
    CALL_DEBUG_ENTER;
    return GetSystemHotkey(env);
}

static napi_value EnumConstructor(napi_env env, napi_callback_info info)
{
    CALL_DEBUG_ENTER;
    size_t argc = 0;
    napi_value args[1] = { 0 };
    napi_value ret = nullptr;
    void *data = nullptr;
    CHKRP(napi_get_cb_info(env, info, &argc, args, &ret, &data), GET_CB_INFO);
    return ret;
}

static napi_value CreateShieldMode(napi_env env, napi_value exports)
{
    CALL_DEBUG_ENTER;
    napi_value factory_mode = nullptr;
    CHKRP(napi_create_int32(env, SHIELD_MODE::FACTORY_MODE, &factory_mode), CREATE_INT32);
    napi_value oobe_mode = nullptr;
    CHKRP(napi_create_int32(env, SHIELD_MODE::OOBE_MODE, &oobe_mode), CREATE_INT32);

    napi_property_descriptor desc[] = {
        DECLARE_NAPI_STATIC_PROPERTY("FACTORY_MODE", factory_mode),
        DECLARE_NAPI_STATIC_PROPERTY("OOBE_MODE", oobe_mode),
    };
    napi_value result = nullptr;
    CHKRP(napi_define_class(env, "ShieldMode", NAPI_AUTO_LENGTH, EnumConstructor, nullptr,
        sizeof(desc) / sizeof(*desc), desc, &result), DEFINE_CLASS);
    CHKRP(napi_set_named_property(env, exports, "ShieldMode", result), SET_NAMED_PROPERTY);
    return exports;
}

KeyEventMonitorInfo::KeyEventMonitorInfo(napi_env env):env(env)
{
    (void)napi_add_env_cleanup_hook(env, EnvCleanUp, this);
}

KeyEventMonitorInfo::~KeyEventMonitorInfo()
{
    std::lock_guard<std::mutex> lock(envMutex_);
    if (env == nullptr) {
        return;
    }
    (void)napi_remove_env_cleanup_hook(env, EnvCleanUp, this);
    if (callback == nullptr) {
        return;
    }
    uint32_t refcount = 0;
    CHKRV(napi_reference_unref(env, callback, &refcount), REFERENCE_UNREF);
    if (refcount == 0) {
        CHKRV(napi_delete_reference(env, callback), DELETE_REFERENCE);
    }
    callback = nullptr;
}

const std::set<int32_t> JsInputConsumer::allowedKeys_ {
    KeyEvent::KEYCODE_VOLUME_DOWN,
    KeyEvent::KEYCODE_VOLUME_UP,
};

std::shared_ptr<JsInputConsumer> JsInputConsumer::GetInstance()
{
    static std::once_flag flag;
    static std::shared_ptr<JsInputConsumer> instance_;

    std::call_once(flag, []() {
        instance_ = std::make_shared<JsInputConsumer>();
    });
    return instance_;
}

bool JsInputConsumer::KeyMonitor::Parse(napi_env env, napi_callback_info info)
{
    size_t argc { KEY_MONITOR_EXPECT_N_PARAMS };
    napi_value argv[KEY_MONITOR_EXPECT_N_PARAMS] {};
    CHKRF(napi_get_cb_info(env, info, &argc, argv, nullptr, nullptr), GET_CB_INFO);

    if (argc < KEY_MONITOR_EXPECT_N_PARAMS) {
        MMI_HILOGE("Parameter number error argc:%{public}zu", argc);
        THROWERR_CUSTOM(env, COMMON_PARAMETER_ERROR, "parameter number error");
        return false;
    }
    if (!UtilNapi::TypeOf(env, argv[FIRST_PARAMETER], napi_string)) {
        MMI_HILOGE("The first parameter is not string");
        THROWERR_API9(env, COMMON_PARAMETER_ERROR, "type", "string");
        return false;
    }
    if (!UtilNapi::TypeOf(env, argv[SECOND_PARAMETER], napi_object)) {
        MMI_HILOGE("The second parameter is not object");
        THROWERR_API9(env, COMMON_PARAMETER_ERROR, "options", "object");
        return false;
    }
    if (!UtilNapi::TypeOf(env, argv[THIRD_PARAMETER], napi_function)) {
        MMI_HILOGE("The third parameter is not function");
        THROWERR_API9(env, COMMON_PARAMETER_ERROR, "callback", "function");
        return false;
    }
    if (!ParseKeyMonitorOption(env, argv[SECOND_PARAMETER])) {
        MMI_HILOGE("Invalid KeyMonitorOption");
        return false;
    }
    auto ret = napi_create_reference(env, argv[THIRD_PARAMETER], DEFAULT_REFERENCE_COUNT, &callback_);
    if (ret != napi_ok) {
        MMI_HILOGE("napi_create_reference fail");
        return false;
    }
    env_ = env;
    return true;
}

bool JsInputConsumer::KeyMonitor::ParseKeyMonitorOption(napi_env env, napi_value keyOption)
{
    CALL_DEBUG_ENTER;
    auto optKey = GetNamedPropertyInt32(env, keyOption, "key");
    if (!optKey) {
        MMI_HILOGE("Expect 'key'");
        THROWERR_CUSTOM(env, COMMON_PARAMETER_ERROR, "Expect 'key'");
        return false;
    }
    auto optAction = GetNamedPropertyInt32(env, keyOption, "action");
    if (!optAction) {
        MMI_HILOGE("Expect 'action'");
        THROWERR_CUSTOM(env, COMMON_PARAMETER_ERROR, "Expect 'action'");
        return false;
    }
    bool isRepeat { true };
    if (!GetNamedPropertyBool(env, keyOption, "isRepeat", isRepeat)) {
        MMI_HILOGE("Expect 'isRepeat'");
        THROWERR_CUSTOM(env, COMMON_PARAMETER_ERROR, "Expect 'isRepeat'");
        return false;
    }

    keyOption_.SetKey(*optKey);
    keyOption_.SetAction(JsInputConsumer::JsKeyAction2KeyAction(*optAction));
    keyOption_.SetRepeat(isRepeat);

    if (!JsInputConsumer::CheckKeyMonitorOption(keyOption_)) {
        MMI_HILOGE("Input for KeyPressedConfig is invalid");
        THROWERR_CUSTOM(env, COMMON_PARAMETER_ERROR, "Input for KeyPressedConfig is invalid");
        return false;
    }
    return true;
}

bool JsInputConsumer::KeyMonitor::ParseUnsubscription(napi_env env, napi_callback_info info)
{
    size_t argc { KEY_MONITOR_EXPECT_N_PARAMS };
    napi_value argv[KEY_MONITOR_EXPECT_N_PARAMS] {};

    auto ret = napi_get_cb_info(env, info, &argc, argv, nullptr, nullptr);
    if (ret != napi_ok) {
        MMI_HILOGE("napi_get_cb_info fail");
        return false;
    }
    if (argc < AT_LEAST_ONE_PARAMETER) {
        MMI_HILOGE("Type of subscription is required");
        THROWERR_CUSTOM(env, COMMON_PARAMETER_ERROR, "Type of subscription is required");
        return false;
    }
    if (argc == AT_LEAST_ONE_PARAMETER) {
        callback_ = nullptr;
        return true;
    }
    if (!UtilNapi::TypeOf(env, argv[SECOND_PARAMETER], napi_function)) {
        MMI_HILOGE("The second parameter is not function");
        THROWERR_API9(env, COMMON_PARAMETER_ERROR, "callback", "function");
        return false;
    }
    ret = napi_create_reference(env, argv[SECOND_PARAMETER], DEFAULT_REFERENCE_COUNT, &callback_);
    if (ret != napi_ok) {
        MMI_HILOGE("napi_create_reference fail");
        return false;
    }
    env_ = env;
    return true;
}

void JsInputConsumer::SubscribeKeyMonitor(napi_env env, napi_callback_info info)
{
    std::lock_guard guard(mutex_);
    KeyMonitor keyMonitor {};

    if (!keyMonitor.Parse(env, info)) {
        MMI_HILOGE("Unexpected key monitor");
        return;
    }
    MMI_HILOGI("[NAPI] Subscribe key monitor");
    if (!SubscribeKeyMonitor(env, keyMonitor)) {
        CleanupKeyMonitor(env, keyMonitor);
    }
}

void JsInputConsumer::UnsubscribeKeyMonitor(napi_env env, napi_callback_info info)
{
    std::lock_guard guard(mutex_);
    KeyMonitor keyMonitor {};

    if (!keyMonitor.ParseUnsubscription(env, info)) {
        MMI_HILOGE("Unexpected key monitor");
        return;
    }
    if (keyMonitor.callback_ != nullptr) {
        MMI_HILOGI("[NAPI] Unsubscribe key monitor");
        UnsubscribeKeyMonitor(env, keyMonitor);
    } else {
        UnsubscribeKeyMonitors(env);
    }
    CleanupKeyMonitor(env, keyMonitor);
}

size_t JsInputConsumer::GenerateId()
{
    return ++baseId_;
}

void JsInputConsumer::CleanupKeyMonitor(napi_env env, KeyMonitor &keyMonitor) const
{
    if (keyMonitor.callback_ != nullptr) {
        auto ret = napi_delete_reference(env, keyMonitor.callback_);
        if (ret != napi_ok) {
            MMI_HILOGE("napi_delete_reference fail");
        }
        keyMonitor.callback_ = nullptr;
    }
}

int32_t JsInputConsumer::IsIdentical(napi_env env, const KeyMonitor &sMonitor, const KeyMonitor &tMonitor) const
{
    napi_value sHandler { nullptr };
    napi_value tHandler { nullptr };
    bool isEqual { false };

    auto ret = napi_get_reference_value(env, sMonitor.callback_, &sHandler);
    if (ret != napi_ok) {
        MMI_HILOGE("napi_get_reference_value fail");
        return BOOLEAN_NONE;
    }
    ret = napi_get_reference_value(env, tMonitor.callback_, &tHandler);
    if (ret != napi_ok) {
        MMI_HILOGE("napi_get_reference_value fail");
        return BOOLEAN_NONE;
    }
    ret = napi_strict_equals(env, sHandler, tHandler, &isEqual);
    if (ret != napi_ok) {
        MMI_HILOGE("napi_strict_equals fail");
        return BOOLEAN_NONE;
    }
    return (isEqual ? BOOLEAN_TRUE : BOOLEAN_FALSE);
}

int32_t JsInputConsumer::HasSubscribed(napi_env env, const KeyMonitor &keyMonitor) const
{
    napi_value sHandler { nullptr };
    auto ret = napi_get_reference_value(env, keyMonitor.callback_, &sHandler);
    if (ret != napi_ok) {
        MMI_HILOGE("napi_get_reference_value fail");
        return BOOLEAN_NONE;
    }
    for (const auto &[_, monitor] : monitors_) {
        napi_value tHandler { nullptr };
        auto ret = napi_get_reference_value(env, monitor.callback_, &tHandler);
        if (ret != napi_ok) {
            MMI_HILOGE("napi_get_reference_value fail");
            return BOOLEAN_NONE;
        }
        bool isEqual { false };
        ret = napi_strict_equals(env, sHandler, tHandler, &isEqual);
        if (ret != napi_ok) {
            MMI_HILOGE("napi_strict_equals fail");
            return BOOLEAN_NONE;
        }
        if (isEqual) {
            MMI_HILOGE("Callback already exist");
            return BOOLEAN_TRUE;
        }
    }
    return BOOLEAN_FALSE;
}

bool JsInputConsumer::SubscribeKeyMonitor(napi_env env, KeyMonitor &keyMonitor)
{
    auto hasSubscribed = HasSubscribed(env, keyMonitor);
    if (hasSubscribed < 0) {
        MMI_HILOGE("HasSubscribed fail");
        return false;
    }
    if (hasSubscribed) {
        MMI_HILOGE("Duplicate subscription of key monitor");
        return false;
    }
    auto keyMonitorId = GenerateId();
    auto subscriberId = InputManager::GetInstance()->SubscribeKeyMonitor(keyMonitor.keyOption_,
        [keyMonitorId](std::shared_ptr<KeyEvent> keyEvent) {
            JsInputConsumer::GetInstance()->OnSubscribeKeyMonitor(keyMonitorId, keyEvent);
        });
    if (subscriberId < 0) {
        if (subscriberId == -CAPABILITY_NOT_SUPPORTED) {
            MMI_HILOGE("Capability not supported");
            THROWERR_CUSTOM(env, INPUT_DEVICE_NOT_SUPPORTED, "Capability not supported.");
        } else if (subscriberId == -PARAM_INPUT_INVALID) {
            MMI_HILOGE("Input is invalid");
            THROWERR_CUSTOM(env, COMMON_PARAMETER_ERROR, "Input is invalid");
        } else {
            MMI_HILOGE("SubscribeKeyMonitor fail, error:%{public}d", subscriberId);
        }
        return false;
    }
    MMI_HILOGI("[NAPI] Subscribe key monitor(ID:%{public}zu, subscriberId:%{public}d)", keyMonitorId, subscriberId);
    keyMonitor.env_ = env;
    keyMonitor.subscriberId_ = subscriberId;
    monitors_.emplace(keyMonitorId, keyMonitor);
    return true;
}

void JsInputConsumer::UnsubscribeKeyMonitor(napi_env env, const KeyMonitor &keyMonitor)
{
    for (auto mIter = monitors_.begin(); mIter != monitors_.end(); ++mIter) {
        auto identical = IsIdentical(env, keyMonitor, mIter->second);
        if (identical < 0) {
            MMI_HILOGE("IsIdentical fail");
            return;
        }
        if (identical) {
            auto &tMonitor = mIter->second;
            MMI_HILOGI("[NAPI] Unsubscribe key monitor(ID:%{public}zu, subscriberId:%{public}d)",
                mIter->first, tMonitor.subscriberId_);
            auto ret = InputManager::GetInstance()->UnsubscribeKeyMonitor(tMonitor.subscriberId_);
            if (ret == -CAPABILITY_NOT_SUPPORTED) {
                MMI_HILOGE("Capability not supported");
                THROWERR_CUSTOM(env, INPUT_DEVICE_NOT_SUPPORTED, "Capability not supported.");
            } else if (ret == -PARAM_INPUT_INVALID) {
                MMI_HILOGE("Input is invalid");
                THROWERR_CUSTOM(env, COMMON_PARAMETER_ERROR, "Input is invalid");
            } else if (ret != RET_OK) {
                MMI_HILOGE("UnsubscribeKeyMonitor fail, error:%{public}d", ret);
            }
            CleanupKeyMonitor(env, tMonitor);
            monitors_.erase(mIter);
            return;
        }
    }
    auto ret = InputManager::GetInstance()->UnsubscribeKeyMonitor(INVALID_SUBSCRIBER_ID);
    if (ret == -CAPABILITY_NOT_SUPPORTED) {
        MMI_HILOGE("Capability not supported");
        THROWERR_CUSTOM(env, INPUT_DEVICE_NOT_SUPPORTED, "Capability not supported.");
    } else {
        MMI_HILOGE("Input is invalid");
        THROWERR_CUSTOM(env, COMMON_PARAMETER_ERROR, "Input is invalid");
    }
}

void JsInputConsumer::UnsubscribeKeyMonitors(napi_env env)
{
    if (monitors_.empty()) {
        auto ret = InputManager::GetInstance()->UnsubscribeKeyMonitor(INVALID_SUBSCRIBER_ID);
        if (ret == -CAPABILITY_NOT_SUPPORTED) {
            MMI_HILOGE("Capability not supported");
            THROWERR_CUSTOM(env, INPUT_DEVICE_NOT_SUPPORTED, "Capability not supported.");
        }
        return;
    }
    for (auto &[monitorId, monitor] : monitors_) {
        MMI_HILOGI("[NAPI] Unsubscribe key monitor(ID:%{public}zu, subscriberId:%{public}d)",
            monitorId, monitor.subscriberId_);
        auto ret = InputManager::GetInstance()->UnsubscribeKeyMonitor(monitor.subscriberId_);
        if (ret != RET_OK) {
            MMI_HILOGE("UnsubscribeKeyMonitor fail, error:%{public}d", ret);
        }
        CleanupKeyMonitor(env, monitor);
    }
    monitors_.clear();
}

void JsInputConsumer::OnSubscribeKeyMonitor(size_t keyMonitorId, std::shared_ptr<KeyEvent> keyEvent)
{
    CALL_DEBUG_ENTER;
    CHKPV(keyEvent);
    std::lock_guard guard(mutex_);
    auto mIter = monitors_.find(keyMonitorId);
    if (mIter == monitors_.end()) {
        MMI_HILOGE("No key monitor with ID(%{public}zu)", keyMonitorId);
        return;
    }
    auto &monitor = mIter->second;
    uv_loop_s *loop = nullptr;
    CHKRV(napi_get_uv_event_loop(monitor.env_, &loop), GET_UV_EVENT_LOOP);

    auto work = std::make_shared<Work>();
    work->keyMonitorId_ = keyMonitorId;
    work->work_.data = work.get();
    work->keyEvent_ = keyEvent;

    auto ret = uv_queue_work_with_qos(
        loop, &work->work_,
        [](uv_work_t *work) {
            MMI_HILOGD("uv_queue_work callback function is called");
        },
        JsInputConsumer::HandleKeyMonitor, uv_qos_user_initiated);
    if (ret != 0) {
        MMI_HILOGE("uv_queue_work_with_qos fail, error:%{public}d", ret);
        return;
    }
    pendingWorks_.emplace(&work->work_, work);
}

void JsInputConsumer::NotifyKeyMonitor(uv_work_t *work, int32_t status)
{
    CALL_DEBUG_ENTER;
    std::lock_guard guard(mutex_);
    auto pwIter = pendingWorks_.find(work);
    if (pwIter == pendingWorks_.end()) {
        return;
    }
    auto keyMonitorId = pwIter->second->keyMonitorId_;
    auto keyEvent = pwIter->second->keyEvent_;
    pendingWorks_.erase(pwIter);

    auto mIter = monitors_.find(keyMonitorId);
    if (mIter == monitors_.end()) {
        MMI_HILOGE("No key monitor with ID(%{public}zu)", keyMonitorId);
        return;
    }
    NotifyKeyMonitor(mIter->second, keyEvent);
}

void JsInputConsumer::NotifyKeyMonitor(const KeyMonitor &keyMonitor, std::shared_ptr<KeyEvent> keyEvent)
{
    napi_handle_scope scope { nullptr };
    napi_open_handle_scope(keyMonitor.env_, &scope);
    CHKPV(scope);
    NotifyKeyMonitorScoped(keyMonitor, keyEvent);
    napi_close_handle_scope(keyMonitor.env_, scope);
}

void JsInputConsumer::NotifyKeyMonitorScoped(const KeyMonitor &keyMonitor, std::shared_ptr<KeyEvent> keyEvent)
{
    napi_value callback { nullptr };
    CHKRV(napi_get_reference_value(keyMonitor.env_, keyMonitor.callback_, &callback), GET_REFERENCE_VALUE);
    napi_value jsKeyEvent = JsInputConsumer::KeyEvent2JsKeyEvent(keyMonitor.env_, keyEvent);
    CHKPV(jsKeyEvent);
    napi_value result { nullptr };
    CHKRV(napi_call_function(keyMonitor.env_, nullptr, callback, 1, &jsKeyEvent, &result), CALL_FUNCTION);
}

bool JsInputConsumer::CheckKeyMonitorOption(const KeyMonitorOption &keyOption)
{
    return ((allowedKeys_.find(keyOption.GetKey()) != allowedKeys_.cend()) &&
            (keyOption.GetAction() == KeyEvent::KEY_ACTION_DOWN));
}

napi_value JsInputConsumer::KeyEvent2JsKeyEvent(napi_env env, std::shared_ptr<KeyEvent> keyEvent)
{
    CHKPP(keyEvent);
    napi_value jsKeyEvent { nullptr };
    CHKRP(napi_create_object(env, &jsKeyEvent), CREATE_OBJECT);

    SetNamedProperty(env, jsKeyEvent, std::string("id"), keyEvent->GetId());
    SetNamedProperty(env, jsKeyEvent, std::string("deviceId"), keyEvent->GetDeviceId());
    SetNamedProperty(env, jsKeyEvent, std::string("actionTime"), keyEvent->GetActionTime());
    SetNamedProperty(env, jsKeyEvent, std::string("screenId"), keyEvent->GetTargetDisplayId());
    SetNamedProperty(env, jsKeyEvent, std::string("windowId"), keyEvent->GetTargetWindowId());
    SetNamedProperty(env, jsKeyEvent, std::string("action"), KeyAction2JsKeyAction(keyEvent->GetKeyAction()));

    auto keyItem = keyEvent->GetKeyItem();
    if (!keyItem) {
        MMI_HILOGE("No key item(No:%{public}d,KC:%{private}d)", keyEvent->GetId(), keyEvent->GetKeyCode());
        return nullptr;
    }
    napi_value jsKey = JsInputConsumer::KeyItem2JsKey(env, *keyItem);
    CHKPP(jsKey);
    CHKRP(napi_set_named_property(env, jsKeyEvent, "key", jsKey), SET_NAMED_PROPERTY);
    SetNamedProperty(env, jsKeyEvent, std::string("unicodeChar"), keyItem->GetUnicode());

    napi_value jsKeys { nullptr };
    uint32_t index { 0 };

    CHKRP(napi_create_array(env, &jsKeys), CREATE_ARRAY);
    auto keyItems = keyEvent->GetKeyItems();

    for (const auto &keyItem : keyItems) {
        jsKey = JsInputConsumer::KeyItem2JsKey(env, keyItem);
        CHKPP(jsKey);
        CHKRP(napi_set_element(env, jsKeys, index++, jsKey), SET_ELEMENT);
    }

    CHKRP(napi_set_named_property(env, jsKeyEvent, "keys", jsKeys), SET_NAMED_PROPERTY);
    SetNamedProperty(env, jsKeyEvent, std::string("ctrlKey"),
        (keyEvent->GetKeyItem(KeyEvent::KEYCODE_CTRL_LEFT) || keyEvent->GetKeyItem(KeyEvent::KEYCODE_CTRL_RIGHT)));
    SetNamedProperty(env, jsKeyEvent, std::string("altKey"),
        (keyEvent->GetKeyItem(KeyEvent::KEYCODE_ALT_LEFT) || keyEvent->GetKeyItem(KeyEvent::KEYCODE_ALT_RIGHT)));
    SetNamedProperty(env, jsKeyEvent, std::string("shiftKey"),
        (keyEvent->GetKeyItem(KeyEvent::KEYCODE_SHIFT_LEFT) || keyEvent->GetKeyItem(KeyEvent::KEYCODE_SHIFT_RIGHT)));
    SetNamedProperty(env, jsKeyEvent, std::string("logoKey"),
        (keyEvent->GetKeyItem(KeyEvent::KEYCODE_META_LEFT) || keyEvent->GetKeyItem(KeyEvent::KEYCODE_META_RIGHT)));
    SetNamedProperty(env, jsKeyEvent, std::string("fnKey"), keyEvent->GetKeyItem(KeyEvent::KEYCODE_FN).has_value());
    SetNamedProperty(env, jsKeyEvent, std::string("capsLock"),
        keyEvent->GetFunctionKey(KeyEvent::CAPS_LOCK_FUNCTION_KEY));
    SetNamedProperty(env, jsKeyEvent, std::string("numLock"),
        keyEvent->GetFunctionKey(KeyEvent::NUM_LOCK_FUNCTION_KEY));
    SetNamedProperty(env, jsKeyEvent, std::string("scrollLock"),
        keyEvent->GetFunctionKey(KeyEvent::SCROLL_LOCK_FUNCTION_KEY));
    return jsKeyEvent;
}

napi_value JsInputConsumer::KeyItem2JsKey(napi_env env, const KeyEvent::KeyItem &keyItem)
{
    napi_value jsKey { nullptr };
    CHKRP(napi_create_object(env, &jsKey), CREATE_OBJECT);
    SetNamedProperty(env, jsKey, std::string("code"), keyItem.GetKeyCode());
    SetNamedProperty(env, jsKey, std::string("pressedTime"), keyItem.GetDownTime());
    SetNamedProperty(env, jsKey, std::string("deviceId"), keyItem.GetDeviceId());
    return jsKey;
}

void JsInputConsumer::HandleKeyMonitor(uv_work_t *work, int32_t status)
{
    JsInputConsumer::GetInstance()->NotifyKeyMonitor(work, status);
}

int32_t JsInputConsumer::JsKeyAction2KeyAction(int32_t action)
{
    static const std::map<int32_t, int32_t> keyActionMap {
        { JsKeyAction::JS_KEY_ACTION_CANCEL, KeyEvent::KEY_ACTION_CANCEL },
        { JsKeyAction::JS_KEY_ACTION_DOWN, KeyEvent::KEY_ACTION_DOWN },
        { JsKeyAction::JS_KEY_ACTION_UP, KeyEvent::KEY_ACTION_UP },
    };
    if (auto iter = keyActionMap.find(action); iter != keyActionMap.cend()) {
        return iter->second;
    } else {
        return KeyEvent::KEY_ACTION_UNKNOWN;
    }
}

int32_t JsInputConsumer::KeyAction2JsKeyAction(int32_t action)
{
    static const std::map<int32_t, int32_t> keyActionMap {
        { KeyEvent::KEY_ACTION_CANCEL, JsKeyAction::JS_KEY_ACTION_CANCEL },
        { KeyEvent::KEY_ACTION_DOWN, JsKeyAction::JS_KEY_ACTION_DOWN },
        { KeyEvent::KEY_ACTION_UP, JsKeyAction::JS_KEY_ACTION_UP },
    };
    if (auto iter = keyActionMap.find(action); iter != keyActionMap.cend()) {
        return iter->second;
    } else {
        return JsKeyAction::JS_KEY_ACTION_CANCEL;
    }
}

EXTERN_C_START
static napi_value MmiInit(napi_env env, napi_value exports)
{
    CALL_DEBUG_ENTER;
    napi_property_descriptor desc[] = {
        DECLARE_NAPI_FUNCTION("on", JsOn),
        DECLARE_NAPI_FUNCTION("off", JsOff),
        DECLARE_NAPI_FUNCTION("setShieldStatus", SetShieldStatus),
        DECLARE_NAPI_FUNCTION("getShieldStatus", GetShieldStatus),
        DECLARE_NAPI_FUNCTION("getAllSystemHotkeys", GetAllSystemHotkeys)
    };
    NAPI_CALL(env, napi_define_properties(env, exports, sizeof(desc) / sizeof(desc[0]), desc));
    if (CreateShieldMode(env, exports) == nullptr) {
        THROWERR(env, "Failed to create shield mode");
        return nullptr;
    }
    return exports;
}
EXTERN_C_END

static napi_module mmiModule = {
    .nm_version = 1,
    .nm_flags = 0,
    .nm_filename = nullptr,
    .nm_register_func = MmiInit,
    .nm_modname = "multimodalInput.inputConsumer",
    .nm_priv = ((void*)0),
    .reserved = { 0 },
};

extern "C" __attribute__((constructor)) void RegisterModule(void)
{
    napi_module_register(&mmiModule);
}
} // namespace MMI
} // namespace OHOS