Something went wrong. Try again.
Monorepo for Aesthetic.Computer aesthetic.computer
Something went wrong. Try again.
13 kB · 282 lines
Swift
at commit 4ad2f47b
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283// CalAPI.swift — URLSession networking for the AesthetiCal backend.//// Base: https://aesthetic.computer// All authed calls send `Authorization: Bearer <token>`.//// GET /api/cal?from=<ISO>&to=<ISO> → { events:[CalEvent] } (editable)// POST /api/cal {title,start,end,allDay?,note?,visibility?} → { event }// PUT /api/cal {uid, ...fields} → { event }// DELETE /api/cal?uid=<uid> → { ok:true }// GET /api/cal?feedEvents=1&from=<ISO>&to=<ISO> → { events:[FeedEvent], errors:[...] } (read-only)// GET /api/cal?feeds=1 → { feeds:[Feed] }// POST /api/cal {feed:{url,label}} → { feed }// DELETE /api/cal?feedId=<id> → { ok:true }//// Times are ISO-8601 UTC strings on the wire; we keep them as String and// parse to Date via ISO8601 helpers in CalEvent.import Foundation
// ── wire models ──────────────────────────────────────────────────────
// An editable AesthetiCal event (the user owns these).struct CalEvent: Codable { var uid: String var title: String var start: String // ISO-8601 UTC var end: String // ISO-8601 UTC var allDay: Bool? var rrule: String? var note: String? var visibility: String? // "private" | "public"}
// A read-only overlay event sourced from a connected (Google) calendar.struct FeedEvent: Codable { var uid: String var title: String var start: String var end: String? var allDay: Bool? var note: String? var source: String? // feed id var label: String? // feed label var color: String? // feed color (hex or css name) var readOnly: Bool?}
struct FeedError: Codable { var id: String? var label: String? var message: String?}
// A connected external calendar subscription.struct Feed: Codable { var id: String var label: String? var url: String? var color: String? var kind: String? // "google" | "ics"}
// ── response envelopes ───────────────────────────────────────────────
private struct EventsEnvelope: Codable { var events: [CalEvent] }private struct EventEnvelope: Codable { var event: CalEvent }private struct FeedEventsEnvelope: Codable { var events: [FeedEvent] var errors: [FeedError]?}private struct FeedsEnvelope: Codable { var feeds: [Feed] }private struct FeedEnvelope: Codable { var feed: Feed }
// The caller's secret subscription link (full calendar, private included).struct SubscriptionLink: Codable { var token: String var code: String? var url: String? // ready-to-paste ICS subscription URL}private struct OkEnvelope: Codable { var ok: Bool }private struct MessageEnvelope: Codable { var message: String? }
// ── errors ───────────────────────────────────────────────────────────
enum CalAPIError: Error, LocalizedError { case unauthorized // 401 — token missing/expired; sign in again. case http(Int, String) // any non-2xx with a server message. case transport(Error) // URLSession failure. case decode(Error) // JSON shape mismatch. case noData
var errorDescription: String? { switch self { case .unauthorized: return "Authorization failed — run ac-login to sign in." case .http(let code, let msg): return "HTTP \(code): \(msg)" case .transport(let e): return "Network error: \(e.localizedDescription)" case .decode(let e): return "Decode error: \(e.localizedDescription)" case .noData: return "No data returned." } }}
// ── client ───────────────────────────────────────────────────────────
final class CalAPI { static let base = "https://aesthetic.computer"
private let session: URLSession private var token: String?
init(token: String?) { self.token = token let cfg = URLSessionConfiguration.default cfg.timeoutIntervalForRequest = 20 cfg.requestCachePolicy = .reloadIgnoringLocalCacheData self.session = URLSession(configuration: cfg) }
func setToken(_ token: String?) { self.token = token }
// Always-UTC ISO-8601 formatter for from/to query params. static func iso(_ date: Date) -> String { let fmt = ISO8601DateFormatter() fmt.timeZone = TimeZone(identifier: "UTC") return fmt.string(from: date) }
// ── editable events ──────────────────────────────────────────────
func fetchEvents(from: Date, to: Date, completion: @escaping (Result<[CalEvent], CalAPIError>) -> Void) { var comps = URLComponents(string: "\(Self.base)/api/cal")! comps.queryItems = [ URLQueryItem(name: "from", value: Self.iso(from)), URLQueryItem(name: "to", value: Self.iso(to)), ] request(url: comps.url!, method: "GET", body: nil) { result in completion(result.flatMap { Self.decode(EventsEnvelope.self, $0).map { $0.events } }) } }
func createEvent(title: String, start: String, end: String, allDay: Bool, note: String, visibility: String, completion: @escaping (Result<CalEvent, CalAPIError>) -> Void) { let body: [String: Any] = [ "title": title, "start": start, "end": end, "allDay": allDay, "note": note, "visibility": visibility, ] request(url: URL(string: "\(Self.base)/api/cal")!, method: "POST", body: Self.json(body)) { result in completion(result.flatMap { Self.decode(EventEnvelope.self, $0).map { $0.event } }) } }
func updateEvent(uid: String, title: String, start: String, end: String, allDay: Bool, note: String, visibility: String, completion: @escaping (Result<CalEvent, CalAPIError>) -> Void) { let body: [String: Any] = [ "uid": uid, "title": title, "start": start, "end": end, "allDay": allDay, "note": note, "visibility": visibility, ] request(url: URL(string: "\(Self.base)/api/cal")!, method: "PUT", body: Self.json(body)) { result in completion(result.flatMap { Self.decode(EventEnvelope.self, $0).map { $0.event } }) } }
func deleteEvent(uid: String, completion: @escaping (Result<Bool, CalAPIError>) -> Void) { var comps = URLComponents(string: "\(Self.base)/api/cal")! comps.queryItems = [URLQueryItem(name: "uid", value: uid)] request(url: comps.url!, method: "DELETE", body: nil) { result in completion(result.flatMap { Self.decode(OkEnvelope.self, $0).map { $0.ok } }) } }
// ── read-only Google / feed overlay ──────────────────────────────
func fetchFeedEvents(from: Date, to: Date, completion: @escaping (Result<[FeedEvent], CalAPIError>) -> Void) { var comps = URLComponents(string: "\(Self.base)/api/cal")! comps.queryItems = [ URLQueryItem(name: "feedEvents", value: "1"), URLQueryItem(name: "from", value: Self.iso(from)), URLQueryItem(name: "to", value: Self.iso(to)), ] request(url: comps.url!, method: "GET", body: nil) { result in completion(result.flatMap { Self.decode(FeedEventsEnvelope.self, $0).map { $0.events } }) } }
// ── connected calendar management ────────────────────────────────
func fetchFeeds(completion: @escaping (Result<[Feed], CalAPIError>) -> Void) { var comps = URLComponents(string: "\(Self.base)/api/cal")! comps.queryItems = [URLQueryItem(name: "feeds", value: "1")] request(url: comps.url!, method: "GET", body: nil) { result in completion(result.flatMap { Self.decode(FeedsEnvelope.self, $0).map { $0.feeds } }) } }
func connectFeed(url feedURL: String, label: String, completion: @escaping (Result<Feed, CalAPIError>) -> Void) { let body: [String: Any] = ["feed": ["url": feedURL, "label": label]] request(url: URL(string: "\(Self.base)/api/cal")!, method: "POST", body: Self.json(body)) { result in completion(result.flatMap { Self.decode(FeedEnvelope.self, $0).map { $0.feed } }) } }
func removeFeed(id: String, completion: @escaping (Result<Bool, CalAPIError>) -> Void) { var comps = URLComponents(string: "\(Self.base)/api/cal")! comps.queryItems = [URLQueryItem(name: "feedId", value: id)] request(url: comps.url!, method: "DELETE", body: nil) { result in completion(result.flatMap { Self.decode(OkEnvelope.self, $0).map { $0.ok } }) } }
// Fetch (minting on first use) the caller's secret subscription link. func fetchSubscriptionLink( completion: @escaping (Result<SubscriptionLink, CalAPIError>) -> Void) { var comps = URLComponents(string: "\(Self.base)/api/cal")! comps.queryItems = [URLQueryItem(name: "calToken", value: "1")] request(url: comps.url!, method: "GET", body: nil) { result in completion(result.flatMap { Self.decode(SubscriptionLink.self, $0) }) } }
// Rotate the secret (invalidates all existing subscription URLs). func rotateSubscriptionLink( completion: @escaping (Result<SubscriptionLink, CalAPIError>) -> Void) { let body: [String: Any] = ["rotateToken": true] request(url: URL(string: "\(Self.base)/api/cal")!, method: "POST", body: Self.json(body)) { result in completion(result.flatMap { Self.decode(SubscriptionLink.self, $0) }) } }
// ── plumbing ─────────────────────────────────────────────────────
// Run an authed request; hops back to the main queue with raw Data. private func request(url: URL, method: String, body: Data?, completion: @escaping (Result<Data, CalAPIError>) -> Void) { var req = URLRequest(url: url) req.httpMethod = method if let token, !token.isEmpty { req.setValue("Bearer \(token)", forHTTPHeaderField: "Authorization") } if let body { req.httpBody = body req.setValue("application/json", forHTTPHeaderField: "Content-Type") } let task = session.dataTask(with: req) { data, response, error in let done: (Result<Data, CalAPIError>) -> Void = { r in DispatchQueue.main.async { completion(r) } } if let error { done(.failure(.transport(error))); return } guard let http = response as? HTTPURLResponse else { done(.failure(.noData)); return } let payload = data ?? Data() if http.statusCode == 401 { done(.failure(.unauthorized)); return } guard (200..<300).contains(http.statusCode) else { let msg = (try? JSONDecoder().decode(MessageEnvelope.self, from: payload))?.message ?? String(data: payload, encoding: .utf8) ?? "" done(.failure(.http(http.statusCode, msg))) return } done(.success(payload)) } task.resume() }
private static func decode<T: Decodable>(_ type: T.Type, _ data: Data) -> Result<T, CalAPIError> { do { return .success(try JSONDecoder().decode(T.self, from: data)) } catch { return .failure(.decode(error)) } }
private static func json(_ dict: [String: Any]) -> Data? { try? JSONSerialization.data(withJSONObject: dict, options: []) }}