#include "Network/NetworkController.h"

#include <QMutex>
#include <QNetworkAccessManager>
#include <QNetworkReply>
#include <QThread>

Q_LOGGING_CATEGORY(LOG_NetworkController, "NetworkController")

struct NetworkController::NetworkControllerPrivate {
    explicit NetworkControllerPrivate(NetworkController *parent)
            : m_WorkingMutex{}, m_AccessManager{std::make_unique<QNetworkAccessManager>()}
    {
    }
    QMutex m_WorkingMutex;

    std::unique_ptr<QNetworkAccessManager> m_AccessManager{nullptr};
};

NetworkController::NetworkController(QObject *parent)
        : QObject(parent), impl{spimpl::make_unique_impl<NetworkControllerPrivate>(this)}
{

}

void NetworkController::execute(QNetworkReply *reply)
{
    auto replyReadyToRead =[reply, this] () {
           auto content = reply->readAll();

           emit this->replyToRead();
       };

    connect(impl->m_Reply, &QNetworkReply::finished, this, replyReadyToRead);
    connect(impl->m_Reply, &QNetworkReply::aboutToClose, this, replyReadyToRead);
}

void NetworkController::initialize()
{
    qCDebug(LOG_NetworkController()) << tr("NetworkController init") << QThread::currentThread();
    impl->m_WorkingMutex.lock();
    qCDebug(LOG_NetworkController()) << tr("NetworkController init END");
}

void NetworkController::finalize()
{
    impl->m_WorkingMutex.unlock();
}

void NetworkController::waitForFinish()
{
    QMutexLocker locker{&impl->m_WorkingMutex};
}