62 lines
2.1 KiB
C#
62 lines
2.1 KiB
C#
using System;
|
|
using System.Collections.Generic;
|
|
using System.Linq;
|
|
using System.Text;
|
|
using System.Text.Json;
|
|
using System.Threading;
|
|
using System.Threading.Tasks;
|
|
using Microsoft.Extensions.Logging;
|
|
|
|
using IF.Lastfm.Core.Api;
|
|
using StackExchange.Redis;
|
|
using SpotifyAPI.Web;
|
|
|
|
namespace Selector.Cache
|
|
{
|
|
public class PlayCounterCaching: PlayCounter
|
|
{
|
|
private readonly IDatabaseAsync Db;
|
|
public TimeSpan CacheExpiry { get; set; } = TimeSpan.FromDays(1);
|
|
|
|
public PlayCounterCaching(
|
|
IPlayerWatcher watcher,
|
|
ITrackApi trackClient,
|
|
IAlbumApi albumClient,
|
|
IArtistApi artistClient,
|
|
IUserApi userClient,
|
|
IDatabaseAsync db,
|
|
LastFmCredentials credentials = null,
|
|
ILogger<PlayCounterCaching> logger = null,
|
|
CancellationToken token = default
|
|
) : base(watcher, trackClient, albumClient, artistClient, userClient, credentials, logger, token)
|
|
{
|
|
Db = db;
|
|
|
|
NewPlayCount += CacheCallback;
|
|
}
|
|
|
|
public void CacheCallback(object sender, PlayCount e)
|
|
{
|
|
Task.Run(async () => { await AsyncCacheCallback(e); }, CancelToken);
|
|
}
|
|
|
|
public async Task AsyncCacheCallback(PlayCount e)
|
|
{
|
|
var track = e.ListeningEvent.Current.Item as FullTrack;
|
|
Logger.LogTrace($"Caching play count for [{track.DisplayString()}]");
|
|
|
|
var tasks = new Task[]
|
|
{
|
|
Db.StringSetAsync(Key.TrackPlayCount(track.Name, track.Artists[0].Name), e.Track, expiry: CacheExpiry),
|
|
Db.StringSetAsync(Key.AlbumPlayCount(track.Album.Name, track.Album.Artists[0].Name), e.Album, expiry: CacheExpiry),
|
|
Db.StringSetAsync(Key.ArtistPlayCount(track.Artists[0].Name), e.Artist, expiry: CacheExpiry),
|
|
Db.StringSetAsync(Key.UserPlayCount(e.Username), e.User, expiry: CacheExpiry),
|
|
};
|
|
|
|
await Task.WhenAll(tasks);
|
|
|
|
Logger.LogDebug($"Cached play count for [{track.DisplayString()}]");
|
|
}
|
|
}
|
|
}
|