Repository: incubator-geode Updated Branches: refs/heads/develop e15657e9d -> a78fa7537
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/dfb87a59/geode-pulse/src/test/java/org/apache/geode/tools/pulse/tests/ui/PulseBaseTest.java ---------------------------------------------------------------------- diff --git a/geode-pulse/src/test/java/org/apache/geode/tools/pulse/tests/ui/PulseBaseTest.java b/geode-pulse/src/test/java/org/apache/geode/tools/pulse/tests/ui/PulseBaseTest.java new file mode 100644 index 0000000..8cfac53 --- /dev/null +++ b/geode-pulse/src/test/java/org/apache/geode/tools/pulse/tests/ui/PulseBaseTest.java @@ -0,0 +1,697 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * + */ +package org.apache.geode.tools.pulse.tests.ui; + +import static org.junit.Assert.*; + +import java.util.Collections; +import java.util.HashMap; +import java.util.List; +import java.util.Map; +import java.util.TreeMap; +import java.util.concurrent.TimeUnit; + +import org.openqa.selenium.By; +import org.openqa.selenium.WebElement; +import org.openqa.selenium.interactions.Actions; +import org.openqa.selenium.support.ui.ExpectedConditions; +import org.openqa.selenium.support.ui.WebDriverWait; + +import org.apache.geode.tools.pulse.tests.JMXProperties; +import org.apache.geode.tools.pulse.tests.Member; +import org.apache.geode.tools.pulse.tests.PulseTestData; +import org.apache.geode.tools.pulse.tests.PulseTestLocators; +import org.apache.geode.tools.pulse.tests.Region; + +public class PulseBaseTest { + + public static int maxWaitTime = 20; + + WebElement element = null; + + public WebElement findElementUsingId(String id) { + return PulseAbstractTest.driver.findElement(By.id(id)); + } + public WebElement findElementUsingXpath(String xpath) { + return PulseAbstractTest.driver.findElement(By.xpath(xpath)); + } + + public void clickElementUsingId(String id) { + findElementUsingId(id).click(); + } + + public void clickElementUsingXpath(String xpath) { + findElementUsingXpath(xpath).click(); + } + + public void enterTextUsingId(String id, String textToEnter) { + findElementUsingId(id).sendKeys(textToEnter); + + } + + public void enterTextUsingXpath(String xpath, String textToEnter) { + findElementUsingXpath(xpath).sendKeys(textToEnter); + } + + public String getValueFromPropertiesFile(String key) { + return JMXProperties.getInstance().getProperty(key); + } + + public void sendKeysUsingId(String Id, String textToEnter){ + findElementById(Id).sendKeys(textToEnter); + } + + public void waitForElement(WebElement element) { + PulseAbstractTest.driver.manage().timeouts().implicitlyWait(0, TimeUnit.SECONDS); + WebDriverWait wait = new WebDriverWait(PulseAbstractTest.driver, 20); + wait.until(ExpectedConditions.visibilityOf(element)); + } + + public WebElement findElementById(String id) { + return PulseAbstractTest.driver.findElement(By.id(id)); + } + + public WebElement findElementByXpath(String xpath) { + return PulseAbstractTest.driver.findElement(By.xpath(xpath)); + } + + public String getTextUsingXpath(String xpath) { + return findElementByXpath(xpath).getText(); + } + + public String getTextUsingId(String id) { + return findElementById(id).getText(); + } + + public String getPersistanceEnabled(Region r) { + String persitance = null; + + if (r.getPersistentEnabled()) { + persitance = "ON"; + } else if (!r.getPersistentEnabled()) { + persitance = "OFF"; + } + return persitance; + } + + public String getPersistanceEnabled(String trueOrFalse) { + String persitance = null; + + if (trueOrFalse.contains("true")) { + persitance = "ON"; + } else if (trueOrFalse.contains("false")) { + persitance = "OFF"; + } + return persitance; + } + + public String HeapUsage(String valueInKB) { + + return null; + } + + // WIP - need to work on this -- + public HashMap<String, HashMap<String, Region>> getRegionDetailsFromUI(String regionName) { + + String[] regionNames = JMXProperties.getInstance().getProperty("regions").split(" "); + HashMap<String, HashMap<String, Region>> regionUiMap = new HashMap<String, HashMap<String, Region>>(); + + for (String region : regionNames) { + HashMap<String, Region> regionMap = regionUiMap.get(region); + } + + return regionUiMap; + } + + public void validateServerGroupGridData() { + List<WebElement> serverGridRows = PulseAbstractTest.driver.findElements(By.xpath("//table[@id='memberListSG']/tbody/tr")); + int rowsCount = serverGridRows.size(); + String[][] gridDataFromUI = new String[rowsCount][7]; + + for (int j = 2, x = 0; j <= serverGridRows.size(); j++, x++) { + for (int i = 0; i <= 6; i++) { + gridDataFromUI[x][i] = PulseAbstractTest.driver.findElement( + By.xpath("//table[@id='memberListSG']/tbody/tr[" + j + "]/td[" + (i + 1) + "]")).getText(); + } + } + + String[] memberNames = JMXProperties.getInstance().getProperty("members").split(" "); + HashMap<String, HashMap<String, Member>> sgMap = new HashMap<String, HashMap<String, Member>>(); + + for (String member : memberNames) { + Member thisMember = new Member(member); + String[] sgs = thisMember.getGroups(); + + for (String sgName : sgs) { + HashMap<String, Member> sgMembers = sgMap.get(sgName); + if (sgMembers == null) { + sgMembers = new HashMap<String, Member>(); + sgMap.put(sgName, sgMembers); + } + sgMembers.put(thisMember.getMember(), thisMember); + } + } + + for (int i = 0; i < gridDataFromUI.length - 1; i++) { + String sgName = gridDataFromUI[i][0]; + String memName = gridDataFromUI[i][1]; + Member m = sgMap.get(sgName).get(memName); + + assertEquals(sgName, gridDataFromUI[i][0]); + assertEquals(memName, gridDataFromUI[i][1]); + assertEquals(m.getMember(), gridDataFromUI[i][2]); + assertEquals(m.getHost(), gridDataFromUI[i][3]); + String cupUsage = String.valueOf(m.getCpuUsage()); + assertEquals(cupUsage, gridDataFromUI[i][5]); + } + + } + + public void validateRedundancyZonesGridData() { + List<WebElement> rzGridRows = PulseAbstractTest.driver.findElements(By.xpath("//table[@id='memberListRZ']/tbody/tr")); + int rowsCount = rzGridRows.size(); + String[][] gridDataFromUI = new String[rowsCount][7]; + + for (int j = 2, x = 0; j <= rzGridRows.size(); j++, x++) { + for (int i = 0; i <= 6; i++) { + gridDataFromUI[x][i] = PulseAbstractTest.driver.findElement( + By.xpath("//table[@id='memberListRZ']/tbody/tr[" + j + "]/td[" + (i + 1) + "]")).getText(); + } + } + + String[] memberNames = JMXProperties.getInstance().getProperty("members").split(" "); + HashMap<String, HashMap<String, Member>> rzMap = new HashMap<String, HashMap<String, Member>>(); + + for (String member : memberNames) { + Member thisMember = new Member(member); + //String[] rz = thisMember.getRedundancyZone(); + String sgName = thisMember.getRedundancyZone(); + + //for (String sgName : rz) { + HashMap<String, Member> rzMembers = rzMap.get(sgName); + + if (rzMembers == null) { + rzMembers = new HashMap<String, Member>(); + rzMap.put(sgName, rzMembers); + } + + rzMembers.put(thisMember.getMember(), thisMember); + //} + } + + for (int i = 0; i < gridDataFromUI.length - 1; i++) { + String sgName = gridDataFromUI[i][0]; + String memName = gridDataFromUI[i][1]; + Member m = rzMap.get(sgName).get(memName); + + assertEquals(sgName, gridDataFromUI[i][0]); + assertEquals(memName, gridDataFromUI[i][1]); + assertEquals(m.getMember(), gridDataFromUI[i][2]); + assertEquals(m.getHost(), gridDataFromUI[i][3]); + String cupUsage = String.valueOf(m.getCpuUsage()); + assertEquals(cupUsage, gridDataFromUI[i][5]); + } + + } + + public void validateTopologyGridData() { + List<WebElement> rzGridRows = PulseAbstractTest.driver.findElements(By.xpath("//table[@id='memberList']/tbody/tr")); + int rowsCount = rzGridRows.size(); + String[][] gridDataFromUI = new String[rowsCount][8]; + + for (int j = 2, x = 0; j <= rzGridRows.size(); j++, x++) { + for (int i = 0; i <= 7; i++) { + gridDataFromUI[x][i] = PulseAbstractTest.driver.findElement( + By.xpath("//table[@id='memberList']/tbody/tr[" + j + "]/td[" + (i + 1) + "]")).getText(); + } + } + + String[] memberNames = JMXProperties.getInstance().getProperty("members").split(" "); + HashMap<String, Member> tpMap = new HashMap<String, Member>(); + + for (String member : memberNames) { + Member thisMember = new Member(member); + tpMap.put(thisMember.getMember(), thisMember); + + } + + for (int i = 0; i < gridDataFromUI.length - 1; i++) { + + String memName = gridDataFromUI[i][0]; + Member m = tpMap.get(memName); + + assertEquals(m.getMember(), gridDataFromUI[i][0]); + assertEquals(m.getMember(), gridDataFromUI[i][1]); + assertEquals(m.getHost(), gridDataFromUI[i][2]); + String cupUsage = String.valueOf(m.getCpuUsage()); + assertEquals(cupUsage, gridDataFromUI[i][5]); + } + } + + public void validateDataPrespectiveGridData() { + List<WebElement> serverGridRows = PulseAbstractTest.driver.findElements(By.xpath("//table[@id='regionsList']/tbody/tr")); + int rowsCount = serverGridRows.size(); + String[][] gridDataFromUI = new String[rowsCount][7]; + + for (int j = 2, x = 0; j <= serverGridRows.size(); j++, x++) { + for (int i = 0; i <= 6; i++) { + if (i < 5) { + gridDataFromUI[x][i] = PulseAbstractTest.driver.findElement( + By.xpath("//table[@id='regionsList']/tbody/tr[" + j + "]/td[" + (i + 1) + "]")).getText(); + } else if (i == 5) { + gridDataFromUI[x][i] = PulseAbstractTest.driver.findElement( + By.xpath("//table[@id='regionsList']/tbody/tr[" + j + "]/td[" + (i + 4) + "]")).getText(); + } + } + } + + String[] regionNames = JMXProperties.getInstance().getProperty("regions").split(" "); + HashMap<String, Region> dataMap = new HashMap<String, Region>(); + + for (String region : regionNames) { + Region thisRegion = new Region(region); + dataMap.put(thisRegion.getName(), thisRegion); + + } + + for (int i = 0; i < gridDataFromUI.length - 1; i++) { + String memName = gridDataFromUI[i][0]; + Region r = dataMap.get(memName); + + assertEquals(r.getName(), gridDataFromUI[i][0]); + assertEquals(r.getRegionType(), gridDataFromUI[i][1]); + + assertEquals(String.valueOf(r.getSystemRegionEntryCount()), gridDataFromUI[i][2]); + assertEquals(r.getFullPath(), gridDataFromUI[i][4]); + assertEquals(getPersistanceEnabled(r), gridDataFromUI[i][5]); + } + } + + public void validateRegionDetailsGridData() { + List<WebElement> serverGridRows = PulseAbstractTest.driver.findElements(By.xpath("//table[@id='memberList']/tbody/tr")); + int rowsCount = serverGridRows.size(); + String[][] gridDataFromUI = new String[rowsCount][7]; + + for (int j = 2, x = 0; j <= serverGridRows.size(); j++, x++) { + for (int i = 0; i < 2; i++) { + gridDataFromUI[x][i] = PulseAbstractTest.driver.findElement( + By.xpath("//table[@id='memberList']/tbody/tr[" + j + "]/td[" + (i + 1) + "]")).getText(); + } + } + + String[] memberNames = JMXProperties.getInstance().getProperty("members").split(" "); + HashMap<String, Member> tpMap = new HashMap<String, Member>(); + + for (String member : memberNames) { + Member thisMember = new Member(member); + tpMap.put(thisMember.getMember(), thisMember); + } + + for (int i = 0; i < gridDataFromUI.length - 1; i++) { + + String memName = gridDataFromUI[i][0]; + Member m = tpMap.get(memName); + assertEquals(m.getMember(), gridDataFromUI[i][0]); + } + + } + + public void navigateToToplogyView(){ + clickElementUsingXpath(PulseTestLocators.TopNavigation.clusterViewLinkXpath); + clickElementUsingXpath(PulseTestLocators.TopologyView.radioButtonXpath); + } + + public void navigateToServerGroupGView(){ + clickElementUsingXpath(PulseTestLocators.TopNavigation.clusterViewLinkXpath); + clickElementUsingXpath(PulseTestLocators.ServerGroups.radioButtonXpath); + } + + public void navigateToRedundancyZoneView(){ + clickElementUsingXpath(PulseTestLocators.TopNavigation.clusterViewLinkXpath); + clickElementUsingXpath(PulseTestLocators.RedundancyZone.radioButtonXpath); + } + + // ------ Topology / Server Group / Redundancy Group - Tree View + + public void navigateToTopologyTreeView(){ + navigateToToplogyView(); + clickElementUsingId(PulseTestLocators.TopologyView.treeMapButtonId); + } + + public void navigateToServerGroupTreeView() { + clickElementUsingXpath(PulseTestLocators.TopNavigation.clusterViewLinkXpath); + clickElementUsingXpath(PulseTestLocators.ServerGroups.radioButtonXpath); + } + + public void navigateToRedundancyZonesTreeView() { + clickElementUsingXpath(PulseTestLocators.TopNavigation.clusterViewLinkXpath); + clickElementUsingXpath(PulseTestLocators.RedundancyZone.radioButtonXpath); + } + + // ------ Topology / Server Group / Redundancy Group - Grid View + + public void navigateToTopologyGridView() { + clickElementUsingXpath(PulseTestLocators.TopNavigation.clusterViewLinkXpath); + clickElementUsingXpath(PulseTestLocators.TopologyView.radioButtonXpath); + clickElementUsingId(PulseTestLocators.TopologyView.gridButtonId); + } + + public void navigateToServerGroupGridView() { + clickElementUsingXpath(PulseTestLocators.TopNavigation.clusterViewLinkXpath); + clickElementUsingXpath(PulseTestLocators.ServerGroups.radioButtonXpath); + clickElementUsingId(PulseTestLocators.ServerGroups.gridButtonId); + } + + public void navigateToRedundancyZonesGridView() { + clickElementUsingXpath(PulseTestLocators.TopNavigation.clusterViewLinkXpath); + clickElementUsingXpath(PulseTestLocators.RedundancyZone.radioButtonXpath); + clickElementUsingId(PulseTestLocators.RedundancyZone.gridButtonId); + } + + // ----- Data perspective / region details + + public void navigateToDataPrespectiveGridView() { + clickElementUsingXpath(PulseTestLocators.TopNavigation.clusterViewLinkXpath); + clickElementUsingXpath(PulseTestLocators.DataPerspectiveView.downarrowButtonXpath); + clickElementUsingXpath(PulseTestLocators.DataPerspectiveView.dataViewButtonXpath); + clickElementUsingId(PulseTestLocators.DataPerspectiveView.gridButtonId); + } + + public void navigateToRegionDetailsView() { + clickElementUsingXpath(PulseTestLocators.TopNavigation.clusterViewLinkXpath); + clickElementUsingXpath(PulseTestLocators.DataPerspectiveView.downarrowButtonXpath); + clickElementUsingXpath(PulseTestLocators.DataPerspectiveView.dataViewButtonXpath); + // clickElementUsingXpath(PulseTestLocators.RegionDetailsView.regionNameXpath); + // // WIP - region navigation defect needs to fixed + clickElementUsingXpath(PulseTestLocators.RegionDetailsView.treeMapCanvasXpath); + } + + public void navigateToRegionDetailsGridView() { + navigateToRegionDetailsView(); + clickElementUsingXpath(PulseTestLocators.RegionDetailsView.gridButtonXpath); + } + + public String getPropertyValue(String propertyKey) { + String propertyValue = JMXProperties.getInstance().getProperty(propertyKey); + return propertyValue; + } + + public void verifyElementPresentById(String id) { + WebDriverWait wait = new WebDriverWait(PulseAbstractTest.driver, maxWaitTime, 500); + wait.until(ExpectedConditions.presenceOfAllElementsLocatedBy(By.id(id))); + } + + public void verifyElementPresentByLinkText(String lnkText) { + WebDriverWait wait = new WebDriverWait(PulseAbstractTest.driver, maxWaitTime, 500); + wait.until(ExpectedConditions.presenceOfAllElementsLocatedBy(By.linkText(lnkText))); + } + + public void verifyElementPresentByXpath(String xpath) { + WebDriverWait wait = new WebDriverWait(PulseAbstractTest.driver, maxWaitTime, 500); + wait.until(ExpectedConditions.presenceOfAllElementsLocatedBy(By.xpath(xpath))); + } + + public void verifyTextPresrntById(String id, String text) { + WebDriverWait wait = new WebDriverWait(PulseAbstractTest.driver, maxWaitTime, 500); + wait.until(ExpectedConditions.textToBePresentInElementLocated(By.id(id), text)); + } + + public void verifyTextPresrntByXpath(String xpath, String text) { + WebDriverWait wait = new WebDriverWait(PulseAbstractTest.driver, maxWaitTime, 500); + wait.until(ExpectedConditions.textToBePresentInElementLocated(By.xpath(xpath), text)); + } + + public void verifyElementAttributeById(String id, String attribute, String value) { + String actualValue = findElementById(id).getAttribute(attribute); + assertTrue(actualValue.equals(value) || actualValue.contains(value)); + } + + + public void mouseReleaseById(String id){ + verifyElementPresentById(id); + Actions action = new Actions(PulseAbstractTest.driver); + WebElement we = PulseAbstractTest.driver.findElement(By.id(id)); + action.moveToElement(we).release().perform(); + } + public void mouseClickAndHoldOverElementById(String id) { + verifyElementPresentById(id); + Actions action = new Actions(PulseAbstractTest.driver); + WebElement we = PulseAbstractTest.driver.findElement(By.id(id)); + action.moveToElement(we).clickAndHold().perform(); + } + + public void mouseOverElementByXpath(String xpath) { + Actions action = new Actions(PulseAbstractTest.driver); + WebElement we = PulseAbstractTest.driver.findElement(By.xpath(xpath)); + action.moveToElement(we).build().perform(); + } + + + public float stringToFloat(String stringValue){ + float floatNum = Float.parseFloat(stringValue); + return floatNum; + } + + public String floatToString(float floatValue){ + String stringValue = Float.toString(floatValue); + return stringValue; + } + + + public String[] splitString(String stringToSplit, String splitDelimiter){ + String [] stringArray = stringToSplit.split(splitDelimiter); + return stringArray; + } + + public void assertMemberSortingByCpuUsage(){ + Map<Double, String> memberMap = new TreeMap<>(Collections.reverseOrder()); + String [] membersNames = splitString(JMXProperties.getInstance().getProperty("members"), " "); + for (String member : membersNames) { + Member thisMember = new Member(member); + memberMap.put(thisMember.getCpuUsage(), thisMember.getMember()); + } + for(Map.Entry<Double,String> entry : memberMap.entrySet()) { + //here matching painting style to validation that the members are painted according to their cpu usage + String refMemberCPUUsage = null; + if(entry.getValue().equalsIgnoreCase("M1")){ + refMemberCPUUsage = PulseTestData.Topology.cpuUsagePaintStyleM1; + }else if(entry.getValue().equalsIgnoreCase("M2")){ + refMemberCPUUsage = PulseTestData.Topology.cpuUsagePaintStyleM2; + }else{ + refMemberCPUUsage = PulseTestData.Topology.cpuUsagePaintStyleM3; + } + assertTrue(findElementById(entry.getValue()).getAttribute("style").contains(refMemberCPUUsage)); + } + } + + public void assertMemberSortingByHeapUsage(){ + Map<Long, String> memberMap = new TreeMap<Long,String>(Collections.reverseOrder()); + String [] membersNames = splitString(JMXProperties.getInstance().getProperty("members"), " "); + for (String member : membersNames) { + Member thisMember = new Member(member); + memberMap.put(thisMember.getCurrentHeapSize(), thisMember.getMember()); + } + for(Map.Entry<Long, String> entry : memberMap.entrySet()) { + //here matching painting style to validation that the members are painted according to their cpu usage + String refMemberHeapUsage = null; + if(entry.getValue().equalsIgnoreCase("M1")){ + refMemberHeapUsage = PulseTestData.Topology.heapUsagePaintStyleM1; + }else if(entry.getValue().equalsIgnoreCase("M2")){ + refMemberHeapUsage = PulseTestData.Topology.heapUsagePaintStyleM2; + }else{ + refMemberHeapUsage = PulseTestData.Topology.heapUsagePaintStyleM3; + } + assertTrue(findElementById(entry.getValue()).getAttribute("style").contains(refMemberHeapUsage)); + } + } + + public void assertMemberSortingBySGCpuUsage(){ + Map<Double, String> memberMap = new TreeMap<>(Collections.reverseOrder()); + String [] membersNames = splitString(JMXProperties.getInstance().getProperty("members"), " "); + for (String member : membersNames) { + Member thisMember = new Member(member); + memberMap.put(thisMember.getCpuUsage(), thisMember.getMember()); + } + for(Map.Entry<Double,String> entry : memberMap.entrySet()) { + //here matching painting style to validation that the members are painted according to their cpu usage + String refMemberCPUUsage = null; + if(entry.getValue().equalsIgnoreCase("M1")){ + refMemberCPUUsage = PulseTestData.Topology.cpuUsagePaintStyleM1; + }else if(entry.getValue().equalsIgnoreCase("M2")){ + refMemberCPUUsage = PulseTestData.Topology.cpuUsagePaintStyleM2; + }else{ + refMemberCPUUsage = PulseTestData.Topology.cpuUsagePaintStyleM3; + } + assertTrue(findElementById(entry.getValue()).getAttribute("style").contains(refMemberCPUUsage)); + } + } + + + public void assertMemberSortingBySgHeapUsage(){ + String[] memberNames = JMXProperties.getInstance().getProperty("members").split(" "); + HashMap<String, HashMap<String, Member>> sgMap = new HashMap<String, HashMap<String, Member>>(); + for (String member : memberNames) { + Member thisMember = new Member(member); + String[] sgs = thisMember.getGroups(); + + for (String sgName : sgs) { + HashMap<String, Member> sgMembers = sgMap.get(sgName); + if (sgMembers == null) { + sgMembers = new HashMap<String, Member>(); + sgMap.put(sgName, sgMembers); + } + sgMembers.put(thisMember.getMember(), thisMember); + } + } + Map<Float, String> memberMap = new TreeMap<Float,String>(Collections.reverseOrder()); + + for(int sgId=1; sgId<=3; sgId++){ + String sgName = "SG1"; + String memName = "M" + sgId; + Member m = sgMap.get(sgName).get(memName); + memberMap.put((float) m.getCurrentHeapSize(), m.getMember()); + } + + for(Map.Entry<Float,String> entry : memberMap.entrySet()) { + //here matching painting style to validation that the members are painted according to their cpu usage + String refMemberCPUUsage = null; + if(entry.getValue().equalsIgnoreCase("M1")){ + refMemberCPUUsage = PulseTestData.ServerGroups.heapUsagePaintStyleSG1M1; + }else if(entry.getValue().equalsIgnoreCase("M2")){ + refMemberCPUUsage = PulseTestData.ServerGroups.heapUsagePaintStyleSG1M2; + }else{ + refMemberCPUUsage = PulseTestData.ServerGroups.heapUsagePaintStyleSG1M3; + } + assertTrue(findElementById("SG1(!)"+entry.getValue()).getAttribute("style").contains(refMemberCPUUsage)); + } + } + + + + public void assertMemberSortingBySgCpuUsage(){ + String[] memberNames = JMXProperties.getInstance().getProperty("members").split(" "); + HashMap<String, HashMap<String, Member>> sgMap = new HashMap<String, HashMap<String, Member>>(); + for (String member : memberNames) { + Member thisMember = new Member(member); + String[] sgs = thisMember.getGroups(); + + for (String sgName : sgs) { + HashMap<String, Member> sgMembers = sgMap.get(sgName); + if (sgMembers == null) { + sgMembers = new HashMap<String, Member>(); + sgMap.put(sgName, sgMembers); + } + sgMembers.put(thisMember.getMember(), thisMember); + } + } + Map<Double, String> memberMap = new TreeMap<>(Collections.reverseOrder()); + //SG3(!)M3 + for(int sgId=1; sgId<=3; sgId++){ + String sgName = "SG1"; + String memName = "M" + sgId; + Member m = sgMap.get(sgName).get(memName); + memberMap.put(m.getCpuUsage(), m.getMember()); + } + + for(Map.Entry<Double,String> entry : memberMap.entrySet()) { + //here matching painting style to validation that the members are painted according to their cpu usage + String refMemberCPUUsage = null; + if(entry.getValue().equalsIgnoreCase("M1")){ + refMemberCPUUsage = PulseTestData.ServerGroups.cpuUsagePaintStyleSG1M1; + }else if(entry.getValue().equalsIgnoreCase("M2")){ + refMemberCPUUsage = PulseTestData.ServerGroups.cpuUsagePaintStyleSG1M2; + }else{ + refMemberCPUUsage = PulseTestData.ServerGroups.cpuUsagePaintStyleSG1M3; + } + assertTrue(findElementById("SG1(!)"+entry.getValue()).getAttribute("style").contains(refMemberCPUUsage)); + } + } + + public void assertMemberSortingByRzHeapUsage(){ + String[] memberNames = JMXProperties.getInstance().getProperty("members").split(" "); + HashMap<String, HashMap<String, Member>> rzMap = new HashMap<String, HashMap<String, Member>>(); + for (String member : memberNames) { + Member thisMember = new Member(member); + String sgName = thisMember.getRedundancyZone(); + HashMap<String, Member> rzMembers = rzMap.get(sgName); + + if (rzMembers == null) { + rzMembers = new HashMap<String, Member>(); + rzMap.put(sgName, rzMembers); + } + + rzMembers.put(thisMember.getMember(), thisMember); + } + Map<Float, String> memberMap = new TreeMap<Float,String>(Collections.reverseOrder()); + String rzName = "RZ1 RZ2"; + String memName = "M1" ; + Member m = rzMap.get(rzName).get(memName); + memberMap.put((float) m.getCurrentHeapSize(), m.getMember()); + + for(Map.Entry<Float,String> entry : memberMap.entrySet()) { + //here matching painting style to validation that the members are painted according to their cpu usage + String refMemberHeapUsage = null; + if(entry.getValue().equalsIgnoreCase("M1")){ + refMemberHeapUsage = PulseTestData.RedundancyZone.heapUsagePaintStyleRZ1RZ2M1; + }else if(entry.getValue().equalsIgnoreCase("M2")){ + refMemberHeapUsage = PulseTestData.RedundancyZone.heapUsagePaintStyleRZ1RZ2M2; + }else{ + refMemberHeapUsage = PulseTestData.RedundancyZone.heapUsagePaintStyleRZ3M3; + } + assertTrue(findElementById("RZ1 RZ2(!)"+entry.getValue()).getAttribute("style").contains(refMemberHeapUsage)); + } + } + + public void assertMemeberSortingByRzCpuUsage(){ + String[] memberNames = JMXProperties.getInstance().getProperty("members").split(" "); + HashMap<String, HashMap<String, Member>> rzMap = new HashMap<String, HashMap<String, Member>>(); + for (String member : memberNames) { + Member thisMember = new Member(member); + String sgName = thisMember.getRedundancyZone(); + HashMap<String, Member> rzMembers = rzMap.get(sgName); + + if (rzMembers == null) { + rzMembers = new HashMap<String, Member>(); + rzMap.put(sgName, rzMembers); + } + + rzMembers.put(thisMember.getMember(), thisMember); + } + Map<Double, String> memberMap = new TreeMap<>(Collections.reverseOrder()); + String rzName = "RZ1 RZ2"; + String memName = "M1" ; + Member m = rzMap.get(rzName).get(memName); + memberMap.put(m.getCpuUsage(), m.getMember()); + + for(Map.Entry<Double,String> entry : memberMap.entrySet()) { + //here matching painting style to validation that the members are painted according to their cpu usage + String refMemberCPUUsage = null; + if(entry.getValue().equalsIgnoreCase("M1")){ + refMemberCPUUsage = PulseTestData.RedundancyZone.cpuUsagePaintStyleRZ1RZ2M1; + }else if(entry.getValue().equalsIgnoreCase("M2")){ + refMemberCPUUsage = PulseTestData.RedundancyZone.cpuUsagePaintStyleRZ1RZ2M2; + } + assertTrue(findElementById("RZ1 RZ2(!)"+entry.getValue()).getAttribute("style").contains(refMemberCPUUsage)); + } + } + + public List<WebElement> getRegionsFromDataBrowser(){ + List<WebElement> regionList = PulseAbstractTest.driver.findElements(By.xpath("//span[starts-with(@ID,'treeDemo_')][contains(@id,'_span')]")); + return regionList; + } +} http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/dfb87a59/geode-pulse/src/test/java/org/apache/geode/tools/pulse/tests/ui/PulseNoAuthTest.java ---------------------------------------------------------------------- diff --git a/geode-pulse/src/test/java/org/apache/geode/tools/pulse/tests/ui/PulseNoAuthTest.java b/geode-pulse/src/test/java/org/apache/geode/tools/pulse/tests/ui/PulseNoAuthTest.java new file mode 100644 index 0000000..8d62786 --- /dev/null +++ b/geode-pulse/src/test/java/org/apache/geode/tools/pulse/tests/ui/PulseNoAuthTest.java @@ -0,0 +1,34 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * + */ +package org.apache.geode.tools.pulse.tests.ui; + +import org.apache.geode.test.junit.categories.UITest; +import org.junit.BeforeClass; +import org.junit.FixMethodOrder; +import org.junit.experimental.categories.Category; +import org.junit.runners.MethodSorters; + +@Category(UITest.class) +@FixMethodOrder(MethodSorters.JVM) +public class PulseNoAuthTest extends PulseAbstractTest { + + @BeforeClass + public static void beforeClassSetup() throws Exception { + setUpServer("admin", "admin", null); + } +} http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/dfb87a59/gradle/dependency-versions.properties ---------------------------------------------------------------------- diff --git a/gradle/dependency-versions.properties b/gradle/dependency-versions.properties index 91870e0..50af2aa 100644 --- a/gradle/dependency-versions.properties +++ b/gradle/dependency-versions.properties @@ -84,6 +84,7 @@ mx4j-remote.version = 3.0.1 mx4j-tools.version = 3.0.1 netty-all.version = 4.0.4.Final paranamer.version = 2.3 +phantomjsdriver.version=1.2.1 powermock.version = 1.6.4 quartz.version = 2.2.1 scala.version = 2.10.0
