Libation/Source/AaxDecrypter/AudiobookDownloadBase.cs

using Dinah.Core;
using Dinah.Core.Net.Http;
using Dinah.Core.StepRunner;
using FileManager;
using System;
using System.IO;
using System.Threading.Tasks;

#nullable enable
namespace AaxDecrypter
{
	public enum OutputFormat { M4b, Mp3 }

	public abstract class AudiobookDownloadBase
	{
		public event EventHandler<string?>? RetrievedTitle;
		public event EventHandler<string?>? RetrievedAuthors;
		public event EventHandler<string?>? RetrievedNarrators;
		public event EventHandler<byte[]?>? RetrievedCoverArt;
		public event EventHandler<DownloadProgress>? DecryptProgressUpdate;
		public event EventHandler<TimeSpan>? DecryptTimeRemaining;
		public event EventHandler<TempFile>? TempFileCreated;

		public bool IsCanceled { get; protected set; }
		protected AsyncStepSequence AsyncSteps { get; } = new();
		protected string OutputDirectory { get; }
		public IDownloadOptions DownloadOptions { get; }
		protected NetworkFileStream InputFileStream => NfsPersister.NetworkFileStream;
		protected virtual long InputFilePosition => InputFileStream.Position;
		private bool downloadFinished;

		private NetworkFileStreamPersister? m_nfsPersister;
		private NetworkFileStreamPersister NfsPersister => m_nfsPersister ??= OpenNetworkFileStream();
		private readonly DownloadProgress zeroProgress;
		private readonly string jsonDownloadState;
		private readonly string tempFilePath;

		protected AudiobookDownloadBase(string outDirectory, string cacheDirectory, IDownloadOptions dlOptions)
		{			
			OutputDirectory = ArgumentValidator.EnsureNotNullOrWhiteSpace(outDirectory, nameof(outDirectory));
			DownloadOptions = ArgumentValidator.EnsureNotNull(dlOptions, nameof(dlOptions));
			DownloadOptions.DownloadSpeedChanged += (_, speed) => InputFileStream.SpeedLimit = speed;

			if (!Directory.Exists(OutputDirectory))
				Directory.CreateDirectory(OutputDirectory);

			if (!Directory.Exists(cacheDirectory))
				Directory.CreateDirectory(cacheDirectory);

			jsonDownloadState = Path.Combine(cacheDirectory, $"{DownloadOptions.AudibleProductId}.json");
			tempFilePath = Path.ChangeExtension(jsonDownloadState, ".aaxc");

			zeroProgress = new DownloadProgress
			{
				BytesReceived = 0,
				ProgressPercentage = 0,
				TotalBytesToReceive = 0
			};

			OnDecryptProgressUpdate(zeroProgress);
		}

		protected TempFile GetNewTempFilePath(string extension)
		{
			extension = FileUtility.GetStandardizedExtension(extension);
			var path = Path.Combine(OutputDirectory, Guid.NewGuid().ToString("N") + extension);
			return new(path, extension);
		}

		public async Task<bool> RunAsync()
		{
			await InputFileStream.BeginDownloadingAsync();
			var progressTask = Task.Run(reportProgress);

			(bool success, var elapsed) = await AsyncSteps.RunAsync();

			//Stop the downloader so it doesn't keep running in the background.
			if (!success)
				NfsPersister.Dispose();

			await progressTask;

			var speedup = DownloadOptions.RuntimeLength / elapsed;
			Serilog.Log.Information($"Speedup is {speedup:F0}x realtime.");

			NfsPersister.Dispose();
			return success;

			async Task reportProgress()
			{
				AverageSpeed averageSpeed = new();

				while (
					InputFileStream.CanRead
					&& InputFileStream.Length > InputFilePosition
					&& !InputFileStream.IsCancelled
					&& !downloadFinished)
				{
					averageSpeed.AddPosition(InputFilePosition);

					var estSecsRemaining = (InputFileStream.Length - InputFilePosition) / averageSpeed.Average;

					if (double.IsNormal(estSecsRemaining))
						OnDecryptTimeRemaining(TimeSpan.FromSeconds(estSecsRemaining));

					var progressPercent = 100d * InputFilePosition / InputFileStream.Length;

					OnDecryptProgressUpdate(
						new DownloadProgress
						{
							ProgressPercentage = progressPercent,
							BytesReceived = InputFilePosition,
							TotalBytesToReceive = InputFileStream.Length
						});

					await Task.Delay(200);
				}

				OnDecryptTimeRemaining(TimeSpan.Zero);
				OnDecryptProgressUpdate(zeroProgress);
			}
		}

		public virtual Task CancelAsync()
		{
			IsCanceled = true;
			FinalizeDownload();
			return Task.CompletedTask;
		}
		protected abstract Task<bool> Step_DownloadAndDecryptAudiobookAsync();

		public virtual void SetCoverArt(byte[] coverArt) { }
		protected void OnRetrievedTitle(string? title)
			=> RetrievedTitle?.Invoke(this, title);
		protected void OnRetrievedAuthors(string? authors)
			=> RetrievedAuthors?.Invoke(this, authors);
		protected void OnRetrievedNarrators(string? narrators)
			=> RetrievedNarrators?.Invoke(this, narrators);
		protected void OnRetrievedCoverArt(byte[]? coverArt)
			=> RetrievedCoverArt?.Invoke(this, coverArt);
		protected void OnDecryptProgressUpdate(DownloadProgress downloadProgress)
			=> DecryptProgressUpdate?.Invoke(this, downloadProgress);
		protected void OnDecryptTimeRemaining(TimeSpan timeRemaining)
			=> DecryptTimeRemaining?.Invoke(this, timeRemaining);
		public void OnTempFileCreated(TempFile path)
			=> TempFileCreated?.Invoke(this, path);

		protected virtual void FinalizeDownload()
		{
			NfsPersister.Dispose();
			downloadFinished = true;
		}

		protected async Task<bool> Step_CreateCueAsync()
		{
			if (!DownloadOptions.CreateCueSheet) return !IsCanceled;

			if (DownloadOptions.ChapterInfo.Count <= 1)
			{
				Serilog.Log.Logger.Information($"Skipped creating .cue because book has no chapters.");
				return !IsCanceled;
			}

			// not a critical step. its failure should not prevent future steps from running
			try
			{
				var tempFile = GetNewTempFilePath(".cue");
				await File.WriteAllTextAsync(tempFile.FilePath, Cue.CreateContents(Path.GetFileName(tempFile.FilePath), DownloadOptions.ChapterInfo));
				OnTempFileCreated(tempFile);
			}
			catch (Exception ex)
			{
				Serilog.Log.Logger.Error(ex, $"{nameof(Step_CreateCueAsync)} Failed");
			}
			return !IsCanceled;
		}

		private NetworkFileStreamPersister OpenNetworkFileStream()
		{
			NetworkFileStreamPersister? nfsp = default;
			try
			{
				if (!File.Exists(jsonDownloadState))
					return nfsp = newNetworkFilePersister();

				nfsp = new NetworkFileStreamPersister(jsonDownloadState);
				// The download url expires after 1 hour.
				// The new url points to the same file.
				nfsp.NetworkFileStream.SetUriForSameFile(new Uri(DownloadOptions.DownloadUrl));
				return nfsp;
			}
			catch
			{
				nfsp?.Target?.Dispose();
				FileUtility.SaferDelete(jsonDownloadState);
				FileUtility.SaferDelete(tempFilePath);
				return nfsp = newNetworkFilePersister();
			}
			finally
			{
				//nfsp will only be null when an unhandled exception occurs. Let the caller handle it.
				if (nfsp is not null)
				{
					nfsp.NetworkFileStream.RequestHeaders["User-Agent"] = DownloadOptions.UserAgent;
					nfsp.NetworkFileStream.SpeedLimit = DownloadOptions.DownloadSpeedBps;
					OnTempFileCreated(new(tempFilePath, DownloadOptions.InputType.ToString()));
					OnTempFileCreated(new(jsonDownloadState));
				}
			}

			NetworkFileStreamPersister newNetworkFilePersister()
			{
				var networkFileStream = new NetworkFileStream(tempFilePath, new Uri(DownloadOptions.DownloadUrl), 0, new() { { "User-Agent", DownloadOptions.UserAgent } });
				return new NetworkFileStreamPersister(networkFileStream, jsonDownloadState);
			}
		}
	}
}