diff options
| author | Paul Buetow <paul@buetow.org> | 2026-05-01 15:57:13 +0300 |
|---|---|---|
| committer | Paul Buetow <paul@buetow.org> | 2026-05-01 15:57:13 +0300 |
| commit | 65ee2e4d7f2be8036457e3cdca0e26e09eb56e0b (patch) | |
| tree | cbd8143db9e81baed51239a628dfedae2dbf375f /internal/service | |
| parent | 56666ca87f11e72521dcda00de72438e13899b95 (diff) | |
add readme and so on
Diffstat (limited to 'internal/service')
| -rw-r--r-- | internal/service/admin.go | 2 | ||||
| -rw-r--r-- | internal/service/admin_test.go | 10 |
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") }, |
