91 lines
3.5 KiB
C#
91 lines
3.5 KiB
C#
using System;
|
|
using System.Collections.Generic;
|
|
using System.Linq;
|
|
using System.Threading.Tasks;
|
|
using AudibleApi;
|
|
using AudibleApiDTOs;
|
|
using Polly;
|
|
using Polly.Retry;
|
|
|
|
namespace InternalUtilities
|
|
{
|
|
public static class AudibleApiActions
|
|
{
|
|
/// <summary>USE THIS from within Libation. It wraps the call with correct JSONPath</summary>
|
|
public static Task<Api> GetApiAsync(string username, string localeName, ILoginCallback loginCallback = null)
|
|
=> EzApiCreator.GetApiAsync(
|
|
Localization.Get(localeName),
|
|
AudibleApiStorage.AccountsSettingsFile,
|
|
AudibleApiStorage.GetIdentityTokensJsonPath(username, localeName),
|
|
loginCallback);
|
|
|
|
/// <summary>USE THIS from within Libation. It wraps the call with correct JSONPath</summary>
|
|
public static Task<Api> GetApiAsync(Account account, ILoginCallback loginCallback = null)
|
|
=> EzApiCreator.GetApiAsync(
|
|
account.Locale,
|
|
AudibleApiStorage.AccountsSettingsFile,
|
|
account.GetIdentityTokensJsonPath(),
|
|
loginCallback);
|
|
|
|
private static AsyncRetryPolicy policy { get; }
|
|
= Policy.Handle<Exception>()
|
|
// 2 retries == 3 total
|
|
.RetryAsync(2);
|
|
|
|
public static Task<List<Item>> GetAllLibraryItemsAsync(Account account, ILoginCallback callback)
|
|
{
|
|
// bug on audible's side. the 1st time after a long absence, a query to get library will return without titles or authors. a subsequent identical query will be successful. this is true whether or tokens are refreshed
|
|
// worse, this 1st dummy call doesn't seem to help:
|
|
// var page = await api.GetLibraryAsync(new AudibleApi.LibraryOptions { NumberOfResultPerPage = 1, PageNumber = 1, PurchasedAfter = DateTime.Now.AddYears(-20), ResponseGroups = AudibleApi.LibraryOptions.ResponseGroupOptions.ALL_OPTIONS });
|
|
// i don't want to incur the cost of making a full dummy call every time because it fails sometimes
|
|
return policy.ExecuteAsync(() => getItemsAsync(account, callback));
|
|
}
|
|
|
|
private static async Task<List<Item>> getItemsAsync(Account account, ILoginCallback callback)
|
|
{
|
|
var api = await GetApiAsync(account, callback);
|
|
var items = await api.GetAllLibraryItemsAsync();
|
|
|
|
// remove episode parents and 'audible plus' check-outs
|
|
items.RemoveAll(i => i.IsEpisodes || i.IsNonLibraryAudiblePlus);
|
|
|
|
#region // episode handling. doesn't quite work
|
|
// // add individual/children episodes
|
|
// var childIds = items
|
|
// .Where(i => i.Episodes)
|
|
// .SelectMany(ep => ep.Relationships)
|
|
// .Where(r => r.RelationshipToProduct == AudibleApiDTOs.RelationshipToProduct.Child && r.RelationshipType == AudibleApiDTOs.RelationshipType.Episode)
|
|
// .Select(c => c.Asin)
|
|
// .ToList();
|
|
// foreach (var childId in childIds)
|
|
// {
|
|
// var bookResult = await api.GetLibraryBookAsync(childId, AudibleApi.LibraryOptions.ResponseGroupOptions.ALL_OPTIONS);
|
|
// var bookItem = AudibleApiDTOs.LibraryDtoV10.FromJson(bookResult.ToString()).Item;
|
|
// items.Add(bookItem);
|
|
// }
|
|
#endregion
|
|
|
|
var validators = new List<IValidator>();
|
|
validators.AddRange(getValidators());
|
|
foreach (var v in validators)
|
|
{
|
|
var exceptions = v.Validate(items);
|
|
if (exceptions != null && exceptions.Any())
|
|
throw new AggregateException(exceptions);
|
|
}
|
|
|
|
return items;
|
|
}
|
|
|
|
private static List<IValidator> getValidators()
|
|
{
|
|
var type = typeof(IValidator);
|
|
var types = AppDomain.CurrentDomain.GetAssemblies()
|
|
.SelectMany(s => s.GetTypes())
|
|
.Where(p => type.IsAssignableFrom(p) && !p.IsInterface);
|
|
|
|
return types.Select(t => Activator.CreateInstance(t) as IValidator).ToList();
|
|
}
|
|
}
|
|
}
|