#pragma once
/*=========================================================================

 medInria

 Copyright (c) INRIA 2013 - 2021. All rights reserved.
 See LICENSE.txt for details.

  This software is distributed WITHOUT ANY WARRANTY; without even
  the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR
  PURPOSE.

=========================================================================*/

#include <medSourceHandler.h>
#include <medSourceModel.h>

#include <medCoreExport.h>
#include <QMap>
#include <QList>
#include <QAbstractItemModelTester>
#include <QMutex>

#include <medDataIndex.h>
#include <medAbstractData.h>
#include <medAsyncRequest.h>
#include <medDefaultWritingPolicy.h>
#include <medVirtualRepresentation.h>
#include <medSourceHandler.h>

#include <medUtilitiesFiles.h>
#include <dtkCoreSupport/dtkSmartPointer.h>


#define REQUEST_TIME_OUT 120
#define REQUEST_TIME_OUT_PULLING (REQUEST_TIME_OUT/20 ? REQUEST_TIME_OUT/20 : 1)

class MEDCORE_EXPORT medDataHub : public QObject
{
    Q_OBJECT

public:
    static medDataHub* instance(QObject *parent = nullptr);
    ~medDataHub();

    QString getDataName(medDataIndex const & index);

    medAbstractData * getData(medDataIndex const & index);
    QList<medAbstractData *> getDataList(medDataIndex const & index);
    medSourceHandler::datasetAttributes getMetaData(medDataIndex const & index);
    medSourceHandler::datasetAttributes getOptionalMetaData(medDataIndex const & index);


    bool saveData(medAbstractData *pi_pData, QString const &pi_baseName, QStringList &pio_uri);
    bool getChildrenNames(medDataIndex index, QStringList &names);
    bool createPath(QString pi_sourceId, QStringList pi_folders, QStringList &po_uri, QMap<int, QString> pi_knownKeys = QMap<int, QString>());

    bool writeResults(QString pi_sourceId, medAbstractData * pi_pData, QStringList pi_UriOfRelatedData, QString pi_basePath, medWritingPolicyData & pi_writingPolicyData, medAbstractWritingPolicy * pi_pWritingPolicy);
    QUuid writeResultsHackV3(medAbstractData &data, bool originSrc); //To Adapt

    // bool copyData(QString path, medDataIndex destinationIndex);
    bool copyData(medDataIndex indexToCpy, medDataIndex destinationIndex);
	bool fetchData(medDataIndex const & index);
	bool pushData(medDataIndex const & index);


    QList<medAbstractData *> loadDataFromPathAsIndex(medDataIndex index, QUuid uuid = QUuid());
    
    QList< medDataIndex > getSubData(medDataIndex const & index);
    int getDataType(medDataIndex const & index);

    void getDataTypeFS(const medDataIndex & index, int &iRes);

    // ////////////////////////////////////////////////////////////////////////////////////////////
    // Members functions for GUI    
    // ------------  Members functions to deal with datamodel                   Advanced Accessors
    QList<medSourceModel*> models(); // rediscute de son nom
    medSourceModel* getModel(QString const & pi_sourceInstanceId); //also used internally
    void expandAll(const QString &sourceInstanceId);
    void sourceIsOnline(QString sourceIntanceId);


    void setVirtualRepresentation(medVirtualRepresentation * virtRep) { m_virtualRepresentation = virtRep; }
    medVirtualRepresentation * getVirtualRepresentation() { return m_virtualRepresentation; }



public slots:
   void addSource(QString const & pi_sourceId);
   void removeSource(QString const & pi_sourceId);
   void refresh(medDataIndex pi_index); //TODO is it utile  //uri -> sourceInstanceId/IdLevel1/IdLevel.../IdLevelN
   void unloadData(QObject *obj); /* REDO */
   int  waitGetAsyncData(const QString &sourceId, int rqstId);
   void progress(const QString &sourceId, int rqstId, medAbstractSource::eRequestStatus status);
   void sourceOnlineStatus(const QString &sourceId, bool status);

   void timeOutWatcher();

   void loadDataFromLocalFileSystem(QString const path, QUuid uuid = QUuid());

signals:
    void abortRequest  (int); //abort the requestId
    void getAsyncStatus(medAbstractSource* , int, medAbstractSource::eRequestStatus);
    void sourceAdded   (QString /*sourceInstanceId*/);
    void sourceRemoved (QString /*sourceInstanceId*/);
    void sourceVisibled (QString /*sourceInstanceId*/, bool checked);    
    void sourceVisibility (QString /*sourceInstanceId*/);
    void dataLoaded    (medDataIndex);
    void dataExported  (medAbstractData *, QString);

private:
    medDataHub(QObject *parent = nullptr);
	medAbstractData * variantToMedAbstractData(QVariant &data, const medDataIndex & index);

    QVariant prepareDataToWrite(QString &sourceId, medAbstractData * &pi_pData, QStringList & pio_uri);
    bool warpAddAsync(medAbstractSource::levelMinimalEntries &minimalEntries, QStringList & pio_uri, medSourceModel * pModel, unsigned int uiLevel, QString &parentKey, medAbstractData * pi_pData, QVariant &data);

    void getDirectData(const medDataIndex & index, medAbstractData * &pDataRes);
    void getAsyncData (const medDataIndex & index, medAbstractData * &pDataRes);
    static QString getTmpUuid();
    QString convertToPath(QStringList pi_uri);


    void addRequest(QString sourceId, int requestId, asyncRequest & rqst);
    void removeRequest(QString sourceId, int rqstId);

    void releaseRequest();

private:
    medSourceHandler * m_sourcesHandler;
    QMap< QString, medSourceModel*> m_sourceIdToModelMap;

    QMutex m_mapsRequestMutex;
    QMap< QString /*sourceId*/, QMap<int/*requestId*/, asyncRequest> > m_requestsMap;
    QMap< asyncRequest, std::shared_ptr<medNotif>> m_rqstToNotifMap;
	
    QTimer m_clock;

    medVirtualRepresentation * m_virtualRepresentation;
    QMap<medDataIndex, dtkSmartPointer<medAbstractData> > m_IndexToData;
    static medDataHub * s_instance;

};