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

import Foundation
import GRDB

public protocol ThreadAssociatedDataStore {
    func fetch(for threadUniqueId: String, tx: DBReadTransaction) -> ThreadAssociatedData?
    func remove(for threadUniqueId: String, tx: DBWriteTransaction)
}

class ThreadAssociatedDataStoreImpl: ThreadAssociatedDataStore {
    func fetch(for threadUniqueId: String, tx: DBReadTransaction) -> ThreadAssociatedData? {
        let db = tx.database
        do {
            return try ThreadAssociatedData.filter(Column("threadUniqueId") == threadUniqueId).fetchOne(db)
        } catch {
            owsFailDebug("Failed to read thread associated data \(error)")
            return nil
        }
    }

    func remove(for threadUniqueId: String, tx: DBWriteTransaction) {
        let db = tx.database
        do {
            try ThreadAssociatedData.filter(Column("threadUniqueId") == threadUniqueId).deleteAll(db)
        } catch {
            owsFailDebug("Failed to remove associated data \(error)")
        }
    }
}

extension ThreadAssociatedDataStore {
    func fetchOrDefault(
        for thread: TSThread,
        ignoreMissing: Bool = false,
        tx: DBReadTransaction,
    ) -> ThreadAssociatedData {
        fetchOrDefault(for: thread.uniqueId, ignoreMissing: ignoreMissing, tx: tx)
    }

    func fetchOrDefault(
        for threadUniqueId: String,
        ignoreMissing: Bool = false,
        tx: DBReadTransaction,
    ) -> ThreadAssociatedData {
        if let result = fetch(for: threadUniqueId, tx: tx) {
            return result
        }
        owsAssertDebug(ignoreMissing, "Unexpectedly missing associated data for thread")
        return ThreadAssociatedData(threadUniqueId: threadUniqueId)
    }
}

#if TESTABLE_BUILD

class MockThreadAssociatedDataStore: ThreadAssociatedDataStore {
    var values = [String: ThreadAssociatedData]()
    func fetch(for threadUniqueId: String, tx: DBReadTransaction) -> ThreadAssociatedData? { values[threadUniqueId] }
    func remove(for threadUniqueId: String, tx: DBWriteTransaction) { values[threadUniqueId] = nil }
}

#endif