VCST-3259: Add StoreDomainResolverService

src/VirtoCommerce.Xapi.Core/Models/IStoreDomainRequest.cs

@@ -0,0 +1,8 @@
+namespace VirtoCommerce.Xapi.Core.Models;
+
+public class StoreDomainRequest
+{
+    public string StoreId { get; set; }
+
+    public string Domain { get; set; }
+}

src/VirtoCommerce.Xapi.Core/Services/IStoreDomainResolverService.cs

@@ -0,0 +1,10 @@
+using System.Threading.Tasks;
+using VirtoCommerce.StoreModule.Core.Model;
+using VirtoCommerce.Xapi.Core.Models;
+
+namespace VirtoCommerce.Xapi.Core.Services;
+
+public interface IStoreDomainResolverService
+{
+    Task<Store> GetStoreAsync(StoreDomainRequest request);
+}

src/VirtoCommerce.Xapi.Data/Extensions/ServiceCollectionExtensions.cs

@@ -8,7 +8,6 @@
 using VirtoCommerce.Xapi.Core.Models;
 using VirtoCommerce.Xapi.Core.Services;
 using VirtoCommerce.Xapi.Data.Security;
-using VirtoCommerce.Xapi.Data.Security.Authorization;
 using VirtoCommerce.Xapi.Data.Services;
 using static VirtoCommerce.Xapi.Core.ModuleConstants;
 using ContactSignInValidator = VirtoCommerce.Xapi.Data.Security.OpenIddict.ContactSignInValidator;
@@ -55,8 +54,8 @@ public static IServiceCollection AddXCore(this IServiceCollection services, ICon
             services.AddTransient<ITokenRequestValidator, ContactSignInValidator>();
             services.AddTransient<IExternalSignInValidator, ExternalSignInValidator>();
             services.AddTransient<IExternalSignInUserBuilder, ExternalSignInUserBuilder>();
-
             services.AddTransient<ILoadUserToEvalContextService, LoadUserToEvalContextService>();
+            services.AddTransient<IStoreDomainResolverService, StoreDomainResolverService>();
             services.AddDistributedLockService(configuration);
 
             return services;

src/VirtoCommerce.Xapi.Data/Services/StoreDomainResolverService.cs

@@ -0,0 +1,65 @@
+using System.Linq;
+using System.Threading.Tasks;
+using Microsoft.Extensions.Options;
+using VirtoCommerce.Platform.Core.Common;
+using VirtoCommerce.StoreModule.Core.Model;
+using VirtoCommerce.StoreModule.Core.Model.Search;
+using VirtoCommerce.StoreModule.Core.Services;
+using VirtoCommerce.Xapi.Core.Models;
+using VirtoCommerce.Xapi.Core.Services;
+
+namespace VirtoCommerce.Xapi.Data.Services;
+
+public class StoreDomainResolverService : IStoreDomainResolverService
+{
+    private readonly IStoreService _storeService;
+    private readonly IStoreSearchService _storeSearchService;
+    private readonly StoresOptions _storeOptions;
+
+    public StoreDomainResolverService(
+        IStoreService storeService,
+        IStoreSearchService storeSearchService,
+        IOptions<StoresOptions> storeOptions)
+
+    {
+        _storeService = storeService;
+        _storeSearchService = storeSearchService;
+        _storeOptions = storeOptions.Value;
+    }
+
+    public async Task<Store> GetStoreAsync(StoreDomainRequest request)
+    {
+        Store store = null;
+
+        if (!string.IsNullOrEmpty(request.StoreId))
+        {
+            store = await _storeService.GetByIdAsync(request.StoreId, clone: false);
+        }
+        else if (!string.IsNullOrEmpty(request.Domain))
+        {
+            store = await ResolveStoreByDomain(request.Domain);
+
+            if (store == null && !string.IsNullOrEmpty(_storeOptions.DefaultStore))
+            {
+                store = await _storeService.GetByIdAsync(_storeOptions.DefaultStore, clone: false);
+            }
+        }
+
+        return store;
+    }
+
+    protected virtual async Task<Store> ResolveStoreByDomain(string domain)
+    {
+        if (_storeOptions.Domains.TryGetValue(domain, out var storeId))
+        {
+            return await _storeService.GetByIdAsync(storeId, clone: false);
+        }
+
+        var criteria = AbstractTypeFactory<StoreSearchCriteria>.TryCreateInstance();
+        criteria.Domain = domain;
+        criteria.Take = 1;
+
+        var result = await _storeSearchService.SearchAsync(criteria, clone: false);
+        return result.Results.FirstOrDefault();
+    }
+}