feat: Enhance message notifications with history and actions (#4133)

Signed-off-by: James Rich <2199651+jamesarich@users.noreply.github.com>

Author: jamesarich

app/src/main/AndroidManifest.xml

@@ -221,6 +221,8 @@
             </intent-filter>
         </receiver>
         <receiver android:name="com.geeksville.mesh.service.ReplyReceiver"/>
+        <receiver android:name="com.geeksville.mesh.service.MarkAsReadReceiver"/>
+        <receiver android:name="com.geeksville.mesh.service.ReactionReceiver"/>
 
         <!-- allow for plugin discovery -->
         <activity

app/src/main/java/com/geeksville/mesh/service/MarkAsReadReceiver.kt

@@ -0,0 +1,59 @@
+/*
+ * Copyright (c) 2025-2026 Meshtastic LLC
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program.  If not, see <https://www.gnu.org/licenses/>.
+ */
+package com.geeksville.mesh.service
+
+import android.content.BroadcastReceiver
+import android.content.Context
+import android.content.Intent
+import dagger.hilt.android.AndroidEntryPoint
+import kotlinx.coroutines.CoroutineScope
+import kotlinx.coroutines.Dispatchers
+import kotlinx.coroutines.SupervisorJob
+import kotlinx.coroutines.launch
+import org.meshtastic.core.data.repository.PacketRepository
+import org.meshtastic.core.service.MeshServiceNotifications
+import javax.inject.Inject
+
+/** A [BroadcastReceiver] that handles "Mark as read" actions from notifications. */
+@AndroidEntryPoint
+class MarkAsReadReceiver : BroadcastReceiver() {
+    @Inject lateinit var packetRepository: PacketRepository
+
+    @Inject lateinit var meshServiceNotifications: MeshServiceNotifications
+
+    private val scope = CoroutineScope(Dispatchers.IO + SupervisorJob())
+
+    companion object {
+        const val MARK_AS_READ_ACTION = "com.geeksville.mesh.MARK_AS_READ_ACTION"
+        const val CONTACT_KEY = "contactKey"
+    }
+
+    override fun onReceive(context: Context, intent: Intent) {
+        if (intent.action == MARK_AS_READ_ACTION) {
+            val contactKey = intent.getStringExtra(CONTACT_KEY) ?: return
+            val pendingResult = goAsync()
+            scope.launch {
+                try {
+                    packetRepository.clearUnreadCount(contactKey, System.currentTimeMillis())
+                    meshServiceNotifications.cancelMessageNotification(contactKey)
+                } finally {
+                    pendingResult.finish()
+                }
+            }
+        }
+    }
+}

app/src/main/java/com/geeksville/mesh/service/MeshDataHandler.kt

@@ -521,11 +521,12 @@ constructor(
     }
 
     private fun rememberReaction(packet: MeshPacket) = scope.handledLaunch {
+        val emoji = packet.decoded.payload.toByteArray().decodeToString()
         val reaction =
             ReactionEntity(
                 replyId = packet.decoded.replyId,
                 userId = dataMapper.toNodeID(packet.from),
-                emoji = packet.decoded.payload.toByteArray().decodeToString(),
+                emoji = emoji,
                 timestamp = System.currentTimeMillis(),
                 snr = packet.rxSnr,
                 rssi = packet.rxRssi,
@@ -537,6 +538,31 @@ constructor(
                 },
             )
         packetRepository.get().insertReaction(reaction)
+
+        // Find the original packet to get the contactKey
+        packetRepository.get().getPacketByPacketId(packet.decoded.replyId)?.let { original ->
+            val contactKey = original.packet.contact_key
+            val isMuted = packetRepository.get().getContactSettings(contactKey).isMuted
+            if (!isMuted) {
+                val channelName =
+                    if (original.packet.data.to == DataPacket.ID_BROADCAST) {
+                        radioConfigRepository.channelSetFlow
+                            .first()
+                            .settingsList
+                            .getOrNull(original.packet.data.channel)
+                            ?.name
+                    } else {
+                        null
+                    }
+                serviceNotifications.updateReactionNotification(
+                    contactKey,
+                    getSenderName(dataMapper.toDataPacket(packet)!!),
+                    emoji,
+                    original.packet.data.to == DataPacket.ID_BROADCAST,
+                    channelName,
+                )
+            }
+        }
     }
 
     private fun currentTransport(address: String? = meshPrefs.deviceAddress): String = when (address?.firstOrNull()) {