Synnefo

#!/usr/bin/env python

"""

Synnefo ci utils module

"""

import os

import re

import sys

import time

import logging

import fabric.api as fabric

import subprocess

import tempfile

from ConfigParser import ConfigParser, DuplicateSectionError

from kamaki.cli import config as kamaki_config

from kamaki.clients.astakos import AstakosClient, parse_endpoints

from kamaki.clients.cyclades import CycladesClient, CycladesNetworkClient

from kamaki.clients.image import ImageClient

from kamaki.clients.compute import ComputeClient

from kamaki.clients import ClientError

import filelocker

DEFAULT_CONFIG_FILE = "ci_wheezy.conf"

# Is our terminal a colorful one?

USE_COLORS = True

# UUID of owner of system images

DEFAULT_SYSTEM_IMAGES_UUID = [

    "25ecced9-bf53-4145-91ee-cf47377e9fb2",  # production (okeanos.grnet.gr)

    "04cbe33f-29b7-4ef1-94fb-015929e5fc06",  # testing (okeanos.io)

]

def _run(cmd, verbose):

    """Run fabric with verbose level"""

    if verbose:

        args = ('running',)

    else:

        args = ('running', 'stdout',)

    with fabric.hide(*args):  # Used * or ** magic. pylint: disable-msg=W0142

        return fabric.run(cmd)

def _put(local, remote):

    """Run fabric put command without output"""

    with fabric.quiet():

        fabric.put(local, remote)

def _red(msg):

    """Red color"""

    ret = "\x1b[31m" + str(msg) + "\x1b[0m" if USE_COLORS else str(msg)

    return ret

def _yellow(msg):

    """Yellow color"""

    ret = "\x1b[33m" + str(msg) + "\x1b[0m" if USE_COLORS else str(msg)

    return ret

def _green(msg):

    """Green color"""

    ret = "\x1b[32m" + str(msg) + "\x1b[0m" if USE_COLORS else str(msg)

    return ret

def _check_fabric(fun):

    """Check if fabric env has been set"""

    def wrapper(self, *args, **kwargs):

        """wrapper function"""

        if not self.fabric_installed:

            self.setup_fabric()

            self.fabric_installed = True

        return fun(self, *args, **kwargs)

    return wrapper

def _check_kamaki(fun):

    """Check if kamaki has been initialized"""

    def wrapper(self, *args, **kwargs):

        """wrapper function"""

        if not self.kamaki_installed:

            self.setup_kamaki()

            self.kamaki_installed = True

        return fun(self, *args, **kwargs)

    return wrapper

class _MyFormatter(logging.Formatter):

    """Logging Formatter"""

    def format(self, record):

        format_orig = self._fmt

        if record.levelno == logging.DEBUG:

            self._fmt = "  %(message)s"

        elif record.levelno == logging.INFO:

            self._fmt = "%(message)s"

        elif record.levelno == logging.WARNING:

            self._fmt = _yellow("[W] %(message)s")

        elif record.levelno == logging.ERROR:

            self._fmt = _red("[E] %(message)s")

        result = logging.Formatter.format(self, record)

        self._fmt = format_orig

        return result

# Too few public methods. pylint: disable-msg=R0903

class _InfoFilter(logging.Filter):

    """Logging Filter that allows DEBUG and INFO messages only"""

    def filter(self, rec):

        """The filter"""

        return rec.levelno in (logging.DEBUG, logging.INFO)

# Too many instance attributes. pylint: disable-msg=R0902

class SynnefoCI(object):

    """SynnefoCI python class"""

    def __init__(self, config_file=None, build_id=None, cloud=None):

        """ Initialize SynnefoCI python class

        Setup logger, local_dir, config and kamaki

        """

        # Setup logger

        self.logger = logging.getLogger('synnefo-ci')

        self.logger.setLevel(logging.DEBUG)

        handler1 = logging.StreamHandler(sys.stdout)

        handler1.setLevel(logging.DEBUG)

        handler1.addFilter(_InfoFilter())

        handler1.setFormatter(_MyFormatter())

        handler2 = logging.StreamHandler(sys.stderr)

        handler2.setLevel(logging.WARNING)

        handler2.setFormatter(_MyFormatter())

        self.logger.addHandler(handler1)

        self.logger.addHandler(handler2)

        # Get our local dir

        self.ci_dir = os.path.dirname(os.path.abspath(__file__))

        self.repo_dir = os.path.dirname(self.ci_dir)

        # Read config file

        if config_file is None:

            config_file = os.path.join(self.ci_dir, DEFAULT_CONFIG_FILE)

        config_file = os.path.abspath(config_file)

        self.config = ConfigParser()

        self.config.optionxform = str

        self.config.read(config_file)

        # Read temporary_config file

        self.temp_config_file = \

            os.path.expanduser(self.config.get('Global', 'temporary_config'))

        self.temp_config = ConfigParser()

        self.temp_config.optionxform = str

        self.temp_config.read(self.temp_config_file)

        self.build_id = build_id

        if build_id is not None:

            self.logger.info("Will use \"%s\" as build id" %

                             _green(self.build_id))

        # Set kamaki cloud

        if cloud is not None:

            self.kamaki_cloud = cloud

        elif self.config.has_option("Deployment", "kamaki_cloud"):

            kamaki_cloud = self.config.get("Deployment", "kamaki_cloud")

            if kamaki_cloud == "":

                self.kamaki_cloud = None

        else:

            self.kamaki_cloud = None

        # Initialize variables

        self.fabric_installed = False

        self.kamaki_installed = False

        self.cyclades_client = None

        self.network_client = None

        self.compute_client = None

        self.image_client = None

        self.astakos_client = None

    def setup_kamaki(self):

        """Initialize kamaki

        Setup cyclades_client, image_client and compute_client

        """

        config = kamaki_config.Config()

        if self.kamaki_cloud is None:

            try:

                self.kamaki_cloud = config.get("global", "default_cloud")

            except AttributeError:

                # Compatibility with kamaki version <=0.10

                self.kamaki_cloud = config.get("global", "default_cloud")

        self.logger.info("Setup kamaki client, using cloud '%s'.." %

                         self.kamaki_cloud)

        auth_url = config.get_cloud(self.kamaki_cloud, "url")

        self.logger.debug("Authentication URL is %s" % _green(auth_url))

        token = config.get_cloud(self.kamaki_cloud, "token")

        #self.logger.debug("Token is %s" % _green(token))

        self.astakos_client = AstakosClient(auth_url, token)

        endpoints = self.astakos_client.authenticate()

        cyclades_url = get_endpoint_url(endpoints, "compute")

        self.logger.debug("Cyclades API url is %s" % _green(cyclades_url))

        self.cyclades_client = CycladesClient(cyclades_url, token)

        self.cyclades_client.CONNECTION_RETRY_LIMIT = 2

        network_url = get_endpoint_url(endpoints, "network")

        self.logger.debug("Network API url is %s" % _green(network_url))

        self.network_client = CycladesNetworkClient(network_url, token)

        self.network_client.CONNECTION_RETRY_LIMIT = 2

        image_url = get_endpoint_url(endpoints, "image")

        self.logger.debug("Images API url is %s" % _green(image_url))

        self.image_client = ImageClient(cyclades_url, token)

        self.image_client.CONNECTION_RETRY_LIMIT = 2

        compute_url = get_endpoint_url(endpoints, "compute")

        self.logger.debug("Compute API url is %s" % _green(compute_url))

        self.compute_client = ComputeClient(compute_url, token)

        self.compute_client.CONNECTION_RETRY_LIMIT = 2

    def _wait_transition(self, server_id, current_status, new_status):

        """Wait for server to go from current_status to new_status"""

        self.logger.debug("Waiting for server to become %s" % new_status)

        timeout = self.config.getint('Global', 'build_timeout')

        sleep_time = 5

        while True:

            server = self.cyclades_client.get_server_details(server_id)

            if server['status'] == new_status:

                return server

            elif timeout < 0:

                self.logger.error(

                    "Waiting for server to become %s timed out" % new_status)

                self.destroy_server(False)

                sys.exit(1)

            elif server['status'] == current_status:

                # Sleep for #n secs and continue

                timeout = timeout - sleep_time

                time.sleep(sleep_time)

            else:

                self.logger.error(

                    "Server failed with status %s" % server['status'])

                self.destroy_server(False)

                sys.exit(1)

    @_check_kamaki

    def destroy_server(self, wait=True):

        """Destroy slave server"""

        server_id = int(self.read_temp_config('server_id'))

        fips = [f for f in self.network_client.list_floatingips()

                if str(f['instance_id']) == str(server_id)]

        self.logger.info("Destoying server with id %s " % server_id)

        self.cyclades_client.delete_server(server_id)

        if wait:

            self._wait_transition(server_id, "ACTIVE", "DELETED")

        for fip in fips:

            self.logger.info("Destroying floating ip %s",

                             fip['floating_ip_address'])

            self.network_client.delete_floatingip(fip['id'])

    # pylint: disable= no-self-use

    @_check_fabric

    def shell_connect(self):

        """Open shell to remote server"""

        fabric.open_shell("export TERM=xterm")

    def _create_floating_ip(self):

        """Create a new floating ip"""

        networks = self.network_client.list_networks(detail=True)

        pub_nets = [n for n in networks

                    if n['SNF:floating_ip_pool'] and n['public']]

        for pub_net in pub_nets:

            # Try until we find a public network that is not full

            try:

                fip = self.network_client.create_floatingip(pub_net['id'])

            except ClientError as err:

                self.logger.warning("%s: %s", err.message, err.details)

                continue

            self.logger.debug("Floating IP %s with id %s created",

                              fip['floating_ip_address'], fip['id'])

            return fip

        self.logger.error("No mor IP addresses available")

        sys.exit(1)

    def _create_port(self, floating_ip):

        """Create a new port for our floating IP"""

        net_id = floating_ip['floating_network_id']

        self.logger.debug("Creating a new port to network with id %s", net_id)

        fixed_ips = [{'ip_address': floating_ip['floating_ip_address']}]

        port = self.network_client.create_port(

            net_id, device_id=None, fixed_ips=fixed_ips)

        return port

    @_check_kamaki

    # Too many local variables. pylint: disable-msg=R0914

    def create_server(self, image=None, flavor=None, ssh_keys=None,

                      server_name=None):

        """Create slave server"""

        self.logger.info("Create a new server..")

        # Find a build_id to use

        self._create_new_build_id()

        # Find an image to use

        image_id = self._find_image(image)

        # Find a flavor to use

        flavor_id = self._find_flavor(flavor)

        # Create Server

        networks = []

        if self.config.get("Deployment", "allocate_floating_ip") == "True":

            fip = self._create_floating_ip()

            port = self._create_port(fip)

            networks.append({'port': port['id']})

        private_networks = self.config.get('Deployment', 'private_networks')

        if private_networks:

            private_networks = [p.strip() for p in private_networks.split(",")]

            networks.extend([{"uuid": uuid} for uuid in private_networks])

        if server_name is None:

            server_name = self.config.get("Deployment", "server_name")

            server_name = "%s(BID: %s)" % (server_name, self.build_id)

        server = self.cyclades_client.create_server(

            server_name, flavor_id, image_id, networks=networks)

        server_id = server['id']

        self.write_temp_config('server_id', server_id)

        self.logger.debug("Server got id %s" % _green(server_id))

        server_user = server['metadata']['users']

        self.write_temp_config('server_user', server_user)

        self.logger.debug("Server's admin user is %s" % _green(server_user))

        server_passwd = server['adminPass']

        self.write_temp_config('server_passwd', server_passwd)

        server = self._wait_transition(server_id, "BUILD", "ACTIVE")

        self._get_server_ip_and_port(server, private_networks)

        self._copy_ssh_keys(ssh_keys)

        # Setup Firewall

        self.setup_fabric()

        self.logger.info("Setup firewall")

        accept_ssh_from = self.config.get('Global', 'accept_ssh_from')

        if accept_ssh_from != "":

            self.logger.debug("Block ssh except from %s" % accept_ssh_from)

            cmd = """

            local_ip=$(/sbin/ifconfig eth0 | grep 'inet addr:' | \

                cut -d':' -f2 | cut -d' ' -f1)

            iptables -A INPUT -s localhost -j ACCEPT

            iptables -A INPUT -s $local_ip -j ACCEPT

            iptables -A INPUT -s {0} -p tcp --dport 22 -j ACCEPT

            iptables -A INPUT -p tcp --dport 22 -j DROP

            """.format(accept_ssh_from)

            _run(cmd, False)

        # Setup apt, download packages

        self.logger.debug("Setup apt. Install x2goserver and firefox")

        cmd = """

        echo 'APT::Install-Suggests "false";' >> /etc/apt/apt.conf

        echo 'precedence ::ffff:0:0/96  100' >> /etc/gai.conf

        apt-get update

        apt-get install curl --yes --force-yes

        echo -e "\n\n{0}" >> /etc/apt/sources.list

        # Synnefo repo's key

        curl https://dev.grnet.gr/files/apt-grnetdev.pub | apt-key add -

        # X2GO Key

        apt-key adv --recv-keys --keyserver keys.gnupg.net E1F958385BFE2B6E

        apt-get install x2go-keyring --yes --force-yes

        apt-get update

        apt-get install x2goserver x2goserver-xsession \

                iceweasel --yes --force-yes

        # xterm published application

        echo '[Desktop Entry]' > /usr/share/applications/xterm.desktop

        echo 'Name=XTerm' >> /usr/share/applications/xterm.desktop

        echo 'Comment=standard terminal emulator for the X window system' >> \

            /usr/share/applications/xterm.desktop

        echo 'Exec=xterm' >> /usr/share/applications/xterm.desktop

        echo 'Terminal=false' >> /usr/share/applications/xterm.desktop

        echo 'Type=Application' >> /usr/share/applications/xterm.desktop

        echo 'Encoding=UTF-8' >> /usr/share/applications/xterm.desktop

        echo 'Icon=xterm-color_48x48' >> /usr/share/applications/xterm.desktop

        echo 'Categories=System;TerminalEmulator;' >> \

                /usr/share/applications/xterm.desktop

        """.format(self.config.get('Global', 'apt_repo'))

        _run(cmd, False)

    def _find_flavor(self, flavor=None):

        """Find a suitable flavor to use

        Search by name (reg expression) or by id

        """

        # Get a list of flavors from config file

        flavors = self.config.get('Deployment', 'flavors').split(",")

        if flavor is not None:

            # If we have a flavor_name to use, add it to our list

            flavors.insert(0, flavor)

        list_flavors = self.compute_client.list_flavors()

        for flv in flavors:

            flv_type, flv_value = parse_typed_option(option="flavor",

                                                     value=flv)

            if flv_type == "name":

                # Filter flavors by name

                self.logger.debug(

                    "Trying to find a flavor with name \"%s\"" % flv_value)

                list_flvs = \

                    [f for f in list_flavors

                     if re.search(flv_value, f['name'], flags=re.I)

                     is not None]

            elif flv_type == "id":

                # Filter flavors by id

                self.logger.debug(

                    "Trying to find a flavor with id \"%s\"" % flv_value)

                list_flvs = \

                    [f for f in list_flavors

                     if str(f['id']) == flv_value]

            else:

                self.logger.error("Unrecognized flavor type %s" % flv_type)

            # Check if we found one

            if list_flvs:

                self.logger.debug("Will use \"%s\" with id \"%s\""

                                  % (_green(list_flvs[0]['name']),

                                     _green(list_flvs[0]['id'])))

                return list_flvs[0]['id']

        self.logger.error("No matching flavor found.. aborting")

        sys.exit(1)

    def _find_image(self, image=None):

        """Find a suitable image to use

        In case of search by name, the image has to belong to one

        of the `DEFAULT_SYSTEM_IMAGES_UUID' users.

        In case of search by id it only has to exist.

        """

        # Get a list of images from config file

        images = self.config.get('Deployment', 'images').split(",")

        if image is not None:

            # If we have an image from command line, add it to our list

            images.insert(0, image)

        auth = self.astakos_client.authenticate()

        user_uuid = auth["access"]["token"]["tenant"]["id"]

        list_images = self.image_client.list_public(detail=True)['images']

        for img in images:

            img_type, img_value = parse_typed_option(option="image", value=img)

            if img_type == "name":

                # Filter images by name

                self.logger.debug(

                    "Trying to find an image with name \"%s\"" % img_value)

                accepted_uuids = DEFAULT_SYSTEM_IMAGES_UUID + [user_uuid]

                list_imgs = \

                    [i for i in list_images if i['user_id'] in accepted_uuids

                     and

                     re.search(img_value, i['name'], flags=re.I) is not None]

            elif img_type == "id":

                # Filter images by id

                self.logger.debug(

                    "Trying to find an image with id \"%s\"" % img_value)

                list_imgs = \

                    [i for i in list_images

                     if i['id'].lower() == img_value.lower()]

            else:

                self.logger.error("Unrecognized image type %s" % img_type)

                sys.exit(1)

            # Check if we found one

            if list_imgs:

                self.logger.debug("Will use \"%s\" with id \"%s\""

                                  % (_green(list_imgs[0]['name']),

                                     _green(list_imgs[0]['id'])))

                return list_imgs[0]['id']

        # We didn't found one

        self.logger.error("No matching image found.. aborting")

        sys.exit(1)

    def _get_server_ip_and_port(self, server, private_networks):

        """Compute server's IPv4 and ssh port number"""

        self.logger.info("Get server connection details..")

        if private_networks:

            # Choose the networks that belong to private_networks

            networks = [n for n in server['attachments']

                        if n['network_id'] in private_networks]

        else:

            # Choose the networks that are public

            networks = [n for n in server['attachments']

                        if self.network_client.

                        get_network_details(n['network_id'])['public']]

        # Choose the networks with IPv4

        networks = [n for n in networks if n['ipv4']]

        # Use the first network as IPv4

        server_ip = networks[0]['ipv4']

        # Check if config has ssh_port option and if so, use that port.

        if self.config.has_option("Deployment", "ssh_port"):

            server_port = self.config.get("Deployment", "ssh_port")

        else:

            if (".okeanos.io" in self.cyclades_client.base_url or

            ".demo.synnefo.org" in self.cyclades_client.base_url):

                tmp1 = int(server_ip.split(".")[2])

                tmp2 = int(server_ip.split(".")[3])

                server_ip = "gate.okeanos.io"

                server_port = 10000 + tmp1 * 256 + tmp2

            else:

                server_port = 22

        self.write_temp_config('server_ip', server_ip)

        self.logger.debug("Server's IPv4 is %s" % _green(server_ip))

        self.write_temp_config('server_port', server_port)

        self.logger.debug("Server's ssh port is %s" % _green(server_port))

        ssh_command = "ssh -p %s %s@%s" \

            % (server_port, server['metadata']['users'], server_ip)

        self.logger.debug("Access server using \"%s\"" %

                          (_green(ssh_command)))

    @_check_fabric

    def _copy_ssh_keys(self, ssh_keys):

        """Upload/Install ssh keys to server"""

        self.logger.debug("Check for authentication keys to use")

        if ssh_keys is None:

            ssh_keys = self.config.get("Deployment", "ssh_keys")

        if ssh_keys != "":

            ssh_keys = os.path.expanduser(ssh_keys)

            self.logger.debug("Will use \"%s\" authentication keys file" %

                              _green(ssh_keys))

            keyfile = '/tmp/%s.pub' % fabric.env.user

            _run('mkdir -p ~/.ssh && chmod 700 ~/.ssh', False)

            if ssh_keys.startswith("http://") or \

                    ssh_keys.startswith("https://") or \

                    ssh_keys.startswith("ftp://"):

                cmd = """

                apt-get update

                apt-get install wget --yes --force-yes

                wget {0} -O {1} --no-check-certificate

                """.format(ssh_keys, keyfile)

                _run(cmd, False)

            elif os.path.exists(ssh_keys):

                _put(ssh_keys, keyfile)

            else:

                self.logger.debug("No ssh keys found")

                return

            _run('cat %s >> ~/.ssh/authorized_keys' % keyfile, False)

            _run('rm %s' % keyfile, False)

            self.logger.debug("Uploaded ssh authorized keys")

        else:

            self.logger.debug("No ssh keys found")

    def _create_new_build_id(self):

        """Find a uniq build_id to use"""

        with filelocker.lock("%s.lock" % self.temp_config_file,

                             filelocker.LOCK_EX):

            # Read temp_config again to get any new entries

            self.temp_config.read(self.temp_config_file)

            # Find a uniq build_id to use

            if self.build_id is None:

                ids = self.temp_config.sections()

                if ids:

                    max_id = int(max(self.temp_config.sections(), key=int))

                    self.build_id = max_id + 1

                else:

                    self.build_id = 1

            self.logger.debug("Will use \"%s\" as build id"

                              % _green(self.build_id))

            # Create a new section

            try:

                self.temp_config.add_section(str(self.build_id))

            except DuplicateSectionError:

                msg = ("Build id \"%s\" already in use. " +

                       "Please use a uniq one or cleanup \"%s\" file.\n") \

                    % (self.build_id, self.temp_config_file)

                self.logger.error(msg)

                sys.exit(1)

            creation_time = \

                time.strftime("%a, %d %b %Y %X", time.localtime())

            self.temp_config.set(str(self.build_id),

                                 "created", str(creation_time))

            # Write changes back to temp config file

            with open(self.temp_config_file, 'wb') as tcf:

                self.temp_config.write(tcf)

    def write_temp_config(self, option, value):

        """Write changes back to config file"""

        # Acquire the lock to write to temp_config_file

        with filelocker.lock("%s.lock" % self.temp_config_file,

                             filelocker.LOCK_EX):

            # Read temp_config again to get any new entries

            self.temp_config.read(self.temp_config_file)

            self.temp_config.set(str(self.build_id), option, str(value))

            curr_time = time.strftime("%a, %d %b %Y %X", time.localtime())

            self.temp_config.set(str(self.build_id), "modified", curr_time)

            # Write changes back to temp config file

            with open(self.temp_config_file, 'wb') as tcf:

                self.temp_config.write(tcf)

    def read_temp_config(self, option):

        """Read from temporary_config file"""

        # If build_id is None use the latest one

        if self.build_id is None:

            ids = self.temp_config.sections()

            if ids:

                self.build_id = int(ids[-1])

            else:

                self.logger.error("No sections in temporary config file")

                sys.exit(1)

            self.logger.debug("Will use \"%s\" as build id"

                              % _green(self.build_id))

        # Read specified option

        return self.temp_config.get(str(self.build_id), option)

    def setup_fabric(self):

        """Setup fabric environment"""

        self.logger.info("Setup fabric parameters..")

        fabric.env.user = self.read_temp_config('server_user')

        fabric.env.host_string = self.read_temp_config('server_ip')

        fabric.env.port = int(self.read_temp_config('server_port'))

        fabric.env.password = self.read_temp_config('server_passwd')

        fabric.env.connection_attempts = 10

        fabric.env.shell = "/bin/bash -c"

        fabric.env.disable_known_hosts = True

        fabric.env.output_prefix = None

    def _check_hash_sum(self, localfile, remotefile):

        """Check hash sums of two files"""

        self.logger.debug("Check hash sum for local file %s" % localfile)

        hash1 = os.popen("sha256sum %s" % localfile).read().split(' ')[0]

        self.logger.debug("Local file has sha256 hash %s" % hash1)

        self.logger.debug("Check hash sum for remote file %s" % remotefile)

        hash2 = _run("sha256sum %s" % remotefile, False)

        hash2 = hash2.split(' ')[0]

        self.logger.debug("Remote file has sha256 hash %s" % hash2)

        if hash1 != hash2:

            self.logger.error("Hashes differ.. aborting")

            sys.exit(1)

    @_check_fabric

    def clone_repo(self, local_repo=False):

        """Clone Synnefo repo from slave server"""

        self.logger.info("Configure repositories on remote server..")

        self.logger.debug("Install/Setup git")

        cmd = """

        apt-get install git --yes --force-yes

        git config --global user.name {0}

        git config --global user.email {1}

        """.format(self.config.get('Global', 'git_config_name'),

                   self.config.get('Global', 'git_config_mail'))

        _run(cmd, False)

        # Clone synnefo_repo

        synnefo_branch = self.clone_synnefo_repo(local_repo=local_repo)

        # Clone pithos-web-client

        self.clone_pithos_webclient_repo(synnefo_branch)

    @_check_fabric

    def clone_synnefo_repo(self, local_repo=False):

        """Clone Synnefo repo to remote server"""

        # Find synnefo_repo and synnefo_branch to use

        synnefo_repo = self.config.get('Global', 'synnefo_repo')

        synnefo_branch = self.config.get("Global", "synnefo_branch")

        if synnefo_branch == "":

            synnefo_branch = \

                subprocess.Popen(

                    ["git", "rev-parse", "--abbrev-ref", "HEAD"],

                    stdout=subprocess.PIPE).communicate()[0].strip()

            if synnefo_branch == "HEAD":

                synnefo_branch = \

                    subprocess.Popen(

                        ["git", "rev-parse", "--short", "HEAD"],

                        stdout=subprocess.PIPE).communicate()[0].strip()

        self.logger.debug("Will use branch \"%s\"" % _green(synnefo_branch))

        if local_repo or synnefo_repo == "":

            # Use local_repo

            self.logger.debug("Push local repo to server")

            # Firstly create the remote repo

            _run("git init synnefo", False)

            # Then push our local repo over ssh

            # We have to pass some arguments to ssh command

            # namely to disable host checking.

            (temp_ssh_file_handle, temp_ssh_file) = tempfile.mkstemp()

            os.close(temp_ssh_file_handle)

            # XXX: git push doesn't read the password

            cmd = """

            echo 'exec ssh -o "StrictHostKeyChecking no" \

                           -o "UserKnownHostsFile /dev/null" \

                           -q "$@"' > {4}