diff options
Diffstat (limited to 'shared.py')
| -rw-r--r-- | shared.py | 210 |
1 files changed, 0 insertions, 210 deletions
diff --git a/shared.py b/shared.py deleted file mode 100644 index c0d59f5..0000000 --- a/shared.py +++ /dev/null @@ -1,210 +0,0 @@ -# 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 - -import gtk -import logging -import telepathy -from gobject import property, SIGNAL_RUN_FIRST, TYPE_PYOBJECT - -from sugar.activity.activity import Activity -from sugar.presence.sugartubeconn import SugarTubeConnection -from sugar.graphics.alert import ConfirmationAlert, NotifyAlert - -NEW_INSTANCE = 0 -RESUME_INSTANCE = 1 -PRE_INSTANCE = 2 -POST_INSTANCE = 3 - -class CanvasActivity(Activity): - # will be invoked after __init__() - # instead of resume_instance() - def new_instance(self): - # stub - pass - - # will be invoked after __init__() - # instead of new_instance() - def resume_instance(self, filepath): - # stub - pass - - def save_instance(self, filepath): - # stub - raise NotImplementedError - - # will be invoked after __init__() and {new,resume}_instance() - def share_instance(self, connection, is_initiator): - # stub - pass - - def __init__(self, canvas, handle): - Activity.__init__(self, handle) - - if handle.object_id: - self.__state = RESUME_INSTANCE - else: - self.__state = NEW_INSTANCE - - self.__resume_filename = None - self.__postponed_share = [] - - # XXX do it after(possible) read_file() invoking - # have to rely on calling read_file() from map_cb in sugar-toolkit - canvas.connect_after('map', self._map_canvasactivity_cb) - self.set_canvas(canvas) - - def __instance(self): - logging.error('CanvasActivity.__instance') - - if self.__resume_filename: - self.resume_instance(self.__resume_filename) - else: - self.new_instance() - - for i in self.__postponed_share: - self.share_instance(*i) - self.__postponed_share = [] - - self.__state = POST_INSTANCE - - def read_file(self, filepath): - logging.error('CanvasActivity.read_file state=%s' % self.__state) - - self.__resume_filename = filepath - - if self.__state == RESUME_INSTANCE: - self.__state = PRE_INSTANCE - elif self.__state == PRE_INSTANCE: - self.__instance(); - - def _map_canvasactivity_cb(self, widget): - logging.error('CanvasActivity._map_canvasactivity_cb state=%s' % \ - self.__state) - - if self.__state == NEW_INSTANCE: - self.__instance() - elif self.__state == RESUME_INSTANCE: - self.__state = PRE_INSTANCE - elif self.__state == PRE_INSTANCE: - self.__instance(); - - return False - - def _share(self, tube_conn, initiator): - logging.error('CanvasActivity._share state=%s' % self.__state) - - if self.__state == RESUME_INSTANCE: - self.__postponed_share.append((tube_conn, initiator)) - self.__state = PRE_INSTANCE - elif self.__state == PRE_INSTANCE: - self.__postponed_share.append((tube_conn, initiator)) - self.__instance(); - elif self.__state == POST_INSTANCE: - self.share_instance(tube_conn, initiator) - - def write_file(self, filepath): - self.save_instance(filepath) - - def notify_alert(self, title, msg): - alert = NotifyAlert(title=title, msg=msg) - - def response(alert, response_id, self): - self.remove_alert(alert) - - alert.connect('response', response, self) - alert.show_all() - self.add_alert(alert) - - def confirmation_alert(self, title, msg, cb, *cb_args): - alert = ConfirmationAlert(title=title, msg=msg) - - def response(alert, response_id, self, cb, *cb_args): - self.remove_alert(alert) - if response_id is gtk.RESPONSE_OK: - cb(*cb_args) - - alert.connect('response', response, self, cb, *cb_args) - alert.show_all() - self.add_alert(alert) - -class SharedActivity(CanvasActivity): - def __init__(self, canvas, service, *args): - CanvasActivity.__init__(self, canvas, *args) - self.service = service - - self.connect('shared', self._shared_cb) - - # Owner.props.key - if self._shared_activity: - # We are joining the activity - self.connect('joined', self._joined_cb) - if self.get_shared(): - # We've already joined - self._joined_cb() - - def _shared_cb(self, activity): - logging.debug('My activity was shared') - self.__initiator = True - self._sharing_setup() - - logging.debug('This is my activity: making a tube...') - id = self._tubes_chan[telepathy.CHANNEL_TYPE_TUBES].OfferDBusTube( - self.service, {}) - - def _joined_cb(self, activity): - if not self._shared_activity: - return - - logging.debug('Joined an existing shared activity') - - self.__initiator = False - self._sharing_setup() - - logging.debug('This is not my activity: waiting for a tube...') - self._tubes_chan[telepathy.CHANNEL_TYPE_TUBES].ListTubes( - reply_handler=self._list_tubes_reply_cb, - error_handler=self._list_tubes_error_cb) - - def _sharing_setup(self): - if self._shared_activity is None: - logging.error('Failed to share or join activity') - return - self._conn = self._shared_activity.telepathy_conn - self._tubes_chan = self._shared_activity.telepathy_tubes_chan - self._text_chan = self._shared_activity.telepathy_text_chan - - self._tubes_chan[telepathy.CHANNEL_TYPE_TUBES].connect_to_signal('NewTube', self._new_tube_cb) - - def _list_tubes_reply_cb(self, tubes): - for tube_info in tubes: - self._new_tube_cb(*tube_info) - - def _list_tubes_error_cb(self, e): - logging.error('ListTubes() failed: %s', e) - - def _new_tube_cb(self, id, initiator, type, service, params, state): - logging.debug('New tube: ID=%d initator=%d type=%d service=%s ' - 'params=%r state=%d', id, initiator, type, service, - params, state) - - if (type == telepathy.TUBE_TYPE_DBUS and - service == self.service): - if state == telepathy.TUBE_STATE_LOCAL_PENDING: - self._tubes_chan[telepathy.CHANNEL_TYPE_TUBES].AcceptDBusTube(id) - - tube_conn = SugarTubeConnection(self._conn, - self._tubes_chan[telepathy.CHANNEL_TYPE_TUBES], - id, group_iface=self._text_chan[telepathy.CHANNEL_INTERFACE_GROUP]) - - self._share(tube_conn, self.__initiator) |