Provides user data

warm/components/__init__.py

@@ -17,6 +17,9 @@
 
 """Components."""
 
+import os
+import uuid
+
 from openstackclient.common import utils
 from neutronclient.neutron import v2_0 as neutronV20
 
@@ -192,6 +195,13 @@ class Server(Base):
                     "v4-fixed-ip": obj.get("fixed_ip"),
                     "port-id": obj.get("port"),
                     })
+
+        userdata = None
+        if "userdata" in options:
+            tmpname = uuid.uuid1()
+            os.system("/usr/bin/write-mime-multipart --output=/tmp/%s %s " % 
+                      (tmpname, " ".join(options["userdata"])))
+            userdata = open("/tmp/%s" % tmpname)
             
         whitelist = dict(
             name=options.get("name"),
@@ -199,11 +209,8 @@ class Server(Base):
             flavor=flavor.id,
             security_groups=secgrps,
             nics=networks,
-            #userdata=self._UserData(options.get("userdata")),
-            )
-        
-        
-                
+            userdata=userdata)
+
         return self._agent.client.compute.servers.create(**whitelist)
 
     def _PostExecute(self, options):

warm/tests/test_components.py

@@ -40,7 +40,7 @@ class TestComponents(testtools.TestCase):
         super(TestComponents, self).setUp()
         self.agent = warm.Agent()
         
-    def _test_key(self):
+    def test_key(self):
         cfg = {"name": rndname("key"),
                "path": "/tmp"}
         key = components.Key(self.agent)(**cfg)
@@ -48,14 +48,14 @@ class TestComponents(testtools.TestCase):
             os.path.exists("%(path)s/%(name)s.pem" % cfg))
         key.delete()
 
-    def _test_volume(self):
+    def test_volume(self):
         cfg = {"name": rndname("vol"),
                "size": 1}
         vol = components.Volume(self.agent)(**cfg)
         vol.wait_for_ready()
         vol.delete()
 
-    def _test_securitygroup(self):
+    def test_securitygroup(self):
         cfg = {"name": rndname("secgroup"),
                "rules": [
                 {"ip_protocol":"tcp",
@@ -65,7 +65,7 @@ class TestComponents(testtools.TestCase):
         sec = components.SecurityGroup(self.agent)(**cfg)
         sec.delete()
 
-    def _test_server(self):
+    def test_server(self):
         cfg = {"name": rndname("srv"),
                "flavor": 1,
                "image": "cirros-0.3.1-x86_64-uec",}
@@ -73,7 +73,7 @@ class TestComponents(testtools.TestCase):
         srv.wait_for_ready()
         srv.delete()
 
-    def _test_server_volume(self):
+    def test_server_volume(self):
         cfg = {"name": rndname("vol"),
                "size": 1}
         vol = components.Volume(self.agent)(**cfg)
@@ -114,8 +114,18 @@ class TestComponents(testtools.TestCase):
         
         time.sleep(5) #TODO(sahid): Bug, not able to remove an used network
         net.delete()
+
+    def _test_server_userdata(self):
+        path = os.path.dirname(os.path.abspath(__file__))
+        cfg = {"name": rndname("srv"),
+               "flavor": 2,
+               "image": "ubuntu",
+               "userdata": [path + "/templates/test.ci",]}
+        srv = components.Server(self.agent)(**cfg)
+        srv.delete()
+
         
-    def _test_network(self):
+    def test_network(self):
         cfg = {"name": rndname("net"),
                "subnets": [
                 {"name": rndname("subnet"),
@@ -124,7 +134,7 @@ class TestComponents(testtools.TestCase):
         net = components.Network(self.agent)(**cfg)
         net.delete()
 
-    def _test_router(self):
+    def test_router(self):
         cfg = {"name": rndname("net")}
         net = components.Network(self.agent)(**cfg)