|
|
|
@ -38,56 +38,62 @@ |
|
|
|
|
#import <gRPC/GRPCMethodName.h> |
|
|
|
|
#import <gRPC/GRXWriter+Immediate.h> |
|
|
|
|
#import <gRPC/GRXWriteable.h> |
|
|
|
|
#import <Route_guide/RouteGuide.pbobjc.h> |
|
|
|
|
#import <Route_guide/RouteGuide.pbrpc.h> |
|
|
|
|
#import <RouteGuide/RouteGuide.pbobjc.h> |
|
|
|
|
#import <RouteGuide/RouteGuide.pbrpc.h> |
|
|
|
|
|
|
|
|
|
// These tests require the gRPC-Java "RouteGuide" sample server to be running locally. To do so, |
|
|
|
|
// install Gradle by following the instructions here: https://docs.gradle.org/current/userguide/installation.html |
|
|
|
|
// And use it to run the server by following the instructions here: https://github.com/grpc/grpc-java/tree/master/examples |
|
|
|
|
// These tests require a gRPC "RouteGuide" sample server to be running locally. You can compile and |
|
|
|
|
// run one by following the instructions here: https://github.com/grpc/grpc-common/blob/master/cpp/cpptutorial.md#try-it-out |
|
|
|
|
// Be sure to have the C gRPC library installed in your system (for example, by having followed the |
|
|
|
|
// instructions at https://github.com/grpc/homebrew-grpc |
|
|
|
|
|
|
|
|
|
static NSString * const kRouteGuideHost = @"http://localhost:50051"; |
|
|
|
|
static NSString * const kPackage = @"examples"; |
|
|
|
|
static NSString * const kService = @"RouteGuide"; |
|
|
|
|
|
|
|
|
|
@interface LocalClearTextTests : XCTestCase |
|
|
|
|
@end |
|
|
|
|
|
|
|
|
|
@implementation LocalClearTextTests |
|
|
|
|
|
|
|
|
|
- (void)testConnectionToLocalServer { |
|
|
|
|
__weak XCTestExpectation *expectation = [self expectationWithDescription:@"Server reachable."]; |
|
|
|
|
|
|
|
|
|
// This method isn't implemented by the local server. |
|
|
|
|
GRPCMethodName *method = [[GRPCMethodName alloc] initWithPackage:@"grpc.testing" |
|
|
|
|
interface:@"TestService" |
|
|
|
|
method:@"EmptyCall"]; |
|
|
|
|
|
|
|
|
|
id<GRXWriter> requestsWriter = [GRXWriter writerWithValue:[NSData data]]; |
|
|
|
|
|
|
|
|
|
GRPCCall *call = [[GRPCCall alloc] initWithHost:@"http://127.0.0.1:8980" |
|
|
|
|
method:method |
|
|
|
|
requestsWriter:requestsWriter]; |
|
|
|
|
|
|
|
|
|
id<GRXWriteable> responsesWriteable = [[GRXWriteable alloc] initWithValueHandler:^(NSData *value) { |
|
|
|
|
XCTFail(@"Received unexpected response: %@", value); |
|
|
|
|
} completionHandler:^(NSError *errorOrNil) { |
|
|
|
|
XCTAssertNotNil(errorOrNil, @"Finished without error!"); |
|
|
|
|
XCTAssertEqual(errorOrNil.code, 12, @"Finished with unexpected error: %@", errorOrNil); |
|
|
|
|
[expectation fulfill]; |
|
|
|
|
}]; |
|
|
|
|
|
|
|
|
|
[call startWithWriteable:responsesWriteable]; |
|
|
|
|
|
|
|
|
|
[self waitForExpectationsWithTimeout:2.0 handler:nil]; |
|
|
|
|
} |
|
|
|
|
// This test currently fails: see Issue #1907. |
|
|
|
|
//- (void)testConnectionToLocalServer { |
|
|
|
|
// __weak XCTestExpectation *expectation = [self expectationWithDescription:@"Server reachable."]; |
|
|
|
|
// |
|
|
|
|
// // This method isn't implemented by the local server. |
|
|
|
|
// GRPCMethodName *method = [[GRPCMethodName alloc] initWithPackage:kPackage |
|
|
|
|
// interface:kService |
|
|
|
|
// method:@"EmptyCall"]; |
|
|
|
|
// |
|
|
|
|
// id<GRXWriter> requestsWriter = [GRXWriter writerWithValue:[NSData data]]; |
|
|
|
|
// |
|
|
|
|
// GRPCCall *call = [[GRPCCall alloc] initWithHost:kRouteGuideHost |
|
|
|
|
// method:method |
|
|
|
|
// requestsWriter:requestsWriter]; |
|
|
|
|
// |
|
|
|
|
// id<GRXWriteable> responsesWriteable = [[GRXWriteable alloc] initWithValueHandler:^(NSData *value) { |
|
|
|
|
// XCTFail(@"Received unexpected response: %@", value); |
|
|
|
|
// } completionHandler:^(NSError *errorOrNil) { |
|
|
|
|
// XCTAssertNotNil(errorOrNil, @"Finished without error!"); |
|
|
|
|
// XCTAssertEqual(errorOrNil.code, 12, @"Finished with unexpected error: %@", errorOrNil); |
|
|
|
|
// [expectation fulfill]; |
|
|
|
|
// }]; |
|
|
|
|
// |
|
|
|
|
// [call startWithWriteable:responsesWriteable]; |
|
|
|
|
// |
|
|
|
|
// [self waitForExpectationsWithTimeout:8.0 handler:nil]; |
|
|
|
|
//} |
|
|
|
|
|
|
|
|
|
- (void)testEmptyRPC { |
|
|
|
|
__weak XCTestExpectation *response = [self expectationWithDescription:@"Empty response received."]; |
|
|
|
|
__weak XCTestExpectation *completion = [self expectationWithDescription:@"Empty RPC completed."]; |
|
|
|
|
|
|
|
|
|
GRPCMethodName *method = [[GRPCMethodName alloc] initWithPackage:@"grpc.example.routeguide" |
|
|
|
|
interface:@"RouteGuide" |
|
|
|
|
GRPCMethodName *method = [[GRPCMethodName alloc] initWithPackage:kPackage |
|
|
|
|
interface:kService |
|
|
|
|
method:@"RecordRoute"]; |
|
|
|
|
|
|
|
|
|
id<GRXWriter> requestsWriter = [GRXWriter emptyWriter]; |
|
|
|
|
|
|
|
|
|
GRPCCall *call = [[GRPCCall alloc] initWithHost:@"http://127.0.0.1:8980" |
|
|
|
|
GRPCCall *call = [[GRPCCall alloc] initWithHost:kRouteGuideHost |
|
|
|
|
method:method |
|
|
|
|
requestsWriter:requestsWriter]; |
|
|
|
|
|
|
|
|
@ -109,8 +115,8 @@ |
|
|
|
|
__weak XCTestExpectation *response = [self expectationWithDescription:@"Response received."]; |
|
|
|
|
__weak XCTestExpectation *completion = [self expectationWithDescription:@"RPC completed."]; |
|
|
|
|
|
|
|
|
|
GRPCMethodName *method = [[GRPCMethodName alloc] initWithPackage:@"grpc.example.routeguide" |
|
|
|
|
interface:@"RouteGuide" |
|
|
|
|
GRPCMethodName *method = [[GRPCMethodName alloc] initWithPackage:kPackage |
|
|
|
|
interface:kService |
|
|
|
|
method:@"GetFeature"]; |
|
|
|
|
|
|
|
|
|
RGDPoint *point = [RGDPoint message]; |
|
|
|
@ -118,7 +124,7 @@ |
|
|
|
|
point.longitude = -15E7; |
|
|
|
|
id<GRXWriter> requestsWriter = [GRXWriter writerWithValue:[point data]]; |
|
|
|
|
|
|
|
|
|
GRPCCall *call = [[GRPCCall alloc] initWithHost:@"http://127.0.0.1:8980" |
|
|
|
|
GRPCCall *call = [[GRPCCall alloc] initWithHost:kRouteGuideHost |
|
|
|
|
method:method |
|
|
|
|
requestsWriter:requestsWriter]; |
|
|
|
|
|
|
|
|
@ -145,7 +151,7 @@ |
|
|
|
|
point.latitude = 28E7; |
|
|
|
|
point.longitude = -15E7; |
|
|
|
|
|
|
|
|
|
RGDRouteGuide *service = [[RGDRouteGuide alloc] initWithHost:@"http://127.0.0.1:8980"]; |
|
|
|
|
RGDRouteGuide *service = [[RGDRouteGuide alloc] initWithHost:kRouteGuideHost]; |
|
|
|
|
[service getFeatureWithRequest:point handler:^(RGDFeature *response, NSError *error) { |
|
|
|
|
XCTAssertNil(error, @"Finished with unexpected error: %@", error); |
|
|
|
|
XCTAssertEqualObjects(point, response.location); |
|
|
|
|