Merge lp:~corey.bryant/charm-helpers/image-instance into lp:charm-helpers

[Corey Bryant]

Add openstack Amulet utility methods for using images/instances

[James Page (james-page)]

review: Needs Fixing

[Corey Bryant (corey.bryant)]

James,

Thanks for reviewing. I've pushed a new version that uses AMULET_HTTP_PROXY to set the proxy server.

Thanks,
Corey

[James Troup (elmo)]

Is there any reason not to use $http_proxy (sic) rather than a custom/Amulet specific variable name? $http_proxy is the de facto standard environment variable name.

[Corey Bryant (corey.bryant)]

I think we can probably use http_proxy instead. I'll give that a shot.
 Thanks for the comment!

On Mon, Jun 23, 2014 at 5:32 PM, James Troup <email address hidden>
wrote:

> Is there any reason not to use $http_proxy (sic) rather than a
> custom/Amulet specific variable name? $http_proxy is the de facto standard
> environment variable name.
> --
>
> https://code.launchpad.net/~corey.bryant/charm-helpers/image-instance/+merge/224170
> You are the owner of lp:~corey.bryant/charm-helpers/image-instance.
>

--
Regards,
Corey

[Corey Bryant (corey.bryant)]

> Is there any reason not to use $http_proxy (sic) rather than a custom/Amulet
> specific variable name? $http_proxy is the de facto standard environment
> variable name.

I don't know what the deal is but juju does not like http_proxy. juju deployment/status commands hang when it is set.

[lp:~corey.bryant/charm-helpers/image-instance]

165. By Corey Bryant on 2014-06-24

Add openstack Amulet utility methods for using images/instances.

=== modified file 'charmhelpers/contrib/openstack/amulet/utils.py'
--- charmhelpers/contrib/openstack/amulet/utils.py	2014-06-20 13:27:58 +0000
+++ charmhelpers/contrib/openstack/amulet/utils.py	2014-06-24 13:58:27 +0000
@@ -1,4 +1,7 @@
 import logging
+import os
+import time
+import urllib
 
 import glanceclient.v1.client as glance_client
 import keystoneclient.v2_0 as keystone_client
@@ -149,3 +152,58 @@
                                               endpoint_type='publicURL')
         return nova_client.Client(username=user, api_key=password,
                                   project_id=tenant, auth_url=ep)
+
+    def create_cirros_image(self, glance, image_name):
+        """Download the latest cirros image and upload it to glance."""
+        http_proxy = os.getenv('AMULET_HTTP_PROXY')
+        self.log.debug('AMULET_HTTP_PROXY: {}'.format(http_proxy))
+        if http_proxy:
+            proxies = {'http': http_proxy}
+            opener = urllib.FancyURLopener(proxies)
+        else:
+            opener = urllib.FancyURLopener()
+
+        f = opener.open("http://download.cirros-cloud.net/version/released")
+        version = f.read().strip()
+        cirros_img = "tests/cirros-{}-x86_64-disk.img".format(version)
+
+        if not os.path.exists(cirros_img):
+            cirros_url = "http://{}/{}/{}".format("download.cirros-cloud.net",
+                                                  version, cirros_img)
+            opener.retrieve(cirros_url, cirros_img)
+        f.close()
+
+        with open(cirros_img) as f:
+            image = glance.images.create(name=image_name, is_public=True,
+                                         disk_format='qcow2',
+                                         container_format='bare', data=f)
+        return image
+
+    def delete_image(self, glance, image):
+        """Delete the specified image."""
+        glance.images.delete(image)
+
+    def create_instance(self, nova, image_name, instance_name, flavor):
+        """Create the specified instance."""
+        image = nova.images.find(name=image_name)
+        flavor = nova.flavors.find(name=flavor)
+        instance = nova.servers.create(name=instance_name, image=image,
+                                       flavor=flavor)
+
+        count = 1
+        status = instance.status
+        while status == 'BUILD' and count < 10:
+            time.sleep(5)
+            instance = nova.servers.get(instance.id)
+            status = instance.status
+            self.log.debug('instance status: {}'.format(status))
+            count += 1
+
+        if status == 'BUILD':
+            return None
+
+        return instance
+
+    def delete_instance(self, nova, instance):
+        """Delete the specified instance."""
+        nova.servers.delete(instance)