From ab1288351cddb5171be564e10dc8215d2451191d Mon Sep 17 00:00:00 2001
From: andrewso <9V5f1FkzI2LD>
Date: Mon, 12 Oct 2020 17:41:15 +0100
Subject: [PATCH] [12.10.20] Testing

---
 src/tweets/collector.py | 8 +++++++-
 1 file changed, 7 insertions(+), 1 deletion(-)

diff --git a/src/tweets/collector.py b/src/tweets/collector.py
index e942e07..e75fea0 100644
--- a/src/tweets/collector.py
+++ b/src/tweets/collector.py
@@ -69,12 +69,18 @@ class Streamer():
                 stream = Stream(auth=api.auth, listener=listener, tweet_mode='extended')
                 stream.filter(languages=["en"], track=hashtag)
             except IncompleteRead:
+                stream = Stream(auth=api.auth, listener=listener, tweet_mode='extended')
+                stream.filter(languages=["en"], track=hashtag)
                 log("Incomplete Read Error", 'ERR')
                 continue
             except ProtocolError:
+                stream = Stream(auth=api.auth, listener=listener, tweet_mode='extended')
+                stream.filter(languages=["en"], track=hashtag)
                 log("Protocol Error", 'ERR')
                 continue
             except:
+                stream = Stream(auth=api.auth, listener=listener, tweet_mode='extended')
+                stream.filter(languages=["en"], track=hashtag)
                 log("Some other Error", 'ERR')
                 continue
 
@@ -109,7 +115,7 @@ class Listener(StreamListener):
                     processTweet(text, self.hashtag)
                     # dumpStack.append({'type': self.hashtag, 'tweet': text})
                 else:
-                    log("[{}]".format(data['text']), 'ERR')
+                    processTweet(data["text"], self.hashtag)
 
 def processTweet(text, type):