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

#include "dm_anonymous.h"
#include "dm_crypto.h"
#include "dm_log.h"
#include "dm_radar_helper.h"
#include "nlohmann/json.hpp"

namespace OHOS {
namespace DistributedHardware {
constexpr int32_t SESSION_SIDE_SERVER = 0;
constexpr int32_t SESSION_ID_INVALID = -1;
constexpr int32_t REPLY_SUCCESS = 0;
constexpr int32_t REPLY_FAILED = -1;

constexpr int32_t MSG_TYPE_CREATE_PIN_HOLDER = 600;
constexpr int32_t MSG_TYPE_CREATE_PIN_HOLDER_RESP = 601;
constexpr int32_t MSG_TYPE_DESTROY_PIN_HOLDER = 650;
constexpr int32_t MSG_TYPE_DESTROY_PIN_HOLDER_RESP = 651;
constexpr int32_t MSG_TYPE_PIN_HOLDER_CHANGE = 700;
constexpr int32_t MSG_TYPE_PIN_HOLDER_CHANGE_RESP = 701;
constexpr int32_t MSG_TYPE_PIN_CLOSE_SESSION = 800;

constexpr const char* PINHOLDER_CREATE_TIMEOUT_TASK = "deviceManagerTimer:pinholdercreate";
constexpr int32_t PIN_HOLDER_SESSION_CREATE_TIMEOUT = 60;

constexpr const char* TAG_PIN_TYPE = "PIN_TYPE";
constexpr const char* TAG_PAYLOAD = "PAYLOAD";
constexpr const char* TAG_REPLY = "REPLY";
constexpr const char* TAG_REMOTE_DEVICE_ID = "REMOTE_DEVICE_ID";

constexpr int32_t DM_OK = 0;
constexpr int32_t ERR_DM_FAILED = 96929744;
constexpr int32_t ERR_DM_TIME_OUT = 96929745;
constexpr int32_t ERR_DM_CREATE_PIN_HOLDER_BUSY = 96929821;
constexpr const char* TAG_MSG_TYPE = "MSG_TYPE";
constexpr const char* TAG_DM_VERSION = "DM_VERSION";
constexpr const char* DM_CONNECTION_DISCONNECTED = "DM_CONNECTION_DISCONNECTED";
constexpr int32_t DEVICE_UUID_LENGTH = 65;
constexpr int32_t ERR_DM_INPUT_PARA_INVALID = 96929749;
constexpr int32_t ERR_DM_BIND_PEER_UNSUPPORTED = 96929802;
PinHolder::PinHolder(std::shared_ptr<IDeviceManagerServiceListener> listener): listener_(listener)
{
    if (session_ == nullptr) {
        session_ = std::make_shared<PinHolderSession>();
    }
    if (timer_ == nullptr) {
        timer_ = std::make_shared<DmTimer>();
    }
    sinkState_ = SINK_INIT;
    sourceState_ = SOURCE_INIT;
}

PinHolder::~PinHolder()
{
    if (session_ != nullptr) {
        session_->UnRegisterSessionCallback();
        session_ = nullptr;
    }
    if (timer_ != nullptr) {
        timer_->DeleteAll();
        timer_ = nullptr;
    }
}

int32_t PinHolder::RegisterPinHolderCallback(const std::string &pkgName)
{
    if (session_ == nullptr) {
        LOGE("RegisterPinHolderCallback session is nullptr.");
        return ERR_DM_FAILED;
    }
    registerPkgName_ = pkgName;
    session_->RegisterSessionCallback(shared_from_this());
    return DM_OK;
}

int32_t PinHolder::CreatePinHolder(const std::string &pkgName,
    const PeerTargetId &targetId, DmPinType pinType, const std::string &payload)
{
    LOGI("CreatePinHolder.");
    if (registerPkgName_.empty() || registerPkgName_ != pkgName) {
        LOGE("CreatePinHolder pkgName: %{public}s is not register callback.", pkgName.c_str());
        return ERR_DM_FAILED;
    }
    int32_t ret = CheckTargetIdVaild(targetId);
    if (ret != DM_OK) {
        LOGE("CreatePinHolder targetId is invalid.");
        return ret;
    }
    if (listener_ == nullptr || session_ == nullptr) {
        LOGE("CreatePinHolder listener or session is nullptr.");
        return ERR_DM_FAILED;
    }
    if (sourceState_ != SOURCE_INIT) {
        LOGE("CreatePinHolder failed, state is %{public}d.", sourceState_);
        return ERR_DM_FAILED;
    }
    if (sessionId_ != SESSION_ID_INVALID) {
        LOGI("CreatePinHolder session already create, sessionId: %{public}d.", sessionId_);
        CreateGeneratePinHolderMsg();
        return DM_OK;
    }

    sessionId_ = session_->OpenSessionServer(targetId);
    int32_t stageRes =
        sessionId_ > 0 ? static_cast<int32_t>(StageRes::STAGE_SUCC) : static_cast<int32_t>(StageRes::STAGE_FAIL);
    DmRadarHelper::GetInstance().ReportCreatePinHolder(
        registerPkgName_, sessionId_, targetId.deviceId, sessionId_, stageRes);
    if (sessionId_ < 0) {
        LOGE("[SOFTBUS]open session error, sessionId: %{public}d.", sessionId_);
        listener_->OnCreateResult(registerPkgName_, sessionId_);
        listener_->OnPinHolderEvent(registerPkgName_, DmPinHolderEvent::CREATE_RESULT,
            sessionId_, "");
        sessionId_ = SESSION_ID_INVALID;
        return sessionId_;
    }
    pinType_ = pinType;
    payload_ = payload;
    return DM_OK;
}

int32_t PinHolder::DestroyPinHolder(const std::string &pkgName, const PeerTargetId &targetId, DmPinType pinType,
    const std::string &payload)
{
    LOGI("DestroyPinHolder.");
    if (listener_ == nullptr || session_ == nullptr) {
        LOGE("DestroyPinHolder listener or session is nullptr.");
        return ERR_DM_FAILED;
    }
    if (registerPkgName_.empty() || pkgName != registerPkgName_) {
        LOGE("DestroyPinHolder pkgName: %{public}s is not register callback.", pkgName.c_str());
        return ERR_DM_FAILED;
    }
    int32_t ret = CheckTargetIdVaild(targetId);
    if (ret != DM_OK) {
        LOGE("DestroyPinHolder targetId is invalid.");
        return ret;
    }
    if (sessionId_ == SESSION_ID_INVALID) {
        LOGI("DestroyPinHolder session already destroy.");
        listener_->OnDestroyResult(registerPkgName_, ret);
        listener_->OnPinHolderEvent(registerPkgName_, DmPinHolderEvent::DESTROY_RESULT, ret, "");
        return ret;
    }
    if (sourceState_ != SOURCE_CREATE) {
        LOGE("DestroyPinHolder failed, state is %{public}d.", sourceState_);
        return ERR_DM_FAILED;
    }
    if (timer_ != nullptr) {
        timer_->DeleteTimer(PINHOLDER_CREATE_TIMEOUT_TASK);
    }

    nlohmann::json jsonObj;
    jsonObj[TAG_MSG_TYPE] = MSG_TYPE_DESTROY_PIN_HOLDER;
    jsonObj[TAG_PIN_TYPE] = pinType;
    jsonObj[TAG_PAYLOAD] = payload;
    pinType_ = pinType;
    std::string message = jsonObj.dump();
    LOGI("DestroyPinHolder, message type is: %{public}d, pin type is: %{public}d.", MSG_TYPE_DESTROY_PIN_HOLDER,
        pinType);
    ret = session_->SendData(sessionId_, message);
    int32_t stageRes =
        ret == DM_OK ? static_cast<int32_t>(StageRes::STAGE_SUCC) : static_cast<int32_t>(StageRes::STAGE_FAIL);
    DmRadarHelper::GetInstance().ReportDestroyPinHolder(registerPkgName_,
        targetId.deviceId, ret, stageRes);
    if (ret != DM_OK) {
        LOGE("[SOFTBUS]SendBytes failed, ret: %{public}d.", ret);
        listener_->OnDestroyResult(registerPkgName_, ERR_DM_FAILED);
        listener_->OnPinHolderEvent(registerPkgName_, DmPinHolderEvent::DESTROY_RESULT, ERR_DM_FAILED, "");
        return ret;
    }
    return ret;
}

int32_t PinHolder::CreateGeneratePinHolderMsg()
{
    if (listener_ == nullptr || session_ == nullptr) {
        LOGE("CreateGeneratePinHolderMsg listener or session is nullptr.");
        return ERR_DM_FAILED;
    }
    if (timer_ != nullptr) {
        timer_->DeleteAll();
        timer_->StartTimer(std::string(PINHOLDER_CREATE_TIMEOUT_TASK), PIN_HOLDER_SESSION_CREATE_TIMEOUT,
            [this] (std::string name) {
                PinHolder::CloseSession(name);
            });
    }
    nlohmann::json jsonObj;
    jsonObj[TAG_PIN_TYPE] = pinType_;
    jsonObj[TAG_PAYLOAD] = payload_;
    jsonObj[TAG_MSG_TYPE] = MSG_TYPE_CREATE_PIN_HOLDER;
    jsonObj[TAG_DM_VERSION] = "";
    std::string message = jsonObj.dump();
    LOGI("CreateGeneratePinHolderMsg, message type is: %{public}d, pin type is: %{public}d.",
        MSG_TYPE_CREATE_PIN_HOLDER, pinType_);
    int32_t ret = session_->SendData(sessionId_, message);
    int32_t bizStage = static_cast<int32_t>(PinHolderStage::SEND_CREATE_PIN_HOLDER_MSG);
    DmRadarHelper::GetInstance().ReportSendOrReceiveHolderMsg(bizStage,
        std::string("CreateGeneratePinHolderMsg"), "");
    if (ret != DM_OK) {
        LOGE("[SOFTBUS]SendBytes failed, ret: %{public}d.", ret);
        listener_->OnCreateResult(registerPkgName_, ret);
        listener_->OnPinHolderEvent(registerPkgName_, DmPinHolderEvent::CREATE_RESULT, ret, "");
        return ret;
    }
    return ret;
}

int32_t PinHolder::ParseMsgType(const std::string &message)
{
    nlohmann::json jsonObject = nlohmann::json::parse(message, nullptr, false);
    if (jsonObject.is_discarded()) {
        LOGE("ParseMsgType DecodeRequest jsonStr error");
        return ERR_DM_FAILED;
    }
    if (!IsInt32(jsonObject, TAG_MSG_TYPE)) {
        LOGE("ParseMsgType err json string.");
        return ERR_DM_FAILED;
    }
    int32_t msgType = jsonObject[TAG_MSG_TYPE].get<int32_t>();
    return msgType;
}

void PinHolder::ProcessCloseSessionMsg(const std::string &message)
{
    if (listener_ == nullptr || session_ == nullptr) {
        LOGE("ProcessCloseSessionMsg listener or session is nullptr.");
        return;
    }
    LOGI("CloseSessionMsg, message type is: %{public}d.", MSG_TYPE_PIN_CLOSE_SESSION);
    session_->CloseSessionServer(sessionId_);
    sessionId_ = SESSION_ID_INVALID;
    sourceState_ = SOURCE_INIT;
    sinkState_ = SINK_INIT;
    listener_->OnCreateResult(registerPkgName_, ERR_DM_CREATE_PIN_HOLDER_BUSY);
}

void PinHolder::ProcessCreateMsg(const std::string &message)
{
    if (listener_ == nullptr || session_ == nullptr) {
        LOGE("ProcessCreateMsg listener or session is nullptr.");
        return;
    }
    nlohmann::json jsonObject = nlohmann::json::parse(message, nullptr, false);
    if (jsonObject.is_discarded()) {
        LOGE("ProcessCreateMsg DecodeRequest jsonStr error");
        return;
    }
    if (!IsInt32(jsonObject, TAG_PIN_TYPE) || !IsString(jsonObject, TAG_PAYLOAD)) {
        LOGE("ProcessCreateMsg err json string.");
        return;
    }
    DmPinType pinType = static_cast<DmPinType>(jsonObject[TAG_PIN_TYPE].get<int32_t>());
    std::string payload = jsonObject[TAG_PAYLOAD].get<std::string>();
    isRemoteSupported_ = jsonObject.contains(TAG_DM_VERSION);
    int32_t bizStage = static_cast<int32_t>(PinHolderStage::RECEIVE_CREATE_PIN_HOLDER_MSG);
    DmRadarHelper::GetInstance().ReportSendOrReceiveHolderMsg(bizStage, std::string("ProcessCreateMsg"), "");
    nlohmann::json jsonObj;
    jsonObj[TAG_MSG_TYPE] = MSG_TYPE_CREATE_PIN_HOLDER_RESP;
    if (sinkState_ != SINK_INIT) {
        jsonObj[TAG_REPLY] = REPLY_FAILED;
    } else {
        jsonObj[TAG_REPLY] = REPLY_SUCCESS;
        sinkState_ = SINK_CREATE;
        sourceState_ = SOURCE_CREATE;
        listener_->OnPinHolderCreate(registerPkgName_, remoteDeviceId_, pinType, payload);
        nlohmann::json jsonContent;
        jsonContent[TAG_PIN_TYPE] = pinType;
        jsonContent[TAG_PAYLOAD] = payload;
        jsonContent[TAG_REMOTE_DEVICE_ID] = remoteDeviceId_;
        std::string content = jsonContent.dump();
        listener_->OnPinHolderEvent(registerPkgName_, DmPinHolderEvent::CREATE, DM_OK, content);
    }
    jsonObj[TAG_DM_VERSION] = "";

    std::string msg = jsonObj.dump();
    LOGI("ProcessCreateMsg, message type is: %{public}d.", MSG_TYPE_CREATE_PIN_HOLDER_RESP);
    int32_t ret = session_->SendData(sessionId_, msg);
    if (ret != DM_OK) {
        LOGE("[SOFTBUS]SendBytes failed, ret: %{public}d.", ret);
        return;
    }
}

void PinHolder::ProcessCreateRespMsg(const std::string &message)
{
    nlohmann::json jsonObject = nlohmann::json::parse(message, nullptr, false);
    if (jsonObject.is_discarded()) {
        LOGE("ProcessCreateRespMsg DecodeRequest jsonStr error.");
        return;
    }
    if (!IsInt32(jsonObject, TAG_REPLY)) {
        LOGE("ProcessCreateRespMsg err json string.");
        return;
    }
    isRemoteSupported_ = jsonObject.contains(TAG_DM_VERSION);
    int32_t reply = jsonObject[TAG_REPLY].get<int32_t>();
    if (listener_ == nullptr || session_ == nullptr) {
        LOGE("ProcessCreateRespMsg listener or session is nullptr.");
        return;
    }
    if (reply == REPLY_SUCCESS) {
        listener_->OnCreateResult(registerPkgName_, DM_OK);
        listener_->OnPinHolderEvent(registerPkgName_, DmPinHolderEvent::CREATE_RESULT, DM_OK, "");
        sourceState_ = SOURCE_CREATE;
        sinkState_ = SINK_CREATE;
    } else {
        LOGE("ProcessCreateRespMsg remote state is wrong.");
        listener_->OnCreateResult(registerPkgName_, ERR_DM_FAILED);
        listener_->OnPinHolderEvent(registerPkgName_, DmPinHolderEvent::CREATE_RESULT, ERR_DM_FAILED, "");
        session_->CloseSessionServer(sessionId_);
        sessionId_ = SESSION_ID_INVALID;
        destroyState_ = STATE_REMOTE_WRONG;
        sourceState_ = SOURCE_INIT;
        sinkState_ = SINK_INIT;
    }
}

void PinHolder::ProcessDestroyMsg(const std::string &message)
{
    if (listener_ == nullptr || session_ == nullptr) {
        LOGE("ProcessDestroyMsg listener or session is nullptr.");
        return;
    }
    nlohmann::json jsonObject = nlohmann::json::parse(message, nullptr, false);
    if (jsonObject.is_discarded()) {
        LOGE("ProcessDestroyMsg DecodeRequest jsonStr error.");
        return;
    }
    if (!IsInt32(jsonObject, TAG_PIN_TYPE) || !IsString(jsonObject, TAG_PAYLOAD)) {
        LOGE("ProcessDestroyMsg err json string.");
        return;
    }
    DmPinType pinType = static_cast<DmPinType>(jsonObject[TAG_PIN_TYPE].get<int32_t>());
    std::string payload = jsonObject[TAG_PAYLOAD].get<std::string>();
    int32_t bizStage = static_cast<int32_t>(PinHolderStage::RECEIVE_DESTROY_PIN_HOLDER_MSG);
    DmRadarHelper::GetInstance().ReportSendOrReceiveHolderMsg(bizStage, std::string("ProcessDestroyMsg"), "");
    nlohmann::json jsonObj;
    jsonObj[TAG_MSG_TYPE] = MSG_TYPE_DESTROY_PIN_HOLDER_RESP;
    if (sinkState_ != SINK_CREATE) {
        jsonObj[TAG_REPLY] = REPLY_FAILED;
    } else {
        jsonObj[TAG_REPLY] = REPLY_SUCCESS;
        sinkState_ = SINK_INIT;
        sourceState_ = SOURCE_INIT;
        if (!isDestroy_.load()) {
            listener_->OnPinHolderDestroy(registerPkgName_, pinType, payload);
            nlohmann::json jsonContent;
            jsonContent[TAG_PIN_TYPE] = pinType;
            jsonContent[TAG_PAYLOAD] = payload;
            std::string content = jsonContent.dump();
            listener_->OnPinHolderEvent(registerPkgName_, DmPinHolderEvent::DESTROY, DM_OK, content);
            isDestroy_.store(true);
        }
    }

    std::string msg = jsonObj.dump();
    LOGI("ProcessDestroyMsg, message type is: %{public}d.", MSG_TYPE_DESTROY_PIN_HOLDER_RESP);
    int32_t ret = session_->SendData(sessionId_, msg);
    if (ret != DM_OK) {
        LOGE("[SOFTBUS]SendBytes failed, ret: %{public}d.", ret);
        return;
    }
}

void PinHolder::CloseSession(const std::string &name)
{
    LOGI("PinHolder::CloseSession start timer name %{public}s.", name.c_str());
    if (session_ == nullptr) {
        LOGE("CloseSession session is nullptr.");
        return;
    }
    nlohmann::json jsonObj;
    jsonObj[DM_CONNECTION_DISCONNECTED] = true;
    std::string payload = jsonObj.dump();
    if (listener_ != nullptr && !isDestroy_.load()) {
        listener_->OnPinHolderDestroy(registerPkgName_, pinType_, payload);
        nlohmann::json jsonContent;
        jsonContent[TAG_PIN_TYPE] = pinType_;
        jsonContent[TAG_PAYLOAD] = payload;
        std::string content = jsonContent.dump();
        listener_->OnPinHolderEvent(registerPkgName_, DmPinHolderEvent::DESTROY, ERR_DM_TIME_OUT, content);
        isDestroy_.store(true);
    }
    session_->CloseSessionServer(sessionId_);
    if (timer_ != nullptr) {
        timer_->DeleteAll();
    }
    destroyState_ = STATE_TIME_OUT;
    sessionId_ = SESSION_ID_INVALID;
    sinkState_ = SINK_INIT;
    sourceState_ = SOURCE_INIT;
    remoteDeviceId_ = "";
    isRemoteSupported_ = false;
}

void PinHolder::ProcessDestroyResMsg(const std::string &message)
{
    nlohmann::json jsonObject = nlohmann::json::parse(message, nullptr, false);
    if (jsonObject.is_discarded()) {
        LOGE("ProcessDestroyResMsg DecodeRequest jsonStr error.");
        return;
    }
    if (!IsInt32(jsonObject, TAG_REPLY)) {
        LOGE("ProcessDestroyResMsg err json string.");
        return;
    }
    int32_t reply = jsonObject[TAG_REPLY].get<int32_t>();
    if (listener_ == nullptr || session_ == nullptr) {
        LOGE("ProcessDestroyResMsg listener or session is nullptr.");
        return;
    }
    if (reply == REPLY_SUCCESS) {
        listener_->OnDestroyResult(registerPkgName_, DM_OK);
        listener_->OnPinHolderEvent(registerPkgName_, DmPinHolderEvent::DESTROY_RESULT, DM_OK, "");
        sourceState_ = SOURCE_INIT;
        sinkState_ = SINK_INIT;
        if (timer_ != nullptr) {
            timer_->DeleteAll();
        }
    } else {
        LOGE("ProcessDestroyResMsg remote state is wrong.");
        listener_->OnDestroyResult(registerPkgName_, ERR_DM_FAILED);
        listener_->OnPinHolderEvent(registerPkgName_, DmPinHolderEvent::DESTROY_RESULT, ERR_DM_FAILED, "");
        sinkState_ = SINK_INIT;
        sourceState_ = SOURCE_INIT;
    }
    session_->CloseSessionServer(sessionId_);
    sessionId_ = SESSION_ID_INVALID;
    remoteDeviceId_ = "";
}

void PinHolder::OnDataReceived(int32_t sessionId, std::string message)
{
    int32_t msgType = ParseMsgType(message);
    LOGI("OnDataReceived, msgType: %{public}d.", msgType);
    int32_t sessionSide = GetSessionSide(sessionId);
    if (sessionSide == SESSION_SIDE_SERVER && sessionId != sessionId_) {
        LOGE("another session opened, close this sessionId: %{public}d.", sessionId);
        nlohmann::json jsonObj;
        jsonObj[TAG_MSG_TYPE] = MSG_TYPE_PIN_CLOSE_SESSION;
        std::string msg = jsonObj.dump();
        int32_t ret = session_->SendData(sessionId, msg);
        if (ret != DM_OK) {
            LOGE("[SOFTBUS] SendBytes failed. ret: %{public}d.", ret);
            listener_->OnPinHolderEvent(registerPkgName_, DmPinHolderEvent::CREATE_RESULT, ERR_DM_FAILED, "");
        }
        return;
    }
    switch (msgType) {
        case MSG_TYPE_PIN_CLOSE_SESSION:
            ProcessCloseSessionMsg(message);
            break;
        case MSG_TYPE_CREATE_PIN_HOLDER:
            ProcessCreateMsg(message);
            break;
        case MSG_TYPE_CREATE_PIN_HOLDER_RESP:
            ProcessCreateRespMsg(message);
            break;
        case MSG_TYPE_DESTROY_PIN_HOLDER:
            ProcessDestroyMsg(message);
            break;
        case MSG_TYPE_DESTROY_PIN_HOLDER_RESP:
            ProcessDestroyResMsg(message);
            break;
        case MSG_TYPE_PIN_HOLDER_CHANGE:
            ProcessChangeMsg(message);
            break;
        case MSG_TYPE_PIN_HOLDER_CHANGE_RESP:
            ProcessChangeRespMsg(message);
            break;
        default:
            break;
    }
}

void PinHolder::GetPeerDeviceId(int32_t sessionId, std::string &udidHash)
{
    char peerDeviceId[DEVICE_UUID_LENGTH] = {0};
    int32_t ret = ::GetPeerDeviceId(sessionId, &peerDeviceId[0], DEVICE_UUID_LENGTH);
    if (ret != DM_OK) {
        LOGE("[SOFTBUS]GetPeerDeviceId failed for session: %{public}d.", sessionId);
        udidHash = "";
        return;
    }
    std::string deviceId = peerDeviceId;
    char udidHashTmp[DM_MAX_DEVICE_ID_LEN] = {0};
    if (Crypto::GetUdidHash(deviceId, reinterpret_cast<uint8_t *>(udidHashTmp)) != DM_OK) {
        LOGE("get udidhash by udid: %{public}s failed.", GetAnonyString(deviceId).c_str());
        udidHash = "";
        return;
    }
    udidHash = udidHashTmp;
    LOGI("GetPeerDeviceId udid hash: %{public}s success.", GetAnonyString(udidHash).c_str());
}

void PinHolder::OnSessionOpened(int32_t sessionId, int32_t sessionSide, int32_t result)
{
    isDestroy_.store(false);
    destroyState_ = STATE_UNKNOW;
    char peerDeviceId[DEVICE_UUID_LENGTH] = {0};
    int32_t ret = ::GetPeerDeviceId(sessionId, &peerDeviceId[0], DEVICE_UUID_LENGTH);
    if (ret != DM_OK) {
        LOGE("[SOFTBUS]GetPeerDeviceId failed for session: %{public}d.", sessionId);
    }
    DmRadarHelper::GetInstance().ReportSendOrReceiveHolderMsg(static_cast<int32_t>(PinHolderStage::SESSION_OPENED),
        std::string("OnSessionOpened"), std::string(peerDeviceId));
    if (sessionSide == SESSION_SIDE_SERVER) {
        LOGI("[SOFTBUS]onSesssionOpened success, side is sink. sessionId: %{public}d.", sessionId);
        GetPeerDeviceId(sessionId, remoteDeviceId_);
        if (sessionId_ == SESSION_ID_INVALID) {
            sessionId_ = sessionId;
        }
        return;
    }
    sessionId_ = sessionId;
    if (result == DM_OK) {
        CreateGeneratePinHolderMsg();
        return;
    }
    LOGE("[SOFTBUS]onSesssionOpened failed. sessionId: %{public}d.", sessionId);
    sessionId_ = SESSION_ID_INVALID;
    if (listener_ != nullptr) {
        listener_->OnCreateResult(registerPkgName_, result);
        listener_->OnPinHolderEvent(registerPkgName_, DmPinHolderEvent::CREATE_RESULT, result, "");
    }
    return;
}

void PinHolder::OnSessionClosed(int32_t sessionId)
{
    if (sessionId != sessionId_) {
        return;
    }
    LOGI("[SOFTBUS]OnSessionClosed sessionId: %{public}d.", sessionId);
    sessionId_ = SESSION_ID_INVALID;
    sinkState_ = SINK_INIT;
    sourceState_ = SOURCE_INIT;
    remoteDeviceId_ = "";
    isRemoteSupported_ = false;
    nlohmann::json jsonObj;
    jsonObj[DM_CONNECTION_DISCONNECTED] = true;
    std::string payload = jsonObj.dump();
    if (listener_ != nullptr && !isDestroy_.load()) {
        listener_->OnPinHolderDestroy(registerPkgName_, pinType_, payload);
        nlohmann::json jsonContent;
        jsonContent[TAG_PIN_TYPE] = pinType_;
        jsonContent[TAG_PAYLOAD] = payload;
        std::string content = jsonContent.dump();
        if (destroyState_ == STATE_UNKNOW) {
            listener_->OnPinHolderEvent(registerPkgName_, DmPinHolderEvent::DESTROY, sessionId, content);
        } else if (destroyState_ == STATE_REMOTE_WRONG) {
            listener_->OnPinHolderEvent(registerPkgName_, DmPinHolderEvent::DESTROY, ERR_DM_FAILED, content);
        } else if (destroyState_ == STATE_TIME_OUT) {
            listener_->OnPinHolderEvent(registerPkgName_, DmPinHolderEvent::DESTROY, ERR_DM_TIME_OUT, content);
        }
        isDestroy_.store(true);
    }
    if (timer_ != nullptr) {
        timer_->DeleteAll();
    }
    return;
}

int32_t PinHolder::CheckTargetIdVaild(const PeerTargetId &targetId)
{
    if (targetId.deviceId.empty() && targetId.brMac.empty() && targetId.bleMac.empty() && targetId.wifiIp.empty()) {
        LOGE("CheckTargetIdVaild failed. targetId is empty.");
        return ERR_DM_INPUT_PARA_INVALID;
    }
    return DM_OK;
}

int32_t PinHolder::NotifyPinHolderEvent(const std::string &pkgName, const std::string &event)
{
    LOGI("NotifyPinHolderEvent.");
    if (listener_ == nullptr || session_ == nullptr) {
        LOGE("NotifyPinHolderEvent listener or session is nullptr.");
        return ERR_DM_FAILED;
    }
    if (registerPkgName_.empty() || pkgName != registerPkgName_ || event.empty()) {
        LOGE("NotifyPinHolderEvent pkgName: %{public}s is not register callback.", pkgName.c_str());
        return ERR_DM_FAILED;
    }
    if (sessionId_ == SESSION_ID_INVALID) {
        LOGE("NotifyPinHolderEvent session invalid.");
        return ERR_DM_FAILED;
    }
    if (!isRemoteSupported_) {
        LOGE("NotifyPinHolderEvent failed, remote not support.");
        return ERR_DM_BIND_PEER_UNSUPPORTED;
    }
    nlohmann::json jsonObject = nlohmann::json::parse(event, nullptr, false);
    if (jsonObject.is_discarded() || !IsInt32(jsonObject, TAG_PIN_TYPE)) {
        LOGE("ProcessChangeMsg DecodeRequest jsonStr error.");
        return ERR_DM_FAILED;
    }
    if (timer_ != nullptr) {
        timer_->DeleteAll();
        timer_->StartTimer(std::string(PINHOLDER_CREATE_TIMEOUT_TASK), PIN_HOLDER_SESSION_CREATE_TIMEOUT,
            [this] (std::string name) {
                PinHolder::CloseSession(name);
            });
    }
    DmPinType pinType = static_cast<DmPinType>(jsonObject[TAG_PIN_TYPE].get<int32_t>());
    nlohmann::json jsonObj;
    jsonObj[TAG_MSG_TYPE] = MSG_TYPE_PIN_HOLDER_CHANGE;
    jsonObj[TAG_PIN_TYPE] = pinType;
    std::string message = jsonObj.dump();
    LOGI("NotifyPinHolderEvent, message type is: %{public}d, pin type is: %{public}d.",
        MSG_TYPE_PIN_HOLDER_CHANGE, pinType);
    int32_t ret = session_->SendData(sessionId_, message);
    if (ret != DM_OK) {
        LOGE("[SOFTBUS]SendBytes failed, ret: %{public}d.", ret);
        listener_->OnPinHolderEvent(registerPkgName_, DmPinHolderEvent::PIN_TYPE_CHANGE_RESULT, ERR_DM_FAILED, "");
        return ERR_DM_FAILED;
    }
    return ret;
}

void PinHolder::ProcessChangeMsg(const std::string &message)
{
    if (listener_ == nullptr || session_ == nullptr) {
        LOGE("ProcessChangeMsg listener or session is nullptr.");
        return;
    }
    nlohmann::json jsonObject = nlohmann::json::parse(message, nullptr, false);
    if (jsonObject.is_discarded()) {
        LOGE("ProcessChangeMsg DecodeRequest jsonStr error.");
        return;
    }
    if (!IsInt32(jsonObject, TAG_PIN_TYPE)) {
        LOGE("ProcessChangeMsg err json string.");
        return;
    }
    DmPinType pinType = static_cast<DmPinType>(jsonObject[TAG_PIN_TYPE].get<int32_t>());

    nlohmann::json jsonObj;
    jsonObj[TAG_MSG_TYPE] = MSG_TYPE_PIN_HOLDER_CHANGE_RESP;
    if (sinkState_ != SINK_CREATE) {
        jsonObj[TAG_REPLY] = REPLY_FAILED;
    } else {
        jsonObj[TAG_REPLY] = REPLY_SUCCESS;
        nlohmann::json jsonContent;
        jsonContent[TAG_PIN_TYPE] = pinType;
        std::string content = jsonContent.dump();
        listener_->OnPinHolderEvent(registerPkgName_, DmPinHolderEvent::PIN_TYPE_CHANGE, DM_OK, content);
        if (timer_ != nullptr) {
            timer_->DeleteAll();
            timer_->StartTimer(std::string(PINHOLDER_CREATE_TIMEOUT_TASK), PIN_HOLDER_SESSION_CREATE_TIMEOUT,
                [this] (std::string name) {
                    PinHolder::CloseSession(name);
                });
        }
    }

    std::string msg = jsonObj.dump();
    LOGI("ProcessChangeMsg, message type is: %{public}d.", MSG_TYPE_PIN_HOLDER_CHANGE_RESP);
    int32_t ret = session_->SendData(sessionId_, msg);
    if (ret != DM_OK) {
        LOGE("[SOFTBUS]SendBytes failed, ret: %{public}d.", ret);
        return;
    }
}

void PinHolder::ProcessChangeRespMsg(const std::string &message)
{
    nlohmann::json jsonObject = nlohmann::json::parse(message, nullptr, false);
    if (jsonObject.is_discarded()) {
        LOGE("ProcessChangeRespMsg DecodeRequest jsonStr error.");
        return;
    }
    if (!IsInt32(jsonObject, TAG_REPLY)) {
        LOGE("ProcessChangeRespMsg err json string.");
        return;
    }
    int32_t reply = jsonObject[TAG_REPLY].get<int32_t>();
    if (listener_ == nullptr || session_ == nullptr) {
        LOGE("ProcessChangeRespMsg listener or session is nullptr.");
        return;
    }
    if (reply == REPLY_SUCCESS) {
        listener_->OnPinHolderEvent(registerPkgName_, DmPinHolderEvent::PIN_TYPE_CHANGE_RESULT, DM_OK, "");
    } else {
        LOGE("ProcessChangeRespMsg remote state is wrong.");
        listener_->OnPinHolderEvent(registerPkgName_, DmPinHolderEvent::PIN_TYPE_CHANGE_RESULT, ERR_DM_FAILED, "");
    }
}
} // namespace DistributedHardware
} // namespace OHOS