blob: 109c7bb8873ea0b9613916bd70e567edc6dab20f (
plain)
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
|
from sugar.p2p.Stream import Stream
from sugar.presence import PresenceService
class _Marshaller(object):
def marshal(self, title, address):
return title + '\n' + address
def demarshal(self, message):
return message.split('\n')
class LinksController(object):
def __init__(self, service, model):
self._model = model
self._pservice = PresenceService.get_instance()
self._marshaller = _Marshaller()
self._stream = Stream.new_from_service(service)
self._stream.set_data_listener(self._recv_message)
self._stream_writer = self._stream.new_writer()
def post_link(self, title, address):
message = self._marshaller.marshal(title, address)
self._stream_writer.write(message)
def _recv_message(self, address, msg):
buddy = self._pservice.get_buddy_by_address(address)
if buddy:
link = self._marshaller.demarshal(msg)
self._model.add_link(buddy, *link)
|
