Skip to content

Commit

Permalink
Used Events definition as Disciminated Union in exercises
Browse files Browse the repository at this point in the history 
Replaced When method name into Evolve, as it's now more aligned with how people are doing it.
  • Loading branch information
@oskardudycz
oskardudycz committed Apr 26, 2024
1 parent d83b85b commit 451f4f5
Show file tree
Hide file tree
Showing 31 changed files with 392 additions and 306 deletions.
2 changes: 1 addition & 1 deletion Core.ElasticSearch/Projections/ElasticSearchProjection.cs
View file
Expand Up @@ -30,7 +30,7 @@ public async Task Handle(EventEnvelope<TEvent> eventEnvelope, CancellationToken
var entity = (await elasticClient.GetAsync<TView>(id, i => i.Index(indexName), ct).ConfigureAwait(false))?.Source ??
(TView) Activator.CreateInstance(typeof(TView), true)!;

entity.When(eventEnvelope);
entity.Evolve(eventEnvelope);

await elasticClient.IndexAsync(
entity,
Expand Down
2 changes: 1 addition & 1 deletion Core.EventStoreDB/Events/AggregateStreamExtensions.cs
View file
Expand Up @@ -30,7 +30,7 @@ await foreach (var @event in readResult)
{
var eventData = @event.Deserialize();

aggregate.When(eventData!);
aggregate.Evolve(eventData!);
}

return aggregate;
Expand Down
2 changes: 1 addition & 1 deletion Core.Marten/ExternalProjections/MartenExternalProjection.cs
View file
Expand Up @@ -33,7 +33,7 @@ public async Task Handle(EventEnvelope<TEvent> eventEnvelope, CancellationToken
if (entity.LastProcessedPosition >= eventLogPosition)
return;

entity.When(@event);
entity.Evolve(@event);

entity.LastProcessedPosition = eventLogPosition;

Expand Down
4 changes: 2 additions & 2 deletions Core.Tests/AggregateWithWhenTests.cs
View file
Expand Up @@ -55,7 +55,7 @@ public class Invoice: Aggregate<string>
public InvoiceSendMethod SentVia { get; private set; }
public DateTime SentAt { get; private set; }

public override void When(object @event)
public override void Evolve(object @event)
{
switch (@event)
{
Expand Down Expand Up @@ -125,7 +125,7 @@ public void AggregationWithWhenShouldGetTheCurrentState()
// 3. Apply each event on the entity.
foreach (var @event in events)
{
invoice.When(@event);
invoice.Evolve(@event);
}

invoice.Id.Should().Be(invoiceInitiated.Number);
Expand Down
2 changes: 1 addition & 1 deletion Core/Aggregates/Aggregate.cs
View file
Expand Up @@ -12,7 +12,7 @@ public abstract class Aggregate<T>: IAggregate<T> where T : notnull

[NonSerialized] private readonly Queue<object> uncommittedEvents = new();

public virtual void When(object @event) { }
public virtual void Evolve(object @event) { }

public object[] DequeueUncommittedEvents()
{
Expand Down
2 changes: 1 addition & 1 deletion Core/ProcessManagers/ProcessManager.cs
View file
Expand Up @@ -29,7 +29,7 @@ public EventOrCommand[] DequeuePendingMessages()
protected void ScheduleCommand(object @event) =>
scheduledCommands.Enqueue(EventOrCommand.Command(@event));

public virtual void When(object @event)
public virtual void Evolve(object @event)
{
}
}
2 changes: 1 addition & 1 deletion Core/Projections/IProjection.cs
View file
Expand Up @@ -2,7 +2,7 @@

public interface IProjection
{
void When(object @event);
void Evolve(object @event);
}

public interface IVersionedProjection: IProjection
Expand Down
2 changes: 1 addition & 1 deletion Sample/EventStoreDB/ECommerce/Carts/Carts.Tests/Builders/CartBuilder.cs
View file
Expand Up @@ -25,7 +25,7 @@ public ShoppingCart Build()

foreach (var @event in eventsToApply)
{
cart.When(@event);
cart.Evolve(@event);
}

return cart;
Expand Down
2 changes: 1 addition & 1 deletion ...e/EventStoreDB/ECommerce/Carts/Carts/ShoppingCarts/GettingCartById/ShoppingCartDetails.cs
View file
Expand Up @@ -23,7 +23,7 @@ public class ShoppingCartDetails: IVersionedProjection
public long Version { get; set; }


public void When(object @event)
public void Evolve(object @event)
{
switch (@event)
{
Expand Down
2 changes: 1 addition & 1 deletion Sample/EventStoreDB/ECommerce/Carts/Carts/ShoppingCarts/GettingCartHistory/CartHistory.cs
View file
Expand Up @@ -14,7 +14,7 @@ public class CartHistory: IVersionedProjection
public string Description { get; set; } = default!;
public ulong LastProcessedPosition { get; set; }

public void When(object @event)
public void Evolve(object @event)
{
switch (@event)
{
Expand Down
2 changes: 1 addition & 1 deletion ...le/EventStoreDB/ECommerce/Carts/Carts/ShoppingCarts/GettingCarts/ShoppingCartShortInfo.cs
View file
Expand Up @@ -17,7 +17,7 @@ public class ShoppingCartShortInfo: IVersionedProjection

public ulong LastProcessedPosition { get; set; }

public void When(object @event)
public void Evolve(object @event)
{
switch (@event)
{
Expand Down
2 changes: 1 addition & 1 deletion Sample/EventStoreDB/ECommerce/Carts/Carts/ShoppingCarts/ShoppingCart.cs
View file
Expand Up @@ -29,7 +29,7 @@ public class ShoppingCart: Aggregate

private ShoppingCart(){}

public override void When(object @event)
public override void Evolve(object @event)
{
switch (@event)
{
Expand Down
1 change: 1 addition & 0 deletions Workshops/IntroductionToEventSourcing/Solved/01-EventsDefinition/README.md
View file
Expand Up @@ -17,5 +17,6 @@ Events model:

![events](./assets/events.jpg)

There are two alternative solutions:
1. Simple events structure [Solution1/EventsDefinitionTests.cs](./Solution1/EventsDefinitionTests.cs).
2. Events structure with union type to give option to tell that Shopping Cart event is one of the defined types [Solution2/EventsDefinitionTests.cs](./Solution2/EventsDefinitionTests.cs). Read more in [Union types in C#](https://event-driven.io/en/union_types_in_csharp/).
55 changes: 31 additions & 24 deletions Workshops/IntroductionToEventSourcing/Solved/03-AppendingEvents.Marten/AppendingEvents.cs
View file
Expand Up @@ -4,32 +4,39 @@
using Xunit;

namespace IntroductionToEventSourcing.AppendingEvents;
using static ShoppingCartEvent;

// EVENTS
public record ShoppingCartOpened(
Guid ShoppingCartId,
Guid ClientId
);

public record ProductItemAddedToShoppingCart(
Guid ShoppingCartId,
PricedProductItem ProductItem
);

public record ProductItemRemovedFromShoppingCart(
Guid ShoppingCartId,
PricedProductItem ProductItem
);

public record ShoppingCartConfirmed(
Guid ShoppingCartId,
DateTime ConfirmedAt
);

public record ShoppingCartCanceled(
Guid ShoppingCartId,
DateTime CanceledAt
);
public abstract record ShoppingCartEvent
{
public record ShoppingCartOpened(
Guid ShoppingCartId,
Guid ClientId
): ShoppingCartEvent;

public record ProductItemAddedToShoppingCart(
Guid ShoppingCartId,
PricedProductItem ProductItem
): ShoppingCartEvent;

public record ProductItemRemovedFromShoppingCart(
Guid ShoppingCartId,
PricedProductItem ProductItem
): ShoppingCartEvent;

public record ShoppingCartConfirmed(
Guid ShoppingCartId,
DateTime ConfirmedAt
): ShoppingCartEvent;

public record ShoppingCartCanceled(
Guid ShoppingCartId,
DateTime CanceledAt
): ShoppingCartEvent;

// This won't allow
private ShoppingCartEvent(){}
}

// VALUE OBJECTS
public record PricedProductItem(
Expand Down
55 changes: 31 additions & 24 deletions ...ops/IntroductionToEventSourcing/Solved/04-AppendingEvents.EventStoreDB/AppendingEvents.cs
View file
Expand Up @@ -4,32 +4,39 @@
using Xunit;

namespace IntroductionToEventSourcing.AppendingEvents;
using static ShoppingCartEvent;

// EVENTS
public record ShoppingCartOpened(
Guid ShoppingCartId,
Guid ClientId
);

public record ProductItemAddedToShoppingCart(
Guid ShoppingCartId,
PricedProductItem ProductItem
);

public record ProductItemRemovedFromShoppingCart(
Guid ShoppingCartId,
PricedProductItem ProductItem
);

public record ShoppingCartConfirmed(
Guid ShoppingCartId,
DateTime ConfirmedAt
);

public record ShoppingCartCanceled(
Guid ShoppingCartId,
DateTime CanceledAt
);
public abstract record ShoppingCartEvent
{
public record ShoppingCartOpened(
Guid ShoppingCartId,
Guid ClientId
): ShoppingCartEvent;

public record ProductItemAddedToShoppingCart(
Guid ShoppingCartId,
PricedProductItem ProductItem
): ShoppingCartEvent;

public record ProductItemRemovedFromShoppingCart(
Guid ShoppingCartId,
PricedProductItem ProductItem
): ShoppingCartEvent;

public record ShoppingCartConfirmed(
Guid ShoppingCartId,
DateTime ConfirmedAt
): ShoppingCartEvent;

public record ShoppingCartCanceled(
Guid ShoppingCartId,
DateTime CanceledAt
): ShoppingCartEvent;

// This won't allow
private ShoppingCartEvent(){}
}

// VALUE OBJECTS
public record PricedProductItem(
Expand Down
55 changes: 31 additions & 24 deletions ...Sourcing/Solved/05-GettingStateFromEvents.Marten/Immutable/GettingStateFromEventsTests.cs
View file
Expand Up @@ -4,32 +4,39 @@
using Xunit;

namespace IntroductionToEventSourcing.GettingStateFromEvents.Immutable;
using static ShoppingCartEvent;

// EVENTS
public record ShoppingCartOpened(
Guid ShoppingCartId,
Guid ClientId
);

public record ProductItemAddedToShoppingCart(
Guid ShoppingCartId,
PricedProductItem ProductItem
);

public record ProductItemRemovedFromShoppingCart(
Guid ShoppingCartId,
PricedProductItem ProductItem
);

public record ShoppingCartConfirmed(
Guid ShoppingCartId,
DateTime ConfirmedAt
);

public record ShoppingCartCanceled(
Guid ShoppingCartId,
DateTime CanceledAt
);
public abstract record ShoppingCartEvent
{
public record ShoppingCartOpened(
Guid ShoppingCartId,
Guid ClientId
): ShoppingCartEvent;

public record ProductItemAddedToShoppingCart(
Guid ShoppingCartId,
PricedProductItem ProductItem
): ShoppingCartEvent;

public record ProductItemRemovedFromShoppingCart(
Guid ShoppingCartId,
PricedProductItem ProductItem
): ShoppingCartEvent;

public record ShoppingCartConfirmed(
Guid ShoppingCartId,
DateTime ConfirmedAt
): ShoppingCartEvent;

public record ShoppingCartCanceled(
Guid ShoppingCartId,
DateTime CanceledAt
): ShoppingCartEvent;

// This won't allow
private ShoppingCartEvent(){}
}

// VALUE OBJECTS
public record PricedProductItem(
Expand Down
55 changes: 31 additions & 24 deletions ...ntSourcing/Solved/05-GettingStateFromEvents.Marten/Mutable/GettingStateFromEventsTests.cs
View file
Expand Up @@ -4,32 +4,39 @@
using Xunit;

namespace IntroductionToEventSourcing.GettingStateFromEvents.Mutable;
using static ShoppingCartEvent;

// EVENTS
public record ShoppingCartOpened(
Guid ShoppingCartId,
Guid ClientId
);

public record ProductItemAddedToShoppingCart(
Guid ShoppingCartId,
PricedProductItem ProductItem
);

public record ProductItemRemovedFromShoppingCart(
Guid ShoppingCartId,
PricedProductItem ProductItem
);

public record ShoppingCartConfirmed(
Guid ShoppingCartId,
DateTime ConfirmedAt
);

public record ShoppingCartCanceled(
Guid ShoppingCartId,
DateTime CanceledAt
);
public abstract record ShoppingCartEvent
{
public record ShoppingCartOpened(
Guid ShoppingCartId,
Guid ClientId
): ShoppingCartEvent;

public record ProductItemAddedToShoppingCart(
Guid ShoppingCartId,
PricedProductItem ProductItem
): ShoppingCartEvent;

public record ProductItemRemovedFromShoppingCart(
Guid ShoppingCartId,
PricedProductItem ProductItem
): ShoppingCartEvent;

public record ShoppingCartConfirmed(
Guid ShoppingCartId,
DateTime ConfirmedAt
): ShoppingCartEvent;

public record ShoppingCartCanceled(
Guid ShoppingCartId,
DateTime CanceledAt
): ShoppingCartEvent;

// This won't allow
private ShoppingCartEvent(){}
}

// VALUE OBJECTS
public class PricedProductItem
Expand Down

0 comments on commit 451f4f5

Please sign in to comment.