Merge commit '32d1019eb5a96665d31572405c362e83a1fec02d'

Reviewed-on: #14

.drone.yml

@@ -0,0 +1,71 @@
+---
+kind: pipeline
+type: docker
+name: litecharms-nuget-libraries
+
+steps:
+  - name: build
+    image: mcr.microsoft.com/dotnet/sdk:10.0
+    commands:
+      - dotnet restore
+      - dotnet build -c Release --no-restore
+
+  - name: pack-and-publish
+    image: mcr.microsoft.com/dotnet/sdk:10.0
+    environment:
+      NEXUS_KEY: { from_secret: nexus_api_key }
+      NEXUS_URL: https://nexus.khongisa.co.za/repository/nuget-hosted/
+      VERSION: 1.${DRONE_BUILD_NUMBER}.0
+    commands:
+      # Abstractions
+      - dotnet pack LiteCharms.Abstractions/LiteCharms.Abstractions.csproj -c Release -p:PackageVersion=$VERSION -o dist/
+      - dotnet nuget push dist/LiteCharms.Abstractions.$VERSION.nupkg --api-key $NEXUS_KEY --source $NEXUS_URL
+
+      # Models
+      - dotnet pack LiteCharms.Models/LiteCharms.Models.csproj -c Release -p:PackageVersion=$VERSION -o dist/
+      - dotnet nuget push dist/LiteCharms.Models.$VERSION.nupkg --api-key $NEXUS_KEY --source $NEXUS_URL
+
+      # Infrastructure
+      - dotnet pack LiteCharms.Infrastructure/LiteCharms.Infrastructure.csproj -c Release -p:PackageVersion=$VERSION -o dist/
+      - dotnet nuget push dist/LiteCharms.Infrastructure.$VERSION.nupkg --api-key $NEXUS_KEY --source $NEXUS_URL
+
+      # Features
+      - dotnet pack LiteCharms.Features/LiteCharms.Features.csproj -c Release -p:PackageVersion=$VERSION -o dist/
+      - dotnet nuget push dist/LiteCharms.Features.$VERSION.nupkg --api-key $NEXUS_KEY --source $NEXUS_URL
+
+      # Extensions
+      - dotnet pack LiteCharms.Extensions/LiteCharms.Extensions.csproj -c Release -p:PackageVersion=$VERSION -o dist/
+      - dotnet nuget push dist/LiteCharms.Extensions.$VERSION.nupkg --api-key $NEXUS_KEY --source $NEXUS_URL
+
+      # Entities
+      - 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:
+  event:
+    - pull_request

.editorconfig

@@ -0,0 +1,248 @@
+# Remove the line below if you want to inherit .editorconfig settings from higher directories
+root = true
+
+# C# files
+[*.cs]
+
+#### Core EditorConfig Options ####
+
+# Indentation and spacing
+indent_size = 4
+indent_style = space
+tab_width = 4
+
+# New line preferences
+end_of_line = crlf
+insert_final_newline = false
+
+#### .NET Code Actions ####
+
+# Type members
+dotnet_hide_advanced_members = false
+dotnet_member_insertion_location = with_other_members_of_the_same_kind
+dotnet_property_generation_behavior = prefer_throwing_properties
+
+# Symbol search
+dotnet_search_reference_assemblies = true
+
+#### .NET Coding Conventions ####
+
+# Organize usings
+dotnet_separate_import_directive_groups = false
+dotnet_sort_system_directives_first = false
+file_header_template = unset
+
+# this. and Me. preferences
+dotnet_style_qualification_for_event = false
+dotnet_style_qualification_for_field = false
+dotnet_style_qualification_for_method = false
+dotnet_style_qualification_for_property = false
+
+# Language keywords vs BCL types preferences
+dotnet_style_predefined_type_for_locals_parameters_members = true
+dotnet_style_predefined_type_for_member_access = true
+
+# Parentheses preferences
+dotnet_style_parentheses_in_arithmetic_binary_operators = always_for_clarity
+dotnet_style_parentheses_in_other_binary_operators = always_for_clarity
+dotnet_style_parentheses_in_other_operators = never_if_unnecessary
+dotnet_style_parentheses_in_relational_binary_operators = always_for_clarity
+
+# Modifier preferences
+dotnet_style_require_accessibility_modifiers = for_non_interface_members
+
+# Expression-level preferences
+dotnet_prefer_system_hash_code = true
+dotnet_style_coalesce_expression = true
+dotnet_style_collection_initializer = true
+dotnet_style_explicit_tuple_names = true
+dotnet_style_namespace_match_folder = true
+dotnet_style_null_propagation = true
+dotnet_style_object_initializer = true
+dotnet_style_operator_placement_when_wrapping = beginning_of_line
+dotnet_style_prefer_auto_properties = true
+dotnet_style_prefer_collection_expression = when_types_loosely_match
+dotnet_style_prefer_compound_assignment = true
+dotnet_style_prefer_conditional_expression_over_assignment = true
+dotnet_style_prefer_conditional_expression_over_return = true
+dotnet_style_prefer_foreach_explicit_cast_in_source = when_strongly_typed
+dotnet_style_prefer_inferred_anonymous_type_member_names = true
+dotnet_style_prefer_inferred_tuple_names = true
+dotnet_style_prefer_is_null_check_over_reference_equality_method = true
+dotnet_style_prefer_non_hidden_explicit_cast_in_source = true
+dotnet_style_prefer_simplified_boolean_expressions = true
+dotnet_style_prefer_simplified_interpolation = true
+
+# Field preferences
+dotnet_style_readonly_field = true
+
+# Parameter preferences
+dotnet_code_quality_unused_parameters = all
+
+# Suppression preferences
+dotnet_remove_unnecessary_suppression_exclusions = none
+
+# New line preferences
+dotnet_style_allow_multiple_blank_lines_experimental = true
+dotnet_style_allow_statement_immediately_after_block_experimental = true
+
+#### C# Coding Conventions ####
+
+# var preferences
+csharp_style_var_elsewhere = false
+csharp_style_var_for_built_in_types = false
+csharp_style_var_when_type_is_apparent = false
+
+# Expression-bodied members
+csharp_style_expression_bodied_accessors = true
+csharp_style_expression_bodied_constructors = false
+csharp_style_expression_bodied_indexers = true
+csharp_style_expression_bodied_lambdas = true
+csharp_style_expression_bodied_local_functions = true
+csharp_style_expression_bodied_methods = false
+csharp_style_expression_bodied_operators = false
+csharp_style_expression_bodied_properties = true
+
+# Pattern matching preferences
+csharp_style_pattern_matching_over_as_with_null_check = true
+csharp_style_pattern_matching_over_is_with_cast_check = true
+csharp_style_prefer_extended_property_pattern = true
+csharp_style_prefer_not_pattern = true
+csharp_style_prefer_pattern_matching = true
+csharp_style_prefer_switch_expression = true
+
+# Null-checking preferences
+csharp_style_conditional_delegate_call = true
+
+# Modifier preferences
+csharp_prefer_static_anonymous_function = true
+csharp_prefer_static_local_function = true
+csharp_preferred_modifier_order = public,private,protected,internal,file,static,extern,new,virtual,abstract,sealed,override,readonly,unsafe,required,volatile,async
+csharp_style_prefer_readonly_struct = true
+csharp_style_prefer_readonly_struct_member = true
+
+# Code-block preferences
+csharp_prefer_braces = true
+csharp_prefer_simple_using_statement = true
+csharp_prefer_system_threading_lock = true
+csharp_style_namespace_declarations = block_scoped
+csharp_style_prefer_method_group_conversion = true
+csharp_style_prefer_primary_constructors = true
+csharp_style_prefer_simple_property_accessors = true
+csharp_style_prefer_top_level_statements = true
+
+# Expression-level preferences
+csharp_prefer_simple_default_expression = true
+csharp_style_deconstructed_variable_declaration = true
+csharp_style_implicit_object_creation_when_type_is_apparent = true
+csharp_style_inlined_variable_declaration = true
+csharp_style_prefer_implicitly_typed_lambda_expression = true
+csharp_style_prefer_index_operator = true
+csharp_style_prefer_local_over_anonymous_function = true
+csharp_style_prefer_null_check_over_type_check = true
+csharp_style_prefer_range_operator = true
+csharp_style_prefer_tuple_swap = true
+csharp_style_prefer_unbound_generic_type_in_nameof = true
+csharp_style_prefer_utf8_string_literals = true
+csharp_style_throw_expression = true
+csharp_style_unused_value_assignment_preference = discard_variable
+csharp_style_unused_value_expression_statement_preference = discard_variable
+
+# 'using' directive preferences
+csharp_using_directive_placement = outside_namespace
+
+# New line preferences
+csharp_style_allow_blank_line_after_colon_in_constructor_initializer_experimental = true
+csharp_style_allow_blank_line_after_token_in_arrow_expression_clause_experimental = true
+csharp_style_allow_blank_line_after_token_in_conditional_expression_experimental = true
+csharp_style_allow_blank_lines_between_consecutive_braces_experimental = true
+csharp_style_allow_embedded_statements_on_same_line_experimental = true
+
+#### C# Formatting Rules ####
+
+# New line preferences
+csharp_new_line_before_catch = true
+csharp_new_line_before_else = true
+csharp_new_line_before_finally = true
+csharp_new_line_before_members_in_anonymous_types = true
+csharp_new_line_before_members_in_object_initializers = true
+csharp_new_line_before_open_brace = all
+csharp_new_line_between_query_expression_clauses = true
+
+# Indentation preferences
+csharp_indent_block_contents = true
+csharp_indent_braces = false
+csharp_indent_case_contents = true
+csharp_indent_case_contents_when_block = true
+csharp_indent_labels = one_less_than_current
+csharp_indent_switch_labels = true
+
+# Space preferences
+csharp_space_after_cast = false
+csharp_space_after_colon_in_inheritance_clause = true
+csharp_space_after_comma = true
+csharp_space_after_dot = false
+csharp_space_after_keywords_in_control_flow_statements = true
+csharp_space_after_semicolon_in_for_statement = true
+csharp_space_around_binary_operators = before_and_after
+csharp_space_around_declaration_statements = false
+csharp_space_before_colon_in_inheritance_clause = true
+csharp_space_before_comma = false
+csharp_space_before_dot = false
+csharp_space_before_open_square_brackets = false
+csharp_space_before_semicolon_in_for_statement = false
+csharp_space_between_empty_square_brackets = false
+csharp_space_between_method_call_empty_parameter_list_parentheses = false
+csharp_space_between_method_call_name_and_opening_parenthesis = false
+csharp_space_between_method_call_parameter_list_parentheses = false
+csharp_space_between_method_declaration_empty_parameter_list_parentheses = false
+csharp_space_between_method_declaration_name_and_open_parenthesis = false
+csharp_space_between_method_declaration_parameter_list_parentheses = false
+csharp_space_between_parentheses = false
+csharp_space_between_square_brackets = false
+
+# Wrapping preferences
+csharp_preserve_single_line_blocks = true
+csharp_preserve_single_line_statements = true
+
+#### Naming styles ####
+
+# Naming rules
+
+dotnet_naming_rule.interface_should_be_begins_with_i.severity = suggestion
+dotnet_naming_rule.interface_should_be_begins_with_i.symbols = interface
+dotnet_naming_rule.interface_should_be_begins_with_i.style = begins_with_i
+
+dotnet_naming_rule.types_should_be_pascal_case.severity = suggestion
+dotnet_naming_rule.types_should_be_pascal_case.symbols = types
+dotnet_naming_rule.types_should_be_pascal_case.style = pascal_case
+
+dotnet_naming_rule.non_field_members_should_be_pascal_case.severity = suggestion
+dotnet_naming_rule.non_field_members_should_be_pascal_case.symbols = non_field_members
+dotnet_naming_rule.non_field_members_should_be_pascal_case.style = pascal_case
+
+# Symbol specifications
+
+dotnet_naming_symbols.interface.applicable_kinds = interface
+dotnet_naming_symbols.interface.applicable_accessibilities = public, internal, private, protected, protected_internal, private_protected
+dotnet_naming_symbols.interface.required_modifiers = 
+
+dotnet_naming_symbols.types.applicable_kinds = class, struct, interface, enum
+dotnet_naming_symbols.types.applicable_accessibilities = public, internal, private, protected, protected_internal, private_protected
+dotnet_naming_symbols.types.required_modifiers = 
+
+dotnet_naming_symbols.non_field_members.applicable_kinds = property, event, method
+dotnet_naming_symbols.non_field_members.applicable_accessibilities = public, internal, private, protected, protected_internal, private_protected
+dotnet_naming_symbols.non_field_members.required_modifiers = 
+
+# Naming styles
+
+dotnet_naming_style.pascal_case.required_prefix = 
+dotnet_naming_style.pascal_case.required_suffix = 
+dotnet_naming_style.pascal_case.word_separator = 
+dotnet_naming_style.pascal_case.capitalization = pascal_case
+
+dotnet_naming_style.begins_with_i.required_prefix = I
+dotnet_naming_style.begins_with_i.required_suffix = 
+dotnet_naming_style.begins_with_i.word_separator = 
+dotnet_naming_style.begins_with_i.capitalization = pascal_case

LiteCharms.Abstractions/Constants.cs

@@ -0,0 +1,12 @@
+namespace LiteCharms.Abstractions;
+
+public static class Constants
+{
+    public const int QueueBounds = 100000;
+
+    public const string ShopSchedulerName = "shop";
+
+    public const string EmailServiceBus = nameof(EmailServiceBus);
+    public const string GeneralServiceBus = nameof(GeneralServiceBus);
+    public const string SalesServiceBus = nameof(SalesServiceBus);
+}

LiteCharms.Abstractions/EventBusQueueBase.cs

@@ -0,0 +1,10 @@
+namespace LiteCharms.Abstractions;
+
+public abstract class EventBusQueueBase
+{
+    protected readonly Channel<IEvent> channel = Channel.CreateBounded<IEvent>(Constants.QueueBounds);
+
+    public ChannelWriter<IEvent> Outgoing => channel.Writer;
+
+    public ChannelReader<IEvent> Incoming => channel.Reader;
+}

LiteCharms.Abstractions/IEvent.cs

@@ -0,0 +1,12 @@
+namespace LiteCharms.Abstractions;
+
+public interface IEvent : INotification
+{
+    Guid Id { get; set; }
+
+    string Name { get; set; }
+
+    DateTimeOffset EnqueueAt { get; set; }
+
+    string CorrelationId { get; set; }
+}

LiteCharms.Abstractions/IEventBus.cs

@@ -0,0 +1,7 @@
+namespace LiteCharms.Abstractions;
+
+public interface IEventBus
+{
+    Task<Result> PublishAsync<TEvent>(TEvent notification, CancellationToken cancellationToken = default)
+        where TEvent : class, IEvent;
+}

LiteCharms.Abstractions/IEventBusQueue.cs

@@ -0,0 +1,8 @@
+namespace LiteCharms.Abstractions;
+
+public interface IEventBusQueue
+{
+    ChannelWriter<IEvent> Outgoing { get; }
+
+    ChannelReader<IEvent> Incoming { get; }
+}

LiteCharms.Abstractions/IJobOrchestrator.cs

@@ -0,0 +1,10 @@
+namespace LiteCharms.Abstractions;
+
+public interface IJobOrchestrator
+{
+    Task SendAsync<TNotification>(TNotification notification, CancellationToken cancellationToken = default)
+        where TNotification : IEvent;
+
+    Task ScheduleAsync<TNotification>(TNotification notification, string cronExpression, CancellationToken cancellationToken = default) 
+        where TNotification : IEvent;
+}

LiteCharms.Abstractions/LiteCharms.Abstractions.csproj

@@ -0,0 +1,40 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <TargetFramework>net10.0</TargetFramework>
+    <ImplicitUsings>enable</ImplicitUsings>
+    <Nullable>enable</Nullable>
+    <SignAssembly>True</SignAssembly>
+    <AssemblyOriginatorKeyFile>..\LiteCharms.snk</AssemblyOriginatorKeyFile>
+  </PropertyGroup>
+
+  <!-- Nuget Package Details -->
+  <PropertyGroup>
+    <PackageId>LiteCharms.Abstractions</PackageId>
+    <Version>1.0.20</Version>
+    <Authors>Khwezi Mngoma</Authors>
+    <Company>Lite Charms (PTY) Ltd</Company>
+    <Description>Shared abstractions for Lite Charms applications.</Description>
+    <PackageProjectUrl>https://gitea.khongisa.co.za/litecharms/components</PackageProjectUrl>
+    <RepositoryUrl>https://gitea.khongisa.co.za/litecharms/components.git</RepositoryUrl>
+    <RepositoryType>git</RepositoryType>
+    <PackageLicenseFile>LICENSE</PackageLicenseFile>
+    <PackageTags>utility;dotnet</PackageTags>
+    <PackageIcon>icon.png</PackageIcon>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <None Include="..\LICENSE" Pack="true" PackagePath="\" />
+    <None Include="..\icon.png" Pack="true" PackagePath="\" />
+  </ItemGroup>
+  
+  <ItemGroup>
+    <PackageReference Include="FluentResults" Version="4.0.0" />
+    <PackageReference Include="Mediator.Abstractions" Version="3.0.2" />
+
+    <Using Include="Mediator" />
+    <Using Include="FluentResults" />
+    <Using Include="System.Threading.Channels" />
+  </ItemGroup>
+
+</Project>

LiteCharms.Abstractions/Timezones.cs

@@ -0,0 +1,27 @@
+namespace LiteCharms.Abstractions;
+
+public static class Timezones
+{
+    public static TimeZoneInfo SouthAfricanTimeZone => TimeZoneInfo.FindSystemTimeZoneById("South Africa Standard Time");
+
+    public static string? LocaliseDateTime(this DateTime dateTime, TimeSpan offset) => offset.Hours > 0
+        ? $"{dateTime:yyyy-MM-ddTHH:mm:ss.fff}+{offset.Hours:00}:{offset.Minutes:00}"
+        : $"{dateTime:yyyy-MM-ddTHH:mm:ss.fff}{offset.Hours:00}:{offset.Minutes:00}";
+
+    public static string? LocaliseDateTimeOffset(this DateTimeOffset dateTime, TimeSpan offset) => LocaliseDateTime(dateTime.DateTime, offset);
+
+    public static DateTimeOffset ToDateTimeWithTimeZone(this DateTime source, TimeZoneInfo? timezone = null)
+    {
+        DateTime sourceDateAdjusted = source.Kind != DateTimeKind.Utc
+            ? new(source.Ticks, DateTimeKind.Utc)
+            : source;
+
+        var localised = timezone is null
+            ? new DateTimeOffset(sourceDateAdjusted.Ticks, SouthAfricanTimeZone.BaseUtcOffset).LocaliseDateTimeOffset(SouthAfricanTimeZone.BaseUtcOffset)
+            : new DateTimeOffset(sourceDateAdjusted.Ticks, timezone!.BaseUtcOffset).LocaliseDateTimeOffset(timezone.BaseUtcOffset);
+
+        return DateTimeOffset.Parse(localised!);
+    }
+
+    public static DateTimeOffset UtcNow(this TimeZoneInfo timezone) => ToDateTimeWithTimeZone(DateTime.Now, timezone);
+}

LiteCharms.Entities/Configuration/LeadConfiguration.cs

@@ -10,7 +10,8 @@ public class LeadConfiguration : IEntityTypeConfiguration<Lead>
         builder.Property(f => f.CreatedAt).ValueGeneratedOnAdd();
         builder.Property(f => f.UpdatedAt).IsRequired(false).ValueGeneratedOnUpdate();
         builder.Property(f => f.CustomerId).IsRequired(false);
-        builder.Property(f => f.GoogleClickId);
+        builder.Property(f => f.Source);
+        builder.Property(f => f.ClickId);
         builder.Property(f => f.WebClickId);
         builder.Property(f => f.AppClickId);
         builder.Property(f => f.CampaignId);

LiteCharms.Entities/Configuration/NotificationConfiguration.cs

@@ -0,0 +1,26 @@
+namespace LiteCharms.Entities.Configuration;
+
+public class NotificationConfiguration : IEntityTypeConfiguration<Notification>
+{
+    public void Configure(EntityTypeBuilder<Notification> builder)
+    {
+        builder.ToTable(nameof(Notification));
+
+        builder.HasKey(f => f.Id);
+        builder.Property(f => f.CreatedAt).IsRequired().ValueGeneratedOnAdd();
+        builder.Property(f => f.UpdatedAt).IsRequired(false).ValueGeneratedOnUpdate();
+        builder.Property(f => f.Direction).IsRequired();
+        builder.Property(f => f.Platform).IsRequired();
+        builder.Property(f => f.Priority).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);
+    }
+}

LiteCharms.Entities/Configuration/OrderConfiguration.cs

@@ -10,14 +10,18 @@ public class OrderConfiguration : IEntityTypeConfiguration<Order>
         builder.Property(f => f.CreatedAt).ValueGeneratedOnAdd();
         builder.Property(f => f.UpdatedAt).IsRequired(false).ValueGeneratedOnUpdate();
         builder.Property(f => f.CustomerId).IsRequired();
+        builder.Property(f => f.QuoteId).IsRequired(false);
         builder.Property(f => f.RefundId).IsRequired(false);
-        builder.Property(f => f.ProductPriceId).IsRequired();
+        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.ProductPrice)
-            .WithMany()
-            .HasForeignKey(f => f.ProductPriceId)
+        builder.HasOne(f => f.Quote)
+            .WithOne(f => f.Order)
+            .HasForeignKey<Order>(f => f.QuoteId)
             .OnDelete(DeleteBehavior.Restrict);
 
         builder.HasOne(f => f.Customer)

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

@@ -0,0 +1,23 @@
+namespace LiteCharms.Entities.Configuration;
+
+public class QuoteConfiguration : IEntityTypeConfiguration<Quote>
+{
+    public void Configure(EntityTypeBuilder<Quote> builder)
+    {
+        builder.ToTable(nameof(Quote));
+
+        builder.HasKey(f => f.Id);
+        builder.Property(f => f.CreatedAt).IsRequired().ValueGeneratedOnAdd();
+        builder.Property(f => f.UpdatedAt).IsRequired(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.ShoppingCartId).IsRequired();
+        builder.Property(f => f.Reason).IsRequired(false);
+
+        builder.HasOne(f => f.Customer)
+            .WithMany()
+            .HasForeignKey(f => f.CustomerId)
+            .OnDelete(DeleteBehavior.Cascade);
+    }
+}

LiteCharms.Entities/Configuration/ShoppingCartConfiguration.cs

@@ -0,0 +1,31 @@
+namespace LiteCharms.Entities.Configuration;
+
+public class ShoppingCartConfiguration : IEntityTypeConfiguration<ShoppingCart>
+{
+    public void Configure(EntityTypeBuilder<ShoppingCart> builder)
+    {
+        builder.ToTable(nameof(ShoppingCart));
+
+        builder.HasKey(f =>  f.Id);
+        builder.Property(f => f.CreatedAt).IsRequired().ValueGeneratedOnAdd();
+        builder.Property(f => f.UpdatedAt).IsRequired(false).ValueGeneratedOnUpdate();
+        builder.Property(f => f.CustomerId).IsRequired(false);
+        builder.Property(f => f.OrderId).IsRequired(false);
+        builder.Property(f => f.QuoteId).IsRequired(false);        
+
+        builder.HasOne(f => f.Customer)
+            .WithMany(c => c.ShoppingCarts)
+            .HasForeignKey(f => f.CustomerId)
+            .OnDelete(DeleteBehavior.NoAction);
+
+        builder.HasOne(f => f.Order)
+            .WithOne(o => o.ShoppingCart)
+            .HasForeignKey<Order>(o => o.ShoppingCartId)
+            .OnDelete(DeleteBehavior.NoAction);
+
+        builder.HasOne(f => f.Quote)
+            .WithOne(o => o.ShoppingCart)
+            .HasForeignKey<Quote>(o => o.ShoppingCartId)
+            .OnDelete(DeleteBehavior.NoAction);
+    }
+}

LiteCharms.Entities/Configuration/ShoppingCartItemConfiguration.cs

@@ -0,0 +1,25 @@
+namespace LiteCharms.Entities.Configuration;
+
+public class ShoppingCartItemConfiguration : IEntityTypeConfiguration<ShoppingCartItem>
+{
+    public void Configure(EntityTypeBuilder<ShoppingCartItem> builder)
+    {
+        builder.ToTable(nameof(ShoppingCartItem));
+
+        builder.HasKey(f => f.Id);
+        builder.Property(f => f.CreatedAt).IsRequired().ValueGeneratedOnAdd();
+        builder.Property(f => f.UpdatedAt).IsRequired(false).ValueGeneratedOnUpdate();
+        builder.Property(f => f.Quantity).IsRequired().HasDefaultValue(1);
+        builder.Property(f => f.ProductPriceId).IsRequired();
+
+        builder.HasOne(f => f.ProductPrice)
+            .WithMany()
+            .HasForeignKey(f => f.ProductPriceId)
+            .OnDelete(DeleteBehavior.NoAction);
+
+        builder.HasOne(f => f.ShoppingCart)
+            .WithMany(f => f.ShoppingCartItems)
+            .HasForeignKey(f => f.ShoppingCartId)
+            .OnDelete(DeleteBehavior.NoAction);
+    }
+}

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/Customer.cs

@@ -8,4 +8,8 @@ public class Customer : Models.Customer
     public virtual ICollection<Lead>? Leads { get; set; }
 
     public virtual ICollection<Order>? Orders { get; set; }
+
+    public virtual ICollection<Quote>? Quotes { get; set; }
+
+    public virtual ICollection<ShoppingCart>? ShoppingCarts { get; set; }
 }

LiteCharms.Entities/LiteCharms.Entities.csproj

@@ -11,7 +11,7 @@
   <!-- Nuget Package Details -->
   <PropertyGroup>
     <PackageId>LiteCharms.Entities</PackageId>
-    <Version>1.0.2</Version>
+    <Version>1.0.20</Version>
     <Authors>Khwezi Mngoma</Authors>
     <Company>Lite Charms (PTY) Ltd</Company>
     <Description>Shared entities for Lite Charms applications.</Description>

LiteCharms.Entities/Notification.cs

@@ -0,0 +1,6 @@
+using LiteCharms.Entities.Configuration;
+
+namespace LiteCharms.Entities;
+
+[EntityTypeConfiguration<NotificationConfiguration, Notification>]
+public class Notification : Models.Notification;

LiteCharms.Entities/Order.cs

@@ -9,5 +9,7 @@ public class Order : Models.Order
 
     public virtual Customer? Customer { get; set; }
 
-    public virtual ProductPrice? ProductPrice { get; set; }
+    public virtual Quote? Quote { get; set; }
+
+    public virtual ShoppingCart? ShoppingCart { get; set; }
 }

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/Quote.cs

@@ -0,0 +1,13 @@
+using LiteCharms.Entities.Configuration;
+
+namespace LiteCharms.Entities;
+
+[EntityTypeConfiguration<QuoteConfiguration, Quote>]
+public class Quote : Models.Quote
+{
+    public virtual Customer? Customer { get; set; }
+
+    public virtual ShoppingCart? ShoppingCart { get; set; }
+
+    public virtual Order? Order { get; set; }
+}

LiteCharms.Entities/ShoppingCart.cs

@@ -0,0 +1,15 @@
+using LiteCharms.Entities.Configuration;
+
+namespace LiteCharms.Entities;
+
+[EntityTypeConfiguration<ShoppingCartConfiguration, ShoppingCart>]
+public class ShoppingCart : Models.ShoppingCart
+{
+    public virtual Customer? Customer { get; set; }
+
+    public virtual Order? Order { get; set; }
+
+    public virtual Quote? Quote { get; set; }
+
+    public virtual ICollection<ShoppingCartItem>? ShoppingCartItems { get; set; }
+}

LiteCharms.Entities/ShoppingCartItem.cs

@@ -0,0 +1,8 @@
+namespace LiteCharms.Entities;
+
+public class ShoppingCartItem : Models.ShoppingCartItem
+{
+    public virtual ShoppingCart? ShoppingCart { get; set; }
+
+    public virtual ProductPrice? ProductPrice { 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/Email.cs

@@ -0,0 +1,13 @@
+using LiteCharms.Models.Configuraton.Email;
+
+namespace LiteCharms.Extensions;
+
+public static class Email
+{
+    public static IServiceCollection AddEmailServices(this IServiceCollection services, IConfiguration configuration)
+    {
+        services.Configure<SmtpSettings>(configuration.GetSection("Email"));
+
+        return services;
+    }
+}

LiteCharms.Extensions/EntityModeMappers.cs

@@ -4,6 +4,58 @@ namespace LiteCharms.Extensions;
 
 public static class EntityModeMappers
 {
+    public static ShoppingCartItem ToModel(this Entities.ShoppingCartItem entity) =>
+        new()
+        {
+            Id = entity.Id,
+            CreatedAt = entity.CreatedAt,
+            UpdatedAt = entity.UpdatedAt,
+            ProductPriceId = entity.ProductPriceId,
+            Quantity = entity.Quantity,
+            ShoppingCartId = entity.ShoppingCartId            
+        };
+
+    public static ShoppingCart ToModel(this Entities.ShoppingCart entity) =>
+        new()
+        {
+            Id = entity.Id,
+            CreatedAt = entity.CreatedAt,
+            UpdatedAt = entity.UpdatedAt,
+            CustomerId = entity.CustomerId,
+            OrderId = entity.OrderId,
+            QuoteId = entity.QuoteId            
+        };
+
+    public static Quote ToModel(this Entities.Quote entity) =>
+        new()
+        {
+            Id = entity.Id,
+            CreatedAt = entity.CreatedAt,
+            UpdatedAt = entity.UpdatedAt,
+            CustomerId = entity.CustomerId,
+            ExpiredAt = entity.ExpiredAt,
+            Reason = entity.Reason,
+            ShoppingCartId = entity.ShoppingCartId,
+            Status = entity.Status            
+        };
+
+    public static Notification ToModel(this Entities.Notification entity) =>
+        new()
+        {
+            Id = entity.Id,
+            CreatedAt = entity.CreatedAt,
+            Message = entity.Message,
+            Direction = entity.Direction,
+            CorrelationId = entity.CorrelationId,
+            CorrelationIdType = entity.CorrelationIdType,
+            IsInternal = entity.IsInternal,
+            Sender = entity.Sender,
+            Platform = entity.Platform,
+            Recipient = entity.Recipient,
+            Subject = entity.Subject,
+            Processed = entity.Processed            
+        };
+
     public static Customer ToModel(this Entities.Customer entity) =>
         new()
         {
@@ -43,7 +95,8 @@ public static class EntityModeMappers
             ClickLocation = entity.ClickLocation,
             CustomerId = entity.CustomerId,
             FeedItemId = entity.FeedItemId,
-            GoogleClickId = entity.GoogleClickId,
+            Source = entity.Source,
+            ClickId = entity.ClickId,
             TargetId = entity.TargetId,
             WebClickId = entity.WebClickId,
             Status = entity.Status            
@@ -56,9 +109,11 @@ public static class EntityModeMappers
             CreatedAt = entity.CreatedAt,
             UpdatedAt = entity.UpdatedAt,
             CustomerId = entity.CustomerId,            
-            ProductPriceId = entity.ProductPriceId,
             Notes = entity.Notes,
-            RefundId = entity.RefundId            
+            RefundId = entity.RefundId,
+            QuoteId = entity.QuoteId,
+            Status = entity.Status,
+            ShoppingCartId = entity.ShoppingCartId            
         };
 
     public static OrderRefund ToModel(this Entities.OrderRefund entity) =>

LiteCharms.Extensions/HealthChecks.cs

@@ -0,0 +1,34 @@
+using LiteCharms.Infrastructure.HealthChecks;
+
+namespace LiteCharms.Extensions;
+
+public static class HealthChecks
+{
+    public static IServiceCollection AddQuartzHealtchCheck(this IServiceCollection services)
+    {
+        services.AddHealthChecks().AddCheck<QuartzHealthCheck>("Quartz");
+
+        return services;
+    }
+
+    public static IServiceCollection AddPostgresHealtchCheck(this IServiceCollection services)
+    {
+        services.AddHealthChecks().AddCheck<PostgresHealthCheck>("PostgreSQL");
+
+        return services;
+    }
+
+    public static IServiceCollection AddHealthChecksSupport(this IServiceCollection services, IConfiguration configuration)
+    {
+        services.AddHealthChecks()
+            .AddCheck("Self", () => HealthCheckResult.Healthy());
+
+        //services.AddHealthChecksUI(setup =>
+        //{
+        //    setup.AddHealthCheckEndpoint("Lead Generator", $"{configuration["ASPNETCORE_URLS"]}/health");
+        //    setup.SetEvaluationTimeInSeconds(15);
+        //}).AddInMemoryStorage(databaseName: "healthuidb");
+
+        return services;
+    }
+}

LiteCharms.Extensions/LiteCharms.Extensions.csproj

@@ -6,12 +6,23 @@
     <Nullable>enable</Nullable>
     <SignAssembly>True</SignAssembly>
     <AssemblyOriginatorKeyFile>..\LiteCharms.snk</AssemblyOriginatorKeyFile>
+    <JsonSerializerIsReflectionEnabledByDefault>true</JsonSerializerIsReflectionEnabledByDefault>
+  </PropertyGroup>
+
+  <!-- Warnings And Exclusions -->
+  <PropertyGroup>
+    <NoWarn>$(NoWarn);MA0004</NoWarn>
+    <!-- https://github.com/dotnet/aspnetcore/issues/50836 -->
+    <NoWarn>$(NoWarn);AD0001</NoWarn>
+    <PublishTrimmed>true</PublishTrimmed>
+    <NoWarn>$(NoWarn);IL2080;IL2065;IL2075;IL2087;IL2057;IL2060;IL2070;IL2067;IL2072;IL2026;IL2104</NoWarn>
+    <NoWarn>$(NoWarn);IL2110;IL2111</NoWarn>
   </PropertyGroup>
   
   <!-- Nuget Package Details -->
   <PropertyGroup>
     <PackageId>LiteCharms.Extensions</PackageId>
-    <Version>1.0.7</Version>
+    <Version>1.0.20</Version>
     <Authors>Khwezi Mngoma</Authors>
     <Company>Lite Charms (PTY) Ltd</Company>
     <Description>Extension components for Lite Charms applications.</Description>
@@ -28,14 +39,6 @@
     <None Include="..\icon.png" Pack="true" PackagePath="\" />
   </ItemGroup>
 
-  <!-- Shared Usings -->
-  <ItemGroup>
-    <Using Include="Microsoft.AspNetCore.Builder" />
-    <Using Include="Microsoft.Extensions.Configuration" />
-    <Using Include="Microsoft.Extensions.DependencyInjection" />
-    <Using Include="Microsoft.Extensions.Logging" />
-  </ItemGroup>
-
   <!-- Health Checks -->
   <ItemGroup>
     <PackageReference Include="AspNetCore.HealthChecks.UI.Client" Version="9.0.0" />
@@ -45,6 +48,8 @@
     <PackageReference Include="AspNetCore.HealthChecks.UI.InMemory.Storage" Version="9.0.0" />
     <PackageReference Include="Microsoft.EntityFrameworkCore.InMemory" Version="10.0.7" />
     <PackageReference Include="Microsoft.Extensions.DependencyInjection" Version="10.0.7" />
+    <PackageReference Include="Quartz.AspNetCore" Version="3.18.1" />
+    <PackageReference Include="Quartz.Extensions.DependencyInjection" Version="3.18.1" />
 
     <!-- Global Usings -->
     <Using Include="Microsoft.Extensions.Diagnostics.HealthChecks" />
@@ -58,6 +63,7 @@
     <PackageReference Include="OpenTelemetry.Instrumentation.AspNetCore" Version="1.15.2" />
     <PackageReference Include="OpenTelemetry.Instrumentation.Http" Version="1.15.1" />
     <PackageReference Include="OpenTelemetry.Instrumentation.Runtime" Version="1.15.1" />
+    <PackageReference Include="OpenTelemetry.Exporter.Console" Version="1.15.3" />
 
     <!-- Global Usings -->
     <Using Include="OpenTelemetry.Resources" />
@@ -88,6 +94,16 @@
     <Using Include="Microsoft.EntityFrameworkCore.Metadata.Builders" />
   </ItemGroup>
 
+  <!-- Shared Usings -->
+  <ItemGroup>
+    <Using Include="Quartz" />
+    <Using Include="Microsoft.AspNetCore.Builder" />
+    <Using Include="Microsoft.Extensions.Configuration" />
+    <Using Include="Microsoft.Extensions.DependencyInjection" />
+    <Using Include="Microsoft.Extensions.Logging" />
+  </ItemGroup>
+  
+  <!-- Project References -->
   <ItemGroup>
     <ProjectReference Include="..\LiteCharms.Entities\LiteCharms.Entities.csproj" />
     <ProjectReference Include="..\LiteCharms.Infrastructure\LiteCharms.Infrastructure.csproj" />

LiteCharms.Extensions/Monitoring.cs

@@ -1,33 +1,7 @@
-using LiteCharms.Infrastructure.Database;
-using LiteCharms.Infrastructure.HealthChecks;
+namespace LiteCharms.Extensions;
 
-namespace LiteCharms.Extensions;
-
-public static class Services
+public static class Monitoring
 {
-    public static IServiceCollection AddHealthChecksSupport(this IServiceCollection services, IConfiguration configuration)
-    {
-        services.AddHealthChecks()
-            .AddCheck("Self", () => HealthCheckResult.Healthy())
-            .AddCheck<PostgresHealthCheck>("PostgreSQL");
-
-        //services.AddHealthChecksUI(setup =>
-        //{
-        //    setup.AddHealthCheckEndpoint("Lead Generator", $"{configuration["ASPNETCORE_URLS"]}/health");
-        //    setup.SetEvaluationTimeInSeconds(15);
-        //}).AddInMemoryStorage(databaseName: "healthuidb");
-
-        return services;
-    }
-
-    public static IServiceCollection AddLeadGeneratorDatabase(this IServiceCollection services, IConfiguration configuration)
-    {
-        services.AddPooledDbContextFactory<LeadGeneratorDbContext>(options =>
-            options.UseNpgsql(configuration.GetConnectionString("PostgresLeadGenerator")));
-
-        return services;
-    }
-
     public static WebApplicationBuilder AddMonitoring(this WebApplicationBuilder builder)
     {
         var serviceName = builder.Configuration.GetValue<string>("Monitoring:ServiceName") ?? "LiteCharms";

LiteCharms.Extensions/Postgres.cs

@@ -0,0 +1,14 @@
+using LiteCharms.Infrastructure.Database;
+
+namespace LiteCharms.Extensions;
+
+public static class Postgres
+{
+    public static IServiceCollection AddShopDatabase(this IServiceCollection services, IConfiguration configuration)
+    {
+        services.AddPooledDbContextFactory<ShopDbContext>(options =>
+            options.UseNpgsql(configuration.GetConnectionString("PostgresShop")));
+
+        return services;
+    }
+}

LiteCharms.Extensions/Quartz.cs

@@ -0,0 +1,99 @@
+using LiteCharms.Abstractions;
+using LiteCharms.Infrastructure.Quartz;
+
+namespace LiteCharms.Extensions;
+
+public static class Quartz
+{
+    private const string databaseConfigName = "PostgresScheduler";
+
+    public static IServiceCollection AddQuartzSchedulerClient(this IServiceCollection services, string schedulerName, IConfiguration configuration)
+    {
+        var connectionString = configuration.GetConnectionString(databaseConfigName);
+
+        services.ConfigureCommon();
+
+        services.AddQuartz(config =>
+        {
+            config.SchedulerName = schedulerName;
+            config.SchedulerId = "AUTO";
+                        
+            config.UseSimpleTypeLoader();
+            config.UseDefaultThreadPool(options => options.MaxConcurrency = 0);
+            config.UseTimeZoneConverter();
+
+            config.UsePersistentStore(storage =>
+            {
+                storage.PerformSchemaValidation = false;
+
+                storage.UseSystemTextJsonSerializer();
+                storage.SetProperty("quartz.jobStore.clustered", "true");
+                storage.SetProperty("quartz.jobStore.tablePrefix", "qrtz_");
+
+                storage.UsePostgres(connectionString!);
+                storage.UseClustering(cluster =>
+                {
+                    cluster.CheckinInterval = TimeSpan.FromSeconds(30);
+                    cluster.CheckinMisfireThreshold = TimeSpan.FromSeconds(2);
+                });
+            });
+        });
+
+        return services;
+    }
+
+    public static IServiceCollection AddQuartzScheduler(this IServiceCollection services, string schedulerName, IConfiguration configuration)
+    {
+        var connectionString = configuration.GetConnectionString(databaseConfigName);
+
+        services.ConfigureCommon();
+
+        services.AddQuartz(config =>
+        {
+            config.SchedulerName = schedulerName;
+            config.SchedulerId = "AUTO";
+            config.InterruptJobsOnShutdown = true;
+            config.InterruptJobsOnShutdownWithWait = true;
+            config.MaxBatchSize = 5;
+
+            config.UseSimpleTypeLoader();
+            config.UseDefaultThreadPool(options => options.MaxConcurrency = 1);
+            config.UseTimeZoneConverter();
+
+            config.UsePersistentStore(storage =>
+            {
+                storage.PerformSchemaValidation = false;
+
+                storage.UseSystemTextJsonSerializer();
+                storage.SetProperty("quartz.jobStore.clustered", "true");
+                storage.SetProperty("quartz.jobStore.tablePrefix", "qrtz_");
+
+                storage.UsePostgres(connectionString!);
+                storage.UseClustering(cluster =>
+                {
+                    cluster.CheckinInterval = TimeSpan.FromSeconds(30);
+                    cluster.CheckinMisfireThreshold = TimeSpan.FromSeconds(2);
+                });
+            });
+        });
+
+        return services;
+    }
+
+    private static IServiceCollection ConfigureCommon(this IServiceCollection services)
+    {
+        services.Configure<QuartzOptions>(options =>
+        {
+            options.Scheduling.IgnoreDuplicates = true;
+            options.Scheduling.OverWriteExistingData = true;
+            options["quartz.plugin.jobHistory.type"] = "Quartz.Plugin.History.LoggingJobHistoryPlugin, Quartz.Plugins";
+            options["quartz.plugin.triggerHistory.type"] = "Quartz.Plugin.History.LoggingTriggerHistoryPlugin, Quartz.Plugins";
+        });
+
+        services.AddTransient<RetryJobListener>();
+        services.AddTransient<IJobOrchestrator, JobOrchestrator>();
+        services.AddQuartzHostedService(options => options.WaitForJobsToComplete = true);
+
+        return services;
+    }
+}

LiteCharms.Extensions/ServiceBus.cs

@@ -0,0 +1,27 @@
+using LiteCharms.Abstractions;
+using LiteCharms.Infrastructure.ServiceBus;
+using LiteCharms.Infrastructure.ServiceBus.Exchanges;
+using LiteCharms.Infrastructure.ServiceBus.Queues;
+
+namespace LiteCharms.Extensions;
+
+public static class ServiceBus
+{
+    public static IServiceCollection AddGeneralServiceBus(this IServiceCollection services) => services
+        .AddSingleton<GeneralQueue>()
+        .AddHostedService<GeneralExchange>()
+        .AddKeyedSingleton<IEventBus, GeneralServiceBus>(Constants.GeneralServiceBus)
+        .AddMemoryCache();
+
+    public static IServiceCollection AddEmailServiceBus(this IServiceCollection services) => services
+        .AddSingleton<EmailQueue>()
+        .AddHostedService<EmailExchange>()
+        .AddKeyedTransient<IEventBus, EmailServiceBus>(Constants.EmailServiceBus)
+        .AddMemoryCache();
+
+    public static IServiceCollection AddSalesServiceBus(this IServiceCollection services) => services
+        .AddSingleton<SalesQueue>()
+        .AddHostedService<SalesExchange>()
+        .AddKeyedSingleton<IEventBus, SalesServiceBus>(Constants.SalesServiceBus)
+        .AddMemoryCache();
+}

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/GetCustomerQuery.cs

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

LiteCharms.Features/Customers/Queries/GetCustomersQuery.cs

@@ -8,17 +8,23 @@ public class GetCustomersQuery : IRequest<Result<Customer[]>>
 
     public DateOnly To { get; set; }
 
-    private GetCustomersQuery(DateOnly from, DateOnly to)
+    public int MaxRecords { get; set; }
+
+    private GetCustomersQuery(DateOnly from, DateOnly to, int maxRecords = 1000)
     {
         From = from;
         To = to;
+        MaxRecords = maxRecords;
     }
 
-    public static GetCustomersQuery Create(DateOnly from, DateOnly to)
+    public static GetCustomersQuery Create(DateOnly from, DateOnly to, int maxRecords = 1000)
     {
         if (from > to)
             throw new ArgumentException("From date cannot be greater than To date.");
 
-        return new(from, to);
+        if(maxRecords <= 0)
+            throw new ArgumentException("MaxRecords must be a positive integer.");
+
+        return new(from, to, maxRecords);
     }
 }

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

@@ -0,0 +1,26 @@
+using LiteCharms.Extensions;
+using LiteCharms.Infrastructure.Database;
+using LiteCharms.Models;
+
+namespace LiteCharms.Features.Customers.Queries.Handlers;
+
+public class GetCustomerQueryHandler(IDbContextFactory<ShopDbContext> contextFactory) : IRequestHandler<GetCustomerQuery, Result<Customer>>
+{
+    public async ValueTask<Result<Customer>> Handle(GetCustomerQuery request, CancellationToken cancellationToken)
+    {
+		try
+		{
+            using var context = await contextFactory.CreateDbContextAsync(cancellationToken);
+
+            var customer = await context.Customers.FirstOrDefaultAsync(c => c.Id == request.CustomerId, cancellationToken);
+
+            return customer is not null
+                ? Result.Ok(customer.ToModel())
+                : Result.Fail<Customer>($"Customer not found with id {request.CustomerId}");
+        }
+		catch (Exception ex)
+		{
+            return Result.Fail<Customer>(new Error(ex.Message).CausedBy(ex));
+        }
+    }
+}

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)
     {
@@ -18,6 +18,7 @@ public class GetCustomersQueryHandler(IDbContextFactory<LeadGeneratorDbContext>
             var customers = await context.Customers.AsNoTracking()
                 .OrderByDescending(o => o.CreatedAt)
                 .Where(c => c.CreatedAt >= fromDate && c.CreatedAt <= toDate)
+                .Take(request.MaxRecords)
                 .ToArrayAsync(cancellationToken);
 
             return customers?.Length > 0

LiteCharms.Features/Leads/Commands/CreateLeadCommand.cs

@@ -4,7 +4,9 @@ public class CreateLeadCommand : IRequest<Result<Guid>>
 {
     public Guid? CustomerId { get; set; }
 
-    public string? GoogleClickId { get; set; }
+    public string? Source { get; set; }
+
+    public string? ClickId { get; set; }
 
     public string? WebClickId { get; set; }
 
@@ -24,10 +26,11 @@ public class CreateLeadCommand : IRequest<Result<Guid>>
 
     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)
+    private CreateLeadCommand(Guid? customerId, string source, string clickId, string webClickId, string appClickId, long? campaignId, long? adGroupId, long? adName, long? targetId, long? feedItemId, string? clickLocation, string? attribusionHash)
     {
         CustomerId = customerId;
-        GoogleClickId = googleClickId;
+        Source = source;
+        ClickId = clickId;
         WebClickId = webClickId;
         AppClickId = appClickId;
         CampaignId = campaignId;
@@ -39,11 +42,14 @@ public class CreateLeadCommand : IRequest<Result<Guid>>
         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)
+    public static CreateLeadCommand Create(Guid? customerId, string source, string clickId, 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.");
+        if(string.IsNullOrWhiteSpace(source))
+            throw new ArgumentNullException("Lead source is required to create a lead.", nameof(source));
 
-        return new(customerId, googleClickId, webClickId, appClickId, campaignId, adGroupId, adName, targetId, feedItemId, clickLocation, attribusionHash);
+        if (string.IsNullOrWhiteSpace(clickId) || string.IsNullOrWhiteSpace(appClickId) || string.IsNullOrWhiteSpace(webClickId))
+            throw new ArgumentException("ClickId, App ClickId and Web ClickId are required to create a lead.");
+
+        return new(customerId, source, clickId, webClickId, appClickId, campaignId, adGroupId, adName, targetId, feedItemId, clickLocation, attribusionHash);
     }
 }

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

@@ -3,17 +3,17 @@ 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)
     {
         try
         {
-            var hashCommand = ComputeHashCommand.Create($"{request.GoogleClickId}{request.AppClickId}{request.WebClickId}");
+            var hashCommand = ComputeHashCommand.Create($"{request.ClickId}{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}")
+                return Result.Fail<Guid>(new Error($"Failed to compute hash for lead -> Google ClickId: {request.ClickId}, App ClickId: {request.AppClickId}, Web ClickId: {request.WebClickId}")
                     .CausedBy(hashResult.Errors));
 
             using var context = await contextFactory.CreateDbContextAsync(cancellationToken);
@@ -22,7 +22,8 @@ public class CreateLeadCommandHandler(IDbContextFactory<LeadGeneratorDbContext>
             {
                 WebClickId = request.WebClickId,
                 AppClickId = request.AppClickId,
-                GoogleClickId = request.GoogleClickId,
+                Source = request.Source,
+                ClickId = request.ClickId,
                 AdGroupId = request.AdGroupId,
                 AdName = request.AdName,
                 CampaignId = request.CampaignId,
@@ -36,7 +37,7 @@ public class CreateLeadCommandHandler(IDbContextFactory<LeadGeneratorDbContext>
 
             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}"));
+                : Result.Fail<Guid>(new Error($"Failed to create lead -> Google ClickId: {request.ClickId}, App ClickId: {request.AppClickId}, Web ClickId: {request.WebClickId}"));
         }
         catch (Exception ex)
         {

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/GetLeadsQuery.cs

@@ -8,17 +8,23 @@ public class GetLeadsQuery : IRequest<Result<Lead[]>>
 
     public DateOnly To { get; set; }
 
-    private GetLeadsQuery(DateOnly from, DateOnly to)
+    public int MaxRecords { get; set; }
+
+    private GetLeadsQuery(DateOnly from, DateOnly to, int maxRecords = 1000)
     {
         From = from;
         To = to;
+        MaxRecords = maxRecords;
     }
 
-    public static GetLeadsQuery Create(DateOnly from, DateOnly to)
+    public static GetLeadsQuery Create(DateOnly from, DateOnly to, int maxRecords = 1000)
     {
         if (from > to)
             throw new ArgumentException("From date cannot be greater than To date.");
 
-        return new(from, to);
+        if(maxRecords <= 0)
+            throw new ArgumentException("MaxRecords must be a positive integer.");
+
+        return new(from, to, maxRecords);
     }
 }

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)
     {
@@ -18,6 +18,7 @@ public class GetLeadsQueryHandler(IDbContextFactory<LeadGeneratorDbContext> cont
             var leads = await context.Leads.AsNoTracking()
                 .OrderByDescending(o => o.CreatedAt)
                 .Where(l => l.CreatedAt.Date >= fromDate && l.CreatedAt.Date <= toDate)
+                .Take(request.MaxRecords)
                 .ToArrayAsync(cancellationToken);
 
             return leads?.Length > 0 

LiteCharms.Features/LiteCharms.Features.csproj

@@ -11,7 +11,7 @@
   <!-- Nuget Package Details -->
   <PropertyGroup>
     <PackageId>LiteCharms.Features</PackageId>
-    <Version>1.0.9</Version>
+    <Version>1.0.20</Version>
     <Authors>Khwezi Mngoma</Authors>
     <Company>Lite Charms (PTY) Ltd</Company>
     <Description>Feature components for Lite Charms applications.</Description>
@@ -28,6 +28,16 @@
     <None Include="..\icon.png" Pack="true" PackagePath="\" />
   </ItemGroup>
 
+  <!-- Email -->
+  <ItemGroup>
+    <PackageReference Include="MailKit" Version="4.16.0" />
+    <PackageReference Include="MimeKit" Version="4.16.0" />
+    
+    <!-- Global Usings-->
+    <Using Include="MimeKit" />
+    <Using Include="MailKit.Net.Smtp" />
+  </ItemGroup>
+  
   <!-- CQRS -->
   <ItemGroup>
     <PackageReference Include="FluentResults" Version="4.0.0" />
@@ -43,6 +53,7 @@
     <Using Include="System.Text" />
     <Using Include="System.Security.Cryptography" />
     <Using Include="Microsoft.EntityFrameworkCore" />
+    <Using Include="Microsoft.Extensions.Options" />
   </ItemGroup>
 
   <ItemGroup>    

LiteCharms.Features/Notifications/Commands/CreateNotificationCommand.cs

@@ -0,0 +1,60 @@
+using LiteCharms.Models;
+
+namespace LiteCharms.Features.Notifications.Commands;
+
+public class CreateNotificationCommand : IRequest<Result<Guid>>
+{
+    public NotificationDirection Direction { get; set; }
+
+    public string? Author { get; set; }
+
+    public string? Title { get; set; }
+
+    public string? Description { get; set; }
+
+    public NotificationPlatforms Platform { get; set; }
+
+    public string? PlatformAddress { get; set; }
+
+    public string? CorrelationId { get; set; }
+
+    public string? CorrelationIdType { get; set; }
+
+    public bool IsInternal { get; set; }
+
+    private CreateNotificationCommand(NotificationDirection direction, string author, string title, string description, NotificationPlatforms platform, string platformAddress, string correlationId, string correlationIdType, bool isInternal)
+    {
+        Direction = direction;
+        Author = author;
+        Title = title;
+        Description = description;
+        Platform = platform;
+        PlatformAddress = platformAddress;
+        CorrelationId = correlationId;
+        CorrelationIdType = correlationIdType;
+        IsInternal = isInternal;
+    }
+
+    public static CreateNotificationCommand Create(NotificationDirection direction, string author, string title, string description, NotificationPlatforms platform, string platformAddress, string correlationId, string correlationIdType, bool isInternal)
+    {
+        if (string.IsNullOrWhiteSpace(author))
+            throw new ArgumentException("Author cannot be null or whitespace.", nameof(author));
+
+        if (string.IsNullOrWhiteSpace(title))
+            throw new ArgumentException("Title cannot be null or whitespace.", nameof(title));
+
+        if (string.IsNullOrWhiteSpace(description))
+            throw new ArgumentException("Description cannot be null or whitespace.", nameof(description));
+
+        if (string.IsNullOrWhiteSpace(platformAddress))
+            throw new ArgumentException("PlatformAddress cannot be null or whitespace.", nameof(platformAddress));
+
+        if (string.IsNullOrWhiteSpace(correlationId))
+            throw new ArgumentException("CorrelationId cannot be null or whitespace.", nameof(correlationId));
+
+        if (string.IsNullOrWhiteSpace(correlationIdType))
+            throw new ArgumentException("CorrelationIdType cannot be null or whitespace.", nameof(correlationIdType));
+
+        return new(direction, author, title, description, platform, platformAddress, correlationId, correlationIdType, isInternal);
+    }
+}

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

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

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

@@ -0,0 +1,29 @@
+using LiteCharms.Infrastructure.Database;
+
+namespace LiteCharms.Features.Notifications.Commands.Handlers;
+
+public class UpdateNotificationCommandHandler(IDbContextFactory<ShopDbContext> contextFactory) : IRequestHandler<UpdateNotificationCommand, Result>
+{
+    public async ValueTask<Result> Handle(UpdateNotificationCommand request, CancellationToken cancellationToken)
+    {
+		try
+		{
+            using var context = await contextFactory.CreateDbContextAsync(cancellationToken);
+
+            var notification = await context.Notifications.FirstOrDefaultAsync(n => n.Id == request.NotificationId, cancellationToken);
+
+            if(notification is null)
+                return Result.Fail(new Error($"Notification with id {request.NotificationId} not found."));
+
+            notification.Processed = request.Processed;
+
+            return await context.SaveChangesAsync(cancellationToken) > 0
+                ? Result.Ok()
+                : Result.Fail(new Error($"Failed to update notification with id {request.NotificationId}."));
+        }
+		catch (Exception ex)
+		{
+            return Result.Fail(new Error(ex.Message).CausedBy(ex));
+        }
+    }
+}

LiteCharms.Features/Notifications/Commands/UpdateNotificationCommand.cs

@@ -0,0 +1,22 @@
+namespace LiteCharms.Features.Notifications.Commands;
+
+public class UpdateNotificationCommand : IRequest<Result>
+{
+    public Guid NotificationId { get; set; }
+
+    public bool Processed { get; set; }
+
+    private UpdateNotificationCommand(Guid notificationId, bool processed)
+    {
+        NotificationId = notificationId;
+        Processed = processed;
+    }
+
+    public static UpdateNotificationCommand Create(Guid notificationId, bool processed) 
+    { 
+        if(notificationId == Guid.Empty)
+            throw new ArgumentException("Notification ID cannot be empty.", nameof(notificationId));
+
+        return new(notificationId, processed);
+    }
+}

LiteCharms.Features/Notifications/Queries/GetNotificationQuery.cs

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

LiteCharms.Features/Notifications/Queries/GetNotificationsQuery.cs

@@ -0,0 +1,30 @@
+using LiteCharms.Models;
+
+namespace LiteCharms.Features.Notifications.Queries;
+
+public class GetNotificationsQuery : IRequest<Result<Notification[]>>
+{
+    public DateOnly From { get; set; }
+
+    public DateOnly To { get; set; }
+
+    public int MaxRecords { get; set; }
+
+    private GetNotificationsQuery(DateOnly from, DateOnly to, int maxRecords = 1000)
+    {
+        From = from;
+        To = to;
+        MaxRecords = maxRecords;
+    }
+
+    public static GetNotificationsQuery Create(DateOnly from, DateOnly to, int maxRecords = 1000)
+    {
+        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.", nameof(maxRecords));
+
+        return new(from, to, maxRecords);
+    }
+}

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

@@ -0,0 +1,26 @@
+using LiteCharms.Extensions;
+using LiteCharms.Infrastructure.Database;
+using LiteCharms.Models;
+
+namespace LiteCharms.Features.Notifications.Queries.Handlers;
+
+public class GetNotificationQueryHandler(IDbContextFactory<ShopDbContext> contextFactory) : IRequestHandler<GetNotificationQuery, Result<Notification>>
+{
+    public async ValueTask<Result<Notification>> Handle(GetNotificationQuery request, CancellationToken cancellationToken)
+    {
+        try
+        {
+            await using var context = await contextFactory.CreateDbContextAsync(cancellationToken);
+
+            var notification = await context.Notifications.FindAsync(new object[] { request.NotificationId }, cancellationToken);
+
+            return notification is not null 
+                ? Result.Ok(notification.ToModel())
+                : Result.Fail<Notification>(new Error($"Notification with id {request.NotificationId} not found"));
+        }
+        catch (Exception ex)
+        {
+            return Result.Fail<Notification>(new Error(ex.Message).CausedBy(ex));
+        }
+    }
+}

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

@@ -0,0 +1,33 @@
+using LiteCharms.Extensions;
+using LiteCharms.Infrastructure.Database;
+using LiteCharms.Models;
+
+namespace LiteCharms.Features.Notifications.Queries.Handlers;
+
+public class GetNotificationsQueryHandler(IDbContextFactory<ShopDbContext> contextFactory) : IRequestHandler<GetNotificationsQuery, Result<Notification[]>>
+{
+    public async ValueTask<Result<Notification[]>> Handle(GetNotificationsQuery 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 notifications = await context.Notifications.AsNoTracking()
+                .Where(n => n.CreatedAt >= fromDate && n.CreatedAt <= toDate)
+                .OrderByDescending(n => n.CreatedAt)
+                .Take(request.MaxRecords)
+                .ToArrayAsync(cancellationToken);
+
+            return notifications?.Length > 0 
+                ? Result.Ok(notifications.Select(n => n.ToModel()).ToArray()) 
+                : Result.Fail(new Error($"No notifications 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/Orders/Commands/CreateOrderCommand.cs

@@ -4,22 +4,25 @@ public class CreateOrderCommand : IRequest<Result<Guid>>
 {
     public Guid CustomerId { get; set; }
 
-    public Guid ProductPriceId { get; set; }
+    public Guid ShoppingCartId { get; set; }
 
-    private CreateOrderCommand(Guid customerId, Guid productPriceId)
+    public Guid? QuoteId { get; set; }
+
+    private CreateOrderCommand(Guid customerId, Guid shoppingCartId, Guid? quoteId = null)
     {
         CustomerId = customerId;
-        ProductPriceId = productPriceId;
+        ShoppingCartId = shoppingCartId;
+        QuoteId = quoteId;
     }
 
-    public static CreateOrderCommand Create(Guid customerId, Guid productPriceId)
+    public static CreateOrderCommand Create(Guid customerId, Guid shoppingCartId, Guid? quoteId = null)
     {
         if (customerId == Guid.Empty)
             throw new ArgumentException("CustomerId is required.", nameof(customerId));
 
-        if (productPriceId == Guid.Empty)
-            throw new ArgumentException("ProductPriceId is required.", nameof(productPriceId));
+        if (shoppingCartId == Guid.Empty)
+            throw new ArgumentException("ShoppingCartId is required.", nameof(shoppingCartId));
 
-        return new(customerId, productPriceId);
+        return new(customerId, shoppingCartId, quoteId);
     }
 }

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

@@ -2,7 +2,7 @@
 
 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)
     {
@@ -10,16 +10,26 @@ public class CreateOrderCommandHandler(IDbContextFactory<LeadGeneratorDbContext>
 		{
             using var context = await contextFactory.CreateDbContextAsync(cancellationToken);
 
+            if(!await context.Customers.AnyAsync(c => c.Id == request.CustomerId, cancellationToken))
+                return Result.Fail<Guid>(new Error($"Customer {request.CustomerId} does not exist."));
+
+            if(!await context.ShoppingCarts.AnyAsync(sc => sc.Id == request.ShoppingCartId, cancellationToken))
+                return Result.Fail<Guid>(new Error($"Shopping cart {request.ShoppingCartId} does not exist."));
+
+            if(request.QuoteId.HasValue && !await context.Quotes.AnyAsync(q => q.Id == request.QuoteId.Value, cancellationToken))
+                return Result.Fail<Guid>(new Error($"Quote {request.QuoteId.Value} does not exist."));
+
             var newOrder = context.Orders.Add(new Entities.Order
             {
                 CustomerId = request.CustomerId,
-                ProductPriceId = request.ProductPriceId,
+                ShoppingCartId = request.ShoppingCartId,
+                QuoteId = request.QuoteId,
                 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}."));
+                : Result.Fail<Guid>(new Error($"Failed to create customer {request.CustomerId} order using shopping cart {request.ShoppingCartId}."));
         }
 		catch (Exception ex)
 		{

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

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

LiteCharms.Features/Orders/Commands/UpdateOrderStatusCommand.cs

@@ -2,7 +2,7 @@
 
 namespace LiteCharms.Features.Orders.Commands;
 
-public class UpdateOrderCommand : IRequest<Result>
+public class UpdateOrderStatusCommand : IRequest<Result>
 {
     public Guid OrderId { get; set; }
 
@@ -10,14 +10,14 @@ public class UpdateOrderCommand : IRequest<Result>
 
     public string? Note { get; set; }
 
-    private UpdateOrderCommand(Guid orderId, OrderStatus status, string? note)
+    private UpdateOrderStatusCommand(Guid orderId, OrderStatus status, string? note)
     {
         OrderId = orderId;
         Status = status;
         Note = note;
     }
 
-    public static UpdateOrderCommand Create(Guid orderId, OrderStatus status, string? note)
+    public static UpdateOrderStatusCommand Create(Guid orderId, OrderStatus status, string? note)
     {
         if (orderId == Guid.Empty)
             throw new ArgumentException("OrderId is required.", nameof(orderId));

LiteCharms.Features/Orders/Queries/GetCustomerOrdersQuery.cs

@@ -1,6 +1,6 @@
 using LiteCharms.Models;
 
-namespace LiteCharms.Features.Customers.Queries;
+namespace LiteCharms.Features.Orders.Queries;
 
 public class GetCustomerOrdersQuery : IRequest<Result<Order[]>>
 {

LiteCharms.Features/Orders/Queries/GetOrdersQuery.cs

@@ -8,17 +8,23 @@ public class GetOrdersQuery : IRequest<Result<Order[]>>
 
     public DateOnly To { get; set; }
 
-    private GetOrdersQuery(DateOnly from, DateOnly to)
+    public int MaxRecords { get; set; }
+
+    private GetOrdersQuery(DateOnly from, DateOnly to, int maxRecords = 1000)
     {
         From = from;
         To = to;
+        MaxRecords = maxRecords;
     }
 
-    public static GetOrdersQuery Create(DateOnly from, DateOnly to)
+    public static GetOrdersQuery Create(DateOnly from, DateOnly to, int maxRecords = 1000)
     {
         if (from > to)
             throw new ArgumentException("From date cannot be greater than To date.");
 
-        return new(from, to);
+        if(maxRecords <= 0)
+            throw new ArgumentException("MaxRecords must be a positive integer.");
+
+        return new(from, to, maxRecords);
     }
 }

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

@@ -2,9 +2,9 @@
 using LiteCharms.Infrastructure.Database;
 using LiteCharms.Models;
 
-namespace LiteCharms.Features.Customers.Queries.Handlers;
+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)
     {
@@ -12,6 +12,9 @@ public class GetCustomerOrdersQueryHandler(IDbContextFactory<LeadGeneratorDbCont
 		{
             using var context = await contextFactory.CreateDbContextAsync(cancellationToken);
 
+            if(!await context.Customers.AsNoTracking().AnyAsync(c => c.Id == request.CustomerId, cancellationToken))
+                return Result.Fail<Order[]>(new Error($"Customer with Id {request.CustomerId} does not exist."));
+
             var orders = await context.Orders.AsNoTracking()
                 .OrderByDescending(o => o.CreatedAt)
                 .Where(o => o.CustomerId == request.CustomerId)

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)
     {
@@ -18,6 +18,7 @@ public class GetOrdersQueryHandler(IDbContextFactory<LeadGeneratorDbContext> con
             var orders = await context.Orders
                 .OrderByDescending(o => o.CreatedAt)
                 .Where(o => o.CreatedAt >= fromDate && o.CreatedAt <= toDate)
+                .Take(request.MaxRecords)
                 .ToArrayAsync(cancellationToken);   
 
             return orders?.Length > 0

LiteCharms.Features/Products/Queries/GetProductPricesQuery.cs

@@ -0,0 +1,18 @@
+using LiteCharms.Models;
+
+namespace LiteCharms.Features.Products.Queries;
+
+public class GetProductPricesQuery : IRequest<Result<ProductPrice[]>>
+{
+    public int MaxRecords { get; set; }
+
+    private GetProductPricesQuery(int maxRecords = 1000) => MaxRecords = maxRecords;
+
+    public static GetProductPricesQuery Create(int maxRecords = 1000)
+    {
+        if (maxRecords <= 0)
+            throw new ArgumentOutOfRangeException(nameof(maxRecords), "MaxRecords must be greater than zero.");
+
+        return new(maxRecords);
+    }
+}

LiteCharms.Features/Products/Queries/GetProductsQuery.cs

@@ -4,5 +4,15 @@ namespace LiteCharms.Features.Products.Queries;
 
 public class GetProductsQuery : IRequest<Result<Product[]>>
 {
-    public static GetProductsQuery Create() => new();
+    public int MaxRecords { get; set; }
+
+    private GetProductsQuery(int maxRecords = 1000) => MaxRecords = maxRecords;
+
+    public static GetProductsQuery Create(int maxRecords = 1000)
+    {
+        if (maxRecords <= 0)
+            throw new ArgumentException("MaxRecords must be a positive integer.");
+
+        return new(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)
     {
@@ -12,6 +12,9 @@ public class GetProductPriceQueryHandler(IDbContextFactory<LeadGeneratorDbContex
 		{
             using var context = await contextFactory.CreateDbContextAsync(cancellationToken);
 
+            if(!await context.Products.AnyAsync(p => p.Id == request.ProductId, cancellationToken))
+                return Result.Fail<ProductPrice>(new Error($"Product {request.ProductId} not found."));
+
             var productPrice = await context.ProductPrices.AsNoTracking()
                 .Where(pp => pp.ProductId == request.ProductId && pp.Active)
                 .OrderByDescending(pp => pp.CreatedAt)

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

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

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)
     {
@@ -14,6 +14,7 @@ public class GetProductsQueryHandler(IDbContextFactory<LeadGeneratorDbContext> c
 
             var products = await context.Products.AsNoTracking()
                 .OrderByDescending(o => o.Id)
+                .Take(request.MaxRecords)
                 .ToArrayAsync(cancellationToken);
 
             return Result.Ok(products.Select(p => p.ToModel()).ToArray());

LiteCharms.Features/Quotes/Commands/AssignQuoteToOrderCommand.cs

@@ -0,0 +1,25 @@
+namespace LiteCharms.Features.Quotes.Commands;
+
+public class AssignQuoteToOrderCommand : IRequest<Result>
+{
+    public Guid OrderId { get; set; }
+
+    public Guid QuoteId { get; set; }
+
+    private AssignQuoteToOrderCommand(Guid orderId, Guid quoteId)
+    {
+        OrderId = orderId;
+        QuoteId = quoteId;
+    }
+
+    public static AssignQuoteToOrderCommand Create(Guid orderId, Guid quoteId)
+    {
+        if(orderId == Guid.Empty)
+            throw new ArgumentException("Order ID is required.", nameof(orderId));
+
+        if(quoteId == Guid.Empty)
+            throw new ArgumentException("Quote ID is required.", nameof(quoteId));
+
+        return new AssignQuoteToOrderCommand(orderId, quoteId);
+    }
+}

LiteCharms.Features/Quotes/Commands/AssignQuoteToShoppingCartCommand.cs

@@ -0,0 +1,25 @@
+namespace LiteCharms.Features.Quotes.Commands;
+
+public class AssignQuoteToShoppingCartCommand : IRequest<Result>
+{
+    public Guid QuoteId { get; set; }
+
+    public Guid ShoppingCartId { get; set; }
+
+    private AssignQuoteToShoppingCartCommand(Guid quoteId, Guid shoppingCartId)
+    {
+        QuoteId = quoteId;
+        ShoppingCartId = shoppingCartId;
+    }
+
+    public static AssignQuoteToShoppingCartCommand Create(Guid quoteId, Guid shoppingCartId)
+    {
+        if(quoteId == Guid.Empty)
+            throw new ArgumentException("QuoteId cannot be empty.", nameof(quoteId));
+
+        if (shoppingCartId == Guid.Empty)
+            throw new ArgumentException("ShoppingCartId cannot be empty.", nameof(shoppingCartId));
+
+        return new(quoteId, shoppingCartId);
+    }
+}

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

@@ -0,0 +1,35 @@
+using LiteCharms.Infrastructure.Database;
+
+namespace LiteCharms.Features.Quotes.Commands.Handlers;
+
+public class AssignQuoteToOrderCommandHandler(IDbContextFactory<ShopDbContext> contextFactory) : IRequestHandler<AssignQuoteToOrderCommand, Result>
+{
+    public async ValueTask<Result> Handle(AssignQuoteToOrderCommand 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 with id {request.OrderId} not found"));
+
+            if(!await context.Quotes.AnyAsync(q => q.Id == request.OrderId, cancellationToken))
+                return Result.Fail(new Error($"Quote with id {request.QuoteId} not found"));
+
+            if(order.QuoteId == request.QuoteId)
+                return Result.Fail(new Error($"Quote with id {request.QuoteId} is already assigned to order with id {request.OrderId}"));
+
+            order.QuoteId = request.QuoteId;
+
+            return await context.SaveChangesAsync(cancellationToken) > 0
+                ? Result.Ok()
+                : Result.Fail(new Error($"Failed to assign quote with id {request.QuoteId} to order with id {request.OrderId}"));
+        }
+        catch (Exception ex)
+        {
+            return Result.Fail(new Error(ex.Message).CausedBy(ex));
+        }
+    }
+}

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

@@ -0,0 +1,32 @@
+using LiteCharms.Infrastructure.Database;
+
+namespace LiteCharms.Features.Quotes.Commands.Handlers;
+
+public class AssignQuoteToShoppingCartCommandHandler(IDbContextFactory<ShopDbContext> contextFactory) : IRequestHandler<AssignQuoteToShoppingCartCommand, Result>
+{
+    public async ValueTask<Result> Handle(AssignQuoteToShoppingCartCommand request, CancellationToken cancellationToken)
+    {
+		try
+		{
+            using var context = await contextFactory.CreateDbContextAsync(cancellationToken);
+
+            var shoppingCart = await context.Orders.FirstOrDefaultAsync(o => o.Id == request.ShoppingCartId, cancellationToken);
+
+            if (shoppingCart is null)
+                return Result.Fail(new Error($"ShoppingCart with id {request.ShoppingCartId} not found"));
+
+            if(!await context.Quotes.AnyAsync(q => q.Id == request.QuoteId, cancellationToken))
+                return Result.Fail(new Error($"Quote with id {request.QuoteId} not found"));
+
+            shoppingCart.QuoteId = request.QuoteId;
+
+            return await context.SaveChangesAsync(cancellationToken) > 0
+                ? Result.Ok()
+                : Result.Fail(new Error("Failed to assign quote to shopping cart"));
+        }
+		catch (Exception ex)
+		{
+            return Result.Fail(new Error(ex.Message).CausedBy(ex));
+        }
+    }
+}

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

@@ -0,0 +1,29 @@
+using LiteCharms.Infrastructure.Database;
+
+namespace LiteCharms.Features.Quotes.Commands.Handlers;
+
+public class UpdateQuoteStatusCommandHandler(IDbContextFactory<ShopDbContext> contextFactory) : IRequestHandler<UpdateQuoteStatusCommand, Result>
+{
+    public async ValueTask<Result> Handle(UpdateQuoteStatusCommand request, CancellationToken cancellationToken)
+    {
+        try
+        {
+            using var context = await contextFactory.CreateDbContextAsync(cancellationToken);
+
+            var quote = await context.Quotes.FirstOrDefaultAsync(q => q.Id == request.QuoteId, cancellationToken);
+
+            if (quote is null)
+                return Result.Fail(new Error("Quote not found."));
+
+            quote.Status = request.Status;
+
+            return await context.SaveChangesAsync(cancellationToken) > 0
+                ? Result.Ok()
+                : Result.Fail(new Error("Failed to update quote status."));
+        }
+        catch (Exception ex)
+        {
+            return Result.Fail(new Error(ex.Message).CausedBy(ex));
+        }
+    }
+}

LiteCharms.Features/Quotes/Commands/UpdateQuoteStatusCommand.cs

@@ -0,0 +1,24 @@
+using LiteCharms.Models;
+
+namespace LiteCharms.Features.Quotes.Commands;
+
+public class UpdateQuoteStatusCommand : IRequest<Result>
+{
+    public Guid QuoteId { get; set; }
+
+    public QuoteStatus Status { get; set; }
+
+    private UpdateQuoteStatusCommand(Guid quoteId, QuoteStatus status)
+    {
+        QuoteId = quoteId;
+        Status = status;
+    }
+
+    public static UpdateQuoteStatusCommand Create(Guid quoteId, QuoteStatus status)
+    {
+        if(quoteId == Guid.Empty)
+            throw new ArgumentException("Quote ID cannot be empty.", nameof(quoteId));
+
+        return new(quoteId, status);
+    }
+}

LiteCharms.Features/Quotes/Queries/GetCustomerQuotesQuery.cs

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

LiteCharms.Features/Quotes/Queries/GetQuoteQuery.cs

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

LiteCharms.Features/Quotes/Queries/GetQuotesQuery.cs

@@ -0,0 +1,30 @@
+using LiteCharms.Models;
+
+namespace LiteCharms.Features.Quotes.Queries;
+
+public class GetQuotesQuery : IRequest<Result<Quote[]>>
+{
+    public DateOnly From { get; set; }
+
+    public DateOnly To { get; set; }
+
+    public int MaxRecords { get; set; }
+
+    private GetQuotesQuery(DateOnly from, DateOnly to, int maxRecords = 1000)
+    {
+        From = from;
+        To = to;
+        MaxRecords = maxRecords;
+    }
+
+    public static GetQuotesQuery Create(DateOnly from, DateOnly to, int maxRecords = 1000)
+    {
+        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);
+    }
+}

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

@@ -0,0 +1,31 @@
+using LiteCharms.Extensions;
+using LiteCharms.Features.Quotes.Queries;
+using LiteCharms.Infrastructure.Database;
+using LiteCharms.Models;
+
+namespace LiteCharms.Features.Quotes.Queries.Handlers;
+
+public class GetCustomerQuotesQueryHandler(IDbContextFactory<ShopDbContext> contextFactory) : IRequestHandler<GetCustomerQuotesQuery, Result<Quote[]>>
+{
+    public async ValueTask<Result<Quote[]>> Handle(GetCustomerQuotesQuery 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<Quote[]>(new Error($"Customer with Id {request.CustomerId} does not exist."));
+
+            var quotes = await context.Quotes.AsNoTracking()
+                .Where(q => q.CustomerId == request.CustomerId).ToArrayAsync(cancellationToken);
+
+            return quotes?.Length > 0
+                ? Result.Ok(quotes.Select(q => q.ToModel()).ToArray())
+                : Result.Fail<Quote[]>(new Error($"No quotes found for customer with Id {request.CustomerId}."));
+        }
+		catch (Exception ex)
+		{
+            return Result.Fail<Quote[]>(new Error(ex.Message).CausedBy(ex));
+        }
+    }
+}

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

@@ -0,0 +1,26 @@
+using LiteCharms.Extensions;
+using LiteCharms.Infrastructure.Database;
+using LiteCharms.Models;
+
+namespace LiteCharms.Features.Quotes.Queries.Handlers;
+
+public class GetQuoteQueryHandler(IDbContextFactory<ShopDbContext> contextFactory) : IRequestHandler<GetQuoteQuery, Result<Quote>>
+{
+    public async ValueTask<Result<Quote>> Handle(GetQuoteQuery request, CancellationToken cancellationToken)
+    {
+        try
+        {
+            await using var context = await contextFactory.CreateDbContextAsync(cancellationToken);
+
+            var quote = await context.Quotes.AsNoTracking().FirstOrDefaultAsync(q => q.Id == request.QuoteId, cancellationToken);
+
+            return quote is not null
+                ? Result.Ok(quote.ToModel())
+                : Result.Fail<Quote>(new Error($"Quote with ID {request.QuoteId} not found."));
+        }
+        catch (Exception ex)
+        {
+            return Result.Fail<Quote>(new Error(ex.Message).CausedBy(ex));
+        }
+    }
+}

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

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

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

@@ -1,8 +1,8 @@
 using LiteCharms.Infrastructure.Database;
 
-namespace LiteCharms.Features.Customers.Commands.Handlers;
+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

@@ -0,0 +1,30 @@
+using LiteCharms.Infrastructure.Database;
+
+namespace LiteCharms.Features.Refunds.Commands.Handlers;
+
+public class UpdateOrderRefundCommandHandler(IDbContextFactory<ShopDbContext> contextFactory) : IRequestHandler<UpdateOrderRefundCommand, Result>
+{
+    public async ValueTask<Result> Handle(UpdateOrderRefundCommand request, CancellationToken cancellationToken)
+    {
+		try
+		{
+            using var context = await contextFactory.CreateDbContextAsync(cancellationToken);
+
+            var refund = await context.OrderRefunds.FirstOrDefaultAsync(r => r.Id == request.OrderRefundId, cancellationToken);
+
+            if (refund is null)
+                return Result.Fail($"Order refund not found with id {request.OrderRefundId}");
+
+            refund.Reason = request.Reason;
+            refund.Amount = request.Amount;
+
+            return await context.SaveChangesAsync(cancellationToken) > 0
+                ? Result.Ok()
+                : Result.Fail($"Failed to update order refund {request.OrderRefundId}");
+        }
+		catch (Exception ex)
+		{
+            return Result.Fail(new Error(ex.Message).CausedBy(ex));
+        }
+    }
+}

LiteCharms.Features/Refunds/Commands/RefundCustomerCommand.cs

@@ -1,4 +1,4 @@
-namespace LiteCharms.Features.Customers.Commands;
+namespace LiteCharms.Features.Refunds.Commands;
 
 public class RefundCustomerCommand : IRequest<Result<Guid>>
 {

LiteCharms.Features/Refunds/Commands/UpdateOrderRefundCommand.cs

@@ -0,0 +1,28 @@
+namespace LiteCharms.Features.Refunds.Commands;
+
+public class UpdateOrderRefundCommand : IRequest<Result>
+{
+    public Guid OrderRefundId { get; set; }
+
+    public string? Reason { get; set; }
+
+    public decimal Amount { get; set; }
+
+    private UpdateOrderRefundCommand(Guid orderRefundId, string? reason, decimal amount)
+    {
+        OrderRefundId = orderRefundId;
+        Reason = reason;
+        Amount = amount;
+    }
+
+    public static UpdateOrderRefundCommand Create(Guid orderRefundId, string? reason, decimal amount)
+    {
+        if (orderRefundId == Guid.Empty)
+            throw new ArgumentException("Order refund id is required.", nameof(orderRefundId));
+
+        if (string.IsNullOrWhiteSpace(reason))
+            throw new ArgumentException("Refund update reason is required");
+        
+        return new(orderRefundId, reason, amount);
+    }
+}

LiteCharms.Features/Refunds/Queries/GetCustomerRefundsQuery.cs

@@ -1,6 +1,6 @@
 using LiteCharms.Models;
 
-namespace LiteCharms.Features.Customers.Queries;
+namespace LiteCharms.Features.Refunds.Queries;
 
 public class GetCustomerRefundsQuery : IRequest<Result<OrderRefund[]>>
 {

LiteCharms.Features/Refunds/Queries/GetRefundQuery.cs

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

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

@@ -1,10 +1,11 @@
 using LiteCharms.Extensions;
+using LiteCharms.Features.Refunds.Queries;
 using LiteCharms.Infrastructure.Database;
 using LiteCharms.Models;
 
-namespace LiteCharms.Features.Customers.Queries.Handlers;
+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

@@ -0,0 +1,26 @@
+using LiteCharms.Extensions;
+using LiteCharms.Infrastructure.Database;
+using LiteCharms.Models;
+
+namespace LiteCharms.Features.Refunds.Queries.Handlers;
+
+public class GetRefundQueryHandler(IDbContextFactory<ShopDbContext> contextFactory) : IRequestHandler<GetRefundQuery, Result<OrderRefund>>
+{
+    public async ValueTask<Result<OrderRefund>> Handle(GetRefundQuery request, CancellationToken cancellationToken)
+    {
+		try
+		{
+            using var context = await contextFactory.CreateDbContextAsync(cancellationToken);
+
+            var refund = await context.OrderRefunds.AsNoTracking().FirstOrDefaultAsync(r => r.Id == request.OrderRefundId, cancellationToken);
+
+            return refund is not null
+                ? Result.Ok(refund.ToModel())
+                : Result.Fail<OrderRefund>($"Order refund could not be found with id {request.OrderRefundId}");
+        }
+		catch (Exception ex)
+		{
+            return Result.Fail<OrderRefund>(new Error(ex.Message).CausedBy(ex));
+        }
+    }
+}

LiteCharms.Features/ShoppingCarts/Commands/AddItemToShoppingCartCommand.cs

@@ -0,0 +1,30 @@
+namespace LiteCharms.Features.ShoppingCarts.Commands;
+
+public class AddItemToShoppingCartCommand : IRequest<Result>
+{
+    public Guid ShoppingCartId { get; set; }
+
+    public Guid ProductPriceId { get; set; }
+
+    public int Quantity { get; set; }
+
+    private AddItemToShoppingCartCommand(Guid shoppingCartId, Guid productPriceId, int quantity = 1)
+    {
+        ShoppingCartId = shoppingCartId;
+        ProductPriceId = productPriceId;
+        Quantity = quantity;
+    }
+
+    public static AddItemToShoppingCartCommand Create(Guid shoppingCartId, Guid productPriceId, int quantity = 1)
+    {
+        if (shoppingCartId == Guid.Empty)
+            throw new ArgumentException($"Shopping cart ID is required", nameof(shoppingCartId));
+
+        if (productPriceId == Guid.Empty)
+            throw new ArgumentException($"Product item required", nameof(productPriceId));
+
+        if(quantity <= 0) throw new ArgumentException($"Quantity must be at least 1", nameof(quantity));  
+
+        return new(shoppingCartId, productPriceId, quantity);
+    }
+}

LiteCharms.Features/ShoppingCarts/Commands/CreateShoppingCartCommand.cs

@@ -0,0 +1,25 @@
+namespace LiteCharms.Features.ShoppingCarts.Commands;
+
+public class CreateShoppingCartCommand : IRequest<Result<Guid>>
+{
+    public Guid? CustomerId { get; set; }
+
+    public Guid? OrderId { get; set; }
+
+    public Guid? QuoteId { get; set; }
+
+    private CreateShoppingCartCommand(Guid customerId, Guid? orderId = null, Guid? quoteId = null)
+    {
+        CustomerId = customerId;
+        OrderId = orderId;
+        QuoteId = quoteId;
+    }
+
+    public static CreateShoppingCartCommand Create(Guid customerId, Guid? orderId = null, Guid? quoteId = null)
+    {
+        if (customerId == Guid.Empty)
+            throw new ArgumentException($"Customer ID is required", nameof(customerId));
+
+        return new(customerId, orderId, quoteId);
+    }
+}

LiteCharms.Features/ShoppingCarts/Commands/EmptyShoppingCartCommand.cs

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

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

@@ -0,0 +1,40 @@
+using LiteCharms.Infrastructure.Database;
+
+namespace LiteCharms.Features.ShoppingCarts.Commands.Handlers;
+
+public class AddItemToShoppingCartCommandHandler(IDbContextFactory<ShopDbContext> contextFactory) : IRequestHandler<AddItemToShoppingCartCommand, Result>
+{
+    public async ValueTask<Result> Handle(AddItemToShoppingCartCommand request, CancellationToken cancellationToken)
+    {
+        try
+        {
+            using var context = await contextFactory.CreateDbContextAsync(cancellationToken);
+
+            if (!await context.ProductPrices.AnyAsync(c => c.Id == request.ProductPriceId, cancellationToken))
+                return Result.Fail($"Product item could not be found with id {request.ProductPriceId}");
+
+            var cart = await context.ShoppingCarts.FirstOrDefaultAsync(c => c.Id == request.ShoppingCartId, cancellationToken);
+
+            if (cart is null)
+                return Result.Fail($"Shopping cart could not be found with id {request.ShoppingCartId}");
+
+            if (cart.ShoppingCartItems?.Any(i => i.ProductPriceId == request.ProductPriceId) == true)
+                return Result.Fail($"Item already in shopping cart with id {request.ShoppingCartId}");
+
+            context.ShoppingCartItems.Add(new Entities.ShoppingCartItem
+            {
+                ShoppingCartId = request.ShoppingCartId,
+                ProductPriceId = request.ProductPriceId,
+                Quantity = request.Quantity
+            });
+
+            return await context.SaveChangesAsync(cancellationToken) > 0
+                ? Result.Ok()
+                : Result.Fail($"Failed to add cart item with id {request.ProductPriceId}");
+        }
+        catch (Exception ex)
+        {
+            return Result.Fail(new Error(ex.Message).CausedBy(ex));
+        }
+    }
+}

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

@@ -0,0 +1,32 @@
+using LiteCharms.Infrastructure.Database;
+
+namespace LiteCharms.Features.ShoppingCarts.Commands.Handlers;
+
+public class CreateShoppingCartCommandHandler(IDbContextFactory<ShopDbContext> contextFactory) : IRequestHandler<CreateShoppingCartCommand, Result<Guid>>
+{
+    public async ValueTask<Result<Guid>> Handle(CreateShoppingCartCommand 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<Guid>($"Customer could not be found with id {request.CustomerId}");
+
+            var cart = context.ShoppingCarts.Add(new Entities.ShoppingCart
+            {
+                CustomerId = request.CustomerId,
+                OrderId = request.OrderId,
+                QuoteId = request.QuoteId
+            });
+
+            return await context.SaveChangesAsync(cancellationToken) > 0
+                ? Result.Ok(cart.Entity.Id)
+                : Result.Fail<Guid>($"Failed to create shopping cart for customer id {request.CustomerId}");
+        }
+        catch (Exception ex)
+        {
+            return Result.Fail<Guid>(new Error(ex.Message).CausedBy(ex));
+        }
+    }
+}

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

@@ -0,0 +1,32 @@
+using LiteCharms.Infrastructure.Database;
+
+namespace LiteCharms.Features.ShoppingCarts.Commands.Handlers;
+
+public class EmptyShoppingCartCommandHandler(IDbContextFactory<ShopDbContext> contextFactory) : IRequestHandler<EmptyShoppingCartCommand, Result>
+{
+    public async ValueTask<Result> Handle(EmptyShoppingCartCommand 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 could not be found with id {request.ShoppingCartId}");
+
+            if (await context.ShoppingCartItems.CountAsync(i => i.ShoppingCartId == request.ShoppingCartId, cancellationToken) == 0)
+                return Result.Ok();
+
+            var cartItems = await context.ShoppingCartItems.Where(i => i.ShoppingCartId == request.ShoppingCartId).ToListAsync(cancellationToken);
+
+            context.RemoveRange(cartItems);
+
+            return await context.SaveChangesAsync(cancellationToken) > 0
+                ? Result.Ok()
+                : Result.Fail($"Could not empty cart with id {request.ShoppingCartId}");
+        }
+		catch (Exception ex)
+		{
+            return Result.Fail(new Error(ex.Message).CausedBy(ex));
+        }
+    }
+}

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

@@ -0,0 +1,36 @@
+using LiteCharms.Infrastructure.Database;
+
+namespace LiteCharms.Features.ShoppingCarts.Commands.Handlers;
+
+public class RemoveShoppingCartItemCommandHandler(IDbContextFactory<ShopDbContext> contextFactory) : IRequestHandler<RemoveShoppingCartItemCommand, Result>
+{
+    public async ValueTask<Result> Handle(RemoveShoppingCartItemCommand request, CancellationToken cancellationToken)
+    {
+		try
+		{
+            using var context = await contextFactory.CreateDbContextAsync(cancellationToken);
+
+            if (!await context.ProductPrices.AnyAsync(c => c.Id == request.ShoppingCartItemId, cancellationToken))
+                return Result.Fail($"Product item could not be found with id {request.ShoppingCartItemId}");
+
+            var cart = await context.ShoppingCarts.FirstOrDefaultAsync(c => c.Id == request.ShoppingCartId, cancellationToken);
+
+            if (cart is null)
+                return Result.Fail($"Shopping cart item could not be found with id {request.ShoppingCartId}");
+
+            var item = await context.ShoppingCartItems.FirstOrDefaultAsync(i => i.Id == request.ShoppingCartItemId, cancellationToken);
+
+            if (item is null) return Result.Ok();
+
+            context.ShoppingCartItems.Remove(item);
+
+            return await context.SaveChangesAsync(cancellationToken) > 0
+                ? Result.Ok()
+                : Result.Fail($"Failed to remove shopping cart item with id {request.ShoppingCartItemId}");
+        }
+		catch (Exception ex)
+		{
+            return Result.Fail(new Error(ex.Message).CausedBy(ex));
+        }
+    }
+}