@@ -43,10 +43,10 @@ public struct ChannelManagerConstructionParameters {
43
43
public var enableP2PGossip : Bool = false
44
44
public var scorer : MultiThreadedLockableScore ?
45
45
public var scoreParams : ProbabilisticScoringFeeParameters ?
46
- public var payerRetries : Retry = Retry . initWithAttempts ( a: UInt ( 3 ) )
46
+ public var payerRetries : Retry = Retry . initWithAttempts ( a: UInt32 ( 3 ) )
47
47
public var logger : Logger
48
48
49
- public init ( config: UserConfig , entropySource: EntropySource , nodeSigner: NodeSigner , signerProvider: SignerProvider , feeEstimator: FeeEstimator , chainMonitor: ChainMonitor , txBroadcaster: BroadcasterInterface , logger: Logger , enableP2PGossip: Bool = false , scorer: MultiThreadedLockableScore ? = nil , scoreParams: ProbabilisticScoringFeeParameters ? = nil , payerRetries: Retry = Retry . initWithAttempts ( a: UInt ( 3 ) ) ) {
49
+ public init ( config: UserConfig , entropySource: EntropySource , nodeSigner: NodeSigner , signerProvider: SignerProvider , feeEstimator: FeeEstimator , chainMonitor: ChainMonitor , txBroadcaster: BroadcasterInterface , logger: Logger , enableP2PGossip: Bool = false , scorer: MultiThreadedLockableScore ? = nil , scoreParams: ProbabilisticScoringFeeParameters ? = nil , payerRetries: Retry = Retry . initWithAttempts ( a: UInt32 ( 3 ) ) ) {
50
50
self . config = config
51
51
self . entropySource = entropySource
52
52
self . nodeSigner = nodeSigner
@@ -134,7 +134,7 @@ public class ChannelManagerConstructor: NativeTypeWrapper {
134
134
var monitorFundingSet = Set < String > ( )
135
135
136
136
for currentSerializedChannelMonitor in channelMonitorsSerialized {
137
- let channelMonitorResult : Result_C2Tuple_BlockHashChannelMonitorZDecodeErrorZ = Bindings . readBlockHashChannelMonitor ( ser: currentSerializedChannelMonitor, argA: params. entropySource, argB: params. signerProvider)
137
+ let channelMonitorResult = Bindings . readThirtyTwoBytesChannelMonitor ( ser: currentSerializedChannelMonitor, argA: params. entropySource, argB: params. signerProvider)
138
138
139
139
guard let ( blockHash, channelMonitor) = channelMonitorResult. getValue ( ) else {
140
140
throw InvalidSerializedDataError . invalidSerializedChannelMonitor
@@ -170,8 +170,8 @@ public class ChannelManagerConstructor: NativeTypeWrapper {
170
170
// TODO: figure out better way to obtain a router
171
171
let router = params. router ( networkGraph: self . netGraph)
172
172
let channelManagerReadArgs = ChannelManagerReadArgs ( entropySource: params. entropySource, nodeSigner: params. nodeSigner, signerProvider: params. signerProvider, feeEstimator: params. feeEstimator, chainMonitor: params. chainMonitor. asWatch ( ) , txBroadcaster: params. txBroadcaster, router: router, logger: params. logger, defaultConfig: params. config, channelMonitors: monitors)
173
-
174
- guard let ( latestBlockHash, channelManager) = Bindings . readBlockHashChannelManager ( ser: channelManagerSerialized, arg: channelManagerReadArgs) . getValue ( ) else {
173
+
174
+ guard let ( latestBlockHash, channelManager) = Bindings . readThirtyTwoBytesChannelManager ( ser: channelManagerSerialized, arg: channelManagerReadArgs) . getValue ( ) else {
175
175
throw InvalidSerializedDataError . invalidSerializedChannelManager
176
176
}
177
177
@@ -281,7 +281,7 @@ public class ChannelManagerConstructor: NativeTypeWrapper {
281
281
let ( outPoint, _) = currentChannelMonitor. getFundingTxo ( )
282
282
print ( " watching channel " )
283
283
let monitorWatchResult = chainMonitorWatch. watchChannel ( fundingTxo: outPoint, monitor: currentChannelMonitor)
284
- if monitorWatchResult != . Completed {
284
+ if ! monitorWatchResult. isOk ( ) || monitorWatchResult . getValue ( ) != . Completed {
285
285
Bindings . print ( " Some issue occurred with a chainMonitorWatch.watch_channel call: \( monitorWatchResult) " , severity: . WARNING)
286
286
}
287
287
// monitorClone.cType?.is_owned = true
@@ -360,16 +360,16 @@ fileprivate class CustomChannelManagerPersister: Persister {
360
360
self . handler = handler
361
361
super. init ( )
362
362
}
363
-
364
- override func persistManager( channelManager: Bindings . ChannelManager ) -> Bindings . Result_NoneErrorZ {
363
+
364
+ override func persistManager( channelManager: Bindings . ChannelManager ) -> Bindings . Result_NoneIOErrorZ {
365
365
return self . handler. persistManager ( channelManager: channelManager)
366
366
}
367
-
368
- override func persistGraph( networkGraph: Bindings . NetworkGraph ) -> Bindings . Result_NoneErrorZ {
367
+
368
+ override func persistGraph( networkGraph: Bindings . NetworkGraph ) -> Bindings . Result_NoneIOErrorZ {
369
369
return self . handler. persistGraph ( networkGraph: networkGraph)
370
370
}
371
-
372
- override func persistScorer( scorer: Bindings . WriteableScore ) -> Bindings . Result_NoneErrorZ {
371
+
372
+ override func persistScorer( scorer: Bindings . WriteableScore ) -> Bindings . Result_NoneIOErrorZ {
373
373
return self . handler. persistScorer ( scorer: scorer)
374
374
}
375
375
}
0 commit comments