325 lines
7.7 KiB
C++
325 lines
7.7 KiB
C++
#include "aoapplication.h"
|
|
|
|
#include "lobby.h"
|
|
#include "courtroom.h"
|
|
#include "networkmanager.h"
|
|
#include "encryption_functions.h"
|
|
#include "hardware_functions.h"
|
|
|
|
#include <QDebug>
|
|
|
|
void AOApplication::ms_packet_received(AOPacket *p_packet)
|
|
{
|
|
p_packet->net_decode();
|
|
|
|
QString header = p_packet->get_header();
|
|
QStringList f_contents = p_packet->get_contents();
|
|
|
|
if (header != "CHECK")
|
|
qDebug() << "R(ms):" << p_packet->to_string();
|
|
|
|
if (header == "ALL")
|
|
{
|
|
server_list.clear();
|
|
|
|
for (QString i_string : p_packet->get_contents())
|
|
{
|
|
server_type f_server;
|
|
QStringList sub_contents = i_string.split("&");
|
|
|
|
if (sub_contents.size() < 4)
|
|
{
|
|
qDebug() << "W: malformed packet";
|
|
continue;
|
|
}
|
|
|
|
f_server.name = sub_contents.at(0);
|
|
f_server.desc = sub_contents.at(1);
|
|
f_server.ip = sub_contents.at(2);
|
|
f_server.port = sub_contents.at(3).toInt();
|
|
|
|
server_list.append(f_server);
|
|
}
|
|
|
|
if (lobby_constructed)
|
|
{
|
|
w_lobby->list_servers();
|
|
}
|
|
}
|
|
else if (header == "CT")
|
|
{
|
|
QString message_line;
|
|
|
|
if (f_contents.size() == 1)
|
|
message_line = f_contents.at(0);
|
|
else if (f_contents.size() >= 2)
|
|
message_line = f_contents.at(0) + ": " + f_contents.at(1);
|
|
else
|
|
return;
|
|
|
|
if (lobby_constructed)
|
|
{
|
|
w_lobby->append_chatmessage(message_line);
|
|
}
|
|
if (courtroom_constructed)
|
|
{
|
|
//T0D0: uncomment this when it's implemented
|
|
//w_courtroom->append_ms_chat_message(message_line);
|
|
}
|
|
}
|
|
}
|
|
|
|
void AOApplication::server_packet_received(AOPacket *p_packet)
|
|
{
|
|
p_packet->net_decode();
|
|
|
|
QString header = p_packet->get_header();
|
|
QStringList f_contents = p_packet->get_contents();
|
|
QString f_packet = p_packet->to_string();
|
|
|
|
qDebug() << "R: " << f_packet;
|
|
|
|
if (header == "decryptor")
|
|
{
|
|
if (f_contents.size() == 0)
|
|
return;
|
|
|
|
//you may ask where 322 comes from. that would be a good question.
|
|
s_decryptor = fanta_decrypt(f_contents.at(0), 322).toUInt();
|
|
|
|
QString f_hdid;
|
|
f_hdid = get_hdid();
|
|
|
|
AOPacket *hi_packet = new AOPacket("HI#" + f_hdid + "#%");
|
|
send_server_packet(hi_packet);
|
|
}
|
|
else if (header == "ID")
|
|
{
|
|
if (f_contents.size() < 1)
|
|
return;
|
|
|
|
s_pv = f_contents.at(0).toInt();
|
|
|
|
if (f_contents.size() < 2)
|
|
return;
|
|
|
|
//T0D0: store server version
|
|
}
|
|
else if (header == "CT")
|
|
{
|
|
if (f_contents.size() < 2)
|
|
{
|
|
qDebug() << "W: malformed packet!";
|
|
return;
|
|
}
|
|
|
|
//QString message_line = f_contents.at(0) + ": " + f_contents.at(1);
|
|
|
|
//T0D0, uncomment when implemented
|
|
//w_courtroom->append_ooc_chatmessage(message_line)
|
|
}
|
|
else if (header == "PN")
|
|
{
|
|
if (f_contents.size() < 2)
|
|
return;
|
|
|
|
w_lobby->set_player_count(f_contents.at(0).toInt(), f_contents.at(1).toInt());
|
|
}
|
|
else if (header == "SI")
|
|
{
|
|
if (f_contents.size() < 3)
|
|
return;
|
|
|
|
char_list_size = f_contents.at(0).toInt();
|
|
loaded_chars = 0;
|
|
evidence_list_size = f_contents.at(1).toInt();
|
|
loaded_evidence = 0;
|
|
music_list_size = f_contents.at(2).toInt();
|
|
loaded_music = 0;
|
|
|
|
destruct_courtroom();
|
|
|
|
construct_courtroom();
|
|
|
|
w_lobby->show_loading_overlay();
|
|
w_lobby->set_loading_text("Loading");
|
|
|
|
AOPacket *f_packet = new AOPacket("askchar2#%");
|
|
send_server_packet(f_packet);
|
|
}
|
|
else if (header == "CI")
|
|
{
|
|
if (!courtroom_constructed)
|
|
return;
|
|
|
|
for (int n_element = 0 ; n_element < f_contents.size() ; n_element += 2)
|
|
{
|
|
if (f_contents.at(n_element).toInt() != loaded_chars)
|
|
break;
|
|
|
|
//this means we are on the last element and checking n + 1 element will be game over so
|
|
if (n_element == f_contents.size() - 1)
|
|
break;
|
|
|
|
QStringList sub_elements = f_contents.at(n_element + 1).split("&");
|
|
if (sub_elements.size() < 2)
|
|
break;
|
|
|
|
char_type f_char;
|
|
f_char.name = sub_elements.at(0);
|
|
f_char.description = sub_elements.at(1);
|
|
//temporary. the CharsCheck packet sets this properly
|
|
f_char.taken = false;
|
|
|
|
++loaded_chars;
|
|
|
|
w_lobby->set_loading_text("Loading chars:\n" + QString::number(loaded_chars) + "/" + QString::number(char_list_size));
|
|
|
|
w_courtroom->append_char(f_char);
|
|
//qDebug() << "appended " << f_char.name << " to char_list";
|
|
}
|
|
|
|
if (loaded_chars < char_list_size)
|
|
{
|
|
QString next_packet_number = QString::number(((loaded_chars - 1) / 10) + 1);
|
|
send_server_packet(new AOPacket("AN#" + next_packet_number + "#%"));
|
|
}
|
|
|
|
else
|
|
{
|
|
if (evidence_list_size == 0)
|
|
send_server_packet(new AOPacket("AM#0#%"));
|
|
else
|
|
send_server_packet(new AOPacket("AE#0#%"));
|
|
}
|
|
}
|
|
else if (header == "EI"){
|
|
if (!courtroom_constructed)
|
|
return;
|
|
|
|
|
|
// +1 because evidence starts at 1 rather than 0 for whatever reason
|
|
//enjoy fanta
|
|
if (f_contents.at(0).toInt() != loaded_evidence + 1)
|
|
return;
|
|
|
|
if (f_contents.size() < 2)
|
|
return;
|
|
|
|
QStringList sub_elements = f_contents.at(1).split("&");
|
|
if (sub_elements.size() < 4)
|
|
return;
|
|
|
|
evi_type f_evi;
|
|
f_evi.name = sub_elements.at(0);
|
|
f_evi.description = sub_elements.at(1);
|
|
//no idea what the number at position 2 is. probably an identifier?
|
|
f_evi.image = sub_elements.at(3);
|
|
|
|
++loaded_evidence;
|
|
|
|
w_lobby->set_loading_text("Loading evidence:\n" + QString::number(loaded_evidence) + "/" + QString::number(evidence_list_size));
|
|
|
|
w_courtroom->append_evidence(f_evi);
|
|
|
|
if (loaded_evidence < evidence_list_size)
|
|
{
|
|
qDebug() << "loaded evidence: " << loaded_evidence;
|
|
QString next_packet_number = QString::number(loaded_evidence);
|
|
send_server_packet(new AOPacket("AE#" + next_packet_number + "#%"));
|
|
}
|
|
else
|
|
{
|
|
send_server_packet(new AOPacket("AM#0#%"));
|
|
}
|
|
}
|
|
else if (header == "EM")
|
|
{
|
|
if (!courtroom_constructed)
|
|
return;
|
|
|
|
for (int n_element = 0 ; n_element < f_contents.size() ; n_element += 2)
|
|
{
|
|
if (f_contents.at(n_element).toInt() != loaded_music)
|
|
break;
|
|
|
|
if (n_element == f_contents.size() - 1)
|
|
break;
|
|
|
|
QString f_music = f_contents.at(n_element + 1);
|
|
|
|
++loaded_music;
|
|
|
|
w_lobby->set_loading_text("Loading music:\n" + QString::number(loaded_music) + "/" + QString::number(music_list_size));
|
|
|
|
w_courtroom->append_music(f_music);
|
|
}
|
|
|
|
//apparently we need to intentionally send another AM packet to get onwards in the loading process
|
|
//in spite of the fact that we actually received all the music
|
|
//enjoy fanta
|
|
//if (loaded_music < music_list_size)
|
|
//{
|
|
QString next_packet_number = QString::number(((loaded_music - 1) / 10) + 1);
|
|
send_server_packet(new AOPacket("AM#" + next_packet_number + "#%"));
|
|
//}
|
|
}
|
|
if (header == "CharsCheck")
|
|
{
|
|
for (int n_char = 0 ; n_char < f_contents.size() ; ++n_char)
|
|
{
|
|
if (f_contents.at(n_char) == "-1")
|
|
w_courtroom->set_taken(n_char, true);
|
|
else
|
|
w_courtroom->set_taken(n_char, false);
|
|
}
|
|
}
|
|
if (header == "DONE")
|
|
{
|
|
if (!courtroom_constructed)
|
|
return;
|
|
|
|
w_courtroom->set_char_select_page();
|
|
|
|
w_courtroom->show();
|
|
|
|
destruct_lobby();
|
|
}
|
|
}
|
|
|
|
void AOApplication::send_ms_packet(AOPacket *p_packet)
|
|
{
|
|
p_packet->net_encode();
|
|
|
|
QString f_packet = p_packet->to_string();
|
|
|
|
net_manager->ship_ms_packet(f_packet);
|
|
|
|
qDebug() << "S(ms):" << f_packet;
|
|
|
|
delete p_packet;
|
|
}
|
|
|
|
void AOApplication::send_server_packet(AOPacket *p_packet)
|
|
{
|
|
p_packet->net_encode();
|
|
|
|
QString f_packet = p_packet->to_string();
|
|
|
|
if (encryption_needed)
|
|
{
|
|
qDebug() << "S(e):" << f_packet;
|
|
|
|
p_packet->encrypt_header(s_decryptor);
|
|
f_packet = p_packet->to_string();
|
|
}
|
|
else
|
|
{
|
|
qDebug() << "S:" << f_packet;
|
|
}
|
|
|
|
net_manager->ship_server_packet(f_packet);
|
|
|
|
delete p_packet;
|
|
}
|