# -*- coding: utf-8 -*-
import attr
from navmazing import NavigateToAttribute, NavigateToSibling
from widgetastic.utils import VersionPick, Version
from widgetastic.widget import View
from cfme.common import Taggable, TagPageView
from cfme.containers.provider import (ContainerObjectAllBaseView,
ContainerObjectDetailsBaseView,
ContainerObjectDetailsEntities, Labelable,
GetRandomInstancesMixin)
from cfme.exceptions import ItemNotFound
from cfme.modeling.base import BaseCollection, BaseEntity
from cfme.utils.appliance.implementations.ui import CFMENavigateStep, navigator, navigate_to
from cfme.utils.providers import get_crud_by_name
from widgetastic_manageiq import NestedSummaryTable
[docs]class PodAllView(ContainerObjectAllBaseView):
"""Container Pods All view"""
SUMMARY_TEXT = VersionPick({
Version.lowest(): 'Pods',
'5.9': 'Container Pods'
})
[docs]class PodDetailsView(ContainerObjectDetailsBaseView):
"""Container Pods Detail view"""
SUMMARY_TEXT = VersionPick({
Version.lowest(): 'Pods',
'5.9': 'Container Pods'
})
@View.nested
class entities(ContainerObjectDetailsEntities): # noqa
volumes = NestedSummaryTable(title='Volumes')
conditions = NestedSummaryTable(title='Conditions')
@attr.s
[docs]class Pod(BaseEntity, Taggable, Labelable):
"""Pod Class"""
PLURAL = 'Pods'
all_view = PodAllView
details_view = PodDetailsView
name = attr.ib()
project_name = attr.ib()
provider = attr.ib()
@property
def exists(self):
"""Return True if the Pod exists"""
try:
navigate_to(self, 'Details')
except ItemNotFound:
return False
else:
return True
@attr.s
[docs]class PodCollection(GetRandomInstancesMixin, BaseCollection):
"""Collection object for :py:class:`Pod`."""
ENTITY = Pod
[docs] def all(self):
# container_groups table has ems_id, join with ext_mgmgt_systems on id for provider name
# Then join with container_projects on the id for the project
# TODO Update to use REST API instead of DB queries
pod_table = self.appliance.db.client['container_groups']
ems_table = self.appliance.db.client['ext_management_systems']
project_table = self.appliance.db.client['container_projects']
pod_query = (
self.appliance.db.client.session
.query(pod_table.name, project_table.name, ems_table.name)
.join(ems_table, pod_table.ems_id == ems_table.id)
.join(project_table, pod_table.container_project_id == project_table.id))
if self.filters.get('archived'):
pod_query = pod_query.filter(pod_table.deleted_on.isnot(None))
if self.filters.get('active'):
pod_query = pod_query.filter(pod_table.deleted_on.is_(None))
provider = None
# filtered
if self.filters.get('provider'):
provider = self.filters.get('provider')
pod_query = pod_query.filter(ems_table.name == provider.name)
pods = []
for name, project_name, ems_name, in pod_query.all():
pods.append(self.instantiate(name=name,
project_name=project_name,
provider=provider or get_crud_by_name(ems_name)))
return pods
@navigator.register(PodCollection, 'All')
[docs]class All(CFMENavigateStep):
prerequisite = NavigateToAttribute('appliance.server', 'LoggedIn')
VIEW = PodAllView
[docs] def step(self):
self.prerequisite_view.navigation.select('Compute', 'Containers', 'Pods')
[docs] def resetter(self):
# Reset view and selection
self.view.toolbar.view_selector.select("List View")
self.view.paginator.reset_selection()
@navigator.register(Pod, 'Details')
[docs]class Details(CFMENavigateStep):
VIEW = PodDetailsView
prerequisite = NavigateToAttribute('parent', 'All')
[docs] def step(self):
search_visible = self.prerequisite_view.entities.search.is_displayed
self.prerequisite_view.entities.get_entity(name=self.obj.name,
project_name=self.obj.project_name,
surf_pages=not search_visible,
use_search=search_visible).click()
@navigator.register(Pod, 'EditTags')