// // Copyright 2010-2020 Amazon.com, Inc. or its affiliates. All Rights Reserved. // // Licensed under the Apache License, Version 2.0 (the "License"). // You may not use this file except in compliance with the License. // A copy of the License is located at // // http://aws.amazon.com/apache2.0 // // or in the "license" file accompanying this file. This file is distributed // on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either // express or implied. See the License for the specific language governing // permissions and limitations under the License. // #import <UIKit/UIKit.h> #import <XCTest/XCTest.h> #import "OCMock.h" #import "AWSTestUtility.h" #import "AWSKinesisService.h" static id mockNetworking = nil; @interface AWSGeneralKinesisTests : XCTestCase @end @implementation AWSGeneralKinesisTests - (void)setUp { [super setUp]; [AWSTestUtility setupFakeCognitoCredentialsProvider]; mockNetworking = OCMClassMock([AWSNetworking class]); AWSTask *errorTask = [AWSTask taskWithError:[NSError errorWithDomain:@"OCMockExpectedNetworkingError" code:8848 userInfo:nil]]; OCMStub([mockNetworking sendRequest:[OCMArg isKindOfClass:[AWSNetworkingRequest class]]]).andReturn(errorTask); } - (void)tearDown { [super tearDown]; } - (void)testConstructors { NSString *key = @"testKinesisConstructors"; XCTAssertNotNil([AWSKinesis defaultKinesis]); XCTAssertEqual([[AWSKinesis defaultKinesis] class], [AWSKinesis class]); XCTAssertNil([AWSKinesis KinesisForKey:key]); AWSServiceConfiguration *configuration = [[AWSServiceConfiguration alloc] initWithRegion:AWSRegionSAEast1 credentialsProvider:[AWSServiceManager defaultServiceManager].defaultServiceConfiguration.credentialsProvider]; [AWSKinesis registerKinesisWithConfiguration:configuration forKey:key]; XCTAssertNotNil([AWSKinesis KinesisForKey:key]); XCTAssertEqual([[AWSKinesis KinesisForKey:key] class], [AWSKinesis class]); XCTAssertEqual([AWSKinesis KinesisForKey:key].configuration.regionType, AWSRegionSAEast1); [AWSKinesis removeKinesisForKey:key]; XCTAssertNil([AWSKinesis KinesisForKey:key]); } - (void)testAddTagsToStream { NSString *key = @"testAddTagsToStream"; AWSServiceConfiguration *configuration = [[AWSServiceConfiguration alloc] initWithRegion:AWSRegionUSEast1 credentialsProvider:nil]; [AWSKinesis registerKinesisWithConfiguration:configuration forKey:key]; AWSKinesis *awsClient = [AWSKinesis KinesisForKey:key]; XCTAssertNotNil(awsClient); XCTAssertNotNil(mockNetworking); [awsClient setValue:mockNetworking forKey:@"networking"]; [[[[AWSKinesis KinesisForKey:key] addTagsToStream:[AWSKinesisAddTagsToStreamInput new]] continueWithBlock:^id(AWSTask *task) { XCTAssertNotNil(task.error); XCTAssertEqualObjects(@"OCMockExpectedNetworkingError", task.error.domain); XCTAssertEqual(8848, task.error.code); XCTAssertNil(task.result); return nil; }] waitUntilFinished]; OCMVerify([mockNetworking sendRequest:[OCMArg isNotNil]]); [AWSKinesis removeKinesisForKey:key]; } - (void)testAddTagsToStreamCompletionHandler { NSString *key = @"testAddTagsToStream"; AWSServiceConfiguration *configuration = [[AWSServiceConfiguration alloc] initWithRegion:AWSRegionUSEast1 credentialsProvider:nil]; [AWSKinesis registerKinesisWithConfiguration:configuration forKey:key]; AWSKinesis *awsClient = [AWSKinesis KinesisForKey:key]; XCTAssertNotNil(awsClient); XCTAssertNotNil(mockNetworking); [awsClient setValue:mockNetworking forKey:@"networking"]; dispatch_semaphore_t semaphore = dispatch_semaphore_create(0); [[AWSKinesis KinesisForKey:key] addTagsToStream:[AWSKinesisAddTagsToStreamInput new] completionHandler:^(NSError * _Nullable error) { XCTAssertNotNil(error); XCTAssertEqualObjects(@"OCMockExpectedNetworkingError", error.domain); XCTAssertEqual(8848, error.code); dispatch_semaphore_signal(semaphore); }]; dispatch_semaphore_wait(semaphore, dispatch_time(DISPATCH_TIME_NOW, (int)(2.0 * NSEC_PER_SEC))); OCMVerify([mockNetworking sendRequest:[OCMArg isNotNil]]); [AWSKinesis removeKinesisForKey:key]; } - (void)testCreateStream { NSString *key = @"testCreateStream"; AWSServiceConfiguration *configuration = [[AWSServiceConfiguration alloc] initWithRegion:AWSRegionUSEast1 credentialsProvider:nil]; [AWSKinesis registerKinesisWithConfiguration:configuration forKey:key]; AWSKinesis *awsClient = [AWSKinesis KinesisForKey:key]; XCTAssertNotNil(awsClient); XCTAssertNotNil(mockNetworking); [awsClient setValue:mockNetworking forKey:@"networking"]; [[[[AWSKinesis KinesisForKey:key] createStream:[AWSKinesisCreateStreamInput new]] continueWithBlock:^id(AWSTask *task) { XCTAssertNotNil(task.error); XCTAssertEqualObjects(@"OCMockExpectedNetworkingError", task.error.domain); XCTAssertEqual(8848, task.error.code); XCTAssertNil(task.result); return nil; }] waitUntilFinished]; OCMVerify([mockNetworking sendRequest:[OCMArg isNotNil]]); [AWSKinesis removeKinesisForKey:key]; } - (void)testCreateStreamCompletionHandler { NSString *key = @"testCreateStream"; AWSServiceConfiguration *configuration = [[AWSServiceConfiguration alloc] initWithRegion:AWSRegionUSEast1 credentialsProvider:nil]; [AWSKinesis registerKinesisWithConfiguration:configuration forKey:key]; AWSKinesis *awsClient = [AWSKinesis KinesisForKey:key]; XCTAssertNotNil(awsClient); XCTAssertNotNil(mockNetworking); [awsClient setValue:mockNetworking forKey:@"networking"]; dispatch_semaphore_t semaphore = dispatch_semaphore_create(0); [[AWSKinesis KinesisForKey:key] createStream:[AWSKinesisCreateStreamInput new] completionHandler:^(NSError * _Nullable error) { XCTAssertNotNil(error); XCTAssertEqualObjects(@"OCMockExpectedNetworkingError", error.domain); XCTAssertEqual(8848, error.code); dispatch_semaphore_signal(semaphore); }]; dispatch_semaphore_wait(semaphore, dispatch_time(DISPATCH_TIME_NOW, (int)(2.0 * NSEC_PER_SEC))); OCMVerify([mockNetworking sendRequest:[OCMArg isNotNil]]); [AWSKinesis removeKinesisForKey:key]; } - (void)testDecreaseStreamRetentionPeriod { NSString *key = @"testDecreaseStreamRetentionPeriod"; AWSServiceConfiguration *configuration = [[AWSServiceConfiguration alloc] initWithRegion:AWSRegionUSEast1 credentialsProvider:nil]; [AWSKinesis registerKinesisWithConfiguration:configuration forKey:key]; AWSKinesis *awsClient = [AWSKinesis KinesisForKey:key]; XCTAssertNotNil(awsClient); XCTAssertNotNil(mockNetworking); [awsClient setValue:mockNetworking forKey:@"networking"]; [[[[AWSKinesis KinesisForKey:key] decreaseStreamRetentionPeriod:[AWSKinesisDecreaseStreamRetentionPeriodInput new]] continueWithBlock:^id(AWSTask *task) { XCTAssertNotNil(task.error); XCTAssertEqualObjects(@"OCMockExpectedNetworkingError", task.error.domain); XCTAssertEqual(8848, task.error.code); XCTAssertNil(task.result); return nil; }] waitUntilFinished]; OCMVerify([mockNetworking sendRequest:[OCMArg isNotNil]]); [AWSKinesis removeKinesisForKey:key]; } - (void)testDecreaseStreamRetentionPeriodCompletionHandler { NSString *key = @"testDecreaseStreamRetentionPeriod"; AWSServiceConfiguration *configuration = [[AWSServiceConfiguration alloc] initWithRegion:AWSRegionUSEast1 credentialsProvider:nil]; [AWSKinesis registerKinesisWithConfiguration:configuration forKey:key]; AWSKinesis *awsClient = [AWSKinesis KinesisForKey:key]; XCTAssertNotNil(awsClient); XCTAssertNotNil(mockNetworking); [awsClient setValue:mockNetworking forKey:@"networking"]; dispatch_semaphore_t semaphore = dispatch_semaphore_create(0); [[AWSKinesis KinesisForKey:key] decreaseStreamRetentionPeriod:[AWSKinesisDecreaseStreamRetentionPeriodInput new] completionHandler:^(NSError * _Nullable error) { XCTAssertNotNil(error); XCTAssertEqualObjects(@"OCMockExpectedNetworkingError", error.domain); XCTAssertEqual(8848, error.code); dispatch_semaphore_signal(semaphore); }]; dispatch_semaphore_wait(semaphore, dispatch_time(DISPATCH_TIME_NOW, (int)(2.0 * NSEC_PER_SEC))); OCMVerify([mockNetworking sendRequest:[OCMArg isNotNil]]); [AWSKinesis removeKinesisForKey:key]; } - (void)testDeleteStream { NSString *key = @"testDeleteStream"; AWSServiceConfiguration *configuration = [[AWSServiceConfiguration alloc] initWithRegion:AWSRegionUSEast1 credentialsProvider:nil]; [AWSKinesis registerKinesisWithConfiguration:configuration forKey:key]; AWSKinesis *awsClient = [AWSKinesis KinesisForKey:key]; XCTAssertNotNil(awsClient); XCTAssertNotNil(mockNetworking); [awsClient setValue:mockNetworking forKey:@"networking"]; [[[[AWSKinesis KinesisForKey:key] deleteStream:[AWSKinesisDeleteStreamInput new]] continueWithBlock:^id(AWSTask *task) { XCTAssertNotNil(task.error); XCTAssertEqualObjects(@"OCMockExpectedNetworkingError", task.error.domain); XCTAssertEqual(8848, task.error.code); XCTAssertNil(task.result); return nil; }] waitUntilFinished]; OCMVerify([mockNetworking sendRequest:[OCMArg isNotNil]]); [AWSKinesis removeKinesisForKey:key]; } - (void)testDeleteStreamCompletionHandler { NSString *key = @"testDeleteStream"; AWSServiceConfiguration *configuration = [[AWSServiceConfiguration alloc] initWithRegion:AWSRegionUSEast1 credentialsProvider:nil]; [AWSKinesis registerKinesisWithConfiguration:configuration forKey:key]; AWSKinesis *awsClient = [AWSKinesis KinesisForKey:key]; XCTAssertNotNil(awsClient); XCTAssertNotNil(mockNetworking); [awsClient setValue:mockNetworking forKey:@"networking"]; dispatch_semaphore_t semaphore = dispatch_semaphore_create(0); [[AWSKinesis KinesisForKey:key] deleteStream:[AWSKinesisDeleteStreamInput new] completionHandler:^(NSError * _Nullable error) { XCTAssertNotNil(error); XCTAssertEqualObjects(@"OCMockExpectedNetworkingError", error.domain); XCTAssertEqual(8848, error.code); dispatch_semaphore_signal(semaphore); }]; dispatch_semaphore_wait(semaphore, dispatch_time(DISPATCH_TIME_NOW, (int)(2.0 * NSEC_PER_SEC))); OCMVerify([mockNetworking sendRequest:[OCMArg isNotNil]]); [AWSKinesis removeKinesisForKey:key]; } - (void)testDescribeLimits { NSString *key = @"testDescribeLimits"; AWSServiceConfiguration *configuration = [[AWSServiceConfiguration alloc] initWithRegion:AWSRegionUSEast1 credentialsProvider:nil]; [AWSKinesis registerKinesisWithConfiguration:configuration forKey:key]; AWSKinesis *awsClient = [AWSKinesis KinesisForKey:key]; XCTAssertNotNil(awsClient); XCTAssertNotNil(mockNetworking); [awsClient setValue:mockNetworking forKey:@"networking"]; [[[[AWSKinesis KinesisForKey:key] describeLimits:[AWSKinesisDescribeLimitsInput new]] continueWithBlock:^id(AWSTask *task) { XCTAssertNotNil(task.error); XCTAssertEqualObjects(@"OCMockExpectedNetworkingError", task.error.domain); XCTAssertEqual(8848, task.error.code); XCTAssertNil(task.result); return nil; }] waitUntilFinished]; OCMVerify([mockNetworking sendRequest:[OCMArg isNotNil]]); [AWSKinesis removeKinesisForKey:key]; } - (void)testDescribeLimitsCompletionHandler { NSString *key = @"testDescribeLimits"; AWSServiceConfiguration *configuration = [[AWSServiceConfiguration alloc] initWithRegion:AWSRegionUSEast1 credentialsProvider:nil]; [AWSKinesis registerKinesisWithConfiguration:configuration forKey:key]; AWSKinesis *awsClient = [AWSKinesis KinesisForKey:key]; XCTAssertNotNil(awsClient); XCTAssertNotNil(mockNetworking); [awsClient setValue:mockNetworking forKey:@"networking"]; dispatch_semaphore_t semaphore = dispatch_semaphore_create(0); [[AWSKinesis KinesisForKey:key] describeLimits:[AWSKinesisDescribeLimitsInput new] completionHandler:^(AWSKinesisDescribeLimitsOutput* _Nullable response, NSError * _Nullable error) { XCTAssertNotNil(error); XCTAssertEqualObjects(@"OCMockExpectedNetworkingError", error.domain); XCTAssertEqual(8848, error.code); XCTAssertNil(response); dispatch_semaphore_signal(semaphore); }]; dispatch_semaphore_wait(semaphore, dispatch_time(DISPATCH_TIME_NOW, (int)(2.0 * NSEC_PER_SEC))); OCMVerify([mockNetworking sendRequest:[OCMArg isNotNil]]); [AWSKinesis removeKinesisForKey:key]; } - (void)testDescribeStream { NSString *key = @"testDescribeStream"; AWSServiceConfiguration *configuration = [[AWSServiceConfiguration alloc] initWithRegion:AWSRegionUSEast1 credentialsProvider:nil]; [AWSKinesis registerKinesisWithConfiguration:configuration forKey:key]; AWSKinesis *awsClient = [AWSKinesis KinesisForKey:key]; XCTAssertNotNil(awsClient); XCTAssertNotNil(mockNetworking); [awsClient setValue:mockNetworking forKey:@"networking"]; [[[[AWSKinesis KinesisForKey:key] describeStream:[AWSKinesisDescribeStreamInput new]] continueWithBlock:^id(AWSTask *task) { XCTAssertNotNil(task.error); XCTAssertEqualObjects(@"OCMockExpectedNetworkingError", task.error.domain); XCTAssertEqual(8848, task.error.code); XCTAssertNil(task.result); return nil; }] waitUntilFinished]; OCMVerify([mockNetworking sendRequest:[OCMArg isNotNil]]); [AWSKinesis removeKinesisForKey:key]; } - (void)testDescribeStreamCompletionHandler { NSString *key = @"testDescribeStream"; AWSServiceConfiguration *configuration = [[AWSServiceConfiguration alloc] initWithRegion:AWSRegionUSEast1 credentialsProvider:nil]; [AWSKinesis registerKinesisWithConfiguration:configuration forKey:key]; AWSKinesis *awsClient = [AWSKinesis KinesisForKey:key]; XCTAssertNotNil(awsClient); XCTAssertNotNil(mockNetworking); [awsClient setValue:mockNetworking forKey:@"networking"]; dispatch_semaphore_t semaphore = dispatch_semaphore_create(0); [[AWSKinesis KinesisForKey:key] describeStream:[AWSKinesisDescribeStreamInput new] completionHandler:^(AWSKinesisDescribeStreamOutput* _Nullable response, NSError * _Nullable error) { XCTAssertNotNil(error); XCTAssertEqualObjects(@"OCMockExpectedNetworkingError", error.domain); XCTAssertEqual(8848, error.code); XCTAssertNil(response); dispatch_semaphore_signal(semaphore); }]; dispatch_semaphore_wait(semaphore, dispatch_time(DISPATCH_TIME_NOW, (int)(2.0 * NSEC_PER_SEC))); OCMVerify([mockNetworking sendRequest:[OCMArg isNotNil]]); [AWSKinesis removeKinesisForKey:key]; } - (void)testDescribeStreamSummary { NSString *key = @"testDescribeStreamSummary"; AWSServiceConfiguration *configuration = [[AWSServiceConfiguration alloc] initWithRegion:AWSRegionUSEast1 credentialsProvider:nil]; [AWSKinesis registerKinesisWithConfiguration:configuration forKey:key]; AWSKinesis *awsClient = [AWSKinesis KinesisForKey:key]; XCTAssertNotNil(awsClient); XCTAssertNotNil(mockNetworking); [awsClient setValue:mockNetworking forKey:@"networking"]; [[[[AWSKinesis KinesisForKey:key] describeStreamSummary:[AWSKinesisDescribeStreamSummaryInput new]] continueWithBlock:^id(AWSTask *task) { XCTAssertNotNil(task.error); XCTAssertEqualObjects(@"OCMockExpectedNetworkingError", task.error.domain); XCTAssertEqual(8848, task.error.code); XCTAssertNil(task.result); return nil; }] waitUntilFinished]; OCMVerify([mockNetworking sendRequest:[OCMArg isNotNil]]); [AWSKinesis removeKinesisForKey:key]; } - (void)testDescribeStreamSummaryCompletionHandler { NSString *key = @"testDescribeStreamSummary"; AWSServiceConfiguration *configuration = [[AWSServiceConfiguration alloc] initWithRegion:AWSRegionUSEast1 credentialsProvider:nil]; [AWSKinesis registerKinesisWithConfiguration:configuration forKey:key]; AWSKinesis *awsClient = [AWSKinesis KinesisForKey:key]; XCTAssertNotNil(awsClient); XCTAssertNotNil(mockNetworking); [awsClient setValue:mockNetworking forKey:@"networking"]; dispatch_semaphore_t semaphore = dispatch_semaphore_create(0); [[AWSKinesis KinesisForKey:key] describeStreamSummary:[AWSKinesisDescribeStreamSummaryInput new] completionHandler:^(AWSKinesisDescribeStreamSummaryOutput* _Nullable response, NSError * _Nullable error) { XCTAssertNotNil(error); XCTAssertEqualObjects(@"OCMockExpectedNetworkingError", error.domain); XCTAssertEqual(8848, error.code); XCTAssertNil(response); dispatch_semaphore_signal(semaphore); }]; dispatch_semaphore_wait(semaphore, dispatch_time(DISPATCH_TIME_NOW, (int)(2.0 * NSEC_PER_SEC))); OCMVerify([mockNetworking sendRequest:[OCMArg isNotNil]]); [AWSKinesis removeKinesisForKey:key]; } - (void)testDisableEnhancedMonitoring { NSString *key = @"testDisableEnhancedMonitoring"; AWSServiceConfiguration *configuration = [[AWSServiceConfiguration alloc] initWithRegion:AWSRegionUSEast1 credentialsProvider:nil]; [AWSKinesis registerKinesisWithConfiguration:configuration forKey:key]; AWSKinesis *awsClient = [AWSKinesis KinesisForKey:key]; XCTAssertNotNil(awsClient); XCTAssertNotNil(mockNetworking); [awsClient setValue:mockNetworking forKey:@"networking"]; [[[[AWSKinesis KinesisForKey:key] disableEnhancedMonitoring:[AWSKinesisDisableEnhancedMonitoringInput new]] continueWithBlock:^id(AWSTask *task) { XCTAssertNotNil(task.error); XCTAssertEqualObjects(@"OCMockExpectedNetworkingError", task.error.domain); XCTAssertEqual(8848, task.error.code); XCTAssertNil(task.result); return nil; }] waitUntilFinished]; OCMVerify([mockNetworking sendRequest:[OCMArg isNotNil]]); [AWSKinesis removeKinesisForKey:key]; } - (void)testDisableEnhancedMonitoringCompletionHandler { NSString *key = @"testDisableEnhancedMonitoring"; AWSServiceConfiguration *configuration = [[AWSServiceConfiguration alloc] initWithRegion:AWSRegionUSEast1 credentialsProvider:nil]; [AWSKinesis registerKinesisWithConfiguration:configuration forKey:key]; AWSKinesis *awsClient = [AWSKinesis KinesisForKey:key]; XCTAssertNotNil(awsClient); XCTAssertNotNil(mockNetworking); [awsClient setValue:mockNetworking forKey:@"networking"]; dispatch_semaphore_t semaphore = dispatch_semaphore_create(0); [[AWSKinesis KinesisForKey:key] disableEnhancedMonitoring:[AWSKinesisDisableEnhancedMonitoringInput new] completionHandler:^(AWSKinesisEnhancedMonitoringOutput* _Nullable response, NSError * _Nullable error) { XCTAssertNotNil(error); XCTAssertEqualObjects(@"OCMockExpectedNetworkingError", error.domain); XCTAssertEqual(8848, error.code); XCTAssertNil(response); dispatch_semaphore_signal(semaphore); }]; dispatch_semaphore_wait(semaphore, dispatch_time(DISPATCH_TIME_NOW, (int)(2.0 * NSEC_PER_SEC))); OCMVerify([mockNetworking sendRequest:[OCMArg isNotNil]]); [AWSKinesis removeKinesisForKey:key]; } - (void)testEnableEnhancedMonitoring { NSString *key = @"testEnableEnhancedMonitoring"; AWSServiceConfiguration *configuration = [[AWSServiceConfiguration alloc] initWithRegion:AWSRegionUSEast1 credentialsProvider:nil]; [AWSKinesis registerKinesisWithConfiguration:configuration forKey:key]; AWSKinesis *awsClient = [AWSKinesis KinesisForKey:key]; XCTAssertNotNil(awsClient); XCTAssertNotNil(mockNetworking); [awsClient setValue:mockNetworking forKey:@"networking"]; [[[[AWSKinesis KinesisForKey:key] enableEnhancedMonitoring:[AWSKinesisEnableEnhancedMonitoringInput new]] continueWithBlock:^id(AWSTask *task) { XCTAssertNotNil(task.error); XCTAssertEqualObjects(@"OCMockExpectedNetworkingError", task.error.domain); XCTAssertEqual(8848, task.error.code); XCTAssertNil(task.result); return nil; }] waitUntilFinished]; OCMVerify([mockNetworking sendRequest:[OCMArg isNotNil]]); [AWSKinesis removeKinesisForKey:key]; } - (void)testEnableEnhancedMonitoringCompletionHandler { NSString *key = @"testEnableEnhancedMonitoring"; AWSServiceConfiguration *configuration = [[AWSServiceConfiguration alloc] initWithRegion:AWSRegionUSEast1 credentialsProvider:nil]; [AWSKinesis registerKinesisWithConfiguration:configuration forKey:key]; AWSKinesis *awsClient = [AWSKinesis KinesisForKey:key]; XCTAssertNotNil(awsClient); XCTAssertNotNil(mockNetworking); [awsClient setValue:mockNetworking forKey:@"networking"]; dispatch_semaphore_t semaphore = dispatch_semaphore_create(0); [[AWSKinesis KinesisForKey:key] enableEnhancedMonitoring:[AWSKinesisEnableEnhancedMonitoringInput new] completionHandler:^(AWSKinesisEnhancedMonitoringOutput* _Nullable response, NSError * _Nullable error) { XCTAssertNotNil(error); XCTAssertEqualObjects(@"OCMockExpectedNetworkingError", error.domain); XCTAssertEqual(8848, error.code); XCTAssertNil(response); dispatch_semaphore_signal(semaphore); }]; dispatch_semaphore_wait(semaphore, dispatch_time(DISPATCH_TIME_NOW, (int)(2.0 * NSEC_PER_SEC))); OCMVerify([mockNetworking sendRequest:[OCMArg isNotNil]]); [AWSKinesis removeKinesisForKey:key]; } - (void)testGetRecords { NSString *key = @"testGetRecords"; AWSServiceConfiguration *configuration = [[AWSServiceConfiguration alloc] initWithRegion:AWSRegionUSEast1 credentialsProvider:nil]; [AWSKinesis registerKinesisWithConfiguration:configuration forKey:key]; AWSKinesis *awsClient = [AWSKinesis KinesisForKey:key]; XCTAssertNotNil(awsClient); XCTAssertNotNil(mockNetworking); [awsClient setValue:mockNetworking forKey:@"networking"]; [[[[AWSKinesis KinesisForKey:key] getRecords:[AWSKinesisGetRecordsInput new]] continueWithBlock:^id(AWSTask *task) { XCTAssertNotNil(task.error); XCTAssertEqualObjects(@"OCMockExpectedNetworkingError", task.error.domain); XCTAssertEqual(8848, task.error.code); XCTAssertNil(task.result); return nil; }] waitUntilFinished]; OCMVerify([mockNetworking sendRequest:[OCMArg isNotNil]]); [AWSKinesis removeKinesisForKey:key]; } - (void)testGetRecordsCompletionHandler { NSString *key = @"testGetRecords"; AWSServiceConfiguration *configuration = [[AWSServiceConfiguration alloc] initWithRegion:AWSRegionUSEast1 credentialsProvider:nil]; [AWSKinesis registerKinesisWithConfiguration:configuration forKey:key]; AWSKinesis *awsClient = [AWSKinesis KinesisForKey:key]; XCTAssertNotNil(awsClient); XCTAssertNotNil(mockNetworking); [awsClient setValue:mockNetworking forKey:@"networking"]; dispatch_semaphore_t semaphore = dispatch_semaphore_create(0); [[AWSKinesis KinesisForKey:key] getRecords:[AWSKinesisGetRecordsInput new] completionHandler:^(AWSKinesisGetRecordsOutput* _Nullable response, NSError * _Nullable error) { XCTAssertNotNil(error); XCTAssertEqualObjects(@"OCMockExpectedNetworkingError", error.domain); XCTAssertEqual(8848, error.code); XCTAssertNil(response); dispatch_semaphore_signal(semaphore); }]; dispatch_semaphore_wait(semaphore, dispatch_time(DISPATCH_TIME_NOW, (int)(2.0 * NSEC_PER_SEC))); OCMVerify([mockNetworking sendRequest:[OCMArg isNotNil]]); [AWSKinesis removeKinesisForKey:key]; } - (void)testGetShardIterator { NSString *key = @"testGetShardIterator"; AWSServiceConfiguration *configuration = [[AWSServiceConfiguration alloc] initWithRegion:AWSRegionUSEast1 credentialsProvider:nil]; [AWSKinesis registerKinesisWithConfiguration:configuration forKey:key]; AWSKinesis *awsClient = [AWSKinesis KinesisForKey:key]; XCTAssertNotNil(awsClient); XCTAssertNotNil(mockNetworking); [awsClient setValue:mockNetworking forKey:@"networking"]; [[[[AWSKinesis KinesisForKey:key] getShardIterator:[AWSKinesisGetShardIteratorInput new]] continueWithBlock:^id(AWSTask *task) { XCTAssertNotNil(task.error); XCTAssertEqualObjects(@"OCMockExpectedNetworkingError", task.error.domain); XCTAssertEqual(8848, task.error.code); XCTAssertNil(task.result); return nil; }] waitUntilFinished]; OCMVerify([mockNetworking sendRequest:[OCMArg isNotNil]]); [AWSKinesis removeKinesisForKey:key]; } - (void)testGetShardIteratorCompletionHandler { NSString *key = @"testGetShardIterator"; AWSServiceConfiguration *configuration = [[AWSServiceConfiguration alloc] initWithRegion:AWSRegionUSEast1 credentialsProvider:nil]; [AWSKinesis registerKinesisWithConfiguration:configuration forKey:key]; AWSKinesis *awsClient = [AWSKinesis KinesisForKey:key]; XCTAssertNotNil(awsClient); XCTAssertNotNil(mockNetworking); [awsClient setValue:mockNetworking forKey:@"networking"]; dispatch_semaphore_t semaphore = dispatch_semaphore_create(0); [[AWSKinesis KinesisForKey:key] getShardIterator:[AWSKinesisGetShardIteratorInput new] completionHandler:^(AWSKinesisGetShardIteratorOutput* _Nullable response, NSError * _Nullable error) { XCTAssertNotNil(error); XCTAssertEqualObjects(@"OCMockExpectedNetworkingError", error.domain); XCTAssertEqual(8848, error.code); XCTAssertNil(response); dispatch_semaphore_signal(semaphore); }]; dispatch_semaphore_wait(semaphore, dispatch_time(DISPATCH_TIME_NOW, (int)(2.0 * NSEC_PER_SEC))); OCMVerify([mockNetworking sendRequest:[OCMArg isNotNil]]); [AWSKinesis removeKinesisForKey:key]; } - (void)testIncreaseStreamRetentionPeriod { NSString *key = @"testIncreaseStreamRetentionPeriod"; AWSServiceConfiguration *configuration = [[AWSServiceConfiguration alloc] initWithRegion:AWSRegionUSEast1 credentialsProvider:nil]; [AWSKinesis registerKinesisWithConfiguration:configuration forKey:key]; AWSKinesis *awsClient = [AWSKinesis KinesisForKey:key]; XCTAssertNotNil(awsClient); XCTAssertNotNil(mockNetworking); [awsClient setValue:mockNetworking forKey:@"networking"]; [[[[AWSKinesis KinesisForKey:key] increaseStreamRetentionPeriod:[AWSKinesisIncreaseStreamRetentionPeriodInput new]] continueWithBlock:^id(AWSTask *task) { XCTAssertNotNil(task.error); XCTAssertEqualObjects(@"OCMockExpectedNetworkingError", task.error.domain); XCTAssertEqual(8848, task.error.code); XCTAssertNil(task.result); return nil; }] waitUntilFinished]; OCMVerify([mockNetworking sendRequest:[OCMArg isNotNil]]); [AWSKinesis removeKinesisForKey:key]; } - (void)testIncreaseStreamRetentionPeriodCompletionHandler { NSString *key = @"testIncreaseStreamRetentionPeriod"; AWSServiceConfiguration *configuration = [[AWSServiceConfiguration alloc] initWithRegion:AWSRegionUSEast1 credentialsProvider:nil]; [AWSKinesis registerKinesisWithConfiguration:configuration forKey:key]; AWSKinesis *awsClient = [AWSKinesis KinesisForKey:key]; XCTAssertNotNil(awsClient); XCTAssertNotNil(mockNetworking); [awsClient setValue:mockNetworking forKey:@"networking"]; dispatch_semaphore_t semaphore = dispatch_semaphore_create(0); [[AWSKinesis KinesisForKey:key] increaseStreamRetentionPeriod:[AWSKinesisIncreaseStreamRetentionPeriodInput new] completionHandler:^(NSError * _Nullable error) { XCTAssertNotNil(error); XCTAssertEqualObjects(@"OCMockExpectedNetworkingError", error.domain); XCTAssertEqual(8848, error.code); dispatch_semaphore_signal(semaphore); }]; dispatch_semaphore_wait(semaphore, dispatch_time(DISPATCH_TIME_NOW, (int)(2.0 * NSEC_PER_SEC))); OCMVerify([mockNetworking sendRequest:[OCMArg isNotNil]]); [AWSKinesis removeKinesisForKey:key]; } - (void)testListShards { NSString *key = @"testListShards"; AWSServiceConfiguration *configuration = [[AWSServiceConfiguration alloc] initWithRegion:AWSRegionUSEast1 credentialsProvider:nil]; [AWSKinesis registerKinesisWithConfiguration:configuration forKey:key]; AWSKinesis *awsClient = [AWSKinesis KinesisForKey:key]; XCTAssertNotNil(awsClient); XCTAssertNotNil(mockNetworking); [awsClient setValue:mockNetworking forKey:@"networking"]; [[[[AWSKinesis KinesisForKey:key] listShards:[AWSKinesisListShardsInput new]] continueWithBlock:^id(AWSTask *task) { XCTAssertNotNil(task.error); XCTAssertEqualObjects(@"OCMockExpectedNetworkingError", task.error.domain); XCTAssertEqual(8848, task.error.code); XCTAssertNil(task.result); return nil; }] waitUntilFinished]; OCMVerify([mockNetworking sendRequest:[OCMArg isNotNil]]); [AWSKinesis removeKinesisForKey:key]; } - (void)testListShardsCompletionHandler { NSString *key = @"testListShards"; AWSServiceConfiguration *configuration = [[AWSServiceConfiguration alloc] initWithRegion:AWSRegionUSEast1 credentialsProvider:nil]; [AWSKinesis registerKinesisWithConfiguration:configuration forKey:key]; AWSKinesis *awsClient = [AWSKinesis KinesisForKey:key]; XCTAssertNotNil(awsClient); XCTAssertNotNil(mockNetworking); [awsClient setValue:mockNetworking forKey:@"networking"]; dispatch_semaphore_t semaphore = dispatch_semaphore_create(0); [[AWSKinesis KinesisForKey:key] listShards:[AWSKinesisListShardsInput new] completionHandler:^(AWSKinesisListShardsOutput* _Nullable response, NSError * _Nullable error) { XCTAssertNotNil(error); XCTAssertEqualObjects(@"OCMockExpectedNetworkingError", error.domain); XCTAssertEqual(8848, error.code); XCTAssertNil(response); dispatch_semaphore_signal(semaphore); }]; dispatch_semaphore_wait(semaphore, dispatch_time(DISPATCH_TIME_NOW, (int)(2.0 * NSEC_PER_SEC))); OCMVerify([mockNetworking sendRequest:[OCMArg isNotNil]]); [AWSKinesis removeKinesisForKey:key]; } - (void)testListStreams { NSString *key = @"testListStreams"; AWSServiceConfiguration *configuration = [[AWSServiceConfiguration alloc] initWithRegion:AWSRegionUSEast1 credentialsProvider:nil]; [AWSKinesis registerKinesisWithConfiguration:configuration forKey:key]; AWSKinesis *awsClient = [AWSKinesis KinesisForKey:key]; XCTAssertNotNil(awsClient); XCTAssertNotNil(mockNetworking); [awsClient setValue:mockNetworking forKey:@"networking"]; [[[[AWSKinesis KinesisForKey:key] listStreams:[AWSKinesisListStreamsInput new]] continueWithBlock:^id(AWSTask *task) { XCTAssertNotNil(task.error); XCTAssertEqualObjects(@"OCMockExpectedNetworkingError", task.error.domain); XCTAssertEqual(8848, task.error.code); XCTAssertNil(task.result); return nil; }] waitUntilFinished]; OCMVerify([mockNetworking sendRequest:[OCMArg isNotNil]]); [AWSKinesis removeKinesisForKey:key]; } - (void)testListStreamsCompletionHandler { NSString *key = @"testListStreams"; AWSServiceConfiguration *configuration = [[AWSServiceConfiguration alloc] initWithRegion:AWSRegionUSEast1 credentialsProvider:nil]; [AWSKinesis registerKinesisWithConfiguration:configuration forKey:key]; AWSKinesis *awsClient = [AWSKinesis KinesisForKey:key]; XCTAssertNotNil(awsClient); XCTAssertNotNil(mockNetworking); [awsClient setValue:mockNetworking forKey:@"networking"]; dispatch_semaphore_t semaphore = dispatch_semaphore_create(0); [[AWSKinesis KinesisForKey:key] listStreams:[AWSKinesisListStreamsInput new] completionHandler:^(AWSKinesisListStreamsOutput* _Nullable response, NSError * _Nullable error) { XCTAssertNotNil(error); XCTAssertEqualObjects(@"OCMockExpectedNetworkingError", error.domain); XCTAssertEqual(8848, error.code); XCTAssertNil(response); dispatch_semaphore_signal(semaphore); }]; dispatch_semaphore_wait(semaphore, dispatch_time(DISPATCH_TIME_NOW, (int)(2.0 * NSEC_PER_SEC))); OCMVerify([mockNetworking sendRequest:[OCMArg isNotNil]]); [AWSKinesis removeKinesisForKey:key]; } - (void)testListTagsForStream { NSString *key = @"testListTagsForStream"; AWSServiceConfiguration *configuration = [[AWSServiceConfiguration alloc] initWithRegion:AWSRegionUSEast1 credentialsProvider:nil]; [AWSKinesis registerKinesisWithConfiguration:configuration forKey:key]; AWSKinesis *awsClient = [AWSKinesis KinesisForKey:key]; XCTAssertNotNil(awsClient); XCTAssertNotNil(mockNetworking); [awsClient setValue:mockNetworking forKey:@"networking"]; [[[[AWSKinesis KinesisForKey:key] listTagsForStream:[AWSKinesisListTagsForStreamInput new]] continueWithBlock:^id(AWSTask *task) { XCTAssertNotNil(task.error); XCTAssertEqualObjects(@"OCMockExpectedNetworkingError", task.error.domain); XCTAssertEqual(8848, task.error.code); XCTAssertNil(task.result); return nil; }] waitUntilFinished]; OCMVerify([mockNetworking sendRequest:[OCMArg isNotNil]]); [AWSKinesis removeKinesisForKey:key]; } - (void)testListTagsForStreamCompletionHandler { NSString *key = @"testListTagsForStream"; AWSServiceConfiguration *configuration = [[AWSServiceConfiguration alloc] initWithRegion:AWSRegionUSEast1 credentialsProvider:nil]; [AWSKinesis registerKinesisWithConfiguration:configuration forKey:key]; AWSKinesis *awsClient = [AWSKinesis KinesisForKey:key]; XCTAssertNotNil(awsClient); XCTAssertNotNil(mockNetworking); [awsClient setValue:mockNetworking forKey:@"networking"]; dispatch_semaphore_t semaphore = dispatch_semaphore_create(0); [[AWSKinesis KinesisForKey:key] listTagsForStream:[AWSKinesisListTagsForStreamInput new] completionHandler:^(AWSKinesisListTagsForStreamOutput* _Nullable response, NSError * _Nullable error) { XCTAssertNotNil(error); XCTAssertEqualObjects(@"OCMockExpectedNetworkingError", error.domain); XCTAssertEqual(8848, error.code); XCTAssertNil(response); dispatch_semaphore_signal(semaphore); }]; dispatch_semaphore_wait(semaphore, dispatch_time(DISPATCH_TIME_NOW, (int)(2.0 * NSEC_PER_SEC))); OCMVerify([mockNetworking sendRequest:[OCMArg isNotNil]]); [AWSKinesis removeKinesisForKey:key]; } - (void)testMergeShards { NSString *key = @"testMergeShards"; AWSServiceConfiguration *configuration = [[AWSServiceConfiguration alloc] initWithRegion:AWSRegionUSEast1 credentialsProvider:nil]; [AWSKinesis registerKinesisWithConfiguration:configuration forKey:key]; AWSKinesis *awsClient = [AWSKinesis KinesisForKey:key]; XCTAssertNotNil(awsClient); XCTAssertNotNil(mockNetworking); [awsClient setValue:mockNetworking forKey:@"networking"]; [[[[AWSKinesis KinesisForKey:key] mergeShards:[AWSKinesisMergeShardsInput new]] continueWithBlock:^id(AWSTask *task) { XCTAssertNotNil(task.error); XCTAssertEqualObjects(@"OCMockExpectedNetworkingError", task.error.domain); XCTAssertEqual(8848, task.error.code); XCTAssertNil(task.result); return nil; }] waitUntilFinished]; OCMVerify([mockNetworking sendRequest:[OCMArg isNotNil]]); [AWSKinesis removeKinesisForKey:key]; } - (void)testMergeShardsCompletionHandler { NSString *key = @"testMergeShards"; AWSServiceConfiguration *configuration = [[AWSServiceConfiguration alloc] initWithRegion:AWSRegionUSEast1 credentialsProvider:nil]; [AWSKinesis registerKinesisWithConfiguration:configuration forKey:key]; AWSKinesis *awsClient = [AWSKinesis KinesisForKey:key]; XCTAssertNotNil(awsClient); XCTAssertNotNil(mockNetworking); [awsClient setValue:mockNetworking forKey:@"networking"]; dispatch_semaphore_t semaphore = dispatch_semaphore_create(0); [[AWSKinesis KinesisForKey:key] mergeShards:[AWSKinesisMergeShardsInput new] completionHandler:^(NSError * _Nullable error) { XCTAssertNotNil(error); XCTAssertEqualObjects(@"OCMockExpectedNetworkingError", error.domain); XCTAssertEqual(8848, error.code); dispatch_semaphore_signal(semaphore); }]; dispatch_semaphore_wait(semaphore, dispatch_time(DISPATCH_TIME_NOW, (int)(2.0 * NSEC_PER_SEC))); OCMVerify([mockNetworking sendRequest:[OCMArg isNotNil]]); [AWSKinesis removeKinesisForKey:key]; } - (void)testPutRecord { NSString *key = @"testPutRecord"; AWSServiceConfiguration *configuration = [[AWSServiceConfiguration alloc] initWithRegion:AWSRegionUSEast1 credentialsProvider:nil]; [AWSKinesis registerKinesisWithConfiguration:configuration forKey:key]; AWSKinesis *awsClient = [AWSKinesis KinesisForKey:key]; XCTAssertNotNil(awsClient); XCTAssertNotNil(mockNetworking); [awsClient setValue:mockNetworking forKey:@"networking"]; [[[[AWSKinesis KinesisForKey:key] putRecord:[AWSKinesisPutRecordInput new]] continueWithBlock:^id(AWSTask *task) { XCTAssertNotNil(task.error); XCTAssertEqualObjects(@"OCMockExpectedNetworkingError", task.error.domain); XCTAssertEqual(8848, task.error.code); XCTAssertNil(task.result); return nil; }] waitUntilFinished]; OCMVerify([mockNetworking sendRequest:[OCMArg isNotNil]]); [AWSKinesis removeKinesisForKey:key]; } - (void)testPutRecordCompletionHandler { NSString *key = @"testPutRecord"; AWSServiceConfiguration *configuration = [[AWSServiceConfiguration alloc] initWithRegion:AWSRegionUSEast1 credentialsProvider:nil]; [AWSKinesis registerKinesisWithConfiguration:configuration forKey:key]; AWSKinesis *awsClient = [AWSKinesis KinesisForKey:key]; XCTAssertNotNil(awsClient); XCTAssertNotNil(mockNetworking); [awsClient setValue:mockNetworking forKey:@"networking"]; dispatch_semaphore_t semaphore = dispatch_semaphore_create(0); [[AWSKinesis KinesisForKey:key] putRecord:[AWSKinesisPutRecordInput new] completionHandler:^(AWSKinesisPutRecordOutput* _Nullable response, NSError * _Nullable error) { XCTAssertNotNil(error); XCTAssertEqualObjects(@"OCMockExpectedNetworkingError", error.domain); XCTAssertEqual(8848, error.code); XCTAssertNil(response); dispatch_semaphore_signal(semaphore); }]; dispatch_semaphore_wait(semaphore, dispatch_time(DISPATCH_TIME_NOW, (int)(2.0 * NSEC_PER_SEC))); OCMVerify([mockNetworking sendRequest:[OCMArg isNotNil]]); [AWSKinesis removeKinesisForKey:key]; } - (void)testPutRecords { NSString *key = @"testPutRecords"; AWSServiceConfiguration *configuration = [[AWSServiceConfiguration alloc] initWithRegion:AWSRegionUSEast1 credentialsProvider:nil]; [AWSKinesis registerKinesisWithConfiguration:configuration forKey:key]; AWSKinesis *awsClient = [AWSKinesis KinesisForKey:key]; XCTAssertNotNil(awsClient); XCTAssertNotNil(mockNetworking); [awsClient setValue:mockNetworking forKey:@"networking"]; [[[[AWSKinesis KinesisForKey:key] putRecords:[AWSKinesisPutRecordsInput new]] continueWithBlock:^id(AWSTask *task) { XCTAssertNotNil(task.error); XCTAssertEqualObjects(@"OCMockExpectedNetworkingError", task.error.domain); XCTAssertEqual(8848, task.error.code); XCTAssertNil(task.result); return nil; }] waitUntilFinished]; OCMVerify([mockNetworking sendRequest:[OCMArg isNotNil]]); [AWSKinesis removeKinesisForKey:key]; } - (void)testPutRecordsCompletionHandler { NSString *key = @"testPutRecords"; AWSServiceConfiguration *configuration = [[AWSServiceConfiguration alloc] initWithRegion:AWSRegionUSEast1 credentialsProvider:nil]; [AWSKinesis registerKinesisWithConfiguration:configuration forKey:key]; AWSKinesis *awsClient = [AWSKinesis KinesisForKey:key]; XCTAssertNotNil(awsClient); XCTAssertNotNil(mockNetworking); [awsClient setValue:mockNetworking forKey:@"networking"]; dispatch_semaphore_t semaphore = dispatch_semaphore_create(0); [[AWSKinesis KinesisForKey:key] putRecords:[AWSKinesisPutRecordsInput new] completionHandler:^(AWSKinesisPutRecordsOutput* _Nullable response, NSError * _Nullable error) { XCTAssertNotNil(error); XCTAssertEqualObjects(@"OCMockExpectedNetworkingError", error.domain); XCTAssertEqual(8848, error.code); XCTAssertNil(response); dispatch_semaphore_signal(semaphore); }]; dispatch_semaphore_wait(semaphore, dispatch_time(DISPATCH_TIME_NOW, (int)(2.0 * NSEC_PER_SEC))); OCMVerify([mockNetworking sendRequest:[OCMArg isNotNil]]); [AWSKinesis removeKinesisForKey:key]; } - (void)testRemoveTagsFromStream { NSString *key = @"testRemoveTagsFromStream"; AWSServiceConfiguration *configuration = [[AWSServiceConfiguration alloc] initWithRegion:AWSRegionUSEast1 credentialsProvider:nil]; [AWSKinesis registerKinesisWithConfiguration:configuration forKey:key]; AWSKinesis *awsClient = [AWSKinesis KinesisForKey:key]; XCTAssertNotNil(awsClient); XCTAssertNotNil(mockNetworking); [awsClient setValue:mockNetworking forKey:@"networking"]; [[[[AWSKinesis KinesisForKey:key] removeTagsFromStream:[AWSKinesisRemoveTagsFromStreamInput new]] continueWithBlock:^id(AWSTask *task) { XCTAssertNotNil(task.error); XCTAssertEqualObjects(@"OCMockExpectedNetworkingError", task.error.domain); XCTAssertEqual(8848, task.error.code); XCTAssertNil(task.result); return nil; }] waitUntilFinished]; OCMVerify([mockNetworking sendRequest:[OCMArg isNotNil]]); [AWSKinesis removeKinesisForKey:key]; } - (void)testRemoveTagsFromStreamCompletionHandler { NSString *key = @"testRemoveTagsFromStream"; AWSServiceConfiguration *configuration = [[AWSServiceConfiguration alloc] initWithRegion:AWSRegionUSEast1 credentialsProvider:nil]; [AWSKinesis registerKinesisWithConfiguration:configuration forKey:key]; AWSKinesis *awsClient = [AWSKinesis KinesisForKey:key]; XCTAssertNotNil(awsClient); XCTAssertNotNil(mockNetworking); [awsClient setValue:mockNetworking forKey:@"networking"]; dispatch_semaphore_t semaphore = dispatch_semaphore_create(0); [[AWSKinesis KinesisForKey:key] removeTagsFromStream:[AWSKinesisRemoveTagsFromStreamInput new] completionHandler:^(NSError * _Nullable error) { XCTAssertNotNil(error); XCTAssertEqualObjects(@"OCMockExpectedNetworkingError", error.domain); XCTAssertEqual(8848, error.code); dispatch_semaphore_signal(semaphore); }]; dispatch_semaphore_wait(semaphore, dispatch_time(DISPATCH_TIME_NOW, (int)(2.0 * NSEC_PER_SEC))); OCMVerify([mockNetworking sendRequest:[OCMArg isNotNil]]); [AWSKinesis removeKinesisForKey:key]; } - (void)testSplitShard { NSString *key = @"testSplitShard"; AWSServiceConfiguration *configuration = [[AWSServiceConfiguration alloc] initWithRegion:AWSRegionUSEast1 credentialsProvider:nil]; [AWSKinesis registerKinesisWithConfiguration:configuration forKey:key]; AWSKinesis *awsClient = [AWSKinesis KinesisForKey:key]; XCTAssertNotNil(awsClient); XCTAssertNotNil(mockNetworking); [awsClient setValue:mockNetworking forKey:@"networking"]; [[[[AWSKinesis KinesisForKey:key] splitShard:[AWSKinesisSplitShardInput new]] continueWithBlock:^id(AWSTask *task) { XCTAssertNotNil(task.error); XCTAssertEqualObjects(@"OCMockExpectedNetworkingError", task.error.domain); XCTAssertEqual(8848, task.error.code); XCTAssertNil(task.result); return nil; }] waitUntilFinished]; OCMVerify([mockNetworking sendRequest:[OCMArg isNotNil]]); [AWSKinesis removeKinesisForKey:key]; } - (void)testSplitShardCompletionHandler { NSString *key = @"testSplitShard"; AWSServiceConfiguration *configuration = [[AWSServiceConfiguration alloc] initWithRegion:AWSRegionUSEast1 credentialsProvider:nil]; [AWSKinesis registerKinesisWithConfiguration:configuration forKey:key]; AWSKinesis *awsClient = [AWSKinesis KinesisForKey:key]; XCTAssertNotNil(awsClient); XCTAssertNotNil(mockNetworking); [awsClient setValue:mockNetworking forKey:@"networking"]; dispatch_semaphore_t semaphore = dispatch_semaphore_create(0); [[AWSKinesis KinesisForKey:key] splitShard:[AWSKinesisSplitShardInput new] completionHandler:^(NSError * _Nullable error) { XCTAssertNotNil(error); XCTAssertEqualObjects(@"OCMockExpectedNetworkingError", error.domain); XCTAssertEqual(8848, error.code); dispatch_semaphore_signal(semaphore); }]; dispatch_semaphore_wait(semaphore, dispatch_time(DISPATCH_TIME_NOW, (int)(2.0 * NSEC_PER_SEC))); OCMVerify([mockNetworking sendRequest:[OCMArg isNotNil]]); [AWSKinesis removeKinesisForKey:key]; } - (void)testStartStreamEncryption { NSString *key = @"testStartStreamEncryption"; AWSServiceConfiguration *configuration = [[AWSServiceConfiguration alloc] initWithRegion:AWSRegionUSEast1 credentialsProvider:nil]; [AWSKinesis registerKinesisWithConfiguration:configuration forKey:key]; AWSKinesis *awsClient = [AWSKinesis KinesisForKey:key]; XCTAssertNotNil(awsClient); XCTAssertNotNil(mockNetworking); [awsClient setValue:mockNetworking forKey:@"networking"]; [[[[AWSKinesis KinesisForKey:key] startStreamEncryption:[AWSKinesisStartStreamEncryptionInput new]] continueWithBlock:^id(AWSTask *task) { XCTAssertNotNil(task.error); XCTAssertEqualObjects(@"OCMockExpectedNetworkingError", task.error.domain); XCTAssertEqual(8848, task.error.code); XCTAssertNil(task.result); return nil; }] waitUntilFinished]; OCMVerify([mockNetworking sendRequest:[OCMArg isNotNil]]); [AWSKinesis removeKinesisForKey:key]; } - (void)testStartStreamEncryptionCompletionHandler { NSString *key = @"testStartStreamEncryption"; AWSServiceConfiguration *configuration = [[AWSServiceConfiguration alloc] initWithRegion:AWSRegionUSEast1 credentialsProvider:nil]; [AWSKinesis registerKinesisWithConfiguration:configuration forKey:key]; AWSKinesis *awsClient = [AWSKinesis KinesisForKey:key]; XCTAssertNotNil(awsClient); XCTAssertNotNil(mockNetworking); [awsClient setValue:mockNetworking forKey:@"networking"]; dispatch_semaphore_t semaphore = dispatch_semaphore_create(0); [[AWSKinesis KinesisForKey:key] startStreamEncryption:[AWSKinesisStartStreamEncryptionInput new] completionHandler:^(NSError * _Nullable error) { XCTAssertNotNil(error); XCTAssertEqualObjects(@"OCMockExpectedNetworkingError", error.domain); XCTAssertEqual(8848, error.code); dispatch_semaphore_signal(semaphore); }]; dispatch_semaphore_wait(semaphore, dispatch_time(DISPATCH_TIME_NOW, (int)(2.0 * NSEC_PER_SEC))); OCMVerify([mockNetworking sendRequest:[OCMArg isNotNil]]); [AWSKinesis removeKinesisForKey:key]; } - (void)testStopStreamEncryption { NSString *key = @"testStopStreamEncryption"; AWSServiceConfiguration *configuration = [[AWSServiceConfiguration alloc] initWithRegion:AWSRegionUSEast1 credentialsProvider:nil]; [AWSKinesis registerKinesisWithConfiguration:configuration forKey:key]; AWSKinesis *awsClient = [AWSKinesis KinesisForKey:key]; XCTAssertNotNil(awsClient); XCTAssertNotNil(mockNetworking); [awsClient setValue:mockNetworking forKey:@"networking"]; [[[[AWSKinesis KinesisForKey:key] stopStreamEncryption:[AWSKinesisStopStreamEncryptionInput new]] continueWithBlock:^id(AWSTask *task) { XCTAssertNotNil(task.error); XCTAssertEqualObjects(@"OCMockExpectedNetworkingError", task.error.domain); XCTAssertEqual(8848, task.error.code); XCTAssertNil(task.result); return nil; }] waitUntilFinished]; OCMVerify([mockNetworking sendRequest:[OCMArg isNotNil]]); [AWSKinesis removeKinesisForKey:key]; } - (void)testStopStreamEncryptionCompletionHandler { NSString *key = @"testStopStreamEncryption"; AWSServiceConfiguration *configuration = [[AWSServiceConfiguration alloc] initWithRegion:AWSRegionUSEast1 credentialsProvider:nil]; [AWSKinesis registerKinesisWithConfiguration:configuration forKey:key]; AWSKinesis *awsClient = [AWSKinesis KinesisForKey:key]; XCTAssertNotNil(awsClient); XCTAssertNotNil(mockNetworking); [awsClient setValue:mockNetworking forKey:@"networking"]; dispatch_semaphore_t semaphore = dispatch_semaphore_create(0); [[AWSKinesis KinesisForKey:key] stopStreamEncryption:[AWSKinesisStopStreamEncryptionInput new] completionHandler:^(NSError * _Nullable error) { XCTAssertNotNil(error); XCTAssertEqualObjects(@"OCMockExpectedNetworkingError", error.domain); XCTAssertEqual(8848, error.code); dispatch_semaphore_signal(semaphore); }]; dispatch_semaphore_wait(semaphore, dispatch_time(DISPATCH_TIME_NOW, (int)(2.0 * NSEC_PER_SEC))); OCMVerify([mockNetworking sendRequest:[OCMArg isNotNil]]); [AWSKinesis removeKinesisForKey:key]; } - (void)testUpdateShardCount { NSString *key = @"testUpdateShardCount"; AWSServiceConfiguration *configuration = [[AWSServiceConfiguration alloc] initWithRegion:AWSRegionUSEast1 credentialsProvider:nil]; [AWSKinesis registerKinesisWithConfiguration:configuration forKey:key]; AWSKinesis *awsClient = [AWSKinesis KinesisForKey:key]; XCTAssertNotNil(awsClient); XCTAssertNotNil(mockNetworking); [awsClient setValue:mockNetworking forKey:@"networking"]; [[[[AWSKinesis KinesisForKey:key] updateShardCount:[AWSKinesisUpdateShardCountInput new]] continueWithBlock:^id(AWSTask *task) { XCTAssertNotNil(task.error); XCTAssertEqualObjects(@"OCMockExpectedNetworkingError", task.error.domain); XCTAssertEqual(8848, task.error.code); XCTAssertNil(task.result); return nil; }] waitUntilFinished]; OCMVerify([mockNetworking sendRequest:[OCMArg isNotNil]]); [AWSKinesis removeKinesisForKey:key]; } - (void)testUpdateShardCountCompletionHandler { NSString *key = @"testUpdateShardCount"; AWSServiceConfiguration *configuration = [[AWSServiceConfiguration alloc] initWithRegion:AWSRegionUSEast1 credentialsProvider:nil]; [AWSKinesis registerKinesisWithConfiguration:configuration forKey:key]; AWSKinesis *awsClient = [AWSKinesis KinesisForKey:key]; XCTAssertNotNil(awsClient); XCTAssertNotNil(mockNetworking); [awsClient setValue:mockNetworking forKey:@"networking"]; dispatch_semaphore_t semaphore = dispatch_semaphore_create(0); [[AWSKinesis KinesisForKey:key] updateShardCount:[AWSKinesisUpdateShardCountInput new] completionHandler:^(AWSKinesisUpdateShardCountOutput* _Nullable response, NSError * _Nullable error) { XCTAssertNotNil(error); XCTAssertEqualObjects(@"OCMockExpectedNetworkingError", error.domain); XCTAssertEqual(8848, error.code); XCTAssertNil(response); dispatch_semaphore_signal(semaphore); }]; dispatch_semaphore_wait(semaphore, dispatch_time(DISPATCH_TIME_NOW, (int)(2.0 * NSEC_PER_SEC))); OCMVerify([mockNetworking sendRequest:[OCMArg isNotNil]]); [AWSKinesis removeKinesisForKey:key]; } @end