Compare commits
9
Commits
1.16.0
..
42001998d6
| Author | SHA1 | Date | |
|---|---|---|---|
 Khwezi Mngoma
|
42001998d6 | ||
|
Khwezi Mngoma
|
a42c51d7b2 | ||
|
Khwezi Mngoma
|
26075cd9a7 | ||
|
Khwezi Mngoma
|
cecd9f90e9 | ||
|
Khwezi Mngoma
|
73ba41beaf | ||
|
Khwezi Mngoma
|
e8e9a85c57 | ||
|
Khwezi Mngoma
|
394429677e | ||
|
Khwezi Mngoma
|
32d1019eb5 | ||
|
Khwezi Mngoma
|
275befc258 |
@@ -1,40 +0,0 @@
|
|||||||
<Project Sdk="Microsoft.NET.Sdk">
|
|
||||||
|
|
||||||
<PropertyGroup>
|
|
||||||
<TargetFramework>net10.0</TargetFramework>
|
|
||||||
<ImplicitUsings>enable</ImplicitUsings>
|
|
||||||
<Nullable>enable</Nullable>
|
|
||||||
<SignAssembly>True</SignAssembly>
|
|
||||||
<AssemblyOriginatorKeyFile>..\LiteCharms.snk</AssemblyOriginatorKeyFile>
|
|
||||||
</PropertyGroup>
|
|
||||||
|
|
||||||
<!-- Nuget Package Details -->
|
|
||||||
<PropertyGroup>
|
|
||||||
<PackageId>LiteCharms.Abstractions</PackageId>
|
|
||||||
<Version>1.0.20</Version>
|
|
||||||
<Authors>Khwezi Mngoma</Authors>
|
|
||||||
<Company>Lite Charms (PTY) Ltd</Company>
|
|
||||||
<Description>Shared abstractions for Lite Charms applications.</Description>
|
|
||||||
<PackageProjectUrl>https://gitea.khongisa.co.za/litecharms/components</PackageProjectUrl>
|
|
||||||
<RepositoryUrl>https://gitea.khongisa.co.za/litecharms/components.git</RepositoryUrl>
|
|
||||||
<RepositoryType>git</RepositoryType>
|
|
||||||
<PackageLicenseFile>LICENSE</PackageLicenseFile>
|
|
||||||
<PackageTags>utility;dotnet</PackageTags>
|
|
||||||
<PackageIcon>icon.png</PackageIcon>
|
|
||||||
</PropertyGroup>
|
|
||||||
|
|
||||||
<ItemGroup>
|
|
||||||
<None Include="..\LICENSE" Pack="true" PackagePath="\" />
|
|
||||||
<None Include="..\icon.png" Pack="true" PackagePath="\" />
|
|
||||||
</ItemGroup>
|
|
||||||
|
|
||||||
<ItemGroup>
|
|
||||||
<PackageReference Include="FluentResults" Version="4.0.0" />
|
|
||||||
<PackageReference Include="Mediator.Abstractions" Version="3.0.2" />
|
|
||||||
|
|
||||||
<Using Include="Mediator" />
|
|
||||||
<Using Include="FluentResults" />
|
|
||||||
<Using Include="System.Threading.Channels" />
|
|
||||||
</ItemGroup>
|
|
||||||
|
|
||||||
</Project>
|
|
||||||
@@ -1,22 +0,0 @@
|
|||||||
namespace LiteCharms.Entities.Configuration;
|
|
||||||
|
|
||||||
public class NotificationConfiguration : IEntityTypeConfiguration<Notification>
|
|
||||||
{
|
|
||||||
public void Configure(EntityTypeBuilder<Notification> builder)
|
|
||||||
{
|
|
||||||
builder.ToTable(nameof(Notification));
|
|
||||||
|
|
||||||
builder.HasKey(f => f.Id);
|
|
||||||
builder.Property(f => f.CreatedAt).IsRequired().ValueGeneratedOnAdd();
|
|
||||||
builder.Property(f => f.Direction).IsRequired();
|
|
||||||
builder.Property(f => f.Author).IsRequired();
|
|
||||||
builder.Property(f => f.Title).IsRequired();
|
|
||||||
builder.Property(f => f.Description).IsRequired();
|
|
||||||
builder.Property(f => f.Platform).IsRequired();
|
|
||||||
builder.Property(f => f.PlatformAddress).IsRequired();
|
|
||||||
builder.Property(f => f.CorrelationId).IsRequired();
|
|
||||||
builder.Property(f => f.CorrelationIdType).IsRequired();
|
|
||||||
builder.Property(f => f.IsInternal).HasDefaultValue(true);
|
|
||||||
builder.Property(f => f.Processed).HasDefaultValue(false);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@@ -1,29 +0,0 @@
|
|||||||
namespace LiteCharms.Entities.Configuration;
|
|
||||||
|
|
||||||
public class OrderConfiguration : IEntityTypeConfiguration<Order>
|
|
||||||
{
|
|
||||||
public void Configure(EntityTypeBuilder<Order> builder)
|
|
||||||
{
|
|
||||||
builder.ToTable(nameof(Order));
|
|
||||||
|
|
||||||
builder.HasKey(f => f.Id);
|
|
||||||
builder.Property(f => f.CreatedAt).ValueGeneratedOnAdd();
|
|
||||||
builder.Property(f => f.UpdatedAt).IsRequired(false).ValueGeneratedOnUpdate();
|
|
||||||
builder.Property(f => f.CustomerId).IsRequired();
|
|
||||||
builder.Property(f => f.QuoteId).IsRequired(false);
|
|
||||||
builder.Property(f => f.RefundId).IsRequired(false);
|
|
||||||
builder.Property(f => f.ShoppingCartId).IsRequired();
|
|
||||||
builder.Property(f => f.Status).HasConversion<int>().IsRequired();
|
|
||||||
builder.Property(f => f.Notes).HasColumnType("jsonb").IsRequired(false);
|
|
||||||
|
|
||||||
builder.HasOne(f => f.Quote)
|
|
||||||
.WithOne(f => f.Order)
|
|
||||||
.HasForeignKey<Order>(f => f.QuoteId)
|
|
||||||
.OnDelete(DeleteBehavior.Restrict);
|
|
||||||
|
|
||||||
builder.HasOne(f => f.Customer)
|
|
||||||
.WithMany(f => f.Orders)
|
|
||||||
.HasForeignKey(f => f.CustomerId)
|
|
||||||
.OnDelete(DeleteBehavior.Restrict);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@@ -1,14 +0,0 @@
|
|||||||
namespace LiteCharms.Entities.Configuration;
|
|
||||||
|
|
||||||
public class ProductConfiguration : IEntityTypeConfiguration<Product>
|
|
||||||
{
|
|
||||||
public void Configure(EntityTypeBuilder<Product> builder)
|
|
||||||
{
|
|
||||||
builder.ToTable(nameof(Product));
|
|
||||||
|
|
||||||
builder.HasKey(f => f.Id);
|
|
||||||
builder.Property(f => f.Name).IsRequired();
|
|
||||||
builder.Property(f => f.Description).IsRequired();
|
|
||||||
builder.Property(f => f.Active).HasDefaultValue(true);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@@ -1,23 +0,0 @@
|
|||||||
namespace LiteCharms.Entities.Configuration;
|
|
||||||
|
|
||||||
public class QuoteConfiguration : IEntityTypeConfiguration<Quote>
|
|
||||||
{
|
|
||||||
public void Configure(EntityTypeBuilder<Quote> builder)
|
|
||||||
{
|
|
||||||
builder.ToTable(nameof(Quote));
|
|
||||||
|
|
||||||
builder.HasKey(f => f.Id);
|
|
||||||
builder.Property(f => f.CreatedAt).IsRequired().ValueGeneratedOnAdd();
|
|
||||||
builder.Property(f => f.UpdatedAt).IsRequired().ValueGeneratedOnAddOrUpdate();
|
|
||||||
builder.Property(f => f.ExpiredAt).IsRequired(false);
|
|
||||||
builder.Property(f => f.CustomerId).IsRequired();
|
|
||||||
builder.Property(f => f.Status).IsRequired();
|
|
||||||
builder.Property(f => f.ShoppingCartId).IsRequired();
|
|
||||||
builder.Property(f => f.Reason).IsRequired(false);
|
|
||||||
|
|
||||||
builder.HasOne(f => f.Customer)
|
|
||||||
.WithMany()
|
|
||||||
.HasForeignKey(f => f.CustomerId)
|
|
||||||
.OnDelete(DeleteBehavior.Cascade);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@@ -1,31 +0,0 @@
|
|||||||
namespace LiteCharms.Entities.Configuration;
|
|
||||||
|
|
||||||
public class ShoppingCartConfiguration : IEntityTypeConfiguration<ShoppingCart>
|
|
||||||
{
|
|
||||||
public void Configure(EntityTypeBuilder<ShoppingCart> builder)
|
|
||||||
{
|
|
||||||
builder.ToTable(nameof(ShoppingCart));
|
|
||||||
|
|
||||||
builder.HasKey(f => f.Id);
|
|
||||||
builder.Property(f => f.CreatedAt).IsRequired().ValueGeneratedOnAdd();
|
|
||||||
builder.Property(f => f.UpdatedAt).IsRequired().ValueGeneratedOnAddOrUpdate();
|
|
||||||
builder.Property(f => f.CustomerId).IsRequired(false);
|
|
||||||
builder.Property(f => f.OrderId).IsRequired(false);
|
|
||||||
builder.Property(f => f.QuoteId).IsRequired(false);
|
|
||||||
|
|
||||||
builder.HasOne(f => f.Customer)
|
|
||||||
.WithMany(c => c.ShoppingCarts)
|
|
||||||
.HasForeignKey(f => f.CustomerId)
|
|
||||||
.OnDelete(DeleteBehavior.NoAction);
|
|
||||||
|
|
||||||
builder.HasOne(f => f.Order)
|
|
||||||
.WithOne(o => o.ShoppingCart)
|
|
||||||
.HasForeignKey<Order>(o => o.ShoppingCartId)
|
|
||||||
.OnDelete(DeleteBehavior.NoAction);
|
|
||||||
|
|
||||||
builder.HasOne(f => f.Quote)
|
|
||||||
.WithOne(o => o.ShoppingCart)
|
|
||||||
.HasForeignKey<Quote>(o => o.ShoppingCartId)
|
|
||||||
.OnDelete(DeleteBehavior.NoAction);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@@ -1,25 +0,0 @@
|
|||||||
namespace LiteCharms.Entities.Configuration;
|
|
||||||
|
|
||||||
public class ShoppingCartItemConfiguration : IEntityTypeConfiguration<ShoppingCartItem>
|
|
||||||
{
|
|
||||||
public void Configure(EntityTypeBuilder<ShoppingCartItem> builder)
|
|
||||||
{
|
|
||||||
builder.ToTable(nameof(ShoppingCartItem));
|
|
||||||
|
|
||||||
builder.HasKey(f => f.Id);
|
|
||||||
builder.Property(f => f.CreatedAt).IsRequired().ValueGeneratedOnAdd();
|
|
||||||
builder.Property(f => f.UpdatedAt).IsRequired().ValueGeneratedOnAddOrUpdate();
|
|
||||||
builder.Property(f => f.Quantity).IsRequired().HasDefaultValue(1);
|
|
||||||
builder.Property(f => f.ProductPriceId).IsRequired();
|
|
||||||
|
|
||||||
builder.HasOne(f => f.ProductPrice)
|
|
||||||
.WithMany()
|
|
||||||
.HasForeignKey(f => f.ProductPriceId)
|
|
||||||
.OnDelete(DeleteBehavior.NoAction);
|
|
||||||
|
|
||||||
builder.HasOne(f => f.ShoppingCart)
|
|
||||||
.WithMany(f => f.ShoppingCartItems)
|
|
||||||
.HasForeignKey(f => f.ShoppingCartId)
|
|
||||||
.OnDelete(DeleteBehavior.NoAction);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@@ -1,45 +0,0 @@
|
|||||||
<Project Sdk="Microsoft.NET.Sdk">
|
|
||||||
|
|
||||||
<PropertyGroup>
|
|
||||||
<TargetFramework>net10.0</TargetFramework>
|
|
||||||
<ImplicitUsings>enable</ImplicitUsings>
|
|
||||||
<Nullable>enable</Nullable>
|
|
||||||
<SignAssembly>True</SignAssembly>
|
|
||||||
<AssemblyOriginatorKeyFile>..\LiteCharms.snk</AssemblyOriginatorKeyFile>
|
|
||||||
</PropertyGroup>
|
|
||||||
|
|
||||||
<!-- Nuget Package Details -->
|
|
||||||
<PropertyGroup>
|
|
||||||
<PackageId>LiteCharms.Entities</PackageId>
|
|
||||||
<Version>1.0.20</Version>
|
|
||||||
<Authors>Khwezi Mngoma</Authors>
|
|
||||||
<Company>Lite Charms (PTY) Ltd</Company>
|
|
||||||
<Description>Shared entities for Lite Charms applications.</Description>
|
|
||||||
<PackageProjectUrl>https://gitea.khongisa.co.za/litecharms/components</PackageProjectUrl>
|
|
||||||
<RepositoryUrl>https://gitea.khongisa.co.za/litecharms/components.git</RepositoryUrl>
|
|
||||||
<RepositoryType>git</RepositoryType>
|
|
||||||
<PackageLicenseFile>LICENSE</PackageLicenseFile>
|
|
||||||
<PackageTags>utility;dotnet</PackageTags>
|
|
||||||
<PackageIcon>icon.png</PackageIcon>
|
|
||||||
</PropertyGroup>
|
|
||||||
|
|
||||||
<ItemGroup>
|
|
||||||
<None Include="..\LICENSE" Pack="true" PackagePath="\"/>
|
|
||||||
<None Include="..\icon.png" Pack="true" PackagePath="\" />
|
|
||||||
</ItemGroup>
|
|
||||||
|
|
||||||
<!-- Database -->
|
|
||||||
<ItemGroup>
|
|
||||||
<PackageReference Include="Microsoft.EntityFrameworkCore" Version="10.0.7" />
|
|
||||||
<PackageReference Include="Microsoft.EntityFrameworkCore.Relational" Version="10.0.7" />
|
|
||||||
|
|
||||||
<!-- Global Usings -->
|
|
||||||
<Using Include="Microsoft.EntityFrameworkCore" />
|
|
||||||
<Using Include="Microsoft.EntityFrameworkCore.Metadata.Builders" />
|
|
||||||
</ItemGroup>
|
|
||||||
|
|
||||||
<ItemGroup>
|
|
||||||
<ProjectReference Include="..\LiteCharms.Models\LiteCharms.Models.csproj" />
|
|
||||||
</ItemGroup>
|
|
||||||
|
|
||||||
</Project>
|
|
||||||
@@ -1,15 +0,0 @@
|
|||||||
using LiteCharms.Entities.Configuration;
|
|
||||||
|
|
||||||
namespace LiteCharms.Entities;
|
|
||||||
|
|
||||||
[EntityTypeConfiguration<OrderConfiguration, Order>]
|
|
||||||
public class Order : Models.Order
|
|
||||||
{
|
|
||||||
public virtual OrderRefund? Refund { get; set; }
|
|
||||||
|
|
||||||
public virtual Customer? Customer { get; set; }
|
|
||||||
|
|
||||||
public virtual Quote? Quote { get; set; }
|
|
||||||
|
|
||||||
public virtual ShoppingCart? ShoppingCart { get; set; }
|
|
||||||
}
|
|
||||||
@@ -1,13 +0,0 @@
|
|||||||
using LiteCharms.Models.Configuraton.Email;
|
|
||||||
|
|
||||||
namespace LiteCharms.Extensions;
|
|
||||||
|
|
||||||
public static class Email
|
|
||||||
{
|
|
||||||
public static IServiceCollection AddEmailServices(this IServiceCollection services, IConfiguration configuration)
|
|
||||||
{
|
|
||||||
services.Configure<SmtpSettings>(configuration.GetSection("Email"));
|
|
||||||
|
|
||||||
return services;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@@ -1,113 +0,0 @@
|
|||||||
<Project Sdk="Microsoft.NET.Sdk">
|
|
||||||
|
|
||||||
<PropertyGroup>
|
|
||||||
<TargetFramework>net10.0</TargetFramework>
|
|
||||||
<ImplicitUsings>enable</ImplicitUsings>
|
|
||||||
<Nullable>enable</Nullable>
|
|
||||||
<SignAssembly>True</SignAssembly>
|
|
||||||
<AssemblyOriginatorKeyFile>..\LiteCharms.snk</AssemblyOriginatorKeyFile>
|
|
||||||
<JsonSerializerIsReflectionEnabledByDefault>true</JsonSerializerIsReflectionEnabledByDefault>
|
|
||||||
</PropertyGroup>
|
|
||||||
|
|
||||||
<!-- Warnings And Exclusions -->
|
|
||||||
<PropertyGroup>
|
|
||||||
<NoWarn>$(NoWarn);MA0004</NoWarn>
|
|
||||||
<!-- https://github.com/dotnet/aspnetcore/issues/50836 -->
|
|
||||||
<NoWarn>$(NoWarn);AD0001</NoWarn>
|
|
||||||
<PublishTrimmed>true</PublishTrimmed>
|
|
||||||
<NoWarn>$(NoWarn);IL2080;IL2065;IL2075;IL2087;IL2057;IL2060;IL2070;IL2067;IL2072;IL2026;IL2104</NoWarn>
|
|
||||||
<NoWarn>$(NoWarn);IL2110;IL2111</NoWarn>
|
|
||||||
</PropertyGroup>
|
|
||||||
|
|
||||||
<!-- Nuget Package Details -->
|
|
||||||
<PropertyGroup>
|
|
||||||
<PackageId>LiteCharms.Extensions</PackageId>
|
|
||||||
<Version>1.0.20</Version>
|
|
||||||
<Authors>Khwezi Mngoma</Authors>
|
|
||||||
<Company>Lite Charms (PTY) Ltd</Company>
|
|
||||||
<Description>Extension components for Lite Charms applications.</Description>
|
|
||||||
<PackageProjectUrl>https://gitea.khongisa.co.za/litecharms/components</PackageProjectUrl>
|
|
||||||
<RepositoryUrl>https://gitea.khongisa.co.za/litecharms/components.git</RepositoryUrl>
|
|
||||||
<RepositoryType>git</RepositoryType>
|
|
||||||
<PackageLicenseFile>LICENSE</PackageLicenseFile>
|
|
||||||
<PackageTags>utility;dotnet</PackageTags>
|
|
||||||
<PackageIcon>icon.png</PackageIcon>
|
|
||||||
</PropertyGroup>
|
|
||||||
|
|
||||||
<ItemGroup>
|
|
||||||
<None Include="..\LICENSE" Pack="true" PackagePath="\" />
|
|
||||||
<None Include="..\icon.png" Pack="true" PackagePath="\" />
|
|
||||||
</ItemGroup>
|
|
||||||
|
|
||||||
<!-- Health Checks -->
|
|
||||||
<ItemGroup>
|
|
||||||
<PackageReference Include="AspNetCore.HealthChecks.UI.Client" Version="9.0.0" />
|
|
||||||
<PackageReference Include="AspNetCore.HealthChecks.UI" Version="9.0.0" />
|
|
||||||
<PackageReference Include="AspNetCore.HealthChecks.UI.Core" Version="9.0.0" />
|
|
||||||
<PackageReference Include="AspNetCore.HealthChecks.UI.Data" Version="9.0.0" />
|
|
||||||
<PackageReference Include="AspNetCore.HealthChecks.UI.InMemory.Storage" Version="9.0.0" />
|
|
||||||
<PackageReference Include="Microsoft.EntityFrameworkCore.InMemory" Version="10.0.7" />
|
|
||||||
<PackageReference Include="Microsoft.Extensions.DependencyInjection" Version="10.0.7" />
|
|
||||||
<PackageReference Include="Quartz.AspNetCore" Version="3.18.1" />
|
|
||||||
<PackageReference Include="Quartz.Extensions.DependencyInjection" Version="3.18.1" />
|
|
||||||
|
|
||||||
<!-- Global Usings -->
|
|
||||||
<Using Include="Microsoft.Extensions.Diagnostics.HealthChecks" />
|
|
||||||
<Using Include="Microsoft.AspNetCore.Diagnostics.HealthChecks" />
|
|
||||||
</ItemGroup>
|
|
||||||
|
|
||||||
<!-- Open Telemetry -->
|
|
||||||
<ItemGroup>
|
|
||||||
<PackageReference Include="OpenTelemetry.Exporter.OpenTelemetryProtocol" Version="1.15.3" />
|
|
||||||
<PackageReference Include="OpenTelemetry.Extensions.Hosting" Version="1.15.3" />
|
|
||||||
<PackageReference Include="OpenTelemetry.Instrumentation.AspNetCore" Version="1.15.2" />
|
|
||||||
<PackageReference Include="OpenTelemetry.Instrumentation.Http" Version="1.15.1" />
|
|
||||||
<PackageReference Include="OpenTelemetry.Instrumentation.Runtime" Version="1.15.1" />
|
|
||||||
<PackageReference Include="OpenTelemetry.Exporter.Console" Version="1.15.3" />
|
|
||||||
|
|
||||||
<!-- Global Usings -->
|
|
||||||
<Using Include="OpenTelemetry.Resources" />
|
|
||||||
<Using Include="OpenTelemetry.Exporter" />
|
|
||||||
<Using Include="OpenTelemetry.Logs" />
|
|
||||||
<Using Include="OpenTelemetry.Metrics" />
|
|
||||||
<Using Include="OpenTelemetry.Trace" />
|
|
||||||
</ItemGroup>
|
|
||||||
|
|
||||||
<!-- Database -->
|
|
||||||
<ItemGroup>
|
|
||||||
<PackageReference Include="Microsoft.EntityFrameworkCore" Version="10.0.7" />
|
|
||||||
<PackageReference Include="Microsoft.EntityFrameworkCore.Design" Version="10.0.7">
|
|
||||||
<PrivateAssets>all</PrivateAssets>
|
|
||||||
<IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
|
|
||||||
</PackageReference>
|
|
||||||
<PackageReference Include="Microsoft.EntityFrameworkCore.Relational" Version="10.0.7" />
|
|
||||||
<PackageReference Include="Microsoft.EntityFrameworkCore.Tools" Version="10.0.7">
|
|
||||||
<PrivateAssets>all</PrivateAssets>
|
|
||||||
<IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
|
|
||||||
</PackageReference>
|
|
||||||
<PackageReference Include="Npgsql.EntityFrameworkCore.PostgreSQL" Version="10.0.1" />
|
|
||||||
|
|
||||||
<!-- Global Usings -->
|
|
||||||
<Using Include="Npgsql" />
|
|
||||||
<Using Include="Microsoft.EntityFrameworkCore" />
|
|
||||||
<Using Include="Microsoft.EntityFrameworkCore.Design" />
|
|
||||||
<Using Include="Microsoft.EntityFrameworkCore.Metadata.Builders" />
|
|
||||||
</ItemGroup>
|
|
||||||
|
|
||||||
<!-- Shared Usings -->
|
|
||||||
<ItemGroup>
|
|
||||||
<Using Include="Quartz" />
|
|
||||||
<Using Include="Microsoft.AspNetCore.Builder" />
|
|
||||||
<Using Include="Microsoft.Extensions.Configuration" />
|
|
||||||
<Using Include="Microsoft.Extensions.DependencyInjection" />
|
|
||||||
<Using Include="Microsoft.Extensions.Logging" />
|
|
||||||
</ItemGroup>
|
|
||||||
|
|
||||||
<!-- Project References -->
|
|
||||||
<ItemGroup>
|
|
||||||
<ProjectReference Include="..\LiteCharms.Entities\LiteCharms.Entities.csproj" />
|
|
||||||
<ProjectReference Include="..\LiteCharms.Infrastructure\LiteCharms.Infrastructure.csproj" />
|
|
||||||
<ProjectReference Include="..\LiteCharms.Models\LiteCharms.Models.csproj" />
|
|
||||||
</ItemGroup>
|
|
||||||
|
|
||||||
</Project>
|
|
||||||
@@ -0,0 +1,34 @@
|
|||||||
|
using LiteCharms.Features.Extensions;
|
||||||
|
|
||||||
|
namespace LiteCharms.Features.Tests;
|
||||||
|
|
||||||
|
public class CommonFixture : IDisposable
|
||||||
|
{
|
||||||
|
public IConfiguration Configuration { get; set; }
|
||||||
|
|
||||||
|
public IServiceProvider Services { get; set; }
|
||||||
|
|
||||||
|
public IMediator Mediator { get; set; }
|
||||||
|
|
||||||
|
public CommonFixture()
|
||||||
|
{
|
||||||
|
Configuration = new ConfigurationBuilder()
|
||||||
|
.SetBasePath(Directory.GetCurrentDirectory())
|
||||||
|
.AddJsonFile("appsettings.json")
|
||||||
|
.AddUserSecrets<CommonFixture>()
|
||||||
|
.AddEnvironmentVariables()
|
||||||
|
.Build();
|
||||||
|
|
||||||
|
Services = new ServiceCollection()
|
||||||
|
.AddMediator()
|
||||||
|
.AddLogging()
|
||||||
|
.AddEmailServiceBus()
|
||||||
|
.AddShopDatabase(Configuration)
|
||||||
|
.AddEmailServices(Configuration)
|
||||||
|
.BuildServiceProvider();
|
||||||
|
|
||||||
|
Mediator = Services.GetRequiredService<IMediator>();
|
||||||
|
}
|
||||||
|
|
||||||
|
public void Dispose() { }
|
||||||
|
}
|
||||||
@@ -0,0 +1,50 @@
|
|||||||
|
<Project Sdk="Microsoft.NET.Sdk">
|
||||||
|
|
||||||
|
<PropertyGroup>
|
||||||
|
<TargetFramework>net10.0</TargetFramework>
|
||||||
|
<ImplicitUsings>enable</ImplicitUsings>
|
||||||
|
<Nullable>enable</Nullable>
|
||||||
|
<IsPackable>false</IsPackable>
|
||||||
|
<UserSecretsId>62fa604a-1340-4edb-9ddd-3305fcf46fca</UserSecretsId>
|
||||||
|
</PropertyGroup>
|
||||||
|
|
||||||
|
<ItemGroup>
|
||||||
|
<PackageReference Include="coverlet.collector" Version="10.0.0">
|
||||||
|
<PrivateAssets>all</PrivateAssets>
|
||||||
|
<IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
|
||||||
|
</PackageReference>
|
||||||
|
<PackageReference Include="Mediator.SourceGenerator" Version="3.0.2">
|
||||||
|
<PrivateAssets>all</PrivateAssets>
|
||||||
|
<IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
|
||||||
|
</PackageReference>
|
||||||
|
<PackageReference Include="Microsoft.NET.Test.Sdk" Version="18.5.1" />
|
||||||
|
<PackageReference Include="xunit" Version="2.9.3" />
|
||||||
|
<PackageReference Include="xunit.runner.visualstudio" Version="3.1.5">
|
||||||
|
<PrivateAssets>all</PrivateAssets>
|
||||||
|
<IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
|
||||||
|
</PackageReference>
|
||||||
|
</ItemGroup>
|
||||||
|
|
||||||
|
<!-- Global Usings -->
|
||||||
|
<ItemGroup>
|
||||||
|
<Using Include="Mediator"/>
|
||||||
|
<Using Include="Xunit.Abstractions"/>
|
||||||
|
<Using Include="Microsoft.Extensions.DependencyInjection"/>
|
||||||
|
<Using Include="Microsoft.Extensions.Configuration"/>
|
||||||
|
</ItemGroup>
|
||||||
|
|
||||||
|
<ItemGroup>
|
||||||
|
<ProjectReference Include="..\LiteCharms.Features\LiteCharms.Features.csproj" />
|
||||||
|
</ItemGroup>
|
||||||
|
|
||||||
|
<ItemGroup>
|
||||||
|
<Using Include="Xunit" />
|
||||||
|
</ItemGroup>
|
||||||
|
|
||||||
|
<ItemGroup>
|
||||||
|
<None Update="appsettings.json">
|
||||||
|
<CopyToOutputDirectory>PreserveNewest</CopyToOutputDirectory>
|
||||||
|
</None>
|
||||||
|
</ItemGroup>
|
||||||
|
|
||||||
|
</Project>
|
||||||
@@ -0,0 +1,19 @@
|
|||||||
|
using LiteCharms.Features.Notifications.Commands;
|
||||||
|
|
||||||
|
namespace LiteCharms.Features.Tests;
|
||||||
|
|
||||||
|
public class NotificationsFeatureTests(CommonFixture fixture) : IClassFixture<CommonFixture>
|
||||||
|
{
|
||||||
|
[Fact]
|
||||||
|
public async Task CreateNotificationCommand_ShouldSucceed()
|
||||||
|
{
|
||||||
|
var command = CreateNotification.Create(Models.NotificationDirection.Outgoing, "UnitTest", "khwezi@mngoma.co.za",
|
||||||
|
"CreateNotificationCommand_ShouldSucceed Test", "Test Message", Models.NotificationPlatforms.Email, Models.Priorities.Medium,
|
||||||
|
"Khngisa Shop - Test", "shop@litecharms.co.za", Guid.NewGuid().ToString(), Models.CorrelationIdTypes.None,
|
||||||
|
true, false);
|
||||||
|
|
||||||
|
var result = await fixture.Mediator.Send(command);
|
||||||
|
|
||||||
|
Assert.True(result.IsSuccess);
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -0,0 +1,22 @@
|
|||||||
|
{
|
||||||
|
"Email": {
|
||||||
|
"Credentials": {
|
||||||
|
"Username": "shop@litecharms.co.za"
|
||||||
|
},
|
||||||
|
"Port": 465,
|
||||||
|
"Host": "mail.litecharms.co.za",
|
||||||
|
"UseSsl": true
|
||||||
|
},
|
||||||
|
"Monitoring": {
|
||||||
|
"ApiKey": "",
|
||||||
|
"Address": "http://aspire-dashboard-service.aspire.svc.cluster.local:18889",
|
||||||
|
"ServiceName": "LiteCharms.LeadGenerator"
|
||||||
|
},
|
||||||
|
"Logging": {
|
||||||
|
"LogLevel": {
|
||||||
|
"Default": "Information",
|
||||||
|
"Microsoft.AspNetCore": "Warning"
|
||||||
|
}
|
||||||
|
},
|
||||||
|
"AllowedHosts": "*"
|
||||||
|
}
|
||||||
@@ -0,0 +1,13 @@
|
|||||||
|
using LiteCharms.Features.Extensions;
|
||||||
|
using static LiteCharms.Features.Extensions.Timezones;
|
||||||
|
|
||||||
|
namespace LiteCharms.Features.Abstractions;
|
||||||
|
|
||||||
|
public abstract class EventBase
|
||||||
|
{
|
||||||
|
public Guid Id { get; set; } = Guid.CreateVersion7();
|
||||||
|
|
||||||
|
public DateTimeOffset EnqueueAt { get; set; } = SouthAfricanTimeZone.UtcNow();
|
||||||
|
|
||||||
|
public string CorrelationId { get; set; } = Guid.CreateVersion7().ToString();
|
||||||
|
}
|
||||||
@@ -1,4 +1,4 @@
|
|||||||
namespace LiteCharms.Abstractions;
|
namespace LiteCharms.Features.Abstractions;
|
||||||
|
|
||||||
public interface IEvent : INotification
|
public interface IEvent : INotification
|
||||||
{
|
{
|
||||||
+1
-1
@@ -1,4 +1,4 @@
|
|||||||
namespace LiteCharms.Models.Configuraton.Email;
|
namespace LiteCharms.Features.Email.Configuration;
|
||||||
|
|
||||||
public class Account
|
public class Account
|
||||||
{
|
{
|
||||||
+1
-1
@@ -1,4 +1,4 @@
|
|||||||
namespace LiteCharms.Models.Configuraton.Email;
|
namespace LiteCharms.Features.Email.Configuration;
|
||||||
|
|
||||||
public class SmtpSettings
|
public class SmtpSettings
|
||||||
{
|
{
|
||||||
@@ -0,0 +1,192 @@
|
|||||||
|
using LiteCharms.Features.Email.Configuration;
|
||||||
|
using LiteCharms.Features.Email.Extensions;
|
||||||
|
using LiteCharms.Features.Email.Models;
|
||||||
|
using LiteCharms.Features.Shop;
|
||||||
|
|
||||||
|
namespace LiteCharms.Features.Email;
|
||||||
|
|
||||||
|
public class EmailService(IOptions<SmtpSettings> options) : IEmailService
|
||||||
|
{
|
||||||
|
private readonly SmtpSettings settings = options.Value;
|
||||||
|
private readonly SmtpClient client = new();
|
||||||
|
private readonly int sendMaxCount = 10;
|
||||||
|
private int sendCount = 0;
|
||||||
|
|
||||||
|
public EmailStatuses Status { get; private set; } = EmailStatuses.Disconnected;
|
||||||
|
|
||||||
|
public async Task<Result<Response>> SendEmailAsync(Message message, CancellationToken cancellationToken = default)
|
||||||
|
{
|
||||||
|
using var activity = EmailTelemetry.Source.StartActivity("Email Send");
|
||||||
|
activity?.SetTag("email.recipient", message.Recipient?.Address);
|
||||||
|
|
||||||
|
try
|
||||||
|
{
|
||||||
|
if (Status != EmailStatuses.Connected)
|
||||||
|
{
|
||||||
|
activity?.SetStatus(ActivityStatusCode.Error, "Disconnected");
|
||||||
|
|
||||||
|
return Result.Fail<Response>("Smtp service is disconnected.");
|
||||||
|
}
|
||||||
|
|
||||||
|
var email = new MimeMessage();
|
||||||
|
email.From.Add(new MailboxAddress(message.Sender!.Name, message.Sender.Address!));
|
||||||
|
email.To.Add(new MailboxAddress(message.Recipient!.Name, message.Recipient!.Address!));
|
||||||
|
email.Subject = message.Subject!;
|
||||||
|
|
||||||
|
var bodyBuilder = new BodyBuilder();
|
||||||
|
|
||||||
|
foreach (var attachment in message.Body?.Attachments!)
|
||||||
|
bodyBuilder.Attachments.Add(attachment.Name!, attachment.FileStream!, cancellationToken);
|
||||||
|
|
||||||
|
if (!message.Body.Properties.IsHtml) bodyBuilder.TextBody = message.Body.Message;
|
||||||
|
if (message.Body.Properties.IsHtml) bodyBuilder.HtmlBody = message.Body.Message;
|
||||||
|
|
||||||
|
email.Body = bodyBuilder.ToMessageBody();
|
||||||
|
|
||||||
|
var response = await client.SendAsync(email, cancellationToken);
|
||||||
|
|
||||||
|
bool emailSent = response.Contains("OK", StringComparison.InvariantCultureIgnoreCase);
|
||||||
|
|
||||||
|
message.Dispose();
|
||||||
|
|
||||||
|
Interlocked.Increment(ref sendCount);
|
||||||
|
|
||||||
|
if (sendCount % sendMaxCount == 0)
|
||||||
|
{
|
||||||
|
using var delayActivity = EmailTelemetry.Source.StartActivity("Rate Limit Pause");
|
||||||
|
|
||||||
|
sendCount = 0;
|
||||||
|
|
||||||
|
await Task.Delay(1000, cancellationToken);
|
||||||
|
}
|
||||||
|
|
||||||
|
if (emailSent)
|
||||||
|
{
|
||||||
|
EmailTelemetry.EmailsSent.Add(1, new TagList { { "host", settings.Host } });
|
||||||
|
|
||||||
|
return Result.Ok(Response.Create(EmailStatuses.Success));
|
||||||
|
}
|
||||||
|
|
||||||
|
await DisconnectAsync(cancellationToken);
|
||||||
|
|
||||||
|
if (response.Contains("421"))
|
||||||
|
{
|
||||||
|
Status = EmailStatuses.TooManyConnections;
|
||||||
|
|
||||||
|
return Result.Fail<Response>(response);
|
||||||
|
}
|
||||||
|
|
||||||
|
if (response.Contains("451"))
|
||||||
|
{
|
||||||
|
Status = EmailStatuses.ConnectionAborted;
|
||||||
|
|
||||||
|
return Result.Fail<Response>(response);
|
||||||
|
}
|
||||||
|
|
||||||
|
EmailTelemetry.EmailsFailed.Add(1, new TagList { { "error_message", response } });
|
||||||
|
|
||||||
|
Status = EmailStatuses.Disconnected;
|
||||||
|
|
||||||
|
return Result.Fail<Response>("General error, disconnected");
|
||||||
|
}
|
||||||
|
catch (Exception ex)
|
||||||
|
{
|
||||||
|
activity?.SetStatus(ActivityStatusCode.Error, ex.Message);
|
||||||
|
activity?.AddException(ex);
|
||||||
|
|
||||||
|
EmailTelemetry.EmailsFailed.Add(1, new TagList { { "exception", ex.GetType().Name } });
|
||||||
|
|
||||||
|
return Result.Fail(new Error(ex.Message).CausedBy(ex));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
public async Task<Result<Response>> ConnectAsync(CancellationToken cancellationToken = default)
|
||||||
|
{
|
||||||
|
using var activity = EmailTelemetry.Source.StartActivity("Email Connect");
|
||||||
|
activity?.SetTag("email.smtp.connect", settings.Host);
|
||||||
|
|
||||||
|
try
|
||||||
|
{
|
||||||
|
if (Status is EmailStatuses.Connected) return Result.Ok(Response.Create(Status));
|
||||||
|
|
||||||
|
await client.ConnectAsync(settings.Host!, settings.Port, settings.UseSsl, cancellationToken);
|
||||||
|
await client.AuthenticateAsync(settings.Credentials!.Username!, settings.Credentials.Password!, cancellationToken);
|
||||||
|
|
||||||
|
Status = EmailStatuses.Connected;
|
||||||
|
|
||||||
|
activity?.SetStatus(ActivityStatusCode.Ok, "Connected");
|
||||||
|
|
||||||
|
return Result.Ok(Response.Create(Status));
|
||||||
|
}
|
||||||
|
catch (MailKit.ProtocolException ex)
|
||||||
|
{
|
||||||
|
activity?.SetStatus(ActivityStatusCode.Error, ex.Message);
|
||||||
|
activity?.AddException(ex);
|
||||||
|
|
||||||
|
EmailTelemetry.EmailsFailed.Add(1, new TagList { { "exception", ex.GetType().Name } });
|
||||||
|
|
||||||
|
Status = EmailStatuses.ProtocolError;
|
||||||
|
|
||||||
|
return Result.Fail<Response>(new Error(ex.Message).CausedBy(ex));
|
||||||
|
}
|
||||||
|
catch (Exception ex) when (ex is MailKit.Security.SslHandshakeException || ex is MailKit.Security.AuthenticationException)
|
||||||
|
{
|
||||||
|
activity?.SetStatus(ActivityStatusCode.Error, ex.Message);
|
||||||
|
activity?.AddException(ex);
|
||||||
|
|
||||||
|
EmailTelemetry.EmailsFailed.Add(1, new TagList { { "exception", ex.GetType().Name } });
|
||||||
|
|
||||||
|
Status = EmailStatuses.AuthenticationError;
|
||||||
|
|
||||||
|
return Result.Fail<Response>(new Error(ex.Message).CausedBy(ex));
|
||||||
|
}
|
||||||
|
catch (Exception ex)
|
||||||
|
{
|
||||||
|
activity?.SetStatus(ActivityStatusCode.Error, ex.Message);
|
||||||
|
activity?.AddException(ex);
|
||||||
|
|
||||||
|
EmailTelemetry.EmailsFailed.Add(1, new TagList { { "exception", ex.GetType().Name } });
|
||||||
|
|
||||||
|
Status = EmailStatuses.GeneralError;
|
||||||
|
|
||||||
|
return Result.Fail<Response>(new Error(ex.Message).CausedBy(ex));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
public async Task<Result> DisconnectAsync(CancellationToken cancellationToken = default)
|
||||||
|
{
|
||||||
|
using var activity = EmailTelemetry.Source.StartActivity("Email Disconnect");
|
||||||
|
activity?.SetTag("email.smtp.disconnect", settings.Host);
|
||||||
|
|
||||||
|
try
|
||||||
|
{
|
||||||
|
if (Status is EmailStatuses.Disconnected) return Result.Ok();
|
||||||
|
|
||||||
|
await client.DisconnectAsync(true, cancellationToken);
|
||||||
|
|
||||||
|
activity?.SetStatus(ActivityStatusCode.Ok, "Disconnected");
|
||||||
|
|
||||||
|
Status = EmailStatuses.Disconnected;
|
||||||
|
|
||||||
|
return Result.Ok();
|
||||||
|
}
|
||||||
|
catch (Exception ex)
|
||||||
|
{
|
||||||
|
activity?.SetStatus(ActivityStatusCode.Error, ex.Message);
|
||||||
|
activity?.AddException(ex);
|
||||||
|
|
||||||
|
EmailTelemetry.EmailsFailed.Add(1, new TagList { { "exception", ex.GetType().Name } });
|
||||||
|
|
||||||
|
Status = EmailStatuses.GeneralError;
|
||||||
|
|
||||||
|
return Result.Fail(new Error(ex.Message).CausedBy(ex));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
public void Dispose()
|
||||||
|
{
|
||||||
|
client.Dispose();
|
||||||
|
|
||||||
|
GC.SuppressFinalize(this);
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -0,0 +1,22 @@
|
|||||||
|
using LiteCharms.Features.Notifications.Commands;
|
||||||
|
using LiteCharms.Features.Shop;
|
||||||
|
using static LiteCharms.Features.Email.Extensions.Constants;
|
||||||
|
|
||||||
|
namespace LiteCharms.Features.Email.Events.Handlers;
|
||||||
|
|
||||||
|
// TODO: Inject the INotificationService
|
||||||
|
public class SendShopEmailEnquiryEventHandler(ISender mediator) :
|
||||||
|
INotificationHandler<SendShopEmailEnquiryEvent>
|
||||||
|
{
|
||||||
|
public async ValueTask Handle(SendShopEmailEnquiryEvent notification, CancellationToken cancellationToken)
|
||||||
|
{
|
||||||
|
// TODO: Refactor this to use the NotificationService
|
||||||
|
var command = CreateNotification.Create(NotificationDirection.Outgoing, notification.SenderName!,
|
||||||
|
notification.SenderAddress!, notification.Subject!, notification.Message!, NotificationPlatforms.Email,
|
||||||
|
notification.Priority, ShopEmailFromName, ShopEmailFromAddress, Guid.CreateVersion7().ToString(),
|
||||||
|
CorrelationIdTypes.None, isInternal: true, isHtml: false);
|
||||||
|
|
||||||
|
// TODO: Remove, deprecated
|
||||||
|
await mediator.Send(command, cancellationToken);
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -0,0 +1,40 @@
|
|||||||
|
using LiteCharms.Features.Abstractions;
|
||||||
|
using LiteCharms.Features.Shop;
|
||||||
|
|
||||||
|
namespace LiteCharms.Features.Email.Events;
|
||||||
|
|
||||||
|
public class SendShopEmailEnquiryEvent : EventBase, IEvent
|
||||||
|
{
|
||||||
|
public string Name { get; set; } = nameof(SendShopEmailEnquiryEvent);
|
||||||
|
|
||||||
|
public string? SenderName { get; set; }
|
||||||
|
|
||||||
|
public string? SenderAddress { get; set; }
|
||||||
|
|
||||||
|
public string? Subject { get; set; }
|
||||||
|
|
||||||
|
public string? Message { get; set; }
|
||||||
|
|
||||||
|
public Priorities Priority { get; set; }
|
||||||
|
|
||||||
|
public SendShopEmailEnquiryEvent() { }
|
||||||
|
|
||||||
|
private SendShopEmailEnquiryEvent(string senderName, string senderAddress, string subject, string message, Priorities priority = Priorities.Medium)
|
||||||
|
{
|
||||||
|
SenderName = senderName;
|
||||||
|
SenderAddress = senderAddress;
|
||||||
|
Subject = subject;
|
||||||
|
Message = message;
|
||||||
|
Priority = priority;
|
||||||
|
}
|
||||||
|
|
||||||
|
public static SendShopEmailEnquiryEvent Create(string senderName, string senderAddress, string subject, string message, Priorities priority = Priorities.Medium)
|
||||||
|
{
|
||||||
|
ArgumentNullException.ThrowIfNullOrWhiteSpace(senderName, nameof(senderName));
|
||||||
|
ArgumentNullException.ThrowIfNullOrWhiteSpace(senderAddress, nameof(senderAddress));
|
||||||
|
ArgumentNullException.ThrowIfNullOrWhiteSpace(subject, nameof(subject));
|
||||||
|
ArgumentNullException.ThrowIfNullOrWhiteSpace(message, nameof(message));
|
||||||
|
|
||||||
|
return new(senderName, senderAddress, subject, message, priority);
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -0,0 +1,8 @@
|
|||||||
|
namespace LiteCharms.Features.Email.Extensions;
|
||||||
|
|
||||||
|
public static class Constants
|
||||||
|
{
|
||||||
|
public const string ShopSchedulerName = "shop";
|
||||||
|
public const string ShopEmailFromName = "Khongisa Shop";
|
||||||
|
public const string ShopEmailFromAddress = "shop@litecharms.co.za";
|
||||||
|
}
|
||||||
@@ -0,0 +1,9 @@
|
|||||||
|
namespace LiteCharms.Features.Email.Extensions;
|
||||||
|
|
||||||
|
public static class EmailTelemetry
|
||||||
|
{
|
||||||
|
public static readonly ActivitySource Source = new("LiteCharms.EmailService");
|
||||||
|
public static readonly Meter Meter = new("LiteCharms.EmailService");
|
||||||
|
public static readonly Counter<long> EmailsSent = Meter.CreateCounter<long>("emails_sent_total", "count", "Total successful emails sent");
|
||||||
|
public static readonly Counter<long> EmailsFailed = Meter.CreateCounter<long>("emails_failed_total", "count", "Total failed email attempts");
|
||||||
|
}
|
||||||
@@ -0,0 +1,19 @@
|
|||||||
|
using LiteCharms.Features.Email.Configuration;
|
||||||
|
|
||||||
|
namespace LiteCharms.Features.Email.Extensions;
|
||||||
|
|
||||||
|
public static class Setup
|
||||||
|
{
|
||||||
|
public static IServiceCollection AddEmailServices(this IServiceCollection services, IConfiguration configuration)
|
||||||
|
{
|
||||||
|
services.Configure<SmtpSettings>(configuration.GetSection("Email"));
|
||||||
|
|
||||||
|
services.AddSingleton<IEmailService, EmailService>();
|
||||||
|
|
||||||
|
services.AddOpenTelemetry()
|
||||||
|
.WithTracing(tracing => tracing.AddSource("LiteCharms.EmailService"))
|
||||||
|
.WithMetrics(metrics => metrics.AddMeter("LiteCharms.EmailService"));
|
||||||
|
|
||||||
|
return services;
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -0,0 +1,15 @@
|
|||||||
|
using LiteCharms.Features.Email.Models;
|
||||||
|
using LiteCharms.Features.Shop;
|
||||||
|
|
||||||
|
namespace LiteCharms.Features.Email;
|
||||||
|
|
||||||
|
public interface IEmailService : IDisposable
|
||||||
|
{
|
||||||
|
EmailStatuses Status { get; }
|
||||||
|
|
||||||
|
Task<Result<Response>> SendEmailAsync(Message message, CancellationToken cancellationToken = default);
|
||||||
|
|
||||||
|
Task<Result<Response>> ConnectAsync(CancellationToken cancellationToken = default);
|
||||||
|
|
||||||
|
Task<Result> DisconnectAsync(CancellationToken cancellationToken = default);
|
||||||
|
}
|
||||||
@@ -0,0 +1,8 @@
|
|||||||
|
namespace LiteCharms.Features.Email.Models;
|
||||||
|
|
||||||
|
public class Attachment
|
||||||
|
{
|
||||||
|
public string? Name { get; set; }
|
||||||
|
|
||||||
|
public Stream? FileStream { get; set; }
|
||||||
|
}
|
||||||
@@ -0,0 +1,26 @@
|
|||||||
|
namespace LiteCharms.Features.Email.Models;
|
||||||
|
|
||||||
|
public class Body : IDisposable
|
||||||
|
{
|
||||||
|
public string? Message { get; set; }
|
||||||
|
|
||||||
|
public ReadOnlyCollection<Attachment>? Attachments { get; set; }
|
||||||
|
|
||||||
|
public BodyProperties Properties { get; set; } = new();
|
||||||
|
|
||||||
|
public void Dispose()
|
||||||
|
{
|
||||||
|
if (Attachments is null) return;
|
||||||
|
|
||||||
|
foreach (var attachment in Attachments!)
|
||||||
|
{
|
||||||
|
if (attachment is not null)
|
||||||
|
{
|
||||||
|
attachment.FileStream!.Close();
|
||||||
|
attachment.FileStream!.Dispose();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
GC.SuppressFinalize(this);
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -0,0 +1,8 @@
|
|||||||
|
namespace LiteCharms.Features.Email.Models;
|
||||||
|
|
||||||
|
public class BodyProperties
|
||||||
|
{
|
||||||
|
public bool IsHtml { get; set; }
|
||||||
|
|
||||||
|
public bool HasAttachments { get; set; }
|
||||||
|
}
|
||||||
+3
-1
@@ -1,4 +1,6 @@
|
|||||||
namespace LiteCharms.Models;
|
using System.ComponentModel.DataAnnotations;
|
||||||
|
|
||||||
|
namespace LiteCharms.Features.Email.Models;
|
||||||
|
|
||||||
public sealed class EmailEnquiry
|
public sealed class EmailEnquiry
|
||||||
{
|
{
|
||||||
@@ -0,0 +1,19 @@
|
|||||||
|
namespace LiteCharms.Features.Email.Models;
|
||||||
|
|
||||||
|
public class Message : IDisposable
|
||||||
|
{
|
||||||
|
public Party? Sender { get; set; }
|
||||||
|
|
||||||
|
public Party? Recipient { get; set; }
|
||||||
|
|
||||||
|
public string? Subject { get; set; }
|
||||||
|
|
||||||
|
public Body? Body { get; set; }
|
||||||
|
|
||||||
|
public void Dispose()
|
||||||
|
{
|
||||||
|
Body?.Dispose();
|
||||||
|
|
||||||
|
GC.SuppressFinalize(this);
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -0,0 +1,8 @@
|
|||||||
|
namespace LiteCharms.Features.Email.Models;
|
||||||
|
|
||||||
|
public class Party
|
||||||
|
{
|
||||||
|
public string? Name { get; set; }
|
||||||
|
|
||||||
|
public string? Address { get; set; }
|
||||||
|
}
|
||||||
@@ -0,0 +1,22 @@
|
|||||||
|
using LiteCharms.Features.Shop;
|
||||||
|
|
||||||
|
namespace LiteCharms.Features.Email.Models;
|
||||||
|
|
||||||
|
public class Response
|
||||||
|
{
|
||||||
|
public int Code { get; set; }
|
||||||
|
|
||||||
|
public string? Error { get; set; }
|
||||||
|
|
||||||
|
public EmailStatuses Status { get; set; }
|
||||||
|
|
||||||
|
private Response(EmailStatuses status, int code = 0, string? error = null)
|
||||||
|
{
|
||||||
|
Status = status;
|
||||||
|
Code = code;
|
||||||
|
Error = error;
|
||||||
|
}
|
||||||
|
|
||||||
|
public static Response Create(EmailStatuses status, int code = 0, string? error = null) =>
|
||||||
|
new(status, code, error);
|
||||||
|
}
|
||||||
+79
-29
@@ -1,10 +1,49 @@
|
|||||||
using LiteCharms.Models;
|
using LiteCharms.Features.Shop.CartPackages.Models;
|
||||||
|
using LiteCharms.Features.Shop.Customers.Models;
|
||||||
|
using LiteCharms.Features.Shop.Leads.Models;
|
||||||
|
using LiteCharms.Features.Shop.Notifications.Models;
|
||||||
|
using LiteCharms.Features.Shop.Orders.Models;
|
||||||
|
using LiteCharms.Features.Shop.Products.Models;
|
||||||
|
using LiteCharms.Features.Shop.Quotes.Models;
|
||||||
|
using LiteCharms.Features.Shop.ShoppingCarts.Models;
|
||||||
|
|
||||||
namespace LiteCharms.Extensions;
|
namespace LiteCharms.Features.Extensions;
|
||||||
|
|
||||||
public static class EntityModeMappers
|
public static class EntityModeMappers
|
||||||
{
|
{
|
||||||
public static ShoppingCartItem ToModel(this Entities.ShoppingCartItem entity) =>
|
public static ShoppingCartPackage ToModel(this Shop.ShoppingCarts.Entities.ShoppingCartPackage entity) =>
|
||||||
|
new()
|
||||||
|
{
|
||||||
|
Id = entity.Id,
|
||||||
|
CreatedAt = entity.CreatedAt,
|
||||||
|
PackageId = entity.PackageId,
|
||||||
|
ShoppingCartId = entity.ShoppingCartId
|
||||||
|
};
|
||||||
|
|
||||||
|
public static PackageItem ToModel(this Shop.CartPackages.Entities.PackageItem entity) =>
|
||||||
|
new()
|
||||||
|
{
|
||||||
|
Id = entity.Id,
|
||||||
|
Active = entity.Active,
|
||||||
|
CreatedAt = entity.CreatedAt,
|
||||||
|
PackageId = entity.PackageId,
|
||||||
|
ProductPriceId = entity.ProductPriceId
|
||||||
|
};
|
||||||
|
|
||||||
|
public static Package ToModel(this Shop.CartPackages.Entities.Package entity) =>
|
||||||
|
new()
|
||||||
|
{
|
||||||
|
Id = entity.Id,
|
||||||
|
CreatedAt = entity.CreatedAt,
|
||||||
|
Active = entity.Active,
|
||||||
|
Description = entity.Description,
|
||||||
|
Name = entity.Name,
|
||||||
|
UpdatedAt = entity.UpdatedAt,
|
||||||
|
ImageUrl = entity.ImageUrl,
|
||||||
|
Summary = entity.Summary
|
||||||
|
};
|
||||||
|
|
||||||
|
public static ShoppingCartItem ToModel(this Shop.ShoppingCarts.Entities.ShoppingCartItem entity) =>
|
||||||
new()
|
new()
|
||||||
{
|
{
|
||||||
Id = entity.Id,
|
Id = entity.Id,
|
||||||
@@ -12,21 +51,20 @@ public static class EntityModeMappers
|
|||||||
UpdatedAt = entity.UpdatedAt,
|
UpdatedAt = entity.UpdatedAt,
|
||||||
ProductPriceId = entity.ProductPriceId,
|
ProductPriceId = entity.ProductPriceId,
|
||||||
Quantity = entity.Quantity,
|
Quantity = entity.Quantity,
|
||||||
ShoppingCartId = entity.ShoppingCartId
|
ShoppingCartId = entity.ShoppingCartId
|
||||||
};
|
};
|
||||||
|
|
||||||
public static ShoppingCart ToModel(this Entities.ShoppingCart entity) =>
|
public static ShoppingCart ToModel(this Shop.ShoppingCarts.Entities.ShoppingCart entity) =>
|
||||||
new()
|
new()
|
||||||
{
|
{
|
||||||
Id = entity.Id,
|
Id = entity.Id,
|
||||||
CreatedAt = entity.CreatedAt,
|
CreatedAt = entity.CreatedAt,
|
||||||
UpdatedAt = entity.UpdatedAt,
|
UpdatedAt = entity.UpdatedAt,
|
||||||
CustomerId = entity.CustomerId,
|
CustomerId = entity.CustomerId,
|
||||||
OrderId = entity.OrderId,
|
OrderId = entity.OrderId
|
||||||
QuoteId = entity.QuoteId
|
|
||||||
};
|
};
|
||||||
|
|
||||||
public static Quote ToModel(this Entities.Quote entity) =>
|
public static Quote ToModel(this Shop.Quotes.Entities.Quote entity) =>
|
||||||
new()
|
new()
|
||||||
{
|
{
|
||||||
Id = entity.Id,
|
Id = entity.Id,
|
||||||
@@ -36,27 +74,36 @@ public static class EntityModeMappers
|
|||||||
ExpiredAt = entity.ExpiredAt,
|
ExpiredAt = entity.ExpiredAt,
|
||||||
Reason = entity.Reason,
|
Reason = entity.Reason,
|
||||||
ShoppingCartId = entity.ShoppingCartId,
|
ShoppingCartId = entity.ShoppingCartId,
|
||||||
Status = entity.Status
|
Status = entity.Status,
|
||||||
|
InvoiceUrl = entity.InvoiceUrl,
|
||||||
|
OrderId = entity.OrderId
|
||||||
};
|
};
|
||||||
|
|
||||||
public static Notification ToModel(this Entities.Notification entity) =>
|
public static Notification ToModel(this Shop.Notifications.Entities.Notification entity) =>
|
||||||
new()
|
new()
|
||||||
{
|
{
|
||||||
Id = entity.Id,
|
Id = entity.Id,
|
||||||
CreatedAt = entity.CreatedAt,
|
CreatedAt = entity.CreatedAt,
|
||||||
Description = entity.Description,
|
Message = entity.Message,
|
||||||
Direction = entity.Direction,
|
Direction = entity.Direction,
|
||||||
CorrelationId = entity.CorrelationId,
|
CorrelationId = entity.CorrelationId,
|
||||||
CorrelationIdType = entity.CorrelationIdType,
|
CorrelationIdType = entity.CorrelationIdType,
|
||||||
IsInternal = entity.IsInternal,
|
IsInternal = entity.IsInternal,
|
||||||
Author = entity.Author,
|
Sender = entity.Sender,
|
||||||
Platform = entity.Platform,
|
Platform = entity.Platform,
|
||||||
PlatformAddress = entity.PlatformAddress,
|
Recipient = entity.Recipient,
|
||||||
Title = entity.Title,
|
Subject = entity.Subject,
|
||||||
Processed = entity.Processed
|
Processed = entity.Processed,
|
||||||
|
SenderName = entity.SenderName,
|
||||||
|
RecipientAddress = entity.RecipientAddress,
|
||||||
|
Priority = entity.Priority,
|
||||||
|
UpdatedAt = entity?.UpdatedAt,
|
||||||
|
IsHtml = entity!.IsHtml,
|
||||||
|
HasError = entity.HasError,
|
||||||
|
Errors = entity.Errors
|
||||||
};
|
};
|
||||||
|
|
||||||
public static Customer ToModel(this Entities.Customer entity) =>
|
public static Customer ToModel(this Shop.Customers.Entities.Customer entity) =>
|
||||||
new()
|
new()
|
||||||
{
|
{
|
||||||
Id = entity.Id,
|
Id = entity.Id,
|
||||||
@@ -78,10 +125,10 @@ public static class EntityModeMappers
|
|||||||
Slack = entity.Slack,
|
Slack = entity.Slack,
|
||||||
Tax = entity.Tax,
|
Tax = entity.Tax,
|
||||||
Website = entity.Website,
|
Website = entity.Website,
|
||||||
Whatsapp = entity.Whatsapp
|
Whatsapp = entity.Whatsapp
|
||||||
};
|
};
|
||||||
|
|
||||||
public static Lead ToModel(this Entities.Lead entity) =>
|
public static Lead ToModel(this Shop.Leads.Entities.Lead entity) =>
|
||||||
new()
|
new()
|
||||||
{
|
{
|
||||||
Id = entity.Id,
|
Id = entity.Id,
|
||||||
@@ -99,10 +146,10 @@ public static class EntityModeMappers
|
|||||||
ClickId = entity.ClickId,
|
ClickId = entity.ClickId,
|
||||||
TargetId = entity.TargetId,
|
TargetId = entity.TargetId,
|
||||||
WebClickId = entity.WebClickId,
|
WebClickId = entity.WebClickId,
|
||||||
Status = entity.Status
|
Status = entity.Status
|
||||||
};
|
};
|
||||||
|
|
||||||
public static Order ToModel(this Entities.Order entity) =>
|
public static Order ToModel(this Shop.Orders.Entities.Order entity) =>
|
||||||
new()
|
new()
|
||||||
{
|
{
|
||||||
Id = entity.Id,
|
Id = entity.Id,
|
||||||
@@ -110,32 +157,35 @@ public static class EntityModeMappers
|
|||||||
UpdatedAt = entity.UpdatedAt,
|
UpdatedAt = entity.UpdatedAt,
|
||||||
CustomerId = entity.CustomerId,
|
CustomerId = entity.CustomerId,
|
||||||
Notes = entity.Notes,
|
Notes = entity.Notes,
|
||||||
RefundId = entity.RefundId,
|
|
||||||
QuoteId = entity.QuoteId,
|
|
||||||
Status = entity.Status,
|
Status = entity.Status,
|
||||||
ShoppingCartId = entity.ShoppingCartId
|
Requirements = entity.Requirements,
|
||||||
|
Terms = entity.Terms,
|
||||||
|
InvoiceUrl = entity.InvoiceUrl
|
||||||
};
|
};
|
||||||
|
|
||||||
public static OrderRefund ToModel(this Entities.OrderRefund entity) =>
|
public static OrderRefund ToModel(this Shop.Orders.Entities.OrderRefund entity) =>
|
||||||
new()
|
new()
|
||||||
{
|
{
|
||||||
Id = entity.Id,
|
Id = entity.Id,
|
||||||
CreatedAt = entity.CreatedAt,
|
CreatedAt = entity.CreatedAt,
|
||||||
OrderId = entity.OrderId,
|
OrderId = entity.OrderId,
|
||||||
Reason = entity.Reason,
|
Reason = entity.Reason,
|
||||||
Amount = entity.Amount
|
Amount = entity.Amount
|
||||||
};
|
};
|
||||||
|
|
||||||
public static Product ToModel(this Entities.Product entity) =>
|
public static Product ToModel(this Shop.Products.Entities.Product entity) =>
|
||||||
new()
|
new()
|
||||||
{
|
{
|
||||||
Id = entity.Id,
|
Id = entity.Id,
|
||||||
Name = entity.Name,
|
Name = entity.Name,
|
||||||
Description = entity.Description,
|
Description = entity.Description,
|
||||||
Active = entity.Active
|
Active = entity.Active,
|
||||||
|
Summary = entity.Summary,
|
||||||
|
ImageUrl = entity.ImageUrl,
|
||||||
|
Thumbnails = entity.Thumbnails
|
||||||
};
|
};
|
||||||
|
|
||||||
public static ProductPrice ToModel(this Entities.ProductPrice entity) =>
|
public static ProductPrice ToModel(this Shop.Products.Entities.ProductPrice entity) =>
|
||||||
new()
|
new()
|
||||||
{
|
{
|
||||||
Id = entity.Id,
|
Id = entity.Id,
|
||||||
@@ -144,6 +194,6 @@ public static class EntityModeMappers
|
|||||||
Active = entity.Active,
|
Active = entity.Active,
|
||||||
CreatedAt = entity.CreatedAt,
|
CreatedAt = entity.CreatedAt,
|
||||||
Discount = entity.Discount,
|
Discount = entity.Discount,
|
||||||
UpdatedAt = entity.UpdatedAt
|
UpdatedAt = entity.UpdatedAt
|
||||||
};
|
};
|
||||||
}
|
}
|
||||||
@@ -0,0 +1,7 @@
|
|||||||
|
namespace LiteCharms.Features.Extensions;
|
||||||
|
|
||||||
|
public static class Hash
|
||||||
|
{
|
||||||
|
public static Func<string?, string?> GenerateSha256HashString = (input) =>
|
||||||
|
Convert.ToHexString(SHA256.HashData(Encoding.UTF8.GetBytes(input!)));
|
||||||
|
}
|
||||||
+2
-2
@@ -1,6 +1,6 @@
|
|||||||
using LiteCharms.Infrastructure.HealthChecks;
|
using LiteCharms.Features.HealthChecks;
|
||||||
|
|
||||||
namespace LiteCharms.Extensions;
|
namespace LiteCharms.Features.Extensions;
|
||||||
|
|
||||||
public static class HealthChecks
|
public static class HealthChecks
|
||||||
{
|
{
|
||||||
@@ -1,4 +1,4 @@
|
|||||||
namespace LiteCharms.Extensions;
|
namespace LiteCharms.Features.Extensions;
|
||||||
|
|
||||||
public static class Monitoring
|
public static class Monitoring
|
||||||
{
|
{
|
||||||
@@ -1,6 +1,6 @@
|
|||||||
using LiteCharms.Infrastructure.Database;
|
using LiteCharms.Features.Shop.Postgres;
|
||||||
|
|
||||||
namespace LiteCharms.Extensions;
|
namespace LiteCharms.Features.Extensions;
|
||||||
|
|
||||||
public static class Postgres
|
public static class Postgres
|
||||||
{
|
{
|
||||||
@@ -1,7 +1,7 @@
|
|||||||
using LiteCharms.Abstractions;
|
using LiteCharms.Features.Quartz;
|
||||||
using LiteCharms.Infrastructure.Quartz;
|
using LiteCharms.Features.Quartz.Abstractions;
|
||||||
|
|
||||||
namespace LiteCharms.Extensions;
|
namespace LiteCharms.Features.Extensions;
|
||||||
|
|
||||||
public static class Quartz
|
public static class Quartz
|
||||||
{
|
{
|
||||||
@@ -1,9 +1,9 @@
|
|||||||
using LiteCharms.Abstractions;
|
using LiteCharms.Features.ServiceBus;
|
||||||
using LiteCharms.Infrastructure.ServiceBus;
|
using LiteCharms.Features.ServiceBus.Abstractions;
|
||||||
using LiteCharms.Infrastructure.ServiceBus.Exchanges;
|
using LiteCharms.Features.ServiceBus.Exchanges;
|
||||||
using LiteCharms.Infrastructure.ServiceBus.Queues;
|
using LiteCharms.Features.ServiceBus.Queues;
|
||||||
|
|
||||||
namespace LiteCharms.Extensions;
|
namespace LiteCharms.Features.Extensions;
|
||||||
|
|
||||||
public static class ServiceBus
|
public static class ServiceBus
|
||||||
{
|
{
|
||||||
@@ -1,4 +1,4 @@
|
|||||||
namespace LiteCharms.Abstractions;
|
namespace LiteCharms.Features.Extensions;
|
||||||
|
|
||||||
public static class Timezones
|
public static class Timezones
|
||||||
{
|
{
|
||||||
+1
-1
@@ -1,4 +1,4 @@
|
|||||||
namespace LiteCharms.Infrastructure.HealthChecks;
|
namespace LiteCharms.Features.HealthChecks;
|
||||||
|
|
||||||
public class PostgresHealthCheck(IConfiguration configuration) : IHealthCheck
|
public class PostgresHealthCheck(IConfiguration configuration) : IHealthCheck
|
||||||
{
|
{
|
||||||
+1
-1
@@ -1,4 +1,4 @@
|
|||||||
namespace LiteCharms.Infrastructure.HealthChecks;
|
namespace LiteCharms.Features.HealthChecks;
|
||||||
|
|
||||||
public class QuartzHealthCheck(ISchedulerFactory schedulerFactory) : IHealthCheck
|
public class QuartzHealthCheck(ISchedulerFactory schedulerFactory) : IHealthCheck
|
||||||
{
|
{
|
||||||
@@ -28,6 +28,86 @@
|
|||||||
<None Include="..\icon.png" Pack="true" PackagePath="\" />
|
<None Include="..\icon.png" Pack="true" PackagePath="\" />
|
||||||
</ItemGroup>
|
</ItemGroup>
|
||||||
|
|
||||||
|
<!-- Quartz Scheduler-->
|
||||||
|
<ItemGroup>
|
||||||
|
<PackageReference Include="OpenTelemetry" Version="1.15.3" />
|
||||||
|
<PackageReference Include="Quartz" Version="3.18.1" />
|
||||||
|
<PackageReference Include="Quartz.Plugins" Version="3.18.1" />
|
||||||
|
<PackageReference Include="Quartz.Plugins.TimeZoneConverter" Version="3.18.1" />
|
||||||
|
<PackageReference Include="Quartz.Serialization.SystemTextJson" Version="3.18.1" />
|
||||||
|
<PackageReference Include="Quartz.AspNetCore" Version="3.18.1" />
|
||||||
|
<PackageReference Include="Quartz.Extensions.DependencyInjection" Version="3.18.1" />
|
||||||
|
|
||||||
|
<!-- Global Usings -->
|
||||||
|
<Using Include="Quartz" />
|
||||||
|
</ItemGroup>
|
||||||
|
|
||||||
|
<!-- Configuration -->
|
||||||
|
<ItemGroup>
|
||||||
|
<PackageReference Include="Microsoft.Extensions.Configuration" Version="10.0.8" />
|
||||||
|
<PackageReference Include="Microsoft.Extensions.Configuration.Abstractions" Version="10.0.8" />
|
||||||
|
<PackageReference Include="Microsoft.Extensions.Configuration.EnvironmentVariables" Version="10.0.8" />
|
||||||
|
<PackageReference Include="Microsoft.Extensions.Configuration.Json" Version="10.0.8" />
|
||||||
|
<PackageReference Include="Microsoft.Extensions.Configuration.UserSecrets" Version="10.0.8" />
|
||||||
|
|
||||||
|
<!-- Global Usings -->
|
||||||
|
<Using Include="Microsoft.Extensions.Configuration" />
|
||||||
|
</ItemGroup>
|
||||||
|
|
||||||
|
<!-- Health Checks -->
|
||||||
|
<ItemGroup>
|
||||||
|
<PackageReference Include="AspNetCore.HealthChecks.UI.Client" Version="9.0.0" />
|
||||||
|
<PackageReference Include="AspNetCore.HealthChecks.UI" Version="9.0.0" />
|
||||||
|
<PackageReference Include="AspNetCore.HealthChecks.UI.Core" Version="9.0.0" />
|
||||||
|
<PackageReference Include="AspNetCore.HealthChecks.UI.Data" Version="9.0.0" />
|
||||||
|
<PackageReference Include="AspNetCore.HealthChecks.UI.InMemory.Storage" Version="9.0.0" />
|
||||||
|
<PackageReference Include="Microsoft.EntityFrameworkCore.InMemory" Version="10.0.8" />
|
||||||
|
<PackageReference Include="Microsoft.Extensions.DependencyInjection" Version="10.0.8" />
|
||||||
|
<PackageReference Include="Microsoft.Extensions.Diagnostics.HealthChecks" Version="10.0.8" />
|
||||||
|
|
||||||
|
<!-- Global Usings -->
|
||||||
|
<Using Include="Microsoft.Extensions.Diagnostics.HealthChecks" />
|
||||||
|
<Using Include="Microsoft.AspNetCore.Diagnostics.HealthChecks" />
|
||||||
|
</ItemGroup>
|
||||||
|
|
||||||
|
<!-- Open Telemetry -->
|
||||||
|
<ItemGroup>
|
||||||
|
<PackageReference Include="OpenTelemetry.Exporter.OpenTelemetryProtocol" Version="1.15.3" />
|
||||||
|
<PackageReference Include="OpenTelemetry.Extensions.Hosting" Version="1.15.3" />
|
||||||
|
<PackageReference Include="OpenTelemetry.Instrumentation.AspNetCore" Version="1.15.2" />
|
||||||
|
<PackageReference Include="OpenTelemetry.Instrumentation.Http" Version="1.15.1" />
|
||||||
|
<PackageReference Include="OpenTelemetry.Instrumentation.Runtime" Version="1.15.1" />
|
||||||
|
<PackageReference Include="OpenTelemetry.Exporter.Console" Version="1.15.3" />
|
||||||
|
|
||||||
|
<!-- Global Usings -->
|
||||||
|
<Using Include="OpenTelemetry.Resources" />
|
||||||
|
<Using Include="OpenTelemetry.Exporter" />
|
||||||
|
<Using Include="OpenTelemetry.Logs" />
|
||||||
|
<Using Include="OpenTelemetry.Metrics" />
|
||||||
|
<Using Include="OpenTelemetry.Trace" />
|
||||||
|
</ItemGroup>
|
||||||
|
|
||||||
|
<!-- Database -->
|
||||||
|
<ItemGroup>
|
||||||
|
<PackageReference Include="Microsoft.EntityFrameworkCore" Version="10.0.8" />
|
||||||
|
<PackageReference Include="Microsoft.EntityFrameworkCore.Design" Version="10.0.8">
|
||||||
|
<PrivateAssets>all</PrivateAssets>
|
||||||
|
<IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
|
||||||
|
</PackageReference>
|
||||||
|
<PackageReference Include="Microsoft.EntityFrameworkCore.Relational" Version="10.0.8" />
|
||||||
|
<PackageReference Include="Microsoft.EntityFrameworkCore.Tools" Version="10.0.8">
|
||||||
|
<PrivateAssets>all</PrivateAssets>
|
||||||
|
<IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
|
||||||
|
</PackageReference>
|
||||||
|
<PackageReference Include="Npgsql.EntityFrameworkCore.PostgreSQL" Version="10.0.1" />
|
||||||
|
|
||||||
|
<!-- Global Usings -->
|
||||||
|
<Using Include="Npgsql" />
|
||||||
|
<Using Include="Microsoft.EntityFrameworkCore" />
|
||||||
|
<Using Include="Microsoft.EntityFrameworkCore.Design" />
|
||||||
|
<Using Include="Microsoft.EntityFrameworkCore.Metadata.Builders" />
|
||||||
|
</ItemGroup>
|
||||||
|
|
||||||
<!-- Email -->
|
<!-- Email -->
|
||||||
<ItemGroup>
|
<ItemGroup>
|
||||||
<PackageReference Include="MailKit" Version="4.16.0" />
|
<PackageReference Include="MailKit" Version="4.16.0" />
|
||||||
@@ -50,15 +130,18 @@
|
|||||||
|
|
||||||
<!-- Shared Usings -->
|
<!-- Shared Usings -->
|
||||||
<ItemGroup>
|
<ItemGroup>
|
||||||
|
<Using Include="Microsoft.AspNetCore.Builder" />
|
||||||
|
<Using Include="Microsoft.Extensions.Hosting" />
|
||||||
<Using Include="System.Text" />
|
<Using Include="System.Text" />
|
||||||
<Using Include="System.Security.Cryptography" />
|
<Using Include="System.Text.Json" />
|
||||||
<Using Include="Microsoft.EntityFrameworkCore" />
|
<Using Include="System.Threading.Channels" />
|
||||||
|
<Using Include="System.Collections.ObjectModel" />
|
||||||
|
<Using Include="System.Diagnostics" />
|
||||||
|
<Using Include="System.Diagnostics.Metrics" />
|
||||||
|
<Using Include="Microsoft.Extensions.DependencyInjection" />
|
||||||
|
<Using Include="System.Security.Cryptography" />
|
||||||
<Using Include="Microsoft.Extensions.Options" />
|
<Using Include="Microsoft.Extensions.Options" />
|
||||||
</ItemGroup>
|
<Using Include="Microsoft.Extensions.Logging" />
|
||||||
|
|
||||||
<ItemGroup>
|
|
||||||
<ProjectReference Include="..\LiteCharms.Extensions\LiteCharms.Extensions.csproj" />
|
|
||||||
<ProjectReference Include="..\LiteCharms.Infrastructure\LiteCharms.Infrastructure.csproj" />
|
|
||||||
</ItemGroup>
|
</ItemGroup>
|
||||||
|
|
||||||
</Project>
|
</Project>
|
||||||
|
|||||||
@@ -0,0 +1,29 @@
|
|||||||
|
namespace LiteCharms.Features.Mediator;
|
||||||
|
|
||||||
|
public sealed class LoggingPipelineBehavior<TRequest, TResponse>(ILogger<LoggingPipelineBehavior<TRequest, TResponse>> logger) :
|
||||||
|
IPipelineBehavior<TRequest, TResponse?>
|
||||||
|
where TRequest : IRequest<TResponse>
|
||||||
|
where TResponse : ResultBase, new()
|
||||||
|
{
|
||||||
|
public async ValueTask<TResponse?> Handle(TRequest message, MessageHandlerDelegate<TRequest, TResponse?> next, CancellationToken cancellationToken)
|
||||||
|
{
|
||||||
|
TResponse? response = await next(message, cancellationToken);
|
||||||
|
|
||||||
|
if (response is null)
|
||||||
|
logger.LogCritical("{Request} {TypeName} was returned as null", typeof(TRequest).Name, typeof(TRequest).Name);
|
||||||
|
|
||||||
|
if(response?.IsFailed == true || response?.Errors?.Any() == true)
|
||||||
|
{
|
||||||
|
foreach (var error in response.Errors)
|
||||||
|
{
|
||||||
|
if (!string.IsNullOrWhiteSpace(error.Message))
|
||||||
|
logger.LogWarning("{Request} {Error}", typeof(TRequest).Name, error.Message);
|
||||||
|
|
||||||
|
if (error?.Reasons?.Count > 0)
|
||||||
|
error.Reasons.ForEach(r => logger.LogError("{Request} {Reason}", typeof(TRequest).Name, r.ToString()));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
return response;
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -0,0 +1,12 @@
|
|||||||
|
namespace LiteCharms.Features.Mediator;
|
||||||
|
|
||||||
|
public static class MediatorTelemetry
|
||||||
|
{
|
||||||
|
public const string ServiceName = "LiteCharms.Mediator";
|
||||||
|
|
||||||
|
public static readonly ActivitySource Source = new(ServiceName);
|
||||||
|
public static readonly Meter Meter = new(ServiceName);
|
||||||
|
|
||||||
|
public static readonly Counter<long> RequestCounter = Meter.CreateCounter<long>("mediator_requests_total");
|
||||||
|
public static readonly Histogram<double> RequestDuration = Meter.CreateHistogram<double>("mediator_request_duration_ms");
|
||||||
|
}
|
||||||
@@ -0,0 +1,66 @@
|
|||||||
|
namespace LiteCharms.Features.Mediator;
|
||||||
|
|
||||||
|
public sealed class TelemetryPipelineBehavior<TRequest, TResponse> :
|
||||||
|
IPipelineBehavior<TRequest, TResponse?>
|
||||||
|
where TRequest : IRequest<TResponse>
|
||||||
|
where TResponse : ResultBase, new()
|
||||||
|
{
|
||||||
|
public async ValueTask<TResponse?> Handle(TRequest message, MessageHandlerDelegate<TRequest, TResponse?> next, CancellationToken cancellationToken)
|
||||||
|
{
|
||||||
|
var requestName = typeof(TRequest).Name;
|
||||||
|
|
||||||
|
using var activity = MediatorTelemetry.Source.StartActivity(requestName);
|
||||||
|
|
||||||
|
activity?.SetTag("mediator.request_type", typeof(TRequest).FullName);
|
||||||
|
|
||||||
|
var stopWatch = Stopwatch.StartNew();
|
||||||
|
var status = "Success";
|
||||||
|
|
||||||
|
try
|
||||||
|
{
|
||||||
|
TResponse? response = await next(message, cancellationToken);
|
||||||
|
|
||||||
|
if (response is null)
|
||||||
|
{
|
||||||
|
status = "NullResponse";
|
||||||
|
activity?.SetStatus(ActivityStatusCode.Error, "Response was null");
|
||||||
|
|
||||||
|
return response;
|
||||||
|
}
|
||||||
|
|
||||||
|
if (response.IsFailed)
|
||||||
|
{
|
||||||
|
status = "Failed";
|
||||||
|
activity?.SetStatus(ActivityStatusCode.Error, "Request failed");
|
||||||
|
|
||||||
|
var firstError = response.Errors.FirstOrDefault()?.Message ?? "Unknown Error";
|
||||||
|
activity?.SetTag("error.message", firstError);
|
||||||
|
|
||||||
|
foreach (var error in response.Errors)
|
||||||
|
activity?.AddEvent(new ActivityEvent("Result Error", tags: new() { { "message", error.Message } }));
|
||||||
|
}
|
||||||
|
else
|
||||||
|
activity?.SetStatus(ActivityStatusCode.Ok);
|
||||||
|
|
||||||
|
return response;
|
||||||
|
}
|
||||||
|
catch (Exception ex)
|
||||||
|
{
|
||||||
|
status = "Exception";
|
||||||
|
activity?.SetStatus(ActivityStatusCode.Error, ex.Message);
|
||||||
|
|
||||||
|
activity?.AddException(ex);
|
||||||
|
|
||||||
|
throw;
|
||||||
|
}
|
||||||
|
finally
|
||||||
|
{
|
||||||
|
stopWatch.Stop();
|
||||||
|
|
||||||
|
var tags = new TagList { { "request", requestName }, { "status", status } };
|
||||||
|
|
||||||
|
MediatorTelemetry.RequestCounter.Add(1, tags);
|
||||||
|
MediatorTelemetry.RequestDuration.Record(stopWatch.Elapsed.TotalMilliseconds, tags);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -1,63 +0,0 @@
|
|||||||
using LiteCharms.Models;
|
|
||||||
|
|
||||||
namespace LiteCharms.Features.Notifications.Commands;
|
|
||||||
|
|
||||||
public class CreateNotificationCommand : IRequest<Result<Guid>>
|
|
||||||
{
|
|
||||||
public NotificationDirection Direction { get; set; }
|
|
||||||
|
|
||||||
public string? Author { get; set; }
|
|
||||||
|
|
||||||
public string? Title { get; set; }
|
|
||||||
|
|
||||||
public string? Description { get; set; }
|
|
||||||
|
|
||||||
public string? Platform { get; set; }
|
|
||||||
|
|
||||||
public string? PlatformAddress { get; set; }
|
|
||||||
|
|
||||||
public string? CorrelationId { get; set; }
|
|
||||||
|
|
||||||
public string? CorrelationIdType { get; set; }
|
|
||||||
|
|
||||||
public bool IsInternal { get; set; }
|
|
||||||
|
|
||||||
private CreateNotificationCommand(NotificationDirection direction, string author, string title, string description, string platform, string platformAddress, string correlationId, string correlationIdType, bool isInternal)
|
|
||||||
{
|
|
||||||
Direction = direction;
|
|
||||||
Author = author;
|
|
||||||
Title = title;
|
|
||||||
Description = description;
|
|
||||||
Platform = platform;
|
|
||||||
PlatformAddress = platformAddress;
|
|
||||||
CorrelationId = correlationId;
|
|
||||||
CorrelationIdType = correlationIdType;
|
|
||||||
IsInternal = isInternal;
|
|
||||||
}
|
|
||||||
|
|
||||||
public static CreateNotificationCommand Create(NotificationDirection direction, string author, string title, string description, string platform, string platformAddress, string correlationId, string correlationIdType, bool isInternal)
|
|
||||||
{
|
|
||||||
if (string.IsNullOrWhiteSpace(author))
|
|
||||||
throw new ArgumentException("Author cannot be null or whitespace.", nameof(author));
|
|
||||||
|
|
||||||
if (string.IsNullOrWhiteSpace(title))
|
|
||||||
throw new ArgumentException("Title cannot be null or whitespace.", nameof(title));
|
|
||||||
|
|
||||||
if (string.IsNullOrWhiteSpace(description))
|
|
||||||
throw new ArgumentException("Description cannot be null or whitespace.", nameof(description));
|
|
||||||
|
|
||||||
if (string.IsNullOrWhiteSpace(platform))
|
|
||||||
throw new ArgumentException("Platform cannot be null or whitespace.", nameof(platform));
|
|
||||||
|
|
||||||
if (string.IsNullOrWhiteSpace(platformAddress))
|
|
||||||
throw new ArgumentException("PlatformAddress cannot be null or whitespace.", nameof(platformAddress));
|
|
||||||
|
|
||||||
if (string.IsNullOrWhiteSpace(correlationId))
|
|
||||||
throw new ArgumentException("CorrelationId cannot be null or whitespace.", nameof(correlationId));
|
|
||||||
|
|
||||||
if (string.IsNullOrWhiteSpace(correlationIdType))
|
|
||||||
throw new ArgumentException("CorrelationIdType cannot be null or whitespace.", nameof(correlationIdType));
|
|
||||||
|
|
||||||
return new(direction, author, title, description, platform, platformAddress, correlationId, correlationIdType, isInternal);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
+3
-1
@@ -1,4 +1,6 @@
|
|||||||
namespace LiteCharms.Abstractions;
|
using LiteCharms.Features.Abstractions;
|
||||||
|
|
||||||
|
namespace LiteCharms.Features.Quartz.Abstractions;
|
||||||
|
|
||||||
public interface IJobOrchestrator
|
public interface IJobOrchestrator
|
||||||
{
|
{
|
||||||
+5
-4
@@ -1,7 +1,8 @@
|
|||||||
using LiteCharms.Abstractions;
|
using LiteCharms.Features.Abstractions;
|
||||||
using static LiteCharms.Abstractions.Timezones;
|
using LiteCharms.Features.Quartz.Abstractions;
|
||||||
|
using static LiteCharms.Features.Extensions.Timezones;
|
||||||
|
|
||||||
namespace LiteCharms.Infrastructure.Quartz;
|
namespace LiteCharms.Features.Quartz;
|
||||||
|
|
||||||
public class JobOrchestrator(ISchedulerFactory schedulerFactory) : IJobOrchestrator
|
public class JobOrchestrator(ISchedulerFactory schedulerFactory) : IJobOrchestrator
|
||||||
{
|
{
|
||||||
@@ -35,7 +36,7 @@ public class JobOrchestrator(ISchedulerFactory schedulerFactory) : IJobOrchestra
|
|||||||
var chainedJobGroup = "scheduled-jobs";
|
var chainedJobGroup = "scheduled-jobs";
|
||||||
|
|
||||||
var scheduler = await schedulerFactory.GetScheduler(cancellationToken);
|
var scheduler = await schedulerFactory.GetScheduler(cancellationToken);
|
||||||
var jobKey = new JobKey($"{notification.Name.ToLower()}-{notification.CorrelationId.ToLower()}", chainedJobGroup);
|
var jobKey = new JobKey($"{notification.Name.ToLower()}", chainedJobGroup);
|
||||||
var triggerKey = new TriggerKey($"{jobKey.Name}-trigger", chainedJobGroup);
|
var triggerKey = new TriggerKey($"{jobKey.Name}-trigger", chainedJobGroup);
|
||||||
|
|
||||||
var job = JobBuilder.Create<MediatorJob<TNotification>>()
|
var job = JobBuilder.Create<MediatorJob<TNotification>>()
|
||||||
+2
-2
@@ -1,6 +1,6 @@
|
|||||||
using LiteCharms.Abstractions;
|
using LiteCharms.Features.Abstractions;
|
||||||
|
|
||||||
namespace LiteCharms.Infrastructure.Quartz;
|
namespace LiteCharms.Features.Quartz;
|
||||||
|
|
||||||
[DisallowConcurrentExecution]
|
[DisallowConcurrentExecution]
|
||||||
public class MediatorJob<TNotification>(IMediator mediator) : IJob where TNotification : IEvent
|
public class MediatorJob<TNotification>(IMediator mediator) : IJob where TNotification : IEvent
|
||||||
+1
-1
@@ -1,4 +1,4 @@
|
|||||||
namespace LiteCharms.Infrastructure.Quartz;
|
namespace LiteCharms.Features.Quartz;
|
||||||
|
|
||||||
public class RetryJobListener : IJobListener
|
public class RetryJobListener : IJobListener
|
||||||
{
|
{
|
||||||
+3
-1
@@ -1,4 +1,6 @@
|
|||||||
namespace LiteCharms.Abstractions;
|
using LiteCharms.Features.Abstractions;
|
||||||
|
|
||||||
|
namespace LiteCharms.Features.ServiceBus.Abstractions;
|
||||||
|
|
||||||
public abstract class EventBusQueueBase
|
public abstract class EventBusQueueBase
|
||||||
{
|
{
|
||||||
+3
-1
@@ -1,4 +1,6 @@
|
|||||||
namespace LiteCharms.Abstractions;
|
using LiteCharms.Features.Abstractions;
|
||||||
|
|
||||||
|
namespace LiteCharms.Features.ServiceBus.Abstractions;
|
||||||
|
|
||||||
public interface IEventBus
|
public interface IEventBus
|
||||||
{
|
{
|
||||||
+3
-1
@@ -1,4 +1,6 @@
|
|||||||
namespace LiteCharms.Abstractions;
|
using LiteCharms.Features.Abstractions;
|
||||||
|
|
||||||
|
namespace LiteCharms.Features.ServiceBus.Abstractions;
|
||||||
|
|
||||||
public interface IEventBusQueue
|
public interface IEventBusQueue
|
||||||
{
|
{
|
||||||
@@ -1,11 +1,9 @@
|
|||||||
namespace LiteCharms.Abstractions;
|
namespace LiteCharms.Features.ServiceBus;
|
||||||
|
|
||||||
public static class Constants
|
public static class Constants
|
||||||
{
|
{
|
||||||
public const int QueueBounds = 100000;
|
public const int QueueBounds = 100000;
|
||||||
|
|
||||||
public const string ShopSchedulerName = "shop";
|
|
||||||
|
|
||||||
public const string EmailServiceBus = nameof(EmailServiceBus);
|
public const string EmailServiceBus = nameof(EmailServiceBus);
|
||||||
public const string GeneralServiceBus = nameof(GeneralServiceBus);
|
public const string GeneralServiceBus = nameof(GeneralServiceBus);
|
||||||
public const string SalesServiceBus = nameof(SalesServiceBus);
|
public const string SalesServiceBus = nameof(SalesServiceBus);
|
||||||
+4
-3
@@ -1,7 +1,8 @@
|
|||||||
using LiteCharms.Abstractions;
|
using LiteCharms.Features.Abstractions;
|
||||||
using LiteCharms.Infrastructure.ServiceBus.Queues;
|
using LiteCharms.Features.ServiceBus.Abstractions;
|
||||||
|
using LiteCharms.Features.ServiceBus.Queues;
|
||||||
|
|
||||||
namespace LiteCharms.Infrastructure.ServiceBus;
|
namespace LiteCharms.Features.ServiceBus;
|
||||||
|
|
||||||
public class EmailServiceBus(EmailQueue messages) : IEventBus
|
public class EmailServiceBus(EmailQueue messages) : IEventBus
|
||||||
{
|
{
|
||||||
@@ -0,0 +1,33 @@
|
|||||||
|
using LiteCharms.Features.Abstractions;
|
||||||
|
using LiteCharms.Features.ServiceBus.Queues;
|
||||||
|
|
||||||
|
namespace LiteCharms.Features.ServiceBus.Exchanges;
|
||||||
|
|
||||||
|
public class EmailExchange(EmailQueue messages, ILogger<EmailExchange> logger, IPublisher mediator) : BackgroundService
|
||||||
|
{
|
||||||
|
protected override async Task ExecuteAsync(CancellationToken stoppingToken)
|
||||||
|
{
|
||||||
|
await foreach(IEvent? message in messages.Incoming.ReadAllAsync(stoppingToken))
|
||||||
|
{
|
||||||
|
try
|
||||||
|
{
|
||||||
|
switch (message.Name)
|
||||||
|
{
|
||||||
|
case "SendShopEmailEnquiryEvent":
|
||||||
|
await mediator.Publish(message, stoppingToken);
|
||||||
|
break;
|
||||||
|
case "ProcessEmailNotificationsEvent":
|
||||||
|
await mediator.Publish(message, stoppingToken);
|
||||||
|
break;
|
||||||
|
default:
|
||||||
|
logger.LogWarning("Unsupported email event {Event}", message.Name);
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
catch (Exception ex)
|
||||||
|
{
|
||||||
|
logger.LogError(ex, ex.Message);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
+2
-2
@@ -1,6 +1,6 @@
|
|||||||
using LiteCharms.Infrastructure.ServiceBus.Queues;
|
using LiteCharms.Features.ServiceBus.Queues;
|
||||||
|
|
||||||
namespace LiteCharms.Infrastructure.ServiceBus.Exchanges;
|
namespace LiteCharms.Features.ServiceBus.Exchanges;
|
||||||
|
|
||||||
public class GeneralExchange(GeneralQueue messages) : BackgroundService
|
public class GeneralExchange(GeneralQueue messages) : BackgroundService
|
||||||
{
|
{
|
||||||
+2
-2
@@ -1,6 +1,6 @@
|
|||||||
using LiteCharms.Infrastructure.ServiceBus.Queues;
|
using LiteCharms.Features.ServiceBus.Queues;
|
||||||
|
|
||||||
namespace LiteCharms.Infrastructure.ServiceBus.Exchanges;
|
namespace LiteCharms.Features.ServiceBus.Exchanges;
|
||||||
|
|
||||||
public class SalesExchange(SalesQueue messages) : BackgroundService
|
public class SalesExchange(SalesQueue messages) : BackgroundService
|
||||||
{
|
{
|
||||||
+4
-3
@@ -1,7 +1,8 @@
|
|||||||
using LiteCharms.Abstractions;
|
using LiteCharms.Features.Abstractions;
|
||||||
using LiteCharms.Infrastructure.ServiceBus.Queues;
|
using LiteCharms.Features.ServiceBus.Abstractions;
|
||||||
|
using LiteCharms.Features.ServiceBus.Queues;
|
||||||
|
|
||||||
namespace LiteCharms.Infrastructure.ServiceBus;
|
namespace LiteCharms.Features.ServiceBus;
|
||||||
|
|
||||||
public class GeneralServiceBus(GeneralQueue messages) : IEventBus
|
public class GeneralServiceBus(GeneralQueue messages) : IEventBus
|
||||||
{
|
{
|
||||||
@@ -0,0 +1,5 @@
|
|||||||
|
using LiteCharms.Features.ServiceBus.Abstractions;
|
||||||
|
|
||||||
|
namespace LiteCharms.Features.ServiceBus.Queues;
|
||||||
|
|
||||||
|
public class EmailQueue : EventBusQueueBase, IEventBusQueue;
|
||||||
@@ -0,0 +1,5 @@
|
|||||||
|
using LiteCharms.Features.ServiceBus.Abstractions;
|
||||||
|
|
||||||
|
namespace LiteCharms.Features.ServiceBus.Queues;
|
||||||
|
|
||||||
|
public class GeneralQueue : EventBusQueueBase, IEventBusQueue;
|
||||||
@@ -0,0 +1,5 @@
|
|||||||
|
using LiteCharms.Features.ServiceBus.Abstractions;
|
||||||
|
|
||||||
|
namespace LiteCharms.Features.ServiceBus.Queues;
|
||||||
|
|
||||||
|
public class SalesQueue : EventBusQueueBase, IEventBusQueue;
|
||||||
+4
-3
@@ -1,7 +1,8 @@
|
|||||||
using LiteCharms.Abstractions;
|
using LiteCharms.Features.Abstractions;
|
||||||
using LiteCharms.Infrastructure.ServiceBus.Queues;
|
using LiteCharms.Features.ServiceBus.Abstractions;
|
||||||
|
using LiteCharms.Features.ServiceBus.Queues;
|
||||||
|
|
||||||
namespace LiteCharms.Infrastructure.ServiceBus;
|
namespace LiteCharms.Features.ServiceBus;
|
||||||
|
|
||||||
public class SalesServiceBus(SalesQueue messages) : IEventBus
|
public class SalesServiceBus(SalesQueue messages) : IEventBus
|
||||||
{
|
{
|
||||||
@@ -0,0 +1,25 @@
|
|||||||
|
namespace LiteCharms.Features.CartPackages.Commands;
|
||||||
|
|
||||||
|
public class AddPackageItemCommand : IRequest<Result<Guid>>
|
||||||
|
{
|
||||||
|
public Guid PackageId { get; set; }
|
||||||
|
|
||||||
|
public Guid ProductPriceId { get; set; }
|
||||||
|
|
||||||
|
private AddPackageItemCommand(Guid packageId, Guid productPriceId)
|
||||||
|
{
|
||||||
|
PackageId = packageId;
|
||||||
|
ProductPriceId = productPriceId;
|
||||||
|
}
|
||||||
|
|
||||||
|
public static AddPackageItemCommand Create(Guid packageId, Guid productPriceId)
|
||||||
|
{
|
||||||
|
if (packageId == Guid.Empty)
|
||||||
|
throw new ArgumentException("Package id is required", nameof(packageId));
|
||||||
|
|
||||||
|
if (productPriceId == Guid.Empty)
|
||||||
|
throw new ArgumentException("Product price id is required", nameof(productPriceId));
|
||||||
|
|
||||||
|
return new(packageId, productPriceId);
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -0,0 +1,23 @@
|
|||||||
|
namespace LiteCharms.Features.CartPackages.Commands;
|
||||||
|
|
||||||
|
public class CreatePackageCommand : IRequest<Result<Guid>>
|
||||||
|
{
|
||||||
|
public string? Name { get; set; }
|
||||||
|
|
||||||
|
public string? Description { get; set; }
|
||||||
|
|
||||||
|
private CreatePackageCommand(string? name, string? description)
|
||||||
|
{
|
||||||
|
Name = name;
|
||||||
|
Description = description;
|
||||||
|
}
|
||||||
|
|
||||||
|
public static CreatePackageCommand Create(string? name, string? description)
|
||||||
|
{
|
||||||
|
ArgumentException.ThrowIfNullOrWhiteSpace(name, nameof(name));
|
||||||
|
|
||||||
|
ArgumentException.ThrowIfNullOrWhiteSpace(description, nameof(description));
|
||||||
|
|
||||||
|
return new(name, description);
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -0,0 +1,25 @@
|
|||||||
|
namespace LiteCharms.Features.CartPackages.Commands;
|
||||||
|
|
||||||
|
public class DeletePackageItemCommand : IRequest<Result>
|
||||||
|
{
|
||||||
|
public Guid PackageId { get; set; }
|
||||||
|
|
||||||
|
public Guid PackageItemId { get; set; }
|
||||||
|
|
||||||
|
private DeletePackageItemCommand(Guid packageId, Guid packageItemId)
|
||||||
|
{
|
||||||
|
PackageId = packageId;
|
||||||
|
PackageItemId = packageItemId;
|
||||||
|
}
|
||||||
|
|
||||||
|
public static DeletePackageItemCommand Create(Guid packageId, Guid packageItemId)
|
||||||
|
{
|
||||||
|
if (packageId == Guid.Empty)
|
||||||
|
throw new ArgumentException("Package id is required", nameof(packageId));
|
||||||
|
|
||||||
|
if (packageItemId == Guid.Empty)
|
||||||
|
throw new ArgumentException("Product price id is required", nameof(packageItemId));
|
||||||
|
|
||||||
|
return new(packageId, packageItemId);
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -0,0 +1,16 @@
|
|||||||
|
namespace LiteCharms.Features.CartPackages.Commands;
|
||||||
|
|
||||||
|
public class DeletePackageItemsCommand : IRequest<Result>
|
||||||
|
{
|
||||||
|
public Guid PackageId { get; set; }
|
||||||
|
|
||||||
|
private DeletePackageItemsCommand(Guid packageId) => PackageId = packageId;
|
||||||
|
|
||||||
|
public static DeletePackageItemsCommand Create(Guid packageId)
|
||||||
|
{
|
||||||
|
if (packageId == Guid.Empty)
|
||||||
|
throw new ArgumentException("Package ID is required", nameof(packageId));
|
||||||
|
|
||||||
|
return new(packageId);
|
||||||
|
}
|
||||||
|
}
|
||||||
+38
@@ -0,0 +1,38 @@
|
|||||||
|
using LiteCharms.Features.Shop.Postgres;
|
||||||
|
|
||||||
|
namespace LiteCharms.Features.CartPackages.Commands.Handlers;
|
||||||
|
|
||||||
|
public class AddPackageItemCommandHandler(IDbContextFactory<ShopDbContext> contextFactory) : IRequestHandler<AddPackageItemCommand, Result<Guid>>
|
||||||
|
{
|
||||||
|
public async ValueTask<Result<Guid>> Handle(AddPackageItemCommand request, CancellationToken cancellationToken)
|
||||||
|
{
|
||||||
|
try
|
||||||
|
{
|
||||||
|
using var context = await contextFactory.CreateDbContextAsync(cancellationToken);
|
||||||
|
|
||||||
|
if (!await context.Packages.AnyAsync(p => p.Id == request.PackageId, cancellationToken))
|
||||||
|
return Result.Fail($"Could not find package by ID {request.PackageId}");
|
||||||
|
|
||||||
|
if (!await context.ProductPrices.AnyAsync(p => p.Id == request.ProductPriceId && p.Active == true, cancellationToken))
|
||||||
|
return Result.Fail($"Could not find an active product price by ID {request.ProductPriceId}");
|
||||||
|
|
||||||
|
if (await context.PackageItems.AnyAsync(p => p.ProductPriceId == request.ProductPriceId && p.PackageId == request.PackageId, cancellationToken))
|
||||||
|
return Result.Fail<Guid>($"Product price {request.ProductPriceId} is already added to this package {request.PackageId}");
|
||||||
|
|
||||||
|
var newPackageItem = context.PackageItems.Add(new Entities.PackageItem
|
||||||
|
{
|
||||||
|
PackageId = request.PackageId,
|
||||||
|
ProductPriceId = request.ProductPriceId,
|
||||||
|
Active = true
|
||||||
|
});
|
||||||
|
|
||||||
|
return await context.SaveChangesAsync(cancellationToken) > 0
|
||||||
|
? Result.Ok(newPackageItem.Entity.Id)
|
||||||
|
: Result.Fail<Guid>($"Failed to add new package item by ID {request.ProductPriceId}");
|
||||||
|
}
|
||||||
|
catch (Exception ex)
|
||||||
|
{
|
||||||
|
return Result.Fail<Guid>(new Error(ex.Message).CausedBy(ex));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
+32
@@ -0,0 +1,32 @@
|
|||||||
|
using LiteCharms.Features.Shop.Postgres;
|
||||||
|
|
||||||
|
namespace LiteCharms.Features.CartPackages.Commands.Handlers;
|
||||||
|
|
||||||
|
public class CreatePackageCommandHandler(IDbContextFactory<ShopDbContext> contextFactory) : IRequestHandler<CreatePackageCommand, Result<Guid>>
|
||||||
|
{
|
||||||
|
public async ValueTask<Result<Guid>> Handle(CreatePackageCommand request, CancellationToken cancellationToken)
|
||||||
|
{
|
||||||
|
try
|
||||||
|
{
|
||||||
|
using var context = await contextFactory.CreateDbContextAsync(cancellationToken);
|
||||||
|
|
||||||
|
if (await context.Packages.AnyAsync(p => p.Name == request.Name, cancellationToken))
|
||||||
|
return Result.Fail($"A package by the same name already exists: {request.Name}");
|
||||||
|
|
||||||
|
var newPackage = context.Packages.Add(new Entities.Package
|
||||||
|
{
|
||||||
|
Name = request.Name,
|
||||||
|
Description = request.Description,
|
||||||
|
Active = true
|
||||||
|
});
|
||||||
|
|
||||||
|
return await context.SaveChangesAsync(cancellationToken) > 0
|
||||||
|
? Result.Ok(newPackage.Entity.Id)
|
||||||
|
: Result.Fail($"Failed to create a new package by the name: {request.Name}");
|
||||||
|
}
|
||||||
|
catch (Exception ex)
|
||||||
|
{
|
||||||
|
return Result.Fail<Guid>(new Error(ex.Message).CausedBy(ex));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
+32
@@ -0,0 +1,32 @@
|
|||||||
|
using LiteCharms.Features.Shop.Postgres;
|
||||||
|
|
||||||
|
namespace LiteCharms.Features.CartPackages.Commands.Handlers;
|
||||||
|
|
||||||
|
public class DeletePackageItemCommandHandler(IDbContextFactory<ShopDbContext> contextFactory) : IRequestHandler<DeletePackageItemCommand, Result>
|
||||||
|
{
|
||||||
|
public async ValueTask<Result> Handle(DeletePackageItemCommand request, CancellationToken cancellationToken)
|
||||||
|
{
|
||||||
|
try
|
||||||
|
{
|
||||||
|
using var context = await contextFactory.CreateDbContextAsync(cancellationToken);
|
||||||
|
|
||||||
|
if (!await context.Packages.AnyAsync(p => p.Id == request.PackageId, cancellationToken))
|
||||||
|
return Result.Fail($"Could not find package by ID {request.PackageId}");
|
||||||
|
|
||||||
|
var item = await context.PackageItems.FirstOrDefaultAsync(p => p.Id == request.PackageItemId && p.PackageId == request.PackageId, cancellationToken);
|
||||||
|
|
||||||
|
if(item is null)
|
||||||
|
return Result.Fail($"Product item {request.PackageItemId} is already added to this package {request.PackageId}");
|
||||||
|
|
||||||
|
context.PackageItems.Remove(item);
|
||||||
|
|
||||||
|
return await context.SaveChangesAsync(cancellationToken) > 0
|
||||||
|
? Result.Ok()
|
||||||
|
: Result.Fail($"Failed to delete package item by id {request.PackageItemId}");
|
||||||
|
}
|
||||||
|
catch (Exception ex)
|
||||||
|
{
|
||||||
|
return Result.Fail(new Error(ex.Message).CausedBy(ex));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
+29
@@ -0,0 +1,29 @@
|
|||||||
|
using LiteCharms.Features.Shop.Postgres;
|
||||||
|
|
||||||
|
namespace LiteCharms.Features.CartPackages.Commands.Handlers;
|
||||||
|
|
||||||
|
public class DeletePackageItemsCommandHandler(IDbContextFactory<ShopDbContext> contextFactory) : IRequestHandler<DeletePackageItemsCommand, Result>
|
||||||
|
{
|
||||||
|
public async ValueTask<Result> Handle(DeletePackageItemsCommand request, CancellationToken cancellationToken)
|
||||||
|
{
|
||||||
|
try
|
||||||
|
{
|
||||||
|
using var context = await contextFactory.CreateDbContextAsync(cancellationToken);
|
||||||
|
|
||||||
|
if (!await context.Packages.AnyAsync(p => p.Id == request.PackageId, cancellationToken))
|
||||||
|
return Result.Fail($"Could not find package by ID {request.PackageId}");
|
||||||
|
|
||||||
|
var items = await context.PackageItems.Where(i => i.PackageId == request.PackageId).ToArrayAsync(cancellationToken);
|
||||||
|
|
||||||
|
context.PackageItems.RemoveRange(items);
|
||||||
|
|
||||||
|
return await context.SaveChangesAsync(cancellationToken) > 0
|
||||||
|
? Result.Ok()
|
||||||
|
: Result.Fail($"Failed to delete package {request.PackageId} items");
|
||||||
|
}
|
||||||
|
catch (Exception ex)
|
||||||
|
{
|
||||||
|
return Result.Fail(new Error(ex.Message).CausedBy(ex));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
+33
@@ -0,0 +1,33 @@
|
|||||||
|
using LiteCharms.Features.Shop.Postgres;
|
||||||
|
|
||||||
|
namespace LiteCharms.Features.CartPackages.Commands.Handlers;
|
||||||
|
|
||||||
|
public class UpdatePackageCommandHandler(IDbContextFactory<ShopDbContext> contextFactory) : IRequestHandler<UpdatePackageCommand, Result>
|
||||||
|
{
|
||||||
|
public async ValueTask<Result> Handle(UpdatePackageCommand request, CancellationToken cancellationToken)
|
||||||
|
{
|
||||||
|
try
|
||||||
|
{
|
||||||
|
using var context = await contextFactory.CreateDbContextAsync(cancellationToken);
|
||||||
|
|
||||||
|
if (await context.Packages.AnyAsync(p => p.Name == request.Name, cancellationToken))
|
||||||
|
return Result.Fail($"A package by the same name already exists: {request.Name}");
|
||||||
|
|
||||||
|
var package = await context.Packages.FirstOrDefaultAsync(p => p.Id == request.PackageId, cancellationToken);
|
||||||
|
|
||||||
|
if (package is null)
|
||||||
|
return Result.Fail($"Could not find package by id {request.PackageId}");
|
||||||
|
|
||||||
|
package.Name = request.Name;
|
||||||
|
package.Description = request.Description;
|
||||||
|
|
||||||
|
return await context.SaveChangesAsync(cancellationToken) > 0
|
||||||
|
? Result.Ok()
|
||||||
|
: Result.Fail($"Failed to update package with id {request.PackageId}");
|
||||||
|
}
|
||||||
|
catch (Exception ex)
|
||||||
|
{
|
||||||
|
return Result.Fail(new Error(ex.Message).CausedBy(ex));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
+29
@@ -0,0 +1,29 @@
|
|||||||
|
using LiteCharms.Features.Shop.Postgres;
|
||||||
|
|
||||||
|
namespace LiteCharms.Features.CartPackages.Commands.Handlers;
|
||||||
|
|
||||||
|
public class UpdatePackageStatusCommandHandler(IDbContextFactory<ShopDbContext> contextFactory) : IRequestHandler<UpdatePackageStatusCommand, Result>
|
||||||
|
{
|
||||||
|
public async ValueTask<Result> Handle(UpdatePackageStatusCommand request, CancellationToken cancellationToken)
|
||||||
|
{
|
||||||
|
try
|
||||||
|
{
|
||||||
|
using var context = await contextFactory.CreateDbContextAsync(cancellationToken);
|
||||||
|
|
||||||
|
var package = await context.Packages.FirstOrDefaultAsync(p => p.Id == request.PackageId, cancellationToken);
|
||||||
|
|
||||||
|
if (package is null)
|
||||||
|
return Result.Fail($"Could not find package by id {request.PackageId}");
|
||||||
|
|
||||||
|
package.Active = request.Active;
|
||||||
|
|
||||||
|
return await context.SaveChangesAsync(cancellationToken) > 0
|
||||||
|
? Result.Ok()
|
||||||
|
: Result.Fail($"Failed to update package with id {request.PackageId}");
|
||||||
|
}
|
||||||
|
catch (Exception ex)
|
||||||
|
{
|
||||||
|
return Result.Fail(new Error(ex.Message).CausedBy(ex));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -0,0 +1,28 @@
|
|||||||
|
namespace LiteCharms.Features.CartPackages.Commands;
|
||||||
|
|
||||||
|
public class UpdatePackageCommand : IRequest<Result>
|
||||||
|
{
|
||||||
|
public Guid PackageId { get; set; }
|
||||||
|
|
||||||
|
public string? Name { get; set; }
|
||||||
|
|
||||||
|
public string? Description { get; set; }
|
||||||
|
|
||||||
|
private UpdatePackageCommand(Guid packageId, string? name, string? description)
|
||||||
|
{
|
||||||
|
PackageId = packageId;
|
||||||
|
Name = name;
|
||||||
|
Description = description;
|
||||||
|
}
|
||||||
|
|
||||||
|
public static UpdatePackageCommand Create(Guid packageId, string? name, string? description)
|
||||||
|
{
|
||||||
|
if (packageId == Guid.Empty)
|
||||||
|
throw new ArgumentException($"Package ID is required", nameof(packageId));
|
||||||
|
|
||||||
|
ArgumentNullException.ThrowIfNullOrWhiteSpace(name, nameof(name));
|
||||||
|
ArgumentNullException.ThrowIfNullOrWhiteSpace(description, nameof(description));
|
||||||
|
|
||||||
|
return new(packageId, name, description);
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -0,0 +1,22 @@
|
|||||||
|
namespace LiteCharms.Features.CartPackages.Commands;
|
||||||
|
|
||||||
|
public class UpdatePackageStatusCommand : IRequest<Result>
|
||||||
|
{
|
||||||
|
public Guid PackageId { get; set; }
|
||||||
|
|
||||||
|
public bool Active { get; set; }
|
||||||
|
|
||||||
|
private UpdatePackageStatusCommand(Guid packageId, bool active)
|
||||||
|
{
|
||||||
|
PackageId = packageId;
|
||||||
|
Active = active;
|
||||||
|
}
|
||||||
|
|
||||||
|
public static UpdatePackageStatusCommand Create(Guid packageId, bool active)
|
||||||
|
{
|
||||||
|
if(packageId == Guid.Empty)
|
||||||
|
throw new ArgumentException($"Package id is required", nameof(packageId));
|
||||||
|
|
||||||
|
return new(packageId, active);
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -0,0 +1,7 @@
|
|||||||
|
namespace LiteCharms.Features.Shop.CartPackages.Entities;
|
||||||
|
|
||||||
|
[EntityTypeConfiguration<PackageConfirguration, Package>]
|
||||||
|
public class Package : Models.Package
|
||||||
|
{
|
||||||
|
public virtual ICollection<PackageItem>? PackageItems { get; set; }
|
||||||
|
}
|
||||||
@@ -0,0 +1,18 @@
|
|||||||
|
namespace LiteCharms.Features.Shop.CartPackages.Entities;
|
||||||
|
|
||||||
|
public class PackageConfirguration : IEntityTypeConfiguration<Package>
|
||||||
|
{
|
||||||
|
public void Configure(EntityTypeBuilder<Package> builder)
|
||||||
|
{
|
||||||
|
builder.ToTable(nameof(Package));
|
||||||
|
|
||||||
|
builder.HasKey(f => f.Id);
|
||||||
|
builder.Property(f => f.CreatedAt).IsRequired().ValueGeneratedOnAdd().HasDefaultValueSql("now()");
|
||||||
|
builder.Property(f => f.UpdatedAt).IsRequired(false);
|
||||||
|
builder.Property(f => f.Name).IsRequired();
|
||||||
|
builder.Property(f => f.Summary).IsRequired().HasMaxLength(512);
|
||||||
|
builder.Property(f => f.Description).IsRequired().HasMaxLength(2048);
|
||||||
|
builder.Property(f => f.ImageUrl).IsRequired(false).HasMaxLength(2048);
|
||||||
|
builder.Property(f => f.Active);
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -0,0 +1,11 @@
|
|||||||
|
using LiteCharms.Features.Shop.Products.Entities;
|
||||||
|
|
||||||
|
namespace LiteCharms.Features.Shop.CartPackages.Entities;
|
||||||
|
|
||||||
|
[EntityTypeConfiguration<PackageItemConfiguration, PackageItem>]
|
||||||
|
public class PackageItem : Models.PackageItem
|
||||||
|
{
|
||||||
|
public virtual Package? Package { get; set; }
|
||||||
|
|
||||||
|
public virtual ProductPrice? ProductPrice { get; set; }
|
||||||
|
}
|
||||||
@@ -0,0 +1,27 @@
|
|||||||
|
namespace LiteCharms.Features.Shop.CartPackages.Entities;
|
||||||
|
|
||||||
|
public class PackageItemConfiguration : IEntityTypeConfiguration<PackageItem>
|
||||||
|
{
|
||||||
|
public void Configure(EntityTypeBuilder<PackageItem> builder)
|
||||||
|
{
|
||||||
|
builder.ToTable(nameof(PackageItem));
|
||||||
|
|
||||||
|
builder.HasKey(f => f.Id);
|
||||||
|
builder.Property(f => f.CreatedAt).IsRequired().ValueGeneratedOnAdd().HasDefaultValueSql("now()");
|
||||||
|
builder.Property(f => f.PackageId).IsRequired();
|
||||||
|
builder.Property(f => f.ProductPriceId).IsRequired();
|
||||||
|
builder.Property(f => f.Active);
|
||||||
|
|
||||||
|
builder.HasOne(f => f.Package)
|
||||||
|
.WithMany(f => f.PackageItems)
|
||||||
|
.HasForeignKey(pi => pi.PackageId)
|
||||||
|
.IsRequired()
|
||||||
|
.OnDelete(DeleteBehavior.Cascade);
|
||||||
|
|
||||||
|
builder.HasOne(f => f.ProductPrice)
|
||||||
|
.WithMany()
|
||||||
|
.HasForeignKey(pi => pi.ProductPriceId)
|
||||||
|
.IsRequired()
|
||||||
|
.OnDelete(DeleteBehavior.Restrict);
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -0,0 +1,20 @@
|
|||||||
|
namespace LiteCharms.Features.Shop.CartPackages.Models;
|
||||||
|
|
||||||
|
public class Package
|
||||||
|
{
|
||||||
|
public Guid Id { get; set; }
|
||||||
|
|
||||||
|
public DateTimeOffset CreatedAt { get; set; }
|
||||||
|
|
||||||
|
public DateTimeOffset? UpdatedAt { get; set; }
|
||||||
|
|
||||||
|
public string? Name { get; set; }
|
||||||
|
|
||||||
|
public string? Summary { get; set; }
|
||||||
|
|
||||||
|
public string? Description { get; set; }
|
||||||
|
|
||||||
|
public string? ImageUrl { get; set; }
|
||||||
|
|
||||||
|
public bool Active { get; set; }
|
||||||
|
}
|
||||||
@@ -0,0 +1,14 @@
|
|||||||
|
namespace LiteCharms.Features.Shop.CartPackages.Models;
|
||||||
|
|
||||||
|
public class PackageItem
|
||||||
|
{
|
||||||
|
public Guid Id { get; set; }
|
||||||
|
|
||||||
|
public Guid PackageId { get; set; }
|
||||||
|
|
||||||
|
public Guid ProductPriceId { get; set; }
|
||||||
|
|
||||||
|
public DateTimeOffset CreatedAt { get; set; }
|
||||||
|
|
||||||
|
public bool Active { get; set; }
|
||||||
|
}
|
||||||
@@ -0,0 +1,18 @@
|
|||||||
|
using LiteCharms.Features.Shop.CartPackages.Models;
|
||||||
|
|
||||||
|
namespace LiteCharms.Features.CartPackages.Queries;
|
||||||
|
|
||||||
|
public class GetPackageItemsQuery : IRequest<Result<PackageItem[]>>
|
||||||
|
{
|
||||||
|
public Guid PackageId { get; set; }
|
||||||
|
|
||||||
|
private GetPackageItemsQuery(Guid packageId) => PackageId = packageId;
|
||||||
|
|
||||||
|
public static GetPackageItemsQuery Create(Guid packageId)
|
||||||
|
{
|
||||||
|
if (packageId == Guid.Empty)
|
||||||
|
throw new ArgumentException("Package ID is required", nameof(packageId));
|
||||||
|
|
||||||
|
return new(packageId);
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -0,0 +1,18 @@
|
|||||||
|
using LiteCharms.Features.Shop.CartPackages.Models;
|
||||||
|
|
||||||
|
namespace LiteCharms.Features.CartPackages.Queries;
|
||||||
|
|
||||||
|
public class GetPackageQuery : IRequest<Result<Package>>
|
||||||
|
{
|
||||||
|
public Guid PackageId { get; set; }
|
||||||
|
|
||||||
|
private GetPackageQuery(Guid packageId) => PackageId = packageId;
|
||||||
|
|
||||||
|
public static GetPackageQuery Create(Guid packageId)
|
||||||
|
{
|
||||||
|
if(packageId == Guid.Empty)
|
||||||
|
throw new ArgumentException("Package ID is required", nameof(packageId));
|
||||||
|
|
||||||
|
return new(packageId);
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -0,0 +1,33 @@
|
|||||||
|
using LiteCharms.Features.Shop.CartPackages.Models;
|
||||||
|
|
||||||
|
namespace LiteCharms.Features.CartPackages.Queries;
|
||||||
|
|
||||||
|
public class GetPackagesQuery : IRequest<Result<Package[]>>
|
||||||
|
{
|
||||||
|
public DateOnly From { get; set; }
|
||||||
|
|
||||||
|
public DateOnly To { get; set; }
|
||||||
|
|
||||||
|
public int MaxRecords { get; set; }
|
||||||
|
|
||||||
|
public bool Active { get; set; }
|
||||||
|
|
||||||
|
private GetPackagesQuery(DateOnly from, DateOnly to, int maxRecords = 1000, bool active = true)
|
||||||
|
{
|
||||||
|
From = from;
|
||||||
|
To = to;
|
||||||
|
MaxRecords = maxRecords;
|
||||||
|
Active = active;
|
||||||
|
}
|
||||||
|
|
||||||
|
public static GetPackagesQuery Create(DateOnly from, DateOnly to, int maxRecords = 1000, bool active = true)
|
||||||
|
{
|
||||||
|
if (from > to)
|
||||||
|
throw new ArgumentException("From date cannot be greater than To date.");
|
||||||
|
|
||||||
|
if (maxRecords <= 0)
|
||||||
|
throw new ArgumentException("MaxRecords must be a positive integer.");
|
||||||
|
|
||||||
|
return new(from, to, maxRecords, active);
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -0,0 +1,32 @@
|
|||||||
|
using LiteCharms.Extensions;
|
||||||
|
using LiteCharms.Features.Shop.CartPackages.Models;
|
||||||
|
using LiteCharms.Features.Shop.Postgres;
|
||||||
|
|
||||||
|
namespace LiteCharms.Features.CartPackages.Queries.Handlers;
|
||||||
|
|
||||||
|
public class GetPackageItemsQueryHandler(IDbContextFactory<ShopDbContext> contextFactory) : IRequestHandler<GetPackageItemsQuery, Result<PackageItem[]>>
|
||||||
|
{
|
||||||
|
public async ValueTask<Result<PackageItem[]>> Handle(GetPackageItemsQuery request, CancellationToken cancellationToken)
|
||||||
|
{
|
||||||
|
try
|
||||||
|
{
|
||||||
|
using var context = await contextFactory.CreateDbContextAsync(cancellationToken);
|
||||||
|
|
||||||
|
if (!await context.Packages.AnyAsync(p => p.Id == request.PackageId, cancellationToken))
|
||||||
|
return Result.Fail<PackageItem[]>($"Package could not be found with ID {request.PackageId}");
|
||||||
|
|
||||||
|
var items = await context.PackageItems.AsNoTracking()
|
||||||
|
.OrderByDescending(o => o.CreatedAt)
|
||||||
|
.Where(p => p.PackageId == request.PackageId)
|
||||||
|
.ToArrayAsync(cancellationToken);
|
||||||
|
|
||||||
|
return items?.Length > 0
|
||||||
|
? Result.Ok(items.Select(i => i.ToModel()).ToArray())
|
||||||
|
: Result.Fail<PackageItem[]>($"Could not find package items by package ID {request.PackageId}");
|
||||||
|
}
|
||||||
|
catch (Exception ex)
|
||||||
|
{
|
||||||
|
return Result.Fail<PackageItem[]>(new Error(ex.Message).CausedBy(ex));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -0,0 +1,27 @@
|
|||||||
|
using LiteCharms.Extensions;
|
||||||
|
using LiteCharms.Features.Shop.CartPackages.Models;
|
||||||
|
using LiteCharms.Features.Shop.Postgres;
|
||||||
|
|
||||||
|
namespace LiteCharms.Features.CartPackages.Queries.Handlers;
|
||||||
|
|
||||||
|
public class GetPackageQueryHandler(IDbContextFactory<ShopDbContext> contextFactory) : IRequestHandler<GetPackageQuery, Result<Package>>
|
||||||
|
{
|
||||||
|
public async ValueTask<Result<Package>> Handle(GetPackageQuery request, CancellationToken cancellationToken)
|
||||||
|
{
|
||||||
|
try
|
||||||
|
{
|
||||||
|
using var context = await contextFactory.CreateDbContextAsync(cancellationToken);
|
||||||
|
|
||||||
|
var package = await context.Packages.FirstOrDefaultAsync(p => p.Id == request.PackageId, cancellationToken);
|
||||||
|
|
||||||
|
return package is not null
|
||||||
|
? Result.Ok(package.ToModel())
|
||||||
|
: Result.Fail($"Failed to find package by ID {request.PackageId}");
|
||||||
|
|
||||||
|
}
|
||||||
|
catch (Exception ex)
|
||||||
|
{
|
||||||
|
return Result.Fail<Package>(new Error(ex.Message).CausedBy(ex));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -0,0 +1,35 @@
|
|||||||
|
using LiteCharms.Extensions;
|
||||||
|
using LiteCharms.Features.Shop.CartPackages.Models;
|
||||||
|
using LiteCharms.Features.Shop.Postgres;
|
||||||
|
|
||||||
|
namespace LiteCharms.Features.CartPackages.Queries.Handlers;
|
||||||
|
|
||||||
|
public class GetPackagesQueryHandler(IDbContextFactory<ShopDbContext> contextFactory) : IRequestHandler<GetPackagesQuery, Result<Package[]>>
|
||||||
|
{
|
||||||
|
public async ValueTask<Result<Package[]>> Handle(GetPackagesQuery request, CancellationToken cancellationToken)
|
||||||
|
{
|
||||||
|
try
|
||||||
|
{
|
||||||
|
var fromDate = request.From.ToDateTime(TimeOnly.MinValue);
|
||||||
|
var toDate = request.To.ToDateTime(TimeOnly.MaxValue);
|
||||||
|
|
||||||
|
using var context = await contextFactory.CreateDbContextAsync(cancellationToken);
|
||||||
|
|
||||||
|
var packages = await context.Packages
|
||||||
|
.AsNoTracking()
|
||||||
|
.OrderByDescending(o => o.CreatedAt)
|
||||||
|
.Where(p => p.CreatedAt >= fromDate && p.CreatedAt <= toDate)
|
||||||
|
.Where(p => p.Active == request.Active)
|
||||||
|
.Take(request.MaxRecords)
|
||||||
|
.ToArrayAsync(cancellationToken);
|
||||||
|
|
||||||
|
return packages?.Length > 0
|
||||||
|
? Result.Ok(packages.Select(o => o.ToModel()).ToArray())
|
||||||
|
: Result.Fail<Package[]>(new Error($"No packages found for the specified date range {request.From} - {request.To}."));
|
||||||
|
}
|
||||||
|
catch (Exception ex)
|
||||||
|
{
|
||||||
|
return Result.Fail<Package[]>(new Error(ex.Message).CausedBy(ex));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
+1
-1
@@ -1,4 +1,4 @@
|
|||||||
using LiteCharms.Infrastructure.Database;
|
using LiteCharms.Features.Shop.Postgres;
|
||||||
|
|
||||||
namespace LiteCharms.Features.Customers.Commands.Handlers;
|
namespace LiteCharms.Features.Customers.Commands.Handlers;
|
||||||
|
|
||||||
+1
-1
@@ -1,4 +1,4 @@
|
|||||||
using LiteCharms.Infrastructure.Database;
|
using LiteCharms.Features.Shop.Postgres;
|
||||||
|
|
||||||
namespace LiteCharms.Features.Customers.Commands.Handlers;
|
namespace LiteCharms.Features.Customers.Commands.Handlers;
|
||||||
|
|
||||||
+5
-2
@@ -1,6 +1,9 @@
|
|||||||
using LiteCharms.Entities.Configuration;
|
using LiteCharms.Features.Shop.Leads.Entities;
|
||||||
|
using LiteCharms.Features.Shop.Orders.Entities;
|
||||||
|
using LiteCharms.Features.Shop.Quotes.Entities;
|
||||||
|
using LiteCharms.Features.Shop.ShoppingCarts.Entities;
|
||||||
|
|
||||||
namespace LiteCharms.Entities;
|
namespace LiteCharms.Features.Shop.Customers.Entities;
|
||||||
|
|
||||||
[EntityTypeConfiguration<CustomerConfiguration, Customer>]
|
[EntityTypeConfiguration<CustomerConfiguration, Customer>]
|
||||||
public class Customer : Models.Customer
|
public class Customer : Models.Customer
|
||||||
+3
-8
@@ -1,4 +1,4 @@
|
|||||||
namespace LiteCharms.Entities.Configuration;
|
namespace LiteCharms.Features.Shop.Customers.Entities;
|
||||||
|
|
||||||
public class CustomerConfiguration : IEntityTypeConfiguration<Customer>
|
public class CustomerConfiguration : IEntityTypeConfiguration<Customer>
|
||||||
{
|
{
|
||||||
@@ -7,8 +7,8 @@ public class CustomerConfiguration : IEntityTypeConfiguration<Customer>
|
|||||||
builder.ToTable(nameof(Customer));
|
builder.ToTable(nameof(Customer));
|
||||||
|
|
||||||
builder.HasKey(f => f.Id);
|
builder.HasKey(f => f.Id);
|
||||||
builder.Property(f => f.CreatedAt).ValueGeneratedOnAdd();
|
builder.Property(f => f.CreatedAt).ValueGeneratedOnAdd().HasDefaultValueSql("now()");
|
||||||
builder.Property(f => f.UpdatedAt).IsRequired(false).ValueGeneratedOnUpdate();
|
builder.Property(f => f.UpdatedAt).IsRequired(false);
|
||||||
builder.Property(f => f.Company);
|
builder.Property(f => f.Company);
|
||||||
builder.Property(f => f.Name).IsRequired();
|
builder.Property(f => f.Name).IsRequired();
|
||||||
builder.Property(f => f.LastName).IsRequired();
|
builder.Property(f => f.LastName).IsRequired();
|
||||||
@@ -26,10 +26,5 @@ public class CustomerConfiguration : IEntityTypeConfiguration<Customer>
|
|||||||
builder.Property(f => f.Country);
|
builder.Property(f => f.Country);
|
||||||
builder.Property(f => f.PostalCode);
|
builder.Property(f => f.PostalCode);
|
||||||
builder.Property(f => f.Active).HasDefaultValue(true);
|
builder.Property(f => f.Active).HasDefaultValue(true);
|
||||||
|
|
||||||
builder.HasMany(f => f.Leads)
|
|
||||||
.WithOne(f => f.Customer)
|
|
||||||
.HasForeignKey(f => f.CustomerId)
|
|
||||||
.OnDelete(DeleteBehavior.NoAction);
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
+1
-1
@@ -1,4 +1,4 @@
|
|||||||
namespace LiteCharms.Models;
|
namespace LiteCharms.Features.Shop.Customers.Models;
|
||||||
|
|
||||||
public class Customer
|
public class Customer
|
||||||
{
|
{
|
||||||
+1
-1
@@ -1,4 +1,4 @@
|
|||||||
using LiteCharms.Models;
|
using LiteCharms.Features.Shop.Customers.Models;
|
||||||
|
|
||||||
namespace LiteCharms.Features.Customers.Queries;
|
namespace LiteCharms.Features.Customers.Queries;
|
||||||
|
|
||||||
+1
-1
@@ -1,4 +1,4 @@
|
|||||||
using LiteCharms.Models;
|
using LiteCharms.Features.Shop.Customers.Models;
|
||||||
|
|
||||||
namespace LiteCharms.Features.Customers.Queries;
|
namespace LiteCharms.Features.Customers.Queries;
|
||||||
|
|
||||||
+2
-2
@@ -1,6 +1,6 @@
|
|||||||
using LiteCharms.Extensions;
|
using LiteCharms.Extensions;
|
||||||
using LiteCharms.Infrastructure.Database;
|
using LiteCharms.Features.Shop.Customers.Models;
|
||||||
using LiteCharms.Models;
|
using LiteCharms.Features.Shop.Postgres;
|
||||||
|
|
||||||
namespace LiteCharms.Features.Customers.Queries.Handlers;
|
namespace LiteCharms.Features.Customers.Queries.Handlers;
|
||||||
|
|
||||||
+2
-2
@@ -1,6 +1,6 @@
|
|||||||
using LiteCharms.Extensions;
|
using LiteCharms.Extensions;
|
||||||
using LiteCharms.Infrastructure.Database;
|
using LiteCharms.Features.Shop.Customers.Models;
|
||||||
using LiteCharms.Models;
|
using LiteCharms.Features.Shop.Postgres;
|
||||||
|
|
||||||
namespace LiteCharms.Features.Customers.Queries.Handlers;
|
namespace LiteCharms.Features.Customers.Queries.Handlers;
|
||||||
|
|
||||||
Some files were not shown because too many files have changed in this diff Show More
Reference in New Issue
Block a user