package com.planet_ink.siplet.support;
import java.io.*;
import java.util.*;
import com.jcraft.jzlib.*;
import com.planet_ink.siplet.applet.Siplet;
/*
Copyright 2000-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 TelnetFilter
{
public final static boolean debugChars=false;
public final static boolean debugTelnetCodes=false;
protected static final char IAC_SE=240;
protected static final char IAC_ = 255;
protected static final char IAC_SB=250;
protected static final char IAC_DO = 253;
protected static final char IAC_WILL = 251;
protected static final char IAC_WONT = 252;
protected static final char IAC_DONT = 254;
protected static final char IAC_MSP = 90;
protected static final char IAC_MXP = 91;
protected static final char TELOPT_BINARY=0;
protected static final char TELOPT_EOR = 25;
protected static final char TELOPT_ECHO = 1;
protected static final char TELOPT_NAWS = 31;
protected static final char TELOPT_TTYPE = 24;
protected static final char TELOPT_TSPEED = 32;
protected static final char MCCP_COMPRESS = 85;
protected static final char MCCP_COMPRESS2 = 86;
protected static final char TELOPT_NEWENVIRONMENT = 39;
private static String defaultBackground="black";
private static String defaultForeground="white";
private static String[] colorCodes1={ // 30-37
"black", // black
"#993300", // red
"green", // green
"#999966", // brown
"#000099", // blue
"purple", // purple
"darkcyan", // cyan
"lightgrey"}; // grey
private static String[] colorCodes2={
"gray", // dark grey
"red", // light red
"lightgreen", // light green
"yellow", // yellow
"blue", // light blue
"violet", // light purple
"cyan", // light cyan
"white" }; // white
protected String lastBackground=null;
protected String lastForeground=null;
protected boolean blinkOn=false;
protected boolean fontOn=false;
protected boolean boldOn=false;
protected boolean underlineOn=false;
protected boolean italicsOn=false;
private Siplet codeBase=null;
protected boolean comment=false;
protected boolean neverSupportMSP=false;
protected boolean neverSupportMXP=false;
protected boolean neverSupportMCCP=false;
protected boolean MSPsupport=false;
protected boolean MXPsupport=false;
protected boolean MCCPsupport=false;
private MSP mspModule=new MSP();
private MXP mxpModule=new MXP();
private TelnetFilter(){};
public TelnetFilter(Siplet codebase)
{
codeBase=codebase;
}
public static String getSipletVersion(){ return Siplet.VERSION_MAJOR+"."+Siplet.VERSION_MINOR;}
public String getEnquedResponses(){return MXPsupport()?mxpModule.getAnyResponses():"";}
public String getEnquedJScript(){return (mxpModule!=null)?mxpModule.getAnyJScript():"";}
public boolean MSPsupport(){return MSPsupport;}
public void setMSPSupport(boolean truefalse){MSPsupport=truefalse;}
public boolean MXPsupport(){return MXPsupport;}
public void setMXPSupport(boolean truefalse){MXPsupport=truefalse;}
public boolean MCCPsupport(){return MCCPsupport;}
public void setMCCPSupport(boolean truefalse){MCCPsupport=truefalse;}
public boolean isUIonHold(){return MXPsupport()&&mxpModule.isUIonHold();}
private String blinkOff(){ if(blinkOn){blinkOn=false; return "</BLINK>";}return ""; }
private String underlineOff(){ if(underlineOn){underlineOn=false; return "</U>";}return ""; }
private String fontOff()
{
if(fontOn)
{
setLastBackground(defaultBackground);
setLastForeground(defaultForeground);
fontOn=false;
return "</FONT>";
}
return "";
}
private String italicsOff(){ if(italicsOn){italicsOn=false; return "</I>";}return ""; }
private String allOff()
{
StringBuffer off=new StringBuffer("");
off.append(blinkOff());
off.append(underlineOff());
off.append(fontOff());
off.append(italicsOff());
return off.toString();
}
public static int getColorCodeIndex(String word)
{
if(word==null) word=defaultForeground;
for(int i=0;i<colorCodes1.length;i++)
if(word.equalsIgnoreCase(colorCodes1[i]))
return (40+i);
for(int i=0;i<colorCodes2.length;i++)
if(word.equalsIgnoreCase(colorCodes2[i]))
return (30+i);
return 30;
}
public static int getRelativeColorCodeIndex(String word)
{
int x=getColorCodeIndex(word);
if(x<40) return x-30;
if(x>50) return x%10;
return x-40;
}
private void setLastBackground(String val)
{
if(MXPsupport())
mxpModule.lastBackground=val;
else
lastBackground=val;
}
private void setLastForeground(String val)
{
if(MXPsupport())
mxpModule.lastForeground=val;
else
lastForeground=val;
}
private String lastBackground(){return MXPsupport()?mxpModule.lastBackground:lastBackground;}
private String lastForeground(){return MXPsupport()?mxpModule.lastForeground:lastForeground;}
private String escapeTranslate(String escapeString)
{
if(escapeString.endsWith("m"))
{
Vector V=Util.parseSemicolons(escapeString.substring(0,escapeString.length()-1),true);
StringBuffer str=new StringBuffer("");
String s=null;
int code=0;
String background=null;
String foreground=null;
for(int i=0;i<V.size();i++)
{
s=(String)V.elementAt(i);
code=Util.s0_int(s);
switch(code)
{
case 0:
if(i==(V.size()-1))
str.append(allOff());
boldOn=false;
break;
case 1:
boldOn=true;
if((V.size()==1)&&(lastForeground()!=null))
foreground=colorCodes2[getRelativeColorCodeIndex(lastForeground())];
break;
case 4:
{
if(!underlineOn)
{
underlineOn=true;
str.append("<U>");
}
break;
}
case 5:
{
if(!blinkOn)
{
blinkOn=true;
str.append("<BLINK>");
}
break;
}
case 6:
{
if(!italicsOn)
{
italicsOn=true;
str.append("<I>");
}
break;
}
case 7:
{
// this is reverse on, and requires a wierd color reversal
// from whatever the previous colors were.
// do it later
break;
}
case 8:
{
background=defaultBackground;
foreground=defaultBackground;
break;
}
case 22:
str.append(allOff());
break;
case 24:
str.append(underlineOff());
break;
case 25:
str.append(blinkOff());
break;
case 26:
str.append(italicsOff());
break;
case 30:
case 31:
case 32:
case 33:
case 34:
case 35:
case 36:
case 37:
foreground=boldOn?colorCodes2[code-30]:colorCodes1[code-30];
break;
case 39:
foreground=defaultForeground;
break;
case 40:
case 41:
case 42:
case 43:
case 44:
case 45:
case 46:
case 47:
background=colorCodes1[code-40];
break;
case 49:
background=defaultForeground;
break;
}
if((background!=null)||(foreground!=null))
{
if(lastBackground()==null)setLastBackground(defaultBackground);
if(lastForeground()==null)setLastForeground(defaultForeground);
if(background==null) background=lastBackground();
if(foreground==null) foreground=lastForeground();
if((!background.equals(lastBackground()))
||(!foreground.equals(lastForeground())))
{
str.append(fontOff());
setLastBackground(background);
setLastForeground(foreground);
fontOn=true;
if(MXPsupport())
str.append("<FONT COLOR="+foreground+" BACK="+background+">");
else
str.append("<FONT STYLE=\"color: "+foreground+";background-color: "+background+"\">");
}
}
}
return str.toString();
}
return escapeString;
}
public static final char[] mccppattern={IAC_,IAC_SB,MCCP_COMPRESS2,IAC_,IAC_SE};
public int patDex=0;
public void TelnetRead(StringBuffer buf, InputStream rawin, BufferedReader in[])
throws InterruptedIOException, IOException
{
char c=(char)in[0].read();
if(mccppattern[patDex]==c)
{
patDex++;
if((patDex>=mccppattern.length)&&(!neverSupportMCCP))
{
while(rawin.available()>0) rawin.read();
ZInputStream zIn=new ZInputStream(rawin);
if(debugTelnetCodes) System.out.println("MCCP compression started");
in[0]=new BufferedReader(new InputStreamReader(zIn));
patDex=0;
}
return;
}
else
if(patDex>0)
{
for(int i=0;i<patDex;i++)
buf.append(mccppattern[i]);
patDex=0;
}
buf.append(c);
if(c==65535) throw new java.io.InterruptedIOException("ARGH!");
}
public int TelenetFilter(StringBuffer buf, DataOutputStream response, InputStream rawin, BufferedReader[] in)
throws IOException
{
int i=0;
while(i<buf.length())
{
switch(buf.charAt(i))
{
case IAC_:
{
if(debugTelnetCodes) System.out.println("Got IAC in "+i+"/"+buf.length());
if(i>=buf.length()-2)
return i;
if(debugTelnetCodes) System.out.println("Receiving "+(int)buf.charAt(i+1));
int oldI=i;
int end=oldI+3;
switch(buf.charAt(++i))
{
case IAC_SB:
{
char[] subOptionData = new char[1024];
int subOptionCode = buf.charAt(++i);
if(debugTelnetCodes) System.out.println("Got sub-option "+subOptionCode);
int numBytes = 0;
int last = 0;
while((i<(buf.length()-1))
&&((last = buf.charAt(++i)) != -1)
&&(numBytes<subOptionData.length))
{
if((last == IAC_)&&(i<(buf.length()-1)))
{
last = buf.charAt(++i);
if(last == IAC_)
subOptionData[numBytes++] = IAC_;
else
if(last == IAC_SE)
break;
}
else
subOptionData[numBytes++] = (char)last;
}
end=i+1;
if(debugTelnetCodes) System.out.println("Got SB "+subOptionCode);
if(subOptionCode==TELOPT_TTYPE)
{
if(debugTelnetCodes) System.out.println("Responding with termtype.");
byte[] data=new byte[6];
data[0]=(short)'s';
data[1]=(short)'i';
data[2]=(short)'p';
data[3]=(short)'l';
data[4]=(short)'e';
data[5]=(short)'t';
response.writeBytes(""+IAC_+IAC_SB+TELOPT_TTYPE+(char)0);
response.write(data);
response.writeBytes(""+IAC_+IAC_SE);
response.flush();
}
else
if(subOptionCode==TELOPT_NAWS)
{
if(debugTelnetCodes) System.out.println("Responding with screen size.");
byte[] data=new byte[4];
data[1]=80;
data[3]=25;
response.writeBytes(""+IAC_+IAC_SB+TELOPT_NAWS);
response.write(data);
response.writeBytes(""+IAC_+IAC_SE);
response.flush();
}
else
if(subOptionCode==MCCP_COMPRESS2)
{
// probably need to handle this earlier
}
break;
}
case IAC_WILL:
i++;
if(buf.charAt(i)==TELOPT_NAWS)
{
if(debugTelnetCodes) System.out.println("Responding with screen size to WILL NAWS.");
byte[] data=new byte[4];
data[1]=80;
data[3]=25;
response.writeBytes(""+IAC_+IAC_SB+TELOPT_NAWS);
response.write(data);
response.writeBytes(""+IAC_+IAC_SE);
break;
}
else
if(buf.charAt(i)==IAC_MSP)
{
if(debugTelnetCodes) System.out.println("Got WILL MSP!");
if(neverSupportMSP)
{
if(MSPsupport())
{
if(debugTelnetCodes) System.out.println("Sent DONT MSP!");
response.writeBytes(""+IAC_+IAC_DONT+IAC_MSP);
response.flush();
setMSPSupport(false);
}
}
else
if(!MSPsupport())
{
if(debugTelnetCodes) System.out.println("Sent DO MSP!");
response.writeBytes(""+IAC_+IAC_DO+IAC_MSP);
response.flush();
setMSPSupport(true);
}
}
else
if(buf.charAt(i)==IAC_MXP)
{
if(debugTelnetCodes) System.out.println("Got WILL MXP!");
if(neverSupportMXP)
{
if(MXPsupport())
{
if(debugTelnetCodes) System.out.println("Send DONT MXP!");
response.writeBytes(""+IAC_+IAC_DONT+IAC_MXP);
response.flush();
setMXPSupport(false);
}
}
else
if(!MXPsupport())
{
if(debugTelnetCodes) System.out.println("Send DO MXP!");
response.writeBytes(""+IAC_+IAC_DO+IAC_MXP);
response.flush();
setMXPSupport(true);
}
}
else
if(buf.charAt(i)==MCCP_COMPRESS2)
{
if(debugTelnetCodes) System.out.println("Got WILL COMPRESS2!");
if(neverSupportMCCP)
{
if(MCCPsupport())
{
if(debugTelnetCodes) System.out.println("Send DONT COMPRESS2!");
response.writeBytes(""+IAC_+IAC_DONT+MCCP_COMPRESS2);
response.flush();
setMXPSupport(false);
}
}
else
if(!MCCPsupport())
{
if(debugTelnetCodes) System.out.println("Send DO MCCP!");
response.writeBytes(""+IAC_+IAC_DO+MCCP_COMPRESS2);
response.flush();
setMCCPSupport(true);
}
}
else
if(buf.charAt(i)!=TELOPT_BINARY)
{
if(debugTelnetCodes) System.out.println("Sent DONT "+((int)buf.charAt(i))+"!");
response.writeBytes(""+IAC_+IAC_DONT+buf.charAt(i));
response.flush();
}
break;
case IAC_WONT:
i++;
if(buf.charAt(i)==IAC_MSP)
{
if(debugTelnetCodes) System.out.println("Got WONT MSP!");
if(MSPsupport())
{
if(debugTelnetCodes) System.out.println("Sent DONT MSP!");
response.writeBytes(""+IAC_+IAC_DONT+IAC_MSP);
response.flush();
setMSPSupport(false);
}
}
else
if(buf.charAt(i)==IAC_MXP)
{
if(debugTelnetCodes) System.out.println("Got WONT MXP!");
if(MXPsupport())
{
if(debugTelnetCodes) System.out.println("Sent DONT MXP!");
response.writeBytes(""+IAC_+IAC_DONT+IAC_MXP);
response.flush();
setMXPSupport(false);
if(mxpModule!=null) mxpModule.shutdownMXP();
}
}
break;
case IAC_DO:
i++;
if(buf.charAt(i)==IAC_MSP)
{
if(debugTelnetCodes) System.out.println("Got DO MSP!");
if(neverSupportMSP)
{
if(MSPsupport())
{
if(debugTelnetCodes) System.out.println("Sent WONT MSP!");
response.writeBytes(""+IAC_+IAC_WONT+IAC_MSP);
response.flush();
setMSPSupport(false);
}
}
else
if(!MSPsupport())
{
if(debugTelnetCodes) System.out.println("Sent WILL MSP!");
response.writeBytes(""+IAC_+IAC_WILL+IAC_MSP);
response.flush();
setMSPSupport(true);
}
}
else
if(buf.charAt(i)==IAC_MXP)
{
if(debugTelnetCodes) System.out.println("Got DO MXP!");
if(neverSupportMXP)
{
if(MXPsupport())
{
if(debugTelnetCodes) System.out.println("Sent WONT MXP!");
response.writeBytes(""+IAC_+IAC_WONT+IAC_MXP);
response.flush();
setMXPSupport(false);
}
}
else
if(!MXPsupport())
{
response.writeBytes(""+IAC_+IAC_WILL+IAC_MXP);
if(debugTelnetCodes) System.out.println("Sent WILL MXP!");
response.flush();
setMXPSupport(true);
}
}
else
if(buf.charAt(i)!=TELOPT_BINARY)
{
if(debugTelnetCodes) System.out.println("Send WONT "+(int)buf.charAt(i)+"!");
response.writeBytes(""+IAC_+IAC_WONT+buf.charAt(i));
response.flush();
}
break;
case IAC_DONT:
i++;
if(buf.charAt(i)==IAC_MSP)
{
if(debugTelnetCodes) System.out.println("Got DONT MSP!");
if(MSPsupport())
{
if(debugTelnetCodes) System.out.println("Sent WONT MSP!");
response.writeBytes(""+IAC_+IAC_WONT+IAC_MSP);
response.flush();
setMSPSupport(false);
}
}
else
if(buf.charAt(i)==IAC_MXP)
{
if(MXPsupport())
{
if(debugTelnetCodes) System.out.println("Sent WONT MXP!");
response.writeBytes(""+IAC_+IAC_WONT+IAC_MXP);
response.flush();
setMXPSupport(false);
if(mxpModule!=null) mxpModule.shutdownMXP();
}
}
break;
}
buf.delete(oldI,end);
i=oldI-1;
break;
}
}
i++;
}
return buf.length();
}
// filters out color codes -> <FONT>
// CRS -> <BR>
// SPACES ->
// < -> <
// TELNET codes -> response outputstream
public int HTMLFilter(StringBuffer buf)
{
int i=0;
boolean[] eolEater=new boolean[1];
while(i<buf.length())
{
if(debugChars) System.out.println(">"+buf.charAt(i));
if(comment)
{
if(buf.substring(i,i+3).equals("-->"))
{
comment=false;
i+=3;
}
}
else
if((MXPsupport()
&&(mxpModule.eatTextUntilNextEOLN())
&&(buf.charAt(i)!='\n')
&&(buf.charAt(i)!='\r')))
{
buf.deleteCharAt(i);
i--;
}
else
switch(buf.charAt(i))
{
case '!':
if((i<buf.length()-3)
&&(buf.charAt(i+1)=='!'))
{
if(MSPsupport())
{
int endl=mspModule.process(buf,i,codeBase);
if(endl==-1)
i--;
else
if(endl>0)
return endl;
}
}
break;
case '&':
{
if(!MXPsupport())
{
buf.insert(i+1,"amp;");
i+=4;
}
else
{
int x=mxpModule.processEntity(buf,i,null,true);
if(x==Integer.MAX_VALUE) return i;
i+=x;
}
break;
}
case ' ':
buf.setCharAt(i,'&');
buf.insert(i+1,"nbsp;");
i+=5;
break;
case '>':
buf.setCharAt(i,'&');
buf.insert(i+1,"gt;");
i+=3;
break;
case '<':
if(!MXPsupport())
{
buf.setCharAt(i,'&');
buf.insert(i+1,"lt;");
i+=3;
}
else
if(((i+4)<buf.length())&&(buf.substring(i+1,i+4).equals("!--")))
comment=true;
else
{
int x=mxpModule.processTag(buf,i);
if(x==Integer.MAX_VALUE) return i;
i+=x;
}
break;
case '\n':
{
if(MXPsupport())
{
int x=mxpModule.newlineDetected(buf,i+1,eolEater);
if(eolEater[0])
buf.deleteCharAt(i);
else
{
buf.setCharAt(i,'<');
buf.insert(i+1,"BR>");
i+=3;
}
i+=x;
}
else
{
buf.setCharAt(i,'<');
buf.insert(i+1,"BR>");
i+=3;
}
break;
}
case '\r':
buf.deleteCharAt(i);
i--;
break;
case IAC_:
{
if(i>=buf.length()-3)
return i;
break;
}
case '\033':
{
int savedI=i;
if(i==buf.length()-1)
return i;
if(buf.charAt(++i)!='[')
buf.setCharAt(i,' ');
else
{
boolean quote=false;
while(((++i)<buf.length())
&&((quote)||(!Character.isLetter(buf.charAt(i)))))
if(buf.charAt(i)=='"')
quote=!quote;
if(i==buf.length())
return savedI;
String oldStr=buf.substring(savedI+2,i+1);
String translate=escapeTranslate(oldStr);
if(translate.equals(oldStr))
{
int x=mxpModule.escapeTranslate(oldStr,buf,savedI);
if(x==Integer.MAX_VALUE) return i;
i=savedI+x;
}
else
if(!translate.equals(oldStr))
{
buf.replace(savedI,i+1,translate);
i=savedI+translate.length()-1;
}
}
}
break;
}
i++;
}
return buf.length();
}
}
