From a4c632530e6783a6a899947c7ec32d78b55fc3c6 Mon Sep 17 00:00:00 2001 From: Harmon Date: Tue, 4 Oct 2022 15:06:14 -0500 Subject: [PATCH] Change AsyncBaseStream._connect oauth_1 parameter to oauth_client --- tweepy/asynchronous/streaming.py | 13 ++++++------- 1 file changed, 6 insertions(+), 7 deletions(-) diff --git a/tweepy/asynchronous/streaming.py b/tweepy/asynchronous/streaming.py index 530179c..7a19d44 100644 --- a/tweepy/asynchronous/streaming.py +++ b/tweepy/asynchronous/streaming.py @@ -38,7 +38,8 @@ class AsyncBaseStream: ) async def _connect( - self, method, url, params=None, headers=None, body=None, oauth_1=False + self, method, url, params=None, headers=None, body=None, + oauth_client=None ): error_count = 0 # https://developer.twitter.com/en/docs/twitter-api/v1/tweets/filter-realtime/guides/connecting @@ -60,11 +61,7 @@ class AsyncBaseStream: try: while error_count <= self.max_retries: try: - if oauth_1: - oauth_client = OAuthClient( - self.consumer_key, self.consumer_secret, - self.access_token, self.access_token_secret - ) + if oauth_client: url, headers, body = oauth_client.sign( url, http_method=method, headers=headers, body=body ) @@ -256,10 +253,12 @@ class AsyncStream(AsyncBaseStream): async def _connect( self, method, endpoint, params={}, headers=None, body=None ): + oauth_client = OAuthClient(self.consumer_key, self.consumer_secret, + self.access_token, self.access_token_secret) url = f"https://stream.twitter.com/1.1/{endpoint}.json" url = str(URL(url).with_query(sorted(params.items()))) await super()._connect( - method, url, headers=headers, body=body, oauth_1=True + method, url, headers=headers, body=body, oauth_client=oauth_client ) def filter(self, *, follow=None, track=None, locations=None, -- 2.25.1