6
6
//
7
7
8
8
import Foundation
9
- // import LDKHeaders
10
9
11
10
enum InvalidSerializedDataError : Error {
12
11
case invalidSerializedChannelMonitor
@@ -25,7 +24,7 @@ public class ChannelManagerConstructor {
25
24
26
25
27
26
public let channel_manager_latest_block_hash : [ UInt8 ] ?
28
-
27
+
29
28
let logger : Logger
30
29
fileprivate var customPersister : CustomChannelManagerPersister ?
31
30
fileprivate var customEventHandler : CustomEventHandler ?
@@ -87,7 +86,7 @@ public class ChannelManagerConstructor {
87
86
self . channel_manager_latest_block_hash = latestBlockHash
88
87
self . chain_monitor = chain_monitor
89
88
self . logger = logger
90
-
89
+
91
90
let random_data = keys_interface. get_secure_random_bytes ( ) ;
92
91
if let router = router {
93
92
let messageHandler = MessageHandler ( chan_handler_arg: channelManager. as_ChannelMessageHandler ( ) , route_handler_arg: router. as_RoutingMessageHandler ( ) )
@@ -119,7 +118,7 @@ public class ChannelManagerConstructor {
119
118
let chainParameters = ChainParameters ( network_arg: network, best_block_arg: block)
120
119
self . channelManager = ChannelManager ( fee_est: fee_estimator, chain_monitor: chain_monitor. as_Watch ( ) , tx_broadcaster: tx_broadcaster, logger: logger, keys_manager: keys_interface, config: config, params: chainParameters)
121
120
self . logger = logger
122
-
121
+
123
122
let random_data = keys_interface. get_secure_random_bytes ( ) ;
124
123
if let router = router {
125
124
let messageHandler = MessageHandler ( chan_handler_arg: channelManager. as_ChannelMessageHandler ( ) , route_handler_arg: router. as_RoutingMessageHandler ( ) )
@@ -134,7 +133,7 @@ public class ChannelManagerConstructor {
134
133
var persisterWorkItem : DispatchWorkItem ?
135
134
var backgroundProcessor : BackgroundProcessor ?
136
135
var shutdown = false
137
-
136
+
138
137
/**
139
138
* Utility which adds all of the deserialized ChannelMonitors to the chain watch so that further updates from the
140
139
* ChannelManager are processed as normal.
@@ -143,7 +142,7 @@ public class ChannelManagerConstructor {
143
142
* ChannelManagerPersister as required.
144
143
*/
145
144
public func chain_sync_completed( persister: ExtendedChannelManagerPersister ) {
146
-
145
+
147
146
if self . backgroundProcessor != nil {
148
147
return
149
148
}
@@ -164,10 +163,10 @@ public class ChannelManagerConstructor {
164
163
self . customPersister = CustomChannelManagerPersister ( handler: persister)
165
164
self . customEventHandler = CustomEventHandler ( handler: persister)
166
165
self . backgroundProcessor = BackgroundProcessor ( persister: self . customPersister!, event_handler: self . customEventHandler!, chain_monitor: self . chain_monitor, channel_manager: self . channelManager, peer_manager: self . peerManager, logger: self . logger)
167
-
168
-
166
+
167
+
169
168
}
170
-
169
+
171
170
public func interrupt( ) {
172
171
self . shutdown = true
173
172
self . backgroundProcessor? . stop ( )
@@ -177,14 +176,14 @@ public class ChannelManagerConstructor {
177
176
}
178
177
179
178
fileprivate class CustomChannelManagerPersister : ChannelManagerPersister {
180
-
179
+
181
180
let handler : ExtendedChannelManagerPersister
182
-
181
+
183
182
init ( handler: ExtendedChannelManagerPersister ) {
184
183
self . handler = handler
185
184
super. init ( )
186
185
}
187
-
186
+
188
187
override func persist_manager( channel_manager: ChannelManager ) -> Result_NoneErrorZ {
189
188
return self . handler. persist_manager ( channel_manager: channel_manager)
190
189
}
@@ -193,17 +192,17 @@ fileprivate class CustomChannelManagerPersister: ChannelManagerPersister {
193
192
fileprivate class CustomEventHandler : EventHandler {
194
193
195
194
let handler : ExtendedChannelManagerPersister
196
-
195
+
197
196
init ( handler: ExtendedChannelManagerPersister ) {
198
197
self . handler = handler
199
198
super. init ( )
200
199
}
201
-
200
+
202
201
override func handle_event( event: Event ) {
203
202
self . handler. handle_event ( event: event)
204
203
}
205
-
206
-
204
+
205
+
207
206
}
208
207
209
208
public protocol ExtendedChannelManagerPersister : ChannelManagerPersister {
0 commit comments