Synnefo

from synnefo.management import common, pprint

from snf_django.management.utils import parse_bool

                    help="Password for the new server"),

        make_option(

            '--wait',

            dest='wait',

            default="True",

            choices=["True", "False"],

            metavar="True|False",

            help="Wait for Ganeti job to complete."),

        server = servers.create(user_id, name, password, flavor, image,

                                use_backend=backend)

        pprint.pprint_server(server, stdout=self.stdout)

        wait = parse_bool(options["wait"])

        common.wait_server_task(server, wait, self.stdout)

# Copyright 2012-2013 GRNET S.A. All rights reserved.

from synnefo.management import pprint

        pprint.pprint_server(vm, display_mails=displayname, stdout=self.stdout)

        self.stdout.write("\n")

        pprint.pprint_server_nics(vm, stdout=self.stdout)

        self.stdout.write("\n")

        pprint.pprint_server_in_ganeti(vm, print_jobs=options["jobs"],

                                       stdout=self.stdout)

        self.stdout.write("\n")

from synnefo.management.common import get_image

        ("username", ucache.get_name(userid) if display_mails else None),

def pprint_server(server, display_mails=False, stdout=None, title=None):

    if stdout is None:

        stdout = sys.stdout

    if title is None:

        title = "State of Server %s in DB" % server.id

    ucache = UserCache(ASTAKOS_BASE_URL, ASTAKOS_TOKEN)

    userid = server.userid

    try:

        image = get_image(server.imageid, server.userid)['name']

    except:

        image = server.imageid

    server_dict = OrderedDict([

        ("id", server.id),

        ("name", server.name),

        ("userid", server.userid),

        ("username", ucache.get_name(userid) if display_mails else None),

        ("flavor_id", server.flavor_id),

        ("flavor_name", server.flavor.name),

        ("imageid", server.imageid),

        ("image_name", image),

        ("state", server.operstate),

        ("backend", server.backend),

        ("deleted", server.deleted),

        ("action", server.action),

        ("task", server.task),

        ("task_job_id", server.task_job_id),

        ("backendjobid", server.backendjobid),

        ("backendopcode", server.backendopcode),

        ("backendjobstatus", server.backendjobstatus),

        ("backend_time", server.backendtime),

        ])

    pprint_table(stdout, server_dict.items(), None, separator=" | ",

                 title=title)

def pprint_server_nics(server, stdout=None, title=None):

    if title is None:

        title = "NICs of Server %s" % server.id

    if stdout is None:

        stdout = sys.stdout

    nics = []

    for nic in server.nics.all():

        nics.append((nic.name, nic.index, nic.mac, nic.ipv4_address,

                     nic.ipv6_address, nic.network, nic.firewall_profile,

                     nic.state))

    headers = ["Name", "Index", "MAC", "IPv4 Address", "IPv6 Address",

               "Network", "Firewall", "State"]

    pprint_table(stdout, nics, headers, separator=" | ",

                 title=title)

def pprint_server_in_ganeti(server, print_jobs=False, stdout=None, title=None):

    if stdout is None:

        stdout = sys.stdout

    if title is None:

        title = "State of Server %s in Ganeti" % server.id

    client = server.get_client()

    try:

        server_info = client.GetInstance(server.backend_vm_id)

    except GanetiApiError as e:

        if e.code == 404:

            stdout.write("NIC seems attached to server %s, but"

                         " server does not exist in backend.\n"

                         % server)

            return

        raise e

    server.put_client(client)

    GANETI_INSTANCE_FIELDS = ('name', 'oper_state', 'admin_state', 'status',

                              'pnode', 'snode', 'network_port',

                              'disk_template', 'disk_usage',

                              'oper_ram', 'oper_vcpus', 'mtime')

    server_dict = OrderedDict([(k, server_info.get(k))

                              for k in GANETI_INSTANCE_FIELDS])

    pprint_table(stdout, server_dict.items(), None, separator=" | ",

                 title="NICs of Server %s in Ganeti" % server.id)

    stdout.write("\n")

    nics = nics_from_instance(server_info)

    nics_keys = ["ip", "mac", "name", "network"]

    nics_values = [[nic[key] for key in nics_keys] for nic in nics]

    pprint_table(stdout, nics_values, nics_keys, separator=" | ",

                 title=title)

    if not print_jobs:

        return

    client = server.get_client()

    jobs = client.GetJobs(bulk=True)

    server_jobs = filter(

        lambda x: server.backend_vm_id in (" ".join(x.get("summary"))), jobs)

    GANETI_JOB_FIELDS = ('id', 'status', 'summary', 'opresult', 'opstatus',

                         'oplog', 'start_ts', 'end_ts')

    for server_job in server_jobs:

        stdout.write("\n")

        values = [server_job.get(k) for k in GANETI_JOB_FIELDS]

        pprint_table(stdout, zip(GANETI_JOB_FIELDS, values), None,

                     separator=" | ",

                     title="Ganeti Job %s" % server_job["id"])

    server.put_client(client)