daohualiuxiang
/
dotnet-podcasts
mirror of https://github.com/microsoft/dotnet-podcasts.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

use a more realistic network delay simulation

pull/178/head
Chet Husk 2022-11-03 15:40:24 -05:00
parent 255a77456f
commit a4b55f5f3a
2 changed files with 12 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
src/Services/Podcasts/Podcast.Infrastructure/Http/Feeds/FeedClient.cs
View File

@ -7,6 +7,17 @@ using Podcast.Infrastructure.Data.Models;
namespace Podcast.Infrastructure.Http.Feeds; namespace Podcast.Infrastructure.Http.Feeds;
public class JitterHandler : DelegatingHandler
{
protected override async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken)
{
// Who would do such a thing?!
// TODO fix this horrible perf leak!
await Task.Delay(TimeSpan.FromSeconds(Random.Shared.NextInt64()));
return await base.SendAsync(request, cancellationToken);
}
}
public class FeedClient : IFeedClient public class FeedClient : IFeedClient
{ {
private static readonly XmlSerializer XmlSerializer = new(typeof(Rss)); private static readonly XmlSerializer XmlSerializer = new(typeof(Rss));

2
src/Services/Podcasts/Podcast.MinimalAPI/Program.cs
View File

@ -17,7 +17,7 @@ var connectionString = builder.Configuration.GetConnectionString("PodcastDb")!;
builder.Services.AddSqlServer<PodcastDbContext>(connectionString); builder.Services.AddSqlServer<PodcastDbContext>(connectionString);
var queueConnectionString = builder.Configuration.GetConnectionString("FeedQueue"); var queueConnectionString = builder.Configuration.GetConnectionString("FeedQueue");
builder.Services.AddSingleton(new QueueClient(queueConnectionString, "feed-queue")); builder.Services.AddSingleton(new QueueClient(queueConnectionString, "feed-queue"));
builder.Services.AddHttpClient<IFeedClient, FeedClient>(); builder.Services.AddHttpClient<IFeedClient, FeedClient>().AddHttpMessageHandler<JitterHandler>();
// Authentication and authorization-related services // Authentication and authorization-related services
builder.Services.AddAuthentication().AddJwtBearer(); builder.Services.AddAuthentication().AddJwtBearer();