Register IPipelineOutputService in DI for pipeline output directory management

src/Aspire.Cli/Commands/PublishCommand.cs

@@ -49,11 +49,10 @@ protected override string[] GetRunArguments(string? fullyQualifiedOutputPath, st
     {
         var baseArgs = new List<string> { "--operation", "publish", "--step", "publish" };
 
-        var targetPath = fullyQualifiedOutputPath is not null
-            ? fullyQualifiedOutputPath
-            : Path.Combine(Environment.CurrentDirectory, "aspire-output");
-
-        baseArgs.AddRange(["--output-path", targetPath]);
+        if (fullyQualifiedOutputPath is not null)
+        {
+            baseArgs.AddRange(["--output-path", fullyQualifiedOutputPath]);
+        }
 
         // Add --log-level and --envionment flags if specified
         var logLevel = parseResult.GetValue(_logLevelOption);

src/Aspire.Hosting.Azure/AzureEnvironmentResource.cs

@@ -122,7 +122,7 @@ private Task PublishAsync(PipelineStepContext context)
     {
         var azureProvisioningOptions = context.Services.GetRequiredService<IOptions<AzureProvisioningOptions>>();
         var publishingContext = new AzurePublishingContext(
-            context.OutputPath ?? throw new InvalidOperationException("OutputPath is required for Azure publishing."),
+            context.OutputService.GetOutputDirectory(),
             azureProvisioningOptions.Value,
             context.Services,
             context.Logger,

src/Aspire.Hosting.Docker/DockerComposePublishingContext.cs

@@ -37,7 +37,7 @@ internal sealed class DockerComposePublishingContext(
         UnixFileMode.OtherRead | UnixFileMode.OtherWrite;
 
     public readonly IResourceContainerImageBuilder ImageBuilder = imageBuilder;
-    public readonly string OutputPath = outputPath ?? throw new InvalidOperationException("OutputPath is required for Docker Compose publishing.");
+    public readonly string OutputPath = outputPath;
 
     internal async Task WriteModelAsync(DistributedApplicationModel model, DockerComposeEnvironmentResource environment)
     {

src/Aspire.Hosting.Kubernetes/KubernetesPublishingContext.cs

@@ -20,7 +20,7 @@ internal sealed class KubernetesPublishingContext(
     ILogger logger,
     CancellationToken cancellationToken = default)
 {
-    public readonly string OutputPath = outputPath ?? throw new InvalidOperationException("OutputPath is required for Kubernetes publishing.");
+    public readonly string OutputPath = outputPath;
 
     private readonly Dictionary<string, Dictionary<string, object>> _helmValues = new()
     {

src/Aspire.Hosting/Pipelines/IPipelineOutputService.cs

@@ -0,0 +1,40 @@
+// Licensed to the .NET Foundation under one or more agreements.
+// The .NET Foundation licenses this file to you under the MIT license.
+
+using System.Diagnostics.CodeAnalysis;
+using Aspire.Hosting.ApplicationModel;
+
+namespace Aspire.Hosting.Pipelines;
+
+/// <summary>
+/// Service for managing pipeline output directories.
+/// </summary>
+[Experimental("ASPIREPIPELINES001", UrlFormat = "https://aka.ms/aspire/diagnostics/{0}")]
+public interface IPipelineOutputService
+{
+    /// <summary>
+    /// Gets the output directory for deployment artifacts.
+    /// </summary>
+    /// <returns>The path to the output directory for deployment artifacts.</returns>
+    string GetOutputDirectory();
+
+    /// <summary>
+    /// Gets the output directory for a specific resource's deployment artifacts.
+    /// </summary>
+    /// <param name="resource">The resource to get the output directory for.</param>
+    /// <returns>The path to the output directory for the resource's deployment artifacts.</returns>
+    string GetOutputDirectory(IResource resource);
+
+    /// <summary>
+    /// Gets a temporary directory for build artifacts.
+    /// </summary>
+    /// <returns>The path to a temporary directory for build artifacts.</returns>
+    string GetTempDirectory();
+
+    /// <summary>
+    /// Gets a temporary directory for a specific resource's build artifacts.
+    /// </summary>
+    /// <param name="resource">The resource to get the temporary directory for.</param>
+    /// <returns>The path to a temporary directory for the resource's build artifacts.</returns>
+    string GetTempDirectory(IResource resource);
+}

src/Aspire.Hosting/Pipelines/PipelineContext.cs

@@ -3,6 +3,8 @@
 
 using System.Diagnostics.CodeAnalysis;
 using Aspire.Hosting.ApplicationModel;
+using Microsoft.Extensions.Configuration;
+using Microsoft.Extensions.DependencyInjection;
 using Microsoft.Extensions.Logging;
 
 namespace Aspire.Hosting.Pipelines;
@@ -51,7 +53,7 @@ public sealed class PipelineContext(
     public CancellationToken CancellationToken { get; set; } = cancellationToken;
 
     /// <summary>
-    /// Gets the output path for deployment artifacts.
+    /// Gets the service for managing pipeline output directories.
     /// </summary>
-    public string? OutputPath { get; } = outputPath;
+    public IPipelineOutputService OutputService { get; } = new PipelineOutputService(outputPath, serviceProvider.GetRequiredService<IConfiguration>());
 }

src/Aspire.Hosting/Pipelines/PipelineOutputService.cs

@@ -0,0 +1,67 @@
+// Licensed to the .NET Foundation under one or more agreements.
+// The .NET Foundation licenses this file to you under the MIT license.
+
+using System.Diagnostics.CodeAnalysis;
+using Aspire.Hosting.ApplicationModel;
+using Microsoft.Extensions.Configuration;
+
+namespace Aspire.Hosting.Pipelines;
+
+/// <summary>
+/// Default implementation of <see cref="IPipelineOutputService"/>.
+/// </summary>
+[Experimental("ASPIREPIPELINES001", UrlFormat = "https://aka.ms/aspire/diagnostics/{0}")]
+internal sealed class PipelineOutputService : IPipelineOutputService
+{
+    private readonly string? _outputPath;
+    private readonly Lazy<string> _tempDirectory;
+
+    public PipelineOutputService(string? outputPath, IConfiguration configuration)
+    {
+        _outputPath = outputPath;
+        _tempDirectory = new Lazy<string>(() => CreateTempDirectory(configuration));
+    }
+
+    /// <inheritdoc/>
+    public string GetOutputDirectory()
+    {
+        return _outputPath ?? Path.Combine(Environment.CurrentDirectory, "aspire-output");
+    }
+
+    /// <inheritdoc/>
+    public string GetOutputDirectory(IResource resource)
+    {
+        ArgumentNullException.ThrowIfNull(resource);
+
+        var baseOutputDir = GetOutputDirectory();
+        return Path.Combine(baseOutputDir, resource.Name);
+    }
+
+    /// <inheritdoc/>
+    public string GetTempDirectory()
+    {
+        return _tempDirectory.Value;
+    }
+
+    /// <inheritdoc/>
+    public string GetTempDirectory(IResource resource)
+    {
+        ArgumentNullException.ThrowIfNull(resource);
+
+        var baseTempDir = GetTempDirectory();
+        return Path.Combine(baseTempDir, resource.Name);
+    }
+
+    private static string CreateTempDirectory(IConfiguration configuration)
+    {
+        var appHostSha = configuration["AppHost:PathSha256"];
+
+        if (!string.IsNullOrEmpty(appHostSha))
+        {
+            return Directory.CreateTempSubdirectory($"aspire-{appHostSha}").FullName;
+        }
+
+        // Fallback if AppHost:PathSha256 is not available
+        return Directory.CreateTempSubdirectory("aspire").FullName;
+    }
+}

src/Aspire.Hosting/Pipelines/PipelineStepContext.cs

@@ -56,7 +56,7 @@ public sealed class PipelineStepContext
     public CancellationToken CancellationToken => PipelineContext.CancellationToken;
 
     /// <summary>
-    /// Gets the output path for deployment artifacts.
+    /// Gets the service for managing pipeline output directories.
     /// </summary>
-    public string? OutputPath => PipelineContext.OutputPath;
+    public IPipelineOutputService OutputService => PipelineContext.OutputService;
 }

src/Shared/PublishingContextUtils.cs

@@ -15,10 +15,10 @@ public static string GetEnvironmentOutputPath(PipelineStepContext context, IComp
         if (context.Model.Resources.OfType<IComputeEnvironmentResource>().Count() > 1)
         {
             // If there are multiple compute environments, append the environment name to the output path
-            return Path.Combine(context.OutputPath!, environment.Name);
+            return Path.Combine(context.OutputService.GetOutputDirectory(), environment.Name);
         }
 
         // If there is only one compute environment, use the root output path
-        return context.OutputPath!;
+        return context.OutputService.GetOutputDirectory();
     }
 }

tests/Aspire.Hosting.Tests/Helpers/JsonDocumentManifestPublisher.cs

@@ -78,7 +78,7 @@ public static IDistributedApplicationPipeline AddJsonDocumentManifestPublishing(
                 using var stream = new MemoryStream();
                 using var writer = new Utf8JsonWriter(stream, new() { Indented = true });
 
-                var manifestPath = context.OutputPath ?? "aspire-manifest.json";
+                var manifestPath = context.OutputService.GetOutputDirectory();
                 var publishingContext = new ManifestPublishingContext(executionContext, manifestPath, writer, context.CancellationToken);
 
                 await publishingContext.WriteModel(context.Model, context.CancellationToken).ConfigureAwait(false);