lsps2: use paymentFailure chan for timeouts

lsps2/intercept_handler.go

@@ -39,7 +39,6 @@ type Interceptor struct {
 	registrationReady        chan *registrationReadyEvent
 	notRegistered            chan string
 	paymentReady             chan string
-	paymentTimeout           chan string
 	paymentFailure           chan *paymentFailureEvent
 	paymentChanOpened        chan *paymentChanOpenedEvent
 	inflightPayments         map[string]*paymentState
@@ -68,7 +67,6 @@ func NewInterceptHandler(
 		registrationReady:        make(chan *registrationReadyEvent, 1000),
 		notRegistered:            make(chan string, 1000),
 		paymentReady:             make(chan string, 1000),
-		paymentTimeout:           make(chan string, 1000),
 		paymentFailure:           make(chan *paymentFailureEvent, 1000),
 		paymentChanOpened:        make(chan *paymentChanOpenedEvent, 1000),
 		inflightPayments:         make(map[string]*paymentState),
@@ -148,8 +146,6 @@ func (i *Interceptor) Start(ctx context.Context) {
 			i.handlePartAwaitingRegistration(ev)
 		case paymentId := <-i.paymentReady:
 			i.handlePaymentReady(paymentId)
-		case paymentId := <-i.paymentTimeout:
-			i.handlePaymentTimeout(paymentId)
 		case ev := <-i.paymentFailure:
 			i.handlePaymentFailure(ev.paymentId, ev.code)
 		case ev := <-i.paymentChanOpened:
@@ -159,23 +155,27 @@ func (i *Interceptor) Start(ctx context.Context) {
 }
 
 func (i *Interceptor) handleNewPart(part *partState) {
-	payment, paymentExisted := i.inflightPayments[part.req.PaymentId()]
+	paymentId := part.req.PaymentId()
+	payment, paymentExisted := i.inflightPayments[paymentId]
 	if !paymentExisted {
 		payment = &paymentState{
-			id:          part.req.PaymentId(),
+			id:          paymentId,
 			fakeScid:    part.req.Scid,
 			parts:       make(map[string]*partState),
 			timeoutChan: make(chan struct{}),
 		}
-		i.inflightPayments[part.req.PaymentId()] = payment
+		i.inflightPayments[paymentId] = payment
 
 		go func() {
 			select {
 			case <-time.After(i.config.MppTimeout):
 				// Handle timeout inside the event loop, to make sure there are
 				// no race conditions, since this timeout watcher is running in
 				// a goroutine.
-				i.paymentTimeout <- part.req.PaymentId()
+				i.paymentFailure <- &paymentFailureEvent{
+					paymentId: paymentId,
+					code:      shared.FAILURE_TEMPORARY_CHANNEL_FAILURE,
+				}
 			case <-payment.timeoutChan:
 				// Stop listening for timeouts when the payment is ready.
 			}
@@ -666,10 +666,6 @@ func (i *Interceptor) handlePaymentChanOpened(event *paymentChanOpenedEvent) {
 	delete(i.inflightPayments, event.paymentId)
 }
 
-func (i *Interceptor) handlePaymentTimeout(paymentId string) {
-	i.handlePaymentFailure(paymentId, shared.FAILURE_TEMPORARY_CHANNEL_FAILURE)
-}
-
 func (i *Interceptor) handlePaymentFailure(
 	paymentId string,
 	code shared.InterceptFailureCode,