Niek Otten
566fc9bcea
On each notification the subscriber reads the zaak's reference (identificatie) through the ACL — the only code allowed to talk to ZGW (§8.1) — and persists it on the register_projection row and in the processed_notifications replay log. Storing it in the log keeps rebuild log-only (ADR-0008): no ACL/ZGW access on rebuild. Co-Authored-By: Claude Opus 4.8 (1M context) <noreply@anthropic.com>
49 lines
1.9 KiB
C#
49 lines
1.9 KiB
C#
using EventSubscriber.Application;
|
|
|
|
namespace Acceptance.Support;
|
|
|
|
/// <summary>In-memory stand-ins for the Event Subscriber's projection store and notification
|
|
/// log, so the S-06 acceptance scenario runs without Postgres (real delivery is a live-stack
|
|
/// check). Mirrors the <c>InMemoryZaakGateway</c> approach used for the ACL scenario.</summary>
|
|
public sealed class InMemoryNotificationLog : INotificationLog
|
|
{
|
|
private readonly Dictionary<string, RecordedNotification> _byKey = [];
|
|
|
|
public Task<bool> TryRecordAsync(RecordedNotification notification, CancellationToken ct = default)
|
|
=> Task.FromResult(_byKey.TryAdd(notification.Key, notification));
|
|
|
|
public Task<IReadOnlyList<RecordedNotification>> AllAsync(CancellationToken ct = default)
|
|
=> Task.FromResult<IReadOnlyList<RecordedNotification>>([.. _byKey.Values]);
|
|
}
|
|
|
|
public sealed class InMemoryProjectionStore : IProjectionStore
|
|
{
|
|
private readonly Dictionary<string, RegisterEntry> _byId = [];
|
|
|
|
public Task UpsertAsync(RegisterEntry entry, CancellationToken ct = default)
|
|
{
|
|
_byId[entry.Id] = entry;
|
|
return Task.CompletedTask;
|
|
}
|
|
|
|
public Task ClearAsync(CancellationToken ct = default)
|
|
{
|
|
_byId.Clear();
|
|
return Task.CompletedTask;
|
|
}
|
|
|
|
public Task<IReadOnlyList<RegisterEntry>> AllAsync(CancellationToken ct = default)
|
|
=> Task.FromResult<IReadOnlyList<RegisterEntry>>([.. _byId.Values]);
|
|
|
|
public IReadOnlyList<RegisterEntry> RowsFor(string id)
|
|
=> [.. _byId.Values.Where(e => e.Id == id)];
|
|
}
|
|
|
|
/// <summary>A fake ACL client for the projection acceptance scenario: returns a reference derived
|
|
/// from the zaak, so the projector can enrich rows without a running ACL (#78).</summary>
|
|
public sealed class InMemoryAclReferenceClient : IAclClient
|
|
{
|
|
public Task<string> GetZaakReferenceAsync(Uri zaakUrl, CancellationToken ct = default)
|
|
=> Task.FromResult("REG-" + zaakUrl.Segments[^1].Trim('/'));
|
|
}
|