xoonips/AL/commonal.cc

/*
 * 
 * $Revision: 1.5 $
 * $Log: commonal.cc,v $
 * Revision 1.5  2004/11/26 01:08:25  aga
 * ??ddSlashes()篏???.
 *
 * Revision 1.4  2004/11/25 12:14:29  youi
 * getUid????????絎?臂?????.
 *
 * Revision 1.3  2004/11/25 11:13:59  youi
 * getLastErrorString/setLastErrorString??絎?臂?
 *
 * Revision 1.2  2004/11/25 08:55:19  youi
 * 綣??違??????篆??.
 * freeResult??菴遵??.
 *
 * Revision 1.1  2004/11/25 05:14:58  youi
 * initial version
 *
 * 
 */

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <mysql.h>
#include <string>

#include "common.h"
#include "account.h"
#include "group.h"
#include "session.h"
#include "criteria.h"
#include "commonal.h"

static MYSQL* mysql = NULL; //!< MySQL????潟????/span>

/** 
 * 
 * php??ddslashes????????
 * 
 * @param addslashes???鴻????絖?????NULL??絎?筝?????
 * @return addslashes????????絖???
 */
string addSlashes( const char *str )
{
        int len = strlen(str);
        char *buf = new char[len*2+1];
        int bufLen = mysql_real_escape_string( mysql, buf, str, len );
        string s( buf, bufLen );
        return s;
}


/**
 * 
 * ???若?帥???若?鴻????????
 * 
 * @param host ???若?帥???若?鴻?????鴻????
 * @param user ???若?帥???若?鴻???≪???祉?鴻???????若?九??
 * @param password 筝?荐????若?吟?????鴻???若??
 * @param dbname ???若?帥???若?鴻??????
 * @param prefix XOOPS???若?帥???若?鴻???若??????REFIX
 * @return result_t
 * @refer result_t
 */
result_t initializeDB( const char* host, const char* user, const char* password, const char* dbname, const char* prefix )
{
    // ?≪??･膓?筝???????筝???????/span>
    if ( mysql != NULL )
        mysql_close( mysql );
    
    // ????????･膓?
    mysql = mysql_init(NULL);
    if ( mysql == NULL ){
        return RES_DB_INITIALIZE_ERROR;
    }
    char *unix_socket = NULL; // ?
    uint flag = 0;       // ?
    if ( NULL == mysql_real_connect( mysql, host, user, password, dbname, 3306, unix_socket, flag ) ){
        return RES_DB_CONNECT_ERROR;
    }
    
    return RES_OK;
}


/**
 * 
 * Platform???若?倶?粋??倶????緇?
 * 
 * @param 
 * @return 
 * 
 */
bool isActivated( sessionid_t sid, userid_t uid )
{
    return false;
}

/**
 * 
 * Platform???若?倶?粋??倶??紊???/span>
 * 
 * @param 
 * @return 
 * 
 */
result_t activate( sessionid_t sid, userid_t uid, bool activate )
{
    return RES_ERROR;
}

/**
 * 
 * ?≪?????潟????/span>
 * 
 * @param 
 * @return 
 * 
 */
int getAccountCount( sessionid_t sid )
{
    return 0;
}

/**
 * 
 * ?≪?????潟??????/span>
 * 
 * @param 
 * @return 
 * 
 */
result_t deleteAccount( sessionid_t sid, userid_t uid )
{
    return RES_ERROR;
}

/**
 * 
 * ?≪?????潟?????怨??
 * 
 * @param 
 * @return 
 * 
 */
result_t getAccount( sessionid_t sid, userid_t uid, const account_t** )
{
    return RES_ERROR;
}

/**
 * 
 * ?≪?????潟?????怨??
 * 
 * @param 
 * @return 
 * 
 */
result_t getAccounts( sessionid_t sid, const userid_t* uids, int uidsLen, const criteria_t* cri, const account_t** accounts, int* accountsLen )
{
    return RES_ERROR;
}

/**
 * 
 * ?≪?????潟???脂??/span>
 * 
 * @param 
 * @return 
 * 
 */
result_t insertAccount( sessionid_t sid, const account_t* account )
{
    return RES_ERROR;
}

/**
 * 
 * ?≪?????潟??紊???/span>
 * 
 * @param 
 * @return 
 * 
 */
result_t updateAccount( sessionid_t sid, const account_t* account )
{
    return RES_ERROR;
}

/**
 * 
 * ???若??D筝?荀?/span>
 * 
 * @param 
 * @return 
 * 
 */
result_t dumpUids( sessionid_t sid, const criteria_t* cri, userid_t** uids, int* uidsLen )
{
    return RES_ERROR;
}

/**
 * 
 * ?違???若????/span>
 * 
 * @param 
 * @return 
 * 
 */
int getGroupCount( sessionid_t sid )
{
    return 0;
}

/**
 * 
 * ??絮??違???若??筝?荀у??
 * 
 * @param 
 * @return 
 * 
 */
result_t getGroupsByUid( sessionid_t sid, userid_t uid, const criteria_t* cri, groupid_t** gids, int* gidsLen )
{
    return RES_ERROR;
}

/**
 * 
 * ?違???若??膊∞??罔????????
 * 
 * @param 
 * @return 
 * 
 */
bool isGroupAdmin( sessionid_t sid, groupid_t gid, userid_t uid )
{
    return RES_ERROR;
}

/**
 * 
 * ?違???若??ID筝?荀?/span>
 * 
 * @param 
 * @return 
 * 
 */
result_t dumpGids( sessionid_t sid, const criteria_t* cri, groupid_t** gids, int* gidsLen )
{
    return RES_ERROR;
}

/**
 * 
 * ?違???若??膊∞????ID??緇?
 * 
 * @param 
 * @return 
 * 
 */
result_t dumpGroupAdmins( sessionid_t sid, groupid_t gid, const criteria_t* cri, userid_t** uids, int* uidsLen )
{
    return RES_ERROR;
}

/**
 * 
 * ?違???若????絮????若?九????/span>
 * 
 * @param 
 * @return 
 * 
 */
result_t deleteMember( sessionid_t sid, groupid_t gid, userid_t uid )
{
    return RES_ERROR;
}

/**
 * 
 * ?違???若????絮????若?区申??
 * 
 * @param 
 * @return 
 * 
 */
result_t insertMember( sessionid_t sid, groupid_t gid, userid_t uid )
{
    return RES_ERROR;
}

/**
 * 
 * ?違???若????絮????若?九??
 * 
 * @param 
 * @return 
 * 
 */
result_t getMembers( sessionid_t sid, groupid_t gid, const criteria_t* cri, userid_t** uids, int* uidsLen )
{
    return RES_ERROR;
}

/**
 * 
 * ?違???若????????/span>
 * 
 * @param 
 * @return 
 * 
 */
result_t deleteGroup( sessionid_t sid, groupid_t gid )
{
    return RES_ERROR;
}

/**
 * 
 * ?違???若?????脂??/span>
 * 
 * @param 
 * @return 
 * 
 */
result_t insertGroup( sessionid_t sid, const group_t* group )
{
    return RES_ERROR;
}

/**
 * 
 * ?違???若???????/span>
 * 
 * @param 
 * @return 
 * 
 */
result_t updateGroup( sessionid_t sid, const group_t* group )
{
    return RES_ERROR;
}

/**
 * 
 * ?違???若?????怨??
 * 
 * @param 
 * @return 
 * 
 */
result_t getGroup( sessionid_t sid, groupid_t gid, const group_t** group )
{
    return RES_ERROR;
}

/**
 * 
 * ?違???若?????怨??
 * 
 * @param 
 * @return 
 * 
 */
result_t getGroups( sessionid_t sid, groupid_t* gids, int gidsLen, const criteria_t* cri, const group_t** groups, int* groupsLen )
{
    return RES_ERROR;
}

/**
 * 
 * ?≪?????若?炊┤???????
 * 
 * @param 
 * @return 
 * 
 */
bool isModerator( sessionid_t sid, userid_t uid )
{
    return RES_ERROR;
}

/**
 * 
 * ???若??D??緇?
 * 
 * @param 
 * @return 
 * 
 */
result_t getUid( const char* uname, userid_t* uid )
{
    string sql;
    
    sql = "SELECT uid FROM " + dbprefix + "_users WHERE uname='" + uname + "'";
    if( mysql_query( mysql, sql.c_str( ) ) ){
        return RES_DB_QUERY_ERROR;
    }
    MYSQL_RES* result = mysql_use_result( mysql ) ;
    MYSQL_ROW row = mysql_fetch_row(result);
    if( row ){
        *uid = atoi( row[0] );
        mysql_free_result( result );
        return RES_OK;
    }else{
        mysql_free_result( result );
        return RES_NO_SUCH_USER;
    }
}

/**
 * 
 * ???違?ゃ?活?荐若???祉???激?с?割???
 * 
 * @param uname ???違?ゃ?喝??
 * @param passwd ???鴻???若??
 * @param session sessionid_t???????????????????ゃ?潟?帥??
 * @return RES_OK ???違?ゃ?恰??????session??essionid_t???吾??莨若??????
 * @return RES_LOGIN_FAILURE uname?障????asswd???医幻
 * @return RES_DB_QUERY_ERROR DB????????筝?????????/span>
 * 
 */
result_t loginUser(const char* uname, const char* passwd, sessionid_t* session )
{
    result_t ret;
    string sql;
    
    // uname, passwd -> uid
    string escUname = addSlashes( uname );
    string escPasswd = addSlashes( passwd );
    sql = "SELECT uid FROM " + dbprefix + "_users WHERE uname='" + escUname + "' and paswd=md5('" + escPasswd + "')";
    if( 0 == mysql_query( mysql, sql.c_str( ) ) ){
        MYSQL_RES* result = mysql_store_result( mysql );
        if( result ){
            MYSQL_ROW row = mysql_fetch_row(result);
            if( row ){
                // uid -> create session
                sql = "INSERT INTO " + dbprefix + "_vpaccount_session (uid,remote_host) values (" + row[0] + ",0)";
                if ( 0 == mysql_query( mysql, sql.c_str() ) ){
                    *session = (int)mysql_insert_id(mysql);
                    ret = RES_OK;
                }
                else {
                    ret = RES_DB_QUERY_ERROR;
                }
            }else{
                ret = RES_LOGIN_FAILUE;
            }
            mysql_free_result( result );
        }else {
            ret = RES_DB_QUERY_ERROR;
        }
    }else{
        ret = RES_DB_QUERY_ERROR;
    }
    
    return ret;
}

/**
 * 
 * ???違?≪???????祉???激?с?括?篋?
 * 
 * @param sid session id
 * @return ????
 * 
 */
void logoutUser( sessionid_t sid ){
    result_t ret;
    string sql;
    sprintf( sidstr, 
    sql = "DELETE FROM " + dbprefix + "_vpaccount_session WHERE sid=" + intToString((int)sid);
    if ( 0 == mysql_query( mysql, sql.c_str() ) ){
        if ( mysql_affected_rows(mysql) == 1 ){
            // ???違?≪????????
        }
        else {
            // sid???≦??/span>
        }
    }
    else {
        // DB????????筝?????????/span>
    }
}

/**
 * 
 * ?祉???激?с?潟?????.<br>
 * XOOPS??ession???若????????蚊??????sess_id?????essionid??膈???????
 * ?逸?session_t??篏?????????
 * ???若?帥???若?鴻???祉???激?с?潟????違?????宴??荐??蚊????
 * 
 * @param 
 * @return 
 *
 */
result_t createSession( const char* sessionid, userid_t uid, unsigned long remoteHost, sessionid_t* sessions )
{
    return RES_ERROR;
}

/**
 * 
 * ?祉???激?с?潟???膣違??session_t?у??????.<br>
 * 
 * @param 
 * @return 
 *
 */
result_t getSessionDetail( sessionid_t sess_id, const session_t** session )
{
    return RES_ERROR;
}

void freeResult( account_t* ptr ){ delete[] ptr; }

void freeResult( group_t* ptr ){ delete[] ptr; }

void freeResult( session_t* ptr ){ delete[] ptr; }

void freeResult( int* ptr ){ delete[] ptr; }

using namespace std;
static string errstr;
const char* getLastErrorString()
{
    return errstr.c_str( );
}

void setLastErrorString( const char* str )
{
    errstr = str;
}