sugar-toolkit-gtk3/sugar/activity/Activity.py

193 lines
5.5 KiB
Python
Raw Normal View History

import sys
import logging
import dbus
import dbus.service
import dbus.glib
import gtk
import gobject
2006-07-26 12:57:54 +02:00
from sugar.presence.PresenceService import PresenceService
2006-07-26 01:14:31 +02:00
# Work around for dbus mutex locking issue
gtk.gdk.threads_init()
dbus.glib.threads_init()
2006-07-06 16:06:07 +02:00
from sugar.LogWriter import LogWriter
import sugar.util
2006-07-06 16:06:07 +02:00
ACTIVITY_SERVICE_NAME = "com.redhat.Sugar.Activity"
ACTIVITY_SERVICE_PATH = "/com/redhat/Sugar/Activity"
def get_path(activity_name):
"""Returns the activity path"""
return '/' + activity_name.replace('.', '/')
def get_factory(activity_name):
"""Returns the activity factory"""
return activity_name + '.Factory'
class ActivityFactory(dbus.service.Object):
"""Dbus service that takes care of creating new instances of an activity"""
def __init__(self, name, activity_class, default_type):
self._default_type = default_type
splitted_module = activity_class.rsplit('.', 1)
module_name = splitted_module[0]
class_name = splitted_module[1]
module = __import__(module_name)
for comp in module_name.split('.')[1:]:
module = getattr(module, comp)
self._class = getattr(module, class_name)
bus = dbus.SessionBus()
factory = get_factory(name)
bus_name = dbus.service.BusName(factory, bus = bus)
dbus.service.Object.__init__(self, bus_name, get_path(factory))
2006-08-07 11:08:10 +02:00
@dbus.service.method("com.redhat.Sugar.ActivityFactory",
in_signature="o", out_signature="")
2006-07-26 12:57:54 +02:00
def create_with_service(self, service_path):
pservice = PresenceService()
2006-08-07 11:08:10 +02:00
service = pservice.get(service_path)
2006-08-09 01:08:19 +02:00
activity = self._class()
activity.set_default_type(self._default_type)
activity.join(service)
@dbus.service.method("com.redhat.Sugar.ActivityFactory")
2006-07-08 15:47:51 +02:00
def create(self):
2006-08-09 01:08:19 +02:00
activity = self._class()
activity.set_default_type(self._default_type)
2006-08-09 01:08:19 +02:00
2006-08-07 16:26:54 +02:00
def create(activity_name, service = None):
"""Create a new activity from his name."""
bus = dbus.SessionBus()
factory_name = get_factory(activity_name)
factory_path = get_path(factory_name)
proxy_obj = bus.get_object(factory_name, factory_path)
factory = dbus.Interface(proxy_obj, "com.redhat.Sugar.ActivityFactory")
2006-07-26 12:57:54 +02:00
if service:
print service.object_path()
factory.create_with_service(service.object_path())
else:
2006-07-08 15:47:51 +02:00
factory.create()
def register_factory(name, activity_class, default_type=None):
2006-07-12 22:17:57 +02:00
"""Register the activity factory."""
factory = ActivityFactory(name, activity_class, default_type)
gtk.main()
class ActivityDbusService(dbus.service.Object):
"""Base dbus service object that each Activity uses to export dbus methods.
The dbus service is separate from the actual Activity object so that we can
2006-07-12 22:17:57 +02:00
tightly control what stuff passes through the dbus python bindings."""
def __init__(self, xid, activity):
self._activity = activity
bus = dbus.SessionBus()
service_name = ACTIVITY_SERVICE_NAME + "%s" % xid
object_path = ACTIVITY_SERVICE_PATH + "/%s" % xid
service = dbus.service.BusName(service_name, bus=bus)
dbus.service.Object.__init__(self, service, object_path)
@dbus.service.method(ACTIVITY_SERVICE_NAME)
2006-07-26 00:17:05 +02:00
def share(self):
"""Called by the shell to request the activity to share itself on the network."""
2006-08-08 12:34:04 +02:00
self._activity.share()
@dbus.service.method(ACTIVITY_SERVICE_NAME)
def get_id(self):
"""Get the activity identifier"""
2006-07-19 19:35:32 +02:00
return self._activity.get_id()
@dbus.service.method(ACTIVITY_SERVICE_NAME)
def get_default_type(self):
"""Get the activity default type"""
return self._activity.get_default_type()
@dbus.service.method(ACTIVITY_SERVICE_NAME)
def get_shared(self):
"""Returns True if the activity is shared on the mesh."""
return self._activity.get_shared()
2006-07-08 15:47:51 +02:00
class Activity(gtk.Window):
"""Base Activity class that all other Activities derive from."""
def __init__(self, service = None):
2006-07-08 15:47:51 +02:00
gtk.Window.__init__(self)
2006-08-09 01:08:19 +02:00
self._shared = False
self._activity_id = None
self._default_type = None
self._pservice = PresenceService()
self.present()
group = gtk.Window()
group.realize()
self.window.set_group(group.window)
2006-08-08 12:34:04 +02:00
self._dbus_service = ActivityDbusService(self.window.xid, self)
2006-08-08 12:34:04 +02:00
def __del__(self):
if self._dbus_service:
del self._dbus_service
self._dbus_service = None
def set_default_type(self, default_type):
2006-08-08 12:34:04 +02:00
"""Set 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."""
self._default_type = default_type
def get_default_type(self):
2006-08-08 12:34:04 +02:00
"""Get the activity default type."""
return self._default_type
def get_shared(self):
2006-08-08 12:34:04 +02:00
"""Returns TRUE if the activity is shared on the mesh."""
return self._shared
2006-06-15 17:29:00 +02:00
def get_id(self):
2006-08-08 12:34:04 +02:00
"""Get the unique activity identifier."""
2006-08-09 01:08:19 +02:00
if self._activity_id == None:
self._activity_id = sugar.util.unique_id()
return self._activity_id
2006-08-09 01:08:19 +02:00
def join(self, activity_ps):
"""Join an activity shared on the network."""
2006-08-09 01:08:19 +02:00
self._shared = True
self._activity_id = activity_ps.get_id()
# Publish the default service, it's a copy of
# one of those we found on the network.
services = activity_ps.get_services_of_type(self._default_type)
if len(services) > 0:
service = services[0]
addr = service.get_address()
port = service.get_port()
properties = { 'title' : service.get_published_value('title') }
self._service = self._pservice.share_activity(self,
self._default_type, properties, addr, port)
else:
logging.error('Cannot join the activity')
2006-07-26 00:17:05 +02:00
def share(self):
2006-08-09 01:08:19 +02:00
"""Share the activity on the network."""
properties = { 'title' : self.get_title() }
2006-08-08 12:34:04 +02:00
self._service = self._pservice.share_activity(self,
self._default_type,
properties)
2006-08-08 12:34:04 +02:00
self._shared = True