dashboard: make resources change an operation

circle/dashboard/static/dashboard/vm-details.js

@@ -11,13 +11,14 @@ $(function() {
   /* save resources */
   $('#vm-details-resources-save').click(function() {
     $('i.icon-save', this).removeClass("icon-save").addClass("icon-refresh icon-spin");
+    var vm = $(this).data("vm");
     $.ajax({
       type: 'POST',
-      url: location.href,
+      url: "/dashboard/vm/" + vm + "/op/resources_change/", 
       data: $('#vm-details-resources-form').serialize(),
       success: function(data, textStatus, xhr) {
-        addMessage(data['message'], 'success');
         $("#vm-details-resources-save i").removeClass('icon-refresh icon-spin').addClass("icon-save");
+        $('a[href="#activity"]').trigger("click");
       },
       error: function(xhr, textStatus, error) {
         $("#vm-details-resources-save i").removeClass('icon-refresh icon-spin').addClass("icon-save");
@@ -367,6 +368,12 @@ function checkNewActivity(only_status, runs) {
         $("[data-target=#_console]").attr("data-toggle", "_pill").attr("href", "#").parent("li").addClass("disabled");
       }
 
+      if(data['status'] == "STOPPED") {
+        $(".enabled-when-stopped").prop("disabled", false);
+      } else {
+        $(".enabled-when-stopped").prop("disabled", true);
+      }
+
       if(runs > 0 && decideActivityRefresh()) {
         setTimeout(
           function() {checkNewActivity(only_status, runs + 1)}, 

circle/dashboard/templates/dashboard/vm-detail/resources.html

@@ -35,7 +35,11 @@
 
 <p class="row">
   <div class="col-sm-12">
-    <button type="submit" class="btn btn-success btn-sm" id="vm-details-resources-save"><i class="icon-save"></i> {% trans "Save resources" %}</button>
+    <button type="submit" class="btn btn-success btn-sm enabled-when-stopped" id="vm-details-resources-save"
+      data-vm="{{ instance.pk }}"
+      {% if not op.resources_change %}disabled{% endif %}>
+      <i class="icon-save"></i> {% trans "Save resources" %}
+    </button>
   </div>
 </p>
 </form>

circle/dashboard/views.py

@@ -290,10 +290,6 @@ class VmDetailView(CheckedDetailView):
         return context
 
     def post(self, request, *args, **kwargs):
-        if (request.POST.get('ram-size') and request.POST.get('cpu-count')
-                and request.POST.get('cpu-priority')):
-            return self.__set_resources(request)
-
         options = {
             'change_password': self.__change_password,
             'new_name': self.__set_name,
@@ -321,33 +317,6 @@ class VmDetailView(CheckedDetailView):
             return redirect(reverse_lazy("dashboard.views.detail",
                                          kwargs={'pk': self.object.pk}))
 
-    def __set_resources(self, request):
-        self.object = self.get_object()
-        if not self.object.has_level(request.user, 'owner'):
-            raise PermissionDenied()
-        if not request.user.has_perm('vm.change_resources'):
-            raise PermissionDenied()
-
-        resources = {
-            'num_cores': request.POST.get('cpu-count'),
-            'ram_size': request.POST.get('ram-size'),
-            'max_ram_size': request.POST.get('ram-size'),  # TODO: max_ram
-            'priority': request.POST.get('cpu-priority')
-        }
-        Instance.objects.filter(pk=self.object.pk).update(**resources)
-
-        success_message = _("Resources successfully updated.")
-        if request.is_ajax():
-            response = {'message': success_message}
-            return HttpResponse(
-                json.dumps(response),
-                content_type="application/json"
-            )
-        else:
-            messages.success(request, success_message)
-            return redirect(reverse_lazy("dashboard.views.detail",
-                                         kwargs={'pk': self.object.pk}))
-
     def __set_name(self, request):
         self.object = self.get_object()
         if not self.object.has_level(request.user, 'owner'):
@@ -577,8 +546,9 @@ class VmOperationView(OperationView):
     model = Instance
     context_object_name = 'instance'  # much simpler to mock object
 
-    def post(self, request, *args, **kwargs):
-        resp = super(VmOperationView, self).post(request, *args, **kwargs)
+    def post(self, request, extra=None, *args, **kwargs):
+        resp = super(VmOperationView, self).post(request, extra, *args,
+                                                 **kwargs)
         if request.is_ajax():
             store = messages.get_messages(request)
             store.used = True
@@ -668,6 +638,29 @@ class VmSaveView(FormOperationMixin, VmOperationView):
     icon = 'save'
     form_class = VmSaveForm
 
+
+class VmResourcesChangeView(VmOperationView):
+    op = 'resources_change'
+    icon = "save"
+    show_in_toolbar = False
+
+    def post(self, request, extra=None, *args, **kwargs):
+        if extra is None:
+            extra = {}
+
+        resources = {
+            'num_cores': "cpu-count",
+            'priority': "cpu-priority",
+            'ram_size': "ram-size",
+            "max_ram_size": "ram-size",  # TODO
+        }
+        for k, v in resources.iteritems():
+            extra[k] = request.POST.get(v)
+
+        return super(VmResourcesChangeView, self).post(request, extra,
+                                                       *args, **kwargs)
+
+
 vm_ops = {
     'reset': VmOperationView.factory(op='reset', icon='bolt'),
     'deploy': VmOperationView.factory(op='deploy', icon='play'),
@@ -681,6 +674,7 @@ vm_ops = {
     'wake_up': VmOperationView.factory(op='wake_up', icon='sun'),
     'create_disk': VmCreateDiskView,
     'download_disk': VmDownloadDiskView,
+    'resources_change': VmResourcesChangeView,
 }
 
 

circle/vm/operations.py

@@ -600,3 +600,31 @@ class ScreenshotOperation(InstanceOperation):
 
 
 register_operation(ScreenshotOperation)
+
+
+class ResourcesOperation(InstanceOperation):
+    activity_code_suffix = 'Resources change'
+    id = 'resources_change'
+    name = _("resources change")
+    description = _("Change resources")
+    acl_level = "owner"
+    concurrency_check = False
+
+    def check_precond(self):
+        super(ResourcesOperation, self).check_precond()
+        if self.instance.status in ['RUNNING']:
+            raise self.instance.WrongStateError(self.instance)
+
+    def _operation(self, user, num_cores, ram_size, max_ram_size, priority):
+        if not user.has_perm('vm.change_resources'):
+            raise PermissionDenied()
+
+        self.instance.num_cores = num_cores
+        self.instance.ram_size = ram_size
+        self.instance.max_ram_size = max_ram_size
+        self.instance.priority = priority
+
+        self.instance.save()
+
+
+register_operation(ResourcesOperation)