From c4b9878105be1c85dc3556de14ff70c334f0ca7f Mon Sep 17 00:00:00 2001 From: Roman Efremov Date: Fri, 14 Feb 2025 17:13:46 +0500 Subject: [PATCH] =?UTF-8?q?=D0=94=D0=BE=D0=B1=D0=B0=D0=B2=D0=B8=D1=82?= =?UTF-8?q?=D1=8C=20=D1=82=D0=B5=D1=81=D1=82?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../Clients/TimestampedMappingClient.cs | 2 +- .../DD.Persistence.Test.csproj | 1 + DD.Persistence.Test/MappingClientsTest.cs | 40 +++++++++++++++++++ 3 files changed, 42 insertions(+), 1 deletion(-) create mode 100644 DD.Persistence.Test/MappingClientsTest.cs diff --git a/DD.Persistence.Client/Clients/Mapping/Clients/TimestampedMappingClient.cs b/DD.Persistence.Client/Clients/Mapping/Clients/TimestampedMappingClient.cs index 8211fd0..d9ada9c 100644 --- a/DD.Persistence.Client/Clients/Mapping/Clients/TimestampedMappingClient.cs +++ b/DD.Persistence.Client/Clients/Mapping/Clients/TimestampedMappingClient.cs @@ -6,7 +6,7 @@ using System.Collections.Concurrent; using System.Reflection; namespace DD.Persistence.Client.Clients.Mapping.Clients; -internal class TimestampedMappingClient(ITimestampedValuesClient client, Dictionary? mappingConfigs) : ITimestampedMappingClient +public class TimestampedMappingClient(ITimestampedValuesClient client, Dictionary? mappingConfigs) : ITimestampedMappingClient { /// private readonly ConcurrentDictionary mapperCache = new(); diff --git a/DD.Persistence.Test/DD.Persistence.Test.csproj b/DD.Persistence.Test/DD.Persistence.Test.csproj index f71b186..43f350d 100644 --- a/DD.Persistence.Test/DD.Persistence.Test.csproj +++ b/DD.Persistence.Test/DD.Persistence.Test.csproj @@ -16,6 +16,7 @@ + diff --git a/DD.Persistence.Test/MappingClientsTest.cs b/DD.Persistence.Test/MappingClientsTest.cs new file mode 100644 index 0000000..967ce45 --- /dev/null +++ b/DD.Persistence.Test/MappingClientsTest.cs @@ -0,0 +1,40 @@ +using DD.Persistence.Client.Clients.Interfaces; +using DD.Persistence.Client.Clients.Mapping.Abstractions; +using DD.Persistence.Client.Clients.Mapping.Clients; +using DD.Persistence.Repositories; +using DD.Persistence.Services.Interfaces; +using NSubstitute; +using System; +using System.Collections.Generic; +using System.Linq; +using System.Text; +using System.Threading.Tasks; + +namespace DD.Persistence.Test; +public class MappingClientsTest +{ + private readonly ITimestampedValuesClient timestampedValuesClient = Substitute.For(); + private readonly TimestampedMappingClient timestampedMappingClient; + public record TestDto + { + public int Id { get; set; } + public string? Value { get; set; } + } + + private readonly Dictionary mappingConfigs = new Dictionary() + { + { Guid.NewGuid(), typeof(TestDto) } + }; + + public MappingClientsTest() + { + timestampedMappingClient = new TimestampedMappingClient(timestampedValuesClient, mappingConfigs); + } + + [Fact] + public async void Test() + { + var discriminatorIds = mappingConfigs.Keys; + var result = await timestampedMappingClient.Gett(discriminatorIds, null, null, null, 0, 1, CancellationToken.None); + } +}