CatalogueController.cpp
131 lines
| 3.9 KiB
| text/x-c
|
CppLexer
| r1059 | #include <Catalogue/CatalogueController.h> | |||
| #include <Variable/Variable.h> | ||||
| #include <CatalogueDao.h> | ||||
| r1125 | #include <ComparaisonPredicate.h> | |||
| #include <CompoundPredicate.h> | ||||
| #include <DBCatalogue.h> | ||||
| #include <DBEvent.h> | ||||
| #include <DBTag.h> | ||||
| #include <IRequestPredicate.h> | ||||
| r1059 | #include <QMutex> | |||
| #include <QThread> | ||||
| #include <QDir> | ||||
| #include <QStandardPaths> | ||||
| Q_LOGGING_CATEGORY(LOG_CatalogueController, "CatalogueController") | ||||
| r1125 | namespace { | |||
| static QString REPOSITORY_WORK_SUFFIX = QString{"Work"}; | ||||
| } | ||||
| r1059 | class CatalogueController::CatalogueControllerPrivate { | |||
| public: | ||||
| QMutex m_WorkingMutex; | ||||
| CatalogueDao m_CatalogueDao; | ||||
| r1125 | ||||
| std::list<QString> m_RepositoryList; | ||||
| 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(); | ||||
| } | ||||
| 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); | ||||
| } | ||||
| else | ||||
| { | ||||
| impl->m_RepositoryList << dirName; | ||||
| } | ||||
| } | ||||
| 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; | ||||
| } | ||||
| r1059 | void CatalogueController::initialize() | |||
| { | ||||
| qCDebug(LOG_CatalogueController()) << tr("CatalogueController init") | ||||
| << QThread::currentThread(); | ||||
| impl->m_WorkingMutex.lock(); | ||||
| impl->m_CatalogueDao.initialize(); | ||||
| r1125 | auto defaultRepository = QString("%1/%2").arg( | |||
| QStandardPaths::displayName(QStandardPaths::AppDataLocation), REPOSITORY_DEFAULT); | ||||
| QDir defaultRepositoryDir(defaultRepository); | ||||
| if (defaultRepositoryDir.exists()) { | ||||
| qCInfo(LOG_CatalogueController()) << tr("Persistant data loading from: ") | ||||
| << defaultRepository; | ||||
| this->addDB(defaultRepository); | ||||
| qCDebug(LOG_CatalogueController()) << tr("CatalogueController init END"); | ||||
| } | ||||
| r1059 | } | |||
| void CatalogueController::finalize() | ||||
| { | ||||
| impl->m_WorkingMutex.unlock(); | ||||
| } | ||||
| void CatalogueController::waitForFinish() | ||||
| { | ||||
| QMutexLocker locker{&impl->m_WorkingMutex}; | ||||
| } | ||||
