using MediaBrowser.Common.Extensions; using MediaBrowser.Common.Net; using MediaBrowser.Controller.Configuration; using MediaBrowser.Controller.Entities; using MediaBrowser.Controller.Entities.Audio; using MediaBrowser.Model.Entities; using MediaBrowser.Model.Logging; using MediaBrowser.Model.Serialization; using MoreLinq; using System; using System.IO; using System.Linq; using System.Threading; using System.Threading.Tasks; namespace MediaBrowser.Controller.Providers.Music { public class LastfmAlbumProvider : LastfmBaseProvider { private static readonly Task BlankId = Task.FromResult(""); private readonly IProviderManager _providerManager; public LastfmAlbumProvider(IJsonSerializer jsonSerializer, IHttpClient httpClient, ILogManager logManager, IServerConfigurationManager configurationManager, IProviderManager providerManager) : base(jsonSerializer, httpClient, logManager, configurationManager) { _providerManager = providerManager; LocalMetaFileName = LastfmHelper.LocalAlbumMetaFileName; } protected override Task FindId(BaseItem item, CancellationToken cancellationToken) { // We don't fetch by id return BlankId; } /// /// Needses the refresh internal. /// /// The item. /// The provider info. /// true if XXXX, false otherwise protected override bool NeedsRefreshInternal(BaseItem item, BaseProviderInfo providerInfo) { // If song metadata has changed and we don't have an mbid, refresh if (string.IsNullOrEmpty(item.GetProviderId(MetadataProviders.Musicbrainz)) && GetComparisonData(item as MusicAlbum) != providerInfo.Data) { return true; } return base.NeedsRefreshInternal(item, providerInfo); } protected override async Task FetchLastfmData(BaseItem item, string id, CancellationToken cancellationToken) { var result = await GetAlbumResult(item, cancellationToken).ConfigureAwait(false); if (result != null && result.album != null) { LastfmHelper.ProcessAlbumData(item, result.album); //And save locally if indicated if (ConfigurationManager.Configuration.SaveLocalMeta) { var ms = new MemoryStream(); JsonSerializer.SerializeToStream(result.album, ms); cancellationToken.ThrowIfCancellationRequested(); await _providerManager.SaveToLibraryFilesystem(item, Path.Combine(item.MetaLocation, LocalMetaFileName), ms, cancellationToken).ConfigureAwait(false); } } BaseProviderInfo data; if (!item.ProviderData.TryGetValue(Id, out data)) { data = new BaseProviderInfo(); item.ProviderData[Id] = data; } data.Data = GetComparisonData(item as MusicAlbum); } private async Task GetAlbumResult(BaseItem item, CancellationToken cancellationToken) { var folder = (Folder)item; // Get each song, distinct by the combination of AlbumArtist and Album var songs = folder.RecursiveChildren.OfType