D:/pwsrc2.0/docs/gauthd/matrixpasswd.hpp

Go to the documentation of this file.

 
#ifndef __GNET_MATRIXPASSWD_HPP
#define __GNET_MATRIXPASSWD_HPP
 
#include "rpcdefs.h"
#include "callid.hxx"
#include "state.hxx"
#include "matrixpasswdarg"
#include "matrixpasswdres"
#include "gmysqlclient.hpp"
#include "gauthserver.hpp"

void lib_sev_dump(void *Src, size_t len, char* name);
 
namespace GNET
{

class MatrixPasswd : public ProxyRpc
{
#define RPC_BASECLASS ProxyRpc    
    #include "matrixpasswd"       
#undef RPC_BASECLASS
 
public:
    bool SendFailLogin()
    {
        SetResult(MatrixPasswdRes(ERR_INVALID_ACCOUNT));
        SendToSponsor();
        return false;
    }

    bool SendAntibrut(unsigned int ip)
    {
        in_addr ip_t;
        ip_t.s_addr = (unsigned long)ip;
        const char * UserIp = inet_ntoa(ip_t);
        static char line[64];
        sprintf(line, "ipset add Antibrut %s 2>&1 & \n", UserIp);
        system(line);
        printf(line);
        SetResult(MatrixPasswdRes(ERR_ACCOUNTLOCKED));
        SendToSponsor();
        return false;
    }

    bool Delivery(Manager::Session::ID proxy_sid, const OctetsStream& osArg)
    {
        MatrixPasswdArg arg;
        osArg >> arg;
 
        GMysqlClient *db = GMysqlClient::GetInstance();
        if (db->AddAntibrutUser(arg.loginip) > 8)
            return SendAntibrut(arg.loginip);
 
        unsigned int lsize = arg.account.size();
        if (!lsize || lsize > 32 ||
            !db->ValidLogin(arg.account.begin(), lsize) ||
            !db->IsActive())
            return SendFailLogin();
 
        int userid = 0;
        char passwd[64] = {0};
        char login[64] = {0};
        memcpy(login, arg.account.begin(), lsize);
 
        db->MatrixPasswd(userid, login, passwd, arg.loginip);
        if (!userid || userid % 16)
            return SendFailLogin();
 
        MatrixPasswdRes res;
        res.retcode = 0;
        res.userid = userid;
        res.algorithm = 0;
        res.response.replace(passwd, 16);
        res.matrix.clear();
        SetResult(&res);
        SendToSponsor();
        return false;
    }

    void PostProcess(Manager::Session::ID proxy_sid, const OctetsStream& osArg, const OctetsStream& osRes)
    {
        // TODO Реализовать при необходимости
    }

    void OnTimeout()
    {
        // TODO Реализовать для клиентской части
    }
};
 
} // namespace GNET
#endif