Add PushManifestsAsync method

Devantler.KubernetesProvisioner.GitOps.Core/IGitOpsProvisioner.cs

@@ -9,6 +9,18 @@ public interface IGitOpsProvisioner
   /// The Kubernetes context.
   /// </summary>
   public string? Context { get; set; }
+
+  /// <summary>
+  /// Push manifests to an OCI registry
+  /// </summary>
+  /// <param name="registryUri"></param>
+  /// <param name="manifestsDirectory"></param>
+  /// <param name="userName"></param>
+  /// <param name="password"></param>
+  /// <param name="cancellationToken"></param>
+  /// <returns></returns>
+  public Task PushManifestsAsync(Uri registryUri, string manifestsDirectory, string? userName = default, string? password = default, CancellationToken cancellationToken = default);
+
   /// <summary>
   /// Install the GitOps tooling on the Kubernetes cluster.
   /// </summary>

Devantler.KubernetesProvisioner.GitOps.Flux.Tests/Devantler.KubernetesProvisioner.GitOps.Flux.Tests.csproj

@@ -21,6 +21,10 @@
     <PackageReference Include="xunit" Version="2.9.2" />
   </ItemGroup>
 
+  <ItemGroup>
+    <PackageReference Include="Devantler.ContainerEngineProvisioner.Docker" Version="0.0.2" />
+  </ItemGroup>
+
   <ItemGroup>
     <ProjectReference Include="..\Devantler.KubernetesProvisioner.GitOps.Flux\Devantler.KubernetesProvisioner.GitOps.Flux.csproj" />
     <ProjectReference Include="..\Devantler.KubernetesProvisioner.Cluster.Kind\Devantler.KubernetesProvisioner.Cluster.Kind.csproj" />
@@ -33,4 +37,4 @@
   <ItemGroup>
     <Using Include="Xunit" />
   </ItemGroup>
-</Project>
+</Project>

Devantler.KubernetesProvisioner.GitOps.Flux.Tests/FluxProvisionerTests/AllMethodsTests.cs

@@ -1,4 +1,5 @@
 using Devantler.KindCLI;
+using Devantler.ContainerEngineProvisioner.Docker;
 
 namespace Devantler.KubernetesProvisioner.GitOps.Flux.Tests.FluxProvisionerTests;
 
@@ -20,18 +21,25 @@ public async Task Flux_InstallsAndReconciles_KustomizationsAsync()
     string context = "kind-" + clusterName;
     string configPath = Path.Combine(AppContext.BaseDirectory, "assets/kind-config.yaml");
     var fluxProvisioner = new FluxProvisioner(context);
+    var dockerProvisioner = new DockerProvisioner();
     var cancellationToken = new CancellationToken();
 
     // Act
     await Kind.DeleteClusterAsync(clusterName, cancellationToken);
     await Kind.CreateClusterAsync(clusterName, configPath, cancellationToken);
+    await dockerProvisioner.CreateRegistryAsync("ksail-registry", 5555, cancellationToken);
     await fluxProvisioner.InstallAsync(cancellationToken);
+    string testFile = Path.Combine(Path.GetTempPath(), Path.GetRandomFileName());
+    await File.WriteAllTextAsync(testFile, "test");
+    await fluxProvisioner.PushManifestsAsync(new Uri("oci://localhost:5555/test-manifest"), testFile, cancellationToken: cancellationToken);
     await FluxCLI.Flux.CreateOCISourceAsync("podinfo", new Uri("oci://ghcr.io/stefanprodan/manifests/podinfo"), context, cancellationToken: cancellationToken);
     await FluxCLI.Flux.CreateKustomizationAsync("podinfo", "OCIRepository/podinfo", "", context, cancellationToken: cancellationToken);
     await fluxProvisioner.ReconcileAsync(cancellationToken);
     await fluxProvisioner.UninstallAsync(cancellationToken);
 
     // Cleanup
     await Kind.DeleteClusterAsync(clusterName, cancellationToken);
+    await dockerProvisioner.DeleteRegistryAsync("ksail-registry", cancellationToken);
+    File.Delete(testFile);
   }
 }

Devantler.KubernetesProvisioner.GitOps.Flux/FluxProvisioner.cs

@@ -18,6 +18,10 @@ public class FluxProvisioner(string? context = default) : IGitOpsProvisioner
   /// <inheritdoc/>
   public string? Context { get; set; } = context;
 
+  /// <inheritdoc/>
+  public async Task PushManifestsAsync(Uri registryUri, string manifestsDirectory, string? userName = null, string? password = null, CancellationToken cancellationToken = default) =>
+    await FluxCLI.Flux.PushArtifactAsync(registryUri, manifestsDirectory, cancellationToken: cancellationToken).ConfigureAwait(false);
+
   /// <summary>
   /// Install Flux on the Kubernetes cluster.
   /// </summary>
@@ -26,11 +30,7 @@ public class FluxProvisioner(string? context = default) : IGitOpsProvisioner
   public async Task InstallAsync(CancellationToken cancellationToken = default) =>
     await FluxCLI.Flux.InstallAsync(Context, cancellationToken).ConfigureAwait(false);
 
-  /// <summary>
-  /// Reconcile resources on the Kubernetes cluster.
-  /// </summary>
-  /// <param name="cancellationToken"></param>
-  /// <returns></returns>
+  /// <inheritdoc/>
   public async Task ReconcileAsync(CancellationToken cancellationToken = default)
   {
     using var kubernetesResourceProvisioner = new KubernetesResourceProvisioner(Context);