fix(Dashboard): Workflow create vs update

- An `IsNew` variable was added to the state, which tracks whether the workflow is new or existing. This change prevents unnecessary API calls, reducing 404 errors and improving efficiency.

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

Author: JBBianchi

src/dashboard/Synapse.Dashboard/Pages/Workflows/Create/State.cs

@@ -36,6 +36,11 @@ public record CreateWorkflowViewState
     /// </summary>
     public string? DslVersion { get; set; }
 
+    /// <summary>
+    /// Gets/sets a boolean determining if the workflow is new or if it's an update
+    /// </summary>
+    public bool IsNew { get; set; } = true;
+
     /// <summary>
     /// Gets/sets the definition of the workflow to create
     /// </summary>

src/dashboard/Synapse.Dashboard/Pages/Workflows/Create/Store.cs

@@ -12,14 +12,14 @@
 // limitations under the License.
 
 using JsonCons.Utilities;
-using Neuroglia.Collections;
 using Neuroglia.Data;
 using Semver;
 using ServerlessWorkflow.Sdk.Models;
 using ServerlessWorkflow.Sdk.Validation;
 using Synapse.Api.Client.Services;
 using Synapse.Resources;
 using System.Text.RegularExpressions;
+using System.Xml.Linq;
 
 namespace Synapse.Dashboard.Pages.Workflows.Create;
 
@@ -102,7 +102,7 @@ IWorkflowDefinitionValidator workflowDefinitionValidator
     protected MonacoInterop MonacoInterop { get; } = monacoInterop;
 
     /// <summary>
-    /// Gets the service to  to validate workflow defintions
+    /// Gets the service to  to validate workflow definitions
     /// </summary>
     protected IWorkflowDefinitionValidator WorkflowDefinitionValidator { get; } = workflowDefinitionValidator;
 
@@ -218,6 +218,18 @@ public void SetName(string? name)
         });
     }
 
+    /// <summary>
+    /// Sets the state's <see cref="CreateWorkflowViewState.IsNew"/>
+    /// </summary>
+    /// <param name="isNew">The new <see cref="CreateWorkflowViewState.IsNew"/> value</param>
+    public void SetIsNew(bool isNew)
+    {
+        this.Reduce(state => state with
+        {
+            IsNew = isNew
+        });
+    }
+
     /// <summary>
     /// Sets the state's <see cref="CreateWorkflowViewState" /> <see cref="ProblemDetails"/>'s related data
     /// </summary>
@@ -415,57 +427,56 @@ public async Task SaveWorkflowDefinitionAsync()
             var @namespace = workflowDefinition!.Document.Namespace;
             var name = workflowDefinition.Document.Name;
             var version = workflowDefinition.Document.Version;
+            var isNew = this.Get(state => state.IsNew);
             this.Reduce(s => s with
             {
                 Saving = true
             });
             Workflow? workflow = null;
-            try
-            {
-                workflow = await this.Api.Workflows.GetAsync(name, @namespace);
-            }
-            catch
+            if (isNew)
             {
-                // Assume 404, might need actual handling
-            }
-            if (workflow == null)
-            {
-                workflow = await this.Api.Workflows.CreateAsync(new()
-                {
-                    Metadata = new()
-                    {
-                        Namespace = workflowDefinition!.Document.Namespace,
-                        Name = workflowDefinition.Document.Name
-                    },
-                    Spec = new()
+                try { 
+                    workflow = await this.Api.Workflows.CreateAsync(new()
                     {
-                        Versions = [workflowDefinition]
-                    }
-                });
-            }
-            else
-            {
-                var updatedResource = workflow.Clone()!;
-                var documentVersion = SemVersion.Parse(version, SemVersionStyles.Strict)!;
-                var latestVersion = SemVersion.Parse(updatedResource.Spec.Versions.GetLatest().Document.Version, SemVersionStyles.Strict)!;
-                if (updatedResource.Spec.Versions.Any(v => SemVersion.Parse(v.Document.Version, SemVersionStyles.Strict).CompareSortOrderTo(documentVersion) >= 0))
-                {
-                    this.Reduce(state => state with
-                    {
-                        ProblemTitle = "Invalid version",
-                        ProblemDetail = $"The specified version '{documentVersion}' must be strictly superior to the latest version '{latestVersion}'."
+                        Metadata = new()
+                        {
+                            Namespace = workflowDefinition!.Document.Namespace,
+                            Name = workflowDefinition.Document.Name
+                        },
+                        Spec = new()
+                        {
+                            Versions = [workflowDefinition]
+                        }
                     });
+                    this.NavigationManager.NavigateTo($"/workflows/details/{@namespace}/{name}/{version}");
                     return;
                 }
-                updatedResource.Spec.Versions.Add(workflowDefinition!);
-                var jsonPatch = JsonPatch.FromDiff(this.JsonSerializer.SerializeToElement(workflow)!.Value, this.JsonSerializer.SerializeToElement(updatedResource)!.Value);
-                var patch = this.JsonSerializer.Deserialize<Json.Patch.JsonPatch>(jsonPatch.RootElement);
-                if (patch != null)
+                catch (ProblemDetailsException ex) when (ex.Problem.Title == "Conflict" && ex.Problem.Detail != null && ex.Problem.Detail.EndsWith("already exists"))
                 {
-                    var resourcePatch = new Patch(PatchType.JsonPatch, jsonPatch);
-                    await this.Api.ManageNamespaced<Workflow>().PatchAsync(name, @namespace, resourcePatch, null, this.CancellationTokenSource.Token);
+                    // the workflow exists, try to update it instead
                 }
             }
+            workflow = await this.Api.Workflows.GetAsync(name, @namespace);
+            var updatedResource = workflow.Clone()!;
+            var documentVersion = SemVersion.Parse(version, SemVersionStyles.Strict)!;
+            var latestVersion = SemVersion.Parse(updatedResource.Spec.Versions.GetLatest().Document.Version, SemVersionStyles.Strict)!;
+            if (updatedResource.Spec.Versions.Any(v => SemVersion.Parse(v.Document.Version, SemVersionStyles.Strict).CompareSortOrderTo(documentVersion) >= 0))
+            {
+                this.Reduce(state => state with
+                {
+                    ProblemTitle = "Invalid version",
+                    ProblemDetail = $"The specified version '{documentVersion}' must be strictly superior to the latest version '{latestVersion}'."
+                });
+                return;
+            }
+            updatedResource.Spec.Versions.Add(workflowDefinition!);
+            var jsonPatch = JsonPatch.FromDiff(this.JsonSerializer.SerializeToElement(workflow)!.Value, this.JsonSerializer.SerializeToElement(updatedResource)!.Value);
+            var patch = this.JsonSerializer.Deserialize<Json.Patch.JsonPatch>(jsonPatch.RootElement);
+            if (patch != null)
+            {
+                var resourcePatch = new Patch(PatchType.JsonPatch, jsonPatch);
+                await this.Api.ManageNamespaced<Workflow>().PatchAsync(name, @namespace, resourcePatch, null, this.CancellationTokenSource.Token);
+            }
             this.NavigationManager.NavigateTo($"/workflows/details/{@namespace}/{name}/{version}");
         }
         catch (ProblemDetailsException ex)

src/dashboard/Synapse.Dashboard/Pages/Workflows/Create/View.razor

@@ -37,10 +37,10 @@ else
         <PreferredLanguageSelector PreferredLanguageChange="Store.ToggleTextBasedEditorLanguageAsync" />
     </div>
     <StandaloneCodeEditor @ref="Store.TextEditor"
-                          ConstructionOptions="Store.StandaloneEditorConstructionOptions"
-                          OnDidInit="Store.OnTextBasedEditorInitAsync"
-                          OnDidChangeModelContent="Store.OnDidChangeModelContent"
-                          CssClass="h-100" />
+    ConstructionOptions="Store.StandaloneEditorConstructionOptions"
+    OnDidInit="Store.OnTextBasedEditorInitAsync"
+    OnDidChangeModelContent="Store.OnDidChangeModelContent"
+    CssClass="h-100" />
     @if (problemDetails != null)
     {
         <div class="problems px-3">
@@ -93,6 +93,7 @@ else
         await base.OnInitializedAsync();
         BreadcrumbManager.Use(Breadcrumbs.Workflows);
         BreadcrumbManager.Add(new($"New", $"/workflows/new"));
+        Store.SetIsNew(true);
         Store.Namespace.Subscribe(value => OnStateChanged(_ => ns = value), token: CancellationTokenSource.Token);
         Store.Name.Subscribe(value => OnStateChanged(_ => name = value), token: CancellationTokenSource.Token);
         Store.Loading.Subscribe(value => OnStateChanged(_ => loading = value), token: CancellationTokenSource.Token);
@@ -110,6 +111,7 @@ else
         if (Name != name)
         {
             Store.SetName(Name);
+            Store.SetIsNew(false);
         }
     }