Платформа ЦРНП "Мирокод" для разработки проектов
https://git.mirocod.ru
You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
109 lines
3.0 KiB
109 lines
3.0 KiB
// Copyright 2021 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 ( |
|
"bytes" |
|
"fmt" |
|
"net/http" |
|
"testing" |
|
|
|
"code.gitea.io/gitea/models/db" |
|
"code.gitea.io/gitea/models/packages" |
|
"code.gitea.io/gitea/models/unittest" |
|
user_model "code.gitea.io/gitea/models/user" |
|
|
|
"github.com/stretchr/testify/assert" |
|
) |
|
|
|
func TestPackageGeneric(t *testing.T) { |
|
defer prepareTestEnv(t)() |
|
user := unittest.AssertExistsAndLoadBean(t, &user_model.User{ID: 2}).(*user_model.User) |
|
|
|
packageName := "te-st_pac.kage" |
|
packageVersion := "1.0.3" |
|
filename := "fi-le_na.me" |
|
content := []byte{1, 2, 3} |
|
|
|
url := fmt.Sprintf("/api/packages/%s/generic/%s/%s/%s", user.Name, packageName, packageVersion, filename) |
|
|
|
t.Run("Upload", func(t *testing.T) { |
|
defer PrintCurrentTest(t)() |
|
|
|
req := NewRequestWithBody(t, "PUT", url, bytes.NewReader(content)) |
|
AddBasicAuthHeader(req, user.Name) |
|
MakeRequest(t, req, http.StatusCreated) |
|
|
|
pvs, err := packages.GetVersionsByPackageType(db.DefaultContext, user.ID, packages.TypeGeneric) |
|
assert.NoError(t, err) |
|
assert.Len(t, pvs, 1) |
|
|
|
pd, err := packages.GetPackageDescriptor(db.DefaultContext, pvs[0]) |
|
assert.NoError(t, err) |
|
assert.NotNil(t, pd.SemVer) |
|
assert.Nil(t, pd.Metadata) |
|
assert.Equal(t, packageName, pd.Package.Name) |
|
assert.Equal(t, packageVersion, pd.Version.Version) |
|
|
|
pfs, err := packages.GetFilesByVersionID(db.DefaultContext, pvs[0].ID) |
|
assert.NoError(t, err) |
|
assert.Len(t, pfs, 1) |
|
assert.Equal(t, filename, pfs[0].Name) |
|
assert.True(t, pfs[0].IsLead) |
|
|
|
pb, err := packages.GetBlobByID(db.DefaultContext, pfs[0].BlobID) |
|
assert.NoError(t, err) |
|
assert.Equal(t, int64(len(content)), pb.Size) |
|
}) |
|
|
|
t.Run("UploadExists", func(t *testing.T) { |
|
defer PrintCurrentTest(t)() |
|
|
|
req := NewRequestWithBody(t, "PUT", url, bytes.NewReader(content)) |
|
AddBasicAuthHeader(req, user.Name) |
|
MakeRequest(t, req, http.StatusBadRequest) |
|
}) |
|
|
|
t.Run("Download", func(t *testing.T) { |
|
defer PrintCurrentTest(t)() |
|
|
|
req := NewRequest(t, "GET", url) |
|
resp := MakeRequest(t, req, http.StatusOK) |
|
|
|
assert.Equal(t, content, resp.Body.Bytes()) |
|
|
|
pvs, err := packages.GetVersionsByPackageType(db.DefaultContext, user.ID, packages.TypeGeneric) |
|
assert.NoError(t, err) |
|
assert.Len(t, pvs, 1) |
|
assert.Equal(t, int64(1), pvs[0].DownloadCount) |
|
}) |
|
|
|
t.Run("Delete", func(t *testing.T) { |
|
defer PrintCurrentTest(t)() |
|
|
|
req := NewRequest(t, "DELETE", url) |
|
AddBasicAuthHeader(req, user.Name) |
|
MakeRequest(t, req, http.StatusOK) |
|
|
|
pvs, err := packages.GetVersionsByPackageType(db.DefaultContext, user.ID, packages.TypeGeneric) |
|
assert.NoError(t, err) |
|
assert.Empty(t, pvs) |
|
}) |
|
|
|
t.Run("DownloadNotExists", func(t *testing.T) { |
|
defer PrintCurrentTest(t)() |
|
|
|
req := NewRequest(t, "GET", url) |
|
MakeRequest(t, req, http.StatusNotFound) |
|
}) |
|
|
|
t.Run("DeleteNotExists", func(t *testing.T) { |
|
defer PrintCurrentTest(t)() |
|
|
|
req := NewRequest(t, "DELETE", url) |
|
AddBasicAuthHeader(req, user.Name) |
|
MakeRequest(t, req, http.StatusNotFound) |
|
}) |
|
}
|
|
|