summaryrefslogtreecommitdiff
path: root/internal/media/manager_test.go
diff options
context:
space:
mode:
authorLibravatar kim <89579420+NyaaaWhatsUpDoc@users.noreply.github.com>2022-11-24 08:35:46 +0000
committerLibravatar GitHub <noreply@github.com>2022-11-24 09:35:46 +0100
commitfcb9c0bb8bed51ffb856b8e47f4e047ddd75eb67 (patch)
tree933c9e1ed2b37e3ca2ee371c0b53f2c1ac561cc5 /internal/media/manager_test.go
parent[feature/performance] Fail fast when doing remote transport calls inside inco... (diff)
downloadgotosocial-fcb9c0bb8bed51ffb856b8e47f4e047ddd75eb67.tar.xz
[chore] cleanup storage implementation, no need for multiple interface types (#1131)
Signed-off-by: kim <grufwub@gmail.com> Signed-off-by: kim <grufwub@gmail.com>
Diffstat (limited to 'internal/media/manager_test.go')
-rw-r--r--internal/media/manager_test.go13
1 files changed, 9 insertions, 4 deletions
diff --git a/internal/media/manager_test.go b/internal/media/manager_test.go
index 3955c1b63..659740af6 100644
--- a/internal/media/manager_test.go
+++ b/internal/media/manager_test.go
@@ -927,14 +927,19 @@ func (suite *ManagerTestSuite) TestSimpleJpegProcessBlockingWithDiskStorage() {
temp := fmt.Sprintf("%s/gotosocial-test", os.TempDir())
defer os.RemoveAll(temp)
- diskStorage, err := kv.OpenDisk(temp, &storage.DiskConfig{
+ disk, err := storage.OpenDisk(temp, &storage.DiskConfig{
LockFile: path.Join(temp, "store.lock"),
})
if err != nil {
panic(err)
}
- diskManager, err := media.NewManager(suite.db, &gtsstorage.Local{KVStore: diskStorage})
+ storage := &gtsstorage.Driver{
+ KVStore: kv.New(disk),
+ Storage: disk,
+ }
+
+ diskManager, err := media.NewManager(suite.db, storage)
if err != nil {
panic(err)
}
@@ -974,7 +979,7 @@ func (suite *ManagerTestSuite) TestSimpleJpegProcessBlockingWithDiskStorage() {
suite.NotNil(dbAttachment)
// make sure the processed file is in storage
- processedFullBytes, err := diskStorage.Get(ctx, attachment.File.Path)
+ processedFullBytes, err := storage.Get(ctx, attachment.File.Path)
suite.NoError(err)
suite.NotEmpty(processedFullBytes)
@@ -987,7 +992,7 @@ func (suite *ManagerTestSuite) TestSimpleJpegProcessBlockingWithDiskStorage() {
suite.Equal(processedFullBytesExpected, processedFullBytes)
// now do the same for the thumbnail and make sure it's what we expected
- processedThumbnailBytes, err := diskStorage.Get(ctx, attachment.Thumbnail.Path)
+ processedThumbnailBytes, err := storage.Get(ctx, attachment.Thumbnail.Path)
suite.NoError(err)
suite.NotEmpty(processedThumbnailBytes)