Synnefo

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

#

# Redistribution and use in source and binary forms, with or without

# modification, are permitted provided that the following conditions

# are met:

#

#   1. Redistributions of source code must retain the above copyright

#      notice, this list of conditions and the following disclaimer.

#

#  2. Redistributions in binary form must reproduce the above copyright

#     notice, this list of conditions and the following disclaimer in the

#     documentation and/or other materials provided with the distribution.

#

# THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND

# ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE

# IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE

# ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE

# FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL

# DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS

# OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)

# HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT

# LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY

# OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF

# SUCH DAMAGE.

#

# The views and conclusions contained in the software and documentation are

# those of the authors and should not be interpreted as representing official

# policies, either expressed or implied, of GRNET S.A.

#

from optparse import make_option

from django.core.management.base import BaseCommand, CommandError

from synnefo.db.models import Backend, Network, BackendNetwork

from django.db.utils import IntegrityError

from synnefo.logic.backend import (get_physical_resources,

                                   update_resources,

                                   create_client,

                                   create_network_synced)

from synnefo.util.rapi import GanetiApiError

class Command(BaseCommand):

    can_import_settings = True

    help = 'Create a new backend.'

    output_transaction = True  # The management command runs inside

                               # an SQL transaction

    option_list = BaseCommand.option_list + (

        make_option('--clustername', dest='clustername'),

        make_option('--port', dest='port', default=5080),

        make_option('--user', dest='username'),

        make_option('--pass', dest='password'),

        make_option('--drained', action='store_true',

            dest='drained', default=False,

            help="Set as drained to exclude from allocations"),

        make_option('--no-check', action='store_false',

            dest='check', default=True,

            help="Do not perform credentials check and resources update"),

        make_option('--no-init', action='store_false',

            dest='init', default=True,

            help="Do not perform initialization of the Backend Model")

        )

    def handle(self, **options):

        clustername = options['clustername']

        port = options['port']

        username = options['username']

        password = options['password']

        drained = options['drained']

        if not (clustername and username and password):

            raise CommandError("Clustername, user and pass must be supplied")

        # Ensure correctness of credentials

        if options['check']:

            self.stdout.write('Checking connectivity and credentials.\n')

            try:

                client = create_client(clustername, port, username, password)

                # This command will raise an exception if there is no

                # write-access

                client.ModifyCluster()

            except GanetiApiError as e:

                self.stdout.write('Check failed:\n%s\n' % e)

                return

            else:

                self.stdout.write('Check passed.\n')

        # Create the new backend in database

        try:

            backend = Backend.objects.create(clustername=clustername,

                                             port=port,

                                             username=username,

                                             password=password,

                                             drained=drained)

        except IntegrityError as e:

            raise CommandError("Cannot create backend: %s\n" % e)

        self.stdout.write('\nSuccessfully created backend with id %d\n' %

                          backend.id)

        if not options['check']:

            return

        self.stdout.write('\rRetrieving backend resources:\n')

        resources = get_physical_resources(backend)

        attr = ['mfree', 'mtotal', 'dfree', 'dtotal', 'pinst_cnt', 'ctotal']

        self.stdout.write('----------------------------\n')

        for a in attr:

            self.stdout.write(a.ljust(12) + ' : ' + str(resources[a]) + '\n')

        update_resources(backend, resources)

        if not options['init']:

            return

        networks = Network.objects.filter(deleted=False)

        self.stdout.write('\nCreating the follow networks:\n')

        fields = ('Name', 'Subnet', 'Gateway', 'Mac Prefix', 'Public')

        columns = (20, 16, 16, 16, 10)

        line = ' '.join(f.ljust(c) for f, c in zip(fields, columns))

        sep = '-' * len(line)

        self.stdout.write(sep + '\n')

        self.stdout.write(line + '\n')

        self.stdout.write(sep + '\n')

        for net in networks:

            fields = (net.backend_id, str(net.subnet), str(net.gateway),

                      str(net.mac_prefix), str(net.public))

            line = ' '.join(f.ljust(c) for f, c in zip(fields, columns))

            self.stdout.write(line + '\n')

        self.stdout.write(sep + '\n\n')

        for net in networks:

            BackendNetwork.objects.create(network=net, backend=backend)

            result = create_network_synced(net, backend)

            if result[0] != "success":

                self.stdout.write('\nError Creating Network %s: %s\n' %\

                                  (net.backend_id, result[1]))

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

#

# Redistribution and use in source and binary forms, with or

# without modification, are permitted provided that the following

# conditions are met:

#

#   1. Redistributions of source code must retain the above

#      copyright notice, this list of conditions and the following

#      disclaimer.

#

#   2. Redistributions in binary form must reproduce the above

#      copyright notice, this list of conditions and the following

#      disclaimer in the documentation and/or other materials

#      provided with the distribution.

#

# THIS SOFTWARE IS PROVIDED BY GRNET S.A. ``AS IS'' AND ANY EXPRESS

# OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED

# WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR

# PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL GRNET S.A OR

# CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,

# SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT

# LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF

# USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED

# AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT

# LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN

# ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE

# POSSIBILITY OF SUCH DAMAGE.

#

# The views and conclusions contained in the software and

# documentation are those of the authors and should not be

# interpreted as representing official policies, either expressed

# or implied, of GRNET S.A.

from optparse import make_option

from django.core.management.base import BaseCommand, CommandError

from synnefo.db.models import Backend

class Command(BaseCommand):

    help = "List backends"

    option_list = BaseCommand.option_list + (

        make_option('-c',

            action='store_true',

            dest='csv',

            default=False,

            help="Use pipes to separate values"),

        )

    def handle(self, *args, **options):

        if args:

            raise CommandError("Command doesn't accept any arguments")

        backends = Backend.objects.order_by('id')

        labels = ('id', 'clustername', 'port', 'username', "vm's", 'drained',

                  'offline')

        columns = (3, 50, 5, 10, 4, 6, 6)

        if not options['csv']:

            line = ' '.join(l.rjust(w) for l, w in zip(labels, columns))

            sep = '-' * len(line)

            self.stdout.write(sep + '\n')

            self.stdout.write(line + '\n')

            self.stdout.write(sep + '\n')

        for backend in backends:

            id = str(backend.id)

            vms = str(backend.virtual_machines.filter(deleted=False).count())

            fields = (id, backend.clustername, str(backend.port),

                      backend.username, vms, str(backend.drained),

                      str(backend.offline))

            if options['csv']:

                line = '|'.join(fields)

            else:

                line = ' '.join(f.rjust(w) for f, w in zip(fields, columns))

            self.stdout.write(line.encode('utf8') + '\n')

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

#

# Redistribution and use in source and binary forms, with or

# without modification, are permitted provided that the following

# conditions are met:

#

#   1. Redistributions of source code must retain the above

#      copyright notice, this list of conditions and the following

#      disclaimer.

#

#   2. Redistributions in binary form must reproduce the above

#      copyright notice, this list of conditions and the following

#      disclaimer in the documentation and/or other materials

#      provided with the distribution.

#

# THIS SOFTWARE IS PROVIDED BY GRNET S.A. ``AS IS'' AND ANY EXPRESS

# OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED

# WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR

# PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL GRNET S.A OR

# CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,

# SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT

# LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF

# USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED

# AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT

# LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN

# ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE

# POSSIBILITY OF SUCH DAMAGE.

#

# The views and conclusions contained in the software and

# documentation are those of the authors and should not be

# interpreted as representing official policies, either expressed

# or implied, of GRNET S.A.

from optparse import make_option

from django.core.management.base import BaseCommand, CommandError

from synnefo.db.models import Backend

class Command(BaseCommand):

    args = "<backend ID>"

    help = "Modify a backend"

    option_list = BaseCommand.option_list + (

        make_option('--clustername',

            dest='clustername',

            help="Set backend's clustername"),

        make_option('--port',

            dest='port',

            help="Set backend's port"),

        make_option('--username',

            dest='username',

            help="Set backend'username"),

        make_option('--password',

            dest='password',

            help="Set backend's password"),

        make_option('--drained',

            dest='drained',

            action='store_true',

            default=False,

            help="Set the backend as drained to exclude from allocation "\

                 "operations"),

        make_option('--no-drained',

            dest='drained',

            action='store_false'),

        make_option('--offline',

            dest='offline',

            action='store_true',

            default=False,

            help="Set the backend as offline to not communicate in order "\

                 "to avoid delays"),

        make_option('--no-offline',

            dest='offline',

            action='store_false')

        )

    def handle(self, *args, **options):

        if len(args) != 1:

            raise CommandError("Please provide a backend ID")

        try:

            backend_id = int(args[0])

            backend = Backend.objects.get(id=backend_id)

        except ValueError:

            raise CommandError("Invalid backend ID")

        except Backend.DoesNotExist:

            raise CommandError("Backend not found in DB")

        # Ensure fields correspondence with options and Backend model

        fields = ('clustername', 'port', 'username', 'password', 'drained',

                  'offline')

        for field in fields:

            value = options.get(field)

            if value is not None:

                backend.__setattr__(field, value)

        backend.save()

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

#

# Redistribution and use in source and binary forms, with or without

# modification, are permitted provided that the following conditions

# are met:

#

#   1. Redistributions of source code must retain the above copyright

#      notice, this list of conditions and the following disclaimer.

#

#  2. Redistributions in binary form must reproduce the above copyright

#     notice, this list of conditions and the following disclaimer in the

#     documentation and/or other materials provided with the distribution.

#

# THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND

# ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE

# IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE

# ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE

# FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL

# DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS

# OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)

# HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT

# LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY

# OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF

# SUCH DAMAGE.

#

# The views and conclusions contained in the software and documentation are

# those of the authors and should not be interpreted as representing official

# policies, either expressed or implied, of GRNET S.A.

#

from optparse import make_option

from django.core.management.base import BaseCommand, CommandError

from synnefo import settings

import datetime

from synnefo.db.models import Backend

from synnefo.logic.backend import update_resources

class Command(BaseCommand):

    can_import_settings = True

    help = "Update backend statistics, which are used for instance allocation."

    output_transaction = True  # The management command runs inside

                               # an SQL transaction

    option_list = BaseCommand.option_list + (

        make_option('--backend_id', dest='backend_id',

                   help="Update statistics of only this backend"),

        make_option('--older_than', dest='older_than', metavar="MINUTES",

                   help="Update only backends that have not been updated for\

                   MINUTES. Set to 0 to force update.")

        )

    def handle(self, **options):

        if options['backend_id']:

            try:

                backend_id = int(options['backend_id'])

                backends = [Backend.objects.get(id=backend_id)]

            except ValueError:

                raise CommandError("Wrong backend ID")

            except Backend.DoesNotExist:

                raise CommandError("Backend not found in DB")

        else:

            # XXX:filter drained ?

            backends = Backend.objects.all()

        now = datetime.datetime.now()

        if options['older_than'] is not None:

            minutes = int(options['older_than'])

        else:

            minutes = settings.BACKEND_REFRESH_MIN

        delta = datetime.timedelta(minutes=minutes)

        for b in backends:

            if now > b.updated + delta:

                update_resources(b)

                print 'Successfully updated backend with id: %d' % b.id

            else:

                print 'Backend %d does not need update' % b.id

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

#

# Redistribution and use in source and binary forms, with or

# without modification, are permitted provided that the following

# conditions are met:

#

#   1. Redistributions of source code must retain the above

#      copyright notice, this list of conditions and the following

#      disclaimer.

#

#   2. Redistributions in binary form must reproduce the above

#      copyright notice, this list of conditions and the following

#      disclaimer in the documentation and/or other materials

#      provided with the distribution.

#

# THIS SOFTWARE IS PROVIDED BY GRNET S.A. ``AS IS'' AND ANY EXPRESS

# OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED

# WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR

# PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL GRNET S.A OR

# CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,

# SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT

# LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF

# USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED

# AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT

# LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN

# ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE

# POSSIBILITY OF SUCH DAMAGE.

#

# The views and conclusions contained in the software and

# documentation are those of the authors and should not be

# interpreted as representing official policies, either expressed

# or implied, of GRNET S.A.

import json

from django.core.management.base import BaseCommand, CommandError

from synnefo.db.models import Backend, Network, BackendNetwork

from synnefo.util.rapi import GanetiApiError

class Command(BaseCommand):

    help = "Inspect a network on DB and Ganeti."

    def handle(self, *args, **options):

        if len(args) != 1:

            raise CommandError("Please provide a network ID.")

        try:

            net_id = int(args[0])

        except ValueError:

            raise CommandError("Invalid network ID.")

        try:

            net = Network.objects.get(id=net_id)

        except Network.DoesNotExist:

            raise CommandError("Network not found in DB.")

        sep = '-' * 80 + '\n'

        labels = ('name', 'backend-name', 'state', 'owner', 'subnet', 'gateway',

                  'max_prefix', 'link', 'public', 'dhcp', 'type', 'deleted',

                  'action')

        fields = (net.name, net.backend_id, net.state, str(net.userid),

                  str(net.subnet), str(net.gateway), str(net.mac_prefix),

                  str(net.link), str(net.public),  str(net.dhcp),

                  str(net.type), str(net.deleted), str(net.action))

        self.stdout.write(sep)

        self.stdout.write('State of Network in DB\n')

        self.stdout.write(sep)

        for l, f in zip(labels, fields):

            self.stdout.write(l.ljust(20) + ': ' + f.ljust(20) + '\n')

        labels = ('Backend', 'State', 'Deleted', 'JobID', 'OpCode',

                  'JobStatus')

        for back_net in BackendNetwork.objects.filter(network=net):

            self.stdout.write('\n')

            fields = (back_net.backend.clustername, back_net.operstate,

                     str(back_net.deleted),  str(back_net.backendjobid),

                     str(back_net.backendopcode),

                     str(back_net.backendjobstatus))

            for l, f in zip(labels, fields):

                self.stdout.write(l.ljust(20) + ': ' + f.ljust(20) + '\n')

        self.stdout.write('\n')

        self.stdout.write(sep)

        self.stdout.write('State of Network in Ganeti\n')

        self.stdout.write(sep)

        for backend in Backend.objects.exclude(offline=True):

            client = backend.client

            try:

                g_net = client.GetNetwork(net.backend_id)

                self.stdout.write("Backend: %s\n" % backend.clustername)

                print json.dumps(g_net, indent=2)

                self.stdout.write(sep)

            except GanetiApiError as e:

                if e.code == 404:

                    self.stdout.write('Network does not exist in backend %s\n' %

                                      backend.clustername)

                else:

                    raise e

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

#

# Redistribution and use in source and binary forms, with or without

# modification, are permitted provided that the following conditions

# are met:

#

#   1. Redistributions of source code must retain the above copyright

#      notice, this list of conditions and the following disclaimer.

#

#  2. Redistributions in binary form must reproduce the above copyright

#     notice, this list of conditions and the following disclaimer in the

#     documentation and/or other materials provided with the distribution.

#

# THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND

# ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE

# IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE

# ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE

# FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL

# DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS

# OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)

# HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT

# LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY

# OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF

# SUCH DAMAGE.

#

# The views and conclusions contained in the software and documentation are

# those of the authors and should not be interpreted as representing official

# policies, either expressed or implied, of GRNET S.A.

#

"""Reconciliation management command

Management command to reconcile the contents of the Synnefo DB with

the state of the Ganeti backend. See docstring on top of

logic/reconciliation.py for a description of reconciliation rules.

"""

import datetime

from optparse import make_option

from django.conf import settings

from django.core.management.base import BaseCommand, CommandError

from synnefo.db.models import Backend, Network, BackendNetwork

from synnefo.logic import reconciliation, backend, utils

class Command(BaseCommand):

    can_import_settings = True

    help = 'Reconcile contents of Synnefo DB with state of Ganeti backend'

    output_transaction = True  # The management command runs inside

                               # an SQL transaction

    option_list = BaseCommand.option_list + (

        make_option('--fix-all', action='store_true',

                    dest='fix', default=False,

                    help='Fix all issues.'),

        )

    def handle(self, **options):

        self.verbosity = int(options['verbosity'])

        fix = options['fix']

        reconcile_networks(self.stdout, fix)

def reconcile_networks(out, fix):

    # Get models from DB

    backends = Backend.objects.exclude(offline=True)

    networks = Network.objects.filter(deleted=False)

    # Get info from all ganeti backends

    ganeti_networks = {}

    ganeti_hanging_networks = {}

    for b in backends:

        g_nets = reconciliation.get_networks_from_ganeti(b)

        ganeti_networks[b] = g_nets

        g_hanging_nets = reconciliation.hanging_networks(b, g_nets)

        ganeti_hanging_networks[b] = g_hanging_nets

    # Perform reconciliation for each network

    for network in networks:

        net_id = network.id

        destroying = network.action == 'DESTROY'

        # Perform reconcilliation for each backend

        for b in backends:

            info = (net_id, b.clustername)

            back_network = None

            try:

                # Get the model describing the network to this backend

                back_network = BackendNetwork.objects.get(network=network,

                                                          backend=b)

            except BackendNetwork.DoesNotExist:

                out.write('D: No DB entry for network %d in backend %s\n' % info)

                if fix:

                    out.write('F: Created entry in DB\n')

                    back_network = \

                        BackendNetwork.objects.create(network=network,

                                                      backend=b)

            try:

                # Get the info from backend

                ganeti_networks[b][net_id]

            except KeyError:

                # Stale network does not exist in backend

                if destroying:

                    out.write('D: Stale network %d in backend %s\n' % info)

                    if fix:

                        out.write("F: Issued OP_NETWORK_REMOVE'\n")

                        etime = datetime.datetime.now()

                        backend.process_network_status(back_network, etime,

                                            0, 'OP_NETWORK_REMOVE', 'success',

                                            'Reconciliation simulated event.')

                    continue

                else:

                    # Pending network

                    out.write('D: Pending network %d in backend %s\n' % info)

                    if fix:

                        out.write('F: Creating network in backend.\n')

                        backend.create_network(network, [b])

                        # Skip rest reconciliation as the network is just

                        # being created

                    continue

            try:

                hanging_groups = ganeti_hanging_networks[b][net_id]

            except KeyError:

                # Network is connected to all nodegroups

                hanging_groups = []

            if hanging_groups and not destroying:

                # Hanging network = not connected to all nodegroups of backend

                out.write('D: Network %d in backend %s is not connected to '

                          'the following groups:\n' % info)

                out.write('-  ' + '\n-  '.join(hanging_groups) + '\n')

                if fix:

                    for group in hanging_groups:

                        out.write('F: Connecting network %d to nodegroup %s\n'

                                  % (net_id, group))

                        backend.connect_network_group(b, network, group)

            elif back_network and back_network.operstate != 'ACTIVE':

                # Network is active

                out.write('D: Unsynced network %d in backend %s\n' % info)

                if fix:

                    out.write("F: Issued OP_NETWORK_CONNECT\n")

                    etime = datetime.datetime.now()

                    backend.process_network_status(back_network, etime,

                                        0, 'OP_NETWORK_CONNECT', 'success',

                                        'Reconciliation simulated event.')

    # Detect Orphan Networks in Ganeti

    db_network_ids = set([net.id for net in networks])

    for back_end, ganeti_networks in ganeti_networks.items():

        ganeti_network_ids = set(ganeti_networks.keys())

        orphans = ganeti_network_ids - db_network_ids

        if len(orphans) > 0:

            out.write('D: Orphan Networks in backend %s:\n' % back_end.clustername)

            out.write('-  ' + '\n-  '.join([str(o) for o in orphans]) + '\n')

            client = back_end.client

            if fix:

                #XXX:Move this to backend

                for id in orphans:

                    out.write('Disconnecting and deleting network %d\n' % id)

                    network = utils.id_to_network_name(id)

                    for group in client.GetGroups():

                        client.DisconnectNetwork(network, group)

                        client.DeleteNetwork(network)

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

#

# Redistribution and use in source and binary forms, with or

# without modification, are permitted provided that the following

# conditions are met:

#

#   1. Redistributions of source code must retain the above

#      copyright notice, this list of conditions and the following

#      disclaimer.

#

#   2. Redistributions in binary form must reproduce the above

#      copyright notice, this list of conditions and the following

#      disclaimer in the documentation and/or other materials

#      provided with the distribution.

#

# THIS SOFTWARE IS PROVIDED BY GRNET S.A. ``AS IS'' AND ANY EXPRESS

# OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED

# WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR

# PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL GRNET S.A OR

# CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,

# SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT

# LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF

# USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED

# AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT

# LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN

# ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE

# POSSIBILITY OF SUCH DAMAGE.

#

# The views and conclusions contained in the software and

# documentation are those of the authors and should not be

# interpreted as representing official policies, either expressed

# or implied, of GRNET S.A.

from datetime import datetime

from optparse import make_option

from django.core.management.base import BaseCommand, CommandError

from synnefo.api.util import get_image

from synnefo.lib.utils import merge_time

from synnefo.db.models import VirtualMachine

from synnefo.util.rapi import GanetiApiError

# Fields to print from a gnt-instance info

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

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

                          'disk_usage', 'oper_ram', 'oper_vcpus', 'mtime',

                          'nic.ips', 'nic.macs', 'nic.networks', 'nic.modes')

# Fields to print from a gnt-job info

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

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

class Command(BaseCommand):

    help = "Inspect a server on DB and Ganeti"

    option_list = BaseCommand.option_list + (

        make_option('--jobs', action='store_true',

                    dest='jobs', default='False',

                    help="Show non-archived jobs concerning server."

            ),

    )

    def handle(self, *args, **options):

        if len(args) != 1:

            raise CommandError("Please provide a server ID")

        try:

            vm_id = int(args[0])

        except ValueError:

            raise CommandError("Invalid server ID")

        try:

            vm = VirtualMachine.objects.get(id=vm_id)

        except VirtualMachine.DoesNotExist:

            raise CommandError("Server not found in DB")

        try:

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

        except:

            image = vm.imageid