Skip to content

Commit af992fd

Browse files
author
andrey.leskov
committed
New class for registering ObjectAdapters
1 parent 4fb0386 commit af992fd

7 files changed

Lines changed: 32 additions & 8 deletions
Lines changed: 23 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,23 @@
1+
using GridDomain.EventSourcing.Adapters;
2+
using Newtonsoft.Json;
3+
4+
namespace GridDomain.Node
5+
{
6+
public static class DomainEventAdapters
7+
{
8+
public static void Register(JsonConverter converter)
9+
{
10+
DomainEventsJsonSerializer.Register(converter);
11+
}
12+
13+
public static void Clear()
14+
{
15+
DomainEventsJsonSerializer.Clear();
16+
}
17+
18+
public static void Register<TFrom, TTo>(ObjectAdapter<TFrom, TTo> converter)
19+
{
20+
DomainEventsJsonSerializer.Register(converter);
21+
}
22+
}
23+
}

GridDomain.Node/DomainEventsJsonSerializer.cs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,7 @@ public DomainEventsJsonSerializer(ExtendedActorSystem system) : base(system)
2323
_log = LogManager.GetLogger();
2424
}
2525

26-
public static void Register(JsonConverter converter)
26+
internal static void Register(JsonConverter converter)
2727
{
2828
JsonSerializerSettings.Converters.Add(converter);
2929
}
@@ -33,7 +33,7 @@ public static void Clear()
3333
JsonSerializerSettings.Converters.Clear();
3434
}
3535

36-
public static void Register<TFrom,TTo>(ObjectAdapter<TFrom, TTo> converter)
36+
internal static void Register<TFrom,TTo>(ObjectAdapter<TFrom, TTo> converter)
3737
{
3838
Register((JsonConverter)converter);
3939
}

GridDomain.Node/GridDomain.Node.csproj

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -250,6 +250,7 @@
250250
<Compile Include="Configuration\Akka\Hocon\TypeExtensions.cs" />
251251
<Compile Include="DefaultAppInsightsConfiguration.cs" />
252252
<Compile Include="DefaultPerfCountersConfiguration.cs" />
253+
<Compile Include="DomainEventsAdapters.cs" />
253254
<Compile Include="EventChronicles\AkkaEventsChronicle.cs" />
254255
<Compile Include="Actors\GridNodeController.cs" />
255256
<Compile Include="Actors\IPersistentChildsRecycleConfiguration.cs" />

GridDomain.Tests.Acceptance/EventsUpgrade/GridNode_should_convert_and_upgrade_events_stored_in_legacy_wire_format.cs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -29,8 +29,8 @@ public GridNode_should_convert_and_upgrade_events_stored_in_legacy_wire_format()
2929
[OneTimeSetUp]
3030
public void When_wire_stored_events_loaded_and_saved_back()
3131
{
32-
DomainEventsJsonSerializer.Register(new BookOrderAdapter());
33-
32+
DomainEventAdapters.Register(new BookOrderAdapter());
33+
3434
var orderA = new BookOrder_V1("A");
3535
var orderB = new BookOrder_V1("B");
3636
var id = Guid.NewGuid();

GridDomain.Tests.Acceptance/EventsUpgrade/GridNode_should_load_events_stored_in_legacy_wire_format.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,7 @@ public GridNode_should_load_events_stored_in_legacy_wire_format():base(false)
2121
[Test]
2222
public void When_wire_stored_events_loaded_and_saved_back()
2323
{
24-
DomainEventsJsonSerializer.Register(new BookOrderAdapter());
24+
DomainEventAdapters.Register(new BookOrderAdapter());
2525

2626
var orderA = new BookOrder_V1("A");
2727
var orderB = new BookOrder_V1("B");

GridDomain.Tests.Acceptance/EventsUpgrade/GridNode_should_upgrade_objects_in_domain_events_after_save_load_by_journal.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,7 @@ public GridNode_should_upgrade_objects_in_domain_events_after_save_load_by_journ
2121
[Test]
2222
public void GridNode_updates_objects_in_events_by_adapter()
2323
{
24-
DomainEventsJsonSerializer.Register(new BookOrderAdapter());
24+
DomainEventAdapters.Register(new BookOrderAdapter());
2525

2626
var orderA = new BookOrder_V1("A");
2727
var orderB = new BookOrder_V1("B");

GridDomain.Tests.Acceptance/EventsUpgrade/GridNode_upgrade_events_stored_in_legacy_wire_format_when_loading_aggregate.cs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -46,8 +46,8 @@ public void Then_domain_events_should_be_upgraded_by_json_custom_adapter()
4646
{
4747
var cmd = new CreateSampleAggregateCommand(1, Guid.NewGuid());
4848

49-
DomainEventsJsonSerializer.Register(new InIncreaseByInstanceAdapter());
50-
DomainEventsJsonSerializer.Register(new NullAdapter());
49+
DomainEventAdapters.Register(new InIncreaseByInstanceAdapter());
50+
DomainEventAdapters.Register(new NullAdapter());
5151

5252
var expect = Expect.Message<SampleAggregateCreatedEvent>();
5353

0 commit comments

Comments
 (0)