Support provisioning azure resources for dev

Directory.Packages.props

@@ -14,6 +14,13 @@
     <PackageVersion Include="Azure.Storage.Blobs" Version="12.17.0" />
     <PackageVersion Include="Azure.Storage.Queues" Version="12.15.0" />
     <PackageVersion Include="Microsoft.Extensions.Azure" Version="1.7.0" />
+
+    <!-- Azure Management SDK for .NET dependencies -->
+    <PackageVersion Include="Azure.ResourceManager.KeyVault" Version="1.2.0-beta.2" />
+    <PackageVersion Include="Azure.ResourceManager.ServiceBus" Version="1.1.0-beta.3" />
+    <PackageVersion Include="Azure.ResourceManager.Storage" Version="1.1.1" />
+    <PackageVersion Include="Azure.ResourceManager.Authorization" Version="1.1.0-beta.1" />
+
     <!-- ASP.NET Core dependencies -->
     <PackageVersion Include="Microsoft.AspNetCore.Diagnostics.EntityFrameworkCore" Version="$(AspNetCoreVersion)" />
     <PackageVersion Include="Microsoft.AspNetCore.OpenApi" Version="$(AspNetCoreVersion)" />

samples/DevHost/Program.cs

@@ -6,6 +6,8 @@
 
 var builder = DistributedApplication.CreateBuilder(args);
 
+builder.AddAzureProvisioning();
+
 var grafana = builder.AddContainer("grafana", "grafana/grafana")
        .WithServiceBinding(containerPort: 3000, name: "grafana-http", scheme: "http");
 
@@ -18,7 +20,7 @@
                      .WithReplicas(2)
                      .WithSqlServer(sql, "master");
 
-var serviceBus = builder.AddAzureServiceBus("messaging");
+var serviceBus = builder.AddAzureServiceBus("messaging", "orders");
 
 var basket = builder.AddProject<Projects.BasketService>()
                     .WithRedis(redis)

samples/OrderProcessor/OrderProcessingWorker.cs

@@ -31,7 +31,7 @@ protected override async Task ExecuteAsync(CancellationToken stoppingToken)
         }
 
         const string configKeyName = "Aspire:Azure:Messaging:ServiceBus:OrderQueueName";
-        string queueName = _config[configKeyName] ?? throw new InvalidOperationException($"Queue name not found. Please add a valid name for configuration key '{configKeyName}'.");
+        string queueName = _config[configKeyName] ?? "orders";
 
         _messageProcessor = _client.CreateProcessor(queueName);
         _messageProcessor.ProcessMessageAsync += ProcessMessageAsync;
@@ -58,20 +58,24 @@ private Task ProcessMessageAsync(ProcessMessageEventArgs args)
             _logger.LogInformation($"Processing Order at: {DateTime.UtcNow}");
 
             var message = args.Message;
-            _logger.LogDebug($"""
-                MessageId:{message.MessageId}
-                MessageBody:{message.Body}
-                """);
+
+            if (_logger.Equals(LogLevel.Debug))
+            {
+                _logger.LogDebug("""
+                MessageId:{MessageId}
+                MessageBody:{Body}
+                """, message.MessageId, message.Body);
+            }
             var order = message.Body.ToObjectFromJson<Order>();
 
             activity?.AddTag("order-id", order.Id);
             activity?.AddTag("product-count", order.Items.Count);
 
-            _logger.LogCritical($"""
-                OrderId:{order.Id}
-                BuyerId:{order.BuyerId}
-                ProductCount:{order.Items.Count}
-                """);
+            _logger.LogInformation("""
+                OrderId:{Id}
+                BuyerId:{BuyerId}
+                ProductCount:{Count}
+                """, order.Id, order.BuyerId, order.Items.Count);
 
             return Task.CompletedTask;
         }

samples/OrderProcessor/Program.cs

@@ -2,6 +2,8 @@
 
 var builder = Host.CreateApplicationBuilder(args);
 
+builder.AddServiceDefaults();
+
 // When running for Development, don't fail at startup if the developer hasn't configured ServiceBus yet.
 if (!builder.Environment.IsDevelopment() || builder.Configuration[AspireServiceBusExtensions.DefaultNamespaceConfigKey] is not null)
 {

src/Aspire.Hosting.Azure/Aspire.Hosting.Azure.csproj

@@ -1,4 +1,4 @@
-<Project Sdk="Microsoft.NET.Sdk">
+<Project Sdk="Microsoft.NET.Sdk">
 
   <PropertyGroup>
     <TargetFramework>$(NetCurrent)</TargetFramework>
@@ -7,6 +7,11 @@
 
   <ItemGroup>
     <ProjectReference Include="..\Aspire.Hosting\Aspire.Hosting.csproj" />
+    <PackageReference Include="Azure.ResourceManager.KeyVault" />
+    <PackageReference Include="Azure.ResourceManager.ServiceBus" />
+    <PackageReference Include="Azure.ResourceManager.Storage" />
+    <PackageReference Include="Azure.ResourceManager.Authorization" />
+    <PackageReference Include="Azure.Identity" />
   </ItemGroup>
 
 </Project>

src/Aspire.Hosting.Azure/AzureComponentExtensions.cs

@@ -0,0 +1,86 @@
+// 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;
+using Aspire.Hosting.Lifecycle;
+
+namespace Aspire.Hosting.Azure;
+
+public static class AzureComponentExtensions
+{
+    public static IDistributedApplicationBuilder AddAzureProvisioning(this IDistributedApplicationBuilder builder)
+    {
+        builder.Services.AddLifecycleHook<AzureProvisioner>();
+        return builder;
+    }
+
+    public static IDistributedApplicationComponentBuilder<AzureKeyVaultComponent> AddAzureKeyVault(this IDistributedApplicationBuilder builder, string name)
+    {
+        var component = new AzureKeyVaultComponent();
+        return builder.AddComponent(name, component);
+    }
+
+    public static IDistributedApplicationComponentBuilder<T> WithAddAzureKeyVault<T>(this IDistributedApplicationComponentBuilder<T> builder, IDistributedApplicationComponentBuilder<AzureKeyVaultComponent> keyvalut)
+        where T : IDistributedApplicationComponentWithEnvironment
+    {
+        return builder.WithEnvironment((env) =>
+        {
+            var vaultName = keyvalut.Component.VaultName ?? builder.ApplicationBuilder.Configuration["Aspire:Azure:Security:KeyVault:VaultName"];
+
+            if (vaultName is not null)
+            {
+                env[$"Aspire__Azure__Security__KeyVault__VaultUri"] = $"https://{vaultName}.vault.azure.net/";
+            }
+        });
+    }
+
+    public static IDistributedApplicationComponentBuilder<AzureServiceBusComponent> AddAzureServiceBus(this IDistributedApplicationBuilder builder, string name, params string[] queueNames)
+    {
+        var component = new AzureServiceBusComponent
+        {
+            QueueNames = queueNames
+        };
+
+        return builder.AddComponent(name, component);
+    }
+
+    public static IDistributedApplicationComponentBuilder<T> WithAzureServiceBus<T>(this IDistributedApplicationComponentBuilder<T> builder, IDistributedApplicationComponentBuilder<AzureServiceBusComponent> serviceBus)
+        where T : IDistributedApplicationComponentWithEnvironment
+    {
+        return builder.WithEnvironment((env) =>
+        {
+            var sbNamespace = serviceBus.Component.ServiceBusNamespace ?? builder.ApplicationBuilder.Configuration["Aspire:Azure:Messaging:ServiceBus:Namespace"];
+
+            if (sbNamespace is not null)
+            {
+                env[$"Aspire__Azure__Messaging__ServiceBus__Namespace"] = $"{sbNamespace}.servicebus.windows.net";
+            }
+        });
+    }
+
+    public static IDistributedApplicationComponentBuilder<AzureStorageComponent> AddAzureStorage(this IDistributedApplicationBuilder builder, string name)
+    {
+        var component = new AzureStorageComponent();
+        return builder.AddComponent(name, component);
+    }
+
+    public static IDistributedApplicationComponentBuilder<T> WithAzureStorage<T>(this IDistributedApplicationComponentBuilder<T> builder, IDistributedApplicationComponentBuilder<AzureStorageComponent> storage)
+        where T : IDistributedApplicationComponentWithEnvironment
+    {
+        return builder.WithEnvironment((env) =>
+        {
+            // We don't support connection strings yet
+            //storage.Component.TryGetName(out var name);
+            //env[$"ConnectionStrings__{name}"] = storage.Component.ConnectionString!;
+
+            var accountName = storage.Component.AccountName ?? builder.ApplicationBuilder.Configuration["Aspire:Azure:Storage:AccountName"];
+
+            if (accountName is not null)
+            {
+                env[$"Aspire__Azure__Data__Tables__ServiceUri"] = $"https://{accountName}.table.core.windows.net/";
+                env[$"Aspire__Azure__Storage__Blobs__ServiceUri"] = $"https://{accountName}.blob.core.windows.net/";
+                env[$"Aspire__Azure__Storage__Queues__ServiceUri"] = $"https://{accountName}.queue.core.windows.net/";
+            }
+        });
+    }
+}

src/Aspire.Hosting.Azure/ServiceBusComponent.cs → src/Aspire.Hosting.Azure/AzureKeyVaultComponent.cs

@@ -5,7 +5,9 @@
 
 namespace Aspire.Hosting.Azure;
 
-public class ServiceBusComponent : IDistributedApplicationComponent
+public class AzureKeyVaultComponent : IAzureComponent
 {
     public ComponentMetadataCollection Annotations { get; } = new();
+
+    public string? VaultName { get; set; }
 }