Remove sd dependence. Add default callback to match all request that doesn't match...
[bertos.git] / bertos / net / http.c
1 /**
2  * \file
3  * <!--
4  * This file is part of BeRTOS.
5  *
6  * Bertos is free software; you can redistribute it and/or modify
7  * it under the terms of the GNU General Public License as published by
8  * the Free Software Foundation; either version 2 of the License, or
9  * (at your option) any later version.
10  *
11  * This program is distributed in the hope that it will be useful,
12  * but WITHOUT ANY WARRANTY; without even the implied warranty of
13  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
14  * GNU General Public License for more details.
15  *
16  * You should have received a copy of the GNU General Public License
17  * along with this program; if not, write to the Free Software
18  * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA
19  *
20  * As a special exception, you may use this file as part of a free software
21  * library without restriction.  Specifically, if other files instantiate
22  * templates or use macros or inline functions from this file, or you compile
23  * this file and link it with other files to produce an executable, this
24  * file does not by itself cause the resulting executable to be covered by
25  * the GNU General Public License.  This exception does not however
26  * invalidate any other reasons why the executable file might be covered by
27  * the GNU General Public License.
28  *
29  * Copyright 2011 Develer S.r.l. (http://www.develer.com/)
30  *
31  * -->
32  *
33  * \author Daniele Basile <asterix@develer.com>
34  *
35  * \brief Simple Http server.
36  *
37  * This simple web server read the site's pages from SD card, and manage
38  * the cases where SD is not present or page not found, using embedded pages.
39  * Quering from browser the /status page, the server return a json dictionary where are store
40  * some board status info, like board temperature, up-time, etc.
41  */
42
43 #include "http.h"
44
45 #include "hw/hw_sd.h"
46 #include "hw/hw_http.h"
47
48 #include "cfg/cfg_http.h"
49
50 // Define logging setting (for cfg/log.h module).
51 #define LOG_LEVEL         HTTP_LOG_LEVEL
52 #define LOG_VERBOSITY     HTTP_LOG_FORMAT
53 #include <cfg/log.h>
54
55 #include <stdio.h>
56 #include <string.h>
57
58
59 static const char http_html_hdr_200[] = "HTTP/1.1 200 OK\r\nContent-type: text/html\r\n\r\n";
60 static const char http_html_hdr_404[] = "HTTP/1.1 404 Not Found\r\nContent-type: text/html\r\n\r\n";
61 static const char http_html_hdr_500[] = "HTTP/1.1 500 Internal Server Error\r\nContent-type: text/html\r\n\r\n";
62
63 static HttpCGI *cgi_table;
64 static http_handler_t http_callback;
65
66
67 void http_sendOk(struct netconn *client)
68 {
69         netconn_write(client, http_html_hdr_200, sizeof(http_html_hdr_200) - 1, NETCONN_NOCOPY);
70 }
71
72 void http_sendFileNotFound(struct netconn *client)
73 {
74         netconn_write(client, http_html_hdr_404, sizeof(http_html_hdr_404) - 1, NETCONN_NOCOPY);
75 }
76
77 void http_sendInternalErr(struct netconn *client)
78 {
79         netconn_write(client, http_html_hdr_500, sizeof(http_html_hdr_500) - 1, NETCONN_NOCOPY);
80 }
81
82 static void get_fileName(const char *revc_buf, size_t recv_len, char *name, size_t len)
83 {
84         int i = 0;
85         char *p = strstr(revc_buf, "GET");
86         if (p)
87         {
88                 //Find the end of the page request.
89                 char *stop = strstr(revc_buf, "HTTP");
90                 if (!stop)
91                 {
92                         LOG_ERR("Bad GET request\n");
93                         name[0] = '\0';
94                         return;
95                 }
96
97                 //skip the "/" in get string request
98                 p += sizeof("GET") + 1;
99
100                 while (p != stop)
101                 {
102                         if ((size_t)i == len || (size_t)i >= recv_len)
103                         {
104                                 name[i] = '\0';
105                                 break;
106                         }
107
108                         name[i++] = *(p++);
109                 }
110         }
111
112         //Trail white space in the string.
113         while ( --i >= 0 )
114                 if (name[i] != ' ' && name[i] != '\t' && name[i] != '\n')
115                         break;
116
117         name[i + 1] = '\0';
118 }
119
120 INLINE const char *get_ext(const char *name)
121 {
122         const char *ext = strstr(name, ".");
123         if(ext && (ext + 1))
124                 return (ext + 1);
125
126         return NULL;
127 }
128
129 static http_handler_t cgi_search(const char *name,  HttpCGI *table)
130 {
131         if (!table)
132                 return NULL;
133
134         int i = 0;
135         const char *ext = get_ext(name);
136         LOG_INFO("EXT %s\n", ext);
137         while(table[i].name)
138         {
139                 if (ext && table[i].type == CGI_MATCH_EXT)
140                 {
141                         LOG_INFO("Match all ext %s\n", ext);
142                         if (!strcmp(table[i].name, ext))
143                                 break;
144                 }
145                 else /* (table[i].type == CGI_MATCH_NAME) */
146                 {
147                         LOG_INFO("Match all name %s\n", name);
148                         if (!strcmp(table[i].name, name))
149                                 break;
150                 }
151
152                 i++;
153         }
154
155         return table[i].handler;
156 }
157
158 static char req_string[80];
159
160 void http_poll(struct netconn *server)
161 {
162         struct netconn *client;
163         struct netbuf *rx_buf_conn;
164         char *rx_buf;
165         uint16_t len;
166
167         client = netconn_accept(server);
168         if (!client)
169                 return;
170
171         rx_buf_conn = netconn_recv(client);
172         if (rx_buf_conn)
173         {
174                 netbuf_data(rx_buf_conn, (void **)&rx_buf, &len);
175                 if (rx_buf)
176                 {
177                         memset(req_string, 0, sizeof(req_string));
178                         get_fileName(rx_buf, len, req_string, sizeof(req_string));
179
180                         LOG_INFO("Search %s\n", req_string);
181                         if (req_string[0] == '\0')
182                                 strcpy(req_string, HTTP_DEFAULT_PAGE);
183
184                         http_handler_t cgi = cgi_search(req_string, cgi_table);
185                         if (cgi)
186                         {
187                                 if (cgi(client, req_string, rx_buf, len) < 0)
188                                 {
189                                         LOG_ERR("Internal server error\n");
190                                         http_sendInternalErr(client);
191                                         netconn_write(client, http_server_error, http_server_error_len - 1, NETCONN_NOCOPY);
192                                 }
193                         }
194                         else
195                         {
196                                 http_callback(client, req_string, rx_buf, len);
197                         }
198                 }
199                 netconn_close(client);
200                 netbuf_delete(rx_buf_conn);
201         }
202         netconn_delete(client);
203 }
204
205 void http_init(http_handler_t default_callback, struct HttpCGI *table)
206 {
207         ASSERT(default_callback);
208
209         cgi_table = table;
210         http_callback = default_callback;
211 }
212