slack us the logs

Gopkg.toml

@@ -33,3 +33,7 @@
 [[constraint]]
   branch = "master"
   name = "github.com/phayes/freeport"
+
+[[constraint]]
+  branch = "master"
+  name = "github.com/johntdyer/slackrus"

cmd/reflector.go

@@ -7,6 +7,7 @@ import (
 	"syscall"
 
 	"github.com/lbryio/reflector.go/db"
+	"github.com/lbryio/reflector.go/meta"
 	"github.com/lbryio/reflector.go/reflector"
 	"github.com/lbryio/reflector.go/store"
 
@@ -24,6 +25,7 @@ func init() {
 }
 
 func reflectorCmd(cmd *cobra.Command, args []string) {
+	log.Printf("reflector version %s", meta.Version)
 	db := new(db.SQL)
 	err := db.Connect(globalConfig.DBConn)
 	if err != nil {

cmd/root.go

@@ -9,6 +9,7 @@ import (
 	"github.com/lbryio/lbry.go/util"
 	"github.com/lbryio/reflector.go/dht"
 
+	"github.com/johntdyer/slackrus"
 	"github.com/sirupsen/logrus"
 	"github.com/spf13/cobra"
 )
@@ -20,6 +21,7 @@ type Config struct {
 	BucketRegion string `json:"bucket_region"`
 	BucketName   string `json:"bucket_name"`
 	DBConn       string `json:"db_conn"`
+	SlackHookURL string `json:"slack_hook_url"`
 }
 
 var verbose []string
@@ -34,39 +36,9 @@ var conf string
 var globalConfig Config
 
 var rootCmd = &cobra.Command{
-	Use:   "prism",
-	Short: "Prism is a single entry point application with multiple sub modules which can be leveraged individually or together",
-	PersistentPreRun: func(cmd *cobra.Command, args []string) {
-		debugLogger := logrus.New()
-		debugLogger.SetLevel(logrus.DebugLevel)
-
-		if util.InSlice(verboseAll, verbose) {
-			logrus.SetLevel(logrus.DebugLevel)
-			verbose = []string{verboseDHT, verboseNodeFinder}
-		}
-
-		for _, debugType := range verbose {
-			switch debugType {
-			case verboseDHT:
-				dht.UseLogger(debugLogger)
-			case verboseNodeFinder:
-				dht.NodeFinderUseLogger(debugLogger)
-			}
-		}
-
-		var err error
-		if conf == "" {
-			logrus.Errorln("--conf flag required")
-			os.Exit(1)
-		} else if conf != "none" {
-			globalConfig, err = loadConfig(conf)
-			if err != nil {
-				logrus.Error(err)
-				os.Exit(1)
-			}
-		}
-	},
-
+	Use:              "prism",
+	Short:            "Prism is a single entry point application with multiple sub modules which can be leveraged individually or together",
+	PersistentPreRun: preRun,
 	// Uncomment the following line if your bare application
 	// has an action associated with it:
 	//	Run: func(cmd *cobra.Command, args []string) { },
@@ -87,6 +59,51 @@ func Execute() {
 	}
 }
 
+func preRun(cmd *cobra.Command, args []string) {
+	debugLogger := logrus.New()
+	debugLogger.SetLevel(logrus.DebugLevel)
+	debugLogger.SetOutput(os.Stderr)
+
+	if util.InSlice(verboseAll, verbose) {
+		logrus.SetLevel(logrus.DebugLevel)
+		verbose = []string{verboseDHT, verboseNodeFinder}
+	}
+
+	for _, debugType := range verbose {
+		switch debugType {
+		case verboseDHT:
+			dht.UseLogger(debugLogger)
+		case verboseNodeFinder:
+			dht.NodeFinderUseLogger(debugLogger)
+		}
+	}
+
+	var err error
+	if conf == "" {
+		logrus.Errorln("--conf flag required")
+		os.Exit(1)
+	} else if conf != "none" {
+		globalConfig, err = loadConfig(conf)
+		if err != nil {
+			logrus.Error(err)
+			os.Exit(1)
+		}
+	}
+
+	if globalConfig.SlackHookURL != "" {
+		hook := &slackrus.SlackrusHook{
+			HookURL:        globalConfig.SlackHookURL,
+			AcceptedLevels: slackrus.LevelThreshold(logrus.InfoLevel),
+			Channel:        "#reflector-logs",
+			//IconEmoji:      ":ghost:",
+			//Username:       "reflector.go",
+		}
+		//logrus.SetFormatter(&logrus.JSONFormatter{})
+		logrus.AddHook(hook)
+		debugLogger.AddHook(hook)
+	}
+}
+
 func checkErr(err error) {
 	if err != nil {
 		panic(err)