HarmonyOS鸿蒙Next中js对象传递到native侧并实现callback回调，是否有相应的示例？

native侧实现

NativeBase::m_nativeBase;

napi_value NativeBase::jsSetListener(napi_env env, napi_callback_info info) {

    OH_LOG_INFO(LOG_APP, "JS_SetListener call begin");

    size_t argc = 1;

    napi_value argv[1] = {NULL};

    napi_status status = napi_get_cb_info(env, info, &argc, argv, NULL, NULL);

    if (status != napi_ok)
        return nullptr;

    napi_value listener = argv[0];

    status = napi_create_reference(env, listener, 1, &NativeBase::GetInstance()->js_onProgressChangedListener);

    if (status != napi_ok)
        return nullptr;

    OH_LOG_INFO(LOG_APP, "JS_SetListener call end");

    return nullptr;
}

static void CallJs(napi_env env, napi_value js_cb, void *context, void *data) {

    OH_LOG_INFO(LOG_APP, "CallJs begin");

    napi_value listener = nullptr;

    napi_status status = napi_get_reference_value(env, NativeBase::GetInstance()->js_onProgressChangedListener, &listener);

    if (status != napi_ok) {
        return;
    }

    napi_value js_callback = nullptr;

    status = napi_get_named_property(env, listener, "onProgressChanged", &js_callback);

    if (status != napi_ok)
        return;

    ThreadData *prop = (ThreadData *)data;

    napi_value progress[1];
    napi_create_int32(env, prop->progress * 10, &progress[0]);
    napi_value result = nullptr;
    status = napi_call_function(env, NULL, js_callback, 1, progress, &result);

    if (status != napi_ok) {
        return;
    }

    OH_LOG_INFO(LOG_APP, "CallJs end");
}

napi_value NativeBase::jsExecuteTask(napi_env env, napi_callback_info info) {

    OH_LOG_INFO(LOG_APP, "jsExecuteTask begin");

    if (NativeBase::GetInstance()->js_onProgressChangedListener == nullptr) {
        OH_LOG_ERROR(LOG_APP, "jsExecuteTask js_onProgressChangedListener is null");
        return nullptr;
    }

    size_t argc = 1;

    napi_value jsCb = nullptr;
    napi_get_cb_info(env, info, &argc, &jsCb, nullptr, nullptr);

    // 创建一个线程安全函数
    napi_value resourceName = nullptr;
    napi_create_string_utf8(env, "Thread-safe Function Demo", NAPI_AUTO_LENGTH, &resourceName);
    napi_status status =
        napi_create_threadsafe_function(env, NULL, NULL, resourceName, 0, 1, NULL, NULL, NULL, CallJs, &NativeBase::GetInstance()->tsfn);

    if (status != napi_ok) {
        return nullptr;
    }

    std::thread t({
        OH_LOG_INFO(LOG_APP, "thread begin");

        int32_t num = 0;

        while (num < 10) {
            num++;
            std::this_thread::sleep_for(std::chrono::milliseconds(2000));
            OH_LOG_INFO(LOG_APP, "threadFunc: %s", "耗时2s");
            ThreadData *data = new ThreadData();
            data->progress = num;
            napi_call_threadsafe_function(NativeBase::GetInstance()->tsfn, data, napi_tsfn_nonblocking);
        }

        OH_LOG_INFO(LOG_APP, "thread end");
    });

    t.detach();

    OH_LOG_INFO(LOG_APP, "jsExecuteTask end");

    return nullptr;
}

napi_value NativeBase::jsReleaseListener(napi_env env, napi_callback_info info) {

    OH_LOG_INFO(LOG_APP, "jsReleaseListener");

    NativeBase::GetInstance()->js_onProgressChangedListener = nullptr;

    return nullptr;
}

头文件定义

struct ThreadData {
    int32_t progress;
};

class NativeBase {

public:
    static NativeBase *GetInstance() { return &NativeBase::m_nativeBase; }

    void Export(napi_env env, napi_value exports);
    static napi_value jsSetListener(napi_env env, napi_callback_info info);
    static napi_value jsExecuteTask(napi_env env, napi_callback_info info);
    static napi_value jsReleaseListener(napi_env env, napi_callback_info info);
    static napi_value nativetoJs(napi_env env);

public:
    static NativeBase m_nativeBase;
    std::string m_id;

public:
    napi_ref js_onProgressChangedListener;
    napi_threadsafe_function tsfn;
};

index.d.ts导出

// TS注册对象到native侧
export const setListener: (listener: object) => void;

// native执行耗时业务，并将结果传递给ts侧
export const executeTask: () => void;

// 销毁注册的对象
export const releaseListener: () => void;

ets侧用于回调的接口

private mListener: onProgressChangedListener = {
    onProgressChanged: (progress: number) => {
        log.info(`onProgressChanged: ${progress}`);
    }
};