glenux-archive/cloutier--bird.makeup
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

made twitter service more async

Browse source
This commit is contained in:
Vincent Cloutier 2022-12-26 11:13:00 -05:00
parent 29d8091997
commit e21381bee8
2 changed files with 5 additions and 14 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
src/BirdsiteLive.Pipeline/Processors/RetrieveTweetsProcessor.cs
View file

@ -39,7 +39,7 @@ namespace BirdsiteLive.Pipeline.Processors
foreach (var userWtData in syncTwitterUsers) foreach (var userWtData in syncTwitterUsers)
{ {
var user = userWtData.User; var user = userWtData.User;
var tweets = RetrieveNewTweets(user); var tweets = await RetrieveNewTweets(user);
_logger.LogInformation("Got " + tweets.Length + " tweets from user " + user.Acct); _logger.LogInformation("Got " + tweets.Length + " tweets from user " + user.Acct);
if (tweets.Length > 0 && user.LastTweetPostedId != -1) if (tweets.Length > 0 && user.LastTweetPostedId != -1)
{ {
@ -64,16 +64,16 @@ namespace BirdsiteLive.Pipeline.Processors
return usersWtTweets.ToArray(); return usersWtTweets.ToArray();
} }
private ExtractedTweet[] RetrieveNewTweets(SyncTwitterUser user) private async Task<ExtractedTweet[]> RetrieveNewTweets(SyncTwitterUser user)
{ {
var tweets = new ExtractedTweet[0]; var tweets = new ExtractedTweet[0];
try try
{ {
if (user.LastTweetPostedId == -1) if (user.LastTweetPostedId == -1)
tweets = _twitterTweetsService.GetTimeline(user.Acct, 1); tweets = await _twitterTweetsService.GetTimelineAsync(user.Acct, 1);
else else
tweets = _twitterTweetsService.GetTimeline(user.Acct, 200, user.LastTweetSynchronizedForAllFollowersId); tweets = await _twitterTweetsService.GetTimelineAsync(user.Acct, 200, user.LastTweetSynchronizedForAllFollowersId);
} }
catch (Exception e) catch (Exception e)
{ {

11
src/BirdsiteLive.Twitter/TwitterTweetsService.cs
View file

@ -18,8 +18,7 @@ namespace BirdsiteLive.Twitter
public interface ITwitterTweetsService public interface ITwitterTweetsService
{ {
Task<ExtractedTweet> GetTweetAsync(long statusId); Task<ExtractedTweet> GetTweetAsync(long statusId);
ExtractedTweet GetTweet(long statusId); Task<ExtractedTweet[]> GetTimelineAsync(string username, int nberTweets, long fromTweetId = -1);
ExtractedTweet[] GetTimeline(string username, int nberTweets, long fromTweetId = -1);
} }
public class TwitterTweetsService : ITwitterTweetsService public class TwitterTweetsService : ITwitterTweetsService
@ -41,10 +40,6 @@ namespace BirdsiteLive.Twitter
#endregion #endregion
public ExtractedTweet GetTweet(long statusId)
{
return GetTweetAsync(statusId).Result;
}
public async Task<ExtractedTweet> GetTweetAsync(long statusId) public async Task<ExtractedTweet> GetTweetAsync(long statusId)
{ {
@ -79,10 +74,6 @@ namespace BirdsiteLive.Twitter
} }
} }
public ExtractedTweet[] GetTimeline(string username, int nberTweets, long fromTweetId = -1)
{
return GetTimelineAsync(username, nberTweets, fromTweetId).Result;
}
public async Task<ExtractedTweet[]> GetTimelineAsync(string username, int nberTweets, long fromTweetId = -1) public async Task<ExtractedTweet[]> GetTimelineAsync(string username, int nberTweets, long fromTweetId = -1)
{ {
if (nberTweets < 5) if (nberTweets < 5)