Mauricio Donatti
/
HTTP_SERVER
Important changes to repositories hosted on mbed.com
Mbed hosted mercurial repositories are deprecated and are due to be permanently deleted in July 2026.
To keep a copy of this software download the repository Zip archive or clone locally using Mercurial.
It is also possible to export all your personal repositories from the account settings page.
Fork of
HTTP_SERVER
by 
Akifumi Takahashi
Revision 14:f21da0acc9f6, committed 2018-05-10
- Comitter:
- mmdonatti
- Date:
- Thu May 10 20:24:03 2018 +0000
- Parent:
- 13:b6dd6ed0060b
- Commit message:
- Simple server GET and POST for one index.html page and javascript
Changed in this revision
--- a/HTTP_SERVER.cpp Fri Mar 16 21:55:50 2018 +0000
+++ b/HTTP_SERVER.cpp Thu May 10 20:24:03 2018 +0000
@@ -1,9 +1,82 @@
#include "HTTP_SERVER.h"
-#include "string"
+
#ifndef DEBUG
//#define DEBUG
#endif
+//HTML file - with Javascript
+const char *index_html = "<html><head><title>DCM Heaters Driver</title><link rel=\"shortcut icon\" type=\"image/x-icon\" href=\"http://cnpem.br/wp-content/uploads/2018/01/LNLS_Sirius-02-293x300.png\" />\n\
+<script src=\"https://ajax.googleapis.com/ajax/libs/jquery/3.3.1/jquery.min.js\"></script></head>\n\
+<script language=\"javascript\" type=\"text/javascript\">\n\
+function loop(){\n\
+$.post(\"read_data\", function(data){\n\
+if(data.length >0)\n\
+{\n\
+var str = data;\n\
+var res = str.split(\" \");\n\
+if(res.length == 97){\n\
+var table = '<div id=\"data_table\">'+\n\
+'<table width=\"100%\" border=\"1\" cellpadding=\"3\" cellspacing=\"1\" bgcolor=\"#E3EBFB\">'+\n\
+'<tr align=\"center\" valign=\"middle\">'+\n\
+'<td width=\"50\" height=\"40\"><strong>Channel</font></strong></td>'+\n\
+'<td width=\"96\" height=\"40\"><strong>Voltage (V)</font></strong></td>'+\n\
+'<td width=\"96\" height=\"40\"><strong>Current (A)</font></strong></td>'+\n\
+'<td width=\"96\" height=\"40\"><strong>Control (%)</font></strong></td>'+\n\
+'<td width=\"96\" height=\"40\"><strong>Current Limit (A)</font></strong></td>'+\n\
+'<td width=\"96\" height=\"40\"><strong>Failure</font></strong></td>'+\n\
+'<td width=\"96\" height=\"40\"><strong>Overload</font></strong></td>'+\n\
+'<td width=\"96\" height=\"40\"><strong>No Load</font></strong></td>'+\n\
+'<td width=\"96\" height=\"40\"><strong>Enable</font></strong></td></tr>';\n\
+for(var i=0;i<8;i++){\n\
+table = table + '<tr align=\"center\" valign=\"middle\">'+\n\
+'<td width=\"50\" height=\"31\"bgcolor=\"#FFFFFF\"><span style=\"font-weight:bold;\">'+(i+1)+'</span></td>'+\n\
+'<td width=\"96\" height=\"28\"bgcolor=\"#FFFFFF\"><span style=\"font-weight:bold;\">'+res[i*12]+'</span></td>'+\n\
+'<td width=\"96\" height=\"28\"bgcolor=\"#FFFFFF\"><span style=\"font-weight:bold;\">'+res[i*12+1]+'</span></td>'+\n\
+'<td width=\"96\" height=\"28\"bgcolor=\"#FFFFFF\"><span style=\"font-weight:bold;\">'+res[i*12+2]+'</span></td>'+\n\
+'<td width=\"96\" height=\"28\"bgcolor=\"#FFFFFF\"><span style=\"font-weight:bold;\">'+res[i*12+3]+'</span></td>'+\n\
+'<td width=\"96\" height=\"28\"bgcolor=\"'+res[i*12+4]+'\"><span style=\"font-weight:bold;\">'+res[i*12+5]+'</span></td>'+\n\
+'<td width=\"96\" height=\"28\"bgcolor=\"'+res[i*12+6]+'\"><span style=\"font-weight:bold;\">'+res[i*12+7]+'</span></td>'+\n\
+'<td width=\"96\" height=\"28\"bgcolor=\"'+res[i*12+8]+'\"><span style=\"font-weight:bold;\">'+res[i*12+9]+'</span></td>'+\n\
+'<td width=\"96\" height=\"28\"bgcolor=\"'+res[i*12+10]+'\"><span style=\"font-weight:bold;\">'+res[i*12+11]+'</span></td>'+\n\
+'</tr>';\n\
+}\n\
+table = table + '</table></div>';\n\
+document.getElementById(\"data_table\").innerHTML = table;\n\
+}}\n\
+});\n\
+setTimeout(function(){ loop() }, 2000);\n\
+}\n\
+</script>\n\
+<body onLoad=\"loop()\">\n\
+<table width=\"100%\"border=\"0\" cellspacing=\"0\" cellpadding=\"0\" style=\"font-weight:normal;\">\n\
+<tr>\n\
+<td width=\"25%\" height=\"142\" align=\"center\" valign=\"middle\" style=\"border-bottom: #000000 solid 1px;\">\n\
+<a href=\"http://www.lnls.cnpem.br/\"><img src=\"http://lnls.cnpem.br/wp-content/themes/lnls-v2/assets/images/logo-header.svg\" alt=\"LNLS\" width=\"305\" height=\"142\" /></a></td>\n\
+<td colspan=\"5\" height=\"142\" align=\"center\" scope=\"col\" style=\"border-bottom: #000000 solid 1px;\"><p><span class=\"style7\">DCM HEATERS DRIVER<br /><br/>\n\
+<strong>DIAGNOSTICS<br/></strong></span></p>\n\
+<p><span class=\"style7\"><strong><em> <a href=\"http://www.lnls.cnpem.br\">LNLS</a></em></strong></span></p></td>\n\
+<td width=\"25%\" height=\"142\" align=\"center\" style=\"border-bottom: #000000 solid 1px;\">\n\
+<a href=\"http://www.lnls.cnpem.br/grupos/gae/\"><img src=\"http://www.gae.agency/wp-content/uploads/2016/03/Logo_gae_hp_blue.png\" alt=\"GAE\" width=\"305\" height=\"99\" /></a></td>\n\
+</tr>\n\
+</table>\n<div id=\"data_table\"></div></body></html>\0";
+
+//table colors vector
+const char *color[] = {"#C8FFC8\0","#FF0000\0"};
+
+int index_html_len; //index with html length
+
+char buffer[MAX_BUFFER_SIZE]; //receive and transmit buffer
+char tmp_buffer[200]; //aux buffer
+int status_code; //http status code
+char reason_phrase[30]; //http reason phrase
+
+char httpmethod[20]; //http method
+char filepath[20]; //file requested
+char http_ver[20]; //http version
+
+int idx_buffer; //index buffer
+
+//Debug functions
namespace HTTP_SERVER
{
void DEBUG_PRINT_LINE(const char* arg_line)
@@ -37,181 +110,124 @@
HttpServer::HttpServer()
{
- keep_alive = (false);
- listening_flag = (false);
- req_buf[0] = '\0';
+ buffer[0] = '\0'; //constructor
}
HttpServer::~HttpServer()
{
}
-
bool HttpServer::init()
{
-
-// Ethernet Initialization
- if(eth.init()) {
- printf("(HTTP_SERVER) Error!@EthernetInterface::init()\r\n");
- return false;
- }
- // Ethernet Connecting setup
- if(eth.connect()) {
- printf("(HTTP_SERVER) Error!@EthernetInterface::connect()\r\n");
- return false;
- } else {
- printf("(HTTP_SERVER) IP Address is %s\r\n", eth.getIPAddress());
- }
// TCP Socket setup
// To open Server-side PORT
if(tcpsvr.bind(TCP_PORT)< 0) {
- printf("(HTTP_SERVER) Error!@TCPSocketServer::bind()\r\n");
return false;
- } else {
- printf("(HTTP_SERVER) TCP Server has bounden!\r\n");
- }
+ }
+ tcpsvr.set_blocking(true,1500); //set blocking socket
+
// Server start listening Request from a web browser.
- if(tcpsvr.listen(1) < 0) {
- printf("(HTTP_SERVER) tcp server listen failed.\r\n");
+
+ if(tcpsvr.listen(5) < 0) {
return false;
- } else {
- listening_flag = true;
- printf("(HTTP_SERVER) tcp server is listening...\r\n");
}
+
+ index_html_len = strlen(index_html); //calculate string length
return true;
}
-bool HttpServer::run()
-{
- DigitalOut led1(LED1);
- DigitalOut led2(LED1);
-
- while (listening_flag) {
- led1 = true;
- // blocking mode (never timeout)
- // waiting client connection
- printf("(HTTP_SERVER) waiting connection\r\n");
- if(tcpsvr.accept(tcpcon) < 0) {
- printf("(HTTP_SERVER) failed to accept connection.\r\n");
- return -1;
- } else {
- printf("(HTTP_SERVER) connection success!\r\nIP: %s\r\n",tcpcon.get_address());
- led2 = true;
+bool HttpServer::run(channel *CH)
+{
+ if(tcpsvr.accept(tcpcon) < 0) {
+ //printf("(HTTP_SERVER) failed to accept connection.\r\n");
+ return -1;
+ }
+ // When conected
+ while(tcpcon.is_connected())
+ {
+ tcpcon.set_blocking(false,100);
+ //
+ // Request Analysis
+ //
+
+ DEBUG_PRINT_LINE("DEBUG MODE");
+ switch(tcpcon.receive(buffer, 1023)) {
+ case 0:
+ //DEBUG_PRINT_LINE("received buffer is empty.");
+ status_code = 400;
+ sprintf(reason_phrase,"No Request\0");
+ httpmethod[0] = '\0';
+ filepath[0] = '\0';
+ http_ver[0] = '\0';
+ break;
+ case -1:
+ DEBUG_PRINT_LINE("failed to read data from client.");
+ status_code = 500;
+ sprintf(reason_phrase,"Internal Server Error\0");
+ httpmethod[0] = '\0';
+ filepath[0] = '\0';
+ http_ver[0] = '\0';
+ break;
+ default:
+ DEBUG_PRINT_LINE("Received Data: %d",strlen(buffer));
+ DEBUG_PRINT_LINE("-->\r\n");
+ DEBUG_PRINT_LINE("%.*s[End of Request]",strlen(buffer),buffer);
+ // get HTTP method, File path, HTTP version
+ sprintf(httpmethod,strtok(buffer," "));
+ filepath[0] = '\0';
+ sprintf(http_ver,"HTTP/1.1\0");
+ DEBUG_PRINT_LINE("httpmethod: %s", httpmethod);
+ DEBUG_PRINT_LINE("file path: %s", filepath);
+ DEBUG_PRINT_LINE("http ver : %s", http_ver);
+ break;
}
- // When conected
- while(tcpcon.is_connected()) {
- printf("(HTTP_SERVER) connected\r\n");
-
- char buffer[1024] = {0};
- char* httpmethod = NULL;
- char* filepath = NULL;
- char* http_ver = NULL;
- char* header_field_name = NULL;
- char* header_field_val = NULL;
-
- //
- // Request Analysis
- //
- DEBUG_PRINT_LINE("DEBUG MODE");
- switch(tcpcon.receive(buffer, 1023)) {
- case 0:
- DEBUG_PRINT_LINE("recieved buffer is empty.");
- msger.setStatusLine(400, "No Request");
- if(msger.setHeaderField("Connection", "Close"))DEBUG_PRINT_LINE("buffer over flow @ ResponseMessenger");
- httpmethod = NULL;
- filepath = NULL;
- http_ver = NULL;
- break;
- case -1:
- DEBUG_PRINT_LINE("failed to read data from client.");
- msger.setStatusLine(500, "Internal Server Error");
- if(msger.setHeaderField("Connection", "Close"))DEBUG_PRINT_LINE("buffer over flow @ ResponseMessenger");
- httpmethod = NULL;
- filepath = NULL;
- http_ver = NULL;
- break;
- default:
- DEBUG_PRINT_LINE("Recieved Data: %d",strlen(buffer));
- DEBUG_PRINT_LINE("-->\r\n");
- DEBUG_PRINT_LINE("%.*s[End of Request]",strlen(buffer),buffer);
- // get HTTP method, File path, HTTP version
- httpmethod = strtok(buffer," ");
- filepath = strtok(NULL, " ");
- http_ver = strtok(NULL, "\r\n");
- DEBUG_PRINT_LINE("httpmethod: %s", httpmethod);
- DEBUG_PRINT_LINE("file path: %s", filepath);
- DEBUG_PRINT_LINE("http ver : %s", http_ver);
- break;
- }
+
+ if (httpmethod[0] == '\0') {
+ buffer[MAX_BUFFER_SIZE - 1] = '\0';
+ sprintf(buffer,"%s %d %s\r\nConnection: Close\r\n\r\n\0", http_ver, status_code, reason_phrase);
+ DEBUG_PRINT_LINE("echo back done.");
+ break;
+ }
+
+ // Response
+ if (strcmp(httpmethod,"GET") == 0 ) //GET request - always index.html stoed in index_html
+ {
+ DEBUG_PRINT_LINE("GET request incomming.");
+
+ buffer[MAX_BUFFER_SIZE-1] = '\0';
+ status_code = 200;
+ sprintf(reason_phrase,"OK\0");
- //
- // Response
- //
- if (strcmp(httpmethod,"GET") == 0 ) {
- DEBUG_PRINT_LINE("GET request incomming.");
+ sprintf(buffer,"%s %d %s\r\nConnection: Close\r\nContent-Type: text/html\r\nKeep-Alive: timeout=15\r\n\r\n\0", http_ver, status_code, reason_phrase);
+ tcpcon.send_all(buffer,strlen(buffer));
+ tcpcon.send_all((char*)index_html,index_html_len);
+
+ break;
+ }
+ if (strcmp(httpmethod,"POST") == 0 ) //POST request - javascript request
+ {
+ DEBUG_PRINT_LINE("POST request incomming.");
+ status_code = 200;
+ sprintf(reason_phrase,"OK\0");
+
+ sprintf(buffer,"%s %d %s\r\nConnection: Close\r\n\r\n\0", http_ver, status_code, reason_phrase);
- // file calibration
- DEBUG_PRINT_LINE("file opening");
- fhandl.open(filepath,"rb");
- if(fhandl.arrival()) {
- msger.setStatusLine(200, "OK");
- if(msger.setHeaderField("Content-Length", fhandl.getFileSize())) DEBUG_PRINT_LINE("buffer over flow @ ResponseMessenger");
- if(msger.setHeaderField("Connection", "keep-alive")) DEBUG_PRINT_LINE("buffer over flow @ ResponseMessenger");
- } else {
- if(msger.setStatusLine(404, "NOT FOUND")) DEBUG_PRINT_LINE("buffer over flow @ ResponseMessenger");
- if(msger.setHeaderField("Connection", "Close")) DEBUG_PRINT_LINE("buffer over flow @ ResponseMessenger");
- DEBUG_PRINT_LINE("NOT FOUND");
- }
- if( !strcmp(fhandl.getSuffix(), "htm" ) ||
- !strcmp(fhandl.getSuffix(), "HTM" ) ||
- !strcmp(fhandl.getSuffix(), "html") ||
- !strcmp(fhandl.getSuffix(), "HTML")){
- if(msger.setHeaderField("Content-Type", "text/html")) DEBUG_PRINT_LINE("buffer over flow @ ResponseMessenger");
- } else if( !strcmp(fhandl.getSuffix(), "js" )){
- if(msger.setHeaderField("Content-Type", "text/javascript")) DEBUG_PRINT_LINE("buffer over flow @ ResponseMessenger");
- } else if ( !strcmp(fhandl.getSuffix(), "ico" )){
- if(msger.setHeaderField("Content-Type", "image/png")) DEBUG_PRINT_LINE("buffer over flow @ ResponseMessenger");
- } else if ( !strcmp(fhandl.getSuffix(), "png" ) ||
- !strcmp(fhandl.getSuffix(), "PNG" )){
- if(msger.setHeaderField("Content-Type", "image/png")) DEBUG_PRINT_LINE("buffer over flow @ ResponseMessenger");
- } else if ( !strcmp(fhandl.getSuffix(), "jpg" ) ||
- !strcmp(fhandl.getSuffix(), "JPG" )){
- if(msger.setHeaderField("Content-Type", "image/jpg")) DEBUG_PRINT_LINE("buffer over flow @ ResponseMessenger");
- } else {
- msger.setStatusLine(406, "not acceptable");
- }
+ for(idx_buffer=0;idx_buffer<=7;idx_buffer++)
+ {
+ sprintf(tmp_buffer,"%4.2f %3.2f %d %3.2f %s %d %s %d %s %d %s %d \0",CH[idx_buffer].voltage,CH[idx_buffer].current,CH[idx_buffer].control,CH[idx_buffer].limit,\
+ color[CH[idx_buffer].failure>0],CH[idx_buffer].failure,\
+ color[CH[idx_buffer].overload>ERROR_REP],CH[idx_buffer].overload>ERROR_REP,\
+ color[CH[idx_buffer].noload>ERROR_REP],CH[idx_buffer].noload>ERROR_REP,\
+ color[CH[idx_buffer].enable==0],CH[idx_buffer].enable);
+ strcat(buffer,tmp_buffer);
- // Connection timeout field
- if(msger.setHeaderField("Keep-Alive", "timeouit=15")) DEBUG_PRINT_LINE("buffer over flow @ ResponseMessenger");
-
- // send response
- msger.sendHTTPResponse(tcpcon, fhandl);
+ }
+ tcpcon.send_all(buffer,strlen(buffer));
+ break;
+
- //file close
- if( fhandl.close()== 0)
- DEBUG_PRINT_LINE("file has closed");
- else if(EOF)
- DEBUG_PRINT_LINE("failed to close the file");
-
- msger.resetHeader();
- DEBUG_PRINT_LINE("echo back done.");
- }
- if (httpmethod == NULL) {
- msger.sendHTTPResponse(tcpcon);
- msger.resetHeader();
- DEBUG_PRINT_LINE("echo back done.");
- }
- printf("(HTTP_SERVER) Response to Request has done\r\n");
- //
- //
- //
- }
- printf("(HTTP_SERVER) close connection.\r\ntcp server is listening...\r\n");
- tcpcon.close();
- led2 = false;
+ }
}
- tcpsvr.close();
- listening_flag = false;
- led1 = false;
+ tcpcon.close(); //always close the connection
return 0;
}
\ No newline at end of file
--- a/HTTP_SERVER.h Fri Mar 16 21:55:50 2018 +0000
+++ b/HTTP_SERVER.h Thu May 10 20:24:03 2018 +0000
@@ -1,12 +1,13 @@
//HTTP_SERVER.h
#ifndef HTTP_SERVER_H
#define HTTP_SERVER_H
-#include "mbed.h"
+
#include "EthernetInterface.h"
-#include "ResponseMessenger.h"
-#include "FileHandler.h"
+#include "definitions.h"
#include "string.h"
-#include <stdlib.h>
+
+#define MAX_BUFFER_SIZE 1024
+
using namespace std;
enum PortNum {
@@ -35,19 +36,11 @@
* @retval TRUE at error end.
* @retval FALSE at normal end.
*/
- bool run();
+ bool run(channel *CH);
-private:
// Handlers
- EthernetInterface eth; // Eternet
TCPSocketServer tcpsvr; // TCP server
TCPSocketConnection tcpcon; // TCP server connection clerk
- ResponseMessenger msger; // Messenger for a client
- FileHandler fhandl; //
- // Param
- bool keep_alive;
- bool listening_flag;
- char req_buf[1024];
};
#endif
\ No newline at end of file
--- a/handlers/FileHandler.h Fri Mar 16 21:55:50 2018 +0000
+++ /dev/null Thu Jan 01 00:00:00 1970 +0000
@@ -1,32 +0,0 @@
-/*FileHandler.h*/
-#ifndef FILE_HANDLER_H
-#define FILE_HANDLER_H
-#include "mbed.h"
-#include "string.h"
-#include <stdlib.h>
-
-using namespace std;
-class FileHandler
-{
-public:
- FileHandler();
- ~FileHandler();
- FILE* open(const char*, const char*);
- int close();
- virtual int getc();
- bool arrival();
- bool atEOF();
- bool hasError();
- char *getFullpath();
- char *getFilename();
- char *getSuffix();
- int getFileSize();
-private:
- FILE *fp;
- char *fullpath;
- char *filename;
- char *suffix;
- char content_buffer[1024];
- int file_size;
-};
-#endif
\ No newline at end of file
--- a/handlers/Filehandler.cpp Fri Mar 16 21:55:50 2018 +0000
+++ /dev/null Thu Jan 01 00:00:00 1970 +0000
@@ -1,137 +0,0 @@
-#include "FileHandler.h"
-#ifndef DEBUG
-//#define DEBUG
-#endif
-LocalFileSystem local("local");
-
-FileHandler::FileHandler()
-{
- fullpath = NULL;
- filename = NULL;
- suffix = NULL;
- fp = NULL;
- file_size = 0;
-}
-FileHandler::~FileHandler()
-{
- if (fullpath != NULL) free(fullpath);
- if (fp != NULL) fclose(fp);
-}
-
-FILE* FileHandler::open
-( const char* arg_filepath,
- const char* arg_mode
-)
-{
- FILE *tmp;
-
- //////printf("\r\n"
- // "fp: %d@FileHandler::open\r\n", fp);
- if (fullpath != NULL) free(fullpath);
- fullpath = (char*)malloc(sizeof(char) * (strlen("/local/") + strlen(arg_filepath) + strlen("index.htm") + 1));
- //////printf("fp: %d@FileHandler::open\r\n", fp);
-
- // Path formatting
- if (arg_filepath[0] == '/') {
- sprintf(fullpath, "/local/%s", arg_filepath + 1);
- } else {
- sprintf(fullpath, "/local/%s", arg_filepath);
- }
- // if the argument has no file name but directory, defalt settiing.
- if (fullpath[strlen(fullpath) - 1] == '/')
- strcat(fullpath, "index.htm");
- // store the file name part to a pointer
- filename = strrchr(fullpath, '/');
- if(filename != NULL) filename++; // remove '/' and just get only the file name.
- // store the suffix part to a pointer
- suffix = strchr(filename, '.');
- if(suffix != NULL) suffix++; // remove '.' and just get only the suffix.
-#ifdef DEBUG
- //////printf("full path: %s\r\nfilename: %s\r\nsuffix: %s\r\n", getFullpath(), getFilename(), getSuffix());
-#endif
- fp = fopen(fullpath, arg_mode);
-#ifdef DEBUG
- //////////printf("file opened@FileHandler::open\r\n");
-#endif
- // mesure file size
- file_size = 0;
- tmp = fp;
- if(tmp != NULL ) {
- ////printf("\r\nfile content\r\n");
- int ctmp;
- while(1) {
- ctmp = fgetc(tmp);
- if(ctmp != EOF) {
- //////printf("%c", ctmp);
- file_size++;
- } else {
- //////printf("[EOF]\r\n");
- break;
- }
- }
- ////printf("file size: %d\r\n", file_size);
- if(fseek(tmp, 0L, SEEK_SET) != 0) {
- //////printf("fseek failed\r\n");
- }
- } else {
- file_size = 0;
- }
-
- return fp;
-}
-int FileHandler::close()
-{
- int tmp;
-
- if(fp != NULL) {
- tmp = fclose(fp);
- fp = NULL;
- return tmp;
- } else {
- return 1;
- }
-}
-
-int FileHandler::getc()
-{
- int tmp = fgetc(fp);
-#ifdef DEBUG
- if(0x20 < tmp && tmp < 0x7e)
- printf("%c", tmp);
- else if (tmp == '\r')
- printf("\r");
- else if (tmp == '\n')
- printf("\n");
- else
- printf("@");
-#endif
- return tmp;
-}
-bool FileHandler::arrival()
-{
- return (bool)fp;
-}
-bool FileHandler::atEOF()
-{
- return (bool)feof(fp);
-}
-bool FileHandler::hasError()
-{
- return (bool)ferror(fp);
-}
-char *FileHandler::getFullpath()
-{
- return fullpath;
-}
-char *FileHandler::getFilename()
-{
- return filename;
-}
-char *FileHandler::getSuffix()
-{
- return suffix;
-}
-int FileHandler::getFileSize()
-{
- return file_size;
-}
\ No newline at end of file
--- a/handlers/ResponseMessenger.cpp Fri Mar 16 21:55:50 2018 +0000
+++ /dev/null Thu Jan 01 00:00:00 1970 +0000
@@ -1,204 +0,0 @@
-#include "ResponseMessenger.h"
-
-const char ResponseMessenger::http_ver[9] = "HTTP/1.1";
-ResponseMessenger::ResponseMessenger()
-{
- // Status-Line
- status_code = 0;
- reason_phrase[0] = '\0';
- header_field_buffer[0]='\0';
- // Response Header
-}
-ResponseMessenger::~ResponseMessenger()
-{
-}
-int ResponseMessenger::resetHeader()
-{
- // Status-Line
- status_code = 0;
- reason_phrase[0] = '\0';
- // Response Header
- header_field_buffer[0]='\0';
- return 0;
-}
-int ResponseMessenger::setStatusLine(
- int arg_status_code,
- const char* arg_reason_phrase
-)
-{
- status_code = arg_status_code;
- strcpy(reason_phrase, arg_reason_phrase);
-
- // To be safe on the sage side
- reason_phrase[REASON_PHRASE_SIZE - 1] = '\0';
- // Send 0 if arg str size is too big, else -1.
- if (strlen(arg_reason_phrase) < REASON_PHRASE_SIZE)
- return 0;
- else
- return -1;
-}
-
-int ResponseMessenger::setHeaderField(
- const char* arg_field_name, const char* arg_field_val)
-{
- const int nField = 7;
- char registered_field_name[nField][32]= {
- "Connection",
- "Location",
- "Keep-Alive",
- "Content-Type",
- "Upgrade",
- "Sec-WebSocket-Accept",
- "Access-Control-Allow-Origin"
- };
- bool flag = false;
- char header_field_line_buffer[128];
- int buffer_size = strlen(header_field_buffer);
-
- for (int i = 0; i < nField; i++) {
- if(strcmp(arg_field_name, registered_field_name[i]) == 0)
- flag = true;
- }
- if(flag) {
- sprintf(header_field_line_buffer, "%s: %s\r\n", arg_field_name, arg_field_val);
- strcat(header_field_buffer, header_field_line_buffer);
- //printf("(RM) header field: \r\n%s\r\n", header_field_buffer);
- }
- // To be safe on the sage side
- header_field_buffer[HEADER_FIELDS_SIZE - 1] = '\0';
- // Send 0 if arg str size is too big, else -1.
- if (buffer_size + strlen(arg_field_name) + strlen(arg_field_val) < HEADER_FIELDS_SIZE + 1)
- return 0;
- else
- return -1;
-}
-
-int ResponseMessenger::setHeaderField(
- const char* arg_field_name, int arg_field_val)
-{
- const int nField = 1;
- char registered_field_name[nField][32]= {
- "Content-Length"
- };
- bool flag = false;
- char header_field_line_buffer[128];
- int buffer_size = strlen(header_field_buffer);
-
- for (int i = 0; i < nField; i++) {
- if(strcmp(arg_field_name, registered_field_name[i]) == 0)
- flag = true;
- }
- if(flag) {
- sprintf(header_field_line_buffer, "%s: %d\r\n", arg_field_name, arg_field_val);
- strcat(header_field_buffer, header_field_line_buffer);
- //printf("(RM) header field: \r\n%s\r\n", header_field_buffer);
- }
- // To be safe on the sage side
- header_field_buffer[HEADER_FIELDS_SIZE - 1] = '\0';
- // Send 0 if arg str size is too big, else -1.
- if (buffer_size + strlen(arg_field_name) + 10 < HEADER_FIELDS_SIZE + 1)
- return 0;
- else
- return -1;
-}
-
-int ResponseMessenger::rmHeaderField(
- const char* arg_field_name)
-{
- char* removedLineHead;
- char* removedLineEnd;
- int buffer_size;
-
- // Look for the head of the line to want to remove
- removedLineHead = strstr(header_field_buffer, arg_field_name);
- if(removedLineHead == NULL) return -1;
- // Look for the first "\r\n" which is the end of the line
- removedLineEnd = strstr(removedLineHead, "\r\n");
- removedLineEnd += 3; //pointing next line head or '\0' if the line of the last one.
- buffer_size = strlen(removedLineEnd);
-
- for(int i = 0; i < buffer_size + 1; i++)
- removedLineHead[i] = removedLineEnd[i];
-
- return 0;
-}
-
-int ResponseMessenger::getStatusCode()
-{
- return status_code;
-}
-
-char ResponseMessenger::sendHTTPResponse(
- TCPSocketConnection &arg_connection)
-{
- int err_log = 0;
- int err_code = 0;
- enum {
- MAX_BUFFER_SIZE = 1024
- };
- char buffer[MAX_BUFFER_SIZE] = "\0";
-
- //
- // Header
- //
- printf("(RM) [send]Header\r\n");
- // Status Line
- sprintf(buffer, "%s %d %s\r\n", http_ver, status_code, reason_phrase);
- buffer[MAX_BUFFER_SIZE - 1] = '\0';
- err_log = arg_connection.send_all(buffer, strlen(buffer));
- if(err_log < 0) err_code = ((err_code << 1) | 1);
- // Response Header
- err_log = arg_connection.send_all(header_field_buffer, strlen(header_field_buffer));
- if(err_log < 0) err_code = ((err_code << 1) | 1);
- // Blank line
- err_log = arg_connection.send_all("\r\n", strlen("\r\n"));
- if(err_log < 0) err_code = ((err_code << 1) | 1);
- printf("(RM) [Header has sent]\r\n");
- //return error code
- return err_code << 2;
-
-}
-
-char ResponseMessenger::sendHTTPResponse(
- TCPSocketConnection &arg_connection,
- FileHandler &arg_file)
-{
- int err_log = 0;
- int err_code = 0;
- enum {
- MAX_BUFFER_SIZE = 1024
- };
- signed char buffer[MAX_BUFFER_SIZE];
-
- //
- // Header
- //
- err_code = sendHTTPResponse(arg_connection);
- //
- // Body
- //
- if (arg_file.arrival() && status_code == 200) {
- printf("(RM) [send]Body\r\n");
- do {
- int i = 0;
- do {
- buffer[i++] = arg_file.getc();//return a byte from file ponter, or -1 if EOF or ERROR
- } while ((i < MAX_BUFFER_SIZE - 1) && (buffer[i - 1] != EOF));
- if(buffer[i - 1] == EOF)buffer[i - 1] = '\0';
- buffer[i] = '\0';
- if (!arg_file.hasError()) {
- err_log = arg_connection.send_all((char*)buffer, i);
- //printf("(RM) buffer log: %s", buffer);
- }
- if (arg_file.hasError()) printf("(RM)---[ERR]---\r\n");
- if (arg_file.atEOF()) printf("(RM)---[EOF]---\r\n");
- } while (!arg_file.atEOF() && !arg_file.hasError());
- printf("(RM) [Body has sent]\r\n");
-
- if (err_log < 0) err_code = ((err_code) | 2);
- if (!arg_file.hasError())err_code = ((err_code) | 1);
- } else {
- printf("(RM) [No Body]\r\n");
- }
- return (char)err_code;
-}
\ No newline at end of file
--- a/handlers/ResponseMessenger.h Fri Mar 16 21:55:50 2018 +0000
+++ /dev/null Thu Jan 01 00:00:00 1970 +0000
@@ -1,51 +0,0 @@
-/* ResponseMessenger.h */
-#ifndef RESPONSE_MESSENGER_H
-#define RESPONSE_MESSENGER_H
-#include "mbed.h"
-#include "string.h"
-#include "EthernetInterface.h"
-#include "FileHandler.h"
-#include <stdlib.h>
-using namespace std;
-
-class ResponseMessenger
-{
- enum {
- REASON_PHRASE_SIZE = 32,
- HEADER_FIELDS_SIZE = 2048
- };
-public:
- ResponseMessenger();
- ~ResponseMessenger();
- int resetHeader();
- int setStatusLine(int,const char*);
- int setHeaderField(const char*, const char*);
- int setHeaderField(const char*, int);
- int rmHeaderField(const char*);
- int getStatusCode();
- /**
- * Function to send response messages.
- * just header only
- * @return char
- * @retval error code
- */
- char sendHTTPResponse(TCPSocketConnection&);
- /**
- * Function to send response messages.
- * @return char
- * @retval error code
- */
- char sendHTTPResponse(TCPSocketConnection&, FileHandler&);
-private:
- // Status-Line
- static const char http_ver[9];
- int status_code;
- char reason_phrase[REASON_PHRASE_SIZE];
- // Header Field buffer
- // - General Header
- // - Response Header
- // - Entity Header
- char header_field_buffer[HEADER_FIELDS_SIZE];
-};
-
-#endif
\ No newline at end of file