/*
** Luxor - XML User Interface Language (XUL) Toolkit
** Copyright (c) 2001, 2002 by Gerald Bauer
**
** This program is free software.
**
** You may redistribute it and/or modify it under the terms of the GNU
** General Public License as published by the Free Software Foundation.
** Version 2 of the license should be included with this distribution in
** the file LICENSE, as well as License.html. If the license is not
** included with this distribution, you may find a copy at the FSF web
** site at 'www.gnu.org' or 'www.fsf.org', or you may write to the
** Free Software Foundation, 675 Mass Ave, Cambridge, MA 02139 USA.
**
** THIS SOFTWARE IS PROVIDED AS-IS WITHOUT WARRANTY OF ANY KIND,
** NOT EVEN THE IMPLIED WARRANTY OF MERCHANTABILITY. THE AUTHOR
** OF THIS SOFTWARE, ASSUMES _NO_ RESPONSIBILITY FOR ANY
** CONSEQUENCE RESULTING FROM THE USE, MODIFICATION, OR
** REDISTRIBUTION OF THIS SOFTWARE.
**
*/

package luxor.http;

import java.io.*;
import java.net.*;
import java.util.*;
import javax.swing.event.*;
import luxor.event.*;
import luxor.http.loader.*;
import luxor.spi.*;
import luxor.status.*;

public class WebServer extends Thread
{
   static Logger T = Logger.getLogger( WebServer.class );
   private EventListenerList _listener = new EventListenerList();
   private WebResourceLoader _loader;
   private int _numThreads = 10;

   private ServerSocket _server;

   public WebServer( int port, WebResourceLoader loader )
          throws IOException
   {
      _loader = loader;
      _server = new ServerSocket( port );
   }

   /**
    *  test driver
    */
   public static void main( String[] args )
   {
      int port = 5050;

      WebResourceManager rm = WebResourceManager.getWebResourceManager();
      rm.addResourceLoader( new FileResourceLoader( new File( "c:/www" ) ) );

      try
      {
         WebServer webServer = new WebServer( port, rm );
         webServer.start();
      }
      catch( IOException ioex )
      {
         Status.error( "*** failed to startup web service: " + ioex.toString() );
      }
   }

   public void addRequestListener( RequestListener l )
   {
      _listener.add( RequestListener.class, l );
   }

   public void removeRequestListener( RequestListener l )
   {
      _listener.remove( RequestListener.class, l );
   }

   public void run()
   {
      ThreadGroup tg = new ThreadGroup( "http" );

      for( int i = 0; i < _numThreads; i++ )
      {
         Thread t = new Thread( tg, new RequestProcessor( this, _loader ), "http-" + ( i + 1 ) );

         // note: event thread has priority 6
         //       screen updater thread has priority 4
         //       default priority is 5?
         //  use the same priority as the screen updater

         t.setPriority( 4 );
         t.setDaemon( true );
         t.start();
      }

      T.debug( "accepting connections on port " + _server.getLocalPort() );

      while( true )
      {
         try
         {
            Socket request = _server.accept();
            RequestProcessor.processRequest( request );
         }
         catch( IOException ioex )
         {
            Status.error( "*** i/o error in request processor: " + ioex.toString() );
         }
      }
   }

   protected void fireRequestAccepted( RequestResponseInfo info )
   {
      RequestListener l[] = ( RequestListener[] ) _listener.getListeners( RequestListener.class );
      for( int i = 0; i < l.length; i++ )
         l[i].requestAccepted( info );
   }

   protected void fireRequestServiced( RequestResponseInfo info )
   {
      RequestListener l[] = ( RequestListener[] ) _listener.getListeners( RequestListener.class );
      for( int i = 0; i < l.length; i++ )
         l[i].requestServiced( info );
   }

}