Add fusion publish command to CLI (#8606)

Author: tobias-tengler

src/HotChocolate/Fusion-vnext/src/Fusion.CommandLine/Commands/ComposeCommand.cs

@@ -5,8 +5,11 @@
 using System.Threading.Channels;
 using HotChocolate.Buffers;
 using HotChocolate.Fusion.Logging;
+using HotChocolate.Fusion.Logging.Contracts;
 using HotChocolate.Fusion.Options;
 using HotChocolate.Fusion.Packaging;
+using HotChocolate.Fusion.Results;
+using HotChocolate.Types.Mutable;
 using static HotChocolate.Fusion.Properties.CommandLineResources;
 
 namespace HotChocolate.Fusion.CommandLine;
@@ -361,7 +364,7 @@ await ComposeAsync(
         }
     }
 
-    private static bool IsSchemaFile(string? fileName)
+    public static bool IsSchemaFile(string? fileName)
     {
         if (fileName is null)
         {
@@ -381,23 +384,61 @@ private static async Task<int> ComposeAsync(
         bool printSchema,
         CancellationToken cancellationToken)
     {
-        environment ??= Environment.GetEnvironmentVariable("ASPNETCORE_ENVIRONMENT") ?? "Development";
-
-        Dictionary<string, (SourceSchemaText, JsonDocument)> sourceSchemas;
+        using var archive = File.Exists(archiveFile)
+            ? FusionArchive.Open(archiveFile, mode: FusionArchiveMode.Update)
+            : FusionArchive.Create(archiveFile);
 
         try
         {
-            sourceSchemas = await ReadSourceSchemasAsync(sourceSchemaFiles, cancellationToken);
+            var compositionLog = new CompositionLog();
+
+            var result = await ComposeAsync(
+                compositionLog,
+                sourceSchemaFiles,
+                archive,
+                environment,
+                enableGlobalObjectIdentification,
+                cancellationToken);
+
+            WriteCompositionLog(
+                compositionLog,
+                writer: result.IsSuccess ? console.Out : console.Error,
+                writeAsGraphQLComments: result.IsSuccess && printSchema);
+
+            if (result.IsFailure)
+            {
+                foreach (var error in result.Errors)
+                {
+                    console.Error.WriteLine(error.Message);
+                }
+
+                return 1;
+            }
+
+            console.Out.WriteLine(printSchema
+                ? result.Value.ToString()
+                : string.Format(ComposeCommand_CompositeSchemaFile_Written, archiveFile));
+
+            return 0;
         }
         catch (Exception e)
         {
             console.Error.WriteLine(e.Message);
             return 1;
         }
+    }
 
-        using var archive = File.Exists(archiveFile)
-            ? FusionArchive.Open(archiveFile, mode: FusionArchiveMode.Update)
-            : FusionArchive.Create(archiveFile);
+    public static async Task<CompositionResult<MutableSchemaDefinition>> ComposeAsync(
+        ICompositionLog compositionLog,
+        List<string> sourceSchemaFiles,
+        FusionArchive archive,
+        string? environment,
+        bool enableGlobalObjectIdentification,
+        CancellationToken cancellationToken)
+    {
+        environment ??= Environment.GetEnvironmentVariable("ASPNETCORE_ENVIRONMENT") ?? "Development";
+
+        var sourceSchemas = await ReadSourceSchemasAsync(sourceSchemaFiles, cancellationToken);
         var schemaNames = new SortedSet<string>(StringComparer.Ordinal);
 
         await UpdateArchiveMetadata(archive, schemaNames, cancellationToken);
@@ -442,27 +483,16 @@ await archive.TryGetSourceSchemaConfigurationAsync(
             EnableGlobalObjectIdentification = enableGlobalObjectIdentification
         };
 
-        var compositionLog = new CompositionLog();
         var schemaComposer = new SchemaComposer(
             sourceSchemas.Values.Select(t => t.Item1),
             schemaComposerOptions,
             compositionLog);
 
         var result = schemaComposer.Compose();
 
-        WriteCompositionLog(
-            compositionLog,
-            writer: result.IsSuccess ? console.Out : console.Error,
-            writeAsGraphQLComments: result.IsSuccess && printSchema);
-
         if (result.IsFailure)
         {
-            foreach (var error in result.Errors)
-            {
-                console.Error.WriteLine(error.Message);
-            }
-
-            return 1;
+            return result;
         }
 
         bufferWriter.Reset();
@@ -479,11 +509,7 @@ await archive.SetGatewayConfigurationAsync(
 
         await archive.CommitAsync(cancellationToken);
 
-        console.Out.WriteLine(printSchema
-            ? result.Value.ToString()
-            : string.Format(ComposeCommand_CompositeSchemaFile_Written, archiveFile));
-
-        return 0;
+        return result;
     }
 
     private static async Task UpdateArchiveMetadata(
@@ -510,7 +536,7 @@ private static async Task UpdateArchiveMetadata(
         await archive.SetArchiveMetadataAsync(metadata, cancellationToken);
     }
 
-    private static void WriteCompositionLog(
+    public static void WriteCompositionLog(
         CompositionLog compositionLog,
         IStandardStreamWriter writer,
         bool writeAsGraphQLComments)

src/HotChocolate/Fusion-vnext/src/Fusion.CommandLine/HotChocolate.Fusion.CommandLine.csproj

@@ -12,6 +12,7 @@
 
   <ItemGroup>
     <InternalsVisibleTo Include="HotChocolate.Fusion.CommandLine.Tests" />
+    <InternalsVisibleTo Include="ChilliCream.Nitro.CommandLine.Cloud" />
   </ItemGroup>
 
   <ItemGroup>

src/Nitro/CommandLine/src/CommandLine.Cloud/Commands/Fusion/FusionCommand.cs

@@ -0,0 +1,14 @@
+using ChilliCream.Nitro.CommandLine.Cloud.Option;
+
+namespace ChilliCream.Nitro.CommandLine.Cloud.Commands.Fusion;
+
+internal sealed class FusionCommand : Command
+{
+    public FusionCommand() : base("fusion")
+    {
+        AddGlobalOption(Opt<CloudUrlOption>.Instance);
+        AddGlobalOption(Opt<ApiKeyOption>.Instance);
+
+        AddCommand(new FusionPublishCommand());
+    }
+}