plugin/src/cooperate_context.cpp

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

#include <algorithm>

#include "display_manager.h"
#include "display_info.h"
#include "ddm_adapter.h"
#include "devicestatus_define.h"
#include "dsoftbus_handler.h"
#include "utility.h"

#undef LOG_TAG
#define LOG_TAG "CooperateContext"

namespace OHOS {
namespace Msdp {
namespace DeviceStatus {
namespace Cooperate {
namespace {
const std::string THREAD_NAME { "os_Cooperate_EventHandler" };
constexpr double PERCENT { 100.0 };
const int32_t MAX_MOUSE_SPEED { 20 };
} // namespace

class BoardObserver final : public IBoardObserver {
public:
    explicit BoardObserver(Channel<CooperateEvent>::Sender sender) : sender_(sender) {}
    ~BoardObserver() = default;
    DISALLOW_COPY_AND_MOVE(BoardObserver);

    void OnBoardOnline(const std::string &networkId) override
    {
        FI_HILOGD("\'%{public}s\' is online", Utility::Anonymize(networkId).c_str());
        auto ret = sender_.Send(CooperateEvent(
            CooperateEventType::DDM_BOARD_ONLINE,
            DDMBoardOnlineEvent {
                .networkId = networkId
            }));
        if (ret != Channel<CooperateEvent>::NO_ERROR) {
            FI_HILOGE("Failed to send event via channel, error:%{public}d", ret);
        }
    }

    void OnBoardOffline(const std::string &networkId) override
    {
        FI_HILOGD("\'%{public}s\' is offline", Utility::Anonymize(networkId).c_str());
        auto ret = sender_.Send(CooperateEvent(
            CooperateEventType::DDM_BOARD_OFFLINE,
            DDMBoardOfflineEvent {
                .networkId = networkId
            }));
        if (ret != Channel<CooperateEvent>::NO_ERROR) {
            FI_HILOGE("Failed to send event via channel, error:%{public}d", ret);
        }
    }

private:
    Channel<CooperateEvent>::Sender sender_;
};

void HotplugObserver::OnDeviceAdded(std::shared_ptr<IDevice> dev)
{
    CHKPV(dev);
    auto ret = sender_.Send(CooperateEvent(
        CooperateEventType::INPUT_HOTPLUG_EVENT,
        InputHotplugEvent {
            .deviceId = dev->GetId(),
            .type = InputHotplugType::PLUG,
            .isKeyboard = dev->IsKeyboard(),
        }));
    if (ret != Channel<CooperateEvent>::NO_ERROR) {
        FI_HILOGE("Failed to send event via channel, error:%{public}d", ret);
    }
}

void HotplugObserver::OnDeviceRemoved(std::shared_ptr<IDevice> dev)
{
    CHKPV(dev);
    auto ret = sender_.Send(CooperateEvent(
        CooperateEventType::INPUT_HOTPLUG_EVENT,
        InputHotplugEvent {
            .deviceId = dev->GetId(),
            .type = InputHotplugType::UNPLUG,
            .isKeyboard = dev->IsKeyboard(),
        }));
    if (ret != Channel<CooperateEvent>::NO_ERROR) {
        FI_HILOGE("Failed to send event via channel, error:%{public}d", ret);
    }
}

Context::Context(IContext *env)
    : dsoftbus_(env), eventMgr_(env), hotArea_(env), mouseLocation_(env), inputDevMgr_(env),
      inputEventBuilder_(env), inputEventInterceptor_(env), env_(env)
{}

void Context::AttachSender(Channel<CooperateEvent>::Sender sender)
{
    sender_ = sender;
    dsoftbus_.AttachSender(sender);
}

void Context::AddObserver(std::shared_ptr<ICooperateObserver> observer)
{
    CHKPV(observer);
    observers_.insert(observer);
}

void Context::RemoveObserver(std::shared_ptr<ICooperateObserver> observer)
{
    observers_.erase(observer);
}

void Context::Enable()
{
    CALL_DEBUG_ENTER;
    StartEventHandler();
    EnableDDM();
    EnableDevMgr();
    EnableInputDevMgr();
}

void Context::Disable()
{
    CALL_DEBUG_ENTER;
    DisableDevMgr();
    DisableDDM();
    DisableInputDevMgr();
    StopEventHandler();
}

int32_t Context::StartEventHandler()
{
    auto runner = AppExecFwk::EventRunner::Create(THREAD_NAME, AppExecFwk::ThreadMode::FFRT);
    CHKPR(runner, RET_ERR);
    eventHandler_ = std::make_shared<AppExecFwk::EventHandler>(runner);
    return RET_OK;
}

void Context::StopEventHandler()
{
    eventHandler_.reset();
}

void Context::EnableDDM()
{
    boardObserver_ = std::make_shared<BoardObserver>(sender_);
    CHKPV(env_);
    env_->GetDDM().AddBoardObserver(boardObserver_);
}

void Context::DisableDDM()
{
    CHKPV(env_);
    env_->GetDDM().RemoveBoardObserver(boardObserver_);
    boardObserver_.reset();
}

int32_t Context::EnableDevMgr()
{
    hotplugObserver_ = std::make_shared<HotplugObserver>(sender_);
    CHKPR(env_, RET_ERR);
    env_->GetDeviceManager().AddDeviceObserver(hotplugObserver_);
    return RET_OK;
}

void Context::DisableDevMgr()
{
    CHKPV(env_);
    env_->GetDeviceManager().RemoveDeviceObserver(hotplugObserver_);
    hotplugObserver_.reset();
}

int32_t Context::EnableInputDevMgr()
{
    inputDevMgr_.Enable(sender_);
    return RET_OK;
}

void Context::DisableInputDevMgr()
{
    inputDevMgr_.Disable();
}

NormalizedCoordinate Context::NormalizedCursorPosition() const
{
    auto display = Rosen::DisplayManager::GetInstance().GetDisplayById(currentDisplayId_);
    if (display == nullptr) {
        FI_HILOGE("No default display");
        return { 0, 0 };
    }
    Rectangle displayRect {
        .width = display->GetWidth(),
        .height = display->GetHeight(),
    };
    if ((displayRect.width <= 0) || (displayRect.height <= 0)) {
        FI_HILOGE("Invalid display information");
        return { 0, 0 };
    }
    return NormalizedCoordinate {
        .x = static_cast<int32_t>((cursorPos_.x + 1) * PERCENT / displayRect.width),
        .y = static_cast<int32_t>((cursorPos_.y + 1) * PERCENT / displayRect.height),
    };
}

void Context::EnableCooperate(const EnableCooperateEvent &event)
{
}

void Context::DisableCooperate(const DisableCooperateEvent &event)
{
    priv_ = 0;
}

void Context::ResetPriv()
{
    priv_ = 0;
}

void Context::StartCooperate(const StartCooperateEvent &event)
{
    remoteNetworkId_ = event.remoteNetworkId;
    startDeviceId_ = event.startDeviceId;
    priv_ = 0;
}

void Context::OnPointerEvent(const InputPointerEvent &event)
{
    if ((event.sourceType == MMI::PointerEvent::SOURCE_TYPE_MOUSE) &&
        ((event.pointerAction == MMI::PointerEvent::POINTER_ACTION_MOVE) ||
         (event.pointerAction == MMI::PointerEvent::POINTER_ACTION_PULL_MOVE))) {
        cursorPos_ = event.position;
        currentDisplayId_ = event.currentDisplayId == -1 ? 0 : event.currentDisplayId;
    }
}

void Context::RemoteStartSuccess(const DSoftbusStartCooperateFinished &event)
{
    remoteNetworkId_ = event.originNetworkId;
    flag_ = event.extra.flag;
    priv_ = event.extra.priv;
    SetCursorPosition(event.cursorPos);
}

void Context::StartCooperateWithOptions(const StartWithOptionsEvent &event)
{
    remoteNetworkId_ = event.remoteNetworkId;
    startDeviceId_ = event.startDeviceId;
    priv_ = 0;
    cooperateOptions_ = {
        event.displayX,
        event.displayY,
        event.displayId
    };
}

void Context::UpdateCooperateOptions(const StartWithOptionsEvent &event)
{
    cooperateOptions_ = {
        event.displayX,
        event.displayY,
        event.displayId
    };
}

void Context::OnRemoteStart(const DSoftbusCooperateWithOptionsFinished &event)
{
    remoteNetworkId_ = event.originNetworkId;
    flag_ = event.extra.flag;
    priv_ = event.extra.priv;
    CHKPV(env_);
    env_->GetInput().SetPointerLocation(event.cooperateOptions.displayX, event.cooperateOptions.displayY,
        event.cooperateOptions.displayId);
    FI_HILOGI("Set pointer location: %{private}d, %{private}d, %{private}d",
        event.cooperateOptions.displayX, event.cooperateOptions.displayY, event.cooperateOptions.displayId);
    cooperateOptions_ = {
        event.cooperateOptions.displayX,
        event.cooperateOptions.displayY,
        event.cooperateOptions.displayId,
    };
}

void Context::AdjustPointerPos(DSoftbusCooperateOptions& dSoftbusCooperateOptions)
{
    auto displayId = dSoftbusCooperateOptions.cooperateOptions.displayId;
    auto& displayX = dSoftbusCooperateOptions.cooperateOptions.displayX;
    auto& displayY = dSoftbusCooperateOptions.cooperateOptions.displayY;
    FI_HILOGI("Start cooperate finish,displayX:%{private}d,displayY:%{private}d,displayId:%{public}d",
        displayX, displayY, displayId);
#ifndef OHOS_BUILD_PC_PRODUCT
    auto display = Rosen::DisplayManager::GetInstance().GetDisplayById(displayId);
#else
    sptr<Rosen::DisplayInfo> display =
        Rosen::DisplayManager::GetInstance().GetVisibleAreaDisplayInfoById(displayId);
#endif // OHOS_BUILD_PC_PRODUCT
    if (display == nullptr) {
        FI_HILOGE("No default display");
        return;
    }
    Rectangle displayRect {
        .width = display->GetWidth(),
        .height = display->GetHeight(),
    };
    if (displayX <= 0) {
        displayX = 0;
    }
    if (displayX >= displayRect.width) {
        displayX = displayRect.width - 1;
    }
    if (displayY <= 0) {
        displayY = 0;
    }
    if (displayY >= displayRect.height) {
        displayY = displayRect.height - 1;
    }
    FI_HILOGI("adjust pointer position finish,displayX:%{private}d,displayY:%{private}d",
        displayX, displayY);
}

void Context::RelayCooperate(const DSoftbusRelayCooperate &event)
{
    remoteNetworkId_ = event.targetNetworkId;
}

void Context::UpdateCooperateFlag(const UpdateCooperateFlagEvent &event)
{
    flag_ = ((flag_ & ~event.mask) | (event.flag & event.mask));
}

bool Context::IsAllowCooperate()
{
    FI_HILOGI("Notify observers of allow cooperate");
    return std::all_of(observers_.cbegin(), observers_.cend(), [](const auto &observer) {
        return observer->IsAllowCooperate();
    });
}

void Context::OnStartCooperate(StartCooperateData &data)
{
    std::for_each(observers_.cbegin(), observers_.cend(), [&data](const auto &observer) {
        return observer->OnStartCooperate(data);
    });
}

void Context::OnRemoteStartCooperate(RemoteStartCooperateData &data)
{
    std::for_each(observers_.cbegin(), observers_.cend(), [&data](const auto &observer) {
        return observer->OnRemoteStartCooperate(data);
    });
}

void Context::OnStopCooperate()
{
    CHKPV(eventHandler_);
    FI_HILOGI("Notify observers of stop cooperate");
    for (const auto &observer : observers_) {
        eventHandler_->PostTask(
            [observer, remoteNetworkId = Peer()] {
                FI_HILOGI("Notify observer of stop cooperate");
                CHKPV(observer);
                observer->OnStopCooperate(remoteNetworkId);
        });
    }
}

void Context::OnTransitionOut()
{
    CHKPV(eventHandler_);
    FI_HILOGI("Notify observers of transition out");
    CooperateInfo cooperateInfo = { NormalizedCursorPosition(), cooperateOptions_ };
    for (const auto &observer : observers_) {
        eventHandler_->PostTask(
            [observer, remoteNetworkId = Peer(), cooperateInfo] {
                FI_HILOGI("Notify one observer of transition out");
                CHKPV(observer);
                observer->OnTransitionOut(remoteNetworkId, cooperateInfo);
            });
    }
}

void Context::OnTransitionIn()
{
    StoreOriginPointerSpeed();
    SetPointerSpeed(peerPointerSpeed_);
    StoreOriginTouchPadSpeed();
    SetTouchPadSpeed(peerTouchPadSpeed_);
    CHKPV(eventHandler_);
    FI_HILOGI("Notify observers of transition in");
    CooperateInfo cooperateInfo = { NormalizedCursorPosition(), cooperateOptions_ };
    for (const auto &observer : observers_) {
        eventHandler_->PostTask(
            [observer, remoteNetworkId = Peer(), cooperateInfo] {
                FI_HILOGI("Notify one observer of transition in");
                CHKPV(observer);
                observer->OnTransitionIn(remoteNetworkId, cooperateInfo);
            });
    }
}

void Context::OnBack()
{
    SetPointerSpeed(originPointerSpeed_);
    ClearPeerPointerSpeed();
    SetTouchPadSpeed(originTouchPadSpeed_);
    ClearPeerTouchPadSpeed();
    CHKPV(eventHandler_);
    FI_HILOGI("Notify observers of come back");
    CooperateInfo cooperateInfo = { NormalizedCursorPosition(), cooperateOptions_ };
    for (const auto &observer : observers_) {
        eventHandler_->PostTask(
            [observer, remoteNetworkId = Peer(), cooperateInfo] {
                FI_HILOGI("Notify one observer of come back");
                CHKPV(observer);
                observer->OnBack(remoteNetworkId, cooperateInfo);
            });
    }
}

void Context::OnRelayCooperation(const std::string &networkId, const NormalizedCoordinate &cursorPos)
{
    CHKPV(eventHandler_);
    FI_HILOGI("Notify observers of relay cooperation");
    CooperateInfo cooperateInfo = { NormalizedCursorPosition(), cooperateOptions_ };
    for (const auto &observer : observers_) {
        eventHandler_->PostTask(
            [observer, networkId, cooperateInfo] {
                FI_HILOGI("Notify one observer of relay cooperation");
                CHKPV(observer);
                observer->OnRelay(networkId, cooperateInfo);
            });
    }
}

void Context::CloseDistributedFileConnection(const std::string &remoteNetworkId)
{
    CHKPV(eventHandler_);
    FI_HILOGI("Notify observers of device offline");
    for (const auto &observer : observers_) {
        eventHandler_->PostTask(
            [observer, remoteNetworkId] {
                FI_HILOGI("Notify one observer of device offline, remoteNetworkId:%{public}s",
                    Utility::Anonymize(remoteNetworkId).c_str());
                CHKPV(observer);
                observer->CloseDistributedFileConnection(remoteNetworkId);
            });
    }
}

void Context::StorePeerPointerSpeed(int32_t speed)
{
    CALL_INFO_TRACE;
    peerPointerSpeed_ = speed;
}

void Context::ClearPeerPointerSpeed()
{
    CALL_INFO_TRACE;
    peerPointerSpeed_ = -1;
}

void Context::StoreOriginPointerSpeed()
{
    CALL_INFO_TRACE;
    originPointerSpeed_ = GetPointerSpeed();
}

void Context::StorePeerTouchPadSpeed(int32_t speed)
{
    CALL_INFO_TRACE;
    peerTouchPadSpeed_ = speed;
}

void Context::ClearPeerTouchPadSpeed()
{
    CALL_INFO_TRACE;
    peerTouchPadSpeed_ = -1;
}

void Context::StoreOriginTouchPadSpeed()
{
    CALL_INFO_TRACE;
    originTouchPadSpeed_ = GetTouchPadSpeed();
}

void Context::OnResetCooperation()
{
    SetPointerSpeed(originPointerSpeed_);
    ClearPeerPointerSpeed();
    SetTouchPadSpeed(originTouchPadSpeed_);
    ClearPeerTouchPadSpeed();
    priv_ = 0;
    CHKPV(eventHandler_);
    FI_HILOGI("Notify observers of reset cooperation");
    for (const auto &observer : observers_) {
        eventHandler_->PostTask(
            [observer] {
                FI_HILOGI("Notify one observer of reset cooperation");
                CHKPV(observer);
                observer->OnReset();
            });
    }
}

void Context::SetCursorPosition(const Coordinate &cursorPos)
{
    auto display = Rosen::DisplayManager::GetInstance().GetDefaultDisplay();
    CHKPV(display);
    auto cursor = GetCursorPos(cursorPos);
    cursorPos_ = cursor;
    CHKPV(env_);
    env_->GetInput().SetPointerLocation(cursor.x, cursor.y);
    FI_HILOGI("Set cursor position (%{private}d,%{private}d)(%{private}d,%{private}d)(%{public}d,%{public}d)",
        cursorPos.x, cursorPos.y, cursor.x, cursor.y, display->GetWidth(), display->GetHeight());
}

void Context::StopCooperateSetCursorPosition(const Coordinate &cursorPos)
{
    auto display = Rosen::DisplayManager::GetInstance().GetDefaultDisplay();
    CHKPV(display);
    int32_t displayId = static_cast<int32_t>(display->GetId());
    if (displayId < 0) {
        displayId = 0;
    }
    auto cursor = GetCursorPos(cursorPos);
    CHKPV(env_);
    env_->GetInput().SetPointerLocation(cursor.x, cursor.y, displayId);
    FI_HILOGI("Set cursor position (%{private}d,%{private}d)(%{private}d,%{private}d)(%{public}d,%{public}d),"
        "dafault display id is %{public}d", cursorPos.x, cursorPos.y, cursor.x, cursor.y,
        display->GetWidth(), display->GetHeight(), displayId);
}

Coordinate Context::GetCursorPos(const Coordinate &cursorPos)
{
    double xPercent = (PERCENT - std::clamp<double>(cursorPos.x, 0.0, PERCENT)) / PERCENT;
    double yPercent = std::clamp<double>(cursorPos.y, 0.0, PERCENT) / PERCENT;

    auto display = Rosen::DisplayManager::GetInstance().GetDefaultDisplay();
    if (display == nullptr) {
        FI_HILOGE("No default display");
        return cursorPos_;
    }
    int32_t displayId = static_cast<int32_t>(display->GetId());
    if (displayId < 0) {
        displayId = 0;
    }
    return Coordinate {
        .x = static_cast<int32_t>(xPercent * display->GetWidth()),
        .y = static_cast<int32_t>(yPercent * display->GetHeight()),
    };
}

void Context::UpdateCursorPosition()
{
    CHKPV(env_);
    env_->GetInput().SetPointerLocation(cursorPos_.x, cursorPos_.y);
    FI_HILOGI("Update cursor position (%{private}d,%{private}d)", cursorPos_.x, cursorPos_.y);
}

int32_t Context::GetPointerSpeed()
{
    int32_t speed { -1 };
    CHKPR(env_, RET_ERR);
    env_->GetInput().GetPointerSpeed(speed);
    FI_HILOGI("Current pointer speed:%{public}d", speed);
    return speed;
}

void Context::SetPointerSpeed(int32_t speed)
{
    CHKPV(env_);
    env_->GetInput().SetPointerSpeed(speed);
    FI_HILOGI("Current pointer speed:%{public}d", speed);
}

int32_t Context::GetTouchPadSpeed()
{
    int32_t speed { -1 };
    CHKPR(env_, RET_ERR);
    env_->GetInput().GetTouchPadSpeed(speed);
    FI_HILOGI("Current touchPad speed:%{public}d", speed);
    return speed;
}

void Context::SetTouchPadSpeed(int32_t speed)
{
    if (speed > MAX_MOUSE_SPEED) {
        FI_HILOGE("speed is :%{public}d", speed);
        return;
    }
    CHKPV(env_);
    env_->GetInput().SetTouchPadSpeed(speed);
    FI_HILOGI("Current touchPad speed:%{public}d", speed);
}

void Context::ResetCursorPosition()
{
    constexpr Coordinate defaultCursorPos {
        .x = 50,
        .y = 50,
    };
    StopCooperateSetCursorPosition(defaultCursorPos);
}

void Context::SetVirtualTrackpadDeviceId(int32_t deviceId)
{
    VirtualTrackpadDeviceId_ = deviceId;
    FI_HILOGI("Cur vir track pad:%{public}d", deviceId);
}

int32_t Context::GetVirtualTrackpadDeviceId()
{
    return VirtualTrackpadDeviceId_;
}

void Context::ResetVirtualTrackpadDeviceId()
{
    VirtualTrackpadDeviceId_ = -1;
}

#ifdef ENABLE_PERFORMANCE_CHECK
void Context::StartTrace(const std::string &name)
{
    std::lock_guard guard { lock_ };
    if (traces_.find(name) != traces_.end()) {
        return;
    }
    traces_.emplace(name, std::chrono::steady_clock::now());
    FI_HILOGI("[PERF] Start tracing \'%{public}s\'", name.c_str());
}

void Context::FinishTrace(const std::string &name)
{
    std::lock_guard guard { lock_ };
    if (auto iter = traces_.find(name); iter != traces_.end()) {
        FI_HILOGI("[PERF] Finish tracing \'%{public}s\', elapsed:%{public}lld ms", name.c_str(),
            std::chrono::duration_cast<std::chrono::milliseconds>(
                std::chrono::steady_clock::now() - iter->second).count());
        traces_.erase(iter);
    }
}
#endif // ENABLE_PERFORMANCE_CHECK

} // namespace Cooperate
} // namespace DeviceStatus
} // namespace Msdp
} // namespace OHOS