Source code for horizon.dashboards.nova.instances_and_volumes.volumes.tables

# Copyright 2012 Nebula, Inc.
#
#    Licensed under the Apache License, Version 2.0 (the "License"); you may
#    not use this file except in compliance with the License. You may obtain
#    a copy of the License at
#
#         http://www.apache.org/licenses/LICENSE-2.0
#
#    Unless required by applicable law or agreed to in writing, software
#    distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
#    WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
#    License for the specific language governing permissions and limitations
#    under the License.

import logging

from django.core.urlresolvers import reverse
from django.template.defaultfilters import title
from django.utils import safestring
from django.utils.translation import ugettext_lazy as _

from horizon import api
from horizon import tables


LOG = logging.getLogger(__name__)

URL_PREFIX = "horizon:nova:instances_and_volumes"
DELETABLE_STATES = ("available", "error")


class DeleteVolume(tables.DeleteAction):
    data_type_singular = _("Volume")
[docs] data_type_plural = _("Volumes") def delete(self, request, obj_id): api.volume_delete(request, obj_id)
[docs] def allowed(self, request, volume=None): if volume:
[docs] return volume.status in DELETABLE_STATES return True class CreateVolume(tables.LinkAction): name = "create"
[docs] verbose_name = _("Create Volume") url = "%s:volumes:create" % URL_PREFIX classes = ("ajax-modal", "btn-create") class EditAttachments(tables.LinkAction): name = "attachments"
[docs] verbose_name = _("Edit Attachments") url = "%s:volumes:attach" % URL_PREFIX classes = ("ajax-modal", "btn-edit") def allowed(self, request, volume=None): return volume.status in ("available", "in-use")
[docs] class CreateSnapshot(tables.LinkAction): name = "snapshots"
[docs] verbose_name = _("Create Snapshot") url = "%s:volumes:create_snapshot" % URL_PREFIX classes = ("ajax-modal", "btn-camera") def allowed(self, request, volume=None): return volume.status == "available"
[docs] class UpdateRow(tables.Row): ajax = True
[docs] def get_data(self, request, volume_id): volume = api.volume_get(request, volume_id)
[docs] return volume def get_size(volume): return _("%s GB") % volume.size
[docs] def get_attachment(volume): attachments = []
[docs] link = '<a href="%(url)s">Instance %(instance)s&nbsp;' \ '<small>(%(dev)s)</small></a>' # Filter out "empty" attachments which the client returns... for attachment in [att for att in volume.attachments if att]: url = reverse("%s:instances:detail" % URL_PREFIX, args=(attachment["server_id"],)) # TODO(jake): Make "instance" the instance name vals = {"url": url, "instance": attachment["server_id"], "dev": attachment["device"]} attachments.append(link % vals) return safestring.mark_safe(", ".join(attachments)) class VolumesTableBase(tables.DataTable): STATUS_CHOICES = (
[docs] ("in-use", True), ("available", True), ("creating", None), ("error", False), ) name = tables.Column("display_name", verbose_name=_("Name"), link="%s:volumes:detail" % URL_PREFIX) description = tables.Column("display_description", verbose_name=_("Description")) size = tables.Column(get_size, verbose_name=_("Size")) status = tables.Column("status", filters=(title,), verbose_name=_("Status"), status=True, status_choices=STATUS_CHOICES) def get_object_display(self, obj): return obj.display_name class VolumesTable(VolumesTableBase): name = tables.Column("display_name",
[docs] verbose_name=_("Name"), link="%s:volumes:detail" % URL_PREFIX) attachments = tables.Column(get_attachment, verbose_name=_("Attachments")) class Meta: name = "volumes" verbose_name = _("Volumes") status_columns = ["status"] row_class = UpdateRow table_actions = (CreateVolume, DeleteVolume,) row_actions = (EditAttachments, CreateSnapshot, DeleteVolume) class DetachVolume(tables.BatchAction): name = "detach"
[docs] action_present = _("Detach") action_past = _("Detached") data_type_singular = _("Volume") data_type_plural = _("Volumes") classes = ('btn-danger', 'btn-detach') def action(self, request, obj_id): instance_id = self.table.get_object_by_id(obj_id)['server_id']
[docs] api.volume_detach(request, instance_id, obj_id) def get_success_url(self, request): return reverse('%s:index' % URL_PREFIX)
[docs] class AttachmentsTable(tables.DataTable): instance = tables.Column("server_id", verbose_name=_("Instance"))
[docs] device = tables.Column("device") def get_object_id(self, obj): return obj['id'] def get_object_display(self, obj): vals = {"dev": obj['device'], "instance": obj['server_id']} return "Attachment %(dev)s on %(instance)s" % vals def get_object_by_id(self, obj_id): for obj in self.data: if self.get_object_id(obj) == obj_id: return obj raise ValueError('No match found for the id "%s".' % obj_id) class Meta: name = "attachments" table_actions = (DetachVolume,) row_actions = (DetachVolume,)