diff options
Diffstat (limited to '0.8/src/chat')
| -rw-r--r-- | 0.8/src/chat/base.h | 120 | ||||
| -rw-r--r-- | 0.8/src/chat/base.tmpl | 89 | ||||
| -rw-r--r-- | 0.8/src/chat/chat.cpp | 438 | ||||
| -rw-r--r-- | 0.8/src/chat/chat.h | 94 | ||||
| -rw-r--r-- | 0.8/src/chat/gcol.cpp | 146 | ||||
| -rw-r--r-- | 0.8/src/chat/gcol.h | 62 | ||||
| -rw-r--r-- | 0.8/src/chat/perm.cpp | 108 | ||||
| -rw-r--r-- | 0.8/src/chat/perm.h | 67 | ||||
| -rw-r--r-- | 0.8/src/chat/room.cpp | 133 | ||||
| -rw-r--r-- | 0.8/src/chat/room.h | 116 | ||||
| -rw-r--r-- | 0.8/src/chat/sess.cpp | 91 | ||||
| -rw-r--r-- | 0.8/src/chat/sess.h | 56 | ||||
| -rw-r--r-- | 0.8/src/chat/sman.cpp | 133 | ||||
| -rw-r--r-- | 0.8/src/chat/sman.h | 60 | ||||
| -rw-r--r-- | 0.8/src/chat/user.cpp | 650 | ||||
| -rw-r--r-- | 0.8/src/chat/user.h | 166 |
16 files changed, 2529 insertions, 0 deletions
diff --git a/0.8/src/chat/base.h b/0.8/src/chat/base.h new file mode 100644 index 0000000..bba37e0 --- /dev/null +++ b/0.8/src/chat/base.h @@ -0,0 +1,120 @@ +/*:* + *: File: ./src/chat/base.h + *: + *: 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. + *:*/ + +#include "../incl.h" + +#ifndef BASE_H +#define BASE_H + +#include <map> +#include "../maps/nhashmap.h" + +template<class type> +class base : public nhashmap<type*> +{ +protected: + void dumpit(); + +public: + base(); + ~base(); + + static string to_lower( string s ) + { + string s_tmp(""); + for (int i=0;i < s.size() ;i++) + s_tmp=s_tmp+(char)tolower(s.at(i)); + return s_tmp; + } + + virtual type* get_elem( string s_name, bool &b_found ); // get a element. + virtual type* get_elem( string s_name ); + virtual void add_elem( type* p_type ); // add a element. + + // chat::msg_post sends to all users of the system a message. + // room::msg_post sends to all users of the room a message. + // user::msg_post sends to the user a message. + virtual void msg_post( string *s_msg ) + { + nhashmap<type*>::run_func( &base<type>::msg_post_ , (void*)s_msg ); + } + + static void msg_post_( type* type_obj, void* v_arg ) + { + type_obj -> msg_post( (string*) v_arg ); + } + + virtual void check_timeout( int* i_timeout_settings ) + { + nhashmap<type*>::run_func( &base<type>::check_timeout_ , (void*)i_timeout_settings ); + } + + static void check_timeout_( type* type_obj, void* v_arg ) + { + type_obj -> check_timeout( (int*) v_arg ); + } + + virtual void reconf() + { + nhashmap<type*>::run_func( &base<type>::reconf_ ); + } + + static void reconf_ ( type* type_obj ) + { + type_obj -> reconf (); + } + + void get_data( map<string,string> *p_map_string ) + { + nhashmap<type*>::run_func( &base<type>::get_data_ , (void*)p_map_string ); + } + + static void get_data_( type* type_obj, void* v_arg ) + { + type_obj -> get_data ( (map<string,string>*) v_arg ); + } + + + // chat::get_user_list gets a list of all users of the system. + // room::get_user_list gets a list of all users of the room. + // user::get_user_list gets a "list" of a user <font color="usercolor">username</font>seperator + void get_user_list( string &s_list ) + { + container c; + c.elem[0] = (void*) &s_list; + + nhashmap<type*>::run_func( &base<type>::get_user_list_, (void*)&c ); + } + + static void get_user_list_( type* type_obj, void* v_arg ) + { + container *c = (container*) v_arg; + type_obj -> get_user_list( *((string*)c->elem[0]) ); + } +}; + +#include "base.tmpl" + +#endif diff --git a/0.8/src/chat/base.tmpl b/0.8/src/chat/base.tmpl new file mode 100644 index 0000000..9b1d682 --- /dev/null +++ b/0.8/src/chat/base.tmpl @@ -0,0 +1,89 @@ +/*:* + *: File: ./src/chat/base.tmpl + *: + *: 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 BASE_CPP +#define BASE_CPP + +#include "base.h" + +template<class type> +base<type>::base() +{} + +template<class type> +base<type>::~base( ) +{} + +template<class type> +type* +base<type>::get_elem( string s_name, bool &b_found ) +{ + s_name = to_lower(s_name); + type* p_type = nhashmap<type*>::get_elem( s_name ); + b_found = p_type == NULL ? false : true; + return p_type; +} + +template<class type> +type* +base<type>::get_elem( string s_name) +{ + bool b; + return get_elem(s_name, b); +} + +template<class type> +void +base<type>::add_elem( type* p_type ) +{ + nhashmap<type*>::add_elem(p_type, p_type->get_lowercase_name()); +} + +template<class type> +void +base<type>::dumpit() +{ + dumpable::add + ("[base]"); + vector<string>* p_vec = nhashmap<type*>::get_key_vector(); + + vector<string>::iterator iter; + for (iter = p_vec->begin(); iter != p_vec->end(); ++iter) + { + dumpable::add + (*iter); + type* p_elem = get_elem(*iter); + if (p_elem) + { + dumpable::next_no_newline(); + dumpable::add + (p_elem->dump(dumpable::get_level())); + } + } + + delete p_vec; +} + +#endif diff --git a/0.8/src/chat/chat.cpp b/0.8/src/chat/chat.cpp new file mode 100644 index 0000000..cea9ab6 --- /dev/null +++ b/0.8/src/chat/chat.cpp @@ -0,0 +1,438 @@ +/*:* + *: File: ./src/chat/chat.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. + *:*/ + +// class chat implementation. + +#ifndef CHAT_CPP +#define CHAT_CPP + +#include "chat.h" +#include "../tool/tool.h" +#include "../maps/mtools.h" +#include <list> + +using namespace std; + +chat::chat( ) +{ + { + // Set up replace strings; + wrap::system_message(CHATREP); + vector<string>* p_vec_keys = wrap::CONF->get_key_vector(); + + for (vector<string>::iterator iter = p_vec_keys-> + begin(); + iter != p_vec_keys->end(); + iter++ ) + { + if ( iter->length() >= 24 && iter->compare( 0, 22, "chat.html.replace.from" ) == 0 ) + { + string s_from = wrap::CONF->get_elem(*iter); + map_replace_strings[s_from] = "chat.html.replace.into." + s_from; + vec_replace_keys.push_back(s_from); + } + } + + sort(vec_replace_keys.begin(), vec_replace_keys.end()); + delete p_vec_keys; + } +} + +chat::~chat( ) +{ + // Delete all room objects! + run_func( mtools<room*>::delete_obj ); +} + +user* +chat::get_user( string &s_user ) +{ + bool b_flag; + return get_user( s_user, b_flag ); +} + +user* +chat::get_user( string &s_user, bool &b_found ) +{ + container param; + + param.elem[0] = (void*) &s_user ; + param.elem[1] = (void*) &b_found; + + b_found = false; + + base<room>::run_func( get_user_, (void*)¶m ); + + if ( *( (bool*) param.elem[1] ) ) + return (user*) param.elem[2]; +} + +void +chat::get_user_( room *room_obj, void *v_arg ) +{ + container* param = (container*) v_arg; + + if ( *((bool*)param->elem[1]) ) + return; + + param->elem[2] = (void*)room_obj->get_elem( *((string*)param->elem[0]), *((bool*)param->elem[1]) ); +} + +void +chat::login( map<string,string> &map_params ) +{ + string s_user = map_params["nick"]; + + // prove if nick is empty: + if ( s_user.empty() ) + { + map_params["INFO"] = wrap::CONF->get_elem( "chat.msgs.err.nonick" ); + map_params["request"] = wrap::CONF->get_elem( "httpd.startsite" ); // redirect to the startpage. + wrap::system_message( LOGINE0 ); + return; + } + + // prove if the nick is alphanumeric: + else if ( ! tool::is_alpha_numeric( s_user ) ) + { + map_params["INFO"] = wrap::CONF->get_elem( "chat.msgs.err.alpnum" ); + map_params["request"] = wrap::CONF->get_elem( "httpd.startsite" ); // redirect to the startpage. + wrap::system_message( LOGINE1 + s_user ); + return; + } + + // prove if the nick is too long: + else if ( s_user.length() > tool::string2int( wrap::CONF->get_elem("chat.maxlength.username") ) ) + { + map_params["INFO"] = wrap::CONF->get_elem( "chat.msgs.err.nicklength" ); + map_params["request"] = wrap::CONF->get_elem( "httpd.startsite" ); // redirect to the startpage. + wrap::system_message( LOGINE2 + s_user ); + return; + } + + // prove if the room name is too long: + else if ( map_params["room"].length() > tool::string2int( wrap::CONF->get_elem("chat.maxlength.roomname") ) ) + { + map_params["INFO"] = wrap::CONF->get_elem( "chat.msgs.err.roomnamelength" ); + map_params["request"] = wrap::CONF->get_elem( "httpd.startsite" ); // redirect to the startpage. + wrap::system_message( LOGINE3 + s_user + " / " + map_params["room"] ); + return; + } + + // prove if the room name is valid + else if ( map_params["room"].length() < 1 ) + { + map_params["INFO"] = wrap::CONF->get_elem( "chat.msgs.err.noroom" ); + map_params["request"] = wrap::CONF->get_elem( "httpd.startsite" ); // redirect to the startpage. + wrap::system_message( LOGINE3 + s_user + " / " + map_params["room"] ); + return; + } + + // prove if nick is banned from chat + if (map_banned_nicks.exists(tool::to_lower(s_user))) + { + map_params["INFO"] = wrap::CONF->get_elem( "chat.msgs.err.banned" ); + map_params["request"] = wrap::CONF->get_elem( "httpd.startsite" ); + return; + } + + bool b_flag; + + // prove if nick is already online / logged in. + get_user( s_user, b_flag ); + + if ( b_flag ) + { + map_params["INFO"] = wrap::CONF->get_elem( "chat.msgs.err.online" ); + map_params["request"] = wrap::CONF->get_elem( "httpd.startsite" ); + return; + } + + // Prove if user is recycleable from the garbage collector: + user *p_user = wrap::GCOL->get_user_from_garbage( s_user ); + + if ( p_user != NULL ) + { + // 1. possibility to prove the password at login! (using recycled user) + if ( p_user->get_pass() != map_params["password"] ) + { + map_params["INFO"] = wrap::CONF->get_elem( "chat.msgs.err.wrongpassword" ); + map_params["request"] = wrap::CONF->get_elem( "httpd.startsite" ); // redirect to the startpage. + wrap::system_message( LOGINER + s_user ); + return; + } + + if ( p_user->get_has_sess() ) + { + map_params["tmpid"] = p_user->get_tmpid(); + } + + else + { + sess* p_sess = wrap::SMAN->create_session(); + p_sess->set_user(p_user); + map_params["tmpid"] = p_sess->get_tmpid(); + p_user->set_tmpid( map_params["tmpid"] ); + p_user->set_has_sess( true ); + } + } + else // if ( p_user == NULL ) // If not in garbage create a new user! + { + p_user = new user( s_user ); + + // prove if nick is registered, else create a guest chatter. +#ifdef DATABASE + + hashmap<string> map_results = wrap::DATA->select_user_data( tool::to_lower(s_user), "selectlogin"); + + if ( map_results["nick"] == tool::to_lower(s_user) ) + { + p_user->set_is_reg( true ); + // User exists in database, prove password: + // 2. possibility to prove the password at login! (using new created user from database) + if ( map_results["password"] != map_params["password"] ) + { + map_params["INFO"] = wrap::CONF->get_elem( "chat.msgs.err.wrongpassword" ); + map_params["request"] = wrap::CONF->get_elem( "httpd.startsite" ); // redirect to the startpage. + wrap::system_message( LOGINER + s_user ); + return; + } + else + { + // If registered use saved options + map_params["registered"] = "yes"; + map_params["color1"] = map_results["color1"]; + map_params["color2"] = map_results["color2"]; + map_params["email"] = map_results["email"]; + map_params["status"] = map_results["status"]; + } + } + else +#endif + + { + // If not registered prove if guest chatting is enabled. + if (wrap::CONF->get_elem("chat.enableguest") != "true") + { + map_params["INFO"] = wrap::CONF->get_elem( "chat.msgs.err.noguest" ); + map_params["request"] = wrap::CONF->get_elem( "httpd.startsite" ); // redirect to the startpage. + wrap::system_message( LOGINE4 + s_user ); + return; + } + + // Guest chatter are enabled, use standard font colors + map_params["color1"] = wrap::CONF->get_elem( "chat.html.user.color1" ); + map_params["color2"] = wrap::CONF->get_elem( "chat.html.user.color2" ); + map_params["status"] = wrap::CONF->get_elem( "chat.defaultrang" ); + } + + sess* p_sess = wrap::SMAN->create_session(); + p_sess->set_user(p_user); + map_params["tmpid"] = p_sess->get_tmpid(); + p_user->set_tmpid( map_params["tmpid"] ); + p_user->set_col1( map_params["color1"] ); + p_user->set_col2( map_params["color2"] ); + p_user->set_status( tool::string2int(map_params["status"])); + } + + // Prove if user is the default operator. + if ( tool::to_lower(wrap::CONF->get_elem("chat.defaultop")) == tool::to_lower(s_user) ) + { + wrap::system_message(CHATDOP); + p_user->set_status(0); + } + + string s_room = map_params["room"]; + room* p_room = get_room( s_room , b_flag ); + + // if room does not exist add room to list! + if ( ! b_flag ) + { + p_room = wrap::GCOL->get_room_from_garbage(); + + if ( p_room ) + { + p_room->set_name( s_room ); + wrap::system_message( REUROOM + s_room ); + } + else + { + p_room = new room( s_room ); + wrap::system_message( NEWROOM + s_room ); + } + + add_elem( p_room ); + } + + // add user to the room. + p_room->add_user( p_user ); + + wrap::system_message( NEWUSER + s_user ); + + // post "username enters the chat" into the room. + string s_msg = wrap::TIMR->get_time() + " " + p_user->get_colored_bold_name() + wrap::CONF->get_elem( "chat.msgs.userenterschat" ) + "<br>\n"; + + // If created a new user from database while logging on (not a recycled user, they already have this set) + if ( map_params["registered"] == "yes" ) + { + p_user->set_email( map_params["email"] ); + p_user->set_pass( map_params["password"] ); + // Now we will store all wanted user data into MySQL after logging out! (recycled user already have this set) + p_user->set_changed_data_on(); + } + p_room->msg_post(&s_msg); +} + +void +chat::post( user* p_user, map<string,string> &map_params ) +{ + p_user->renew_timeout(); + + string s_msg( map_params["message"] ); + + if ( s_msg.empty() ) + return; + + int i_max_message_length = tool::string2int(wrap::CONF->get_elem( "chat.maxlength.message" )); + if ( s_msg.length() > i_max_message_length ) + { + s_msg = s_msg.substr( 0, i_max_message_length ); + string s_private = "<font color=\"" + wrap::CONF->get_elem( "chat.html.errorcolor" ) + "\">" + + wrap::CONF->get_elem( "chat.msgs.err.messagelength" ) + "</font><br>\n"; + p_user->msg_post( &s_private ); + } + + int i_max_word_length = tool::string2int(wrap::CONF->get_elem( "chat.maxlength.word" )); + + // Check max word length + list<string> list_msg = tool::split_string( s_msg, " "); + list<string>::iterator iter = list_msg.begin(); + + for ( s_msg = ""; iter != list_msg.end(); ++iter ) + { + if ( iter->length() > i_max_word_length ) + { + string s_tmp[] = { iter->substr(0, i_max_word_length ), iter->substr(i_max_word_length) }; + iter = list_msg.erase( iter ); + iter = list_msg.insert( iter, s_tmp[1] ); + iter = list_msg.insert( iter, s_tmp[0] ); + --iter; + } + else + { + s_msg.append(*iter + " "); + } + } + + if ( wrap::CONF->get_elem( "chat.html.tagsallow" ) != "true" ) + tool::strip_html( &s_msg ); + + unsigned i_pos = s_msg.find( "/" ); + if ( i_pos == 0 ) + return p_user->command( s_msg ); + + if (p_user->get_is_gag()) + { + p_user->msg_post(wrap::CONF->colored_error_msg("chat.msgs.err.gagged")); + return; + } + + + string_replacer(&s_msg); + string s_post; + + if ( wrap::CONF->get_elem( "chat.printalwaystime" ) == "true" ) + s_post.append( wrap::TIMR->get_time() + " " ); + + s_post.append( "<font color=\"#" ) + .append( p_user->get_col1() ) + .append( "\">" ) + .append( p_user->get_name() ) + .append( ":</font> <font color=\"#") + .append( p_user->get_col2() ) + .append( "\">" ) + .append( s_msg ) + .append( "</font><br>\n" ); + + p_user->get_room()->msg_post( &s_post ); +} + +void +chat::reconf() +{} + +void +chat::string_replacer(string *p_msg) +{ + if ( wrap::CONF->get_elem( "chat.html.replace.activate" ) == "true" ) + { + for (vector<string>::iterator iter = vec_replace_keys.end()-1; + iter != vec_replace_keys.begin(); + iter-- ) + *p_msg = tool::replace( *p_msg, *iter, wrap::CONF->get_elem(map_replace_strings[*iter]) ); + } +} + +void +chat::dumpit() +{ + dumpable::add + ("[chat]"); + base<room>::dumpit(); +} + +string +chat::ban_nick(string &s_nick, string s_reason) +{ + string s_lower_nick(tool::to_lower(s_nick)); + + if (map_banned_nicks.exists(s_lower_nick)) + return map_banned_nicks.get_elem(s_lower_nick); + + map_banned_nicks.add_elem(s_reason, s_lower_nick); + return ""; +} + +string +chat::unban_nick(string &s_nick) +{ + string s_lower_nick(tool::to_lower(s_nick)); + + if (!map_banned_nicks.exists(s_lower_nick)) + return ""; + + string s_ret(map_banned_nicks.get_elem(s_lower_nick)); + map_banned_nicks.del_elem(s_lower_nick); + + return s_ret; +} + +shashmap<string>* +chat::get_map_banned_nicks() +{ + return &map_banned_nicks; +} + +#endif diff --git a/0.8/src/chat/chat.h b/0.8/src/chat/chat.h new file mode 100644 index 0000000..edc5270 --- /dev/null +++ b/0.8/src/chat/chat.h @@ -0,0 +1,94 @@ +/*:* + *: File: ./src/chat/chat.h + *: + *: 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. + *:*/ + +// class chat declaration. + +class chat; + +#ifndef CHAT_H +#define CHAT_H + +#include <vector> +#include "../incl.h" +#include "base.h" +#include "perm.h" +#include "room.h" +#include "user.h" +#include "sess.h" +#include "../tool/tool.h" +#include "../maps/shashmap.h" + +using namespace std; + +#undef chat +class chat : public base<room>, public perm +{ +private: + map<string,string> map_replace_strings; + vector<string> vec_replace_keys; + shashmap<string> map_banned_nicks; + shashmap<string, unsigned, self_hash<unsigned>, equals_allocator<unsigned> > map_banned_ips; + + void dumpit(); + +public: + virtual room* get_room( string s_name ) + { + bool b_bool; + return get_room( s_name, b_bool ); + } + + virtual room* get_room( string &s_name, bool &b_found ) + { + return static_cast<room*>( get_elem( s_name, b_found ) ); + } + + void del_elem( string s_name ) + { + base<room>::del_elem( s_name ); + } + + // public methods: + explicit chat(); // a standard constructor. + ~chat(); // destructor. + + // get the object of a specific user. + user* get_user( string &s_nick ); + user* get_user( string &s_nick, bool &b_found ); + static void get_user_( room* room_obj, void *v_arg ); + + // will be called every time a user tries to login. + void login( map<string,string> &map_params ); + + // will be called if a user posts a message. + void post ( user* u_user, map<string,string> &map_params ); + + void reconf(); + void string_replacer(string *p_msg); + string ban_nick(string &s_nick, string s_reason); + string unban_nick(string &s_nick); + shashmap<string>* get_map_banned_nicks(); +}; +#endif diff --git a/0.8/src/chat/gcol.cpp b/0.8/src/chat/gcol.cpp new file mode 100644 index 0000000..dddb01d --- /dev/null +++ b/0.8/src/chat/gcol.cpp @@ -0,0 +1,146 @@ +/*:* + *: File: ./src/chat/gcol.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 GCOL_CPP +#define GCOL_CPP + +#include "gcol.h" + +using namespace std; + +gcol::gcol() +{ + + p_map_users = new shashmap<user*>; + wrap::system_message( GARBAGE ); +} + +gcol::~gcol() +{ + remove_garbage(); + delete p_map_users; +} + +void +gcol::add_room_to_garbage( room* p_room ) +{ + vec_rooms.push_back( p_room ); + wrap::system_message( GARROOM + p_room->get_name() ); +} + +void +gcol::add_user_to_garbage( user* p_user ) +{ + p_user->destroy_session(); + p_map_users->add_elem(p_user, tool::to_lower(p_user->get_name())); + wrap::system_message(GARUSER + p_user->get_name()); +} + +bool +gcol::remove_garbage() +{ + bool b_empty; + + b_empty = ( vec_rooms.empty() && p_map_users->size() == 0); + + if ( b_empty ) + return false; + + wrap::system_message( GARBACT ); + + for ( vector<room*>::iterator iter = vec_rooms.begin(); + iter != vec_rooms.end(); iter++ ) + { + wrap::system_message( REMROOM + (*iter)->get_name() ); + delete *iter; + } + vec_rooms.clear(); + + + p_map_users->run_func( delete_users_ ); + p_map_users->clear(); + + return true; +} + +room* +gcol::get_room_from_garbage() +{ + + if ( vec_rooms.empty() ) + return NULL; + + room* p_room = vec_rooms.back(); + vec_rooms.pop_back(); + + return p_room; +} + +room* +gcol::get_room_from_garbage_or_new( string s_room ) +{ + room* p_room = get_room_from_garbage(); + if ( p_room == NULL ) + return new room( s_room ); + p_room->set_name( s_room ); + return p_room; +} + +user* +gcol::get_user_from_garbage( string s_user ) +{ + user* p_user = p_map_users->get_elem(tool::to_lower(s_user)); + + if ( p_user != NULL ) + { + p_map_users->del_elem(tool::to_lower(s_user)); + p_user->set_name(s_user); + p_user->set_online(true); + p_user->set_invisible(false); + p_user->set_sock(NULL); + p_user->renew_timeout(); + wrap::system_message(GARUSE2 + p_user->get_name()); + } + + return p_user; +} + +void +gcol::delete_users_( user *user_obj ) +{ + wrap::system_message( REMUSER + user_obj->get_name() ); + user_obj->clean(); + delete user_obj; +} + +void +gcol::lock_mutex() +{} + +void +gcol::unlock_mutex() +{} + +#endif diff --git a/0.8/src/chat/gcol.h b/0.8/src/chat/gcol.h new file mode 100644 index 0000000..710fc5f --- /dev/null +++ b/0.8/src/chat/gcol.h @@ -0,0 +1,62 @@ +/*:* + *: File: ./src/chat/gcol.h + *: + *: 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. + *:*/ + +// garbage collector +#include "../incl.h" + +#ifndef GCOL_H +#define GCOL_H + +#include <vector> +#include "room.h" +#include "user.h" +#include "../maps/shashmap.h" + +using namespace std; + +class gcol +{ +private: + vector<room*> vec_rooms; + shashmap<user*>* p_map_users; + + + static void delete_users_( user* user_obj ); + +public: + gcol(); + ~gcol(); + + bool remove_garbage(); + void add_room_to_garbage( room* p_room ); + void add_user_to_garbage( user* p_user ); + virtual room* get_room_from_garbage(); + virtual room* get_room_from_garbage_or_new( string s_room ); + user* get_user_from_garbage( string s_user ); + virtual void lock_mutex(); + virtual void unlock_mutex(); +}; + +#endif diff --git a/0.8/src/chat/perm.cpp b/0.8/src/chat/perm.cpp new file mode 100644 index 0000000..8adb83f --- /dev/null +++ b/0.8/src/chat/perm.cpp @@ -0,0 +1,108 @@ +/*:* + *: File: ./src/chat/perm.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 PERM_CPP +#define PERM_CPP + +#include "perm.h" +#include "../maps/mtools.h" + +using namespace std; + +perm::perm() +{ + p_command_status = new shashmap< valwrap<int>* >; + p_command_disabled = new shashmap< valwrap<bool>* >; + + set_standard_command_permissions(); +} + +perm::~perm() +{ + p_command_status->run_func( &mtools< valwrap<int>* >::delete_obj ); + p_command_disabled->run_func( &mtools< valwrap<bool>* >::delete_obj ); + + delete p_command_status; + delete p_command_disabled; +} + +int +perm::get_command_status( string s_command ) +{ + if ( p_command_status->exists( s_command ) ) + return p_command_status->get_elem( s_command )->val; + + return 0; +} + +void +perm::set_command_status( string s_command, int i_int ) +{ + valwrap<int>* p_val = p_command_status->get_set_elem( new valwrap<int>(i_int), s_command ); + + if ( p_val ) + delete p_val; +} + +bool +perm::get_command_disabled( string s_command ) +{ + if ( p_command_disabled->exists( s_command ) ) + return p_command_disabled->get_elem( s_command )->val; + return 0; +} + +void +perm::set_command_disabled( string s_command, bool b_bool ) +{ + valwrap<bool>* p_val = p_command_disabled->get_set_elem( new valwrap<bool>(b_bool), s_command ); + + if ( p_val ) + delete p_val; +} + +void +perm::set_standard_command_permissions() +{ + wrap::system_message(PERMSTD); + + vector<string>* p_vec_keys = wrap::CONF->get_key_vector(); + + for (vector<string>::iterator iter = p_vec_keys-> + begin(); + iter != p_vec_keys->end(); + iter++ ) + { + if ( iter->length() > 17 && iter->compare( 0, 16, "chat.permissions" ) == 0 ) + { + valwrap<int>* p_val = new valwrap<int>( tool::string2int( wrap::CONF->get_elem(*iter) ) ); + p_command_status->add_elem( p_val, iter->substr(17) ); + } + } + + delete p_vec_keys; +} + +#endif diff --git a/0.8/src/chat/perm.h b/0.8/src/chat/perm.h new file mode 100644 index 0000000..bac038e --- /dev/null +++ b/0.8/src/chat/perm.h @@ -0,0 +1,67 @@ +/*:* + *: File: ./src/chat/perm.h + *: + *: 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. + *:*/ + +#include "../incl.h" +#include "../maps/shashmap.h" + +#ifndef PERM_H +#define PERM_H + +using namespace std; + +template<class type_> +struct valwrap +{ + type_ val; + valwrap(type_ i) + { + val = i; + } + + type_ get_val() + { + return val; + } +}; + +class perm +{ +private: + shashmap< valwrap<int>* >* p_command_status; + shashmap< valwrap<bool>* >* p_command_disabled; + + void set_standard_command_permissions(); + +public: + perm( ); + ~perm( ); + + virtual int get_command_status( string s_command ); + virtual bool get_command_disabled( string s_command ); + virtual void set_command_status( string s_command, int i_int ); + virtual void set_command_disabled( string s_command, bool b_bool ); +}; + +#endif diff --git a/0.8/src/chat/room.cpp b/0.8/src/chat/room.cpp new file mode 100644 index 0000000..39177e7 --- /dev/null +++ b/0.8/src/chat/room.cpp @@ -0,0 +1,133 @@ +/*:* + *: File: ./src/chat/room.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 ROOM_CPP +#define ROOM_CPP + +#include "room.h" +#include "../maps/mtools.h" + +using namespace std; + +room::room( string s_name ) : name( s_name ) +{ +#ifdef LOGGING + + p_logd = new logd( wrap::CONF->get_elem("chat.logging.roomlogdir") + get_lowercase_name(), + wrap::CONF->get_elem("chat.logging.roomloglines") ); +#endif + + wrap::STAT->increment_num_rooms(); +} + +room::~room() +{ + wrap::STAT->decrement_num_rooms(); + + // Delete all user objects + run_func( mtools<user*>::delete_obj ); + +#ifdef LOGGING + + delete p_logd; +#endif + +} + +string +room::get_topic() +{ + string s_ret; + s_ret = s_topic; + return s_ret; +} + +void +room::set_topic( string s_topic ) +{ + if ( s_topic == "" ) + this->s_topic = ""; + else + this->s_topic = s_topic + "<br><br>"; + reload_onlineframe(); +} + +void +room::set_topic( string s_topic, string s_color ) +{ + set_topic( "<font color=\"#" + s_color + "\">" + s_topic + "</font>"); +} + +void +room::clean_room() +{ + this->s_topic = ""; + wrap::CHAT->del_elem( get_lowercase_name() ); + wrap::GCOL->add_room_to_garbage( this ); +} + +void +room::reload_onlineframe() +{ + javascript_post("parent.online.location.reload();"); +} + +void +room::set_name( string s_name ) +{ + if ( tool::to_lower(s_name) == get_lowercase_name() ) + { + name::set_name( s_name ); + return; + } + +#ifdef LOGGING + p_logd->flush_logs(); +#endif + + if ( s_name == "" ) + return; + + name::set_name( s_name ); +#ifdef LOGGING + + p_logd->set_logfile( wrap::CONF->get_elem("chat.logging.roomlogdir"), get_lowercase_name() ); +#endif +} + +void +room::dumpit() +{ + dumpable::add + ("[room]"); + dumpable::add + ("Name: "+get_name()); + dumpable::add + ("Topic: "+get_topic()); + base<user>::dumpit(); +} + + +#endif diff --git a/0.8/src/chat/room.h b/0.8/src/chat/room.h new file mode 100644 index 0000000..035633a --- /dev/null +++ b/0.8/src/chat/room.h @@ -0,0 +1,116 @@ +/*:* + *: File: ./src/chat/room.h + *: + *: 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. + *:*/ + +// class room declaration. + +#include "../incl.h" +#include "../wrap.h" + +#ifndef ROOM_H +#define ROOM_H + +#include "base.h" +#include "../name.h" +#include "user.h" +#include "../tool/tool.h" +#include "../logd.h" + +using namespace std; + +class room : public base<user>, public name +{ +private: + string s_topic; +#ifdef LOGGING + + logd* p_logd; +#endif + + void dumpit(); + +public: + room( string s_name ); + ~room(); + + virtual void reload_onlineframe(); + + void add_user( user* p_user ) + { + add_elem( p_user ); + p_user->set_p_room( this ); + reload_onlineframe(); + } + + user* get_user( string &s_name, bool &b_found ) + { + return static_cast<user*>( get_elem( s_name, b_found ) ); + } + + void del_elem( string &s_name ) + { + base<user>::del_elem( s_name ); + + if ( base<user>::size() == 0 ) + clean_room(); + + else + reload_onlineframe(); + } + + void msg_post( string s_msg ) + { + msg_post( &s_msg ); + } + + void msg_post( string *p_msg ) + { +#ifdef LOGGING + p_logd->log_simple_line( logd::remove_html_tags(*p_msg) ); +#endif + base<user>::msg_post( p_msg ); + } + + void javascript_post( string s_msg ) + { + string s_js = "<script language=\"JavaScript\">"+s_msg+"</script>\n"; + base<user>::msg_post( &s_js ); + } + + string get_bold_name() + { + return "<b>" + get_name() + "</b>"; + } + + virtual void set_name( string s_name ); + string get_topic(); + void set_topic( string s_topic ); + void set_topic( string s_topic, string s_color ); + void clean_room(); + + + +}; + +#endif diff --git a/0.8/src/chat/sess.cpp b/0.8/src/chat/sess.cpp new file mode 100644 index 0000000..9ba5636 --- /dev/null +++ b/0.8/src/chat/sess.cpp @@ -0,0 +1,91 @@ +/*:* + *: File: ./src/chat/sess.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 SESS_CPP +#define SESS_CPP + +#include "sess.h" + +sess::sess( string s_tmpid ) +{ + this->p_user = NULL; + this->s_tmpid = s_tmpid; +} + +sess::~sess() +{} + +string +sess::get_tmpid() +{ + return s_tmpid; +} + +void +sess::set_tmpid(string s_tmpid) +{ + this->s_tmpid = s_tmpid; +} + +string +sess::get_name() +{ + if ( p_user = NULL ) + return ""; + + return p_user->get_name(); +} + +void +sess::set_name(string s_name) +{ + if ( p_user != NULL ) + p_user->set_name(s_name); +} + +user* +sess::get_user() +{ + return p_user; +} + +void +sess::set_user(user* p_user) +{ + this->p_user = p_user; + //p_user->set_sess(this); +} + +/* +void +sess::invalidate() +{ + set_user(NULL); + set_tmpid("!invalidated"); + wrap::system_message(SESSIOI); +} +*/ + +#endif diff --git a/0.8/src/chat/sess.h b/0.8/src/chat/sess.h new file mode 100644 index 0000000..d4e099f --- /dev/null +++ b/0.8/src/chat/sess.h @@ -0,0 +1,56 @@ +/*:* + *: File: ./src/chat/sess.h + *: + *: 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. + *:*/ + +#include "../incl.h" + +#ifndef SESS_H +#define SESS_H + +#include <string> +#include "user.h" + +class cont; + +using namespace std; + +class sess +{ +private: + string s_tmpid; + user *p_user; + +public: + sess(string s_tmpid); + ~sess(); + + string get_tmpid(); + void set_tmpid(string s_tmpid); + void set_user(user* p_user); + user* get_user(); + void set_name(string s_name); + string get_name(); + void invalidate(); +}; +#endif diff --git a/0.8/src/chat/sman.cpp b/0.8/src/chat/sman.cpp new file mode 100644 index 0000000..8026497 --- /dev/null +++ b/0.8/src/chat/sman.cpp @@ -0,0 +1,133 @@ +/*:* + *: File: ./src/chat/sman.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 SMAN_CPP +#define SMAN_CPP + +#include "sman.h" +#include "../tool/tool.h" +#include "../maps/mtools.h" +#include "../contrib/crypt/md5.h" + +sman::sman() +{ + i_continous_session_count = i_session_count = 0; +} + +sman::~sman() +{ + // Delete each session object of the shashmap! + shashmap<sess*>::run_func( mtools<sess*>::delete_obj ); +} + +string sman::generate_id( int i_len ) +{ + string s_valid = wrap::CONF->get_elem("chat.session.validchars"); + string s_ret = ""; + + srand(time(0)+tool::string2int(wrap::CONF->get_elem("chat.session.kloakkey"))); + int i_char; + + + for (int i = 0; i < i_len; i++) + { + i_char = rand() % s_valid.length(); + s_ret += s_valid[i_char]; + } + + if ( wrap::CONF->get_elem("chat.session.md5hash") == "true" ) + { + string s_salt = wrap::CONF->get_elem("chat.session.md5salt"); + string s_hash(md5::MD5Crypt(s_ret.c_str(), s_salt.c_str())); + s_ret.append(s_hash.substr(s_ret.find(s_salt) + s_salt.length() + 3)); + } + + // Prove, if the TempID already exists + sess* p_sess = get_elem(s_ret); + + if (p_sess) + { + wrap::system_message(SESSEXI); + return generate_id(i_len); + } + + return s_ret; +} + +sess *sman::create_session( ) +{ + string s_tmpid = generate_id( tool::string2int( wrap::CONF->get_elem( "chat.session.length" ) ) ); + + sess* p_sess = new sess( s_tmpid ); + + i_session_count++; + wrap::system_message(string(SESSIOC) + "(" + + tool::int2string(++i_continous_session_count) + "," + + tool::long2string((long)p_sess) + ")" ); + + + //???? + add_elem( p_sess, s_tmpid ); + + return p_sess; +} + +sess *sman::get_session( string s_id ) +{ + return get_elem( s_id ); +} + +void +sman::destroy_session( string s_id ) +{ + sess* p_sess = get_elem(s_id); + + i_session_count--; + + wrap::system_message(string(SESSIOD) + "(" + + tool::int2string(i_continous_session_count) + "," + + tool::long2string((long)p_sess) + ")" ); + + + del_elem(s_id); + delete p_sess; +} + +int +sman::get_session_count() +{ + int i_ret = i_session_count; + return i_ret; +} + +/* +void +sman::dump() { + shashmap<sess*>::dump(); + cout << "BLA" << endl; +} +*/ + +#endif diff --git a/0.8/src/chat/sman.h b/0.8/src/chat/sman.h new file mode 100644 index 0000000..b8aff57 --- /dev/null +++ b/0.8/src/chat/sman.h @@ -0,0 +1,60 @@ +/*:* + *: File: ./src/chat/sman.h + *: + *: 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. + *:*/ + +#include "../incl.h" + +#ifndef SMAN_H +#define SMAN_H + +#include <cstdlib> + +#include "sess.h" +#include "../maps/shashmap.h" +#include "../monitor/dump.h" + +using namespace std; + +class sman : public shashmap<sess*> +{ +private: + string generate_id( int i_len ); + int i_session_count; + int i_continous_session_count; + + +public: + sman(); + ~sman(); + sess *get_session( string s_tmpid ); + int get_session_count( ); + sess *create_session( ); + void destroy_session( string s_tmpid ); + + //virtual void dump(); +}; + + +#endif + diff --git a/0.8/src/chat/user.cpp b/0.8/src/chat/user.cpp new file mode 100644 index 0000000..80f4c65 --- /dev/null +++ b/0.8/src/chat/user.cpp @@ -0,0 +1,650 @@ +/*:* + *: File: ./src/chat/user.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 USER_CPP +#define USER_CPP + +#include "user.h" +#include "../tool/tool.h" + +using namespace std; + +#include <errno.h> + +user::user() : name( "" ) +{ + initialize(); +} + +user::user( string s_name ) : name( s_name ) +{ + initialize(); +} + +user::~user() +{} + +void +user::initialize() +{ + time(&t_flood_time); + init_strings(wrap::CONF->get_vector("chat.fields.userstrings")); + init_ints(wrap::CONF->get_vector("chat.fields.userints")); + init_bools(wrap::CONF->get_vector("chat.fields.userbools")); + + this -> l_messages_recv = 0; + this -> p_sock = NULL; + this -> p_room = NULL; + this -> s_msg = ""; + this -> b_is_reg = false; + this -> b_is_gag = false; + this -> b_set_changed_data = false; + this -> b_away = false; + this -> b_fake = false; + this -> b_invisible = false; + this -> s_col1 = wrap::CONF->get_elem( "chat.html.user.color1" ); + this -> s_col2 = wrap::CONF->get_elem( "chat.html.user.color2" ); + + renew_timeout(); +} + +void +user::clean() +{ + destroy_session(); + set_fake(false); + set_invisible(false); + set_away(false, ""); + set_sock(NULL); +} + +void +user::destroy_session() +{ + if ( !get_has_sess() ) + return; + +#ifdef DATABASE + // Store all changed data into the mysql table if this user is registered: + if ( b_is_reg ) + wrap::DATA->update_user_data( get_name(), "savechangednick", + map_changed_data ); +#endif + + set_has_sess(false); + wrap::SMAN->destroy_session(get_tmpid()); + //wrap::system_message(tool::int2string(reinterpret_cast<int>(*p_sess))); + set_tmpid(""); +} + +string +user::get_colored_name() +{ + return "<font color=\"#" + get_col1() + "\">" + get_name() + "</font>"; +} + +void +user::get_data( map<string,string> *p_map_data ) +{ + string s_req = (*p_map_data)["!get"]; + + // get the nick and the color of the user. + if ( s_req == "nick" ) + (*p_map_data)[get_name()] = get_col1(); +} + +bool +user::get_online( ) +{ + return b_online; +} + +bool +user::get_fake( ) +{ + return b_fake; +} + +bool +user::get_invisible( ) +{ + return b_invisible; +} + +bool +user::get_has_sess( ) +{ + return b_has_sess; +} + +void +user::set_has_sess(bool b_has_sess) +{ + this->b_has_sess = b_has_sess; +} + +bool +user::get_is_reg( ) +{ + return b_is_reg; +} + +bool +user::get_is_gag( ) +{ + return b_is_gag; +} + +void +user::set_is_reg( bool b_is_reg ) +{ + this -> b_is_reg = b_is_reg; +} + +void +user::set_is_gag( bool b_is_gag ) +{ + this -> b_is_gag = b_is_gag; +} + +void +user::set_online( bool b_online ) +{ + if (this->b_online == b_online) + return; + + this -> b_online = b_online; + if (!b_online) + { + cout << "SETTING OFFLINE" << endl; + // remove the user from its room. + string s_user(get_name()); + string s_user_lowercase(get_lowercase_name()); + + room* p_room = get_room(); + p_room->del_elem(s_user_lowercase); + + // post the room that the user has left the chat. + string s_msg = wrap::TIMR->get_time() + " " + + get_colored_bold_name() + + wrap::CONF->get_elem( "chat.msgs.userleaveschat" ) + + "<br>\n"; + + p_room->msg_post( &s_msg ); + p_room->reload_onlineframe(); + +#ifdef VERBOSE + cout << REMUSER << s_user << endl; +#endif + + wrap::GCOL->add_user_to_garbage(this); + } +} + +void +user::set_fake( bool b_fake ) +{ + this -> b_fake = b_fake; +} + +void +user::set_invisible( bool b_invisible ) +{ + this -> b_invisible = b_invisible; +} + +bool +user::get_away() +{ + bool b_ret; + b_ret = b_away; + return b_ret; +} + +string +user::get_away_msg() +{ + string s_ret; + s_ret = s_away; + return s_ret; +} + +void +user::set_away( bool b_away, string s_away ) +{ + this -> b_away = b_away; + this -> s_away = s_away; +} + +void +user::set_away( bool b_away ) +{ + this -> b_away = b_away; +} + +room* +user::get_room( ) +{ + room* p_return; + p_return = p_room; + return p_return; +} + +void +user::set_p_room( room* p_room ) +{ + this -> p_room = p_room; +} + +/* +void +user::set_sess( sess** p_sess ) +{ + this -> p_sess = p_sess; +} +*/ + +string +user::get_pass() +{ + string s_ret; + s_ret = s_pass; + return s_ret; +} + +string +user::get_col1() +{ + string s_ret; + s_ret = s_col1; + return s_ret; +} + +string +user::get_col2() +{ + string s_ret; + s_ret = s_col2; + return s_ret; +} + +string +user::get_email() +{ + string s_ret; + s_ret = s_email; + return s_ret; +} + +string +user::get_tmpid() +{ + string s_ret; + s_ret = s_tmpid; + return s_ret; +} + +void +user::set_tmpid ( string s_tmpid ) +{ + this -> s_tmpid = s_tmpid; +} + +void +user::set_pass ( string s_pass ) +{ + set_changed_data( "password", s_pass ); + this -> s_pass = s_pass; +} + +void +user::set_col1 ( string s_col1 ) +{ + set_changed_data( "color1", s_col1 ); + this -> s_col1 = s_col1; +} + +void +user::set_col2 ( string s_col2 ) +{ + set_changed_data( "color2", s_col2 ); + this -> s_col2 = s_col2; +} + +void +user::set_email ( string s_email ) +{ + set_changed_data( "email", s_email ); + this -> s_email = s_email; +} + +int +user::get_status ( ) +{ + int r_ret; + r_ret = i_status; + return r_ret; +} + +void +user::set_status ( int i_status ) +{ + set_changed_data( "status", tool::int2string(i_status)); + i_old_status = this -> i_status; + this -> i_status = i_status; +} + +void +user::set_changed_data( string s_varname, string s_value ) +{ + if ( b_set_changed_data ) + { + map_changed_data[s_varname] = s_value; + } +} + +void +user::command( string &s_command ) +{ + check_restore_away(); + + unsigned long pos = s_command.find( "/" ); + unsigned long pos2 = s_command.find( " " ); + if ( pos != (unsigned long) string::npos ) + { + s_command.replace( pos, 1, "" ); + } + else + return; + + if (pos2 == string::npos) + pos2 = s_command.size() + 1; + + string s_mod( wrap::CONF->get_elem("httpd.modules.commandsdir") + "yc_" ); + string s_command2 = s_command.substr(0, pos2-1); + s_mod.append( s_command2 ).append( ".so" ); + + dynmod *mod = wrap::MODL->get_module( s_mod, get_name() ); + + if ( mod == NULL || + wrap::CHAT->get_command_disabled( s_command2 ) || + get_status() > wrap::CHAT->get_command_status( s_command2 ) ) + { + string s_msg = "<font color=\"" + wrap::CONF->get_elem("chat.html.errorcolor") + "\">" + + wrap::CONF->get_elem( "chat.msgs.err.findingcommand" ) + + "</font>\n"; + msg_post( &s_msg ); + return; + } + + vector<string> params; + + // execute the module. + if (s_command.find(" ") != string::npos) + { + s_command = s_command.substr(s_command2.size()+1); + pos = s_command.find(" "); + pos2 = 0; + + while (pos != string::npos) + { + string sParam = s_command.substr(pos2, pos - pos2); + params.push_back(sParam); + pos2 = pos + 1; + pos = s_command.find(" ", pos2); + } + + if (pos2 < s_command.size()) + { + params.push_back(s_command.substr(pos2, s_command.size()-pos2)); + } + + } + + container* c = new container; + //c->elem[0]=(void*) unreserved + c->elem[1] = (void*) this; + c->elem[2] = (void*) ¶ms; + c->elem[3] = (void*) wrap::WRAP; + + ( *(mod->the_func) ) ( static_cast<void*>(c) ); + + delete c; +} + +void +user::set_sock(_socket* p_sock) +{ + this->p_sock = p_sock; +} + +void +user::msg_post( string *p_msg ) +{ + /* + ++l_messages_recv; + if (p_sock == NULL) { + s_msg.append(*p_msg); + return; + + } + else if (!s_msg.empty()) + { + wrap::SOCK->_send(p_sock, s_msg.c_str(), s_msg.size() ); + s_msg.clear(); + } + + if ( 0 > wrap::SOCK->_send(p_sock, p_msg->c_str(), p_msg->size() ) ) { + cout << "psock: " << (int) p_sock << endl; + set_online( false ); + */ +} +/* + void + sock::handle_client_write(int i_fd, short event, void *p_arg) { + static int i_char_size = sizeof(char); + + context *p_context = static_cast<context*>(p_arg); + string *p_response = p_context->p_response; + + if (-1 == write(i_fd, p_response->c_str(), p_response->length()*i_char_size)) + { + switch (errno) { + case EAGAIN: + case EINTR: + event_add(p_context->p_event, NULL); + return; + } + } + + delete p_context; + } +*/ + +void +user::post_action_msg(string s_msgkey) +{ + get_room()->msg_post(wrap::TIMR->get_time()+" "+get_colored_bold_name()+wrap::CONF->get_elem(s_msgkey)+"<br>\n"); +} + +void +user::renew_timeout() +{ + timo::renew_timeout(); + double d_time_diff = wrap::TIMR->get_time_diff(t_flood_time); + + if (d_time_diff < static_cast<double>(wrap::CONF->get_int("chat.floodprotection.seconds")) + ) + { + if (++i_flood_messages > static_cast<double>(wrap::CONF->get_int("chat.floodprotection.messages")) + ) + { + room* p_room = get_room(); + if (p_room == 0) + { + i_flood_messages = 0; + return; + } + + wrap::system_message(CHATFLO+get_name()+","+p_room->get_name()+","+tool::int2string(i_flood_messages)+")"); + msg_post(wrap::CONF->colored_error_msg("chat.msgs.err.flooding")); + if (!get_is_gag()) + { + set_is_gag(true); + post_action_msg("chat.msgs.floodgag"); + } + } + } + + else + { + time(&t_flood_time); + i_flood_messages = 0; + } +} + +void +user::check_timeout( int* i_idle_timeout ) +{ + double d_user_timeout = get_last_activity(); + if ( get_away() ? i_idle_timeout[1] <= d_user_timeout : i_idle_timeout[0] <= d_user_timeout ) + { + wrap::system_message( string(TIMERTO) + "(" + get_name() + "," + tool::int2string((int)d_user_timeout) + ")"); + string s_quit = "<script language=JavaScript>top.location.href='/" + + wrap::CONF->get_elem("httpd.startsite") + + "';</script>"; + msg_post( &s_quit ); + set_online( false ); + + } + else if ( ! get_away() && i_idle_timeout[2] <= d_user_timeout ) + { + wrap::system_message( string(TIMERAT) + "(" + get_name() + "," + tool::int2string((int)d_user_timeout) + ")"); + string s_msg = wrap::CONF->get_elem("chat.msgs.userautoawaytimeout"); + set_away( true, s_msg ); + string s_msg2 = wrap::TIMR->get_time() + " <b>" + get_colored_name()+ "</b>" + s_msg + "<br>\n"; + get_room()->msg_post( &s_msg2 ); + get_room()->reload_onlineframe(); + } +} + +void +user::get_user_list( string &s_list ) +{ + if ( get_invisible() ) + return; + + s_list.append( wrap::CONF->get_elem("chat.html.onlinebefore") ); + + if ( get_away() ) + { + s_list.append("<img src=\"" + wrap::CONF->get_elem("chat.html.rangimages.location")+ "away.gif\"" ) + .append( " alt='" ) + .append( get_away_msg() ) + .append( "' title='" ) + .append( get_away_msg() ) + .append( "'" + wrap::CONF->get_elem("chat.html.rangimages.options") + "> " ); + } + else if ( ! get_is_reg() ) + { + string s_msgs = wrap::CONF->get_elem("chat.msgs.guest"); + s_list.append("<img src=\"" + wrap::CONF->get_elem("chat.html.rangimages.location")+ "guest.png\"" ) + .append( " alt='" ) + .append( s_msgs ) + .append( "' title='" ) + .append( s_msgs ) + .append( "'" + wrap::CONF->get_elem("chat.html.rangimages.options") + "> " ); + } + else if ( get_status() != tool::string2int( wrap::CONF->get_elem("chat.defaultrang") ) && ! get_fake() ) + { + string s_status = "rang" + tool::int2string( get_status() ); + string s_msgs = wrap::CONF->get_elem( "chat.msgs." + s_status ); + s_list.append("<img src=\"" + wrap::CONF->get_elem("chat.html.rangimages.location") + tool::to_lower(s_status) + ".png\"" ) + .append( " alt='" ) + .append( s_msgs ) + .append( "' title='" ) + .append( s_msgs ) + .append( "'" + wrap::CONF->get_elem("chat.html.rangimages.options") + "> " ); + } + else + { + s_list.append("<img src=\"images/blank.gif\"" + wrap::CONF->get_elem("chat.html.rangimages.options") + "> "); + } + + s_list.append( get_colored_name() ); + s_list.append( wrap::CONF->get_elem("chat.html.onlinebehind") ); + s_list.append( "\n" ); +} + +void +user::check_restore_away() +{ + if ( get_away() ) + { + get_room()->msg_post( + new string( + wrap::TIMR->get_time() + + " <b>" + get_colored_name() + + "</b> " + wrap::CONF->get_elem( "chat.msgs.unsetmodeaway" ) + + "( <font color=" + get_col2() + ">" + + get_away_msg() + "</font>)<br>\n" + ) + ); + set_away( false ); + get_room()->reload_onlineframe(); + } +} + +void +user::reconf() +{} + +void +user::dumpit() +{ + dumpable::add + ("[user]"); + dumpable::add + ("Name: " + get_name() + + "; Room: " + get_room()->get_name() + + "; Status: " + tool::int2string(get_status())); + dumpable::add + ("TempID: " + get_tmpid()); +} + +bool +user::same_rooms(user *p_user) +{ + return p_user->get_room()->get_lowercase_name() + .compare(this->get_room()->get_lowercase_name()) == 0; +} + +string +user::make_colors(string s_msg) +{ + return "<font color=\"#" + get_col1() + "\">" + s_msg + "</font>"; +} + +#endif diff --git a/0.8/src/chat/user.h b/0.8/src/chat/user.h new file mode 100644 index 0000000..1369067 --- /dev/null +++ b/0.8/src/chat/user.h @@ -0,0 +1,166 @@ +/*:* + *: File: ./src/chat/user.h + *: + *: 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. + *:*/ + +#include "../incl.h" + +#ifndef USER_H +#define USER_H + +#include "../name.h" +#include "../time/timo.h" +#include "../memb/memb.h" +#include "../monitor/dump.h" + +using namespace std; + +class room; +//class sess; + +class user : + public name, + public timo, + public dumpable, + public memb_base +{ +private: + + // private members: + _socket *p_sock; + string s_msg; + bool b_online; // true if user is online. + bool b_has_sess; // true if user already has a session! + bool b_is_reg; // true if user is registered + bool b_is_gag; // true if user is gagged + bool b_away; // true if user is away. + bool b_fake; // true if user hides his status logo (does not work for guest) + bool b_invisible; // true if user hides his status logo (does not work for guest) + bool b_set_changed_data; // Only set change data if required! + + int i_status; // user's rang ( see enum rang @ globals.h ). + int i_old_status; // user's previous status. + int i_flood_messages; // user's message posts (needed for flood protection, does not need to be syncronized) + time_t t_flood_time; // user's time count (needed for flood protection, does not need to be syncronized) + long l_messages_recv; + + string s_tmpid; + string s_agnt; // user's http user agent. + string s_away; // user's last away message. + string s_col1; // user's nick color. + string s_col2; // user's text color. + string s_email; // user's email addres + string s_pass; // password + room* p_room; // pointer to the user's room. + + hashmap<string> map_changed_data; // Needed to tell yChat which data to change after user is removed! + + void initialize(); + void set_changed_data( string s_varname, string s_value ); + void dumpit(); + +public: + + user(); + user(string s_name); + ~user(); + + void clean(); + void destroy_session(); + + // gets specific data of this user und stores it in + // (*p_map<string,string>)["nick"]. this method will be used + // every time data has to be got from every user of a room + // or even of the system. + void get_data( map<string,string> *p_map_data ); + + string get_colored_name(); + string get_colored_bold_name() + { + return "<b>" + get_colored_name() + "</b>"; + } + void msg_clear() + { + s_msg.clear(); + } + bool get_online(); + bool get_fake(); + bool get_invisible(); + bool get_has_sess(); + bool get_is_reg(); + bool get_is_gag(); + void set_online( bool b_online ); + void set_sock(_socket *p_sock); + void set_fake( bool b_fake ); + void set_invisible( bool b_invisible ); + void set_has_sess( bool b_has_sess ); + void set_is_reg( bool b_is_reg ); + void set_is_gag( bool b_is_gag ); + void set_changed_data_on() + { + b_set_changed_data = 1; + } + bool get_away( ); + string get_away_msg( ); + void set_away( bool b_away, string s_away ); + void set_away( bool b_away ); + room* get_room(); + void set_p_room( room* p_room ); + // void set_sess(sess** p_sess); + string get_pass(); + string get_col1(); + string get_col2(); + string get_email(); + string get_tmpid(); + void set_tmpid( string s_tmpid ); + void set_pass( string s_col1 ); + void set_col1( string s_col1 ); + void set_col2( string s_col2 ); + void set_email( string s_email ); + int get_status( ); + void set_status( int i_status ); + void set_messages_recv( long l ) + { + l_messages_recv = l; + } + void post_action_msg(string s_msgkey); + void check_timeout( int* i_idle_timeout ); + void renew_timeout(); + + // executes a command. + void command( string &s_command ); + + + void msg_post( string s_msg ) + { + msg_post( &s_msg ); + } + void msg_post( string *p_msg ); + void get_user_list( string &s_list ); + void check_restore_away(); + void reconf(); + bool same_rooms(user *p_user); + string make_colors(string s_msg); +}; + +#endif |