Added a test script to run the setup against a fresh EC2 instance.

test/requirements.txt

@@ -0,0 +1,3 @@
+boto
+fabric
+unipath

test/runtest.py

@@ -0,0 +1,133 @@
+import os
+import sys
+import time
+
+from boto.ec2 import EC2Connection, get_region
+from boto.exception import EC2ResponseError
+from fabric.api import settings
+from fabric.network import disconnect_all
+from paramiko import PKey
+from unipath import Path
+
+sys.path.insert(0, Path(Path.cwd(), ".."))
+
+def create_vm():
+
+    try:
+        kwargs = {
+            'aws_access_key_id': os.environ['AWS_ACCESS_KEY_ID'],
+            'aws_secret_access_key': os.environ['AWS_SECRET_ACCESS_KEY'],
+            'region': get_region('eu-west-1'),
+        }
+    except KeyError:
+        print '*' * 50
+        print "You must set both the AWS_ACCESS_KEY_ID and AWS_SECRET_ACCESS_KEY enviroment variables."
+        print '*' * 50
+        raise
+
+    ec2 = EC2Connection(**kwargs)
+
+    vm_name = 'chef_recipes_test'
+
+    # Check the keypair exists, if it doesn't - create it.
+    # The boto docs claim None is returned if it doesn't exist, but actually
+    # an EC2ResponseError is raised.
+    try:
+        key_pair = ec2.get_key_pair(vm_name)
+    except EC2ResponseError:
+        key_pair = None
+
+    if not key_pair:
+        ec2.create_key_pair(vm_name)
+
+    # Check the security group exists, if it doesn't - create it.
+    # The boto docs claim None is returned if it doesn't exist, but actually
+    # an EC2ResponseError is raised.
+    try:
+        security_group = ec2.get_all_security_groups(groupnames=[vm_name,])[0]
+    except EC2ResponseError:
+        security_group = None
+
+    if not security_group:
+        security_group = ec2.create_security_group(vm_name, vm_name)
+        security_group.authorize(ip_protocol='tcp', from_port=22, to_port=22, cidr_ip='0.0.0.0/0')
+
+    # Create a reservation - the image is an ubuntu machine.
+    reservation = ec2.run_instances(image_id='ami-4a34013e',
+            key_name='chef_recipes_test', security_groups=['chef_recipes_test',])
+
+    instance = reservation.instances[0]
+
+    print "Started VM, Waiting for VM to be 'running'"
+
+    while True:
+        time.sleep(5)
+        instance.update()
+        if instance.state == 'running':
+            print "VM Running, it needs a little bit of time before we can connect..."
+            break
+
+    # Even after its running, we need a short delay before we can connect.
+    time.sleep(30)
+
+    print "OK! Ready. Lets do this."
+
+    host_string = instance.public_dns_name
+    user = 'ubuntu'
+
+    return {
+        'host_string': host_string, 
+        'user': user,
+        'key_pair' : key_pair,
+        'instance': instance,
+    }
+
+class TestRunner(object):
+
+    def test(self, host_string, user, key_pair):
+
+        print host_string
+        print key_pair.fingerprint
+        print key_pair
+        print dir(key_pair)
+        print user
+
+        pkey = PKey(data=key_pair.fingerprint)
+        print pkey
+        return
+
+        from fabfile import install_chef, sync_config, sites, update_all
+
+        with settings(host_string=host_string, pkey=pkey, user=user):
+            print 'OK!'
+            install_chef()
+            sync_config()
+            sites()
+            update_all()
+            print "DONE!"
+
+    def tear_down(self):
+
+        disconnect_all()
+        try:
+            print "Terminating the VM"
+            self.instance.terminate()
+        except AttributeError:
+            pass
+
+    def setup(self):
+
+        vm_info = create_vm()
+        self.instance = vm_info['instance']
+        vm_info.pop('instance')
+        self.test(**vm_info)
+
+    def run_tests(self,):
+        try:
+            self.setup()
+        finally:
+            self.tear_down()
+
+
+t = TestRunner()
+t.run_tests()