Merge branch 'improve-sync-temporary-blocks' into 'master'

block synchronization is improved

See merge request open-platform/chain!376

Author: george-bisiarin

src/main/kotlin/io/openfuture/chain/core/sync/ChainSynchronizer.kt

@@ -28,6 +28,7 @@ import org.springframework.context.ApplicationListener
 import org.springframework.context.event.EventListener
 import org.springframework.stereotype.Component
 import java.util.concurrent.ScheduledFuture
+import javax.annotation.PostConstruct
 
 @Component
 class ChainSynchronizer(
@@ -52,6 +53,11 @@ class ChainSynchronizer(
     private var future: ScheduledFuture<*>? = null
 
 
+    @PostConstruct
+    fun forceSynchronizationCheck() {
+        checkLastBlock()
+    }
+
     override fun onApplicationEvent(event: DataSourceSchemaCreatedEvent) {
         prepareDB(nodeConfigurator.getConfig().mode)
     }
@@ -63,7 +69,7 @@ class ChainSynchronizer(
     }
 
     fun prepareDB(syncMode: SyncMode) {
-        status = SyncStatus.PROCESSING
+        status = PROCESSING
         dbChecker.prepareDB(syncMode)
         status = SYNCHRONIZED
     }

src/main/kotlin/io/openfuture/chain/core/sync/SyncSession.kt

@@ -66,8 +66,13 @@ class SyncSession(
         }
 
         val temporaryBlocks = createTemporaryBlocks(epochBlocks)
+        val lastTemporaryBlock = temporaryBlocks.last()
+
+        val lastSavedTemporaryBlock = temporaryBlockService.getByHeightIn(listOf(lastTemporaryBlock.height))
+        if (null == lastSavedTemporaryBlock.firstOrNull { it.block == lastTemporaryBlock.block }) {
+            temporaryBlockService.save(temporaryBlocks)
+        }
 
-        temporaryBlockService.save(temporaryBlocks)
         completed = null != epochBlocks.firstOrNull { it.hash == currentGenesisBlock.hash }
         epochAdded++
         log.info("#$epochAdded epochs FROM ${epochQuantity + 1} is processed")
@@ -101,7 +106,14 @@ class SyncSession(
         }
 
         for (index in 1 until chain.size) {
-            if (!mainBlockValidator.verify(chain[index], chain[index - 1], chain[index] as MainBlock, false, pipeline)) {
+            if (!mainBlockValidator.verify(
+                    chain[index],
+                    chain[index - 1],
+                    chain[index] as MainBlock,
+                    false,
+                    pipeline
+                )
+            ) {
                 return false
             }
         }