Ombi/Ombi.UI/Modules/ApprovalModule.cs

#region Copyright
// /************************************************************************
//    Copyright (c) 2016 Jamie Rees
//    File: ApprovalModule.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.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
using Nancy;
using NLog;
using Ombi.Api.Interfaces;
using Ombi.Core;
using Ombi.Core.Queue;
using Ombi.Core.SettingModels;
using Ombi.Helpers;
using Ombi.Helpers.Permissions;
using Ombi.Store;
using Ombi.UI.Helpers;
using Ombi.UI.Models;
using ISecurityExtensions = Ombi.Core.ISecurityExtensions;

namespace Ombi.UI.Modules
{
    public class ApprovalModule : BaseAuthModule
    {

        public ApprovalModule(IRequestService service,  ISonarrApi sonarrApi,
            ISettingsService<SonarrSettings> sonarrSettings, ISickRageApi srApi, ISettingsService<SickRageSettings> srSettings,
            ISettingsService<HeadphonesSettings> hpSettings, IHeadphonesApi hpApi, ISettingsService<PlexRequestSettings> pr, ITransientFaultQueue faultQueue
            , ISecurityExtensions security, IMovieSender movieSender, ICacheProvider cache) : base("approval", pr, security)
        {

            Before += (ctx) => Security.AdminLoginRedirect(ctx, Permissions.Administrator,Permissions.ManageRequests);

            Service = service;
            SonarrApi = sonarrApi;
            SonarrSettings = sonarrSettings;
            SickRageApi = srApi;
            SickRageSettings = srSettings;
            HeadphonesSettings = hpSettings;
            HeadphoneApi = hpApi;
            FaultQueue = faultQueue;
            MovieSender = movieSender;
            Cache = cache;

            Post["/approve", true] = async (x, ct) => await Approve((int)Request.Form.requestid, (string)Request.Form.qualityId);
            Post["/deny", true] = async (x, ct) => await DenyRequest((int)Request.Form.requestid, (string)Request.Form.reason);
            Post["/approveall", true] = async (x, ct) => await ApproveAll();
            Post["/approveallmovies", true] = async (x, ct) => await ApproveAllMovies();
            Post["/approvealltvshows", true] = async (x, ct) => await ApproveAllTVShows();
            Post["/deleteallmovies", true] = async (x, ct) => await DeleteAllMovies();
            Post["/deletealltvshows", true] = async (x, ct) => await DeleteAllTVShows();
            Post["/deleteallalbums", true] = async (x, ct) => await DeleteAllAlbums();
        }

        private IRequestService Service { get; }
        private IMovieSender MovieSender { get; }

        private static Logger Log = LogManager.GetCurrentClassLogger();
        private ISettingsService<SonarrSettings> SonarrSettings { get; }
        private ISettingsService<SickRageSettings> SickRageSettings { get; }
        private ISettingsService<HeadphonesSettings> HeadphonesSettings { get; }
        private ISonarrApi SonarrApi { get; }
        private ISickRageApi SickRageApi { get; }
        private IHeadphonesApi HeadphoneApi { get; }
        private ITransientFaultQueue FaultQueue { get; }
        private ICacheProvider Cache { get; }

        /// <summary>
        /// Approves the specified request identifier.
        /// </summary>
        /// <param name="requestId">The request identifier.</param>
        /// <returns></returns>
        private async Task<Response> Approve(int requestId, string qualityId)
        {
            Log.Info("approving request {0}", requestId);

            // Get the request from the DB
            var request = await Service.GetAsync(requestId);

            if (request == null)
            {
                Log.Warn("Tried approving a request, but the request did not exist in the database, requestId = {0}", requestId);
                return Response.AsJson(new JsonResponseModel { Result = false, Message = "There are no requests to approve. Please refresh." });
            }

            switch (request.Type)
            {
                case RequestType.Movie:
                    return await RequestMovieAndUpdateStatus(request, qualityId);
                case RequestType.TvShow:
                    return await RequestTvAndUpdateStatus(request, qualityId);
                case RequestType.Album:
                    return await RequestAlbumAndUpdateStatus(request);
                default:
                    throw new ArgumentOutOfRangeException(nameof(request));
            }
        }

        private async Task<Response> RequestTvAndUpdateStatus(RequestedModel request, string qualityId)
        {
            var sender = new TvSenderOld(SonarrApi, SickRageApi, Cache); // TODO put back

            var sonarrSettings = await SonarrSettings.GetSettingsAsync();
            if (sonarrSettings.Enabled)
            {
                Log.Trace("Sending to Sonarr");
                var result = await sender.SendToSonarr(sonarrSettings, request, qualityId);
                Log.Trace("Sonarr Result: ");
                Log.Trace(result.DumpJson());
                if (!string.IsNullOrEmpty(result.title))
                {
                    Log.Info("Sent successfully, Approving request now.");
                    request.Approved = true;
                    var requestResult = await Service.UpdateRequestAsync(request);
                    Log.Trace("Approval result: {0}", requestResult);
                    if (requestResult)
                    {
                        return Response.AsJson(new JsonResponseModel { Result = true });
                    }
                    return
                        Response.AsJson(new JsonResponseModel
                        {
                            Result = false,
                            Message = "Updated Sonarr but could not approve it in PlexRequests :("
                        });
                }
                return Response.AsJson(ValidationHelper.SendSonarrError(result.ErrorMessages));

            }

            var srSettings = await SickRageSettings.GetSettingsAsync();
            if (srSettings.Enabled)
            {
                Log.Trace("Sending to SickRage");
                var result = sender.SendToSickRage(srSettings, request, qualityId);
                Log.Trace("SickRage Result: ");
                Log.Trace(result.DumpJson());
                if (result?.result == "success")
                {
                    Log.Info("Sent successfully, Approving request now.");
                    request.Approved = true;
                    var requestResult = await Service.UpdateRequestAsync(request);
                    Log.Trace("Approval result: {0}", requestResult);
                    return Response.AsJson(requestResult
                        ? new JsonResponseModel { Result = true }
                        : new JsonResponseModel { Result = false, Message = "Updated SickRage but could not approve it in PlexRequests :(" });
                }
                return Response.AsJson(new JsonResponseModel
                {
                    Result = false,
                    Message = result?.message != null ? "<b>Message From SickRage: </b>" + result.message : "Could not add the series to SickRage"
                });
            }


            request.Approved = true;
            var res = await Service.UpdateRequestAsync(request);
            return Response.AsJson(res
                ? new JsonResponseModel { Result = true, Message = "This has been approved, but It has not been sent to Sonarr/SickRage because it has not been configured" }
                : new JsonResponseModel { Result = false, Message = "Updated SickRage but could not approve it in PlexRequests :(" });
        }

        private async Task<Response> RequestMovieAndUpdateStatus(RequestedModel request, string qualityId)
        {

            var result = await MovieSender.Send(request, qualityId);

            if (!result.MovieSendingEnabled)
            {
                // Approve it
                request.Approved = true;
                Log.Warn("We approved movie: {0} but could not add it to CouchPotato/Watcher/Radarr because it has not been setup", request.Title);

                // Update the record
                var inserted = await Service.UpdateRequestAsync(request);
                return Response.AsJson(inserted
                    ? new JsonResponseModel { Result = true, Message = "This has been approved, but It has not been sent to CouchPotato/Watcher because it has not been configured." }
                    : new JsonResponseModel
                    {
                        Result = false,
                        Message = "We could not approve this request. Please try again or check the logs."
                    });
            }

            if (result.Result)
            {
                // Approve it
                request.Approved = true;

                // Update the record
                var inserted = await Service.UpdateRequestAsync(request);

                return Response.AsJson(inserted
                    ? new JsonResponseModel { Result = true }
                    : new JsonResponseModel
                    {
                        Result = false,
                        Message = "We could not approve this request. Please try again or check the logs."
                    });
            }
            return
                Response.AsJson(
                    new
                    {
                        Result = false,
                        Message =
                            "Something went wrong adding the movie! Please check your settings."
                    });
        }

        private async Task<Response> RequestAlbumAndUpdateStatus(RequestedModel request)
        {
            var hpSettings = await HeadphonesSettings.GetSettingsAsync();
            Log.Info("Adding album to Headphones : {0}", request.Title);
            if (!hpSettings.Enabled)
            {
                // Approve it
                request.Approved = true;
                Log.Warn("We approved Album: {0} but could not add it to Headphones because it has not been setup", request.Title);

                // Update the record
                var inserted = await Service.UpdateRequestAsync(request);
                return Response.AsJson(inserted
                    ? new JsonResponseModel { Result = true, Message = "This has been approved, but It has not been sent to Headphones because it has not been configured." }
                    : new JsonResponseModel
                    {
                        Result = false,
                        Message = "We could not approve this request. Please try again or check the logs."
                    });
            }

            var sender = new HeadphonesSender(HeadphoneApi, hpSettings, Service);
            var result = sender.AddAlbum(request);


            return Response.AsJson(new JsonResponseModel { Result = true, Message = "We have sent the approval to Headphones for processing, This can take a few minutes." });
        }

        private async Task<Response> ApproveAllMovies()
        {

            var requests = await Service.GetAllAsync();
            requests = requests.Where(x => x.CanApprove && x.Type == RequestType.Movie);
            var requestedModels = requests as RequestedModel[] ?? requests.ToArray();
            if (!requestedModels.Any())
            {
                return Response.AsJson(new JsonResponseModel { Result = false, Message = "There are no movie requests to approve. Please refresh." });
            }

            try
            {
                return await UpdateRequestsAsync(requestedModels);
            }
            catch (Exception e)
            {
                Log.Fatal(e);
                return Response.AsJson(new JsonResponseModel { Result = false, Message = "Something bad happened, please check the logs!" });
            }
        }

        private async Task<Response> DeleteAllMovies()
        {

            var requests = await Service.GetAllAsync();
            requests = requests.Where(x => x.Type == RequestType.Movie);
            var requestedModels = requests as RequestedModel[] ?? requests.ToArray();
            if (!requestedModels.Any())
            {
                return Response.AsJson(new JsonResponseModel { Result = false, Message = "There are no movie requests to delete. Please refresh." });
            }

            try
            {
                return await DeleteRequestsAsync(requestedModels);
            }
            catch (Exception e)
            {
                Log.Fatal(e);
                return Response.AsJson(new JsonResponseModel { Result = false, Message = "Something bad happened, please check the logs!" });
            }
        }

        private async Task<Response> DeleteAllAlbums()
        {

            var requests = await Service.GetAllAsync();
            requests = requests.Where(x => x.Type == RequestType.Album);
            var requestedModels = requests as RequestedModel[] ?? requests.ToArray();
            if (!requestedModels.Any())
            {
                return Response.AsJson(new JsonResponseModel { Result = false, Message = "There are no album requests to delete. Please refresh." });
            }

            try
            {
                return await DeleteRequestsAsync(requestedModels);
            }
            catch (Exception e)
            {
                Log.Fatal(e);
                return Response.AsJson(new JsonResponseModel { Result = false, Message = "Something bad happened, please check the logs!" });
            }
        }

        private async Task<Response> ApproveAllTVShows()
        {
            var requests = await Service.GetAllAsync();
            requests = requests.Where(x => x.CanApprove && x.Type == RequestType.TvShow);
            var requestedModels = requests as RequestedModel[] ?? requests.ToArray();
            if (!requestedModels.Any())
            {
                return Response.AsJson(new JsonResponseModel { Result = false, Message = "There are no tv show requests to approve. Please refresh." });
            }

            try
            {
                return await UpdateRequestsAsync(requestedModels);
            }
            catch (Exception e)
            {
                Log.Fatal(e);
                return Response.AsJson(new JsonResponseModel { Result = false, Message = "Something bad happened, please check the logs!" });
            }
        }

        private async Task<Response> DeleteAllTVShows()
        {

            var requests = await Service.GetAllAsync();
            requests = requests.Where(x => x.Type == RequestType.TvShow);
            var requestedModels = requests as RequestedModel[] ?? requests.ToArray();
            if (!requestedModels.Any())
            {
                return Response.AsJson(new JsonResponseModel { Result = false, Message = "There are no tv show requests to delete. Please refresh." });
            }

            try
            {
                return await DeleteRequestsAsync(requestedModels);
            }
            catch (Exception e)
            {
                Log.Fatal(e);
                return Response.AsJson(new JsonResponseModel { Result = false, Message = "Something bad happened, please check the logs!" });
            }
        }

        /// <summary>
        /// Approves all.
        /// </summary>
        /// <returns></returns>
        private async Task<Response> ApproveAll()
        {
            var requests = await Service.GetAllAsync();
            requests = requests.Where(x => x.CanApprove);
            var requestedModels = requests as RequestedModel[] ?? requests.ToArray();
            if (!requestedModels.Any())
            {
                return Response.AsJson(new JsonResponseModel { Result = false, Message = "There are no requests to approve. Please refresh." });
            }

            try
            {
                return await UpdateRequestsAsync(requestedModels);
            }
            catch (Exception e)
            {
                Log.Fatal(e);
                return Response.AsJson(new JsonResponseModel { Result = false, Message = "Something bad happened, please check the logs!" });
            }

        }

        private async Task<Response> DeleteRequestsAsync(IEnumerable<RequestedModel> requestedModels)
        {
            try
            {
                var result = await Service.BatchDeleteAsync(requestedModels);
                return Response.AsJson(result
                    ? new JsonResponseModel { Result = true }
                    : new JsonResponseModel { Result = false, Message = "We could not delete all of the requests. Please try again or check the logs." });
            }
            catch (Exception e)
            {
                Log.Fatal(e);
                return Response.AsJson(new JsonResponseModel { Result = false, Message = "Something bad happened, please check the logs!" });
            }
        }

        private async Task<Response> UpdateRequestsAsync(RequestedModel[] requestedModels)
        {
            var updatedRequests = new List<RequestedModel>();
            foreach (var r in requestedModels)
            {
                if (r.Type == RequestType.Movie)
                {
                    var movieResult = await MovieSender.Send(r);
                    if (movieResult.Result)
                    {
                        r.Approved = true;
                        updatedRequests.Add(r);

                    }
                    else
                    {
                        Log.Error("Could not approve and send the movie {0} to couch potato!", r.Title);
                    }
                    if(!movieResult.MovieSendingEnabled)
                    {
                        r.Approved = true;
                        updatedRequests.Add(r);
                    }
                }
                if (r.Type == RequestType.TvShow)
                {
                    var sender = new TvSenderOld(SonarrApi, SickRageApi, Cache); // TODO put back
                    var sr = await SickRageSettings.GetSettingsAsync();
                    var sonarr = await SonarrSettings.GetSettingsAsync();
                    if (sr.Enabled)
                    {
                        var res = sender.SendToSickRage(sr, r);
                        if (res?.result == "success")
                        {
                            r.Approved = true;
                            updatedRequests.Add(r);
                        }
                        else
                        {
                            Log.Error("Could not approve and send the TV {0} to SickRage!", r.Title);
                            Log.Error("SickRage Message: {0}", res?.message);
                        }
                    }

                    else if (sonarr.Enabled)
                    {
                        var res = await sender.SendToSonarr(sonarr, r);
                        if (!string.IsNullOrEmpty(res?.title))
                        {
                            r.Approved = true;
                            updatedRequests.Add(r);
                        }
                        else
                        {
                            Log.Error("Could not approve and send the TV {0} to Sonarr!", r.Title);
                            res?.ErrorMessages?.ForEach(x => Log.Error("Error messages: {0}", x));
                        }
                    }
                    else
                    {
                        r.Approved = true;
                        updatedRequests.Add(r);
                    }
                }
            }
            try
            {
                var result = await Service.BatchUpdateAsync(updatedRequests);
                return Response.AsJson(result
                    ? new JsonResponseModel { Result = true }
                    : new JsonResponseModel { Result = false, Message = "We could not approve all of the requests. Please try again or check the logs." });
            }
            catch (Exception e)
            {
                Log.Fatal(e);
                return Response.AsJson(new JsonResponseModel { Result = false, Message = "Something bad happened, please check the logs!" });
            }
        }

        private async Task<Response> DenyRequest(int requestId, string reason)
        {
            // Get the request from the DB
            var request = await Service.GetAsync(requestId);

            // Deny it
            request.Denied = true;
            request.DeniedReason = reason;

            // Update the new value
            var result = await Service.UpdateRequestAsync(request);

            return result
                ? Response.AsJson(new JsonResponseModel { Result = true, Message = "Request has been denied" })
                : Response.AsJson(new JsonResponseModel { Result = false, Message = "An error happened, could not update the DB" });

        }
    }
}