Untitled

import java.io.*;import java.net.*;import java.util.*;import java.lang.*;public class HttpProtocol {	PrintWriter out= null;	BufferedReader in= null;	private Socket MySocket;	OutputStream outputstream=null;	File webRootDirector=null;	long contLength;	byte[] contL;	   	/*public OutputStream getOutputStream() {        return outputstream;		}*/					public HttpProtocol (Socket MySocket, BufferedReader in,PrintWriter out){		this.in=in;		this.out=out;		this.MySocket=MySocket;				}	 	public void processInput(){	 // InputStream streamin= mySocket.getInputStream();	 // if (streamin==null) return;	  //BufferedReader in=new BufferedReader(new InputStreamReader(streamin));	  try{	  StringTokenizer tok=new StringTokenizer(in.readLine());	  if (!tok.hasMoreTokens())	  	respond(HTTP_BADREQUEST,"Wrong Syntax.Try :GET /foo/doublefoo/foo.html");	  		   String method =tok.nextToken();	  	  if (!tok.hasMoreTokens())	  	respond(HTTP_BADREQUEST,"Wrong Syntax.No URI defined.Try :GET /foo/doublefoo/foo.html");	   	   String Uri = decodeUri1(tok.nextToken());	   	 	  Properties parameter =new Properties();	  int erotimatiko=Uri.indexOf('?');	  		if(erotimatiko>=0){	  			decodeUri2(Uri.substring(erotimatiko+1),parameter);	  			Uri	= decodeUri1(Uri.substring(0,erotimatiko));	  		}	  			  Properties header=new Properties();	  	if(tok.hasMoreTokens())	  		{	  			String epomgram=in.readLine();	  				while(epomgram.trim().length()>0){	  					int anwkatw=epomgram.indexOf(':');	  					header.put(epomgram.substring(0,anwkatw).trim(),epomgram.substring(anwkatw+1).trim());	  						  					epomgram=in.readLine();	  				}	  			}						if(method.equalsIgnoreCase("POST"))			decodeUri2(in.readLine(),parameter);		if(!method.equalsIgnoreCase("POST")&& !method.equalsIgnoreCase("GET"))			respond(HTTP_BADREQUEST,"Bad Request:we only support GET or POST methods");					Response resp=serving(Uri,method,header,parameter);		if(resp==null)		respond (HTTP_INTERNALERROR,"An Internal Server Error has occured:	server returned a null response");	else{System.out.println(resp.status);		System.out.println(resp.mimeType);		System.out.println(resp.data);						sendResponse(resp.status,resp.mimeType,resp.header,resp.data);	  //in.close();	 }//// prosekse pou einai to try .elekse kala ta { }	 }catch(IOException e){	 	try{	 		respond(HTTP_INTERNALERROR, "SERVER INTERNAL ERROR: IOException: " + e.getMessage());	 	}catch ( Throwable t ) {}	}			catch ( InterruptedException ie )			{ }	}	//problima me parentheseis			private void respond( String status, String msg ) throws InterruptedException		{			sendResponse( status, MIME_PLAINTEXT, null, new ByteArrayInputStream( msg.getBytes()));			throw new InterruptedException();	   	}						private void sendResponse(String status,String mime,Properties header,InputStream data){		try {		//	OutputStream out= mySocket.getOutputStream();		//	PrintWriter print=new PrintWriter(out);			//pws tha to paroume apo th my server thread ayto.. opws kai to in		//	OutputStream eee=setOutputStream(os);			System.out.println("HTTP/1.1 "+status+"\r\n");			out.print("HTTP/1.1 "+status+"\r\n");//allakseee toooo			out.print("Content-Type: " + mime + "\r\n");			if(header==null || header.getProperty("Date")==null)				out.print("Date:"+gmtFrmt.format(new Date())+"\r\n");							if(header!=null){				Enumeration e =header.keys();				while(e.hasMoreElements()){					String key=(String)e.nextElement();					String value =header.getProperty(key);					out.print(key+":"+value+"\r\n"); 					}			}			out.print("r\n");			out.flush();			if(data!=null){			//	byte[] buffer=new byte[2048];				while(true){					int read =data.read(contL,0,(int)contLength);					if (read<=0)					break;			//OutputStream mprizola=new BufferedOutputStream(MySocket.getOutputStream());			(MySocket.getOutputStream()).write(contL,0,read);				}			}			(MySocket.getOutputStream()).flush();					(MySocket.getOutputStream()).close();						//if(data!=null)			//data.close();		}		catch (IOException ioe){			try{				MySocket.close();				}catch(Throwable t){}			}					}	/*		//if not perl       				File f = new File(httpRootDir,requestedFile);//dimiourgia arxeiou me orismata ton trexonta				// katalogo kai to antistoixo arxeio zitisis                byte[] theData = new byte[(int) f.length( )];//dimourgia pinaka byte me megethos                //to megethos tou arxeiou zitisis                z=theData.length;//mikos tou pinaka aparaitito gia to HEADER                 if (f.canRead()==false)//diabasma arxeiou : anepitixes		void sendFile(byte[] theData,File f)    {    	//sinaritisi aposotilis tou arxeiou pou zitithike apo ton client       	try       	{       		       		DataInputStream fista = new DataInputStream(new BufferedInputStream(                          new FileInputStream(f)));                          OutputStream raw = new BufferedOutputStream(client.getOutputStream( ));                  	    	sendResponseHeader(contentType);//stelnei to aparaitito header ston client   		    fista.readFully(theData);   		    //diabazei ton pinaka byte pou iparxei sti sinartisi diadikasia_arxeiou   		    fista.close();          	raw.write(theData);//stelnei ta dedomena tou pinaka            	raw.flush();         }           	catch(IOException e)          	{          		System.out.println("error sending");           	}    }				*/						private String decodeUri1(String string) throws InterruptedException{		try {			StringBuffer buff=new StringBuffer();			for(int i=0;i<string.length();i++){				char c=string.charAt(i);				switch (c){					case '+':						buff.append(' ');						break;					case '%':						buff.append((char)Integer.parseInt(string.substring(i+1,i+3),16));						i=i+2;						break;					 default:					 	buff.append(c);					 	break;					 }				}return new String(buff.toString().getBytes());			}			catch(Exception e){				respond(HTTP_BADREQUEST,"BAD REQUEST:Problem with uri encoding");				return null;			}	} 					 	 private void decodeUri2(String param,Properties p) throws InterruptedException{	if (param==null) return;	StringTokenizer str=new StringTokenizer(param,"&");	while(str.hasMoreTokens()){		String next=str.nextToken();		int ison=next.indexOf('=');		if(ison>=0)		p.put(decodeUri1(next.substring(0,ison)).trim(),decodeUri1(next.substring(ison+1)));	}}public Response serving (String Uri,String method,Properties header,Properties parameter){	//gia na blepoume ki emeis ti ginetai	System.out.println(method+"  "+Uri);	Enumeration enume=header.propertyNames();	while(enume.hasMoreElements()){		String mtbl=(String)enume.nextElement();		System.out.println("header :"+mtbl+" = "+header.getProperty(mtbl)+"\n");}			enume=parameter.propertyNames();	while(enume.hasMoreElements()){		String mtbl=(String)enume.nextElement();		System.out.println("header :"+mtbl+" = "+parameter.getProperty(mtbl)+"\n");}			return sendingNow(Uri,header,new File("."));	}	public Response sendingNow(String Uri,Properties header,File webRootDirect){	//prwtos elegxos an ontws yparxei to arxiko  directory	if(!webRootDirect.isDirectory()){return new Response(HTTP_INTERNALERROR,MIME_PLAINTEXT,"Internal Error :given webRootDirectory is not a directory");}	//katharizoume ligo to uri gia na broume to path sthn poria enw orizoume gia fileseparator to "/"	Uri=Uri.trim().replace(File.separatorChar,'/');	if (Uri.indexOf('?')>=0){Uri=Uri.substring(0,Uri.indexOf('?'));}	//prosexoume na mhn eksipiretoume ../ uri pou bgainoun apo to root tou webserver mas	if(Uri.startsWith("..")||Uri.indexOf( "../" ) >= 0)	return new Response(HTTP_FORBIDDEN,MIME_PLAINTEXT,"Server doesn't allow <..> characters");	File f = new File( webRootDirect, Uri ); //ftiaxnoume ena path xrisimopoiwntas to url		if (!f.exists())		return new Response(HTTP_NOTFOUND,MIME_PLAINTEXT,"Error 404 file not found.");		//koitame an yparxei to file mas 	if (f.isDirectory()){		//koitame an yparxei to index.html h to index.htm se periptwsh pou mas exdei dwthei mono to directory		if (new File(f,"index.html").exists())			f=new File(webRootDirect,Uri+"index.html");//prosthetoume me ayton ton tropo sto uri to index.html kai ayto to kanoume 													   //path mesw ths file to opoio elegxoume an yparxei ontws.to idio kai gia tin index.htm		else if (new File(f,"index.htm").exists())			f=new File(webRootDirect,Uri+"index.htm");		//an den yparxei index file kanoume list to directory se morfi html 					else {		String[] arxeia_ola=f.list();		String msg ="<html><body><h1>Directory " + Uri + "</h1><br/>";		if(Uri.length()>1){			String path=Uri.substring(0,Uri.length()-1); //bgazoume to teleytaio "/"			int slas=path.lastIndexOf('/');			if (slas>=0 && slas<path.length()) // an twra  yparxei slas sto uri kai h thesi tou einai kapoios deiktis mikroteros apo to mhkos			msg+="<b><a href=\"" + Uri.substring(0, slas+1) + "\">..</a></b><br/>"; // ftiaxnoume to link gia ton prohgoumeno fakelo			}		for (int i=0; i<arxeia_ola.length;i++){			File thisfile=new File(f,arxeia_ola[i]);			if(thisfile.isDirectory()){					arxeia_ola[i]+="/" ;// bazoume ena slas stous fakelous gia na ksexwrizoun					}			msg+="<a href=\"" + URLEncoder.encode( Uri + arxeia_ola[i]) + "\">" + 			arxeia_ola[i] + "</a>"; // to kanoume encode gia na leitourgisei san link gia to ekastote arxeio			}						return new Response(HTTP_OK,MIME_HTML,msg);									}		}	String mime=null;	int tel=Uri.lastIndexOf('.');	if (tel<0||tel>Uri.length()) 		mime=MIME_DEFAULT_BINARY;	if (tel>=0)		mime=(String)getMimeTypes.get(Uri.substring(tel+1).toLowerCase());	try{		FileInputStream file=new FileInputStream(f);		contL=new byte[(int) f.length()];		contLength=contL.length;		System.out.println(contLength);		String stringlenth=String.valueOf(contLength);		System.out.println(stringlenth);		Response resp= new Response(HTTP_OK,mime,file);		resp.putHeader("Content-length",stringlenth);//""+ f.length());	//	resp1.header.put("Content-length",""+ f.length());		System.out.println(contLength);		return resp;	}catch (IOException e){		return new Response(HTTP_FORBIDDEN, MIME_PLAINTEXT, "FORBIDDEN: failed to serve the requested file." );	}							}private static Hashtable getMimeTypes = new Hashtable();	static	{		StringTokenizer st = new StringTokenizer(			"htm		text/html "+			"html		text/html "+			"txt		text/plain "+			"asc		text/plain "+			"gif		image/gif "+			"jpg		image/jpeg "+			"jpeg		image/jpeg "+			"png		image/png "+			"mp3		audio/mpeg "+			"m3u		audio/mpeg-url " +			"pdf		application/pdf "+			"doc		application/msword "+			"ogg		application/x-ogg "+			"zip		application/octet-stream "+			"exe		application/octet-stream "+			"class		application/octet-stream " );		while ( st.hasMoreTokens())			getMimeTypes.put( st.nextToken(), st.nextToken());	}				private static java.text.SimpleDateFormat gmtFrmt;	static	{		gmtFrmt = new java.text.SimpleDateFormat( "E, d MMM yyyy HH:mm:ss 'GMT'", Locale.US);		gmtFrmt.setTimeZone(TimeZone.getTimeZone("GMT"));	}public static final String		HTTP_OK = "200 OK",		HTTP_REDIRECT = "301 Moved Permanently",		HTTP_FORBIDDEN = "403 Forbidden",		HTTP_NOTFOUND = "404 Not Found",		HTTP_BADREQUEST = "400 Bad Request",		HTTP_INTERNALERROR = "500 Internal Server Error",		HTTP_NOTIMPLEMENTED = "501 Not Implemented";		public static final String		MIME_PLAINTEXT = "text/plain",		MIME_HTML = "text/html",		MIME_DEFAULT_BINARY = "application/octet-stream";} class Response{		String HTTP_OK = "200 OK";	public String status; // meta thn antistoixish twn dynatwn timwn se metabliti p.x 200 OK	public String mimeType; // edw apothikeyoume times opws to "text/plain"	public InputStream data;	public Properties header;// arxikopoioume edw gia na ftiaksoume methodo prosthesis ki allwn timwn sthn header			//kataskeyastes	public Response(){this.status=HTTP_OK;}//gia data kai mime null	public Response(String status,String mimeType,InputStream data){		this.status=status;		this.mimeType=mimeType;		this.data=data;}			public Response(String status,String mimeType,String message){		this.status=status;		this.mimeType=mimeType;		this.data=new ByteArrayInputStream(message.getBytes());}	//xrhsimopoioume mia methodo gia na mporoume na prosthetoume ston hashtable headers	public void putHeader(String mtbl,String value){		header.put( mtbl, value);	}	}