1// Auteur : Simon-Pierre Boucher — contact@spboucher.ai2// Services.swift — réseau : client JSON avec cache disque (mode hors ligne de3// consultation), service d'univers (listes/recherche), stats live, et4// KA Agent (chat SSE vers l'API centrale api-ka).5import Foundation67// MARK: - Client HTTP + cache disque89actor APIClient {10 static let shared = APIClient()11 private let session: URLSession12 private let cacheDir: URL1314 init() {15 let cfg = URLSessionConfiguration.default16 cfg.timeoutIntervalForRequest = 1517 cfg.waitsForConnectivity = false18 session = URLSession(configuration: cfg)19 cacheDir = FileManager.default.urls(for: .cachesDirectory, in: .userDomainMask)[0]20 .appendingPathComponent("ka-json", isDirectory: true)21 try? FileManager.default.createDirectory(at: cacheDir, withIntermediateDirectories: true)22 }2324 private func cacheFile(for url: URL) -> URL {25 let name = url.absoluteString.data(using: .utf8)!.base64EncodedString()26 .replacingOccurrences(of: "/", with: "_")27 return cacheDir.appendingPathComponent(String(name.suffix(120)) + ".json")28 }2930 /// JSON brut ; en cas d'échec réseau, sert la dernière copie disque (hors ligne).31 func json(_ url: URL, ttl: TimeInterval = 120) async throws -> JSONValue {32 let file = cacheFile(for: url)33 if let attrs = try? FileManager.default.attributesOfItem(atPath: file.path),34 let date = attrs[.modificationDate] as? Date, Date().timeIntervalSince(date) < ttl,35 let data = try? Data(contentsOf: file),36 let cached = try? JSONDecoder().decode(JSONValue.self, from: data) {37 return cached38 }39 do {40 var req = URLRequest(url: url)41 req.setValue("KA-iOS/1.0 (+https://www.groupe-ka.com)", forHTTPHeaderField: "User-Agent")42 let (data, resp) = try await session.data(for: req)43 guard let http = resp as? HTTPURLResponse, http.statusCode == 200 else {44 throw URLError(.badServerResponse)45 }46 let value = try JSONDecoder().decode(JSONValue.self, from: data)47 try? data.write(to: file)48 return value49 } catch {50 if let data = try? Data(contentsOf: file),51 let cached = try? JSONDecoder().decode(JSONValue.self, from: data) {52 return cached // hors ligne : dernier contenu connu53 }54 throw error55 }56 }57}5859// MARK: - Univers : listes, recherche, stats6061enum UniverseService {62 static func listURL(_ u: Universe, query: String?, city: String? = nil, limit: Int = 30, params: [String: String] = [:]) -> URL? {63 guard let path = u.listPath else { return nil }64 var comps = URLComponents(url: u.baseURL.appendingPathComponent(""), resolvingAgainstBaseURL: false)!65 // listPath peut contenir déjà une query (ex. events?upcoming=true)66 let split = path.split(separator: "?", maxSplits: 1)67 comps.path = String(split[0])68 var items: [URLQueryItem] = split.count > 169 ? split[1].split(separator: "&").map {70 let kv = $0.split(separator: "=", maxSplits: 1)71 return URLQueryItem(name: String(kv[0]), value: kv.count > 1 ? String(kv[1]) : nil)72 } : []73 if let q = query, !q.isEmpty { items.append(.init(name: u.searchParam, value: q)) }74 if let c = city, !c.isEmpty { items.append(.init(name: "city", value: c)) }75 for (k, v) in params.sorted(by: { $0.key < $1.key }) where !v.isEmpty {76 items.append(.init(name: k, value: v))77 }78 items.append(.init(name: "limit", value: String(limit)))79 comps.queryItems = items80 return comps.url81 }8283 static func fetch(_ u: Universe, query: String? = nil, city: String? = nil, limit: Int = 30, params: [String: String] = [:]) async throws -> [KAItem] {84 guard let url = listURL(u, query: query, city: city, limit: limit, params: params), let map = u.map else { return [] }85 let root = try await APIClient.shared.json(url)86 let obj = root.object ?? [:]87 let raw = obj[u.itemsKey]?.array88 ?? obj["items"]?.array ?? obj["results"]?.array ?? obj["hits"]?.array89 ?? root.array ?? []90 return raw.compactMap { $0.object.flatMap(map) }91 }9293 /// Total d'une requête (champ `total` de la réponse liste) — pour les alertes.94 static func total(_ u: Universe, query: String? = nil, params: [String: String] = [:]) async -> Int? {95 guard let url = listURL(u, query: query, limit: 1, params: params),96 let root = try? await APIClient.shared.json(url, ttl: 60) else { return nil }97 return root.object?.num("total", "count").map(Int.init)98 }99100 /// Items GÉOLOCALISÉS pour une région de carte.101 /// lou-ka / immo-ka / job-ka : endpoint geojson avec bbox RÉEL (vérifié).102 /// Autres univers : liste standard filtrée client sur la région.103 static func mapItems(_ u: Universe, west: Double, south: Double, east: Double, north: Double,104 limit: Int = 150) async -> [KAItem] {105 let bboxCapable = ["lou-ka": "/api/listings.geojson",106 "immo-ka": "/api/listings.geojson",107 "job-ka": "/api/jobs.geojson"]108 if let path = bboxCapable[u.id], let map = u.map {109 var comps = URLComponents(string: "https://\(u.domain)\(path)")!110 comps.queryItems = [111 .init(name: "bbox", value: "\(west),\(south),\(east),\(north)"),112 .init(name: "limit", value: String(limit)),113 ]114 guard let url = comps.url,115 let root = try? await APIClient.shared.json(url, ttl: 90),116 let features = root.object?["features"]?.array else { return [] }117 return features.compactMap { f -> KAItem? in118 guard let fo = f.object,119 var props = fo["properties"]?.object,120 let coords = fo["geometry"]?.object?["coordinates"]?.array,121 coords.count >= 2, let lon = coords[0].number, let lat = coords[1].number122 else { return nil }123 props["lat"] = .number(lat)124 props["lng"] = .number(lon)125 return map(props)126 }127 }128 // repli : liste + filtre client129 let items = (try? await fetch(u, limit: limit)) ?? []130 return items.filter { it in131 guard let la = it.latitude, let lo = it.longitude else { return false }132 return la >= south && la <= north && lo >= west && lo <= east133 }134 }135136 /// Total « en direct » depuis /api/stats (clé selon l'univers, chemins a.b acceptés)137 static func liveTotal(_ u: Universe) async -> Int? {138 let path = u.id == "trouve-ka" ? "/api/status" : "/api/stats"139 guard let url = URL(string: "https://\(u.domain)\(path)"),140 let root = try? await APIClient.shared.json(url, ttl: 300) else { return nil }141 for key in u.statTotalKeys {142 var cur: JSONValue? = root143 for part in key.split(separator: ".") {144 cur = cur?.object?[String(part)]145 }146 if let n = cur?.number { return Int(n) }147 }148 return nil149 }150}151152// MARK: - KA Agent (SSE)153154struct AgentEvent { let kind: Kind; enum Kind { case delta(String), tool(String), done, error(String) } }155156enum AgentService {157 static let endpoint = URL(string: "https://www.api-ka.com/api/agent/chat")!158159 static func stream(site: String, messages: [[String: String]]) -> AsyncThrowingStream<AgentEvent, Error> {160 AsyncThrowingStream { continuation in161 let task = Task {162 var req = URLRequest(url: endpoint)163 req.httpMethod = "POST"164 req.setValue("application/json", forHTTPHeaderField: "Content-Type")165 req.timeoutInterval = 90166 req.httpBody = try JSONSerialization.data(withJSONObject: ["site": site, "messages": messages])167 let (bytes, resp) = try await URLSession.shared.bytes(for: req)168 guard (resp as? HTTPURLResponse)?.statusCode == 200 else { throw URLError(.badServerResponse) }169 var event = ""170 for try await line in bytes.lines {171 if line.hasPrefix("event: ") { event = String(line.dropFirst(7)) }172 else if line.hasPrefix("data: ") {173 let data = Data(line.dropFirst(6).utf8)174 let obj = (try? JSONSerialization.jsonObject(with: data) as? [String: Any]) ?? [:]175 switch event {176 case "delta": if let t = obj["text"] as? String { continuation.yield(.init(kind: .delta(t))) }177 case "tool": continuation.yield(.init(kind: .tool(obj["name"] as? String ?? "recherche")))178 case "done": continuation.yield(.init(kind: .done)); continuation.finish(); return179 case "error": continuation.yield(.init(kind: .error(obj["message"] as? String ?? "erreur")))180 default: break181 }182 }183 }184 continuation.finish()185 }186 continuation.onTermination = { _ in task.cancel() }187 }188 }189}190