Skip to content

Commit 453877d

Browse files
authored
Enroll API to return CA cert using standard Base64 (#75858)
* Enroll API to return CA cert using standard Base64 encoding
1 parent 715bbb6 commit 453877d

File tree

5 files changed

+9
-9
lines changed

5 files changed

+9
-9
lines changed

client/rest-high-level/qa/ssl-enabled/src/javaRestTest/java/org/elasticsearch/client/EnrollmentIT.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -64,7 +64,7 @@ public void testEnrollNode() throws Exception {
6464
assertThat(nodeEnrollmentResponse, notNullValue());
6565
assertThat(nodeEnrollmentResponse.getHttpCaKey(), endsWith("K2S3vidA="));
6666
assertThat(nodeEnrollmentResponse.getHttpCaCert(), endsWith("LfkRjirc="));
67-
assertThat(nodeEnrollmentResponse.getTransportKey(), endsWith("1I-r8vOQ=="));
67+
assertThat(nodeEnrollmentResponse.getTransportKey(), endsWith("1I+r8vOQ=="));
6868
assertThat(nodeEnrollmentResponse.getTransportCert(), endsWith("OpTdtgJo="));
6969
List<String> nodesAddresses = nodeEnrollmentResponse.getNodesAddresses();
7070
assertThat(nodesAddresses.size(), equalTo(2));
@@ -75,7 +75,7 @@ public void testEnrollKibana() throws Exception {
7575
execute(highLevelClient().security()::enrollKibana, highLevelClient().security()::enrollKibanaAsync, RequestOptions.DEFAULT);
7676
assertThat(kibanaResponse, notNullValue());
7777
assertThat(kibanaResponse.getHttpCa()
78-
, endsWith("brcNC5xq6YE7C4_06nH7F6le4kE4Uo6c9fpkl4ehOxQxndNLn462tFF-8VBA8IftJ1PPWzqGxLsCTzM6p6w8sa-XhgNYglLfkRjirc="));
78+
, endsWith("brcNC5xq6YE7C4/06nH7F6le4kE4Uo6c9fpkl4ehOxQxndNLn462tFF+8VBA8IftJ1PPWzqGxLsCTzM6p6w8sa+XhgNYglLfkRjirc="));
7979
assertNotNull(kibanaResponse.getPassword());
8080
assertThat(kibanaResponse.getPassword().toString().length(), equalTo(14));
8181
}

x-pack/plugin/security/src/main/java/org/elasticsearch/xpack/security/action/enrollment/TransportKibanaEnrollmentAction.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -91,7 +91,7 @@ public class TransportKibanaEnrollmentAction extends HandledTransportAction<Kiba
9191
} else {
9292
String httpCa;
9393
try {
94-
httpCa = Base64.getUrlEncoder().encodeToString(caCertificates.get(0).getEncoded());
94+
httpCa = Base64.getEncoder().encodeToString(caCertificates.get(0).getEncoded());
9595
} catch (CertificateEncodingException cee) {
9696
listener.onFailure(new ElasticsearchException(
9797
"Unable to enroll kibana instance. Elasticsearch node HTTP layer SSL configuration uses a malformed CA certificate",

x-pack/plugin/security/src/main/java/org/elasticsearch/xpack/security/action/enrollment/TransportNodeEnrollmentAction.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -102,12 +102,12 @@ protected void doExecute(Task task, NodeEnrollmentRequest request, ActionListene
102102
nodeList.add(nodeInfo.getInfo(TransportInfo.class).getAddress().publishAddress().toString());
103103
}
104104
try {
105-
final String httpCaKey = Base64.getUrlEncoder().encodeToString(httpCaKeysAndCertificates.get(0).v1().getEncoded());
106-
final String httpCaCert = Base64.getUrlEncoder().encodeToString(httpCaKeysAndCertificates.get(0).v2().getEncoded());
105+
final String httpCaKey = Base64.getEncoder().encodeToString(httpCaKeysAndCertificates.get(0).v1().getEncoded());
106+
final String httpCaCert = Base64.getEncoder().encodeToString(httpCaKeysAndCertificates.get(0).v2().getEncoded());
107107
final String transportKey =
108-
Base64.getUrlEncoder().encodeToString(transportKeysAndCertificates.get(0).v1().getEncoded());
108+
Base64.getEncoder().encodeToString(transportKeysAndCertificates.get(0).v1().getEncoded());
109109
final String transportCert =
110-
Base64.getUrlEncoder().encodeToString(transportKeysAndCertificates.get(0).v2().getEncoded());
110+
Base64.getEncoder().encodeToString(transportKeysAndCertificates.get(0).v2().getEncoded());
111111
listener.onResponse(new NodeEnrollmentResponse(httpCaKey,
112112
httpCaCert,
113113
transportKey,

x-pack/plugin/security/src/test/java/org/elasticsearch/xpack/security/action/enrollment/TransportKibanaEnrollmentActionTests.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -104,7 +104,7 @@ public void testKibanaEnrollment() {
104104
final KibanaEnrollmentResponse response = future.actionGet();
105105
assertThat(response.getHttpCa(), startsWith("MIIDSjCCAjKgAwIBAgIVALCgZXvbceUrjJaQMheDCX0kXnRJMA0GCSqGSIb3DQEBCwUAMDQxMjAw" +
106106
"BgNVBAMTKUVsYXN0aWMgQ2VydGlmaWNhdGUgVG9vbCBBdXRvZ2VuZXJhdGVkIENBMB4XDTIxMDQyODEyNTY0MVoXDTI0MDQyNzEyNTY0MVowNDEyMDAGA1UEA" +
107-
"xMpRWxhc3RpYyBDZXJ0aWZpY2F0ZSBUb29sIEF1dG9nZW5lcmF0ZWQgQ0EwggEiMA0GCSqGSIb3DQEBAQUAA4IBDwAwggEKAoIBAQCCJbOU4JvxDD_F"));
107+
"xMpRWxhc3RpYyBDZXJ0aWZpY2F0ZSBUb29sIEF1dG9nZW5lcmF0ZWQgQ0EwggEiMA0GCSqGSIb3DQEBAQUAA4IBDwAwggEKAoIBAQCCJbOU4JvxDD/F"));
108108
assertNotNull(response.getPassword());
109109
assertThat(changePasswordRequests.size(), equalTo(1));
110110
}

x-pack/plugin/security/src/test/java/org/elasticsearch/xpack/security/action/enrollment/TransportNodeEnrollmentActionTests.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -148,7 +148,7 @@ public void testDoExecute() throws Exception {
148148
private void assertSameCertificate(String cert, Path original, char[] originalPassword, boolean isCa) throws Exception{
149149
Map<Certificate, Key> originalKeysAndCerts = CertParsingUtils.readPkcs12KeyPairs(original, originalPassword, p -> originalPassword);
150150
Certificate deserializedCert = CertParsingUtils.readCertificates(
151-
new ByteArrayInputStream(Base64.getUrlDecoder().decode(cert.getBytes(StandardCharsets.UTF_8)))).get(0);
151+
new ByteArrayInputStream(Base64.getDecoder().decode(cert.getBytes(StandardCharsets.UTF_8)))).get(0);
152152
assertThat(originalKeysAndCerts, hasKey(deserializedCert));
153153
assertThat(deserializedCert, instanceOf(X509Certificate.class));
154154
if (isCa) {

0 commit comments

Comments
 (0)