From 08a286cf2326c9c55c99f2907c22a696aff811f3 Mon Sep 17 00:00:00 2001
From: Athou <jeremiepanzer@gmail.com>
Date: Sat, 18 May 2013 09:38:34 +0200
Subject: [PATCH] more metrics

---
 .../java/com/commafeed/backend/MetricsBean.java    | 14 +++++++++++++-
 .../backend/services/FeedUpdateService.java        |  2 +-
 2 files changed, 14 insertions(+), 2 deletions(-)

diff --git a/src/main/java/com/commafeed/backend/MetricsBean.java b/src/main/java/com/commafeed/backend/MetricsBean.java
index 9279e56e..0447c422 100644
--- a/src/main/java/com/commafeed/backend/MetricsBean.java
+++ b/src/main/java/com/commafeed/backend/MetricsBean.java
@@ -33,9 +33,12 @@ public class MetricsBean {
 		thisHour.feedsRefreshed++;
 	}
 
-	public void feedUpdated() {
+	public void feedUpdated(int entriesCount) {
 		thisHour.feedsRefreshed++;
 		thisMinute.feedsUpdated++;
+
+		thisHour.entriesInserted += entriesCount;
+		thisMinute.entriesInserted += entriesCount;
 	}
 
 	public Metric getLastMinute() {
@@ -49,6 +52,7 @@ public class MetricsBean {
 	public static class Metric {
 		private int feedsRefreshed;
 		private int feedsUpdated;
+		private int entriesInserted;
 
 		public int getFeedsRefreshed() {
 			return feedsRefreshed;
@@ -66,5 +70,13 @@ public class MetricsBean {
 			this.feedsUpdated = feedsUpdated;
 		}
 
+		public int getEntriesInserted() {
+			return entriesInserted;
+		}
+
+		public void setEntriesInserted(int entriesInserted) {
+			this.entriesInserted = entriesInserted;
+		}
+
 	}
 }
diff --git a/src/main/java/com/commafeed/backend/services/FeedUpdateService.java b/src/main/java/com/commafeed/backend/services/FeedUpdateService.java
index 6fe3d517..8c73b1e5 100644
--- a/src/main/java/com/commafeed/backend/services/FeedUpdateService.java
+++ b/src/main/java/com/commafeed/backend/services/FeedUpdateService.java
@@ -95,7 +95,7 @@ public class FeedUpdateService {
 
 		feedEntryDAO.saveOrUpdate(entryUpdateList);
 		feedEntryStatusDAO.saveOrUpdate(statusUpdateList);
-		metricsBean.feedUpdated();
+		metricsBean.feedUpdated(entryUpdateList.size());
 	}
 
 	private FeedEntry findEntry(List<FeedEntry> existingEntries, FeedEntry entry) {