#include "registration_thread.hpp"

#include "connection.hpp"
#include "ircmsg.hpp"
#include "sasl_mechanism.hpp"

#include <memory>
#include <unordered_map>
#include <unordered_set>

RegistrationThread::RegistrationThread(
    Connection& connection,
    const Settings &settings,
    std::shared_ptr<SelfThread> self
)
    : connection_{connection}
    , settings_{settings}
    , self_{std::move(self)}
{
}

auto RegistrationThread::on_connect() -> void
{
    connection_.send_cap_ls();
    connection_.send_pass(settings_.password);
    connection_.send_user(settings_.username, settings_.realname);
    connection_.send_nick(settings_.nickname);
}

auto RegistrationThread::send_req() -> void
{
    std::string request;
    std::vector<char const*> want {
        "account-notify",
        "account-tag",
        "batch",
        "chghost",
        "draft/chathistory",
        "extended-join",
        "invite-notify",
        "server-time",
        "setname",
        "soju.im/no-implicit-names",
        "solanum.chat/identify-msg",
        "solanum.chat/oper",
        "solanum.chat/realhost",
    };

    if (settings_.sasl_mechanism == "PLAIN") {
        want.push_back("sasl");
    }

    for (auto const cap : want)
    {
        if (caps.contains(cap))
        {
            request.append(cap);
            request.push_back(' ');
            outstanding.insert(cap);
        }
    }

    if (not outstanding.empty())
    {
        request.pop_back();
        connection_.send_cap_req(request);

        listen_for_cap_ack();
    }
    else
    {
        connection_.send_cap_end();
    }
}

auto RegistrationThread::on_msg_cap_ack(IrcMsg const& msg) -> void
{
    auto in = std::istringstream{std::string{msg.args[2]}};
    std::for_each(
        std::istream_iterator<std::string>{in},
        std::istream_iterator<std::string>{},
        [this](std::string x) {
            outstanding.erase(x);
        }
    );
    if (outstanding.empty())
    {
        message_handle_.disconnect();
        
        if (settings_.sasl_mechanism.empty()) {
            connection_.send_cap_end();
        } else {
            self_->start_sasl(std::make_unique<SaslPlain>(settings_.sasl_authcid, settings_.sasl_authzid, settings_.sasl_password));
            connection_.sig_ircmsg.connect_extended([thread = shared_from_this()](auto &slot, auto cmd, auto &msg) {
                switch (cmd) {
                    default: break;
                    case IrcCommand::RPL_SASLSUCCESS:
                    case IrcCommand::ERR_SASLFAIL:
                        thread->connection_.send_cap_end();
                        slot.disconnect();
                }
            });
        }
    }
}

auto RegistrationThread::on_msg_cap_ls(IrcMsg const& msg) -> void
{
    std::string_view const* kvs;
    bool last;

    if (3 == msg.args.size())
    {
        kvs = &msg.args[2];
        last = true;
    }
    else if (4 == msg.args.size() && "*" == msg.args[2])
    {
        kvs = &msg.args[3];
        last = false;
    }
    else
    {
        return;
    }

    auto in = std::istringstream{std::string{*kvs}};

    std::for_each(
        std::istream_iterator<std::string>{in},
        std::istream_iterator<std::string>{},
        [this](std::string x) {
            auto const eq = x.find('=');
            if (eq == x.npos)
            {
                caps.emplace(x, std::string{});
            }
            else
            {
                caps.emplace(std::string{x, 0, eq}, std::string{x, eq+1, x.npos});
            }
        }
    );

    if (last)
    {
        message_handle_.disconnect();
        send_req();
    }
}

auto RegistrationThread::start(
    Connection& connection,
    const Settings &settings,
    std::shared_ptr<SelfThread> self
) -> std::shared_ptr<RegistrationThread>
{
    auto const thread = std::make_shared<RegistrationThread>(connection, std::move(settings), std::move(self));

    thread->listen_for_cap_ls();

    thread->connect_handle_ = connection.sig_connect.connect([thread]()
    {
        thread->connect_handle_.disconnect();
        thread->on_connect();
    });

    return thread;
}

auto RegistrationThread::listen_for_cap_ack() -> void
{
    message_handle_ = connection_.sig_ircmsg.connect([thread = shared_from_this()](IrcCommand cmd, IrcMsg const& msg)
    {
        if (IrcCommand::CAP == cmd && msg.args.size() >= 2 && "ACK" == msg.args[1])
        {
            thread->on_msg_cap_ack(msg);
        }
    });
}

auto RegistrationThread::listen_for_cap_ls() -> void
{
    message_handle_ = connection_.sig_ircmsg.connect([thread = shared_from_this()](IrcCommand cmd, IrcMsg const& msg)
    {
        if (IrcCommand::CAP == cmd && msg.args.size() >= 2 && "LS" == msg.args[1])
        {
            thread->on_msg_cap_ls(msg);
        }
    });
}