@@ -1124,44 +1124,44 @@ impl_writeable_tlv_based!(PendingChannelMonitorUpdate, {
1124
1124
(0, update, required),
1125
1125
});
1126
1126
1127
- /// The `ChannelPhase ` enum describes the current phase in life of a lightning channel with each of
1127
+ /// The `Channel ` enum describes the current phase in life of a lightning channel with each of
1128
1128
/// its variants containing an appropriate channel struct.
1129
- pub(super) enum ChannelPhase <SP: Deref> where SP::Target: SignerProvider {
1129
+ pub(super) enum Channel <SP: Deref> where SP::Target: SignerProvider {
1130
1130
UnfundedOutboundV1(OutboundV1Channel<SP>),
1131
1131
UnfundedInboundV1(InboundV1Channel<SP>),
1132
1132
#[allow(dead_code)] // TODO(dual_funding): Remove once creating V2 channels is enabled.
1133
1133
UnfundedV2(PendingV2Channel<SP>),
1134
1134
Funded(FundedChannel<SP>),
1135
1135
}
1136
1136
1137
- impl<'a, SP: Deref> ChannelPhase <SP> where
1137
+ impl<'a, SP: Deref> Channel <SP> where
1138
1138
SP::Target: SignerProvider,
1139
1139
<SP::Target as SignerProvider>::EcdsaSigner: ChannelSigner,
1140
1140
{
1141
1141
pub fn context(&'a self) -> &'a ChannelContext<SP> {
1142
1142
match self {
1143
- ChannelPhase ::Funded(chan) => &chan.context,
1144
- ChannelPhase ::UnfundedOutboundV1(chan) => &chan.context,
1145
- ChannelPhase ::UnfundedInboundV1(chan) => &chan.context,
1146
- ChannelPhase ::UnfundedV2(chan) => &chan.context,
1143
+ Channel ::Funded(chan) => &chan.context,
1144
+ Channel ::UnfundedOutboundV1(chan) => &chan.context,
1145
+ Channel ::UnfundedInboundV1(chan) => &chan.context,
1146
+ Channel ::UnfundedV2(chan) => &chan.context,
1147
1147
}
1148
1148
}
1149
1149
1150
1150
pub fn context_mut(&'a mut self) -> &'a mut ChannelContext<SP> {
1151
1151
match self {
1152
- ChannelPhase ::Funded(ref mut chan) => &mut chan.context,
1153
- ChannelPhase ::UnfundedOutboundV1(ref mut chan) => &mut chan.context,
1154
- ChannelPhase ::UnfundedInboundV1(ref mut chan) => &mut chan.context,
1155
- ChannelPhase ::UnfundedV2(ref mut chan) => &mut chan.context,
1152
+ Channel ::Funded(ref mut chan) => &mut chan.context,
1153
+ Channel ::UnfundedOutboundV1(ref mut chan) => &mut chan.context,
1154
+ Channel ::UnfundedInboundV1(ref mut chan) => &mut chan.context,
1155
+ Channel ::UnfundedV2(ref mut chan) => &mut chan.context,
1156
1156
}
1157
1157
}
1158
1158
1159
1159
pub fn unfunded_context_mut(&mut self) -> Option<&mut UnfundedChannelContext> {
1160
1160
match self {
1161
- ChannelPhase ::Funded(_) => { debug_assert!(false); None },
1162
- ChannelPhase ::UnfundedOutboundV1(chan) => Some(&mut chan.unfunded_context),
1163
- ChannelPhase ::UnfundedInboundV1(chan) => Some(&mut chan.unfunded_context),
1164
- ChannelPhase ::UnfundedV2(chan) => Some(&mut chan.unfunded_context),
1161
+ Channel ::Funded(_) => { debug_assert!(false); None },
1162
+ Channel ::UnfundedOutboundV1(chan) => Some(&mut chan.unfunded_context),
1163
+ Channel ::UnfundedInboundV1(chan) => Some(&mut chan.unfunded_context),
1164
+ Channel ::UnfundedV2(chan) => Some(&mut chan.unfunded_context),
1165
1165
}
1166
1166
}
1167
1167
@@ -1170,67 +1170,67 @@ impl<'a, SP: Deref> ChannelPhase<SP> where
1170
1170
}
1171
1171
1172
1172
pub fn as_funded(&self) -> Option<&FundedChannel<SP>> {
1173
- if let ChannelPhase ::Funded(channel) = self {
1173
+ if let Channel ::Funded(channel) = self {
1174
1174
Some(channel)
1175
1175
} else {
1176
1176
None
1177
1177
}
1178
1178
}
1179
1179
1180
1180
pub fn as_funded_mut(&mut self) -> Option<&mut FundedChannel<SP>> {
1181
- if let ChannelPhase ::Funded(channel) = self {
1181
+ if let Channel ::Funded(channel) = self {
1182
1182
Some(channel)
1183
1183
} else {
1184
1184
None
1185
1185
}
1186
1186
}
1187
1187
1188
1188
pub fn as_unfunded_outbound_v1_mut(&mut self) -> Option<&mut OutboundV1Channel<SP>> {
1189
- if let ChannelPhase ::UnfundedOutboundV1(channel) = self {
1189
+ if let Channel ::UnfundedOutboundV1(channel) = self {
1190
1190
Some(channel)
1191
1191
} else {
1192
1192
None
1193
1193
}
1194
1194
}
1195
1195
1196
1196
pub fn is_unfunded_outbound_v1(&self) -> bool {
1197
- matches!(self, ChannelPhase ::UnfundedOutboundV1(_))
1197
+ matches!(self, Channel ::UnfundedOutboundV1(_))
1198
1198
}
1199
1199
1200
1200
pub fn into_unfunded_outbound_v1(self) -> Result<OutboundV1Channel<SP>, Self> {
1201
- if let ChannelPhase ::UnfundedOutboundV1(channel) = self {
1201
+ if let Channel ::UnfundedOutboundV1(channel) = self {
1202
1202
Ok(channel)
1203
1203
} else {
1204
1204
Err(self)
1205
1205
}
1206
1206
}
1207
1207
1208
1208
pub fn into_unfunded_inbound_v1(self) -> Result<InboundV1Channel<SP>, Self> {
1209
- if let ChannelPhase ::UnfundedInboundV1(channel) = self {
1209
+ if let Channel ::UnfundedInboundV1(channel) = self {
1210
1210
Ok(channel)
1211
1211
} else {
1212
1212
Err(self)
1213
1213
}
1214
1214
}
1215
1215
1216
1216
pub fn as_unfunded_v2(&self) -> Option<&PendingV2Channel<SP>> {
1217
- if let ChannelPhase ::UnfundedV2(channel) = self {
1217
+ if let Channel ::UnfundedV2(channel) = self {
1218
1218
Some(channel)
1219
1219
} else {
1220
1220
None
1221
1221
}
1222
1222
}
1223
1223
1224
1224
pub fn as_unfunded_v2_mut(&mut self) -> Option<&mut PendingV2Channel<SP>> {
1225
- if let ChannelPhase ::UnfundedV2(channel) = self {
1225
+ if let Channel ::UnfundedV2(channel) = self {
1226
1226
Some(channel)
1227
1227
} else {
1228
1228
None
1229
1229
}
1230
1230
}
1231
1231
1232
1232
pub fn into_unfunded_v2(self) -> Option<PendingV2Channel<SP>> {
1233
- if let ChannelPhase ::UnfundedV2(channel) = self {
1233
+ if let Channel ::UnfundedV2(channel) = self {
1234
1234
Some(channel)
1235
1235
} else {
1236
1236
None
@@ -1241,8 +1241,8 @@ impl<'a, SP: Deref> ChannelPhase<SP> where
1241
1241
&mut self, chain_hash: ChainHash, logger: &L,
1242
1242
) -> Option<SignerResumeUpdates> where L::Target: Logger {
1243
1243
match self {
1244
- ChannelPhase ::Funded(chan) => Some(chan.signer_maybe_unblocked(logger)),
1245
- ChannelPhase ::UnfundedOutboundV1(chan) => {
1244
+ Channel ::Funded(chan) => Some(chan.signer_maybe_unblocked(logger)),
1245
+ Channel ::UnfundedOutboundV1(chan) => {
1246
1246
let (open_channel, funding_created) = chan.signer_maybe_unblocked(chain_hash, logger);
1247
1247
Some(SignerResumeUpdates {
1248
1248
commitment_update: None,
@@ -1258,7 +1258,7 @@ impl<'a, SP: Deref> ChannelPhase<SP> where
1258
1258
shutdown_result: None,
1259
1259
})
1260
1260
},
1261
- ChannelPhase ::UnfundedInboundV1(chan) => {
1261
+ Channel ::UnfundedInboundV1(chan) => {
1262
1262
let logger = WithChannelContext::from(logger, &chan.context, None);
1263
1263
let accept_channel = chan.signer_maybe_unblocked(&&logger);
1264
1264
Some(SignerResumeUpdates {
@@ -1275,38 +1275,38 @@ impl<'a, SP: Deref> ChannelPhase<SP> where
1275
1275
shutdown_result: None,
1276
1276
})
1277
1277
},
1278
- ChannelPhase ::UnfundedV2(_) => None,
1278
+ Channel ::UnfundedV2(_) => None,
1279
1279
}
1280
1280
}
1281
1281
1282
1282
pub fn is_resumable(&self) -> bool {
1283
1283
match self {
1284
- ChannelPhase ::Funded(_) => false,
1285
- ChannelPhase ::UnfundedOutboundV1(chan) => chan.is_resumable(),
1286
- ChannelPhase ::UnfundedInboundV1(_) => false,
1287
- ChannelPhase ::UnfundedV2(_) => false,
1284
+ Channel ::Funded(_) => false,
1285
+ Channel ::UnfundedOutboundV1(chan) => chan.is_resumable(),
1286
+ Channel ::UnfundedInboundV1(_) => false,
1287
+ Channel ::UnfundedV2(_) => false,
1288
1288
}
1289
1289
}
1290
1290
1291
1291
pub fn maybe_get_open_channel<L: Deref>(
1292
1292
&mut self, chain_hash: ChainHash, logger: &L,
1293
1293
) -> Option<OpenChannelMessage> where L::Target: Logger {
1294
1294
match self {
1295
- ChannelPhase ::Funded(_) => None,
1296
- ChannelPhase ::UnfundedOutboundV1(chan) => {
1295
+ Channel ::Funded(_) => None,
1296
+ Channel ::UnfundedOutboundV1(chan) => {
1297
1297
let logger = WithChannelContext::from(logger, &chan.context, None);
1298
1298
chan.get_open_channel(chain_hash, &&logger)
1299
1299
.map(|msg| OpenChannelMessage::V1(msg))
1300
1300
},
1301
- ChannelPhase ::UnfundedInboundV1(_) => {
1301
+ Channel ::UnfundedInboundV1(_) => {
1302
1302
// Since unfunded inbound channel maps are cleared upon disconnecting a peer,
1303
1303
// they are not persisted and won't be recovered after a crash.
1304
1304
// Therefore, they shouldn't exist at this point.
1305
1305
debug_assert!(false);
1306
1306
None
1307
1307
},
1308
1308
#[cfg(dual_funding)]
1309
- ChannelPhase ::UnfundedV2(chan) => {
1309
+ Channel ::UnfundedV2(chan) => {
1310
1310
if chan.context.is_outbound() {
1311
1311
Some(OpenChannelMessage::V2(chan.get_open_channel_v2(chain_hash)))
1312
1312
} else {
@@ -1318,7 +1318,7 @@ impl<'a, SP: Deref> ChannelPhase<SP> where
1318
1318
}
1319
1319
},
1320
1320
#[cfg(not(dual_funding))]
1321
- ChannelPhase ::UnfundedV2(_) => {
1321
+ Channel ::UnfundedV2(_) => {
1322
1322
debug_assert!(false);
1323
1323
None
1324
1324
},
@@ -1333,15 +1333,15 @@ impl<'a, SP: Deref> ChannelPhase<SP> where
1333
1333
L::Target: Logger,
1334
1334
{
1335
1335
match self {
1336
- ChannelPhase ::Funded(_) => Ok(None),
1337
- ChannelPhase ::UnfundedOutboundV1(chan) => {
1336
+ Channel ::Funded(_) => Ok(None),
1337
+ Channel ::UnfundedOutboundV1(chan) => {
1338
1338
let logger = WithChannelContext::from(logger, &chan.context, None);
1339
1339
chan.maybe_handle_error_without_close(chain_hash, fee_estimator, &&logger)
1340
1340
.map(|msg| Some(OpenChannelMessage::V1(msg)))
1341
1341
},
1342
- ChannelPhase ::UnfundedInboundV1(_) => Ok(None),
1342
+ Channel ::UnfundedInboundV1(_) => Ok(None),
1343
1343
#[cfg(dual_funding)]
1344
- ChannelPhase ::UnfundedV2(chan) => {
1344
+ Channel ::UnfundedV2(chan) => {
1345
1345
if chan.context.is_outbound() {
1346
1346
chan.maybe_handle_error_without_close(chain_hash, fee_estimator)
1347
1347
.map(|msg| Some(OpenChannelMessage::V2(msg)))
@@ -1350,51 +1350,51 @@ impl<'a, SP: Deref> ChannelPhase<SP> where
1350
1350
}
1351
1351
},
1352
1352
#[cfg(not(dual_funding))]
1353
- ChannelPhase ::UnfundedV2(_) => {
1353
+ Channel ::UnfundedV2(_) => {
1354
1354
debug_assert!(false);
1355
1355
Ok(None)
1356
1356
},
1357
1357
}
1358
1358
}
1359
1359
}
1360
1360
1361
- impl<SP: Deref> From<OutboundV1Channel<SP>> for ChannelPhase <SP>
1361
+ impl<SP: Deref> From<OutboundV1Channel<SP>> for Channel <SP>
1362
1362
where
1363
1363
SP::Target: SignerProvider,
1364
1364
<SP::Target as SignerProvider>::EcdsaSigner: ChannelSigner,
1365
1365
{
1366
1366
fn from(channel: OutboundV1Channel<SP>) -> Self {
1367
- ChannelPhase ::UnfundedOutboundV1(channel)
1367
+ Channel ::UnfundedOutboundV1(channel)
1368
1368
}
1369
1369
}
1370
1370
1371
- impl<SP: Deref> From<InboundV1Channel<SP>> for ChannelPhase <SP>
1371
+ impl<SP: Deref> From<InboundV1Channel<SP>> for Channel <SP>
1372
1372
where
1373
1373
SP::Target: SignerProvider,
1374
1374
<SP::Target as SignerProvider>::EcdsaSigner: ChannelSigner,
1375
1375
{
1376
1376
fn from(channel: InboundV1Channel<SP>) -> Self {
1377
- ChannelPhase ::UnfundedInboundV1(channel)
1377
+ Channel ::UnfundedInboundV1(channel)
1378
1378
}
1379
1379
}
1380
1380
1381
- impl<SP: Deref> From<PendingV2Channel<SP>> for ChannelPhase <SP>
1381
+ impl<SP: Deref> From<PendingV2Channel<SP>> for Channel <SP>
1382
1382
where
1383
1383
SP::Target: SignerProvider,
1384
1384
<SP::Target as SignerProvider>::EcdsaSigner: ChannelSigner,
1385
1385
{
1386
1386
fn from(channel: PendingV2Channel<SP>) -> Self {
1387
- ChannelPhase ::UnfundedV2(channel)
1387
+ Channel ::UnfundedV2(channel)
1388
1388
}
1389
1389
}
1390
1390
1391
- impl<SP: Deref> From<FundedChannel<SP>> for ChannelPhase <SP>
1391
+ impl<SP: Deref> From<FundedChannel<SP>> for Channel <SP>
1392
1392
where
1393
1393
SP::Target: SignerProvider,
1394
1394
<SP::Target as SignerProvider>::EcdsaSigner: ChannelSigner,
1395
1395
{
1396
1396
fn from(channel: FundedChannel<SP>) -> Self {
1397
- ChannelPhase ::Funded(channel)
1397
+ Channel ::Funded(channel)
1398
1398
}
1399
1399
}
1400
1400
0 commit comments