moved stuff the trunk

1 files changed, 182 insertions, 0 deletions

diff --git a/src/reqp.cpp b/src/reqp.cpp
new file mode 100644
index 0000000..fbf794f
--- /dev/null
+++ b/src/reqp.cpp
@@ -0,0 +1,182 @@
+/*:*
+ *: File: ./src/reqp.cpp
+ *: 
+ *: yChat; Homepage: ychat.buetow.org; Version 0.9.0-CURRENT
+ *: 
+ *: Copyright (C) 2003 Paul C. Buetow, Volker Richter
+ *: Copyright (C) 2004 Paul C. Buetow
+ *: Copyright (C) 2005 EXA Digital Solutions GbR
+ *: Copyright (C) 2006, 2007 Paul C. Buetow
+ *: 
+ *: This program is free software; you can redistribute it and/or
+ *: modify it under the terms of the GNU General Public License
+ *: as published by the Free Software Foundation; either version 2
+ *: of the License, or (at your option) any later version.
+ *: 
+ *: This program is distributed in the hope that it will be useful,
+ *: but WITHOUT ANY WARRANTY; without even the implied warranty of
+ *: MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ *: GNU General Public License for more details.
+ *: 
+ *: You should have received a copy of the GNU General Public License
+ *: along with this program; if not, write to the Free Software
+ *: Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
+ *:*/
+
+#ifndef REQP_CPP
+#define REQP_CPP
+
+#include "reqp.h"
+#include "tool/tool.h"
+
+using namespace std;
+
+#define HEADER HEADER1 HEADER2 HEADER3 HEADER4 HEADER9
+#define STREAM HEADER5 HEADER6
+
+const string reqp::s_http = HEADER;
+const string reqp::s_http_stream = STREAM;
+const string reqp::s_http_colength = HEADER7;
+const string reqp::s_http_cotype = HEADER8;
+const string reqp::s_http_cotype_add = HEADER8b;
+
+reqp::reqp( )
+{}
+
+void
+reqp::parse(context *p_context)
+{
+  map<string, string> &map_params = *p_context->p_map_params;
+
+  string *p_response = p_context->p_response;
+  string &s_event = map_params["event"];
+
+  //<<*
+  // check the event variable.
+  if ( ! s_event.empty() )
+  {
+    // login procedure.
+    if ( s_event == "login" )
+    {
+      wrap::CHAT->login( map_params );
+    }
+    else if ( s_event == "register" )
+    {
+      user* p_user = new user;
+      map_params["INFO"] = "";
+      run_html_mod( s_event, map_params, p_user );
+      wrap::GCOL->add_user_to_garbage( p_user );
+    }
+    else
+    {
+      sess *p_sess = wrap::SMAN->get_session( map_params["tmpid"] );
+      user *p_user = NULL;
+
+      if ( p_sess != NULL )
+      {
+        p_user = p_sess->get_user();
+      }
+      else
+      {
+        wrap::system_message(SESSERR);
+        return;
+      }
+
+      if ( ! p_user )
+      {
+        map_params["INFO"]    = wrap::CONF->get_elem( "chat.msgs.err.notonline" );
+        map_params["request"] = wrap::CONF->get_elem( "httpd.startsite" ); // redirect to the startpage.
+      }
+      else
+      {
+        map_params["nick"] = p_user->get_name().c_str();
+
+        // if a message input.
+        if ( s_event == "input" )
+        {
+          if ( p_user )
+          {
+            p_user->check_restore_away();
+            wrap::CHAT->post( p_user, map_params );
+          }
+        }
+
+        // if a chat stream
+        else if ( s_event == "stream" )
+        {
+          /*
+          string s_resp(s_http+s_http_stream);
+          s_resp.append(s_http_colength + tool::int2string(s_response.size()) + "\r\n" +
+               s_http_cotype + map_params["content-type"]
+                // + s_http_cotype_add
+          	 + "\r\n\r\n" );*/
+          /*		  string s_resp("");
+                    s_resp.append(wrap::HTML->parse(map_params));
+          		  p_user->set_context(p_context);
+          		  */
+          map_params["KEEP_ALIVE"] = "yes";
+          return;
+        }
+
+        // if a request for the online list of the active room.
+        else if ( s_event == "online" )
+        {
+          wrap::HTML->online_list( p_user, map_params );
+        }
+        else //if ( s_event != "input" )
+        {
+          run_html_mod( s_event, map_params, p_user );
+        }
+      }
+    }
+  }
+
+  if ( wrap::CONF->get_elem("httpd.enablecgi").compare("true") == 0 &&
+       string::npos != map_params["request"].find(".cgi") )
+  {
+    p_response->append( tool::shell_command(
+                          wrap::CONF->get_elem("httpd.templatedir") + map_params["request"],
+                          METH_RETSTRING ) );
+  }
+  else
+  {
+    // parse and get the requested html-template and also use
+    // the values stored in map_params for %%KEY%% substituations.
+    p_response->append( wrap::HTML->parse( map_params ) );
+  }
+
+  // create the http header if not a stream
+//  if ( s_event.compare("stream") != 0 ) {
+  string s_resp("");
+  s_resp.append(s_http);
+  //s_resp.append( s_http_stream );
+  s_resp.append( s_http_colength + tool::int2string(p_response->size()) + "\r\n" +
+                 s_http_cotype + map_params["content-type"] +
+                 s_http_cotype_add + "\r\n" );
+
+  s_resp.append(*p_response);
+// }
+}
+
+//<<*
+void
+reqp::run_html_mod( string s_event, map<string,string> &map_params, user* p_user )
+{
+  container *c = new container;
+
+  c->elem[0] = (void*) wrap::WRAP;
+  c->elem[1] = (void*) &map_params;
+  c->elem[2] = (void*) p_user;
+
+  string s_mod = wrap::CONF->get_elem("httpd.modules.htmldir") + "yc_" + s_event + ".so";
+
+  dynmod* p_module = wrap::MODL->get_module( s_mod, p_user->get_name() );
+
+  if ( p_module != NULL )
+    ( *( p_module->the_func ) ) ( static_cast<void*>(c) );
+
+  delete c;
+}
+//*>>
+
+#endif