Add a test for mainnet graph sync.

Author: arik-so

ci/LDKSwift/Tests/LDKSwiftTests/LDKSwiftTest.swift

@@ -92,6 +92,64 @@ class LDKSwiftTest: XCTestCase {
 		print("restored invoice string: \(regeneratedInvoiceString)")
 	}
 
+	func testMainnetGraphSync() async throws {
+        let reversedGenesisHashHex = "6fe28c0ab6f1b372c1a6a246ae63f74f931e8365e15a089c68d6190000000000"
+        let reversedGenesisHash = Self.hexStringToBytes(hexString: reversedGenesisHashHex)!
+
+        let seed: [UInt8] = [UInt8](Data(base64Encoded: "//////////////////////////////////////////8=")!)
+		let timestamp_seconds = UInt64(NSDate().timeIntervalSince1970)
+		let timestamp_nanos = UInt32(truncating: NSNumber(value: timestamp_seconds * 1000 * 1000))
+        let keysManager = KeysManager(seed: seed, starting_time_secs: timestamp_seconds, starting_time_nanos: timestamp_nanos)
+        let keysInterface = keysManager.as_KeysInterface()
+
+        let config = UserConfig()
+        let lightningNetwork = LDKNetwork_Bitcoin
+        let networkGraph = NetworkGraph(genesis_hash: reversedGenesisHash)
+
+        let scoringParams = ProbabilisticScoringParameters()
+        let probabalisticScorer = ProbabilisticScorer(params: scoringParams, network_graph: networkGraph)
+        let score = probabalisticScorer.as_Score()
+        let multiThreadedScorer = MultiThreadedLockableScore(score: score)
+
+        let feeEstimator = TestFeeEstimator()
+        let broadcaster = TestBroadcasterInterface()
+        let logger = TestLogger()
+        let channelMonitorPersister = TestPersister()
+        let chainMonitor = ChainMonitor(chain_source: Option_FilterZ(value: nil), broadcaster: broadcaster, logger: logger, feeest: feeEstimator, persister: channelMonitorPersister)
+
+        let channelManagerConstructor = ChannelManagerConstructor(network: lightningNetwork, config: config, current_blockchain_tip_hash: reversedGenesisHash, current_blockchain_tip_height: 0, keys_interface: keysInterface, fee_estimator: feeEstimator, chain_monitor: chainMonitor, net_graph: networkGraph, tx_broadcaster: broadcaster, logger: logger)
+        let channelManager = channelManagerConstructor.channelManager
+        let peerManager = channelManagerConstructor.peerManager
+        let tcpPeerHandler = channelManagerConstructor.getTCPPeerHandler()
+        if let netGraph = channelManagerConstructor.net_graph {
+            print("net graph available!")
+        }
+
+        // bitrefill
+        tcpPeerHandler.connect(address: "52.50.244.44", port: 9735, theirNodeId: Self.hexStringToBytes(hexString: "030c3f19d742ca294a55c00376b3b355c3c90d61c6b6b39554dbc7ac19b141c14f")!)
+
+        // River
+        tcpPeerHandler.connect(address: "104.196.249.140", port: 9735, theirNodeId: Self.hexStringToBytes(hexString: "03037dc08e9ac63b82581f79b662a4d0ceca8a8ca162b1af3551595b8f2d97b70a")!)
+
+        // Acinq
+        tcpPeerHandler.connect(address: "3.33.236.230", port: 9735, theirNodeId: Self.hexStringToBytes(hexString: "03864ef025fde8fb587d989186ce6a4a186895ee44a926bfc370e2c366597a3f8f")!)
+
+        // Kraken
+        tcpPeerHandler.connect(address: "52.13.118.208", port: 9735, theirNodeId: Self.hexStringToBytes(hexString: "02f1a8c87607f415c8f22c00593002775941dea48869ce23096af27b0cfdcc0b69")!)
+
+        // Matt
+        tcpPeerHandler.connect(address: "69.59.18.80", port: 9735, theirNodeId: Self.hexStringToBytes(hexString: "03db10aa09ff04d3568b0621750794063df401e6853c79a21a83e1a3f3b5bfb0c8")!)
+
+        let channelManagerAndNetworkGraphPersisterAndEventHandler = TestChannelManagerPersister(channelManager: channelManager)
+        channelManagerConstructor.chain_sync_completed(persister: channelManagerAndNetworkGraphPersisterAndEventHandler, scorer: multiThreadedScorer)
+
+        // run this for one minute
+        for _ in 0..<600 {
+            // sleep for 100ms
+            try! await Task.sleep(nanoseconds: 0_100_000_000)
+        }
+    }
+
     func testRouteConstruction() throws {
 
         let destPubkeyHex = "03c2abfa93eacec04721c019644584424aab2ba4dff3ac9bdab4e9c97007491dda"

ci/run_tests.sh

@@ -33,3 +33,4 @@ pushd LDKSwift/
 #swift test
 swift test -Xswiftc -suppress-warnings
 #swift test --filter 'testInvoiceSerialization' -Xswiftc -suppress-warnings
+#swift test --filter 'testMainnetGraphSync' -Xswiftc -suppress-warnings

xcode/DirectBindingsApp/DirectBindingsAppTests/DirectBindingsAppTests.swift

@@ -224,6 +224,65 @@ class DirectBindingsAppTests: XCTestCase {
         print("restored invoice string: \(regeneratedInvoiceString)")
     }
 
+    func testMainnetGraphSync() async throws {
+        let reversedGenesisHashHex = "6fe28c0ab6f1b372c1a6a246ae63f74f931e8365e15a089c68d6190000000000"
+        let reversedGenesisHash = Self.hexStringToBytes(hexString: reversedGenesisHashHex)!
+        
+        let seed: [UInt8] = [UInt8](Data(base64Encoded: "//////////////////////////////////////////8=")!)
+        let timestamp_seconds = UInt64(NSDate().timeIntervalSince1970)
+        let timestamp_nanos = UInt32(truncating: NSNumber(value: timestamp_seconds * 1000 * 1000))
+
+        let keysManager = KeysManager(seed: seed, starting_time_secs: timestamp_seconds, starting_time_nanos: timestamp_nanos)
+        let keysInterface = keysManager.as_KeysInterface()
+
+        let config = UserConfig()
+        let lightningNetwork = LDKNetwork_Bitcoin
+        let networkGraph = NetworkGraph(genesis_hash: reversedGenesisHash)
+        
+        let scoringParams = ProbabilisticScoringParameters()
+        let probabalisticScorer = ProbabilisticScorer(params: scoringParams, network_graph: networkGraph)
+        let score = probabalisticScorer.as_Score()
+        let multiThreadedScorer = MultiThreadedLockableScore(score: score)
+        
+        let feeEstimator = TestFeeEstimator()
+        let broadcaster = TestBroadcasterInterface()
+        let logger = TestLogger()
+        let channelMonitorPersister = TestPersister()
+        let chainMonitor = ChainMonitor(chain_source: Option_FilterZ(value: nil), broadcaster: broadcaster, logger: logger, feeest: feeEstimator, persister: channelMonitorPersister)
+
+        let channelManagerConstructor = ChannelManagerConstructor(network: lightningNetwork, config: config, current_blockchain_tip_hash: reversedGenesisHash, current_blockchain_tip_height: 0, keys_interface: keysInterface, fee_estimator: feeEstimator, chain_monitor: chainMonitor, net_graph: networkGraph, tx_broadcaster: broadcaster, logger: logger)
+        let channelManager = channelManagerConstructor.channelManager
+        let peerManager = channelManagerConstructor.peerManager
+        let tcpPeerHandler = channelManagerConstructor.getTCPPeerHandler()
+        if let netGraph = channelManagerConstructor.net_graph {
+            print("net graph available!")
+        }
+        
+        // bitrefill
+        tcpPeerHandler.connect(address: "52.50.244.44", port: 9735, theirNodeId: Self.hexStringToBytes(hexString: "030c3f19d742ca294a55c00376b3b355c3c90d61c6b6b39554dbc7ac19b141c14f")!)
+        
+        // River
+        tcpPeerHandler.connect(address: "104.196.249.140", port: 9735, theirNodeId: Self.hexStringToBytes(hexString: "03037dc08e9ac63b82581f79b662a4d0ceca8a8ca162b1af3551595b8f2d97b70a")!)
+        
+        // Acinq
+        tcpPeerHandler.connect(address: "3.33.236.230", port: 9735, theirNodeId: Self.hexStringToBytes(hexString: "03864ef025fde8fb587d989186ce6a4a186895ee44a926bfc370e2c366597a3f8f")!)
+        
+        // Kraken
+        tcpPeerHandler.connect(address: "52.13.118.208", port: 9735, theirNodeId: Self.hexStringToBytes(hexString: "02f1a8c87607f415c8f22c00593002775941dea48869ce23096af27b0cfdcc0b69")!)
+        
+        // Matt
+        tcpPeerHandler.connect(address: "69.59.18.80", port: 9735, theirNodeId: Self.hexStringToBytes(hexString: "03db10aa09ff04d3568b0621750794063df401e6853c79a21a83e1a3f3b5bfb0c8")!)
+        
+        let channelManagerAndNetworkGraphPersisterAndEventHandler = TestChannelManagerPersister(channelManager: channelManager)
+        channelManagerConstructor.chain_sync_completed(persister: channelManagerAndNetworkGraphPersisterAndEventHandler, scorer: multiThreadedScorer)
+        
+        // run this for one minute
+        for _ in 0..<600 {
+            // sleep for 100ms
+            try! await Task.sleep(nanoseconds: 0_100_000_000)
+        }
+    }
+    
     func testPeerGraphConnectivity() async throws {
         let instance = HumanObjectPeerTestInstance(nice_close: true, use_km_wrapper: false, use_manual_watch: false, reload_peers: false, break_cross_peer_refs: false, use_nio_peer_handler: true, use_filter: false, use_chan_manager_constructor: true)
         await instance.test_multiple_peer_connections()

xcode/DirectBindingsApp/DirectBindingsAppTests/test-batteries/TestLogger.swift

@@ -8,7 +8,7 @@
 class TestLogger: Logger {
 
     override func log(record: Record) {
-        print("\nRLLogger (\(record.get_level())): \(record.get_file()):\(record.get_line()):\n> \(record.get_args())\n")
+        print("\nRLTestLogger (\(record.get_level())): \(record.get_file()):\(record.get_line()):\n> \(record.get_args())\n")
     }
 
 }