From 2df04c594bb75d3bc4c8b4e15ac5e08b978ea313 Mon Sep 17 00:00:00 2001
From: Edouard Paris <m@edouard.paris>
Date: Tue, 26 Mar 2019 17:48:58 +0100
Subject: [PATCH] cli: add pubsub command

---
 cli/cli.go | 23 +++++++++++++++++++++++
 1 file changed, 23 insertions(+)

diff --git a/cli/cli.go b/cli/cli.go
index a509111..962b63d 100644
--- a/cli/cli.go
+++ b/cli/cli.go
@@ -8,8 +8,10 @@ import (
 
 	"github.com/edouardparis/lntop/app"
 	"github.com/edouardparis/lntop/config"
+	"github.com/edouardparis/lntop/events"
 	"github.com/edouardparis/lntop/logging"
 	"github.com/edouardparis/lntop/network"
+	"github.com/edouardparis/lntop/pubsub"
 	"github.com/edouardparis/lntop/ui"
 )
 
@@ -42,6 +44,12 @@ func New() *cli.App {
 				Usage:   "",
 				Action:  walletBalance,
 			},
+			{
+				Name:    "pubsub",
+				Aliases: []string{""},
+				Usage:   "",
+				Action:  pubsubRun,
+			},
 		},
 	}
 }
@@ -60,6 +68,21 @@ func run(c *cli.Context) error {
 	return ui.Run(context.Background(), app)
 }
 
+func pubsubRun(c *cli.Context) error {
+	cfg, err := config.Load(c.String("config"))
+	if err != nil {
+		return err
+	}
+
+	app, err := app.New(cfg)
+	if err != nil {
+		return err
+	}
+
+	events := make(chan *events.Event)
+	return pubsub.Run(context.Background(), app, events)
+}
+
 func getNetworkFromConfig(c *cli.Context) (*network.Network, error) {
 	cfg, err := config.Load(c.String("config"))
 	if err != nil {