93 lines
3.4 KiB
C#
93 lines
3.4 KiB
C#
using Microsoft.Extensions.Logging;
|
|
using DD.Persistence.Client.Clients.Base;
|
|
using DD.Persistence.Client.Clients.Interfaces;
|
|
using DD.Persistence.Client.Clients.Interfaces.Refit;
|
|
using DD.Persistence.Models;
|
|
using static System.Runtime.InteropServices.JavaScript.JSType;
|
|
using System.Runtime.CompilerServices;
|
|
using System.Text.Json;
|
|
using System.Reflection;
|
|
using System.Collections.Concurrent;
|
|
|
|
namespace DD.Persistence.Client.Clients;
|
|
public class TimestampedSetClient : BaseClient, ITimestampedSetClient
|
|
{
|
|
private readonly IRefitTimestampedSetClient refitTimestampedSetClient;
|
|
private readonly ConcurrentDictionary<Guid, TimestampedSetMapperBase> mapperCache = new();
|
|
public TimestampedSetClient(IRefitClientFactory<IRefitTimestampedSetClient> refitTimestampedSetClientFactory, ILogger<TimestampedSetClient> logger) : base(logger)
|
|
{
|
|
this.refitTimestampedSetClient = refitTimestampedSetClientFactory.Create();
|
|
}
|
|
|
|
public async Task<int> AddRange(Guid idDiscriminator, IEnumerable<TimestampedSetDto> sets, CancellationToken token)
|
|
{
|
|
var result = await ExecutePostResponse(
|
|
async () => await refitTimestampedSetClient.AddRange(idDiscriminator, sets, token), token);
|
|
|
|
return result;
|
|
}
|
|
|
|
public async Task<IEnumerable<TimestampedSetDto>> Get(Guid idDiscriminator, DateTimeOffset? geTimestamp, IEnumerable<string>? columnNames, int skip, int take, CancellationToken token)
|
|
{
|
|
var result = await ExecuteGetResponse(
|
|
async () => await refitTimestampedSetClient.Get(idDiscriminator, geTimestamp, columnNames, skip, take, token), token);
|
|
|
|
return result!;
|
|
}
|
|
|
|
public async Task<IEnumerable<TimestampedSetDto>> GetLast(Guid idDiscriminator, IEnumerable<string>? columnNames, int take, CancellationToken token)
|
|
{
|
|
var result = await ExecuteGetResponse(
|
|
async () => await refitTimestampedSetClient.GetLast(idDiscriminator, columnNames, take, token), token);
|
|
|
|
return result!;
|
|
}
|
|
|
|
public async Task<int> Count(Guid idDiscriminator, CancellationToken token)
|
|
{
|
|
var result = await ExecuteGetResponse(
|
|
async () => await refitTimestampedSetClient.Count(idDiscriminator, token), token);
|
|
|
|
return result;
|
|
}
|
|
|
|
public async Task<DatesRangeDto?> GetDatesRange(Guid idDiscriminator, CancellationToken token)
|
|
{
|
|
var result = await ExecuteGetResponse(
|
|
async () => await refitTimestampedSetClient.GetDatesRange(idDiscriminator, token), token);
|
|
|
|
return result;
|
|
}
|
|
|
|
public async Task<IEnumerable<T>> Get<T>(Guid idDiscriminator, DateTimeOffset? geTimestamp, IEnumerable<string>? columnNames, int skip, int take, CancellationToken token)
|
|
{
|
|
var data = await Get(idDiscriminator, geTimestamp, columnNames, skip, take, token);
|
|
var mapper = GetMapper<T>(idDiscriminator);
|
|
|
|
return data.Select(mapper.DeserializeTimeStampedData);
|
|
}
|
|
|
|
|
|
|
|
public async Task<IEnumerable<T>> GetLast<T>(Guid idDiscriminator, IEnumerable<string>? columnNames, int take, CancellationToken token)
|
|
{
|
|
var data = await GetLast(idDiscriminator, columnNames, take, token);
|
|
var mapper = GetMapper<T>(idDiscriminator);
|
|
|
|
return data.Select(mapper.DeserializeTimeStampedData);
|
|
}
|
|
|
|
private TimestampedSetMapper<T> GetMapper<T>(Guid idDiscriminator)
|
|
{
|
|
return (TimestampedSetMapper<T>)mapperCache.GetOrAdd(idDiscriminator, name => new TimestampedSetMapper<T>(idDiscriminator));
|
|
}
|
|
public void Dispose()
|
|
{
|
|
refitTimestampedSetClient.Dispose();
|
|
|
|
GC.SuppressFinalize(this);
|
|
}
|
|
|
|
|
|
}
|