aboutsummaryrefslogtreecommitdiffhomepage
path: root/test/cpp/end2end
diff options
context:
space:
mode:
authorGravatar yangg <yangg@google.com>2015-01-09 14:19:44 -0800
committerGravatar Nicolas Noble <nnoble@google.com>2015-01-12 11:22:01 -0800
commit4105e2b86c91ecc3687def3abcbb602bee894b0a (patch)
treedbeed01da6a51b69f0a7651cac16541b99c293c5 /test/cpp/end2end
parent5d61ac074c26a1631cfdbd34d590c730139a9de6 (diff)
Add ServiceAccount Credentials wrapping and handle credentials creation
failure. Change on 2015/01/09 by yangg <yangg@google.com> ------------- Created by MOE: http://code.google.com/p/moe-java MOE_MIGRATED_REVID=83634736
Diffstat (limited to 'test/cpp/end2end')
-rw-r--r--test/cpp/end2end/end2end_test.cc33
1 files changed, 33 insertions, 0 deletions
diff --git a/test/cpp/end2end/end2end_test.cc b/test/cpp/end2end/end2end_test.cc
index f63f6ad076..1dcdd4202c 100644
--- a/test/cpp/end2end/end2end_test.cc
+++ b/test/cpp/end2end/end2end_test.cc
@@ -42,6 +42,7 @@
#include <grpc++/channel_interface.h>
#include <grpc++/client_context.h>
#include <grpc++/create_channel.h>
+#include <grpc++/credentials.h>
#include <grpc++/server.h>
#include <grpc++/server_builder.h>
#include <grpc++/server_context.h>
@@ -401,6 +402,38 @@ TEST_F(End2endTest, DiffPackageServices) {
EXPECT_TRUE(s.IsOk());
}
+// rpc and stream should fail on bad credentials.
+TEST_F(End2endTest, BadCredentials) {
+ std::unique_ptr<Credentials> bad_creds =
+ CredentialsFactory::ServiceAccountCredentials("", "",
+ std::chrono::seconds(1));
+ EXPECT_EQ(nullptr, bad_creds.get());
+ std::shared_ptr<ChannelInterface> channel =
+ CreateChannel(server_address_.str(), bad_creds, ChannelArguments());
+ std::unique_ptr<grpc::cpp::test::util::TestService::Stub> stub(
+ grpc::cpp::test::util::TestService::NewStub(channel));
+ EchoRequest request;
+ EchoResponse response;
+ ClientContext context;
+ grpc::string msg("hello");
+
+ Status s = stub->Echo(&context, request, &response);
+ EXPECT_EQ("", response.message());
+ EXPECT_FALSE(s.IsOk());
+ EXPECT_EQ(StatusCode::UNKNOWN, s.code());
+ EXPECT_EQ("Rpc sent on a lame channel.", s.details());
+
+ ClientContext context2;
+ ClientReaderWriter<EchoRequest, EchoResponse>* stream =
+ stub->BidiStream(&context2);
+ s = stream->Wait();
+ EXPECT_FALSE(s.IsOk());
+ EXPECT_EQ(StatusCode::UNKNOWN, s.code());
+ EXPECT_EQ("Rpc sent on a lame channel.", s.details());
+
+ delete stream;
+}
+
} // namespace testing
} // namespace grpc