Fixed extended retweets in Streaming API. Closes #174

This commit is contained in:
2017-11-08 09:43:12 -06:00
parent 68ea029fe3
commit ed7c9802d1
3 changed files with 11 additions and 8 deletions

View File

@@ -60,12 +60,12 @@ class timelinesStreamer(TwythonStreamer):
self.friends = friends
def on_success(self, data):
# try:
if "text" in data and utils.is_allowed(data, self.session.settings["twitter"]["ignored_clients"]) == True:
if data.has_key("extended_tweet"):
data["full_text"] = data["extended_tweet"]["full_text"]
# data["entities"] = data["extended_tweet"]["entities"]
# log.error(data["extended_entities"])
if data.has_key("retweeted_status"):
if data["retweeted_status"].has_key("extended_tweet"):
data["retweeted_status"]["full_text"] = data["retweeted_status"]["extended_tweet"]["full_text"]
data["full_text"] = data["text"]
data["retweeted_status"]["entities"] = data["retweeted_status"]["extended_tweet"]["entities"]
self.check_tls(data)
# except:
# pass

View File

@@ -132,8 +132,11 @@ class streamer(TwythonStreamer):
if data.has_key("extended_tweet"):
data["full_text"] = data["extended_tweet"]["full_text"]
data["entities"] = data["extended_tweet"]["entities"]
# log.error(data["extended_tweet"])
# log.error("Extended tweet")
if data.has_key("retweeted_status"):
if data["retweeted_status"].has_key("extended_tweet"):
data["retweeted_status"]["full_text"] = data["retweeted_status"]["extended_tweet"]["full_text"]
data["full_text"] = data["text"]
data["retweeted_status"]["entities"] = data["retweeted_status"]["extended_tweet"]["entities"]
if data["user"]["id"] in self.muted_users: return
self.check_mentions(data)
self.check_send(data)