func()

in custom-targets/git-ops/git-deployer/providers/github.go [74:114]

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

func (p *GitHubProvider) MergePullRequest(prNo int) (*MergeResponse, error) {
	call := func(prNo int) (*MergeResponse, error) {
		payload, err := json.Marshal(map[string]string{
			"merge_method": "merge",
		})
		if err != nil {
			return nil, fmt.Errorf("unable to marshal json for merging pull request: %v", err)
		}
		reader := bytes.NewReader(payload)
		req, err := http.NewRequest(http.MethodPut, fmt.Sprintf("https://api.github.com/repos/%s/%s/pulls/%d/merge", p.Owner, p.Repository, prNo), 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)
		if err != nil {
			return nil, fmt.Errorf("unable to make request: %v", err)
		}
		defer resp.Body.Close()

		var mr MergeResponse
		r, err := io.ReadAll(resp.Body)
		if err != nil {
			return nil, fmt.Errorf("unable to read response body: %v", err)
		}
		if resp.StatusCode != http.StatusOK {
			return nil, fmt.Errorf("merge pull request body: %q, status got: %v want: %v", r, resp.StatusCode, http.StatusOK)
		}
		if err := json.Unmarshal(r, &mr); err != nil {
			return nil, fmt.Errorf("unable to unmarshal merge pull request response: %v", err)
		}

		return &mr, nil
	}

	return mergePullRequestWithRetries(prNo, call)
}