| | | 1 | | using System.Collections.Concurrent; |
| | | 2 | | using AsiBackbone.Core.Audit; |
| | | 3 | | |
| | | 4 | | namespace AsiBackbone.Storage.InMemory.Audit; |
| | | 5 | | |
| | | 6 | | /// <summary> |
| | | 7 | | /// In-memory decision receipt lifecycle store for tests, samples, and development hosts. |
| | | 8 | | /// </summary> |
| | | 9 | | /// <remarks> |
| | | 10 | | /// This store is not durable across process restarts. Production hosts should use a durable provider such as EF Core or |
| | | 11 | | /// </remarks> |
| | | 12 | | public sealed class InMemoryDecisionReceiptLifecycleStore : IDecisionReceiptLifecycleStore |
| | | 13 | | { |
| | 24 | 14 | | private readonly ConcurrentDictionary<string, DecisionReceiptLifecycleEvent> events = new(StringComparer.Ordinal); |
| | | 15 | | |
| | | 16 | | /// <inheritdoc /> |
| | | 17 | | public ValueTask<DecisionReceiptLifecycleEvent> AppendAsync( |
| | | 18 | | DecisionReceiptLifecycleEvent lifecycleEvent, |
| | | 19 | | CancellationToken cancellationToken = default) |
| | | 20 | | { |
| | 18 | 21 | | ArgumentNullException.ThrowIfNull(lifecycleEvent); |
| | 17 | 22 | | cancellationToken.ThrowIfCancellationRequested(); |
| | | 23 | | |
| | 16 | 24 | | return !events.TryAdd(lifecycleEvent.EventId, lifecycleEvent) |
| | 16 | 25 | | ? throw new InvalidOperationException($"Lifecycle event '{lifecycleEvent.EventId}' already exists.") |
| | 16 | 26 | | : ValueTask.FromResult(lifecycleEvent); |
| | | 27 | | } |
| | | 28 | | |
| | | 29 | | /// <inheritdoc /> |
| | | 30 | | public ValueTask<DecisionReceiptLifecycleEvent?> FindByEventIdAsync( |
| | | 31 | | string eventId, |
| | | 32 | | CancellationToken cancellationToken = default) |
| | | 33 | | { |
| | 18 | 34 | | ArgumentException.ThrowIfNullOrWhiteSpace(eventId); |
| | 17 | 35 | | cancellationToken.ThrowIfCancellationRequested(); |
| | | 36 | | |
| | 16 | 37 | | _ = events.TryGetValue(eventId.Trim(), out DecisionReceiptLifecycleEvent? lifecycleEvent); |
| | | 38 | | |
| | 16 | 39 | | return ValueTask.FromResult(lifecycleEvent); |
| | | 40 | | } |
| | | 41 | | |
| | | 42 | | /// <inheritdoc /> |
| | | 43 | | public ValueTask<IReadOnlyList<DecisionReceiptLifecycleEvent>> FindByCorrelationIdAsync( |
| | | 44 | | string correlationId, |
| | | 45 | | CancellationToken cancellationToken = default) |
| | | 46 | | { |
| | 4 | 47 | | ArgumentException.ThrowIfNullOrWhiteSpace(correlationId); |
| | 3 | 48 | | cancellationToken.ThrowIfCancellationRequested(); |
| | | 49 | | |
| | 2 | 50 | | string normalizedCorrelationId = correlationId.Trim(); |
| | | 51 | | |
| | 2 | 52 | | IReadOnlyList<DecisionReceiptLifecycleEvent> matches = [.. events.Values |
| | 2 | 53 | | .Where(lifecycleEvent => string.Equals(lifecycleEvent.CorrelationId, normalizedCorrelationId, StringComparis |
| | 2 | 54 | | .OrderBy(lifecycleEvent => lifecycleEvent.OccurredUtc) |
| | 2 | 55 | | .ThenBy(lifecycleEvent => lifecycleEvent.EventId)]; |
| | | 56 | | |
| | 2 | 57 | | return ValueTask.FromResult(matches); |
| | | 58 | | } |
| | | 59 | | |
| | | 60 | | /// <inheritdoc /> |
| | | 61 | | public ValueTask<IReadOnlyList<DecisionReceiptLifecycleEvent>> FindByDecisionReceiptIdAsync( |
| | | 62 | | string decisionReceiptId, |
| | | 63 | | CancellationToken cancellationToken = default) |
| | | 64 | | { |
| | 4 | 65 | | ArgumentException.ThrowIfNullOrWhiteSpace(decisionReceiptId); |
| | 3 | 66 | | cancellationToken.ThrowIfCancellationRequested(); |
| | | 67 | | |
| | 2 | 68 | | string normalizedDecisionReceiptId = decisionReceiptId.Trim(); |
| | | 69 | | |
| | 2 | 70 | | IReadOnlyList<DecisionReceiptLifecycleEvent> matches = [.. events.Values |
| | 2 | 71 | | .Where(lifecycleEvent => string.Equals(lifecycleEvent.DecisionReceiptId, normalizedDecisionReceiptId, String |
| | 2 | 72 | | .OrderBy(lifecycleEvent => lifecycleEvent.OccurredUtc) |
| | 2 | 73 | | .ThenBy(lifecycleEvent => lifecycleEvent.EventId)]; |
| | | 74 | | |
| | 2 | 75 | | return ValueTask.FromResult(matches); |
| | | 76 | | } |
| | | 77 | | } |