[telepathy-doc/master] Basic Approver

[Danielle Madeley]

---
 docs/examples/python_mc5_clients/Makefile.am |    1 +
 docs/examples/python_mc5_clients/approver.py |   76 ++++++++++++++++++++++++++
 2 files changed, 77 insertions(+), 0 deletions(-)
 create mode 100644 docs/examples/python_mc5_clients/approver.py

diff --git a/docs/examples/python_mc5_clients/Makefile.am b/docs/examples/python_mc5_clients/Makefile.am
index 000769c..f25a460 100644
--- a/docs/examples/python_mc5_clients/Makefile.am
+++ b/docs/examples/python_mc5_clients/Makefile.am
@@ -1,4 +1,5 @@
 noinst_PYTHON = \
+	approver.py \
 	observer.py
 
 include $(top_srcdir)/docs/rsync-dist.make
diff --git a/docs/examples/python_mc5_clients/approver.py b/docs/examples/python_mc5_clients/approver.py
new file mode 100644
index 0000000..bd7468a
--- /dev/null
+++ b/docs/examples/python_mc5_clients/approver.py
@@ -0,0 +1,76 @@
+import dbus.glib
+import gobject
+import telepathy
+
+from telepathy.constants import CONNECTION_HANDLE_TYPE_CONTACT
+from telepathy.interfaces import CLIENT, \
+                                 CLIENT_APPROVER, \
+                                 CHANNEL
+
+DBUS_PROPERTIES = "org.freedesktop.DBus.Properties"
+
+class ExampleApprover(dbus.service.Object):
+    properties = {
+        CLIENT: {
+            'Interfaces': [ CLIENT_APPROVER ],
+        },
+        CLIENT_APPROVER: {
+            'ApproverChannelFilter': dbus.Array([
+                    dbus.Dictionary({
+                    }, signature='sv')
+                ], signature='a{sv}')
+        },
+    }
+
+    def __init__(self, client_name):
+        bus_name = '.'.join ([CLIENT, client_name])
+        object_path = '/' + bus_name.replace('.', '/')
+
+        bus_name = dbus.service.BusName(bus_name, bus=dbus.SessionBus())
+        dbus.service.Object.__init__(self, bus_name, object_path)
+        self.nameref = bus_name
+
+    @dbus.service.method(dbus_interface=DBUS_PROPERTIES,
+                         in_signature='s',
+                         out_signature='a{sv}')
+    def GetAll(self, interface):
+        print "GetAll", interface
+        if interface in self.properties:
+            return self.properties[interface]
+        else:
+            return {}
+
+    @dbus.service.method(dbus_interface=DBUS_PROPERTIES,
+                         in_signature='ss',
+                         out_signature='v')
+    def Get(self, interface, property):
+        print "Get", interface, property
+        if interface in self.properties and \
+           property in self.properties[interface]:
+            return self.properties[interface][property]
+        else:
+            return 0
+
+    @dbus.service.method(dbus_interface=CLIENT_APPROVER,
+                         in_signature='a(oa{sv})oa{sv}',
+                         out_signature='')
+    def AddDispatchOperation(self, channels, dispatch, properties):
+
+        print "Incoming channels:"
+        for object, props in channels:
+            print " - %s :: %s" % (props[CHANNEL + '.ChannelType'],
+                                   props[CHANNEL + '.TargetID'])
+	# if we return from our approver without raising an error, it's assumed
+	# that we accept the request and we're waiting for user feedback.
+	# if this is the only approver, and we then do nothing with the request
+	# it will get stuck and never be handled.
+	raise Exception("not interested")
+
+def start():
+    ExampleApprover("ExampleApprover")
+    return False
+
+if __name__ == '__main__':
+    gobject.timeout_add(0, start)
+    loop = gobject.MainLoop()
+    loop.run()
-- 
1.5.6.5