@@ -42,7 +42,8 @@ class PolarConnectionExperiment: ObservableObject {
42
42
self . feeEstimator = TestFeeEstimator ( )
43
43
self . persister = TestPersister ( )
44
44
45
- self . chainMonitor = ChainMonitor ( chain_source: self . filter, broadcaster: self . broadcaster, logger: self . logger, feeest: self . feeEstimator, persister: self . persister)
45
+ let filterOption = Option_FilterZ ( value: self . filter)
46
+ self . chainMonitor = ChainMonitor ( chain_source: filterOption. dangle ( ) , broadcaster: self . broadcaster, logger: self . logger, feeest: self . feeEstimator, persister: self . persister)
46
47
47
48
let seed : [ UInt8 ] = [ UInt8] ( Data ( base64Encoded: " //////////////////////////////////////////8= " ) !)
48
49
let timestamp_seconds = UInt64 ( NSDate ( ) . timeIntervalSince1970)
@@ -69,6 +70,8 @@ class PolarConnectionExperiment: ObservableObject {
69
70
self . cmPersister = RegtestChannelManagerPersister ( channelManager: self . channelManager)
70
71
self . hasCaughtUpToChainTip = true
71
72
self . objectWillChange. send ( )
73
+
74
+ // Bindings.new_LDKTransactionWrapper(array: <#T##[UInt8]#>)
72
75
}
73
76
74
77
}
@@ -98,8 +101,14 @@ class PolarConnectionExperiment: ObservableObject {
98
101
self . isConnectedToAlice = true
99
102
// let theirNodeId: [UInt8] = [3, 76, 1, 164, 167, 52, 78, 65, 176, 169, 137, 4, 159, 182, 49, 198, 72, 197, 210, 127, 107, 63, 166, 28, 124, 25, 59, 64, 220, 201, 106, 147, 65]
100
103
let theirNodeId = Block . hexStringToBytes ( hexString: " 034c01a4a7344e41b0a989049fb631c648c5d27f6b3fa61c7c193b40dcc96a9341 " ) !
101
- self . peerNetworkHandler. connect ( address: " 127.0.0.1 " , port: 9735 , theirNodeId: theirNodeId)
104
+ let connectionSucceeded = self . peerNetworkHandler. connect ( address: " 127.0.0.1 " , port: 9735 , theirNodeId: theirNodeId)
105
+ if !connectionSucceeded {
106
+ self . isConnectedToAlice = false
107
+ return
108
+ }
102
109
self . objectWillChange. send ( )
110
+
111
+ let peers = self . peerManager. get_peer_node_ids ( )
103
112
}
104
113
105
114
func openChannelWithAlice( ) {
@@ -114,13 +123,20 @@ class PolarConnectionExperiment: ObservableObject {
114
123
115
124
self . objectWillChange. send ( )
116
125
117
- if channelOpenResult. cOpaqueStruct ? . result_ok == true {
126
+ if channelOpenResult. isOk ( ) {
118
127
print ( " Channel should have opened successfully! " )
119
- } else {
120
- let errorDetails = APIError ( pointer: channelOpenResult. cOpaqueStruct!. contents. err. pointee)
128
+ } else if let errorDetails = channelOpenResult. getError ( ) {
121
129
print ( " Channel open failed! " )
122
130
if let error = errorDetails. getValueAsAPIMisuseError ( ) {
123
131
print ( " Misuse: \( error. getErr ( ) ) " )
132
+ } else if let error = errorDetails. getValueAsRouteError ( ) {
133
+ print ( " Route: \( error. getErr ( ) ) " )
134
+ } else if let error = errorDetails. getValueAsChannelUnavailable ( ) {
135
+ print ( " Channel Unavailable: \( error. getErr ( ) ) " )
136
+ } else if let error = errorDetails. getValueAsFeeRateTooHigh ( ) {
137
+ print ( " fee rate: \( error. getErr ( ) ) " )
138
+ } else if let error = errorDetails. getValueAsIncompatibleShutdownScript ( ) {
139
+ print ( " incompatible shutdown script " )
124
140
}
125
141
self . isChannelWithAliceOpen = false
126
142
self . objectWillChange. send ( )
0 commit comments