adapt to index, doc[]

Author: dagweg

Source/Ecommerce.Application/Services/Workers/Elastic/ElasticTaskNotificationHandler.cs

@@ -1,4 +1,5 @@
 using System.Reflection.Metadata;
+using Ecommerce.Application.Common.Defaults;
 using Ecommerce.Application.Common.Interfaces.Providers.Search.Elastic;
 using Ecommerce.Application.Common.Models.Search.Elastic.Documents;
 using MediatR;
@@ -17,37 +18,46 @@ public async Task Handle(
     CancellationToken cancellationToken
   )
   {
+    if (!await elasticSearch.IsReachableAsync())
+      return;
+
     taskQueue.QueueBackgroundWorkItem(async x =>
     {
       try
       {
         if (notification.ElasticAction == ElasticAction.Index)
         {
           logger.LogInformation("Indexing documents to ElasticSearch.");
-          List<ProductDocument> failed = [];
+          List<ElasticDocumentBase> failed = [];
           foreach (var kvp in notification.IndexDocs)
           {
             var indexName = kvp.Key;
-            var document = (ProductDocument)kvp.Value;
-            var success = await elasticSearch.IndexAsync(indexName, document, cancellationToken);
-            if (!success)
-            {
-              failed.Add(document);
-              logger.LogError(
-                "Failed to index document {DocumentId} in index {IndexName}.",
-                document.Id,
-                indexName
-              );
-            }
+
+            if (indexName == ElasticIndices.ProductIndex)
+              foreach (var doc in kvp.Value)
+              {
+                var document = (ProductDocument)doc;
+                var success = await elasticSearch.IndexAsync(
+                  indexName,
+                  document,
+                  cancellationToken
+                );
+                if (!success)
+                {
+                  failed.Add(document);
+                  logger.LogError(
+                    "Failed to index document \nDocumentId: {DocumentId} \nProductName: {ProductName}\n in index {IndexName}.",
+                    document.Id,
+                    document.Name,
+                    indexName
+                  );
+                }
+              }
           }
 
           if (failed.Count > 0)
           {
-            logger.LogError(
-              "Failed to index {Count} documents in ElasticSearch. \n{@DocumentNames}",
-              failed.Count,
-              string.Join(",\n", failed.Select(x => x.Name))
-            );
+            logger.LogError("Failed to index {Count} documents in ElasticSearch.", failed.Count);
           }
           else
           {

Source/Ecommerce.Application/UseCases/Products/Commands/CreateProduct/CreateProductCommandHandler.cs

@@ -176,9 +176,9 @@ await _publisher.Publish(
       new ElasticTaskNotification()
       {
         ElasticAction = ElasticAction.Index,
-        IndexDocs = new Dictionary<string, ElasticDocumentBase>
+        IndexDocs = new Dictionary<string, ElasticDocumentBase[]>
         {
-          { ElasticIndices.ProductIndex, _mapper.Map<ProductDocument>(product) },
+          { ElasticIndices.ProductIndex, [_mapper.Map<ProductDocument>(product)] },
         },
       }
     );

Source/Ecommerce.Application/UseCases/Products/Queries/GetFilteredProducts/GetFilteredProductsQueryHandler.cs

@@ -75,15 +75,20 @@ CancellationToken cancellationToken
     _logger.LogInformation("No products found in ElasticSearch, falling back to DB search.");
     GetProductsResult products = await _productRepository.GetFilteredProductsAsync(request);
 
-    // Index the products in ElasticSearch for future searches
+    // Schedule an indexing job for the non-indexed products for future searches
     await _publisher.Publish(
       new ElasticTaskNotification()
       {
         ElasticAction = ElasticAction.Index,
-        IndexDocs = products.Items.ToDictionary(
-          k => ElasticIndices.ProductIndex,
-          v => (ElasticDocumentBase)_mapper.Map<ProductDocument>(v)
-        ),
+        IndexDocs = new Dictionary<string, ElasticDocumentBase[]>
+        {
+          {
+            ElasticIndices.ProductIndex,
+            products
+              .Items.Select(v => (ElasticDocumentBase)_mapper.Map<ProductDocument>(v))
+              .ToArray()
+          },
+        },
       }
     );