9:19 a.m.
Author: mgencur(a)redhat.com
Date: 2010-01-21 10:19:48 -0500 (Thu, 21 Jan 2010)
New Revision: 5546
Added:
ftest/numberguess/trunk/src/main/java/org/jboss/weld/example/numberguess/clustertest/
ftest/numberguess/trunk/src/main/java/org/jboss/weld/example/numberguess/clustertest/selenium/
ftest/numberguess/trunk/src/main/java/org/jboss/weld/example/numberguess/clustertest/selenium/NumberGuessClusteringTest.java
Log:
WELD-396 functional test for numberguess example in cluster
Added:
ftest/numberguess/trunk/src/main/java/org/jboss/weld/example/numberguess/clustertest/selenium/NumberGuessClusteringTest.java
===================================================================
---
ftest/numberguess/trunk/src/main/java/org/jboss/weld/example/numberguess/clustertest/selenium/NumberGuessClusteringTest.java
(rev 0)
+++
ftest/numberguess/trunk/src/main/java/org/jboss/weld/example/numberguess/clustertest/selenium/NumberGuessClusteringTest.java 2010-01-21
15:19:48 UTC (rev 5546)
@@ -0,0 +1,253 @@
+/*
+ * JBoss, Home of Professional Open Source
+ * Copyright 2008, Red Hat Middleware LLC, and individual contributors
+ * by the @authors tag. See the copyright.txt in the distribution for a
+ * full listing of individual contributors.
+ *
+ * This 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 software 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 software; if not, write to the Free
+ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
+ * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
+ */
+package org.jboss.weld.example.numberguess.clustertest.selenium;
+
+import static org.testng.Assert.assertTrue;
+import static org.testng.Assert.assertEquals;
+import static org.testng.Assert.fail;
+
+import java.io.IOException;
+
+import org.jboss.weld.example.common.test.selenium.WeldSelenium;
+import org.jboss.weld.example.common.test.selenium.WeldSeleniumTest;
+import org.testng.annotations.BeforeMethod;
+import org.testng.annotations.Test;
+
+/**
+ * This class tests Weld numberguess example in a cluster. Two instances of JBoss AS are
+ * being used. First part of test is executed at first (master) instance. Then the first
+ * instance is killed and a second (slave) instance takes over executing of the
application.
+ * This behaviour simulates recovery from breakdown and session replication.
+ *
+ * The first version of application server that can be used is JBoss 6.0.0.M1,
nevertheless this
+ * version of AS has to be updated with current version of Weld core.
+ *
+ * Prior to executing this test it is needed to start both JBoss AS instances manually.
+ * For example (assuming you have created second "all" configuration
("all2")):
+ * ./run.sh -c all -g DocsPartition -u 239.255.101.101 -b localhost
-Djboss.messaging.ServerPeerID=1
+ * -Djboss.service.binding.set=ports-default
+ * ./run.sh -c all2 -g DocsPartition -u 239.255.101.101 -b localhost
-Djboss.messaging.ServerPeerID=2
+ * -Djboss.service.binding.set=ports-01
+ * The configuration all is considered to be master jboss instance (related to
+ * jboss.service.binding.set=ports-default) and the application is deployed to farm
directory under
+ * chosen jboss configuration directory specified with jboss.master.configuration
property.
+ *
+ *
+ * @author mgencur
+ * @author kpiwko
+ *
+ */
+public class NumberGuessClusteringTest extends WeldSeleniumTest
+{
+
+ protected String MAIN_PAGE = "/home.jsf";
+ protected String GUESS_MESSAGES = "id=numberGuess:messages";
+ protected String GUESS_STATUS = "xpath=//div[contains(text(),'I'm
thinking of ')]";
+
+ protected String GUESS_FIELD = "id=numberGuess:inputGuess";
+ protected String GUESS_FIELD_WITH_VALUE =
"xpath=//input[@id='numberGuess:inputGuess'][@value=3]";
+
+ protected String GUESS_SUBMIT = "id=numberGuess:guessButton";
+ protected String GUESS_RESTART = "id=numberGuess:restartButton";
+ protected String GUESS_SMALLEST = "id=numberGuess:smallest";
+ protected String GUESS_BIGGEST = "id=numberGuess:biggest";
+
+ protected String WIN_MSG = "Correct!";
+ protected String LOSE_MSG = "No guesses left!";
+ protected String HIGHER_MSG = "Higher!";
+
+ private final String SECOND_INSTANCE_BROWSER_URL = "http://localhost:8180";
+ private final long JBOSS_SHUTDOWN_TIMEOUT = 20000;
+
+ private WeldSelenium browser2;
+
+ @BeforeMethod(dependsOnGroups = "seleniumSetUp")
+ public void open()
+ {
+ browser.open(contextPath + MAIN_PAGE);
+ browser.waitForPageToLoad();
+ deleteCookies(browser);
+ browser2 = startSecondBrowser();
+ deleteCookies(browser2);
+ }
+
+ @Test
+ public void guessingWithFailoverTest()
+ {
+ preFailurePart(browser);
+
+ String newAddress = getAddressForSecondInstance(browser);
+
+ shutdownMasterJBossInstance();
+
+ browser2.open(newAddress);
+
+ assertTrue(browser2.isTextPresent(HIGHER_MSG), "Page should contain message
Higher!");
+ assertEquals(Integer.parseInt(browser.getText(GUESS_SMALLEST)),4, "Page
should contain smallest number equal to 4");
+ assertEquals(Integer.parseInt(browser.getText(GUESS_BIGGEST)),100, "Page
should contain biggest number equal to 100");
+ assertTrue(browser2.isElementPresent(GUESS_FIELD_WITH_VALUE), "Page should
contain input field with value of 3");
+
+ postFailurePart(browser2);
+
+ assertTrue(isOnWinPage(browser2), "Win page expected after playing
smart.");
+ }
+
+ protected void preFailurePart(WeldSelenium browser)
+ {
+ int numberOfGuesses = 3;
+ int guess = 0;
+
+ //enter several guesses
+ while (true){
+ while (isOnGuessPage(browser) && guess < numberOfGuesses)
+ {
+ enterGuess(browser, ++guess);
+ }
+
+ //we always want to enter at least 3 guesses so that we can continue in the other
browser window with expected results
+ if (guess < numberOfGuesses)
+ {
+ resetForm(browser);
+ guess = 0;
+ }
+ else
+ {
+ break;
+ }
+ }
+ }
+
+ protected void postFailurePart(WeldSelenium browser)
+ {
+ int min, max, guess;
+ int i = 0;
+
+ while (isOnGuessPage(browser))
+ {
+ deleteCookies(browser);
+ if (i > 7)
+ {
+ fail("Game should not be longer than 7 guesses in the second browser
after failover");
+ }
+
+ assertTrue(browser.isElementPresent(GUESS_SMALLEST), "Expected smallest
number on page");
+ assertTrue(browser.isElementPresent(GUESS_BIGGEST), "Expected biggest
number on page");
+
+ min = Integer.parseInt(browser.getText(GUESS_SMALLEST));
+ max = Integer.parseInt(browser.getText(GUESS_BIGGEST));
+ guess = min + ((max - min) / 2);
+ enterGuess(browser, guess);
+ i++;
+ }
+ }
+
+ protected void resetForm(WeldSelenium browser)
+ {
+ browser.click(GUESS_RESTART);
+ browser.waitForPageToLoad();
+ }
+
+ protected void enterGuess(WeldSelenium browser, int guess)
+ {
+ browser.type(GUESS_FIELD, String.valueOf(guess));
+ browser.click(GUESS_SUBMIT);
+ browser.waitForPageToLoad();
+ }
+
+ protected boolean isOnGuessPage(WeldSelenium browser)
+ {
+ return !(isOnWinPage(browser) || isOnLosePage(browser));
+ }
+
+ protected boolean isOnWinPage(WeldSelenium browser)
+ {
+ String text = browser.getText(GUESS_MESSAGES);
+ return WIN_MSG.equals(text);
+ }
+
+ protected boolean isOnLosePage(WeldSelenium browser)
+ {
+ String text = browser.getText(GUESS_MESSAGES);
+ return LOSE_MSG.equals(text);
+ }
+
+ public WeldSelenium startSecondBrowser()
+ {
+ String url = SECOND_INSTANCE_BROWSER_URL;
+ return super.startBrowser(super.host, super.port, super.browserType, url);
+ }
+
+ public String getAddressForSecondInstance(WeldSelenium browser)
+ {
+ String loc = browser.getLocation();
+ String[] parsedStrings = loc.split("/");
+ StringBuilder sb = new StringBuilder();
+ for (int i = 3; i != parsedStrings.length; i++){
+ sb.append("/").append(parsedStrings[i]);
+ }
+
+ String sid;
+ if (browser.isCookiePresent("JSESSIONID"))
+ {
+ sid = browser.getCookieByName("JSESSIONID");
+ }
+ else
+ {
+ //get sessionid directly from browser URL if JSESSIONID cookie is not present
+ sid = loc.substring(loc.indexOf("jsessionid=") +
"jsessionid=".length(), loc.length());
+ }
+
+ String newAddress = sb.toString();
+ String firstPart = newAddress.substring(0, newAddress.indexOf(";"));
+
+ //construct a new address for second browser
+ newAddress = firstPart + ";jsessionid=" + sid;
+
+ return newAddress;
+ }
+
+ private void deleteCookies(WeldSelenium browser)
+ {
+ if (browser.isCookiePresent("JSESSIONID"))
+ {
+ browser.deleteCookie("JSESSIONID", "path=" + contextPath +
", domain=localhost, recurse=true");
+ }
+ }
+
+ public void shutdownMasterJBossInstance()
+ {
+ String command = super.jbossConfig + "/../../bin/shutdown.sh -s localhost:1099
-S";
+ try
+ {
+ Process process = Runtime.getRuntime().exec(command);
+ process.waitFor();
+ Thread.sleep(JBOSS_SHUTDOWN_TIMEOUT);
+ }
+ catch (IOException e)
+ {
+ throw new RuntimeException(e.getCause());
+ }
+ catch (InterruptedException e)
+ {
+ }
+ }
+}