Merge commit 'cecd9f90e9812a2bd84b2bb8026dbc9cce79741f'

Reviewed-on: #15

.drone.yml

@@ -13,8 +13,7 @@ steps:
   - name: pack-and-publish
     image: mcr.microsoft.com/dotnet/sdk:10.0
     environment:
-      NEXUS_KEY:
+      NEXUS_KEY: { from_secret: nexus_api_key }
-        from_secret: nexus_api_key
       NEXUS_URL: https://nexus.khongisa.co.za/repository/nuget-hosted/
       VERSION: 1.${DRONE_BUILD_NUMBER}.0
     commands:
@@ -42,6 +41,31 @@ steps:
       - dotnet pack LiteCharms.Entities/LiteCharms.Entities.csproj -c Release -p:PackageVersion=$VERSION -o dist/
       - dotnet nuget push dist/LiteCharms.Entities.$VERSION.nupkg --api-key $NEXUS_KEY --source $NEXUS_URL
 
+  - name: gitea-tag-release
+    image: alpine/git
+    environment:
+      GITEA_TOKEN: { from_secret: git_token }
+      GITEA_USER: { from_secret: git_username }
+      GITEA_PASS: { from_secret: git_password }
+      VERSION: 1.${DRONE_BUILD_NUMBER}.0
+    commands:
+      - apk add --no-cache curl
+      - git remote set-url origin https://$${GITEA_USER}:$${GITEA_PASS}@gitea.khongisa.co.za/litecharms/components.git
+      - git tag $VERSION
+      - git push origin $VERSION
+      - |
+        curl -X POST "https://gitea.khongisa.co.za/api/v1/repos/litecharms/components/releases" \
+             -H "Authorization: token $${GITEA_TOKEN}" \
+             -H "Content-Type: application/json" \
+             -d "{
+               \"tag_name\": \"$VERSION\",
+               \"target_commitish\": \"${DRONE_COMMIT_SHA}\",
+               \"name\": \"Library Suite $VERSION\",
+               \"body\": \"### Published NuGet Packages\nAll packages versioned as **$VERSION**:\n* LiteCharms.Abstractions\n* LiteCharms.Models\n* LiteCharms.Infrastructure\n* LiteCharms.Features\n* LiteCharms.Extensions\n* LiteCharms.Entities\n\n[View in Nexus](https://nexus.khongisa.co.za/repository/nuget-group/)\",
+               \"draft\": false,
+               \"prerelease\": false
+             }"
+
 trigger:
-  branch:
+  event:
-    - master
+    - pull_request

LiteCharms.Abstractions/Constants.cs

@@ -4,6 +4,10 @@ public static class Constants
 {
     public const int QueueBounds = 100000;
 
+    public const string ShopSchedulerName = "shop";
+    public const string ShopEmailFromName = "Khongisa Shop";
+    public const string ShopEmailFromAddress = "shop@litecharms.co.za";
+
     public const string EmailServiceBus = nameof(EmailServiceBus);
     public const string GeneralServiceBus = nameof(GeneralServiceBus);
     public const string SalesServiceBus = nameof(SalesServiceBus);

LiteCharms.Abstractions/EventBase.cs

@@ -0,0 +1,12 @@
+using static LiteCharms.Abstractions.Timezones;
+
+namespace LiteCharms.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();
+}

LiteCharms.Entities/Configuration/NotificationConfiguration.cs

@@ -1,4 +1,6 @@
-namespace LiteCharms.Entities.Configuration;
+using LiteCharms.Models;
+
+namespace LiteCharms.Entities.Configuration;
 
 public class NotificationConfiguration : IEntityTypeConfiguration<Notification>
 {
@@ -8,15 +10,21 @@ public class NotificationConfiguration : IEntityTypeConfiguration<Notification>
 
         builder.HasKey(f => f.Id);
         builder.Property(f => f.CreatedAt).IsRequired().ValueGeneratedOnAdd();
-        builder.Property(f => f.Direction).IsRequired();
+        builder.Property(f => f.UpdatedAt).IsRequired(false).ValueGeneratedOnUpdate();
-        builder.Property(f => f.Author).IsRequired();
+        builder.Property(f => f.Direction).IsRequired().HasConversion<int>();
-        builder.Property(f => f.Title).IsRequired();
+        builder.Property(f => f.Platform).IsRequired().HasConversion<int>();
-        builder.Property(f => f.Description).IsRequired();
+        builder.Property(f => f.Priority).IsRequired().HasConversion<int>();
-        builder.Property(f => f.Platform).IsRequired();
+        builder.Property(f => f.CorrelationIdType).IsRequired().HasConversion<int>();
-        builder.Property(f => f.PlatformAddress).IsRequired();
+        builder.Property(f => f.Sender).IsRequired();
+        builder.Property(f => f.Subject).IsRequired();
+        builder.Property(f => f.Message).IsRequired();
+        builder.Property(f => f.Recipient).IsRequired();
+        builder.Property(f => f.RecipientAddress).IsRequired();
         builder.Property(f => f.CorrelationId).IsRequired();
-        builder.Property(f => f.CorrelationIdType).IsRequired();
+        builder.Property(f => f.IsHtml).HasDefaultValue(false);
         builder.Property(f => f.IsInternal).HasDefaultValue(true);
         builder.Property(f => f.Processed).HasDefaultValue(false);
+        builder.Property(f => f.HasError).HasDefaultValue(false);
+        builder.Property(f => f.Errors).HasColumnType("jsonb").IsRequired(false);
     }
 }

LiteCharms.Entities/Configuration/OrderConfiguration.cs

@@ -14,7 +14,10 @@ public class OrderConfiguration : IEntityTypeConfiguration<Order>
         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.Requirements).HasColumnType("jsonb").IsRequired(false);
         builder.Property(f => f.Notes).HasColumnType("jsonb").IsRequired(false);
+        builder.Property(f => f.Terms).HasColumnType("jsonb").IsRequired(false);
+        builder.Property(f => f.DepositRequired);
 
         builder.HasOne(f => f.Quote)
             .WithOne(f => f.Order)

LiteCharms.Entities/Configuration/PackageConfirguration.cs

@@ -0,0 +1,16 @@
+namespace LiteCharms.Entities.Configuration;
+
+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();
+        builder.Property(f => f.UpdatedAt).IsRequired(false).ValueGeneratedOnUpdate();
+        builder.Property(f => f.Name).IsRequired();
+        builder.Property(f => f.Description).IsRequired();
+        builder.Property(f => f.Active);
+    }
+}

LiteCharms.Entities/Configuration/PackageItemConfiguration.cs

@@ -0,0 +1,20 @@
+namespace LiteCharms.Entities.Configuration;
+
+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();
+        builder.Property(f => f.PackageId).IsRequired();
+        builder.Property(f => f.ProductPriceId).IsRequired();
+        builder.Property(f => f.Active);
+
+        builder.HasOne(f => f.Package)
+            .WithMany()
+            .HasForeignKey(f => f.PackageId)
+            .OnDelete(DeleteBehavior.NoAction);
+    }
+}

LiteCharms.Entities/Configuration/QuoteConfiguration.cs

@@ -8,10 +8,10 @@ public class QuoteConfiguration : IEntityTypeConfiguration<Quote>
 
         builder.HasKey(f => f.Id);
         builder.Property(f => f.CreatedAt).IsRequired().ValueGeneratedOnAdd();
-        builder.Property(f => f.UpdatedAt).IsRequired().ValueGeneratedOnAddOrUpdate();
+        builder.Property(f => f.UpdatedAt).IsRequired(false).ValueGeneratedOnUpdate();
         builder.Property(f => f.ExpiredAt).IsRequired(false);
         builder.Property(f => f.CustomerId).IsRequired();
-        builder.Property(f => f.Status).IsRequired();
+        builder.Property(f => f.Status).IsRequired().HasConversion<int>();
         builder.Property(f => f.ShoppingCartId).IsRequired();
         builder.Property(f => f.Reason).IsRequired(false);
 

LiteCharms.Entities/Configuration/ShoppingCartConfiguration.cs

@@ -8,7 +8,7 @@ public class ShoppingCartConfiguration : IEntityTypeConfiguration<ShoppingCart>
 
         builder.HasKey(f =>  f.Id);
         builder.Property(f => f.CreatedAt).IsRequired().ValueGeneratedOnAdd();
-        builder.Property(f => f.UpdatedAt).IsRequired().ValueGeneratedOnAddOrUpdate();
+        builder.Property(f => f.UpdatedAt).IsRequired(false).ValueGeneratedOnUpdate();
         builder.Property(f => f.CustomerId).IsRequired(false);
         builder.Property(f => f.OrderId).IsRequired(false);
         builder.Property(f => f.QuoteId).IsRequired(false);        

LiteCharms.Entities/Configuration/ShoppingCartItemConfiguration.cs

@@ -8,7 +8,7 @@ public class ShoppingCartItemConfiguration : IEntityTypeConfiguration<ShoppingCa
 
         builder.HasKey(f => f.Id);
         builder.Property(f => f.CreatedAt).IsRequired().ValueGeneratedOnAdd();
-        builder.Property(f => f.UpdatedAt).IsRequired().ValueGeneratedOnAddOrUpdate();
+        builder.Property(f => f.UpdatedAt).IsRequired(false).ValueGeneratedOnUpdate();
         builder.Property(f => f.Quantity).IsRequired().HasDefaultValue(1);
         builder.Property(f => f.ProductPriceId).IsRequired();
 

LiteCharms.Entities/Configuration/ShoppingCartPackageConfiguration.cs

@@ -0,0 +1,24 @@
+namespace LiteCharms.Entities.Configuration;
+
+public class ShoppingCartPackageConfiguration : IEntityTypeConfiguration<ShoppingCartPackage>
+{
+    public void Configure(EntityTypeBuilder<ShoppingCartPackage> builder)
+    {
+        builder.ToTable(nameof(ShoppingCartPackage));
+
+        builder.HasKey(f => f.Id);
+        builder.Property(f => f.CreatedAt).IsRequired().ValueGeneratedOnAdd();
+        builder.Property(f => f.ShoppingCartId).IsRequired();
+        builder.Property(f => f.PackageId).IsRequired();
+
+        builder.HasOne(f => f.Package)
+            .WithMany()
+            .HasForeignKey(f => f.PackageId)
+            .OnDelete(DeleteBehavior.NoAction);
+
+        builder.HasOne(f => f.ShoppingCart)
+            .WithMany()
+            .HasForeignKey(f => f.ShoppingCartId)
+            .OnDelete(DeleteBehavior.NoAction);
+    }
+}

LiteCharms.Entities/Package.cs

@@ -0,0 +1,9 @@
+using LiteCharms.Entities.Configuration;
+
+namespace LiteCharms.Entities;
+
+[EntityTypeConfiguration<PackageConfirguration, Package>]
+public class Package : Models.Package
+{
+    public virtual ICollection<PackageItem>? PackageItems { get; set; }
+}

LiteCharms.Entities/PackageItem.cs

@@ -0,0 +1,9 @@
+using LiteCharms.Entities.Configuration;
+
+namespace LiteCharms.Entities;
+
+[EntityTypeConfiguration<PackageItemConfiguration, PackageItem>]
+public class PackageItem : Models.PackageItem
+{
+    public virtual Package? Package { get; set; }
+}

LiteCharms.Entities/ShoppingCart.cs

@@ -12,4 +12,6 @@ public class ShoppingCart : Models.ShoppingCart
     public virtual Quote? Quote { get; set; }
 
     public virtual ICollection<ShoppingCartItem>? ShoppingCartItems { get; set; }
+
+    public virtual ICollection<Package>? Packages { get; set; }
 }

LiteCharms.Entities/ShoppingCartPackage.cs

@@ -0,0 +1,11 @@
+using LiteCharms.Entities.Configuration;
+
+namespace LiteCharms.Entities;
+
+[EntityTypeConfiguration<ShoppingCartPackageConfiguration, ShoppingCartPackage>]
+public class ShoppingCartPackage : Models.ShoppingCartPackage
+{
+    public virtual ShoppingCart? ShoppingCart { get; set; }
+
+    public virtual Package? Package { get; set; }
+}

LiteCharms.Extensions/EntityModeMappers.cs

@@ -4,6 +4,36 @@ namespace LiteCharms.Extensions;
 
 public static class EntityModeMappers
 {
+    public static ShoppingCartPackage ToModel(this Entities.ShoppingCartPackage entity) =>
+        new()
+        {
+            Id = entity.Id,
+            CreatedAt = entity.CreatedAt,
+            PackageId = entity.PackageId,
+            ShoppingCartId = entity.ShoppingCartId
+        };
+
+    public static PackageItem ToModel(this Entities.PackageItem entity) =>
+        new()
+        {
+            Id = entity.Id,
+            Active = entity.Active,
+            CreatedAt = entity.CreatedAt,
+            PackageId = entity.PackageId,
+            ProductPriceId = entity.ProductPriceId            
+        };
+
+    public static Package ToModel(this Entities.Package entity) =>
+        new()
+        {
+            Id = entity.Id,
+            CreatedAt = entity.CreatedAt,
+            Active = entity.Active,
+            Description = entity.Description,
+            Name = entity.Name,
+            UpdatedAt = entity.UpdatedAt
+        };
+
     public static ShoppingCartItem ToModel(this Entities.ShoppingCartItem entity) =>
         new()
         {
@@ -36,7 +66,7 @@ public static class EntityModeMappers
             ExpiredAt = entity.ExpiredAt,
             Reason = entity.Reason,
             ShoppingCartId = entity.ShoppingCartId,
-            Status = entity.Status            
+            Status = entity.Status
         };
 
     public static Notification ToModel(this Entities.Notification entity) =>
@@ -44,16 +74,23 @@ public static class EntityModeMappers
         {
             Id = entity.Id,
             CreatedAt = entity.CreatedAt,
-            Description = entity.Description,
+            Message = entity.Message,
             Direction = entity.Direction,
             CorrelationId = entity.CorrelationId,
             CorrelationIdType = entity.CorrelationIdType,
             IsInternal = entity.IsInternal,
-            Author = entity.Author,
+            Sender = entity.Sender,
             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) =>
@@ -78,7 +115,7 @@ public static class EntityModeMappers
             Slack = entity.Slack,
             Tax = entity.Tax,
             Website = entity.Website,
-            Whatsapp = entity.Whatsapp            
+            Whatsapp = entity.Whatsapp
         };
 
     public static Lead ToModel(this Entities.Lead entity) =>
@@ -113,7 +150,10 @@ public static class EntityModeMappers
             RefundId = entity.RefundId,
             QuoteId = entity.QuoteId,
             Status = entity.Status,
-            ShoppingCartId = entity.ShoppingCartId            
+            ShoppingCartId = entity.ShoppingCartId,
+            DepositRequired = entity.DepositRequired,
+            Requirements = entity.Requirements,
+            Terms = entity.Terms
         };
 
     public static OrderRefund ToModel(this Entities.OrderRefund entity) =>

LiteCharms.Extensions/Postgres.cs

@@ -4,10 +4,10 @@ namespace LiteCharms.Extensions;
 
 public static class Postgres
 {
-    public static IServiceCollection AddLeadGeneratorDatabase(this IServiceCollection services, IConfiguration configuration)
+    public static IServiceCollection AddShopDatabase(this IServiceCollection services, IConfiguration configuration)
     {
-        services.AddPooledDbContextFactory<LeadGeneratorDbContext>(options =>
+        services.AddPooledDbContextFactory<ShopDbContext>(options =>
-            options.UseNpgsql(configuration.GetConnectionString("PostgresLeadGenerator")));
+            options.UseNpgsql(configuration.GetConnectionString("PostgresShop")));
 
         return services;
     }

LiteCharms.Extensions/Quartz.cs

@@ -7,7 +7,7 @@ public static class Quartz
 {
     private const string databaseConfigName = "PostgresScheduler";
 
-    public static IServiceCollection AddQuartzSchedulerClient(this IServiceCollection services, string schedulerName, string schedulerId, IConfiguration configuration)
+    public static IServiceCollection AddQuartzSchedulerClient(this IServiceCollection services, string schedulerName, IConfiguration configuration)
     {
         var connectionString = configuration.GetConnectionString(databaseConfigName);
 
@@ -16,7 +16,7 @@ public static class Quartz
         services.AddQuartz(config =>
         {
             config.SchedulerName = schedulerName;
-            config.SchedulerId = schedulerId;
+            config.SchedulerId = "AUTO";
                         
             config.UseSimpleTypeLoader();
             config.UseDefaultThreadPool(options => options.MaxConcurrency = 0);
@@ -42,7 +42,7 @@ public static class Quartz
         return services;
     }
 
-    public static IServiceCollection AddQuartzScheduler(this IServiceCollection services, string schedulerName, string schedulerId, IConfiguration configuration)
+    public static IServiceCollection AddQuartzScheduler(this IServiceCollection services, string schedulerName, IConfiguration configuration)
     {
         var connectionString = configuration.GetConnectionString(databaseConfigName);
 
@@ -51,7 +51,7 @@ public static class Quartz
         services.AddQuartz(config =>
         {
             config.SchedulerName = schedulerName;
-            config.SchedulerId = schedulerId;
+            config.SchedulerId = "AUTO";
             config.InterruptJobsOnShutdown = true;
             config.InterruptJobsOnShutdownWithWait = true;
             config.MaxBatchSize = 5;
@@ -66,7 +66,7 @@ public static class Quartz
 
                 storage.UseSystemTextJsonSerializer();
                 storage.SetProperty("quartz.jobStore.clustered", "true");
-                storage.SetProperty("quartz.jobStore.tablePrefix", "quartz_");
+                storage.SetProperty("quartz.jobStore.tablePrefix", "qrtz_");
 
                 storage.UsePostgres(connectionString!);
                 storage.UseClustering(cluster =>

LiteCharms.Features/CartPackages/Commands/AddPackageItemsCommand.cs

@@ -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);
+    }
+}

LiteCharms.Features/CartPackages/Commands/CreatePackageCommand.cs

@@ -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);
+    }
+}

LiteCharms.Features/CartPackages/Commands/DeletePackageCommand.cs

@@ -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);
+    }
+}

LiteCharms.Features/CartPackages/Commands/DeletePackageItemsCommand.cs

@@ -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);
+    }
+}

LiteCharms.Features/CartPackages/Commands/Handlers/AddPackageItemCommandHandler.cs

@@ -0,0 +1,38 @@
+using LiteCharms.Infrastructure.Database;
+
+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));
+        }
+    }
+}

LiteCharms.Features/CartPackages/Commands/Handlers/CreatePackageCommandHandler.cs

@@ -0,0 +1,32 @@
+using LiteCharms.Infrastructure.Database;
+
+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));
+        }
+    }
+}

LiteCharms.Features/CartPackages/Commands/Handlers/DeletePackageItemCommandHandler.cs

@@ -0,0 +1,32 @@
+using LiteCharms.Infrastructure.Database;
+
+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));
+        }
+    }
+}

LiteCharms.Features/CartPackages/Commands/Handlers/DeletePackageItemsCommandHandler.cs

@@ -0,0 +1,29 @@
+using LiteCharms.Infrastructure.Database;
+
+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));
+        }
+    }
+}

LiteCharms.Features/CartPackages/Commands/Handlers/UpdatePackageCommandHandler.cs

@@ -0,0 +1,33 @@
+using LiteCharms.Infrastructure.Database;
+
+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));
+        }
+    }
+}

LiteCharms.Features/CartPackages/Commands/Handlers/UpdatePackageStatusCommandHandler.cs

@@ -0,0 +1,29 @@
+using LiteCharms.Infrastructure.Database;
+
+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));
+        }
+    }
+}

LiteCharms.Features/CartPackages/Commands/UpdatePackageCommand.cs

@@ -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);
+    }
+}

LiteCharms.Features/CartPackages/Commands/UpdatePackageStatusCommand.cs

@@ -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);
+    }
+}

LiteCharms.Features/CartPackages/Queries/GetPackageItemsQuery.cs

@@ -0,0 +1,18 @@
+using LiteCharms.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);
+    }
+}

LiteCharms.Features/CartPackages/Queries/GetPackageQuery.cs

@@ -0,0 +1,18 @@
+using LiteCharms.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);
+    }
+}

LiteCharms.Features/CartPackages/Queries/GetPackagesQuery.cs

@@ -0,0 +1,33 @@
+using LiteCharms.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);
+    }
+}

LiteCharms.Features/CartPackages/Queries/Handlers/GetPackageItemsQueryHandler.cs

@@ -0,0 +1,32 @@
+using LiteCharms.Extensions;
+using LiteCharms.Infrastructure.Database;
+using LiteCharms.Models;
+
+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));
+        }
+    }
+}

LiteCharms.Features/CartPackages/Queries/Handlers/GetPackageQueryHandler.cs

@@ -0,0 +1,27 @@
+using LiteCharms.Extensions;
+using LiteCharms.Infrastructure.Database;
+using LiteCharms.Models;
+
+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));
+        }
+    }
+}

LiteCharms.Features/CartPackages/Queries/Handlers/GetPackagesQueryHandler.cs

@@ -0,0 +1,35 @@
+using LiteCharms.Extensions;
+using LiteCharms.Infrastructure.Database;
+using LiteCharms.Models;
+
+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));
+        }
+    }
+}

LiteCharms.Features/Customers/Commands/Handlers/CreateCustomerCommandHandler.cs

@@ -2,7 +2,7 @@
 
 namespace LiteCharms.Features.Customers.Commands.Handlers;
 
-public class CreateCustomerCommandHandler(IDbContextFactory<LeadGeneratorDbContext> contextFactory) : IRequestHandler<CreateCustomerCommand, Result<Guid>>
+public class CreateCustomerCommandHandler(IDbContextFactory<ShopDbContext> contextFactory) : IRequestHandler<CreateCustomerCommand, Result<Guid>>
 {
     public async ValueTask<Result<Guid>> Handle(CreateCustomerCommand request, CancellationToken cancellationToken)
     {

LiteCharms.Features/Customers/Commands/Handlers/UpdateCustomerCommandHandler.cs

@@ -2,7 +2,7 @@
 
 namespace LiteCharms.Features.Customers.Commands.Handlers;
 
-public class UpdateCustomerCommandHandler(IDbContextFactory<LeadGeneratorDbContext> contextFactory) : IRequestHandler<UpdateCustomerCommand, Result>
+public class UpdateCustomerCommandHandler(IDbContextFactory<ShopDbContext> contextFactory) : IRequestHandler<UpdateCustomerCommand, Result>
 {
     public async ValueTask<Result> Handle(UpdateCustomerCommand request, CancellationToken cancellationToken)
     {

LiteCharms.Features/Customers/Queries/Handlers/GetCustomerQueryHandler.cs

@@ -4,7 +4,7 @@ using LiteCharms.Models;
 
 namespace LiteCharms.Features.Customers.Queries.Handlers;
 
-public class GetCustomerQueryHandler(IDbContextFactory<LeadGeneratorDbContext> contextFactory) : IRequestHandler<GetCustomerQuery, Result<Customer>>
+public class GetCustomerQueryHandler(IDbContextFactory<ShopDbContext> contextFactory) : IRequestHandler<GetCustomerQuery, Result<Customer>>
 {
     public async ValueTask<Result<Customer>> Handle(GetCustomerQuery request, CancellationToken cancellationToken)
     {

LiteCharms.Features/Customers/Queries/Handlers/GetCustomersQueryHandler.cs

@@ -4,7 +4,7 @@ using LiteCharms.Models;
 
 namespace LiteCharms.Features.Customers.Queries.Handlers;
 
-public class GetCustomersQueryHandler(IDbContextFactory<LeadGeneratorDbContext> contextFactory) : IRequestHandler<GetCustomersQuery, Result<Customer[]>>
+public class GetCustomersQueryHandler(IDbContextFactory<ShopDbContext> contextFactory) : IRequestHandler<GetCustomersQuery, Result<Customer[]>>
 {
     public async ValueTask<Result<Customer[]>> Handle(GetCustomersQuery request, CancellationToken cancellationToken)
     {

LiteCharms.Features/Email/Commands/Handlers/SendEmailCommandHandler.cs

@@ -1,6 +1,7 @@
-using LiteCharms.Models.Configuraton.Email;
+using LiteCharms.Features.Email.Commands;
+using LiteCharms.Models.Configuraton.Email;
 
-namespace LiteCharms.Features.Utilities.Commands.Handlers;
+namespace LiteCharms.Features.Email.Commands.Handlers;
 
 public class SendEmailCommandHandler(IOptions<SmtpSettings> smtpOptions) : IRequestHandler<SendEmailCommand, Result>
 {

LiteCharms.Features/Email/Commands/SendEmailCommand.cs

@@ -1,4 +1,4 @@
-namespace LiteCharms.Features.Utilities.Commands;
+namespace LiteCharms.Features.Email.Commands;
 
 public class SendEmailCommand : IRequest<Result>
 {

LiteCharms.Features/Email/Events/Handlers/SendShopEmailEnquiryEventHandler.cs

@@ -0,0 +1,18 @@
+using LiteCharms.Features.Notifications.Commands;
+using static LiteCharms.Abstractions.Constants;
+
+namespace LiteCharms.Features.Email.Events.Handlers;
+
+public class SendShopEmailEnquiryEventHandler(ISender mediator) : 
+    INotificationHandler<SendShopEmailEnquiryEvent>
+{
+    public async ValueTask Handle(SendShopEmailEnquiryEvent notification, CancellationToken cancellationToken)
+    {
+        var command = CreateNotificationCommand.Create(Models.NotificationDirection.Outgoing, notification.SenderName!,
+            notification.SenderAddress!, notification.Subject!, notification.Message!, Models.NotificationPlatforms.Email,
+            notification.Priority, ShopEmailFromName, ShopEmailFromAddress, Guid.CreateVersion7().ToString(),
+            Models.CorrelationIdTypes.None, isInternal: true, isHtml: false);
+
+        await mediator.Send(command, cancellationToken);
+    }
+}

LiteCharms.Features/Email/Events/SendShopEmailEnquiryEvent.cs

@@ -0,0 +1,40 @@
+using LiteCharms.Abstractions;
+using LiteCharms.Models;
+
+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);
+    }
+}

LiteCharms.Features/Leads/Commands/Handlers/CreateLeadCommandHandler.cs

@@ -1,9 +1,9 @@
-using LiteCharms.Features.Utilities.Commands;
+using LiteCharms.Features.Utilities.Hash.Commands;
 using LiteCharms.Infrastructure.Database;
 
 namespace LiteCharms.Features.Leads.Commands.Handlers;
 
-public class CreateLeadCommandHandler(IDbContextFactory<LeadGeneratorDbContext> contextFactory, ISender mediator) : IRequestHandler<CreateLeadCommand, Result<Guid>>
+public class CreateLeadCommandHandler(IDbContextFactory<ShopDbContext> contextFactory, ISender mediator) : IRequestHandler<CreateLeadCommand, Result<Guid>>
 {
     public async ValueTask<Result<Guid>> Handle(CreateLeadCommand request, CancellationToken cancellationToken)
     {

LiteCharms.Features/Leads/Commands/Handlers/UpdateLeadCommandHandler.cs

@@ -2,7 +2,7 @@
 
 namespace LiteCharms.Features.Leads.Commands.Handlers;
 
-public class UpdateLeadCommandHandler(IDbContextFactory<LeadGeneratorDbContext> contextFactory) : IRequestHandler<UpdateLeadCommand, Result>
+public class UpdateLeadCommandHandler(IDbContextFactory<ShopDbContext> contextFactory) : IRequestHandler<UpdateLeadCommand, Result>
 {
     public async ValueTask<Result> Handle(UpdateLeadCommand request, CancellationToken cancellationToken)
     {

LiteCharms.Features/Leads/Queries/Handlers/GetCustomerLeadsQueryHandler.cs

@@ -4,7 +4,7 @@ using LiteCharms.Models;
 
 namespace LiteCharms.Features.Leads.Queries.Handlers;
 
-public class GetCustomerLeadsQueryHandler(IDbContextFactory<LeadGeneratorDbContext> contextFactory) : IRequestHandler<GetCustomerLeadsQuery, Result<Lead[]>>
+public class GetCustomerLeadsQueryHandler(IDbContextFactory<ShopDbContext> contextFactory) : IRequestHandler<GetCustomerLeadsQuery, Result<Lead[]>>
 {
     public async ValueTask<Result<Lead[]>> Handle(GetCustomerLeadsQuery request, CancellationToken cancellationToken)
     {

LiteCharms.Features/Leads/Queries/Handlers/GetLeadsQueryHandler.cs

@@ -4,7 +4,7 @@ using LiteCharms.Models;
 
 namespace LiteCharms.Features.Leads.Queries.Handlers;
 
-public class GetLeadsQueryHandler(IDbContextFactory<LeadGeneratorDbContext> contextFactory) : IRequestHandler<GetLeadsQuery, Result<Lead[]>>
+public class GetLeadsQueryHandler(IDbContextFactory<ShopDbContext> contextFactory) : IRequestHandler<GetLeadsQuery, Result<Lead[]>>
 {
     public async ValueTask<Result<Lead[]>> Handle(GetLeadsQuery request, CancellationToken cancellationToken)
     {

LiteCharms.Features/LiteCharms.Features.csproj

@@ -54,6 +54,7 @@
     <Using Include="System.Security.Cryptography" />
     <Using Include="Microsoft.EntityFrameworkCore" />
     <Using Include="Microsoft.Extensions.Options" />
+    <Using Include="Microsoft.Extensions.Logging" />
   </ItemGroup>
 
   <ItemGroup>    

LiteCharms.Features/Notifications/Commands/CreateNotificationCommand.cs

@@ -6,58 +6,67 @@ public class CreateNotificationCommand : IRequest<Result<Guid>>
 {
     public NotificationDirection Direction { get; set; }
 
-    public string? Author { get; set; }
+    public string? Sender { get; set; }
 
-    public string? Title { get; set; }
+    public string? SenderAddress { get; set; }
 
-    public string? Description { get; set; }
+    public string? Subject { get; set; }
 
-    public string? Platform { get; set; }
+    public string? Message { get; set; }
 
-    public string? PlatformAddress { get; set; }
+    public NotificationPlatforms Platform { get; set; }
+
+    public Priorities Priority { get; set; }
+
+    public string? Recipient { get; set; }
+
+    public string? RecipientAddress { get; set; }
 
     public string? CorrelationId { get; set; }
 
-    public string? CorrelationIdType { get; set; }
+    public CorrelationIdTypes 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)
+    public bool IsHtml { get; set; }
+
+    private CreateNotificationCommand(NotificationDirection direction, string sender, string senderAddress, string subject, string message, NotificationPlatforms platform, Priorities priority, string recipient, string recipientAddress, string correlationId, CorrelationIdTypes correlationIdType, bool isInternal, bool isHtml = false)
     {
         Direction = direction;
-        Author = author;
+        Sender = sender;
-        Title = title;
+        SenderAddress = senderAddress;
-        Description = description;
+        Subject = subject;
+        Message = message;
         Platform = platform;
-        PlatformAddress = platformAddress;
+        Priority = priority;
+        Recipient = recipient;
+        RecipientAddress = recipientAddress;
         CorrelationId = correlationId;
         CorrelationIdType = correlationIdType;
         IsInternal = isInternal;
+        IsHtml = isHtml;
     }
 
-    public static CreateNotificationCommand Create(NotificationDirection direction, string author, string title, string description, string platform, string platformAddress, string correlationId, string correlationIdType, bool isInternal)
+    public static CreateNotificationCommand Create(NotificationDirection direction, string sender, string senderAddress, string subject, string message, NotificationPlatforms platform, Priorities priority, string recipient, string recipientAddress, string correlationId, CorrelationIdTypes correlationIdType, bool isInternal, bool isHtml = false)
     {
-        if (string.IsNullOrWhiteSpace(author))
+        if (string.IsNullOrWhiteSpace(sender))
-            throw new ArgumentException("Author cannot be null or whitespace.", nameof(author));
+            throw new ArgumentException("Sender name is required.", nameof(sender));
 
-        if (string.IsNullOrWhiteSpace(title))
+        if (string.IsNullOrWhiteSpace(subject))
-            throw new ArgumentException("Title cannot be null or whitespace.", nameof(title));
+            throw new ArgumentException("Subject is required.", nameof(subject));
 
-        if (string.IsNullOrWhiteSpace(description))
+        if (string.IsNullOrWhiteSpace(message))
-            throw new ArgumentException("Description cannot be null or whitespace.", nameof(description));
+            throw new ArgumentException("Message is required.", nameof(message));
 
-        if (string.IsNullOrWhiteSpace(platform))
+        if (string.IsNullOrWhiteSpace(recipient))
-            throw new ArgumentException("Platform cannot be null or whitespace.", nameof(platform));
+            throw new ArgumentException("Recipient name is required.", nameof(recipient));
 
-        if (string.IsNullOrWhiteSpace(platformAddress))
+        if (string.IsNullOrWhiteSpace(recipientAddress))
-            throw new ArgumentException("PlatformAddress cannot be null or whitespace.", nameof(platformAddress));
+            throw new ArgumentException("Recipient address is required.", nameof(recipientAddress));
 
         if (string.IsNullOrWhiteSpace(correlationId))
-            throw new ArgumentException("CorrelationId cannot be null or whitespace.", nameof(correlationId));
+            throw new ArgumentException("CorrelationId is required.", nameof(correlationId));
 
-        if (string.IsNullOrWhiteSpace(correlationIdType))
+        return new(direction, sender, senderAddress, subject, message, platform, priority, recipient, recipientAddress, correlationId, correlationIdType, isInternal, isHtml);
-            throw new ArgumentException("CorrelationIdType cannot be null or whitespace.", nameof(correlationIdType));
-
-        return new(direction, author, title, description, platform, platformAddress, correlationId, correlationIdType, isInternal);
     }
 }

LiteCharms.Features/Notifications/Commands/Handlers/CreateNotificationCommandHandler.cs

@@ -2,33 +2,38 @@
 
 namespace LiteCharms.Features.Notifications.Commands.Handlers;
 
-public class CreateNotificationCommandHandler(IDbContextFactory<LeadGeneratorDbContext> contextFactory) : IRequestHandler<CreateNotificationCommand, Result<Guid>>
+public class CreateNotificationCommandHandler(IDbContextFactory<ShopDbContext> contextFactory) : IRequestHandler<CreateNotificationCommand, Result<Guid>>
 {
     public async ValueTask<Result<Guid>> Handle(CreateNotificationCommand request, CancellationToken cancellationToken)
     {
-		try
+        try
-		{
+        {
             using var context = await contextFactory.CreateDbContextAsync(cancellationToken);
 
             var newNotification = context.Notifications.Add(new Entities.Notification
             {
                 Direction = request.Direction,
-                Author = request.Author,
+                SenderName = request.Sender,
-                Title = request.Title,
+                Sender = request.SenderAddress,
-                Description = request.Description,
+                Recipient = request.Recipient,
+                RecipientAddress = request.RecipientAddress,
+                Subject = request.Subject,
+                Message = request.Message,
                 Platform = request.Platform,
-                PlatformAddress = request.PlatformAddress,
+                Priority = request.Priority,
                 CorrelationId = request.CorrelationId,
                 CorrelationIdType = request.CorrelationIdType,
                 IsInternal = request.IsInternal,
+                IsHtml = request.IsHtml,
+                Processed = false
             });
 
-            return newNotification is not null 
+            return newNotification is not null
-                ? Result.Ok(newNotification.Entity.Id) 
+                ? Result.Ok(newNotification.Entity.Id)
                 : Result.Fail(new Error("Failed to create notification"));
         }
-		catch (Exception ex)
+        catch (Exception ex)
-		{
+        {
             return Result.Fail(new Error(ex.Message).CausedBy(ex));
         }
     }

LiteCharms.Features/Notifications/Commands/Handlers/UpdateNotificationCommandHandler.cs

@@ -2,7 +2,7 @@
 
 namespace LiteCharms.Features.Notifications.Commands.Handlers;
 
-public class UpdateNotificationCommandHandler(IDbContextFactory<LeadGeneratorDbContext> contextFactory) : IRequestHandler<UpdateNotificationCommand, Result>
+public class UpdateNotificationCommandHandler(IDbContextFactory<ShopDbContext> contextFactory) : IRequestHandler<UpdateNotificationCommand, Result>
 {
     public async ValueTask<Result> Handle(UpdateNotificationCommand request, CancellationToken cancellationToken)
     {
@@ -17,6 +17,12 @@ public class UpdateNotificationCommandHandler(IDbContextFactory<LeadGeneratorDbC
 
             notification.Processed = request.Processed;
 
+            if (request.HasError)
+            {
+                notification.HasError = request.HasError;
+                notification.Errors = request.Errors; 
+            }
+
             return await context.SaveChangesAsync(cancellationToken) > 0
                 ? Result.Ok()
                 : Result.Fail(new Error($"Failed to update notification with id {request.NotificationId}."));

LiteCharms.Features/Notifications/Commands/UpdateNotificationCommand.cs

@@ -6,13 +6,19 @@ public class UpdateNotificationCommand : IRequest<Result>
 
     public bool Processed { get; set; }
 
-    private UpdateNotificationCommand(Guid notificationId, bool processed)
+    public bool HasError { get; set; }
+
+    public string[]? Errors { get; set; }
+
+    private UpdateNotificationCommand(Guid notificationId, bool processed, bool hasError = false, string[]? errors = null)
     {
         NotificationId = notificationId;
         Processed = processed;
+        HasError = hasError;
+        Errors = errors;
     }
 
-    public static UpdateNotificationCommand Create(Guid notificationId, bool processed) 
+    public static UpdateNotificationCommand Create(Guid notificationId, bool processed, bool hasError = false, string[]? errors = null) 
     { 
         if(notificationId == Guid.Empty)
             throw new ArgumentException("Notification ID cannot be empty.", nameof(notificationId));

LiteCharms.Features/Notifications/Events/Handlers/ProcessEmailNotificationsEventHandler.cs

@@ -0,0 +1,70 @@
+using LiteCharms.Features.Email.Commands;
+using LiteCharms.Infrastructure.Database;
+using static LiteCharms.Abstractions.Constants;
+
+namespace LiteCharms.Features.Notifications.Events.Handlers;
+
+public class ProcessEmailNotificationsEventHandler(IDbContextFactory<ShopDbContext> contextFactory, ILogger<ProcessEmailNotificationsEvent> logger, ISender mediator) :
+    INotificationHandler<ProcessEmailNotificationsEvent>
+{
+    public async ValueTask Handle(ProcessEmailNotificationsEvent message, CancellationToken cancellationToken)
+    {
+        try
+        {
+            using var context = await contextFactory.CreateDbContextAsync(cancellationToken);
+
+            var notifications = await context.Notifications
+                .OrderByDescending(o => o.Priority)
+                .ThenBy(o => o.CreatedAt)
+                .Where(n => n.CorrelationIdType == Models.CorrelationIdTypes.Email)
+                .Where(n => n.Direction == Models.NotificationDirection.Outgoing)
+                .Take(message.MaxRecords)
+                .ToListAsync(cancellationToken);
+
+            foreach (var notification in notifications)
+            {
+                var sendResult = await SendEmailAsync(notification, cancellationToken);
+
+                if(sendResult.IsFailed)
+                {
+                    var errors = new List<string>(1000);
+
+                    errors.AddRange(sendResult.Errors.Select(e => e.Message));
+
+                    if (sendResult.Reasons?.Count > 0)
+                        errors.AddRange(sendResult.Reasons.Select(e => e.Message));
+
+                    notification.HasError = true;                    
+                    notification.Errors = [.. errors];
+                }
+
+                notification.Processed = true;
+            }
+
+            await context.SaveChangesAsync(cancellationToken);
+        }
+        catch (Exception ex)
+        {
+            logger.LogError(ex, ex.Message);
+        }
+    }
+
+    private async Task<Result> SendEmailAsync(Entities.Notification notification, CancellationToken cancellationToken = default)
+    {
+        try
+        {
+            var request = SendEmailCommand.Create(notification.Sender!, notification.SenderName!, ShopEmailFromAddress,
+                ShopEmailFromName, notification.Subject!, notification.Message!);
+
+            var result = await mediator.Send(request, cancellationToken);
+
+            return result.IsFailed 
+                ? Result.Fail(result.Errors) 
+                : Result.Ok();
+        }
+        catch (Exception ex)
+        {
+            return Result.Fail(new Error(ex.Message).CausedBy(ex));
+        }
+    }
+}

LiteCharms.Features/Notifications/Events/ProcessEmailNotificationsEvent.cs

@@ -0,0 +1,14 @@
+using LiteCharms.Abstractions;
+
+namespace LiteCharms.Features.Notifications.Events;
+
+public class ProcessEmailNotificationsEvent : EventBase, IEvent
+{
+    public string Name { get; set; } = nameof(ProcessEmailNotificationsEvent);
+
+    public int MaxRecords { get; set; }
+
+    private ProcessEmailNotificationsEvent(int maxRecords = 1000) => MaxRecords = maxRecords;
+
+    public static ProcessEmailNotificationsEvent Create(int maxRecords = 1000) => new(maxRecords);
+}

LiteCharms.Features/Notifications/Queries/Handlers/GetNotificationQueryHandler.cs

@@ -4,7 +4,7 @@ using LiteCharms.Models;
 
 namespace LiteCharms.Features.Notifications.Queries.Handlers;
 
-public class GetNotificationQueryHandler(IDbContextFactory<LeadGeneratorDbContext> contextFactory) : IRequestHandler<GetNotificationQuery, Result<Notification>>
+public class GetNotificationQueryHandler(IDbContextFactory<ShopDbContext> contextFactory) : IRequestHandler<GetNotificationQuery, Result<Notification>>
 {
     public async ValueTask<Result<Notification>> Handle(GetNotificationQuery request, CancellationToken cancellationToken)
     {
@@ -12,7 +12,7 @@ public class GetNotificationQueryHandler(IDbContextFactory<LeadGeneratorDbContex
         {
             await using var context = await contextFactory.CreateDbContextAsync(cancellationToken);
 
-            var notification = await context.Notifications.FindAsync(new object[] { request.NotificationId }, cancellationToken);
+            var notification = await context.Notifications.FirstOrDefaultAsync(n => n.Id == request.NotificationId, cancellationToken);
 
             return notification is not null 
                 ? Result.Ok(notification.ToModel())

LiteCharms.Features/Notifications/Queries/Handlers/GetNotificationsQueryHandler.cs

@@ -4,7 +4,7 @@ using LiteCharms.Models;
 
 namespace LiteCharms.Features.Notifications.Queries.Handlers;
 
-public class GetNotificationsQueryHandler(IDbContextFactory<LeadGeneratorDbContext> contextFactory) : IRequestHandler<GetNotificationsQuery, Result<Notification[]>>
+public class GetNotificationsQueryHandler(IDbContextFactory<ShopDbContext> contextFactory) : IRequestHandler<GetNotificationsQuery, Result<Notification[]>>
 {
     public async ValueTask<Result<Notification[]>> Handle(GetNotificationsQuery request, CancellationToken cancellationToken)
     {

LiteCharms.Features/Orders/Commands/CreateOrderCommand.cs

@@ -8,14 +8,26 @@ public class CreateOrderCommand : IRequest<Result<Guid>>
 
     public Guid? QuoteId { get; set; }
 
-    private CreateOrderCommand(Guid customerId, Guid shoppingCartId, Guid? quoteId = null)
+    public string[]? Requirements { get; set; }
+
+    public string[]? Notes { get; set; }
+
+    public string[]? Terms { get; set; }
+
+    public bool DepositRequired { get; set; }
+
+    private CreateOrderCommand(Guid customerId, Guid shoppingCartId, bool depositRequired, Guid? quoteId = null, string[]? requirements = null, string[]? notes = null, string[]? terms = null)
     {
         CustomerId = customerId;
         ShoppingCartId = shoppingCartId;
+        DepositRequired = depositRequired;
         QuoteId = quoteId;
+        Requirements = requirements;
+        Notes = notes;
+        Terms = terms;
     }
 
-    public static CreateOrderCommand Create(Guid customerId, Guid shoppingCartId, Guid? quoteId = null)
+    public static CreateOrderCommand Create(Guid customerId, Guid shoppingCartId, bool depositRequired, Guid? quoteId = null, string[]? requirements = null, string[]? notes = null, string[]? terms = null)
     {
         if (customerId == Guid.Empty)
             throw new ArgumentException("CustomerId is required.", nameof(customerId));
@@ -23,6 +35,6 @@ public class CreateOrderCommand : IRequest<Result<Guid>>
         if (shoppingCartId == Guid.Empty)
             throw new ArgumentException("ShoppingCartId is required.", nameof(shoppingCartId));
 
-        return new(customerId, shoppingCartId, quoteId);
+        return new(customerId, shoppingCartId, depositRequired, quoteId, requirements, notes, terms);
     }
 }

LiteCharms.Features/Orders/Commands/Handlers/CreateOrderCommandHandler.cs

@@ -1,8 +1,9 @@
 using LiteCharms.Infrastructure.Database;
+using LiteCharms.Models;
 
 namespace LiteCharms.Features.Orders.Commands.Handlers;
 
-public class CreateOrderCommandHandler(IDbContextFactory<LeadGeneratorDbContext> contextFactory) : IRequestHandler<CreateOrderCommand, Result<Guid>>
+public class CreateOrderCommandHandler(IDbContextFactory<ShopDbContext> contextFactory) : IRequestHandler<CreateOrderCommand, Result<Guid>>
 {
     public async ValueTask<Result<Guid>> Handle(CreateOrderCommand request, CancellationToken cancellationToken)
     {
@@ -21,10 +22,15 @@ public class CreateOrderCommandHandler(IDbContextFactory<LeadGeneratorDbContext>
 
             var newOrder = context.Orders.Add(new Entities.Order
             {
+                CreatedAt = DateTime.UtcNow,
+                Status = OrderStatus.Pending,
                 CustomerId = request.CustomerId,
-                ShoppingCartId = request.ShoppingCartId,
                 QuoteId = request.QuoteId,
-                CreatedAt = DateTime.UtcNow
+                ShoppingCartId = request.ShoppingCartId,
+                DepositRequired = request.DepositRequired,
+                Requirements = request.Requirements,
+                Notes = request.Notes,
+                Terms = request.Terms
             });
 
             return await context.SaveChangesAsync(cancellationToken) > 0

LiteCharms.Features/Orders/Commands/Handlers/UpdateOrderStatusCommandHandler.cs

@@ -2,7 +2,7 @@
 
 namespace LiteCharms.Features.Orders.Commands.Handlers;
 
-public class UpdateOrderStatusCommandHandler(IDbContextFactory<LeadGeneratorDbContext> contextFactory) : IRequestHandler<UpdateOrderStatusCommand, Result>
+public class UpdateOrderStatusCommandHandler(IDbContextFactory<ShopDbContext> contextFactory) : IRequestHandler<UpdateOrderStatusCommand, Result>
 {
     public async ValueTask<Result> Handle(UpdateOrderStatusCommand request, CancellationToken cancellationToken)
     {

LiteCharms.Features/Orders/Queries/Handlers/GetCustomerOrdersQueryHandler.cs

@@ -4,7 +4,7 @@ using LiteCharms.Models;
 
 namespace LiteCharms.Features.Orders.Queries.Handlers;
 
-public class GetCustomerOrdersQueryHandler(IDbContextFactory<LeadGeneratorDbContext> contextFactory) : IRequestHandler<GetCustomerOrdersQuery, Result<Order[]>>
+public class GetCustomerOrdersQueryHandler(IDbContextFactory<ShopDbContext> contextFactory) : IRequestHandler<GetCustomerOrdersQuery, Result<Order[]>>
 {
     public async ValueTask<Result<Order[]>> Handle(GetCustomerOrdersQuery request, CancellationToken cancellationToken)
     {

LiteCharms.Features/Orders/Queries/Handlers/GetOrderRefundQueryHandler.cs

@@ -4,7 +4,7 @@ using LiteCharms.Models;
 
 namespace LiteCharms.Features.Orders.Queries.Handlers;
 
-public class GetOrderRefundQueryHandler(IDbContextFactory<LeadGeneratorDbContext> contextFactory) : IRequestHandler<GetOrderRefundQuery, Result<OrderRefund>>
+public class GetOrderRefundQueryHandler(IDbContextFactory<ShopDbContext> contextFactory) : IRequestHandler<GetOrderRefundQuery, Result<OrderRefund>>
 {
     public async ValueTask<Result<OrderRefund>> Handle(GetOrderRefundQuery request, CancellationToken cancellationToken)
     {

LiteCharms.Features/Orders/Queries/Handlers/GetOrdersQueryHandler.cs

@@ -4,7 +4,7 @@ using LiteCharms.Models;
 
 namespace LiteCharms.Features.Orders.Queries.Handlers;
 
-public class GetOrdersQueryHandler(IDbContextFactory<LeadGeneratorDbContext> contextFactory) : IRequestHandler<GetOrdersQuery, Result<Order[]>>
+public class GetOrdersQueryHandler(IDbContextFactory<ShopDbContext> contextFactory) : IRequestHandler<GetOrdersQuery, Result<Order[]>>
 {
     public async ValueTask<Result<Order[]>> Handle(GetOrdersQuery request, CancellationToken cancellationToken)
     {
@@ -16,6 +16,7 @@ public class GetOrdersQueryHandler(IDbContextFactory<LeadGeneratorDbContext> con
             using var context = await contextFactory.CreateDbContextAsync(cancellationToken);
 
             var orders = await context.Orders
+                .AsNoTracking()
                 .OrderByDescending(o => o.CreatedAt)
                 .Where(o => o.CreatedAt >= fromDate && o.CreatedAt <= toDate)
                 .Take(request.MaxRecords)

LiteCharms.Features/Products/Queries/Handlers/GetProductPriceQueryHandler.cs

@@ -4,7 +4,7 @@ using LiteCharms.Models;
 
 namespace LiteCharms.Features.Products.Queries.Handlers;
 
-public class GetProductPriceQueryHandler(IDbContextFactory<LeadGeneratorDbContext> contextFactory) : IRequestHandler<GetProductPriceQuery, Result<ProductPrice>>
+public class GetProductPriceQueryHandler(IDbContextFactory<ShopDbContext> contextFactory) : IRequestHandler<GetProductPriceQuery, Result<ProductPrice>>
 {
     public async ValueTask<Result<ProductPrice>> Handle(GetProductPriceQuery request, CancellationToken cancellationToken)
     {

LiteCharms.Features/Products/Queries/Handlers/GetProductPricesQueryHandler.cs

@@ -4,7 +4,7 @@ using LiteCharms.Models;
 
 namespace LiteCharms.Features.Products.Queries.Handlers;
 
-public class GetProductPricesQueryHandler(IDbContextFactory<LeadGeneratorDbContext> contextFactory) : IRequestHandler<GetProductPricesQuery, Result<ProductPrice[]>>
+public class GetProductPricesQueryHandler(IDbContextFactory<ShopDbContext> contextFactory) : IRequestHandler<GetProductPricesQuery, Result<ProductPrice[]>>
 {
     public async ValueTask<Result<ProductPrice[]>> Handle(GetProductPricesQuery request, CancellationToken cancellationToken)
     {

LiteCharms.Features/Products/Queries/Handlers/GetProductQueryHandler.cs

@@ -4,7 +4,7 @@ using LiteCharms.Models;
 
 namespace LiteCharms.Features.Products.Queries.Handlers;
 
-public class GetProductQueryHandler(IDbContextFactory<LeadGeneratorDbContext> contextFactory) : IRequestHandler<GetProductQuery, Result<Product>>
+public class GetProductQueryHandler(IDbContextFactory<ShopDbContext> contextFactory) : IRequestHandler<GetProductQuery, Result<Product>>
 {
     public async ValueTask<Result<Product>> Handle(GetProductQuery request, CancellationToken cancellationToken)
     {

LiteCharms.Features/Products/Queries/Handlers/GetProductsQueryHandler.cs

@@ -4,7 +4,7 @@ using LiteCharms.Models;
 
 namespace LiteCharms.Features.Products.Queries.Handlers;
 
-public class GetProductsQueryHandler(IDbContextFactory<LeadGeneratorDbContext> contextFactory) : IRequestHandler<GetProductsQuery, Result<Product[]>>
+public class GetProductsQueryHandler(IDbContextFactory<ShopDbContext> contextFactory) : IRequestHandler<GetProductsQuery, Result<Product[]>>
 {
     public async ValueTask<Result<Product[]>> Handle(GetProductsQuery request, CancellationToken cancellationToken)
     {

LiteCharms.Features/Quotes/Commands/Handlers/AssignQuoteToOrderCommandHandler.cs

@@ -2,7 +2,7 @@
 
 namespace LiteCharms.Features.Quotes.Commands.Handlers;
 
-public class AssignQuoteToOrderCommandHandler(IDbContextFactory<LeadGeneratorDbContext> contextFactory) : IRequestHandler<AssignQuoteToOrderCommand, Result>
+public class AssignQuoteToOrderCommandHandler(IDbContextFactory<ShopDbContext> contextFactory) : IRequestHandler<AssignQuoteToOrderCommand, Result>
 {
     public async ValueTask<Result> Handle(AssignQuoteToOrderCommand request, CancellationToken cancellationToken)
     {

LiteCharms.Features/Quotes/Commands/Handlers/AssignQuoteToShoppingCartCommandHandler.cs

@@ -2,7 +2,7 @@
 
 namespace LiteCharms.Features.Quotes.Commands.Handlers;
 
-public class AssignQuoteToShoppingCartCommandHandler(IDbContextFactory<LeadGeneratorDbContext> contextFactory) : IRequestHandler<AssignQuoteToShoppingCartCommand, Result>
+public class AssignQuoteToShoppingCartCommandHandler(IDbContextFactory<ShopDbContext> contextFactory) : IRequestHandler<AssignQuoteToShoppingCartCommand, Result>
 {
     public async ValueTask<Result> Handle(AssignQuoteToShoppingCartCommand request, CancellationToken cancellationToken)
     {

LiteCharms.Features/Quotes/Commands/Handlers/UpdateQuoteStatusCommandHandler.cs

@@ -2,7 +2,7 @@
 
 namespace LiteCharms.Features.Quotes.Commands.Handlers;
 
-public class UpdateQuoteStatusCommandHandler(IDbContextFactory<LeadGeneratorDbContext> contextFactory) : IRequestHandler<UpdateQuoteStatusCommand, Result>
+public class UpdateQuoteStatusCommandHandler(IDbContextFactory<ShopDbContext> contextFactory) : IRequestHandler<UpdateQuoteStatusCommand, Result>
 {
     public async ValueTask<Result> Handle(UpdateQuoteStatusCommand request, CancellationToken cancellationToken)
     {

LiteCharms.Features/Quotes/Queries/Handlers/GetCustomerQuotesQueryHandler.cs

@@ -5,7 +5,7 @@ using LiteCharms.Models;
 
 namespace LiteCharms.Features.Quotes.Queries.Handlers;
 
-public class GetCustomerQuotesQueryHandler(IDbContextFactory<LeadGeneratorDbContext> contextFactory) : IRequestHandler<GetCustomerQuotesQuery, Result<Quote[]>>
+public class GetCustomerQuotesQueryHandler(IDbContextFactory<ShopDbContext> contextFactory) : IRequestHandler<GetCustomerQuotesQuery, Result<Quote[]>>
 {
     public async ValueTask<Result<Quote[]>> Handle(GetCustomerQuotesQuery request, CancellationToken cancellationToken)
     {

LiteCharms.Features/Quotes/Queries/Handlers/GetQuoteQueryHandler.cs

@@ -4,7 +4,7 @@ using LiteCharms.Models;
 
 namespace LiteCharms.Features.Quotes.Queries.Handlers;
 
-public class GetQuoteQueryHandler(IDbContextFactory<LeadGeneratorDbContext> contextFactory) : IRequestHandler<GetQuoteQuery, Result<Quote>>
+public class GetQuoteQueryHandler(IDbContextFactory<ShopDbContext> contextFactory) : IRequestHandler<GetQuoteQuery, Result<Quote>>
 {
     public async ValueTask<Result<Quote>> Handle(GetQuoteQuery request, CancellationToken cancellationToken)
     {

LiteCharms.Features/Quotes/Queries/Handlers/GetQuotesHandler.cs

@@ -4,7 +4,7 @@ using LiteCharms.Models;
 
 namespace LiteCharms.Features.Quotes.Queries.Handlers;
 
-public class GetQuotesHandler(IDbContextFactory<LeadGeneratorDbContext> contextFactory) : IRequestHandler<GetQuotesQuery, Result<Quote[]>>
+public class GetQuotesHandler(IDbContextFactory<ShopDbContext> contextFactory) : IRequestHandler<GetQuotesQuery, Result<Quote[]>>
 {
     public async ValueTask<Result<Quote[]>> Handle(GetQuotesQuery request, CancellationToken cancellationToken)
     {

LiteCharms.Features/Refunds/Commands/Handlers/RefundCustomerCommandHandler.cs

@@ -2,7 +2,7 @@
 
 namespace LiteCharms.Features.Refunds.Commands.Handlers;
 
-public class RefundCustomerCommandHandler(IDbContextFactory<LeadGeneratorDbContext> contextFactory) : IRequestHandler<RefundCustomerCommand, Result<Guid>>
+public class RefundCustomerCommandHandler(IDbContextFactory<ShopDbContext> contextFactory) : IRequestHandler<RefundCustomerCommand, Result<Guid>>
 {
     public async ValueTask<Result<Guid>> Handle(RefundCustomerCommand request, CancellationToken cancellationToken)
     {

LiteCharms.Features/Refunds/Commands/Handlers/UpdateOrderRefundCommandHandler.cs

@@ -2,7 +2,7 @@
 
 namespace LiteCharms.Features.Refunds.Commands.Handlers;
 
-public class UpdateOrderRefundCommandHandler(IDbContextFactory<LeadGeneratorDbContext> contextFactory) : IRequestHandler<UpdateOrderRefundCommand, Result>
+public class UpdateOrderRefundCommandHandler(IDbContextFactory<ShopDbContext> contextFactory) : IRequestHandler<UpdateOrderRefundCommand, Result>
 {
     public async ValueTask<Result> Handle(UpdateOrderRefundCommand request, CancellationToken cancellationToken)
     {

LiteCharms.Features/Refunds/Queries/Handlers/GetCustomerRefundsQueryHandler.cs

@@ -5,7 +5,7 @@ using LiteCharms.Models;
 
 namespace LiteCharms.Features.Refunds.Queries.Handlers;
 
-public class GetCustomerRefundsQueryHandler(IDbContextFactory<LeadGeneratorDbContext> contextFactory) : IRequestHandler<GetCustomerRefundsQuery, Result<OrderRefund[]>>
+public class GetCustomerRefundsQueryHandler(IDbContextFactory<ShopDbContext> contextFactory) : IRequestHandler<GetCustomerRefundsQuery, Result<OrderRefund[]>>
 {
     public async ValueTask<Result<OrderRefund[]>> Handle(GetCustomerRefundsQuery request, CancellationToken cancellationToken)
     {

LiteCharms.Features/Refunds/Queries/Handlers/GetRefundQueryHandler.cs

@@ -4,7 +4,7 @@ using LiteCharms.Models;
 
 namespace LiteCharms.Features.Refunds.Queries.Handlers;
 
-public class GetRefundQueryHandler(IDbContextFactory<LeadGeneratorDbContext> contextFactory) : IRequestHandler<GetRefundQuery, Result<OrderRefund>>
+public class GetRefundQueryHandler(IDbContextFactory<ShopDbContext> contextFactory) : IRequestHandler<GetRefundQuery, Result<OrderRefund>>
 {
     public async ValueTask<Result<OrderRefund>> Handle(GetRefundQuery request, CancellationToken cancellationToken)
     {

LiteCharms.Features/ShoppingCarts/Commands/AddPackageToShoppingCartCommand.cs

@@ -0,0 +1,25 @@
+namespace LiteCharms.Features.ShoppingCarts.Commands;
+
+public class AddPackageToShoppingCartCommand : IRequest<Result>
+{
+    public Guid ShoppingCartId { get; set; }
+
+    public Guid PackageId { get; set; }
+
+    private AddPackageToShoppingCartCommand(Guid shoppingCartId, Guid packageId)
+    {
+        ShoppingCartId = shoppingCartId;
+        PackageId = packageId;
+    }
+
+    public static AddPackageToShoppingCartCommand Create(Guid shoppingCartId, Guid packageId)
+    {
+        if (shoppingCartId == Guid.Empty)
+            throw new ArgumentException($"Shopping cart ID is required", nameof(shoppingCartId));
+
+        if (packageId == Guid.Empty)
+            throw new ArgumentException($"Package ID is required", nameof(packageId));
+
+        return new(shoppingCartId, packageId);
+    }
+}

LiteCharms.Features/ShoppingCarts/Commands/Handlers/AddItemToShoppingCartCommandHandler.cs

@@ -2,7 +2,7 @@
 
 namespace LiteCharms.Features.ShoppingCarts.Commands.Handlers;
 
-public class AddItemToShoppingCartCommandHandler(IDbContextFactory<LeadGeneratorDbContext> contextFactory) : IRequestHandler<AddItemToShoppingCartCommand, Result>
+public class AddItemToShoppingCartCommandHandler(IDbContextFactory<ShopDbContext> contextFactory) : IRequestHandler<AddItemToShoppingCartCommand, Result>
 {
     public async ValueTask<Result> Handle(AddItemToShoppingCartCommand request, CancellationToken cancellationToken)
     {

LiteCharms.Features/ShoppingCarts/Commands/Handlers/AddPackageToShoppingCartCommandHandler.cs

@@ -0,0 +1,39 @@
+using LiteCharms.Infrastructure.Database;
+
+namespace LiteCharms.Features.ShoppingCarts.Commands.Handlers;
+
+public class AddPackageToShoppingCartCommandHandler(IDbContextFactory<ShopDbContext> contextFactory) : IRequestHandler<AddPackageToShoppingCartCommand, Result>
+{
+    public async ValueTask<Result> Handle(AddPackageToShoppingCartCommand 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($"Package cold not be found by ID {request.PackageId}");
+
+            var shoppingCart = await context.ShoppingCarts.FirstOrDefaultAsync(c => c.Id == request.ShoppingCartId, cancellationToken);
+
+            if (shoppingCart is null)
+                return Result.Fail($"Shopping cart could not be found by ID {request.ShoppingCartId}");
+
+            if (!await context.ShoppingCartPackages.AnyAsync(cp => cp.ShoppingCartId == request.ShoppingCartId, cancellationToken))
+                return Result.Fail($"Package {request.PackageId} is already in the cart");
+
+            var newShoppingCartPackage = context.ShoppingCartPackages.Add(new Entities.ShoppingCartPackage
+            {
+                ShoppingCartId = request.ShoppingCartId,
+                PackageId = request.PackageId
+            });
+
+            return await context.SaveChangesAsync(cancellationToken) > 0
+                ? Result.Ok()
+                : Result.Fail($"Could not add package of id {request.PackageId} to shopping cart {request.ShoppingCartId}");
+        }
+        catch (Exception ex)
+        {
+            return Result.Fail(new Error(ex.Message).CausedBy(ex));
+        }
+    }
+}

LiteCharms.Features/ShoppingCarts/Commands/Handlers/CreateShoppingCartCommandHandler.cs

@@ -2,7 +2,7 @@
 
 namespace LiteCharms.Features.ShoppingCarts.Commands.Handlers;
 
-public class CreateShoppingCartCommandHandler(IDbContextFactory<LeadGeneratorDbContext> contextFactory) : IRequestHandler<CreateShoppingCartCommand, Result<Guid>>
+public class CreateShoppingCartCommandHandler(IDbContextFactory<ShopDbContext> contextFactory) : IRequestHandler<CreateShoppingCartCommand, Result<Guid>>
 {
     public async ValueTask<Result<Guid>> Handle(CreateShoppingCartCommand request, CancellationToken cancellationToken)
     {

LiteCharms.Features/ShoppingCarts/Commands/Handlers/EmptyShoppingCartCommandHandler.cs

@@ -2,7 +2,7 @@
 
 namespace LiteCharms.Features.ShoppingCarts.Commands.Handlers;
 
-public class EmptyShoppingCartCommandHandler(IDbContextFactory<LeadGeneratorDbContext> contextFactory) : IRequestHandler<EmptyShoppingCartCommand, Result>
+public class EmptyShoppingCartCommandHandler(IDbContextFactory<ShopDbContext> contextFactory) : IRequestHandler<EmptyShoppingCartCommand, Result>
 {
     public async ValueTask<Result> Handle(EmptyShoppingCartCommand request, CancellationToken cancellationToken)
     {

LiteCharms.Features/ShoppingCarts/Commands/Handlers/RemovePackageFromShoppingCartCommandHandler.cs

@@ -0,0 +1,35 @@
+using LiteCharms.Infrastructure.Database;
+
+namespace LiteCharms.Features.ShoppingCarts.Commands.Handlers;
+
+public class RemovePackageFromShoppingCartCommandHandler(IDbContextFactory<ShopDbContext> contextFactory) : IRequestHandler<RemovePackageFromShoppingCartCommand, Result>
+{
+    public async ValueTask<Result> Handle(RemovePackageFromShoppingCartCommand request, CancellationToken cancellationToken)
+    {
+        try
+        {
+            using var context = await contextFactory.CreateDbContextAsync(cancellationToken);
+
+            if (!await context.ShoppingCarts.AnyAsync(c => c.Id == request.ShoppingCartId, cancellationToken))
+                return Result.Fail($"Shopping cart could not be found by ID {request.ShoppingCartId}");
+
+            if (!await context.ShoppingCartPackages.AnyAsync(p => p.Id == request.ShoppingCartPackageId, cancellationToken))
+                return Result.Fail($"Shopping cart package {request.ShoppingCartPackageId} is not in the shopping cart {request.ShoppingCartId}");
+
+            var shoppingCartPackage = await context.ShoppingCartPackages.FirstOrDefaultAsync(cp => cp.Id == request.ShoppingCartPackageId, cancellationToken);
+
+            if (shoppingCartPackage is null)
+                return Result.Ok();
+
+            context.ShoppingCartPackages.Remove(shoppingCartPackage!);
+
+            return await context.SaveChangesAsync(cancellationToken) > 0
+                ? Result.Ok()
+                : Result.Fail($"Could remove package of id {request.ShoppingCartPackageId} from shopping cart {request.ShoppingCartId}");
+        }
+        catch (Exception ex)
+        {
+            return Result.Fail(new Error(ex.Message).CausedBy(ex));
+        }
+    }
+}

LiteCharms.Features/ShoppingCarts/Commands/Handlers/RemoveShoppingCartItemCommandHandler.cs

@@ -2,7 +2,7 @@
 
 namespace LiteCharms.Features.ShoppingCarts.Commands.Handlers;
 
-public class RemoveShoppingCartItemCommandHandler(IDbContextFactory<LeadGeneratorDbContext> contextFactory) : IRequestHandler<RemoveShoppingCartItemCommand, Result>
+public class RemoveShoppingCartItemCommandHandler(IDbContextFactory<ShopDbContext> contextFactory) : IRequestHandler<RemoveShoppingCartItemCommand, Result>
 {
     public async ValueTask<Result> Handle(RemoveShoppingCartItemCommand request, CancellationToken cancellationToken)
     {

LiteCharms.Features/ShoppingCarts/Commands/Handlers/UpdateShoppingCartItemCommandHandler.cs

@@ -2,7 +2,7 @@
 
 namespace LiteCharms.Features.ShoppingCarts.Commands.Handlers;
 
-public class UpdateShoppingCartItemCommandHandler(IDbContextFactory<LeadGeneratorDbContext> contextFactory) : IRequestHandler<UpdateShoppingCartItemCommand, Result>
+public class UpdateShoppingCartItemCommandHandler(IDbContextFactory<ShopDbContext> contextFactory) : IRequestHandler<UpdateShoppingCartItemCommand, Result>
 {
     public async ValueTask<Result> Handle(UpdateShoppingCartItemCommand request, CancellationToken cancellationToken)
     {

LiteCharms.Features/ShoppingCarts/Commands/RemovePackageFromShoppingCartCommand.cs

@@ -0,0 +1,25 @@
+namespace LiteCharms.Features.ShoppingCarts.Commands;
+
+public class RemovePackageFromShoppingCartCommand : IRequest<Result>
+{
+    public Guid ShoppingCartId { get; set; }
+
+    public Guid ShoppingCartPackageId { get; set; }
+
+    private RemovePackageFromShoppingCartCommand(Guid shoppingCartId, Guid shoppingCartPackageId)
+    {
+        ShoppingCartId = shoppingCartId;
+        ShoppingCartPackageId = shoppingCartPackageId;
+    }
+
+    public static RemovePackageFromShoppingCartCommand Create(Guid shoppingCartId, Guid shoppingCartPackageId)
+    {
+        if (shoppingCartId == Guid.Empty)
+            throw new ArgumentException($"Shopping cart ID is required", nameof(shoppingCartId));
+
+        if (shoppingCartPackageId == Guid.Empty)
+            throw new ArgumentException($"Shopping cart Package ID is required", nameof(shoppingCartPackageId));
+
+        return new(shoppingCartId, shoppingCartPackageId);
+    }
+}

LiteCharms.Features/ShoppingCarts/Queries/GetShoppingCartPackagesQuery.cs

@@ -0,0 +1,18 @@
+using LiteCharms.Models;
+
+namespace LiteCharms.Features.ShoppingCarts.Queries;
+
+public class GetShoppingCartPackagesQuery : IRequest<Result<ShoppingCartPackage[]>>
+{
+    public Guid ShoppingCartId { get; set; }
+
+    private GetShoppingCartPackagesQuery(Guid shoppingCartId) => ShoppingCartId = shoppingCartId;
+
+    public static GetShoppingCartPackagesQuery Create(Guid shoppingCartId)
+    {
+        if (shoppingCartId == Guid.Empty)
+            throw new ArgumentException("Shopping cart id is required", nameof(shoppingCartId));
+
+        return new(shoppingCartId);
+    }
+}

LiteCharms.Features/ShoppingCarts/Queries/Handlers/GetCustomerShoppingCartsQueryHandler.cs

@@ -5,7 +5,7 @@ using LiteCharms.Models;
 
 namespace LiteCharms.Features.ShoppingCarts.Queries.Handlers;
 
-public class GetCustomerShoppingCartsQueryHandler(IDbContextFactory<LeadGeneratorDbContext> contextFactory) : IRequestHandler<GetCustomerShoppingCartsQuery, Result<ShoppingCart[]>>
+public class GetCustomerShoppingCartsQueryHandler(IDbContextFactory<ShopDbContext> contextFactory) : IRequestHandler<GetCustomerShoppingCartsQuery, Result<ShoppingCart[]>>
 {
     public async ValueTask<Result<ShoppingCart[]>> Handle(GetCustomerShoppingCartsQuery request, CancellationToken cancellationToken)
     {

LiteCharms.Features/ShoppingCarts/Queries/Handlers/GetShoppingCartItemsQueryHandler.cs

@@ -4,7 +4,7 @@ using LiteCharms.Models;
 
 namespace LiteCharms.Features.ShoppingCarts.Queries.Handlers;
 
-public class GetShoppingCartItemsQueryHandler(IDbContextFactory<LeadGeneratorDbContext> contextFactory) : IRequestHandler<GetShoppingCartItemsQuery, Result<ShoppingCartItem[]>>
+public class GetShoppingCartItemsQueryHandler(IDbContextFactory<ShopDbContext> contextFactory) : IRequestHandler<GetShoppingCartItemsQuery, Result<ShoppingCartItem[]>>
 {
     public async ValueTask<Result<ShoppingCartItem[]>> Handle(GetShoppingCartItemsQuery request, CancellationToken cancellationToken)
     {

LiteCharms.Features/ShoppingCarts/Queries/Handlers/GetShoppingCartPackagesQueryHandler.cs

@@ -0,0 +1,32 @@
+using LiteCharms.Extensions;
+using LiteCharms.Infrastructure.Database;
+using LiteCharms.Models;
+
+namespace LiteCharms.Features.ShoppingCarts.Queries.Handlers;
+
+public class GetShoppingCartPackagesQueryHandler(IDbContextFactory<ShopDbContext> contextFactory) : IRequestHandler<GetShoppingCartPackagesQuery, Result<ShoppingCartPackage[]>>
+{
+    public async ValueTask<Result<ShoppingCartPackage[]>> Handle(GetShoppingCartPackagesQuery request, CancellationToken cancellationToken)
+    {
+        try
+        {
+            using var context = await contextFactory.CreateDbContextAsync(cancellationToken);
+
+            if (!await context.ShoppingCarts.AnyAsync(c => c.Id == request.ShoppingCartId, cancellationToken))
+                return Result.Fail($"Shopping cart could not be found by ID {request.ShoppingCartId}");
+
+            var packages = await context.ShoppingCartPackages.AsNoTracking()
+                .OrderByDescending(o => o.CreatedAt)
+                .Where(cp => cp.ShoppingCartId == request.ShoppingCartId)
+                .ToArrayAsync(cancellationToken);
+
+            return packages?.Length > 0
+                ? Result.Ok(packages.Select(p => p.ToModel()).ToArray())
+                : Result.Fail($"Could not find packaged in shopping cart by ID {request.ShoppingCartId}");
+        }
+        catch (Exception ex)
+        {
+            return Result.Fail<ShoppingCartPackage[]>(new Error(ex.Message).CausedBy(ex));
+        }
+    }
+}

LiteCharms.Features/ShoppingCarts/Queries/Handlers/GetShoppingCartQueryHandler.cs

@@ -4,7 +4,7 @@ using LiteCharms.Models;
 
 namespace LiteCharms.Features.ShoppingCarts.Queries.Handlers;
 
-public class GetShoppingCartQueryHandler(IDbContextFactory<LeadGeneratorDbContext> contextFactory) : IRequestHandler<GetShoppingCartQuery, Result<ShoppingCart>>
+public class GetShoppingCartQueryHandler(IDbContextFactory<ShopDbContext> contextFactory) : IRequestHandler<GetShoppingCartQuery, Result<ShoppingCart>>
 {
     public async ValueTask<Result<ShoppingCart>> Handle(GetShoppingCartQuery request, CancellationToken cancellationToken)
     {

LiteCharms.Features/Utilities/Hash/Commands/ComputeHashCommand.cs

@@ -1,4 +1,4 @@
-namespace LiteCharms.Features.Utilities.Commands;
+namespace LiteCharms.Features.Utilities.Hash.Commands;
 
 public class ComputeHashCommand : IRequest<Result<string>>
 {

LiteCharms.Features/Utilities/Hash/Commands/Handlers/ComputeHashCommandHandler.cs

@@ -1,4 +1,6 @@
-namespace LiteCharms.Features.Utilities.Commands.Handlers;
+using LiteCharms.Features.Utilities.Hash.Commands;
+
+namespace LiteCharms.Features.Utilities.Hash.Commands.Handlers;
 
 public class ComputeHashCommandHandler : IRequestHandler<ComputeHashCommand, Result<string>>
 {

LiteCharms.Infrastructure/Database/LeadGeneratorDbContextFactory.cs

@@ -1,19 +0,0 @@
-namespace LiteCharms.Infrastructure.Database;
-
-public class LeadGeneratorDbContextFactory : IDesignTimeDbContextFactory<LeadGeneratorDbContext>
-{
-    public LeadGeneratorDbContext CreateDbContext(string[] args)
-    {
-        var configuration = new ConfigurationBuilder()
-            .SetBasePath(Directory.GetCurrentDirectory())
-            .AddUserSecrets(typeof(LeadGeneratorDbContext).Assembly)
-            .AddJsonFile("appsettings.json")
-            .AddEnvironmentVariables()
-            .Build();
-
-        var optionsBuilder = new DbContextOptionsBuilder<LeadGeneratorDbContext>();
-        optionsBuilder.UseNpgsql(configuration.GetConnectionString("PostgresLeadGenerator"));
-
-        return new LeadGeneratorDbContext(optionsBuilder.Options);
-    }
-}

LiteCharms.Infrastructure/Database/Migrations/20260502231708_Init.Designer.cs

@@ -1,272 +0,0 @@
-// <auto-generated />
-using System;
-using LiteCharms.Infrastructure.Database;
-using Microsoft.EntityFrameworkCore;
-using Microsoft.EntityFrameworkCore.Infrastructure;
-using Microsoft.EntityFrameworkCore.Migrations;
-using Microsoft.EntityFrameworkCore.Storage.ValueConversion;
-using Npgsql.EntityFrameworkCore.PostgreSQL.Metadata;
-
-#nullable disable
-
-namespace LiteCharms.Infrastructure.Database.Migrations
-{
-    [DbContext(typeof(LeadGeneratorDbContext))]
-    [Migration("20260502231708_Init")]
-    partial class Init
-    {
-        /// <inheritdoc />
-        protected override void BuildTargetModel(ModelBuilder modelBuilder)
-        {
-#pragma warning disable 612, 618
-            modelBuilder
-                .HasAnnotation("ProductVersion", "10.0.7")
-                .HasAnnotation("Relational:MaxIdentifierLength", 63);
-
-            NpgsqlModelBuilderExtensions.UseIdentityByDefaultColumns(modelBuilder);
-
-            modelBuilder.Entity("LeadGenerator.Database.Entities.Customer", b =>
-                {
-                    b.Property<Guid>("Id")
-                        .ValueGeneratedOnAdd()
-                        .HasColumnType("uuid");
-
-                    b.Property<bool>("Active")
-                        .ValueGeneratedOnAdd()
-                        .HasColumnType("boolean")
-                        .HasDefaultValue(true);
-
-                    b.Property<string>("Address")
-                        .HasColumnType("text");
-
-                    b.Property<string>("City")
-                        .HasColumnType("text");
-
-                    b.Property<string>("Company")
-                        .HasColumnType("text");
-
-                    b.Property<string>("Country")
-                        .HasColumnType("text");
-
-                    b.Property<DateTimeOffset>("CreatedAt")
-                        .ValueGeneratedOnAdd()
-                        .HasColumnType("timestamp with time zone");
-
-                    b.Property<string>("Discord")
-                        .HasColumnType("text");
-
-                    b.Property<string>("Email")
-                        .IsRequired()
-                        .HasColumnType("text");
-
-                    b.Property<string>("LastName")
-                        .IsRequired()
-                        .HasColumnType("text");
-
-                    b.Property<string>("LinkedIn")
-                        .HasColumnType("text");
-
-                    b.Property<string>("Name")
-                        .IsRequired()
-                        .HasColumnType("text");
-
-                    b.Property<string>("Phone")
-                        .HasColumnType("text");
-
-                    b.Property<string>("PostalCode")
-                        .HasColumnType("text");
-
-                    b.Property<string>("Region")
-                        .HasColumnType("text");
-
-                    b.Property<string>("Slack")
-                        .HasColumnType("text");
-
-                    b.Property<string>("Tax")
-                        .HasColumnType("text");
-
-                    b.Property<DateTimeOffset?>("UpdatedAt")
-                        .ValueGeneratedOnUpdate()
-                        .HasColumnType("timestamp with time zone");
-
-                    b.Property<string>("Website")
-                        .HasColumnType("text");
-
-                    b.Property<string>("Whatsapp")
-                        .HasColumnType("text");
-
-                    b.HasKey("Id");
-
-                    b.ToTable("Customer", (string)null);
-                });
-
-            modelBuilder.Entity("LeadGenerator.Database.Entities.Lead", b =>
-                {
-                    b.Property<Guid>("Id")
-                        .ValueGeneratedOnAdd()
-                        .HasColumnType("uuid");
-
-                    b.Property<long?>("AdGroupId")
-                        .HasColumnType("bigint");
-
-                    b.Property<long?>("AdName")
-                        .HasColumnType("bigint");
-
-                    b.Property<string>("AppClickId")
-                        .HasColumnType("text");
-
-                    b.Property<string>("AttribusionHash")
-                        .IsRequired()
-                        .HasColumnType("text");
-
-                    b.Property<long?>("CampaignId")
-                        .HasColumnType("bigint");
-
-                    b.Property<string>("ClickLocation")
-                        .HasColumnType("text");
-
-                    b.Property<DateTimeOffset>("CreatedAt")
-                        .ValueGeneratedOnAdd()
-                        .HasColumnType("timestamp with time zone");
-
-                    b.Property<long?>("FeedItemId")
-                        .HasColumnType("bigint");
-
-                    b.Property<string>("GoogleClickId")
-                        .HasColumnType("text");
-
-                    b.Property<long?>("TargetId")
-                        .HasColumnType("bigint");
-
-                    b.Property<DateTimeOffset?>("UpdatedAt")
-                        .ValueGeneratedOnUpdate()
-                        .HasColumnType("timestamp with time zone");
-
-                    b.Property<string>("WebClickId")
-                        .HasColumnType("text");
-
-                    b.HasKey("Id");
-
-                    b.ToTable("Lead", (string)null);
-                });
-
-            modelBuilder.Entity("LeadGenerator.Database.Entities.Order", b =>
-                {
-                    b.Property<Guid>("Id")
-                        .ValueGeneratedOnAdd()
-                        .HasColumnType("uuid");
-
-                    b.Property<DateTimeOffset>("CreatedAt")
-                        .ValueGeneratedOnAdd()
-                        .HasColumnType("timestamp with time zone");
-
-                    b.Property<Guid>("LeadId")
-                        .HasColumnType("uuid");
-
-                    b.PrimitiveCollection<string>("Notes")
-                        .HasColumnType("jsonb");
-
-                    b.Property<Guid>("ProductId")
-                        .HasColumnType("uuid");
-
-                    b.Property<Guid>("ProductPriceId")
-                        .HasColumnType("uuid");
-
-                    b.Property<int>("Status")
-                        .HasColumnType("integer");
-
-                    b.Property<DateTimeOffset?>("UpdatedAt")
-                        .ValueGeneratedOnUpdate()
-                        .HasColumnType("timestamp with time zone");
-
-                    b.HasKey("Id");
-
-                    b.ToTable("Order", (string)null);
-                });
-
-            modelBuilder.Entity("LeadGenerator.Database.Entities.OrderRefund", b =>
-                {
-                    b.Property<Guid>("Id")
-                        .ValueGeneratedOnAdd()
-                        .HasColumnType("uuid");
-
-                    b.Property<decimal>("Amount")
-                        .HasPrecision(18, 2)
-                        .HasColumnType("numeric(18,2)");
-
-                    b.Property<DateTimeOffset>("CreatedAt")
-                        .ValueGeneratedOnAdd()
-                        .HasColumnType("timestamp with time zone");
-
-                    b.Property<Guid>("OrderId")
-                        .HasColumnType("uuid");
-
-                    b.Property<string>("Reason")
-                        .IsRequired()
-                        .HasColumnType("text");
-
-                    b.HasKey("Id");
-
-                    b.ToTable("OrderRefund", (string)null);
-                });
-
-            modelBuilder.Entity("LeadGenerator.Database.Entities.Product", b =>
-                {
-                    b.Property<Guid>("Id")
-                        .ValueGeneratedOnAdd()
-                        .HasColumnType("uuid");
-
-                    b.Property<bool>("Active")
-                        .ValueGeneratedOnAdd()
-                        .HasColumnType("boolean")
-                        .HasDefaultValue(true);
-
-                    b.Property<string>("Description")
-                        .IsRequired()
-                        .HasColumnType("text");
-
-                    b.Property<string>("Name")
-                        .IsRequired()
-                        .HasColumnType("text");
-
-                    b.HasKey("Id");
-
-                    b.ToTable("Product", (string)null);
-                });
-
-            modelBuilder.Entity("LeadGenerator.Database.Entities.ProductPrice", b =>
-                {
-                    b.Property<Guid>("Id")
-                        .ValueGeneratedOnAdd()
-                        .HasColumnType("uuid");
-
-                    b.Property<bool>("Active")
-                        .HasColumnType("boolean");
-
-                    b.Property<DateTimeOffset>("CreatedAt")
-                        .ValueGeneratedOnAdd()
-                        .HasColumnType("timestamp with time zone");
-
-                    b.Property<decimal>("Discount")
-                        .HasPrecision(18, 2)
-                        .HasColumnType("numeric(18,2)");
-
-                    b.Property<decimal>("Price")
-                        .HasPrecision(18, 2)
-                        .HasColumnType("numeric(18,2)");
-
-                    b.Property<Guid>("ProductId")
-                        .HasColumnType("uuid");
-
-                    b.Property<DateTimeOffset?>("UpdatedAt")
-                        .ValueGeneratedOnUpdate()
-                        .HasColumnType("timestamp with time zone");
-
-                    b.HasKey("Id");
-
-                    b.ToTable("ProductPrice", (string)null);
-                });
-#pragma warning restore 612, 618
-        }
-    }
-}

LiteCharms.Infrastructure/Database/Migrations/20260502231708_Init.cs

@@ -1,154 +0,0 @@
-using System;
-using Microsoft.EntityFrameworkCore.Migrations;
-
-#nullable disable
-
-namespace LiteCharms.Infrastructure.Database.Migrations
-{
-    /// <inheritdoc />
-    public partial class Init : Migration
-    {
-        /// <inheritdoc />
-        protected override void Up(MigrationBuilder migrationBuilder)
-        {
-            migrationBuilder.CreateTable(
-                name: "Customer",
-                columns: table => new
-                {
-                    Id = table.Column<Guid>(type: "uuid", nullable: false),
-                    CreatedAt = table.Column<DateTimeOffset>(type: "timestamp with time zone", nullable: false),
-                    UpdatedAt = table.Column<DateTimeOffset>(type: "timestamp with time zone", nullable: true),
-                    Company = table.Column<string>(type: "text", nullable: true),
-                    Name = table.Column<string>(type: "text", nullable: false),
-                    LastName = table.Column<string>(type: "text", nullable: false),
-                    Tax = table.Column<string>(type: "text", nullable: true),
-                    Email = table.Column<string>(type: "text", nullable: false),
-                    Discord = table.Column<string>(type: "text", nullable: true),
-                    Slack = table.Column<string>(type: "text", nullable: true),
-                    LinkedIn = table.Column<string>(type: "text", nullable: true),
-                    Whatsapp = table.Column<string>(type: "text", nullable: true),
-                    Website = table.Column<string>(type: "text", nullable: true),
-                    Phone = table.Column<string>(type: "text", nullable: true),
-                    Address = table.Column<string>(type: "text", nullable: true),
-                    City = table.Column<string>(type: "text", nullable: true),
-                    Region = table.Column<string>(type: "text", nullable: true),
-                    Country = table.Column<string>(type: "text", nullable: true),
-                    PostalCode = table.Column<string>(type: "text", nullable: true),
-                    Active = table.Column<bool>(type: "boolean", nullable: false, defaultValue: true)
-                },
-                constraints: table =>
-                {
-                    table.PrimaryKey("PK_Customer", x => x.Id);
-                });
-
-            migrationBuilder.CreateTable(
-                name: "Lead",
-                columns: table => new
-                {
-                    Id = table.Column<Guid>(type: "uuid", nullable: false),
-                    CreatedAt = table.Column<DateTimeOffset>(type: "timestamp with time zone", nullable: false),
-                    UpdatedAt = table.Column<DateTimeOffset>(type: "timestamp with time zone", nullable: true),
-                    GoogleClickId = table.Column<string>(type: "text", nullable: true),
-                    WebClickId = table.Column<string>(type: "text", nullable: true),
-                    AppClickId = table.Column<string>(type: "text", nullable: true),
-                    CampaignId = table.Column<long>(type: "bigint", nullable: true),
-                    AdGroupId = table.Column<long>(type: "bigint", nullable: true),
-                    AdName = table.Column<long>(type: "bigint", nullable: true),
-                    TargetId = table.Column<long>(type: "bigint", nullable: true),
-                    FeedItemId = table.Column<long>(type: "bigint", nullable: true),
-                    ClickLocation = table.Column<string>(type: "text", nullable: true),
-                    AttribusionHash = table.Column<string>(type: "text", nullable: false)
-                },
-                constraints: table =>
-                {
-                    table.PrimaryKey("PK_Lead", x => x.Id);
-                });
-
-            migrationBuilder.CreateTable(
-                name: "Order",
-                columns: table => new
-                {
-                    Id = table.Column<Guid>(type: "uuid", nullable: false),
-                    CreatedAt = table.Column<DateTimeOffset>(type: "timestamp with time zone", nullable: false),
-                    UpdatedAt = table.Column<DateTimeOffset>(type: "timestamp with time zone", nullable: true),
-                    LeadId = table.Column<Guid>(type: "uuid", nullable: false),
-                    ProductId = table.Column<Guid>(type: "uuid", nullable: false),
-                    ProductPriceId = table.Column<Guid>(type: "uuid", nullable: false),
-                    Status = table.Column<int>(type: "integer", nullable: false),
-                    Notes = table.Column<string>(type: "jsonb", nullable: true)
-                },
-                constraints: table =>
-                {
-                    table.PrimaryKey("PK_Order", x => x.Id);
-                });
-
-            migrationBuilder.CreateTable(
-                name: "OrderRefund",
-                columns: table => new
-                {
-                    Id = table.Column<Guid>(type: "uuid", nullable: false),
-                    CreatedAt = table.Column<DateTimeOffset>(type: "timestamp with time zone", nullable: false),
-                    OrderId = table.Column<Guid>(type: "uuid", nullable: false),
-                    Reason = table.Column<string>(type: "text", nullable: false),
-                    Amount = table.Column<decimal>(type: "numeric(18,2)", precision: 18, scale: 2, nullable: false)
-                },
-                constraints: table =>
-                {
-                    table.PrimaryKey("PK_OrderRefund", x => x.Id);
-                });
-
-            migrationBuilder.CreateTable(
-                name: "Product",
-                columns: table => new
-                {
-                    Id = table.Column<Guid>(type: "uuid", nullable: false),
-                    Name = table.Column<string>(type: "text", nullable: false),
-                    Description = table.Column<string>(type: "text", nullable: false),
-                    Active = table.Column<bool>(type: "boolean", nullable: false, defaultValue: true)
-                },
-                constraints: table =>
-                {
-                    table.PrimaryKey("PK_Product", x => x.Id);
-                });
-
-            migrationBuilder.CreateTable(
-                name: "ProductPrice",
-                columns: table => new
-                {
-                    Id = table.Column<Guid>(type: "uuid", nullable: false),
-                    CreatedAt = table.Column<DateTimeOffset>(type: "timestamp with time zone", nullable: false),
-                    UpdatedAt = table.Column<DateTimeOffset>(type: "timestamp with time zone", nullable: true),
-                    ProductId = table.Column<Guid>(type: "uuid", nullable: false),
-                    Price = table.Column<decimal>(type: "numeric(18,2)", precision: 18, scale: 2, nullable: false),
-                    Discount = table.Column<decimal>(type: "numeric(18,2)", precision: 18, scale: 2, nullable: false),
-                    Active = table.Column<bool>(type: "boolean", nullable: false)
-                },
-                constraints: table =>
-                {
-                    table.PrimaryKey("PK_ProductPrice", x => x.Id);
-                });
-        }
-
-        /// <inheritdoc />
-        protected override void Down(MigrationBuilder migrationBuilder)
-        {
-            migrationBuilder.DropTable(
-                name: "Customer");
-
-            migrationBuilder.DropTable(
-                name: "Lead");
-
-            migrationBuilder.DropTable(
-                name: "Order");
-
-            migrationBuilder.DropTable(
-                name: "OrderRefund");
-
-            migrationBuilder.DropTable(
-                name: "Product");
-
-            migrationBuilder.DropTable(
-                name: "ProductPrice");
-        }
-    }
-}

LiteCharms.Infrastructure/Database/Migrations/20260503002123_DefinedEntityRelationships.Designer.cs

@@ -1,357 +0,0 @@
-// <auto-generated />
-using System;
-using LiteCharms.Infrastructure.Database;
-using Microsoft.EntityFrameworkCore;
-using Microsoft.EntityFrameworkCore.Infrastructure;
-using Microsoft.EntityFrameworkCore.Migrations;
-using Microsoft.EntityFrameworkCore.Storage.ValueConversion;
-using Npgsql.EntityFrameworkCore.PostgreSQL.Metadata;
-
-#nullable disable
-
-namespace LiteCharms.Infrastructure.Database.Migrations
-{
-    [DbContext(typeof(LeadGeneratorDbContext))]
-    [Migration("20260503002123_DefinedEntityRelationships")]
-    partial class DefinedEntityRelationships
-    {
-        /// <inheritdoc />
-        protected override void BuildTargetModel(ModelBuilder modelBuilder)
-        {
-#pragma warning disable 612, 618
-            modelBuilder
-                .HasAnnotation("ProductVersion", "10.0.7")
-                .HasAnnotation("Relational:MaxIdentifierLength", 63);
-
-            NpgsqlModelBuilderExtensions.UseIdentityByDefaultColumns(modelBuilder);
-
-            modelBuilder.Entity("LeadGenerator.Database.Entities.Customer", b =>
-                {
-                    b.Property<Guid>("Id")
-                        .ValueGeneratedOnAdd()
-                        .HasColumnType("uuid");
-
-                    b.Property<bool>("Active")
-                        .ValueGeneratedOnAdd()
-                        .HasColumnType("boolean")
-                        .HasDefaultValue(true);
-
-                    b.Property<string>("Address")
-                        .HasColumnType("text");
-
-                    b.Property<string>("City")
-                        .HasColumnType("text");
-
-                    b.Property<string>("Company")
-                        .HasColumnType("text");
-
-                    b.Property<string>("Country")
-                        .HasColumnType("text");
-
-                    b.Property<DateTimeOffset>("CreatedAt")
-                        .ValueGeneratedOnAdd()
-                        .HasColumnType("timestamp with time zone");
-
-                    b.Property<string>("Discord")
-                        .HasColumnType("text");
-
-                    b.Property<string>("Email")
-                        .IsRequired()
-                        .HasColumnType("text");
-
-                    b.Property<string>("LastName")
-                        .IsRequired()
-                        .HasColumnType("text");
-
-                    b.Property<string>("LinkedIn")
-                        .HasColumnType("text");
-
-                    b.Property<string>("Name")
-                        .IsRequired()
-                        .HasColumnType("text");
-
-                    b.Property<string>("Phone")
-                        .HasColumnType("text");
-
-                    b.Property<string>("PostalCode")
-                        .HasColumnType("text");
-
-                    b.Property<string>("Region")
-                        .HasColumnType("text");
-
-                    b.Property<string>("Slack")
-                        .HasColumnType("text");
-
-                    b.Property<string>("Tax")
-                        .HasColumnType("text");
-
-                    b.Property<DateTimeOffset?>("UpdatedAt")
-                        .ValueGeneratedOnUpdate()
-                        .HasColumnType("timestamp with time zone");
-
-                    b.Property<string>("Website")
-                        .HasColumnType("text");
-
-                    b.Property<string>("Whatsapp")
-                        .HasColumnType("text");
-
-                    b.HasKey("Id");
-
-                    b.ToTable("Customer", (string)null);
-                });
-
-            modelBuilder.Entity("LeadGenerator.Database.Entities.Lead", b =>
-                {
-                    b.Property<Guid>("Id")
-                        .ValueGeneratedOnAdd()
-                        .HasColumnType("uuid");
-
-                    b.Property<long?>("AdGroupId")
-                        .HasColumnType("bigint");
-
-                    b.Property<long?>("AdName")
-                        .HasColumnType("bigint");
-
-                    b.Property<string>("AppClickId")
-                        .HasColumnType("text");
-
-                    b.Property<string>("AttribusionHash")
-                        .IsRequired()
-                        .HasColumnType("text");
-
-                    b.Property<long?>("CampaignId")
-                        .HasColumnType("bigint");
-
-                    b.Property<string>("ClickLocation")
-                        .HasColumnType("text");
-
-                    b.Property<DateTimeOffset>("CreatedAt")
-                        .ValueGeneratedOnAdd()
-                        .HasColumnType("timestamp with time zone");
-
-                    b.Property<Guid?>("CustomerId")
-                        .HasColumnType("uuid");
-
-                    b.Property<long?>("FeedItemId")
-                        .HasColumnType("bigint");
-
-                    b.Property<string>("GoogleClickId")
-                        .HasColumnType("text");
-
-                    b.Property<Guid?>("LeadId")
-                        .HasColumnType("uuid");
-
-                    b.Property<long?>("TargetId")
-                        .HasColumnType("bigint");
-
-                    b.Property<DateTimeOffset?>("UpdatedAt")
-                        .ValueGeneratedOnUpdate()
-                        .HasColumnType("timestamp with time zone");
-
-                    b.Property<string>("WebClickId")
-                        .HasColumnType("text");
-
-                    b.HasKey("Id");
-
-                    b.HasIndex("CustomerId");
-
-                    b.ToTable("Lead", (string)null);
-                });
-
-            modelBuilder.Entity("LeadGenerator.Database.Entities.Order", b =>
-                {
-                    b.Property<Guid>("Id")
-                        .ValueGeneratedOnAdd()
-                        .HasColumnType("uuid");
-
-                    b.Property<DateTimeOffset>("CreatedAt")
-                        .ValueGeneratedOnAdd()
-                        .HasColumnType("timestamp with time zone");
-
-                    b.Property<Guid>("CustomerId")
-                        .HasColumnType("uuid");
-
-                    b.PrimitiveCollection<string>("Notes")
-                        .HasColumnType("jsonb");
-
-                    b.Property<Guid>("ProductPriceId")
-                        .HasColumnType("uuid");
-
-                    b.Property<Guid?>("RefundId")
-                        .HasColumnType("uuid");
-
-                    b.Property<int>("Status")
-                        .HasColumnType("integer");
-
-                    b.Property<DateTimeOffset?>("UpdatedAt")
-                        .ValueGeneratedOnUpdate()
-                        .HasColumnType("timestamp with time zone");
-
-                    b.HasKey("Id");
-
-                    b.HasIndex("CustomerId");
-
-                    b.HasIndex("ProductPriceId");
-
-                    b.ToTable("Order", (string)null);
-                });
-
-            modelBuilder.Entity("LeadGenerator.Database.Entities.OrderRefund", b =>
-                {
-                    b.Property<Guid>("Id")
-                        .ValueGeneratedOnAdd()
-                        .HasColumnType("uuid");
-
-                    b.Property<decimal>("Amount")
-                        .HasPrecision(18, 2)
-                        .HasColumnType("numeric(18,2)");
-
-                    b.Property<DateTimeOffset>("CreatedAt")
-                        .ValueGeneratedOnAdd()
-                        .HasColumnType("timestamp with time zone");
-
-                    b.Property<Guid>("OrderId")
-                        .HasColumnType("uuid");
-
-                    b.Property<string>("Reason")
-                        .IsRequired()
-                        .HasColumnType("text");
-
-                    b.HasKey("Id");
-
-                    b.HasIndex("OrderId")
-                        .IsUnique();
-
-                    b.ToTable("OrderRefund", (string)null);
-                });
-
-            modelBuilder.Entity("LeadGenerator.Database.Entities.Product", b =>
-                {
-                    b.Property<Guid>("Id")
-                        .ValueGeneratedOnAdd()
-                        .HasColumnType("uuid");
-
-                    b.Property<bool>("Active")
-                        .ValueGeneratedOnAdd()
-                        .HasColumnType("boolean")
-                        .HasDefaultValue(true);
-
-                    b.Property<string>("Description")
-                        .IsRequired()
-                        .HasColumnType("text");
-
-                    b.Property<string>("Name")
-                        .IsRequired()
-                        .HasColumnType("text");
-
-                    b.HasKey("Id");
-
-                    b.ToTable("Product", (string)null);
-                });
-
-            modelBuilder.Entity("LeadGenerator.Database.Entities.ProductPrice", b =>
-                {
-                    b.Property<Guid>("Id")
-                        .ValueGeneratedOnAdd()
-                        .HasColumnType("uuid");
-
-                    b.Property<bool>("Active")
-                        .HasColumnType("boolean");
-
-                    b.Property<DateTimeOffset>("CreatedAt")
-                        .ValueGeneratedOnAdd()
-                        .HasColumnType("timestamp with time zone");
-
-                    b.Property<decimal>("Discount")
-                        .HasPrecision(18, 2)
-                        .HasColumnType("numeric(18,2)");
-
-                    b.Property<decimal>("Price")
-                        .HasPrecision(18, 2)
-                        .HasColumnType("numeric(18,2)");
-
-                    b.Property<Guid>("ProductId")
-                        .HasColumnType("uuid");
-
-                    b.Property<DateTimeOffset?>("UpdatedAt")
-                        .ValueGeneratedOnUpdate()
-                        .HasColumnType("timestamp with time zone");
-
-                    b.HasKey("Id");
-
-                    b.HasIndex("ProductId");
-
-                    b.ToTable("ProductPrice", (string)null);
-                });
-
-            modelBuilder.Entity("LeadGenerator.Database.Entities.Lead", b =>
-                {
-                    b.HasOne("LeadGenerator.Database.Entities.Customer", "Customer")
-                        .WithMany("Leads")
-                        .HasForeignKey("CustomerId")
-                        .OnDelete(DeleteBehavior.NoAction);
-
-                    b.Navigation("Customer");
-                });
-
-            modelBuilder.Entity("LeadGenerator.Database.Entities.Order", b =>
-                {
-                    b.HasOne("LeadGenerator.Database.Entities.Customer", "Customer")
-                        .WithMany("Orders")
-                        .HasForeignKey("CustomerId")
-                        .OnDelete(DeleteBehavior.Restrict)
-                        .IsRequired();
-
-                    b.HasOne("LeadGenerator.Database.Entities.ProductPrice", "ProductPrice")
-                        .WithMany()
-                        .HasForeignKey("ProductPriceId")
-                        .OnDelete(DeleteBehavior.Restrict)
-                        .IsRequired();
-
-                    b.Navigation("Customer");
-
-                    b.Navigation("ProductPrice");
-                });
-
-            modelBuilder.Entity("LeadGenerator.Database.Entities.OrderRefund", b =>
-                {
-                    b.HasOne("LeadGenerator.Database.Entities.Order", "Order")
-                        .WithOne("Refund")
-                        .HasForeignKey("LeadGenerator.Database.Entities.OrderRefund", "OrderId")
-                        .OnDelete(DeleteBehavior.Cascade)
-                        .IsRequired();
-
-                    b.Navigation("Order");
-                });
-
-            modelBuilder.Entity("LeadGenerator.Database.Entities.ProductPrice", b =>
-                {
-                    b.HasOne("LeadGenerator.Database.Entities.Product", "Product")
-                        .WithMany("ProductPrices")
-                        .HasForeignKey("ProductId")
-                        .OnDelete(DeleteBehavior.Restrict)
-                        .IsRequired();
-
-                    b.Navigation("Product");
-                });
-
-            modelBuilder.Entity("LeadGenerator.Database.Entities.Customer", b =>
-                {
-                    b.Navigation("Leads");
-
-                    b.Navigation("Orders");
-                });
-
-            modelBuilder.Entity("LeadGenerator.Database.Entities.Order", b =>
-                {
-                    b.Navigation("Refund");
-                });
-
-            modelBuilder.Entity("LeadGenerator.Database.Entities.Product", b =>
-                {
-                    b.Navigation("ProductPrices");
-                });
-#pragma warning restore 612, 618
-        }
-    }
-}

LiteCharms.Infrastructure/Database/Migrations/20260503002123_DefinedEntityRelationships.cs

@@ -1,175 +0,0 @@
-using System;
-using Microsoft.EntityFrameworkCore.Migrations;
-
-#nullable disable
-
-namespace LiteCharms.Infrastructure.Database.Migrations
-{
-    /// <inheritdoc />
-    public partial class DefinedEntityRelationships : Migration
-    {
-        /// <inheritdoc />
-        protected override void Up(MigrationBuilder migrationBuilder)
-        {
-            migrationBuilder.DropColumn(
-                name: "LeadId",
-                table: "Order");
-
-            migrationBuilder.RenameColumn(
-                name: "ProductId",
-                table: "Order",
-                newName: "CustomerId");
-
-            migrationBuilder.AddColumn<Guid>(
-                name: "RefundId",
-                table: "Order",
-                type: "uuid",
-                nullable: true);
-
-            migrationBuilder.AddColumn<Guid>(
-                name: "CustomerId",
-                table: "Lead",
-                type: "uuid",
-                nullable: true);
-
-            migrationBuilder.AddColumn<Guid>(
-                name: "LeadId",
-                table: "Lead",
-                type: "uuid",
-                nullable: true);
-
-            migrationBuilder.CreateIndex(
-                name: "IX_ProductPrice_ProductId",
-                table: "ProductPrice",
-                column: "ProductId");
-
-            migrationBuilder.CreateIndex(
-                name: "IX_OrderRefund_OrderId",
-                table: "OrderRefund",
-                column: "OrderId",
-                unique: true);
-
-            migrationBuilder.CreateIndex(
-                name: "IX_Order_CustomerId",
-                table: "Order",
-                column: "CustomerId");
-
-            migrationBuilder.CreateIndex(
-                name: "IX_Order_ProductPriceId",
-                table: "Order",
-                column: "ProductPriceId");
-
-            migrationBuilder.CreateIndex(
-                name: "IX_Lead_CustomerId",
-                table: "Lead",
-                column: "CustomerId");
-
-            migrationBuilder.AddForeignKey(
-                name: "FK_Lead_Customer_CustomerId",
-                table: "Lead",
-                column: "CustomerId",
-                principalTable: "Customer",
-                principalColumn: "Id");
-
-            migrationBuilder.AddForeignKey(
-                name: "FK_Order_Customer_CustomerId",
-                table: "Order",
-                column: "CustomerId",
-                principalTable: "Customer",
-                principalColumn: "Id",
-                onDelete: ReferentialAction.Restrict);
-
-            migrationBuilder.AddForeignKey(
-                name: "FK_Order_ProductPrice_ProductPriceId",
-                table: "Order",
-                column: "ProductPriceId",
-                principalTable: "ProductPrice",
-                principalColumn: "Id",
-                onDelete: ReferentialAction.Restrict);
-
-            migrationBuilder.AddForeignKey(
-                name: "FK_OrderRefund_Order_OrderId",
-                table: "OrderRefund",
-                column: "OrderId",
-                principalTable: "Order",
-                principalColumn: "Id",
-                onDelete: ReferentialAction.Cascade);
-
-            migrationBuilder.AddForeignKey(
-                name: "FK_ProductPrice_Product_ProductId",
-                table: "ProductPrice",
-                column: "ProductId",
-                principalTable: "Product",
-                principalColumn: "Id",
-                onDelete: ReferentialAction.Restrict);
-        }
-
-        /// <inheritdoc />
-        protected override void Down(MigrationBuilder migrationBuilder)
-        {
-            migrationBuilder.DropForeignKey(
-                name: "FK_Lead_Customer_CustomerId",
-                table: "Lead");
-
-            migrationBuilder.DropForeignKey(
-                name: "FK_Order_Customer_CustomerId",
-                table: "Order");
-
-            migrationBuilder.DropForeignKey(
-                name: "FK_Order_ProductPrice_ProductPriceId",
-                table: "Order");
-
-            migrationBuilder.DropForeignKey(
-                name: "FK_OrderRefund_Order_OrderId",
-                table: "OrderRefund");
-
-            migrationBuilder.DropForeignKey(
-                name: "FK_ProductPrice_Product_ProductId",
-                table: "ProductPrice");
-
-            migrationBuilder.DropIndex(
-                name: "IX_ProductPrice_ProductId",
-                table: "ProductPrice");
-
-            migrationBuilder.DropIndex(
-                name: "IX_OrderRefund_OrderId",
-                table: "OrderRefund");
-
-            migrationBuilder.DropIndex(
-                name: "IX_Order_CustomerId",
-                table: "Order");
-
-            migrationBuilder.DropIndex(
-                name: "IX_Order_ProductPriceId",
-                table: "Order");
-
-            migrationBuilder.DropIndex(
-                name: "IX_Lead_CustomerId",
-                table: "Lead");
-
-            migrationBuilder.DropColumn(
-                name: "RefundId",
-                table: "Order");
-
-            migrationBuilder.DropColumn(
-                name: "CustomerId",
-                table: "Lead");
-
-            migrationBuilder.DropColumn(
-                name: "LeadId",
-                table: "Lead");
-
-            migrationBuilder.RenameColumn(
-                name: "CustomerId",
-                table: "Order",
-                newName: "ProductId");
-
-            migrationBuilder.AddColumn<Guid>(
-                name: "LeadId",
-                table: "Order",
-                type: "uuid",
-                nullable: false,
-                defaultValue: new Guid("00000000-0000-0000-0000-000000000000"));
-        }
-    }
-}

LiteCharms.Infrastructure/Database/Migrations/20260503003624_RemovedLeadIdFromLead.Designer.cs

@@ -1,354 +0,0 @@
-// <auto-generated />
-using System;
-using LiteCharms.Infrastructure.Database;
-using Microsoft.EntityFrameworkCore;
-using Microsoft.EntityFrameworkCore.Infrastructure;
-using Microsoft.EntityFrameworkCore.Migrations;
-using Microsoft.EntityFrameworkCore.Storage.ValueConversion;
-using Npgsql.EntityFrameworkCore.PostgreSQL.Metadata;
-
-#nullable disable
-
-namespace LiteCharms.Infrastructure.Database.Migrations
-{
-    [DbContext(typeof(LeadGeneratorDbContext))]
-    [Migration("20260503003624_RemovedLeadIdFromLead")]
-    partial class RemovedLeadIdFromLead
-    {
-        /// <inheritdoc />
-        protected override void BuildTargetModel(ModelBuilder modelBuilder)
-        {
-#pragma warning disable 612, 618
-            modelBuilder
-                .HasAnnotation("ProductVersion", "10.0.7")
-                .HasAnnotation("Relational:MaxIdentifierLength", 63);
-
-            NpgsqlModelBuilderExtensions.UseIdentityByDefaultColumns(modelBuilder);
-
-            modelBuilder.Entity("LeadGenerator.Database.Entities.Customer", b =>
-                {
-                    b.Property<Guid>("Id")
-                        .ValueGeneratedOnAdd()
-                        .HasColumnType("uuid");
-
-                    b.Property<bool>("Active")
-                        .ValueGeneratedOnAdd()
-                        .HasColumnType("boolean")
-                        .HasDefaultValue(true);
-
-                    b.Property<string>("Address")
-                        .HasColumnType("text");
-
-                    b.Property<string>("City")
-                        .HasColumnType("text");
-
-                    b.Property<string>("Company")
-                        .HasColumnType("text");
-
-                    b.Property<string>("Country")
-                        .HasColumnType("text");
-
-                    b.Property<DateTimeOffset>("CreatedAt")
-                        .ValueGeneratedOnAdd()
-                        .HasColumnType("timestamp with time zone");
-
-                    b.Property<string>("Discord")
-                        .HasColumnType("text");
-
-                    b.Property<string>("Email")
-                        .IsRequired()
-                        .HasColumnType("text");
-
-                    b.Property<string>("LastName")
-                        .IsRequired()
-                        .HasColumnType("text");
-
-                    b.Property<string>("LinkedIn")
-                        .HasColumnType("text");
-
-                    b.Property<string>("Name")
-                        .IsRequired()
-                        .HasColumnType("text");
-
-                    b.Property<string>("Phone")
-                        .HasColumnType("text");
-
-                    b.Property<string>("PostalCode")
-                        .HasColumnType("text");
-
-                    b.Property<string>("Region")
-                        .HasColumnType("text");
-
-                    b.Property<string>("Slack")
-                        .HasColumnType("text");
-
-                    b.Property<string>("Tax")
-                        .HasColumnType("text");
-
-                    b.Property<DateTimeOffset?>("UpdatedAt")
-                        .ValueGeneratedOnUpdate()
-                        .HasColumnType("timestamp with time zone");
-
-                    b.Property<string>("Website")
-                        .HasColumnType("text");
-
-                    b.Property<string>("Whatsapp")
-                        .HasColumnType("text");
-
-                    b.HasKey("Id");
-
-                    b.ToTable("Customer", (string)null);
-                });
-
-            modelBuilder.Entity("LeadGenerator.Database.Entities.Lead", b =>
-                {
-                    b.Property<Guid>("Id")
-                        .ValueGeneratedOnAdd()
-                        .HasColumnType("uuid");
-
-                    b.Property<long?>("AdGroupId")
-                        .HasColumnType("bigint");
-
-                    b.Property<long?>("AdName")
-                        .HasColumnType("bigint");
-
-                    b.Property<string>("AppClickId")
-                        .HasColumnType("text");
-
-                    b.Property<string>("AttribusionHash")
-                        .IsRequired()
-                        .HasColumnType("text");
-
-                    b.Property<long?>("CampaignId")
-                        .HasColumnType("bigint");
-
-                    b.Property<string>("ClickLocation")
-                        .HasColumnType("text");
-
-                    b.Property<DateTimeOffset>("CreatedAt")
-                        .ValueGeneratedOnAdd()
-                        .HasColumnType("timestamp with time zone");
-
-                    b.Property<Guid?>("CustomerId")
-                        .HasColumnType("uuid");
-
-                    b.Property<long?>("FeedItemId")
-                        .HasColumnType("bigint");
-
-                    b.Property<string>("GoogleClickId")
-                        .HasColumnType("text");
-
-                    b.Property<long?>("TargetId")
-                        .HasColumnType("bigint");
-
-                    b.Property<DateTimeOffset?>("UpdatedAt")
-                        .ValueGeneratedOnUpdate()
-                        .HasColumnType("timestamp with time zone");
-
-                    b.Property<string>("WebClickId")
-                        .HasColumnType("text");
-
-                    b.HasKey("Id");
-
-                    b.HasIndex("CustomerId");
-
-                    b.ToTable("Lead", (string)null);
-                });
-
-            modelBuilder.Entity("LeadGenerator.Database.Entities.Order", b =>
-                {
-                    b.Property<Guid>("Id")
-                        .ValueGeneratedOnAdd()
-                        .HasColumnType("uuid");
-
-                    b.Property<DateTimeOffset>("CreatedAt")
-                        .ValueGeneratedOnAdd()
-                        .HasColumnType("timestamp with time zone");
-
-                    b.Property<Guid>("CustomerId")
-                        .HasColumnType("uuid");
-
-                    b.PrimitiveCollection<string>("Notes")
-                        .HasColumnType("jsonb");
-
-                    b.Property<Guid>("ProductPriceId")
-                        .HasColumnType("uuid");
-
-                    b.Property<Guid?>("RefundId")
-                        .HasColumnType("uuid");
-
-                    b.Property<int>("Status")
-                        .HasColumnType("integer");
-
-                    b.Property<DateTimeOffset?>("UpdatedAt")
-                        .ValueGeneratedOnUpdate()
-                        .HasColumnType("timestamp with time zone");
-
-                    b.HasKey("Id");
-
-                    b.HasIndex("CustomerId");
-
-                    b.HasIndex("ProductPriceId");
-
-                    b.ToTable("Order", (string)null);
-                });
-
-            modelBuilder.Entity("LeadGenerator.Database.Entities.OrderRefund", b =>
-                {
-                    b.Property<Guid>("Id")
-                        .ValueGeneratedOnAdd()
-                        .HasColumnType("uuid");
-
-                    b.Property<decimal>("Amount")
-                        .HasPrecision(18, 2)
-                        .HasColumnType("numeric(18,2)");
-
-                    b.Property<DateTimeOffset>("CreatedAt")
-                        .ValueGeneratedOnAdd()
-                        .HasColumnType("timestamp with time zone");
-
-                    b.Property<Guid>("OrderId")
-                        .HasColumnType("uuid");
-
-                    b.Property<string>("Reason")
-                        .IsRequired()
-                        .HasColumnType("text");
-
-                    b.HasKey("Id");
-
-                    b.HasIndex("OrderId")
-                        .IsUnique();
-
-                    b.ToTable("OrderRefund", (string)null);
-                });
-
-            modelBuilder.Entity("LeadGenerator.Database.Entities.Product", b =>
-                {
-                    b.Property<Guid>("Id")
-                        .ValueGeneratedOnAdd()
-                        .HasColumnType("uuid");
-
-                    b.Property<bool>("Active")
-                        .ValueGeneratedOnAdd()
-                        .HasColumnType("boolean")
-                        .HasDefaultValue(true);
-
-                    b.Property<string>("Description")
-                        .IsRequired()
-                        .HasColumnType("text");
-
-                    b.Property<string>("Name")
-                        .IsRequired()
-                        .HasColumnType("text");
-
-                    b.HasKey("Id");
-
-                    b.ToTable("Product", (string)null);
-                });
-
-            modelBuilder.Entity("LeadGenerator.Database.Entities.ProductPrice", b =>
-                {
-                    b.Property<Guid>("Id")
-                        .ValueGeneratedOnAdd()
-                        .HasColumnType("uuid");
-
-                    b.Property<bool>("Active")
-                        .HasColumnType("boolean");
-
-                    b.Property<DateTimeOffset>("CreatedAt")
-                        .ValueGeneratedOnAdd()
-                        .HasColumnType("timestamp with time zone");
-
-                    b.Property<decimal>("Discount")
-                        .HasPrecision(18, 2)
-                        .HasColumnType("numeric(18,2)");
-
-                    b.Property<decimal>("Price")
-                        .HasPrecision(18, 2)
-                        .HasColumnType("numeric(18,2)");
-
-                    b.Property<Guid>("ProductId")
-                        .HasColumnType("uuid");
-
-                    b.Property<DateTimeOffset?>("UpdatedAt")
-                        .ValueGeneratedOnUpdate()
-                        .HasColumnType("timestamp with time zone");
-
-                    b.HasKey("Id");
-
-                    b.HasIndex("ProductId");
-
-                    b.ToTable("ProductPrice", (string)null);
-                });
-
-            modelBuilder.Entity("LeadGenerator.Database.Entities.Lead", b =>
-                {
-                    b.HasOne("LeadGenerator.Database.Entities.Customer", "Customer")
-                        .WithMany("Leads")
-                        .HasForeignKey("CustomerId")
-                        .OnDelete(DeleteBehavior.NoAction);
-
-                    b.Navigation("Customer");
-                });
-
-            modelBuilder.Entity("LeadGenerator.Database.Entities.Order", b =>
-                {
-                    b.HasOne("LeadGenerator.Database.Entities.Customer", "Customer")
-                        .WithMany("Orders")
-                        .HasForeignKey("CustomerId")
-                        .OnDelete(DeleteBehavior.Restrict)
-                        .IsRequired();
-
-                    b.HasOne("LeadGenerator.Database.Entities.ProductPrice", "ProductPrice")
-                        .WithMany()
-                        .HasForeignKey("ProductPriceId")
-                        .OnDelete(DeleteBehavior.Restrict)
-                        .IsRequired();
-
-                    b.Navigation("Customer");
-
-                    b.Navigation("ProductPrice");
-                });
-
-            modelBuilder.Entity("LeadGenerator.Database.Entities.OrderRefund", b =>
-                {
-                    b.HasOne("LeadGenerator.Database.Entities.Order", "Order")
-                        .WithOne("Refund")
-                        .HasForeignKey("LeadGenerator.Database.Entities.OrderRefund", "OrderId")
-                        .OnDelete(DeleteBehavior.Cascade)
-                        .IsRequired();
-
-                    b.Navigation("Order");
-                });
-
-            modelBuilder.Entity("LeadGenerator.Database.Entities.ProductPrice", b =>
-                {
-                    b.HasOne("LeadGenerator.Database.Entities.Product", "Product")
-                        .WithMany("ProductPrices")
-                        .HasForeignKey("ProductId")
-                        .OnDelete(DeleteBehavior.Restrict)
-                        .IsRequired();
-
-                    b.Navigation("Product");
-                });
-
-            modelBuilder.Entity("LeadGenerator.Database.Entities.Customer", b =>
-                {
-                    b.Navigation("Leads");
-
-                    b.Navigation("Orders");
-                });
-
-            modelBuilder.Entity("LeadGenerator.Database.Entities.Order", b =>
-                {
-                    b.Navigation("Refund");
-                });
-
-            modelBuilder.Entity("LeadGenerator.Database.Entities.Product", b =>
-                {
-                    b.Navigation("ProductPrices");
-                });
-#pragma warning restore 612, 618
-        }
-    }
-}

LiteCharms.Infrastructure/Database/Migrations/20260503003624_RemovedLeadIdFromLead.cs

@@ -1,29 +0,0 @@
-using System;
-using Microsoft.EntityFrameworkCore.Migrations;
-
-#nullable disable
-
-namespace LiteCharms.Infrastructure.Database.Migrations
-{
-    /// <inheritdoc />
-    public partial class RemovedLeadIdFromLead : Migration
-    {
-        /// <inheritdoc />
-        protected override void Up(MigrationBuilder migrationBuilder)
-        {
-            migrationBuilder.DropColumn(
-                name: "LeadId",
-                table: "Lead");
-        }
-
-        /// <inheritdoc />
-        protected override void Down(MigrationBuilder migrationBuilder)
-        {
-            migrationBuilder.AddColumn<Guid>(
-                name: "LeadId",
-                table: "Lead",
-                type: "uuid",
-                nullable: true);
-        }
-    }
-}