1.0.3

.github/workflows/ci.yml

@@ -19,11 +19,13 @@ jobs:
  uses: actions/setup-dotnet@v1
  with:
  dotnet-version: 8.0.x
- - name: Run EventStore
- run: docker compose up -d
  - name: Restore dependencies
  run: dotnet restore
  - name: Build
  run: dotnet build --no-restore
  - name: Test
  run: dotnet test --no-build --verbosity normal
+ - name: Create nuget packages
+ run: dotnet pack -c Release
+ - name: Push nuget packages
+ run: dotnet nuget push */**.nupkg -s https://api.nuget.org/v3/index.json -k "${{ secrets.NUGET_API_KEY }}"

CHANGELOG.md

@@ -0,0 +1,22 @@
+# Change Log
+
+All notable changes to this project will be documented in this file.
+
+## [1.0.3](https://github.com/dariogriffo/marty-net/blob/main/CHANGELOG.md)
+
+Improve pipeline execution.
+
+## [1.0.2](https://github.com/dariogriffo/marty-net/releases/tag/1.0.2)
+
+Hide UncommittedEvents property from `Aggregate` class.
+
+## [1.0.1](https://github.com/dariogriffo/marty-net/releases/tag/1.0.1)
+
+Use DateTimeOffset instead of DateTime for the event timestamp.
+
+Fixed lifetime for IAggregateStore
+
+## [1.0.0](https://github.com/dariogriffo/marty-net/releases/tag/1.0.0)
+
+First version with a stable API.
+

examples/Common/Aggregates/Payment.cs

@@ -1,13 +1,13 @@
 namespace Common.Aggregates;
 
-using System;
-using System.Collections.Generic;
-using System.Linq;
 using Commands;
 using Entities;
 using Events;
 using Marty.Net.Aggregates.Contracts;
 using Marty.Net.Contracts;
+using System;
+using System.Collections.Generic;
+using System.Linq;
 
 public class Payment : Aggregate
 {

examples/Common/Events/PaymentCaptured.cs

@@ -1,8 +1,8 @@
 namespace Common.Events;
 
-using System;
-using System.Collections.Generic;
 using Marty.Net.Contracts;
+using System;
+using System.Collections.Frozen;
 
 public class PaymentCaptured : IEvent
 {
@@ -12,5 +12,5 @@ public class PaymentCaptured : IEvent
 
  public DateTimeOffset Timestamp { get; init; }
 
- public IReadOnlyDictionary<string, string>? Metadata { get; set; }
+ public FrozenDictionary<string, string>? Metadata { get; set; }
 }

examples/Common/Events/PaymentDeclined.cs

@@ -1,8 +1,8 @@
 namespace Common.Events;
 
-using System;
-using System.Collections.Generic;
 using Marty.Net.Contracts;
+using System;
+using System.Collections.Frozen;
 
 public class PaymentDeclined : IEvent
 {
@@ -12,5 +12,5 @@ public class PaymentDeclined : IEvent
 
  public DateTimeOffset Timestamp { get; init; } = DateTimeOffset.UtcNow;
 
- public IReadOnlyDictionary<string, string>? Metadata { get; set; }
+ public FrozenDictionary<string, string>? Metadata { get; set; }
 }

examples/Common/Events/PaymentRefunded.cs

@@ -1,8 +1,8 @@
 namespace Common.Events;
 
-using System;
-using System.Collections.Generic;
 using Marty.Net.Contracts;
+using System;
+using System.Collections.Frozen;
 
 public class PaymentRefunded : IEvent
 {
@@ -12,5 +12,5 @@ public class PaymentRefunded : IEvent
 
  public DateTimeOffset Timestamp { get; init; }
 
- public IReadOnlyDictionary<string, string>? Metadata { get; set; }
+ public FrozenDictionary<string, string>? Metadata { get; set; }
 }

examples/Common/Events/PaymentRequested.cs

@@ -1,8 +1,8 @@
 namespace Common.Events;
 
-using System;
-using System.Collections.Generic;
 using Marty.Net.Contracts;
+using System;
+using System.Collections.Frozen;
 
 public class PaymentRequested : IEvent
 {
@@ -14,5 +14,5 @@ public class PaymentRequested : IEvent
 
  public DateTimeOffset Timestamp { get; init; }
 
- public IReadOnlyDictionary<string, string>? Metadata { get; set; }
+ public FrozenDictionary<string, string>? Metadata { get; set; }
 }

examples/Common/Events/RefundActionAccepted.cs

@@ -1,14 +1,14 @@
 namespace Common.Events;
 
-using System;
-using System.Collections.Generic;
 using Marty.Net.Contracts;
+using System;
+using System.Collections.Frozen;
 
 public class RefundActionAccepted : IEvent
 {
  public string TransactionId { get; init; } = null!;
 
  public DateTimeOffset Timestamp { get; init; }
 
- public IReadOnlyDictionary<string, string>? Metadata { get; set; }
+ public FrozenDictionary<string, string>? Metadata { get; set; }
 }

examples/Common/Events/RefundActionCompleted.cs

@@ -1,8 +1,8 @@
 namespace Common.Events;
 
-using System;
-using System.Collections.Generic;
 using Marty.Net.Contracts;
+using System;
+using System.Collections.Frozen;
 
 public class RefundActionCompleted : IEvent
 {
@@ -16,5 +16,5 @@ public class RefundActionCompleted : IEvent
 
  public DateTimeOffset Timestamp { get; init; }
 
- public IReadOnlyDictionary<string, string>? Metadata { get; set; }
+ public FrozenDictionary<string, string>? Metadata { get; set; }
 }

examples/Common/Events/RefundDeclined.cs

@@ -1,8 +1,8 @@
 namespace Common.Events;
 
-using System;
-using System.Collections.Generic;
 using Marty.Net.Contracts;
+using System;
+using System.Collections.Frozen;
 
 public class RefundDeclined : IEvent
 {
@@ -18,5 +18,5 @@ public class RefundDeclined : IEvent
 
  public DateTimeOffset Timestamp { get; init; }
 
- public IReadOnlyDictionary<string, string>? Metadata { get; set; }
+ public FrozenDictionary<string, string>? Metadata { get; set; }
 }

examples/Common/Events/RefundRequested.cs

@@ -1,8 +1,8 @@
 namespace Common.Events;
 
-using System;
-using System.Collections.Generic;
 using Marty.Net.Contracts;
+using System;
+using System.Collections.Frozen;
 
 public class RefundRequested : IEvent
 {
@@ -15,5 +15,5 @@ public class RefundRequested : IEvent
 
  public DateTimeOffset Timestamp { get; init; }
 
- public IReadOnlyDictionary<string, string>? Metadata { get; set; }
+ public FrozenDictionary<string, string>? Metadata { get; set; }
 }

examples/Common/Events/RefundRequestedRepeated.cs

@@ -1,8 +1,8 @@
 namespace Common.Events;
 
-using System;
-using System.Collections.Generic;
 using Marty.Net.Contracts;
+using System;
+using System.Collections.Frozen;
 
 public class RefundRequestedRepeated : IEvent
 {
@@ -16,5 +16,5 @@ public class RefundRequestedRepeated : IEvent
 
  public DateTimeOffset Timestamp { get; init; }
 
- public IReadOnlyDictionary<string, string>? Metadata { get; set; }
+ public FrozenDictionary<string, string>? Metadata { get; set; }
 }

examples/Publisher/EventStoreConfigurationExtensions.cs

@@ -1,11 +1,11 @@
 namespace Publisher;
 
-using System;
-using System.Collections.Generic;
 using Marty.Net.Contracts;
 using Microsoft.Extensions.Configuration;
 using Microsoft.Extensions.DependencyInjection;
 using Microsoft.Extensions.Logging;
+using System;
+using System.Collections.Generic;
 
 internal static class EventStoreConfigurationExtensions
 {

examples/Publisher/Program.cs

@@ -1,12 +1,12 @@
-using System;
-using System.Text.Json;
-using Common.Aggregates;
+using Common.Aggregates;
 using Common.Commands;
 using Marty.Net;
 using Marty.Net.Aggregates.Contracts;
 using Marty.Net.Contracts;
 using Microsoft.Extensions.DependencyInjection;
 using Publisher;
+using System;
+using System.Text.Json;
 
 ServiceCollection services = new();
 

examples/Subscriber/EventStoreConfigurationExtensions.cs

@@ -1,11 +1,11 @@
 namespace Subscriber;
 
-using System;
-using System.Collections.Generic;
 using Marty.Net.Contracts;
 using Microsoft.Extensions.Configuration;
 using Microsoft.Extensions.DependencyInjection;
 using Microsoft.Extensions.Logging;
+using System;
+using System.Collections.Generic;
 
 internal static class EventStoreConfigurationExtensions
 {

examples/Subscriber/PaymentHandler.cs

@@ -1,10 +1,10 @@
 namespace Subscriber;
 
+using Common.Events;
+using Marty.Net.Contracts;
 using System;
 using System.Threading;
 using System.Threading.Tasks;
-using Common.Events;
-using Marty.Net.Contracts;
 
 public class PaymentHandler : IEventHandler<PaymentRequested>, IEventHandler<PaymentCaptured>
 {

examples/Subscriber/Pipelines/OpenBehavior.cs

@@ -1,10 +1,10 @@
 namespace Subscriber.Pipelines;
 
+using Marty.Net.Contracts;
 using System;
 using System.Text.Json;
 using System.Threading;
 using System.Threading.Tasks;
-using Marty.Net.Contracts;
 
 public class OpenBehavior<T> : IPipelineBehavior<T>
  where T : IEvent

examples/Subscriber/Pipelines/PaymentCapturedPostAction.cs

@@ -1,10 +1,10 @@
 namespace Subscriber.Pipelines;
 
+using Common.Events;
+using Marty.Net.Contracts;
 using System;
 using System.Threading;
 using System.Threading.Tasks;
-using Common.Events;
-using Marty.Net.Contracts;
 
 public class PaymentCapturedPostAction : IPostProcessor<PaymentRequested>
 {

examples/Subscriber/Pipelines/PaymentRequestedLogAction.cs

@@ -1,11 +1,11 @@
 namespace Subscriber.Pipelines;
 
+using Common.Events;
+using Marty.Net.Contracts;
 using System;
 using System.Text.Json;
 using System.Threading;
 using System.Threading.Tasks;
-using Common.Events;
-using Marty.Net.Contracts;
 
 public class PaymentPreActions : IPreProcessor<PaymentRequested>
 {

examples/Subscriber/Pipelines/PaymentRequestedPipeline1.cs

@@ -1,11 +1,11 @@
 namespace Subscriber.Pipelines;
 
+using Common.Events;
+using Marty.Net.Contracts;
 using System;
 using System.Text.Json;
 using System.Threading;
 using System.Threading.Tasks;
-using Common.Events;
-using Marty.Net.Contracts;
 
 public class PaymentRequestedPipeline1 : IPipelineBehavior<PaymentRequested>
 {

examples/Subscriber/Pipelines/PaymentRequestedPipelineBehavior.cs

@@ -1,11 +1,11 @@
 namespace Subscriber.Pipelines;
 
+using Common.Events;
+using Marty.Net.Contracts;
 using System;
 using System.Text.Json;
 using System.Threading;
 using System.Threading.Tasks;
-using Common.Events;
-using Marty.Net.Contracts;
 
 public class PaymentRequestedPipelineBehavior : IPipelineBehavior<PaymentRequested>
 {

examples/Subscriber/Program.cs

@@ -1,11 +1,11 @@
-using System;
-using Common.Aggregates;
+using Common.Aggregates;
 using Marty.Net;
 using Marty.Net.Aggregates.Contracts;
 using Marty.Net.Contracts;
 using Microsoft.Extensions.DependencyInjection;
 using Subscriber;
 using Subscriber.Pipelines;
+using System;
 
 ServiceCollection services = new();
 services

marty-net.sln

@@ -28,8 +28,9 @@ Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "solution-items", "solution-
  .github\workflows\ci.yml = .github\workflows\ci.yml
  MediatR_LICENSE = MediatR_LICENSE
  README.md = README.md
- RELEASE_NOTES.md = RELEASE_NOTES.md
+ CHANGELOG.md = CHANGELOG.md
  LICENSE = LICENSE
+ docker-compose.yml = docker-compose.yml
  EndProjectSection
 EndProject
 Global

src/Marty.Net.Aggregates.Contracts/Aggregate.cs

@@ -1,12 +1,12 @@
 namespace Marty.Net.Aggregates.Contracts;
 
+using Net.Contracts;
+using ReflectionMagic;
 using System;
 using System.Collections.Generic;
 using System.Text.Json.Serialization;
 using System.Threading;
 using System.Threading.Tasks;
-using Net.Contracts;
-using ReflectionMagic;
 
 /// <summary>
 /// A base Aggregate NOT thread safe