7
7
8
8
#if SWIFT_PACKAGE
9
9
import LDKHeaders
10
- import LDKBindings
11
10
#endif
12
11
13
12
import Foundation
@@ -37,7 +36,7 @@ public class ChannelManagerConstructor: NativeTypeWrapper {
37
36
fileprivate var customPersister : CustomChannelManagerPersister ?
38
37
fileprivate var customEventHandler : EventHandler ?
39
38
public private( set) var net_graph : NetworkGraph ?
40
- fileprivate var graph_msg_handler : NetGraphMsgHandler ?
39
+ fileprivate var graph_msg_handler : GossipSync ?
41
40
fileprivate var scorer : MultiThreadedLockableScore ?
42
41
fileprivate let keysInterface : KeysInterface !
43
42
public private( set) var payer : InvoicePayer ?
@@ -111,7 +110,7 @@ public class ChannelManagerConstructor: NativeTypeWrapper {
111
110
let random_data = keys_interface. get_secure_random_bytes ( ) ;
112
111
113
112
if let serializedNetworkGraph = net_graph_serialized {
114
- let netGraphResult = NetworkGraph . read ( ser: serializedNetworkGraph)
113
+ let netGraphResult = NetworkGraph . read ( ser: serializedNetworkGraph, arg : self . logger )
115
114
if !netGraphResult. isOk ( ) {
116
115
throw InvalidSerializedDataError . invalidSerializedNetworkGraph
117
116
}
@@ -121,7 +120,8 @@ public class ChannelManagerConstructor: NativeTypeWrapper {
121
120
let noCustomMessages = IgnoringMessageHandler ( )
122
121
var messageHandler : MessageHandler !
123
122
if let netGraph = net_graph {
124
- self . graph_msg_handler = NetGraphMsgHandler ( network_graph: netGraph, chain_access: Option_AccessZ . none ( ) , logger: logger)
123
+ // TODO: fix
124
+ // self.graph_msg_handler = NetGraphMsgHandler(network_graph: netGraph, chain_access: Option_AccessZ.none(), logger: logger)
125
125
126
126
// messageHandler = MessageHandler(chan_handler_arg: channelManager.as_ChannelMessageHandler(), route_handler_arg: self.graph_msg_handler!.as_RoutingMessageHandler())
127
127
// temporarily disable handling routing messages by the peer manager to avoid excessive memory growth
@@ -169,7 +169,9 @@ public class ChannelManagerConstructor: NativeTypeWrapper {
169
169
var messageHandler : MessageHandler !
170
170
if let netGraph = net_graph {
171
171
let noneOption = Option_AccessZ . none ( )
172
- self . graph_msg_handler = NetGraphMsgHandler ( network_graph: netGraph, chain_access: noneOption, logger: logger)
172
+
173
+ // TODO: fix
174
+ // self.graph_msg_handler = NetGraphMsgHandler(network_graph: netGraph, chain_access: noneOption, logger: logger)
173
175
174
176
175
177
// messageHandler = MessageHandler(chan_handler_arg: channelManager.as_ChannelMessageHandler(), route_handler_arg: self.graph_msg_handler!.as_RoutingMessageHandler())
@@ -227,18 +229,18 @@ public class ChannelManagerConstructor: NativeTypeWrapper {
227
229
let router = DefaultRouter ( network_graph: netGraph, logger: self . logger, random_seed_bytes: self . keysInterface. get_secure_random_bytes ( ) )
228
230
// either dangle router, or set is_owned to false
229
231
router. cOpaqueStruct!. is_owned = false
230
- self . payer = InvoicePayer ( payer: self . channelManager. as_Payer ( ) , router: router. as_Router ( ) , scorer: scorer, logger: self . logger, event_handler: self . customEventHandler!, retry_attempts : RetryAttempts ( a_arg : 3 ) )
232
+ self . payer = InvoicePayer ( payer: self . channelManager. as_Payer ( ) , router: router. as_Router ( ) , scorer: scorer, logger: self . logger, event_handler: self . customEventHandler!, retry : Retry . attempts ( a : 3 ) )
231
233
router. cOpaqueStruct!. is_owned = true
232
234
self . customEventHandler = self . payer!. as_EventHandler ( )
233
235
}
234
236
235
237
// if there is a graph msg handler, set its is_owned to false
236
- self . graph_msg_handler? . cOpaqueStruct? . is_owned = false
238
+ // self.graph_msg_handler?.cOpaqueStruct?.is_owned = false
237
239
238
- self . backgroundProcessor = BackgroundProcessor ( persister: self . customPersister!, event_handler: self . customEventHandler!, chain_monitor: self . chain_monitor, channel_manager: self . channelManager, net_graph_msg_handler : self . graph_msg_handler, peer_manager: self . peerManager, logger: self . logger)
240
+ self . backgroundProcessor = BackgroundProcessor ( persister: self . customPersister!, event_handler: self . customEventHandler!, chain_monitor: self . chain_monitor, channel_manager: self . channelManager, gossip_sync : self . graph_msg_handler, peer_manager: self . peerManager, logger: self . logger, scorer : Option_WriteableScoreZ . none ( ) )
239
241
240
242
// restore it back to true
241
- self . graph_msg_handler? . cOpaqueStruct? . is_owned = true
243
+ // self.graph_msg_handler?.cOpaqueStruct?.is_owned = true
242
244
243
245
try ? self . backgroundProcessor!. addAnchor ( anchor: self . peerManager)
244
246
try ? self . backgroundProcessor!. addAnchor ( anchor: persister)
0 commit comments