0x1949 Team - FAZEMRX - MANAGER
Edit File: low_level.cpython-310.pyc
o ���`�J � @ s d dl mZ d dlmZmZmZ d dlZd dlmZ G dd� de �Z G dd� de�Z e j e j d �ZG d d � d e�ZG d d � d e�ZG dd� de�Zdd� ZG dd� d�ZG dd� de�ZG dd� de�Zedd�edd�edd �e� ed d �ed d �ed d!�ed d"�ed d#�e� d$� ZG d%d&� d&�Ze�eed' �eed' �eed( �d)�� G d*d+� d+�ZG d,d-� d-e�ZG d.d/� d/�ZG d0d1� d1�Z d2d3� Z d4d5� Z eeed( e � g��Z d6d7� Z d8d9d9d9d'd9d9d:d'd;� Z!d<d=� Z"G d>d?� d?�Z#G d@dA� dA�Z$G dBdC� dC�Z%G dDdE� dE�Z&dS )F� )�deque)�Enum�IntEnum�IntFlagN)�Optionalc @ s e Zd ZdZdS )�SizeLimitErrorz�Raised when trying to (de-)serialise data exceeding D-Bus' size limit. This is currently only implemented for arrays, where the maximum size is 64 MiB. N)�__name__� __module__� __qualname__�__doc__� r r �3/usr/lib/python3/dist-packages/jeepney/low_level.pyr s r c @ s$ e Zd ZdZdZdd� Zdd� ZdS )� Endianness� � c C � | t ju rdS dS )N�<�>�r �little��selfr r r � struct_code � zEndianness.struct_codec C r )N� l� Br r r r r � dbus_code r zEndianness.dbus_codeN)r r r r �bigr r r r r r r s r )r r c @ s e Zd ZdZdZdZdZdS )� MessageTyper r � � N)r r r � method_call� method_return�error�signalr r r r r s r c @ s e Zd ZdZdZdZdS )� MessageFlagr r r N)r r r �no_reply_expected� no_auto_start� allow_interactive_authorizationr r r r r% # s r% c @ s0 e Zd ZdZdZdZdZdZdZdZ dZ d Z d S ) � HeaderFieldsr r r r � � � � � N) r r r �path� interface�member� error_name� reply_serial� destination�sender� signature�unix_fdsr r r r r) ) s r) c C s || | }||kr dS |S �Nr r )�pos�step�padr r r �padding5 s r< c @ s8 e Zd Zdd� Zd dd�Zddd�Zd d � Zd d � ZdS )� FixedTypec C s | | _ | _|| _d S �N)�size� alignmentr )r r? r r r r �__init__= s zFixedType.__init__r c C sJ |t || j�7 }|�� | j }t�||||| j � �d }||| j fS r8 )r< r@ r �struct�unpackr? )r �bufr9 � endianness�fds�code�valr r r � parse_dataA s zFixedType.parse_dataNc C s. dt || j� }|�� | j }|t�||� S )N� )r< r@ r rB �pack)r �datar9 rE rF r; rG r r r � serialiseG s zFixedType.serialisec C s d� | j| j�S )NzFixedType({!r}, {!r}))�formatr? r r r r r �__repr__L s zFixedType.__repr__c C s$ t |�tu o| j|jko| j|jkS r> )�typer= r? r �r �otherr r r �__eq__O s �zFixedType.__eq__�r r> )r r r rA rI rM rO rS r r r r r= < s r= c s: e Zd Z� fdd�Zd � fdd� Zdd� Zdd � Z� ZS ) �Booleanc � t � �dd� d S �Nr �I��superrA r �� __class__r r rA U r zBoolean.__init__r c s t � �|||�\}}t|�|fS r> )rZ rI �bool)r rD r9 rE rF rH �new_posr[ r r rI X � zBoolean.parse_datac C � dS )Nz Boolean()r r r r r rO \ � zBoolean.__repr__c C � t |�tu S r> )rP rU rQ r r r rS _ � zBoolean.__eq__rT )r r r rA rI rO rS � __classcell__r r r[ r rU T s rU c sH e Zd Z� fdd�Zd � fdd� Zd� fdd� Zd d � Zd d � Z� ZS )�FileDescriptorc rV rW rY r r[ r r rA d r zFileDescriptor.__init__r c s t � �|||�\}}|| |fS r> )rZ rI )r rD r9 rE rF �idxr^ r[ r r rI g r_ zFileDescriptor.parse_dataNc sx |d u rt d��t|d�r|�� }t|t�st|t�s td��|dk r+td|� d���|�|� t � � t |�d ||�S )Nz+Sending FDs is not supported or not enabled�filenozYCannot use {data!r} as file descriptor. Expected an int or an object with fileno() methodr z#File descriptor can't be negative (�)r ) � RuntimeError�hasattrrg � isinstancer] �int� TypeError� ValueError�appendrZ rM �len)r rL r9 rE rF r[ r r rM k s zFileDescriptor.serialisec C r` )NzFileDescriptor()r r r r r rO { ra zFileDescriptor.__repr__c C rb r> )rP re rQ r r r rS ~ rc zFileDescriptor.__eq__rT r> ) r r r rA rI rM rO rS rd r r r[ r re c s re r �Br �h�Hr �irX r- �q�Q�d) �y�nru �brt �u�x�trw rr c @ sD e Zd Zdd� Zedd� �Zddd�Zdd d �Zd d � Zd d� Z dS )� StringTypec C � || _ d S r> )� length_type)r r� r r r rA � � zStringType.__init__c C s | j jS r> )r� r? r r r r r@ � s zStringType.alignmentr c C sR | j �|||�\}}|| }|||� �d�}|||d � dks#J �||d fS )N�utf-8r rJ )r� rI �decode)r rD r9 rE rF �length�endrH r r r rI � s zStringType.parse_dataNc C sB t |t�s td�|���|�d�}| j�t|�||�}|| d S )NzExpected str, not {!r}r� rJ )rk �strrm rN �encoder� rM rp )r rL r9 rE rF �encoded�len_datar r r rM � s zStringType.serialisec C � d� | j�S )NzStringType({!r}))rN r� r r r r rO � rc zStringType.__repr__c C � t |�tu o | j|jkS r> )rP r~ r� rQ r r r rS � s �zStringType.__eq__rT r> ) r r r rA �propertyr@ rI rM rO rS r r r r r~ � s r~ r{ rx )�s�o�gc @ s< e Zd ZdZdd� Zddd�Zddd �Zd d � Zd d � ZdS )�Structr- c C s$ t dd� |D ��r td��|| _d S )Nc s s � | ]}t |t�V qd S r> )rk � DictEntry)�.0�fr r r � <genexpr>� s � z"Struct.__init__.<locals>.<genexpr>z Found dict entry outside array)�anyrm �fields�r r� r r r rA � s zStruct.__init__r c C sJ |t |d�7 }g }| jD ]}|j||||d�\}}|�|� q t|�|fS )Nr- �rF )r< r� rI ro �tuple)r rD r9 rE rF �res�field�vr r r rI � s zStruct.parse_dataNc C s� t |t�s td�|���t|�t| j�kr"td�t|�t| j����dt|| j� }|t|�7 }g }t || j�D ]\}}|� |j ||||d�� |t|d �7 }q8|d� |� S )NzExpected tuple, not {!r}z{} entries for {} fieldsrJ r� ���� ) rk r� rm rN rp r� rn r< r@ �zipro rM �join) r rL r9 rE rF r; � res_pieces�itemr� r r r rM � s � zStruct.serialisec C s d� t| �j| j�S )Nz{}({!r}))rN rP r r� r r r r rO � s zStruct.__repr__c C s t |�t | �u o | j|jkS r> )rP r� rQ r r r rS � s z Struct.__eq__rT r> ) r r r r@ rA rI rM rO rS r r r r r� � s r� c s e Zd Z� fdd�Z� ZS )r� c sT t |�dkrtdt |� ��t|d ttf�s"td�t|d ����t� �|� d S )Nr z%Dict entry must have 2 fields, not %dr z5First field in dict entry must be simple type, not {}) rp rm rk r= r~ rN rP rZ rA r� r[ r r rA � s ��zDictEntry.__init__)r r r rA rd r r r[ r r� � s r� c @ sF e Zd ZdZedd�Zdd� Zddd�Zdd d �Zd d � Z d d� Z dS )�Arrayr rX c C r r> )�elt_type)r r� r r r rA � r� zArray.__init__r c C s� | j �|||�\}}|t|| jj�7 }|| }| jtd kr&|||� |fS g }||k rA| jj||||d�\}}|�|� ||k s,t| jt�rKt |�}||fS )Nrx r� ) r� rI r< r� r@ � simple_typesro rk r� �dict) r rD r9 rE rF r� r� r� r� r r r rI � s � zArray.parse_dataNc C sD d}t | jt�rt |t�r|�� }n| jtd kr!t |t�r!d}n t |t�s-td� |���t | jt �rA| jj t |� dkrAt d��t|| j�}|| d }t|| jj�}|rY|} n1|| } | d } g } |D ] } | �| jj| | ||d�� | t | d �7 } | | kr�t d��qed �| �} | j�t | �|| |�}d | | d | | S ) NFrx Tz Not suitable for array: {!r}i z Array size exceeds 64 MiB limitr r� r� r� rJ )rk r� r� r� �itemsr� �bytes�listrm rN r= r? rp r r< r@ ro rM r� r� )r rL r9 rE rF � data_is_bytes�pad1�pos_after_length�pad2rD �data_pos� limit_pos�chunksr� r� r r r rM � s: �� zArray.serialisec C r� )Nz Array({!r}))rN r� r r r r rO % rc zArray.__repr__c C r� r> )rP r� r� rQ r r r rS ( � z Array.__eq__rT r> ) r r r r@ r= r� rA rI rM rO rS r r r r r� � s & r� c @ s4 e Zd ZdZd dd�Zd dd�Zdd � Zd d � ZdS )�Variantr r c C sD t d �|||�\}}tt|��}|j||||d�\}}||f|fS �Nr� r� )r� rI �parse_signaturer� )r rD r9 rE rF �sig�valtyperH r r r rI / s zVariant.parse_dataNc C sD |\}}t t|��}td �|||�}||j||t|� ||d� S r� )r� r� r� rM rp )r rL r9 rE rF r� r� �sig_bufr r r rM 8 s �zVariant.serialisec C r` )Nz Variant()r r r r r rO @ ra zVariant.__repr__c C rb r> )rP r� rQ r r r rS C rc zVariant.__eq__rT r> )r r r r@ rI rM rO rS r r r r r� , s r� c C s� | � d�}|dkrtt| ��S |dkrt� S |dkr8g }| d dkr/|�t| �� | d dks"| � d� t|�S |dkrZg }| d dkrQ|�t| �� | d dksD| � d� t|�S |dv rbtd ��t| S ) z-Parse a symbolic signature into objects. r �ar� �(rh �{�}z)}zUnexpected end of struct) �popr� r� r� ro r� r� rn r� )r� �tokenr� �der r r r� F s, � � r� c C st t �d| d d� �\}t| }t �|�� d | dd� �\}t �|�� d | dd� �\}d| }|t|d� | S )N�cr rX r r- � � )rB rC � endian_mapr r< )rD �endian� body_length�fields_array_len� header_lenr r r � calc_msg_sizea s r� c C s$ t �| d|�\}}dd� |D �|fS )Nr� c S s i | ] \}}t |�|d �qS )r )r) )r� �kr� r r r � <dictcomp>o s z'parse_header_fields.<locals>.<dictcomp>)�_header_fields_typerI )rD rE �lr9 r r r �parse_header_fieldsm s r� r� r� r� ) r r r r r* r+ r, r- r. c C s$ dd� t | �� �D �}t�|d|�S )Nc S s" g | ] \}}|j t| |ff�qS r )�value�header_field_codes)r� rt r� r r r � <listcomp>� s " z+serialise_header_fields.<locals>.<listcomp>r� )�sortedr� r� rM )rw rE r� r r r �serialise_header_fields s r� c @ s2 e Zd Zdd� Zdd� Zd dd�Zedd � �ZdS ) �Headerc C s6 || _ t|�| _t|�| _|| _|| _|| _|| _dS )z�A D-Bus message header It's not normally necessary to construct this directly: use higher level functions and methods instead. N) rE r � message_typer% �flags�protocol_versionr� �serialr� )r rE r� r� r� r� r� r� r r r rA � s zHeader.__init__c C s$ d� | j| j| j| j| j| j| j�S )Nz7Header({!r}, {!r}, {!r}, {!r}, {!r}, {!r}, fields={!r}))rN rE r� r� r� r� r� r� r r r r rO � s �zHeader.__repr__Nc C sP | j �� d }|d u r| j}t�|| j �� | jj| j| j | j |�t | j | j � S )N�cBBBII) rE r r� rB rK r r� r� r� r� r� r� r� )r r� r� r r r rM � s � �zHeader.serialisec C sj t �d|d d� �\}}}}t| }t �|�� d |dd� �\}}t||�\}} | |||||||�| fS )N�cBBBr �IIr� )rB rC r� r r� ) �clsrD r� �msgtyper� �pv�bodylenr� r� r9 r r r � from_buffer� s zHeader.from_bufferr> )r r r rA rO rM � classmethodr� r r r r r� � s r� c @ sH e Zd ZdZdd� Zdd� Zeddedd fd d ��Zddefd d �Z d S )�Messagez�Object representing a DBus message. It's not normally necessary to construct this directly: use higher level functions and methods instead. c C s || _ || _d S r> )�header�body)r r� r� r r r rA � s zMessage.__init__c C s d� t| �j| j| j�S )Nz{}({!r}, {!r}))rN rP r r� r� r r r r rO � r� zMessage.__repr__r rD �returnc C s� t �|�\}}|j�tjd�}|t|�kr"td|� dt|�� d���|d |� }d}tj|jv rJ|jtj }t t d| ��}|j |||j |d�d }t ||�S )Nr zMessage expects z FDs, but only z were receivedr �(%s)r� )r� r� r� �getr) r7 rp rn r6 r� r� rI rE r� ) r� rD rF r� r9 �n_fdsr� r� � body_typer r r r� � s � zMessage.from_bufferNc C s� | j j}tj| j jv r%| j jtj }ttd| ��}|j| jd||d�}nd}t |�| j _ |r8t |�| j jtj < | j j|d�}dt t |�d� }|| | S )a� Convert this message to bytes. Specifying *serial* overrides the ``msg.header.serial`` field, so a connection can use its own serial number without modifying the message. If file-descriptor support is in use, *fds* should be a :class:`array.array` object with type ``'i'``. Any file descriptors in the message will be added to the array. If the message contains FDs, it can't be serialised without this array. r� r r� r� )r� rJ r- ) r� rE r) r6 r� r� r� rM r� rp r� r7 r< ) r r� rF r� r� r� �body_buf� header_bufr; r r r rM � s zMessage.serialiserT )NN) r r r r rA rO r� r� r� rM r r r r r� � s r� c @ sJ e Zd ZdZdd� Zddefdd�Zdd � Zd d � Zd e e fd d�Z dS )�Parserz8Parse DBus messages from a stream of incoming data. c C s t � | _g | _d | _d S r> )� BufferPiperD rF � next_msg_sizer r r r rA � s zParser.__init__r rL c C s | j �|� | j�|� dS )z)Provide newly received data to the parserN)rD �writerF �extend)r rL rF r r r �add_data� s zParser.add_datac C s | � |� tt| jd��S )zhFeed the parser newly read data. Returns a list of messages completed by the new data. N)r� r� �iter�get_next_message)r rL r r r �feed� s z Parser.feedc C s> | j j}|dk r d| S | jdu rt| j �d��| _| j| S )z�How many bytes can be received without going beyond the next message? This is only used with file-descriptor passing, so we don't get too many FDs in a single recvmsg call. r� N)rD �bytes_bufferedr� r� �peek)r �gotr r r � bytes_desired� s zParser.bytes_desiredr� c C s� | j du r| jjdkrt| j�d��| _ | j }|durE| jj|krG| j�|�}tj|| jd�}d| _ |j j � t j d�}| j|d� | _|S dS dS )zqParse one message, if there is enough data. Returns None if it doesn't have a complete message. Nr� r� r )r� rD r� r� r� �readr� r� rF r� r� r� r) r7 )r �nms�raw_msg�msg� fds_consumedr r r r� s �zParser.get_next_messageNrT ) r r r r rA r� r� r� r� r r� r� r r r r r� � s r� c @ sf e Zd ZdZdd� Zdefdd�Zdefdd �Zded efd d �Z defd d�Z ded efdd�Z dS )r� z�A place to store received data until we can parse a complete message The main difference from io.BytesIO is that read & write operate at opposite ends, like a pipe. c C s t � | _d| _d S r8 )r r� r� r r r r rA ! s zBufferPipe.__init__rz c C s" | j �|� | jt|�7 _d S r> )r� ro r� rp )r rz r r r r� % s zBufferPipe.write�nbytesc c sL � || j ksJ �| jD ]}|d |� }|t|�8 }|V |dkr# d S q d S r8 )r� r� rp )r r� �chunkr r r � _peek_iter) s � ��zBufferPipe._peek_iterr� c C � d� | �|��S )z=Get exactly nbytes bytes from the front without removing themr� )r� r� �r r� r r r r� 2 � zBufferPipe.peekc c s� � || j ksJ � | j�� }| j t|�8 _ |t|�kr n |t|�8 }|V q |d |� ||d � }}|rF| j�|� | j t|�7 _ |V d S r> )r� r� �popleftrp � appendleft)r r� r� �remr r r � _read_iter6 s � � zBufferPipe._read_iterc C r� )z1Take & return exactly nbytes bytes from the frontr� )r� r r r r r r� G r zBufferPipe.readN) r r r r rA r� r� rl r� r� r r� r r r r r� s r� )'� collectionsr �enumr r r rB �typingr rn r r r r r� r r% r) r< r= rU re r� r~ �updater� r� r� r� r� r� r� r� r� r� r� r� r� r� r r r r �<module> sl � �& F � (:5