RuntimeJournalReopenTests.cs

namespace KeyLoad.UnitTests.Features.ClusterRouting;

internal sealed class RuntimeJournalReopenTests
{
    private const string JournalName = "reopen-journal";
    private const string Instance = "55667788-99aa-bbcc-ddee-ff0011223344";

    [Test]
    public async Task CommittedNativeHeaderAndOpaqueChunksSurviveStoreReopen()
    {
        using var fixture = new RuntimeJournalReopenFixture();
        await Assert.That(fixture.MinimumReaderContract).IsEqualTo(KeyLoad.Storage.StoreReaderContract.RuntimeJournal);
        var create = new RuntimeJournalMutation(RuntimeJournalAction.Create, JournalName, Guid.Parse(Instance), 0, 0,
            null, ReadOnlyMemory<byte>.Empty, new(StringComparer.Ordinal), []);
        var header = fixture.Submit(create).Snapshot!;
        var expected = Enumerable.Range(0, 90_000).Select(index => (byte)(index % byte.MaxValue)).ToArray();
        header = fixture.Submit(RuntimeJournalFixture.Mutation(RuntimeJournalAction.Append, header, expected)).Snapshot!;

        fixture.Reopen();
        await Assert.That(fixture.MinimumReaderContract).IsEqualTo(KeyLoad.Storage.StoreReaderContract.RuntimeJournal);
        var recovered = fixture.Database.GetRuntimeJournalHeader(RuntimeJournalFixture.JournalPrincipal, JournalName)!;
        var actual = new List<byte>();
        var offset = 0L;
        var complete = false;
        while (!complete)
        {
            var page = fixture.Database.ReadRuntimeJournal(RuntimeJournalFixture.JournalPrincipal,
                new(JournalName, recovered.InstanceId, recovered.OwnerGeneration, recovered.ContentRevision, offset));
            actual.AddRange(page.Data.ToArray());
            offset += page.Data.Length;
            complete = page.IsCompleted;
        }
        await Assert.That(actual).IsEquivalentTo(expected);
        await Assert.That(recovered.ContentRevision).IsEqualTo(1L);
        var deleted = fixture.Submit(RuntimeJournalFixture.Mutation(RuntimeJournalAction.Delete, recovered));
        await Assert.That(deleted.Applied).IsTrue();
    }
}