# Copyright (c) 2013 Mirantis, 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.core.urlresolvers import reverse from django import http from django.template import defaultfilters 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 horizon.utils import filters from oslo_log import log as logging from muranoclient.common import exceptions as exc from muranodashboard import api LOG = logging.getLogger(__name__) class ImportBundle(tables.LinkAction): name = 'import_bundle' verbose_name = _('Import Bundle') url = 'horizon:murano:packages:import_bundle' classes = ('ajax-modal',) icon = "plus" class ImportPackage(tables.LinkAction): name = 'upload_package' verbose_name = _('Import Package') url = 'horizon:murano:packages:upload' classes = ('ajax-modal',) icon = "plus" def allowed(self, request, package): _allowed = False with api.handled_exceptions(request): client = api.muranoclient(request) _allowed = client.packages.categories() is not None return _allowed class PackagesFilterAction(tables.FilterAction): name = "filter_packages" filter_type = "server" filter_choices = (('search', _("KeyWord"), True), ('type', _("Type"), True), ('name', _("Name"), True)) class DownloadPackage(tables.Action): name = 'download_package' verbose_name = _('Download Package') def allowed(self, request, package): return True @staticmethod def get_package_name(data_table, app_id): # TODO(tsufiev): should use more optimal search here name = None for pkg in data_table.data: if pkg.id == app_id: name = defaultfilters.slugify(pkg.name) break return name if name is not None else app_id def single(self, data_table, request, app_id): try: body = api.muranoclient(request).packages.download(app_id) content_type = 'application/octet-stream' response = http.HttpResponse(body, content_type=content_type) response['Content-Disposition'] = 'filename={name}.zip'.format( name=self.get_package_name(data_table, app_id)) return response except exc.HTTPException: LOG.exception(_('Something went wrong during package downloading')) redirect = reverse('horizon:murano:packages:index') exceptions.handle(request, _('Unable to download package.'), redirect=redirect) class ToggleEnabled(tables.BatchAction): name = 'toggle_enabled' verbose_name = _("Toggle Enabled") icon = "toggle-on" @staticmethod def action_present(count): return ungettext_lazy( u"Toggle Active", u"Toggle Active", count ) @staticmethod def action_past(count): return ungettext_lazy( u"Toggled Active", u"Toggled Active", count ) def action(self, request, obj_id): try: api.muranoclient(request).packages.toggle_active(obj_id) LOG.debug('Toggle Active for package {0}.'.format(obj_id)) except exc.HTTPForbidden: msg = _("You are not allowed to perform this operation") LOG.exception(msg) messages.error(request, msg) exceptions.handle( request, msg, redirect=reverse('horizon:murano:packages:index')) class TogglePublicEnabled(tables.BatchAction): name = 'toggle_public_enabled' verbose_name = _("Toggle Public") icon = "share-alt" @staticmethod def action_present(count): return ungettext_lazy( u"Toggle Public", u"Toggle Public", count ) @staticmethod def action_past(count): return ungettext_lazy( u"Toggled Public", u"Toggled Public", count ) def action(self, request, obj_id): try: api.muranoclient(request).packages.toggle_public(obj_id) LOG.debug('Toggle Public for package {0}.'.format(obj_id)) except exc.HTTPForbidden: msg = _("You are not allowed to perform this operation") LOG.exception(msg) messages.error(request, msg) exceptions.handle( request, msg, redirect=reverse('horizon:murano:packages:index')) except exc.HTTPConflict: msg = _('Package or Class with the same name is already made ' 'public') LOG.exception(msg) messages.error(request, msg) exceptions.handle( request, msg, redirect=reverse('horizon:murano:packages:index')) class DeletePackage(tables.DeleteAction): name = 'delete_package' data_type_singular = _('Package') def delete(self, request, obj_id): try: api.muranoclient(request).packages.delete(obj_id) except exc.HTTPNotFound: msg = _("Package with id {0} is not found").format(obj_id) LOG.exception(msg) exceptions.handle( self.request, msg, redirect=reverse('horizon:murano:packages:index')) except exc.HTTPForbidden: msg = _("You are not allowed to delete this package") LOG.exception(msg) exceptions.handle( request, msg, redirect=reverse('horizon:murano:packages:index')) except Exception: LOG.exception(_('Unable to delete package in murano-api server')) url = reverse('horizon:murano:packages:index') exceptions.handle(request, _('Unable to remove package.'), redirect=url) class ModifyPackage(tables.LinkAction): name = 'modify_package' verbose_name = _('Modify Package') url = 'horizon:murano:packages:modify' classes = ('ajax-modal',) icon = "edit" def allowed(self, request, package): return True class PackageDefinitionsTable(tables.DataTable): name = tables.Column('name', link="horizon:murano:packages:detail", verbose_name=_('Package Name')) tenant_name = tables.Column('tenant_name', verbose_name=_('Tenant Name')) enabled = tables.Column('enabled', verbose_name=_('Active')) is_public = tables.Column('is_public', verbose_name=_('Public')) type = tables.Column('type', verbose_name=_('Type')) version = tables.Column(lambda obj: getattr(obj, 'version', None), verbose_name=_('Version')) created_time = tables.Column('created', verbose_name=_('Created'), filters=(filters.parse_isotime,)) updated_time = tables.Column('updated', verbose_name=_('Updated'), filters=(filters.parse_isotime,)) def get_prev_pagination_string(self): pagination_string = super( PackageDefinitionsTable, self).get_prev_pagination_string() return pagination_string + "&sort_dir=desc" class Meta(object): name = 'packages' prev_pagination_param = 'marker' verbose_name = _('Packages') table_actions_menu = (ToggleEnabled, TogglePublicEnabled) table_actions = (PackagesFilterAction, ImportPackage, ImportBundle, DeletePackage) row_actions = (ModifyPackage, DownloadPackage, ToggleEnabled, TogglePublicEnabled, DeletePackage)