feat: added Exception to InitAsync OpenSearch

Refs: SITKO-CORE-T-19
sitkoru · Jul 26, 2024 · 637b1c3 · 637b1c3
1 parent b3f6ee7
commit 637b1c3
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/src/Sitko.Core.Search.OpenSearch/OpenSearchSearcher.cs b/src/Sitko.Core.Search.OpenSearch/OpenSearchSearcher.cs
@@ -3,6 +3,7 @@
 using Microsoft.Extensions.Options;
 using OpenSearch.Client;
 using OpenSearch.Net;
+using Exception = System.Exception;
 
 namespace Sitko.Core.Search.OpenSearch;
 
@@ -151,6 +152,7 @@ public async Task InitAsync(string indexName, CancellationToken cancellationToke
                 {
                     logger.LogError("Error while init {IndexName} index: {ErrorText}", indexName,
                         result.ServerError);
+                    throw new Exception("Error while init " + indexName + " index: " + result.ServerError);
                 }
 
                 if (result.OriginalException != null)
@@ -170,6 +172,7 @@ public async Task InitAsync(string indexName, CancellationToken cancellationToke
                 {
                     logger.LogError("Error while create {IndexName} index: {ErrorText}", indexName,
                         result.ServerError);
+                    throw new Exception("Error while init " + indexName + " index: " + result.ServerError);
                 }
 
                 if (result.OriginalException != null)