# 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. from django.template.defaultfilters import title # noqa from django.urls import NoReverseMatch # noqa from django.urls import reverse from django.utils.translation import string_concat, ugettext_lazy # noqa from django.utils.translation import pgettext_lazy from django.utils.translation import ugettext_lazy as _ from django.utils.translation import ungettext_lazy from horizon import exceptions from horizon import messages from horizon import tables from openstack_dashboard.usage import quotas from manila_ui.api import manila from manila_ui.dashboards.project.share_snapshots import tables as ss_tables from manila_ui.dashboards import utils from manila_ui import features DELETABLE_STATES = ( "AVAILABLE", "ERROR", "MANAGE_ERROR", ) class DeleteShare(tables.DeleteAction): policy_rules = (("share", "share:delete"),) @staticmethod def action_present(count): return ungettext_lazy( u"Delete Share", u"Delete Shares", count ) @staticmethod def action_past(count): return ungettext_lazy( u"Deleted Share", u"Deleted Shares", count ) def get_policy_target(self, request, datum=None): project_id = None if datum: project_id = getattr(datum, "os-share-tenant-attr:tenant_id", None) return {"project_id": project_id} def delete(self, request, obj_id): share = manila.share_get(request, obj_id) try: manila.share_delete( request, share.id, share_group_id=share.share_group_id) except Exception: msg = _('Unable to delete share "%s". ') % obj_id messages.error(request, msg) def allowed(self, request, share=None): if share: # Row button return (share.status.upper() in DELETABLE_STATES and not getattr(share, 'has_snapshot', False)) # Table button. Always return 'True'. return True class CreateShare(tables.LinkAction): name = "create" verbose_name = _("Create Share") url = "horizon:project:shares:create" classes = ("ajax-modal", "btn-create") icon = "plus" policy_rules = (("share", "share:create"),) def allowed(self, request, share=None): usages = quotas.tenant_quota_usages(request) if usages['shares']['available'] <= 0: if "disabled" not in self.classes: self.classes = [c for c in self.classes] + ['disabled'] self.verbose_name = string_concat(self.verbose_name, ' ', _("(Quota exceeded)")) else: self.verbose_name = _("Create Share") classes = [c for c in self.classes if c != "disabled"] self.classes = classes return True class EditShare(tables.LinkAction): name = "edit" verbose_name = _("Edit Share") url = "horizon:project:shares:update" classes = ("ajax-modal", "btn-create") policy_rules = (("share", "share:update"),) def get_policy_target(self, request, datum=None): project_id = None if datum: project_id = getattr(datum, "os-share-tenant-attr:tenant_id", None) return {"project_id": project_id} def allowed(self, request, share=None): return share.status in ("available", "in-use") class EditShareMetadata(tables.LinkAction): name = "update_metadata" verbose_name = _("Edit Share Metadata") url = "horizon:project:shares:update_metadata" classes = ("ajax-modal", "btn-create") policy_rules = (("share", "share:update_share_metadata"),) def get_policy_target(self, request, datum=None): project_id = None if datum: project_id = getattr(datum, "os-share-tenant-attr:tenant_id", None) return {"project_id": project_id} def allowed(self, request, share=None): return share.status in ("available", "in-use") class ExtendShare(tables.LinkAction): name = "extend_share" verbose_name = _("Extend Share") url = "horizon:project:shares:extend" classes = ("ajax-modal", "btn-create") policy_rules = (("share", "share:extend"),) def get_policy_target(self, request, datum=None): project_id = None if datum: project_id = getattr(datum, "os-share-tenant-attr:tenant_id", None) return {"project_id": project_id} def allowed(self, request, share=None): return share.status.lower() in ("available",) class RevertShare(tables.LinkAction): name = "revert_share" verbose_name = _("Revert Share") url = "horizon:project:shares:revert" classes = ("ajax-modal", "btn-create") policy_rules = (("share", "share:revert"),) def get_policy_target(self, request, datum=None): project_id = None if datum: project_id = getattr(datum, "os-share-tenant-attr:tenant_id", None) return {"project_id": project_id} def allowed(self, request, share=None): return ( getattr(share, 'revert_to_snapshot_support', False) and share.status.lower() == "available" ) class UpdateRow(tables.Row): ajax = True def get_data(self, request, share_id): share = manila.share_get(request, share_id) if not share.name: share.name = share_id if share.share_network_id: share_net = manila.share_network_get(request, share.share_network_id) share.share_network = share_net.name or share_net.id else: share.share_network = None share.metadata = utils.metadata_to_str(share.metadata) return share def get_size(share): return _("%sGiB") % share.size class SharesTableBase(tables.DataTable): STATUS_CHOICES = ( ("available", True), ("AVAILABLE", True), ("creating", None), ("CREATING", None), ("deleting", None), ("DELETING", None), ("reverting", None), ("migrating", None), ("migrating_to", None), ("error", False), ("ERROR", False), ("error_deleting", False), ("ERROR_DELETING", False), ("MANAGE_ERROR", False), ("UNMANAGE_ERROR", False), ("extending_error", False), ("reverting_error", False), ) STATUS_DISPLAY_CHOICES = ( ("available", pgettext_lazy("Current status of share", u"Available")), ("AVAILABLE", pgettext_lazy("Current status of share", u"Available")), ("creating", pgettext_lazy("Current status of share", u"Creating")), ("CREATING", pgettext_lazy("Current status of share", u"Creating")), ("deleting", pgettext_lazy("Current status of share", u"Deleting")), ("DELETING", pgettext_lazy("Current status of share", u"Deleting")), ("migrating", pgettext_lazy("Current status of share", u"Migrating")), ("migrating_to", pgettext_lazy("Current status of share", u"Migrating to")), ("error", pgettext_lazy("Current status of share", u"Error")), ("ERROR", pgettext_lazy("Current status of share", u"Error")), ("error_deleting", pgettext_lazy("Current status of share", u"Deleting")), ("ERROR_DELETING", pgettext_lazy("Current status of share", u"Deleting")), ("MANAGE_ERROR", pgettext_lazy("Current status of share", u"Manage Error")), ("UNMANAGE_ERROR", pgettext_lazy("Current status of share", u"Unmanage Error")), ("extending_error", pgettext_lazy("Current status of share", u"Extending Error")), ("reverting_error", pgettext_lazy("Current status of share", u"Reverting Error")), ) name = tables.WrappingColumn( "name", verbose_name=_("Name"), link="horizon:project:shares:detail") description = tables.Column("description", verbose_name=_("Description"), truncate=40) metadata = tables.Column("metadata", verbose_name=_("Metadata")) size = tables.Column(get_size, verbose_name=_("Size"), attrs={'data-type': 'size'}) status = tables.Column("status", filters=(title,), verbose_name=_("Status"), status=True, status_choices=STATUS_CHOICES, display_choices=STATUS_DISPLAY_CHOICES) def get_object_display(self, obj): return obj.name or obj.id def get_share_group_link(share): if (features.is_share_groups_enabled() and getattr(share, 'share_group_id', None)): return reverse( "horizon:project:share_groups:detail", args=(share.share_group_id,)) else: return None share_group_id = tables.Column( "share_group_id", verbose_name=_("Share Group"), empty_value="-", link=get_share_group_link, ) class ManageRules(tables.LinkAction): name = "manage_rules" verbose_name = _("Manage Rules") url = "horizon:project:shares:manage_rules" classes = ("btn-edit",) policy_rules = (("share", "share:access_get_all"),) class ManageReplicas(tables.LinkAction): name = "manage_replicas" verbose_name = _("Manage Replicas") url = "horizon:project:shares:manage_replicas" classes = ("btn-edit",) policy_rules = (("share", "share:replica_get_all"),) def allowed(self, request, share): share_replication_enabled = share.replication_type is not None return features.is_replication_enabled() and share_replication_enabled class AddRule(tables.LinkAction): name = "rule_add" verbose_name = _("Add rule") url = 'horizon:project:shares:rule_add' classes = ("ajax-modal", "btn-create") icon = "plus" policy_rules = (("share", "share:allow_access"),) def allowed(self, request, share=None): share = manila.share_get(request, self.table.kwargs['share_id']) return share.status in ("available", "in-use") def get_link_url(self): return reverse(self.url, args=[self.table.kwargs['share_id']]) class DeleteRule(tables.DeleteAction): policy_rules = (("share", "share:deny_access"),) @staticmethod def action_present(count): return ungettext_lazy( u"Delete Rule", u"Delete Rules", count ) @staticmethod def action_past(count): return ungettext_lazy( u"Deleted Rule", u"Deleted Rules", count ) def delete(self, request, obj_id): try: manila.share_deny(request, self.table.kwargs['share_id'], obj_id) except Exception: msg = _('Unable to delete rule "%s".') % obj_id exceptions.handle(request, msg) class UpdateRuleRow(tables.Row): ajax = True def get_data(self, request, rule_id): rules = manila.share_rules_list(request, self.table.kwargs['share_id']) if rules: for rule in rules: if rule.id == rule_id: return rule raise exceptions.NotFound class RulesTable(tables.DataTable): access_type = tables.Column("access_type", verbose_name=_("Access Type")) access_to = tables.Column("access_to", verbose_name=_("Access to")) access_level = tables.Column( "access_level", verbose_name=_("Access Level")) status = tables.Column("state", verbose_name=_("Status")) access_key = tables.Column("access_key", verbose_name=_("Access Key")) def get_object_display(self, obj): return obj.id class Meta(object): name = "rules" verbose_name = _("Rules") status_columns = ["status"] row_class = UpdateRuleRow table_actions = ( AddRule, DeleteRule) row_actions = ( DeleteRule,) def get_share_network(share): name = share.share_network_name return name if name != "None" else None class SharesTable(SharesTableBase): name = tables.WrappingColumn( "name", verbose_name=_("Name"), link="horizon:project:shares:detail") visibility = tables.Column( "is_public", verbose_name=_("Visibility"), help_text=("Whether this share visible to all tenants (public) or " "only for owner (private)."), filters=(lambda d: 'public' if d is True else 'private', ), ) proto = tables.Column("share_proto", verbose_name=_("Protocol")) share_network = tables.Column("share_network", verbose_name=_("Share Network"), empty_value="-") class Meta(object): name = "shares" verbose_name = _("Shares") status_columns = ["status"] row_class = UpdateRow table_actions = ( tables.NameFilterAction, CreateShare, DeleteShare) row_actions = ( EditShare, ExtendShare, RevertShare, ss_tables.CreateShareSnapshot, ManageRules, ManageReplicas, EditShareMetadata, DeleteShare) columns = [ 'name', 'description', 'metadata', 'size', 'status', 'proto', 'visibility', 'share_network', ] if features.is_share_groups_enabled(): columns.append('share_group_id')