[hY SrSSKrSSKrSSKrSSKrSSKrSSKrSSKrSSKrSSK r SSK J r J r SSK Jr SSKJrJrJrJrJrJrJrJrJrJrJr SSKJrJr SSKJr SSK J!r!J"r" SS K#J$r$ SSK%r%SS K&J'r'J(r(J)r) S S K*J+r+J,r, S S K J-r- S SK.J/r/ S SK0J1r1 S SK2J3r3 S SK4J5r5J6r6 S SK7J8r8J9r9 S SK:J;r; S SKr>J?r?J@r@JArAJBrBJCrCJDrDJErE S SKFJGrG \(aSSKHJIrI OSrI\RS:a \(aSSKJKrK \RS:aSSKJLrL O\rL\"S\=S5rM\"S\?S9rN\RS:H=(a \RS:grQ\R4S\SS \RS!\R4S"jjrUS\SS#\VS \RS!\R4S$jrWS!\V4S%jrX"S&S'\ 5rY"S(S)\Y5rZ"S*S+\Y5r["S,S-\\N\M45r\"S.S/\5r]S0\S1\S2\S!\4S3jr^\/\R4r`\R\RS44S5\`S6\cS!\\R4S7jj5rd\R4S5\`S!\R4S8jjreSQS9\RS6\cS!S4S:jjrfS!\R4S;jrhSRS<\\IS!\R4S=jjrjSR\3\5"S S 5S4S\3\3\3\8SS>S?S@. SA\SSB\SSC\SD\SE\5SF\cSG\SH\SI\SJ\SK\9S<\\ISL\VS9\S!\A4SMjjjrk\3\34SN\SO\S!\4SPjjrlg)SzUtilities shared by tests.N)ABCabstractmethod) TracebackType) TYPE_CHECKINGAnyCallableGenericIteratorListOptionalTypeTypeVarcastoverload)IsolatedAsyncioTestCasemock)Signal) CIMultiDictCIMultiDictProxy)URL)_RequestContextManager_RequestOptions_WSRequestContextManager) ClientSessionhdrs)AbstractCookieJar)ClientResponse)ClientWebSocketResponse)sentinel) HttpVersionRawRequestMessage) EMPTY_PAYLOAD StreamReader)StrOrURL) Application AppRunner BaseRequest BaseRunnerRequestServer ServerRunnerSockSiteUrlMappingMatchInfo)_RequestHandler) SSLContext )Unpack)Self_ApplicationNone_Request)boundposixcygwinhostfamilyreturnc[USU5$)Nr)get_port_socket)r;r<s a/home/gothic/public_html/Fooocus/fooocus_env/lib64/python3.13/site-packages/aiohttp/test_utils.pyget_unused_port_socketrAPs 4F ++portc[R"U[R5n[(a/UR[R[R S5 UR X45 U$)Nr)socket SOCK_STREAM REUSE_ADDRESS setsockopt SOL_SOCKET SO_REUSEADDRbind)r;rCr<ss r@r?r?VsP  ff001A} V&&(;(;Q?FFD< HrBc[R"[R[R5nURS5 [ [ UR 5S5sSSS5 $!,(df  g=f)z1Return a port that is unused on the current host.) 127.0.0.1rrN)rEAF_INETrFrKrint getsockname)rLs r@ unused_portrRcsJ v~~v'9'9 :a  C+, ; : :s 2A00 A>c\rSrSrSrSSSSS\S.S\S\\RS \S \\ S \ S \ \\ \ R/\ R4S \SS4SjjrS S\\RS \SS4Sjjr\S \S\4Sj5rS\S\4Sjr\S\ 4Sj5r\S\ 4Sj5r\S\4Sj5rS!SjrS!SjrS\\\ S\\ S\\!SS4Sjr"S"Sjr#S\\\ S\\ S\\!SS4Sjr$Sr%g)#BaseTestServerjFNrN)schemeloopr;rCskip_url_assertssocket_factoryrWrXr;rCrYrZkwargsr=c vX lSUlSUlX0lX@lSUlXlXPlX`lg)NF) _looprunner_rootr;rC_closedrWrYrZ)selfrWrXr;rCrYrZr[s r@__init__BaseTestServer.__init__ms9 ,0 $(     0,rBc^# UR(agXlURSS5UlUR"SSS0UD6IShvN UlURR 5IShvN UR (dSUlURn[R"UR5RnUS:XaSURS3nUS:Xa[RO[RnURURUR U5nUR!5SS uUlUl[#URX`RS 9nUR%5IShvN UR&nUceUR(n U ceU SR!5S UlUR*(dUR(aS OS Ul[-UR*SUSUR 35UlgGNGN![a SnGNcf=fN7f)Nsslhandler_cancellationTr[])sock ssl_contextrhttpshttpz://:)r^r]pop_ssl _make_runnersetuprCr; ipaddress ip_addressversion ValueErrorrEAF_INET6rOrZrQr-start_serversocketsrWrr_) rarXr[ absolute_hostrxr<_socksiteserverr}s r@ start_serverBaseTestServer.start_servers ;;  JJud+  --R4R6RR kk!!!yyDI  **4995==G a< {!,M$+qLfnn##DIItyy&A$0022A6 49 %YYGjjl!!!.."""AJ**,Q/ {{%)YY'FDKDKK=M?!DII;GH /S!  G  sVAH- H &H-0H1(H-*HB4H-8H+9BH-H- H($H-'H((H-c # g7fNrqrar[s r@rtBaseTestServer._make_runners spathcURce[U5nUR(d.UR(aeURR U5$[[ UR5[ U5-5$r)r_rrYabsolutejoinstr)rarurls r@make_urlBaseTestServer.make_urls`zz%%%$i$$|| ##::??3' 's4::T23 3rBcURSL$r)r^ras r@startedBaseTestServer.starteds{{$&&rBcUR$r)r`rs r@closedBaseTestServer.closed ||rBcZURnUceURceUR$r)r^r)rar^s r@handlerBaseTestServer.handlers3!!!}}(((}}rBc# UR(aYUR(dGURceURR5IShvN SUlSUlSUlgggN7f)a0Close all fixtures created by the test client. After that point, the TestClient is no longer usable. This is an idempotent function: running close multiple times will not have any additional effects. close is also run when the object is garbage collected, and on exit when used as a context manager. NT)rrr^cleanupr_rCr`rs r@closeBaseTestServer.closesY << ;;* **++%%' ' 'DJDIDL !,< 'sAA0A.A0c[S5eNzUse async with instead TypeErrorrs r@ __enter__BaseTestServer.__enter__011rBexc_type exc_value tracebackcgrrqrarrrs r@__exit__BaseTestServer.__exit__ rBcT# URURS9IShvN U$N7fNrX)rr]rs r@ __aenter__BaseTestServer.__aenter__s*TZZ000  1s (&(c@# UR5IShvN gN7frrrs r@ __aexit__BaseTestServer.__aexit__ jjl ) r`r]r_rsr;rCr^rWrYrZrr=N)r=rT)&__name__ __module__ __qualname____firstlineno____test__r?rr asyncioAbstractEventLooprPboolrrE AddressFamilyrrbrrr)rtr%rrpropertyrrr+rrrr BaseExceptionrrrr__static_attributes__rqrBr@rTrTjsH 48"!& --w001 -  - sm --! #v++ ,fmm ; -- -0;?IW667IJMI I@ 3 :  4X4#4''' &2 4 ./ M* M*    4 ./M*M*   rBrTc d^\rSrSrSSSS.S\S\S\S \\S \4 U4S jjjr S \S \ 4S jr Sr U=r $) TestServerrVrNNrWr;rCapprWr;rCr[c 8>Xl[TU]"SX#US.UD6 gNrrq)rsuperrb)rarrWr;rCr[ __class__s r@rbTestServer.__init__s! GGGrBr=c6# [UR40UD6$7fr)r'rrs r@rtTestServer._make_runners,V,,s)r)rrrrr&rr rPrrbr)rtr __classcell__rs@r@rrsk " H  H H  H sm H H H-3-:--rBrc p^\rSrSrSSSS.S\S\S\S \\S \S S4 U4S jjjr SS \ S \S \ 4Sjjr Sr U=r$) RawTestServerrVrNNrrrWr;rCr[r=c 8>Xl[TU]"SX#US.UD6 gr)_handlerrrb)rarrWr;rCr[rs r@rbRawTestServer.__init__s!  GGGrBdebugcl# [UR4URUS.UD6n[U4SU0UD6$7f)N)rXrr)r+rr]r,)rarr[srvs r@rtRawTestServer._make_runner s8T]]K5KFKC7u777s24)r)T)rrrrr/rr rPrrbrr,rtrrrs@r@rrs} " H  H H  H sm H H  H H88s8|88rBrc \rSrSrSrSr\SS.SSS\S \\ S \ S S4 S jj5r \SS.SS S\ S \\ S \ S S4 Sjj5r SSS.S\ S \\ S\\ RS \ S S4 Sjjr S8Sjr\S \4Sj5r\S \\4Sj5r\S \ 4Sj5r\S \4Sj5r\S \4Sj5rS\S \4SjrS\S\S \ S \4Sjr\R@S:az\!(asS\S\S \"\#S \$4Sjr%S\S \"\#S \$4Sjr&S\S \"\#S \$4Sjr'S\S \"\#S \$4S jr(S\S \"\#S \$4S!jr)S\S \"\#S \$4S"jr*S\S \"\#S \$4S#jr+S\S \"\#S \$4S$jr,OZS\S\S \ S \$4S%jr%S\S \ S \$4S&jr&S\S \ S \$4S'jr)S\S \ S \$4S(jr'S\S \ S \$4S)jr(S\S \ S \$4S*jr*S\S \ S \$4S+jr+S\S \ S \$4S,jr,S\S \ S \-4S-jr.S\S \ S \/4S.jr0S8S/jr1S8S0jr2S1\\3\4S2\\4S3\\5S S4S4jr6S \74S5jr8S1\\3\4S2\\4S3\\5S S4S6jr9S7r:g)9 TestClientizV A test client implementation. To write functional tests for aiohttp based servers. FN) cookie_jarraz TestClient[Request, Application]rrr[r=c grrqrarrr[s r@rbTestClient.__init__rBzTestClient[_Request, None]c grrqrs r@rbr#rrB)rrXrXc [U[5(d[S[U5-5eXlX0lUc[ R"SUS9n[SX2S.UD6Ul SURl SUl /Ul /Ul g)Nz2server must be TestServer instance, found type: %rT)unsaferX)rXrFrq) isinstancerTrtyper|r]aiohttp CookieJarr_session_retry_connectionr` _responses _websockets)rarrrXr[s r@rbr+s&.11DtF|S     **$TBJ%Q4Q&Q */ ' 02:<rBcf# URRURS9IShvN gN7fr)r|rr]rs r@rTestClient.start_serverAs$ll''TZZ'888s '1/1c.URR$r)r|r;rs r@r;TestClient.hostD||   rBc.URR$r)r|rCrs r@rCTestClient.portHrrBcUR$r)r|rs r@rTestClient.serverLrrBc0[URSS5$)Nr)getattrr|rs r@rTestClient.appPst||UD11rBcUR$)zAn internal aiohttp.ClientSession. Unlike the methods on the TestClient, client session requests do not automatically include the host in the url queried, and will require an absolute path to the resource. )rrs r@sessionTestClient.sessionTs}}rBrc8URRU5$r)r|r)rars r@rTestClient.make_url_s||$$T**rBmethodc# URR"XRU540UD6IShvN nURR U5 U$N!7fr)rrequestrrappend)rarrr[resps r@_requestTestClient._requestbsI]]**6==3FQ&QQ t$ R0AA"Ar1c grrqrarrr[s r@rTestClient.requestls%(rBc grrqrarr[s r@getTestClient.getp&)rBc grrqr s r@optionsTestClient.optionsvrrBc grrqr s r@headTestClient.head|rrBc grrqr s r@postTestClient.postrrBc grrqr s r@putTestClient.putrrBc grrqr s r@patchTestClient.patchrrBc grrqr s r@deleteTestClient.deleterrBc :[UR"X40UD65$)zRoutes a request to tested http server. The interface is identical to aiohttp.ClientSession.request, except the loop kwarg is overridden by the instance used by the test server. )rrr s r@rr s*$--*O*OP PrBc X[UR"[RU40UD65$)zPerform an HTTP GET request.)rrrMETH_GETr s r@rr!)$-- t*Vv*VW WrBc X[UR"[RU40UD65$)zPerform an HTTP POST request.)rrr METH_POSTr s r@rr")$--*WPV*WX XrBc X[UR"[RU40UD65$)z Perform an HTTP OPTIONS request.)rrr METH_OPTIONSr s r@rrs() d//@@ rBc X[UR"[RU40UD65$)zPerform an HTTP HEAD request.)rrr METH_HEADr s r@rrr)rBc X[UR"[RU40UD65$)zPerform an HTTP PUT request.)rrrMETH_PUTr s r@rrr&rBc X[UR"[RU40UD65$zPerform an HTTP PATCH request.)rrr METH_PATCHr s r@rrs&) doot>v> rBc X[UR"[RU40UD65$r1)rrr METH_DELETEr s r@r!r"s() d..?? rBc :[UR"U40UD65$)zZInitiate websocket connection. The api corresponds to aiohttp.ClientSession.ws_connect. )r _ws_connectr s r@ ws_connectTestClient.ws_connects ((8(8(H(HIIrBc# URR"URU540UD6IShvN nURR U5 U$N!7fr)rr7rrr)rarr[wss r@r6TestClient._ws_connectsK==++DMM$,?J6J J # Krcn# UR(dURHnUR5 M URHnUR5IShvN M URR5IShvN UR R5IShvN SUlggNUN1N7f)aClose all fixtures created by the test client. After that point, the TestClient is no longer usable. This is an idempotent function: running close multiple times will not have any additional effects. close is also run on exit when used as a(n) (asynchronous) context manager. NT)r`rrrrr|)rarr:s r@rTestClient.closes|| (&&hhj  '--%%' ' ',,$$& & &DL! ' &s6AB5B/%B5?B1!B5!B3"B51B53B5c[S5errrs r@rTestClient.__enter__rrBrexctbcgrrqrarr@rAs r@rTestClient.__exit__rrBcB# UR5IShvN U$N7fr)rrs r@rTestClient.__aenter__s!!!!  "s c@# UR5IShvN gN7frrrCs r@rTestClient.__aexit__rr)r`r]rr|rrr);rrrr__doc__rrrr rrrbrTrrrrrr;rPrCrr6rrrr%rrrrsys version_inforr4rrrrrrrrrr!rr7rr6rrr rrrr5rrrrqrBr@rrsH 37 0./      37 *./     3748 ==./ = w001 =  = =,9!c!!!hsm!!2%22+X+#+!)58  7"} ) )%- )9?9P ) # ) ) )_- )$  )  ) )_- )$  )  ) )_- )$  )  ) )_- )$  )  ) )_- )$  )  ) )_- )$  )  ) )_- )$  ) Q Q%- Q9< Q # Q XH X X8N X YX Y Y9O Y  C # UR5IShvN $N7fr) tearDownAsyncrs r@ asyncTearDownAioHTTPTestCase.asyncTearDown1s''))))s cT# URR5IShvN gN7fr)r]rrs r@r`AioHTTPTestCase.tearDownAsync4skk!!!s (&(rc0# [XRS9$7f)zReturn a TestServer instance.r)rrX)rars r@r[AioHTTPTestCase.get_server7s#II..rc0# [XRS9$7f)zReturn a TestClient instance.r)rrX)rars r@r\AioHTTPTestCase.get_client;s&yy11rg)rr]rXrr)rrrrrIr&rPrOrXrWrar`rr[rr*r\rrqrBr@rMrMse {JJ')*"/K/J/2z2j+AU6V2rBrMfuncargsr[c:[R"S[SS9 U$)zk A decorator dedicated to use with asynchronous AioHTTPTestCase test methods. In 3.8+, this does nothing. zBDecorator `@unittest_run_loop` is no longer needed in aiohttp 3.8+rk) stacklevel)warningswarnDeprecationWarning)rjrkr[s r@unittest_run_looprq@s  MML KrBF loop_factoryfastc#<# [U5nUv [X!S9 g7f)zrA contextmanager that creates an event_loop, for test purposes. Handles the creation and cleanup of a test loop. )rsN)setup_test_loopteardown_test_loop)rrrsrXs r@ loop_contextrwQs < (D Jt'sc@U"5n[R"U5 U$)zCreate and return an asyncio.BaseEventLoop instance. The caller should also call teardown_test_loop, once they are done with the loop. )rset_event_loop)rrrXs r@ruru^s >D 4 KrBrXc UR5nU(d;URUR5 UR5 UR 5 U(d[ R "5 [R"S5 g)z>Teardown and cleanup an event_loop created by setup_test_loop.N) is_closed call_soonstop run_foreverrgccollectrry)rXrsrs r@rvrvksP ^^ F  tyy!    4 rBcS[S[S[4SjnS[S[S[SS4Sjn[R"[S9n0UlXlXlSUl[U5Ul URR5 U$) Nrkeyr=c URU$r __app_dict)rrs r@get_dict"_create_app_mock..get_dictzs~~c""rBvaluec X RU'grr)rrrs r@set_dict"_create_app_mock..set_dict}s#srB)specF) rrr MagicMockr&r __getitem__ __setitem___debugron_response_preparefreeze)rrrs r@_create_app_mockrys#c###$c$$C$D$ ..k *CCNOOCJ$SkC""$ JrB sslcontextc^[R"5nS[S[[4U4SjjnX!R lU$)Nrr=c>US:XaT$g)Nrrq)rrs r@get_extra_info)_create_transport..get_extra_infos ,  rB)rMockrr r0r side_effect)r transportrs` r@_create_transportrs: ICHZ$8 ,:( rBi.) match_inforxclosingrwriterprotocolrpayloadrclient_max_sizerXrrheadersrrxrrrrrrrc [R"5nU SLa[R"5n U[SS5:aSnU(a5[[U55n[SUR555nO[[55nSnSUR[RS5R5;n[!UUUUUUSS U[#U55 nUc [%5nU [&La [)U 5n U[&Lan[R"5nXl[R,"U R/S 5S 9[1U5l[R,"U S 9[1U5lU[&La[[R"5n[7S5Ul[7S5Ul[7S5Ul[7S5UlXlXlXxl [CUXX~XS 9n[EU[&La0OU[R"55nURGU5 UUl$U$![a* [R"5n SU R lGN&make_mocked_request..s, ?NtqQXXg  1 2s13chunkedrVNFpeername) return_value)r)%rrrrVrS create_futurerr!rrtupleitemsrrTRANSFER_ENCODINGlowerr"rrr rr PropertyMockrrrrmmake_mocked_coro write_headerswrite write_eofdrainrr*r.add_app _match_info)rrrrrxrrrrrrrrrXtaskraw_hdrsrmessagereqs r@make_mocked_requestrs, 99;D s{  1++-D Q""";w#78 ?F}}  #;=17;;t'='=rBHHJJG    D  G { H%j1 899;&"&"3"3"11*=# X&*%6%6J%OX" /5'- +D1'- $"O F$ C%H$*diikJs CO JC 199;D.0D   + 1sH::0I.-I.rraise_exceptioncd^^S[S[S[4UU4Sjjn[R"US9$)zCreates a coroutine mock.rkr[r=cv># T[LaTe[R"T5(dT$TIShvN gN7fr)r inspect isawaitable)rkr[rrs r@ mock_coro#make_mocked_coro..mock_coros4 ( *! !""<00 s .979)wraps)rrr)rrrs`` r@rrs3 scc 999 %%rB)Fr)mrIr contextlibrrrvosrErJrnabcrrtypesrtypingrrrr r r r r rrrunittestrr aiosignalr multidictrryarlrraiohttp.clientrrrrVrrr client_reqrepr client_wsrhelpersr ror!r"streamsr#r$typedefsr%webr&r'r(r)r*r+r,r-r. web_protocolr/rer0rKr4r5r6r7nameplatformrGrOrrrArPr?rRrTrrrrMrqr _LOOP_FACTORYcontextmanagernew_event_looprrwrurvrrrrrrrqrBr@rs   #    33 "").00   *Jw=w D-{DA :[ 17"?s||x'? /5nn, ,++, ]],      "("6"6   ]]  -S-ASAH--"8N8$s#334sl62-62r C  s s W6667  ")"8"8u ( (@D ( g''( ( (#*"8"8     !W66 !d !t !$..$ (:"6 $))  _ &q!,)'+"_ _ __  _  __ _ ____$__ _  !_F! & &36 & &rB