Remove RedisContainerResource and containerize RedisResource.

Directory.Packages.props

@@ -70,6 +70,7 @@
     <PackageVersion Include="Microsoft.Extensions.Http.Resilience" Version="$(MicrosoftExtensionsHttpResiliencePackageVersion)" />
     <!-- external dependencies -->
     <PackageVersion Include="Confluent.Kafka" Version="2.3.0" />
+    <PackageVersion Include="Dapper" Version="2.1.28" />
     <PackageVersion Include="Dapr.AspNetCore" Version="1.12.0" />
     <PackageVersion Include="DnsClient" Version="1.7.0" />
     <PackageVersion Include="Grpc.AspNetCore" Version="2.59.0" />

src/Aspire.Hosting/ApplicationModel/IResourceBuilder.cs

@@ -23,14 +23,16 @@ public interface IResourceBuilder<out T> where T : IResource
     /// Adds an annotation to the resource being built.
     /// </summary>
     /// <typeparam name="TAnnotation">The type of the annotation to add.</typeparam>
+    /// <param name="behavior">The behavior to use when adding the annotation.</param>
     /// <returns>The resource builder instance.</returns>
-    IResourceBuilder<T> WithAnnotation<TAnnotation>() where TAnnotation : IResourceAnnotation, new() => WithAnnotation(new TAnnotation());
+    IResourceBuilder<T> WithAnnotation<TAnnotation>(ResourceAnnotationMutationBehavior behavior = ResourceAnnotationMutationBehavior.AddAppend) where TAnnotation : IResourceAnnotation, new() => WithAnnotation(new TAnnotation(), behavior);
 
     /// <summary>
     /// Adds an annotation to the resource being built.
     /// </summary>
     /// <typeparam name="TAnnotation">The type of the annotation to add.</typeparam>
     /// <param name="annotation">The annotation to add.</param>
+    /// <param name="behavior">The behavior to use when adding the annotation.</param>
     /// <returns>The resource builder instance.</returns>
-    IResourceBuilder<T> WithAnnotation<TAnnotation>(TAnnotation annotation) where TAnnotation : IResourceAnnotation;
+    IResourceBuilder<T> WithAnnotation<TAnnotation>(TAnnotation annotation, ResourceAnnotationMutationBehavior behavior = ResourceAnnotationMutationBehavior.AddAppend) where TAnnotation : IResourceAnnotation;
 }

src/Aspire.Hosting/Redis/IRedisResource.cs → src/Aspire.Hosting/ApplicationModel/ResourceAnnotationMutationBehavior.cs

@@ -1,9 +1,10 @@
 // Licensed to the .NET Foundation under one or more agreements.
 // The .NET Foundation licenses this file to you under the MIT license.
 
-using Aspire.Hosting.ApplicationModel;
+namespace Aspire.Hosting.ApplicationModel;
 
-namespace Aspire.Hosting.Redis;
-public interface IRedisResource : IResourceWithConnectionString
+public enum ResourceAnnotationMutationBehavior
 {
+    AddAppend,
+    AddReplace
 }

src/Aspire.Hosting/DistributedApplicationResourceBuilder.cs

@@ -10,8 +10,23 @@ internal sealed class DistributedApplicationResourceBuilder<T>(IDistributedAppli
     public T Resource { get; } = resource;
     public IDistributedApplicationBuilder ApplicationBuilder { get; } = applicationBuilder;
 
-    public IResourceBuilder<T> WithAnnotation<TAnnotation>(TAnnotation annotation) where TAnnotation : IResourceAnnotation
+    /// <inheritdoc />
+    public IResourceBuilder<T> WithAnnotation<TAnnotation>(TAnnotation annotation, ResourceAnnotationMutationBehavior behavior = ResourceAnnotationMutationBehavior.AddAppend) where TAnnotation : IResourceAnnotation
     {
+        // Some defensive code to protect against introducing a new enumeration value without first updating
+        // this code to accomodate it.
+        if (behavior != ResourceAnnotationMutationBehavior.AddAppend && behavior != ResourceAnnotationMutationBehavior.AddReplace)
+        {
+            throw new ArgumentOutOfRangeException(nameof(behavior), behavior, "ResourceAnnotationMutationBehavior must be either AddAppend or AddReplace.");
+        }
+
+        // If the behavior is AddReplace then there should never be more than one annotation present. The following call will result in an exception which
+        // allows us to easily spot these bugs.
+        if (behavior == ResourceAnnotationMutationBehavior.AddReplace && Resource.Annotations.OfType<TAnnotation>().SingleOrDefault() is { } existingAnnotation)
+        {
+            Resource.Annotations.Remove(existingAnnotation);
+        }
+
         Resource.Annotations.Add(annotation);
         return this;
     }

src/Aspire.Hosting/Extensions/ResourceBuilderExtensions.cs

@@ -105,7 +105,8 @@ public static IResourceBuilder<T> WithEnvironment<T>(this IResourceBuilder<T> bu
     /// <returns>A reference to the <see cref="IResourceBuilder{T}"/>.</returns>
     public static IResourceBuilder<T> WithManifestPublishingCallback<T>(this IResourceBuilder<T> builder, Action<ManifestPublishingContext> callback) where T : IResource
     {
-        return builder.WithAnnotation(new ManifestPublishingCallbackAnnotation(callback));
+        // You can only ever have one manifest publishing callback, so it must be a replace operation.
+        return builder.WithAnnotation(new ManifestPublishingCallbackAnnotation(callback), ResourceAnnotationMutationBehavior.AddReplace);
     }
 
     private static bool ContainsAmbiguousEndpoints(IEnumerable<AllocatedEndpointAnnotation> endpoints)

src/Aspire.Hosting/Redis/RedisBuilderExtensions.cs

@@ -14,22 +14,6 @@ namespace Aspire.Hosting;
 /// </summary>
 public static class RedisBuilderExtensions
 {
-    /// <summary>
-    /// Adds a Redis container to the application model. The default image is "redis" and tag is "latest".
-    /// </summary>
-    /// <param name="builder">The <see cref="IDistributedApplicationBuilder"/>.</param>
-    /// <param name="name">The name of the resource. This name will be used as the connection string name when referenced in a dependency.</param>
-    /// <param name="port">The host port for the redis server.</param>
-    /// <returns>A reference to the <see cref="IResourceBuilder{T}"/>.</returns>
-    public static IResourceBuilder<RedisContainerResource> AddRedisContainer(this IDistributedApplicationBuilder builder, string name, int? port = null)
-    {
-        var redis = new RedisContainerResource(name);
-        return builder.AddResource(redis)
-                      .WithManifestPublishingCallback(context => WriteRedisContainerResourceToManifest(context, redis))
-                      .WithAnnotation(new EndpointAnnotation(ProtocolType.Tcp, port: port, containerPort: 6379))
-                      .WithAnnotation(new ContainerImageAnnotation { Image = "redis", Tag = "latest" });
-    }
-
     /// <summary>
     /// Adds a Redis container to the application model. The default image is "redis" and tag is "latest".
     /// </summary>
@@ -45,7 +29,8 @@ public static IResourceBuilder<RedisResource> AddRedis(this IDistributedApplicat
                       .WithAnnotation(new ContainerImageAnnotation { Image = "redis", Tag = "latest" });
     }
 
-    public static IResourceBuilder<T> WithRedisCommander<T>(this IResourceBuilder<T> builder, string? containerName = null, int? hostPort = null) where T: IRedisResource
+
+    public static IResourceBuilder<RedisResource> WithRedisCommander(this IResourceBuilder<RedisResource> builder, string? containerName = null, int? hostPort = null)
     {
         if (builder.ApplicationBuilder.Resources.OfType<RedisCommanderResource>().Any())
         {
@@ -70,7 +55,12 @@ private static void WriteRedisResourceToManifest(ManifestPublishingContext conte
         context.Writer.WriteString("type", "redis.v0");
     }
 
-    private static void WriteRedisContainerResourceToManifest(ManifestPublishingContext context, RedisContainerResource resource)
+    public static IResourceBuilder<RedisResource> PublishAsContainer(this IResourceBuilder<RedisResource> builder)
+    {
+        return builder.WithManifestPublishingCallback(context => WriteRedisContainerResourceToManifest(context, builder.Resource));
+    }
+
+    private static void WriteRedisContainerResourceToManifest(ManifestPublishingContext context, RedisResource resource)
     {
         context.WriteContainer(resource);
         context.Writer.WriteString(                     // "connectionString": "...",

src/Aspire.Hosting/Redis/RedisCommanderConfigWriterHook.cs

@@ -17,7 +17,7 @@ public Task AfterEndpointsAllocatedAsync(DistributedApplicationModel appModel, C
             return Task.CompletedTask;
         }
 
-        var redisInstances = appModel.Resources.OfType<IRedisResource>();
+        var redisInstances = appModel.Resources.OfType<RedisResource>();
 
         if (!redisInstances.Any())
         {

src/Aspire.Hosting/Redis/RedisResource.cs

@@ -1,15 +1,13 @@
 // Licensed to the .NET Foundation under one or more agreements.
 // The .NET Foundation licenses this file to you under the MIT license.
 
-using Aspire.Hosting.Redis;
-
 namespace Aspire.Hosting.ApplicationModel;
 
 /// <summary>
 /// A resource that represents a Redis resource independent of the hosting model.
 /// </summary>
 /// <param name="name">The name of the resource.</param>
-public class RedisResource(string name) : Resource(name), IResourceWithConnectionString, IRedisResource
+public class RedisResource(string name) : ContainerResource(name), IResourceWithConnectionString
 {
     /// <summary>
     /// Gets the connection string for the Redis server.

tests/Aspire.Hosting.Tests/ManifestGenerationTests.cs

@@ -194,7 +194,7 @@ public void EnsureAllRedisManifestTypesHaveVersion0Suffix()
         var program = CreateTestProgramJsonDocumentManifestPublisher();
 
         program.AppBuilder.AddRedis("redisabstract");
-        program.AppBuilder.AddRedisContainer("rediscontainer");
+        program.AppBuilder.AddRedis("rediscontainer").PublishAsContainer();
 
         // Build AppHost so that publisher can be resolved.
         program.Build();
@@ -211,6 +211,27 @@ public void EnsureAllRedisManifestTypesHaveVersion0Suffix()
         Assert.Equal("container.v0", container.GetProperty("type").GetString());
     }
 
+    [Fact]
+    public void PublishingRedisResourceAsContainerResultsInConnectionStringProperty()
+    {
+        var program = CreateTestProgramJsonDocumentManifestPublisher();
+
+        program.AppBuilder.AddRedis("rediscontainer").PublishAsContainer();
+
+        // Build AppHost so that publisher can be resolved.
+        program.Build();
+        var publisher = program.GetManifestPublisher();
+
+        program.Run();
+
+        var resources = publisher.ManifestDocument.RootElement.GetProperty("resources");
+
+        var container = resources.GetProperty("rediscontainer");
+        Assert.Equal("container.v0", container.GetProperty("type").GetString());
+        Assert.Equal("{rediscontainer.bindings.tcp.host}:{rediscontainer.bindings.tcp.port}", container.GetProperty("connectionString").GetString());
+
+    }
+
     [Fact]
     public void EnsureAllPostgresManifestTypesHaveVersion0Suffix()
     {