X-Git-Url: http://git.bitcoin.ninja/index.cgi?a=blobdiff_plain;f=lightning%2Fsrc%2Fln%2Fchannelmanager.rs;h=6ba7396ebfe04262904640c6b041d6969e95195f;hb=88e1b56d66ff550b36a6d422f47c9b9729406f61;hp=be2b599e6af31f8e45a7d7d17988ea2756d7defd;hpb=05e6252b20ac3a3412d4da38f732191724f30bc0;p=rust-lightning

diff --git a/lightning/src/ln/channelmanager.rs b/lightning/src/ln/channelmanager.rs
index be2b599e..6ba7396e 100644
--- a/lightning/src/ln/channelmanager.rs
+++ b/lightning/src/ln/channelmanager.rs
@@ -4031,8 +4031,8 @@ where
 		self.pending_outbound_payments
 			.send_payment_for_bolt12_invoice(
 				invoice, payment_id, &self.router, self.list_usable_channels(),
-				|| self.compute_inflight_htlcs(), &self.entropy_source, &self.node_signer,
-				best_block_height, &self.logger, &self.pending_events,
+				|| self.compute_inflight_htlcs(), &self.entropy_source, &self.node_signer, &self,
+				&self.secp_ctx, best_block_height, &self.logger, &self.pending_events,
 				|args| self.send_payment_along_path(args)
 			)
 	}
@@ -6211,21 +6211,13 @@ where
 		}
 		if valid_mpp {
 			for htlc in sources.drain(..) {
-				let prev_hop_chan_id = htlc.prev_hop.channel_id;
-				if let Err((pk, err)) = self.claim_funds_from_hop(
+				self.claim_funds_from_hop(
 					htlc.prev_hop, payment_preimage,
 					|_, definitely_duplicate| {
 						debug_assert!(!definitely_duplicate, "We shouldn't claim duplicatively from a payment");
 						Some(MonitorUpdateCompletionAction::PaymentClaimed { payment_hash })
 					}
-				) {
-					if let msgs::ErrorAction::IgnoreError = err.err.action {
-						// We got a temporary failure updating monitor, but will claim the
-						// HTLC when the monitor updating is restored (or on chain).
-						let logger = WithContext::from(&self.logger, None, Some(prev_hop_chan_id), Some(payment_hash));
-						log_error!(logger, "Temporary failure claiming HTLC, treating as success: {}", err.err.err);
-					} else { errs.push((pk, err)); }
-				}
+				);
 			}
 		}
 		if !valid_mpp {
@@ -6247,9 +6239,10 @@ where
 		}
 	}
 
-	fn claim_funds_from_hop<ComplFunc: FnOnce(Option<u64>, bool) -> Option<MonitorUpdateCompletionAction>>(&self,
-		prev_hop: HTLCPreviousHopData, payment_preimage: PaymentPreimage, completion_action: ComplFunc)
-	-> Result<(), (PublicKey, MsgHandleErrInternal)> {
+	fn claim_funds_from_hop<ComplFunc: FnOnce(Option<u64>, bool) -> Option<MonitorUpdateCompletionAction>>(
+		&self, prev_hop: HTLCPreviousHopData, payment_preimage: PaymentPreimage,
+		completion_action: ComplFunc,
+	) {
 		//TODO: Delay the claimed_funds relaying just like we do outbound relay!
 
 		// If we haven't yet run background events assume we're still deserializing and shouldn't
@@ -6311,7 +6304,7 @@ where
 								let action = if let Some(action) = completion_action(None, true) {
 									action
 								} else {
-									return Ok(());
+									return;
 								};
 								mem::drop(peer_state_lock);
 
@@ -6327,7 +6320,7 @@ where
 								} else {
 									debug_assert!(false,
 										"Duplicate claims should always free another channel immediately");
-									return Ok(());
+									return;
 								};
 								if let Some(peer_state_mtx) = per_peer_state.get(&node_id) {
 									let mut peer_state = peer_state_mtx.lock().unwrap();
@@ -6352,7 +6345,7 @@ where
 							}
 						}
 					}
-					return Ok(());
+					return;
 				}
 			}
 		}
@@ -6400,7 +6393,6 @@ where
 		// generally always allowed to be duplicative (and it's specifically noted in
 		// `PaymentForwarded`).
 		self.handle_monitor_update_completion_actions(completion_action(None, false));
-		Ok(())
 	}
 
 	fn finalize_claims(&self, sources: Vec<HTLCSource>) {
@@ -6433,7 +6425,7 @@ where
 				let completed_blocker = RAAMonitorUpdateBlockingAction::from_prev_hop_data(&hop_data);
 				#[cfg(debug_assertions)]
 				let claiming_chan_funding_outpoint = hop_data.outpoint;
-				let res = self.claim_funds_from_hop(hop_data, payment_preimage,
+				self.claim_funds_from_hop(hop_data, payment_preimage,
 					|htlc_claim_value_msat, definitely_duplicate| {
 						let chan_to_release =
 							if let Some(node_id) = next_channel_counterparty_node_id {
@@ -6527,10 +6519,6 @@ where
 							})
 						}
 					});
-				if let Err((pk, err)) = res {
-					let result: Result<(), _> = Err(err);
-					let _ = handle_error!(self, result, pk);
-				}
 			},
 		}
 	}
@@ -10389,6 +10377,17 @@ where
 					},
 				}
 			},
+			#[cfg(async_payments)]
+			OffersMessage::StaticInvoice(_invoice) => {
+				match responder {
+					Some(responder) => {
+						responder.respond(OffersMessage::InvoiceError(
+								InvoiceError::from_string("Static invoices not yet supported".to_string())
+						))
+					},
+					None => return ResponseInstruction::NoResponse,
+				}
+			},
 			OffersMessage::InvoiceError(invoice_error) => {
 				log_trace!(self.logger, "Received invoice_error: {}", invoice_error);
 				ResponseInstruction::NoResponse