the goods

Author: mattrobenolt

.dockerignore

@@ -0,0 +1,5 @@
+Dockerfile
+.git
+bin
+src
+README.md

.gitignore

@@ -22,3 +22,6 @@ _testmain.go
 *.exe
 *.test
 *.prof
+
+src
+bin

Dockerfile

@@ -0,0 +1,20 @@
+FROM golang:1.4-cross
+
+RUN mkdir -p /go/src/app
+WORKDIR /go/src/app
+
+ENV CROSSPLATFORMS \
+        linux/amd64 linux/386 linux/arm \
+        darwin/amd64 darwin/386 \
+        freebsd/amd64 freebsd/386 freebsd/arm \
+        windows/amd64 windows/386
+
+ENV GOARM 5
+
+CMD set -x \
+    && go-wrapper download \
+    && for platform in $CROSSPLATFORMS; do \
+            GOOS=${platform%/*} \
+            GOARCH=${platform##*/} \
+                go build -v -o bin/email-me-${platform%/*}-${platform##*/}; \
+    done

build.sh

@@ -0,0 +1,6 @@
+#!/bin/bash
+set -x
+
+rm -rf bin/
+docker build --rm -t email-me .
+docker run --rm -v $PWD:/go/src/app -it email-me

command.go

@@ -0,0 +1,88 @@
+package main
+
+import (
+	"bytes"
+	"os"
+	"os/exec"
+	"os/user"
+	"text/template"
+	"time"
+)
+
+const emailTemplate = `From: {{.From}}
+To: {{.To}}
+Subject: {{.Subject}}
+
+Cmd: {{.Result.Cmd.Args}}
+Start: {{.Result.Start}}
+End: {{.Result.End}}
+Duration: {{.Result.Duration}}
+ProcessState: {{.Result.Cmd.ProcessState}}
+Error: {{.Result.Error}}
+Stderr:{{if .Result.StderrExtra}}
+... {{.Result.StderrExtra}} more bytes ...{{end}}
+{{.Result.Stderr}}
+
+Stdout:{{if .Result.StdoutExtra}}
+... {{.Result.StdoutExtra}} more bytes ...{{end}}
+{{.Result.Stdout}}
+`
+
+type Message struct {
+	To      string
+	From    string
+	Subject string
+	Result  *Result
+}
+
+func (m *Message) Bytes() []byte {
+	var buf bytes.Buffer
+	t := template.New("mail")
+	t, _ = t.Parse(emailTemplate)
+	t.Execute(&buf, m)
+	return buf.Bytes()
+}
+
+func (m *Message) String() string {
+	return string(m.Bytes())
+}
+
+type Result struct {
+	Cmd         *exec.Cmd
+	Error       error
+	Start       time.Time
+	End         time.Time
+	Duration    time.Duration
+	Stdout      string
+	Stderr      string
+	StdoutExtra int
+	StderrExtra int
+}
+
+func identity() string {
+	var username string
+	user, err := user.Current()
+	if err != nil {
+		username = "root"
+	} else {
+		username = user.Username
+	}
+
+	hostname, err := os.Hostname()
+	if err != nil {
+		hostname = "localhost"
+	}
+	return username + "@" + hostname
+}
+
+type Mailer interface {
+	Send([]string, string, []byte) error
+}
+
+func findMailer() Mailer {
+	if _, err := exec.LookPath("sendmail"); err == nil {
+		return &SendMailMailer{}
+	}
+
+	return &SMTPMailer{}
+}

main.go

@@ -0,0 +1,97 @@
+package main
+
+import (
+	"flag"
+	"fmt"
+	"io"
+	"log"
+	"os"
+	"os/exec"
+	"runtime"
+	"time"
+
+	"github.com/cespare/window"
+	"github.com/jeanfric/goembed/countingwriter"
+)
+
+const Version = "0.1.0"
+
+var (
+	toFlag      = flag.String("to", "", "email address to send output to")
+	subjectFlag = flag.String("s", "", "subject of email (optional)")
+	maxFlag     = flag.Int("max", 10000, "max bytes to capture for stdout/stderr")
+)
+
+func usageAndExit(s string) {
+	fmt.Printf("!! %s\n", s)
+	flag.Usage()
+	fmt.Println()
+	fmt.Printf("%s version: %s (%s on %s/%s; %s)\n", os.Args[0], Version, runtime.Version(), runtime.GOOS, runtime.GOARCH, runtime.Compiler)
+	os.Exit(1)
+}
+
+func init() {
+	runtime.GOMAXPROCS(1)
+	runtime.LockOSThread()
+
+	flag.Usage = func() {
+		fmt.Fprint(os.Stderr, "usage: email-me [flags] [command]\n")
+		flag.PrintDefaults()
+	}
+	flag.Parse()
+}
+
+func main() {
+	if *toFlag == "" {
+		usageAndExit("missing -to=[address]")
+	}
+
+	args := flag.Args()
+	if len(args) == 0 {
+		usageAndExit("missing [command]")
+	}
+
+	truncStdout := window.NewWriter(*maxFlag)
+	truncStderr := window.NewWriter(*maxFlag)
+	countedStdout := countingwriter.New(truncStdout)
+	countedStderr := countingwriter.New(truncStderr)
+	child := exec.Command(args[0], args[1:]...)
+	child.Stdout = io.MultiWriter(os.Stdout, countedStdout)
+	child.Stderr = io.MultiWriter(os.Stderr, countedStderr)
+
+	start := time.Now()
+	err := child.Run()
+	end := time.Now()
+
+	stdout := truncStdout.Bytes()
+	stderr := truncStderr.Bytes()
+
+	r := &Result{
+		Cmd:         child,
+		Error:       err,
+		Start:       start,
+		End:         end,
+		Duration:    end.Sub(start),
+		Stdout:      string(stdout),
+		Stderr:      string(stderr),
+		StdoutExtra: countedStdout.BytesWritten() - len(stdout),
+		StderrExtra: countedStderr.BytesWritten() - len(stderr),
+	}
+
+	me := identity()
+	subject := *subjectFlag
+	if subject == "" {
+		subject = fmt.Sprintf("%s", child.Args)
+	}
+
+	m := &Message{
+		To:      *toFlag,
+		From:    me,
+		Subject: subject,
+		Result:  r,
+	}
+
+	if err := findMailer().Send([]string{*toFlag}, me, m.Bytes()); err != nil {
+		log.Fatal(err)
+	}
+}

sendmail.go

@@ -0,0 +1,14 @@
+package main
+
+import (
+	"bytes"
+	"os/exec"
+)
+
+type SendMailMailer struct{}
+
+func (m *SendMailMailer) Send(to []string, from string, body []byte) error {
+	sendmail := exec.Command("sendmail", to...)
+	sendmail.Stdin = bytes.NewReader(body)
+	return sendmail.Run()
+}

smtp.go

@@ -0,0 +1,9 @@
+package main
+
+import "net/smtp"
+
+type SMTPMailer struct{}
+
+func (m *SMTPMailer) Send(to []string, from string, body []byte) error {
+	return smtp.SendMail("localhost:25", nil, from, to, body)
+}