Massive refactoring to the troveclient

The new client adheres to the standards of the other clients
now. It prints out tables, uses ENVVAR's for auth, no longer
stores pickled json in a login token, uses openstack common,
and moves the cli operations into a v1 module for the future
of trove when it has a v2 api.

Please note for compatibility, the troveclient.compat module
has the old cli. In order to deploy it, amend the setup.cfg
to include the compat module.

implements blueprint cli-compliance-upgrade

Change-Id: Ie69d9dbc75ce90496da316244c97acca1877a327

1 files changed, 78 insertions, 0 deletions

diff --git a/troveclient/v1/databases.py b/troveclient/v1/databases.py
new file mode 100644
index 0000000..20f3cd5
--- /dev/null
+++ b/troveclient/v1/databases.py
@@ -0,0 +1,78 @@
+from troveclient import base
+from troveclient.common import check_for_exceptions
+from troveclient.common import limit_url
+from troveclient.common import Paginated
+import urlparse
+
+
+class Database(base.Resource):
+    """
+    According to Wikipedia, "A database is a system intended to organize,
+    store, and retrieve
+    large amounts of data easily."
+    """
+    def __repr__(self):
+        return "<Database: %s>" % self.name
+
+
+class Databases(base.ManagerWithFind):
+    """
+    Manage :class:`Databases` resources.
+    """
+    resource_class = Database
+
+    def create(self, instance_id, databases):
+        """
+        Create new databases within the specified instance
+        """
+        body = {"databases": databases}
+        url = "/instances/%s/databases" % instance_id
+        resp, body = self.api.client.post(url, body=body)
+        check_for_exceptions(resp, body)
+
+    def delete(self, instance_id, dbname):
+        """Delete an existing database in the specified instance"""
+        url = "/instances/%s/databases/%s" % (instance_id, dbname)
+        resp, body = self.api.client.delete(url)
+        check_for_exceptions(resp, body)
+
+    def _list(self, url, response_key, limit=None, marker=None):
+        resp, body = self.api.client.get(limit_url(url, limit, marker))
+        check_for_exceptions(resp, body)
+        if not body:
+            raise Exception("Call to " + url +
+                            " did not return a body.")
+        links = body.get('links', [])
+        next_links = [link['href'] for link in links if link['rel'] == 'next']
+        next_marker = None
+        for link in next_links:
+            # Extract the marker from the url.
+            parsed_url = urlparse.urlparse(link)
+            query_dict = dict(urlparse.parse_qsl(parsed_url.query))
+            next_marker = query_dict.get('marker', None)
+        databases = body[response_key]
+        databases = [self.resource_class(self, res) for res in databases]
+        return Paginated(databases, next_marker=next_marker, links=links)
+
+    def list(self, instance, limit=None, marker=None):
+        """
+        Get a list of all Databases from the instance.
+
+        :rtype: list of :class:`Database`.
+        """
+        return self._list("/instances/%s/databases" % base.getid(instance),
+                          "databases", limit, marker)
+
+#    def get(self, instance, database):
+#        """
+#        Get a specific instances.
+#
+#        :param flavor: The ID of the :class:`Database` to get.
+#        :rtype: :class:`Database`
+#        """
+#        assert isinstance(instance, Instance)
+#        assert isinstance(database, (Database, int))
+#        instance_id = base.getid(instance)
+#        db_id = base.getid(database)
+#        url = "/instances/%s/databases/%s" % (instance_id, db_id)
+#        return self._get(url, "database")