xref: /ohos5.0/foundation/distributedhardware/distributed_audio/interfaces/inner_kits/native_cpp/audio_source/src/daudio_source_handler.cpp

/*
 * Copyright (c) 2022-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 "daudio_source_handler.h"

#include "if_system_ability_manager.h"
#include "iservice_registry.h"

#include "daudio_constants.h"
#include "daudio_errorcode.h"
#include "daudio_hisysevent.h"
#include "daudio_hitrace.h"
#include "daudio_log.h"
#include "daudio_util.h"
#include "daudio_source_load_callback.h"

#undef DH_LOG_TAG
#define DH_LOG_TAG "DAudioSourceHandler"

namespace OHOS {
namespace DistributedHardware {
IMPLEMENT_SINGLE_INSTANCE(DAudioSourceHandler);
DAudioSourceHandler::DAudioSourceHandler()
{
    DHLOGD("Audio source handler constructed.");
    if (!sourceSvrRecipient_) {
        sourceSvrRecipient_ = sptr<DAudioSourceSvrRecipient>(new DAudioSourceSvrRecipient());
    }

    if (!dAudioIpcCallback_) {
        dAudioIpcCallback_ = sptr<DAudioIpcCallback>(new DAudioIpcCallback());
    }
}

DAudioSourceHandler::~DAudioSourceHandler()
{
    DHLOGD("Audio source handler destructed.");
}

int32_t DAudioSourceHandler::InitSource(const std::string &params)
{
    DHLOGI("Init source handler.");
    if (dAudioSourceProxy_ == nullptr) {
        sptr<ISystemAbilityManager> samgr = SystemAbilityManagerClient::GetInstance().GetSystemAbilityManager();
        CHECK_NULL_RETURN(samgr, ERR_DH_AUDIO_NULLPTR);
        sptr<DAudioSourceLoadCallback> loadCallback = sptr<DAudioSourceLoadCallback>(
            new DAudioSourceLoadCallback(params));
        int32_t ret = samgr->LoadSystemAbility(DISTRIBUTED_HARDWARE_AUDIO_SOURCE_SA_ID, loadCallback);
        if (ret != ERR_OK) {
            DHLOGE("Failed to Load systemAbility, ret code: %{public}d", ret);
            DAudioHisysevent::GetInstance().SysEventWriteFault(DAUDIO_INIT_FAIL,
                DISTRIBUTED_HARDWARE_AUDIO_SOURCE_SA_ID, ERR_DH_AUDIO_SA_LOAD_FAILED,
                "daudio source LoadSystemAbility call failed.");
            return ERR_DH_AUDIO_SA_LOAD_FAILED;
        }
    }

    std::unique_lock<std::mutex> lock(sourceProxyMutex_);
    auto waitStatus = sourceProxyConVar_.wait_for(lock, std::chrono::milliseconds(AUDIO_LOADSA_TIMEOUT_MS),
        [this]() { return dAudioSourceProxy_ != nullptr; });
    if (!waitStatus) {
        DHLOGE("Load audio SA timeout.");
        DAudioHisysevent::GetInstance().SysEventWriteFault(DAUDIO_INIT_FAIL, DISTRIBUTED_HARDWARE_AUDIO_SOURCE_SA_ID,
            ERR_DH_AUDIO_SA_LOAD_FAILED, "daudio source sa load timeout.");
        return ERR_DH_AUDIO_SA_LOAD_FAILED;
    }
    return DH_SUCCESS;
}

int32_t DAudioSourceHandler::ReleaseSource()
{
    DHLOGI("Release source handler.");
    std::lock_guard<std::mutex> lock(sourceProxyMutex_);
    if (dAudioSourceProxy_ == nullptr) {
        DHLOGE("Daudio source proxy not init.");
        DAudioHisysevent::GetInstance().SysEventWriteFault(DAUDIO_INIT_FAIL, DISTRIBUTED_HARDWARE_AUDIO_SOURCE_SA_ID,
            ERR_DH_AUDIO_SA_PROXY_NOT_INIT, "daudio source proxy not init.");
        return ERR_DH_AUDIO_SA_PROXY_NOT_INIT;
    }

    int32_t ret = dAudioSourceProxy_->ReleaseSource();
    dAudioSourceProxy_ = nullptr;
    return ret;
}

int32_t DAudioSourceHandler::RegisterDistributedHardware(const std::string &devId, const std::string &dhId,
    const EnableParam &param, std::shared_ptr<RegisterCallback> callback)
{
    DHLOGI("Register distributed hardware, devId: %{public}s, dhId: %{public}s.",
        GetAnonyString(devId).c_str(), dhId.c_str());
    std::lock_guard<std::mutex> lock(sourceProxyMutex_);
    CHECK_NULL_RETURN(dAudioSourceProxy_, ERR_DH_AUDIO_SA_PROXY_NOT_INIT);
    CHECK_NULL_RETURN(dAudioIpcCallback_, ERR_DH_AUDIO_NULLPTR);
    if (devId.length() > DAUDIO_MAX_DEVICE_ID_LEN || dhId.length() > DAUDIO_MAX_DEVICE_ID_LEN) {
        return ERR_DH_AUDIO_SA_DEVID_ILLEGAL;
    }

    std::string reqId = GetRandomID();
    dAudioIpcCallback_->PushRegisterCallback(reqId, callback);
    std::string reduceDhId = dhId;
    return dAudioSourceProxy_->RegisterDistributedHardware(devId, reduceDhId, param, reqId);
}

int32_t DAudioSourceHandler::UnregisterDistributedHardware(const std::string &devId, const std::string &dhId,
    std::shared_ptr<UnregisterCallback> callback)
{
    DHLOGI("Unregister distributed hardware, devId: %{public}s, dhId: %{public}s.",
        GetAnonyString(devId).c_str(), dhId.c_str());
    std::lock_guard<std::mutex> lock(sourceProxyMutex_);
    CHECK_NULL_RETURN(dAudioSourceProxy_, ERR_DH_AUDIO_SA_PROXY_NOT_INIT);
    CHECK_NULL_RETURN(dAudioIpcCallback_, ERR_DH_AUDIO_NULLPTR);
    if (devId.length() > DAUDIO_MAX_DEVICE_ID_LEN || dhId.length() > DAUDIO_MAX_DEVICE_ID_LEN) {
        return ERR_DH_AUDIO_SA_DEVID_ILLEGAL;
    }

    std::string reqId = GetRandomID();
    dAudioIpcCallback_->PushUnregisterCallback(reqId, callback);
    std::string reduceDhId = dhId;
    return dAudioSourceProxy_->UnregisterDistributedHardware(devId, reduceDhId, reqId);
}

int32_t DAudioSourceHandler::ConfigDistributedHardware(const std::string &devId, const std::string &dhId,
    const std::string &key, const std::string &value)
{
    DHLOGI("Config distributed hardware, devId: %{public}s, dhId: %{public}s.",
        GetAnonyString(devId).c_str(), dhId.c_str());
    std::lock_guard<std::mutex> lock(sourceProxyMutex_);
    CHECK_NULL_RETURN(dAudioSourceProxy_, ERR_DH_AUDIO_SA_PROXY_NOT_INIT);
    if (devId.length() > DAUDIO_MAX_DEVICE_ID_LEN || dhId.length() > DAUDIO_MAX_DEVICE_ID_LEN) {
        return ERR_DH_AUDIO_SA_DEVID_ILLEGAL;
    }
    std::string reduceDhId = dhId;
    return dAudioSourceProxy_->ConfigDistributedHardware(devId, reduceDhId, key, value);
}

void DAudioSourceHandler::RegisterDistributedHardwareStateListener(
    std::shared_ptr<DistributedHardwareStateListener> listener)
{
    CHECK_AND_RETURN_LOG(dAudioIpcCallback_ == nullptr, "%{public}s", "ipc callback is null.");
    dAudioIpcCallback_->RegisterStateListener(listener);
}

void DAudioSourceHandler::UnregisterDistributedHardwareStateListener()
{
    CHECK_AND_RETURN_LOG(dAudioIpcCallback_ == nullptr, "%{public}s", "ipc callback is null.");
    dAudioIpcCallback_->UnRegisterStateListener();
}

void DAudioSourceHandler::RegisterDataSyncTriggerListener(std::shared_ptr<DataSyncTriggerListener> listener)
{
    CHECK_AND_RETURN_LOG(dAudioIpcCallback_ == nullptr, "%{public}s", "ipc callback is null.");
    dAudioIpcCallback_->RegisterTriggerListener(listener);
}

void DAudioSourceHandler::UnregisterDataSyncTriggerListener()
{
    CHECK_AND_RETURN_LOG(dAudioIpcCallback_ == nullptr, "%{public}s", "ipc callback is null.");
    dAudioIpcCallback_->UnRegisterTriggerListener();
}

void DAudioSourceHandler::OnRemoteSourceSvrDied(const wptr<IRemoteObject> &remote)
{
    DHLOGI("The daudio source service died.");
    sptr<IRemoteObject> remoteObject = remote.promote();
    if (!remoteObject) {
        DHLOGE("OnRemoteDied remote promoted failed");
        return;
    }
    std::lock_guard<std::mutex> lock(sourceProxyMutex_);
    if ((dAudioSourceProxy_ != nullptr) && (dAudioSourceProxy_->AsObject() != nullptr)) {
        dAudioSourceProxy_->AsObject()->RemoveDeathRecipient(sourceSvrRecipient_);
        dAudioSourceProxy_ = nullptr;
    }
}

void DAudioSourceHandler::FinishStartSA(const std::string &param, const sptr<IRemoteObject> &remoteObject)
{
    DHLOGI("Finish start SA.");
    std::lock_guard<std::mutex> lock(sourceProxyMutex_);
    if (remoteObject != nullptr) {
        remoteObject->AddDeathRecipient(sourceSvrRecipient_);
    }
    dAudioSourceProxy_ = iface_cast<IDAudioSource>(remoteObject);
    if ((dAudioSourceProxy_ == nullptr) || (!dAudioSourceProxy_->AsObject())) {
        DHLOGE("Failed to get daudio source proxy.");
        DAudioHisysevent::GetInstance().SysEventWriteFault(DAUDIO_INIT_FAIL, DISTRIBUTED_HARDWARE_AUDIO_SOURCE_SA_ID,
            ERR_DH_AUDIO_SA_PROXY_NOT_INIT, "daudio source get proxy failed.");
        return;
    }
    dAudioSourceProxy_->InitSource(param, dAudioIpcCallback_);
    sourceProxyConVar_.notify_one();
    DAudioHisysevent::GetInstance().SysEventWriteBehavior(DAUDIO_INIT, "daudio source sa load success.");
}

void DAudioSourceHandler::DAudioSourceSvrRecipient::OnRemoteDied(const wptr<IRemoteObject> &remote)
{
    DAudioSourceHandler::GetInstance().OnRemoteSourceSvrDied(remote);
}

IDistributedHardwareSource *GetSourceHardwareHandler()
{
    DHLOGI("Get source hardware handler.");
    return &DAudioSourceHandler::GetInstance();
}
} // namespace DistributedHardware
} // namespace OHOS