diff --git a/src/BirdsiteLive.Pipeline/Processors/SubTasks/SendTweetsTaskBase.cs b/src/BirdsiteLive.Pipeline/Processors/SubTasks/SendTweetsTaskBase.cs index 79fd5ef..58ae052 100644 --- a/src/BirdsiteLive.Pipeline/Processors/SubTasks/SendTweetsTaskBase.cs +++ b/src/BirdsiteLive.Pipeline/Processors/SubTasks/SendTweetsTaskBase.cs @@ -3,29 +3,30 @@ using System.Threading.Tasks; using BirdsiteLive.DAL.Contracts; using BirdsiteLive.DAL.Models; -namespace BirdsiteLive.Pipeline.Processors.SubTasks; - -public class SendTweetsTaskBase +namespace BirdsiteLive.Pipeline.Processors.SubTasks { - private readonly ISyncTweetsPostgresDal _syncTweetsPostgresDal; - - #region Ctor - protected SendTweetsTaskBase(ISyncTweetsPostgresDal syncTweetsPostgresDal) + public class SendTweetsTaskBase { - _syncTweetsPostgresDal = syncTweetsPostgresDal; - } - #endregion + private readonly ISyncTweetsPostgresDal _syncTweetsPostgresDal; - protected async Task SaveSyncTweetAsync(string acct, long tweetId, string host, string inbox) - { - var inboxUrl = $"https://{host}/{inbox.Trim('/')}"; - var tweet = new SyncTweet + #region Ctor + protected SendTweetsTaskBase(ISyncTweetsPostgresDal syncTweetsPostgresDal) { - Acct = acct, - TweetId = tweetId, - PublishedAt = DateTime.UtcNow, - Inbox = inboxUrl - }; - await _syncTweetsPostgresDal.SaveTweetAsync(tweet); + _syncTweetsPostgresDal = syncTweetsPostgresDal; + } + #endregion + + protected async Task SaveSyncTweetAsync(string acct, long tweetId, string host, string inbox) + { + var inboxUrl = $"https://{host}/{inbox.Trim('/')}"; + var tweet = new SyncTweet + { + Acct = acct, + TweetId = tweetId, + PublishedAt = DateTime.UtcNow, + Inbox = inboxUrl + }; + await _syncTweetsPostgresDal.SaveTweetAsync(tweet); + } } } \ No newline at end of file