package git import ( "fmt" "net/http" "strings" "github.com/rs/zerolog/log" "github.com/velour/catbase/bot" "gopkg.in/go-playground/webhooks.v5/github" ) func (p *GitPlugin) githubEvent(w http.ResponseWriter, r *http.Request) { if p.ghhook == nil { log.Error().Msg("github hook not initialized") w.WriteHeader(500) fmt.Fprintf(w, "not initialized") return } icon := p.c.Get("github.icon", ":octocat:") payload, err := p.ghhook.Parse(r, github.PushEvent, github.PullRequestEvent, github.PingEvent, ) if err != nil { log.Error().Err(err).Msg("unknown event") w.WriteHeader(500) fmt.Fprintf(w, "unknown event: %+v", err) return } msg, repo, owner := icon+" ", "", "" switch payload.(type) { case github.PushPayload: push := payload.(github.PushPayload) repo = push.Repository.Name owner = push.Repository.Owner.Login commits := "" for _, c := range push.Commits { m := strings.Split(c.Message, "\n")[0] commits += fmt.Sprintf("%s pushed to %s (<%s|%s>) %s\n", c.Author.Name, repo, c.URL, c.ID[:7], m, ) } msg += commits case github.PullRequestPayload: pr := payload.(github.PullRequestPayload) if pr.Action != "opened" { w.WriteHeader(200) fmt.Fprintf(w, "ignoring action %s", pr.Action) return } repo = pr.Repository.Name owner = pr.Repository.Owner.Login msg += fmt.Sprintf("%s opened new pull request \"%s\" on %s: %s", pr.PullRequest.User.Login, pr.PullRequest.Title, pr.Repository.Name, pr.PullRequest.URL, ) case github.PingPayload: ping := payload.(github.PingPayload) repo = ping.Repository.Name owner = ping.Repository.Owner.Login msg += fmt.Sprintf(icon+"Got a ping request on %s", repo) default: log.Error().Interface("payload", payload).Msg("unknown event payload") w.WriteHeader(500) fmt.Fprintf(w, "unknown event payload: %+v", payload) return } chs := p.c.GetArray(fmt.Sprintf("github.%s.%s.channels", owner, repo), []string{}) for _, ch := range chs { p.b.Send(p.b.DefaultConnector(), bot.Message, ch, msg) } }