35 lines
1.2 KiB
C#
35 lines
1.2 KiB
C#
using Microsoft.Extensions.Caching.Memory;
|
|
using Mirea.Api.Security.Common.Interfaces;
|
|
using System;
|
|
using System.Text.Json;
|
|
using System.Threading;
|
|
using System.Threading.Tasks;
|
|
|
|
namespace Mirea.Api.Endpoint.Common.Services.Security;
|
|
|
|
public class MemoryCacheService(IMemoryCache cache) : ICacheService
|
|
{
|
|
public Task SetAsync<T>(string key, T value, TimeSpan? absoluteExpirationRelativeToNow = null, TimeSpan? slidingExpiration = null, CancellationToken cancellationToken = default)
|
|
{
|
|
var options = new MemoryCacheEntryOptions
|
|
{
|
|
AbsoluteExpirationRelativeToNow = absoluteExpirationRelativeToNow,
|
|
SlidingExpiration = slidingExpiration
|
|
};
|
|
|
|
cache.Set(key, value as byte[] ?? JsonSerializer.SerializeToUtf8Bytes(value), options);
|
|
return Task.CompletedTask;
|
|
}
|
|
|
|
public Task<T?> GetAsync<T>(string key, CancellationToken cancellationToken = default)
|
|
{
|
|
cache.TryGetValue(key, out byte[]? value);
|
|
return Task.FromResult(JsonSerializer.Deserialize<T>(value));
|
|
}
|
|
|
|
public Task RemoveAsync(string key, CancellationToken cancellationToken = default)
|
|
{
|
|
cache.Remove(key);
|
|
return Task.CompletedTask;
|
|
}
|
|
} |