* Copyright (C) 2022 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 "napi_util.h"
#include "securec.h"
#include "string_ex.h"
#include "country_code.h"
#include "common_utils.h"
#include "geo_address.h"
#include "location_log.h"
#include "locator_proxy.h"
#include "request_config.h"
namespace OHOS {
namespace Location {
static constexpr int MAX_BUF_LEN = 100;
static constexpr int MIN_WIFI_SCAN_TIME = 5000;
const uint32_t MAX_ADDITION_SIZE = 100;
const uint32_t MAX_ARRAY_LENGTH = 1000;
napi_value UndefinedNapiValue(const napi_env& env)
{
napi_value result;
NAPI_CALL(env, napi_get_undefined(env, &result));
return result;
}
void SatelliteStatusToJs(const napi_env& env,
const std::shared_ptr<SatelliteStatus>& statusInfo, napi_value& result)
{
napi_value satelliteIdsArray;
napi_value cn0Array;
napi_value altitudesArray;
napi_value azimuthsArray;
napi_value carrierFrequenciesArray;
napi_value additionalInfoArray;
napi_value satelliteConstellationArray;
int svNum = statusInfo->GetSatellitesNumber();
SetValueDouble(env, "satellitesNumber", svNum, result);
if (svNum >= 0) {
NAPI_CALL_RETURN_VOID(env, napi_create_array_with_length(env, svNum, &satelliteIdsArray));
NAPI_CALL_RETURN_VOID(env, napi_create_array_with_length(env, svNum, &cn0Array));
NAPI_CALL_RETURN_VOID(env, napi_create_array_with_length(env, svNum, &altitudesArray));
NAPI_CALL_RETURN_VOID(env, napi_create_array_with_length(env, svNum, &azimuthsArray));
NAPI_CALL_RETURN_VOID(env, napi_create_array_with_length(env, svNum, &carrierFrequenciesArray));
NAPI_CALL_RETURN_VOID(env, napi_create_array_with_length(env, svNum, &satelliteConstellationArray));
NAPI_CALL_RETURN_VOID(env, napi_create_array_with_length(env, svNum, &additionalInfoArray));
uint32_t idx1 = 0;
for (int index = 0; index < svNum; index++) {
napi_value value = nullptr;
NAPI_CALL_RETURN_VOID(env, napi_create_int32(env, statusInfo->GetSatelliteIds()[index], &value));
NAPI_CALL_RETURN_VOID(env, napi_set_element(env, satelliteIdsArray, idx1, value));
NAPI_CALL_RETURN_VOID(env,
napi_create_double(env, statusInfo->GetCarrierToNoiseDensitys()[index], &value));
NAPI_CALL_RETURN_VOID(env, napi_set_element(env, cn0Array, idx1, value));
NAPI_CALL_RETURN_VOID(env, napi_create_double(env, statusInfo->GetAltitudes()[index], &value));
NAPI_CALL_RETURN_VOID(env, napi_set_element(env, altitudesArray, idx1, value));
NAPI_CALL_RETURN_VOID(env, napi_create_double(env, statusInfo->GetAzimuths()[index], &value));
NAPI_CALL_RETURN_VOID(env, napi_set_element(env, azimuthsArray, idx1, value));
NAPI_CALL_RETURN_VOID(env, napi_create_double(env, statusInfo->GetCarrierFrequencies()[index], &value));
NAPI_CALL_RETURN_VOID(env, napi_set_element(env, carrierFrequenciesArray, idx1, value));
NAPI_CALL_RETURN_VOID(env,
napi_create_int32(env, statusInfo->GetSatelliteAdditionalInfoList()[index], &value));
NAPI_CALL_RETURN_VOID(env, napi_set_element(env, additionalInfoArray, idx1, value));
NAPI_CALL_RETURN_VOID(env,
napi_create_int32(env, statusInfo->GetConstellationTypes()[index], &value));
NAPI_CALL_RETURN_VOID(env, napi_set_element(env, satelliteConstellationArray, idx1, value));
idx1++;
}
SetValueStringArray(env, "satelliteIds", satelliteIdsArray, result);
SetValueStringArray(env, "carrierToNoiseDensitys", cn0Array, result);
SetValueStringArray(env, "altitudes", altitudesArray, result);
SetValueStringArray(env, "azimuths", azimuthsArray, result);
SetValueStringArray(env, "carrierFrequencies", carrierFrequenciesArray, result);
SetValueStringArray(env, "satelliteConstellation", satelliteConstellationArray, result);
SetValueStringArray(env, "satelliteAdditionalInfo", additionalInfoArray, result);
}
}
void LocationsToJs(const napi_env& env, const std::vector<std::unique_ptr<Location>>& locations, napi_value& result)
{
if (locations.size() > 0) {
for (unsigned int index = 0; index < locations.size(); index++) {
napi_value value;
NAPI_CALL_RETURN_VOID(env, napi_create_object(env, &value));
LocationToJs(env, locations[index], value);
NAPI_CALL_RETURN_VOID(env, napi_set_element(env, result, index, value));
}
}
}
void LocationToJs(const napi_env& env, const std::unique_ptr<Location>& locationInfo, napi_value& result)
{
SetValueDouble(env, "latitude", locationInfo->GetLatitude(), result);
SetValueDouble(env, "longitude", locationInfo->GetLongitude(), result);
SetValueDouble(env, "altitude", locationInfo->GetAltitude(), result);
SetValueDouble(env, "accuracy", locationInfo->GetAccuracy(), result);
SetValueDouble(env, "speed", locationInfo->GetSpeed(), result);
SetValueInt64(env, "timeStamp", locationInfo->GetTimeStamp(), result);
SetValueDouble(env, "direction", locationInfo->GetDirection(), result);
SetValueInt64(env, "timeSinceBoot", locationInfo->GetTimeSinceBoot(), result);
napi_value additionArray;
uint32_t additionSize = static_cast<uint32_t>(locationInfo->GetAdditionSize());
additionSize = additionSize > MAX_ADDITION_SIZE ? MAX_ADDITION_SIZE : additionSize;
std::vector<std::string> additions = locationInfo->GetAdditions();
SetValueInt64(env, "additionSize", additionSize, result);
NAPI_CALL_RETURN_VOID(env,
napi_create_array_with_length(env, additionSize, &additionArray));
for (uint32_t index = 0; index < std::min(additionSize, static_cast<uint32_t>(additions.size())); index++) {
napi_value value;
NAPI_CALL_RETURN_VOID(env, napi_create_string_utf8(env, additions[index].c_str(),
NAPI_AUTO_LENGTH, &value));
NAPI_CALL_RETURN_VOID(env, napi_set_element(env, additionArray, index, value));
}
SetValueStringArray(env, "additions", additionArray, result);
SetValueBool(env, "isFromMock", locationInfo->GetIsFromMock(), result);
napi_value additionMap = CreateJsMap(env, locationInfo->GetAdditionsMap());
SetValueStringMap(env, "additionsMap", additionMap, result);
SetValueDouble(env, "altitudeAccuracy", locationInfo->GetAltitudeAccuracy(), result);
SetValueDouble(env, "speedAccuracy", locationInfo->GetSpeedAccuracy(), result);
SetValueDouble(env, "directionAccuracy", locationInfo->GetDirectionAccuracy(), result);
SetValueInt64(env, "uncertaintyOfTimeSinceBoot", locationInfo->GetUncertaintyOfTimeSinceBoot(), result);
SetValueInt32(env, "sourceType", locationInfo->GetLocationSourceType(), result);
napi_value poiJsObj = CreatePoiInfoJsObj(env, locationInfo->GetPoiInfo());
SetValuePoi(env, "poi", poiJsObj, result);
}
void BluetoothScanResultToJs(const napi_env& env, const std::unique_ptr<BluetoothScanResult>& bluetoothScanResult,
napi_value& result)
{
SetValueUtf8String(env, "deviceId", bluetoothScanResult->GetDeviceId().c_str(), result);
SetValueUtf8String(env, "deviceName", bluetoothScanResult->GetDeviceName().c_str(), result);
SetValueInt64(env, "rssi", bluetoothScanResult->GetRssi(), result);
SetValueBool(env, "connectable", bluetoothScanResult->GetConnectable(), result);
SetValueArrayBuffer(env, "data", bluetoothScanResult->GetData(), result);
}
void PoiToJs(const napi_env& env, const std::unique_ptr<Location>& locationInfo, napi_value& result)
{
napi_value poiJsObj = CreatePoiInfoJsObj(env, locationInfo->GetPoiInfo());
result = poiJsObj;
}
napi_value CreatePoiInfoJsObj(const napi_env& env, const PoiInfo& poiInfo)
{
napi_value jsObject = nullptr;
if (poiInfo.poiArray.size() == 0) {
napi_get_undefined(env, &jsObject);
return jsObject;
}
NAPI_CALL(env, napi_create_object(env, &jsObject));
napi_value jsArray = nullptr;
NAPI_CALL(env, napi_create_array(env, &jsArray));
size_t index = 0;
for (auto poi : poiInfo.poiArray) {
napi_value jsPoiObject = nullptr;
NAPI_CALL(env, napi_create_object(env, &jsPoiObject));
napi_value jsValue = nullptr;
NAPI_CALL(env, napi_create_string_utf8(env, poi.id.c_str(), NAPI_AUTO_LENGTH, &jsValue));
NAPI_CALL(env, napi_set_named_property(env, jsPoiObject, "id", jsValue));
NAPI_CALL(env, napi_create_double(env, poi.confidence, &jsValue));
NAPI_CALL(env, napi_set_named_property(env, jsPoiObject, "confidence", jsValue));
NAPI_CALL(env, napi_create_string_utf8(env, poi.name.c_str(), NAPI_AUTO_LENGTH, &jsValue));
NAPI_CALL(env, napi_set_named_property(env, jsPoiObject, "name", jsValue));
NAPI_CALL(env, napi_create_double(env, poi.latitude, &jsValue));
NAPI_CALL(env, napi_set_named_property(env, jsPoiObject, "latitude", jsValue));
NAPI_CALL(env, napi_create_double(env, poi.longitude, &jsValue));
NAPI_CALL(env, napi_set_named_property(env, jsPoiObject, "longitude", jsValue));
NAPI_CALL(env, napi_create_string_utf8(env, poi.administrativeArea.c_str(), NAPI_AUTO_LENGTH, &jsValue));
NAPI_CALL(env, napi_set_named_property(env, jsPoiObject, "administrativeArea", jsValue));
NAPI_CALL(env, napi_create_string_utf8(env, poi.subAdministrativeArea.c_str(), NAPI_AUTO_LENGTH, &jsValue));
NAPI_CALL(env, napi_set_named_property(env, jsPoiObject, "subAdministrativeArea", jsValue));
NAPI_CALL(env, napi_create_string_utf8(env, poi.locality.c_str(), NAPI_AUTO_LENGTH, &jsValue));
NAPI_CALL(env, napi_set_named_property(env, jsPoiObject, "locality", jsValue));
NAPI_CALL(env, napi_create_string_utf8(env, poi.subLocality.c_str(), NAPI_AUTO_LENGTH, &jsValue));
NAPI_CALL(env, napi_set_named_property(env, jsPoiObject, "subLocality", jsValue));
NAPI_CALL(env, napi_create_string_utf8(env, poi.address.c_str(), NAPI_AUTO_LENGTH, &jsValue));
NAPI_CALL(env, napi_set_named_property(env, jsPoiObject, "address", jsValue));
NAPI_CALL(env, napi_create_string_utf8(env, poi.additionalInfo.c_str(), NAPI_AUTO_LENGTH, &jsValue));
NAPI_CALL(env, napi_set_named_property(env, jsPoiObject, "additionalInfo", jsValue));
napi_value jsIndex = nullptr;
NAPI_CALL(env, napi_create_uint32(env, index, &jsIndex));
NAPI_CALL(env, napi_set_property(env, jsArray, jsIndex, jsPoiObject));
index++;
}
NAPI_CALL(env, napi_set_named_property(env, jsObject, "poiArray", jsArray));
napi_value jsTimestamp = nullptr;
NAPI_CALL(env, napi_create_int64(env, poiInfo.timestamp, &jsTimestamp));
NAPI_CALL(env, napi_set_named_property(env, jsObject, "timestamp", jsTimestamp));
return jsObject;
}
void SetUndefinedResult(const napi_env& env, napi_value& result)
{
napi_get_undefined(env, &result);
}
napi_value CreateJsMap(napi_env env, const std::map<std::string, std::string>& additionsMap)
{
napi_value global = nullptr;
napi_value mapFunc = nullptr;
napi_value map = nullptr;
NAPI_CALL(env, napi_get_global(env, &global));
NAPI_CALL(env, napi_get_named_property(env, global, "Map", &mapFunc));
NAPI_CALL(env, napi_new_instance(env, mapFunc, 0, nullptr, &map));
napi_value setFunc = nullptr;
NAPI_CALL(env, napi_get_named_property(env, map, "set", &setFunc));
for (auto iter : additionsMap) {
napi_value key = nullptr;
napi_value value = nullptr;
NAPI_CALL(env, napi_create_string_utf8(env, iter.first.c_str(), NAPI_AUTO_LENGTH, &key));
NAPI_CALL(env, napi_create_string_utf8(env, iter.second.c_str(), NAPI_AUTO_LENGTH, &value));
napi_value setArgs[] = { key, value };
NAPI_CALL(env, napi_call_function(env, map, setFunc, sizeof(setArgs) / sizeof(setArgs[0]), setArgs, nullptr));
}
return map;
}
void GeofenceResultToJs(const napi_env& env, const Geofence& fence, napi_value& result)
{
SetValueDouble(env, "latitude", fence.GetLatitude(), result);
SetValueDouble(env, "longitude", fence.GetLongitude(), result);
SetValueDouble(env, "radius", fence.GetRadius(), result);
SetValueDouble(env, "expiration", fence.GetExpiration(), result);
SetValueInt32(env, "coordinateSystemType", fence.GetCoordinateSystemType(), result);
}
napi_value CreateFenceMap(const napi_env& env, const std::map<int, Geofence>& fenceMap)
{
napi_value global = nullptr;
napi_value mapFunc = nullptr;
napi_value map = nullptr;
NAPI_CALL(env, napi_get_global(env, &global));
NAPI_CALL(env, napi_get_named_property(env, global, "Map", &mapFunc));
NAPI_CALL(env, napi_new_instance(env, mapFunc, 0, nullptr, &map));
napi_value setFunc = nullptr;
NAPI_CALL(env, napi_get_named_property(env, map, "set", &setFunc));
for (auto iter : fenceMap) {
napi_value key = nullptr;
napi_value value = nullptr;
NAPI_CALL(env, napi_create_int32(env, iter.first, &key));
NAPI_CALL(env, napi_create_object(env, &value));
GeofenceResultToJs(env, iter.second, value);
napi_value setArgs[] = { key, value };
NAPI_CALL(env, napi_call_function(env, map, setFunc, sizeof(setArgs) / sizeof(setArgs[0]), setArgs, nullptr));
}
return map;
}
void CountryCodeToJs(const napi_env& env, const std::shared_ptr<CountryCode>& country, napi_value& result)
{
SetValueUtf8String(env, "country", country->GetCountryCodeStr().c_str(), result);
SetValueInt64(env, "type", country->GetCountryCodeType(), result);
}
void SystemLocationToJs(const napi_env& env, const std::unique_ptr<Location>& locationInfo, napi_value& result)
{
SetValueDouble(env, "longitude", locationInfo->GetLongitude(), result);
SetValueDouble(env, "latitude", locationInfo->GetLatitude(), result);
SetValueDouble(env, "altitude", locationInfo->GetAltitude(), result);
SetValueDouble(env, "accuracy", locationInfo->GetAccuracy(), result);
SetValueInt64(env, "time", locationInfo->GetTimeStamp(), result);
}
bool GeoAddressesToJsObj(const napi_env& env,
std::list<std::shared_ptr<GeoAddress>>& replyList, napi_value& arrayResult)
{
uint32_t idx = 0;
for (auto iter = replyList.begin(); iter != replyList.end(); ++iter) {
auto geoAddress = *iter;
napi_value eachObj;
NAPI_CALL_BASE(env, napi_create_object(env, &eachObj), false);
SetValueDouble(env, "latitude", geoAddress->GetLatitude(), eachObj);
SetValueDouble(env, "longitude", geoAddress->GetLongitude(), eachObj);
SetValueUtf8String(env, "locale", geoAddress->locale_.c_str(), eachObj);
SetValueUtf8String(env, "placeName", geoAddress->placeName_.c_str(), eachObj);
SetValueUtf8String(env, "countryCode", geoAddress->countryCode_.c_str(), eachObj);
SetValueUtf8String(env, "countryName", geoAddress->countryName_.c_str(), eachObj);
SetValueUtf8String(env, "administrativeArea", geoAddress->administrativeArea_.c_str(), eachObj);
SetValueUtf8String(env, "subAdministrativeArea", geoAddress->subAdministrativeArea_.c_str(), eachObj);
SetValueUtf8String(env, "locality", geoAddress->locality_.c_str(), eachObj);
SetValueUtf8String(env, "subLocality", geoAddress->subLocality_.c_str(), eachObj);
SetValueUtf8String(env, "roadName", geoAddress->roadName_.c_str(), eachObj);
SetValueUtf8String(env, "subRoadName", geoAddress->subRoadName_.c_str(), eachObj);
SetValueUtf8String(env, "premises", geoAddress->premises_.c_str(), eachObj);
SetValueUtf8String(env, "postalCode", geoAddress->postalCode_.c_str(), eachObj);
SetValueUtf8String(env, "phoneNumber", geoAddress->phoneNumber_.c_str(), eachObj);
SetValueUtf8String(env, "addressUrl", geoAddress->addressUrl_.c_str(), eachObj);
napi_value descriptionArray;
if (geoAddress->descriptionsSize_ > 0) {
NAPI_CALL_BASE(env,
napi_create_array_with_length(env, geoAddress->descriptionsSize_, &descriptionArray), false);
uint32_t idx1 = 0;
for (int index = 0; index < geoAddress->descriptionsSize_; index++) {
napi_value value;
NAPI_CALL_BASE(env, napi_create_string_utf8(env, geoAddress->GetDescriptions(index).c_str(),
NAPI_AUTO_LENGTH, &value), false);
NAPI_CALL_BASE(env, napi_set_element(env, descriptionArray, idx1++, value), false);
}
SetValueStringArray(env, "descriptions", descriptionArray, eachObj);
}
SetValueInt32(env, "descriptionsSize", geoAddress->descriptionsSize_, eachObj);
if (geoAddress->GetIsSystemApp()) {
SetValueBool(env, "isFromMock", geoAddress->isFromMock_, eachObj);
}
NAPI_CALL_BASE(env, napi_set_element(env, arrayResult, idx++, eachObj), false);
}
return true;
}
bool LocatingRequiredDataToJsObj(const napi_env& env,
std::vector<std::shared_ptr<LocatingRequiredData>>& replyList, napi_value& arrayResult)
{
uint32_t idx = 0;
for (size_t i = 0; i < replyList.size(); i++) {
napi_value eachObj;
NAPI_CALL_BASE(env, napi_create_object(env, &eachObj), false);
napi_value wifiObj;
NAPI_CALL_BASE(env, napi_create_object(env, &wifiObj), false);
SetValueUtf8String(env, "ssid", replyList[i]->GetWifiScanInfo()->GetSsid().c_str(), wifiObj);
SetValueUtf8String(env, "bssid", replyList[i]->GetWifiScanInfo()->GetBssid().c_str(), wifiObj);
SetValueInt32(env, "rssi", replyList[i]->GetWifiScanInfo()->GetRssi(), wifiObj);
SetValueInt32(env, "frequency", replyList[i]->GetWifiScanInfo()->GetFrequency(), wifiObj);
SetValueInt64(env, "timestamp", replyList[i]->GetWifiScanInfo()->GetTimestamp(), wifiObj);
napi_value blueToothObj;
NAPI_CALL_BASE(env, napi_create_object(env, &blueToothObj), false);
SetValueUtf8String(env, "deviceName",
replyList[i]->GetBluetoothScanInfo()->GetDeviceName().c_str(), blueToothObj);
SetValueUtf8String(env, "macAddress", replyList[i]->GetBluetoothScanInfo()->GetMac().c_str(), blueToothObj);
SetValueInt64(env, "rssi", replyList[i]->GetBluetoothScanInfo()->GetRssi(), blueToothObj);
SetValueInt64(env, "timestamp", replyList[i]->GetBluetoothScanInfo()->GetTimeStamp(), blueToothObj);
napi_value compedCellInfoObj;
NAPI_CALL_BASE(env, napi_create_object(env, &compedCellInfoObj), false);
std::shared_ptr<CellularInfo> campedCellInfo = replyList[i]->GetCampedCellInfo();
CellularInfoToJsObj(env, campedCellInfo, compedCellInfoObj);
napi_value neighboringCellInfoObj = nullptr;
NAPI_CALL_BASE(env, napi_create_array_with_length(env, replyList[i]->GetNeighboringCellInfo().size(),
&neighboringCellInfoObj), false);
for (size_t j = 0; j < replyList[i]->GetNeighboringCellInfo().size() && j < MAX_ARRAY_LENGTH; j++) {
napi_value cellularInfoObj;
NAPI_CALL_BASE(env, napi_create_object(env, &cellularInfoObj), false);
std::shared_ptr<CellularInfo> cellularInfo = replyList[i]->GetNeighboringCellInfo()[j];
CellularInfoToJsObj(env, cellularInfo, cellularInfoObj);
NAPI_CALL_BASE(env, napi_set_element(env, neighboringCellInfoObj, j, cellularInfoObj), false);
}
NAPI_CALL_BASE(env, napi_set_named_property(env, eachObj, "wifiData", wifiObj), false);
NAPI_CALL_BASE(env, napi_set_named_property(env, eachObj, "bluetoothData", blueToothObj), false);
SetValueInt32(env, "slotId", replyList[i]->GetSlotId(), eachObj);
NAPI_CALL_BASE(env, napi_set_named_property(env, eachObj, "campedCellInfo", compedCellInfoObj), false);
NAPI_CALL_BASE(env,
napi_set_named_property(env, eachObj, "neighboringCellInfo", neighboringCellInfoObj), false);
napi_status status = napi_set_element(env, arrayResult, idx++, eachObj);
if (status != napi_ok) {
LBSLOGE(LOCATING_DATA_CALLBACK, "set element error: %{public}d, idx: %{public}d", status, idx - 1);
return false;
}
}
return true;
}
void CellularInfoToJsObj(const napi_env& env,
std::shared_ptr<CellularInfo>& cellularInfo, napi_value& cellularInfoObj)
{
SetValueInt64(env, "timeSinceBoot", cellularInfo->GetTimeSinceBoot(), cellularInfoObj);
SetValueInt64(env, "cellId", cellularInfo->GetCellId(), cellularInfoObj);
SetValueInt64(env, "lac", cellularInfo->GetLac(), cellularInfoObj);
SetValueInt64(env, "mcc", cellularInfo->GetMcc(), cellularInfoObj);
SetValueInt64(env, "mnc", cellularInfo->GetMnc(), cellularInfoObj);
SetValueInt64(env, "rat", cellularInfo->GetRat(), cellularInfoObj);
SetValueInt64(env, "signalIntensity", cellularInfo->GetSignalIntensity(), cellularInfoObj);
SetValueInt64(env, "arfcn", cellularInfo->GetArfcn(), cellularInfoObj);
SetValueInt64(env, "pci", cellularInfo->GetPci(), cellularInfoObj);
if (cellularInfo->GetAdditionsMap() != nullptr) {
napi_value additionsMap = CreateJsMap(env, *cellularInfo->GetAdditionsMap());
SetValueStringMap(env, "additionsMap", additionsMap, cellularInfoObj);
}
}
void JsObjToCachedLocationRequest(const napi_env& env, const napi_value& object,
std::unique_ptr<CachedGnssLocationsRequest>& request)
{
JsObjectToInt(env, object, "reportingPeriodSec", request->reportingPeriodSec);
JsObjectToBool(env, object, "wakeUpCacheQueueFull", request->wakeUpCacheQueueFull);
}
void JsObjToLocationRequest(const napi_env& env, const napi_value& object,
std::unique_ptr<RequestConfig>& requestConfig)
{
int value = 0;
double valueDouble = 0.0;
bool valueBool = false;
if (JsObjectToInt(env, object, "priority", value) == SUCCESS) {
requestConfig->SetPriority(value);
}
if (JsObjectToInt(env, object, "scenario", value) == SUCCESS ||
JsObjectToInt(env, object, "locationScenario", value) == SUCCESS) {
requestConfig->SetScenario(value);
}
if (JsObjectToInt(env, object, "timeInterval", value) == SUCCESS ||
JsObjectToInt(env, object, "interval", value) == SUCCESS) {
requestConfig->SetTimeInterval(value);
}
if (JsObjectToDouble(env, object, "maxAccuracy", valueDouble) == SUCCESS) {
requestConfig->SetMaxAccuracy(valueDouble);
}
if (JsObjectToDouble(env, object, "distanceInterval", valueDouble) == SUCCESS) {
requestConfig->SetDistanceInterval(valueDouble);
}
if (JsObjectToBool(env, object, "needPoi", valueBool) == SUCCESS) {
requestConfig->SetIsNeedPoi(valueBool);
}
}
bool JsObjToLocation(const napi_env& env, const napi_value& object,
Location& location)
{
double valueDouble = 0.0;
if (JsObjectToDouble(env, object, "latitude", valueDouble) == SUCCESS) {
location.SetLatitude(valueDouble);
} else {
LBSLOGE(NAPI_UTILS, "analysis latitude fail.");
return false;
}
if (JsObjectToDouble(env, object, "longitude", valueDouble) == SUCCESS) {
location.SetLongitude(valueDouble);
} else {
LBSLOGE(NAPI_UTILS, "analysis longitude fail.");
return false;
}
return true;
}
void JsObjToLocatingRequiredDataConfig(const napi_env& env, const napi_value& object,
std::unique_ptr<LocatingRequiredDataConfig>& config)
{
int valueInt = 0;
bool valueBool = false;
if (JsObjectToInt(env, object, "type", valueInt) == SUCCESS) {
config->SetType(valueInt);
}
if (JsObjectToBool(env, object, "needStartScan", valueBool) == SUCCESS) {
config->SetNeedStartScan(valueBool);
}
if (JsObjectToInt(env, object, "scanInterval", valueInt) == SUCCESS) {
config->SetScanIntervalMs(valueInt < MIN_WIFI_SCAN_TIME ? MIN_WIFI_SCAN_TIME : valueInt);
}
if (JsObjectToInt(env, object, "scanTimeout", valueInt) == SUCCESS) {
config->SetScanTimeoutMs(valueInt < MIN_WIFI_SCAN_TIME ? MIN_WIFI_SCAN_TIME : valueInt);
}
if (JsObjectToInt(env, object, "slotId", valueInt) == SUCCESS) {
config->SetSlotId(valueInt);
}
std::vector<int32_t> vectorArfcn;
if (GetIntArrayFromJsObj(env, object, "arfcn", vectorArfcn)) {
config->SetArfcnArray(vectorArfcn);
}
std::vector<int32_t> vectorPlmnId;
if (GetIntArrayFromJsObj(env, object, "plmnId", vectorPlmnId)) {
config->SetPlmnParamArray(vectorPlmnId);
}
}
void JsObjToCurrentLocationRequest(const napi_env& env, const napi_value& object,
std::unique_ptr<RequestConfig>& requestConfig)
{
int value = 0;
double valueDouble = 0.0;
bool valueBool = false;
if (JsObjectToInt(env, object, "priority", value) == SUCCESS ||
JsObjectToInt(env, object, "locatingPriority", value) == SUCCESS) {
requestConfig->SetPriority(value);
}
if (JsObjectToInt(env, object, "scenario", value) == SUCCESS) {
requestConfig->SetScenario(value);
}
if (JsObjectToDouble(env, object, "maxAccuracy", valueDouble) == SUCCESS) {
requestConfig->SetMaxAccuracy(valueDouble);
}
if (JsObjectToInt(env, object, "timeoutMs", value) == SUCCESS ||
JsObjectToInt(env, object, "locatingTimeoutMs", value) == SUCCESS) {
requestConfig->SetTimeOut(value);
}
if (JsObjectToBool(env, object, "needPoi", valueBool) == SUCCESS) {
requestConfig->SetIsNeedPoi(valueBool);
}
}
int JsObjToCommand(const napi_env& env, const napi_value& object,
std::unique_ptr<LocationCommand>& commandConfig)
{
if (commandConfig == nullptr) {
return COMMON_ERROR;
}
CHK_ERROR_CODE("scenario", JsObjectToInt(env, object, "scenario", commandConfig->scenario), true);
CHK_ERROR_CODE("command", JsObjectToString(env, object, "command", MAX_BUF_LEN, commandConfig->command), true);
return SUCCESS;
}
int JsObjToGeoCodeRequest(const napi_env& env, const napi_value& object, MessageParcel& dataParcel)
{
std::string description = "";
int maxItems = 1;
double minLatitude = 0.0;
double minLongitude = 0.0;
double maxLatitude = 0.0;
double maxLongitude = 0.0;
std::string locale = "";
int bufLen = MAX_BUF_LEN;
std::string country = "";
CHK_ERROR_CODE("locale", JsObjectToString(env, object, "locale", bufLen, locale), false);
CHK_ERROR_CODE("description", JsObjectToString(env, object, "description", bufLen, description), true);
if (description == "") {
LBSLOGE(LOCATOR_STANDARD, "The required description field should not be empty.");
return INPUT_PARAMS_ERROR;
}
CHK_ERROR_CODE("maxItems", JsObjectToInt(env, object, "maxItems", maxItems), false);
CHK_ERROR_CODE("minLatitude", JsObjectToDouble(env, object, "minLatitude", minLatitude), false);
CHK_ERROR_CODE("minLongitude", JsObjectToDouble(env, object, "minLongitude", minLongitude), false);
CHK_ERROR_CODE("maxLatitude", JsObjectToDouble(env, object, "maxLatitude", maxLatitude), false);
CHK_ERROR_CODE("maxLongitude", JsObjectToDouble(env, object, "maxLongitude", maxLongitude), false);
CHK_ERROR_CODE("country", JsObjectToString(env, object, "country", MAX_BUF_LEN, country), false);
if (minLatitude < MIN_LATITUDE || minLatitude > MAX_LATITUDE) {
return INPUT_PARAMS_ERROR;
}
if (minLongitude < MIN_LONGITUDE || minLongitude > MAX_LONGITUDE) {
return INPUT_PARAMS_ERROR;
}
if (maxLatitude < MIN_LATITUDE || maxLatitude > MAX_LATITUDE) {
return INPUT_PARAMS_ERROR;
}
if (maxLongitude < MIN_LONGITUDE || maxLongitude > MAX_LONGITUDE) {
return INPUT_PARAMS_ERROR;
}
if (!dataParcel.WriteInterfaceToken(LocatorProxy::GetDescriptor())) {
LBSLOGE(LOCATOR_STANDARD, "write interfaceToken fail!");
return COMMON_ERROR;
}
dataParcel.WriteString16(Str8ToStr16(locale));
dataParcel.WriteString16(Str8ToStr16(description));
dataParcel.WriteInt32(maxItems);
dataParcel.WriteDouble(minLatitude);
dataParcel.WriteDouble(minLongitude);
dataParcel.WriteDouble(maxLatitude);
dataParcel.WriteDouble(maxLongitude);
dataParcel.WriteString16(Str8ToStr16(CommonUtils::GenerateUuid()));
dataParcel.WriteString16(Str8ToStr16(country));
return SUCCESS;
}
int JsObjToReverseGeoCodeRequest(const napi_env& env, const napi_value& object, MessageParcel& dataParcel)
{
double latitude = 0;
double longitude = 0;
int maxItems = 1;
std::string locale = "";
std::string country = "";
CHK_ERROR_CODE("latitude", JsObjectToDouble(env, object, "latitude", latitude), true);
CHK_ERROR_CODE("longitude", JsObjectToDouble(env, object, "longitude", longitude), true);
CHK_ERROR_CODE("maxItems", JsObjectToInt(env, object, "maxItems", maxItems), false);
CHK_ERROR_CODE("locale", JsObjectToString(env, object, "locale", MAX_BUF_LEN, locale), false);
CHK_ERROR_CODE("country", JsObjectToString(env, object, "country", MAX_BUF_LEN, country), false);
if (latitude < MIN_LATITUDE || latitude > MAX_LATITUDE) {
return INPUT_PARAMS_ERROR;
}
if (longitude < MIN_LONGITUDE || longitude > MAX_LONGITUDE) {
return INPUT_PARAMS_ERROR;
}
if (!dataParcel.WriteInterfaceToken(LocatorProxy::GetDescriptor())) {
return COMMON_ERROR;
}
dataParcel.WriteString16(Str8ToStr16(locale));
dataParcel.WriteDouble(latitude);
dataParcel.WriteDouble(longitude);
dataParcel.WriteInt32(maxItems);
dataParcel.WriteString16(Str8ToStr16(CommonUtils::GenerateUuid()));
dataParcel.WriteString16(Str8ToStr16(country));
return SUCCESS;
}
napi_value GetArrayProperty(const napi_env& env, const napi_value& object, const std::string propertyName)
{
if (object == nullptr) {
LBSLOGE(NAPI_UTILS, "object is nullptr.");
return UndefinedNapiValue(env);
}
bool hasProperty = false;
NAPI_CALL_BASE(env,
napi_has_named_property(env, object, propertyName.c_str(), &hasProperty), UndefinedNapiValue(env));
if (!hasProperty) {
LBSLOGE(NAPI_UTILS, "propertyName is not exist");
return UndefinedNapiValue(env);
}
napi_value property = nullptr;
NAPI_CALL_BASE(env,
napi_get_named_property(env, object, propertyName.c_str(), &property), UndefinedNapiValue(env));
bool isArray = false;
NAPI_CALL_BASE(env, napi_is_array(env, property, &isArray), UndefinedNapiValue(env));
if (!isArray) {
LBSLOGE(NAPI_UTILS, "propertyName is not an array!");
return UndefinedNapiValue(env);
}
return property;
}
bool GetLocationInfo(const napi_env& env, const napi_value& object,
const char* fieldStr, std::shared_ptr<ReverseGeocodeRequest>& request)
{
bool result = false;
napi_value value = nullptr;
if (object == nullptr) {
LBSLOGE(LOCATOR_STANDARD, "object is nullptr.");
return false;
}
NAPI_CALL_BASE(env, napi_has_named_property(env, object, fieldStr, &result), false);
if (result) {
NAPI_CALL_BASE(env, napi_get_named_property(env, object, fieldStr, &value), false);
JsObjectToString(env, value, "locale", MAX_BUF_LEN, request->locale);
JsObjectToInt(env, value, "maxItems", request->maxItems);
JsObjectToDouble(env, value, "latitude", request->latitude);
JsObjectToDouble(env, value, "longitude", request->longitude);
return true;
}
return false;
}
napi_value GetNapiValueByKey(napi_env env, const std::string& keyChar, napi_value object)
{
if (object == nullptr) {
LBSLOGE(LOCATOR_STANDARD, "GetNapiValueByKey object is nullptr.");
return nullptr;
}
bool result = false;
NAPI_CALL(env, napi_has_named_property(env, object, keyChar.c_str(), &result));
if (result) {
napi_value value = nullptr;
NAPI_CALL(env, napi_get_named_property(env, object, keyChar.c_str(), &value));
return value;
}
return nullptr;
}
bool GetStringArrayFromJsObj(napi_env env, napi_value value, std::vector<std::string>& outArray)
{
uint32_t arrayLength = 0;
NAPI_CALL_BASE(env, napi_get_array_length(env, value, &arrayLength), false);
if (arrayLength == 0) {
LBSLOGE(LOCATOR_STANDARD, "The array is empty.");
return false;
}
for (size_t i = 0; i < arrayLength && i < MAX_ARRAY_LENGTH; i++) {
napi_value napiElement = nullptr;
NAPI_CALL_BASE(env, napi_get_element(env, value, i, &napiElement), false);
napi_valuetype napiValueType = napi_undefined;
NAPI_CALL_BASE(env, napi_typeof(env, napiElement, &napiValueType), false);
if (napiValueType != napi_string) {
LBSLOGE(LOCATOR_STANDARD, "wrong argument type.");
return false;
}
char type[64] = {0};
size_t typeLen = 0;
NAPI_CALL_BASE(env, napi_get_value_string_utf8(env, napiElement, type, sizeof(type), &typeLen), false);
std::string event = type;
outArray.push_back(event);
}
return true;
}
bool GetIntArrayFromJsObj(
napi_env env, napi_value jsObject, const std::string& key, std::vector<int32_t>& outArray)
{
napi_value array = GetNapiValueByKey(env, key, jsObject);
if (array == nullptr) {
return false;
}
bool isArray = false;
NAPI_CALL_BASE(env, napi_is_array(env, array, &isArray), false);
if (!isArray) {
LBSLOGE(LOCATOR_STANDARD, "not an array!");
return false;
}
uint32_t arrayLength = 0;
NAPI_CALL_BASE(env, napi_get_array_length(env, array, &arrayLength), false);
if (arrayLength == 0) {
LBSLOGE(LOCATOR_STANDARD, "The array is empty.");
return false;
}
for (size_t i = 0; i < arrayLength; i++) {
napi_value napiElement = nullptr;
NAPI_CALL_BASE(env, napi_get_element(env, array, i, &napiElement), false);
napi_valuetype napiValueType = napi_undefined;
NAPI_CALL_BASE(env, napi_typeof(env, napiElement, &napiValueType), false);
if (napiValueType != napi_number) {
LBSLOGE(LOCATOR_STANDARD, "wrong argument type.");
return false;
}
int value = 0;
NAPI_CALL_BASE(env, napi_get_value_int32(env, napiElement, &value), false);
outArray.push_back(value);
}
return true;
}
bool GetStringArrayValueByKey(
napi_env env, napi_value jsObject, const std::string& key, std::vector<std::string>& outArray)
{
napi_value array = GetNapiValueByKey(env, key, jsObject);
if (array == nullptr) {
return false;
}
bool isArray = false;
NAPI_CALL_BASE(env, napi_is_array(env, array, &isArray), false);
if (!isArray) {
LBSLOGE(LOCATOR_STANDARD, "not an array!");
return false;
}
return GetStringArrayFromJsObj(env, array, outArray);
}
bool GetGeoAddressInfo(const napi_env& env, const napi_value& object,
const std::string& fieldStr, std::shared_ptr<GeoAddress> address)
{
napi_value value = GetNapiValueByKey(env, fieldStr, object);
if (value == nullptr) {
LBSLOGE(LOCATOR_STANDARD, "GetNapiValueByKey is nullptr.");
return false;
}
int bufLen = MAX_BUF_LEN;
JsObjectToDouble(env, value, "latitude", address->latitude_);
JsObjectToDouble(env, value, "longitude", address->longitude_);
JsObjectToString(env, value, "locale", bufLen, address->locale_);
JsObjectToString(env, value, "placeName", bufLen, address->placeName_);
JsObjectToString(env, value, "countryCode", bufLen, address->countryCode_);
JsObjectToString(env, value, "countryName", bufLen, address->countryName_);
JsObjectToString(env, value, "administrativeArea", bufLen, address->administrativeArea_);
JsObjectToString(env, value, "subAdministrativeArea", bufLen, address->subAdministrativeArea_);
JsObjectToString(env, value, "locality", bufLen, address->locality_);
JsObjectToString(env, value, "subLocality", bufLen, address->subLocality_);
JsObjectToString(env, value, "roadName", bufLen, address->roadName_);
JsObjectToString(env, value, "subRoadName", bufLen, address->subRoadName_);
JsObjectToString(env, value, "premises", bufLen, address->premises_);
JsObjectToString(env, value, "postalCode", bufLen, address->postalCode_);
JsObjectToString(env, value, "phoneNumber", bufLen, address->phoneNumber_);
JsObjectToString(env, value, "addressUrl", bufLen, address->addressUrl_);
JsObjectToInt(env, value, "descriptionsSize", address->descriptionsSize_);
JsObjectToBool(env, value, "isFromMock", address->isFromMock_);
std::vector<std::string> descriptions;
GetStringArrayValueByKey(env, value, "descriptions", descriptions);
size_t size = static_cast<size_t>(address->descriptionsSize_) > descriptions.size() ?
descriptions.size() : static_cast<size_t>(address->descriptionsSize_);
for (size_t i = 0; i < size; i++) {
address->descriptions_.insert(std::make_pair(i, descriptions[i]));
}
return true;
}
bool JsObjToRevGeocodeMock(const napi_env& env, const napi_value& object,
std::vector<std::shared_ptr<GeocodingMockInfo>>& mockInfo)
{
bool isArray = false;
NAPI_CALL_BASE(env, napi_is_array(env, object, &isArray), false);
if (!isArray) {
LBSLOGE(LOCATOR_STANDARD, "JsObjToRevGeocodeMock:not an array!");
return false;
}
uint32_t arrayLength = 0;
NAPI_CALL_BASE(env, napi_get_array_length(env, object, &arrayLength), false);
if (arrayLength == 0) {
LBSLOGE(LOCATOR_STANDARD, "JsObjToRevGeocodeMock:The array is empty.");
return false;
}
for (size_t i = 0; i < arrayLength; i++) {
napi_value napiElement = nullptr;
NAPI_CALL_BASE(env, napi_get_element(env, object, i, &napiElement), false);
std::shared_ptr<GeocodingMockInfo> info = std::make_shared<GeocodingMockInfo>();
std::shared_ptr<ReverseGeocodeRequest> request = std::make_shared<ReverseGeocodeRequest>();
std::shared_ptr<GeoAddress> geoAddress = std::make_shared<GeoAddress>();
GetLocationInfo(env, napiElement, "location", request);
GetGeoAddressInfo(env, napiElement, "geoAddress", geoAddress);
info->SetLocation(request);
info->SetGeoAddressInfo(geoAddress);
mockInfo.push_back(info);
}
return true;
}
void GetLocationArray(const napi_env& env, LocationMockAsyncContext *asyncContext, const napi_value& object)
{
uint32_t arrayLength = 0;
NAPI_CALL_RETURN_VOID(env, napi_get_array_length(env, object, &arrayLength));
if (arrayLength == 0) {
LBSLOGE(LOCATOR_STANDARD, "The array is empty.");
return;
}
for (uint32_t i = 0; i < arrayLength; i++) {
napi_value elementValue = nullptr;
std::shared_ptr<Location> locationAdapter = std::make_shared<Location>();
NAPI_CALL_RETURN_VOID(env, napi_get_element(env, object, i, &elementValue));
double latitude = 0.0;
JsObjectToDouble(env, elementValue, "latitude", latitude);
locationAdapter->SetLatitude(latitude);
double longitude = 0.0;
JsObjectToDouble(env, elementValue, "longitude", longitude);
locationAdapter->SetLongitude(longitude);
double altitude = 0.0;
JsObjectToDouble(env, elementValue, "altitude", altitude);
locationAdapter->SetAltitude(altitude);
double accuracy = 0.0;
JsObjectToDouble(env, elementValue, "accuracy", accuracy);
locationAdapter->SetAccuracy(accuracy);
double speed = 0.0;
JsObjectToDouble(env, elementValue, "speed", speed);
locationAdapter->SetSpeed(speed);
double direction = 0.0;
JsObjectToDouble(env, elementValue, "direction", direction);
locationAdapter->SetDirection(direction);
int64_t timeStamp = 0;
JsObjectToInt64(env, elementValue, "timeStamp", timeStamp);
locationAdapter->SetTimeStamp(timeStamp);
int64_t timeSinceBoot = 0;
JsObjectToInt64(env, elementValue, "timeSinceBoot", timeSinceBoot);
locationAdapter->SetTimeSinceBoot(timeSinceBoot);
int32_t additionSize = 0;
JsObjectToInt(env, elementValue, "additionSize", additionSize);
locationAdapter->SetAdditionSize(static_cast<int64_t>(additionSize));
bool isFromMock = false;
JsObjectToBool(env, elementValue, "isFromMock", isFromMock);
locationAdapter->SetIsFromMock(isFromMock ? 1 : 0);
std::vector<std::string> additions;
GetStringArrayValueByKey(env, elementValue, "additions", additions);
locationAdapter->SetAdditions(additions, false);
asyncContext->LocationNapi.push_back(locationAdapter);
}
}
int JsObjectToString(const napi_env& env, const napi_value& object,
const char* fieldStr, const int bufLen, std::string& fieldRef)
{
bool hasProperty = false;
NAPI_CALL_BASE(env, napi_has_named_property(env, object, fieldStr, &hasProperty), COMMON_ERROR);
if (hasProperty) {
napi_value field;
napi_valuetype valueType;
NAPI_CALL_BASE(env, napi_get_named_property(env, object, fieldStr, &field), COMMON_ERROR);
NAPI_CALL_BASE(env, napi_typeof(env, field, &valueType), COMMON_ERROR);
if (valueType != napi_string) {
LBSLOGE(LOCATOR_STANDARD, "JsObjectToString, valueType != napi_string.");
return INPUT_PARAMS_ERROR;
}
if (bufLen <= 0) {
LBSLOGE(LOCATOR_STANDARD, "The length of buf should be greater than 0.");
return COMMON_ERROR;
}
int32_t actBuflen = bufLen + 1;
std::unique_ptr<char[]> buf = std::make_unique<char[]>(actBuflen);
(void)memset_s(buf.get(), actBuflen, 0, actBuflen);
size_t result = 0;
NAPI_CALL_BASE(env, napi_get_value_string_utf8(env, field, buf.get(), actBuflen, &result), COMMON_ERROR);
fieldRef = buf.get();
return SUCCESS;
}
LBSLOGD(LOCATOR_STANDARD, "Js obj to str no property: %{public}s", fieldStr);
return PARAM_IS_EMPTY;
}
int JsObjectToDouble(const napi_env& env, const napi_value& object, const char* fieldStr, double& fieldRef)
{
bool hasProperty = false;
NAPI_CALL_BASE(env, napi_has_named_property(env, object, fieldStr, &hasProperty), COMMON_ERROR);
if (hasProperty) {
napi_value field;
napi_valuetype valueType;
NAPI_CALL_BASE(env, napi_get_named_property(env, object, fieldStr, &field), COMMON_ERROR);
NAPI_CALL_BASE(env, napi_typeof(env, field, &valueType), COMMON_ERROR);
NAPI_ASSERT_BASE(env, valueType == napi_number, "Wrong argument type.", INPUT_PARAMS_ERROR);
NAPI_CALL_BASE(env, napi_get_value_double(env, field, &fieldRef), COMMON_ERROR);
return SUCCESS;
}
LBSLOGD(LOCATOR_STANDARD, "Js to int no property: %{public}s", fieldStr);
return PARAM_IS_EMPTY;
}
int JsObjectToInt(const napi_env& env, const napi_value& object, const char* fieldStr, int& fieldRef)
{
bool hasProperty = false;
NAPI_CALL_BASE(env, napi_has_named_property(env, object, fieldStr, &hasProperty), COMMON_ERROR);
if (hasProperty) {
napi_value field;
napi_valuetype valueType;
NAPI_CALL_BASE(env, napi_get_named_property(env, object, fieldStr, &field), COMMON_ERROR);
NAPI_CALL_BASE(env, napi_typeof(env, field, &valueType), COMMON_ERROR);
NAPI_ASSERT_BASE(env, valueType == napi_number, "Wrong argument type.", INPUT_PARAMS_ERROR);
NAPI_CALL_BASE(env, napi_get_value_int32(env, field, &fieldRef), COMMON_ERROR);
return SUCCESS;
}
LBSLOGD(LOCATOR_STANDARD, "Js to int no property: %{public}s", fieldStr);
return PARAM_IS_EMPTY;
}
int JsObjectToInt64(const napi_env& env, const napi_value& object, const char* fieldStr, int64_t& fieldRef)
{
bool hasProperty = false;
NAPI_CALL_BASE(env, napi_has_named_property(env, object, fieldStr, &hasProperty), COMMON_ERROR);
if (hasProperty) {
napi_value field;
napi_valuetype valueType;
NAPI_CALL_BASE(env, napi_get_named_property(env, object, fieldStr, &field), COMMON_ERROR);
NAPI_CALL_BASE(env, napi_typeof(env, field, &valueType), COMMON_ERROR);
NAPI_ASSERT_BASE(env, valueType == napi_number, "Wrong argument type.", INPUT_PARAMS_ERROR);
NAPI_CALL_BASE(env, napi_get_value_int64(env, field, &fieldRef), COMMON_ERROR);
return SUCCESS;
}
LBSLOGD(LOCATOR_STANDARD, "Js to int no property: %{public}s", fieldStr);
return PARAM_IS_EMPTY;
}
int JsObjectToBool(const napi_env& env, const napi_value& object, const char* fieldStr, bool& fieldRef)
{
bool hasProperty = false;
NAPI_CALL_BASE(env, napi_has_named_property(env, object, fieldStr, &hasProperty), COMMON_ERROR);
if (hasProperty) {
napi_value field;
napi_valuetype valueType;
NAPI_CALL_BASE(env, napi_get_named_property(env, object, fieldStr, &field), COMMON_ERROR);
NAPI_CALL_BASE(env, napi_typeof(env, field, &valueType), COMMON_ERROR);
NAPI_ASSERT_BASE(env, valueType == napi_boolean, "Wrong argument type.", INPUT_PARAMS_ERROR);
NAPI_CALL_BASE(env, napi_get_value_bool(env, field, &fieldRef), COMMON_ERROR);
return SUCCESS;
}
LBSLOGD(LOCATOR_STANDARD, "Js to bool no property: %{public}s", fieldStr);
return PARAM_IS_EMPTY;
}
napi_status SetValueUtf8String(const napi_env& env, const char* fieldStr, const char* str, napi_value& result)
{
napi_value value = nullptr;
NAPI_CALL_BASE(env, napi_create_string_utf8(env, str, NAPI_AUTO_LENGTH, &value), napi_generic_failure);
NAPI_CALL_BASE(env, napi_set_named_property(env, result, fieldStr, value), napi_generic_failure);
return napi_ok;
}
napi_status SetValueStringArray(const napi_env& env, const char* fieldStr, napi_value& value, napi_value& result)
{
NAPI_CALL_BASE(env, napi_set_named_property(env, result, fieldStr, value), napi_generic_failure);
return napi_ok;
}
napi_status SetValueStringMap(const napi_env& env, const char* fieldStr, napi_value& value, napi_value& result)
{
NAPI_CALL_BASE(env, napi_set_named_property(env, result, fieldStr, value), napi_generic_failure);
return napi_ok;
}
napi_status SetValuePoi(const napi_env& env, const char* fieldStr, napi_value& value, napi_value& result)
{
NAPI_CALL_BASE(env, napi_set_named_property(env, result, fieldStr, value), napi_generic_failure);
return napi_ok;
}
napi_status SetValueInt32(const napi_env& env, const char* fieldStr, const int intValue, napi_value& result)
{
napi_value value = nullptr;
NAPI_CALL_BASE(env, napi_create_int32(env, intValue, &value), napi_generic_failure);
NAPI_CALL_BASE(env, napi_set_named_property(env, result, fieldStr, value), napi_generic_failure);
return napi_ok;
}
napi_status SetValueInt64(const napi_env& env, const char* fieldStr, const int64_t intValue, napi_value& result)
{
napi_value value = nullptr;
NAPI_CALL_BASE(env, napi_create_int64(env, intValue, &value), napi_generic_failure);
NAPI_CALL_BASE(env, napi_set_named_property(env, result, fieldStr, value), napi_generic_failure);
return napi_ok;
}
napi_status SetValueDouble(const napi_env& env, const char* fieldStr, const double doubleValue, napi_value& result)
{
napi_value value = nullptr;
NAPI_CALL_BASE(env, napi_create_double(env, doubleValue, &value), napi_generic_failure);
NAPI_CALL_BASE(env, napi_set_named_property(env, result, fieldStr, value), napi_generic_failure);
return napi_ok;
}
napi_status SetValueBool(const napi_env& env, const char* fieldStr, const bool boolvalue, napi_value& result)
{
napi_value value = nullptr;
NAPI_CALL_BASE(env, napi_get_boolean(env, boolvalue, &value), napi_generic_failure);
NAPI_CALL_BASE(env, napi_set_named_property(env, result, fieldStr, value), napi_generic_failure);
return napi_ok;
}
napi_status SetValueArrayBuffer(const napi_env& env, const char* fieldStr, const std::vector<uint8_t> vectorValue,
napi_value& result)
{
size_t bufferSize = vectorValue.size();
uint8_t *nativeArraybuffer = nullptr;
napi_value nativeValue = nullptr;
napi_create_arraybuffer(env, bufferSize, reinterpret_cast<void **>(&nativeArraybuffer), &nativeValue);
memcpy_s(nativeArraybuffer, bufferSize, vectorValue.data(), bufferSize);
NAPI_CALL_BASE(env, napi_set_named_property(env, result, fieldStr, nativeValue), napi_generic_failure);
return napi_ok;
}
static bool InitAsyncCallBackEnv(const napi_env& env, AsyncContext* asyncContext,
const size_t argc, const napi_value* argv, const size_t objectArgsNum)
{
if (asyncContext == nullptr || argv == nullptr ||
argc > MAXIMUM_JS_PARAMS || objectArgsNum > MAXIMUM_JS_PARAMS) {
return false;
}
size_t startLoop = objectArgsNum;
size_t endLoop = argc;
for (size_t i = startLoop; i < endLoop; ++i) {
napi_valuetype valuetype;
NAPI_CALL_BASE(env, napi_typeof(env, argv[i], &valuetype), false);
NAPI_ASSERT_BASE(env, valuetype == napi_function, "Wrong argument type.", false);
size_t index = i - startLoop;
if (index >= MAX_CALLBACK_NUM) {
break;
}
NAPI_CALL_BASE(env, napi_create_reference(env, argv[i], 1, &asyncContext->callback[index]), false);
}
return true;
}
static bool InitAsyncPromiseEnv(const napi_env& env, AsyncContext *asyncContext, napi_value& promise)
{
napi_deferred deferred;
if (asyncContext == nullptr) {
return false;
}
NAPI_CALL_BASE(env, napi_create_promise(env, &deferred, &promise), false);
asyncContext->deferred = deferred;
return true;
}
void CreateFailCallBackParams(AsyncContext& context, const std::string& msg, int32_t errorCode)
{
SetValueUtf8String(context.env, "data", msg.c_str(), context.result[PARAM0]);
SetValueInt32(context.env, "code", errorCode, context.result[PARAM1]);
}
napi_value GetErrorObject(napi_env env, const int32_t errCode, const std::string& errMsg)
{
napi_value businessError = nullptr;
napi_value eCode = nullptr;
napi_value eMsg = nullptr;
NAPI_CALL(env, napi_create_int32(env, errCode, &eCode));
NAPI_CALL(env, napi_create_string_utf8(env, errMsg.c_str(), errMsg.length(), &eMsg));
NAPI_CALL(env, napi_create_object(env, &businessError));
NAPI_CALL(env, napi_set_named_property(env, businessError, "code", eCode));
NAPI_CALL(env, napi_set_named_property(env, businessError, "message", eMsg));
return businessError;
}
void CreateResultObject(const napi_env& env, AsyncContext* context)
{
if (context == nullptr || env == nullptr) {
LBSLOGE(LOCATOR_STANDARD, "CreateResultObject input para error");
return;
}
if (context->errCode != SUCCESS) {
std::string errMsg = CommonUtils::GetErrorMsgByCode(context->errCode);
context->errCode = CommonUtils::ConvertErrorCode(context->errCode);
context->result[PARAM0] = GetErrorObject(env, context->errCode, errMsg);
NAPI_CALL_RETURN_VOID(env, napi_get_undefined(env, &context->result[PARAM1]));
} else {
NAPI_CALL_RETURN_VOID(env, napi_get_undefined(env, &context->result[PARAM0]));
}
}
void SendResultToJs(const napi_env& env, AsyncContext* context)
{
if (context == nullptr || env == nullptr) {
LBSLOGE(LOCATOR_STANDARD, "SendResultToJs input para error");
return;
}
bool isPromise = context->deferred != nullptr;
if (isPromise) {
if (context->errCode != SUCCESS) {
napi_status status = napi_reject_deferred(env, context->deferred, context->result[PARAM0]);
if (status != napi_ok) {
LBSLOGE(LOCATOR_STANDARD, "SendResultToJs napi_reject_deferred fail status: %{public}d", status);
}
} else {
napi_status status = napi_resolve_deferred(env, context->deferred, context->result[PARAM1]);
if (status != napi_ok) {
LBSLOGE(LOCATOR_STANDARD, "SendResultToJs napi_reject_deferred fail status: %{public}d", status);
}
}
} else {
napi_value undefine;
napi_get_undefined(env, &undefine);
napi_value callback;
napi_status getCallbackStatus = napi_get_reference_value(env, context->callback[0], &callback);
if (getCallbackStatus != napi_ok) {
LBSLOGE(LOCATOR_STANDARD, "SendResultToJs getCallbackStatus fail status: %{public}d", getCallbackStatus);
return;
}
napi_status callFunStatus = napi_call_function(env, nullptr, callback, RESULT_SIZE, context->result, &undefine);
if (callFunStatus != napi_ok) {
LBSLOGE(LOCATOR_STANDARD, "SendResultToJs getCallFun fail status: %{public}d", callFunStatus);
}
}
}
void MemoryReclamation(const napi_env& env, AsyncContext* context)
{
if (context == nullptr || env == nullptr) {
LBSLOGE(LOCATOR_STANDARD, "MemoryReclamation input para error");
return;
}
if (context->callback[SUCCESS_CALLBACK] != nullptr) {
napi_status status = napi_delete_reference(env, context->callback[SUCCESS_CALLBACK]);
LBSLOGE(LOCATOR_STANDARD, "napi_delete_reference for success callback status: %{public}d", status);
}
if (context->callback[FAIL_CALLBACK] != nullptr) {
napi_status status = napi_delete_reference(env, context->callback[FAIL_CALLBACK]);
LBSLOGE(LOCATOR_STANDARD, "napi_delete_reference for fail callback status: %{public}d", status);
}
if (context->callback[COMPLETE_CALLBACK] != nullptr) {
napi_status status = napi_delete_reference(env, context->callback[COMPLETE_CALLBACK]);
LBSLOGE(LOCATOR_STANDARD, "napi_delete_reference for fail complete status: %{public}d", status);
}
napi_status deleteWorkStatus = napi_delete_async_work(env, context->work);
if (deleteWorkStatus != napi_ok) {
LBSLOGE(LOCATOR_STANDARD, "napi_delete_async_work fail status: %{public}d", deleteWorkStatus);
}
delete context;
context = nullptr;
}
static napi_value CreateAsyncWork(const napi_env& env, AsyncContext* asyncContext)
{
if (asyncContext == nullptr) {
return UndefinedNapiValue(env);
}
napi_status createWorkStatus = napi_create_async_work(
env, nullptr, asyncContext->resourceName,
[](napi_env env, void* data) {
if (data == nullptr) {
LBSLOGE(LOCATOR_STANDARD, "Async data parameter is null");
return;
}
AsyncContext* context = static_cast<AsyncContext *>(data);
context->executeFunc(context);
},
[](napi_env env, napi_status status, void* data) {
if (data == nullptr) {
LBSLOGE(LOCATOR_STANDARD, "Async data parameter is null");
return;
}
AsyncContext* context = static_cast<AsyncContext *>(data);
context->completeFunc(data);
CreateResultObject(env, context);
SendResultToJs(env, context);
MemoryReclamation(env, context);
}, static_cast<void*>(asyncContext), &asyncContext->work);
if (createWorkStatus != napi_ok) {
LBSLOGE(LOCATOR_STANDARD, "napi_create_async_work fail status: %{public}d", createWorkStatus);
asyncContext->isAsyncWorkAddToQueue = false;
MemoryReclamation(env, asyncContext);
return UndefinedNapiValue(env);
}
napi_status queueWorkStatus = napi_queue_async_work(env, asyncContext->work);
if (queueWorkStatus != napi_ok) {
LBSLOGE(LOCATOR_STANDARD, "napi_queue_async_work fail status: %{public}d", queueWorkStatus);
asyncContext->isAsyncWorkAddToQueue = false;
MemoryReclamation(env, asyncContext);
return UndefinedNapiValue(env);
}
asyncContext->isAsyncWorkAddToQueue = true;
return UndefinedNapiValue(env);
}
napi_value DoAsyncWork(const napi_env& env, AsyncContext* asyncContext,
const size_t argc, const napi_value* argv, const size_t objectArgsNum)
{
if (asyncContext == nullptr || argv == nullptr) {
return UndefinedNapiValue(env);
}
if (argc > objectArgsNum) {
InitAsyncCallBackEnv(env, asyncContext, argc, argv, objectArgsNum);
return CreateAsyncWork(env, asyncContext);
} else {
napi_value promise;
InitAsyncPromiseEnv(env, asyncContext, promise);
CreateAsyncWork(env, asyncContext);
return promise;
}
}
void DeleteQueueWork(AsyncContext* context)
{
uv_loop_s *loop = nullptr;
if (context->env == nullptr) {
LBSLOGE(LOCATOR_STANDARD, "env is nullptr.");
delete context;
return;
}
NAPI_CALL_RETURN_VOID(context->env, napi_get_uv_event_loop(context->env, &loop));
if (loop == nullptr) {
LBSLOGE(LOCATOR_STANDARD, "loop == nullptr.");
delete context;
return;
}
uv_work_t *work = new (std::nothrow) uv_work_t;
if (work == nullptr) {
LBSLOGE(LOCATOR_STANDARD, "work == nullptr.");
delete context;
return;
}
work->data = context;
DeleteCallbackHandler(loop, work);
}
void DeleteCallbackHandler(uv_loop_s *&loop, uv_work_t *&work)
{
uv_queue_work_internal(loop, work, [](uv_work_t *work) {},
[](uv_work_t *work, int status) {
AsyncContext *context = nullptr;
napi_handle_scope scope = nullptr;
if (work == nullptr) {
LBSLOGE(LOCATOR_CALLBACK, "work is nullptr");
return;
}
context = static_cast<AsyncContext *>(work->data);
if (context == nullptr || context->env == nullptr) {
LBSLOGE(LOCATOR_CALLBACK, "context is nullptr");
delete work;
return;
}
NAPI_CALL_RETURN_VOID(context->env, napi_open_handle_scope(context->env, &scope));
if (scope == nullptr) {
LBSLOGE(LOCATOR_CALLBACK, "scope is nullptr");
delete context;
delete work;
return;
}
if (context->callback[SUCCESS_CALLBACK] != nullptr) {
CHK_NAPI_ERR_CLOSE_SCOPE(context->env,
napi_delete_reference(context->env, context->callback[SUCCESS_CALLBACK]),
scope, context, work);
}
if (context->callback[FAIL_CALLBACK] != nullptr) {
CHK_NAPI_ERR_CLOSE_SCOPE(context->env,
napi_delete_reference(context->env, context->callback[FAIL_CALLBACK]),
scope, context, work);
}
if (context->callback[COMPLETE_CALLBACK] != nullptr) {
CHK_NAPI_ERR_CLOSE_SCOPE(context->env,
napi_delete_reference(context->env, context->callback[COMPLETE_CALLBACK]),
scope, context, work);
}
NAPI_CALL_RETURN_VOID(context->env, napi_close_handle_scope(context->env, scope));
delete context;
delete work;
}, "deleteCallback");
}
bool CheckIfParamIsFunctionType(napi_env env, napi_value param)
{
napi_valuetype valueType;
NAPI_CALL_BASE(env, napi_typeof(env, param, &valueType), false);
if (valueType != napi_function) {
return false;
}
return true;
}
napi_value SetEnumPropertyByInteger(napi_env env, napi_value dstObj, int32_t enumValue, const char *enumName)
{
napi_value enumProp = nullptr;
NAPI_CALL(env, napi_create_int32(env, enumValue, &enumProp));
NAPI_CALL(env, napi_set_named_property(env, dstObj, enumName, enumProp));
return enumProp;
}
bool CheckIfParamIsObjectType(napi_env env, napi_value param)
{
napi_valuetype valueType;
NAPI_CALL_BASE(env, napi_typeof(env, param, &valueType), false);
if (valueType != napi_object) {
return false;
}
return true;
}
napi_value CreateError(napi_env env, int32_t err, const std::string &msg)
{
napi_value businessError = nullptr;
napi_value errorCode = nullptr;
NAPI_CALL(env, napi_create_int32(env, err, &errorCode));
napi_value errorMessage = nullptr;
NAPI_CALL(env, napi_create_string_utf8(env, msg.c_str(), NAPI_AUTO_LENGTH, &errorMessage));
napi_create_error(env, nullptr, errorMessage, &businessError);
napi_set_named_property(env, businessError, "code", errorCode);
return businessError;
}
}
}