.github/ISSUE_TEMPLATE/bug.yml

@@ -0,0 +1,72 @@
+name: Bug Report
+description: Create a bug report
+labels: ["type: bug"]
+body:
+- type: markdown
+  attributes:
+    value: |
+       :pray: Thanks for taking the time to fill out this bug report!
+
+- type: markdown
+  attributes:
+    value: |
+       ## Bug Report
+
+- type: textarea
+  id: i-tried-this
+  attributes:
+    label: "I tried this:"
+    placeholder: "What did you try to do? A code snippet or example helps."
+  validations:
+    required: true
+
+- type: textarea
+  id: instead-what-happened
+  attributes:
+    label: "This happened:"
+    placeholder: "What happened instead of what you've expected?"
+  validations:
+    required: true
+
+- type: textarea
+  id: what-did-you-expect
+  attributes:
+    label: "I expected this:"
+    placeholder: "What did you expect to happen? Describe the output or behavior you expected to see (unless it's obvious)."
+
+- type: textarea
+  id: workaround
+  attributes:
+    label: "Is there a workaround?"
+    placeholder: "What's the workaround to avoid this issue?"
+
+- type: textarea
+  attributes:
+    label: Anything else?
+    placeholder: |
+      Links? References? Logs? Anything that will give us more context about the issue you are encountering.
+      Tip: You can attach images or log files by dragging files in.
+
+- type: markdown
+  attributes:
+    value: |
+       ## Environment
+
+- type: dropdown
+  id: platform
+  attributes:
+    label: "Platform(s)"
+    multiple: true
+    options:
+      - MacOS
+      - Linux
+      - Windows
+      - Other
+
+- type: textarea
+  attributes:
+    label: Community Notes
+    value: |
+      <!-- Please keep this note for the community -->
+      * Please vote by adding a 👍 reaction to the issue to help us prioritize.
+      * If you are interested to work on this issue, please leave a comment.name: Bug Report 🐞

.github/ISSUE_TEMPLATE/feature.yml

@@ -0,0 +1,47 @@
+name: Feature Request
+description: Create a feature request
+labels: ["type: enhancement"]
+body:
+- type: markdown
+  attributes:
+    value: |
+       :pray: Thanks for taking the time to fill out this feature request!
+
+- type: markdown
+  attributes:
+    value: |
+       ## Feature Request
+
+- type: textarea
+  id: what-would-you-like-to-be-added
+  attributes:
+    label: "What would you like to be added?"
+    placeholder: "Description of the feature you'd like to see."
+  validations:
+    required: true
+
+- type: textarea
+  id: proposals
+  attributes:
+    label: "Proposal(s):"
+    placeholder: "Describe your proposal(s) and any relevant details here."
+
+- type: textarea
+  id: alternatives
+  attributes:
+    label: "Alternative(s):"
+    placeholder: "Describe any alternative approaches, options, or suggestions you’d like to consider."
+
+- type: textarea
+  id: additional-info
+  attributes:
+    label: "Additional info:"
+    placeholder: "Provide any supplementary details, context, or supporting information here."
+
+- type: textarea
+  attributes:
+    label: Community Notes
+    value: |
+      <!-- Please keep this note for the community -->
+      * Please vote by adding a 👍 reaction to the feature to help us prioritize.
+      * If you are interested to work on this feature, please leave a comment.

Synapse.sln

@@ -138,6 +138,28 @@ Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "kubernetes", "kubernetes",
 EndProject
 Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Synapse.Core.Infrastructure.Containers.Kubernetes", "src\core\Synapse.Core.Infrastructure.Containers.Kubernetes\Synapse.Core.Infrastructure.Containers.Kubernetes.csproj", "{41C99069-BD99-4FD2-BF33-984CF03B53E8}"
 EndProject
+Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = ".github", ".github", "{35D495F4-D267-4A84-9479-DB3C1BE85434}"
+	ProjectSection(SolutionItems) = preProject
+		.github\PULL_REQUEST_TEMPLATE.md = .github\PULL_REQUEST_TEMPLATE.md
+	EndProjectSection
+EndProject
+Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "workflows", "workflows", "{AB30A91B-0158-411D-9BD3-36FFA441B3A2}"
+	ProjectSection(SolutionItems) = preProject
+		.github\workflows\build-dotnet.yml = .github\workflows\build-dotnet.yml
+		.github\workflows\ci-pipeline.yml = .github\workflows\ci-pipeline.yml
+		.github\workflows\helm.yml = .github\workflows\helm.yml
+		.github\workflows\publish.yml = .github\workflows\publish.yml
+		.github\workflows\release.yml = .github\workflows\release.yml
+		.github\workflows\versioning.yml = .github\workflows\versioning.yml
+	EndProjectSection
+EndProject
+Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "ISSUE_TEMPLATE", "ISSUE_TEMPLATE", "{06404855-A5BE-4556-91BC-064630E95737}"
+	ProjectSection(SolutionItems) = preProject
+		.github\ISSUE_TEMPLATE\bug.yml = .github\ISSUE_TEMPLATE\bug.yml
+		config.yml = config.yml
+		.github\ISSUE_TEMPLATE\feature.yml = .github\ISSUE_TEMPLATE\feature.yml
+	EndProjectSection
+EndProject
 Global
 	GlobalSection(SolutionConfigurationPlatforms) = preSolution
 		Debug|Any CPU = Debug|Any CPU
@@ -272,6 +294,8 @@ Global
 		{DD6381BD-2C8B-4CE1-99B2-EC585DD818FA} = {9E296C8A-4D78-4592-B046-11A3A953FD25}
 		{B3F3DB1B-23E7-45FA-8934-448BFFB294E8} = {562C91A3-6E91-4489-9D9D-064E7436D900}
 		{41C99069-BD99-4FD2-BF33-984CF03B53E8} = {9E296C8A-4D78-4592-B046-11A3A953FD25}
+		{AB30A91B-0158-411D-9BD3-36FFA441B3A2} = {35D495F4-D267-4A84-9479-DB3C1BE85434}
+		{06404855-A5BE-4556-91BC-064630E95737} = {35D495F4-D267-4A84-9479-DB3C1BE85434}
 	EndGlobalSection
 	GlobalSection(ExtensibilityGlobals) = postSolution
 		SolutionGuid = {2A6C03D6-355A-4B39-9F2B-D0FDE429C0E2}

config.yml

@@ -0,0 +1,2 @@
+blank_issues_enabled: false
+contact_links: []

src/api/Synapse.Api.Application/Synapse.Api.Application.csproj

@@ -44,7 +44,7 @@
   <ItemGroup>
     <PackageReference Include="IdentityServer4" Version="4.1.2" NoWarn="NU1902" />
     <PackageReference Include="IdentityServer4.Storage" Version="4.1.2" NoWarn="NU1902" />
-    <PackageReference Include="Polly" Version="8.5.0" />
+    <PackageReference Include="Polly" Version="8.5.1" />
   </ItemGroup>
 
   <ItemGroup>

src/api/Synapse.Api.Client.Http/Synapse.Api.Client.Http.csproj

@@ -42,8 +42,8 @@
   </ItemGroup>
 
   <ItemGroup>
-    <PackageReference Include="Microsoft.AspNetCore.SignalR.Client" Version="9.0.0" />
-	<PackageReference Include="ServerlessWorkflow.Sdk.IO" Version="1.0.0-alpha5.2" />
+    <PackageReference Include="Microsoft.AspNetCore.SignalR.Client" Version="9.0.1" />
+	<PackageReference Include="ServerlessWorkflow.Sdk.IO" Version="1.0.0-alpha6.3" />
     <PackageReference Include="System.Reactive" Version="6.0.1" />
   </ItemGroup>
 

src/api/Synapse.Api.Http/Synapse.Api.Http.csproj

@@ -45,7 +45,7 @@
   <ItemGroup>
     <PackageReference Include="Neuroglia.Mediation.AspNetCore" Version="4.18.1" />
     <PackageReference Include="Neuroglia.Security.AspNetCore" Version="4.18.1" />
-	<PackageReference Include="Swashbuckle.AspNetCore.SwaggerGen" Version="7.1.0" />
+	<PackageReference Include="Swashbuckle.AspNetCore.SwaggerGen" Version="7.2.0" />
   </ItemGroup>
 
   <ItemGroup>

src/api/Synapse.Api.Server/Synapse.Api.Server.csproj

@@ -31,11 +31,11 @@
   </PropertyGroup>
 
   <ItemGroup>
-    <PackageReference Include="Microsoft.AspNetCore.Authentication.JwtBearer" Version="9.0.0" />
-    <PackageReference Include="Microsoft.AspNetCore.Authentication.OpenIdConnect" Version="9.0.0" />
-    <PackageReference Include="Microsoft.AspNetCore.Components.WebAssembly.Server" Version="9.0.0" />
+    <PackageReference Include="Microsoft.AspNetCore.Authentication.JwtBearer" Version="9.0.1" />
+    <PackageReference Include="Microsoft.AspNetCore.Authentication.OpenIdConnect" Version="9.0.1" />
+    <PackageReference Include="Microsoft.AspNetCore.Components.WebAssembly.Server" Version="9.0.1" />
     <PackageReference Include="Microsoft.VisualStudio.Azure.Containers.Tools.Targets" Version="1.21.0" />
-	<PackageReference Include="Swashbuckle.AspNetCore.SwaggerUI" Version="7.1.0" />
+	<PackageReference Include="Swashbuckle.AspNetCore.SwaggerUI" Version="7.2.0" />
   </ItemGroup>
 
   <ItemGroup>

src/cli/Synapse.Cli/Synapse.Cli.csproj

@@ -29,11 +29,11 @@
   </PropertyGroup>
 
   <ItemGroup>
-	<PackageReference Include="Microsoft.Extensions.DependencyInjection" Version="9.0.0" />
-	<PackageReference Include="Microsoft.Extensions.Logging.Abstractions" Version="9.0.0" />
+	<PackageReference Include="Microsoft.Extensions.DependencyInjection" Version="9.0.1" />
+	<PackageReference Include="Microsoft.Extensions.Logging.Abstractions" Version="9.0.1" />
 	<PackageReference Include="moment.net" Version="1.3.4" />
 	<PackageReference Include="NetEscapades.Configuration.Yaml" Version="3.1.0" />
-	<PackageReference Include="ServerlessWorkflow.Sdk.IO" Version="1.0.0-alpha5.2" />
+	<PackageReference Include="ServerlessWorkflow.Sdk.IO" Version="1.0.0-alpha6.3" />
 	<PackageReference Include="Spectre.Console" Version="0.49.1" />
     <PackageReference Include="System.CommandLine.NamingConventionBinder" Version="2.0.0-beta4.22272.1" />
   </ItemGroup>

src/core/Synapse.Core.Infrastructure/Services/XmlSchemaHandler.cs

@@ -15,9 +15,8 @@
 using Neuroglia.Serialization;
 using ServerlessWorkflow.Sdk;
 using System.Net;
-using System.Xml.Schema;
 using System.Xml;
-using Avro.Generic;
+using System.Xml.Schema;
 
 namespace Synapse.Core.Infrastructure.Services;
 

src/core/Synapse.Core.Infrastructure/Synapse.Core.Infrastructure.csproj

@@ -51,7 +51,7 @@
 	<PackageReference Include="Neuroglia.Mediation" Version="4.18.1" />
 	<PackageReference Include="Neuroglia.Plugins" Version="4.18.1" />
 	<PackageReference Include="Neuroglia.Serialization.Xml" Version="4.18.1" />
-	<PackageReference Include="ServerlessWorkflow.Sdk.IO" Version="1.0.0-alpha5.2" />
+	<PackageReference Include="ServerlessWorkflow.Sdk.IO" Version="1.0.0-alpha6.3" />
   </ItemGroup>
 
   <ItemGroup>

src/core/Synapse.Core/Resources/CorrelationContext.cs

@@ -37,13 +37,19 @@ public record CorrelationContext
     /// <summary>
     /// Gets a key/value mapping of the context's correlation keys
     /// </summary>
-    [DataMember(Name = "keys", Order = 2), JsonPropertyName("keys"), JsonPropertyOrder(2), YamlMember(Alias = "keys", Order = 2)]
+    [DataMember(Name = "keys", Order = 3), JsonPropertyName("keys"), JsonPropertyOrder(3), YamlMember(Alias = "keys", Order = 3)]
     public virtual EquatableDictionary<string, string> Keys { get; set; } = [];
 
     /// <summary>
     /// Gets a key/value mapping of all correlated events, with the key being the index of the matched correlation filter
     /// </summary>
-    [DataMember(Name = "events", Order = 3), JsonPropertyName("events"), JsonPropertyOrder(3), YamlMember(Alias = "events", Order = 3)]
+    [DataMember(Name = "events", Order = 4), JsonPropertyName("events"), JsonPropertyOrder(4), YamlMember(Alias = "events", Order = 4)]
     public virtual EquatableDictionary<int, CloudEvent> Events { get; set; } = [];
 
+    /// <summary>
+    /// Gets the offset that serves as the index of the event being processed by the consumer, if streaming has been enabled for the correlation associated with the context.
+    /// </summary>
+    [DataMember(Name = "offset", Order = 5), JsonPropertyName("offset"), JsonPropertyOrder(5), YamlMember(Alias = "offset", Order = 5)]
+    public virtual uint? Offset { get; set; }
+
 }

src/core/Synapse.Core/Resources/CorrelationSpec.cs

@@ -46,10 +46,16 @@ public record CorrelationSpec
     [DataMember(Name = "events", Order = 4), JsonPropertyName("events"), JsonPropertyOrder(4), YamlMember(Alias = "events", Order = 4)]
     public virtual EventConsumptionStrategyDefinition Events { get; set; } = null!;
 
+    /// <summary>
+    /// Gets/sets a boolean indicating whether or not to stream events. When enabled, each correlated event is atomically published to the subscriber immediately rather than waiting for the entire correlation to complete
+    /// </summary>
+    [DataMember(Name = "stream", Order = 5), JsonPropertyName("stream"), JsonPropertyOrder(5), YamlMember(Alias = "stream", Order = 5)]
+    public virtual bool Stream { get; set; }
+
     /// <summary>
     /// Gets/sets an object used to configure the correlation's outcome
     /// </summary>
-    [DataMember(Name = "outcome", Order = 5), JsonPropertyName("outcome"), JsonPropertyOrder(5), YamlMember(Alias = "outcome", Order = 5)]
+    [DataMember(Name = "outcome", Order = 6), JsonPropertyName("outcome"), JsonPropertyOrder(6), YamlMember(Alias = "outcome", Order = 6)]
     public virtual CorrelationOutcomeDefinition Outcome { get; set; } = null!;
 
 }

src/core/Synapse.Core/Synapse.Core.csproj

@@ -66,11 +66,11 @@
   <ItemGroup>
 	<PackageReference Include="Apache.Avro" Version="1.12.0" />
 	<PackageReference Include="Docker.DotNet" Version="3.125.15" />
-	<PackageReference Include="KubernetesClient" Version="15.0.1" />
+	<PackageReference Include="KubernetesClient" Version="16.0.1" />
 	<PackageReference Include="Neuroglia.Data.Infrastructure.ResourceOriented" Version="4.18.1" />
 	<PackageReference Include="Neuroglia.Eventing.CloudEvents" Version="4.18.1" />
     <PackageReference Include="Semver" Version="3.0.0" />
-    <PackageReference Include="ServerlessWorkflow.Sdk" Version="1.0.0-alpha5.2" />
+    <PackageReference Include="ServerlessWorkflow.Sdk" Version="1.0.0-alpha6.3" />
   </ItemGroup>
 
 </Project>

src/correlator/Synapse.Correlator/Services/CorrelationHandler.cs

@@ -334,7 +334,7 @@ protected virtual async Task CreateOrUpdateContextAsync(CorrelationContext conte
         {
             var index = updatedResource.Status.Contexts.IndexOf(existingContext);
             updatedResource.Status.Contexts.Remove(existingContext);
-            if (!completed) updatedResource.Status.Contexts.Insert(index, context);
+            updatedResource.Status.Contexts.Insert(index, context);
         }
         if (completed)
         {

src/correlator/Synapse.Correlator/Synapse.Correlator.csproj

@@ -33,17 +33,17 @@
   </PropertyGroup>
 
   <ItemGroup>
-	<PackageReference Include="Microsoft.Extensions.Configuration.KeyPerFile" Version="9.0.0" />
-    <PackageReference Include="Microsoft.Extensions.Hosting" Version="9.0.0" />
+	<PackageReference Include="Microsoft.Extensions.Configuration.KeyPerFile" Version="9.0.1" />
+    <PackageReference Include="Microsoft.Extensions.Hosting" Version="9.0.1" />
     <PackageReference Include="Microsoft.VisualStudio.Azure.Containers.Tools.Targets" Version="1.21.0" />
 	<PackageReference Include="Neuroglia.Data.Expressions.JavaScript" Version="4.18.1" />
 	<PackageReference Include="Neuroglia.Data.Expressions.JQ" Version="4.18.1" />
     <PackageReference Include="Neuroglia.Eventing.CloudEvents.AspNetCore" Version="4.18.1" />
 	<PackageReference Include="Neuroglia.Mediation.AspNetCore" Version="4.18.1" />
 	<PackageReference Include="Neuroglia.Eventing.CloudEvents.Infrastructure" Version="4.18.1" />
 	<PackageReference Include="Neuroglia.Security.AspNetCore" Version="4.18.1" />
-	<PackageReference Include="Swashbuckle.AspNetCore.SwaggerGen" Version="7.1.0" />
-	<PackageReference Include="Swashbuckle.AspNetCore.SwaggerUI" Version="7.0.0" />
+	<PackageReference Include="Swashbuckle.AspNetCore.SwaggerGen" Version="7.2.0" />
+	<PackageReference Include="Swashbuckle.AspNetCore.SwaggerUI" Version="7.2.0" />
   </ItemGroup>
 
   <ItemGroup>

src/dashboard/Synapse.Dashboard.StateManagement/Synapse.Dashboard.StateManagement.csproj

@@ -9,9 +9,9 @@
   </PropertyGroup>
 
   <ItemGroup>
-	<PackageReference Include="Microsoft.Extensions.DependencyInjection.Abstractions" Version="9.0.0" />
-	<PackageReference Include="Microsoft.Extensions.Logging.Abstractions" Version="9.0.0" />
-	<PackageReference Include="Microsoft.Extensions.Options" Version="9.0.0" />
+	<PackageReference Include="Microsoft.Extensions.DependencyInjection.Abstractions" Version="9.0.1" />
+	<PackageReference Include="Microsoft.Extensions.Logging.Abstractions" Version="9.0.1" />
+	<PackageReference Include="Microsoft.Extensions.Options" Version="9.0.1" />
   </ItemGroup>
 
   <ItemGroup>

src/dashboard/Synapse.Dashboard/Components/WorkflowDiagram/Templates/NodeShapeTemplate.razor

@@ -42,7 +42,7 @@
                 c 0 -@((Node.RadiusX / 2).ToInvariantString()) @((Node.RadiusX / 2).ToInvariantString()) -@(Node.RadiusX.ToInvariantString()) @(Node.RadiusX.ToInvariantString()) -@(Node.RadiusX.ToInvariantString()) 
                 h @((bounds.Width - (Node.RadiusX * 2)).ToInvariantString()) 
                 c @((Node.RadiusX / 2).ToInvariantString()) 0 @(Node.RadiusX.ToInvariantString()) @((Node.RadiusY / 2).ToInvariantString()) @(Node.RadiusX.ToInvariantString()) @(Node.RadiusY.ToInvariantString())
-                v @(Constants.ClusterHeight + 10)
+                v @(Constants.ClusterHeight - 10)
                 h -@(bounds.Width.ToInvariantString()) 
                 z"
             />

src/dashboard/Synapse.Dashboard/Components/WorkflowDiagram/Templates/NodeSymbolTemplate.razor

@@ -31,7 +31,7 @@
         (0 - bounds.Height / 4).ToInvariantString() :
         !WorkflowNode.IsCluster ?
             (0 - _symbolSize / 2).ToInvariantString() :
-            (0 - (bounds.Height + _symbolSize - (Constants.ClusterHeight+10)) / 2).ToInvariantString();
+            (0 - (bounds.Height + _symbolSize - (Constants.ClusterHeight-10)) / 2).ToInvariantString();
 
     [CascadingParameter(Name = "Node")] public INodeViewModel Node { get; set; } = null!;
     [CascadingParameter(Name = "Symbol")] public string? Symbol { get; set; }