2005-04-07 21:19:42 +02:00
// httpdFileHandler.java
// -----------------------
// (C) by Michael Peter Christen; mc@anomic.de
// first published on http://www.anomic.de
2005-10-05 10:40:20 +02:00
// Frankfurt, Germany, 2004, 2005
// last major change: 05.10.2005
2005-04-07 21:19:42 +02:00
//
// This program is free software; you can redistribute it and/or modify
// it under the terms of the GNU General Public License as published by
// the Free Software Foundation; either version 2 of the License, or
// (at your option) any later version.
//
// This program 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 General Public License for more details.
//
// You should have received a copy of the GNU General Public License
// along with this program; if not, write to the Free Software
// Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
//
// Using this software in any meaning (reading, learning, copying, compiling,
// running) means that you agree that the Author(s) is (are) not responsible
// for cost, loss of data or any harm that may be caused directly or indirectly
// by usage of this softare or this documentation. The usage of this software
// is on your own risk. The installation and usage (starting/running) of this
// software may allow other people or application to access your computer and
// any attached devices and is highly dependent on the configuration of the
// software which must be done by the user of the software; the author(s) is
// (are) also not responsible for proper configuration and usage of the
// software, even if provoked by documentation provided together with
// the software.
//
// Any changes to this file according to the GPL as documented in the file
// gpl.txt aside this file in the shipment you received can be done to the
// lines that follows this copyright notice here, but changes must not be
// done inside the copyright notive above. A re-distribution must contain
// the intact and unchanged copyright notice.
// Contributions and changes to the program code must be marked as such.
/ *
2005-06-09 12:12:07 +02:00
Class documentation :
this class provides a file servlet and CGI interface
for the httpd server .
Whenever this server is addressed to load a local file ,
this class searches for the file in the local path as
configured in the setting property ' rootPath '
The servlet loads the file and returns it to the client .
Every file can also act as an template for the built - in
CGI interface . There is no specific path for CGI functions .
CGI functionality is triggered , if for the file to - be - served
' template . html ' also a file ' template . class ' exists . Then ,
the class file is called with the GET / POST properties that
are attached to the http call .
Possible variable hand - over are :
- form method GET
- form method POST , enctype text / plain
- form method POST , enctype multipart / form - data
The class that creates the CGI respond must have at least one
static method of the form
public static java . util . Hashtable respond ( java . util . HashMap , serverSwitch )
In the HashMap , the GET / POST variables are handed over .
The return value is a Property object that contains replacement
key / value pairs for the patterns in the template file .
The templates must have the form
either ' # [ ' < name > ' ] # ' for single attributes , or
' # { ' < enumname > ' } # ' and ' # { / ' < enumname > ' } # ' for enumerations of
values ' # [ ' < value > ' ] # ' .
A single value in repetitions / enumerations in the template has
the property key '_' < enumname > < count > '_' < value >
Please see also the example files ' test . html ' and ' test . java '
* /
2005-04-07 21:19:42 +02:00
package de.anomic.http ;
2006-04-03 00:59:53 +02:00
import java.awt.Image ;
import java.awt.image.BufferedImage ;
2005-09-12 12:47:27 +02:00
import java.io.BufferedInputStream ;
2005-09-09 13:14:22 +02:00
import java.io.ByteArrayInputStream ;
2005-05-05 07:32:19 +02:00
import java.io.File ;
import java.io.FileInputStream ;
import java.io.IOException ;
import java.io.InputStream ;
import java.io.OutputStream ;
import java.io.PushbackInputStream ;
2006-04-23 13:01:31 +02:00
import java.io.UnsupportedEncodingException ;
2005-09-09 13:14:22 +02:00
import java.lang.ref.SoftReference ;
2005-05-05 07:32:19 +02:00
import java.lang.reflect.InvocationTargetException ;
import java.lang.reflect.Method ;
2006-04-23 13:01:31 +02:00
import java.net.URLDecoder ;
2005-05-05 07:32:19 +02:00
import java.util.Date ;
import java.util.HashMap ;
import java.util.Iterator ;
import java.util.Map ;
import java.util.Properties ;
2005-09-09 13:14:22 +02:00
import java.util.logging.Level ;
2005-09-22 12:30:55 +02:00
import java.util.zip.GZIPInputStream ;
2005-06-09 12:12:07 +02:00
import java.util.zip.GZIPOutputStream ;
2005-12-22 15:05:05 +01:00
2008-02-18 17:38:06 +01:00
import de.anomic.htmlFilter.htmlFilterContentScraper ;
2005-10-12 22:45:14 +02:00
import de.anomic.plasma.plasmaParser ;
2005-12-22 15:05:05 +01:00
import de.anomic.plasma.plasmaSwitchboard ;
2005-10-10 09:15:57 +02:00
import de.anomic.server.serverByteBuffer ;
2005-05-05 07:32:19 +02:00
import de.anomic.server.serverClassLoader ;
import de.anomic.server.serverCore ;
2007-08-22 02:59:05 +02:00
import de.anomic.server.serverDate ;
2005-05-05 07:32:19 +02:00
import de.anomic.server.serverFileUtils ;
import de.anomic.server.serverObjects ;
import de.anomic.server.serverSwitch ;
2006-10-21 17:01:53 +02:00
import de.anomic.server.servletProperties ;
2005-06-09 12:12:07 +02:00
import de.anomic.server.logging.serverLog ;
2007-01-16 00:31:50 +01:00
import de.anomic.ymage.ymageMatrix ;
2005-04-07 21:19:42 +02:00
2007-08-09 23:58:38 +02:00
public final class httpdFileHandler {
2005-06-09 12:12:07 +02:00
2006-08-07 02:19:01 +02:00
private static final boolean safeServletsMode = false ; // if true then all servlets are called synchronized
2005-08-31 11:22:55 +02:00
private static final Properties mimeTable = new Properties ( ) ;
2005-10-05 12:45:33 +02:00
private static final serverClassLoader provider ;
2008-03-22 02:28:37 +01:00
private static serverSwitch < ? > switchboard ;
2005-10-19 14:20:08 +02:00
private static plasmaSwitchboard sb = plasmaSwitchboard . getSwitchboard ( ) ;
2005-10-05 12:45:33 +02:00
2008-02-18 17:38:06 +01:00
private static File htRootPath = null ;
private static File htDocsPath = null ;
private static File htTemplatePath = null ;
private static String [ ] defaultFiles = null ;
private static File htDefaultPath = null ;
private static File htLocalePath = null ;
2007-02-05 20:46:50 +01:00
2008-01-28 19:21:08 +01:00
private static final HashMap < File , SoftReference < byte [ ] > > templateCache ;
private static final HashMap < File , SoftReference < Method > > templateMethodCache ;
2005-09-09 13:14:22 +02:00
2005-09-12 12:47:27 +02:00
public static boolean useTemplateCache = false ;
2007-08-09 23:58:38 +02:00
//private Properties connectionProperties = null;
private static serverLog theLogger ;
2005-09-12 12:47:27 +02:00
static {
2008-03-22 02:28:37 +01:00
serverSwitch < ? > switchboard = plasmaSwitchboard . getSwitchboard ( ) ;
2007-08-09 23:58:38 +02:00
useTemplateCache = switchboard . getConfig ( " enableTemplateCache " , " true " ) . equalsIgnoreCase ( " true " ) ;
2008-01-28 19:21:08 +01:00
templateCache = ( useTemplateCache ) ? new HashMap < File , SoftReference < byte [ ] > > ( ) : new HashMap < File , SoftReference < byte [ ] > > ( 0 ) ;
templateMethodCache = ( useTemplateCache ) ? new HashMap < File , SoftReference < Method > > ( ) : new HashMap < File , SoftReference < Method > > ( 0 ) ;
2005-10-05 12:45:33 +02:00
// create a class loader
provider = new serverClassLoader ( /*this.getClass().getClassLoader()*/ ) ;
2007-08-09 23:58:38 +02:00
2005-07-07 15:58:54 +02:00
// creating a logger
2007-08-09 23:58:38 +02:00
theLogger = new serverLog ( " FILEHANDLER " ) ;
2005-07-07 15:58:54 +02:00
2005-10-05 12:45:33 +02:00
if ( httpdFileHandler . switchboard = = null ) {
httpdFileHandler . switchboard = switchboard ;
if ( mimeTable . size ( ) = = 0 ) {
// load the mime table
String mimeTablePath = switchboard . getConfig ( " mimeConfig " , " " ) ;
BufferedInputStream mimeTableInputStream = null ;
try {
serverLog . logConfig ( " HTTPDFiles " , " Loading mime mapping file " + mimeTablePath ) ;
mimeTableInputStream = new BufferedInputStream ( new FileInputStream ( new File ( switchboard . getRootPath ( ) , mimeTablePath ) ) ) ;
mimeTable . load ( mimeTableInputStream ) ;
} catch ( Exception e ) {
serverLog . logSevere ( " HTTPDFiles " , " ERROR: path to configuration file or configuration invalid \ n " + e ) ;
System . exit ( 1 ) ;
} finally {
if ( mimeTableInputStream ! = null ) try { mimeTableInputStream . close ( ) ; } catch ( Exception e1 ) { }
}
2005-06-09 12:12:07 +02:00
}
2005-10-05 12:45:33 +02:00
// create default files array
2006-08-22 15:35:51 +02:00
initDefaultPath ( ) ;
2005-10-05 12:45:33 +02:00
// create a htRootPath: system pages
if ( htRootPath = = null ) {
htRootPath = new File ( switchboard . getRootPath ( ) , switchboard . getConfig ( " htRootPath " , " htroot " ) ) ;
if ( ! ( htRootPath . exists ( ) ) ) htRootPath . mkdir ( ) ;
}
// create a htDocsPath: user defined pages
if ( htDocsPath = = null ) {
2007-11-04 11:36:25 +01:00
htDocsPath = switchboard . getConfigPath ( plasmaSwitchboard . HTDOCS_PATH , plasmaSwitchboard . HTDOCS_PATH_DEFAULT ) ;
2005-10-05 12:45:33 +02:00
if ( ! ( htDocsPath . exists ( ) ) ) htDocsPath . mkdir ( ) ;
}
// create a htTemplatePath
if ( htTemplatePath = = null ) {
2007-11-04 11:36:25 +01:00
htTemplatePath = switchboard . getConfigPath ( " htTemplatePath " , " htroot/env/templates " ) ;
2005-10-05 12:45:33 +02:00
if ( ! ( htTemplatePath . exists ( ) ) ) htTemplatePath . mkdir ( ) ;
}
2005-11-21 09:33:54 +01:00
//This is now handles by #%env/templates/foo%#
//if (templates.size() == 0) templates.putAll(httpTemplate.loadTemplates(htTemplatePath));
2005-10-05 12:45:33 +02:00
// create htLocaleDefault, htLocalePath
2007-11-04 11:36:25 +01:00
if ( htDefaultPath = = null ) htDefaultPath = switchboard . getConfigPath ( " htDefaultPath " , " htroot " ) ;
if ( htLocalePath = = null ) htLocalePath = switchboard . getConfigPath ( " locale.translated_html " , " DATA/LOCALE/htroot " ) ;
2005-06-09 12:12:07 +02:00
}
2005-04-07 21:19:42 +02:00
}
2005-12-06 22:21:14 +01:00
2006-08-22 15:35:51 +02:00
public static final void initDefaultPath ( ) {
// create default files array
defaultFiles = switchboard . getConfig ( " defaultFiles " , " index.html " ) . split ( " , " ) ;
if ( defaultFiles . length = = 0 ) defaultFiles = new String [ ] { " index.html " } ;
}
2007-07-04 12:32:30 +02:00
/ * * Returns a path to the localized or default file according to the locale . language ( from he switchboard )
2006-11-05 18:43:37 +01:00
* @param path relative from htroot * /
public static File getLocalizedFile ( String path ) {
2007-07-04 12:32:30 +02:00
return getLocalizedFile ( path , switchboard . getConfig ( " locale.language " , " default " ) ) ;
2006-11-05 18:43:37 +01:00
}
/ * * Returns a path to the localized or default file according to the parameter localeSelection
* @param path relative from htroot
2007-07-04 12:32:30 +02:00
* @param localeSelection language of localized file ; locale . language from switchboard is used if localeSelection . equals ( " " ) * /
2006-11-05 18:43:37 +01:00
public static File getLocalizedFile ( String path , String localeSelection ) {
2007-11-04 11:36:25 +01:00
if ( htDefaultPath = = null ) htDefaultPath = switchboard . getConfigPath ( " htDefaultPath " , " htroot " ) ;
if ( htLocalePath = = null ) htLocalePath = switchboard . getConfigPath ( " locale.translated_html " , " DATA/LOCALE/htroot " ) ;
2005-10-12 14:44:05 +02:00
2006-11-05 18:43:37 +01:00
if ( ! ( localeSelection . equals ( " default " ) ) ) {
File localePath = new File ( htLocalePath , localeSelection + " / " + path ) ;
if ( localePath . exists ( ) ) // avoid "NoSuchFile" troubles if the "localeSelection" is misspelled
2005-10-12 14:44:05 +02:00
return localePath ;
}
return new File ( htDefaultPath , path ) ;
}
2005-04-07 21:19:42 +02:00
2005-06-09 12:12:07 +02:00
// private void textMessage(OutputStream out, int retcode, String body) throws IOException {
// httpd.sendRespondHeader(
// this.connectionProperties, // the connection properties
// out, // the output stream
// "HTTP/1.1", // the http version that should be used
// retcode, // the http status code
// null, // the http status message
// "text/plain", // the mimetype
// body.length(), // the content length
// httpc.nowDate(), // the modification date
// null, // the expires date
// null, // cookies
// null, // content encoding
// null); // transfer encoding
// out.write(body.getBytes());
// out.flush();
// }
2007-08-09 23:58:38 +02:00
private static final httpHeader getDefaultHeaders ( String path ) {
2005-06-09 12:12:07 +02:00
httpHeader headers = new httpHeader ( ) ;
2005-10-12 22:45:14 +02:00
String ext ;
int pos ;
if ( ( pos = path . lastIndexOf ( '.' ) ) < 0 ) {
ext = " " ;
} else {
ext = path . substring ( pos + 1 ) . toLowerCase ( ) ;
}
2005-06-09 12:12:07 +02:00
headers . put ( httpHeader . SERVER , " AnomicHTTPD (www.anomic.de) " ) ;
headers . put ( httpHeader . DATE , httpc . dateString ( httpc . nowDate ( ) ) ) ;
2005-10-12 22:45:14 +02:00
if ( ! ( plasmaParser . mediaExtContains ( ext ) ) ) {
headers . put ( httpHeader . PRAGMA , " no-cache " ) ;
}
2005-06-09 12:12:07 +02:00
return headers ;
2005-04-07 21:19:42 +02:00
}
2007-08-11 02:42:04 +02:00
public static void doGet ( Properties conProp , httpHeader requestHeader , OutputStream response ) {
2005-06-09 12:12:07 +02:00
doResponse ( conProp , requestHeader , response , null ) ;
2005-04-07 21:19:42 +02:00
}
2005-06-09 12:12:07 +02:00
2007-08-11 02:42:04 +02:00
public static void doHead ( Properties conProp , httpHeader requestHeader , OutputStream response ) {
2005-06-09 12:12:07 +02:00
doResponse ( conProp , requestHeader , response , null ) ;
2005-04-07 21:19:42 +02:00
}
2005-06-09 12:12:07 +02:00
2007-08-11 02:42:04 +02:00
public static void doPost ( Properties conProp , httpHeader requestHeader , OutputStream response , PushbackInputStream body ) {
2005-06-09 12:12:07 +02:00
doResponse ( conProp , requestHeader , response , body ) ;
2005-04-07 21:19:42 +02:00
}
2005-06-09 12:12:07 +02:00
2007-08-09 23:58:38 +02:00
public static void doResponse ( Properties conProp , httpHeader requestHeader , OutputStream out , InputStream body ) {
2005-06-09 12:12:07 +02:00
2006-10-03 16:21:46 +02:00
String path = null ;
2006-04-23 13:01:31 +02:00
try {
2006-10-03 16:21:46 +02:00
// getting some connection properties
String method = conProp . getProperty ( httpHeader . CONNECTION_PROP_METHOD ) ;
path = conProp . getProperty ( httpHeader . CONNECTION_PROP_PATH ) ;
String argsString = conProp . getProperty ( httpHeader . CONNECTION_PROP_ARGS ) ; // is null if no args were given
2007-09-04 01:43:55 +02:00
String httpVersion = conProp . getProperty ( httpHeader . CONNECTION_PROP_HTTP_VER ) ;
2008-02-25 22:26:49 +01:00
String clientIP = conProp . getProperty ( httpHeader . CONNECTION_PROP_CLIENTIP , " unknown-host " ) ;
2006-10-03 16:21:46 +02:00
// check hack attacks in path
if ( path . indexOf ( " .. " ) > = 0 ) {
httpd . sendRespondError ( conProp , out , 4 , 403 , null , " Access not allowed " , null ) ;
2006-06-12 15:47:44 +02:00
return ;
2005-04-07 21:19:42 +02:00
}
2006-10-03 16:21:46 +02:00
// url decoding of path
try {
path = URLDecoder . decode ( path , " UTF-8 " ) ;
} catch ( UnsupportedEncodingException e ) {
// This should never occur
assert ( false ) : " UnsupportedEncodingException: " + e . getMessage ( ) ;
}
// check permission/granted access
String authorization = ( String ) requestHeader . get ( httpHeader . AUTHORIZATION ) ;
2007-02-05 20:46:50 +01:00
String adminAccountBase64MD5 = switchboard . getConfig ( httpd . ADMIN_ACCOUNT_B64MD5 , " " ) ;
2006-10-03 16:21:46 +02:00
int pos = path . lastIndexOf ( " . " ) ;
if ( ( path . substring ( 0 , ( pos = = - 1 ) ? path . length ( ) : pos ) ) . endsWith ( " _p " ) & & ( adminAccountBase64MD5 . length ( ) ! = 0 ) ) {
//authentication required
//userDB
2008-02-07 23:16:36 +01:00
if ( sb . userDB . hasAdminRight ( authorization , conProp . getProperty ( httpHeader . CONNECTION_PROP_CLIENTIP ) , requestHeader . getHeaderCookies ( ) ) ) {
2006-10-03 16:21:46 +02:00
//Authentication successful. remove brute-force flag
2008-02-07 23:16:36 +01:00
serverCore . bfHost . remove ( conProp . getProperty ( httpHeader . CONNECTION_PROP_CLIENTIP ) ) ;
2006-10-03 16:21:46 +02:00
//static
2007-02-05 20:46:50 +01:00
} else if ( authorization ! = null & & httpd . staticAdminAuthenticated ( authorization . trim ( ) . substring ( 6 ) , switchboard ) = = 4 ) {
2006-10-03 16:21:46 +02:00
//Authentication successful. remove brute-force flag
2008-02-07 23:16:36 +01:00
serverCore . bfHost . remove ( conProp . getProperty ( httpHeader . CONNECTION_PROP_CLIENTIP ) ) ;
2006-10-03 16:21:46 +02:00
//no auth
} else if ( authorization = = null ) {
// no authorization given in response. Ask for that
httpHeader headers = getDefaultHeaders ( path ) ;
headers . put ( httpHeader . WWW_AUTHENTICATE , " Basic realm= \" admin log-in \" " ) ;
//httpd.sendRespondHeader(conProp,out,httpVersion,401,headers);
2006-10-21 17:01:53 +02:00
servletProperties tp = new servletProperties ( ) ;
2006-10-03 16:21:46 +02:00
tp . put ( " returnto " , path ) ;
//TODO: separate errorpage Wrong Login / No Login
httpd . sendRespondError ( conProp , out , 5 , 401 , " Wrong Authentication " , " " , new File ( " proxymsg/authfail.inc " ) , tp , null , headers ) ;
return ;
} else {
// a wrong authentication was given or the userDB user does not have admin access. Ask again
serverLog . logInfo ( " HTTPD " , " Wrong log-in for account 'admin' in http file handler for path ' " + path + " ' from host ' " + clientIP + " ' " ) ;
Integer attempts = ( Integer ) serverCore . bfHost . get ( clientIP ) ;
if ( attempts = = null )
serverCore . bfHost . put ( clientIP , new Integer ( 1 ) ) ;
else
serverCore . bfHost . put ( clientIP , new Integer ( attempts . intValue ( ) + 1 ) ) ;
httpHeader headers = getDefaultHeaders ( path ) ;
headers . put ( httpHeader . WWW_AUTHENTICATE , " Basic realm= \" admin log-in \" " ) ;
httpd . sendRespondHeader ( conProp , out , httpVersion , 401 , headers ) ;
return ;
}
}
2005-06-09 12:12:07 +02:00
2005-07-30 09:15:39 +02:00
2006-10-03 16:21:46 +02:00
// parse arguments
serverObjects args = new serverObjects ( ) ;
int argc ;
if ( argsString = = null ) {
// no args here, maybe a POST with multipart extension
int length = 0 ;
//System.out.println("HEADER: " + requestHeader.toString()); // DEBUG
if ( method . equals ( httpHeader . METHOD_POST ) ) {
GZIPInputStream gzipBody = null ;
if ( requestHeader . containsKey ( httpHeader . CONTENT_LENGTH ) ) {
length = Integer . parseInt ( ( String ) requestHeader . get ( httpHeader . CONTENT_LENGTH ) ) ;
} else if ( requestHeader . gzip ( ) ) {
length = - 1 ;
gzipBody = new GZIPInputStream ( body ) ;
}
// } else {
// httpd.sendRespondError(conProp,out,4,403,null,"bad post values",null);
// return;
// }
// if its a POST, it can be either multipart or as args in the body
if ( ( requestHeader . containsKey ( httpHeader . CONTENT_TYPE ) ) & &
( ( ( String ) requestHeader . get ( httpHeader . CONTENT_TYPE ) ) . toLowerCase ( ) . startsWith ( " multipart " ) ) ) {
// parse multipart
2008-01-06 20:23:38 +01:00
HashMap < String , byte [ ] > files = httpd . parseMultipart ( requestHeader , args , ( gzipBody ! = null ) ? gzipBody : body , length ) ;
2006-10-03 16:21:46 +02:00
// integrate these files into the args
if ( files ! = null ) {
2008-01-06 20:23:38 +01:00
Iterator < Map . Entry < String , byte [ ] > > fit = files . entrySet ( ) . iterator ( ) ;
Map . Entry < String , byte [ ] > entry ;
2006-10-03 16:21:46 +02:00
while ( fit . hasNext ( ) ) {
2008-01-06 20:23:38 +01:00
entry = fit . next ( ) ;
args . put ( entry . getKey ( ) + " $file " , entry . getValue ( ) ) ;
2006-10-03 16:21:46 +02:00
}
2005-04-07 21:19:42 +02:00
}
2006-10-03 16:21:46 +02:00
argc = Integer . parseInt ( ( String ) requestHeader . get ( " ARGC " ) ) ;
} else {
// parse args in body
argc = httpd . parseArgs ( args , ( gzipBody ! = null ) ? gzipBody : body , length ) ;
2005-04-07 21:19:42 +02:00
}
2005-06-09 12:12:07 +02:00
} else {
2006-10-03 16:21:46 +02:00
// no args
argsString = null ;
args = null ;
argc = 0 ;
2005-06-09 12:12:07 +02:00
}
} else {
2006-10-03 16:21:46 +02:00
// simple args in URL (stuff after the "?")
argc = httpd . parseArgs ( args , argsString ) ;
2005-06-09 12:12:07 +02:00
}
2006-10-03 16:21:46 +02:00
// check for cross site scripting - attacks in request arguments
if ( argc > 0 ) {
// check all values for occurrences of script values
2008-01-29 11:12:48 +01:00
Iterator < String > e = args . values ( ) . iterator ( ) ; // enumeration of values
2008-01-28 19:21:08 +01:00
String val ;
2008-01-29 11:12:48 +01:00
while ( e . hasNext ( ) ) {
val = e . next ( ) ;
2008-01-28 19:21:08 +01:00
if ( ( val ! = null ) & & ( val . indexOf ( " <script " ) > = 0 ) ) {
2006-10-03 16:21:46 +02:00
// deny request
httpd . sendRespondError ( conProp , out , 4 , 403 , null , " bad post values " , null ) ;
return ;
}
2005-06-09 12:12:07 +02:00
}
}
2006-10-03 16:21:46 +02:00
// we are finished with parsing
// the result of value hand-over is in args and argc
if ( path . length ( ) = = 0 ) {
httpd . sendRespondError ( conProp , out , 4 , 400 , null , " Bad Request " , null ) ;
out . flush ( ) ;
return ;
}
File targetClass = null ;
2005-06-09 12:12:07 +02:00
// locate the file
2005-10-07 00:30:13 +02:00
if ( ! ( path . startsWith ( " / " ) ) ) path = " / " + path ; // attach leading slash
2006-11-05 18:43:37 +01:00
2007-07-04 12:32:30 +02:00
// a different language can be desired (by i.e. ConfigBasic.html) than the one stored in the locale.language
String localeSelection = switchboard . getConfig ( " locale.language " , " default " ) ;
2008-02-25 22:26:49 +01:00
if ( args ! = null & & ( args . containsKey ( " language " ) ) ) {
2006-11-09 23:18:16 +01:00
// TODO 9.11.06 Bost: a class with information about available languages is needed.
// the indexOf(".") is just a workaround because there from ConfigLanguage.html commes "de.lng" and
// from ConfigBasic.html comes just "de" in the "language" parameter
2006-11-05 18:43:37 +01:00
localeSelection = args . get ( " language " , localeSelection ) ;
2006-11-09 23:18:16 +01:00
if ( localeSelection . indexOf ( " . " ) ! = - 1 )
localeSelection = localeSelection . substring ( 0 , localeSelection . indexOf ( " . " ) ) ;
}
2006-11-05 18:43:37 +01:00
File targetFile = getLocalizedFile ( path , localeSelection ) ;
2005-10-07 03:25:39 +02:00
String targetExt = conProp . getProperty ( " EXT " , " " ) ;
2005-10-20 16:58:15 +02:00
targetClass = rewriteClassFile ( new File ( htDefaultPath , path ) ) ;
2005-04-07 21:19:42 +02:00
if ( path . endsWith ( " / " ) ) {
2005-10-07 00:30:13 +02:00
String testpath ;
2005-06-09 12:12:07 +02:00
// attach default file name
2005-04-07 21:19:42 +02:00
for ( int i = 0 ; i < defaultFiles . length ; i + + ) {
testpath = path + defaultFiles [ i ] ;
2006-07-17 17:49:42 +02:00
targetFile = getOverlayedFile ( testpath ) ;
2008-02-18 17:38:06 +01:00
targetClass = getOverlayedClass ( testpath ) ;
2005-10-19 09:17:49 +02:00
if ( targetFile . exists ( ) ) {
path = testpath ;
break ;
}
2005-04-07 21:19:42 +02:00
}
2008-02-18 17:38:06 +01:00
2006-07-17 17:49:42 +02:00
//no defaultfile, send a dirlisting
2008-02-18 17:38:06 +01:00
if ( targetFile = = null | | ! targetFile . exists ( ) ) {
StringBuffer sb = new StringBuffer ( ) ;
sb . append ( " <html> \ n<head> \ n</head> \ n<body> \ n<h1>Index of " + path + " </h1> \ n <ul> \ n " ) ;
File dir = new File ( htDocsPath , path ) ;
String [ ] list = dir . list ( ) ;
2008-02-25 15:08:15 +01:00
if ( list = = null ) list = new String [ 0 ] ; // should not occur!
2008-02-18 17:38:06 +01:00
File f ;
String size ;
long sz ;
String headline , author , description ;
int images , links ;
htmlFilterContentScraper scraper ;
for ( int i = 0 ; i < list . length ; i + + ) {
f = new File ( dir , list [ i ] ) ;
if ( f . isDirectory ( ) ) {
sb . append ( " <li><a href= \" " + path + list [ i ] + " \" > " + list [ i ] + " /</a><br></li> \ n " ) ;
} else {
if ( list [ i ] . endsWith ( " html " ) | | ( list [ i ] . endsWith ( " htm " ) ) ) {
scraper = htmlFilterContentScraper . parseResource ( f ) ;
headline = scraper . getTitle ( ) ;
author = scraper . getAuthor ( ) ;
description = scraper . getDescription ( ) ;
images = scraper . getImages ( ) . size ( ) ;
links = scraper . getAnchors ( ) . size ( ) ;
} else {
headline = null ;
author = null ;
description = null ;
images = 0 ;
links = 0 ;
}
sz = f . length ( ) ;
if ( sz < 1024 ) {
size = sz + " bytes " ;
} else if ( sz < 1024 * 1024 ) {
size = ( sz / 1024 ) + " KB " ;
} else {
size = ( sz / 1024 / 1024 ) + " MB " ;
}
sb . append ( " <li> " ) ;
if ( ( headline ! = null ) & & ( headline . length ( ) > 0 ) ) sb . append ( " <a href= \" " + list [ i ] + " \" ><b> " + headline + " </b></a><br> " ) ;
sb . append ( " <a href= \" " + path + list [ i ] + " \" > " + list [ i ] + " </a><br> " ) ;
if ( ( author ! = null ) & & ( author . length ( ) > 0 ) ) sb . append ( " Author: " + author + " <br> " ) ;
if ( ( description ! = null ) & & ( description . length ( ) > 0 ) ) sb . append ( " Description: " + description + " <br> " ) ;
sb . append ( serverDate . formatShortDay ( new Date ( f . lastModified ( ) ) ) + " , " + size + ( ( images > 0 ) ? " , " + images + " images " : " " ) + ( ( links > 0 ) ? " , " + links + " links " : " " ) + " <br></li> \ n " ) ;
}
}
sb . append ( " </ul> \ n</body> \ n</html> \ n " ) ;
// write the list to the client
httpd . sendRespondHeader ( conProp , out , httpVersion , 200 , null , " text/html " , sb . length ( ) , new Date ( dir . lastModified ( ) ) , null , new httpHeader ( ) , null , null , true ) ;
if ( ! method . equals ( httpHeader . METHOD_HEAD ) ) {
out . write ( sb . toString ( ) . getBytes ( ) ) ;
2006-07-17 17:49:42 +02:00
}
2008-02-18 17:38:06 +01:00
return ;
2006-07-17 17:49:42 +02:00
}
2008-02-18 17:38:06 +01:00
} else {
2006-06-12 15:47:44 +02:00
//XXX: you cannot share a .png/.gif file with a name like a class in htroot.
2005-11-29 08:27:58 +01:00
if ( ! ( targetFile . exists ( ) ) & & ! ( ( path . endsWith ( " png " ) | | path . endsWith ( " gif " ) | | path . endsWith ( " .stream " ) ) & & targetClass ! = null ) ) {
2005-10-19 09:17:49 +02:00
targetFile = new File ( htDocsPath , path ) ;
targetClass = rewriteClassFile ( new File ( htDocsPath , path ) ) ;
}
2005-06-09 12:12:07 +02:00
}
2005-04-07 21:19:42 +02:00
2005-10-19 09:17:49 +02:00
//File targetClass = rewriteClassFile(targetFile);
2006-01-13 22:29:04 +01:00
//We need tp here
2006-10-21 17:01:53 +02:00
servletProperties tp = new servletProperties ( ) ;
2005-10-05 10:40:20 +02:00
Date targetDate ;
2005-12-07 14:26:27 +01:00
boolean nocache = false ;
2005-10-05 10:40:20 +02:00
2005-10-24 02:34:15 +02:00
if ( ( targetClass ! = null ) & & ( path . endsWith ( " png " ) ) ) {
2005-10-05 10:40:20 +02:00
// call an image-servlet to produce an on-the-fly - generated image
2006-04-03 00:59:53 +02:00
Object img = null ;
2005-10-05 10:40:20 +02:00
try {
2008-02-07 23:16:36 +01:00
requestHeader . put ( httpHeader . CONNECTION_PROP_CLIENTIP , conProp . getProperty ( httpHeader . CONNECTION_PROP_CLIENTIP ) ) ;
2007-02-19 13:47:46 +01:00
requestHeader . put ( httpHeader . CONNECTION_PROP_PATH , path ) ;
2005-10-05 10:40:20 +02:00
// in case that there are no args given, args = null or empty hashmap
2006-08-07 02:19:01 +02:00
img = invokeServlet ( targetClass , requestHeader , args ) ;
2005-10-05 10:40:20 +02:00
} catch ( InvocationTargetException e ) {
2007-08-09 23:58:38 +02:00
theLogger . logSevere ( " INTERNAL ERROR: " + e . toString ( ) + " : " +
2005-10-05 10:40:20 +02:00
e . getMessage ( ) +
" target exception at " + targetClass + " : " +
e . getTargetException ( ) . toString ( ) + " : " +
2005-10-11 09:46:14 +02:00
e . getTargetException ( ) . getMessage ( ) +
" ; java.awt.graphicsenv=' " + System . getProperty ( " java.awt.graphicsenv " , " " ) + " ' " , e ) ;
2005-10-05 10:40:20 +02:00
targetClass = null ;
2005-06-09 12:12:07 +02:00
}
2006-04-03 00:59:53 +02:00
if ( img = = null ) {
2005-10-09 16:46:33 +02:00
// error with image generation; send file-not-found
2007-08-09 23:58:38 +02:00
httpd . sendRespondError ( conProp , out , 3 , 404 , " File not Found " , null , null ) ;
2005-10-09 16:46:33 +02:00
} else {
2007-01-16 00:31:50 +01:00
if ( img instanceof ymageMatrix ) {
ymageMatrix yp = ( ymageMatrix ) img ;
2006-04-03 00:59:53 +02:00
// send an image to client
targetDate = new Date ( System . currentTimeMillis ( ) ) ;
nocache = true ;
String mimeType = mimeTable . getProperty ( targetExt , " text/html " ) ;
2007-12-07 03:15:12 +01:00
serverByteBuffer result = ymageMatrix . exportImage ( yp . getImage ( ) , targetExt ) ;
2006-04-03 00:59:53 +02:00
// write the array to the client
2007-12-07 03:15:12 +01:00
httpd . sendRespondHeader ( conProp , out , httpVersion , 200 , null , mimeType , result . length ( ) , targetDate , null , null , null , null , nocache ) ;
2006-04-03 00:59:53 +02:00
if ( ! method . equals ( httpHeader . METHOD_HEAD ) ) {
2007-12-07 03:15:12 +01:00
result . writeTo ( out ) ;
2006-04-03 00:59:53 +02:00
}
}
if ( img instanceof Image ) {
Image i = ( Image ) img ;
// send an image to client
targetDate = new Date ( System . currentTimeMillis ( ) ) ;
nocache = true ;
String mimeType = mimeTable . getProperty ( targetExt , " text/html " ) ;
// generate an byte array from the generated image
2006-12-20 16:44:29 +01:00
int width = i . getWidth ( null ) ; if ( width < 0 ) width = 96 ; // bad hack
int height = i . getHeight ( null ) ; if ( height < 0 ) height = 96 ; // bad hack
2006-04-11 00:34:47 +02:00
BufferedImage bi = new BufferedImage ( width , height , BufferedImage . TYPE_INT_RGB ) ;
bi . createGraphics ( ) . drawImage ( i , 0 , 0 , width , height , null ) ;
2007-12-07 03:15:12 +01:00
serverByteBuffer result = ymageMatrix . exportImage ( bi , targetExt ) ;
2006-04-03 00:59:53 +02:00
// write the array to the client
2007-12-07 03:15:12 +01:00
httpd . sendRespondHeader ( conProp , out , httpVersion , 200 , null , mimeType , result . length ( ) , targetDate , null , null , null , null , nocache ) ;
2006-04-03 00:59:53 +02:00
if ( ! method . equals ( httpHeader . METHOD_HEAD ) ) {
2007-12-07 03:15:12 +01:00
result . writeTo ( out ) ;
2006-04-03 00:59:53 +02:00
}
2005-12-09 18:35:45 +01:00
}
2005-10-09 16:46:33 +02:00
}
2005-11-29 08:27:58 +01:00
} else if ( ( targetClass ! = null ) & & ( path . endsWith ( " .stream " ) ) ) {
// call rewrite-class
2008-02-07 23:16:36 +01:00
requestHeader . put ( httpHeader . CONNECTION_PROP_CLIENTIP , conProp . getProperty ( httpHeader . CONNECTION_PROP_CLIENTIP ) ) ;
2007-02-19 13:47:46 +01:00
requestHeader . put ( httpHeader . CONNECTION_PROP_PATH , path ) ;
2008-01-28 21:08:32 +01:00
//requestHeader.put(httpHeader.CONNECTION_PROP_INPUTSTREAM, body);
//requestHeader.put(httpHeader.CONNECTION_PROP_OUTPUTSTREAM, out);
2005-11-29 08:27:58 +01:00
2007-08-09 23:58:38 +02:00
httpd . sendRespondHeader ( conProp , out , httpVersion , 200 , null ) ;
2005-11-29 08:27:58 +01:00
// in case that there are no args given, args = null or empty hashmap
2006-10-21 18:53:31 +02:00
/* servletProperties tp = (servlerObjects) */ invokeServlet ( targetClass , requestHeader , args ) ;
2007-08-09 23:58:38 +02:00
forceConnectionClose ( conProp ) ;
2005-11-29 08:27:58 +01:00
return ;
2005-10-05 10:40:20 +02:00
} else if ( ( targetFile . exists ( ) ) & & ( targetFile . canRead ( ) ) ) {
2005-06-09 12:12:07 +02:00
// we have found a file that can be written to the client
// if this file uses templates, then we use the template
// re-write - method to create an result
2005-10-05 10:40:20 +02:00
String mimeType = mimeTable . getProperty ( targetExt , " text/html " ) ;
2005-06-09 12:12:07 +02:00
boolean zipContent = requestHeader . acceptGzip ( ) & & httpd . shallTransportZipped ( " . " + conProp . getProperty ( " EXT " , " " ) ) ;
if ( path . endsWith ( " html " ) | |
path . endsWith ( " xml " ) | |
2008-01-28 19:21:08 +01:00
path . endsWith ( " rdf " ) | |
2005-06-09 12:12:07 +02:00
path . endsWith ( " rss " ) | |
path . endsWith ( " csv " ) | |
2006-02-06 15:41:59 +01:00
path . endsWith ( " pac " ) | |
2006-07-17 17:49:42 +02:00
path . endsWith ( " src " ) | |
2007-03-21 16:08:18 +01:00
path . endsWith ( " vcf " ) | |
2007-03-02 02:19:38 +01:00
path . endsWith ( " / " ) | |
path . equals ( " /robots.txt " ) ) {
2005-10-05 10:40:20 +02:00
2006-07-17 17:49:42 +02:00
/ * targetFile = getLocalizedFile ( path ) ;
2005-10-14 13:50:11 +02:00
if ( ! ( targetFile . exists ( ) ) ) {
// try to find that file in the htDocsPath
File trialFile = new File ( htDocsPath , path ) ;
if ( trialFile . exists ( ) ) targetFile = trialFile ;
2006-07-17 17:49:42 +02:00
} * /
2005-10-14 13:50:11 +02:00
2005-10-05 10:40:20 +02:00
// call rewrite-class
2006-01-13 22:29:04 +01:00
2005-10-05 10:40:20 +02:00
if ( targetClass = = null ) {
targetDate = new Date ( targetFile . lastModified ( ) ) ;
} else {
2005-06-09 12:12:07 +02:00
// CGI-class: call the class to create a property for rewriting
try {
2008-02-07 23:16:36 +01:00
requestHeader . put ( httpHeader . CONNECTION_PROP_CLIENTIP , conProp . getProperty ( httpHeader . CONNECTION_PROP_CLIENTIP ) ) ;
2007-02-19 13:47:46 +01:00
requestHeader . put ( httpHeader . CONNECTION_PROP_PATH , path ) ;
2005-06-09 12:12:07 +02:00
// in case that there are no args given, args = null or empty hashmap
2007-07-23 11:54:12 +02:00
Object tmp = invokeServlet ( targetClass , requestHeader , args ) ;
2007-07-24 15:39:53 +02:00
if ( tmp = = null ) {
2007-07-23 11:54:12 +02:00
// if no args given, then tp will be an empty Hashtable object (not null)
tp = new servletProperties ( ) ;
} else if ( tmp instanceof servletProperties ) {
tp = ( servletProperties ) tmp ;
} else {
tp = new servletProperties ( ( serverObjects ) tmp ) ;
2006-10-21 18:41:22 +02:00
}
2005-04-07 21:19:42 +02:00
// check if the servlets requests authentification
2007-02-19 13:47:46 +01:00
if ( tp . containsKey ( servletProperties . ACTION_AUTHENTICATE ) ) {
2005-07-30 09:15:39 +02:00
// handle brute-force protection
if ( authorization ! = null ) {
serverLog . logInfo ( " HTTPD " , " dynamic log-in for account 'admin' in http file handler for path ' " + path + " ' from host ' " + clientIP + " ' " ) ;
Integer attempts = ( Integer ) serverCore . bfHost . get ( clientIP ) ;
if ( attempts = = null )
serverCore . bfHost . put ( clientIP , new Integer ( 1 ) ) ;
else
serverCore . bfHost . put ( clientIP , new Integer ( attempts . intValue ( ) + 1 ) ) ;
}
// send authentication request to browser
2005-10-12 22:45:14 +02:00
httpHeader headers = getDefaultHeaders ( path ) ;
2007-02-19 13:47:46 +01:00
headers . put ( httpHeader . WWW_AUTHENTICATE , " Basic realm= \" " + tp . get ( servletProperties . ACTION_AUTHENTICATE , " " ) + " \" " ) ;
2005-06-09 12:12:07 +02:00
httpd . sendRespondHeader ( conProp , out , httpVersion , 401 , headers ) ;
2005-04-07 21:19:42 +02:00
return ;
2007-02-19 13:47:46 +01:00
} else if ( tp . containsKey ( servletProperties . ACTION_LOCATION ) ) {
String location = tp . get ( servletProperties . ACTION_LOCATION , " " ) ;
2005-09-01 09:52:46 +02:00
if ( location . length ( ) = = 0 ) location = path ;
2005-10-12 22:45:14 +02:00
httpHeader headers = getDefaultHeaders ( path ) ;
2006-06-18 14:15:26 +02:00
headers . setCookieVector ( tp . getOutgoingHeader ( ) . getCookieVector ( ) ) ; //put the cookies into the new header TODO: can we put all headerlines, without trouble?
2005-09-01 09:52:46 +02:00
headers . put ( httpHeader . LOCATION , location ) ;
2005-09-12 13:38:46 +02:00
httpd . sendRespondHeader ( conProp , out , httpVersion , 302 , headers ) ;
2005-09-01 09:52:46 +02:00
return ;
2005-04-07 21:19:42 +02:00
}
2005-08-14 17:45:48 +02:00
// add the application version, the uptime and the client name to every rewrite table
2007-02-19 13:47:46 +01:00
tp . put ( servletProperties . PEER_STAT_VERSION , switchboard . getConfig ( " version " , " " ) ) ;
2007-08-22 02:59:05 +02:00
tp . put ( servletProperties . PEER_STAT_UPTIME , ( ( System . currentTimeMillis ( ) - serverCore . startupTime ) / 1000 ) / 60 ) ; // uptime in minutes
2007-02-19 13:47:46 +01:00
tp . put ( servletProperties . PEER_STAT_CLIENTNAME , switchboard . getConfig ( " peerName " , " anomic " ) ) ;
2007-12-21 01:53:46 +01:00
tp . put ( servletProperties . PEER_STAT_MYTIME , serverDate . formatShortSecond ( ) ) ;
2005-06-09 12:12:07 +02:00
//System.out.println("respond props: " + ((tp == null) ? "null" : tp.toString())); // debug
} catch ( InvocationTargetException e ) {
2005-10-18 09:45:27 +02:00
if ( e . getCause ( ) instanceof InterruptedException ) {
throw new InterruptedException ( e . getCause ( ) . getMessage ( ) ) ;
}
2007-08-09 23:58:38 +02:00
theLogger . logSevere ( " INTERNAL ERROR: " + e . toString ( ) + " : " +
2005-06-09 12:12:07 +02:00
e . getMessage ( ) +
2005-10-05 10:40:20 +02:00
" target exception at " + targetClass + " : " +
2005-06-09 12:12:07 +02:00
e . getTargetException ( ) . toString ( ) + " : " +
2005-06-10 11:19:24 +02:00
e . getTargetException ( ) . getMessage ( ) , e ) ;
2005-10-05 10:40:20 +02:00
targetClass = null ;
2005-10-20 11:55:12 +02:00
throw e ;
2005-06-09 12:12:07 +02:00
}
2005-10-05 10:40:20 +02:00
targetDate = new Date ( System . currentTimeMillis ( ) ) ;
2005-12-07 14:26:27 +01:00
nocache = true ;
2005-06-09 12:12:07 +02:00
}
2005-09-09 13:14:22 +02:00
2005-06-09 12:12:07 +02:00
// rewrite the file
2005-09-09 13:14:22 +02:00
InputStream fis = null ;
2007-06-26 16:37:10 +02:00
// read the file/template
byte [ ] templateContent = null ;
if ( useTemplateCache ) {
long fileSize = targetFile . length ( ) ;
if ( fileSize < = 512 * 1024 ) {
// read from cache
2008-01-28 19:21:08 +01:00
SoftReference < byte [ ] > ref = templateCache . get ( targetFile ) ;
2007-06-26 16:37:10 +02:00
if ( ref ! = null ) {
templateContent = ( byte [ ] ) ref . get ( ) ;
if ( templateContent = = null ) templateCache . remove ( targetFile ) ;
}
if ( templateContent = = null ) {
// loading the content of the template file into
// a byte array
templateContent = serverFileUtils . read ( targetFile ) ;
// storing the content into the cache
2008-01-28 19:21:08 +01:00
ref = new SoftReference < byte [ ] > ( templateContent ) ;
2007-06-26 16:37:10 +02:00
templateCache . put ( targetFile , ref ) ;
2007-08-09 23:58:38 +02:00
if ( theLogger . isLoggable ( Level . FINEST ) )
theLogger . logFinest ( " Cache MISS for file " + targetFile ) ;
2005-09-09 13:14:22 +02:00
} else {
2007-08-09 23:58:38 +02:00
if ( theLogger . isLoggable ( Level . FINEST ) )
theLogger . logFinest ( " Cache HIT for file " + targetFile ) ;
2005-09-09 13:14:22 +02:00
}
2007-06-26 16:37:10 +02:00
// creating an inputstream needed by the template
// rewrite function
fis = new ByteArrayInputStream ( templateContent ) ;
templateContent = null ;
2005-09-09 13:14:22 +02:00
} else {
2007-06-26 16:37:10 +02:00
// read from file directly
2005-10-05 10:40:20 +02:00
fis = new BufferedInputStream ( new FileInputStream ( targetFile ) ) ;
2005-09-09 13:14:22 +02:00
}
2007-06-26 16:37:10 +02:00
} else {
fis = new BufferedInputStream ( new FileInputStream ( targetFile ) ) ;
}
// write the array to the client
// we can do that either in standard mode (whole thing completely) or in chunked mode
2007-08-09 23:58:38 +02:00
// since yacy clients do not understand chunked mode (yet), we use this only for communication with the administrator
2007-06-26 16:37:10 +02:00
boolean yacyClient = requestHeader . userAgent ( ) . startsWith ( " yacy " ) ;
2007-06-26 17:06:23 +02:00
boolean chunked = ! method . equals ( httpHeader . METHOD_HEAD ) & & ! yacyClient & & httpVersion . equals ( httpHeader . HTTP_VERSION_1_1 ) ;
2007-06-26 16:37:10 +02:00
if ( chunked ) {
// send page in chunks and parse SSIs
serverByteBuffer o = new serverByteBuffer ( ) ;
// apply templates
httpTemplate . writeTemplate ( fis , o , tp , " -UNRESOLVED_PATTERN- " . getBytes ( " UTF-8 " ) ) ;
2007-08-09 23:58:38 +02:00
httpd . sendRespondHeader ( conProp , out , httpVersion , 200 , null , mimeType , - 1 , targetDate , null , tp . getOutgoingHeader ( ) , null , " chunked " , nocache ) ;
2007-06-26 16:37:10 +02:00
// send the content in chunked parts, see RFC 2616 section 3.6.1
httpChunkedOutputStream chos = new httpChunkedOutputStream ( out ) ;
2008-02-25 22:26:49 +01:00
httpSSI . writeSSI ( o , chos , authorization , clientIP ) ;
2007-06-26 16:37:10 +02:00
//chos.write(result);
chos . finish ( ) ;
} else {
// send page as whole thing, SSIs are not possible
String contentEncoding = ( zipContent ) ? " gzip " : null ;
// apply templates
2007-08-09 23:58:38 +02:00
serverByteBuffer o1 = new serverByteBuffer ( ) ;
httpTemplate . writeTemplate ( fis , o1 , tp , " -UNRESOLVED_PATTERN- " . getBytes ( " UTF-8 " ) ) ;
2007-06-26 16:37:10 +02:00
serverByteBuffer o = new serverByteBuffer ( ) ;
2007-08-09 23:58:38 +02:00
2005-06-09 12:12:07 +02:00
if ( zipContent ) {
2007-06-26 16:37:10 +02:00
GZIPOutputStream zippedOut = new GZIPOutputStream ( o ) ;
2008-02-25 22:26:49 +01:00
httpSSI . writeSSI ( o1 , zippedOut , authorization , clientIP ) ;
2007-08-09 23:58:38 +02:00
//httpTemplate.writeTemplate(fis, zippedOut, tp, "-UNRESOLVED_PATTERN-".getBytes("UTF-8"));
2005-06-09 12:12:07 +02:00
zippedOut . finish ( ) ;
zippedOut . flush ( ) ;
zippedOut . close ( ) ;
zippedOut = null ;
2007-06-26 16:37:10 +02:00
} else {
2008-02-25 22:26:49 +01:00
httpSSI . writeSSI ( o1 , o , authorization , clientIP ) ;
2007-08-09 23:58:38 +02:00
//httpTemplate.writeTemplate(fis, o, tp, "-UNRESOLVED_PATTERN-".getBytes("UTF-8"));
2005-06-09 12:12:07 +02:00
}
2007-06-26 16:37:10 +02:00
if ( method . equals ( httpHeader . METHOD_HEAD ) ) {
2007-08-09 23:58:38 +02:00
httpd . sendRespondHeader ( conProp , out ,
2007-06-26 16:37:10 +02:00
httpVersion , 200 , null , mimeType , o . length ( ) ,
targetDate , null , tp . getOutgoingHeader ( ) ,
contentEncoding , null , nocache ) ;
} else {
2007-12-07 03:15:12 +01:00
byte [ ] result = o . getBytes ( ) ; // this interrupts streaming (bad idea!)
2007-08-09 23:58:38 +02:00
httpd . sendRespondHeader ( conProp , out ,
2007-06-26 16:37:10 +02:00
httpVersion , 200 , null , mimeType , result . length ,
targetDate , null , tp . getOutgoingHeader ( ) ,
contentEncoding , null , nocache ) ;
2008-03-14 01:16:04 +01:00
serverFileUtils . copy ( result , out ) ;
2007-06-26 16:37:10 +02:00
}
2005-06-09 12:12:07 +02:00
}
2006-02-16 10:23:27 +01:00
} else { // no html
int statusCode = 200 ;
int rangeStartOffset = 0 ;
httpHeader header = new httpHeader ( ) ;
// adding the accept ranges header
header . put ( httpHeader . ACCEPT_RANGES , " bytes " ) ;
// reading the files md5 hash if availabe and use it as ETAG of the resource
String targetMD5 = null ;
File targetMd5File = new File ( targetFile + " .md5 " ) ;
try {
if ( targetMd5File . exists ( ) ) {
2006-02-19 01:39:16 +01:00
//String description = null;
2006-02-16 10:23:27 +01:00
targetMD5 = new String ( serverFileUtils . read ( targetMd5File ) ) ;
pos = targetMD5 . indexOf ( '\n' ) ;
if ( pos > = 0 ) {
2006-02-19 01:39:16 +01:00
//description = targetMD5.substring(pos + 1);
2006-02-16 10:23:27 +01:00
targetMD5 = targetMD5 . substring ( 0 , pos ) ;
}
// using the checksum as ETAG header
header . put ( httpHeader . ETAG , targetMD5 ) ;
}
} catch ( IOException e ) {
e . printStackTrace ( ) ;
}
if ( requestHeader . containsKey ( httpHeader . RANGE ) ) {
Object ifRange = requestHeader . ifRange ( ) ;
if ( ( ifRange = = null ) | |
( ifRange instanceof Date & & targetFile . lastModified ( ) = = ( ( Date ) ifRange ) . getTime ( ) ) | |
( ifRange instanceof String & & ifRange . equals ( targetMD5 ) ) ) {
String rangeHeaderVal = ( ( String ) requestHeader . get ( httpHeader . RANGE ) ) . trim ( ) ;
if ( rangeHeaderVal . startsWith ( " bytes= " ) ) {
String rangesVal = rangeHeaderVal . substring ( " bytes= " . length ( ) ) ;
String [ ] ranges = rangesVal . split ( " , " ) ;
if ( ( ranges . length = = 1 ) & & ( ranges [ 0 ] . endsWith ( " - " ) ) ) {
rangeStartOffset = Integer . valueOf ( ranges [ 0 ] . substring ( 0 , ranges [ 0 ] . length ( ) - 1 ) ) . intValue ( ) ;
statusCode = 206 ;
if ( header = = null ) header = new httpHeader ( ) ;
header . put ( httpHeader . CONTENT_RANGE , " bytes " + rangeStartOffset + " - " + ( targetFile . length ( ) - 1 ) + " / " + targetFile . length ( ) ) ;
}
}
}
}
2005-04-07 21:19:42 +02:00
// write the file to the client
2005-10-05 10:40:20 +02:00
targetDate = new Date ( targetFile . lastModified ( ) ) ;
2006-02-16 11:27:21 +01:00
long contentLength = ( zipContent ) ? - 1 : targetFile . length ( ) - rangeStartOffset ;
String contentEncoding = ( zipContent ) ? " gzip " : null ;
2006-02-15 13:31:52 +01:00
String transferEncoding = ( ! httpVersion . equals ( httpHeader . HTTP_VERSION_1_1 ) ) ? null : ( zipContent ) ? " chunked " : null ;
2007-08-09 23:58:38 +02:00
if ( ! httpVersion . equals ( httpHeader . HTTP_VERSION_1_1 ) & & zipContent ) forceConnectionClose ( conProp ) ;
2006-02-15 13:31:52 +01:00
2007-08-09 23:58:38 +02:00
httpd . sendRespondHeader ( conProp , out , httpVersion , statusCode , null , mimeType , contentLength , targetDate , null , header , contentEncoding , transferEncoding , nocache ) ;
2006-02-15 13:31:52 +01:00
if ( ! method . equals ( httpHeader . METHOD_HEAD ) ) {
httpChunkedOutputStream chunkedOut = null ;
GZIPOutputStream zipped = null ;
OutputStream newOut = out ;
if ( transferEncoding ! = null ) {
chunkedOut = new httpChunkedOutputStream ( newOut ) ;
newOut = chunkedOut ;
}
if ( contentEncoding ! = null ) {
zipped = new GZIPOutputStream ( newOut ) ;
newOut = zipped ;
}
2008-02-18 17:38:06 +01:00
serverFileUtils . copyRange ( targetFile , newOut , rangeStartOffset ) ;
2006-02-15 13:31:52 +01:00
if ( zipped ! = null ) {
zipped . flush ( ) ;
zipped . finish ( ) ;
}
if ( chunkedOut ! = null ) {
chunkedOut . finish ( ) ;
}
2008-03-10 00:58:22 +01:00
// flush all
try { newOut . flush ( ) ; } catch ( Exception e ) { }
// wait a little time until everything closes so that clients can read from the streams/sockets
if ( ( contentLength > = 0 ) & & ( ( String ) requestHeader . get ( httpHeader . CONNECTION , " close " ) ) . indexOf ( " keep-alive " ) = = - 1 ) {
// in case that the client knows the size in advance (contentLength present) the waiting will have no effect on the interface performance
// but if the client waits on a connection interruption this will slow down.
try { Thread . sleep ( 2000 ) ; } catch ( InterruptedException e ) { } // FIXME: is this necessary?
}
}
2005-06-09 12:12:07 +02:00
// check mime type again using the result array: these are 'magics'
// if (serverByteBuffer.equals(result, 1, "PNG".getBytes())) mimeType = mimeTable.getProperty("png","text/html");
// else if (serverByteBuffer.equals(result, 0, "GIF89".getBytes())) mimeType = mimeTable.getProperty("gif","text/html");
// else if (serverByteBuffer.equals(result, 6, "JFIF".getBytes())) mimeType = mimeTable.getProperty("jpg","text/html");
2006-02-15 13:31:52 +01:00
//System.out.print("MAGIC:"); for (int i = 0; i < 10; i++) System.out.print(Integer.toHexString((int) result[i]) + ","); System.out.println();
2005-12-09 18:35:45 +01:00
}
2005-06-09 12:12:07 +02:00
} else {
httpd . sendRespondError ( conProp , out , 3 , 404 , " File not Found " , null , null ) ;
2005-07-07 15:58:54 +02:00
return ;
2005-06-09 12:12:07 +02:00
}
2005-07-04 13:09:48 +02:00
} catch ( Exception e ) {
2005-07-07 15:58:54 +02:00
try {
// doing some errorhandling ...
int httpStatusCode = 400 ;
String httpStatusText = null ;
StringBuffer errorMessage = new StringBuffer ( ) ;
Exception errorExc = null ;
2005-08-04 13:05:04 +02:00
String errorMsg = e . getMessage ( ) ;
if (
( e instanceof InterruptedException ) | |
( ( errorMsg ! = null ) & & ( errorMsg . startsWith ( " Socket closed " ) ) & & ( Thread . currentThread ( ) . isInterrupted ( ) ) )
) {
2005-07-07 15:58:54 +02:00
errorMessage . append ( " Interruption detected while processing query. " ) ;
httpStatusCode = 503 ;
2005-06-13 09:50:35 +02:00
} else {
2005-07-07 15:58:54 +02:00
if ( ( errorMsg ! = null ) & &
(
errorMsg . startsWith ( " Broken pipe " ) | |
errorMsg . startsWith ( " Connection reset " ) | |
2005-08-04 13:05:04 +02:00
errorMsg . startsWith ( " Software caused connection abort " )
2005-07-07 15:58:54 +02:00
) ) {
// client closed the connection, so we just end silently
errorMessage . append ( " Client unexpectedly closed connection while processing query. " ) ;
2005-08-04 13:05:04 +02:00
} else if ( ( errorMsg ! = null ) & & ( errorMsg . startsWith ( " Connection timed out " ) ) ) {
errorMessage . append ( " Connection timed out. " ) ;
2005-06-13 09:50:35 +02:00
} else {
2005-07-07 15:58:54 +02:00
errorMessage . append ( " Unexpected error while processing query. " ) ;
httpStatusCode = 500 ;
errorExc = e ;
2005-06-13 09:50:35 +02:00
}
}
2005-07-07 15:58:54 +02:00
2005-08-04 13:05:04 +02:00
errorMessage . append ( " \ nSession: " ) . append ( Thread . currentThread ( ) . getName ( ) )
. append ( " \ nQuery: " ) . append ( path )
2005-09-20 23:49:47 +02:00
. append ( " \ nClient: " ) . append ( conProp . getProperty ( httpHeader . CONNECTION_PROP_CLIENTIP , " unknown " ) )
2005-08-04 13:05:04 +02:00
. append ( " \ nReason: " ) . append ( e . toString ( ) ) ;
2005-07-07 15:58:54 +02:00
2005-09-20 23:49:47 +02:00
if ( ! conProp . containsKey ( httpHeader . CONNECTION_PROP_PROXY_RESPOND_HEADER ) ) {
2005-07-07 15:58:54 +02:00
// sending back an error message to the client
// if we have not already send an http header
2007-02-06 17:26:56 +01:00
httpd . sendRespondError ( conProp , out , 4 , httpStatusCode , httpStatusText , new String ( errorMessage ) , errorExc ) ;
2005-07-07 15:58:54 +02:00
} else {
// otherwise we close the connection
2007-08-09 23:58:38 +02:00
forceConnectionClose ( conProp ) ;
2005-07-07 15:58:54 +02:00
}
// if it is an unexpected error we log it
if ( httpStatusCode = = 500 ) {
2007-08-09 23:58:38 +02:00
theLogger . logWarning ( new String ( errorMessage ) , e ) ;
2005-07-07 15:58:54 +02:00
}
} catch ( Exception ee ) {
2007-08-09 23:58:38 +02:00
forceConnectionClose ( conProp ) ;
2005-07-07 15:58:54 +02:00
}
2005-06-13 09:50:35 +02:00
} finally {
try { out . flush ( ) ; } catch ( Exception e ) { }
2005-04-07 21:19:42 +02:00
}
}
2006-08-07 02:19:01 +02:00
2007-08-09 23:58:38 +02:00
public static final File getOverlayedClass ( String path ) {
2006-07-17 17:49:42 +02:00
File targetClass ;
2008-02-18 17:38:06 +01:00
targetClass = rewriteClassFile ( new File ( htDefaultPath , path ) ) ; //works for default and localized files
if ( targetClass = = null | | ! targetClass . exists ( ) ) {
2006-07-17 17:49:42 +02:00
//works for htdocs
targetClass = rewriteClassFile ( new File ( htDocsPath , path ) ) ;
}
return targetClass ;
}
2007-08-09 23:58:38 +02:00
public static final File getOverlayedFile ( String path ) {
2006-07-17 17:49:42 +02:00
File targetFile ;
targetFile = getLocalizedFile ( path ) ;
2008-02-18 17:38:06 +01:00
if ( ! targetFile . exists ( ) ) {
2006-07-17 17:49:42 +02:00
targetFile = new File ( htDocsPath , path ) ;
}
return targetFile ;
}
2005-06-09 12:12:07 +02:00
2007-08-09 23:58:38 +02:00
private static final void forceConnectionClose ( Properties conprop ) {
if ( conprop ! = null ) {
conprop . setProperty ( httpHeader . CONNECTION_PROP_PERSISTENT , " close " ) ;
2005-07-07 15:58:54 +02:00
}
}
2007-08-09 23:58:38 +02:00
private static final File rewriteClassFile ( File template ) {
2005-06-09 12:12:07 +02:00
try {
String f = template . getCanonicalPath ( ) ;
int p = f . lastIndexOf ( " . " ) ;
if ( p < 0 ) return null ;
f = f . substring ( 0 , p ) + " .class " ;
//System.out.println("constructed class path " + f);
File cf = new File ( f ) ;
if ( cf . exists ( ) ) return cf ;
return null ;
} catch ( IOException e ) {
return null ;
}
2005-04-07 21:19:42 +02:00
}
2005-06-09 12:12:07 +02:00
2007-08-09 23:58:38 +02:00
private static final Method rewriteMethod ( File classFile ) {
2005-06-09 12:12:07 +02:00
Method m = null ;
// now make a class out of the stream
try {
2006-11-05 18:43:37 +01:00
if ( useTemplateCache ) {
2008-01-28 19:21:08 +01:00
SoftReference < Method > ref = templateMethodCache . get ( classFile ) ;
2005-10-10 11:13:17 +02:00
if ( ref ! = null ) {
m = ( Method ) ref . get ( ) ;
if ( m = = null ) {
templateMethodCache . remove ( classFile ) ;
} else {
return m ;
}
}
2006-11-05 18:43:37 +01:00
}
2005-10-10 11:13:17 +02:00
2008-01-28 19:21:08 +01:00
Class < ? > c = provider . loadClass ( classFile ) ;
Class < ? > [ ] params = new Class [ ] {
2007-02-27 23:52:22 +01:00
httpHeader . class ,
serverObjects . class ,
serverSwitch . class } ;
2005-06-09 12:12:07 +02:00
m = c . getMethod ( " respond " , params ) ;
2005-10-10 11:13:17 +02:00
if ( useTemplateCache ) {
// storing the method into the cache
2008-01-28 19:21:08 +01:00
SoftReference < Method > ref = new SoftReference < Method > ( m ) ;
templateMethodCache . put ( classFile , ref ) ;
2005-10-10 11:13:17 +02:00
}
2005-06-09 12:12:07 +02:00
} catch ( ClassNotFoundException e ) {
System . out . println ( " INTERNAL ERROR: class " + classFile + " is missing: " + e . getMessage ( ) ) ;
} catch ( NoSuchMethodException e ) {
System . out . println ( " INTERNAL ERROR: method respond not found in class " + classFile + " : " + e . getMessage ( ) ) ;
}
//System.out.println("found method: " + m.toString());
return m ;
2005-04-07 21:19:42 +02:00
}
2005-06-09 12:12:07 +02:00
2007-08-09 23:58:38 +02:00
public static final Object invokeServlet ( File targetClass , httpHeader request , serverObjects args ) throws IllegalArgumentException , IllegalAccessException , InvocationTargetException {
2006-08-07 02:19:01 +02:00
Object result ;
if ( safeServletsMode ) synchronized ( switchboard ) {
result = rewriteMethod ( targetClass ) . invoke ( null , new Object [ ] { request , args , switchboard } ) ;
} else {
result = rewriteMethod ( targetClass ) . invoke ( null , new Object [ ] { request , args , switchboard } ) ;
}
return result ;
}
2005-04-07 21:19:42 +02:00
public void doConnect ( Properties conProp , httpHeader requestHeader , InputStream clientIn , OutputStream clientOut ) {
throw new UnsupportedOperationException ( ) ;
}
2005-06-09 12:12:07 +02:00
2005-04-07 21:19:42 +02:00
}