mirror of
https://github.com/opentibiabr/remeres-map-editor
synced 2026-08-15 18:26:04 -04:00
2057c5203b
Removed boosts (replaced with equivalent on std 14/17/20) With this modification, there are only 16 libs for the project to add, simplifying a lot. So two additional libraries will be needed to compile: asio, nlohmann-json I also removed OTGZ support by default and disabled it, making it optional (needs to be enabled). Anyone who wants to use it will need to activate this, I think it's ideal since few should use it, so a majority don't use it, which is fairer that those who need to activate it to use it than those who don't need to have this in their program.
138 lines
3 KiB
C++
138 lines
3 KiB
C++
//////////////////////////////////////////////////////////////////////
|
|
// This file is part of Remere's Map Editor
|
|
//////////////////////////////////////////////////////////////////////
|
|
// Remere's Map Editor is free software: you can redistribute it and/or modify
|
|
// it under the terms of the GNU General Public License as published by
|
|
// the Free Software Foundation, either version 3 of the License, or
|
|
// (at your option) any later version.
|
|
//
|
|
// Remere's Map Editor is distributed in the hope that it will be useful,
|
|
// but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
// GNU General Public License for more details.
|
|
//
|
|
// You should have received a copy of the GNU General Public License
|
|
// along with this program. If not, see <http://www.gnu.org/licenses/>.
|
|
//////////////////////////////////////////////////////////////////////
|
|
|
|
#include "main.h"
|
|
#include "net_connection.h"
|
|
|
|
NetworkMessage::NetworkMessage()
|
|
{
|
|
clear();
|
|
}
|
|
|
|
void NetworkMessage::clear()
|
|
{
|
|
buffer.resize(4);
|
|
position = 4;
|
|
size = 0;
|
|
}
|
|
|
|
void NetworkMessage::expand(const size_t length)
|
|
{
|
|
if(position + length >= buffer.size()) {
|
|
buffer.resize(position + length + 1);
|
|
}
|
|
size += length;
|
|
}
|
|
|
|
template<> std::string NetworkMessage::read<std::string>()
|
|
{
|
|
const uint16_t length = read<uint16_t>();
|
|
char* strBuffer = reinterpret_cast<char*>(&buffer[position]);
|
|
position += length;
|
|
return std::string(strBuffer, length);
|
|
}
|
|
|
|
template<> Position NetworkMessage::read<Position>()
|
|
{
|
|
Position position;
|
|
position.x = read<uint16_t>();
|
|
position.y = read<uint16_t>();
|
|
position.z = read<uint8_t>();
|
|
return position;
|
|
}
|
|
|
|
template<> void NetworkMessage::write<std::string>(const std::string& value)
|
|
{
|
|
const size_t length = value.length();
|
|
write<uint16_t>(length);
|
|
|
|
expand(length);
|
|
memcpy(&buffer[position], &value[0], length);
|
|
position += length;
|
|
}
|
|
|
|
template<> void NetworkMessage::write<Position>(const Position& value)
|
|
{
|
|
write<uint16_t>(value.x);
|
|
write<uint16_t>(value.y);
|
|
write<uint8_t>(value.z);
|
|
}
|
|
|
|
// NetworkConnection
|
|
NetworkConnection::NetworkConnection() :
|
|
service(nullptr), thread(), stopped(false)
|
|
{
|
|
//
|
|
}
|
|
|
|
NetworkConnection::~NetworkConnection()
|
|
{
|
|
stop();
|
|
}
|
|
|
|
NetworkConnection& NetworkConnection::getInstance()
|
|
{
|
|
static NetworkConnection connection;
|
|
return connection;
|
|
}
|
|
|
|
bool NetworkConnection::start()
|
|
{
|
|
if(thread.joinable()) {
|
|
if(stopped) {
|
|
return false;
|
|
}
|
|
return true;
|
|
}
|
|
|
|
stopped = false;
|
|
if(!service) {
|
|
service = new asio::io_service;
|
|
}
|
|
|
|
thread = std::thread([this]() -> void {
|
|
asio::io_service& serviceRef = *service;
|
|
try {
|
|
while(!stopped) {
|
|
serviceRef.run_one();
|
|
serviceRef.reset();
|
|
}
|
|
} catch (std::exception& e) {
|
|
std::cout << e.what() << std::endl;
|
|
}
|
|
});
|
|
return true;
|
|
}
|
|
|
|
void NetworkConnection::stop()
|
|
{
|
|
if(!service) {
|
|
return;
|
|
}
|
|
|
|
service->stop();
|
|
stopped = true;
|
|
thread.join();
|
|
|
|
delete service;
|
|
service = nullptr;
|
|
}
|
|
|
|
asio::io_service& NetworkConnection::get_service()
|
|
{
|
|
return *service;
|
|
}
|