import Foundation
#if canImport(FoundationNetworking)
import FoundationNetworking
#endif

extension GeminiStatusProbe {
    public static func defaultDataLoader(for request: URLRequest) async throws -> (Data, URLResponse) {
        let loader = Self.dataLoaderWithCurlFallback(
            primary: { request in
                try await ProviderHTTPClient.shared.data(for: request)
            },
            fallback: Self.curlDataLoader)
        return try await loader(request)
    }

    public static func dataLoaderWithCurlFallback(
        primary: @escaping @Sendable (URLRequest) async throws -> (Data, URLResponse),
        fallback: @escaping @Sendable (URLRequest) async throws -> (Data, URLResponse))
        -> @Sendable (URLRequest) async throws -> (Data, URLResponse)
    {
        { request in
            do {
                return try await primary(request)
            } catch {
                guard Self.isURLSessionTimeout(error) else {
                    throw error
                }
                CodexBarLog.logger(LogCategories.geminiProbe)
                    .warning("Gemini URLSession timed out; retrying with curl")
                return try await fallback(request)
            }
        }
    }

    private static func isURLSessionTimeout(_ error: Error) -> Bool {
        if let urlError = error as? URLError {
            return urlError.code == .timedOut
        }

        let nsError = error as NSError
        return nsError.domain == NSURLErrorDomain && nsError.code == NSURLErrorTimedOut
    }

    private static func curlDataLoader(for request: URLRequest) async throws -> (Data, URLResponse) {
        guard let url = request.url else {
            throw URLError(.badURL)
        }

        let fileManager = FileManager.default
        let tempDir = fileManager.temporaryDirectory
            .appendingPathComponent("codexbar-gemini-curl-\(UUID().uuidString)", isDirectory: true)
        try fileManager.createDirectory(
            at: tempDir,
            withIntermediateDirectories: true,
            attributes: [.posixPermissions: 0o700])
        defer {
            try? fileManager.removeItem(at: tempDir)
        }

        let configURL = tempDir.appendingPathComponent("curl.conf")
        var config = [
            "silent",
            "show-error",
            "location",
            "url = \(Self.curlConfigQuote(url.absoluteString))",
            "max-time = \(max(1, Int(ceil(request.timeoutInterval))))",
        ]

        if let method = request.httpMethod, !method.isEmpty {
            config.append("request = \(Self.curlConfigQuote(method))")
        }

        for (name, value) in (request.allHTTPHeaderFields ?? [:]).sorted(by: { $0.key < $1.key }) {
            let header = "\(name): \(value)"
            guard !header.contains("\n"), !header.contains("\r") else {
                throw GeminiStatusProbeError.apiError("Invalid request header")
            }
            config.append("header = \(Self.curlConfigQuote(header))")
        }

        if let body = request.httpBody {
            let bodyURL = tempDir.appendingPathComponent("body")
            try body.write(to: bodyURL, options: .atomic)
            try fileManager.setAttributes([.posixPermissions: 0o600], ofItemAtPath: bodyURL.path)
            config.append("data-binary = \(Self.curlConfigQuote("@\(bodyURL.path)"))")
        }

        config.append("write-out = \(Self.curlConfigQuote(Self.curlHTTPStatusMarker + "%{http_code}"))")
        try config.joined(separator: "\n").write(to: configURL, atomically: true, encoding: .utf8)
        try fileManager.setAttributes([.posixPermissions: 0o600], ofItemAtPath: configURL.path)

        let result = try await SubprocessRunner.run(
            binary: "/usr/bin/curl",
            arguments: ["--config", configURL.path],
            environment: TTYCommandRunner.enrichedEnvironment(),
            timeout: max(5, request.timeoutInterval + 2),
            label: "gemini-api-curl")

        return try Self.parseCurlDataLoaderResult(result.stdout, url: url)
    }

    private static let curlHTTPStatusMarker = "__CODEXBAR_HTTP_STATUS__:"

    private static func curlConfigQuote(_ value: String) -> String {
        let escaped = value
            .replacingOccurrences(of: "\\", with: "\\\\")
            .replacingOccurrences(of: "\"", with: "\\\"")
        return "\"\(escaped)\""
    }

    private static func parseCurlDataLoaderResult(_ output: String, url: URL) throws -> (Data, URLResponse) {
        guard let markerRange = output.range(of: curlHTTPStatusMarker, options: .backwards) else {
            throw GeminiStatusProbeError.apiError("curl response missing HTTP status")
        }

        let body = String(output[..<markerRange.lowerBound])
        let statusText = output[markerRange.upperBound...]
            .trimmingCharacters(in: .whitespacesAndNewlines)
        guard let statusCode = Int(statusText), statusCode > 0,
              let response = HTTPURLResponse(
                  url: url,
                  statusCode: statusCode,
                  httpVersion: nil,
                  headerFields: nil)
        else {
            throw GeminiStatusProbeError.apiError("curl response had invalid HTTP status")
        }

        return (Data(body.utf8), response)
    }
}