register-referentie/services/domain/Big.Tests/WerkbakTests.cs

using Big.Application;
using Big.Domain;

namespace Big.Tests;

/// <summary>
/// The werkbak query (S-12c): the behandelaar's list of registrations awaiting beoordeling. It reads
/// the open Beoordelen tasks from the workflow engine (§8.2) and enriches each with its registration
/// (bsn + status) from the store. A task whose registration is unknown is skipped defensively.
/// </summary>
public class WerkbakTests
{
    [Fact]
    public async Task Lists_an_item_per_open_beoordeling_enriched_from_the_registration()
    {
        var store = new FakeRegistrationStore();
        var registration = Registration.Submit("123456782");
        registration.AttachZaak(FakeAclClient.DefaultZaakUrl);
        registration.TakeIntoBehandeling();
        store.Seed(registration);
        var tasks = new FakeUserTaskClient([new BeoordelingTask("task-1", "exec-1", registration.Id)]);
        var werkbak = new Werkbak(tasks, store);

        var items = await werkbak.GetAsync();

        var item = Assert.Single(items);
        Assert.Equal(registration.Id.ToString(), item.RegistrationId);
        Assert.Equal("123456782", item.Bsn);
        Assert.Equal("InBehandeling", item.Status);
    }

    [Fact]
    public async Task Is_empty_when_no_beoordelingen_are_open()
    {
        var werkbak = new Werkbak(new FakeUserTaskClient([]), new FakeRegistrationStore());

        Assert.Empty(await werkbak.GetAsync());
    }

    [Fact]
    public async Task Skips_a_task_whose_registration_is_unknown()
    {
        // Defensive: the werkbak never invents an item for a task the domain has no aggregate for.
        var tasks = new FakeUserTaskClient([new BeoordelingTask("task-1", "exec-1", RegistrationId.New())]);
        var werkbak = new Werkbak(tasks, new FakeRegistrationStore());

        Assert.Empty(await werkbak.GetAsync());
    }

    [Fact]
    public async Task Skips_a_task_whose_registration_is_no_longer_open()
    {
        // A withdrawn registration (S-11) may still have a Beoordelen task lingering until the workflow
        // cancels it; the werkbak lists only registrations still open for beoordeling, so it drops off.
        var store = new FakeRegistrationStore();
        var registration = Registration.Submit("123456782");
        registration.Withdraw();
        store.Seed(registration);
        var tasks = new FakeUserTaskClient([new BeoordelingTask("task-1", "exec-1", registration.Id)]);
        var werkbak = new Werkbak(tasks, store);

        Assert.Empty(await werkbak.GetAsync());
    }
}