Add polling change expiration token to association service

VirtoCommerce · Oct 21, 2020 · 38acc3a · 38acc3a
1 parent 715c806
commit 38acc3a
Show file tree

Hide file tree

Showing 2 changed files with 19 additions and 14 deletions.
diff --git a/VirtoCommerce.Storefront/Domain/Recommendations/DynamicAssociationsProvider.cs b/VirtoCommerce.Storefront/Domain/Recommendations/DynamicAssociationsProvider.cs
@@ -4,40 +4,39 @@
 using System.Threading.Tasks;
 using Microsoft.Extensions.Caching.Memory;
 using VirtoCommerce.Storefront.AutoRestClients.DynamicAssociationsModuleModuleApi;
-using VirtoCommerce.Storefront.Common;
-using VirtoCommerce.Storefront.Model;
+using VirtoCommerce.Storefront.Infrastructure;
 using VirtoCommerce.Storefront.Model.Caching;
 using VirtoCommerce.Storefront.Model.Catalog;
 using VirtoCommerce.Storefront.Model.Common.Caching;
 using VirtoCommerce.Storefront.Model.Recommendations;
 using VirtoCommerce.Storefront.Model.Services;
 
-namespace VirtoCommerce.Storefront.Domain
+namespace VirtoCommerce.Storefront.Domain.Recommendations
 {
     public class DynamicAssociationsProvider : IRecommendationsProvider
     {
         private readonly ICatalogService _catalogService;
         private readonly IAssociations _associationsApi;
         private readonly IStorefrontMemoryCache _memoryCache;
+        private readonly IApiChangesWatcher _apiChangesWatcher;
 
-        public DynamicAssociationsProvider(ICatalogService catalogService, IAssociations associationsApi,
-            IStorefrontMemoryCache memoryCache)
+        public DynamicAssociationsProvider(
+            ICatalogService catalogService,
+            IAssociations associationsApi,
+            IStorefrontMemoryCache memoryCache,
+            IApiChangesWatcher apiChangesWatcher
+            )
         {
             _catalogService = catalogService;
             _associationsApi = associationsApi;
             _memoryCache = memoryCache;
+            _apiChangesWatcher = apiChangesWatcher;
         }
-        public string ProviderName
-        {
-            get
-            {
-                return "DynamicAssociations";
-            }
-        }
+
+        public string ProviderName => "DynamicAssociations";
 
         public Task AddEventAsync(IEnumerable<UsageEvent> events)
         {
-            //Nothing todo
             return Task.FromResult(true);
         }
 
@@ -49,22 +48,27 @@ public RecommendationEvalContext CreateEvalContext()
         public async Task<Product[]> GetRecommendationsAsync(RecommendationEvalContext context)
         {
             var dynamicAssociationsContext = context as DynamicAssociationsEvalContext;
+
             if (dynamicAssociationsContext == null)
             {
                 throw new InvalidCastException(nameof(context));
             }
 
-            var cacheKey = CacheKey.With(GetType(), "GetRecommendationsAsync", context.GetCacheKey());
+            var cacheKey = CacheKey.With(GetType(), nameof(GetRecommendationsAsync), context.GetCacheKey());
+
             return await _memoryCache.GetOrCreateExclusiveAsync(cacheKey, async (cacheEntry) =>
             {
                 cacheEntry.AddExpirationToken(RecommendationsCacheRegion.CreateChangeToken());
+                cacheEntry.AddExpirationToken(_apiChangesWatcher.CreateChangeToken());
 
                 var result = new List<Product>();
                 var recommendedProductIds = await _associationsApi.EvaluateDynamicAssociationsAsync(dynamicAssociationsContext.ToContextDto());
+
                 if (recommendedProductIds != null)
                 {
                     result.AddRange(await _catalogService.GetProductsAsync(recommendedProductIds.ToArray(), ItemResponseGroup.Seo | ItemResponseGroup.Outlines | ItemResponseGroup.ItemWithPrices | ItemResponseGroup.ItemWithDiscounts | ItemResponseGroup.Inventory));
                 }
+
                 return result.ToArray();
             });
         }

diff --git a/VirtoCommerce.Storefront/Startup.cs b/VirtoCommerce.Storefront/Startup.cs
@@ -31,6 +31,7 @@
 using VirtoCommerce.Storefront.Domain;
 using VirtoCommerce.Storefront.Domain.Cart.Demo;
 using VirtoCommerce.Storefront.Domain.Catalog;
+using VirtoCommerce.Storefront.Domain.Recommendations;
 using VirtoCommerce.Storefront.Domain.Security;
 using VirtoCommerce.Storefront.Extensions;
 using VirtoCommerce.Storefront.Filters;