update for setting genre

Author: nullable-eth

README.md

@@ -16,12 +16,12 @@ Automatically sync TMDb movie keywords as Plex labels - A lightweight Go applica
 - ⚙️ **Environment Configuration**: Fully configurable via environment variables
 - 🔒 **Protocol Flexibility**: Supports both HTTP and HTTPS Plex connections
 - Allows you to have TMBDB keywords as labels in Plex:
-![1](https://github.com/user-attachments/assets/914c5d32-1a90-4378-be3c-38679bc6263c)
+![1](example/labels.png)
 - Create custom dynamic filters for multiple labels that will update automatically when new movies are labeled:
-![2](https://github.com/user-attachments/assets/23ab5d2c-9300-4560-a626-31ed836c583c)
+![2](example/dynamic_filter.png)
 - Filter on the fly by a label:
 
-![3](https://github.com/user-attachments/assets/886df494-83c5-4fff-862d-8f51152bd68c)
+![3](example/filter.png)
 
 ## 📋 Environment Variables
 
@@ -35,6 +35,34 @@ Automatically sync TMDb movie keywords as Plex labels - A lightweight Go applica
 | `PROCESS_TIMER` | Processing interval (e.g., `5m`, `1h`) | `5m` | No |
 | `LIBRARY_ID` | Plex library ID (auto-detected if not set) | - | No |
 | `PROCESS_ALL_MOVIE_LIBRARIES` | Process all movie libraries (set to `true` to enable) | `false` | No |
+| `UPDATE_FIELD` | Field to update: `labels` (default) or `genre` | `labels` | No |
+
+## 🆕 UPDATE_FIELD: Sync as Labels or Genres
+
+You can control whether TMDb keywords are synced as Plex **labels** (default) or **genres** by setting the `UPDATE_FIELD` environment variable:
+
+- `UPDATE_FIELD=labels` (default): Syncs keywords as Plex labels (original behavior)
+- `UPDATE_FIELD=genre`: Syncs keywords as Plex genres
+
+The chosen field will be **locked** after update to prevent Plex from overwriting it.
+
+### Example Usage
+
+```bash
+docker run -d --name labelarr \
+  -e PLEX_SERVER=localhost \
+  -e PLEX_PORT=32400 \
+  -e PLEX_TOKEN=your_plex_token_here \
+  -e TMDB_READ_ACCESS_TOKEN=your_tmdb_read_access_token \
+  -e UPDATE_FIELD=genre \
+  nullableeth/labelarr:latest
+```
+
+#### Example: Genres Updated and Locked in Plex
+
+![Plex genres updated and locked by Labelarr](example/genre.png)
+
+*Genres updated and locked by Labelarr using `UPDATE_FIELD=genre`. The lock icon indicates the field is protected from automatic changes by Plex.*
 
 ## 🔑 Getting API Keys
 
@@ -50,7 +78,7 @@ Automatically sync TMDb movie keywords as Plex labels - A lightweight Go applica
 
 1. Visit [TMDb API Settings](https://www.themoviedb.org/settings/api)
 2. Create account and generate API key
-3. Use the **Bearer Token** (not the API key)
+3. Use the Read Access Token (not the API key)
 
 ## 🐳 Docker Deployment
 

README_DOCKER.md

@@ -37,6 +37,7 @@ docker run -d --name labelarr \
 | `PROCESS_TIMER`           | How often to scan (e.g., `5m`)     | `5m`, `10m`, `1h`, etc.                                                    |
 | `LIBRARY_ID`              | Plex library ID (auto-detected if not set) | See Library Selection Logic below                                          |
 | `PROCESS_ALL_MOVIE_LIBRARIES` | Process all movie libraries (set to `true` to enable) | `false` |
+| `UPDATE_FIELD`              | Field to update: `labels` (default) or `genre` | `labels` | No |
 
 ## Docker Compose Example
 
@@ -151,6 +152,27 @@ The application provides detailed logging including:
 - **Issues**: Report bugs and feature requests
 - **Logs**: Check container logs for troubleshooting
 
+## 🆕 UPDATE_FIELD: Sync as Labels or Genres
+
+You can control whether TMDb keywords are synced as Plex **labels** (default) or **genres** by setting the `UPDATE_FIELD` environment variable:
+
+- `UPDATE_FIELD=labels` (default): Syncs keywords as Plex labels (original behavior)
+- `UPDATE_FIELD=genre`: Syncs keywords as Plex genres
+
+The chosen field will be **locked** after update to prevent Plex from overwriting it.
+
+### Example Usage
+
+```bash
+docker run -d --name labelarr \
+  -e PLEX_SERVER=localhost \
+  -e PLEX_PORT=32400 \
+  -e PLEX_TOKEN=your_plex_token_here \
+  -e TMDB_READ_ACCESS_TOKEN=your_tmdb_read_access_token \
+  -e UPDATE_FIELD=genre \
+  nullableeth/labelarr:latest
+```
+
 ---
 
 **Tags**: plex, tmdb, automation, movies, labels, docker, go, selfhosted

example/dynamic_filter.png

@@ -35,6 +35,7 @@ type Movie struct {
 	Title     string       `json:"title"`
 	Year      int          `json:"year"`
 	Label     []Label      `json:"Label,omitempty"`
+	Genre     []Genre      `json:"Genre,omitempty"`
 	Guid      FlexibleGuid `json:"Guid,omitempty"`
 	Media     []Media      `json:"Media,omitempty"`
 }
@@ -43,6 +44,10 @@ type Label struct {
 	Tag string `json:"tag"`
 }
 
+type Genre struct {
+	Tag string `json:"tag"`
+}
+
 type Guid struct {
 	ID string `json:"id"`
 }
@@ -205,18 +210,25 @@ func main() {
 	// Start the periodic processing
 	fmt.Println("\n🔄 Starting periodic movie processing...")
 
+	// Add UPDATE_FIELD env variable
+	updateField := getEnvWithDefault("UPDATE_FIELD", "labels")
+	if updateField != "labels" && updateField != "genre" {
+		fmt.Println("❌ UPDATE_FIELD must be 'labels' or 'genre'")
+		os.Exit(1)
+	}
+
 	processFunc := func() {
 		if processAllMovieLibraries {
 			for _, lib := range movieLibraries {
 				fmt.Printf("\n==============================\n")
 				fmt.Printf("🎬 Processing library: %s (ID: %s)\n", lib.Title, lib.Key)
 				libConfig := config
 				libConfig.LibraryID = lib.Key
-				processAllMovies(libConfig)
+				processAllMovies(libConfig, updateField)
 			}
 		} else {
 			config.LibraryID = movieLibraries[0].Key
-			processAllMovies(config)
+			processAllMovies(config, updateField)
 		}
 	}
 
@@ -236,7 +248,7 @@ func main() {
 	}
 }
 
-func processAllMovies(config Config) {
+func processAllMovies(config Config, updateField string) {
 	fmt.Println("\n📋 Fetching all movies from library...")
 	movies, err := getMoviesFromLibrary(config)
 	if err != nil {
@@ -257,73 +269,71 @@ func processAllMovies(config Config) {
 	skippedMovies := 0
 
 	for i, movie := range movies {
-		// Check if movie was already processed
 		processed, exists := processedMovies[movie.RatingKey]
 		if exists && processed.KeywordsSynced {
 			skippedMovies++
 			continue
 		}
 
-		// Extract TMDb ID from movie first (before any output)
 		tmdbID := extractTMDbID(movie)
 		if tmdbID == "" {
 			fmt.Printf("⚠️ No TMDb ID found for movie: %s\n", movie.Title)
 			continue
 		}
 
-		// Get TMDb keywords
 		keywords, err := getTMDbKeywords(config, tmdbID)
 		if err != nil {
 			fmt.Printf("❌ Error fetching TMDb keywords for %s: %v\n", movie.Title, err)
 			continue
 		}
 
-		// Fetch detailed movie information to get current labels
 		movieDetails, err := getMovieDetails(config, movie.RatingKey)
 		if err != nil {
 			fmt.Printf("❌ Error fetching movie details for %s: %v\n", movie.Title, err)
 			continue
 		}
 
-		// Get current movie labels from detailed fetch
-		currentLabels := make([]string, len(movieDetails.Label))
-		for j, label := range movieDetails.Label {
-			currentLabels[j] = label.Tag
+		var currentValues []string
+		if updateField == "labels" {
+			currentValues = make([]string, len(movieDetails.Label))
+			for j, label := range movieDetails.Label {
+				currentValues[j] = label.Tag
+			}
+		} else {
+			currentValues = make([]string, len(movieDetails.Genre))
+			for j, genre := range movieDetails.Genre {
+				currentValues[j] = genre.Tag
+			}
 		}
 
-		// Check if all keywords already exist as labels (case-insensitive)
-		currentLabelsMap := make(map[string]bool)
-		for _, label := range currentLabels {
-			currentLabelsMap[strings.ToLower(label)] = true
+		currentValuesMap := make(map[string]bool)
+		for _, val := range currentValues {
+			currentValuesMap[strings.ToLower(val)] = true
 		}
 
 		allKeywordsExist := true
 		for _, keyword := range keywords {
-			if !currentLabelsMap[strings.ToLower(keyword)] {
+			if !currentValuesMap[strings.ToLower(keyword)] {
 				allKeywordsExist = false
 				break
 			}
 		}
 
-		// If all keywords already exist, skip silently
 		if allKeywordsExist {
 			skippedMovies++
 			continue
 		}
 
-		// Only show processing output for movies that need updates
 		fmt.Printf("\n🎬 Processing movie %d/%d: %s (%d)\n", i+1, len(movies), movie.Title, movie.Year)
 		fmt.Printf("🔑 TMDb ID: %s (%s)\n", tmdbID, movie.Title)
 		fmt.Printf("🏷️ Found %d TMDb keywords\n", len(keywords))
 
-		// Sync labels with keywords
-		err = syncMovieLabelsWithKeywords(config, movie.RatingKey, currentLabels, keywords)
+		err = syncMovieFieldWithKeywords(config, movie.RatingKey, currentValues, keywords, updateField)
 		if err != nil {
-			fmt.Printf("❌ Error syncing labels: %v\n", err)
+			fmt.Printf("❌ Error syncing %s: %v\n", updateField, err)
 			continue
 		}
 
-		// Update processed movies dictionary
 		processedMovies[movie.RatingKey] = &ProcessedMovie{
 			RatingKey:      movie.RatingKey,
 			Title:          movie.Title,
@@ -339,8 +349,6 @@ func processAllMovies(config Config) {
 		}
 
 		fmt.Printf("✅ Successfully processed: %s\n", movie.Title)
-
-		// Small delay to avoid overwhelming the APIs
 		time.Sleep(500 * time.Millisecond)
 	}
 
@@ -456,50 +464,50 @@ func getTMDbKeywords(config Config, tmdbID string) ([]string, error) {
 	return keywords, nil
 }
 
-func syncMovieLabelsWithKeywords(config Config, movieID string, currentLabels []string, keywords []string) error {
-	// Convert current labels to a map for easy lookup (case-insensitive)
-	currentLabelsMap := make(map[string]bool)
-	for _, label := range currentLabels {
-		currentLabelsMap[strings.ToLower(label)] = true
+func syncMovieFieldWithKeywords(config Config, movieID string, currentValues []string, keywords []string, updateField string) error {
+	currentValuesMap := make(map[string]bool)
+	for _, val := range currentValues {
+		currentValuesMap[strings.ToLower(val)] = true
 	}
 
-	// Find keywords to add (keywords not in current labels, case-insensitive comparison)
-	labelsToAdd := make([]string, 0)
+	valuesToAdd := make([]string, 0)
 	for _, keyword := range keywords {
-		if !currentLabelsMap[strings.ToLower(keyword)] {
-			labelsToAdd = append(labelsToAdd, keyword)
+		if !currentValuesMap[strings.ToLower(keyword)] {
+			valuesToAdd = append(valuesToAdd, keyword)
 		}
 	}
 
-	fmt.Printf("  📝 Labels to add: %v\n", labelsToAdd)
-	fmt.Printf("  🏷️ Existing labels: %v\n", currentLabels)
+	fmt.Printf("  📝 %s to add: %v\n", strings.Title(updateField), valuesToAdd)
+	fmt.Printf("  🏷️ Existing %s: %v\n", updateField, currentValues)
 
-	// Merge existing labels with new keywords
-	allLabels := make([]string, 0, len(currentLabels)+len(labelsToAdd))
-	allLabels = append(allLabels, currentLabels...)
-	allLabels = append(allLabels, labelsToAdd...)
+	allValues := make([]string, 0, len(currentValues)+len(valuesToAdd))
+	allValues = append(allValues, currentValues...)
+	allValues = append(allValues, valuesToAdd...)
 
-	// Update movie labels with combined list
-	return updateMovieLabelsWithKeywords(config, movieID, allLabels)
+	return updateMovieFieldWithKeywords(config, movieID, allValues, updateField)
 }
 
-func updateMovieLabelsWithKeywords(config Config, movieID string, keywords []string) error {
-	// Build the base URL path
+func updateMovieFieldWithKeywords(config Config, movieID string, keywords []string, updateField string) error {
 	basePath := fmt.Sprintf("/library/sections/%s/all?type=1&id=%s&includeExternalMedia=1", config.LibraryID, movieID)
 
-	// Add each keyword as a label parameter
-	for i, keyword := range keywords {
-		encodedKeyword := url.QueryEscape(keyword)
-		basePath += fmt.Sprintf("&label%%5B%d%%5D.tag.tag=%s", i, encodedKeyword)
+	if updateField == "labels" {
+		for i, keyword := range keywords {
+			encodedKeyword := url.QueryEscape(keyword)
+			basePath += fmt.Sprintf("&label%%5B%d%%5D.tag.tag=%s", i, encodedKeyword)
+		}
+		basePath += "&label.locked=1"
+	} else {
+		for i, keyword := range keywords {
+			encodedKeyword := url.QueryEscape(keyword)
+			basePath += fmt.Sprintf("&genre%%5B%d%%5D.tag.tag=%s", i, encodedKeyword)
+		}
+		basePath += "&genre.locked=1"
 	}
+	basePath += fmt.Sprintf("&X-Plex-Token=%s", config.PlexToken)
 
-	// Add label lock and token
-	basePath += fmt.Sprintf("&label.locked=1&X-Plex-Token=%s", config.PlexToken)
-
-	// Build the complete URL
 	updateURL := buildPlexURL(config, basePath)
 
-	fmt.Printf("  📤 Updating movie labels...\n")
+	fmt.Printf("  📤 Updating movie %s...\n", updateField)
 
 	req, err := http.NewRequest("PUT", updateURL, nil)
 	if err != nil {