feat(Dashboard): added operator filtering in workflows

Signed-off-by: Jean-Baptiste Bianchi <[email protected]>

Author: JBBianchi

src/dashboard/Synapse.Dashboard/Components/ResourceEditor/ResourceEditor.razor

@@ -36,7 +36,7 @@
                 }
             }
         </div>
-        <Button Color="ButtonColor.Primary" Outline="true" Disabled="updating || saving" Loading="saving" @onclick="async _ => await Store.SubmitResourceAsync()">
+        <Button Color="ButtonColor.Primary" Outline="true" Disabled="isUpdating || isSaving" Loading="isSaving" @onclick="async _ => await Store.SubmitResourceAsync()">
             @if (resource?.Metadata?.Generation == null || resource?.Metadata?.Generation == 0)
             {
                 <span>Create</span>
@@ -57,6 +57,12 @@
     /// </summary>
     [Parameter] public TResource? Resource { get; set; }
 
+    bool isCluster = false;
+    /// <summary>
+    /// Gets/sets a boolean indicating the resource is a cluster
+    /// </summary>
+    [Parameter] public bool IsCluster { get; set; } = false;
+
     /// <summary>
     /// The reference of the <see cref="StandaloneCodeEditor" />
     /// </summary>
@@ -80,12 +86,12 @@
     /// <summary>
     /// A boolean indicating if the text editor is being updated
     /// </summary>
-    private bool updating = false;
+    private bool isUpdating = false;
 
     /// <summary>
     /// A boolean indicating if the resource is being saved
     /// </summary>
-    private bool saving = false;
+    private bool isSaving = false;
 
     /// <summary>
     /// The <see cref="ProblemDetails"/> that occurred when trying to save the resource, if any
@@ -97,8 +103,8 @@
     {
         await base.OnInitializedAsync().ConfigureAwait(false);
         this.Store.Resource.Subscribe(resource => this.OnStateChanged(cmp => cmp.resource = resource), token: this.CancellationTokenSource.Token);
-        this.Store.Updating.Subscribe(updating => this.OnStateChanged(cmp => cmp.updating = updating), token: this.CancellationTokenSource.Token);
-        this.Store.Saving.Subscribe(OnSavingChanged, token: this.CancellationTokenSource.Token);
+        this.Store.IsUpdating.Subscribe(updating => this.OnStateChanged(cmp => cmp.isUpdating = updating), token: this.CancellationTokenSource.Token);
+        this.Store.IsSaving.Subscribe(OnSavingChanged, token: this.CancellationTokenSource.Token);
         this.Store.ProblemDetails.Subscribe(problemDetails => this.OnStateChanged(cmp => cmp.problemDetails = problemDetails), token: this.CancellationTokenSource.Token);
         this.textEditorInput
             .Throttle(TimeSpan.FromMilliseconds(300))
@@ -119,6 +125,11 @@
             this.resource = this.Resource; // should happen in this.Store.Resource.Subscribe but prevents possible race when multiple params are set
             this.Store.SetResource(this.Resource);
         }
+        if (this.isCluster != this.IsCluster)
+        {
+            this.isCluster = this.IsCluster;
+            this.Store.SetIsCluster(this.IsCluster);
+        }
         return base.OnParametersSetAsync();
     }
 
@@ -128,7 +139,7 @@
     /// <param name="saving">Whenever the resource is in a saving state</param>
     private void OnSavingChanged(bool saving)
     {
-        this.saving = saving;
+        this.isSaving = saving;
         if (this.textBasedEditor != null) this.textBasedEditor.UpdateOptions(new EditorUpdateOptions() { ReadOnly = saving });
         this.StateHasChanged();
     }
@@ -161,7 +172,7 @@
     /// <returns>A <see cref="Task"/></returns>
     private async Task OnTextBasedValueChanged(ModelContentChangedEvent e)
     {
-        if (!this.updating && this.textBasedEditor != null && this.textEditorInput != null)
+        if (!this.isUpdating && this.textBasedEditor != null && this.textEditorInput != null)
         {
             var text = await this.textBasedEditor.GetValue();
             this.textEditorInput.OnNext(text);

src/dashboard/Synapse.Dashboard/Components/ResourceEditor/State.cs

@@ -35,15 +35,20 @@ public record ResourceEditorState<TResource>
     /// </summary>
     public string TextEditorValue { get; set; } = string.Empty;
 
+    /// <summary>
+    /// Gets/sets a boolean indicating if the resource is a cluster
+    /// </summary>
+    public bool IsCluster { get; set; } = false;
+
     /// <summary>
     /// Gets/sets a boolean indicating if the text editor is being updated
     /// </summary>
-    public bool Updating { get; set; } = false;
+    public bool IsUpdating { get; set; } = false;
 
     /// <summary>
     /// Gets/sets a boolean indicating if the resource is being saved
     /// </summary>
-    public bool Saving { get; set; } = false;
+    public bool IsSaving { get; set; } = false;
 
     /// <summary>
     /// Gets/sets the <see cref="ProblemDetails"/> type that occurred when trying to save the resource, if any

src/dashboard/Synapse.Dashboard/Components/ResourceEditor/Store.cs

@@ -15,7 +15,6 @@
 using Neuroglia.Data;
 using Neuroglia.Serialization.Yaml;
 using Synapse.Api.Client.Services;
-using System.Reactive.Linq;
 
 namespace Synapse.Dashboard.Components.ResourceEditorStateManagement;
 
@@ -50,14 +49,19 @@ public class ResourceEditorStore<TResource>(ISynapseApiClient apiClient, IMonaco
     public IObservable<string> TextEditorValue => this.Select(state => state.TextEditorValue).DistinctUntilChanged();
 
     /// <summary>
-    /// Gets an <see cref="IObservable{T}"/> used to observe <see cref="ResourceEditorState{TResource}.Updating"/> changes
+    /// Gets an <see cref="IObservable{T}"/> used to observe <see cref="ResourceEditorState{TResource}.IsCluster"/> changes
     /// </summary>
-    public IObservable<bool> Updating => this.Select(state => state.Updating).DistinctUntilChanged();
+    public IObservable<bool> IsCluster => this.Select(state => state.IsCluster).DistinctUntilChanged();
 
     /// <summary>
-    /// Gets an <see cref="IObservable{T}"/> used to observe <see cref="ResourceEditorState{TResource}.Saving"/> changes
+    /// Gets an <see cref="IObservable{T}"/> used to observe <see cref="ResourceEditorState{TResource}.IsUpdating"/> changes
     /// </summary>
-    public IObservable<bool> Saving => this.Select(state => state.Saving).DistinctUntilChanged();
+    public IObservable<bool> IsUpdating => this.Select(state => state.IsUpdating).DistinctUntilChanged();
+
+    /// <summary>
+    /// Gets an <see cref="IObservable{T}"/> used to observe <see cref="ResourceEditorState{TResource}.IsSaving"/> changes
+    /// </summary>
+    public IObservable<bool> IsSaving => this.Select(state => state.IsSaving).DistinctUntilChanged();
 
     /// <summary>
     /// Gets an <see cref="IObservable{T}"/> used to observe <see cref="ResourceEditorState{TResource}.ProblemType"/> changes
@@ -166,26 +170,38 @@ public void SetEditorValue(string textEditorValue)
     }
 
     /// <summary>
-    /// Sets the state's <see cref="ResourceEditorState{TResource}.Updating"/>
+    /// Sets the state's <see cref="ResourceEditorState{TResource}.IsUpdating"/>
+    /// </summary>
+    /// <param name="isUpdating">The new <see cref="ResourceEditorState{TResource}.IsUpdating"/> value</param>
+    public void SetUpdating(bool isUpdating)
+    {
+        this.Reduce(state => state with
+        {
+            IsUpdating = isUpdating
+        });
+    }
+
+    /// <summary>
+    /// Sets the state's <see cref="ResourceEditorState{TResource}.IsCluster"/>
     /// </summary>
-    /// <param name="updating">The new <see cref="ResourceEditorState{TResource}.Updating"/> value</param>
-    public void SetUpdating(bool updating)
+    /// <param name="isCluster">The new <see cref="ResourceEditorState{TResource}.IsCluster"/> value</param>
+    public void SetIsCluster(bool isCluster)
     {
         this.Reduce(state => state with
         {
-            Updating = updating
+            IsCluster = isCluster
         });
     }
 
     /// <summary>
-    /// Sets the state's <see cref="ResourceEditorState{TResource}.Saving"/>
+    /// Sets the state's <see cref="ResourceEditorState{TResource}.IsSaving"/>
     /// </summary>
-    /// <param name="saving">The new <see cref="ResourceEditorState{TResource}.Saving"/> value</param>
-    public void SetSaving(bool saving)
+    /// <param name="isSaving">The new <see cref="ResourceEditorState{TResource}.IsSaving"/> value</param>
+    public void SetSaving(bool isSaving)
     {
         this.Reduce(state => state with
         {
-            Saving = saving
+            IsSaving = isSaving
         });
     }
 
@@ -258,7 +274,11 @@ public async Task CreateResourceAsync()
         try
         {
             resource = jsonSerializer.Deserialize<TResource>(textEditorValue);
-            resource = await apiClient.ManageNamespaced<TResource>().CreateAsync(resource!, this.CancellationTokenSource.Token);
+            var isCluster = this.Get(state => state.IsCluster);
+            resource = await (!isCluster ? 
+                 apiClient.ManageNamespaced<TResource>().CreateAsync(resource!, this.CancellationTokenSource.Token) :
+                 apiClient.ManageCluster<TResource>().CreateAsync(resource!, this.CancellationTokenSource.Token)
+            );
             this.SetResource(resource);
         }
         catch (ProblemDetailsException ex)
@@ -294,7 +314,11 @@ public async Task UpdateResourceAsync()
             var resourcePatch = new Patch(PatchType.JsonPatch, jsonPatch);
             try
             {
-                resource = await apiClient.ManageNamespaced<TResource>().PatchAsync(resource.GetName(), resource.GetNamespace()!, resourcePatch, null, this.CancellationTokenSource.Token);
+                var isCluster = this.Get(state => state.IsCluster);
+                resource = await (!isCluster ? 
+                     apiClient.ManageNamespaced<TResource>().PatchAsync(resource.GetName(), resource.GetNamespace()!, resourcePatch, null, this.CancellationTokenSource.Token) :
+                     apiClient.ManageCluster<TResource>().PatchAsync(resource.GetName(), resourcePatch, null, this.CancellationTokenSource.Token)
+                );
                 this.SetResource(resource);
             }
             catch(ProblemDetailsException ex)

src/dashboard/Synapse.Dashboard/Components/ResourceManagement/ClusterResourceManagementComponentStore.cs

@@ -36,4 +36,38 @@ public override async Task DeleteResourceAsync(TResource resource)
         await this.ApiClient.ManageCluster<TResource>().DeleteAsync(resource.GetName()).ConfigureAwait(false);
     }
 
+    /// <inheritdoc/>
+    public override async Task GetResourceDefinitionAsync()
+    {
+        var resourceDefinition = await this.ApiClient.ManageCluster<TResource>().GetDefinitionAsync().ConfigureAwait(false);
+        this.Reduce(s => s with
+        {
+            Definition = resourceDefinition
+        });
+    }
+
+    /// <inheritdoc/>
+    public override async Task ListResourcesAsync(ResourcesFilter? filter = null)
+    {
+        try
+        {
+            this.Reduce(state => state with
+            {
+                Loading = true,
+            });
+            var resourceList = new EquatableList<TResource>(await (await this.ApiClient.ManageCluster<TResource>().ListAsync(filter?.LabelSelectors).ConfigureAwait(false)).OrderBy(r => r.Metadata.CreationTimestamp).ToListAsync().ConfigureAwait(false));
+            this.Reduce(s => s with
+            {
+                Resources = resourceList,
+                Loading = false
+            });
+        }
+        catch (Exception ex)
+        {
+            Console.WriteLine(ex.ToString());
+            // todo: implement proper error handling
+        }
+    }
+
+
 }

src/dashboard/Synapse.Dashboard/Components/ResourceManagement/NamespacedResourceManagementComponentState.cs

@@ -23,12 +23,12 @@ public record NamespacedResourceManagementComponentState<TResource>
 {
 
     /// <summary>
-    /// Gets a <see cref="List{T}"/> that contains all cached <see cref="Neuroglia.Data.Infrastructure.ResourceOriented.Namespace"/>s
+    /// Gets a <see cref="EquatableList{T}"/> that contains all <see cref="Neuroglia.Data.Infrastructure.ResourceOriented.Namespace"/>s
     /// </summary>
     public EquatableList<Namespace>? Namespaces { get; set; }
 
     /// <summary>
-    /// Gets the <see cref="Neuroglia.Data.Infrastructure.ResourceOriented.Namespace"/>, if any, the (namespaced) resources to list belong to
+    /// Gets the <see cref="Neuroglia.Data.Infrastructure.ResourceOriented.Namespace"/> the (namespaced) resources to list belong to, if any
     /// </summary>
     public string? Namespace { get; set; }
 

src/dashboard/Synapse.Dashboard/Components/ResourceManagement/ResourceManagementComponent.cs

@@ -227,7 +227,7 @@ protected Task OnShowResourceDetailsAsync(TResource resource)
         if (this.DetailsOffCanvas == null) return Task.CompletedTask;
         var parameters = new Dictionary<string, object>
         {
-            { "Resource", resource }
+            { nameof(ResourceEditor<TResource>.Resource), resource }
         };
         return this.DetailsOffCanvas.ShowAsync<ResourceDetails<TResource>>(title: typeof(TResource).Name + " details", parameters: parameters);
     }
@@ -236,12 +236,12 @@ protected Task OnShowResourceDetailsAsync(TResource resource)
     /// Opens the targeted <see cref="Resource"/>'s edition
     /// </summary>
     /// <param name="resource">The <see cref="Resource"/> to edit</param>
-    protected Task OnShowResourceEditorAsync(TResource? resource = null)
+    protected virtual Task OnShowResourceEditorAsync(TResource? resource = null)
     {
         if (this.EditorOffCanvas == null) return Task.CompletedTask;
         var parameters = new Dictionary<string, object>
         {
-            { "Resource", resource! }
+            { nameof(ResourceEditor<TResource>.Resource), resource! }
         };
         string actionType = resource == null ? "creation" : "edition";
         return this.EditorOffCanvas.ShowAsync<ResourceEditor<TResource>>(title: typeof(TResource).Name + " " + actionType, parameters: parameters);