config/sysinv/sysinv/sysinv/sysinv/api/controllers/v1/helm_charts.py

#
# Copyright (c) 2018 Wind River Systems, Inc.
#
# SPDX-License-Identifier: Apache-2.0
#

import pecan
from pecan import rest
import yaml

import wsme
from wsme import types as wtypes
import wsmeext.pecan as wsme_pecan

from sysinv import objects
from sysinv.common import constants
from sysinv.common import exception
from sysinv.openstack.common import log
from sysinv.openstack.common.gettextutils import _


LOG = log.getLogger(__name__)


class HelmChartsController(rest.RestController):

    @wsme_pecan.wsexpose(wtypes.text)
    def get_all(self):
        """Provides information about the available charts to override."""

        namespaces = pecan.request.rpcapi.get_helm_application_namespaces(
            pecan.request.context, constants.HELM_APP_OPENSTACK)
        charts = [{'name': chart, 'namespaces': namespaces[chart]}
                  for chart in namespaces]

        return {'charts': charts}

    @wsme_pecan.wsexpose(wtypes.text, wtypes.text, wtypes.text)
    def get_one(self, name, namespace):
        """Retrieve information about the given chart.

        :param name: name of helm chart
        :param namespace: namespace of chart overrides
        """
        self.validate_name_and_namespace(name, namespace)

        # Get any user-specified overrides.
        try:
            db_chart = objects.helm_overrides.get_by_name(
                pecan.request.context, name, namespace)
            user_overrides = db_chart.user_overrides
        except exception.HelmOverrideNotFound:
            if name in constants.SUPPORTED_HELM_CHARTS:
                user_overrides = ''
            else:
                # Unsupported/invalid chart name (and namespace)
                raise wsme.exc.ClientSideError(_("Override not found."))

        # Get any system overrides.
        try:
            system_overrides = pecan.request.rpcapi.get_helm_chart_overrides(
                pecan.request.context, name, namespace)
            system_overrides = yaml.safe_dump(system_overrides)
        except Exception:
            # Unsupported/invalid namespace
            raise wsme.exc.ClientSideError(_("Override not found."))

        # Merge the system overrides with the saved user-specified overrides,
        # with user-specified overrides taking priority over the system
        # overrides.
        file_overrides = [system_overrides, user_overrides] \
            if user_overrides else [system_overrides]

        combined_overrides = pecan.request.rpcapi.merge_overrides(
             pecan.request.context, file_overrides=file_overrides)

        rpc_chart = {'name': name,
                     'namespace': namespace,
                     'system_overrides': system_overrides,
                     'user_overrides': user_overrides,
                     'combined_overrides': combined_overrides}

        return rpc_chart

    def validate_name_and_namespace(self, name, namespace):
        if not name:
                raise wsme.exc.ClientSideError(_("Name must be specified."))
        if not namespace:
            raise wsme.exc.ClientSideError(_("Namespace must be specified."))

    @wsme_pecan.wsexpose(wtypes.text, wtypes.text, wtypes.text, wtypes.text, wtypes.text)
    def patch(self, name, namespace, flag, values):
        """ Update user overrides.

        :param name: chart name
        :param namespace: namespace of chart overrides
        :param flag: one of "reuse" or "reset", describes how to handle
                     previous user overrides
        :param values: a dict of different types of user override values
        """
        self.validate_name_and_namespace(name, namespace)

        file_overrides = values.get('files', [])
        set_overrides = values.get('set', [])

        # Get any stored user overrides for this chart.  We'll need this
        # object later either way.
        try:
            db_chart = objects.helm_overrides.get_by_name(
                pecan.request.context, name, namespace)
        except exception.HelmOverrideNotFound:
            if name in constants.SUPPORTED_HELM_CHARTS:
                pecan.request.dbapi.helm_override_create({
                    'name': name,
                    'namespace': namespace,
                    'user_overrides': ''})
                db_chart = objects.helm_overrides.get_by_name(
                    pecan.request.context, name, namespace)
            else:
                raise

        if flag == 'reuse':
            file_overrides.insert(0, db_chart.user_overrides)
        elif flag == 'reset':
            pass
        else:
            raise wsme.exc.ClientSideError(_("Invalid flag: %s must be either "
                                             "'reuse' or 'reset'.") % flag)

        user_overrides = pecan.request.rpcapi.merge_overrides(
            pecan.request.context, file_overrides=file_overrides,
            set_overrides=set_overrides)

        # save chart overrides back to DB
        db_chart.user_overrides = user_overrides
        db_chart.save()

        chart = {'name': name, 'namespace': namespace,
                 'user_overrides': user_overrides}

        return chart

    @wsme_pecan.wsexpose(None, wtypes.text, wtypes.text, status_code=204)
    def delete(self, name, namespace):
        """Delete user overrides for a chart

        :param name: chart name.
        :param namespace: namespace of chart overrides
        """
        self.validate_name_and_namespace(name, namespace)
        try:
            pecan.request.dbapi.helm_override_update(name, namespace,
                                                     {'user_overrides': None})
        except exception.HelmOverrideNotFound:
            pass