/**

  * Copyright 2010 The Kuali Foundation Licensed under the

  * Educational Community 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.osedu.org/licenses/ECL-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.kuali.student.common.test.spring;

 import java.io.File;

 import org.junit.internal.runners.InitializationError;

 import org.junit.internal.runners.JUnit4ClassRunner;

 import org.junit.runner.notification.RunNotifier;

 import org.mortbay.jetty.Connector;

 import org.mortbay.jetty.Handler;

 import org.mortbay.jetty.Server;

 import org.mortbay.jetty.handler.DefaultHandler;

 import org.mortbay.jetty.handler.HandlerCollection;

 import org.mortbay.jetty.nio.SelectChannelConnector;

 import org.mortbay.jetty.webapp.WebAppContext;

 import org.slf4j.Logger;

 import org.slf4j.LoggerFactory;

 public class IntegrationServiceTestClassRunner extends JUnit4ClassRunner {

         final static Logger logger = LoggerFactory.getLogger(IntegrationServiceTestClassRunner.class);

         private Class<?> testClass;

         private Server server;

         private String webAppPath;

         private String contextPath;

         private int port = 9090;

         public IntegrationServiceTestClassRunner(Class<?> klass) throws InitializationError {

                 super(klass);

                 testClass = klass;

         }

         private void getAnnotations() {

                 IntegrationServer webapp = this.testClass.getAnnotation(IntegrationServer.class);

                 this.port = webapp.port();

                 this.webAppPath = webapp.webappPath();

                 this.contextPath = webapp.contextPath();

                 if (logger.isDebugEnabled()) {

                         logger.debug("port="+this.port);

                         logger.debug("webAppPath="+this.webAppPath);

                         logger.debug("contextPath="+this.contextPath);

                 }

         }

         private void setProperties() {

                 if (System.getProperty("catalina.base") == null) {

                         System.setProperty("catalina.base", "./target");

                 }

                 SystemProperties systemProperties = this.testClass.getAnnotation(SystemProperties.class);

                 if (systemProperties != null) {

                         for(Property property : systemProperties.properties()) {

                                 System.setProperty(property.key(), property.value());

                         }

                 }

         }

         @Override

         public void run(RunNotifier notifier) {

                 startServer();

                 super.run(notifier);

                 stopServer();

         }

         private void startServer() {

                 getAnnotations();

                 setProperties();

                 this.server = new Server();

                 Connector connector = new SelectChannelConnector();

                 connector.setPort(this.port);

                 this.server.setConnectors(new Connector[] { connector });

                 // Metro: Additional debugging info to console

                 // com.sun.xml.ws.transport.http.client.HttpTransportPipe.dump=true;      

                 String root = IntegrationServiceTestClassRunner.class.getResource("/").getPath();

                 File webAppsPath = new File(root + this.webAppPath);

                 try {

                     if(!webAppsPath.isDirectory()) {

                             throw new RuntimeException("Webapps directory does not exist. " +

                                             "Webapps directory must be an exploded (war) directory: " + 

                                             webAppsPath.getCanonicalPath());

                     }

                         if (logger.isDebugEnabled()) {

                                 logger.debug("WebApps Path="+webAppsPath.getCanonicalPath());

                         }

                         WebAppContext webAppcontext = new WebAppContext();

                         webAppcontext.setParentLoaderPriority(true);

                         webAppcontext.setContextPath(this.contextPath); // e.g. /brms-ws-0.1.0-SNAPSHOT

                         webAppcontext.setWar(webAppsPath.getCanonicalPath());

                         //webAppcontext.setTempDirectory(new File(root));

                         HandlerCollection handlers = new HandlerCollection();

                         handlers.setHandlers(new Handler[] { webAppcontext, new DefaultHandler() });

                         this.server.setHandler(handlers);

                         this.server.start();

                 } catch (Exception e) {

                         throw new RuntimeException("Starting Jetty server failed", e);

                 }

         }

         private void stopServer() {

                 try {

                         this.server.stop();

                 } catch (Exception e) {

                         throw new RuntimeException("Stopping Jetty server failed", e);

                 }

         }

 }