Next generation framework for Domain Driven Design needs. .Net Core 2.2 support !
Autofac
SOLID
Domain Driven Design
EntityFramework Core
Dapper
NHibernate
Mapster
AutoMapper
NewtonSoftJson
Utf8Json
RabbitMQ support
Azure Service Bus
Azure Event Grid
MongoDB
Redis
In-Memory
FluentValidation
Serilog support
NLog support
Galaxy.Identity
- Conventional Dependency Registering
- Async await first
- Multi Tenancy
- GlobalQuery Filtering
- Domain Driven Design Concepts
- Repository and UnitofWork pattern implementations
- Object to object mapping with abstraction
- Auto Audit Trailing
- Domain Events Pattern implementation with MediatR
- Net Core 2.x support
- Auto object validation support
- Aspect Oriented Programming
- Simple Usage
- Modularity
Basic Usage
GalaxyCoreModule.New
.RegisterGalaxyContainerBuilder()
.UseGalaxyCore()
.UseGalaxyEntityFrameworkCore<YourDbContext>(conf=>
{
conf.UseSqlServer(Configuration.GetConnectionString("DefaultConnection"));
})
.InitializeGalaxy();
MultiTenancy Activation
.UseGalaxyEntityFrameworkCore<CustomerSampleDbContext>(conf=>
{
conf.UseSqlServer(Configuration.GetConnectionString("DefaultConnection"));
}, typeof(CustomerSampleAppSession))
Conventional Registration
.UseGalaxyCore(b =>
{
b.UseConventinalCustomRepositories(typeof(BrandRepository).Assembly);
b.UseConventinalPolicies(typeof(BrandPolicy).Assembly);
b.UseConventinalDomainService(typeof(Brand).Assembly);
b.UseConventinalApplicationService(typeof(CustomerAppService).Assembly);
b.UseConventinalDomainEventHandlers(typeof(BrandNameChangedDomainEventHandler).Assembly);
...
})
FluentValidators Activation
.UseGalaxyFluentValidation(typeof(BrandValidation).Assembly)
public class BrandValidation : AbstractValidator<BrandDto>
{
public BrandValidation()
{
RuleFor(t => t.Name).NotEmpty().MinimumLength(3);
...
}
}
Mapster Activation
.UseGalaxyMapster()
AutoMapper Activation
.UseGalaxyAutoMapper()
InMemory Cache Activation
.UseGalaxyInMemoryCache(services);
Serilog Activation
.UseGalaxySerilogger( configs => {
...
});
Interceptors Activation
.UseGalaxyCore(b =>
{
b.RegisterAssemblyTypes(typeof(BrandAppService).Assembly)
.AssignableTo<IApplicationService>()
.AsImplementedInterfaces()
.EnableInterfaceInterceptors()
.InterceptedBy(typeof(ValidatorInterceptor))
.InterceptedBy(typeof(UnitOfWorkInterceptor))
.InstancePerLifetimeScope();
...
})
AggregateRoot definations
public class Limit : AggregateRootEntity
{
...
}
public class Brand : AuditAggregateRootEntity
{
...
}
public class Brand : FullyAuditAggregateRootEntity
{
...
}
Entity definations
public class Merchant : Entity
{
...
}
Audit Entity definations
public class Brand : AuditEntity
{
...
}
Fully Audit Entity definations
public class Brand : FullyAuditEntity
{
...
}
Soft Delete definations
// This interface activate global query filtering on soft delete
public class Limit : Entity, ISoftDelete
{
...
}
Domain Events definations
public class BrandNameChangedDomainEvent : INotification
{
public Brand Brand { get; private set; }
public BrandNameChangedDomainEvent(Brand brand)
{
this.Brand = brand;
}
}
Domain Events Firing
public Brand ChangeBrandName(string brandName)
{
this.BrandName = brandName;
AddEvent(new BrandNameChangedDomainEvent(this));
return this;
}
Domain Events Handling
public sealed class BrandNameChangedDomainEventHandler : INotificationHandler<BrandNameChangedDomainEvent>
{
public async Task Handle(BrandNameChangedDomainEvent notification, CancellationToken cancellationToken)
{
...
}
}
Application Service definations
// Query methods all comes from base class. You can override if you want!
public class BrandAppService : QueryAppServiceAsync<BrandDto, int, Brand>
{
public BrandAppService(IRepositoryAsync<Brand, int> repositoryAsync, IObjectMapper objectMapper) : base(repositoryAsync, objectMapper)
{
}
public override Task<BrandDto> FindAsync(int id)
{
return base.FindAsync(id);
}
public override IList<BrandDto> GetAll()
{
return base.GetAll();
}
}
// CRUD methods all comes from base class. You can override if you want!
public class BrandAppService : CrudAppServiceAsync<BrandDto, int, Brand>
{
public BrandAppService(IRepositoryAsync<Brand, int> repositoryAsync
, IObjectMapper objectMapper
, IUnitOfWorkAsync unitOfWork) : base(repositoryAsync, objectMapper, unitOfWork)
{
}
public async Task<BrandDto> GetBrandByIdAsync(int brandId) =>
await FindAsync(brandId);
public async Task<IList<BrandDto>> GetAllBrandsAsync() =>
await this.QueryableNoTrack().ToListAsync();
public async Task<BrandDto> AddNewBrandAsync(BrandDto brandDto)
{
return await AddAsync(async () => {
var brand = Brand.Create(brandDto.EMail, brandDto.BrandName, brandDto.Gsm, brandDto.SNCode);
return brand;
});
}
public async Task<BrandDto> ChangeBrandNameAsync(BrandDto brandDto)
{
return await UpdateAsync(brandDto.Id, async brand => {
brand
.ChangeBrandName(brandDto.BrandName);
});
}
}
CommandHandlers definations
public class DirectPaymentCommandHandler : CommandHandlerBase<PaymentTransaction,int>
, IRequestHandler<DirectPaymentCommand, bool>
{
public DirectPaymentCommandHandler(IUnitOfWorkAsync unitOfWorkAsync
, IRepositoryAsync<PaymentTransaction,int> aggregateRootRepository) : base(unitOfWorkAsync, aggregateRootRepository)
{
}
public async Task<bool> Handle(DirectPaymentCommand request, CancellationToken cancellationToken)
{
await AddAsync(async () =>
{
var paymentTransaction = PaymentTransaction.Create(request.Msisdn, request.OrderId, DateTime.Now);
paymentTransaction
.SetMoney(request.CurrencyCode.Value, request.Amount.Value);
return paymentTransaction;
});
return await Task.FromResult(true);
}
}
Custom Repository definations
public interface IBrandRepository : ICustomRepository
{
}
EntityFrameworkCore definations
public sealed class CustomerSampleDbContext : GalaxyDbContext, IGalaxyContextAsync
{
public const string DEFAULT_SCHEMA = "customer";
public CustomerSampleDbContext(DbContextOptions options) : base(options)
{
}
public CustomerSampleDbContext(DbContextOptions options, IAppSessionBase appSession) : base(options, appSession)
{
}
protected override void OnModelCreating(ModelBuilder modelBuilder)
{
modelBuilder.HasDefaultSchema(DEFAULT_SCHEMA);
base.OnModelCreating(modelBuilder);
...
}
}
public class BrandEntityTypeConfiguration : GalaxyBaseEntityTypeConfigration<Brand>
{
public override void Configure(EntityTypeBuilder<Brand> builder)
{
base.Configure(builder);
builder.ToTable("Brands");
...
}
}
Cache Service definations
public sealed class BrandNameChangedDomainEventHandler : INotificationHandler<BrandNameChangedDomainEvent>
{
private readonly ICache _cacheServ;
public BrandNameChangedDomainEventHandler(ICache cacheServ)
{
_cacheServ = cacheServ;
}
public async Task Handle(BrandNameChangedDomainEvent notification, CancellationToken cancellationToken)
{
var newBrandName = notification.Brand.BrandName;
await this._cacheServ.SetAsync(newBrandName, notification.Brand);
await Task.FromResult(true);
}
}
Log Service definations
private readonly ILog _log;
public CustomerAppService(ILog log)
{
this._log = log
}
public async Task<object> GetBrandByName(string brandName) {
this._log.Warning($"This is a test message!!!");
...
}
Sample Name | Implementations |
---|---|
customerSample | DDD |
paymentSample | DDD, CQRS |
eventStoreSample | DDD, CQRS, Event Sourcing |
I inspired a lot from https://github.com/aspnetboilerplate/aspnetboilerplate. Thank you for the ambition that they gave me.