Eladei.Architecture.Tests.EntityFramework 1.0.0

Eladei.Architecture

Lightweight CQRS + DDD / Entity Framework Executor for .NET

Eladei.Architecture is a set of libraries for implementing commands and queries with support for CQRS, DDD, EF Core, and Outbox.

Библиотеки

Основные концепции

Команды

• Executed through DddCommandExecutor or EfCommandExecutor.
• Can persist domain events into the Outbox.
• Outbox — ensures reliable message delivery: command execution results and events are stored within the same transaction, while event publishing is performed by a separate process.
• If an error occurs, the transaction is rolled back, and neither events nor execution results are persisted.

Запросы

• Executed through DddQueryExecutor or EfQueryExecutor.
• Return read models without modifying state.

Outbox

• After successful command execution, all domain events are stored in the Outbox.
• Can be integrated with a message bus or another event-processing mechanism.
• Atomicity is guaranteed: either both command results and events are persisted, or everything is rolled back.

Quick Examples

1. EF example (transaction script)

// Command executor
var commandExecutor = new EfCommandExecutor<BookRatingDbContext>(
    contextFactory,
    new MockOperationExecutionPolicyService(),
    new MockOutboxDomainEventDao(eventDaoLogger));

// Query executor
var queryExecutor = new EfQueryExecutor<BookRatingDbContext>(contextFactory);

// Execute command
var registerBookCommand = new RegisterBookCommand("Капитанская дочка", "А.С.Пушкин");

var bookId = await commandExecutor.ExecuteAsync(registerBookCommand, CancellationToken.None);

// Execute query
var findBookQuery = new FindBookByIdQuery(bookId);

var bookInfo = await queryExecutor.ExecuteAsync(findBookQuery, CancellationToken.None);

EF Command Executor Workflow

flowchart TD
    A["Input Command"] --> B["EfCommandExecutor"]
    B --> C["Get Execution Policy (retry)"]
    C --> D["Attempt Execution (up to MaxAttempts)"]
    D --> E["BeforeExecuteAsync"]
    E --> F["Create DbContext & Begin Transaction"]
    F --> G["ExecuteAsync"]
    G --> H{"Has Domain Events?"}
    H -->|Yes| I["Save Domain Events (Outbox)"]
    H -->|No| J["Skip"]
    I --> J["SaveChangesAsync"]
    J --> K["Commit Transaction"]
    F -->|Exception| L["Rollback Transaction"]
    L --> M{"Attempts < MaxAttempts?"}
    M -->|Yes| D
    M -->|No| N["Throw Exception"]
    K --> O["Return Result"]

EF Query Executor Workflow

flowchart TD
    A["Input Query"] --> B["EfQueryExecutor"]
    B --> C["Create DbContext"]
    C --> D["Execute Query (ExecuteAsync)"]
    D --> E{"Exception?"}
    E -->|OperationCanceledException| F["Log Cancelled & throw"]
    E -->|Other Exception| G["Log Critical & throw"]
    E -->|No Exception| H["Return Result"]

2. DDD Example (Application Layer + Domain Model)

// Command executor
var commandExecutor = new DddCommandExecutor(
    contextFactory,
    new MockOperationExecutionPolicyService(),
    new MockOutboxDomainEventDao(eventDaoLogger));

// Query executor
var queryExecutor = new DddQueryExecutor(contextFactory);

 // Execute command
var registerBookCommand = new RegisterBookCommand("Капитанская дочка", "А.С. Пушкин");

var bookId = await _commandExecutor.ExecuteAsync(registerBookCommand, CancellationToken.None);

// Execute query
var query = new FindBookByIdQuery(bookId);

var foundBook = await queryExecutor.ExecuteAsync(query, CancellationToken.None);

DDD Command Executor Workflow

flowchart TD
    A["Input Command"] --> B["DddCommandExecutor"]
    B --> C["Get Execution Policy (retry)"]
    C --> D["Attempt Execution (up to MaxAttempts)"]
    D --> E["BeforeExecuteAsync"]
    E --> F["Create UnitOfWork Context & Begin Transaction"]
    F --> G["ExecuteAsync"]
    G --> H{"Are there domain events?"}
    H -->|Yes| I["Save Domain Events (Outbox)"]
    H -->|No| J["Skip domain events"]
    I --> J["Save Changes (SaveChangesAsync)"]
    J --> K["Commit Transaction"]
    F -->|Exception| L["Rollback Transaction"]
    L --> M{"Attempt < MaxAttempts?"}
    M -->|Yes| D
    M -->|No| N["Throw Exception"]
    K --> O["Return Result / Finish"]

DDD Query Executor Workflow

flowchart TD
    A["Input Query"] --> B["DddQueryExecutor"]
    B --> C["Create UnitOfWork Context"]
    C --> D["ExecuteAsync Query"]
    D --> E{"Exception?"}
    E -->|OperationCanceledException| F["Log Cancelled & Throw"]
    E -->|Other Exception| G["Wrap in QueryExecutingErrorException & Throw"]
    E -->|No Exception| H["Log Success"]
    H --> I["Return Result"]

Notes

• In the EF scenario, commands interact directly with the database through the DbContext (Transaction Script).
• In the DDD scenario, commands operate through the Application Layer by modifying aggregates and producing domain events.
• Command execution results and Outbox events are persisted only after a successful transaction commit.

Full examples: /samples/ConsoleExamples

Samples

ConsoleExamples

• CqrsWithDddExecuting - console application demonstrating command and query execution using the DDD approach.
• CqrsWithEntityFrameworkExecuting - console application demonstrating command and query execution using the Transaction Script approach with Entity Framework.

Notes

The DDD-based domain model is intentionally simplified to demonstrate how the library works. In real-world projects, DDD should only be used for complex business logic.

Microservices (production-ready)

• BookRating: CQRS + transaction script + Outbox + Kafka
• BookInfo: CQRS + transaction script + Outbox + Kafka

Roadmap / TODO

• Unit tests for CQRS libraries (planned)
• Unit and integration tests for microservice samples
• Example microservice with a full-featured DDD implementation