From c4ee6be8ce226cef6db6f48d7f588d3fd449fb64 Mon Sep 17 00:00:00 2001
From: Nicolas Constant <github@nicolas-constant.com>
Date: Sun, 5 Sep 2021 14:38:56 -0400
Subject: [PATCH] added reset error count

---
 .../RefreshTwitterUserStatusProcessor.cs      |  1 +
 .../RefreshTwitterUserStatusProcessorTests.cs | 43 +++++++++++++++++++
 2 files changed, 44 insertions(+)

diff --git a/src/BirdsiteLive.Pipeline/Processors/RefreshTwitterUserStatusProcessor.cs b/src/BirdsiteLive.Pipeline/Processors/RefreshTwitterUserStatusProcessor.cs
index 7d8d6db..b4883ab 100644
--- a/src/BirdsiteLive.Pipeline/Processors/RefreshTwitterUserStatusProcessor.cs
+++ b/src/BirdsiteLive.Pipeline/Processors/RefreshTwitterUserStatusProcessor.cs
@@ -39,6 +39,7 @@ namespace BirdsiteLive.Pipeline.Processors
                 }
                 else if (!userView.Protected)
                 {
+                    user.FetchingErrorCount = 0;
                     var userWtData = new UserWithDataToSync
                     {
                         User = user
diff --git a/src/Tests/BirdsiteLive.Pipeline.Tests/Processors/RefreshTwitterUserStatusProcessorTests.cs b/src/Tests/BirdsiteLive.Pipeline.Tests/Processors/RefreshTwitterUserStatusProcessorTests.cs
index ae7f004..0045120 100644
--- a/src/Tests/BirdsiteLive.Pipeline.Tests/Processors/RefreshTwitterUserStatusProcessorTests.cs
+++ b/src/Tests/BirdsiteLive.Pipeline.Tests/Processors/RefreshTwitterUserStatusProcessorTests.cs
@@ -64,6 +64,49 @@ namespace BirdsiteLive.Pipeline.Tests.Processors
             #endregion
         }
 
+        [TestMethod]
+        public async Task ProcessAsync_ResetErrorCount_Test()
+        {
+            #region Stubs
+            var userId1 = 1;
+
+            var users = new List<SyncTwitterUser>
+            {
+                new SyncTwitterUser
+                {
+                    Id = userId1,
+                    FetchingErrorCount = 100
+                }
+            };
+            #endregion
+
+            #region Mocks
+            var twitterUserServiceMock = new Mock<ICachedTwitterUserService>(MockBehavior.Strict);
+            twitterUserServiceMock
+                .Setup(x => x.GetUser(It.IsAny<string>()))
+                .Returns(new TwitterUser
+                {
+                    Protected = false
+                });
+
+            var twitterUserDalMock = new Mock<ITwitterUserDal>(MockBehavior.Strict);
+            var removeTwitterAccountActionMock = new Mock<IRemoveTwitterAccountAction>(MockBehavior.Strict);
+            #endregion
+
+            var processor = new RefreshTwitterUserStatusProcessor(twitterUserServiceMock.Object, twitterUserDalMock.Object, removeTwitterAccountActionMock.Object);
+            var result = await processor.ProcessAsync(users.ToArray(), CancellationToken.None);
+
+            #region Validations
+            Assert.AreEqual(1, result.Length);
+            Assert.IsTrue(result.Any(x => x.User.Id == userId1));
+            Assert.AreEqual(0, result.First().User.FetchingErrorCount);
+
+            twitterUserServiceMock.VerifyAll();
+            twitterUserDalMock.VerifyAll();
+            removeTwitterAccountActionMock.VerifyAll();
+            #endregion
+        }
+
         [TestMethod]
         public async Task ProcessAsync_Unfound_Test()
         {