in githubissues/main.go [95:155]
func (g *githubissuesNotifier) SendNotification(ctx context.Context, build *cbpb.Build) error {
if !g.filter.Apply(ctx, build) {
log.V(2).Infof("not sending response for event (build id = %s, status = %v)", build.Id, build.Status)
return nil
}
repo := GetGithubRepo(build)
if repo == "" {
log.Warningf("could not determine GitHub repository from build, skipping notification")
return nil
}
webhookURL := fmt.Sprintf("%s/%s/issues", githubApiEndpoint, repo)
log.Infof("sending GitHub Issue webhook for Build %q (status: %q) to url %q", build.Id, build.Status, webhookURL)
bindings, err := g.br.Resolve(ctx, nil, build)
if err != nil {
log.Errorf("failed to resolve bindings :%v", err)
}
g.tmplView = ¬ifiers.TemplateView{
Build: ¬ifiers.BuildView{Build: build},
Params: bindings,
}
logURL, err := notifiers.AddUTMParams(build.LogUrl, notifiers.HTTPMedium)
if err != nil {
return fmt.Errorf("failed to add UTM params: %w", err)
}
build.LogUrl = logURL
payload := new(bytes.Buffer)
var buf bytes.Buffer
if err := g.tmpl.Execute(&buf, g.tmplView); err != nil {
return err
}
err = json.NewEncoder(payload).Encode(buf)
if err != nil {
return fmt.Errorf("failed to encode payload: %w", err)
}
req, err := http.NewRequestWithContext(ctx, http.MethodPost, webhookURL, strings.NewReader(buf.String()))
if err != nil {
return fmt.Errorf("failed to create a new HTTP request: %w", err)
}
req.Header.Set("Accept", "application/vnd.github.v3+json")
req.Header.Set("Authorization", fmt.Sprintf("token %s", g.githubToken))
req.Header.Set("User-Agent", "GCB-Notifier/0.1 (http)")
resp, err := http.DefaultClient.Do(req)
if err != nil {
return fmt.Errorf("failed to make HTTP request: %w", err)
}
defer resp.Body.Close()
if resp.StatusCode != http.StatusOK {
log.Warningf("got a non-OK response status %q (%d) from %q", resp.Status, resp.StatusCode, webhookURL)
}
log.V(2).Infoln("send HTTP request successfully")
return nil
}