Add C_ prefix to command

By now we have quite a few phew...

deploy.sh

@@ -0,0 +1 @@
+go install .

go.mod

@@ -1,14 +1,18 @@
-module datesorter
+module dategrouper
 
-go 1.23.3
+go 1.23.6
 
-require git.site.quack-lab.dev/dave/cylogger v1.4.0
+require (
+	git.site.quack-lab.dev/dave/cylogger v1.4.0
+	git.site.quack-lab.dev/dave/cyutils v1.4.0
+)
 
 require (
 	github.com/google/go-cmp v0.5.9 // indirect
 	github.com/hexops/valast v1.5.0 // indirect
 	golang.org/x/mod v0.7.0 // indirect
 	golang.org/x/sys v0.3.0 // indirect
+	golang.org/x/time v0.12.0 // indirect
 	golang.org/x/tools v0.4.0 // indirect
 	mvdan.cc/gofumpt v0.4.0 // indirect
 )

go.sum

@@ -1,5 +1,7 @@
 git.site.quack-lab.dev/dave/cylogger v1.4.0 h1:3Ca7V5JWvruARJd5S8xDFwW9LnZ9QInqkYLRdrEFvuY=
 git.site.quack-lab.dev/dave/cylogger v1.4.0/go.mod h1:wctgZplMvroA4X6p8f4B/LaCKtiBcT1Pp+L14kcS8jk=
+git.site.quack-lab.dev/dave/cyutils v1.4.0 h1:/Xo3QfLIFNab+axHneWmUK4MyfuObl+qq8whF9vTQpk=
+git.site.quack-lab.dev/dave/cyutils v1.4.0/go.mod h1:fBjALu2Cp2u2bDr+E4zbGVMBeIgFzROg+4TCcTNAiQU=
 github.com/frankban/quicktest v1.14.3 h1:FJKSZTDHjyhriyC81FLQ0LY93eSai0ZyR/ZIkd3ZUKE=
 github.com/frankban/quicktest v1.14.3/go.mod h1:mgiwOwqx65TmIk1wJ6Q7wvnVMocbUorkibMOrVTHZps=
 github.com/google/go-cmp v0.5.9 h1:O2Tfq5qg4qc4AmwVlvv0oLiVAGB7enBSJ2x2DqQFi38=
@@ -22,6 +24,8 @@ golang.org/x/sync v0.1.0 h1:wsuoTGHzEhffawBOhz5CYhcrV4IdKZbEyZjBMuTp12o=
 golang.org/x/sync v0.1.0/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
 golang.org/x/sys v0.3.0 h1:w8ZOecv6NaNa/zC8944JTU3vz4u6Lagfk4RPQxv92NQ=
 golang.org/x/sys v0.3.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
+golang.org/x/time v0.12.0 h1:ScB/8o8olJvc+CQPWrK3fPZNfh7qgwCrY0zJmoEQLSE=
+golang.org/x/time v0.12.0/go.mod h1:CDIdPxbZBQxdj6cxyCIdrNogrJKMJ7pr37NYpMcMDSg=
 golang.org/x/tools v0.4.0 h1:7mTAgkunk3fr4GAloyyCasadO6h9zSsQZbwvcaIciV4=
 golang.org/x/tools v0.4.0/go.mod h1:UE5sM2OK9E/d67R0ANs2xJizIymRP5gJU295PvKXxjQ=
 mvdan.cc/gofumpt v0.4.0 h1:JVf4NN1mIpHogBj7ABpgOyZc65/UUOkKQFkoURsz4MM=

install_context_menu.reg

@@ -0,0 +1,7 @@
+Windows Registry Editor Version 5.00
+
+[HKEY_CURRENT_USER\Software\Classes\AllFileSystemObjects\shell\C_Group by date]
+@="Group by date"
+
+[HKEY_CURRENT_USER\Software\Classes\AllFileSystemObjects\shell\C_Group by date\command]
+@="C:\\Users\\administrator\\go\\bin\\dategrouper.exe \"%1\""

main.go

@@ -3,12 +3,14 @@ package main
 import (
 	"flag"
 	"fmt"
+	"io"
 	"os"
 	"path/filepath"
 	"regexp"
 	"time"
 
 	logger "git.site.quack-lab.dev/dave/cylogger"
+	"git.site.quack-lab.dev/dave/cyutils"
 )
 
 type DateParser interface {
@@ -42,6 +44,7 @@ func (dp *DateParserISO) Parse(s string) (time.Time, error) {
 func main() {
 	flag.Parse()
 	logger.InitFlag()
+	// logger.Default = logger.Default.ToFile("dategrouper.log")
 
 	if flag.NArg() == 0 {
 		logger.Error("no files provided")
@@ -55,42 +58,65 @@ func main() {
 
 	files := flag.Args()
 
-	for _, file := range files {
-		filelog := logger.Default.WithPrefix(fmt.Sprintf("file=%q", file))
+	cyutils.WithWorkers(10, files, func(worker int, _ int, file string) {
+		workerlog := logger.Default.WithPrefix(fmt.Sprintf("worker=%d", worker))
+		filelog := workerlog.WithPrefix(fmt.Sprintf("file=%q", file))
 		filelog.Info("processing file")
 		date, err := parseDate(file, parsers)
 		if err != nil {
 			filelog.Error("error parsing date: %s", err)
-			continue
+			return
 		}
 		filelog.Info("date: %s", date)
-		
-		datedir := fmt.Sprintf("%04d-%02d-%02d", date.Year(), date.Month(), date.Day())
-		dest := filepath.Join(datedir, file)
+
+		dir := filepath.Dir(file)
+		datedir := filepath.Join(dir, fmt.Sprintf("%04d-%02d-%02d", date.Year(), date.Month(), date.Day()))
+		dest := filepath.Join(datedir, filepath.Base(file))
 		filelog.Info("dest: %s", dest)
 		err = os.MkdirAll(datedir, 0755)
 		if err != nil {
 			filelog.Error("error creating directory: %s", err)
-			continue
+			return
 		}
-		// Make sure file doesn't exist
 		destfile, err := os.Stat(dest)
 		if err == nil {
 			filelog.Info("dest file already exists: %s", destfile.Name())
-			continue
-		} else {
-			if !os.IsNotExist(err) {
-				filelog.Error("error checking dest file: %s", err)
-				continue
-			}
+			return
+		} else if !os.IsNotExist(err) {
+			filelog.Error("error checking dest file: %s", err)
+			return
 		}
-		err = os.Rename(file, dest)
+
+		filelog.Debug("opening input file")
+		in, err := os.Open(file)
 		if err != nil {
-			filelog.Error("error renaming file: %s", err)
-			continue
+			filelog.Error("error opening file: %s", err)
+			return
+		}
+		filelog.Debug("opening output file %s", dest)
+		out, err := os.Create(dest)
+		if err != nil {
+			filelog.Error("error creating dest file: %s", err)
+			in.Close()
+			return
+		}
+		filelog.Info("copying file")
+		_, err = io.Copy(out, in)
+		in.Close()
+		out.Close()
+		if err != nil {
+			filelog.Error("error copying file: %s", err)
+			return
+		}
+
+		filelog.Info("removing original file")
+		err = os.Remove(file)
+		if err != nil {
+			filelog.Error("error removing original file: %s", err)
+			return
 		}
 		filelog.Info("moved to %q", dest)
-	}
+	})
 }
 
 func parseDate(file string, parsers []DateParser) (time.Time, error) {

uninstall_context_menu.reg

@@ -0,0 +1,4 @@
+Windows Registry Editor Version 5.00
+
+[-HKEY_CURRENT_USER\Software\Classes\AllFileSystemObjects\shell\C_Group by date]
+[-HKEY_CURRENT_USER\Software\Classes\AllFileSystemObjects\shell\C_Group by date\command]