Create functional tests for additional integrations

[radical]

Split from #1566

We are missing the EntityFramework components in our functional integration tests added in #1217. We should add them, plus any other missing components that would be valuable.

TODO:

• cosmos
• 🔴 blocked: dapr (needs dapr cli installed)
• nats
• seq
• qdrant
• orleans

Tests needed that reference these nugets too:

• Microsoft.Extensions.ServiceDiscovery
• Microsoft.Extensions.ServiceDiscovery.Abstractions
• Microsoft.Extensions.ServiceDiscovery.Dns
• Microsoft.Extensions.ServiceDiscovery.Yarp

cc @eerhardt

[eerhardt]

qdrant is done:

aspire/tests/Aspire.Hosting.Qdrant.Tests/QdrantFunctionalTests.cs

Lines 23 to 63 in 9a68b55

	[Fact]
	[RequiresDocker]
	public async Task VerifyQdrantResource()
	{
	var cts = new CancellationTokenSource(TimeSpan.FromMinutes(3));
	var pipeline = new ResiliencePipelineBuilder()
	.AddRetry(new() { MaxRetryAttempts = 10, Delay = TimeSpan.FromSeconds(1), ShouldHandle = new PredicateBuilder().Handle<RpcException>() })
	.Build();
	using var builder = TestDistributedApplicationBuilder.CreateWithTestContainerRegistry(testOutputHelper);
	var qdrant = builder.AddQdrant("qdrant");
	using var app = builder.Build();
	await app.StartAsync();
	var hb = Host.CreateApplicationBuilder();
	hb.Configuration.AddInMemoryCollection(new Dictionary<string, string?>
	{
	[$"ConnectionStrings:{qdrant.Resource.Name}"] = await qdrant.Resource.ConnectionStringExpression.GetValueAsync(default)
	});
	hb.AddQdrantClient(qdrant.Resource.Name);
	using var host = hb.Build();
	await host.StartAsync();
	await pipeline.ExecuteAsync(async token =>
	{
	var qdrantClient = host.Services.GetRequiredService<QdrantClient>();
	await CreateTestDataAsync(qdrantClient, token);
	var results = await qdrantClient.SearchAsync(CollectionName, s_testVector, limit: 1, cancellationToken: token);
	Assert.Collection(results,
	r => Assert.Equal("Test", r.Payload["title"].StringValue));
	}, cts.Token);
	}

[radical]

cc @sebastienros

[Alirexaa]

nats is done too:

aspire/tests/Aspire.Hosting.Nats.Tests/NatsFunctionalTests.cs

Lines 21 to 61 in 9a68b55

	[Fact]
	[RequiresDocker]
	public async Task VerifyNatsResource()
	{
	var cts = new CancellationTokenSource(TimeSpan.FromMinutes(5));
	var pipeline = new ResiliencePipelineBuilder()
	.AddRetry(new() { MaxRetryAttempts = 10, Delay = TimeSpan.FromSeconds(1), ShouldHandle = new PredicateBuilder().Handle<NatsException>() })
	.Build();
	using var builder = TestDistributedApplicationBuilder.CreateWithTestContainerRegistry(testOutputHelper);
	var nats = builder.AddNats("nats")
	.WithJetStream();
	using var app = builder.Build();
	await app.StartAsync();
	var hb = Host.CreateApplicationBuilder();
	hb.Configuration[$"ConnectionStrings:{nats.Resource.Name}"] = await nats.Resource.ConnectionStringExpression.GetValueAsync(default);
	hb.AddNatsClient("nats", configureOptions: opts =>
	{
	var jsonRegistry = new NatsJsonContextSerializerRegistry(AppJsonContext.Default);
	return opts with { SerializerRegistry = jsonRegistry };
	});
	hb.AddNatsJetStream();
	using var host = hb.Build();
	await host.StartAsync();
	await pipeline.ExecuteAsync(async token =>
	{
	var jetStream = host.Services.GetRequiredService<INatsJSContext>();
	await CreateTestData(jetStream, token);
	await ConsumeTestData(jetStream, token);
	}, cts.Token);

[eerhardt]

CosmosDB has both EF and non-EF functional tests in Extract EventHubs and Cosmos Tests from EndToEndTests and into Aspire.Hosting.Azure.Tests (dotnet/aspire#6538).