1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
|
#!/usr/bin/python
# -*- coding: iso-8859-1 -*-
#
# Copyright 2008, 2009 Pablo Moleri
# This file is part of Quinteti.
#
# Quinteti 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 3 of the License, or
# (at your option) any later version.
#
# Quinteti 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 Quinteti. If not, see <http://www.gnu.org/licenses/>.
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)
|
