123 lines
2.4 KiB
C++
123 lines
2.4 KiB
C++
#include "networkmanager.h"
|
|
|
|
#include "datatypes.h"
|
|
#include "debug_functions.h"
|
|
#include "lobby.h"
|
|
|
|
|
|
NetworkManager::NetworkManager(AOApplication *parent) : QObject(parent)
|
|
{
|
|
ao_app = parent;
|
|
|
|
ms_socket = new QTcpSocket();
|
|
server_socket = new QTcpSocket();
|
|
|
|
QObject::connect(ms_socket, SIGNAL(readyRead()), this, SLOT(handle_ms_packet()));
|
|
QObject::connect(server_socket, SIGNAL(readyRead()), this, SLOT(handle_server_packet()));
|
|
}
|
|
|
|
NetworkManager::~NetworkManager()
|
|
{
|
|
delete ms_socket;
|
|
delete server_socket;
|
|
}
|
|
|
|
void NetworkManager::connect_to_master()
|
|
{
|
|
ms_socket->close();
|
|
ms_socket->abort();
|
|
|
|
ms_socket->connectToHost(ms_hostname, ms_port);
|
|
}
|
|
|
|
void NetworkManager::connect_to_server(server_type p_server)
|
|
{
|
|
server_socket->close();
|
|
server_socket->abort();
|
|
|
|
server_socket->connectToHost(p_server.ip, p_server.port);
|
|
}
|
|
|
|
void NetworkManager::ship_ms_packet(QString p_packet)
|
|
{
|
|
ms_socket->write(p_packet.toLocal8Bit());
|
|
}
|
|
|
|
void NetworkManager::ship_server_packet(QString p_packet)
|
|
{
|
|
server_socket->write(p_packet.toLocal8Bit());
|
|
}
|
|
|
|
void NetworkManager::handle_ms_packet()
|
|
{
|
|
char buffer[16384] = {0};
|
|
ms_socket->read(buffer, ms_socket->bytesAvailable());
|
|
|
|
QString in_data = buffer;
|
|
|
|
if (!in_data.endsWith("%"))
|
|
{
|
|
ms_partial_packet = true;
|
|
ms_temp_packet += in_data;
|
|
return;
|
|
}
|
|
|
|
else
|
|
{
|
|
if (ms_partial_packet)
|
|
{
|
|
in_data = ms_temp_packet + in_data;
|
|
ms_temp_packet = "";
|
|
ms_partial_packet = false;
|
|
}
|
|
}
|
|
|
|
QStringList packet_list = in_data.split("%", QString::SplitBehavior(QString::SkipEmptyParts));
|
|
|
|
for (QString packet : packet_list)
|
|
{
|
|
AOPacket *f_packet = new AOPacket(packet);
|
|
|
|
ao_app->ms_packet_received(f_packet);
|
|
|
|
delete f_packet;
|
|
}
|
|
}
|
|
|
|
void NetworkManager::handle_server_packet()
|
|
{
|
|
char buffer[16384] = {0};
|
|
server_socket->read(buffer, server_socket->bytesAvailable());
|
|
|
|
QString in_data = buffer;
|
|
|
|
if (!in_data.endsWith("%"))
|
|
{
|
|
partial_packet = true;
|
|
temp_packet += in_data;
|
|
return;
|
|
}
|
|
|
|
else
|
|
{
|
|
if (partial_packet)
|
|
{
|
|
in_data = temp_packet + in_data;
|
|
temp_packet = "";
|
|
partial_packet = false;
|
|
}
|
|
}
|
|
|
|
QStringList packet_list = in_data.split("%", QString::SplitBehavior(QString::SkipEmptyParts));
|
|
|
|
for (QString packet : packet_list)
|
|
{
|
|
AOPacket *f_packet = new AOPacket(packet);
|
|
|
|
ao_app->server_packet_received(f_packet);
|
|
|
|
delete f_packet;
|
|
}
|
|
}
|
|
|