1 /*
2 * Copyright (c) 2022 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 #define LOG_TAG "NapiRdbStoreConvertUtils"
17 #include "napi_rdb_store_convert_utils.h"
18
19 #include "js_native_api.h"
20 #include "js_native_api_types.h"
21 #include "js_sendable_utils.h"
22 #include "js_utils.h"
23 #include "logger.h"
24 #include "napi_rdb_error.h"
25 #include "napi_rdb_js_utils.h"
26 #include "napi_rdb_sendable_utils.h"
27
28 using namespace OHOS::RelationalStoreJsKit;
29 using namespace OHOS::AppDataMgrJsKit::JSUtils;
30 namespace OHOS {
31 namespace SendableRdb {
32
33 constexpr int32_t KEY_INDEX = 0;
34 constexpr int32_t VALUE_INDEX = 1;
35
FromSendableValuesBucket(napi_env env,napi_callback_info info)36 napi_value FromSendableValuesBucket(napi_env env, napi_callback_info info)
37 {
38 size_t argc = 1;
39 napi_value args[1] = { nullptr };
40 napi_status status = napi_get_cb_info(env, info, &argc, args, nullptr, nullptr);
41 RDB_NAPI_ASSERT(env, status == napi_ok && argc == 1, std::make_shared<ParamNumError>("1"));
42
43 bool isMap = false;
44 status = napi_is_map(env, args[0], &isMap);
45 RDB_NAPI_ASSERT(env, status == napi_ok && isMap,
46 std::make_shared<ParamError>("ValuesBucket is invalid" + std::to_string(status)));
47
48 uint32_t length = 0;
49 status = napi_map_get_size(env, args[0], &length);
50 RDB_NAPI_ASSERT(env, status == napi_ok, std::make_shared<InnerError>("napi_map_get_size failed."));
51 napi_value entries = nullptr;
52 status = napi_map_get_entries(env, args[0], &entries);
53 RDB_NAPI_ASSERT(env, status == napi_ok, std::make_shared<InnerError>("napi_map_get_entries failed."));
54 napi_value object = nullptr;
55 status = napi_create_object(env, &object);
56 for (uint32_t i = 0; i < length; ++i) {
57 napi_value iter = nullptr;
58 status = napi_map_iterator_get_next(env, entries, &iter);
59 RDB_NAPI_ASSERT(env, status == napi_ok, std::make_shared<InnerError>("napi_map_iterator_get_next failed."));
60 napi_value values = nullptr;
61 status = napi_get_named_property(env, iter, "value", &values);
62 RDB_NAPI_ASSERT(env, status == napi_ok, std::make_shared<InnerError>("napi_get_named_property value failed."));
63
64 napi_value key = nullptr;
65 status = napi_get_element(env, values, KEY_INDEX, &key);
66 RDB_NAPI_ASSERT(env, status == napi_ok, std::make_shared<InnerError>("napi_get_element key failed."));
67
68 napi_value value = nullptr;
69 status = napi_get_element(env, values, VALUE_INDEX, &value);
70 RDB_NAPI_ASSERT(env, status == napi_ok, std::make_shared<InnerError>("napi_get_element value failed."));
71
72 status = napi_set_property(env, object, key, Convert2JSValue(env, value));
73 RDB_NAPI_ASSERT(env, status == napi_ok, std::make_shared<InnerError>("napi_set_property failed."));
74 }
75
76 return object;
77 }
78
ToSendableValuesBucket(napi_env env,napi_callback_info info)79 napi_value ToSendableValuesBucket(napi_env env, napi_callback_info info)
80 {
81 size_t argc = 1;
82 napi_value args[1] = { nullptr };
83 napi_status status = napi_get_cb_info(env, info, &argc, args, nullptr, nullptr);
84 RDB_NAPI_ASSERT(env, status == napi_ok && argc == 1, std::make_shared<ParamNumError>("1"));
85
86 napi_valuetype type = napi_undefined;
87 status = napi_typeof(env, args[0], &type);
88 RDB_NAPI_ASSERT(env, status == napi_ok && type == napi_object,
89 std::make_shared<ParamError>("ValuesBucket is invalid" + std::to_string(status)));
90
91 napi_value keys = nullptr;
92 napi_get_all_property_names(env, args[0], napi_key_own_only,
93 static_cast<napi_key_filter>(napi_key_enumerable | napi_key_skip_symbols), napi_key_numbers_to_strings, &keys);
94 uint32_t length = 0;
95 status = napi_get_array_length(env, keys, &length);
96 RDB_NAPI_ASSERT(env, status == napi_ok, std::make_shared<InnerError>("napi_get_array_length failed."));
97
98 napi_value map = nullptr;
99 status = napi_create_sendable_map(env, &map);
100 RDB_NAPI_ASSERT(env, status == napi_ok, std::make_shared<InnerError>("napi_create_sendable_map failed."));
101 for (uint32_t i = 0; i < length; ++i) {
102 napi_value key = nullptr;
103 status = napi_get_element(env, keys, i, &key);
104 RDB_NAPI_ASSERT(env, status == napi_ok, std::make_shared<InnerError>("napi_get_element failed."));
105 napi_value value = nullptr;
106 status = napi_get_property(env, args[0], key, &value);
107 RDB_NAPI_ASSERT(env, status == napi_ok, std::make_shared<InnerError>("napi_get_property failed."));
108 status = napi_map_set_property(env, map, key, Convert2Sendable(env, value));
109
110 RDB_NAPI_ASSERT(env, status == napi_ok, std::make_shared<InnerError>("napi_map_set_property failed."));
111 }
112 return map;
113 }
114
FromSendableAsset(napi_env env,napi_callback_info info)115 napi_value FromSendableAsset(napi_env env, napi_callback_info info)
116 {
117 size_t argc = 1;
118 napi_value args[1] = { nullptr };
119 napi_status status = napi_get_cb_info(env, info, &argc, args, nullptr, nullptr);
120 RDB_NAPI_ASSERT(env, status == napi_ok && argc == 1, std::make_shared<ParamNumError>("1"));
121
122 napi_valuetype type = napi_undefined;
123 status = napi_typeof(env, args[0], &type);
124 RDB_NAPI_ASSERT(env, status == napi_ok && type == napi_object,
125 std::make_shared<ParamError>("Asset is invalid" + std::to_string(status)));
126
127 return Convert2JSValue(env, args[0]);
128 }
129
ToSendableAsset(napi_env env,napi_callback_info info)130 napi_value ToSendableAsset(napi_env env, napi_callback_info info)
131 {
132 size_t argc = 1;
133 napi_value args[1] = { nullptr };
134 napi_status status = napi_get_cb_info(env, info, &argc, args, nullptr, nullptr);
135 RDB_NAPI_ASSERT(env, status == napi_ok && argc == 1, std::make_shared<ParamNumError>("1"));
136
137 napi_valuetype type = napi_undefined;
138 status = napi_typeof(env, args[0], &type);
139 RDB_NAPI_ASSERT(env, status == napi_ok && type == napi_object,
140 std::make_shared<ParamError>("Asset is invalid" + std::to_string(status)));
141
142 return Convert2Sendable(env, args[0]);
143 }
144
FromSendableValues(napi_env env,napi_callback_info info)145 napi_value FromSendableValues(napi_env env, napi_callback_info info)
146 {
147 size_t argc = 1;
148 napi_value args[1] = { nullptr };
149 napi_status status = napi_get_cb_info(env, info, &argc, args, nullptr, nullptr);
150 RDB_NAPI_ASSERT(env, status == napi_ok && argc == 1, std::make_shared<ParamNumError>("1"));
151
152 bool isArray = false;
153 status = napi_is_array(env, args[0], &isArray);
154 RDB_NAPI_ASSERT(env, status == napi_ok && isArray,
155 std::make_shared<ParamError>("values is invalid" + std::to_string(status)));
156
157 uint32_t length = 0;
158 status = napi_get_array_length(env, args[0], &length);
159 RDB_NAPI_ASSERT(env, status == napi_ok, std::make_shared<InnerError>("napi_get_array_length failed."));
160 napi_value outArray;
161 status = napi_create_array(env, &outArray);
162 RDB_NAPI_ASSERT(env, status == napi_ok, std::make_shared<InnerError>("napi_create_array failed."));
163 for (uint32_t i = 0; i < length; ++i) {
164 napi_value item = nullptr;
165 status = napi_get_element(env, args[0], i, &item);
166 RDB_NAPI_ASSERT(env, status == napi_ok, std::make_shared<InnerError>("napi_get_element failed."));
167 napi_value jsvalue = Convert2JSValue(env, item);
168 status = napi_set_element(env, outArray, i, jsvalue);
169 RDB_NAPI_ASSERT(env, status == napi_ok, std::make_shared<InnerError>("napi_set_element failed."));
170 }
171 return outArray;
172 }
173
ToSendableValues(napi_env env,napi_callback_info info)174 napi_value ToSendableValues(napi_env env, napi_callback_info info)
175 {
176 size_t argc = 1;
177 napi_value args[1] = { nullptr };
178 napi_status status = napi_get_cb_info(env, info, &argc, args, nullptr, nullptr);
179 RDB_NAPI_ASSERT(env, status == napi_ok && argc == 1, std::make_shared<ParamNumError>("1"));
180
181 bool isArray = false;
182 status = napi_is_array(env, args[0], &isArray);
183 RDB_NAPI_ASSERT(env, status == napi_ok && isArray,
184 std::make_shared<ParamError>("values is invalid" + std::to_string(status)));
185
186 uint32_t length = 0;
187 status = napi_get_array_length(env, args[0], &length);
188 RDB_NAPI_ASSERT(env, status == napi_ok, std::make_shared<InnerError>("napi_get_array_length failed."));
189
190 napi_value outArray;
191 status = napi_create_sendable_array(env, &outArray);
192 RDB_NAPI_ASSERT(env, status == napi_ok, std::make_shared<InnerError>("napi_create_sendable_array failed."));
193 for (uint32_t i = 0; i < length; ++i) {
194 napi_value item = nullptr;
195 status = napi_get_element(env, args[0], i, &item);
196 RDB_NAPI_ASSERT(env, status == napi_ok, std::make_shared<InnerError>("napi_get_element failed."));
197 ValueObject object;
198 status = (napi_status)Convert2Value(env, item, object);
199 RDB_NAPI_ASSERT(env, status == napi_ok, std::make_shared<InnerError>("Convert2Value failed."));
200 napi_value sendablevalue = Convert2Sendable(env, object);
201
202 status = napi_set_element(env, outArray, i, sendablevalue);
203 RDB_NAPI_ASSERT(env, status == napi_ok, std::make_shared<InnerError>("napi_set_element failed."));
204 }
205 return outArray;
206 }
207
InitRdbStoreUtils(napi_env env,napi_value exports)208 napi_value InitRdbStoreUtils(napi_env env, napi_value exports)
209 {
210 napi_property_descriptor properties[] = {
211 DECLARE_NAPI_FUNCTION("fromSendableValuesBucket", FromSendableValuesBucket),
212 DECLARE_NAPI_FUNCTION("toSendableValuesBucket", ToSendableValuesBucket),
213 DECLARE_NAPI_FUNCTION("fromSendableAsset", FromSendableAsset),
214 DECLARE_NAPI_FUNCTION("toSendableAsset", ToSendableAsset),
215 DECLARE_NAPI_FUNCTION("fromSendableValues", FromSendableValues),
216 DECLARE_NAPI_FUNCTION("toSendableValues", ToSendableValues),
217 };
218 NAPI_CALL(env, napi_define_properties(env, exports, sizeof(properties) / sizeof(*properties), properties));
219 return exports;
220 }
221 } // namespace SendableRdb
222 } // namespace OHOS