mirror/mxpv-podsync
1
0
Fork 0
mirror of https://github.com/mxpv/podsync.git synced 2024-05-11 05:55:04 +00:00
Code Issues Releases Activity

Support additional fields in storage

Browse Source
This commit is contained in:
Maksym Pavlenko
2016-12-10 15:46:16 -08:00
parent 7f007db197
commit 7b746307f7
2 changed files with 33 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/Podsync/Services/Storage/FeedMetadata.cs
+5
View File
@@ -1,4 +1,5 @@
using Podsync.Services.Links;
using Podsync.Services.Resolver;
namespace Podsync.Services.Storage
{
@@ -9,5 +10,9 @@ namespace Podsync.Services.Storage
public LinkType LinkType { get; set; }
public string Id { get; set; }
public ResolveType Quality { get; set; }
public int PageSize { get; set; }
}
}
src/Podsync/Services/Storage/RedisStorage.cs
+28 -5
View File
@@ -5,6 +5,7 @@ using System.Threading.Tasks;
using HashidsNet;
using Microsoft.Extensions.Options;
using Podsync.Services.Links;
using Podsync.Services.Resolver;
using StackExchange.Redis;
namespace Podsync.Services.Storage
@@ -19,6 +20,11 @@ namespace Podsync.Services.Storage
private const string ProviderField = "provider";
private const string TypeField = "type";
private const string IdField = "id";
private const string QualityField = "quality";
private const string PageSizeField = "pageSize";
private const ResolveType DefaultQuality = ResolveType.VideoHigh;
private const int DefaultPageSize = 50;
private static readonly IHashids HashIds = new Hashids(IdSalt, IdLength);
@@ -50,7 +56,9 @@ namespace Podsync.Services.Storage
{
new HashEntry(ProviderField, metadata.Provider.ToString()),
new HashEntry(TypeField, metadata.LinkType.ToString()),
new HashEntry(IdField, metadata.Id)
new HashEntry(IdField, metadata.Id),
new HashEntry(QualityField, metadata.Quality.ToString()),
new HashEntry(PageSizeField, metadata.PageSize),
});
await _db.KeyExpireAsync(id, TimeSpan.FromDays(1));
@@ -67,6 +75,9 @@ namespace Podsync.Services.Storage
var entries = await _db.HashGetAllAsync(key);
// Expire after 3 month if no use
await _db.KeyExpireAsync(key, TimeSpan.FromDays(90));
if (entries.Length == 0)
{
throw new KeyNotFoundException("Invaid key");
@@ -75,10 +86,22 @@ namespace Podsync.Services.Storage
var metadata = new FeedMetadata
{
Id = entries.Single(x => x.Name == IdField).Value,
LinkType = ToEnum<LinkType>(entries.Single(x => x.Name == TypeField).Value),
Provider = ToEnum<Provider>(entries.Single(x => x.Name == ProviderField).Value)
LinkType = ToEnum<LinkType>(entries.Single(x => x.Name == TypeField)),
Provider = ToEnum<Provider>(entries.Single(x => x.Name == ProviderField)),
};
if (entries.Length > 3)
{
metadata.Quality = ToEnum<ResolveType>(entries.Single(x => x.Name == QualityField));
metadata.PageSize = (int)entries.Single(x => x.Name == PageSizeField).Value;
}
else
{
// Set default values
metadata.Quality = DefaultQuality;
metadata.PageSize = DefaultPageSize;
}
return metadata;
}
@@ -93,9 +116,9 @@ namespace Podsync.Services.Storage
return HashIds.EncodeLong(id);
}
private static T ToEnum<T>(string key)
private static T ToEnum<T>(HashEntry key)
{
return (T)Enum.Parse(typeof(T), key, true);
return (T)Enum.Parse(typeof(T), key.Value, true);
}
}
}