From ed81d4906b75aac42868b5d94bd22b1f6ae729b7 Mon Sep 17 00:00:00 2001
From: Thomas Leonard <talex5@gmail.com>
Date: Mon, 27 Feb 2006 08:26:10 +0000
Subject: [PATCH] Added 'xxmlrpc' module. This allows sending XML-RPC messages
 to other processes, via the X server.

git-svn-id: https://rox.svn.sourceforge.net/svnroot/rox/trunk/ROX-Lib2@4403 66de3db3-b00d-0410-b41b-f4738ad19bea
---
 python/rox/xxmlrpc.py | 115 ++++++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 115 insertions(+)
 create mode 100644 python/rox/xxmlrpc.py

diff --git a/python/rox/xxmlrpc.py b/python/rox/xxmlrpc.py
new file mode 100644
index 0000000..aac0f1b
--- /dev/null
+++ b/python/rox/xxmlrpc.py
@@ -0,0 +1,115 @@
+"""XML-RPC over X."""
+from logging import warn
+from rox import g
+import xmlrpclib
+
+_message_prop = g.gdk.atom_intern('_XXMLRPC_MESSAGE', False)
+_message_id_prop = g.gdk.atom_intern('_XXMLRPC_ID', False)
+
+class XXMLRPCServer:
+	def __init__(self, service):
+		self.service = service
+		self.objects = {}	# Path -> Object
+
+		# Can be used whether sending or receiving...
+		self.ipc_window = g.Invisible()
+		self.ipc_window.add_events(g.gdk.PROPERTY_NOTIFY)
+
+		self.ipc_window.realize()
+
+		# Append our window to the list for this service
+
+		# Make the IPC window contain a property pointing to
+		# itself - this can then be used to check that it really
+		# is an IPC window.
+		# 
+		self.ipc_window.window.property_change(self.service,
+				'XA_WINDOW', 32,
+				g.gdk.PROP_MODE_REPLACE,
+				[self.ipc_window.window.xid])
+
+		self.ipc_window.connect('property-notify-event',
+						self.property_changed)
+
+	def register(self):
+		# Make the root window contain a pointer to the IPC window
+		g.gdk.get_default_root_window().property_change(
+				self.service, 'XA_WINDOW', 32,
+				g.gdk.PROP_MODE_REPLACE,
+				[self.ipc_window.window.xid])
+	
+	def property_changed(self, win, event):
+		if event.atom != _message_id_prop:
+			return
+		
+		if event.state == g.gdk.PROPERTY_NEW_VALUE:
+			val = self.ipc_window.window.property_get(
+				_message_id_prop, 'XA_WINDOW', True)
+			if val is not None:
+				self.process_requests(val[2])
+	
+	def process_requests(self, requests):
+		for xid in requests:
+			foreign = g.gdk.window_foreign_new(xid)
+			xml = foreign.property_get(
+					_message_prop, 'XA_STRING', False)
+			if xml:
+				params, method = xmlrpclib.loads(xml[2])
+				self.invoke(method, *params)
+			else:
+				warn("No '%s' property on window %x",
+					_message_prop, xid)
+	
+	def invoke(self, method, *params):
+		if len(params) == 0:
+			raise Exception('No object path in message')
+		obpath = params[0]
+		try:
+			obj = self.objects[obpath]
+		except KeyError:
+			raise Exception("Unknown object '%s'" % obpath)
+		obj._invoke(method, params[1:])
+
+class ExportedObject:
+	def _invoke(self, method, params):
+		print "Invoking", method, params
+
+class XXMLProxy:
+	def __init__(self, service):
+		self.service = service
+		xid = g.gdk.get_default_root_window().property_get(
+				self.service, 'XA_WINDOW', False)
+
+		assert xid[0] == 'XA_WINDOW'
+		assert xid[1] == 32
+		assert len(xid[2]) == 1
+
+		self.remote = g.gdk.window_foreign_new(xid[2][0])
+		self.ipc_window = g.Invisible()
+		self.ipc_window.realize()
+	
+	def invoke(self, method, *params):
+		# Store the message on our window
+		xml = xmlrpclib.dumps(params, method)
+
+		self.ipc_window.window.property_change(_message_prop,
+				'XA_STRING', 8,
+				g.gdk.PROP_MODE_REPLACE,
+				xml)
+
+		# Tell the service about it
+		self.remote.property_change(_message_id_prop,
+				'XA_WINDOW', 32,
+				g.gdk.PROP_MODE_APPEND,
+				[self.ipc_window.window.xid])
+		print "Invoked"
+
+service = XXMLRPCServer('rox_TEST')
+service.register()
+service.objects['/foo'] = ExportedObject()
+
+proxy = XXMLProxy('rox_TEST')
+proxy.invoke('bang', '/foo')
+proxy.invoke('bang', '/foo')
+
+g.main()
-- 
2.11.4.GIT