Send sync read messages to sibling devices

Author: Trolldemorted

Signal-Windows.Lib/OutgoingMessages.cs

@@ -2,6 +2,7 @@
 using libsignalservice;
 using libsignalservice.crypto;
 using libsignalservice.messages;
+using libsignalservice.messages.multidevice;
 using libsignalservice.push;
 using libsignalservice.push.exceptions;
 using libsignalservice.util;
@@ -40,6 +41,14 @@ public void SendMessage(List<SignalServiceAddress> recipients, SignalServiceData
             }
         }
 
+        public void SendMessage(SignalServiceSyncMessage message)
+        {
+            lock (this)
+            {
+                MessageSender.sendMessage(message);
+            }
+        }
+
         public void HandleOutgoingMessages()
         {
             Logger.LogDebug("HandleOutgoingMessages()");

Signal-Windows.Lib/SignalLibHandle.cs

@@ -20,6 +20,9 @@
 using Windows.Networking.BackgroundTransfer;
 using Windows.Storage;
 using Windows.Web;
+using libsignalservice.push;
+using Strilanc.Value;
+using libsignalservice.messages.multidevice;
 
 namespace Signal_Windows.Lib
 {
@@ -50,7 +53,7 @@ public interface ISignalLibHandle
         //Frontend API
         SignalStore Store { get; set; }
         Task SendMessage(SignalMessage message, SignalConversation conversation);
-        Task SetMessageRead(long index, SignalConversation conversation);
+        Task SetMessageRead(long index, SignalMessage message, SignalConversation conversation);
         void ResendMessage(SignalMessage message);
         List<SignalMessageContainer> GetMessages(SignalConversation thread, int startIndex, int count);
         void SaveAndDispatchSignalConversation(SignalConversation updatedConversation, SignalMessage updateMessage);
@@ -331,14 +334,17 @@ await Task.Run(() =>
         /// Marks and dispatches a message as read. Must not be called on a task which holds the handle lock.
         /// </summary>
         /// <param name="message"></param>
-        public async Task SetMessageRead(long index, SignalConversation conversation)
+        public async Task SetMessageRead(long index, SignalMessage message, SignalConversation conversation)
         {
             Logger.LogTrace("SetMessageRead() locking");
             await SemaphoreSlim.WaitAsync(CancelSource.Token);
             try
             {
                 Logger.LogTrace("SetMessageRead() locked");
                 conversation = SignalDBContext.UpdateMessageRead(index, conversation);
+                OutgoingMessages.SendMessage(SignalServiceSyncMessage.forRead(new List<ReadMessage>() {
+                        new ReadMessage(message.Author.ThreadId, message.ComposedTimestamp)
+                }));
                 await DispatchMessageRead(index, conversation);
             }
             finally

Signal-Windows/Controls/Conversation.xaml.cs

@@ -344,7 +344,7 @@ private void ScrollViewer_ViewChanged(object sender, ScrollViewerViewChangedEven
                     LastMarkReadRequest = bottomIndex;
                     Task.Run(async () =>
                     {
-                        await App.Handle.SetMessageRead(bottomIndex, SignalConversation);
+                        await App.Handle.SetMessageRead(bottomIndex, ((SignalMessageContainer) Collection[bottomIndex]).Message, SignalConversation);
                     });
                 }
             }