add client/python/ensure-channel.py (#32986)

2 files changed, 69 insertions, 0 deletions

diff --git a/examples/client/python/Makefile.am b/examples/client/python/Makefile.am
index f31e15236..6af4e11eb 100644
--- a/examples/client/python/Makefile.am
+++ b/examples/client/python/Makefile.am
@@ -1,2 +1,3 @@
 EXTRA_DIST = \
+  ensure-channel.py \
   text-handler.py
diff --git a/examples/client/python/ensure-channel.py b/examples/client/python/ensure-channel.py
new file mode 100755
index 000000000..1acce1d21
--- /dev/null
+++ b/examples/client/python/ensure-channel.py
@@ -0,0 +1,68 @@
+#!/usr/bin/env python
+import sys
+
+import gobject
+gobject.threads_init()
+
+from gi.repository import TelepathyGLib
+
+def usage():
+    print "%s ACCOUNT [text|audio|video] CONTACT" % sys.argv[0]
+    print "ACCOUNT is a Telepathy account name, use 'mc-tool list' to list all your accounts"
+    print "CONTACT is a contact id such as badger@gmail.com"
+
+    sys.exit(1)
+
+def create_request(action, contact_id):
+    if action == 'text':
+        return {
+            TelepathyGLib.PROP_CHANNEL_CHANNEL_TYPE:
+                TelepathyGLib.IFACE_CHANNEL_TYPE_TEXT,
+            TelepathyGLib.PROP_CHANNEL_TARGET_HANDLE_TYPE:
+                int(TelepathyGLib.HandleType.CONTACT),
+            TelepathyGLib.PROP_CHANNEL_TARGET_ID: contact_id}
+    elif action in ['audio', 'video']:
+        return {
+            TelepathyGLib.PROP_CHANNEL_CHANNEL_TYPE:
+                TelepathyGLib.IFACE_CHANNEL_TYPE_STREAMED_MEDIA,
+            TelepathyGLib.PROP_CHANNEL_TARGET_HANDLE_TYPE:
+                int(TelepathyGLib.HandleType.CONTACT),
+            TelepathyGLib.PROP_CHANNEL_TARGET_ID: contact_id,
+            TelepathyGLib.PROP_CHANNEL_TYPE_STREAMED_MEDIA_INITIAL_AUDIO:
+                True,
+            TelepathyGLib.PROP_CHANNEL_TYPE_STREAMED_MEDIA_INITIAL_VIDEO:
+                action == 'video'}
+    else:
+        usage()
+
+def ensure_channel_cb(req, result, main_loop):
+    req.ensure_channel_finish(result)
+
+    main_loop.quit()
+
+if __name__ == '__main__':
+    #TelepathyGLib.debug_set_flags("all")
+
+    dbus = TelepathyGLib.DBusDaemon.dup()
+
+    if len(sys.argv) != 4:
+        usage()
+
+    _, account_id, action, contact_id = sys.argv
+
+    mgr = TelepathyGLib.AccountManager.dup()
+
+    account = mgr.ensure_account("%s%s" % (TelepathyGLib.ACCOUNT_OBJECT_PATH_BASE,
+        account_id))
+
+    request = create_request(action, contact_id)
+
+    req = TelepathyGLib.AccountChannelRequest.new(account, request, 0)
+    # FIXME: for some reason TelepathyGLib.USER_ACTION_TIME_CURRENT_TIME is
+    # not defined
+
+    main_loop = gobject.MainLoop()
+
+    req.ensure_channel_async("", None, ensure_channel_cb, main_loop)
+
+    main_loop.run()