Method ServeHTTP

lib/server.go:19–119

(w http.ResponseWriter, r *http.Request)

}

func (s *Server) ServeHTTP(w http.ResponseWriter, r *http.Request) {
	// Start subprocess
	cmd := exec.Command(s.Script[0], s.Script[1:]...)

	// Get handles to subprocess stdin, stdout and stderr
	stdinPipe, err := cmd.StdinPipe()
	if err != nil {
		log.Printf("error accessing subprocess stdin: %v", err)
		respError(w)
		return
	}
	defer stdinPipe.Close()
	stderrPipe, err := cmd.StderrPipe()
	if err != nil {
		log.Printf("error accessing subprocess stderr: %v", err)
		respError(w)
		return
	}
	stdoutPipe, err := cmd.StdoutPipe()
	if err != nil {
		log.Printf("error accessing subprocess stdout: %v", err)
		respError(w)
		return
	}

	// Start the subprocess
	err = cmd.Start()
	if err != nil {
		log.Printf("error starting subprocess: %v", err)
		respError(w)
		return
	}

	// We use a WaitGroup to wait for all goroutines to finish
	wg := sync.WaitGroup{}

	// Write request body to subprocess stdin
	wg.Add(1)
	go func() {
		defer func() {
			stdinPipe.Close()
			wg.Done()
		}()
		_, err = io.Copy(stdinPipe, r.Body)
		if err != nil {
			log.Printf("error writing request body to subprocess stdin: %v", err)
			respError(w)
			return
		}
	}()

	// Read all stderr and write to parent stderr if not empty
	wg.Add(1)
	go func() {
		defer wg.Done()
		stderr, err := ioutil.ReadAll(stderrPipe)
		if err != nil {
			log.Printf("error reading subprocess stderr: %v", err)