Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/twisted/protocols/__pycache__/sip.cpython-39.pyc
Ðазад
a k�hH� � 6 @ s� d Z ddlZddlZddlZddlmZ ddlmZmZ ddl m Z m Z ddl m Z ddlmZmZmZ ddlmZ dd lmZ d Zd d d ddddddd� Zi Ze�� D ]\ZZeee< q�[[dddddddd d d d d d!d"d#d$d%d&d'd(d)d*d+d,d-d.d/d0d1d2d3d4d5d6d7d8d9d:d;d<d=d>d?d@dAdBdCdDdEdFdGdHd'dI�5Z dJdKdLdM�Z dNdO� Z dPdQ� Z e � Z!G dRdS� dS�Z"dTdU� Z#G dVdW� dW�Z$d|dXdY�Z%dZd[� Z&d}d\d]�Z'G d^d_� d_e(�Z)G d`da� dae)�Z*G dbdc� dc�Z+G ddde� dee+�Z,G dfdg� dge+�Z-G dhdi� diej.�Z/G djdk� dkej0�Z1G dldm� dme �Z2G dndo� do�Z3G dpdq� dqe �Z4G drds� dse �Z5G dtdu� due1�Z6G dvdw� dwe �Z7G dxdy� dye6�Z8e e4e5�G dzd{� d{��Z9dS )~zP Session Initialization Protocol. Documented in RFC 2543. [Superseded by 3261] � N)� OrderedDict)�Dict�List)� Interface� implementer)�cred)�defer�protocol�reactor)�basic)�logi� �i�m�e�l�c�f�s�t�v) �call-id�contactzcontent-encoding�content-lengthz content-type�from�subject�to�viaZTryingZRingingzCall Is Being ForwardedZQueuedzSession Progress�OKzMultiple ChoiceszMoved PermanentlyzMoved Temporarilyz See Otherz Use ProxyzAlternative Servicez Bad Request� UnauthorizedzPayment Required� Forbiddenz Not FoundzMethod Not AllowedzNot Acceptablez Proxy Authentication RequiredzRequest Timeout�Conflict�GonezLength RequiredzRequest Entity Too LargezRequest-URI Too LargezUnsupported Media TypezUnsupported URI Schemez Bad ExtensionzExtension RequiredzInterval Too BriefzTemporarily Unavailablez Call/Transaction Does Not Existz Loop Detectedz Too Many HopszAddress IncompleteZ Ambiguousz Busy HerezRequest TerminatedzNot Acceptable HerezRequest PendingZUndecipherablezInternal Server ErrorzNot Implementedz Bad GatewayzService UnavailablezServer Time-outzSIP Version not supportedzMessage Too LargezBusy EverywhereZDeclinezDoes not exist anywhere)5�d � � � � �� i, i- i. i/ i1 i| � � i� i� � i� i� i� i� i� i� i� i� i� i� i� i� i� i� i� i� i� i� i� i� i� i� i� i� i� �� � i� i� i� i� i iX i[ i\ i^ ZCSeqzCall-IDzWWW-Authenticate)�cseqr �www-authenticatec C s d� dd� | �d�D ��S )zK Capitalize a string, making sure to treat '-' as a word separator �-c S s g | ] }|� � �qS � )� capitalize)�.0�xr0 r0 ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/twisted/protocols/sip.py� <listcomp>p � z"dashCapitalize.<locals>.<listcomp>)�join�split�r r0 r0 r4 �dashCapitalizel s r: c C s0 | d | d kr dkr,n n | dd� S | S )Nr ����"� r0 r9 r0 r0 r4 �unqs s r> c @ sL e Zd ZdZeddddeddfdd�Zedd� �Zej d d� �Zd d � Z dS ) �Viaa� A L{Via} is a SIP Via header, representing a segment of the path taken by the request. See RFC 3261, sections 8.1.1.7, 18.2.2, and 20.42. @ivar transport: Network protocol used for this leg. (Probably either "TCP" or "UDP".) @type transport: C{str} @ivar branch: Unique identifier for this request. @type branch: C{str} @ivar host: Hostname or IP for this leg. @type host: C{str} @ivar port: Port used for this leg. @type port C{int}, or None. @ivar rportRequested: Whether to request RFC 3581 client processing or not. @type rportRequested: C{bool} @ivar rportValue: Servers wishing to honor requests for RFC 3581 processing should set this parameter to the source port the request was received from. @type rportValue: C{int}, or None. @ivar ttl: Time-to-live for requests on multicast paths. @type ttl: C{int}, or None. @ivar maddr: The destination multicast address, if any. @type maddr: C{str}, or None. @ivar hidden: Obsolete in SIP 2.0. @type hidden: C{bool} @ivar otherParams: Any other parameters in the header. @type otherParams: C{dict} ZUDPNFc K s� || _ || _|| _|| _|| _|| _|du rJtjdtdd� d| _ d| _ n8|du r`d| _ d| _ n"|t u rvd| _ d| _ n || _ d| _ || _ | | _ | | _dS )a( Set parameters of this Via header. All arguments correspond to attributes of the same name. To maintain compatibility with old SIP code, the 'rport' argument is used to determine the values of C{rportRequested} and C{rportValue}. If None, C{rportRequested} is set to True. (The deprecated method for doing this is to pass True.) If an integer, C{rportValue} is set to the given value. Any arguments not explicitly named here are collected into the C{otherParams} dict. Tz+rport=True is deprecated since Twisted 9.0.� )� stacklevelNF)� transport�host�port�ttl�hidden�received�warnings�warn�DeprecationWarning� rportValue�rportRequested�_absent�branch�maddr� otherParams) �selfrC rD rB rE rF rG �rportrN rO �kwr0 r0 r4 �__init__� s2 �z Via.__init__c C s& | j dkrdS | jdur | jS dS dS )zG Returns the rport value expected by the old SIP code. TN)rL rK �rQ r0 r0 r4 rR � s z Via.rportc C s || _ d| _dS )z� L{Base._fixupNAT} sets C{rport} directly, so this method sets C{rportValue} based on that. @param newRPort: The new rport value. @type newRPort: C{int} FN)rK rL )rQ ZnewRPortr0 r0 r4 rR � s c C s� d| j � d| j� d| j� �}| jr*|d7 }dD ]*}t| |�}|dur.|d|� d|� �7 }q.| jrj|d 7 }n| jdur�|d | j� �7 }t| j � � �}|D ]2\}}|du r�|d| 7 }q�|d|� d|� �7 }q�|S ) zI Serialize this header for use in a request or response. zSIP/2.0/� �:z;hidden)rE rN rO rG N�;�=z;rportz;rport=) rB rC rD rF �getattrrL rK rR �sortedrP �items)rQ r �n�value�etc�kr r0 r0 r4 �toString� s" z Via.toString) �__name__� __module__� __qualname__�__doc__�PORTrM rT �propertyrR �setterra r0 r0 r0 r4 r? | s #� 6 r? c C sP | � d�}|d |dd� }}|� dd�\}}|�� }i }|� d�\}}} |dks\|dkrjtd | ����| |d < d |v r�|� d �\} } t| �|d < | |d < n||d < |D ]�} | �� � dd�} t| �dkr�| d d } } n| \} } | dkr�d|d< q�| � dd�}t|�dk�r |d d }} n|\}} |dv �r8t| �} | ||< q�tf i |��S )za Parse a Via header. @return: The parsed version of this header. @rtype: L{Via} rX r r= NrV �/ZSIPz2.0zwrong protocol or version: rB rW rD rC � rF TrY )rR rE )r8 �strip� ValueError�int�lenr? )r^ �parts�sent�paramsZ protocolinfoZby�resultZpnameZpversionrB rC rD �p�comment�namer0 r0 r4 �parseViaHeader s< rv c @ sD e Zd ZdZd dd�Zed�dd�Zed�dd �Zed�d d �ZdS ) �URLz A SIP URL. Nc C sl || _ || _|| _|| _|| _|| _|| _| | _|| _| | _ | d krLg | _ n| | _ | d krbi | _ n| | _ d S �N) �usernamerC �passwordrD rB �usertype�method�tagrE rO �other�headers) rQ rC ry rz rD rB r{ r| rE rO r} r~ r r0 r0 r4 rT 4 s z URL.__init__��returnc C s� g }|j }|d� | jd krF|| j� | jd kr>|d| j � |d� || j� | jd krh|d| j � | jd kr�|d| j � dD ]*}t| |�}|d kr�|d|� d|� �� q�| jD ]}|d | � q�| jr�|d � |d � d d � | j� � D ��� d� |�S )N�sip:z:%s�@z:%dz;user=%s�rB rE rO r| r} rX rY z;%s�?�&c S s, g | ]$\}}t �|�p t|�� d |� ��qS )rY )� specialCases�getr: )r2 �hr r0 r0 r4 r5 n s �z URL.toString.<locals>.<listcomp>rj ) �appendry rz rC rD r{ rZ r~ r r7 r\ )rQ r �wr] r r0 r0 r4 ra V s: ���z URL.toStringc C s | � � S rx )ra rU r0 r0 r4 �__str__v s z URL.__str__c C s d� | j| j| j| j| j�S )Nz<URL {}:{}@{}:{!r}/{}>)�formatry rz rC rD rB rU r0 r0 r4 �__repr__y s �z URL.__repr__) NNNNNNNNNNN) rb rc rd re rT �strra r� r� r0 r0 r0 r4 rw / s � " rw c C s i }| � d�s"td| dd� ��| dd� �d�}|d |dd� }}|�dd�}t|�d kr�|\}} |�d d�} t| �dkr�| d |d < q�| d |d < | d |d < n|d } | �d d�} t| �dkr�| d |d < n | d |d < t| d �|d< |dk�r||d < |dk�r||d< |D ]�} | |d k�r|d| v �r|i |d< } | �dd�\} }|�d�D ] }|�d�\}}|| |< �q^| �dd�}t|�dk�r�|�dg ��| � �q |\}}|dk�r�||d< n8|dv �r�|dk�r�t|�}|||< n|�dg ��| � �q tf i |��S )zV Return string into URL object. URIs are of form 'sip:user@example.com'. r� zunsupported scheme: N� rX r r= r� r@ rW ry rz rC rD r; r� r r� rY r~ �userr{ r� rE )� startswithrl r8 rn rm � setdefaultr� rw )�urlrC rD �dro Z userdomainrq ZudpartsZuserpass�hostportZuppartsZhppartsrs r� r �headerr` r �nvru r^ r0 r0 r4 �parseURL� sV r� c C s d| _ d| _d| _i | _dS )z* Clean a URL from a Request line. N)rB rO rE r )r� r0 r0 r4 �cleanRequestURL� s r� c C s� | � � } | �d�r&dt| ||d�i fS i }| �dd�\}}|� � }|�d�rX|dd� }|�d�rn|dd� }|�d d�\}}t|||d�}|� � }|r�|�d �D ] }|s�q�|�d �\} } | || < q�|r�d|_i |_d|_d|_|||fS ) z� Return (name, uri, params) for From/To/Contact header. @param clean: remove unnecessary info, usually for From and To headers. r� rj �rC rD �<r= r< Nr; �>rX rY ) rk r� r� r8 �endswithrE r rB rO ) �addressrC rD �cleanrq ru r� Z paramstringr r` r r0 r0 r4 � parseAddress� s2 r� c @ s e Zd Zddd�ZdS )�SIPErrorNc C s4 |d u rt | }t�| d||f � || _|| _d S )NzSIP error (%d): %s)� statusCodes� ExceptionrT �code�phrase)rQ r� r� r0 r0 r4 rT � s zSIPError.__init__)N�rb rc rd rT r0 r0 r0 r4 r� � s r� c @ s e Zd ZdZdS )�RegistrationErrorz( Registration was not possible. N�rb rc rd re r0 r0 r0 r4 r� � s r� c @ sD e Zd ZdZdZdd� Zdd� Zdd� Zd d � Zd d � Z d d� Z dS )�Messagez A SIP message. Nc C s t � | _d| _d| _d S )Nrj r )r r �body�finishedrU r0 r0 r4 rT � s zMessage.__init__c C s> |� � }t�||�}|dkr&t|�| _| j�|g ��|� d S )Nr )�lower� longHeadersr� rm �lengthr r� r� )rQ ru r^ r0 r0 r4 � addHeader s zMessage.addHeaderc C s | j |7 _ d S rx )r� �rQ �datar0 r0 r4 �bodyDataReceived s zMessage.bodyDataReceivedc C s, | j d kr"| j t| j�kr"td��d| _d S )Nzwrong body lengthr= )r� rn r� rl r� rU r0 r0 r4 �creationFinished s zMessage.creationFinishedc C sb d| � � }| j�� D ]4\}}|D ]&}|t�|�p8t|�� d|� d�7 }q"q|d7 }|| j7 }|S )Nz%s z: z )�_getHeaderLiner r\ r� r� r: r� )rQ r r] �vsr r0 r0 r4 ra s & zMessage.toStringc C s t �d S rx ��NotImplementedErrorrU r0 r0 r4 r� s zMessage._getHeaderLine) rb rc rd re r� rT r� r� r� ra r� r0 r0 r0 r4 r� � s r� c @ s0 e Zd ZdZd dd�Zed�dd�Zdd � Zd S ) �Requestz A Request for a URI �SIP/2.0c C s: t �| � || _t|t�r"|| _nt|�| _t| j� d S rx )r� rT r| � isinstancerw �urir� r� )rQ r| r� �versionr0 r0 r4 rT # s zRequest.__init__r� c C s dt | �| j| j�� f S )Nz<SIP Request %d:%s %s>)�idr| r� ra rU r0 r0 r4 r� , s zRequest.__repr__c C s | j � d| j�� � d�S )NrV z SIP/2.0)r| r� ra rU r0 r0 r4 r� / s zRequest._getHeaderLineN)r� �rb rc rd re rT r� r� r� r0 r0 r0 r4 r� s r� c @ s0 e Zd ZdZd dd�Zed�dd�Zd d � ZdS ) �Responsez% A Response to a URI Request Nr� c C s* t �| � || _|d kr t| }|| _d S rx )r� rT r� r� r� )rQ r� r� r� r0 r0 r4 rT 8 s zResponse.__init__r� c C s dt | �| jf S )Nz<SIP Response %d:%s>)r� r� rU r0 r0 r4 r� ? s zResponse.__repr__c C s d| j � d| j� �S )NzSIP/2.0 rV )r� r� rU r0 r0 r4 r� B s zResponse._getHeaderLine)Nr� r� r0 r0 r0 r4 r� 3 s r� c @ sx e Zd ZdZdZdZdZdZdZdd� Z d d d �Z d d � Z d d� Z dd� Z dd� Zdd� Zdd� Zd dd�Zdd� ZdS ) �MessagesParserz� A SIP messages parser. Expects dataReceived, dataDone repeatedly, in that order. Shouldn't be connected to actual transport. r� r= � firstliner c C s || _ | �� d S rx )�messageReceived�reset)rQ ZmessageReceivedCallbackr0 r0 r4 rT U s zMessagesParser.__init__rj c C s, d| _ d | _d| _d | _d | _| �|� d S )Nr� r )�stater� � bodyReceived�messager� Z setLineMode�rQ Z remainingDatar0 r0 r4 r� Y s zMessagesParser.resetc C s d| _ | �� d S )N�invalid)r� � setRawModerU r0 r0 r4 �invalidMessagea s z MessagesParser.invalidMessagec C sb | � � | jdkrdS | jdkr,| �� dS | jdkr@| �� n | j| jk rV| �� ntd��dS )zI Clear out any buffered data that may be hanging around. r� Nr� zthis should never happen)ZclearLineBufferr� r� r� � messageDoner� � RuntimeErrorrU r0 r0 r4 �dataDonee s zMessagesParser.dataDonec C sN z&t |t�r|�d�}tj�| |� W n" tyH t�� | � � Y n0 d S )N�utf-8) r� r� �encoder � LineReceiver� dataReceivedr� r �errr� r� r0 r0 r4 r� y s zMessagesParser.dataReceivedc C s t �dS )z2 Expected to create self.message. Nr� �rQ �liner0 r0 r4 �handleFirstLine� s z MessagesParser.handleFirstLinec C s | � � d S rx )r� r� r0 r0 r4 �lineLengthExceeded� s z!MessagesParser.lineLengthExceededc C s& t |t�r|�d�}| jdkr�|�d�s2|�d�r@|dd � }q |sHd S z|�dd�\}}}W n tyz | �� Y d S 0 |dkr�| jr�z t |�}W n ty� | �� Y d S 0 t ||�| _ n(|dkr�| j r�t ||�| _ n | �� d S d | _d S | jd k�sJ �|�r�|�d��s"|�d ��r@| j\}}|||�� f| _n�| j�r\| j j| j� d | _z|�d d�\}}W n t�y� | �� Y d S 0 ||�� f| _|�� d k�r"zt |�� �| _W n t�y� | �� Y d S 0 nBd | _| j�r| j j| j� d | _| jdk�r| �� d S | �� d S )Nr� r� � � r= rV r@ r� r � rW r r� r )r� �bytes�decoder� r� r8 rl r� �acceptResponsesrm r� r� �acceptRequestsr� r� �lstripr� r� r� r� r� )rQ r� �a�br r� ru r^ r0 r0 r4 � lineReceived� sj zMessagesParser.lineReceivedc C s2 | j dksJ �| j�� | �| j� | �|� d S )Nr� )r� r� r� r� r� r� r0 r0 r4 r� � s zMessagesParser.messageDonec C s� | j dv sJ �t|t�r"|�d�}| j dkr0d S | jd krH| j�|� ntt|�}| j| j }||kr�| j�|d |� � | � ||d � � d S | j|7 _| j�|� | j| jkr�| � � d S )N)r� r� r� r� ) r� r� r� r� r� r� r� rn r� r� )rQ r� ZdataLenZ expectedLenr0 r0 r4 �rawDataReceived� s" z MessagesParser.rawDataReceivedN)rj )rj )rb rc rd re r� r� r� r� �debugrT r� r� r� r� r� r� r� r� r� r0 r0 r0 r4 r� F s C r� c @ s` e Zd ZdZeZdZdd� Zdd� Zdd� Zd d � Z d d � Z d d� Z dd� Z dd� Z dd� ZdS )�Basez1 Base class for SIP clients and servers. Fc C s g | _ t| j�| _d S rx )�messagesr� � addMessage�parserrU r0 r0 r4 rT � s z Base.__init__c C s | j �|� d S rx )r� r� )rQ �msgr0 r0 r4 r� � s zBase.addMessagec C s� | j �|� | j �� | jD ]T}| �||� | jrLt�d|�� �d|��� t |t �rd| � ||� q | � ||� q g | jd d �< d S )Nz Received z from ) r� r� r� r� � _fixupNATr� r r� ra r� r� �handle_request�handle_response)rQ r� �addrr r0 r0 r4 �datagramReceived� s zBase.datagramReceivedc C sz |\}}t |jd d �}|j|krN||_|j|kr:||_|�� |jd d< n(|jdkrv||_||_|�� |jd d< d S )Nr r T)rv r rC rG rD rR ra )rQ r� � sourcePeer�srcHost�srcPortZ senderViar0 r0 r4 r� s zBase._fixupNATc C sL t |jd d �}|jp |j}|jp.|jp.| j}t||d�}| �||� dS �zX Deliver response. Destination is based on topmost Via header. r r r� N� rv r rG rC rR rD rf rw � sendMessage�rQ ZresponseMessageZdestViarC rD ZdestAddrr0 r0 r4 �deliverResponse s zBase.deliverResponsec C s2 t |�}dD ] }|j�|g �dd� |j|< q |S �z9 Create a response to a request message. )r r r r r- N�r� r r� �rQ r� �request�responseru r0 r0 r4 �responseFromRequest! s zBase.responseFromRequestc C sn |j dvrtd��| jr2t�d|�� �d|��� |�� }t|t�rN|�d�}| j � ||j |j pd| j f� dS )z� Send a message. @param destURL: C{URL}. This should be a *physical* URL, not a logical one. @param message: The message to send. )ZudpNz only UDP currently supportedzSending z to r� N) rB r� r� r r� ra r� r� r� �writerC rD rf )rQ ZdestURLr� r� r0 r0 r4 r� + s zBase.sendMessagec C s t �dS )z� Override to define behavior for requests received @type message: C{Message} @type addr: C{tuple} Nr� �rQ r� r� r0 r0 r4 r� ; s zBase.handle_requestc C s t �dS )z� Override to define behavior for responses received. @type message: C{Message} @type addr: C{tuple} Nr� r� r0 r0 r4 r� D s zBase.handle_responseN)rb rc rd re rf r� rT r� r� r� r� r� r� r� r� r0 r0 r0 r4 r� � s r� c @ s e Zd ZdZdS )�IContactz( A user of a registrar or proxy Nr� r0 r0 r0 r4 r� N s r� c @ s e Zd Zdd� ZdS )� Registrationc C s || _ || _d S rx )�secondsToExpiry� contactURL)rQ r r r0 r0 r4 rT U s zRegistration.__init__Nr� r0 r0 r0 r4 r T s r c @ s( e Zd ZdZdd� Zdd� Zdd� ZdS ) � IRegistryz? Allows registration of logical->physical URL mapping. c C s dS )z� Register the physical address of a logical URL. @return: Deferred of C{Registration} or failure with RegistrationError. Nr0 �� domainURL� logicalURL� physicalURLr0 r0 r4 �registerAddress_ s zIRegistry.registerAddressc C s dS )z� Unregister the physical address of a logical URL. @return: Deferred of C{Registration} or failure with RegistrationError. Nr0 r r0 r0 r4 �unregisterAddressf s zIRegistry.unregisterAddressc C s dS )z� Get registration info for logical URL. @return: Deferred of C{Registration} object or failure of LookupError. Nr0 �r r0 r0 r4 �getRegistrationInfom s z IRegistry.getRegistrationInfoN)rb rc rd re r r r r0 r0 r0 r4 r Z s r c @ s e Zd ZdZdd� ZdS )�ILocatorz< Allow looking up physical address for logical URL. c C s dS )z� Return physical URL of server for logical URL of user. @param logicalURL: a logical C{URL}. @return: Deferred which becomes URL or fails with LookupError. Nr0 r r0 r0 r4 � getAddressz s zILocator.getAddressN)rb rc rd re r r0 r0 r0 r4 r u s r c @ sf e Zd ZdZeZdZdefdd�Zdd� Zdd� Zd d � Z d d � Z d d� Z dd� Z dd� Z dd� ZdS )�Proxyz SIP proxy. Nc C s" |p t �� | _|| _t�| � dS )z� Create new instance. @param host: our hostname/IP as set in Via headers. @param port: our port as set in Via headers. N)�socket�getfqdnrC rD r� rT )rQ rC rD r0 r0 r4 rT � s zProxy.__init__c C s t | j| jd�S )z< Return value of Via header for this proxy. r� )r? rC rD rU r0 r0 r4 �getVia� s z Proxy.getViac s� t �d� j d �}|d u r �j}z|� |�}W nb tyf } z ����|j� �� W Y d }~nPd }~0 ty� t� � ����d� �� Y n 0 |d ur�|� � �fdd�� d S )Nzhandle_%s_requestr+ c s �� ��| j� ��S rx )r� r� r� )r �r� rQ r0 r4 �<lambda>� s �z&Proxy.handle_request.<locals>.<lambda>) rZ r| �handle_request_defaultr� r� r� r� � BaseExceptionr r� � addErrback)rQ r� r� r r� r r0 r r4 r� � s ( �zProxy.handle_requestc s� |\}}� fdd�}� � � }|�� |jd v r<t�d� dS |jd �d|�� � t|jd d dd �\}}} � j�|�} | � � j |� | � � j |� dS ) z� Default request handler. Default behaviour for OPTIONS and unknown methods for proxies is to forward message on to the client. Since at the moment we are stateless proxy, that's basically everything. c s | � � |jd d< � �| |�S )Nr r )ra r r� )r� r� rU r0 r4 �_mungContactHeader� s z8Proxy.handle_request_default.<locals>._mungContactHeaderr zDropping looped message.Nr r r= �r� ) r ra r r r� �insertr� �locatorr � addCallbackr� r �_cantForwardRequest) rQ r� r� r� r� r Z viaHeaderru r� �tagsr� r0 rU r4 r � s z Proxy.handle_request_defaultc C s, |� t� |jd d= | �| �d|�� d S )Nr r r* )�trap� LookupErrorr r� r� �rQ �errorr� r0 r0 r4 r � s zProxy._cantForwardRequestc C sL t |jd d �}|jp |j}|jp.|jp.| j}t||d�}| �||� dS r� r� r� r0 r0 r4 r� � s zProxy.deliverResponsec C s2 t |�}dD ] }|j�|g �dd� |j|< q |S r� r� r� r0 r0 r4 r� � s zProxy.responseFromRequestc C sl t |jd d �}|j|jf| j| jfkr8t�d� dS |jd d= |jd s^| �||� dS | �|� dS )z+ Default response handler. r r z&Dropping incorrectly addressed messageN)rv r rC rD r r� � gotResponser� )rQ r� r� r r0 r0 r4 r� � s zProxy.handle_responsec C s dS )zJ Called with responses that are addressed at this server. Nr0 r� r0 r0 r4 r" � s zProxy.gotResponse)rb rc rd re rf r rT r r� r r r� r� r� r" r0 r0 r0 r4 r � s r c @ s e Zd Zdd� Zdd� ZdS )� IAuthorizerc C s dS )z� Generate a challenge the client may respond to. @type peer: C{tuple} @param peer: The client's address @rtype: C{str} @return: The challenge string Nr0 )Zpeerr0 r0 r4 � getChallenge s zIAuthorizer.getChallengec C s dS )zf Create a credentials object from the given response. @type response: C{str} Nr0 )r� r0 r0 r4 r� s zIAuthorizer.decodeN)rb rc rd r$ r� r0 r0 r0 r4 r# s r# c @ s� e Zd ZU dZdZdZi Zeee f e d< dd� Z dd� Z dd � Z d d � Zd d � Zdd� Zdd� Zdd� Zdd� Zdd� Zdd� Zdd� Zd d � ZdS ) � RegisterProxyzk A proxy that allows registration for a specific domain. Unregistered users won't be handled. N� authorizersc O s" t j| g|�R i |�� i | _d S rx )r rT ZliveChallenges)rQ �argsrS r0 r0 r4 rT & s zRegisterProxy.__init__c C s |\}}d S rx r0 �rQ r� � host_portrC rD r0 r0 r4 �handle_ACK_request* s z RegisterProxy.handle_ACK_requestc C sL |\}}| j du r"| �|||� n&d|jvr:| �|||�S | �|||�S dS )z` Handle a registration request. Currently registration is not proxied. N� authorization)�portal�registerr � unauthorized�loginr( r0 r0 r4 �handle_REGISTER_request3 s z%RegisterProxy.handle_REGISTER_requestc C s� | � d|�}| j�� D ]f\}}|�||f�}|d u rL|�� � d| j� d�}n |�� � d|� d| j� d�}|j�dg ��|� q| � |� d S )Nr) z realm="r< rV z,realm="r. ) r� r& r\ r$ �titlerC r r� r� r� ) rQ r� rC rD r �scheme�auth�chalr^ r0 r0 r4 r. D s zRegisterProxy.unauthorizedc C s� |j d d �d d�}| j�|d �� �}|r�z|�|d �}W n> tyT � Y q� ty~ t� � | � | � d|�� Y q�0 | j d| j 7 _ | j�|d t��| j|||��| j|||��tj � n| � | � d|�� d S )Nr+ r r= r+ r� r, )r r8 r& r� r� r� r� r r r� r� r� ry rC r, r/ r� r �_cbLoginr �_ebLogin)rQ r� rC rD ro r� r r0 r0 r4 r/ O s& � ��zRegisterProxy.loginc C s |\}}}| � |||� d S rx )r- )rQ Zi_a_lr� rC rD r r� r r0 r0 r4 r5 b s zRegisterProxy._cbLoginc C s |� tjj� | �|||� d S rx )r r r! ZUnauthorizedLoginr. )rQ Zfailurer� rC rD r0 r0 r4 r6 g s zRegisterProxy._ebLoginc C s� t |jd d dd�\}}}d}d|jv r8|jd d }|j�ddg�d dkr`| �|||� nV|dur�t |||d �\}}}| j�|j||�} n | j�|�} | j| j | j |f|fd � dS ) z- Allow all users to register r r r= r Nr �expires�0r� )Z callbackArgsZ errbackArgs) r� r r� � unregister�registryr r� r Z addCallbacks� _cbRegister� _ebRegister) rQ r� rC rD ru �toURLrq r r r� r0 r0 r4 r- k s �zRegisterProxy.registerc C sT | � d|�}|jd kr:|�d|j�� � |�dd|j � |�dd� | �|� d S )Nr' r r7 z%dr r8 )r� r r� ra r r� )rQ � registrationr� r� r0 r0 r4 r; � s zRegisterProxy._cbRegisterc C s |� tt� d S rx )r r� r r r0 r0 r4 r< � s zRegisterProxy._ebRegisterc C s� zt |jd d �}W n$ ty: | �| �d|�� Y nP0 |dkr�|dkrRd}nt|�\}}}| j�|j||�}|� | j |�� | j |� d S )Nr7 r r( �*) rm r rl r� r� r� r: r r� r � _cbUnregisterr � _ebUnregister) rQ r� r= r r7 r ru rq r� r0 r0 r4 r9 � s �zRegisterProxy.unregisterc C s@ | � d|�}|j�dg ��|j�� � |�dd� | �|� d S )Nr' r r7 r8 )r� r r� r� r ra r� r� )rQ r> r� r� r0 r0 r4 r@ � s zRegisterProxy._cbUnregisterc C s d S rx r0 )rQ r> r� r0 r0 r4 rA � s zRegisterProxy._ebUnregister)rb rc rd re r, r: r& r r� r# �__annotations__rT r* r0 r. r/ r5 r6 r- r; r< r9 r@ rA r0 r0 r0 r4 r% s" r% c @ s@ e Zd ZdZdd� Zdd� Zdd� Zdd � Zd d � Zd d � Z dS )�InMemoryRegistryz6 A simplistic registry for a specific domain. c C s || _ i | _d S rx )�domain�users)rQ rD r0 r0 r4 rT � s zInMemoryRegistry.__init__c C sR |j | jkrt�td��S |j| jv r@| j|j \}}t�|�S t�td��S d S �Nzunknown domain� no such user)rC rD r �failr ry rE �succeed�rQ ZuserURI�dcr� r0 r0 r4 r � s zInMemoryRegistry.getAddressc C sh |j | jkrt�td��S |j| jv rV| j|j \}}t�tt |� � t � � �|��S t�td��S d S rF ) rC rD r rH r ry rE rI r rm �getTime�timerJ r0 r0 r4 r � s z$InMemoryRegistry.getRegistrationInfoc C sT z| j | \}}W n ty2 t�td�� Y S 0 |�� | j |= t�td|��S )NrG r )rE �KeyErrorr rH r �cancelrI r )rQ ry rK r� r0 r0 r4 �_expireRegistration� s z$InMemoryRegistry._expireRegistrationc C s� |j | jkr$t�d� t�td��S |j | jkrHt�d� t�td��S |j| jv rp| j|j \}}|� d� nt � d| j |j�}t�d|� � � d|� � � �� ||f| j|j< t�tt|�� t�� �|��S )Nz(Registration for domain we don't handle.r* i z Registered z at )rC rD r r� r rH r� ry rE r� r Z callLaterrP ra rI r rm rL rM )rQ r r r rK �oldr0 r0 r4 r � s z InMemoryRegistry.registerAddressc C s | � |j�S rx )rP ry )rQ r r r r0 r0 r4 r � s z"InMemoryRegistry.unregisterAddressN) rb rc rd re rT r r rP r r r0 r0 r0 r4 rC � s rC )NN)NNr ):re r rM rH � collectionsr �typingr r Zzope.interfacer r Ztwistedr Ztwisted.internetr r r Ztwisted.protocolsr Ztwisted.pythonr rf Z shortHeadersr� r\ r` r r� r� r: r> �objectrM r? rv rw r� r� r� r� r� r� r� r� r� r� r� ZDatagramProtocolr� r� r r r r r# r% rC r0 r0 r0 r4 �<module> s� � �9� +T 7 # ( %d
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка