from navmazing import NavigateToSibling, NavigateToAttribute
from widgetastic.exceptions import NoSuchElementException
from wrapanapi.hawkular import CanonicalPath
from cfme.common import WidgetasticTaggable, UtilizationMixin
from cfme.exceptions import MiddlewareDatasourceNotFound
from cfme.middleware.provider import (
MiddlewareBase, download, get_server_name)
from cfme.middleware.provider import parse_properties
from cfme.middleware.provider.hawkular import HawkularProvider
from cfme.middleware.provider.middleware_views import (DatasourceDetailsView,
DatasourceAllView)
from cfme.middleware.server import MiddlewareServer
from cfme.utils import attributize_string
from cfme.utils.appliance import Navigatable, current_appliance
from cfme.utils.appliance.implementations.ui import navigator, CFMENavigateStep, navigate_to
from cfme.utils.providers import get_crud_by_name, list_providers_by_class
from cfme.utils.varmeth import variable
def _db_select_query(name=None, nativeid=None, server=None, provider=None):
"""Column order: `id`, `nativeid`, `name`, `properties`, `server_name`,
`feed`, `provider_name`, `ems_ref`, `hostname`"""
t_ms = current_appliance.db.client['middleware_servers']
t_mds = current_appliance.db.client['middleware_datasources']
t_ems = current_appliance.db.client['ext_management_systems']
query = current_appliance.db.client.session.query(
t_mds.id,
t_mds.nativeid,
t_mds.name,
t_mds.properties,
t_ms.name.label('server_name'),
t_ms.feed,
t_ems.name.label('provider_name'),
t_ms.hostname,
t_mds.ems_ref)\
.join(t_ms, t_mds.server_id == t_ms.id).join(t_ems, t_mds.ems_id == t_ems.id)
if name:
query = query.filter(t_mds.name == name)
if nativeid:
query = query.filter(t_mds.nativeid == nativeid)
if server:
query = query.filter(t_ms.name == server.name)
if server.feed:
query = query.filter(t_ms.feed == server.feed)
if provider:
query = query.filter(t_ems.name == provider.name)
return query
def _get_datasources_page(provider=None, server=None):
if server: # if server instance is provided navigate through server page
return navigate_to(server, 'ServerDatasources')
elif provider: # if provider instance is provided navigate through provider page
return navigate_to(provider, 'ProviderDatasources')
else: # if None(provider and server) given navigate through all middleware datasources page
return navigate_to(MiddlewareDatasource, 'All')
[docs]class MiddlewareDatasource(MiddlewareBase, WidgetasticTaggable, Navigatable, UtilizationMixin):
"""
MiddlewareDatasource class provides details on datasource page.
Class methods available to get existing datasources list
Args:
name: Name of the datasource
provider: Provider object (HawkularProvider)
nativeid: Native id (internal id) of datasource
server: Server object of the datasource (MiddlewareServer)
properties: Datasource driver name, connection URL and JNDI name
db_id: database row id of datasource
Usage:
mydatasource = MiddlewareDatasource(name='FooDS',
server=ser_instance,
provider=haw_provider,
properties='ds-properties')
datasources = MiddlewareDatasource.datasources() [or]
datasources = MiddlewareDeployment.datasources(provider=haw_provider) [or]
datasources = MiddlewareDeployment.datasources(provider=haw_provider,server=ser_instance)
"""
property_tuples = [('name', 'Name'), ('nativeid', 'Nativeid'),
('driver_name', 'Driver Name'), ('jndi_name', 'JNDI Name'),
('connection_url', 'Connection URL'), ('enabled', 'Enabled')]
taggable_type = 'MiddlewareDatasource'
def __init__(self, name, server, provider=None, appliance=None, **kwargs):
Navigatable.__init__(self, appliance=appliance)
if name is None:
raise KeyError("'name' should not be 'None'")
if not isinstance(server, MiddlewareServer):
raise KeyError("'server' should be an instance of MiddlewareServer")
self.name = name
self.provider = provider
self.server = server
self.nativeid = kwargs['nativeid'] if 'nativeid' in kwargs else None
self.hostname = kwargs['hostname'] if 'hostname' in kwargs else None
if 'properties' in kwargs:
for property in kwargs['properties']:
setattr(self, attributize_string(property), kwargs['properties'][property])
self.db_id = kwargs['db_id'] if 'db_id' in kwargs else None
@classmethod
[docs] def datasources(cls, provider=None, server=None):
datasources = []
view = _get_datasources_page(provider=provider, server=server)
for _ in view.entities.paginator.pages():
for row in view.entities.elements:
_server = MiddlewareServer(provider=provider, name=row.server.text)
datasources.append(MiddlewareDatasource(
provider=provider,
server=_server,
name=row.datasource_name.text,
hostname=row.host_name.text))
return datasources
@classmethod
[docs] def datasources_in_db(cls, server=None, provider=None, strict=True):
datasources = []
rows = _db_select_query(server=server, provider=provider).all()
_provider = provider
for datasource in rows:
if strict:
_provider = get_crud_by_name(datasource.provider_name)
_server = MiddlewareServer(
name=datasource.server_name,
feed=datasource.feed,
provider=provider)
datasources.append(MiddlewareDatasource(
nativeid=datasource.nativeid,
name=datasource.name,
db_id=datasource.id,
server=_server,
provider=_provider,
hostname=datasource.hostname,
properties=parse_properties(datasource.properties)))
return datasources
@classmethod
def _datasources_in_mgmt(cls, provider, server=None):
datasources = []
rows = provider.mgmt.inventory.list_server_datasource()
for datasource in rows:
_server = MiddlewareServer(name=get_server_name(datasource.path),
feed=datasource.path.feed_id,
provider=provider)
_include = False
if server:
if server.name == _server.name:
_include = True if not server.feed else server.feed == _server.feed
else:
_include = True
if _include:
datasources.append(MiddlewareDatasource(nativeid=datasource.id,
name=datasource.name,
server=_server,
provider=provider))
return datasources
@classmethod
[docs] def datasources_in_mgmt(cls, provider=None, server=None):
if provider is None:
datasources = []
for _provider in list_providers_by_class(HawkularProvider):
datasources.extend(cls._datasources_in_mgmt(_provider, server))
return datasources
else:
return cls._datasources_in_mgmt(provider, server)
@classmethod
[docs] def remove_from_list(cls, datasource):
view = _get_datasources_page(server=datasource.server)
view.entities.get_entity(name=datasource.name).check()
view.toolbar.configuration.item_select('Remove', handle_alert=True)
view.flash.assert_success_message('The selected datasources were removed')
[docs] def load_details(self, refresh=False):
view = navigate_to(self, 'Details')
if not self.db_id or refresh:
tmp_dsource = self.datasource(method='db')
self.db_id = tmp_dsource.db_id
if refresh:
view.browser.selenium.refresh()
view.flush_widget_cache()
return view
@variable(alias='ui')
def datasource(self):
self.load_details(refresh=False)
self.id = self.get_detail("Properties", "Nativeid")
self.server = MiddlewareServer(
provider=self.provider,
name=self.get_detail("Relationships", "Middleware Server"))
return self
@datasource.variant('mgmt')
def datasource_in_mgmt(self):
db_ds = _db_select_query(name=self.name, server=self.server,
nativeid=self.nativeid).first()
if db_ds:
path = CanonicalPath(db_ds.ems_ref)
mgmt_ds = self.provider.mgmt.inventory.get_config_data(feed_id=path.feed_id,
resource_id=path.resource_id)
if mgmt_ds:
ds = MiddlewareDatasource(
server=self.server,
provider=self.provider,
name=db_ds.name,
hostname=db_ds.hostname,
nativeid=db_ds.nativeid,
properties=mgmt_ds.value)
return ds
return None
@datasource.variant('db')
def datasource_in_db(self):
datasource = _db_select_query(name=self.name, server=self.server,
nativeid=self.nativeid).first()
if datasource:
_server = MiddlewareServer(name=datasource.server_name, provider=self.provider)
return MiddlewareDatasource(
provider=self.provider,
server=_server,
db_id=datasource.id,
nativeid=datasource.nativeid,
name=datasource.name,
hostname=datasource.hostname,
properties=parse_properties(datasource.properties))
return None
@datasource.variant('rest')
def datasource_in_rest(self):
raise NotImplementedError('This feature not implemented yet')
@classmethod
[docs] def download(cls, extension, provider=None, server=None):
view = _get_datasources_page(provider, server)
download(view, extension)
[docs] def delete(self, cancel=False):
"""
Deletes a datasource from CFME
:param cancel: Whether to cancel the deletion, defaults to False
"""
view = self.load_details()
view.toolbar.configuration.item_select('Remove', handle_alert=not cancel)
# flash message only displayed if it was deleted
if not cancel:
view.flash.assert_success_message('The selected datasources were removed')
@navigator.register(MiddlewareDatasource, 'All')
[docs]class All(CFMENavigateStep):
VIEW = DatasourceAllView
prerequisite = NavigateToAttribute('appliance.server', 'LoggedIn')
[docs] def step(self):
self.prerequisite_view.navigation.select('Middleware', 'Datasources')
[docs] def resetter(self):
"""Reset view and selection"""
self.view.entities.paginator.reset_selection()
@navigator.register(MiddlewareDatasource, 'Details')
[docs]class Details(CFMENavigateStep):
VIEW = DatasourceDetailsView
prerequisite = NavigateToSibling('All')
[docs] def step(self, *args, **kwargs):
try:
if self.obj.server:
# TODO find_row_on_pages change to entities.get_entity()
row = self.prerequisite_view.entities.paginator.find_row_on_pages(
self.prerequisite_view.entities.elements,
datasource_name=self.obj.name,
server=self.obj.server.name)
else:
row = self.prerequisite_view.entities.paginator.find_row_on_pages(
self.prerequisite_view.entities.elements,
datasource_name=self.obj.name)
except NoSuchElementException:
raise MiddlewareDatasourceNotFound(
"Datasource '{}' not found in table".format(self.obj.name))
row.click()