diff options
-rw-r--r-- | src/main/TweetCounter.java | 16 | ||||
-rw-r--r-- | src/main/TweetShell.java | 6 |
2 files changed, 22 insertions, 0 deletions
diff --git a/src/main/TweetCounter.java b/src/main/TweetCounter.java index e922c5c..6c1397a 100644 --- a/src/main/TweetCounter.java +++ b/src/main/TweetCounter.java @@ -1,5 +1,6 @@ package main; +import java.util.Date; import java.util.HashSet; import java.util.Set; import java.util.logging.Level; @@ -20,9 +21,11 @@ public class TweetCounter implements ResultListener { private int tweetCount = 0; private final Set<String> users; + private final Date start_date; public TweetCounter() { this.users = new HashSet<>(); + this.start_date = new Date(); } @Override @@ -47,4 +50,17 @@ public class TweetCounter implements ResultListener { public Set<String> getUsers() { return users; } + + public Date getStartDate() { + return start_date; + } + + public String getActiveTime() { + Date now = new Date(); + long timediff = (now.getTime() - start_date.getTime()) / 1000; + return String.format("%d hour(s), %d min(s), %d sec(s)", + timediff / 3600, + (timediff % 3600) / 60, + timediff % 60); + } } diff --git a/src/main/TweetShell.java b/src/main/TweetShell.java index 354bdf9..8b801ea 100644 --- a/src/main/TweetShell.java +++ b/src/main/TweetShell.java @@ -6,6 +6,8 @@ import io.OAuthRequester; import io.StreamImpl; import java.io.Closeable; import java.io.IOException; +import java.text.DateFormat; +import java.text.SimpleDateFormat; import java.util.Arrays; import java.util.Map; import java.util.NoSuchElementException; @@ -297,6 +299,10 @@ public class TweetShell implements TwitterApi.PinSupplier { } else { System.out.println("Streaming is inactive."); } + DateFormat df = SimpleDateFormat.getDateTimeInstance(); + String start_date = df.format(tc.getStartDate()); + System.out.println("Started at " + start_date); + System.out.println("Elapsed: " + tc.getActiveTime()); System.out.println("Received tweets in session: " + tc.getTweetCount()); System.out.println("Unique users: " + tc.getUsers().size()); break; |