File: //usr/lib/python3.9/site-packages/dasbus/client/__pycache__/handler.cpython-39.pyc
a
װ_�= � @ s� d dl mZmZ d dlmZ d dlmZ d dlmZ d dl m
Z
d dl m Z d dl
mZ d dlmZmZmZ d d lZe�d
d � e�d d � d d
lmZmZ g d�ZG dd� de�ZG dd� ded�ZG dd� de�Z d S )� )�ABCMeta�abstractmethod)�partial)�
PropertyProxy)� ErrorMapper)�Signal)�DBUS_FLAG_NONE��DBusSpecification)� get_variant�get_variant_type�unwrap_variantN�Gioz2.0�GLib)r r )�
GLibClient�AbstractClientObjectHandler�ClientObjectHandlerc @ s� e Zd ZdZejZeeefdd��Z edeefdd��Z
edd� �Z edefd d
��Z ed d � �Z
ed
d� �Zedd� �Zedd� �Zedd� �ZdS )r z0The low-level DBus client library based on GLib.c
C s |� |||||||| d� S )zVSynchronously call a DBus method.
:return: a result of the DBus call
N)Z call_sync)
�cls�
connection� service_name� object_path�interface_name� method_name�
parameters�
reply_type�flags�timeout� r �9/usr/lib/python3.9/site-packages/dasbus/client/handler.py� sync_call1 s �zGLibClient.sync_callr c C s( |j |||||||
| | j|| fd�
dS )z"Asynchronously call a DBus method.��callback� user_dataN)�call�_async_call_finish) r r r r r r r r r! �
callback_argsr r r r r �
async_callE s �zGLibClient.async_callc s& |\}}|� �fdd�g|�R � dS )z(Finish an asynchronous DBus method call.c s
�� � �S �N)Z call_finishr ��
result_object�
source_objectr r �<lambda>` � z/GLibClient._async_call_finish.<locals>.<lambda>Nr )r r* r) r" r! r% r r( r r$ X s ��z GLibClient._async_call_finishc
C s. |j ||||d|| j||fd�} t| j|| �S )zKSubscribe to a signal.
:return: a callback to unsubscribe
Nr )Zsignal_subscribe�_signal_callbackr �_unsubscribe_signal)
r r r r r � signal_namer! r% r �subscription_idr r r �subscribe_signald s � �zGLibClient.subscribe_signalc
C s |\}} ||g| �R � dS �z8A callback that is called when a DBus signal is emitted.Nr )
r r Z sender_namer r r/ r r" r! r% r r r r- } s zGLibClient._signal_callbackc C s |� |� dS )zUnsubscribe from a signal.N)Zsignal_unsubscribe)r r r0 r r r r. � s z GLibClient._unsubscribe_signalc C s t |tj�otj�|�S )zIs it a remote DBus error?)�
isinstancer �Errorr � DBusError�is_remote_error�r �errorr r r r6 � s
�zGLibClient.is_remote_errorc C s t j�|�S )z)Get a DBus name of the remote DBus error.)r r5 Zget_remote_errorr7 r r r �get_remote_error_name� s z GLibClient.get_remote_error_namec C s: | � |�}|j}d�d|�}|�|�r6|t|�d� S |S )z'Get a message of the remote DBus error.z{}:{}: z GDBus.ErrorN)r9 �message�format�
startswith�len)r r8 �namer: �prefixr r r �get_remote_error_message� s
z#GLibClient.get_remote_error_messageN)�__name__�
__module__� __qualname__�__doc__r ZMAXINTZDBUS_TIMEOUT_NONE� classmethodr r r& r$ r1 r- r. r6 r9 r@ r r r r r + s2 � �
�
r c @ s� e Zd ZdZg d�Zdd� Zedd� �Zedd� �Zed d
� �Z e
d d � �Z d
d� Z dd� Z
dd� Ze
dd� �Ze
dd� �Ze
dd� �Ze
dd� �ZdS ) r z-The abstract handler of a remote DBus object.�� _message_bus�
_service_name� _object_path�_specificationc C s || _ || _|| _d| _dS )z�Create a new handler.
:param message_bus: a message bus
:param service_name: a DBus name of the service
:param object_path: a DBus path the object
NrF )�self� message_busr r r r r �__init__� s z$AbstractClientObjectHandler.__init__c C s | j S )z9DBus service name.
:return: a DBus name
)rH �rK r r r r � s z(AbstractClientObjectHandler.service_namec C s | j S )z8DBus object path.
:return: a DBus path
)rI rN r r r r � s z'AbstractClientObjectHandler.object_pathc C s | j s| �� | _ | j S )zDBus specification.)rJ �_get_specificationrN r r r �
specification� s
z)AbstractClientObjectHandler.specificationc C s t � S )zKIntrospect the DBus object.
:return: a DBus specification
r rN r r r rO � s z.AbstractClientObjectHandler._get_specificationc C s" | � ||�}| �t|��}||�S )z�Create a member of the DBus object.
:param interface_name: a name of the interface
:param member_name: a name of the member
:return: a signal, a method or a property
)�_find_member_spec�
_find_handler�type)rK r � member_name�specZhandlerr r r �
create_member� s z)AbstractClientObjectHandler.create_memberc C s | j �||�S )z�Find a specification of the DBus member.
:param interface_name: a name of the interface
:param member_name: a name of the member
:return: a specification of the member
)rP Z
get_member)rK r rT r r r rQ � s �z-AbstractClientObjectHandler._find_member_specc C sD |t ju r| jS |t ju r | jS |t ju r0| jS td�|j ���dS )z�Find a handler for the given member type.
:param member_type: a type of the member
:return: a callback
zUnsupported type: {}N)
r
ZProperty�
_get_propertyZMethod� _get_methodr � _get_signal� TypeErrorr; rA )rK � member_typer r r rR � s
�z)AbstractClientObjectHandler._find_handlerc C s dS )z�Get a proxy of the DBus property.
:param property_spec: a property_specification
:return: a property object
Nr )rK �
property_specr r r rW s z)AbstractClientObjectHandler._get_propertyc C s dS )zGet a proxy of the DBus method.
:param method_spec: a method specification
:return: a callable object
Nr �rK Z method_specr r r rX s z'AbstractClientObjectHandler._get_methodc C s dS )z}Get a proxy of the DBus signal.
:param signal_spec: a signal specification
:return: a signal object
Nr )rK � signal_specr r r rY s z'AbstractClientObjectHandler._get_signalc C s dS )z�Disconnect members of the DBus object.
Unsubscribe from DBus signals and disconnect all
registered callbacks of the proxy signals.
Nr rN r r r �disconnect_members s z.AbstractClientObjectHandler.disconnect_membersN)rA rB rC rD � __slots__rM �propertyr r rP r rO rV rQ rR rW rX rY r_ r r r r r � s,
r )� metaclassc s� e Zd ZdZg d�Zdeef� fdd� Zdd� Zdd � Z d
d � Z
d d
� Z dd� Z dd� Z
dd� Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Z� ZS ) r z$The client handler of a DBus object.)�_client�_signal_factory�
_error_mapper�_subscriptionsNc s2 t � �|||� || _|| _|p$t� | _g | _dS )aB Create a new handler.
:param message_bus: a message bus
:param service_name: a DBus name of the service
:param object_path: a DBus path the object
:param error_mapper: a DBus error mapper
:param client: a DBus client library
:param signal_factory: a signal factory
N)�superrM rc rd r re rf )rK rL r r Z error_mapperZclientZsignal_factory�� __class__r r rM 2 s
z ClientObjectHandler.__init__c C s | � dddd�}t�|�S )zIntrospect the DBus object.z#org.freedesktop.DBus.IntrospectableZ
IntrospectNz(s))� _call_methodr
Zfrom_xml)rK Zxmlr r r rO D s �z&ClientObjectHandler._get_specificationc C sR | � � }| jj| jj| j| j|j|j| j |j
fd�}| j � |� | j � |j
� |S )z Get a proxy of the DBus signal.�r! r% )rd rc r1 rG r rH rI r r> r- �emitrf �appendZ
disconnect)rK r^ �signalZ unsubscriber r r rY O s � z ClientObjectHandler._get_signalc C s |t |�� dS r2 )r
)rK r r! r r r r- e s z$ClientObjectHandler._signal_callbackc C s6 d}d}|j rt| j|�}|jr,t| j|�}t||�S )z!Get a proxy of the DBus property.N)�readabler �_get_property_value�writable�_set_property_valuer )rK r\ �getter�setterr r r rW i s z!ClientObjectHandler._get_propertyc C s | � dddd|j|j�}t|�S )z!Get a value of the DBus property.� org.freedesktop.DBus.PropertiesZGetz(ss)z(v))rj r r> r
)rK r\ Zvariantr r r rp v s �z'ClientObjectHandler._get_property_valuec C s" | � dddd|j|jt|j|��S )z!Set a value of the DBus property.ru �Setz(ssv)N)rj r r> r rS )rK r\ Zproperty_valuer r r rr � s
�z'ClientObjectHandler._set_property_valuec C s t | j|j|j|j|j�S )z(Get a callable proxy of the DBus method.)r rj r r> �in_type�out_typer] r r r rX � s �z ClientObjectHandler._get_methodc O s� |sd}|durt ||�}d}|dur.t|�}| jj| j| j||||f}|�dd�} |�dt� �}
| s�| j| j j
g|�R i |��S | j j |i |�| j | |
fd���S dS )zKCall a DBus method.
:return: a result of the call or None
Nr! r% rk )
r r rG r rH rI �pop�tuple�_get_method_replyrc r r& �_method_callback) rK r r rw rx r �kwargsr �argsr! r% r r r rj � sB
� ������z ClientObjectHandler._call_methodc s |� �fdd�g|�R � dS )z/A callback of an asynchronous DBus method call.c s
�� � �S r' )r{ r �rs rK r r r+ � r, z6ClientObjectHandler._method_callback.<locals>.<lambda>Nr )rK rs r! r% r r r r| � s
��z$ClientObjectHandler._method_callbackc
O sN z||i |��}| � |�W S tyH } z| �|�W Y d}~S d}~0 0 dS )a Get a result of a DBus call.
:param call: a callback
:param args: arguments of the callback
:param kwargs: keyword arguments of the callback
:return: a result of the callback
:raise: an exception raised by the callback
N)�_handle_method_result� Exception�_handle_method_error)rK r# r~ r} �resultr8 r r r r{ � s
z%ClientObjectHandler._get_method_replyc C sL | j �|�s|�| j �|�}| j�|�}| j �|�}||�}||_|d�dS )zcHandle an error of a DBus call.
:param error: an exception raised during the call
N)rc r6 r9 re Zget_exception_typer@ Z dbus_name)rK r8 r> r r: � exceptionr r r r� � s z(ClientObjectHandler._handle_method_errorc C s( t |�}|sdS t|�dkr$|d S |S )zPHandle a result of a DBus call.
:param result: a variant tuple
N� r )r
r= )rK r� �valuesr r r r� � s z)ClientObjectHandler._handle_method_resultc C s | j r| j �� }|� q dS )z&Disconnect members of the DBus object.N)rf ry )rK r! r r r r_ s
z&ClientObjectHandler.disconnect_members)rA rB rC rD r` r r rM rO rY r- rW rp rr rX rj r| r{ r� r� r_ �
__classcell__r r rh r r ( s$ �
1r ) �abcr r � functoolsr Zdasbus.client.propertyr Z dasbus.errorr Z
dasbus.signalr Zdasbus.constantsr Zdasbus.specificationr
Z
dasbus.typingr r r
ZgiZrequire_versionZ
gi.repositoryr r �__all__�objectr r r r r r r �<module> s y