cloudkit 0.3.2

Safe Rust bindings for Apple's CloudKit framework — iCloud databases and sync on macOS
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85

import CloudKit
import Foundation

enum CKSubscriptionPayloadKind: String, Codable {
    case query
    case recordZone
    case database
}

struct CKSubscriptionPayload: Codable {
    var kind: CKSubscriptionPayloadKind
    var subscriptionID: String
    var subscriptionType: Int32
    var notificationInfo: CKNotificationInfoPayload?
    var recordType: String?
    var predicateFormat: String?
    var zoneID: CKRecordZoneIDPayload?
    var querySubscriptionOptions: UInt64?
}

func ckEncodeSubscription(_ subscription: CKSubscription) -> CKSubscriptionPayload {
    if let querySubscription = subscription as? CKQuerySubscription {
        return CKSubscriptionPayload(
            kind: .query,
            subscriptionID: querySubscription.subscriptionID,
            subscriptionType: Int32(querySubscription.subscriptionType.rawValue),
            notificationInfo: ckEncodeNotificationInfo(querySubscription.notificationInfo),
            recordType: querySubscription.recordType,
            predicateFormat: querySubscription.predicate.predicateFormat,
            zoneID: querySubscription.zoneID.map(ckEncodeZoneID),
            querySubscriptionOptions: UInt64(querySubscription.querySubscriptionOptions.rawValue)
        )
    }
    if let recordZoneSubscription = subscription as? CKRecordZoneSubscription {
        return CKSubscriptionPayload(
            kind: .recordZone,
            subscriptionID: recordZoneSubscription.subscriptionID,
            subscriptionType: Int32(recordZoneSubscription.subscriptionType.rawValue),
            notificationInfo: ckEncodeNotificationInfo(recordZoneSubscription.notificationInfo),
            recordType: recordZoneSubscription.recordType,
            predicateFormat: nil,
            zoneID: ckEncodeZoneID(recordZoneSubscription.zoneID),
            querySubscriptionOptions: nil
        )
    }
    let databaseSubscription = subscription as! CKDatabaseSubscription
    return CKSubscriptionPayload(
        kind: .database,
        subscriptionID: databaseSubscription.subscriptionID,
        subscriptionType: Int32(databaseSubscription.subscriptionType.rawValue),
        notificationInfo: ckEncodeNotificationInfo(databaseSubscription.notificationInfo),
        recordType: databaseSubscription.recordType,
        predicateFormat: nil,
        zoneID: nil,
        querySubscriptionOptions: nil
    )
}

func ckDecodeSubscription(_ payload: CKSubscriptionPayload) -> CKSubscription {
    switch payload.kind {
    case .query:
        let subscription = CKQuerySubscription(
            recordType: payload.recordType ?? "",
            predicate: NSPredicate(format: payload.predicateFormat ?? "TRUEPREDICATE"),
            subscriptionID: payload.subscriptionID,
            options: CKQuerySubscription.Options(rawValue: UInt(payload.querySubscriptionOptions ?? 0))
        )
        subscription.zoneID = payload.zoneID.map(ckDecodeZoneID)
        subscription.notificationInfo = ckDecodeNotificationInfo(payload.notificationInfo)
        return subscription
    case .recordZone:
        let subscription = CKRecordZoneSubscription(
            zoneID: payload.zoneID.map(ckDecodeZoneID) ?? CKRecordZone.ID(zoneName: CKRecordZone.ID.defaultZoneName, ownerName: CKCurrentUserDefaultName),
            subscriptionID: payload.subscriptionID
        )
        subscription.recordType = payload.recordType
        subscription.notificationInfo = ckDecodeNotificationInfo(payload.notificationInfo)
        return subscription
    case .database:
        let subscription = CKDatabaseSubscription(subscriptionID: payload.subscriptionID)
        subscription.recordType = payload.recordType
        subscription.notificationInfo = ckDecodeNotificationInfo(payload.notificationInfo)
        return subscription
    }
}