func()

in custom-targets/git-ops/git-deployer/providers/github.go [33:71]

• 36 lines of code
• 7 McCabe index (conditional complexity)

func (p *GitHubProvider) OpenPullRequest(src, dst, title, body string) (*PullRequest, error) {
	payload, err := json.Marshal(map[string]string{
		"title": title,
		"head":  src,
		"base":  dst,
		"body":  body,
	})
	if err != nil {
		return nil, fmt.Errorf("unable to marshal json for pull request: %v", err)
	}
	reader := bytes.NewReader(payload)
	req, err := http.NewRequest(http.MethodPost, fmt.Sprintf("https://api.github.com/repos/%s/%s/pulls", p.Owner, p.Repository), reader)
	if err != nil {
		return nil, fmt.Errorf("unable to create new request: %v", err)
	}

	req.Header.Add("Accept", "application/vnd.github+json")
	req.Header.Add("Authorization", fmt.Sprintf("Bearer %s", p.Token))
	req.Header.Add("X-GitHub-Api-Version", "2022-11-28")

	resp, err := http.DefaultClient.Do(req)
	defer resp.Body.Close()
	if err != nil {
		return nil, fmt.Errorf("unable to make request: %v", err)
	}
	var pr PullRequest
	r, err := io.ReadAll(resp.Body)
	if err != nil {
		return nil, fmt.Errorf("unable to read response body: %v", err)
	}
	if resp.StatusCode != http.StatusCreated {
		return nil, fmt.Errorf("create pull request body: %q, status got: %v want: %v", r, resp.StatusCode, http.StatusCreated)
	}
	if err := json.Unmarshal(r, &pr); err != nil {
		return nil, fmt.Errorf("unable to unmarshal open pull request response: %v", err)
	}

	return &pr, nil
}