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

Reconnecting streams every 5 mins

Browse Source
This commit is contained in:
Manuel Cortez 2015-08-12 16:43:23 -05:00
parent 704ade560a
commit 34ad0c5e47
2 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/controller/mainController.py
View File

@ -125,7 +125,7 @@ class Controller(object):
log.debug("Binding other application events...") log.debug("Binding other application events...")
pub.subscribe(self.logout_account, "logout") pub.subscribe(self.logout_account, "logout")
pub.subscribe(self.login_account, "login") pub.subscribe(self.login_account, "login")
pub.subscribe(self.manage_stream_errors, "stream-error") pub.subscribe(self.manage_stream_errors, "streamError")
pub.subscribe(self.create_new_buffer, "create-new-buffer") pub.subscribe(self.create_new_buffer, "create-new-buffer")
pub.subscribe(self.restart_streams, "restart-streams") pub.subscribe(self.restart_streams, "restart-streams")
@ -1204,7 +1204,7 @@ class Controller(object):
session.start_streaming() session.start_streaming()
def manage_stream_errors(self, session): def manage_stream_errors(self, session):
log.error("An error ocurred with the stream for the %s session. It will be destroyed" % (session,)) log.debug(" Restarting %s session streams. It will be destroyed" % (session,))
s = session_.sessions[session] s = session_.sessions[session]
for i in self.buffers: for i in self.buffers:
if i.invisible == True and i.session.session_id == s.session_id: if i.invisible == True and i.session.session_id == s.session_id:

1
src/sessionmanager/session.py
View File

@ -344,6 +344,7 @@ class Session(object):
self.logged = False self.logged = False
self.twitter = twitter.twitter.twitter() self.twitter = twitter.twitter.twitter()
self.login(False) self.login(False)
pub.sendMessage("streamError", session=self.session_id)
if self.reconnection_function_active == True: return if self.reconnection_function_active == True: return
self.reconnection_function_active = True self.reconnection_function_active = True
if not hasattr(self, "main_stream"): if not hasattr(self, "main_stream"):