xref: /ohos5.0/base/telephony/core_service/services/ims_service_interaction/src/ims_core_service_client.cpp

/*
 * 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 "ims_core_service_client.h"

#include "ims_core_service_callback_stub.h"
#include "iservice_registry.h"
#include "system_ability_definition.h"
#include "telephony_errors.h"
#include "telephony_log_wrapper.h"
#include "telephony_types.h"


namespace OHOS {
namespace Telephony {
ImsCoreServiceClient::ImsCoreServiceClient() = default;

ImsCoreServiceClient::~ImsCoreServiceClient()
{
    UnInit();
}

void ImsCoreServiceClient::Init()
{
    TELEPHONY_LOGI("Init start");
    if (IsConnect()) {
        TELEPHONY_LOGE("Init, IsConnect return true");
        return;
    }

    GetImsCoreServiceProxy();
    if (imsCoreServiceProxy_ == nullptr) {
        TELEPHONY_LOGE("Init, get ims core service proxy failed!");
    }

    statusChangeListener_ = new (std::nothrow) SystemAbilityListener();
    if (statusChangeListener_ == nullptr) {
        TELEPHONY_LOGE("Init, failed to create statusChangeListener.");
        return;
    }
    auto managerPtr = SystemAbilityManagerClient::GetInstance().GetSystemAbilityManager();
    if (managerPtr == nullptr) {
        TELEPHONY_LOGE("Init, get system ability manager error.");
        return;
    }
    int32_t ret = managerPtr->SubscribeSystemAbility(TELEPHONY_IMS_SYS_ABILITY_ID,
        statusChangeListener_);
    if (ret) {
        TELEPHONY_LOGE("Init, failed to subscribe sa:%{public}d", TELEPHONY_IMS_SYS_ABILITY_ID);
        return;
    }
    TELEPHONY_LOGI("Init successfully");
}

void ImsCoreServiceClient::UnInit()
{
    Clean();
    if (statusChangeListener_ != nullptr) {
        statusChangeListener_.clear();
        statusChangeListener_ = nullptr;
    }
    handlerMap_.clear();
}

int32_t ImsCoreServiceClient::GetImsRegistrationStatus(int32_t slotId)
{
    if (ReConnectService() != TELEPHONY_SUCCESS) {
        TELEPHONY_LOGE("ipc reconnect failed!");
        return TELEPHONY_ERR_IPC_CONNECT_STUB_FAIL;
    }

    return imsCoreServiceProxy_->GetImsRegistrationStatus(slotId);
}

int32_t ImsCoreServiceClient::GetPhoneNumberFromIMPU(int32_t slotId, std::string &phoneNumber)
{
    if (ReConnectService() != TELEPHONY_SUCCESS) {
        TELEPHONY_LOGE("ipc reconnect failed!");
        return TELEPHONY_ERR_IPC_CONNECT_STUB_FAIL;
    }

    return imsCoreServiceProxy_->GetPhoneNumberFromIMPU(slotId, phoneNumber);
}

sptr<ImsCoreServiceInterface> ImsCoreServiceClient::GetImsCoreServiceProxy()
{
    Utils::UniqueWriteGuard<Utils::RWLock> guard(rwClientLock_);
    if (imsCoreServiceProxy_ != nullptr) {
        return imsCoreServiceProxy_;
    }
    auto managerPtr = SystemAbilityManagerClient::GetInstance().GetSystemAbilityManager();
    if (managerPtr == nullptr) {
        TELEPHONY_LOGE("GetImsCoreServiceProxy return, get system ability manager error.");
        return nullptr;
    }
    auto remoteObjectPtr = managerPtr->CheckSystemAbility(TELEPHONY_IMS_SYS_ABILITY_ID);
    if (remoteObjectPtr == nullptr) {
        TELEPHONY_LOGE("GetImsCoreServiceProxy return, remote service not exists.");
        return nullptr;
    }

    imsCoreServiceProxy_ = iface_cast<ImsCoreServiceInterface>(remoteObjectPtr);
    if (imsCoreServiceProxy_ == nullptr) {
        TELEPHONY_LOGE("GetImsCoreServiceProxy return, iface_cast is nullptr.");
        return nullptr;
    }
    // register callback
    RegisterImsCoreServiceCallback();
    TELEPHONY_LOGI("GetImsCoreServiceProxy success.");
    return imsCoreServiceProxy_;
}

bool ImsCoreServiceClient::IsConnect() const
{
    return (imsCoreServiceProxy_ != nullptr);
}

int32_t ImsCoreServiceClient::RegisterImsCoreServiceCallback()
{
    if (imsCoreServiceProxy_ == nullptr) {
        TELEPHONY_LOGE("imsCoreServiceProxy_ is null!");
        return TELEPHONY_ERR_LOCAL_PTR_NULL;
    }
    imsCoreServiceCallback_ = new ImsCoreServiceCallbackStub();
    int32_t ret = imsCoreServiceProxy_->RegisterImsCoreServiceCallback(imsCoreServiceCallback_);
    if (ret) {
        TELEPHONY_LOGE("RegisterImsCoreServiceCallback return, register callback error.");
        return TELEPHONY_ERR_FAIL;
    }
    for (int32_t slotId = SimSlotId::SIM_SLOT_0; slotId < SIM_SLOT_COUNT; slotId++) {
        if (GetHandler(slotId) != nullptr) {
            GetImsRegistrationStatus(slotId);
        }
    }
    TELEPHONY_LOGI("RegisterImsCoreServiceCallback success.");
    return TELEPHONY_SUCCESS;
}

int32_t ImsCoreServiceClient::RegisterImsCoreServiceCallbackHandler(int32_t slotId,
    const std::shared_ptr<AppExecFwk::EventHandler> &handler)
{
    if (handler == nullptr) {
        TELEPHONY_LOGE("RegisterImsCoreServiceCallbackHandler return, handler is null.");
        return TELEPHONY_ERR_LOCAL_PTR_NULL;
    }

    handlerMap_.insert(std::make_pair(slotId, handler));
    if (IsConnect()) {
        GetImsRegistrationStatus(slotId);
    }
    TELEPHONY_LOGI("RegisterImsCoreServiceCallbackHandler success.");
    return TELEPHONY_SUCCESS;
}

std::shared_ptr<AppExecFwk::EventHandler> ImsCoreServiceClient::GetHandler(int32_t slotId)
{
    auto itor = handlerMap_.find(slotId);
    if (itor != handlerMap_.end()) {
        return itor->second;
    }
    return nullptr;
}

int32_t ImsCoreServiceClient::ReConnectService()
{
    if (imsCoreServiceProxy_ == nullptr) {
        TELEPHONY_LOGI("try to reconnect ims core service now...");
        GetImsCoreServiceProxy();
        if (imsCoreServiceProxy_ == nullptr) {
            TELEPHONY_LOGE("Connect service failed");
            return TELEPHONY_ERR_IPC_CONNECT_STUB_FAIL;
        }
    }
    return TELEPHONY_SUCCESS;
}

void ImsCoreServiceClient::Clean()
{
    Utils::UniqueWriteGuard<Utils::RWLock> guard(rwClientLock_);
    if (imsCoreServiceProxy_ != nullptr) {
        imsCoreServiceProxy_.clear();
        imsCoreServiceProxy_ = nullptr;
    }
    if (imsCoreServiceCallback_ != nullptr) {
        imsCoreServiceCallback_.clear();
        imsCoreServiceCallback_ = nullptr;
    }
}

void ImsCoreServiceClient::SystemAbilityListener::OnAddSystemAbility(int32_t systemAbilityId,
    const std::string& deviceId)
{
    TELEPHONY_LOGI("SA:%{public}d is added!", systemAbilityId);
    if (!CheckInputSysAbilityId(systemAbilityId)) {
        TELEPHONY_LOGE("add SA:%{public}d is invalid!", systemAbilityId);
        return;
    }

    auto imsCoreServiceClient = DelayedSingleton<ImsCoreServiceClient>::GetInstance();
    if (imsCoreServiceClient->IsConnect()) {
        TELEPHONY_LOGI("SA:%{public}d already connected!", systemAbilityId);
        return;
    }

    imsCoreServiceClient->Clean();
    int32_t res = imsCoreServiceClient->ReConnectService();
    if (res != TELEPHONY_SUCCESS) {
        TELEPHONY_LOGE("SA:%{public}d reconnect service failed!", systemAbilityId);
        return;
    }
    TELEPHONY_LOGI("SA:%{public}d reconnect service successfully!", systemAbilityId);
}

void ImsCoreServiceClient::SystemAbilityListener::OnRemoveSystemAbility(int32_t systemAbilityId,
    const std::string& deviceId)
{
    TELEPHONY_LOGI("SA:%{public}d is removed!", systemAbilityId);
    auto imsCoreServiceClient = DelayedSingleton<ImsCoreServiceClient>::GetInstance();
    if (!imsCoreServiceClient->IsConnect()) {
        return;
    }
    imsCoreServiceClient->Clean();
}
} // namespace Telephony
} // namespace OHOS