From 43fb42727e04465fb16d59a297dd12fba2184c51 Mon Sep 17 00:00:00 2001 From: Vincent Cloutier Date: Sun, 1 Jan 2023 15:55:05 -0500 Subject: [PATCH] bigger user batch --- .../Processors/RetrieveTwitterUsersProcessor.cs | 7 +------ .../Processors/RetrieveTwitterUsersProcessorTests.cs | 10 +++++----- 2 files changed, 6 insertions(+), 11 deletions(-) diff --git a/src/BirdsiteLive.Pipeline/Processors/RetrieveTwitterUsersProcessor.cs b/src/BirdsiteLive.Pipeline/Processors/RetrieveTwitterUsersProcessor.cs index a4f2396..ec58504 100644 --- a/src/BirdsiteLive.Pipeline/Processors/RetrieveTwitterUsersProcessor.cs +++ b/src/BirdsiteLive.Pipeline/Processors/RetrieveTwitterUsersProcessor.cs @@ -38,14 +38,9 @@ namespace BirdsiteLive.Pipeline.Processors try { - //var users = await _twitterUserDal.GetAllTwitterUsersAsync(50); - - //var splitUsers = users.Split(25).ToList(); - //var maxUsersNumber = await _maxUsersNumberProvider.GetMaxUsersNumberAsync(); - var users = await _twitterUserDal.GetAllTwitterUsersWithFollowersAsync(1000); + var users = await _twitterUserDal.GetAllTwitterUsersWithFollowersAsync(5000); var userCount = users.Any() ? Math.Min(users.Length, 25) : 1; - //var splitNumber = (int) Math.Ceiling(userCount / 15d); var splitUsers = users.Split(userCount).ToList(); foreach (var u in splitUsers) diff --git a/src/Tests/BirdsiteLive.Pipeline.Tests/Processors/RetrieveTwitterUsersProcessorTests.cs b/src/Tests/BirdsiteLive.Pipeline.Tests/Processors/RetrieveTwitterUsersProcessorTests.cs index 4949bb7..73397a8 100644 --- a/src/Tests/BirdsiteLive.Pipeline.Tests/Processors/RetrieveTwitterUsersProcessorTests.cs +++ b/src/Tests/BirdsiteLive.Pipeline.Tests/Processors/RetrieveTwitterUsersProcessorTests.cs @@ -41,7 +41,7 @@ namespace BirdsiteLive.Pipeline.Tests.Processors var twitterUserDalMock = new Mock(MockBehavior.Strict); twitterUserDalMock .Setup(x => x.GetAllTwitterUsersWithFollowersAsync( - It.Is(y => y == maxUsers))) + It.Is(y => true))) .ReturnsAsync(users); var loggerMock = new Mock>(); @@ -83,7 +83,7 @@ namespace BirdsiteLive.Pipeline.Tests.Processors var twitterUserDalMock = new Mock(MockBehavior.Strict); twitterUserDalMock .SetupSequence(x => x.GetAllTwitterUsersWithFollowersAsync( - It.Is(y => y == maxUsers))) + It.Is(y => true))) .ReturnsAsync(users.ToArray()) .ReturnsAsync(new SyncTwitterUser[0]) .ReturnsAsync(new SyncTwitterUser[0]) @@ -129,7 +129,7 @@ namespace BirdsiteLive.Pipeline.Tests.Processors var twitterUserDalMock = new Mock(MockBehavior.Strict); twitterUserDalMock .SetupSequence(x => x.GetAllTwitterUsersWithFollowersAsync( - It.Is(y => y == maxUsers))) + It.Is(y => true))) .ReturnsAsync(users.ToArray()) .ReturnsAsync(new SyncTwitterUser[0]) .ReturnsAsync(new SyncTwitterUser[0]) @@ -171,7 +171,7 @@ namespace BirdsiteLive.Pipeline.Tests.Processors var twitterUserDalMock = new Mock(MockBehavior.Strict); twitterUserDalMock .Setup(x => x.GetAllTwitterUsersWithFollowersAsync( - It.Is(y => y == maxUsers))) + It.Is(y => true))) .ReturnsAsync(new SyncTwitterUser[0]); var loggerMock = new Mock>(); @@ -207,7 +207,7 @@ namespace BirdsiteLive.Pipeline.Tests.Processors var twitterUserDalMock = new Mock(MockBehavior.Strict); twitterUserDalMock .Setup(x => x.GetAllTwitterUsersWithFollowersAsync( - It.Is(y => y == maxUsers))) + It.Is(y => true))) .Returns(async () => await DelayFaultedTask(new Exception())); var loggerMock = new Mock>();