/* XMRig
 * Copyright (c) 2018-2025 SChernykh   <https://github.com/SChernykh>
 * Copyright (c) 2016-2025 XMRig       <https://github.com/xmrig>, <support@xmrig.com>
 *
 *   This program is free software: you can redistribute it and/or modify
 *   it under the terms of the GNU 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 General Public License for more details.
 *
 *   You should have received a copy of the GNU General Public License
 *   along with this program. If not, see <http://www.gnu.org/licenses/>.
 */

#include <uv.h>

#include "base/net/dns/DnsUvBackend.h"
#include "base/kernel/interfaces/IDnsListener.h"
#include "base/net/dns/DnsConfig.h"
#include "base/tools/Chrono.h"


namespace xmrig {


static Storage<DnsUvBackend> *storage = nullptr;


Storage<DnsUvBackend> &DnsUvBackend::getStorage()
{
    if (storage == nullptr) {
        storage = new Storage<DnsUvBackend>();
    }

    return *storage;
}


static addrinfo hints{};


} // namespace xmrig


xmrig::DnsUvBackend::DnsUvBackend()
{
    if (!hints.ai_protocol) {
        hints.ai_family     = AF_UNSPEC;
        hints.ai_socktype   = SOCK_STREAM;
        hints.ai_protocol   = IPPROTO_TCP;
    }

    m_key = getStorage().add(this);
}


xmrig::DnsUvBackend::~DnsUvBackend()
{
    assert(storage);

    storage->release(m_key);

    if (storage->isEmpty()) {
        delete storage;
        storage = nullptr;
    }
}


void xmrig::DnsUvBackend::resolve(const String &host, const std::weak_ptr<IDnsListener> &listener, const DnsConfig &config)
{
    m_queue.emplace_back(listener);

    if (Chrono::currentMSecsSinceEpoch() - m_ts <= config.ttl()) {
        return notify();
    }

    if (m_req) {
        return;
    }

    m_ai_family = config.ai_family();

    if (!resolve(host)) {
        notify();
    }
}


bool xmrig::DnsUvBackend::resolve(const String &host)
{
    m_req = std::make_shared<uv_getaddrinfo_t>();
    m_req->data = getStorage().ptr(m_key);

    m_status = uv_getaddrinfo(uv_default_loop(), m_req.get(), DnsUvBackend::onResolved, host.data(), nullptr, &hints);

    return m_status == 0;
}


void xmrig::DnsUvBackend::notify()
{
    const char *error = m_status < 0 ? uv_strerror(m_status) : nullptr;

    for (const auto &l : m_queue) {
        auto listener = l.lock();
        if (listener) {
            listener->onResolved(m_records, m_status, error);
        }
    }

    m_queue.clear();
    m_req.reset();
}


void xmrig::DnsUvBackend::onResolved(int status, addrinfo *res)
{
    m_status = status;
    m_ts     = Chrono::currentMSecsSinceEpoch();

    if (m_status < 0) {
        m_records = {};

        return notify();
    }

    m_records = { res, m_ai_family };

    if (m_records.isEmpty()) {
        m_status = UV_EAI_NONAME;
    }

    notify();
}


void xmrig::DnsUvBackend::onResolved(uv_getaddrinfo_t *req, int status, addrinfo *res)
{
    auto *backend = getStorage().get(req->data);
    if (backend) {
        backend->onResolved(status, res);
    }

    uv_freeaddrinfo(res);
}