Added recently added stuff

src/Ombi.Core/Engine/IRecentlyAddedEngine.cs

@@ -0,0 +1,12 @@
+using System;
+using System.Collections.Generic;
+using Ombi.Core.Models;
+
+namespace Ombi.Core.Engine
+{
+    public interface IRecentlyAddedEngine
+    {
+        IEnumerable<RecentlyAddedMovieModel> GetRecentlyAddedMovies();
+        IEnumerable<RecentlyAddedMovieModel> GetRecentlyAddedMovies(DateTime from, DateTime to);
+    }
+}

src/Ombi.Core/Engine/RecentlyAddedEngine.cs

@@ -11,7 +11,7 @@ using Ombi.Store.Repository;
 
 namespace Ombi.Core.Engine
 {
-    public class RecentlyAddedEngine
+    public class RecentlyAddedEngine : IRecentlyAddedEngine
     {
         public RecentlyAddedEngine(IPlexContentRepository plex, IEmbyContentRepository emby)
         {
@@ -22,11 +22,11 @@ namespace Ombi.Core.Engine
         private readonly IPlexContentRepository _plex;
         private readonly IEmbyContentRepository _emby;
 
-        public IEnumerable<RecentlyAddedMovieModel> GetRecentlyAddedMovies(TimeSpan from)
+        public IEnumerable<RecentlyAddedMovieModel> GetRecentlyAddedMovies(DateTime from, DateTime to)
         {
             var model = new HashSet<RecentlyAddedMovieModel>();
-            var plexMovies = _plex.GetAll().Where(x => x.Type == PlexMediaTypeEntity.Movie && x.AddedAt.Subtract(from) <= x.AddedAt);
+            var plexMovies = _plex.GetAll().Where(x => x.Type == PlexMediaTypeEntity.Movie && x.AddedAt > from && x.AddedAt < to);
-            var embyMovies = _emby.GetAll().Where(x => x.Type == EmbyMediaType.Movie && x.AddedAt.Subtract(from) <= x.AddedAt);
+            var embyMovies = _emby.GetAll().Where(x => x.Type == EmbyMediaType.Movie && x.AddedAt > from && x.AddedAt < to);
 
             TransformPlexMovies(plexMovies, model);
             TransformEmbyMovies(embyMovies, model);

src/Ombi.DependencyInjection/IocExtensions.cs

@@ -79,6 +79,7 @@ namespace Ombi.DependencyInjection
             services.AddTransient<ITvSearchEngine, TvSearchEngine>();
             services.AddTransient<IRuleEvaluator, RuleEvaluator>();
             services.AddTransient<IMovieSender, MovieSender>();
+            services.AddTransient<IRecentlyAddedEngine, RecentlyAddedEngine>();
             services.AddTransient<ITvSender, TvSender>();
         }
         public static void RegisterHttp(this IServiceCollection services)

src/Ombi/Controllers/RecentlyAddedController.cs

@@ -0,0 +1,33 @@
+using System.Collections.Generic;
+using System.Threading.Tasks;
+using Microsoft.AspNetCore.Authorization;
+using Microsoft.AspNetCore.Mvc;
+using Ombi.Core.Engine;
+using Ombi.Core.Models;
+using Ombi.Models;
+
+namespace Ombi.Controllers
+{
+    [ApiV1]
+    [Produces("application/json")]
+    [Authorize]
+    public class RecentlyAddedController : Controller
+    {
+        public RecentlyAddedController(IRecentlyAddedEngine engine)
+        {
+            _recentlyAdded = engine;
+        }
+
+        private readonly IRecentlyAddedEngine _recentlyAdded;
+
+        /// <summary>
+        /// Returns the recently added movies between two dates
+        /// </summary>
+        [HttpPost("movies")]
+        [ProducesResponseType(typeof(IEnumerable<RecentlyAddedMovieModel>), 200)]
+        public IEnumerable<RecentlyAddedMovieModel> GetRecentlyAddedMovies([FromBody] RecentlyAddedRangeModel model)
+        {
+            return _recentlyAdded.GetRecentlyAddedMovies(model.From, model.To);
+        }
+    }
+}

src/Ombi/Models/RecentlyAddedRangeModel.cs

@@ -0,0 +1,10 @@
+using System;
+
+namespace Ombi.Models
+{
+    public class RecentlyAddedRangeModel
+    {
+        public DateTime From { get; set; }
+        public DateTime To { get; set; }
+    }
+}