refactor(daemon): reduce the frequency of annoying notifications

Author: WhiredPlanck

app/src/main/java/com/osfans/trime/daemon/RimeDaemon.kt

@@ -113,11 +113,18 @@ object RimeDaemon {
     private const val MESSAGE_ID = 2331
     private var restartId = 0
 
+    private const val NOTIFICATION_TIMEOUT = 60000L // 60secs
+    private const val SILENCE_DURATION = 30L // 30ms
+
+    private var silenceNotificationUntil = 0L
+    private var allowNotificationUntil = 0L
+
     init {
         createNotificationChannel(
             CHANNEL_ID,
             appContext.getString(R.string.rime_daemon),
         )
+        allowNotification()
         TrimeApplication.getInstance().coroutineScope.launch {
             realRime.messageFlow.collect {
                 handleRimeMessage(it)
@@ -137,6 +144,10 @@ object RimeDaemon {
         builder.build().let { notificationManager.notify(id, it) }
     }
 
+    private fun allowNotification() {
+        allowNotificationUntil = System.currentTimeMillis() + NOTIFICATION_TIMEOUT
+    }
+
     /**
      * Restart Rime instance to deploy while keep the session
      */
@@ -153,6 +164,7 @@ object RimeDaemon {
             }
         }
         realRime.finalize()
+        allowNotification()
         realRime.startup(fullCheck)
         TrimeApplication.getInstance().coroutineScope.launch {
             // cancel notification on ready
@@ -164,9 +176,11 @@ object RimeDaemon {
 
     private suspend fun handleRimeMessage(it: RimeMessage<*>) {
         if (it is RimeMessage.DeployMessage) {
+            val buildNotification: NotificationCompat.Builder.() -> Unit
+            var blockMessage = false
             when (it.data) {
                 RimeMessage.DeployMessage.State.Start -> {
-                    sendNotification(MESSAGE_ID) {
+                    buildNotification = {
                         setSmallIcon(R.drawable.ic_baseline_refresh_reversed_24)
                         setContentText(appContext.getString(R.string.deploy_progress))
                         setProgress(0, 0, true)
@@ -177,7 +191,7 @@ object RimeDaemon {
                     withContext(Dispatchers.IO) { subprocess("logcat", "--clear") }
                 }
                 RimeMessage.DeployMessage.State.Success -> {
-                    sendNotification(MESSAGE_ID) {
+                    buildNotification = {
                         setSmallIcon(R.drawable.ic_baseline_refresh_reversed_24)
                         setColor(Color.GREEN)
                         setContentText(appContext.getString(R.string.deploy_finish))
@@ -186,6 +200,7 @@ object RimeDaemon {
                         setAutoCancel(true)
                         setPriority(NotificationCompat.PRIORITY_DEFAULT)
                     }
+                    blockMessage = true
                 }
                 RimeMessage.DeployMessage.State.Failure -> {
                     val intent =
@@ -197,7 +212,7 @@ object RimeDaemon {
                             putExtra(LogActivity.FROM_DEPLOY, true)
                             putExtra(LogActivity.DEPLOY_FAILURE_TRACE, log)
                         }
-                    sendNotification(MESSAGE_ID) {
+                    buildNotification = {
                         setSmallIcon(R.drawable.ic_baseline_warning_24)
                         setColor(Color.YELLOW)
                         setContentText(appContext.getString(R.string.view_deploy_failure_log))
@@ -214,8 +229,17 @@ object RimeDaemon {
                         setAutoCancel(true)
                         setPriority(NotificationCompat.PRIORITY_HIGH)
                     }
+                    blockMessage = true
                 }
             }
+            val current = System.currentTimeMillis()
+            if (current > silenceNotificationUntil && current < allowNotificationUntil) {
+                sendNotification(MESSAGE_ID, buildNotification)
+            }
+
+            if (blockMessage) {
+                silenceNotificationUntil = current + SILENCE_DURATION
+            }
         }
     }
 }