diff --git a/src/BirdsiteLive.Pipeline/Contracts/ISaveProgressionTask.cs b/src/BirdsiteLive.Pipeline/Contracts/ISaveProgressionTask.cs deleted file mode 100644 index f920c81..0000000 --- a/src/BirdsiteLive.Pipeline/Contracts/ISaveProgressionTask.cs +++ /dev/null @@ -1,11 +0,0 @@ -using System.Threading; -using System.Threading.Tasks; -using BirdsiteLive.Pipeline.Models; - -namespace BirdsiteLive.Pipeline.Contracts -{ - public interface ISaveProgressionTask - { - Task ProcessAsync(UserWithDataToSync userWithTweetsToSync, CancellationToken ct); - } -} \ No newline at end of file diff --git a/src/BirdsiteLive.Pipeline/StatusPublicationPipeline.cs b/src/BirdsiteLive.Pipeline/StatusPublicationPipeline.cs index cbdd169..fdbb9bd 100644 --- a/src/BirdsiteLive.Pipeline/StatusPublicationPipeline.cs +++ b/src/BirdsiteLive.Pipeline/StatusPublicationPipeline.cs @@ -21,16 +21,14 @@ namespace BirdsiteLive.Pipeline private readonly IRetrieveTweetsProcessor _retrieveTweetsProcessor; private readonly IRetrieveFollowersProcessor _retrieveFollowersProcessor; private readonly ISendTweetsToFollowersProcessor _sendTweetsToFollowersProcessor; - private readonly ISaveProgressionTask _saveProgressionTask; private readonly ILogger _logger; #region Ctor - public StatusPublicationPipeline(IRetrieveTweetsProcessor retrieveTweetsProcessor, IRetrieveTwitterUsersProcessor retrieveTwitterAccountsProcessor, IRetrieveFollowersProcessor retrieveFollowersProcessor, ISendTweetsToFollowersProcessor sendTweetsToFollowersProcessor, ISaveProgressionTask saveProgressionTask, ILogger logger) + public StatusPublicationPipeline(IRetrieveTweetsProcessor retrieveTweetsProcessor, IRetrieveTwitterUsersProcessor retrieveTwitterAccountsProcessor, IRetrieveFollowersProcessor retrieveFollowersProcessor, ISendTweetsToFollowersProcessor sendTweetsToFollowersProcessor, ILogger logger) { _retrieveTweetsProcessor = retrieveTweetsProcessor; _retrieveFollowersProcessor = retrieveFollowersProcessor; _sendTweetsToFollowersProcessor = sendTweetsToFollowersProcessor; - _saveProgressionTask = saveProgressionTask; _retrieveTwitterAccountsProcessor = retrieveTwitterAccountsProcessor; _logger = logger; diff --git a/src/Tests/BirdsiteLive.Pipeline.Tests/Processors/SendTweetsToFollowersProcessorTests.cs b/src/Tests/BirdsiteLive.Pipeline.Tests/Processors/SendTweetsToFollowersProcessorTests.cs index 2121831..c131c2b 100644 --- a/src/Tests/BirdsiteLive.Pipeline.Tests/Processors/SendTweetsToFollowersProcessorTests.cs +++ b/src/Tests/BirdsiteLive.Pipeline.Tests/Processors/SendTweetsToFollowersProcessorTests.cs @@ -77,7 +77,6 @@ namespace BirdsiteLive.Pipeline.Tests.Processors var followersDalMock = new Mock(MockBehavior.Strict); var loggerMock = new Mock>(); - var saveProgressMock = new Mock(); var settings = new InstanceSettings { @@ -165,7 +164,6 @@ namespace BirdsiteLive.Pipeline.Tests.Processors ParallelFediversePosts = 1 }; - var saveProgressMock = new Mock(); var removeFollowerMock = new Mock(MockBehavior.Strict); #endregion @@ -250,7 +248,6 @@ namespace BirdsiteLive.Pipeline.Tests.Processors .Returns(Task.CompletedTask); var loggerMock = new Mock>(); - var saveProgressMock = new Mock(); var settings = new InstanceSettings { @@ -343,7 +340,6 @@ namespace BirdsiteLive.Pipeline.Tests.Processors var loggerMock = new Mock>(); - var saveProgressMock = new Mock(); var settings = new InstanceSettings { ParallelFediversePosts = 1 @@ -440,7 +436,6 @@ namespace BirdsiteLive.Pipeline.Tests.Processors var loggerMock = new Mock>(); - var saveProgressMock = new Mock(); var settings = new InstanceSettings { ParallelFediversePosts = 1 @@ -519,7 +514,6 @@ namespace BirdsiteLive.Pipeline.Tests.Processors var followersDalMock = new Mock(MockBehavior.Strict); var loggerMock = new Mock>(); - var saveProgressMock = new Mock(); var settings = new InstanceSettings { @@ -600,7 +594,6 @@ namespace BirdsiteLive.Pipeline.Tests.Processors var followersDalMock = new Mock(MockBehavior.Strict); var loggerMock = new Mock>(); - var saveProgressMock = new Mock(); var settings = new InstanceSettings { @@ -689,7 +682,6 @@ namespace BirdsiteLive.Pipeline.Tests.Processors .Returns(Task.CompletedTask); var loggerMock = new Mock>(); - var saveProgressMock = new Mock(); var settings = new InstanceSettings { @@ -775,7 +767,6 @@ namespace BirdsiteLive.Pipeline.Tests.Processors var followersDalMock = new Mock(MockBehavior.Strict); var loggerMock = new Mock>(); - var saveProgressMock = new Mock(); var settings = new InstanceSettings { @@ -865,7 +856,6 @@ namespace BirdsiteLive.Pipeline.Tests.Processors var followersDalMock = new Mock(MockBehavior.Strict); var loggerMock = new Mock>(); - var saveProgressMock = new Mock(); var settings = new InstanceSettings { @@ -959,7 +949,6 @@ namespace BirdsiteLive.Pipeline.Tests.Processors .Returns(Task.CompletedTask); var loggerMock = new Mock>(); - var saveProgressMock = new Mock(); var settings = new InstanceSettings { @@ -1054,7 +1043,6 @@ namespace BirdsiteLive.Pipeline.Tests.Processors .Returns(Task.CompletedTask); var loggerMock = new Mock>(); - var saveProgressMock = new Mock(); var settings = new InstanceSettings { diff --git a/src/Tests/BirdsiteLive.Pipeline.Tests/StatusPublicationPipelineTests.cs b/src/Tests/BirdsiteLive.Pipeline.Tests/StatusPublicationPipelineTests.cs index 31f52c5..a0d2129 100644 --- a/src/Tests/BirdsiteLive.Pipeline.Tests/StatusPublicationPipelineTests.cs +++ b/src/Tests/BirdsiteLive.Pipeline.Tests/StatusPublicationPipelineTests.cs @@ -30,18 +30,16 @@ namespace BirdsiteLive.Pipeline.Tests var retrieveTweetsProcessor = new Mock(MockBehavior.Strict); var retrieveFollowersProcessor = new Mock(MockBehavior.Strict); var sendTweetsToFollowersProcessor = new Mock(MockBehavior.Strict); - var saveProgressionProcessor = new Mock(MockBehavior.Strict); var logger = new Mock>(); #endregion - var pipeline = new StatusPublicationPipeline(retrieveTweetsProcessor.Object, retrieveTwitterUserProcessor.Object, retrieveFollowersProcessor.Object, sendTweetsToFollowersProcessor.Object, saveProgressionProcessor.Object, logger.Object); + var pipeline = new StatusPublicationPipeline(retrieveTweetsProcessor.Object, retrieveTwitterUserProcessor.Object, retrieveFollowersProcessor.Object, sendTweetsToFollowersProcessor.Object, logger.Object); await pipeline.ExecuteAsync(ct.Token); #region Validations retrieveTweetsProcessor.VerifyAll(); retrieveFollowersProcessor.VerifyAll(); sendTweetsToFollowersProcessor.VerifyAll(); - saveProgressionProcessor.VerifyAll(); logger.VerifyAll(); #endregion }