File: //opt/saltstack/salt/lib/python3.10/site-packages/aiohttp/__pycache__/abc.cpython-310.pyc
o
;jp � @ s� d dl Z d dlZd dlZd dlmZmZ d dlmZmZm Z m
Z
m Z m Z d dl
mZmZmZ d dlmZ d dlmZmZmZ d dlmZ d dlmZ d d
lm Z d d l m Z ersd d l m Z d d
l!m"Z" d dl#m$Z$m%Z% d dl&m'Z' n
e Z$ Z% Z Z'eZ"G dd� de�Z(G dd� de�Z)G dd� de�Z*G dd� de�Z+G dd� de�Z,er�e
ee- Z.ne
Z.edge/f Z0G dd � d e e.�Z1G d d � d e�Z2G d d � d e�Z3dS )!� N)�ABC�abstractmethod)� Awaitable�Callable� Generator�Iterable�Sequence�Sized)�
BaseCookie�Morsel� SimpleCookie)�MappingProxyType)�
TYPE_CHECKING�Any� TypedDict)� CIMultiDict)�URL� )�parse_set_cookie_headers)� LooseCookies)� Application)�
HTTPException)� BaseRequest�Request)�StreamResponsec @ sZ e Zd Zddd�Zdeddfdd�Zedefdd ��Zdd
d �Z e
d e dd
fdd��Z dS )�AbstractRouter�returnNc C s
d| _ d S )NF�Z_frozen��self� r �?/opt/saltstack/salt/lib/python3.10/site-packages/aiohttp/abc.py�__init__ �
zAbstractRouter.__init__�appc C � dS )z�Post init stage.
Not an abstract method for sake of backward compatibility,
but if the router wants to be aware of the application
it can override this.
Nr �r r$ r r r! � post_init � zAbstractRouter.post_initc C � | j S �Nr r r r r! �frozen& s zAbstractRouter.frozenc C s
d| _ dS )zFreeze router.TNr r r r r! �freeze* s
zAbstractRouter.freeze�request�AbstractMatchInfoc � � �dS )z#Return MATCH_INFO for given requestNr �r r- r r r! �resolve. � zAbstractRouter.resolve�r N)
�__name__�
__module__� __qualname__r" r r' �property�boolr+ r, r r r1 r r r r! r s
r c @ s� e Zd ZdZeedeegee f fdd���Z
eedeegee dB f fdd���Z eede dB fdd ���Z
edeeef fd
d ��Zeedeed f fd
d���Zededdfdd��Zeddd��ZdS )r. r r c C r% )z Execute matched request handlerNr r r r r! �handler7 r( zAbstractMatchInfo.handlerNc C r% )z*Expect handler for 100-continue processingNr r r r r! �expect_handler< r( z AbstractMatchInfo.expect_handlerc C r% )z<HTTPException instance raised on router's resolving, or NoneNr r r r r! �http_exceptionC r( z AbstractMatchInfo.http_exceptionc C r% )z;Return a dict with additional info useful for introspectionNr r r r r! �get_infoH r( zAbstractMatchInfo.get_info.c C r% )z\Stack of nested applications.
Top level application is left-most element.
Nr r r r r! �appsL r( zAbstractMatchInfo.appsr$ c C r% )z)Add application to the nested apps stack.Nr r& r r r! �add_appU r( zAbstractMatchInfo.add_appc C r% )z�Freeze the match info.
The method is called after route resolution.
After the call .add_app() is forbidden.
Nr r r r r! r, Y r( zAbstractMatchInfo.freezer3 )r4 r5 r6 � __slots__r7 r r r r r r9 r: r r; �dict�strr r< �tupler r= r> r, r r r r! r. 3 s, �r. c @ sP e Zd ZdZdeddfdd�Zedefdd��Zede dde
f fd d
��Z dS ) � AbstractViewzAbstract class based view.r- r Nc C s
|| _ d S r* �Z_requestr0 r r r! r" g r# zAbstractView.__init__c C r) )zRequest instance.rD r r r r! r- j s zAbstractView.requestc C r% )zExecute the view handler.Nr r r r r! � __await__o r( zAbstractView.__await__) r4 r5 r6 �__doc__r r" r7 r- r r r rE r r r r! rC d s rC c @ sB e Zd ZU dZeed< eed< eed< eed< eed< eed< dS ) �
ResolveResulta� Resolve result.
This is the result returned from an AbstractResolver's
resolve method.
:param hostname: The hostname that was provided.
:param host: The IP address that was resolved.
:param port: The port that was resolved.
:param family: The address family that was resolved.
:param proto: The protocol that was resolved.
:param flags: The flags that were resolved.
�hostname�host�port�family�proto�flagsN)r4 r5 r6 rF rA �__annotations__�intr r r r! rG t s
rG c @ sJ e Zd ZdZedejfdededej de
e fdd��Z ed d
d ��Z
d S )
�AbstractResolverzAbstract DNS resolver.r rI rJ rK r c � r/ )z$Return IP address for given hostnameNr )r rI rJ rK r r r! r1 � r2 zAbstractResolver.resolveNc � r/ )zRelease resolverNr r r r r! �close� r2 zAbstractResolver.closer3 )r4 r5 r6 rF r �socket�AF_INETrA rO �
AddressFamily�listrG r1 rQ r r r r! rP � s ���� �rP z Morsel[str]c @ s$ e Zd ZdZdd�dejdB ddfdd�Zeede fdd ���Z
eede fd
d ���Z eede e
eef ef fd d
���Zeedee
eef fdd���Zed!dedB ddfdd��Zededdfdd��Zee� fdededdfdd��Zdee deddfdd �Zed edd fd d ��ZdS )"�AbstractCookieJarzAbstract Cookie Jar.N)�looprW r c C s |pt �� | _d S r* )�asyncioZget_running_loopZ_loop)r rW r r r! r" � s zAbstractCookieJar.__init__c C r% )z5Return True if cookies can be used with IP addresses.Nr r r r r! �unsafe� r( zAbstractCookieJar.unsafec C r% )z(Return True if cookies should be quoted.Nr r r r r! � quote_cookie� r( z AbstractCookieJar.quote_cookiec C r% )z&Return the cookies stored in this jar.Nr r r r r! �cookies� r( zAbstractCookieJar.cookiesc C r% )z0Return the host-only cookies stored in this jar.Nr r r r r! �host_only_cookies� r( z#AbstractCookieJar.host_only_cookies� predicatec C r% )z,Clear all cookies if no predicate is passed.Nr )r r] r r r! �clear� r( zAbstractCookieJar.clear�domainc C r% )z0Clear all cookies for domain and all subdomains.Nr )r r_ r r r! � clear_domain� r( z AbstractCookieJar.clear_domainr[ � response_urlc C r% )zUpdate cookies.Nr )r r[ ra r r r! �update_cookies� r( z AbstractCookieJar.update_cookies�headersc C s( |rt |� }r| �||� dS dS dS )z+Update cookies from raw Set-Cookie headers.N)r rb )r rc ra Zcookies_to_updater r r! �update_cookies_from_headers� s �z-AbstractCookieJar.update_cookies_from_headers� request_urlzBaseCookie[str]c C r% )z6Return the jar's cookies filtered by their attributes.Nr )r re r r r! �filter_cookies� r( z AbstractCookieJar.filter_cookiesr* ) r4 r5 r6 rF rX ZAbstractEventLoopr" r7 r r8 rY rZ r
rB rA r r[ � frozensetr\ �ClearCookiePredicater^ r` r r rb r rd rf r r r r! rV � s< " ��
�rV c @ s� e Zd ZU dZdZeed< dZeed< dZedB ed< e de
e B e B ddfd d
��Z
e d de
ddfd d
��Ze d dd��Ze d dededB ddfdd��Ze d dd��Ze deddddfdd��Zd d d �ZdS )!�AbstractStreamWriterzAbstract stream writer.r � buffer_size� output_sizeN�length�chunkr c � r/ )zWrite chunk into stream.Nr �r rm r r r! �write� r2 zAbstractStreamWriter.write� c � r/ )zWrite last chunk.Nr rn r r r! � write_eof� r2 z AbstractStreamWriter.write_eofc � r/ )zFlush the write buffer.Nr r r r r! �drain� r2 zAbstractStreamWriter.drain�deflate�encoding�strategyc C r% )z Enable HTTP body compressionNr )r rt ru r r r! �enable_compression� r( z'AbstractStreamWriter.enable_compressionc C r% )zEnable HTTP chunked modeNr r r r r! �enable_chunking� r( z$AbstractStreamWriter.enable_chunking� status_linerc zCIMultiDict[str]c � r/ )zWrite HTTP headersNr )r rx rc r r r! �
write_headers� r2 z"AbstractStreamWriter.write_headersc C r% )z�Force sending buffered headers if not already sent.
Required only if write_headers() buffers headers instead of sending immediately.
For backwards compatibility, this method does nothing by default.
Nr r r r r! � send_headers� r( z!AbstractStreamWriter.send_headers)rp r3 )rs N)r4 r5 r6 rF rj rO rN rk rl r �bytes� bytearray�
memoryviewro rq rr rA rv rw ry rz r r r r! ri � s>
��� � �� �ri c @ s\ e Zd ZdZdZdejdeddfdd�Ze d e
d
e d e ddfd d
��Z
edefdd��ZdS )�AbstractAccessLoggerz Abstract writer to access log.��logger�
log_formatr� r� r Nc C s || _ || _d S r* r )r r� r� r r r! r" s
z AbstractAccessLogger.__init__r- �response�timec C r% )zEmit log to logger.Nr )r r- r� r� r r r! �log r( zAbstractAccessLogger.logc C r% )zCheck if logger is enabled.Tr r r r r! �enabled s z AbstractAccessLogger.enabled)r4 r5 r6 rF r? �logging�LoggerrA r" r r r �floatr� r7 r8 r� r r r r! r~ � s r~ )4rX r� rR �abcr r �collections.abcr r r r r r Z http.cookiesr
r r �typesr
�typingr r r Z multidictr Zyarlr Z_cookie_helpersr Ztypedefsr Zweb_appr Zweb_exceptionsr Z web_requestr r Z web_responser r r. rC rG rP rA Z IterableBaser8 rh rV ri r~ r r r r! �<module> s> 12+