|
|
@ -33,7 +33,7 @@ func (p *PubSub) invoices(ctx context.Context, sub chan *events.Event) {
|
|
|
|
|
|
|
|
|
|
|
|
go func() {
|
|
|
|
go func() {
|
|
|
|
for invoice := range invoices {
|
|
|
|
for invoice := range invoices {
|
|
|
|
p.logger.Debug("receive invoice", logging.Object("invoice", invoice))
|
|
|
|
p.logger.Info("receive invoice", logging.Object("invoice", invoice))
|
|
|
|
if invoice.Settled {
|
|
|
|
if invoice.Settled {
|
|
|
|
sub <- events.New(events.InvoiceSettled)
|
|
|
|
sub <- events.New(events.InvoiceSettled)
|
|
|
|
} else {
|
|
|
|
} else {
|
|
|
@ -66,7 +66,7 @@ func (p *PubSub) transactions(ctx context.Context, sub chan *events.Event) {
|
|
|
|
|
|
|
|
|
|
|
|
go func() {
|
|
|
|
go func() {
|
|
|
|
for tx := range transactions {
|
|
|
|
for tx := range transactions {
|
|
|
|
p.logger.Debug("receive transaction", logging.String("tx_hash", tx.TxHash))
|
|
|
|
p.logger.Info("receive transaction", logging.String("tx_hash", tx.TxHash))
|
|
|
|
sub <- events.New(events.TransactionCreated)
|
|
|
|
sub <- events.New(events.TransactionCreated)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
p.wg.Done()
|
|
|
|
p.wg.Done()
|
|
|
@ -95,7 +95,7 @@ func (p *PubSub) routingUpdates(ctx context.Context, sub chan *events.Event) {
|
|
|
|
|
|
|
|
|
|
|
|
go func() {
|
|
|
|
go func() {
|
|
|
|
for hu := range routingUpdates {
|
|
|
|
for hu := range routingUpdates {
|
|
|
|
p.logger.Debug("receive htlcUpdate")
|
|
|
|
p.logger.Info("receive htlcUpdate")
|
|
|
|
sub <- events.NewWithData(events.RoutingEventUpdated, hu)
|
|
|
|
sub <- events.NewWithData(events.RoutingEventUpdated, hu)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
p.wg.Done()
|
|
|
|
p.wg.Done()
|
|
|
|