OpenHarmony-v4.1-Release/s

/*
 * Copyright (C) 2021-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 "network_search_state.h"

#include <securec.h>

#include "network_search_manager.h"
#include "network_search_notify.h"
#include "telephony_errors.h"
#include "telephony_log_wrapper.h"

namespace OHOS {
namespace Telephony {
NetworkSearchState::NetworkSearchState(const std::weak_ptr<NetworkSearchManager> &networkSearchManager, int32_t slotId)
    : networkSearchManager_(networkSearchManager), slotId_(slotId)
{}

bool NetworkSearchState::Init()
{
    TELEPHONY_LOGI("NetworkSearchState Init slotId:%{public}d", slotId_);
    networkStateOld_ = std::make_unique<NetworkState>();
    if (networkStateOld_ == nullptr) {
        TELEPHONY_LOGE("failed to create old networkState slotId:%{public}d", slotId_);
        return false;
    }
    networkState_ = std::make_unique<NetworkState>();
    if (networkState_ == nullptr) {
        TELEPHONY_LOGE("failed to create new networkState slotId:%{public}d", slotId_);
        return false;
    }
    imsServiceStatus_ = std::make_unique<ImsServiceStatus>();
    if (imsServiceStatus_ == nullptr) {
        TELEPHONY_LOGE("failed to create new imsServiceStatus_ slotId:%{public}d", slotId_);
        return false;
    }
    return true;
}

void NetworkSearchState::SetOperatorInfo(
    const std::string &longName, const std::string &shortName, const std::string &numeric, DomainType domainType)
{
    std::lock_guard<std::mutex> lock(mutex_);
    if (networkState_ != nullptr) {
        networkState_->SetOperatorInfo(longName, shortName, numeric, domainType);
        TELEPHONY_LOGI("NetworkSearchState::SetOperatorInfo longName : %{public}s, shortName : %{public}s, numeric : "
                       "%{public}s, slotId:%{public}d",
            networkState_->GetLongOperatorName().c_str(), networkState_->GetShortOperatorName().c_str(),
            networkState_->GetPlmnNumeric().c_str(), slotId_);
    }
}

void NetworkSearchState::SetEmergency(bool isEmergency)
{
    std::lock_guard<std::mutex> lock(mutex_);
    if (networkState_ != nullptr) {
        networkState_->SetEmergency(isEmergency);
    }
}

bool NetworkSearchState::IsEmergency()
{
    std::lock_guard<std::mutex> lock(mutex_);
    if (networkState_ != nullptr) {
        return networkState_->IsEmergency();
    }
    return false;
}

void NetworkSearchState::SetNetworkType(RadioTech tech, DomainType domainType)
{
    std::lock_guard<std::mutex> lock(mutex_);
    if (networkState_ != nullptr) {
        networkState_->SetNetworkType(tech, domainType);
    }
}

void NetworkSearchState::SetNetworkState(RegServiceState state, DomainType domainType)
{
    std::lock_guard<std::mutex> lock(mutex_);
    if (networkState_ != nullptr) {
        networkState_->SetNetworkState(state, domainType);
    }
}

void NetworkSearchState::SetNetworkStateToRoaming(RoamingType roamingType, DomainType domainType)
{
    std::lock_guard<std::mutex> lock(mutex_);
    if (networkState_ != nullptr) {
        networkState_->SetRoaming(roamingType, domainType);
    }
}

int32_t NetworkSearchState::GetImsStatus(ImsServiceType imsSrvType, ImsRegInfo &info)
{
    std::lock_guard<std::mutex> lock(imsMutex_);
    bool isRegister = false;
    switch (imsSrvType) {
        case ImsServiceType::TYPE_VOICE:
            isRegister = imsRegStatus_ && imsServiceStatus_->supportImsVoice;
            break;
        case ImsServiceType::TYPE_VIDEO:
            isRegister = imsRegStatus_ && imsServiceStatus_->supportImsVideo;
            break;
        case ImsServiceType::TYPE_UT:
            isRegister = imsRegStatus_ && imsServiceStatus_->supportImsUt;
            break;
        case ImsServiceType::TYPE_SMS:
            isRegister = imsRegStatus_ && imsServiceStatus_->supportImsSms;
            break;
        default:
            TELEPHONY_LOGE("%{public}d unkunow ims service type!", imsSrvType);
            return TELEPHONY_ERR_ARGUMENT_INVALID;
    }
    info.imsRegState = isRegister ? ImsRegState::IMS_REGISTERED : ImsRegState::IMS_UNREGISTERED;
    info.imsRegTech = imsServiceStatus_->imsRegTech;
    return TELEPHONY_SUCCESS;
}

void NetworkSearchState::SetImsStatus(bool imsRegStatus)
{
    std::lock_guard<std::mutex> lock(imsMutex_);
    bool imsRegStateChanged = imsRegStatus_ != imsRegStatus;
    if (!imsRegStateChanged) {
        return;
    }
    imsRegStatus_ = imsRegStatus;

    ImsRegInfo imsRegInfo;
    bool isRegister = false;
    imsRegInfo.imsRegTech = imsServiceStatus_->imsRegTech;
    if (imsServiceStatus_->supportImsVoice) {
        isRegister = imsRegStatus_ && imsServiceStatus_->supportImsVoice;
        imsRegInfo.imsRegState = isRegister ? ImsRegState::IMS_REGISTERED : ImsRegState::IMS_UNREGISTERED;
        NotifyImsStateChange(ImsServiceType::TYPE_VOICE, imsRegInfo);
    }
    if (imsServiceStatus_->supportImsVideo) {
        isRegister = imsRegStatus_ && imsServiceStatus_->supportImsVideo;
        imsRegInfo.imsRegState = isRegister ? ImsRegState::IMS_REGISTERED : ImsRegState::IMS_UNREGISTERED;
        NotifyImsStateChange(ImsServiceType::TYPE_VIDEO, imsRegInfo);
    }
    if (imsServiceStatus_->supportImsUt) {
        isRegister = imsRegStatus_ && imsServiceStatus_->supportImsUt;
        imsRegInfo.imsRegState = isRegister ? ImsRegState::IMS_REGISTERED : ImsRegState::IMS_UNREGISTERED;
        NotifyImsStateChange(ImsServiceType::TYPE_UT, imsRegInfo);
    }
    if (imsServiceStatus_->supportImsSms) {
        isRegister = imsRegStatus_ && imsServiceStatus_->supportImsSms;
        imsRegInfo.imsRegState = isRegister ? ImsRegState::IMS_REGISTERED : ImsRegState::IMS_UNREGISTERED;
        NotifyImsStateChange(ImsServiceType::TYPE_SMS, imsRegInfo);
    }
}

void NetworkSearchState::SetImsServiceStatus(const ImsServiceStatus &imsServiceStatus)
{
    std::lock_guard<std::mutex> lock(imsMutex_);
    bool voiceChanged = imsServiceStatus_->supportImsVoice != imsServiceStatus.supportImsVoice;
    bool videoChanged = imsServiceStatus_->supportImsVideo != imsServiceStatus.supportImsVideo;
    bool utChanged = imsServiceStatus_->supportImsUt != imsServiceStatus.supportImsUt;
    bool smsChanged = imsServiceStatus_->supportImsSms != imsServiceStatus.supportImsSms;
    bool radioTechChanged = imsServiceStatus_->imsRegTech != imsServiceStatus.imsRegTech;
    if (!voiceChanged && !videoChanged && !utChanged && !smsChanged && !radioTechChanged) {
        TELEPHONY_LOGI("Nothing need update for slotId:%{public}d", slotId_);
        return;
    }

    *imsServiceStatus_ = imsServiceStatus;

    if (!imsRegStatus_) {
        TELEPHONY_LOGI("Nothing need to do since IMS haven't register");
        return;
    }
    ImsRegInfo imsRegInfo;
    imsRegInfo.imsRegTech = imsServiceStatus.imsRegTech;
    if (voiceChanged || (radioTechChanged && imsServiceStatus_->supportImsVoice)) {
        imsRegInfo.imsRegState = GetImsRegState(ImsServiceType::TYPE_VOICE);
        NotifyImsStateChange(ImsServiceType::TYPE_VOICE, imsRegInfo);
    }
    if (videoChanged || (radioTechChanged && imsServiceStatus_->supportImsVideo)) {
        imsRegInfo.imsRegState = GetImsRegState(ImsServiceType::TYPE_VIDEO);
        NotifyImsStateChange(ImsServiceType::TYPE_VIDEO, imsRegInfo);
    }
    if (utChanged || (radioTechChanged && imsServiceStatus_->supportImsUt)) {
        imsRegInfo.imsRegState = GetImsRegState(ImsServiceType::TYPE_UT);
        NotifyImsStateChange(ImsServiceType::TYPE_UT, imsRegInfo);
    }
    if (smsChanged || (radioTechChanged && imsServiceStatus_->supportImsSms)) {
        imsRegInfo.imsRegState = GetImsRegState(ImsServiceType::TYPE_SMS);
        NotifyImsStateChange(ImsServiceType::TYPE_SMS, imsRegInfo);
    }
}

ImsRegState NetworkSearchState::GetImsRegState(const ImsServiceType type)
{
    bool isRegister = false;
    switch (type) {
        case ImsServiceType::TYPE_VOICE:
            isRegister = imsRegStatus_ && imsServiceStatus_->supportImsVoice;
            break;
        case ImsServiceType::TYPE_VIDEO:
            isRegister = imsRegStatus_ && imsServiceStatus_->supportImsVideo;
            break;
        case ImsServiceType::TYPE_UT:
            isRegister = imsRegStatus_ && imsServiceStatus_->supportImsUt;
            break;
        case ImsServiceType::TYPE_SMS:
            isRegister = imsRegStatus_ && imsServiceStatus_->supportImsSms;
            break;
        default:
            break;
    }
    return isRegister ? ImsRegState::IMS_REGISTERED : ImsRegState::IMS_UNREGISTERED;
}

std::unique_ptr<NetworkState> NetworkSearchState::GetNetworkStatus()
{
    if (networkState_ == nullptr) {
        TELEPHONY_LOGE("GetNetworkStatus networkState_ is null slotId:%{public}d", slotId_);
        return nullptr;
    }
    std::lock_guard<std::mutex> lock(mutex_);
    MessageParcel data;
    networkState_->Marshalling(data);
    std::unique_ptr<NetworkState> networkState = std::make_unique<NetworkState>();
    if (networkState == nullptr) {
        TELEPHONY_LOGE("failed to create new networkState slotId:%{public}d", slotId_);
        return nullptr;
    }
    networkState->ReadFromParcel(data);
    return networkState;
}

void NetworkSearchState::SetInitial()
{
    TELEPHONY_LOGI("NetworkSearchState::SetInitial slotId:%{public}d", slotId_);
    std::lock_guard<std::mutex> lock(mutex_);
    if (networkState_ != nullptr) {
        networkState_->Init();
    }
}

int32_t NetworkSearchState::GetLastCfgTech(RadioTech &tech)
{
    std::lock_guard<std::mutex> lock(mutex_);
    if (networkState_ == nullptr) {
        TELEPHONY_LOGE("networkState_ is null, slotId:%{public}d", slotId_);
        return TELEPHONY_ERR_LOCAL_PTR_NULL;
    }
    tech = networkState_->GetLastCfgTech();
    return TELEPHONY_ERR_SUCCESS;
}

int32_t NetworkSearchState::GetLastPsRadioTech(RadioTech &tech)
{
    std::lock_guard<std::mutex> lock(mutex_);
    if (networkState_ == nullptr) {
        TELEPHONY_LOGE("networkState_ is null, slotId:%{public}d", slotId_);
        return TELEPHONY_ERR_LOCAL_PTR_NULL;
    }
    tech = networkState_->GetLastPsRadioTech();
    return TELEPHONY_ERR_SUCCESS;
}

void NetworkSearchState::SetCfgTech(RadioTech tech)
{
    std::lock_guard<std::mutex> lock(mutex_);
    if (networkState_ != nullptr) {
        networkState_->SetCfgTech(tech);
    }
}

void NetworkSearchState::SetNrState(NrState state)
{
    std::lock_guard<std::mutex> lock(mutex_);
    if (networkState_ != nullptr) {
        TELEPHONY_LOGE("nrState_:%{public}d slotId:%{public}d", state, slotId_);
        networkState_->SetNrState(state);
    }
}

void NetworkSearchState::NotifyPsRegStatusChange()
{
    std::lock_guard<std::mutex> lock(mutex_);
    auto networkSearchManager = networkSearchManager_.lock();
    if (networkSearchManager == nullptr) {
        TELEPHONY_LOGE("NotifyPsRegStatusChange NetworkSearchManager is null slotId:%{public}d", slotId_);
        return;
    }
    if (networkState_ == nullptr) {
        TELEPHONY_LOGE("NotifyPsRegStatusChange networkState_ is null slotId:%{public}d", slotId_);
        return;
    }

    if (networkState_->GetPsRegStatus() == RegServiceState::REG_STATE_IN_SERVICE &&
        networkStateOld_->GetPsRegStatus() != RegServiceState::REG_STATE_IN_SERVICE) {
        networkSearchManager->NotifyPsConnectionAttachedChanged(slotId_);
    }
    if (networkState_->GetPsRegStatus() != RegServiceState::REG_STATE_IN_SERVICE &&
        networkStateOld_->GetPsRegStatus() == RegServiceState::REG_STATE_IN_SERVICE) {
        networkSearchManager->NotifyPsConnectionDetachedChanged(slotId_);
    }
}

void NetworkSearchState::NotifyPsRoamingStatusChange()
{
    std::lock_guard<std::mutex> lock(mutex_);
    auto networkSearchManager = networkSearchManager_.lock();
    if (networkSearchManager == nullptr) {
        TELEPHONY_LOGE("NotifyPsRoamingStatusChange NetworkSearchManager is null slotId:%{public}d", slotId_);
        return;
    }
    if (networkState_ == nullptr) {
        TELEPHONY_LOGE("NotifyPsRoamingStatusChange networkState_ is null slotId:%{public}d", slotId_);
        return;
    }
    if (networkState_->GetPsRoamingStatus() > RoamingType::ROAMING_STATE_UNKNOWN &&
        networkStateOld_->GetPsRoamingStatus() == RoamingType::ROAMING_STATE_UNKNOWN) {
        networkSearchManager->NotifyPsRoamingOpenChanged(slotId_);
    }
    if (networkStateOld_->GetPsRoamingStatus() > RoamingType::ROAMING_STATE_UNKNOWN &&
        networkState_->GetPsRoamingStatus() == RoamingType::ROAMING_STATE_UNKNOWN) {
        networkSearchManager->NotifyPsRoamingCloseChanged(slotId_);
    }
}

void NetworkSearchState::NotifyPsRadioTechChange()
{
    std::lock_guard<std::mutex> lock(mutex_);
    auto networkSearchManager = networkSearchManager_.lock();
    if (networkSearchManager == nullptr) {
        TELEPHONY_LOGE("NotifyPsRadioTechChange NetworkSearchManager is null slotId:%{public}d", slotId_);
        return;
    }
    if (networkState_ == nullptr) {
        TELEPHONY_LOGE("NotifyPsRadioTechChange networkState_ is null slotId:%{public}d", slotId_);
        return;
    }

    if (networkState_->GetPsRadioTech() != networkStateOld_->GetPsRadioTech()) {
        networkSearchManager->SendUpdateCellLocationRequest(slotId_);
        networkSearchManager->NotifyPsRatChanged(slotId_);
    }
}

void NetworkSearchState::NotifyEmergencyChange()
{
    std::lock_guard<std::mutex> lock(mutex_);
    auto networkSearchManager = networkSearchManager_.lock();
    if (networkSearchManager == nullptr) {
        TELEPHONY_LOGE("NotifyEmergencyChange NetworkSearchManager is null slotId:%{public}d", slotId_);
        return;
    }
    if (networkState_ == nullptr) {
        TELEPHONY_LOGE("NotifyEmergencyChange networkState_ is null slotId:%{public}d", slotId_);
        return;
    }
    if (networkState_->IsEmergency() != networkStateOld_->IsEmergency()) {
        if (networkState_->IsEmergency()) {
            networkSearchManager->NotifyEmergencyOpenChanged(slotId_);
        } else {
            networkSearchManager->NotifyEmergencyCloseChanged(slotId_);
        }
    }
}

void NetworkSearchState::NotifyNrStateChange()
{
    std::lock_guard<std::mutex> lock(mutex_);
    auto networkSearchManager = networkSearchManager_.lock();
    if (networkSearchManager == nullptr) {
        TELEPHONY_LOGE("NotifyPsRadioTechChange NetworkSearchManager is null slotId:%{public}d", slotId_);
        return;
    }
    if (networkState_ == nullptr) {
        TELEPHONY_LOGE("NotifyPsRadioTechChange networkState_ is null slotId:%{public}d", slotId_);
        return;
    }

    if (networkState_->GetNrState() != networkStateOld_->GetNrState()) {
        networkSearchManager->NotifyNrStateChanged(slotId_);
    }
}

void NetworkSearchState::NotifyImsStateChange(ImsServiceType imsSrvType, const ImsRegInfo &info)
{
    std::lock_guard<std::mutex> lock(mutex_);
    auto networkSearchManager = networkSearchManager_.lock();
    if (networkSearchManager == nullptr) {
        TELEPHONY_LOGE("networkSearchManager is null slotId:%{public}d", slotId_);
        return;
    }
    if (networkState_ == nullptr) {
        TELEPHONY_LOGE("networkState_ is null slotId:%{public}d", slotId_);
        return;
    }
    networkSearchManager->NotifyImsRegInfoChanged(slotId_, imsSrvType, info);
}

void NetworkSearchState::NotifyStateChange()
{
    TELEPHONY_LOGI("NetworkSearchState::NotifyStateChange slotId:%{public}d", slotId_);
    if (networkState_ == nullptr) {
        TELEPHONY_LOGE("NotifyStateChange networkState_ is null slotId:%{public}d", slotId_);
        return;
    }

    // We must Update RadioTech(PhoneType) bebore notifying observers,
    // otherwise observers may get the wrong phone type
    CsRadioTechChange();

    NotifyPsRadioTechChange();
    NotifyPsRegStatusChange();
    NotifyPsRoamingStatusChange();
    NotifyEmergencyChange();
    NotifyNrStateChange();

    if (!(*networkState_ == *networkStateOld_)) {
        TELEPHONY_LOGI(
            "NetworkSearchState::StateCheck isNetworkStateChange notify to app... slotId:%{public}d", slotId_);
        sptr<NetworkState> ns = new NetworkState;
        if (ns == nullptr) {
            TELEPHONY_LOGE("failed to create networkState slotId:%{public}d", slotId_);
            return;
        }

        MessageParcel data;
        networkState_->Marshalling(data);
        ns->ReadFromParcel(data);
        DelayedSingleton<NetworkSearchNotify>::GetInstance()->NotifyNetworkStateUpdated(slotId_, ns);
        networkState_->Marshalling(data);
        networkStateOld_->ReadFromParcel(data);
    }
}

void NetworkSearchState::CsRadioTechChange()
{
    TELEPHONY_LOGI("NetworkSearchState::CsRadioTechChange slotId:%{public}d", slotId_);
    std::lock_guard<std::mutex> lock(mutex_);
    auto networkSearchManager = networkSearchManager_.lock();
    if (networkSearchManager == nullptr) {
        TELEPHONY_LOGE("CsRadioTechChange NetworkSearchManager is null slotId:%{public}d", slotId_);
        return;
    }
    if (networkState_ == nullptr) {
        TELEPHONY_LOGE("CsRadioTechChange networkState is null slotId:%{public}d", slotId_);
        return;
    }
    if (networkStateOld_ == nullptr) {
        TELEPHONY_LOGE("CsRadioTechChange networkStateOld_ is null slotId:%{public}d", slotId_);
        return;
    }

    if (networkState_->GetCsRadioTech() != networkStateOld_->GetCsRadioTech()) {
        networkSearchManager->UpdatePhone(slotId_, networkState_->GetCsRadioTech(), networkState_->GetPsRadioTech());
    }
}

void NetworkSearchState::SetLongOperatorName(const std::string &longName, DomainType domainType)
{
    std::lock_guard<std::mutex> lock(mutex_);
    if (networkState_ != nullptr) {
        networkState_->SetLongOperatorName(longName, domainType);
        TELEPHONY_LOGD("NetworkSearchState::SetLongOperatorName longName : %{public}s", longName.c_str());
    }
}
} // namespace Telephony
} // namespace OHOS