import java.applet.*; //import java.awt.*; import java.awt.event.*; import javax.swing.Timer; import java.awt.image.*; import java.net.InetSocketAddress; import java.net.InetAddress; import java.lang.*; import java.io.*; import java.net.*; import java.util.Date; import java.text.SimpleDateFormat; import java.util.Scanner; import java.util.HashMap; import javax.swing.JOptionPane.*; import java.util.Enumeration; import java.util.List; import java.util.ArrayList; class ConnHandler implements Runnable { Socket sock; ResManager res; final int TYPE_GET = 0; final int TYPE_POST = 1; public ConnHandler(Socket s, ResManager r) { sock = s; res = r; } /* parseAjax * Ajax content is in form of * (key=value\n)*\n\n * returns a string:string hashmap of key value pairs */ HashMap parseAjax(BufferedReader sin) { HashMap req = new HashMap(); Scanner scan = new Scanner(sin); scan.useDelimiter("\n\n"); String all = scan.next(); req.put("req", all); for ( String line : all.split("\n")) { String kv[] = line.split("="); req.put(kv[0], kv[1]); } return req; } String ajaxCall(String dest, BufferedReader sin) { Socket client = null; PrintWriter out = null; BufferedReader in = null; // Get Ajax call Scanner scan = new Scanner(sin); scan.useDelimiter("\n\n"); String all = scan.next(); //res.log("Sending to " + dest + ": '" + all +"'"); // clean up dest // Connect to dest try { //res.alert(dest); String[] d = dest.split(":"); //res.alert(Integer.toString( d.length)); String p = "2600"; if (d.length > 1) p = d[1]; client = new Socket(d[0], Integer.parseInt(p)); //InetAddress addr = new InetSocketAddress("127.0.0.1"); if (!client.isConnected()) res.error("failed to connect!!!!!!!"); out = new PrintWriter(client.getOutputStream(), true); in = new BufferedReader(new InputStreamReader(client.getInputStream())); } catch (Exception e) { res.log( "ERROR> Exception in ajaxCall (Connecting): " + e.toString()); return ""; } //res.alert("Established connection"); // HTTP / AJAX Header + call out.print("POST / HTTP/1.1\r\n" + "Host: " + dest + "\r\n" + "User-Agent: Cortex\r\n" + "Accept: text/html,application/xhtml+xml,application/xml;q=0.9,*/*;q=0.8\r\n" + "Accept-Language: en-us,en;q=0.5\r\n"+ "Accept-Encoding: gzip,deflate\r\n" + "Accept-Charset: ISO-8859-1,utf-8;q=0.7,*;q=0.7\r\n" + "Keep-Alive: 300\r\n" + "Connection: keep-alive\r\n" + "Content-Type: application/x-www-form-urlencoded; charset=UTF-8\r\n" + "Referer: " + getIPAddress() + ":" + Integer.toString(res.PORT) + "/client.html\r\n" + "Content-Length: " + (all.length()+2) + "\r\n" + "Pragma: no-cache\r\n" + "Cache-Control: no-cache\r\n" + "\r\n"); out.print(all + "\n\n"); out.flush(); //res.alert("SENT: " + all); //res.log("sent message"); //out.close(); //res.alert("printed request, trying to read"); // Read response String resp = ""; // read http header //res.log("Reading resp header"); try { if (in.ready()) { String header = in.readLine(); if (header.length() >= 3) { //res.log("header: " + header); header = in.readLine(); } } } catch (Exception e) { res.error("Exception in ajaxCall (reading HTTP response header): " + e.toString()); return ""; } //res.log("Reading response body"); //res.alert("done reading resp header"); // read actual response scan = new Scanner(in); scan.useDelimiter("\n\n"); resp = scan.next(); //res.alert("done reading resp"); //res.log("Closing ajaxCall"); try { in.close(); out.close(); client.close(); } catch (Exception e) { res.error( "Exception in ajaxCall (Closing Connection): " + e.toString()); } //res.alert("closed connections"); //res.log("ajaxCall returning response to js caller: '" + resp + "'"); return resp; } // Function to enumerate all IP addresses of a computer // and then try and select the web facing one private String getIPAddress() { ArrayList ips = new ArrayList(); try { Enumeration e = NetworkInterface.getNetworkInterfaces(); while(e.hasMoreElements()) { NetworkInterface ni = (NetworkInterface) e.nextElement(); Enumeration e2 = ni.getInetAddresses(); InetAddress ip=null; String istr = null; while (e2.hasMoreElements()){ ip = (InetAddress) e2.nextElement(); istr = ip.toString(); if (istr.substring(0,1).equals("/")) istr = istr.substring(1); if (istr.charAt(0) >= '0' && istr.charAt(0) <= '9' && istr.indexOf(':') == -1) { //res.log("adding: '" + istr +"'"); ips.add(istr); } //ip = (InetAddress) e2.nextElement(); } /*if (ip == null) continue; istr = ip.toString(); if (istr.substring(0,1).equals("/")) istr = istr.substring(1); ips.add(istr);*/ } } catch (Exception e) { res.error( "Exception in ConnHandler.getIPAddress(): " + e.toString()); } // Now we have a list of IPs associated with this machine. Lets pick the best one if (ips.size() == 0) return ""; else if (ips.size() == 1) return ips.get(0); else { ips.remove("127.0.0.1"); /*for (int i=0; i< ips.size(); i++) { if(ips.size() ==1) break; String ip = ips.get(i); if ( */ // Many IPs so weed out baddies for (int i=0; i < ips.size(); i++) { if (ips.size() == 1) break; String ip = ips.get(i); // remove local private subnets if(ip.substring(0, 7).equals("192.168")) { ips.remove(i); i--; } else if (ip.substring(0, 3).equals("10.")) { ips.remove(i); i--; } } return ips.get(0); } } /* handleAjax * handle the various ajax commands appropriately */ private String handleAjax(HashMap req) { String response = ""; String cmd = req.get("cmd"); //res.log("AJAX " + cmd); if (cmd.equals("ping")) { response = "pong"; //res.log("PING pong"); } else if (cmd.equals("greet")) { response = getIPAddress() + ":" + res.PORT + " " + res.getNodeData("originURL") ; } else if (cmd.equals("getLog")) { res.debug("getLog"); ArrayList l = res.getLog(); if (l.size() == 0) { res.debug("logWait"); res.logWait(); l = res.getLog(); } res.debug("process Log"); response = ""; for (int i = l.size()-1; i >= 0; i--) { response += l.get(i) + "\n"; } // response += " "; } else if (cmd.equals("reloadHTML")) { res.log("Reloading HTML from src..."); res.reloadSite(); } else if (cmd.equals("sendMsg")) { //res.log("sendMsg: query=" + req.get("query")); res.queueMsg(req.get("req")); response = "received on " + res.PORT; } else if (cmd.equals("getMsgs")) { res.debug("getMsgs"); ArrayList mq = res.getMsgs(); if (mq.size() == 0) { res.debug("mqWait"); res.mqWait(); mq = res.getMsgs(); } res.debug("mq process"); for(int i =0; i < mq.size(); i++) { response += mq.get(i) + "\n\n"; } //res.log("getMsgs: '" + response + "'"); //response = ""; } else if (cmd.equals("kill")) { res.killSwitch = true; } else { response = "Unknown cmd: " + cmd; res.log("Unknown cmd: " + cmd); } return response; } /* Handle GET requests * A GET request is a generic browser request, * meaning not an AJAX request, so we serve the main * interface html file. */ private byte[] handleGet(String req) { //javax.swing.JOptionPane.showMessageDialog(null, "GET: " + req); int end = req.indexOf(' '); req = req.substring(1, end); //res.alert("'" + req + "'"); if (req.equals("")) req = "shell.html"; byte[] r = res.getSite(req); if (r == null) { //javax.swing.JOptionPane.showMessageDialog(null, "Error: file not found: " + req); return new byte[0]; } else return r; } /* run * Handle a HTTP connection * Read the HTTP request and handle accordingly * GET requests all get the main html file * AJAX requests are managed accordingly */ public void run() { /*try { Thread.currentThread().sleep(10000); } catch (Exception e) { res.alert("EXCEPTION : " + e.toString()); } res.alert("Done waiting");*/ try { // READ HTTP / AJAX call BufferedReader sin = new BufferedReader(new InputStreamReader(sock.getInputStream())); String header= ""; int i = 0; int type = TYPE_POST; String reqLine = ""; int contentLength = 0; header = sin.readLine(); if (header == null) { // no header, not a valid HTTP conn res.log("Invalid connection"); return; } String userAgent = "agent"; while (header != null && header.length() >= 3) { if ( header.substring(0, 3).equals("GET")) { type = TYPE_GET; reqLine = header; } else if (header.length() > 4 && header.substring(0, 4).equals("POST")) { reqLine = header; reqLine = reqLine.substring(5); int end = reqLine.indexOf(' '); reqLine = reqLine.substring(0, end); if (reqLine.charAt(0) == '/') reqLine = reqLine.substring(1); } else if (header.length() > 14 && header.substring(0, 14).toLowerCase().equals("content-length")) { contentLength = Integer.parseInt(header.substring(16)); } else if (header.length() > 10 && header.substring(0, 10).equals("User-Agent")) { //javax.swing.JOptionPane.showMessageDialog(null, header); userAgent = header; } //System.out.println(i + ": '" + header + "'"); i++; header = sin.readLine(); } //res.alert("Done reading header"); // Figure out response String ajax_resp=""; byte[] get_resp= null; String CODE = "200 OK"; int resp_length = 0; String content_type = "text/html"; if (type == TYPE_GET) { reqLine = reqLine.substring(4); res.log("GET " + reqLine); get_resp = handleGet(reqLine); if (get_resp.length == 0) { CODE = "404 Not Found"; } resp_length = get_resp.length; String end = reqLine.substring(reqLine.length()-4); if (end == ".js") content_type = "text/javascript"; else if (end == "css") content_type= "text/css"; } else { // No forward if (reqLine.equals("")) { //res.alert("no forward, parse ajax"); HashMap req = parseAjax(sin); //res.alert("handleAjax"); ajax_resp = handleAjax(req); //res.alert("ajax resp: " + ajax_resp); } else { // Forward request to node //res.log("AJAX forward to '" + reqLine + "'"); ajax_resp = reqLine; ajax_resp = ajaxCall(reqLine, sin); } resp_length = ajax_resp.length(); } // HTTP Response PrintWriter sout = new PrintWriter(sock.getOutputStream(), true); Date now = new java.util.Date(); SimpleDateFormat formater = new SimpleDateFormat("E, d M y H:m:s z"); sout.print("HTTP/1.1 " + CODE + "\r\n"+ "Date: " + formater.format(now) + "\r\n" + "Content-Type: " + content_type + "; charset=UTF-8\r\n" + "Server: Cortex @ " + Integer.toString(res.PORT) + "\r\n"); // Print response sout.print("Content-Length: " + resp_length + "\r\n" + "\r\n"); sout.flush(); if (type == TYPE_GET) { //sout.write(get_resp); sock.getOutputStream().write(get_resp); } else { sout.print(ajax_resp); //res.alert("ajax returning: " + ajax_resp); } sout.flush(); sin.close(); sout.close(); sock.close(); } catch (IOException e) { res.error( "IOException in ConnHandler.run(): " + e.toString()); System.out.println("IOException in ConnHandler.run()"); } System.out.println("DONE run()"); } }