Merge branch 'fn-start' into 'master'

Added fn start and fn update commands

Closes #22

See merge request !11

fn/common.go

@@ -14,6 +14,10 @@ import (
 	"gitlab.oracledx.com/odx/functions/fn/langs"
 )
 
+const (
+	functionsDockerImage = "treeder/functions"
+)
+
 func verbwriter(verbose bool) io.Writer {
 	// this is too limiting, removes all logs which isn't what we want
 	// verbwriter := ioutil.Discard

fn/main.go

@@ -70,6 +70,8 @@ GLOBAL OPTIONS:
 		fmt.Fprintf(os.Stderr, "command not found: %v\n", cmd)
 	}
 	app.Commands = []cli.Command{
+		startCmd(),
+		updateCmd(),
 		initFn(),
 		apps(),
 		routes(),

fn/start.go

@@ -0,0 +1,79 @@
+package main
+
+import (
+	"fmt"
+	"os"
+	"os/exec"
+	"os/signal"
+	"syscall"
+
+	"github.com/Sirupsen/logrus"
+	"github.com/urfave/cli"
+)
+
+func startCmd() cli.Command {
+	return cli.Command{
+		Name:   "start",
+		Usage:  "start a functions server",
+		Action: start,
+		Flags: []cli.Flag{
+			cli.StringFlag{
+				Name:  "log-level",
+				Usage: "--log-level DEBUG to enable debugging",
+			},
+		},
+	}
+}
+
+func start(c *cli.Context) error {
+	denvs := []string{}
+	if c.String("log-level") != "" {
+		denvs = append(denvs, "GIN_MODE="+c.String("log-level"))
+	}
+	// docker run --rm -it --name functions -v ${PWD}/data:/app/data -v /var/run/docker.sock:/var/run/docker.sock -p 8080:8080 treeder/functions
+	wd, err := os.Getwd()
+	if err != nil {
+		logrus.WithError(err).Fatalln("Getwd failed")
+	}
+	args := []string{"run", "--rm", "-i",
+		"--name", "functions",
+		"-v", fmt.Sprintf("%s/data:/app/data", wd),
+		"-v", "/var/run/docker.sock:/var/run/docker.sock",
+		"-p", "8080:8080",
+	}
+	for _, v := range denvs {
+		args = append(args, "-e", v)
+	}
+	args = append(args, functionsDockerImage)
+	cmd := exec.Command("docker", args...)
+	cmd.Stdout = os.Stdout
+	cmd.Stderr = os.Stderr
+	err = cmd.Start()
+	if err != nil {
+		logrus.WithError(err).Fatalln("starting command failed")
+	}
+
+	done := make(chan error, 1)
+	go func() {
+		done <- cmd.Wait()
+	}()
+	// catch ctrl-c and kill
+	sigC := make(chan os.Signal, 2)
+	signal.Notify(sigC, os.Interrupt, syscall.SIGTERM)
+
+	select {
+	case <-sigC:
+		logrus.Infoln("interrupt caught, exiting")
+		err = cmd.Process.Kill()
+		if err != nil {
+			logrus.WithError(err).Errorln("Could not kill process")
+		}
+	case err := <-done:
+		if err != nil {
+			logrus.WithError(err).Errorln("processed finished with error")
+		} else {
+			logrus.Println("process done gracefully without error")
+		}
+	}
+	return nil
+}

fn/update.go

@@ -0,0 +1,55 @@
+package main
+
+import (
+	"os"
+	"os/exec"
+	"os/signal"
+	"syscall"
+
+	"github.com/Sirupsen/logrus"
+	"github.com/urfave/cli"
+)
+
+func updateCmd() cli.Command {
+	return cli.Command{
+		Name:   "update",
+		Usage:  "pulls latest functions server",
+		Action: update,
+	}
+}
+
+func update(c *cli.Context) error {
+	args := []string{"pull",
+		functionsDockerImage,
+	}
+	cmd := exec.Command("docker", args...)
+	cmd.Stdout = os.Stdout
+	cmd.Stderr = os.Stderr
+	err := cmd.Start()
+	if err != nil {
+		logrus.WithError(err).Fatalln("starting command failed")
+	}
+
+	done := make(chan error, 1)
+	go func() {
+		done <- cmd.Wait()
+	}()
+	// catch ctrl-c and kill
+	sigC := make(chan os.Signal, 2)
+	signal.Notify(sigC, os.Interrupt, syscall.SIGTERM)
+	select {
+	case <-sigC:
+		logrus.Infoln("interrupt caught, exiting")
+		err = cmd.Process.Kill()
+		if err != nil {
+			logrus.WithError(err).Errorln("Could not kill process")
+		}
+	case err := <-done:
+		if err != nil {
+			logrus.WithError(err).Errorln("processed finished with error")
+		} else {
+			logrus.Println("process done gracefully without error")
+		}
+	}
+	return nil
+}