Merge pull request #111 from TransactionProcessing/task/#110_configurablesscache

Make cache configurable

Author: StuartFerguson

Shared.EventStore/SubscriptionWorker/SubscriptionRepository.cs

@@ -28,11 +28,11 @@ public class SubscriptionRepository : ISubscriptionRepository
 
         #region Constructors
 
-        private SubscriptionRepository()
+        private SubscriptionRepository(Int32 cacheDuration = 120)
         {
             this.Subscriptions = new PersistentSubscriptions();
 
-            this.RefreshRequired = (force, s) => force || s.InitialState || SubscriptionRepository.RefreshNeeded(s.LastTimeRefreshed);
+            this.RefreshRequired = (force, s) => force || s.InitialState || SubscriptionRepository.RefreshNeeded(s.LastTimeRefreshed, cacheDuration);
         }
 
         #endregion
@@ -45,28 +45,28 @@ private SubscriptionRepository()
 
         #region Methods
 
-        public static SubscriptionRepository Create(String eventStoreConnectionString)
+        public static SubscriptionRepository Create(String eventStoreConnectionString,Int32 cacheDuration = 120)
         {
             EventStoreClientSettings settings = EventStoreClientSettings.Create(eventStoreConnectionString);
             HttpClient httpClient = SubscriptionWorkerHelper.CreateHttpClient(settings);
 
-            return new SubscriptionRepository
+            return new SubscriptionRepository(cacheDuration)
                    {
                        GetAllSubscriptions = cancellationToken => SubscriptionRepository.GetSubscriptions(httpClient, cancellationToken)
                    };
         }
 
-        public static SubscriptionRepository Create(Task<List<PersistentSubscriptionInfo>> func)
+        public static SubscriptionRepository Create(Task<List<PersistentSubscriptionInfo>> func,Int32 cacheDuration = 120)
         {
-            return new()
+            return new(cacheDuration)
                    {
                        GetAllSubscriptions = _ => func
                    };
         }
 
-        public static SubscriptionRepository Create(Func<CancellationToken, Task<List<PersistentSubscriptionInfo>>> func)
+        public static SubscriptionRepository Create(Func<CancellationToken, Task<List<PersistentSubscriptionInfo>>> func,Int32 cacheDuration = 120)
         {
-            return new()
+            return new(cacheDuration)
                    {
                        GetAllSubscriptions = func
                    };
@@ -147,16 +147,11 @@ private PersistentSubscriptions GetSubscriptionsFromCache(String reason)
             return this.Subscriptions;
         }
 
-        private static Boolean RefreshNeeded(DateTime lastRefreshed)
+        private static Boolean RefreshNeeded(DateTime lastRefreshed, Int32 cacheDuration)
         {
             TimeSpan elapsed = DateTime.Now - lastRefreshed;
 
-            //TODO: Add to configuration
-            //OR this.PersistentSubscriptionPollingInSeconds x 2 ?
-            //60 seconds is how often we are willing to refresh our cache.
-            //I suspect this could be much higher (trade of with update the UI and wanting response, versus how often we hot the hit ES essentially getting
-            //the same information each time.
-            if (elapsed.TotalSeconds < 120)
+            if (elapsed.TotalSeconds < cacheDuration)
             {
                 return false;
             }