/*
 * 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 "audio_device_manager.h"
#include "call_ability_connect_callback.h"
#include "call_ability_report_proxy.h"
#include "call_connect_ability.h"
#include "call_object_manager.h"
#include "telephony_log_wrapper.h"
#include "call_superprivacy_control_manager.h"
#include "call_voice_assistant_manager.h"

namespace OHOS {
namespace Telephony {
const int32_t CONNECT_ABILITY_SUCCESS = 0;
const int32_t UNEXPECT_DISCONNECT_CODE = -1;

void CallAbilityConnectCallback::OnAbilityConnectDone(
    const AppExecFwk::ElementName &element, const sptr<IRemoteObject> &remoteObject, int resultCode)
{
    HILOG_COMM_WARN("connect callui result code: %{public}d", resultCode);
    if (resultCode == CONNECT_ABILITY_SUCCESS) {
        DelayedSingleton<CallConnectAbility>::GetInstance()->SetConnectFlag(true);
        DelayedSingleton<CallConnectAbility>::GetInstance()->SetConnectingFlag(false);
        DelayedSingleton<CallConnectAbility>::GetInstance()->NotifyAll();
    
        CallEventInfo eventInfo;
        (void)memset_s(&eventInfo, sizeof(CallEventInfo), 0, sizeof(CallEventInfo));
        auto callSuperPrivacyControlManager = DelayedSingleton<CallSuperPrivacyControlManager>::GetInstance();
        if (callSuperPrivacyControlManager == nullptr) {
            return;
        }
        bool isSuperPrivacyMode = !callSuperPrivacyControlManager->CanCallWithSuperPrivacyPolicy();
        TELEPHONY_LOGI("OnAbilityConnectDone SuperPrivacyMode:%{public}d", isSuperPrivacyMode);
        if (isSuperPrivacyMode) {
            eventInfo.eventId = CallAbilityEventId::EVENT_IS_SUPER_PRIVACY_MODE_ON;
        } else {
            eventInfo.eventId = CallAbilityEventId::EVENT_IS_SUPER_PRIVACY_MODE_OFF;
        }
        DelayedSingleton<CallAbilityReportProxy>::GetInstance()->CallEventUpdated(eventInfo);
        DelayedSingleton<AudioDeviceManager>::GetInstance()->UpdateEarpieceDevice();
        CallVoiceAssistantManager::GetInstance()->PublishCommonEvent(true, std::string("call_ui_connect_done"));
    }
}

void CallAbilityConnectCallback::OnAbilityDisconnectDone(const AppExecFwk::ElementName &element, int resultCode)
{
    TELEPHONY_LOGW("disconnect callui result code: %{public}d", resultCode);
    DelayedSingleton<CallConnectAbility>::GetInstance()->SetConnectFlag(false);
    DelayedSingleton<CallConnectAbility>::GetInstance()->SetDisconnectingFlag(false);
    if (resultCode == UNEXPECT_DISCONNECT_CODE) {
        ReConnectAbility();
    }
}

void CallAbilityConnectCallback::ReConnectAbility()
{
    TELEPHONY_LOGI("ReConnectAbility");
    if (!CallObjectManager::HasCallExist()) {
        TELEPHONY_LOGE("callObjectPtrList_ is empty, no need to report");
        return;
    }
    std::vector<CallAttributeInfo> callAttributeInfo = CallObjectManager::GetAllCallInfoList();
    std::vector<CallAttributeInfo>::iterator it = callAttributeInfo.begin();
    while (it != callAttributeInfo.end()) {
        CallAttributeInfo info = (*it);
        TelCallState callState = info.callState;
        it++;
        if (callState == TelCallState::CALL_STATUS_DISCONNECTING ||
            callState == TelCallState::CALL_STATUS_DISCONNECTED ||
            callState == TelCallState::CALL_STATUS_UNKNOWN || callState == TelCallState::CALL_STATUS_IDLE) {
            TELEPHONY_LOGE("no need to report");
            continue;
        }
        DelayedSingleton<CallConnectAbility>::GetInstance()->ConnectAbility();
        return;
    }
}
} // namespace Telephony
} // namespace OHOS