Added shared projects

LiteCharms.Features/Customers/Commands/CreateCustomerCommand.cs

@@ -0,0 +1,64 @@
+namespace LiteCharms.Features.Customers.Commands;
+
+public class CreateCustomerCommand : IRequest<Result<Guid>>
+{
+    public string? Company { get; set; }
+
+    public string Name { get; set; }
+
+    public string LastName { get; set; }
+
+    public string? Tax { get; set; }
+
+    public string Email { get; set; }
+
+    public string? Discord { get; set; }
+
+    public string? Slack { get; set; }
+
+    public string? LinkedIn { get; set; }
+
+    public string? Whatsapp { get; set; }
+
+    public string? Website { get; set; }
+
+    public string? Phone { get; set; }
+
+    public string? Address { get; set; }
+
+    public string? City { get; set; }
+
+    public string? Region { get; set; }
+
+    public string? Country { get; set; }
+
+    public string? PostalCode { get; set; }
+
+    private CreateCustomerCommand(string name, string lastName, string? company, string? tax, string email, string? discord, string? slack, string? linkedIn, string? whatsapp, string? website, string? phone, string? address, string? city, string? region, string? country, string? postalCode)
+    {
+        Name = name;
+        LastName = lastName;
+        Company = company;
+        Tax = tax;
+        Email = email;
+        Discord = discord;
+        Slack = slack;
+        LinkedIn = linkedIn;
+        Whatsapp = whatsapp;
+        Website = website;
+        Phone = phone;
+        Address = address;
+        City = city;
+        Region = region;
+        Country = country;
+        PostalCode = postalCode;
+    }
+
+    public static CreateCustomerCommand Create(string name, string lastName, string? company, string? tax, string email, string? discord, string? slack, string? linkedIn, string? whatsapp, string? website, string? phone, string? address, string? city, string? region, string? country, string? postalCode)
+    {
+        if (string.IsNullOrWhiteSpace(name) && string.IsNullOrWhiteSpace(lastName) && string.IsNullOrWhiteSpace(email))
+            throw new ArgumentException("At the following fields must be provided: Name, LastName, Email");
+
+        return new(name, lastName, company, tax, email, discord, slack, linkedIn, whatsapp, website, phone, address, city, region, country, postalCode);
+    }
+}

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

@@ -0,0 +1,48 @@
+using LiteCharms.Infrastructure.Database;
+
+namespace LiteCharms.Features.Customers.Commands.Handlers;
+
+public class CreateCustomerCommandHandler(IDbContextFactory<LeadGeneratorDbContext> contextFactory) : IRequestHandler<CreateCustomerCommand, Result<Guid>>
+{
+    public async ValueTask<Result<Guid>> Handle(CreateCustomerCommand request, CancellationToken cancellationToken)
+    {
+		try
+		{
+            using var context = await contextFactory.CreateDbContextAsync(cancellationToken);
+
+            var customerEmail = request.Email.ToLower().Trim();
+
+            if (await context.Customers.AnyAsync(c => c.Email == customerEmail, cancellationToken))
+                return Result.Fail<Guid>(new Error($"A customer with the email {customerEmail} already exists"));
+
+            var newCustomer = context.Customers.Add(new Entities.Customer
+            {
+                Company = request.Company,
+                Name = request.Name,
+                LastName = request.LastName,
+                Tax = request.Tax,
+                Email = customerEmail,
+                Discord = request.Discord,
+                Slack = request.Slack,
+                LinkedIn = request.LinkedIn,
+                Whatsapp = request.Whatsapp,
+                Website = request.Website,
+                Phone = request.Phone,
+                Address = request.Address,
+                City = request.City,
+                Region = request.Region,
+                Country = request.Country,
+                PostalCode = request.PostalCode,
+                Active = true,
+            });
+
+            return await context.SaveChangesAsync(cancellationToken) > 0
+                ? Result.Ok(newCustomer.Entity.Id)
+                : Result.Fail<Guid>(new Error($"Failed to create customer {customerEmail}"));
+        }
+		catch (Exception ex)
+		{
+            return Result.Fail<Guid>(new Error(ex.Message).CausedBy(ex));
+        }
+    }
+}

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

@@ -0,0 +1,38 @@
+using LiteCharms.Infrastructure.Database;
+
+namespace LiteCharms.Features.Customers.Commands.Handlers;
+
+public class RefundCustomerCommandHandler(IDbContextFactory<LeadGeneratorDbContext> contextFactory) : IRequestHandler<RefundCustomerCommand, Result<Guid>>
+{
+    public async ValueTask<Result<Guid>> Handle(RefundCustomerCommand request, CancellationToken cancellationToken)
+    {
+		try
+		{
+            using var context = await contextFactory.CreateDbContextAsync(cancellationToken);
+
+            if(!await context.Orders.AnyAsync(o => o.Id == request.OrderId, cancellationToken))
+                return Result.Fail<Guid>(new Error($"Order with Id: {request.OrderId} does not exist"));
+
+            if (!await context.Customers.AnyAsync(c => c.Id == request.CustomerId, cancellationToken))
+                return Result.Fail<Guid>(new Error($"Customer with Id: {request.CustomerId} does not exist"));
+
+            if(!await context.Orders.AnyAsync(o => o.Id == request.OrderId && o.CustomerId == request.CustomerId, cancellationToken))
+                return Result.Fail<Guid>(new Error($"Order with Id: {request.OrderId} does not belong to Customer with Id: {request.CustomerId}"));
+
+            var refund = context.OrderRefunds.Add(new Entities.OrderRefund
+            {
+                OrderId = request.OrderId,
+                Reason = request.Reason,
+                Amount = request.Amount
+            });
+
+            return await context.SaveChangesAsync(cancellationToken) > 0
+                ? Result.Ok(refund.Entity.Id)
+                : Result.Fail<Guid>(new Error($"Failed to create refund for OrderId: {request.OrderId}"));
+        }
+		catch (Exception ex)
+		{
+            return Result.Fail<Guid>(new Error(ex.Message).CausedBy(ex));
+        }
+    }
+}

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

@@ -0,0 +1,44 @@
+using LiteCharms.Infrastructure.Database;
+
+namespace LiteCharms.Features.Customers.Commands.Handlers;
+
+public class UpdateCustomerCommandHandler(IDbContextFactory<LeadGeneratorDbContext> contextFactory) : IRequestHandler<UpdateCustomerCommand, Result>
+{
+    public async ValueTask<Result> Handle(UpdateCustomerCommand request, CancellationToken cancellationToken)
+    {
+        try
+        {
+            using var context = await contextFactory.CreateDbContextAsync(cancellationToken);
+
+            var customer = await context.Customers.FirstOrDefaultAsync(c => c.Id == request.CustomerId, cancellationToken);
+
+            if (customer is null)
+                return Result.Fail(new Error($"Customer with ID {request.CustomerId} not found."));
+
+            customer.Name = request.Name;
+            customer.LastName = request.LastName;
+            customer.Email = request.Email;
+            customer.Company = request.Company;
+            customer.Address = request.Address;
+            customer.City = request.City;
+            customer.Region = request.Region;
+            customer.Country = request.Country;
+            customer.PostalCode = request.PostalCode;
+            customer.Phone = request.Phone;
+            customer.Tax = request.Tax;
+            customer.City = request.City;
+            customer.Discord = request.Discord;
+            customer.Slack = request.Slack;
+            customer.LinkedIn = request.LinkedIn;
+            customer.Whatsapp = request.Whatsapp;
+
+            return await context.SaveChangesAsync(cancellationToken) > 0
+                ? Result.Ok()
+                : Result.Fail(new Error($"Failed to update the customer {request.CustomerId}."));
+        }
+        catch (Exception ex)
+        {
+            return Result.Fail(new Error(ex.Message).CausedBy(ex));
+        }
+    }
+}

LiteCharms.Features/Customers/Commands/RefundCustomerCommand.cs

@@ -0,0 +1,38 @@
+namespace LiteCharms.Features.Customers.Commands;
+
+public class RefundCustomerCommand : IRequest<Result<Guid>>
+{
+    public Guid OrderId { get; set; }
+
+    public Guid CustomerId { get; set; }
+
+    public string? Reason { get; set; }
+
+    public decimal Amount { get; set; }
+
+    private RefundCustomerCommand(Guid orderId, Guid customerId, string? reason, decimal amount)
+    {
+        OrderId = orderId;
+        CustomerId = customerId;
+        Reason = reason;
+        Amount = amount;
+        CustomerId = customerId;
+    }
+
+    public static RefundCustomerCommand Create(Guid orderId, Guid customerId, string? reason, decimal amount)
+    {
+        if (orderId == Guid.Empty)
+            throw new ArgumentException("OrderId is required", nameof(orderId));
+
+        if (customerId == Guid.Empty)
+            throw new ArgumentException("CustomerId is required", nameof(customerId));
+
+        if (amount <= 0)
+            throw new ArgumentException("Amount must be greater than zero", nameof(amount));
+
+        if (string.IsNullOrWhiteSpace(reason))
+            throw new ArgumentException("Reason is required", nameof(reason));
+
+        return new(orderId, customerId, reason, amount);
+    }
+}

LiteCharms.Features/Customers/Commands/UpdateCustomerCommand.cs

@@ -0,0 +1,70 @@
+namespace LiteCharms.Features.Customers.Commands;
+
+public class UpdateCustomerCommand : IRequest<Result>
+{
+    public Guid CustomerId { get; set; }
+
+    public string? Company { get; set; }
+
+    public string? Name { get; set; }
+
+    public string? LastName { get; set; }
+
+    public string? Tax { get; set; }
+
+    public string? Email { get; set; }
+
+    public string? Discord { get; set; }
+
+    public string? Slack { get; set; }
+
+    public string? LinkedIn { get; set; }
+
+    public string? Whatsapp { get; set; }
+
+    public string? Website { get; set; }
+
+    public string? Phone { get; set; }
+
+    public string? Address { get; set; }
+
+    public string? City { get; set; }
+
+    public string? Region { get; set; }
+
+    public string? Country { get; set; }
+
+    public string? PostalCode { get; set; }
+
+    private UpdateCustomerCommand(Guid customerId, string name, string lastName, string? company, string? tax, string email, string? discord, string? slack, string? linkedIn, string? whatsapp, string? website, string? phone, string? address, string? city, string? region, string? country, string? postalCode)
+    {
+        CustomerId = customerId;
+        Name = name;
+        LastName = lastName;
+        Company = company;
+        Tax = tax;
+        Email = email;
+        Discord = discord;
+        Slack = slack;
+        LinkedIn = linkedIn;
+        Whatsapp = whatsapp;
+        Website = website;
+        Phone = phone;
+        Address = address;
+        City = city;
+        Region = region;
+        Country = country;
+        PostalCode = postalCode;
+    }
+
+    public static UpdateCustomerCommand Create(Guid customerId, string name, string lastName, string? company, string? tax, string email, string? discord, string? slack, string? linkedIn, string? whatsapp, string? website, string? phone, string? address, string? city, string? region, string? country, string? postalCode)
+    {
+        if (customerId == Guid.Empty)
+            throw new ArgumentException("Customer ID is required.", nameof(customerId));
+
+        if (string.IsNullOrWhiteSpace(name) && string.IsNullOrWhiteSpace(lastName) && string.IsNullOrWhiteSpace(email))
+            throw new ArgumentException("At the following fields must be provided: Name, LastName, Email");
+
+        return new(customerId, name, lastName, company, tax, email, discord, slack, linkedIn, whatsapp, website, phone, address, city, region, country, postalCode);
+    }
+}

LiteCharms.Features/Customers/Queries/GetCustomerOrdersQuery.cs

@@ -0,0 +1,18 @@
+using LiteCharms.Models;
+
+namespace LiteCharms.Features.Customers.Queries;
+
+public class GetCustomerOrdersQuery : IRequest<Result<Order[]>>
+{
+    public Guid CustomerId { get; }
+
+    private GetCustomerOrdersQuery(Guid customerId) => CustomerId = customerId;
+
+    public static GetCustomerOrdersQuery Create(Guid customerId)
+    {
+        if (customerId == Guid.Empty)
+            throw new ArgumentException("CustomerId is required.", nameof(customerId));
+
+        return new(customerId);
+    }
+}

LiteCharms.Features/Customers/Queries/GetCustomerRefundsQuery.cs

@@ -0,0 +1,18 @@
+using LiteCharms.Models;
+
+namespace LiteCharms.Features.Customers.Queries;
+
+public class GetCustomerRefundsQuery : IRequest<Result<OrderRefund[]>>
+{
+    public Guid CustomerId { get; set; }
+
+    private GetCustomerRefundsQuery(Guid customerId) => CustomerId = customerId;
+
+    public static GetCustomerRefundsQuery Create(Guid customerId)
+    {
+        if (customerId == Guid.Empty)
+            throw new ArgumentException("CustomerId is required.", nameof(customerId));
+
+        return new(customerId);
+    }
+}

LiteCharms.Features/Customers/Queries/GetCustomersQuery.cs

@@ -0,0 +1,24 @@
+using LiteCharms.Models;
+
+namespace LiteCharms.Features.Customers.Queries;
+
+public class GetCustomersQuery : IRequest<Result<Customer[]>>
+{
+    public DateOnly From { get; set; }
+
+    public DateOnly To { get; set; }
+
+    private GetCustomersQuery(DateOnly from, DateOnly to)
+    {
+        From = from;
+        To = to;
+    }
+
+    public static GetCustomersQuery Create(DateOnly from, DateOnly to)
+    {
+        if (from > to)
+            throw new ArgumentException("From date cannot be greater than To date.");
+
+        return new(from, to);
+    }
+}

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

@@ -0,0 +1,29 @@
+using LiteCharms.Extensions;
+using LiteCharms.Infrastructure.Database;
+using LiteCharms.Models;
+
+namespace LiteCharms.Features.Customers.Queries.Handlers;
+
+public class GetCustomerOrdersQueryHandler(IDbContextFactory<LeadGeneratorDbContext> contextFactory) : IRequestHandler<GetCustomerOrdersQuery, Result<Order[]>>
+{
+    public async ValueTask<Result<Order[]>> Handle(GetCustomerOrdersQuery request, CancellationToken cancellationToken)
+    {
+		try
+		{
+            using var context = await contextFactory.CreateDbContextAsync(cancellationToken);
+
+            var orders = await context.Orders.AsNoTracking()
+                .OrderByDescending(o => o.CreatedAt)
+                .Where(o => o.CustomerId == request.CustomerId)
+                .ToArrayAsync(cancellationToken);
+
+            return orders?.Length > 0
+                ? Result.Ok(orders.Select(o => o.ToModel()).ToArray())
+                : Result.Fail<Order[]>(new Error($"No orders found for customer with Id {request.CustomerId}."));
+        }
+		catch (Exception ex)
+		{
+            return Result.Fail<Order[]>(new Error(ex.Message).CausedBy(ex));
+        }
+    }
+}

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

@@ -0,0 +1,31 @@
+using LiteCharms.Extensions;
+using LiteCharms.Infrastructure.Database;
+using LiteCharms.Models;
+
+namespace LiteCharms.Features.Customers.Queries.Handlers;
+
+public class GetCustomerRefundsQueryHandler(IDbContextFactory<LeadGeneratorDbContext> contextFactory) : IRequestHandler<GetCustomerRefundsQuery, Result<OrderRefund[]>>
+{
+    public async ValueTask<Result<OrderRefund[]>> Handle(GetCustomerRefundsQuery request, CancellationToken cancellationToken)
+    {
+		try
+		{
+            using var context = await contextFactory.CreateDbContextAsync(cancellationToken);
+
+            if(!await context.Customers.AnyAsync(c => c.Id == request.CustomerId, cancellationToken))
+                return Result.Fail<OrderRefund[]>(new Error($"Customer with Id {request.CustomerId} does not exist."));
+
+            var refunds = await context.OrderRefunds.AsNoTracking().AsSplitQuery()
+                .OrderByDescending(o => o.CreatedAt)
+                .Where(r => r.Order!.CustomerId == request.CustomerId).ToArrayAsync(cancellationToken);
+
+            return refunds?.Length > 0 
+                ? Result.Ok(refunds.Select(r => r.ToModel()).ToArray()) 
+                : Result.Fail<OrderRefund[]>(new Error($"No refunds found for customer with Id {request.CustomerId}."));
+        }
+		catch (Exception ex)
+		{
+            return Result.Fail<OrderRefund[]>(new Error(ex.Message).CausedBy(ex));
+        }
+    }
+}

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

@@ -0,0 +1,32 @@
+using LiteCharms.Extensions;
+using LiteCharms.Infrastructure.Database;
+using LiteCharms.Models;
+
+namespace LiteCharms.Features.Customers.Queries.Handlers;
+
+public class GetCustomersQueryHandler(IDbContextFactory<LeadGeneratorDbContext> contextFactory) : IRequestHandler<GetCustomersQuery, Result<Customer[]>>
+{
+    public async ValueTask<Result<Customer[]>> Handle(GetCustomersQuery 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 customers = await context.Customers.AsNoTracking()
+                .OrderByDescending(o => o.CreatedAt)
+                .Where(c => c.CreatedAt >= fromDate && c.CreatedAt <= toDate)
+                .ToArrayAsync(cancellationToken);
+
+            return customers?.Length > 0
+                ? Result.Ok(customers.Select(c => c.ToModel()).ToArray())
+                : Result.Fail<Customer[]>(new Error("No customers found in the specified date range."));
+        }
+		catch (Exception ex)
+		{
+            return Result.Fail<Customer[]>(new Error(ex.Message).CausedBy(ex));
+        }
+    }
+}

LiteCharms.Features/Leads/Commands/CreateLeadCommand.cs

@@ -0,0 +1,49 @@
+namespace LiteCharms.Features.Leads.Commands;
+
+public class CreateLeadCommand : IRequest<Result<Guid>>
+{
+    public Guid? CustomerId { get; set; }
+
+    public string? GoogleClickId { get; set; }
+
+    public string? WebClickId { get; set; }
+
+    public string? AppClickId { get; set; }
+
+    public long? CampaignId { get; set; }
+
+    public long? AdGroupId { get; set; }
+
+    public long? AdName { get; set; }
+
+    public long? TargetId { get; set; }
+
+    public long? FeedItemId { get; set; }
+
+    public string? ClickLocation { get; set; }
+
+    public string? AttribusionHash { get; set; }
+
+    private CreateLeadCommand(Guid? customerId, string googleClickId, string webClickId, string appClickId, long? campaignId, long? adGroupId, long? adName, long? targetId, long? feedItemId, string? clickLocation, string? attribusionHash)
+    {
+        CustomerId = customerId;
+        GoogleClickId = googleClickId;
+        WebClickId = webClickId;
+        AppClickId = appClickId;
+        CampaignId = campaignId;
+        AdGroupId = adGroupId;
+        AdName = adName;
+        TargetId = targetId;
+        FeedItemId = feedItemId;
+        ClickLocation = clickLocation;
+        AttribusionHash = attribusionHash;
+    }
+
+    public static CreateLeadCommand Create(Guid? customerId, string googleClickId, string webClickId, string appClickId, long? campaignId, long? adGroupId, long? adName, long? targetId, long? feedItemId, string? clickLocation, string? attribusionHash)
+    {
+        if (string.IsNullOrWhiteSpace(googleClickId) || string.IsNullOrWhiteSpace(appClickId) || string.IsNullOrWhiteSpace(webClickId))
+            throw new ArgumentException("Google ClickId, App ClickId and Web ClickId are required to create a lead.");
+
+        return new(customerId, googleClickId, webClickId, appClickId, campaignId, adGroupId, adName, targetId, feedItemId, clickLocation, attribusionHash);
+    }
+}

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

@@ -0,0 +1,46 @@
+using LiteCharms.Features.Utilities.Commands;
+using LiteCharms.Infrastructure.Database;
+
+namespace LiteCharms.Features.Leads.Commands.Handlers;
+
+public class CreateLeadCommandHandler(IDbContextFactory<LeadGeneratorDbContext> contextFactory, ISender mediator) : IRequestHandler<CreateLeadCommand, Result<Guid>>
+{
+    public async ValueTask<Result<Guid>> Handle(CreateLeadCommand request, CancellationToken cancellationToken)
+    {
+        try
+        {
+            var hashCommand = ComputeHashCommand.Create($"{request.GoogleClickId}{request.AppClickId}{request.WebClickId}");
+            var hashResult = await mediator.Send(hashCommand, cancellationToken);
+
+            if(hashResult.IsFailed)
+                return Result.Fail<Guid>(new Error($"Failed to compute hash for lead -> Google ClickId: {request.GoogleClickId}, App ClickId: {request.AppClickId}, Web ClickId: {request.WebClickId}")
+                    .CausedBy(hashResult.Errors));
+
+            using var context = await contextFactory.CreateDbContextAsync(cancellationToken);
+
+            var newLead = context.Leads.Add(new Entities.Lead
+            {
+                WebClickId = request.WebClickId,
+                AppClickId = request.AppClickId,
+                GoogleClickId = request.GoogleClickId,
+                AdGroupId = request.AdGroupId,
+                AdName = request.AdName,
+                CampaignId = request.CampaignId,
+                ClickLocation = request.ClickLocation,
+                CustomerId = request.CustomerId,
+                FeedItemId = request.FeedItemId,
+                Status = Models.LeadStatus.New,
+                TargetId = request.TargetId,
+                AttributionHash = hashResult.Value
+            });
+
+            return await context.SaveChangesAsync(cancellationToken) > 0
+                ? Result.Ok(newLead.Entity.Id)
+                : Result.Fail<Guid>(new Error($"Failed to create lead -> Google ClickId: {request.GoogleClickId}, App ClickId: {request.AppClickId}, Web ClickId: {request.WebClickId}"));
+        }
+        catch (Exception ex)
+        {
+            return Result.Fail<Guid>(new Error(ex.Message).CausedBy(ex));
+        }
+    }
+}

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

@@ -0,0 +1,29 @@
+using LiteCharms.Infrastructure.Database;
+
+namespace LiteCharms.Features.Leads.Commands.Handlers;
+
+public class UpdateLeadCommandHandler(IDbContextFactory<LeadGeneratorDbContext> contextFactory) : IRequestHandler<UpdateLeadCommand, Result>
+{
+    public async ValueTask<Result> Handle(UpdateLeadCommand request, CancellationToken cancellationToken)
+    {
+        try
+        {
+            using var context = await contextFactory.CreateDbContextAsync(cancellationToken);
+
+            var lead = await context.Leads.FirstOrDefaultAsync(l => l.Id == request.LeadId, cancellationToken);
+
+            if (lead is null)
+                return Result.Fail(new Error($"Lead with ID {request.LeadId} not found."));
+
+            lead.Status = request.Status;
+
+            return await context.SaveChangesAsync(cancellationToken) > 0
+                ? Result.Ok()
+                : Result.Fail(new Error($"Failed to update the lead {request.LeadId}."));
+        }
+        catch (Exception ex)
+        {
+            return Result.Fail(new Error(ex.Message).CausedBy(ex));
+        }
+    }
+}

LiteCharms.Features/Leads/Commands/UpdateLeadCommand.cs

@@ -0,0 +1,27 @@
+using LiteCharms.Models;
+
+namespace LiteCharms.Features.Leads.Commands;
+
+public class UpdateLeadCommand : IRequest<Result>
+{
+    public Guid LeadId { get; set; }
+
+    public LeadStatus Status { get; set; }
+
+    private UpdateLeadCommand(Guid leadId, LeadStatus status)
+    {
+        LeadId = leadId;
+        Status = status;
+    }
+
+    public static UpdateLeadCommand Create(Guid leadId, LeadStatus status)
+    {
+        if (leadId == Guid.Empty)
+            throw new ArgumentException("Lead ID cannot be empty.", nameof(leadId));
+
+        if (!Enum.IsDefined(typeof(LeadStatus), status))
+            throw new ArgumentException("Invalid lead status.", nameof(status));
+
+        return new(leadId, status);
+    }
+}

LiteCharms.Features/Leads/Queries/GetCustomerLeadsQuery.cs

@@ -0,0 +1,30 @@
+using LiteCharms.Models;
+
+namespace LiteCharms.Features.Leads.Queries;
+
+public class GetCustomerLeadsQuery : IRequest<Result<Lead[]>>
+{
+    public Guid CustomerId { get; }
+
+    public DateOnly From { get; set; }
+
+    public DateOnly To { get; set; }
+
+    private GetCustomerLeadsQuery(Guid customerId, DateOnly from, DateOnly to)
+    {
+        CustomerId = customerId;
+        From = from;
+        To = to;
+    }
+
+    public static GetCustomerLeadsQuery Create(Guid customerId, DateOnly from, DateOnly to)
+    {
+        if(customerId == Guid.Empty)
+            throw new ArgumentException("Customer ID cannot be empty.", nameof(customerId));
+
+        if(from > to)
+            throw new ArgumentException("The 'From' date cannot be later than the 'To' date.");
+
+        return new(customerId, from, to);
+    }
+}

LiteCharms.Features/Leads/Queries/GetLeadsQuery.cs

@@ -0,0 +1,24 @@
+using LiteCharms.Models;
+
+namespace LiteCharms.Features.Leads.Queries;
+
+public class GetLeadsQuery : IRequest<Result<Lead[]>>
+{
+    public DateOnly From { get; set; }
+
+    public DateOnly To { get; set; }
+
+    private GetLeadsQuery(DateOnly from, DateOnly to)
+    {
+        From = from;
+        To = to;
+    }
+
+    public static GetLeadsQuery Create(DateOnly from, DateOnly to)
+    {
+        if (from > to)
+            throw new ArgumentException("From date cannot be greater than To date.");
+
+        return new(from, to);
+    }
+}

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

@@ -0,0 +1,33 @@
+using LiteCharms.Extensions;
+using LiteCharms.Infrastructure.Database;
+using LiteCharms.Models;
+
+namespace LiteCharms.Features.Leads.Queries.Handlers;
+
+public class GetCustomerLeadsQueryHandler(IDbContextFactory<LeadGeneratorDbContext> contextFactory) : IRequestHandler<GetCustomerLeadsQuery, Result<Lead[]>>
+{
+    public async ValueTask<Result<Lead[]>> Handle(GetCustomerLeadsQuery 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 leads = await context.Leads.AsNoTracking()
+                .OrderByDescending(o => o.CreatedAt)
+                .Where(lead => lead.CustomerId == request.CustomerId)
+                .Where(lead => lead.CreatedAt.Date >= fromDate && lead.CreatedAt.Date <= toDate)
+                .ToArrayAsync(cancellationToken);
+
+            return leads?.Length > 0
+                ? Result.Ok(leads.Select(l => l.ToModel()).ToArray())
+                : Result.Fail(new Error($"No customer {request.CustomerId} leads found for the specified date range {request.From} to {request.To}."));
+        }
+		catch (Exception ex)
+		{
+            return Result.Fail<Lead[]>(new Error(ex.Message).CausedBy(ex));
+        }
+    }
+}

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

@@ -0,0 +1,32 @@
+using LiteCharms.Extensions;
+using LiteCharms.Infrastructure.Database;
+using LiteCharms.Models;
+
+namespace LiteCharms.Features.Leads.Queries.Handlers;
+
+public class GetLeadsQueryHandler(IDbContextFactory<LeadGeneratorDbContext> contextFactory) : IRequestHandler<GetLeadsQuery, Result<Lead[]>>
+{
+    public async ValueTask<Result<Lead[]>> Handle(GetLeadsQuery 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 leads = await context.Leads.AsNoTracking()
+                .OrderByDescending(o => o.CreatedAt)
+                .Where(l => l.CreatedAt.Date >= fromDate && l.CreatedAt.Date <= toDate)
+                .ToArrayAsync(cancellationToken);
+
+            return leads?.Length > 0 
+                ? Result.Ok(leads.Select(l => l.ToModel()).ToArray()) 
+                : Result.Fail(new Error($"No leads found for the specified date range {request.From} to {request.To}."));
+        }
+		catch (Exception ex)
+		{
+            return Result.Fail(new Error(ex.Message).CausedBy(ex));
+        }
+    }
+}

LiteCharms.Features/LiteCharms.Features.csproj

@@ -0,0 +1,53 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <TargetFramework>net10.0</TargetFramework>
+    <ImplicitUsings>enable</ImplicitUsings>
+    <Nullable>enable</Nullable>
+    <SignAssembly>True</SignAssembly>
+    <AssemblyOriginatorKeyFile>..\LiteCharms.snk</AssemblyOriginatorKeyFile>
+  </PropertyGroup>
+
+  <!-- Nuget Package Details -->
+  <PropertyGroup>
+    <PackageId>LiteCharms.Features</PackageId>
+    <Version>1.0.2</Version>
+    <Authors>Khwezi Mngoma</Authors>
+    <Company>Lite Charms (PTY) Ltd</Company>
+    <Description>Feature components for Lite Charms applications.</Description>
+    <PackageProjectUrl>https://gitea.khongisa.co.za/litecharms/leadgenerator</PackageProjectUrl>
+    <RepositoryUrl>https://gitea.khongisa.co.za/litecharms/leadgenerator.git</RepositoryUrl>
+    <RepositoryType>git</RepositoryType>
+    <PackageLicenseFile>LICENSE</PackageLicenseFile>
+    <PackageTags>utility;dotnet</PackageTags>
+    <PackageIcon>icon.png</PackageIcon>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <None Include="..\LICENSE" Pack="true" PackagePath="\" />
+    <None Include="..\icon.png" Pack="true" PackagePath="\" />
+  </ItemGroup>
+  
+  <!-- CQRS -->
+  <ItemGroup>
+    <PackageReference Include="FluentResults" Version="4.0.0" />
+    <PackageReference Include="Mediator.Abstractions" Version="3.0.2" />
+
+    <!-- Global Usings -->
+    <Using Include="FluentResults" />
+    <Using Include="Mediator" />
+  </ItemGroup>
+
+  <!-- Shared Usings -->
+  <ItemGroup>
+    <Using Include="System.Text" />
+    <Using Include="System.Security.Cryptography" />
+    <Using Include="Microsoft.EntityFrameworkCore" />
+  </ItemGroup>
+
+  <ItemGroup>    
+    <ProjectReference Include="..\LiteCharms.Extensions\LiteCharms.Extensions.csproj" />
+    <ProjectReference Include="..\LiteCharms.Infrastructure\LiteCharms.Infrastructure.csproj" />
+  </ItemGroup>
+
+</Project>

LiteCharms.Features/Orders/Commands/CreateOrderCommand.cs

@@ -0,0 +1,25 @@
+namespace LiteCharms.Features.Orders.Commands;
+
+public class CreateOrderCommand : IRequest<Result<Guid>>
+{
+    public Guid CustomerId { get; set; }
+
+    public Guid ProductPriceId { get; set; }
+
+    private CreateOrderCommand(Guid customerId, Guid productPriceId)
+    {
+        CustomerId = customerId;
+        ProductPriceId = productPriceId;
+    }
+
+    public static CreateOrderCommand Create(Guid customerId, Guid productPriceId)
+    {
+        if (customerId == Guid.Empty)
+            throw new ArgumentException("CustomerId is required.", nameof(customerId));
+
+        if (productPriceId == Guid.Empty)
+            throw new ArgumentException("ProductPriceId is required.", nameof(productPriceId));
+
+        return new(customerId, productPriceId);
+    }
+}

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

@@ -0,0 +1,29 @@
+using LiteCharms.Infrastructure.Database;
+
+namespace LiteCharms.Features.Orders.Commands.Handlers;
+
+public class CreateOrderCommandHandler(IDbContextFactory<LeadGeneratorDbContext> contextFactory) : IRequestHandler<CreateOrderCommand, Result<Guid>>
+{
+    public async ValueTask<Result<Guid>> Handle(CreateOrderCommand request, CancellationToken cancellationToken)
+    {
+		try
+		{
+            using var context = await contextFactory.CreateDbContextAsync(cancellationToken);
+
+            var newOrder = context.Orders.Add(new Entities.Order
+            {
+                CustomerId = request.CustomerId,
+                ProductPriceId = request.ProductPriceId,
+                CreatedAt = DateTime.UtcNow
+            });
+
+            return await context.SaveChangesAsync(cancellationToken) > 0
+                ? Result.Ok(newOrder.Entity.Id)
+                : Result.Fail<Guid>(new Error($"Failed to create customer {request.CustomerId} order using product price {request.ProductPriceId}."));
+        }
+		catch (Exception ex)
+		{
+            return Result.Fail<Guid>(new Error(ex.Message).CausedBy(ex));
+        }
+    }
+}

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

@@ -0,0 +1,29 @@
+using LiteCharms.Infrastructure.Database;
+
+namespace LiteCharms.Features.Orders.Commands.Handlers;
+
+public class UpdateOrderCommandHandler(IDbContextFactory<LeadGeneratorDbContext> contextFactory) : IRequestHandler<UpdateOrderCommand, Result>
+{
+    public async ValueTask<Result> Handle(UpdateOrderCommand request, CancellationToken cancellationToken)
+    {
+		try
+		{
+            using var context = await contextFactory.CreateDbContextAsync(cancellationToken);
+
+            var order = await context.Orders.FirstOrDefaultAsync(o => o.Id == request.OrderId, cancellationToken);
+
+            if (order is null)
+                return Result.Fail(new Error($"Order {request.OrderId} not found"));
+
+            order.Status = request.Status;
+
+            return await context.SaveChangesAsync(cancellationToken) > 0
+                ? Result.Ok()
+                : Result.Fail(new Error($"Failed to update order {request.OrderId}"));
+        }
+		catch (Exception ex)
+		{
+            return Result.Fail(new Error(ex.Message).CausedBy(ex));
+        }
+    }
+}

LiteCharms.Features/Orders/Commands/UpdateOrderCommand.cs

@@ -0,0 +1,30 @@
+using LiteCharms.Models;
+
+namespace LiteCharms.Features.Orders.Commands;
+
+public class UpdateOrderCommand : IRequest<Result>
+{
+    public Guid OrderId { get; set; }
+
+    public OrderStatus Status { get; set; }
+
+    public string? Note { get; set; }
+
+    private UpdateOrderCommand(Guid orderId, OrderStatus status, string? note)
+    {
+        OrderId = orderId;
+        Status = status;
+        Note = note;
+    }
+
+    public static UpdateOrderCommand Create(Guid orderId, OrderStatus status, string? note)
+    {
+        if (orderId == Guid.Empty)
+            throw new ArgumentException("OrderId is required.", nameof(orderId));
+
+        if (!Enum.IsDefined(typeof(OrderStatus), status))
+            throw new ArgumentException("Invalid order status.", nameof(status));
+
+        return new(orderId, status, note);
+    }
+}

LiteCharms.Features/Orders/Queries/GetOrderRefundQuery.cs

@@ -0,0 +1,27 @@
+using LiteCharms.Models;
+
+namespace LiteCharms.Features.Orders.Queries;
+
+public class GetOrderRefundQuery : IRequest<Result<OrderRefund>>
+{
+    public Guid OrderId { get; set; }
+
+    public Guid OrderRefundId { get; set; }
+
+    private GetOrderRefundQuery(Guid orderId, Guid orderRefundId)
+    {
+        OrderId = orderId;
+        OrderRefundId = orderRefundId;
+    }
+
+    public static GetOrderRefundQuery Create(Guid orderId, Guid orderRefundId)
+    {
+        if (orderId == Guid.Empty)
+            throw new ArgumentException("OrderId is required.", nameof(orderId));
+
+        if (orderRefundId == Guid.Empty)
+            throw new ArgumentException("OrderRefundId is required.", nameof(orderRefundId));
+
+        return new(orderId, orderRefundId);
+    }
+}

LiteCharms.Features/Orders/Queries/GetOrdersQuery.cs

@@ -0,0 +1,24 @@
+using LiteCharms.Models;
+
+namespace LiteCharms.Features.Orders.Queries;
+
+public class GetOrdersQuery : IRequest<Result<Order[]>>
+{
+    public DateOnly From { get; set; }
+
+    public DateOnly To { get; set; }
+
+    private GetOrdersQuery(DateOnly from, DateOnly to)
+    {
+        From = from;
+        To = to;
+    }
+
+    public static GetOrdersQuery Create(DateOnly from, DateOnly to)
+    {
+        if (from > to)
+            throw new ArgumentException("From date cannot be greater than To date.");
+
+        return new(from, to);
+    }
+}

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

@@ -0,0 +1,27 @@
+using LiteCharms.Extensions;
+using LiteCharms.Infrastructure.Database;
+using LiteCharms.Models;
+
+namespace LiteCharms.Features.Orders.Queries.Handlers;
+
+public class GetOrderRefundQueryHandler(IDbContextFactory<LeadGeneratorDbContext> contextFactory) : IRequestHandler<GetOrderRefundQuery, Result<OrderRefund>>
+{
+    public async ValueTask<Result<OrderRefund>> Handle(GetOrderRefundQuery request, CancellationToken cancellationToken)
+    {
+		try
+		{
+            using var context = await contextFactory.CreateDbContextAsync(cancellationToken);
+
+            var refund = await context.OrderRefunds.AsNoTracking()
+                .FirstOrDefaultAsync(r => r.OrderId == request.OrderId && r.Id == request.OrderRefundId, cancellationToken);
+            
+            return refund is not null
+                ? Result.Ok(refund.ToModel())
+                : Result.Fail<OrderRefund>(new Error($"Refund {request.OrderRefundId} not found for the given OrderId: {request.OrderId}"));
+        }
+		catch (Exception ex)
+		{
+            return Result.Fail<OrderRefund>(new Error(ex.Message).CausedBy(ex));
+        }
+    }
+}

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

@@ -0,0 +1,32 @@
+using LiteCharms.Extensions;
+using LiteCharms.Infrastructure.Database;
+using LiteCharms.Models;
+
+namespace LiteCharms.Features.Orders.Queries.Handlers;
+
+public class GetOrdersQueryHandler(IDbContextFactory<LeadGeneratorDbContext> contextFactory) : IRequestHandler<GetOrdersQuery, Result<Order[]>>
+{
+    public async ValueTask<Result<Order[]>> Handle(GetOrdersQuery 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 orders = await context.Orders
+                .OrderByDescending(o => o.CreatedAt)
+                .Where(o => o.CreatedAt >= fromDate && o.CreatedAt <= toDate)
+                .ToArrayAsync(cancellationToken);   
+
+            return orders?.Length > 0
+                ? Result.Ok(orders.Select(o => o.ToModel()).ToArray())
+                : Result.Fail<Order[]>(new Error($"No orders found for the specified date range {request.From} - {request.To}."));
+        }
+		catch (Exception ex)
+		{
+            return Result.Fail<Order[]>(new Error(ex.Message).CausedBy(ex));
+        }
+    }
+}

LiteCharms.Features/Products/Queries/GetProductPriceQuery.cs

@@ -0,0 +1,18 @@
+using LiteCharms.Models;
+
+namespace LiteCharms.Features.Products.Queries;
+
+public class GetProductPriceQuery : IRequest<Result<ProductPrice>>
+{
+    public Guid ProductId { get; set; }
+
+    private GetProductPriceQuery(Guid productId) => ProductId = productId;
+
+    public static GetProductPriceQuery Create(Guid productId)
+    {
+        if (productId == Guid.Empty)
+            throw new ArgumentException("ProductId is required.", nameof(productId));
+
+        return new(productId);
+    }
+}

LiteCharms.Features/Products/Queries/GetProductQuery.cs

@@ -0,0 +1,18 @@
+using LiteCharms.Models;
+
+namespace LiteCharms.Features.Products.Queries;
+
+public class GetProductQuery : IRequest<Result<Product>>
+{
+    public Guid ProductId { get; set; }
+
+    private GetProductQuery(Guid productId) => ProductId = productId;
+
+    public static GetProductQuery Create(Guid productId)
+    {
+        if(productId == Guid.Empty)
+            throw new ArgumentException("Product ID is required.", nameof(productId));
+
+        return new(productId);
+    }
+}

LiteCharms.Features/Products/Queries/GetProductsQuery.cs

@@ -0,0 +1,8 @@
+using LiteCharms.Models;
+
+namespace LiteCharms.Features.Products.Queries;
+
+public class GetProductsQuery : IRequest<Result<Product[]>>
+{
+    public static GetProductsQuery Create() => new();
+}

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

@@ -0,0 +1,29 @@
+using LiteCharms.Extensions;
+using LiteCharms.Infrastructure.Database;
+using LiteCharms.Models;
+
+namespace LiteCharms.Features.Products.Queries.Handlers;
+
+public class GetProductPriceQueryHandler(IDbContextFactory<LeadGeneratorDbContext> contextFactory) : IRequestHandler<GetProductPriceQuery, Result<ProductPrice>>
+{
+    public async ValueTask<Result<ProductPrice>> Handle(GetProductPriceQuery request, CancellationToken cancellationToken)
+    {
+		try
+		{
+            using var context = await contextFactory.CreateDbContextAsync(cancellationToken);
+
+            var productPrice = await context.ProductPrices.AsNoTracking()
+                .Where(pp => pp.ProductId == request.ProductId && pp.Active)
+                .OrderByDescending(pp => pp.CreatedAt)
+                .FirstOrDefaultAsync(cancellationToken);
+
+            return productPrice is not null 
+                ? Result.Ok(productPrice.ToModel())
+                : Result.Fail<ProductPrice>(new Error($"Product price {request.ProductId} not found."));
+        }
+        catch (Exception ex)
+		{
+            return Result.Fail<ProductPrice>(new Error(ex.Message).CausedBy(ex));
+        }
+    }
+}

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

@@ -0,0 +1,26 @@
+using LiteCharms.Extensions;
+using LiteCharms.Infrastructure.Database;
+using LiteCharms.Models;
+
+namespace LiteCharms.Features.Products.Queries.Handlers;
+
+public class GetProductQueryHandler(IDbContextFactory<LeadGeneratorDbContext> contextFactory) : IRequestHandler<GetProductQuery, Result<Product>>
+{
+    public async ValueTask<Result<Product>> Handle(GetProductQuery request, CancellationToken cancellationToken)
+    {
+		try
+		{
+            using var context = await contextFactory.CreateDbContextAsync(cancellationToken);
+
+            var product = await context.Products.FirstOrDefaultAsync(p => p.Id == request.ProductId, cancellationToken);
+
+            return product is not null
+                ? Result.Ok(product.ToModel())
+                : Result.Fail<Product>(new Error($"Product with ID {request.ProductId} not found."));
+        }
+		catch (Exception ex)
+		{
+            return Result.Fail<Product>(new Error(ex.Message).CausedBy(ex));
+        }
+    }
+}

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

@@ -0,0 +1,26 @@
+using LiteCharms.Extensions;
+using LiteCharms.Infrastructure.Database;
+using LiteCharms.Models;
+
+namespace LiteCharms.Features.Products.Queries.Handlers;
+
+public class GetProductsQueryHandler(IDbContextFactory<LeadGeneratorDbContext> contextFactory) : IRequestHandler<GetProductsQuery, Result<Product[]>>
+{
+    public async ValueTask<Result<Product[]>> Handle(GetProductsQuery request, CancellationToken cancellationToken)
+    {
+		try
+		{
+            using var context = await contextFactory.CreateDbContextAsync(cancellationToken);
+
+            var products = await context.Products.AsNoTracking()
+                .OrderByDescending(o => o.Id)
+                .ToArrayAsync(cancellationToken);
+
+            return Result.Ok(products.Select(p => p.ToModel()).ToArray());
+        }
+		catch (Exception ex)
+		{
+            return Result.Fail<Product[]>(new Error(ex.Message).CausedBy(ex));
+        }
+    }
+}

LiteCharms.Features/Utilities/Commands/ComputeHashCommand.cs

@@ -0,0 +1,16 @@
+namespace LiteCharms.Features.Utilities.Commands;
+
+public class ComputeHashCommand : IRequest<Result<string>>
+{
+    public string? Input { get; set; }
+
+    private ComputeHashCommand(string input) => Input = input;
+
+    public static ComputeHashCommand Create(string input)
+    {
+        if(string.IsNullOrWhiteSpace(input))
+            throw new ArgumentException("Input is required", nameof(input));
+
+        return new(input);
+    }
+}

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

@@ -0,0 +1,18 @@
+namespace LiteCharms.Features.Utilities.Commands.Handlers;
+
+public class ComputeHashCommandHandler : IRequestHandler<ComputeHashCommand, Result<string>>
+{
+    public async ValueTask<Result<string>> Handle(ComputeHashCommand request, CancellationToken cancellationToken)
+    {
+		try
+		{
+            var bytes = SHA256.HashData(Encoding.UTF8.GetBytes(request.Input!));
+
+            return Result.Ok(Convert.ToHexString(bytes));
+        }
+		catch (Exception ex)
+		{
+            return Result.Fail<string>(new Error(ex.Message).CausedBy(ex));
+        }
+    }
+}