OpenHarmony-v5.1.0-Release/s

/*
 * Copyright (c) 2024 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 "js_systemload.h"

#include <functional>

#include "js_napi_utils.h"
#include "res_sched_client.h"
#include "res_sched_log.h"

namespace OHOS {
namespace ResourceSchedule {
static constexpr size_t ARG_COUNT_ONE = 1;
static constexpr size_t ARG_COUNT_TWO = 2;
static const std::string SYSTEMLOAD_LEVEL = "systemLoadChange";


Systemload& Systemload::GetInstance()
{
    static Systemload systemload;
    return systemload;
}

Systemload::~Systemload()
{
    std::lock_guard<std::mutex> autoLock(jsCallbackMapLock_);
    jsCallBackMap_.clear();
}

napi_value Systemload::SystemloadOn(napi_env env, napi_callback_info info)
{
    return GetInstance().RegisterSystemloadCallback(env, info);
}

napi_value Systemload::SystemloadOff(napi_env env, napi_callback_info info)
{
    return GetInstance().UnRegisterSystemloadCallback(env, info);
}

napi_value Systemload::GetLevel(napi_env env, napi_callback_info info)
{
    return GetInstance().GetSystemloadLevel(env, info);
}

void Systemload::OnSystemloadLevel(napi_env env, napi_value callbackObj, int32_t level)
{
    RESSCHED_LOGI("OnSystemloadLevel asyncCallback.");
    std::lock_guard<std::mutex> autoLock(jsCallbackMapLock_);
    if (jsCallBackMap_.find(SYSTEMLOAD_LEVEL) == jsCallBackMap_.end()) {
        RESSCHED_LOGE("OnSystemloadLevel cb type has not register yet.");
        return;
    }
    auto& callbackList = jsCallBackMap_[SYSTEMLOAD_LEVEL];
    auto iter = callbackList.begin();
    bool isEqual = false;
    for (; iter != callbackList.end(); iter++) {
        NAPI_CALL_RETURN_VOID(env, napi_strict_equals(env, callbackObj, iter->first->GetNapiValue(), &isEqual));
        if (isEqual) {
            break;
        }
    }
    if (!isEqual) {
        RESSCHED_LOGE("OnSystemload level callback not found in registered array.");
        return;
    }
    std::unique_ptr<SystemloadLevelCbInfo> cbInfo = std::make_unique<SystemloadLevelCbInfo>(env);
    if (cbInfo == nullptr) {
        RESSCHED_LOGE("OnSystemloadLevel cbInfo null.");
        return;
    }
    cbInfo->result = level;
    napi_value resourceName = nullptr;
    NAPI_CALL_RETURN_VOID(env,
        napi_create_string_latin1(env, "OnSystemloadLevel", NAPI_AUTO_LENGTH, &resourceName));

    NAPI_CALL_RETURN_VOID(env,
        napi_create_reference(env, iter->first->GetNapiValue(), 1, &cbInfo->callback));

    SystemloadLevelCbInfo* ctx = cbInfo.get();
    auto task = [env, ctx]() {
        Systemload::CompleteCb(env, ctx);
    };
    if (napi_status::napi_ok != napi_send_event(env, task, napi_eprio_high)) {
        RESSCHED_LOGE("failed to napi_send_event");
        return;
    }
    cbInfo.release();
    napi_value result = nullptr;
    NAPI_CALL_RETURN_VOID(env, napi_get_null(env, &result));
    RESSCHED_LOGI("OnSystemloadLevel asyncCallback end");
}

napi_value Systemload::RegisterSystemloadCallback(napi_env env, napi_callback_info info)
{
    RESSCHED_LOGD("Regster Systemload Callback");
    std::string cbType;
    napi_value jsCallback = nullptr;

    if (!CheckCallbackParam(env, info, cbType, &jsCallback)) {
        RESSCHED_LOGE("Register Systemload Callback parameter error.");
        return CreateJsUndefined(env);
    }

    napi_ref tempRef = nullptr;
    napi_create_reference(env, jsCallback, 1, &tempRef);
    std::unique_ptr<NativeReference> callbackRef;
    callbackRef.reset(reinterpret_cast<NativeReference*>(tempRef));
    std::lock_guard<std::mutex> autoLock(jsCallbackMapLock_);
    if (jsCallBackMap_.find(cbType) == jsCallBackMap_.end()) {
        jsCallBackMap_[cbType] = std::list<CallBackPair>();
    }
    auto& callbackList = jsCallBackMap_[cbType];
    auto iter = callbackList.begin();
    for (; iter != callbackList.end(); iter++) {
        bool isEqual = false;
        napi_strict_equals(env, jsCallback, iter->first->GetNapiValue(), &isEqual);
        if (isEqual) {
            RESSCHED_LOGW("Register a exist callback type.");
            return CreateJsUndefined(env);
        }
    }
    auto systemloadLevelCb = [](napi_env env, napi_value callbackObj, int32_t level) {
        Systemload::GetInstance().OnSystemloadLevel(env, callbackObj, level);
    };
    sptr<SystemloadListener> systemloadListener =
        new (std::nothrow) SystemloadListener(env, jsCallback, systemloadLevelCb);
    if (systemloadListener == nullptr) {
        RESSCHED_LOGE("Register Systemload listener nullptr.");
        return CreateJsUndefined(env);
    }
    ResSchedClient::GetInstance().RegisterSystemloadNotifier(systemloadListener);
    callbackList.emplace_back(std::move(callbackRef), systemloadListener);
    return CreateJsUndefined(env);
}

napi_value Systemload::UnRegisterSystemloadCallback(napi_env env, napi_callback_info info)
{
    RESSCHED_LOGD("UnRegster Systemload Callback");
    std::string cbType;
    napi_value jsCallback = nullptr;

    if (!CheckCallbackParam(env, info, cbType, &jsCallback)) {
        RESSCHED_LOGE("UnRegister Systemload Callback parameter error.");
        return CreateJsUndefined(env);
    }

    std::lock_guard<std::mutex> autoLock(jsCallbackMapLock_);
    if (jsCallBackMap_.find(cbType) == jsCallBackMap_.end()) {
        RESSCHED_LOGE("unRegister cbType has not registered");
        return CreateJsUndefined(env);
    }
    auto& callbackList = jsCallBackMap_[cbType];
    for (auto iter = callbackList.begin(); iter != callbackList.end(); iter++) {
        bool isEqual = false;
        napi_strict_equals(env, jsCallback, iter->first->GetNapiValue(), &isEqual);
        if (isEqual) {
            ResSchedClient::GetInstance().UnRegisterSystemloadNotifier(iter->second);
            callbackList.erase(iter);
            break;
        }
    }
    return CreateJsUndefined(env);
}

napi_value Systemload::GetSystemloadLevel(napi_env env, napi_callback_info info)
{
    RESSCHED_LOGI("GetSystemloadLevel, promise.");
    std::unique_ptr<SystemloadLevelCbInfo> cbInfo = std::make_unique<SystemloadLevelCbInfo>(env);
    if (cbInfo == nullptr) {
        return CreateJsUndefined(env);
    }
    napi_value resourceName;
    NAPI_CALL(env, napi_create_string_latin1(env, "GetSystemloadLevel", NAPI_AUTO_LENGTH, &resourceName));
    napi_deferred deferred;
    napi_value promise = nullptr;
    NAPI_CALL(env, napi_create_promise(env, &deferred, &promise));
    cbInfo->deferred = deferred;

    NAPI_CALL(env, napi_create_async_work(env, nullptr, resourceName,
        Execute,
        Complete,
        static_cast<void *>(cbInfo.get()),
        &cbInfo->asyncWork));
    NAPI_CALL(env, napi_queue_async_work(env, cbInfo->asyncWork));
    cbInfo.release();
    RESSCHED_LOGI("GetSystemloadLevel, promise end");
    return promise;
}

void Systemload::Execute(napi_env env, void* data)
{
    RESSCHED_LOGI("GetSystemloadLevel, worker pool thread execute.");
    auto* cbInfo = static_cast<SystemloadLevelCbInfo*>(data);
    if (cbInfo == nullptr) {
        RESSCHED_LOGW("GetSystemloadLevel execute cb info is nullptr.");
        return;
    }
    cbInfo->result = ResSchedClient::GetInstance().GetSystemloadLevel();
    RESSCHED_LOGI("GetSystemloadLevel, worker pool thread execute end.");
}

void Systemload::Complete(napi_env env, napi_status status, void* data)
{
    RESSCHED_LOGI("GetSystemloadLevel, main event thread complete.");
    auto* info = static_cast<SystemloadLevelCbInfo*>(data);
    if (info == nullptr) {
        RESSCHED_LOGW("GetSystemloadLevel Complete cb info is nullptr.");
        return;
    }
    std::unique_ptr<SystemloadLevelCbInfo> cbInfo(info);
    napi_value result = nullptr;
    napi_create_uint32(env, static_cast<uint32_t>(cbInfo->result), &result);
    NAPI_CALL_RETURN_VOID(env, napi_resolve_deferred(env, cbInfo->deferred, result));
    NAPI_CALL_RETURN_VOID(env, napi_delete_async_work(env, cbInfo->asyncWork));
    cbInfo->asyncWork = nullptr;
    RESSCHED_LOGI("GetSystemloadLevel,  main event thread complete end.");
}

void Systemload::CompleteCb(napi_env env, SystemloadLevelCbInfo* info)
{
    RESSCHED_LOGI("CompleteCb, main event thread complete callback.");
    if (info == nullptr) {
        RESSCHED_LOGW("Complete cb info is nullptr.");
        return;
    }
    std::unique_ptr<SystemloadLevelCbInfo> cbInfo(info);
    napi_value callback = nullptr;
    napi_value undefined = nullptr;
    napi_value result = nullptr;
    napi_value callResult = nullptr;
    NAPI_CALL_RETURN_VOID(env, napi_get_undefined(env, &undefined));
    NAPI_CALL_RETURN_VOID(env, napi_get_reference_value(env, cbInfo->callback, &callback));
    napi_create_uint32(env, static_cast<uint32_t>(cbInfo->result), &result);
    // call js callback
    NAPI_CALL_RETURN_VOID(env, napi_call_function(env, undefined, callback, 1, &result, &callResult));
    if (cbInfo->callback != nullptr) {
        NAPI_CALL_RETURN_VOID(env, napi_delete_reference(env, cbInfo->callback));
        cbInfo->callback = nullptr;
    }
    RESSCHED_LOGI("CompleteCb, main event thread complete end.");
}

bool Systemload::CheckCallbackParam(napi_env env, napi_callback_info info,
                                    std::string &cbType, napi_value *jsCallback)
{
    if (jsCallback == nullptr) {
        RESSCHED_LOGE("Input callback is nullptr.");
        return false;
    }
    size_t argc = ARG_COUNT_TWO;
    napi_value argv[ARG_COUNT_TWO] = { 0 };
    NAPI_CALL_BASE(env, napi_get_cb_info(env, info, &argc, argv, nullptr, nullptr), false);
    if (argc != ARG_COUNT_TWO) {
        RESSCHED_LOGE("Parameter error. The type of \"number of parameters\" must be 2");
        return false;
    }
    if (!ConvertFromJsValue(env, argv[0], cbType)) {
        RESSCHED_LOGE("Parameter error. The type of \"type\" must be string");
        return false;
    }

    *jsCallback = argv[ARG_COUNT_ONE];
    if (*jsCallback == nullptr) {
        RESSCHED_LOGE("listenerObj is nullptr");
        return false;
    }
    bool isCallable = false;
    napi_is_callable(env, *jsCallback, &isCallable);
    if (!isCallable) {
        RESSCHED_LOGE("Parameter error. The type of \"callback\" must be Callback");
        return false;
    }
    return true;
}
} // ResourceSchedule
} // OHOS