mcvsoftware/twblue
1
0
Fork 0
mirror of https://github.com/MCV-Software/TWBlue.git synced 2025-07-18 06:06:06 -04:00
Code Issues Actions Packages Projects Releases Wiki Activity

Quoted tweets again

Browse Source
This commit is contained in:
Manuel Cortez
2015-10-14 17:07:57 -05:00
parent 6c47dd2fa9
commit 0f56d8cdd4
5 changed files with 17 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/twitter/buffers/indibidual.py
View File

@@ -22,6 +22,7 @@ class timelinesStreamer(TwythonStreamer):
def on_error(self, status_code, data):
log.debug("%s: %s" % (status_code, data))
pub.sendMessage("stream-error")
def on_timeout(self, *args, **kwargs):
log.debug("Twitter timeout Error")
@@ -33,7 +34,11 @@ class timelinesStreamer(TwythonStreamer):
if utils.find_item(data["id"], self.session.db["%s-timeline" % (i,)]) != None:
log.error("duplicated tweet. Ignoring it...")
return
data = self.session.check_quoted_status(data)
try:
data_ = self.session.check_quoted_status(data)
data = data_
except:
pass
if self.session.settings["general"]["reverse_timelines"] == False: self.session.db["%s-timeline" % (i,)].append(data)
else: self.session.db["%s-timeline" % (i,)].insert(0, data)
pub.sendMessage("item-in-timeline", data= data, user= self.session.db["user_name"], who= i)

7
src/twitter/buffers/stream.py
View File

@@ -27,6 +27,7 @@ class streamer(TwythonStreamer):
def on_error(self, status_code, data):
log.debug("Error %s: %s" % (status_code, data))
pub.sendMessage("stream-error")
def get_user(self):
return self.session.db["user_name"]
@@ -36,7 +37,11 @@ class streamer(TwythonStreamer):
if utils.find_item(data["id"], self.session.db[place]) != None:
log.error("duplicated tweet. Ignoring it...")
return
# data = self.session.check_quoted_status(data)
try:
data_ = self.session.check_quoted_status(data)
data = data_
except:
pass
if self.session.settings["general"]["reverse_timelines"] == False:
self.session.db[place].append(data)
else: