summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--src/main/TweetCounter.java16
-rw-r--r--src/main/TweetShell.java6
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;