WIP: different approach

src/app/main.cpp

@@ -12,9 +12,12 @@
 
 int main(int argc, char *argv[])
 {
+    // App setup
     QCoreApplication app(argc, argv);
     QCoreApplication::setApplicationName("colnod-connector");
     QCoreApplication::setApplicationVersion("1.0");
+
+    // Command line parsing
     QCommandLineParser parser;
     parser.setApplicationDescription("Colnod sync");
     QCommandLineOption dryModeOption("dryMode", "ColnodAPI", "Read-only mode, prints changes which would normally be made");
@@ -26,8 +29,9 @@ int main(int argc, char *argv[])
     parser.process(app);
 
 
-    // ======== LOGGER ==============
+    // Logger initializiaton
     serversdk::initAppLogger(); // <-- then Logger::outputMessage will handle all messages
+
     // Log messge Filtering
     QStringList filters;
     filters << "qt.*=false";
@@ -35,16 +39,21 @@ int main(int argc, char *argv[])
     //filters << "*=false";
     QLoggingCategory::setFilterRules(filters.join(QStringLiteral("\n")));
 
-    SyncManager api(parser.isSet(dryModeOption));
 
-    // TODO: handle error in init
+
-    if (api.init()) {
+    SyncManager syncManager(parser.isSet(dryModeOption));
-        api.run();
+
-    } else {
+    // Initialize database and colnod API
-        //error
+    if (!syncManager.databaseInitialization()) {
+        qCritical("Not possible to initialize sync application");
         return -1;
     }
 
+    // Synchronizaiton
+    if (!syncManager.startSynchronization()) {
+        qCritical("Not possible to start synchronization");
+        return -1;
+    }
 
     return QCoreApplication::exec();
 }

src/colnod/data.h

@@ -19,9 +19,10 @@ public:
     }
 };
 
-
 class Data
 {
+    friend class ColnodAPI;
+    friend class DatabaseAPI;
 public:
     Data() = default;
 

src/colnod/databaseapi.cpp

@@ -2,6 +2,8 @@
 
 Q_LOGGING_CATEGORY(database, "database.api");
 
+
+
 DatabaseAPI::DatabaseAPI(serversdk::DatabaseManager *dbMan, bool dryMode)
     : mDryMode(dryMode),
       mDbMan(dbMan),
@@ -34,17 +36,23 @@ bool DatabaseAPI::executeQuery(QSqlQuery &query, const QString &statement)
     return true;
 }
 
-void DatabaseAPI::downloadData()
+std::shared_ptr<Data> DatabaseAPI::downloadData()
 {
     auto updatedQuery = mDbMan->createQuery();
     auto deletedQuery = mDbMan->createQuery();
     if (!executeQuery(updatedQuery, "SELECT * FROM colnod_token WHERE last_modified > last_update AND deleted = false")) {
         qWarning(database) << "ERROR during geting new/updated tokens from db.";
+        return nullptr;
     }
     if (!executeQuery(deletedQuery, "SELECT id FROM colnod_token WHERE last_modified > last_update AND deleted = true")) {
         qWarning(database) << "ERROR during geting marked tokens for deletion from db.";
+        return nullptr;
     }
-    emit downloadDataFinished(composeData(updatedQuery, deletedQuery));
+
+    return composeData(updatedQuery, deletedQuery);
+    // TODO: why emiting signal??
+    // this can return Strucutre
+    //emit downloadDataFinished(composeData(updatedQuery, deletedQuery));
 }
 
 void DatabaseAPI::processData(const std::shared_ptr<Data> &data)
@@ -144,6 +152,7 @@ qint64 DatabaseAPI::getNow()
     auto query = mDbMan->createQuery();
     if (!executeQuery(query, "SELECT EXTRACT(EPOCH FROM NOW())*1000")) {
         qCritical(database) << "ERROR during getting acctual time from db";
+        return -1;
         emit error();
     }
     query.next();
@@ -172,13 +181,29 @@ void DatabaseAPI::initNewTokens()
 
 void DatabaseAPI::uploadTokens(const QHash<QString, std::shared_ptr<Token>> &tokens)
 {
+    // TODO: first check if OK, then message
+    // OK -> token was updated
+    // ERROR -> not possible to update
     auto query = mDbMan->createQuery();
     for (const auto &token : tokens) {
+        // Get token
+
+        QSqlQuery query;
+
+
+
+
+
+
+
         if (exists(token->id(), "colnod_token")) {
             query = utils->updateTable(token.get(), "colnod_token");
             qInfo(database).noquote() << Message::massageTemplate("Updating", "token", "database", token->name());
         }
         else {
+            // TODO: first check if OK, then message
+            // OK -> token was updated
+            // ERROR -> not possible to update
             query = utils->insertIntoTable(token.get(), "colnod_token");
             qInfo(database).noquote() << Message::massageTemplate("Adding", "token", "database", token->name());
         }
@@ -270,6 +295,7 @@ bool DatabaseAPI::isValid()
     return mValid;
 }
 
+
 bool DatabaseAPI::exists(const QString &id, const QString &tableName)
 {
     auto query = mDbMan->createQuery();

src/colnod/databaseapi.h

@@ -11,6 +11,8 @@
 
 Q_DECLARE_LOGGING_CATEGORY(database)
 
+
+
 class DatabaseAPI : public QObject
 {
     Q_OBJECT
@@ -21,7 +23,7 @@ public:
 
     bool executeQuery(QSqlQuery &query, const QString &statement = QString());
 
-    void downloadData();
+    std::shared_ptr<Data> downloadData();
     void processData(const std::shared_ptr<Data> &data);
     qint64 getLastSync();
     void setLastSync(qint64 timestamp);

src/colnod/syncmanager.cpp

@@ -10,43 +10,78 @@ SyncManager::SyncManager(bool dryMode)
 
 }
 
-bool SyncManager::init()
+bool SyncManager::databaseInitialization()
 {
     database = std::make_shared<DatabaseAPI>(&dbMan, mDryMode);
-    connect(database.get(), &DatabaseAPI::error, [=](){
+//    connect(database.get(), &DatabaseAPI::error, [=](){
-        QCoreApplication::exit(1);
+//        QCoreApplication::exit(1);
-    });
+//    });
 
-    if (database->open()){
+    // Open database
-        mlastSync.set_timestamp(database->getLastSync());
+    if (!database->open()) {
-
+        qCritical(syncmanager) << "Not possible to open database:" << dbMan.database().hostName();
-        colnod = std::make_shared<ColnodAPI>(&reqMan, mlastSync.timestamp(), mDryMode);
-        connect(colnod.get(), &ColnodAPI::error, [=](){
-            QCoreApplication::exit(1);
-        });
-
-        // -1 --> some error with getting data from DB
-        if (mlastSync.timestamp() >= 0){
-            return true;
-        }
-        qCritical(syncmanager) << "Couldn't get time of last synchronization";
-    }
-    else
-        qCritical(syncmanager) << "Opening database wasn't successful";
         return false;
     }
 
+    // Get last synchronizaiton date
+    qint64 lastsync_in_ms = database->getLastSync();
+    if (lastsync_in_ms == -1) {
+        qCritical(syncmanager) << "Not possible to get last synchronization date";
+        return false;
+    }
 
-void SyncManager::run()
+    // here -> nothing can fail
+    mlastSync.set_timestamp(database->getLastSync());
+    colnod = std::make_shared<ColnodAPI>(&reqMan, mlastSync.timestamp(), mDryMode);
+    return true;
+}
+
+
+bool SyncManager::startSynchronization()
 {
+    // I have to current time from database
     qint64 syncBegin = database->getNow();
+    if (syncBegin == -1) {
+        qCritical(syncmanager) << "Not possible to get last sync date";
+        return false;
+    }
 
     qInfo(syncmanager) << equals;
     qInfo(syncmanager) << "SYNCHRONIZATION BEGIN";
 
+    // TODO: check error
     database->initNewTokens();
 
-    downloadData();
+
+    // GETTING DATA FROM DATABASE
+    auto databaseData = database->downloadData();
+    if (!databaseData) {
+        qCritical(syncmanager) << "not possible to get data from database";
+        return false;
+    }
+    // NOW I HAVE DATA FROM DATABASE
+
+
+
+    colnod->downloadData();
+    connect(colnod.get(), &ColnodAPI::downloadDataFinished, [=](std::shared_ptr<Data> data) {
+        // NOW I HAVE DATA FROM COLNOD
+
+        // I can process data
+        qDebug(syncmanager) << "I have colnod and database data";
+        qDebug(syncmanager) << "updated token count" << data->updatedTokens.count();
+    });
+
+    return true;
+    //downloadData();
+
+    auto colnodDataFinished = [=](std::shared_ptr<Data> data) {
+        qDebug() << "Now I can check that I have all data I need";
+    };
+
+    //connect(this, &SyncManager::dataReady, processDownloadedData);
+
+
     connect(this, &SyncManager::dataReady, [=](){
         prepareData();
 
@@ -77,6 +112,7 @@ void SyncManager::run()
 
         processData();
     });
+    return true;
 }
 
 void SyncManager::downloadData()
@@ -88,8 +124,8 @@ void SyncManager::downloadData()
     qInfo(syncmanager) << dash;
 
     connect(colnod.get(), &ColnodAPI::downloadDataFinished, this, &SyncManager::saveColnodData);
-    connect(database.get(), &DatabaseAPI::downloadDataFinished, this, &SyncManager::saveDatabaseData);
+    //connect(database.get(), &DatabaseAPI::downloadDataFinished, this, &SyncManager::saveDatabaseData);
-    database->downloadData();
+    //database->downloadData();
     colnod->downloadData();
 }
 
@@ -103,6 +139,11 @@ void SyncManager::prepareData()
     qInfo(syncmanager) << dash;
 
 
+    Q_ASSERT(colnodData);
+    Q_ASSERT(databaseData);
+
+
+    // TODO: why copy data?
     colnodDataToProcess = std::make_shared<Data>(*colnodData);
     databaseDataToProcess = std::make_shared<Data>(*databaseData);
 
@@ -205,7 +246,7 @@ void SyncManager::updateLastUpdate(qint64 syncBegin)
 
 void SyncManager::areDataReady()
 {
-    if (++dataAmount == 2) {
+    if (++dataAmount == 1) {
 
         qInfo(syncmanager) << "DOWNLOADING DATA -> FINISHED";
         qInfo(syncmanager) << equals;

src/colnod/syncmanager.h

@@ -12,8 +12,8 @@ class SyncManager : public QObject
 public:
     explicit SyncManager(bool dryMode);
 
-    bool init();
+    bool databaseInitialization();
-    void run();
+    bool startSynchronization();
 
 private:
     void downloadData();