43 lines
1.3 KiB
C#
43 lines
1.3 KiB
C#
|
using System;
|
|||
|
|
using System.Threading;
|
|||
|
|
using System.Threading.Tasks;
|
|||
|
|
using System.Threading.Tasks.Dataflow;
|
|||
|
|
using BirdsiteLive.DAL.Contracts;
|
|||
|
|
using BirdsiteLive.DAL.Models;
|
|||
|
|
using BirdsiteLive.Pipeline.Contracts;
|
|||
|
|
|
|||
|
|
namespace BirdsiteLive.Pipeline.Processors
|
|||
|
|
{
|
|||
|
|
public class RetrieveTwitterUsersProcessor : IRetrieveTwitterUsersProcessor
|
|||
|
|
{
|
|||
|
|
private readonly ITwitterUserDal _twitterUserDal;
|
|||
|
|
private const int SyncPeriod = 15; //in minutes
|
|||
|
|
|
|||
|
|
#region Ctor
|
|||
|
|
public RetrieveTwitterUsersProcessor(ITwitterUserDal twitterUserDal)
|
|||
|
|
{
|
|||
|
|
_twitterUserDal = twitterUserDal;
|
|||
|
|
}
|
|||
|
|
#endregion
|
|||
|
|
|
|||
|
|
public async Task GetTwitterUsersAsync(BufferBlock<SyncTwitterUser[]> twitterUsersBufferBlock, CancellationToken ct)
|
|||
|
|
{
|
|||
|
|
for (;;)
|
|||
|
|
{
|
|||
|
|
ct.ThrowIfCancellationRequested();
|
|||
|
|
|
|||
|
|
try
|
|||
|
|
{
|
|||
|
|
var users = await _twitterUserDal.GetAllTwitterUsersAsync();
|
|||
|
|
await twitterUsersBufferBlock.SendAsync(users, ct);
|
|||
|
|
}
|
|||
|
|
catch (Exception e)
|
|||
|
|
{
|
|||
|
|
Console.WriteLine(e);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
await Task.Delay(SyncPeriod * 1000 * 60, ct);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|