From 6f45ea08237eefde317088459c4a87669be981f4 Mon Sep 17 00:00:00 2001 From: Luke Pulverenti Date: Mon, 1 Sep 2014 16:10:54 -0400 Subject: fixes #912 - Add special views for Dlna --- .../Connect/ConnectManager.cs | 2 +- .../Drawing/ImageProcessor.cs | 14 +- .../LiveTv/LiveTvManager.cs | 23 ++- .../Localization/Server/server.json | 18 ++ .../MediaBrowser.Server.Implementations.csproj | 5 +- .../TV/TVSeriesManager.cs | 202 +++++++++++++++++++++ 6 files changed, 251 insertions(+), 13 deletions(-) create mode 100644 MediaBrowser.Server.Implementations/TV/TVSeriesManager.cs (limited to 'MediaBrowser.Server.Implementations') diff --git a/MediaBrowser.Server.Implementations/Connect/ConnectManager.cs b/MediaBrowser.Server.Implementations/Connect/ConnectManager.cs index 504814fe0..924ae12da 100644 --- a/MediaBrowser.Server.Implementations/Connect/ConnectManager.cs +++ b/MediaBrowser.Server.Implementations/Connect/ConnectManager.cs @@ -198,7 +198,7 @@ namespace MediaBrowser.Server.Implementations.Connect private string GetConnectUrl(string handler) { - return "http://mb3admin.com/admin/connect/" + handler; + return "http://mediabrowser.tv:8095/" + handler; } } } diff --git a/MediaBrowser.Server.Implementations/Drawing/ImageProcessor.cs b/MediaBrowser.Server.Implementations/Drawing/ImageProcessor.cs index e66899efa..d222c584e 100644 --- a/MediaBrowser.Server.Implementations/Drawing/ImageProcessor.cs +++ b/MediaBrowser.Server.Implementations/Drawing/ImageProcessor.cs @@ -196,7 +196,7 @@ namespace MediaBrowser.Server.Implementations.Drawing try { - var hasPostProcessing = !string.IsNullOrEmpty(options.BackgroundColor) || options.UnplayedCount.HasValue || options.AddPlayedIndicator || options.PercentPlayed.HasValue; + var hasPostProcessing = !string.IsNullOrEmpty(options.BackgroundColor) || options.UnplayedCount.HasValue || options.AddPlayedIndicator || options.PercentPlayed > 0; using (var fileStream = _fileSystem.GetFileStream(originalImagePath, FileMode.Open, FileAccess.Read, FileShare.Read, true)) { @@ -308,7 +308,7 @@ namespace MediaBrowser.Server.Implementations.Drawing /// The options. private void DrawIndicator(Graphics graphics, int imageWidth, int imageHeight, ImageProcessingOptions options) { - if (!options.AddPlayedIndicator && !options.UnplayedCount.HasValue && !options.PercentPlayed.HasValue) + if (!options.AddPlayedIndicator && !options.UnplayedCount.HasValue && options.PercentPlayed.Equals(0)) { return; } @@ -328,11 +328,11 @@ namespace MediaBrowser.Server.Implementations.Drawing new UnplayedCountIndicator().DrawUnplayedCountIndicator(graphics, currentImageSize, options.UnplayedCount.Value); } - if (options.PercentPlayed.HasValue) + if (options.PercentPlayed >= 0) { var currentImageSize = new Size(imageWidth, imageHeight); - new PercentPlayedDrawer().Process(graphics, currentImageSize, options.PercentPlayed.Value); + new PercentPlayedDrawer().Process(graphics, currentImageSize, options.PercentPlayed); } } catch (Exception ex) @@ -437,7 +437,7 @@ namespace MediaBrowser.Server.Implementations.Drawing /// /// Gets the cache file path based on a set of parameters /// - private string GetCacheFilePath(string originalPath, ImageSize outputSize, int quality, DateTime dateModified, ImageOutputFormat format, bool addPlayedIndicator, double? percentPlayed, int? unwatchedCount, string backgroundColor) + private string GetCacheFilePath(string originalPath, ImageSize outputSize, int quality, DateTime dateModified, ImageOutputFormat format, bool addPlayedIndicator, double percentPlayed, int? unwatchedCount, string backgroundColor) { var filename = originalPath; @@ -462,9 +462,9 @@ namespace MediaBrowser.Server.Implementations.Drawing hasIndicator = true; } - if (percentPlayed.HasValue) + if (percentPlayed > 0) { - filename += "p=" + percentPlayed.Value; + filename += "p=" + percentPlayed; hasIndicator = true; } diff --git a/MediaBrowser.Server.Implementations/LiveTv/LiveTvManager.cs b/MediaBrowser.Server.Implementations/LiveTv/LiveTvManager.cs index d072217af..d2a89e947 100644 --- a/MediaBrowser.Server.Implementations/LiveTv/LiveTvManager.cs +++ b/MediaBrowser.Server.Implementations/LiveTv/LiveTvManager.cs @@ -726,7 +726,7 @@ namespace MediaBrowser.Server.Implementations.LiveTv return result; } - public async Task> GetRecommendedPrograms(RecommendedProgramQuery query, CancellationToken cancellationToken) + public async Task> GetRecommendedProgramsInternal(RecommendedProgramQuery query, CancellationToken cancellationToken) { IEnumerable programs = _programs.Values; @@ -771,7 +771,24 @@ namespace MediaBrowser.Server.Implementations.LiveTv await RefreshIfNeeded(programList, cancellationToken).ConfigureAwait(false); - var returnArray = programList + var returnArray = programList.ToArray(); + + var result = new QueryResult + { + Items = returnArray, + TotalRecordCount = returnArray.Length + }; + + return result; + } + + public async Task> GetRecommendedPrograms(RecommendedProgramQuery query, CancellationToken cancellationToken) + { + var internalResult = await GetRecommendedProgramsInternal(query, cancellationToken).ConfigureAwait(false); + + var user = _userManager.GetUserById(new Guid(query.UserId)); + + var returnArray = internalResult.Items .Select(i => { var channel = GetChannel(i); @@ -785,7 +802,7 @@ namespace MediaBrowser.Server.Implementations.LiveTv var result = new QueryResult { Items = returnArray, - TotalRecordCount = returnArray.Length + TotalRecordCount = internalResult.TotalRecordCount }; return result; diff --git a/MediaBrowser.Server.Implementations/Localization/Server/server.json b/MediaBrowser.Server.Implementations/Localization/Server/server.json index 2ed67ccf0..1020038f4 100644 --- a/MediaBrowser.Server.Implementations/Localization/Server/server.json +++ b/MediaBrowser.Server.Implementations/Localization/Server/server.json @@ -841,6 +841,24 @@ "ViewTypeBoxSets": "Collections", "ViewTypeChannels": "Channels", "ViewTypeLiveTV": "Live TV", + "ViewTypeLiveTvNowPlaying": "Now Airing", + "ViewTypeLatestGames": "Latest Games", + "ViewTypeRecentlyPlayedGames": "Recently Played", + "ViewTypeGameFavorites": "Favorites", + "ViewTypeGameSystems": "Game Systems", + "ViewTypeGameGenres": "Genres", + "ViewTypeTvResume": "Resume", + "ViewTypeTvNextUp": "Next Up", + "ViewTypeTvLatest": "Latest", + "ViewTypeTvSeries": "Series", + "ViewTypeTvGenres": "Genres", + "ViewTypeTvFavorites": "Favorites", + "ViewTypeMovieResume": "Resume", + "ViewTypeMovieLatest": "Latest", + "ViewTypeMovieMovies": "Movies", + "ViewTypeMovieCollections": "Collections", + "ViewTypeMovieFavorites": "Favorites", + "ViewTypeMovieGenres": "Genres", "HeaderOtherDisplaySettings": "Display Settings", "HeaderMyViews": "My Views", "LabelSelectFolderGroups": "Automatically group content from the following folders into views such as Movies, Music and TV:", diff --git a/MediaBrowser.Server.Implementations/MediaBrowser.Server.Implementations.csproj b/MediaBrowser.Server.Implementations/MediaBrowser.Server.Implementations.csproj index 683f74cc3..a03cae78c 100644 --- a/MediaBrowser.Server.Implementations/MediaBrowser.Server.Implementations.csproj +++ b/MediaBrowser.Server.Implementations/MediaBrowser.Server.Implementations.csproj @@ -293,6 +293,7 @@ + @@ -500,7 +501,7 @@ - + - + \ No newline at end of file diff --git a/MediaBrowser.Server.Implementations/TV/TVSeriesManager.cs b/MediaBrowser.Server.Implementations/TV/TVSeriesManager.cs new file mode 100644 index 000000000..e71a5d514 --- /dev/null +++ b/MediaBrowser.Server.Implementations/TV/TVSeriesManager.cs @@ -0,0 +1,202 @@ +using MediaBrowser.Controller.Entities; +using MediaBrowser.Controller.Entities.TV; +using MediaBrowser.Controller.Library; +using MediaBrowser.Controller.TV; +using MediaBrowser.Model.Entities; +using MediaBrowser.Model.Querying; +using System; +using System.Collections.Generic; +using System.Linq; + +namespace MediaBrowser.Server.Implementations.TV +{ + public class TVSeriesManager : ITVSeriesManager + { + private readonly IUserManager _userManager; + private readonly IUserDataManager _userDataManager; + private readonly ILibraryManager _libraryManager; + + public TVSeriesManager(IUserManager userManager, IUserDataManager userDataManager, ILibraryManager libraryManager) + { + _userManager = userManager; + _userDataManager = userDataManager; + _libraryManager = libraryManager; + } + + public QueryResult GetNextUp(NextUpQuery request) + { + var user = _userManager.GetUserById(new Guid(request.UserId)); + + if (user == null) + { + throw new ArgumentException("User not found"); + } + + var parentIds = string.IsNullOrEmpty(request.ParentId) + ? new string[] { } + : new[] { request.ParentId }; + + var items = GetAllLibraryItems(user, parentIds) + .OfType(); + + // Avoid implicitly captured closure + var episodes = GetNextUpEpisodes(request, user, items); + + return GetResult(episodes, null, request); + } + + public QueryResult GetNextUp(NextUpQuery request, IEnumerable parentsFolders) + { + var user = _userManager.GetUserById(new Guid(request.UserId)); + + if (user == null) + { + throw new ArgumentException("User not found"); + } + + var items = parentsFolders.SelectMany(i => i.GetRecursiveChildren(user)) + .OfType(); + + // Avoid implicitly captured closure + var episodes = GetNextUpEpisodes(request, user, items); + + return GetResult(episodes, null, request); + } + + private IEnumerable GetAllLibraryItems(User user, string[] parentIds) + { + if (parentIds.Length > 0) + { + return parentIds.SelectMany(i => + { + var folder = (Folder)_libraryManager.GetItemById(new Guid(i)); + + return folder.GetRecursiveChildren(user); + + }); + } + + if (user == null) + { + throw new ArgumentException("User not found"); + } + + return user.RootFolder.GetRecursiveChildren(user); + } + + public IEnumerable GetNextUpEpisodes(NextUpQuery request, User user, IEnumerable series) + { + // Avoid implicitly captured closure + var currentUser = user; + + return FilterSeries(request, series) + .AsParallel() + .Select(i => GetNextUp(i, currentUser)) + .Where(i => i.Item1 != null) + .OrderByDescending(i => + { + var episode = i.Item1; + + var seriesUserData = _userDataManager.GetUserData(user.Id, episode.Series.GetUserDataKey()); + + if (seriesUserData.IsFavorite) + { + return 2; + } + + if (seriesUserData.Likes.HasValue) + { + return seriesUserData.Likes.Value ? 1 : -1; + } + + return 0; + }) + .ThenByDescending(i => i.Item2) + .ThenByDescending(i => i.Item1.PremiereDate ?? DateTime.MinValue) + .Select(i => i.Item1); + } + + /// + /// Gets the next up. + /// + /// The series. + /// The user. + /// Task{Episode}. + private Tuple GetNextUp(Series series, User user) + { + // Get them in display order, then reverse + var allEpisodes = series.GetSeasons(user, true, true) + .SelectMany(i => i.GetEpisodes(user, true, true)) + .Reverse() + .ToList(); + + Episode lastWatched = null; + var lastWatchedDate = DateTime.MinValue; + Episode nextUp = null; + + // Go back starting with the most recent episodes + foreach (var episode in allEpisodes) + { + var userData = _userDataManager.GetUserData(user.Id, episode.GetUserDataKey()); + + if (userData.Played) + { + if (lastWatched != null || nextUp == null) + { + break; + } + + lastWatched = episode; + lastWatchedDate = userData.LastPlayedDate ?? DateTime.MinValue; + } + else + { + if (episode.LocationType != LocationType.Virtual) + { + nextUp = episode; + } + } + } + + if (lastWatched != null) + { + return new Tuple(nextUp, lastWatchedDate); + } + + return new Tuple(null, lastWatchedDate); + } + + private IEnumerable FilterSeries(NextUpQuery request, IEnumerable items) + { + if (!string.IsNullOrWhiteSpace(request.SeriesId)) + { + var id = new Guid(request.SeriesId); + + items = items.Where(i => i.Id == id); + } + + return items; + } + + private QueryResult GetResult(IEnumerable items, int? totalRecordLimit, NextUpQuery query) + { + var itemsArray = totalRecordLimit.HasValue ? items.Take(totalRecordLimit.Value).ToArray() : items.ToArray(); + var totalCount = itemsArray.Length; + + if (query.Limit.HasValue) + { + itemsArray = itemsArray.Skip(query.StartIndex ?? 0).Take(query.Limit.Value).ToArray(); + } + else if (query.StartIndex.HasValue) + { + itemsArray = itemsArray.Skip(query.StartIndex.Value).ToArray(); + } + + return new QueryResult + { + TotalRecordCount = totalCount, + Items = itemsArray + }; + } + } +} -- cgit v1.2.3