Log the time it takes to send a group message

diff --git a/lib/src/main/java/org/asamk/signal/manager/helper/SendHelper.java b/lib/src/main/java/org/asamk/signal/manager/helper/SendHelper.java
index acdba555f0e797b3db06d505e6d3b285a0853d80..108c3c6896f54df5d8f112841f213d21c4814453 100644 (file)
--- a/lib/src/main/java/org/asamk/signal/manager/helper/SendHelper.java
+++ b/lib/src/main/java/org/asamk/signal/manager/helper/SendHelper.java
@@ -38,6 +38,7 @@ import org.whispersystems.signalservice.api.push.exceptions.UnregisteredUserExce
 import org.whispersystems.signalservice.internal.push.exceptions.InvalidUnidentifiedAccessHeaderException;
 
 import java.io.IOException;
 import org.whispersystems.signalservice.internal.push.exceptions.InvalidUnidentifiedAccessHeaderException;
 
 import java.io.IOException;

+import java.time.Duration;

 import java.util.ArrayList;
 import java.util.HashSet;
 import java.util.List;
 import java.util.ArrayList;
 import java.util.HashSet;
 import java.util.List;


@@ -285,6 +286,7 @@ public class SendHelper {
             final Set<RecipientId> recipientIds,
             final DistributionId distributionId
     ) throws IOException {
             final Set<RecipientId> recipientIds,
             final DistributionId distributionId
     ) throws IOException {

+        long startTime = System.currentTimeMillis();

         // isRecipientUpdate is true if we've already sent this message to some recipients in the past, otherwise false.
         final var isRecipientUpdate = false;
         Set<RecipientId> senderKeyTargets = distributionId == null
         // isRecipientUpdate is true if we've already sent this message to some recipients in the past, otherwise false.
         final var isRecipientUpdate = false;
         Set<RecipientId> senderKeyTargets = distributionId == null


@@ -329,7 +331,8 @@ public class SendHelper {
                     isRecipientUpdate || allResults.size() > 0);
             allResults.addAll(results);
         }
                     isRecipientUpdate || allResults.size() > 0);
             allResults.addAll(results);
         }

-
+        final var duration = Duration.ofMillis(System.currentTimeMillis() - startTime);
+        logger.debug("Sending took {} seconds", duration.toString());

         return allResults;
     }
 
         return allResults;
     }