Add force_verify to adapters.

PythonistaGuild · Mar 18, 2024 · 7dd3246 · 7dd3246
1 parent 7f7716a
commit 7dd3246
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 2 deletions.
diff --git a/twitchio/client.py b/twitchio/client.py
@@ -32,7 +32,6 @@
 from twitchio.http import HTTPAsyncIterator
 
 from .authentication import ManagedHTTPClient, Scopes
-from .payloads import EventErrorPayload
 from .models import (
     ChannelInfo,
     ChatterColor,
@@ -45,7 +44,7 @@
     Stream,
     Team,
 )
-
+from .payloads import EventErrorPayload
 from .web import AiohttpAdapter, WebAdapter
 
 

diff --git a/twitchio/web/adapters.py b/twitchio/web/adapters.py
@@ -127,6 +127,8 @@ async def oauth_callback(self, request: Request) -> Response:
 
     async def oauth_redirect(self, request: Request) -> Response:
         scopes: str | None = request.query_params.get("scopes", None)
+        force_verify: bool = request.query_params.get("force_verify", "false").lower() == "true"
+
         if not scopes:
             scopes = str(self.client._http.scopes) if self.client._http.scopes else None
 
@@ -143,6 +145,7 @@ async def oauth_redirect(self, request: Request) -> Response:
             payload: AuthorizationURLPayload = self.client._http.get_authorization_url(
                 scopes=scopes_,
                 redirect_uri=self._redirect_uri,
+                force_verify=force_verify,
             )
         except Exception as e:
             logger.error(
@@ -231,6 +234,8 @@ async def oauth_callback(self, request: web.Request) -> web.Response:
 
     async def oauth_redirect(self, request: web.Request) -> web.Response:
         scopes: str | None = request.query.get("scopes", None)
+        force_verify: bool = request.query.get("force_verify", "false").lower() == "true"
+
         if not scopes:
             scopes = str(self.client._http.scopes) if self.client._http.scopes else None
 
@@ -247,6 +252,7 @@ async def oauth_redirect(self, request: web.Request) -> web.Response:
             payload: AuthorizationURLPayload = self.client._http.get_authorization_url(
                 scopes=scopes_,
                 redirect_uri=self._redirect_uri,
+                force_verify=force_verify,
             )
         except Exception as e:
             logger.error(