BackupArchiveRecipientStore.swift

//
// Copyright 2024 Signal Messenger, LLC
// SPDX-License-Identifier: AGPL-3.0-only
//

public class BackupArchiveRecipientStore {

    private let recipientTable: RecipientDatabaseTable
    private let searchableNameIndexer: SearchableNameIndexer

    init(
        recipientTable: RecipientDatabaseTable,
        searchableNameIndexer: SearchableNameIndexer,
    ) {
        self.recipientTable = recipientTable
        self.searchableNameIndexer = searchableNameIndexer
    }

    // MARK: - Archiving

    func enumerateAllSignalRecipients(
        tx: DBReadTransaction,
        block: (SignalRecipient) -> Void,
    ) throws {
        let cursor = try SignalRecipient.fetchCursor(tx.database)
        while let next = try cursor.next() {
            try Task.checkCancellation()
            block(next)
        }
    }

    func fetchRecipient(
        for address: BackupArchive.ContactAddress,
        tx: DBReadTransaction,
    ) -> SignalRecipient? {
        return recipientTable.fetchRecipient(address: address.asInteropAddress(), tx: tx)
    }

    func fetchRecipient(
        localIdentifiers: LocalIdentifiers,
        tx: DBReadTransaction,
    ) -> SignalRecipient? {
        return recipientTable.fetchRecipient(serviceId: localIdentifiers.aci, transaction: tx)
    }

    // MARK: - Restoring

    func didInsertRecipient(_ recipient: SignalRecipient, tx: DBWriteTransaction) {
        // Unlike messages, whose indexing is deferred, we insert
        // into the index immediately within the backup write tx.
        // This is because:
        // 1. There are way fewer recipients than messages
        // 2. Its not unlikely one of the first things the user
        //    will do post-restore is search up a recipient.
        // If this ends up being a performance issue, we can
        // defer this indexing, too.
        searchableNameIndexer.insert(recipient, tx: tx)
    }
}