Merge pull request 'Populated README' (#14) from develop into master

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/LiteCharms.Entities.csproj

@@ -11,7 +11,7 @@
   <!-- Nuget Package Details -->
   <PropertyGroup>
     <PackageId>LiteCharms.Entities</PackageId>
-    <Version>1.0.3</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.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/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.9</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" />
@@ -44,7 +47,9 @@
     <PackageReference Include="AspNetCore.HealthChecks.UI.Data" Version="9.0.0" />
     <PackageReference Include="AspNetCore.HealthChecks.UI.InMemory.Storage" Version="9.0.0" />
     <PackageReference Include="Microsoft.EntityFrameworkCore.InMemory" Version="10.0.7" />
-    <PackageReference Include="Microsoft.Extensions.DependencyInjection" Version="10.0.7" />    
+    <PackageReference Include="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,41 +1,7 @@
-using LiteCharms.Infrastructure.Database;
+namespace LiteCharms.Extensions;
-using LiteCharms.Infrastructure.HealthChecks;
-using LiteCharms.Models.Configuraton.Email;
 
-namespace LiteCharms.Extensions;
+public static class Monitoring
-
-public static class Services
 {
-    public static IServiceCollection AddEmailServices(this IServiceCollection services, IConfiguration configuration)
-    {
-        services.Configure<SmtpSettings>(configuration.GetSection("Email"));
-
-        return services;
-    }
-
-    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/Handlers/GetCustomerQueryHandler.cs

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

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

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

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

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

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

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

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

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

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

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

LiteCharms.Features/LiteCharms.Features.csproj

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

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

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

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

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

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

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

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

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

LiteCharms.Features/Orders/Commands/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)
     {

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

LiteCharms.Infrastructure/Database/LeadGeneratorDbContextFactory.cs

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

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

@@ -11,7 +11,7 @@ using Npgsql.EntityFrameworkCore.PostgreSQL.Metadata;
 
 namespace LiteCharms.Infrastructure.Database.Migrations
 {
-    [DbContext(typeof(LeadGeneratorDbContext))]
+    [DbContext(typeof(ShopDbContext))]
     [Migration("20260502231708_Init")]
     partial class Init
     {

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

@@ -11,7 +11,7 @@ using Npgsql.EntityFrameworkCore.PostgreSQL.Metadata;
 
 namespace LiteCharms.Infrastructure.Database.Migrations
 {
-    [DbContext(typeof(LeadGeneratorDbContext))]
+    [DbContext(typeof(ShopDbContext))]
     [Migration("20260503002123_DefinedEntityRelationships")]
     partial class DefinedEntityRelationships
     {

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

@@ -11,7 +11,7 @@ using Npgsql.EntityFrameworkCore.PostgreSQL.Metadata;
 
 namespace LiteCharms.Infrastructure.Database.Migrations
 {
-    [DbContext(typeof(LeadGeneratorDbContext))]
+    [DbContext(typeof(ShopDbContext))]
     [Migration("20260503003624_RemovedLeadIdFromLead")]
     partial class RemovedLeadIdFromLead
     {

LiteCharms.Infrastructure/Database/Migrations/20260503012708_AddedStatusToLead.Designer.cs

@@ -11,7 +11,7 @@ using Npgsql.EntityFrameworkCore.PostgreSQL.Metadata;
 
 namespace LiteCharms.Infrastructure.Database.Migrations
 {
-    [DbContext(typeof(LeadGeneratorDbContext))]
+    [DbContext(typeof(ShopDbContext))]
     [Migration("20260503012708_AddedStatusToLead")]
     partial class AddedStatusToLead
     {

LiteCharms.Infrastructure/Database/Migrations/20260503133855_CorrectedAttributionHashColumnOnLead.Designer.cs

@@ -11,7 +11,7 @@ using Npgsql.EntityFrameworkCore.PostgreSQL.Metadata;
 
 namespace LiteCharms.Infrastructure.Database.Migrations
 {
-    [DbContext(typeof(LeadGeneratorDbContext))]
+    [DbContext(typeof(ShopDbContext))]
     [Migration("20260503133855_CorrectedAttributionHashColumnOnLead")]
     partial class CorrectedAttributionHashColumnOnLead
     {

LiteCharms.Infrastructure/Database/Migrations/20260505120450_GeneralisedLead.Designer.cs

@@ -11,7 +11,7 @@ using Npgsql.EntityFrameworkCore.PostgreSQL.Metadata;
 
 namespace LiteCharms.Infrastructure.Database.Migrations
 {
-    [DbContext(typeof(LeadGeneratorDbContext))]
+    [DbContext(typeof(ShopDbContext))]
     [Migration("20260505120450_GeneralisedLead")]
     partial class GeneralisedLead
     {

LiteCharms.Infrastructure/Database/Migrations/20260505123745_AddedNotifications.Designer.cs

@@ -11,7 +11,7 @@ using Npgsql.EntityFrameworkCore.PostgreSQL.Metadata;
 
 namespace LiteCharms.Infrastructure.Database.Migrations
 {
-    [DbContext(typeof(LeadGeneratorDbContext))]
+    [DbContext(typeof(ShopDbContext))]
     [Migration("20260505123745_AddedNotifications")]
     partial class AddedNotifications
     {

LiteCharms.Infrastructure/Database/Migrations/20260505124135_AddedProcessedColumnToNotifications.Designer.cs

@@ -11,7 +11,7 @@ using Npgsql.EntityFrameworkCore.PostgreSQL.Metadata;
 
 namespace LiteCharms.Infrastructure.Database.Migrations
 {
-    [DbContext(typeof(LeadGeneratorDbContext))]
+    [DbContext(typeof(ShopDbContext))]
     [Migration("20260505124135_AddedProcessedColumnToNotifications")]
     partial class AddedProcessedColumnToNotifications
     {

LiteCharms.Infrastructure/Database/Migrations/20260505202859_AddedQuoteShoppingCartalteredOrderCustomer.Designer.cs

@@ -11,7 +11,7 @@ using Npgsql.EntityFrameworkCore.PostgreSQL.Metadata;
 
 namespace LiteCharms.Infrastructure.Database.Migrations
 {
-    [DbContext(typeof(LeadGeneratorDbContext))]
+    [DbContext(typeof(ShopDbContext))]
     [Migration("20260505202859_AddedQuoteShoppingCartalteredOrderCustomer")]
     partial class AddedQuoteShoppingCartalteredOrderCustomer
     {

LiteCharms.Infrastructure/Database/Migrations/LeadGeneratorDbContextModelSnapshot.cs

@@ -10,7 +10,7 @@ using Npgsql.EntityFrameworkCore.PostgreSQL.Metadata;
 
 namespace LiteCharms.Infrastructure.Migrations
 {
-    [DbContext(typeof(LeadGeneratorDbContext))]
+    [DbContext(typeof(ShopDbContext))]
     partial class LeadGeneratorDbContextModelSnapshot : ModelSnapshot
     {
         protected override void BuildModel(ModelBuilder modelBuilder)

LiteCharms.Infrastructure/Database/ShopDbContext.cs

@@ -2,7 +2,7 @@
 
 namespace LiteCharms.Infrastructure.Database;
 
-public class LeadGeneratorDbContext(DbContextOptions<LeadGeneratorDbContext> options) : DbContext(options)
+public class ShopDbContext(DbContextOptions<ShopDbContext> options) : DbContext(options)
 {
     public DbSet<Customer> Customers { get; set; }
 

LiteCharms.Infrastructure/Database/ShopDbContextFactory.cs

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

LiteCharms.Infrastructure/HealthChecks/PostgresHealthCheck.cs

@@ -2,7 +2,7 @@
 
 public class PostgresHealthCheck(IConfiguration configuration) : IHealthCheck
 {
-    private readonly string connectionString = configuration.GetConnectionString("PostgresLeadGenerator")!;
+    private readonly string connectionString = configuration.GetConnectionString("PostgresShop")!;
 
     public async Task<HealthCheckResult> CheckHealthAsync(HealthCheckContext context, CancellationToken cancellationToken = default)
     {

LiteCharms.Infrastructure/HealthChecks/QuartzHealthCheck.cs

@@ -0,0 +1,23 @@
+namespace LiteCharms.Infrastructure.HealthChecks;
+
+public class QuartzHealthCheck(ISchedulerFactory schedulerFactory) : IHealthCheck
+{
+    public async Task<HealthCheckResult> CheckHealthAsync(HealthCheckContext context, CancellationToken cancellationToken = default)
+    {
+        try
+        {
+            var scheduler = await schedulerFactory.GetScheduler(cancellationToken);
+
+            if (!scheduler.IsStarted)
+                return HealthCheckResult.Unhealthy("Quartz scheduler is not running");
+
+            await scheduler.CheckExists(new JobKey(Guid.NewGuid().ToString()), cancellationToken);
+
+            return HealthCheckResult.Healthy("Quartz scheduler is ready");
+        }
+        catch (SchedulerException)
+        {
+            return HealthCheckResult.Unhealthy("Quartz scheduler cannot connect to the store");
+        }
+    }
+}

LiteCharms.Infrastructure/LiteCharms.Infrastructure.csproj

@@ -12,7 +12,7 @@
   <!-- Nuget Package Details -->
   <PropertyGroup>
     <PackageId>LiteCharms.Infrastructure</PackageId>
-    <Version>1.0.3</Version>
+    <Version>1.0.20</Version>
     <Authors>Khwezi Mngoma</Authors>
     <Company>Lite Charms (PTY) Ltd</Company>
     <Description>Infrastructure components for Lite Charms applications.</Description>
@@ -28,6 +28,19 @@
     <None Include="..\icon.png" Pack="true" PackagePath="\" />
   </ItemGroup>
 
+  <!-- Quartz Scheduler-->
+  <ItemGroup>        
+    <PackageReference Include="Quartz" Version="3.18.1" />    
+    <PackageReference Include="Quartz.Plugins" Version="3.18.1" />
+    <PackageReference Include="Quartz.Plugins.TimeZoneConverter" Version="3.18.1" />
+    <PackageReference Include="Quartz.Serialization.SystemTextJson" Version="3.18.1" />
+
+    <!-- Global Usings -->
+    <Using Include="Quartz" />
+    <Using Include="Mediator" />
+    <Using Include="FluentResults" />
+  </ItemGroup>
+
   <!-- Configuration -->
   <ItemGroup>
     <PackageReference Include="Microsoft.Extensions.Configuration" Version="10.0.7" />    
@@ -70,10 +83,18 @@
   </ItemGroup>
 
   <!-- Project References -->
-  <ItemGroup>    
+  <ItemGroup>
+    <ProjectReference Include="..\LiteCharms.Abstractions\LiteCharms.Abstractions.csproj" />
     <ProjectReference Include="..\LiteCharms.Entities\LiteCharms.Entities.csproj" />
     <ProjectReference Include="..\LiteCharms.Models\LiteCharms.Models.csproj" />
   </ItemGroup>
+
+  <!-- Global Usings -->
+  <ItemGroup>
+    <Using Include="System.Text.Json" />
+    <Using Include="Microsoft.Extensions.Hosting" />
+  </ItemGroup>
+  
   <ItemGroup>
     <None Update="appsettings.json">
       <CopyToOutputDirectory>PreserveNewest</CopyToOutputDirectory>

LiteCharms.Infrastructure/Quartz/JobOrchestrator.cs

@@ -0,0 +1,66 @@
+using LiteCharms.Abstractions;
+using static LiteCharms.Abstractions.Timezones;
+
+namespace LiteCharms.Infrastructure.Quartz;
+
+public class JobOrchestrator(ISchedulerFactory schedulerFactory) : IJobOrchestrator
+{
+    public async Task SendAsync<TNotification>(TNotification notification, CancellationToken cancellationToken = default)
+        where TNotification : IEvent
+    {
+        var chainedJobGroup = "onetime-jobs";
+
+        var scheduler = await schedulerFactory.GetScheduler(cancellationToken);
+        var jobKey = new JobKey($"{notification.Name.ToLower()}-{notification.CorrelationId.ToLower()}", chainedJobGroup);
+        var triggerKey = new TriggerKey($"{jobKey.Name}-trigger", chainedJobGroup);
+
+        var job = JobBuilder.Create<MediatorJob<TNotification>>()
+            .WithIdentity(jobKey)
+            .WithDescription($"Correlation ID: {notification.CorrelationId}")
+            .UsingJobData(new JobDataMap { ["Payload"] = JsonSerializer.Serialize(notification) })
+            .DisallowConcurrentExecution()
+            .Build();
+
+        var trigger = global::Quartz.TriggerBuilder.Create()
+            .WithIdentity(triggerKey)
+            .StartNow()
+            .Build();
+
+        await scheduler.ScheduleJob(job, new List<ITrigger> { trigger }.AsReadOnly(), replace: true, cancellationToken);
+    }
+
+    public async Task ScheduleAsync<TNotification>(TNotification notification, string cronExpression, CancellationToken cancellationToken = default)
+        where TNotification : IEvent
+    {
+        var chainedJobGroup = "scheduled-jobs";
+
+        var scheduler = await schedulerFactory.GetScheduler(cancellationToken);
+        var jobKey = new JobKey($"{notification.Name.ToLower()}-{notification.CorrelationId.ToLower()}", chainedJobGroup);
+        var triggerKey = new TriggerKey($"{jobKey.Name}-trigger", chainedJobGroup);
+
+        var job = JobBuilder.Create<MediatorJob<TNotification>>()
+            .WithIdentity(jobKey)
+            .WithDescription($"Correlation ID: {notification.CorrelationId}")
+            .UsingJobData(new JobDataMap { ["Payload"] = JsonSerializer.Serialize(notification) })
+            .DisallowConcurrentExecution()
+            .StoreDurably()
+            .Build();
+
+        var now = SouthAfricanTimeZone.UtcNow();
+
+        var trigger = global::Quartz.TriggerBuilder.Create()
+            .WithIdentity(triggerKey)
+            .WithDescription($"Scheduled via Main Job at {now:g}")
+            .WithCronSchedule(cronExpression, cron => cron.InTimeZone(SouthAfricanTimeZone)
+                .WithMisfireHandlingInstructionFireAndProceed())
+            .StartAt(now)
+            .Build();
+
+        await scheduler.AddJob(job, replace: true, cancellationToken);
+
+        if (await scheduler.CheckExists(triggerKey, cancellationToken))
+            await scheduler.RescheduleJob(triggerKey, trigger, cancellationToken);
+        else
+            await scheduler.ScheduleJob(job, new List<ITrigger> { trigger }.AsReadOnly(), replace: true, cancellationToken);
+    }
+}

LiteCharms.Infrastructure/Quartz/MediatorJob.cs

@@ -0,0 +1,21 @@
+using LiteCharms.Abstractions;
+
+namespace LiteCharms.Infrastructure.Quartz;
+
+[DisallowConcurrentExecution]
+public class MediatorJob<TNotification>(IMediator mediator) : IJob where TNotification : IEvent
+{
+    public async Task Execute(IJobExecutionContext context)
+    {
+        var data = context.MergedJobDataMap["Payload"] as string;
+
+        if (string.IsNullOrWhiteSpace(data)) return;
+
+        var notification = JsonSerializer.Deserialize<TNotification>(data);
+
+        if(notification is null) return;
+
+        if(notification is TNotification)
+            await mediator.Publish(notification, context.CancellationToken);
+    }
+}

LiteCharms.Infrastructure/Quartz/RetryJobListener.cs

@@ -0,0 +1,18 @@
+namespace LiteCharms.Infrastructure.Quartz;
+
+public class RetryJobListener : IJobListener
+{
+    public string Name => "RetryJobListener";
+
+    public int RetryCount { get; set; } = 3;
+
+    public Task JobExecutionVetoed(IJobExecutionContext context, CancellationToken cancellationToken = default) => Task.CompletedTask;
+
+    public Task JobToBeExecuted(IJobExecutionContext context, CancellationToken cancellationToken = default) => Task.CompletedTask;
+
+    public async Task JobWasExecuted(IJobExecutionContext context, JobExecutionException? jobException, CancellationToken cancellationToken = default)
+    {
+        if (jobException is not null && context.RefireCount < RetryCount)
+            jobException.RefireImmediately = true;
+    }
+}

LiteCharms.Infrastructure/ServiceBus/EmailServiceBus.cs

@@ -0,0 +1,22 @@
+using LiteCharms.Abstractions;
+using LiteCharms.Infrastructure.ServiceBus.Queues;
+
+namespace LiteCharms.Infrastructure.ServiceBus;
+
+public class EmailServiceBus(EmailQueue messages) : IEventBus
+{
+    public async Task<Result> PublishAsync<TEvent>(TEvent notification, CancellationToken cancellationToken = default)
+		where TEvent : class, IEvent
+    {
+		try
+		{
+			await messages.Outgoing.WriteAsync(notification, cancellationToken);
+
+			return Result.Ok();
+		}
+		catch (Exception ex)
+		{
+			return Result.Fail(new Error(ex.Message).CausedBy(ex));
+		}
+    }
+}

LiteCharms.Infrastructure/ServiceBus/Exchanges/EmailExchange.cs

@@ -0,0 +1,12 @@
+using LiteCharms.Infrastructure.ServiceBus.Queues;
+
+namespace LiteCharms.Infrastructure.ServiceBus.Exchanges;
+
+public class EmailExchange(EmailQueue messages) : BackgroundService
+{
+    protected override async Task ExecuteAsync(CancellationToken stoppingToken)
+    {
+        if(messages.Incoming.CanCount)
+            await Task.Delay(1000, stoppingToken);
+    }
+}

LiteCharms.Infrastructure/ServiceBus/Exchanges/GeneralExchange.cs

@@ -0,0 +1,12 @@
+using LiteCharms.Infrastructure.ServiceBus.Queues;
+
+namespace LiteCharms.Infrastructure.ServiceBus.Exchanges;
+
+public class GeneralExchange(GeneralQueue messages) : BackgroundService
+{
+    protected override async Task ExecuteAsync(CancellationToken stoppingToken)
+    {
+        if (messages.Incoming.CanCount)
+            await Task.Delay(1000, stoppingToken);
+    }
+}

LiteCharms.Infrastructure/ServiceBus/Exchanges/SalesExchange.cs

@@ -0,0 +1,12 @@
+using LiteCharms.Infrastructure.ServiceBus.Queues;
+
+namespace LiteCharms.Infrastructure.ServiceBus.Exchanges;
+
+public class SalesExchange(SalesQueue messages) : BackgroundService
+{
+    protected override async Task ExecuteAsync(CancellationToken stoppingToken)
+    {
+        if (messages.Incoming.CanCount)
+            await Task.Delay(1000, stoppingToken);
+    }
+}

LiteCharms.Infrastructure/ServiceBus/GeneralServiceBus.cs

@@ -0,0 +1,22 @@
+using LiteCharms.Abstractions;
+using LiteCharms.Infrastructure.ServiceBus.Queues;
+
+namespace LiteCharms.Infrastructure.ServiceBus;
+
+public class GeneralServiceBus(GeneralQueue messages) : IEventBus
+{
+    public async Task<Result> PublishAsync<TEvent>(TEvent notification, CancellationToken cancellationToken = default)
+        where TEvent : class, IEvent
+    {
+        try
+        {
+            await messages.Outgoing.WriteAsync(notification, cancellationToken);
+
+            return Result.Ok();
+        }
+        catch (Exception ex)
+        {
+            return Result.Fail(new Error(ex.Message).CausedBy(ex));
+        }
+    }
+}

LiteCharms.Infrastructure/ServiceBus/Queues/EmailQueue.cs

@@ -0,0 +1,5 @@
+using LiteCharms.Abstractions;
+
+namespace LiteCharms.Infrastructure.ServiceBus.Queues;
+
+public class EmailQueue : EventBusQueueBase, IEventBusQueue;

LiteCharms.Infrastructure/ServiceBus/Queues/GeneralQueue.cs

@@ -0,0 +1,5 @@
+using LiteCharms.Abstractions;
+
+namespace LiteCharms.Infrastructure.ServiceBus.Queues;
+
+public class GeneralQueue : EventBusQueueBase, IEventBusQueue;

LiteCharms.Infrastructure/ServiceBus/Queues/SalesQueue.cs

@@ -0,0 +1,5 @@
+using LiteCharms.Abstractions;
+
+namespace LiteCharms.Infrastructure.ServiceBus.Queues;
+
+public class SalesQueue : EventBusQueueBase, IEventBusQueue;

LiteCharms.Infrastructure/ServiceBus/SalesServiceBus.cs

@@ -0,0 +1,22 @@
+using LiteCharms.Abstractions;
+using LiteCharms.Infrastructure.ServiceBus.Queues;
+
+namespace LiteCharms.Infrastructure.ServiceBus;
+
+public class SalesServiceBus(SalesQueue messages) : IEventBus
+{
+    public async Task<Result> PublishAsync<TEvent>(TEvent notification, CancellationToken cancellationToken = default)
+        where TEvent : class, IEvent
+    {
+        try
+        {
+            await messages.Outgoing.WriteAsync(notification, cancellationToken);
+
+            return Result.Ok();
+        }
+        catch (Exception ex)
+        {
+            return Result.Fail(new Error(ex.Message).CausedBy(ex));
+        }
+    }
+}

LiteCharms.Models/LiteCharms.Models.csproj

@@ -4,14 +4,14 @@
     <TargetFramework>net10.0</TargetFramework>
     <ImplicitUsings>enable</ImplicitUsings>
     <Nullable>enable</Nullable>
-    <AssemblyOriginatorKeyFile>..\LiteCharms.snk</AssemblyOriginatorKeyFile>
     <SignAssembly>True</SignAssembly>
+    <AssemblyOriginatorKeyFile>..\LiteCharms.snk</AssemblyOriginatorKeyFile>
   </PropertyGroup>
 
   <!-- Nuget Package Details -->
   <PropertyGroup>
     <PackageId>LiteCharms.Models</PackageId>
-    <Version>1.0.5</Version>
+    <Version>1.0.20</Version>
     <Authors>Khwezi Mngoma</Authors>
     <Company>Lite Charms (PTY) Ltd</Company>
     <Description>Shared models for Lite Charms applications.</Description>

LiteCharmsShared.slnx

@@ -1,4 +1,15 @@
 <Solution>
+  <Folder Name="/Solution Items/">
+    <File Path=".drone.yml" />
+    <File Path=".editorconfig" />
+    <File Path=".gitattributes" />
+    <File Path=".gitignore" />
+    <File Path="icon.png" />
+    <File Path="LICENSE" />
+    <File Path="LiteCharms.snk" />
+    <File Path="README.md" />
+  </Folder>
+  <Project Path="LiteCharms.Abstractions/LiteCharms.Abstractions.csproj" Id="e080e621-5394-4260-a793-d54178401942" />
   <Project Path="LiteCharms.Entities/LiteCharms.Entities.csproj" />
   <Project Path="LiteCharms.Extensions/LiteCharms.Extensions.csproj" />
   <Project Path="LiteCharms.Features/LiteCharms.Features.csproj" />

README.md

@@ -1 +1,23 @@
-# LiteCharmsShared
+# LiteCharms.Components
+
+A suite of shared libraries providing core logic, models, and infrastructure for the LiteCharms ecosystem.
+
+## 📦 Published Packages
+All packages are versioned and pushed to [Nexus](https://nexus.khongisa.co.za) automatically via CI/CD.
+
+* **Abstractions:** Interfaces and base contracts.
+* **Models:** Shared DTOs and Request/Response objects.
+* **Entities:** Database schema definitions.
+* **Infrastructure:** Persistence and external service clients.
+* **Features:** Core business logic modules.
+* **Extensions:** Shared helper methods and DI configurations.
+
+## 🚀 CI/CD Workflow
+1. Create a **Pull Request** to `master`.
+2. Drone CI builds, tests, and packs the suite as `1.${DRONE_BUILD_NUMBER}.0`.
+3. Packages are pushed to the Nexus `nuget-hosted` repository.
+4. A formal **Gitea Release** is created with the versioned "Bill of Materials."
+
+## 🛠 Usage
+Add the Nexus NuGet source to your local environment and reference the version listed in the latest Gitea Release:
+`dotnet add package LiteCharms.Models -v 1.XX.0`