@@ -14317,11 +14317,9 @@ where
1431714317
1431814318 let invoice_request = match self.flow.verify_invoice_request(invoice_request, context) {
1431914319 Ok(InvreqResponseInstructions::SendInvoice(invoice_request)) => invoice_request,
14320- Ok(InvreqResponseInstructions::SendStaticInvoice {
14321- recipient_id: _recipient_id, invoice_id: _invoice_id
14322- }) => {
14320+ Ok(InvreqResponseInstructions::SendStaticInvoice { recipient_id, invoice_id }) => {
1432314321 self.pending_events.lock().unwrap().push_back((Event::StaticInvoiceRequested {
14324- recipient_id: _recipient_id , invoice_id: _invoice_id , reply_path: responder
14322+ recipient_id, invoice_id, reply_path: responder
1432514323 }, None));
1432614324
1432714325 return None
@@ -14443,29 +14441,29 @@ where
1444314441 L::Target: Logger,
1444414442{
1444514443 fn handle_offer_paths_request(
14446- &self, _message: OfferPathsRequest, _context : AsyncPaymentsContext,
14447- _responder : Option<Responder>,
14444+ &self, _message: OfferPathsRequest, context : AsyncPaymentsContext,
14445+ responder : Option<Responder>,
1444814446 ) -> Option<(OfferPaths, ResponseInstruction)> {
1444914447 let peers = self.get_peers_for_blinded_path();
1445014448 let entropy = &*self.entropy_source;
1445114449 let (message, reply_path_context) =
14452- match self.flow.handle_offer_paths_request(_context , peers, entropy) {
14450+ match self.flow.handle_offer_paths_request(context , peers, entropy) {
1445314451 Some(msg) => msg,
1445414452 None => return None,
1445514453 };
14456- _responder .map(|resp| (message, resp.respond_with_reply_path(reply_path_context)))
14454+ responder .map(|resp| (message, resp.respond_with_reply_path(reply_path_context)))
1445714455 }
1445814456
1445914457 fn handle_offer_paths(
14460- &self, _message : OfferPaths, _context : AsyncPaymentsContext, _responder : Option<Responder>,
14458+ &self, message : OfferPaths, context : AsyncPaymentsContext, responder : Option<Responder>,
1446114459 ) -> Option<(ServeStaticInvoice, ResponseInstruction)> {
14462- let responder = match _responder {
14460+ let responder = match responder {
1446314461 Some(responder) => responder,
1446414462 None => return None,
1446514463 };
1446614464 let (serve_static_invoice, reply_context) = match self.flow.handle_offer_paths(
14467- _message ,
14468- _context ,
14465+ message ,
14466+ context ,
1446914467 responder.clone(),
1447014468 self.get_peers_for_blinded_path(),
1447114469 self.list_usable_channels(),
@@ -14484,25 +14482,25 @@ where
1448414482 }
1448514483
1448614484 fn handle_serve_static_invoice(
14487- &self, _message : ServeStaticInvoice, _context : AsyncPaymentsContext,
14488- _responder : Option<Responder>,
14485+ &self, message : ServeStaticInvoice, context : AsyncPaymentsContext,
14486+ responder : Option<Responder>,
1448914487 ) {
14490- let responder = match _responder {
14488+ let responder = match responder {
1449114489 Some(resp) => resp,
1449214490 None => return,
1449314491 };
1449414492
1449514493 let (recipient_id, invoice_id) =
14496- match self.flow.verify_serve_static_invoice_message(&_message, _context ) {
14494+ match self.flow.verify_serve_static_invoice_message(&message, context ) {
1449714495 Ok((recipient_id, inv_id)) => (recipient_id, inv_id),
1449814496 Err(()) => return,
1449914497 };
1450014498
1450114499 let mut pending_events = self.pending_events.lock().unwrap();
1450214500 pending_events.push_back((
1450314501 Event::PersistStaticInvoice {
14504- invoice: _message .invoice,
14505- invoice_slot: _message .invoice_slot,
14502+ invoice: message .invoice,
14503+ invoice_slot: message .invoice_slot,
1450614504 recipient_id,
1450714505 invoice_id,
1450814506 invoice_persisted_path: responder,
@@ -14512,24 +14510,24 @@ where
1451214510 }
1451314511
1451414512 fn handle_static_invoice_persisted(
14515- &self, _message: StaticInvoicePersisted, _context : AsyncPaymentsContext,
14513+ &self, _message: StaticInvoicePersisted, context : AsyncPaymentsContext,
1451614514 ) {
14517- let should_persist = self.flow.handle_static_invoice_persisted(_context );
14515+ let should_persist = self.flow.handle_static_invoice_persisted(context );
1451814516 if should_persist {
1451914517 let _persistence_guard = PersistenceNotifierGuard::notify_on_drop(self);
1452014518 }
1452114519 }
1452214520
1452314521 fn handle_held_htlc_available(
14524- &self, _message: HeldHtlcAvailable, _context : AsyncPaymentsContext,
14525- _responder : Option<Responder>,
14522+ &self, _message: HeldHtlcAvailable, context : AsyncPaymentsContext,
14523+ responder : Option<Responder>,
1452614524 ) -> Option<(ReleaseHeldHtlc, ResponseInstruction)> {
14527- self.flow.verify_inbound_async_payment_context(_context ).ok()?;
14528- return _responder .map(|responder| (ReleaseHeldHtlc {}, responder.respond()));
14525+ self.flow.verify_inbound_async_payment_context(context ).ok()?;
14526+ return responder .map(|responder| (ReleaseHeldHtlc {}, responder.respond()));
1452914527 }
1453014528
14531- fn handle_release_held_htlc(&self, _message: ReleaseHeldHtlc, _context : AsyncPaymentsContext) {
14532- let payment_id = match _context {
14529+ fn handle_release_held_htlc(&self, _message: ReleaseHeldHtlc, context : AsyncPaymentsContext) {
14530+ let payment_id = match context {
1453314531 AsyncPaymentsContext::OutboundPayment { payment_id } => payment_id,
1453414532 _ => return,
1453514533 };
0 commit comments