관리-도구
편집 파일: handler.cpython-39.opt-1.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