Replay any cache invalidation requests that happen before RepositoryManager is set

Author: shana

src/GitHub.Api/Application/ApplicationManagerBase.cs

@@ -150,6 +150,7 @@ public void RestartRepository()
                 repositoryManager.Initialize();
                 Environment.Repository.Initialize(repositoryManager);
                 repositoryManager.Start();
+                Environment.Repository.Start();
                 Logger.Trace($"Got a repository? {Environment.Repository}");
             }
         }

src/GitHub.Api/Git/IRepository.cs

@@ -78,5 +78,6 @@ public interface IRepository : IEquatable<IRepository>
         event Action<CacheUpdateEvent> LocksChanged;
         event Action<CacheUpdateEvent> RemoteBranchListChanged;
         event Action<CacheUpdateEvent> LocalAndRemoteBranchListChanged;
+        void Start();
     }
 }

src/GitHub.Api/Git/Repository.cs

@@ -15,6 +15,7 @@ class Repository : IEquatable<Repository>, IRepository
         private ICacheContainer cacheContainer;
         private UriString cloneUrl;
         private string name;
+        private HashSet<CacheType> cacheInvalidationRequests = new HashSet<CacheType>();
 
         public event Action<CacheUpdateEvent> LogChanged;
         public event Action<CacheUpdateEvent> TrackingStatusChanged;
@@ -39,7 +40,7 @@ public Repository(NPath localPath, ICacheContainer container)
             LocalPath = localPath;
 
             cacheContainer = container;
-            cacheContainer.CacheInvalidated += CacheContainer_OnCacheInvalidated;
+            cacheContainer.CacheInvalidated += InvalidateCache;
             cacheContainer.CacheUpdated += CacheContainer_OnCacheUpdated;
         }
 
@@ -58,6 +59,14 @@ public void Initialize(IRepositoryManager initRepositoryManager)
             repositoryManager.RemoteBranchesUpdated += RepositoryManagerOnRemoteBranchesUpdated;
         }
 
+        public void Start()
+        {
+            foreach (var req in cacheInvalidationRequests)
+            {
+                InvalidateCache(req);
+            }
+        }
+
         public ITask SetupRemote(string remote, string remoteUrl)
         {
             Guard.ArgumentNotNullOrWhiteSpace(remote, "remote");
@@ -275,8 +284,16 @@ private void CheckBranchCacheEvent(CacheUpdateEvent cacheUpdateEvent)
             }
         }
 
-        private void CacheContainer_OnCacheInvalidated(CacheType cacheType)
+        private void InvalidateCache(CacheType cacheType)
         {
+            if (repositoryManager == null)
+            {
+                if (!cacheInvalidationRequests.Contains(cacheType))
+                    cacheInvalidationRequests.Add(cacheType);
+                return;
+            }
+
+
             switch (cacheType)
             {
                 case CacheType.BranchCache:

src/GitHub.Api/Git/RepositoryManager.cs

@@ -42,11 +42,11 @@ public interface IRepositoryManager : IDisposable
         void UpdateGitAheadBehindStatus();
         void UpdateLocks();
         int WaitForEvents();
+        void UpdateRepositoryInfo();
 
         IGitConfig Config { get; }
         IGitClient GitClient { get; }
         bool IsBusy { get; }
-        void UpdateRepositoryInfo();
     }
 
     interface IRepositoryPathConfiguration
@@ -400,7 +400,7 @@ private ITask HookupHandlers(ITask task, bool filesystemChangesExpected)
             var isExclusive = task.IsChainExclusive();
             task.GetTopOfChain().OnStart += t =>
             {
-                if (t.Affinity == TaskAffinity.Exclusive)
+                if (isExclusive)
                 {
                     Logger.Trace("Starting Operation - Setting Busy Flag");
                     IsBusy = true;