softbuscache/src/dm_softbus_cache.cpp

/*
 * Copyright (c) 2024 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 "dm_softbus_cache.h"
#include "dm_anonymous.h"
#include "dm_crypto.h"
#include "dm_constants.h"
#include "dm_device_info.h"
#include "dm_log.h"
#include <atomic>
namespace OHOS {
namespace DistributedHardware {
DM_IMPLEMENT_SINGLE_INSTANCE(SoftbusCache);
std::atomic<bool> g_online{false};
std::atomic<bool> g_getLocalDevInfo{false};
DmDeviceInfo localDeviceInfo_;
std::mutex localDevInfoMutex_;
void SoftbusCache::SaveLocalDeviceInfo()
{
    LOGI("start");
    std::lock_guard<std::mutex> mutexLock(localDevInfoMutex_);
    if (g_online) {
        return;
    }
    NodeBasicInfo nodeBasicInfo;
    int32_t ret = GetLocalNodeDeviceInfo(DM_PKG_NAME, &nodeBasicInfo);
    if (ret != DM_OK) {
        LOGE("[SOFTBUS]GetLocalNodeDeviceInfo failed, ret: %{public}d.", ret);
        return;
    }
    ConvertNodeBasicInfoToDmDevice(nodeBasicInfo, localDeviceInfo_);
    LOGI("networkid %{public}s.", GetAnonyString(std::string(localDeviceInfo_.networkId)).c_str());
    SaveDeviceInfo(localDeviceInfo_);
    SaveDeviceSecurityLevel(localDeviceInfo_.networkId);
    g_online = true;
    g_getLocalDevInfo = true;
}

void SoftbusCache::DeleteLocalDeviceInfo()
{
    LOGI("networkid %{public}s.", GetAnonyString(std::string(localDeviceInfo_.networkId)).c_str());
    std::lock_guard<std::mutex> mutexLock(localDevInfoMutex_);
    g_online = false;
    g_getLocalDevInfo = false;
    if (memset_s(&localDeviceInfo_, sizeof(DmDeviceInfo), 0, sizeof(DmDeviceInfo)) != DM_OK) {
        LOGE("DeleteLocalDeviceInfo memset_s failed.");
        return;
    }
}

int32_t SoftbusCache::GetLocalDeviceInfo(DmDeviceInfo &nodeInfo)
{
    std::lock_guard<std::mutex> mutexLock(localDevInfoMutex_);
    if (g_getLocalDevInfo) {
        nodeInfo = localDeviceInfo_;
        LOGD("dm cache success.");
        return DM_OK;
    }
    NodeBasicInfo nodeBasicInfo;
    int32_t ret = GetLocalNodeDeviceInfo(DM_PKG_NAME, &nodeBasicInfo);
    if (ret != DM_OK) {
        LOGE("[SOFTBUS]GetLocalNodeDeviceInfo failed, ret: %{public}d.", ret);
        return ret;
    }
    ConvertNodeBasicInfoToDmDevice(nodeBasicInfo, localDeviceInfo_);
    nodeInfo = localDeviceInfo_;
    SaveDeviceInfo(localDeviceInfo_);
    SaveDeviceSecurityLevel(localDeviceInfo_.networkId);
    g_getLocalDevInfo = true;
    LOGI("from softbus success.");
    return DM_OK;
}

void SoftbusCache::UpDataLocalDevInfo()
{
    LOGI("start");
    NodeBasicInfo nodeBasicInfo;
    int32_t ret = GetLocalNodeDeviceInfo(DM_PKG_NAME, &nodeBasicInfo);
    if (ret != DM_OK) {
        LOGE("[SOFTBUS]GetLocalNodeDeviceInfo failed, ret: %{public}d.", ret);
        return;
    }
    std::lock_guard<std::mutex> mutexLock(localDevInfoMutex_);
    ConvertNodeBasicInfoToDmDevice(nodeBasicInfo, localDeviceInfo_);
    ChangeDeviceInfo(localDeviceInfo_);
}

int32_t SoftbusCache::GetUdidByNetworkId(const char *networkId, std::string &udid)
{
    uint8_t mUdid[UDID_BUF_LEN] = {0};
    int32_t ret = GetNodeKeyInfo(DM_PKG_NAME, networkId, NodeDeviceInfoKey::NODE_KEY_UDID, mUdid, sizeof(mUdid));
    if (ret != DM_OK) {
        LOGE("[SOFTBUS]GetNodeKeyInfo failed, ret: %{public}d.", ret);
        return ret;
    }
    udid = reinterpret_cast<char *>(mUdid);
    return ret;
}

int32_t SoftbusCache::GetUuidByNetworkId(const char *networkId, std::string &uuid)
{
    uint8_t mUuid[UUID_BUF_LEN] = {0};
    int32_t ret = GetNodeKeyInfo(DM_PKG_NAME, networkId, NodeDeviceInfoKey::NODE_KEY_UUID, mUuid, sizeof(mUuid));
    if (ret != DM_OK) {
        LOGE("[SOFTBUS]GetNodeKeyInfo failed, ret: %{public}d.", ret);
        return ret;
    }
    uuid = reinterpret_cast<char *>(mUuid);
    return ret;
}

void SoftbusCache::SaveDeviceInfo(DmDeviceInfo deviceInfo)
{
    LOGI("start");
    std::string udid = "";
    std::string uuid = "";
    if (deviceInfo.networkId[0] == '\0') {
        LOGE("networkId is empty.");
        return;
    }
    GetUdidByNetworkId(deviceInfo.networkId, udid);
    GetUuidByNetworkId(deviceInfo.networkId, uuid);
    if (udid.empty()) {
        LOGE("udid is empty.");
        return;
    }
    char udidHash[DM_MAX_DEVICE_ID_LEN] = {0};
    if (Crypto::GetUdidHash(udid, reinterpret_cast<uint8_t *>(udidHash)) != DM_OK) {
        LOGE("get udidhash by udid: %{public}s failed.", GetAnonyString(udid).c_str());
        return;
    }
    if (memcpy_s(deviceInfo.deviceId, sizeof(deviceInfo.deviceId), udidHash,
                 std::min(sizeof(deviceInfo.deviceId), sizeof(udidHash))) != DM_OK) {
        LOGE("SaveDeviceInfo copy deviceId failed.");
        return;
    }
    std::lock_guard<std::mutex> mutexLock(deviceInfosMutex_);
    CHECK_SIZE_VOID(deviceInfo_);
    deviceInfo_[udid] = std::pair<std::string, DmDeviceInfo>(uuid, deviceInfo);
    LOGI("success udid %{public}s, networkId %{public}s",
        GetAnonyString(udid).c_str(), GetAnonyString(std::string(deviceInfo.networkId)).c_str());
}

void SoftbusCache::DeleteDeviceInfo(const DmDeviceInfo &nodeInfo)
{
    LOGI("networkId %{public}s", GetAnonyString(std::string(nodeInfo.networkId)).c_str());
    std::lock_guard<std::mutex> mutexLock(deviceInfosMutex_);
    for (const auto &item : deviceInfo_) {
        if (std::string(item.second.second.networkId) == std::string(nodeInfo.networkId)) {
            LOGI("success udid %{public}s", GetAnonyString(item.first).c_str());
            deviceInfo_.erase(item.first);
            break;
        }
    }
}

void SoftbusCache::DeleteDeviceInfo()
{
    std::lock_guard<std::mutex> mutexLock(deviceInfosMutex_);
    deviceInfo_.clear();
}

void SoftbusCache::ChangeDeviceInfo(const DmDeviceInfo deviceInfo)
{
    LOGI("start");
    std::string udid = "";
    GetUdidByNetworkId(deviceInfo.networkId, udid);
    std::lock_guard<std::mutex> mutexLock(deviceInfosMutex_);
    if (deviceInfo_.find(udid) != deviceInfo_.end()) {
        if (memcpy_s(deviceInfo_[udid].second.deviceName, sizeof(deviceInfo_[udid].second.deviceName),
                     deviceInfo.deviceName, sizeof(deviceInfo.deviceName)) != DM_OK) {
            LOGE("ChangeDeviceInfo deviceInfo copy deviceName failed");
            return;
        }
        if (memcpy_s(deviceInfo_[udid].second.networkId, sizeof(deviceInfo_[udid].second.networkId),
                     deviceInfo.networkId, sizeof(deviceInfo.networkId)) != DM_OK) {
            LOGE("ChangeDeviceInfo deviceInfo copy networkId failed");
            return;
        }
        deviceInfo_[udid].second.deviceTypeId = deviceInfo.deviceTypeId;
        std::string uuid = "";
        GetUuidByNetworkId(deviceInfo.networkId, uuid);
        deviceInfo_[udid].first = uuid;
    }
    LOGI("sucess udid %{public}s, networkId %{public}s.",
        GetAnonyString(udid).c_str(), GetAnonyString(std::string(deviceInfo.networkId)).c_str());
}

int32_t SoftbusCache::GetDeviceInfoFromCache(std::vector<DmDeviceInfo> &deviceInfoList)
{
    std::lock_guard<std::mutex> mutexLock(deviceInfosMutex_);
    for (const auto &item : deviceInfo_) {
        if (std::string(item.second.second.networkId) == std::string(localDeviceInfo_.networkId)) {
            continue;
        }
        deviceInfoList.push_back(item.second.second);
    }
    return DM_OK;
}

void SoftbusCache::UpdateDeviceInfoCache()
{
    LOGI("start");
    int32_t deviceCount = 0;
    NodeBasicInfo *nodeInfo = nullptr;
    int32_t ret = GetAllNodeDeviceInfo(DM_PKG_NAME, &nodeInfo, &deviceCount);
    if (ret != DM_OK) {
        LOGE("[SOFTBUS]GetAllNodeDeviceInfo failed, ret: %{public}d.", ret);
        return;
    }
    SaveLocalDeviceInfo();
    for (int32_t i = 0; i < deviceCount; ++i) {
        NodeBasicInfo *nodeBasicInfo = nodeInfo + i;
        DmDeviceInfo deviceInfo;
        ConvertNodeBasicInfoToDmDevice(*nodeBasicInfo, deviceInfo);
        SaveDeviceInfo(deviceInfo);
    }
    FreeNodeInfo(nodeInfo);
    LOGI("success, deviceCount: %{public}d.", deviceCount);
    return;
}

int32_t SoftbusCache::GetUdidFromCache(const char *networkId, std::string &udid)
{
    std::lock_guard<std::mutex> mutexLock(deviceInfosMutex_);
    for (const auto &item : deviceInfo_) {
        if (std::string(item.second.second.networkId) == std::string(networkId)) {
            udid = item.first;
            LOGI("Get udid from cache success, networkId %{public}s, udid %{public}s.",
                GetAnonyString(std::string(networkId)).c_str(), GetAnonyString(udid).c_str());
            return DM_OK;
        }
    }
    int32_t ret = GetUdidByNetworkId(networkId, udid);
    if (ret == DM_OK) {
        LOGI("Get udid from bus success, networkId %{public}s, udid %{public}s.",
            GetAnonyString(std::string(networkId)).c_str(), GetAnonyString(udid).c_str());
        return DM_OK;
    }
    return ret;
}

int32_t SoftbusCache::GetUuidFromCache(const char *networkId, std::string &uuid)
{
    std::lock_guard<std::mutex> mutexLock(deviceInfosMutex_);
    for (const auto &item : deviceInfo_) {
        if (std::string(item.second.second.networkId) == std::string(networkId)) {
            uuid = item.second.first;
            LOGI("Get uuid from cache success, networkId %{public}s, uuid %{public}s.",
                GetAnonyString(std::string(networkId)).c_str(), GetAnonyString(uuid).c_str());
            return DM_OK;
        }
    }
    int32_t ret = GetUuidByNetworkId(networkId, uuid);
    if (ret == DM_OK) {
        LOGI("Get uuid from bus success, networkId %{public}s, uuid %{public}s.",
            GetAnonyString(std::string(networkId)).c_str(), GetAnonyString(uuid).c_str());
        return DM_OK;
    }
    return ret;
}

int32_t SoftbusCache::ConvertNodeBasicInfoToDmDevice(const NodeBasicInfo &nodeInfo, DmDeviceInfo &devInfo)
{
    if (memset_s(&devInfo, sizeof(DmDeviceInfo), 0, sizeof(DmDeviceInfo)) != DM_OK) {
        LOGE("ConvertNodeBasicInfoToDmDevice memset_s failed.");
        return ERR_DM_FAILED;
    }

    if (memcpy_s(devInfo.networkId, sizeof(devInfo.networkId), nodeInfo.networkId,
                 std::min(sizeof(devInfo.networkId), sizeof(nodeInfo.networkId))) != DM_OK) {
        LOGE("ConvertNodeBasicInfoToDmDevice copy networkId data failed.");
        return ERR_DM_FAILED;
    }

    if (memcpy_s(devInfo.deviceName, sizeof(devInfo.deviceName), nodeInfo.deviceName,
                 std::min(sizeof(devInfo.deviceName), sizeof(nodeInfo.deviceName))) != DM_OK) {
        LOGE("ConvertNodeBasicInfoToDmDevice copy deviceName data failed.");
        return ERR_DM_FAILED;
    }

    devInfo.deviceTypeId = nodeInfo.deviceTypeId;
    JsonObject extraJson;
    extraJson[PARAM_KEY_OS_TYPE] = nodeInfo.osType;
    extraJson[PARAM_KEY_OS_VERSION] = ConvertCharArray2String(nodeInfo.osVersion, OS_VERSION_BUF_LEN);
    devInfo.extraData = ToString(extraJson);
    return DM_OK;
}

void SoftbusCache::SaveDeviceSecurityLevel(const char *networkId)
{
    LOGI("networkId %{public}s.", GetAnonyString(std::string(networkId)).c_str());
    std::lock_guard<std::mutex> mutexLock(deviceSecurityLevelMutex_);
    if (deviceSecurityLevel_.find(std::string(networkId)) != deviceSecurityLevel_.end()) {
        return;
    }
    CHECK_SIZE_VOID(deviceSecurityLevel_);
    int32_t tempSecurityLevel = -1;
    if (GetNodeKeyInfo(DM_PKG_NAME, networkId, NodeDeviceInfoKey::NODE_KEY_DEVICE_SECURITY_LEVEL,
        reinterpret_cast<uint8_t *>(&tempSecurityLevel), LNN_COMMON_LEN) != DM_OK) {
        LOGE("[SOFTBUS]GetNodeKeyInfo networkType failed.");
        return;
    }
    deviceSecurityLevel_[std::string(networkId)] = tempSecurityLevel;
}

void SoftbusCache::DeleteDeviceSecurityLevel(const char *networkId)
{
    LOGI("networkId %{public}s.", GetAnonyString(std::string(networkId)).c_str());
    std::lock_guard<std::mutex> mutexLock(deviceSecurityLevelMutex_);
    if (deviceSecurityLevel_.find(std::string(networkId)) != deviceSecurityLevel_.end()) {
        deviceSecurityLevel_.erase(std::string(networkId));
    }
}

int32_t SoftbusCache::GetSecurityDeviceLevel(const char *networkId, int32_t &securityLevel)
{
    std::lock_guard<std::mutex> mutexLock(deviceSecurityLevelMutex_);
    for (const auto &item : deviceSecurityLevel_) {
        if (item.first == std::string(networkId)) {
            securityLevel = item.second;
            LOGI("Get dev level from cache success, networkId is %{public}s.",
                GetAnonyString(std::string(networkId)).c_str());
            return DM_OK;
        }
    }
    int32_t ret = GetDevLevelFromBus(networkId, securityLevel);
    if (ret == DM_OK) {
        LOGI("Get dev level from softbus success.");
        return DM_OK;
    }
    return ret;
}

int32_t SoftbusCache::GetDevLevelFromBus(const char *networkId, int32_t &securityLevel)
{
    int32_t tempSecurityLevel = -1;
    if (GetNodeKeyInfo(DM_PKG_NAME, networkId, NodeDeviceInfoKey::NODE_KEY_DEVICE_SECURITY_LEVEL,
        reinterpret_cast<uint8_t *>(&tempSecurityLevel), LNN_COMMON_LEN) != DM_OK) {
        LOGE("[SOFTBUS]GetNodeKeyInfo networkType failed.");
        return ERR_DM_FAILED;
    }
    CHECK_SIZE_RETURN(deviceSecurityLevel_, ERR_DM_FAILED);
    securityLevel = tempSecurityLevel;
    deviceSecurityLevel_[std::string(networkId)] = tempSecurityLevel;
    LOGI("Get dev level from softbus success, networkId is %{public}s.",
        GetAnonyString(std::string(networkId)).c_str());
    return DM_OK;
}

int32_t SoftbusCache::GetDevInfoByNetworkId(const std::string &networkId, DmDeviceInfo &nodeInfo)
{
    {
        std::lock_guard<std::mutex> mutexLock(deviceInfosMutex_);
        for (const auto &item : deviceInfo_) {
            if (std::string(item.second.second.networkId) == networkId) {
                nodeInfo = item.second.second;
                LOGI("success networkId %{public}s, udid %{public}s.",
                    GetAnonyString(networkId).c_str(), GetAnonyString(item.first).c_str());
                return DM_OK;
            }
        }
    }
    int32_t ret = GetDevInfoFromBus(networkId, nodeInfo);
    if (ret != DM_OK) {
        LOGE("GetDevInfoFromBus failed.");
        return ret;
    }
    SaveDeviceInfo(nodeInfo);
    return DM_OK;
}

int32_t SoftbusCache::GetDevInfoFromBus(const std::string &networkId, DmDeviceInfo &devInfo)
{
    int32_t nodeInfoCount = 0;
    NodeBasicInfo *nodeInfo = nullptr;
    int32_t ret = GetAllNodeDeviceInfo(DM_PKG_NAME, &nodeInfo, &nodeInfoCount);
    if (ret != DM_OK) {
        LOGE("[SOFTBUS]GetAllNodeDeviceInfo failed, ret: %{public}d.", ret);
        return ret;
    }
    for (int32_t i = 0; i < nodeInfoCount; ++i) {
        NodeBasicInfo *nodeBasicInfo = nodeInfo + i;
        if (networkId == std::string(nodeBasicInfo->networkId)) {
            ConvertNodeBasicInfoToDmDevice(*nodeBasicInfo, devInfo);
            break;
        }
    }
    FreeNodeInfo(nodeInfo);
    LOGI("GetDeviceInfo complete, deviceName : %{public}s, deviceTypeId : %{public}d.",
        GetAnonyString(devInfo.deviceName).c_str(), devInfo.deviceTypeId);
    return ret;
}

int32_t SoftbusCache::GetUdidByUdidHash(const std::string &udidHash, std::string &udid)
{
    {
        std::lock_guard<std::mutex> mutexLock(deviceInfosMutex_);
        for (const auto &item : deviceInfo_) {
            if (std::string(item.second.second.deviceId) == udidHash) {
                udid = item.first;
                LOGI("success udid %{public}s.", GetAnonyString(udid).c_str());
                return DM_OK;
            }
        }
    }
    LOGI("failed udidHash %{public}s.", GetAnonyString(udidHash).c_str());
    return ERR_DM_FAILED;
}

int32_t SoftbusCache::GetUuidByUdid(const std::string &udid, std::string &uuid)
{
    {
        std::lock_guard<std::mutex> mutexLock(deviceInfosMutex_);
        if (deviceInfo_.find(udid) != deviceInfo_.end()) {
            uuid = deviceInfo_[udid].first;
            LOGI("success uuid %{public}s.", GetAnonyString(uuid).c_str());
            return DM_OK;
        }
    }
    LOGI("failed udid %{public}s.", GetAnonyString(udid).c_str());
    return ERR_DM_FAILED;
}

int32_t SoftbusCache::GetNetworkIdFromCache(const std::string &udid, std::string &networkId)
{
    {
        std::lock_guard<std::mutex> mutexLock(deviceInfosMutex_);
        if (deviceInfo_.find(udid) != deviceInfo_.end()) {
            networkId = deviceInfo_[udid].second.networkId;
            LOGI("success networkId %{public}s, udid %{public}s.",
                GetAnonyString(networkId).c_str(), GetAnonyString(udid).c_str());
            return DM_OK;
        }
    }
    LOGI("failed udid %{public}s.", GetAnonyString(udid).c_str());
    return ERR_DM_FAILED;
}

int32_t SoftbusCache::GetDeviceNameFromCache(const std::string &udid, std::string &deviceName)
{
    {
        std::lock_guard<std::mutex> mutexLock(deviceInfosMutex_);
        if (deviceInfo_.find(udid) != deviceInfo_.end()) {
            deviceName = deviceInfo_[udid].second.deviceName;
            LOGI("success deviceName: %{public}s, udid: %{public}s.",
                deviceName.c_str(), GetAnonyString(udid).c_str());
            return DM_OK;
        }
    }
    LOGI("failed udid %{public}s.", GetAnonyString(udid).c_str());
    return ERR_DM_FAILED;
}

bool SoftbusCache::CheckIsOnline(const std::string &udidHash)
{
    {
        std::lock_guard<std::mutex> mutexLock(deviceInfosMutex_);
        for (const auto &item : deviceInfo_) {
            LOGI("deviceId %{public}s, cache udidHash %{public}s.", GetAnonyString(udidHash).c_str(),
                GetAnonyString(std::string(item.second.second.deviceId)).c_str());
            if (std::string(item.second.second.deviceId) == udidHash) {
                LOGI("CheckIsOnline is true.");
                return true;
            }
        }
    }
    return false;
}

bool SoftbusCache::CheckIsOnlineByPeerUdid(const std::string &peerUdid)
{
    {
        std::lock_guard<std::mutex> mutexLock(deviceInfosMutex_);
        if (deviceInfo_.find(peerUdid) != deviceInfo_.end()) {
            LOGI("peerUdid %{public}s is online.", GetAnonyString(peerUdid).c_str());
            return true;
        }
    }
    LOGI("peerUdid %{public}s is not online.", GetAnonyString(peerUdid).c_str());
    return false;
}
} // namespace DistributedHardware
} // namespace OHOS