Parse and execute a simple bash script.

script.sh

ls -la
echo "hello"
tree 
adb devices
adb wait-for-device #example of a long running task

scriptworker.go

package main

import (
	"bufio"
	"fmt"
	shlex "github.com/flynn/go-shlex"
	"gopkg.in/pipe.v2"
	"os"
	"time"
)

func readLines(path string) []string {
	inFile, _ := os.Open(path)
	defer inFile.Close()
	scanner := bufio.NewScanner(inFile)
	scanner.Split(bufio.ScanLines)
	var lines []string

	for scanner.Scan() {
		lines = append(lines, scanner.Text())

	}

	return lines
}

func execScript(script []string, status chan string, log chan string, quit chan bool) {
	s := pipe.NewState(nil, nil)
	go func() {
		for _, v := range script {
			args, err := shlex.Split(v)
			if err != nil {
				fmt.Println(err)
			}
			p := pipe.Line(pipe.Exec(args[0], args[1:]...), pipe.Filter(func(line []byte) bool {
				log <- string(line)

				return true
			}))
			p(s)
			cmdline := args[0] + " " + fmt.Sprintf("%s", args[1:])
			s.RunTasks()
			status <- cmdline

		}

	}()
	<-quit
	s.Kill()
}

func main() {
	script := readLines("script.sh")
	status := make(chan string)
	log := make(chan string)
	quit := make(chan bool)
	go execScript(script, status, log, quit)
loop:
	for {
		select {
		case s := <-status:
			fmt.Printf(">>task done: %v\n", s)
		case l := <-log:
			fmt.Println(l)
		case <-time.After(time.Second * 10):
			fmt.Println("timed out\n")
			quit <- true
			break loop

		}

	}

}

this would be a great idea if I could extract all the multiline EXPORTS and execute ${var} substitutions