Browse Source

Don't show non-comments in comments API (#2001)

for-closed-social
Ethan Koenig 7 years ago
committed by Lunny Xiao
parent
commit
255adc40ae
5 changed files with 49 additions and 10 deletions
  1. +39
    -0
      integrations/api_comment_test.go
  2. +1
    -4
      integrations/api_team_test.go
  3. +5
    -0
      integrations/integration_test.go
  4. +2
    -6
      integrations/version_test.go
  5. +2
    -0
      models/issue_comment.go

+ 39
- 0
integrations/api_comment_test.go View File

@ -0,0 +1,39 @@
// Copyright 2017 The Gitea Authors. All rights reserved.
// Use of this source code is governed by a MIT-style
// license that can be found in the LICENSE file.
package integrations
import (
"fmt"
"net/http"
"testing"
"code.gitea.io/gitea/models"
api "code.gitea.io/sdk/gitea"
"github.com/stretchr/testify/assert"
)
func TestAPIListComments(t *testing.T) {
prepareTestEnv(t)
comment := models.AssertExistsAndLoadBean(t, &models.Comment{},
models.Cond("type = ?", models.CommentTypeComment)).(*models.Comment)
issue := models.AssertExistsAndLoadBean(t, &models.Issue{ID: comment.IssueID}).(*models.Issue)
repo := models.AssertExistsAndLoadBean(t, &models.Repository{ID: issue.RepoID}).(*models.Repository)
repoOwner := models.AssertExistsAndLoadBean(t, &models.User{ID: repo.OwnerID}).(*models.User)
session := loginUser(t, repoOwner.Name)
requestUrl := fmt.Sprintf("/api/v1/repos/%s/%s/issues/%d/comments",
repoOwner.Name, repo.Name, issue.Index)
req := NewRequest(t, "GET", requestUrl)
resp := session.MakeRequest(t, req)
assert.EqualValues(t, http.StatusOK, resp.HeaderCode)
var comments []*api.Comment
DecodeJSON(t, resp, &comments)
expectedCount := models.GetCount(t, &models.Comment{IssueID: issue.ID},
models.Cond("type = ?", models.CommentTypeComment))
assert.EqualValues(t, expectedCount, len(comments))
}

+ 1
- 4
integrations/api_team_test.go View File

@ -5,8 +5,6 @@
package integrations package integrations
import ( import (
"bytes"
"encoding/json"
"fmt" "fmt"
"net/http" "net/http"
"testing" "testing"
@ -30,8 +28,7 @@ func TestAPITeam(t *testing.T) {
assert.EqualValues(t, http.StatusOK, resp.HeaderCode) assert.EqualValues(t, http.StatusOK, resp.HeaderCode)
var apiTeam api.Team var apiTeam api.Team
decoder := json.NewDecoder(bytes.NewBuffer(resp.Body))
assert.NoError(t, decoder.Decode(&apiTeam))
DecodeJSON(t, resp, &apiTeam)
assert.EqualValues(t, team.ID, apiTeam.ID) assert.EqualValues(t, team.ID, apiTeam.ID)
assert.Equal(t, team.Name, apiTeam.Name) assert.Equal(t, team.Name, apiTeam.Name)
} }

+ 5
- 0
integrations/integration_test.go View File

@ -252,3 +252,8 @@ func MakeRequest(req *http.Request) *TestResponse {
Headers: respWriter.Headers, Headers: respWriter.Headers,
} }
} }
func DecodeJSON(t testing.TB, resp *TestResponse, v interface{}) {
decoder := json.NewDecoder(bytes.NewBuffer(resp.Body))
assert.NoError(t, decoder.Decode(v))
}

+ 2
- 6
integrations/version_test.go View File

@ -5,8 +5,6 @@
package integrations package integrations
import ( import (
"bytes"
"encoding/json"
"net/http" "net/http"
"testing" "testing"
@ -22,11 +20,9 @@ func TestVersion(t *testing.T) {
setting.AppVer = "1.1.0+dev" setting.AppVer = "1.1.0+dev"
req := NewRequest(t, "GET", "/api/v1/version") req := NewRequest(t, "GET", "/api/v1/version")
resp := MakeRequest(req) resp := MakeRequest(req)
assert.EqualValues(t, http.StatusOK, resp.HeaderCode)
var version gitea.ServerVersion var version gitea.ServerVersion
decoder := json.NewDecoder(bytes.NewBuffer(resp.Body))
assert.NoError(t, decoder.Decode(&version))
assert.EqualValues(t, http.StatusOK, resp.HeaderCode)
DecodeJSON(t, resp, &version)
assert.Equal(t, setting.AppVer, string(version.Version)) assert.Equal(t, setting.AppVer, string(version.Version))
} }

+ 2
- 0
models/issue_comment.go View File

@ -572,6 +572,7 @@ func getCommentsByIssueIDSince(e Engine, issueID, since int64) ([]*Comment, erro
comments := make([]*Comment, 0, 10) comments := make([]*Comment, 0, 10)
sess := e. sess := e.
Where("issue_id = ?", issueID). Where("issue_id = ?", issueID).
Where("type = ?", CommentTypeComment).
Asc("created_unix") Asc("created_unix")
if since > 0 { if since > 0 {
sess.And("updated_unix >= ?", since) sess.And("updated_unix >= ?", since)
@ -582,6 +583,7 @@ func getCommentsByIssueIDSince(e Engine, issueID, since int64) ([]*Comment, erro
func getCommentsByRepoIDSince(e Engine, repoID, since int64) ([]*Comment, error) { func getCommentsByRepoIDSince(e Engine, repoID, since int64) ([]*Comment, error) {
comments := make([]*Comment, 0, 10) comments := make([]*Comment, 0, 10)
sess := e.Where("issue.repo_id = ?", repoID). sess := e.Where("issue.repo_id = ?", repoID).
Where("comment.type = ?", CommentTypeComment).
Join("INNER", "issue", "issue.id = comment.issue_id"). Join("INNER", "issue", "issue.id = comment.issue_id").
Asc("comment.created_unix") Asc("comment.created_unix")
if since > 0 { if since > 0 {

Loading…
Cancel
Save