##// END OF EJS Templates
GIT_REPOSITORIES » LPP » Users » mperrinel » SciQLop-fork
RSS

Fork of HG_REPOSITORIES/LPP/SciQLOP_Repos/SciQLop

Implements test execute() method...
Implements test execute() method For each iteration of the test, this method generates available operations according to states of the variables, and execute an operation that has been chosen randomly.
trabillard - - Load All Authors

File last commit:

r1196:b6390f556418
r1205:0c07405da56c
Show More
CatalogueController.cpp
296 lines | 9.6 KiB | text/x-c | CppLexer
/ core / src / Catalogue / CatalogueController.cpp
History | Source | Raw |Copy content |Copy permalink
perrinel
correction of merge
 r1097 #include <Catalogue/CatalogueController.h>
#include <Variable/Variable.h>
#include <CatalogueDao.h>
perrinel
Add retrieve events impl
 r1158 #include <ComparaisonPredicate.h>
#include <CompoundPredicate.h>
#include <DBCatalogue.h>
#include <DBEvent.h>
perrinel
Add Catalogue methods
 r1191 #include <DBEventProduct.h>
perrinel
Add retrieve events impl
 r1158 #include <DBTag.h>
#include <IRequestPredicate.h>
perrinel
correction of merge
 r1097 #include <QMutex>
#include <QThread>
#include <QDir>
#include <QStandardPaths>
Q_LOGGING_CATEGORY(LOG_CatalogueController, "CatalogueController")
trabillard
Fix the loading of the default database
 r1159 namespace {
perrinel
Add retrieve events impl
 r1158
perrinel
Add Catalogue methods
 r1191 static QString REPOSITORY_WORK_SUFFIX = QString{"work"};
static QString REPOSITORY_TRASH_SUFFIX = QString{"trash"};
perrinel
Add retrieve events impl
 r1158 }
perrinel
correction of merge
 r1097 class CatalogueController::CatalogueControllerPrivate {
perrinel
Add Catalogue methods
 r1191
perrinel
correction of merge
 r1097 public:
perrinel
Add Catalogue methods
 r1191 explicit CatalogueControllerPrivate(CatalogueController *parent) : m_Q{parent} {}
perrinel
correction of merge
 r1097 QMutex m_WorkingMutex;
CatalogueDao m_CatalogueDao;
perrinel
Add retrieve events impl
 r1158
perrinel
Add Catalogue methods
 r1191 QStringList m_RepositoryList;
CatalogueController *m_Q;
void copyDBtoDB(const QString &dbFrom, const QString &dbTo);
QString toWorkRepository(QString repository);
QString toSyncRepository(QString repository);
perrinel
correction of merge
 r1097 };
CatalogueController::CatalogueController(QObject *parent)
perrinel
Add Catalogue methods
 r1191 : impl{spimpl::make_unique_impl<CatalogueControllerPrivate>(this)}
perrinel
correction of merge
 r1097 {
qCDebug(LOG_CatalogueController()) << tr("CatalogueController construction")
<< QThread::currentThread();
}
CatalogueController::~CatalogueController()
{
qCDebug(LOG_CatalogueController()) << tr("CatalogueController destruction")
<< QThread::currentThread();
this->waitForFinish();
}
perrinel
Add Catalogue methods
 r1191 QStringList CatalogueController::getRepositories() const
{
return impl->m_RepositoryList;
}
perrinel
Add retrieve events impl
 r1158 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
 r1159 else {
perrinel
Add Catalogue methods
 r1191 impl->m_RepositoryList << dirName;
impl->copyDBtoDB(dirName, impl->toWorkRepository(dirName));
perrinel
Add retrieve events impl
 r1158 }
}
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
{
perrinel
Add Catalogue methods
 r1191 QString dbDireName = repository.isEmpty() ? REPOSITORY_DEFAULT : repository;
perrinel
Add retrieve events impl
 r1158 auto eventsShared = std::list<std::shared_ptr<DBEvent> >{};
perrinel
Add Catalogue methods
 r1191 auto events = impl->m_CatalogueDao.getEvents(impl->toWorkRepository(dbDireName));
perrinel
Add retrieve events impl
 r1158 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
 r1161 std::list<std::shared_ptr<DBEvent> >
trabillard
Adaptation to the shared pointers of catalogue controller
 r1176 CatalogueController::retrieveEventsFromCatalogue(std::shared_ptr<DBCatalogue> catalogue) const
trabillard
CatalogueController: add few basic methods + commit the one not yet implemented
 r1161 {
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;
}
perrinel
Add Catalogue methods
 r1191 void CatalogueController::updateEvent(std::shared_ptr<DBEvent> event)
{
event->setRepository(impl->toSyncRepository(event->getRepository()));
impl->m_CatalogueDao.updateEvent(*event);
}
void CatalogueController::removeEvent(std::shared_ptr<DBEvent> event)
{
// Remove it from both repository and repository_work
event->setRepository(impl->toWorkRepository(event->getRepository()));
impl->m_CatalogueDao.removeEvent(*event);
event->setRepository(impl->toSyncRepository(event->getRepository()));
impl->m_CatalogueDao.removeEvent(*event);
}
void CatalogueController::addEvent(std::shared_ptr<DBEvent> event)
{
trabillard
Adaptation to last version of catalogue controller
 r1196 event->setRepository(impl->toWorkRepository(event->getRepository()));
perrinel
Add Catalogue methods
 r1191
impl->m_CatalogueDao.addEvent(*event);
// Call update is necessary at the creation of add Event if it has some tags or some event
// products
if (!event->getEventProducts().empty() || !event->getTags().empty()) {
impl->m_CatalogueDao.updateEvent(*event);
}
}
void CatalogueController::saveEvent(std::shared_ptr<DBEvent> event)
{
impl->m_CatalogueDao.moveEvent(*event, impl->toSyncRepository(event->getRepository()), true);
}
trabillard
CatalogueController: add few basic methods + commit the one not yet implemented
 r1161 std::list<std::shared_ptr<DBCatalogue> >
perrinel
Add Catalogue methods
 r1191 CatalogueController::retrieveCatalogues(const QString &repository) const
trabillard
CatalogueController: add few basic methods + commit the one not yet implemented
 r1161 {
perrinel
Add Catalogue methods
 r1191 QString dbDireName = repository.isEmpty() ? REPOSITORY_DEFAULT : repository;
trabillard
CatalogueController: add few basic methods + commit the one not yet implemented
 r1161 auto cataloguesShared = std::list<std::shared_ptr<DBCatalogue> >{};
perrinel
Add Catalogue methods
 r1191 auto catalogues = impl->m_CatalogueDao.getCatalogues(impl->toWorkRepository(dbDireName));
trabillard
CatalogueController: add few basic methods + commit the one not yet implemented
 r1161 for (auto catalogue : catalogues) {
cataloguesShared.push_back(std::make_shared<DBCatalogue>(catalogue));
}
return cataloguesShared;
}
perrinel
Add Catalogue methods
 r1191 void CatalogueController::updateCatalogue(std::shared_ptr<DBCatalogue> catalogue)
{
catalogue->setRepository(impl->toSyncRepository(catalogue->getRepository()));
impl->m_CatalogueDao.updateCatalogue(*catalogue);
}
void CatalogueController::removeCatalogue(std::shared_ptr<DBCatalogue> catalogue)
{
// Remove it from both repository and repository_work
catalogue->setRepository(impl->toWorkRepository(catalogue->getRepository()));
impl->m_CatalogueDao.removeCatalogue(*catalogue);
catalogue->setRepository(impl->toSyncRepository(catalogue->getRepository()));
impl->m_CatalogueDao.removeCatalogue(*catalogue);
}
void CatalogueController::saveCatalogue(std::shared_ptr<DBCatalogue> catalogue)
{
impl->m_CatalogueDao.moveCatalogue(*catalogue,
impl->toSyncRepository(catalogue->getRepository()), true);
}
void CatalogueController::saveAll()
{
for (auto repository : impl->m_RepositoryList) {
// Save Event
auto events = this->retrieveEvents(repository);
for (auto event : events) {
this->saveEvent(event);
}
// Save Catalogue
auto catalogues = this->retrieveCatalogues(repository);
for (auto catalogue : catalogues) {
this->saveCatalogue(catalogue);
}
}
}
perrinel
correction of merge
 r1097 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
 r1159 auto defaultRepositoryLocation
= QStandardPaths::writableLocation(QStandardPaths::AppDataLocation);
QDir defaultRepositoryLocationDir;
if (defaultRepositoryLocationDir.mkpath(defaultRepositoryLocation)) {
defaultRepositoryLocationDir.cd(defaultRepositoryLocation);
auto defaultRepository = defaultRepositoryLocationDir.absoluteFilePath(REPOSITORY_DEFAULT);
perrinel
Add Catalogue methods
 r1191 qCInfo(LOG_CatalogueController()) << tr("Persistant data loading from: ")
<< defaultRepository;
perrinel
Add retrieve events impl
 r1158 this->addDB(defaultRepository);
}
trabillard
Fix the loading of the default database
 r1159 else {
qCWarning(LOG_CatalogueController())
<< tr("Cannot load the persistent default repository from ")
<< defaultRepositoryLocation;
}
qCDebug(LOG_CatalogueController()) << tr("CatalogueController init END");
perrinel
correction of merge
 r1097 }
void CatalogueController::finalize()
{
impl->m_WorkingMutex.unlock();
}
void CatalogueController::waitForFinish()
{
QMutexLocker locker{&impl->m_WorkingMutex};
}
perrinel
Add Catalogue methods
 r1191
void CatalogueController::CatalogueControllerPrivate::copyDBtoDB(const QString &dbFrom,
const QString &dbTo)
{
trabillard
Adaptation to last version of catalogue controller
 r1196 auto cataloguesShared = std::list<std::shared_ptr<DBCatalogue> >{};
auto catalogues = m_CatalogueDao.getCatalogues(dbFrom);
perrinel
Add Catalogue methods
 r1191 for (auto catalogue : catalogues) {
trabillard
Adaptation to last version of catalogue controller
 r1196 cataloguesShared.push_back(std::make_shared<DBCatalogue>(catalogue));
perrinel
Add Catalogue methods
 r1191 }
trabillard
Adaptation to last version of catalogue controller
 r1196 auto eventsShared = std::list<std::shared_ptr<DBEvent> >{};
auto events = m_CatalogueDao.getEvents(dbFrom);
perrinel
Add Catalogue methods
 r1191 for (auto event : events) {
trabillard
Adaptation to last version of catalogue controller
 r1196 eventsShared.push_back(std::make_shared<DBEvent>(event));
}
for (auto catalogue : cataloguesShared) {
m_CatalogueDao.copyCatalogue(*catalogue, dbTo, true);
}
for (auto event : eventsShared) {
perrinel
Add Catalogue methods
 r1191 m_CatalogueDao.copyEvent(*event, dbTo, true);
}
}
QString CatalogueController::CatalogueControllerPrivate::toWorkRepository(QString repository)
{
auto syncRepository = toSyncRepository(repository);
return QString("%1_%2").arg(syncRepository, REPOSITORY_WORK_SUFFIX);
}
QString CatalogueController::CatalogueControllerPrivate::toSyncRepository(QString repository)
{
auto syncRepository = repository;
if (repository.endsWith(REPOSITORY_WORK_SUFFIX)) {
syncRepository.remove(REPOSITORY_WORK_SUFFIX);
}
else if (repository.endsWith(REPOSITORY_TRASH_SUFFIX)) {
syncRepository.remove(REPOSITORY_TRASH_SUFFIX);
}
return syncRepository;
}