Simple HTTP Server with support for SD Card file serving and CGI commands

Dependencies:   EthernetInterface TCPEchoServer SDFileSystem mbed-rtos mbed

Fork of TCPEchoServer by mbed official

Committer:
gsteiert
Date:
Sat Apr 06 06:09:22 2013 +0000
Revision:
6:6aa0b2a3c4e4
Parent:
3:36fd3cfad85a
This is a functional web server with SD card file serving and cgi I2C commands

Who changed what in which revision?

UserRevisionLine numberNew contents of line
mbed_official 0:38cbb854d85f 1 #include "mbed.h"
emilmont 1:5cebe0e38cd2 2 #include "EthernetInterface.h"
gsteiert 6:6aa0b2a3c4e4 3 #include "SDFileSystem.h"
gsteiert 6:6aa0b2a3c4e4 4 #include <stdio.h>
gsteiert 6:6aa0b2a3c4e4 5 #include <string.h>
emilmont 1:5cebe0e38cd2 6
gsteiert 6:6aa0b2a3c4e4 7 #define HTTPD_SERVER_PORT 80
gsteiert 6:6aa0b2a3c4e4 8 #define HTTPD_MAX_REQ_LENGTH 1023
gsteiert 6:6aa0b2a3c4e4 9 #define HTTPD_MAX_HDR_LENGTH 255
gsteiert 6:6aa0b2a3c4e4 10 #define HTTPD_MAX_FNAME_LENGTH 127
gsteiert 6:6aa0b2a3c4e4 11 #define I2C_BUFFER_SIZE 63
gsteiert 6:6aa0b2a3c4e4 12
gsteiert 6:6aa0b2a3c4e4 13 SDFileSystem sd(p5, p6, p7, p8, "sd"); //
gsteiert 6:6aa0b2a3c4e4 14 I2C i2c(p28, p27);
gsteiert 6:6aa0b2a3c4e4 15 EthernetInterface eth;
gsteiert 6:6aa0b2a3c4e4 16 TCPSocketServer server;
gsteiert 6:6aa0b2a3c4e4 17 TCPSocketConnection client;
gsteiert 6:6aa0b2a3c4e4 18
gsteiert 6:6aa0b2a3c4e4 19 char buffer[HTTPD_MAX_REQ_LENGTH+1];
gsteiert 6:6aa0b2a3c4e4 20 char httpHeader[HTTPD_MAX_HDR_LENGTH+1];
gsteiert 6:6aa0b2a3c4e4 21 char filename[HTTPD_MAX_FNAME_LENGTH+1];
gsteiert 6:6aa0b2a3c4e4 22 char data[I2C_BUFFER_SIZE];
gsteiert 6:6aa0b2a3c4e4 23 char *uristr;
gsteiert 6:6aa0b2a3c4e4 24 char *eou;
gsteiert 6:6aa0b2a3c4e4 25 char *qrystr;
gsteiert 6:6aa0b2a3c4e4 26
gsteiert 6:6aa0b2a3c4e4 27 FILE *fp;
gsteiert 6:6aa0b2a3c4e4 28 int rdCnt;
gsteiert 6:6aa0b2a3c4e4 29
gsteiert 6:6aa0b2a3c4e4 30 void cmd_i2c_write(char* qry)
gsteiert 6:6aa0b2a3c4e4 31 {
gsteiert 6:6aa0b2a3c4e4 32 int addr = 0;
gsteiert 6:6aa0b2a3c4e4 33 int dlen = 0;
gsteiert 6:6aa0b2a3c4e4 34 int dtmp = 0;
gsteiert 6:6aa0b2a3c4e4 35 if (sscanf(qry, "%2x", &addr) == 1) {
gsteiert 6:6aa0b2a3c4e4 36 qry += 2;
gsteiert 6:6aa0b2a3c4e4 37 printf("Addr: %x Data: ", addr);
gsteiert 6:6aa0b2a3c4e4 38 while (sscanf(qry, "&%2x", &dtmp) == 1) {
gsteiert 6:6aa0b2a3c4e4 39 data[dlen] = dtmp;
gsteiert 6:6aa0b2a3c4e4 40 qry +=3;
gsteiert 6:6aa0b2a3c4e4 41 dlen +=1;
gsteiert 6:6aa0b2a3c4e4 42 printf("%x ", dtmp);
gsteiert 6:6aa0b2a3c4e4 43 }
gsteiert 6:6aa0b2a3c4e4 44 printf("Bytes: %d\r\n ", dlen);
gsteiert 6:6aa0b2a3c4e4 45 } else {
gsteiert 6:6aa0b2a3c4e4 46 dlen = -1;
gsteiert 6:6aa0b2a3c4e4 47 printf("Invalid address: %s\r\n", qry);
gsteiert 6:6aa0b2a3c4e4 48 }
gsteiert 6:6aa0b2a3c4e4 49 if (dlen > 0 ) {
gsteiert 6:6aa0b2a3c4e4 50 printf("Write %d bytes to %x\r\n", dlen, addr);
gsteiert 6:6aa0b2a3c4e4 51 i2c.write(addr, data, dlen);
gsteiert 6:6aa0b2a3c4e4 52 }
gsteiert 6:6aa0b2a3c4e4 53 sprintf(httpHeader,"HTTP/1.1 200 OK\r\nContent-Type: text/html\r\nConnection: Close\r\n\r\n%d", dlen);
gsteiert 6:6aa0b2a3c4e4 54 client.send(httpHeader,strlen(httpHeader));
gsteiert 6:6aa0b2a3c4e4 55 }
gsteiert 6:6aa0b2a3c4e4 56
gsteiert 6:6aa0b2a3c4e4 57 void cmd_i2c_read(char* qry)
gsteiert 6:6aa0b2a3c4e4 58 {
gsteiert 6:6aa0b2a3c4e4 59 int addr = 0;
gsteiert 6:6aa0b2a3c4e4 60 int dlen = 0;
gsteiert 6:6aa0b2a3c4e4 61 if (sscanf(qry, "%2x", &addr) == 1) {
gsteiert 6:6aa0b2a3c4e4 62 qry += 2;
gsteiert 6:6aa0b2a3c4e4 63 printf("Read from addr %x ", addr);
gsteiert 6:6aa0b2a3c4e4 64 if (sscanf(qry, "&%2x", &dlen) == 1) {
gsteiert 6:6aa0b2a3c4e4 65 if (i2c.read(addr, data, dlen)!=0) {
gsteiert 6:6aa0b2a3c4e4 66 dlen = -1;
gsteiert 6:6aa0b2a3c4e4 67 printf("failed\r\n");
gsteiert 6:6aa0b2a3c4e4 68 } else {
gsteiert 6:6aa0b2a3c4e4 69 printf("%d bytes\r\n ", dlen);
gsteiert 6:6aa0b2a3c4e4 70 }
gsteiert 6:6aa0b2a3c4e4 71 } else {
gsteiert 6:6aa0b2a3c4e4 72 printf("\r\nInvalid data length: %s\r\n", qry);
gsteiert 6:6aa0b2a3c4e4 73 }
gsteiert 6:6aa0b2a3c4e4 74 } else {
gsteiert 6:6aa0b2a3c4e4 75 dlen = -1;
gsteiert 6:6aa0b2a3c4e4 76 printf("Invalid address: %s\r\n", qry);
gsteiert 6:6aa0b2a3c4e4 77 }
gsteiert 6:6aa0b2a3c4e4 78 sprintf(httpHeader,"HTTP/1.1 200 OK\r\nContent-Type: text/html\r\nConnection: Close\r\n\r\n%d", dlen);
gsteiert 6:6aa0b2a3c4e4 79 client.send(httpHeader,strlen(httpHeader));
gsteiert 6:6aa0b2a3c4e4 80 while (dlen > 0) {
gsteiert 6:6aa0b2a3c4e4 81 dlen -= 1;
gsteiert 6:6aa0b2a3c4e4 82 sprintf(httpHeader," %x", data[dlen]);
gsteiert 6:6aa0b2a3c4e4 83 client.send(httpHeader,strlen(httpHeader));
gsteiert 6:6aa0b2a3c4e4 84 }
gsteiert 6:6aa0b2a3c4e4 85 }
emilmont 3:36fd3cfad85a 86
gsteiert 6:6aa0b2a3c4e4 87 void cmd_i2c_addr_read(char* qry)
gsteiert 6:6aa0b2a3c4e4 88 {
gsteiert 6:6aa0b2a3c4e4 89 int addr = 0;
gsteiert 6:6aa0b2a3c4e4 90 int radd = 0;
gsteiert 6:6aa0b2a3c4e4 91 int dlen = 0;
gsteiert 6:6aa0b2a3c4e4 92 if (sscanf(qry, "%2x", &addr) == 1) {
gsteiert 6:6aa0b2a3c4e4 93 qry += 2;
gsteiert 6:6aa0b2a3c4e4 94 printf("Addressed Read from I2C addr %x ", addr);
gsteiert 6:6aa0b2a3c4e4 95 if (sscanf(qry, "&%2x", &radd) == 1) {
gsteiert 6:6aa0b2a3c4e4 96 qry += 3;
gsteiert 6:6aa0b2a3c4e4 97 printf("reg addr %x ", radd);
gsteiert 6:6aa0b2a3c4e4 98 if (sscanf(qry, "&%2x", &dlen) == 1) {
gsteiert 6:6aa0b2a3c4e4 99 data[0] = radd;
gsteiert 6:6aa0b2a3c4e4 100 i2c.write(addr, data, 1, false);
gsteiert 6:6aa0b2a3c4e4 101 if (i2c.read(addr, data, dlen)!=0) {
gsteiert 6:6aa0b2a3c4e4 102 dlen = -1;
gsteiert 6:6aa0b2a3c4e4 103 printf("failed\r\n");
gsteiert 6:6aa0b2a3c4e4 104 } else {
gsteiert 6:6aa0b2a3c4e4 105 printf("%d bytes\r\n ", dlen);
gsteiert 6:6aa0b2a3c4e4 106 }
gsteiert 6:6aa0b2a3c4e4 107 } else {
gsteiert 6:6aa0b2a3c4e4 108 printf("\r\nInvalid data length: %s\r\n", qry);
gsteiert 6:6aa0b2a3c4e4 109 }
gsteiert 6:6aa0b2a3c4e4 110 } else {
gsteiert 6:6aa0b2a3c4e4 111 dlen = -1;
gsteiert 6:6aa0b2a3c4e4 112 printf("Invalid register address: %s\r\n", qry);
gsteiert 6:6aa0b2a3c4e4 113
gsteiert 6:6aa0b2a3c4e4 114 }
gsteiert 6:6aa0b2a3c4e4 115 } else {
gsteiert 6:6aa0b2a3c4e4 116 dlen = -1;
gsteiert 6:6aa0b2a3c4e4 117 printf("Invalid address: %s\r\n", qry);
gsteiert 6:6aa0b2a3c4e4 118 }
gsteiert 6:6aa0b2a3c4e4 119 sprintf(httpHeader,"HTTP/1.1 200 OK\r\nContent-Type: text/html\r\nConnection: Close\r\n\r\n%d", dlen);
gsteiert 6:6aa0b2a3c4e4 120 client.send(httpHeader,strlen(httpHeader));
gsteiert 6:6aa0b2a3c4e4 121 while (dlen > 0) {
gsteiert 6:6aa0b2a3c4e4 122 dlen -= 1;
gsteiert 6:6aa0b2a3c4e4 123 sprintf(httpHeader," %x", data[dlen]);
gsteiert 6:6aa0b2a3c4e4 124 client.send(httpHeader,strlen(httpHeader));
gsteiert 6:6aa0b2a3c4e4 125 }
gsteiert 6:6aa0b2a3c4e4 126 }
gsteiert 6:6aa0b2a3c4e4 127 void get_file(char* uri)
gsteiert 6:6aa0b2a3c4e4 128 {
gsteiert 6:6aa0b2a3c4e4 129 char *lstchr = strrchr(uri, NULL) -1;
gsteiert 6:6aa0b2a3c4e4 130 if ('/' == *lstchr) {
gsteiert 6:6aa0b2a3c4e4 131 printf("Open directory /sd%s\n", uri);
gsteiert 6:6aa0b2a3c4e4 132 *lstchr = 0;
gsteiert 6:6aa0b2a3c4e4 133 sprintf(filename, "/sd%s", uri);
gsteiert 6:6aa0b2a3c4e4 134 DIR *d = opendir(filename);
gsteiert 6:6aa0b2a3c4e4 135 if (d != NULL) {
gsteiert 6:6aa0b2a3c4e4 136 sprintf(httpHeader,"HTTP/1.1 200 OK\r\nContent-Type: text/html\r\nConnection: Close\r\n\r\n");
gsteiert 6:6aa0b2a3c4e4 137 client.send(httpHeader,strlen(httpHeader));
gsteiert 6:6aa0b2a3c4e4 138 sprintf(httpHeader,"<html><head><title>Directory Listing</title></head><body><h1>%s</h1><ul>", uri);
gsteiert 6:6aa0b2a3c4e4 139 client.send(httpHeader,strlen(httpHeader));
gsteiert 6:6aa0b2a3c4e4 140 struct dirent *p;
gsteiert 6:6aa0b2a3c4e4 141 while((p = readdir(d)) != NULL) {
gsteiert 6:6aa0b2a3c4e4 142 printf("%s\n", p->d_name);
gsteiert 6:6aa0b2a3c4e4 143 sprintf(httpHeader,"<li>%s</li>", p->d_name);
gsteiert 6:6aa0b2a3c4e4 144 client.send(httpHeader,strlen(httpHeader));
gsteiert 6:6aa0b2a3c4e4 145 }
gsteiert 6:6aa0b2a3c4e4 146 }
gsteiert 6:6aa0b2a3c4e4 147 closedir(d);
gsteiert 6:6aa0b2a3c4e4 148 printf("Directory closed\n");
gsteiert 6:6aa0b2a3c4e4 149 sprintf(httpHeader,"</ul></body></html>");
gsteiert 6:6aa0b2a3c4e4 150 client.send(httpHeader,strlen(httpHeader));
gsteiert 6:6aa0b2a3c4e4 151 } else {
gsteiert 6:6aa0b2a3c4e4 152 sprintf(filename, "/sd%s", uri);
gsteiert 6:6aa0b2a3c4e4 153 fp = fopen(filename, "r");
gsteiert 6:6aa0b2a3c4e4 154 if (fp == NULL) {
gsteiert 6:6aa0b2a3c4e4 155 sprintf(httpHeader,"HTTP/1.1 404 Not Found \r\nContent-Type: text\r\nConnection: Close\r\n\r\n");
gsteiert 6:6aa0b2a3c4e4 156 client.send(httpHeader,strlen(httpHeader));
gsteiert 6:6aa0b2a3c4e4 157 client.send(uri,strlen(uri));
gsteiert 6:6aa0b2a3c4e4 158 } else {
gsteiert 6:6aa0b2a3c4e4 159 sprintf(httpHeader,"HTTP/1.1 200 OK\r\nContent-Type: text/html\r\nConnection: Close\r\n\r\n");
gsteiert 6:6aa0b2a3c4e4 160 client.send(httpHeader,strlen(httpHeader));
gsteiert 6:6aa0b2a3c4e4 161 while ((rdCnt = fread(buffer, sizeof( char ), 1024, fp)) == 1024) {
gsteiert 6:6aa0b2a3c4e4 162 client.send(buffer, rdCnt);
gsteiert 6:6aa0b2a3c4e4 163 }
gsteiert 6:6aa0b2a3c4e4 164 client.send(buffer, rdCnt);
gsteiert 6:6aa0b2a3c4e4 165 fclose(fp);
gsteiert 6:6aa0b2a3c4e4 166 }
gsteiert 6:6aa0b2a3c4e4 167 }
gsteiert 6:6aa0b2a3c4e4 168 }
gsteiert 6:6aa0b2a3c4e4 169
gsteiert 6:6aa0b2a3c4e4 170 void get_cgi(char* uri, char* qry)
gsteiert 6:6aa0b2a3c4e4 171 {
gsteiert 6:6aa0b2a3c4e4 172 if (!strncmp(uri, "i2cW", 4)) { // i2cW [addr] [data] [data] [data] ...
gsteiert 6:6aa0b2a3c4e4 173 cmd_i2c_write(qry);
gsteiert 6:6aa0b2a3c4e4 174 } else if (!strncmp(uri, "i2cR", 4)) { // i2cR [addr] [count]
gsteiert 6:6aa0b2a3c4e4 175 cmd_i2c_read(qry);
gsteiert 6:6aa0b2a3c4e4 176 } else if (!strncmp(uri, "i2cAR", 5)) { // i2cAR [addr] [radd] [count]
gsteiert 6:6aa0b2a3c4e4 177 cmd_i2c_addr_read(qry);
gsteiert 6:6aa0b2a3c4e4 178 } else {
gsteiert 6:6aa0b2a3c4e4 179 sprintf(httpHeader,"HTTP/1.1 200 OK\r\nContent-Type: text/html\r\nConnection: Close\r\n\r\n");
gsteiert 6:6aa0b2a3c4e4 180 client.send(httpHeader,strlen(httpHeader));
gsteiert 6:6aa0b2a3c4e4 181 sprintf(httpHeader,"<html><head><title>Unrecognized CGI Command</title></head><body><h1>Unrecognized CGI Command</h1>");
gsteiert 6:6aa0b2a3c4e4 182 client.send(httpHeader,strlen(httpHeader));
gsteiert 6:6aa0b2a3c4e4 183 sprintf(httpHeader,"<h2>Command: %s</h2>", uri);
gsteiert 6:6aa0b2a3c4e4 184 client.send(httpHeader,strlen(httpHeader));
gsteiert 6:6aa0b2a3c4e4 185 sprintf(httpHeader,"<h2>Query: %s</h2>", qry);
gsteiert 6:6aa0b2a3c4e4 186 client.send(httpHeader,strlen(httpHeader));
gsteiert 6:6aa0b2a3c4e4 187 sprintf(httpHeader,"<h2>Supported Commands: </h2><ul>");
gsteiert 6:6aa0b2a3c4e4 188 client.send(httpHeader,strlen(httpHeader));
gsteiert 6:6aa0b2a3c4e4 189 sprintf(httpHeader,"<li>i2cR [addr] [count]");
gsteiert 6:6aa0b2a3c4e4 190 client.send(httpHeader,strlen(httpHeader));
gsteiert 6:6aa0b2a3c4e4 191 sprintf(httpHeader,"<li>i2cAR [addr] [radd] [count]");
gsteiert 6:6aa0b2a3c4e4 192 client.send(httpHeader,strlen(httpHeader));
gsteiert 6:6aa0b2a3c4e4 193 sprintf(httpHeader,"<li>i2cW [addr] [data] [data] [data] ...");
gsteiert 6:6aa0b2a3c4e4 194 client.send(httpHeader,strlen(httpHeader));
gsteiert 6:6aa0b2a3c4e4 195 sprintf(httpHeader,"</ul><br>addr = I2C address<br>radd = register address<br>count = number of bytes to read<br>data = data byte to send<br>All values are in two digit hexdecimal bytes.");
gsteiert 6:6aa0b2a3c4e4 196 client.send(httpHeader,strlen(httpHeader));
gsteiert 6:6aa0b2a3c4e4 197 sprintf(httpHeader,"</body></html>");
gsteiert 6:6aa0b2a3c4e4 198 client.send(httpHeader,strlen(httpHeader));
gsteiert 6:6aa0b2a3c4e4 199 }
gsteiert 6:6aa0b2a3c4e4 200 }
gsteiert 6:6aa0b2a3c4e4 201
gsteiert 6:6aa0b2a3c4e4 202
gsteiert 6:6aa0b2a3c4e4 203 int main (void)
gsteiert 6:6aa0b2a3c4e4 204 {
gsteiert 6:6aa0b2a3c4e4 205 // EthernetInterface eth;
emilmont 1:5cebe0e38cd2 206 eth.init(); //Use DHCP
emilmont 1:5cebe0e38cd2 207 eth.connect();
emilmont 1:5cebe0e38cd2 208 printf("IP Address is %s\n", eth.getIPAddress());
gsteiert 6:6aa0b2a3c4e4 209
gsteiert 6:6aa0b2a3c4e4 210 // TCPSocketServer server;
gsteiert 6:6aa0b2a3c4e4 211 server.bind(HTTPD_SERVER_PORT);
emilmont 3:36fd3cfad85a 212 server.listen();
gsteiert 6:6aa0b2a3c4e4 213
emilmont 1:5cebe0e38cd2 214 while (true) {
gsteiert 6:6aa0b2a3c4e4 215 printf("\nWait for new connection...\r\n");
emilmont 1:5cebe0e38cd2 216 server.accept(client);
emilmont 3:36fd3cfad85a 217 client.set_blocking(false, 1500); // Timeout after (1.5)s
gsteiert 6:6aa0b2a3c4e4 218
gsteiert 6:6aa0b2a3c4e4 219 printf("Connection from: %s\r\n", client.get_address());
emilmont 1:5cebe0e38cd2 220 while (true) {
emilmont 3:36fd3cfad85a 221 int n = client.receive(buffer, sizeof(buffer));
emilmont 1:5cebe0e38cd2 222 if (n <= 0) break;
gsteiert 6:6aa0b2a3c4e4 223 printf("Recieved Data: %d\r\n\r\n%.*s\r\n",n,n,buffer);
gsteiert 6:6aa0b2a3c4e4 224 if (n >= 1024) {
gsteiert 6:6aa0b2a3c4e4 225 sprintf(httpHeader,"HTTP/1.1 413 Request Entity Too Large \r\nContent-Type: text\r\nConnection: Close\r\n\r\n");
gsteiert 6:6aa0b2a3c4e4 226 client.send(httpHeader,strlen(httpHeader));
gsteiert 6:6aa0b2a3c4e4 227 client.send(buffer,n);
gsteiert 6:6aa0b2a3c4e4 228 break;
gsteiert 6:6aa0b2a3c4e4 229 } else {
gsteiert 6:6aa0b2a3c4e4 230 buffer[n]=0;
gsteiert 6:6aa0b2a3c4e4 231 }
gsteiert 6:6aa0b2a3c4e4 232 if (!strncmp(buffer, "GET ", 4)) {
gsteiert 6:6aa0b2a3c4e4 233 uristr = buffer + 4;
gsteiert 6:6aa0b2a3c4e4 234 eou = strstr(uristr, " ");
gsteiert 6:6aa0b2a3c4e4 235 if (eou == NULL) {
gsteiert 6:6aa0b2a3c4e4 236 sprintf(httpHeader,"HTTP/1.1 400 Bad Request \r\nContent-Type: text\r\nConnection: Close\r\n\r\n");
gsteiert 6:6aa0b2a3c4e4 237 client.send(httpHeader,strlen(httpHeader));
gsteiert 6:6aa0b2a3c4e4 238 client.send(buffer,n);
gsteiert 6:6aa0b2a3c4e4 239 } else {
gsteiert 6:6aa0b2a3c4e4 240 *eou = 0;
gsteiert 6:6aa0b2a3c4e4 241 qrystr = strstr(uristr, "?");
gsteiert 6:6aa0b2a3c4e4 242 if (qrystr != NULL) {
gsteiert 6:6aa0b2a3c4e4 243 *qrystr = 0;
gsteiert 6:6aa0b2a3c4e4 244 qrystr++;
gsteiert 6:6aa0b2a3c4e4 245 }
gsteiert 6:6aa0b2a3c4e4 246 if (!strncmp(uristr, "/cgi/", 5)) {
gsteiert 6:6aa0b2a3c4e4 247 get_cgi(uristr+5, qrystr);
gsteiert 6:6aa0b2a3c4e4 248 } else {
gsteiert 6:6aa0b2a3c4e4 249 get_file(uristr);
gsteiert 6:6aa0b2a3c4e4 250 }
gsteiert 6:6aa0b2a3c4e4 251 }
gsteiert 6:6aa0b2a3c4e4 252 }
emilmont 1:5cebe0e38cd2 253 }
gsteiert 6:6aa0b2a3c4e4 254
emilmont 1:5cebe0e38cd2 255 client.close();
emilmont 1:5cebe0e38cd2 256 }
emilmont 1:5cebe0e38cd2 257 }