davrot/forgejo_backup
1
0
Fork 0
mirror of https://codeberg.org/davrot/forgejo.git synced 2025-06-24 11:00:02 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions 2

git/blob: add truncated tests

Browse source
This commit is contained in:
oliverpool 2025-06-18 12:39:26 +02:00
parent 31ad7c9353
commit c78f56e7cb
1 changed files with 79 additions and 16 deletions
Download patch file Download diff file Expand all files Collapse all files

95
modules/git/blob_test.go
View file

@ -35,7 +35,7 @@ func TestBlob_Data(t *testing.T) {
assert.Equal(t, output, string(data)) assert.Equal(t, output, string(data))
} }
func TestBlob_GetBlobContent(t *testing.T) { func TestBlob(t *testing.T) {
bareRepo1Path := filepath.Join(testReposDir, "repo1_bare") bareRepo1Path := filepath.Join(testReposDir, "repo1_bare")
repo, err := openRepositoryWithDefaultContext(bareRepo1Path) repo, err := openRepositoryWithDefaultContext(bareRepo1Path)
require.NoError(t, err) require.NoError(t, err)
@ -45,30 +45,93 @@ func TestBlob_GetBlobContent(t *testing.T) {
testBlob, err := repo.GetBlob("6c493ff740f9380390d5c9ddef4af18697ac9375") testBlob, err := repo.GetBlob("6c493ff740f9380390d5c9ddef4af18697ac9375")
require.NoError(t, err) require.NoError(t, err)
r, err := testBlob.GetBlobContent(100) t.Run("GetBlobContent", func(t *testing.T) {
require.NoError(t, err) r, err := testBlob.GetBlobContent(100)
require.Equal(t, "file2\n", r) require.NoError(t, err)
require.Equal(t, "file2\n", r)
r, err = testBlob.GetBlobContent(-1) r, err = testBlob.GetBlobContent(-1)
require.NoError(t, err) require.NoError(t, err)
require.Empty(t, r) require.Empty(t, r)
r, err = testBlob.GetBlobContent(4) r, err = testBlob.GetBlobContent(4)
require.NoError(t, err) require.NoError(t, err)
require.Equal(t, "file", r) require.Equal(t, "file", r)
r, err = testBlob.GetBlobContent(6) r, err = testBlob.GetBlobContent(6)
require.NoError(t, err) require.NoError(t, err)
require.Equal(t, "file2\n", r) require.Equal(t, "file2\n", r)
})
t.Run("non-existing blob", func(t *testing.T) { t.Run("NewTruncatedReader", func(t *testing.T) {
inexistingBlob, err := repo.GetBlob("00003ff740f9380390d5c9ddef4af18690000000") // read fewer than available
rc, size, err := testBlob.NewTruncatedReader(100)
require.NoError(t, err)
require.Equal(t, int64(6), size)
buf := make([]byte, 1)
n, err := rc.Read(buf)
require.NoError(t, err)
require.Equal(t, 1, n)
require.Equal(t, "f", string(buf))
n, err = rc.Read(buf)
require.NoError(t, err)
require.Equal(t, 1, n)
require.Equal(t, "i", string(buf))
require.NoError(t, rc.Close())
// read more than available
rc, size, err = testBlob.NewTruncatedReader(100)
require.NoError(t, err)
require.Equal(t, int64(6), size)
buf = make([]byte, 100)
n, err = rc.Read(buf)
require.NoError(t, err)
require.Equal(t, 6, n)
require.Equal(t, "file2\n", string(buf[:n]))
n, err = rc.Read(buf)
require.Error(t, err)
require.Equal(t, io.EOF, err)
require.Equal(t, 0, n)
require.NoError(t, rc.Close())
// read more than truncated
rc, size, err = testBlob.NewTruncatedReader(4)
require.NoError(t, err)
require.Equal(t, int64(6), size)
buf = make([]byte, 10)
n, err = rc.Read(buf)
require.NoError(t, err)
require.Equal(t, 4, n)
require.Equal(t, "file", string(buf[:n]))
n, err = rc.Read(buf)
require.Error(t, err)
require.Equal(t, io.EOF, err)
require.Equal(t, 0, n)
require.NoError(t, rc.Close())
})
t.Run("NonExisting", func(t *testing.T) {
nonExistingBlob, err := repo.GetBlob("00003ff740f9380390d5c9ddef4af18690000000")
require.NoError(t, err) require.NoError(t, err)
r, err := inexistingBlob.GetBlobContent(100) r, err := nonExistingBlob.GetBlobContent(100)
require.Error(t, err) require.Error(t, err)
require.IsType(t, ErrNotExist{}, err) require.IsType(t, ErrNotExist{}, err)
require.Empty(t, r) require.Empty(t, r)
rc, size, err := nonExistingBlob.NewTruncatedReader(100)
require.Error(t, err)
require.IsType(t, ErrNotExist{}, err)
require.Empty(t, rc)
require.Empty(t, size)
}) })
} }