diff --git a/src/api/Synapse.Api.Application/Synapse.Api.Application.csproj b/src/api/Synapse.Api.Application/Synapse.Api.Application.csproj
index 345d385d..784f3f5c 100644
--- a/src/api/Synapse.Api.Application/Synapse.Api.Application.csproj
+++ b/src/api/Synapse.Api.Application/Synapse.Api.Application.csproj
@@ -7,7 +7,7 @@
en
True
1.0.0
- alpha5.12
+
$(VersionPrefix)
$(VersionPrefix)
The Synapse Authors
diff --git a/src/api/Synapse.Api.Client.Core/Synapse.Api.Client.Core.csproj b/src/api/Synapse.Api.Client.Core/Synapse.Api.Client.Core.csproj
index 9dfa1105..708ba6ac 100644
--- a/src/api/Synapse.Api.Client.Core/Synapse.Api.Client.Core.csproj
+++ b/src/api/Synapse.Api.Client.Core/Synapse.Api.Client.Core.csproj
@@ -7,7 +7,7 @@
en
True
1.0.0
- alpha5.12
+
$(VersionPrefix)
$(VersionPrefix)
The Synapse Authors
diff --git a/src/api/Synapse.Api.Client.Http/Synapse.Api.Client.Http.csproj b/src/api/Synapse.Api.Client.Http/Synapse.Api.Client.Http.csproj
index 81297faa..368116e6 100644
--- a/src/api/Synapse.Api.Client.Http/Synapse.Api.Client.Http.csproj
+++ b/src/api/Synapse.Api.Client.Http/Synapse.Api.Client.Http.csproj
@@ -7,7 +7,7 @@
en
True
1.0.0
- alpha5.12
+
$(VersionPrefix)
$(VersionPrefix)
The Synapse Authors
@@ -43,7 +43,7 @@
-
+
diff --git a/src/api/Synapse.Api.Http/Synapse.Api.Http.csproj b/src/api/Synapse.Api.Http/Synapse.Api.Http.csproj
index 2a4eeb1a..dbe2e207 100644
--- a/src/api/Synapse.Api.Http/Synapse.Api.Http.csproj
+++ b/src/api/Synapse.Api.Http/Synapse.Api.Http.csproj
@@ -8,7 +8,7 @@
Library
True
1.0.0
- alpha5.12
+
$(VersionPrefix)
$(VersionPrefix)
The Synapse Authors
@@ -43,8 +43,8 @@
-
-
+
+
diff --git a/src/api/Synapse.Api.Server/Synapse.Api.Server.csproj b/src/api/Synapse.Api.Server/Synapse.Api.Server.csproj
index b5c7e509..6964cbd0 100644
--- a/src/api/Synapse.Api.Server/Synapse.Api.Server.csproj
+++ b/src/api/Synapse.Api.Server/Synapse.Api.Server.csproj
@@ -7,7 +7,7 @@
en
True
1.0.0
- alpha5.12
+
$(VersionPrefix)
$(VersionPrefix)
The Synapse Authors
@@ -27,7 +27,6 @@
Linux
..\..\..
false
- false
diff --git a/src/cli/Synapse.Cli/Synapse.Cli.csproj b/src/cli/Synapse.Cli/Synapse.Cli.csproj
index 112b6d4e..70307239 100644
--- a/src/cli/Synapse.Cli/Synapse.Cli.csproj
+++ b/src/cli/Synapse.Cli/Synapse.Cli.csproj
@@ -8,7 +8,7 @@
en
True
1.0.0
- alpha5.12
+
$(VersionPrefix)
$(VersionPrefix)
The Synapse Authors
@@ -33,7 +33,7 @@
-
+
diff --git a/src/core/Synapse.Core.Infrastructure.Containers.Docker/Synapse.Core.Infrastructure.Containers.Docker.csproj b/src/core/Synapse.Core.Infrastructure.Containers.Docker/Synapse.Core.Infrastructure.Containers.Docker.csproj
index 729b3fa1..d954abc5 100644
--- a/src/core/Synapse.Core.Infrastructure.Containers.Docker/Synapse.Core.Infrastructure.Containers.Docker.csproj
+++ b/src/core/Synapse.Core.Infrastructure.Containers.Docker/Synapse.Core.Infrastructure.Containers.Docker.csproj
@@ -7,7 +7,7 @@
en
True
1.0.0
- alpha5.12
+
$(VersionPrefix)
$(VersionPrefix)
The Synapse Authors
diff --git a/src/core/Synapse.Core.Infrastructure.Containers.Kubernetes/Synapse.Core.Infrastructure.Containers.Kubernetes.csproj b/src/core/Synapse.Core.Infrastructure.Containers.Kubernetes/Synapse.Core.Infrastructure.Containers.Kubernetes.csproj
index 5237405c..c2b604a5 100644
--- a/src/core/Synapse.Core.Infrastructure.Containers.Kubernetes/Synapse.Core.Infrastructure.Containers.Kubernetes.csproj
+++ b/src/core/Synapse.Core.Infrastructure.Containers.Kubernetes/Synapse.Core.Infrastructure.Containers.Kubernetes.csproj
@@ -7,7 +7,7 @@
en
True
1.0.0
- alpha5.12
+
$(VersionPrefix)
$(VersionPrefix)
The Synapse Authors
diff --git a/src/core/Synapse.Core.Infrastructure/Synapse.Core.Infrastructure.csproj b/src/core/Synapse.Core.Infrastructure/Synapse.Core.Infrastructure.csproj
index 72703a72..443e8984 100644
--- a/src/core/Synapse.Core.Infrastructure/Synapse.Core.Infrastructure.csproj
+++ b/src/core/Synapse.Core.Infrastructure/Synapse.Core.Infrastructure.csproj
@@ -7,7 +7,7 @@
en
True
1.0.0
- alpha5.12
+
$(VersionPrefix)
$(VersionPrefix)
The Synapse Authors
@@ -44,14 +44,14 @@
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
diff --git a/src/core/Synapse.Core/Synapse.Core.csproj b/src/core/Synapse.Core/Synapse.Core.csproj
index a2405cc8..c4f8f688 100644
--- a/src/core/Synapse.Core/Synapse.Core.csproj
+++ b/src/core/Synapse.Core/Synapse.Core.csproj
@@ -7,7 +7,7 @@
en
True
1.0.0
- alpha5.12
+
$(VersionPrefix)
$(VersionPrefix)
The Synapse Authors
@@ -66,11 +66,11 @@
-
-
-
+
+
+
-
+
diff --git a/src/correlator/Synapse.Correlator/Synapse.Correlator.csproj b/src/correlator/Synapse.Correlator/Synapse.Correlator.csproj
index 3c1628e3..cb836a2a 100644
--- a/src/correlator/Synapse.Correlator/Synapse.Correlator.csproj
+++ b/src/correlator/Synapse.Correlator/Synapse.Correlator.csproj
@@ -8,7 +8,7 @@
en
True
1.0.0
- alpha5.12
+
$(VersionPrefix)
$(VersionPrefix)
The Synapse Authors
@@ -36,12 +36,12 @@
-
-
-
-
-
-
+
+
+
+
+
+
diff --git a/src/dashboard/Synapse.Dashboard/Synapse.Dashboard.csproj b/src/dashboard/Synapse.Dashboard/Synapse.Dashboard.csproj
index 4559655e..7a35323b 100644
--- a/src/dashboard/Synapse.Dashboard/Synapse.Dashboard.csproj
+++ b/src/dashboard/Synapse.Dashboard/Synapse.Dashboard.csproj
@@ -10,14 +10,14 @@
-
+
-
+
diff --git a/src/operator/Synapse.Operator/Synapse.Operator.csproj b/src/operator/Synapse.Operator/Synapse.Operator.csproj
index d072a885..e4290357 100644
--- a/src/operator/Synapse.Operator/Synapse.Operator.csproj
+++ b/src/operator/Synapse.Operator/Synapse.Operator.csproj
@@ -8,7 +8,7 @@
en
True
1.0.0
- alpha5.12
+
$(VersionPrefix)
$(VersionPrefix)
The Synapse Authors
diff --git a/src/runner/Synapse.Runner/Services/ConnectedWorkflowExecutionContext.cs b/src/runner/Synapse.Runner/Services/ConnectedWorkflowExecutionContext.cs
index cb4ccfb0..6f79b5ef 100644
--- a/src/runner/Synapse.Runner/Services/ConnectedWorkflowExecutionContext.cs
+++ b/src/runner/Synapse.Runner/Services/ConnectedWorkflowExecutionContext.cs
@@ -424,7 +424,7 @@ public virtual async Task CorrelateAsync(ITaskExecutionConte
{
ArgumentNullException.ThrowIfNull(task);
if (task.Definition is not ListenTaskDefinition listenTask) throw new ArgumentException("The specified task's definition must be a 'listen' task", nameof(task));
- if (listenTask.Foreach == null) throw new ArgumentException($"Since the specified listen task uses streaming, the {nameof(StreamAsync)} method must be used instead");
+ if (listenTask.Foreach != null) throw new ArgumentException($"Since the specified listen task uses streaming, the {nameof(StreamAsync)} method must be used instead");
if (this.Instance.Status?.Correlation?.Contexts?.TryGetValue(task.Instance.Reference.OriginalString, out var context) == true && context != null) return context;
var @namespace = task.Workflow.Instance.GetNamespace()!;
var name = $"{task.Workflow.Instance.GetName()}.{task.Instance.Id}";
diff --git a/src/runner/Synapse.Runner/Services/Executors/ListenTaskExecutor.cs b/src/runner/Synapse.Runner/Services/Executors/ListenTaskExecutor.cs
index 90231273..3057ae38 100644
--- a/src/runner/Synapse.Runner/Services/Executors/ListenTaskExecutor.cs
+++ b/src/runner/Synapse.Runner/Services/Executors/ListenTaskExecutor.cs
@@ -64,8 +64,8 @@ protected override async Task DoExecuteAsync(CancellationToken cancellationToken
var context = await this.Task.CorrelateAsync(cancellationToken).ConfigureAwait(false);
var events = this.Task.Definition.Listen.Read switch
{
- EventReadMode.Data or EventReadMode.Raw => context.Events.Select(e => e.Value.Data),
- EventReadMode.Envelope => context.Events.Select(e => e.Value.Data),
+ EventReadMode.Data or EventReadMode.Raw or null => context.Events.Select(e => e.Value.Data),
+ EventReadMode.Envelope => context.Events.Select(e => e.Value),
_ => throw new NotSupportedException($"The specified event read mode '{this.Task.Definition.Listen.Read}' is not supported")
};
await this.SetResultAsync(events, this.Task.Definition.Then, cancellationToken).ConfigureAwait(false);
@@ -115,7 +115,7 @@ protected virtual async Task OnStreamingEventAsync(IStreamedCloudEvent e)
var arguments = this.GetExpressionEvaluationArguments();
var eventData = this.Task.Definition.Listen.Read switch
{
- EventReadMode.Data or EventReadMode.Raw => e.Event.Data,
+ EventReadMode.Data or EventReadMode.Raw or null => e.Event.Data,
EventReadMode.Envelope => e.Event,
_ => throw new NotSupportedException($"The specified event read mode '{this.Task.Definition.Listen.Read}' is not supported")
};
diff --git a/src/runner/Synapse.Runner/Synapse.Runner.csproj b/src/runner/Synapse.Runner/Synapse.Runner.csproj
index fa42a182..e076a3de 100644
--- a/src/runner/Synapse.Runner/Synapse.Runner.csproj
+++ b/src/runner/Synapse.Runner/Synapse.Runner.csproj
@@ -8,7 +8,7 @@
en
True
1.0.0
- alpha5.12
+
$(VersionPrefix)
$(VersionPrefix)
The Synapse Authors
@@ -59,15 +59,15 @@
-
+
-
-
-
-
-
+
+
+
+
+
diff --git a/src/runtime/Synapse.Runtime.Abstractions/Synapse.Runtime.Abstractions.csproj b/src/runtime/Synapse.Runtime.Abstractions/Synapse.Runtime.Abstractions.csproj
index ff6dcb96..8cdc67a3 100644
--- a/src/runtime/Synapse.Runtime.Abstractions/Synapse.Runtime.Abstractions.csproj
+++ b/src/runtime/Synapse.Runtime.Abstractions/Synapse.Runtime.Abstractions.csproj
@@ -7,7 +7,7 @@
en
True
1.0.0
- alpha5.12
+
$(VersionPrefix)
$(VersionPrefix)
The Synapse Authors
diff --git a/src/runtime/Synapse.Runtime.Docker/Synapse.Runtime.Docker.csproj b/src/runtime/Synapse.Runtime.Docker/Synapse.Runtime.Docker.csproj
index 483e7fae..aa3669ed 100644
--- a/src/runtime/Synapse.Runtime.Docker/Synapse.Runtime.Docker.csproj
+++ b/src/runtime/Synapse.Runtime.Docker/Synapse.Runtime.Docker.csproj
@@ -7,7 +7,7 @@
en
True
1.0.0
- alpha5.12
+
$(VersionPrefix)
$(VersionPrefix)
The Synapse Authors
diff --git a/src/runtime/Synapse.Runtime.Kubernetes/Synapse.Runtime.Kubernetes.csproj b/src/runtime/Synapse.Runtime.Kubernetes/Synapse.Runtime.Kubernetes.csproj
index 038a9519..933b081e 100644
--- a/src/runtime/Synapse.Runtime.Kubernetes/Synapse.Runtime.Kubernetes.csproj
+++ b/src/runtime/Synapse.Runtime.Kubernetes/Synapse.Runtime.Kubernetes.csproj
@@ -7,7 +7,7 @@
en
True
1.0.0
- alpha5.12
+
$(VersionPrefix)
$(VersionPrefix)
The Synapse Authors
diff --git a/src/runtime/Synapse.Runtime.Native/Synapse.Runtime.Native.csproj b/src/runtime/Synapse.Runtime.Native/Synapse.Runtime.Native.csproj
index 59922664..a79161d7 100644
--- a/src/runtime/Synapse.Runtime.Native/Synapse.Runtime.Native.csproj
+++ b/src/runtime/Synapse.Runtime.Native/Synapse.Runtime.Native.csproj
@@ -7,7 +7,7 @@
en
True
1.0.0
- alpha5.12
+
$(VersionPrefix)
$(VersionPrefix)
The Synapse Authors
diff --git a/tests/Synapse.IntegrationTests/Synapse.IntegrationTests.csproj b/tests/Synapse.IntegrationTests/Synapse.IntegrationTests.csproj
index 8d28aa01..f2805b3f 100644
--- a/tests/Synapse.IntegrationTests/Synapse.IntegrationTests.csproj
+++ b/tests/Synapse.IntegrationTests/Synapse.IntegrationTests.csproj
@@ -10,14 +10,14 @@
-
+
all
runtime; build; native; contentfiles; analyzers; buildtransitive
-
+
-
+
diff --git a/tests/Synapse.UnitTests/Synapse.UnitTests.csproj b/tests/Synapse.UnitTests/Synapse.UnitTests.csproj
index 33ad199e..c4c87fc2 100644
--- a/tests/Synapse.UnitTests/Synapse.UnitTests.csproj
+++ b/tests/Synapse.UnitTests/Synapse.UnitTests.csproj
@@ -10,20 +10,20 @@
-
+
all
runtime; build; native; contentfiles; analyzers; buildtransitive
-
+
-
-
-
-
-
+
+
+
+
+