mirror of
https://github.com/EQEmu/Server.git
synced 2025-12-12 01:11:29 +00:00
7a46a6595c
* Convert common/eq_limits.cpp to use make_unique * Convert common/net/console_server.cpp to use make_unique * Convert common/net/servertalk_client_connection.cpp to use make_unique * Convert common/net/servertalk_legacy_client_connection.cpp to use make_unique * Convert common/net/servertalk_server.cpp to use make_unique * Convert common/net/websocket_server.cpp to use make_unique * Convert common/net/websocket_server_connection.cpp to use make_unique * Convert common/shareddb.cpp to use make_unique * Convert eqlaunch/worldserver.cpp to use make_unique * Convert loginserver/server_manager.cpp to use make_unique * Convert loginserver/world_server.cpp to use make_unique * Convert queryserv/worldserver.cpp to use make_unique * Convert ucs/worldserver.cpp to use make_unique * Convert world/clientlist.cpp to use make_unique * Convert world/expedition.cpp to use make_unique * Convert world/launcher_link.cpp to use make_unique * Convert world/login_server.cpp to use make_unique * Convert world/main.cpp to use make_unique * Convert world/ucs.cpp to use make_unique * Convert world/web_interface.cpp to use make_unique * Convert world/zonelist.cpp to use make_unique * Convert world/zoneserver.cpp to use make_unique * Convert zone/client.cpp to use make_unique * Convert zone/corpse.cpp to use make_unique * Convert zone/dynamiczone.cpp to use make_unique * Convert zone/expedition.cpp to use make_unique * Convert zone/main.cpp to use make_unique * Convert zone/mob_ai.cpp to use make_unique * Convert zone/mob_movement_manager.cpp to use make_unique * Convert zone/pathfinder_nav_mesh.cpp to use make_unique * Convert zone/worldserver.cpp to use make_unique
98 lines
2.6 KiB
C++
98 lines
2.6 KiB
C++
#include "servertalk_server.h"
|
|
|
|
EQ::Net::ServertalkServer::ServertalkServer()
|
|
{
|
|
}
|
|
|
|
EQ::Net::ServertalkServer::~ServertalkServer()
|
|
{
|
|
}
|
|
|
|
void EQ::Net::ServertalkServer::Listen(const ServertalkServerOptions& opts)
|
|
{
|
|
m_encrypted = opts.encrypted;
|
|
m_credentials = opts.credentials;
|
|
m_allow_downgrade = opts.allow_downgrade;
|
|
m_server = std::make_unique<EQ::Net::TCPServer>();
|
|
m_server->Listen(opts.port, opts.ipv6, [this](std::shared_ptr<EQ::Net::TCPConnection> connection) {
|
|
m_unident_connections.push_back(std::make_shared<ServertalkServerConnection>(connection, this, m_encrypted, m_allow_downgrade));
|
|
});
|
|
}
|
|
|
|
void EQ::Net::ServertalkServer::OnConnectionIdentified(const std::string &type, std::function<void(std::shared_ptr<ServertalkServerConnection>)> cb)
|
|
{
|
|
m_on_ident.insert(std::make_pair(type, cb));
|
|
}
|
|
|
|
void EQ::Net::ServertalkServer::OnConnectionRemoved(const std::string &type, std::function<void(std::shared_ptr<ServertalkServerConnection>)> cb)
|
|
{
|
|
m_on_disc.insert(std::make_pair(type, cb));
|
|
}
|
|
|
|
void EQ::Net::ServertalkServer::ConnectionDisconnected(ServertalkServerConnection *conn)
|
|
{
|
|
if (conn->GetIdentifier().empty()) {
|
|
auto iter = m_unident_connections.begin();
|
|
while (iter != m_unident_connections.end()) {
|
|
if (conn == iter->get()) {
|
|
m_unident_connections.erase(iter);
|
|
return;
|
|
}
|
|
++iter;
|
|
}
|
|
}
|
|
else {
|
|
auto type = m_ident_connections.find(conn->GetIdentifier());
|
|
if (type != m_ident_connections.end()) {
|
|
auto iter = type->second.begin();
|
|
while (iter != type->second.end()) {
|
|
if (conn == iter->get()) {
|
|
auto on_disc = m_on_disc.find(conn->GetIdentifier());
|
|
if (on_disc != m_on_disc.end()) {
|
|
on_disc->second(*iter);
|
|
}
|
|
type->second.erase(iter);
|
|
return;
|
|
}
|
|
++iter;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
void EQ::Net::ServertalkServer::ConnectionIdentified(ServertalkServerConnection *conn)
|
|
{
|
|
auto iter = m_unident_connections.begin();
|
|
while (iter != m_unident_connections.end()) {
|
|
if (conn == iter->get()) {
|
|
auto on_ident = m_on_ident.find(conn->GetIdentifier());
|
|
if (on_ident != m_on_ident.end()) {
|
|
on_ident->second(*iter);
|
|
}
|
|
|
|
if (m_ident_connections.count(conn->GetIdentifier()) > 0) {
|
|
auto &vec = m_ident_connections[conn->GetIdentifier()];
|
|
vec.push_back(*iter);
|
|
}
|
|
else {
|
|
std::vector<std::shared_ptr<EQ::Net::ServertalkServerConnection>> vec;
|
|
vec.push_back(*iter);
|
|
m_ident_connections.insert(std::make_pair(conn->GetIdentifier(), vec));
|
|
}
|
|
|
|
m_unident_connections.erase(iter);
|
|
return;
|
|
}
|
|
++iter;
|
|
}
|
|
}
|
|
|
|
bool EQ::Net::ServertalkServer::CheckCredentials(const std::string &credentials)
|
|
{
|
|
if (credentials.compare(m_credentials) == 0) {
|
|
return true;
|
|
}
|
|
|
|
return false;
|
|
}
|