1 /* 2 * Copyright (C) 2023 The Android Open Source Project 3 * 4 * Licensed under the Apache License, Version 2.0 (the "License"); 5 * you may not use this file except in compliance with the License. 6 * You may obtain a copy of the License at 7 * 8 * http://www.apache.org/licenses/LICENSE-2.0 9 * 10 * Unless required by applicable law or agreed to in writing, software 11 * distributed under the License is distributed on an "AS IS" BASIS, 12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 13 * See the License for the specific language governing permissions and 14 * limitations under the License. 15 */ 16 17 package com.android.systemui.keyevent.data.repository 18 19 import android.view.KeyEvent 20 import com.android.systemui.common.coroutine.ChannelExt.trySendWithFailureLogging 21 import com.android.systemui.utils.coroutines.flow.conflatedCallbackFlow 22 import com.android.systemui.dagger.SysUISingleton 23 import com.android.systemui.statusbar.CommandQueue 24 import javax.inject.Inject 25 import kotlinx.coroutines.channels.awaitClose 26 import kotlinx.coroutines.flow.Flow 27 28 /** Defines interface for classes that encapsulate application state for key event presses. */ 29 interface KeyEventRepository { 30 /** Observable for whether the power button key is pressed/down or not. */ 31 val isPowerButtonDown: Flow<Boolean> 32 33 /** Observable for when the power button is being pressed but till the duration of long press */ 34 val isPowerButtonLongPressed: Flow<Boolean> 35 } 36 37 @SysUISingleton 38 class KeyEventRepositoryImpl 39 @Inject 40 constructor( 41 private val commandQueue: CommandQueue, 42 ) : KeyEventRepository { <lambda>null43 override val isPowerButtonDown: Flow<Boolean> = conflatedCallbackFlow { 44 val callback = 45 object : CommandQueue.Callbacks { 46 override fun handleSystemKey(event: KeyEvent) { 47 if (event.keyCode == KeyEvent.KEYCODE_POWER) { 48 trySendWithFailureLogging(event.isDown, TAG, "updated isPowerButtonDown") 49 } 50 } 51 } 52 trySendWithFailureLogging(false, TAG, "init isPowerButtonDown") 53 commandQueue.addCallback(callback) 54 awaitClose { commandQueue.removeCallback(callback) } 55 } 56 <lambda>null57 override val isPowerButtonLongPressed: Flow<Boolean> = conflatedCallbackFlow { 58 val callback = 59 object : CommandQueue.Callbacks { 60 override fun handleSystemKey(event: KeyEvent) { 61 if (event.keyCode == KeyEvent.KEYCODE_POWER) { 62 trySendWithFailureLogging(event.action == KeyEvent.ACTION_DOWN 63 && event.isLongPress, TAG, "updated isPowerButtonLongPressed") 64 } 65 } 66 } 67 trySendWithFailureLogging(false, TAG, "init isPowerButtonLongPressed") 68 commandQueue.addCallback(callback) 69 awaitClose { commandQueue.removeCallback(callback) } 70 } 71 72 companion object { 73 private const val TAG = "KeyEventRepositoryImpl" 74 } 75 } 76