Merge pull request #80 from iron-io/stdin

Streams stderr from user functions and outputs a standard format for …

api/runner/logger.go

@@ -0,0 +1,37 @@
+package runner
+
+import (
+	"bufio"
+	"io"
+
+	"github.com/Sirupsen/logrus"
+)
+
+// FuncLogger reads STDERR output from a container and outputs it in a parseable structured log format, see: https://github.com/iron-io/functions/issues/76
+type FuncLogger struct {
+	r io.Reader
+	w io.Writer
+}
+
+func NewFuncLogger(appName, path, function, requestID string) io.Writer {
+	r, w := io.Pipe()
+	funcLogger := &FuncLogger{
+		r: r,
+		w: w,
+	}
+	log := logrus.WithFields(logrus.Fields{"user_log": true, "app_name": appName, "path": path, "function": function, "request_id": requestID})
+	go func(reader io.Reader) {
+		scanner := bufio.NewScanner(reader)
+		for scanner.Scan() {
+			log.Println(scanner.Text())
+		}
+		if err := scanner.Err(); err != nil {
+			log.WithError(err).Println("There was an error with the scanner in attached container")
+		}
+	}(r)
+	return funcLogger
+}
+
+func (l *FuncLogger) Write(p []byte) (n int, err error) {
+	return l.w.Write(p)
+}

api/server/runner.go

@@ -112,7 +112,9 @@ func handleRunner(c *gin.Context) {
 	log.WithField("routes", routes).Debug("Got routes from datastore")
 	for _, el := range routes {
 		if params, match := matchRoute(el.Path, route); match {
-			var stdout, stderr bytes.Buffer
+
+			var stdout bytes.Buffer // TODO: should limit the size of this, error if gets too big. akin to: https://golang.org/pkg/io/#LimitReader
+			stderr := runner.NewFuncLogger(appName, route, el.Image, reqID)
 
 			envVars := map[string]string{
 				"METHOD":      c.Request.Method,
@@ -147,7 +149,7 @@ func handleRunner(c *gin.Context) {
 				ID:      reqID,
 				AppName: appName,
 				Stdout:  &stdout,
-				Stderr:  &stderr,
+				Stderr:  stderr,
 				Env:     envVars,
 			}
 
@@ -162,7 +164,7 @@ func handleRunner(c *gin.Context) {
 				if result.Status() == "success" {
 					c.Data(http.StatusOK, "", stdout.Bytes())
 				} else {
-					log.WithFields(logrus.Fields{"app": appName, "route": el, "req_id": reqID}).Debug(stderr.String())
+					// log.WithFields(logrus.Fields{"app": appName, "route": el, "req_id": reqID}).Debug(stderr.String())
 					c.AbortWithStatus(http.StatusInternalServerError)
 				}
 			}

api/server/version.go

@@ -7,7 +7,7 @@ import (
 )
 
 // Version of IronFunctions
-var Version = "0.0.2"
+var Version = "0.0.31"
 
 func handleVersion(c *gin.Context) {
 	c.JSON(http.StatusOK, gin.H{"version": Version})