host.py

#
# Project Kimchi
#
# Copyright IBM Corp, 2015-2017
#
# This library is free software; you can redistribute it and/or
# modify it under the terms of the GNU Lesser General Public
# License as published by the Free Software Foundation; either
# version 2.1 of the License, or (at your option) any later version.
#
# This library is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
# Lesser General Public License for more details.
#
# You should have received a copy of the GNU Lesser General Public
# License along with this library; if not, write to the Free Software
# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301 USA
import platform

from wok.control.base import Collection
from wok.control.base import Resource
from wok.control.base import SimpleCollection
from wok.control.utils import UrlSubNode
from wok.exception import NotFoundError
from wok.plugins.kimchi.control.cpuinfo import CPUInfo
from wok.plugins.kimchi.utils import is_s390x

ARCH = platform.machine()


@UrlSubNode('host', True)
class Host(Resource):
    def __init__(self, model, id=None):
        super(Host, self).__init__(model, id)
        self.admin_methods = ['GET', 'POST']
        self.uri_fmt = '/host/%s'
        self.devices = Devices(self.model)
        self.cpuinfo = CPUInfo(self.model)
        self.partitions = Partitions(self.model)
        self.vgs = VolumeGroups(self.model)

    @property
    def data(self):
        return {'arch': ARCH}


class VolumeGroups(Collection):
    def __init__(self, model):
        super(VolumeGroups, self).__init__(model)
        self.uri_fmt = '/host/vgs'
        self.admin_methods = ['GET']
        self.resource = VolumeGroup


class VolumeGroup(Resource):
    def __init__(self, model, id=None):
        super(VolumeGroup, self).__init__(model, id)
        self.uri_fmt = '/host/vgs/%s'
        self.admin_methods = ['GET']

    @property
    def data(self):
        return self.info


class VMHolders(SimpleCollection):
    def __init__(self, model, device_id):
        super(VMHolders, self).__init__(model)
        self.model_args = (device_id,)


class Devices(Collection):
    def __init__(self, model):
        super(Devices, self).__init__(model)
        self.resource = Device


class Device(Resource):
    def __init__(self, model, id):
        super(Device, self).__init__(model, id)
        self.vm_holders = VMHolders(self.model, id)

    @property
    def data(self):
        return self.info


class Partitions(Collection):
    def __init__(self, model):
        super(Partitions, self).__init__(model)
        self.admin_methods = ['GET']
        self.resource = Partition

    # Defining get_resources in order to return list of partitions in UI
    # sorted by their path
    def _get_resources(self, flag_filter):
        res_list = super(Partitions, self)._get_resources(flag_filter)
        res_list = list(filter(lambda x: x.info.get('available', False), res_list))
        if is_s390x():
            # On s390x arch filter out the DASD block devices which
            # don't have any partition(s). This is necessary because
            # DASD devices without any partitions are not valid
            # block device(s) for operations like pvcreate on s390x
            res_list = list(
                filter(
                    lambda x: (
                        x.info['name'].startswith(
                            'dasd') and x.info['type'] == 'part'
                    ) or
                    (not x.info['name'].startswith('dasd')),
                    res_list,
                )
            )
        res_list.sort(key=lambda x: x.info['path'])
        return res_list


class Partition(Resource):
    def __init__(self, model, id):
        self.admin_methods = ['GET']
        super(Partition, self).__init__(model, id)

    @property
    def data(self):
        if not self.info.get('available', False):
            raise NotFoundError('KCHPART0001E', {'name': self.info['name']})

        return self.info