StreamWave 0.1.0

StreamWave AggregateRoot

An aggregate root designed for a streaming environment, addressing the dual write problem by decoupling the domain model from the event stream.

Table of Contents

• Features
• Installation
• Usage
• Configuration
• Contributing
• License

Features

• Easy integration

Installation

To install the package, use the following command in your .NET Core project:

dotnet add package StreamWave

Alternatively, you can add it manually to your .csproj file:

<PackageReference Include="StreamWave" Version="0.1.0" />

Usage

Here are some basic examples of how to use the library:

Setup

Add the aggregate to the service collection

using StreamWave;
using StreamWave.EntityFramework;

var builder = WebApplication.CreateBuilder(args);

builder.Services.AddAggregate<TestState, Guid>(() => new TestState() {  Id = Guid.NewGuid() })
            .WithEntityFramework<TestContext, TestState, Guid>()
            .WithApplier<TestEvent>((s, e) =>
            {
                s.Test = e.Field;
                return s;
            });

Use

public Task HandleAsync(IAggregate<TestState, Guid> aggregate, Guid id)
{
    aggregate.LoadAsync(id);

    aggregate.Apply(new TestEvent("Update"));
}

Configuration

[TODO]

Contributing

Contributions are welcome! Please feel free to submit a pull request or open an issue if you encounter any bugs or have feature requests.

1. Fork the repository
2. Create your feature branch (git checkout -b feature/fooBar)
3. Commit your changes (git commit -am 'Add some fooBar')
4. Push to the branch (git push origin feature/fooBar)
5. Create a new Pull Request

License

This project is licensed under the MIT License - see the LICENSE file for details.