From 635dbd772dc148b1416ba5f345e78c051c1caa86 Mon Sep 17 00:00:00 2001
From: Fei Long Wang <flwang@cn.ibm.com>
Date: Tue, 1 Apr 2014 22:21:38 +0800
Subject: [PATCH] Add sample for Keystone auth

Add a sample about how the client to talk with Marconi
server when the Keystone auth is enabled on server side.

Change-Id: I446063da2e6958c27ff8afab2afad7b8818104cb
---
 examples/keystone_auth.py | 54 +++++++++++++++++++++++++++++++++++++++
 1 file changed, 54 insertions(+)
 create mode 100644 examples/keystone_auth.py

diff --git a/examples/keystone_auth.py b/examples/keystone_auth.py
new file mode 100644
index 00000000..1ca02cdf
--- /dev/null
+++ b/examples/keystone_auth.py
@@ -0,0 +1,54 @@
+# Copyright 2014 Red Hat, Inc.
+# Copyright 2014 IBM Corp.
+#
+#    Licensed under the Apache License, Version 2.0 (the "License"); you may
+#    not use this file except in compliance with the License. You may obtain
+#    a copy of the License at
+#
+#         http://www.apache.org/licenses/LICENSE-2.0
+#
+#    Unless required by applicable law or agreed to in writing, software
+#    distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+#    WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
+#    License for the specific language governing permissions and limitations
+#    under the License.
+
+from marconiclient.queues.v1 import client
+
+URL = 'http://localhost:8888'
+
+
+def create_post_delete(queue_name, messages):
+    """Creates a queue, posts messages to it and finally deletes it with
+    keystone auth strategy enabled on Marconi server side.
+
+    :params queue_name: The name of the queue
+    :type queue_name: `six.text_type`
+    :params messages: Messages to post.
+    :type messages: list
+    """
+    conf = {'auth_opts':
+            {'backend': 'keystone',
+             'options': {'os_username': 'marconi',
+                         'os_password': 'marconi',
+                         'os_project_id': 'ccad479c402f43a2994f6e372ab3f8fe',
+                         'os_project_name': '',
+                         'os_auth_url': 'http://127.0.0.1:5000/v2.0/',
+                         'insecure': ''}
+             }
+            }
+    cli = client.Client(URL, conf=conf)
+    queue = cli.queue(queue_name)
+    queue.post(messages)
+
+    for msg in queue.messages(echo=True):
+        print(msg.body)
+        msg.delete()
+
+    queue.delete()
+
+
+if __name__ == '__main__':
+    messages = [{'body': {'id': idx}, 'ttl': 360}
+                for idx in range(20)]
+    create_post_delete('my_queue', messages)