asda?‰PNG
IHDR ? f ??C1 sRGB ?? é gAMA ±? üa pHYs ? ??o¨d GIDATx^íüL”÷ e÷Y?a?("Bh?_ò???￠§?q5k?*:t0A-o??￥]VkJ￠M??f?±8\k2íll￡1]q?ù???T
dbus/constants.py 0000644 00000002700 15102715602 0010065 0 ustar 00 # -*- 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 .
#
# Authors:
# Nils Philippsen
"""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
dbus/bus.py 0000644 00000002531 15102715602 0006644 0 ustar 00 # -*- 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 .
#
# Authors:
# Nils Philippsen
"""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})
dbus/introspection.py 0000644 00000010330 15102715602 0010747 0 ustar 00 # -*- 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 .
#
# Authors:
# Nils Philippsen
"""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
dbus/mainloop.py 0000644 00000006443 15102715602 0007677 0 ustar 00 # -*- 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 .
#
# Authors:
# Nils Philippsen
"""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)
dbus/polkit.py 0000644 00000022111 15102715602 0007351 0 ustar 00 # -*- 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 .
#
# Authors:
# Nils Philippsen
"""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)
dbus/proxies.py 0000644 00000003540 15102715602 0007545 0 ustar 00 # -*- coding: utf-8 -*-
# slip.dbus.proxies -- slightly augmented dbus proxy classes
#
# Copyright © 2005-2007 Collabora Ltd.
# 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 .
#
# Authors:
# Nils Philippsen
"""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
dbus/service.py 0000644 00000017640 15102715602 0007522 0 ustar 00 # -*- 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 .
#
# Authors:
# Nils Philippsen
"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)
dbus/__pycache__/introspection.cpython-36.opt-1.pyc 0000644 00000011116 15102715602 0016175 0 ustar 00 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
W s z"IElem.__init__..)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__..)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 s ,
dbus/__pycache__/mainloop.cpython-36.opt-1.pyc 0000644 00000006142 15102715602 0015116 0 ustar 00 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 s
> dbus/__pycache__/polkit.cpython-36.opt-1.pyc 0000644 00000017150 15102715602 0014603 0 ustar 00 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..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.._enable_proxyNc s
t | S )N)r )r )r# r r decorate s z enable_proxy..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 s z4PolKit.AreAuthorizationsObtainable..)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..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 s( Wo dbus/__pycache__/__init__.cpython-36.pyc 0000644 00000000606 15102715602 0014077 0 ustar 00 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 s dbus/__pycache__/__init__.cpython-36.opt-1.pyc 0000644 00000000606 15102715602 0015036 0 ustar 00 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 s dbus/__pycache__/bus.cpython-36.pyc 0000644 00000001322 15102715602 0013125 0 ustar 00 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 s
dbus/__pycache__/proxies.cpython-36.pyc 0000644 00000002345 15102715602 0014033 0 ustar 00 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 s
dbus/__pycache__/mainloop.cpython-36.pyc 0000644 00000006142 15102715602 0014157 0 ustar 00 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 s
> dbus/__pycache__/proxies.cpython-36.opt-1.pyc 0000644 00000002345 15102715602 0014772 0 ustar 00 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 s
dbus/__pycache__/introspection.cpython-36.pyc 0000644 00000011116 15102715602 0015236 0 ustar 00 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
W s z"IElem.__init__..)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__..)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 s ,
dbus/__pycache__/constants.cpython-36.pyc 0000644 00000000335 15102715602 0014353 0 ustar 00 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 s dbus/__pycache__/constants.cpython-36.opt-1.pyc 0000644 00000000335 15102715602 0015312 0 ustar 00 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 s dbus/__pycache__/bus.cpython-36.opt-1.pyc 0000644 00000001322 15102715602 0014064 0 ustar 00 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 s
dbus/__pycache__/polkit.cpython-36.pyc 0000644 00000017503 15102715602 0013646 0 ustar 00 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..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.._enable_proxyc s
t | S )N)r )r )r% r r decorate s z enable_proxy..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 s z4PolKit.AreAuthorizationsObtainable..)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..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 s( Wo dbus/__pycache__/service.cpython-36.opt-1.pyc 0000644 00000012352 15102715602 0014740 0 ustar 00 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
dbus/__pycache__/service.cpython-36.pyc 0000644 00000012352 15102715602 0014001 0 ustar 00 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
dbus/__init__.py 0000644 00000000336 15102715602 0007613 0 ustar 00 # -*- 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
__pycache__/__init__.cpython-36.pyc 0000644 00000000161 15102715602 0013136 0 ustar 00 3
uAc @ s d S )N r r r /usr/lib/python3.6/__init__.py s __pycache__/__init__.cpython-36.opt-1.pyc 0000644 00000000161 15102715602 0014075 0 ustar 00 3
uAc @ s d S )N r r r /usr/lib/python3.6/__init__.py s _wrappers/__pycache__/__init__.cpython-36.pyc 0000644 00000000161 15102715602 0015140 0 ustar 00 3
uAc @ s d S )N r r r /usr/lib/python3.6/__init__.py s _wrappers/__pycache__/__init__.cpython-36.opt-1.pyc 0000644 00000000161 15102715602 0016077 0 ustar 00 3
uAc @ s d S )N r r r /usr/lib/python3.6/__init__.py s _wrappers/__pycache__/_glib.cpython-36.pyc 0000644 00000001250 15102715602 0014455 0 ustar 00 3
uAc\ @ s d Z ddlmZ ddlZdddgZeje ZdZxhedkrdejkrPejd Zndejkrdejd Zedkr2y ddl Z W q2 e
k
r ddl Z Y q2X q2W x*eD ]"Z
e
eekreee
eee
qW dS ) zjThis module lets some other slip modules cooperate with either the glib
or the gi.repository.GLib modules. )absolute_importNZMainLoopZ
source_removeZ timeout_addzgi.repository.GLibglib)__doc__Z
__future__r sys__all__modules__name___selfZ_modr ImportErrorZgi.repository.GLibZgiZwhatdirsetattrgetattr r r /usr/lib/python3.6/_glib.py s$
_wrappers/__pycache__/_glib.cpython-36.opt-1.pyc 0000644 00000001250 15102715602 0015414 0 ustar 00 3
uAc\ @ s d Z ddlmZ ddlZdddgZeje ZdZxhedkrdejkrPejd Zndejkrdejd Zedkr2y ddl Z W q2 e
k
r ddl Z Y q2X q2W x*eD ]"Z
e
eekreee
eee
qW dS ) zjThis module lets some other slip modules cooperate with either the glib
or the gi.repository.GLib modules. )absolute_importNZMainLoopZ
source_removeZ timeout_addzgi.repository.GLibglib)__doc__Z
__future__r sys__all__modules__name___selfZ_modr ImportErrorZgi.repository.GLibZgiZwhatdirsetattrgetattr r r /usr/lib/python3.6/_glib.py s$
_wrappers/_glib.py 0000644 00000003134 15102715602 0010174 0 ustar 00 # -*- coding: utf-8 -*-
# slip._wrappers._glib -- abstract (some) differences between glib and
# gi.repository.GLib
#
# Copyright © 2012, 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 .
#
# Authors:
# Nils Philippsen
"""This module lets some other slip modules cooperate with either the glib
or the gi.repository.GLib modules."""
from __future__ import absolute_import
import sys
__all__ = ['MainLoop', 'source_remove', 'timeout_add']
_self = sys.modules[__name__]
_mod = None
while _mod is None:
if 'gi.repository.GLib' in sys.modules:
_mod = sys.modules['gi.repository.GLib']
elif 'glib' in sys.modules:
_mod = sys.modules['glib']
# if not yet imported, try to import glib first, then
# gi.repository.GLib ...
if _mod is None:
try:
import glib
except ImportError:
import gi.repository.GLib
# ... then repeat.
for what in __all__:
if what not in dir(_self):
setattr(_self, what, getattr(_mod, what))
_wrappers/__init__.py 0000644 00000000000 15102715602 0010644 0 ustar 00 util/files.py 0000644 00000017257 15102715602 0007210 0 ustar 00 # -*- coding: utf-8 -*-
# slip.util.files -- file helper functions
#
# Copyright © 2009, 2010, 2012, 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 .
#
# Authors:
# Nils Philippsen
"""This module contains helper functions for dealing with files."""
from __future__ import absolute_import
# ensure range() returns a generator
if 'xrange' in dir(__builtins__):
range = xrange
__all__ = ["issamefile", "linkfile", "copyfile", "linkorcopyfile",
"overwrite_safely"]
import os
import selinux
import tempfile
import errno
import stat
BLOCKSIZE = 1024
def _issamefile(path1, path2):
s1 = os.stat(path1)
s2 = os.stat(path2)
return os.path.samestat(s1, s2)
def issamefile(path1, path2, catch_stat_exceptions=[]):
"""Check whether two paths point to the same file (i.e. are hardlinked)."""
if catch_stat_exceptions is True:
catch_stat_exceptions = Exception
try:
return _issamefile(path1, path2)
except catch_stat_exceptions:
return False
def linkfile(srcpath, dstpath):
"""Hardlink srcpath to dstpath.
Attempt to atomically replace dstpath if it exists."""
if issamefile(srcpath, dstpath, catch_stat_exceptions=OSError):
return
dstpath = os.path.abspath(dstpath)
dstdname = os.path.dirname(dstpath)
dstbname = os.path.basename(dstpath)
hardlinked = False
for attempt in range(tempfile.TMP_MAX):
_dsttmp = tempfile.mktemp(prefix=dstbname + os.extsep, dir=dstdname)
try:
os.link(srcpath, _dsttmp)
except OSError as e:
if e.errno == errno.EEXIST:
# try another name
pass
else:
raise
else:
hardlinked = True
break
if hardlinked:
os.rename(_dsttmp, dstpath)
def copyfile(srcpath, dstpath, copy_mode_from_dst=True, run_restorecon=True):
"""Copy srcpath to dstpath.
Abort operation if e.g. not enough space is available. Attempt to
atomically replace dstpath if it exists."""
if issamefile(srcpath, dstpath, catch_stat_exceptions=OSError):
return
dstpath = os.path.abspath(dstpath)
dstdname = os.path.dirname(dstpath)
dstbname = os.path.basename(dstpath)
srcfile = open(srcpath, "rb")
dsttmpfile = tempfile.NamedTemporaryFile(
prefix=dstbname + os.path.extsep, dir=dstdname, delete=False)
s = os.stat(srcpath)
if copy_mode_from_dst:
# attempt to copy mode from destination file (if it exists,
# otherwise fall back to copying it from the source file below)
try:
s = os.stat(dstpath)
except OSError:
pass
os.fchmod(dsttmpfile.fileno(), stat.S_IMODE(s.st_mode))
data = None
while data != "":
data = srcfile.read(BLOCKSIZE)
try:
dsttmpfile.write(data)
except:
srcfile.close()
dsttmpfile.close()
os.unlink(dsttmpfile.name)
raise
srcfile.close()
dsttmpfile.close()
os.rename(dsttmpfile.name, dstpath)
if run_restorecon and selinux.is_selinux_enabled() > 0:
selinux.restorecon(dstpath)
def linkorcopyfile(
srcpath, dstpath, copy_mode_from_dst=True, run_restorecon=True):
"""First attempt to hardlink srcpath to dstpath, if hardlinking isn't
possible, attempt copying srcpath to dstpath."""
try:
linkfile(srcpath, dstpath)
return
except OSError as e:
if e.errno not in (errno.EMLINK, errno.EPERM, errno.EXDEV):
# don't bother copying
raise
else:
# try copying
pass
copyfile(srcpath, dstpath, copy_mode_from_dst, run_restorecon)
def symlink_atomically(srcpath, dstpath, force=False, preserve_context=True):
"""Create a symlink, optionally replacing dstpath atomically, optionally
setting or preserving SELinux context."""
dstdname = os.path.dirname(dstpath)
dstbname = os.path.basename(dstpath)
run_restorecon = False
ctx = None
if preserve_context and selinux.is_selinux_enabled() <= 0:
preserve_context = False
else:
try:
ret, ctx = selinux.lgetfilecon(dstpath)
if ret < 0:
raise RuntimeError("getfilecon(%r) failed" % dstpath)
except OSError as e:
if e.errno == errno.ENOENT:
run_restorecon = True
else:
raise
if not force:
os.symlink(srcpath, dstpath)
if preserve_context:
selinux.restorecon(dstpath)
else:
dsttmp = None
for attempt in range(tempfile.TMP_MAX):
_dsttmp = tempfile.mktemp(
prefix=dstbname + os.extsep, dir=dstdname)
try:
os.symlink(srcpath, _dsttmp)
except OSError as e:
if e.errno == errno.EEXIST:
# try again
continue
raise
else:
dsttmp = _dsttmp
break
if dsttmp is None:
raise IOError(
errno.EEXIST,
"No suitable temporary symlink could be created.")
if preserve_context and not run_restorecon:
selinux.lsetfilecon(dsttmp, ctx)
try:
os.rename(dsttmp, dstpath)
except:
# clean up
os.remove(dsttmp)
raise
if run_restorecon:
selinux.restorecon(dstpath)
def overwrite_safely(
path, content, preserve_mode=True, preserve_context=True,
preserve_ownership=True):
"""Safely overwrite a file by creating a temporary file in the same
directory, writing it, moving it over the original file, eventually
preserving file mode, SELinux context and ownership."""
path = os.path.realpath(path)
dir_ = os.path.dirname(path)
base = os.path.basename(path)
fd = None
f = None
tmpname = None
exists = os.path.exists(path)
if preserve_context and selinux.is_selinux_enabled() <= 0:
preserve_context = False
try:
fd, tmpname = tempfile.mkstemp(prefix=base + os.path.extsep,
dir=dir_)
if exists:
s = os.stat(path)
if preserve_ownership:
os.fchown(fd, s.st_uid, s.st_gid)
if preserve_mode:
os.fchmod(fd, stat.S_IMODE(s.st_mode))
if preserve_context:
ret, ctx = selinux.getfilecon(path)
if ret < 0:
raise RuntimeError("getfilecon(%r) failed" % path)
f = os.fdopen(fd, "w")
fd = None
f.write(content)
f.close()
f = None
os.rename(tmpname, path)
if preserve_context:
if exists:
selinux.setfilecon(path, ctx)
else:
selinux.restorecon(path)
finally:
if f:
f.close()
elif fd:
os.close(fd)
if tmpname and os.path.isfile(tmpname):
try:
os.unlink(tmpname)
except:
pass
util/__pycache__/__init__.cpython-36.pyc 0000644 00000000345 15102715602 0014117 0 ustar 00 3
uAcl @ s( d dl mZ ddlmZ ddlmZ dS ) )absolute_import )hookable)filesN)Z
__future__r r r r r /usr/lib/python3.6/__init__.py s util/__pycache__/__init__.cpython-36.opt-1.pyc 0000644 00000000345 15102715602 0015056 0 ustar 00 3
uAcl @ s( d dl mZ ddlmZ ddlmZ dS ) )absolute_import )hookable)filesN)Z
__future__r r r r r /usr/lib/python3.6/__init__.py s util/__pycache__/hookable.cpython-36.opt-1.pyc 0000644 00000013376 15102715602 0015113 0 ustar 00 3
uAc^ @ sl d Z ddlZddlmZ ddgZG dd deZG dd d eZG d
d deeeZ G d d de
e Z dS ) z[This module contains variants of certain base types which call registered
hooks on changes. N)with_metaclassHookable HookableSetc @ s e Zd Zdd Zedd ZdS ) HookableTypec
C s d|kry |d }W nJ t k
r^ d }x0dd |D D ] }|rRtdt| q8|}q8W Y nX x |d D ]}tj||||< qjW tj| |||S )N_hookable_change_methodsZ_hookable_base_classc s s | ]}|t kr|V qd S )N)r ).0x r /usr/lib/python3.6/hookable.py ) s z'HookableType.__new__..ztoo many base classes: %s)KeyError TypeErrorstrr wrap_methodtype__new__)clsnamebasesZdctbaseZbase_candidate
methodnamer r r
r " s zHookableType.__new__c s t || fdd}||_|S )Nc s | f||}| j |S )N)
_run_hooks)selfpkZretval)funcr r
methodwrapper9 s z/HookableType.wrap_method..methodwrapper)getattr__name__)r r r r r )r r
r 5 s
zHookableType.wrap_methodN)r
__module__ __qualname__r classmethodr r r r r
r s r c @ s6 e Zd Zd ddZdd Zdd Zdd Zd
d ZdS )
_HookEntryNc C s xFt |D ]:\}}y t| W q
tk
rB td||f Y q
X q
W xF|j D ]:\}}y t| W qR tk
r td||f Y qRX qRW t|tst|}|| _|| _|| _|| _ d | _
d S )Nz*Positional argument %d is not hashable: %rz'Keyword argument %r is not hashable: %r) enumeratehashr
items
isinstancetuple_HookEntry__hook_HookEntry__args_HookEntry__kwargs_HookEntry__hookable_HookEntry__hash)r hookargskwargshookablenr r r r r
__init__D s*
z_HookEntry.__init__c C s$ | j |j ko"| j|jko"| j|jkS )N)r( r) r* )r objr r r
__cmp__c s z_HookEntry.__cmp__c C s | j s| j | _ | j S )N)r,
_compute_hash)r r r r
__hash__i s
z_HookEntry.__hash__c C s> t | j}t |t | jA }t |t tt| jj A }|S )N)r$ r( r) r' sortedr* r% )r hashvaluer r r
r5 n s
z_HookEntry._compute_hashc C s4 | j r | j| j f| j| j n| j| j| j d S )N)r+ r( r) r* )r r r r
runu s z_HookEntry.run)N)r r r r2 r4 r6 r5 r9 r r r r
r" B s
r" c @ s e Zd ZdZedd Zdd Zdd ZeeeZdd Z d
d Z
ee e
Z d d
Z dd Z
dd Zdd Zdd Zdd Zdd ZdS )r z2An object which calls registered hooks on changes.c O s t | dst | _| jS )N__real_hooks__)hasattrsetr: )r r r r r r
__hooks__ s
zHookable.__hooks__c C s t | dsd| _| jS )N__hooks_enabled__T)r; r> )r r r r
_get_hooks_enabled s
zHookable._get_hooks_enabledc C s
|| _ d S )N)r> )r Zenabledr r r
_set_hooks_enabled s zHookable._set_hooks_enabledc C s t | dsd| _| jS )N__hooks_frozen__F)r; rA )r r r r
_get_hooks_frozen s
zHookable._get_hooks_frozenc C sB || j krd S || _|r"t | _n x| jD ] }|j q*W | `d S )N) hooks_frozenrA r< __hooks_frozen_entries__r9 )r Zfreeze hookentryr r r
_set_hooks_frozen s
zHookable._set_hooks_frozenc C s
d| _ d S )NT)rC )r r r r
freeze_hooks s zHookable.freeze_hooksc C s
d| _ d S )NF)rC )r r r r
thaw_hooks s zHookable.thaw_hooksc O s | j |d f|| d S )N)_Hookable__add_hook)r r- r. r/ r r r
add_hook s zHookable.add_hookc O s | j || f|| d S )N)rI )r r- r. r/ r r r
add_hook_hookable s zHookable.add_hook_hookablec O s t ||||d}| jj| d S )N)r0 )r" r= add)r r- Z _hookabler. r/ rE r r r
Z
__add_hook s zHookable.__add_hookc O s | j jt||| d S )N)r= remover" )r r- r. r/ r r r
remove_hook s zHookable.remove_hookc C s8 | j r4| js&x&| jD ] }|j qW n| jj| j d S )N)
hooks_enabledrC r= r9 rD update)r rE r r r
r s
zHookable._run_hooksN)r r r __doc__propertyr= r? r@ rO rB rF rC rG rH rJ rK rI rN r r r r r
r | s
c @ s e Zd ZdZdZd d Zd
S )r z5A set object which calls registered hooks on changes.rL cleardifference_updatediscardintersection_updatepoprM symmetric_difference_updaterP c C s t j| }t |_|S )N)r< copyr: )r r3 r r r
rY s
zHookableSet.copyN) rL rS rT rU rV rW rM rX rP )r r r rQ r rY r r r r
r s ) rQ collectionsZsixr __all__r r objectr" r r< r r r r r
s ":G util/__pycache__/files.cpython-36.opt-1.pyc 0000644 00000011525 15102715602 0014423 0 ustar 00 3
uAc @ s d Z ddlmZ deekr eZdddddgZdd lZdd l Z dd l
Z
dd l Z dd l Z d
Z
d d Zg fd
dZdd ZdddZdddZdddZdddZd S )z=This module contains helper functions for dealing with files. )absolute_importxrange
issamefilelinkfilecopyfilelinkorcopyfileoverwrite_safelyNi c C s" t j| }t j|}t jj||S )N)osstatpathsamestat)path1path2s1s2 r /usr/lib/python3.6/files.py _issamefile+ s
r c C s0 |dkr t }y
t| |S |k
r* dS X dS )zECheck whether two paths point to the same file (i.e. are hardlinked).TFN) Exceptionr )r
r catch_stat_exceptionsr r r r 2 s
c C s t | |tdrdS tjj|}tjj|}tjj|}d}xpttj D ]b}tj
|tj |d}ytj | | W n2 tk
r } z|j
t
jkrn W Y dd}~X qFX d}P qFW |rtj|| dS )zUHardlink srcpath to dstpath.
Attempt to atomically replace dstpath if it exists.)r NF)prefixdirT)r OSErrorr r abspathdirnamebasenamerangetempfileTMP_MAXmktempextseplinkerrnoEEXISTrename)srcpathdstpathdstdnamedstbnameZ
hardlinkedattempt_dsttmper r r r > s$ Tc
C s8 t | |tdrdS tjj|}tjj|}tjj|}t| d}tj |tjj
|dd}tj | }|rytj |}W n tk
r Y nX tj |j
t j|j d} xP| dkr|jt} y|j| W q |j |j tj|j Y qX qW |j |j tj|j| |r4tj dkr4tj| dS )zCopy srcpath to dstpath.
Abort operation if e.g. not enough space is available. Attempt to
atomically replace dstpath if it exists.)r NrbF)r r delete r )r r r r r r r openr ZNamedTemporaryFiler r
fchmodfilenoS_IMODEst_moderead BLOCKSIZEwritecloseunlinknamer$ selinuxis_selinux_enabled
restorecon)
r% r& copy_mode_from_dstrun_restoreconr' r( ZsrcfileZ
dsttmpfilesdatar r r r _ s<
c C s^ yt | | dS tk
rJ } z |jtjtjtjfkr: n W Y dd}~X nX t| ||| dS )ztFirst attempt to hardlink srcpath to dstpath, if hardlinking isn't
possible, attempt copying srcpath to dstpath.N)r r r" ZEMLINKZEPERMZEXDEVr )r% r& r= r> r+ r r r r s
Fc
C s t jj|}t jj|}d}d}|r6tj dkr6d}n^y&tj|\}}|dk rZtd| W n6 tk
r } z| j t j
krd}n W Y dd} ~ X nX |st j | | |rtj | nd}
xtt
tjD ]f} tj|t j |d} yt j | | W n6 tk
r" } z| j t jkrwĂ W Y dd} ~ X qX | }
P qW |
dkrDtt jd|r^| r^tj|
| yt j|
| W n t j|
Y nX |rtj | dS )zpCreate a symlink, optionally replacing dstpath atomically, optionally
setting or preserving SELinux context.FNr zgetfilecon(%r) failedT)r r z/No suitable temporary symlink could be created.)r r r r r: r; Z lgetfilecon RuntimeErrorr r" ENOENTsymlinkr< r r r r r r# IOErrorZ lsetfileconr$ remove)
r% r& forcepreserve_contextr' r( r> ctxretr+ Zdsttmpr) r* r r r symlink_atomically sV
rJ c C s~ t jj| } t jj| }t jj| }d}d}d} t jj| }
|rPtj dkrPd}ztj |t jj
|d\}} |
rt j | } |rt j || j
| j |rt j|t j| j |rtj| \} }
| dk rtd| t j|d}d}|j| |j d}t j| | |r$|
rtj| |
n
tj| W d|r8|j n|rHt j| | rxt jj| rxyt j| W n Y nX X dS )zSafely overwrite a file by creating a temporary file in the same
directory, writing it, moving it over the original file, eventually
preserving file mode, SELinux context and ownership.Nr F)r r zgetfilecon(%r) failedw) r r realpathr r existsr: r; r Zmkstempr r
fchownst_uidst_gidr0 r2 r3 Z
getfileconrA fdopenr6 r7 r$ Z
setfileconr< isfiler8 )r ZcontentZ
preserve_moderG Zpreserve_ownershipZdir_basefdfZtmpnamerM r? rI rH r r r r sR
)TT)TT)FT)TTT)__doc__Z
__future__r r __builtins__r r __all__r r: r r" r
r5 r r r r r rJ r r r r r s& !
5
? util/__pycache__/files.cpython-36.pyc 0000644 00000011525 15102715602 0013464 0 ustar 00 3
uAc @ s d Z ddlmZ deekr eZdddddgZdd lZdd l Z dd l
Z
dd l Z dd l Z d
Z
d d Zg fd
dZdd ZdddZdddZdddZdddZd S )z=This module contains helper functions for dealing with files. )absolute_importxrange
issamefilelinkfilecopyfilelinkorcopyfileoverwrite_safelyNi c C s" t j| }t j|}t jj||S )N)osstatpathsamestat)path1path2s1s2 r /usr/lib/python3.6/files.py _issamefile+ s
r c C s0 |dkr t }y
t| |S |k
r* dS X dS )zECheck whether two paths point to the same file (i.e. are hardlinked).TFN) Exceptionr )r
r catch_stat_exceptionsr r r r 2 s
c C s t | |tdrdS tjj|}tjj|}tjj|}d}xpttj D ]b}tj
|tj |d}ytj | | W n2 tk
r } z|j
t
jkrn W Y dd}~X qFX d}P qFW |rtj|| dS )zUHardlink srcpath to dstpath.
Attempt to atomically replace dstpath if it exists.)r NF)prefixdirT)r OSErrorr r abspathdirnamebasenamerangetempfileTMP_MAXmktempextseplinkerrnoEEXISTrename)srcpathdstpathdstdnamedstbnameZ
hardlinkedattempt_dsttmper r r r > s$ Tc
C s8 t | |tdrdS tjj|}tjj|}tjj|}t| d}tj |tjj
|dd}tj | }|rytj |}W n tk
r Y nX tj |j
t j|j d} xP| dkr|jt} y|j| W q |j |j tj|j Y qX qW |j |j tj|j| |r4tj dkr4tj| dS )zCopy srcpath to dstpath.
Abort operation if e.g. not enough space is available. Attempt to
atomically replace dstpath if it exists.)r NrbF)r r delete r )r r r r r r r openr ZNamedTemporaryFiler r
fchmodfilenoS_IMODEst_moderead BLOCKSIZEwritecloseunlinknamer$ selinuxis_selinux_enabled
restorecon)
r% r& copy_mode_from_dstrun_restoreconr' r( ZsrcfileZ
dsttmpfilesdatar r r r _ s<
c C s^ yt | | dS tk
rJ } z |jtjtjtjfkr: n W Y dd}~X nX t| ||| dS )ztFirst attempt to hardlink srcpath to dstpath, if hardlinking isn't
possible, attempt copying srcpath to dstpath.N)r r r" ZEMLINKZEPERMZEXDEVr )r% r& r= r> r+ r r r r s
Fc
C s t jj|}t jj|}d}d}|r6tj dkr6d}n^y&tj|\}}|dk rZtd| W n6 tk
r } z| j t j
krd}n W Y dd} ~ X nX |st j | | |rtj | nd}
xtt
tjD ]f} tj|t j |d} yt j | | W n6 tk
r" } z| j t jkrwĂ W Y dd} ~ X qX | }
P qW |
dkrDtt jd|r^| r^tj|
| yt j|
| W n t j|
Y nX |rtj | dS )zpCreate a symlink, optionally replacing dstpath atomically, optionally
setting or preserving SELinux context.FNr zgetfilecon(%r) failedT)r r z/No suitable temporary symlink could be created.)r r r r r: r; Z lgetfilecon RuntimeErrorr r" ENOENTsymlinkr< r r r r r r# IOErrorZ lsetfileconr$ remove)
r% r& forcepreserve_contextr' r( r> ctxretr+ Zdsttmpr) r* r r r symlink_atomically sV
rJ c C s~ t jj| } t jj| }t jj| }d}d}d} t jj| }
|rPtj dkrPd}ztj |t jj
|d\}} |
rt j | } |rt j || j
| j |rt j|t j| j |rtj| \} }
| dk rtd| t j|d}d}|j| |j d}t j| | |r$|
rtj| |
n
tj| W d|r8|j n|rHt j| | rxt jj| rxyt j| W n Y nX X dS )zSafely overwrite a file by creating a temporary file in the same
directory, writing it, moving it over the original file, eventually
preserving file mode, SELinux context and ownership.Nr F)r r zgetfilecon(%r) failedw) r r realpathr r existsr: r; r Zmkstempr r
fchownst_uidst_gidr0 r2 r3 Z
getfileconrA fdopenr6 r7 r$ Z
setfileconr< isfiler8 )r ZcontentZ
preserve_moderG Zpreserve_ownershipZdir_basefdfZtmpnamerM r? rI rH r r r r sR
)TT)TT)FT)TTT)__doc__Z
__future__r r __builtins__r r __all__r r: r r" r
r5 r r r r r rJ r r r r r s& !
5
? util/__pycache__/hookable.cpython-36.pyc 0000644 00000013577 15102715602 0014157 0 ustar 00 3
uAc^ @ sl d Z ddlZddlmZ ddgZG dd deZG dd d eZG d
d deeeZ G d d de
e Z dS ) z[This module contains variants of certain base types which call registered
hooks on changes. N)with_metaclassHookable HookableSetc @ s e Zd Zdd Zedd ZdS ) HookableTypec
C s d|kry |d }W nJ t k
r^ d }x0dd |D D ] }|rRtdt| q8|}q8W Y nX x |d D ]}tj||||< qjW tj| |||S )N_hookable_change_methodsZ_hookable_base_classc s s | ]}|t kr|V qd S )N)r ).0x r /usr/lib/python3.6/hookable.py ) s z'HookableType.__new__..ztoo many base classes: %s)KeyError TypeErrorstrr wrap_methodtype__new__)clsnamebasesZdctbaseZbase_candidate
methodnamer r r
r " s zHookableType.__new__c s t || fdd}||_|S )Nc s | f||}| j |S )N)
_run_hooks)selfpkZretval)funcr r
methodwrapper9 s z/HookableType.wrap_method..methodwrapper)getattr__name__)r r r r r )r r
r 5 s
zHookableType.wrap_methodN)r
__module__ __qualname__r classmethodr r r r r
r s r c @ s6 e Zd Zd ddZdd Zdd Zdd Zd
d ZdS )
_HookEntryNc C s t |tjstt |ts txFt|D ]:\}}y t| W q( tk
r` td||f Y q(X q(W xF|j D ]:\}}y t| W qp tk
r td||f Y qpX qpW t |t st |}|| _
|| _ || _ || _
d | _d S )Nz*Positional argument %d is not hashable: %rz'Keyword argument %r is not hashable: %r)
isinstance collectionsCallableAssertionErrorr enumeratehashr
itemstuple_HookEntry__hook_HookEntry__args_HookEntry__kwargs_HookEntry__hookable_HookEntry__hash)r hookargskwargshookablenr r r r r
__init__D s.
z_HookEntry.__init__c C s$ | j |j ko"| j|jko"| j|jkS )N)r+ r, r- )r objr r r
__cmp__c s z_HookEntry.__cmp__c C s | j s| j | _ | j S )N)r/
_compute_hash)r r r r
__hash__i s
z_HookEntry.__hash__c C s> t | j}t |t | jA }t |t tt| jj A }|S )N)r( r+ r, r* sortedr- r) )r hashvaluer r r
r8 n s
z_HookEntry._compute_hashc C s4 | j r | j| j f| j| j n| j| j| j d S )N)r. r+ r, r- )r r r r
runu s z_HookEntry.run)N)r r r r5 r7 r9 r8 r< r r r r
r" B s
r" c @ s e Zd ZdZedd Zdd Zdd ZeeeZdd Z d
d Z
ee e
Z d d
Z dd Z
dd Zdd Zdd Zdd Zdd ZdS )r z2An object which calls registered hooks on changes.c O s t | dst | _| jS )N__real_hooks__)hasattrsetr= )r r r r r r
__hooks__ s
zHookable.__hooks__c C s t | dsd| _| jS )N__hooks_enabled__T)r> rA )r r r r
_get_hooks_enabled s
zHookable._get_hooks_enabledc C s
|| _ d S )N)rA )r Zenabledr r r
_set_hooks_enabled s zHookable._set_hooks_enabledc C s t | dsd| _| jS )N__hooks_frozen__F)r> rD )r r r r
_get_hooks_frozen s
zHookable._get_hooks_frozenc C sB || j krd S || _|r"t | _n x| jD ] }|j q*W | `d S )N) hooks_frozenrD r? __hooks_frozen_entries__r< )r Zfreeze hookentryr r r
_set_hooks_frozen s
zHookable._set_hooks_frozenc C s
d| _ d S )NT)rF )r r r r
freeze_hooks s zHookable.freeze_hooksc C s
d| _ d S )NF)rF )r r r r
thaw_hooks s zHookable.thaw_hooksc O s | j |d f|| d S )N)_Hookable__add_hook)r r0 r1 r2 r r r
add_hook s zHookable.add_hookc O s | j || f|| d S )N)rL )r r0 r1 r2 r r r
add_hook_hookable s zHookable.add_hook_hookablec O s> t |tjstt |ts tt||||d}| jj| d S )N)r3 )r# r$ r% r& r r" r@ add)r r0 Z _hookabler1 r2 rH r r r
Z
__add_hook s zHookable.__add_hookc O s | j jt||| d S )N)r@ remover" )r r0 r1 r2 r r r
remove_hook s zHookable.remove_hookc C s8 | j r4| js&x&| jD ] }|j qW n| jj| j d S )N)
hooks_enabledrF r@ r< rG update)r rH r r r
r s
zHookable._run_hooksN)r r r __doc__propertyr@ rB rC rR rE rI rF rJ rK rM rN rL rQ r r r r r
r | s
c @ s e Zd ZdZdZd d Zd
S )r z5A set object which calls registered hooks on changes.rO cleardifference_updatediscardintersection_updatepoprP symmetric_difference_updaterS c C s t j| }t |_|S )N)r? copyr= )r r6 r r r
r\ s
zHookableSet.copyN) rO rV rW rX rY rZ rP r[ rS )r r r rT r r\ r r r r
r s ) rT r$ Zsixr __all__r r objectr" r r? r r r r r
s ":G util/hookable.py 0000644 00000014136 15102715602 0007663 0 ustar 00 # -*- coding: utf-8 -*-
# slip.util.hookable -- run hooks on changes in objects
#
# Copyright © 2008 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 .
#
# Authors:
# Nils Philippsen
"""This module contains variants of certain base types which call registered
hooks on changes."""
import collections
from six import with_metaclass
__all__ = ["Hookable", "HookableSet"]
class HookableType(type):
def __new__(cls, name, bases, dct):
if '_hookable_change_methods' in dct:
try:
base = dct["_hookable_base_class"]
except KeyError:
base = None
for base_candidate in (x for x in bases if x != Hookable):
if base:
raise TypeError(
"too many base classes: %s" % str(bases))
else:
base = base_candidate
for methodname in dct["_hookable_change_methods"]:
dct[methodname] = HookableType.wrap_method(base, methodname)
return type.__new__(cls, name, bases, dct)
@classmethod
def wrap_method(cls, base, methodname):
func = getattr(base, methodname)
def methodwrapper(self, *p, **k):
retval = func(self, *p, **k)
self._run_hooks()
return retval
methodwrapper.__name__ = methodname
return methodwrapper
class _HookEntry(object):
def __init__(self, hook, args, kwargs, hookable=None):
assert(isinstance(hook, collections.Callable))
assert(isinstance(hookable, Hookable))
for n, x in enumerate(args):
try:
hash(x)
except TypeError:
raise TypeError(
"Positional argument %d is not hashable: %r" %
(n, x))
for k, x in kwargs.items():
try:
hash(x)
except TypeError:
raise TypeError(
"Keyword argument %r is not hashable: %r" %
(k, x))
if not isinstance(args, tuple):
args = tuple(args)
self.__hook = hook
self.__args = args
self.__kwargs = kwargs
self.__hookable = hookable
self.__hash = None
def __cmp__(self, obj):
return (
self.__hook == obj.__hook and
self.__args == obj.__args and
self.__kwargs == obj.__kwargs)
def __hash__(self):
if not self.__hash:
self.__hash = self._compute_hash()
return self.__hash
def _compute_hash(self):
hashvalue = hash(self.__hook)
hashvalue = hash(hashvalue) ^ hash(self.__args)
hashvalue = hash(hashvalue) ^ hash(
tuple(sorted(self.__kwargs.items())))
return hashvalue
def run(self):
if self.__hookable:
self.__hook(self.__hookable, *self.__args, **self.__kwargs)
else:
self.__hook(*self.__args, **self.__kwargs)
class Hookable(with_metaclass(HookableType, object)):
"""An object which calls registered hooks on changes."""
@property
def __hooks__(self, *p, **k):
if not hasattr(self, "__real_hooks__"):
self.__real_hooks__ = set()
return self.__real_hooks__
def _get_hooks_enabled(self):
if not hasattr(self, "__hooks_enabled__"):
self.__hooks_enabled__ = True
return self.__hooks_enabled__
def _set_hooks_enabled(self, enabled):
self.__hooks_enabled__ = enabled
hooks_enabled = property(_get_hooks_enabled, _set_hooks_enabled)
def _get_hooks_frozen(self):
if not hasattr(self, "__hooks_frozen__"):
self.__hooks_frozen__ = False
return self.__hooks_frozen__
def _set_hooks_frozen(self, freeze):
if freeze == self.hooks_frozen:
return
self.__hooks_frozen__ = freeze
if freeze:
self.__hooks_frozen_entries__ = set()
else:
for hookentry in self.__hooks_frozen_entries__:
hookentry.run()
del self.__hooks_frozen_entries__
hooks_frozen = property(_get_hooks_frozen, _set_hooks_frozen)
def freeze_hooks(self):
self.hooks_frozen = True
def thaw_hooks(self):
self.hooks_frozen = False
def add_hook(self, hook, *args, **kwargs):
self.__add_hook(hook, None, *args, **kwargs)
def add_hook_hookable(self, hook, *args, **kwargs):
self.__add_hook(hook, self, *args, **kwargs)
def __add_hook(self, hook, _hookable, *args, **kwargs):
assert isinstance(hook, collections.Callable)
assert isinstance(_hookable, Hookable)
hookentry = _HookEntry(hook, args, kwargs, hookable=_hookable)
self.__hooks__.add(hookentry)
def remove_hook(self, hook, *args, **kwargs):
self.__hooks__.remove(_HookEntry(hook, args, kwargs))
def _run_hooks(self):
if self.hooks_enabled:
if not self.hooks_frozen:
for hookentry in self.__hooks__:
hookentry.run()
else:
self.__hooks_frozen_entries__.update(self.__hooks__)
class HookableSet(set, Hookable):
"""A set object which calls registered hooks on changes."""
_hookable_change_methods = (
"add", "clear", "difference_update", "discard", "intersection_update",
"pop", "remove", "symmetric_difference_update", "update")
def copy(self):
obj = set.copy(self)
obj.__real_hooks__ = set()
return obj
util/__init__.py 0000644 00000000154 15102715602 0007631 0 ustar 00 # -*- coding: utf-8 -*-
from __future__ import absolute_import
from . import hookable
from . import files
__init__.py 0000644 00000000000 15102715602 0006642 0 ustar 00