Rystem.RepositoryFramework.Abstractions 4.1.23

There is a newer version of this package available.
See the version list below for details.
dotnet add package Rystem.RepositoryFramework.Abstractions --version 4.1.23                
NuGet\Install-Package Rystem.RepositoryFramework.Abstractions -Version 4.1.23                
This command is intended to be used within the Package Manager Console in Visual Studio, as it uses the NuGet module's version of Install-Package.
<PackageReference Include="Rystem.RepositoryFramework.Abstractions" Version="4.1.23" />                
For projects that support PackageReference, copy this XML node into the project file to reference the package.
paket add Rystem.RepositoryFramework.Abstractions --version 4.1.23                
#r "nuget: Rystem.RepositoryFramework.Abstractions, 4.1.23"                
#r directive can be used in F# Interactive and Polyglot Notebooks. Copy this into the interactive tool or source code of the script to reference the package.
// Install Rystem.RepositoryFramework.Abstractions as a Cake Addin
#addin nuget:?package=Rystem.RepositoryFramework.Abstractions&version=4.1.23

// Install Rystem.RepositoryFramework.Abstractions as a Cake Tool
#tool nuget:?package=Rystem.RepositoryFramework.Abstractions&version=4.1.23                

What is Rystem?

Interfaces

Based on CQRS we could split our repository pattern in two main interfaces, one for update (write, delete) and one for read.

Command (Write-Delete)
public interface ICommandPattern<T, TKey> : ICommandPattern
    where TKey : notnull
{
    Task<State<T, TKey>> InsertAsync(TKey key, T value, CancellationToken cancellationToken = default);
    Task<State<T, TKey>> UpdateAsync(TKey key, T value, CancellationToken cancellationToken = default);
    Task<State<T, TKey>> DeleteAsync(TKey key, CancellationToken cancellationToken = default);
    Task<BatchResults<T, TKey>> BatchAsync(BatchOperations<T, TKey> operations, CancellationToken cancellationToken = default);
}
Query (Read)
public interface IQueryPattern<T, TKey> : IQueryPattern
    where TKey : notnull
{
    Task<State<T, TKey>> ExistAsync(TKey key, CancellationToken cancellationToken = default);
    Task<T?> GetAsync(TKey key, CancellationToken cancellationToken = default);
    IAsyncEnumerable<IEntity<T, TKey>> QueryAsync(IFilterExpression filter, CancellationToken cancellationToken = default);
    ValueTask<TProperty> OperationAsync<TProperty>(OperationType<TProperty> operation, IFilterExpression filter, CancellationToken cancellationToken = default);
}
Repository Pattern (Write-Delete-Read)

Repository pattern is a sum of CQRS interfaces.

public interface IRepositoryPattern<T, TKey> : ICommandPattern<T, TKey>, IQueryPattern<T, TKey>, IRepositoryPattern, ICommandPattern, IQueryPattern
    where TKey : notnull
{
    Task<State<T, TKey>> InsertAsync(TKey key, T value, CancellationToken cancellationToken = default);
    Task<State<T, TKey>> UpdateAsync(TKey key, T value, CancellationToken cancellationToken = default);
    Task<State<T, TKey>> DeleteAsync(TKey key, CancellationToken cancellationToken = default);
    Task<BatchResults<T, TKey>> BatchAsync(BatchOperations<T, TKey> operations, CancellationToken cancellationToken = default);
    Task<State<T, TKey>> ExistAsync(TKey key, CancellationToken cancellationToken = default);
    Task<T?> GetAsync(TKey key, CancellationToken cancellationToken = default);
    IAsyncEnumerable<IEntity<T, TKey>> QueryAsync(IFilterExpression filter, CancellationToken cancellationToken = default);
    ValueTask<TProperty> OperationAsync<TProperty>(OperationType<TProperty> operation, IFilterExpression filter, CancellationToken cancellationToken = default);
}

Examples

Model
public class User
{
    public string Id { get; set; }
    public string Name { get; set; }
    public string Email { get; set; }
}
Command

Your storage class has to extend ICommand, and use it on injection

public class UserWriter : ICommand<User, string>
{
    public Task<State<User, string>> DeleteAsync(string key, CancellationToken cancellationToken = default)
    {
        //delete on with DB or storage context
        throw new NotImplementedException();
    }
    public Task<State<User, string>> InsertAsync(string key, User value, CancellationToken cancellationToken = default)
    {
        //insert on DB or storage context
        throw new NotImplementedException();
    }
    public Task<State<User, string>> UpdateAsync(string key, User value, CancellationToken cancellationToken = default)
    {
        //update on DB or storage context
        throw new NotImplementedException();
    }
    public Task<BatchResults<User, string>> BatchAsync(BatchOperations<User, string> operations, CancellationToken cancellationToken = default)
    {
        //insert, update or delete some items on DB or storage context
        throw new NotImplementedException();
    }
}
Query

Your storage class has to extend IQuery, and use it on injection

public class UserReader : IQuery<User, string>
{
    public Task<User?> GetAsync(string key, CancellationToken cancellationToken = default)
    {
        //get an item by key from DB or storage context
        throw new NotImplementedException();
    }
    public Task<State<User, string>> ExistAsync(string key, CancellationToken cancellationToken = default)
    {
        //check if an item by key exists in DB or storage context
        throw new NotImplementedException();
    }
    public IAsyncEnumerable<IEntity<User, string>> QueryAsync(IFilterExpression filter, CancellationToken cancellationToken = default)
    {
        //get a list of items by a predicate with top and skip from DB or storage context
        throw new NotImplementedException();
    }
    public ValueTask<TProperty> OperationAsync<TProperty>(OperationType<TProperty> operation, IFilterExpression filter, CancellationToken cancellationToken = default)
    {
        //get an items count by a predicate with top and skip from DB or storage context or max or min or some other operations
        throw new NotImplementedException();
    }
}
Alltogether as repository pattern

if you don't have CQRS infrastructure (usually it's correct to use CQRS when you have minimum two infrastructures one for write and delete and at least one for read). You may choose to extend IRepository, but when you inject you have to use IRepository

public class UserRepository : IRepository<User, string>, IQuery<User, string>, ICommand<User, string>
{
    public Task<State<User, string>> DeleteAsync(string key, CancellationToken cancellationToken = default)
    {
        //delete on with DB or storage context
        throw new NotImplementedException();
    }
    public Task<State<User, string>> InsertAsync(string key, User value, CancellationToken cancellationToken = default)
    {
        //insert on DB or storage context
        throw new NotImplementedException();
    }
    public Task<State<User, string>> UpdateAsync(string key, User value, CancellationToken cancellationToken = default)
    {
        //update on DB or storage context
        throw new NotImplementedException();
    }
    public Task<BatchResults<User, string>> BatchAsync(BatchOperations<User, string> operations, CancellationToken cancellationToken = default)
    {
        //insert, update or delete some items on DB or storage context
        throw new NotImplementedException();
    }
    public Task<User?> GetAsync(string key, CancellationToken cancellationToken = default)
    {
        //get an item by key from DB or storage context
        throw new NotImplementedException();
    }
    public Task<State<User, string>> ExistAsync(string key, CancellationToken cancellationToken = default)
    {
        //check if an item by key exists in DB or storage context
        throw new NotImplementedException();
    }
    public IAsyncEnumerable<IEntity<User, string>> QueryAsync(IFilterExpression filter, CancellationToken cancellationToken = default)
    {
        //get a list of items by a predicate with top and skip from DB or storage context
        throw new NotImplementedException();
    }
    public ValueTask<TProperty> OperationAsync<TProperty>(OperationType<TProperty> operation, IFilterExpression filter, CancellationToken cancellationToken = default)
    {
        //get an items count by a predicate with top and skip from DB or storage context or max or min or some other operations
        throw new NotImplementedException();
    }
}

How to use it

In DI you install the service

services.AddRepository<User, string, UserRepository>();

And you may inject the object

Please, use IRepository and not IRepositoryPattern

IRepository<User, string> repository

Query and Command

In DI you install the services

services.AddCommand<User, string, UserWriter>();
services.AddQuery<User, string, UserReader>();

And you may inject the objects

Please, use ICommand, IQuery and not ICommandPattern, IQueryPattern

ICommand<User, string> command
IQuery<User, string> command

Twice or more configurations for the same repository service

Pay attention during the DI, you may install the same repository two or more times for the same model. If you want to be sure, you may start the DI with a method that checks for you. When can it happen? For instance, when you use at the same time InMemory integration with a custom integration.

services.ThrowExceptionIfARepositoryServiceIsAddedTwoOrMoreTimes();

TKey when it's not a primitive

You can use a class or record. Record is better in my opinion, for example, if you want to use the Equals operator from key, with record you don't check it by the refence but by the value of the properties in the record. My key:

public class MyKey 
{
    public int Id { get; set; }
    public int Id2 { get; set; }
}

the DI

services.AddRepository<User, MyKey, UserRepository>();

and you may inject (for ICommand and IQuery is the same)

IRepository<User, MyKey> repository

Default TKey record

You may use the default record key in repository framework namespace. It's not really useful when used with no-primitive or no-struct objects (in terms of memory usage [Heap]). For 1 value (it's not really useful I know, but I liked to create it).

new Key<int>(2);

or for 2 values (useful)

new Key<int, int>(2, 4);

or for 3 values (unuseful)

new Key<int, int, string>(2, 4, "312");

or for 4 values (useful)

new Key<int, int, double, Guid>(2, 4, 3, Guid.NewGuid());

or for 5 values (unuseful)

new Key<int, int, string, Guid, string>(2, 4, "312", Guid.NewGuid(), "3232");

the DI

services.AddRepository<User, Key<int, int>, UserRepository>();

and you may inject (for ICommand and IQuery is the same)

IRepository<User, Key<int, int>> repository

Translation

In some cases you need to "translate" your query for your database context query, for example in case of EF integration.

.AddDbContext<SampleContext>(options =>
{
    options.UseSqlServer(configuration["ConnectionString:Database"]);
}, ServiceLifetime.Scoped)
.AddRepository<AppUser, AppUserKey, AppUserStorage>(settings => 
{
    settings
        .Translate<User>()
            .With(x => x.Id, x => x.Identificativo)
            .With(x => x.Username, x => x.Nome)
            .With(x => x.Email, x => x.IndirizzoElettronico);
});

In this case I'm helping the Filter class to understand how to transform itself when used in a different context. Use Filter methods to help to translate and apply to your context the right query.

await foreach (var user in filter.ApplyAsAsyncEnumerable(_context.Users))
    yield return new AppUser(user.Identificativo, user.Nome, user.IndirizzoElettronico, new());

You may use Filter for queryable, FilterAsEnumerable for Enumerable and FilterAsAsyncEnumerable for async enumerable context.

You can add more translations for the same model

.AddDbContext<SampleContext>(options =>
{
    options.UseSqlServer(configuration["ConnectionString:Database"]);
}, ServiceLifetime.Scoped)
.AddRepository<AppUser, AppUserKey, AppUserStorage>(settings => {
    settings
        .Translate<User>()
            .With(x => x.Id, x => x.Identificativo)
            .With(x => x.Username, x => x.Nome)
            .With(x => x.Email, x => x.IndirizzoElettronico)
        .AndTranslate<AnotherUser>()
            .With(x => x.Id, x => x.Identificativo)
            .With(x => x.Username, x => x.Nome)
            .With(x => x.Email, x => x.IndirizzoElettronico)
});

Entity framework examples

Here you may find the example Repository pattern applied Unit test flow

Business Manager

You have the chance to write your business methods to execute them before or after a command or query. For instance, you have to check before an update or insert the value of an entity and deny the final insert/update on the database.

Example

In this example BeforeInsertAsync runs before InsertAsync of IRepository/ICommand and AfterInsertAsync runs after InsertAsync of IRepository/ICommand.

.AddRepositoryInMemoryStorage<Animal, long>(settings => {
    settings
        .AddBusiness()
            .AddBusinessAfterInsert<AnimalBusiness>()
            .AddBusinessBeforeInsert<AnimalBusiness>();
});
    

more interesting usage comes to move business in another project, you can add to your infrastructure in the following way

.AddBusinessForRepository<Animal, long>(settings => {
    settings
        .AddBusiness()
            .AddBusinessAfterInsert<AnimalBusiness>()
            .AddBusinessBeforeInsert<AnimalBusiness>();
});
   

Then, you could have a library for infrastructure (or more than one) and a library for business to separate furthermore the concepts.

The animal business to inject will be the following one.

public sealed class AnimalBusiness : IRepositoryBusinessBeforeInsert<Animal, long>, IRepositoryBusinessAfterInsert<Animal, long>
{
    public static int After;
    public Task<State<Animal>> AfterInsertAsync(State<Animal, long> state, Entity<Animal, long> entity, CancellationToken cancellationToken = default)
    {
        After++;
        return Task.FromResult(state);
    }

    public static int Before;
    public Task<State<Animal, long>> BeforeInsertAsync(Entity<Animal, long> entity, CancellationToken cancellationToken = default)
    {
        Before++;
        return Task.FromResult(State.Ok(entity));
    }
}

You have to create the class as public to allow the dependency injection to instastiate it. It's added directly to DI.

Product Compatible and additional computed target framework versions.
.NET net7.0 is compatible.  net7.0-android was computed.  net7.0-ios was computed.  net7.0-maccatalyst was computed.  net7.0-macos was computed.  net7.0-tvos was computed.  net7.0-windows was computed.  net8.0 was computed.  net8.0-android was computed.  net8.0-browser was computed.  net8.0-ios was computed.  net8.0-maccatalyst was computed.  net8.0-macos was computed.  net8.0-tvos was computed.  net8.0-windows was computed. 
Compatible target framework(s)
Included target framework(s) (in package)
Learn more about Target Frameworks and .NET Standard.

NuGet packages (12)

Showing the top 5 NuGet packages that depend on Rystem.RepositoryFramework.Abstractions:

Package Downloads
Rystem.RepositoryFramework.Api.Server

Rystem.RepositoryFramework allows you to use correctly concepts like repository pattern, CQRS and DDD. You have interfaces for your domains, auto-generated api, auto-generated HttpClient to simplify connection "api to front-end", a functionality for auto-population in memory of your models, a functionality to simulate exceptions and waiting time from external sources to improve your implementation/business test and load test.

Rystem.RepositoryFramework.Api.Client

Rystem.RepositoryFramework allows you to use correctly concepts like repository pattern, CQRS and DDD. You have interfaces for your domains, auto-generated api, auto-generated HttpClient to simplify connection "api to front-end", a functionality for auto-population in memory of your models, a functionality to simulate exceptions and waiting time from external sources to improve your implementation/business test and load test.

Rystem.RepositoryFramework.Infrastructure.Azure.Storage.Blob

Rystem.RepositoryFramework allows you to use correctly concepts like repository pattern, CQRS and DDD. You have interfaces for your domains, auto-generated api, auto-generated HttpClient to simplify connection "api to front-end", a functionality for auto-population in memory of your models, a functionality to simulate exceptions and waiting time from external sources to improve your implementation/business test and load test.

Rystem.RepositoryFramework.Infrastructure.Azure.Storage.Table

Rystem.RepositoryFramework allows you to use correctly concepts like repository pattern, CQRS and DDD. You have interfaces for your domains, auto-generated api, auto-generated HttpClient to simplify connection "api to front-end", a functionality for auto-population in memory of your models, a functionality to simulate exceptions and waiting time from external sources to improve your implementation/business test and load test.

Rystem.RepositoryFramework.Cache

Rystem.RepositoryFramework allows you to use correctly concepts like repository pattern, CQRS and DDD. You have interfaces for your domains, auto-generated api, auto-generated HttpClient to simplify connection "api to front-end", a functionality for auto-population in memory of your models, a functionality to simulate exceptions and waiting time from external sources to improve your implementation/business test and load test.

GitHub repositories

This package is not used by any popular GitHub repositories.

Version Downloads Last updated
9.0.0-rc.1 125 10/18/2024
6.2.0 182,123 10/9/2024
6.1.1 212 10/9/2024
6.1.0 48,080 9/29/2024
6.0.24 348 9/11/2024
6.0.23 340,252 7/18/2024
6.0.21 286 6/18/2024
6.0.20 727,869 6/16/2024
6.0.19 30,678 6/14/2024
6.0.18 255 6/14/2024
6.0.17 258 6/14/2024
6.0.16 50,123 6/10/2024
6.0.15 267 6/9/2024
6.0.14 94,588 5/24/2024
6.0.13 270 5/23/2024
6.0.12 227 5/23/2024
6.0.11 297 5/20/2024
6.0.9 288 5/19/2024
6.0.7 257 5/18/2024
6.0.6 287 5/10/2024
6.0.5 231 5/10/2024
6.0.4 550,227 4/3/2024
6.0.3 1,504 3/25/2024
6.0.2 378,190 3/11/2024
6.0.1 51,170 3/8/2024
6.0.0 1,171,995 11/21/2023
6.0.0-rc.6 140 10/25/2023
6.0.0-rc.5 107 10/25/2023
6.0.0-rc.4 96 10/23/2023
6.0.0-rc.3 82 10/19/2023
6.0.0-rc.2 121 10/18/2023
6.0.0-rc.1 133 10/16/2023
5.0.20 641,466 9/25/2023
5.0.19 3,185 9/10/2023
5.0.18 2,455 9/6/2023
5.0.17 2,353 9/6/2023
5.0.16 2,408 9/5/2023
5.0.15 2,365 9/5/2023
5.0.14 2,379 9/5/2023
5.0.13 2,441 9/1/2023
5.0.12 2,303 8/31/2023
5.0.11 2,326 8/30/2023
5.0.10 2,361 8/29/2023
5.0.9 2,419 8/24/2023
5.0.8 2,467 8/24/2023
5.0.7 451,919 8/23/2023
5.0.6 19,822 8/21/2023
5.0.5 6,572 8/21/2023
5.0.4 2,474 8/16/2023
5.0.3 214,998 8/2/2023
5.0.2 4,289 8/2/2023
5.0.1 14,041 8/1/2023
5.0.0 14,445 7/31/2023
4.1.26 143,321 7/20/2023
4.1.25 27,130 7/16/2023
4.1.24 400,537 6/13/2023
4.1.23 48,212 6/13/2023
4.1.22 132,166 5/30/2023
4.1.21 58,194 5/20/2023
4.1.20 407,569 4/19/2023
4.1.19 98,335 3/20/2023
4.1.18 2,889 3/20/2023
4.1.17 3,141 3/16/2023
4.1.16 2,886 3/16/2023
4.1.15 2,842 3/15/2023
4.1.14 10,561 3/9/2023
4.1.13 2,993 3/7/2023
4.1.12 3,450 2/9/2023
4.1.11 3,052 1/26/2023
4.1.10 3,275 1/22/2023
4.1.9 2,936 1/20/2023
4.1.8 3,211 1/18/2023
4.1.7 3,164 1/18/2023
4.1.6 3,231 1/17/2023
4.1.1 3,188 1/4/2023
4.1.0 3,070 1/1/2023
3.1.5 3,020 12/21/2022
3.1.4 1,537 12/21/2022
3.1.3 3,329 12/12/2022
3.1.2 3,081 12/7/2022
3.1.1 3,169 12/7/2022
3.1.0 3,149 12/1/2022
3.0.29 3,116 12/1/2022
3.0.28 3,947 12/1/2022
3.0.27 3,319 11/23/2022
3.0.25 6,882 11/23/2022
3.0.24 4,539 11/18/2022
3.0.23 4,214 11/18/2022
3.0.22 4,354 11/15/2022
3.0.21 4,393 11/14/2022
3.0.20 4,459 11/13/2022
3.0.19 4,751 11/2/2022
3.0.18 4,489 11/2/2022
3.0.17 4,567 10/29/2022
3.0.16 4,644 10/29/2022
3.0.15 1,635 10/29/2022
3.0.14 7,473 10/24/2022
3.0.13 4,692 10/24/2022
3.0.12 4,702 10/17/2022
3.0.11 4,655 10/10/2022
3.0.10 4,214 10/6/2022
3.0.9 4,142 10/6/2022
3.0.8 4,116 10/6/2022
3.0.7 4,226 10/6/2022
3.0.6 4,220 10/5/2022
3.0.5 4,120 10/5/2022
3.0.4 4,190 10/5/2022
3.0.3 4,170 10/3/2022
3.0.2 4,230 9/30/2022
3.0.1 4,173 9/29/2022
3.0.0 1,671 9/29/2022
2.0.17 3,811 9/29/2022
2.0.16 4,292 9/27/2022
2.0.15 4,402 9/27/2022
2.0.14 4,307 9/26/2022
2.0.13 4,231 9/26/2022
2.0.12 4,227 9/26/2022
2.0.11 4,165 9/25/2022
2.0.10 4,372 9/25/2022
2.0.9 4,241 9/22/2022
2.0.8 4,161 9/22/2022
2.0.7 1,679 9/22/2022
2.0.6 4,173 9/20/2022
2.0.5 4,369 9/20/2022
2.0.4 4,250 9/20/2022
2.0.2 4,267 9/20/2022
2.0.1 4,490 9/13/2022
2.0.0 4,355 8/19/2022
1.1.24 4,375 7/30/2022
1.1.23 4,314 7/29/2022
1.1.22 4,124 7/29/2022
1.1.21 4,528 7/29/2022
1.1.20 4,291 7/29/2022
1.1.19 4,320 7/27/2022
1.1.17 4,334 7/27/2022
1.1.16 4,331 7/26/2022
1.1.15 4,368 7/25/2022
1.1.14 4,330 7/25/2022
1.1.13 4,227 7/22/2022
1.1.12 4,224 7/19/2022
1.1.11 4,301 7/19/2022
1.1.10 4,273 7/19/2022
1.1.9 4,319 7/19/2022
1.1.8 4,372 7/18/2022
1.1.7 4,208 7/18/2022
1.1.6 4,298 7/18/2022
1.1.5 4,292 7/17/2022
1.1.4 1,653 7/17/2022
1.1.3 6,811 7/17/2022
1.1.2 4,350 7/17/2022
1.1.1 1,686 7/17/2022
1.1.0 4,290 7/17/2022
1.0.2 4,295 7/15/2022
1.0.1 2,980 7/15/2022
1.0.0 5,486 7/8/2022
0.10.7 4,300 7/7/2022
0.10.6 1,746 7/7/2022
0.10.3 2,197 7/7/2022
0.10.2 5,743 7/2/2022
0.10.1 4,301 7/1/2022
0.10.0 4,101 7/1/2022
0.9.10 5,404 6/20/2022
0.9.9 4,343 6/11/2022
0.9.8 1,670 6/10/2022
0.9.7 4,238 6/9/2022
0.9.6 4,227 6/5/2022
0.9.5 2,844 6/3/2022
0.9.3 4,135 6/3/2022
0.9.2 2,454 5/31/2022
0.9.1 2,409 5/31/2022
0.9.0 2,395 5/31/2022
0.8.3-beta.1 110 5/31/2022
0.8.2 1,715 5/30/2022
0.8.1 1,724 5/29/2022