feat: signals

Author: BL19

src/Spindle.Abstractions/Flows/IFlowContext.cs

@@ -41,9 +41,9 @@ ValueTask DelayUntil(
         DateTimeOffset dueAt,
         CancellationToken cancellationToken = default);
 
-    ValueTask<TSignal> WaitForSignal<TSignal>(
+    ValueTask<TSignal?> WaitForSignal<TSignal>(
         SignalName signalName,
-        CorrelationKey? correlationKey = null,
+        CorrelationKey correlationKey,
         SignalWaitOptions? options = null,
         CancellationToken cancellationToken = default);
 }

src/Spindle.Abstractions/Flows/ISpindleRuntime.cs

@@ -86,6 +86,7 @@ ValueTask<TResult> RunAsync<TRequest, TResult>(
     ValueTask SignalAsync<TSignal>(
         FlowInstanceId instanceId,
         SignalName signalName,
+        CorrelationKey correlationKey,
         TSignal payload,
         CancellationToken cancellationToken = default);
 
@@ -95,6 +96,17 @@ ValueTask SignalAsync<TSignal>(
         TSignal payload,
         CancellationToken cancellationToken = default);
 
+    ValueTask SignalAsync(
+        FlowInstanceId instanceId,
+        SignalName signalName,
+        CorrelationKey correlationKey,
+        CancellationToken cancellationToken = default);
+
+    ValueTask SignalAsync(
+        SignalName signalName,
+        CorrelationKey correlationKey,
+        CancellationToken cancellationToken = default);
+
     ValueTask CancelAsync(
         FlowInstanceId instanceId,
         string? reason = null,

src/Spindle.Persistence.Abstractions/Signals/SignalRecord.cs

@@ -11,7 +11,7 @@ public sealed record SignalRecord
 
     public FlowInstanceId? FlowInstanceId { get; init; }
 
-    public required SerializedPayload Payload { get; init; }
+    public required SerializedPayload? Payload { get; init; }
 
     public required DateTimeOffset RaisedAt { get; init; }
 }

src/Spindle.Persistence.Abstractions/Signals/SignalWaitRecord.cs

@@ -10,7 +10,7 @@ public sealed record SignalWaitRecord
 
     public required SignalName SignalName { get; init; }
 
-    public CorrelationKey? CorrelationKey { get; init; }
+    public CorrelationKey CorrelationKey { get; init; }
 
     public required DateTimeOffset CreatedAt { get; init; }