77 lines
2.9 KiB
C#
77 lines
2.9 KiB
C#
using System;
|
|
using System.Collections.Generic;
|
|
using System.Linq;
|
|
using System.Threading.Tasks;
|
|
using DataLayer;
|
|
using Dinah.Core;
|
|
using Dinah.Core.ErrorHandling;
|
|
|
|
namespace FileLiberator
|
|
{
|
|
public abstract class Processable : Streamable
|
|
{
|
|
public event EventHandler<LibraryBook> Begin;
|
|
|
|
/// <summary>General string message to display. DON'T rely on this for success, failure, or control logic</summary>
|
|
public event EventHandler<string> StatusUpdate;
|
|
|
|
public event EventHandler<LibraryBook> Completed;
|
|
|
|
/// <returns>True == Valid</returns>
|
|
public abstract bool Validate(LibraryBook libraryBook);
|
|
|
|
/// <returns>True == success</returns>
|
|
public abstract Task<StatusHandler> ProcessAsync(LibraryBook libraryBook);
|
|
|
|
// when used in foreach: stateful. deferred execution
|
|
public IEnumerable<LibraryBook> GetValidLibraryBooks(IEnumerable<LibraryBook> library)
|
|
=> library.Where(libraryBook =>
|
|
Validate(libraryBook)
|
|
&& (libraryBook.Book.ContentType != ContentType.Episode || LibationFileManager.Configuration.Instance.DownloadEpisodes)
|
|
);
|
|
|
|
public async Task<StatusHandler> ProcessSingleAsync(LibraryBook libraryBook, bool validate)
|
|
{
|
|
if (validate && !Validate(libraryBook))
|
|
return new StatusHandler { "Validation failed" };
|
|
|
|
Serilog.Log.Logger.Information("Begin " + nameof(ProcessSingleAsync) + " {@DebugInfo}", new
|
|
{
|
|
libraryBook.Book.Title,
|
|
libraryBook.Book.AudibleProductId,
|
|
libraryBook.Book.Locale,
|
|
Account = libraryBook.Account?.ToMask() ?? "[empty]"
|
|
});
|
|
|
|
var status
|
|
= (await ProcessAsync(libraryBook))
|
|
?? new StatusHandler { "Processable should never return a null status" };
|
|
|
|
return status;
|
|
}
|
|
|
|
public async Task<StatusHandler> TryProcessAsync(LibraryBook libraryBook)
|
|
=> Validate(libraryBook)
|
|
? await ProcessAsync(libraryBook)
|
|
: new StatusHandler();
|
|
|
|
protected void OnBegin(LibraryBook libraryBook)
|
|
{
|
|
Serilog.Log.Logger.Debug("Event fired {@DebugInfo}", new { Name = nameof(Begin), Book = libraryBook.LogFriendly() });
|
|
Begin?.Invoke(this, libraryBook);
|
|
}
|
|
|
|
protected void OnStatusUpdate(string statusUpdate)
|
|
{
|
|
Serilog.Log.Logger.Debug("Event fired {@DebugInfo}", new { Name = nameof(StatusUpdate), Status = statusUpdate });
|
|
StatusUpdate?.Invoke(this, statusUpdate);
|
|
}
|
|
|
|
protected void OnCompleted(LibraryBook libraryBook)
|
|
{
|
|
Serilog.Log.Logger.Debug("Event fired {@DebugInfo}", new { Name = nameof(Completed), Book = libraryBook.LogFriendly() });
|
|
Completed?.Invoke(this, libraryBook);
|
|
}
|
|
}
|
|
}
|