refactor: replace fileutil with fsutil and local hashing

internal/downloader/client.go

@@ -13,7 +13,7 @@ import (
 
 	"github.com/mathismqn/godeez/internal/config"
 	"github.com/mathismqn/godeez/internal/deezer"
-	"github.com/mathismqn/godeez/internal/fileutil"
+	"github.com/mathismqn/godeez/internal/fsutil"
 	"github.com/mathismqn/godeez/internal/store"
 	"github.com/mathismqn/godeez/internal/tag"
 )
@@ -27,7 +27,7 @@ type Client struct {
 	deezerClient *deezer.Client
 
 	hashIndexOnce sync.Once
-	hashIndex     *fileutil.HashIndex
+	hashIndex     *hashIndex
 	hashIndexErr  error
 }
 
@@ -85,7 +85,7 @@ func (c *Client) prepareResource(ctx context.Context, id string, opts Options) (
 	}
 
 	outputDir := resource.GetOutputDir(c.appConfig.OutputDir)
-	if err := fileutil.EnsureDir(outputDir); err != nil {
+	if err := fsutil.EnsureDir(outputDir); err != nil {
 		return nil, "", fmt.Errorf("failed to create output directory: %w", err)
 	}
 
@@ -156,7 +156,7 @@ func (c *Client) downloadTrack(ctx context.Context, resource deezer.Resource, tr
 
 	key := deezer.BlowfishKey(track.ID)
 	if err := c.streamToFile(dlCtx, stream, outputPath, key); err != nil {
-		fileutil.DeleteFile(outputPath)
+		fsutil.Remove(outputPath)
 		return downloadResult{err: fmt.Errorf("failed to stream to file: %w", err)}
 	}
 
@@ -237,7 +237,7 @@ func (c *Client) finalizeDownload(resource deezer.Resource, track *deezer.Track,
 		warnings = append(warnings, fmt.Sprintf("failed to add tags: %v", err))
 	}
 
-	hash, err := fileutil.GetFileHash(outputPath)
+	hash, err := hashFile(outputPath)
 	if err != nil {
 		warnings = append(warnings, fmt.Sprintf("failed to get file hash: %v", err))
 	}
@@ -259,7 +259,7 @@ func (c *Client) finalizeDownload(resource deezer.Resource, track *deezer.Track,
 
 func (c *Client) initHashIndex(ctx context.Context) error {
 	c.hashIndexOnce.Do(func() {
-		c.hashIndex, c.hashIndexErr = fileutil.NewHashIndex(ctx, c.appConfig.OutputDir)
+		c.hashIndex, c.hashIndexErr = newHashIndex(ctx, c.appConfig.OutputDir)
 	})
 
 	return c.hashIndexErr

internal/downloader/hash.go

@@ -0,0 +1,61 @@
+package downloader
+
+import (
+	"context"
+	"crypto/sha256"
+	"encoding/hex"
+	"io"
+	"io/fs"
+	"os"
+	"path/filepath"
+)
+
+func hashFile(path string) (string, error) {
+	file, err := os.Open(path)
+	if err != nil {
+		return "", err
+	}
+	defer file.Close()
+
+	h := sha256.New()
+	if _, err := io.Copy(h, file); err != nil {
+		return "", err
+	}
+
+	return hex.EncodeToString(h.Sum(nil)), nil
+}
+
+type hashIndex struct {
+	files map[string]string
+}
+
+func newHashIndex(ctx context.Context, root string) (*hashIndex, error) {
+	index := &hashIndex{files: make(map[string]string)}
+
+	err := filepath.WalkDir(root, func(path string, d fs.DirEntry, err error) error {
+		if ctx.Err() != nil {
+			return ctx.Err()
+		}
+		if err != nil || d.IsDir() {
+			return nil
+		}
+
+		hash, err := hashFile(path)
+		if err != nil {
+			return nil
+		}
+
+		index.files[hash] = path
+		return nil
+	})
+	if err != nil {
+		return nil, err
+	}
+
+	return index, nil
+}
+
+func (h *hashIndex) find(hash string) (string, bool) {
+	path, ok := h.files[hash]
+	return path, ok
+}

internal/downloader/skip.go

@@ -3,7 +3,7 @@ package downloader
 import (
 	"context"
 
-	"github.com/mathismqn/godeez/internal/fileutil"
+	"github.com/mathismqn/godeez/internal/fsutil"
 )
 
 func (c *Client) shouldSkipDownload(ctx context.Context, trackID, mediaFormat string) (string, bool) {
@@ -12,7 +12,7 @@ func (c *Client) shouldSkipDownload(ctx context.Context, trackID, mediaFormat st
 		return "", false
 	}
 
-	if fileutil.FileExists(existing.Path) {
+	if fsutil.Exists(existing.Path) {
 		return existing.Path, true
 	}
 
@@ -24,7 +24,7 @@ func (c *Client) shouldSkipDownload(ctx context.Context, trackID, mediaFormat st
 		return "", false
 	}
 
-	foundPath, ok := c.hashIndex.Find(existing.Hash)
+	foundPath, ok := c.hashIndex.find(existing.Hash)
 	if !ok {
 		return "", false
 	}