ping the server to trigger reconnect on WS fail
This commit is contained in:
parent
82106deeaa
commit
fa6e0e1c77
1 changed files with 9 additions and 0 deletions
|
@ -19,6 +19,7 @@ def dbg(debug_string):
|
||||||
|
|
||||||
class RtmBot(object):
|
class RtmBot(object):
|
||||||
def __init__(self, token):
|
def __init__(self, token):
|
||||||
|
self.last_ping = 0
|
||||||
self.token = token
|
self.token = token
|
||||||
self.bot_plugins = []
|
self.bot_plugins = []
|
||||||
self.slack_client = None
|
self.slack_client = None
|
||||||
|
@ -34,7 +35,15 @@ class RtmBot(object):
|
||||||
self.input(reply)
|
self.input(reply)
|
||||||
self.crons()
|
self.crons()
|
||||||
self.output()
|
self.output()
|
||||||
|
self.autoping()
|
||||||
time.sleep(.1)
|
time.sleep(.1)
|
||||||
|
def autoping(self):
|
||||||
|
#hardcode the interval to 3 seconds
|
||||||
|
now = int(time.time())
|
||||||
|
if now > self.last_ping + 3:
|
||||||
|
print 'ping'
|
||||||
|
self.slack_client.server.ping()
|
||||||
|
self.last_ping = now
|
||||||
def input(self, data):
|
def input(self, data):
|
||||||
if "type" in data:
|
if "type" in data:
|
||||||
function_name = "process_" + data["type"]
|
function_name = "process_" + data["type"]
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue