Merge pull request #21 from CCoupel/feature/issue-13-full-metadata

feat: v1.1.0 — Full metadata sync, MetadataMode, RemoteSyncFull, progress UI

Author: CCoupel

docs/CONFIGURATION.md

@@ -48,23 +48,39 @@ Ce répertoire sera créé automatiquement par le plugin. Il doit être accessib
 
 ### Étape 3 : Ajouter un serveur source
 
-Cliquer **"Ajouter un serveur"** et remplir :
+Cliquer **"+ Add Connector"** et remplir :
 
 | Champ | Exemple | Description |
 |---|---|---|
 | Nom d'affichage | `Serveur B - Bureau` | Nom libre pour identifier la source |
 | Type de serveur | `Emby` | Emby / Jellyfin / Plex |
 | URL du serveur | `http://192.168.1.200:8096` ou `https://media.example.com/emby` | URL complète avec port **et chemin de base** Emby |
-| Clé API | `abc123def456...` | Clé API du serveur source |
+| Mode d'authentification | `User Credentials` | Voir section Authentication ci-dessous |
+| Mode de métadonnées | `Remote Sync` | Voir section Metadata Source ci-dessous |
 
 **Important — URL du serveur** : inclure le chemin de base si Emby est derrière un reverse proxy.
 Exemple : si Emby répond sur `https://media.example.com/emby/Items/...`, l'URL à configurer est `https://media.example.com/emby`.
 
-Cliquer **"Tester la connexion"** pour valider avant de sauvegarder.
+Cliquer **"Test Connection"** pour valider avant de sauvegarder.
+
+#### Authentification
+
+| Mode | Description |
+|---|---|
+| **API Key** | Accès admin complet, aucun suivi d'usage sur le serveur distant |
+| **User Credentials** | Le serveur distant voit les sessions de cet utilisateur, applique ses restrictions et enregistre l'historique de lecture |
+
+#### Metadata Source
+
+| Mode | Description |
+|---|---|
+| **Remote Sync** | Le plugin télécharge métadonnées et images depuis le serveur distant. Items avec `.nfo` existant ignorés (incrémental). |
+| **Remote Sync Full** | Identique à Remote Sync mais réécrit tous les `.nfo` et re-télécharge les images à chaque sync. |
+| **Local Scraping** | Seuls les `.strm` sont créés. Emby utilise ses propres scrapers (TMDB, TVDB, FanArt) pour enrichir la bibliothèque. Nécessite un accès internet. |
 
 ### Étape 4 : Sélectionner les bibliothèques à synchroniser
 
-Après un test de connexion réussi, la liste des bibliothèques disponibles sur le serveur source s'affiche. Cocher celles à inclure.
+Après un test de connexion réussi, la liste des bibliothèques disponibles s'affiche. Cocher celles à inclure — les dossiers virtuels Emby sont créés automatiquement.
 
 ### Étape 5 : Configurer la synchronisation automatique
 
@@ -75,17 +91,11 @@ Timeout proxy stream :          30 secondes
 
 ### Étape 6 : Lancer la première synchronisation
 
-Cliquer **"Synchroniser maintenant"** pour déclencher la première sync manuellement.
+Cliquer **"Synchronise Now"** pour déclencher la première sync manuellement. La barre de progression avance bibliothèque par bibliothèque.
 
-### Étape 7 : Ajouter la bibliothèque virtuelle dans Emby
+Les dossiers virtuels Emby sont créés automatiquement par le plugin — aucune configuration manuelle dans le Dashboard Emby n'est nécessaire.
 
-Après la sync :
-1. Dashboard → Bibliothèques → Ajouter une bibliothèque
-2. Type : Films (ou Séries selon le contenu)
-3. Dossier : `/media/virtual-libraries/Films_ServeurB`
-4. Valider
-
-Les médias du serveur B apparaissent maintenant dans l'interface d'Emby A.
+Les médias du serveur distant apparaissent dans l'interface d'Emby après le scan de bibliothèque déclenché automatiquement en fin de sync.
 
 ---
 
@@ -235,9 +245,15 @@ Normal : la terminaison TLS est faite par le reverse proxy (traefik). Le serveur
 
 ### La sync ne détecte pas les nouveaux ajouts
 
-- La sync delta compare les IDs distants avec l'index local (`.index/{connectorId}.json`)
-- Si l'index est corrompu, le supprimer pour forcer une re-sync complète
-- Vérifier l'intervalle de sync configuré
+- Les items ajoutés sur le serveur distant sont détectés automatiquement à la prochaine sync (aucun `.nfo` local → créé)
+- Vérifier l'intervalle de sync configuré (défaut : 6h)
+- Déclencher une sync manuelle depuis le dashboard plugin
+
+### Les métadonnées sont incomplètes ou manquantes
+
+- Vérifier que le mode **Remote Sync** ou **Remote Sync Full** est sélectionné (pas Local Scraping)
+- Si les métadonnées ne se mettent pas à jour malgré une sync : passer en mode **Remote Sync Full** pour forcer la réécriture des `.nfo`
+- Les items dont la récupération de métadonnées a échoué sont comptés "failed" et retentés à la prochaine sync
 
 ---
 

docs/ROADMAP.md

@@ -25,16 +25,26 @@
 
 ---
 
-## Phase 2a — Synchronisation des métadonnées *(en cours)*
+## Phase 2a — Synchronisation des métadonnées ✅ Terminé (v1.1.0)
 
 - [x] `SyncService` : orchestration sync par connector + bibliothèque
-- [x] Génération `.strm` + `.nfo` + téléchargement artwork
-- [x] Skip intelligent : toujours régénérer le `.strm` (cheap), ne sauter que si `.nfo` déjà présent
-- [ ] `LibrarySyncJob` : tâche planifiée (`IScheduledTask`) configurable
-- [ ] Détection delta : index JSON local `{connectorId}.json`
+- [x] Génération `.strm` + `.nfo` + téléchargement artwork (poster, fanart, landscape, logo)
+- [x] Métadonnées complètes : cast, directors, writers, tagline, trailer URL
+- [x] Skip intelligent : toujours régénérer le `.strm`, ne sauter le `.nfo` qu'en mode `RemoteSync`
+- [x] `MetadataMode` par connecteur : `RemoteSync` (incrémental) / `RemoteSyncFull` (force) / `LocalScraping`
+- [x] `LibraryOptions` Emby appliquées selon le mode (fetchers TMDB/TVDB/FanArt, cache, chapitres)
+- [x] `LibrarySyncJob` : tâche planifiée (`IScheduledTask`) avec intervalle configurable
+- [x] Mise à jour dynamique du trigger sans redémarrage
+- [x] `QueueLibraryScan()` déclenché si des items ont été créés
+- [x] Compteurs d'items distants par bibliothèque (endpoint `/item-counts`)
+- [x] Fix `Users/Me` 500 : `GetUserIdAsync` sans appel à `/Users/Me`
+- [x] Progression sync par librairie dans l'UI (itération client-side)
+
+**Reste en backlog :**
+- [ ] Détection delta : index JSON local `{connectorId}.json` (issue #12)
 - [ ] Gestion des suppressions (items supprimés sur la source)
-- [ ] Logs de sync dans le dashboard
-- [ ] Tests intégration sync job
+- [ ] Tests intégration sync job (issue #14)
+- [ ] Progression sync par item en temps réel (issue #20)
 
 ---
 

src/VirtualLib/Api/ConfigController.cs

@@ -3,6 +3,7 @@
 using MediaBrowser.Controller.Library;
 using MediaBrowser.Controller.Net;
 using MediaBrowser.Model.Services;
+using MediaBrowser.Model.Tasks;
 using Microsoft.Extensions.Logging.Abstractions;
 using VirtualLib.Core;
 using VirtualLib.Core.Models;
@@ -28,6 +29,7 @@ public sealed class CreateConnector : IReturn<ConnectorConfig>
     public string ApiKey { get; set; } = string.Empty;
     public string Username { get; set; } = string.Empty;
     public string Password { get; set; } = string.Empty;
+    public MetadataMode MetadataMode { get; set; } = MetadataMode.RemoteSync;
     public List<string> LibraryIds { get; set; } = new();
     public bool Enabled { get; set; } = true;
 }
@@ -44,6 +46,7 @@ public sealed class UpdateConnector : IReturn<ConnectorConfig>
     public string ApiKey { get; set; } = string.Empty;
     public string Username { get; set; } = string.Empty;
     public string Password { get; set; } = string.Empty;
+    public MetadataMode MetadataMode { get; set; } = MetadataMode.RemoteSync;
     public List<string> LibraryIds { get; set; } = new();
     public bool Enabled { get; set; } = true;
 }
@@ -172,9 +175,13 @@ public sealed class ConfigController : BaseApiService
             NullLogger<SyncService>.Instance));
 
     private readonly LibraryProvisioner _libraryProvisioner;
+    private readonly ILibraryManager _libraryManager;
+    private readonly ITaskManager _taskManager;
 
-    public ConfigController(ILibraryManager libraryManager)
+    public ConfigController(ILibraryManager libraryManager, ITaskManager taskManager)
     {
+        _libraryManager = libraryManager;
+        _taskManager = taskManager;
         _libraryProvisioner = new LibraryProvisioner(libraryManager, NullLogger<LibraryProvisioner>.Instance);
     }
 
@@ -257,6 +264,7 @@ public object Post(CreateConnector request)
             ApiKey = request.ApiKey,
             Username = request.Username,
             Password = request.Password,
+            MetadataMode = request.MetadataMode,
             LibraryIds = request.LibraryIds,
             Enabled = request.Enabled
         };
@@ -291,6 +299,7 @@ public object Put(UpdateConnector request)
             Username = request.Username,
             // Preserve existing password if the client sent an empty string (placeholder pattern)
             Password = string.IsNullOrEmpty(request.Password) ? existing.Password : request.Password,
+            MetadataMode = request.MetadataMode,
             LibraryIds = request.LibraryIds,
             Enabled = request.Enabled,
             KnownLibraries = existing.KnownLibraries
@@ -307,7 +316,7 @@ public object Put(UpdateConnector request)
             var removedIds = existing.LibraryIds.Except(request.LibraryIds).ToList();
 
             foreach (var lib in updated.KnownLibraries.Where(l => addedIds.Contains(l.Id)))
-                _libraryProvisioner.EnsureVirtualFolder(updated.DisplayName, lib.Name, lib.Type, virtualLibRoot);
+                _libraryProvisioner.EnsureVirtualFolder(updated.DisplayName, lib.Name, lib.Type, virtualLibRoot, updated.MetadataMode);
 
             foreach (var lib in existing.KnownLibraries.Where(l => removedIds.Contains(l.Id)))
                 _libraryProvisioner.RemoveVirtualFolder(existing.DisplayName, lib.Name);
@@ -362,6 +371,21 @@ public object Put(SaveSettings request)
         config.ProxyTimeoutSeconds = request.ProxyTimeoutSeconds;
         Plugin.Instance.SaveConfiguration();
 
+        // Update the scheduled task trigger to reflect the new interval
+        var worker = _taskManager.ScheduledTasks
+            .FirstOrDefault(t => t.ScheduledTask is LibrarySyncJob);
+        if (worker != null)
+        {
+            worker.Triggers = new[]
+            {
+                new TaskTriggerInfo
+                {
+                    Type = TaskTriggerInfo.TriggerInterval,
+                    IntervalTicks = TimeSpan.FromHours(config.SyncIntervalHours).Ticks
+                }
+            };
+        }
+
         return ResultFactory.GetResult(Request, new GlobalSettings
         {
             VirtualLibraryRootPath = config.VirtualLibraryRootPath,
@@ -467,6 +491,9 @@ public object Post(SyncLibrary request)
             progress: null,
             CancellationToken.None).GetAwaiter().GetResult();
 
+        if (result.Success && result.ItemsCreated > 0)
+            _libraryManager.QueueLibraryScan();
+
         return ResultFactory.GetResult(Request, result, NoHeaders);
     }
 
@@ -556,7 +583,8 @@ public object Get(GetConnectorLibraries request)
         if (!string.IsNullOrEmpty(virtualLibRoot))
         {
             foreach (var lib in connectorConfig.KnownLibraries)
-                _libraryProvisioner.EnsureVirtualFolder(connectorConfig.DisplayName, lib.Name, lib.Type, virtualLibRoot);
+                _libraryProvisioner.EnsureVirtualFolder(
+                    connectorConfig.DisplayName, lib.Name, lib.Type, virtualLibRoot, connectorConfig.MetadataMode);
         }
 
         return ResultFactory.GetResult(Request, libList, NoHeaders);
@@ -587,6 +615,9 @@ public object Post(SyncAll request)
             results.Add(result);
         }
 
+        if (results.Any(r => r.Success && r.ItemsCreated > 0))
+            _libraryManager.QueueLibraryScan();
+
         return ResultFactory.GetResult(Request, results, NoHeaders);
     }
 
@@ -611,6 +642,9 @@ public object Post(SyncConnector request)
             progress: null,
             CancellationToken.None).GetAwaiter().GetResult();
 
+        if (result.Success && result.ItemsCreated > 0)
+            _libraryManager.QueueLibraryScan();
+
         return ResultFactory.GetResult(Request, result, NoHeaders);
     }
 
@@ -626,6 +660,7 @@ private void ProvisionEnabledLibraries(ConnectorConfig connectorConfig, string v
             .Where(l => connectorConfig.LibraryIds.Contains(l.Id));
 
         foreach (var lib in enabledLibs)
-            _libraryProvisioner.EnsureVirtualFolder(connectorConfig.DisplayName, lib.Name, lib.Type, virtualLibRoot);
+            _libraryProvisioner.EnsureVirtualFolder(
+                connectorConfig.DisplayName, lib.Name, lib.Type, virtualLibRoot, connectorConfig.MetadataMode);
     }
 }

src/VirtualLib/Connectors/EmbyConnector.cs

@@ -4,6 +4,7 @@
 using VirtualLib.Connectors.Internal;
 using VirtualLib.Core;
 using VirtualLib.Core.Models;
+using PersonInfo = VirtualLib.Core.Models.PersonInfo;
 
 namespace VirtualLib.Connectors;
 
@@ -286,7 +287,10 @@ public async Task<MediaMetadata> GetMetadataAsync(
         string itemId,
         CancellationToken cancellationToken = default)
     {
-        var url = $"Items/{itemId}?Fields=Overview,Genres,Studios,ProviderIds,People,Tags";
+        var userId = await GetUserIdAsync(cancellationToken);
+        var url = userId is not null
+            ? $"Users/{userId}/Items/{itemId}?Fields=Overview,Genres,Studios,ProviderIds,People,Tags,RemoteTrailers,Taglines"
+            : $"Items/{itemId}?Fields=Overview,Genres,Studios,ProviderIds,People,Tags,RemoteTrailers,Taglines";
         using var response = await GetWithRetryAsync(url, cancellationToken);
         response.EnsureSuccessStatusCode();
 
@@ -488,7 +492,21 @@ private MediaMetadata MapMetadata(EmbyItem item)
             Genres = item.Genres?.AsReadOnly() ?? (IReadOnlyList<string>)Array.Empty<string>(),
             Studios = item.Studios?.Select(s => s.Name).ToList().AsReadOnly() ?? (IReadOnlyList<string>)Array.Empty<string>(),
             Tags = item.Tags?.AsReadOnly() ?? (IReadOnlyList<string>)Array.Empty<string>(),
-            OfficialRating = item.OfficialRating
+            OfficialRating = item.OfficialRating,
+            Cast = item.People?
+                .Where(p => string.Equals(p.Type, "Actor", StringComparison.OrdinalIgnoreCase))
+                .Select(p => new PersonInfo { Name = p.Name, Role = p.Role })
+                .ToList() ?? (IReadOnlyList<PersonInfo>)Array.Empty<PersonInfo>(),
+            Directors = item.People?
+                .Where(p => string.Equals(p.Type, "Director", StringComparison.OrdinalIgnoreCase))
+                .Select(p => p.Name)
+                .ToList() ?? (IReadOnlyList<string>)Array.Empty<string>(),
+            Writers = item.People?
+                .Where(p => string.Equals(p.Type, "Writer", StringComparison.OrdinalIgnoreCase))
+                .Select(p => p.Name)
+                .ToList() ?? (IReadOnlyList<string>)Array.Empty<string>(),
+            Tagline = item.Taglines?.FirstOrDefault(),
+            TrailerUrl = item.RemoteTrailers?.FirstOrDefault()?.Url
         };
     }
 

src/VirtualLib/Connectors/Internal/EmbyApiModels.cs

@@ -93,6 +93,15 @@ internal sealed class EmbyItem
 
     [JsonPropertyName("BackdropImageTags")]
     public List<string>? BackdropImageTags { get; init; }
+
+    [JsonPropertyName("People")]
+    public List<EmbyPerson>? People { get; init; }
+
+    [JsonPropertyName("RemoteTrailers")]
+    public List<EmbyRemoteTrailer>? RemoteTrailers { get; init; }
+
+    [JsonPropertyName("Taglines")]
+    public List<string>? Taglines { get; init; }
 }
 
 internal sealed class EmbyStudio
@@ -101,6 +110,24 @@ internal sealed class EmbyStudio
     public string Name { get; init; } = string.Empty;
 }
 
+internal sealed class EmbyPerson
+{
+    [JsonPropertyName("Name")]
+    public string Name { get; init; } = string.Empty;
+
+    [JsonPropertyName("Role")]
+    public string? Role { get; init; }
+
+    [JsonPropertyName("Type")]
+    public string? Type { get; init; }
+}
+
+internal sealed class EmbyRemoteTrailer
+{
+    [JsonPropertyName("Url")]
+    public string? Url { get; init; }
+}
+
 internal sealed class EmbyUser
 {
     [JsonPropertyName("Id")]