feat: add ElasticSearch integration and configure dependency injection

Author: dagweg

Source/Ecommerce.Infrastructure/DependencyInjection.cs

@@ -13,6 +13,7 @@ namespace Ecommerce.Infrastructure;
 using Ecommerce.Application.Common.Interfaces.Providers.Forex;
 using Ecommerce.Application.Common.Interfaces.Providers.Localization;
 using Ecommerce.Application.Common.Interfaces.Providers.Payment.Stripe;
+using Ecommerce.Application.Common.Interfaces.Providers.Search.Elastic;
 using Ecommerce.Application.Common.Interfaces.Storage;
 using Ecommerce.Application.Common.Utilities;
 using Ecommerce.Application.Services.Storage;
@@ -30,8 +31,10 @@ namespace Ecommerce.Infrastructure;
 using Ecommerce.Infrastructure.Services.Providers.Forex;
 using Ecommerce.Infrastructure.Services.Providers.Payment;
 using Ecommerce.Infrastructure.Services.Providers.Payment.Stripe;
+using Ecommerce.Infrastructure.Services.Providers.Search.Elastic;
 using Ecommerce.Infrastructure.Services.Providers.Smtp;
 using Ecommerce.Infrastructure.Services.Storage;
+using Elastic.Clients.Elasticsearch;
 using IdentityModel;
 using Microsoft.AspNetCore.Authentication;
 using Microsoft.AspNetCore.Authentication.Cookies;
@@ -80,6 +83,8 @@ IConfigurationManager configuration
     // stripe, paypal .. etc
     services.AddPaymentGateways();
 
+    services.AddElastic(configuration);
+
     return services;
   }
 
@@ -249,6 +254,8 @@ public static IServiceCollection AddAppSettings(
     IConfigurationManager configuration
   )
   {
+    services.Configure<ElasticSettings>(configuration.GetSection(ElasticSettings.SectionName));
+
     services.Configure<DatabaseOptions>(configuration.GetSection(DatabaseOptions.SectionName));
 
     services.Configure<PaymentOptions>(configuration.GetSection(PaymentOptions.SectionName));
@@ -300,7 +307,7 @@ IConfigurationManager configuration
   {
     services.AddScoped<ISmtpClientWrapper>(sp =>
     {
-      string? host = configuration.GetConnectionString($"{EmailSettings.SectionName}:Host");
+      string? host = configuration[$"{EmailSettings.SectionName}:Host"];
 
       if (host is null)
       {
@@ -317,4 +324,23 @@ public static IServiceCollection AddPaymentGateways(this IServiceCollection serv
     services.AddTransient<IStripeService, StripeService>();
     return services;
   }
+
+  public static IServiceCollection AddElastic(
+    this IServiceCollection services,
+    IConfigurationManager configuration
+  )
+  {
+    var elasticUri = configuration[$"{ElasticSettings.SectionName}:ConnectionString"];
+    if (elasticUri == null)
+    {
+      throw new Exception("Elastic Connection String is null.");
+    }
+
+    var elasticClient = new ElasticsearchClient(new Uri(elasticUri));
+
+    services.AddSingleton(elasticClient);
+    services.AddScoped(typeof(IElasticSearch<>), typeof(ElasticSearch<>));
+
+    return services;
+  }
 }

Source/Ecommerce.Infrastructure/Ecommerce.Infrastructure.csproj

@@ -16,6 +16,7 @@
 
     <ItemGroup>
       <PackageReference Include="CloudinaryDotNet" Version="1.27.3" />
+      <PackageReference Include="Elastic.Clients.Elasticsearch" Version="9.0.0" />
       <PackageReference Include="Microsoft.EntityFrameworkCore" Version="9.0.0" />
       <PackageReference Include="Microsoft.EntityFrameworkCore.InMemory" Version="9.0.0" />
       <PackageReference Include="Microsoft.EntityFrameworkCore.SqlServer" Version="9.0.0" />