芝麻web文件管理V1.00
编辑当前文件:/home/conskgoa/doughi.co.uk/dbus.zip
PK {\DD` ` proxies.pynu [ # -*- coding: utf-8 -*- # slip.dbus.proxies -- slightly augmented dbus proxy classes # # Copyright © 2005-2007 Collabora Ltd. <http://www.collabora.co.uk/> # Copyright © 2009, 2011 Red Hat, Inc. # # This program is free software; you can redistribute it and/or modify # it under the terms of the GNU General Public License as published by # the Free Software Foundation; either version 2 of the License, or # (at your option) any later version. # # This program is distributed in the hope that it will be useful, # but WITHOUT ANY WARRANTY; without even the implied warranty of # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the # GNU General Public License for more details. # # You should have received a copy of the GNU General Public License # along with this program. If not, see <http://www.gnu.org/licenses/>. # # Authors: # Nils Philippsen <nils@redhat.com> """This module contains D-Bus proxy classes which implement the default timeout of the augmented bus classes in slip.dbus.bus.""" from __future__ import absolute_import import dbus.proxies from . import constants class _ProxyMethod(dbus.proxies._ProxyMethod): _connections_default_timeouts = {} @property def default_timeout(self): if self._connection not in self._connections_default_timeouts: dt = getattr(self._proxy._bus, "default_timeout", None) if dt is None: dt = constants.method_call_no_timeout self._connections_default_timeouts[self._connection] = dt return self._connections_default_timeouts[self._connection] def __call__(self, *args, **kwargs): if kwargs.get('timeout') is None: kwargs["timeout"] = self.default_timeout return dbus.proxies._ProxyMethod.__call__(self, *args, **kwargs) class ProxyObject(dbus.proxies.ProxyObject): ProxyMethodClass = _ProxyMethod PK {\g Ih h ' __pycache__/polkit.cpython-36.opt-1.pycnu [ 3 uAcI$ @ s d Z ddlmZ ddlZddlZddlmZ ddlmZ ddlm Z dd d d d d gZ dd Z dZ G dd d e Zdeddfdd ZG dd d ejZG dd de Ze Zdd Zdi fdd ZdS )zmThis module contains convenience decorators and functions for using PolicyKit with dbus services and clients. )absolute_importN) decorator)reduce )method_call_no_timeout require_auth enable_proxyAUTHFAIL_DONTCATCHNotAuthorizedExceptionAreAuthorizationsObtainable IsSystemBusNameAuthorizedAsyncc s fdd}|S )u Decorator for DBus service methods. Specify that a user needs a specific PolicyKit authorization `polkit_auth´ to execute it.c s t | d | S )NZ_slip_polkit_auth_required)setattr)method) polkit_auth /usr/lib/python3.6/polkit.pyrequire_auth_decorator/ s z,require_auth.<locals>.require_auth_decoratorr )r r r )r r r ) s zBorg.fedoraproject.slip.dbus.service.PolKit.NotAuthorizedException.c @ s e Zd ZdS )r N)__name__ __module__ __qualname__r r r r r < s c s6 fdd | dk r"t | S fdd}|S dS )u Decorator for DBus proxy methods. Let's you (optionally) specify either a result value or an exception type and a callback which is returned, thrown or called respectively if a PolicyKit authorization doesn't exist or can't be obtained in the DBus mechanism, i.e. an appropriate DBus exception is thrown. An exception constructor may and a callback must accept an `action_id´ parameter which will be set to the id of the PolicyKit action for which authorization could not be obtained. Examples: 1) Return `False´ in the event of an authorization problem, and call `error_handler´: def error_handler(action_id=None): print "Authorization problem:", action_id class MyProxy(object): @polkit.enable_proxy(authfail_result=False, authfail_callback=error_handler) def some_method(self, ...): ... 2) Throw a `MyAuthError´ instance in the event of an authorization problem: class MyAuthError(Exception): def __init__(self, *args, **kwargs): action_id = kwargs.pop("action_id") super(MyAuthError, self).__init__(*args, **kwargs) self.action_id = action_id class MyProxy(object): @polkit.enable_proxy(authfail_exception=MyAuthError) def some_method(self, ...): ...c s y | ||S t jk r } zr|j }|jts2 |ttd } d k rT |d d k ry|d}W n }Y nX |tkr S d }~X nX d S )N) action_id)dbus DBusExceptionZ get_dbus_name startswithAUTH_EXC_PREFIXlenr )funcpkeZexc_namer Zaf_exc)authfail_callbackauthfail_exceptionauthfail_resultr r _enable_proxyv s$ z#enable_proxy.<locals>._enable_proxyNc s t | S )N)r )r )r# r r decorate s z enable_proxy.<locals>.decorate)r )r r" r! r r$ r )r# r r! r" r r @ s 6 c s$ e Zd ZdZdZ fddZ ZS )r zqException which a DBus service method throws if an authorization required for executing it can't be obtained.zAorg.fedoraproject.slip.dbus.service.PolKit.NotAuthorizedExceptionc s( | j jd | | _tt| j|| d S )N.) __class___dbus_error_namesuperr __init__)selfr r r )r& r r r) s z NotAuthorizedException.__init__)r r r __doc__r' r) __classcell__r r )r& r r s c @ s e Zd ZdZdZdZdZdZdZdZ dZ e dd Z e dd Ze d d Ze d d Ze dd Zdd Zdd Zdd Zdi fddZdS )PolKitz"Convenience wrapper around polkit.zorg.freedesktop.PolicyKit1z%/org/freedesktop/PolicyKit1/Authorityz$org.freedesktop.PolicyKit1.AuthorityNc C s4 || j kr0tjr0tjjtj d t_d t_d t_d S )N) _dbus_namer- _PolKit__busZremove_signal_receiver_PolKit__signal_receiver_PolKit__interface)clsnameZ old_ownerZ new_ownerr r r _on_name_owner_changed s z PolKit._on_name_owner_changedc C s0 t js*tj t _t jj| jdd| jdt _t jS )NZNameOwnerChangedzorg.freedesktop.DBus)Zhandler_functionZ signal_nameZdbus_interfaceZarg0)r- r/ r Z SystemBusZadd_signal_receiverr4 r. r0 )r* r r r _bus s z PolKit._busc C s t js| jj t _t jS )N)r- _PolKit__bus_namer5 Zget_unique_name)r* r r r _bus_name s zPolKit._bus_namec C sF t js@y"tj| jj| j| j| jt _W n tj k r> Y nX t jS )N) r- r1 r Interfacer5 get_objectr. _dbus_path_dbus_interfacer )r* r r r _interface s zPolKit._interfacec C s t | jS )N)boolr< )r* r r r _polkit_present s zPolKit._polkit_presentc C s> | j jdd}tj|d}y|j|}W n d }Y nX |S )Nzorg.freedesktop.DBusz/org/freedesktop/DBus)r5 r9 r r8 ZGetConnectionUnixUser)r* system_bus_nameZ bus_objectZ bus_interfaceZuidr r r Z__dbus_system_bus_name_uid s z!PolKit.__dbus_system_bus_name_uidc C s6 | j s dS | jjdd| jif|i dd\}}}|p4|S )NTzsystem-bus-namer3 r )r> r< CheckAuthorizationr7 )r* Z authorization is_authorized is_challengedetailsr r r Z __authorization_is_obtainable s z$PolKit.__authorization_is_obtainablec s8 j s dS t|tttfs |f}t fdd|d}|S )NTc s | o j |S )N)$_PolKit__authorization_is_obtainable)xy)r* r r <lambda> s z4PolKit.AreAuthorizationsObtainable.<locals>.<lambda>)r> isinstancetuplelistsetr )r* authorizationsZ obtainabler )r* r r s z"PolKit.AreAuthorizationsObtainableTc sd | j s |d kp | j|dkS d}|r0|dO } fdd}| jjdd|if|||d||td d S ) Nr r c s | \}}} | d S )Nr )argsrB rC rD ) reply_handlerr r reply_cb s z7PolKit.IsSystemBusNameAuthorizedAsync.<locals>.reply_cbzsystem-bus-namer3 r@ )rO error_handlerZtimeout)r> !_PolKit__dbus_system_bus_name_uidr< rA r ) r* r? r rO rQ challengerD flagsrP r )rO r r s z%PolKit.IsSystemBusNameAuthorizedAsync)r r r r+ r. r: r; r1 r/ r6 r0 classmethodr4 propertyr5 r7 r< r> rR rE r r r r r r r- s" r- c C s t j| S )N)__polkitr )rM r r r r s Tc C s t j| |||||S )N)rW r )r? r rO rQ rS rD r r r r s )r+ Z __future__r collectionsr r functoolsr Z constantsr __all__r r objectr r r r r- rW r r r r r r <module> s( WoPK {\rbb b ) __pycache__/mainloop.cpython-36.opt-1.pycnu [ 3 uAc# @ s@ d Z ddlmZ d ZG dd deZG dd deZdd Zd S ) zVThis module contains mainloop wrappers. Currently only glib main loops are supported. )absolute_importMainLoopset_typec sX e Zd ZdZdZ fddZedd Zdd Zd d Z d d Z d d Z dd Z Z S )r a An abstract main loop wrapper class and factory. Use MainLoop() to get a main loop wrapper object for a main loop type previously registered with set_type(). Defaults to glib main loops. Actual main loop wrapper classes are derived from this class.Nc s. t jd krt jd tt | jt jf||S )Nglib)r Z_mainloop_classr super__new___MainLoop__mainloop_class)clsargskwargs) __class__ /usr/lib/python3.6/mainloop.pyr * s zMainLoop.__new__c C sH t jdk rtddti}||kr.|| t _ntd|dj|f dS )zxSet a main loop type for non-blocking interfaces. mltype: "glib" (currently only glib main loops are supported)Nz(The main loop type can only be set once.r z0'%s' is not one of the valid main loop types: %sz, )r r RuntimeError GlibMainLoop ValueErrorjoin)r mltypeZ ml_type_classr r r r 1 s zMainLoop.set_typec C s t dS )z$Returns if there are pending events.N)NotImplementedError)selfr r r pendingC s zMainLoop.pendingc C s t dS )z Iterates over one pending event.N)r )r r r r iterateH s zMainLoop.iteratec C s x| j r| j qW dS )z!Iterates over all pending events.N)r r )r r r r iterate_over_pending_eventsM s z$MainLoop.iterate_over_pending_eventsc C s t dS )zRuns the main loop.N)r )r r r r runS s z MainLoop.runc C s t dS )zQuits the main loop.N)r )r r r r quitX s z MainLoop.quit)__name__ __module__ __qualname____doc__r r classmethodr r r r r r __classcell__r r )r r r s c @ s e Zd Zdd ZdS )r c C sF ddl m} |j }|j }|| _|j| _|j| _|j| _|j | _ d S )N )_glib) Z _wrappersr" r Z get_contextZ _mainloopr Z iterationr r r )r r" ZmlZctxr r r __init__` s zGlibMainLoop.__init__N)r r r r# r r r r r ^ s r c C s$ ddl m} |dt tj| dS )zSet a main loop type for non-blocking interfaces. mltype: "glib" (currently only glib main loops are supported) Deprecated, use MainLoop.set_type() instead.r )warnz use MainLoop.set_type() insteadN)warningsr$ DeprecationWarningr r )r r$ r r r r l s N)r r )r Z __future__r __all__objectr r r r r r r <module> s >PK {\@ $ __pycache__/constants.cpython-36.pycnu [ 3 uAc @ s d Z dZdS )z*This module contains some constant values.ig @@Ng`Mb@A)__doc__Zmethod_call_no_timeout r r /usr/lib/python3.6/constants.py<module> s PK {\`: ( __pycache__/proxies.cpython-36.opt-1.pycnu [ 3 uAc` @ sP d Z ddlmZ ddlZddlmZ G dd dejjZG dd d ejj Z dS ) z{This module contains D-Bus proxy classes which implement the default timeout of the augmented bus classes in slip.dbus.bus. )absolute_importN ) constantsc @ s$ e Zd Zi Zedd Zdd ZdS ) _ProxyMethodc C sB | j | jkr6t| jjdd }|d kr*tj}|| j| j < | j| j S )Ndefault_timeout)Z _connection _connections_default_timeoutsgetattr_proxyZ_busr Zmethod_call_no_timeout)selfZdt r /usr/lib/python3.6/proxies.pyr & s z _ProxyMethod.default_timeoutc O s. |j dd kr| j|d< tjjj| f||S )NZtimeout)getr dbusproxiesr __call__)r argskwargsr r r r / s z_ProxyMethod.__call__N)__name__ __module__ __qualname__r propertyr r r r r r r " s r c @ s e Zd ZeZdS ) ProxyObjectN)r r r r ZProxyMethodClassr r r r r 6 s r ) __doc__Z __future__r Z dbus.proxiesr r r r r r r r r <module> s PK {\`: " __pycache__/proxies.cpython-36.pycnu [ 3 uAc` @ sP d Z ddlmZ ddlZddlmZ G dd dejjZG dd d ejj Z dS ) z{This module contains D-Bus proxy classes which implement the default timeout of the augmented bus classes in slip.dbus.bus. )absolute_importN ) constantsc @ s$ e Zd Zi Zedd Zdd ZdS ) _ProxyMethodc C sB | j | jkr6t| jjdd }|d kr*tj}|| j| j < | j| j S )Ndefault_timeout)Z _connection _connections_default_timeoutsgetattr_proxyZ_busr Zmethod_call_no_timeout)selfZdt r /usr/lib/python3.6/proxies.pyr & s z _ProxyMethod.default_timeoutc O s. |j dd kr| j|d< tjjj| f||S )NZtimeout)getr dbusproxiesr __call__)r argskwargsr r r r / s z_ProxyMethod.__call__N)__name__ __module__ __qualname__r propertyr r r r r r r " s r c @ s e Zd ZeZdS ) ProxyObjectN)r r r r ZProxyMethodClassr r r r r 6 s r ) __doc__Z __future__r Z dbus.proxiesr r r r r r r r r <module> s PK {\@ * __pycache__/constants.cpython-36.opt-1.pycnu [ 3 uAc @ s d Z dZdS )z*This module contains some constant values.ig @@Ng`Mb@A)__doc__Zmethod_call_no_timeout r r /usr/lib/python3.6/constants.py<module> s PK {\Rf0 $ __pycache__/bus.cpython-36.opt-1.pycnu [ 3 uAcY @ sX d Z ddlmZ ddlZddlmZ ddlmZ x"d D ]Zed ee ej d q6W dS )zQThis module contains functions which create monkey-patched/augmented D-Bus buses. )absolute_importN )proxies) constantsBus SystemBus SessionBus StarterBuszdef %(name)s(*args, **kwargs): busobj = dbus.%(name)s(*args, **kwargs) busobj.ProxyObjectClass = proxies.ProxyObject busobj.default_timeout = %(default_timeout)s return busobj )namemodnameZdefault_timeout)r r r r ) __doc__Z __future__r Zdbus r r r exec__name__Zmethod_call_no_timeout r r /usr/lib/python3.6/bus.py<module> s PK {\ )* ) __pycache__/__init__.cpython-36.opt-1.pycnu [ 3 uAc @ s` d dl mZ ddlmZ ddlmZmZmZ ddlmZ ddlmZ ddlm Z ddlm Z d S ) )absolute_import )bus) SessionBus SystemBus StarterBus)proxies)service)polkit)mainloopN) Z __future__r r r r r r r r r r r /usr/lib/python3.6/__init__.py<module> s PK {\x ( __pycache__/service.cpython-36.opt-1.pycnu [ 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.<locals>.wrapped_method.<locals>.reply_handlerc s | j d S )N)r )r )r r" r r error_handler s z:wrap_method.<locals>.wrapped_method.<locals>.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.<locals>.wrapped_methodc s s" | ]}|d d dkr|V qd S )N Z_dbus_r ).0xr r r <genexpr> s z wrap_method.<locals>.<genexpr>_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 <module> s& g PK {\ )* # __pycache__/__init__.cpython-36.pycnu [ 3 uAc @ s` d dl mZ ddlmZ ddlmZmZmZ ddlmZ ddlmZ ddlm Z ddlm Z d S ) )absolute_import )bus) SessionBus SystemBus StarterBus)proxies)service)polkit)mainloopN) Z __future__r r r r r r r r r r r /usr/lib/python3.6/__init__.py<module> s PK {\ N N ( __pycache__/introspection.cpython-36.pycnu [ 3 uAc @ s d Z ddlmZ ddlmZ ddlmZ ddlmZ G dd de Z G dd d ee e Z G d d d e Z G d d d e ZG dd de eZG dd de ZG dd de ZG dd de ZG dd de eZdd ZdS )z?Classes and functions to easily access DBus introspection data. )absolute_import) ElementTree)StringIO)with_metaclassc @ s( e Zd ZdZi Zedd Zdd ZdS ) IElemMetazMetaclass for introspection elements. Sets elemname class member automatically from class name if not set explicitly. Registers classes for their element names.c C s> d}x4|D ],}|j }||kr.t|r.|d7 }||7 }q W |S )N _)lowerlen)clsZclsnameelemnamecZc_lower r #/usr/lib/python3.6/introspection.pyclsname_to_elemname( s z IElemMeta.clsname_to_elemnamec C s |dkrt j| |||S d|krL|jds6td| tj|dd |d< |d }|tjkrntd||f t j| |||}|tj|< |S )NIElemr z;Class '%s' needs to set elemname (or be called 'IElem...')) z4Class '%s' tries to register duplicate elemname '%s')type__new__ startswith TypeErrorr r elemnames_to_classes)r namebasesZdctr klsr r r r 3 s zIElemMeta.__new__N)__name__ __module__ __qualname____doc__r classmethodr r r r r r r s r c s@ e Zd ZdZd fdd Zd ddZdd Zed d Z Z S ) r z&Base class for introspection elements.Nc s* t jj|jt jd }tt| j|||S )N)r r gettagsuperr r )r elemparentr ) __class__r r r O s z IElem.__new__c s$ | _ | _ fdd|D _d S )Nc s g | ]}t | d qS ))r$ )r ).0r )selfr r <listcomp>W s z"IElem.__init__.<locals>.<listcomp>)r# r$ child_elements)r' r# r$ r )r' r __init__T s zIElem.__init__c C sZ d| j r| j n d| jj | jf }x2| jD ](}x"t|jdD ]}|d| 7 }q>W q*W |S )Nz%s %rz unknown:%s z %s)r r# r! attribr) strsplit)r' sr Zccr r r __str__Y s z IElem.__str__c C s | j jS )N)r# r, )r' r r r r, a s z IElem.attrib)N)N) r r r r r r* r0 propertyr, __classcell__r r )r% r r L s r c @ s e Zd ZdZdZdS ) IElemUnknownz-Catch-all for unknown introspection elements.N)r r r r r r r r r r3 f s r3 c @ s e Zd ZdZedd ZdS )IElemNameMixinz,Mixin for introspection elements with names.c C s | j d S )Nr )r, )r' r r r r o s zIElemNameMixin.nameN)r r r r r1 r r r r r r4 l s r4 c s" e Zd ZdZd fdd Z ZS ) IElemNodezIntrospection node.Nc s( t t| j|| dd | jD | _d S )Nc S s g | ]}t |tr|qS r ) isinstancer5 )r& r r r r r( { s z&IElemNode.__init__.<locals>.<listcomp>)r" r5 r* r) Z child_nodes)r' r# r$ )r% r r r* w s zIElemNode.__init__)N)r r r r r* r2 r r )r% r r5 t s r5 c @ s e Zd ZdZdS )IElemInterfacezIntrospection interface.N)r r r r r r r r r7 ~ s r7 c @ s e Zd ZdZdS ) IElemMethodz Introspection interface method.N)r r r r r r r r r8 s r8 c @ s e Zd ZdZdS )IElemArgz Introspection method argument.N)r r r r r r r r r9 s r9 c @ s e Zd ZdZdS ) IElemSignalz Introspection interface signal.N)r r r r r r r r r: s r: c C s. t }t| dst| } |j| }t|}|S )Nread)r hasattrr parser )Zstring_or_fileZtreeZxml_rootZ elem_rootr r r introspect s r> N)r Z __future__r Zxml.etree.ElementTreer ior Zsixr r r objectr r3 r4 r5 r7 r8 r9 r: r> r r r r <module> s , PK {\UKC C ! __pycache__/polkit.cpython-36.pycnu [ 3 uAcI$ @ s d Z ddlmZ ddlZddlZddlmZ ddlmZ ddlm Z dd d d d d gZ dd Z dZ G dd d e Zdeddfdd ZG dd d ejZG dd de Ze Zdd Zdi fdd ZdS )zmThis module contains convenience decorators and functions for using PolicyKit with dbus services and clients. )absolute_importN) decorator)reduce )method_call_no_timeout require_auth enable_proxyAUTHFAIL_DONTCATCHNotAuthorizedExceptionAreAuthorizationsObtainable IsSystemBusNameAuthorizedAsyncc s fdd}|S )u Decorator for DBus service methods. Specify that a user needs a specific PolicyKit authorization `polkit_auth´ to execute it.c s t | dstt| d | S )NZ_dbus_is_methodZ_slip_polkit_auth_required)hasattrAssertionErrorsetattr)method) polkit_auth /usr/lib/python3.6/polkit.pyrequire_auth_decorator/ s z,require_auth.<locals>.require_auth_decoratorr )r r r )r r r ) s zBorg.fedoraproject.slip.dbus.service.PolKit.NotAuthorizedException.c @ s e Zd ZdS )r N)__name__ __module__ __qualname__r r r r r < s c s | dkst | tjstdtfks0dks0tdksHt tjsHtdks^tts^tfdd | dk rt | S fdd}|S dS )u Decorator for DBus proxy methods. Let's you (optionally) specify either a result value or an exception type and a callback which is returned, thrown or called respectively if a PolicyKit authorization doesn't exist or can't be obtained in the DBus mechanism, i.e. an appropriate DBus exception is thrown. An exception constructor may and a callback must accept an `action_id´ parameter which will be set to the id of the PolicyKit action for which authorization could not be obtained. Examples: 1) Return `False´ in the event of an authorization problem, and call `error_handler´: def error_handler(action_id=None): print "Authorization problem:", action_id class MyProxy(object): @polkit.enable_proxy(authfail_result=False, authfail_callback=error_handler) def some_method(self, ...): ... 2) Throw a `MyAuthError´ instance in the event of an authorization problem: class MyAuthError(Exception): def __init__(self, *args, **kwargs): action_id = kwargs.pop("action_id") super(MyAuthError, self).__init__(*args, **kwargs) self.action_id = action_id class MyProxy(object): @polkit.enable_proxy(authfail_exception=MyAuthError) def some_method(self, ...): ...Nc s y | ||S t jk r } zr|j }|jts2 |ttd } d k rT |d d k ry|d}W n }Y nX |tkr S d }~X nX d S )N) action_id)dbus DBusExceptionZ get_dbus_name startswithAUTH_EXC_PREFIXlenr )funcpkeZexc_namer Zaf_exc)authfail_callbackauthfail_exceptionauthfail_resultr r _enable_proxyv s$ z#enable_proxy.<locals>._enable_proxyc s t | S )N)r )r )r% r r decorate s z enable_proxy.<locals>.decorate) isinstance collectionsCallabler r issubclass Exceptionr )r r$ r# r" r& r )r% r" r# r$ r r @ s * c s$ e Zd ZdZdZ fddZ ZS )r zqException which a DBus service method throws if an authorization required for executing it can't be obtained.zAorg.fedoraproject.slip.dbus.service.PolKit.NotAuthorizedExceptionc s( | j jd | | _tt| j|| d S )N.) __class___dbus_error_namesuperr __init__)selfr r r )r- r r r0 s z NotAuthorizedException.__init__)r r r __doc__r. r0 __classcell__r r )r- r r s c @ s e Zd ZdZdZdZdZdZdZdZ dZ e dd Z e dd Ze d d Ze d d Ze dd Zdd Zdd Zdd Zdi fddZdS )PolKitz"Convenience wrapper around polkit.zorg.freedesktop.PolicyKit1z%/org/freedesktop/PolicyKit1/Authorityz$org.freedesktop.PolicyKit1.AuthorityNc C s4 || j kr0tjr0tjjtj d t_d t_d t_d S )N) _dbus_namer4 _PolKit__busZremove_signal_receiver_PolKit__signal_receiver_PolKit__interface)clsnameZ old_ownerZ new_ownerr r r _on_name_owner_changed s z PolKit._on_name_owner_changedc C s0 t js*tj t _t jj| jdd| jdt _t jS )NZNameOwnerChangedzorg.freedesktop.DBus)Zhandler_functionZ signal_nameZdbus_interfaceZarg0)r4 r6 r Z SystemBusZadd_signal_receiverr; r5 r7 )r1 r r r _bus s z PolKit._busc C s t js| jj t _t jS )N)r4 _PolKit__bus_namer< Zget_unique_name)r1 r r r _bus_name s zPolKit._bus_namec C sF t js@y"tj| jj| j| j| jt _W n tj k r> Y nX t jS )N) r4 r8 r Interfacer< get_objectr5 _dbus_path_dbus_interfacer )r1 r r r _interface s zPolKit._interfacec C s t | jS )N)boolrC )r1 r r r _polkit_present s zPolKit._polkit_presentc C s> | j jdd}tj|d}y|j|}W n d }Y nX |S )Nzorg.freedesktop.DBusz/org/freedesktop/DBus)r< r@ r r? ZGetConnectionUnixUser)r1 system_bus_nameZ bus_objectZ bus_interfaceZuidr r r Z__dbus_system_bus_name_uid s z!PolKit.__dbus_system_bus_name_uidc C s6 | j s dS | jjdd| jif|i dd\}}}|p4|S )NTzsystem-bus-namer: r )rE rC CheckAuthorizationr> )r1 Z authorization is_authorized is_challengedetailsr r r Z __authorization_is_obtainable s z$PolKit.__authorization_is_obtainablec s8 j s dS t|tttfs |f}t fdd|d}|S )NTc s | o j |S )N)$_PolKit__authorization_is_obtainable)xy)r1 r r <lambda> s z4PolKit.AreAuthorizationsObtainable.<locals>.<lambda>)rE r' tuplelistsetr )r1 authorizationsZ obtainabler )r1 r r s z"PolKit.AreAuthorizationsObtainableTc sd | j s |d kp | j|dkS d}|r0|dO } fdd}| jjdd|if|||d||td d S ) Nr r c s | \}}} | d S )Nr )argsrI rJ rK ) reply_handlerr r reply_cb s z7PolKit.IsSystemBusNameAuthorizedAsync.<locals>.reply_cbzsystem-bus-namer: rG )rU error_handlerZtimeout)rE !_PolKit__dbus_system_bus_name_uidrC rH r ) r1 rF r rU rW challengerK flagsrV r )rU r r s z%PolKit.IsSystemBusNameAuthorizedAsync)r r r r2 r5 rA rB r8 r6 r= r7 classmethodr; propertyr< r> rC rE rX rL r r r r r r r4 s" r4 c C s t j| S )N)__polkitr )rS r r r r s Tc C s t j| |||||S )N)r] r )rF r rU rW rY rK r r r r s )r2 Z __future__r r( r r functoolsr Z constantsr __all__r r objectr r r r r4 r] r r r r r r <module> s( WoPK {\rbb b # __pycache__/mainloop.cpython-36.pycnu [ 3 uAc# @ s@ d Z ddlmZ d ZG dd deZG dd deZdd Zd S ) zVThis module contains mainloop wrappers. Currently only glib main loops are supported. )absolute_importMainLoopset_typec sX e Zd ZdZdZ fddZedd Zdd Zd d Z d d Z d d Z dd Z Z S )r a An abstract main loop wrapper class and factory. Use MainLoop() to get a main loop wrapper object for a main loop type previously registered with set_type(). Defaults to glib main loops. Actual main loop wrapper classes are derived from this class.Nc s. t jd krt jd tt | jt jf||S )Nglib)r Z_mainloop_classr super__new___MainLoop__mainloop_class)clsargskwargs) __class__ /usr/lib/python3.6/mainloop.pyr * s zMainLoop.__new__c C sH t jdk rtddti}||kr.|| t _ntd|dj|f dS )zxSet a main loop type for non-blocking interfaces. mltype: "glib" (currently only glib main loops are supported)Nz(The main loop type can only be set once.r z0'%s' is not one of the valid main loop types: %sz, )r r RuntimeError GlibMainLoop ValueErrorjoin)r mltypeZ ml_type_classr r r r 1 s zMainLoop.set_typec C s t dS )z$Returns if there are pending events.N)NotImplementedError)selfr r r pendingC s zMainLoop.pendingc C s t dS )z Iterates over one pending event.N)r )r r r r iterateH s zMainLoop.iteratec C s x| j r| j qW dS )z!Iterates over all pending events.N)r r )r r r r iterate_over_pending_eventsM s z$MainLoop.iterate_over_pending_eventsc C s t dS )zRuns the main loop.N)r )r r r r runS s z MainLoop.runc C s t dS )zQuits the main loop.N)r )r r r r quitX s z MainLoop.quit)__name__ __module__ __qualname____doc__r r classmethodr r r r r r __classcell__r r )r r r s c @ s e Zd Zdd ZdS )r c C sF ddl m} |j }|j }|| _|j| _|j| _|j| _|j | _ d S )N )_glib) Z _wrappersr" r Z get_contextZ _mainloopr Z iterationr r r )r r" ZmlZctxr r r __init__` s zGlibMainLoop.__init__N)r r r r# r r r r r ^ s r c C s$ ddl m} |dt tj| dS )zSet a main loop type for non-blocking interfaces. mltype: "glib" (currently only glib main loops are supported) Deprecated, use MainLoop.set_type() instead.r )warnz use MainLoop.set_type() insteadN)warningsr$ DeprecationWarningr r )r r$ r r r r l s N)r r )r Z __future__r __all__objectr r r r r r r <module> s >PK {\x " __pycache__/service.cpython-36.pycnu [ 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.<locals>.wrapped_method.<locals>.reply_handlerc s | j d S )N)r )r )r r" r r error_handler s z:wrap_method.<locals>.wrapped_method.<locals>.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.<locals>.wrapped_methodc s s" | ]}|d d dkr|V qd S )N Z_dbus_r ).0xr r r <genexpr> s z wrap_method.<locals>.<genexpr>_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 <module> s& g PK {\Rf0 __pycache__/bus.cpython-36.pycnu [ 3 uAcY @ sX d Z ddlmZ ddlZddlmZ ddlmZ x"d D ]Zed ee ej d q6W dS )zQThis module contains functions which create monkey-patched/augmented D-Bus buses. )absolute_importN )proxies) constantsBus SystemBus SessionBus StarterBuszdef %(name)s(*args, **kwargs): busobj = dbus.%(name)s(*args, **kwargs) busobj.ProxyObjectClass = proxies.ProxyObject busobj.default_timeout = %(default_timeout)s return busobj )namemodnameZdefault_timeout)r r r r ) __doc__Z __future__r Zdbus r r r exec__name__Zmethod_call_no_timeout r r /usr/lib/python3.6/bus.py<module> s PK {\ N N . __pycache__/introspection.cpython-36.opt-1.pycnu [ 3 uAc @ s d Z ddlmZ ddlmZ ddlmZ ddlmZ G dd de Z G dd d ee e Z G d d d e Z G d d d e ZG dd de eZG dd de ZG dd de ZG dd de ZG dd de eZdd ZdS )z?Classes and functions to easily access DBus introspection data. )absolute_import) ElementTree)StringIO)with_metaclassc @ s( e Zd ZdZi Zedd Zdd ZdS ) IElemMetazMetaclass for introspection elements. Sets elemname class member automatically from class name if not set explicitly. Registers classes for their element names.c C s> d}x4|D ],}|j }||kr.t|r.|d7 }||7 }q W |S )N _)lowerlen)clsZclsnameelemnamecZc_lower r #/usr/lib/python3.6/introspection.pyclsname_to_elemname( s z IElemMeta.clsname_to_elemnamec C s |dkrt j| |||S d|krL|jds6td| tj|dd |d< |d }|tjkrntd||f t j| |||}|tj|< |S )NIElemr z;Class '%s' needs to set elemname (or be called 'IElem...')) z4Class '%s' tries to register duplicate elemname '%s')type__new__ startswith TypeErrorr r elemnames_to_classes)r namebasesZdctr klsr r r r 3 s zIElemMeta.__new__N)__name__ __module__ __qualname____doc__r classmethodr r r r r r r s r c s@ e Zd ZdZd fdd Zd ddZdd Zed d Z Z S ) r z&Base class for introspection elements.Nc s* t jj|jt jd }tt| j|||S )N)r r gettagsuperr r )r elemparentr ) __class__r r r O s z IElem.__new__c s$ | _ | _ fdd|D _d S )Nc s g | ]}t | d qS ))r$ )r ).0r )selfr r <listcomp>W s z"IElem.__init__.<locals>.<listcomp>)r# r$ child_elements)r' r# r$ r )r' r __init__T s zIElem.__init__c C sZ d| j r| j n d| jj | jf }x2| jD ](}x"t|jdD ]}|d| 7 }q>W q*W |S )Nz%s %rz unknown:%s z %s)r r# r! attribr) strsplit)r' sr Zccr r r __str__Y s z IElem.__str__c C s | j jS )N)r# r, )r' r r r r, a s z IElem.attrib)N)N) r r r r r r* r0 propertyr, __classcell__r r )r% r r L s r c @ s e Zd ZdZdZdS ) IElemUnknownz-Catch-all for unknown introspection elements.N)r r r r r r r r r r3 f s r3 c @ s e Zd ZdZedd ZdS )IElemNameMixinz,Mixin for introspection elements with names.c C s | j d S )Nr )r, )r' r r r r o s zIElemNameMixin.nameN)r r r r r1 r r r r r r4 l s r4 c s" e Zd ZdZd fdd Z ZS ) IElemNodezIntrospection node.Nc s( t t| j|| dd | jD | _d S )Nc S s g | ]}t |tr|qS r ) isinstancer5 )r& r r r r r( { s z&IElemNode.__init__.<locals>.<listcomp>)r" r5 r* r) Z child_nodes)r' r# r$ )r% r r r* w s zIElemNode.__init__)N)r r r r r* r2 r r )r% r r5 t s r5 c @ s e Zd ZdZdS )IElemInterfacezIntrospection interface.N)r r r r r r r r r7 ~ s r7 c @ s e Zd ZdZdS ) IElemMethodz Introspection interface method.N)r r r r r r r r r8 s r8 c @ s e Zd ZdZdS )IElemArgz Introspection method argument.N)r r r r r r r r r9 s r9 c @ s e Zd ZdZdS ) IElemSignalz Introspection interface signal.N)r r r r r r r r r: s r: c C s. t }t| dst| } |j| }t|}|S )Nread)r hasattrr parser )Zstring_or_fileZtreeZxml_rootZ elem_rootr r r introspect s r> N)r Z __future__r Zxml.etree.ElementTreer ior Zsixr r r objectr r3 r4 r5 r7 r8 r9 r: r> r r r r <module> s , PK {\!+ service.pynu [ # -*- coding: utf-8 -*- # slip.dbus.service -- convenience functions for using dbus-activated # services # # Copyright © 2008, 2009, 2015 Red Hat, Inc. # # This program is free software; you can redistribute it and/or modify # it under the terms of the GNU General Public License as published by # the Free Software Foundation; either version 2 of the License, or # (at your option) any later version. # # This program is distributed in the hope that it will be useful, # but WITHOUT ANY WARRANTY; without even the implied warranty of # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the # GNU General Public License for more details. # # You should have received a copy of the GNU General Public License # along with this program. If not, see <http://www.gnu.org/licenses/>. # # Authors: # Nils Philippsen <nils@redhat.com> "This module contains convenience functions for using dbus-activated services." from __future__ import absolute_import import dbus import dbus.service from six import with_metaclass from .._wrappers import _glib as GLib from . import polkit __all__ = ["Object", "InterfaceType", "set_mainloop"] __mainloop__ = None def __glib_quit_cb__(): global __mainloop__ # assume a Glib mainloop __mainloop__.quit() __quit_cb__ = __glib_quit_cb__ def set_mainloop(mainloop): global __mainloop__ __mainloop__ = mainloop def set_quit_cb(quit_cb): global __quit_cb__ __quit_cb__ = quit_cb def quit_cb(): global __quit_cb__ __quit_cb__() SENDER_KEYWORD = "__slip_dbus_service_sender__" ASYNC_CALLBACKS = ("__slip_dbus_service_reply_cb__", "__slip_dbus_service_error_cb__") def wrap_method(method): global SENDER_KEYWORD global ASYNC_CALLBACKS if method._dbus_sender_keyword is not None: sender_keyword = method._dbus_sender_keyword hide_sender_keyword = False else: sender_keyword = SENDER_KEYWORD hide_sender_keyword = True if method._dbus_async_callbacks is not None: async_callbacks = method._dbus_async_callbacks method_is_async = True else: async_callbacks = ASYNC_CALLBACKS method_is_async = False hide_async_callbacks = not method_is_async def wrapped_method(self, *p, **k): sender = k.get(sender_keyword) if sender is not None: # i.e. called over the bus, not locally reply_cb = k[async_callbacks[0]] error_cb = k[async_callbacks[1]] if hide_sender_keyword: del k[sender_keyword] if hide_async_callbacks: del k[async_callbacks[0]] del k[async_callbacks[1]] self.sender_seen(sender) action_id = getattr(method, "_slip_polkit_auth_required", getattr(self, "default_polkit_auth_required", None)) if sender is not None and action_id: def reply_handler(is_auth): if is_auth: if method_is_async: # k contains async callbacks, simply pass on reply_cb # and error_cb method(self, *p, **k) else: # execute the synchronous method ... error = None try: result = method(self, *p, **k) except Exception as e: error = e # ... and call the reply or error callback if error: error_cb(error) else: # reply_cb((None,)) != reply_cb() if result is None: reply_cb() else: reply_cb(result) else: error_cb(polkit.NotAuthorizedException(action_id)) self.timeout_restart() def error_handler(error): error_cb(error) self.timeout_restart() polkit.IsSystemBusNameAuthorizedAsync( sender, action_id, reply_handler=reply_handler, error_handler=error_handler) else: # no action id, or run locally, no need to do anything fancy retval = method(self, *p, **k) self.timeout_restart() return retval for attr in (x for x in dir(method) if x[:6] == "_dbus_"): if attr == "_dbus_sender_keyword": wrapped_method._dbus_sender_keyword = sender_keyword elif attr == "_dbus_async_callbacks": wrapped_method._dbus_async_callbacks = async_callbacks else: setattr(wrapped_method, attr, getattr(method, attr)) # delattr (method, attr) wrapped_method.__name__ = method.__name__ return wrapped_method class InterfaceType(dbus.service.InterfaceType): def __new__(cls, name, bases, dct): for (attrname, attr) in dct.items(): if getattr(attr, "_dbus_is_method", False): dct[attrname] = wrap_method(attr) return super(InterfaceType, cls).__new__(cls, name, bases, dct) class Object(with_metaclass(InterfaceType, dbus.service.Object)): # timeout & persistence persistent = False default_duration = 5 duration = default_duration current_source = None senders = set() connections_senders = {} connections_smobjs = {} # PolicyKit default_polkit_auth_required = None def __init__( self, conn=None, object_path=None, bus_name=None, persistent=None): super(Object, self).__init__(conn, object_path, bus_name) if persistent is None: self.persistent = self.__class__.persistent else: self.persistent = persistent def _timeout_cb(self): if not self.persistent and len(Object.senders) == 0: quit_cb() return False Object.current_source = None Object.duration = self.default_duration return False def _name_owner_changed(self, name, old_owner, new_owner): conn = self.connection if not new_owner and (old_owner, conn) in Object.senders: Object.senders.remove((old_owner, conn)) Object.connections_senders[conn].remove(old_owner) if len(Object.connections_senders[conn]) == 0: Object.connections_smobjs[conn].remove() del Object.connections_senders[conn] del Object.connections_smobjs[conn] if not self.persistent and len(Object.senders) == 0 and \ Object.current_source is None: quit_cb() def timeout_restart(self, duration=None): if not duration: duration = self.__class__.default_duration if not Object.duration or duration > Object.duration: Object.duration = duration if not self.persistent or len(Object.senders) == 0: if Object.current_source: GLib.source_remove(Object.current_source) Object.current_source = \ GLib.timeout_add(Object.duration * 1000, self._timeout_cb) def sender_seen(self, sender): if (sender, self.connection) not in Object.senders: Object.senders.add((sender, self.connection)) if self.connection not in Object.connections_senders: Object.connections_senders[self.connection] = set() Object.connections_smobjs[self.connection] = \ self.connection.add_signal_receiver( handler_function=self._name_owner_changed, signal_name='NameOwnerChanged', dbus_interface='org.freedesktop.DBus', arg1=sender) Object.connections_senders[self.connection].add(sender) PK {\ introspection.pynu [ # -*- coding: utf-8 -*- # slip.dbus.introspection -- access dbus introspection data # # Copyright © 2011 Red Hat, Inc. # # This program is free software; you can redistribute it and/or modify # it under the terms of the GNU General Public License as published by # the Free Software Foundation; either version 2 of the License, or # (at your option) any later version. # # This program is distributed in the hope that it will be useful, # but WITHOUT ANY WARRANTY; without even the implied warranty of # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the # GNU General Public License for more details. # # You should have received a copy of the GNU General Public License # along with this program. If not, see <http://www.gnu.org/licenses/>. # # Authors: # Nils Philippsen <nils@redhat.com> """Classes and functions to easily access DBus introspection data.""" from __future__ import absolute_import from xml.etree.ElementTree import ElementTree from io import StringIO from six import with_metaclass class IElemMeta(type): """Metaclass for introspection elements. Sets elemname class member automatically from class name if not set explicitly. Registers classes for their element names.""" elemnames_to_classes = {} @classmethod def clsname_to_elemname(cls, clsname): elemname = "" for c in clsname: c_lower = c.lower() if c_lower != c: if len(elemname): elemname += "_" elemname += c_lower return elemname def __new__(cls, name, bases, dct): if name == "IElem": return type.__new__(cls, name, bases, dct) if 'elemname' not in dct: if not name.startswith("IElem"): raise TypeError( "Class '%s' needs to set elemname (or be called " "'IElem...'))" % name) dct['elemname'] = IElemMeta.clsname_to_elemname(name[5:]) elemname = dct['elemname'] if elemname in IElemMeta.elemnames_to_classes: raise TypeError( "Class '%s' tries to register duplicate elemname '%s'" % (name, elemname)) kls = type.__new__(cls, name, bases, dct) IElemMeta.elemnames_to_classes[elemname] = kls return kls class IElem(with_metaclass(IElemMeta, object)): """Base class for introspection elements.""" def __new__(cls, elem, parent=None): kls = IElemMeta.elemnames_to_classes.get( elem.tag, IElemMeta.elemnames_to_classes[None]) return super(IElem, cls).__new__(kls, elem, parent) def __init__(self, elem, parent=None): self.elem = elem self.parent = parent self.child_elements = [IElem(c, parent=self) for c in elem] def __str__(self): s = "%s %r" % (self.elemname if self.elemname else "unknown:%s" % self.elem.tag, self.attrib) for c in self.child_elements: for cc in str(c).split("\n"): s += "\n %s" % (cc) return s @property def attrib(self): return self.elem.attrib class IElemUnknown(IElem): """Catch-all for unknown introspection elements.""" elemname = None class IElemNameMixin(object): """Mixin for introspection elements with names.""" @property def name(self): return self.attrib['name'] class IElemNode(IElem, IElemNameMixin): """Introspection node.""" def __init__(self, elem, parent=None): super(IElemNode, self).__init__(elem, parent) self.child_nodes = [ c for c in self.child_elements if isinstance(c, IElemNode)] class IElemInterface(IElem): """Introspection interface.""" class IElemMethod(IElem): """Introspection interface method.""" class IElemArg(IElem): """Introspection method argument.""" class IElemSignal(IElem, IElemNameMixin): """Introspection interface signal.""" def introspect(string_or_file): tree = ElementTree() # assume string if read() method doesn't exist, works for string, unicode, # dbus.String if not hasattr(string_or_file, "read"): string_or_file = StringIO(string_or_file) xml_root = tree.parse(string_or_file) elem_root = IElem(xml_root) return elem_root PK {\4 __init__.pynu [ # -*- coding: utf-8 -*- from __future__ import absolute_import from . import bus from .bus import SessionBus, SystemBus, StarterBus from . import proxies from . import service from . import polkit from . import mainloop PK {\,Vr constants.pynu [ # -*- coding: utf-8 -*- # slip.dbus.constants -- constant values # # Copyright © 2011 Red Hat, Inc. # # This program is free software; you can redistribute it and/or modify # it under the terms of the GNU General Public License as published by # the Free Software Foundation; either version 2 of the License, or # (at your option) any later version. # # This program is distributed in the hope that it will be useful, # but WITHOUT ANY WARRANTY; without even the implied warranty of # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the # GNU General Public License for more details. # # You should have received a copy of the GNU General Public License # along with this program. If not, see <http://www.gnu.org/licenses/>. # # Authors: # Nils Philippsen <nils@redhat.com> """This module contains some constant values.""" # The maximum value of a 32bit signed integer is the magic value to indicate an # infinite timeout for dbus. Unlike the C interface which deals with # milliseconds as integers, the python interface uses seconds as floats for the # timeout. Therefore we need to use the Python float (C double) value that # gives 0x7FFFFFFF if multiplied by 1000.0 and cast into an integer. # # This calculation should be precise enough to get a value of 0x7FFFFFFF on the # C side. If not, it will still amount to a very long time (not quite 25 days) # which should be enough for all intents and purposes. method_call_no_timeout = 0x7FFFFFFF / 1000.0 PK {\bΜ# # mainloop.pynu [ # -*- coding: utf-8 -*- # slip.dbus.mainloop -- mainloop wrappers # # Copyright © 2009, 2012 Red Hat, Inc. # # This program is free software; you can redistribute it and/or modify # it under the terms of the GNU General Public License as published by # the Free Software Foundation; either version 2 of the License, or # (at your option) any later version. # # This program is distributed in the hope that it will be useful, # but WITHOUT ANY WARRANTY; without even the implied warranty of # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the # GNU General Public License for more details. # # You should have received a copy of the GNU General Public License # along with this program. If not, see <http://www.gnu.org/licenses/>. # # Authors: # Nils Philippsen <nils@redhat.com> """This module contains mainloop wrappers. Currently only glib main loops are supported.""" from __future__ import absolute_import __all__ = ("MainLoop", "set_type") class MainLoop(object): """An abstract main loop wrapper class and factory. Use MainLoop() to get a main loop wrapper object for a main loop type previously registered with set_type(). Defaults to glib main loops. Actual main loop wrapper classes are derived from this class.""" __mainloop_class = None def __new__(cls, *args, **kwargs): global _mainloop_class if MainLoop._mainloop_class is None: MainLoop.set_type("glib") return super(MainLoop, cls).__new__( MainLoop.__mainloop_class, *args, **kwargs) @classmethod def set_type(cls, mltype): """Set a main loop type for non-blocking interfaces. mltype: "glib" (currently only glib main loops are supported)""" if MainLoop.__mainloop_class is not None: raise RuntimeError("The main loop type can only be set once.") ml_type_class = {"glib": GlibMainLoop} if mltype in ml_type_class: MainLoop.__mainloop_class = ml_type_class[mltype] else: raise ValueError( "'%s' is not one of the valid main loop types:\n%s" % (mltype, ", ".join(ml_type_class))) def pending(self): """Returns if there are pending events.""" raise NotImplementedError() def iterate(self): """Iterates over one pending event.""" raise NotImplementedError() def iterate_over_pending_events(self): """Iterates over all pending events.""" while self.pending(): self.iterate() def run(self): """Runs the main loop.""" raise NotImplementedError() def quit(self): """Quits the main loop.""" raise NotImplementedError() class GlibMainLoop(MainLoop): def __init__(self): from .._wrappers import _glib ml = _glib.MainLoop() ctx = ml.get_context() self._mainloop = ml self.pending = ctx.pending self.iterate = ctx.iteration self.run = ml.run self.quit = ml.quit def set_type(mltype): """Set a main loop type for non-blocking interfaces. mltype: "glib" (currently only glib main loops are supported) Deprecated, use MainLoop.set_type() instead.""" from warnings import warn warn("use MainLoop.set_type() instead", DeprecationWarning) MainLoop.set_type(mltype) PK {\$:Y Y bus.pynu [ # -*- coding: utf-8 -*- # slip.dbus.bus -- augmented dbus buses # # Copyright © 2009, 2011 Red Hat, Inc. # # This program is free software; you can redistribute it and/or modify # it under the terms of the GNU General Public License as published by # the Free Software Foundation; either version 2 of the License, or # (at your option) any later version. # # This program is distributed in the hope that it will be useful, # but WITHOUT ANY WARRANTY; without even the implied warranty of # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the # GNU General Public License for more details. # # You should have received a copy of the GNU General Public License # along with this program. If not, see <http://www.gnu.org/licenses/>. # # Authors: # Nils Philippsen <nils@redhat.com> """This module contains functions which create monkey-patched/augmented D-Bus buses.""" from __future__ import absolute_import import dbus from . import proxies from . import constants for name in ("Bus", "SystemBus", "SessionBus", "StarterBus"): exec( """def %(name)s(*args, **kwargs): busobj = dbus.%(name)s(*args, **kwargs) busobj.ProxyObjectClass = proxies.ProxyObject busobj.default_timeout = %(default_timeout)s return busobj """ % { "name": name, "modname": __name__, "default_timeout": constants.method_call_no_timeout}) PK {\?CI$ I$ polkit.pynu [ # -*- coding: utf-8 -*- # slip.dbus.polkit -- convenience decorators and functions for using PolicyKit # with dbus services and clients # # Copyright © 2008, 2009, 2012, 2013, 2015 Red Hat, Inc. # # This program is free software; you can redistribute it and/or modify # it under the terms of the GNU General Public License as published by # the Free Software Foundation; either version 2 of the License, or # (at your option) any later version. # # This program is distributed in the hope that it will be useful, # but WITHOUT ANY WARRANTY; without even the implied warranty of # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the # GNU General Public License for more details. # # You should have received a copy of the GNU General Public License # along with this program. If not, see <http://www.gnu.org/licenses/>. # # Authors: # Nils Philippsen <nils@redhat.com> """This module contains convenience decorators and functions for using PolicyKit with dbus services and clients.""" from __future__ import absolute_import import collections import dbus from decorator import decorator from functools import reduce from .constants import method_call_no_timeout __all__ = ["require_auth", "enable_proxy", "AUTHFAIL_DONTCATCH", "NotAuthorizedException", "AreAuthorizationsObtainable", "IsSystemBusNameAuthorizedAsync"] def require_auth(polkit_auth): """Decorator for DBus service methods. Specify that a user needs a specific PolicyKit authorization `polkit_auth´ to execute it.""" def require_auth_decorator(method): assert hasattr(method, "_dbus_is_method") setattr(method, "_slip_polkit_auth_required", polkit_auth) return method return require_auth_decorator AUTH_EXC_PREFIX = \ "org.fedoraproject.slip.dbus.service.PolKit.NotAuthorizedException." class AUTHFAIL_DONTCATCH(object): pass def enable_proxy( func=None, authfail_result=AUTHFAIL_DONTCATCH, authfail_exception=None, authfail_callback=None): """Decorator for DBus proxy methods. Let's you (optionally) specify either a result value or an exception type and a callback which is returned, thrown or called respectively if a PolicyKit authorization doesn't exist or can't be obtained in the DBus mechanism, i.e. an appropriate DBus exception is thrown. An exception constructor may and a callback must accept an `action_id´ parameter which will be set to the id of the PolicyKit action for which authorization could not be obtained. Examples: 1) Return `False´ in the event of an authorization problem, and call `error_handler´: def error_handler(action_id=None): print "Authorization problem:", action_id class MyProxy(object): @polkit.enable_proxy(authfail_result=False, authfail_callback=error_handler) def some_method(self, ...): ... 2) Throw a `MyAuthError´ instance in the event of an authorization problem: class MyAuthError(Exception): def __init__(self, *args, **kwargs): action_id = kwargs.pop("action_id") super(MyAuthError, self).__init__(*args, **kwargs) self.action_id = action_id class MyProxy(object): @polkit.enable_proxy(authfail_exception=MyAuthError) def some_method(self, ...): ...""" assert(func is None or isinstance(func, collections.Callable)) assert( authfail_result in (None, AUTHFAIL_DONTCATCH) or authfail_exception is None) assert( authfail_callback is None or isinstance(authfail_callback, collections.Callable)) assert( authfail_exception is None or issubclass(authfail_exception, Exception)) def _enable_proxy(func, *p, **k): try: return func(*p, **k) except dbus.DBusException as e: exc_name = e.get_dbus_name() if not exc_name.startswith(AUTH_EXC_PREFIX): raise action_id = exc_name[len(AUTH_EXC_PREFIX):] if authfail_callback is not None: authfail_callback(action_id=action_id) if authfail_exception is not None: try: af_exc = authfail_exception(action_id=action_id) except: af_exc = authfail_exception() raise af_exc if authfail_result is AUTHFAIL_DONTCATCH: raise return authfail_result if func is not None: return decorator(_enable_proxy, func) else: def decorate(func): return decorator(_enable_proxy, func) return decorate class NotAuthorizedException(dbus.DBusException): """Exception which a DBus service method throws if an authorization required for executing it can't be obtained.""" _dbus_error_name = \ "org.fedoraproject.slip.dbus.service.PolKit.NotAuthorizedException" def __init__(self, action_id, *p, **k): self._dbus_error_name = self.__class__._dbus_error_name + "." +\ action_id super(NotAuthorizedException, self).__init__(*p, **k) class PolKit(object): """Convenience wrapper around polkit.""" _dbus_name = 'org.freedesktop.PolicyKit1' _dbus_path = '/org/freedesktop/PolicyKit1/Authority' _dbus_interface = 'org.freedesktop.PolicyKit1.Authority' __interface = None __bus = None __bus_name = None __signal_receiver = None @classmethod def _on_name_owner_changed(cls, name, old_owner, new_owner): if name == cls._dbus_name and PolKit.__bus: PolKit.__bus.remove_signal_receiver(PolKit.__signal_receiver) PolKit.__bus = None PolKit.__signal_receiver = None PolKit.__interface = None @property def _bus(self): if not PolKit.__bus: PolKit.__bus = dbus.SystemBus() PolKit.__signal_receiver = PolKit.__bus.add_signal_receiver( handler_function=self._on_name_owner_changed, signal_name='NameOwnerChanged', dbus_interface='org.freedesktop.DBus', arg0=self._dbus_name) return PolKit.__bus @property def _bus_name(self): if not PolKit.__bus_name: PolKit.__bus_name = self._bus.get_unique_name() return PolKit.__bus_name @property def _interface(self): if not PolKit.__interface: try: PolKit.__interface = dbus.Interface(self._bus.get_object( self._dbus_name, self._dbus_path), self._dbus_interface) except dbus.DBusException: pass return PolKit.__interface @property def _polkit_present(self): return bool(self._interface) def __dbus_system_bus_name_uid(self, system_bus_name): bus_object = self._bus.get_object( 'org.freedesktop.DBus', '/org/freedesktop/DBus') bus_interface = dbus.Interface(bus_object, 'org.freedesktop.DBus') try: uid = bus_interface.GetConnectionUnixUser(system_bus_name) except: uid = None return uid def __authorization_is_obtainable(self, authorization): if not self._polkit_present: return True (is_authorized, is_challenge, details) = \ self._interface.CheckAuthorization( ("system-bus-name", {"name": self._bus_name}), authorization, {}, 0, "") return is_authorized or is_challenge def AreAuthorizationsObtainable(self, authorizations): if not self._polkit_present: return True if not isinstance(authorizations, (tuple, list, set)): authorizations = (authorizations,) obtainable = \ reduce( lambda x, y: x and self.__authorization_is_obtainable(y), authorizations, True) return obtainable def IsSystemBusNameAuthorizedAsync( self, system_bus_name, action_id, reply_handler, error_handler, challenge=True, details={}): if not self._polkit_present: return reply_handler(action_id is None or self.__dbus_system_bus_name_uid(system_bus_name) == 0) flags = 0 if challenge: flags |= 0x1 def reply_cb(args): (is_authorized, is_challenge, details) = args reply_handler(is_authorized) self._interface.CheckAuthorization( ("system-bus-name", {"name": system_bus_name}), action_id, details, flags, "", reply_handler=reply_cb, error_handler=error_handler, timeout=method_call_no_timeout) __polkit = PolKit() def AreAuthorizationsObtainable(authorizations): return __polkit.AreAuthorizationsObtainable(authorizations) def IsSystemBusNameAuthorizedAsync( system_bus_name, action_id, reply_handler, error_handler, challenge=True, details={}): return __polkit.IsSystemBusNameAuthorizedAsync( system_bus_name, action_id, reply_handler, error_handler, challenge, details) PK {\DD` ` proxies.pynu [ PK {\g Ih h ' __pycache__/polkit.cpython-36.opt-1.pycnu [ PK {\rbb b ) Y& __pycache__/mainloop.cpython-36.opt-1.pycnu [ PK {\@ $ 3 __pycache__/constants.cpython-36.pycnu [ PK {\`: ( E4 __pycache__/proxies.cpython-36.opt-1.pycnu [ PK {\`: " 9 __pycache__/proxies.cpython-36.pycnu [ PK {\@ * > __pycache__/constants.cpython-36.opt-1.pycnu [ PK {\Rf0 $ ? __pycache__/bus.cpython-36.opt-1.pycnu [ PK {\ )* ) C __pycache__/__init__.cpython-36.opt-1.pycnu [ PK {\x ( D __pycache__/service.cpython-36.opt-1.pycnu [ PK {\ )* # 7Z __pycache__/__init__.cpython-36.pycnu [ PK {\ N N ( \ __pycache__/introspection.cpython-36.pycnu [ PK {\UKC C ! n __pycache__/polkit.cpython-36.pycnu [ PK {\rbb b # J __pycache__/mainloop.cpython-36.pycnu [ PK {\x " __pycache__/service.cpython-36.pycnu [ PK {\Rf0 ; __pycache__/bus.cpython-36.pycnu [ PK {\ N N . [ __pycache__/introspection.cpython-36.opt-1.pycnu [ PK {\!+ service.pynu [ PK {\ introspection.pynu [ PK {\4 __init__.pynu [ PK {\,Vr constants.pynu [ PK {\bΜ# # mainloop.pynu [ PK {\$:Y Y l bus.pynu [ PK {\?CI$ I$ polkit.pynu [ PK }5