fix: ensure only 1 xref per company exist

Closes #1191
ShokoAnime · Oct 25, 2024 · 991ac1c · 991ac1c
1 parent 3013fcf
commit 991ac1c
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/Shoko.Server/Providers/TMDB/TmdbMetadataService.cs b/Shoko.Server/Providers/TMDB/TmdbMetadataService.cs
@@ -1931,16 +1931,18 @@ private void PurgeTitlesAndOverviews(ForeignEntityType foreignType, int foreignI
     private async Task<bool> UpdateCompanies(IEntityMetadata tmdbEntity, List<ProductionCompany> companies)
     {
         var existingXrefs = _xrefTmdbCompanyEntity.GetByTmdbEntityTypeAndID(tmdbEntity.Type, tmdbEntity.Id)
-            .ToDictionary(xref => xref.TmdbCompanyID);
+            .GroupBy(xref => xref.TmdbCompanyID)
+            .ToDictionary(xref => xref.Key, groupBy => groupBy.ToList());
         var xrefsToAdd = 0;
         var xrefsToSkip = new HashSet<int>();
         var xrefsToSave = new List<TMDB_Company_Entity>();
         var indexCounter = 0;
         foreach (var company in companies)
         {
             var currentIndex = indexCounter++;
-            if (existingXrefs.TryGetValue(company.Id, out var existingXref))
+            if (existingXrefs.TryGetValue(company.Id, out var existingXrefList))
             {
+                var existingXref = existingXrefList[0];
                 if (existingXref.Ordering != currentIndex || existingXref.ReleasedAt != tmdbEntity.ReleasedAt)
                 {
                     existingXref.Ordering = currentIndex;
@@ -1958,6 +1960,7 @@ private async Task<bool> UpdateCompanies(IEntityMetadata tmdbEntity, List<Produc
             await UpdateCompany(company);
         }
         var xrefsToRemove = existingXrefs.Values
+            .SelectMany(xrefs => xrefs)
             .ExceptBy(xrefsToSkip, o => o.TMDB_Company_EntityID)
             .ToList();