diff options
author | James Fargher <jfargher@gitlab.com> | 2023-04-05 00:30:21 +0300 |
---|---|---|
committer | James Fargher <jfargher@gitlab.com> | 2023-04-11 01:28:43 +0300 |
commit | 4c2166710e74ab23867c1b4aa48b9d69f85623bc (patch) | |
tree | 1bae0f468ce7af86eef227c35454a1d8e0b837fd /internal/backup/filesystem_sink_test.go | |
parent | b40669b35a49cfc4fa6f7ea3ef45c5b166b10bf5 (diff) |
backup: Remove Write from filesystem sink
Diffstat (limited to 'internal/backup/filesystem_sink_test.go')
-rw-r--r-- | internal/backup/filesystem_sink_test.go | 53 |
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"))) - }) -} |