0a18473ca7
* this is a side effect of follow_name_owner_changes which removes some
blocking calls in the __init__ of proxies. It introduces some semantics
we might not want (such as following name owner changes) but which
are fairly beinign
119 lines
4.3 KiB
Python
119 lines
4.3 KiB
Python
# Copyright (C) 2006-2007 Red Hat, Inc.
|
|
# Copyright (C) 2007 One Laptop Per Child
|
|
#
|
|
# This library is free software; you can redistribute it and/or
|
|
# modify it under the terms of the GNU Lesser General Public
|
|
# License as published by the Free Software Foundation; either
|
|
# version 2 of the License, or (at your option) any later version.
|
|
#
|
|
# This library 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
|
|
# Lesser General Public License for more details.
|
|
#
|
|
# You should have received a copy of the GNU Lesser General Public
|
|
# License along with this library; if not, write to the
|
|
# Free Software Foundation, Inc., 59 Temple Place - Suite 330,
|
|
# Boston, MA 02111-1307, USA.
|
|
|
|
import logging
|
|
|
|
import dbus
|
|
import gobject
|
|
|
|
_ACTIVITY_REGISTRY_SERVICE_NAME = 'org.laptop.ActivityRegistry'
|
|
_ACTIVITY_REGISTRY_IFACE = 'org.laptop.ActivityRegistry'
|
|
_ACTIVITY_REGISTRY_PATH = '/org/laptop/ActivityRegistry'
|
|
|
|
def _activity_info_from_dict(info_dict):
|
|
if not info_dict:
|
|
return None
|
|
return ActivityInfo(info_dict['name'], info_dict['icon'],
|
|
info_dict['service_name'], info_dict['path'],
|
|
info_dict['show_launcher'])
|
|
|
|
class ActivityInfo(object):
|
|
def __init__(self, name, icon, service_name, path, show_launcher):
|
|
self.name = name
|
|
self.icon = icon
|
|
self.service_name = service_name
|
|
self.path = path
|
|
self.show_launcher = show_launcher
|
|
|
|
class ActivityRegistry(gobject.GObject):
|
|
__gsignals__ = {
|
|
'activity-added': (gobject.SIGNAL_RUN_FIRST, gobject.TYPE_NONE,
|
|
([gobject.TYPE_PYOBJECT]))
|
|
}
|
|
def __init__(self):
|
|
gobject.GObject.__init__(self)
|
|
|
|
bus = dbus.SessionBus()
|
|
|
|
# FIXME: Is follow_name_owner_changes what we really want?
|
|
# It speeds up the start time by about 2 seconds
|
|
# but is really a side effect of starting a proxy
|
|
# in this state (i.e. we don't block in the constructor)
|
|
bus_object = bus.get_object(_ACTIVITY_REGISTRY_SERVICE_NAME,
|
|
_ACTIVITY_REGISTRY_PATH,
|
|
follow_name_owner_changes = True)
|
|
self._registry = dbus.Interface(bus_object, _ACTIVITY_REGISTRY_IFACE)
|
|
self._registry.connect_to_signal('ActivityAdded', self._activity_added_cb)
|
|
|
|
# Two caches fo saving some travel across dbus.
|
|
self._service_name_to_activity_info = {}
|
|
self._mime_type_to_activities = {}
|
|
|
|
def _convert_info_list(self, info_list):
|
|
result = []
|
|
|
|
for info_dict in info_list:
|
|
result.append(_activity_info_from_dict(info_dict))
|
|
|
|
return result
|
|
|
|
def get_activities(self):
|
|
info_list = self._registry.GetActivities()
|
|
return self._convert_info_list(info_list)
|
|
|
|
def get_activity(self, service_name):
|
|
if self._service_name_to_activity_info.has_key(service_name):
|
|
return self._service_name_to_activity_info[service_name]
|
|
|
|
info_dict = self._registry.GetActivity(service_name)
|
|
activity_info = _activity_info_from_dict(info_dict)
|
|
|
|
self._service_name_to_activity_info[service_name] = activity_info
|
|
return activity_info
|
|
|
|
def find_activity(self, name):
|
|
info_list = self._registry.FindActivity(name)
|
|
return self._convert_info_list(info_list)
|
|
|
|
def get_activities_for_type(self, mime_type):
|
|
if self._mime_type_to_activities.has_key(mime_type):
|
|
return self._mime_type_to_activities[mime_type]
|
|
|
|
info_list = self._registry.GetActivitiesForType(mime_type)
|
|
activities = self._convert_info_list(info_list)
|
|
|
|
self._mime_type_to_activities[mime_type] = activities
|
|
return activities
|
|
|
|
def add_bundle(self, bundle_path):
|
|
return self._registry.AddBundle(bundle_path)
|
|
|
|
def _activity_added_cb(self, info_dict):
|
|
logging.debug('ActivityRegistry._activity_added_cb: flushing caches')
|
|
self._service_name_to_activity_info.clear()
|
|
self._mime_type_to_activities.clear()
|
|
self.emit('activity-added', _activity_info_from_dict(info_dict))
|
|
|
|
_registry = None
|
|
|
|
def get_registry():
|
|
global _registry
|
|
if not _registry:
|
|
_registry = ActivityRegistry()
|
|
return _registry
|