//////////////////////////////////////////////////////////////////////////////////////
//    akashi - a server for Attorney Online 2                                       //
//    Copyright (C) 2020  scatterflower                                             //
//                                                                                  //
//    This program is free software: you can redistribute it and/or modify          //
//    it under the terms of the GNU Affero General Public License as                //
//    published by the Free Software Foundation, either version 3 of the            //
//    License, or (at your option) any later version.                               //
//                                                                                  //
//    This program 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 Affero General Public License for more details.                           //
//                                                                                  //
//    You should have received a copy of the GNU Affero General Public License      //
//    along with this program.  If not, see <https://www.gnu.org/licenses/>.        //
//////////////////////////////////////////////////////////////////////////////////////
#include "include/server.h"

Server::Server(int p_port, int p_ws_port, QObject* parent) : QObject(parent)
{
    server = new QTcpServer(this);
    connect(server, SIGNAL(newConnection()), this, SLOT(clientConnected()));

    port = p_port;
    ws_port = p_ws_port;

    player_count = 0;
}

void Server::start()
{
    if (!server->listen(QHostAddress::Any, port)) {
        // TODO: signal server start failed
        qDebug() << "Server error:" << server->errorString();
    }
    else {
        // TODO: signal server start success
        qDebug() << "Server listening on" << port;
    }

    proxy = new WSProxy(port, ws_port, this);
    if(ws_port != -1)
        proxy->start();

    QFile char_list("config/characters.txt");
    char_list.open(QIODevice::ReadOnly | QIODevice::Text);
    while (!char_list.atEnd()) {
        characters.append(char_list.readLine().trimmed());
    }
    char_list.close();

    QFile music_file("config/music.txt");
    music_file.open(QIODevice::ReadOnly | QIODevice::Text);
    while (!music_file.atEnd()) {
        music_list.append(music_file.readLine().trimmed());
    }
    music_file.close();
    if(music_list[0].contains(".")) // Add a default category if none exists
        music_list.insert(0, "==Music==");

    // TODO: add verification that this exists
    QSettings areas_ini("config/areas.ini", QSettings::IniFormat);
    area_names = areas_ini.childGroups();
    for (int i = 0; i < area_names.length(); i++) {
        QString area_name = area_names[i];
        areas.insert(i, new AreaData(characters, area_name, i));
        areas_ini.beginGroup(area_name);
        // TODO: more area config
        areas[i]->background = areas_ini.value("background", "gs4").toString();
        areas_ini.endGroup();
        qDebug() << "Added area" << area_name;
    }
}

void Server::clientConnected()
{
    QTcpSocket* socket = server->nextPendingConnection();
    AOClient* client = new AOClient(this, socket, this);
    clients.append(client);
    connect(socket, &QTcpSocket::disconnected, client,
            &AOClient::clientDisconnected);
    connect(socket, &QTcpSocket::disconnected, this, [=] {
        qDebug() << "removed client" << client->getIpid();
        clients.removeAll(client);
        client->deleteLater();
    });
    connect(socket, &QTcpSocket::readyRead, client, &AOClient::clientData);

    AOPacket decryptor(
        "decryptor", {"NOENCRYPT"}); // This is the infamous workaround for
                                     // tsuserver4. It should disable fantacrypt
                                     // completely in any client 2.4.3 or newer
    client->sendPacket(decryptor);

    qDebug() << client->remote_ip.toString() << "connected";
}

void Server::updateCharsTaken(AreaData* area)
{
    QStringList chars_taken;
    for (QString cur_char : area->characters_taken.keys()) {
        chars_taken.append(area->characters_taken.value(cur_char)
                               ? QStringLiteral("-1")
                               : QStringLiteral("0"));
    }

    AOPacket response_cc("CharsCheck", chars_taken);
    broadcast(response_cc, area->index);
}

void Server::broadcast(AOPacket packet, int area_index)
{
    for (AOClient* client : clients) {
        if (client->current_area == area_index)
            client->sendPacket(packet);
    }
}

void Server::broadcast(AOPacket packet)
{
    for (AOClient* client : clients) {
        client->sendPacket(packet);
    }
}

AOClient* Server::getClient(QString ipid)
{
    for (AOClient* client : clients) {
        if (client->getIpid() == ipid)
            return client;
    }
    return nullptr;
}

Server::~Server()
{
    for (AOClient* client : clients) {
        client->cleanup();
        client->deleteLater();
    }
    server->deleteLater();
    proxy->deleteLater();
}