Merlijn van Deen has uploaded a new change for review.
https://gerrit.wikimedia.org/r/185200
Change subject: RCStream: return heartbeats and handle on_reconnect
......................................................................
RCStream: return heartbeats and handle on_reconnect
Bug: T85717
Change-Id: I20b02488bd9302a3ed8846b344c870eb6763e651
---
M pywikibot/comms/rcstream.py
1 file changed, 10 insertions(+), 0 deletions(-)
git pull ssh://gerrit.wikimedia.org:29418/pywikibot/core
refs/changes/00/185200/1
diff --git a/pywikibot/comms/rcstream.py b/pywikibot/comms/rcstream.py
index 7b4ea73..8ba75a5 100644
--- a/pywikibot/comms/rcstream.py
+++ b/pywikibot/comms/rcstream.py
@@ -21,6 +21,8 @@
_logger = 'pywikibot.rcstream'
+import logging
+logging.basicConfig(level=logging.DEBUG)
class RcListenerThread(threading.Thread):
@@ -75,6 +77,8 @@
self.count = 0
import socketIO_client
+ socketIO_client.BaseNamespace.on_heartbeat = lambda self:
self._transport.send_heartbeat()
+
debug('Opening connection to %r' % self, _logger)
self.client = socketIO_client.SocketIO(rchost, rcport)
@@ -98,11 +102,17 @@
return
def on_connect(self):
+ print self._callback_by_event,
self._find_event_callback('heartbeat')
debug('Connected to %r; subscribing to %s'
% (thread, thread.wikihost),
_logger)
self.emit('subscribe', thread.wikihost)
debug('Subscribed to %s' % thread.wikihost, _logger)
+ self.on_heartbeat()
+
+ def on_reconnect(self):
+ debug('Reconnected to %r' % (thread,), _logger)
+ self.on_connect()
self.client.define(RCListener, rcpath)
--
To view, visit https://gerrit.wikimedia.org/r/185200
To unsubscribe, visit https://gerrit.wikimedia.org/r/settings
Gerrit-MessageType: newchange
Gerrit-Change-Id: I20b02488bd9302a3ed8846b344c870eb6763e651
Gerrit-PatchSet: 1
Gerrit-Project: pywikibot/core
Gerrit-Branch: master
Gerrit-Owner: Merlijn van Deen <[email protected]>
_______________________________________________
MediaWiki-commits mailing list
[email protected]
https://lists.wikimedia.org/mailman/listinfo/mediawiki-commits
