Welcome to mirror list, hosted at ThFree Co, Russian Federation.

gitlab.com/gitlab-org/gitaly.git - Unnamed repository; edit this file 'description' to name the repository.
summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorJames Fargher <jfargher@gitlab.com>2023-04-05 00:30:21 +0300
committerJames Fargher <jfargher@gitlab.com>2023-04-11 01:28:43 +0300
commit4c2166710e74ab23867c1b4aa48b9d69f85623bc (patch)
tree1bae0f468ce7af86eef227c35454a1d8e0b837fd /internal/backup/filesystem_sink_test.go
parentb40669b35a49cfc4fa6f7ea3ef45c5b166b10bf5 (diff)
backup: Remove Write from filesystem sink
Diffstat (limited to 'internal/backup/filesystem_sink_test.go')
-rw-r--r--internal/backup/filesystem_sink_test.go53
1 files changed, 0 insertions, 53 deletions
diff --git a/internal/backup/filesystem_sink_test.go b/internal/backup/filesystem_sink_test.go
index c3b997963..703eb282e 100644
--- a/internal/backup/filesystem_sink_test.go
+++ b/internal/backup/filesystem_sink_test.go
@@ -115,56 +115,3 @@ func TestFilesystemSink_GetWriter(t *testing.T) {
require.EqualError(t, err, fmt.Sprintf(`create directory structure %[1]q: mkdir %[1]s: not a directory`, filepath.Join(dir, "nested")))
})
}
-
-func TestFilesystemSink_Write(t *testing.T) {
- t.Parallel()
-
- t.Run("ok", func(t *testing.T) {
- t.Parallel()
- ctx := testhelper.Context(t)
-
- dir := testhelper.TempDir(t)
- const relativePath = "nested/dir/test.dat"
-
- fsSink := NewFilesystemSink(dir)
- require.NoError(t, fsSink.Write(ctx, relativePath, strings.NewReader("test")))
-
- require.FileExists(t, filepath.Join(dir, relativePath))
- data, err := os.ReadFile(filepath.Join(dir, relativePath))
- require.NoError(t, err)
- require.Equal(t, []byte("test"), data)
- })
-
- t.Run("overrides existing data", func(t *testing.T) {
- t.Parallel()
- ctx := testhelper.Context(t)
-
- dir := testhelper.TempDir(t)
- const relativePath = "nested/dir/test.dat"
- fullPath := filepath.Join(dir, relativePath)
-
- require.NoError(t, os.MkdirAll(filepath.Dir(fullPath), perm.SharedDir))
- require.NoError(t, os.WriteFile(fullPath, []byte("initial"), perm.SharedFile))
-
- fsSink := NewFilesystemSink(dir)
- require.NoError(t, fsSink.Write(ctx, relativePath, strings.NewReader("test")))
-
- require.FileExists(t, fullPath)
- data, err := os.ReadFile(fullPath)
- require.NoError(t, err)
- require.Equal(t, []byte("test"), data)
- })
-
- t.Run("dir creation error", func(t *testing.T) {
- t.Parallel()
- ctx := testhelper.Context(t)
-
- dir := testhelper.TempDir(t)
- const relativePath = "nested/test.dat"
- require.NoError(t, os.WriteFile(filepath.Join(dir, "nested"), []byte("lock"), perm.PublicFile))
-
- fsSink := NewFilesystemSink(dir)
- err := fsSink.Write(ctx, relativePath, strings.NewReader("test"))
- require.EqualError(t, err, fmt.Sprintf(`create directory structure %[1]q: mkdir %[1]s: not a directory`, filepath.Join(dir, "nested")))
- })
-}