Merge pull request #583 from oceanplexian/feat/flac-cue-splitting

Add split_flac toggle for Lidarr CUE+FLAC splitting

Author: davidnewhall

go.mod

@@ -81,3 +81,4 @@ require (
 	golift.io/udf v0.0.1 // indirect
 	google.golang.org/protobuf v1.36.11 // indirect
 )
+

pkg/unpackerr/handlers.go

@@ -16,6 +16,7 @@ import (
 // Extract holds data for files being extracted.
 type Extract struct {
 	Syncthing   bool
+	SplitFlac   bool
 	Retries     uint
 	Path        string
 	App         starr.App
@@ -122,15 +123,18 @@ func (u *Unpackerr) extractCompletedDownload(name string, now time.Time, item *E
 	item.Status = QUEUED
 	item.Updated = now
 	// This queues the extraction. Which may start right away.
+	archiveTypes := []string{".rar", ".r00", ".zip", ".7z", ".7z.001", ".gz", ".tgz", ".tar", ".tar.gz", ".bz2", ".tbz2"}
+	if item.SplitFlac {
+		archiveTypes = append(archiveTypes, ".cue")
+	}
+
 	queueSize, _ := u.Extract(&xtractr.Xtract{
 		Password:  u.getPasswordFromPath(item.Path),
 		Passwords: u.Passwords,
 		Name:      name,
 		Filter: xtractr.Filter{
-			Path: item.Path,
-			ExcludeSuffix: xtractr.AllExcept(
-				".rar", ".r00", ".zip", ".7z", ".7z.001", ".gz", ".tgz", ".tar", ".tar.gz", ".bz2", ".tbz2",
-			),
+			Path:          item.Path,
+			ExcludeSuffix: xtractr.AllExcept(archiveTypes...),
 		},
 		TempFolder: false,
 		DeleteOrig: false,

pkg/unpackerr/lidarr.go

@@ -11,6 +11,7 @@ import (
 // LidarrConfig represents the input data for a Lidarr server.
 type LidarrConfig struct {
 	StarrConfig
+	SplitFlac      bool          `json:"split_flac" toml:"split_flac" xml:"split_flac" yaml:"split_flac"`
 	Queue          *lidarr.Queue `json:"-" toml:"-" xml:"-" yaml:"-"`
 	*lidarr.Lidarr `json:"-" toml:"-" xml:"-" yaml:"-"`
 }
@@ -38,17 +39,19 @@ func (u *Unpackerr) validateLidarr() error {
 
 func (u *Unpackerr) logLidarr() {
 	if count := len(u.Lidarr); count == 1 {
-		u.Printf(" => Lidarr Config: 1 server: "+starrLogLine,
+		u.Printf(" => Lidarr Config: 1 server: "+starrLogLine+", split_flac:%v",
 			u.Lidarr[0].URL, u.Lidarr[0].APIKey != "", u.Lidarr[0].Timeout,
 			u.Lidarr[0].ValidSSL, u.Lidarr[0].Protocols, u.Lidarr[0].Syncthing,
-			u.Lidarr[0].DeleteOrig, u.Lidarr[0].DeleteDelay.Duration, u.Lidarr[0].Paths)
+			u.Lidarr[0].DeleteOrig, u.Lidarr[0].DeleteDelay.Duration, u.Lidarr[0].Paths,
+			u.Lidarr[0].SplitFlac)
 	} else {
 		u.Printf(" => Lidarr Config: %d servers", count)
 
 		for _, f := range u.Lidarr {
-			u.Printf(starrLogPfx+starrLogLine,
+			u.Printf(starrLogPfx+starrLogLine+", split_flac:%v",
 				f.URL, f.APIKey != "", f.Timeout, f.ValidSSL, f.Protocols,
-				f.Syncthing, f.DeleteOrig, f.DeleteDelay.Duration, f.Paths)
+				f.Syncthing, f.DeleteOrig, f.DeleteDelay.Duration, f.Paths,
+				f.SplitFlac)
 		}
 	}
 }
@@ -95,6 +98,7 @@ func (u *Unpackerr) checkLidarrQueue(now time.Time) {
 					DeleteOrig:  server.DeleteOrig,
 					DeleteDelay: server.DeleteDelay.Duration,
 					Syncthing:   server.Syncthing,
+					SplitFlac:   server.SplitFlac,
 					Path:        u.getDownloadPath(record.OutputPath, starr.Lidarr, record.Title, server.Paths),
 					IDs: map[string]any{
 						"title":      record.Title,