Asyncify (almost) all the things!

Author: Trolldemorted

Signal-Windows.Lib/IncomingMessages.cs

@@ -65,7 +65,7 @@ public void SendMessage(SignalServiceSyncMessage message)
             }
         }
 
-        public void HandleOutgoingMessages()
+        public async Task HandleOutgoingMessages()
         {
             Logger.LogDebug("HandleOutgoingMessages()");
             while (!Token.IsCancellationRequested)
@@ -92,7 +92,7 @@ public void HandleOutgoingMessages()
                     else
                     {
                         List<SignalServiceAddress> recipients = new List<SignalServiceAddress>();
-                        SignalGroup g = SignalDBContext.GetOrCreateGroupLocked(outgoingSignalMessage.ThreadId, 0);
+                        SignalGroup g = await SignalDBContext.GetOrCreateGroupLocked(outgoingSignalMessage.ThreadId, 0);
                         foreach (GroupMembership sc in g.GroupMemberships)
                         {
                             if (sc.Contact.ThreadId != SignalLibHandle.Instance.Store.Username)
@@ -132,7 +132,7 @@ public void HandleOutgoingMessages()
                     }
                     foreach (UntrustedIdentityException e in identityExceptions)
                     {
-                        Handle.HandleOutgoingKeyChangeLocked(e.E164number, Base64.EncodeBytes(e.IdentityKey.serialize()));
+                        await Handle.HandleOutgoingKeyChangeLocked(e.E164number, Base64.EncodeBytes(e.IdentityKey.serialize()));
                     }
                 }
                 catch (RateLimitException)
@@ -144,15 +144,15 @@ public void HandleOutgoingMessages()
                 {
                     Logger.LogError("HandleOutgoingMessages() could not send due to untrusted identities");
                     outgoingSignalMessage.Status = SignalMessageStatus.Failed_Identity;
-                    Handle.HandleOutgoingKeyChangeLocked(e.E164number, Base64.EncodeBytes(e.IdentityKey.serialize()));
+                    await Handle.HandleOutgoingKeyChangeLocked(e.E164number, Base64.EncodeBytes(e.IdentityKey.serialize()));
                 }
                 catch (Exception e)
                 {
                     var line = new StackTrace(e, true).GetFrames()[0].GetFileLineNumber();
                     Logger.LogError("HandleOutgoingMessages() failed in line {0}: {1}\n{2}", line, e.Message, e.StackTrace);
                     outgoingSignalMessage.Status = SignalMessageStatus.Failed_Unknown;
                 }
-                Handle.HandleMessageSentLocked(outgoingSignalMessage);
+                await Handle.HandleMessageSentLocked(outgoingSignalMessage);
             }
             Logger.LogInformation("HandleOutgoingMessages() finished");
         }

Signal-Windows.Lib/OutgoingMessages.cs

@@ -166,7 +166,7 @@
   </ItemGroup>
   <ItemGroup>
     <PackageReference Include="libsignal-service-dotnet">
-      <Version>2.7.5.8</Version>
+      <Version>2.7.5.9</Version>
     </PackageReference>
     <PackageReference Include="Microsoft.EntityFrameworkCore">
       <Version>1.1.4</Version>