package de.tudarmstadt.informatik.hostage.protocol; import java.util.ArrayList; import java.util.List; /** * HTTP protocol * @author Wulf Pfeiffer */ public final class HTTP implements Protocol { /** * Represents the states of the protocol */ private enum STATE { NONE, CLOSED } /** * Denotes in which state the protocol is right now */ private STATE state = STATE.NONE; @Override public int getPort() { return 80; } @Override public TALK_FIRST whoTalksFirst() { return TALK_FIRST.CLIENT; } @Override public List processMessage(String message) { List response = new ArrayList(); request = message + request; switch(state) { case NONE: if(!message.contains(version)){ response.add(buildPacket(versionUnsupported, "")); } else if(message.contains(get)) { response.add(buildPacket(ok, get)); } else if(message.contains(head)) { response.add(buildPacket(ok, head)); } else if(message.contains(trace)){ response.add(buildPacket(ok, trace)); } else if(message.contains(options)){ response.add(buildPacket(methodNotAllowed, options)); } else if(message.contains(post)){ response.add(buildPacket(methodNotAllowed, post)); } else if(message.contains(put)){ response.add(buildPacket(methodNotAllowed, put)); } else if(message.contains(delete)){ response.add(buildPacket(methodNotAllowed, delete)); } else if(message.contains(connect)){ response.add(buildPacket(methodNotAllowed, connect)); } else { response.add(buildPacket(badRequest, "")); } state = STATE.CLOSED; default: state = STATE.CLOSED; } return response; } @Override public boolean isClosed() { return state == STATE.CLOSED; } @Override public boolean isSecure() { return false; } @Override public Class getType() { return String.class; } @Override public String toString() { return "HTTP"; } /** * Builds a html response that can be sent * @param code response code that was determined * @param type request type that was sent by the client * @return the html response */ private String buildPacket(String code, String type) { String doc = ""; if(type.equals(get)) doc = htmlDoc; else if(type.equals(head)) doc = ""; else if(type.equals(trace)) doc = request; else doc = errorHtmlPrefix + code + errorHtmlSuffix; return version + code + headerPrefix + doc.length() + headerSuffix + doc; } /** Whole request that was sent by the client */ private String request = ""; private String version = "HTTP/1.1"; //request codes private String options = "OPTIONS"; private String get = "GET"; private String head = "HEAD"; private String post = "POST"; private String put = "PUT"; private String delete = "DELETE"; private String trace = "TRACE"; private String connect = "CONNECT"; //response codes private String ok = " 200 OK\r\n"; private String badRequest = " 400 Bad Request\r\n"; private String methodNotAllowed = " 405 Method Not Allowed\r\n"; private String versionUnsupported = " 505 HTTP Version not supported\r\n"; //html header pre and suffix private String headerPrefix = "Date: Mon, 01 Jul 2013 18:27:55 GMT\r\n" + "Server: Apache/2.2.22 (Debian)\r\n" + "Vary: Accept-Encoding\r\n" + "Content-Length: "; private String headerSuffix = "\r\n" + "Keep-Alive: timeout=5, max=100\r\n" + "Connection: Keep-Alive\r\n" + "Content-Type: text/html\r\n" + "\r\n"; //html website private String htmlDoc = "\n" + "\n" + "\n" + "\n" + "Test successful\n" + "\n" + "\n" + "

Test successful

\n" + "

Congratulations.

\n" + "\n" + ""; //html error pre and suffix private String errorHtmlPrefix = "\n" + "\n" + "\n" + "\n" + ""; private String errorHtmlSuffix = "\n" + "\n" + "\n" + "\n" + ""; }