Get rid of default type from the activity definition.
Modify code to use activity type id instead, except from mapping service to activity.
This commit is contained in:
parent
8ffff18bc3
commit
58a79eb123
@ -51,8 +51,7 @@ class BrowserActivity(Activity):
|
|||||||
|
|
||||||
activity_ps.connect('service-appeared', self._service_appeared_cb)
|
activity_ps.connect('service-appeared', self._service_appeared_cb)
|
||||||
|
|
||||||
default_type = self.get_default_type()
|
services = activity_ps.get_services_of_type(self._default_type)
|
||||||
services = activity_ps.get_services_of_type(default_type)
|
|
||||||
if len(services) > 0:
|
if len(services) > 0:
|
||||||
self._notif_service = services[0]
|
self._notif_service = services[0]
|
||||||
|
|
||||||
|
@ -3,5 +3,4 @@ name = Web
|
|||||||
id = com.redhat.Sugar.BrowserActivity
|
id = com.redhat.Sugar.BrowserActivity
|
||||||
icon = activity-web
|
icon = activity-web
|
||||||
python_module = browser.BrowserActivity.BrowserActivity
|
python_module = browser.BrowserActivity.BrowserActivity
|
||||||
default_type = _web_olpc._udp
|
|
||||||
show_launcher = yes
|
show_launcher = yes
|
||||||
|
@ -18,11 +18,11 @@ class ActivityHost:
|
|||||||
|
|
||||||
self._activity = dbus.Interface(proxy_obj, Activity.ACTIVITY_INTERFACE)
|
self._activity = dbus.Interface(proxy_obj, Activity.ACTIVITY_INTERFACE)
|
||||||
self._id = self._activity.get_id()
|
self._id = self._activity.get_id()
|
||||||
self._default_type = self._activity.get_default_type()
|
self._type = self._activity.get_type()
|
||||||
self._gdk_window = gtk.gdk.window_foreign_new(self._xid)
|
self._gdk_window = gtk.gdk.window_foreign_new(self._xid)
|
||||||
|
|
||||||
registry = conf.get_activity_registry()
|
registry = conf.get_activity_registry()
|
||||||
info = registry.get_activity(self._default_type)
|
info = registry.get_activity(self._type)
|
||||||
self._icon_name = info.get_icon()
|
self._icon_name = info.get_icon()
|
||||||
|
|
||||||
def get_id(self):
|
def get_id(self):
|
||||||
@ -45,8 +45,8 @@ class ActivityHost:
|
|||||||
def get_shared(self):
|
def get_shared(self):
|
||||||
return self._activity.get_shared()
|
return self._activity.get_shared()
|
||||||
|
|
||||||
def get_default_type(self):
|
def get_type(self):
|
||||||
return self._default_type
|
return self._type
|
||||||
|
|
||||||
def present(self):
|
def present(self):
|
||||||
self._window.activate(gtk.get_current_event_time())
|
self._window.activate(gtk.get_current_event_time())
|
||||||
|
@ -155,12 +155,12 @@ class Shell(gobject.GObject):
|
|||||||
activity = self.get_current_activity()
|
activity = self.get_current_activity()
|
||||||
if activity:
|
if activity:
|
||||||
registry = conf.get_activity_registry()
|
registry = conf.get_activity_registry()
|
||||||
module = registry.get_activity(activity.get_default_type())
|
module = registry.get_activity(activity.get_type())
|
||||||
self._console.set_page(module.get_id())
|
self._console.set_page(module.get_id())
|
||||||
|
|
||||||
def join_activity(self, service):
|
def join_activity(self, service):
|
||||||
registry = conf.get_activity_registry()
|
registry = conf.get_activity_registry()
|
||||||
info = registry.get_activity(service.get_type())
|
info = registry.get_activity_from_type(service.get_type())
|
||||||
|
|
||||||
activity_id = service.get_activity_id()
|
activity_id = service.get_activity_id()
|
||||||
|
|
||||||
@ -172,24 +172,14 @@ class Shell(gobject.GObject):
|
|||||||
|
|
||||||
if activity_ps:
|
if activity_ps:
|
||||||
activity = ActivityFactory.create(info.get_id())
|
activity = ActivityFactory.create(info.get_id())
|
||||||
activity.set_default_type(service.get_type())
|
|
||||||
activity.join(activity_ps.object_path())
|
activity.join(activity_ps.object_path())
|
||||||
else:
|
else:
|
||||||
logging.error('Cannot start activity.')
|
logging.error('Cannot start activity.')
|
||||||
|
|
||||||
def start_activity(self, activity_name):
|
def start_activity(self, activity_type):
|
||||||
activity = ActivityFactory.create(activity_name)
|
activity = ActivityFactory.create(activity_type)
|
||||||
registry = conf.get_activity_registry()
|
activity.execute('test', [])
|
||||||
info = registry.get_activity_from_id(activity_name)
|
return activity
|
||||||
if info:
|
|
||||||
default_type = info.get_default_type()
|
|
||||||
if default_type != None:
|
|
||||||
activity.set_default_type(default_type)
|
|
||||||
activity.execute('test', [])
|
|
||||||
return activity
|
|
||||||
else:
|
|
||||||
logging.error('No such activity in the directory')
|
|
||||||
return None
|
|
||||||
|
|
||||||
def get_chat_controller(self):
|
def get_chat_controller(self):
|
||||||
return self._chat_controller
|
return self._chat_controller
|
||||||
|
@ -11,7 +11,7 @@ class ActivityItem(IconItem):
|
|||||||
def __init__(self, activity, size):
|
def __init__(self, activity, size):
|
||||||
icon_name = activity.get_icon()
|
icon_name = activity.get_icon()
|
||||||
if not icon_name:
|
if not icon_name:
|
||||||
act_type = activity.get_default_type()
|
act_type = activity.get_type()
|
||||||
raise RuntimeError("Activity %s did not have an icon!" % act_type)
|
raise RuntimeError("Activity %s did not have an icon!" % act_type)
|
||||||
IconItem.__init__(self, icon_name=icon_name,
|
IconItem.__init__(self, icon_name=icon_name,
|
||||||
color=IconColor('white'), size=size)
|
color=IconColor('white'), size=size)
|
||||||
|
@ -21,7 +21,7 @@ class ActivityItem(IconItem):
|
|||||||
|
|
||||||
def get_icon_name(self):
|
def get_icon_name(self):
|
||||||
registry = conf.get_activity_registry()
|
registry = conf.get_activity_registry()
|
||||||
info = registry.get_activity(self._service.get_type())
|
info = registry.get_activity_from_type(self._service.get_type())
|
||||||
|
|
||||||
return info.get_icon()
|
return info.get_icon()
|
||||||
|
|
||||||
@ -62,7 +62,7 @@ class MeshGroup(goocanvas.Group):
|
|||||||
|
|
||||||
def __check_service(self, service):
|
def __check_service(self, service):
|
||||||
registry = conf.get_activity_registry()
|
registry = conf.get_activity_registry()
|
||||||
if registry.get_activity(service.get_type()) != None:
|
if registry.get_activity_from_type(service.get_type()) != None:
|
||||||
if not self.has_activity(service.get_activity_id()):
|
if not self.has_activity(service.get_activity_id()):
|
||||||
self.add_activity(service)
|
self.add_activity(service)
|
||||||
|
|
||||||
|
@ -7,6 +7,7 @@ import gtk
|
|||||||
import gobject
|
import gobject
|
||||||
|
|
||||||
from sugar.presence.PresenceService import PresenceService
|
from sugar.presence.PresenceService import PresenceService
|
||||||
|
from sugar.conf import ActivityRegistry
|
||||||
import sugar.util
|
import sugar.util
|
||||||
|
|
||||||
ACTIVITY_SERVICE_NAME = "org.laptop.Activity"
|
ACTIVITY_SERVICE_NAME = "org.laptop.Activity"
|
||||||
@ -47,14 +48,14 @@ class ActivityDbusService(dbus.service.Object):
|
|||||||
return self._activity.get_id()
|
return self._activity.get_id()
|
||||||
|
|
||||||
@dbus.service.method(ACTIVITY_INTERFACE)
|
@dbus.service.method(ACTIVITY_INTERFACE)
|
||||||
def get_default_type(self):
|
def get_type(self):
|
||||||
"""Get the activity default type"""
|
"""Get the activity type"""
|
||||||
return self._activity.get_default_type()
|
return self._activity.get_type()
|
||||||
|
|
||||||
@dbus.service.method(ACTIVITY_INTERFACE)
|
@dbus.service.method(ACTIVITY_INTERFACE)
|
||||||
def set_default_type(self, default_type):
|
def set_type(self, activity_type):
|
||||||
"""Set the activity default type"""
|
"""Set the activity type"""
|
||||||
self._activity.set_default_type(default_type)
|
self._activity.set_type(activity_type)
|
||||||
|
|
||||||
@dbus.service.method(ACTIVITY_INTERFACE)
|
@dbus.service.method(ACTIVITY_INTERFACE)
|
||||||
def get_shared(self):
|
def get_shared(self):
|
||||||
@ -92,16 +93,14 @@ class Activity(gtk.Window):
|
|||||||
self._bus = ActivityDbusService(bus_name, get_object_path(xid))
|
self._bus = ActivityDbusService(bus_name, get_object_path(xid))
|
||||||
self._bus.start(self._pservice, self)
|
self._bus.start(self._pservice, self)
|
||||||
|
|
||||||
def set_default_type(self, default_type):
|
def set_type(self, activity_type):
|
||||||
"""Set the activity default type.
|
"""Sets the activity type."""
|
||||||
|
self._activity_type = activity_type
|
||||||
|
self._default_type = ActivityRegistry.get_default_type(activity_type)
|
||||||
|
|
||||||
It's the type of the main network service which tracks presence
|
def get_type(self):
|
||||||
and provides info about the activity, for example the title."""
|
"""Gets the activity type."""
|
||||||
self._default_type = default_type
|
return self._activity_type
|
||||||
|
|
||||||
def get_default_type(self):
|
|
||||||
"""Get the activity default type."""
|
|
||||||
return self._default_type
|
|
||||||
|
|
||||||
def get_shared(self):
|
def get_shared(self):
|
||||||
"""Returns TRUE if the activity is shared on the mesh."""
|
"""Returns TRUE if the activity is shared on the mesh."""
|
||||||
|
@ -19,7 +19,9 @@ def _get_factory(activity_name):
|
|||||||
class ActivityFactory(dbus.service.Object):
|
class ActivityFactory(dbus.service.Object):
|
||||||
"""Dbus service that takes care of creating new instances of an activity"""
|
"""Dbus service that takes care of creating new instances of an activity"""
|
||||||
|
|
||||||
def __init__(self, name, activity_class):
|
def __init__(self, activity_type, activity_class):
|
||||||
|
self._activity_type = activity_type
|
||||||
|
|
||||||
splitted_module = activity_class.rsplit('.', 1)
|
splitted_module = activity_class.rsplit('.', 1)
|
||||||
module_name = splitted_module[0]
|
module_name = splitted_module[0]
|
||||||
class_name = splitted_module[1]
|
class_name = splitted_module[1]
|
||||||
@ -31,13 +33,14 @@ class ActivityFactory(dbus.service.Object):
|
|||||||
self._class = getattr(module, class_name)
|
self._class = getattr(module, class_name)
|
||||||
|
|
||||||
bus = dbus.SessionBus()
|
bus = dbus.SessionBus()
|
||||||
factory = _get_factory(name)
|
factory = _get_factory(activity_type)
|
||||||
bus_name = dbus.service.BusName(factory, bus = bus)
|
bus_name = dbus.service.BusName(factory, bus = bus)
|
||||||
dbus.service.Object.__init__(self, bus_name, get_path(factory))
|
dbus.service.Object.__init__(self, bus_name, get_path(factory))
|
||||||
|
|
||||||
@dbus.service.method("com.redhat.Sugar.ActivityFactory")
|
@dbus.service.method("com.redhat.Sugar.ActivityFactory")
|
||||||
def create(self):
|
def create(self):
|
||||||
activity = self._class()
|
activity = self._class()
|
||||||
|
activity.set_type(self._activity_type)
|
||||||
return activity.window.xid
|
return activity.window.xid
|
||||||
|
|
||||||
def create(activity_name):
|
def create(activity_name):
|
||||||
|
@ -5,6 +5,15 @@ from ConfigParser import NoOptionError
|
|||||||
|
|
||||||
from sugar import env
|
from sugar import env
|
||||||
|
|
||||||
|
def get_default_type(activity_type):
|
||||||
|
"""Get the activity default type.
|
||||||
|
|
||||||
|
It's the type of the main network service which tracks presence
|
||||||
|
and provides info about the activity, for example the title."""
|
||||||
|
splitted_id = activity_type.split('.')
|
||||||
|
splitted_id.reverse()
|
||||||
|
return '_' + '_'.join(splitted_id) + '._udp'
|
||||||
|
|
||||||
class ActivityModule:
|
class ActivityModule:
|
||||||
"""Info about an activity module. Wraps a .activity file."""
|
"""Info about an activity module. Wraps a .activity file."""
|
||||||
|
|
||||||
@ -37,7 +46,7 @@ class ActivityModule:
|
|||||||
|
|
||||||
def get_default_type(self):
|
def get_default_type(self):
|
||||||
"""Get the the type of the default activity service."""
|
"""Get the the type of the default activity service."""
|
||||||
return self._default_type
|
return get_default_type(self._id)
|
||||||
|
|
||||||
def set_default_type(self, default_type):
|
def set_default_type(self, default_type):
|
||||||
"""Set the the type of the default activity service."""
|
"""Set the the type of the default activity service."""
|
||||||
@ -51,21 +60,21 @@ class ActivityModule:
|
|||||||
"""Set whether there should be a visible launcher for the activity"""
|
"""Set whether there should be a visible launcher for the activity"""
|
||||||
self._show_launcher = show_launcher
|
self._show_launcher = show_launcher
|
||||||
|
|
||||||
class ActivityRegistry:
|
class _ActivityRegistry:
|
||||||
"""Service that tracks the available activities"""
|
"""Service that tracks the available activities"""
|
||||||
|
|
||||||
def __init__(self):
|
def __init__(self):
|
||||||
self._activities = []
|
self._activities = []
|
||||||
self.scan_directory(env.get_activities_dir())
|
self.scan_directory(env.get_activities_dir())
|
||||||
|
|
||||||
def get_activity_from_id(self, activity_id):
|
def get_activity(self, activity_id):
|
||||||
"""Returns an activity given his identifier"""
|
"""Returns an activity given his identifier"""
|
||||||
for activity in self._activities:
|
for activity in self._activities:
|
||||||
if activity.get_id() == activity_id:
|
if activity.get_id() == activity_id:
|
||||||
return activity
|
return activity
|
||||||
return None
|
return None
|
||||||
|
|
||||||
def get_activity(self, default_type):
|
def get_activity_from_type(self, default_type):
|
||||||
"""Returns an activity given his default type"""
|
"""Returns an activity given his default type"""
|
||||||
for activity in self._activities:
|
for activity in self._activities:
|
||||||
if activity.get_default_type() == default_type:
|
if activity.get_default_type() == default_type:
|
||||||
@ -98,11 +107,6 @@ class ActivityRegistry:
|
|||||||
logging.error('%s miss the required name option' % (path))
|
logging.error('%s miss the required name option' % (path))
|
||||||
return False
|
return False
|
||||||
|
|
||||||
if cp.has_option('Activity', 'default_type'):
|
|
||||||
default_type = cp.get('Activity', 'default_type')
|
|
||||||
else:
|
|
||||||
default_type = None
|
|
||||||
|
|
||||||
module = ActivityModule(name, activity_id, directory)
|
module = ActivityModule(name, activity_id, directory)
|
||||||
self._activities.append(module)
|
self._activities.append(module)
|
||||||
|
|
||||||
@ -112,8 +116,6 @@ class ActivityRegistry:
|
|||||||
if cp.has_option('Activity', 'icon'):
|
if cp.has_option('Activity', 'icon'):
|
||||||
module.set_icon(cp.get('Activity', 'icon'))
|
module.set_icon(cp.get('Activity', 'icon'))
|
||||||
|
|
||||||
module.set_default_type(default_type)
|
|
||||||
|
|
||||||
return True
|
return True
|
||||||
|
|
||||||
def list_activities(self):
|
def list_activities(self):
|
||||||
|
@ -1,7 +1,7 @@
|
|||||||
from sugar.conf.ActivityRegistry import ActivityRegistry
|
from sugar.conf.ActivityRegistry import _ActivityRegistry
|
||||||
from sugar.conf.Profile import Profile
|
from sugar.conf.Profile import Profile
|
||||||
|
|
||||||
__registry = ActivityRegistry()
|
__registry = _ActivityRegistry()
|
||||||
__profile = Profile()
|
__profile = Profile()
|
||||||
|
|
||||||
def get_activity_registry():
|
def get_activity_registry():
|
||||||
|
Loading…
Reference in New Issue
Block a user