/* |
Copyright (C) 2014 Apple Inc. All Rights Reserved. |
See LICENSE.txt for this sample’s licensing information |
|
*/ |
|
@import CloudKit; |
#import "AAPLCloudManager.h" |
|
NSString * const NameField = @"name"; |
NSString * const ParentField = @"parent"; |
NSString * const PhotoAssetField = @"photo"; |
NSString * const LocationField = @"location"; |
NSString * const ReferenceItemsRecordType = @"ReferenceItems"; |
NSString * const ReferenceSubItemsRecordType = @"ReferenceSubitems"; |
|
static NSString * const ItemRecordType = @"Items"; |
static NSString * const PhotoAssetRecordType = @"Photos"; |
static NSString * const subscriptionIDkey = @"subscriptionID"; |
|
@interface AAPLCloudManager () |
|
@property (readonly) CKContainer *container; |
@property (readonly) CKDatabase *publicDatabase; |
|
@end |
|
@implementation AAPLCloudManager |
|
- (id)init { |
self = [super init]; |
if (self) { |
_container = [CKContainer defaultContainer]; |
_publicDatabase = [_container publicCloudDatabase]; |
} |
|
return self; |
} |
|
- (void)requestDiscoverabilityPermission:(void (^)(BOOL discoverable)) completionHandler { |
|
[self.container requestApplicationPermission:CKApplicationPermissionUserDiscoverability |
completionHandler:^(CKApplicationPermissionStatus applicationPermissionStatus, NSError *error) { |
if (error) { |
// In your app, handle this error really beautifully. |
NSLog(@"An error occured in %@: %@", NSStringFromSelector(_cmd), error); |
abort(); |
} else { |
dispatch_async(dispatch_get_main_queue(), ^{ |
completionHandler(applicationPermissionStatus == CKApplicationPermissionStatusGranted); |
}); |
} |
}]; |
} |
|
- (void)discoverUserInfo:(void (^)(CKDiscoveredUserInfo *user))completionHandler { |
|
[self.container fetchUserRecordIDWithCompletionHandler:^(CKRecordID *recordID, NSError *error) { |
|
if (error) { |
// In your app, handle this error in an awe-inspiring way. |
NSLog(@"An error occured in %@: %@", NSStringFromSelector(_cmd), error); |
abort(); |
} else { |
[self.container discoverUserInfoWithUserRecordID:recordID |
completionHandler:^(CKDiscoveredUserInfo *user, NSError *error) { |
if (error) { |
// In your app, handle this error deftly. |
NSLog(@"An error occured in %@: %@", NSStringFromSelector(_cmd), error); |
abort(); |
} else { |
dispatch_async(dispatch_get_main_queue(), ^(void){ |
completionHandler(user); |
}); |
} |
}]; |
} |
}]; |
} |
|
- (void)uploadAssetWithURL:(NSURL *)assetURL completionHandler:(void (^)(CKRecord *record))completionHandler { |
|
CKRecord *assetRecord = [[CKRecord alloc] initWithRecordType:PhotoAssetRecordType]; |
CKAsset *photo = [[CKAsset alloc] initWithFileURL:assetURL]; |
assetRecord[PhotoAssetField] = photo; |
|
[self.publicDatabase saveRecord:assetRecord completionHandler:^(CKRecord *record, NSError *error) { |
if (error) { |
// In your app, masterfully handle this error. |
NSLog(@"An error occured in %@: %@", NSStringFromSelector(_cmd), error); |
abort(); |
} else { |
dispatch_async(dispatch_get_main_queue(), ^(void){ |
completionHandler(record); |
}); |
} |
}]; |
} |
|
- (void)addRecordWithName:(NSString *)name location:(CLLocation *)location completionHandler:(void (^)(CKRecord *record))completionHandler { |
|
CKRecord *record = [[CKRecord alloc] initWithRecordType:ItemRecordType]; |
record[NameField] = name; |
record[LocationField] = location; |
|
[self.publicDatabase saveRecord:record completionHandler:^(CKRecord *record, NSError *error) { |
if (error) { |
// In your app, handle this error like a pro. |
NSLog(@"An error occured in %@: %@", NSStringFromSelector(_cmd), error); |
abort(); |
} else { |
dispatch_async(dispatch_get_main_queue(), ^(void){ |
completionHandler(record); |
}); |
} |
}]; |
} |
|
- (void)fetchRecordWithID:(NSString *)recordID completionHandler:(void (^)(CKRecord *record))completionHandler { |
|
CKRecordID *current = [[CKRecordID alloc] initWithRecordName:recordID]; |
[self.publicDatabase fetchRecordWithID:current completionHandler:^(CKRecord *record, NSError *error) { |
|
if (error) { |
// In your app, handle this error gracefully. |
NSLog(@"An error occured in %@: %@", NSStringFromSelector(_cmd), error); |
abort(); |
} else { |
dispatch_async(dispatch_get_main_queue(), ^(void){ |
completionHandler(record); |
}); |
} |
}]; |
} |
|
- (void)queryForRecordsNearLocation:(CLLocation *)location completionHandler:(void (^)(NSArray *records))completionHandler { |
|
CGFloat radiusInKilometers = 5; |
NSPredicate *predicate = [NSPredicate predicateWithFormat:@"distanceToLocation:fromLocation:(location, %@) < %f", location, radiusInKilometers]; |
|
CKQuery *query = [[CKQuery alloc] initWithRecordType:ItemRecordType predicate:predicate]; |
|
CKQueryOperation *queryOperation = [[CKQueryOperation alloc] initWithQuery:query]; |
|
NSMutableArray *results = [[NSMutableArray alloc] init]; |
|
[queryOperation setRecordFetchedBlock:^(CKRecord *record) { |
[results addObject:record]; |
}]; |
|
queryOperation.queryCompletionBlock = ^(CKQueryCursor *cursor, NSError *error) { |
if (error) { |
// In your app, handle this error with such perfection that your users will never realize an error occurred. |
NSLog(@"An error occured in %@: %@", NSStringFromSelector(_cmd), error); |
abort(); |
} else { |
dispatch_async(dispatch_get_main_queue(), ^(void){ |
completionHandler(results); |
}); |
} |
}; |
|
[self.publicDatabase addOperation:queryOperation]; |
} |
|
- (void)saveRecord:(CKRecord *)record { |
[self.publicDatabase saveRecord:record completionHandler:^(CKRecord *record, NSError *error) { |
if (error) { |
// In your app, handle this error awesomely. |
NSLog(@"An error occured in %@: %@", NSStringFromSelector(_cmd), error); |
abort(); |
} else { |
NSLog(@"Successfully saved record"); |
} |
}]; |
} |
|
- (void)deleteRecord:(CKRecord *)record { |
[self.publicDatabase deleteRecordWithID:record.recordID completionHandler:^(CKRecordID *recordID, NSError *error) { |
if (error) { |
// In your app, handle this error. Please. |
NSLog(@"An error occured in %@: %@", NSStringFromSelector(_cmd), error); |
abort(); |
} else { |
NSLog(@"Successfully deleted record"); |
} |
}]; |
} |
|
- (void)fetchRecordsWithType:(NSString *)recordType completionHandler:(void (^)(NSArray *records))completionHandler { |
|
NSPredicate *truePredicate = [NSPredicate predicateWithValue:YES]; |
CKQuery *query = [[CKQuery alloc] initWithRecordType:recordType predicate:truePredicate]; |
|
CKQueryOperation *queryOperation = [[CKQueryOperation alloc] initWithQuery:query]; |
// Just request the name field for all records |
queryOperation.desiredKeys = @[NameField]; |
|
NSMutableArray *results = [[NSMutableArray alloc] init]; |
|
queryOperation.recordFetchedBlock = ^(CKRecord *record) { |
[results addObject:record]; |
}; |
|
queryOperation.queryCompletionBlock = ^(CKQueryCursor *cursor, NSError *error) { |
if (error) { |
// In your app, this error needs love and care. |
NSLog(@"An error occured in %@: %@", NSStringFromSelector(_cmd), error); |
abort(); |
} else { |
dispatch_async(dispatch_get_main_queue(), ^(void){ |
completionHandler(results); |
}); |
} |
}; |
|
[self.publicDatabase addOperation:queryOperation]; |
} |
|
- (void)queryForRecordsWithReferenceNamed:(NSString *)referenceRecordName completionHandler:(void (^)(NSArray *records))completionHandler { |
|
CKRecordID *recordID = [[CKRecordID alloc] initWithRecordName:referenceRecordName]; |
CKReference *parent = [[CKReference alloc] initWithRecordID:recordID action:CKReferenceActionNone]; |
|
NSPredicate *predicate = [NSPredicate predicateWithFormat:@"parent == %@", parent]; |
CKQuery *query = [[CKQuery alloc] initWithRecordType:ReferenceSubItemsRecordType predicate:predicate]; |
|
CKQueryOperation *queryOperation = [[CKQueryOperation alloc] initWithQuery:query]; |
// Just request the name field for all records |
queryOperation.desiredKeys = @[NameField]; |
|
NSMutableArray *results = [[NSMutableArray alloc] init]; |
|
queryOperation.recordFetchedBlock = ^(CKRecord *record) { |
[results addObject:record]; |
}; |
|
queryOperation.queryCompletionBlock = ^(CKQueryCursor *cursor, NSError *error) { |
if (error) { |
// In your app, you should do the Right Thing |
NSLog(@"An error occured in %@: %@", NSStringFromSelector(_cmd), error); |
abort(); |
} else { |
dispatch_async(dispatch_get_main_queue(), ^(void){ |
completionHandler(results); |
}); |
} |
}; |
|
[self.publicDatabase addOperation:queryOperation]; |
} |
|
- (void)subscribe { |
|
if (self.subscribed == NO) { |
|
NSPredicate *truePredicate = [NSPredicate predicateWithValue:YES]; |
CKSubscription *itemSubscription = [[CKSubscription alloc] initWithRecordType:ItemRecordType |
predicate:truePredicate |
options:CKSubscriptionOptionsFiresOnRecordCreation]; |
|
|
CKNotificationInfo *notification = [[CKNotificationInfo alloc] init]; |
notification.alertBody = @"New Item Added!"; |
itemSubscription.notificationInfo = notification; |
|
[self.publicDatabase saveSubscription:itemSubscription completionHandler:^(CKSubscription *subscription, NSError *error) { |
if (error) { |
// In your app, handle this error appropriately. |
NSLog(@"An error occured in %@: %@", NSStringFromSelector(_cmd), error); |
abort(); |
} else { |
NSLog(@"Subscribed to Item"); |
NSUserDefaults *defaults = [NSUserDefaults standardUserDefaults]; |
[defaults setBool:YES forKey:@"subscribed"]; |
[defaults setObject:subscription.subscriptionID forKey:subscriptionIDkey]; |
} |
}]; |
} |
} |
|
- (void)unsubscribe { |
if (self.subscribed == YES) { |
|
NSString *subscriptionID = [[NSUserDefaults standardUserDefaults] objectForKey:subscriptionIDkey]; |
|
CKModifySubscriptionsOperation *modifyOperation = [[CKModifySubscriptionsOperation alloc] init]; |
modifyOperation.subscriptionIDsToDelete = @[subscriptionID]; |
|
modifyOperation.modifySubscriptionsCompletionBlock = ^(NSArray *savedSubscriptions, NSArray *deletedSubscriptionIDs, NSError *error) { |
if (error) { |
// In your app, handle this error beautifully. |
NSLog(@"An error occured in %@: %@", NSStringFromSelector(_cmd), error); |
abort(); |
} else { |
NSLog(@"Unsubscribed to Item"); |
[[NSUserDefaults standardUserDefaults] removeObjectForKey:subscriptionIDkey]; |
} |
}; |
|
[self.publicDatabase addOperation:modifyOperation]; |
} |
} |
|
- (BOOL)isSubscribed { |
return [[NSUserDefaults standardUserDefaults] objectForKey:subscriptionIDkey] != nil; |
} |
|
@end |
