OpenHarmony-v3.2.1-Release/s

/*
 * Copyright (c) 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 <string>

#include "distributed_mission_manager.h"

#include "ability_manager_client.h"
#include "hilog_wrapper.h"
#include "ipc_skeleton.h"
#include "napi_common_data.h"
#include "napi_common_util.h"
#include "napi_common_want.h"
#include "napi_remote_object.h"

using namespace OHOS::AppExecFwk;

namespace OHOS {
namespace AAFwk {
using AbilityManagerClient = AAFwk::AbilityManagerClient;
const std::string TAG = "NAPIMissionRegistration";
constexpr size_t VALUE_BUFFER_SIZE = 128;
const std::string CODE_KEY_NAME = "code";
static const std::map<int32_t, int32_t> DMS_MISSION_MANAGER_ERROR_CODE_MAP = {
    { NO_ERROR, NO_ERROR },
    { DMS_PERMISSION_DENIED, PERMISSION_DENIED },
    { CHECK_PERMISSION_FAILED, PERMISSION_DENIED },
    { ERR_NULL_OBJECT, PARAMETER_CHECK_FAILED },
    { INVALID_PARAMETERS_ERR, PARAMETER_CHECK_FAILED },
    { ERR_INVALID_VALUE, PARAMETER_CHECK_FAILED },
    { INNER_ERR, SYSTEM_WORK_ABNORMALLY },
    { ABILITY_SERVICE_NOT_CONNECTED, SYSTEM_WORK_ABNORMALLY },
    { INVALID_REMOTE_PARAMETERS_ERR, SYSTEM_WORK_ABNORMALLY },
    { NO_MISSION_INFO_FOR_MISSION_ID, NO_MISSION_INFO_FOR_MISSION_ID },
    { CONTINUE_REMOTE_UNINSTALLED_UNSUPPORT_FREEINSTALL, REMOTE_UNINSTALLED_AND_UNSUPPORT_FREEINSTALL_FOR_CONTINUE },
    { CONTINUE_REMOTE_UNINSTALLED_SUPPORT_FREEINSTALL, CONTINUE_WITHOUT_FREEINSTALL_FLAG },
    { OPERATION_DEVICE_NOT_INITIATOR_OR_TARGET, OPERATION_DEVICE_NOT_INITIATOR_OR_TARGET },
    { CONTINUE_ALREADY_IN_PROGRESS, CONTINUE_ALREADY_IN_PROGRESS },
    { MISSION_FOR_CONTINUING_IS_NOT_ALIVE, MISSION_FOR_CONTINUING_IS_NOT_ALIVE },
};

static const std::map<int32_t, std::string> DMS_MISSION_MANAGER_ERROR_INFO_MAP = {
    { NO_ERROR, std::string() },
    { PERMISSION_DENIED, std::string("permission denied") },
    { PARAMETER_CHECK_FAILED, std::string("parameter check failed.") },
    { SYSTEM_WORK_ABNORMALLY, std::string("the system ability work abnormally.") },
    { NO_MISSION_INFO_FOR_MISSION_ID, std::string("failed to get the missionInfo of the specified missionId.") },
    { REMOTE_UNINSTALLED_AND_UNSUPPORT_FREEINSTALL_FOR_CONTINUE, std::string("the application is not installed on the \
remote end and installation-free is not supported.") },
    { CONTINUE_WITHOUT_FREEINSTALL_FLAG, std::string("the application is not installed on the remote end but \
installation-free is supported, try again with freeInstall flag.") },
    { OPERATION_DEVICE_NOT_INITIATOR_OR_TARGET, std::string("the operation device must be the device where the \
application to be continued is located or the target device to be continued.") },
    { CONTINUE_ALREADY_IN_PROGRESS, std::string("the local continuation task is already in progress.") },
    { MISSION_FOR_CONTINUING_IS_NOT_ALIVE, std::string("the mission for continuing is not alive, \
try again after restart this mission.") },
};

napi_value GenerateBusinessError(const napi_env &env, int32_t errCode, const std::string &errMsg)
{
    HILOG_ERROR("%{public}s", errMsg.c_str());
    napi_value code = nullptr;
    napi_create_int32(env, errCode, &code);
    napi_value msg = nullptr;
    napi_create_string_utf8(env, errMsg.c_str(), NAPI_AUTO_LENGTH, &msg);
    napi_value businessError = nullptr;
    napi_create_error(env, nullptr, msg, &businessError);
    napi_set_named_property(env, businessError, CODE_KEY_NAME.c_str(), code);
    return businessError;
}

int32_t ErrorCodeReturn(int32_t code)
{
    return DMS_MISSION_MANAGER_ERROR_CODE_MAP.find(code) != DMS_MISSION_MANAGER_ERROR_CODE_MAP.end() ?
        DMS_MISSION_MANAGER_ERROR_CODE_MAP.at(code) : SYSTEM_WORK_ABNORMALLY;
}

napi_value GetUndefined(const napi_env &env)
{
    napi_value nullResult = nullptr;
    napi_get_undefined(env, &nullResult);
    return nullResult;
}

std::string ErrorInfoReturn(int32_t code)
{
    return DMS_MISSION_MANAGER_ERROR_INFO_MAP.find(code) != DMS_MISSION_MANAGER_ERROR_INFO_MAP.end() ?
        DMS_MISSION_MANAGER_ERROR_INFO_MAP.at(code) : DMS_MISSION_MANAGER_ERROR_INFO_MAP.at(SYSTEM_WORK_ABNORMALLY);
}

bool SetStartSyncMissionsContext(const napi_env &env, const napi_value &value,
    SyncRemoteMissionsContext* context, std::string &errInfo)
{
    HILOG_INFO("%{public}s call.", __func__);
    bool isFixConflict = false;
    napi_has_named_property(env, value, "fixConflict", &isFixConflict);
    if (!isFixConflict) {
        errInfo = "Parameter error. The key of \"MissionParameter\" must be fixConflict";
        return false;
    }
    napi_value fixConflictValue = nullptr;
    napi_get_named_property(env, value, "fixConflict", &fixConflictValue);
    if (fixConflictValue == nullptr) {
        errInfo = "Parameter error. The value of \"fixConflict\" must not be undefined";
        return false;
    }
    napi_valuetype valueType = napi_undefined;
    napi_typeof(env, fixConflictValue, &valueType);
    if (valueType != napi_boolean) {
        errInfo = "Parameter error. The type of \"fixConflict\" must be boolean";
        return false;
    }
    napi_get_value_bool(env, fixConflictValue, &context->fixConflict);
    bool isTag = false;
    napi_has_named_property(env, value, "tag", &isTag);
    if (!isTag) {
        errInfo = "Parameter error. The key of \"MissionParameter\" must be tag";
        return false;
    }
    napi_value tagValue = nullptr;
    napi_get_named_property(env, value, "tag", &tagValue);
    if (tagValue == nullptr) {
        errInfo = "Parameter error. The value of \"tag\" must not be undefined";
        return false;
    }
    napi_typeof(env, tagValue, &valueType);
    if (valueType != napi_number) {
        errInfo = "Parameter error. The type of \"tag\" must be number";
        return false;
    }
    napi_get_value_int64(env, tagValue, &context->tag);
    HILOG_INFO("%{public}s end.", __func__);
    return true;
}

bool SetSyncRemoteMissionsContext(const napi_env &env, const napi_value &value,
    bool isStart, SyncRemoteMissionsContext* context, std::string &errInfo)
{
    HILOG_INFO("%{public}s call.", __func__);
    napi_valuetype valueType = napi_undefined;
    napi_typeof(env, value, &valueType);
    if (valueType != napi_object) {
        errInfo = "Parameter error. The type of \"parameter\" must be MissionParameter";
        return false;
    }
    napi_value deviceIdValue = nullptr;
    bool isDeviceId = false;
    napi_has_named_property(env, value, "deviceId", &isDeviceId);
    if (!isDeviceId) {
        errInfo = "Parameter error. The key of \"parameter\" must be deviceId";
        return false;
    }
    napi_get_named_property(env, value, "deviceId", &deviceIdValue);
    if (deviceIdValue == nullptr) {
        errInfo = "Parameter error. The value of \"deviceId\" must not be undefined";
        return false;
    }
    napi_typeof(env, deviceIdValue, &valueType);
    if (valueType != napi_string) {
        errInfo = "Parameter error. The type of \"deviceId\" must be string";
        return false;
    }

    char deviceId[VALUE_BUFFER_SIZE + 1] = {0};
    napi_get_value_string_utf8(env, deviceIdValue, deviceId, VALUE_BUFFER_SIZE + 1, &context->valueLen);
    if (context->valueLen > VALUE_BUFFER_SIZE) {
        errInfo = "Parameter error. The length of \"deviceId\" must be less than " +
            std::to_string(VALUE_BUFFER_SIZE);
        return false;
    }
    context->deviceId = deviceId;

    if (isStart) {
        if (!SetStartSyncMissionsContext (env, value, context, errInfo)) {
            HILOG_ERROR("%{public}s, Wrong argument for start sync.", __func__);
            return false;
        }
    }
    HILOG_INFO("%{public}s end.", __func__);
    return true;
}

bool ProcessSyncInput(napi_env env, napi_callback_info info, bool isStart,
    SyncRemoteMissionsContext* syncContext, std::string &errInfo)
{
    HILOG_INFO("%{public}s,called.", __func__);
    size_t argc = 2;
    napi_value argv[2] = { 0 };
    napi_get_cb_info(env, info, &argc, argv, nullptr, nullptr);
    if (argc != ARGS_ONE && argc != ARGS_TWO) {
        errInfo = "Parameter error. The type of \"number of parameters\" must be 1 or 2";
        return false;
    }
    syncContext->env = env;
    if (!SetSyncRemoteMissionsContext(env, argv[0], isStart, syncContext, errInfo)) {
        HILOG_ERROR("%{public}s, Wrong argument.", __func__);
        return false;
    }
    if (argc == ARGS_TWO) {
        napi_valuetype valueType = napi_undefined;
        napi_typeof(env, argv[1], &valueType);
        if (valueType != napi_function) {
            errInfo = "Parameter error. The type of \"callback\" must be AsynCallback<void>: void";
            return false;
        }
        napi_create_reference(env, argv[1], 1, &syncContext->callbackRef);
    }
    HILOG_INFO("%{public}s, end.", __func__);
    return true;
}

void StartSyncRemoteMissionsAsyncWork(napi_env env, const napi_value resourceName,
    SyncRemoteMissionsContext* syncContext)
{
    HILOG_INFO("%{public}s, called.", __func__);
    napi_create_async_work(env, nullptr, resourceName,
        [](napi_env env, void* data) {
            SyncRemoteMissionsContext* syncContext = (SyncRemoteMissionsContext*)data;
            syncContext->result = AbilityManagerClient::GetInstance()->
                StartSyncRemoteMissions(syncContext->deviceId,
                syncContext->fixConflict, syncContext->tag);
        },
        [](napi_env env, napi_status status, void* data) {
            SyncRemoteMissionsContext* syncContext = (SyncRemoteMissionsContext*)data;
            // set result
            napi_value result[2] = { nullptr };
            napi_get_undefined(env, &result[1]);
            if (syncContext->result == 0) {
                napi_get_undefined(env, &result[0]);
            } else {
                int32_t errCode = ErrorCodeReturn(syncContext->result);
                result[0] = GenerateBusinessError(env, errCode, ErrorInfoReturn(errCode));
            }

            if (syncContext->callbackRef == nullptr) { // promise
                if (syncContext->result == 0) {
                    napi_resolve_deferred(env, syncContext->deferred, result[1]);
                } else {
                    napi_reject_deferred(env, syncContext->deferred, result[0]);
                }
            } else { // AsyncCallback
                napi_value callback = nullptr;
                napi_get_reference_value(env, syncContext->callbackRef, &callback);
                napi_value callResult;
                napi_call_function(env, nullptr, callback, ARGS_TWO, &result[0], &callResult);
                napi_delete_reference(env, syncContext->callbackRef);
            }
            napi_delete_async_work(env, syncContext->work);
            delete syncContext;
            syncContext = nullptr;
        },
        static_cast<void *>(syncContext),
        &syncContext->work);
        napi_queue_async_work(env, syncContext->work);
    HILOG_INFO("%{public}s, end.", __func__);
}

napi_value NAPI_StartSyncRemoteMissions(napi_env env, napi_callback_info info)
{
    HILOG_INFO("%{public}s, called.", __func__);
    std::string errInfo = "Parameter error";
    auto syncContext = new SyncRemoteMissionsContext();
    if (!ProcessSyncInput(env, info, true, syncContext, errInfo)) {
        delete syncContext;
        syncContext = nullptr;
        napi_throw(env, GenerateBusinessError(env, PARAMETER_CHECK_FAILED, errInfo));
        return GetUndefined(env);
    }
    napi_value result = nullptr;
    if (syncContext->callbackRef == nullptr) {
        napi_create_promise(env, &syncContext->deferred, &result);
    } else {
        napi_get_undefined(env, &result);
    }

    napi_value resourceName = nullptr;
    napi_create_string_latin1(env, __func__, NAPI_AUTO_LENGTH, &resourceName);

    StartSyncRemoteMissionsAsyncWork(env, resourceName, syncContext);
    HILOG_INFO("%{public}s, end.", __func__);
    return result;
}

void StopSyncRemoteMissionsAsyncWork(napi_env env, napi_value resourceName,
    SyncRemoteMissionsContext* syncContext)
{
    HILOG_INFO("%{public}s, called.", __func__);
    napi_create_async_work(env, nullptr, resourceName,
        [](napi_env env, void* data) {
            SyncRemoteMissionsContext* syncContext = (SyncRemoteMissionsContext*)data;
            syncContext->result = AbilityManagerClient::GetInstance()->
                StopSyncRemoteMissions(syncContext->deviceId);
        },
        [](napi_env env, napi_status status, void* data) {
            SyncRemoteMissionsContext* syncContext = (SyncRemoteMissionsContext*)data;
            // set result
            napi_value result[2] = { nullptr };
            napi_get_undefined(env, &result[1]);
            if (syncContext->result == 0) {
                napi_get_undefined(env, &result[0]);
            } else {
                int32_t errCode = ErrorCodeReturn(syncContext->result);
                result[0] = GenerateBusinessError(env, errCode, ErrorInfoReturn(errCode));
            }

            if (syncContext->callbackRef == nullptr) { // promise
                if (syncContext->result == 0) {
                    napi_resolve_deferred(env, syncContext->deferred, result[1]);
                } else {
                    napi_reject_deferred(env, syncContext->deferred, result[0]);
                }
            } else { // AsyncCallback
                napi_value callback = nullptr;
                napi_get_reference_value(env, syncContext->callbackRef, &callback);
                napi_value callResult;
                napi_call_function(env, nullptr, callback, ARGS_TWO, &result[0], &callResult);
                napi_delete_reference(env, syncContext->callbackRef);
            }
            napi_delete_async_work(env, syncContext->work);
            delete syncContext;
            syncContext = nullptr;
        },
        static_cast<void *>(syncContext),
        &syncContext->work);
        napi_queue_async_work(env, syncContext->work);
    HILOG_INFO("%{public}s, end.", __func__);
}

napi_value NAPI_StopSyncRemoteMissions(napi_env env, napi_callback_info info)
{
    HILOG_INFO("%{public}s, called.", __func__);
    std::string errInfo = "Parameter error";
    auto syncContext = new SyncRemoteMissionsContext();
    if (!ProcessSyncInput(env, info, false, syncContext, errInfo)) {
        delete syncContext;
        syncContext = nullptr;
        napi_throw(env, GenerateBusinessError(env, PARAMETER_CHECK_FAILED, errInfo));
        return GetUndefined(env);
    }
    napi_value result = nullptr;
    if (syncContext->callbackRef == nullptr) {
        napi_create_promise(env, &syncContext->deferred, &result);
    } else {
        napi_get_undefined(env, &result);
    }

    napi_value resourceName = nullptr;
    napi_create_string_latin1(env, __func__, NAPI_AUTO_LENGTH, &resourceName);

    StopSyncRemoteMissionsAsyncWork(env, resourceName, syncContext);
    HILOG_INFO("%{public}s, end.", __func__);
    return result;
}

RegisterMissionCB *CreateRegisterMissionCBCBInfo(napi_env env)
{
    HILOG_INFO("%{public}s called.", __func__);
    auto registerMissionCB = new (std::nothrow) RegisterMissionCB;
    if (registerMissionCB == nullptr) {
        HILOG_ERROR("%{public}s registerMissionCB == nullptr", __func__);
        return nullptr;
    }
    registerMissionCB->cbBase.cbInfo.env = env;
    registerMissionCB->cbBase.asyncWork = nullptr;
    registerMissionCB->cbBase.deferred = nullptr;
    registerMissionCB->callbackRef = nullptr;
    HILOG_INFO("%{public}s end.", __func__);
    return registerMissionCB;
}

void RegisterMissionExecuteCB(napi_env env, void *data)
{
    HILOG_INFO("%{public}s called.", __func__);
    auto registerMissionCB = (RegisterMissionCB*)data;

    std::lock_guard<std::mutex> autoLock(registrationLock_);
    sptr<NAPIRemoteMissionListener> registration;
    auto item = registration_.find(registerMissionCB->deviceId);
    if (item != registration_.end()) {
        HILOG_INFO("registration exits.");
        registration = registration_[registerMissionCB->deviceId];
    } else {
        HILOG_INFO("registration not exits.");
        registration = new (std::nothrow) NAPIRemoteMissionListener();
    }
    registerMissionCB->missionRegistration = registration;
    if (registerMissionCB->missionRegistration == nullptr) {
        HILOG_ERROR("%{public}s missionRegistration == nullptr.", __func__);
        registerMissionCB->result = -1;
        return;
    }
    registerMissionCB->missionRegistration->SetEnv(env);
    registerMissionCB->missionRegistration->
        SetNotifyMissionsChangedCBRef(registerMissionCB->missionRegistrationCB.callback[0]);
    registerMissionCB->missionRegistration->
        SetNotifySnapshotCBRef(registerMissionCB->missionRegistrationCB.callback[1]);
    registerMissionCB->missionRegistration->
        SetNotifyNetDisconnectCBRef(registerMissionCB->
            missionRegistrationCB.callback[2]); // 2 refers the second argument
    HILOG_INFO("set callback success.");

    registerMissionCB->result =
        AbilityManagerClient::GetInstance()->
        RegisterMissionListener(registerMissionCB->deviceId,
        registerMissionCB->missionRegistration);
    if (registerMissionCB->result == NO_ERROR) {
        HILOG_INFO("add registration.");
        registration_[registerMissionCB->deviceId] = registration;
    }
    HILOG_DEBUG("%{public}s end.deviceId:%{public}d ", __func__, registerMissionCB->result);
}

void RegisterMissionCallbackCompletedCB(napi_env env, napi_status status, void *data)
{
    HILOG_INFO("%{public}s called.", __func__);
    auto registerMissionCB = static_cast<RegisterMissionCB *>(data);
    // set result
    napi_value result[2] = { nullptr };
    napi_get_undefined(env, &result[1]);
    if (registerMissionCB->result == 0) {
        napi_get_undefined(env, &result[0]);
    } else {
        int32_t errCode = ErrorCodeReturn(registerMissionCB->result);
        result[0] = GenerateBusinessError(env, errCode, ErrorInfoReturn(errCode));
    }

    ReturnValueToApplication(env, &result[0], registerMissionCB);
    delete registerMissionCB;
    registerMissionCB = nullptr;
    HILOG_INFO("%{public}s end.", __func__);
}

void ReturnValueToApplication(napi_env env, napi_value *result, RegisterMissionCB *registerMissionCB)
{
    if (registerMissionCB->callbackRef == nullptr) { // promise
        if (registerMissionCB->result == 0) {
            napi_resolve_deferred(env, registerMissionCB->cbBase.deferred, result[1]);
        } else {
            napi_reject_deferred(env, registerMissionCB->cbBase.deferred, result[0]);
        }
    } else { // AsyncCallback
        napi_value callback = nullptr;
        napi_get_reference_value(env, registerMissionCB->callbackRef, &callback);
        napi_value callResult;
        napi_call_function(env, nullptr, callback, ARGS_TWO, &result[0], &callResult);
        napi_delete_reference(env, registerMissionCB->callbackRef);
    }
    NAPI_CALL_RETURN_VOID(env, napi_delete_async_work(env, registerMissionCB->cbBase.asyncWork));
}

napi_value RegisterMissionAsync(napi_env env, RegisterMissionCB *registerMissionCB)
{
    HILOG_INFO("%{public}s asyncCallback.", __func__);
    if (registerMissionCB == nullptr) {
        HILOG_ERROR("%{public}s, registerMissionCB == nullptr.", __func__);
        napi_throw(env, GenerateBusinessError(env, SYSTEM_WORK_ABNORMALLY, ErrorInfoReturn(SYSTEM_WORK_ABNORMALLY)));
        return nullptr;
    }
    napi_value result = nullptr;
    if (registerMissionCB->callbackRef == nullptr) {
        napi_create_promise(env, &registerMissionCB->cbBase.deferred, &result);
    } else {
        napi_get_undefined(env, &result);
    }
    napi_value resourceName = nullptr;
    napi_create_string_latin1(env, __func__, NAPI_AUTO_LENGTH, &resourceName);

    napi_create_async_work(env,
        nullptr,
        resourceName,
        RegisterMissionExecuteCB,
        RegisterMissionCallbackCompletedCB,
        static_cast<void *>(registerMissionCB),
        &registerMissionCB->cbBase.asyncWork);
    napi_queue_async_work(env, registerMissionCB->cbBase.asyncWork);
    HILOG_INFO("%{public}s asyncCallback end.", __func__);
    return result;
}

bool SetCallbackReference(napi_env env, const napi_value& value,
    RegisterMissionCB *registerMissionCB, std::string &errInfo)
{
    HILOG_INFO("%{public}s called.", __func__);
    bool isFirstCallback = false;
    napi_has_named_property(env, value, "notifyMissionsChanged", &isFirstCallback);
    bool isSecondCallback = false;
    napi_has_named_property(env, value, "notifySnapshot", &isSecondCallback);
    bool isThirdCallback = false;
    napi_has_named_property(env, value, "notifyNetDisconnect", &isThirdCallback);
    if (!isFirstCallback || !isSecondCallback || !isThirdCallback) {
        errInfo = "Parameter error. The type of \"options\" must be MissionCallback";
        return false;
    }
    napi_value jsMethod = nullptr;
    napi_get_named_property(env, value, "notifyMissionsChanged", &jsMethod);
    if (jsMethod == nullptr) {
        errInfo = "Parameter error. The value of \"notifyMissionsChanged\" must not be undefined";
        return false;
    }
    napi_valuetype valuetype = napi_undefined;
    napi_typeof(env, jsMethod, &valuetype);
    if (valuetype != napi_function) {
        errInfo = "Parameter error. The type of \"notifyMissionsChanged\" must be function";
        return false;
    }
    napi_create_reference(env, jsMethod, 1, &registerMissionCB->missionRegistrationCB.callback[0]);

    napi_get_named_property(env, value, "notifySnapshot", &jsMethod);
    if (jsMethod == nullptr) {
        errInfo = "Parameter error. The value of \"notifySnapshot\" must not be undefined";
        return false;
    }
    napi_typeof(env, jsMethod, &valuetype);
    if (valuetype != napi_function) {
        errInfo = "Parameter error. The type of \"notifySnapshot\" must be function";
        return false;
    }
    napi_create_reference(env, jsMethod, 1, &registerMissionCB->missionRegistrationCB.callback[1]);

    napi_get_named_property(env, value, "notifyNetDisconnect", &jsMethod);
    if (jsMethod == nullptr) {
        errInfo = "Parameter error. The value of \"notifyNetDisconnect\" must not be undefined";
        return false;
    }
    napi_typeof(env, jsMethod, &valuetype);
    if (valuetype != napi_function) {
        errInfo = "Parameter error. The type of \"notifyNetDisconnect\" must be function";
        return false;
    }
    napi_create_reference(env, jsMethod, 1,
        &registerMissionCB->missionRegistrationCB.callback[2]); // 2 refers the second argument
    HILOG_INFO("%{public}s called end.", __func__);
    return true;
}

bool CreateCallbackReference(napi_env env, const napi_value& value,
    RegisterMissionCB *registerMissionCB, std::string &errInfo)
{
    HILOG_INFO("%{public}s called.", __func__);
    napi_valuetype valuetype = napi_undefined;
    napi_typeof(env, value, &valuetype);
    if (valuetype == napi_object) {
        if (!SetCallbackReference(env, value, registerMissionCB, errInfo)) {
            HILOG_ERROR("%{public}s, Wrong callback.", __func__);
            return false;
        }
    } else {
        errInfo = "Parameter error. The type of \"options\" must be MissionCallback";
        return false;
    }
    HILOG_INFO("%{public}s called end.", __func__);
    return true;
}

napi_value RegisterMissionWrap(napi_env env, napi_callback_info info,
    RegisterMissionCB *registerMissionCB, std::string &errInfo)
{
    HILOG_INFO("%{public}s called.", __func__);
    size_t argcAsync = 3;
    napi_value args[ARGS_MAX_COUNT] = {nullptr};
    napi_get_cb_info(env, info, &argcAsync, args, nullptr, nullptr);
    if (argcAsync != ARGS_TWO && argcAsync != ARGS_THREE) {
        errInfo = "Parameter error. The type of \"number of parameters\" must be 2 or 3";
        return nullptr;
    }
    napi_value firstNApi = nullptr;
    napi_valuetype valueType = napi_undefined;
    bool isDeviceId = false;
    napi_has_named_property(env, args[0], "deviceId", &isDeviceId);
    napi_typeof(env, args[0], &valueType);
    if (!isDeviceId || valueType != napi_object) {
        errInfo = "Parameter error. The key of \"MissionDeviceInfo\" must be deviceId";
        return nullptr;
    }
    napi_get_named_property(env, args[0], "deviceId", &firstNApi);
    if (firstNApi == nullptr) {
        errInfo = "Parameter error. The value of \"deviceId\" must not be undefined";
        return nullptr;
    }

    napi_typeof(env, firstNApi, &valueType);
    if (valueType != napi_string) {
        errInfo = "Parameter error. The type of \"deviceId\" must be string";
        return nullptr;
    }
    char deviceId[VALUE_BUFFER_SIZE + 1] = {0};
    size_t valueLen = 0;
    napi_get_value_string_utf8(env, firstNApi, deviceId, VALUE_BUFFER_SIZE + 1, &valueLen);
    if (valueLen > VALUE_BUFFER_SIZE) {
        errInfo = "Parameter error. The length of \"deviceId\" must be less than " +
            std::to_string(VALUE_BUFFER_SIZE);
        return nullptr;
    }
    registerMissionCB->deviceId = deviceId;

    if (argcAsync > 1 && !CreateCallbackReference(env, args[1], registerMissionCB, errInfo)) {
        return nullptr;
    }

    if (argcAsync == ARGS_THREE) {
        napi_typeof(env, args[ARGS_TWO], &valueType);
        if (valueType != napi_function) {
            errInfo = "Parameter error. The type of \"options\" must be MissionCallback";
            return nullptr;
        }
        napi_create_reference(env, args[ARGS_TWO], 1, &registerMissionCB->callbackRef);
    }

    napi_value ret = RegisterMissionAsync(env, registerMissionCB);
    HILOG_INFO("%{public}s called end.", __func__);
    return ret;
}

napi_value NAPI_RegisterMissionListener(napi_env env, napi_callback_info info)
{
    HILOG_INFO("%{public}s called.", __func__);
    std::string errInfo = "Parameter error";
    RegisterMissionCB *registerMissionCB = CreateRegisterMissionCBCBInfo(env);
    if (registerMissionCB == nullptr) {
        HILOG_ERROR("%{public}s registerMissionCB == nullptr", __func__);
        napi_throw(env, GenerateBusinessError(env, SYSTEM_WORK_ABNORMALLY, ErrorInfoReturn(SYSTEM_WORK_ABNORMALLY)));
        return GetUndefined(env);
    }

    napi_value ret = RegisterMissionWrap(env, info, registerMissionCB, errInfo);
    if (ret == nullptr) {
        HILOG_ERROR("%{public}s ret == nullptr", __func__);
        delete registerMissionCB;
        registerMissionCB = nullptr;
        napi_throw(env, GenerateBusinessError(env, PARAMETER_CHECK_FAILED, errInfo));
        return GetUndefined(env);
    }
    HILOG_INFO("%{public}s end.", __func__);
    return ret;
}

void NAPIMissionContinue::SetEnv(const napi_env &env)
{
    env_ = env;
}

NAPIRemoteMissionListener::~NAPIRemoteMissionListener()
{
    if (env_ == nullptr) {
        return;
    }
    if (notifyMissionsChangedRef_ != nullptr) {
        napi_delete_reference(env_, notifyMissionsChangedRef_);
        notifyMissionsChangedRef_ = nullptr;
    }
    if (notifySnapshotRef_ != nullptr) {
        napi_delete_reference(env_, notifySnapshotRef_);
        notifySnapshotRef_ = nullptr;
    }
    if (notifyNetDisconnectRef_ != nullptr) {
        napi_delete_reference(env_, notifyNetDisconnectRef_);
        notifyNetDisconnectRef_ = nullptr;
    }
}

void NAPIRemoteMissionListener::SetEnv(const napi_env &env)
{
    env_ = env;
}

void NAPIRemoteMissionListener::SetNotifyMissionsChangedCBRef(const napi_ref &ref)
{
    notifyMissionsChangedRef_ = ref;
}

void NAPIRemoteMissionListener::SetNotifySnapshotCBRef(const napi_ref &ref)
{
    notifySnapshotRef_ = ref;
}

void NAPIRemoteMissionListener::SetNotifyNetDisconnectCBRef(const napi_ref &ref)
{
    notifyNetDisconnectRef_ = ref;
}

void UvWorkNotifyMissionChanged(uv_work_t *work, int status)
{
    HILOG_INFO("UvWorkNotifyMissionChanged, uv_queue_work");
    if (work == nullptr) {
        HILOG_ERROR("UvWorkNotifyMissionChanged, work is null");
        return;
    }
    RegisterMissionCB *registerMissionCB = static_cast<RegisterMissionCB *>(work->data);
    if (registerMissionCB == nullptr) {
        HILOG_ERROR("UvWorkNotifyMissionChanged, registerMissionCB is null");
        delete work;
        return;
    }
    napi_value result = nullptr;
    result =
        WrapString(registerMissionCB->cbBase.cbInfo.env, registerMissionCB->deviceId.c_str(), "deviceId");

    napi_value callback = nullptr;
    napi_value undefined = nullptr;
    napi_get_undefined(registerMissionCB->cbBase.cbInfo.env, &undefined);
    napi_value callResult = nullptr;
    napi_get_reference_value(
        registerMissionCB->cbBase.cbInfo.env, registerMissionCB->cbBase.cbInfo.callback, &callback);

    napi_call_function(registerMissionCB->cbBase.cbInfo.env, undefined, callback, 1, &result, &callResult);
    delete registerMissionCB;
    registerMissionCB = nullptr;
    delete work;
    HILOG_INFO("UvWorkNotifyMissionChanged, uv_queue_work end");
}

void NAPIRemoteMissionListener::NotifyMissionsChanged(const std::string& deviceId)
{
    HILOG_INFO("%{public}s, called.", __func__);
    uv_loop_s *loop = nullptr;

    napi_get_uv_event_loop(env_, &loop);
    if (loop == nullptr) {
        HILOG_ERROR("%{public}s, loop == nullptr.", __func__);
        return;
    }

    uv_work_t *work = new uv_work_t;

    auto registerMissionCB = new (std::nothrow) RegisterMissionCB;
    if (registerMissionCB == nullptr) {
        HILOG_ERROR("%{public}s, registerMissionCB == nullptr.", __func__);
        delete work;
        return;
    }
    registerMissionCB->cbBase.cbInfo.env = env_;
    registerMissionCB->cbBase.cbInfo.callback = notifyMissionsChangedRef_;
    registerMissionCB->deviceId = deviceId;
    work->data = static_cast<void *>(registerMissionCB);

    int rev = uv_queue_work(
        loop, work, [](uv_work_t *work) {}, UvWorkNotifyMissionChanged);
    if (rev != 0) {
        delete registerMissionCB;
        registerMissionCB = nullptr;
        delete work;
    }
    HILOG_INFO("%{public}s, end.", __func__);
}

void UvWorkNotifySnapshot(uv_work_t *work, int status)
{
    HILOG_INFO("UvWorkNotifySnapshot, uv_queue_work");
    if (work == nullptr) {
        HILOG_ERROR("UvWorkNotifySnapshot, work is null");
        return;
    }
    RegisterMissionCB *registerMissionCB = static_cast<RegisterMissionCB *>(work->data);
    if (registerMissionCB == nullptr) {
        HILOG_ERROR("UvWorkNotifySnapshot, registerMissionCB is null");
        delete work;
        return;
    }
    napi_value result[2] = {nullptr};
    result[0] =
        WrapString(registerMissionCB->cbBase.cbInfo.env, registerMissionCB->deviceId.c_str(), "deviceId");
    result[1] =
        WrapInt32(registerMissionCB->cbBase.cbInfo.env, registerMissionCB->missionId, "missionId");
    CallbackReturn(&result[0], registerMissionCB);
    delete registerMissionCB;
    registerMissionCB = nullptr;
    delete work;
    HILOG_INFO("UvWorkNotifySnapshot, uv_queue_work end");
}

void CallbackReturn(napi_value *result, RegisterMissionCB *registerMissionCB)
{
    napi_value callback = nullptr;
    napi_value undefined = nullptr;
    napi_get_undefined(registerMissionCB->cbBase.cbInfo.env, &undefined);
    napi_value callResult = nullptr;
    napi_get_reference_value(
        registerMissionCB->cbBase.cbInfo.env, registerMissionCB->cbBase.cbInfo.callback, &callback);

    napi_call_function(registerMissionCB->cbBase.cbInfo.env, undefined, callback, ARGS_TWO, &result[0], &callResult);
}

void NAPIRemoteMissionListener::NotifySnapshot(const std::string& deviceId, int32_t missionId)
{
    uv_loop_s *loop = nullptr;

    napi_get_uv_event_loop(env_, &loop);
    if (loop == nullptr) {
        HILOG_ERROR("%{public}s, loop == nullptr.", __func__);
        return;
    }

    uv_work_t *work = new uv_work_t;

    auto registerMissionCB = new (std::nothrow) RegisterMissionCB;
    if (registerMissionCB == nullptr) {
        HILOG_ERROR("%{public}s, registerMissionCB == nullptr.", __func__);
        delete work;
        return;
    }
    registerMissionCB->cbBase.cbInfo.env = env_;
    registerMissionCB->cbBase.cbInfo.callback = notifySnapshotRef_;
    registerMissionCB->deviceId = deviceId;
    registerMissionCB->missionId = missionId;
    work->data = static_cast<void *>(registerMissionCB);

    int rev = uv_queue_work(
        loop, work, [](uv_work_t *work) {}, UvWorkNotifySnapshot);
    if (rev != 0) {
        delete registerMissionCB;
        registerMissionCB = nullptr;
        delete work;
    }
    HILOG_INFO("%{public}s, end.", __func__);
}

void UvWorkNotifyNetDisconnect(uv_work_t *work, int status)
{
    HILOG_INFO("UvWorkNotifyNetDisconnect, uv_queue_work");
    if (work == nullptr) {
        HILOG_ERROR("UvWorkNotifyNetDisconnect, work is null");
        return;
    }
    RegisterMissionCB *registerMissionCB = static_cast<RegisterMissionCB *>(work->data);
    if (registerMissionCB == nullptr) {
        HILOG_ERROR("UvWorkNotifyNetDisconnect, registerMissionCB is null");
        delete work;
        return;
    }
    napi_value result[2] = {nullptr};
    result[0] =
        WrapString(registerMissionCB->cbBase.cbInfo.env, registerMissionCB->deviceId.c_str(), "deviceId");
    HILOG_INFO("UvWorkNotifyNetDisconnect, state = %{public}d", registerMissionCB->state);
    result[1] =
        WrapInt32(registerMissionCB->cbBase.cbInfo.env, registerMissionCB->state, "state");

    CallbackReturn(&result[0], registerMissionCB);
    delete registerMissionCB;
    registerMissionCB = nullptr;
    delete work;
    HILOG_INFO("UvWorkNotifyNetDisconnect, uv_queue_work end");
}

void NAPIRemoteMissionListener::NotifyNetDisconnect(const std::string& deviceId, int32_t state)
{
    HILOG_INFO("%{public}s called. state = %{public}d", __func__, state);
    uv_loop_s *loop = nullptr;

    napi_get_uv_event_loop(env_, &loop);
    if (loop == nullptr) {
        HILOG_ERROR("%{public}s, loop == nullptr.", __func__);
        return;
    }

    uv_work_t *work = new uv_work_t;

    auto registerMissionCB = new (std::nothrow) RegisterMissionCB;
    if (registerMissionCB == nullptr) {
        HILOG_ERROR("%{public}s, registerMissionCB == nullptr.", __func__);
        delete work;
        return;
    }
    registerMissionCB->cbBase.cbInfo.env = env_;
    registerMissionCB->cbBase.cbInfo.callback = notifyNetDisconnectRef_;
    registerMissionCB->deviceId = deviceId;
    registerMissionCB->state = state;
    work->data = static_cast<void *>(registerMissionCB);

    int rev = uv_queue_work(
        loop, work, [](uv_work_t *work) {}, UvWorkNotifyNetDisconnect);
    if (rev != 0) {
        delete registerMissionCB;
        registerMissionCB = nullptr;
        delete work;
    }
    HILOG_INFO("%{public}s, end.", __func__);
}

void UnRegisterMissionExecuteCB(napi_env env, void *data)
{
    HILOG_INFO("%{public}s called.", __func__);
    auto registerMissionCB = (RegisterMissionCB*)data;

    std::lock_guard<std::mutex> autoLock(registrationLock_);
    sptr<NAPIRemoteMissionListener> registration;
    auto item = registration_.find(registerMissionCB->deviceId);
    if (item != registration_.end()) {
        HILOG_INFO("registration exits.");
        registration = registration_[registerMissionCB->deviceId];
    } else {
        HILOG_INFO("registration not exits.");
        registerMissionCB->result = -1;
        return;
    }
    registerMissionCB->missionRegistration = registration;

    registerMissionCB->result =
        AbilityManagerClient::GetInstance()->
        UnRegisterMissionListener(registerMissionCB->deviceId,
        registerMissionCB->missionRegistration);
    if (registerMissionCB->result == NO_ERROR) {
        HILOG_INFO("remove registration.");
        registration_.erase(registerMissionCB->deviceId);
    }
    HILOG_DEBUG("%{public}s end.deviceId:%{public}d ", __func__, registerMissionCB->result);
}

void UnRegisterMissionPromiseCompletedCB(napi_env env, napi_status status, void *data)
{
    HILOG_INFO("%{public}s called.", __func__);
    auto registerMissionCB = (RegisterMissionCB*)data;
    // set result
    napi_value result[2] = { nullptr };
    napi_get_undefined(env, &result[1]);
    if (registerMissionCB->result == 0) {
        napi_get_undefined(env, &result[0]);
    } else {
        int32_t errCode = ErrorCodeReturn(registerMissionCB->result);
        result[0] = GenerateBusinessError(env, errCode, ErrorInfoReturn(errCode));
    }

    ReturnValueToApplication(env, &result[0], registerMissionCB);
    delete registerMissionCB;
    registerMissionCB = nullptr;
    HILOG_INFO("%{public}s end.", __func__);
}

napi_value UnRegisterMissionPromise(napi_env env, RegisterMissionCB *registerMissionCB)
{
    HILOG_INFO("%{public}s asyncCallback.", __func__);
    if (registerMissionCB == nullptr) {
        HILOG_ERROR("%{public}s, param == nullptr.", __func__);
        return nullptr;
    }
    napi_value promise = nullptr;
    if (registerMissionCB->callbackRef == nullptr) {
        napi_create_promise(env, &registerMissionCB->cbBase.deferred, &promise);
    } else {
        napi_get_undefined(env, &promise);
    }

    napi_value resourceName = nullptr;
    napi_create_string_latin1(env, __func__, NAPI_AUTO_LENGTH, &resourceName);

    napi_create_async_work(env,
        nullptr,
        resourceName,
        UnRegisterMissionExecuteCB,
        UnRegisterMissionPromiseCompletedCB,
        static_cast<void *>(registerMissionCB),
        &registerMissionCB->cbBase.asyncWork);
    napi_queue_async_work(env, registerMissionCB->cbBase.asyncWork);
    HILOG_INFO("%{public}s asyncCallback end.", __func__);
    return promise;
}

bool GetUnRegisterMissionDeviceId(napi_env env, const napi_value& value,
    RegisterMissionCB *registerMissionCB, std::string &errInfo)
{
    HILOG_INFO("%{public}s called.", __func__);
    napi_value firstNApi = nullptr;
    napi_valuetype valueType = napi_undefined;
    bool isDeviceId = false;
    napi_has_named_property(env, value, "deviceId", &isDeviceId);
    napi_typeof(env, value, &valueType);
    if (isDeviceId && valueType == napi_object) {
        napi_get_named_property(env, value, "deviceId", &firstNApi);
    } else {
        errInfo = "Parameter error. The key of \"MissionDeviceInfo\" must be deviceId";
        return false;
    }
    if (firstNApi == nullptr) {
        errInfo = "Parameter error. The value of \"deviceId\" must not be undefined";
        return false;
    }

    size_t valueLen = 0;
    napi_typeof(env, firstNApi, &valueType);
    if (valueType != napi_string) {
        errInfo = "Parameter error. The type of \"deviceId\" must be string";
        return false;
    }
    char deviceId[VALUE_BUFFER_SIZE + 1] = {0};
    napi_get_value_string_utf8(env, firstNApi, deviceId, VALUE_BUFFER_SIZE + 1, &valueLen);
    if (valueLen > VALUE_BUFFER_SIZE) {
        errInfo = "Parameter error. The length of \"deviceId\" must be less than " +
            std::to_string(VALUE_BUFFER_SIZE);
        return false;
    }
    registerMissionCB->deviceId = deviceId;
    HILOG_INFO("%{public}s called end.", __func__);
    return true;
}

napi_value UnRegisterMissionWrap(napi_env env, napi_callback_info info,
    RegisterMissionCB *registerMissionCB, std::string &errInfo)
{
    HILOG_INFO("%{public}s called.", __func__);
    size_t argc = 2;
    napi_value args[ARGS_MAX_COUNT] = {nullptr};
    napi_value ret = nullptr;

    napi_get_cb_info(env, info, &argc, args, nullptr, nullptr);
    HILOG_INFO("argc is %{public}zu", argc);
    if (argc != ARGS_ONE && argc != ARGS_TWO) {
        errInfo = "Parameter error. The type of \"number of parameters\" must be 1 or 2";
        return nullptr;
    }

    if (!GetUnRegisterMissionDeviceId(env, args[0], registerMissionCB, errInfo)) {
        HILOG_ERROR("%{public}s, Wrong argument.", __func__);
        return nullptr;
    }

    if (argc == ARGS_TWO) {
        napi_valuetype valueType = napi_undefined;
        napi_typeof(env, args[1], &valueType);
        if (valueType != napi_function) {
            errInfo = "Parameter error. The type of \"callback\" must be AsynCallback<void>: void";
            return nullptr;
        }
        napi_create_reference(env, args[1], 1, &registerMissionCB->callbackRef);
    }
    ret = UnRegisterMissionPromise(env, registerMissionCB);
    HILOG_INFO("%{public}s called end.", __func__);
    return ret;
}

napi_value NAPI_UnRegisterMissionListener(napi_env env, napi_callback_info info)
{
    HILOG_INFO("%{public}s called.", __func__);
    std::string errInfo = "Parameter error";
    RegisterMissionCB *registerMissionCB = CreateRegisterMissionCBCBInfo(env);
    if (registerMissionCB == nullptr) {
        HILOG_ERROR("%{public}s registerMissionCB == nullptr", __func__);
        napi_throw(env, GenerateBusinessError(env, SYSTEM_WORK_ABNORMALLY, ErrorInfoReturn(SYSTEM_WORK_ABNORMALLY)));
        return GetUndefined(env);
    }

    napi_value ret = UnRegisterMissionWrap(env, info, registerMissionCB, errInfo);
    if (ret == nullptr) {
        HILOG_ERROR("%{public}s ret == nullptr", __func__);
        delete registerMissionCB;
        registerMissionCB = nullptr;
        napi_throw(env, GenerateBusinessError(env, PARAMETER_CHECK_FAILED, errInfo));
        return GetUndefined(env);
    }
    HILOG_INFO("%{public}s end.", __func__);
    return ret;
}

napi_value WrapString(napi_env env, const std::string &param, const std::string &paramName)
{
    HILOG_INFO("%{public}s called.", __func__);

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

    napi_value jsValue = nullptr;
    HILOG_DEBUG("%{public}s called. %{public}s = %{public}s", __func__, paramName.c_str(), param.c_str());
    napi_create_string_utf8(env, param.c_str(), NAPI_AUTO_LENGTH, &jsValue);
    napi_set_named_property(env, jsObject, paramName.c_str(), jsValue);

    return jsObject;
}

napi_value WrapInt32(napi_env env, int32_t num, const std::string &paramName)
{
    HILOG_INFO("%{public}s called.", __func__);

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

    napi_value jsValue = nullptr;
    HILOG_DEBUG("%{public}s called. %{public}s = %{public}d", __func__, paramName.c_str(), num);
    napi_create_int32(env, num, &jsValue);
    napi_set_named_property(env, jsObject, paramName.c_str(), jsValue);

    return jsObject;
}

ContinueAbilityCB *CreateContinueAbilityCBCBInfo(napi_env env)
{
    HILOG_INFO("%{public}s called.", __func__);
    auto continueAbilityCB = new (std::nothrow) ContinueAbilityCB;
    if (continueAbilityCB == nullptr) {
        HILOG_ERROR("%{public}s continueAbilityCB == nullptr", __func__);
        return nullptr;
    }
    continueAbilityCB->cbBase.cbInfo.env = env;
    continueAbilityCB->cbBase.asyncWork = nullptr;
    continueAbilityCB->cbBase.deferred = nullptr;
    continueAbilityCB->callbackRef = nullptr;
    HILOG_INFO("%{public}s end.", __func__);
    return continueAbilityCB;
}

void ContinueAbilityExecuteCB(napi_env env, void *data)
{
    HILOG_INFO("%{public}s called.", __func__);
    auto continueAbilityCB = static_cast<ContinueAbilityCB *>(data);
    HILOG_INFO("create continueAbilityCB success.");
    sptr<NAPIMissionContinue> continuation(new (std::nothrow) NAPIMissionContinue());
    continueAbilityCB->abilityContinuation = continuation;
    if (continueAbilityCB->abilityContinuation == nullptr) {
        HILOG_ERROR("%{public}s abilityContinuation == nullptr.", __func__);
        return;
    }
    continueAbilityCB->abilityContinuation->SetContinueAbilityEnv(env);
    HILOG_INFO("set env success.");
    continueAbilityCB->abilityContinuation->
        SetContinueAbilityCBRef(continueAbilityCB->abilityContinuationCB.callback[0]);
    HILOG_INFO("set callback success.");
    continueAbilityCB->result = -1;
    continueAbilityCB->result = AAFwk::AbilityManagerClient::GetInstance()->
        ContinueMission(continueAbilityCB->srcDeviceId, continueAbilityCB->dstDeviceId,
        continueAbilityCB->missionId, continueAbilityCB->abilityContinuation,
        continueAbilityCB->wantParams);
    HILOG_INFO("%{public}s end. error:%{public}d ", __func__, continueAbilityCB->result);
}

void ContinueAbilityCallbackCompletedCB(napi_env env, napi_status status, void *data)
{
    HILOG_INFO("%{public}s called.", __func__);
    auto continueAbilityCB = static_cast<ContinueAbilityCB *>(data);
    // set result
    napi_value result[2] = { nullptr };
    napi_get_undefined(env, &result[1]);
    if (continueAbilityCB->result == 0) {
        napi_get_undefined(env, &result[0]);
    } else {
        int32_t errCode = ErrorCodeReturn(continueAbilityCB->result);
        result[0] = GenerateBusinessError(env, errCode, ErrorInfoReturn(errCode));
    }

    if (continueAbilityCB->callbackRef == nullptr) { // promise
        if (continueAbilityCB->result == 0) {
            napi_resolve_deferred(env, continueAbilityCB->cbBase.deferred, result[1]);
        } else {
            napi_reject_deferred(env, continueAbilityCB->cbBase.deferred, result[0]);
        }
    } else { // AsyncCallback
        napi_value callback = nullptr;
        napi_get_reference_value(env, continueAbilityCB->callbackRef, &callback);
        napi_value callResult;
        napi_call_function(env, nullptr, callback, ARGS_TWO, &result[0], &callResult);
        napi_delete_reference(env, continueAbilityCB->callbackRef);
    }
    napi_delete_async_work(env, continueAbilityCB->cbBase.asyncWork);
    delete continueAbilityCB;
    continueAbilityCB = nullptr;
    HILOG_INFO("%{public}s end.", __func__);
}

napi_value ContinueAbilityAsync(napi_env env, ContinueAbilityCB *continueAbilityCB)
{
    HILOG_INFO("%{public}s asyncCallback.", __func__);
    if (continueAbilityCB == nullptr) {
        HILOG_ERROR("%{public}s, param == nullptr.", __func__);
        return nullptr;
    }

    napi_value result = nullptr;
    if (continueAbilityCB->callbackRef == nullptr) {
        napi_create_promise(env, &continueAbilityCB->cbBase.deferred, &result);
    } else {
        napi_get_undefined(env, &result);
    }

    napi_value resourceName = nullptr;
    napi_create_string_latin1(env, "ContinueAbilityAsyncForLauncher", NAPI_AUTO_LENGTH, &resourceName);

    napi_create_async_work(env,
        nullptr,
        resourceName,
        ContinueAbilityExecuteCB,
        ContinueAbilityCallbackCompletedCB,
        static_cast<void *>(continueAbilityCB),
        &continueAbilityCB->cbBase.asyncWork);
    napi_queue_async_work(env, continueAbilityCB->cbBase.asyncWork);
    HILOG_INFO("%{public}s asyncCallback end.", __func__);
    return result;
}

bool CheckContinueKeyExist(napi_env env, const napi_value &value)
{
    bool isSrcDeviceId = false;
    napi_has_named_property(env, value, "srcDeviceId", &isSrcDeviceId);
    bool isDstDeviceId = false;
    napi_has_named_property(env, value, "dstDeviceId", &isDstDeviceId);
    bool isMissionId = false;
    napi_has_named_property(env, value, "missionId", &isMissionId);
    bool isWantParam = false;
    napi_has_named_property(env, value, "wantParam", &isWantParam);
    if (!isSrcDeviceId && !isDstDeviceId && !isMissionId && !isWantParam) {
        HILOG_ERROR("%{public}s, Wrong argument key.", __func__);
        return false;
    }
    return true;
}

bool CheckContinueFirstArgs(napi_env env, const napi_value &value,
    ContinueAbilityCB *continueAbilityCB, std::string &errInfo)
{
    HILOG_INFO("%{public}s called.", __func__);
    if (!CheckContinueKeyExist(env, value)) {
        errInfo = "Parameter error. The type of \"parameter\" must be ContinueMission";
        return false;
    }
    napi_value firstNApi = nullptr;
    napi_value secondNApi = nullptr;
    napi_value thirdNApi = nullptr;
    napi_value fourthNApi = nullptr;
    napi_valuetype valueType = napi_undefined;
    napi_typeof(env, value, &valueType);
    if (valueType != napi_object) {
        errInfo = "Parameter error. The type of \"parameter\" must be ContinueMission";
        return false;
    }
    napi_get_named_property(env, value, "srcDeviceId", &firstNApi);
    napi_get_named_property(env, value, "dstDeviceId", &secondNApi);
    napi_get_named_property(env, value, "missionId", &thirdNApi);
    napi_get_named_property(env, value, "wantParam", &fourthNApi);
    if (firstNApi == nullptr || secondNApi == nullptr || thirdNApi == nullptr || fourthNApi == nullptr) {
        errInfo = "Parameter error. The number of \"ContinueMission\" must be 4";
        return false;
    }
    napi_typeof(env, firstNApi, &valueType);
    if (valueType != napi_string) {
        errInfo = "Parameter error. The type of \"srcDeviceId\" must be string";
        return false;
    }
    continueAbilityCB->srcDeviceId = AppExecFwk::UnwrapStringFromJS(env, firstNApi, "");
    napi_typeof(env, secondNApi, &valueType);
    if (valueType != napi_string) {
        errInfo = "Parameter error. The type of \"dstDeviceId\" must be string";
        return false;
    }
    continueAbilityCB->dstDeviceId = AppExecFwk::UnwrapStringFromJS(env, secondNApi, "");
    napi_typeof(env, thirdNApi, &valueType);
    if (valueType != napi_number) {
        errInfo = "Parameter error. The type of \"missionId\" must be number";
        return false;
    }
    continueAbilityCB->missionId = AppExecFwk::UnwrapInt32FromJS(env, thirdNApi, -1);
    napi_typeof(env, fourthNApi, &valueType);
    if (valueType != napi_object) {
        errInfo = "Parameter error. The type of \"wantParams\" must be object";
        return false;
    }
    if (!AppExecFwk::UnwrapWantParams(env, fourthNApi, continueAbilityCB->wantParams)) {
        errInfo = "Parameter error. The type of \"wantParams\" must be array";
        return false;
    }
    HILOG_INFO("%{public}s called end.", __func__);
    return true;
}

bool CheckContinueCallback(napi_env env, const napi_value &value,
    ContinueAbilityCB *continueAbilityCB, std::string &errInfo)
{
    HILOG_INFO("%{public}s called.", __func__);
    napi_value jsMethod = nullptr;
    napi_valuetype valuetype = napi_undefined;
    napi_typeof(env, value, &valuetype);
    if (valuetype != napi_object) {
        errInfo = "Parameter error. The type of \"options\" must be ContinueCallback";
        return false;
    }
    bool isFirstCallback = false;
    napi_has_named_property(env, value, "onContinueDone", &isFirstCallback);
    if (!isFirstCallback) {
        errInfo = "Parameter error. The key of \"ContinueCallback\" must be onContinueDone";
        return false;
    }
    napi_get_named_property(env, value, "onContinueDone", &jsMethod);
    if (jsMethod == nullptr) {
        errInfo = "Parameter error. The value of \"onContinueDone\" must not be undefined";
        return false;
    }
    napi_typeof(env, jsMethod, &valuetype);
    if (valuetype != napi_function) {
        errInfo = "Parameter error. The type of \"onContinueDone\" must be function";
        return false;
    }
    napi_create_reference(env, jsMethod, 1, &continueAbilityCB->abilityContinuationCB.callback[0]);
    HILOG_INFO("%{public}s called end.", __func__);
    return true;
}

napi_value ContinueAbilityWrap(napi_env env, napi_callback_info info,
    ContinueAbilityCB *continueAbilityCB, std::string &errInfo)
{
    HILOG_INFO("%{public}s called.", __func__);
    size_t argcAsync = 3;
    napi_value args[ARGS_MAX_COUNT] = {nullptr};
    napi_value ret = nullptr;

    napi_get_cb_info(env, info, &argcAsync, args, nullptr, nullptr);
    HILOG_INFO("argcAsync is %{public}zu", argcAsync);
    if (argcAsync != ARGS_TWO && argcAsync != ARGS_THREE) {
        errInfo = "Parameter error. The type of \"number of parameters\" must be 2 or 3";
        return nullptr;
    }

    if (!CheckContinueFirstArgs(env, args[0], continueAbilityCB, errInfo)) {
        HILOG_ERROR("%{public}s, check the first argument failed.", __func__);
        return nullptr;
    }

    if (argcAsync > 1) {
        if (!CheckContinueCallback(env, args[1], continueAbilityCB, errInfo)) {
            HILOG_ERROR("%{public}s, check callback failed.", __func__);
            return nullptr;
        }
    }

    if (argcAsync == ARGS_THREE) {
        napi_valuetype valueType = napi_undefined;
        napi_typeof(env, args[ARGS_TWO], &valueType);
        if (valueType != napi_function) {
            errInfo = "Parameter error. The type of \"callback\" must be AsynCallback<void>: void";
            return nullptr;
        }
        napi_create_reference(env, args[ARGS_TWO], 1, &continueAbilityCB->callbackRef);
    }

    ret = ContinueAbilityAsync(env, continueAbilityCB);
    HILOG_INFO("%{public}s called end.", __func__);
    return ret;
}

napi_value NAPI_ContinueAbility(napi_env env, napi_callback_info info)
{
    HILOG_INFO("%{public}s called.", __func__);
    std::string errInfo = "Parameter error";
    ContinueAbilityCB *continueAbilityCB = CreateContinueAbilityCBCBInfo(env);
    if (continueAbilityCB == nullptr) {
        HILOG_ERROR("%{public}s continueAbilityCB == nullptr", __func__);
        napi_throw(env, GenerateBusinessError(env, SYSTEM_WORK_ABNORMALLY, ErrorInfoReturn(SYSTEM_WORK_ABNORMALLY)));
        return GetUndefined(env);
    }

    napi_value ret = ContinueAbilityWrap(env, info, continueAbilityCB, errInfo);
    if (ret == nullptr) {
        HILOG_ERROR("%{public}s ret == nullptr", __func__);
        delete continueAbilityCB;
        continueAbilityCB = nullptr;
        napi_throw(env, GenerateBusinessError(env, PARAMETER_CHECK_FAILED, errInfo));
        return GetUndefined(env);
    }
    HILOG_INFO("%{public}s end.", __func__);
    return ret;
}

void UvWorkOnContinueDone(uv_work_t *work, int status)
{
    HILOG_INFO("UvWorkOnContinueDone, uv_queue_work");
    if (work == nullptr) {
        HILOG_ERROR("UvWorkOnContinueDone, work is null");
        return;
    }
    ContinueAbilityCB *continueAbilityCB = static_cast<ContinueAbilityCB *>(work->data);
    if (continueAbilityCB == nullptr) {
        HILOG_ERROR("UvWorkOnContinueDone, continueAbilityCB is null");
        delete work;
        return;
    }
    napi_value result = nullptr;
    HILOG_INFO("UvWorkOnContinueDone, resultCode = %{public}d", continueAbilityCB->resultCode);
    result =
        WrapInt32(continueAbilityCB->cbBase.cbInfo.env, continueAbilityCB->resultCode, "resultCode");

    napi_value callback = nullptr;
    napi_value undefined = nullptr;
    napi_get_undefined(continueAbilityCB->cbBase.cbInfo.env, &undefined);
    napi_value callResult = nullptr;
    napi_get_reference_value(continueAbilityCB->cbBase.cbInfo.env,
        continueAbilityCB->cbBase.cbInfo.callback, &callback);

    napi_call_function(continueAbilityCB->cbBase.cbInfo.env, undefined, callback, 1, &result, &callResult);
    if (continueAbilityCB->cbBase.cbInfo.callback != nullptr) {
        napi_delete_reference(continueAbilityCB->cbBase.cbInfo.env, continueAbilityCB->cbBase.cbInfo.callback);
    }
    delete continueAbilityCB;
    continueAbilityCB = nullptr;
    delete work;
    HILOG_INFO("UvWorkOnContinueDone, uv_queue_work end");
}

void NAPIMissionContinue::OnContinueDone(int32_t result)
{
    HILOG_INFO("%{public}s, called. result = %{public}d", __func__, result);
    uv_loop_s *loop = nullptr;

    napi_get_uv_event_loop(env_, &loop);
    if (loop == nullptr) {
        HILOG_ERROR("%{public}s, loop == nullptr.", __func__);
        return;
    }

    uv_work_t *work = new uv_work_t;

    auto continueAbilityCB = new (std::nothrow) ContinueAbilityCB;
    if (continueAbilityCB == nullptr) {
        HILOG_ERROR("%{public}s, continueAbilityCB == nullptr.", __func__);
        delete work;
        return;
    }
    continueAbilityCB->cbBase.cbInfo.env = env_;
    continueAbilityCB->cbBase.cbInfo.callback = onContinueDoneRef_;
    continueAbilityCB->resultCode = result;
    work->data = static_cast<void *>(continueAbilityCB);

    int rev = uv_queue_work(
        loop, work, [](uv_work_t *work) {}, UvWorkOnContinueDone);
    if (rev != 0) {
        delete continueAbilityCB;
        continueAbilityCB = nullptr;
        delete work;
    }
    HILOG_INFO("%{public}s, end.", __func__);
}

void NAPIMissionContinue::SetContinueAbilityEnv(const napi_env &env)
{
    env_ = env;
}

void NAPIMissionContinue::SetContinueAbilityCBRef(const napi_ref &ref)
{
    onContinueDoneRef_ = ref;
}

napi_value DistributedMissionManagerExport(napi_env env, napi_value exports)
{
    HILOG_INFO("%{public}s,called", __func__);
    napi_property_descriptor properties[] = {
        DECLARE_NAPI_FUNCTION("startSyncRemoteMissions", NAPI_StartSyncRemoteMissions),
        DECLARE_NAPI_FUNCTION("stopSyncRemoteMissions", NAPI_StopSyncRemoteMissions),
        DECLARE_NAPI_FUNCTION("registerMissionListener", NAPI_RegisterMissionListener),
        DECLARE_NAPI_FUNCTION("unRegisterMissionListener", NAPI_UnRegisterMissionListener),
        DECLARE_NAPI_FUNCTION("continueMission", NAPI_ContinueAbility),
    };
    NAPI_CALL(env, napi_define_properties(env, exports, sizeof(properties) / sizeof(properties[0]), properties));
    return exports;
}

static napi_module missionModule = {
    .nm_version = 1,
    .nm_flags = 0,
    .nm_filename = nullptr,
    .nm_register_func = DistributedMissionManagerExport,
    .nm_modname = "distributedMissionManager",
    .nm_priv = ((void*)nullptr),
    .reserved = {nullptr}
};

extern "C" __attribute__((constructor)) void AbilityRegister()
{
    napi_module_register(&missionModule);
}
}
}