From 05a8dbf46792adfef007a0ffbcb654026db036fa Mon Sep 17 00:00:00 2001
From: Gabriel Arakaki Giovanini <mail@gabrielgio.me>
Date: Tue, 4 Jul 2023 19:01:17 +0200
Subject: feat: Add use based file scanner

---
 pkg/worker/exif_scanner.go | 39 ---------------------------------------
 1 file changed, 39 deletions(-)
 delete mode 100644 pkg/worker/exif_scanner.go

(limited to 'pkg/worker/exif_scanner.go')

diff --git a/pkg/worker/exif_scanner.go b/pkg/worker/exif_scanner.go
deleted file mode 100644
index 5ea1810..0000000
--- a/pkg/worker/exif_scanner.go
+++ /dev/null
@@ -1,39 +0,0 @@
-package worker
-
-import (
-	"context"
-
-	"git.sr.ht/~gabrielgio/img/pkg/coroutine"
-	"git.sr.ht/~gabrielgio/img/pkg/database/repository"
-	"git.sr.ht/~gabrielgio/img/pkg/fileop"
-)
-
-type (
-	EXIFScanner struct {
-		repository repository.MediaRepository
-	}
-)
-
-var _ BatchProcessor[*repository.Media] = &EXIFScanner{}
-
-func NewEXIFScanner(repository repository.MediaRepository) *EXIFScanner {
-	return &EXIFScanner{
-		repository: repository,
-	}
-}
-
-func (e *EXIFScanner) Query(ctx context.Context) ([]*repository.Media, error) {
-	return e.repository.ListEmptyEXIF(ctx, &repository.Pagination{
-		Page: 0,
-		Size: 100,
-	})
-}
-
-func (e *EXIFScanner) Process(ctx context.Context, m *repository.Media) error {
-	exif, err := coroutine.WrapProcess(ctx, func() (*repository.MediaEXIF, error) { return fileop.ReadExif(m.Path) })
-	if err != nil {
-		return err
-	}
-
-	return e.repository.CreateEXIF(ctx, m.ID, exif)
-}
-- 
cgit v1.2.3