using System.Linq; using System.Collections.Generic; using NzbDrone.Core.Profiles.Delay; using NzbDrone.Core.Languages; namespace NzbDrone.Core.DecisionEngine { public interface IPrioritizeDownloadDecision { List PrioritizeDecisions(List decisions); } public class DownloadDecisionPriorizationService : IPrioritizeDownloadDecision { private readonly IDelayProfileService _delayProfileService; public DownloadDecisionPriorizationService(IDelayProfileService delayProfileService) { _delayProfileService = delayProfileService; } public List PrioritizeDecisions(List decisions) { return decisions.Where(c => c.RemoteAlbum.DownloadAllowed) .GroupBy(c => c.RemoteAlbum.Artist.Id, (artistId, downloadDecisions) => { return downloadDecisions.OrderByDescending(decision => decision, new DownloadDecisionComparer(_delayProfileService)); }) .SelectMany(c => c) .Union(decisions.Where(c => !c.RemoteAlbum.DownloadAllowed)) .ToList(); } } }