refactor

1 files changed, 13 insertions, 8 deletions

diff --git a/internal/queue/queue.go b/internal/queue/queue.go
index e14ff90..94ea1e0 100644
--- a/internal/queue/queue.go
+++ b/internal/queue/queue.go
@@ -29,9 +29,10 @@ func queueEntries(args config.Args) error {
 	// Strictly, we only operate on .txt files, but we also accept .md as Obsidian creates only .md files.
 	var validExtensions = []string{".txt", ".md"}
 
-	ch, err := oi.ReadDirFilter(args.GosDir, func(entry os.DirEntry) bool {
-		return slices.Contains(validExtensions, filepath.Ext(entry.Name())) &&
-			entry.Type().IsRegular()
+	ch, err := oi.ReadDirFilter(args.GosDir, func(file os.DirEntry) (string, bool) {
+		filePath := filepath.Join(args.GosDir, file.Name())
+		return filePath, slices.Contains(validExtensions, filepath.Ext(file.Name())) &&
+			file.Type().IsRegular()
 	})
 	if err != err {
 		return err
@@ -52,9 +53,10 @@ func queueEntries(args config.Args) error {
 // Queue all ./db/queued/*.txt.STAMP.queued into ./db/platforms/PLATFORM/*.txt.STAMP.queued
 // for each PLATFORM
 func queuePlatforms(args config.Args) error {
-	dbDir := fmt.Sprintf("%s/db", args.GosDir)
-	ch, err := oi.ReadDirFilter(dbDir, func(entry os.DirEntry) bool {
-		return strings.HasSuffix(entry.Name(), ".queued")
+	dbDir := filepath.Join(args.GosDir, "db")
+	ch, err := oi.ReadDirFilter(dbDir, func(file os.DirEntry) (string, bool) {
+		filePath := filepath.Join(dbDir, file.Name())
+		return filePath, strings.HasSuffix(file.Name(), ".queued")
 	})
 	if err != err {
 		return err
@@ -70,6 +72,7 @@ func queuePlatforms(args config.Args) error {
 		if err := os.Remove(filePath); err != nil {
 			return err
 		}
+
 	}
 
 	return nil
@@ -77,8 +80,10 @@ func queuePlatforms(args config.Args) error {
 
 // Queue ./db/queued/*.txt.STAMP.queued to ./db/platforms/PLATFORM/*.txt.STAMP.queued
 func queuePlatform(entryPath, gosDir, platform string) error {
-	destDir := fmt.Sprintf("%s/db/platforms/%s/", gosDir, strings.ToLower(platform))
-	destPath := fmt.Sprintf("%s/%s", destDir, filepath.Base(entryPath))
+	destDir := filepath.Join(gosDir, "db/platform", strings.ToLower(platform))
+	// destDir := fmt.Sprintf("%s/db/platforms/%s/", gosDir, strings.ToLower(platform))
+	destPath := filepath.Join(destDir, filepath.Base(entryPath))
+	// destPath := fmt.Sprintf("%s/%s", destDir, filepath.Base(entryPath))
 	postedFile := fmt.Sprintf("%s.posted", strings.TrimSuffix(destPath, ".queued"))
 
 	// Entry already posted platform?