()
| 431 | } |
| 432 | |
| 433 | @Test |
| 434 | public void mtls_succeeds() throws Exception { |
| 435 | ServerCredentials serverCreds; |
| 436 | try (InputStream serverCert = TlsTesting.loadCert("server1.pem"); |
| 437 | InputStream serverPrivateKey = TlsTesting.loadCert("server1.key"); |
| 438 | InputStream caCert = TlsTesting.loadCert("ca.pem")) { |
| 439 | serverCreds = TlsServerCredentials.newBuilder() |
| 440 | .keyManager(serverCert, serverPrivateKey) |
| 441 | .trustManager(caCert) |
| 442 | .clientAuth(TlsServerCredentials.ClientAuth.REQUIRE) |
| 443 | .build(); |
| 444 | } |
| 445 | ChannelCredentials channelCreds; |
| 446 | try (InputStream clientCertChain = TlsTesting.loadCert("client.pem"); |
| 447 | InputStream clientPrivateKey = TlsTesting.loadCert("client.key"); |
| 448 | InputStream caCert = TlsTesting.loadCert("ca.pem")) { |
| 449 | channelCreds = TlsChannelCredentials.newBuilder() |
| 450 | .keyManager(clientCertChain, clientPrivateKey) |
| 451 | .trustManager(caCert) |
| 452 | .build(); |
| 453 | } |
| 454 | Server server = grpcCleanupRule.register(server(serverCreds)); |
| 455 | ManagedChannel channel = grpcCleanupRule.register(clientChannel(server, channelCreds)); |
| 456 | |
| 457 | SimpleServiceGrpc.newBlockingStub(channel).unaryRpc(SimpleRequest.getDefaultInstance()); |
| 458 | } |
| 459 | |
| 460 | @Test |
| 461 | public void untrustedClient_fails() throws Exception { |
nothing calls this directly
no test coverage detected