This is a HTTP Server example using the new EthernetInterface and new mbed-rpc libraries.
Dependents: HTTP-RPCServerExample
Fork of HTTPServer by
Diff: HTTPConnection.cpp
- Revision:
- 0:7a2421e63e74
- Child:
- 1:6b7472d5e9ee
--- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/HTTPConnection.cpp Sun May 26 20:13:28 2013 +0000 @@ -0,0 +1,219 @@ +/* HTTPConnection.cpp */ + +#include "mbed.h" +#include "HTTPConnection.h" + +#include <vector> +using std::vector; + +using std::string; + +#if (1 && !defined(TARGET_LPC11U24)) +#define INFO(x, ...) std::printf("[HttpConnection : INFO]"x"\r\n", ##__VA_ARGS__); +#define WARN(x, ...) std::printf("[HttpConnection : WARN]"x"\r\n", ##__VA_ARGS__); +#define ERR(x, ...) std::printf("[HttpConnection : ERR]"x"\r\n", ##__VA_ARGS__); +#else +#define INFO(x, ...) +#define WARN(x, ...) +#define ERR(x, ...) +#endif + + + + +HTTPConnection::HTTPConnection() +{ +} + + +HTTPConnection::~HTTPConnection() +{ + close(); +} + +void HTTPConnection::close() +{ + m_Msg.headers.clear(); +} + +int HTTPConnection::poll() +{ + static char buffer[256] = {}; + static char echoHeader[256] = {}; + + + int rcvd= 0; + INFO("[HTTPConnection]Waiting for new data in connection"); + // Try receiving request line + rcvd = receiveLine(buffer, 255, 3000); + if (rcvd == -1) { + // there was an error, probably the connection was closed, so close this connection as well + INFO("No more data available. Will close this connection now."); + close(); + return -1; + } + + // The Request has not yet been received so try it + rcvd = parse(buffer); + if (rcvd == -1) { + // Invalid content received, so close the connection + INFO("Invalid message received, so sending negative response and closing connection !"); + sprintf(echoHeader,"HTTP/1.1 400 NOK\n\rContent-Length: %d\n\rContent-Type: text\n\rConnection: Close\n\r\n\r",strlen(buffer)); + m_Tcp.set_blocking(true, 1500); + m_Tcp.send(echoHeader,strlen(echoHeader)); + m_Tcp.send(buffer,strlen(buffer)); + close(); + rcvd = -1; + return -1; + } + // The request has been received, try receive the body + while(rcvd > 0) { + rcvd = receiveLine((char*)buffer, 255, 3000); + // First check if we received an empty line. This would indicate the end of the message or message body. + if (rcvd < 0) { + // there was an empty line, so we can start with performing the request + INFO("Request Header was received completely. Performing request."); + rcvd = 0; + break; + } + else { + // add message body + if (parseHeader(buffer) == 0) { + } + else { + WARN("Invalid message header received !"); + } + } + } + if (rcvd == 0) { + sprintf(echoHeader,"HTTP/1.1 200 OK\n\rContent-Length: %d\n\rContent-Type: text\n\rConnection: Close\n\r\n\r",strlen(buffer)); + m_Tcp.set_blocking(true); + m_Tcp.send_all(echoHeader,strlen(echoHeader)); + m_Tcp.send_all(buffer,strlen(buffer)); + + /// INSERT PRCESSING OF REQUESST HERE + /// END OF PROCESSING REQUEST + + // Do not close the connection, it may be reused + } + INFO("Leaving poll function!"); + return rcvd; +} + +int HTTPConnection::receiveLine(char* szLine, int nMaxLen, int nTimeout, char cLineTerm) +{ + if ((szLine == NULL) || (nMaxLen == 0)) + return -1; + + m_Tcp.set_blocking(false); + + Timer tm; + int i; + + // Try to receive up to the max number of characters + for (i = 0 ; i < nMaxLen-1 ; i++) { + int c; + c = m_Tcp.receive_all( szLine + i, 1 ); + // Check that - if no character was currently received - the timeout period is reached. + if ((c == 0) || (c==-1)) { + // no character was read, so check if operation timed out + if (tm.read_ms() > nTimeout) { + // Operation timed out + INFO("Timeout occured in function 'receiveLine'."); + return -1; + } + } + + // Check if line terminating character was received + if (szLine[i] == cLineTerm) + break; + } + // Terminate with \0 + szLine[i] = 0; + + // Trim for '\r' linefeed at the end + if( (i >0) && (szLine[i-1] == '\r')) { + i--; + szLine[i] = 0; + } + INFO("receiveLine : \"%s\".", szLine); + + // return number of characters received in the line or return -2 if an empty line was received + if ((i == 0) || ((i==1) &&(szLine[0] == '\r'))) + { + // empty line received, so return -2 + return -2; + } + return i; +} + +int HTTPConnection::parse(const char* buffer) +{ + if ((buffer == NULL) || (strlen(buffer) < 4)) { + ERR("Buffer content is invalid or too short."); + return -1; + } + + vector<std::string> args; + args.clear(); + + // decompose string into a list of arguments + char s = 0; // current starting char + static char buff[255] = {}; + for (int i = 0 ; i < strlen(buffer)+1 ; i++) { + if ((buffer[i] == ' ') || (buffer[i] == '\n') || (buffer[i] == 0)) { + // new arg found + strncpy(buff, &buffer[s], i-s); + buff[i-s] = 0; + INFO("Found argument \"%s\"", buff); + args.push_back(std::string(buff)); + s = i+1; + } + } + + if (args.at(0) == "GET") { + m_Msg.request = HTTP_RT_GET; + m_Msg.uri = args[1]; + m_Msg.version = args[2]; + } + else { + if (args.at(0) == "POST") { + m_Msg.request = HTTP_RT_GET; + m_Msg.uri = args[1]; + m_Msg.version = args[2]; + } + else { + INFO("unhandled message."); + } + } + args.clear(); + + return 1; +} + + +int HTTPConnection::parseHeader(const char *buffer) +{ + if ((strlen(buffer) <3) || (buffer == NULL)) + return -1; + + // decompose string into a touple of <field name> : <field value> + static char fieldname[256] = {}; + static char fieldvalue[256] = {}; + for (int i = 0 ; i < strlen(buffer)+1 ; i++) { + if (buffer[i] == ':') { + // touple found + strncpy(fieldname, buffer, i); + fieldname[i] = 0; + strcpy(fieldvalue, &buffer[i+1]); + +// m_Msg.headers[fieldname] = fieldvalue; + + INFO("Header name=\"%s\" : value=\"%s\".", fieldname, fieldvalue); + return 0; + } + } + + ERR("Did not recieve a valid header : \"%s\".", buffer); + return -1; +}