package com.planet_ink.coffee_mud.core.http;
import com.planet_ink.coffee_mud.core.interfaces.*;
import com.planet_ink.coffee_mud.core.intermud.IMudClient;
import com.planet_ink.coffee_mud.core.*;
import com.planet_ink.coffee_mud.Abilities.interfaces.*;
import com.planet_ink.coffee_mud.Areas.interfaces.*;
import com.planet_ink.coffee_mud.Behaviors.interfaces.*;
import com.planet_ink.coffee_mud.CharClasses.interfaces.*;
import com.planet_ink.coffee_mud.Libraries.interfaces.*;
import com.planet_ink.coffee_mud.Common.interfaces.*;
import com.planet_ink.coffee_mud.Exits.interfaces.*;
import com.planet_ink.coffee_mud.Items.interfaces.*;
import com.planet_ink.coffee_mud.Locales.interfaces.*;
import com.planet_ink.coffee_mud.MOBS.interfaces.*;
import com.planet_ink.coffee_mud.Races.interfaces.*;
import com.planet_ink.coffee_mud.WebMacros.interfaces.*;
import java.net.*;
import java.util.*;
import java.util.regex.*;
import org.mozilla.javascript.*;
import java.io.*;
import com.planet_ink.coffee_mud.core.exceptions.*;
/*
Portions Copyright 2002 Jeff Kamenek
Portions Copyright 2002-2006 Bo Zimmerman
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.
*/
public class ProcessHTTPrequest extends Thread implements ExternalHTTPRequests
{
public String ID(){return "ProcessHTTPrequest";}
public CMObject newInstance(){try{return (CMObject)getClass().newInstance();}catch(Exception e){return new ProcessHTTPrequest();}}
public void initializeClass(){}
public CMObject copyOf(){try{return (CMObject)this.clone();}catch(Exception e){return newInstance();}}
public int compareTo(Object o){ return CMClass.classID(this).compareToIgnoreCase(CMClass.classID(o));}
private CMProps page;
private Socket sock;
private static long instanceCnt = 0;
private long processStartTime=0;
protected String command = null;
protected String request = null;
protected String requestMain = null;
protected String requestParametersEncoded = null; // I keep the encoded form
// I've called it Table to distinguish it from Encoded string...
private Hashtable requestParametersTable = null;
// default mime type
protected String mimetype = "text/html";
private final static String mimePrefix = "MIME";
protected boolean headersOnly = false;
protected boolean isAdminServer = false;
// these are all the HTTP states this class can return
private final static String S_200 = "200 OK";
private final static String S_301 = "301 Moved Permanently";
private final static String S_302 = "302 Found";
private final static String S_303 = "303 See Other";
private final static String S_307 = "307 Temporary Redirect";
private final static String S_400 = "400 Bad Request";
private final static String S_401 = "401 Unauthorized";
private final static String S_404 = "404 Not Found";
private final static String S_500 = "500 Internal Server Error";
private final static String S_501 = "501 Not Implemented";
// not sure which order is expected - I think the first
private final static String cr = "\r\n";
//private final static String cr = "\n\r";
protected String status = S_500;
protected String statusExtra = "...";
HTTPserver webServer;
public boolean virtualPage;
private Hashtable objects=null;
public ProcessHTTPrequest()
{
super();
page = null;
webServer = null;
sock = null;
isAdminServer = true;
setDaemon(true);
}
public ProcessHTTPrequest(Socket a_sock,
HTTPserver a_webServer,
CMProps a_page,
boolean a_isAdminServer)
{
// thread name contains both an instance counter and the client's IP address
// (too long)
// super( "HTTPrq-"+ instanceCnt++ +"-" + a_sock.getInetAddress().toString() );
// thread name contains just the instance counter (faster)
// and short enough to use in log
super( "HTTPrq-"+((a_webServer!=null)?a_webServer.getPartialName():"")+ instanceCnt++ );
setDaemon(true);
page = a_page;
webServer = a_webServer;
sock = a_sock;
isAdminServer = a_isAdminServer;
if (page != null && sock != null)
this.start();
}
public Hashtable getVirtualDirectories(){return webServer.getVirtualDirectories();}
public HTTPserver getWebServer() {return webServer;}
public String getHTTPstatus() {return status;}
public String getHTTPstatusInfo() {return statusExtra==null?"":statusExtra;}
public CMFile grabFile(String fn)
{
GrabbedFile GF=getWebServer().pageGrabber.grabFile(fn);
if(GF==null) return null;
switch(GF.state)
{
case GrabbedFile.STATE_OK:
case GrabbedFile.STATE_IS_DIRECTORY:
return GF.file;
default:
return null;
}
}
public String getMimeType(String a_extension)
{
return page.getStr(new String (mimePrefix + a_extension).toUpperCase());
}
protected boolean process(String inLine) throws Exception
{
virtualPage = false;
try
{
StringTokenizer inTok = new StringTokenizer(inLine," ");
try
{
command = inTok.nextToken();
}
catch (NoSuchElementException e)
{
status = S_400;
statusExtra = "Empty request";
return false;
}
statusExtra=inLine;
if(command.startsWith("["))
{
int err=400;
if(command.length()>1)
err=CMath.s_int(command.substring(1));
switch(err)
{
case 200: status=S_200; break;
case 301: status=S_301; break;
case 302: status=S_302; break;
case 303: status=S_303; break;
case 307: status=S_307; break;
case 400: status=S_400; break;
case 401: status=S_401; break;
case 404: status=S_404; break;
case 500: status=S_500; break;
case 501: status=S_501; break;
}
return false;
}
// should always be uppercase, but I allow for mixed-case anyway
// only handles GET, simple POST, & HEAD requests
// (not the obscure ones: PUT, DELETE, OPTIONS and TRACE)
if (command.equalsIgnoreCase("HEAD"))
{
headersOnly = true;
command = "GET";
}
else
if((command.equalsIgnoreCase("GET"))
||(command.equalsIgnoreCase("POST")))
{
try
{
request = inTok.nextToken();
}
catch (NoSuchElementException e)
{
request = "/";
}
int p = request.indexOf("?");
if (p == -1)
{
requestMain = request;
}
else
{
if (p == 0)
{
requestMain = "/";
requestParametersEncoded = request.substring(1);
}
else
{
requestMain = request.substring(0,p);
if (p < request.length())
requestParametersEncoded = request.substring(p+1);
}
}
try
{
requestMain = URLDecoder.decode(requestMain,"UTF-8");
}
catch(UnsupportedEncodingException e)
{
Log.errOut(getName(),"Received wrong encoding");
}
}
else
{
// must reply with 501 if unsupported
status = S_501;
statusExtra = "Unimplemented HTTP request: <i>" + command + "</i>";
return false;
}
return true;
}
catch (Exception e)
{
status = S_500;
statusExtra = "D'OH! An internal exception occured: <i>" + e.getMessage()+"</i>";
return false;
}
}
public Hashtable getRequestObjects()
{
if(objects==null) objects=new Hashtable();
return objects;
}
public void resetRequestEncodedParameters()
{
StringBuffer buf=new StringBuffer("");
for(Enumeration e=getRequestParameters().keys();e.hasMoreElements();)
{
String key=(String)e.nextElement();
String value=(String)getRequestParameters().get(key);
if(buf.length()>0) buf.append("&");
try
{
buf.append(URLEncoder.encode(key,"UTF-8")+"="+URLEncoder.encode(value,"UTF-8"));
}
catch(java.io.UnsupportedEncodingException es)
{
Log.errOut(getName(),"Wrong Encoding");
}
}
requestParametersEncoded=buf.toString();
}
public void addRequestParameters(String key, String value)
{
getRequestParameters().remove(key);
requestParametersTable.put(key,value);
resetRequestEncodedParameters();
}
public boolean isRequestParameter(String key)
{
if(key==null) return false;
return getRequestParameters().containsKey(key);
}
public void removeRequestParameter(String key)
{
if(key==null) return;
getRequestParameters().remove(key);
resetRequestEncodedParameters();
}
public String getRequestParameter(String key)
{
if(key==null) return null;
return (String)getRequestParameters().get(key);
}
public Vector getAllRequestParameterKeys(String keyMask)
{
Hashtable H=getRequestParameters();
Pattern p=Pattern.compile(keyMask,Pattern.CASE_INSENSITIVE);
Matcher M=null;
Vector V=new Vector();
for(Enumeration e=H.keys();e.hasMoreElements();)
{
String key=(String)e.nextElement();
M=p.matcher(key);
if(M.matches()) V.addElement(key);
}
return V;
}
private Hashtable getRequestParameters()
{
// have we already parsed the parameters?
if (requestParametersTable != null)
return requestParametersTable;
requestParametersTable = new Hashtable();
// do we have any parameters to parse?
if (requestParametersEncoded == null)
return requestParametersTable;
String pStr = new String(requestParametersEncoded);
String thisParam;
String thisParamName;
String thisParamValue;
while (pStr != null)
{
int p = pStr.indexOf("&");
if (p == -1)
{
thisParam = pStr;
pStr = null;
}
else
{
thisParam = pStr.substring(0,p);
if (p < pStr.length())
pStr = pStr.substring(p+1);
else
pStr = null;
}
int eq=thisParam.indexOf("=");
if (eq == -1)
{
// a null parameter (ie a parameter name with no value,
// which is valid - I give it a value of "" rather than null tho!
thisParamName = thisParam;
thisParamValue = "";
}
else
{
thisParamName = thisParam.substring(0,eq);
thisParamValue = "";
if (eq < thisParam.length())
{
try
{
if(thisParamName.equalsIgnoreCase("RAWTEXT"))
thisParamValue=URLDecoder.decode(thisParam.substring(eq+1), "UTF-8");
else
thisParamValue=preFilter(new StringBuffer(URLDecoder.decode(thisParam.substring(eq+1), "UTF-8")));
}
catch(UnsupportedEncodingException e)
{
Log.errOut(getName(),"Received wrong encoding.2");
}
catch(Exception e2)
{
if((!Log.isMaskedErrMsg(e2.getMessage()))
||(CMSecurity.isDebugging("HTTPERR")))
Log.errOut(getName(),e2.getMessage());
if(CMSecurity.isDebugging("HTTPERREXT"))
Log.errOut(getName(),e2);
}
}
}
if(thisParamName.length()>0)
{
if(!requestParametersTable.containsKey(thisParamName.toUpperCase()))
requestParametersTable.put(thisParamName.toUpperCase(),thisParamValue);
else
for(int i=1;;i++)
if(!requestParametersTable.containsKey(thisParamName.toUpperCase()+(new Integer(i).toString())))
{
requestParametersTable.put(thisParamName.toUpperCase()+(new Integer(i).toString()),thisParamValue);
break;
}
}
}
return requestParametersTable;
}
public String getRequestEncodedParameters()
{
return (requestParametersEncoded!=null?requestParametersEncoded:"");
}
protected String parseFoundMacro(StringBuffer s, int i, boolean lookOnly)
{
String foundMacro=null;
boolean extend=false;
for(int x=i+1;x<s.length();x++)
{
if((s.charAt(x)=='@')
&&(extend)
&&(x<(s.length()-1))
&&(s.charAt(x+1)=='@'))
{
if(!lookOnly)
s.deleteCharAt(x);
while((x<s.length())&&(s.charAt(x)=='@'))
x++;
x--;
}
else
if((s.charAt(x)=='@')
&&((!extend)||(x>=s.length()-1)||(s.charAt(x+1)!='@')))
{
foundMacro=s.substring(i+1,x);
break;
}
else
if((s.charAt(x)=='?')&&(Character.isLetterOrDigit(s.charAt(x-1))))
extend=true;
else
if(((x-i)>CMClass.longestWebMacro)&&(!extend))
break;
}
return foundMacro;
}
protected int myBack(StringBuffer s, int i)
{
int backsToFind=1;
for(;i<s.length();i++)
{
if(s.charAt(i)=='@')
{
String foundMacro=parseFoundMacro(s,i,true);
if((foundMacro!=null)&&(foundMacro.length()>0))
{
if(foundMacro.equalsIgnoreCase("loop"))
backsToFind++;
else
if(foundMacro.equalsIgnoreCase("back"))
{
backsToFind--;
if(backsToFind<=0)
return i;
}
}
}
}
return -1;
}
protected String preFilter(StringBuffer input)
{
if(input==null) return null;
int x=0;
while(x<input.length())
{
char c=input.charAt(x);
if(c=='\'')
input.setCharAt(x,'`');
else
if(c==8)
{
String newStr=input.toString();
if(x==0)
input=new StringBuffer(newStr.substring(x+1));
else
{
input=new StringBuffer(newStr.substring(0,x-1)+newStr.substring(x+1));
x--;
}
x--;
}
x++;
}
return input.toString();
}
protected int myEndif(StringBuffer s, int i)
{
int endifsToFind=1;
for(;i<s.length();i++)
{
if(s.charAt(i)=='@')
{
String foundMacro=parseFoundMacro(s,i,true);
if((foundMacro!=null)&&(foundMacro.length()>0))
{
if(foundMacro.startsWith("if?"))
endifsToFind++;
else
if(foundMacro.equalsIgnoreCase("endif"))
{
endifsToFind--;
if(endifsToFind<=0)
return i;
}
}
}
}
return -1;
}
private int myEndJScript(StringBuffer s, int i)
{
for(;i<s.length();i++)
{
if(s.charAt(i)=='@')
{
String foundMacro=parseFoundMacro(s,i,true);
if((foundMacro!=null)&&(foundMacro.length()>0))
{
if(foundMacro.equalsIgnoreCase("/jscript"))
return i;
}
}
}
return -1;
}
protected String runMacro(String foundMacro)
throws HTTPRedirectException, HTTPServerException
{
int x=foundMacro.indexOf("?");
StringBuffer parms=null;
if(x>=0)
{
parms=new StringBuffer(foundMacro.substring(x+1));
foundMacro=foundMacro.substring(0,x);
int y=parms.indexOf("@");
while(y>=0)
{
String newFoundMacro=parseFoundMacro(parms,y,false);
if((newFoundMacro!=null)&&(newFoundMacro.length()>0))
{
int l=newFoundMacro.length();
String qq=runMacro(newFoundMacro);
if (qq != null)
parms.replace(y,y+l+2, qq );
else
parms.replace(y,y+l+2, "[error]" );
}
else
break;
y=parms.indexOf("@");
}
}
if(foundMacro.length()==0)
return "";
WebMacro W=CMClass.getWebMacro(foundMacro.toUpperCase());
if(W!=null)
{
String q=null;
if (!isAdminServer && W.isAdminMacro())
{
Log.errOut(getName(), "Non-admin cannot access admin macro '" + W.name() + "'; client IP: " + sock.getInetAddress());
q = "[error]";
}
else
if(W.preferBinary())
{
byte[] bin=W.runBinaryMacro(this,(parms==null)?null:parms.toString());
if(bin==null)
q=" @break@";
else
q=new String(bin);
}
else
q=W.runMacro(this,(parms==null)?null:parms.toString());
if (q != null)
return q;
return "[error]";
}
return null;
}
protected int myElse(StringBuffer s, int i, int end)
{
int endifsToFind=1;
for(;i<end;i++)
{
if(s.charAt(i)=='@')
{
String foundMacro=parseFoundMacro(s,i,true);
if((foundMacro!=null)&&(foundMacro.length()>0))
{
if(foundMacro.startsWith("if?"))
endifsToFind++;
else
if(foundMacro.equalsIgnoreCase("endif"))
{
endifsToFind--;
if(endifsToFind<=0)
return -1;
}
else
if((foundMacro.equalsIgnoreCase("else"))&&(endifsToFind==1))
return i;
}
}
}
return -1;
}
// OK - this parser is getting a bit ugly now;
// I'm probably gonna replace it soon
public byte [] doVirtualPage(byte [] data) throws HTTPRedirectException
{
return doVirtualPage(new String(data)).toString().getBytes();
}
// OK - this parser is getting a bit ugly now;
// I'm probably gonna replace it soon
public String doVirtualPage(String data) throws HTTPRedirectException
{
StringBuffer s2 = new StringBuffer(data);
return doVirtualPage(s2).toString();
}
// OK - this parser is getting a bit ugly now;
// I'm probably gonna replace it soon
public StringBuffer doVirtualPage(StringBuffer s) throws HTTPRedirectException
{
String redirectTo = null;
boolean analLogging=CMSecurity.isDebugging("HTTPERREXT");
if((webServer!=null)
&&(!webServer.isAdminServer)
&&(processStartTime>0)
&&(System.currentTimeMillis()-processStartTime)>(120*1000))
{
if(analLogging) Log.infoOut(getName(),"Encountered TIMEOUT!");
return new StringBuffer("");
}
try
{
for(int i=0;i<s.length();i++)
{
if(s.charAt(i)=='@')
{
String foundMacro=parseFoundMacro(s,i,false);
if((foundMacro!=null)&&(foundMacro.length()>0))
{
if(foundMacro.startsWith("if?"))
{
int l=foundMacro.length()+2;
int v=myEndif(s,i+l);
if(v<0)
s.replace(i,i+l,"[if without endif]");
else
{
int v2=myElse(s,i+l,v);
foundMacro=foundMacro.substring(3);
try
{
String compare="true";
if(foundMacro.startsWith("!"))
{
foundMacro=foundMacro.substring(1);
compare="false";
}
String q=runMacro(foundMacro);
if((q!=null)&&(q.equalsIgnoreCase(compare)))
{
if(v2>=0)
s.replace(v2,v+7,"");
else
s.replace(v,v+7,"");
s.replace(i,i+l,"");
}
else
{
if(v2>=0)
s.replace(i,v2+6,"");
else
s.replace(i,v+7,"");
}
}
catch (HTTPRedirectException e)
{
redirectTo = e.getMessage();
}
}
continue;
}
else
if(foundMacro.equalsIgnoreCase("/jscript"))
{
int l=foundMacro.length()+2;
s.replace(i,i+l,"[/jscript without jscript]");
}
else
if(foundMacro.equalsIgnoreCase("jscript"))
{
int l=foundMacro.length()+2;
int v=myEndJScript(s,i+l);
if(v<0)
s.replace(i,i+l,"[jscript without /jscript]");
else
{
Context cx = Context.enter();
try
{
String script=s.substring(i+l,v);
JScriptablePage scope = new JScriptablePage(this);
cx.initStandardObjects(scope);
scope.defineFunctionProperties(JScriptablePage.functions,
JScriptablePage.class,
ScriptableObject.DONTENUM);
cx.evaluateString(scope, script,"<cmd>", 1, null);
s.replace(i,v+l+1,scope.getBuffer());
i=i+scope.getBuffer().length();
}
catch(Exception e)
{
if(e!=null)
s.replace(i,v+l+1,"[jscript error: "+e.getMessage()+"]");
else
s.replace(i,v+l+1,"[jscript error: unknown]");
}
Context.exit();
}
continue;
}
else
if(foundMacro.equalsIgnoreCase("endif"))
{
s.replace(i,i+7,"");
continue;
}
else
if(foundMacro.equalsIgnoreCase("else"))
{
s.replace(i,i+6,"");
continue;
}
else
if(foundMacro.equalsIgnoreCase("loop"))
{
int v=myBack(s,i+6);
if(v<0)
s.replace(i,i+6, "[loop without back]" );
else
{
String s2=s.substring(i+6,v);
s.replace(i,v+6,"");
int ldex=i;
String s3=" ";
while(s3.length()>0)
{
try
{
s3=new String(doVirtualPage(s2.getBytes()));
}
catch (HTTPRedirectException e)
{
s3 = " ";
redirectTo = e.getMessage();
}
s.insert(ldex,s3);
ldex+=s3.length();
}
if((webServer!=null)
&&(!webServer.isAdminServer)
&&(processStartTime>0)
&&(System.currentTimeMillis()-processStartTime)>(120*1000))
{
if(analLogging) Log.infoOut(getName(),"Encountered TIMEOUT!");
return new StringBuffer("");
}
}
continue;
}
else
if(foundMacro.equalsIgnoreCase("break"))
{
if(analLogging) Log.infoOut(getName(),"Encountered BREAK! at "+i);
return new StringBuffer("");
}
else
if(foundMacro.equalsIgnoreCase("back"))
{
s.replace(i,i+6, "[back without loop]" );
continue;
}
if(foundMacro.length()>0)
{
try
{
int l=foundMacro.length();
String q=runMacro(foundMacro);
if (q != null)
{
if((analLogging)&&(q.toUpperCase().indexOf("@BREAK@")>=0))
Log.infoOut(getName(),"WebMacro:"+foundMacro+" generated a BREAK! at "+i);
s.replace(i,i+l+2, q );
}
else
s.replace(i,i+l+2, "[error]" );
}
catch (HTTPRedirectException e)
{
// can't just do this:
// throw e;
// since we want ALL macros on the page to run
redirectTo = e.getMessage();
// doesn't bother to replace original
// macro text; page will never be seen
// (replaced by redirection page)
}
}
}
}
}
}
catch (Exception e)
{
String errMsg=e.getMessage()==null?e.toString():e.getMessage();
if((errMsg!=null)
&&((!Log.isMaskedErrMsg(errMsg))||(CMSecurity.isDebugging("HTTPERR"))))
{
Log.errOut(getName(), "Exception in doVirtualPage() - " + errMsg );
Log.errOut(getName(),e);
}
}
if (redirectTo != null)
{
throw new HTTPRedirectException(redirectTo);
}
return s;
}
// if the client's browser does not support or honour 3xx redirects,
// then this attached page attempts to use javascript to redirect
// if that doesn't work, the meta refresh will hopefully refresh to the new url;
// if *that* doesn't work, we present the user with a link to click.
// the page is also marked as uncacheable with an invalid expiry date
//
// *** this will be replaced by a template page in the near future ***
// (when I can be bothered doing it that is)
public String makeRedirectPage(String url)
{
return "<html><head>"
+"<META HTTP-EQUIV=\"Expires\" CONTENT=\"Mon, 06 Jan 1990 00:00:01 GMT\">"
+"<meta HTTP-EQUIV=\"Refresh\" CONTENT=\"2; URL=" + url + "\">"
+"<script>self.location.href = \"" + url +"\";</script>"
+"</head><body>"
+"<br>Redirecting in 2 seconds; if redirection does not work, "
+"<a href=\"" + url + "\">click here!</a><br></body></html>";
}
public void run()
{
String hdrRedirectTo = null;
processStartTime=System.currentTimeMillis();
BufferedReader sin = null;
DataOutputStream sout = null;
ByteArrayOutputStream bout=null;
byte[] replyData = null;
String contentHeader=null;
status = S_200;
try
{
//sout = new DataOutputStream(new BufferedOutputStream(sock.getOutputStream()));
bout=new ByteArrayOutputStream();
sout = new DataOutputStream(bout);
GrabbedFile requestedFile;
headersOnly = false;
virtualPage = false;
String totalRequest=getHTTPRequest(sock.getInputStream());
boolean processOK = process(totalRequest);
if (processOK)
{
if(requestMain==null) requestMain="";
String filename = new String(requestMain);
// now do the web path macro check, complete
// with zmud correction;
int lastSlash=filename.lastIndexOf("/");
String macCheck=(lastSlash>=0)?filename.substring(lastSlash+1):filename;
lastSlash=macCheck.indexOf("?");
if(lastSlash>=0) macCheck=macCheck.substring(0,lastSlash);
lastSlash=macCheck.indexOf("&");
if(lastSlash>=0) macCheck=macCheck.substring(0,lastSlash);
WebMacro W=CMClass.getWebMacro(macCheck.toUpperCase());
if((W!=null)&&(W.isAWebPath())&&((!W.isAdminMacro())||(isAdminServer)))
{
requestedFile=null;
virtualPage=false;
if(W.preferBinary())
replyData=W.runBinaryMacro(this,"");
else
{
virtualPage=true;
replyData=W.runMacro(this,"").getBytes();
}
filename=W.getFilename(this,filename);
}
else
requestedFile = webServer.pageGrabber.grabFile(filename);
if(W!=null) contentHeader=W.getSpecialContentHeader(filename);
if(requestedFile!=null)
switch (requestedFile.state)
{
case GrabbedFile.STATE_OK:
break;
case GrabbedFile.STATE_IS_DIRECTORY:
if (!filename.endsWith( "/" ))
filename += '/';
filename += page.getStr("DEFAULTFILE");
requestedFile = webServer.pageGrabber.grabFile(filename);
if (requestedFile.state != GrabbedFile.STATE_OK)
{
status = S_401;
statusExtra = "Directory listing for <i>" + requestMain + "</i> denied.";
processOK = false;
}
break;
case GrabbedFile.STATE_BAD_FILENAME:
status = S_400;
statusExtra = "The requested URL <i>" + requestMain + "</i> is invalid.";
processOK = false;
break;
case GrabbedFile.STATE_NOT_FOUND:
status = S_404;
statusExtra = "The requested URL <i>" + requestMain + "</i> was not found on this server.";
processOK = false;
break;
case GrabbedFile.STATE_SECURITY_VIOLATION:
status = S_401;
statusExtra = "Denied access to <i>" + requestMain + "</i>. WARNING: I will never be your best friend.";
processOK = false;
break;
//case GrabbedFile.INTERNAL_ERROR:
default:
status = S_500;
statusExtra = "An internal error occured.";
processOK = false;
break;
}
if (processOK)
{
String exten;
try { exten = filename.substring(filename.lastIndexOf(".")); }
catch (Exception e) {exten = "";}
if (exten==null) exten = "";
mimetype = getMimeType(exten);
if (mimetype.length() == 0)
mimetype = "application/octet-stream"; // default to raw binary
if (page.getStr("VIRTUALPAGEEXTENSION").equalsIgnoreCase(exten) )
virtualPage = true;
if((replyData==null)&&(requestedFile!=null))
{
try
{
replyData=requestedFile.file.raw();
if(replyData.length==0)
{
replyData=null;
throw new IOException("File not found!");
}
}
catch (IOException e)
{
status = S_500;
statusExtra = "IO error while reading URL <I>" + request +"</I>";
processOK = false;
}
}
}
}
// build error page
if (!processOK || replyData == null)
{
//mimetype = "text/html";
mimetype = getMimeType(page.getStr("VIRTUALPAGEEXTENSION"));
if (mimetype.length() == 0)
mimetype = "application/octet-stream"; // default to raw binary
// try to get an error page from the template directory
// if it doesn't exist, make a simple error page and return that
try
{
//requestedFile = new File("web" + CMFile.pathSeparator + "error" + page.getStr("VIRTUALPAGEEXTENSION") );
///requestedFile = new File(webServer.getServerTemplateDir() + CMFile.pathSeparator + "error" + page.getStr("VIRTUALPAGEEXTENSION") );
requestedFile = webServer.templateGrabber.grabFile("error" + page.getStr("VIRTUALPAGEEXTENSION"));
if (requestedFile.state == GrabbedFile.STATE_OK)
{
virtualPage = true;
replyData=requestedFile.file.raw();
if(replyData.length==0)
{
replyData=null;
throw new IOException("File not found!");
}
}
else
replyData = null;
}
catch (Exception e)
{
replyData = null;
}
if (replyData == null)
{
// make the builtin error page
virtualPage = false;
mimetype = "text/html";
replyData = WebHelper.makeErrorPage(status,statusExtra);
}
}
if(virtualPage)
{
try
{
replyData = doVirtualPage(replyData);
}
catch (HTTPRedirectException e)
{
status = S_303;
hdrRedirectTo = e.getMessage();
replyData = makeRedirectPage(hdrRedirectTo).getBytes();
}
}
// first the status header
sout.writeBytes("HTTP/1.0 " + status + cr);
// other headers
// may add content-length at some point, shouldn't
// be necassary though
// should also probably add Last-Modified
if (hdrRedirectTo != null)
{
sout.writeBytes("Location: " + hdrRedirectTo + cr);
}
sout.writeBytes("Server: " + HTTPserver.ServerVersionString + cr);
sout.writeBytes("MIME-Version: 1.0" + cr);
if(contentHeader!=null)
sout.writeBytes(contentHeader);
else
sout.writeBytes("Content-Type: " + mimetype + cr);
if ((replyData != null))
{
sout.writeBytes("Content-Length: " + replyData.length);
sout.writeBytes( cr );
}
if (!headersOnly)
{
if ((replyData != null))
{
// must insert a blank line before message body
sout.writeBytes( cr );
sout.write(replyData);
}
}
}
catch (Exception e)
{
String errMsg=e.getMessage()==null?e.toString():e.getMessage();
if((errMsg!=null)
&&((!Log.isMaskedErrMsg(errMsg))
||(CMSecurity.isDebugging("HTTPERR"))))
{
Log.errOut(getName(),"Exception: " + errMsg );
if((!(e instanceof java.net.SocketException))
||(CMSecurity.isDebugging("HTTPERREXT")))
Log.errOut(getName(),e);
}
}
if((Log.debugChannelOn())&&(CMSecurity.isDebugging("HTTPREQ")))
Log.debugOut(getName(), sock.getInetAddress().getHostAddress() + ":" + (command==null?"(null)":command + " " + (request==null?"(null)":request)) +
":" + status +" ("+replyData.length+")");
try
{
if (sout != null)
{
sout.flush();
OutputStream o=sock.getOutputStream();
o.write(bout.toByteArray());
o.flush();
sout.close();
o.close();
sout = null;
}
}
catch (Exception e) {}
try
{
if (sin != null)
{
sin.close();
sin = null;
}
}
catch (Exception e) {}
try
{
if (sock != null)
{
sock.close();
sock = null;
}
}
catch (Exception e) {}
}
public String getHTTPclientIP()
{
if (sock != null)
return sock.getInetAddress().getHostAddress();
return "[NOT CONNECTED]";
}
// gets the InetAddress of the server this request connected to;
// this is because HTTP redirects must specify complete path (doh!)
public InetAddress getServerAddress()
{
if (sock != null)
return sock.getLocalAddress();
return null;
}
public String getPageContent(String filename)
{
try
{
GrabbedFile requestedFile = webServer.pageGrabber.grabFile(filename);
if((requestedFile==null)
||(requestedFile.state!=GrabbedFile.STATE_OK))
return "";
byte[] replyData=requestedFile.file.raw();
if(replyData.length==0)
{
replyData=null;
throw new IOException("File not found!");
}
String exten="";
try { exten = filename.substring(filename.lastIndexOf(".")); }
catch (Exception e) {}
if(page.getStr("VIRTUALPAGEEXTENSION").equalsIgnoreCase(exten) )
replyData=doVirtualPage(replyData);
return new String(replyData);
}
catch (Exception e)
{
String errMsg=e.getMessage()==null?e.toString():e.getMessage();
if((errMsg!=null)
&&((!Log.isMaskedErrMsg(errMsg))
||(CMSecurity.isDebugging("HTTPERR"))))
{
Log.errOut(getName(),"Exception: " + errMsg );
if((!(e instanceof java.net.SocketException))
||(CMSecurity.isDebugging("HTTPERREXT")))
Log.errOut(getName(),e);
}
}
return "";
}
protected Vector getData(InputStream sin)
{
Vector data=new Vector();
ByteArrayOutputStream out=new ByteArrayOutputStream();
try
{
BufferedInputStream BR=new BufferedInputStream(sin);
int contentLength=-1;
byte c=-1;
long startTime=System.currentTimeMillis();
while(((contentLength<0)||(out.size()<contentLength))
&&((System.currentTimeMillis()-startTime)<20000))
{
c=(byte)BR.read();
if((contentLength<0)&&(c==13))
{
if(out.size()==0)
{
// got empty line, but no data yet!
contentLength=getContentLength(data);
if(contentLength<0) return data;
}
else
{
String s=new String(out.toByteArray());
out=new ByteArrayOutputStream();
data.addElement(s);
if(s.startsWith("GET ")) return data;
}
}
else
if((c!=10)||((contentLength>0)&&(out.size()>0)))
{
out.write(c);
if(out.size()>100000000){ return data;}
if((contentLength>0)&&(out.size()>=contentLength))
{
data.addElement(out.toByteArray());
return data;
}
}
}
}
catch(Exception e)
{
if((!Log.isMaskedErrMsg(e.getMessage()))
||(CMSecurity.isDebugging("HTTPERR")))
Log.errOut(getName(),e.getMessage());
if(CMSecurity.isDebugging("HTTPERREXT"))
Log.errOut(getName(),e);
};
if(data.size()==0)
data.addElement(new String(out.toByteArray()));
else
if(out.size()>0)
data.addElement(out.toByteArray());
return data;
}
public String getContentType(Vector data)
{
for(int s=0;s<data.size();s++)
{
Object O=data.elementAt(s);
if(O instanceof String)
{
String str=(String)O;
if(str.toLowerCase().startsWith("content-type: "))
return str.substring(14).trim();
}
}
return "";
}
public int getContentLength(Vector data)
{
for(int s=0;s<data.size();s++)
{
Object O=data.elementAt(s);
if(O instanceof String)
{
String str=(String)O;
if(str.toLowerCase().startsWith("content-length: "))
return CMath.s_int(str.substring(16).trim());
}
}
return -1;
}
public String getBoundary(Vector data)
{
for(int s=0;s<data.size();s++)
{
Object O=data.elementAt(s);
if(O instanceof String)
{
String str=(String)O;
int x=str.toLowerCase().indexOf("boundary=");
if(x>=0)
return str.substring(x+9).trim();
}
}
return "";
}
public boolean byteCompare(byte[] buf, int start, byte[] to)
{
if((buf.length-start)<to.length)
return false;
for(int i=0;i<to.length;i++)
if(buf[start+i]!=to[i])
return false;
return true;
}
public String getHTTPRequest(InputStream sin)
{
try
{
Vector inData = getData(sin);
//Log.sysOut("HTTP",inLine);
if((inData==null)||(inData.size()==0)||(!(inData.elementAt(0) instanceof String)))
return "[400 -- no request received]";
String inLine=(String)inData.elementAt(0);
if((inLine.startsWith("GET")||inLine.startsWith("HEAD")))
return inLine;
else
if(inLine.startsWith("POST"))
{
String type=getContentType(inData);
if(type.length()==0) return "";
if(!(inData.lastElement() instanceof byte[]))
return "[400 -- no content data received]";
if(type.toLowerCase().indexOf("multipart/form-data")>=0)
{
int x=inLine.lastIndexOf(" ");
if(x<0) return "[400 -- improperly formatted post request]";
StringBuffer parms=new StringBuffer("");
String boundary="--"+getBoundary(inData)+"\r\n";
String secondBoundary="\r\n"+boundary;
if(boundary.length()==0) return "[400 -- improperly formatted post request]";
byte[] bounBytes=boundary.getBytes();
byte[] bounBytes2=secondBoundary.getBytes();
byte[] buf=(byte[])inData.lastElement();
byte[] CRCR="\r\n\r\n".getBytes();
int s=0;
int lastEnd=-1;
while(s<buf.length)
{
if(byteCompare(buf,s,bounBytes))
{
if(lastEnd>0)
{
for(int i=lastEnd;i<s;i++)
if(byteCompare(buf,i,CRCR))
{
byte[] mybuf=new byte[i-lastEnd];
System.arraycopy(buf,lastEnd,mybuf,0,mybuf.length);
String header=new String(mybuf);
int nameDex=header.indexOf("name=\"");
String name=null;
if(nameDex>=0)
{
int nameEnDex=header.indexOf("\"",nameDex+6);
if(nameEnDex>nameDex)
name=header.substring(nameDex+6,nameEnDex);
}
nameDex=header.indexOf("filename=\"");
String filename=null;
if(nameDex>=0)
{
int nameEnDex=header.indexOf("\"",nameDex+10);
if(nameEnDex>nameDex)
filename=header.substring(nameDex+10,nameEnDex);
}
boolean binary=filename!=null;
mybuf=new byte[s-(i+CRCR.length)];
System.arraycopy(buf,(i+CRCR.length),mybuf,0,mybuf.length);
if(!binary)
{
parms.append("&"+URLEncoder.encode(name, "UTF-8")+"="+URLEncoder.encode(new String(mybuf), "UTF-8"));
}
else
{
getRequestObjects().put(name,mybuf);
char c3=' ';
for(int i3=0;i3<filename.length();i3++)
{
if((filename.charAt(i3)=='\\')||(filename.charAt(i3)=='/'))
{ c3=filename.charAt(i3); break;}
}
if(c3!=' ')
filename=filename.substring(filename.lastIndexOf(c3)+1);
parms.append("&"+URLEncoder.encode(name, "UTF-8")+"="+URLEncoder.encode(filename, "UTF-8"));
}
break;
}
}
s+=bounBytes.length;
lastEnd=s;
bounBytes=bounBytes2;
}
else
s++;
}
if(parms.length()>0)
return inLine.substring(0,x)+"?"+(parms.toString().substring(1));
return inLine.substring(0,x);
}
else
if(type.toLowerCase().indexOf("urlencoded")>=0)
{
String lastLine=new String((byte[])inData.lastElement());
int x=inLine.lastIndexOf(" ");
if(x<0) return "[400 -- improperly formatted post request]";
return inLine.substring(0,x)+"?"+lastLine+inLine.substring(x);
}
else
return "[501 -- unsupported post type]";
}
else
return "[501 -- command not implemented]";
}
catch (Exception e)
{
String errMsg=e.getMessage()==null?e.toString():e.getMessage();
if((errMsg!=null)
&&((!Log.isMaskedErrMsg(errMsg))
||(CMSecurity.isDebugging("HTTPERR"))))
{
Log.errOut(getName(),"Exception: " + errMsg );
if((!(e instanceof java.net.SocketException))
||(CMSecurity.isDebugging("HTTPERREXT")))
Log.errOut(getName(),e);
}
}
finally
{
}
return "[400 -- error occurred processing request]";
}
protected static class JScriptablePage extends ScriptableObject
{
public String getClassName(){ return "JScriptablePage";}
static final long serialVersionUID=43;
StringBuffer buf=new StringBuffer("");
public void write(Object O){buf.append( Context.toString(O));}
public String getBuffer(){return buf.toString();}
ExternalHTTPRequests req=null;
public ExternalHTTPRequests request(){return req;}
public JScriptablePage(ExternalHTTPRequests requests){req=requests;}
public static String[] functions = { "request", "write", "toJavaString"};
public String toJavaString(Object O){return Context.toString(O);}
}
public String ServerVersionString(){return HTTPserver.ServerVersionString;}
public String getWebServerPortStr(){return getWebServer().getPortStr();}
public String getWebServerPartialName(){ return getWebServer().getPartialName();}
public MudHost getMUD(){return getWebServer().getMUD();}
}
