2023-09-25 08:23:52 -04:00
|
|
|
|
#include "connector.h"
|
|
|
|
|
|
2023-09-25 17:17:17 -04:00
|
|
|
|
Connector::Connector() {}
|
2023-09-25 08:23:52 -04:00
|
|
|
|
|
2023-09-25 17:17:17 -04:00
|
|
|
|
Connector::~Connector() {}
|
|
|
|
|
|
|
|
|
|
int Connector::Init() {
|
|
|
|
|
#ifdef _WIN32
|
|
|
|
|
if (WSAStartup(MAKEWORD(2, 2), &m_wsaData) != 0) { /* Initialisation de l'environnement reseau (Windows only) */
|
|
|
|
|
std::cout << "Initialisation WinSock." << std::endl;
|
|
|
|
|
return 1;
|
|
|
|
|
}
|
|
|
|
|
#endif
|
|
|
|
|
|
|
|
|
|
m_sock_udp = socket(AF_INET, SOCK_DGRAM, 0);
|
|
|
|
|
if (m_sock_udp == INVALID_SOCKET) { /* Creation du socket UDP */
|
|
|
|
|
std::cout << "Creation Socket UDP." << std::endl;
|
|
|
|
|
return 2;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
m_sock_tcp = socket(AF_INET, SOCK_STREAM, 0);
|
|
|
|
|
if (m_sock_tcp == INVALID_SOCKET) { /* Creation du socket TCP */
|
|
|
|
|
std::cout << "Creation Socket TCP." << std::endl;
|
|
|
|
|
return 3;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/* Creation structure donnes descripteur du socket serveur */
|
|
|
|
|
sockaddr_in addr;
|
|
|
|
|
addr.sin_family = AF_INET;
|
2023-09-27 11:24:41 -04:00
|
|
|
|
addr.sin_port = htons(CLI_PORT);
|
2023-09-25 17:17:17 -04:00
|
|
|
|
addr.sin_addr.s_addr = htonl(INADDR_ANY);
|
|
|
|
|
|
|
|
|
|
if (bind(m_sock_udp, (sockaddr*)&addr, sizeof(addr)) != 0) { /* Associer le socket UDP au port */
|
|
|
|
|
std::cout << "Association Socket UDP." << std::endl;
|
|
|
|
|
return 4;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
if (bind(m_sock_tcp, (sockaddr*)&addr, sizeof(addr)) != 0) { /* Associer le socket TCP au port */
|
|
|
|
|
std::cout << "Association Socket TCP." << std::endl;
|
|
|
|
|
return 5;
|
|
|
|
|
}
|
2023-09-25 08:23:52 -04:00
|
|
|
|
return 0;
|
|
|
|
|
}
|
|
|
|
|
|
2023-10-23 15:41:07 -04:00
|
|
|
|
int Connector::Connect(const char* srv_addr, std::string name) {
|
2023-09-27 11:24:41 -04:00
|
|
|
|
sockaddr_in add;
|
2023-09-27 17:34:25 -04:00
|
|
|
|
m_srvsockaddr.sin_family = AF_INET;
|
|
|
|
|
m_srvsockaddr.sin_port = htons(SRV_PORT);
|
2023-09-27 11:24:41 -04:00
|
|
|
|
|
2023-09-27 17:34:25 -04:00
|
|
|
|
if (inet_pton(AF_INET, srv_addr, &m_srvsockaddr.sin_addr) <= 0) {
|
2023-09-27 11:24:41 -04:00
|
|
|
|
std::cout << "Addresse serveur invalide." << std::endl;
|
|
|
|
|
return 1;
|
|
|
|
|
}
|
2023-09-27 17:34:25 -04:00
|
|
|
|
|
|
|
|
|
if (connect(m_sock_tcp, (sockaddr*)&m_srvsockaddr, sizeof(m_srvsockaddr)) < 0) {
|
2023-09-27 11:24:41 -04:00
|
|
|
|
std::cout << "<EFBFBD>chec de la connexion." << std::endl;
|
2023-10-28 11:18:01 -04:00
|
|
|
|
return 2;
|
|
|
|
|
}
|
2023-10-29 15:24:03 -04:00
|
|
|
|
|
2023-10-29 15:20:19 -04:00
|
|
|
|
u_long flag = 1;
|
2023-10-29 15:24:03 -04:00
|
|
|
|
if (ioctl(m_sock_tcp, SOCK_NONBLOCK, &flag) < 0) {
|
2023-10-29 15:20:19 -04:00
|
|
|
|
std::cout << "Impossible de mettre le socket en mode non-bloquant." << std::endl;
|
|
|
|
|
return 3;
|
|
|
|
|
}
|
|
|
|
|
|
2023-10-28 12:03:22 -04:00
|
|
|
|
netprot::Buffer bf;
|
2023-09-27 17:34:25 -04:00
|
|
|
|
netprot::LoginInfo log;
|
2023-10-28 12:13:45 -04:00
|
|
|
|
strcpy(log.name, name.c_str());
|
2023-09-27 11:24:41 -04:00
|
|
|
|
|
2023-10-28 12:03:22 -04:00
|
|
|
|
netprot::sendPack(m_sock_tcp, &log, &bf);
|
2023-09-27 17:34:25 -04:00
|
|
|
|
|
2023-10-27 14:37:53 -04:00
|
|
|
|
bool ready = false;
|
2023-10-18 09:59:34 -04:00
|
|
|
|
int errors = 0;
|
2023-10-28 12:03:22 -04:00
|
|
|
|
std::vector<netprot::Packet> lsPck;
|
2023-10-27 14:37:53 -04:00
|
|
|
|
while (!ready) {
|
2023-10-28 12:03:22 -04:00
|
|
|
|
lsPck = netprot::recvPacks(m_sock_tcp, &bf);
|
|
|
|
|
|
|
|
|
|
for (auto& pck : lsPck) {
|
|
|
|
|
bool bypass_delete = false;
|
|
|
|
|
netprot::PlayerInfo* pl = nullptr;
|
|
|
|
|
switch (pck.type) {
|
|
|
|
|
using enum netprot::PACKET_TYPE;
|
|
|
|
|
case LOGINF:
|
|
|
|
|
m_loginfo = netprot::LoginInfo((netprot::LoginInfo*)pck.ptr);
|
|
|
|
|
break;
|
|
|
|
|
case GAMEINFO:
|
|
|
|
|
m_gameinfo = netprot::GameInfo((netprot::GameInfo*)pck.ptr);
|
2023-10-27 15:44:33 -04:00
|
|
|
|
break;
|
2023-10-28 12:03:22 -04:00
|
|
|
|
case PLAYINF:
|
|
|
|
|
pl = (netprot::PlayerInfo*)pck.ptr;
|
|
|
|
|
m_players[pl->id] = pl;
|
|
|
|
|
bypass_delete = true;
|
2023-10-27 15:44:33 -04:00
|
|
|
|
break;
|
2023-10-28 12:03:22 -04:00
|
|
|
|
case TEAMINF:
|
|
|
|
|
// TODO: Faire dequoi avec TeamInfo si on fini par avoir des teams.
|
2023-10-27 15:44:33 -04:00
|
|
|
|
break;
|
2023-10-28 12:03:22 -04:00
|
|
|
|
case SYNC:
|
|
|
|
|
m_origin = netprot::Sync((netprot::Sync*)pck.ptr);
|
2023-10-27 15:44:33 -04:00
|
|
|
|
ready = true;
|
|
|
|
|
break;
|
|
|
|
|
default:
|
2023-10-28 12:03:22 -04:00
|
|
|
|
errors++;
|
2023-10-27 15:44:33 -04:00
|
|
|
|
break;
|
2023-10-27 14:37:53 -04:00
|
|
|
|
}
|
2023-10-28 12:03:22 -04:00
|
|
|
|
if (!bypass_delete)
|
|
|
|
|
netprot::emptyPack(pck);
|
|
|
|
|
}
|
|
|
|
|
lsPck.clear();
|
|
|
|
|
if (errors > 100)
|
|
|
|
|
return 4;
|
2023-09-27 11:24:41 -04:00
|
|
|
|
}
|
2023-09-25 08:23:52 -04:00
|
|
|
|
return 0;
|
|
|
|
|
}
|
|
|
|
|
|
2023-09-27 17:34:25 -04:00
|
|
|
|
uint64_t Connector::getId() const { return m_loginfo.sid; }
|
2023-09-25 08:23:52 -04:00
|
|
|
|
|
2023-09-27 17:34:25 -04:00
|
|
|
|
unsigned int Connector::getSeed() const { return m_gameinfo.seed; }
|
2023-10-27 14:37:53 -04:00
|
|
|
|
|
|
|
|
|
netprot::Sync Connector::getOrigin() const { return m_origin; }
|