1 files changed, 156 insertions, 0 deletions
diff --git a/activities/browser/BrowserActivity.py b/activities/browser/BrowserActivity.py
new file mode 100644
index 0000000..662313f
--- /dev/null
+++ b/activities/browser/BrowserActivity.py
@@ -0,0 +1,156 @@
+import logging
+import xml.sax.saxutils
+
+import pygtk
+pygtk.require('2.0')
+import gtk
+import geckoembed
+
+from sugar.activity import activity
+from sugar.presence.PresenceService import PresenceService
+from sugar.p2p.model.LocalModel import LocalModel
+from sugar.p2p.model.RemoteModel import RemoteModel
+
+from NotificationBar import NotificationBar
+from NavigationToolbar import NavigationToolbar
+
+_BROWSER_ACTIVITY_TYPE = "_web_olpc._udp"
+_SERVICE_URI_TAG = "URI"
+_SERVICE_TITLE_TAG = "Title"
+
+class BrowserActivity(activity.Activity):
+	SOLO = 1
+	FOLLOWING = 2
+	LEADING = 3
+
+	def __init__(self, uri, mode = SOLO):
+		activity.Activity.__init__(self, _BROWSER_ACTIVITY_TYPE)
+		self.uri = uri
+		self._mode = mode
+		
+		self._share_service = None
+		self._model_service = None
+		self._notif_service = None
+		self._model = None
+	
+	def _service_appeared_cb(self, pservice, buddy, service):
+		# Make sure the service is for our activity
+		if service.get_activity_uid() != self._activity_id:
+			return
+
+		if service.get_type() == _BROWSER_ACTIVITY_TYPE:
+			self._notif_service = service
+		elif service.get_type() == LocalModel.SERVICE_TYPE:
+			if self._mode != BrowserActivity.LEADING:
+				self._model_service = service
+		
+		if self._notif_service and self._model_service:
+			self._model = RemoteModel(self._model_service, self._notif_service)
+			self._model.add_listener(self.__shared_location_changed_cb)
+	
+	def get_default_type(self):
+		return _BROWSER_ACTIVITY_TYPE
+	
+	def _update_shared_location(self):
+		address = self.embed.get_address()
+		self._model.set_value('address', address)
+		title = self.embed.get_title()
+		self._model.set_value('title', title)
+		
+	def __notif_bar_action_cb(self, bar, action_id):
+		print action_id
+		if action_id == 'set_shared_location':
+			self._update_shared_location()
+		elif action_id == 'goto_shared_location':
+			address = self._model.get_value("address")
+			print address
+			self.embed.load_address(address)
+			self._notif_bar.hide()
+
+	def set_mode(self, mode):
+		self._mode = mode
+		if mode == BrowserActivity.LEADING:
+			self._notif_bar.set_text('Share this page with the group.')
+			self._notif_bar.set_action('set_shared_location', 'Share')
+			self._notif_bar.set_icon('stock_shared-by-me')
+			self._notif_bar.show()
+
+	def on_connected_to_shell(self):
+		self.set_ellipsize_tab(True)
+		self.set_can_close(True)
+		self.set_tab_text("Web Page")
+		self.set_tab_icon(name="web-browser")
+		self.set_show_tab_icon(True)
+
+		vbox = gtk.VBox()
+
+		self._notif_bar = NotificationBar()
+		vbox.pack_start(self._notif_bar, False)
+		self._notif_bar.connect('action', self.__notif_bar_action_cb)
+
+		self.embed = geckoembed.Embed()
+		self.embed.connect("title", self.__title_cb)
+		vbox.pack_start(self.embed)
+		
+		self.embed.show()
+		self.embed.load_address(self.uri)
+		
+		nav_toolbar = NavigationToolbar(self)
+		vbox.pack_start(nav_toolbar, False)
+		nav_toolbar.show()
+
+		plug = self.gtk_plug()		
+		plug.add(vbox)
+		plug.show()
+
+		vbox.show()
+
+		logging.debug('Start presence service')
+		self._pservice = PresenceService.get_instance()
+		self._pservice.start()
+		
+		logging.debug('Track browser activities')
+		self._pservice.connect('service-appeared', self._service_appeared_cb)
+		self._pservice.track_service_type(_BROWSER_ACTIVITY_TYPE)
+		self._pservice.track_service_type(LocalModel.SERVICE_TYPE)
+
+		# Join the shared activity if we were started from one
+		if self._initial_service:
+			logging.debug("BrowserActivity joining shared activity %s" % self._initial_service.get_activity_uid())
+			self._pservice.join_shared_activity(self._initial_service)
+
+	def get_embed(self):
+		return self.embed
+	
+	def publish(self):
+		escaped_title = xml.sax.saxutils.escape(self.embed.get_title())
+		escaped_url = xml.sax.saxutils.escape(self.embed.get_address())
+
+		# Publish ourselves on the network
+		properties = {_SERVICE_URI_TAG: escaped_url, _SERVICE_TITLE_TAG: escaped_title}
+		self._share_service = self._pservice.share_activity(self,
+				stype=_BROWSER_ACTIVITY_TYPE, properties=properties)
+
+		# Create our activity-specific browser sharing service
+		self._model = LocalModel(self, self._pservice, self._share_service)
+		self._model.set_value('owner', self._pservice.get_owner().get_nick_name())
+		self._update_shared_location()
+		
+		self.set_mode(BrowserActivity.LEADING)
+
+	def __title_cb(self, embed):
+		self.set_tab_text(embed.get_title())
+
+	def __shared_location_changed_cb(self, model, key):
+		self.set_has_changes(True)
+		self._notify_shared_location_change()
+
+	def _notify_shared_location_change(self):
+		owner = self._model.get_value('owner')
+		title = self._model.get_value('title')
+		
+		text = '<b>' + owner + '</b> is reading <i>' + title + '</i>'
+		self._notif_bar.set_text(text)
+		self._notif_bar.set_action('goto_shared_location', 'Go There')
+		self._notif_bar.set_icon('stock_right')
+		self._notif_bar.show()