Implemented PR creation in Gitea driver.

Author: chhsia0

scm/driver/gitea/pr.go

@@ -18,7 +18,7 @@ type pullService struct {
 
 func (s *pullService) Find(ctx context.Context, repo string, index int) (*scm.PullRequest, *scm.Response, error) {
 	path := fmt.Sprintf("api/v1/repos/%s/pulls/%d", repo, index)
-	out := new(pullRequest)
+	out := new(pr)
 	res, err := s.client.do(ctx, "GET", path, nil, out)
 	return convertPullRequest(out), res, err
 }
@@ -29,7 +29,7 @@ func (s *pullService) FindComment(context.Context, string, int, int) (*scm.Comme
 
 func (s *pullService) List(ctx context.Context, repo string, opts scm.PullRequestListOptions) ([]*scm.PullRequest, *scm.Response, error) {
 	path := fmt.Sprintf("api/v1/repos/%s/pulls", repo)
-	out := []*pullRequest{}
+	out := []*pr{}
 	res, err := s.client.do(ctx, "GET", path, nil, &out)
 	return convertPullRequests(out), res, err
 }
@@ -42,6 +42,19 @@ func (s *pullService) ListChanges(context.Context, string, int, scm.ListOptions)
 	return nil, nil, scm.ErrNotSupported
 }
 
+func (s *pullService) Create(ctx context.Context, repo string, input *scm.PullRequestInput) (*scm.PullRequest, *scm.Response, error) {
+	path := fmt.Sprintf("api/v1/repos/%s/pulls", repo)
+	in := &prInput{
+		Title: input.Title,
+		Body:  input.Body,
+		Head:  input.Source,
+		Base:  input.Target,
+	}
+	out := new(pr)
+	res, err := s.client.do(ctx, "POST", path, in, out)
+	return convertPullRequest(out), res, err
+}
+
 func (s *pullService) CreateComment(context.Context, string, int, *scm.CommentInput) (*scm.Comment, *scm.Response, error) {
 	return nil, nil, scm.ErrNotSupported
 }
@@ -64,7 +77,7 @@ func (s *pullService) Close(context.Context, string, int) (*scm.Response, error)
 // native data structures
 //
 
-type pullRequest struct {
+type pr struct {
 	ID         int        `json:"id"`
 	Number     int        `json:"number"`
 	User       user       `json:"user"`
@@ -90,19 +103,26 @@ type reference struct {
 	Sha  string     `json:"sha"`
 }
 
+type prInput struct {
+	Title string `json:"title"`
+	Body  string `json:"body"`
+	Head  string `json:"head"`
+	Base  string `json:"base"`
+}
+
 //
 // native data structure conversion
 //
 
-func convertPullRequests(src []*pullRequest) []*scm.PullRequest {
+func convertPullRequests(src []*pr) []*scm.PullRequest {
 	dst := []*scm.PullRequest{}
 	for _, v := range src {
 		dst = append(dst, convertPullRequest(v))
 	}
 	return dst
 }
 
-func convertPullRequest(src *pullRequest) *scm.PullRequest {
+func convertPullRequest(src *pr) *scm.PullRequest {
 	return &scm.PullRequest{
 		Number:  src.Number,
 		Title:   src.Title,

scm/driver/gitea/pr_test.go

@@ -69,6 +69,38 @@ func TestPullRequestList(t *testing.T) {
 	}
 }
 
+func TestPullRequestCreate(t *testing.T) {
+	defer gock.Off()
+
+	gock.New("https://try.gitea.io").
+		Post("/api/v1/repos/jcitizen/my-repo/pulls").
+		Reply(201).
+		Type("application/json").
+		File("testdata/pr.json")
+
+	input := scm.PullRequestInput{
+		Title:  "Add License File",
+		Body:   "Using a BSD License",
+		Source: "feature",
+		Target: "master",
+	}
+
+	client, _ := New("https://try.gitea.io")
+	got, _, err := client.PullRequests.Create(context.Background(), "jcitizen/my-repo", &input)
+	if err != nil {
+		t.Error(err)
+	}
+
+	want := new(scm.PullRequest)
+	raw, _ := ioutil.ReadFile("testdata/pr.json.golden")
+	json.Unmarshal(raw, want)
+
+	if diff := cmp.Diff(got, want); diff != "" {
+		t.Errorf("Unexpected Results")
+		t.Log(diff)
+	}
+}
+
 func TestPullRequestClose(t *testing.T) {
 	client, _ := New("https://try.gitea.io")
 	_, err := client.PullRequests.Close(context.Background(), "go-gitea/gitea", 1)

scm/driver/gitea/webhook.go

@@ -171,11 +171,11 @@ type (
 
 	// gitea pull request webhook payload
 	pullRequestHook struct {
-		Action      string      `json:"action"`
-		Number      int         `json:"number"`
-		PullRequest pullRequest `json:"pull_request"`
-		Repository  repository  `json:"repository"`
-		Sender      user        `json:"sender"`
+		Action      string     `json:"action"`
+		Number      int        `json:"number"`
+		PullRequest pr         `json:"pull_request"`
+		Repository  repository `json:"repository"`
+		Sender      user       `json:"sender"`
 	}
 )
 
@@ -209,7 +209,7 @@ func convertBranchHook(dst *createHook, action scm.Action) *scm.BranchHook {
 func convertPushHook(dst *pushHook) *scm.PushHook {
 	if len(dst.Commits) > 0 {
 		return &scm.PushHook{
-			Ref: dst.Ref,
+			Ref:    dst.Ref,
 			Before: dst.Before,
 			Commit: scm.Commit{
 				Sha:     dst.After,