summaryrefslogtreecommitdiff
path: root/internal/media/manager_test.go
diff options
context:
space:
mode:
Diffstat (limited to 'internal/media/manager_test.go')
-rw-r--r--internal/media/manager_test.go10
1 files changed, 5 insertions, 5 deletions
diff --git a/internal/media/manager_test.go b/internal/media/manager_test.go
index 396df1523..67f0184bd 100644
--- a/internal/media/manager_test.go
+++ b/internal/media/manager_test.go
@@ -26,7 +26,6 @@ import (
"os"
"path"
"testing"
- "time"
"codeberg.org/gruf/go-store/kv"
"codeberg.org/gruf/go-store/storage"
@@ -34,6 +33,7 @@ import (
gtsmodel "github.com/superseriousbusiness/gotosocial/internal/gtsmodel"
"github.com/superseriousbusiness/gotosocial/internal/media"
gtsstorage "github.com/superseriousbusiness/gotosocial/internal/storage"
+ "github.com/superseriousbusiness/gotosocial/testrig"
)
type ManagerTestSuite struct {
@@ -360,11 +360,11 @@ func (suite *ManagerTestSuite) TestSimpleJpegProcessAsync() {
attachmentID := processingMedia.AttachmentID()
// wait for the media to finish processing
- for finished := processingMedia.Finished(); !finished; finished = processingMedia.Finished() {
- time.Sleep(10 * time.Millisecond)
- fmt.Printf("\n\nnot finished yet...\n\n")
+ if !testrig.WaitFor(func() bool {
+ return processingMedia.Finished()
+ }) {
+ suite.FailNow("timed out waiting for media to be processed")
}
- fmt.Printf("\n\nfinished!\n\n")
// fetch the attachment from the database
attachment, err := suite.db.GetAttachmentByID(ctx, attachmentID)