Fix for a couple of failure scenarios

Author: Drawaes

CondenserDotNet.sln

@@ -83,10 +83,15 @@ Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "Release Notes", "Release No
 		releasenotes\4.1.1.props = releasenotes\4.1.1.props
 		releasenotes\4.1.10.props = releasenotes\4.1.10.props
 		releasenotes\4.1.11.props = releasenotes\4.1.11.props
+		releasenotes\4.1.12.props = releasenotes\4.1.12.props
 		releasenotes\4.1.13.props = releasenotes\4.1.13.props
 		releasenotes\4.1.3.props = releasenotes\4.1.3.props
 		releasenotes\4.1.4.props = releasenotes\4.1.4.props
 		releasenotes\4.1.9.props = releasenotes\4.1.9.props
+		releasenotes\5.0.0.props = releasenotes\5.0.0.props
+		releasenotes\5.1.0.props = releasenotes\5.1.0.props
+		releasenotes\5.2.0.props = releasenotes\5.2.0.props
+		releasenotes\5.2.1.props = releasenotes\5.2.1.props
 	EndProjectSection
 EndProject
 Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "CondenserDotNet.Middleware", "src\CondenserDotNet.Middleware\CondenserDotNet.Middleware.csproj", "{5DC8FA9E-4CB9-4F80-8AA9-7F4ABF8375B3}"

releasenotes/5.2.1.props

@@ -0,0 +1,8 @@
+<Project>
+  <PropertyGroup>
+    <PackageReleaseNotes>
+* Added refresh session when leadership has 3 failures
+* Reset Consul Index on service lookup when there is a failure
+</PackageReleaseNotes>
+  </PropertyGroup>
+</Project>

src/CondenserDotNet.Client/Leadership/LeaderWatcher.cs

@@ -22,7 +22,7 @@ public class LeaderWatcher : ILeaderWatcher
         private IServiceManager _serviceManager;
         private string _keyToWatch;
         private AsyncManualResetEvent<InformationService> _currentInfoService = new AsyncManualResetEvent<InformationService>();
-        
+
         public LeaderWatcher(IServiceManager serviceManager, string keyToWatch)
         {
             _currentInfoService.Reset();
@@ -78,17 +78,25 @@ private StringContent GetServiceInformation() => HttpUtils.GetStringContent(new
         private async Task KeepLeadershipLoop()
         {
             var sessionId = await _sessionIdTask.ConfigureAwait(false);
+            var errorCount = 0;
             while (true)
             {
                 var leaderResult = await _serviceManager.Client.PutAsync($"{KeyPath}{_keyToWatch}?acquire={sessionId}", GetServiceInformation()).ConfigureAwait(false);
                 if (!leaderResult.IsSuccessStatusCode)
                 {
+                    errorCount++;
                     //error so we need to get a new session
                     await Task.Delay(500).ConfigureAwait(false);
+                    if (errorCount > 3)
+                    {
+                        _sessionIdTask = GetSession();
+                        sessionId = await _sessionIdTask.ConfigureAwait(false);
+                        errorCount = 0;
+                    }
                     continue;
                 }
                 var areWeLeader = bool.Parse(await leaderResult.Content.ReadAsStringAsync().ConfigureAwait(false));
-                if(areWeLeader)
+                if (areWeLeader)
                 {
                     _electedLeaderEvent.Set(true);
                 }
@@ -102,7 +110,7 @@ private async Task KeepLeadershipLoop()
 
         private async Task WaitForLeadershipChange()
         {
-            while(true)
+            while (true)
             {
                 using (var leaderResult = await _serviceManager.Client.GetAsync($"{KeyPath}{_keyToWatch}?index={_consulIndex}").ConfigureAwait(false))
                 {

src/CondenserDotNet.Client/Leadership/LeaderWatcherNew.cs

@@ -97,6 +97,7 @@ private async Task WatcherLoop(HttpClient client)
                                     {
                                         _state = WatcherState.UsingCachedValues;
                                     }
+                                    consulIndex = "0";
                                     await Task.Delay(1000).ConfigureAwait(false);
                                     continue;
                                 }

src/CondenserDotNet.Client/Services/ServiceWatcher.cs

@@ -1,6 +1,6 @@
 <Project>
     <PropertyGroup>
-        <VersionPrefix>5.2.0</VersionPrefix>
+        <VersionPrefix>5.2.1</VersionPrefix>
         <VersionSuffix>beta</VersionSuffix>
     </PropertyGroup>
 </Project>