feature: Adding service run command

cmd/root.go

@@ -36,6 +36,8 @@ func init() {
 	rootCmd.AddCommand(addPeerCmd)
 	rootCmd.AddCommand(upCmd)
 	rootCmd.AddCommand(signalCmd)
+	rootCmd.AddCommand(serviceCmd)
+	serviceCmd.AddCommand(runCmd) // run is a subcommand of service
 }
 
 // SetupCloseHandler handles SIGTERM signal and exits with success

cmd/service.go

@@ -0,0 +1,26 @@
+package cmd
+
+import (
+	"github.com/kardianos/service"
+	"github.com/spf13/cobra"
+)
+
+func newSVCConfig() *service.Config {
+	return &service.Config{
+		Name:        "wiretrustee",
+		DisplayName: "wiretrustee",
+		Description: "This is an example Go service.",
+	}
+}
+
+var (
+	serviceCmd = &cobra.Command{
+		Use:   "service",
+		Short: "manages wiretrustee service",
+		//Run: func(cmd *cobra.Command, args []string) {
+		//},
+	}
+)
+
+func init() {
+}

cmd/service_run.go

@@ -0,0 +1,58 @@
+package cmd
+
+import (
+	"github.com/kardianos/service"
+	log "github.com/sirupsen/logrus"
+	"github.com/spf13/cobra"
+)
+
+type program struct {
+	cmd  *cobra.Command
+	args []string
+}
+
+var logger service.Logger
+
+func (p *program) Start(s service.Service) error {
+	// Start should not block. Do the actual work async.
+	logger.Info("Starting service") //nolint
+	go upCmd.Run(p.cmd, p.args)
+	return nil
+}
+
+func (p *program) Stop(s service.Service) error {
+	stopUP <- 1
+	return nil
+}
+
+var (
+	runCmd = &cobra.Command{
+		Use:   "run",
+		Short: "runs wiretrustee as service",
+		Run: func(cmd *cobra.Command, args []string) {
+
+			svcConfig := newSVCConfig()
+
+			prg := &program{
+				cmd:  cmd,
+				args: args,
+			}
+			s, err := service.New(prg, svcConfig)
+			if err != nil {
+				log.Fatal(err)
+			}
+			logger, err = s.Logger(nil)
+			if err != nil {
+				log.Fatal(err)
+			}
+
+			err = s.Run()
+			if err != nil {
+				logger.Error(err) //nolint
+			}
+		},
+	}
+)
+
+func init() {
+}

cmd/up.go

@@ -48,10 +48,15 @@ var (
 			//signalClient.WaitConnected()
 
 			SetupCloseHandler()
-			select {}
+			<-stopUP
+			log.Println("Receive signal to stop running")
 		},
 	}
 )
 
+// Execution control channel for stopUP signal
+var stopUP chan int
+
 func init() {
+	stopUP = make(chan int)
 }