Web   ·   Wiki   ·   Activities   ·   Blog   ·   Lists   ·   Chat   ·   Meeting   ·   Bugs   ·   Git   ·   Translate   ·   Archive   ·   People   ·   Donate
summaryrefslogtreecommitdiffstats
path: root/tests/simulator/kiu.py
blob: fb114195ffbc5134b30dc71e7b36db8a7a876092 (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
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
#!/usr/bin/python
import os

import gtk
import gobject

from sugar.session.TestSession import TestSession
from sugar.presence import PresenceService
from sugar.canvas.IconColor import IconColor
from sugar.p2p import Stream
from sugar import util

PRESENCE_SERVICE_TYPE = "_presence_olpc._tcp"

class SimulatedActivity:
	def __init__(self):
		self._id = util.unique_id()

	def get_id(self):
		return self._id

class ShellOwner(object):
	def __init__(self):
		self._pservice = PresenceService.get_instance()
		self._color = IconColor()
		self._nick = 'kiu'

	def announce(self):
		props = { 'color':  self._color.to_string() }
		self._service = self._pservice.register_service(self._nick,
				PRESENCE_SERVICE_TYPE, properties=props)
		self._stream = Stream.Stream.new_from_service(self._service)
		self._stream.register_reader_handler(self._handle_buddy_icon_request, "get_buddy_icon")
		self._stream.register_reader_handler(self._handle_invite, "invite")

	def _handle_buddy_icon_request(self):
		return ''

	def _handle_invite(self, issuer, bundle_id, activity_id):
		return ''

def start():
	pservice = PresenceService.get_instance()

	if not pservice.get_owner().get_color():
		print 'Color not found'
		return True

	activity = SimulatedActivity()
	properties = { 'title' : 'OLPC' }
	activity_type = '_GroupChatActivity_Sugar_redhat_com._udp'
	service = pservice.share_activity(activity, activity_type, properties)

	return False

os.environ['SUGAR_NICK_NAME'] = 'kiu'

session = TestSession()
session.start()

PresenceService.start()

owner = ShellOwner()
owner.announce()

gobject.timeout_add(1000, start)

gtk.main()