Compare commits
9 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| f79fb40bef | |||
| cb162c154b | |||
| 437e318240 | |||
| 2e2fcbabfc | |||
| 9a6298cc4f | |||
| be68e51898 | |||
| 49db84fb82 | |||
| 08b5d4051b | |||
| d606d0a202 |
@@ -439,7 +439,7 @@ func main() {
|
|||||||
inlineComments = append(inlineComments, vcs.ReviewComment{
|
inlineComments = append(inlineComments, vcs.ReviewComment{
|
||||||
Path: f.File,
|
Path: f.File,
|
||||||
Position: pos,
|
Position: pos,
|
||||||
CommitID: pr.Head.SHA,
|
CommitID: evaluatedSHA,
|
||||||
Body: fmt.Sprintf("**[%s]** %s", f.Severity, f.Finding),
|
Body: fmt.Sprintf("**[%s]** %s", f.Severity, f.Finding),
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
@@ -485,7 +485,7 @@ func main() {
|
|||||||
reviewReq := vcs.ReviewRequest{
|
reviewReq := vcs.ReviewRequest{
|
||||||
Body: reviewBody,
|
Body: reviewBody,
|
||||||
Event: event,
|
Event: event,
|
||||||
CommitID: pr.Head.SHA,
|
CommitID: evaluatedSHA,
|
||||||
Comments: inlineComments,
|
Comments: inlineComments,
|
||||||
}
|
}
|
||||||
posted, err := client.PostReview(ctx, owner, repoName, prNumber, reviewReq)
|
posted, err := client.PostReview(ctx, owner, repoName, prNumber, reviewReq)
|
||||||
|
|||||||
@@ -409,7 +409,7 @@ func TestAdapter_RequestReviewerSelf(t *testing.T) {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
func TestAdapter_PostReview_CommitID_Threading(t *testing.T) {
|
func TestAdapter_PostReview_CommitID(t *testing.T) {
|
||||||
var gotPayload struct {
|
var gotPayload struct {
|
||||||
Body string `json:"body"`
|
Body string `json:"body"`
|
||||||
Event string `json:"event"`
|
Event string `json:"event"`
|
||||||
|
|||||||
@@ -147,6 +147,46 @@ func TestPostReview(t *testing.T) {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func TestPostReview_CommitID(t *testing.T) {
|
||||||
|
server := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
||||||
|
if r.Method != "POST" {
|
||||||
|
t.Fatalf("expected POST, got %s", r.Method)
|
||||||
|
}
|
||||||
|
|
||||||
|
body, _ := io.ReadAll(r.Body)
|
||||||
|
var payload struct {
|
||||||
|
Body string `json:"body"`
|
||||||
|
Event string `json:"event"`
|
||||||
|
CommitID string `json:"commit_id"`
|
||||||
|
}
|
||||||
|
if err := json.Unmarshal(body, &payload); err != nil {
|
||||||
|
t.Fatalf("unmarshal payload: %v", err)
|
||||||
|
}
|
||||||
|
if payload.CommitID != "deadbeef123" {
|
||||||
|
t.Errorf("expected commit_id %q, got %q", "deadbeef123", payload.CommitID)
|
||||||
|
}
|
||||||
|
if payload.Event != "APPROVED" {
|
||||||
|
t.Errorf("expected event APPROVED, got %q", payload.Event)
|
||||||
|
}
|
||||||
|
|
||||||
|
w.WriteHeader(http.StatusOK)
|
||||||
|
w.Write([]byte(`{"id":101,"user":{"login":"review-bot"},"state":"APPROVED","stale":false,"commit_id":"deadbeef123"}`))
|
||||||
|
}))
|
||||||
|
defer server.Close()
|
||||||
|
|
||||||
|
client := NewClient(server.URL, "test-token")
|
||||||
|
review, err := client.PostReview(context.Background(), "owner", "repo", 3, "APPROVED", "LGTM", "deadbeef123", nil)
|
||||||
|
if err != nil {
|
||||||
|
t.Fatalf("unexpected error: %v", err)
|
||||||
|
}
|
||||||
|
if review.ID != 101 {
|
||||||
|
t.Errorf("expected review ID 101, got %d", review.ID)
|
||||||
|
}
|
||||||
|
if review.CommitID != "deadbeef123" {
|
||||||
|
t.Errorf("expected commit_id %q, got %q", "deadbeef123", review.CommitID)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
func TestGetPullRequest_Non200(t *testing.T) {
|
func TestGetPullRequest_Non200(t *testing.T) {
|
||||||
server := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
server := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
||||||
w.WriteHeader(http.StatusNotFound)
|
w.WriteHeader(http.StatusNotFound)
|
||||||
|
|||||||
@@ -2,9 +2,9 @@ package github
|
|||||||
|
|
||||||
import (
|
import (
|
||||||
"context"
|
"context"
|
||||||
"fmt"
|
|
||||||
"encoding/json"
|
"encoding/json"
|
||||||
"errors"
|
"errors"
|
||||||
|
"fmt"
|
||||||
"io"
|
"io"
|
||||||
"net/http"
|
"net/http"
|
||||||
"strings"
|
"strings"
|
||||||
|
|||||||
+6
-3
@@ -117,7 +117,7 @@ func (c *Client) PostReview(ctx context.Context, owner, repo string, number int,
|
|||||||
// the resolved commit_id.
|
// the resolved commit_id.
|
||||||
for _, comment := range req.Comments {
|
for _, comment := range req.Comments {
|
||||||
if comment.CommitID != "" {
|
if comment.CommitID != "" {
|
||||||
if payload.CommitID == "" {
|
if payload.CommitID == "" { // only reachable when req.CommitID is empty
|
||||||
payload.CommitID = comment.CommitID
|
payload.CommitID = comment.CommitID
|
||||||
} else if payload.CommitID != comment.CommitID {
|
} else if payload.CommitID != comment.CommitID {
|
||||||
return nil, ErrConflictingCommitIDs
|
return nil, ErrConflictingCommitIDs
|
||||||
@@ -197,8 +197,10 @@ func (c *Client) ListReviews(ctx context.Context, owner, repo string, number int
|
|||||||
break
|
break
|
||||||
}
|
}
|
||||||
|
|
||||||
// If we just fetched page maxPages and it was full (the short-page break
|
// Truncation detection: this runs on the final allowed iteration
|
||||||
// above didn't fire), more reviews likely exist beyond our limit.
|
// (page == maxPages) only when the page was full (the len < perPage
|
||||||
|
// early-break above didn't fire). A full final page means additional
|
||||||
|
// reviews likely exist beyond our pagination limit.
|
||||||
if page == maxPages {
|
if page == maxPages {
|
||||||
truncated = true
|
truncated = true
|
||||||
}
|
}
|
||||||
@@ -221,6 +223,7 @@ func (c *Client) DeleteReview(ctx context.Context, owner, repo string, number in
|
|||||||
reqURL := fmt.Sprintf("%s/repos/%s/%s/pulls/%d/reviews/%d",
|
reqURL := fmt.Sprintf("%s/repos/%s/%s/pulls/%d/reviews/%d",
|
||||||
c.baseURL, url.PathEscape(owner), url.PathEscape(repo), number, reviewID)
|
c.baseURL, url.PathEscape(owner), url.PathEscape(repo), number, reviewID)
|
||||||
|
|
||||||
|
// nil body: the GitHub DELETE endpoint for reviews requires no request body.
|
||||||
_, err := c.doRequestWithBody(ctx, http.MethodDelete, reqURL, nil)
|
_, err := c.doRequestWithBody(ctx, http.MethodDelete, reqURL, nil)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
var apiErr *APIError
|
var apiErr *APIError
|
||||||
|
|||||||
Reference in New Issue
Block a user