Started to impliment the Plex checker. This will check plex every x minutes to see if there is any new content and then update the avalibility of the requests

PlexRequests.Core/IRequestService.cs

@@ -0,0 +1,42 @@
+#region Copyright
+// /************************************************************************
+//    Copyright (c) 2016 Jamie Rees
+//    File: IRequestService.cs
+//    Created By: Jamie Rees
+//   
+//    Permission is hereby granted, free of charge, to any person obtaining
+//    a copy of this software and associated documentation files (the
+//    "Software"), to deal in the Software without restriction, including
+//    without limitation the rights to use, copy, modify, merge, publish,
+//    distribute, sublicense, and/or sell copies of the Software, and to
+//    permit persons to whom the Software is furnished to do so, subject to
+//    the following conditions:
+//   
+//    The above copyright notice and this permission notice shall be
+//    included in all copies or substantial portions of the Software.
+//   
+//    THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
+//    EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
+//    MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
+//    NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE
+//    LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION
+//    OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
+//    WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
+//  ************************************************************************/
+#endregion
+
+using System.Collections.Generic;
+using PlexRequests.Store;
+
+namespace PlexRequests.Core
+{
+    public interface IRequestService
+    {
+        long AddRequest(int providerId, RequestedModel model);
+        bool CheckRequest(int providerId);
+        void DeleteRequest(int tmdbId);
+        void UpdateRequest(int originalId, RequestedModel model);
+        RequestedModel Get(int id);
+        IEnumerable<RequestedModel> GetAll();
+    }
+}

PlexRequests.Core/PlexRequests.Core.csproj

@@ -64,8 +64,8 @@
   </ItemGroup>
   <ItemGroup>
     <Compile Include="CacheKeys.cs" />
+    <Compile Include="IRequestService.cs" />
     <Compile Include="ISettingsService.cs" />
-    <Compile Include="RequestService.cs" />
     <Compile Include="SettingModels\AuthenticationSettings.cs" />
     <Compile Include="SettingModels\PlexSettings.cs" />
     <Compile Include="SettingModels\SonarrSettings.cs" />
@@ -73,7 +73,7 @@
     <Compile Include="SettingModels\CouchPotatoSettings.cs" />
     <Compile Include="SettingModels\PlexRequestSettings.cs" />
     <Compile Include="SettingModels\Settings.cs" />
-    <Compile Include="SettingsService.cs" />
+    <Compile Include="RequestService.cs" />
     <Compile Include="SettingsServiceV2.cs" />
     <Compile Include="Setup.cs" />
     <Compile Include="UserIdentity.cs" />

PlexRequests.Core/RequestService.cs

@@ -24,35 +24,30 @@
 //    WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
 //  ************************************************************************/
 #endregion
-using System.Linq;
 
+using System.Collections.Generic;
+using System.Linq;
 using PlexRequests.Store;
 
 namespace PlexRequests.Core
 {
-    public class RequestService
+    public class RequestService : IRequestService
     {
-        public RequestService(ISqliteConfiguration db, IRepository<RequestedModel> repo)
+        public RequestService(IRepository<RequestedModel> db)
         {
-            Db = db;
+            Repo = db;
-            Repo = repo;
         }
-        private ISqliteConfiguration Db { get; set; }
+    
         private IRepository<RequestedModel> Repo { get; set; }
-        public void AddRequest(int tmdbid, RequestType type)
-        {
-            var model = new RequestedModel
-            {
-                ProviderId = tmdbid,
-                Type = type
-            };
 
-            Repo.Insert(model);
+        public long AddRequest(int providerId, RequestedModel model)
+        {
+            return Repo.Insert(model);
         }
 
-        public bool CheckRequest(int tmdbid)
+        public bool CheckRequest(int providerId)
         {
-            return Repo.GetAll().Any(x => x.ProviderId == tmdbid);
+            return Repo.GetAll().Any(x => x.ProviderId == providerId);
         }
 
         public void DeleteRequest(int tmdbId)
@@ -61,5 +56,20 @@ namespace PlexRequests.Core
             Repo.Delete(entity);
         }
 
+        public void UpdateRequest(int originalId, RequestedModel model)
+        {
+            model.Id = originalId;
+            Repo.Update(model);
+        }
+
+        public RequestedModel Get(int id)
+        {
+            return Repo.Get(id);
+        }
+
+        public IEnumerable<RequestedModel> GetAll()
+        {
+            return Repo.GetAll();
+        }
     }
 }

PlexRequests.Core/SettingsService.cs

@@ -1,83 +0,0 @@
-#region Copyright
-// /************************************************************************
-//    Copyright (c) 2016 Jamie Rees
-//    File: SettingsService.cs
-//    Created By: Jamie Rees
-//   
-//    Permission is hereby granted, free of charge, to any person obtaining
-//    a copy of this software and associated documentation files (the
-//    "Software"), to deal in the Software without restriction, including
-//    without limitation the rights to use, copy, modify, merge, publish,
-//    distribute, sublicense, and/or sell copies of the Software, and to
-//    permit persons to whom the Software is furnished to do so, subject to
-//    the following conditions:
-//   
-//    The above copyright notice and this permission notice shall be
-//    included in all copies or substantial portions of the Software.
-//   
-//    THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
-//    EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
-//    MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
-//    NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE
-//    LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION
-//    OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
-//    WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
-//  ************************************************************************/
-#endregion
-using System;
-using System.Linq;
-
-using Mono.Data.Sqlite;
-
-using PlexRequests.Api;
-using PlexRequests.Helpers;
-using PlexRequests.Store;
-
-namespace PlexRequests.Core
-{
-    public class SettingsService
-    {
-        public SettingsService(ICacheProvider cache)
-        {
-            Cache = cache;
-        }
-
-        public SettingsModel GetSettings()
-        {
-            
-            var db = new DbConfiguration(new SqliteFactory());
-            var repo = new GenericRepository<SettingsModel>(db);
-
-            var settings = repo.GetAll().FirstOrDefault();
-
-            return settings;
-        }
-        private ICacheProvider Cache { get; set; }
-
-        public void AddRequest(int providerId, RequestedModel model)
-        {
-            var db = new DbConfiguration(new SqliteFactory());
-            var repo = new GenericRepository<RequestedModel>(db);
-
-            repo.Insert(model);
-        }
-
-        public bool CheckRequest(int providerId)
-        {
-            var db = new DbConfiguration(new SqliteFactory());
-            var repo = new GenericRepository<RequestedModel>(db);
-
-            return repo.GetAll().Any(x => x.ProviderId == providerId);
-        }
-
-        public void DeleteRequest(int tmdbId)
-        {
-            var db = new DbConfiguration(new SqliteFactory());
-            var repo = new GenericRepository<RequestedModel>(db);
-            var entity = repo.GetAll().FirstOrDefault(x => x.ProviderId == tmdbId);
-            repo.Delete(entity);
-        }
-
-
-    }
-}

PlexRequests.Store/RequestedModel.cs

@@ -19,6 +19,7 @@ namespace PlexRequests.Store
         public bool Approved { get; set; }
         public string RequestedBy { get; set; }
         public DateTime RequestedDate { get; set; }
+        public bool Available { get; set; }
 
     }
 

PlexRequests.Store/SqlTables.sql

@@ -30,7 +30,7 @@ CREATE TABLE IF NOT EXISTS Requested
 	Approved							INTEGER NOT NULL,
 	RequestedBy							varchar(50),
 	RequestedDate						varchar(50) NOT NULL,
-	Available							varchar(50)
+	Available							INTEGER(50)
 
 );
 

PlexRequests.UI/Bootstrapper.cs

@@ -24,6 +24,8 @@
 //    WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
 //  ************************************************************************/
 #endregion
+
+using FluentScheduler;
 using Mono.Data.Sqlite;
 
 using Nancy;
@@ -39,6 +41,8 @@ using PlexRequests.Core.SettingModels;
 using PlexRequests.Helpers;
 using PlexRequests.Store;
 using PlexRequests.Store.Repository;
+using PlexRequests.UI.Jobs;
+using TaskFactory = FluentScheduler.TaskFactory;
 
 namespace PlexRequests.UI
 {
@@ -62,12 +66,16 @@ namespace PlexRequests.UI
             container.Register<ISettingsService<AuthenticationSettings>, SettingsServiceV2<AuthenticationSettings>>();
             container.Register<ISettingsService<PlexSettings>, SettingsServiceV2<PlexSettings>>();
             container.Register<IRepository<RequestedModel>, GenericRepository<RequestedModel>>();
+            container.Register<IAvailabilityChecker, PlexAvailabilityChecker>();
+            container.Register<IRequestService, RequestService>();
 
             base.ConfigureRequestContainer(container, context);
         }
 
         protected override void ApplicationStartup(TinyIoCContainer container, IPipelines pipelines)
         {
+            TaskManager.TaskFactory = new Jobs.TaskFactory();
+            TaskManager.Initialize(new PlexRegistry());
 
             CookieBasedSessions.Enable(pipelines, CryptographyConfiguration.Default);
             

PlexRequests.UI/Jobs/IAvailabilityChecker.cs

@@ -0,0 +1,34 @@
+#region Copyright
+// /************************************************************************
+//    Copyright (c) 2016 Jamie Rees
+//    File: IAvailabilityChecker.cs
+//    Created By: Jamie Rees
+//   
+//    Permission is hereby granted, free of charge, to any person obtaining
+//    a copy of this software and associated documentation files (the
+//    "Software"), to deal in the Software without restriction, including
+//    without limitation the rights to use, copy, modify, merge, publish,
+//    distribute, sublicense, and/or sell copies of the Software, and to
+//    permit persons to whom the Software is furnished to do so, subject to
+//    the following conditions:
+//   
+//    The above copyright notice and this permission notice shall be
+//    included in all copies or substantial portions of the Software.
+//   
+//    THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
+//    EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
+//    MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
+//    NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE
+//    LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION
+//    OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
+//    WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
+//  ************************************************************************/
+#endregion
+namespace PlexRequests.UI.Jobs
+{
+    public interface IAvailabilityChecker
+    {
+        void CheckAndUpdate(string searchTerm, int id);
+        void CheckAndUpdateAll();
+    }
+}

PlexRequests.UI/Jobs/PlexAvailabilityChecker.cs

@@ -0,0 +1,109 @@
+#region Copyright
+// /************************************************************************
+//    Copyright (c) 2016 Jamie Rees
+//    File: PlexAvailabilityChecker.cs
+//    Created By: Jamie Rees
+//   
+//    Permission is hereby granted, free of charge, to any person obtaining
+//    a copy of this software and associated documentation files (the
+//    "Software"), to deal in the Software without restriction, including
+//    without limitation the rights to use, copy, modify, merge, publish,
+//    distribute, sublicense, and/or sell copies of the Software, and to
+//    permit persons to whom the Software is furnished to do so, subject to
+//    the following conditions:
+//   
+//    The above copyright notice and this permission notice shall be
+//    included in all copies or substantial portions of the Software.
+//   
+//    THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
+//    EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
+//    MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
+//    NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE
+//    LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION
+//    OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
+//    WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
+//  ************************************************************************/
+#endregion
+
+using System;
+using System.Linq;
+using System.Web.Hosting;
+using FluentScheduler;
+using PlexRequests.Api;
+using PlexRequests.Core;
+using PlexRequests.Core.SettingModels;
+
+namespace PlexRequests.UI.Jobs
+{
+    public class PlexAvailabilityChecker : IAvailabilityChecker, ITask, IRegisteredObject
+    {
+        public PlexAvailabilityChecker(ISettingsService<PlexSettings> plexSettings, ISettingsService<AuthenticationSettings> auth, IRequestService request)
+        {
+            Plex = plexSettings;
+            Auth = auth;
+            RequestService = request;
+            HostingEnvironment.RegisterObject(this);
+        }
+        private readonly object _lock = new object();
+
+        private bool _shuttingDown;
+        private ISettingsService<PlexSettings> Plex { get; } 
+        private ISettingsService<AuthenticationSettings> Auth { get; } 
+        private IRequestService RequestService { get; set; }
+        public void CheckAndUpdate(string searchTerm, int id)
+        {
+            var plexSettings = Plex.GetSettings();
+            var authSettings = Auth.GetSettings();
+
+            var api = new PlexApi();
+            var results = api.SearchContent(authSettings.PlexAuthToken, searchTerm, plexSettings.FullUri);
+
+            var result = results.Video.FirstOrDefault(x => x.Title == searchTerm);
+            var originalRequest = RequestService.Get(id);
+
+            originalRequest.Available = result != null;
+            RequestService.UpdateRequest(id, originalRequest);
+        }
+
+        public void CheckAndUpdateAll()
+        {
+            var plexSettings = Plex.GetSettings();
+            var authSettings = Auth.GetSettings();
+            var requests = RequestService.GetAll();
+            var api = new PlexApi();
+
+
+            foreach (var r in requests)
+            {
+                var results = api.SearchContent(authSettings.PlexAuthToken, r.Title, plexSettings.FullUri);
+                var result = results.Video.FirstOrDefault(x => x.Title == r.Title);
+                var originalRequest = RequestService.Get(r.Id);
+
+                originalRequest.Available = result != null;
+                RequestService.UpdateRequest(r.Id, originalRequest);
+            }
+        }
+
+        public void Execute()
+        {
+            lock (_lock)
+            {
+                if (_shuttingDown)
+                    return;
+
+                CheckAndUpdateAll();
+            }
+
+        }
+
+        public void Stop(bool immediate)
+        {
+            lock (_lock)
+            {
+                _shuttingDown = true;
+            }
+
+            HostingEnvironment.UnregisterObject(this);
+        }
+    }
+}

PlexRequests.UI/Jobs/PlexRegistry.cs

@@ -0,0 +1,39 @@
+#region Copyright
+// /************************************************************************
+//    Copyright (c) 2016 Jamie Rees
+//    File: PlexRegistry.cs
+//    Created By: Jamie Rees
+//   
+//    Permission is hereby granted, free of charge, to any person obtaining
+//    a copy of this software and associated documentation files (the
+//    "Software"), to deal in the Software without restriction, including
+//    without limitation the rights to use, copy, modify, merge, publish,
+//    distribute, sublicense, and/or sell copies of the Software, and to
+//    permit persons to whom the Software is furnished to do so, subject to
+//    the following conditions:
+//   
+//    The above copyright notice and this permission notice shall be
+//    included in all copies or substantial portions of the Software.
+//   
+//    THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
+//    EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
+//    MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
+//    NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE
+//    LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION
+//    OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
+//    WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
+//  ************************************************************************/
+#endregion
+
+using FluentScheduler;
+
+namespace PlexRequests.UI.Jobs
+{
+    public class PlexRegistry : Registry
+    {
+        public PlexRegistry()
+        {
+            Schedule<PlexAvailabilityChecker>().ToRunNow().AndEvery(2).Minutes();
+        }
+    }
+}

PlexRequests.UI/Jobs/TaskFactory.cs

@@ -0,0 +1,17 @@
+using FluentScheduler;
+using Nancy.TinyIoc;
+
+namespace PlexRequests.UI.Jobs
+{
+    public class TaskFactory : ITaskFactory
+    {
+        public ITask GetTaskInstance<T>() where T : ITask
+        {
+            var container = TinyIoCContainer.Current;
+            object outT;
+            container.TryResolve(typeof(T), out outT);
+
+            return (T)outT;
+        }
+    }
+}

PlexRequests.UI/Modules/AdminModule.cs

@@ -104,7 +104,7 @@ namespace PlexRequests.UI.Modules
             Log.Trace("Getting Settings:");
             Log.Trace(settings.DumpJson());
     
-            return View["/Settings", settings];
+            return View["Settings", settings];
         }
 
         private Response SaveAdmin()
@@ -166,7 +166,7 @@ namespace PlexRequests.UI.Modules
             { return Response.AsJson(string.Empty); }
 
             var usernames = users.User.Select(x => x.Username);
-            return Response.AsJson(usernames); //TODO usernames are not populated.
+            return Response.AsJson(usernames);
         }
 
         private Negotiator CouchPotato()

PlexRequests.UI/Modules/RequestsModule.cs

@@ -72,31 +72,25 @@ namespace PlexRequests.UI.Modules
 
         private Response GetMovies()
         {
-            // TODO check plex to see the availability
-            var settings = AuthSettings.GetSettings();
-            var plexSettings = PlexSettings.GetSettings();
-            var plex = new PlexApi();
             var dbMovies = Service.GetAll().Where(x => x.Type == RequestType.Movie);
-            var viewModel = dbMovies.Select(tv => new RequestViewModel
+            var viewModel = dbMovies.Select(movie => new RequestViewModel
             {
-                ProviderId = tv.ProviderId,
+                ProviderId = movie.ProviderId,
-                Type = tv.Type,
+                Type = movie.Type,
-                Status = tv.Status,
+                Status = movie.Status,
-                ImdbId = tv.ImdbId,
+                ImdbId = movie.ImdbId,
-                Id = tv.Id,
+                Id = movie.Id,
-                PosterPath = tv.PosterPath,
+                PosterPath = movie.PosterPath,
-                ReleaseDate = tv.ReleaseDate.Humanize(),
+                ReleaseDate = movie.ReleaseDate.Humanize(),
-                RequestedDate = tv.RequestedDate.Humanize(),
+                RequestedDate = movie.RequestedDate.Humanize(),
-                Approved = tv.Approved,
+                Approved = movie.Approved,
-                Title = tv.Title,
+                Title = movie.Title,
-                Overview = tv.Overview,
+                Overview = movie.Overview,
-                RequestedBy = tv.RequestedBy,
+                RequestedBy = movie.RequestedBy,
-                ReleaseYear = tv.ReleaseDate.Year.ToString()
+                ReleaseYear = movie.ReleaseDate.Year.ToString(),
+                Available = movie.Available
             }).ToList();
 
-
-
-            //TODO check if Available in CP
             return Response.AsJson(viewModel);
         }
 
@@ -117,9 +111,10 @@ namespace PlexRequests.UI.Modules
                 Title = tv.Title,
                 Overview = tv.Overview,
                 RequestedBy = tv.RequestedBy,
-                ReleaseYear = tv.ReleaseDate.Year.ToString()
+                ReleaseYear = tv.ReleaseDate.Year.ToString(),
+                Available = tv.Available
             }).ToList();
-            //TODO check if Available in Sonarr
+
             return Response.AsJson(viewModel);
         }
 

PlexRequests.UI/Modules/SearchModule.cs

@@ -26,7 +26,6 @@
 #endregion
 using System;
 using System.Collections.Generic;
-using System.Linq;
 using Nancy;
 using Nancy.Responses.Negotiation;
 
@@ -37,19 +36,24 @@ using PlexRequests.Core;
 using PlexRequests.Core.SettingModels;
 using PlexRequests.Helpers;
 using PlexRequests.Store;
+using PlexRequests.UI.Jobs;
 using PlexRequests.UI.Models;
 
 namespace PlexRequests.UI.Modules
 {
     public class SearchModule : BaseModule
     {
-        public SearchModule(ICacheProvider cache, ISettingsService<CouchPotatoSettings> cpSettings, ISettingsService<PlexRequestSettings> prSettings) : base("search")
+        public SearchModule(ICacheProvider cache, ISettingsService<CouchPotatoSettings> cpSettings,
+            ISettingsService<PlexRequestSettings> prSettings, IAvailabilityChecker checker,
+            IRequestService request) : base("search")
         {
             CpService = cpSettings;
             PrService = prSettings;
             MovieApi = new TheMovieDbApi();
             TvApi = new TheTvDbApi();
             Cache = cache;
+            Checker = checker;
+            RequestService = request;
 
             Get["/"] = parameters => RequestLoad();
 
@@ -64,9 +68,11 @@ namespace PlexRequests.UI.Modules
         }
         private TheMovieDbApi MovieApi { get; }
         private TheTvDbApi TvApi { get; }
+        private IRequestService RequestService { get; }
         private ICacheProvider Cache { get; }
         private ISettingsService<CouchPotatoSettings> CpService { get; }
         private ISettingsService<PlexRequestSettings> PrService { get; }
+        private IAvailabilityChecker Checker { get; }
         private static Logger Log = LogManager.GetCurrentClassLogger();
         private string AuthToken => Cache.GetOrSet(CacheKeys.TvDbToken, TvApi.Authenticate, 50);
 
@@ -145,8 +151,7 @@ namespace PlexRequests.UI.Modules
         private Response RequestMovie(int movieId)
         {
             Log.Trace("Requesting movie with id {0}", movieId);
-            var s = new SettingsService(Cache);
+            if (RequestService.CheckRequest(movieId))
-            if (s.CheckRequest(movieId))
             {
                 Log.Trace("movie with id {0} exists", movieId);
                 return Response.AsJson(new { Result = false, Message = "Movie has already been requested!" });
@@ -193,7 +198,7 @@ namespace PlexRequests.UI.Modules
                 {
                     model.Approved = true;
                     Log.Trace("Adding movie to database requests (No approval required)");
-                    s.AddRequest(movieId, model);
+                    RequestService.AddRequest(movieId, model);
 
                     return Response.AsJson(new { Result = true });
                 }
@@ -203,7 +208,9 @@ namespace PlexRequests.UI.Modules
             try
             {
                 Log.Trace("Adding movie to database requests");
-                s.AddRequest(movieId, model);
+                var id = RequestService.AddRequest(movieId, model);
+                //BackgroundJob.Enqueue(() => Checker.CheckAndUpdate(model.Title, (int)id));
+
                 return Response.AsJson(new { Result = true });
             }
             catch (Exception e)
@@ -223,8 +230,7 @@ namespace PlexRequests.UI.Modules
         private Response RequestTvShow(int showId, bool latest)
         {
             // Latest send to Sonarr and no need to store in DB
-            var s = new SettingsService(Cache);
+            if (RequestService.CheckRequest(showId))
-            if (s.CheckRequest(showId))
             {
                 return Response.AsJson(new { Result = false, Message = "TV Show has already been requested!" });
             }
@@ -251,7 +257,7 @@ namespace PlexRequests.UI.Modules
                 RequestedBy = Session[SessionKeys.UsernameKey].ToString()
             };
 
-            s.AddRequest(showId, model);
+            RequestService.AddRequest(showId, model);
             return Response.AsJson(new { Result = true });
         }
         private string GetAuthToken(TheTvDbApi api)

PlexRequests.UI/PlexRequests.UI.csproj

@@ -61,16 +61,8 @@
       <HintPath>..\packages\Dapper.1.42\lib\net45\Dapper.dll</HintPath>
       <Private>True</Private>
     </Reference>
-    <Reference Include="Hangfire.Core, Version=1.5.3.0, Culture=neutral, processorArchitecture=MSIL">
+    <Reference Include="FluentScheduler, Version=3.1.46.0, Culture=neutral, PublicKeyToken=b76503528a14ebd1, processorArchitecture=MSIL">
-      <HintPath>..\packages\Hangfire.Core.1.5.3\lib\net45\Hangfire.Core.dll</HintPath>
+      <HintPath>..\packages\FluentScheduler.3.1.46\lib\net40\FluentScheduler.dll</HintPath>
-      <Private>True</Private>
-    </Reference>
-    <Reference Include="Hangfire.SQLite, Version=1.1.0.0, Culture=neutral, processorArchitecture=MSIL">
-      <HintPath>..\packages\Hangfire.SQLite.1.1.0.0\lib\net45\Hangfire.SQLite.dll</HintPath>
-      <Private>True</Private>
-    </Reference>
-    <Reference Include="Hangfire.SqlServer, Version=1.5.3.0, Culture=neutral, processorArchitecture=MSIL">
-      <HintPath>..\packages\Hangfire.SqlServer.1.5.3\lib\net45\Hangfire.SqlServer.dll</HintPath>
       <Private>True</Private>
     </Reference>
     <Reference Include="Humanizer, Version=2.0.1.0, Culture=neutral, PublicKeyToken=979442b78dfc278e, processorArchitecture=MSIL">
@@ -169,6 +161,10 @@
     <Content Include="Content\custom.css">
       <CopyToOutputDirectory>PreserveNewest</CopyToOutputDirectory>
     </Content>
+    <Compile Include="Jobs\IAvailabilityChecker.cs" />
+    <Compile Include="Jobs\PlexAvailabilityChecker.cs" />
+    <Compile Include="Jobs\PlexRegistry.cs" />
+    <Compile Include="Jobs\TaskFactory.cs" />
     <Compile Include="Models\PlexAuth.cs" />
     <Compile Include="Models\RequestViewModel.cs" />
     <Compile Include="Models\SearchTvShowViewModel.cs" />

PlexRequests.UI/Startup.cs

@@ -25,10 +25,10 @@
 //  ************************************************************************/
 #endregion
 using System;
-using Hangfire;
+using FluentScheduler;
-using Hangfire.SQLite;
 using Owin;
-using PlexRequests.Core;
+using PlexRequests.UI.Jobs;
+using TaskFactory = FluentScheduler.TaskFactory;
 
 namespace PlexRequests.UI
 {
@@ -40,10 +40,6 @@ namespace PlexRequests.UI
             {
                 app.UseNancy();
 
-                //GlobalConfiguration.Configuration.UseSQLiteStorage("Sqlite");
-
-                //app.UseHangfireDashboard();
-                //app.UseHangfireServer();
 
             }
             catch (Exception exception)

PlexRequests.UI/app.config

@@ -10,7 +10,9 @@
     
     <add key="ClientSettingsProvider.ServiceUri" value="" />
   <add key="webPages:Enabled" value="false" /></appSettings>
-  
+  <connectionStrings>
+    <add name="Sqlite" connectionString="Data Source=RequestPlex.sqlite" providerName="Mono.Data.Sqlite" />
+  </connectionStrings>
   <system.web>
     <membership defaultProvider="ClientAuthenticationMembershipProvider">
       <providers>

PlexRequests.UI/packages.config

@@ -1,10 +1,7 @@
 <?xml version="1.0" encoding="utf-8"?>
 <packages>
   <package id="Dapper" version="1.42" targetFramework="net46" />
-  <package id="Hangfire" version="1.5.3" targetFramework="net46" />
+  <package id="FluentScheduler" version="3.1.46" targetFramework="net46" />
-  <package id="Hangfire.Core" version="1.5.3" targetFramework="net46" />
-  <package id="Hangfire.SQLite" version="1.1.0.0" targetFramework="net46" />
-  <package id="Hangfire.SqlServer" version="1.5.3" targetFramework="net46" />
   <package id="Humanizer.Core" version="2.0.1" targetFramework="net452" />
   <package id="Microsoft.AspNet.Razor" version="2.0.30506.0" targetFramework="net452" />
   <package id="Microsoft.Owin" version="3.0.1" targetFramework="net452" />

PlexRequests.UI/web.config

@@ -27,7 +27,7 @@
     </httpHandlers>
   </system.web>
   <connectionStrings>
-    <add name="Sqlite" connectionString="Data Source=RequestPlex.sqlite"/>
+    <add name="Sqlite" connectionString="Data Source=RequestPlex.sqlite" providerName="Mono.Data.Sqlite"/>
   </connectionStrings>
   <appSettings>
     <add key="webPages:Enabled" value="false" />