[LithuanianJack]

Hello. Something's wrong happened with my "played time" plugin when I changed data saving from steamid to ip address. Plugin says:

L 11/10/2018 - 23:23:22: [AMXX] Plugin ("pt_sql.amxx") is setting itself as failed.
L 11/10/2018 - 23:23:22: [AMXX] Plugin says: Query failed
L 11/10/2018 - 23:23:22: [AMXX] Displaying debug trace (plugin "pt_sql.amxx", version "0.25")
L 11/10/2018 - 23:23:22: [AMXX] Run time error 1: forced exit
L 11/10/2018 - 23:23:22: [AMXX] [0] pt_sql.sma::Query_Handler (line 766)

I would be grateful if anyone could help me.

PHP Code:

#include <amxmodx>
#include <amxmisc>

new const VERSION[] = "0.25"

enum
{
    SQL = 1,
    VAULT
}

/* ************ EDIT STARTS HERE ************ */
// 1 = SQL
// 2 = nVault
#define SAVETYPE 1

#define MAX_TIME_LENGTH        999999

// If defined: 
// Update name in SQL database or vault file immediately after change name
// If NOT defined: 
// Update it only in disconnect and connect
#define REALTIME_UPDATE_NAME // *** done ***

#if SAVETYPE == VAULT
    // Only edit this when using vault
    // If defined:
    // This plugin will read data from vault each time a top command is executed
    // To make the top motd
    // IF not, it will only open the vault once on each map start
    //#define VAULT_REALTIME_TOP_MOTD_UPDATE // *** done ***
    
    #if !defined VAULT_REALTIME_TOP_MOTD_UPDATE
        // Top players number for the top motd command when not using the above define
        #define VAULT_TOP_NUMBER 15
    #endif
#endif

// If defined:
// Make all chat messages colored
// If NOT defined
// Show by client con_color color
#define COLORED_MESSAGES

new const g_szChatMsgPrefix[] = ""

#if SAVETYPE == SQL
// IF using sql, edit these..
new const gsz_SQLINFO[][] = {
    { "" },        // HOST
    { "" },        // USER
    { "" },    // User's password
    { "" }        // Database Name
}

new const g_szTableName[] = "played_time"
#endif

new gsz_MyTimeStrings[][] = {
    "/pt",
    "pt"
}
/* ************ EDIT ENDS HERE ************** */

#if SAVETYPE == SQL
    #include <sqlx>
    new Handle:g_hSql
    new gsz_Query[256]
        
    enum
    {
        HOST,
        USER,
        PASS,
        DB
    }
#else
    #include <nvault_util>
    new const SPECIAL_CHAR[2] = "-"
    new gVault
#endif



new g_iPlayedTime[33], g_iDonateTo[33]
new g_pDonate, g_pConnectMessages

#if defined REALTIME_UPDATE_NAME
    new g_iClientsThatConnectedBit
    #define HasPutInServer(%1) ( g_iClientsThatConnectedBit & (1<<%1) )
    #define SetPutInServer(%1) ( g_iClientsThatConnectedBit |= (1<<%1) )
    #define SetDisconnected(%1) ( g_iClientsThatConnectedBit &= ~(1<<%1) )
#endif

#if !defined VAULT_REALTIME_TOP_MOTD_UPDATE
    new g_szTopMotd[1024]
#endif

public plugin_init()
{
    register_plugin("Played Time: Extended", VERSION, "Khalid :)")
    
    register_clcmd("say /asd65s5d", "Cmd_Donate")
    register_concmd("Type", "DonateAmount")
    
    g_pDonate = register_cvar("pte_allow_donate", "0")
    g_pConnectMessages = register_cvar("pte_show_connect_messages", "1")
    
    new szCommand[40]
    for(new i; i < sizeof(gsz_MyTimeStrings); i++)
    {
        formatex(szCommand, charsmax(szCommand), "say %s", gsz_MyTimeStrings[i])
        register_clcmd(szCommand, "ShowUserTime")
        formatex(szCommand, charsmax(szCommand), "say_team %s", gsz_MyTimeStrings[i])
        register_clcmd(szCommand, "ShowUserTime")
    }

    #if SAVETYPE == VAULT
        #if defined VAULT_REALTIME_TOP_MOTD_UPDATE
            register_clcmd("say", "HookSaid")
            register_clcmd("say_team", "HookSaid")
        #else
            formatex(szCommand, charsmax(szCommand), "say /ontop%d", VAULT_TOP_NUMBER)
            register_clcmd(szCommand, "TopMotdCmd")
            formatex(szCommand, charsmax(szCommand), "say_team /ontop%d", VAULT_TOP_NUMBER)
            register_clcmd(szCommand, "TopMotdCmd")
        #endif
    #endif
    
    register_concmd("amx_show_player_time", "show_players_times", ADMIN_KICK)

    #if SAVETYPE == SQL
    CheckSqlConnection()
    #else
    gVault = nvault_open("played_time")
        #if !defined VAULT_REALTIME_TOP_MOTD_UPDATE
            FormatTop(VAULT_TOP_NUMBER)
        #endif
    #endif
}

public plugin_natives()
{
    register_library("played_time")
    
    register_native("get_user_played_time", "native_get_user_played_time", 1)
    register_native("set_user_played_time", "native_set_user_played_time", 1)
    register_native("pt_get_save_type", "native_get_save_type", 1)
}

#if !defined VAULT_REALTIME_TOP_MOTD_UPDATE
public TopMotdCmd(id)
{
    show_motd(id, g_szTopMotd, "Total time TOP 15")
    return PLUGIN_HANDLED
}
#else
public HookSaid(id)
{
    new szSaid[25]
    read_argv(1, szSaid, charsmax(szSaid))
    
    if( containi(szSaid, "/top") != -1 && containi(szSaid, "") != -1 )
    {
        replace(szSaid, charsmax(szSaid), "/top", ""); replace(szSaid, charsmax(szSaid), "", "")
        
        if(!is_str_num(szSaid))        // If it has more other words than /top*_time
        {
            return PLUGIN_CONTINUE    // stop plugin and continue to show the words
        }
            
        new iNum = str_to_num(szSaid)
        Top(id, iNum)
    }
    
    return PLUGIN_CONTINUE
}
#endif

public show_players_times(id, level, cid)
{
    if(!cmd_access(id, level, cid, 1))
        return PLUGIN_HANDLED
    
    new szName[32], iPlayer
    if(read_argc() == 1)
    {
        console_print(id, "Showing players times of all connected players")
        new iPlayers[32], iNum, iPlayer, szName[32]
        get_players(iPlayers, iNum, "h")
    
        for(new i; i < iNum; i++)
        {
            iPlayer = iPlayers[i]
            get_user_name(iPlayer, szName, 31)
        
            console_print(id, "%d. %s %22.22d", i + 1, szName, (g_iPlayedTime[iPlayer] + get_user_time(iPlayer)) / 60)
        }
    }
    
    else
    {
        new szArg[32]
        read_argv(1, szArg, charsmax(szArg))
        
        if(szArg[0] == '@')
        {
            new iPlayers[32], iNum
            if( equali(szArg, "@TERRORIST") || equali(szArg, "@T") || equal(szArg, "@TERR") )
            {
                console_print(id, "Showing players times for team Terrorist")
                get_players(iPlayers, iNum, "eh", "TERRORIST")
            }
                
            else if( equali(szArg, "@COUNTERTERRORIST") || equali(szArg, "@CT") || equali(szArg, "@COUNTER") )
            {
                console_print(id, "Showing players times for team Counter-Terrorist")
                get_players(iPlayers, iNum, "eh", "CT")
            }
                
            else    return console_print(id, "That's not a correct team")
            
            for(new i; i < iNum; i++)
            {
                iPlayer = iPlayers[i]
                get_user_name(iPlayer, szName, 31)
                console_print(id, "%d. %s %22.22d", i + 1, szName, (g_iPlayedTime[iPlayer] + get_user_time(iPlayer)) / 60)
            }
        }
        
        else
        {
            iPlayer = cmd_target(id, szArg, CMDTARGET_OBEY_IMMUNITY)
            if(!iPlayer)
            {
                console_print(id, "Player could not be targetted.")
                return PLUGIN_HANDLED
            }
            
            get_user_name(iPlayer, szName, charsmax(szName))
            console_print(id, "%s total played time is %d", szName, ( g_iPlayedTime[iPlayer] + get_user_time(iPlayer) ) / 60)
        }
    }
    
    return PLUGIN_HANDLED
}
        
public ShowUserTime(id)
{
    new iTime = get_user_time(id)
    new iTotalTime = (g_iPlayedTime[id] + iTime) / 60
    
    iTime /= 60
    
    #if defined COLORED_MESSAGES
    PrintToChat(id, "^4*^1 At this session you've playing ^4%d^1 minutes.", iTime, iTime ? "" : "s")
    PrintToChat(id, "^4*^1 Your total time in this server is ^4%d^1 minutes.", iTotalTime, iTime == 1 ? "" : "s")
    #else
    PrintToChat(id, "You have been playing for %d minute%s", iTime, iTime == 1 ? "" : "s")
    PrintToChat(id, "Your total played time is %d minute%s", iTotalTime, iTime == 1 ? "" : "s")
    #endif    
    return PLUGIN_HANDLED
}

#if defined REALTIME_UPDATE_NAME
public client_infochanged(id)
{
    //server_print("Called client_infochanged")
    if(!HasPutInServer(id))
    {
        //server_print("Not in server yet")
        return;
    }
    
    new szOldName[34], szNewName[32]
    
    get_user_name(id, szOldName, charsmax(szOldName))
    get_user_info(id, "name", szNewName, charsmax(szNewName))
    
    new szIp[32]; get_user_ip(id, szIp, charsmax(szIp), 1)
    
    if(!equal(szOldName, szNewName))
    {
        //server_print("name change")
        #if SAVETYPE == SQL
        
        CleanName(szNewName)
        
        formatex(gsz_Query, charsmax(gsz_Query), "UPDATE `%s` SET name = '%s' WHERE steamid = '%s'", g_szTableName, szNewName, szIp)
        SQL_ThreadQuery(g_hSql, "Query_Handler", gsz_Query)
        #else
        
        new szIp[32]; get_user_ip(id, szIp, charsmax(szIp), 1)
        
        formatex(szOldName, charsmax(szOldName), "%s%s", szIp, SPECIAL_CHAR)
        
        nvault_remove(gVault, szIp)
        nvault_set(gVault, szOldName, szNewName)
        
        #endif
    }
}
#endif

public client_putinserver(id)
{
    if( is_user_hltv(id)  || is_user_bot(id) )
        return;

    g_iPlayedTime[id] = get_user_totaltime(id)
    
    if(get_pcvar_num(g_pConnectMessages))
    {
        new szName[32]; get_user_name(id, szName, charsmax(szName))
        new iTime = g_iPlayedTime[id] / 60
        
        #if defined COLORED_MESSAGES
        PrintToChat(id, "Player ^3%s ^4Connected with a total time of ^3%d ^4minute%s", szName, iTime, iTime == 1 ? "" : "s")
        #else
        PrintToChat(id, "Player %s Connected with a total time of %d minute%s", szName, iTime, iTime == 1 ? "" : "s")
        #endif
    }
    
    #if defined REALTIME_UPDATE_NAME
    SetPutInServer(id)
    #endif
}

public client_disconnected(id)
{
    // CZ bots steam id is the same (BOT)
    // Prevent them from saving time
    if( is_user_hltv(id)  || is_user_bot(id) )
        return;
    
    SaveTime(id)
    
    #if defined REALTIME_UPDATE_NAME
    SetDisconnected(id)
    #endif
}

public Cmd_Donate(id)
{
    if(!get_pcvar_num(g_pDonate))
    {
        #if defined COLORED_MESSAGES
        PrintToChat(id, "Donating is disabled at the moment.")
        #else
        PrintToChat(id, "Donating is disabled at the moment.")
        #endif
        return PLUGIN_HANDLED
    }
    
    new iPlayers[32], iNum, iPlayer
    get_players(iPlayers, iNum, "h")
    
    if(iNum < 2)
    {
        PrintToChat(id, "Sorry, There are no other players to donate to ..")
        return PLUGIN_HANDLED
    }
    
    new szTitle[70]
    formatex(szTitle, charsmax(szTitle), "\rDonate Menu^n\yYour total time is: \w%d \yminute%s^n", g_iPlayedTime[id] / 60, ( g_iPlayedTime[id] / 60 ) == 1 ? "" : "s" )
    new iMenu = menu_create(szTitle, "DonateMenuHandler")
    new szName[32], szInfo[4]
    
    for(new i; i < iNum; i++)
    {
        iPlayer = iPlayers[i]
        
        if(iPlayer != id)
        {
            get_user_name(iPlayer, szName, charsmax(szName))
            num_to_str(iPlayer, szInfo, 3)
            menu_additem(iMenu, szName, szInfo)
        }
    }
    
    menu_display(id, iMenu)
    return PLUGIN_HANDLED
}

public DonateMenuHandler(id, menu, item)
{
    if(!get_pcvar_num(g_pDonate))
    {
        #if defined COLORED_MESSAGES
        PrintToChat(id, "Donating is disabled at the moment.")
        #else
        PrintToChat(id, "Donating is disabled at the moment.")
        #endif
        return;
    }
    
    if(item < 0)
        return;
    
    new id2, callback, iAccess, szInfo[4]
    menu_item_getinfo(menu, item,iAccess, szInfo, 3, .callback = callback)
    
    id2 = str_to_num(szInfo)
    menu_destroy(menu)
    
    if(!is_user_connected(id2))
    {
        #if defined COLORED_MESSAGES
        PrintToChat(id, "You can't donate to a disconnected player..")
        #else
        PrintToChat(id, "You can't donate to a disconnected player..")
        #endif
        return;
    }
    
    g_iDonateTo[id] = id2
    new szName[32]; get_user_name(id2, szName, 31)
    
    client_cmd(id, "messagemode ^"Type the amount that you want to donate^"")
    
    #if defined COLORED_MESSAGES
    PrintToChat(id, "*** Type the amount that you want to donate to ^3%s", szName)
    #else
    PrintToChat(id, "*** Type the amount that you want to donate to %s", szName)
    #endif
}

public DonateAmount(id)
{
    if(!get_pcvar_num(g_pDonate))
    {
        #if defined COLORED_MESSAGES
        PrintToChat(id, "Donating is disabled at the moment.")
        #else
        PrintToChat(id, "Donating is disabled at the moment.")
        #endif
        return PLUGIN_HANDLED
    }

    
    new id2 = g_iDonateTo[id]
    if(!id2 || !is_user_connected(id2))
        return PLUGIN_HANDLED
    
    new szAmount[50], iAmount
    read_argv(read_argc() - 1, szAmount, charsmax(szAmount))
    
    new iTime = g_iPlayedTime[id]
    
    if( is_str_num(szAmount) )
    {
        iAmount = (str_to_num(szAmount) * 60)
        if(iAmount < 0)
        {
            PrintToChat(id, "You can't donate that")
            return PLUGIN_HANDLED
        }
        
        if(iAmount > iTime)
            iAmount = iTime
    }
    
    else if(szAmount[0] == '*' && szAmount[1] == EOS)
        iAmount = iTime
        
    else
    {
        PrintToChat(id, "You can't donate that")
        return PLUGIN_HANDLED
    }
    
    if( g_iPlayedTime[id] - iAmount < 0 )
        iAmount -= g_iPlayedTime[id]
    
    g_iPlayedTime[id] -= iAmount
    g_iPlayedTime[id2] += iAmount
    
    new szName[32], szName2[32]
    get_user_name(id, szName, 31); get_user_name(id2, szName2, 31)
    
    #if defined COLORED_MESSAGES
    PrintToChat(0, "Player ^3%s ^4donated to ^3%s ^1%d ^4minutes", szName, szName2, iAmount / 60)
    #else
    PrintToChat(0, "Played %s donated to %s %d minutes", szName, szName2, iAmount / 60)
    #endif
    
    return PLUGIN_HANDLED
}

#if SAVETYPE == SQL
CheckSqlConnection()
{
    g_hSql = SQL_MakeDbTuple(gsz_SQLINFO[HOST], gsz_SQLINFO[USER], gsz_SQLINFO[PASS], gsz_SQLINFO[DB])
    
    if(g_hSql == Empty_Handle)
    {
        set_fail_state("Could not connect to SQL database")
        return;
    }
    
    formatex(gsz_Query, charsmax(gsz_Query), "CREATE TABLE IF NOT EXISTS `%s` (steamid VARCHAR(35), name VARCHAR(32), time INT)", g_szTableName)
    SQL_ThreadQuery(g_hSql, "Query_Handler", gsz_Query)
}
#endif

stock Top(id, NUM)
{
    if(NUM < 0)
        NUM *= -1
    
    new iSize
    #if SAVETYPE == SQL
    new iErrorCode, szError[50]
    new Handle:iConnection = SQL_Connect(g_hSql, iErrorCode, szError, charsmax(szError))
    new Handle:iQuery = SQL_PrepareQuery(iConnection, "SELECT COUNT(*) FROM `played_time`")
    
    if(!SQL_Execute(iQuery))
        log_amx(szError)
    
    if(!SQL_MoreResults(iQuery))
    {
        #if defined COLORED_MESSAGES
        PrintToChat(id, "No entries yet")
        #else
        PrintToChat(id, "No entries yet")
        #endif
        return;
    }
    
    iSize = SQL_ReadResult(iQuery, 0)
    
    SQL_FreeHandle(iConnection); SQL_FreeHandle(iQuery)
    #else
    new Vault2 = nvault_util_open("played_time")
    iSize = nvault_util_count(Vault2)
    
    if(!iSize)
    {
        #if defined COLORED_MESSAGES
        PrintToChat(id, "No etnries yet")
        #else
        PrintToChat(id, "No entries yet")
        #endif
        nvault_util_close(Vault2)
        return;
    }
    
    //nvault_util_close(Vault2)
    
    #endif
    
    if( NUM > iSize )
        NUM = iSize
    
    #if SAVETYPE == SQL
    new data[3]
    data[0] = id
    data[1] = NUM
    
    formatex(gsz_Query, charsmax(gsz_Query), "SELECT * FROM `%s` ORDER BY time DESC LIMIT %d", g_szTableName, NUM)
    SQL_ThreadQuery(g_hSql, "FormatTop", gsz_Query, data, 1)
    
    #else
    FormatTop(id, Vault2, NUM, iSize)
    #endif
}

#if SAVETYPE == SQL
public FormatTop(FailState, Handle:Query, Error[], Errcode, Data[], DataSize)
{
    if(FailState == TQUERY_CONNECT_FAILED || FailState == TQUERY_QUERY_FAILED)
    {
        log_amx("[SQL ERROR] Error on query: %s", Error)
        return;
    }
    
    new szMotd[1024], iLen, szName[32], iPlace, iTime
    iLen = formatex(szMotd, charsmax(szMotd), "<body bgcolor=#000000><font color=#FFB00><pre>")
    iLen += format(szMotd[iLen], charsmax(szMotd) - iLen,"%s %-22.22s %3s^n", "#", "Name", "Time in minutes")
    
    while(SQL_MoreResults(Query))
    {
        SQL_ReadResult(Query, 1, szName, charsmax(szName))
        iTime = SQL_ReadResult(Query, 2)

        replace_all(szName, charsmax(szName), "<", "&lt;")
        replace_all(szName, charsmax(szName), ">", "&gt;")

        iLen += formatex(szMotd[iLen], charsmax(szMotd) - iLen, "%d %-22.22s %d^n", ++iPlace, szName, iTime / 60)
        SQL_NextRow(Query)
    }
    
    iLen += formatex(szMotd[iLen], charsmax(szMotd) - iLen, "</pre></font></body>")
    
    new szTitle[25]
    formatex(szTitle, charsmax(szTitle), "Total time TOP %d", Data[1])
    show_motd(Data[0], szMotd, szTitle)
}
#else

// TOP Motd.... TY Exolent!
#if defined VAULT_REALTIME_TOP_MOTD_UPDATE
    stock FormatTop(id, Vault2, iNum, const iSize)    
#else
    stock FormatTop(iNum)
#endif
{    
    enum _:VaultData
    {
        VD_Key[33],
        VD_Value,
        VD_szName[33]
    };
    
    #if !defined VAULT_REALTIME_TOP_MOTD_UPDATE
        new Vault2 = nvault_util_open("played_time")
        new iSize = nvault_util_count(Vault2)
    #endif
    
    // create our array to hold entries and keep track of its size
    new Array:entries = ArrayCreate(VaultData);
    new sizeEntries
    
    // count entries in vault and prepare variables
    new data[VaultData], value[MAX_TIME_LENGTH], data2[VaultData]
    // iterate through all entries
    for(new i = 0, pos, timestamp; i < iSize; i++)
    {
        // grab entry data from current position
        pos = nvault_util_read(Vault2, pos, data[VD_Key], charsmax(data[VD_Key]), value, charsmax(value), timestamp);
        
        /*for(new i; i < sizeof(data[VD_Key]); i++)
            if(!data[VD_Key][i])
                data[VD_Key][i] = EOS*/
    
        if(contain(data[VD_Key], SPECIAL_CHAR) != -1)
            continue;
        
        else
        {
            formatex(data[VD_szName], charsmax(data[VD_szName]), "%s%s", data[VD_Key], SPECIAL_CHAR)
            nvault_get(gVault, data[VD_szName], data[VD_szName], charsmax(data[VD_szName]))
        }

        // turn value string into integer
        data[VD_Value] = str_to_num(value);
        
        // if this is the first entry
        if(sizeEntries == 0)
        {
            // go ahead and add it
            ArrayPushArray(entries, data);
            sizeEntries++;
            continue;
        }
        
        else
        {
            // loop through other entries to see where this one should be placed (sorted from HIGH->LOW)
            for(timestamp = 0; timestamp <= sizeEntries; timestamp++)
            {
                // if we looped through all entries without finding a place
                if(timestamp == sizeEntries)
                {
                    // this entry value is too low to fit before any others
                    // if we have room at the end of the array
                    if(sizeEntries < iNum)
                    {
                        // add it to the end
                        ArrayPushArray(entries, data);
                        sizeEntries++;
                    }
                    
                    // don't continue with code below
                    break;
                }

                
                // grab current entry to compare it with
                ArrayGetArray(entries, timestamp, data2);
                
                // if this new entry should be placed before the compared entry
                if(data[VD_Value] >= data2[VD_Value])
                {
                    // insert before
                    ArrayInsertArrayBefore(entries, timestamp, data);
                    
                    // if we aren't maxxed out
                    if(sizeEntries < iNum)
                    {
                        // increase entry size
                        sizeEntries++;
                    } 
                    else 
                    {
                        // delete the last entry to keep the size at maximum
                        ArrayDeleteItem(entries, sizeEntries);
                    }
                    
                    break;
                }
            }
        }
    }
    
    new iLen
    
    #if defined VAULT_REALTIME_TOP_MOTD_UPDATE
        new szMotd[1024]
        new len = charsmax(szMotd)
    #else
        new len = charsmax(g_szTopMotd)
    #endif
    
    #if defined VAULT_REALTIME_TOP_MOTD_UPDATE
        iLen = formatex(szMotd, len, "<body bgcolor=#000000><font color=#FFB00><pre>")
        iLen += formatex(szMotd[iLen], len - iLen, "%s. %-22.22s %s^n", "#", "Slapyvardis", "Laikas")
    #else
        iLen = formatex(g_szTopMotd, len, "<body bgcolor=#000000><font color=#FFB00><pre>")
        iLen += formatex(g_szTopMotd[iLen], len - iLen, "%s. %-22.22s %s^n", "#", "Slapyvardis", "Laikas")
    #endif
    
    new i
    for(i = 0; i < sizeEntries; i++)
    {
        // grab current entry
        ArrayGetArray(entries, i, data);
        
        // truncate entry key for output
        data[VD_Key][32] = 0;
        data[VD_szName][32] = 0
        
        replace_all(data[VD_szName], charsmax(data[VD_szName]), "<", "&lt;")
        replace_all(data[VD_szName], charsmax(data[VD_szName]), ">", "&gt;")
        
        // display data
        #if defined VAULT_REALTIME_TOP_MOTD_UPDATE
            iLen += formatex(szMotd[iLen], len - iLen, "%d. %-22.22s %d min^n", (i+1), data[VD_szName], data[VD_Value] / 60)
        #else
            iLen += formatex(g_szTopMotd[iLen], len - iLen, "%d. %-22.22s %d min^n", (i+1), data[VD_szName], data[VD_Value] / 60)
        #endif
    }
    
    // destroy the entry array from cache
    ArrayDestroy(entries);
    
    
    #if defined VAULT_REALTIME_TOP_MOTD_UPDATE
        nvault_util_close(Vault2)
    
        iLen += formatex(szMotd[iLen], len - iLen, "</pre></font></body>")
    
        new szTitle[50]; formatex(szTitle, charsmax(szTitle), "Time Top%d", i)
        show_motd(id, szMotd, szTitle)
    #else
        iLen += formatex(g_szTopMotd[iLen], len - iLen, "</pre></font></body>")
    #endif
}
#endif

#if SAVETYPE == SQL
public Query_Handler(FailState, Handle:Query, Error[], Errcode, Data[], DataSize)
{
    if(FailState < 0)
    {
        set_fail_state(FailState == TQUERY_CONNECT_FAILED ? "Could not connect to SQL database." : "Query failed")
    }
   
    if(Errcode)
    {
        log_amx("Error on query: %s",Error)
    }
}
#endif

// NATIVES
public native_get_user_played_time(const id)
{
    if(!IsValidPlayer(id))
    {
        return -1
    }

    return g_iPlayedTime[id]
}
    
public native_set_user_played_time(const id, iNewTime)
{
    if(!IsValidPlayer(id))
    {
        return 0
    }
    
    g_iPlayedTime[id] = iNewTime
    return 1
}

stock IsValidPlayer(id)
{
    if(!is_user_connected(id))
    {
        log_error(AMX_ERR_NATIVE, "Client %d is NOT connected", id)
        return 0
    }
    
    if(is_user_bot(id))
    {
        log_error(AMX_ERR_NATIVE, "Client %d is a BOT", id)
        return 0
    }
    
    if(is_user_hltv(id))
    {
        log_error(AMX_ERR_NATIVE, "HLTV client %d", id)
        return 0
    }
    
    static iMaxPlayers
    if( !iMaxPlayers )
    {
        iMaxPlayers = get_maxplayers()
    }
    
    if( ! ( 1 <= id <= iMaxPlayers ) )
    {
        log_error(AMX_ERR_BOUNDS, "Index out of bounds %d", id)
        return 0
    }
    
    return 1
}

public native_get_save_type()
    return SAVETYPE
    
public plugin_end()
{
    #if SAVETYPE == SQL
        SQL_FreeHandle(g_hSql)
    #else
        nvault_close(gVault)
    #endif
}


/* ------------------------------------------------------------
                              STOCKS
   ------------------------------------------------------------ */
stock PrintToChat(id, szFmt[], any:...)
{
    new szMsg[192]
    
    #if defined COLORED_MESSAGES
    new iLen = formatex(szMsg, charsmax(szMsg), "^3%s ", g_szChatMsgPrefix)
    #else
    new iLen = formatex(szMsg, charsmax(szMsg), "%s ", g_szChatMsgPrefix)
    #endif
    
    vformat(szMsg[iLen], charsmax(szMsg) - iLen, szFmt, 3)
    
    #if defined COLORED_MESSAGES
    new iPlayers[32], iNum
    
    if(id)
    {
        if(!IsValidPlayer(id))
        {
            return;
        }
        
        iPlayers[0] = id; iNum = 1
    }
    
    else
    {
        get_players(iPlayers, iNum)
    }
    
    static iMsgIdSayText
    if(!iMsgIdSayText)
    {
        iMsgIdSayText = get_user_msgid("SayText")
    }
    
    for(new i; i < iNum; i++)
    {
        message_begin(MSG_ONE_UNRELIABLE, iMsgIdSayText,_, iPlayers[i])
        {
            write_byte(iPlayers[i])
            write_string(szMsg)
        }
        message_end()
    }
    
    #else
    
    client_print(id, print_chat, szMsg)
    
    #endif
}

stock CleanName(szName[32])
{
    replace_all(szName, 31, "'", "")
    replace_all(szName, 31, "^"", "")
}

stock SaveTime(id)
{
    new szIp[32]; get_user_ip(id, szIp, charsmax(szIp), 1)
    
    #if !defined REALTIME_UPDATE_NAME
    new szName[32]; get_user_name(id, szName, 31)
    #endif

    #if SAVETYPE == SQL
        #if !defined REALTIME_UPDATE_NAME
            CleanName(szName)
            formatex(gsz_Query, charsmax(gsz_Query), "UPDATE `%s` SET time = '%d', name = '%s' WHERE steamid = '%s'", g_szTableName, g_iPlayedTime[id] + get_user_time(id), szName, szIp)
        #else
            formatex(gsz_Query, charsmax(gsz_Query), "UPDATE `%s` SET time = '%d' WHERE steamid = '%s'", g_szTableName, g_iPlayedTime[id] + get_user_time(id), szIp)
        #endif
        
        SQL_ThreadQuery(g_hSql, "Query_Handler", gsz_Query)
    #else
        new szTime[MAX_TIME_LENGTH]; num_to_str(g_iPlayedTime[id] + get_user_time(id), szTime, charsmax(szTime))
        nvault_remove(gVault, szIp)
        nvault_set(gVault, szIp, szTime)
        
        #if !defined REALTIME_UPDATE_NAME
            format(szIp, charsmax(szIp), "%s%s", szIp, SPECIAL_CHAR)
            nvault_remove(gVault, szIp)
            nvault_set(gVault, szIp, szName)
        #endif
    #endif
    
    g_iPlayedTime[id] = 0
}

stock get_user_totaltime(id)
{
    new iNum, szSavedName[32]
    new szName[32]; get_user_name(id, szName, 31)
    new szIp[32]; get_user_ip(id, szIp, charsmax(szIp), 1)
    
    #if SAVETYPE == SQL
    new iErrorCode, szError[50]
    
    new Handle:hConnection = SQL_Connect(g_hSql, iErrorCode, szError, charsmax(szError))
    new Handle:hQuery = SQL_PrepareQuery(hConnection, "SELECT * FROM `played_time` WHERE steamid='%s'", szIp)
    
    SQL_Execute(hQuery)

    if(!SQL_MoreResults(hQuery))
    {
        formatex(gsz_Query, charsmax(gsz_Query), "INSERT INTO `%s` VALUES ('%s', '%s', %d)", g_szTableName, szIp, szName, 0)
        SQL_ThreadQuery(g_hSql, "Query_Handler", gsz_Query)
        
        SQL_FreeHandle(hConnection); SQL_FreeHandle(hQuery)
        
        return 0
    }

    /*else
    {
        if(SQL_NumResults(hQuery) > 1)
        {
            server_print("More than 1 result!")
        }
    }*/
    
    SQL_ReadResult(hQuery, 2, szSavedName, 31)
    
    CleanName(szSavedName)
    
    if(!equal(szName, szSavedName))
    {
        formatex(gsz_Query, charsmax(gsz_Query), "UPDATE `%s` SET name = '%s' WHERE steamid = '%s'", g_szTableName, szName, szIp)
        SQL_ThreadQuery(g_hSql, "Query_Handler", gsz_Query)
    }
    
    iNum = SQL_ReadResult(hQuery, 2)
    
    SQL_FreeHandle(hConnection); SQL_FreeHandle(hQuery)
    
    #else
    new szTime[MAX_TIME_LENGTH], iTimeStamp
    if( !nvault_lookup(gVault, szIp, szTime, charsmax(szTime), iTimeStamp) )
    {
        nvault_set(gVault, szIp, "0")
        
        format(szIp, charsmax(szIp), "%s%s", szIp, SPECIAL_CHAR)
        nvault_set(gVault, szIp, szName)
        
        return 0
    }
    
    iNum = str_to_num(szTime)
    
    format(szIp, charsmax(szIp), "%s%s", szIp, SPECIAL_CHAR)
    nvault_get(gVault, szIp, szSavedName)
    
    if(!equal(szName, szSavedName))
    {
        nvault_remove(gVault, szIp)
        nvault_set(gVault, szIp, szName)
    }
    #endif
    
    return iNum
}
/* AMXX-Studio Notes - DO NOT MODIFY BELOW HERE
*{\\ rtf1\\ ansi\\ deff0{\\ fonttbl{\\ f0\\ fnil Tahoma;}}\n\\ viewkind4\\ uc1\\ pard\\ lang1033\\ f0\\ fs16 \n\\ par }
*/