Update README.md

README.md

@@ -19,7 +19,7 @@ structure for that files.
 
 ## Installing
 ```bash
-go install github.com/derfenix/photocatalog
+go install github.com/derfenix/photocatalog/v2@latest
 ```
 Optionally you could copy created binary from the GO's bin path to 
 system or user $PATH, e.g. /usr/local/bin/.
@@ -27,6 +27,10 @@ system or user $PATH, e.g. /usr/local/bin/.
 sudo cp ${GOPATH}/bin/photocatalog /usr/local/bin/photocatalog
 ```
 
+## Migrating from v0.*
+
+TODO 
+
 ## Supported formats
 At this moment supported jpeg files with filled exif data or any other 
 files but with names matching pattern `yyymmdd_HHMMSS.ext`. Such 
@@ -40,31 +44,31 @@ at this time.
 ### One-shot 
 #### Copy files (make a COW if fs supports it)
 ```bash
-photocalog -mode copy -target ./photos/ ./sync/photos/*
+photocalog -mode copy -target ./photos/ -source ./sync/photos/
 ```
 
 #### Create hardlinks (only withing one disk partition)
 ```bash
-photocalog -mode hardlink -target ./photos/ ./sync/photos/*
+photocalog -mode hardlink -target ./photos/ -source ./sync/photos/
 ```
 or 
 ```bash
-photocalog -target ./photos/ ./sync/photos/*
+photocalog -target ./photos/ -source ./sync/photos/*
 ```
 
-### Monitor
+### Watch mode
 #### Copy files (make a COW if fs supports it)
 ```bash
-photocalog -mode copy -target ./photos -monitor ./sync/photos/*
+photocalog -mode copy -target ./photos -watch -source ./sync/photos/
 ```
 
 #### Create hardlinks (only withing one disk partition)
 ```bash
-photocalog -mode hardlink -target ./photos/ -monitor ./sync/photos/
+photocalog -mode hardlink -target ./photos/ -watch -source ./sync/photos/
 ```
 or 
 ```bash
-photocalog -target ./photos/ -monitor ./sync/photos/
+photocalog -target ./photos/ -watch -source ./sync/photos/
 ```
 
 ## Install and run monitor service
@@ -89,6 +93,6 @@ under corresponding sub-dir.
 
 ### Why this tool was created if there is awesome XXX tool?
 I had two good reasons:
-1. I wanted
+1. I wish
 2. I can
 

application/application.go

@@ -0,0 +1,64 @@
+package application
+
+import (
+	"context"
+	"fmt"
+	"log"
+	"os"
+	"sync"
+
+	"github.com/derfenix/photocatalog/v2/internal/organizer"
+	"github.com/derfenix/photocatalog/v2/internal/organizer/modes"
+)
+
+type Application struct {
+	config Config
+}
+
+func NewApplication(config Config) (Application, error) {
+	if err := config.Validate(); err != nil {
+		return Application{}, fmt.Errorf("invalid config: %w", err)
+	}
+
+	return Application{config: config}, nil
+}
+
+func (a *Application) Start(ctx context.Context, wg *sync.WaitGroup) error {
+	var mode organizer.Mode
+
+	switch a.config.Mode {
+	case ModeCopy:
+		mode = modes.Copy{}
+	case ModeHardlink:
+		mode = modes.HardLink{}
+	case ModeMove:
+		mode = modes.Move{}
+	case ModeSymlink:
+		mode = modes.SymLink{}
+	default:
+		mode = modes.HardLink{}
+	}
+
+	org := organizer.NewOrganizer(mode, a.config.SourceDir, a.config.TargetDir).
+		WithDirMode(os.FileMode(a.config.DirMode)).
+		WithFileMode(os.FileMode(a.config.FileMode)).
+		WithErrLogger(func(err error) {
+			log.Println(err)
+		})
+
+	if a.config.Overwrite {
+		org = org.WithOverwrite()
+	}
+
+	if err := org.FullSync(ctx); err != nil {
+		return fmt.Errorf("full sync: %w", err)
+	}
+
+	if a.config.Watch {
+		if err := org.Watch(ctx, wg); err != nil {
+			return fmt.Errorf("initialize watch: %w", err)
+		}
+	}
+
+	return nil
+}

application/config.go

@@ -0,0 +1,41 @@
+package application
+
+import (
+	"fmt"
+	"slices"
+)
+
+type Mode string
+
+const (
+	ModeCopy     Mode = "copy"
+	ModeHardlink Mode = "hardlink"
+	ModeSymlink  Mode = "symlink"
+	ModeMove     Mode = "move"
+)
+
+type Config struct {
+	SourceDir string
+	TargetDir string
+	Mode      Mode
+	Overwrite bool
+	DirMode   uint64
+	FileMode  uint64
+	Watch     bool
+}
+
+func (c *Config) Validate() error {
+	if c.SourceDir == "" {
+		return fmt.Errorf("source dir is required")
+	}
+
+	if c.TargetDir == "" {
+		return fmt.Errorf("target dir is required")
+	}
+
+	if !slices.Contains([]Mode{ModeHardlink, ModeSymlink, ModeMove, ModeCopy}, c.Mode) {
+		return fmt.Errorf("invalid mode %s", c.Mode)
+	}
+
+	return nil
+}

cmd/photocatalog/photocatalog.go

@@ -1,140 +0,0 @@
-package main
-
-import (
-	"flag"
-	"log"
-	"os"
-	"os/signal"
-	"path"
-	"path/filepath"
-	"strings"
-	"syscall"
-
-	"github.com/fsnotify/fsnotify"
-
-	"github.com/derfenix/photocatalog/pkg/manager"
-)
-
-func main() {
-	mode := flag.String("mode", "hardlink", "Manage mode: copy or hardlink")
-	target := flag.String("target", "./", "Root directory to organize files in")
-	monitor := flag.String("monitor", "", "Monitor specified folder for new files")
-	updateMtime := flag.Bool("update_mtime", false, "Update mtime on organized files to be equal to the files creation date")
-
-	flag.Parse()
-	args := flag.Args()
-	log.Println("Using", *target, "as target and", *mode, "as mode")
-
-	var manageMode manager.ManageMode
-	switch *mode {
-	case "copy":
-		manageMode = manager.Copy
-	case "hardlink":
-		manageMode = manager.Hardlink
-	default:
-		log.Fatalf("Invalid mode %s", *mode)
-	}
-
-	mgr, err := manager.NewManager(*target, manageMode, *updateMtime)
-	if err != nil {
-		log.Fatalf(err.Error())
-	}
-
-	if *monitor == "" {
-		processFiles(args, mgr)
-	} else {
-		startMonitoring(*monitor, mgr)
-	}
-}
-
-func processFiles(args []string, manager *manager.Manager) {
-	var manageErr error
-	var gotErrors bool
-
-	if len(args) > 0 {
-		var err error
-		if len(args) == 1 && strings.HasSuffix(args[0], "/") {
-			args, err = filepath.Glob(args[0] + "*")
-			if err != nil {
-				log.Fatal(err)
-			}
-		}
-		log.Println("Processing", len(args), "files")
-		for _, f := range args {
-			manageErr = manager.Manage(f)
-			if manageErr != nil {
-				log.Println(manageErr)
-				gotErrors = true
-			}
-		}
-	} else {
-		log.Println("No input files")
-	}
-
-	if gotErrors {
-		log.Println("All files processed, got errors")
-	} else {
-		log.Println("All files processed without errors")
-	}
-}
-
-func startMonitoring(monitor string, manager *manager.Manager) {
-	var manageErr error
-
-	if !path.IsAbs(monitor) {
-		cwd, err := os.Getwd()
-		if err != nil {
-			log.Fatalf("failed to get CWD: %s", err.Error())
-		}
-		monitor = path.Join(cwd, monitor)
-	}
-
-	log.Println("Monitoring", monitor)
-
-	watcher, err := fsnotify.NewWatcher()
-	if err != nil {
-		log.Fatal(err)
-	}
-	defer func() {
-		closeErr := watcher.Close()
-		if closeErr != nil {
-			log.Println(closeErr)
-		}
-	}()
-
-	done := make(chan os.Signal)
-	signal.Notify(done, os.Interrupt, syscall.SIGTERM)
-
-	go func() {
-		for {
-			select {
-			case event, ok := <-watcher.Events:
-				if !ok {
-					return
-				}
-				if event.Op == fsnotify.Create {
-					if strings.HasSuffix(event.Name, "tmp") {
-						continue
-					}
-					manageErr = manager.Manage(event.Name)
-					if manageErr != nil {
-						log.Println(manageErr)
-					}
-				}
-			case wErr, ok := <-watcher.Errors:
-				log.Println("error:", wErr)
-				if !ok {
-					return
-				}
-			}
-		}
-	}()
-
-	err = watcher.Add(monitor)
-	if err != nil {
-		log.Fatal(err)
-	}
-
-	sig := <-done
-	log.Println("Monitoring stopped with", sig, "signal")
-}

go.mod

@@ -1,10 +1,10 @@
-module github.com/derfenix/photocatalog
+module github.com/derfenix/photocatalog/v2
 
-go 1.12
+go 1.22
 
 require (
-	github.com/fsnotify/fsnotify v1.4.7
+	github.com/fsnotify/fsnotify v1.8.0
-	github.com/pkg/errors v0.8.1
 	github.com/rwcarlsen/goexif v0.0.0-20190401172101-9e8deecbddbd
-	golang.org/x/sys v0.0.0-20190804053845-51ab0e2deafa // indirect
 )
+
+require golang.org/x/sys v0.28.0 // indirect

go.sum

@@ -1,8 +1,10 @@
 github.com/fsnotify/fsnotify v1.4.7 h1:IXs+QLmnXW2CcXuY+8Mzv/fWEsPGWxqefPtCP5CnV9I=
 github.com/fsnotify/fsnotify v1.4.7/go.mod h1:jwhsz4b93w/PPRr/qN1Yymfu8t87LnFCMoQvtojpjFo=
-github.com/pkg/errors v0.8.1 h1:iURUrRGxPUNPdy5/HRSm+Yj6okJ6UtLINN0Q9M4+h3I=
+github.com/fsnotify/fsnotify v1.8.0 h1:dAwr6QBTBZIkG8roQaJjGof0pp0EeF+tNV7YBP3F/8M=
-github.com/pkg/errors v0.8.1/go.mod h1:bwawxfHBFNV+L2hUp1rHADufV3IMtnDRdf1r5NINEl0=
+github.com/fsnotify/fsnotify v1.8.0/go.mod h1:8jBTzvmWwFyi3Pb8djgCCO5IBqzKJ/Jwo8TRcHyHii0=
 github.com/rwcarlsen/goexif v0.0.0-20190401172101-9e8deecbddbd h1:CmH9+J6ZSsIjUK3dcGsnCnO41eRBOnY12zwkn5qVwgc=
 github.com/rwcarlsen/goexif v0.0.0-20190401172101-9e8deecbddbd/go.mod h1:hPqNNc0+uJM6H+SuU8sEs5K5IQeKccPqeSjfgcKGgPk=
 golang.org/x/sys v0.0.0-20190804053845-51ab0e2deafa h1:KIDDMLT1O0Nr7TSxp8xM5tJcdn8tgyAONntO829og1M=
 golang.org/x/sys v0.0.0-20190804053845-51ab0e2deafa/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
+golang.org/x/sys v0.28.0 h1:Fksou7UEQUWlKvIdsqzJmUmCX3cZuD2+P3XyyzwMhlA=
+golang.org/x/sys v0.28.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA=

internal/metadata/default.go

@@ -0,0 +1,53 @@
+package metadata
+
+import (
+	"errors"
+	"fmt"
+	"io"
+	"path/filepath"
+	"strings"
+	"time"
+)
+
+const timeFormat = "20060102_150405"
+
+var (
+	ErrBadPrefix     = errors.New("bad prefix")
+	ErrBadNameFormat = errors.New("bad name format")
+)
+
+type Default struct {
+	TimeFormat string
+	Prefix     string
+}
+
+func (d *Default) Extract(fp string, _ io.Reader) (Metadata, error) {
+	format := d.TimeFormat
+	if format == "" {
+		format = timeFormat
+	}
+
+	if d.Prefix != "" && !strings.HasPrefix(fp, d.Prefix) {
+		return Metadata{}, fmt.Errorf("%w: expect a prefix %s, got %s", ErrBadPrefix, d.Prefix, fp)
+	}
+
+	fp = filepath.Base(fp)
+
+	leftLimit := len(d.Prefix)
+	rightLimit := leftLimit + len(format)
+
+	if len(fp) < rightLimit {
+		return Metadata{}, fmt.Errorf("%w: too short", ErrBadNameFormat)
+	}
+
+	created, err := time.Parse(format, fp[leftLimit:rightLimit])
+	if err != nil {
+		return Metadata{}, fmt.Errorf("parse time: %w", err)
+	}
+
+	meta := Metadata{
+		Created: created,
+	}
+
+	return meta, nil
+}

internal/metadata/default_test.go

@@ -0,0 +1,123 @@
+package metadata_test
+
+import (
+	"errors"
+	"reflect"
+	"testing"
+	"time"
+
+	. "github.com/derfenix/photocatalog/v2/internal/metadata"
+)
+
+func TestDefault_Extract(t *testing.T) {
+	t.Parallel()
+
+	const timeFormat = "20060102_150405"
+
+	tests := []struct {
+		name        string
+		filePath    string
+		prefix      string
+		timeFormat  string
+		want        Metadata
+		wantErr     bool
+		wantErrType error
+	}{
+		{
+			name:       "simple",
+			filePath:   "20241108_160834.jpg",
+			timeFormat: timeFormat,
+			want: Metadata{
+				Created: time.Date(2024, 11, 8, 16, 8, 34, 0, time.UTC),
+			},
+			wantErr: false,
+		},
+		{
+			name:       "simple in subdirectory",
+			filePath:   "foo/20241108_160834.jpg",
+			timeFormat: timeFormat,
+			want: Metadata{
+				Created: time.Date(2024, 11, 8, 16, 8, 34, 0, time.UTC),
+			},
+			wantErr: false,
+		},
+		{
+			name:       "simple with suffix",
+			filePath:   "20241108_160834_(1).jpg",
+			timeFormat: timeFormat,
+			want: Metadata{
+				Created: time.Date(2024, 11, 8, 16, 8, 34, 0, time.UTC),
+			},
+			wantErr: false,
+		},
+		{
+			name:       "prefix",
+			filePath:   "foo_20241108_160834.jpg",
+			timeFormat: timeFormat,
+			prefix:     "foo_",
+			want: Metadata{
+				Created: time.Date(2024, 11, 8, 16, 8, 34, 0, time.UTC),
+			},
+			wantErr: false,
+		},
+		{
+			name:       "bad prefix",
+			filePath:   "foo_20241108_160834.jpg",
+			timeFormat: timeFormat,
+			prefix:     "bar_",
+			want: Metadata{
+				Created: time.Time{},
+			},
+			wantErr:     true,
+			wantErrType: ErrBadPrefix,
+		},
+		{
+			name:       "no prefix",
+			filePath:   "20241108_160834.jpg",
+			timeFormat: timeFormat,
+			prefix:     "bar_",
+			want: Metadata{
+				Created: time.Time{},
+			},
+			wantErr:     true,
+			wantErrType: ErrBadPrefix,
+		},
+		{
+			name:       "unexpected prefix",
+			filePath:   "foo_20241108_160834.jpg",
+			timeFormat: timeFormat,
+			prefix:     "",
+			want: Metadata{
+				Created: time.Time{},
+			},
+			wantErr: true,
+		},
+	}
+
+	for _, tt := range tests {
+		t.Run(tt.name, func(t *testing.T) {
+			t.Parallel()
+
+			d := &Default{
+				TimeFormat: tt.timeFormat,
+				Prefix:     tt.prefix,
+			}
+
+			got, err := d.Extract(tt.filePath, nil)
+			if (err != nil) != tt.wantErr {
+				t.Errorf("Extract() error = %v, wantErr %v", err, tt.wantErr)
+				return
+			}
+
+			if tt.wantErr && tt.wantErrType != nil {
+				if !errors.Is(err, tt.wantErrType) {
+					t.Errorf("Extract() errorType = %v, wantErrType %v", err, tt.wantErrType)
+				}
+			}
+
+			if !reflect.DeepEqual(got, tt.want) {
+				t.Errorf("Extract() got = %v, want %v", got, tt.want)
+			}
+		})
+	}
+}

internal/metadata/exif.go

@@ -0,0 +1,28 @@
+package metadata
+
+import (
+	"fmt"
+	"io"
+
+	"github.com/rwcarlsen/goexif/exif"
+)
+
+type Exif struct{}
+
+func (j Exif) Extract(_ string, data io.Reader) (Metadata, error) {
+	decode, err := exif.Decode(data)
+	if err != nil {
+		return Metadata{}, fmt.Errorf("decode exif: %w", err)
+	}
+
+	meta := Metadata{}
+
+	created, err := decode.DateTime()
+	if err != nil {
+		return Metadata{}, fmt.Errorf("parse datetime: %w", err)
+	}
+
+	meta.Created = created
+
+	return meta, nil
+}

internal/metadata/metadata.go

@@ -0,0 +1,9 @@
+package metadata
+
+import (
+	"time"
+)
+
+type Metadata struct {
+	Created time.Time
+}

internal/organizer/modes/copy.go

@@ -0,0 +1,65 @@
+package modes
+
+import (
+	"fmt"
+	"io"
+	"log"
+	"os"
+	"runtime"
+	"sync/atomic"
+
+	"golang.org/x/sys/unix"
+)
+
+var cowDisabled = atomic.Bool{}
+
+type Copy struct{}
+
+func (c Copy) PlaceIt(sourcePath, targetPath string, mode os.FileMode) error {
+	targetFile, err := os.OpenFile(targetPath, os.O_TRUNC|os.O_WRONLY|os.O_CREATE, mode)
+	if err != nil {
+		return fmt.Errorf("open target file: %w", err)
+	}
+
+	defer func() {
+		_ = targetFile.Close()
+	}()
+
+	sourceFile, err := os.OpenFile(sourcePath, os.O_RDONLY, os.ModePerm)
+	if err != nil {
+		return fmt.Errorf("open source file: %w", err)
+	}
+
+	defer func() {
+		_ = sourceFile.Close()
+	}()
+
+	// Try to do a COW.
+	if runtime.GOOS == "linux" && !cowDisabled.Load() {
+		if err := unix.IoctlFileClone(int(targetFile.Fd()+1), int(sourceFile.Fd())); err == nil {
+			return nil
+		} else {
+			log.Println(fmt.Errorf("COW attempt for %s failed: %w", targetPath, err))
+			log.Println("Disabling COW until restart")
+			cowDisabled.Store(true)
+		}
+	}
+
+	copySize, err := io.Copy(targetFile, sourceFile)
+	if err != nil {
+		return fmt.Errorf("copy source file: %w", err)
+	}
+
+	stat, err := sourceFile.Stat()
+	if err != nil {
+		log.Println("stat source file failed:", err)
+
+		return nil
+	}
+
+	if stat.Size() != copySize {
+		log.Printf("copy source file size not equal target file size: source %d != %d copied\n", stat.Size(), copySize)
+	}
+
+	return nil
+}

internal/organizer/modes/copy_test.go

@@ -0,0 +1,47 @@
+package modes_test
+
+import (
+	"fmt"
+	"os"
+	"testing"
+
+	. "github.com/derfenix/photocatalog/v2/internal/organizer/modes"
+)
+
+func TestCopy_PlaceIt(t *testing.T) {
+	t.Parallel()
+
+	const testDataDir = "copy"
+
+	t.Cleanup(func() {
+		if err := os.RemoveAll(fmt.Sprintf("./testdata/%s/target/", testDataDir)); err != nil {
+			t.Errorf("error removing ./testdata/%s/target/: %v", testDataDir, err)
+		}
+	})
+
+	if err := os.Mkdir(fmt.Sprintf("./testdata/%s/target/", testDataDir), 0777); err != nil {
+		t.Errorf("error creating ./testdata/%s/target/: %v", testDataDir, err)
+	}
+
+	source := fmt.Sprintf("./testdata/%s/source/foo.txt", testDataDir)
+	target := fmt.Sprintf("./testdata/%s/target/foo.txt", testDataDir)
+
+	err := Copy{}.PlaceIt(source, target, 0644)
+	if err != nil {
+		t.Errorf("place file: %v", err)
+	}
+
+	targetData, err := os.ReadFile(target)
+	if err != nil {
+		t.Errorf("read target file: %v", err)
+	}
+
+	sourceData, err := os.ReadFile(source)
+	if err != nil {
+		t.Errorf("read source file: %v", err)
+	}
+
+	if string(targetData) != string(sourceData) {
+		t.Error("copy file contents missmatch")
+	}
+}

internal/organizer/modes/hardlink.go

@@ -0,0 +1,21 @@
+package modes
+
+import (
+	"fmt"
+	"os"
+)
+
+type HardLink struct {
+}
+
+func (h HardLink) PlaceIt(sourcePath, targetPath string, mode os.FileMode) error {
+	if err := os.Link(sourcePath, targetPath); err != nil {
+		if os.IsExist(err) {
+			return nil
+		}
+
+		return fmt.Errorf("create hard link: %w", err)
+	}
+
+	return nil
+}

internal/organizer/modes/hardlink_test.go

@@ -0,0 +1,47 @@
+package modes_test
+
+import (
+	"fmt"
+	"os"
+	"testing"
+
+	. "github.com/derfenix/photocatalog/v2/internal/organizer/modes"
+)
+
+func TestHardLink_PlaceIt(t *testing.T) {
+	t.Parallel()
+
+	const testDataDir = "hardlink"
+
+	t.Cleanup(func() {
+		if err := os.RemoveAll(fmt.Sprintf("./testdata/%s/target/", testDataDir)); err != nil {
+			t.Errorf("error removing ./testdata/%s/target/: %v", testDataDir, err)
+		}
+	})
+
+	if err := os.Mkdir(fmt.Sprintf("./testdata/%s/target/", testDataDir), 0777); err != nil {
+		t.Errorf("error creating ./testdata/%s/target/: %v", testDataDir, err)
+	}
+
+	source := fmt.Sprintf("./testdata/%s/source/foo.txt", testDataDir)
+	target := fmt.Sprintf("./testdata/%s/target/foo.txt", testDataDir)
+
+	err := HardLink{}.PlaceIt(source, target, 0644)
+	if err != nil {
+		t.Errorf("place file: %v", err)
+	}
+
+	targetData, err := os.ReadFile(target)
+	if err != nil {
+		t.Errorf("read target file: %v", err)
+	}
+
+	sourceData, err := os.ReadFile(source)
+	if err != nil {
+		t.Errorf("read source file: %v", err)
+	}
+
+	if string(targetData) != string(sourceData) {
+		t.Error("copy file contents missmatch")
+	}
+}

internal/organizer/modes/move.go

@@ -0,0 +1,21 @@
+package modes
+
+import (
+	"fmt"
+	"os"
+)
+
+type Move struct {
+}
+
+func (m Move) PlaceIt(sourcePath, targetPath string, mode os.FileMode) error {
+	if err := os.Rename(sourcePath, targetPath); err != nil {
+		return fmt.Errorf("rename %s to %s: %w", sourcePath, targetPath, err)
+	}
+
+	if err := os.Chmod(targetPath, mode); err != nil {
+		return fmt.Errorf("chmod hard link: %w", err)
+	}
+
+	return nil
+}

internal/organizer/modes/move_test.go

@@ -0,0 +1,53 @@
+package modes_test
+
+import (
+	"fmt"
+	"os"
+	"testing"
+
+	. "github.com/derfenix/photocatalog/v2/internal/organizer/modes"
+)
+
+func TestMove_PlaceIt(t *testing.T) {
+	t.Parallel()
+
+	const testDataDir = "move"
+
+	t.Cleanup(func() {
+		if err := os.RemoveAll(fmt.Sprintf("./testdata/%s/target/", testDataDir)); err != nil {
+			t.Errorf("error removing ./testdata/%s/target/: %v", testDataDir, err)
+		}
+	})
+
+	if err := os.Mkdir(fmt.Sprintf("./testdata/%s/target/", testDataDir), 0777); err != nil {
+		t.Errorf("error creating ./testdata/%s/target/: %v", testDataDir, err)
+	}
+
+	source := fmt.Sprintf("./testdata/%s/source/foo.txt", testDataDir)
+	target := fmt.Sprintf("./testdata/%s/target/foo.txt", testDataDir)
+
+	t.Cleanup(func() {
+		if err := (&Move{}).PlaceIt(target, source, 0644); err != nil {
+			t.Errorf("error placing back target: %v", err)
+		}
+	})
+
+	sourceData, err := os.ReadFile(source)
+	if err != nil {
+		t.Errorf("read source file: %v", err)
+	}
+
+	err = Move{}.PlaceIt(source, target, 0644)
+	if err != nil {
+		t.Errorf("place file: %v", err)
+	}
+
+	targetData, err := os.ReadFile(target)
+	if err != nil {
+		t.Errorf("read target file: %v", err)
+	}
+
+	if string(targetData) != string(sourceData) {
+		t.Error("copy file contents missmatch")
+	}
+}

internal/organizer/modes/symlink.go

@@ -0,0 +1,21 @@
+package modes
+
+import (
+	"fmt"
+	"os"
+)
+
+type SymLink struct {
+}
+
+func (s SymLink) PlaceIt(sourcePath, targetPath string, _ os.FileMode) error {
+	if err := os.Symlink(sourcePath, targetPath); err != nil {
+		if os.IsExist(err) {
+			return nil
+		}
+
+		return fmt.Errorf("create symlink: %w", err)
+	}
+
+	return nil
+}

internal/organizer/modes/symlink_test.go

@@ -0,0 +1,42 @@
+package modes_test
+
+import (
+	"fmt"
+	"os"
+	"testing"
+
+	. "github.com/derfenix/photocatalog/v2/internal/organizer/modes"
+)
+
+func TestSymLink_PlaceIt(t *testing.T) {
+	t.Parallel()
+
+	const testDataDir = "symlink"
+
+	t.Cleanup(func() {
+		if err := os.RemoveAll(fmt.Sprintf("./testdata/%s/target/", testDataDir)); err != nil {
+			t.Errorf("error removing ./testdata/%s/target/: %v", testDataDir, err)
+		}
+	})
+
+	if err := os.Mkdir(fmt.Sprintf("./testdata/%s/target/", testDataDir), 0777); err != nil {
+		t.Errorf("error creating ./testdata/%s/target/: %v", testDataDir, err)
+	}
+
+	source := fmt.Sprintf("./testdata/%s/source/foo.txt", testDataDir)
+	target := fmt.Sprintf("./testdata/%s/target/foo.txt", testDataDir)
+
+	err := SymLink{}.PlaceIt(source, target, 0644)
+	if err != nil {
+		t.Errorf("place file: %v", err)
+	}
+
+	linkedFilePath, err := os.Readlink(target)
+	if err != nil {
+		t.Errorf("read target file: %v", err)
+	}
+
+	if linkedFilePath != source {
+		t.Errorf("linked file path is %s, want %s", linkedFilePath, source)
+	}
+}

internal/organizer/modes/testdata/copy/source/foo.txt

@@ -0,0 +1,17 @@
+Lorem ipsum dolor sit amet, consectetur adipiscing elit. Elit culpa hendrerit assum aliquam placerat cupiditat placerat excepteur doming ad incidunt magna eirmod, delenit nam at aliquip iure cupiditat qui congue consectetuer placerat mollit enim fugiat consequat aliquip delenit nam feugait vero aliquyam vel vel. Euismod adipiscing anim officia nibh molestie amet pariatur. Te te nulla pariatur ut option doming excepteur gubergren justo dolore sadipscing tempor stet. Tation nonummy nam nulla sint odio at sint feugait cum esse. Lorem adipiscing excepteur praesent nisi facilisis, clita invidunt molestie vulputate in tempor vulputate eiusmod tincidunt nobis. Iusto iure exerci.
+
+Gubergren nobis ut illum dignissim at aliquam feugiat tation velit illum consequat hendrerit. Feugait facilisis nibh odio sint at adipiscing at nibh incidunt quod cupiditat ullamcorper dolore ex aute ullamco commodi rebum rebum sunt ea enim fugiat facilisi exercitation feugait eos blandit nihil molestie et facilisi aute incidunt nisl illum. Assum consequat assum at et voluptate nobis sed nobis sunt id eros consectetuer, culpa tation deserunt praesent aliquam erat stet zzril voluptate nibh, et fugiat commodi quod tation stet sadipscing lobortis officia quod ex imperdiet doming. Excepteur augue nobis.
+
+Sanctus possim feugiat nostrud amet illum eros, eu ipsum dignissim ea tincidunt tincidunt accusam delenit placerat vel facilisi volutpat amet. Wisi dolore zzril pariatur odio cum incidunt esse duo liber aliquam voluptate eos autem est. Congue kasd vero hendrerit adipiscing rebum elitr, laboris mollit takimata nonummy id esse commodo excepteur non possim quis zzril. Consectetuer accumsan volutpat.
+
+Eum nibh zzril vulputate consectetur mazim voluptate commodo sea augue tempor. Fugiat voluptua tempor nonumy. Congue eirmod voluptua nulla. Nonumy consectetuer voluptate.
+
+Consequat eum tempor stet cupiditat quis in nobis. Veniam lorem sit veniam eu amet option no molestie dolores option cum reprehenderit assum tempor. Gubergren dolore wisi ut voluptua amet eum incidunt commodi eos justo quis lorem aliquyam velit praesent ullamco tempor anim volutpat velit velit aliquam cum facilisis iusto erat veniam option. Rebum nobis ea excepteur ex sea consequat blandit, excepteur et qui mazim lorem eos augue duo nulla deserunt ullamco sadipscing sed. Eos takimata justo incidunt sea vulputate blandit tempor aliqua reprehenderit aliquid sit aliqua takimata. Ullamco takimata elitr dolore ipsum takimata. Consequat aute aliquid.
+
+Placerat sunt ut delenit aliquid enim hendrerit. Vel rebum et ad dolor luptatum veniam, volutpat soluta euismod facilisis lobortis placerat eos dignissim excepteur reprehenderit facer autem nobis officia facilisis, quis duo augue dolor autem placerat obcaecat ipsum volutpat pariatur. Ullamco elitr exerci at ad nostrud. Suscipit eu dolores sint molestie proident eleifend aute sadipscing anim. Iusto aliquid aliquam.
+
+Iriure elitr sit nihil sanctus soluta autem et, nisi dolores erat option blandit soluta aliquip nihil placerat cum clita diam duis sunt sunt tation vel consequat deserunt doming gubergren euismod liber ad esse augue aliquyam ad facilisis. Anim dignissim fugiat. Aliquam dolores, obcaecat aliquam nobis quod euismod consectetur iusto wisi aute mollit eirmod eirmod nonumy, qui officia in eros hendrerit nonummy soluta option aliquip. Feugait laboris duis accumsan proident velit stet invidunt kasd consetetur nobis fugiat invidunt cupiditat et excepteur nonumy feugait iusto consectetur eos cillum. Eos at commodo facilisi. Facer facilisi exercitation.
+
+Soluta takimata labore sunt erat cum option eu deserunt eu consectetur, soluta option cum euismod aliquid illum commodo obcaecat aliquyam erat eleifend blandit, mazim exercitation consequat duis vel imperdiet consetetur ullamco doming. In elit duis. Duo praesent lorem.
+
+Commodi molestie reprehenderit ipsum enim, zzril vulputate in laboris voluptua nibh suscipit, autem facilisi invidunt commodi iusto mollit aliquip nam culpa consetetur dolore elitr, fugiat luptatum nisl amet elitr facilisis te quod ad kasd wisi reprehenderit invidunt. Facer ut quis nam dignissim. Option suscipit duis dolor consequat takimata te amet accumsan obcaecat autem congue ad obcaecat velit. Imperdiet id laborum sea. Hendrerit nisi eros.

internal/organizer/modes/testdata/hardlink/source/foo.txt

@@ -0,0 +1,17 @@
+Lorem ipsum dolor sit amet, consectetur adipiscing elit. Elit culpa hendrerit assum aliquam placerat cupiditat placerat excepteur doming ad incidunt magna eirmod, delenit nam at aliquip iure cupiditat qui congue consectetuer placerat mollit enim fugiat consequat aliquip delenit nam feugait vero aliquyam vel vel. Euismod adipiscing anim officia nibh molestie amet pariatur. Te te nulla pariatur ut option doming excepteur gubergren justo dolore sadipscing tempor stet. Tation nonummy nam nulla sint odio at sint feugait cum esse. Lorem adipiscing excepteur praesent nisi facilisis, clita invidunt molestie vulputate in tempor vulputate eiusmod tincidunt nobis. Iusto iure exerci.
+
+Gubergren nobis ut illum dignissim at aliquam feugiat tation velit illum consequat hendrerit. Feugait facilisis nibh odio sint at adipiscing at nibh incidunt quod cupiditat ullamcorper dolore ex aute ullamco commodi rebum rebum sunt ea enim fugiat facilisi exercitation feugait eos blandit nihil molestie et facilisi aute incidunt nisl illum. Assum consequat assum at et voluptate nobis sed nobis sunt id eros consectetuer, culpa tation deserunt praesent aliquam erat stet zzril voluptate nibh, et fugiat commodi quod tation stet sadipscing lobortis officia quod ex imperdiet doming. Excepteur augue nobis.
+
+Sanctus possim feugiat nostrud amet illum eros, eu ipsum dignissim ea tincidunt tincidunt accusam delenit placerat vel facilisi volutpat amet. Wisi dolore zzril pariatur odio cum incidunt esse duo liber aliquam voluptate eos autem est. Congue kasd vero hendrerit adipiscing rebum elitr, laboris mollit takimata nonummy id esse commodo excepteur non possim quis zzril. Consectetuer accumsan volutpat.
+
+Eum nibh zzril vulputate consectetur mazim voluptate commodo sea augue tempor. Fugiat voluptua tempor nonumy. Congue eirmod voluptua nulla. Nonumy consectetuer voluptate.
+
+Consequat eum tempor stet cupiditat quis in nobis. Veniam lorem sit veniam eu amet option no molestie dolores option cum reprehenderit assum tempor. Gubergren dolore wisi ut voluptua amet eum incidunt commodi eos justo quis lorem aliquyam velit praesent ullamco tempor anim volutpat velit velit aliquam cum facilisis iusto erat veniam option. Rebum nobis ea excepteur ex sea consequat blandit, excepteur et qui mazim lorem eos augue duo nulla deserunt ullamco sadipscing sed. Eos takimata justo incidunt sea vulputate blandit tempor aliqua reprehenderit aliquid sit aliqua takimata. Ullamco takimata elitr dolore ipsum takimata. Consequat aute aliquid.
+
+Placerat sunt ut delenit aliquid enim hendrerit. Vel rebum et ad dolor luptatum veniam, volutpat soluta euismod facilisis lobortis placerat eos dignissim excepteur reprehenderit facer autem nobis officia facilisis, quis duo augue dolor autem placerat obcaecat ipsum volutpat pariatur. Ullamco elitr exerci at ad nostrud. Suscipit eu dolores sint molestie proident eleifend aute sadipscing anim. Iusto aliquid aliquam.
+
+Iriure elitr sit nihil sanctus soluta autem et, nisi dolores erat option blandit soluta aliquip nihil placerat cum clita diam duis sunt sunt tation vel consequat deserunt doming gubergren euismod liber ad esse augue aliquyam ad facilisis. Anim dignissim fugiat. Aliquam dolores, obcaecat aliquam nobis quod euismod consectetur iusto wisi aute mollit eirmod eirmod nonumy, qui officia in eros hendrerit nonummy soluta option aliquip. Feugait laboris duis accumsan proident velit stet invidunt kasd consetetur nobis fugiat invidunt cupiditat et excepteur nonumy feugait iusto consectetur eos cillum. Eos at commodo facilisi. Facer facilisi exercitation.
+
+Soluta takimata labore sunt erat cum option eu deserunt eu consectetur, soluta option cum euismod aliquid illum commodo obcaecat aliquyam erat eleifend blandit, mazim exercitation consequat duis vel imperdiet consetetur ullamco doming. In elit duis. Duo praesent lorem.
+
+Commodi molestie reprehenderit ipsum enim, zzril vulputate in laboris voluptua nibh suscipit, autem facilisi invidunt commodi iusto mollit aliquip nam culpa consetetur dolore elitr, fugiat luptatum nisl amet elitr facilisis te quod ad kasd wisi reprehenderit invidunt. Facer ut quis nam dignissim. Option suscipit duis dolor consequat takimata te amet accumsan obcaecat autem congue ad obcaecat velit. Imperdiet id laborum sea. Hendrerit nisi eros.

internal/organizer/modes/testdata/move/source/foo.txt

@@ -0,0 +1,17 @@
+Lorem ipsum dolor sit amet, consectetur adipiscing elit. Elit culpa hendrerit assum aliquam placerat cupiditat placerat excepteur doming ad incidunt magna eirmod, delenit nam at aliquip iure cupiditat qui congue consectetuer placerat mollit enim fugiat consequat aliquip delenit nam feugait vero aliquyam vel vel. Euismod adipiscing anim officia nibh molestie amet pariatur. Te te nulla pariatur ut option doming excepteur gubergren justo dolore sadipscing tempor stet. Tation nonummy nam nulla sint odio at sint feugait cum esse. Lorem adipiscing excepteur praesent nisi facilisis, clita invidunt molestie vulputate in tempor vulputate eiusmod tincidunt nobis. Iusto iure exerci.
+
+Gubergren nobis ut illum dignissim at aliquam feugiat tation velit illum consequat hendrerit. Feugait facilisis nibh odio sint at adipiscing at nibh incidunt quod cupiditat ullamcorper dolore ex aute ullamco commodi rebum rebum sunt ea enim fugiat facilisi exercitation feugait eos blandit nihil molestie et facilisi aute incidunt nisl illum. Assum consequat assum at et voluptate nobis sed nobis sunt id eros consectetuer, culpa tation deserunt praesent aliquam erat stet zzril voluptate nibh, et fugiat commodi quod tation stet sadipscing lobortis officia quod ex imperdiet doming. Excepteur augue nobis.
+
+Sanctus possim feugiat nostrud amet illum eros, eu ipsum dignissim ea tincidunt tincidunt accusam delenit placerat vel facilisi volutpat amet. Wisi dolore zzril pariatur odio cum incidunt esse duo liber aliquam voluptate eos autem est. Congue kasd vero hendrerit adipiscing rebum elitr, laboris mollit takimata nonummy id esse commodo excepteur non possim quis zzril. Consectetuer accumsan volutpat.
+
+Eum nibh zzril vulputate consectetur mazim voluptate commodo sea augue tempor. Fugiat voluptua tempor nonumy. Congue eirmod voluptua nulla. Nonumy consectetuer voluptate.
+
+Consequat eum tempor stet cupiditat quis in nobis. Veniam lorem sit veniam eu amet option no molestie dolores option cum reprehenderit assum tempor. Gubergren dolore wisi ut voluptua amet eum incidunt commodi eos justo quis lorem aliquyam velit praesent ullamco tempor anim volutpat velit velit aliquam cum facilisis iusto erat veniam option. Rebum nobis ea excepteur ex sea consequat blandit, excepteur et qui mazim lorem eos augue duo nulla deserunt ullamco sadipscing sed. Eos takimata justo incidunt sea vulputate blandit tempor aliqua reprehenderit aliquid sit aliqua takimata. Ullamco takimata elitr dolore ipsum takimata. Consequat aute aliquid.
+
+Placerat sunt ut delenit aliquid enim hendrerit. Vel rebum et ad dolor luptatum veniam, volutpat soluta euismod facilisis lobortis placerat eos dignissim excepteur reprehenderit facer autem nobis officia facilisis, quis duo augue dolor autem placerat obcaecat ipsum volutpat pariatur. Ullamco elitr exerci at ad nostrud. Suscipit eu dolores sint molestie proident eleifend aute sadipscing anim. Iusto aliquid aliquam.
+
+Iriure elitr sit nihil sanctus soluta autem et, nisi dolores erat option blandit soluta aliquip nihil placerat cum clita diam duis sunt sunt tation vel consequat deserunt doming gubergren euismod liber ad esse augue aliquyam ad facilisis. Anim dignissim fugiat. Aliquam dolores, obcaecat aliquam nobis quod euismod consectetur iusto wisi aute mollit eirmod eirmod nonumy, qui officia in eros hendrerit nonummy soluta option aliquip. Feugait laboris duis accumsan proident velit stet invidunt kasd consetetur nobis fugiat invidunt cupiditat et excepteur nonumy feugait iusto consectetur eos cillum. Eos at commodo facilisi. Facer facilisi exercitation.
+
+Soluta takimata labore sunt erat cum option eu deserunt eu consectetur, soluta option cum euismod aliquid illum commodo obcaecat aliquyam erat eleifend blandit, mazim exercitation consequat duis vel imperdiet consetetur ullamco doming. In elit duis. Duo praesent lorem.
+
+Commodi molestie reprehenderit ipsum enim, zzril vulputate in laboris voluptua nibh suscipit, autem facilisi invidunt commodi iusto mollit aliquip nam culpa consetetur dolore elitr, fugiat luptatum nisl amet elitr facilisis te quod ad kasd wisi reprehenderit invidunt. Facer ut quis nam dignissim. Option suscipit duis dolor consequat takimata te amet accumsan obcaecat autem congue ad obcaecat velit. Imperdiet id laborum sea. Hendrerit nisi eros.

internal/organizer/modes/testdata/symlink/source/foo.txt

@@ -0,0 +1,17 @@
+Lorem ipsum dolor sit amet, consectetur adipiscing elit. Elit culpa hendrerit assum aliquam placerat cupiditat placerat excepteur doming ad incidunt magna eirmod, delenit nam at aliquip iure cupiditat qui congue consectetuer placerat mollit enim fugiat consequat aliquip delenit nam feugait vero aliquyam vel vel. Euismod adipiscing anim officia nibh molestie amet pariatur. Te te nulla pariatur ut option doming excepteur gubergren justo dolore sadipscing tempor stet. Tation nonummy nam nulla sint odio at sint feugait cum esse. Lorem adipiscing excepteur praesent nisi facilisis, clita invidunt molestie vulputate in tempor vulputate eiusmod tincidunt nobis. Iusto iure exerci.
+
+Gubergren nobis ut illum dignissim at aliquam feugiat tation velit illum consequat hendrerit. Feugait facilisis nibh odio sint at adipiscing at nibh incidunt quod cupiditat ullamcorper dolore ex aute ullamco commodi rebum rebum sunt ea enim fugiat facilisi exercitation feugait eos blandit nihil molestie et facilisi aute incidunt nisl illum. Assum consequat assum at et voluptate nobis sed nobis sunt id eros consectetuer, culpa tation deserunt praesent aliquam erat stet zzril voluptate nibh, et fugiat commodi quod tation stet sadipscing lobortis officia quod ex imperdiet doming. Excepteur augue nobis.
+
+Sanctus possim feugiat nostrud amet illum eros, eu ipsum dignissim ea tincidunt tincidunt accusam delenit placerat vel facilisi volutpat amet. Wisi dolore zzril pariatur odio cum incidunt esse duo liber aliquam voluptate eos autem est. Congue kasd vero hendrerit adipiscing rebum elitr, laboris mollit takimata nonummy id esse commodo excepteur non possim quis zzril. Consectetuer accumsan volutpat.
+
+Eum nibh zzril vulputate consectetur mazim voluptate commodo sea augue tempor. Fugiat voluptua tempor nonumy. Congue eirmod voluptua nulla. Nonumy consectetuer voluptate.
+
+Consequat eum tempor stet cupiditat quis in nobis. Veniam lorem sit veniam eu amet option no molestie dolores option cum reprehenderit assum tempor. Gubergren dolore wisi ut voluptua amet eum incidunt commodi eos justo quis lorem aliquyam velit praesent ullamco tempor anim volutpat velit velit aliquam cum facilisis iusto erat veniam option. Rebum nobis ea excepteur ex sea consequat blandit, excepteur et qui mazim lorem eos augue duo nulla deserunt ullamco sadipscing sed. Eos takimata justo incidunt sea vulputate blandit tempor aliqua reprehenderit aliquid sit aliqua takimata. Ullamco takimata elitr dolore ipsum takimata. Consequat aute aliquid.
+
+Placerat sunt ut delenit aliquid enim hendrerit. Vel rebum et ad dolor luptatum veniam, volutpat soluta euismod facilisis lobortis placerat eos dignissim excepteur reprehenderit facer autem nobis officia facilisis, quis duo augue dolor autem placerat obcaecat ipsum volutpat pariatur. Ullamco elitr exerci at ad nostrud. Suscipit eu dolores sint molestie proident eleifend aute sadipscing anim. Iusto aliquid aliquam.
+
+Iriure elitr sit nihil sanctus soluta autem et, nisi dolores erat option blandit soluta aliquip nihil placerat cum clita diam duis sunt sunt tation vel consequat deserunt doming gubergren euismod liber ad esse augue aliquyam ad facilisis. Anim dignissim fugiat. Aliquam dolores, obcaecat aliquam nobis quod euismod consectetur iusto wisi aute mollit eirmod eirmod nonumy, qui officia in eros hendrerit nonummy soluta option aliquip. Feugait laboris duis accumsan proident velit stet invidunt kasd consetetur nobis fugiat invidunt cupiditat et excepteur nonumy feugait iusto consectetur eos cillum. Eos at commodo facilisi. Facer facilisi exercitation.
+
+Soluta takimata labore sunt erat cum option eu deserunt eu consectetur, soluta option cum euismod aliquid illum commodo obcaecat aliquyam erat eleifend blandit, mazim exercitation consequat duis vel imperdiet consetetur ullamco doming. In elit duis. Duo praesent lorem.
+
+Commodi molestie reprehenderit ipsum enim, zzril vulputate in laboris voluptua nibh suscipit, autem facilisi invidunt commodi iusto mollit aliquip nam culpa consetetur dolore elitr, fugiat luptatum nisl amet elitr facilisis te quod ad kasd wisi reprehenderit invidunt. Facer ut quis nam dignissim. Option suscipit duis dolor consequat takimata te amet accumsan obcaecat autem congue ad obcaecat velit. Imperdiet id laborum sea. Hendrerit nisi eros.

internal/organizer/organizer.go

@@ -0,0 +1,312 @@
+package organizer
+
+import (
+	"context"
+	"fmt"
+	"io"
+	"io/fs"
+	"log"
+	"os"
+	"path/filepath"
+	"strconv"
+	"strings"
+	"sync"
+
+	"github.com/fsnotify/fsnotify"
+
+	"github.com/derfenix/photocatalog/v2/internal/metadata"
+)
+
+type MetaExtractor interface {
+	Extract(_ string, data io.Reader) (metadata.Metadata, error)
+}
+
+type Mode interface {
+	PlaceIt(sourcePath, targetPath string, mode os.FileMode) error
+}
+
+func NewOrganizer(mode Mode, source, target string) *Organizer {
+	return &Organizer{
+		mode:      mode,
+		sourceDir: source,
+		targetDir: target,
+
+		dirMode:  0777,
+		fileMode: 0644,
+
+		metaExtractors: map[string]MetaExtractor{
+			"":     &metadata.Default{},
+			"jpg":  metadata.Exif{},
+			"jpeg": metadata.Exif{},
+			"tiff": metadata.Exif{},
+		},
+	}
+}
+
+type Organizer struct {
+	mode Mode
+
+	sourceDir string
+	targetDir string
+
+	overwrite bool
+	dirMode   os.FileMode
+	fileMode  os.FileMode
+	errLogger func(error)
+
+	metaExtractors map[string]MetaExtractor
+}
+
+func (o *Organizer) WithOverwrite() *Organizer {
+	o.overwrite = true
+
+	return o
+}
+
+func (o *Organizer) WithDirMode(mode os.FileMode) *Organizer {
+	o.dirMode = mode
+
+	return o
+}
+
+func (o *Organizer) WithFileMode(mode os.FileMode) *Organizer {
+	o.fileMode = mode
+
+	return o
+}
+
+func (o *Organizer) WithErrLogger(f func(error)) *Organizer {
+	o.errLogger = f
+
+	return o
+}
+
+func (o *Organizer) logErr(err error) {
+	if o.errLogger != nil {
+		o.errLogger(err)
+	}
+}
+
+func (o *Organizer) Watch(ctx context.Context, wg *sync.WaitGroup) error {
+	watcher, err := fsnotify.NewWatcher()
+	if err != nil {
+		return fmt.Errorf("new watcher: %w", err)
+	}
+
+	if err := watcher.Add(o.sourceDir); err != nil {
+		return fmt.Errorf("add source dir to watcher: %w", err)
+	}
+
+	// Add all subfolders to the watcher.
+	err = filepath.WalkDir(o.sourceDir, func(path string, d fs.DirEntry, err error) error {
+		if path == o.sourceDir {
+			return nil
+		}
+
+		if d.IsDir() {
+			if err := watcher.Add(path); err != nil {
+				o.logErr(fmt.Errorf("add the directory %s to watcher: %w", path, err))
+			}
+		}
+
+		return nil
+	})
+	if err != nil {
+		return fmt.Errorf("add subdirs to watcher: %w", err)
+	}
+
+	wg.Add(2)
+
+	go func() {
+		defer wg.Done()
+
+		<-ctx.Done()
+
+		if err := watcher.Close(); err != nil {
+			o.logErr(fmt.Errorf("close watcher: %w", err))
+		}
+	}()
+
+	go func() {
+		defer wg.Done()
+
+		for {
+			select {
+			case event := <-watcher.Events:
+				if event.Op == fsnotify.Write {
+					stat, err := os.Stat(event.Name)
+					if err != nil {
+						o.logErr(fmt.Errorf("stat %s: %w", event.Name, err))
+
+						continue
+					}
+
+					// Add new directories to the watcher.
+					if stat.IsDir() {
+						if err := watcher.Add(event.Name); err != nil {
+							o.logErr(fmt.Errorf("watch dir: %w", err))
+						}
+
+						continue
+					}
+
+					if err := o.processFile(event.Name); err != nil {
+						o.logErr(fmt.Errorf("process file %s: %w", event.Name, err))
+					}
+				}
+
+			case <-ctx.Done():
+				return
+			}
+		}
+	}()
+
+	return nil
+}
+
+func (o *Organizer) FullSync(ctx context.Context) error {
+	err := filepath.WalkDir(o.sourceDir, func(path string, info fs.DirEntry, err error) error {
+		if ctx.Err() != nil {
+			return ctx.Err()
+		}
+
+		if info.IsDir() {
+			return nil
+		}
+
+		if err := o.processFile(path); err != nil {
+			return err
+		}
+
+		return nil
+	})
+	if err != nil {
+		return fmt.Errorf("walking source dir: %w", err)
+	}
+
+	return nil
+}
+
+func (o *Organizer) getMetaForPath(fp string) (metadata.Metadata, error) {
+	file, err := os.OpenFile(fp, os.O_RDONLY, os.ModePerm)
+	if err != nil {
+		return metadata.Metadata{}, fmt.Errorf("open file: %w", err)
+	}
+	defer func() {
+		_ = file.Close()
+	}()
+
+	meta, err := o.getMetadata(fp, file)
+	if err != nil {
+		return metadata.Metadata{}, fmt.Errorf("get metadata: %w", err)
+	}
+
+	return meta, nil
+}
+
+func (o *Organizer) getMetadata(fp string, data io.Reader) (metadata.Metadata, error) {
+	ext := strings.ToLower(filepath.Ext(fp))
+
+	if strings.HasPrefix(ext, ".") {
+		ext = ext[1:]
+	}
+
+	extractor, ok := o.metaExtractors[ext]
+	if !ok {
+		extractor = o.metaExtractors[""]
+	}
+
+	meta, err := extractor.Extract(fp, data)
+	if err != nil || meta.Created.IsZero() {
+		// Fallback to default extractor.
+		extractor = o.metaExtractors[""]
+
+		meta, err = extractor.Extract(fp, data)
+		if err != nil {
+			return metadata.Metadata{}, fmt.Errorf("extract metadata: %w", err)
+		}
+	}
+
+	return meta, nil
+}
+
+func (o *Organizer) processFile(sourcePath string) error {
+	meta, err := o.getMetaForPath(sourcePath)
+	if err != nil {
+		return err
+	}
+
+	targetPath, err := o.BuildTargetPath(sourcePath, meta)
+	if err != nil {
+		return fmt.Errorf("build target path: %w", err)
+	}
+
+	if pathExists(targetPath) && !o.overwrite {
+		return nil
+	}
+
+	if err := o.ensureTargetPath(filepath.Dir(targetPath)); err != nil {
+		return fmt.Errorf("ensure target path: %w", err)
+	}
+
+	if err := o.mode.PlaceIt(sourcePath, targetPath, o.fileMode); err != nil {
+		return fmt.Errorf("place file to new path: %w", err)
+	}
+
+	log.Printf("File %s placed at %s", sourcePath, targetPath)
+
+	return nil
+}
+
+func (o *Organizer) BuildTargetPath(sourcePath string, meta metadata.Metadata) (string, error) {
+	sourcePath, err := filepath.Rel(o.sourceDir, sourcePath)
+	if err != nil {
+		return "", fmt.Errorf("get a relative path: %w", err)
+	}
+
+	target := filepath.Join(
+		o.targetDir,
+		strconv.Itoa(meta.Created.Year()),
+		strconv.Itoa(int(meta.Created.Month())),
+		strconv.Itoa(meta.Created.Day()),
+		sourcePath,
+	)
+
+	return target, nil
+}
+
+func (o *Organizer) ensureTargetPath(targetPath string) error {
+	if pathExists(targetPath) {
+		return nil
+	}
+
+	relPath, err := filepath.Rel(o.targetDir, targetPath)
+	if err != nil {
+		return fmt.Errorf("get a relative path: %w", err)
+	}
+
+	dir := o.targetDir
+
+	for _, part := range strings.Split(relPath, string(filepath.Separator)) {
+		dir = filepath.Join(dir, part)
+
+		if err := os.Mkdir(dir, o.dirMode); err != nil && !os.IsExist(err) {
+			return fmt.Errorf("create target directory path at %s: %w", dir, err)
+		}
+	}
+
+	return nil
+}
+
+func pathExists(path string) bool {
+	_, err := os.Stat(path)
+	if err != nil {
+		if os.IsNotExist(err) {
+			return false
+		}
+
+		return true
+	}
+
+	return true
+}

internal/organizer/organizer_test.go

@@ -0,0 +1,152 @@
+package organizer
+
+import (
+	"bytes"
+	"context"
+	"fmt"
+	"io/fs"
+	"os"
+	"path/filepath"
+	"sync"
+	"testing"
+	"time"
+
+	"github.com/derfenix/photocatalog/v2/internal/metadata"
+	"github.com/derfenix/photocatalog/v2/internal/organizer/modes"
+)
+
+func TestOrganizer_FullSync(t *testing.T) {
+	t.Parallel()
+
+	source := "./testdata/fullsync/source"
+	target := "./testdata/fullsync/target"
+
+	t.Cleanup(func() {
+		if err := os.RemoveAll(target); err != nil {
+			t.Fatal(err)
+		}
+	})
+
+	if err := os.Mkdir(target, 0777); err != nil {
+		t.Fatalf("create target dir %s failed: %v", target, err)
+	}
+
+	ctx := context.Background()
+
+	org := NewOrganizer(modes.HardLink{}, source, target)
+	if err := org.FullSync(ctx); err != nil {
+		t.Fatalf("full sync failed: %v", err)
+	}
+
+	err := filepath.WalkDir(source, func(path string, d fs.DirEntry, err error) error {
+		if d.IsDir() {
+			return nil
+		}
+
+		sourceFile, err := os.ReadFile(path)
+		if err != nil {
+			return fmt.Errorf("read source file %s: %v", path, err)
+		}
+
+		meta, err := (&metadata.Default{}).Extract(path, nil)
+		if err != nil {
+			return fmt.Errorf("extract metadata from %s: %v", path, err)
+		}
+
+		targetPath, err := org.BuildTargetPath(path, meta)
+		if err != nil {
+			return fmt.Errorf("build target file %s: %v", path, err)
+		}
+
+		targetFile, err := os.ReadFile(targetPath)
+		if err != nil {
+			return fmt.Errorf("read target file %s: %v", targetPath, err)
+		}
+
+		if !bytes.Equal(sourceFile, targetFile) {
+			return fmt.Errorf("target file content missmatch")
+		}
+
+		return nil
+	})
+	if err != nil {
+		t.Fatalf("walk dir failed: %v", err)
+	}
+}
+
+func TestOrganizer_Watch(t *testing.T) {
+	t.Parallel()
+
+	source := "./testdata/watcher/source"
+	target := "./testdata/watcher/target"
+
+	t.Cleanup(func() {
+		if err := os.RemoveAll(target); err != nil {
+			t.Fatal(err)
+		}
+	})
+
+	if err := os.Mkdir(target, 0777); err != nil {
+		t.Fatalf("create target dir %s failed: %v", target, err)
+	}
+
+	ctx, cancel := context.WithCancel(context.Background())
+
+	t.Cleanup(cancel)
+
+	wg := sync.WaitGroup{}
+
+	org := NewOrganizer(&modes.HardLink{}, source, target)
+	if err := org.Watch(ctx, &wg); err != nil {
+		t.Fatalf("watch failed: %v", err)
+	}
+
+	nonEmpty, err := checkEmpty(t, target)
+	if err != nil {
+		t.Fatalf("check empty failed: %v", err)
+	}
+
+	if nonEmpty {
+		t.Fatal("target dir should not be empty")
+	}
+
+	err = os.WriteFile(filepath.Join(source, "20241108_160834.txt"), []byte("test"), 0777)
+	if err != nil {
+		t.Fatalf("file write failed: %v", err)
+	}
+
+	time.Sleep(time.Millisecond)
+
+	nonEmpty, err = checkEmpty(t, target)
+	if err != nil {
+		t.Fatalf("check empty failed: %v", err)
+	}
+
+	if !nonEmpty {
+		t.Fatal("target dir should not be empty")
+	}
+
+	cancel()
+
+	wg.Wait()
+}
+
+func checkEmpty(t *testing.T, target string) (bool, error) {
+	t.Helper()
+
+	var nonEmpty bool
+	err := filepath.WalkDir(target, func(path string, d fs.DirEntry, err error) error {
+		if path == target {
+			return nil
+		}
+
+		nonEmpty = true
+
+		return nil
+	})
+	if err != nil {
+		t.Fatalf("walk dir failed: %v", err)
+	}
+
+	return nonEmpty, err
+}

internal/organizer/testdata/fullsync/source/20241108_160834.txt

@@ -0,0 +1,17 @@
+Lorem ipsum dolor sit amet, consectetur adipiscing elit. Elit culpa hendrerit assum aliquam placerat cupiditat placerat excepteur doming ad incidunt magna eirmod, delenit nam at aliquip iure cupiditat qui congue consectetuer placerat mollit enim fugiat consequat aliquip delenit nam feugait vero aliquyam vel vel. Euismod adipiscing anim officia nibh molestie amet pariatur. Te te nulla pariatur ut option doming excepteur gubergren justo dolore sadipscing tempor stet. Tation nonummy nam nulla sint odio at sint feugait cum esse. Lorem adipiscing excepteur praesent nisi facilisis, clita invidunt molestie vulputate in tempor vulputate eiusmod tincidunt nobis. Iusto iure exerci.
+
+Gubergren nobis ut illum dignissim at aliquam feugiat tation velit illum consequat hendrerit. Feugait facilisis nibh odio sint at adipiscing at nibh incidunt quod cupiditat ullamcorper dolore ex aute ullamco commodi rebum rebum sunt ea enim fugiat facilisi exercitation feugait eos blandit nihil molestie et facilisi aute incidunt nisl illum. Assum consequat assum at et voluptate nobis sed nobis sunt id eros consectetuer, culpa tation deserunt praesent aliquam erat stet zzril voluptate nibh, et fugiat commodi quod tation stet sadipscing lobortis officia quod ex imperdiet doming. Excepteur augue nobis.
+
+Sanctus possim feugiat nostrud amet illum eros, eu ipsum dignissim ea tincidunt tincidunt accusam delenit placerat vel facilisi volutpat amet. Wisi dolore zzril pariatur odio cum incidunt esse duo liber aliquam voluptate eos autem est. Congue kasd vero hendrerit adipiscing rebum elitr, laboris mollit takimata nonummy id esse commodo excepteur non possim quis zzril. Consectetuer accumsan volutpat.
+
+Eum nibh zzril vulputate consectetur mazim voluptate commodo sea augue tempor. Fugiat voluptua tempor nonumy. Congue eirmod voluptua nulla. Nonumy consectetuer voluptate.
+
+Consequat eum tempor stet cupiditat quis in nobis. Veniam lorem sit veniam eu amet option no molestie dolores option cum reprehenderit assum tempor. Gubergren dolore wisi ut voluptua amet eum incidunt commodi eos justo quis lorem aliquyam velit praesent ullamco tempor anim volutpat velit velit aliquam cum facilisis iusto erat veniam option. Rebum nobis ea excepteur ex sea consequat blandit, excepteur et qui mazim lorem eos augue duo nulla deserunt ullamco sadipscing sed. Eos takimata justo incidunt sea vulputate blandit tempor aliqua reprehenderit aliquid sit aliqua takimata. Ullamco takimata elitr dolore ipsum takimata. Consequat aute aliquid.
+
+Placerat sunt ut delenit aliquid enim hendrerit. Vel rebum et ad dolor luptatum veniam, volutpat soluta euismod facilisis lobortis placerat eos dignissim excepteur reprehenderit facer autem nobis officia facilisis, quis duo augue dolor autem placerat obcaecat ipsum volutpat pariatur. Ullamco elitr exerci at ad nostrud. Suscipit eu dolores sint molestie proident eleifend aute sadipscing anim. Iusto aliquid aliquam.
+
+Iriure elitr sit nihil sanctus soluta autem et, nisi dolores erat option blandit soluta aliquip nihil placerat cum clita diam duis sunt sunt tation vel consequat deserunt doming gubergren euismod liber ad esse augue aliquyam ad facilisis. Anim dignissim fugiat. Aliquam dolores, obcaecat aliquam nobis quod euismod consectetur iusto wisi aute mollit eirmod eirmod nonumy, qui officia in eros hendrerit nonummy soluta option aliquip. Feugait laboris duis accumsan proident velit stet invidunt kasd consetetur nobis fugiat invidunt cupiditat et excepteur nonumy feugait iusto consectetur eos cillum. Eos at commodo facilisi. Facer facilisi exercitation.
+
+Soluta takimata labore sunt erat cum option eu deserunt eu consectetur, soluta option cum euismod aliquid illum commodo obcaecat aliquyam erat eleifend blandit, mazim exercitation consequat duis vel imperdiet consetetur ullamco doming. In elit duis. Duo praesent lorem.
+
+Commodi molestie reprehenderit ipsum enim, zzril vulputate in laboris voluptua nibh suscipit, autem facilisi invidunt commodi iusto mollit aliquip nam culpa consetetur dolore elitr, fugiat luptatum nisl amet elitr facilisis te quod ad kasd wisi reprehenderit invidunt. Facer ut quis nam dignissim. Option suscipit duis dolor consequat takimata te amet accumsan obcaecat autem congue ad obcaecat velit. Imperdiet id laborum sea. Hendrerit nisi eros.

internal/organizer/testdata/watcher/source/20241108_160834.txt

@@ -0,0 +1 @@
+test

main.go

@@ -0,0 +1,76 @@
+package main
+
+import (
+	"context"
+	"flag"
+	"log"
+	"os/signal"
+	"strconv"
+	"sync"
+	"syscall"
+
+	"github.com/derfenix/photocatalog/v2/application"
+)
+
+func main() {
+	cfg := loadCfg()
+
+	ctx, cancel := signal.NotifyContext(context.Background(), syscall.SIGINT, syscall.SIGTERM)
+	defer cancel()
+
+	app, err := application.NewApplication(cfg)
+	if err != nil {
+		log.Fatal(err)
+	}
+
+	wg := &sync.WaitGroup{}
+
+	if err := app.Start(ctx, wg); err != nil {
+		log.Fatal(err)
+	}
+
+	wg.Wait()
+}
+
+func loadCfg() application.Config {
+	cfg := application.Config{
+		SourceDir: "",
+		TargetDir: "",
+		Mode:      "",
+		Overwrite: false,
+		DirMode:   0,
+		FileMode:  0,
+		Watch:     false,
+	}
+
+	flag.StringVar(&cfg.SourceDir, "source", "", "Source directory")
+	flag.StringVar(&cfg.TargetDir, "target", "", "Target directory")
+	flag.BoolVar(&cfg.Overwrite, "overwrite", false, "Overwrite existing files")
+	flag.BoolVar(&cfg.Watch, "watch", false, "Watch for changes in the source directory")
+
+	var dirMode string
+	var fileMode string
+	flag.StringVar(&dirMode, "dirmode", "0777", "Mode bits for directories can be created while syncing")
+	flag.StringVar(&fileMode, "filemode", "0644", "Mode bits for files created while syncing (not applicable for hardlink mode)")
+
+	var mode string
+	flag.StringVar(&mode, "mode", "hardlink", "Mode")
+
+	flag.Parse()
+
+	cfg.Mode = application.Mode(mode)
+
+	var err error
+
+	cfg.DirMode, err = strconv.ParseUint(dirMode, 8, 32)
+	if err != nil {
+		cfg.DirMode = 0o777
+	}
+
+	cfg.FileMode, err = strconv.ParseUint(fileMode, 8, 32)
+	if err != nil {
+		cfg.DirMode = 0o644
+	}
+
+	return cfg
+}

pkg/manager/managemode.go

@@ -1,10 +0,0 @@
-package manager
-
-//go:generate stringer -type ManageMode
-
-type ManageMode uint8
-
-const (
-	Copy ManageMode = iota
-	Hardlink
-)

pkg/manager/managemode_string.go

@@ -1,24 +0,0 @@
-// Code generated by "stringer -type ManageMode"; DO NOT EDIT.
-
-package manager
-
-import "strconv"
-
-func _() {
-	// An "invalid array index" compiler error signifies that the constant values have changed.
-	// Re-run the stringer command to generate them again.
-	var x [1]struct{}
-	_ = x[Copy-0]
-	_ = x[Hardlink-1]
-}
-
-const _ManageMode_name = "CopyHardlink"
-
-var _ManageMode_index = [...]uint8{0, 4, 12}
-
-func (i ManageMode) String() string {
-	if i >= ManageMode(len(_ManageMode_index)-1) {
-		return "ManageMode(" + strconv.FormatInt(int64(i), 10) + ")"
-	}
-	return _ManageMode_name[_ManageMode_index[i]:_ManageMode_index[i+1]]
-}

pkg/manager/manager.go

@@ -1,144 +0,0 @@
-package manager
-
-import (
-	"fmt"
-	"log"
-	"os"
-	"os/exec"
-	"path"
-	"strings"
-	"time"
-
-	"github.com/pkg/errors"
-
-	"github.com/derfenix/photocatalog/pkg/metadata"
-)
-
-type Manager struct {
-	TargetPath  string
-	Mode        ManageMode
-	updateMtime bool
-
-	processor       func(fp, targetDir string) (string, error)
-	extractorsCache map[string]metadata.Extractor
-}
-
-func NewManager(target string, mode ManageMode, updateMtime bool) (*Manager, error) {
-	manager := Manager{
-		TargetPath:  target,
-		Mode:        mode,
-		processor:   nil,
-		updateMtime: updateMtime,
-	}
-	if err := manager.initProcessor(); err != nil {
-		return nil, err
-	}
-	manager.extractorsCache = map[string]metadata.Extractor{}
-	return &manager, nil
-}
-
-func (m *Manager) buildTarget(meta *metadata.Metadata) (string, error) {
-	dir, err := m.dirPathFromMeta(meta)
-	if err != nil {
-		return "", err
-	}
-	dirPath := path.Join(m.TargetPath, dir)
-	err = os.MkdirAll(dirPath, os.FileMode(0770))
-	if err != nil {
-		return "", err
-	}
-	return dirPath, nil
-}
-
-func (m *Manager) dirPathFromMeta(meta *metadata.Metadata) (string, error) {
-	t := meta.Time
-	year := t.Format("2006")
-	month := t.Format("01")
-	day := t.Format("02")
-	return path.Join(year, month, day), nil
-}
-
-func (m *Manager) getMetadataExtractor(fp string) metadata.Extractor {
-	switch strings.ToLower(path.Ext(fp)) {
-	case ".jpeg", ".jpg":
-		if _, ok := m.extractorsCache["jpeg"]; !ok {
-			m.extractorsCache["jpeg"] = metadata.NewJpegExtractor()
-		}
-		return m.extractorsCache["jpeg"]
-	default:
-		if _, ok := m.extractorsCache["default"]; !ok {
-			m.extractorsCache["default"] = metadata.NewDefaultExtractor()
-		}
-		return m.extractorsCache["default"]
-	}
-}
-
-func (m *Manager) initProcessor() error {
-	switch m.Mode {
-	case Copy:
-		m.processor = func(fp, targetDir string) (string, error) {
-			_, fn := path.Split(fp)
-			target := path.Join(targetDir, fn)
-			cmd := exec.Command("cp", "-f", "--reflink=auto", fp, target)
-			return target, cmd.Run()
-		}
-	case Hardlink:
-		m.processor = func(fp, targetDir string) (string, error) {
-			_, fn := path.Split(fp)
-			target := path.Join(targetDir, fn)
-			cmd := exec.Command("ln", "-f", fp, target)
-			return target, cmd.Run()
-		}
-	default:
-		return fmt.Errorf("failed to init processor: invalid Mode value")
-	}
-	return nil
-}
-
-func (m *Manager) Manage(fp string) error {
-	if m.processor == nil {
-		return fmt.Errorf("no processor initialized")
-	}
-	// Skip hidden files
-	if strings.HasPrefix(path.Base(fp), ".") {
-		return nil
-	}
-
-	log.Println("processing", fp)
-
-	extractor := m.getMetadataExtractor(fp)
-	if extractor == nil {
-		return fmt.Errorf("failed to get md extractor for %s", fp)
-	}
-
-	md, err := extractor.Extract(fp)
-	if err != nil {
-		return errors.WithMessagef(err, "failed to extract md from %s", fp)
-	}
-
-	targetDir, err := m.buildTarget(&md)
-	if err != nil {
-		return errors.WithMessagef(err, "failed to create dir for %s", fp)
-	}
-
-	target, err := m.processor(fp, targetDir)
-	if err != nil {
-		return errors.WithMessagef(err, "failed to process %s to %s", fp, targetDir)
-	}
-
-	if m.updateMtime {
-		err = os.Chtimes(target, time.Now(), md.Time)
-		if err != nil {
-			return errors.WithMessage(err, "failed to update mtime/atime")
-		}
-	}
-
-	if m.Mode == Hardlink {
-		log.Println(fp, "linked to", target)
-	} else if m.Mode == Copy {
-		log.Println(fp, "copied to", target)
-	}
-
-	log.Println("success")
-	return nil
-}

pkg/metadata/base.go

@@ -1,15 +0,0 @@
-package metadata
-
-import (
-	"time"
-)
-
-// Metadata contains meta data for the files have to be processed
-type Metadata struct {
-	Time time.Time
-}
-
-// Extractor interface for Metadata extractors
-type Extractor interface {
-	Extract(string) (Metadata, error)
-}

pkg/metadata/default.go

@@ -1,45 +0,0 @@
-package metadata
-
-import (
-	"path"
-	"strings"
-	"time"
-)
-
-const defaultTimeLayout = "20060102_150405"
-
-// DefaultExtractor extract metadata from all file types, not covered by special extractors
-//
-// Gets the meta data from the file's name
-type DefaultExtractor struct {
-	Layout string
-}
-
-// NewDefaultExtractor returns new DefaultExtractor's instance
-func NewDefaultExtractor() *DefaultExtractor {
-	return &DefaultExtractor{Layout: defaultTimeLayout}
-}
-
-// NewDefaultExtractorWithLayout returns DefaultExtractor with custom time layout
-func NewDefaultExtractorWithLayout(l string) *DefaultExtractor {
-	return &DefaultExtractor{Layout: l}
-}
-
-// Extract returns Metadata from specified filename using its name to parse Time
-func (d *DefaultExtractor) Extract(fp string) (Metadata, error) {
-	_, fName := path.Split(fp)
-
-	// Remove extension
-	fName = strings.Replace(fName, path.Ext(fName), "", 1)
-
-	// If there more than one photo in one second, cameras append ~N to the end of file name (before extension)
-	if strings.ContainsRune(fName, '~') {
-		fName = fName[:strings.IndexRune(fName, '~')]
-	}
-
-	t, err := time.ParseInLocation(d.Layout, fName, time.Local)
-	if err != nil {
-		return Metadata{}, err
-	}
-	return Metadata{Time: t}, nil
-}

pkg/metadata/default_test.go

@@ -1,70 +0,0 @@
-package metadata
-
-import (
-	"reflect"
-	"testing"
-	"time"
-)
-
-func TestDefaultExtractor_Extract(t *testing.T) {
-	local, err := time.LoadLocation("Europe/Moscow")
-	if err != nil {
-		t.Fatal(err)
-	}
-	time.Local = local
-
-	type args struct {
-		fp string
-	}
-	tests := []struct {
-		name    string
-		args    args
-		want    Metadata
-		wantErr bool
-	}{
-		{
-			name: "Normal",
-			args: args{"20190321_120325.jpg"},
-			want: Metadata{
-				Time: func() time.Time {
-					tm, err := time.Parse(time.RFC3339, "2019-03-21T12:03:25+03:00")
-					if err != nil {
-						t.Fatal(err)
-					}
-					return tm
-				}(),
-			},
-			wantErr: false,
-		},
-		{
-			name: "Name with tilda",
-			args: args{"20190321_120325~2.jpg"},
-			want: Metadata{
-				Time: func() time.Time {
-					tm, err := time.Parse(time.RFC3339, "2019-03-21T12:03:25+03:00")
-					if err != nil {
-						t.Fatal(err)
-					}
-					return tm
-				}(),
-			},
-			wantErr: false,
-		},
-	}
-	for _, tt := range tests {
-		t.Run(tt.name, func(t *testing.T) {
-			d := NewDefaultExtractor()
-			if err != nil {
-				t.Fatal(err)
-			}
-			got, err := d.Extract(tt.args.fp)
-			if (err != nil) != tt.wantErr {
-				t.Errorf("Extract() error = %v, wantErr %v", err, tt.wantErr)
-				return
-			}
-			if !reflect.DeepEqual(got, tt.want) {
-				t.Errorf("Extract() got = %v, want %v", got, tt.want)
-			}
-		})
-	}
-}

pkg/metadata/jpeg.go

@@ -1,40 +0,0 @@
-package metadata
-
-import (
-	"os"
-
-	"github.com/rwcarlsen/goexif/exif"
-)
-
-// JpegExtractor meta data extractor for the jpeg files
-type JpegExtractor struct {
-}
-
-// NewJpegExtractor returns new JpegExtractor
-func NewJpegExtractor() *JpegExtractor {
-	return &JpegExtractor{}
-}
-
-// Extract returns Metadata from specified jpeg file reading its exif data
-//
-// TODO: Fallback to default extractor on exif reading/parsing error
-func (j *JpegExtractor) Extract(fp string) (Metadata, error) {
-	f, err := os.Open(fp)
-	if err != nil {
-		return Metadata{}, err
-	}
-	x, err := exif.Decode(f)
-	if err != nil {
-		return Metadata{}, err
-	}
-
-	time, err := x.DateTime()
-	if err != nil {
-		return Metadata{}, err
-	}
-	meta := Metadata{
-		Time: time,
-	}
-
-	return meta, nil
-}