@@ -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,37 +1275,37 @@ 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
- ChannelPhase ::UnfundedV2(chan) => {
1308
+ Channel ::UnfundedV2(chan) => {
1309
1309
if chan.context.is_outbound() {
1310
1310
Some(OpenChannelMessage::V2(chan.get_open_channel_v2(chain_hash)))
1311
1311
} else {
@@ -1327,14 +1327,14 @@ impl<'a, SP: Deref> ChannelPhase<SP> where
1327
1327
L::Target: Logger,
1328
1328
{
1329
1329
match self {
1330
- ChannelPhase ::Funded(_) => Ok(None),
1331
- ChannelPhase ::UnfundedOutboundV1(chan) => {
1330
+ Channel ::Funded(_) => Ok(None),
1331
+ Channel ::UnfundedOutboundV1(chan) => {
1332
1332
let logger = WithChannelContext::from(logger, &chan.context, None);
1333
1333
chan.maybe_handle_error_without_close(chain_hash, fee_estimator, &&logger)
1334
1334
.map(|msg| Some(OpenChannelMessage::V1(msg)))
1335
1335
},
1336
- ChannelPhase ::UnfundedInboundV1(_) => Ok(None),
1337
- ChannelPhase ::UnfundedV2(chan) => {
1336
+ Channel ::UnfundedInboundV1(_) => Ok(None),
1337
+ Channel ::UnfundedV2(chan) => {
1338
1338
if chan.context.is_outbound() {
1339
1339
chan.maybe_handle_error_without_close(chain_hash, fee_estimator)
1340
1340
.map(|msg| Some(OpenChannelMessage::V2(msg)))
@@ -1346,43 +1346,43 @@ impl<'a, SP: Deref> ChannelPhase<SP> where
1346
1346
}
1347
1347
}
1348
1348
1349
- impl<SP: Deref> From<OutboundV1Channel<SP>> for ChannelPhase <SP>
1349
+ impl<SP: Deref> From<OutboundV1Channel<SP>> for Channel <SP>
1350
1350
where
1351
1351
SP::Target: SignerProvider,
1352
1352
<SP::Target as SignerProvider>::EcdsaSigner: ChannelSigner,
1353
1353
{
1354
1354
fn from(channel: OutboundV1Channel<SP>) -> Self {
1355
- ChannelPhase ::UnfundedOutboundV1(channel)
1355
+ Channel ::UnfundedOutboundV1(channel)
1356
1356
}
1357
1357
}
1358
1358
1359
- impl<SP: Deref> From<InboundV1Channel<SP>> for ChannelPhase <SP>
1359
+ impl<SP: Deref> From<InboundV1Channel<SP>> for Channel <SP>
1360
1360
where
1361
1361
SP::Target: SignerProvider,
1362
1362
<SP::Target as SignerProvider>::EcdsaSigner: ChannelSigner,
1363
1363
{
1364
1364
fn from(channel: InboundV1Channel<SP>) -> Self {
1365
- ChannelPhase ::UnfundedInboundV1(channel)
1365
+ Channel ::UnfundedInboundV1(channel)
1366
1366
}
1367
1367
}
1368
1368
1369
- impl<SP: Deref> From<PendingV2Channel<SP>> for ChannelPhase <SP>
1369
+ impl<SP: Deref> From<PendingV2Channel<SP>> for Channel <SP>
1370
1370
where
1371
1371
SP::Target: SignerProvider,
1372
1372
<SP::Target as SignerProvider>::EcdsaSigner: ChannelSigner,
1373
1373
{
1374
1374
fn from(channel: PendingV2Channel<SP>) -> Self {
1375
- ChannelPhase ::UnfundedV2(channel)
1375
+ Channel ::UnfundedV2(channel)
1376
1376
}
1377
1377
}
1378
1378
1379
- impl<SP: Deref> From<FundedChannel<SP>> for ChannelPhase <SP>
1379
+ impl<SP: Deref> From<FundedChannel<SP>> for Channel <SP>
1380
1380
where
1381
1381
SP::Target: SignerProvider,
1382
1382
<SP::Target as SignerProvider>::EcdsaSigner: ChannelSigner,
1383
1383
{
1384
1384
fn from(channel: FundedChannel<SP>) -> Self {
1385
- ChannelPhase ::Funded(channel)
1385
+ Channel ::Funded(channel)
1386
1386
}
1387
1387
}
1388
1388
0 commit comments