xref: /ohos5.0/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/src/rdb_manager_impl.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.
 */
#define LOG_TAG "RdbManagerImpl"
#include "rdb_manager_impl.h"

#include <thread>

#include "ipc_skeleton.h"
#include "irdb_service.h"
#include "iservice_registry.h"
#include "itypes_util.h"
#include "logger.h"
#include "rdb_errno.h"
#include "rdb_service_proxy.h"
#include "system_ability_definition.h"

namespace OHOS::DistributedRdb {
using namespace OHOS::Rdb;
using RdbServiceProxy =  DistributedRdb::RdbServiceProxy;
using namespace OHOS::NativeRdb;
using namespace OHOS::DistributedRdb::RelationalStore;

class DeathStub : public IRemoteBroker {
public:
    DECLARE_INTERFACE_DESCRIPTOR(u"OHOS.DistributedRdb.DeathStub");
};
class DeathStubImpl : public IRemoteStub<DeathStub> {
};
std::shared_ptr<RdbStoreDataServiceProxy> RdbManagerImpl::GetDistributedDataManager(const std::string &bundleName)
{
    auto manager = SystemAbilityManagerClient::GetInstance().GetSystemAbilityManager();
    if (manager == nullptr) {
        LOG_ERROR("get system ability manager failed.");
        return nullptr;
    }
    auto dataMgr = manager->CheckSystemAbility(DISTRIBUTED_KV_DATA_SERVICE_ABILITY_ID);
    if (dataMgr == nullptr) {
        LOG_ERROR("get distributed data manager failed.");
        return nullptr;
    }
    sptr<RdbStoreDataServiceProxy> dataService = new (std::nothrow) RdbStoreDataServiceProxy(dataMgr);
    if (dataService == nullptr) {
        LOG_ERROR("new RdbStoreDataServiceProxy failed.");
        return nullptr;
    }

    sptr<IRemoteObject> observer = new (std::nothrow) DeathStubImpl();
    dataService->RegisterDeathObserver(bundleName, observer);
    return std::shared_ptr<RdbStoreDataServiceProxy>(dataService.GetRefPtr(), [dataService, observer](const auto *) {});
}

static void LinkToDeath(const sptr<IRemoteObject>& remote)
{
    auto& manager = RdbManagerImpl::GetInstance();
    sptr<RdbManagerImpl::ServiceDeathRecipient> deathRecipient =
        new(std::nothrow) RdbManagerImpl::ServiceDeathRecipient(&manager);
    if (deathRecipient == nullptr) {
        LOG_ERROR("new ServiceDeathRecipient failed.");
        return;
    }
    if (!remote->AddDeathRecipient(deathRecipient)) {
        LOG_ERROR("add death recipient failed.");
    }
}

RdbManagerImpl::RdbManagerImpl()
{
}

RdbManagerImpl::~RdbManagerImpl()
{
    LOG_INFO("destroy.");
}

RdbManagerImpl& RdbManagerImpl::GetInstance()
{
    static RdbManagerImpl manager;
    return manager;
}

std::pair<int32_t, std::shared_ptr<RdbService>> RdbManagerImpl::GetRdbService(const RdbSyncerParam &param)
{
    if (param.bundleName_.empty()) {
        return { E_INVALID_ARGS, nullptr };
    }

    std::lock_guard<std::mutex> lock(mutex_);
    if (rdbService_ != nullptr) {
        return { E_OK, rdbService_ };
    }

    if (distributedDataMgr_ == nullptr) {
        distributedDataMgr_ = GetDistributedDataManager(param.bundleName_);
    }
    if (distributedDataMgr_ == nullptr) {
        LOG_ERROR("get distributed data manager failed.");
        return { E_SERVICE_NOT_FOUND, nullptr };
    }

    auto remote = distributedDataMgr_->GetFeatureInterface(DistributedRdb::RdbService::SERVICE_NAME);
    if (remote == nullptr) {
        LOG_ERROR("get rdb service failed.");
        return { E_NOT_SUPPORT, nullptr };
    }

    if (!remote->IsProxyObject()) {
        return { E_NOT_SUPPORT, nullptr };
    }

    sptr<RdbServiceProxy> rdbService = iface_cast<RdbServiceProxy>(remote);
    if (rdbService == nullptr) {
        rdbService = new (std::nothrow) RdbServiceProxy(remote);
    }

    if (rdbService == nullptr || rdbService->InitNotifier(param) != RDB_OK) {
        LOG_ERROR("init notifier failed.");
        return { E_ERROR, nullptr };
    }

    sptr<IRdbService> serviceBase = rdbService;
    LinkToDeath(serviceBase->AsObject());
    // the rdbService is not null, so rdbService.GetRefPtr() is not null;
    rdbService_ = std::shared_ptr<RdbService>(rdbService.GetRefPtr(), [rdbService](const auto *) {});
    param_ = param;
    return { E_OK, rdbService_ };
}

void RdbManagerImpl::OnRemoteDied()
{
    LOG_INFO("rdb service has dead!");
    if (rdbService_ == nullptr) {
        ResetServiceHandle();
        return;
    }
    auto proxy = std::static_pointer_cast<RdbServiceProxy>(rdbService_);
    auto observers = proxy->ExportObservers();
    ResetServiceHandle();

    std::this_thread::sleep_for(std::chrono::seconds(WAIT_TIME));
    auto [errCode, service] = DistributedRdb::RdbManagerImpl::GetInstance().GetRdbService(param_);
    if (errCode != E_OK) {
        return;
    }
    proxy = std::static_pointer_cast<RdbServiceProxy>(service);
    if (proxy == nullptr) {
        return;
    }
    proxy->ImportObservers(observers);
}

void RdbManagerImpl::ResetServiceHandle()
{
    std::lock_guard<std::mutex> lock(mutex_);
    distributedDataMgr_ = nullptr;
    rdbService_ = nullptr;
}

RdbStoreDataServiceProxy::RdbStoreDataServiceProxy(const sptr<IRemoteObject> &impl)
    : IRemoteProxy<DistributedRdb::IKvStoreDataService>(impl)
{
}

sptr<IRemoteObject> RdbStoreDataServiceProxy::GetFeatureInterface(const std::string &name)
{
    LOG_DEBUG("%{public}s", name.c_str());
    MessageParcel data;
    if (!data.WriteInterfaceToken(RdbStoreDataServiceProxy::GetDescriptor())) {
        LOG_ERROR("write descriptor failed.");
        return nullptr;
    }

    if (!ITypesUtil::Marshal(data, name)) {
        LOG_ERROR("write descriptor failed.");
        return nullptr;
    }

    MessageParcel reply;
    MessageOption mo { MessageOption::TF_SYNC };
    int32_t error = Remote()->SendRequest(
        static_cast<uint32_t>(KvStoreInterfaceCode::GET_FEATURE_INTERFACE), data, reply, mo);
    if (error != 0) {
        LOG_ERROR("SendRequest returned %{public}d", error);
        return nullptr;
    }

    sptr<IRemoteObject> remoteObject;
    if (!ITypesUtil::Unmarshal(reply, remoteObject)) {
        LOG_ERROR("remote object is nullptr.");
        return nullptr;
    }
    return remoteObject;
}

int32_t RdbStoreDataServiceProxy::RegisterDeathObserver(const std::string &bundleName, sptr<IRemoteObject> observer)
{
    MessageParcel data;
    if (!data.WriteInterfaceToken(RdbStoreDataServiceProxy::GetDescriptor())) {
        LOG_ERROR("write descriptor failed.");
        return E_ERROR;
    }

    if (!ITypesUtil::Marshal(data, bundleName, observer)) {
        LOG_ERROR("write descriptor failed.");
        return E_ERROR;
    }

    MessageParcel reply;
    MessageOption mo { MessageOption::TF_SYNC };
    int32_t error = Remote()->SendRequest(
        static_cast<uint32_t>(KvStoreInterfaceCode::REGISTER_DEATH_OBSERVER), data, reply, mo);
    if (error != 0) {
        LOG_ERROR("SendRequest returned %{public}d", error);
        return E_ERROR;
    }

    int32_t status = E_ERROR;
    ITypesUtil::Unmarshal(reply, status);
    return status;
}
} // namespace OHOS::DistributedRdb