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 httpServer by
Handler/FsHandler.cpp@2:859187375533, 2015-08-19 (annotated)
- Committer:
- M_J
- Date:
- Wed Aug 19 16:26:26 2015 +0000
- Revision:
- 2:859187375533
- Parent:
- 0:e59cc54df17c
- Child:
- 3:b2d8ac343302
led delete
Who changed what in which revision?
| User | Revision | Line number | New contents of line |
|---|---|---|---|
| hjjeon | 0:e59cc54df17c | 1 | /* FsHandler.cpp */ |
| hjjeon | 0:e59cc54df17c | 2 | #include "mbed.h" |
| hjjeon | 0:e59cc54df17c | 3 | #include "FsHandler.h" |
| hjjeon | 0:e59cc54df17c | 4 | //#define DEBUG |
| hjjeon | 0:e59cc54df17c | 5 | #include "hl_debug.h" |
| hjjeon | 0:e59cc54df17c | 6 | |
| M_J | 2:859187375533 | 7 | int lumi_val = 1; |
| M_J | 2:859187375533 | 8 | int cel_val = 1; |
| M_J | 2:859187375533 | 9 | int touch_val = 1; |
| hjjeon | 0:e59cc54df17c | 10 | |
| hjjeon | 0:e59cc54df17c | 11 | DigitalIn din(PC_14); |
| hjjeon | 0:e59cc54df17c | 12 | |
| hjjeon | 0:e59cc54df17c | 13 | |
| hjjeon | 0:e59cc54df17c | 14 | static int matchstrings(const char* one, const char* two) |
| hjjeon | 0:e59cc54df17c | 15 | { |
| hjjeon | 0:e59cc54df17c | 16 | int m = 0; |
| hjjeon | 0:e59cc54df17c | 17 | |
| hjjeon | 0:e59cc54df17c | 18 | for (m = 0; m < min(strlen(one), strlen(two)) ; m++) { |
| hjjeon | 0:e59cc54df17c | 19 | if (one[m] != two[m]) |
| hjjeon | 0:e59cc54df17c | 20 | return m; |
| hjjeon | 0:e59cc54df17c | 21 | } |
| hjjeon | 0:e59cc54df17c | 22 | return m; |
| hjjeon | 0:e59cc54df17c | 23 | } |
| hjjeon | 0:e59cc54df17c | 24 | |
| hjjeon | 0:e59cc54df17c | 25 | std::map<const char*, const char*> HTTPFsRequestHandler::m_fsMap; |
| hjjeon | 0:e59cc54df17c | 26 | |
| hjjeon | 0:e59cc54df17c | 27 | HTTPFsRequestHandler::HTTPFsRequestHandler(const char* rootPath, const char* localPath, HTTPConnection::HTTPMessage& Msg, TCPSocketConnection& Tcp) |
| hjjeon | 0:e59cc54df17c | 28 | : HTTPRequestHandler(Msg, Tcp) |
| hjjeon | 0:e59cc54df17c | 29 | { |
| hjjeon | 0:e59cc54df17c | 30 | m_rootPath = rootPath; |
| hjjeon | 0:e59cc54df17c | 31 | m_localPath = localPath; |
| hjjeon | 0:e59cc54df17c | 32 | |
| hjjeon | 0:e59cc54df17c | 33 | string myPath = m_rootPath + m_localPath; |
| hjjeon | 0:e59cc54df17c | 34 | |
| hjjeon | 0:e59cc54df17c | 35 | // Now replace the virtual root path with a mounted device path |
| hjjeon | 0:e59cc54df17c | 36 | std::map<const char*, const char*>::iterator it; |
| hjjeon | 0:e59cc54df17c | 37 | const char *bestMatch = NULL; |
| hjjeon | 0:e59cc54df17c | 38 | const char *bestMatchExchange = NULL; |
| hjjeon | 0:e59cc54df17c | 39 | int match_ind = -1; |
| hjjeon | 0:e59cc54df17c | 40 | for (it = m_fsMap.begin() ; it != m_fsMap.end() ; it++) { |
| hjjeon | 0:e59cc54df17c | 41 | // find best match (if the given logical path is containted in the root |
| hjjeon | 0:e59cc54df17c | 42 | int s = matchstrings(myPath.c_str(), it->second); |
| hjjeon | 0:e59cc54df17c | 43 | INFO("Matching Root %s with handler %s results in %d identical characters\n", myPath.c_str(), it->second, s); |
| hjjeon | 0:e59cc54df17c | 44 | if ((s == strlen(it->second)) && (s > match_ind)) { |
| hjjeon | 0:e59cc54df17c | 45 | match_ind = s; |
| hjjeon | 0:e59cc54df17c | 46 | bestMatch = it->first; |
| hjjeon | 0:e59cc54df17c | 47 | bestMatchExchange = it->second; |
| hjjeon | 0:e59cc54df17c | 48 | } |
| hjjeon | 0:e59cc54df17c | 49 | } |
| hjjeon | 0:e59cc54df17c | 50 | |
| hjjeon | 0:e59cc54df17c | 51 | if (bestMatch != NULL) { |
| hjjeon | 0:e59cc54df17c | 52 | m_rootPath = bestMatch; |
| hjjeon | 0:e59cc54df17c | 53 | m_localPath = string(myPath).substr(strlen(bestMatchExchange)); |
| hjjeon | 0:e59cc54df17c | 54 | } |
| hjjeon | 0:e59cc54df17c | 55 | |
| hjjeon | 0:e59cc54df17c | 56 | handleRequest(); |
| hjjeon | 0:e59cc54df17c | 57 | } |
| hjjeon | 0:e59cc54df17c | 58 | |
| hjjeon | 0:e59cc54df17c | 59 | HTTPFsRequestHandler::~HTTPFsRequestHandler() |
| hjjeon | 0:e59cc54df17c | 60 | { |
| hjjeon | 0:e59cc54df17c | 61 | } |
| hjjeon | 0:e59cc54df17c | 62 | |
| hjjeon | 0:e59cc54df17c | 63 | int HTTPFsRequestHandler::handleGetRequest() |
| hjjeon | 0:e59cc54df17c | 64 | { |
| hjjeon | 0:e59cc54df17c | 65 | HTTPHeaders headers; |
| hjjeon | 0:e59cc54df17c | 66 | int retval = 0; //success |
| hjjeon | 0:e59cc54df17c | 67 | uint8_t pin_state; |
| hjjeon | 0:e59cc54df17c | 68 | |
| hjjeon | 0:e59cc54df17c | 69 | if( std::string::npos != msg.uri.find("get_dio14.cgi") ) |
| hjjeon | 0:e59cc54df17c | 70 | { |
| hjjeon | 0:e59cc54df17c | 71 | if(din) |
| hjjeon | 0:e59cc54df17c | 72 | pin_state = 1; |
| hjjeon | 0:e59cc54df17c | 73 | else |
| hjjeon | 0:e59cc54df17c | 74 | pin_state = 0; |
| hjjeon | 0:e59cc54df17c | 75 | |
| hjjeon | 0:e59cc54df17c | 76 | /* |
| hjjeon | 0:e59cc54df17c | 77 | *len = sprintf((char *)buf, "DioCallback({\"dio_p\":\"14\",\ |
| hjjeon | 0:e59cc54df17c | 78 | \"dio_s\":\"%d\"\ |
| hjjeon | 0:e59cc54df17c | 79 | });", |
| hjjeon | 0:e59cc54df17c | 80 | pin_state // Digital io status |
| hjjeon | 0:e59cc54df17c | 81 | ); |
| hjjeon | 0:e59cc54df17c | 82 | |
| hjjeon | 0:e59cc54df17c | 83 | |
| hjjeon | 0:e59cc54df17c | 84 | Tcp. |
| hjjeon | 0:e59cc54df17c | 85 | */ |
| hjjeon | 0:e59cc54df17c | 86 | } |
| hjjeon | 0:e59cc54df17c | 87 | else //read html pages |
| hjjeon | 0:e59cc54df17c | 88 | { |
| hjjeon | 0:e59cc54df17c | 89 | if (m_localPath.length() > 4) |
| hjjeon | 0:e59cc54df17c | 90 | getStandardHeaders(headers, m_localPath.substr(m_localPath.length()-4).c_str()); |
| hjjeon | 0:e59cc54df17c | 91 | else |
| hjjeon | 0:e59cc54df17c | 92 | getStandardHeaders(headers); |
| hjjeon | 0:e59cc54df17c | 93 | |
| hjjeon | 0:e59cc54df17c | 94 | INFO("Handling Get Request (root = %s, local = %s).", m_rootPath.c_str(), m_localPath.c_str()); |
| hjjeon | 0:e59cc54df17c | 95 | |
| hjjeon | 0:e59cc54df17c | 96 | std::string reqPath; |
| hjjeon | 0:e59cc54df17c | 97 | |
| hjjeon | 0:e59cc54df17c | 98 | // Check if we received a directory with the local bath |
| hjjeon | 0:e59cc54df17c | 99 | if ((m_localPath.length() == 0) || (m_localPath.substr( m_localPath.length()-1, 1) == "/")) { |
| hjjeon | 0:e59cc54df17c | 100 | // yes, we shall append the default page name |
| hjjeon | 0:e59cc54df17c | 101 | m_localPath += "index.html"; |
| hjjeon | 0:e59cc54df17c | 102 | } |
| hjjeon | 0:e59cc54df17c | 103 | |
| hjjeon | 0:e59cc54df17c | 104 | reqPath = m_rootPath + m_localPath; |
| hjjeon | 0:e59cc54df17c | 105 | |
| hjjeon | 0:e59cc54df17c | 106 | INFO("Mapping \"%s\" to \"%s\"", msg.uri.c_str(), reqPath.c_str()); |
| hjjeon | 0:e59cc54df17c | 107 | |
| hjjeon | 0:e59cc54df17c | 108 | FILE *fp = fopen(reqPath.c_str(), "r"); |
| hjjeon | 0:e59cc54df17c | 109 | if (fp != NULL) { |
| hjjeon | 0:e59cc54df17c | 110 | char * pBuffer = NULL; |
| hjjeon | 0:e59cc54df17c | 111 | int sz = 8192; |
| hjjeon | 0:e59cc54df17c | 112 | while( pBuffer == NULL) { |
| hjjeon | 0:e59cc54df17c | 113 | sz /= 2; |
| hjjeon | 0:e59cc54df17c | 114 | pBuffer = (char*)malloc(sz); |
| hjjeon | 0:e59cc54df17c | 115 | if (sz < 128) |
| hjjeon | 0:e59cc54df17c | 116 | error ("OutOfMemory"); |
| hjjeon | 0:e59cc54df17c | 117 | } |
| hjjeon | 0:e59cc54df17c | 118 | |
| hjjeon | 0:e59cc54df17c | 119 | // File was found and can be returned |
| hjjeon | 0:e59cc54df17c | 120 | |
| hjjeon | 0:e59cc54df17c | 121 | // first determine the size |
| hjjeon | 0:e59cc54df17c | 122 | fseek(fp, 0, SEEK_END); |
| hjjeon | 0:e59cc54df17c | 123 | long size = ftell(fp); |
| hjjeon | 0:e59cc54df17c | 124 | fseek(fp, 0, SEEK_SET); |
| hjjeon | 0:e59cc54df17c | 125 | |
| hjjeon | 0:e59cc54df17c | 126 | startResponse(200, size); |
| hjjeon | 0:e59cc54df17c | 127 | while(!feof(fp) && !ferror(fp)) { |
| hjjeon | 0:e59cc54df17c | 128 | int cnt = fread(pBuffer, 1, sz , fp); |
| hjjeon | 0:e59cc54df17c | 129 | if (cnt < 0) |
| hjjeon | 0:e59cc54df17c | 130 | cnt = 0; |
| hjjeon | 0:e59cc54df17c | 131 | processResponse(cnt, pBuffer); |
| hjjeon | 0:e59cc54df17c | 132 | } |
| hjjeon | 0:e59cc54df17c | 133 | delete pBuffer; |
| hjjeon | 0:e59cc54df17c | 134 | endResponse(); |
| hjjeon | 0:e59cc54df17c | 135 | fclose(fp); |
| hjjeon | 0:e59cc54df17c | 136 | } |
| hjjeon | 0:e59cc54df17c | 137 | else { |
| hjjeon | 0:e59cc54df17c | 138 | retval = 404; |
| hjjeon | 0:e59cc54df17c | 139 | ERR("Requested file was not found !"); |
| hjjeon | 0:e59cc54df17c | 140 | } |
| hjjeon | 0:e59cc54df17c | 141 | } |
| hjjeon | 0:e59cc54df17c | 142 | |
| hjjeon | 0:e59cc54df17c | 143 | return retval; |
| hjjeon | 0:e59cc54df17c | 144 | } |
| hjjeon | 0:e59cc54df17c | 145 | |
| hjjeon | 0:e59cc54df17c | 146 | int HTTPFsRequestHandler::handlePostRequest() |
| hjjeon | 0:e59cc54df17c | 147 | { |
| hjjeon | 0:e59cc54df17c | 148 | |
| hjjeon | 0:e59cc54df17c | 149 | int pin = 0; |
| hjjeon | 0:e59cc54df17c | 150 | |
| hjjeon | 0:e59cc54df17c | 151 | if( std::string::npos != msg.uri.find("set_dio.cgi") ) |
| hjjeon | 0:e59cc54df17c | 152 | { |
| hjjeon | 0:e59cc54df17c | 153 | pin = get_http_param_value("pin"); |
| hjjeon | 0:e59cc54df17c | 154 | if(pin == 8) |
| hjjeon | 0:e59cc54df17c | 155 | { |
| M_J | 2:859187375533 | 156 | lumi_val = get_http_param_value("val"); |
| hjjeon | 0:e59cc54df17c | 157 | } |
| hjjeon | 0:e59cc54df17c | 158 | else if(pin == 9) |
| hjjeon | 0:e59cc54df17c | 159 | { |
| M_J | 2:859187375533 | 160 | cel_val = get_http_param_value("val"); |
| hjjeon | 0:e59cc54df17c | 161 | } |
| hjjeon | 0:e59cc54df17c | 162 | else if(pin == 5) |
| hjjeon | 0:e59cc54df17c | 163 | { |
| M_J | 2:859187375533 | 164 | touch_val = get_http_param_value("val"); |
| hjjeon | 0:e59cc54df17c | 165 | } |
| hjjeon | 0:e59cc54df17c | 166 | else |
| hjjeon | 0:e59cc54df17c | 167 | { |
| hjjeon | 0:e59cc54df17c | 168 | WARN("Wrong pin number"); |
| hjjeon | 0:e59cc54df17c | 169 | } |
| hjjeon | 0:e59cc54df17c | 170 | return 0; |
| hjjeon | 0:e59cc54df17c | 171 | } |
| hjjeon | 0:e59cc54df17c | 172 | else |
| hjjeon | 0:e59cc54df17c | 173 | { |
| hjjeon | 0:e59cc54df17c | 174 | return 404; |
| hjjeon | 0:e59cc54df17c | 175 | } |
| hjjeon | 0:e59cc54df17c | 176 | } |
| hjjeon | 0:e59cc54df17c | 177 | |
| hjjeon | 0:e59cc54df17c | 178 | int HTTPFsRequestHandler::handlePutRequest() |
| hjjeon | 0:e59cc54df17c | 179 | { |
| hjjeon | 0:e59cc54df17c | 180 | return 404; |
| hjjeon | 0:e59cc54df17c | 181 | } |
| hjjeon | 0:e59cc54df17c | 182 | |
| hjjeon | 0:e59cc54df17c | 183 | uint32_t HTTPFsRequestHandler::get_http_param_value(char* param_name) |
| hjjeon | 0:e59cc54df17c | 184 | { |
| hjjeon | 0:e59cc54df17c | 185 | uint8_t * name = 0; |
| hjjeon | 0:e59cc54df17c | 186 | uint8_t * pos2; |
| hjjeon | 0:e59cc54df17c | 187 | uint16_t len = 0; |
| hjjeon | 0:e59cc54df17c | 188 | char value[10]; |
| hjjeon | 0:e59cc54df17c | 189 | uint32_t ret = 0; |
| hjjeon | 0:e59cc54df17c | 190 | |
| hjjeon | 0:e59cc54df17c | 191 | //msg.attri |
| hjjeon | 0:e59cc54df17c | 192 | if((name = (uint8_t *)strstr(msg.attri, param_name))) |
| hjjeon | 0:e59cc54df17c | 193 | { |
| hjjeon | 0:e59cc54df17c | 194 | name += strlen(param_name) + 1; |
| hjjeon | 0:e59cc54df17c | 195 | pos2 = (uint8_t*)strstr((char*)name, "&"); |
| hjjeon | 0:e59cc54df17c | 196 | if(!pos2) |
| hjjeon | 0:e59cc54df17c | 197 | { |
| hjjeon | 0:e59cc54df17c | 198 | pos2 = name + strlen((char*)name); |
| hjjeon | 0:e59cc54df17c | 199 | } |
| hjjeon | 0:e59cc54df17c | 200 | len = pos2 - name; |
| hjjeon | 0:e59cc54df17c | 201 | |
| hjjeon | 0:e59cc54df17c | 202 | if(len) |
| hjjeon | 0:e59cc54df17c | 203 | { |
| hjjeon | 0:e59cc54df17c | 204 | strncpy(value, (char*)name, len); |
| hjjeon | 0:e59cc54df17c | 205 | ret = atoi(value); |
| hjjeon | 0:e59cc54df17c | 206 | } |
| hjjeon | 0:e59cc54df17c | 207 | } |
| hjjeon | 0:e59cc54df17c | 208 | return ret; |
| hjjeon | 0:e59cc54df17c | 209 | } |
| hjjeon | 0:e59cc54df17c | 210 |
