From f7f24b5822ab039faba6c57edee9833496a0b261 Mon Sep 17 00:00:00 2001
From: Daniel Gasienica <daniel@signal.org>
Date: Wed, 28 Mar 2018 10:24:07 -0400
Subject: [PATCH] Log total number of processed messages

---
 js/modules/messages_data_migrator.js | 10 ++++++++--
 1 file changed, 8 insertions(+), 2 deletions(-)

diff --git a/js/modules/messages_data_migrator.js b/js/modules/messages_data_migrator.js
index c240e7f2d..2fa04573f 100644
--- a/js/modules/messages_data_migrator.js
+++ b/js/modules/messages_data_migrator.js
@@ -104,6 +104,7 @@ exports.processAll = async ({
 
   const migrationStartTime = Date.now();
   let unprocessedMessages = [];
+  let totalMessagesProcessed = 0;
   do {
     // eslint-disable-next-line no-await-in-loop
     const lastProcessedIndex = await getLastProcessedIndex(connection);
@@ -147,9 +148,11 @@ exports.processAll = async ({
       await setLastProcessedIndex(connection, newLastProcessedIndex);
     }
 
-    console.log('Upgrade message schema on startup:', {
+    totalMessagesProcessed += numUnprocessedMessages;
+    console.log('Upgrade message schema:', {
       lastProcessedIndex,
       numUnprocessedMessages,
+      numCumulativeMessagesProcessed: totalMessagesProcessed,
       fetchDuration,
       saveDuration,
       upgradeDuration,
@@ -161,7 +164,10 @@ exports.processAll = async ({
   connection.close();
 
   const totalDuration = Date.now() - migrationStartTime;
-  console.log('Attachment migration complete:', { totalDuration });
+  console.log('Attachment migration complete:', {
+    totalDuration,
+    totalMessagesProcessed,
+  });
 };
 
 const _saveMessageBackbone = ({ BackboneMessage } = {}) => (message) => {