2015-09-16 08:56:47 +00:00
/*
ChibiOS / RT - Copyright ( C ) 2006 - 2013 Giovanni Di Sirio
Licensed under the Apache License , Version 2.0 ( the " License " ) ;
you may not use this file except in compliance with the License .
You may obtain a copy of the License at
http : //www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing , software
distributed under the License is distributed on an " AS IS " BASIS ,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND , either express or implied .
See the License for the specific language governing permissions and
limitations under the License .
*/
/*
* This file is a modified version of the lwIP web server demo . The original
* author is unknown because the file didn ' t contain any license information .
*/
/**
* @ file web . c
* @ brief HTTP server wrapper thread code .
* @ addtogroup WEB_THREAD
* @ {
*/
2015-10-01 09:12:33 +00:00
# include <ctype.h>
2015-09-16 08:56:47 +00:00
# include "ch.h"
# include "lwip/opt.h"
# include "lwip/arch.h"
# include "lwip/api.h"
# include "web.h"
# if LWIP_NETCONN
2015-10-01 09:12:33 +00:00
static char url_buffer [ WEB_MAX_PATH_SIZE ] ;
# define HEXTOI(x) (isdigit(x) ? (x) - '0' : (x) - 'a' + 10)
/**
* @ brief Decodes an URL sting .
* @ note The string is terminated by a zero or a separator .
*
* @ param [ in ] url encoded URL string
* @ param [ out ] buf buffer for the processed string
* @ param [ in ] max max number of chars to copy into the buffer
* @ return The conversion status .
* @ retval false string converted .
* @ retval true the string was not valid or the buffer overflowed
*
* @ notapi
*/
static bool decode_url ( const char * url , char * buf , size_t max ) {
while ( true ) {
int h , l ;
unsigned c = * url + + ;
switch ( c ) {
case 0 :
case ' \r ' :
case ' \n ' :
case ' \t ' :
case ' ' :
case ' ? ' :
* buf = 0 ;
return false ;
case ' . ' :
if ( max < = 1 )
return true ;
h = * ( url + 1 ) ;
if ( h = = ' . ' )
return true ;
break ;
case ' % ' :
if ( max < = 1 )
return true ;
h = tolower ( ( int ) * url + + ) ;
if ( h = = 0 )
return true ;
if ( ! isxdigit ( h ) )
return true ;
l = tolower ( ( int ) * url + + ) ;
if ( l = = 0 )
return true ;
if ( ! isxdigit ( l ) )
return true ;
c = ( char ) ( ( HEXTOI ( h ) < < 4 ) | HEXTOI ( l ) ) ;
break ;
default :
if ( max < = 1 )
return true ;
if ( ! isalnum ( c ) & & ( c ! = ' _ ' ) & & ( c ! = ' - ' ) & & ( c ! = ' + ' ) & &
( c ! = ' / ' ) )
return true ;
break ;
}
* buf + + = c ;
max - - ;
}
}
2015-09-16 08:56:47 +00:00
static const char http_html_hdr [ ] = " HTTP/1.1 200 OK \r \n Content-type: text/html \r \n \r \n " ;
static const char http_index_html [ ] = " <html><head><title>Congrats!</title></head><body><h1>Welcome to our lwIP HTTP server!</h1><p>This is a small test page.</body></html> " ;
static void http_server_serve ( struct netconn * conn ) {
struct netbuf * inbuf ;
char * buf ;
u16_t buflen ;
err_t err ;
/* Read the data from the port, blocking if nothing yet there.
2015-10-01 09:12:33 +00:00
We assume the request ( the part we care about ) is in one netbuf . */
2015-09-16 08:56:47 +00:00
err = netconn_recv ( conn , & inbuf ) ;
if ( err = = ERR_OK ) {
netbuf_data ( inbuf , ( void * * ) & buf , & buflen ) ;
/* Is this an HTTP GET command? (only check the first 5 chars, since
2015-10-01 09:12:33 +00:00
there are other formats for GET , and we ' re keeping it very simple ) . */
if ( buflen > = 5 & &
buf [ 0 ] = = ' G ' & &
buf [ 1 ] = = ' E ' & &
buf [ 2 ] = = ' T ' & &
buf [ 3 ] = = ' ' & &
buf [ 4 ] = = ' / ' ) {
if ( decode_url ( buf + 4 , url_buffer , WEB_MAX_PATH_SIZE ) ) {
/* Invalid URL handling.*/
return ;
}
2015-09-16 08:56:47 +00:00
/* Send the HTML header
* subtract 1 from the size , since we dont send the \ 0 in the string
* NETCONN_NOCOPY : our data is const static , so no need to copy it
*/
netconn_write ( conn , http_html_hdr , sizeof ( http_html_hdr ) - 1 , NETCONN_NOCOPY ) ;
/* Send our HTML page */
netconn_write ( conn , http_index_html , sizeof ( http_index_html ) - 1 , NETCONN_NOCOPY ) ;
}
}
/* Close the connection (server closes in HTTP) */
netconn_close ( conn ) ;
/* Delete the buffer (netconn_recv gives us ownership,
so we have to make sure to deallocate the buffer ) */
netbuf_delete ( inbuf ) ;
}
/**
2015-10-01 09:12:33 +00:00
* @ brief Stack area for the http thread .
2015-09-16 08:56:47 +00:00
*/
THD_WORKING_AREA ( wa_http_server , WEB_THREAD_STACK_SIZE ) ;
/**
2015-10-01 09:12:33 +00:00
* @ brief HTTP server thread .
2015-09-16 08:56:47 +00:00
*/
THD_FUNCTION ( http_server , p ) {
struct netconn * conn , * newconn ;
err_t err ;
( void ) p ;
chRegSetThreadName ( " http " ) ;
/* Create a new TCP connection handle */
conn = netconn_new ( NETCONN_TCP ) ;
LWIP_ERROR ( " http_server: invalid conn " , ( conn ! = NULL ) , chThdExit ( MSG_RESET ) ; ) ;
/* Bind to port 80 (HTTP) with default IP address */
netconn_bind ( conn , NULL , WEB_THREAD_PORT ) ;
/* Put the connection into LISTEN state */
netconn_listen ( conn ) ;
/* Goes to the final priority after initialization.*/
chThdSetPriority ( WEB_THREAD_PRIORITY ) ;
while ( true ) {
err = netconn_accept ( conn , & newconn ) ;
if ( err ! = ERR_OK )
continue ;
http_server_serve ( newconn ) ;
netconn_delete ( newconn ) ;
}
}
# endif /* LWIP_NETCONN */
/** @} */
