This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel.git
commit ece78985a2f89e73d2132358a0736f2bafff82c6 Author: Andrea Cosentino <[email protected]> AuthorDate: Tue Feb 22 10:57:01 2022 +0100 CAMEL-17691 - Camel Google Secret Manager: Add more operations - Access Secret Version, default version should be latest, if not provided --- .../component/google/secret/manager/GoogleSecretManagerProducer.java | 3 ++- .../component/google/secret/manager/integration/GoogleCloudIT.java | 2 +- 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/components/camel-google/camel-google-secrets-manager/src/main/java/org/apache/camel/component/google/secret/manager/GoogleSecretManagerProducer.java b/components/camel-google/camel-google-secrets-manager/src/main/java/org/apache/camel/component/google/secret/manager/GoogleSecretManagerProducer.java index 93d2a4c..95479a8 100644 --- a/components/camel-google/camel-google-secrets-manager/src/main/java/org/apache/camel/component/google/secret/manager/GoogleSecretManagerProducer.java +++ b/components/camel-google/camel-google-secrets-manager/src/main/java/org/apache/camel/component/google/secret/manager/GoogleSecretManagerProducer.java @@ -86,13 +86,14 @@ public class GoogleSecretManagerProducer extends DefaultProducer { } private void getSecretVersion(SecretManagerServiceClient client, Exchange exchange) throws InvalidPayloadException { + final String defaultVersion = "latest"; AccessSecretVersionResponse response; if (getConfiguration().isPojoRequest()) { AccessSecretVersionRequest request = exchange.getIn().getMandatoryBody(AccessSecretVersionRequest.class); response = client.accessSecretVersion(request); } else { String secretId = exchange.getMessage().getHeader(GoogleSecretManagerConstants.SECRET_ID, String.class); - String versionId = exchange.getMessage().getHeader(GoogleSecretManagerConstants.VERSION_ID, String.class); + String versionId = exchange.getMessage().getHeader(GoogleSecretManagerConstants.VERSION_ID, defaultVersion, String.class); String projectId = getConfiguration().getProject(); SecretVersionName secretVersionName = SecretVersionName.of(projectId, secretId, versionId); response = client.accessSecretVersion(secretVersionName); diff --git a/components/camel-google/camel-google-secrets-manager/src/test/java/org/apache/camel/component/google/secret/manager/integration/GoogleCloudIT.java b/components/camel-google/camel-google-secrets-manager/src/test/java/org/apache/camel/component/google/secret/manager/integration/GoogleCloudIT.java index a325ad5..3638eaf 100644 --- a/components/camel-google/camel-google-secrets-manager/src/test/java/org/apache/camel/component/google/secret/manager/integration/GoogleCloudIT.java +++ b/components/camel-google/camel-google-secrets-manager/src/test/java/org/apache/camel/component/google/secret/manager/integration/GoogleCloudIT.java @@ -52,7 +52,7 @@ public class GoogleCloudIT extends CamelTestSupport { .to("mock:createSecret"); from("direct:getSecretVersion").to("google-secret-manager://" + project + "?serviceAccountKey=" - + serviceAccountKeyFile + "&operation=getSecretVersion") + + serviceAccountKeyFile + "&operation=getSecretVersion") .to("mock:getSecret"); }
