/*
 * Copyright (c) 2021-2023 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 <cstdint>

#include "hilog_wrapper.h"
#include "ipc_skeleton.h"
#include "js_plugin_callback.h"
#include "js_plugin_callback_mgr.h"
#include "js_plugin_util.h"
#include "js_plugin_want.h"
#include "napi/native_api.h"
#include "napi/native_node_api.h"

#include "core/components/plugin/plugin_component_manager.h"

namespace OHOS::Ace::Napi {
constexpr int ACE_ARGS_MAX_COUNT = 10;
constexpr int ACE_ARGS_TWO = 2;
constexpr int ACE_ARGS_THREE = 3;
constexpr int ACE_PARAM0 = 0;
constexpr int ACE_PARAM1 = 1;
constexpr int ACE_PARAM2 = 2;
constexpr int NAPI_ACE_ERR_ERROR = 1;

bool UnwrapStageWantFromJS(napi_env env, napi_value param, ACEAsyncJSCallbackInfo* asyncCallbackInfo)
{
    if (!AceUnwrapWant(env, param, asyncCallbackInfo->wantStage)) {
        HILOG_INFO("%{public}s called, Params(want stage) is invalid.", __func__);
        return false;
    }
    return true;
}

bool UnwrapOwnerWantFromJS(napi_env env, napi_value param, ACEAsyncJSCallbackInfo* asyncCallbackInfo)
{
    napi_value jsValue = AceGetPropertyValueByPropertyName(env, param, "owner", napi_object);
    if (jsValue == nullptr) {
        HILOG_INFO("%{public}s called, Params(want) is not object.", __func__);
        return false;
    }

    if (!AceUnwrapWant(env, jsValue, asyncCallbackInfo->wantStage)) {
        HILOG_INFO("%{public}s called, Params(want) is invalid.", __func__);
        return false;
    }
    return true;
}

bool UnwrapWantFromJS(napi_env env, napi_value param, ACEAsyncJSCallbackInfo* asyncCallbackInfo)
{
    napi_value jsValue = AceGetPropertyValueByPropertyName(env, param, "want", napi_object);
    if (jsValue == nullptr) {
        HILOG_INFO("%{public}s called, Params(want) is not object.", __func__);
        return false;
    }

    if (!AceUnwrapWant(env, jsValue, asyncCallbackInfo->jsParamList.want)) {
        HILOG_INFO("%{public}s called, Params(want) is invalid.", __func__);
        return false;
    }
    return true;
}

bool UnwrapTargetFromJS(napi_env env, napi_value param, ACEAsyncJSCallbackInfo* asyncCallbackInfo)
{
    napi_value jsValue = AceGetPropertyValueByPropertyName(env, param, "target", napi_object);
    if (jsValue == nullptr) {
        HILOG_INFO("%{public}s called, Params(Target) is not object.", __func__);
        return false;
    }

    if (!AceUnwrapWant(env, jsValue, asyncCallbackInfo->jsParamList.want)) {
        HILOG_INFO("%{public}s called, Params(Target) is invalid.", __func__);
        return false;
    }
    return true;
}

bool UnwrapNameFromJS(napi_env env, napi_value param, const std::string& key, ACEAsyncJSCallbackInfo* asyncCallbackInfo)
{
    napi_value jsValue = AceGetPropertyValueByPropertyName(env, param, key.c_str(), napi_string);
    if (jsValue == nullptr) {
        HILOG_INFO("%{public}s called, Params(%{public}s) is not string.", __func__, key.c_str());
        return false;
    }

    std::string strValue = AceUnwrapStringFromJS(env, jsValue);
    asyncCallbackInfo->jsParamList.paramList.PutStringValue(key, strValue);
    return true;
}

bool UnwrapKVObjectFromJS(napi_env env, napi_value param, const std::string& key,
    ACEAsyncJSCallbackInfo* asyncCallbackInfo)
{
    napi_value jsValue = AceGetPropertyValueByPropertyName(env, param, key.c_str(), napi_object);
    if (jsValue == nullptr) {
        HILOG_INFO("%{public}s called, Params(%{public}s) is not object.", __func__, key.c_str());
        return false;
    }

    std::string jsonString("{}");
    bool ret = AceKVObjectToString(env, jsValue, jsonString);
    if (ret) {
        asyncCallbackInfo->jsParamList.paramList.PutStringValue(key, jsonString);
    }
    return ret;
}

bool UnwrapPushParameters(napi_env env, napi_value param, ACEAsyncJSCallbackInfo* asyncCallbackInfo)
{
    if (!AceIsTypeForNapiValue(env, param, napi_object)) {
        HILOG_INFO("%{public}s called, Params is invalid.", __func__);
        return false;
    }

    bool isStageModelAPI = (asyncCallbackInfo->ability == nullptr);
    if (isStageModelAPI) {
        if (!UnwrapOwnerWantFromJS(env, param, asyncCallbackInfo)) {
            HILOG_INFO("%{public}s called, Params(ownerWant) is invalid.", __func__);
            return false;
        }
    }

    if (!UnwrapWantFromJS(env, param, asyncCallbackInfo) && !UnwrapTargetFromJS(env, param, asyncCallbackInfo)) {
        HILOG_INFO("%{public}s called, Params(want) is invalid.", __func__);
        return false;
    }
    if (!UnwrapNameFromJS(env, param, "name", asyncCallbackInfo)) {
        HILOG_INFO("%{public}s called, Params(name) is invalid.", __func__);
        return false;
    }
    if (!UnwrapKVObjectFromJS(env, param, "data", asyncCallbackInfo)) {
        HILOG_INFO("%{public}s called, Params(data) is invalid.", __func__);
        return false;
    }
    if (!UnwrapKVObjectFromJS(env, param, "extraData", asyncCallbackInfo)) {
        HILOG_INFO("%{public}s called, Params(data) is invalid.", __func__);
        return false;
    }

    UnwrapNameFromJS(env, param, "jsonPath", asyncCallbackInfo);
    return true;
}

bool UnwrapParamForPush(napi_env env, size_t argc, napi_value* argv, ACEAsyncJSCallbackInfo* asyncCallbackInfo)
{
    HILOG_INFO("%{public}s called, argc=%{public}zu", __func__, argc);
    const size_t argcMax = ACE_ARGS_TWO;
    if (argc <= 0 || argc > argcMax) {
        HILOG_INFO("%{public}s called, Params is invalid.", __func__);
        return false;
    }

    if (!UnwrapPushParameters(env, argv[ACE_PARAM0], asyncCallbackInfo)) {
        HILOG_INFO("%{public}s called, the first parameter is invalid.", __func__);
        return false;
    }

    if (argc == argcMax) {
        if (!AceCreateAsyncCallback(env, argv[ACE_PARAM1], asyncCallbackInfo)) {
            HILOG_INFO("%{public}s called, the last parameter is invalid.", __func__);
            return false;
        }
    }
    return true;
}

void JSPushWork(napi_env env, void* data)
{
    HILOG_INFO("%{public}s called.", __func__);
}

void JSPushCompleteAsyncCallbackWork(napi_env env, napi_status status, void* data)
{
    HILOG_INFO("%{public}s called.", __func__);
    ACEAsyncJSCallbackInfo* asyncCallbackInfo = (ACEAsyncJSCallbackInfo*)data;
    if (asyncCallbackInfo == nullptr) {
        HILOG_INFO("%{public}s called. asyncCallbackInfo is null", __func__);
        return;
    }
    PluginComponentManager::GetInstance()->Push(asyncCallbackInfo->jsParamList.want,
        asyncCallbackInfo->jsParamList.paramList.GetStringValue("name"),
        asyncCallbackInfo->jsParamList.paramList.GetStringValue("jsonPath"),
        asyncCallbackInfo->jsParamList.paramList.GetStringValue("data"),
        asyncCallbackInfo->jsParamList.paramList.GetStringValue("extraData"));

    asyncCallbackInfo->error_code = 0;
    AceCompleteAsyncCallbackWork(env, status, data);
}

void JSPushCompletePromiseCallbackWork(napi_env env, napi_status status, void* data)
{
    HILOG_INFO("%{public}s called.", __func__);

    ACEAsyncJSCallbackInfo* asyncCallbackInfo = (ACEAsyncJSCallbackInfo*)data;
    if (asyncCallbackInfo == nullptr) {
        HILOG_INFO("%{public}s called, asyncCallbackInfo is null", __func__);
        return;
    }

    PluginComponentManager::GetInstance()->Push(asyncCallbackInfo->jsParamList.want,
        asyncCallbackInfo->jsParamList.paramList.GetStringValue("name"),
        asyncCallbackInfo->jsParamList.paramList.GetStringValue("jsonPath"),
        asyncCallbackInfo->jsParamList.paramList.GetStringValue("data"),
        asyncCallbackInfo->jsParamList.paramList.GetStringValue("extraData"));

    asyncCallbackInfo->error_code = 0;
    AceCompletePromiseCallbackWork(env, status, data);
}

napi_value NAPI_JSPushWrap(napi_env env, napi_callback_info info, ACEAsyncJSCallbackInfo* asyncCallbackInfo)
{
    HILOG_INFO("%{public}s called.", __func__);
    size_t argc = ACE_ARGS_MAX_COUNT;
    napi_value args[ACE_ARGS_MAX_COUNT] = {nullptr};
    napi_value jsthis = 0;
    void* data = nullptr;

    NAPI_CALL(env, napi_get_cb_info(env, info, &argc, args, &jsthis, &data));
    if (!UnwrapParamForPush(env, argc, args, asyncCallbackInfo)) {
        HILOG_INFO("%{public}s called. Invoke UnwrapParamForPush fail", __func__);
        return nullptr;
    }
    ACEAsyncParamEx asyncParamEx;
    if (asyncCallbackInfo->cbInfo.callback != nullptr) {
        HILOG_INFO("%{public}s called. asyncCallback.", __func__);
        asyncParamEx.resource = "NAPI_JSPushCallback";
        asyncParamEx.execute = JSPushWork;
        asyncParamEx.complete = JSPushCompleteAsyncCallbackWork;

        return AceExecuteAsyncCallbackWork(env, asyncCallbackInfo, &asyncParamEx);
    } else {
        HILOG_INFO("%{public}s called. promise.", __func__);
        asyncParamEx.resource = "NAPI_JSPushPromise";
        asyncParamEx.execute = JSPushWork;
        asyncParamEx.complete = JSPushCompletePromiseCallbackWork;
        return AceExecutePromiseCallbackWork(env, asyncCallbackInfo, &asyncParamEx);
    }
}

static napi_value JSPush(napi_env env, napi_callback_info info)
{
    HILOG_INFO("%{public}s called.", __func__);

    ACEAsyncJSCallbackInfo* asyncCallbackInfo = AceCreateAsyncJSCallbackInfo(env);
    if (asyncCallbackInfo == nullptr) {
        return AceWrapVoidToJS(env);
    }

    napi_value rev = NAPI_JSPushWrap(env, info, asyncCallbackInfo);
    if (rev == nullptr) {
        AceFreeAsyncJSCallbackInfo(&asyncCallbackInfo);
        rev = AceWrapVoidToJS(env);
    }
    return rev;
}

bool UnwrapRequestParameters(napi_env env, napi_value param, ACEAsyncJSCallbackInfo* asyncCallbackInfo)
{
    if (!AceIsTypeForNapiValue(env, param, napi_object)) {
        HILOG_INFO("%{public}s called, Params is invalid.", __func__);
        return false;
    }

    bool isStageModelAPI = (asyncCallbackInfo->ability == nullptr);
    if (isStageModelAPI) {
        if (!UnwrapOwnerWantFromJS(env, param, asyncCallbackInfo)) {
            HILOG_INFO("%{public}s called, Params(ownerWant) is invalid.", __func__);
            return false;
        }
    }

    if (!UnwrapWantFromJS(env, param, asyncCallbackInfo) && !UnwrapTargetFromJS(env, param, asyncCallbackInfo)) {
        HILOG_INFO("%{public}s called, Params(want) is invalid.", __func__);
        return false;
    }
    if (!UnwrapNameFromJS(env, param, "name", asyncCallbackInfo)) {
        HILOG_INFO("%{public}s called, Params(name) is invalid.", __func__);
        return false;
    }
    if (!UnwrapKVObjectFromJS(env, param, "data", asyncCallbackInfo)) {
        HILOG_INFO("%{public}s called, Params(data) is invalid.", __func__);
        return false;
    }

    UnwrapNameFromJS(env, param, "jsonPath", asyncCallbackInfo);
    return true;
}

bool UnwrapParamForRequest(napi_env env, size_t argc, napi_value* argv,
    ACEAsyncJSCallbackInfo* asyncCallbackInfo)
{
    HILOG_INFO("%{public}s called, argc=%{public}zu", __func__, argc);
    if (argc <= 0 || argc > ACE_ARGS_TWO) {
        HILOG_INFO("%{public}s called, Params is invalid.", __func__);
        return false;
    }

    if (!UnwrapRequestParameters(env, argv[ACE_PARAM0], asyncCallbackInfo)) {
        HILOG_INFO("%{public}s called, the first parameter is invalid.", __func__);
        return false;
    }

    if (argc == ACE_ARGS_TWO) {
        if (!AceCreateAsyncCallback(env, argv[ACE_PARAM1], asyncCallbackInfo)) {
            HILOG_INFO("%{public}s called, the last parameter is invalid.", __func__);
            return false;
        }
    }
    return true;
}

void JSRequestWork(napi_env env, void* data)
{
    HILOG_INFO("%{public}s called.", __func__);
}

void JSRequestPromiseWork(napi_env env, void* data)
{
    HILOG_INFO("%{public}s called.", __func__);
}

void AceRequestCompleteAsyncCallbackWork(napi_env env, napi_status status, void* data)
{
    HILOG_INFO("%{public}s called.", __func__);

    ACEAsyncJSCallbackInfo* asyncCallbackInfo = (ACEAsyncJSCallbackInfo*)data;
    if (asyncCallbackInfo == nullptr) {
        HILOG_INFO("%{public}s called, asyncCallbackInfo is null", __func__);
        return;
    }

    if (asyncCallbackInfo->ability != nullptr) {
        std::shared_ptr<AAFwk::Want> pWant = asyncCallbackInfo->ability->GetWant();
        asyncCallbackInfo->wantStage = *pWant;
    } else {
        int32_t pid = IPCSkeleton::GetCallingPid();
        asyncCallbackInfo->wantStage.SetBundle("plugin" + std::to_string(pid));
    }

    std::shared_ptr<AceJSPluginRequestParam> param = std::make_shared<AceJSPluginRequestParam>(
        asyncCallbackInfo->jsParamList.want,
        asyncCallbackInfo->jsParamList.paramList.GetStringValue("name"),
        asyncCallbackInfo->jsParamList.paramList.GetStringValue("data"),
        asyncCallbackInfo->jsParamList.paramList.GetStringValue("jsonPath")
    );
    if (param != nullptr) {
        HILOG_INFO("%{public}s called, pWant = %{public}s:%{public}s",
            __func__, asyncCallbackInfo->wantStage.GetElement().GetBundleName().c_str(),
            asyncCallbackInfo->wantStage.GetElement().GetAbilityName().c_str());
        bool ret = JSPluginCallbackMgr::Instance().RegisterRequestEvent(env, asyncCallbackInfo->wantStage,
            asyncCallbackInfo->cbInfo, param);
        if (ret) {
            asyncCallbackInfo->cbInfo.callback = nullptr;
        }
    }

    PluginComponentManager::GetInstance()->Request(asyncCallbackInfo->jsParamList.want,
        asyncCallbackInfo->jsParamList.paramList.GetStringValue("name"),
        asyncCallbackInfo->jsParamList.paramList.GetStringValue("jsonPath"),
        asyncCallbackInfo->jsParamList.paramList.GetStringValue("data"));

    napi_delete_async_work(env, asyncCallbackInfo->asyncWork);
    AceFreeAsyncJSCallbackInfo(&asyncCallbackInfo);
}

napi_value MakePluginTemplateObject(napi_env env, const PluginComponentTemplate& pluginTemplate)
{
    HILOG_INFO("%{public}s called.", __func__);
    napi_value jsPluginTemplate = AceCreateJSObject(env);
    if (jsPluginTemplate != nullptr) {
        napi_value jsSource = AceWrapStringToJS(env, pluginTemplate.GetSource());
        napi_value jsAbility = AceWrapStringToJS(env, pluginTemplate.GetAbility());

        AceSetPropertyValueByPropertyName(env, jsPluginTemplate, "source", jsSource);
        AceSetPropertyValueByPropertyName(env, jsPluginTemplate, "ability", jsAbility);
    }
    return jsPluginTemplate;
}

napi_value MakeCallbackParamForRequest(napi_env env, const PluginComponentTemplate& pluginTemplate,
    const ACEAsyncJSCallbackInfo* asyncCallbackInfo)
{
    HILOG_INFO("%{public}s called.", __func__);
    napi_value jsObject = AceCreateJSObject(env);
    if (jsObject == nullptr) {
        return nullptr;
    }
    HILOG_INFO("%{public}s called.   1111", __func__);
    std::string dataTmp("{}");
    std::string extraDataTmp("{}");
    if (!asyncCallbackInfo->requestCallbackData.data.empty()) {
        dataTmp = asyncCallbackInfo->requestCallbackData.data;
    }
    if (!asyncCallbackInfo->requestCallbackData.extraData.empty()) {
        extraDataTmp = asyncCallbackInfo->requestCallbackData.extraData;
    }

    napi_value jsPluginTemplate = MakePluginTemplateObject(env, pluginTemplate);
    napi_value jsData = AceStringToKVObject(env, dataTmp);
    napi_value jsExtraData = AceStringToKVObject(env, extraDataTmp);

    if (jsData != nullptr) {
        HILOG_INFO("%{public}s called.   componentTemplate", __func__);
        AceSetPropertyValueByPropertyName(env, jsObject, "componentTemplate", jsPluginTemplate);
    }
    if (jsData != nullptr) {
        HILOG_INFO("%{public}s called.   data", __func__);
        AceSetPropertyValueByPropertyName(env, jsObject, "data", jsData);
    }
    if (jsExtraData != nullptr) {
        HILOG_INFO("%{public}s called.   extraData", __func__);
        AceSetPropertyValueByPropertyName(env, jsObject, "extraData", jsExtraData);
    }
    return jsObject;
}

napi_value TransferRequestCallBackData(napi_env env, ACEAsyncJSCallbackInfo* asyncCallbackInfo)
{
    HILOG_INFO("%{public}s called.", __func__);
    PluginComponentTemplate componentTemplate;
    componentTemplate.SetSource(asyncCallbackInfo->requestCallbackData.sourceName);
    componentTemplate.SetAbility(asyncCallbackInfo->requestCallbackData.abilityName);
    napi_value jsResult = MakeCallbackParamForRequest(env, componentTemplate, asyncCallbackInfo);
    return jsResult;
}

void AceRequestPromiseAsyncCallbackWork(napi_env env, napi_status status, void* data)
{
    HILOG_INFO("%{public}s called.", __func__);
    ACEAsyncJSCallbackInfo* asyncCallbackInfo = (ACEAsyncJSCallbackInfo*)data;
    if (asyncCallbackInfo == nullptr) {
        HILOG_INFO("%{public}s called, asyncCallbackInfo is null", __func__);
        return;
    }

    if (asyncCallbackInfo->ability != nullptr) {
        std::shared_ptr<AAFwk::Want> pWant = asyncCallbackInfo->ability->GetWant();
        asyncCallbackInfo->wantStage = *pWant;
    } else {
        int32_t pid = IPCSkeleton::GetCallingPid();
        asyncCallbackInfo->wantStage.SetBundle("plugin" + std::to_string(pid));
    }

    std::shared_ptr<AceJSPluginRequestParam> param = std::make_shared<AceJSPluginRequestParam>(
        asyncCallbackInfo->jsParamList.want,
        asyncCallbackInfo->jsParamList.paramList.GetStringValue("name"),
        asyncCallbackInfo->jsParamList.paramList.GetStringValue("data"),
        asyncCallbackInfo->jsParamList.paramList.GetStringValue("jsonPath")
    );
    asyncCallbackInfo->onRequestCallbackOK = false;
    
    if (param != nullptr) {
        HILOG_INFO("%{public}s called, pWant = %{public}s:%{public}s",
            __func__, asyncCallbackInfo->wantStage.GetElement().GetBundleName().c_str(),
            asyncCallbackInfo->wantStage.GetElement().GetAbilityName().c_str());
        JSPluginCallbackMgr::Instance().RegisterRequestEvent(env, asyncCallbackInfo->wantStage,
            asyncCallbackInfo, param);
    }

    PluginComponentManager::GetInstance()->Request(asyncCallbackInfo->jsParamList.want,
        asyncCallbackInfo->jsParamList.paramList.GetStringValue("name"),
        asyncCallbackInfo->jsParamList.paramList.GetStringValue("jsonPath"),
        asyncCallbackInfo->jsParamList.paramList.GetStringValue("data"));

    if (asyncCallbackInfo->onRequestCallbackOK) {
        asyncCallbackInfo->error_code = 0;
        napi_resolve_deferred(env, asyncCallbackInfo->deferred, TransferRequestCallBackData(env, asyncCallbackInfo));
        AceFreeAsyncJSCallbackInfo(&asyncCallbackInfo);
    } else {
        asyncCallbackInfo->error_code = NAPI_ACE_ERR_ERROR;
        AceCompletePromiseCallbackWork(env, status, data);
    }
}

napi_value NAPI_JSRequestWrap(napi_env env, napi_callback_info info, ACEAsyncJSCallbackInfo* asyncCallbackInfo)
{
    HILOG_INFO("%{public}s called.", __func__);
    size_t argc = ACE_ARGS_MAX_COUNT;
    napi_value args[ACE_ARGS_MAX_COUNT] = {nullptr};
    napi_value jsthis = 0;
    void* data = nullptr;

    NAPI_CALL(env, napi_get_cb_info(env, info, &argc, args, &jsthis, &data));

    if (!UnwrapParamForRequest(env, argc, args, asyncCallbackInfo)) {
        HILOG_INFO("%{public}s called. Invoke UnwrapParamForRequest fail", __func__);
        return nullptr;
    }

    ACEAsyncParamEx asyncParamEx;
    if (asyncCallbackInfo->cbInfo.callback != nullptr) {
        HILOG_INFO("%{public}s called. asyncCallback.", __func__);
        asyncParamEx.resource = "NAPI_JSRequestCallback";
        asyncParamEx.execute = JSRequestWork;
        asyncParamEx.complete = AceRequestCompleteAsyncCallbackWork;
        return AceExecuteAsyncCallbackWork(env, asyncCallbackInfo, &asyncParamEx);
    } else {
        HILOG_INFO("%{public}s called. promise.", __func__);
        asyncParamEx.resource = "NAPI_JSRequestPromise";
        asyncParamEx.execute = JSRequestPromiseWork;
        asyncParamEx.complete = AceRequestPromiseAsyncCallbackWork;
        return AceExecutePromiseCallbackWork(env, asyncCallbackInfo, &asyncParamEx);
    }
}

static napi_value JSRequest(napi_env env, napi_callback_info info)
{
    HILOG_INFO("%{public}s called.", __func__);

    ACEAsyncJSCallbackInfo* asyncCallbackInfo = AceCreateAsyncJSCallbackInfo(env);
    if (asyncCallbackInfo == nullptr) {
        return AceWrapVoidToJS(env);
    }

    napi_value rev = NAPI_JSRequestWrap(env, info, asyncCallbackInfo);
    if (rev == nullptr) {
        AceFreeAsyncJSCallbackInfo(&asyncCallbackInfo);
        rev = AceWrapVoidToJS(env);
    }
    return rev;
}

bool UnwrapParamForOn(napi_env env, size_t argc, napi_value* argv,
    ACEAsyncJSCallbackInfo* asyncCallbackInfo)
{
    HILOG_INFO("%{public}s called, argc=%{public}zu", __func__, argc);

    const size_t argcMax = ACE_ARGS_THREE;
    if (argc > argcMax || argc < ACE_ARGS_TWO) {
        HILOG_INFO("%{public}s called, Params is invalid.", __func__);
        return false;
    }

    if (argc == ACE_ARGS_THREE) {
        if (!UnwrapStageWantFromJS(env, argv[ACE_PARAM0], asyncCallbackInfo)) {
            HILOG_INFO("%{public}s called, the owner want parameter is invalid.", __func__);
            return false;
        }

        std::string eventName = AceUnwrapStringFromJS(env, argv[ACE_PARAM1]);
        if (eventName == "push" || eventName == "request") {
            asyncCallbackInfo->jsParamList.paramList.PutStringValue("eventName", eventName);
        } else {
            HILOG_INFO("%{public}s called, the first parameter is invalid.", __func__);
            return false;
        }

        if (!AceCreateAsyncCallback(env, argv[ACE_PARAM2], asyncCallbackInfo)) {
            HILOG_INFO("%{public}s called, the second parameter is invalid.", __func__);
            return false;
        }
    } else {
        std::string eventName = AceUnwrapStringFromJS(env, argv[ACE_PARAM0]);
        if (eventName == "push" || eventName == "request") {
            asyncCallbackInfo->jsParamList.paramList.PutStringValue("eventName", eventName);
        } else {
            HILOG_INFO("%{public}s called, the first parameter is invalid.", __func__);
            return false;
        }

        if (!AceCreateAsyncCallback(env, argv[ACE_PARAM1], asyncCallbackInfo)) {
            HILOG_INFO("%{public}s called, the second parameter is invalid.", __func__);
            return false;
        }
    }
    return true;
}

void JSOnWork(napi_env env, void* data)
{
    HILOG_INFO("%{public}s called.", __func__);
}

void AceOnCompleteAsyncCallbackWork(napi_env env, napi_status status, void* data)
{
    HILOG_INFO("%{public}s called.", __func__);

    ACEAsyncJSCallbackInfo* asyncCallbackInfo = (ACEAsyncJSCallbackInfo*)data;
    if (asyncCallbackInfo == nullptr) {
        HILOG_INFO("%{public}s called, asyncCallbackInfo is null", __func__);
        return;
    }

    std::string eventName = asyncCallbackInfo->jsParamList.paramList.GetStringValue("eventName");
    CallBackType eventCallbackType = CallBackType::PushEvent;
    if (eventName == "request") {
        eventCallbackType = CallBackType::RequestEvent;
    }

    if (asyncCallbackInfo->ability != nullptr) {
        std::shared_ptr<AAFwk::Want> pWant = asyncCallbackInfo->ability->GetWant();
        asyncCallbackInfo->wantStage = *pWant;
    } else {
        int32_t pid = IPCSkeleton::GetCallingPid();
        asyncCallbackInfo->wantStage.SetBundle("plugin" + std::to_string(pid));
    }

    bool ret = JSPluginCallbackMgr::Instance().RegisterOnEvent(env, eventCallbackType,
        asyncCallbackInfo->wantStage, asyncCallbackInfo->cbInfo);
    if (ret) {
        asyncCallbackInfo->cbInfo.callback = nullptr;
    }
    napi_delete_async_work(env, asyncCallbackInfo->asyncWork);
    AceFreeAsyncJSCallbackInfo(&asyncCallbackInfo);
}

napi_value NAPI_JSOnWrap(napi_env env, napi_callback_info info, ACEAsyncJSCallbackInfo* asyncCallbackInfo)
{
    HILOG_INFO("%{public}s called.", __func__);
    size_t argc = ACE_ARGS_MAX_COUNT;
    napi_value args[ACE_ARGS_MAX_COUNT] = {nullptr};
    napi_value jsthis = 0;
    void* data = nullptr;

    NAPI_CALL(env, napi_get_cb_info(env, info, &argc, args, &jsthis, &data));

    if (!UnwrapParamForOn(env, argc, args, asyncCallbackInfo)) {
        HILOG_INFO("%{public}s called. Invoke UnwrapParamForOn fail", __func__);
        return nullptr;
    }

    ACEAsyncParamEx asyncParamEx;
    if (asyncCallbackInfo->cbInfo.callback != nullptr) {
        HILOG_INFO("%{public}s called. asyncCallback.", __func__);
        asyncParamEx.resource = "NAPI_JSOCallback";
        asyncParamEx.execute = JSOnWork;
        asyncParamEx.complete = AceOnCompleteAsyncCallbackWork;

        return AceExecuteAsyncCallbackWork(env, asyncCallbackInfo, &asyncParamEx);
    } else {
        HILOG_INFO("%{public}s called. promise.", __func__);
        asyncParamEx.resource = "NAPI_JSOnPromise";
        return nullptr;
    }
}

static napi_value JSOn(napi_env env, napi_callback_info info)
{
    HILOG_INFO("%{public}s called.", __func__);

    ACEAsyncJSCallbackInfo* asyncCallbackInfo = AceCreateAsyncJSCallbackInfo(env);
    if (asyncCallbackInfo == nullptr) {
        return AceWrapVoidToJS(env);
    }

    napi_value rev = NAPI_JSOnWrap(env, info, asyncCallbackInfo);
    if (rev == nullptr) {
        AceFreeAsyncJSCallbackInfo(&asyncCallbackInfo);
        rev = AceWrapVoidToJS(env);
    }
    return rev;
}


bool UnwrapParamForOff(napi_env env, size_t argc, napi_value* argv,
    ACEAsyncJSCallbackInfo* asyncCallbackInfo)
{
    HILOG_INFO("%{public}s called, argc=%{public}zu", __func__, argc);

    if (argc != ACE_ARGS_TWO) {
        HILOG_INFO("%{public}s called, Params is invalid.", __func__);
        return false;
    }

    if (!UnwrapStageWantFromJS(env, argv[ACE_PARAM0], asyncCallbackInfo)) {
        HILOG_INFO("%{public}s called, the owner want parameter is invalid.", __func__);
        return false;
    }

    if (!AceCreateAsyncCallback(env, argv[ACE_PARAM1], asyncCallbackInfo)) {
        HILOG_INFO("%{public}s called, the second parameter is invalid.", __func__);
        return false;
    }

    return true;
}

void JSOffWork(napi_env env, void* data)
{
    HILOG_INFO("%{public}s called.", __func__);
}

void AceOffCompleteAsyncCallbackWork(napi_env env, napi_status status, void* data)
{
    HILOG_INFO("%{public}s called.", __func__);

    ACEAsyncJSCallbackInfo* asyncCallbackInfo = (ACEAsyncJSCallbackInfo*)data;
    if (asyncCallbackInfo == nullptr) {
        HILOG_INFO("%{public}s called, asyncCallbackInfo is null", __func__);
        return;
    }

    JSPluginCallbackMgr::Instance().UnregisterCallBack(env, asyncCallbackInfo->wantStage);
    napi_delete_async_work(env, asyncCallbackInfo->asyncWork);
    AceFreeAsyncJSCallbackInfo(&asyncCallbackInfo);
}

napi_value NAPI_JSOffWrap(napi_env env, napi_callback_info info, ACEAsyncJSCallbackInfo* asyncCallbackInfo)
{
    HILOG_INFO("%{public}s called.", __func__);
    size_t argc = ACE_ARGS_MAX_COUNT;
    napi_value args[ACE_ARGS_MAX_COUNT] = {nullptr};
    napi_value jsthis = 0;
    void* data = nullptr;

    NAPI_CALL(env, napi_get_cb_info(env, info, &argc, args, &jsthis, &data));

    if (!UnwrapParamForOff(env, argc, args, asyncCallbackInfo)) {
        HILOG_INFO("%{public}s called. Invoke UnwrapParamForOff fail", __func__);
        return nullptr;
    }

    ACEAsyncParamEx asyncParamEx;
    if (asyncCallbackInfo->cbInfo.callback != nullptr) {
        HILOG_INFO("%{public}s called. asyncCallback.", __func__);
        asyncParamEx.resource = "NAPI_JSOffCallback";
        asyncParamEx.execute = JSOffWork;
        asyncParamEx.complete = AceOffCompleteAsyncCallbackWork;

        return AceExecuteAsyncCallbackWork(env, asyncCallbackInfo, &asyncParamEx);
    } else {
        HILOG_INFO("%{public}s called. promise.", __func__);
        asyncParamEx.resource = "NAPI_JSOffPromise";
        return nullptr;
    }
}

static napi_value JSOff(napi_env env, napi_callback_info info)
{
    HILOG_INFO("%{public}s called.", __func__);

    ACEAsyncJSCallbackInfo* asyncCallbackInfo = AceCreateAsyncJSCallbackInfo(env);
    if (asyncCallbackInfo == nullptr) {
        return AceWrapVoidToJS(env);
    }

    napi_value rev = NAPI_JSOffWrap(env, info, asyncCallbackInfo);
    if (rev == nullptr) {
        AceFreeAsyncJSCallbackInfo(&asyncCallbackInfo);
        rev = AceWrapVoidToJS(env);
    }
    return rev;
}

napi_value PluginComponentEventTypeInit(napi_env env, napi_value exports)
{
    HILOG_INFO("%{public}s, called", __func__);

    napi_value obj = nullptr;
    napi_create_object(env, &obj);

    AceSetNamedPropertyByString(env, obj, "push", "EVENT_TYPE_PUSH");
    AceSetNamedPropertyByString(env, obj, "request", "EVENT_TYPE_REQUEST");

    napi_property_descriptor properties[] = {
        DECLARE_NAPI_PROPERTY("EventType", obj),
    };

    NAPI_CALL(env, napi_define_properties(env, exports, sizeof(properties) / sizeof(properties[0]), properties));
    return exports;
}

napi_value PluginComponentInit(napi_env env, napi_value exports)
{
    HILOG_INFO("%{public}s, called", __func__);

    napi_property_descriptor properties[] = {
        DECLARE_NAPI_FUNCTION("push", JSPush),
        DECLARE_NAPI_FUNCTION("request", JSRequest),
        DECLARE_NAPI_FUNCTION("on", JSOn),
        DECLARE_NAPI_FUNCTION("off", JSOff),
    };

    NAPI_CALL(env, napi_define_properties(env, exports, sizeof(properties) / sizeof(properties[0]), properties));
    return exports;
}

static napi_value PluginComponentExport(napi_env env, napi_value exports)
{
    HILOG_INFO("%{public}s, called", __func__);

    PluginComponentEventTypeInit(env, exports);
    PluginComponentInit(env, exports);
    return exports;
}

static napi_module PlugInComonentModule = {
    .nm_version = 1,
    .nm_flags = 0,
    .nm_filename = nullptr,
    .nm_register_func = PluginComponentExport,
    .nm_modname = "pluginComponent",
    .nm_priv = ((void*)0),
    .reserved = { 0 },
};

extern "C" __attribute__((constructor)) void RegisterPluginComponent()
{
    napi_module_register(&PlugInComonentModule);
}
}  // namespace OHOS::Ace::Napi