<gh_stars>1-10
#
# Copyright (c) 2019 Wind River Systems, Inc.
#
# SPDX-License-Identifier: Apache-2.0
#

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

from sysinv.api.controllers.v1 import base
from sysinv.api.controllers.v1 import collection
from sysinv.common import exception
from sysinv.common import kubernetes
from sysinv import objects


class KubeVersion(base.APIBase):
    """API representation of a k8s version."""

    version = wtypes.text
    "Unique version for this entry"

    upgrade_from = [wtypes.text]
    "List of versions that can upgrade to this version"

    downgrade_to = [wtypes.text]
    "List of versions that this version can downgrade to"

    applied_patches = [wtypes.text]
    "List of patches that must be applied before upgrading to this version"

    available_patches = [wtypes.text]
    "List of patches that must be available before upgrading to this version"

    target = bool
    "Denotes whether this is the target version"

    state = wtypes.text
    "State of this version"

    def __init__(self, **kwargs):
        self.fields = list(objects.kube_version.fields.keys())
        for k in self.fields:
            if not hasattr(self, k):
                continue
            setattr(self, k, kwargs.get(k, wtypes.Unset))

    @classmethod
    def convert_with_links(cls, rpc_kube_version, expand=True):
        kube_version = KubeVersion(**rpc_kube_version.as_dict())
        if not expand:
            kube_version.unset_fields_except(['version', 'target', 'state'])

        # The version is not a database object so does not have timestamps.
        kube_version.created_at = wtypes.Unset
        kube_version.updated_at = wtypes.Unset
        return kube_version


class KubeVersionCollection(collection.Collection):
    """API representation of a collection of k8s versions."""

    kube_versions = [KubeVersion]
    "A list containing kubernetes version objects"

    def __init__(self, **kwargs):
        self._type = 'kube_versions'

    @classmethod
    def convert_with_links(cls, rpc_kube_version, expand=False):
        collection = KubeVersionCollection()
        collection.kube_versions = [KubeVersion.convert_with_links(p, expand)
                                    for p in rpc_kube_version]
        return collection


class KubeVersionController(rest.RestController):
    """REST controller for Kubernetes Versions."""

    def __init__(self, parent=None, **kwargs):
        self._parent = parent
        self._kube_operator = kubernetes.KubeOperator()

    @staticmethod
    def _update_target(version_obj, upgrade_to_version):
        """Determines whether this is the target version"""

        if upgrade_to_version is not None:
            if upgrade_to_version == version_obj.version:
                # We are in an upgrade and this is the to_version
                version_obj.target = True
            else:
                # We are in an upgrade and this is not the to_version
                version_obj.target = False
        elif version_obj.state == kubernetes.KUBE_STATE_ACTIVE:
            # We are not in an upgrade and this is the active version
            version_obj.target = True
        else:
            # This is not the version you are looking for
            version_obj.target = False

    @wsme_pecan.wsexpose(KubeVersionCollection)
    def get_all(self):
        """Retrieve a list of kubernetes versions."""

        # Get the current upgrade (if one exists)
        upgrade_to_version = None
        try:
            kube_upgrade_obj = pecan.request.dbapi.kube_upgrade_get_one()
            upgrade_to_version = kube_upgrade_obj.to_version
        except exception.NotFound:
            pass

        # Get the dynamic version information
        version_states = self._kube_operator.kube_get_version_states()

        rpc_kube_versions = []
        for version in kubernetes.get_kube_versions():
            version_obj = objects.kube_version.get_by_version(
                version['version'])
            version_obj.state = version_states[version['version']]
            self._update_target(version_obj, upgrade_to_version)
            rpc_kube_versions.append(version_obj)

        return KubeVersionCollection.convert_with_links(rpc_kube_versions)

    @wsme_pecan.wsexpose(KubeVersion, wtypes.text)
    def get_one(self, version):
        """Retrieve information about the given kubernetes version."""

        # Get the static version information
        rpc_kube_version = objects.kube_version.get_by_version(version)

        # Get the dynamic version information
        version_states = self._kube_operator.kube_get_version_states()
        rpc_kube_version.state = version_states[version]

        # Get the current upgrade (if one exists)
        upgrade_to_version = None
        try:
            kube_upgrade_obj = pecan.request.dbapi.kube_upgrade_get_one()
            upgrade_to_version = kube_upgrade_obj.to_version
        except exception.NotFound:
            pass

        self._update_target(rpc_kube_version, upgrade_to_version)

        return KubeVersion.convert_with_links(rpc_kube_version)

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

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

from sysinv.api.controllers.v1 import base
from sysinv.api.controllers.v1 import collection
from sysinv.common import exception
from sysinv.common import kubernetes
from sysinv import objects


class KubeVersion(base.APIBase):
    """API representation of a k8s version."""

    version = wtypes.text
    "Unique version for this entry"

    upgrade_from = [wtypes.text]
    "List of versions that can upgrade to this version"

    downgrade_to = [wtypes.text]
    "List of versions that this version can downgrade to"

    applied_patches = [wtypes.text]
    "List of patches that must be applied before upgrading to this version"

    available_patches = [wtypes.text]
    "List of patches that must be available before upgrading to this version"

    target = bool
    "Denotes whether this is the target version"

    state = wtypes.text
    "State of this version"

    def __init__(self, **kwargs):
        self.fields = list(objects.kube_version.fields.keys())
        for k in self.fields:
            if not hasattr(self, k):
                continue
            setattr(self, k, kwargs.get(k, wtypes.Unset))

    @classmethod
    def convert_with_links(cls, rpc_kube_version, expand=True):
        kube_version = KubeVersion(**rpc_kube_version.as_dict())
        if not expand:
            kube_version.unset_fields_except(['version', 'target', 'state'])

        # The version is not a database object so does not have timestamps.
        kube_version.created_at = wtypes.Unset
        kube_version.updated_at = wtypes.Unset
        return kube_version


class KubeVersionCollection(collection.Collection):
    """API representation of a collection of k8s versions."""

    kube_versions = [KubeVersion]
    "A list containing kubernetes version objects"

    def __init__(self, **kwargs):
        self._type = 'kube_versions'

    @classmethod
    def convert_with_links(cls, rpc_kube_version, expand=False):
        collection = KubeVersionCollection()
        collection.kube_versions = [KubeVersion.convert_with_links(p, expand)
                                    for p in rpc_kube_version]
        return collection


class KubeVersionController(rest.RestController):
    """REST controller for Kubernetes Versions."""

    def __init__(self, parent=None, **kwargs):
        self._parent = parent
        self._kube_operator = kubernetes.KubeOperator()

    @staticmethod
    def _update_target(version_obj, upgrade_to_version):
        """Determines whether this is the target version"""

        if upgrade_to_version is not None:
            if upgrade_to_version == version_obj.version:
                # We are in an upgrade and this is the to_version
                version_obj.target = True
            else:
                # We are in an upgrade and this is not the to_version
                version_obj.target = False
        elif version_obj.state == kubernetes.KUBE_STATE_ACTIVE:
            # We are not in an upgrade and this is the active version
            version_obj.target = True
        else:
            # This is not the version you are looking for
            version_obj.target = False

    @wsme_pecan.wsexpose(KubeVersionCollection)
    def get_all(self):
        """Retrieve a list of kubernetes versions."""

        # Get the current upgrade (if one exists)
        upgrade_to_version = None
        try:
            kube_upgrade_obj = pecan.request.dbapi.kube_upgrade_get_one()
            upgrade_to_version = kube_upgrade_obj.to_version
        except exception.NotFound:
            pass

        # Get the dynamic version information
        version_states = self._kube_operator.kube_get_version_states()

        rpc_kube_versions = []
        for version in kubernetes.get_kube_versions():
            version_obj = objects.kube_version.get_by_version(
                version['version'])
            version_obj.state = version_states[version['version']]
            self._update_target(version_obj, upgrade_to_version)
            rpc_kube_versions.append(version_obj)

        return KubeVersionCollection.convert_with_links(rpc_kube_versions)

    @wsme_pecan.wsexpose(KubeVersion, wtypes.text)
    def get_one(self, version):
        """Retrieve information about the given kubernetes version."""

        # Get the static version information
        rpc_kube_version = objects.kube_version.get_by_version(version)

        # Get the dynamic version information
        version_states = self._kube_operator.kube_get_version_states()
        rpc_kube_version.state = version_states[version]

        # Get the current upgrade (if one exists)
        upgrade_to_version = None
        try:
            kube_upgrade_obj = pecan.request.dbapi.kube_upgrade_get_one()
            upgrade_to_version = kube_upgrade_obj.to_version
        except exception.NotFound:
            pass

        self._update_target(rpc_kube_version, upgrade_to_version)

        return KubeVersion.convert_with_links(rpc_kube_version)
# # Copyright (c) 2019 Wind River Systems, Inc. # # SPDX-License-Identifier: Apache-2.0 # API representation of a k8s version. # The version is not a database object so does not have timestamps. API representation of a collection of k8s versions. REST controller for Kubernetes Versions. Determines whether this is the target version # We are in an upgrade and this is the to_version # We are in an upgrade and this is not the to_version # We are not in an upgrade and this is the active version # This is not the version you are looking for Retrieve a list of kubernetes versions. # Get the current upgrade (if one exists) # Get the dynamic version information Retrieve information about the given kubernetes version. # Get the static version information # Get the dynamic version information # Get the current upgrade (if one exists)