From 02405da2ebfffc6c03ba8fdc53b7534ead871e4e Mon Sep 17 00:00:00 2001
From: Stephen Paul Weber <singpolyma@singpolyma.net>
Date: Wed, 5 Feb 2025 14:35:06 -0500
Subject: [PATCH] Show missed calls from when you were offline

Show them as unread and notify about them
---
 .../siacs/conversations/parser/MessageParser.java   |  8 +++++++-
 .../conversations/services/NotificationService.java | 13 +++++++++++++
 2 files changed, 20 insertions(+), 1 deletion(-)

diff --git a/src/main/java/eu/siacs/conversations/parser/MessageParser.java b/src/main/java/eu/siacs/conversations/parser/MessageParser.java
index c0dca4c3d59c1bb08f738ce53487bc43be8694c5..cc2dc8bd975d5eb90fd9f3c75a80f0123057c496 100644
--- a/src/main/java/eu/siacs/conversations/parser/MessageParser.java
+++ b/src/main/java/eu/siacs/conversations/parser/MessageParser.java
@@ -18,6 +18,7 @@ import java.util.Arrays;
 import java.util.Collections;
 import java.util.Date;
 import java.util.HashSet;
+import java.util.HashMap;
 import java.util.LinkedHashSet;
 import java.util.List;
 import java.util.Locale;
@@ -846,7 +847,6 @@ public class MessageParser extends AbstractParser implements Consumer<im.convers
 
             if (replacementId != null && mXmppConnectionService.allowMessageCorrection()) {
                 final Message replacedMessage = conversation.findMessageWithRemoteIdAndCounterpart(replacementId, counterpart);
-Log.d("WUT", "" + replacementId + "  " + replacedMessage);
                 if (replacedMessage != null) {
                     final boolean fingerprintsMatch = replacedMessage.getFingerprint() == null
                             || replacedMessage.getFingerprint().equals(message.getFingerprint());
@@ -1184,7 +1184,10 @@ Log.d("WUT", "" + replacementId + "  " + replacedMessage);
                                     message.setServerMsgId(serverMsgId);
                                     message.setTime(timestamp);
                                     message.setBody(new RtpSessionStatus(false, 0).toString());
+                                    message.markUnread();
                                     c.add(message);
+                                    mXmppConnectionService.getNotificationService().possiblyMissedCall(c.getUuid() + sessionId, message);
+                                    query.incrementActualMessageCount();
                                     mXmppConnectionService.databaseBackend.createMessage(message);
                                 }
                             } else if ("proceed".equals(action)) {
@@ -1203,6 +1206,9 @@ Log.d("WUT", "" + replacementId + "  " + replacedMessage);
                                         message.setServerMsgId(serverMsgId);
                                     }
                                     message.setTime(timestamp);
+                                    message.markRead();
+                                    mXmppConnectionService.getNotificationService().possiblyMissedCall(c.getUuid() + sessionId, message);
+                                    query.incrementActualMessageCount();
                                     mXmppConnectionService.updateMessage(message, true);
                                 } else {
                                     Log.d(
diff --git a/src/main/java/eu/siacs/conversations/services/NotificationService.java b/src/main/java/eu/siacs/conversations/services/NotificationService.java
index 484ed1a97a1dc15d19c6df1933033d7dd5ab306a..09b19a4a370e9ebb52544515b4c83ec3a2e0a113 100644
--- a/src/main/java/eu/siacs/conversations/services/NotificationService.java
+++ b/src/main/java/eu/siacs/conversations/services/NotificationService.java
@@ -122,6 +122,7 @@ public class NotificationService {
     private final HashMap<Conversation, AtomicInteger> mBacklogMessageCounter = new HashMap<>();
     private final LinkedHashMap<Conversational, MissedCallsInfo> mMissedCalls =
             new LinkedHashMap<>();
+    private final Map<String, Message> possiblyMissedCalls = new HashMap<>();
     private Conversation mOpenConversation;
     private boolean mIsInForeground;
     private long mLastNotification;
@@ -489,6 +490,12 @@ public class NotificationService {
                 updateNotification(count > 0, conversations);
             }
         }
+        synchronized (possiblyMissedCalls) {
+            for (final var entry : possiblyMissedCalls.entrySet()) {
+               pushFromBacklog(entry.getValue());
+            }
+            possiblyMissedCalls.clear();
+        }
         synchronized (mMissedCalls) {
             updateMissedCallNotifications(mMissedCalls.keySet());
         }
@@ -877,6 +884,12 @@ public class NotificationService {
         }
     }
 
+    public void possiblyMissedCall(final String sessionId, final Message message) {
+        synchronized (possiblyMissedCalls) {
+            possiblyMissedCalls.put(sessionId, message);
+        }
+    }
+
     public void pushMissedCallNow(final Message message) {
         synchronized (mMissedCalls) {
             pushMissedCall(message);