#include "DataSource/DataSourceController.h"
#include "DataSource/DataSourceItem.h"

#include <Data/IDataProvider.h>

#include <QMutex>
#include <QThread>

#include <QDir>
#include <QStandardPaths>

Q_LOGGING_CATEGORY(LOG_DataSourceController, "DataSourceController")

class DataSourceController::DataSourceControllerPrivate {
public:
    QMutex m_WorkingMutex;
    /// Data sources registered
    QHash<QUuid, QString> m_DataSources;
    /// Data sources structures
    std::map<QUuid, std::unique_ptr<DataSourceItem> > m_DataSourceItems;
    /// Data providers registered
    /// @remarks Data providers are stored as shared_ptr as they can be sent to a variable and
    /// continue to live without necessarily the data source controller
    std::map<QUuid, std::shared_ptr<IDataProvider> > m_DataProviders;
};

DataSourceController::DataSourceController(QObject *parent)
        : impl{spimpl::make_unique_impl<DataSourceControllerPrivate>()}
{
    qCDebug(LOG_DataSourceController()) << tr("DataSourceController construction")
                                        << QThread::currentThread();
}

DataSourceController::~DataSourceController()
{
    qCDebug(LOG_DataSourceController()) << tr("DataSourceController destruction")
                                        << QThread::currentThread();
    this->waitForFinish();
}

QUuid DataSourceController::registerDataSource(const QString &dataSourceName) noexcept
{
    auto dataSourceUid = QUuid::createUuid();
    impl->m_DataSources.insert(dataSourceUid, dataSourceName);

    return dataSourceUid;
}

void DataSourceController::setDataSourceItem(
    const QUuid &dataSourceUid, std::unique_ptr<DataSourceItem> dataSourceItem) noexcept
{
    if (!dataSourceItem) {
        qCWarning(LOG_DataSourceController())
            << tr("Data source item can't be registered (null item)");
        return;
    }

    if (impl->m_DataSources.contains(dataSourceUid)) {
        // The data provider is implicitly converted to a shared_ptr
        impl->m_DataSourceItems.insert(std::make_pair(dataSourceUid, std::move(dataSourceItem)));

        // Retrieves the data source item to emit the signal with it
        auto it = impl->m_DataSourceItems.find(dataSourceUid);
        if (it != impl->m_DataSourceItems.end()) {
            emit dataSourceItemSet(it->second.get());
        }
    }
    else {
        qCWarning(LOG_DataSourceController()) << tr("Can't set data source item for uid %1 : no "
                                                    "data source has been registered with the uid")
                                                     .arg(dataSourceUid.toString());
    }
}

void DataSourceController::setDataProvider(const QUuid &dataSourceUid,
                                           std::unique_ptr<IDataProvider> dataProvider) noexcept
{
    if (impl->m_DataSources.contains(dataSourceUid)) {
        impl->m_DataProviders.insert(std::make_pair(dataSourceUid, std::move(dataProvider)));
    }
    else {
        qCWarning(LOG_DataSourceController()) << tr("Can't set data provider for uid %1 : no data "
                                                    "source has been registered with the uid")
                                                     .arg(dataSourceUid.toString());
    }
}

void DataSourceController::loadProductItem(const QUuid &dataSourceUid,
                                           const DataSourceItem &productItem) noexcept
{
    if (productItem.type() == DataSourceItemType::PRODUCT) {
        /// Retrieves the data provider of the data source (if any)
        auto it = impl->m_DataProviders.find(dataSourceUid);
        auto dataProvider = (it != impl->m_DataProviders.end()) ? it->second : nullptr;

        /// @todo retrieve timerange, and pass it to the signal
        emit variableCreationRequested(productItem.name(), dataProvider);
    }
    else {
        qCWarning(LOG_DataSourceController()) << tr("Can't load an item that is not a product");
    }
}

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

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

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