From 581ef4f226be9888955fa8d100cc885176b891ca Mon Sep 17 00:00:00 2001 From: Jonathan Zernik Date: Sun, 7 Nov 2021 02:47:09 -0800 Subject: [PATCH] Change print to log for lines in twitter stream class (#1784) --- squeaknode/twitter/twitter_stream.py | 12 ++++++++---- 1 file changed, 8 insertions(+), 4 deletions(-) diff --git a/squeaknode/twitter/twitter_stream.py b/squeaknode/twitter/twitter_stream.py index e75b567e..c1aff292 100644 --- a/squeaknode/twitter/twitter_stream.py +++ b/squeaknode/twitter/twitter_stream.py @@ -20,6 +20,7 @@ # OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE # SOFTWARE. import json +import logging from typing import List import requests @@ -27,6 +28,9 @@ import requests from squeaknode.core.tweet_stream import TweetStream +logger = logging.getLogger(__name__) + + class TwitterStream: twitter_stream_url = "https://api.twitter.com/2/tweets/search/stream" @@ -64,7 +68,7 @@ class TwitterStream: "Cannot get rules (HTTP {}): {}".format( response.status_code, response.text) ) - print(json.dumps(response.json())) + logger.info(json.dumps(response.json())) return response.json() def delete_all_rules(self, rules): @@ -84,7 +88,7 @@ class TwitterStream: response.status_code, response.text ) ) - print(json.dumps(response.json())) + logger.info(json.dumps(response.json())) def set_rules(self, delete): sample_rules = [ @@ -102,7 +106,7 @@ class TwitterStream: "Cannot add rules (HTTP {}): {}".format( response.status_code, response.text) ) - print(json.dumps(response.json())) + logger.info(json.dumps(response.json())) def get_stream(self, set) -> TweetStream: response = requests.get( @@ -110,7 +114,7 @@ class TwitterStream: auth=self.bearer_oauth_fn, stream=True, ) - print(response.status_code) + logger.info(response.status_code) if response.status_code != 200: raise Exception( "Cannot get stream (HTTP {}): {}".format(