diff options
Diffstat (limited to 'Quinteti.activity/logic/mesh.py')
| -rw-r--r-- | Quinteti.activity/logic/mesh.py | 124 |
1 files changed, 124 insertions, 0 deletions
diff --git a/Quinteti.activity/logic/mesh.py b/Quinteti.activity/logic/mesh.py new file mode 100644 index 0000000..4744e75 --- /dev/null +++ b/Quinteti.activity/logic/mesh.py @@ -0,0 +1,124 @@ +from sugar.presence import presenceservice +from sugar.presence.tubeconn import TubeConnection + +import olpcgames +import logging +import telepathy + +SERVICE = "uy.edu.ceibaljam.Quinteti" +IFACE = SERVICE +PATH = "/uy/edu/ceibaljam/Quinteti" + +log = None + +hellotube = None # Shared session + +initiating = False + +conn = None +tubes_chan = None +text_chan = None + +def init_mesh(main_log): + global log + log = main_log + + # get the Presence Service + pservice = presenceservice.get_instance() + # Buddy object for you + owner = pservice.get_owner() + + olpcgames.ACTIVITY.connect("shared", _shared_cb) + olpcgames.ACTIVITY.connect("joined", _joined_cb) + + +def _shared_cb(activity): + log.debug('My activity was shared') + #self._alert('Shared', 'The activity is shared') + + global initiating + initiating = True + _sharing_setup() + + log.debug('This is my activity: making a tube...') + id = tubes_chan[telepathy.CHANNEL_TYPE_TUBES].OfferDBusTube( + SERVICE, {}) + +def _sharing_setup(): + if olpcgames.ACTIVITY._shared_activity is None: + log.error('Failed to share or join activity') + return + + s_activity = olpcgames.ACTIVITY._shared_activity + global conn, tubes_chan, text_chan # Necesario para que escriba sobre las variables globales, en vez de crear locales + + conn = s_activity.telepathy_conn + tubes_chan = s_activity.telepathy_tubes_chan + text_chan = s_activity.telepathy_text_chan + + tubes_chan[telepathy.CHANNEL_TYPE_TUBES].connect_to_signal('NewTube', _new_tube_cb) + + s_activity.connect('buddy-joined', _buddy_joined_cb) + s_activity.connect('buddy-left', _buddy_left_cb) + + # Optional - included for example: + # Find out who's already in the shared activity: + for buddy in s_activity.get_joined_buddies(): + log.debug('Buddy %s is already in the activity', buddy.props.nick) + +def _joined_cb(activity): + if not olpcgames.ACTIVITY._shared_activity: + return + + s_activity = olpcgames.ACTIVITY._shared_activity + log.debug('Joined an existing shared activity') + + global initiating + initiating = False + _sharing_setup() + + log.debug('This is not my activity: waiting for a tube...') + tubes_chan[telepathy.CHANNEL_TYPE_TUBES].ListTubes( + reply_handler=list_tubes_reply_cb, + error_handler=list_tubes_error_cb) + +def _new_tube_cb(id, initiator, type, service, params, state): + log.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 == SERVICE): + if state == telepathy.TUBE_STATE_LOCAL_PENDING: + tubes_chan[telepathy.CHANNEL_TYPE_TUBES].AcceptDBusTube(id) + tube_conn = TubeConnection(conn, + tubes_chan[telepathy.CHANNEL_TYPE_TUBES], + id, group_iface=text_chan[telepathy.CHANNEL_INTERFACE_GROUP]) +# hellotube = TextSync(tube_conn, initiating, +# self.entry_text_update_cb, +# self._alert, +# self._get_buddy) + +def _buddy_joined_cb(activity, buddy): + """Called when a buddy joins the shared activity. + + This doesn't do much here as HelloMesh doesn't have much + functionality. It's up to you do do interesting things + with the Buddy... + """ + log.debug('Buddy %s joined', buddy.props.nick) + +def _buddy_left_cb (activity, buddy): + """Called when a buddy leaves the shared activity. + + This doesn't do much here as HelloMesh doesn't have much + functionality. It's up to you do do interesting things + with the Buddy... + """ + log.debug('Buddy %s left', buddy.props.nick) + +def _list_tubes_reply_cb(tubes): + log.debug('list_tubes_reply_cb') + for tube_info in tubes: + _new_tube_cb(*tube_info) + +def _list_tubes_error_cb(e): + log.error('ListTubes() failed: %s', e) |