1 from __future__ import with_statement
4 from fnmatch import fnmatch
6 from dbuscron.logger import Logger
9 def dbus_to_str(value):
11 if isinstance(value, dbus.Byte):
12 result = str(int(value))
13 elif isinstance(value, dbus.ByteArray):
14 result = ','.join(str(ord(v)) for v in value)
15 elif isinstance(value, dbus.Array):
16 result = ','.join(dbus_to_str(v) for v in value)
17 elif isinstance(value, dbus.Dictionary):
18 result = ','.join('%s:%s' % (k, dbus_to_str(v)) for k, v in value.iteritems())
19 elif isinstance(value, dbus.String):
20 result = value.encode('utf-8')
25 log.error('convert exception', e)
28 def get_dbus_message_type(message):
29 result = message.__class__.__name__[0:-7]
30 for c in 'ABCDEFGHIJKLMNOPQRSTUVWXYZ':
31 result = result.replace(c, '_'+c.lower())
32 return result.strip('_')
34 class DbusBus(object):
39 def __new__(cls, *args, **kw):
41 cls.__bus = super(DbusBus, cls).__new__(cls)
44 def __init__(self, session_bus_address=None):
45 if session_bus_address:
46 self.set_session_bus_address(session_bus_address)
48 self.get_session_bus_address()
50 from dbus.mainloop.glib import DBusGMainLoop
51 DBusGMainLoop(set_as_default=True)
53 def set_session_bus_address(self, value):
54 os.environ['DBUS_SESSION_BUS_ADDRESS'] = str(value)
56 def get_session_bus_address(self):
58 return os.environ['DBUS_SESSION_BUS_ADDRESS']
60 with open('/tmp/session_bus_address.user', 'rb') as f:
61 session_bus_address = f.readline().strip().split('=', 1).pop().strip("'\"")
62 os.environ['DBUS_SESSION_BUS_ADDRESS'] = session_bus_address
63 log('session bus address aquired', session_bus_address)
64 return session_bus_address
66 session_bus_address = property(get_session_bus_address, set_session_bus_address)
70 if not self.__system_bus:
71 self.__system_bus = dbus.SystemBus()
72 return self.__system_bus
76 if not self.__session_bus:
77 self.__session_bus = dbus.SessionBus()
78 return self.__session_bus
80 def attach_handler(self, handler):
82 self.__system_bus.add_message_filter(handler)
83 if self.__session_bus:
84 self.__session_bus.add_message_filter(handler)
86 from gobject import MainLoop
90 class DbusRule(object):
91 def __init__(self, bus_=None, type_=None, sender_=None, interface_=None, path_=None, member_=None, destination_=None, args_=[]):
94 self._sender = sender_
95 self._interface = interface_
97 self._member = member_
98 self._destination = destination_
104 self._bus.add_match_string(rule)
106 def unregister(self):
109 self._bus.remove_match_string(rule)
116 for key in ['type', 'sender', 'interface', 'path', 'member', 'destination']:
117 value = getattr(self, '_'+key)
118 if value is not None:
119 rule.append("%s='%s'" % (key, value))
122 for i, arg in enumerate(self._args):
123 rule.append("arg%d%s='%s'" % (i, 'path' if arg.startswith('/') else '', arg))
125 return ','.join(rule)
127 def match(self, bus, message):
128 if self._bus not in (None, bus):
131 if self._type is not None:
132 type_ = get_dbus_message_type(message)
133 if self._type != type_:
136 if self._sender not in (None, message.get_sender()):
139 if self._interface not in (None, message.get_interface()):
142 if self._path not in (None, message.get_path()):
145 if self._member not in (None, message.get_member()):
148 if self._destination not in (None, message.get_destination()):
151 if self._args is not None:
152 args_ = message.get_args_list()
153 for i, arg in enumerate(args_):
154 if i >= len(self._args):
157 if self._args[i] not in (None, a):
158 if not fnmatch(a, self._args[i]):