class CloudKitManager: ObservableObject {
    private let database = CKContainer.default().publicCloudDatabase

    @Published var words: [WordDto] = []

    func fetchWords() {
        print("Fetching words from NounWord record type...")
        let query = CKQuery(recordType: "NounWord", predicate: NSPredicate(value: true))
        let queryOperation = CKQueryOperation(query: query)
        
        var fetchedWords: [WordDto] = []
        
        queryOperation.recordMatchedBlock = { id, result in
            switch result {
            case .failure(let error):
                print("Failed to load word with id \(id): \(error.localizedDescription)")
                return
            case .success(let record):
                guard let word = record["word"] as? String else { return }
                guard let articleString = record["article"] as? String else { return }
                let dto = WordDto(id: record.recordID.recordName, word: word, article: NounArticle(rawValue: articleString)!, exampleSentences: [])
                fetchedWords.append(dto)
            }
        }
        
        queryOperation.queryResultBlock = { result in
            print("Notifying UI about fetched words...")
            DispatchQueue.main.async {
                switch result {
                case .success:
                    self.words = fetchedWords
                case .failure(let error):
                    print("Error fetching words: \(error.localizedDescription)")
                }
            }
        }
        
        database.add(queryOperation)
    }
}