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 
InitRdbStoreUtils(napi_env env,napi_value exports)145 napi_value InitRdbStoreUtils(napi_env env, napi_value exports)
146 {
147     napi_property_descriptor properties[] = {
148         DECLARE_NAPI_FUNCTION("fromSendableValuesBucket", FromSendableValuesBucket),
149         DECLARE_NAPI_FUNCTION("toSendableValuesBucket", ToSendableValuesBucket),
150         DECLARE_NAPI_FUNCTION("fromSendableAsset", FromSendableAsset),
151         DECLARE_NAPI_FUNCTION("toSendableAsset", ToSendableAsset),
152     };
153     NAPI_CALL(env, napi_define_properties(env, exports, sizeof(properties) / sizeof(*properties), properties));
154     return exports;
155 }
156 } // namespace SendableRdb
157 } // namespace OHOS