tagging ychat-0.7.4.1ychat-0.7.4.1

1 files changed, 156 insertions, 81 deletions

diff --git a/src/main.cpp b/src/main.cpp
index df882a5..26f11c9 100644..100755
--- a/src/main.cpp
+++ b/src/main.cpp
@@ -1,118 +1,193 @@
-/*:*
- *: File: ./src/main.cpp
- *: 
- *: yChat; Homepage: www.yChat.org; Version 0.8.3-CURRENT
- *: 
- *: Copyright (C) 2003 Paul C. Buetow, Volker Richter
- *: Copyright (C) 2005 EXA Digital Solutions GbR
- *: Copyright (C) 2004, 2006 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.
- *:*/
-
+/*
+ * yChat++; Contact: www.yChat.org; Mail@yChat.org
+ * Copyright (C) 2003 Paul C. Buetow, Volker Richter 
+ * Copyright (C) 2004, 2005 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 MAIN_CPP
+#define MAIN_CPP
+
+#include <unistd.h>
+#include <signal.h>
 #include "incl.h"
-#include "sign.h"
-
-#include "maps/hashmap.h"
 
+#ifndef NCURSES
 #ifdef CLI
 #include "cli/cli.h"
 #endif
+#endif
 
 using namespace std;
 
 map<string,string>*
 parse_argc( int argc, char* argv[] )
 {
-  map<string,string>* start_params = new map<string,string>;
+ map<string,string>* start_params = new map<string,string>;
 
-  string s_output = "";
+ string s_output = "";
 
-  // Set to 1 if a config option key has to be read
-  // ( ./ychat -o key1 value1 -o key2 value2 ... );
-  bool b_conf = 0;
+ // Set to 1 if a config option key has to be read
+ // ( ./ychat -o key1 value1 -o key2 value2 ... );
+ bool b_conf = 0;
 
-  // Will store the key of an additional option value (see also b_conf)
-  string s_key;
+ // Will store the key of an additional option value (see also b_conf)
+ string s_key;
 
-  for (int i=1; argv[i] != 0; i++)
+ for (int i=1; argv[i] != 0; i++)
+ {
+  if ( !s_key.empty() )
   {
-    if ( !s_key.empty() )
-    {
-      (*start_params)[s_key] = string(argv[i]);
-      s_key.clear();
-    }
-    else if ( b_conf )
-    {
-      s_key = string(argv[i]);
-      b_conf = 0;
-    }
-    else
-    {
-      if ( string(argv[i]).find("v") != string::npos )
-        s_output.append(tool::ychat_version()+"\n");
-
-      if ( string(argv[i]).find("h") != string::npos )
-        s_output.append( YCUSAGE );
-
-      if ( string(argv[i]).find("o") != string::npos )
-        b_conf = 1;
-    }
+   (*start_params)[s_key] = string(argv[i]);
+   s_key.clear();
   }
 
-  if ( !s_output.empty() )
+  else if ( b_conf )
   {
-    cout << s_output;
-    delete start_params;
-    exit(1);
+   s_key = string(argv[i]);
+   b_conf = 0;
   }
 
-  return start_params;
+  else
+  {
+   if ( string(argv[i]).find("v") != string::npos )
+    s_output.append(tool::ychat_version()+"\n");
+
+   if ( string(argv[i]).find("h") != string::npos )
+    s_output.append( YCUSAGE );
+
+   if ( string(argv[i]).find("o") != string::npos )
+    b_conf = 1;
+  }
+ }
+
+ if ( !s_output.empty() )
+ {
+  cout << s_output;
+  delete start_params;
+  exit(1);
+ }
+
+ return start_params;
 }
 
 int
 main(int argc, char* argv[])
 {
-  cout << tool::ychat_version() << endl
-  << DESCRIP << endl
-  << DESCRI2 << endl
-  << DESCRI3 << endl
-  << CONTACT << endl
-  << SEPERAT << endl;
+ map<string,string>* p_start_params = parse_argc( argc, argv );
 
-  wrap::init_wrapper(parse_argc(argc, argv));
+    cout << tool::ychat_version() << endl 
+         << DESCRIP << endl
+    	 << DESCRI2 << endl
+         << CONTACT << endl
+         << SEPERAT << endl;
 
-  //<<*
-  // Initialize database connection queue
-#ifdef DATABASE
+    // ignore SIGPIPE. otherwise the server will shut down with "Broken pipe" if
+    // a client unexpected disconnects himself from a SOCK_STREAM.
+    signal( SIGPIPE, SIG_IGN );
+
+    // all the static data classes have to be initialized once. otherwise they will
+    // contain only empty pointers and the chat server won't work correctly.
+    // the order of the initializations is very importand. for example the s_html::init()
+    // invokations assumes an initialized s_conf class.
+    // begin to draw the ncurses amdin interface in a new pthread.
+
+    // init the dynamic wrapper (is needed to pass all wrapped objects through a single pointer).
+    wrap::WRAP = new dynamic_wrap;
+
+    // init the config manager.
+    wrap::WRAP->CONF = wrap::CONF = new conf( CONFILE, p_start_params ); 
+    delete p_start_params,
 
-  wrap::DATA->init_connections();
+
+   // init the statistic manager.
+    wrap::WRAP->STAT = wrap::STAT = new stats; 
+
+    // init the html-template manager.
+    wrap::WRAP->HTML = wrap::HTML = new html; 
+
+#ifdef LOGGING
+    // init the system message logd 
+    wrap::WRAP->LOGD = wrap::LOGD = new logd( wrap::CONF->get_elem("httpd.logging.systemfile"),
+                                              wrap::CONF->get_elem("httpd.logging.systemlines") );
 #endif
-  //*>>
+    //<<*
+    // init the session manager.
+    wrap::WRAP->SMAN = wrap::SMAN = new sman; 
+    //*>>
+    
+
+    // init the socket manager.
+    wrap::WRAP->SOCK = wrap::SOCK = new sock; 
 
-  sign::init_signal_handlers();
+#ifdef NCURSES
+    wrap::WRAP->NCUR = wrap::NCUR = new ncur; 	// init the ncurses admin interface.
+    wrap::NCUR->run();				// run the thread
 
+    // wait until ncurses interface has been initialized.
+    while ( ! wrap::NCUR->is_ready() )
+     usleep(1000);
+
+    wrap::HTML->print_cached(0);
+#endif
+
+    //<<*
+    // init the chat manager.
+    wrap::WRAP->CHAT = wrap::CHAT = new chat; 
+    //*>>
+
+    // init the system timer.
+    wrap::WRAP->TIMR = wrap::TIMR = new timr; 
+    wrap::TIMR->run(); // run the thread
+
+    //<<*
+    // init the module-loader manager.
+    wrap::WRAP->MODL = wrap::MODL = new modl; 
+
+    // init the garbage collector 
+    wrap::WRAP->GCOL = wrap::GCOL = new gcol; 
+
+    // init the data manager. 
+#ifdef DATABASE
+    wrap::WRAP->DATA = wrap::DATA = new data; 
+#endif
+    //*>>
+
+#ifndef NCURSES
 #ifdef CLI
-  cli _cli;
-  _cli.run();
+    cli* p_cli = new cli;
+    p_cli->run();
+#endif
+#endif
+
+    //<<*	
+    // Initialize database connection queue
+#ifdef DATABASE
+    wrap::DATA->initialize_connections();
 #endif
+    //*>>
 
-  // start the socket manager. this one will listen for incoming http requests and will
-  // forward them to the specified routines which will generate a http response.
-  wrap::SOCK->start();
+    // start the socket manager. this one will listen for incoming http requests and will
+    // forward them to the specified routines which will generate a http response.
+    wrap::SOCK->start();
 
-  cout << DOWNMSG << endl;
-  return 0;
+    cout << DOWNMSG << endl;
+    return 0;
 }
+
+#endif