Feature/tezos synchronizer

core/src/wallet/tezos/synchronizers/TezosLikeAccountSynchronizer.cpp

@@ -122,7 +122,7 @@ auto TezosLikeAccountSynchronizer::performSynchronization() const -> Future<Resu
     return async::sequence(getContext(), futures)
         .map<Result>(
             getContext(),
-            [this](const auto& tuple) {
+            [this, state](const auto& tuple) {
                 const auto duration = std::chrono::duration_cast<
                     std::chrono::milliseconds>(DateUtils::now() - _start);
                 _logger->info(
@@ -134,17 +134,18 @@ auto TezosLikeAccountSynchronizer::performSynchronization() const -> Future<Resu
                 const auto block = std::get<0>(tuple);
                 const auto syncs = std::get<1>(tuple);
 
+                const auto newOperations = std::accumulate(
+                    std::begin(syncs), std::end(syncs), 0);
+
                 if (block.height > 0) {
-                    auto state = SavedState(block.height, block.hash);
+                    auto newState = SavedState(
+                        block.height, block.hash, state.offset + newOperations);
                     _account->getInternalPreferences()
                             ->editor()
-                            ->putObject<SavedState>("state", state)
+                            ->putObject<SavedState>("state", newState)
                             ->commit();
                 }
 
-                const auto newOperations = std::accumulate(
-                    std::begin(syncs), std::end(syncs), 0);
-
                 return Result(block.height, newOperations);
             })
         .recoverWith(
@@ -179,7 +180,7 @@ auto TezosLikeAccountSynchronizer::synchronizeTransactions(
         }
         return std::string("");
     }();
-    return _explorer->getTransactions({address}, Option<std::string>(state.blockHash))
+    return _explorer->getTransactions({address}, std::to_string(state.offset))
         .flatMap<uint32_t>(
             _account->getContext(),
             [this, address, state, uid, nbTxns](
@@ -192,12 +193,6 @@ auto TezosLikeAccountSynchronizer::synchronizeTransactions(
                         newState.blockHeight = tx.block->height;
                         newState.blockHash = tx.block->hash;
                     }
-                    /*
-                    if (tx.block.hasValue()) {
-                        newState.blockHeight = tx.block->height;
-                        newState.blockHash = tx.block->hash;
-                    }
-                    */
 
                     if (orig) {
                         tx.originatedAccountUid = uid;
@@ -219,6 +214,8 @@ auto TezosLikeAccountSynchronizer::synchronizeTransactions(
                 }
 
                 const auto count = tryPutTx.getValue();
+                newState.offset += count;
+
                 _logger->info(
                     "Successfully inserted {} transactions for account {}.",
                     count, _account->getAccountUid());

core/src/wallet/tezos/synchronizers/TezosLikeAccountSynchronizer.hpp

@@ -77,17 +77,23 @@ class TezosLikeAccountSynchronizer : public DedicatedContext
     {
         uint64_t blockHeight{0};
         std::string blockHash{""};
-
-        SavedState(uint64_t blockHeight, std::string blockHash)
-            : blockHeight(blockHeight), blockHash(blockHash)
+        uint64_t offset{0};
+
+        SavedState(
+            uint64_t blockHeight,
+            std::string blockHash,
+            uint64_t offset)
+            : blockHeight(blockHeight)
+            , blockHash(blockHash)
+            , offset(offset)
         {}
 
         SavedState() = default;
 
         template<typename Archive>
         void serialize(Archive& archive)
         {
-            archive(blockHeight, blockHash);
+            archive(blockHeight, blockHash, offset);
         }
     };