AI-Studio/app/Tests/Tools/Databases/ProvenanceStoreTests.cs

using AIStudio.Tools.Databases.ProvenanceStore;

using Microsoft.Data.Sqlite;
using Microsoft.EntityFrameworkCore;

namespace AIStudio.Tests.Tools.Databases;

/// <summary>
/// Checks the store of what chats received besides their messages.
/// </summary>
/// <remarks>
/// A chat refers to its entries by id only, so an entry has to come back exactly as it was stored,
/// and has to go with its chat, but never with another one.
/// </remarks>
[TestFixture]
public sealed class ProvenanceStoreTests
{
    private static readonly CancellationToken TOKEN = CancellationToken.None;

    [Test]
    public void TheModelSnapshotMatchesTheModel()
    {
        SQLitePCL.Batteries_V2.Init();
        using var context = new ProvenanceStoreDbContext(ProvenanceStoreDbContext.CreateOptions(Path.Combine(Path.GetTempPath(), "ai-studio-never-opened-provenance.sqlite3")));

        Assert.That(context.Database.HasPendingModelChanges(), Is.False, "EF Core refuses to migrate while the snapshot and the model disagree, and the app would start without its provenance store.");
    }

    [Test]
    public async Task AnEntryComesBackAsItWasStored()
    {
        await using var store = await TemporaryProvenanceStore.CreateAsync();
        var chatId = Guid.NewGuid();
        var before = DateTimeOffset.UtcNow.AddSeconds(-1);

        var id = await store.Client.StoreAsync(chatId, ProvenanceKind.DATA_SOURCE_PASSAGE, "The budget grew by 4 %.\nÄnderungen folgen.", ["Before the passage.", "After the passage."], TOKEN);
        var entries = await store.Client.GetEntriesAsync([id!.Value], TOKEN);

        Assert.That(entries, Contains.Key(id.Value));
        var entry = entries[id.Value];
        using (Assert.EnterMultipleScope())
        {
            Assert.That(entry.Id, Is.EqualTo(id.Value));
            Assert.That(entry.Kind, Is.EqualTo(ProvenanceKind.DATA_SOURCE_PASSAGE));
            Assert.That(entry.Content, Is.EqualTo("The budget grew by 4 %.\nÄnderungen folgen."));
            Assert.That(entry.SurroundingContent, Is.EqualTo(new[] { "Before the passage.", "After the passage." }));
            Assert.That(entry.CreatedAtUtc, Is.GreaterThan(before));
        }
    }

    [Test]
    public async Task AnEntryWithoutSurroundingContentStoresNone()
    {
        await using var store = await TemporaryProvenanceStore.CreateAsync();

        var withNull = await store.Client.StoreAsync(Guid.NewGuid(), ProvenanceKind.ATTACHMENT, "file content", null, TOKEN);
        var withEmpty = await store.Client.StoreAsync(Guid.NewGuid(), ProvenanceKind.WEB_PAGE, "page content", [], TOKEN);
        var entries = await store.Client.GetEntriesAsync([withNull!.Value, withEmpty!.Value], TOKEN);

        await using var context = store.CreateContext();
        var rowsWithSurroundingContent = await context.Entries.CountAsync(entry => entry.SurroundingContent != null);
        using (Assert.EnterMultipleScope())
        {
            Assert.That(entries[withNull.Value].SurroundingContent, Is.Empty);
            Assert.That(entries[withEmpty.Value].SurroundingContent, Is.Empty);
            Assert.That(rowsWithSurroundingContent, Is.Zero, "Only an ERI passage brings content around it, so every other row keeps the column empty.");
        }
    }

    [Test]
    public async Task EveryStoredItemGetsARowOfItsOwn()
    {
        await using var store = await TemporaryProvenanceStore.CreateAsync();
        var chatId = Guid.NewGuid();

        var first = await store.Client.StoreAsync(chatId, ProvenanceKind.WEB_PAGE, "the same page", null, TOKEN);
        var second = await store.Client.StoreAsync(chatId, ProvenanceKind.WEB_PAGE, "the same page", null, TOKEN);

        Assert.That(second, Is.Not.EqualTo(first), "One row per item: two calls which read the same page are two items.");
    }

    [Test]
    public async Task AnUnknownIdIsMissingFromTheAnswer()
    {
        await using var store = await TemporaryProvenanceStore.CreateAsync();
        var known = await store.Client.StoreAsync(Guid.NewGuid(), ProvenanceKind.WEB_PAGE, "A page.", null, TOKEN);

        var entries = await store.Client.GetEntriesAsync([known!.Value, Guid.NewGuid()], TOKEN);

        Assert.That(entries.Keys, Is.EquivalentTo(new[] { known.Value }));
    }

    [Test]
    public async Task NoIdsReadNothing()
    {
        await using var store = await TemporaryProvenanceStore.CreateAsync();

        Assert.That(await store.Client.GetEntriesAsync([], TOKEN), Is.Empty);
    }

    [Test]
    public async Task ACopyKeepsTheIdsAndOutlivesItsOrigin()
    {
        await using var store = await TemporaryProvenanceStore.CreateAsync();
        var assistantChat = Guid.NewGuid();
        var chat = Guid.NewGuid();
        var passage = await store.Client.StoreAsync(assistantChat, ProvenanceKind.DATA_SOURCE_PASSAGE, "a passage", null, TOKEN);
        var page = await store.Client.StoreAsync(assistantChat, ProvenanceKind.WEB_PAGE, "a page", null, TOKEN);

        await store.Client.CopyChatAsync(assistantChat, chat, TOKEN);
        await store.Client.DeleteChatsAsync([assistantChat], TOKEN);
        var entries = await store.Client.GetEntriesAsync([passage!.Value, page!.Value], TOKEN);

        using (Assert.EnterMultipleScope())
        {
            Assert.That(entries[passage.Value].Content, Is.EqualTo("a passage"));
            Assert.That(entries[page.Value].Content, Is.EqualTo("a page"));
        }
    }

    [Test]
    public async Task CopyingTwiceLeavesOneCopy()
    {
        await using var store = await TemporaryProvenanceStore.CreateAsync();
        var source = Guid.NewGuid();
        var target = Guid.NewGuid();
        await store.Client.StoreAsync(source, ProvenanceKind.MAIL, "a mail", null, TOKEN);

        await store.Client.CopyChatAsync(source, target, TOKEN);
        await store.Client.CopyChatAsync(source, target, TOKEN);

        await using var context = store.CreateContext();
        Assert.That(await context.Entries.CountAsync(entry => entry.ChatId == target.ToString("D")), Is.EqualTo(1));
    }

    [Test]
    public async Task DeletingAChatLeavesTheOthersAlone()
    {
        await using var store = await TemporaryProvenanceStore.CreateAsync();
        var deletedChat = Guid.NewGuid();
        var keptChat = Guid.NewGuid();
        var deleted = await store.Client.StoreAsync(deletedChat, ProvenanceKind.ATTACHMENT, "deleted", null, TOKEN);
        var kept = await store.Client.StoreAsync(keptChat, ProvenanceKind.ATTACHMENT, "kept", null, TOKEN);

        await store.Client.DeleteChatsAsync([deletedChat], TOKEN);
        var entries = await store.Client.GetEntriesAsync([deleted!.Value, kept!.Value], TOKEN);
        var chatIds = await store.Client.GetChatIdsAsync(TOKEN);

        using (Assert.EnterMultipleScope())
        {
            Assert.That(entries.Keys, Is.EquivalentTo(new[] { kept.Value }));
            Assert.That(chatIds, Is.EquivalentTo(new[] { keptChat }));
        }
    }

    [Test]
    public async Task SeveralChatsGoInOneCall()
    {
        await using var store = await TemporaryProvenanceStore.CreateAsync();
        var firstChat = Guid.NewGuid();
        var secondChat = Guid.NewGuid();
        var keptChat = Guid.NewGuid();
        await store.Client.StoreAsync(firstChat, ProvenanceKind.ATTACHMENT, "first", null, TOKEN);
        await store.Client.StoreAsync(secondChat, ProvenanceKind.WEB_PAGE, "second", null, TOKEN);
        await store.Client.StoreAsync(secondChat, ProvenanceKind.MAIL, "second, again", null, TOKEN);
        await store.Client.StoreAsync(keptChat, ProvenanceKind.ATTACHMENT, "kept", null, TOKEN);

        var deleted = await store.Client.DeleteChatsAsync([firstChat, secondChat], TOKEN);
        var chatIds = await store.Client.GetChatIdsAsync(TOKEN);

        using (Assert.EnterMultipleScope())
        {
            Assert.That(deleted, Is.EqualTo(3));
            Assert.That(chatIds, Is.EquivalentTo(new[] { keptChat }));
        }
    }

    [Test]
    public async Task ADeletedTextLeavesNothingInTheFile()
    {
        await using var store = await TemporaryProvenanceStore.CreateAsync();
        var chat = Guid.NewGuid();
        const string MARKER = "confidential-minutes-of-the-board-7f3a";
        await store.Client.StoreAsync(chat, ProvenanceKind.ATTACHMENT, $"{MARKER} The board met on Monday.", null, TOKEN);

        await store.Client.DeleteChatsAsync([chat], TOKEN);

        // Moves everything from the write-ahead log into the file and empties the log, so the file is all there is to read:
        await using (var context = store.CreateContext())
            await context.Database.ExecuteSqlRawAsync("PRAGMA wal_checkpoint(TRUNCATE);", TOKEN);

        SqliteConnection.ClearAllPools();
        var fileContent = System.Text.Encoding.UTF8.GetString(await File.ReadAllBytesAsync(store.DatabasePath, TOKEN));

        Assert.That(fileContent.Contains(MARKER, StringComparison.Ordinal), Is.False, "Deleting a chat has to remove its text from the file, not only mark its pages as free.");
    }

    [Test]
    public async Task AChatWithoutAnIdIsListedToo()
    {
        await using var store = await TemporaryProvenanceStore.CreateAsync();
        await store.Client.StoreAsync(Guid.Empty, ProvenanceKind.WEB_PAGE, "of a conversation without an id", null, TOKEN);

        var chatIds = await store.Client.GetChatIdsAsync(TOKEN);

        Assert.That(chatIds, Is.EquivalentTo(new[] { Guid.Empty }), "Only a listed chat is cleaned up.");
    }

    [Test]
    public async Task DeletingTheUnreferencedEntriesOfAChatKeepsTheReferencedOnes()
    {
        await using var store = await TemporaryProvenanceStore.CreateAsync();
        var chat = Guid.NewGuid();
        var otherChat = Guid.NewGuid();
        var referenced = await store.Client.StoreAsync(chat, ProvenanceKind.DATA_SOURCE_PASSAGE, "still in the chat", null, TOKEN);
        var removed = await store.Client.StoreAsync(chat, ProvenanceKind.DATA_SOURCE_PASSAGE, "of a deleted message", null, TOKEN);
        var otherChatsEntry = await store.Client.StoreAsync(otherChat, ProvenanceKind.DATA_SOURCE_PASSAGE, "of another chat", null, TOKEN);

        await store.Client.DeleteChatEntriesExceptAsync(chat, [referenced!.Value], TOKEN);
        var entries = await store.Client.GetEntriesAsync([referenced.Value, removed!.Value, otherChatsEntry!.Value], TOKEN);

        Assert.That(entries.Keys, Is.EquivalentTo(new[] { referenced.Value, otherChatsEntry.Value }));
    }

    [Test]
    public async Task DeletingSomeEntriesOfAChatKeepsTheRest()
    {
        await using var store = await TemporaryProvenanceStore.CreateAsync();
        var chat = Guid.NewGuid();
        var copy = Guid.NewGuid();
        var sent = await store.Client.StoreAsync(chat, ProvenanceKind.ATTACHMENT, "sent with the message", null, TOKEN);
        var unsent = await store.Client.StoreAsync(chat, ProvenanceKind.ATTACHMENT, "previewed, then removed", null, TOKEN);
        await store.Client.CopyChatAsync(chat, copy, TOKEN);

        var deleted = await store.Client.DeleteEntriesAsync(chat, [unsent!.Value], TOKEN);
        var entries = await store.Client.GetEntriesAsync([sent!.Value, unsent.Value], TOKEN);
        await store.Client.DeleteChatsAsync([copy], TOKEN);
        var entriesWithoutTheCopy = await store.Client.GetEntriesAsync([sent.Value, unsent.Value], TOKEN);

        using (Assert.EnterMultipleScope())
        {
            Assert.That(deleted, Is.EqualTo(1), "Only the entry of the chat goes, not the one of its copy, which keeps the same id.");
            Assert.That(entries.Keys, Is.EquivalentTo(new[] { sent.Value, unsent.Value }), "The copy still holds the entry.");
            Assert.That(entriesWithoutTheCopy.Keys, Is.EquivalentTo(new[] { sent.Value }));
        }
    }

    [Test]
    public async Task DeletingUpToAMomentKeepsWhatCameAfter()
    {
        await using var store = await TemporaryProvenanceStore.CreateAsync();
        var chat = Guid.NewGuid();
        var entry = await store.Client.StoreAsync(chat, ProvenanceKind.ATTACHMENT, "stored just now", null, TOKEN);

        var deletedBefore = await store.Client.DeleteChatsAsync([chat], TOKEN, DateTimeOffset.UtcNow.AddMinutes(-1));
        var deletedExceptBefore = await store.Client.DeleteChatEntriesExceptAsync(chat, [], TOKEN, DateTimeOffset.UtcNow.AddMinutes(-1));
        var kept = await store.Client.GetEntriesAsync([entry!.Value], TOKEN);
        var deletedAfter = await store.Client.DeleteChatsAsync([chat], TOKEN, DateTimeOffset.UtcNow.AddMinutes(1));

        using (Assert.EnterMultipleScope())
        {
            Assert.That(deletedBefore, Is.Zero);
            Assert.That(deletedExceptBefore, Is.Zero);
            Assert.That(kept.Keys, Is.EquivalentTo(new[] { entry.Value }), "The time is compared as stored text, which has to keep the order of time.");
            Assert.That(deletedAfter, Is.EqualTo(1));
        }
    }

    [Test]
    public async Task TheChatsWithEntriesAreListedOnce()
    {
        await using var store = await TemporaryProvenanceStore.CreateAsync();
        var firstChat = Guid.NewGuid();
        var secondChat = Guid.NewGuid();
        await store.Client.StoreAsync(firstChat, ProvenanceKind.ATTACHMENT, "one", null, TOKEN);
        await store.Client.StoreAsync(firstChat, ProvenanceKind.WEB_PAGE, "two", null, TOKEN);
        await store.Client.StoreAsync(secondChat, ProvenanceKind.MAIL, "three", null, TOKEN);

        Assert.That(await store.Client.GetChatIdsAsync(TOKEN), Is.EquivalentTo(new[] { firstChat, secondChat }));
    }

    [Test]
    public async Task ListingTheChatsSinceAMomentLeavesOutWhatCameBefore()
    {
        await using var store = await TemporaryProvenanceStore.CreateAsync();
        var chat = Guid.NewGuid();
        await store.Client.StoreAsync(chat, ProvenanceKind.ATTACHMENT, "stored just now", null, TOKEN);

        var sinceBefore = await store.Client.GetChatIdsAsync(TOKEN, DateTimeOffset.UtcNow.AddMinutes(-1));
        var sinceAfter = await store.Client.GetChatIdsAsync(TOKEN, DateTimeOffset.UtcNow.AddMinutes(1));

        using (Assert.EnterMultipleScope())
        {
            Assert.That(sinceBefore, Is.EquivalentTo(new[] { chat }));
            Assert.That(sinceAfter, Is.Empty, "The time is compared as stored text, which has to keep the order of time.");
        }
    }

    [Test]
    public async Task TheStartOfTheLastCleanupIsKept()
    {
        await using var store = await TemporaryProvenanceStore.CreateAsync();
        var startedAt = DateTimeOffset.UtcNow;

        var beforeAnyCleanup = await store.Client.GetLastCleanupAsync(TOKEN);
        await store.Client.SetLastCleanupAsync(startedAt, TOKEN);
        var afterTheCleanup = await store.Client.GetLastCleanupAsync(TOKEN);

        using (Assert.EnterMultipleScope())
        {
            Assert.That(beforeAnyCleanup, Is.Null, "A store without a cleanup, e.g., one a restore brought back, needs every chat read.");
            Assert.That(afterTheCleanup, Is.EqualTo(startedAt));
        }
    }

    [Test]
    public async Task TheBackupCopyHoldsEveryEntry()
    {
        await using var store = await TemporaryProvenanceStore.CreateAsync();
        var id = await store.Client.StoreAsync(Guid.NewGuid(), ProvenanceKind.DATA_SOURCE_PASSAGE, "a passage", ["around it"], TOKEN);
        var copyDirectory = CreateCopyDirectory();

        try
        {
            var copyPath = await store.Client.BackupToDirectoryAsync(copyDirectory, TOKEN);
            var copy = new SqliteProvenanceStoreClientImplementation("SQLite", copyPath, copyDirectory, string.Empty);
            var entries = await copy.GetEntriesAsync([id!.Value], TOKEN);

            using (Assert.EnterMultipleScope())
            {
                Assert.That(Path.GetFileName(copyPath), Is.EqualTo(SqliteProvenanceStoreClientImplementation.DATABASE_FILENAME), "A restore puts the copy where the store belongs, under the same name.");
                Assert.That(entries[id.Value].Content, Is.EqualTo("a passage"));
                Assert.That(entries[id.Value].SurroundingContent, Is.EqualTo(new[] { "around it" }));
            }
        }
        finally
        {
            RemoveCopyDirectory(copyDirectory);
        }
    }

    [Test]
    public async Task AChatOfABackupArrivesWithItsEntriesAndTheirIds()
    {
        await using var backup = await TemporaryProvenanceStore.CreateAsync();
        await using var store = await TemporaryProvenanceStore.CreateAsync();
        var chatInBackup = Guid.NewGuid();
        var otherChatInBackup = Guid.NewGuid();
        var importedChat = Guid.NewGuid();
        var passage = await backup.Client.StoreAsync(chatInBackup, ProvenanceKind.DATA_SOURCE_PASSAGE, "a passage", ["around it"], TOKEN);
        var page = await backup.Client.StoreAsync(chatInBackup, ProvenanceKind.WEB_PAGE, "a page", null, TOKEN);
        var otherChatsMail = await backup.Client.StoreAsync(otherChatInBackup, ProvenanceKind.MAIL, "a mail of another chat", null, TOKEN);
        var copyDirectory = CreateCopyDirectory();

        try
        {
            var copyPath = await backup.Client.BackupToDirectoryAsync(copyDirectory, TOKEN);

            var imported = await store.Client.ImportChatAsync(copyPath, chatInBackup, importedChat, TOKEN);
            var importedAgain = await store.Client.ImportChatAsync(copyPath, chatInBackup, importedChat, TOKEN);
            var entries = await store.Client.GetEntriesAsync([passage!.Value, page!.Value, otherChatsMail!.Value], TOKEN);
            var chatIds = await store.Client.GetChatIdsAsync(TOKEN);
            var original = await backup.Client.GetEntriesAsync([passage.Value], TOKEN);

            using (Assert.EnterMultipleScope())
            {
                Assert.That(imported, Is.EqualTo(2));
                Assert.That(importedAgain, Is.Zero, "Entries the chat holds already stay as they are.");
                Assert.That(entries.Keys, Is.EquivalentTo(new[] { passage.Value, page.Value }), "The chat refers to its entries by their ids, also under its new id. Another chat's entries stay behind.");
                Assert.That(entries[passage.Value].Kind, Is.EqualTo(ProvenanceKind.DATA_SOURCE_PASSAGE));
                Assert.That(entries[passage.Value].SurroundingContent, Is.EqualTo(new[] { "around it" }));
                Assert.That(entries[passage.Value].CreatedAtUtc, Is.EqualTo(original[passage.Value].CreatedAtUtc), "The time says when the AI received the content, not when the chat came back.");
                Assert.That(chatIds, Is.EquivalentTo(new[] { importedChat }));
            }
        }
        finally
        {
            RemoveCopyDirectory(copyDirectory);
        }
    }

    [Test]
    public void TheStandInMakesNoCopy()
    {
        var client = new NoProvenanceStoreClient("SQLite", "not available");

        Assert.That(async () => await client.BackupToDirectoryAsync(Path.GetTempPath(), TOKEN), Throws.InvalidOperationException, "An empty copy would pass for the real one.");
    }

    [Test]
    public async Task TheStandInKeepsNothing()
    {
        var client = new NoProvenanceStoreClient("SQLite", "not available");

        var id = await client.StoreAsync(Guid.NewGuid(), ProvenanceKind.ATTACHMENT, "content", null, TOKEN);

        Assert.That(id, Is.Null, "No id tells the caller to keep the content in the chat itself.");
    }

    [Test]
    public async Task TheInformationPageCountsEntriesChatsAndKinds()
    {
        await using var store = await TemporaryProvenanceStore.CreateAsync();
        var chat = Guid.NewGuid();
        await store.Client.StoreAsync(chat, ProvenanceKind.ATTACHMENT, "one", null, TOKEN);
        await store.Client.StoreAsync(chat, ProvenanceKind.WEB_PAGE, "two", null, TOKEN);
        await store.Client.StoreAsync(chat, ProvenanceKind.WEB_PAGE, "three", null, TOKEN);
        await store.Client.StoreAsync(Guid.NewGuid(), ProvenanceKind.MAIL, "four", null, TOKEN);

        var lines = await ReadDisplayInfoAsync(store);

        using (Assert.EnterMultipleScope())
        {
            Assert.That(lines["Stored items across all chats"], Is.EqualTo("4"));
            Assert.That(lines["Chats with stored items"], Is.EqualTo("2"));
            Assert.That(lines["Attached files"], Is.EqualTo("1"));
            Assert.That(lines["Web pages"], Is.EqualTo("2"));
            Assert.That(lines["Mails"], Is.EqualTo("1"));
            Assert.That(lines, Does.Not.ContainKey("Passages of data sources"), "A kind no chat received would only say zero.");
            Assert.That(lines["Journal mode"], Is.EqualTo("WAL"));
            Assert.That(lines["Schema version"], Does.StartWith("20261024000000_InitialProvenanceStore"));
        }
    }

    [Test]
    public async Task AnEmptyStoreShowsZeroAndNoKinds()
    {
        await using var store = await TemporaryProvenanceStore.CreateAsync();

        var lines = await ReadDisplayInfoAsync(store);

        using (Assert.EnterMultipleScope())
        {
            Assert.That(lines["Stored items across all chats"], Is.EqualTo("0"));
            Assert.That(lines["Chats with stored items"], Is.EqualTo("0"));
            Assert.That(lines, Does.Not.ContainKey("Attached files"));
        }
    }

    private static string CreateCopyDirectory() => Path.Combine(Path.GetTempPath(), $"ai-studio-provenance-copy-{Guid.NewGuid():N}");

    private static void RemoveCopyDirectory(string copyDirectory)
    {
        // The copy is read without a pool, but the clients of the stores keep theirs:
        SqliteConnection.ClearAllPools();
        if (Directory.Exists(copyDirectory))
            Directory.Delete(copyDirectory, true);
    }

    private static async Task<Dictionary<string, string>> ReadDisplayInfoAsync(TemporaryProvenanceStore store)
    {
        var lines = new Dictionary<string, string>();
        await foreach (var (label, value) in store.Client.GetDisplayInfo())
            lines[label] = value;

        return lines;
    }
}