ft backend: SubscribeChannels

network/backend/backend.go

@@ -10,6 +10,8 @@ import (
 type Backend interface {
 	SubscribeInvoice(context.Context, chan *models.Invoice) error
 
+	SubscribeChannels(context.Context, chan *models.ChannelUpdate) error
+
 	NodeName() string
 
 	Info(ctx context.Context) (*models.Info, error)

network/backend/lnd/lnd.go

@@ -74,6 +74,27 @@ func (l Backend) SubscribeInvoice(ctx context.Context, channelInvoice chan *mode
 	}
 }
 
+func (l Backend) SubscribeChannels(ctx context.Context, events chan *models.ChannelUpdate) error {
+	_, err := l.Client(ctx)
+	if err != nil {
+		return err
+	}
+
+	// events, err := clt.SubscribeChannelEvents(ctx, &lnrpc.ChannelEventSubscription{})
+	// if err != nil {
+	// 	return err
+	// }
+
+	// for {
+	// 	event, err := events.Recv()
+	// 	if err != nil {
+	// 		return err
+	// 	}
+	// events <-
+	//}
+	return nil
+}
+
 func (l Backend) Client(ctx context.Context) (*Client, error) {
 	conn, err := l.pool.Get(ctx)
 	if err != nil {

network/backend/mock/mock.go

@@ -38,6 +38,10 @@ func (b *Backend) SubscribeInvoice(ctx context.Context, ChannelInvoice chan *mod
 	return nil
 }
 
+func (b *Backend) SubscribeChannels(context.Context, chan *models.ChannelUpdate) error {
+	return nil
+}
+
 func (b *Backend) GetWalletBalance(ctx context.Context) (*models.WalletBalance, error) {
 	return &models.WalletBalance{}, nil
 }

network/models/channel.go

@@ -52,3 +52,6 @@ func (m Channel) MarshalLogObject(enc logging.ObjectEncoder) error {
 
 	return nil
 }
+
+type ChannelUpdate struct {
+}