xref: /foundation/arkui/ace_engine/frameworks/core/pipeline_ng/pipeline_context.cpp

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

#include "base/subwindow/subwindow_manager.h"

#ifdef ENABLE_ROSEN_BACKEND
#include "render_service_client/core/transaction/rs_transaction.h"
#include "render_service_client/core/ui/rs_ui_director.h"
#endif
#if !defined(PREVIEW) && !defined(ACE_UNITTEST) && defined(OHOS_PLATFORM)
#include "interfaces/inner_api/ui_session/ui_session_manager.h"
#include "frameworks/core/components_ng/base/inspector.h"
#endif

#include "base/geometry/ng/offset_t.h"
#include "base/geometry/ng/rect_t.h"
#include "base/log/ace_performance_monitor.h"
#include "base/log/ace_trace.h"
#include "base/log/ace_tracker.h"
#include "base/log/dump_log.h"
#include "base/log/event_report.h"
#include "base/memory/ace_type.h"
#include "base/perfmonitor/perf_monitor.h"
#include "base/ressched/ressched_report.h"
#include "core/common/ace_engine.h"
#include "core/common/font_manager.h"
#include "core/common/font_change_observer.h"
#include "core/common/ime/input_method_manager.h"
#include "core/common/layout_inspector.h"
#include "core/common/stylus/stylus_detector_default.h"
#include "core/common/stylus/stylus_detector_mgr.h"
#include "core/common/text_field_manager.h"
#include "core/components_ng/base/view_advanced_register.h"
#include "core/components_ng/pattern/container_modal/container_modal_view_factory.h"
#include "core/components_ng/pattern/container_modal/enhance/container_modal_pattern_enhance.h"
#include "core/components_ng/pattern/navigation/navigation_pattern.h"
#include "core/components_ng/pattern/navigation/nav_bar_node.h"
#include "core/components_ng/pattern/root/root_pattern.h"
#include "core/components_ng/pattern/text_field/text_field_manager.h"
#ifdef WINDOW_SCENE_SUPPORTED
#include "core/components_ng/pattern/window_scene/scene/window_scene_layout_manager.h"
#endif
#include "core/image/image_file_cache.h"
#include "core/pipeline/pipeline_context.h"

namespace {
constexpr uint64_t ONE_MS_IN_NS = 1 * 1000 * 1000;
constexpr uint64_t ONE_S_IN_NS = 1 * 1000 * 1000 * 1000;
constexpr uint64_t INTERPOLATION_THRESHOLD = 100 * 1000 * 1000; // 100ms
constexpr int32_t INDEX_X = 0;
constexpr int32_t INDEX_Y = 1;
constexpr int32_t INDEX_TIME = 2;
constexpr int32_t INDEX_X_SLOPE = 2;
constexpr int32_t INDEX_Y_SLOPE = 3;
constexpr int32_t TIME_THRESHOLD = 2 * 1000000; // 3 millisecond
constexpr int32_t PLATFORM_VERSION_TEN = 10;
constexpr int32_t USED_ID_FIND_FLAG = 3;                 // if args >3 , it means use id to find
constexpr int32_t MILLISECONDS_TO_NANOSECONDS = 1000000; // Milliseconds to nanoseconds
constexpr int32_t RESAMPLE_COORD_TIME_THRESHOLD = 20 * 1000 * 1000;
constexpr int32_t VSYNC_PERIOD_COUNT = 5;
constexpr int32_t MIN_IDLE_TIME = 1000000;
constexpr uint8_t SINGLECOLOR_UPDATE_ALPHA = 75;
constexpr int8_t RENDERING_SINGLE_COLOR = 1;
constexpr int32_t MAX_MISS_COUNT = 3;
constexpr int32_t DELAY_TIME = 500;

} // namespace

namespace OHOS::Ace::NG {

PipelineContext::PipelineContext(std::shared_ptr<Window> window, RefPtr<TaskExecutor> taskExecutor,
    RefPtr<AssetManager> assetManager, RefPtr<PlatformResRegister> platformResRegister,
    const RefPtr<Frontend>& frontend, int32_t instanceId)
    : PipelineBase(window, std::move(taskExecutor), std::move(assetManager), frontend, instanceId, platformResRegister)
{
    window_->OnHide();
}

PipelineContext::PipelineContext(std::shared_ptr<Window> window, RefPtr<TaskExecutor> taskExecutor,
    RefPtr<AssetManager> assetManager, const RefPtr<Frontend>& frontend, int32_t instanceId)
    : PipelineBase(window, std::move(taskExecutor), std::move(assetManager), frontend, instanceId)
{
    window_->OnHide();
}

RefPtr<PipelineContext> PipelineContext::GetCurrentContext()
{
    auto currentContainer = Container::Current();
    CHECK_NULL_RETURN(currentContainer, nullptr);
    return DynamicCast<PipelineContext>(currentContainer->GetPipelineContext());
}

RefPtr<PipelineContext> PipelineContext::GetCurrentContextSafely()
{
    auto currentContainer = Container::CurrentSafely();
    CHECK_NULL_RETURN(currentContainer, nullptr);
    return DynamicCast<PipelineContext>(currentContainer->GetPipelineContext());
}

RefPtr<PipelineContext> PipelineContext::GetCurrentContextSafelyWithCheck()
{
    auto currentContainer = Container::CurrentSafelyWithCheck();
    CHECK_NULL_RETURN(currentContainer, nullptr);
    return DynamicCast<PipelineContext>(currentContainer->GetPipelineContext());
}

PipelineContext* PipelineContext::GetCurrentContextPtrSafely()
{
    auto currentContainer = Container::CurrentSafely();
    CHECK_NULL_RETURN(currentContainer, nullptr);
    const auto& base = currentContainer->GetPipelineContext();
    CHECK_NULL_RETURN(base, nullptr);
    return DynamicCast<PipelineContext>(RawPtr(base));
}

PipelineContext* PipelineContext::GetCurrentContextPtrSafelyWithCheck()
{
    auto currentContainer = Container::CurrentSafelyWithCheck();
    CHECK_NULL_RETURN(currentContainer, nullptr);
    const auto& base = currentContainer->GetPipelineContext();
    CHECK_NULL_RETURN(base, nullptr);
    return DynamicCast<PipelineContext>(RawPtr(base));
}

RefPtr<PipelineContext> PipelineContext::GetMainPipelineContext()
{
    auto pipeline = PipelineBase::GetMainPipelineContext();
    CHECK_NULL_RETURN(pipeline, nullptr);
    return DynamicCast<PipelineContext>(pipeline);
}

bool PipelineContext::NeedSoftKeyboard()
{
    auto needSoftKeyboard = InputMethodManager::GetInstance()->NeedSoftKeyboard();
    TAG_LOGI(AceLogTag::ACE_KEYBOARD, "window switch need keyboard %d", needSoftKeyboard);
    return needSoftKeyboard;
}

RefPtr<PipelineContext> PipelineContext::GetContextByContainerId(int32_t containerId)
{
    auto preContainer = Container::GetContainer(containerId);
    CHECK_NULL_RETURN(preContainer, nullptr);
    return DynamicCast<PipelineContext>(preContainer->GetPipelineContext());
}

float PipelineContext::GetCurrentRootWidth()
{
    auto context = GetCurrentContext();
    CHECK_NULL_RETURN(context, 0.0f);
    return static_cast<float>(context->rootWidth_);
}

float PipelineContext::GetCurrentRootHeight()
{
    auto context = GetCurrentContext();
    CHECK_NULL_RETURN(context, 0.0f);
    return static_cast<float>(context->rootHeight_);
}

void PipelineContext::AddDirtyPropertyNode(const RefPtr<FrameNode>& dirtyNode)
{
    if (!CheckThreadSafe()) {
        LOGW("AddDirtyPropertyNode doesn't run on UI thread!");
    }
    dirtyPropertyNodes_.emplace(dirtyNode);
    hasIdleTasks_ = true;
    RequestFrame();
}

void PipelineContext::AddDirtyCustomNode(const RefPtr<UINode>& dirtyNode)
{
    CHECK_RUN_ON(UI);
    CHECK_NULL_VOID(dirtyNode);
    auto customNode = DynamicCast<CustomNode>(dirtyNode);
    if (customNode && !dirtyNode->GetInspectorIdValue("").empty()) {
        ACE_BUILD_TRACE_BEGIN("AddDirtyCustomNode[%s][self:%d][parent:%d][key:%s]",
            customNode->GetJSViewName().c_str(),
            dirtyNode->GetId(), dirtyNode->GetParent() ? dirtyNode->GetParent()->GetId() : 0,
            dirtyNode->GetInspectorIdValue("").c_str());
        ACE_BUILD_TRACE_END()
    } else if (customNode) {
        ACE_BUILD_TRACE_BEGIN("AddDirtyCustomNode[%s][self:%d][parent:%d]",
            customNode->GetJSViewName().c_str(),
            dirtyNode->GetId(), dirtyNode->GetParent() ? dirtyNode->GetParent()->GetId() : 0);
        ACE_BUILD_TRACE_END()
    }
    dirtyNodes_.emplace(dirtyNode);
    hasIdleTasks_ = true;
    RequestFrame();
}

void PipelineContext::AddDirtyLayoutNode(const RefPtr<FrameNode>& dirty)
{
    CHECK_RUN_ON(UI);
    CHECK_NULL_VOID(dirty);
    if (IsDestroyed()) {
        LOGW("Cannot add dirty layout node as the pipeline context is destroyed.");
        return;
    }
    if (!dirty->GetInspectorIdValue("").empty()) {
        ACE_BUILD_TRACE_BEGIN("AddDirtyLayoutNode[%s][self:%d][parent:%d][key:%s]",
            dirty->GetTag().c_str(),
            dirty->GetId(), dirty->GetParent() ? dirty->GetParent()->GetId() : 0,
            dirty->GetInspectorIdValue("").c_str());
        ACE_BUILD_TRACE_END()
    } else {
        ACE_BUILD_TRACE_BEGIN("AddDirtyLayoutNode[%s][self:%d][parent:%d]", dirty->GetTag().c_str(),
            dirty->GetId(), dirty->GetParent() ? dirty->GetParent()->GetId() : 0);
        ACE_BUILD_TRACE_END()
    }
    if (!dirty->IsOnMainTree() && predictNode_) {
        predictNode_->AddPredictLayoutNode(dirty);
        return;
    }
    taskScheduler_->AddDirtyLayoutNode(dirty);
    ForceLayoutForImplicitAnimation();
#ifdef UICAST_COMPONENT_SUPPORTED
    do {
        auto container = Container::Current();
        CHECK_NULL_BREAK(container);
        auto distributedUI = container->GetDistributedUI();
        CHECK_NULL_BREAK(distributedUI);
        distributedUI->AddDirtyLayoutNode(dirty->GetId());
    } while (false);
#endif
    hasIdleTasks_ = true;
    if (dirty->GetTag() == V2::ROOT_ETS_TAG && isFirstRootLayout_) {
        isFirstRootLayout_ = false;
        LOGI("Root node request first frame.");
    }
    RequestFrame();
}

void PipelineContext::AddLayoutNode(const RefPtr<FrameNode>& layoutNode)
{
    taskScheduler_->AddLayoutNode(layoutNode);
}

void PipelineContext::AddDirtyRenderNode(const RefPtr<FrameNode>& dirty)
{
    CHECK_RUN_ON(UI);
    CHECK_NULL_VOID(dirty);
    if (IsDestroyed()) {
        LOGW("Cannot add dirty render node as the pipeline context is destroyed.");
        return;
    }
    if (!dirty->GetInspectorIdValue("").empty()) {
        ACE_BUILD_TRACE_BEGIN("AddDirtyRenderNode[%s][self:%d][parent:%d][key:%s]", dirty->GetTag().c_str(),
            dirty->GetId(), dirty->GetParent() ? dirty->GetParent()->GetId() : 0,
            dirty->GetInspectorIdValue("").c_str());
        ACE_BUILD_TRACE_END()
    } else {
        ACE_BUILD_TRACE_BEGIN("AddDirtyRenderNode[%s][self:%d][parent:%d]", dirty->GetTag().c_str(),
            dirty->GetId(), dirty->GetParent() ? dirty->GetParent()->GetId() : 0);
        ACE_BUILD_TRACE_END()
    }
    taskScheduler_->AddDirtyRenderNode(dirty);
    ForceRenderForImplicitAnimation();
#ifdef UICAST_COMPONENT_SUPPORTED
    do {
        auto container = Container::Current();
        CHECK_NULL_BREAK(container);
        auto distributedUI = container->GetDistributedUI();
        CHECK_NULL_BREAK(distributedUI);
        distributedUI->AddDirtyRenderNode(dirty->GetId());
    } while (false);
#endif
    hasIdleTasks_ = true;
    RequestFrame();
}

void PipelineContext::AddDirtyFreezeNode(FrameNode* node)
{
    dirtyFreezeNode_.emplace_back(WeakClaim(node));
    hasIdleTasks_ = true;
    RequestFrame();
}

void PipelineContext::FlushFreezeNode()
{
    std::set<RefPtr<FrameNode>, NodeCompare<RefPtr<FrameNode>>> dirtyFreezeNodeSet;
    auto dirtyFreezeNodes = std::move(dirtyFreezeNode_);
    dirtyFreezeNode_.clear();
    for (auto&& weakNode : dirtyFreezeNodes) {
        auto node = weakNode.Upgrade();
        if (node) {
            dirtyFreezeNodeSet.emplace(node);
        }
    }
    // Process parentNode before childNode
    for (auto&& node : dirtyFreezeNodeSet) {
        node->ProcessFreezeNode();
    }
}

void PipelineContext::FlushDirtyPropertyNodes()
{
    // node api property diff before ets update.
    if (!CheckThreadSafe()) {
        LOGW("FlushDirtyNodeUpdate doesn't run on UI thread!");
    }
    decltype(dirtyPropertyNodes_) dirtyPropertyNodes(std::move(dirtyPropertyNodes_));
    dirtyPropertyNodes_.clear();
    for (const auto& node : dirtyPropertyNodes) {
        node->ProcessPropertyDiff();
    }
}

void PipelineContext::FlushDirtyNodeUpdate()
{
    CHECK_RUN_ON(UI);
    ACE_FUNCTION_TRACE();
    if (FrameReport::GetInstance().GetEnable()) {
        FrameReport::GetInstance().BeginFlushBuild();
    }

    // freeze node unlock before build begin.
    FlushFreezeNode();

    FlushDirtyPropertyNodes();

    if (!ViewStackProcessor::GetInstance()->IsEmpty() && !dirtyNodes_.empty()) {
        ACE_SCOPED_TRACE("Error update, node stack non-empty");
        LOGW("stack is not empty when call FlushDirtyNodeUpdate, node may be mounted to incorrect pos!");
    }
    // SomeTimes, customNode->Update may add some dirty custom nodes to dirtyNodes_,
    // use maxFlushTimes to avoid dead cycle.
    int maxFlushTimes = 3;
    while (!dirtyNodes_.empty() && maxFlushTimes > 0) {
        ArkUIPerfMonitor::GetInstance().RecordStateMgmtNode(dirtyNodes_.size());
        decltype(dirtyNodes_) dirtyNodes(std::move(dirtyNodes_));
        for (const auto& node : dirtyNodes) {
            if (AceType::InstanceOf<NG::CustomNodeBase>(node)) {
                auto customNode = AceType::DynamicCast<NG::CustomNodeBase>(node);
                ACE_SCOPED_TRACE("CustomNodeUpdate %s", customNode->GetJSViewName().c_str());
                customNode->Update();
            }
        }
        --maxFlushTimes;
    }

    if (FrameReport::GetInstance().GetEnable()) {
        FrameReport::GetInstance().EndFlushBuild();
    }
}

uint32_t PipelineContext::AddScheduleTask(const RefPtr<ScheduleTask>& task)
{
    CHECK_RUN_ON(UI);
    scheduleTasks_.try_emplace(++nextScheduleTaskId_, task);
    RequestFrame();
    return nextScheduleTaskId_;
}

void PipelineContext::RemoveScheduleTask(uint32_t id)
{
    CHECK_RUN_ON(UI);
    scheduleTasks_.erase(id);
}

std::tuple<float, float, float, float> PipelineContext::LinearInterpolation(
    const std::tuple<float, float, uint64_t>& history, const std::tuple<float, float, uint64_t>& current,
    const uint64_t nanoTimeStamp)
{
    if (nanoTimeStamp == std::get<INDEX_TIME>(history) || nanoTimeStamp == std::get<INDEX_TIME>(current)) {
        return std::make_tuple(0.0f, 0.0f, 0.0f, 0.0f);
    }
    if (std::get<INDEX_TIME>(current) <= std::get<INDEX_TIME>(history)) {
        return std::make_tuple(0.0f, 0.0f, 0.0f, 0.0f);
    }
    if (std::get<INDEX_TIME>(current) - std::get<INDEX_TIME>(history) > INTERPOLATION_THRESHOLD) {
        return std::make_tuple(0.0f, 0.0f, 0.0f, 0.0f);
    }
    if (nanoTimeStamp < std::get<INDEX_TIME>(history)) {
        return std::make_tuple(0.0f, 0.0f, 0.0f, 0.0f);
    }
    auto inputXDeltaSlope = (std::get<INDEX_X>(current) - std::get<INDEX_X>(history)) * ONE_S_IN_NS /
                            (float)(std::get<INDEX_TIME>(current) - std::get<INDEX_TIME>(history));
    auto inputYDeltaSlope = (std::get<INDEX_Y>(current) - std::get<INDEX_Y>(history)) * ONE_S_IN_NS /
                            (float)(std::get<INDEX_TIME>(current) - std::get<INDEX_TIME>(history));
    if (nanoTimeStamp < std::get<INDEX_TIME>(current)) {
        float alpha = (float)(nanoTimeStamp - std::get<INDEX_TIME>(history)) /
                      (float)(std::get<INDEX_TIME>(current) - std::get<INDEX_TIME>(history));
        float x = std::get<INDEX_X>(history) + alpha * (std::get<INDEX_X>(current) - std::get<INDEX_X>(history));
        float y = std::get<INDEX_Y>(history) + alpha * (std::get<INDEX_Y>(current) - std::get<INDEX_Y>(history));
        return std::make_tuple(x, y, inputXDeltaSlope, inputYDeltaSlope);
    } else if (nanoTimeStamp > std::get<INDEX_TIME>(current)) {
        float alpha = (float)(nanoTimeStamp - std::get<INDEX_TIME>(current)) /
                      (float)(std::get<INDEX_TIME>(current) - std::get<INDEX_TIME>(history));
        float x = std::get<INDEX_X>(current) + alpha * (std::get<INDEX_X>(current) - std::get<INDEX_X>(history));
        float y = std::get<INDEX_Y>(current) + alpha * (std::get<INDEX_Y>(current) - std::get<INDEX_Y>(history));
        return std::make_tuple(x, y, inputXDeltaSlope, inputYDeltaSlope);
    }
    return std::make_tuple(0.0f, 0.0f, 0.0f, 0.0f);
}

std::tuple<float, float, uint64_t> PipelineContext::GetAvgPoint(
    const std::vector<TouchEvent>& events, const bool isScreen)
{
    float avgX = 0.0f;
    float avgY = 0.0f;
    uint64_t avgTime = 0;
    int32_t i = 0;
    uint64_t lastTime = 0;
    for (auto iter = events.begin(); iter != events.end(); iter++) {
        if (lastTime == 0 || static_cast<uint64_t>(iter->time.time_since_epoch().count()) != lastTime) {
            if (!isScreen) {
                avgX += iter->x;
                avgY += iter->y;
            } else {
                avgX += iter->screenX;
                avgY += iter->screenY;
            }
            avgTime += static_cast<uint64_t>(iter->time.time_since_epoch().count());
            i++;
            lastTime = static_cast<uint64_t>(iter->time.time_since_epoch().count());
        }
    }
    if (i > 0) {
        avgX /= i;
        avgY /= i;
        avgTime /= static_cast<uint64_t>(i);
    }
    return std::make_tuple(avgX, avgY, avgTime);
}

std::tuple<float, float, float, float> PipelineContext::GetResampleCoord(const std::vector<TouchEvent>& history,
    const std::vector<TouchEvent>& current, const uint64_t nanoTimeStamp, const bool isScreen)
{
    if (history.empty() || current.empty()) {
        return std::make_tuple(0.0f, 0.0f, 0.0f, 0.0f);
    }
    uint64_t lastNanoTime = 0;
    float x = 0.0f;
    float y = 0.0f;
    for (const auto& item : current) {
        uint64_t currentNanoTime = static_cast<uint64_t>(item.time.time_since_epoch().count());
        if (lastNanoTime < currentNanoTime) {
            lastNanoTime = currentNanoTime;
            x = item.x;
            y = item.y;
        }
    }
    if (nanoTimeStamp > RESAMPLE_COORD_TIME_THRESHOLD + lastNanoTime) {
        return std::make_tuple(x, y, 0.0f, 0.0f);
    }
    auto historyPoint = GetAvgPoint(history, isScreen);
    auto currentPoint = GetAvgPoint(current, isScreen);

    if (SystemProperties::GetDebugEnabled()) {
        TAG_LOGD(AceLogTag::ACE_UIEVENT, "input time is %{public}" PRIu64 "", nanoTimeStamp);
        for (auto iter : history) {
            TAG_LOGD(AceLogTag::ACE_UIEVENT, "history point x %{public}f, y %{public}f, time %{public}" PRIu64 "",
                iter.x, iter.y, static_cast<uint64_t>(iter.time.time_since_epoch().count()));
        }
        TAG_LOGD(AceLogTag::ACE_UIEVENT, "historyAvgPoint is x %{public}f, y %{public}f, time %{public}" PRIu64 "",
            std::get<INDEX_X>(historyPoint), std::get<INDEX_Y>(historyPoint), std::get<INDEX_TIME>(historyPoint));
        for (auto iter : current) {
            TAG_LOGD(AceLogTag::ACE_UIEVENT, "current point x %{public}f, y %{public}f, time %{public}" PRIu64 "",
                iter.x, iter.y, static_cast<uint64_t>(iter.time.time_since_epoch().count()));
        }
        TAG_LOGD(AceLogTag::ACE_UIEVENT, "currentAvgPoint is x %{public}f, y %{public}f, time %{public}" PRIu64 "",
            std::get<INDEX_X>(currentPoint), std::get<INDEX_Y>(currentPoint), std::get<INDEX_TIME>(currentPoint));
    }
    return LinearInterpolation(historyPoint, currentPoint, nanoTimeStamp);
}

bool PipelineContext::GetResampleTouchEvent(const std::vector<TouchEvent>& history,
    const std::vector<TouchEvent>& current, const uint64_t nanoTimeStamp, TouchEvent& newTouchEvent)
{
    auto newXy = GetResampleCoord(history, current, nanoTimeStamp, false);
    auto newScreenXy = GetResampleCoord(history, current, nanoTimeStamp, true);
    newTouchEvent = GetLatestPoint(current, nanoTimeStamp);
    bool ret = false;
    if (std::get<INDEX_X>(newXy) != 0 && std::get<INDEX_Y>(newXy) != 0) {
        newTouchEvent.x = std::get<INDEX_X>(newXy);
        newTouchEvent.y = std::get<INDEX_Y>(newXy);
        newTouchEvent.screenX = std::get<INDEX_X>(newScreenXy);
        newTouchEvent.screenY = std::get<INDEX_Y>(newScreenXy);
        std::chrono::nanoseconds nanoseconds(nanoTimeStamp);
        newTouchEvent.time = TimeStamp(nanoseconds);
        newTouchEvent.history = current;
        newTouchEvent.isInterpolated = true;
        newTouchEvent.inputXDeltaSlope = std::get<INDEX_X_SLOPE>(newXy);
        newTouchEvent.inputYDeltaSlope = std::get<INDEX_Y_SLOPE>(newXy);
        ret = true;
    }
    if (SystemProperties::GetDebugEnabled()) {
        TAG_LOGD(AceLogTag::ACE_UIEVENT,
            "Interpolate point is %{public}d, %{public}f, %{public}f, %{public}f, %{public}f, %{public}" PRIu64 "",
            newTouchEvent.id, newTouchEvent.x, newTouchEvent.y, newTouchEvent.screenX, newTouchEvent.screenY,
            static_cast<uint64_t>(newTouchEvent.time.time_since_epoch().count()));
    }
    return ret;
}

TouchEvent PipelineContext::GetLatestPoint(const std::vector<TouchEvent>& current, const uint64_t nanoTimeStamp)
{
    TouchEvent result;
    uint64_t gap = UINT64_MAX;
    for (auto iter = current.begin(); iter != current.end(); iter++) {
        uint64_t timeStamp = static_cast<uint64_t>(iter->time.time_since_epoch().count());
        if (timeStamp == nanoTimeStamp) {
            result = *iter;
            return result;
        } else if (timeStamp > nanoTimeStamp) {
            if (timeStamp - nanoTimeStamp < gap) {
                gap = timeStamp - nanoTimeStamp;
                result = *iter;
            }
        } else {
            if (nanoTimeStamp - timeStamp < gap) {
                gap = nanoTimeStamp - timeStamp;
                result = *iter;
            }
        }
    }
    return result;
}

void PipelineContext::FlushOnceVsyncTask()
{
    if (onceVsyncListener_ != nullptr) {
        onceVsyncListener_();
        onceVsyncListener_ = nullptr;
    }
}

void PipelineContext::FlushVsync(uint64_t nanoTimestamp, uint32_t frameCount)
{
    CHECK_RUN_ON(UI);
    if (IsDestroyed()) {
        LOGW("Cannot flush vsync as the pipeline context is destroyed.");
        return;
    }
    ACE_SCOPED_TRACE_COMMERCIAL("UIVsyncTask[timestamp:%" PRIu64 "][vsyncID:%" PRIu64 "][instanceID:%d]", nanoTimestamp,
        static_cast<uint64_t>(frameCount), instanceId_);
    window_->Lock();
    static const std::string abilityName = AceApplicationInfo::GetInstance().GetProcessName().empty()
                                               ? AceApplicationInfo::GetInstance().GetPackageName()
                                               : AceApplicationInfo::GetInstance().GetProcessName();
    window_->RecordFrameTime(nanoTimestamp, abilityName);
    resampleTimeStamp_ = nanoTimestamp - static_cast<uint64_t>(window_->GetVSyncPeriod()) + ONE_MS_IN_NS -\
        compensationValue_;
#ifdef UICAST_COMPONENT_SUPPORTED
    do {
        auto container = Container::Current();
        CHECK_NULL_BREAK(container);
        auto distributedUI = container->GetDistributedUI();
        CHECK_NULL_BREAK(distributedUI);
        distributedUI->ApplyOneUpdate();
    } while (false);
#endif
    ProcessDelayTasks();
    DispatchDisplaySync(nanoTimestamp);
    FlushAnimation(nanoTimestamp);
    FlushFrameCallback(nanoTimestamp);
    SetVsyncTime(nanoTimestamp);
    auto hasRunningAnimation = FlushModifierAnimation(nanoTimestamp);
    FlushTouchEvents();
    FlushBuild();
    if (isFormRender_ && drawDelegate_ && rootNode_) {
        auto renderContext = AceType::DynamicCast<NG::RenderContext>(rootNode_->GetRenderContext());
        drawDelegate_->DrawRSFrame(renderContext);
        drawDelegate_ = nullptr;
    }
    if (!taskScheduler_->isEmpty()) {
#if !defined(PREVIEW)
        LayoutInspector::SupportInspector();
#endif
    }

    taskScheduler_->StartRecordFrameInfo(GetCurrentFrameInfo(recvTime_, nanoTimestamp));
    taskScheduler_->FlushTask();
    UIObserverHandler::GetInstance().HandleLayoutDoneCallBack();
    // flush correct rect again
    taskScheduler_->FlushPersistAfterLayoutTask();
    taskScheduler_->FlushLatestFrameLayoutFinishTask();
    taskScheduler_->FinishRecordFrameInfo();
    FlushNodeChangeFlag();
    FlushAnimationClosure();
    TryCallNextFrameLayoutCallback();

#ifdef UICAST_COMPONENT_SUPPORTED
    do {
        auto container = Container::Current();
        CHECK_NULL_BREAK(container);
        auto distributedUI = container->GetDistributedUI();
        CHECK_NULL_BREAK(distributedUI);
        distributedUI->OnTreeUpdate();
    } while (false);
#endif

    if (hasRunningAnimation || window_->HasUIRunningAnimation()) {
        RequestFrame();
    }
    window_->FlushModifier();
    FlushFrameRate();
    if (dragWindowVisibleCallback_) {
        dragWindowVisibleCallback_();
        dragWindowVisibleCallback_ = nullptr;
    }
    if (isFirstFlushMessages_) {
        isFirstFlushMessages_ = false;
        LOGI("ArkUi flush first frame messages.");
    }
    FlushMessages();
    InspectDrew();
    UIObserverHandler::GetInstance().HandleDrawCommandSendCallBack();
    FlushWindowPatternInfo();
    if (onShow_ && onFocus_ && isWindowHasFocused_) {
        auto isDynamicRender = Container::Current() == nullptr ? false : Container::Current()->IsDynamicRender();
        if ((!isFormRender_) || isDynamicRender) {
            FlushFocusView();
            FlushFocus();
            FlushFocusScroll();
        }
    }
    HandleOnAreaChangeEvent(nanoTimestamp);
    HandleVisibleAreaChangeEvent(nanoTimestamp);
    if (isNeedFlushMouseEvent_) {
        FlushMouseEvent();
        isNeedFlushMouseEvent_ = false;
    }
    if (isNeedFlushAnimationStartTime_) {
        window_->FlushAnimationStartTime(animationTimeStamp_);
        isNeedFlushAnimationStartTime_ = false;
    }
    needRenderNode_.clear();
    taskScheduler_->FlushAfterRenderTask();
    FireAccessibilityEvents();
    // Keep the call sent at the end of the function
    ResSchedReport::GetInstance().LoadPageEvent(ResDefine::LOAD_PAGE_COMPLETE_EVENT);
    window_->Unlock();
}

void PipelineContext::FlushWindowPatternInfo()
{
#ifdef WINDOW_SCENE_SUPPORTED
    auto container = Container::Current();
    CHECK_NULL_VOID(container);
    if (!container->IsScenceBoardWindow()) {
        return;
    }
    auto screenNode = screenNode_.Upgrade();
    if (!screenNode) {
        return;
    }
    ACE_SCOPED_TRACE("FlushWindowPatternInfo");
    auto instance = WindowSceneLayoutManager::GetInstance();
    if (instance != nullptr) {
        instance->FlushWindowPatternInfo(screenNode);
    }
#endif
}

void PipelineContext::InspectDrew()
{
    CHECK_RUN_ON(UI);
    if (!needRenderNode_.empty()) {
        auto needRenderNode = std::move(needRenderNode_);
        for (auto&& nodeWeak : needRenderNode) {
            auto node = nodeWeak.Upgrade();
            if (node) {
                OnDrawCompleted(node->GetInspectorId()->c_str());
            }
        }
    }
}

void PipelineContext::ProcessDelayTasks()
{
    if (delayedTasks_.empty()) {
        return;
    }
    auto currentTimeStamp = GetSysTimestamp();
    auto delayedTasks = std::move(delayedTasks_);
    auto result = std::remove_if(delayedTasks.begin(), delayedTasks.end(), [this, currentTimeStamp](const auto& task) {
        if (task.timeStamp + static_cast<int64_t>(task.time) * MILLISECONDS_TO_NANOSECONDS > currentTimeStamp) {
            delayedTasks_.emplace_back(task);
            return true;
        }
        return false;
    });
    delayedTasks.erase(result, delayedTasks.end());
    std::for_each(delayedTasks.begin(), delayedTasks.end(), [this](auto& delayedTask) {
        if (delayedTask.task) {
            delayedTask.task();
        }
    });
}

void PipelineContext::DispatchDisplaySync(uint64_t nanoTimestamp)
{
    CHECK_RUN_ON(UI);
    ACE_FUNCTION_TRACE();

    GetOrCreateUIDisplaySyncManager()->SetRefreshRateMode(window_->GetCurrentRefreshRateMode());
    GetOrCreateUIDisplaySyncManager()->SetVsyncPeriod(window_->GetVSyncPeriod());

    if (FrameReport::GetInstance().GetEnable()) {
        FrameReport::GetInstance().BeginFlushAnimation();
    }

    scheduleTasks_.clear();
    GetOrCreateUIDisplaySyncManager()->DispatchFunc(nanoTimestamp);

    if (FrameReport::GetInstance().GetEnable()) {
        FrameReport::GetInstance().EndFlushAnimation();
    }

    int32_t displaySyncRate = GetOrCreateUIDisplaySyncManager()->GetDisplaySyncRate();
    frameRateManager_->SetDisplaySyncRate(displaySyncRate);
    ArkUIPerfMonitor::GetInstance().RecordDisplaySyncRate(displaySyncRate);
}

void PipelineContext::FlushAnimation(uint64_t nanoTimestamp)
{
    CHECK_RUN_ON(UI);
    ACE_FUNCTION_TRACE();
    if (scheduleTasks_.empty()) {
        return;
    }
}

void PipelineContext::FlushModifier()
{
    window_->FlushModifier();
}

void PipelineContext::FlushMessages()
{
    ACE_FUNCTION_TRACE();
    if (IsFreezeFlushMessage()) {
        SetIsFreezeFlushMessage(false);
        LOGI("Flush message is freezed.");
        return;
    }
    window_->FlushTasks();
}

void PipelineContext::FlushUITasks(bool triggeredByImplicitAnimation)
{
    window_->Lock();
    if (!CheckThreadSafe()) {
        LOGW("FlushUITasks doesn't run on UI thread!");
    }
    decltype(dirtyPropertyNodes_) dirtyPropertyNodes(std::move(dirtyPropertyNodes_));
    dirtyPropertyNodes_.clear();
    for (const auto& dirtyNode : dirtyPropertyNodes) {
        dirtyNode->ProcessPropertyDiff();
    }
    taskScheduler_->FlushTask(triggeredByImplicitAnimation);
    window_->Unlock();
}

void PipelineContext::FlushUITaskWithSingleDirtyNode(const RefPtr<FrameNode>& node)
{
    CHECK_NULL_VOID(node);
    auto layoutProperty = node->GetLayoutProperty();
    CHECK_NULL_VOID(layoutProperty);
    auto layoutConstraint = node->GetLayoutConstraint();
    auto originLayoutingFlag = IsLayouting();
    SetIsLayouting(true);
    if (layoutProperty->GetLayoutRect()) {
        node->SetActive(true, true);
        node->Measure(std::nullopt);
        node->Layout();
    } else {
        auto ancestorNodeOfFrame = node->GetAncestorNodeOfFrame();
        {
            ACE_SCOPED_TRACE("FlushUITaskWithSingleDirtyNodeMeasure[%s][self:%d][parent:%d][layoutConstraint:%s]"
                             "[pageId:%d][depth:%d]",
                node->GetTag().c_str(), node->GetId(), ancestorNodeOfFrame ? ancestorNodeOfFrame->GetId() : 0,
                layoutConstraint.ToString().c_str(), node->GetPageId(), node->GetDepth());
            node->Measure(layoutConstraint);
        }
        {
            ACE_SCOPED_TRACE("FlushUITaskWithSingleDirtyNodeLayout[%s][self:%d][parent:%d][pageId:%d][depth:%d]",
                node->GetTag().c_str(), node->GetId(), ancestorNodeOfFrame ? ancestorNodeOfFrame->GetId() : 0,
                node->GetPageId(), node->GetDepth());
            node->Layout();
        }
    }
    SetIsLayouting(originLayoutingFlag);
}

void PipelineContext::FlushAfterLayoutCallbackInImplicitAnimationTask()
{
    if (AnimationUtils::IsImplicitAnimationOpen()) {
        TAG_LOGI(AceLogTag::ACE_ANIMATION,
            "Can not flush implicit animation task after layout because implicit animation is open.");
        return;
    }
    window_->Lock();
    taskScheduler_->FlushAfterLayoutCallbackInImplicitAnimationTask();
    window_->Unlock();
}

void PipelineContext::SetNeedRenderNode(const WeakPtr<FrameNode>& node)
{
    CHECK_RUN_ON(UI);
    needRenderNode_.insert(node);
}

void PipelineContext::FlushFocus()
{
    CHECK_RUN_ON(UI);
    ACE_FUNCTION_TRACK();
    ACE_FUNCTION_TRACE();

    FlushRequestFocus();

    auto focusNode = dirtyFocusNode_.Upgrade();
    if (!focusNode || focusNode->GetFocusType() != FocusType::NODE) {
        dirtyFocusNode_.Reset();
    } else {
        FlushFocusWithNode(focusNode, false);
        return;
    }
    auto focusScope = dirtyFocusScope_.Upgrade();
    if (!focusScope || focusScope->GetFocusType() != FocusType::SCOPE) {
        dirtyFocusScope_.Reset();
    } else {
        FlushFocusWithNode(focusScope, true);
        return;
    }
    GetOrCreateFocusManager()->WindowFocusMoveEnd();
}

void PipelineContext::FlushFocusWithNode(RefPtr<FrameNode> focusNode, bool isScope)
{
    auto focusNodeHub = focusNode->GetFocusHub();
    if (focusNodeHub && !focusNodeHub->RequestFocusImmediately()) {
        auto unfocusableParentFocusNode = focusNodeHub->GetUnfocusableParentFocusNode().Upgrade();
        if (unfocusableParentFocusNode) {
            TAG_LOGI(AceLogTag::ACE_FOCUS,
                "Request focus on %{public}s: %{public}s/%{public}d return false, unfocusable node: "
                "%{public}s/%{public}d, focusable = %{public}d, shown = %{public}d, enabled = %{public}d",
                isScope ? "scope" : "node", focusNode->GetTag().c_str(), focusNode->GetId(),
                unfocusableParentFocusNode->GetFrameName().c_str(), unfocusableParentFocusNode->GetFrameId(),
                unfocusableParentFocusNode->GetFocusable(), unfocusableParentFocusNode->IsShow(),
                unfocusableParentFocusNode->IsEnabled());
            unfocusableParentFocusNode = nullptr;
        } else {
            TAG_LOGI(AceLogTag::ACE_FOCUS, "Request focus on %{public}s: %{public}s/%{public}d return false",
                isScope ? "scope" : "node", focusNode->GetTag().c_str(), focusNode->GetId());
        }
    }
    dirtyFocusNode_.Reset();
    dirtyFocusScope_.Reset();
    dirtyRequestFocusNode_.Reset();
    GetOrCreateFocusManager()->WindowFocusMoveEnd();
}

void PipelineContext::FlushRequestFocus()
{
    CHECK_RUN_ON(UI);

    auto requestFocusNode = dirtyRequestFocusNode_.Upgrade();
    if (!requestFocusNode) {
        dirtyRequestFocusNode_.Reset();
    } else {
        auto focusNodeHub = requestFocusNode->GetFocusHub();
        if (focusNodeHub && !focusNodeHub->RequestFocusImmediately()) {
            auto unfocusableParentFocusNode = focusNodeHub->GetUnfocusableParentFocusNode().Upgrade();
            if (unfocusableParentFocusNode) {
                TAG_LOGI(AceLogTag::ACE_FOCUS,
                    "Request focus by id on node: %{public}s/%{public}d return false, unfocusable node: "
                    "%{public}s/%{public}d, focusable = %{public}d, shown = %{public}d, enabled = %{public}d",
                    requestFocusNode->GetTag().c_str(), requestFocusNode->GetId(),
                    unfocusableParentFocusNode->GetFrameName().c_str(), unfocusableParentFocusNode->GetFrameId(),
                    unfocusableParentFocusNode->GetFocusable(), unfocusableParentFocusNode->IsShow(),
                    unfocusableParentFocusNode->IsEnabled());
                unfocusableParentFocusNode = nullptr;
            }
        }
        dirtyFocusNode_.Reset();
        dirtyFocusScope_.Reset();
        dirtyRequestFocusNode_.Reset();
        return;
    }
}

void PipelineContext::FlushFocusView()
{
    CHECK_NULL_VOID(focusManager_);
    auto lastFocusView = (focusManager_->GetLastFocusView()).Upgrade();
    CHECK_NULL_VOID(lastFocusView);
    auto lastFocusViewHub = lastFocusView->GetFocusHub();
    CHECK_NULL_VOID(lastFocusViewHub);
    auto container = Container::Current();
    if (container && (container->IsUIExtensionWindow() || container->IsDynamicRender()) &&
        (!lastFocusView->IsRootScopeCurrentFocus())) {
        lastFocusView->SetIsViewRootScopeFocused(false);
    }
    if (lastFocusView && (!lastFocusView->IsRootScopeCurrentFocus() || !lastFocusView->GetIsViewHasFocused()) &&
        lastFocusViewHub->IsFocusableNode()) {
        lastFocusView->RequestDefaultFocus();
    }
}

void PipelineContext::FlushFocusScroll()
{
    CHECK_NULL_VOID(focusManager_);
    if (!focusManager_->GetNeedTriggerScroll()) {
        return;
    }
    auto lastFocusStateNode = focusManager_->GetLastFocusStateNode();
    CHECK_NULL_VOID(lastFocusStateNode);
    if (!lastFocusStateNode->TriggerFocusScroll()) {
        focusManager_->SetNeedTriggerScroll(false);
    }
}

void PipelineContext::FlushPipelineImmediately()
{
    CHECK_RUN_ON(UI);
    ACE_FUNCTION_TRACE();
    FlushPipelineWithoutAnimation();
}

void PipelineContext::RebuildFontNode()
{
    if (fontManager_) {
        fontManager_->RebuildFontNodeNG();
    }
}

void PipelineContext::FlushPipelineWithoutAnimation()
{
    ACE_FUNCTION_TRACE();
    window_->Lock();
    FlushBuild();
    FlushTouchEvents();
    taskScheduler_->FlushTask();
    FlushAnimationClosure();
    window_->FlushModifier();
    FlushMessages();
    FlushFocus();
    window_->Unlock();
}

void PipelineContext::FlushFrameRate()
{
    frameRateManager_->SetAnimateRate(window_->GetAnimateExpectedRate());
    int32_t currAnimatorExpectedFrameRate = GetOrCreateUIDisplaySyncManager()->GetAnimatorRate();
    if (frameRateManager_->IsRateChanged() || currAnimatorExpectedFrameRate != lastAnimatorExpectedFrameRate_) {
        auto [rate, rateType] = frameRateManager_->GetExpectedRate();
        ACE_SCOPED_TRACE("FlushFrameRate Expected frameRate = %d frameRateType = %d "
            "currAnimatorExpectedFrameRate = %d, lastAnimatorExpectedFrameRate = %d",
            rate, rateType, currAnimatorExpectedFrameRate, lastAnimatorExpectedFrameRate_);
        TAG_LOGD(AceLogTag::ACE_DISPLAY_SYNC, "FlushFrameRate Expected frameRate = %{public}d "
            "frameRateType = %{public}d currAnimatorExpectedFrameRate = %{public}d, lastRate = %{public}d",
            rate, rateType, currAnimatorExpectedFrameRate, lastAnimatorExpectedFrameRate_);
        window_->FlushFrameRate(rate, currAnimatorExpectedFrameRate, rateType);
        frameRateManager_->SetIsRateChanged(false);
        lastAnimatorExpectedFrameRate_ = currAnimatorExpectedFrameRate;
    }
}

void PipelineContext::FlushBuild()
{
    if (vsyncListener_ != nullptr) {
        ACE_SCOPED_TRACE("arkoala build");
        vsyncListener_();
    }
    FlushOnceVsyncTask();
    isRebuildFinished_ = false;
    FlushDirtyNodeUpdate();
    isRebuildFinished_ = true;
    FlushBuildFinishCallbacks();
}

void PipelineContext::AddAnimationClosure(std::function<void()>&& animation)
{
    animationClosuresList_.emplace_back(std::move(animation));
}

void PipelineContext::FlushAnimationClosure()
{
    if (animationClosuresList_.empty()) {
        return;
    }
    window_->Lock();
    taskScheduler_->FlushTask();

    decltype(animationClosuresList_) temp(std::move(animationClosuresList_));
    for (const auto& animation : temp) {
        animation();
    }
    window_->Unlock();
}

void PipelineContext::FlushBuildFinishCallbacks()
{
    decltype(buildFinishCallbacks_) buildFinishCallbacks(std::move(buildFinishCallbacks_));
    for (const auto& func : buildFinishCallbacks) {
        if (func) {
            func();
        }
    }
}

void PipelineContext::RegisterRootEvent()
{
    if (!IsFormRender()) {
        return;
    }
    auto accessibilityProperty = rootNode_->GetAccessibilityProperty<AccessibilityProperty>();
    if (accessibilityProperty != nullptr) {
        accessibilityProperty->SetAccessibilityLevel(AccessibilityProperty::Level::NO_STR);
    }

    // To avoid conflicts between longPress and click events on the card,
    // use an empty longPress event placeholder in the EtsCard scenario
    auto hub = rootNode_->GetOrCreateGestureEventHub();
    CHECK_NULL_VOID(hub);
    auto event = [](const GestureEvent& info) mutable {};
    auto longPress = AceType::MakeRefPtr<NG::LongPressEvent>(std::move(event));
    hub->SetLongPressEvent(longPress, false, true);
}

void PipelineContext::SetupRootElement()
{
    CHECK_RUN_ON(UI);
    rootNode_ = FrameNode::CreateFrameNodeWithTree(
        V2::ROOT_ETS_TAG, ElementRegister::GetInstance()->MakeUniqueId(), MakeRefPtr<RootPattern>());
    rootNode_->SetHostRootId(GetInstanceId());
    rootNode_->SetHostPageId(-1);
    rootNode_->SetActive(true);
    RegisterRootEvent();
    CalcSize idealSize { CalcLength(rootWidth_), CalcLength(rootHeight_) };
    MeasureProperty layoutConstraint;
    layoutConstraint.selfIdealSize = idealSize;
    layoutConstraint.maxSize = idealSize;
    rootNode_->UpdateLayoutConstraint(layoutConstraint);
    auto rootFocusHub = rootNode_->GetOrCreateFocusHub();
    rootFocusHub->SetFocusType(FocusType::SCOPE);
    rootFocusHub->SetFocusable(true);
    window_->SetRootFrameNode(rootNode_);
    rootNode_->AttachToMainTree(false, this);
    auto stagePattern = ViewAdvancedRegister::GetInstance()->GeneratePattern(V2::STAGE_ETS_TAG);
    if (!stagePattern) {
        stagePattern = MakeRefPtr<StagePattern>();
    }
    auto stageNode = FrameNode::CreateFrameNode(
        V2::STAGE_ETS_TAG, ElementRegister::GetInstance()->MakeUniqueId(), stagePattern);
    RefPtr<AppBarView> appBar = AceType::MakeRefPtr<AppBarView>();
    auto atomicService = installationFree_ ? appBar->Create(stageNode) : nullptr;
    auto container = Container::Current();
    if (container) {
        container->SetAppBar(appBar);
    }
    if (windowModal_ == WindowModal::CONTAINER_MODAL) {
        MaximizeMode maximizeMode = GetWindowManager()->GetWindowMaximizeMode();
        rootNode_->AddChild(
            ContainerModalViewFactory::GetView(atomicService ? atomicService : stageNode, maximizeMode));
    } else {
        rootNode_->AddChild(atomicService ? atomicService : stageNode);
    }
#ifdef ENABLE_ROSEN_BACKEND
    if (!IsJsCard() && !isFormRender_) {
        auto window = GetWindow();
        if (window) {
            auto rsUIDirector = window->GetRSUIDirector();
            if (rsUIDirector) {
                rsUIDirector->SetAbilityBGAlpha(appBgColor_.GetAlpha());
            }
        }
    }
#endif
#ifdef WINDOW_SCENE_SUPPORTED
    uiExtensionManager_ = MakeRefPtr<UIExtensionManager>();
#endif
    accessibilityManagerNG_ = MakeRefPtr<AccessibilityManagerNG>();
    stageManager_ = ViewAdvancedRegister::GetInstance()->GenerateStageManager(stageNode);
    if (!stageManager_) {
        stageManager_ = MakeRefPtr<StageManager>(stageNode);
    }
    overlayManager_ = MakeRefPtr<OverlayManager>(
        DynamicCast<FrameNode>(installationFree_ ? stageNode->GetParent()->GetParent() : stageNode->GetParent()));
    fullScreenManager_ = MakeRefPtr<FullScreenManager>(rootNode_);
    selectOverlayManager_ = MakeRefPtr<SelectOverlayManager>(rootNode_);
    fontManager_->AddFontObserver(selectOverlayManager_);
    if (!privacySensitiveManager_) {
        privacySensitiveManager_ = MakeRefPtr<PrivacySensitiveManager>();
    }
    postEventManager_ = MakeRefPtr<PostEventManager>();
    dragDropManager_ = MakeRefPtr<DragDropManager>();
    focusManager_ = GetOrCreateFocusManager();
    sharedTransitionManager_ = MakeRefPtr<SharedOverlayManager>(
        DynamicCast<FrameNode>(installationFree_ ? stageNode->GetParent()->GetParent() : stageNode->GetParent()));

    OnAreaChangedFunc onAreaChangedFunc = [weakOverlayManger = AceType::WeakClaim(AceType::RawPtr(overlayManager_))](
                                              const RectF& /* oldRect */, const OffsetF& /* oldOrigin */,
                                              const RectF& /* rect */, const OffsetF& /* origin */) {
        TAG_LOGD(AceLogTag::ACE_OVERLAY, "start OnAreaChangedFunc");
        auto overlay = weakOverlayManger.Upgrade();
        CHECK_NULL_VOID(overlay);
        overlay->HideAllMenus();
        SubwindowManager::GetInstance()->HideMenuNG(false);
        overlay->HideCustomPopups();
        SubwindowManager::GetInstance()->ClearToastInSubwindow();
        SubwindowManager::GetInstance()->ClearToastInSystemSubwindow();
        overlay->UpdateCustomKeyboardPosition();
    };
    rootNode_->SetOnAreaChangeCallback(std::move(onAreaChangedFunc));
    AddOnAreaChangeNode(rootNode_->GetId());
}

void PipelineContext::SetupSubRootElement()
{
    CHECK_RUN_ON(UI);
    appBgColor_ = Color::TRANSPARENT;
    rootNode_ = FrameNode::CreateFrameNodeWithTree(
        V2::ROOT_ETS_TAG, ElementRegister::GetInstance()->MakeUniqueId(), MakeRefPtr<RootPattern>());
    rootNode_->SetHostRootId(GetInstanceId());
    rootNode_->SetHostPageId(-1);
    rootNode_->SetActive(true);
    CalcSize idealSize { CalcLength(rootWidth_), CalcLength(rootHeight_) };
    MeasureProperty layoutConstraint;
    layoutConstraint.selfIdealSize = idealSize;
    layoutConstraint.maxSize = idealSize;
    rootNode_->UpdateLayoutConstraint(layoutConstraint);
    auto rootFocusHub = rootNode_->GetOrCreateFocusHub();
    rootFocusHub->SetFocusType(FocusType::SCOPE);
    rootFocusHub->SetFocusable(true);
    window_->SetRootFrameNode(rootNode_);
    rootNode_->AttachToMainTree(false, this);

#ifdef ENABLE_ROSEN_BACKEND
    if (!IsJsCard()) {
        auto window = GetWindow();
        if (window) {
            auto rsUIDirector = window->GetRSUIDirector();
            if (rsUIDirector) {
                rsUIDirector->SetAbilityBGAlpha(appBgColor_.GetAlpha());
            }
        }
    }
#endif
#ifdef WINDOW_SCENE_SUPPORTED
    uiExtensionManager_ = MakeRefPtr<UIExtensionManager>();
#endif
    accessibilityManagerNG_ = MakeRefPtr<AccessibilityManagerNG>();
    // the subwindow for overlay not need stage
    stageManager_ = ViewAdvancedRegister::GetInstance()->GenerateStageManager(nullptr);
    if (!stageManager_) {
        stageManager_ = MakeRefPtr<StageManager>(nullptr);
    }
    overlayManager_ = MakeRefPtr<OverlayManager>(rootNode_);
    fullScreenManager_ = MakeRefPtr<FullScreenManager>(rootNode_);
    selectOverlayManager_ = MakeRefPtr<SelectOverlayManager>(rootNode_);
    fontManager_->AddFontObserver(selectOverlayManager_);
    dragDropManager_ = MakeRefPtr<DragDropManager>();
    focusManager_ = GetOrCreateFocusManager();
    postEventManager_ = MakeRefPtr<PostEventManager>();
}

RefPtr<AccessibilityManagerNG> PipelineContext::GetAccessibilityManagerNG()
{
    return accessibilityManagerNG_;
}

void PipelineContext::SendEventToAccessibilityWithNode(
    const AccessibilityEvent& accessibilityEvent, const RefPtr<FrameNode>& node)
{
    auto accessibilityManager = GetAccessibilityManager();
    if (!accessibilityManager || !AceApplicationInfo::GetInstance().IsAccessibilityEnabled()) {
        return;
    }
    accessibilityManager->SendEventToAccessibilityWithNode(accessibilityEvent, node, Claim(this));
}

const RefPtr<StageManager>& PipelineContext::GetStageManager()
{
    return stageManager_;
}

const RefPtr<DragDropManager>& PipelineContext::GetDragDropManager()
{
    return dragDropManager_;
}

const RefPtr<FocusManager>& PipelineContext::GetFocusManager() const
{
    return focusManager_;
}

const RefPtr<FocusManager>& PipelineContext::GetOrCreateFocusManager()
{
    if (!focusManager_) {
        focusManager_ = MakeRefPtr<FocusManager>(AceType::Claim(this));
        RegisterFocusCallback();
    }
    return focusManager_;
}

const RefPtr<SelectOverlayManager>& PipelineContext::GetSelectOverlayManager()
{
    return selectOverlayManager_;
}

const RefPtr<OverlayManager>& PipelineContext::GetOverlayManager()
{
    return overlayManager_;
}

const RefPtr<FullScreenManager>& PipelineContext::GetFullScreenManager()
{
    return fullScreenManager_;
}

void PipelineContext::OnSurfaceChanged(int32_t width, int32_t height, WindowSizeChangeReason type,
    const std::shared_ptr<Rosen::RSTransaction>& rsTransaction)
{
    CHECK_RUN_ON(UI);
    if (NearEqual(rootWidth_, width) && NearEqual(rootHeight_, height) &&
        type == WindowSizeChangeReason::CUSTOM_ANIMATION && !isDensityChanged_) {
        TryCallNextFrameLayoutCallback();
        return;
    }
    ExecuteSurfaceChangedCallbacks(width, height, type);
    auto callback = [weakFrontend = weakFrontend_, width, height]() {
        auto frontend = weakFrontend.Upgrade();
        if (frontend) {
            frontend->OnSurfaceChanged(width, height);
        }
    };
    auto container = Container::Current();
    if (!container) {
        return;
    }
    if (container->IsUseStageModel()) {
        callback();
        FlushBuild();
    } else {
        taskExecutor_->PostTask(callback, TaskExecutor::TaskType::JS, "ArkUISurfaceChanged");
    }

    FlushWindowSizeChangeCallback(width, height, type);
    UpdateHalfFoldHoverProperty(width, height);
    UpdateSizeChangeReason(type, rsTransaction);

#ifdef ENABLE_ROSEN_BACKEND
    StartWindowSizeChangeAnimate(width, height, type, rsTransaction);
#else
    SetRootRect(width, height, 0.0);
#endif
}

void PipelineContext::UpdateHalfFoldHoverProperty(int32_t windowWidth, int32_t windowHeight)
{
    isHoverModeChanged_ = false;
    preIsHalfFoldHoverStatus_ = isHalfFoldHoverStatus_;
    UpdateHalfFoldHoverStatus(windowWidth, windowHeight);
    if (preIsHalfFoldHoverStatus_ != isHalfFoldHoverStatus_) {
        isHoverModeChanged_ = true;
    }
}

void PipelineContext::OnLayoutCompleted(const std::string& componentId)
{
    CHECK_RUN_ON(UI);
    auto frontend = weakFrontend_.Upgrade();
    if (frontend) {
        frontend->OnLayoutCompleted(componentId);
    }
}

void PipelineContext::OnDrawCompleted(const std::string& componentId)
{
    CHECK_RUN_ON(UI);
    auto frontend = weakFrontend_.Upgrade();
    if (frontend) {
        frontend->OnDrawCompleted(componentId);
    }
}

void PipelineContext::ExecuteSurfaceChangedCallbacks(int32_t newWidth, int32_t newHeight, WindowSizeChangeReason type)
{
    for (auto&& [id, callback] : surfaceChangedCallbackMap_) {
        if (callback) {
            callback(newWidth, newHeight, rootWidth_, rootHeight_, type);
        }
    }
}

void PipelineContext::OnSurfacePositionChanged(int32_t posX, int32_t posY)
{
    for (auto&& [id, callback] : surfacePositionChangedCallbackMap_) {
        if (callback) {
            callback(posX, posY);
        }
    }
}

void PipelineContext::OnFoldStatusChange(FoldStatus foldStatus)
{
    for (auto&& [id, callback] : foldStatusChangedCallbackMap_) {
        if (callback) {
            callback(foldStatus);
        }
    }
    StartFoldStatusDelayTask(foldStatus);
}

void PipelineContext::OnFoldDisplayModeChange(FoldDisplayMode foldDisplayMode)
{
    for (auto&& [id, callback] : foldDisplayModeChangedCallbackMap_) {
        if (callback) {
            callback(foldDisplayMode);
        }
    }
}

void PipelineContext::OnTransformHintChanged(uint32_t transform)
{
    for (auto&& [id, callback] : transformHintChangedCallbackMap_) {
        if (callback) {
            callback(transform);
        }
    }
    transform_ = transform;
}

void PipelineContext::StartWindowSizeChangeAnimate(int32_t width, int32_t height, WindowSizeChangeReason type,
    const std::shared_ptr<Rosen::RSTransaction>& rsTransaction)
{
    static const bool IsWindowSizeAnimationEnabled = SystemProperties::IsWindowSizeAnimationEnabled();
    if (!IsWindowSizeAnimationEnabled) {
        SetRootRect(width, height, 0.0);
        return;
    }
    switch (type) {
        case WindowSizeChangeReason::FULL_TO_SPLIT:
        case WindowSizeChangeReason::FULL_TO_FLOATING: {
            StartFullToMultWindowAnimation(width, height, type, rsTransaction);
            break;
        }
        case WindowSizeChangeReason::RECOVER:
        case WindowSizeChangeReason::MAXIMIZE: {
            StartWindowMaximizeAnimation(width, height, rsTransaction);
            break;
        }
        case WindowSizeChangeReason::ROTATION: {
            safeAreaManager_->UpdateKeyboardOffset(0.0);
            SetRootRect(width, height, 0.0);
            FlushUITasks();
            if (textFieldManager_) {
                DynamicCast<TextFieldManagerNG>(textFieldManager_)->ScrollTextFieldToSafeArea();
            }
            FlushUITasks();
            if (!textFieldManager_) {
                break;
            }
            PostKeyboardAvoidTask();
            break;
        }
        case WindowSizeChangeReason::DRAG_START:
        case WindowSizeChangeReason::DRAG:
        case WindowSizeChangeReason::DRAG_END:
        case WindowSizeChangeReason::RESIZE:
        case WindowSizeChangeReason::UNDEFINED:
        default: {
            SetRootRect(width, height, 0.0f);
        }
    }
}

void PipelineContext::PostKeyboardAvoidTask()
{
    auto textFieldManager = DynamicCast<TextFieldManagerNG>(textFieldManager_);
    CHECK_NULL_VOID(textFieldManager);
    CHECK_NULL_VOID(textFieldManager->GetLaterAvoid());
    auto container = Container::Current();
    if (container) {
        auto displayInfo = container->GetDisplayInfo();
        if (displayInfo && textFieldManager->GetLaterOrientation() != (int32_t)displayInfo->GetRotation()) {
            TAG_LOGI(AceLogTag::ACE_KEYBOARD, "orientation not match, clear laterAvoid");
            textFieldManager->SetLaterAvoid(false);
            return;
        }
    }
    TAG_LOGI(AceLogTag::ACE_KEYBOARD, "after rotation set root, trigger avoid now");
    taskExecutor_->PostTask(
        [weakContext = WeakClaim(this), keyboardRect = textFieldManager->GetLaterAvoidKeyboardRect(),
            positionY = textFieldManager->GetLaterAvoidPositionY(),
            height = textFieldManager->GetLaterAvoidHeight(),
            weakManager = WeakPtr<TextFieldManagerNG>(textFieldManager)] {
            auto context = weakContext.Upgrade();
            CHECK_NULL_VOID(context);
            context->OnVirtualKeyboardAreaChange(keyboardRect, positionY, height);
            auto manager = weakManager.Upgrade();
            CHECK_NULL_VOID(manager);
            manager->SetLaterAvoid(false);
        },
        TaskExecutor::TaskType::UI, "ArkUIVirtualKeyboardAreaChange");
}

void PipelineContext::StartWindowMaximizeAnimation(
    int32_t width, int32_t height, const std::shared_ptr<Rosen::RSTransaction>& rsTransaction)
{
    TAG_LOGI(AceLogTag::ACE_ANIMATION,
        "Root node start RECOVER/MAXIMIZE animation, width = %{public}d, height = %{public}d", width, height);
#ifdef ENABLE_ROSEN_BACKEND
    if (rsTransaction) {
        FlushMessages();
        rsTransaction->Begin();
    }
#endif
    AnimationOption option;
    int32_t duration = 400;
    MaximizeMode maximizeMode = GetWindowManager()->GetWindowMaximizeMode();
    bool freeMultiWindowModeEnabled = GetWindowManager()->GetFreeMultiWindowModeEnabledState();
    if (maximizeMode == MaximizeMode::MODE_FULL_FILL || maximizeMode == MaximizeMode::MODE_AVOID_SYSTEM_BAR ||
        freeMultiWindowModeEnabled) {
        int32_t preWidth = GetRootRect().Width();
        int32_t preHeight = GetRootRect().Height();
        if (width > preWidth && height > preHeight) {
            duration = 0;
        }
    }
    option.SetDuration(duration);
    auto curve = Curves::EASE_OUT;
    option.SetCurve(curve);
    auto weak = WeakClaim(this);
    Animate(option, curve, [width, height, weak]() {
        auto pipeline = weak.Upgrade();
        CHECK_NULL_VOID(pipeline);
        pipeline->SetRootRect(width, height, 0.0);
        pipeline->FlushUITasks();
    });
#ifdef ENABLE_ROSEN_BACKEND
    if (rsTransaction) {
        rsTransaction->Commit();
    }
#endif
}

void PipelineContext::StartFullToMultWindowAnimation(int32_t width, int32_t height,
    WindowSizeChangeReason type, const std::shared_ptr<Rosen::RSTransaction>& rsTransaction)
{
    TAG_LOGI(AceLogTag::ACE_ANIMATION,
        "Root node start multiple window animation, type = %{public}d, width = %{public}d, height = %{public}d", type,
        width, height);
#ifdef ENABLE_ROSEN_BACKEND
    if (rsTransaction) {
        FlushMessages();
        rsTransaction->Begin();
    }
#endif
    float response = 0.5f;
    float dampingFraction = 1.0f;
    AnimationOption option;
    if (type == WindowSizeChangeReason::FULL_TO_FLOATING) {
        response = 0.45f;
        dampingFraction = 0.75f;
    }
    auto springMotion = AceType::MakeRefPtr<ResponsiveSpringMotion>(response, dampingFraction, 0);
    option.SetCurve(springMotion);
    auto weak = WeakClaim(this);
    Animate(option, springMotion, [width, height, weak]() {
        auto pipeline = weak.Upgrade();
        CHECK_NULL_VOID(pipeline);
        pipeline->SetRootRect(width, height, 0.0);
        pipeline->FlushUITasks();
    });
#ifdef ENABLE_ROSEN_BACKEND
    if (rsTransaction) {
        rsTransaction->Commit();
    }
#endif
}

void PipelineContext::SetRootRect(double width, double height, double offset)
{
    CHECK_RUN_ON(UI);
    UpdateRootSizeAndScale(width, height);
    CHECK_NULL_VOID(rootNode_);
    if (Container::CurrentId() < MIN_SUBCONTAINER_ID) {
        ScreenSystemManager::GetInstance().SetWindowInfo(rootWidth_, density_, dipScale_);
        ScreenSystemManager::GetInstance().OnSurfaceChanged(width);
    } else {
        ScreenSystemManager::GetInstance().SetWindowInfo(density_, dipScale_);
    }
    SizeF sizeF { static_cast<float>(width), static_cast<float>(height) };
    if (rootNode_->GetGeometryNode()->GetFrameSize() != sizeF || rootNode_->IsLayoutDirtyMarked()) {
        CalcSize idealSize { CalcLength(width), CalcLength(height) };
        MeasureProperty layoutConstraint;
        layoutConstraint.selfIdealSize = idealSize;
        layoutConstraint.maxSize = idealSize;
        rootNode_->UpdateLayoutConstraint(layoutConstraint);
        // reset parentLayoutConstraint to update itself when next measure task
        rootNode_->GetGeometryNode()->ResetParentLayoutConstraint();
        rootNode_->MarkDirtyNode();
    }
    if (rootNode_->GetGeometryNode()->GetFrameOffset().GetY() != offset) {
        OffsetF newOffset = rootNode_->GetGeometryNode()->GetFrameOffset();
        newOffset.SetY(static_cast<float>(offset));
        rootNode_->GetGeometryNode()->SetMarginFrameOffset(newOffset);
        auto rootContext = rootNode_->GetRenderContext();
        rootContext->SyncGeometryProperties(RawPtr(rootNode_->GetGeometryNode()));
        RequestFrame();
    }
    if (isDensityChanged_) {
        rootNode_->GetGeometryNode()->ResetParentLayoutConstraint();
        rootNode_->MarkForceMeasure();
        isDensityChanged_ = false;
    }
#if defined(ANDROID_PLATFORM) || defined(IOS_PLATFORM)
    // For cross-platform build, flush tasks when first resize, speed up for fisrt frame.
    if (window_ && rootNode_->GetRenderContext() && !NearZero(width) && !NearZero(height)) {
        rootNode_->GetRenderContext()->SetBounds(0.0, 0.0, width, height);
        window_->FlushTasks();
        FlushVsync(GetTimeFromExternalTimer(), 0);
    }
#endif
}

void PipelineContext::UpdateSystemSafeArea(const SafeAreaInsets& systemSafeArea)
{
    CHECK_NULL_VOID(minPlatformVersion_ >= PLATFORM_VERSION_TEN);
    if (safeAreaManager_->UpdateSystemSafeArea(systemSafeArea)) {
        AnimateOnSafeAreaUpdate();
    }
}

void PipelineContext::UpdateCutoutSafeArea(const SafeAreaInsets& cutoutSafeArea)
{
    CHECK_NULL_VOID(minPlatformVersion_ >= PLATFORM_VERSION_TEN);
    if (safeAreaManager_->UpdateCutoutSafeArea(cutoutSafeArea)) {
        AnimateOnSafeAreaUpdate();
    }
}

void PipelineContext::UpdateNavSafeArea(const SafeAreaInsets& navSafeArea)
{
    CHECK_NULL_VOID(minPlatformVersion_ >= PLATFORM_VERSION_TEN);
    if (safeAreaManager_->UpdateNavArea(navSafeArea)) {
        AnimateOnSafeAreaUpdate();
    }
}

void PipelineContext::CheckAndUpdateKeyboardInset(float keyboardHeight)
{
    safeAreaManager_->UpdateKeyboardSafeArea(keyboardHeight);
}

void PipelineContext::UpdateOriginAvoidArea(const Rosen::AvoidArea& avoidArea, uint32_t type)
{
#ifdef WINDOW_SCENE_SUPPORTED
    CHECK_NULL_VOID(uiExtensionManager_);
    uiExtensionManager_->TransferOriginAvoidArea(avoidArea, type);
#endif
}

void PipelineContext::UpdateSizeChangeReason(
    WindowSizeChangeReason type, const std::shared_ptr<Rosen::RSTransaction>& rsTransaction)
{
#ifdef WINDOW_SCENE_SUPPORTED
    CHECK_NULL_VOID(uiExtensionManager_);
    uiExtensionManager_->NotifySizeChangeReason(type, rsTransaction);
#endif
}

void PipelineContext::SetEnableKeyBoardAvoidMode(bool value)
{
    safeAreaManager_->SetKeyBoardAvoidMode(value);
    TAG_LOGI(AceLogTag::ACE_KEYBOARD, "keyboardAvoid Mode update:%{public}d", value);
}

bool PipelineContext::IsEnableKeyBoardAvoidMode()
{
    return safeAreaManager_->KeyboardSafeAreaEnabled();
}

void PipelineContext::SetIgnoreViewSafeArea(bool value)
{
    if (safeAreaManager_->SetIgnoreSafeArea(value)) {
        SyncSafeArea(SafeAreaSyncType::SYNC_TYPE_WINDOW_IGNORE);
    }
}

void PipelineContext::SetIsLayoutFullScreen(bool value)
{
    if (safeAreaManager_->SetIsFullScreen(value)) {
        SyncSafeArea(SafeAreaSyncType::SYNC_TYPE_WINDOW_IGNORE);
    }
}

void PipelineContext::SetIsNeedAvoidWindow(bool value)
{
    if (safeAreaManager_->SetIsNeedAvoidWindow(value)) {
        SyncSafeArea(SafeAreaSyncType::SYNC_TYPE_WINDOW_IGNORE);
    }
}

PipelineBase::SafeAreaInsets PipelineContext::GetSafeArea() const
{
    return safeAreaManager_->GetSafeArea();
}

PipelineBase::SafeAreaInsets PipelineContext::GetSafeAreaWithoutProcess() const
{
    return safeAreaManager_->GetSafeAreaWithoutProcess();
}

float PipelineContext::GetPageAvoidOffset()
{
    return safeAreaManager_->GetKeyboardOffset();
}

bool PipelineContext::CheckNeedAvoidInSubWindow()
{
    CHECK_NULL_RETURN(NearZero(GetPageAvoidOffset()), true);
    CHECK_NULL_RETURN(safeAreaManager_->KeyboardSafeAreaEnabled(), false);
    auto KeyboardInsetLength = safeAreaManager_->GetKeyboardInset().Length();
    return GreatNotEqual(KeyboardInsetLength, 0.0f);
}

void PipelineContext::SyncSafeArea(SafeAreaSyncType syncType)
{
    bool keyboardSafeArea =
        syncType == SafeAreaSyncType::SYNC_TYPE_KEYBOARD && !safeAreaManager_->KeyboardSafeAreaEnabled();
    CHECK_NULL_VOID(stageManager_);
    stageManager_->SyncPageSafeArea(keyboardSafeArea);
    SubwindowManager::GetInstance()->MarkDirtyDialogSafeArea();
    if (overlayManager_) {
        overlayManager_->MarkDirty(PROPERTY_UPDATE_MEASURE);
    }
    if (selectOverlayManager_) {
        selectOverlayManager_->MarkDirty(PROPERTY_UPDATE_MEASURE);
    }
    auto&& restoreNodes = safeAreaManager_->GetGeoRestoreNodes();
    for (auto&& wk : restoreNodes) {
        auto node = wk.Upgrade();
        if (node) {
            bool needMeasure = (syncType == SafeAreaSyncType::SYNC_TYPE_KEYBOARD && node->SelfExpansiveToKeyboard()) ||
                               (syncType == SafeAreaSyncType::SYNC_TYPE_AVOID_AREA ||
                                   syncType == SafeAreaSyncType::SYNC_TYPE_WINDOW_IGNORE);
            node->MarkDirtyNode(needMeasure ? PROPERTY_UPDATE_MEASURE : PROPERTY_UPDATE_LAYOUT);
        }
    }
}

void PipelineContext::DetachNode(RefPtr<UINode> uiNode)
{
    auto frameNode = DynamicCast<FrameNode>(uiNode);

    CHECK_NULL_VOID(frameNode);

    RemoveStoredNode(frameNode->GetRestoreId());
    if (frameNode->IsPrivacySensitive()) {
        auto privacyManager = GetPrivacySensitiveManager();
        privacyManager->RemoveNode(AceType::WeakClaim(AceType::RawPtr(frameNode)));
    }

    if (!CheckThreadSafe()) {
        LOGW("DetachNode doesn't run on UI thread!");
    }
    dirtyPropertyNodes_.erase(frameNode);
    needRenderNode_.erase(WeakPtr<FrameNode>(frameNode));

    if (dirtyFocusNode_ == frameNode) {
        dirtyFocusNode_.Reset();
    }

    if (dirtyFocusScope_ == frameNode) {
        dirtyFocusScope_.Reset();
    }

    if (dirtyRequestFocusNode_ == frameNode) {
        dirtyRequestFocusNode_.Reset();
    }

    if (activeNode_ == frameNode) {
        activeNode_.Reset();
    }

    if (focusNode_ == frameNode) {
        focusNode_.Reset();
    }
}

void PipelineContext::OnVirtualKeyboardHeightChange(float keyboardHeight,
    const std::shared_ptr<Rosen::RSTransaction>& rsTransaction, const float safeHeight, const bool supportAvoidance,
    bool forceChange)
{
    CHECK_RUN_ON(UI);
    // prevent repeated trigger with same keyboardHeight
    if (!forceChange && NearEqual(keyboardHeight, safeAreaManager_->GetKeyboardInset().Length())) {
        return;
    }

    ACE_FUNCTION_TRACE();
#ifdef ENABLE_ROSEN_BACKEND
    if (rsTransaction) {
        FlushMessages();
        rsTransaction->Begin();
    }
#endif

    if (supportAvoidance) {
        AvoidanceLogic(keyboardHeight, rsTransaction, safeHeight, supportAvoidance);
    } else {
        OriginalAvoidanceLogic(keyboardHeight, rsTransaction);
    }

#ifdef ENABLE_ROSEN_BACKEND
    if (rsTransaction) {
        rsTransaction->Commit();
    }
#endif
}

void PipelineContext::AvoidanceLogic(float keyboardHeight, const std::shared_ptr<Rosen::RSTransaction>& rsTransaction,
    const float safeHeight, const bool supportAvoidance)
{
    auto func = [this, keyboardHeight, safeHeight, supportAvoidance]() mutable {
        safeAreaManager_->UpdateKeyboardSafeArea(keyboardHeight);
        keyboardHeight += safeAreaManager_->GetSafeHeight();
        float positionY = 0.0f;
        float textfieldHeight = 0.0f;
        float keyboardPosition = rootHeight_ - keyboardHeight;
        auto manager = DynamicCast<TextFieldManagerNG>(PipelineBase::GetTextFieldManager());
        float keyboardOffset = manager ? manager->GetClickPositionOffset() : safeAreaManager_->GetKeyboardOffset();
        if (manager) {
            positionY = static_cast<float>(manager->GetClickPosition().GetY()) - keyboardOffset;
            textfieldHeight = manager->GetHeight();
        }
        if (!NearZero(keyboardOffset)) {
            auto offsetY = keyboardPosition - safeAreaManager_->GetLastKeyboardPoistion();
            safeAreaManager_->UpdateKeyboardOffset(keyboardOffset + offsetY);
        } else {
            if (NearZero(keyboardHeight)) {
                safeAreaManager_->UpdateKeyboardOffset(0.0f);
            } else if (LessOrEqual(positionY + safeHeight + textfieldHeight, rootHeight_ - keyboardHeight)) {
                safeAreaManager_->UpdateKeyboardOffset(0.0f);
            } else if (positionY + safeHeight + textfieldHeight > rootHeight_ - keyboardHeight) {
                safeAreaManager_->UpdateKeyboardOffset(
                    -(positionY - rootHeight_ + keyboardHeight)- safeHeight - textfieldHeight);
            } else {
                safeAreaManager_->UpdateKeyboardOffset(0.0f);
            }
        }
        safeAreaManager_->SetLastKeyboardPoistion(keyboardPosition);
        SyncSafeArea(SafeAreaSyncType::SYNC_TYPE_KEYBOARD);
        CHECK_NULL_VOID(manager);
        manager->AvoidKeyBoardInNavigation();
        // layout before scrolling textfield to safeArea, because of getting correct position
        FlushUITasks();
        bool scrollResult = manager->ScrollTextFieldToSafeArea();
        if (scrollResult) {
            FlushUITasks();
        }

        TAG_LOGI(AceLogTag::ACE_KEYBOARD,
            "AvoidanceLogic keyboardHeight: %{public}f, positionY: %{public}f, safeHeight: %{public}f, "
            "rootHeight_ %{public}f final calculate keyboard offset is %{public}f",
            keyboardHeight, positionY, safeHeight, rootHeight_, safeAreaManager_->GetKeyboardOffset());
    };
    FlushUITasks();
    DoKeyboardAvoidAnimate(keyboardAnimationConfig_, keyboardHeight, func);
}

void PipelineContext::OriginalAvoidanceLogic(
    float keyboardHeight, const std::shared_ptr<Rosen::RSTransaction>& rsTransaction)
{
    auto func = [this, keyboardHeight]() mutable {
        safeAreaManager_->UpdateKeyboardSafeArea(keyboardHeight);
        if (keyboardHeight > 0) {
            // add height of navigation bar
            keyboardHeight += safeAreaManager_->GetSystemSafeArea().bottom_.Length();
        }
        float positionY = 0.0f;
        auto manager = DynamicCast<TextFieldManagerNG>(PipelineBase::GetTextFieldManager());
        float height = 0.0f;
        if (manager) {
            height = manager->GetHeight();
            positionY = static_cast<float>(manager->GetClickPosition().GetY());
        }
        SizeF rootSize { static_cast<float>(rootWidth_), static_cast<float>(rootHeight_) };
        float keyboardOffset = manager ? manager->GetClickPositionOffset() : safeAreaManager_->GetKeyboardOffset();
        float positionYWithOffset = positionY - keyboardOffset;
        float offsetFix = (rootSize.Height() - positionYWithOffset) > 100.0f
                              ? keyboardHeight - (rootSize.Height() - positionYWithOffset) / 2.0f
                              : keyboardHeight;
#if defined(ANDROID_PLATFORM) || defined(IOS_PLATFORM)
        if (offsetFix > 0.0f && positionYWithOffset < offsetFix) {
            offsetFix = keyboardHeight - (rootSize.Height() - positionYWithOffset - height);
        }
#endif
        if (NearZero(keyboardHeight)) {
            safeAreaManager_->UpdateKeyboardOffset(0.0f);
        } else if (LessOrEqual(rootSize.Height() - positionYWithOffset - height, height) &&
                   LessOrEqual(rootSize.Height() - positionYWithOffset, keyboardHeight)) {
            safeAreaManager_->UpdateKeyboardOffset(-keyboardHeight);
        } else if (positionYWithOffset + height > (rootSize.Height() - keyboardHeight) && offsetFix > 0.0f) {
            safeAreaManager_->UpdateKeyboardOffset(-offsetFix);
        } else if ((positionYWithOffset + height > rootSize.Height() - keyboardHeight &&
                       positionYWithOffset < rootSize.Height() - keyboardHeight && height < keyboardHeight / 2.0f) &&
                   NearZero(rootNode_->GetGeometryNode()->GetFrameOffset().GetY())) {
            safeAreaManager_->UpdateKeyboardOffset(-height - offsetFix / 2.0f);
        } else {
            safeAreaManager_->UpdateKeyboardOffset(0.0f);
        }
        SyncSafeArea(SafeAreaSyncType::SYNC_TYPE_KEYBOARD);
        CHECK_NULL_VOID(manager);
        manager->AvoidKeyBoardInNavigation();
        // layout before scrolling textfield to safeArea, because of getting correct position
        FlushUITasks();
        bool scrollResult = manager->ScrollTextFieldToSafeArea();
        if (scrollResult) {
            FlushUITasks();
        }
    };
    FlushUITasks();
    DoKeyboardAvoidAnimate(keyboardAnimationConfig_, keyboardHeight, func);
}

void PipelineContext::OnVirtualKeyboardHeightChange(float keyboardHeight, double positionY, double height,
    const std::shared_ptr<Rosen::RSTransaction>& rsTransaction, bool forceChange)
{
    CHECK_RUN_ON(UI);
    // prevent repeated trigger with same keyboardHeight
    CHECK_NULL_VOID(safeAreaManager_);
    auto manager = DynamicCast<TextFieldManagerNG>(PipelineBase::GetTextFieldManager());
    CHECK_NULL_VOID(manager);
    if (!forceChange && NearEqual(keyboardHeight, safeAreaManager_->GetKeyboardInset().Length()) &&
        prevKeyboardAvoidMode_ == safeAreaManager_->KeyboardSafeAreaEnabled() && manager->PrevHasTextFieldPattern()) {
        TAG_LOGD(
            AceLogTag::ACE_KEYBOARD, "KeyboardHeight as same as last time, don't need to calculate keyboardOffset");
        return;
    }

    if (!forceChange && (NearEqual(keyboardHeight + 1, safeAreaManager_->GetKeyboardInset().Length()) ||
        NearEqual(keyboardHeight - 1, safeAreaManager_->GetKeyboardInset().Length())) &&
        prevKeyboardAvoidMode_ == safeAreaManager_->KeyboardSafeAreaEnabled() && manager->PrevHasTextFieldPattern()) {
        TAG_LOGI(
            AceLogTag::ACE_KEYBOARD, "Ignore ileagal keyboard height change");
        return;
    }

    if (keyboardHeight > rootHeight_) {
        TAG_LOGI(AceLogTag::ACE_KEYBOARD, "Keyboard higher than whole rootrect, no need to avoid");
        return;
    }

    if (manager->UsingCustomKeyboardAvoid()) {
        TAG_LOGI(AceLogTag::ACE_KEYBOARD, "Using Custom Avoid Instead");
        return;
    }

    manager->UpdatePrevHasTextFieldPattern();
    prevKeyboardAvoidMode_ = safeAreaManager_->KeyboardSafeAreaEnabled();

    ACE_FUNCTION_TRACE();
#ifdef ENABLE_ROSEN_BACKEND
    if (rsTransaction) {
        FlushMessages();
        rsTransaction->Begin();
    }
#endif

    auto weak = WeakClaim(this);
    auto func = [weak, keyboardHeight, positionY, height, manager]() mutable {
        auto context = weak.Upgrade();
        CHECK_NULL_VOID(context);
        context->SetIsLayouting(false);
        context->safeAreaManager_->UpdateKeyboardSafeArea(keyboardHeight);
        context->SetKeyboardAction(NearZero(keyboardHeight) ? KeyboardAction::CLOSING : KeyboardAction::OPENING);
        if (keyboardHeight > 0) {
            // add height of navigation bar
            keyboardHeight += context->safeAreaManager_->GetSystemSafeArea().bottom_.Length();
        }

        SizeF rootSize { static_cast<float>(context->rootWidth_), static_cast<float>(context->rootHeight_) };

        TAG_LOGI(AceLogTag::ACE_KEYBOARD,
            "origin positionY: %{public}f, height %{public}f", positionY, height);

        float positionYWithOffset = positionY;
        float keyboardOffset = manager ? manager->GetClickPositionOffset() :
            context->safeAreaManager_->GetKeyboardOffset();
        float currentPos = manager->GetClickPosition().GetY() - context->GetRootRect().GetOffset().GetY() -
            keyboardOffset;

        auto onFocusField = manager->GetOnFocusTextField().Upgrade();
        float adjust = 0.0f;
        if (onFocusField && onFocusField->GetHost() && onFocusField->GetHost()->GetGeometryNode()) {
            auto adjustRect = onFocusField->GetHost()->GetGeometryNode()->GetParentAdjust();
            adjust = adjustRect.Top();
        }
        currentPos += adjust;

        if (!onFocusField) {
            TAG_LOGI(AceLogTag::ACE_KEYBOARD, "use origin arg from the window");
        } else if (manager->GetIfFocusTextFieldIsInline()) {
            manager->GetInlineTextFieldAvoidPositionYAndHeight(positionY, height);
            positionYWithOffset = positionY;
        } else if (!NearEqual(positionY, currentPos) && !context->IsEnableKeyBoardAvoidMode()) {
            positionY = currentPos;
            positionYWithOffset = currentPos;
            height = manager->GetHeight();
        }

        if (rootSize.Height() - positionY - height < 0) {
            height = rootSize.Height() - positionY;
        }
        float offsetFix = (rootSize.Height() - positionY - height) < keyboardHeight
                              ? keyboardHeight - (rootSize.Height() - positionY - height)
                              : keyboardHeight;
        auto lastKeyboardOffset = context->safeAreaManager_->GetKeyboardOffset();
        float newKeyboardOffset = 0.0f;
        if (NearZero(keyboardHeight)) {
            newKeyboardOffset = 0.0f;
        } else if (positionYWithOffset + height > (rootSize.Height() - keyboardHeight) && offsetFix > 0.0f) {
            newKeyboardOffset = -offsetFix;
        } else if (LessOrEqual(rootSize.Height() - positionYWithOffset - height, height) &&
                   LessOrEqual(rootSize.Height() - positionYWithOffset, keyboardHeight)) {
            newKeyboardOffset = -keyboardHeight;
        } else if ((positionYWithOffset + height > rootSize.Height() - keyboardHeight &&
                       positionYWithOffset < rootSize.Height() - keyboardHeight && height < keyboardHeight / 2.0f) &&
                   NearZero(context->rootNode_->GetGeometryNode()->GetFrameOffset().GetY())) {
            newKeyboardOffset = -height - offsetFix / 2.0f;
        } else {
            newKeyboardOffset = 0.0f;
        }

        if (NearZero(keyboardHeight) || LessOrEqual(newKeyboardOffset, lastKeyboardOffset) ||
            manager->GetOnFocusTextFieldId() == manager->GetLastAvoidFieldId()) {
            context->safeAreaManager_->UpdateKeyboardOffset(newKeyboardOffset);
        } else {
            TAG_LOGI(AceLogTag::ACE_KEYBOARD, "Different field, Calculated offfset %{public}f is smaller than current"
                "keyboardOffset, so keep current keyboardOffset", newKeyboardOffset);
        }
        manager->SetLastAvoidFieldId(manager->GetOnFocusTextFieldId());

        TAG_LOGI(AceLogTag::ACE_KEYBOARD,
            "keyboardHeight: %{public}f, positionY: %{public}f, textHeight: %{public}f, "
            "rootSize.Height() %{public}f final calculate keyboard offset is %{public}f",
            keyboardHeight, positionY, height, rootSize.Height(), context->safeAreaManager_->GetKeyboardOffset());
        context->SyncSafeArea(SafeAreaSyncType::SYNC_TYPE_KEYBOARD);
        manager->AvoidKeyBoardInNavigation();
        // layout before scrolling textfield to safeArea, because of getting correct position
        context->FlushUITasks();
        bool scrollResult = manager->ScrollTextFieldToSafeArea();
        if (scrollResult) {
            context->FlushUITasks();
        }
        context->SetKeyboardAction(KeyboardAction::NONE);
    };
    FlushUITasks();
    SetIsLayouting(true);
    DoKeyboardAvoidAnimate(keyboardAnimationConfig_, keyboardHeight, func);

#ifdef ENABLE_ROSEN_BACKEND
    if (rsTransaction) {
        rsTransaction->Commit();
    }
#endif
}

bool PipelineContext::OnBackPressed()
{
    CHECK_RUN_ON(PLATFORM);
    auto frontend = weakFrontend_.Upgrade();
    if (!frontend) {
        // return back.
        return false;
    }

    // If the tag of the last child of the rootnode is video, exit full screen.
    if (fullScreenManager_->OnBackPressed()) {
        LOGI("fullscreen component: video or web consumed backpressed event");
        return true;
    }

    // if has sharedTransition, back press will stop the sharedTransition
    if (sharedTransitionManager_ && sharedTransitionManager_->OnBackPressed()) {
        LOGI("sharedTransition consumed backpressed event");
        return true;
    }

    // if has popup, back press would hide popup and not trigger page back
    auto textfieldMgr = DynamicCast<TextFieldManagerNG>(PipelineBase::GetTextFieldManager());
    if (textfieldMgr) {
        auto lastRequestKeyboardNodeId = textfieldMgr->GetLastRequestKeyboardId();
        auto lastRequestKeyboardNode = DynamicCast<FrameNode>(
            ElementRegister::GetInstance()->GetUINodeById(lastRequestKeyboardNodeId));
        if (lastRequestKeyboardNode && lastRequestKeyboardNode->GetPageId() == -1 &&
            textfieldMgr->OnBackPressed()) {
            LOGI("textfield consumed backpressed event");
            return true;
        }
    }

    auto hasOverlay = false;
    taskExecutor_->PostSyncTask(
        [weakOverlay = AceType::WeakClaim(AceType::RawPtr(overlayManager_)),
            weakSelectOverlay = AceType::WeakClaim(AceType::RawPtr(selectOverlayManager_)), &hasOverlay]() {
            // Destroy behaviour of Select Overlay shouble be adjusted.
            auto overlay = weakOverlay.Upgrade();
            CHECK_NULL_VOID(overlay);
            auto selectOverlay = weakSelectOverlay.Upgrade();
            CHECK_NULL_VOID(selectOverlay);
            hasOverlay = selectOverlay->ResetSelectionAndDestroySelectOverlay(true);
            hasOverlay |= overlay->RemoveOverlay(true);
        },
        TaskExecutor::TaskType::UI, "ArkUIBackPressedRemoveOverlay");
    if (hasOverlay) {
        LOGI("Overlay consumed backpressed event");
        return true;
    }

    auto textfieldManager = DynamicCast<TextFieldManagerNG>(PipelineBase::GetTextFieldManager());
    if (textfieldManager && textfieldManager->OnBackPressed()) {
        LOGI("textfield consumed backpressed event");
        return true;
    }

    auto result = false;
    taskExecutor_->PostSyncTask(
        [weakFrontend = weakFrontend_, weakPipelineContext = WeakClaim(this), stageManager = stageManager_, &result]() {
            auto frontend = weakFrontend.Upgrade();
            if (!frontend) {
                result = false;
                return;
            }
            auto context = weakPipelineContext.Upgrade();
            if (!context) {
                result = false;
                return;
            }
            CHECK_NULL_VOID(stageManager);
            auto lastPage = stageManager->GetLastPage();
            CHECK_NULL_VOID(lastPage);
            bool isEntry = false;
            auto navigationGroupNode =
                AceType::DynamicCast<NavigationGroupNode>(context->FindNavigationNodeToHandleBack(lastPage, isEntry));
            if (navigationGroupNode) {
                result = true;
            }
        },
        TaskExecutor::TaskType::UI, "ArkUIBackPressedFindNavigationGroup");

    if (result) {
        // user accept
        LOGI("Navigation consumed backpressed event");
        return true;
    }

    taskExecutor_->PostSyncTask(
        [weakFrontend = weakFrontend_, weakPipelineContext = WeakClaim(this), &result]() {
            auto frontend = weakFrontend.Upgrade();
            if (!frontend) {
                result = false;
                return;
            }
            result = frontend->OnBackPressed();
        },
        TaskExecutor::TaskType::JS, "ArkUIBackPressed");

    if (result) {
        // user accept
        LOGI("router consumed backpressed event");
        return true;
    }
    return false;
}

RefPtr<FrameNode> PipelineContext::FindNavigationNodeToHandleBack(const RefPtr<UINode>& node, bool& isEntry)
{
    CHECK_NULL_RETURN(node, nullptr);
    const auto& children = node->GetChildren();
    for (auto iter = children.rbegin(); iter != children.rend(); ++iter) {
        auto& child = *iter;
        auto childNode = AceType::DynamicCast<FrameNode>(child);
        if (childNode && childNode->GetLayoutProperty()) {
            auto property = childNode->GetLayoutProperty();
            if (property->GetVisibilityValue(VisibleType::VISIBLE) != VisibleType::VISIBLE ||
                !childNode->IsActive()) {
                continue;
            }
        }
        if (childNode && childNode->GetTag() == V2::NAVIGATION_VIEW_ETS_TAG) {
            auto navigationGroupNode = AceType::DynamicCast<NavigationGroupNode>(childNode);
            auto topChild = navigationGroupNode->GetTopDestination();
            // find navigation from top destination
            auto targetNodeFromDestination = FindNavigationNodeToHandleBack(topChild, isEntry);
            if (targetNodeFromDestination) {
                return targetNodeFromDestination;
            }
            if (isEntry) {
                return nullptr;
            }
            targetNodeFromDestination = childNode;
            auto targetNavigation = AceType::DynamicCast<NavigationGroupNode>(targetNodeFromDestination);
            // check if the destination responds
            if (targetNavigation && targetNavigation->CheckCanHandleBack(isEntry)) {
                return targetNavigation;
            }
            if (isEntry) {
                return nullptr;
            }
            // if the destination does not responds, find navigation from navbar
            auto navBarNode = AceType::DynamicCast<NavBarNode>(navigationGroupNode->GetNavBarNode());
            auto navigationLayoutProperty = navigationGroupNode->GetLayoutProperty<NavigationLayoutProperty>();
            CHECK_NULL_RETURN(navigationLayoutProperty, nullptr);
            if (navigationLayoutProperty->GetHideNavBarValue(false)) {
                return nullptr;
            }
            auto targetNodeFromNavbar = FindNavigationNodeToHandleBack(navBarNode, isEntry);
            if (targetNodeFromNavbar) {
                return targetNodeFromNavbar;
            }
            return nullptr;
        }
        auto target = FindNavigationNodeToHandleBack(child, isEntry);
        if (target) {
            return target;
        }
        if (isEntry) {
            return nullptr;
        }
    }
    return nullptr;
}

bool PipelineContext::SetIsFocusActive(bool isFocusActive)
{
    if (isFocusActive_ == isFocusActive) {
        return false;
    }
    TAG_LOGI(AceLogTag::ACE_FOCUS, "Pipeline focus turns to %{public}s", isFocusActive ? "active" : "inactive");
    isFocusActive_ = isFocusActive;
    for (auto& pair : isFocusActiveUpdateEvents_) {
        if (pair.second) {
            pair.second(isFocusActive_);
        }
    }
    CHECK_NULL_RETURN(rootNode_, false);
    auto rootFocusHub = rootNode_->GetFocusHub();
    CHECK_NULL_RETURN(rootFocusHub, false);
    if (isFocusActive_) {
        return rootFocusHub->PaintAllFocusState();
    }
    rootFocusHub->ClearAllFocusState();
    return true;
}

void PipelineContext::OnTouchEvent(const TouchEvent& point, bool isSubPipe)
{
    OnTouchEvent(point, rootNode_, isSubPipe);
}

void PipelineContext::OnMouseEvent(const MouseEvent& event)
{
    OnMouseEvent(event, rootNode_);
}

void PipelineContext::OnAxisEvent(const AxisEvent& event)
{
    OnAxisEvent(event, rootNode_);
}

void PipelineContext::OnTouchEvent(const TouchEvent& point, const RefPtr<FrameNode>& node, bool isSubPipe)
{
    CHECK_RUN_ON(UI);

    HandlePenHoverOut(point);

#ifdef UICAST_COMPONENT_SUPPORTED
    do {
        auto container = Container::Current();
        CHECK_NULL_BREAK(container);
        auto distributedUI = container->GetDistributedUI();
        CHECK_NULL_BREAK(distributedUI);
        if (distributedUI->IsSinkMode()) {
            distributedUI->BypassEvent(point, isSubPipe);
            return;
        }
    } while (false);
#endif

    SerializedGesture etsSerializedGesture;
    if (point.type != TouchType::DOWN) {
        HandleEtsCardTouchEvent(point, etsSerializedGesture);
    }

    auto oriPoint = point;
    auto scalePoint = point.CreateScalePoint(GetViewScale());
    eventManager_->CheckDownEvent(scalePoint);
    ResSchedReport::GetInstance().OnTouchEvent(scalePoint);

    if (scalePoint.type != TouchType::MOVE && scalePoint.type != TouchType::PULL_MOVE &&
        scalePoint.type != TouchType::HOVER_MOVE) {
        eventManager_->GetEventTreeRecord(EventTreeType::TOUCH).AddTouchPoint(scalePoint);
        if (SystemProperties::GetAceCommercialLogEnabled() || scalePoint.isPrivacyMode) {
            TAG_LOGI(AceLogTag::ACE_INPUTKEYFLOW,
                "InputTracking id:%{public}d, fingerId:%{public}d, type=%{public}d, inject=%{public}d, "
                "isPrivacyMode=%{public}d",
                scalePoint.touchEventId, scalePoint.id, (int)scalePoint.type, scalePoint.isInjected,
                scalePoint.isPrivacyMode);
        } else {
            TAG_LOGI(AceLogTag::ACE_INPUTKEYFLOW,
                "InputTracking id:%{public}d, fingerId:%{public}d, x=%{public}.3f, y=%{public}.3f type=%{public}d, "
                "inject=%{public}d",
                scalePoint.touchEventId, scalePoint.id, scalePoint.x, scalePoint.y, (int)scalePoint.type,
                scalePoint.isInjected);
        }
    }

    if (scalePoint.type == TouchType::MOVE) {
        for (auto listenerItem : listenerVector_) {
            if (listenerItem) {
                listenerItem->OnTouchEvent();
            }
        }
    }

    eventManager_->SetInstanceId(GetInstanceId());
    if (scalePoint.type != TouchType::MOVE && historyPointsById_.find(scalePoint.id) != historyPointsById_.end()) {
        historyPointsById_.erase(scalePoint.id);
    }
    if (scalePoint.type == TouchType::DOWN) {
        // Set focus state inactive while touch down event received
        SetIsFocusActive(false);
        TouchRestrict touchRestrict { TouchRestrict::NONE };
        touchRestrict.sourceType = point.sourceType;
        touchRestrict.touchEvent = point;
        touchRestrict.inputEventType = InputEventType::TOUCH_SCREEN;

        eventManager_->TouchTest(scalePoint, node, touchRestrict, GetPluginEventOffset(), viewScale_, isSubPipe);
        if (!touchRestrict.childTouchTestList.empty()) {
            scalePoint.childTouchTestList = touchRestrict.childTouchTestList;
        }
        touchTestResults_ = eventManager_->touchTestResults_;
        if (StylusDetectorMgr::GetInstance()->IsNeedInterceptedTouchEvent(scalePoint, touchTestResults_)) {
            eventManager_->ClearTouchTestTargetForPenStylus(scalePoint);
            return;
        }

        HandleEtsCardTouchEvent(oriPoint, etsSerializedGesture);

        if (etsSerializedGesture.data.size() != 0) {
            GestureGroup rebirth(GestureMode::Exclusive);
            rebirth.Deserialize(etsSerializedGesture.data.data());
            auto recognizer = rebirth.CreateRecognizer();
            if (recognizer) {
                recognizer->SetInnerFlag(true);
                recognizer->BeginReferee(scalePoint.id, true);
                std::list<RefPtr<NGGestureRecognizer>> combined;
                combined.emplace_back(recognizer);
                for (auto iter = touchTestResults_[point.id].begin();
                    iter != touchTestResults_[point.id].end(); iter++) {
                    auto outRecognizer = AceType::DynamicCast<NGGestureRecognizer>(*iter);
                    if (outRecognizer) {
                        combined.emplace_back(outRecognizer);
                        touchTestResults_[point.id].erase(iter);
                        break;
                    }
                }
                auto exclusiveRecognizer = AceType::MakeRefPtr<ExclusiveRecognizer>(std::move(combined));
                exclusiveRecognizer->AttachFrameNode(node);
                exclusiveRecognizer->BeginReferee(scalePoint.id);
                touchTestResults_[point.id].emplace_back(exclusiveRecognizer);
                eventManager_->touchTestResults_ = touchTestResults_;
                eventManager_->SetInnerFlag(true);
            }
        }
        if (IsFormRender() && touchTestResults_.find(point.id) != touchTestResults_.end()) {
            for (const auto& touchResult : touchTestResults_[point.id]) {
                auto recognizer = AceType::DynamicCast<NG::RecognizerGroup>(touchResult);
                if (recognizer) {
                    auto gesture = recognizer->CreateGestureFromRecognizer();
                    if (gesture) {
                        serializedGesture_.data = std::vector<char>(gesture->SizeofMe());
                        gesture->Serialize(serializedGesture_.data.data());
                    }
                    break;
                }
            }
        }
        for (const auto& weakContext : touchPluginPipelineContext_) {
            auto pipelineContext = DynamicCast<OHOS::Ace::PipelineBase>(weakContext.Upgrade());
            if (!pipelineContext) {
                continue;
            }
            auto pluginPoint =
                point.UpdateScalePoint(viewScale_, static_cast<float>(pipelineContext->GetPluginEventOffset().GetX()),
                    static_cast<float>(pipelineContext->GetPluginEventOffset().GetY()), point.id);
            // eventManager_ instance Id may changed.
            pipelineContext->OnTouchEvent(pluginPoint, true);
        }

        // restore instance Id.
        eventManager_->SetInstanceId(GetInstanceId());
    }
    auto rootOffset = GetRootRect().GetOffset();
    eventManager_->HandleGlobalEventNG(scalePoint, selectOverlayManager_, rootOffset);

    if (isSubPipe) {
        return;
    }

    // Currently, SetupRootElement is executed later than InitializeCallback in AceContainer.
    // We need to check whether accessibilityManagerNG_ is created.
    if (accessibilityManagerNG_ != nullptr) {
        accessibilityManagerNG_->HandleAccessibilityHoverEvent(node, scalePoint);
    }

    if (scalePoint.type == TouchType::MOVE) {
        if (!eventManager_->GetInnerFlag()) {
            auto mockPoint = point;
            mockPoint.type = TouchType::CANCEL;
            HandleEtsCardTouchEvent(mockPoint, etsSerializedGesture);
            RemoveEtsCardTouchEventCallback(mockPoint.id);
        }
        touchEvents_.emplace_back(point);
        hasIdleTasks_ = true;
        RequestFrame();
        return;
    }

    if (scalePoint.type == TouchType::UP) {
        lastTouchTime_ = GetTimeFromExternalTimer();
        CompensateTouchMoveEvent(scalePoint);
        if (thpExtraMgr_ != nullptr) {
            const uint32_t delay = 800; // 800: ms
            taskExecutor_->RemoveTask(TaskExecutor::TaskType::UI, "NotifyResponseRegionChanged");
            auto task = [weak = WeakClaim(this)]() {
                auto pipeline = weak.Upgrade();
                CHECK_NULL_VOID(pipeline);
                pipeline->NotifyResponseRegionChanged(pipeline->GetRootElement());
            };
            taskExecutor_->PostDelayedTask(task, TaskExecutor::TaskType::UI, delay, "NotifyResponseRegionChanged");
        }
    }

    eventManager_->DispatchTouchEvent(scalePoint);

    if ((scalePoint.type == TouchType::UP) || (scalePoint.type == TouchType::CANCEL)) {
        // need to reset touchPluginPipelineContext_ for next touch down event.
        touchPluginPipelineContext_.clear();
        RemoveEtsCardTouchEventCallback(point.id);
        ResetDraggingStatus(scalePoint, node);
    }
    if (scalePoint.type != TouchType::MOVE) {
        lastDispatchTime_.erase(scalePoint.id);
        idToTouchPoints_.erase(scalePoint.id);
    }

    hasIdleTasks_ = true;
    RequestFrame();
}

bool PipelineContext::CompensateTouchMoveEventFromUnhandledEvents(const TouchEvent& event)
{
    std::vector<TouchEvent> history;
    if (!touchEvents_.empty()) {
        for (auto iter = touchEvents_.begin(); iter != touchEvents_.end();) {
            auto movePoint = (*iter).CreateScalePoint(GetViewScale());
            if (event.id == movePoint.id) {
                history.emplace_back(movePoint);
                iter = touchEvents_.erase(iter);
            } else {
                auto& pointers = iter->pointers;
                for (auto pointerIter = pointers.begin(); pointerIter != pointers.end();) {
                    if (pointerIter->id == event.id) {
                        pointerIter = pointers.erase(pointerIter);
                    } else {
                        ++pointerIter;
                    }
                }
                ++iter;
            }
        }
        if (!history.empty()) {
            TouchEvent lastMoveEvent(history.back());
            lastMoveEvent.history.swap(history);
            eventManager_->SetLastMoveBeforeUp(event.sourceType == SourceType::MOUSE);
            eventManager_->DispatchTouchEvent(lastMoveEvent);
            eventManager_->SetLastMoveBeforeUp(false);
        } else {
            TAG_LOGI(AceLogTag::ACE_INPUTTRACKING,
                "Finger id: %{public}d, not found unhandled move event, compensate failed.", event.id);
        }
        return true;
    }
    return false;
}

void PipelineContext::CompensateTouchMoveEvent(const TouchEvent& event)
{
    if (event.type != TouchType::UP) {
        // If not up, no need to compensate touch move event.
        return;
    }
    if (!CompensateTouchMoveEventFromUnhandledEvents(event)) {
        // Compensate touch move event with all touch move Event before up has been handled.
        auto lastEventIter = idToTouchPoints_.find(event.id);
        if (lastEventIter != idToTouchPoints_.end()) {
            auto iter = lastDispatchTime_.find(lastEventIter->first);
            if (iter != lastDispatchTime_.end()) {
                ACE_SCOPED_TRACE("CompensateTouchMoveEvent last move event time: %s last dispatch time: %s",
                    std::to_string(static_cast<uint64_t>(lastEventIter->second.time.time_since_epoch().count()))
                        .c_str(),
                    std::to_string(iter->second).c_str());
                if (static_cast<uint64_t>(lastEventIter->second.time.time_since_epoch().count()) > iter->second) {
                    eventManager_->SetLastMoveBeforeUp(event.sourceType == SourceType::MOUSE);
                    eventManager_->DispatchTouchEvent(lastEventIter->second);
                    eventManager_->SetLastMoveBeforeUp(false);
                }
            }
        }
    }

    auto lastEventIter = idToTouchPoints_.find(event.id);
    if (lastEventIter != idToTouchPoints_.end()) {
        ACE_SCOPED_TRACE("Finger id: %d process last move event eventId: %d", lastEventIter->first,
            lastEventIter->second.touchEventId);
    }
}

void PipelineContext::ResetDraggingStatus(const TouchEvent& touchPoint, const RefPtr<FrameNode>& node)
{
    auto manager = GetDragDropManager();
    CHECK_NULL_VOID(manager);
    manager->ResetDraggingStatus(touchPoint);
}

void PipelineContext::OnSurfaceDensityChanged(double density)
{
    CHECK_RUN_ON(UI);
    if (!NearEqual(density, density_)) {
        isDensityChanged_ = true;
    }
    density_ = density;
    if (!NearZero(viewScale_)) {
        dipScale_ = density_ / viewScale_;
    }
    if (isDensityChanged_) {
        UIObserverHandler::GetInstance().NotifyDensityChange(density_);
        PipelineBase::OnSurfaceDensityChanged(density);
    }
}

bool PipelineContext::DumpPageViewData(const RefPtr<FrameNode>& node, RefPtr<ViewDataWrap> viewDataWrap,
    bool skipSubAutoFillContainer, bool needsRecordData)
{
    CHECK_NULL_RETURN(viewDataWrap, false);
    RefPtr<FrameNode> pageNode = nullptr;
    RefPtr<FrameNode> dumpNode = nullptr;
    if (node == nullptr) {
        if (stageManager_) {
            pageNode = stageManager_->GetLastPage();
            dumpNode = pageNode;
        }
    } else {
        pageNode = node->GetPageNode();
        dumpNode = node;
    }
    CHECK_NULL_RETURN(dumpNode, false);
    dumpNode->DumpViewDataPageNodes(viewDataWrap, skipSubAutoFillContainer, needsRecordData);
    if (node && node->GetTag() == V2::DIALOG_ETS_TAG) {
        viewDataWrap->SetPageUrl(node->GetTag());
        return true;
    }
    CHECK_NULL_RETURN(pageNode, false);
    auto pagePattern = pageNode->GetPattern<NG::PagePattern>();
    CHECK_NULL_RETURN(pagePattern, false);
    auto pageInfo = pagePattern->GetPageInfo();
    CHECK_NULL_RETURN(pageInfo, false);
    viewDataWrap->SetPageUrl(pageInfo->GetPageUrl());
    return true;
}

bool PipelineContext::CheckNeedAutoSave()
{
    CHECK_NULL_RETURN(stageManager_, false);
    auto pageNode = stageManager_->GetLastPage();
    CHECK_NULL_RETURN(pageNode, false);
    return pageNode->NeedRequestAutoSave();
}

bool PipelineContext::CheckOverlayFocus()
{
    CHECK_NULL_RETURN(overlayManager_, false);
    auto overlayNode = overlayManager_->GetOverlayNode();
    CHECK_NULL_RETURN(overlayNode, false);
    return overlayNode->GetFocusHub() && overlayNode->GetFocusHub()->IsCurrentFocus();
}

void PipelineContext::NotifyFillRequestSuccess(AceAutoFillType autoFillType, RefPtr<ViewDataWrap> viewDataWrap)
{
    CHECK_NULL_VOID(viewDataWrap);
    auto pageNodeInfoWraps = viewDataWrap->GetPageNodeInfoWraps();
    for (const auto& item : pageNodeInfoWraps) {
        if (item == nullptr) {
            continue;
        }
        auto frameNode = DynamicCast<FrameNode>(ElementRegister::GetInstance()->GetUINodeById(item->GetId()));
        if (frameNode == nullptr) {
            TAG_LOGW(AceLogTag::ACE_AUTO_FILL, "frameNode is not found, id=%{public}d", item->GetId());
            continue;
        }
        frameNode->NotifyFillRequestSuccess(viewDataWrap, item, autoFillType);
    }
}

void PipelineContext::NotifyFillRequestFailed(RefPtr<FrameNode> node, int32_t errCode,
    const std::string& fillContent, bool isPopup)
{
    CHECK_NULL_VOID(node);
    node->NotifyFillRequestFailed(errCode, fillContent, isPopup);
}

bool PipelineContext::OnDumpInfo(const std::vector<std::string>& params) const
{
    ACE_DCHECK(!params.empty());
    if (window_) {
        DumpLog::GetInstance().Print(1, "LastRequestVsyncTime: " + std::to_string(window_->GetLastRequestVsyncTime()));
#ifdef ENABLE_ROSEN_BACKEND
        auto rsUIDirector = window_->GetRSUIDirector();
        if (rsUIDirector) {
            DumpLog::GetInstance().Print(1, "transactionFlags: [" + std::to_string(getpid()) + "," +
                std::to_string(rsUIDirector->GetIndex()) + "]");
        }
#endif
    }
    DumpLog::GetInstance().Print(1, "last vsyncId: " + std::to_string(GetFrameCount()));
    if (params[0] == "-element") {
        if (params.size() > 1 && params[1] == "-lastpage") {
            auto lastPage = stageManager_->GetLastPage();
            if (params.size() < USED_ID_FIND_FLAG && lastPage) {
                lastPage->DumpTree(0);
                DumpLog::GetInstance().OutPutBySize();
            }
            if (params.size() == USED_ID_FIND_FLAG && lastPage && !lastPage->DumpTreeById(0, params[2])) {
                DumpLog::GetInstance().Print(
                    "There is no id matching the ID in the parameter,please check whether the id is correct");
            }
        } else {
            if (params.size() == USED_ID_FIND_FLAG && !rootNode_->DumpTreeById(0, params[2])) {
                DumpLog::GetInstance().Print(
                    "There is no id matching the ID in the parameter,please check whether the id is correct");
            }
            if (params.size() < USED_ID_FIND_FLAG) {
                rootNode_->DumpTree(0);
                DumpLog::GetInstance().OutPutBySize();
            }
        }
    } else if (params[0] == "-navigation") {
        auto navigationDumpMgr = GetNavigationManager();
        if (navigationDumpMgr) {
            navigationDumpMgr->OnDumpInfo();
        }
    } else if (params[0] == "-focus") {
        if (rootNode_->GetFocusHub()) {
            rootNode_->GetFocusHub()->DumpFocusTree(0);
        }
    } else if (params[0] == "-focuswindowscene") {
        auto windowSceneNode = GetFocusedWindowSceneNode();
        auto windowSceneFocusHub = windowSceneNode ? windowSceneNode->GetFocusHub() : nullptr;
        if (windowSceneFocusHub) {
            windowSceneFocusHub->DumpFocusTree(0);
        }
    } else if (params[0] == "-focusmanager") {
        if (focusManager_) {
            focusManager_->DumpFocusManager();
        }
    } else if (params[0] == "-accessibility" || params[0] == "-inspector") {
        auto accessibilityManager = GetAccessibilityManager();
        if (accessibilityManager) {
            accessibilityManager->OnDumpInfoNG(params, windowId_);
        }
    } else if (params[0] == "-rotation" && params.size() >= 2) {
    } else if (params[0] == "-animationscale" && params.size() >= 2) {
    } else if (params[0] == "-velocityscale" && params.size() >= 2) {
    } else if (params[0] == "-scrollfriction" && params.size() >= 2) {
    } else if (params[0] == "-threadstuck" && params.size() >= 3) {
    } else if (params[0] == "-pipeline") {
        DumpPipelineInfo();
    } else if (params[0] == "-jsdump") {
        std::vector<std::string> jsParams;
        if (params.begin() != params.end()) {
            jsParams = std::vector<std::string>(params.begin() + 1, params.end());
        }

        auto stageNode = stageManager_->GetStageNode();
        CHECK_NULL_RETURN(stageNode, false);
        auto children = stageNode->GetChildren();
        for (const auto& pageNode : children) {
            auto frameNode = AceType::DynamicCast<FrameNode>(pageNode);
            CHECK_NULL_RETURN(frameNode, false);
            auto pagePattern = frameNode->GetPattern<PagePattern>();
            CHECK_NULL_RETURN(pagePattern, false);
            pagePattern->FireDumpListener(jsParams);
        }
    } else if (params[0] == "-event") {
        if (eventManager_) {
            eventManager_->DumpEvent(EventTreeType::TOUCH);
        }
    } else if (params[0] == "-postevent") {
        if (eventManager_) {
            eventManager_->DumpEvent(EventTreeType::POST_EVENT);
        }
    } else if (params[0] == "-imagecache") {
        if (imageCache_) {
            imageCache_->DumpCacheInfo();
        }
    } else if (params[0] == "-imagefilecache") {
        ImageFileCache::GetInstance().DumpCacheInfo();
    } else if (params[0] == "-allelements") {
        AceEngine::Get().NotifyContainers([](const RefPtr<Container>& container) {
            auto pipeline = AceType::DynamicCast<NG::PipelineContext>(container->GetPipelineContext());
            auto rootNode = pipeline->GetRootElement();
            if (rootNode) {
                DumpLog::GetInstance().Print(0, "ContainerId: " + std::to_string(Container::CurrentId()));
                rootNode->DumpTree(0);
                DumpLog::GetInstance().OutPutBySize();
            }
        });
    } else if (params[0] == "-default") {
        rootNode_->DumpTree(0);
        DumpLog::GetInstance().OutPutDefault();
    } else if (params[0] == "--stylus") {
        StylusDetectorDefault::GetInstance()->ExecuteCommand(params);
    } else if (params[0] == "-overlay") {
        if (overlayManager_) {
            overlayManager_->DumpOverlayInfo();
        }
    } else if (params[0] == "-simplify") {
        auto root = JsonUtil::Create(true);
        rootNode_->DumpSimplifyTree(0, root);
        auto json = root->ToString();
        json.erase(std::remove(json.begin(), json.end(), ' '), json.end());
        DumpLog::GetInstance().Print(json);
    }
    return true;
}

FrameInfo* PipelineContext::GetCurrentFrameInfo(uint64_t recvTime, uint64_t timeStamp)
{
    if (SystemProperties::GetDumpFrameCount() == 0) {
        return nullptr;
    }
    if (dumpFrameInfos_.size() >= SystemProperties::GetDumpFrameCount()) {
        dumpFrameInfos_.pop_front();
    }

    dumpFrameInfos_.push_back({ .frameRecvTime_ = recvTime, .frameTimeStamp_ = timeStamp });
    return &dumpFrameInfos_.back();
}

void PipelineContext::DumpPipelineInfo() const
{
    DumpLog::GetInstance().Print("PipelineInfo:");
    if (window_) {
        DumpLog::GetInstance().Print(1, "DisplayRefreshRate: " + std::to_string(window_->GetRefreshRate()));
        DumpLog::GetInstance().Print(1, "LastRequestVsyncTime: " + std::to_string(window_->GetLastRequestVsyncTime()));
        DumpLog::GetInstance().Print(1, "NowTime: " + std::to_string(GetSysTimestamp()));
    }
    if (!dumpFrameInfos_.empty()) {
        DumpLog::GetInstance().Print("==================================FrameTask==================================");
        for (const auto& info : dumpFrameInfos_) {
            DumpLog::GetInstance().Print("Task: " + info.GetTimeInfo());
            DumpLog::GetInstance().Print(1, "LayoutTask:");
            for (const auto& layout : info.layoutInfos_) {
                DumpLog::GetInstance().Print(2, layout.ToString());
            }
            DumpLog::GetInstance().Print(1, "RenderTask:");
            for (const auto& layout : info.renderInfos_) {
                DumpLog::GetInstance().Print(2, layout.ToString());
            }
            DumpLog::GetInstance().Print(
                "==================================FrameTask==================================");
        }
    }
}

void PipelineContext::CollectTouchEventsBeforeVsync(std::list<TouchEvent>& touchEvents)
{
    auto targetTimeStamp = GetVsyncTime() - compensationValue_;
    for (auto iter = touchEvents_.begin(); iter != touchEvents_.end();) {
        auto timeStamp = std::chrono::duration_cast<std::chrono::nanoseconds>(iter->time.time_since_epoch()).count();
        if (targetTimeStamp < static_cast<uint64_t>(timeStamp)) {
            iter++;
            continue;
        }
        touchEvents.emplace_back(*iter);
        iter = touchEvents_.erase(iter);
    }
}

void PipelineContext::FlushTouchEvents()
{
    CHECK_RUN_ON(UI);
    CHECK_NULL_VOID(rootNode_);
    {
        std::unordered_set<int32_t> moveEventIds;
        std::list<TouchEvent> touchEvents;
        CollectTouchEventsBeforeVsync(touchEvents);
        if (touchEvents.empty()) {
            canUseLongPredictTask_ = true;
            return;
        }
        canUseLongPredictTask_ = false;
        eventManager_->FlushTouchEventsBegin(touchEvents_);
        std::unordered_map<int, TouchEvent> idToTouchPoints;
        bool needInterpolation = true;
        std::unordered_map<int32_t, TouchEvent> newIdTouchPoints;
        for (auto iter = touchEvents.rbegin(); iter != touchEvents.rend(); ++iter) {
            auto scalePoint = (*iter).CreateScalePoint(GetViewScale());
            idToTouchPoints.emplace(scalePoint.id, scalePoint);
            idToTouchPoints[scalePoint.id].history.insert(idToTouchPoints[scalePoint.id].history.begin(), scalePoint);
            needInterpolation = iter->type != TouchType::MOVE ? false : true;
        }
        if (focusWindowId_.has_value()) {
            needInterpolation = false;
        }
        if (needInterpolation) {
            auto targetTimeStamp = resampleTimeStamp_;
            for (const auto& idIter : idToTouchPoints) {
                auto stamp =
                    std::chrono::duration_cast<std::chrono::nanoseconds>(idIter.second.time.time_since_epoch()).count();
                if (targetTimeStamp > static_cast<uint64_t>(stamp)) {
                    continue;
                }
                TouchEvent newTouchEvent;
                if (GetResampleTouchEvent(
                        historyPointsById_[idIter.first], idIter.second.history, targetTimeStamp, newTouchEvent)) {
                    newIdTouchPoints[idIter.first] = newTouchEvent;
                }
                historyPointsById_[idIter.first] = idIter.second.history;
            }
        }
        std::list<TouchEvent> touchPoints;
        for (const auto& iter : idToTouchPoints) {
            lastDispatchTime_[iter.first] = GetVsyncTime() - compensationValue_;
            auto it = newIdTouchPoints.find(iter.first);
            if (it != newIdTouchPoints.end()) {
                touchPoints.emplace_back(it->second);
            } else {
                touchPoints.emplace_back(iter.second);
            }
        }
        auto maxSize = touchPoints.size();
        for (auto iter = touchPoints.rbegin(); iter != touchPoints.rend(); ++iter) {
            maxSize--;
            if (maxSize == 0) {
                eventManager_->FlushTouchEventsEnd(touchPoints);
            }
            eventManager_->DispatchTouchEvent(*iter);
        }
        idToTouchPoints_ = std::move(idToTouchPoints);
    }
}

void PipelineContext::OnAccessibilityHoverEvent(const TouchEvent& point, const RefPtr<NG::FrameNode>& node)
{
    CHECK_RUN_ON(UI);
    auto scaleEvent = point.CreateScalePoint(viewScale_);
    if (scaleEvent.type != TouchType::HOVER_MOVE) {
#ifdef IS_RELEASE_VERSION
        TAG_LOGI(AceLogTag::ACE_INPUTTRACKING,
            "OnAccessibilityHoverEvent event id:%{public}d, fingerId:%{public}d,"
            "type=%{public}d, "
            "inject=%{public}d",
            scaleEvent.touchEventId, scaleEvent.id, (int)scaleEvent.type, scaleEvent.isInjected);
#else
        TAG_LOGI(AceLogTag::ACE_INPUTTRACKING,
            "OnAccessibilityHoverEvent event id:%{public}d, fingerId:%{public}d, x=%{public}f y=%{public}f "
            "type=%{public}d, "
            "inject=%{public}d",
            scaleEvent.touchEventId, scaleEvent.id, scaleEvent.x, scaleEvent.y, (int)scaleEvent.type,
            scaleEvent.isInjected);
#endif
    }
    auto targerNode = node ? node : rootNode_;
    if (accessibilityManagerNG_ != nullptr) {
        accessibilityManagerNG_->HandleAccessibilityHoverEvent(targerNode, scaleEvent);
    }
    TouchRestrict touchRestrict { TouchRestrict::NONE };
    touchRestrict.sourceType = scaleEvent.sourceType;
    // use mouse to collect accessibility hover target
    touchRestrict.hitTestType = SourceType::MOUSE;
    touchRestrict.inputEventType = InputEventType::TOUCH_SCREEN;
    eventManager_->AccessibilityHoverTest(scaleEvent, targerNode, touchRestrict);
    eventManager_->DispatchAccessibilityHoverEventNG(scaleEvent);
    RequestFrame();
}

void PipelineContext::OnPenHoverEvent(const TouchEvent& point, const RefPtr<NG::FrameNode>& node)
{
    CHECK_RUN_ON(UI);
    auto scaleEvent = point.CreateScalePoint(viewScale_);
    if (scaleEvent.type != TouchType::MOVE) {
        TAG_LOGI(AceLogTag::ACE_INPUTTRACKING,
            "OnPenHoverEvent event id:%{public}d, fingerId:%{public}d "
            "type=%{public}d, "
            "inject=%{public}d",
            scaleEvent.touchEventId, scaleEvent.id, (int)scaleEvent.type,
            scaleEvent.isInjected);
    }

    auto targerNode = node ? node : rootNode_;
    TouchRestrict touchRestrict { TouchRestrict::NONE };
    touchRestrict.sourceType = scaleEvent.sourceType;
    touchRestrict.touchEvent.sourceTool = scaleEvent.sourceTool;
    touchRestrict.touchEvent.type = scaleEvent.type;
    touchRestrict.touchEvent.force = scaleEvent.force;

    // use mouse to collect pen hover target
    touchRestrict.hitTestType = SourceType::MOUSE;
    touchRestrict.inputEventType = InputEventType::TOUCH_SCREEN;
    eventManager_->PenHoverTest(scaleEvent, targerNode, touchRestrict);
    eventManager_->DispatchPenHoverEventNG(scaleEvent);
    RequestFrame();
}

void PipelineContext::HandlePenHoverOut(const TouchEvent& point)
{
    if (point.sourceTool != SourceTool::PEN || point.type != TouchType::DOWN || NearZero(point.force)) {
        return;
    }

    CHECK_RUN_ON(UI);
    auto oriPoint = point;
    oriPoint.type = TouchType::PROXIMITY_OUT;

    TouchTestResult testResult;
    eventManager_->UpdatePenHoverNode(oriPoint, testResult);
    eventManager_->DispatchPenHoverEventNG(oriPoint);
}

void PipelineContext::OnMouseEvent(const MouseEvent& event, const RefPtr<FrameNode>& node)
{
    CHECK_RUN_ON(UI);
    if (!lastMouseEvent_) {
        lastMouseEvent_ = std::make_unique<MouseEvent>();
    }
    lastMouseEvent_->x = event.x;
    lastMouseEvent_->y = event.y;
    lastMouseEvent_->button = event.button;
    lastMouseEvent_->action = event.action;
    lastMouseEvent_->sourceType = event.sourceType;
    lastMouseEvent_->time = event.time;
    lastMouseEvent_->touchEventId = event.touchEventId;

    if (event.button == MouseButton::RIGHT_BUTTON && event.action == MouseAction::PRESS) {
        // Mouse right button press event set focus inactive here.
        // Mouse left button press event will set focus inactive in touch process.
        SetIsFocusActive(false);
    }

    auto manager = GetDragDropManager();
    if (manager) {
        if (event.button == MouseButton::RIGHT_BUTTON &&
            (event.action == MouseAction::PRESS || event.action == MouseAction::PULL_UP)) {
            manager->SetIsDragCancel(true);
        } else {
            manager->SetIsDragCancel(false);
        }
    } else {
        TAG_LOGW(AceLogTag::ACE_INPUTTRACKING, "InputTracking id:%{public}d, OnMouseEvent GetDragDropManager is null",
            event.touchEventId);
    }

    auto container = Container::Current();
    if ((event.action == MouseAction::RELEASE || event.action == MouseAction::PRESS ||
            event.action == MouseAction::MOVE) &&
        (event.button == MouseButton::LEFT_BUTTON || event.pressedButtons == MOUSE_PRESS_LEFT)) {
        auto touchPoint = event.CreateTouchPoint();
        if (event.pullAction == MouseAction::PULL_MOVE) {
            touchPoint.pullType = TouchType::PULL_MOVE;
        }
        OnTouchEvent(touchPoint, node);
    } else {
        auto touchPoint = event.CreateTouchPoint();
        auto scalePoint = touchPoint.CreateScalePoint(GetViewScale());
        auto rootOffset = GetRootRect().GetOffset();
        eventManager_->HandleGlobalEventNG(scalePoint, selectOverlayManager_, rootOffset);
    }

    CHECK_NULL_VOID(node);
    auto scaleEvent = event.CreateScaleEvent(viewScale_);
    TouchRestrict touchRestrict { TouchRestrict::NONE };
    touchRestrict.sourceType = event.sourceType;
    touchRestrict.hitTestType = SourceType::MOUSE;
    touchRestrict.inputEventType = InputEventType::MOUSE_BUTTON;
    eventManager_->MouseTest(scaleEvent, node, touchRestrict);
    eventManager_->DispatchMouseEventNG(scaleEvent);
    eventManager_->DispatchMouseHoverEventNG(scaleEvent);
    eventManager_->DispatchMouseHoverAnimationNG(scaleEvent);
    accessibilityManagerNG_->HandleAccessibilityHoverEvent(node, scaleEvent);
    RequestFrame();
}

void PipelineContext::FlushMouseEvent()
{
    if (!lastMouseEvent_ || lastMouseEvent_->action == MouseAction::WINDOW_LEAVE) {
        return;
    }
    auto container = Container::Current();
    if (container) {
        int32_t sourceType = 0;
        auto result = container->GetCurPointerEventSourceType(sourceType);
        if (result) {
            TAG_LOGI(AceLogTag::ACE_MOUSE,
                "FlushMouseEvent: last pointer event id %{public}d sourceType:%{public}d last mouse event "
                "time:%{public}" PRId64 " current time %{public}" PRId64 "",
                lastMouseEvent_->touchEventId, sourceType,
                static_cast<int64_t>(lastMouseEvent_->time.time_since_epoch().count()), GetSysTimestamp());
        }
    }
    MouseEvent event;
    event.x = lastMouseEvent_->x;
    event.y = lastMouseEvent_->y;
    event.time = lastMouseEvent_->time;
    event.action = MouseAction::MOVE;
    event.button = MouseButton::NONE_BUTTON;
    event.sourceType = SourceType::MOUSE;

    CHECK_RUN_ON(UI);
    CHECK_NULL_VOID(rootNode_);
    auto scaleEvent = event.CreateScaleEvent(viewScale_);
    TouchRestrict touchRestrict { TouchRestrict::NONE };
    touchRestrict.sourceType = event.sourceType;
    touchRestrict.hitTestType = SourceType::MOUSE;
    touchRestrict.inputEventType = InputEventType::MOUSE_BUTTON;
    eventManager_->MouseTest(scaleEvent, rootNode_, touchRestrict);
    eventManager_->DispatchMouseEventNG(scaleEvent);
    eventManager_->DispatchMouseHoverEventNG(scaleEvent);
    eventManager_->DispatchMouseHoverAnimationNG(scaleEvent);
}

bool PipelineContext::ChangeMouseStyle(int32_t nodeId, MouseFormat format, int32_t windowId, bool isByPass)
{
    auto window = GetWindow();
    if (window && window->IsUserSetCursor()) {
        return false;
    }
    if (mouseStyleNodeId_ != nodeId || isByPass) {
        return false;
    }
    auto mouseStyle = MouseStyle::CreateMouseStyle();
    CHECK_NULL_RETURN(mouseStyle, false);
    if (windowId) {
        return mouseStyle->ChangePointerStyle(windowId, format);
    }
    return mouseStyle->ChangePointerStyle(GetFocusWindowId(), format);
}

bool PipelineContext::TriggerKeyEventDispatch(const KeyEvent& event)
{
    auto curFocusView = focusManager_ ? focusManager_->GetLastFocusView().Upgrade() : nullptr;
    auto curEntryFocusView = curFocusView ? curFocusView->GetEntryFocusView() : nullptr;
    auto curEntryFocusViewFrame = curEntryFocusView ? curEntryFocusView->GetFrameNode() : nullptr;
    if (event.isPreIme) {
        return eventManager_->DispatchKeyEventNG(event, curEntryFocusViewFrame);
    }

    if (!IsSkipShortcutAndFocusMove() && DispatchTabKey(event, curFocusView)) {
        return true;
    }
    return eventManager_->DispatchKeyEventNG(event, curEntryFocusViewFrame);
}

bool PipelineContext::IsSkipShortcutAndFocusMove()
{
    // Web component will NOT dispatch shortcut during the first event dispatch process.
    // Web component will NOT trigger focus move during the third event dispatch process.
    auto focusHub = focusManager_ ? focusManager_->GetCurrentFocus() : nullptr;
    RefPtr<FrameNode> curFrameNode = focusHub ? focusHub->GetFrameNode() : nullptr;
    return EventManager::IsSkipEventNode(curFrameNode);
}

bool PipelineContext::DispatchTabKey(const KeyEvent& event, const RefPtr<FocusView>& curFocusView)
{
    auto curEntryFocusView = curFocusView ? curFocusView->GetEntryFocusView() : nullptr;
    auto curEntryFocusViewFrame = curEntryFocusView ? curEntryFocusView->GetFrameNode() : nullptr;
    auto isKeyTabDown = event.action == KeyAction::DOWN && event.IsKey({ KeyCode::KEY_TAB });
    auto isViewRootScopeFocused = curFocusView ? curFocusView->GetIsViewRootScopeFocused() : true;
    isTabJustTriggerOnKeyEvent_ = false;

    if (isKeyTabDown && isViewRootScopeFocused && curFocusView) {
        // Current focused on the view root scope. Tab key used to extend focus.
        // If return true. This tab key will just trigger onKeyEvent process.
        isTabJustTriggerOnKeyEvent_ = curFocusView->TriggerFocusMove();
    }

    // Tab key set focus state from inactive to active.
    // If return true. This tab key will just trigger onKeyEvent process.
    bool isHandleFocusActive = isKeyTabDown && SetIsFocusActive(true);
    isTabJustTriggerOnKeyEvent_ = isTabJustTriggerOnKeyEvent_ || isHandleFocusActive;
    if (eventManager_->DispatchTabIndexEventNG(event, curEntryFocusViewFrame)) {
        return true;
    }
    return false;
}

void PipelineContext::ReDispatch(KeyEvent& keyEvent)
{
    CHECK_NULL_VOID(eventManager_);
    TAG_LOGD(AceLogTag::ACE_WEB, "Web ReDispach key event: code:%{public}d/action:%{public}d.", keyEvent.code,
        keyEvent.action);
    // Set keyEvent coming from Redispatch
    keyEvent.isRedispatch = true;

    if (eventManager_->DispatchKeyboardShortcut(keyEvent)) {
        return;
    }

    auto curFocusView = focusManager_ ? focusManager_->GetLastFocusView().Upgrade() : nullptr;
    auto curEntryFocusView = curFocusView ? curFocusView->GetEntryFocusView() : nullptr;
    auto curEntryFocusViewFrame = curEntryFocusView ? curEntryFocusView->GetFrameNode() : nullptr;
    if (DispatchTabKey(keyEvent, curFocusView)) {
        return;
    }
    eventManager_->DispatchKeyEventNG(keyEvent, curEntryFocusViewFrame);
}

bool PipelineContext::OnKeyEvent(const KeyEvent& event)
{
    CHECK_NULL_RETURN(eventManager_, false);
    eventManager_->SetPressedKeyCodes(event.pressedCodes);

    // onKeyPreIme
    if (event.isPreIme) {
        if (TriggerKeyEventDispatch(event)) {
            return true;
        }
        if (!IsSkipShortcutAndFocusMove()) {
            return eventManager_->DispatchKeyboardShortcut(event);
        }
        return false;
    }

    // process drag cancel
    if (event.code == KeyCode::KEY_ESCAPE) {
        auto manager = GetDragDropManager();
        if (manager && manager->IsMSDPDragging()) {
            manager->SetIsDragCancel(true);
            manager->OnDragEnd(PointerEvent(0, 0), "");
            manager->SetIsDragCancel(false);
            return true;
        }
    }

    // OnKeyEvent
    if (TriggerKeyEventDispatch(event)) {
        return true;
    }

    // process exit overlay
    if (event.code == KeyCode::KEY_ESCAPE && event.action == KeyAction::DOWN) {
        CHECK_NULL_RETURN(overlayManager_, false);
        auto currentContainer = Container::Current();
        if (currentContainer->IsSubContainer() || currentContainer->IsDialogContainer()) {
            return overlayManager_->RemoveOverlayInSubwindow();
        } else {
            return overlayManager_->RemoveOverlay(false);
        }
    }
    return false;
}

bool PipelineContext::RequestFocus(const std::string& targetNodeId, bool isSyncRequest)
{
    auto rootNode = GetFocusedWindowSceneNode();
    if (!rootNode) {
        rootNode = rootNode_;
    }
    CHECK_NULL_RETURN(rootNode, false);
    auto focusHub = rootNode->GetFocusHub();
    CHECK_NULL_RETURN(focusHub, false);
    auto currentFocusChecked = focusHub->RequestFocusImmediatelyById(targetNodeId, isSyncRequest);
    if (!isSubPipeline_ || currentFocusChecked) {
        return currentFocusChecked;
    }
    auto parentPipelineBase = parentPipeline_.Upgrade();
    CHECK_NULL_RETURN(parentPipelineBase, false);
    auto parentPipelineContext = AceType::DynamicCast<NG::PipelineContext>(parentPipelineBase);
    CHECK_NULL_RETURN(parentPipelineContext, false);
    return parentPipelineContext->RequestFocus(targetNodeId, isSyncRequest);
}

void PipelineContext::AddDirtyFocus(const RefPtr<FrameNode>& node)
{
    CHECK_RUN_ON(UI);
    CHECK_NULL_VOID(node);
    if (node->GetFocusType() == FocusType::NODE) {
        dirtyFocusNode_ = WeakClaim(RawPtr(node));
    } else {
        dirtyFocusScope_ = WeakClaim(RawPtr(node));
    }
    RequestFrame();
}

void PipelineContext::AddDirtyRequestFocus(const RefPtr<FrameNode>& node)
{
    CHECK_RUN_ON(UI);
    CHECK_NULL_VOID(node);
    dirtyRequestFocusNode_ = WeakPtr<FrameNode>(node);
    RequestFrame();
}

void PipelineContext::RootLostFocus(BlurReason reason) const
{
    CHECK_NULL_VOID(rootNode_);
    auto focusHub = rootNode_->GetFocusHub();
    CHECK_NULL_VOID(focusHub);
    focusHub->LostFocus(reason);
    CHECK_NULL_VOID(overlayManager_);
    overlayManager_->HideAllMenus();
}

MouseEvent ConvertAxisToMouse(const AxisEvent& event)
{
    MouseEvent result;
    result.x = event.x;
    result.y = event.y;
    result.action = MouseAction::MOVE;
    result.button = MouseButton::NONE_BUTTON;
    result.time = event.time;
    result.deviceId = event.deviceId;
    result.sourceType = event.sourceType;
    result.sourceTool = event.sourceTool;
    result.touchEventId = event.touchEventId;
    result.pointerEvent = event.pointerEvent;
    result.screenX = event.screenX;
    result.screenY = event.screenY;
    return result;
}

void PipelineContext::OnAxisEvent(const AxisEvent& event, const RefPtr<FrameNode>& node)
{
    auto scaleEvent = event.CreateScaleEvent(viewScale_);

    auto dragManager = GetDragDropManager();
    if (dragManager && !dragManager->IsDragged()) {
        if (event.action == AxisAction::BEGIN) {
            isBeforeDragHandleAxis_ = true;
            TouchRestrict touchRestrict { TouchRestrict::NONE };
            touchRestrict.sourceType = event.sourceType;
            touchRestrict.hitTestType = SourceType::TOUCH;
            touchRestrict.inputEventType = InputEventType::AXIS;
            // If received rotate event, no need to touchtest.
            if (!event.isRotationEvent) {
                eventManager_->TouchTest(scaleEvent, node, touchRestrict);
            }
        }
        eventManager_->DispatchTouchEvent(scaleEvent);
    } else if (isBeforeDragHandleAxis_ && event.action == AxisAction::END) {
        eventManager_->DispatchTouchEvent(scaleEvent);
        isBeforeDragHandleAxis_ = false;
    }

    if (event.action == AxisAction::BEGIN || event.action == AxisAction::UPDATE) {
        eventManager_->AxisTest(scaleEvent, node);
        eventManager_->DispatchAxisEventNG(scaleEvent);
    }

    auto mouseEvent = ConvertAxisToMouse(event);
    OnMouseEvent(mouseEvent, node);
}

bool PipelineContext::HasDifferentDirectionGesture() const
{
    CHECK_NULL_RETURN(eventManager_, false);
    return eventManager_->HasDifferentDirectionGesture();
}

void PipelineContext::AddVisibleAreaChangeNode(const int32_t nodeId)
{
    onVisibleAreaChangeNodeIds_.emplace(nodeId);
}

void PipelineContext::AddVisibleAreaChangeNode(const RefPtr<FrameNode>& node,
    const std::vector<double>& ratios, const VisibleRatioCallback& callback, bool isUserCallback,
    bool isCalculateInnerClip)
{
    CHECK_NULL_VOID(node);
    VisibleCallbackInfo addInfo;
    addInfo.callback = callback;
    addInfo.isCurrentVisible = false;
    onVisibleAreaChangeNodeIds_.emplace(node->GetId());
    if (isUserCallback) {
        node->SetVisibleAreaUserCallback(ratios, addInfo);
    } else {
        node->SetVisibleAreaInnerCallback(ratios, addInfo, isCalculateInnerClip);
    }
}

void PipelineContext::RemoveVisibleAreaChangeNode(int32_t nodeId)
{
    onVisibleAreaChangeNodeIds_.erase(nodeId);
}

void PipelineContext::HandleVisibleAreaChangeEvent(uint64_t nanoTimestamp)
{
    ACE_FUNCTION_TRACE();
    if (onVisibleAreaChangeNodeIds_.empty()) {
        return;
    }
    auto nodes = FrameNode::GetNodesById(onVisibleAreaChangeNodeIds_);
    for (auto&& frameNode : nodes) {
        frameNode->TriggerVisibleAreaChangeCallback(nanoTimestamp);
    }
}

void PipelineContext::AddOnAreaChangeNode(int32_t nodeId)
{
    onAreaChangeNodeIds_.emplace(nodeId);
    isOnAreaChangeNodesCacheVaild_ = false;
}

void PipelineContext::RemoveOnAreaChangeNode(int32_t nodeId)
{
    onAreaChangeNodeIds_.erase(nodeId);
    isOnAreaChangeNodesCacheVaild_ = false;
}

bool PipelineContext::HasOnAreaChangeNode(int32_t nodeId)
{
    return onAreaChangeNodeIds_.find(nodeId) != onAreaChangeNodeIds_.end();
}

void PipelineContext::HandleOnAreaChangeEvent(uint64_t nanoTimestamp)
{
    ACE_FUNCTION_TRACE();
    if (onAreaChangeNodeIds_.empty()) {
        return;
    }
    auto nodes = FrameNode::GetNodesById(onAreaChangeNodeIds_);
    for (auto&& frameNode : nodes) {
        frameNode->TriggerOnAreaChangeCallback(nanoTimestamp);
    }
    UpdateFormLinkInfos();
}

void PipelineContext::UpdateFormLinkInfos()
{
    if (formLinkInfoUpdateHandler_ && !formLinkInfoMap_.empty()) {
        std::vector<std::string> formLinkInfos;
        for (auto iter = formLinkInfoMap_.rbegin(); iter != formLinkInfoMap_.rend(); ++iter) {
            auto info = iter->second;
            formLinkInfos.push_back(info);
        }
        formLinkInfoUpdateHandler_(formLinkInfos);
    }
}

void PipelineContext::OnShow()
{
    CHECK_RUN_ON(UI);
    onShow_ = true;
    window_->OnShow();
    PerfMonitor::GetPerfMonitor()->SetAppForeground(true);
    RequestFrame();
    FlushWindowStateChangedCallback(true);
    AccessibilityEvent event;
    event.windowChangeTypes = WindowUpdateType::WINDOW_UPDATE_ACTIVE;
    event.type = AccessibilityEventType::PAGE_CHANGE;
    SendEventToAccessibility(event);
}

void PipelineContext::OnHide()
{
    CHECK_RUN_ON(UI);
    auto dragDropManager = GetDragDropManager();
    if (dragDropManager && dragDropManager->IsItemDragging()) {
        dragDropManager->CancelItemDrag();
    }
    onShow_ = false;
    window_->OnHide();
    PerfMonitor::GetPerfMonitor()->SetAppForeground(false);
    RequestFrame();
    OnVirtualKeyboardAreaChange(Rect());
    FlushWindowStateChangedCallback(false);
    auto rootNode = GetRootElement();
    CHECK_NULL_VOID(rootNode);
    rootNode->OnAccessibilityEvent(AccessibilityEventType::PAGE_CLOSE);
}

void PipelineContext::WindowFocus(bool isFocus)
{
    CHECK_RUN_ON(UI);
    onFocus_ = isFocus;
    if (!isFocus) {
        TAG_LOGI(AceLogTag::ACE_FOCUS, "Window id: %{public}d lost focus.", windowId_);
        RestoreDefault();
        RootLostFocus(BlurReason::WINDOW_BLUR);
        NotifyPopupDismiss();
    } else {
        TAG_LOGI(AceLogTag::ACE_FOCUS, "Window id: %{public}d get focus.", windowId_);
        isWindowHasFocused_ = true;
        InputMethodManager::GetInstance()->SetWindowFocus(true);
    }
    GetOrCreateFocusManager()->WindowFocus(isFocus);
    FlushWindowFocusChangedCallback(isFocus);
}

void PipelineContext::ContainerModalUnFocus()
{
    if (windowModal_ != WindowModal::CONTAINER_MODAL) {
        return;
    }
    CHECK_NULL_VOID(rootNode_);
    auto containerNode = AceType::DynamicCast<FrameNode>(rootNode_->GetChildren().front());
    CHECK_NULL_VOID(containerNode);
    auto containerPattern = containerNode->GetPattern<ContainerModalPattern>();
    CHECK_NULL_VOID(containerPattern);
    containerPattern->OnWindowForceUnfocused();
}

void PipelineContext::ShowContainerTitle(bool isShow, bool hasDeco, bool needUpdate)
{
    if (windowModal_ != WindowModal::CONTAINER_MODAL) {
        return;
    }
    CHECK_NULL_VOID(rootNode_);
    auto containerNode = AceType::DynamicCast<FrameNode>(rootNode_->GetChildren().front());
    CHECK_NULL_VOID(containerNode);
    auto containerPattern = containerNode->GetPattern<ContainerModalPattern>();
    CHECK_NULL_VOID(containerPattern);
    containerPattern->ShowTitle(isShow, hasDeco, needUpdate);
    isShowTitle_ = isShow && hasDeco;
}

void PipelineContext::UpdateTitleInTargetPos(bool isShow, int32_t height)
{
    if (windowModal_ != WindowModal::CONTAINER_MODAL) {
        return;
    }
    CHECK_NULL_VOID(rootNode_);
    auto containerNode = AceType::DynamicCast<FrameNode>(rootNode_->GetChildren().front());
    CHECK_NULL_VOID(containerNode);
    auto containerPattern = containerNode->GetPattern<ContainerModalPatternEnhance>();
    CHECK_NULL_VOID(containerPattern);
    containerPattern->UpdateTitleInTargetPos(isShow, height);
}

void PipelineContext::SetContainerWindow(bool isShow)
{
#ifdef ENABLE_ROSEN_BACKEND
    if (!IsJsCard()) {
        auto window = GetWindow();
        if (window) {
            auto rsUIDirector = window->GetRSUIDirector();
            if (rsUIDirector) {
                // set container window show state to render service
                rsUIDirector->SetContainerWindow(isShow, density_);
            }
        }
    }
#endif
}

void PipelineContext::SetAppBgColor(const Color& color)
{
    appBgColor_ = color;
#ifdef ENABLE_ROSEN_BACKEND
    if (!IsJsCard()) {
        auto window = GetWindow();
        if (window) {
            auto rsUIDirector = window->GetRSUIDirector();
            if (rsUIDirector) {
                rsUIDirector->SetAbilityBGAlpha(appBgColor_.GetAlpha());
            }
        }
    }
#endif
    CHECK_NULL_VOID(stageManager_);
    auto stage = stageManager_->GetStageNode();
    CHECK_NULL_VOID(stage);
    auto renderContext = stage->GetRenderContext();
    CHECK_NULL_VOID(renderContext);
    renderContext->UpdateBackgroundColor(color);
}

void PipelineContext::SetAppTitle(const std::string& title)
{
    if (windowModal_ != WindowModal::CONTAINER_MODAL) {
        return;
    }
    CHECK_NULL_VOID(rootNode_);
    auto containerNode = AceType::DynamicCast<FrameNode>(rootNode_->GetChildren().front());
    CHECK_NULL_VOID(containerNode);
    auto containerPattern = containerNode->GetPattern<ContainerModalPattern>();
    CHECK_NULL_VOID(containerPattern);
    containerPattern->SetAppTitle(title);
}

void PipelineContext::SetAppIcon(const RefPtr<PixelMap>& icon)
{
    if (windowModal_ != WindowModal::CONTAINER_MODAL) {
        return;
    }
    CHECK_NULL_VOID(rootNode_);
    auto containerNode = AceType::DynamicCast<FrameNode>(rootNode_->GetChildren().front());
    CHECK_NULL_VOID(containerNode);
    auto containerPattern = containerNode->GetPattern<ContainerModalPattern>();
    CHECK_NULL_VOID(containerPattern);
    containerPattern->SetAppIcon(icon);
}

void PipelineContext::FlushReload(const ConfigurationChange& configurationChange, bool fullUpdate)
{
    AnimationOption option;
    const int32_t duration = 400;
    option.SetDuration(duration);
    option.SetCurve(Curves::FRICTION);
    RecycleManager::Notify(configurationChange);
    AnimationUtils::Animate(option, [weak = WeakClaim(this), configurationChange,
        weakOverlayManager = AceType::WeakClaim(AceType::RawPtr(overlayManager_)), fullUpdate]() {
        auto pipeline = weak.Upgrade();
        CHECK_NULL_VOID(pipeline);
        if (configurationChange.IsNeedUpdate()) {
            auto rootNode = pipeline->GetRootElement();
            rootNode->UpdateConfigurationUpdate(configurationChange);
            auto overlay = weakOverlayManager.Upgrade();
            if (overlay) {
                overlay->ReloadBuilderNodeConfig();
            }
        }
        if (fullUpdate) {
            CHECK_NULL_VOID(pipeline->stageManager_);
            pipeline->SetIsReloading(true);
            pipeline->stageManager_->ReloadStage();
            pipeline->SetIsReloading(false);
            pipeline->FlushUITasks();
        }
    });
}

void PipelineContext::Destroy()
{
    CHECK_RUN_ON(UI);
    SetDestroyed();
    rootNode_->DetachFromMainTree();
    rootNode_->FireCustomDisappear();
    taskScheduler_->CleanUp();
    scheduleTasks_.clear();
    dirtyNodes_.clear();
    rootNode_.Reset();
    accessibilityManagerNG_.Reset();
    stageManager_.Reset();
    if (overlayManager_) {
        overlayManager_->ClearUIExtensionNode();
    }
    overlayManager_.Reset();
    sharedTransitionManager_.Reset();
    dragDropManager_.Reset();
    TAG_LOGI(AceLogTag::ACE_DRAG, "PipelineContext::Destroy Reset dragDropManager_");
    focusManager_.Reset();
    selectOverlayManager_.Reset();
    fullScreenManager_.Reset();
    touchEvents_.clear();
    buildFinishCallbacks_.clear();
    onWindowStateChangedCallbacks_.clear();
    onWindowFocusChangedCallbacks_.clear();
    nodesToNotifyMemoryLevel_.clear();
    dirtyFocusNode_.Reset();
    dirtyFocusScope_.Reset();
    needRenderNode_.clear();
    dirtyRequestFocusNode_.Reset();
    if (textFieldManager_ && textFieldManager_->GetImeShow()) {
        InputMethodManager::GetInstance()->CloseKeyboardInPipelineDestroy();
    }
#ifdef WINDOW_SCENE_SUPPORTED
    uiExtensionManager_.Reset();
#endif
    PipelineBase::Destroy();
}

void PipelineContext::AddBuildFinishCallBack(std::function<void()>&& callback)
{
    buildFinishCallbacks_.emplace_back(std::move(callback));
}

void PipelineContext::AddWindowStateChangedCallback(int32_t nodeId)
{
    if (!CheckThreadSafe()) {
        LOGW("AddWindowStateChangedCallback doesn't run on UI thread!");
    }
    onWindowStateChangedCallbacks_.emplace(nodeId);
}

void PipelineContext::RemoveWindowStateChangedCallback(int32_t nodeId)
{
    if (!CheckThreadSafe()) {
        LOGW("RemoveWindowStateChangedCallback doesn't run on UI thread!");
    }
    onWindowStateChangedCallbacks_.erase(nodeId);
}

void PipelineContext::FlushWindowStateChangedCallback(bool isShow)
{
    if (!CheckThreadSafe()) {
        LOGW("FlushWindowStateChangedCallback doesn't run on UI thread!");
    }
    auto iter = onWindowStateChangedCallbacks_.begin();
    while (iter != onWindowStateChangedCallbacks_.end()) {
        auto node = ElementRegister::GetInstance()->GetUINodeById(*iter);
        if (!node) {
            iter = onWindowStateChangedCallbacks_.erase(iter);
        } else {
            if (isShow) {
                node->OnWindowShow();
            } else {
                node->OnWindowHide();
            }
            ++iter;
        }
    }
    HandleVisibleAreaChangeEvent(GetTimeFromExternalTimer());
    HandleSubwindow(isShow);
}

void PipelineContext::AddWindowFocusChangedCallback(int32_t nodeId)
{
    onWindowFocusChangedCallbacks_.emplace_back(nodeId);
}

void PipelineContext::RemoveWindowFocusChangedCallback(int32_t nodeId)
{
    onWindowFocusChangedCallbacks_.remove(nodeId);
}

void PipelineContext::FlushWindowFocusChangedCallback(bool isFocus)
{
    auto iter = onWindowFocusChangedCallbacks_.begin();
    while (iter != onWindowFocusChangedCallbacks_.end()) {
        auto node = ElementRegister::GetInstance()->GetUINodeById(*iter);
        if (!node) {
            iter = onWindowFocusChangedCallbacks_.erase(iter);
        } else {
            if (isFocus) {
                node->OnWindowFocused();
            } else {
                node->OnWindowUnfocused();
            }
            ++iter;
        }
    }
}

void PipelineContext::AddWindowSizeChangeCallback(int32_t nodeId)
{
    onWindowSizeChangeCallbacks_.emplace_back(nodeId);
}

void PipelineContext::RemoveWindowSizeChangeCallback(int32_t nodeId)
{
    onWindowSizeChangeCallbacks_.remove(nodeId);
}

void PipelineContext::AddNavigationNode(int32_t pageId, WeakPtr<UINode> navigationNode)
{
    CHECK_RUN_ON(UI);
    pageToNavigationNodes_[pageId].push_back(navigationNode);
}

void PipelineContext::RemoveNavigationNode(int32_t pageId, int32_t nodeId)
{
    CHECK_RUN_ON(UI);
    auto it = pageToNavigationNodes_.find(pageId);
    if (it != pageToNavigationNodes_.end() && !it->second.empty()) {
        for (auto iter = it->second.begin(); iter != it->second.end();) {
            auto navigationNode = AceType::DynamicCast<NavigationGroupNode>((*iter).Upgrade());
            if (navigationNode && navigationNode->GetId() == nodeId) {
                iter = it->second.erase(iter);
            } else {
                iter++;
            }
        }
    }
}

void PipelineContext::FirePageChanged(int32_t pageId, bool isOnShow)
{
    CHECK_RUN_ON(UI);
    for (auto navigationNode : pageToNavigationNodes_[pageId]) {
        NavigationPattern::FireNavigationChange(navigationNode.Upgrade(), isOnShow, true);
    }
}

void PipelineContext::FlushWindowSizeChangeCallback(int32_t width, int32_t height, WindowSizeChangeReason type)
{
    auto iter = onWindowSizeChangeCallbacks_.begin();
    while (iter != onWindowSizeChangeCallbacks_.end()) {
        auto node = ElementRegister::GetInstance()->GetUINodeById(*iter);
        if (!node) {
            iter = onWindowSizeChangeCallbacks_.erase(iter);
        } else {
            node->OnWindowSizeChanged(width, height, type);
            ++iter;
        }
    }
}

void PipelineContext::RequireSummary()
{
    auto manager = GetDragDropManager();
    if (!manager) {
        TAG_LOGW(AceLogTag::ACE_DRAG, "require summary, dragDropManager is null");
        return;
    }
    manager->RequireSummary();
}

void PipelineContext::OnDragEvent(const PointerEvent& pointerEvent, DragEventAction action,
    const RefPtr<NG::FrameNode>& node)
{
    auto manager = GetDragDropManager();
    CHECK_NULL_VOID(manager);
    std::string extraInfo;
    auto container = Container::Current();
    if (container && container->IsScenceBoardWindow()) {
        if (!manager->IsDragged() && manager->IsWindowConsumed()) {
            manager->SetIsWindowConsumed(false);
            return;
        }
    }
    if (action == DragEventAction::DRAG_EVENT_START_FOR_CONTROLLER) {
        manager->RequireSummary();
        manager->OnDragStart(pointerEvent.GetPoint());
        return;
    }
    if (action == DragEventAction::DRAG_EVENT_OUT) {
        manager->OnDragMoveOut(pointerEvent);
        manager->ClearSummary();
        manager->ClearExtraInfo();
        manager->SetDragCursorStyleCore(DragCursorStyleCore::DEFAULT);
        return;
    }

    if (action == DragEventAction::DRAG_EVENT_START) {
        manager->ResetPreTargetFrameNode(GetInstanceId());
        manager->RequireSummaryIfNecessary(pointerEvent);
        manager->SetDragCursorStyleCore(DragCursorStyleCore::DEFAULT);
        TAG_LOGI(AceLogTag::ACE_DRAG, "start drag, current windowId is %{public}d", container->GetWindowId());
    }
    extraInfo = manager->GetExtraInfo();
    if (action == DragEventAction::DRAG_EVENT_END) {
        manager->OnDragEnd(pointerEvent, extraInfo, node);
        return;
    }
    if (action == DragEventAction::DRAG_EVENT_MOVE) {
        manager->DoDragMoveAnimate(pointerEvent);
    }
    manager->OnDragMove(pointerEvent, extraInfo, node);
}

void PipelineContext::AddNodesToNotifyMemoryLevel(int32_t nodeId)
{
    nodesToNotifyMemoryLevel_.emplace_back(nodeId);
}

void PipelineContext::RemoveNodesToNotifyMemoryLevel(int32_t nodeId)
{
    nodesToNotifyMemoryLevel_.remove(nodeId);
}

void PipelineContext::NotifyMemoryLevel(int32_t level)
{
    auto iter = nodesToNotifyMemoryLevel_.begin();
    while (iter != nodesToNotifyMemoryLevel_.end()) {
        auto node = ElementRegister::GetInstance()->GetUINodeById(*iter);
        if (!node) {
            iter = nodesToNotifyMemoryLevel_.erase(iter);
        } else {
            node->OnNotifyMemoryLevel(level);
            ++iter;
        }
    }
}
void PipelineContext::AddPredictTask(PredictTask&& task)
{
    taskScheduler_->AddPredictTask(std::move(task));
    RequestFrame();
}

void PipelineContext::AddFrameCallback(FrameCallbackFunc&& frameCallbackFunc, FrameCallbackFunc&& idleCallbackFunc,
    int64_t delayMillis)
{
    if (delayMillis <= 0) {
        if (frameCallbackFunc != nullptr) {
            frameCallbackFuncs_.emplace_back(std::move(frameCallbackFunc));
        }
        if (idleCallbackFunc != nullptr) {
            idleCallbackFuncs_.emplace_back(std::move(idleCallbackFunc));
        }
        RequestFrame();
        return;
    }
    auto taskScheduler = GetTaskExecutor();
    CHECK_NULL_VOID(taskScheduler);
    if (frameCallbackFunc != nullptr) {
        taskScheduler->PostDelayedTask(
            [weak = WeakClaim(this), callbackFunc = std::move(frameCallbackFunc)]() -> void {
                auto pipeline = weak.Upgrade();
                CHECK_NULL_VOID(pipeline);
                auto callback = const_cast<FrameCallbackFunc&>(callbackFunc);
                pipeline->frameCallbackFuncs_.emplace_back(std::move(callback));
                pipeline->RequestFrame();
            },
            TaskExecutor::TaskType::UI, delayMillis, "ArkUIPostFrameCallbackFuncDelayed");
    }
    if (idleCallbackFunc != nullptr) {
        taskScheduler->PostDelayedTask(
            [weak = WeakClaim(this), callbackFunc = std::move(idleCallbackFunc)]() -> void {
                auto pipeline = weak.Upgrade();
                CHECK_NULL_VOID(pipeline);
                auto callback = const_cast<FrameCallbackFunc&>(callbackFunc);
                pipeline->idleCallbackFuncs_.emplace_back(std::move(callback));
                pipeline->RequestFrame();
            },
            TaskExecutor::TaskType::UI, delayMillis, "ArkUIPostIdleCallbackFuncDelayed");
    }
}

void PipelineContext::TriggerIdleCallback(int64_t deadline)
{
    if (idleCallbackFuncs_.empty()) {
        return;
    }
    int64_t currentTime = GetSysTimestamp();
    if (deadline - currentTime < MIN_IDLE_TIME) {
        RequestFrame();
        return;
    }
    decltype(idleCallbackFuncs_) tasks(std::move(idleCallbackFuncs_));
    for (const auto& idleCallbackFunc : tasks) {
        idleCallbackFunc(deadline - currentTime);
        currentTime = GetSysTimestamp();
    }
}

void PipelineContext::OnIdle(int64_t deadline)
{
    int64_t currentTime = GetSysTimestamp();
    if (deadline == 0) {
        int64_t lastTaskEndTimestamp = window_->GetLastVsyncEndTimestamp();
        if (eventManager_) {
            lastTaskEndTimestamp = std::max(lastTaskEndTimestamp, eventManager_->GetLastTouchEventEndTimestamp());
        }
        if (lastTaskEndTimestamp > 0 && currentTime > lastTaskEndTimestamp
            && currentTime - lastTaskEndTimestamp > VSYNC_PERIOD_COUNT * window_->GetVSyncPeriod()) {
            auto frontend = weakFrontend_.Upgrade();
            if (frontend) {
                frontend->NotifyUIIdle();
            }
        }
    }
    if (deadline == 0 || isWindowAnimation_) {
        canUseLongPredictTask_ = false;
        return;
    }
    if (canUseLongPredictTask_) {
        // check new incoming event after vsync.
        if (!touchEvents_.empty()) {
            canUseLongPredictTask_ = false;
        }
    }
    CHECK_RUN_ON(UI);
    ACE_SCOPED_TRACE("OnIdle, targettime:%" PRId64 "", deadline);
    taskScheduler_->FlushPredictTask(deadline - TIME_THRESHOLD, canUseLongPredictTask_);
    canUseLongPredictTask_ = false;
    if (currentTime < deadline) {
        ElementRegister::GetInstance()->CallJSCleanUpIdleTaskFunc();
    }
    TriggerIdleCallback(deadline);
}

void PipelineContext::Finish(bool /* autoFinish */) const
{
    CHECK_RUN_ON(UI);
    if (finishEventHandler_) {
        finishEventHandler_();
    }
}

void PipelineContext::AddAfterLayoutTask(std::function<void()>&& task, bool isFlushInImplicitAnimationTask)
{
    taskScheduler_->AddAfterLayoutTask(std::move(task), isFlushInImplicitAnimationTask);
}

void PipelineContext::AddPersistAfterLayoutTask(std::function<void()>&& task)
{
    taskScheduler_->AddPersistAfterLayoutTask(std::move(task));
}

void PipelineContext::AddLatestFrameLayoutFinishTask(std::function<void()>&& task)
{
    taskScheduler_->AddLatestFrameLayoutFinishTask(std::move(task));
}

void PipelineContext::AddAfterRenderTask(std::function<void()>&& task)
{
    taskScheduler_->AddAfterRenderTask(std::move(task));
}

void PipelineContext::RestoreNodeInfo(std::unique_ptr<JsonValue> nodeInfo)
{
    auto child = nodeInfo->GetChild();
    while (child->IsValid()) {
        auto key = child->GetKey();
        auto value = child->GetString();
        restoreNodeInfo_.try_emplace(StringUtils::StringToInt(key), value);
        child = child->GetNext();
    }
}

std::unique_ptr<JsonValue> PipelineContext::GetStoredNodeInfo()
{
    auto jsonNodeInfo = JsonUtil::Create(true);
    auto iter = storeNode_.begin();
    while (iter != storeNode_.end()) {
        auto node = (iter->second).Upgrade();
        if (node) {
            std::string info = node->ProvideRestoreInfo();
            if (!info.empty()) {
                jsonNodeInfo->Put(std::to_string(iter->first).c_str(), info.c_str());
            }
        }
        ++iter;
    }
    return jsonNodeInfo;
}

void PipelineContext::StoreNode(int32_t restoreId, const WeakPtr<FrameNode>& node)
{
    auto ret = storeNode_.try_emplace(restoreId, node);
    if (!ret.second) {
        storeNode_[restoreId] = node;
    }
}

bool PipelineContext::GetRestoreInfo(int32_t restoreId, std::string& restoreInfo)
{
    auto iter = restoreNodeInfo_.find(restoreId);
    if (iter != restoreNodeInfo_.end()) {
        restoreInfo = iter->second;
        restoreNodeInfo_.erase(iter);
        return true;
    }
    return false;
}

void PipelineContext::SetContainerButtonHide(bool hideSplit, bool hideMaximize, bool hideMinimize)
{
    if (windowModal_ != WindowModal::CONTAINER_MODAL) {
        LOGW("Set app icon failed, Window modal is not container.");
        return;
    }
    CHECK_NULL_VOID(rootNode_);
    auto containerNode = AceType::DynamicCast<FrameNode>(rootNode_->GetChildren().front());
    CHECK_NULL_VOID(containerNode);
    auto containerPattern = containerNode->GetPattern<ContainerModalPattern>();
    CHECK_NULL_VOID(containerPattern);
    containerPattern->SetContainerButtonHide(hideSplit, hideMaximize, hideMinimize);
}

void PipelineContext::AddFontNodeNG(const WeakPtr<UINode>& node)
{
    if (fontManager_) {
        fontManager_->AddFontNodeNG(node);
    }
}

void PipelineContext::RemoveFontNodeNG(const WeakPtr<UINode>& node)
{
    if (fontManager_) {
        fontManager_->RemoveFontNodeNG(node);
    }
}

void PipelineContext::SetWindowSceneConsumed(bool isConsumed)
{
    isWindowSceneConsumed_ = isConsumed;
}

bool PipelineContext::IsWindowSceneConsumed()
{
    return isWindowSceneConsumed_;
}

void PipelineContext::SetCloseButtonStatus(bool isEnabled)
{
    if (windowModal_ != WindowModal::CONTAINER_MODAL) {
        return;
    }
    CHECK_NULL_VOID(rootNode_);
    auto containerNode = AceType::DynamicCast<FrameNode>(rootNode_->GetChildren().front());
    CHECK_NULL_VOID(containerNode);
    auto containerPattern = containerNode->GetPattern<ContainerModalPattern>();
    CHECK_NULL_VOID(containerPattern);
    containerPattern->SetCloseButtonStatus(isEnabled);
}

void PipelineContext::AnimateOnSafeAreaUpdate()
{
    // complete other layout tasks before animation
    FlushUITasks();
    AnimationOption option;
    option.SetCurve(safeAreaManager_->GetSafeAreaCurve());
    AnimationUtils::Animate(option, [weak = WeakClaim(this)]() {
        auto self = weak.Upgrade();
        CHECK_NULL_VOID(self);
        self->SyncSafeArea(SafeAreaSyncType::SYNC_TYPE_AVOID_AREA);
        self->FlushUITasks();
    });
}

void PipelineContext::HandleSubwindow(bool isShow)
{
    // When the main window is applied to the background,
    // there are sub windows that do not immediately hide, such as Toast floating window
    if (!isShow) {
        overlayManager_->ClearToastInSubwindow();
    }
}

void PipelineContext::AddIsFocusActiveUpdateEvent(
    const RefPtr<FrameNode>& node, const std::function<void(bool)>& eventCallback)
{
    CHECK_NULL_VOID(node);
    isFocusActiveUpdateEvents_.insert_or_assign(node->GetId(), eventCallback);
}

void PipelineContext::RemoveIsFocusActiveUpdateEvent(const RefPtr<FrameNode>& node)
{
    CHECK_NULL_VOID(node);
    auto iter = isFocusActiveUpdateEvents_.find(node->GetId());
    if (iter != isFocusActiveUpdateEvents_.end()) {
        isFocusActiveUpdateEvents_.erase(iter);
    }
}

std::shared_ptr<NavigationController> PipelineContext::GetNavigationController(const std::string& id)
{
    std::lock_guard lock(navigationMutex_);
    auto iter = navigationNodes_.find(id);
    if (iter == navigationNodes_.end()) {
        return nullptr;
    }

    auto navigationGroupNode = iter->second.Upgrade();
    CHECK_NULL_RETURN(navigationGroupNode, nullptr);

    auto navigationPattern = navigationGroupNode->GetPattern<NavigationPattern>();
    CHECK_NULL_RETURN(navigationPattern, nullptr);
    return navigationPattern->GetNavigationController();
}

void PipelineContext::AddOrReplaceNavigationNode(const std::string& id, const WeakPtr<FrameNode>& node)
{
    std::lock_guard lock(navigationMutex_);
    auto frameNode = node.Upgrade();
    CHECK_NULL_VOID(frameNode);
    auto navigationGroupNode = AceType::DynamicCast<NavigationGroupNode>(frameNode);
    CHECK_NULL_VOID(navigationGroupNode);
    auto oldId = navigationGroupNode->GetCurId();
    if (!oldId.empty() && navigationNodes_.find(oldId) != navigationNodes_.end()) {
        navigationNodes_.erase(oldId);
    }

    if (!id.empty()) {
        navigationNodes_[id] = node;
    }
}

void PipelineContext::DeleteNavigationNode(const std::string& id)
{
    std::lock_guard lock(navigationMutex_);
    if (!id.empty() && navigationNodes_.find(id) != navigationNodes_.end()) {
        navigationNodes_.erase(id);
    }
}

void PipelineContext::SetCursor(int32_t cursorValue)
{
    if (cursorValue >= 0 && cursorValue <= static_cast<int32_t>(MouseFormat::RUNNING)) {
        auto window = GetWindow();
        CHECK_NULL_VOID(window);
        auto mouseStyle = MouseStyle::CreateMouseStyle();
        CHECK_NULL_VOID(mouseStyle);
        auto cursor = static_cast<MouseFormat>(cursorValue);
        window->SetCursor(cursor);
        window->SetUserSetCursor(true);
        mouseStyle->ChangePointerStyle(GetFocusWindowId(), cursor);
    }
}

void PipelineContext::RestoreDefault(int32_t windowId)
{
    auto window = GetWindow();
    CHECK_NULL_VOID(window);
    auto mouseStyle = MouseStyle::CreateMouseStyle();
    CHECK_NULL_VOID(mouseStyle);
    window->SetCursor(MouseFormat::DEFAULT);
    window->SetUserSetCursor(false);
    mouseStyle->ChangePointerStyle(windowId > 0 ? windowId : GetFocusWindowId(), MouseFormat::DEFAULT);
}

std::string PipelineContext::GetCurrentExtraInfo()
{
    auto node = activeNode_.Upgrade();
    return node ? node->GetCurrentCustomNodeInfo() : std::string();
}

void PipelineContext::OpenFrontendAnimation(
    const AnimationOption& option, const RefPtr<Curve>& curve, const std::function<void()>& finishCallback)
{
    // push false to show we already open a animation closure.
    pendingFrontendAnimation_.push(false);

    // flush ui tasks before open animation closure.
    if (!isReloading_ && !IsLayouting()) {
        FlushUITasks();
    }
    auto wrapFinishCallback = GetWrappedAnimationCallback(finishCallback);
    if (IsFormRender()) {
        SetIsFormAnimation(true);
        if (!IsFormAnimationFinishCallback()) {
            SetFormAnimationStartTime(GetMicroTickCount());
        }
    }
    AnimationUtils::OpenImplicitAnimation(option, curve, wrapFinishCallback);
}

void PipelineContext::CloseFrontendAnimation()
{
    if (pendingFrontendAnimation_.empty()) {
        return;
    }

    if (pendingFrontendAnimation_.top()) {
        if (!isReloading_ && !IsLayouting()) {
            FlushUITasks();
        } else if (IsLayouting()) {
            TAG_LOGW(AceLogTag::ACE_ANIMATION,
                "IsLayouting, CloseFrontendAnimation has tasks not flushed, maybe some layout animation not generated");
        }
    }
    if (!pendingFrontendAnimation_.empty()) {
        pendingFrontendAnimation_.pop();
    }
    AnimationUtils::CloseImplicitAnimation();
}

void PipelineContext::SetContainerModalTitleVisible(bool customTitleSettedShow, bool floatingTitleSettedShow)
{
    if (windowModal_ != WindowModal::CONTAINER_MODAL) {
        return;
    }
    CHECK_NULL_VOID(rootNode_);
    auto containerNode = AceType::DynamicCast<FrameNode>(rootNode_->GetFirstChild());
    CHECK_NULL_VOID(containerNode);
    auto containerPattern = containerNode->GetPattern<ContainerModalPattern>();
    CHECK_NULL_VOID(containerPattern);
    containerPattern->SetContainerModalTitleVisible(customTitleSettedShow, floatingTitleSettedShow);
    customTitleSettedShow_ = customTitleSettedShow;
}

void PipelineContext::SetContainerModalTitleHeight(int32_t height)
{
    if (windowModal_ != WindowModal::CONTAINER_MODAL) {
        return;
    }
    CHECK_NULL_VOID(rootNode_);
    auto containerNode = AceType::DynamicCast<FrameNode>(rootNode_->GetFirstChild());
    CHECK_NULL_VOID(containerNode);
    auto containerPattern = containerNode->GetPattern<ContainerModalPattern>();
    CHECK_NULL_VOID(containerPattern);
    containerPattern->SetContainerModalTitleHeight(height);
}

int32_t PipelineContext::GetContainerModalTitleHeight()
{
    if (windowModal_ != WindowModal::CONTAINER_MODAL) {
        return -1;
    }
    CHECK_NULL_RETURN(rootNode_, -1);
    auto containerNode = AceType::DynamicCast<FrameNode>(rootNode_->GetFirstChild());
    CHECK_NULL_RETURN(containerNode, -1);
    auto containerPattern = containerNode->GetPattern<ContainerModalPattern>();
    CHECK_NULL_RETURN(containerPattern, -1);
    return containerPattern->GetContainerModalTitleHeight();
}

RefPtr<FrameNode> PipelineContext::GetContainerModalNode()
{
    if (windowModal_ != WindowModal::CONTAINER_MODAL) {
        return nullptr;
    }
    CHECK_NULL_RETURN(rootNode_, nullptr);
    return AceType::DynamicCast<FrameNode>(rootNode_->GetFirstChild());
}

void PipelineContext::DoKeyboardAvoidAnimate(const KeyboardAnimationConfig& keyboardAnimationConfig,
    float keyboardHeight, const std::function<void()>& func)
{
    if (isDoKeyboardAvoidAnimate_) {
        AnimationOption option = AnimationUtil::CreateKeyboardAnimationOption(keyboardAnimationConfig, keyboardHeight);
        Animate(option, option.GetCurve(), func);
    } else {
        func();
    }
}

Dimension PipelineContext::GetCustomTitleHeight()
{
    auto containerModal = GetContainerModalNode();
    CHECK_NULL_RETURN(containerModal, Dimension());
    return containerModal->GetPattern<ContainerModalPattern>()->GetCustomTitleHeight();
}

bool PipelineContext::GetContainerModalButtonsRect(RectF& containerModal, RectF& buttons)
{
    if (windowModal_ != WindowModal::CONTAINER_MODAL) {
        return false;
    }
    CHECK_NULL_RETURN(rootNode_, false);
    auto containerNode = AceType::DynamicCast<FrameNode>(rootNode_->GetFirstChild());
    CHECK_NULL_RETURN(containerNode, false);
    auto containerPattern = containerNode->GetPattern<ContainerModalPattern>();
    CHECK_NULL_RETURN(containerPattern, false);
    return containerPattern->GetContainerModalButtonsRect(containerModal, buttons);
}

void PipelineContext::SubscribeContainerModalButtonsRectChange(
    std::function<void(RectF& containerModal, RectF& buttons)>&& callback)
{
    if (windowModal_ != WindowModal::CONTAINER_MODAL) {
        return;
    }
    CHECK_NULL_VOID(rootNode_);
    auto containerNode = AceType::DynamicCast<FrameNode>(rootNode_->GetFirstChild());
    CHECK_NULL_VOID(containerNode);
    auto containerPattern = containerNode->GetPattern<ContainerModalPattern>();
    CHECK_NULL_VOID(containerPattern);
    containerPattern->SubscribeContainerModalButtonsRectChange(std::move(callback));
}

void PipelineContext::GetWindowPaintRectWithoutMeasureAndLayout(RectInt& rect)
{
    if (windowModal_ != WindowModal::CONTAINER_MODAL) {
        return;
    }
    CHECK_NULL_VOID(rootNode_);
    auto containerNode = AceType::DynamicCast<FrameNode>(rootNode_->GetFirstChild());
    CHECK_NULL_VOID(containerNode);
    auto containerPattern = containerNode->GetPattern<ContainerModalPattern>();
    CHECK_NULL_VOID(containerPattern);
    containerPattern->GetWindowPaintRectWithoutMeasureAndLayout(rect);
}

bool PipelineContext::IsDragging() const
{
    if (!dragDropManager_) {
        return false;
    }
    bool isDragging = dragDropManager_->IsDragging();
    isDragging = (isDragging || dragDropManager_->IsMSDPDragging());
    return isDragging;
}

void PipelineContext::SetIsDragging(bool isDragging)
{
    if (!eventManager_) {
        return;
    }
    eventManager_->SetIsDragging(isDragging);
}

void PipelineContext::ResetDragging()
{
    CHECK_NULL_VOID(dragDropManager_);
    dragDropManager_->ResetDragging();
}

const RefPtr<PostEventManager>& PipelineContext::GetPostEventManager()
{
    return postEventManager_;
}

const SerializedGesture& PipelineContext::GetSerializedGesture() const
{
    return serializedGesture_;
}

bool PipelineContext::PrintVsyncInfoIfNeed() const
{
    if (dumpFrameInfos_.empty()) {
        return false;
    }
    auto lastFrameInfo = dumpFrameInfos_.back();
    const uint64_t timeout = 1000000000; // unit is ns, 1s
    if (lastFrameInfo.frameRecvTime_ < window_->GetLastRequestVsyncTime() &&
        static_cast<uint64_t>(GetSysTimestamp()) - window_->GetLastRequestVsyncTime() >= timeout) {
        LOGW("lastRequestVsyncTime is %{public}" PRIu64 ", now time is %{public}" PRId64
             ", timeout, window foreground:%{public}d, lastReceiveVsync info:%{public}s",
            window_->GetLastRequestVsyncTime(), GetSysTimestamp(), onShow_, lastFrameInfo.GetTimeInfo().c_str());
        return true;
    }
    return false;
}

void PipelineContext::AddSyncGeometryNodeTask(std::function<void()>&& task)
{
    taskScheduler_->AddSyncGeometryNodeTask(std::move(task));
}

void PipelineContext::FlushSyncGeometryNodeTasks()
{
    taskScheduler_->FlushSyncGeometryNodeTasks();
}

void PipelineContext::SetUIExtensionImeShow(bool imeShow)
{
    textFieldManager_->SetUIExtensionImeShow(imeShow);
}

void PipelineContext::SetOverlayNodePositions(std::vector<Ace::RectF> rects)
{
    overlayNodePositions_ = rects;
}

void PipelineContext::SetCallBackNode(const WeakPtr<NG::FrameNode>& node)
{
    auto frameNode = node.Upgrade();
    CHECK_NULL_VOID(frameNode);
    auto pipelineContext = frameNode->GetContext();
    CHECK_NULL_VOID(pipelineContext);
    pipelineContext->UpdateCurrentActiveNode(node);
}

std::vector<Ace::RectF> PipelineContext::GetOverlayNodePositions()
{
    return overlayNodePositions_;
}

void PipelineContext::RegisterOverlayNodePositionsUpdateCallback(
    const std::function<void(std::vector<Ace::RectF>)>&& callback)
{
    overlayNodePositionUpdateCallback_ = std::move(callback);
}

void PipelineContext::TriggerOverlayNodePositionsUpdateCallback(std::vector<Ace::RectF> rects)
{
    if (overlayNodePositionUpdateCallback_) {
        overlayNodePositionUpdateCallback_(rects);
    }
}

bool PipelineContext::IsContainerModalVisible()
{
    if (windowModal_ != WindowModal::CONTAINER_MODAL) {
        return false;
    }
    auto windowManager = GetWindowManager();
    bool isFloatingWindow = windowManager->GetWindowMode() == WindowMode::WINDOW_MODE_FLOATING;
    return isShowTitle_ && isFloatingWindow && customTitleSettedShow_;
}

void PipelineContext::CheckNeedUpdateBackgroundColor(Color& color)
{
    if (!isFormRender_ || (renderingMode_ != RENDERING_SINGLE_COLOR)) {
        return;
    }
    Color replaceColor = color.ChangeAlpha(SINGLECOLOR_UPDATE_ALPHA);
    color = replaceColor;
}

bool PipelineContext::CheckNeedDisableUpdateBackgroundImage()
{
    if (!isFormRender_ || (renderingMode_ != RENDERING_SINGLE_COLOR)) {
        return false;
    }
    return true;
}

void PipelineContext::ChangeDarkModeBrightness()
{
    auto windowManager = GetWindowManager();
    CHECK_NULL_VOID(windowManager);
    auto mode = windowManager->GetWindowMode();
    auto container = Container::CurrentSafely();
    CHECK_NULL_VOID(container);
    auto percent = SystemProperties::GetDarkModeBrightnessPercent();
    auto stage = stageManager_->GetStageNode();
    CHECK_NULL_VOID(stage);
    auto renderContext = stage->GetRenderContext();
    CHECK_NULL_VOID(renderContext);
    CalcDimension dimension;
    dimension.SetValue(1);
    if (SystemProperties::GetColorMode() == ColorMode::DARK && appBgColor_.ColorToString().compare("#FF000000") == 0 &&
        mode != WindowMode::WINDOW_MODE_FULLSCREEN && !container->IsUIExtensionWindow() &&
        !container->IsDynamicRender() && !container->IsFormRender() && !IsJsCard()) {
        if (!onFocus_ && mode == WindowMode::WINDOW_MODE_FLOATING) {
            dimension.SetValue(1 + percent.second);
        } else {
            dimension.SetValue(1 + percent.first);
        }
    }
    renderContext->UpdateFrontBrightness(dimension);
}

void PipelineContext::PreLayout(uint64_t nanoTimestamp, uint32_t frameCount)
{
    FlushVsync(nanoTimestamp, frameCount);
}

void PipelineContext::CheckAndLogLastReceivedTouchEventInfo(int32_t eventId, TouchType type)
{
    eventManager_->CheckAndLogLastReceivedTouchEventInfo(eventId, type);
}

void PipelineContext::CheckAndLogLastConsumedTouchEventInfo(int32_t eventId, TouchType type)
{
    eventManager_->CheckAndLogLastConsumedTouchEventInfo(eventId, type);
}

void PipelineContext::CheckAndLogLastReceivedMouseEventInfo(int32_t eventId, MouseAction action)
{
    eventManager_->CheckAndLogLastReceivedMouseEventInfo(eventId, action);
}

void PipelineContext::CheckAndLogLastConsumedMouseEventInfo(int32_t eventId, MouseAction action)
{
    eventManager_->CheckAndLogLastConsumedMouseEventInfo(eventId, action);
}

void PipelineContext::CheckAndLogLastReceivedAxisEventInfo(int32_t eventId, AxisAction action)
{
    eventManager_->CheckAndLogLastReceivedAxisEventInfo(eventId, action);
}

void PipelineContext::CheckAndLogLastConsumedAxisEventInfo(int32_t eventId, AxisAction action)
{
    eventManager_->CheckAndLogLastConsumedAxisEventInfo(eventId, action);
}

void PipelineContext::RegisterTouchEventListener(const std::shared_ptr<ITouchEventCallback>& listener)
{
    if (!listener) {
        return;
    }
    listenerVector_.emplace_back(listener);
}

void PipelineContext::UnregisterTouchEventListener(const WeakPtr<NG::Pattern>& pattern)
{
    for (auto iter = listenerVector_.begin(); iter != listenerVector_.end();) {
        auto patternPtr = (*iter)->GetPatternFromListener();
        if (patternPtr.Invalid() || patternPtr == pattern) {
            iter = listenerVector_.erase(iter);
        } else {
            iter++;
        }
    }
}

void PipelineContext::FlushFrameCallback(uint64_t nanoTimestamp)
{
    if (!frameCallbackFuncs_.empty()) {
        decltype(frameCallbackFuncs_) tasks(std::move(frameCallbackFuncs_));
        for (const auto& frameCallbackFunc : tasks) {
            frameCallbackFunc(nanoTimestamp);
        }
    }
}

void PipelineContext::RegisterFocusCallback()
{
    focusManager_->AddFocusListener([](const WeakPtr<FocusHub>& last, const RefPtr<FocusHub>& current) {
        CHECK_NULL_VOID(current);
        auto node = current->GetFrameNode();
        CHECK_NULL_VOID(node);
        InputMethodManager::GetInstance()->OnFocusNodeChange(node);
    });
}

void PipelineContext::AddFrameNodeChangeListener(const WeakPtr<FrameNode>& node)
{
    CHECK_NULL_VOID(node.Upgrade());
    if (std::find(changeInfoListeners_.begin(), changeInfoListeners_.end(), node) == changeInfoListeners_.end()) {
        changeInfoListeners_.push_back(node);
    }
}

void PipelineContext::RemoveFrameNodeChangeListener(int32_t nodeId)
{
    if (changeInfoListeners_.empty()) {
        return;
    }
    changeInfoListeners_.remove_if([nodeId](const WeakPtr<FrameNode>& node) {
        return !node.Upgrade() || nodeId == node.Upgrade()->GetId();
    });
}

bool PipelineContext::AddChangedFrameNode(const WeakPtr<FrameNode>& node)
{
    CHECK_NULL_RETURN(node.Upgrade(), false);
    if (changeInfoListeners_.empty()) {
        return false;
    }
    if (std::find(changedNodes_.begin(), changedNodes_.end(), node) == changedNodes_.end()) {
        changedNodes_.push_back(node);
    }
    return true;
}

void PipelineContext::RemoveChangedFrameNode(int32_t nodeId)
{
    if (changedNodes_.empty()) {
        return;
    }
    changedNodes_.remove_if([nodeId](const WeakPtr<FrameNode>& node) {
        return !node.Upgrade() || nodeId == node.Upgrade()->GetId();
    });
}

void PipelineContext::FlushNodeChangeFlag()
{
    ACE_FUNCTION_TRACE();
    if (!changeInfoListeners_.empty()) {
        for (const auto& it : changeInfoListeners_) {
            auto listener = it.Upgrade();
            if (listener) {
                listener->ProcessFrameNodeChangeFlag();
            }
        }
    }
    CleanNodeChangeFlag();
}

void PipelineContext::CleanNodeChangeFlag()
{
    auto cleanNodes = std::move(changedNodes_);
    changedNodes_.clear();
    for (const auto& it : cleanNodes) {
        auto changeNode = it.Upgrade();
        if (changeNode) {
            changeNode->ClearChangeInfoFlag();
        }
    }
}

void PipelineContext::GetInspectorTree()
{
#if !defined(PREVIEW) && !defined(ACE_UNITTEST) && defined(OHOS_PLATFORM)
    bool needThrow = false;
    NG::InspectorFilter filter;
    filter.AddFilterAttr("content");
    auto nodeInfos = NG::Inspector::GetInspector(false, filter, needThrow);
    UiSessionManager::GetInstance().AddValueForTree(0, nodeInfos);
#endif
    rootNode_->GetInspectorValue();
}

void PipelineContext::NotifyAllWebPattern(bool isRegister)
{
    rootNode_->NotifyWebPattern(isRegister);
}

#if defined(SUPPORT_TOUCH_TARGET_TEST)

bool PipelineContext::OnTouchTargetHitTest(const TouchEvent& point, bool isSubPipe, const std::string& target)
{
    auto scalePoint = point.CreateScalePoint(GetViewScale());
    if (scalePoint.type == TouchType::DOWN) {
        TouchRestrict touchRestrict { TouchRestrict::NONE };
        touchRestrict.sourceType = point.sourceType;
        touchRestrict.touchEvent = point;
        bool isTouchTarget = eventManager_->TouchTargetHitTest(
            scalePoint, rootNode_, touchRestrict, GetPluginEventOffset(), viewScale_, isSubPipe, target);
        return isTouchTarget;
    }
    return false;
}
#endif

void PipelineContext::UpdateHalfFoldHoverStatus(int32_t windowWidth, int32_t windowHeight)
{
    if (Container::LessThanAPIVersion(PlatformVersion::VERSION_THIRTEEN)) {
        isHalfFoldHoverStatus_ = false;
        return;
    }
    auto container = Container::Current();
    CHECK_NULL_VOID(container);
    bool isFoldable = container->IsFoldable();
    if (!isFoldable && !SystemProperties::IsSmallFoldProduct()) {
        isHalfFoldHoverStatus_ = false;
        return;
    }
    auto displayInfo = container->GetDisplayInfo();
    CHECK_NULL_VOID(displayInfo);
    auto windowManager = GetWindowManager();
    auto windowMode = windowManager->GetWindowMode();
    auto isHalfFolded = displayInfo->GetFoldStatus() == FoldStatus::HALF_FOLD;
    auto displayWidth = displayInfo->GetWidth();
    auto displayHeight = displayInfo->GetHeight();
    auto isFullScreen = windowMode == WindowMode::WINDOW_MODE_FULLSCREEN ||
        (NearEqual(displayWidth, windowWidth) && NearEqual(displayHeight, windowHeight));
    if (!isFullScreen || !isHalfFolded) {
        isHalfFoldHoverStatus_ = false;
        return;
    }
    auto rotation = displayInfo->GetRotation();
    if (SystemProperties::IsSmallFoldProduct()) {
        isHalfFoldHoverStatus_ = rotation == Rotation::ROTATION_0 || rotation == Rotation::ROTATION_180;
    } else {
        isHalfFoldHoverStatus_ = rotation == Rotation::ROTATION_90 || rotation == Rotation::ROTATION_270;
    }
}

void PipelineContext::OnHalfFoldHoverChangedCallback()
{
    for (auto&& [id, callback] : halfFoldHoverChangedCallbackMap_) {
        if (callback) {
            callback(isHalfFoldHoverStatus_);
        }
    }
}

void PipelineContext::StartFoldStatusDelayTask(FoldStatus foldStatus)
{
    if (foldStatusDelayTask_) {
        foldStatusDelayTask_.Cancel();
    }
    foldStatusDelayTask_.Reset([weak = WeakClaim(this)]() {
        auto context = weak.Upgrade();
        CHECK_NULL_VOID(context);
        context->UpdateHalfFoldHoverProperty(context->GetRootWidth(), context->GetRootHeight());
        context->OnHalfFoldHoverChangedCallback();
    });
    taskExecutor_->PostDelayedTask(
        foldStatusDelayTask_, TaskExecutor::TaskType::UI, DELAY_TIME, "ArkUIHalfFoldHoverStatusChange");
}

bool PipelineContext::CatchInteractiveAnimations(const std::function<void()>& animationCallback)
{
    CHECK_NULL_RETURN(navigationMgr_, false);
    if (navigationMgr_->IsInteractive()) {
        return navigationMgr_->AddInteractiveAnimation(animationCallback);
    }
    return false;
}

std::string PipelineContext::GetResponseRegion(const RefPtr<FrameNode>& rootNode)
{
    CHECK_NULL_RETURN(rootNode, "");
    std::vector<RectF> responseRegionList;
    rootNode->GetResponseRegionListByTraversal(responseRegionList);
    std::string responseRegionStrOrigin;
    std::string responseRegionStrFilter;
    for (const auto& rect : responseRegionList) {
        int32_t left = static_cast<int32_t>(rect.Left());
        int32_t top = static_cast<int32_t>(rect.Top());
        int32_t width = static_cast<int32_t>(rect.Width());
        int32_t height = static_cast<int32_t>(rect.Height());
        int32_t right = static_cast<int32_t>(rect.Right());
        int32_t bottom = static_cast<int32_t>(rect.Bottom());
        std::string rectStr = std::to_string(left) + "," +
                              std::to_string(top) + "," +
                              std::to_string(right) + "," +
                              std::to_string(bottom);

        responseRegionStrOrigin += rectStr + "#";
        if (thpExtraMgr_ && width <= thpExtraMgr_->GetWidth() && height <= thpExtraMgr_->GetHeight()) {
            responseRegionStrFilter += rectStr + "#";
        }
    }
    if (!responseRegionStrFilter.empty()) {
        responseRegionStrFilter.pop_back();
    }
    LOGD("THP_UpdateViewsLocation origin responseRegion = %{public}s", responseRegionStrOrigin.c_str());
    return responseRegionStrFilter;
}

void PipelineContext::NotifyResponseRegionChanged(const RefPtr<FrameNode>& rootNode)
{
    ACE_FUNCTION_TRACE();
    if (!thpExtraMgr_) {
        return;
    }
    std::string responseRegion = GetResponseRegion(rootNode);
    std::string parameters = "thp#Location#" + responseRegion;
    LOGD("THP_UpdateViewsLocation responseRegion = %{public}s", parameters.c_str());
    thpExtraMgr_->ThpExtraRunCommand("THP_UpdateViewsLocation", parameters.c_str());
}

bool PipelineContext::CheckThreadSafe() const
{
    CHECK_NULL_RETURN(taskExecutor_, true);
    if (!isFormRender_ && !taskExecutor_->WillRunOnCurrentThread(OHOS::Ace::TaskExecutor::TaskType::UI)) {
        OHOS::Ace::LogBacktrace();
        return false;
    }
    return true;
}

uint64_t PipelineContext::AdjustVsyncTimeStamp(uint64_t nanoTimestamp)
{
    auto period = window_->GetVSyncPeriod();
    if (period > 0 && recvTime_ > static_cast<int64_t>(nanoTimestamp) + MAX_MISS_COUNT * period) {
        return static_cast<uint64_t>(recvTime_ - ((recvTime_ - static_cast<int64_t>(nanoTimestamp)) % period));
    }
    return nanoTimestamp;
}

bool PipelineContext::FlushModifierAnimation(uint64_t nanoTimestamp)
{
    auto animationTimeStamp = AdjustVsyncTimeStamp(nanoTimestamp);
    if (animationTimeStamp < animationTimeStamp_) {
        ACE_SCOPED_TRACE("skip ModifierAnimation");
        TAG_LOGW(AceLogTag::ACE_ANIMATION,
            "Time decreases, skip ModifierAnimation, lastTime:%{public}" PRIu64 ", nowTime:%{public}" PRIu64,
            animationTimeStamp_, animationTimeStamp);
        return true;
    }
    animationTimeStamp_ = animationTimeStamp;
    return window_->FlushAnimation(animationTimeStamp);
}

ScopedLayout::ScopedLayout(PipelineContext* pipeline)
{
    if (!pipeline) {
        return;
    }
    // save flag before measure
    pipeline_ = pipeline;
    isLayouting_ = pipeline_->IsLayouting();
    pipeline_->SetIsLayouting(true);
}

ScopedLayout::~ScopedLayout()
{
    if (!pipeline_) {
        return;
    }
    // set layout flag back
    pipeline_->SetIsLayouting(isLayouting_);
}
} // namespace OHOS::Ace::NG