1515# specific language governing permissions and limitations
1616# under the License.
1717from dataclasses import fields
18+
1819import trio
20+
1921from selenium .webdriver .common .bidi import network
20- from selenium .webdriver .common .bidi .browsing_context import Navigate , NavigateParameters
21- from selenium .webdriver .common .bidi .network import (
22- AddInterceptParameters ,
23- BeforeRequestSent ,
24- BeforeRequestSentParameters ,
25- ContinueRequestParameters ,
26- )
22+ from selenium .webdriver .common .bidi .browsing_context import Navigate
23+ from selenium .webdriver .common .bidi .browsing_context import NavigateParameters
24+ from selenium .webdriver .common .bidi .network import AddInterceptParameters
25+ from selenium .webdriver .common .bidi .network import BeforeRequestSent
26+ from selenium .webdriver .common .bidi .network import BeforeRequestSentParameters
27+ from selenium .webdriver .common .bidi .network import ContinueRequestParameters
2728
2829
2930def default_request_handler (params : BeforeRequestSentParameters ):
@@ -37,13 +38,17 @@ def __init__(self, driver):
3738 self .intercept = None
3839 self .scope = None
3940
40- async def add_request_handler (self , request_filter = lambda _ : True , handler = default_request_handler , conn = None ):
41+ async def add_request_handler (
42+ self , request_filter = lambda _ : True , handler = default_request_handler , conn = None
43+ ):
4144 with trio .CancelScope () as scope :
4245 self .scope = scope
4346 self .network = network .Network (conn )
4447 params = AddInterceptParameters (["beforeRequestSent" ])
4548 callback = self ._callback (request_filter , handler )
46- result = await self .network .add_intercept (event = BeforeRequestSent , params = params )
49+ result = await self .network .add_intercept (
50+ event = BeforeRequestSent , params = params
51+ )
4752 intercept = result ["intercept" ]
4853 self .intercept = intercept
4954 await self .network .add_listener (event = BeforeRequestSent , callback = callback )
@@ -54,7 +59,10 @@ async def get(self, url, conn):
5459 await conn .execute (Navigate (params ).cmd ())
5560
5661 async def remove_request_handler (self ):
57- await self .network .remove_intercept (event = BeforeRequestSent , params = network .RemoveInterceptParameters (self .intercept ))
62+ await self .network .remove_intercept (
63+ event = BeforeRequestSent ,
64+ params = network .RemoveInterceptParameters (self .intercept ),
65+ )
5866 self .scope .cancel ()
5967
6068 def _callback (self , request_filter , handler ):
0 commit comments