From 4ae713518b124d7092c0cae9b7c793b0952ce85b Mon Sep 17 00:00:00 2001 From: Luke Pulverenti Date: Thu, 27 Jun 2013 15:06:37 -0400 Subject: [PATCH] extracted an ItemUpdateService --- MediaBrowser.Api/ItemUpdateService.cs | 255 +++++++++++++++++++++++ MediaBrowser.Api/LibraryService.cs | 228 -------------------- MediaBrowser.Api/MediaBrowser.Api.csproj | 1 + 3 files changed, 256 insertions(+), 228 deletions(-) create mode 100644 MediaBrowser.Api/ItemUpdateService.cs diff --git a/MediaBrowser.Api/ItemUpdateService.cs b/MediaBrowser.Api/ItemUpdateService.cs new file mode 100644 index 0000000000..08c46d3e04 --- /dev/null +++ b/MediaBrowser.Api/ItemUpdateService.cs @@ -0,0 +1,255 @@ +using System; +using System.Linq; +using System.Threading; +using System.Threading.Tasks; +using MediaBrowser.Controller.Dto; +using MediaBrowser.Controller.Entities; +using MediaBrowser.Controller.Entities.Audio; +using MediaBrowser.Controller.Entities.TV; +using MediaBrowser.Controller.Library; +using MediaBrowser.Model.Dto; +using ServiceStack.ServiceHost; + +namespace MediaBrowser.Api +{ + [Route("/Items/{ItemId}", "POST")] + [Api(("Updates an item"))] + public class UpdateItem : BaseItemDto, IReturnVoid + { + [ApiMember(Name = "ItemId", Description = "The id of the item", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "POST")] + public string ItemId { get; set; } + } + + [Route("/Artists/{ArtistName}", "POST")] + [Api(("Updates an artist"))] + public class UpdateArtist : BaseItemDto, IReturnVoid + { + [ApiMember(Name = "ArtistName", Description = "The name of the item", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "POST")] + public string ArtistName { get; set; } + } + + [Route("/Studios/{StudioName}", "POST")] + [Api(("Updates a studio"))] + public class UpdateStudio : BaseItemDto, IReturnVoid + { + [ApiMember(Name = "StudioName", Description = "The name of the item", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "POST")] + public string StudioName { get; set; } + } + + [Route("/Persons/{PersonName}", "POST")] + [Api(("Updates a person"))] + public class UpdatePerson : BaseItemDto, IReturnVoid + { + [ApiMember(Name = "PersonName", Description = "The name of the item", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "POST")] + public string PersonName { get; set; } + } + + [Route("/MusicGenres/{GenreName}", "POST")] + [Api(("Updates a music genre"))] + public class UpdateMusicGenre : BaseItemDto, IReturnVoid + { + [ApiMember(Name = "GenreName", Description = "The name of the item", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "POST")] + public string GenreName { get; set; } + } + + [Route("/Genres/{GenreName}", "POST")] + [Api(("Updates a genre"))] + public class UpdateGenre : BaseItemDto, IReturnVoid + { + [ApiMember(Name = "GenreName", Description = "The name of the item", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "POST")] + public string GenreName { get; set; } + } + + public class ItemUpdateService : BaseApiService + { + private readonly ILibraryManager _libraryManager; + private readonly IUserManager _userManager; + + public ItemUpdateService(ILibraryManager libraryManager, IUserManager userManager) + { + _libraryManager = libraryManager; + _userManager = userManager; + } + + public void Post(UpdateItem request) + { + var task = UpdateItem(request); + + Task.WaitAll(task); + } + + private Task UpdateItem(UpdateItem request) + { + var item = DtoBuilder.GetItemByClientId(request.ItemId, _userManager, _libraryManager); + + UpdateItem(request, item); + + return _libraryManager.UpdateItem(item, ItemUpdateType.MetadataEdit, CancellationToken.None); + } + + public void Post(UpdatePerson request) + { + var task = UpdateItem(request); + + Task.WaitAll(task); + } + + private async Task UpdateItem(UpdatePerson request) + { + var item = await _libraryManager.GetPerson(request.PersonName).ConfigureAwait(false); + + UpdateItem(request, item); + + await _libraryManager.UpdateItem(item, ItemUpdateType.MetadataEdit, CancellationToken.None).ConfigureAwait(false); + } + + public void Post(UpdateArtist request) + { + var task = UpdateItem(request); + + Task.WaitAll(task); + } + + private async Task UpdateItem(UpdateArtist request) + { + var item = await _libraryManager.GetArtist(request.ArtistName).ConfigureAwait(false); + + UpdateItem(request, item); + + await _libraryManager.UpdateItem(item, ItemUpdateType.MetadataEdit, CancellationToken.None).ConfigureAwait(false); + } + + public void Post(UpdateStudio request) + { + var task = UpdateItem(request); + + Task.WaitAll(task); + } + + private async Task UpdateItem(UpdateStudio request) + { + var item = await _libraryManager.GetStudio(request.StudioName).ConfigureAwait(false); + + UpdateItem(request, item); + + await _libraryManager.UpdateItem(item, ItemUpdateType.MetadataEdit, CancellationToken.None).ConfigureAwait(false); + } + + public void Post(UpdateMusicGenre request) + { + var task = UpdateItem(request); + + Task.WaitAll(task); + } + + private async Task UpdateItem(UpdateMusicGenre request) + { + var item = await _libraryManager.GetMusicGenre(request.GenreName).ConfigureAwait(false); + + UpdateItem(request, item); + + await _libraryManager.UpdateItem(item, ItemUpdateType.MetadataEdit, CancellationToken.None).ConfigureAwait(false); + } + + public void Post(UpdateGenre request) + { + var task = UpdateItem(request); + + Task.WaitAll(task); + } + + private async Task UpdateItem(UpdateGenre request) + { + var item = await _libraryManager.GetGenre(request.GenreName).ConfigureAwait(false); + + UpdateItem(request, item); + + await _libraryManager.UpdateItem(item, ItemUpdateType.MetadataEdit, CancellationToken.None).ConfigureAwait(false); + } + + private void UpdateItem(BaseItemDto request, BaseItem item) + { + item.Name = request.Name; + + // Only set the forced value if they changed it, or there's already one + if (!string.Equals(item.SortName, request.SortName) || !string.IsNullOrEmpty(item.ForcedSortName)) + { + item.ForcedSortName = request.SortName; + } + + item.DisplayMediaType = request.DisplayMediaType; + item.CommunityRating = request.CommunityRating; + item.HomePageUrl = request.HomePageUrl; + item.Budget = request.Budget; + item.Revenue = request.Revenue; + item.CriticRating = request.CriticRating; + item.CriticRatingSummary = request.CriticRatingSummary; + item.IndexNumber = request.IndexNumber; + item.ParentIndexNumber = request.ParentIndexNumber; + item.Overview = request.Overview; + item.Genres = request.Genres; + item.Tags = request.Tags; + item.Studios = request.Studios.Select(x => x.Name).ToList(); + item.People = request.People.Select(x => new PersonInfo { Name = x.Name, Role = x.Role, Type = x.Type }).ToList(); + + item.EndDate = request.EndDate != default(DateTime) ? request.EndDate : null; + item.PremiereDate = request.PremiereDate != default(DateTime) ? request.PremiereDate : null; + item.ProductionYear = request.ProductionYear; + item.AspectRatio = request.AspectRatio; + item.Language = request.Language; + item.OfficialRating = request.OfficialRating; + item.CustomRating = request.CustomRating; + item.DontFetchMeta = !(request.EnableInternetProviders ?? true); + if (request.EnableInternetProviders ?? true) + { + item.LockedFields = request.LockedFields; + } + else + { + item.LockedFields.Clear(); + } + + foreach (var pair in request.ProviderIds.ToList()) + { + if (string.IsNullOrEmpty(pair.Value)) + { + request.ProviderIds.Remove(pair.Key); + } + } + + item.ProviderIds = request.ProviderIds; + + var game = item as Game; + + if (game != null) + { + game.PlayersSupported = request.Players; + } + + var song = item as Audio; + + if (song != null) + { + song.Album = request.Album; + song.AlbumArtist = request.AlbumArtist; + song.Artist = request.Artists[0]; + } + + var musicAlbum = item as MusicAlbum; + + if (musicAlbum != null) + { + musicAlbum.MusicBrainzReleaseGroupId = request.ProviderIds["MusicBrainzReleaseGroupId"]; + } + + var series = item as Series; + if (series != null) + { + series.Status = request.Status; + series.AirDays = request.AirDays; + series.AirTime = request.AirTime; + } + } + + } +} diff --git a/MediaBrowser.Api/LibraryService.cs b/MediaBrowser.Api/LibraryService.cs index d1f50687ac..0f76203da0 100644 --- a/MediaBrowser.Api/LibraryService.cs +++ b/MediaBrowser.Api/LibraryService.cs @@ -126,54 +126,6 @@ namespace MediaBrowser.Api [ApiMember(Name = "UserId", Description = "Optional. Get counts from a specific user's library.", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")] public Guid? UserId { get; set; } } - - [Route("/Items/{ItemId}", "POST")] - [Api(("Updates an item"))] - public class UpdateItem : BaseItemDto, IReturnVoid - { - [ApiMember(Name = "ItemId", Description = "The id of the item", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "POST")] - public string ItemId { get; set; } - } - - [Route("/Artists/{ArtistName}", "POST")] - [Api(("Updates an artist"))] - public class UpdateArtist : BaseItemDto, IReturnVoid - { - [ApiMember(Name = "ArtistName", Description = "The name of the item", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "POST")] - public string ArtistName { get; set; } - } - - [Route("/Studios/{StudioName}", "POST")] - [Api(("Updates a studio"))] - public class UpdateStudio : BaseItemDto, IReturnVoid - { - [ApiMember(Name = "StudioName", Description = "The name of the item", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "POST")] - public string StudioName { get; set; } - } - - [Route("/Persons/{PersonName}", "POST")] - [Api(("Updates a person"))] - public class UpdatePerson : BaseItemDto, IReturnVoid - { - [ApiMember(Name = "PersonName", Description = "The name of the item", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "POST")] - public string PersonName { get; set; } - } - - [Route("/MusicGenres/{GenreName}", "POST")] - [Api(("Updates a music genre"))] - public class UpdateMusicGenre : BaseItemDto, IReturnVoid - { - [ApiMember(Name = "GenreName", Description = "The name of the item", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "POST")] - public string GenreName { get; set; } - } - - [Route("/Genres/{GenreName}", "POST")] - [Api(("Updates a genre"))] - public class UpdateGenre : BaseItemDto, IReturnVoid - { - [ApiMember(Name = "GenreName", Description = "The name of the item", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "POST")] - public string GenreName { get; set; } - } /// /// Class LibraryService @@ -271,186 +223,6 @@ namespace MediaBrowser.Api } } - public void Post(UpdateItem request) - { - var task = UpdateItem(request); - - Task.WaitAll(task); - } - - private Task UpdateItem(UpdateItem request) - { - var item = DtoBuilder.GetItemByClientId(request.ItemId, _userManager, _libraryManager); - - UpdateItem(request, item); - - return _libraryManager.UpdateItem(item, ItemUpdateType.MetadataEdit, CancellationToken.None); - } - - public void Post(UpdatePerson request) - { - var task = UpdateItem(request); - - Task.WaitAll(task); - } - - private async Task UpdateItem(UpdatePerson request) - { - var item = await _libraryManager.GetPerson(request.PersonName).ConfigureAwait(false); - - UpdateItem(request, item); - - await _libraryManager.UpdateItem(item, ItemUpdateType.MetadataEdit, CancellationToken.None).ConfigureAwait(false); - } - - public void Post(UpdateArtist request) - { - var task = UpdateItem(request); - - Task.WaitAll(task); - } - - private async Task UpdateItem(UpdateArtist request) - { - var item = await _libraryManager.GetArtist(request.ArtistName).ConfigureAwait(false); - - UpdateItem(request, item); - - await _libraryManager.UpdateItem(item, ItemUpdateType.MetadataEdit, CancellationToken.None).ConfigureAwait(false); - } - - public void Post(UpdateStudio request) - { - var task = UpdateItem(request); - - Task.WaitAll(task); - } - - private async Task UpdateItem(UpdateStudio request) - { - var item = await _libraryManager.GetStudio(request.StudioName).ConfigureAwait(false); - - UpdateItem(request, item); - - await _libraryManager.UpdateItem(item, ItemUpdateType.MetadataEdit, CancellationToken.None).ConfigureAwait(false); - } - - public void Post(UpdateMusicGenre request) - { - var task = UpdateItem(request); - - Task.WaitAll(task); - } - - private async Task UpdateItem(UpdateMusicGenre request) - { - var item = await _libraryManager.GetMusicGenre(request.GenreName).ConfigureAwait(false); - - UpdateItem(request, item); - - await _libraryManager.UpdateItem(item, ItemUpdateType.MetadataEdit, CancellationToken.None).ConfigureAwait(false); - } - - public void Post(UpdateGenre request) - { - var task = UpdateItem(request); - - Task.WaitAll(task); - } - - private async Task UpdateItem(UpdateGenre request) - { - var item = await _libraryManager.GetGenre(request.GenreName).ConfigureAwait(false); - - UpdateItem(request, item); - - await _libraryManager.UpdateItem(item, ItemUpdateType.MetadataEdit, CancellationToken.None).ConfigureAwait(false); - } - - private void UpdateItem(BaseItemDto request, BaseItem item) - { - item.Name = request.Name; - - // Only set the forced value if they changed it, or there's already one - if (!string.Equals(item.SortName, request.SortName) || !string.IsNullOrEmpty(item.ForcedSortName)) - { - item.ForcedSortName = request.SortName; - } - - item.DisplayMediaType = request.DisplayMediaType; - item.CommunityRating = request.CommunityRating; - item.HomePageUrl = request.HomePageUrl; - item.Budget = request.Budget; - item.Revenue = request.Revenue; - item.CriticRating = request.CriticRating; - item.CriticRatingSummary = request.CriticRatingSummary; - item.IndexNumber = request.IndexNumber; - item.ParentIndexNumber = request.ParentIndexNumber; - item.Overview = request.Overview; - item.Genres = request.Genres; - item.Tags = request.Tags; - item.Studios = request.Studios.Select(x => x.Name).ToList(); - item.People = request.People.Select(x => new PersonInfo { Name = x.Name, Role = x.Role, Type = x.Type }).ToList(); - - item.EndDate = request.EndDate != default(DateTime) ? request.EndDate : null; - item.PremiereDate = request.PremiereDate != default(DateTime) ? request.PremiereDate : null; - item.ProductionYear = request.ProductionYear; - item.AspectRatio = request.AspectRatio; - item.Language = request.Language; - item.OfficialRating = request.OfficialRating; - item.CustomRating = request.CustomRating; - item.DontFetchMeta = !(request.EnableInternetProviders ?? true); - if (request.EnableInternetProviders ?? true) - { - item.LockedFields = request.LockedFields; - } - else - { - item.LockedFields.Clear(); - } - - foreach (var pair in request.ProviderIds.ToList()) - { - if (string.IsNullOrEmpty(pair.Value)) - { - request.ProviderIds.Remove(pair.Key); - } - } - - item.ProviderIds = request.ProviderIds; - - var game = item as Game; - - if (game != null) - { - game.PlayersSupported = request.Players; - } - - var song = item as Audio; - - if (song != null) - { - song.Album = request.Album; - song.AlbumArtist = request.AlbumArtist; - song.Artist = request.Artists[0]; - } - - var musicAlbum = item as MusicAlbum; - - if (musicAlbum != null) - { - musicAlbum.MusicBrainzReleaseGroupId = request.ProviderIds["MusicBrainzReleaseGroupId"]; - } - - var series = item as Series; - if (series != null) - { - series.Status = request.Status; - series.AirDays = request.AirDays; - series.AirTime = request.AirTime; - } - } - /// /// Deletes the specified request. /// diff --git a/MediaBrowser.Api/MediaBrowser.Api.csproj b/MediaBrowser.Api/MediaBrowser.Api.csproj index 5323231f47..8e2c85f469 100644 --- a/MediaBrowser.Api/MediaBrowser.Api.csproj +++ b/MediaBrowser.Api/MediaBrowser.Api.csproj @@ -73,6 +73,7 @@ +