in Facebook/FacebookSDK/JobProcessorFB.cs [81:96]
public async Task FetchUpdates(ConnectorTask taskInfo, SourceInfoFB sourceInfo, List<ItemMetadata> itemMetadata)
{
if (taskInfo.DirtyEntities != null && taskInfo.DirtyEntities?.Count != 0)
{
Trace.TraceInformation($"Number of dirty posts: {taskInfo.DirtyEntities?.Count}");
string url = QueryFB.GetUpdatedPostsUrl(taskInfo);
AuthenticationHeaderValue header = new AuthenticationHeaderValue("Bearer", sourceInfo.AccessToken);
Dictionary<string, PostFB> dict = await this.downloader.GetWebContent<Dictionary<string, PostFB>, ErrorsFB>(url, header);
foreach (KeyValuePair<string, PostFB> postEntry in dict)
{
await HandlePost(postEntry.Value, header, sourceInfo.PageId, sourceInfo.PageName, taskInfo, itemMetadata);
}
}
}