HG_REPOSITORIES/LPP/SciQLOP_Repos/SciQLop Files · core/src/Catalogue/CatalogueController.cpp

Time Zone Mode + prepare graph mode

trabillard - - Load All Authors

File last commit:

r1128:043d6b3a4bf6


                r1138:f7fe3621eadc

Download file

             CatalogueController.cpp
        
                    162 lines
            
             | 5.0 KiB
            
                | text/x-c
            
             |
                CppLexer
            
             / core / src / Catalogue / CatalogueController.cpp
          
                    History
                
                 |
                  Source
                 | Raw
                 |Copy content
                 |Copy permalink

        perrinel
    
correction of merge

              r1059
            
      #include <Catalogue/CatalogueController.h>

      #include <Variable/Variable.h>

      #include <CatalogueDao.h>

        perrinel
    
Add retrieve events impl

              r1125
            
      #include <ComparaisonPredicate.h>

      #include <CompoundPredicate.h>

      #include <DBCatalogue.h>

      #include <DBEvent.h>

      #include <DBTag.h>

      #include <IRequestPredicate.h>

        perrinel
    
correction of merge

              r1059
            
      #include <QMutex>

      #include <QThread>

      #include <QDir>

      #include <QStandardPaths>

      Q_LOGGING_CATEGORY(LOG_CatalogueController, "CatalogueController")

        trabillard
    
Fix the loading of the default database

              r1126
            
      namespace {

        perrinel
    
Add retrieve events impl

              r1125
            
      static QString REPOSITORY_WORK_SUFFIX = QString{"Work"};

      }

        perrinel
    
correction of merge

              r1059
            
      class CatalogueController::CatalogueControllerPrivate {

      public:

          QMutex m_WorkingMutex;

          CatalogueDao m_CatalogueDao;

        perrinel
    
Add retrieve events impl

              r1125
            
          std::list<QString> m_RepositoryList;

        perrinel
    
correction of merge

              r1059
            
      };

      CatalogueController::CatalogueController(QObject *parent)

              : impl{spimpl::make_unique_impl<CatalogueControllerPrivate>()}

      {

          qCDebug(LOG_CatalogueController()) << tr("CatalogueController construction")

                                             << QThread::currentThread();

      }

      CatalogueController::~CatalogueController()

      {

          qCDebug(LOG_CatalogueController()) << tr("CatalogueController destruction")

                                             << QThread::currentThread();

          this->waitForFinish();

      }

        perrinel
    
Add retrieve events impl

              r1125
            
      void CatalogueController::addDB(const QString &dbPath)

      {

          QDir dbDir(dbPath);

          if (dbDir.exists()) {

              auto dirName = dbDir.dirName();

              if (std::find(impl->m_RepositoryList.cbegin(), impl->m_RepositoryList.cend(), dirName)

                  != impl->m_RepositoryList.cend()) {

                  qCCritical(LOG_CatalogueController())

                      << tr("Impossible to addDB that is already loaded");

              }

              if (!impl->m_CatalogueDao.addDB(dbPath, dirName)) {

                  qCCritical(LOG_CatalogueController())

                      << tr("Impossible to addDB %1 from %2 ").arg(dirName, dbPath);

              }

        trabillard
    
Fix the loading of the default database

              r1126
            
              else {

                  impl->m_RepositoryList.push_back(dirName);

        perrinel
    
Add retrieve events impl

              r1125
            
              }

          }

          else {

              qCCritical(LOG_CatalogueController()) << tr("Impossible to addDB that not exists: ")

                                                    << dbPath;

          }

      }

      void CatalogueController::saveDB(const QString &destinationPath, const QString &repository)

      {

          if (!impl->m_CatalogueDao.saveDB(destinationPath, repository)) {

              qCCritical(LOG_CatalogueController())

                  << tr("Impossible to saveDB %1 from %2 ").arg(repository, destinationPath);

          }

      }

      std::list<std::shared_ptr<DBEvent> >

      CatalogueController::retrieveEvents(const QString &repository) const

      {

          auto eventsShared = std::list<std::shared_ptr<DBEvent> >{};

          auto events = impl->m_CatalogueDao.getEvents(repository);

          for (auto event : events) {

              eventsShared.push_back(std::make_shared<DBEvent>(event));

          }

          return eventsShared;

      }

      std::list<std::shared_ptr<DBEvent> > CatalogueController::retrieveAllEvents() const

      {

          auto eventsShared = std::list<std::shared_ptr<DBEvent> >{};

          for (auto repository : impl->m_RepositoryList) {

              eventsShared.splice(eventsShared.end(), retrieveEvents(repository));

          }

          return eventsShared;

      }

        trabillard
    
CatalogueController: add few basic methods + commit the one not yet implemented

              r1128
            
      std::list<std::shared_ptr<DBEvent> >

      CatalogueController::retrieveEventsFromCatalogue(const QString &repository,

                                                       std::shared_ptr<DBCatalogue> catalogue) const

      {

          auto eventsShared = std::list<std::shared_ptr<DBEvent> >{};

          auto events = impl->m_CatalogueDao.getCatalogueEvents(*catalogue);

          for (auto event : events) {

              eventsShared.push_back(std::make_shared<DBEvent>(event));

          }

          return eventsShared;

      }

      std::list<std::shared_ptr<DBCatalogue> >

      CatalogueController::getCatalogues(const QString &repository) const

      {

          auto cataloguesShared = std::list<std::shared_ptr<DBCatalogue> >{};

          auto catalogues = impl->m_CatalogueDao.getCatalogues(repository);

          for (auto catalogue : catalogues) {

              cataloguesShared.push_back(std::make_shared<DBCatalogue>(catalogue));

          }

          return cataloguesShared;

      }

        perrinel
    
correction of merge

              r1059
            
      void CatalogueController::initialize()

      {

          qCDebug(LOG_CatalogueController()) << tr("CatalogueController init")

                                             << QThread::currentThread();

          impl->m_WorkingMutex.lock();

          impl->m_CatalogueDao.initialize();

        trabillard
    
Fix the loading of the default database

              r1126
            
          auto defaultRepositoryLocation

              = QStandardPaths::writableLocation(QStandardPaths::AppDataLocation);

          QDir defaultRepositoryLocationDir;

          if (defaultRepositoryLocationDir.mkpath(defaultRepositoryLocation)) {

              defaultRepositoryLocationDir.cd(defaultRepositoryLocation);

              auto defaultRepository = defaultRepositoryLocationDir.absoluteFilePath(REPOSITORY_DEFAULT);

              qCInfo(LOG_CatalogueController())

                  << tr("Persistant data loading from: ") << defaultRepository;

        perrinel
    
Add retrieve events impl

              r1125
            
              this->addDB(defaultRepository);

          }

        trabillard
    
Fix the loading of the default database

              r1126
            
          else {

              qCWarning(LOG_CatalogueController())

                  << tr("Cannot load the persistent default repository from ")

                  << defaultRepositoryLocation;

          }

          qCDebug(LOG_CatalogueController()) << tr("CatalogueController init END");

        perrinel
    
correction of merge

              r1059
            
      }

      void CatalogueController::finalize()

      {

          impl->m_WorkingMutex.unlock();

      }

      void CatalogueController::waitForFinish()

      {

          QMutexLocker locker{&impl->m_WorkingMutex};

      }

	Site-wide shortcuts
/	Use quick search box
g h	Goto home page
g g	Goto my private gists page
g G	Goto my public gists page
g 0-9	Goto bookmarked items from 0-9
n r	New repository page
n g	New gist page

	Repositories
g s	Goto summary page
g c	Goto changelog page
g f	Goto files page
g F	Goto files page with file search activated
g p	Goto pull requests page
g o	Goto repository settings
g O	Goto repository access permissions settings
t s	Toggle sidebar on some pages

perrinel correction of merge	r1059	#include <Catalogue/CatalogueController.h>

		#include <Variable/Variable.h>

		#include <CatalogueDao.h>

perrinel Add retrieve events impl	r1125	#include <ComparaisonPredicate.h>
		#include <CompoundPredicate.h>
		#include <DBCatalogue.h>
		#include <DBEvent.h>
		#include <DBTag.h>
		#include <IRequestPredicate.h>

perrinel correction of merge	r1059	#include <QMutex>
		#include <QThread>

		#include <QDir>
		#include <QStandardPaths>

		Q_LOGGING_CATEGORY(LOG_CatalogueController, "CatalogueController")

trabillard Fix the loading of the default database	r1126	namespace {
perrinel Add retrieve events impl	r1125
		static QString REPOSITORY_WORK_SUFFIX = QString{"Work"};

		}

perrinel correction of merge	r1059	class CatalogueController::CatalogueControllerPrivate {
		public:
		QMutex m_WorkingMutex;
		CatalogueDao m_CatalogueDao;
perrinel Add retrieve events impl	r1125
		std::list<QString> m_RepositoryList;
perrinel correction of merge	r1059	};

		CatalogueController::CatalogueController(QObject *parent)
		: impl{spimpl::make_unique_impl<CatalogueControllerPrivate>()}
		{
		qCDebug(LOG_CatalogueController()) << tr("CatalogueController construction")
		<< QThread::currentThread();
		}

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

perrinel Add retrieve events impl	r1125	void CatalogueController::addDB(const QString &dbPath)
		{
		QDir dbDir(dbPath);
		if (dbDir.exists()) {
		auto dirName = dbDir.dirName();

		if (std::find(impl->m_RepositoryList.cbegin(), impl->m_RepositoryList.cend(), dirName)
		!= impl->m_RepositoryList.cend()) {
		qCCritical(LOG_CatalogueController())
		<< tr("Impossible to addDB that is already loaded");
		}

		if (!impl->m_CatalogueDao.addDB(dbPath, dirName)) {
		qCCritical(LOG_CatalogueController())
		<< tr("Impossible to addDB %1 from %2 ").arg(dirName, dbPath);
		}
trabillard Fix the loading of the default database	r1126	else {
		impl->m_RepositoryList.push_back(dirName);
perrinel Add retrieve events impl	r1125	}
		}
		else {
		qCCritical(LOG_CatalogueController()) << tr("Impossible to addDB that not exists: ")
		<< dbPath;
		}
		}

		void CatalogueController::saveDB(const QString &destinationPath, const QString &repository)
		{
		if (!impl->m_CatalogueDao.saveDB(destinationPath, repository)) {
		qCCritical(LOG_CatalogueController())
		<< tr("Impossible to saveDB %1 from %2 ").arg(repository, destinationPath);
		}
		}

		std::list<std::shared_ptr<DBEvent> >
		CatalogueController::retrieveEvents(const QString &repository) const
		{
		auto eventsShared = std::list<std::shared_ptr<DBEvent> >{};
		auto events = impl->m_CatalogueDao.getEvents(repository);
		for (auto event : events) {
		eventsShared.push_back(std::make_shared<DBEvent>(event));
		}
		return eventsShared;
		}

		std::list<std::shared_ptr<DBEvent> > CatalogueController::retrieveAllEvents() const
		{
		auto eventsShared = std::list<std::shared_ptr<DBEvent> >{};
		for (auto repository : impl->m_RepositoryList) {
		eventsShared.splice(eventsShared.end(), retrieveEvents(repository));
		}

		return eventsShared;
		}

trabillard CatalogueController: add few basic methods + commit the one not yet implemented	r1128	std::list<std::shared_ptr<DBEvent> >
		CatalogueController::retrieveEventsFromCatalogue(const QString &repository,
		std::shared_ptr<DBCatalogue> catalogue) const
		{
		auto eventsShared = std::list<std::shared_ptr<DBEvent> >{};
		auto events = impl->m_CatalogueDao.getCatalogueEvents(*catalogue);
		for (auto event : events) {
		eventsShared.push_back(std::make_shared<DBEvent>(event));
		}
		return eventsShared;
		}

		std::list<std::shared_ptr<DBCatalogue> >
		CatalogueController::getCatalogues(const QString &repository) const
		{
		auto cataloguesShared = std::list<std::shared_ptr<DBCatalogue> >{};
		auto catalogues = impl->m_CatalogueDao.getCatalogues(repository);
		for (auto catalogue : catalogues) {
		cataloguesShared.push_back(std::make_shared<DBCatalogue>(catalogue));
		}
		return cataloguesShared;
		}

perrinel correction of merge	r1059	void CatalogueController::initialize()
		{
		qCDebug(LOG_CatalogueController()) << tr("CatalogueController init")
		<< QThread::currentThread();
		impl->m_WorkingMutex.lock();
		impl->m_CatalogueDao.initialize();
trabillard Fix the loading of the default database	r1126	auto defaultRepositoryLocation
		= QStandardPaths::writableLocation(QStandardPaths::AppDataLocation);

		QDir defaultRepositoryLocationDir;
		if (defaultRepositoryLocationDir.mkpath(defaultRepositoryLocation)) {
		defaultRepositoryLocationDir.cd(defaultRepositoryLocation);
		auto defaultRepository = defaultRepositoryLocationDir.absoluteFilePath(REPOSITORY_DEFAULT);
		qCInfo(LOG_CatalogueController())
		<< tr("Persistant data loading from: ") << defaultRepository;
perrinel Add retrieve events impl	r1125	this->addDB(defaultRepository);
		}
trabillard Fix the loading of the default database	r1126	else {
		qCWarning(LOG_CatalogueController())
		<< tr("Cannot load the persistent default repository from ")
		<< defaultRepositoryLocation;
		}

		qCDebug(LOG_CatalogueController()) << tr("CatalogueController init END");
perrinel correction of merge	r1059	}

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

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