[Telepathy-commits] [telepathy-doc/master] Example that creates a connection and attempts to set the presence

[Davyd Madeley]

---
 docs/examples/python_simple_presence/example.py |  114 +++++++++++++++++++++++
 1 files changed, 114 insertions(+), 0 deletions(-)
 create mode 100755 docs/examples/python_simple_presence/example.py

diff --git a/docs/examples/python_simple_presence/example.py b/docs/examples/python_simple_presence/example.py
new file mode 100755
index 0000000..2cc56c0
--- /dev/null
+++ b/docs/examples/python_simple_presence/example.py
@@ -0,0 +1,114 @@
+#!/usr/bin/env python
+
+import sys
+
+import gobject
+import dbus.mainloop.glib
+dbus.mainloop.glib.DBusGMainLoop(set_as_default = True)
+
+import telepathy
+import telepathy.client
+from telepathy.interfaces import CONN_MGR_INTERFACE, \
+                                 CONN_INTERFACE
+from telepathy.constants import CONNECTION_STATUS_CONNECTED, \
+                                CONNECTION_STATUS_DISCONNECTED
+
+DBUS_PROPERTIES = 'org.freedesktop.DBus.Properties'
+CONN_INTERFACE_SIMPLE_PRESENCE = 'org.freedesktop.Telepathy.Connection.Interface.SimplePresence'
+
+class Example (object):
+    def generic_reply (self, *args): pass
+    
+    def error_cb (self, error):
+        print "Error:", error
+        self.disconnect()
+
+    def disconnect (self):
+        self.conn[CONN_INTERFACE].Disconnect(
+                                        reply_handler = self.generic_reply,
+                                        error_handler = self.error_cb)
+
+    def get_statuses_cb (self, value):
+        print "Statuses:"
+        
+        for (key, value) in value.iteritems():
+            print " - %s" % key
+
+    def get_interfaces_cb (self, interfaces):
+        print "Interfaces:"
+
+        for interface in interfaces:
+            print " - %s" % interface
+
+    def status_changed_cb (self, status, reason):
+        conn = self.conn
+    
+        if status == CONNECTION_STATUS_DISCONNECTED:
+            print "Disconnected!"
+            self.loop.quit()
+
+        if status != CONNECTION_STATUS_CONNECTED: return
+
+        print 'Carrier Detected' # remember dialup modems?
+    
+        # request the statuses
+        conn[DBUS_PROPERTIES].Get(CONN_INTERFACE_SIMPLE_PRESENCE, 'Statuses',
+                                reply_handler = self.get_statuses_cb,
+                                error_handler = self.error_cb)
+
+        # get a list of interfaces on this connection
+        conn[CONN_INTERFACE].GetInterfaces(
+                                reply_handler = self.get_interfaces_cb,
+                                error_handler = self.error_cb)
+
+        # set our presence
+        # FIXME: doesn't like this interface
+        conn[CONN_INTERFACE_SIMPLE_PRESENCE].SetPresence ('away',
+                                                          'At the Movies',
+                                            reply_handler = self.generic_reply,
+                                            error_handler = self.error_cb)
+    
+    def request_connection_cb (self, bus_name, object_path):
+        print bus_name, object_path
+        self.conn = conn = telepathy.client.Connection(bus_name, object_path)
+        
+        conn[CONN_INTERFACE].connect_to_signal('StatusChanged',
+            self.status_changed_cb)
+    
+        print "Establishing connection..."
+        conn[CONN_INTERFACE].Connect(reply_handler = self.generic_reply,
+                                     error_handler = self.error_cb)
+    
+    def __init__ (self, account, password):
+        """e.g. account  = 'bob at example.com/test'
+                password = 'bigbob'
+        """
+
+        reg = telepathy.client.ManagerRegistry()
+        reg.LoadManagers()
+        
+        # get the gabble Connection Manager
+        self.cm = cm = reg.GetManager('gabble')
+        
+        # get the parameters required to make a Jabber connection
+        cm[CONN_MGR_INTERFACE].RequestConnection('jabber',
+            {
+                'account':  account,
+                'password': password,
+            },
+            reply_handler = self.request_connection_cb,
+            error_handler = self.error_cb)
+        
+        self.loop = gobject.MainLoop()
+        try:
+            self.loop.run()
+        except KeyboardInterrupt:
+            print "Terminating connection..."
+            self.disconnect()
+            # reengage the mainloop so that we can disconnect cleanly
+            self.loop.run()
+
+if __name__ == '__main__':
+    import getpass
+    password = getpass.getpass()
+    Example(sys.argv[1], password)
-- 
1.5.6.5