using Mapster; using Microsoft.AspNetCore.Http; using Microsoft.EntityFrameworkCore; using Microsoft.Extensions.Logging; using Roadie.Library; using Roadie.Library.Caching; using Roadie.Library.Configuration; using Roadie.Library.Encoding; using Roadie.Library.Engines; using Roadie.Library.Enums; using Roadie.Library.Extensions; using Roadie.Library.Factories; using Roadie.Library.Imaging; using Roadie.Library.MetaData.Audio; using Roadie.Library.MetaData.FileName; using Roadie.Library.MetaData.ID3Tags; using Roadie.Library.MetaData.LastFm; using Roadie.Library.MetaData.MusicBrainz; using Roadie.Library.Models; using Roadie.Library.Models.Collections; using Roadie.Library.Models.Pagination; using Roadie.Library.Models.Releases; using Roadie.Library.Models.Statistics; using Roadie.Library.Models.Users; using Roadie.Library.Utility; using System; using System.Collections.Generic; using System.Diagnostics; using System.IO; using System.IO.Compression; using System.Linq; using System.Linq.Dynamic.Core; using System.Threading.Tasks; using data = Roadie.Library.Data; namespace Roadie.Api.Services { public class ReleaseService : ServiceBase, IReleaseService { private IArtistLookupEngine ArtistLookupEngine { get; } private IAudioMetaDataHelper AudioMetaDataHelper { get; } private IBookmarkService BookmarkService { get; } = null; private ICollectionService CollectionService { get; } = null; private IFileNameHelper FileNameHelper { get; } private IID3TagsHelper ID3TagsHelper { get; } private IImageFactory ImageFactory { get; } private ILabelFactory LabelFactory { get; } private ILabelLookupEngine LabelLookupEngine { get; } private ILastFmHelper LastFmHelper { get; } private IMusicBrainzProvider MusicBrainzProvider { get; } private IPlaylistService PlaylistService { get; } = null; private IReleaseFactory ReleaseFactory { get; } private IReleaseLookupEngine ReleaseLookupEngine { get; } public ReleaseService(IRoadieSettings configuration, IHttpEncoder httpEncoder, IHttpContext httpContext, data.IRoadieDbContext dbContext, ICacheManager cacheManager, ICollectionService collectionService, IPlaylistService playlistService, ILogger logger, IBookmarkService bookmarkService) : base(configuration, httpEncoder, dbContext, cacheManager, logger, httpContext) { this.CollectionService = collectionService; this.PlaylistService = playlistService; this.BookmarkService = bookmarkService; this.MusicBrainzProvider = new MusicBrainzProvider(configuration, cacheManager, logger); this.LastFmHelper = new LastFmHelper(configuration, cacheManager, logger, dbContext, httpEncoder); this.FileNameHelper = new FileNameHelper(configuration, cacheManager, logger); this.ID3TagsHelper = new ID3TagsHelper(configuration, cacheManager, logger); this.ArtistLookupEngine = new ArtistLookupEngine(configuration, httpEncoder, dbContext, cacheManager, logger); this.LabelLookupEngine = new LabelLookupEngine(configuration, httpEncoder, dbContext, cacheManager, logger); this.ReleaseLookupEngine = new ReleaseLookupEngine(configuration, httpEncoder, dbContext, cacheManager, logger, this.ArtistLookupEngine, this.LabelLookupEngine); this.ImageFactory = new ImageFactory(configuration, httpEncoder, dbContext, cacheManager, logger, this.ArtistLookupEngine, this.ReleaseLookupEngine); this.LabelFactory = new LabelFactory(configuration, httpEncoder, dbContext, cacheManager, logger, this.ArtistLookupEngine, this.ReleaseLookupEngine); this.AudioMetaDataHelper = new AudioMetaDataHelper(configuration, httpEncoder, dbContext, this.MusicBrainzProvider, this.LastFmHelper, cacheManager, logger, this.ArtistLookupEngine, this.ImageFactory, this.FileNameHelper, this.ID3TagsHelper); this.ReleaseFactory = new ReleaseFactory(configuration, httpEncoder, dbContext, cacheManager, logger, this.ArtistLookupEngine, this.LabelFactory, this.AudioMetaDataHelper, this.ReleaseLookupEngine); } public async Task> ById(User roadieUser, Guid id, IEnumerable includes = null) { var sw = Stopwatch.StartNew(); sw.Start(); var cacheKey = string.Format("urn:release_by_id_operation:{0}:{1}", id, includes == null ? "0" : string.Join("|", includes)); var result = await this.CacheManager.GetAsync>(cacheKey, async () => { return await this.ReleaseByIdAction(id, includes); }, data.Artist.CacheRegionUrn(id)); if (result?.Data != null && roadieUser != null) { var release = this.GetRelease(id); var userBookmarkResult = await this.BookmarkService.List(roadieUser, new PagedRequest(), false, BookmarkType.Release); if (userBookmarkResult.IsSuccess) { result.Data.UserBookmarked = userBookmarkResult?.Rows?.FirstOrDefault(x => x.Bookmark.Value == release.RoadieId.ToString()) != null; } if (result.Data.Medias != null) { var user = this.GetUser(roadieUser.UserId); foreach (var media in result.Data.Medias) { foreach (var track in media.Tracks) { track.TrackPlayUrl = this.MakeTrackPlayUrl(user, track.DatabaseId, track.Id); } } var releaseTrackIds = result.Data.Medias.SelectMany(x => x.Tracks).Select(x => x.Id); var releaseUserTracks = (from ut in this.DbContext.UserTracks join t in this.DbContext.Tracks on ut.TrackId equals t.Id where ut.UserId == roadieUser.Id where (from x in releaseTrackIds select x).Contains(t.RoadieId) select new { t, ut }).ToArray(); if (releaseUserTracks != null && releaseUserTracks.Any()) { foreach (var releaseUserTrack in releaseUserTracks) { foreach (var media in result.Data.Medias) { var releaseTrack = media.Tracks.FirstOrDefault(x => x.Id == releaseUserTrack.t.RoadieId); if (releaseTrack != null) { releaseTrack.UserRating = new UserTrack { Rating = releaseUserTrack.ut.Rating, IsDisliked = releaseUserTrack.ut.IsDisliked ?? false, IsFavorite = releaseUserTrack.ut.IsFavorite ?? false, LastPlayed = releaseUserTrack.ut.LastPlayed, PlayedCount = releaseUserTrack.ut.PlayedCount }; } } } } } var userRelease = this.DbContext.UserReleases.FirstOrDefault(x => x.ReleaseId == release.Id && x.UserId == roadieUser.Id); if (userRelease != null) { result.Data.UserRating = new UserRelease { IsDisliked = userRelease.IsDisliked ?? false, IsFavorite = userRelease.IsFavorite ?? false, Rating = userRelease.Rating }; } } sw.Stop(); return new OperationResult(result.Messages) { Data = result?.Data, IsNotFoundResult = result?.IsNotFoundResult ?? false, Errors = result?.Errors, IsSuccess = result?.IsSuccess ?? false, OperationTime = sw.ElapsedMilliseconds }; } public Task> List(User roadieUser, PagedRequest request, bool? doRandomize = false, IEnumerable includes = null) { var sw = new Stopwatch(); sw.Start(); IEnumerable collectionReleaseIds = null; if (request.FilterToCollectionId.HasValue) { collectionReleaseIds = (from cr in this.DbContext.CollectionReleases join c in this.DbContext.Collections on cr.CollectionId equals c.Id join r in this.DbContext.Releases on cr.ReleaseId equals r.Id where c.RoadieId == request.FilterToCollectionId.Value orderby cr.ListNumber select r.Id).ToArray(); } int[] favoriteReleaseIds = new int[0]; if (request.FilterFavoriteOnly) { favoriteReleaseIds = (from a in this.DbContext.Releases join ur in this.DbContext.UserReleases on a.Id equals ur.ReleaseId where ur.IsFavorite ?? false where (roadieUser == null || ur.UserId == roadieUser.Id) select a.Id ).ToArray(); } int[] genreReleaseIds = new int[0]; var isFilteredToGenre = false; if (!string.IsNullOrEmpty(request.FilterByGenre) || (!string.IsNullOrEmpty(request.Filter) && request.Filter.StartsWith(":genre", StringComparison.OrdinalIgnoreCase))) { var genreFilter = request.FilterByGenre ?? (request.Filter ?? string.Empty).Replace(":genre ", "", StringComparison.OrdinalIgnoreCase); genreReleaseIds = (from rg in this.DbContext.ReleaseGenres join g in this.DbContext.Genres on rg.GenreId equals g.Id where g.Name.Contains(genreFilter) select rg.ReleaseId) .Distinct() .ToArray(); request.Filter = null; isFilteredToGenre = true; } if (request.FilterFromYear.HasValue || request.FilterToYear.HasValue) { // If from is larger than to then reverse values and set sort order to desc if (request.FilterToYear > request.FilterFromYear) { var t = request.FilterToYear; request.FilterToYear = request.FilterFromYear; request.FilterFromYear = t; request.Order = "DESC"; } else { request.Order = "ASC"; } } // // TODO list should honor disliked artist and albums for random // var isEqualFilter = false; if (!string.IsNullOrEmpty(request.FilterValue)) { var filter = request.FilterValue; // if filter string is wrapped in quotes then is an exact not like search, e.g. "Diana Ross" should not return "Diana Ross & The Supremes" if (filter.StartsWith('"') && filter.EndsWith('"')) { isEqualFilter = true; request.Filter = filter.Substring(1, filter.Length - 2); } } var normalizedFilterValue = !string.IsNullOrEmpty(request.FilterValue) ? request.FilterValue.ToAlphanumericName() : null; var result = (from r in this.DbContext.Releases join a in this.DbContext.Artists on r.ArtistId equals a.Id where (request.FilterMinimumRating == null || r.Rating >= request.FilterMinimumRating.Value) where (request.FilterToArtistId == null || r.Artist.RoadieId == request.FilterToArtistId) where (request.FilterToCollectionId == null || collectionReleaseIds.Contains(r.Id)) where (!request.FilterFavoriteOnly || favoriteReleaseIds.Contains(r.Id)) where (!isFilteredToGenre || genreReleaseIds.Contains(r.Id)) where (request.FilterFromYear == null || r.ReleaseDate != null && r.ReleaseDate.Value.Year <= request.FilterFromYear) where (request.FilterToYear == null || r.ReleaseDate != null && r.ReleaseDate.Value.Year >= request.FilterToYear) where (request.FilterValue == "" || (r.Title.Contains(request.FilterValue) || r.AlternateNames.Contains(request.FilterValue) || r.AlternateNames.Contains(normalizedFilterValue))) where (!isEqualFilter || (r.Title.Equals(request.FilterValue) || r.AlternateNames.Equals(request.FilterValue) || r.AlternateNames.Equals(normalizedFilterValue))) select new ReleaseList { DatabaseId = r.Id, Id = r.RoadieId, Artist = new DataToken { Value = a.RoadieId.ToString(), Text = a.Name }, Release = new DataToken { Text = r.Title, Value = r.RoadieId.ToString() }, ArtistThumbnail = this.MakeArtistThumbnailImage(a.RoadieId), CreatedDate = r.CreatedDate, Duration = r.Duration, LastPlayed = r.LastPlayed, LastUpdated = r.LastUpdated, LibraryStatus = r.LibraryStatus, MediaCount = r.MediaCount, Rating = r.Rating, Rank = r.Rank, ReleaseDateDateTime = r.ReleaseDate, ReleasePlayUrl = $"{ this.HttpContext.BaseUrl }/play/release/{ r.RoadieId}", Status = r.Status, Thumbnail = this.MakeReleaseThumbnailImage(r.RoadieId), TrackCount = r.TrackCount, TrackPlayedCount = r.PlayedCount } ).Distinct(); ReleaseList[] rows = null; var rowCount = result.Count(); if (doRandomize ?? false) { var randomLimit = roadieUser?.RandomReleaseLimit ?? 100; request.Limit = request.LimitValue > randomLimit ? randomLimit : request.LimitValue; rows = result.OrderBy(x => x.RandomSortId).Skip(request.SkipValue).Take(request.LimitValue).ToArray(); } else { string sortBy = null; if (request.ActionValue == User.ActionKeyUserRated) { sortBy = request.OrderValue(new Dictionary { { "Rating", "DESC" } }); } else if (request.FilterToArtistId.HasValue) { sortBy = request.OrderValue(new Dictionary { { "ReleaseDate", "ASC" }, { "Release.Text", "ASC" } }); } else { sortBy = request.OrderValue(new Dictionary { { "Release.Text", "ASC" } }); } if (request.FilterRatedOnly) { result = result.Where(x => x.Rating.HasValue); } if (request.FilterMinimumRating.HasValue) { result = result.Where(x => x.Rating.HasValue && x.Rating.Value >= request.FilterMinimumRating.Value); } if (request.FilterToCollectionId.HasValue) { rows = result.ToArray(); } else { rows = result.OrderBy(sortBy).Skip(request.SkipValue).Take(request.LimitValue).ToArray(); } } if (rows.Any()) { var rowIds = rows.Select(x => x.DatabaseId).ToArray(); var genreData = (from rg in this.DbContext.ReleaseGenres join g in this.DbContext.Genres on rg.GenreId equals g.Id where rowIds.Contains(rg.ReleaseId) orderby rg.Id select new { rg.ReleaseId, dt = new DataToken { Text = g.Name, Value = g.RoadieId.ToString() } }).ToArray(); foreach (var release in rows) { var genre = genreData.FirstOrDefault(x => x.ReleaseId == release.DatabaseId); release.Genre = genre?.dt ?? new DataToken(); } if (request.FilterToCollectionId.HasValue) { var newRows = new List(rows); var collection = this.GetCollection(request.FilterToCollectionId.Value); var collectionReleases = (from c in this.DbContext.Collections join cr in this.DbContext.CollectionReleases on c.Id equals cr.CollectionId where c.RoadieId == request.FilterToCollectionId select cr); var pars = collection.PositionArtistReleases().ToArray(); foreach (var par in pars) { var cr = collectionReleases.FirstOrDefault(x => x.ListNumber == par.Position); // Release is known for Collection CSV if (cr != null) { var parRelease = rows.FirstOrDefault(x => x.DatabaseId == cr.ReleaseId); if (parRelease != null) { if (!parRelease.ListNumber.HasValue) { parRelease.ListNumber = par.Position; } } } // Release is not known add missing dummy release to rows else { newRows.Add(new ReleaseList { Artist = new DataToken { Text = par.Artist }, Release = new DataToken { Text = par.Release }, CssClass = "missing", ArtistThumbnail = new Library.Models.Image($"{this.HttpContext.ImageBaseUrl }/unknown.jpg"), Thumbnail = new Library.Models.Image($"{this.HttpContext.ImageBaseUrl }/unknown.jpg"), ListNumber = par.Position }); } } // Resort the list for the collection by listNumber rows = newRows.OrderBy(x => x.ListNumber).Skip(request.SkipValue).Take(request.LimitValue).ToArray(); rowCount = collection.CollectionCount; } if (roadieUser != null) { var userReleaseRatings = (from ur in this.DbContext.UserReleases where ur.UserId == roadieUser.Id where rowIds.Contains(ur.ReleaseId) select ur).ToArray(); foreach (var userReleaseRating in userReleaseRatings.Where(x => rows.Select(r => r.DatabaseId).Contains(x.ReleaseId))) { var row = rows.FirstOrDefault(x => x.DatabaseId == userReleaseRating.ReleaseId); if (row != null) { var isDisliked = userReleaseRating.IsDisliked ?? false; var isFavorite = userReleaseRating.IsFavorite ?? false; row.UserRating = new UserRelease { IsDisliked = isDisliked, IsFavorite = isFavorite, Rating = userReleaseRating.Rating, RatedDate = isDisliked || isFavorite ? (DateTime?)(userReleaseRating.LastUpdated ?? userReleaseRating.CreatedDate) : null }; } } } } if (includes != null && includes.Any()) { if (includes.Contains("tracks")) { foreach (var release in rows) { release.Media = this.DbContext.ReleaseMedias .Include(x => x.Tracks) .Where(x => x.ReleaseId == release.DatabaseId) .ToArray() .AsQueryable() .ProjectToType() .OrderBy(x => x.MediaNumber) .ToArray(); var userRatingsForRelease = (from ut in this.DbContext.UserTracks join t in this.DbContext.Tracks on ut.TrackId equals t.Id join rm in this.DbContext.ReleaseMedias on t.ReleaseMediaId equals rm.Id where rm.ReleaseId == release.DatabaseId where ut.UserId == roadieUser.Id select new { trackId = t.RoadieId, ut }).ToArray(); foreach (var userRatingForRelease in userRatingsForRelease) { var mediaTrack = release.Media?.SelectMany(x => x.Tracks).FirstOrDefault(x => x.Id == userRatingForRelease.trackId); if (mediaTrack != null) { mediaTrack.UserRating = new UserTrack { Rating = userRatingForRelease.ut.Rating, IsFavorite = userRatingForRelease.ut.IsFavorite ?? false, IsDisliked = userRatingForRelease.ut.IsDisliked ?? false }; } } } } } if (request.FilterFavoriteOnly) { rows = rows.OrderBy(x => x.UserRating.Rating).ToArray(); } sw.Stop(); return Task.FromResult(new Library.Models.Pagination.PagedResult { TotalCount = rowCount, CurrentPage = request.PageValue, TotalPages = (int)Math.Ceiling((double)rowCount / request.LimitValue), OperationTime = sw.ElapsedMilliseconds, Rows = rows }); } public async Task> MergeReleases(User user, Guid releaseToMergeId, Guid releaseToMergeIntoId, bool addAsMedia) { var sw = new Stopwatch(); sw.Start(); var errors = new List(); var releaseToMerge = this.DbContext.Releases .Include(x => x.Artist) .Include(x => x.Genres) .Include("Genres.Genre") .Include(x => x.Medias) .Include("Medias.Tracks") .Include("Medias.Tracks.TrackArtist") .FirstOrDefault(x => x.RoadieId == releaseToMergeId); if (releaseToMerge == null) { this.Logger.LogWarning("MergeReleases Unknown Release [{0}]", releaseToMergeId); return new OperationResult(true, string.Format("Release Not Found [{0}]", releaseToMergeId)); } var releaseToMergeInfo = this.DbContext.Releases .Include(x => x.Artist) .Include(x => x.Genres) .Include("Genres.Genre") .Include(x => x.Medias) .Include("Medias.Tracks") .Include("Medias.Tracks.TrackArtist") .FirstOrDefault(x => x.RoadieId == releaseToMergeIntoId); if (releaseToMergeInfo == null) { this.Logger.LogWarning("MergeReleases Unknown Release [{0}]", releaseToMergeIntoId); return new OperationResult(true, string.Format("Release Not Found [{0}]", releaseToMergeIntoId)); } try { await this.ReleaseFactory.MergeReleases(releaseToMerge, releaseToMergeInfo, addAsMedia); } catch (Exception ex) { this.Logger.LogError(ex); errors.Add(ex); } sw.Stop(); this.Logger.LogInformation("MergeReleases Release `{0}` Merged Into Release `{1}`, By User `{2}`", releaseToMerge, releaseToMergeInfo, user); return new OperationResult { IsSuccess = !errors.Any(), Data = !errors.Any(), OperationTime = sw.ElapsedMilliseconds, Errors = errors }; } public Task> ReleaseZipped(User roadieUser, Guid id) { var release = this.GetRelease(id); if (release == null) { return Task.FromResult(new FileOperationResult(true, string.Format("Release Not Found [{0}]", id))); } byte[] zipBytes = null; string zipFileName = null; try { var artistFolder = release.Artist.ArtistFileFolder(this.Configuration, this.Configuration.LibraryFolder); var releaseFolder = release.ReleaseFileFolder(artistFolder); if (!Directory.Exists(releaseFolder)) { this.Logger.LogCritical($"Release Folder [{ releaseFolder }] not found for Release `{ release }`"); return Task.FromResult(new FileOperationResult(true, string.Format("Release Folder Not Found [{0}]", id))); } var releaseFiles = Directory.GetFiles(releaseFolder); using (MemoryStream zipStream = new MemoryStream()) { using (ZipArchive zip = new ZipArchive(zipStream, ZipArchiveMode.Create)) { foreach (var releaseFile in releaseFiles) { var fileInfo = new FileInfo(releaseFile); if (fileInfo.Extension.ToLower() == ".mp3" || fileInfo.Extension.ToLower() == ".jpg") { ZipArchiveEntry entry = zip.CreateEntry(fileInfo.Name); using (Stream entryStream = entry.Open()) { using (FileStream s = fileInfo.OpenRead()) { s.CopyTo(entryStream); } } } } } zipBytes = zipStream.ToArray(); } zipFileName = $"{ release.Artist.Name }_{release.Title}.zip".ToFileNameFriendly(); this.Logger.LogInformation($"User `{ roadieUser }` downloaded Release `{ release }` ZipFileName [{ zipFileName }], Zip Size [{ zipBytes?.Length }]"); } catch (Exception ex) { this.Logger.LogError(ex, "Error creating zip for Release `{0}`", release.ToString()); } return Task.FromResult(new FileOperationResult { IsSuccess = zipBytes != null, Data = zipBytes, AdditionalData = new Dictionary { { "ZipFileName", zipFileName } } }); } public async Task> SetReleaseImageByUrl(User user, Guid id, string imageUrl) { return await this.SaveImageBytes(user, id, WebHelper.BytesForImageUrl(imageUrl)); } public async Task> UpdateRelease(User user, Library.Models.Releases.Release model) { var didChangeArtist = false; var didChangeThumbnail = false; var sw = new Stopwatch(); sw.Start(); var errors = new List(); var release = this.DbContext.Releases .Include(x => x.Artist) .Include(x => x.Genres) .Include("Genres.Genre") .Include(x => x.Labels) .Include("Labels.Label") .FirstOrDefault(x => x.RoadieId == model.Id); if (release == null) { return new OperationResult(true, string.Format("Release Not Found [{0}]", model.Id)); } try { var now = DateTime.UtcNow; var artistFolder = release.Artist.ArtistFileFolder(this.Configuration, this.Configuration.LibraryFolder); var originalReleaseFolder = release.ReleaseFileFolder(artistFolder); release.IsLocked = model.IsLocked; release.IsVirtual = model.IsVirtual; release.Status = SafeParser.ToEnum(model.Status); release.Title = model.Title; release.AlternateNames = model.AlternateNamesList.ToDelimitedList(); release.ReleaseDate = model.ReleaseDate; release.Rating = model.Rating; release.TrackCount = model.TrackCount; release.MediaCount = model.MediaCount; release.Profile = model.Profile; release.DiscogsId = model.DiscogsId; release.ReleaseType = SafeParser.ToEnum(model.ReleaseType); release.LibraryStatus = SafeParser.ToEnum(model.LibraryStatus); release.ITunesId = model.ITunesId; release.AmgId = model.AmgId; release.LastFMId = model.LastFMId; release.LastFMSummary = model.LastFMSummary; release.MusicBrainzId = model.MusicBrainzId; release.SpotifyId = model.SpotifyId; release.Tags = model.TagsList.ToDelimitedList(); release.URLs = model.URLsList.ToDelimitedList(); if (model?.Artist?.Artist?.Value != null) { var artist = this.DbContext.Artists.FirstOrDefault(x => x.RoadieId == SafeParser.ToGuid(model.Artist.Artist.Value)); if (artist != null && release.ArtistId != artist.Id) { release.ArtistId = artist.Id; didChangeArtist = true; } } var releaseImage = ImageHelper.ImageDataFromUrl(model.NewThumbnailData); if (releaseImage != null) { // Ensure is jpeg first release.Thumbnail = ImageHelper.ConvertToJpegFormat(releaseImage); // Save unaltered image to cover file var coverFileName = Path.Combine(release.ReleaseFileFolder(release.Artist.ArtistFileFolder(this.Configuration, this.Configuration.LibraryFolder)), "cover.jpg"); File.WriteAllBytes(coverFileName, release.Thumbnail); // Resize to store in database as thumbnail release.Thumbnail = ImageHelper.ResizeImage(release.Thumbnail, this.Configuration.MediumImageSize.Width, this.Configuration.MediumImageSize.Height); didChangeThumbnail = true; } if (model.NewSecondaryImagesData != null && model.NewSecondaryImagesData.Any()) { var releaseFolder = release.ReleaseFileFolder(release.Artist.ArtistFileFolder(this.Configuration, this.Configuration.LibraryFolder)); // Additional images to add to artist var looper = 0; foreach (var newSecondaryImageData in model.NewSecondaryImagesData) { var releaseSecondaryImage = ImageHelper.ImageDataFromUrl(newSecondaryImageData); if (releaseSecondaryImage != null) { // Ensure is jpeg first releaseSecondaryImage = ImageHelper.ConvertToJpegFormat(releaseSecondaryImage); var releaseImageFilename = Path.Combine(releaseFolder, string.Format(ImageHelper.ReleaseSecondaryImageFilename, looper.ToString("00"))); while (File.Exists(releaseImageFilename)) { looper++; releaseImageFilename = Path.Combine(releaseFolder, string.Format(ImageHelper.ReleaseSecondaryImageFilename, looper.ToString("00"))); } File.WriteAllBytes(releaseImageFilename, releaseSecondaryImage); } looper++; } } if (model.Genres != null && model.Genres.Any()) { // Remove existing Genres not in model list foreach (var genre in release.Genres.ToList()) { var doesExistInModel = model.Genres.Any(x => SafeParser.ToGuid(x.Value) == genre.Genre.RoadieId); if (!doesExistInModel) { release.Genres.Remove(genre); } } // Add new Genres in model not in data foreach (var genre in model.Genres) { var genreId = SafeParser.ToGuid(genre.Value); var doesExistInData = release.Genres.Any(x => x.Genre.RoadieId == genreId); if (!doesExistInData) { var g = this.DbContext.Genres.FirstOrDefault(x => x.RoadieId == genreId); if (g != null) { release.Genres.Add(new data.ReleaseGenre { ReleaseId = release.Id, GenreId = g.Id, Genre = g }); } } } } else if (model.Genres == null || !model.Genres.Any()) { release.Genres.Clear(); } if (model.Labels != null && model.Labels.Any()) { // TODO } if (model.Images != null && model.Images.Any()) { // TODO } release.LastUpdated = now; await this.DbContext.SaveChangesAsync(); await this.ReleaseFactory.CheckAndChangeReleaseTitle(release, originalReleaseFolder); this.CacheManager.ClearRegion(release.CacheRegion); this.Logger.LogInformation($"UpdateRelease `{ release }` By User `{ user }`: Edited Artist [{ didChangeArtist }], Uploaded new image [{ didChangeThumbnail }]"); } catch (Exception ex) { this.Logger.LogError(ex); errors.Add(ex); } sw.Stop(); return new OperationResult { IsSuccess = !errors.Any(), Data = !errors.Any(), OperationTime = sw.ElapsedMilliseconds, Errors = errors }; } public async Task> UploadReleaseImage(User user, Guid id, IFormFile file) { var bytes = new byte[0]; using (var ms = new MemoryStream()) { file.CopyTo(ms); bytes = ms.ToArray(); } return await this.SaveImageBytes(user, id, bytes); } private async Task> ReleaseByIdAction(Guid id, IEnumerable includes = null) { var sw = Stopwatch.StartNew(); sw.Start(); var release = this.GetRelease(id); if (release == null) { return new OperationResult(true, string.Format("Release Not Found [{0}]", id)); } var result = release.Adapt(); result.Artist = ArtistList.FromDataArtist(release.Artist, this.MakeArtistThumbnailImage(release.Artist.RoadieId)); result.Thumbnail = this.MakeReleaseThumbnailImage(release.RoadieId); result.MediumThumbnail = base.MakeThumbnailImage(id, "release", this.Configuration.MediumImageSize.Width, this.Configuration.MediumImageSize.Height); result.ReleasePlayUrl = $"{ this.HttpContext.BaseUrl }/play/release/{ release.RoadieId}"; result.Profile = release.Profile; result.ReleaseDate = release.ReleaseDate.Value; result.MediaCount = release.MediaCount; result.TrackCount = release.TrackCount; result.CreatedDate = release.CreatedDate; result.LastUpdated = release.LastUpdated; result.AlternateNames = release.AlternateNames; result.Tags = release.Tags; result.URLs = release.URLs; result.RankPosition = result.Rank > 0 ? SafeParser.ToNumber(this.DbContext.Releases.Count(x => x.Rank > result.Rank) + 1) : null; if (release.SubmissionId.HasValue) { var submission = this.DbContext.Submissions.Include(x => x.User).FirstOrDefault(x => x.Id == release.SubmissionId); if (submission != null) { if (!submission.User.IsPrivate ?? false) { result.Submission = new ReleaseSubmission { User = new DataToken { Text = submission.User.UserName, Value = submission.User.RoadieId.ToString() }, UserThumbnail = this.MakeUserThumbnailImage(submission.User.RoadieId), SubmittedDate = submission.CreatedDate }; } } } if (includes != null && includes.Any()) { if (includes.Contains("genres")) { result.Genres = release.Genres.Select(x => new DataToken { Text = x.Genre.Name, Value = x.Genre.RoadieId.ToString() }); } if (includes.Contains("stats")) { var releaseTracks = (from r in this.DbContext.Releases join rm in this.DbContext.ReleaseMedias on r.Id equals rm.ReleaseId join t in this.DbContext.Tracks on rm.Id equals t.ReleaseMediaId where r.Id == release.Id select new { id = t.Id, size = t.FileSize, time = t.Duration, isMissing = t.Hash == null }); var releaseMedias = (from r in this.DbContext.Releases join rm in this.DbContext.ReleaseMedias on r.Id equals rm.ReleaseId where r.Id == release.Id select new { rm.Id, rm.MediaNumber }); long releaseTime = releaseTracks?.Sum(x => (long?)x.time) ?? 0; var releaseStats = new ReleaseStatistics { MediaCount = release.MediaCount, MissingTrackCount = releaseTracks?.Where(x => x.isMissing).Count(), TrackCount = release.TrackCount, TrackPlayedCount = release.PlayedCount, TrackSize = releaseTracks?.Sum(x => (long?)x.size).ToFileSize(), TrackTime = releaseTracks.Any() ? new TimeInfo((decimal)releaseTime).ToFullFormattedString() : "--:--" }; result.MaxMediaNumber = releaseMedias.Any() ? releaseMedias.Max(x => x.MediaNumber) : (short)0; result.Statistics = releaseStats; result.MediaCount = release.MediaCount ?? (short?)releaseStats?.MediaCount; } if (includes.Contains("images")) { var releaseImages = this.DbContext.Images.Where(x => x.ReleaseId == release.Id).Select(x => MakeFullsizeImage(x.RoadieId, x.Caption)).ToArray(); if (releaseImages != null && releaseImages.Any()) { result.Images = releaseImages; } var artistFolder = release.Artist.ArtistFileFolder(this.Configuration, this.Configuration.LibraryFolder); var releaseFolder = release.ReleaseFileFolder(artistFolder); var releaseImagesInFolder = ImageHelper.FindImageTypeInDirectory(new DirectoryInfo(releaseFolder), ImageType.ReleaseSecondary, SearchOption.TopDirectoryOnly); if (releaseImagesInFolder.Any()) { result.Images = result.Images.Concat(releaseImagesInFolder.Select((x, i) => MakeFullsizeSecondaryImage(id, ImageType.ReleaseSecondary, i))); } } if (includes.Contains("playlists")) { var pg = new PagedRequest { FilterToReleaseId = release.RoadieId }; var r = await this.PlaylistService.List(pg); if (r.IsSuccess) { result.Playlists = r.Rows.ToArray(); } } if (includes.Contains("labels")) { var releaseLabels = (from l in this.DbContext.Labels join rl in this.DbContext.ReleaseLabels on l.Id equals rl.LabelId where rl.ReleaseId == release.Id orderby rl.BeginDate, l.Name select new { l, rl }).ToArray(); if (releaseLabels != null) { var labels = new List(); foreach (var releaseLabel in releaseLabels) { var rl = new ReleaseLabel { BeginDate = releaseLabel.rl.BeginDate, EndDate = releaseLabel.rl.EndDate, CatalogNumber = releaseLabel.rl.CatalogNumber, CreatedDate = releaseLabel.rl.CreatedDate, Id = releaseLabel.rl.RoadieId, Label = new LabelList { Id = releaseLabel.rl.RoadieId, Label = new DataToken { Text = releaseLabel.l.Name, Value = releaseLabel.l.RoadieId.ToString() }, SortName = releaseLabel.l.SortName, CreatedDate = releaseLabel.l.CreatedDate, LastUpdated = releaseLabel.l.LastUpdated, ArtistCount = releaseLabel.l.ArtistCount, ReleaseCount = releaseLabel.l.ReleaseCount, TrackCount = releaseLabel.l.TrackCount, Thumbnail = MakeLabelThumbnailImage(releaseLabel.l.RoadieId) } }; labels.Add(rl); } result.Labels = labels; } } if (includes.Contains("collections")) { var releaseCollections = this.DbContext.CollectionReleases.Include(x => x.Collection).Where(x => x.ReleaseId == release.Id).OrderBy(x => x.ListNumber).ToArray(); if (releaseCollections != null) { var collections = new List(); foreach (var releaseCollection in releaseCollections) { collections.Add(new ReleaseInCollection { Collection = new CollectionList { DatabaseId = releaseCollection.Collection.Id, Collection = new DataToken { Text = releaseCollection.Collection.Name, Value = releaseCollection.Collection.RoadieId.ToString() }, Id = releaseCollection.Collection.RoadieId, CollectionCount = releaseCollection.Collection.CollectionCount, CollectionType = (releaseCollection.Collection.CollectionType ?? CollectionType.Unknown).ToString(), CollectionFoundCount = (from crc in this.DbContext.CollectionReleases where crc.CollectionId == releaseCollection.Collection.Id select crc.Id).Count(), CreatedDate = releaseCollection.Collection.CreatedDate, IsLocked = releaseCollection.Collection.IsLocked, LastUpdated = releaseCollection.Collection.LastUpdated, Thumbnail = MakeCollectionThumbnailImage(releaseCollection.Collection.RoadieId) }, ListNumber = releaseCollection.ListNumber }); } result.Collections = collections; } } if (includes.Contains("tracks")) { var releaseMedias = new List(); foreach (var releaseMedia in release.Medias.OrderBy(x => x.MediaNumber)) { var rm = releaseMedia.Adapt(); var rmTracks = new List(); foreach (var track in releaseMedia.Tracks.OrderBy(x => x.TrackNumber)) { var t = track.Adapt(); t.Track = new DataToken { Text = track.Title, Value = track.RoadieId.ToString() }; t.MediaNumber = rm.MediaNumber; t.CssClass = string.IsNullOrEmpty(track.Hash) ? "Missing" : "Ok"; t.TrackArtist = track.TrackArtist != null ? ArtistList.FromDataArtist(track.TrackArtist, this.MakeArtistThumbnailImage(track.TrackArtist.RoadieId)) : null; rmTracks.Add(t); } rm.Tracks = rmTracks; releaseMedias.Add(rm); } result.Medias = releaseMedias; } } sw.Stop(); return new OperationResult { Data = result, IsSuccess = result != null, OperationTime = sw.ElapsedMilliseconds }; } private async Task> SaveImageBytes(User user, Guid id, byte[] imageBytes) { var sw = new Stopwatch(); sw.Start(); var errors = new List(); var release = this.DbContext.Releases.Include(x => x.Artist).FirstOrDefault(x => x.RoadieId == id); if (release == null) { return new OperationResult(true, string.Format("Release Not Found [{0}]", id)); } try { var now = DateTime.UtcNow; release.Thumbnail = imageBytes; if (release.Thumbnail != null) { // Ensure is jpeg first release.Thumbnail = ImageHelper.ConvertToJpegFormat(release.Thumbnail); // Save unaltered image to cover file var coverFileName = Path.Combine(release.ReleaseFileFolder(release.Artist.ArtistFileFolder(this.Configuration, this.Configuration.LibraryFolder)), "cover.jpg"); File.WriteAllBytes(coverFileName, release.Thumbnail); // Resize to store in database as thumbnail release.Thumbnail = ImageHelper.ResizeImage(release.Thumbnail, this.Configuration.MediumImageSize.Width, this.Configuration.MediumImageSize.Height); } release.LastUpdated = now; await this.DbContext.SaveChangesAsync(); this.CacheManager.ClearRegion(release.CacheRegion); this.Logger.LogInformation($"SaveImageBytes `{ release }` By User `{ user }`"); } catch (Exception ex) { this.Logger.LogError(ex); errors.Add(ex); } sw.Stop(); return new OperationResult { IsSuccess = !errors.Any(), Data = base.MakeThumbnailImage(id, "release", this.Configuration.MediumImageSize.Width, this.Configuration.MediumImageSize.Height, true), OperationTime = sw.ElapsedMilliseconds, Errors = errors }; } } }