path: root/user.cpp

// class user implementation.

#ifndef USER_CXX
#define USER_CXX

#include "user.h"
#include "s_conf.h"
#include "s_modl.h"
#include "s_tool.h"

using namespace std;

user::user( string s_name ) : name( s_name )
{
    this -> b_online = true;
    this -> l_time   = s_tool::unixtime();
    this -> s_col1   = s_conf::get
                           ().get_val( "USERCOL1" );
    this -> s_col2   = s_conf::get
                           ().get_val( "USERCOL2" );
    map_mods = new hmap<dynmod*,string>(80);

    pthread_mutex_init( &mut_b_online, NULL);
    pthread_mutex_init( &mut_i_sock  , NULL);
    pthread_mutex_init( &mut_l_time  , NULL);
    pthread_mutex_init( &mut_p_room  , NULL);
    pthread_mutex_init( &mut_s_mess  , NULL);
    pthread_cond_init ( &cond_message, NULL);
    pthread_mutex_init( &mut_message , NULL);
    pthread_mutex_init( &mut_map_mods, NULL );
    pthread_mutex_init( &mut_s_col1, NULL );
    pthread_mutex_init( &mut_s_col2, NULL );
    pthread_mutex_init( &mut_s_id, NULL );
    pthread_mutex_init( &mut_r_rang, NULL );
}

user::~user()
{
    pthread_mutex_destroy( &mut_b_online );
    pthread_mutex_destroy( &mut_i_sock   );
    pthread_mutex_destroy( &mut_l_time   );
    pthread_mutex_destroy( &mut_p_room   );
    pthread_mutex_destroy( &mut_s_mess   );
    pthread_cond_destroy ( &cond_message );
    pthread_mutex_destroy( &mut_message  );
    pthread_mutex_destroy( &mut_s_col1   );
    pthread_mutex_destroy( &mut_s_col2   );
    pthread_mutex_destroy( &mut_s_id     );
    pthread_mutex_destroy( &mut_r_rang   );
}

string
user::get_colored_name()
{
 return "<font color=\"#" + get_col1() + "\">" + get_name() + "</font>";
}

void
user::get_data( map_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();
}

string
user::get_mess( )
{
    pthread_mutex_lock  ( &mut_s_mess );
    string s_ret = s_mess;
    s_mess = "";
    pthread_mutex_unlock( &mut_s_mess );
    return s_ret;
}

bool
user::get_online( )
{
    bool b_ret;
    pthread_mutex_lock  ( &mut_b_online );
    b_ret = b_online;
    pthread_mutex_unlock( &mut_b_online );
    return b_ret;
}

void
user::set_online( bool b_online )
{
    pthread_mutex_lock  ( &mut_b_online );
    this -> b_online = b_online;
    pthread_mutex_unlock( &mut_b_online );
}

room*
user::get_room( )
{
    room* p_return;
    pthread_mutex_lock  ( &mut_p_room );
    p_return = p_room;
    pthread_mutex_unlock( &mut_p_room );
    return p_return;
}

void
user::set_p_room( room* p_room )
{
    pthread_mutex_lock  ( &mut_p_room );
    this -> p_room = p_room;
    pthread_mutex_unlock( &mut_p_room );
}

int
user::get_sock( )
{
    int i_ret;
    pthread_mutex_lock  ( &mut_i_sock );
    i_ret = i_sock;
    pthread_mutex_unlock( &mut_i_sock );
    return i_ret;
}

void
user::set_sock( int i_sock )
{
    pthread_mutex_lock  ( &mut_i_sock );
    this -> i_sock = i_sock;
    pthread_mutex_unlock( &mut_i_sock );
}

string
user::get_col1()
{
    string s_ret;
    pthread_mutex_lock  ( &mut_s_col1 );
    s_ret = s_col1;
    pthread_mutex_unlock( &mut_s_col1 );
    return s_ret;
}

string
user::get_col2()
{
    string s_ret;
    pthread_mutex_lock  ( &mut_s_col2 );
    s_ret = s_col2;
    pthread_mutex_unlock( &mut_s_col2 );
    return s_ret;
}

string
user::get_id()
{
    string s_ret;
    pthread_mutex_lock  ( &mut_s_id );
    s_ret = s_id;
    pthread_mutex_unlock( &mut_s_id );
    return s_ret;
}

void
user::set_id    ( string s_id   )
{
    pthread_mutex_lock  ( &mut_s_id );
    this -> s_id = s_id;
    pthread_mutex_unlock( &mut_s_id );
}

void
user::set_col1  ( string s_col1 )
{
    pthread_mutex_lock  ( &mut_s_col1 );
    this -> s_col1 = s_col1;
    pthread_mutex_unlock( &mut_s_col1 );
}

void
user::set_col2  ( string s_col2 )
{
    pthread_mutex_lock  ( &mut_s_col2 );
    this -> s_col2 = s_col2;
    pthread_mutex_unlock( &mut_s_col2 );
}

rang
user::get_rang  ( )
{
    rang r_ret;
    pthread_mutex_lock  ( &mut_r_rang );
    r_ret = r_rang;
    pthread_mutex_unlock(&mut_r_rang );
    return  r_ret;
}

void
user::set_rang  ( rang   r_rang )
{
    pthread_mutex_lock  ( &mut_r_rang );
    r_oldr = this -> r_rang;
    this -> r_rang = r_rang;
    pthread_mutex_unlock( &mut_r_rang );
}

bool
user::new_msgs  ( )
{
    pthread_mutex_lock  ( &mut_s_mess );
    return s_mess.empty();
    pthread_mutex_unlock( &mut_s_mess );
}

void
user::command( string &s_command )
{

    auto unsigned int pos = s_command.find( "/" );
    auto unsigned int pos2 = s_command.find( " " );
    if( pos != string::npos )
    {
        s_command.replace( pos, 1, "" );
    }
    else
        return;


    if(pos2==string::npos)
        pos2=s_command.size()+1;

    string s_mod( "mods/commands/yc_" );
    string s_command2=s_command.substr(0, pos2-1);
    s_mod.append( s_command2  ).append( ".so" );

    dynmod *mod = s_modl::get
                      ().get_module( s_mod );

    if ( mod == NULL )
    {
        msg_post( new string( s_lang::get
                                  ().get_val( "ERRORCMD" ) ) );
        return;
    }

    vector<string> params;
    string *ptr_command;

    // execute the module.
    if(s_command.find(" ")!=string::npos)
    {
        s_command=s_command.substr(s_command2.size()+1);
        ptr_command=new string(s_command);

        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));

    }
    else
    {
        ptr_command=new string("");
    }

    container *c = new container;
    c->elem[0]=(void*) ptr_command;
    c->elem[1]=(void*) this;
    c->elem[2]=(void*) &params;
    c->elem[3]=(void*) &s_conf::get();

    ( *(mod->the_func) ) ( (void*) c );

}

void
user::renew_stamp( )
{
    pthread_mutex_lock  ( &mut_l_time );
    l_time = s_tool::unixtime();
    pthread_mutex_unlock( &mut_l_time );
}

void
user::msg_post( string *p_msg )
{
    pthread_mutex_lock  ( &mut_s_mess );
    s_mess.append( *p_msg );
    pthread_mutex_unlock( &mut_s_mess );

    pthread_cond_signal( &cond_message );
}

void
user::get_user_list( string &s_list, string &s_seperator )
{
    s_list.append( "<font color=\"" )
    .append( get_col1()       )
    .append( "\">"            )
    .append( get_name()       )
    .append( "</font>\n"      )
    .append( s_seperator      );

}
#endif