update test

Blockchain/Sources/Blockchain/BlockchainDataProvider/BlockchainDataProvider.swift

@@ -27,6 +27,7 @@ public actor BlockchainDataProvider: Sendable {
             if header.value.timeslot > bestHead.timeslot {
                 let number = try await dataProvider.getBlockNumber(hash: head).unwrap()
                 bestHead = HeadInfo(hash: head, timeslot: header.value.timeslot, number: number)
+                logger.info("best head with timeslot \(header.value.timeslot) updated to \(bestHead.hash)")
             } else {
                 logger.warning("Found a block with timeslot \(header.value.timeslot) but best head is \(bestHead.timeslot)")
             }
@@ -102,7 +103,7 @@ extension BlockchainDataProvider {
 
     // add forks of finalized head is not allowed
     public func add(block: BlockRef) async throws {
-        logger.debug("adding block: \(block.hash)")
+        logger.info("adding block: \(block.hash)")
 
         // require parent exists (i.e. not purged) and block is not fork of any finalized block
         guard try await hasBlock(hash: block.header.parentHash), block.header.timeslot > finalizedHead.timeslot else {

Database/Sources/Database/RocksDBBackend.swift

@@ -126,7 +126,7 @@ extension RocksDBBackend: BlockchainDataProviderProtocol {
     }
 
     public func add(block: BlockRef) async throws {
-        logger.trace("add(block:) \(block.hash)")
+        logger.info("add(block:) \(block.hash)")
 
         // TODO: batch put
 

Node/Sources/Node/Config.swift

@@ -18,7 +18,7 @@ public enum Database {
     public func open(chainspec: ChainSpec) async throws -> BlockchainDataProvider {
         switch self {
         case let .rocksDB(path):
-            logger.info("Using RocksDB backend at \(path.absoluteString)")
+            logger.debug("Using RocksDB backend at \(path.absoluteString)")
             let backend = try await RocksDBBackend(
                 path: path,
                 config: chainspec.getConfig(),
@@ -27,7 +27,7 @@ public enum Database {
             )
             return try await BlockchainDataProvider(backend)
         case .inMemory:
-            logger.info("Using in-memory backend")
+            logger.debug("Using in-memory backend")
             let genesisBlock = try chainspec.getBlock()
             let genesisStateData = try chainspec.getState()
             let backend = try StateBackend(InMemoryBackend(), config: chainspec.getConfig(), rootHash: Data32())

Node/Tests/NodeTests/NodeTests.swift

@@ -6,13 +6,14 @@ import Utils
 @testable import Node
 
 final class NodeTests {
-    var dataBaseIndex: Int = 0;
+
+    var dataBaseIndex: Int = 0
 
     let path = {
         let tmpDir = FileManager.default.temporaryDirectory
         return tmpDir.appendingPathComponent("\(UUID().uuidString)")
     }()
-
+    
     func getDatabase() -> Database {
         dataBaseIndex += 1;
         return Database.rocksDB(path: path.appendingPathComponent("\(dataBaseIndex)"))
@@ -21,6 +22,7 @@ final class NodeTests {
     deinit {
         try? FileManager.default.removeItem(at: path)
     }
+
     @Test func validatorNodeInMemory() async throws {
         let (nodes, scheduler) = try await Topology(
             nodes: [NodeDescription(isValidator: true)]
@@ -135,12 +137,9 @@ final class NodeTests {
             NodeDescription(isValidator: true, devSeed: 1, database: getDatabase()),
         ]
         // Add 18 non-validator nodes
-        for i in 2...10 {
+        for i in 2...19 {
             nodeDescriptions.append(NodeDescription(devSeed: UInt32(i), database: getDatabase()))
         }
-        for i in 11...19 {
-            nodeDescriptions.append(NodeDescription(devSeed: UInt32(i), database: .inMemory))
-        }
 
         let (nodes, scheduler) = try await Topology(
             nodes: nodeDescriptions,
@@ -162,7 +161,7 @@ final class NodeTests {
         #expect(node1.network.peersCount == 19)
         #expect(node2.network.peersCount == 19)
         // Advance time and verify sync
-        for _ in 0..<10 {
+        for _ in 0..<20 {
             await scheduler.advance(by: TimeInterval(validator1.blockchain.config.value.slotPeriodSeconds))
             await validator1StoreMiddlware.wait()
             await validator2StoreMiddlware.wait()
@@ -172,7 +171,7 @@ final class NodeTests {
             }
         }
 
-        try await Task.sleep(for: .milliseconds(nodes.count * 500))
+        try await Task.sleep(for: .milliseconds(nodes.count * 100))
 
         let validator1BestHead = await validator1.dataProvider.bestHead
         let validator2BestHead = await validator2.dataProvider.bestHead
@@ -216,7 +215,7 @@ final class NodeTests {
         #expect(node1.network.peersCount == 19)
         #expect(node2.network.peersCount == 19)
         // Advance time and verify sync
-        for _ in 0..<10 {
+        for _ in 0..<3 {
             await scheduler.advance(by: TimeInterval(validator1.blockchain.config.value.slotPeriodSeconds))
             await validator1StoreMiddlware.wait()
             await validator2StoreMiddlware.wait()

Node/Tests/NodeTests/Topology.swift

@@ -65,7 +65,6 @@ struct Topology {
             let toNode = ret[to].0
             let conn = try fromNode.network.network.connect(to: toNode.network.network.listenAddress(), role: .validator)
             try? await conn.ready()
-            try await Task.sleep(for: .milliseconds(50))
         }
         return (ret, scheduler)
     }