1 /*
2 * Copyright (c) 2023 Huawei Device Co., Ltd.
3 * Licensed under the Apache License, Version 2.0 (the "License");
4 * you may not use this file except in compliance with the License.
5 * You may obtain a copy of the License at
6 *
7 * http://www.apache.org/licenses/LICENSE-2.0
8 *
9 * Unless required by applicable law or agreed to in writing, software
10 * distributed under the License is distributed on an "AS IS" BASIS,
11 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12 * See the License for the specific language governing permissions and
13 * limitations under the License.
14 */
15
16 #include "napi_datashare_observer.h"
17
18 #include <memory>
19 #include <chrono>
20 #include <cinttypes>
21 #include "datashare_log.h"
22 #include "napi_datashare_values_bucket.h"
23
24 namespace OHOS {
25 namespace DataShare {
26 using namespace std::chrono;
NAPIInnerObserver(napi_env env,napi_value callback)27 NAPIInnerObserver::NAPIInnerObserver(napi_env env, napi_value callback)
28 : env_(env)
29 {
30 napi_create_reference(env, callback, 1, &ref_);
31 napi_get_uv_event_loop(env, &loop_);
32 }
33
OnComplete(ObserverWorker * observerWorker)34 void NAPIInnerObserver::OnComplete(ObserverWorker* observerWorker)
35 {
36 LOG_DEBUG("napi_send_event start");
37 auto observer = observerWorker->observer_.lock();
38 if (observer == nullptr || observer->ref_ == nullptr) {
39 LOG_ERROR("innerWorker->observer_->ref_ is nullptr");
40 delete observerWorker;
41 return;
42 }
43 napi_handle_scope scope = nullptr;
44 napi_open_handle_scope(observer->env_, &scope);
45 if (scope == nullptr) {
46 LOG_ERROR("scope is nullptr");
47 delete observerWorker;
48 return;
49 }
50 napi_value callback = nullptr;
51 napi_value args[2] = {0};
52 napi_value global = nullptr;
53 napi_get_reference_value(observer->env_, observer->ref_, &callback);
54 napi_get_global(observer->env_, &global);
55 napi_get_undefined(observer->env_, &args[0]);
56 if (observerWorker->isNotifyDetails_) {
57 args[1] = DataShareJSUtils::Convert2JSValue(observer->env_, observerWorker->result_);
58 }
59 napi_status callStatus = napi_call_function(observer->env_, global, callback, 2, args, nullptr);
60 napi_close_handle_scope(observer->env_, scope);
61 if (callStatus != napi_ok) {
62 LOG_ERROR("napi_call_function failed status : %{public}d", callStatus);
63 }
64 LOG_DEBUG("napi_call_function succeed status : %{public}d", callStatus);
65 delete observerWorker;
66 }
67
OnChange(const DataShareObserver::ChangeInfo & changeInfo,bool isNotifyDetails)68 void NAPIInnerObserver::OnChange(const DataShareObserver::ChangeInfo& changeInfo, bool isNotifyDetails)
69 {
70 auto time =
71 static_cast<uint64_t>(duration_cast<milliseconds>(system_clock::now().time_since_epoch()).count());
72 LOG_INFO("NAPIInnerObserver datashare callback start, times %{public}" PRIu64 ".", time);
73 if (ref_ == nullptr) {
74 LOG_ERROR("ref_ is nullptr");
75 return;
76 }
77 ObserverWorker* observerWorker = new (std::nothrow) ObserverWorker(shared_from_this(), changeInfo);
78 if (observerWorker == nullptr) {
79 LOG_ERROR("Failed to create observerWorker");
80 return;
81 }
82 observerWorker->isNotifyDetails_ = isNotifyDetails;
83 auto task = [observerWorker]() {
84 NAPIInnerObserver::OnComplete(observerWorker);
85 };
86 int ret = napi_send_event(env_, task, napi_eprio_immediate);
87 if (ret != 0) {
88 LOG_ERROR("napi_send_event failed: %{public}d", ret);
89 delete observerWorker;
90 }
91 LOG_INFO("NAPIInnerObserver datashare callback end, times %{public}" PRIu64 ".", time);
92 }
93
DeleteReference()94 void NAPIInnerObserver::DeleteReference()
95 {
96 if (ref_ != nullptr) {
97 napi_delete_reference(env_, ref_);
98 ref_ = nullptr;
99 }
100 }
101
GetCallback()102 napi_ref NAPIInnerObserver::GetCallback()
103 {
104 return ref_;
105 }
106 } // namespace DataShare
107 } // namespace OHOS