client_repository_pullrequest.go

/*
Copyright 2023 The Flux CD contributors.

Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at

    http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
*/

package gitea

import (
	"context"
	"fmt"

	"code.gitea.io/sdk/gitea"
	"github.com/fluxcd/go-git-providers/gitprovider"
)

// PullRequestClient implements the gitprovider.PullRequestClient interface.
var _ gitprovider.PullRequestClient = &PullRequestClient{}

// PullRequestClient operates on the pull requests for a specific repository.
type PullRequestClient struct {
	*clientContext
	ref gitprovider.RepositoryRef
}

// List lists all pull requests in the repository
func (c *PullRequestClient) List(ctx context.Context) ([]gitprovider.PullRequest, error) {
	opts := gitea.ListPullRequestsOptions{}
	prs, _, err := c.c.ListRepoPullRequests(c.ref.GetIdentity(), c.ref.GetRepository(), opts)
	if err != nil {
		return nil, err
	}

	requests := make([]gitprovider.PullRequest, len(prs))

	for idx, pr := range prs {
		requests[idx] = newPullRequest(c.clientContext, pr)
	}

	return requests, nil
}

// Create creates a pull request with the given specifications.
func (c *PullRequestClient) Create(ctx context.Context, title, branch, baseBranch, description string) (gitprovider.PullRequest, error) {
	prOpts := gitea.CreatePullRequestOption{
		Base:  baseBranch,
		Title: title,
		Head:  branch,
		Body:  description,
	}
	pr, _, err := c.c.CreatePullRequest(c.ref.GetIdentity(), c.ref.GetRepository(), prOpts)

	if err != nil {
		return nil, err
	}

	return newPullRequest(c.clientContext, pr), nil
}

// Get retrieves an existing pull request by number
func (c *PullRequestClient) Get(ctx context.Context, number int) (gitprovider.PullRequest, error) {
	pr, _, err := c.c.GetPullRequest(c.ref.GetIdentity(), c.ref.GetRepository(), int64(number))
	if err != nil {
		return nil, err
	}

	return newPullRequest(c.clientContext, pr), nil
}

// Edit modifies an existing PR. Please refer to "EditOptions" for details on which data can be edited.
func (c *PullRequestClient) Edit(ctx context.Context, number int, opts gitprovider.EditOptions) (gitprovider.PullRequest, error) {
	editPR := gitea.EditPullRequestOption{}
	editPR.Title = *opts.Title
	editedPR, _, err := c.c.EditPullRequest(c.ref.GetIdentity(), c.ref.GetRepository(), int64(number), editPR)
	if err != nil {
		return nil, err
	}
	return newPullRequest(c.clientContext, editedPR), nil
}

// Merge merges a pull request with the given specifications.
// Supported merge methods are: MergeMethodMerge and MergeMethodSquash
func (c *PullRequestClient) Merge(ctx context.Context, number int, mergeMethod gitprovider.MergeMethod, message string) error {
	mergeOpts := gitea.MergePullRequestOption{
		Style:   gitea.MergeStyle(mergeMethod),
		Message: message,
	}

	done, resp, err := c.c.MergePullRequest(c.ref.GetIdentity(), c.ref.GetRepository(), int64(number), mergeOpts)
	if err != nil {
		return handleHTTPError(resp, err)
	}

	if !done {
		if resp.StatusCode != 200 {
			return fmt.Errorf("merge failed: %s", resp.Status)
		}
		return fmt.Errorf("merge failed")
	}

	return nil
}