android-16.0.0_r2/s

/*
 * Copyright (C) 2025 The Android Open Source Project
 *
 * 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.
 */

package com.android.systemui.car.wm.scalableui.panel;

import android.app.ActivityManager;
import android.content.ComponentName;
import android.util.ArraySet;

import com.android.car.scalableui.panel.Panel;
import com.android.car.scalableui.panel.PanelPool;
import com.android.systemui.dagger.qualifiers.UiBackground;
import com.android.wm.shell.dagger.WMSingleton;

import java.util.HashMap;
import java.util.LinkedHashMap;
import java.util.Map;
import java.util.Objects;
import java.util.Set;
import java.util.concurrent.Executor;

import javax.annotation.concurrent.GuardedBy;
import javax.inject.Inject;

@WMSingleton
public class TaskPanelInfoRepository {
    private final Object mLock = new Object();
    @GuardedBy("mLock")
    private final Map<String, LinkedHashMap<Integer, ActivityManager.RunningTaskInfo>>
            mPanelTaskMap = new HashMap<>();
    @GuardedBy("mLock")
    private final Set<TaskPanelChangeListener> mListeners = new ArraySet<>();
    private final Executor mUiBackgroundExecutor;

    @GuardedBy("mLock")
    private boolean mHasPendingTaskChanges = false;

    @Inject
    public TaskPanelInfoRepository(@UiBackground Executor executor) {
        mUiBackgroundExecutor = executor;
    }

    /**
     * Add a change listener for all panels.
     */
    public void addChangeListener(TaskPanelChangeListener listener) {
        synchronized (mLock) {
            mListeners.add(listener);
        }
    }

    /**
     * Remove a change listener for all panels.
     */
    public void removeChangeListener(TaskPanelChangeListener listener) {
        synchronized (mLock) {
            mListeners.remove(listener);
        }
    }

    /**
     * Query if a specific package is currently visible on any panel.
     */
    public boolean isPackageVisible(String packageName) {
        synchronized (mLock) {
            for (String panelId : mPanelTaskMap.keySet()) {
                if (mPanelTaskMap.get(panelId).lastEntry() != null
                        && mPanelTaskMap.get(panelId).lastEntry().getValue().topActivity != null
                        && Objects.equals(mPanelTaskMap.get(panelId).lastEntry().getValue()
                        .topActivity.getPackageName(), packageName)) {
                    return isPanelVisible(panelId);
                }
            }
        }
        return false;
    }

    /**
     * Query if a specific package is currently visible on a specific display.
     */
    public boolean isPackageVisibleOnDisplay(String packageName, int displayId) {
        synchronized (mLock) {
            for (String panelId : mPanelTaskMap.keySet()) {
                if (mPanelTaskMap.get(panelId).lastEntry() != null) {
                    ActivityManager.RunningTaskInfo taskInfo = mPanelTaskMap.get(
                            panelId).lastEntry().getValue();
                    if (taskInfo.topActivity != null && Objects.equals(
                            taskInfo.topActivity.getPackageName(), packageName)
                            && taskInfo.displayId == displayId) {
                        return isPanelVisible(panelId);
                    }
                }
            }
        }
        return false;
    }

    /**
     * Query if a specific component is currently visible.
     */
    public boolean isComponentVisible(ComponentName componentName) {
        synchronized (mLock) {
            for (String panelId : mPanelTaskMap.keySet()) {
                if (mPanelTaskMap.get(panelId).lastEntry() != null && Objects.equals(
                        mPanelTaskMap.get(
                                panelId).lastEntry().getValue().topActivity, componentName)) {
                    return isPanelVisible(panelId);
                }
            }
        }
        return false;
    }

    /**
     * Query if a specific component is currently visible on a specific display.
     */
    public boolean isComponentVisibleOnDisplay(ComponentName componentName, int displayId) {
        synchronized (mLock) {
            for (String panelId : mPanelTaskMap.keySet()) {
                if (mPanelTaskMap.get(panelId).lastEntry() != null && Objects.equals(
                        mPanelTaskMap.get(
                                panelId).lastEntry().getValue().topActivity, componentName)
                        && mPanelTaskMap.get(panelId).lastEntry().getValue().displayId
                        == displayId) {
                    return isPanelVisible(panelId);
                }
            }
        }
        return false;
    }

    /**
     * Query if a specific panel is currently visible.
     */
    private boolean isPanelVisible(String panelId) {
        Panel panel = PanelPool.getInstance().getPanel(panelId);
        if (panel == null) {
            return false;
        }
        return panel.isVisible();
    }

    void onTaskAppearedOnPanel(String panelId, ActivityManager.RunningTaskInfo taskInfo) {
        synchronized (mLock) {
            if (!mPanelTaskMap.containsKey(panelId)) {
                mPanelTaskMap.put(panelId, new LinkedHashMap<>());
            }
            mPanelTaskMap.get(panelId).put(taskInfo.taskId, taskInfo);
            mHasPendingTaskChanges = true;
        }
    }

    void onTaskChangedOnPanel(String panelId, ActivityManager.RunningTaskInfo taskInfo) {
        synchronized (mLock) {
            if (!mPanelTaskMap.containsKey(panelId)) {
                return;
            }
            ActivityManager.RunningTaskInfo oldTask = mPanelTaskMap.get(panelId).get(
                    taskInfo.taskId);
            mPanelTaskMap.get(panelId).put(taskInfo.taskId, taskInfo);
            if ((oldTask == null || !isTaskVisible(oldTask)
                    || !Objects.equals(oldTask.topActivity, taskInfo.topActivity))
                    && isTaskVisible(taskInfo)) {
                mHasPendingTaskChanges = true;
            }
        }
    }

    void onTaskVanishedOnPanel(String panelId, ActivityManager.RunningTaskInfo taskInfo) {
        synchronized (mLock) {
            if (!mPanelTaskMap.containsKey(panelId)) {
                return;
            }
            ActivityManager.RunningTaskInfo removed = mPanelTaskMap.get(panelId).remove(
                    taskInfo.taskId);
            if (removed == null) {
                return;
            }
            mHasPendingTaskChanges = true;
        }
    }

    /**
     * Notify if the top task on any panel has changed. This should be called from startAnimation
     * only since that is when the task stack is finalized and settled (to reduce
     * over-notification).
     */
    public void maybeNotifyTopTaskOnPanelChanged() {
        synchronized (mLock) {
            if (!mHasPendingTaskChanges) {
                return;
            }
            mHasPendingTaskChanges = false;
            mListeners.forEach(listener -> mUiBackgroundExecutor.execute(
                    listener::onTopTaskOnPanelChanged));
        }
    }

    private boolean isTaskVisible(ActivityManager.RunningTaskInfo task) {
        return task.isVisible && task.isRunning && !task.isSleeping;
    }

    public interface TaskPanelChangeListener {
        /**
         * Notify the top task on a panel has changed.
         */
        void onTopTaskOnPanelChanged();
    }
}