diff options
Diffstat (limited to 'reqp.cpp')
| -rw-r--r--[-rwxr-xr-x] | reqp.cpp | 395 |
1 files changed, 206 insertions, 189 deletions
@@ -20,136 +20,140 @@ string reqp::HTTP_CONNEC = "Connection: keep-alive\n"; string reqp::HTTP_COTYPE = "Content-Type: "; reqp::reqp( ) -{ -} +{} string reqp::get_url( thrd* p_thrd, string s_req, map_string &map_params ) { - auto unsigned int pos; - string s_ret ( "" ); - string s_vars( "" ); - auto int i_request; + auto unsigned int pos; + string s_ret ( "" ); + string s_vars( "" ); + auto int i_request; - i_request= ( s_req.find("GET",0) != string::npos ) ? RQ_GET : RQ_POST; + i_request= ( s_req.find("GET",0) != string::npos ) ? RQ_GET : RQ_POST; - pos = s_req.find( "HTTP", 0 ); + pos = s_req.find( "HTTP", 0 ); - if( i_request == RQ_GET ) - s_ret.append( s_req.substr( 5, pos-6 ) ); - else - s_ret.append( s_req.substr( 6, pos-7 ) ); - - // remove ".." from the request. - do - { - pos = s_ret.find( "../", 0 ); + if( i_request == RQ_GET ) + s_ret.append( s_req.substr( 5, pos-6 ) ); + else + s_ret.append( s_req.substr( 6, pos-7 ) ); - if ( pos == string::npos ) - break; + // remove ".." from the request. + do + { + pos = s_ret.find( "../", 0 ); - s_ret.replace( pos, pos+2, "" ); - } - while( true ); + if ( pos == string::npos ) + break; - // do not add the string behind "?" tp s_ret and add all params behind "?" to map_params. - if( i_request == RQ_GET ) - pos = s_ret.find( "?", 0 ); - else - pos = s_req.find("\r\n\r\n", 0); + s_ret.replace( pos, pos+2, "" ); + } + while( true ); - auto string s_params( "" ); - if ( pos != string::npos ) - { + // do not add the string behind "?" tp s_ret and add all params behind "?" to map_params. if( i_request == RQ_GET ) - s_params.append( s_ret.substr( pos+1, s_ret.length() -pos-1 ) ); - + pos = s_ret.find( "?", 0 ); else - s_params = s_req.substr( pos+4, s_req.length() -pos-1 ); + pos = s_req.find("\r\n\r\n", 0); - s_ret = s_ret.substr( 0, pos ); - } + auto string s_params( "" ); + if ( pos != string::npos ) + { + if( i_request == RQ_GET ) + s_params.append( s_ret.substr( pos+1, s_ret.length() -pos-1 ) ); - if ( i_request == RQ_POST && s_params.empty() ) - { - char c_req[READBUF]; + else + s_params = s_req.substr( pos+4, s_req.length() -pos-1 ); - if ( read ( p_thrd->get_sock() , c_req, READBUF ) <= 0 ) - return "NOBYTE"; + s_ret = s_ret.substr( 0, pos ); + } - s_params = string( strstr( c_req, "event" ) ); - } + if ( i_request == RQ_POST && s_params.empty() ) + { + char c_req[READBUF]; - auto unsigned int pos2; - do - { - pos = s_params.find( "=", 0 ); - if ( pos == string::npos ) - break; + if ( read ( p_thrd->get_sock() , c_req, READBUF ) <= 0 ) + return "NOBYTE"; - pos2 = s_params.find( "&", 0 ); - if ( pos2 == string::npos ) - { - auto string sValue( s_params.substr(pos+1, s_params.length()-pos-1) ); - auto string tmpstr( url_decode(sValue) ); - map_params[ s_params.substr( 0, pos ) ] = tmpstr; - break; + s_params = string( strstr( c_req, "event" ) ); } - auto string s_temp= s_params.substr( pos+1, pos2-pos-1 ); - map_params[ s_params.substr( 0, pos ) ] = url_decode(s_temp); - - s_params = s_params.substr( pos2+1, s_params.length()-pos2-1 ); - } - while( true ); + auto unsigned int pos2; + do + { + pos = s_params.find( "=", 0 ); + if ( pos == string::npos ) + break; + + pos2 = s_params.find( "&", 0 ); + if ( pos2 == string::npos ) + { + auto string sValue( s_params.substr(pos+1, s_params.length()-pos-1) ); + auto string tmpstr( url_decode(sValue) ); + map_params[ s_params.substr( 0, pos ) ] = tmpstr; + break; + } + + auto string s_temp= s_params.substr( pos+1, pos2-pos-1 ); + map_params[ s_params.substr( 0, pos ) ] = url_decode(s_temp); + + s_params = s_params.substr( pos2+1, s_params.length()-pos2-1 ); + } + while( true ); #ifdef VERBOSE - pthread_mutex_lock ( &s_mutx::get().mut_stdout ); - cout << REQUEST << s_ret << endl; - pthread_mutex_unlock( &s_mutx::get().mut_stdout ); + + pthread_mutex_lock ( &s_mutx::get + ().mut_stdout ); + cout << REQUEST << s_ret << endl; + pthread_mutex_unlock( &s_mutx::get + ().mut_stdout ); #endif - if ( s_ret.empty() ) - s_ret = s_conf::get().get_val( "STARTMPL" ); + if ( s_ret.empty() ) + s_ret = s_conf::get + ().get_val( "STARTMPL" ); - map_params["request"] = s_ret; + map_params["request"] = s_ret; - return s_ret; + return s_ret; } string reqp::get_content_type( string s_file ) { - string s_ext=s_tool::getExtension( s_file ); + string s_ext=s_tool::getExtension( s_file ); - if(s_ext=="") - s_ext="DEFAULT"; + if(s_ext=="") + s_ext="DEFAULT"; - return s_conf::get().get_val( "CT_"+s_ext ); + return s_conf::get + ().get_val( "CT_"+s_ext ); } void reqp::parse_headers( string s_req, map_string &map_params ) { - int pos = s_req.find("\n"); - if(pos!=string::npos) - map_params["QUERY_STRING"]=s_tool::trim(s_req.substr(0,pos-1)); + int pos = s_req.find("\n"); + if(pos!=string::npos) + map_params["QUERY_STRING"]=s_tool::trim(s_req.substr(0,pos-1)); - while(pos!=string::npos) - { - auto string s_line=s_req.substr(0,pos); - auto int pos2=s_line.find(":"); - if(pos2!=string::npos) - { - auto string key=s_tool::trim(s_line.substr(0, pos2)); - auto string value=s_tool::trim(s_line.substr(pos2+1)); + while(pos!=string::npos) + { + auto string s_line=s_req.substr(0,pos); + auto int pos2=s_line.find(":"); + if(pos2!=string::npos) + { + auto string key=s_tool::trim(s_line.substr(0, pos2)); + auto string value=s_tool::trim(s_line.substr(pos2+1)); - map_params[key]=value; + map_params[key]=value; - } - s_req=s_req.substr(s_line.size()+1); - pos=s_req.find("\n"); - } + } + s_req=s_req.substr(s_line.size()+1); + pos=s_req.find("\n"); + } } @@ -157,135 +161,148 @@ reqp::parse_headers( string s_req, map_string &map_params ) int reqp::htoi(string *s) { - int value; - int c; - - c=s->c_str()[0]; - if(isupper(c)) - c=tolower(c); + int value; + int c; + + c=s->c_str()[0]; + if(isupper(c)) + c=tolower(c); - value=(c>='0' && c<='9'?c-'0':c-'a'+10)*16; + value=(c>='0' && c<='9'?c-'0':c-'a'+10)*16; - c=s->c_str()[1]; - if(isupper(c)) - c=tolower(c); + c=s->c_str()[1]; + if(isupper(c)) + c=tolower(c); - value+=c>='0' && c<='9'?c-'0':c-'a'+10; - return value; + value+=c>='0' && c<='9'?c-'0':c-'a'+10; + return value; } string reqp::url_decode( string s_str ) { - auto string sDest=""; - int len = s_str.size(); - - for(int i=0;i<len;i++) - { - char ch = s_str.at(i); - if(ch=='+') - { - sDest+=" "; - } - else if(ch=='%') - { - auto string sTmp=s_str.substr(i+1,2); - ch=(char)htoi(&sTmp); - sDest+=ch; - i+=2; - - } - else - - sDest+=ch; - } - return sDest; + auto string sDest=""; + int len = s_str.size(); + + for(int i=0;i<len;i++) + { + char ch = s_str.at(i); + if(ch=='+') + { + sDest+=" "; + } + else if(ch=='%') + { + auto string sTmp=s_str.substr(i+1,2); + ch=(char)htoi(&sTmp); + sDest+=ch; + i+=2; + + } + else + + sDest+=ch; + } + return sDest; } string reqp::get_from_header( string s_req, string s_hdr ) { - auto unsigned int pos[2]; - pos[0] = s_req.find( s_hdr, 0 ); - pos[1] = s_req.find( "\n", pos[0] ); + auto unsigned int pos[2]; + pos[0] = s_req.find( s_hdr, 0 ); + pos[1] = s_req.find( "\n", pos[0] ); - auto int i_length = s_hdr.length(); - return s_req.substr( pos[0]+i_length, pos[1]-pos[0]-i_length-1 ); + auto int i_length = s_hdr.length(); + return s_req.substr( pos[0]+i_length, pos[1]-pos[0]-i_length-1 ); } string reqp::parse( thrd* p_thrd, string s_req, map_string &map_params ) { - // store all request informations in map_params. store the url in - // map_params["request"]. - - if ( get_url( p_thrd, s_req, map_params ).compare("NOBYTE") == 0 ) - map_params["request"] = s_conf::get().get_val("NOTFOUND"); + // store all request informations in map_params. store the url in + // map_params["request"]. - parse_headers( s_req, map_params ); - // create the http header. - string s_rep( HTTP_CODEOK ); s_rep.append( HTTP_SERVER ); - s_rep.append( HTTP_CONTAC ); s_rep.append( HTTP_CACHEC ); - s_rep.append( HTTP_CONNEC ); s_rep.append( HTTP_COTYPE ); - s_rep.append( get_content_type( map_params["request"] ) ); - s_rep.append("\r\n\r\n"); + if ( get_url( p_thrd, s_req, map_params ).compare("NOBYTE") == 0 ) + map_params["request"] = s_conf::get + ().get_val("NOTFOUND"); - // check the event variable. + parse_headers( s_req, map_params ); + // create the http header. + string s_rep( HTTP_CODEOK ); + s_rep.append( HTTP_SERVER ); + s_rep.append( HTTP_CONTAC ); + s_rep.append( HTTP_CACHEC ); + s_rep.append( HTTP_CONNEC ); + s_rep.append( HTTP_COTYPE ); + s_rep.append( get_content_type( map_params["request"] ) ); + s_rep.append("\r\n\r\n"); - string s_event( map_params["event"] ); - if ( ! s_event.empty() ) - { - // login procedure. - if ( s_event == "login" ) - { - s_chat::get().login( map_params ); - } + // check the event variable. - else + string s_event( map_params["event"] ); + if ( ! s_event.empty() ) { - bool b_found; - -// user* p_user = s_chat::get().get_user( map_params["nick"], b_found ); - sess *sess_temp=s_sman::get().getSession( map_params["tmpid"] ); - user *p_user; - if(sess_temp!=NULL) - { - string *s_nick=static_cast<string*>(sess_temp->getValue(string("nick"))); - p_user = s_chat::get().get_user( *s_nick, b_found); - } - else - return s_rep; - if ( ! b_found ) - { - map_params["INFO"] = E_NOTONL; - map_params["request"] = s_conf::get().get_val( "STARTMPL" ); // redirect to the startpage. - } - // if a message post. - else if ( s_event == "post" ) - s_chat::get().post( p_user, map_params ); - - - // if a chat stream - else if ( s_event == "stream" ) - { - string s_msg(s_html::get().parse( map_params ) ); - p_user->msg_post( &s_msg); - s_sock::get().chat_stream( p_thrd->get_sock(), p_user, map_params ); - } - - // if a request for the online list of the active room. - else if ( s_event == "online" ) - s_html::get().online_list( p_user, map_params ); + // login procedure. + if ( s_event == "login" ) + { + s_chat::get + ().login( map_params ); + } + + else + { + bool b_found; + + // user* p_user = s_chat::get().get_user( map_params["nick"], b_found ); + sess *sess_temp=s_sman::get + ().getSession( map_params["tmpid"] ); + user *p_user; + if(sess_temp!=NULL) + { + string *s_nick=static_cast<string*>(sess_temp->getValue(string("nick"))); + p_user = s_chat::get + ().get_user( *s_nick, b_found); + } + else + return s_rep; + if ( ! b_found ) + { + map_params["INFO"] = E_NOTONL; + map_params["request"] = s_conf::get + ().get_val( "STARTMPL" ); // redirect to the startpage. + } + // if a message post. + else if ( s_event == "post" ) + s_chat::get + ().post( p_user, map_params ); + + + // if a chat stream + else if ( s_event == "stream" ) + { + string s_msg(s_html::get + ().parse( map_params ) ); + p_user->msg_post( &s_msg); + s_sock::get + ().chat_stream( p_thrd->get_sock(), p_user, map_params ); + } + + // if a request for the online list of the active room. + else if ( s_event == "online" ) + s_html::get + ().online_list( p_user, map_params ); + } } - } - // parse and get the requested html-template and also use - // the values stored in map_params for %%KEY%% substituations. - s_rep.append( s_html::get().parse( map_params ) ); + // parse and get the requested html-template and also use + // the values stored in map_params for %%KEY%% substituations. + s_rep.append( s_html::get + ().parse( map_params ) ); - // return the parsed html-template. - return s_rep; + // return the parsed html-template. + return s_rep; } #endif |