Statistics
| Branch: | Tag: | Revision:

root / snf-cyclades-app / synnefo / api / management / commands / server-modify.py @ 60a71437

History | View | Annotate | Download (4.8 kB)

1
# Copyright 2012 GRNET S.A. All rights reserved.
2
#
3
# Redistribution and use in source and binary forms, with or
4
# without modification, are permitted provided that the following
5
# conditions are met:
6
#
7
#   1. Redistributions of source code must retain the above
8
#      copyright notice, this list of conditions and the following
9
#      disclaimer.
10
#
11
#   2. Redistributions in binary form must reproduce the above
12
#      copyright notice, this list of conditions and the following
13
#      disclaimer in the documentation and/or other materials
14
#      provided with the distribution.
15
#
16
# THIS SOFTWARE IS PROVIDED BY GRNET S.A. ``AS IS'' AND ANY EXPRESS
17
# OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
18
# WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
19
# PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL GRNET S.A OR
20
# CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
21
# SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
22
# LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF
23
# USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED
24
# AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
25
# LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN
26
# ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
27
# POSSIBILITY OF SUCH DAMAGE.
28
#
29
# The views and conclusions contained in the software and
30
# documentation are those of the authors and should not be
31
# interpreted as representing official policies, either expressed
32
# or implied, of GRNET S.A.
33

    
34
from optparse import make_option
35

    
36
from django.db import transaction
37
from django.core.management.base import BaseCommand, CommandError
38
from synnefo.management.common import get_vm, get_flavor, convert_api_faults
39
from synnefo.webproject.management.utils import parse_bool
40
from synnefo.logic import servers, backend as backend_mod
41

    
42

    
43
class Command(BaseCommand):
44
    args = "<server ID>"
45
    help = "Modify a server."
46

    
47
    option_list = BaseCommand.option_list + (
48
        make_option(
49
            '--name',
50
            dest='name',
51
            metavar='NAME',
52
            help="Rename server"),
53
        make_option(
54
            '--owner',
55
            dest='owner',
56
            metavar='USER_UUID',
57
            help="Change ownership of server. Value must be a user UUID"),
58
        make_option(
59
            "--suspended",
60
            dest="suspended",
61
            default=None,
62
            choices=["True", "False"],
63
            metavar="True|False",
64
            help="Mark a server as suspended/non-suspended."),
65
        make_option(
66
            "--flavor",
67
            dest="flavor",
68
            metavar="FLAVOR_ID",
69
            help="Resize a server by modifying its flavor. The new flavor"
70
                 " must have the same disk size and disk template."),
71
    )
72

    
73
    @transaction.commit_on_success
74
    @convert_api_faults
75
    def handle(self, *args, **options):
76
        if len(args) != 1:
77
            raise CommandError("Please provide a server ID")
78

    
79
        server = get_vm(args[0])
80

    
81
        new_name = options.get("name", None)
82
        if new_name is not None:
83
            old_name = server.name
84
            server = servers.rename(server, new_name)
85
            self.stdout.write("Renamed server '%s' from '%s' to '%s'\n" %
86
                              (server, old_name, new_name))
87

    
88
        suspended = options.get("suspended", None)
89
        if suspended is not None:
90
            suspended = parse_bool(suspended)
91
            server.suspended = suspended
92
            server.save()
93
            self.stdout.write("Set server '%s' as suspended=%s\n" %
94
                              (server, suspended))
95

    
96
        new_owner = options.get('owner')
97
        if new_owner is not None:
98
            if "@" in new_owner:
99
                raise CommandError("Invalid owner UUID.")
100
            old_owner = server.userid
101
            server.userid = new_owner
102
            server.save()
103
            msg = "Changed the owner of server '%s' from '%s' to '%s'.\n"
104
            self.stdout.write(msg % (server, old_owner, new_owner))
105

    
106
        new_flavor_id = options.get("flavor")
107
        if new_flavor_id is not None:
108
            new_flavor = get_flavor(new_flavor_id)
109
            old_flavor = server.flavor
110
            msg = "Resizing server '%s' from flavor '%s' to '%s'.\n"
111
            self.stdout.write(msg % (server, old_flavor, new_flavor))
112
            server = servers.resize(server, new_flavor)
113
            jobID = server.task_job_id
114
            msg = "Issued job '%s'. Waiting to complete...\n"
115
            self.stdout.write(msg % jobID)
116
            client = server.get_client()
117
            status, error = backend_mod.wait_for_job(client, jobID)
118
            if status == "success":
119
                self.stdout.write("Job finished successfully.\n")
120
            else:
121
                self.stdout.write("Job failed! Error: %s\n" % error)