RASession Class Reference

#include <RASession.h>

Public Member Functions
	RASession (tcp::socket &&socket)
void	Start ()
const std::string	GetRemoteIpAddress () const
unsigned short	GetRemotePort () const

Private Member Functions
int	Send (const char *data)
std::string	ReadString ()
bool	CheckAccessLevel (const std::string &user)
bool	CheckPassword (const std::string &user, const std::string &pass)
bool	ProcessCommand (std::string &command)

Static Private Member Functions
static void	CommandPrint (void *callbackArg, const char *text)
static void	CommandFinished (void *callbackArg, bool)

Private Attributes
tcp::socket	_socket
boost::asio::streambuf	_readBuffer
boost::asio::streambuf	_writeBuffer
std::promise< void > *	_commandExecuting

Constructor & Destructor Documentation

RASession::RASession ( tcp::socket &&  socket )

inline

 : _socket(std::move(socket)), _commandExecuting(nullptr)
 {
 }

Member Function Documentation

bool RASession::CheckAccessLevel ( const std::string &  user )

private

{
 std::string safeUser = user;

 Utf8ToUpperOnlyLatin(safeUser);

 PreparedStatement* stmt = LoginDatabase.GetPreparedStatement(LOGIN_SEL_ACCOUNT_ACCESS);
 stmt->setString(0, safeUser);
 PreparedQueryResult result = LoginDatabase.Query(stmt);

 if (!result)
 {
 TC_LOG_INFO("commands.ra", "User %s does not exist in database", user.c_str());
 return false;
 }

 Field* fields = result->Fetch();

 if (fields[1].GetUInt8() < sConfigMgr->GetIntDefault("RA.MinLevel", 3))
 {
 TC_LOG_INFO("commands.ra", "User %s has no privilege to login", user.c_str());
 return false;
 }
 else if (fields[2].GetInt32() != -1)
 {
 TC_LOG_INFO("commands.ra", "User %s has to be assigned on all realms (with RealmID = '-1')", user.c_str());
 return false;
 }

 return true;
}

Here is the call graph for this function:

Here is the caller graph for this function:

bool RASession::CheckPassword ( const std::string &  user, const std::string &  pass  )

private

{
 std::string safe_user = user;
 Utf8ToUpperOnlyLatin(safe_user);

 std::string safe_pass = pass;
 Utf8ToUpperOnlyLatin(safe_pass);

 std::string hash = AccountMgr::CalculateShaPassHash(safe_user, safe_pass);

 PreparedStatement* stmt = LoginDatabase.GetPreparedStatement(LOGIN_SEL_CHECK_PASSWORD_BY_NAME);

 stmt->setString(0, safe_user);
 stmt->setString(1, hash);

 PreparedQueryResult result = LoginDatabase.Query(stmt);

 if (!result)
 {
 TC_LOG_INFO("commands.ra", "Wrong password for user: %s", user.c_str());
 return false;
 }

 return true;
}

Here is the call graph for this function:

Here is the caller graph for this function:

void RASession::CommandFinished ( void *  callbackArg, bool    )

staticprivate

{
 RASession* session = static_cast<RASession*>(callbackArg);
 session->_commandExecuting->set_value();
}

Here is the caller graph for this function:

void RASession::CommandPrint ( void *  callbackArg, const char *  text  )

staticprivate

{
 if (!text || !*text)
 return;

 RASession* session = static_cast<RASession*>(callbackArg);
 session->Send(text);
}

Here is the call graph for this function:

Here is the caller graph for this function:

const std::string RASession::GetRemoteIpAddress ( ) const

inline

{ return _socket.remote_endpoint().address().to_string(); }

Here is the caller graph for this function:

unsigned short RASession::GetRemotePort ( ) const

inline

{ return _socket.remote_endpoint().port(); }

bool RASession::ProcessCommand ( std::string &  command )

private

{
 if (command.length() == 0)
 return true;

 TC_LOG_INFO("commands.ra", "Received command: %s", command.c_str());

 // handle quit, exit and logout commands to terminate connection
 if (command == "quit" || command == "exit" || command == "logout")
 {
 Send("Bye\r\n");
 return true;
 }

 // Obtain a new promise per command
 delete _commandExecuting;
 _commandExecuting = new std::promise<void>();

 CliCommandHolder* cmd = new CliCommandHolder(this, command.c_str(), &RASession::CommandPrint, &RASession::CommandFinished);
 sWorld->QueueCliCommand(cmd);

 // Wait for the command to finish
 _commandExecuting->get_future().wait();

 return false;
}

Here is the call graph for this function:

Here is the caller graph for this function:

std::string RASession::ReadString ( )

private

{
 boost::system::error_code error;
 size_t read = boost::asio::read_until(_socket, _readBuffer, "\r\n", error);
 if (!read)
 {
 _socket.close();
 return "";
 }

 std::string line;
 std::istream is(&_readBuffer);
 std::getline(is, line);

 if (*line.rbegin() == '\r')
 line.erase(line.length() - 1);

 return line;
}

Here is the caller graph for this function:

int RASession::Send ( const char *  data )

private

{
 std::ostream os(&_writeBuffer);
 os << data;
 size_t written = _socket.send(_writeBuffer.data());
 _writeBuffer.consume(written);
 return written;
}

Here is the caller graph for this function:

void RASession::Start

(

)

{
 // wait 1 second for active connections to send negotiation request
 for (int counter = 0; counter < 10 && _socket.available() == 0; counter++)
 std::this_thread::sleep_for(std::chrono::milliseconds(100));

 // Check if there are bytes available, if they are, then the client is requesting the negotiation
 if (_socket.available() > 0)
 {
 // Handle subnegotiation
 boost::array<char, 1024> buf;
 _socket.read_some(boost::asio::buffer(buf));

 // Send the end-of-negotiation packet
 uint8 const reply[2] = { 0xFF, 0xF0 };
 _socket.write_some(boost::asio::buffer(reply));
 }

 Send("Authentication Required\r\n");
 Send("Username: ");

 std::string username = ReadString();

 if (username.empty())
 return;

 TC_LOG_INFO("commands.ra", "Accepting RA connection from user %s (IP: %s)", username.c_str(), GetRemoteIpAddress().c_str());

 Send("Password: ");

 std::string password = ReadString();
 if (password.empty())
 return;

 if (!CheckAccessLevel(username) || !CheckPassword(username, password))
 {
 Send("Authentication failed\r\n");
 _socket.close();
 return;
 }

 TC_LOG_INFO("commands.ra", "User %s (IP: %s) authenticated correctly to RA", username.c_str(), GetRemoteIpAddress().c_str());

 // Authentication successful, send the motd
 for (std::string const& line : sWorld->GetMotd())
 Send(line.c_str());
 Send("\r\n");

 // Read commands
 for (;;)
 {
 Send("TC>");
 std::string command = ReadString();

 if (ProcessCommand(command))
 break;
 }

 _socket.close();
}

Here is the call graph for this function:

Member Data Documentation

std::promise<void>* RASession::_commandExecuting

private

boost::asio::streambuf RASession::_readBuffer

private

tcp::socket RASession::_socket

private

boost::asio::streambuf RASession::_writeBuffer

private

---

The documentation for this class was generated from the following files:

• src/server/worldserver/RemoteAccess/RASession.h
• src/server/worldserver/RemoteAccess/RASession.cpp