SignalProtocolStore.swift

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

/// Wraps the stores for 1:1 sessions that use the Signal Protocol (Double Ratchet + X3DH).

public struct SignalProtocolStore {
    public let sessionStore: SessionManagerForIdentity
    public let preKeyStore: PreKeyStoreImpl
    public let signedPreKeyStore: SignedPreKeyStoreImpl
    public let kyberPreKeyStore: KyberPreKeyStoreImpl

    static func build(
        dateProvider: @escaping DateProvider,
        identity: OWSIdentity,
        preKeyStore: PreKeyStore,
        recipientIdFinder: RecipientIdFinder,
        sessionStore: SessionStore,
    ) -> Self {
        return Self(
            sessionStore: SessionManagerForIdentity(identity: identity, recipientIdFinder: recipientIdFinder, sessionStore: sessionStore),
            preKeyStore: PreKeyStoreImpl(for: identity, preKeyStore: preKeyStore),
            signedPreKeyStore: SignedPreKeyStoreImpl(for: identity, preKeyStore: preKeyStore),
            kyberPreKeyStore: KyberPreKeyStoreImpl(for: identity, dateProvider: dateProvider, preKeyStore: preKeyStore),
        )
    }
}

/// Wrapper for ACI/PNI protocol stores that can be passed around to dependencies
public struct SignalProtocolStoreManager {
    let aciProtocolStore: SignalProtocolStore
    let pniProtocolStore: SignalProtocolStore
    let preKeyStore: PreKeyStore
    let sessionStore: SessionStore

    public func signalProtocolStore(for identity: OWSIdentity) -> SignalProtocolStore {
        switch identity {
        case .aci:
            return aciProtocolStore
        case .pni:
            return pniProtocolStore
        }
    }

    public func removeAllKeys(tx: DBWriteTransaction) {
        for signalProtocolStore in [aciProtocolStore, pniProtocolStore] {
            signalProtocolStore.preKeyStore.removeMetadata(tx: tx)
            signalProtocolStore.signedPreKeyStore.removeMetadata(tx: tx)
            signalProtocolStore.kyberPreKeyStore.removeMetadata(tx: tx)
        }
        self.sessionStore.deleteAllSessions(tx: tx)
        self.preKeyStore.removeAll(tx: tx)
    }
}