/**

  * Copyright 2006 Matthew Purland (m.purland@gmail.com)

  *

  *  Licensed 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 net.sf.mud4j.web.server;

 import java.io.IOException;

 import javax.servlet.ServletException;

 import javax.servlet.http.HttpServletRequest;

 import javax.servlet.http.HttpServletResponse;

 import org.mortbay.jetty.Connector;

 import org.mortbay.jetty.Handler;

 import org.mortbay.jetty.Request;

 import org.mortbay.jetty.Server;

 import org.mortbay.jetty.handler.AbstractHandler;

 import org.mortbay.jetty.nio.SelectChannelConnector;

 import org.mortbay.thread.BoundedThreadPool;

 /**

  * Provide a Jetty webserver that will use classes on the classpath or as

  * specified to configure the container.

  * 

  * @author Matthew Purland

  */

 public class JettyWebServer implements WebServer {

     // Jetty server

     private Server server;

     // Port to listen on

     private int port;

     /**

      * Constructor to provide configurable port listener.

      * 

      * @param port Port to listen on.

      */

     public JettyWebServer(int port) {

         this.port = port;

     }

     /**

      * Configure server servlets and configurations.

      * 

      * @throws IOException in case of Jetty configuration setup problem

      */

     protected void configureAndStartServer() throws IOException {

         try {

             server = new Server();

             Connector connector = new SelectChannelConnector();

             connector.setPort(port);

             // Create a thread pool to control number of threads for requests

             BoundedThreadPool threadPool = new BoundedThreadPool();

             threadPool.setMaxThreads(100);

             server.setThreadPool(threadPool);

             Handler handler = new AbstractHandler()

             {

                 public void handle(String target, HttpServletRequest request, HttpServletResponse response, int dispatch) throws IOException, ServletException {

                     response.setContentType("text/html");

                     response.setStatus(HttpServletResponse.SC_OK);

                     response.getWriter().println("<h1>testing</h1>");

                     ((Request)request).setHandled(true);

                 }

             };

             server.setHandler(handler);

             server.setStopAtShutdown(true);

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

             server.start();

             //server.join();

         }

         catch (Exception e) {

             throw new IOException(e.getMessage());

         }

     }

     /**

      * {@inheritDoc}

      */

     public void start() throws IOException {

         configureAndStartServer();

     }

     /**

      * {@inheritDoc}

      */

     public void stop() throws IOException {

         if (server != null) {

             try {

                 server.stop();

             }

             catch (Exception e) {

                 throw new IOException(e.getMessage());

             }

         }

     }

     /**

      * {@inheritDoc}

      */

     public boolean isStarted() {

         return server.isStarted();

     }

     /**

      * {@inheritDoc}

      */

     public boolean isStopped() {

         return server.isStopped();

     }

 }