138 lines
4.7 KiB
Swift
138 lines
4.7 KiB
Swift
import Alamofire
|
|
import Foundation
|
|
import LilithAgentCore
|
|
import LilithLogging
|
|
import MacSyncShared
|
|
import SwiftyJSON
|
|
|
|
private let log = AppLogger.logger(for: "INote.API")
|
|
|
|
// MARK: - Payload Types
|
|
|
|
public struct SyncNotePayload {
|
|
public let noteIdentifier: String
|
|
public let folder: String?
|
|
public let name: String
|
|
public let body: String
|
|
public let modifiedAt: String?
|
|
|
|
public init(
|
|
noteIdentifier: String,
|
|
folder: String?,
|
|
name: String,
|
|
body: String,
|
|
modifiedAt: String?
|
|
) {
|
|
self.noteIdentifier = noteIdentifier
|
|
self.folder = folder
|
|
self.name = name
|
|
self.body = body
|
|
self.modifiedAt = modifiedAt
|
|
}
|
|
|
|
var dictionary: [String: Any?] {
|
|
[
|
|
"noteIdentifier": noteIdentifier,
|
|
"folder": folder,
|
|
"name": name,
|
|
"body": body,
|
|
"modifiedAt": modifiedAt,
|
|
]
|
|
}
|
|
}
|
|
|
|
public struct INoteStatsResponse {
|
|
public let folderCount: Int
|
|
public let noteCount: Int
|
|
public let lastSyncAt: Date?
|
|
|
|
public init(folderCount: Int, noteCount: Int, lastSyncAt: Date?) {
|
|
self.folderCount = folderCount
|
|
self.noteCount = noteCount
|
|
self.lastSyncAt = lastSyncAt
|
|
}
|
|
}
|
|
|
|
// MARK: - Protocol
|
|
|
|
public protocol INoteAPIClientProtocol: AnyObject, Sendable {
|
|
var isAuthenticated: Bool { get }
|
|
func syncNotes(_ payloads: [SyncNotePayload]) async throws -> Int
|
|
func getStats() async throws -> INoteStatsResponse
|
|
func getPendingSends() async throws -> [PendingNoteSend]
|
|
func reportSendResult(id: String, status: String, error: String?) async throws
|
|
}
|
|
|
|
// MARK: - APIClient
|
|
|
|
public final class APIClient: BaseAPIClient, INoteAPIClientProtocol, @unchecked Sendable {
|
|
public static let shared: APIClient = {
|
|
APIClient(baseURL: macSyncResolveServerURL(), keychain: macSyncSharedKeychain)
|
|
}()
|
|
|
|
public var isAuthenticated: Bool {
|
|
(try? getAuthToken()) != nil
|
|
}
|
|
|
|
public func syncNotes(_ payloads: [SyncNotePayload]) async throws -> Int {
|
|
let params: [String: Any] = ["notes": payloads.map { $0.dictionary }]
|
|
let data = try await authenticatedRequest("/client/inotes/sync", method: .post, parameters: params)
|
|
let json = JSON(data)
|
|
guard json["success"].boolValue else {
|
|
let msg = json["error"]["message"].stringValue
|
|
throw APIError.serverError(
|
|
statusCode: json["statusCode"].intValue,
|
|
message: msg.isEmpty ? "Server error" : msg
|
|
)
|
|
}
|
|
let synced = json["data"]["synced"].intValue
|
|
log.info("syncNotes synced=\(synced)")
|
|
return synced
|
|
}
|
|
|
|
public func getStats() async throws -> INoteStatsResponse {
|
|
let data = try await authenticatedRequest("/client/inotes/stats", method: .get)
|
|
let json = JSON(data)
|
|
guard json["success"].boolValue else {
|
|
throw APIError.serverError(statusCode: 0, message: json["error"]["message"].stringValue)
|
|
}
|
|
return INoteStatsResponse(
|
|
folderCount: json["data"]["folderCount"].intValue,
|
|
noteCount: json["data"]["noteCount"].intValue,
|
|
lastSyncAt: json["data"]["lastSyncAt"].string.flatMap { ISO8601DateFormatter().date(from: $0) }
|
|
)
|
|
}
|
|
|
|
// MARK: - Send Queue
|
|
|
|
public func getPendingSends() async throws -> [PendingNoteSend] {
|
|
let data = try await authenticatedRequest("/client/inotes/send-queue/pending", method: .get)
|
|
let json = JSON(data)
|
|
guard json["success"].boolValue else {
|
|
throw APIError.serverError(statusCode: 0, message: json["error"]["message"].stringValue)
|
|
}
|
|
return json["data"]["items"].arrayValue.map { item in
|
|
PendingNoteSend(
|
|
id: item["id"].stringValue,
|
|
action: item["action"].stringValue,
|
|
payload: NoteSendPayload(
|
|
noteIdentifier: item["payload"]["noteIdentifier"].string,
|
|
folder: item["payload"]["folder"].string,
|
|
name: item["payload"]["name"].string,
|
|
body: item["payload"]["body"].string
|
|
),
|
|
createdAt: item["createdAt"].stringValue
|
|
)
|
|
}
|
|
}
|
|
|
|
public func reportSendResult(id: String, status: String, error: String?) async throws {
|
|
var params: [String: Any] = ["status": status]
|
|
if let err = error { params["error"] = err }
|
|
let data = try await authenticatedRequest("/client/inotes/send-queue/\(id)/result", method: .post, parameters: params)
|
|
let json = JSON(data)
|
|
guard json["success"].boolValue else {
|
|
throw APIError.serverError(statusCode: 0, message: json["error"]["message"].stringValue)
|
|
}
|
|
}
|
|
}
|