(NOBIDS) BEDS-372: improve sendPushNotifications

gobitfly · Aug 28, 2024 · 7bd121c · 7bd121c
1 parent dbc0b0d
commit 7bd121c
Showing 1 changed file with 9 additions and 2 deletions.
diff --git a/services/notifications.go b/services/notifications.go
@@ -600,10 +600,17 @@ func sendPushNotifications(useDB *sqlx.DB) error {
 		return fmt.Errorf("error querying notification queue, err: %w", err)
 	}
 
-	logger.WithField("notifications", len(notificationQueueItem)).Info("processing push notifications")
+	totalMessageCount := 0
+	for _, n := range notificationQueueItem {
+		totalMessageCount += len(n.Content.Messages)
+	}
+
+	logger = logger.WithField("items", len(notificationQueueItem))
+	logger = logger.WithField("messages", totalMessageCount)
+	logger.Info("processing push notifications")
 	start := time.Now()
 	defer func() {
-		logger.WithField("notifications", len(notificationQueueItem)).WithField("duration", time.Since(start)).Info("processed push notifications")
+		logger.WithField("duration", time.Since(start)).Info("processed push notifications")
 	}()
 
 	batchSize := 500