mirror of
https://github.com/openharmony/aafwk_standard.git
synced 2026-07-01 20:04:39 -04:00
8130b7fd16
Signed-off-by: zhoushicheng2@huawei.com <zhoushicheng2@huawei.com> Change-Id: Ia08d2d34ba0ffa09f6d1cd66a99eb8fc87d715b9
1619 lines
63 KiB
C++
1619 lines
63 KiB
C++
/*
|
|
* Copyright (c) 2021-2022 Huawei Device Co., Ltd.
|
|
* Licensed under the Apache License, Version 2.0 (the "License");
|
|
* you may not use this file except in compliance with the License.
|
|
* You may obtain a copy of the License at
|
|
*
|
|
* http://www.apache.org/licenses/LICENSE-2.0
|
|
*
|
|
* Unless required by applicable law or agreed to in writing, software
|
|
* distributed under the License is distributed on an "AS IS" BASIS,
|
|
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
* See the License for the specific language governing permissions and
|
|
* limitations under the License.
|
|
*/
|
|
#include "feature_ability.h"
|
|
|
|
#include <cstring>
|
|
#include <uv.h>
|
|
#include <vector>
|
|
|
|
#include "../inner/napi_common/napi_common_ability.h"
|
|
#include "ability_process.h"
|
|
#include "element_name.h"
|
|
#include "hilog_wrapper.h"
|
|
#include "napi_context.h"
|
|
#include "napi_data_ability_helper.h"
|
|
#include "securec.h"
|
|
#include "hitrace_meter.h"
|
|
|
|
using namespace OHOS::AAFwk;
|
|
using namespace OHOS::AppExecFwk;
|
|
|
|
namespace OHOS {
|
|
namespace AppExecFwk {
|
|
static int64_t dummyRequestCode_ = 0;
|
|
CallbackInfo g_aceCallbackInfo;
|
|
|
|
const int PARA_SIZE_IS_ONE = 1;
|
|
const int PARA_SIZE_IS_TWO = 2;
|
|
|
|
/**
|
|
* @brief FeatureAbility NAPI module registration.
|
|
*
|
|
* @param env The environment that the Node-API call is invoked under.
|
|
* @param exports An empty object via the exports parameter as a convenience.
|
|
*
|
|
* @return The return value from Init is treated as the exports object for the module.
|
|
*/
|
|
napi_value FeatureAbilityInit(napi_env env, napi_value exports)
|
|
{
|
|
HILOG_INFO("%{public}s,called", __func__);
|
|
napi_property_descriptor properties[] = {
|
|
DECLARE_NAPI_FUNCTION("startAbility", NAPI_StartAbility),
|
|
DECLARE_NAPI_FUNCTION("startAbilityForResult", NAPI_StartAbilityForResult),
|
|
DECLARE_NAPI_FUNCTION("finishWithResult", NAPI_SetResult),
|
|
DECLARE_NAPI_FUNCTION("terminateSelfWithResult", NAPI_SetResult),
|
|
DECLARE_NAPI_FUNCTION("terminateAbility", NAPI_TerminateAbility),
|
|
DECLARE_NAPI_FUNCTION("terminateSelf", NAPI_TerminateAbility),
|
|
DECLARE_NAPI_FUNCTION("hasWindowFocus", NAPI_HasWindowFocus),
|
|
DECLARE_NAPI_FUNCTION("getContext", NAPI_GetContext),
|
|
DECLARE_NAPI_FUNCTION("getWant", NAPI_GetWant),
|
|
DECLARE_NAPI_FUNCTION("getAppType", NAPI_GetAppType),
|
|
DECLARE_NAPI_FUNCTION("getAbilityName", NAPI_GetAbilityName),
|
|
DECLARE_NAPI_FUNCTION("getAbilityInfo", NAPI_GetAbilityInfo),
|
|
DECLARE_NAPI_FUNCTION("getHapModuleInfo", NAPI_GetHapModuleInfo),
|
|
DECLARE_NAPI_FUNCTION("getDataAbilityHelper", NAPI_GetDataAbilityHelper),
|
|
DECLARE_NAPI_FUNCTION("acquireDataAbilityHelper", NAPI_AcquireDataAbilityHelper),
|
|
DECLARE_NAPI_FUNCTION("connectAbility", NAPI_FAConnectAbility),
|
|
DECLARE_NAPI_FUNCTION("disconnectAbility", NAPI_FADisConnectAbility),
|
|
DECLARE_NAPI_FUNCTION("continueAbility", NAPI_FAContinueAbility),
|
|
DECLARE_NAPI_FUNCTION("getWantSync", NAPI_GetWantSync),
|
|
};
|
|
NAPI_CALL(env, napi_define_properties(env, exports, sizeof(properties) / sizeof(properties[0]), properties));
|
|
|
|
return exports;
|
|
}
|
|
|
|
/**
|
|
* @brief FeatureAbility NAPI method : startAbility.
|
|
*
|
|
* @param env The environment that the Node-API call is invoked under.
|
|
* @param info The callback info passed into the callback function.
|
|
*
|
|
* @return The return value from NAPI C++ to JS for the module.
|
|
*/
|
|
napi_value NAPI_StartAbility(napi_env env, napi_callback_info info)
|
|
{
|
|
HILOG_INFO("%{public}s called.", __func__);
|
|
return NAPI_StartAbilityCommon(env, info, AbilityType::PAGE);
|
|
}
|
|
|
|
/**
|
|
* @brief FeatureAbility NAPI method : startAbilityForResult.
|
|
*
|
|
* @param env The environment that the Node-API call is invoked under.
|
|
* @param info The callback info passed into the callback function.
|
|
*
|
|
* @return The return value from NAPI C++ to JS for the module.
|
|
*/
|
|
napi_value NAPI_StartAbilityForResult(napi_env env, napi_callback_info info)
|
|
{
|
|
HILOG_INFO("%{public}s,called.", __func__);
|
|
AsyncCallbackInfo *asyncCallbackInfo = CreateAsyncCallbackInfo(env);
|
|
if (asyncCallbackInfo == nullptr) {
|
|
return WrapVoidToJS(env);
|
|
}
|
|
|
|
napi_value ret = StartAbilityForResultWrap(env, info, asyncCallbackInfo);
|
|
if (ret == nullptr) {
|
|
if (asyncCallbackInfo != nullptr) {
|
|
delete asyncCallbackInfo;
|
|
asyncCallbackInfo = nullptr;
|
|
}
|
|
ret = WrapVoidToJS(env);
|
|
}
|
|
HILOG_INFO("%{public}s,end.", __func__);
|
|
return ret;
|
|
}
|
|
|
|
/**
|
|
* @brief StartAbilityForResult processing function.
|
|
*
|
|
* @param env The environment that the Node-API call is invoked under.
|
|
* @param asyncCallbackInfo Process data asynchronously.
|
|
*
|
|
* @return Return JS data successfully, otherwise return nullptr.
|
|
*/
|
|
napi_value StartAbilityForResultWrap(napi_env env, napi_callback_info info, AsyncCallbackInfo *asyncCallbackInfo)
|
|
{
|
|
HILOG_INFO("%{public}s,called", __func__);
|
|
size_t argcAsync = 2;
|
|
const size_t argcPromise = 1;
|
|
const size_t argCountWithAsync = argcPromise + ARGS_ASYNC_COUNT;
|
|
napi_value args[ARGS_MAX_COUNT] = {nullptr};
|
|
napi_value ret = 0;
|
|
|
|
NAPI_CALL(env, napi_get_cb_info(env, info, &argcAsync, args, nullptr, nullptr));
|
|
if (argcAsync > argCountWithAsync || argcAsync > ARGS_MAX_COUNT) {
|
|
HILOG_ERROR("%{public}s, Wrong argument count.", __func__);
|
|
return nullptr;
|
|
}
|
|
|
|
CallAbilityParam param;
|
|
if (UnwrapForResultParam(param, env, args[0]) == nullptr) {
|
|
HILOG_ERROR("%{public}s, call UnwrapForResultParam failed.", __func__);
|
|
return nullptr;
|
|
}
|
|
asyncCallbackInfo->param = param;
|
|
asyncCallbackInfo->aceCallback.env = env;
|
|
if (argcAsync > PARAM1) {
|
|
napi_valuetype valuetype = napi_undefined;
|
|
napi_typeof(env, args[PARAM1], &valuetype);
|
|
if (valuetype == napi_function) {
|
|
// resultCallback: AsyncCallback<StartAbilityResult>
|
|
napi_create_reference(env, args[PARAM1], 1, &(asyncCallbackInfo->aceCallback.callback));
|
|
}
|
|
}
|
|
|
|
if (argcAsync > argcPromise) {
|
|
ret = StartAbilityForResultAsync(env, asyncCallbackInfo);
|
|
} else {
|
|
ret = StartAbilityForResultPromise(env, asyncCallbackInfo);
|
|
}
|
|
HILOG_INFO("%{public}s,end.", __func__);
|
|
return ret;
|
|
}
|
|
|
|
napi_value StartAbilityForResultAsync(napi_env env, AsyncCallbackInfo *asyncCallbackInfo)
|
|
{
|
|
HILOG_INFO("%{public}s, asyncCallback.", __func__);
|
|
if (asyncCallbackInfo == nullptr) {
|
|
HILOG_ERROR("%{public}s, param == nullptr.", __func__);
|
|
return nullptr;
|
|
}
|
|
napi_value resourceName = 0;
|
|
NAPI_CALL(env, napi_create_string_latin1(env, __func__, NAPI_AUTO_LENGTH, &resourceName));
|
|
|
|
NAPI_CALL(env, napi_create_async_work(
|
|
env,
|
|
nullptr,
|
|
resourceName,
|
|
[](napi_env env, void *data) {
|
|
HILOG_INFO("NAPI_StartAbilityForResult, worker pool thread execute.");
|
|
AsyncCallbackInfo *asyncCallbackInfo = static_cast<AsyncCallbackInfo *>(data);
|
|
if (asyncCallbackInfo != nullptr) {
|
|
asyncCallbackInfo->errCode = AbilityProcess::GetInstance()->StartAbility(
|
|
asyncCallbackInfo->ability, asyncCallbackInfo->param, asyncCallbackInfo->aceCallback);
|
|
} else {
|
|
HILOG_ERROR("NAPI_StartAbilityForResult, asyncCallbackInfo == nullptr");
|
|
}
|
|
HILOG_INFO("NAPI_StartAbilityForResult, worker pool thread execute end.");
|
|
},
|
|
[](napi_env env, napi_status status, void *data) {
|
|
AsyncCallbackInfo *asyncCallbackInfo = static_cast<AsyncCallbackInfo *>(data);
|
|
HILOG_INFO("NAPI_StartAbilityForResult, complete. err:%{public}d", asyncCallbackInfo->errCode);
|
|
if (asyncCallbackInfo->errCode != ERR_OK) {
|
|
Want resultData; // Callback the errcode when StartAbilityForResult failed.
|
|
AbilityProcess::GetInstance()->OnAbilityResult(asyncCallbackInfo->ability,
|
|
asyncCallbackInfo->param.requestCode, 0, resultData);
|
|
}
|
|
// remove asynccallback from startabilityforresult
|
|
if (asyncCallbackInfo->cbInfo.callback != nullptr) {
|
|
napi_delete_reference(env, asyncCallbackInfo->cbInfo.callback);
|
|
}
|
|
napi_delete_async_work(env, asyncCallbackInfo->asyncWork);
|
|
delete asyncCallbackInfo;
|
|
HILOG_INFO("NAPI_StartAbilityForResult, main event thread complete end.");
|
|
},
|
|
(void *)asyncCallbackInfo,
|
|
&asyncCallbackInfo->asyncWork));
|
|
NAPI_CALL(env, napi_queue_async_work(env, asyncCallbackInfo->asyncWork));
|
|
napi_value result = 0;
|
|
NAPI_CALL(env, napi_get_null(env, &result));
|
|
HILOG_INFO("%{public}s, asyncCallback end.", __func__);
|
|
return result;
|
|
}
|
|
|
|
napi_value StartAbilityForResultPromise(napi_env env, AsyncCallbackInfo *asyncCallbackInfo)
|
|
{
|
|
HILOG_INFO("%{public}s, promise.", __func__);
|
|
if (asyncCallbackInfo == nullptr) {
|
|
HILOG_ERROR("%{public}s, param == nullptr.", __func__);
|
|
return nullptr;
|
|
}
|
|
napi_value resourceName = 0;
|
|
napi_create_string_latin1(env, __func__, NAPI_AUTO_LENGTH, &resourceName);
|
|
napi_deferred deferred;
|
|
napi_value promise = 0;
|
|
napi_create_promise(env, &deferred, &promise);
|
|
asyncCallbackInfo->aceCallback.callback = nullptr;
|
|
asyncCallbackInfo->aceCallback.deferred = deferred;
|
|
|
|
napi_create_async_work(
|
|
env,
|
|
nullptr,
|
|
resourceName,
|
|
[](napi_env env, void *data) {
|
|
HILOG_INFO("NAPI_StartAbilityForResult, worker pool thread execute.");
|
|
AsyncCallbackInfo *asyncCallbackInfo = static_cast<AsyncCallbackInfo *>(data);
|
|
if (asyncCallbackInfo != nullptr) {
|
|
asyncCallbackInfo->errCode = AbilityProcess::GetInstance()->StartAbility(
|
|
asyncCallbackInfo->ability, asyncCallbackInfo->param, asyncCallbackInfo->aceCallback);
|
|
} else {
|
|
HILOG_ERROR("NAPI_StartAbilityForResult, asyncCallbackInfo == nullptr");
|
|
}
|
|
HILOG_INFO("NAPI_StartAbilityForResult, worker pool thread execute end.");
|
|
},
|
|
[](napi_env env, napi_status status, void *data) {
|
|
AsyncCallbackInfo *asyncCallbackInfo = static_cast<AsyncCallbackInfo *>(data);
|
|
HILOG_INFO("NAPI_StartAbilityForResult, complete. err:%{public}d", asyncCallbackInfo->errCode);
|
|
if (asyncCallbackInfo->errCode != ERR_OK) {
|
|
Want resultData; // Callback the errcode when StartAbilityForResult failed.
|
|
AbilityProcess::GetInstance()->OnAbilityResult(asyncCallbackInfo->ability,
|
|
asyncCallbackInfo->param.requestCode, 0, resultData);
|
|
}
|
|
// resolve it when call onAbilityResult
|
|
napi_delete_async_work(env, asyncCallbackInfo->asyncWork);
|
|
delete asyncCallbackInfo;
|
|
HILOG_INFO("NAPI_StartAbilityForResult, main event thread complete end.");
|
|
},
|
|
(void *)asyncCallbackInfo,
|
|
&asyncCallbackInfo->asyncWork);
|
|
napi_queue_async_work(env, asyncCallbackInfo->asyncWork);
|
|
HILOG_INFO("%{public}s, promise end.", __func__);
|
|
return promise;
|
|
}
|
|
|
|
/**
|
|
* @brief FeatureAbility NAPI method : setResult.
|
|
*
|
|
* @param env The environment that the Node-API call is invoked under.
|
|
* @param info The callback info passed into the callback function.
|
|
*
|
|
* @return The return value from NAPI C++ to JS for the module.
|
|
*/
|
|
napi_value NAPI_SetResult(napi_env env, napi_callback_info info)
|
|
{
|
|
HILOG_INFO("%{public}s,called", __func__);
|
|
AsyncCallbackInfo *asyncCallbackInfo = CreateAsyncCallbackInfo(env);
|
|
if (asyncCallbackInfo == nullptr) {
|
|
HILOG_ERROR("%{public}s,asyncCallbackInfo == nullptr", __func__);
|
|
return WrapVoidToJS(env);
|
|
}
|
|
|
|
napi_value ret = SetResultWrap(env, info, asyncCallbackInfo);
|
|
if (ret == nullptr) {
|
|
HILOG_ERROR("%{public}s,ret == nullptr", __func__);
|
|
if (asyncCallbackInfo != nullptr) {
|
|
delete asyncCallbackInfo;
|
|
asyncCallbackInfo = nullptr;
|
|
}
|
|
ret = WrapVoidToJS(env);
|
|
}
|
|
HILOG_INFO("%{public}s,end", __func__);
|
|
return ret;
|
|
}
|
|
|
|
/**
|
|
* @brief SetResult processing function.
|
|
*
|
|
* @param env The environment that the Node-API call is invoked under.
|
|
* @param asyncCallbackInfo Process data asynchronously.
|
|
*
|
|
* @return Return JS data successfully, otherwise return nullptr.
|
|
*/
|
|
napi_value SetResultWrap(napi_env env, napi_callback_info info, AsyncCallbackInfo *asyncCallbackInfo)
|
|
{
|
|
HILOG_INFO("%{public}s,called", __func__);
|
|
size_t argcAsync = 2;
|
|
const size_t argcPromise = 1;
|
|
const size_t argCountWithAsync = argcPromise + ARGS_ASYNC_COUNT;
|
|
napi_value args[ARGS_MAX_COUNT] = {nullptr};
|
|
napi_value ret = 0;
|
|
|
|
NAPI_CALL(env, napi_get_cb_info(env, info, &argcAsync, args, nullptr, nullptr));
|
|
if (argcAsync > argCountWithAsync || argcAsync > ARGS_MAX_COUNT) {
|
|
HILOG_ERROR("%{public}s, Wrong argument count.", __func__);
|
|
return nullptr;
|
|
}
|
|
|
|
CallAbilityParam param;
|
|
if (UnwrapAbilityResult(param, env, args[0]) == nullptr) {
|
|
HILOG_ERROR("%{public}s, call unwrapWant failed.", __func__);
|
|
return nullptr;
|
|
}
|
|
asyncCallbackInfo->param = param;
|
|
|
|
if (argcAsync > argcPromise) {
|
|
ret = SetResultAsync(env, args, 1, asyncCallbackInfo);
|
|
} else {
|
|
ret = SetResultPromise(env, asyncCallbackInfo);
|
|
}
|
|
HILOG_INFO("%{public}s,end", __func__);
|
|
return ret;
|
|
}
|
|
|
|
napi_value SetResultAsync(
|
|
napi_env env, napi_value *args, const size_t argCallback, AsyncCallbackInfo *asyncCallbackInfo)
|
|
{
|
|
HILOG_INFO("%{public}s, asyncCallback.", __func__);
|
|
if (args == nullptr || asyncCallbackInfo == nullptr) {
|
|
HILOG_ERROR("%{public}s, param == nullptr.", __func__);
|
|
return nullptr;
|
|
}
|
|
napi_value resourceName = 0;
|
|
NAPI_CALL(env, napi_create_string_latin1(env, __func__, NAPI_AUTO_LENGTH, &resourceName));
|
|
|
|
napi_valuetype valuetype = napi_undefined;
|
|
NAPI_CALL(env, napi_typeof(env, args[argCallback], &valuetype));
|
|
if (valuetype == napi_function) {
|
|
napi_create_reference(env, args[argCallback], 1, &asyncCallbackInfo->cbInfo.callback);
|
|
}
|
|
|
|
NAPI_CALL(env, napi_create_async_work(
|
|
env,
|
|
nullptr,
|
|
resourceName,
|
|
[](napi_env env, void *data) {
|
|
HILOG_INFO("NAPI_SetResult, worker pool thread execute.");
|
|
AsyncCallbackInfo *asyncCallbackInfo = static_cast<AsyncCallbackInfo *>(data);
|
|
if (asyncCallbackInfo->ability != nullptr) {
|
|
asyncCallbackInfo->ability->SetResult(
|
|
asyncCallbackInfo->param.requestCode, asyncCallbackInfo->param.want);
|
|
asyncCallbackInfo->ability->TerminateAbility();
|
|
} else {
|
|
HILOG_ERROR("NAPI_SetResult, ability == nullptr");
|
|
}
|
|
HILOG_INFO("NAPI_SetResult, worker pool thread execute end.");
|
|
},
|
|
[](napi_env env, napi_status status, void *data) {
|
|
HILOG_INFO("NAPI_SetResult, main event thread complete.");
|
|
AsyncCallbackInfo *asyncCallbackInfo = static_cast<AsyncCallbackInfo *>(data);
|
|
napi_value result[ARGS_TWO] = {0};
|
|
napi_value callback = 0;
|
|
napi_value undefined = 0;
|
|
napi_value callResult = 0;
|
|
napi_get_undefined(env, &undefined);
|
|
result[PARAM0] = GetCallbackErrorValue(env, NO_ERROR);
|
|
napi_get_null(env, &result[PARAM1]);
|
|
napi_get_reference_value(env, asyncCallbackInfo->cbInfo.callback, &callback);
|
|
napi_call_function(env, undefined, callback, ARGS_TWO, &result[PARAM0], &callResult);
|
|
|
|
if (asyncCallbackInfo->cbInfo.callback != nullptr) {
|
|
napi_delete_reference(env, asyncCallbackInfo->cbInfo.callback);
|
|
}
|
|
napi_delete_async_work(env, asyncCallbackInfo->asyncWork);
|
|
delete asyncCallbackInfo;
|
|
HILOG_INFO("NAPI_SetResult, main event thread complete end.");
|
|
},
|
|
(void *)asyncCallbackInfo,
|
|
&asyncCallbackInfo->asyncWork));
|
|
NAPI_CALL(env, napi_queue_async_work(env, asyncCallbackInfo->asyncWork));
|
|
napi_value result = 0;
|
|
NAPI_CALL(env, napi_get_null(env, &result));
|
|
HILOG_INFO("%{public}s, asyncCallback end", __func__);
|
|
return result;
|
|
}
|
|
|
|
napi_value SetResultPromise(napi_env env, AsyncCallbackInfo *asyncCallbackInfo)
|
|
{
|
|
HILOG_INFO("%{public}s, promise.", __func__);
|
|
if (asyncCallbackInfo == nullptr) {
|
|
HILOG_ERROR("%{public}s, param == nullptr.", __func__);
|
|
return nullptr;
|
|
}
|
|
napi_value resourceName = 0;
|
|
NAPI_CALL(env, napi_create_string_latin1(env, __func__, NAPI_AUTO_LENGTH, &resourceName));
|
|
napi_deferred deferred;
|
|
napi_value promise = 0;
|
|
NAPI_CALL(env, napi_create_promise(env, &deferred, &promise));
|
|
asyncCallbackInfo->deferred = deferred;
|
|
|
|
NAPI_CALL(env, napi_create_async_work(
|
|
env,
|
|
nullptr,
|
|
resourceName,
|
|
[](napi_env env, void *data) {
|
|
HILOG_INFO("NAPI_SetResult, worker pool thread execute.");
|
|
AsyncCallbackInfo *asyncCallbackInfo = static_cast<AsyncCallbackInfo *>(data);
|
|
if (asyncCallbackInfo->ability != nullptr) {
|
|
asyncCallbackInfo->ability->SetResult(
|
|
asyncCallbackInfo->param.requestCode, asyncCallbackInfo->param.want);
|
|
asyncCallbackInfo->ability->TerminateAbility();
|
|
} else {
|
|
HILOG_ERROR("NAPI_SetResult, ability == nullptr");
|
|
}
|
|
HILOG_INFO("NAPI_SetResult, worker pool thread execute end.");
|
|
},
|
|
[](napi_env env, napi_status status, void *data) {
|
|
HILOG_INFO("NAPI_SetResult, main event thread complete.");
|
|
AsyncCallbackInfo *asyncCallbackInfo = static_cast<AsyncCallbackInfo *>(data);
|
|
napi_value result = 0;
|
|
napi_get_null(env, &result);
|
|
napi_resolve_deferred(env, asyncCallbackInfo->deferred, result);
|
|
napi_delete_async_work(env, asyncCallbackInfo->asyncWork);
|
|
delete asyncCallbackInfo;
|
|
HILOG_INFO("NAPI_SetResult, main event thread complete end.");
|
|
},
|
|
(void *)asyncCallbackInfo,
|
|
&asyncCallbackInfo->asyncWork));
|
|
NAPI_CALL(env, napi_queue_async_work(env, asyncCallbackInfo->asyncWork));
|
|
HILOG_INFO("%{public}s, promise end", __func__);
|
|
return promise;
|
|
}
|
|
|
|
/**
|
|
* @brief FeatureAbility NAPI method : terminateAbility.
|
|
*
|
|
* @param env The environment that the Node-API call is invoked under.
|
|
* @param info The callback info passed into the callback function.
|
|
*
|
|
* @return The return value from NAPI C++ to JS for the module.
|
|
*/
|
|
napi_value NAPI_TerminateAbility(napi_env env, napi_callback_info info)
|
|
{
|
|
HILOG_INFO("%{public}s,called", __func__);
|
|
AsyncCallbackInfo *asyncCallbackInfo = CreateAsyncCallbackInfo(env);
|
|
if (asyncCallbackInfo == nullptr) {
|
|
HILOG_ERROR("%{public}s,asyncCallbackInfo == nullptr", __func__);
|
|
return WrapVoidToJS(env);
|
|
}
|
|
|
|
napi_value ret = TerminateAbilityWrap(env, info, asyncCallbackInfo);
|
|
if (ret == nullptr) {
|
|
HILOG_ERROR("%{public}s,ret == nullptr", __func__);
|
|
if (asyncCallbackInfo != nullptr) {
|
|
delete asyncCallbackInfo;
|
|
asyncCallbackInfo = nullptr;
|
|
}
|
|
ret = WrapVoidToJS(env);
|
|
}
|
|
HILOG_INFO("%{public}s,end", __func__);
|
|
return ret;
|
|
}
|
|
|
|
/**
|
|
* @brief TerminateAbility processing function.
|
|
*
|
|
* @param env The environment that the Node-API call is invoked under.
|
|
* @param asyncCallbackInfo Process data asynchronously.
|
|
*
|
|
* @return Return JS data successfully, otherwise return nullptr.
|
|
*/
|
|
napi_value TerminateAbilityWrap(napi_env env, napi_callback_info info, AsyncCallbackInfo *asyncCallbackInfo)
|
|
{
|
|
HILOG_INFO("%{public}s, asyncCallback.", __func__);
|
|
if (asyncCallbackInfo == nullptr) {
|
|
HILOG_ERROR("%{public}s, asyncCallbackInfo == nullptr.", __func__);
|
|
return nullptr;
|
|
}
|
|
|
|
size_t argcAsync = 1;
|
|
const size_t argcPromise = 0;
|
|
const size_t argCountWithAsync = argcPromise + ARGS_ASYNC_COUNT;
|
|
napi_value args[ARGS_MAX_COUNT] = {nullptr};
|
|
napi_value ret = 0;
|
|
|
|
NAPI_CALL(env, napi_get_cb_info(env, info, &argcAsync, args, nullptr, nullptr));
|
|
if (argcAsync > argCountWithAsync || argcAsync > ARGS_MAX_COUNT) {
|
|
HILOG_ERROR("%{public}s, Wrong argument count.", __func__);
|
|
return nullptr;
|
|
}
|
|
|
|
if (argcAsync > argcPromise) {
|
|
ret = TerminateAbilityAsync(env, args, 0, asyncCallbackInfo);
|
|
} else {
|
|
ret = TerminateAbilityPromise(env, asyncCallbackInfo);
|
|
}
|
|
HILOG_INFO("%{public}s, asyncCallback end", __func__);
|
|
return ret;
|
|
}
|
|
|
|
napi_value TerminateAbilityAsync(
|
|
napi_env env, napi_value *args, const size_t argCallback, AsyncCallbackInfo *asyncCallbackInfo)
|
|
{
|
|
HILOG_INFO("%{public}s, asyncCallback.", __func__);
|
|
if (args == nullptr || asyncCallbackInfo == nullptr) {
|
|
HILOG_ERROR("%{public}s, param == nullptr.", __func__);
|
|
return nullptr;
|
|
}
|
|
napi_value resourceName = 0;
|
|
NAPI_CALL(env, napi_create_string_latin1(env, __func__, NAPI_AUTO_LENGTH, &resourceName));
|
|
|
|
napi_valuetype valuetype = napi_undefined;
|
|
NAPI_CALL(env, napi_typeof(env, args[argCallback], &valuetype));
|
|
if (valuetype == napi_function) {
|
|
NAPI_CALL(env, napi_create_reference(env, args[argCallback], 1, &asyncCallbackInfo->cbInfo.callback));
|
|
}
|
|
|
|
NAPI_CALL(env, napi_create_async_work(
|
|
env,
|
|
nullptr,
|
|
resourceName,
|
|
[](napi_env env, void *data) {
|
|
HILOG_INFO("NAPI_TerminateAbility, worker pool thread execute.");
|
|
AsyncCallbackInfo *asyncCallbackInfo = static_cast<AsyncCallbackInfo *>(data);
|
|
if (asyncCallbackInfo->ability != nullptr) {
|
|
asyncCallbackInfo->ability->TerminateAbility();
|
|
} else {
|
|
HILOG_ERROR("NAPI_TerminateAbility, ability == nullptr");
|
|
}
|
|
HILOG_INFO("NAPI_TerminateAbility, worker pool thread execute end.");
|
|
},
|
|
[](napi_env env, napi_status status, void *data) {
|
|
HILOG_INFO("NAPI_TerminateAbility, main event thread complete.");
|
|
AsyncCallbackInfo *asyncCallbackInfo = static_cast<AsyncCallbackInfo *>(data);
|
|
napi_value callback = 0;
|
|
napi_value undefined = 0;
|
|
napi_value result[ARGS_TWO] = {0};
|
|
napi_value callResult = 0;
|
|
napi_get_undefined(env, &undefined);
|
|
result[PARAM0] = GetCallbackErrorValue(env, NO_ERROR);
|
|
napi_get_null(env, &result[PARAM1]);
|
|
napi_get_reference_value(env, asyncCallbackInfo->cbInfo.callback, &callback);
|
|
napi_call_function(env, undefined, callback, ARGS_TWO, &result[PARAM0], &callResult);
|
|
|
|
if (asyncCallbackInfo->cbInfo.callback != nullptr) {
|
|
napi_delete_reference(env, asyncCallbackInfo->cbInfo.callback);
|
|
}
|
|
napi_delete_async_work(env, asyncCallbackInfo->asyncWork);
|
|
delete asyncCallbackInfo;
|
|
HILOG_INFO("NAPI_TerminateAbility, main event thread complete end.");
|
|
},
|
|
(void *)asyncCallbackInfo,
|
|
&asyncCallbackInfo->asyncWork));
|
|
NAPI_CALL(env, napi_queue_async_work(env, asyncCallbackInfo->asyncWork));
|
|
napi_value result = 0;
|
|
NAPI_CALL(env, napi_get_null(env, &result));
|
|
HILOG_INFO("%{public}s, asyncCallback end", __func__);
|
|
return result;
|
|
}
|
|
|
|
napi_value TerminateAbilityPromise(napi_env env, AsyncCallbackInfo *asyncCallbackInfo)
|
|
{
|
|
HILOG_INFO("%{public}s, promise.", __func__);
|
|
if (asyncCallbackInfo == nullptr) {
|
|
HILOG_ERROR("%{public}s, param == nullptr.", __func__);
|
|
return nullptr;
|
|
}
|
|
napi_value resourceName = 0;
|
|
NAPI_CALL(env, napi_create_string_latin1(env, __func__, NAPI_AUTO_LENGTH, &resourceName));
|
|
napi_deferred deferred;
|
|
napi_value promise = 0;
|
|
NAPI_CALL(env, napi_create_promise(env, &deferred, &promise));
|
|
|
|
asyncCallbackInfo->deferred = deferred;
|
|
|
|
NAPI_CALL(env, napi_create_async_work(
|
|
env,
|
|
nullptr,
|
|
resourceName,
|
|
[](napi_env env, void *data) {
|
|
HILOG_INFO("NAPI_TerminateAbility, worker pool thread execute.");
|
|
AsyncCallbackInfo *asyncCallbackInfo = static_cast<AsyncCallbackInfo *>(data);
|
|
if (asyncCallbackInfo->ability != nullptr) {
|
|
asyncCallbackInfo->ability->TerminateAbility();
|
|
} else {
|
|
HILOG_INFO("NAPI_TerminateAbility, ability == nullptr");
|
|
}
|
|
HILOG_INFO("NAPI_TerminateAbility, worker pool thread execute end.");
|
|
},
|
|
[](napi_env env, napi_status status, void *data) {
|
|
HILOG_INFO("NAPI_TerminateAbility, main event thread complete.");
|
|
AsyncCallbackInfo *asyncCallbackInfo = static_cast<AsyncCallbackInfo *>(data);
|
|
napi_value result = 0;
|
|
napi_get_null(env, &result);
|
|
napi_resolve_deferred(env, asyncCallbackInfo->deferred, result);
|
|
napi_delete_async_work(env, asyncCallbackInfo->asyncWork);
|
|
delete asyncCallbackInfo;
|
|
HILOG_INFO("NAPI_TerminateAbility, main event thread complete end.");
|
|
},
|
|
(void *)asyncCallbackInfo,
|
|
&asyncCallbackInfo->asyncWork));
|
|
NAPI_CALL(env, napi_queue_async_work(env, asyncCallbackInfo->asyncWork));
|
|
HILOG_INFO("%{public}s, promise end", __func__);
|
|
return promise;
|
|
}
|
|
|
|
/**
|
|
* @brief Checks whether the main window of this ability has window focus.
|
|
*
|
|
* @param env The environment that the Node-API call is invoked under.
|
|
* @param info The callback info passed into the callback function.
|
|
*
|
|
* @return The return value from NAPI C++ to JS for the module.
|
|
*/
|
|
napi_value NAPI_HasWindowFocus(napi_env env, napi_callback_info info)
|
|
{
|
|
#ifdef SUPPORT_GRAPHICS
|
|
HILOG_INFO("%{public}s,called", __func__);
|
|
AsyncCallbackInfo *asyncCallbackInfo = CreateAsyncCallbackInfo(env);
|
|
if (asyncCallbackInfo == nullptr) {
|
|
HILOG_ERROR("%{public}s,asyncCallbackInfo == nullptr", __func__);
|
|
return WrapVoidToJS(env);
|
|
}
|
|
|
|
napi_value ret = HasWindowFocusWrap(env, info, asyncCallbackInfo);
|
|
if (ret == nullptr) {
|
|
HILOG_ERROR("%{public}s,ret == nullptr", __func__);
|
|
if (asyncCallbackInfo != nullptr) {
|
|
delete asyncCallbackInfo;
|
|
asyncCallbackInfo = nullptr;
|
|
}
|
|
ret = WrapVoidToJS(env);
|
|
}
|
|
HILOG_INFO("%{public}s,end", __func__);
|
|
return ret;
|
|
#else
|
|
return nullptr;
|
|
#endif
|
|
}
|
|
|
|
/**
|
|
* @brief Get context.
|
|
*
|
|
* @param env The environment that the Node-API call is invoked under.
|
|
* @param info The callback info passed into the callback function.
|
|
*
|
|
* @return The return value from NAPI C++ to JS for the module.
|
|
*/
|
|
napi_value NAPI_GetContext(napi_env env, napi_callback_info info)
|
|
{
|
|
HILOG_INFO("%{public}s called.", __func__);
|
|
return NAPI_GetContextCommon(env, info, AbilityType::PAGE);
|
|
}
|
|
|
|
/**
|
|
* @brief HasWindowFocus processing function.
|
|
*
|
|
* @param env The environment that the Node-API call is invoked under.
|
|
* @param asyncCallbackInfo Process data asynchronously.
|
|
*
|
|
* @return Return JS data successfully, otherwise return nullptr.
|
|
*/
|
|
napi_value HasWindowFocusWrap(napi_env env, napi_callback_info info, AsyncCallbackInfo *asyncCallbackInfo)
|
|
{
|
|
#ifdef SUPPORT_GRAPHICS
|
|
HILOG_INFO("%{public}s, asyncCallback.", __func__);
|
|
if (asyncCallbackInfo == nullptr) {
|
|
HILOG_ERROR("%{public}s, asyncCallbackInfo == nullptr.", __func__);
|
|
return nullptr;
|
|
}
|
|
|
|
size_t argcAsync = 1;
|
|
const size_t argcPromise = 0;
|
|
const size_t argCountWithAsync = argcPromise + ARGS_ASYNC_COUNT;
|
|
napi_value args[ARGS_MAX_COUNT] = {nullptr};
|
|
napi_value ret = 0;
|
|
|
|
NAPI_CALL(env, napi_get_cb_info(env, info, &argcAsync, args, nullptr, nullptr));
|
|
if (argcAsync > argCountWithAsync || argcAsync > ARGS_MAX_COUNT) {
|
|
HILOG_ERROR("%{public}s, Wrong argument count.", __func__);
|
|
return nullptr;
|
|
}
|
|
|
|
if (argcAsync > argcPromise) {
|
|
ret = HasWindowFocusAsync(env, args, 0, asyncCallbackInfo);
|
|
} else {
|
|
ret = HasWindowFocusPromise(env, asyncCallbackInfo);
|
|
}
|
|
HILOG_INFO("%{public}s, asyncCallback end.", __func__);
|
|
return ret;
|
|
#else
|
|
return nullptr;
|
|
#endif
|
|
}
|
|
|
|
#ifdef SUPPORT_GRAPHICS
|
|
napi_value HasWindowFocusAsync(
|
|
napi_env env, napi_value *args, const size_t argCallback, AsyncCallbackInfo *asyncCallbackInfo)
|
|
{
|
|
HILOG_INFO("%{public}s, asyncCallback.", __func__);
|
|
if (args == nullptr || asyncCallbackInfo == nullptr) {
|
|
HILOG_ERROR("%{public}s, param == nullptr.", __func__);
|
|
return nullptr;
|
|
}
|
|
napi_value resourceName = 0;
|
|
NAPI_CALL(env, napi_create_string_latin1(env, __func__, NAPI_AUTO_LENGTH, &resourceName));
|
|
|
|
napi_valuetype valuetype = napi_undefined;
|
|
NAPI_CALL(env, napi_typeof(env, args[argCallback], &valuetype));
|
|
if (valuetype == napi_function) {
|
|
NAPI_CALL(env, napi_create_reference(env, args[argCallback], 1, &asyncCallbackInfo->cbInfo.callback));
|
|
}
|
|
NAPI_CALL(env, napi_create_async_work(
|
|
env,
|
|
nullptr,
|
|
resourceName,
|
|
[](napi_env env, void *data) {
|
|
HILOG_INFO("NAPI_HasWindowFocus, worker pool thread execute.");
|
|
AsyncCallbackInfo *asyncCallbackInfo = static_cast<AsyncCallbackInfo *>(data);
|
|
if (asyncCallbackInfo->ability != nullptr) {
|
|
asyncCallbackInfo->native_result = asyncCallbackInfo->ability->HasWindowFocus();
|
|
} else {
|
|
HILOG_ERROR("NAPI_HasWindowFocus, ability == nullptr");
|
|
}
|
|
HILOG_INFO("NAPI_HasWindowFocus, worker pool thread execute end.");
|
|
},
|
|
[](napi_env env, napi_status status, void *data) {
|
|
HILOG_INFO("NAPI_HasWindowFocus, main event thread complete.");
|
|
AsyncCallbackInfo *asyncCallbackInfo = static_cast<AsyncCallbackInfo *>(data);
|
|
napi_value callback = 0;
|
|
napi_value undefined = 0;
|
|
napi_value result[ARGS_TWO] = {0};
|
|
napi_value callResult = 0;
|
|
napi_get_undefined(env, &undefined);
|
|
result[PARAM0] = GetCallbackErrorValue(env, NO_ERROR);
|
|
napi_get_boolean(env, asyncCallbackInfo->native_result, &result[PARAM1]);
|
|
napi_get_reference_value(env, asyncCallbackInfo->cbInfo.callback, &callback);
|
|
napi_call_function(env, undefined, callback, ARGS_TWO, &result[PARAM0], &callResult);
|
|
|
|
if (asyncCallbackInfo->cbInfo.callback != nullptr) {
|
|
napi_delete_reference(env, asyncCallbackInfo->cbInfo.callback);
|
|
}
|
|
napi_delete_async_work(env, asyncCallbackInfo->asyncWork);
|
|
delete asyncCallbackInfo;
|
|
asyncCallbackInfo = nullptr;
|
|
HILOG_INFO("NAPI_HasWindowFocus, main event thread complete end.");
|
|
},
|
|
(void *)asyncCallbackInfo,
|
|
&asyncCallbackInfo->asyncWork));
|
|
NAPI_CALL(env, napi_queue_async_work(env, asyncCallbackInfo->asyncWork));
|
|
napi_value result = 0;
|
|
NAPI_CALL(env, napi_get_null(env, &result));
|
|
HILOG_INFO("%{public}s, asyncCallback end.", __func__);
|
|
return result;
|
|
}
|
|
|
|
napi_value HasWindowFocusPromise(napi_env env, AsyncCallbackInfo *asyncCallbackInfo)
|
|
{
|
|
HILOG_INFO("%{public}s, promise.", __func__);
|
|
if (asyncCallbackInfo == nullptr) {
|
|
HILOG_ERROR("%{public}s, param == nullptr.", __func__);
|
|
return nullptr;
|
|
}
|
|
napi_value resourceName = 0;
|
|
NAPI_CALL(env, napi_create_string_latin1(env, __func__, NAPI_AUTO_LENGTH, &resourceName));
|
|
napi_deferred deferred;
|
|
napi_value promise = 0;
|
|
NAPI_CALL(env, napi_create_promise(env, &deferred, &promise));
|
|
asyncCallbackInfo->deferred = deferred;
|
|
|
|
NAPI_CALL(env, napi_create_async_work(
|
|
env,
|
|
nullptr,
|
|
resourceName,
|
|
[](napi_env env, void *data) {
|
|
HILOG_INFO("NAPI_HasWindowFocus, worker pool thread execute.");
|
|
AsyncCallbackInfo *asyncCallbackInfo = static_cast<AsyncCallbackInfo *>(data);
|
|
if (asyncCallbackInfo->ability != nullptr) {
|
|
asyncCallbackInfo->native_result = asyncCallbackInfo->ability->HasWindowFocus();
|
|
} else {
|
|
HILOG_INFO("NAPI_HasWindowFocus, ability == nullptr");
|
|
}
|
|
HILOG_INFO("NAPI_HasWindowFocus, worker pool thread execute end.");
|
|
},
|
|
[](napi_env env, napi_status status, void *data) {
|
|
HILOG_INFO("NAPI_HasWindowFocus, main event thread complete.");
|
|
AsyncCallbackInfo *asyncCallbackInfo = static_cast<AsyncCallbackInfo *>(data);
|
|
napi_value result = 0;
|
|
napi_get_boolean(env, asyncCallbackInfo->native_result, &result);
|
|
napi_resolve_deferred(env, asyncCallbackInfo->deferred, result);
|
|
napi_delete_async_work(env, asyncCallbackInfo->asyncWork);
|
|
delete asyncCallbackInfo;
|
|
asyncCallbackInfo = nullptr;
|
|
HILOG_INFO("NAPI_HasWindowFocus, main event thread complete end.");
|
|
},
|
|
(void *)asyncCallbackInfo,
|
|
&asyncCallbackInfo->asyncWork));
|
|
NAPI_CALL(env, napi_queue_async_work(env, asyncCallbackInfo->asyncWork));
|
|
HILOG_INFO("%{public}s, promise end.", __func__);
|
|
return promise;
|
|
}
|
|
#else
|
|
napi_value HasWindowFocusAsync(
|
|
napi_env env, napi_value *args, const size_t argCallback, AsyncCallbackInfo *asyncCallbackInfo)
|
|
{
|
|
return nullptr;
|
|
}
|
|
|
|
napi_value HasWindowFocusPromise(napi_env env, AsyncCallbackInfo *asyncCallbackInfo)
|
|
{
|
|
return nullptr;
|
|
}
|
|
#endif
|
|
|
|
EXTERN_C_START
|
|
/**
|
|
* @brief The interface of onAbilityResult provided for ACE to call back to JS.
|
|
*
|
|
* @param requestCode Indicates the request code returned after the ability is started.
|
|
* @param resultCode Indicates the result code returned after the ability is started.
|
|
* @param resultData Indicates the data returned after the ability is started.
|
|
* @param cb The environment and call back info that the Node-API call is invoked under.
|
|
*
|
|
* @return The return value from NAPI C++ to JS for the module.
|
|
*/
|
|
void CallOnAbilityResult(int requestCode, int resultCode, const Want &resultData, CallbackInfo cb)
|
|
{
|
|
HILOG_INFO("%{public}s,called", __func__);
|
|
uv_loop_s *loop = nullptr;
|
|
|
|
napi_get_uv_event_loop(cb.env, &loop);
|
|
if (loop == nullptr) {
|
|
return;
|
|
}
|
|
|
|
uv_work_t *work = new (std::nothrow) uv_work_t;
|
|
if (work == nullptr) {
|
|
HILOG_ERROR("%{public}s, work == nullptr.", __func__);
|
|
return;
|
|
}
|
|
OnAbilityCallback *onAbilityCB = new (std::nothrow) OnAbilityCallback;
|
|
if (onAbilityCB == nullptr) {
|
|
HILOG_ERROR("%{public}s, onAbilityCB == nullptr.", __func__);
|
|
if (work != nullptr) {
|
|
delete work;
|
|
work = nullptr;
|
|
}
|
|
return;
|
|
}
|
|
onAbilityCB->requestCode = requestCode;
|
|
onAbilityCB->resultCode = resultCode;
|
|
onAbilityCB->resultData = resultData;
|
|
onAbilityCB->cb = cb;
|
|
|
|
work->data = (void *)onAbilityCB;
|
|
|
|
int rev = uv_queue_work(
|
|
loop,
|
|
work,
|
|
[](uv_work_t *work) {},
|
|
[](uv_work_t *work, int status) {
|
|
HILOG_INFO("CallOnAbilityResult, uv_queue_work");
|
|
// JS Thread
|
|
if (work == nullptr) {
|
|
HILOG_ERROR("%{public}s, uv_queue_work work == nullptr.", __func__);
|
|
return;
|
|
}
|
|
OnAbilityCallback *onAbilityCB = static_cast<OnAbilityCallback *>(work->data);
|
|
if (onAbilityCB == nullptr) {
|
|
HILOG_ERROR("%{public}s, uv_queue_work onAbilityCB == nullptr.", __func__);
|
|
return;
|
|
}
|
|
napi_value result[ARGS_TWO] = {0};
|
|
result[PARAM0] = GetCallbackErrorValue(onAbilityCB->cb.env, onAbilityCB->cb.errCode);
|
|
|
|
napi_create_object(onAbilityCB->cb.env, &result[PARAM1]);
|
|
// create resultCode
|
|
napi_value jsValue = 0;
|
|
napi_create_int32(onAbilityCB->cb.env, onAbilityCB->resultCode, &jsValue);
|
|
napi_set_named_property(onAbilityCB->cb.env, result[PARAM1], "resultCode", jsValue);
|
|
// create want
|
|
napi_value jsWant = WrapWant(onAbilityCB->cb.env, onAbilityCB->resultData);
|
|
napi_set_named_property(onAbilityCB->cb.env, result[PARAM1], "want", jsWant);
|
|
|
|
if (onAbilityCB->cb.callback != nullptr) {
|
|
// asynccallback
|
|
HILOG_INFO("CallOnAbilityResult, asynccallback");
|
|
napi_value callback = 0;
|
|
napi_value undefined = 0;
|
|
napi_get_undefined(onAbilityCB->cb.env, &undefined);
|
|
napi_value callResult = 0;
|
|
napi_get_reference_value(onAbilityCB->cb.env, onAbilityCB->cb.callback, &callback);
|
|
|
|
napi_call_function(onAbilityCB->cb.env, undefined, callback, ARGS_TWO, &result[PARAM0], &callResult);
|
|
if (onAbilityCB->cb.callback != nullptr) {
|
|
napi_delete_reference(onAbilityCB->cb.env, onAbilityCB->cb.callback);
|
|
}
|
|
HILOG_INFO("CallOnAbilityResult, asynccallback end");
|
|
} else {
|
|
// promise
|
|
HILOG_INFO("CallOnAbilityResult, promise");
|
|
napi_resolve_deferred(onAbilityCB->cb.env, onAbilityCB->cb.deferred, result[PARAM1]);
|
|
HILOG_INFO("CallOnAbilityResult, promise end");
|
|
}
|
|
|
|
delete onAbilityCB;
|
|
onAbilityCB = nullptr;
|
|
delete work;
|
|
work = nullptr;
|
|
HILOG_INFO("CallOnAbilityResult, uv_queue_work end");
|
|
});
|
|
|
|
if (rev != 0) {
|
|
if (onAbilityCB != nullptr) {
|
|
delete onAbilityCB;
|
|
onAbilityCB = nullptr;
|
|
}
|
|
if (work != nullptr) {
|
|
delete work;
|
|
work = nullptr;
|
|
}
|
|
}
|
|
HILOG_INFO("%{public}s,end", __func__);
|
|
}
|
|
EXTERN_C_END
|
|
|
|
bool InnerUnwrapWant(napi_env env, napi_value args, Want &want)
|
|
{
|
|
HILOG_INFO("%{public}s called", __func__);
|
|
napi_valuetype valueType = napi_undefined;
|
|
NAPI_CALL_BASE(env, napi_typeof(env, args, &valueType), false);
|
|
if (valueType != napi_object) {
|
|
HILOG_ERROR("%{public}s wrong argument type", __func__);
|
|
return false;
|
|
}
|
|
|
|
napi_value jsWant = GetPropertyValueByPropertyName(env, args, "want", napi_object);
|
|
if (jsWant == nullptr) {
|
|
HILOG_ERROR("%{public}s jsWant == nullptr", __func__);
|
|
return false;
|
|
}
|
|
|
|
return UnwrapWant(env, jsWant, want);
|
|
}
|
|
|
|
/**
|
|
* @brief Parse the parameters.
|
|
*
|
|
* @param param Indicates the parameters saved the parse result.
|
|
* @param env The environment that the Node-API call is invoked under.
|
|
* @param args Indicates the arguments passed into the callback.
|
|
*
|
|
* @return The return value from NAPI C++ to JS for the module.
|
|
*/
|
|
napi_value UnwrapForResultParam(CallAbilityParam ¶m, napi_env env, napi_value args)
|
|
{
|
|
HILOG_INFO("%{public}s,called", __func__);
|
|
// unwrap the param : want object
|
|
InnerUnwrapWant(env, args, param.want);
|
|
|
|
// dummy requestCode for NativeC++ interface and onabilityresult callback
|
|
param.requestCode = dummyRequestCode_;
|
|
param.forResultOption = true;
|
|
dummyRequestCode_ = (dummyRequestCode_ < INT64_MAX) ? (dummyRequestCode_ + 1) : 0;
|
|
HILOG_INFO("%{public}s, reqCode=%{public}d forResultOption=%{public}d.",
|
|
__func__,
|
|
param.requestCode,
|
|
param.forResultOption);
|
|
|
|
// unwrap the param : abilityStartSetting (optional)
|
|
napi_value jsSettingObj = GetPropertyValueByPropertyName(env, args, "abilityStartSetting", napi_object);
|
|
if (jsSettingObj != nullptr) {
|
|
param.setting = AbilityStartSetting::GetEmptySetting();
|
|
if (!UnwrapAbilityStartSetting(env, jsSettingObj, *(param.setting))) {
|
|
HILOG_ERROR("%{public}s, unwrap abilityStartSetting failed.", __func__);
|
|
}
|
|
HILOG_INFO("%{public}s abilityStartSetting", __func__);
|
|
}
|
|
|
|
napi_value result;
|
|
NAPI_CALL(env, napi_create_int32(env, 1, &result));
|
|
HILOG_INFO("%{public}s,end", __func__);
|
|
return result;
|
|
}
|
|
|
|
/**
|
|
* @brief Parse the abilityResult parameters.
|
|
*
|
|
* @param param Indicates the want parameters saved the parse result.
|
|
* @param env The environment that the Node-API call is invoked under.
|
|
* @param args Indicates the arguments passed into the callback.
|
|
*
|
|
* @return The return value from NAPI C++ to JS for the module.
|
|
*/
|
|
napi_value UnwrapAbilityResult(CallAbilityParam ¶m, napi_env env, napi_value args)
|
|
{
|
|
HILOG_INFO("%{public}s,called", __func__);
|
|
// unwrap the param
|
|
napi_valuetype valueType = napi_undefined;
|
|
NAPI_CALL(env, napi_typeof(env, args, &valueType));
|
|
NAPI_ASSERT(env, valueType == napi_object, "param type mismatch!");
|
|
// get resultCode property
|
|
napi_value property = nullptr;
|
|
NAPI_CALL(env, napi_get_named_property(env, args, "resultCode", &property));
|
|
NAPI_CALL(env, napi_typeof(env, property, &valueType));
|
|
NAPI_ASSERT(env, valueType == napi_number, "property type mismatch!");
|
|
NAPI_CALL(env, napi_get_value_int32(env, property, ¶m.requestCode));
|
|
HILOG_INFO("%{public}s, requestCode=%{public}d.", __func__, param.requestCode);
|
|
|
|
// unwrap the param : want object
|
|
InnerUnwrapWant(env, args, param.want);
|
|
|
|
napi_value result;
|
|
NAPI_CALL(env, napi_create_int32(env, 1, &result));
|
|
HILOG_INFO("%{public}s,end", __func__);
|
|
return result;
|
|
}
|
|
|
|
/**
|
|
* @brief GetWantSyncWrap processing function.
|
|
*
|
|
* @param env The environment that the Node-API call is invoked under.
|
|
* @param CallingBundleCB Process data asynchronously.
|
|
*
|
|
* @return Return JS data successfully, otherwise return nullptr.
|
|
*/
|
|
napi_value GetWantSyncWrap(napi_env env, napi_callback_info info, AsyncCallbackInfo *asyncCallbackInfo)
|
|
{
|
|
HILOG_INFO("%{public}s, called.", __func__);
|
|
if (asyncCallbackInfo == nullptr) {
|
|
HILOG_ERROR("%{public}s, asyncCallbackInfo == nullptr.", __func__);
|
|
return nullptr;
|
|
}
|
|
|
|
asyncCallbackInfo->errCode = NAPI_ERR_NO_ERROR;
|
|
if (asyncCallbackInfo->ability == nullptr) {
|
|
HILOG_ERROR("%{public}s, ability == nullptr", __func__);
|
|
asyncCallbackInfo->errCode = NAPI_ERR_ACE_ABILITY;
|
|
return nullptr;
|
|
}
|
|
|
|
std::shared_ptr<AAFwk::Want> ptrWant = asyncCallbackInfo->ability->GetWant();
|
|
if (ptrWant != nullptr) {
|
|
asyncCallbackInfo->param.want = *ptrWant;
|
|
} else {
|
|
asyncCallbackInfo->errCode = NAPI_ERR_ABILITY_CALL_INVALID;
|
|
}
|
|
|
|
napi_value result = nullptr;
|
|
if (asyncCallbackInfo->errCode == NAPI_ERR_NO_ERROR) {
|
|
result = WrapWant(env, asyncCallbackInfo->param.want);
|
|
} else {
|
|
result = WrapVoidToJS(env);
|
|
}
|
|
HILOG_INFO("%{public}s, end.", __func__);
|
|
return result;
|
|
}
|
|
|
|
/**
|
|
* @brief Get want(Sync).
|
|
*
|
|
* @param env The environment that the Node-API call is invoked under.
|
|
* @param info The callback info passed into the callback function.
|
|
*
|
|
* @return The return value from NAPI C++ to JS for the module.
|
|
*/
|
|
napi_value NAPI_GetWantSync(napi_env env, napi_callback_info info)
|
|
{
|
|
HILOG_INFO("%{public}s called.", __func__);
|
|
AsyncCallbackInfo *asyncCallbackInfo = CreateAsyncCallbackInfo(env);
|
|
if (asyncCallbackInfo == nullptr) {
|
|
return WrapVoidToJS(env);
|
|
}
|
|
|
|
asyncCallbackInfo->errCode = NAPI_ERR_NO_ERROR;
|
|
napi_value ret = GetWantSyncWrap(env, info, asyncCallbackInfo);
|
|
|
|
delete asyncCallbackInfo;
|
|
asyncCallbackInfo = nullptr;
|
|
|
|
if (ret == nullptr) {
|
|
ret = WrapVoidToJS(env);
|
|
HILOG_ERROR("%{public}s ret == nullptr", __func__);
|
|
} else {
|
|
HILOG_INFO("%{public}s, end.", __func__);
|
|
}
|
|
return ret;
|
|
}
|
|
|
|
/**
|
|
* @brief Get want.
|
|
*
|
|
* @param env The environment that the Node-API call is invoked under.
|
|
* @param info The callback info passed into the callback function.
|
|
*
|
|
* @return The return value from NAPI C++ to JS for the module.
|
|
*/
|
|
napi_value NAPI_GetWant(napi_env env, napi_callback_info info)
|
|
{
|
|
HILOG_INFO("%{public}s called.", __func__);
|
|
return NAPI_GetWantCommon(env, info, AbilityType::PAGE);
|
|
}
|
|
|
|
/**
|
|
* @brief Obtains the type of this application.
|
|
*
|
|
* @param env The environment that the Node-API call is invoked under.
|
|
* @param info The callback info passed into the callback function.
|
|
*
|
|
* @return The return value from NAPI C++ to JS for the module.
|
|
*/
|
|
napi_value NAPI_GetAppType(napi_env env, napi_callback_info info)
|
|
{
|
|
HILOG_INFO("%{public}s called.", __func__);
|
|
return NAPI_GetAppTypeCommon(env, info, AbilityType::PAGE);
|
|
}
|
|
|
|
/**
|
|
* @brief Obtains the class name in this ability name, without the prefixed bundle name.
|
|
*
|
|
* @param env The environment that the Node-API call is invoked under.
|
|
* @param info The callback info passed into the callback function.
|
|
*
|
|
* @return The return value from NAPI C++ to JS for the module.
|
|
*/
|
|
napi_value NAPI_GetAbilityName(napi_env env, napi_callback_info info)
|
|
{
|
|
HILOG_INFO("%{public}s called.", __func__);
|
|
return NAPI_GetAbilityNameCommon(env, info, AbilityType::PAGE);
|
|
}
|
|
|
|
/**
|
|
* @brief Obtains information about the current ability.
|
|
*
|
|
* @param env The environment that the Node-API call is invoked under.
|
|
* @param info The callback info passed into the callback function.
|
|
*
|
|
* @return The return value from NAPI C++ to JS for the module.
|
|
*/
|
|
napi_value NAPI_GetAbilityInfo(napi_env env, napi_callback_info info)
|
|
{
|
|
HILOG_INFO("%{public}s called.", __func__);
|
|
return NAPI_GetAbilityInfoCommon(env, info, AbilityType::PAGE);
|
|
}
|
|
|
|
/**
|
|
* @brief Obtains the HapModuleInfo object of the application.
|
|
*
|
|
* @param env The environment that the Node-API call is invoked under.
|
|
* @param info The callback info passed into the callback function.
|
|
*
|
|
* @return The return value from NAPI C++ to JS for the module.
|
|
*/
|
|
napi_value NAPI_GetHapModuleInfo(napi_env env, napi_callback_info info)
|
|
{
|
|
HILOG_INFO("%{public}s called.", __func__);
|
|
return NAPI_GetHapModuleInfoCommon(env, info, AbilityType::PAGE);
|
|
}
|
|
|
|
/**
|
|
* @brief FeatureAbility NAPI method : getDataAbilityHelper.
|
|
*
|
|
* @param env The environment that the Node-API call is invoked under.
|
|
* @param info The callback info passed into the callback function.
|
|
*
|
|
* @return The return value from NAPI C++ to JS for the module.
|
|
*/
|
|
napi_value NAPI_GetDataAbilityHelper(napi_env env, napi_callback_info info)
|
|
{
|
|
HILOG_INFO("%{public}s,called", __func__);
|
|
DataAbilityHelperCB *dataAbilityHelperCB = new (std::nothrow) DataAbilityHelperCB;
|
|
if (dataAbilityHelperCB == nullptr) {
|
|
HILOG_ERROR("%{public}s, dataAbilityHelperCB == nullptr", __func__);
|
|
return WrapVoidToJS(env);
|
|
}
|
|
dataAbilityHelperCB->cbBase.cbInfo.env = env;
|
|
napi_value ret = GetDataAbilityHelperWrap(env, info, dataAbilityHelperCB);
|
|
if (ret == nullptr) {
|
|
HILOG_ERROR("%{public}s, ret == nullptr", __func__);
|
|
if (dataAbilityHelperCB != nullptr) {
|
|
delete dataAbilityHelperCB;
|
|
dataAbilityHelperCB = nullptr;
|
|
}
|
|
ret = WrapVoidToJS(env);
|
|
}
|
|
HILOG_INFO("%{public}s,end", __func__);
|
|
return ret;
|
|
}
|
|
|
|
/**
|
|
* @brief getDataAbilityHelper processing function.
|
|
*
|
|
* @param env The environment that the Node-API call is invoked under.
|
|
* @param dataAbilityHelperCB Process data asynchronously.
|
|
*
|
|
* @return Return JS data successfully, otherwise return nullptr.
|
|
*/
|
|
napi_value GetDataAbilityHelperWrap(napi_env env, napi_callback_info info, DataAbilityHelperCB *dataAbilityHelperCB)
|
|
{
|
|
HILOG_INFO("%{public}s,called", __func__);
|
|
if (dataAbilityHelperCB == nullptr) {
|
|
HILOG_ERROR("%{public}s,dataAbilityHelperCB == nullptr", __func__);
|
|
return nullptr;
|
|
}
|
|
|
|
size_t argcAsync = 2;
|
|
const size_t argcPromise = 1;
|
|
const size_t argCountWithAsync = argcPromise + ARGS_ASYNC_COUNT;
|
|
napi_value args[ARGS_MAX_COUNT] = {nullptr};
|
|
napi_value ret = 0;
|
|
|
|
NAPI_CALL(env, napi_get_cb_info(env, info, &argcAsync, args, nullptr, nullptr));
|
|
if (argcAsync > argCountWithAsync || argcAsync > ARGS_MAX_COUNT) {
|
|
HILOG_ERROR("%{public}s, Wrong argument count.", __func__);
|
|
return nullptr;
|
|
}
|
|
|
|
napi_valuetype valuetype = napi_undefined;
|
|
NAPI_CALL(env, napi_typeof(env, args[PARAM0], &valuetype));
|
|
if (valuetype == napi_string) {
|
|
NAPI_CALL(env, napi_create_reference(env, args[PARAM0], 1, &dataAbilityHelperCB->uri));
|
|
}
|
|
|
|
if (argcAsync > argcPromise) {
|
|
ret = GetDataAbilityHelperAsync(env, args, 1, dataAbilityHelperCB);
|
|
} else {
|
|
ret = GetDataAbilityHelperPromise(env, dataAbilityHelperCB);
|
|
}
|
|
HILOG_INFO("%{public}s,end", __func__);
|
|
return ret;
|
|
}
|
|
|
|
napi_value GetDataAbilityHelperAsync(
|
|
napi_env env, napi_value *args, const size_t argCallback, DataAbilityHelperCB *dataAbilityHelperCB)
|
|
{
|
|
HILOG_INFO("%{public}s, asyncCallback.", __func__);
|
|
if (args == nullptr || dataAbilityHelperCB == nullptr) {
|
|
HILOG_ERROR("%{public}s, param == nullptr.", __func__);
|
|
return nullptr;
|
|
}
|
|
napi_value resourceName = 0;
|
|
NAPI_CALL(env, napi_create_string_latin1(env, __func__, NAPI_AUTO_LENGTH, &resourceName));
|
|
|
|
napi_valuetype valuetype = napi_undefined;
|
|
NAPI_CALL(env, napi_typeof(env, args[argCallback], &valuetype));
|
|
if (valuetype == napi_function) {
|
|
NAPI_CALL(env, napi_create_reference(env, args[argCallback], 1, &dataAbilityHelperCB->cbBase.cbInfo.callback));
|
|
}
|
|
|
|
NAPI_CALL(env,
|
|
napi_create_async_work(
|
|
env,
|
|
nullptr,
|
|
resourceName,
|
|
[](napi_env env, void *data) { HILOG_INFO("NAPI_GetDataAbilityHelper, worker pool thread execute."); },
|
|
GetDataAbilityHelperAsyncCompleteCB,
|
|
(void *)dataAbilityHelperCB,
|
|
&dataAbilityHelperCB->cbBase.asyncWork));
|
|
NAPI_CALL(env, napi_queue_async_work(env, dataAbilityHelperCB->cbBase.asyncWork));
|
|
napi_value result = 0;
|
|
NAPI_CALL(env, napi_get_null(env, &result));
|
|
HILOG_INFO("%{public}s, asyncCallback end", __func__);
|
|
return result;
|
|
}
|
|
|
|
napi_value GetDataAbilityHelperPromise(napi_env env, DataAbilityHelperCB *dataAbilityHelperCB)
|
|
{
|
|
HILOG_INFO("%{public}s, promise.", __func__);
|
|
if (dataAbilityHelperCB == nullptr) {
|
|
HILOG_ERROR("%{public}s, param == nullptr.", __func__);
|
|
return nullptr;
|
|
}
|
|
napi_value resourceName;
|
|
NAPI_CALL(env, napi_create_string_latin1(env, __func__, NAPI_AUTO_LENGTH, &resourceName));
|
|
napi_deferred deferred;
|
|
napi_value promise = 0;
|
|
NAPI_CALL(env, napi_create_promise(env, &deferred, &promise));
|
|
dataAbilityHelperCB->cbBase.deferred = deferred;
|
|
|
|
NAPI_CALL(env,
|
|
napi_create_async_work(
|
|
env,
|
|
nullptr,
|
|
resourceName,
|
|
[](napi_env env, void *data) { HILOG_INFO("NAPI_GetDataAbilityHelper, worker pool thread execute."); },
|
|
GetDataAbilityHelperPromiseCompleteCB,
|
|
(void *)dataAbilityHelperCB,
|
|
&dataAbilityHelperCB->cbBase.asyncWork));
|
|
NAPI_CALL(env, napi_queue_async_work(env, dataAbilityHelperCB->cbBase.asyncWork));
|
|
HILOG_INFO("%{public}s, promise end.", __func__);
|
|
return promise;
|
|
}
|
|
|
|
void GetDataAbilityHelperAsyncCompleteCB(napi_env env, napi_status status, void *data)
|
|
{
|
|
HILOG_INFO("NAPI_GetDataAbilityHelper, main event thread complete.");
|
|
DataAbilityHelperCB *dataAbilityHelperCB = static_cast<DataAbilityHelperCB *>(data);
|
|
std::unique_ptr<DataAbilityHelperCB> callbackPtr {dataAbilityHelperCB};
|
|
napi_value uri = nullptr;
|
|
napi_value callback = nullptr;
|
|
napi_value undefined = nullptr;
|
|
napi_value result[ARGS_TWO] = {nullptr};
|
|
napi_value callResult = nullptr;
|
|
napi_get_undefined(env, &undefined);
|
|
napi_get_reference_value(env, dataAbilityHelperCB->uri, &uri);
|
|
napi_get_reference_value(env, dataAbilityHelperCB->cbBase.cbInfo.callback, &callback);
|
|
napi_new_instance(env, GetGlobalDataAbilityHelper(env), 1, &uri, &dataAbilityHelperCB->result);
|
|
if (IsTypeForNapiValue(env, dataAbilityHelperCB->result, napi_object)) {
|
|
result[PARAM1] = dataAbilityHelperCB->result;
|
|
} else {
|
|
HILOG_INFO("NAPI_GetDataAbilityHelper, helper is nullptr.");
|
|
result[PARAM1] = WrapVoidToJS(env);
|
|
}
|
|
result[PARAM0] = GetCallbackErrorValue(env, NO_ERROR);
|
|
napi_call_function(env, undefined, callback, ARGS_TWO, &result[PARAM0], &callResult);
|
|
if (dataAbilityHelperCB->cbBase.cbInfo.callback != nullptr) {
|
|
napi_delete_reference(env, dataAbilityHelperCB->cbBase.cbInfo.callback);
|
|
}
|
|
if (dataAbilityHelperCB->uri != nullptr) {
|
|
napi_delete_reference(env, dataAbilityHelperCB->uri);
|
|
}
|
|
napi_delete_async_work(env, dataAbilityHelperCB->cbBase.asyncWork);
|
|
HILOG_INFO("NAPI_GetDataAbilityHelper, main event thread complete end.");
|
|
}
|
|
|
|
void GetDataAbilityHelperPromiseCompleteCB(napi_env env, napi_status status, void *data)
|
|
{
|
|
HILOG_INFO("NAPI_GetDataAbilityHelper, main event thread complete.");
|
|
DataAbilityHelperCB *dataAbilityHelperCB = static_cast<DataAbilityHelperCB *>(data);
|
|
std::unique_ptr<DataAbilityHelperCB> callbackPtr {dataAbilityHelperCB};
|
|
napi_value uri = nullptr;
|
|
napi_value result = nullptr;
|
|
napi_get_reference_value(env, dataAbilityHelperCB->uri, &uri);
|
|
napi_new_instance(env, GetGlobalDataAbilityHelper(env), 1, &uri, &dataAbilityHelperCB->result);
|
|
if (IsTypeForNapiValue(env, dataAbilityHelperCB->result, napi_object)) {
|
|
result = dataAbilityHelperCB->result;
|
|
napi_resolve_deferred(env, dataAbilityHelperCB->cbBase.deferred, result);
|
|
} else {
|
|
result = GetCallbackErrorValue(env, dataAbilityHelperCB->cbBase.errCode);
|
|
napi_reject_deferred(env, dataAbilityHelperCB->cbBase.deferred, result);
|
|
HILOG_INFO("NAPI_GetDataAbilityHelper, helper is nullptr.");
|
|
}
|
|
|
|
if (dataAbilityHelperCB->uri != nullptr) {
|
|
napi_delete_reference(env, dataAbilityHelperCB->uri);
|
|
}
|
|
napi_delete_async_work(env, dataAbilityHelperCB->cbBase.asyncWork);
|
|
HILOG_INFO("NAPI_GetDataAbilityHelper, main event thread complete end.");
|
|
}
|
|
|
|
/**
|
|
* @brief FeatureAbility NAPI method : acquireDataAbilityHelper.
|
|
*
|
|
* @param env The environment that the Node-API call is invoked under.
|
|
* @param info The callback info passed into the callback function.
|
|
*
|
|
* @return The return value from NAPI C++ to JS for the module.
|
|
*/
|
|
napi_value NAPI_AcquireDataAbilityHelper(napi_env env, napi_callback_info info)
|
|
{
|
|
HILOG_INFO("%{public}s,called", __func__);
|
|
return NAPI_AcquireDataAbilityHelperCommon(env, info, AbilityType::PAGE);
|
|
}
|
|
|
|
/**
|
|
* @brief FeatureAbility NAPI method : connectAbility.
|
|
*
|
|
* @param env The environment that the Node-API call is invoked under.
|
|
* @param info The callback info passed into the callback function.
|
|
*
|
|
* @return The return value from NAPI C++ to JS for the module.
|
|
*/
|
|
napi_value NAPI_FAConnectAbility(napi_env env, napi_callback_info info)
|
|
{
|
|
HITRACE_METER_NAME(HITRACE_TAG_ABILITY_MANAGER, __PRETTY_FUNCTION__);
|
|
HILOG_INFO("FA connect ability called.");
|
|
return NAPI_ConnectAbilityCommon(env, info, AbilityType::PAGE);
|
|
}
|
|
|
|
/**
|
|
* @brief FeatureAbility NAPI method : disConnectAbility.
|
|
*
|
|
* @param env The environment that the Node-API call is invoked under.
|
|
* @param info The callback info passed into the callback function.
|
|
*
|
|
* @return The return value from NAPI C++ to JS for the module.
|
|
*/
|
|
napi_value NAPI_FADisConnectAbility(napi_env env, napi_callback_info info)
|
|
{
|
|
HITRACE_METER_NAME(HITRACE_TAG_ABILITY_MANAGER, __PRETTY_FUNCTION__);
|
|
HILOG_INFO("FA disconnect ability called.");
|
|
return NAPI_DisConnectAbilityCommon(env, info, AbilityType::PAGE);
|
|
}
|
|
|
|
/**
|
|
* @brief FeatureAbility NAPI method : continueAbility.
|
|
*
|
|
* @param env The environment that the Node-API call is invoked under.
|
|
* @param info The callback info passed into the callback function.
|
|
*
|
|
* @return The return value from NAPI C++ to JS for the module.
|
|
*/
|
|
napi_value NAPI_FAContinueAbility(napi_env env, napi_callback_info info)
|
|
{
|
|
HILOG_INFO("%{public}s,called", __func__);
|
|
AsyncCallbackInfo *asyncCallbackInfo = CreateAsyncCallbackInfo(env);
|
|
if (asyncCallbackInfo == nullptr) {
|
|
HILOG_ERROR("%{public}s, asyncCallbackInfo == nullptr.", __func__);
|
|
return WrapVoidToJS(env);
|
|
}
|
|
|
|
napi_value ret = ContinueAbilityWrap(env, info, asyncCallbackInfo);
|
|
if (ret == nullptr) {
|
|
if (asyncCallbackInfo != nullptr) {
|
|
delete asyncCallbackInfo;
|
|
asyncCallbackInfo = nullptr;
|
|
}
|
|
ret = WrapVoidToJS(env);
|
|
}
|
|
HILOG_INFO("%{public}s,end.", __func__);
|
|
return ret;
|
|
}
|
|
|
|
/**
|
|
* @brief ContinueAbilityWrap processing function.
|
|
*
|
|
* @param env The environment that the Node-API call is invoked under.
|
|
* @param asyncCallbackInfo Process data asynchronously.
|
|
*
|
|
* @return Return JS data successfully, otherwise return nullptr.
|
|
*/
|
|
napi_value ContinueAbilityWrap(napi_env env, napi_callback_info info, AsyncCallbackInfo *asyncCallbackInfo)
|
|
{
|
|
HILOG_INFO("%{public}s, called.", __func__);
|
|
size_t argc = 2;
|
|
napi_value args[ARGS_MAX_COUNT] = {nullptr};
|
|
napi_value ret = 0;
|
|
napi_valuetype valueType = napi_undefined;
|
|
|
|
NAPI_CALL(env, napi_get_cb_info(env, info, &argc, args, nullptr, nullptr));
|
|
NAPI_CALL(env, napi_typeof(env, args[0], &valueType));
|
|
if (valueType != napi_object && valueType != napi_function) {
|
|
HILOG_ERROR("%{public}s, Wrong argument type. Object or function expected.", __func__);
|
|
return nullptr;
|
|
}
|
|
if (argc == 0) {
|
|
ret = ContinueAbilityPromise(env, args, asyncCallbackInfo, argc);
|
|
} else if (PARA_SIZE_IS_ONE == argc) {
|
|
if (valueType == napi_function) {
|
|
ret = ContinueAbilityAsync(env, args, asyncCallbackInfo, argc);
|
|
} else {
|
|
ret = ContinueAbilityPromise(env, args, asyncCallbackInfo, argc);
|
|
}
|
|
} else if (PARA_SIZE_IS_TWO == argc) {
|
|
napi_valuetype value = napi_undefined;
|
|
NAPI_CALL(env, napi_typeof(env, args[1], &value));
|
|
if (value != napi_function) {
|
|
HILOG_ERROR("%{public}s, Wrong argument type. function expected.", __func__);
|
|
return nullptr;
|
|
}
|
|
ret = ContinueAbilityAsync(env, args, asyncCallbackInfo, argc);
|
|
} else {
|
|
HILOG_ERROR("%{public}s, Wrong argument count.", __func__);
|
|
}
|
|
HILOG_INFO("%{public}s,end.", __func__);
|
|
return ret;
|
|
}
|
|
|
|
napi_value ContinueAbilityAsync(napi_env env, napi_value *args, AsyncCallbackInfo *asyncCallbackInfo, size_t argc)
|
|
{
|
|
HILOG_INFO("%{public}s, asyncCallback.", __func__);
|
|
if (args == nullptr || asyncCallbackInfo == nullptr) {
|
|
HILOG_ERROR("%{public}s, param == nullptr.", __func__);
|
|
return nullptr;
|
|
}
|
|
napi_value resourceName = 0;
|
|
napi_create_string_latin1(env, __func__, NAPI_AUTO_LENGTH, &resourceName);
|
|
|
|
if (PARA_SIZE_IS_TWO == argc) {
|
|
// args[0] : ContinueAbilityOptions
|
|
napi_valuetype valueTypeOptions = napi_undefined;
|
|
NAPI_CALL(env, napi_typeof(env, args[0], &valueTypeOptions));
|
|
if (valueTypeOptions != napi_object) {
|
|
HILOG_ERROR("%{public}s, Wrong argument type. Object expected.", __func__);
|
|
return nullptr;
|
|
}
|
|
if (GetContinueAbilityOptionsInfoCommon(env, args[0], asyncCallbackInfo->optionInfo) == nullptr) {
|
|
HILOG_ERROR("%{public}s, GetContinueAbilityOptionsInfoCommonFail", __func__);
|
|
return nullptr;
|
|
}
|
|
|
|
// args[1] : callback
|
|
napi_valuetype valueTypeCallBack = napi_undefined;
|
|
napi_typeof(env, args[1], &valueTypeCallBack);
|
|
if (valueTypeCallBack == napi_function) {
|
|
napi_create_reference(env, args[1], 1, &asyncCallbackInfo->cbInfo.callback);
|
|
}
|
|
} else {
|
|
// args[0] : callback
|
|
napi_valuetype valueTypeCallBack = napi_undefined;
|
|
napi_typeof(env, args[1], &valueTypeCallBack);
|
|
if (valueTypeCallBack == napi_function) {
|
|
napi_create_reference(env, args[0], 1, &asyncCallbackInfo->cbInfo.callback);
|
|
}
|
|
}
|
|
|
|
napi_create_async_work(
|
|
env,
|
|
nullptr,
|
|
resourceName,
|
|
[](napi_env env, void *data) {
|
|
HILOG_INFO("NAPI_ContinueAbility, worker pool thread execute.");
|
|
AsyncCallbackInfo *asyncCallbackInfo = (AsyncCallbackInfo *)data;
|
|
if (asyncCallbackInfo->ability != nullptr) {
|
|
asyncCallbackInfo->ability->ContinueAbility(asyncCallbackInfo->optionInfo.deviceId);
|
|
} else {
|
|
HILOG_ERROR("NAPI_ContinueAbilityForResult, asyncCallbackInfo == nullptr");
|
|
}
|
|
HILOG_INFO("NAPI_ContinueAbilityForResult, worker pool thread execute end.");
|
|
},
|
|
[](napi_env env, napi_status status, void *data) {
|
|
HILOG_INFO("NAPI_ContinueAbility, main event thread complete.");
|
|
AsyncCallbackInfo *asyncCallbackInfo = (AsyncCallbackInfo *)data;
|
|
napi_value callback = 0;
|
|
napi_value undefined = 0;
|
|
napi_value result[ARGS_TWO] = {0};
|
|
napi_value callResult = 0;
|
|
napi_get_undefined(env, &undefined);
|
|
result[PARAM0] = GetCallbackErrorValue(env, NO_ERROR);
|
|
napi_get_null(env, &result[PARAM1]);
|
|
napi_get_reference_value(env, asyncCallbackInfo->cbInfo.callback, &callback);
|
|
napi_call_function(env, undefined, callback, ARGS_TWO, &result[PARAM0], &callResult);
|
|
|
|
if (asyncCallbackInfo->cbInfo.callback != nullptr) {
|
|
napi_delete_reference(env, asyncCallbackInfo->cbInfo.callback);
|
|
}
|
|
napi_delete_async_work(env, asyncCallbackInfo->asyncWork);
|
|
delete asyncCallbackInfo;
|
|
HILOG_INFO("NAPI_ContinueAbilityForResult, main event thread complete end.");
|
|
},
|
|
(void *)asyncCallbackInfo,
|
|
&asyncCallbackInfo->asyncWork);
|
|
napi_queue_async_work(env, asyncCallbackInfo->asyncWork);
|
|
napi_value result = 0;
|
|
napi_get_null(env, &result);
|
|
HILOG_INFO("%{public}s, asyncCallback end.", __func__);
|
|
return result;
|
|
}
|
|
|
|
napi_value ContinueAbilityPromise(napi_env env, napi_value *args, AsyncCallbackInfo *asyncCallbackInfo, size_t argc)
|
|
{
|
|
HILOG_INFO("%{public}s, promise.", __func__);
|
|
if (asyncCallbackInfo == nullptr) {
|
|
HILOG_ERROR("%{public}s, param == nullptr.", __func__);
|
|
return nullptr;
|
|
}
|
|
|
|
if (argc == PARA_SIZE_IS_ONE) {
|
|
// args[0] : ContinueAbilityOptions
|
|
napi_valuetype valueTypeOptions = napi_undefined;
|
|
NAPI_CALL(env, napi_typeof(env, args[0], &valueTypeOptions));
|
|
if (valueTypeOptions != napi_object) {
|
|
HILOG_ERROR("%{public}s, Wrong argument type. Object expected.", __func__);
|
|
return nullptr;
|
|
}
|
|
if (GetContinueAbilityOptionsInfoCommon(env, args[0], asyncCallbackInfo->optionInfo) == nullptr) {
|
|
return nullptr;
|
|
}
|
|
}
|
|
|
|
napi_value resourceName = 0;
|
|
napi_create_string_latin1(env, __func__, NAPI_AUTO_LENGTH, &resourceName);
|
|
napi_deferred deferred;
|
|
napi_value promise = 0;
|
|
napi_create_promise(env, &deferred, &promise);
|
|
|
|
asyncCallbackInfo->deferred = deferred;
|
|
|
|
napi_create_async_work(
|
|
env, nullptr, resourceName,
|
|
[](napi_env env, void *data) {
|
|
HILOG_INFO("NAPI_ContinueAbility, worker pool thread execute.");
|
|
AsyncCallbackInfo *asyncCallbackInfo = (AsyncCallbackInfo *)data;
|
|
if (asyncCallbackInfo->ability != nullptr) {
|
|
asyncCallbackInfo->ability->ContinueAbility(asyncCallbackInfo->optionInfo.deviceId);
|
|
} else {
|
|
HILOG_ERROR("NAPI_ContinueAbilityForResult, asyncCallbackInfo == nullptr");
|
|
}
|
|
HILOG_INFO("NAPI_ContinueAbilityForResult, worker pool thread execute end.");
|
|
},
|
|
[](napi_env env, napi_status status, void *data) {
|
|
HILOG_INFO("NAPI_ContinueAbility, main event thread complete.");
|
|
AsyncCallbackInfo *asyncCallbackInfo = (AsyncCallbackInfo *)data;
|
|
napi_value result = 0;
|
|
napi_get_null(env, &result);
|
|
napi_resolve_deferred(env, asyncCallbackInfo->deferred, result);
|
|
napi_delete_async_work(env, asyncCallbackInfo->asyncWork);
|
|
delete asyncCallbackInfo;
|
|
HILOG_INFO("NAPI_ContinueAbilityForResult, main event thread complete end.");
|
|
},
|
|
(void *)asyncCallbackInfo, &asyncCallbackInfo->asyncWork);
|
|
napi_queue_async_work(env, asyncCallbackInfo->asyncWork);
|
|
HILOG_INFO("%{public}s, promise end.", __func__);
|
|
return promise;
|
|
}
|
|
} // namespace AppExecFwk
|
|
} // namespace OHOS
|