Whoops, stack overflowgit add -A

Author: aaronpowell

src/Shared/Dapr/Core/DaprComponentMetadataAnnotation.cs

@@ -1,4 +1,4 @@
 using Aspire.Hosting.ApplicationModel;
 
 namespace CommunityToolkit.Aspire.Hosting.Dapr;
-internal sealed record DaprComponentConfigurationAnnotation(Action<DaprComponentSchema> Configure) : IResourceAnnotation;
+internal sealed record DaprComponentConfigurationAnnotation(Func<DaprComponentSchema, Task> Configure) : IResourceAnnotation;

src/Shared/Dapr/Core/DaprDistributedApplicationLifecycleHook.cs

@@ -12,6 +12,7 @@
 using System.Diagnostics.CodeAnalysis;
 using System.Globalization;
 using System.Net.Sockets;
+using System.Threading.Tasks;
 using static CommunityToolkit.Aspire.Hosting.Dapr.CommandLineArgs;
 
 namespace CommunityToolkit.Aspire.Hosting.Dapr;
@@ -491,7 +492,7 @@ private async Task<string> GetComponentAsync(DaprComponentResource component, Fu
     {
         // We should try to read content from a known location (such as aspire root directory)
         logger.LogInformation("Unvalidated configuration {specType} for component '{ComponentName}'.", component.Type, component.Name);
-        return await contentWriter(GetDaprComponent(component, component.Type)).ConfigureAwait(false);
+        return await contentWriter(await GetDaprComponent(component, component.Type)).ConfigureAwait(false);
     }
     private async Task<string> GetBuildingBlockComponentAsync(DaprComponentResource component, Func<string, Task<string>> contentWriter, string defaultProvider, CancellationToken cancellationToken)
     {
@@ -544,19 +545,19 @@ private static async Task<string> GetDefaultContent(DaprComponentResource compon
         string defaultContent = await File.ReadAllTextAsync(defaultContentPath, cancellationToken).ConfigureAwait(false);
         string yaml = defaultContent.Replace($"name: {component.Type}", $"name: {component.Name}");
         DaprComponentSchema content = DaprComponentSchema.FromYaml(yaml);
-        ConfigureDaprComponent(component, content);
+        await ConfigureDaprComponent(component, content);
         return content.ToString();
     }
 
 
-    private static string GetDaprComponent(DaprComponentResource component, string type)
+    private static async Task<string> GetDaprComponent(DaprComponentResource component, string type)
     {
         var content = new DaprComponentSchema(component.Name, type);
-        ConfigureDaprComponent(component, content);
+        await ConfigureDaprComponent(component, content);
         return content.ToString();
     }
 
-    private static void ConfigureDaprComponent(DaprComponentResource component, DaprComponentSchema content)
+    private static async Task ConfigureDaprComponent(DaprComponentResource component, DaprComponentSchema content)
     {
         if (component.TryGetAnnotationsOfType<DaprComponentSecretAnnotation>(out var secrets) && secrets.Any())
         {
@@ -566,7 +567,7 @@ private static void ConfigureDaprComponent(DaprComponentResource component, Dapr
         {
             foreach (var annotation in annotations)
             {
-                annotation.Configure(content);
+                await annotation.Configure(content);
             }
         }
     }

src/Shared/Dapr/Core/DaprMetadataResourceBuilderExtensions.cs

@@ -28,6 +28,7 @@ public static IResourceBuilder<IDaprComponentResource> WithMetadata(this IResour
                 Name = name,
                 Value = value
             });
+            return Task.CompletedTask;
         }));
 
 
@@ -59,9 +60,22 @@ public static IResourceBuilder<IDaprComponentResource> WithMetadata(this IResour
                                       Key = parameterResource.Name
                                   }
                               });
+                              return Task.CompletedTask;
                           }));
         }
 
-        return builder.WithMetadata(name, parameterResource);
+        return builder.WithAnnotation(new DaprComponentConfigurationAnnotation(async schema =>
+        {
+            var existing = schema.Spec.Metadata.Find(m => m.Name == name);
+            if (existing is not null)
+            {
+                schema.Spec.Metadata.Remove(existing);
+            }
+            schema.Spec.Metadata.Add(new DaprComponentSpecMetadataValue
+            {
+                Name = name,
+                Value = (await ((IValueProvider)parameterResource).GetValueAsync(default))!
+            });
+        }));
     }
 }