feat: export/publish built-in managed gateway apis

Author: daviian

tools/code/common/Gateway.cs

@@ -15,6 +15,8 @@ namespace common;
 
 public sealed record GatewayName : ResourceName
 {
+    public static GatewayName Managed { get; } = From("managed");
+
     private GatewayName(string value) : base(value) { }
 
     public static GatewayName From(string value) => new(value);
@@ -119,6 +121,15 @@ public static Option<GatewayInformationFile> TryParse(FileInfo? file, Management
 
 public sealed record GatewayDto
 {
+    public static GatewayDto Managed { get; } = new()
+    {
+        Properties = new GatewayContract
+        {
+            Description = null,
+            LocationData = null
+        }
+    };
+
     [JsonPropertyName("properties")]
     [JsonIgnore(Condition = JsonIgnoreCondition.WhenWritingDefault)]
     public required GatewayContract Properties { get; init; }

tools/code/extractor/Gateway.cs

@@ -34,15 +34,19 @@ await list(cancellationToken)
 
     private async ValueTask ExtractGateway(GatewayName name, GatewayDto dto, CancellationToken cancellationToken)
     {
-        await writeArtifacts(name, dto, cancellationToken);
+        if (name != GatewayName.Managed)
+        {
+            await writeArtifacts(name, dto, cancellationToken);
+        }
         await extractGatewayApis(name, cancellationToken);
     }
 }
 
 file sealed class ListGatewaysHandler(ManagementServiceUri serviceUri, HttpPipeline pipeline)
 {
     public IAsyncEnumerable<(GatewayName, GatewayDto)> Handle(CancellationToken cancellationToken) =>
-        GatewaysUri.From(serviceUri).List(pipeline, cancellationToken);
+        GatewaysUri.From(serviceUri).List(pipeline, cancellationToken)
+            .Append((GatewayName.Managed, GatewayDto.Managed));
 }
 
 file sealed class ShouldExtractGatewayHandler(ShouldExtractFactory shouldExtractFactory)

tools/code/publisher/Api.cs

@@ -25,7 +25,7 @@ namespace publisher;
 
 internal delegate Option<PublisherAction> FindApiAction(FileInfo file);
 
-file delegate Option<ApiName> TryParseApiName(FileInfo file);
+internal delegate Option<ApiName> TryParseApiName(FileInfo file);
 
 file delegate ValueTask ProcessApi(ApiName name, CancellationToken cancellationToken);
 

tools/code/publisher/Common.cs

@@ -13,8 +13,10 @@
 using Microsoft.IdentityModel.JsonWebTokens;
 using System;
 using System.Collections.Frozen;
+using System.Collections.Generic;
 using System.Diagnostics;
 using System.IO;
+using System.Linq;
 using System.Reflection;
 using System.Threading;
 using System.Threading.Tasks;
@@ -53,19 +55,43 @@ namespace publisher;
 
 file delegate ValueTask<Option<BinaryData>> TryGetFileContentsInCommit(FileInfo fileInfo, CommitId commitId, CancellationToken cancellationToken);
 
-file sealed class GetPublisherFilesHandler(TryGetCommitId tryGetCommitId, ManagementServiceDirectory serviceDirectory)
+file sealed class GetPublisherFilesHandler(TryGetCommitId tryGetCommitId, TryParseApiName tryParseApiName, ManagementServiceDirectory serviceDirectory)
 {
-    private readonly Lazy<FrozenSet<FileInfo>> lazy = new(() => GetPublisherFiles(tryGetCommitId, serviceDirectory));
+    private readonly Lazy<FrozenSet<FileInfo>> lazy = new(() => GetPublisherFiles(tryGetCommitId, tryParseApiName, serviceDirectory));
 
     public FrozenSet<FileInfo> Handle() => lazy.Value;
 
-    private static FrozenSet<FileInfo> GetPublisherFiles(TryGetCommitId tryGetCommitId, ManagementServiceDirectory serviceDirectory) =>
+    private static FrozenSet<FileInfo> GetPublisherFiles(TryGetCommitId tryGetCommitId, TryParseApiName tryParseApiName,
+        ManagementServiceDirectory serviceDirectory) =>
         tryGetCommitId()
-            .Map(commitId => GetPublisherFiles(commitId, serviceDirectory))
-            .IfNone(serviceDirectory.GetFilesRecursively);
+            .Map(commitId => GetPublisherFiles(commitId, tryParseApiName, serviceDirectory))
+            .IfNone(() =>
+                serviceDirectory.GetFilesRecursively().ToList()
+                    .Concat(GetManagedGatewayApis(serviceDirectory))
+                    .ToFrozenSet(x => x.FullName)
+            );
+
+    private static IEnumerable<FileInfo> GetManagedGatewayApis(ManagementServiceDirectory serviceDirectory) =>
+        ApisDirectory.From(serviceDirectory).ToDirectoryInfo()
+            .ListDirectories("*")
+            .Map(info =>
+                GatewayApiInformationFile.From(ApiName.From(info.Name), GatewayName.Managed, serviceDirectory)
+                    .ToFileInfo());
+
+    private static FrozenSet<FileInfo> GetPublisherFiles(CommitId commitId, TryParseApiName tryParseApiName,
+        ManagementServiceDirectory serviceDirectory)
+    {
+        var changedFiles = Git.GetChangedFilesInCommit(serviceDirectory.ToDirectoryInfo(), commitId).ToList();
+        return changedFiles
+            .Concat(GetChangedManagedGatewayApis(changedFiles, tryParseApiName, serviceDirectory))
+            .ToFrozenSet(x => x.FullName);
+    }
 
-    private static FrozenSet<FileInfo> GetPublisherFiles(CommitId commitId, ManagementServiceDirectory serviceDirectory) =>
-        Git.GetChangedFilesInCommit(serviceDirectory.ToDirectoryInfo(), commitId);
+    private static IEnumerable<FileInfo> GetChangedManagedGatewayApis(List<FileInfo> changedFiles, TryParseApiName tryParseApiName, ManagementServiceDirectory serviceDirectory) =>
+        changedFiles.Map(x => tryParseApiName(x))
+            .Filter(x => x.IsSome)
+            .Map(x => GatewayApiInformationFile.From(ApiName.GetRootName(x.ValueUnsafe()), GatewayName.Managed, serviceDirectory)
+                .ToFileInfo());
 }
 
 file sealed class GetArtifactFilesHandler(TryGetCommitId tryGetCommitId, ManagementServiceDirectory serviceDirectory)

tools/code/publisher/Gateway.cs

@@ -93,6 +93,11 @@ public async ValueTask Handle(GatewayName name, CancellationToken cancellationTo
 
     private async ValueTask HandleInner(GatewayName name, CancellationToken cancellationToken)
     {
+        if (name == GatewayName.Managed)
+        {
+            return;
+        }
+
         if (isNameInSourceControl(name))
         {
             await put(name, cancellationToken);

tools/code/publisher/GatewayApi.cs

@@ -163,7 +163,7 @@ public async ValueTask Handle(ApiName name, GatewayApiDto dto, GatewayName gatew
     }
 }
 
-file sealed class DeleteGatewayApiHandler(DeleteGatewayApiFromApim deleteFromApim) : IDisposable
+file sealed class DeleteGatewayApiHandler(PutApi putApi, DeleteGatewayApiFromApim deleteFromApim) : IDisposable
 {
     private readonly GatewayApiSemaphore semaphore = new();
 
@@ -172,6 +172,11 @@ public async ValueTask Handle(ApiName name, GatewayName gatewayName, Cancellatio
 
     private async ValueTask Delete(ApiName name, GatewayName gatewayName, CancellationToken cancellationToken)
     {
+        if (gatewayName == GatewayName.Managed)
+        {
+            await putApi(name, cancellationToken);
+        }
+
         await deleteFromApim(name, gatewayName, cancellationToken);
     }