Skip to content

crosslink test created #201

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
prachiyadav wants to merge 2 commits into
base: master
Choose a base branch
from
Open

crosslink test created #201

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
a5c4929
crosslink test created
Oct 16, 2017
bf1386a
refactoring on opneshift provider tests.
Dec 13, 2017
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
13 changes: 10 additions & 3 deletions tests/test_openshift_provider.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -5,11 +5,18 @@

@pytest.fixture (scope='session')
def web_session(request):
web_session = session(add_provider=False)


web_session = session(add_provider=True)
return web_session

def test_cfui_add_provider(web_session):
provs = mm_openshift_providers(web_session)
provs.add_mm_openshift_provider()

def test_cfui_hawkular_Services_crosslink(web_session):
provs = mm_openshift_providers(web_session)
provs.verify_hawkular_Services_crosslink()

def test_cfui_hawkular_Services_topology_crosslink(web_session):
provs= mm_openshift_providers(web_session)
provs.verify_topology_crosslink_to_hawkular_services_container()

157 changes: 85 additions & 72 deletions views/mm_openshift_provider.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -8,11 +8,13 @@
from common.openshift_utils import openshift_utils
import time
from common.timeout import timeout
from common.navigate import navigate
from views.servers import servers


class mm_openshift_providers():
web_session = None
MIQ_BASE_VERSION = "master"
openshift_container_name = "hawkular-services"
ui_utils = None

def __init__(self, web_session):
Expand All @@ -21,123 +23,92 @@ def __init__(self, web_session):
self.ui_utils = ui_utils(self.web_session)
self.openshift_utils= openshift_utils(self.web_session)

def add_mm_openshift_provider(self, delete_if_provider_present=True, port=None, validate_provider=True):
def add_mm_openshift_provider(self, port=None, validate_provider=True):
self.provider_name = self.web_session.OPENSHIFT_PROVIDER_NAME
self.host_name = self.web_session.OPENSHIFT_HOSTNAME
self.port = self.web_session.OPENSHIFT_PORT if port == None else port
self.openshift_user = self.web_session.OPENSHIFT_USERNAME
self.openshift_token= self.openshift_utils.get_token()
ui_utils(self.web_session).sleep(2)

# Check if any provider already exist. If exist, first delete all the providers and then add a provider.
# Check if any provider already exist.

if db(self.web_session).is_container_provider_present(self.web_session.OPENSHIFT_PROVIDER_NAME):
self.web_session.logger.info("Container Provider already exist.")
if self.does_provider_exist():
self.web_session.logger.info("Openshift Provider already exist.")
return
else:
self.web_session.logger.info("Adding openshift Middleware Provider to ManageIQ instance")
self.web_session.logger.info("Adding openshift Provider to ManageIQ instance")

navigate(self.web_session).get("{}//ems_container/show_list".format(self.web_session.MIQ_URL))
assert ui_utils(self.web_session).waitForTextOnPage("Containers Providers", 15)
self.web_session.web_driver.get("{}//ems_container/show_list".format(self.web_session.MIQ_URL))
assert ui_utils(self.web_session).waitForTextOnPage("Containers Providers", 15)

self.web_driver.find_element_by_xpath("//button[@title='Configuration']").click()
self.ui_utils.waitForElementOnPage(By.XPATH,"//a[@title='Add a new Containers Provider']", 5)
elem_add_new_provider = self.web_driver.find_element_by_xpath("//a[@title='Add a new Containers Provider']")
elem_add_new_provider.click()
self.web_driver.implicitly_wait(15)
assert ui_utils(self.web_session).waitForTextOnPage("Add New Containers Provider", 50)
ui_utils(self.web_session).sleep(2)
self.web_driver.find_element_by_xpath("//button[@title='Configuration']").click()
self.ui_utils.waitForElementOnPage(By.XPATH,"//a[@title='Add a new Containers Provider']", 5)
elem_add_new_provider = self.web_driver.find_element_by_xpath("//a[@title='Add a new Containers Provider']")
elem_add_new_provider.click()
self.web_driver.implicitly_wait(15)
assert ui_utils(self.web_session).waitForTextOnPage("Add New Containers Provider", 50)
ui_utils(self.web_session).sleep(2)

self.web_session.logger.info("The appliance version in use is: {} ".format(self.web_session.appliance_version))
self.web_session.logger.info("The appliance version in use is: {} ".format(self.web_session.appliance_version))

self.submit_provider_form_cfme(validate_provider)
self.verify_add_provider_success()
self.submit_provider_form_cfme(validate_provider)
self.verify_add_provider_success()


def submit_provider_form_cfme(self, validate_provider=True):
# Enter the form details and submit if the appliance version is CFME Downstream

# Enter the form details and submit

self.web_driver.find_element_by_xpath("//input[@id='ems_name']").send_keys(self.provider_name)
self.web_driver.find_element_by_xpath("//button[contains(.,'<Choose>')]").click()
assert ui_utils(self.web_session).waitForTextOnPage("OpenShift", 15)
self.web_driver.find_element_by_xpath("//a[contains(.,'OpenShift')]").click()
self.web_driver.find_element_by_xpath("//input[@id='default_hostname']").send_keys(self.host_name)

# self.web_driver.find_element_by_xpath("//input[@id='default_api_port']").send_keys(self.port)

self.web_driver.find_element_by_xpath("//button[@data-id='default_security_protocol']").click()
assert ui_utils(self.web_session).waitForTextOnPage("SSL without validation", 15)
self.web_driver.find_element_by_xpath("//a[contains(.,'SSL without validation')]").click()

self.web_driver.find_element_by_xpath("//input[@id='default_password']").send_keys(self.openshift_token)


if validate_provider:
self.validate_provider()
self.save_provider()

def does_provider_exist(self):
self.web_session.logger.info("Checking if provider exists")

def verify_refresh_status_success(self):
refresh_value_success = "Success"

self.refresh_provider()

# Refresh the page till till the table value for Last Refresh shows the value - Success

assert self.wait_for_provider_refresh_status(refresh_value_success, 600)
provider_details = ui_utils(self.web_session).get_generic_table_as_dict()

# Verify if the 'Last Refresh' value from table contains 'Success:
refresh_status = provider_details.get("Last Refresh")
# For performance reasons, check if the provider is present via DB

if str(refresh_status).__contains__(refresh_value_success):
self.web_session.logger.info("The Last refresh status is - " + refresh_status)
if db(self.web_session).is_container_provider_present(self.provider_name):
self.web_session.logger.info("Container Provider already exist.")
#if openshift provider exists, refresh Middleware provider
servers(self.web_session).navigate_and_refresh_provider()
return True

else:
self.web_session.logger.info("Adding Container Provider to ManageIQ instance")
return False


def refresh_provider(self):
self.web_driver.find_element_by_xpath("//button[@title='Configuration']").click()
el = self.web_driver.find_element_by_xpath("//a[@id='ems_container_vmdb_choice__ems_container_refresh']")
assert self.ui_utils.wait_until_element_displayed(el, 5)
el.click()
ui_utils(self.web_session).accept_alert(10)
ui_utils(self.web_session).waitForTextOnPage("Refresh Provider initiated", 15)

def validate_providers_list(self):

# Test to validate provider list page in UI and validate matching providers hostname, port number

self.web_session.logger.info("Begin providers list test.")
navigate(self.web_session).get("{}//ems_container/show_list".format(self.web_session.MIQ_URL))
providers_ui = self.ui_utils.get_list_table()
assert len(providers_ui) > 0, "Providers list is empty."

for prov_ui in providers_ui:

if prov_ui.get('Name') == self.web_session.OPENSHIFT_PROVIDER_NAME:
assert (prov_ui.get('Hostname') == self.web_session.OPENSHIFT_HOSTNAME), "Hostname mismatch"
assert (prov_ui.get('Port') == self.web_session.OPENSHIFT_PORT), "Port Number mismatch"

return True

def verify_add_provider_success(self):

assert ui_utils(self.web_session).waitForTextOnPage(
'Containers Providers "{}" was saved'.format(self.provider_name), 90)
assert ui_utils(self.web_session).waitForTextOnPage(
'Containers Providers "{}" was saved'.format(self.provider_name), 90)

if ui_utils(self.web_session).isElementPresent(By.XPATH, "//a[contains(@title,'Name: {}')]".format(
self.provider_name)):
self.web_session.logger.info("Container Provider added successfully.")
if ui_utils(self.web_session).isElementPresent(By.XPATH, "//a[contains(@title,'Name: {}')]".format(
self.provider_name)):
self.web_session.logger.info("Container Provider added successfully.")

# Navigate to the provider details page and check if the last refresh status is - Success.
# Navigate to the openshift provider details page refresh relationships.

view(self.web_session).list_View()
assert ui_utils(self.web_session).waitForTextOnPage(self.web_session.OPENSHIFT_PROVIDER_NAME, 30)
ui_utils(self.web_session).click_on_row_containing_text(self.web_session.OPENSHIFT_PROVIDER_NAME)
view(self.web_session).list_View()
assert ui_utils(self.web_session).waitForTextOnPage(self.web_session.OPENSHIFT_PROVIDER_NAME, 30)
ui_utils(self.web_session).click_on_row_containing_text(self.web_session.OPENSHIFT_PROVIDER_NAME)
self.refresh_openshift_provider()

assert ui_utils(self.web_session).waitForTextOnPage("Status", 30)
# Refresh Middleware provider
servers(self.web_session).navigate_and_refresh_provider()

def validate_provider(self):
validate = WebDriverWait(self.web_driver, 10).until(EC.element_to_be_clickable((By.XPATH, "//button[contains(.,'Validate')]")))
Expand All @@ -163,3 +134,45 @@ def save_provider(self):

time.sleep(1)

def refresh_openshift_provider(self):
self.web_driver.find_element_by_xpath("//button[@title='Configuration']").click()
el = self.web_driver.find_element_by_id('ems_container_vmdb_choice__ems_container_refresh')
assert self.ui_utils.wait_until_element_displayed(el, 5)
el.click()
ui_utils(self.web_session).accept_alert(10)
ui_utils(self.web_session).waitForTextOnPage("Refresh Provider initiated", 15)
self.verify_refresh_success()

def verify_refresh_success(self):
self.web_driver.find_element_by_xpath("//button[@id='view_summary']").click()
ui_utils(self.web_session).waitForTextOnPage("Openshift-Provider (Summary)", 15)
ui_utils(self.web_session).refresh_until_text_appears('Success', 120)

def verify_hawkular_Services_crosslink(self):

self.web_session.web_driver.get("{}/middleware_server/show_list".format(self.web_session.MIQ_URL))
assert ui_utils(self.web_session).waitForTextOnPage("Local", 40)
self.web_driver.find_element_by_xpath("//span[contains(.,'Local')]").click()
assert ui_utils(self.web_session).waitForTextOnPage("Local (Summary)", 15)

while True:
timeout = time.time() + 60 * 5
if ui_utils(self.web_session).isElementPresent(By.XPATH,
"//td[contains(.,'Underlying Container')]") or time.time() > timeout:
break
else:
self.web_driver.refresh()

self.web_driver.find_element_by_xpath("//td[contains(.,'Underlying Container')]").click()
assert ui_utils(self.web_session).waitForTextOnPage("Containers Provider", 15)

return True

def verify_topology_crosslink_to_hawkular_services_container(self):
self.web_session.web_driver.get("{}/middleware_topology/show".format(self.web_session.MIQ_URL))
self.ui_utils.wait_until_element_displayed(self.web_driver.find_element_by_class_name('btn-default'), 10)
assert ui_utils(self.web_session).waitForTextOnPage("{}".format(self.openshift_container_name), 15)

return True