3
uAc @ s d Z ddlmZ ddlZddlZddlmZ ddlmZ ddl
m Z d d
d gZ da
d d
Zeadd Zdd Zdd Zdadadd ZG dd
d
ejjZG dd d eeejjZdS )zMThis module contains convenience functions for using dbus-activated services. )absolute_importN)with_metaclass )_glib )polkitObject
InterfaceType set_mainloopc C s t j d S )N) __mainloop__quit r
r
/usr/lib/python3.6/service.py__glib_quit_cb__) s r c C s | a d S )N)r )Zmainloopr
r
r r
4 s c C s | a d S )N) __quit_cb__)quit_cbr
r
r set_quit_cb9 s r c C s
t d S )N)r r
r
r
r r > s r Z __slip_dbus_service_sender__ __slip_dbus_service_reply_cb__ __slip_dbus_service_error_cb__c s j d k rj dntdjd k r4j dnt d fdd}xLdd tD D ]6}|dkr|_ ql|dkr |_qlt||t| qlW j|_|S ) NFTc s j }|d k rVd d r4 = rLd = d = j| t dtdd |d k r r
fdd}fdd}tj| ||d n f}j |S d S )
Nr r Z_slip_polkit_auth_required default_polkit_auth_requiredc s | rrf qd }yf}W n& t k
rX } z
|}W Y d d }~X nX |rh| q|d krx q| ntj j d S )N) Exceptionr ZNotAuthorizedExceptiontimeout_restart)Zis_autherrorresulte) action_iderror_cbkmethodmethod_is_asyncpreply_cbselfr
r
reply_handlerq s
z:wrap_method..wrapped_method..reply_handlerc s | j d S )N)r )r )r r" r
r
error_handler s z:wrap_method..wrapped_method..error_handler)r# r$ )get sender_seengetattrr Z IsSystemBusNameAuthorizedAsyncr )r" r r senderr# r$ Zretval)async_callbackshide_async_callbackshide_sender_keywordr r sender_keyword)r r r r r! r" r wrapped_method[ s,
" z#wrap_method..wrapped_methodc s s" | ]}|d d dkr|V qd S )N Z_dbus_r
).0xr
r
r s z wrap_method.._dbus_sender_keyword_dbus_async_callbacks)r2 SENDER_KEYWORDr3 ASYNC_CALLBACKSdirsetattrr' __name__)r r- attrr
)r) r* r+ r r r, r wrap_methodH s(
Er: c s e Zd Z fddZ ZS )r c sD x,|j D ] \}}t|ddr
t|||< q
W tt| j| |||S )NZ_dbus_is_methodF)itemsr' r: superr __new__)clsnamebasesZdctZattrnamer9 ) __class__r
r r= s zInterfaceType.__new__)r8
__module__ __qualname__r=
__classcell__r
r
)rA r r s c sb e Zd ZdZdZeZdZe Zi Z i Z
dZ d fdd Z dd Z
dd Zdd
d Zd d
Z ZS )r F Nc s2 t t| j||| |d kr(| jj| _n|| _d S )N)r< r __init__rA
persistent)r" connZ object_pathZbus_namerG )rA r
r rF s zObject.__init__c C s2 | j r ttjdkr t dS d t_| jt_dS )Nr F)rG lenr sendersr current_sourcedefault_durationduration)r" r
r
r _timeout_cb s zObject._timeout_cbc C s | j }| r||ftjkrtjj||f tj| j| ttj| dkrjtj| j tj|= tj|= | j rttjdkrtjd krt d S )Nr )
connectionr rJ removeconnections_sendersrI connections_smobjsrG rK r )r" r? Z old_ownerZ new_ownerrH r
r
r _name_owner_changed s
zObject._name_owner_changedc C sf |s | j j}tj s |tjkr$|t_| j s:ttjdkrbtjrLtj tj tj
tjd | j t_d S )Nr i ) rA rL r rM rG rI rJ rK GLibZ
source_removeZ timeout_addrN )r" rM r
r
r r s zObject.timeout_restartc C sp || j ftjkrltjj|| j f | j tjkrZt tj| j < | j j| jdd|dtj| j < tj| j j| d S )NZNameOwnerChangedzorg.freedesktop.DBus)Zhandler_functionZ signal_nameZdbus_interfaceZarg1) rO r rJ addrQ setZadd_signal_receiverrS rR )r" r( r
r
r r& s zObject.sender_seen)NNNN)N)r8 rB rC rG rL rM rK rV rJ rQ rR r rF rN rS r r& rD r
r
)rA r r s
)r r )__doc__Z
__future__r ZdbusZ dbus.serviceZsixr Z _wrappersr rT r __all__r r r r
r r r4 r5 r: Zservicer r r
r
r
r s&
g