From e303d914feac0f0c46c46a237126bc71d14f5339 Mon Sep 17 00:00:00 2001 From: Manuel Cortez Date: Mon, 20 Nov 2017 01:10:25 -0600 Subject: [PATCH] Filters will work in main buffers too. #102 --- src/twitter/buffers/stream.py | 22 ++++++++++++---------- 1 file changed, 12 insertions(+), 10 deletions(-) diff --git a/src/twitter/buffers/stream.py b/src/twitter/buffers/stream.py index 45fd77fa..25662dc1 100644 --- a/src/twitter/buffers/stream.py +++ b/src/twitter/buffers/stream.py @@ -27,21 +27,23 @@ class streamer(TwythonStreamer): def put_data(self, place, data): if self.session.db.has_key(place): - if utils.find_item(data["id"], self.session.db[place]) != None and utils.is_allowed(data, self.session.settings, place): + if utils.find_item(data["id"], self.session.db[place]) != None: log.error("duplicated tweet. Ignoring it...") return False # try: - data_ = self.session.check_quoted_status(data) - data_ = self.session.check_long_tweet(data_) - data = data_ + if utils.is_allowed(data, self.session.settings, place): + data_ = self.session.check_quoted_status(data) + data_ = self.session.check_long_tweet(data_) + data = data_ # except: # pass - if self.session.settings["general"]["reverse_timelines"] == False: - self.session.db[place].append(data) - else: - self.session.db[place].insert(0, data) - utils.is_audio(data) - return True + if self.session.settings["general"]["reverse_timelines"] == False: + self.session.db[place].append(data) + else: + self.session.db[place].insert(0, data) + utils.is_audio(data) + return True + return False def block_user(self, data): id = data["target"]["id"]