1 files changed, 163 insertions, 0 deletions
diff --git a/src/protocolhttp.cpp b/src/protocolhttp.cpp
new file mode 100644
index 0000000..6f2ae68
--- /dev/null
+++ b/src/protocolhttp.cpp
@@ -0,0 +1,163 @@
+#include <dirent.h>
+#include <sys/wait.h>
+#include <errno.h>
+#include "protocolhttp.h"
+#define CRLF "\x0D\x0A"
+#define CR '\x0D'
+#define LF '\x0A'
+using namespace Bu;
+Bu::ProtocolHttp::ProtocolHttp()
+{
+}
+Bu::ProtocolHttp::~ProtocolHttp()
+{
+}
+void Bu::ProtocolHttp::onNewConnection( Bu::Client *pClient )
+{
+        this->pClient = pClient;
+        iState = 0;
+}
+#define SDB( i ) printf("state %d: %d, \"%s\"\n", i, tt, sToken.getStr() )
+void Bu::ProtocolHttp::onNewData( Bu::Client *pClient )
+{
+        for(;;)
+        {
+                Bu::FString sToken;
+                TokenType tt = getToken( sToken );
+                if( tt == ttOutOfData )
+                        return;
+                switch( iState )
+                {
+                        case 0:         // Initial header
+                                SDB( 0 );
+                                sMethod = sToken;
+                                iState = 1;
+                                break;
+                        case 1:         // Misc headers
+                                SDB( 1 );
+                                sPath = sToken;
+                                iState = 2;
+                                break;
+                        case 2:         // Content
+                                SDB( 2 );
+                                if( strncmp( sToken.getStr(), "HTTP/", 5 ) )
+                                {
+                                        printf("not http, disconnect.\n");
+                                        pClient->disconnect();
+                                        return;
+                                }
+                                else
+                                {
+                                        char *s, *s2;
+                                        s = sToken.getStr()+5;
+                                        iMajor = strtol( s, &s2, 10 );
+                                        iMinor = strtol( s2+1, NULL, 10 );
+                                        printf("HTTP: %d.%d\n", iMajor, iMinor );
+                                        iState = 3;
+                                }
+                                break;
+                        case 3:
+                                SDB( 3 );
+                                pClient->disconnect();
+                                return;
+                                break;
+                }
+        }
+}
+Bu::ProtocolHttp::TokenType Bu::ProtocolHttp::getToken( Bu::FString &line )
+{
+        char s;
+        int jmax = pClient->getInputSize();
+        bool bNonWS = false;
+        
+        for( int j = 0; j < jmax; j++ )
+        {
+                pClient->peek( &s, 1, j );
+                if( iState > 2 && isSeperator( s ) )
+                {
+                        if( j == 0 )
+                        {
+                                line += s;
+                                pClient->seek( 1 );
+                                return ttSeperator;
+                        }
+                        else
+                        {
+                                pClient->seek( j );
+                                return ttString;
+                        }
+                }
+                else if( isWS( s ) )
+                {
+                        if( bNonWS )
+                        {
+                                pClient->seek( j );
+                                return ttString;
+                        }
+                }
+                else if( s == CR )
+                {
+                        if( pClient->getInputSize() < 3 )
+                                return ttOutOfData;
+                        
+                        char ss[2];
+                        pClient->peek( ss, 2, j+1 );
+                        if( ss[0] == LF && ss[1] != ' ' && ss[1] != '\t' )
+                        {
+                                if( bNonWS )
+                                {
+                                        pClient->seek( j );
+                                        return ttString;
+                                }
+                                else
+                                {
+                                        pClient->seek( 2 );
+                                        return ttNewline;
+                                }
+                        }
+                        
+                        j += 2;
+                        if( bNonWS )
+                        {
+                                pClient->seek( j );
+                                return ttString;
+                        }
+                }
+                else
+                {
+                        line += s;
+                        bNonWS = true;
+                }
+        }
+        return ttOutOfData;
+}
+bool Bu::ProtocolHttp::isWS( char buf )
+{
+        return (buf == ' ' || buf == '\t');
+}
+bool Bu::ProtocolHttp::isSeperator( char buf )
+{
+        return (buf == '(' || buf == ')' || buf == '<' || buf == '>' ||
+                        buf == '@' || buf == ',' || buf == ';' || buf == ':' ||
+                        buf == '\\' || buf == '\"' || buf == '/' || buf == '[' ||
+                        buf == ']' || buf == '?' || buf == '=' || buf == '{' ||
+                        buf == '}' );
+}

diff --git a/src/protocolhttp.cpp b/src/protocolhttp.cpp new file mode 100644 index 0000000..6f2ae68 --- /dev/null +++ b/src/protocolhttp.cpp
@@ -0,0 +1,163 @@
	1	#include <dirent.h>
	2	#include <sys/wait.h>
	3	#include <errno.h>
	4	#include "protocolhttp.h"
	5
	6	#define CRLF "\x0D\x0A"
	7	#define CR '\x0D'
	8	#define LF '\x0A'
	9
	10	using namespace Bu;
	11
	12	Bu::ProtocolHttp::ProtocolHttp()
	13	{
	14	}
	15
	16	Bu::ProtocolHttp::~ProtocolHttp()
	17	{
	18	}
	19
	20	void Bu::ProtocolHttp::onNewConnection( Bu::Client *pClient )
	21	{
	22	this->pClient = pClient;
	23
	24	iState = 0;
	25	}
	26
	27	#define SDB( i ) printf("state %d: %d, \"%s\"\n", i, tt, sToken.getStr() )
	28
	29	void Bu::ProtocolHttp::onNewData( Bu::Client *pClient )
	30	{
	31	for(;;)
	32	{
	33	Bu::FString sToken;
	34	TokenType tt = getToken( sToken );
	35
	36	if( tt == ttOutOfData )
	37	return;
	38
	39	switch( iState )
	40	{
	41	case 0: // Initial header
	42	SDB( 0 );
	43	sMethod = sToken;
	44	iState = 1;
	45	break;
	46
	47	case 1: // Misc headers
	48	SDB( 1 );
	49	sPath = sToken;
	50	iState = 2;
	51	break;
	52
	53	case 2: // Content
	54	SDB( 2 );
	55	if( strncmp( sToken.getStr(), "HTTP/", 5 ) )
	56	{
	57	printf("not http, disconnect.\n");
	58	pClient->disconnect();
	59	return;
	60	}
	61	else
	62	{
	63	char s, s2;
	64	s = sToken.getStr()+5;
	65	iMajor = strtol( s, &s2, 10 );
	66	iMinor = strtol( s2+1, NULL, 10 );
	67	printf("HTTP: %d.%d\n", iMajor, iMinor );
	68	iState = 3;
	69	}
	70	break;
	71
	72	case 3:
	73	SDB( 3 );
	74	pClient->disconnect();
	75	return;
	76	break;
	77	}
	78	}
	79	}
	80
	81	Bu::ProtocolHttp::TokenType Bu::ProtocolHttp::getToken( Bu::FString &line )
	82	{
	83	char s;
	84	int jmax = pClient->getInputSize();
	85	bool bNonWS = false;
	86
	87	for( int j = 0; j < jmax; j++ )
	88	{
	89	pClient->peek( &s, 1, j );
	90	if( iState > 2 && isSeperator( s ) )
	91	{
	92	if( j == 0 )
	93	{
	94	line += s;
	95	pClient->seek( 1 );
	96	return ttSeperator;
	97	}
	98	else
	99	{
	100	pClient->seek( j );
	101	return ttString;
	102	}
	103	}
	104	else if( isWS( s ) )
	105	{
	106	if( bNonWS )
	107	{
	108	pClient->seek( j );
	109	return ttString;
	110	}
	111	}
	112	else if( s == CR )
	113	{
	114	if( pClient->getInputSize() < 3 )
	115	return ttOutOfData;
	116
	117	char ss[2];
	118	pClient->peek( ss, 2, j+1 );
	119	if( ss[0] == LF && ss[1] != ' ' && ss[1] != '\t' )
	120	{
	121	if( bNonWS )
	122	{
	123	pClient->seek( j );
	124	return ttString;
	125	}
	126	else
	127	{
	128	pClient->seek( 2 );
	129	return ttNewline;
	130	}
	131	}
	132
	133	j += 2;
	134	if( bNonWS )
	135	{
	136	pClient->seek( j );
	137	return ttString;
	138	}
	139	}
	140	else
	141	{
	142	line += s;
	143	bNonWS = true;
	144	}
	145	}
	146
	147	return ttOutOfData;
	148	}
	149
	150	bool Bu::ProtocolHttp::isWS( char buf )
	151	{
	152	return (buf == ' ' \|\| buf == '\t');
	153	}
	154
	155	bool Bu::ProtocolHttp::isSeperator( char buf )
	156	{
	157	return (buf == '(' \|\| buf == ')' \|\| buf == '<' \|\| buf == '>' \|\|
	158	buf == '@' \|\| buf == ',' \|\| buf == ';' \|\| buf == ':' \|\|
	159	buf == '\\' \|\| buf == '\"' \|\| buf == '/' \|\| buf == '[' \|\|
	160	buf == ']' \|\| buf == '?' \|\| buf == '=' \|\| buf == '{' \|\|
	161	buf == '}' );
	162	}
	163