Get by multiple ids added to BasicRepo

NzbDrone.Core/Datastore/BasicRepository.cs

@@ -15,6 +15,7 @@ namespace NzbDrone.Core.Datastore
         IEnumerable<TModel> All();
         int Count();
         TModel Get(int id);
+        IEnumerable<TModel> Get(IEnumerable<int> ids);
         TModel SingleOrDefault();
         TModel Insert(TModel model);
         TModel Update(TModel model);
@@ -64,6 +65,18 @@ namespace NzbDrone.Core.Datastore
             return _dataMapper.Query<TModel>().Single(c => c.Id == id);
         }
 
+        public IEnumerable<TModel> Get(IEnumerable<int> ids)
+        {
+            var idList = ids.ToList();
+            var result = Query.Where(String.Format("Id IN ({0})", String.Join(",", idList))).ToList();
+            var resultCount = result.Count;
+
+            if (resultCount != idList.Count || result.Select(r => r.Id).Distinct().Count() != resultCount)
+                throw new InvalidOperationException("Unexpected result from query");
+
+            return result;
+        }
+
         public TModel SingleOrDefault()
         {
             return All().Single();

NzbDrone.Core/Tv/SeriesRepository.cs

@@ -13,7 +13,6 @@ namespace NzbDrone.Core.Tv
         Series FindByTvdbId(int tvdbId);
         void SetSeriesType(int seriesId, SeriesTypes seriesTypes);
         void SetTvRageId(int seriesId, int tvRageId);
-        List<Series> SeriesIsInList(IEnumerable<int> ids);
     }
 
     public class SeriesRepository : BasicRepository<Series>, ISeriesRepository
@@ -52,10 +51,5 @@ namespace NzbDrone.Core.Tv
         {
             SetFields(new Series { Id = seriesId, TvRageId = tvRageId }, s => s.TvRageId);
         }
-
-        public List<Series> SeriesIsInList(IEnumerable<int> ids)
-        {
-            return Query.Where(String.Format("Id IN ({0})", String.Join(",", ids)));
-        }
     }
 }

NzbDrone.Core/Tv/SeriesService.cs

@@ -137,11 +137,6 @@ namespace NzbDrone.Core.Tv
 
         }
 
-        public void SetTvRageId(int seriesId, int tvRageId)
-        {
-            _seriesRepository.SetTvRageId(seriesId, tvRageId);
-        }
-
         public Series FindByTvdbId(int tvdbId)
         {
             return _seriesRepository.FindByTvdbId(tvdbId);
@@ -181,7 +176,7 @@ namespace NzbDrone.Core.Tv
 
         public List<Series> GetSeriesInList(IEnumerable<int> seriesIds)
         {
-            return _seriesRepository.SeriesIsInList(seriesIds);
+            return _seriesRepository.Get(seriesIds).ToList();
         }
 
         public void HandleAsync(SeriesAddedEvent message)