summaryrefslogtreecommitdiff
path: root/internal/service
diff options
context:
space:
mode:
Diffstat (limited to 'internal/service')
-rw-r--r--internal/service/admin.go2
-rw-r--r--internal/service/admin_test.go10
2 files changed, 6 insertions, 6 deletions
diff --git a/internal/service/admin.go b/internal/service/admin.go
index 673bf37..ebae686 100644
--- a/internal/service/admin.go
+++ b/internal/service/admin.go
@@ -45,7 +45,7 @@ func (s *adminService) TriggerRescan(ctx context.Context) error {
go func() {
ctx, cancel := context.WithTimeout(context.Background(), 30*time.Minute)
defer cancel()
- if err := s.scanner.Scan(ctx, s.mediaRoot); err != nil {
+ if err := s.scanner.Scan(ctx, s.mediaRoot, nil); err != nil {
fmt.Printf("[rescan] scan failed: %v\n", err)
} else {
fmt.Printf("[rescan] scan completed\n")
diff --git a/internal/service/admin_test.go b/internal/service/admin_test.go
index ac73ce2..d4be649 100644
--- a/internal/service/admin_test.go
+++ b/internal/service/admin_test.go
@@ -10,12 +10,12 @@ import (
)
type fakeScanner struct {
- scanFunc func(ctx context.Context, root string) error
+ scanFunc func(ctx context.Context, root string, progress *model.ScanProgress) error
}
-func (f *fakeScanner) Scan(ctx context.Context, root string) error {
+func (f *fakeScanner) Scan(ctx context.Context, root string, progress *model.ScanProgress) error {
if f.scanFunc != nil {
- return f.scanFunc(ctx, root)
+ return f.scanFunc(ctx, root, progress)
}
return nil
}
@@ -59,7 +59,7 @@ func TestAdminService_TriggerRescan(t *testing.T) {
var scannedRoot string
done := make(chan struct{})
sc := &fakeScanner{
- scanFunc: func(_ context.Context, root string) error {
+ scanFunc: func(_ context.Context, root string, _ *model.ScanProgress) error {
scannedRoot = root
close(done)
return nil
@@ -80,7 +80,7 @@ func TestAdminService_TriggerRescan_Error(t *testing.T) {
ctx := context.Background()
done := make(chan struct{})
sc := &fakeScanner{
- scanFunc: func(_ context.Context, _ string) error {
+ scanFunc: func(_ context.Context, _ string, _ *model.ScanProgress) error {
close(done)
return errors.New("scan failed")
},