// Copyright (c) ppy Pty Ltd . Licensed under the MIT Licence. // See the LICENCE file in the repository root for full licence text. using System; using Microsoft.EntityFrameworkCore.Internal; using osu.Framework.Allocation; using osu.Framework.Configuration; using osu.Framework.Graphics.Containers; using osu.Game.Beatmaps; using osu.Game.Online.API.Requests; namespace osu.Game.Overlays.Direct { public abstract class DownloadTrackingComposite : CompositeDrawable { public readonly Bindable BeatmapSet = new Bindable(); private BeatmapManager beatmaps; /// /// Holds the current download state of the beatmap, whether is has already been downloaded, is in progress, or is not downloaded. /// protected readonly Bindable State = new Bindable(); protected readonly Bindable Progress = new Bindable(); protected DownloadTrackingComposite(BeatmapSetInfo beatmapSet = null) { BeatmapSet.Value = beatmapSet; } [BackgroundDependencyLoader(true)] private void load(BeatmapManager beatmaps) { this.beatmaps = beatmaps; BeatmapSet.BindValueChanged(UpdateState, true); beatmaps.BeatmapDownloadBegan += download => { if (download.BeatmapSet.OnlineBeatmapSetID == BeatmapSet.Value?.OnlineBeatmapSetID) attachDownload(download); }; beatmaps.ItemAdded += setAdded; } protected void UpdateState(BeatmapSetInfo set) { if (set == null) attachDownload(null); else if (this.beatmaps.QueryBeatmapSets(s => s.OnlineBeatmapSetID == set.OnlineBeatmapSetID && !s.DeletePending).Any()) State.Value = DownloadState.LocallyAvailable; else attachDownload(this.beatmaps.GetExistingDownload(set)); } #region Disposal protected override void Dispose(bool isDisposing) { base.Dispose(isDisposing); beatmaps.BeatmapDownloadBegan -= attachDownload; beatmaps.ItemAdded -= setAdded; State.UnbindAll(); attachDownload(null); } #endregion private DownloadBeatmapSetRequest attachedRequest; private void attachDownload(DownloadBeatmapSetRequest request) { if (attachedRequest != null) { attachedRequest.Failure -= onRequestFailure; attachedRequest.DownloadProgressed -= onRequestProgress; attachedRequest.Success -= onRequestSuccess; } attachedRequest = request; if (attachedRequest != null) { if (attachedRequest.Progress == 1) { State.Value = DownloadState.Downloaded; Progress.Value = 1; } else { State.Value = DownloadState.Downloading; Progress.Value = attachedRequest.Progress; attachedRequest.Failure += onRequestFailure; attachedRequest.DownloadProgressed += onRequestProgress; attachedRequest.Success += onRequestSuccess; } } else { State.Value = DownloadState.NotDownloaded; } } private void onRequestSuccess(string data) { Schedule(() => State.Value = DownloadState.Downloaded); } private void onRequestProgress(float progress) { Schedule(() => Progress.Value = progress); } private void onRequestFailure(Exception e) { Schedule(() => attachDownload(null)); } private void setAdded(BeatmapSetInfo s, bool existing, bool silent) { if (s.OnlineBeatmapSetID != BeatmapSet.Value?.OnlineBeatmapSetID) return; Schedule(() => State.Value = DownloadState.LocallyAvailable); } } }