-
Notifications
You must be signed in to change notification settings - Fork 0
/
invoke.go
82 lines (66 loc) · 2.09 KB
/
invoke.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
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
// Sample helloworld-shell is a Cloud Run shell-script-as-a-service.
package main
import (
"encoding/json"
"fmt"
"log"
"net/http"
"os"
"os/exec"
"strings"
)
func main() {
http.HandleFunc("/", scriptHandler)
// Determine port for HTTP service.
port := os.Getenv("PORT")
if port == "" {
port = "8080"
log.Printf("Yes Defaulting to port %s", port)
}
// Start HTTP server.
log.Printf("Listening on port %s", port)
if err := http.ListenAndServe(":"+port, nil); err != nil {
log.Fatal(err)
}
}
type ScriptBody struct {
RepoSourceBranch string
RepoTargetBranch string
RepoName string
RepoUser string
BitbucketUser string
}
func enableCors(w *http.ResponseWriter) {
(*w).Header().Set("Access-Control-Allow-Origin", "*")
(*w).Header().Set("Access-Control-Allow-Methods", "GET, POST")
(*w).Header().Set("Access-Control-Allow-Headers", "*")
}
func scriptHandler(w http.ResponseWriter, r *http.Request) {
enableCors(&w)
log.Println("running bit bucket automerge script")
var sb ScriptBody
// Try to decode the request body into the struct. If there is an error,
// respond to the client with the error message and a 400 status code.
err := json.NewDecoder(r.Body).Decode(&sb)
if err != nil {
http.Error(w, err.Error(), http.StatusBadRequest)
return
}
log.Println(sb.RepoSourceBranch)
// get password from authentication header
reqToken := r.Header.Get("Authorization")
splitToken := strings.Split(reqToken, "Bearer ")
reqToken = splitToken[1]
// output script for debugging
cmdStr := fmt.Sprintf("script.sh -s %s -d %s -u %s -p %s --repo-owner %s --repo-slug %s", sb.RepoSourceBranch, sb.RepoTargetBranch, sb.BitbucketUser, reqToken, sb.RepoUser, sb.RepoName)
log.Println(cmdStr)
// run script
cmd := exec.CommandContext(r.Context(), "/bin/bash", "script.sh", "-s", sb.RepoSourceBranch, "-d", sb.RepoTargetBranch, "-u", sb.BitbucketUser, "-p", reqToken, "--repo-owner", sb.RepoUser, "--repo-slug", sb.RepoName) //cmdStr)
cmd.Stderr = os.Stderr
out, err := cmd.Output()
if err != nil {
w.WriteHeader(500)
}
// output results in the return body
w.Write(out)
}