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

#include "ipc_skeleton.h"

#include "input_event_handler.h"

#undef MMI_LOG_DOMAIN
#define MMI_LOG_DOMAIN MMI_LOG_SERVER
#undef MMI_LOG_TAG
#define MMI_LOG_TAG "NapProcess"

namespace OHOS {
namespace MMI {
namespace {
constexpr int32_t REMOVE_OBSERVER { -2 };
constexpr int32_t NAP_EVENT { 0 };
constexpr int32_t SUBSCRIBED { 1 };
constexpr int32_t ACTIVE_EVENT { 2 };
} // namespace

NapProcess *NapProcess::instance_ = new (std::nothrow) NapProcess();
NapProcess *NapProcess::GetInstance()
{
    return instance_;
}

void NapProcess::Init(UDSServer& udsServer)
{
    udsServer_ = &udsServer;
    CHKPV(udsServer_);
}

int32_t NapProcess::NotifyBundleName(NapStatusData data, int32_t syncState)
{
    CALL_DEBUG_ENTER;
    if (napClientPid_ < 0) {
        MMI_HILOGE("Client pid is unavailable");
        return RET_ERR;
    }
    MMI_HILOGD("NotifyBundle info pid:%{public}d, uid:%{public}d, bundleName:%{public}s, syncState:%{public}d",
        data.pid, data.uid, data.bundleName.c_str(), syncState);
    NetPacket pkt(MmiMessageId::NOTIFY_BUNDLE_NAME);
    pkt << data.pid;
    pkt << data.uid;
    pkt << data.bundleName;
    pkt << syncState;
    CHKPR(udsServer_, RET_ERR);
    int32_t fd = udsServer_->GetClientFd(napClientPid_);
    auto udsServer = InputHandler->GetUDSServer();
    CHKPR(udsServer, RET_ERR);
    auto session = udsServer->GetSession(fd);
    if (!udsServer->SendMsg(fd, pkt)) {
        MMI_HILOGE("Sending structure of EventTouch failed! errCode:%{public}d", MSG_SEND_FAIL);
        return RET_ERR;
    }
    return RET_OK;
}

bool NapProcess::IsNeedNotify(const NapStatusData& data)
{
    CALL_DEBUG_ENTER;
    std::lock_guard guard(mapMtx_);
    for (const auto& map : napMap_) {
        if (data.pid == map.first.pid && data.uid == map.first.uid && data.bundleName == map.first.bundleName) {
            bool IsNeedSendMessage = napMap_[data] == SUBSCRIBED || napMap_[data] == NAP_EVENT;
            return IsNeedSendMessage;
        }
    }
    return false;
}

int32_t NapProcess::SetNapStatus(int32_t pid, int32_t uid, std::string bundleName, int32_t napStatus)
{
    CALL_DEBUG_ENTER;
    NapStatusData napData;
    napData.pid = pid;
    napData.uid = uid;
    napData.bundleName = bundleName;
    if (napStatus == ACTIVE_EVENT) {
        RemoveMmiSubscribedEventData(napData);
        MMI_HILOGD("Remove active event from napMap, pid:%{public}d, uid:%{public}d, bundleName:%{public}s",
            pid, uid, bundleName.c_str());
    }
    if (napStatus == NAP_EVENT) {
        AddMmiSubscribedEventData(napData, napStatus);
        MMI_HILOGD("Add nap process to napMap, pid:%{public}d, uid:%{public}d, bundleName:%{public}s",
            pid, uid, bundleName.c_str());
    }
    return RET_OK;
}

int32_t NapProcess::AddMmiSubscribedEventData(const NapStatusData& napData, int32_t syncState)
{
    CALL_DEBUG_ENTER;
    std::lock_guard guard(mapMtx_);
    if (napMap_.find(napData) == napMap_.end()) {
        napMap_.emplace(napData, syncState);
    } else {
        napMap_[napData] = syncState;
    }
    return RET_OK;
}

int32_t NapProcess::RemoveMmiSubscribedEventData(const NapStatusData& napData)
{
    CALL_DEBUG_ENTER;
    std::lock_guard guard(mapMtx_);
    if (napMap_.find(napData) != napMap_.end()) {
        napMap_.erase(napData);
    }
    return RET_OK;
}

int32_t NapProcess::GetNapClientPid()
{
    return napClientPid_;
}

int32_t NapProcess::NotifyNapOnline()
{
    CALL_DEBUG_ENTER;
    int32_t pid = IPCSkeleton::GetCallingPid();
    napClientPid_ = pid;
    MMI_HILOGD("NotifyNapOnline pid:%{public}d", pid);
    return RET_OK;
}

int32_t NapProcess::RemoveInputEventObserver()
{
    CALL_DEBUG_ENTER;
    std::lock_guard guard(mapMtx_);
    napMap_.clear();
    napClientPid_ = REMOVE_OBSERVER;
    return RET_OK;
}

int32_t NapProcess::GetAllMmiSubscribedEvents(std::map<std::tuple<int32_t, int32_t, std::string>, int32_t> &datas)
{
    CALL_DEBUG_ENTER;
    std::lock_guard guard(mapMtx_);
    for (auto map : napMap_) {
        int32_t getPid = map.first.pid;
        int32_t getUid = map.first.uid;
        std::string getName = map.first.bundleName;
        int32_t getStatus = map.second;
        std::tuple<int32_t, int32_t, std::string> tuple(getPid, getUid, getName);
        datas.emplace(tuple, getStatus);
    }
    return RET_OK;
}
} // namespace MMI
} // namespace OHOS