CKKSAPSReceiverTests.m [plain text]
/*
* Copyright (c) 2016 Apple Inc. All Rights Reserved.
*
* @APPLE_LICENSE_HEADER_START@
*
* This file contains Original Code and/or Modifications of Original Code
* as defined in and that are subject to the Apple Public Source License
* Version 2.0 (the 'License'). You may not use this file except in
* compliance with the License. Please obtain a copy of the License at
* http://www.opensource.apple.com/apsl/ and read it before using this
* file.
*
* The Original Code and all software distributed under the License are
* distributed on an 'AS IS' basis, WITHOUT WARRANTY OF ANY KIND, EITHER
* EXPRESS OR IMPLIED, AND APPLE HEREBY DISCLAIMS ALL SUCH WARRANTIES,
* INCLUDING WITHOUT LIMITATION, ANY WARRANTIES OF MERCHANTABILITY,
* FITNESS FOR A PARTICULAR PURPOSE, QUIET ENJOYMENT OR NON-INFRINGEMENT.
* Please see the License for the specific language governing rights and
* limitations under the License.
*
* @APPLE_LICENSE_HEADER_END@
*/
#import <XCTest/XCTest.h>
#import <OCMock/OCMock.h>
#import <CloudKit/CloudKit.h>
#import <CloudKit/CloudKit_Private.h>
#import "keychain/ckks/CKKS.h"
#import "keychain/ckks/CKKSAPSReceiver.h"
#import "keychain/ckks/tests/CKKSAPSReceiverTests.h"
#import "keychain/ckks/tests/MockCloudKit.h"
#import "keychain/ckks/CKKSCondition.h"
#if OCTAGON
@interface CKKSAPSNotificationReceiver : NSObject <CKKSZoneUpdateReceiver>
@property XCTestExpectation* expectation;
@property void (^block)(CKRecordZoneNotification* notification);
- (instancetype)initWithExpectation:(XCTestExpectation*)expectation;
- (instancetype)initWithExpectation:(XCTestExpectation*)expectation block:(void (^)(CKRecordZoneNotification* notification))block;
@end
@implementation CKKSAPSNotificationReceiver
- (instancetype)initWithExpectation:(XCTestExpectation*)expectation {
return [self initWithExpectation:expectation block:nil];
}
- (instancetype)initWithExpectation:(XCTestExpectation*)expectation block:(void (^)(CKRecordZoneNotification* notification))block
{
if((self = [super init])) {
_expectation = expectation;
_block = block;
}
return self;
}
- (void)notifyZoneChange: (CKRecordZoneNotification*) notification {
[self.expectation fulfill];
self.block(notification);
}
@end
@implementation CKKSAPSReceiverTests
+ (APSIncomingMessage*)messageForZoneID:(CKRecordZoneID*)zoneID {
// reverse engineered from source code. Ugly.
NSMutableDictionary* zoneInfo = [[NSMutableDictionary alloc] init];
zoneInfo[@"zid"] = zoneID.zoneName; // kCKNotificationCKRecordZoneRecordZoneIDKey
NSMutableDictionary* ckinfo = [[NSMutableDictionary alloc] init];
ckinfo[@"fet"] = zoneInfo; // kCKNotificationCKRecordZoneKey
NSMutableDictionary* d = [[NSMutableDictionary alloc] init];
d[@"ck"] = ckinfo; // kCKNotificationCKKey
return [[APSIncomingMessage alloc] initWithTopic:@"i'm-not-sure" userInfo:d];
}
- (void)setUp {
[super setUp];
self.testZoneID = [[CKRecordZoneID alloc] initWithZoneName:@"testzone" ownerName:CKCurrentUserDefaultName];
// Make sure our helpers work properly
APSIncomingMessage* message = [CKKSAPSReceiverTests messageForZoneID:self.testZoneID];
XCTAssertNotNil(message, "Should have received a APSIncomingMessage");
CKNotification* notification = [CKNotification notificationFromRemoteNotificationDictionary:message.userInfo];
XCTAssertNotNil(notification, "Should have received a CKNotification");
XCTAssert([notification isKindOfClass: [CKRecordZoneNotification class]], "Should have received a CKRecordZoneNotification");
CKRecordZoneNotification* ckrzn = (CKRecordZoneNotification*) notification;
XCTAssertEqual(self.testZoneID, ckrzn.recordZoneID, "Should have received a notification for the test zone");
}
- (void)tearDown {
self.testZoneID = nil;
[super tearDown];
}
- (void)testRegisterAndReceive {
__weak __typeof(self)weakSelf = self;
CKKSAPSReceiver* apsr = [[CKKSAPSReceiver alloc] initWithEnvironmentName:@"testenvironment"
namedDelegatePort:SecCKKSAPSNamedPort
apsConnectionClass:[FakeAPSConnection class]];
XCTAssertNotNil(apsr, "Should have received a CKKSAPSReceiver");
CKKSAPSNotificationReceiver* anr = [[CKKSAPSNotificationReceiver alloc] initWithExpectation:[self expectationWithDescription:@"receive notification"]
block:
^(CKRecordZoneNotification* notification) {
__strong __typeof(self) strongSelf = weakSelf;
XCTAssertNotNil(notification, "Should have received a notification");
XCTAssertEqual(strongSelf.testZoneID, notification.recordZoneID, "Should have received a notification for the test zone");
}];
CKKSCondition* registered = [apsr registerReceiver:anr forZoneID:self.testZoneID];
XCTAssertEqual(0, [registered wait:1*NSEC_PER_SEC], "Registration should have completed within a second");
APSIncomingMessage* message = [CKKSAPSReceiverTests messageForZoneID:self.testZoneID];
XCTAssertNotNil(message, "Should have received a APSIncomingMessage");
[apsr connection:apsr.apsConnection didReceiveIncomingMessage:message];
[self waitForExpectationsWithTimeout:5.0 handler:nil];
}
- (void)testRegisterMultipleAndReceive {
__weak __typeof(self)weakSelf = self;
CKKSAPSReceiver* apsr = [[CKKSAPSReceiver alloc] initWithEnvironmentName:@"testenvironment"
namedDelegatePort:SecCKKSAPSNamedPort
apsConnectionClass:[FakeAPSConnection class]];
XCTAssertNotNil(apsr, "Should have received a CKKSAPSReceiver");
CKRecordZoneID* otherZoneID = [[CKRecordZoneID alloc] initWithZoneName:@"otherzone" ownerName:CKCurrentUserDefaultName];
CKKSAPSNotificationReceiver* anr = [[CKKSAPSNotificationReceiver alloc] initWithExpectation:[self expectationWithDescription:@"receive testZoneID notification"]
block:
^(CKRecordZoneNotification* notification) {
__strong __typeof(self) strongSelf = weakSelf;
XCTAssertNotNil(notification, "Should have received a notification");
XCTAssertEqual(strongSelf.testZoneID, notification.recordZoneID, "Should have received a notification for the test zone");
}];
CKKSAPSNotificationReceiver* anr2 = [[CKKSAPSNotificationReceiver alloc] initWithExpectation:[self expectationWithDescription:@"receive otherzone notification"]
block:
^(CKRecordZoneNotification* notification) {
XCTAssertNotNil(notification, "Should have received a notification");
XCTAssertEqual(otherZoneID, notification.recordZoneID, "Should have received a notification for the test zone");
}];
CKKSCondition* registered = [apsr registerReceiver:anr forZoneID:self.testZoneID];
CKKSCondition* registered2 = [apsr registerReceiver:anr2 forZoneID:otherZoneID];
XCTAssertEqual(0, [registered wait:1*NSEC_PER_SEC], "Registration should have completed within a second");
XCTAssertEqual(0, [registered2 wait:1*NSEC_PER_SEC], "Registration should have completed within a second");
[apsr connection:apsr.apsConnection didReceiveIncomingMessage:[CKKSAPSReceiverTests messageForZoneID:self.testZoneID]];
[apsr connection:apsr.apsConnection didReceiveIncomingMessage:[CKKSAPSReceiverTests messageForZoneID:otherZoneID]];
[self waitForExpectationsWithTimeout:5.0 handler:nil];
}
- (void)testReceiveNotificationIfRegisteredAfterDelivery {
CKKSAPSReceiver* apsr = [[CKKSAPSReceiver alloc] initWithEnvironmentName:@"testenvironment"
namedDelegatePort:SecCKKSAPSNamedPort
apsConnectionClass:[FakeAPSConnection class]];
XCTAssertNotNil(apsr, "Should have received a CKKSAPSReceiver");
// Receives a notification for the test zone
APSIncomingMessage* message = [CKKSAPSReceiverTests messageForZoneID:self.testZoneID];
XCTAssertNotNil(message, "Should have received a APSIncomingMessage");
[apsr connection:apsr.apsConnection didReceiveIncomingMessage:message];
CKKSAPSNotificationReceiver* anr = [[CKKSAPSNotificationReceiver alloc] initWithExpectation:[self expectationWithDescription:@"receive notification"]
block:
^(CKRecordZoneNotification* notification) {
XCTAssertNotNil(notification, "Should have received a (stored) notification");
}];
CKKSCondition* registered = [apsr registerReceiver:anr forZoneID:self.testZoneID];
XCTAssertEqual(0, [registered wait:1*NSEC_PER_SEC], "Registration should have completed within a second");
[self waitForExpectationsWithTimeout:5.0 handler:nil];
}
@end
#endif