Implement saving save to enable incremental sync even after shutdown

1 files changed, 20 insertions, 12 deletions

diff --git a/connection.cpp b/connection.cpp
index 3ecabdc5..7650b4dd 100644
--- a/connection.cpp
+++ b/connection.cpp
@@ -159,12 +159,7 @@ void Connection::sync(int timeout)
     auto job = d->syncJob =
             callApi<SyncJob>(d->data->lastEvent(), filter, timeout);
     connect( job, &SyncJob::success, [=] () {
-        d->data->setLastEvent(job->nextBatch());
-        for( auto&& roomData: job->takeRoomData() )
-        {
-            if ( auto* r = provideRoom(roomData.roomId) )
-                r->updateData(std::move(roomData));
-        }
+        onSyncSuccess(*job->data());
         d->syncJob = nullptr;
         emit syncDone();
     });
@@ -178,6 +173,17 @@ void Connection::sync(int timeout)
     });
 }
 
+void Connection::onSyncSuccess(SyncData &data) {
+    d->data->setLastEvent(data.nextBatch());
+    qInfo() << "last event " << d->data->lastEvent();
+    for( auto&& roomData: data.takeRoomData() )
+    {
+        if ( auto* r = provideRoom(roomData.roomId) )
+            r->updateData(std::move(roomData));
+    }
+
+}
+
 void Connection::stopSync()
 {
     if (d->syncJob)
@@ -323,8 +329,8 @@ QByteArray Connection::generateTxnId()
     return d->data->generateTxnId();
 }
 
-QFile Connection::getStateSaveFile() const {
-    return QFile(QStandardPaths::writableLocation(QStandardPaths::AppDataLocation) + "/data.json");
+QString Connection::getStateSaveFile() const {
+    return QStandardPaths::writableLocation(QStandardPaths::AppDataLocation) + "/state.json";
 }
 
 void Connection::saveState() {
@@ -348,18 +354,20 @@ void Connection::saveState() {
     QJsonDocument doc { rootObj };
     QByteArray data = doc.toJson();
 
-    QFile outfile = getStateSaveFile();
+    QFile outfile { getStateSaveFile() };
     outfile.open(QFile::WriteOnly);
     qInfo() << "Writing state to file=" << outfile.fileName();
-    //QFile outfile(path);
     outfile.write(data.data(), data.size());
 }
 
 void Connection::loadState() {
-    QFile file = getStateSaveFile();
+    QFile file { getStateSaveFile() };
     if (!file.exists()) return;
     file.open(QFile::ReadOnly);
     QByteArray data = file.readAll();
 
-    QJsonDocument doc = QJsonDocument.fromJson(data.data(), data.size());
+    QJsonDocument doc { QJsonDocument::fromJson(data) };
+    SyncData sync;
+    sync.parseJson(doc);
+    onSyncSuccess(sync);
 }