120 lines
2.8 KiB
Go
120 lines
2.8 KiB
Go
package main
|
|
|
|
import (
|
|
"encoding/json"
|
|
"fmt"
|
|
"io/ioutil"
|
|
"net/http"
|
|
"strings"
|
|
)
|
|
|
|
const INDENT = " "
|
|
|
|
func ListenForWebHook(config Config) {
|
|
http.HandleFunc("/", handleWebHook)
|
|
|
|
err := http.ListenAndServe(config.BindHost+":"+config.BindPort, nil)
|
|
|
|
if err != nil {
|
|
fmt.Println(err)
|
|
}
|
|
}
|
|
|
|
func handleWebHook(writer http.ResponseWriter, request *http.Request) {
|
|
defer request.Body.Close()
|
|
data, err := ioutil.ReadAll(request.Body)
|
|
if err != nil {
|
|
panic(err)
|
|
}
|
|
|
|
switch eventType := request.Header.Get("X-Gitea-Event"); eventType {
|
|
default:
|
|
fmt.Printf("Unknown event type: %q\n", eventType)
|
|
handleUnknown(data)
|
|
|
|
case "":
|
|
// Not a gitea event.
|
|
fmt.Printf("Got a non-event HTTP request %+v\n", request)
|
|
|
|
case "push":
|
|
handlePush(data)
|
|
|
|
case "issues":
|
|
handleIssueAction(data)
|
|
|
|
case "issue_comment":
|
|
handleIssueComment(data)
|
|
|
|
}
|
|
}
|
|
|
|
func printSep() {
|
|
fmt.Println("---")
|
|
}
|
|
|
|
func handleUnknown(data []byte) {
|
|
printSep()
|
|
fmt.Println(string(data))
|
|
}
|
|
|
|
func handlePush(data []byte) {
|
|
printSep()
|
|
pushData := Push{}
|
|
json.Unmarshal(data, &pushData)
|
|
fmt.Printf(
|
|
"Got a push for repo %q owned by %q. Pushed by %q (%q)\n",
|
|
pushData.Repository.FullName,
|
|
pushData.Repository.Owner.Login,
|
|
pushData.Pusher.Login,
|
|
pushData.Pusher.Email,
|
|
)
|
|
|
|
for _, commit := range pushData.Commits {
|
|
fmt.Println(INDENT + "--")
|
|
fmt.Printf(
|
|
INDENT+"Commit added by %q (%q), made by %q (%q), with hash %q and message:\n",
|
|
commit.Committer.Name,
|
|
commit.Committer.Email,
|
|
commit.Author.Name,
|
|
commit.Author.Email,
|
|
commit.Hash,
|
|
)
|
|
|
|
msg := strings.Replace(commit.Message, "\n", strings.Repeat(INDENT, 2)+"\n", -1)
|
|
fmt.Println(strings.Repeat(INDENT, 2) + msg)
|
|
}
|
|
|
|
}
|
|
|
|
func handleIssueAction(data []byte) {
|
|
action := IssueAction{}
|
|
json.Unmarshal(data, &action)
|
|
printSep()
|
|
fmt.Printf(
|
|
"%q (%q) performed the action %q on repo %q and issue %q\n",
|
|
action.Sender.Login,
|
|
action.Sender.Email,
|
|
action.Action,
|
|
action.Repository.FullName,
|
|
action.Issue.Title,
|
|
)
|
|
}
|
|
|
|
func handleIssueComment(data []byte) {
|
|
action := IssueAction{}
|
|
json.Unmarshal(data, &action)
|
|
printSep()
|
|
fmt.Printf(
|
|
"%q (%q) performed the comment action %q on repo %q and issue %q\n",
|
|
action.Sender.Login,
|
|
action.Sender.Email,
|
|
action.Action,
|
|
action.Repository.FullName,
|
|
action.Issue.Title,
|
|
)
|
|
|
|
fmt.Printf(INDENT + "---")
|
|
msg := strings.Replace(action.Comment.Body, "\n", strings.Repeat(INDENT, 2), -1)
|
|
fmt.Printf(strings.Repeat(INDENT, 2) + msg)
|
|
}
|