72 lines
2.9 KiB
C#
72 lines
2.9 KiB
C#
using System;
|
|
using System.Collections.Generic;
|
|
using System.Linq;
|
|
using System.Threading.Tasks;
|
|
using ApplicationServices;
|
|
using DataLayer;
|
|
using Dinah.Core;
|
|
using Dinah.Core.ErrorHandling;
|
|
|
|
namespace FileLiberator
|
|
{
|
|
public static class IProcessableExt
|
|
{
|
|
//
|
|
// DO NOT USE ConfigureAwait(false) WITH ProcessAsync() unless ensuring ProcessAsync() implementation is cross-thread compatible
|
|
// ProcessAsync() often does a lot with forms in the UI context
|
|
//
|
|
|
|
|
|
// when used in foreach: stateful. deferred execution
|
|
public static IEnumerable<LibraryBook> GetValidLibraryBooks(this IProcessable processable)
|
|
=> DbContexts.GetContext()
|
|
.GetLibrary_Flat_NoTracking()
|
|
.Where(libraryBook => processable.Validate(libraryBook));
|
|
|
|
public static LibraryBook GetSingleLibraryBook(string productId)
|
|
{
|
|
using var context = DbContexts.GetContext();
|
|
var libraryBook = context
|
|
.Library
|
|
.GetLibrary()
|
|
.SingleOrDefault(lb => lb.Book.AudibleProductId == productId);
|
|
return libraryBook;
|
|
}
|
|
|
|
/// <summary>Process the first valid product. Create default context</summary>
|
|
/// <returns>Returns either the status handler from the process, or null if all books have been processed</returns>
|
|
public static async Task<StatusHandler> ProcessSingleAsync(this IProcessable processable, LibraryBook libraryBook)
|
|
{
|
|
if (libraryBook == null)
|
|
return null;
|
|
if (!processable.Validate(libraryBook))
|
|
return new StatusHandler { "Validation failed" };
|
|
|
|
return await processable.ProcessBookAsync_NoValidation(libraryBook);
|
|
}
|
|
|
|
public static async Task<StatusHandler> ProcessBookAsync_NoValidation(this IProcessable processable, LibraryBook libraryBook)
|
|
{
|
|
Serilog.Log.Logger.Information("Begin " + nameof(ProcessBookAsync_NoValidation) + " {@DebugInfo}", new
|
|
{
|
|
libraryBook.Book.Title,
|
|
libraryBook.Book.AudibleProductId,
|
|
libraryBook.Book.Locale,
|
|
Account = libraryBook.Account?.ToMask() ?? "[empty]"
|
|
});
|
|
|
|
// this should never happen. check anyway. ProcessFirstValidAsync returning null is the signal that we're done. we can't let another IProcessable accidentally send this command
|
|
var status = await processable.ProcessAsync(libraryBook);
|
|
if (status == null)
|
|
throw new Exception("Processable should never return a null status");
|
|
|
|
return status;
|
|
}
|
|
|
|
public static async Task<StatusHandler> TryProcessAsync(this IProcessable processable, LibraryBook libraryBook)
|
|
=> processable.Validate(libraryBook)
|
|
? await processable.ProcessAsync(libraryBook)
|
|
: new StatusHandler();
|
|
}
|
|
}
|