ON PAUSE FOR TYPESCRIPT

Client/src/main/java/MessageScraper.java

@@ -0,0 +1,53 @@
+import com.fasterxml.jackson.databind.ObjectMapper;
+
+import java.io.IOException;
+import java.util.ArrayList;
+
+public class MessageScraper implements Runnable{
+    private ArrayList<Message> messageList;
+    private User user;
+    private YouAreEll webber;
+
+    public MessageScraper(User user, YouAreEll webber) {
+        this.user = user;
+        this.webber = webber;
+    }
+
+    public void run() {
+        this.messageList = new ArrayList<Message>();
+        ObjectMapper objectMapper = new ObjectMapper();
+        Message[] incoming = new Message[0];
+        String scrape;
+        while (true){
+            waitN(4000);
+            scrape = webber.get_messages(user);
+            waitN(100);
+            try {
+                incoming = objectMapper.readValue(scrape, Message[].class);
+            } catch (IOException e) {
+                e.printStackTrace();
+            }
+            for (Message message:incoming) {
+                if (newMessageCheck(message)){
+                    System.out.println("New Message!\n" + message.getFromid() + " says: " + message.getMessage());
+                    this.messageList.add(message);
+                }
+            }
+        }
+    }
+
+    private void waitN(int i) {
+        try {
+            Thread.sleep(i);
+        } catch (InterruptedException e) {
+            e.printStackTrace();
+        }
+    }
+
+    private boolean newMessageCheck(Message newMessage){
+        for (Message message:this.messageList) {
+            if (message.getSequence().equals(newMessage.getSequence())) return false;
+        }
+        return true;
+    }
+}

Client/src/main/java/SimpleShell.java

@@ -68,8 +68,10 @@ public class SimpleShell {
         String githubID = console.readLine();
         User user = new User(name, githubID);
         System.out.println(user.getName() + " " + user.getGithub());
-        Thread scrapeThread = new Thread(new DMScraper(user, webber));
-        scrapeThread.start();
+        Thread dmscrapeThread = new Thread(new DMScraper(user, webber));
+        dmscrapeThread.start();
+        Thread globalScrapeThread = new Thread(new MessageScraper(user, webber));
+        globalScrapeThread.start();
         //we break out with <ctrl c>
         while (true) {
             //read what the user enters