fd| : d dl Z d dlZd dlZd dlmZmZ d dlmZmZm Z m
Z
m Z m Z m
Z
mZmZmZmZmZmZmZmZmZmZmZmZ d dlmZ d dl m Z ddl m Z ddl m!Z!m"Z"m#Z#m$Z$ dd l%m&Z&m'Z' dd
l(m)Z) dd l*m+Z+ dd l,m-Z- dd
l.m/Z/ ddl0m1Z1 ddl2m3Z3 ddl4m5Z5 ddl6m7Z7 ddl8m9Z9 ddl:m;Z; ddlm?Z? ddl@mAZAmBZBmCZCmDZDmEZEmFZFmGZG dZHerVee dge
d f ZIee e9e;ge
d f ZJe e/ ZKeeee/eLf ZMed ZNneZIeZJe ZKee ZMeZN ed ZO ed ZP G d deeeQe'e f ef ZR G d d eS ZTere e eRge d f ZUne ZU G d d eU ZVdS ) N)partialupdate_wrapper)
TYPE_CHECKINGAny
AsyncIterator AwaitableCallableDictIterableIteratorListMappingMutableMappingOptionalSequenceTupleTypeTypeVarUnioncastoverload)Signal)
FrozenList )hdrs)AbstractAccessLoggerAbstractMatchInfoAbstractRouterAbstractStreamWriter)DEBUGAppKey)RawRequestMessage)
web_logger) StreamReader)
Middleware)NotAppKeyWarning) AccessLogger)_fix_request_current_app)RequestHandler)Request)StreamResponse)AbstractRouteDef)Server)AbstractResource
AbstractRouteDomain
MaskDomainMatchedSubAppResourcePrefixedSubAppResource
UrlDispatcher) Application CleanupErrorr5 _T_Uc ^ e Zd Z eg d Zeddddddddej dee d e
e d
ee e
ef d ed eej d
eddfdZded ddfdZer de
deddf fd ZdedefdZedee de fd Z ede
defd Z de e
ee f defdZ dWdZ edee d e ddfd Z ede
d eddfd Z de e
ee f d eddfd Z de e
ee f ddfd Z!defd!Z"de#e e
ee f fd"Z$edXdee d#ddee fd$ Z%edee d#e&de e e&f fd% Z%edXde
d#edefd& Z%dYde e
ee f d#edefd'Z%e'dej fd( Z(d eej ddfd)Z)e'defd* Z*dWd+Z+e'defd, Z,dWd-Z-e'defd. Z.dZd0Z/d1e
d/d de0fd2Z1d3e2g e0f d/d de0fd4Z3d5e
d/d de0fd6Z4d7e
e5 de6e7 fd8Z8e'de9fd9 Z:e'de;fd: Ze'd[d> Z?e'de fd? Z@e'deAfd@ ZBdeCdAd eej dBeeD dCedeEfdDZFdeCdAd eej dBeeD dCedeEfdEZGdWdFZHdWdGZIdWdHZJeKfdIeLdJeMdKeNdLeOdMdNdOeeK deKfdPZPde#eQe ef fdQZRdReKdeSfdSZTd\dTZUde
fdUZVdefdVZW xZXS )]r5 )logger_debug_router_loop
_handler_args _middlewares_middlewares_handlers_run_middlewares_state_frozen _pre_frozen_subapps_on_response_prepare _on_startup _on_shutdown _on_cleanup_client_max_size _cleanup_ctxN i .)r: router middlewares handler_argsclient_max_sizeloopdebugr: rM rN rO rP rQ rR returnc @ |t }n t j dt d t |t
s
J | | t j dt d |dur t j dt d || _ || _ || _ || _ || _
t | | _ d | _
d | _ i | _ d| _ d| _ g | _ t' | | _ t' | | _ t' | | _ t' | | _ t1 | _ | j | j j | j | j j || _ d S )Nz router argument is deprecated
stacklevelzloop argument is deprecated.z debug argument is deprecatedF) r4 warningswarnDeprecationWarning
isinstancer r; r< r= r> r: r r? r@ rA rB rC rD rE r rF rG rH rI CleanupContextrK appendrJ )selfr: rM rN rO rP rQ rR s c/builddir/build/BUILD/cloudlinux-venv-1.0.10/venv/lib64/python3.11/site-packages/aiohttp/web_app.py__init__zApplication.__init__i s >"__FF M/1CPQ
&.11996991 M-/Aa
M.0Bq
&,
) *4[*A*A <@"04 =? "$
8>t !'-d||(.t '-d|| * , , 1 =>>> 1 =>>> / clsc n t j d | j t d d S )Nz8Inheritance class {} from web.Application is discouraged rV )rX rY format__name__rZ )rb s r_ __init_subclass__z Application.__init_subclass__ s?
#VCL 1 1
ra namevalc || j vr/t j d | t d t || d S )Nz:Setting custom web.Application.{} attribute is discouragedrU rV )ATTRSrX rY re rZ super __setattr__)r^ rh ri __class__s r_ rm zApplication.__setattr__ sa 4:%%
%%+VD\\&
GG c * * * * *ra otherc
| |u S NrL )r^ ro s r_ __eq__zApplication.__eq__ s u} ra keyc d S rq rL r^ rs s r_ __getitem__zApplication.__getitem__ ra c d S rq rL ru s r_ rv zApplication.__getitem__ rw ra c | j | S rq )rB ru s r_ rv zApplication.__getitem__ s {3 ra c P | j r t j dt d d S d S )Nz=Changing state of started or joined application is deprecatedrd rV )rC rX rY rZ r^ s r_
_check_frozenzApplication._check_frozen sB < MR"
ra valuec d S rq rL r^ rs r} s r_ __setitem__zApplication.__setitem__ rw ra c d S rq rL r s r_ r zApplication.__setitem__ rw ra c | t |t s t j dt
d || j |< d S )NzIt is recommended to use web.AppKey instances for keys.
https://docs.aiohttp.org/en/stable/web_advanced.html#application-s-configrU )categoryrW )r| r[ r! rX rY r& rB r s r_ r zApplication.__setitem__ s` #v&& M* *
! Cra c > | | j |= d S rq )r| rB ru s r_ __delitem__zApplication.__delitem__ s$ K ra c * t | j S rq )lenrB r{ s r_ __len__zApplication.__len__ s 4; ra c * t | j S rq )iterrB r{ s r_ __iter__zApplication.__iter__ s DK ra defaultc d S rq rL r^ rs r s r_ getzApplication.get rw ra c d S rq rL r s r_ r zApplication.get rw ra c d S rq rL r s r_ r zApplication.get rw ra c 8 | j || S rq )rB r r s r_ r zApplication.get s {sG,,,ra c x t j dt d t t j | j S )Nzloop property is deprecatedrU rV )rX rY rZ r asyncioAbstractEventLoopr= r{ s r_ rQ zApplication.loop s3
35GTUVVVVG-tz:::ra c |t j }| j | j |urt d || _ | j du r| | _ | j D ]}| | d S )Nz8web.Application instance initialized with different loop.)r get_event_loopr= RuntimeErrorr; get_debugrE _set_loop)r^ rQ subapps r_ r zApplication._set_loop s <)++D : !dj&<&< J
;# ..**DK m # #F T " " " " # #ra c | j S rq )rD r{ s r_
pre_frozenzApplication.pre_frozen ra c R | j rd S d| _ | j | j | j | j | j | j | j t |
| _ | j rdnd| _
| j D ])}| | j
p|j
| _
*d S )NTF)rD r? freezer< rF rK rG rH rI tuple_prepare_middlewarer@ rN rA rE
pre_freezer^ r s r_ r zApplication.pre_freeze s% F """ !((*** """ !!! """ !!!%*4+C+C+E+E%F%F" )-(8 Ce m U UF $($9$TV=TD ! ! U Ura c | j S rq )rC r{ s r_ frozenzApplication.frozen1
|ra c | j rd S | d| _ | j D ]}| d S NT)rC r rE r r s r_ r zApplication.freeze5 sR < F m F MMOOOO ra c H t j dt d | j S )Nz debug property is deprecatedrU rV )rX rY rZ r; r{ s r_ rR zApplication.debug> s$
46HUVWWWW{ra r c l dt dd f fd } |d |d |d d S )NsignamerS c t | dfd }t | }| | d S )Nappr5 rS c B K d {V d S rq )send)r r subsigs r_ handlerzEApplication._reg_subapp_signals..reg_handler..handlerG s1 kk&)))))))))))ra )r r5 rS N)getattrr] )r r appsigr r^ r s @r_ reg_handlerz4Application._reg_subapp_signals..reg_handlerD s_ VW--F
*
*
*
*
*
*
* T7++F MM' " " " " "ra
on_startup on_shutdown
on_cleanup)str)r^ r r s `` r_ _reg_subapp_signalsz Application._reg_subapp_signalsC sm # # # # # # # # # L!!! M""" L!!!!!ra prefixc t |t st d | d }|st d t t || }| || S )NzPrefix must be str/zPrefix cannot be empty)r[ r TypeErrorrstrip
ValueErrorr r3 _add_subapp)r^ r r factorys r_
add_subappzApplication.add_subappQ ss &#&& 2 011 1 s## 7 566 60&&AA 000ra resource_factoryc n | j rt d |j rt d | }| j | | | | j | | | j | | j |S )Nz0Cannot add sub application to frozen applicationz Cannot add frozen application)
r r rM register_resourcer rE r] r r= r )r^ r r resources r_ r zApplication._add_subappZ s ; S QRR R = @ >?? ?##%% %%h/// (((
V$$$ : ! TZ ( ( (ra domainc t |t st d d|v rt | }nt | }t t || }| || S )NzDomain must be str*)r[ r r r1 r0 r r2 r )r^ r r ruler s r_
add_domainzApplication.add_domainj sn &#&& " 011 1
F]]%f--DD&>>D/v>> 000ra routesc 6 | j | S rq )rM
add_routes)r^ r s r_ r zApplication.add_routest s {%%f---ra c | j S rq )rF r{ s r_ on_response_preparez Application.on_response_preparew s ((ra c | j S rq )rG r{ s r_ r zApplication.on_startup{ r ra c | j S rq )rH r{ s r_ r zApplication.on_shutdown ra c | j S rq )rI r{ s r_ r zApplication.on_cleanup r ra r\ c | j S rq )rK r{ s r_ cleanup_ctxzApplication.cleanup_ctx r ra c | j S rq )r< r{ s r_ rM zApplication.router r ra c | j S rq )r? r{ s r_ rN zApplication.middlewares r ra rQ access_log_classr kwargsc t t |t s"t d | | | | | j |d< ||d< | j r$| j D ]
\ }}|||< t | j
f| j | j d|S )NzMaccess_log_class must be subclass of aiohttp.abc.AbstractAccessLogger, got {}rR r )request_factoryrQ )
issubclassr r re r r r; r> itemsr- _handle
_make_requestr= )r^ rQ r r kvs r_
_make_handlerzApplication._make_handler s *,@AA ;;A6BR;S;S
t
+w%5!" *0022
1 q L
.
ra c Z t j dt d | j d||d|S )NzFApplication.make_handler(...) is deprecated, use AppRunner API insteadrU rV r rL )rX rY rZ r )r^ rQ r r s r_ make_handlerzApplication.make_handler sW
W
"t!
(8
>g
JQQRSTT&
h&t,,d222222ra requestc K t j }| }| j | d {V }|r7t |t s"t d | | | |
d }||_ |j
t j }|r:| | d {V }|j d {V |s|j }| j rT|j d d d D ]C}|j D ]9\ } }
|
r t/ t1 | | | }' | || d {V }:D || d {V }|S )Nz9match_info should be AbstractMatchInfo instance, not {!r})r )r r r r< resolver[ r r re add_appr _match_infoheadersr r EXPECTexpect_handlerr drainr rA appsr@ r r ) r^ r rQ rR
match_inforespexpectr r r new_styles r_ r zApplication._handle s %'' <//88888888
j*;<<
))/
);); 4 ( $$T[11 )#227;;;;;;;;D.&&(( ( ( ( ( ( ( ( < (G$
<%?44R40 < )idr{ s r_ __repr__zApplication.__repr__' s .D.....ra c dS r rL r{ s r_ __bool__zApplication.__bool__* s tra rS N).rq )r r5 rS N)rS r\ )rS r5 )Yrf
__module__ __qualname__ frozensetrk r# loggingLoggerr r4 r r% r r r intr r r` r rg r rm objectboolrr r r! r7 rv r r| r r r r r r r8 propertyrQ r r r r r rR r r. r r r r r, r
r/ r _RespPrepareSignalr
_AppSignalr r r r rM _MiddlewaresrN r' r r- r r r r r r* r" r$ r) r r r r r+ r r r r
__classcell__rn s @r_ r5 r5 Q s I
E4 ",*.,.48 &4850 50 50 50 ' 50
j) 50 wsCx 01
50 50 w0150 50
50 50 50 50n
tM 2
t
+ +C +c +d + + + + + + F t vbz b X s s X uS&*_ 5 # vbz " X s 3 4 X
!uS&*_ 5
!c
!d
!
!
!
! uS&*_ 5 $ !(5fSk)9#:; ! ! ! ! vbz D 8B< X vbz B 5R= X s S 3 X - -uS&*_- - -s - - - - ;g/ ; ; ; X;#hw'@ A #d # # # #$ D X U U U U2 X t X " " " " 1 1m 1@P 1 1 1 1 (-=)= >HU 1 1m 1@P 1 1 1 1.*:!; .]@S . . . . )%7 ) ) ) X) J X !Z ! ! ! X! J X ! ! ! X!
X !\ ! ! ! X! 597C
w01
34
B 597C
w01
34
$) ) ) )* * * * 6 6 6 6$ &
"
!
%
#
7m
& 3XeJ4D.E%F 3 3 3 3 $W $ $ $ $ $L /# / / / /$ ra c 6 e Zd Zedee fd ZdS )r6 rS c X t t t | j d S )Nr )r r
BaseExceptionargsr{ s r_
exceptionszCleanupError.exceptions/ s D '1 666ra N)rf r r r r
r" r$ rL ra r_ r6 r6 . s>
7D / 7 7 7 X7 7 7ra r6 c @ e Zd Zd fd ZdeddfdZdeddfdZ xZS )r\ rS Nc V t g | _ d S rq )rl r` _exits)r^ rn s r_ r` zCleanupContext.__init__; s$
13 ra r c K | D ]S} || }| d {V | j | Td S rq ) __aiter__ __anext__r' r] )r^ r cbits r_ rG zCleanupContext._on_startup? sq # #BC""$$B,,.. K r " " " " # #ra c K g }t | j D ]y} | d {V | t |d C# t
$ r Y Ot $ r }| | Y d }~rd }~ww xY w|r+t | dk r|d t d| d S )Nz has more than one 'yield'r r z Multiple errors on cleanup stage) r r' r* r] r StopAsyncIteration Exceptionr r6 )r^ r errorsr, excs r_ rI zCleanupContext._on_cleanupE s 4;'' Q QB
Qllnn$$$$$$$
lb+N+N+N O OPPPP &
#
#
#
c""""""""
# O6{{a Qi"#EvNNN O Os A
B( B1B Br )rf r r r` r5 rG rI r r s @r_ r\ r\ : s 4 4 4 4 4 4#[ #T # # # # O[ OT O O O O O O O Ora r\ )Wr r rX functoolsr r typingr r r r r r
r r r
r r r r r r r r r r aiosignalr
frozenlistr r abcr r r r helpersr r! http_parserr" logr# streamsr$ typedefsr% web_exceptionsr& web_logr' web_middlewaresr( web_protocolr) web_requestr* web_responser+ web_routedefr,
web_serverr- web_urldispatcherr. r/ r0 r1 r2 r3 r4 __all__r r r r _MiddlewaresHandlers_Subappsr7 r8 r r5 r r6 _CleanupContextBaser\ rL ra r_ rJ sb - - - - - - - - , ! ! ! ! ! ! # " " " " " " " * * * * * * ! ! ! ! ! ! , , , , , , ! ! ! ! ! ! 5 5 5 5 5 5 ( ( ( ( ( ( ( ( ( ( ( ( * * * * * * * - )D/!ABCJ '>)BIdO)S TU j)L#HU:t3C-D$EFM"HH J L#H-H WT]] WT]]Z Z Z Z Z.sF3K'7!8#!=> Z Z Zz7 7 7 7 7< 7 7 7 %$X{m]4=P.P%QR$O O O O O( O O O O Ora