One Hat Cyber Team
Your IP :
216.73.216.64
Server IP :
162.240.179.46
Server :
Linux vps-14493116.nutrivittasaude.com.br 5.14.0-687.17.1.el9_8.x86_64 #1 SMP PREEMPT_DYNAMIC Mon Jun 22 07:21:26 EDT 2026 x86_64
Server Software :
Apache
PHP Version :
8.2.31
Buat File
|
Buat Folder
Eksekusi
Dir :
~
/
lib
/
python3.9
/
site-packages
/
cockpit
/
__pycache__
/
View File Name :
channel.cpython-39.opt-1.pyc
a ��j�V � @ s( d dl Z d dlZd dlZd dlZd dlZd dlZd dlmZmZmZm Z m Z m Z m Z m Z ddlmZmZmZmZmZmZmZ ddlmZ ddlmZmZmZ e� e �Z ej r�e� d�Z!e�"d�Z#G d d � d e�Z$G d d � d e�Z%G d d� de�Z&G dd� de&e j'�Z(G dd� de&�Z)G dd� de&�Z*dS )� N)�BinaryIO�Callable�ClassVar� Collection� Generator�Mapping�Sequence�Type� )� JsonError� JsonObject� JsonValue� create_object�get_bool�get_enum�get_str)�CockpitProblem)�Endpoint�Router� RoutingRule�_T�_Pc sl e Zd ZU ded< edd�� fdd� Zed�dd �Zd eed �d d �Z edd�dd�Z dd�dd�Z � Z S )�ChannelRoutingRulez dict[str, list[Type[Channel]]]�tablezCollection[Type[Channel]])�router� channel_typesc s\ t � �|� i | _|D ] }| j�|jg �}|�|� q| j�� D ]}|jdd� dd� q@d S )Nc S s t | j�S �N)�len� restrictions)�cls� r �3/usr/lib/python3.9/site-packages/cockpit/channel.py�<lambda>) � z-ChannelRoutingRule.__init__.<locals>.<lambda>T)�key�reverse)�super�__init__r � setdefault�payload�append�values�sort)�selfr r r �entry�� __class__r r! r' s zChannelRoutingRule.__init__��returnc C s> i }| j �� D ]*\}}g }|D ]}|�|j� q |||< q|S r )r �items�extend� capabilities)r- �resultr) ZimplsZcaps�implr r r! r5 + s z ChannelRoutingRule.capabilitiesz Collection[tuple[str, object]])r �optionsr2 c C s@ |D ]6\}}|� |�}|d u r$ dS |d ur||kr dS qdS )NFT)�get)r- r r8 r$ Zexpected_valueZ our_valuer r r! �check_restrictions5 s z%ChannelRoutingRule.check_restrictionszChannel | None�r8 r2 c C sL |� d�}t|t�sd S | j� |g �D ] }| �|j|�r&|| j� S q&d S )Nr) )r9 � isinstance�strr r: r r )r- r8 r) r r r r! � apply_ruleF s z ChannelRoutingRule.apply_ruleNc C s d S r r �r- r r r! �shutdownS s zChannelRoutingRule.shutdown) �__name__� __module__� __qualname__�__annotations__r r' r r5 �boolr: r> r@ � __classcell__r r r/ r! r s r c @ s e Zd ZdS )� ChannelErrorN)rA rB rC r r r r! rG W s rG c @ sZ e Zd ZU dZdZdZeed< dZe ed< eZ e ed< eed< d ed < d Z d ed < ded< dZ ded< dZ ded< dZdZeed< ded< eed d�dd�Zeeed d �d d �Zd d ed d �d!d"�Zed d#�d$d%�Zd d&�d'd(�Zd d&�d)d*�Zd d&�d+d,�Zed d-�d.d/�Zed d-�d0d1�Zed d2�d3d4�Z eed d5�d6d7�Z ed8d2�d9d:�Z e d d;�d<d=�Z dd>�eeed?�d@dA�Z!d d&�dBdC�Z"ed&�dDdE�Z#d d&�dFdG�Z$dHdI� Z%dedJdK�Z&dfd d dL�dMdN�Z'eed2�dOdP�Z(eed2�dQdR�Z)eed2�dSdT�Z*dgd e edU�dVdW�Z+dXdY� Z,d d&�dZd[�Z-e.j/d\d]�Z0d^ed_< ee d d`�dadb�Z1ed d-�dcdd�Z2d S )h�Channeli @ i F� _send_pingsr � _out_sequence� _out_window� _ack_byteszset[asyncio.Task]�_tasksN�JsonObject | None� _close_argsz ClassVar[str]r) r z&ClassVar[Sequence[tuple[str, object]]]r zClassVar[Sequence[str]]r5 � � is_binaryz codecs.IncrementalDecoder | None�decoder)�command�messager2 c C s� |dkr�t � | _t|d�| _t|ddd�r0d| _t|ddgd �d u| _t|d d �| _t|d d gd �d u| _ d | _ | � � | � |� np|d kr�| � � n^|dkr�| �� nL|dkr�| �� n:|dkr�| �|� n&|dkr�| �|� n|dkr�| �|� d S )N�open�channelz flow-controlF)�defaultTz send-acks�bytes�grouprW Zbinary�raw�ready�done�close�ping�pongr8 )�setrM r rV r rI r rL rY rQ rR Zfreeze_endpoint�do_open�do_ready�do_done�do_close�do_ping�do_pong� do_options)r- rS rT r r r! � do_controlv s. zChannel.do_control)rV rS rT r2 c C s� | j d urd S zLz| �||� W n6 tyV } z tdt|�d�|�W Y d }~n d }~0 0 W n2 ty� } z| �|�� � W Y d }~n d }~0 0 d S )N�protocol-error�rT )rO rh r rG r= r] � get_attrs)r- rV rS rT �excr r r! �do_channel_control� s ,zChannel.do_channel_controlz str | None)�hostrY �_messager2 c C s< | j d urd S |d urd S |d ur0| j|kr0d S | �� d S r )rO rY rd )r- rn rY ro r r r! �do_kill� s zChannel.do_killr; c C s t �d S r ��NotImplementedError�r- r8 r r r! ra � s zChannel.do_openr1 c C s d S r r r? r r r! rb � s zChannel.do_readyc C s d S r r r? r r r! rc � s zChannel.do_donec C s | � � d S r �r] r? r r r! rd � s zChannel.do_close�rT r2 c C s t ddd��d S )Nz not-supportedz)This channel does not implement "options"rj )rG �r- rT r r r! rg � s zChannel.do_optionsc C s | � |� d S r )� send_pongrv r r r! re � s zChannel.do_ping��datar2 c C s | j r| jdt|�d� d S )NZack)rX )rL � send_controlr �r- ry r r r! �send_ack� s zChannel.send_ack)rV ry r2 c C s^ | j d urd S z| �|�s$| �|� W n2 tyX } z| �|�� � W Y d }~n d }~0 0 d S r )rO �do_datar| rG r] rk )r- rV ry rl r r r! �do_channel_data� s zChannel.do_channel_dataz bool | Nonec C s ~| � � dS )a Handles incoming data to the channel. Return value is True if the channel takes care of send acks on its own, in which case it should call self.send_ack() on `data` at some point. None or False means that the acknowledgement is sent automatically.Trt r{ r r r! r} � s zChannel.do_data)�kwargsr2 c K s | � � | jf ddi|�� d S )NrS r[ )Z thaw_endpointrz )r- r r r r! r[ � s z Channel.ready��final)ry r� r2 c C sN z| j j||d�W S tyH } z tdt|�d�|�W Y d }~n d }~0 0 d S )Nr� ri rj )rR �decode�UnicodeDecodeErrorrG r= )r- ry r� rl r r r! Z__decode_frame� s zChannel.__decode_framec C s( | j d ur| jddd� | jdd� d S )Nr# Tr� r\ )rS )rR �_Channel__decode_framerz r? r r r! r\ � s z Channel.donec C s | j d uS r )rO r? r r r! � is_closing� s zChannel.is_closingc C s | � | j� d S r )Zshutdown_endpointrO r? r r r! � _close_now� s zChannel._close_nowc C s( | j �|� | jd ur$| j s$| �� d S r )rM �removerO r� )r- �taskr r r! � _task_done� s zChannel._task_donec C s& t �|�}| j�|� |�| j� |S )z�Create a task associated with the channel. All tasks must exit before the channel can close. You may not create new tasks after calling .close(). )�asyncio� create_taskrM �add�add_done_callbackr� )r- � coroutine�namer� r r r! r� � s zChannel.create_task)� close_argsr2 c C s* | j durdS |pi | _ | js&| �� dS )z�Requests the channel to be closed. After you call this method, you won't get anymore `.do_*()` calls. This will wait for any running tasks to complete before sending the close message. N)rO rM r� )r- r� r r r! r] s z Channel.closec C sX | � | j|� | jrL| jt|� }| jtj |tj krF| jd|d� || _| j| jk S )a� Send binary data and handle book-keeping for flow control. The flow control is "advisory". The data is sent immediately, even if it's larger than the window. In general you should try to send packets which are approximately Channel.BLOCK_SIZE in size. Returns True if there is still room in the window, or False if you should stop writing for now. In that case, `.do_resume_send()` will be called later when there is more room. Be careful with text channels (i.e. without binary="raw"): you are responsible for ensuring that @data is valid UTF-8. This isn't validated here for efficiency reasons. r^ )rS �sequence) Zsend_channel_datarV rI rJ r rH � BLOCK_SIZErz rK )r- ry Z out_sequencer r r! � send_bytes s zChannel.send_bytesc C s< | j r| �|�S | jdu r,t�d�dd�| _| �| �|��S )aD Send data and transparently handle UTF-8 for text channels Use this for channels which can be text, but are not guaranteed to get valid UTF-8 frames -- i.e. multi-byte characters may be split across frames. This is expensive, so prefer send_text() or send_bytes() wherever possible. Nzutf-8�strict)�errors)rQ r� rR �codecs�getincrementaldecoder� send_textr� r{ r r r! � send_data1 s zChannel.send_datac C s | � |�� �S )z�Send UTF-8 string data and handle book-keeping for flow control. Similar to `send_bytes`, but for text data. The data is sent as UTF-8 encoded bytes. )r� �encoder{ r r r! r� B s zChannel.send_text)�msgr r2 c K s | j �t||��d }| �|�S )N� )� json_encoderr� r r� )r- r� r Zprettyr r r! � send_jsonI s zChannel.send_jsonc C s@ | j st�d| j� d S |d tj | _| j| jk r<| �� d S )NzGot wild pong on channel %sr� ) rI �loggerZwarningrV rH � SEND_WINDOWrK rJ �do_resume_sendrv r r r! rf M s zChannel.do_pongc C s dS )z<Called to indicate that the channel may start sending again.Nr r? r r r! r� V s zChannel.do_resume_send� )�indentzClassVar[json.JSONEncoder]r� )rS r r2 c K s | j | j|d fi |�� d S r �Zsend_channel_controlrV )r- rS r r r r! rz \ s zChannel.send_controlc C s | � | jd|� d S )Nr_ r� rv r r r! rw _ s zChannel.send_pong)N)N)N)3rA rB rC r� r� rI rE rD rJ �intrK rO r r5 rV rY r= r rh rm rp ra rb rc rd rg re rX r| r~ r} r r[ r� r\ r� r� r� r� r] r� r� r� r� rf r� �jsonZ JSONEncoderr� rz rw r r r r! rH [ sX rH c @ sV e Zd ZU dZdZded< dZeed< dZded< dZ d ed < dZ ded < d Z eed < d Z eed< e jee jd�dd�Zedd�dd�Zddd�dd�Ze jdd�dd�Zed �d d �Zd dd �d!d"�Zedd#�d$d%�Zdd �d&d'�Zdd �d(d)�Zedd#�d*d+�Z dd �d,d-�Z dd �d.d/�Z ed �d0d1�Z d2d3� Z dd �d4d5�Z!dd �d6d7�Z"dS )8�ProtocolChannela; A channel subclass that implements the asyncio Protocol interface. In effect, data sent to this channel will be written to the connected transport, and vice-versa. Flow control is supported. The default implementation of the .do_open() method calls the .create_transport() abstract method. This method should return a transport which will be used for communication on the channel. Otherwise, if the subclass implements .do_open() itself, it is responsible for setting up the connection and ensuring that .connection_made() is called. Nzasyncio.Transport | None� _transportT� _send_pongsrN � _last_pingz&asyncio.Task[asyncio.Transport] | None�_create_transport_task� _ready_infoF� _close_on_eof�_eof)�loopr8 r2 c � s t �dS )a Creates the transport for this channel, according to options. The event loop for the transport is passed to the function. The protocol for the transport is the channel object, itself (self). This needs to be implemented by the subclass. Nrq )r- r� r8 r r r! �create_transportz s z ProtocolChannel.create_transportr; c C s. t �� }t �| �||��| _| j�| j� d S r )r� �get_running_loopr� r� r� r� �create_transport_done)r- r8 r� r r r! ra � s zProtocolChannel.do_openz asyncio.Task[asyncio.Transport])r� r2 c C s| d | _ z |�� }W n4 tyF } z | �|�� � W Y d }~d S d }~0 0 | �|� | jd urp| jf i | j�� n| �� d S r )r� r6 rG r] rk �connection_mader� r[ )r- r� � transportrl r r r! r� � s z%ProtocolChannel.create_transport_done)r� r2 c C s || _ d S r )r� )r- r� r r r! r� � s z ProtocolChannel.connection_mader1 c C s i S r r r? r r r! �_get_close_args� s z ProtocolChannel._get_close_argszException | None)rl r2 c C s | � | �� � d S r )r] r� )r- rl r r r! �connection_lost� s z ProtocolChannel.connection_lostrx c C s | j �|� d S r )r� �writer{ r r r! r} � s zProtocolChannel.do_datac C s | j �� r| j �� d S r )r� Z can_write_eofZ write_eofr? r r r! rc � s zProtocolChannel.do_donec C s | j d ur| j �� d S r )r� r] r? r r r! rd � s zProtocolChannel.do_closec C sP z| � |�s| j�� W n2 tyJ } z| �|�� � W Y d }~n d }~0 0 d S r )r� r� Z pause_readingrG r] rk )r- ry rl r r r! � data_received� s z ProtocolChannel.data_receivedc C s | j �� d S r )r� Zresume_readingr? r r r! r� � s z ProtocolChannel.do_resume_sendc C s d| _ | jr| j�� dS )a� Mark the channel to be closed on EOF. Normally, ProtocolChannel tries to keep the channel half-open after receiving EOF from the transport. This instructs that the channel should be closed on EOF. If EOF was already received, then calling this function will close the channel immediately. If you don't call this function, you are responsible for closing the channel yourself. TN)r� r� r� r] r? r r r! � close_on_eof� s z ProtocolChannel.close_on_eofc C s d| _ | �� | j S �NT)r� r\ r� r? r r r! � eof_received� s z ProtocolChannel.eof_receivedc C s | j r| �|� n|| _d S r )r� rw r� rv r r r! re � s zProtocolChannel.do_pingc C s d| _ d S )NF)r� r? r r r! � pause_writing� s z ProtocolChannel.pause_writingc C s& d| _ | jd ur"| �| j� d | _d S r� )r� r� rw r? r r r! �resume_writing� s z ProtocolChannel.resume_writing)#rA rB rC �__doc__r� rD r� rE r� r� r� r� r� r� �AbstractEventLoopr Z Transportr� ra r� Z BaseTransportr� r� r� rX r} rc rd r� r� r� r� re r� r� r r r r! r� c s0 r� c @ s� e Zd ZU dZded< ejed< dZedd�dd �Z edd�d d �Z d d �dd�Z e dd�dd�Z ddddd�dd�Zedd�dd �Zdd �d d �Zedd�d d �Zdd �d!d"�Zdd �d#d$�Zedd%�d&d'�Ze ed�d(d)�ZdS )*� AsyncChannelaA A subclass for async/await-style implementation of channels, with flow control This subclass provides asynchronous `read()` and `write()` calls for subclasses, with familiar semantics. `write()` doesn't buffer, so the `done()` method on the base channel class can be used in a way similar to `shutdown()`. A high-level `sendfile()` method is available to send the entire contents of a binary-mode file-like object. The subclass must provide an async `run()` function, which will be spawned as a task. The task is cancelled when the channel is closed. On the receiving side, the channel will respond to flow control pings to indicate that it has received the data, but only after it has been consumed by `read()`. On the sending side, write() will block if the channel backs up. z(asyncio.Queue[bytes | JsonObject | None]� receive_queuer� NrN r; c � s t �d S r rq rs r r r! �run s zAsyncChannel.runc � s� z$t �� | _| �| �|�I d H � W n� t jy@ | �� Y n� typ } z| �|�� � W Y d }~nfd }~0 ty� } z | �dt |�d�� W Y d }~n0d }~0 t y� | �dt � � d�� � Y n0 d S )Nri )�problemrT zinternal-error)r� �cause) r� r� r� r] r� ZCancelledErrorrG rk r r= � BaseException� traceback� format_exc)r- r8 rl r r r! � run_wrapper s "( zAsyncChannel.run_wrapperz bytes | Noner1 c � sF | j �� I d H }|d u r d S t|t�r2| �|� q | �|� |S q d S r )r� r9 r< r rw r| )r- �itemr r r! �read s zAsyncChannel.readrx c � s& | � |�s"| j�� | _| jI d H d S r )r� r� Z create_future� write_waiterr{ r r r! r� ! s zAsyncChannel.writezCallable[_P, _T]z_P.argsz _P.kwargsr )�fn�argsr r2 c � s" | j jd |g|�R i |��I d H S r )r� �run_in_executor)r- r� r� r r r r! � in_thread& s zAsyncChannel.in_thread)�streamr2 c � sf |�N | j �d |jtj�I d H }|dkr*q<| �|�I d H q| �� W d � n1 sX0 Y d S )Nr# )r� r� r� rH r� r� r\ )r- r� ry r r r! �sendfile) s zAsyncChannel.sendfilec C s | j d ur | j �d � d | _ d S r )r� Z set_resultr? r r r! r� 3 s zAsyncChannel.do_resume_sendc C s4 t �� | _| j| �|�| jj� d|� d�d�| _d S )Nz .run_wrapper(�))r� )r� ZQueuer� r� r� r0 rA � _run_taskrs r r r! ra 8 s �zAsyncChannel.do_openc C s | j �d � d S r �r� Z put_nowaitr? r r r! rc = s zAsyncChannel.do_donec C s | j �� d S r )r� �cancelr? r r r! rd @ s zAsyncChannel.do_closeru c C s | j �|� d S r r� rv r r r! re C s zAsyncChannel.do_pingc C s | j �|� dS r� r� r{ r r r! r} F s zAsyncChannel.do_data)rA rB rC r� rD r� r� r� r r� r� r� rX r� r� r r� r� ra rc rd re rE r} r r r r! r� � s r� c @ sH e Zd ZU dZded< edd�dd�Zedd�dd �Zdd �d d �ZdS ) �GeneratorChannela A trivial Channel subclass for sending data from a generator with flow control. Calls the .do_yield_data() generator with the options from the open message and sends the data which it yields. If the generator returns a value it will be used for the close message. z"Generator[bytes, None, JsonObject]� _GeneratorChannel__generatorr; c C s t �d S r rq rs r r r! � do_yield_dataT s z GeneratorChannel.do_yield_dataNc C s | � |�| _| �� d S r )r� r� r� rs r r r! ra W s zGeneratorChannel.do_openr1 c C sT z| � t| j��rqW n8 tyN } z | �� | �|j� W Y d }~n d }~0 0 d S r )r� �nextr� � StopIterationr\ r] �value)r- �stopr r r! r� [ s z GeneratorChannel.do_resume_send) rA rB rC r� rD r r� ra r� r r r r! r� K s r� )+r� r� r� Zloggingr� �typingr r r r r r r r Zjsonutilr r r r r r r Zprotocolr r r r r Z getLoggerrA r� � TYPE_CHECKING�TypeVarr Z ParamSpecr r rG rH �Protocolr� r� r� r r r r! �<module> s, ($ = f