class TaskData: ObservableObject {
    @Published var tasks: [Task] = []
    @Published var incompleteTasks: [Task] = []
    @Published var completedTasks: [Task] = []
    private var db = Firestore.firestore()
    private var incompleteTaskslistenerRegistration: ListenerRegistration?
    private var completedTasksListenerRegistration: ListenerRegistration?
    init() {
        subscribe()
        Publishers
            .CombineLatest($completedTasks, $incompleteTasks)
            .dropFirst()
            .map { $0 + $1 }
            .assign(to: &$tasks)
    deinit {
        unsubscribe()
    func subscribe() {
        guard let userId = Auth.auth().currentUser?.uid else { return }
        if incompleteTaskslistenerRegistration != nil || completedTasksListenerRegistration != nil {
            unsubscribe()
        let completedTasksQuery = db.collection("tasks")
            .whereField("userId", isEqualTo: userId)
            .whereField("completed", isEqualTo: true)
            .whereField("completedDate", isGreaterThan: Date().advanced(by: -86400))
        completedTasksListenerRegistration = completedTasksQuery.addSnapshotListener { querySnapshot, error in
            guard let documents = querySnapshot?.documents else {
                print("No documents in 'tasks' collection")
                return
            self.completedTasks = documents.compactMap { queryDocumentSnapshot in
                try? queryDocumentSnapshot.data(as: Task.self)
        let incompleteTasksQuery = db.collection("tasks")
            .whereField("userId", isEqualTo: userId)
            .whereField("completed", isEqualTo: false)
        incompleteTaskslistenerRegistration = incompleteTasksQuery.addSnapshotListener { querySnapshot, error in
            guard let documents = querySnapshot?.documents else {
                print("No documents in 'tasks' collection")
                return
            self.incompleteTasks = documents.compactMap { queryDocumentSnapshot in
                try? queryDocumentSnapshot.data(as: Task.self)
    func unsubscribe() {
        if incompleteTaskslistenerRegistration != nil {
            incompleteTaskslistenerRegistration?.remove()
            incompleteTaskslistenerRegistration = nil