-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathCommandSet.go
65 lines (61 loc) · 1.27 KB
/
CommandSet.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
package barnacle
import (
"net/http"
"bytes"
"os/exec"
"fmt"
"strings"
)
type CommandSet struct {
Path string
}
func NewCommandSet(p string) *CommandSet {
cs := &CommandSet{ Path: p }
return cs
}
func (c *CommandSet) Handler() http.Handler {
// Handles an HTTP-ish request made to Barnacle server
return http.HandlerFunc(func (w http.ResponseWriter, r *http.Request) {
var jr JsonResponse
var sc int
var errbuf bytes.Buffer
var out []byte
cm := CommandMapper{
RequestUri: r.RequestURI,
CommandsPath: c.Path,
Method: r.Method,
}
cfp, err := cm.Filepath()
if err != nil {
sc = 404
} else {
for {
cmd := exec.Command(cfp)
cmd.Stderr = &errbuf
out, err = cmd.Output()
if err != nil {
sc = 500
break
}
sc = 200
break
}
}
if err != nil {
var errMsg string
if sc == 404 {
errMsg = "The URL path %s is not a valid resource for method %s."
errMsg = fmt.Sprintf(errMsg, r.RequestURI, r.Method)
} else {
errMsg = strings.Trim(errbuf.String(), "\n")
}
jr = NewFailJsonResponse(errMsg)
} else {
body := strings.Trim(string(out), "\n")
jr = NewOkJsonResponse(body)
}
w.Header().Set("Content-Type", "application/json")
w.WriteHeader(sc)
w.Write(jr.ToByteArray())
});
}