crossmate

NYTPuzzleFetcher.swift (5692B)

---

 import Foundation
 import SwiftUI
 
 extension EnvironmentValues {
     @Entry var nytPuzzleFetcher: NYTPuzzleFetcher? = nil
 }
 
 actor NYTPuzzleFetcher {
     private let cookieProvider: @Sendable () -> String?
 
     init(cookieProvider: @escaping @Sendable () -> String?) {
         self.cookieProvider = cookieProvider
     }
 
     /// Fetches the puzzle list for a given date to get the puzzle ID,
     /// then fetches the game data. For debugging, logs both responses.
     func fetchPuzzleList(for date: Date) async throws -> String {
         guard let cookie = cookieProvider() else {
             throw NYTFetchError.notSignedIn
         }
 
         let formatter = DateFormatter()
         formatter.dateFormat = "yyyy-MM-dd"
         formatter.timeZone = TimeZone(identifier: "America/New_York")
         let dateString = formatter.string(from: date)
 
         // Step 1: Get puzzle ID from list endpoint
         let listURL = URL(string: "https://www.nytimes.com/svc/crosswords/v3/36569100/puzzles.json?publish_type=daily&date_start=\(dateString)&date_end=\(dateString)&limit=1")!
 
         var listRequest = URLRequest(url: listURL)
         listRequest.setValue("NYT-S=\(cookie)", forHTTPHeaderField: "Cookie")
 
         let (listData, listResponse) = try await URLSession.shared.data(for: listRequest)
 
         guard let listHTTP = listResponse as? HTTPURLResponse else {
             throw NYTFetchError.invalidResponse
         }
 
         print("=== NYT LIST RESPONSE ===")
         print("Status: \(listHTTP.statusCode)")
         if let body = String(data: listData, encoding: .utf8) {
             print("Body: \(body.prefix(2000))")
         }
         print("=== END LIST RESPONSE ===")
 
         guard listHTTP.statusCode == 200 else {
             throw NYTFetchError.httpError(statusCode: listHTTP.statusCode)
         }
 
         // Extract puzzle ID from the list
         guard let listJSON = try? JSONSerialization.jsonObject(with: listData) as? [String: Any],
               let results = listJSON["results"] as? [[String: Any]],
               let first = results.first,
               let puzzleID = first["puzzle_id"] as? Int else {
             throw NYTFetchError.invalidResponse
         }
 
         print("=== PUZZLE ID: \(puzzleID) ===")
 
         // Step 2: Fetch game data using the puzzle ID
         let gameURL = URL(string: "https://www.nytimes.com/svc/crosswords/v6/game/\(puzzleID).json")!
 
         var gameRequest = URLRequest(url: gameURL)
         gameRequest.setValue("NYT-S=\(cookie)", forHTTPHeaderField: "Cookie")
 
         let (gameData, gameResponse) = try await URLSession.shared.data(for: gameRequest)
 
         guard let gameHTTP = gameResponse as? HTTPURLResponse else {
             throw NYTFetchError.invalidResponse
         }
 
         print("=== NYT GAME RESPONSE ===")
         print("Status: \(gameHTTP.statusCode)")
         if let body = String(data: gameData, encoding: .utf8) {
             print("Body: \(body.prefix(3000))")
         }
         print("=== END GAME RESPONSE ===")
 
         guard gameHTTP.statusCode == 200 else {
             throw NYTFetchError.httpError(statusCode: gameHTTP.statusCode)
         }
 
         return String(data: gameData, encoding: .utf8) ?? ""
     }
 
     func fetchPuzzle(for date: Date) async throws -> String {
         guard let cookie = cookieProvider() else {
             throw NYTFetchError.notSignedIn
         }
 
         let formatter = DateFormatter()
         formatter.dateFormat = "yyyy-MM-dd"
         formatter.timeZone = TimeZone(identifier: "America/New_York")
         let dateString = formatter.string(from: date)
 
         let url = URL(string: "https://www.nytimes.com/svc/crosswords/v6/puzzle/daily/\(dateString).json")!
 
         var request = URLRequest(url: url)
         request.setValue("NYT-S=\(cookie)", forHTTPHeaderField: "Cookie")
 
         print("=== NYT FETCH REQUEST ===")
         print("URL: \(url)")
         print("Cookie header: NYT-S=\(cookie.prefix(40))...")
         print("=== END FETCH REQUEST ===")
 
         let (data, response) = try await URLSession.shared.data(for: request)
 
         guard let httpResponse = response as? HTTPURLResponse else {
             throw NYTFetchError.invalidResponse
         }
 
         print("=== NYT FETCH RESPONSE ===")
         print("Status: \(httpResponse.statusCode)")
         if httpResponse.statusCode != 200, let body = String(data: data, encoding: .utf8) {
             print("Body: \(body.prefix(1000))")
         }
         print("=== END FETCH RESPONSE ===")
 
         switch httpResponse.statusCode {
         case 200:
             break
         case 401, 403:
             throw NYTFetchError.unauthorized
         case 429:
             throw NYTFetchError.rateLimited
         default:
             throw NYTFetchError.httpError(statusCode: httpResponse.statusCode)
         }
 
         // Convert NYT JSON to .xd format
         let xdSource = try NYTToXDConverter.convert(jsonData: data)
 
         print("=== CONVERTED XD ===")
         print(xdSource)
         print("=== END XD ===")
 
         return xdSource
     }
 }
 
 enum NYTFetchError: LocalizedError {
     case notSignedIn
     case invalidResponse
     case unauthorized
     case rateLimited
     case httpError(statusCode: Int)
 
     var errorDescription: String? {
         switch self {
         case .notSignedIn:
             "Not signed in to NYT."
         case .invalidResponse:
             "Received an invalid response."
         case .unauthorized:
             "Your NYT session has expired. Sign in again from Settings."
         case .rateLimited:
             "Too many requests. Wait a moment and try again."
         case .httpError(let statusCode):
             "Fetch failed (HTTP \(statusCode))."
         }
     }
 }