From b877357e60f633a358d0a4d201d7adf590a980a8 Mon Sep 17 00:00:00 2001 From: Harmon Date: Sun, 24 Jan 2021 07:27:46 -0600 Subject: [PATCH] Log by default in StreamListener methods --- tweepy/streaming.py | 25 +++++++++++++------------ 1 file changed, 13 insertions(+), 12 deletions(-) diff --git a/tweepy/streaming.py b/tweepy/streaming.py index 0d5e74c..7e5e872 100644 --- a/tweepy/streaming.py +++ b/tweepy/streaming.py @@ -34,7 +34,7 @@ class StreamListener: is received from the server. Allows the listener to perform some work prior to entering the read loop. """ - pass + log.info("Stream connected") def on_data(self, raw_data): """Called when raw data is received from connection. @@ -67,31 +67,32 @@ class StreamListener: def on_keep_alive(self): """Called when a keep-alive arrived""" - return + log.debug("Received keep-alive signal") def on_status(self, status): """Called when a new status arrives""" - return + log.debug("Received status: %d", status.id) def on_exception(self, exception): """Called when an unhandled exception occurs.""" - return + log.exception("Stream encountered an exception") def on_delete(self, status_id, user_id): """Called when a delete notice arrives for a status""" - return + log.debug("Received status deletion notice: %d", status_id) def on_limit(self, track): """Called when a limitation notice arrives""" - return + log.debug("Received limit notice: %d", track) def on_request_error(self, status_code): """Called when a non-200 status code is returned""" + log.error("Stream encountered HTTP error: %d", status_code) return False def on_connection_error(self): """Called when stream connection errors or times out""" - return + log.error("Stream connection has errored or timed out") def on_disconnect(self, notice): """Called when twitter sends a disconnect notice @@ -99,23 +100,23 @@ class StreamListener: Disconnect codes are listed here: https://developer.twitter.com/en/docs/tweets/filter-realtime/guides/streaming-message-types """ - return + log.warning("Received disconnect message: %s", notice) def on_warning(self, notice): """Called when a disconnection warning message arrives""" - return + log.warning("Received stall warning: %s", notice) def on_scrub_geo(self, notice): """Called when a location deletion notice arrives""" - return + log.debug("Received location deletion notice: %s", notice) def on_status_withheld(self, notice): """Called when a status withheld content notice arrives""" - return + log.debug("Received status withheld content notice: %s", notice) def on_user_withheld(self, notice): """Called when a user withheld content notice arrives""" - return + log.debug("Received user withheld content notice: %s", notice) class Stream: -- 2.25.1