Merge remote-tracking branch 'remotes/github/0.5' into 0.50.5

1 files changed, 291 insertions, 0 deletions

diff --git a/reqp.cpp b/reqp.cpp
new file mode 100644
index 0000000..d02afb8
--- /dev/null
+++ b/reqp.cpp
@@ -0,0 +1,291 @@
+// class reqp implementation.
+
+#ifndef REQP_CXX
+#define REQP_CXX
+
+#include "reqp.h"
+#include "s_chat.h"
+#include "s_html.h"
+#include "s_mutx.h"
+#include "s_sock.h"
+#include "s_tool.h"
+using namespace std;
+
+// inititialization of static members.
+string reqp::HTTP_CODEOK = "HTTP/1.1 200 OK\n";
+string reqp::HTTP_SERVER = "Server: yChat (Unix)\n";
+string reqp::HTTP_CONTAC = "Contact: www.yChat.org\n";
+string reqp::HTTP_CACHEC = "Expires: 0\nCache-control: no-cache\nPragma: no-cache\n";
+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;
+
+ i_request= ( s_req.find("GET",0) != string::npos ) ? RQ_GET : RQ_POST;
+
+ 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 ( pos == string::npos )
+   break; 
+
+  s_ret.replace( pos, pos+2, "" );
+ }
+ while( true );
+
+ // 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);
+
+ 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 ) ); 
+
+  else
+   s_params = s_req.substr( pos+4, s_req.length() -pos-1 ); 
+
+  s_ret = s_ret.substr( 0, pos );
+ }
+
+ if ( i_request == RQ_POST && s_params.empty() )
+ {
+  char c_req[READBUF];
+
+  if ( read ( p_thrd->get_sock() , c_req, READBUF ) <= 0 )
+   return "NOBYTE";
+
+  s_params = string( strstr( c_req, "event" ) ); 
+ }
+
+ 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 );
+#endif
+
+ if ( s_ret.empty() )
+  s_ret = s_conf::get().get_val( "STARTMPL" );
+
+ map_params["request"] = s_ret;
+
+ return s_ret;
+}
+
+string
+reqp::get_content_type( string s_file )
+{
+	string s_ext=s_tool::getExtension( s_file );
+
+	if(s_ext=="")
+		s_ext="DEFAULT";	
+
+	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));
+
+        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;
+
+
+                }
+                s_req=s_req.substr(s_line.size()+1);
+                pos=s_req.find("\n");
+        }
+
+}
+
+
+int
+reqp::htoi(string *s)
+{
+	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;
+
+	c=s->c_str()[1];
+	if(isupper(c))
+		c=tolower(c);
+
+	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;
+}
+
+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 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");
+
+ 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");
+
+ // check the event variable.
+
+ string s_event( map_params["event"] );
+ if ( ! s_event.empty() )
+ {
+  // 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 ) );
+
+ // return the parsed html-template.
+ return  s_rep;
+}
+
+#endif