diff options
Diffstat (limited to 'src/view/Shell.py')
| -rw-r--r-- | src/view/Shell.py | 298 |
1 files changed, 298 insertions, 0 deletions
diff --git a/src/view/Shell.py b/src/view/Shell.py new file mode 100644 index 0000000..72aa3b1 --- /dev/null +++ b/src/view/Shell.py @@ -0,0 +1,298 @@ +# Copyright (C) 2006-2007 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, write to the Free Software +# Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA + +from gettext import gettext as _ +from sets import Set +import logging +import tempfile +import os +import time +import shutil + +import gobject +import gtk +import wnck +import dbus + +from sugar.activity.activityhandle import ActivityHandle +from sugar import activity +from sugar.activity import activityfactory +from sugar.datastore import datastore +from sugar import profile +from sugar import env + +from view.ActivityHost import ActivityHost +from view.frame.frame import Frame +from view.keyhandler import KeyHandler +from view.home.HomeWindow import HomeWindow +from model.shellmodel import ShellModel + +# #3903 - this constant can be removed and assumed to be 1 when dbus-python +# 0.82.3 is the only version used +if dbus.version >= (0, 82, 3): + DBUS_PYTHON_TIMEOUT_UNITS_PER_SECOND = 1 +else: + DBUS_PYTHON_TIMEOUT_UNITS_PER_SECOND = 1000 + +class Shell(gobject.GObject): + def __init__(self, model): + gobject.GObject.__init__(self) + + self._activities_starting = Set() + self._model = model + self._hosts = {} + self._screen = wnck.screen_get_default() + self._current_host = None + self._pending_host = None + self._screen_rotation = 0 + self._zoom_level = ShellModel.ZOOM_HOME + + self._key_handler = KeyHandler(self) + + self._frame = Frame(self) + + self._home_window = HomeWindow(self) + self._home_window.show() + + home_model = self._model.get_home() + home_model.connect('activity-started', self._activity_started_cb) + home_model.connect('activity-removed', self._activity_removed_cb) + home_model.connect('active-activity-changed', + self._active_activity_changed_cb) + home_model.connect('pending-activity-changed', + self._pending_activity_changed_cb) + + self._model.connect('notify::zoom-level', self._zoom_level_changed_cb) + + gobject.idle_add(self._start_journal_idle) + + def _start_journal_idle(self): + # Mount the datastore in internal flash + ds_path = env.get_profile_path('datastore') + try: + datastore.mount(ds_path, [], timeout=120 * \ + DBUS_PYTHON_TIMEOUT_UNITS_PER_SECOND) + except: + # Don't explode if there's corruption; move the data out of the way + # and attempt to create a store from scratch. + shutil.move(ds_path, os.path.abspath(ds_path) + str(time.time())) + datastore.mount(ds_path, [], timeout=120 * \ + DBUS_PYTHON_TIMEOUT_UNITS_PER_SECOND) + + # Checking for the bundle existence will also ensure + # that the shell service is started up. + registry = activity.get_registry() + if registry.get_activity('org.laptop.JournalActivity'): + self.start_activity('org.laptop.JournalActivity') + + def _activity_started_cb(self, home_model, home_activity): + activity_host = ActivityHost(home_activity) + self._hosts[activity_host.get_xid()] = activity_host + if home_activity.get_type() in self._activities_starting: + self._activities_starting.remove(home_activity.get_type()) + + def _activity_removed_cb(self, home_model, home_activity): + if home_activity.get_type() in self._activities_starting: + self._activities_starting.remove(home_activity.get_type()) + xid = home_activity.get_xid() + if self._hosts.has_key(xid): + self._hosts[xid].destroy() + del self._hosts[xid] + + def _active_activity_changed_cb(self, home_model, home_activity): + if home_activity: + host = self._hosts[home_activity.get_xid()] + else: + host = None + + if self._current_host: + self._current_host.set_active(False) + + self._current_host = host + + def _pending_activity_changed_cb(self, home_model, home_activity): + if home_activity: + self._pending_host = self._hosts[home_activity.get_xid()] + else: + self._pending_host = None + + def get_model(self): + return self._model + + def get_frame(self): + return self._frame + + def join_activity(self, bundle_id, activity_id): + activity_host = self.get_activity(activity_id) + if activity_host: + activity_host.present() + return + + # Get the service name for this activity, if + # we have a bundle on the system capable of handling + # this activity type + registry = activity.get_registry() + bundle = registry.get_activity(bundle_id) + if not bundle: + logging.error("Couldn't find activity for type %s" % bundle_id) + return + + handle = ActivityHandle(activity_id) + activityfactory.create(bundle_id, handle) + + def notify_launch(self, bundle_id, activity_id): + # Zoom to Home for launch feedback + self.set_zoom_level(ShellModel.ZOOM_HOME) + + home_model = self._model.get_home() + home_model.notify_activity_launch(activity_id, bundle_id) + + def notify_launch_failure(self, activity_id): + home_model = self._model.get_home() + home_model.notify_activity_launch_failed(activity_id) + + def start_activity(self, activity_type): + if activity_type in self._activities_starting: + logging.debug("This activity is still launching.") + return + + self._activities_starting.add(activity_type) + activityfactory.create(activity_type) + + def take_activity_screenshot(self): + if self._model.get_zoom_level() != ShellModel.ZOOM_ACTIVITY: + return + if self.get_frame().visible: + return + + home_model = self._model.get_home() + activity = home_model.get_active_activity() + if activity is not None: + service = activity.get_service() + if service is not None: + try: + service.TakeScreenshot(timeout=2.0) + except dbus.DBusException, e: + logging.debug('Error raised by TakeScreenshot(): %s', e) + + def set_zoom_level(self, level): + if level == self._zoom_level: + return + + self.take_activity_screenshot() + + if level == ShellModel.ZOOM_ACTIVITY: + if self._pending_host is not None: + self._pending_host.present() + self._screen.toggle_showing_desktop(False) + else: + self._model.set_zoom_level(level) + self._screen.toggle_showing_desktop(True) + self._home_window.set_zoom_level(level) + + def _zoom_level_changed_cb(self, model, pspec): + new_level = model.props.zoom_level + + if new_level == ShellModel.ZOOM_HOME: + self._frame.show(Frame.MODE_NON_INTERACTIVE) + + if self._zoom_level == ShellModel.ZOOM_HOME: + self._frame.hide() + + self._zoom_level = new_level + + def toggle_activity_fullscreen(self): + if self._model.get_zoom_level() == ShellModel.ZOOM_ACTIVITY: + self.get_current_activity().toggle_fullscreen() + + def activate_previous_activity(self): + home_model = self._model.get_home() + activity = home_model.get_previous_activity() + if activity: + self.take_activity_screenshot() + activity.get_window().activate(1) + + def activate_next_activity(self): + home_model = self._model.get_home() + activity = home_model.get_next_activity() + if activity: + self.take_activity_screenshot() + activity.get_window().activate(1) + + def close_current_activity(self): + if self._model.get_zoom_level() != ShellModel.ZOOM_ACTIVITY: + return + + home_model = self._model.get_home() + activity = home_model.get_active_activity() + if activity.get_type() == 'org.laptop.JournalActivity': + return + + self.take_activity_screenshot() + self.get_current_activity().close() + + def get_current_activity(self): + return self._current_host + + def get_activity(self, activity_id): + for host in self._hosts.values(): + if host.get_id() == activity_id: + return host + return None + + def toggle_chat_visibility(self): + act = self.get_current_activity() + if not act: + return + is_visible = self._frame.is_visible() + if act.is_chat_visible(): + frame_was_visible = act.chat_hide() + if not frame_was_visible: + self._frame.do_slide_out() + else: + if not is_visible: + self._frame.do_slide_in() + act.chat_show(is_visible) + + def take_screenshot(self): + file_path = os.path.join(tempfile.gettempdir(), '%i' % time.time()) + + window = gtk.gdk.get_default_root_window() + width, height = window.get_size() + x_orig, y_orig = window.get_origin() + + screenshot = gtk.gdk.Pixbuf(gtk.gdk.COLORSPACE_RGB, has_alpha=False, + bits_per_sample=8, width=width, height=height) + screenshot.get_from_drawable(window, window.get_colormap(), x_orig, y_orig, 0, 0, + width, height) + screenshot.save(file_path, "png") + try: + jobject = datastore.create() + try: + jobject.metadata['title'] = _('Screenshot') + jobject.metadata['keep'] = '0' + jobject.metadata['buddies'] = '' + jobject.metadata['preview'] = '' + jobject.metadata['icon-color'] = profile.get_color().to_string() + jobject.metadata['mime_type'] = 'image/png' + jobject.file_path = file_path + datastore.write(jobject) + finally: + jobject.destroy() + del jobject + finally: + os.remove(file_path) + |