From 62caf7e956b61bf161cb971cc6568decc3edcaab Mon Sep 17 00:00:00 2001 From: Vincent Cloutier Date: Sun, 19 Mar 2023 11:35:30 -0400 Subject: [PATCH] don't send full backlog of tweets on first sync --- .../Processors/RetrieveTweetsProcessor.cs | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/src/BirdsiteLive.Pipeline/Processors/RetrieveTweetsProcessor.cs b/src/BirdsiteLive.Pipeline/Processors/RetrieveTweetsProcessor.cs index cfdb8a5..15c8d12 100644 --- a/src/BirdsiteLive.Pipeline/Processors/RetrieveTweetsProcessor.cs +++ b/src/BirdsiteLive.Pipeline/Processors/RetrieveTweetsProcessor.cs @@ -57,7 +57,13 @@ namespace BirdsiteLive.Pipeline.Processors.SubTasks { var tweets = await RetrieveNewTweets(user); _logger.LogInformation(index + "/" + syncTwitterUsers.Count() + " Got " + tweets.Length + " tweets from user " + user.Acct + " " ); - if (tweets.Length > 0 && user.LastTweetPostedId != -1) + if (tweets.Length > 0 && user.LastTweetPostedId == -1) + { + // skip the first time to avoid sending backlog of tweet + var tweetId = tweets.Last().Id; + await _twitterUserDal.UpdateTwitterUserAsync(user.Id, tweetId, tweetId, user.FetchingErrorCount, now); + } + else if (tweets.Length > 0 && user.LastTweetPostedId != -1) { userWtData.Tweets = tweets; usersWtTweets.Add(userWtData);