Dolittle.SDK.Events.Processing 23.0.0

• net6.0

  • Dolittle.Contracts (>= 7.8.0)
  • Dolittle.SDK.Events (>= 23.0.0)
  • Dolittle.SDK.Resilience (>= 23.0.0)
  • Dolittle.SDK.Services (>= 23.0.0)
  • Microsoft.Extensions.Logging.Abstractions (>= 8.0.0)
  • Newtonsoft.Json (>= 13.0.3)
  • System.Reactive (>= 4.4.1)

• net7.0

  • Dolittle.Contracts (>= 7.8.0)
  • Dolittle.SDK.Events (>= 23.0.0)
  • Dolittle.SDK.Resilience (>= 23.0.0)
  • Dolittle.SDK.Services (>= 23.0.0)
  • Microsoft.Extensions.Logging.Abstractions (>= 8.0.0)
  • Newtonsoft.Json (>= 13.0.3)
  • System.Reactive (>= 4.4.1)

• net8.0

  • Dolittle.Contracts (>= 7.8.0)
  • Dolittle.SDK.Events (>= 23.0.0)
  • Dolittle.SDK.Resilience (>= 23.0.0)
  • Dolittle.SDK.Services (>= 23.0.0)
  • Microsoft.Extensions.Logging.Abstractions (>= 8.0.0)
  • Newtonsoft.Json (>= 13.0.3)
  • System.Reactive (>= 4.4.1)

Version 23.0.0:
Projections:
This version rewrites projections from being a runtime feature to being done completely on the SDK side. It keeps the interface pretty much the same as the old projections, but relaxes some rules around method signatures.  Context is now an optional second parameter, and allows both ProjectionContext or EventContext. KeyFrom is now optional and will default to the EventSourceId. All projections also needs to extend

The existing IProjectionOf and IProjectionStore interfaces have been reduced to expose Get and the ability to use IQueryable, and will now allow all filtering to be done in the DB.

Example Projection

[Projection("055319f1-6af8-48a0-b190-323e21ba6cde")]
public class SomeProjection : ReadModel
{
   public int UpdateCount { get; set; }
   public string Content { get; set; } = string.Empty;
   public int SomeNumber { get; set; }

   public void On(SomeEvent evt, ProjectionContext ctx)
   {
       UpdateCount++;
       Content = evt.Content;
   }

   public void On(SomeOtherEvent evt, ProjectionContext ctx)
   {
       UpdateCount++;
       SomeNumber = evt.SomeNumber;
   }

   public ProjectionResultType On(DeleteEvent _) => ProjectionResultType.Delete;
}Aggregates:
Added Perform<TResponse> which allows the caller to get return values from operations on aggregates.

Added:
- SDK Projections - Full rewrite
- ProjectionTests<TProjection> - Added blackbox testing of projections.
- AggregateRoot.Perform<TResponse> - Ability to get responses from aggregates

Removed:
- Runtime integrated projections

Changelog:
For all release notes, see changelog (https://github.com/dolittle/DotNET.SDK/blob/master/CHANGELOG.md)