/*  Starshatter: The Open Source Project
    Copyright (c) 2021-2024, Starshatter: The Open Source Project Contributors
    Copyright (c) 2011-2012, Starshatter OpenSource Distribution Contributors
    Copyright (c) 1997-2006, Destroyer Studios LLC.

    AUTHOR:       John DiCamillo


    OVERVIEW
    ========
    Client for Starshatter.com GameNet Broker
*/


#include "NetBrokerClient.h"

#include "HttpClient.h"
#include "HttpServlet.h"
#include "NetLayer.h"

#include "Game.h"
#include "VersionInfo.h"

const char* HOSTNAME = "www.starshatter.com";
const WORD  HTTPPORT = 80;

bool NetBrokerClient::broker_available = false;
bool NetBrokerClient::broker_found     = false;

// +--------------------------------------------------------------------+

bool
NetBrokerClient::GameOn(const char* name,
const char* type,
const char* addr,
WORD        port,
const char* password)
{
    bool        result = false;

    if (!broker_available)
    return result;

    Text        msg;
    char        buffer[8];
    NetAddr     broker(HOSTNAME, HTTPPORT);

    if (broker.IPAddr() == 0)
    return result;

    sprintf_s(buffer, "%d", port);

    msg = "GET http://";
    msg += HOSTNAME;
    msg += "/GameNet/GameOn.php?name=";
    msg += HttpRequest::EncodeParam(name);
    msg += "&addr=";
    msg += HttpRequest::EncodeParam(addr);
    msg += "&game=";
    msg += HttpRequest::EncodeParam(type);
    msg += "&vers=";
    msg += HttpRequest::EncodeParam(versionInfo);
    msg += "&port=";
    msg += buffer;
    msg += "&pass=";
    msg += HttpRequest::EncodeParam(password);
    msg += " HTTP/1.1\n\n";

    HttpClient  client(broker);
    HttpRequest request(msg);
    request.SetHeader("Host", HOSTNAME);

    HttpResponse* response = client.DoRequest(request);

    if (response && response->Status() == 200) {
        broker_found = true;
        result       = true;
    }
    else {
        ::Print("NetBrokerClient unable to contact GameNet!\n");

        if (response) {
            ::Print("  Response Status:  %d\n", response->Status());
            ::Print("  Response Content: %s\n", response->Content().data());
        }
        else {
            ::Print("  No response.\n");
        }

        if (!broker_found)
        broker_available = false;
    }

    delete response;
    return result;
}

bool
NetBrokerClient::GameList(const char* type, List<NetServerInfo>& server_list)
{
    bool result = false;

    if (!broker_available)
    return result;

    Text        msg;
    NetAddr     broker(HOSTNAME, HTTPPORT);

    if (broker.IPAddr() == 0)
    return result;

    msg = "GET http://";
    msg += HOSTNAME;
    msg += "/GameNet/GameList.php?game=";
    msg += HttpRequest::EncodeParam(type);
    msg += "&vers=";
    msg += HttpRequest::EncodeParam(versionInfo);
    msg += " HTTP/1.1\n\n";

    HttpClient  client(broker);
    HttpRequest request(msg);
    request.SetHeader("Host", HOSTNAME);

    HttpResponse* response = client.DoRequest(request);

    if (response && response->Status() == 200) {
        result = true;

        Text name;
        Text type;
        Text addr;
        int  port;
        Text pass;
        Text vers;
        char buff[1024];

        const char* p = response->Content();

        // skip size
        while (*p && strncmp(p, "name:", 5))
        p++;

        while (*p) {
            if (!strncmp(p, "name:", 5)) {
                p += 5;
                ZeroMemory(buff, sizeof(buff));
                char* d = buff;
                while (*p && *p != '\n') *d++ = *p++;
                if (*p) p++;

                name = buff;
            }
            else if (!strncmp(p, "addr:", 5)) {
                p += 5;
                ZeroMemory(buff, sizeof(buff));
                char* d = buff;
                while (*p && *p != '\n') *d++ = *p++;
                if (*p) p++;

                addr = buff;
            }
            else if (!strncmp(p, "port:", 5)) {
                p += 5;
                ZeroMemory(buff, sizeof(buff));
                char* d = buff;
                while (*p && *p != '\n') *d++ = *p++;
                if (*p) p++;

                sscanf_s(buff, "%d", &port);
            }
            else if (!strncmp(p, "pass:", 5)) {
                p += 5;
                ZeroMemory(buff, sizeof(buff));
                char* d = buff;
                while (*p && *p != '\n') *d++ = *p++;
                if (*p) p++;

                pass = buff;
            }
            else if (!strncmp(p, "game:", 5)) {
                p += 5;
                ZeroMemory(buff, sizeof(buff));
                char* d = buff;
                while (*p && *p != '\n') *d++ = *p++;
                if (*p) p++;

                type = buff;
                type.setSensitive(false);

                if (type.contains("lan"))
                type = "LAN";
                else
                type = "Public";
            }
            else if (!strncmp(p, "vers:", 5)) {
                p += 5;
                ZeroMemory(buff, sizeof(buff));
                char* d = buff;
                while (*p && *p != '\n') *d++ = *p++;
                if (*p) p++;

                vers = buff;
            }
            else if (!strncmp(p, "time:", 5)) {
                while (*p && *p != '\n') p++;
                if (*p) p++;
            }

            else if (!strncmp(p, "###", 3)) {
                NetServerInfo* server = new NetServerInfo;
                server->name     = name;
                server->hostname = addr;
                server->type     = type;
                server->addr     = NetAddr(addr, port);
                server->port     = port;
                server->password = pass;
                server->version  = vers;
                server->save     = false;

                server_list.append(server);

                while (*p && strncmp(p, "name:", 5))
                p++;
            }
            else {
                while (*p && *p != '\n') p++;
                if (*p) p++;
            }
        }
    }
    else if (!broker_found) {
        broker_available = false;
    }

    delete response;
    return result;
}