feat: Add log to list list processor

1 files changed, 14 insertions, 4 deletions

diff --git a/cmd/server/main.go b/cmd/server/main.go
index 8b1cc00..54a7ba0 100644
--- a/cmd/server/main.go
+++ b/cmd/server/main.go
@@ -109,17 +109,27 @@ func main() {
 		v.SetMyselfIn(extRouter)
 	}
 
+	// processors
+	var (
+		fileScanner = worker.NewFileScanner(*root, mediaRepository)
+		exifScanner = worker.NewEXIFScanner(mediaRepository)
+	)
+
 	// worker
 	var (
 		serverWorker = worker.NewServerWorker(&fasthttp.Server{Handler: r.Handler})
-		fileScanner  = worker.NewFileScanner(*root, mediaRepository)
-		exifScanner  = worker.NewEXIFScanner(mediaRepository)
+		fileWorker   = worker.NewWorkerFromChanProcessor[string](fileScanner, scheduler)
+		exifWorker   = worker.NewWorkerFromListProcessor[*media.Media](
+			exifScanner,
+			scheduler,
+			logrus.WithField("context", "exif scanner"),
+		)
 	)
 
 	pool := worker.NewWorkerPool()
 	pool.AddWorker("http server", serverWorker)
-	pool.AddWorker("exif scanner", worker.NewWorkerFromListProcessor[*media.Media](exifScanner, scheduler))
-	pool.AddWorker("file scanner", worker.NewWorkerFromChanProcessor[string](fileScanner, scheduler))
+	pool.AddWorker("exif scanner", exifWorker)
+	pool.AddWorker("file scanner", fileWorker)
 
 	ctx, stop := signal.NotifyContext(context.Background(), os.Interrupt)
 	defer stop()