Do not delete the Emby Information every time we run, let's keep the content now.

src/Ombi.Schedule/Jobs/Emby/EmbyContentSync.cs

@@ -68,8 +68,8 @@ namespace Ombi.Schedule.Jobs.Emby
             if (!ValidateSettings(server))
                 return;
 
-            await _repo.ExecuteSql("DELETE FROM EmbyEpisode");
-            await _repo.ExecuteSql("DELETE FROM EmbyContent");
+            //await _repo.ExecuteSql("DELETE FROM EmbyEpisode");
+            //await _repo.ExecuteSql("DELETE FROM EmbyContent");
 
             var movies = await _api.GetAllMovies(server.ApiKey,0, 200, server.AdministratorId, server.FullUri);
             var totalCount = movies.TotalRecordCount;
@@ -103,12 +103,14 @@ namespace Ombi.Schedule.Jobs.Emby
                     processed++;
                     if (string.IsNullOrEmpty(tvShow.ProviderIds?.Tvdb))
                     {
-                        Log.Error("Provider Id on tv {0} is null", tvShow.Name);
+                        _logger.LogInformation("Provider Id on tv {0} is null", tvShow.Name);
                         continue;
                     }
 
                     var existingTv = await _repo.GetByEmbyId(tvShow.Id);
                     if (existingTv == null)
+                    {
+                        _logger.LogDebug("Adding new TV Show {0}", tvShow.Name);
                         mediaToAdd.Add(new EmbyContent
                         {
                             TvDbId = tvShow.ProviderIds?.Tvdb,
@@ -121,6 +123,11 @@ namespace Ombi.Schedule.Jobs.Emby
                             AddedAt = DateTime.UtcNow
                         });
                     }
+                    else
+                    {
+                        _logger.LogDebug("We already have TV Show {0}", tvShow.Name);
+                    }
+                }
                 // Get the next batch
                 tv = await _api.GetAllShows(server.ApiKey, processed + 1, 200, server.AdministratorId, server.FullUri);
                 await _repo.AddRange(mediaToAdd);
@@ -137,6 +144,8 @@ namespace Ombi.Schedule.Jobs.Emby
             var existingMovie = await _repo.GetByEmbyId(movieInfo.Id);
 
             if (existingMovie == null)
+            {
+                _logger.LogDebug("Adding new movie {0}", movieInfo.Name);
                 content.Add(new EmbyContent
                 {
                     ImdbId = movieInfo.ProviderIds.Imdb,
@@ -148,6 +157,12 @@ namespace Ombi.Schedule.Jobs.Emby
                     AddedAt = DateTime.UtcNow,
                 });
             }
+            else
+            {
+                // we have this
+                _logger.LogDebug("We already have movie {0}", movieInfo.Name);
+            }
+        }
 
         private bool ValidateSettings(EmbyServers server)
         {

src/Ombi.Schedule/Jobs/Emby/EmbyEpisodeSync.cs

@@ -76,7 +76,7 @@ namespace Ombi.Schedule.Jobs.Emby
             var allEpisodes = await _api.GetAllEpisodes(server.ApiKey, 0, 200, server.AdministratorId, server.FullUri);
             var total = allEpisodes.TotalRecordCount;
             var processed = 0;
-            var epToAdd = new List<EmbyEpisode>();
+            var epToAdd = new HashSet<EmbyEpisode>();
             while (processed < total)
             {
                 foreach (var ep in allEpisodes.Items)
@@ -93,8 +93,12 @@ namespace Ombi.Schedule.Jobs.Emby
                     }
 
                     var existingEpisode = await _repo.GetEpisodeByEmbyId(ep.Id);
-                    if (existingEpisode == null)
+                    // Make sure it's not in the hashset too
+                    var existingInList = epToAdd.Any(x => x.EmbyId == ep.Id);
+
+                    if (existingEpisode == null && !existingInList)
                     {
+                        _logger.LogDebug("Adding new episode {0} to parent {1}", ep.Name, ep.SeriesName);
                         // add it
                         epToAdd.Add(new EmbyEpisode
                         {