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
The following commit(s) were added to refs/heads/main by this push:
new 809281c9fcf CAMEL-17688 - Support ability to load properties from
Vault/Secrets cloud services - Hashicorp Vault
809281c9fcf is described below
commit 809281c9fcf028d5ae68d333502932930d445ebb
Author: Andrea Cosentino <[email protected]>
AuthorDate: Thu Jul 14 11:18:54 2022 +0200
CAMEL-17688 - Support ability to load properties from Vault/Secrets cloud
services - Hashicorp Vault
---
.../HashicorpVaultPropertiesSourceNoEnvTestIT.java | 514 +++++++++++++++++++++
1 file changed, 514 insertions(+)
diff --git
a/components/camel-hashicorp-vault/src/test/java/org/apache/camel/component/hashicorp/vault/integration/HashicorpVaultPropertiesSourceNoEnvTestIT.java
b/components/camel-hashicorp-vault/src/test/java/org/apache/camel/component/hashicorp/vault/integration/HashicorpVaultPropertiesSourceNoEnvTestIT.java
new file mode 100644
index 00000000000..8d71bd2dafe
--- /dev/null
+++
b/components/camel-hashicorp-vault/src/test/java/org/apache/camel/component/hashicorp/vault/integration/HashicorpVaultPropertiesSourceNoEnvTestIT.java
@@ -0,0 +1,514 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.component.hashicorp.vault.integration;
+
+import org.apache.camel.FailedToCreateRouteException;
+import org.apache.camel.builder.RouteBuilder;
+import org.apache.camel.test.junit5.CamelTestSupport;
+import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.condition.EnabledIfEnvironmentVariable;
+import org.junit.jupiter.api.condition.EnabledIfSystemProperties;
+import org.junit.jupiter.api.condition.EnabledIfSystemProperty;
+
+import static org.junit.jupiter.api.Assertions.assertThrows;
+
+// Must be manually tested. Provide your own accessKey and secretKey using
-Dcamel.vault.hashicorp.token, -Dcamel.vault.hashicorp.engine,
-Dcamel.vault.hashicorp.host, -Dcamel.vault.hashicorp.port and
-Dcamel.vault.hashicorp.scheme
+@EnabledIfSystemProperties({
+ @EnabledIfSystemProperty(named = "camel.vault.hashicorp.token",
matches = ".*",
+ disabledReason = "Token not provided"),
+ @EnabledIfSystemProperty(named = "camel.vault.hashicorp.engine",
matches = ".*",
+ disabledReason = "Engine not provided"),
+ @EnabledIfSystemProperty(named = "camel.vault.hashicorp.host", matches
= ".*", disabledReason = "Host not provided"),
+ @EnabledIfSystemProperty(named = "camel.vault.hashicorp.port", matches
= ".*", disabledReason = "Port not provided"),
+ @EnabledIfSystemProperty(named = "camel.vault.hashicorp.scheme",
matches = ".*", disabledReason = "Scheme not provided")
+})
+public class HashicorpVaultPropertiesSourceNoEnvTestIT extends
CamelTestSupport {
+
+ @Test
+ public void testFunctio() throws Exception {
+
context.getVaultConfiguration().hashicorp().setToken(System.getProperty("camel.vault.hashicorp.token"));
+
context.getVaultConfiguration().hashicorp().setEngine(System.getProperty("camel.vault.hashicorp.engine"));
+
context.getVaultConfiguration().hashicorp().setHost(System.getProperty("camel.vault.hashicorp.host"));
+
context.getVaultConfiguration().hashicorp().setPort(System.getProperty("camel.vault.hashicorp.port"));
+
context.getVaultConfiguration().hashicorp().setScheme(System.getProperty("camel.vault.hashicorp.scheme"));
+ context.addRoutes(new RouteBuilder() {
+ @Override
+ public void configure() {
+
from("direct:start").setBody(simple("{{hashicorp:hello}}")).to("mock:bar");
+ }
+ });
+ context.start();
+
+ getMockEndpoint("mock:bar").expectedBodiesReceived("{id=21,
password=password, username=admin}");
+
+ template.sendBody("direct:start", "Hello World");
+
+ assertMockEndpointsSatisfied();
+ }
+
+ @Test
+ public void testFunctionWithField() throws Exception {
+
context.getVaultConfiguration().hashicorp().setToken(System.getProperty("camel.vault.hashicorp.token"));
+
context.getVaultConfiguration().hashicorp().setEngine(System.getProperty("camel.vault.hashicorp.engine"));
+
context.getVaultConfiguration().hashicorp().setHost(System.getProperty("camel.vault.hashicorp.host"));
+
context.getVaultConfiguration().hashicorp().setPort(System.getProperty("camel.vault.hashicorp.port"));
+
context.getVaultConfiguration().hashicorp().setScheme(System.getProperty("camel.vault.hashicorp.scheme"));
+ context.addRoutes(new RouteBuilder() {
+ @Override
+ public void configure() {
+
from("direct:start").setBody(simple("{{hashicorp:hello/id}}")).to("mock:bar");
+ }
+ });
+ context.start();
+
+ getMockEndpoint("mock:bar").expectedBodiesReceived("21");
+
+ template.sendBody("direct:start", "Hello World");
+
+ assertMockEndpointsSatisfied();
+ }
+
+ @Test
+ public void testComplexCustomPropertiesFunction() throws Exception {
+
context.getVaultConfiguration().hashicorp().setToken(System.getProperty("camel.vault.hashicorp.token"));
+
context.getVaultConfiguration().hashicorp().setEngine(System.getProperty("camel.vault.hashicorp.engine"));
+
context.getVaultConfiguration().hashicorp().setHost(System.getProperty("camel.vault.hashicorp.host"));
+
context.getVaultConfiguration().hashicorp().setPort(System.getProperty("camel.vault.hashicorp.port"));
+
context.getVaultConfiguration().hashicorp().setScheme(System.getProperty("camel.vault.hashicorp.scheme"));
+ context.addRoutes(new RouteBuilder() {
+ @Override
+ public void configure() {
+
from("direct:username").setBody(simple("{{hashicorp:hello/username}}")).to("mock:bar");
+
from("direct:password").setBody(simple("{{hashicorp:hello/password}}")).to("mock:bar");
+ }
+ });
+ context.start();
+
+ getMockEndpoint("mock:bar").expectedBodiesReceived("admin",
"password");
+
+ template.sendBody("direct:username", "Hello World");
+ template.sendBody("direct:password", "Hello World");
+ assertMockEndpointsSatisfied();
+ }
+
+ @Test
+ public void testSecretNotFoundFunction() {
+ Exception exception = assertThrows(FailedToCreateRouteException.class,
() -> {
+
context.getVaultConfiguration().hashicorp().setToken(System.getProperty("camel.vault.hashicorp.token"));
+
context.getVaultConfiguration().hashicorp().setEngine(System.getProperty("camel.vault.hashicorp.engine"));
+
context.getVaultConfiguration().hashicorp().setHost(System.getProperty("camel.vault.hashicorp.host"));
+
context.getVaultConfiguration().hashicorp().setPort(System.getProperty("camel.vault.hashicorp.port"));
+
context.getVaultConfiguration().hashicorp().setScheme(System.getProperty("camel.vault.hashicorp.scheme"));
+ context.addRoutes(new RouteBuilder() {
+ @Override
+ public void configure() {
+
from("direct:start").setBody(simple("{{hashicorp:testExample}}")).to("mock:bar");
+ }
+ });
+ context.start();
+
+ getMockEndpoint("mock:bar").expectedBodiesReceived("hello");
+
+ template.sendBody("direct:start", "Hello World");
+
+ assertMockEndpointsSatisfied();
+ });
+ }
+
+ @Test
+ public void testComplexNoSubkeyPropertiesFunction() {
+ Exception exception = assertThrows(FailedToCreateRouteException.class,
() -> {
+
context.getVaultConfiguration().hashicorp().setToken(System.getProperty("camel.vault.hashicorp.token"));
+
context.getVaultConfiguration().hashicorp().setEngine(System.getProperty("camel.vault.hashicorp.engine"));
+
context.getVaultConfiguration().hashicorp().setHost(System.getProperty("camel.vault.hashicorp.host"));
+
context.getVaultConfiguration().hashicorp().setPort(System.getProperty("camel.vault.hashicorp.port"));
+
context.getVaultConfiguration().hashicorp().setScheme(System.getProperty("camel.vault.hashicorp.scheme"));
+ context.addRoutes(new RouteBuilder() {
+ @Override
+ public void configure() {
+
from("direct:username").setBody(simple("{{hashicorp:database_sample/not_existent}}")).to("mock:bar");
+ }
+ });
+ context.start();
+
+ getMockEndpoint("mock:bar").expectedBodiesReceived("admin");
+
+ template.sendBody("direct:username", "Hello World");
+ assertMockEndpointsSatisfied();
+ });
+ }
+
+ @Test
+ public void testComplexCustomPropertiesDefaultValueFunction() throws
Exception {
+
context.getVaultConfiguration().hashicorp().setToken(System.getProperty("camel.vault.hashicorp.token"));
+
context.getVaultConfiguration().hashicorp().setEngine(System.getProperty("camel.vault.hashicorp.engine"));
+
context.getVaultConfiguration().hashicorp().setHost(System.getProperty("camel.vault.hashicorp.host"));
+
context.getVaultConfiguration().hashicorp().setPort(System.getProperty("camel.vault.hashicorp.port"));
+
context.getVaultConfiguration().hashicorp().setScheme(System.getProperty("camel.vault.hashicorp.scheme"));
+ context.addRoutes(new RouteBuilder() {
+ @Override
+ public void configure() {
+
from("direct:username").setBody(simple("{{hashicorp:hello/additional1:admin}}")).to("mock:bar");
+
from("direct:password").setBody(simple("{{hashicorp:hello/additional2:secret}}")).to("mock:bar");
+ }
+ });
+ context.start();
+
+ getMockEndpoint("mock:bar").expectedBodiesReceived("admin", "secret");
+
+ template.sendBody("direct:username", "Hello World");
+ template.sendBody("direct:password", "Hello World");
+ assertMockEndpointsSatisfied();
+ }
+
+ @Test
+ public void testComplexCustomPropertiesDefaultValueExceptionFunction()
throws Exception {
+
context.getVaultConfiguration().hashicorp().setToken(System.getProperty("camel.vault.hashicorp.token"));
+
context.getVaultConfiguration().hashicorp().setEngine(System.getProperty("camel.vault.hashicorp.engine"));
+
context.getVaultConfiguration().hashicorp().setHost(System.getProperty("camel.vault.hashicorp.host"));
+
context.getVaultConfiguration().hashicorp().setPort(System.getProperty("camel.vault.hashicorp.port"));
+
context.getVaultConfiguration().hashicorp().setScheme(System.getProperty("camel.vault.hashicorp.scheme"));
+ context.addRoutes(new RouteBuilder() {
+ @Override
+ public void configure() {
+
from("direct:username").setBody(simple("{{hashicorp:test-3/additional1:admin}}")).to("mock:bar");
+
from("direct:password").setBody(simple("{{hashicorp:test-3/additional2:secret}}")).to("mock:bar");
+ }
+ });
+ context.start();
+
+ getMockEndpoint("mock:bar").expectedBodiesReceived("admin", "secret");
+
+ template.sendBody("direct:username", "Hello World");
+ template.sendBody("direct:password", "Hello World");
+ assertMockEndpointsSatisfied();
+ }
+
+ @Test
+ public void testComplexCustomPropertiesExceptionFunction() {
+ Exception exception = assertThrows(FailedToCreateRouteException.class,
() -> {
+
context.getVaultConfiguration().hashicorp().setToken(System.getProperty("camel.vault.hashicorp.token"));
+
context.getVaultConfiguration().hashicorp().setEngine(System.getProperty("camel.vault.hashicorp.engine"));
+
context.getVaultConfiguration().hashicorp().setHost(System.getProperty("camel.vault.hashicorp.host"));
+
context.getVaultConfiguration().hashicorp().setPort(System.getProperty("camel.vault.hashicorp.port"));
+
context.getVaultConfiguration().hashicorp().setScheme(System.getProperty("camel.vault.hashicorp.scheme"));
+ context.addRoutes(new RouteBuilder() {
+ @Override
+ public void configure() {
+
from("direct:username").setBody(simple("{{hashicorp:test-3/additional1}}")).to("mock:bar");
+
from("direct:password").setBody(simple("{{hashicorp:test-3/additional2}}")).to("mock:bar");
+ }
+ });
+ context.start();
+
+ getMockEndpoint("mock:bar").expectedBodiesReceived("admin",
"secret");
+
+ template.sendBody("direct:username", "Hello World");
+ template.sendBody("direct:password", "Hello World");
+ assertMockEndpointsSatisfied();
+ });
+ }
+
+ @Test
+ public void testComplexSimpleDefaultValueExceptionFunction() throws
Exception {
+
context.getVaultConfiguration().hashicorp().setToken(System.getProperty("camel.vault.hashicorp.token"));
+
context.getVaultConfiguration().hashicorp().setEngine(System.getProperty("camel.vault.hashicorp.engine"));
+
context.getVaultConfiguration().hashicorp().setHost(System.getProperty("camel.vault.hashicorp.host"));
+
context.getVaultConfiguration().hashicorp().setPort(System.getProperty("camel.vault.hashicorp.port"));
+
context.getVaultConfiguration().hashicorp().setScheme(System.getProperty("camel.vault.hashicorp.scheme"));
+ context.addRoutes(new RouteBuilder() {
+ @Override
+ public void configure() {
+
from("direct:username").setBody(simple("{{hashicorp:hello-2:admin}}")).to("mock:bar");
+
from("direct:password").setBody(simple("{{hashicorp:hello-1:secret}}")).to("mock:bar");
+ }
+ });
+ context.start();
+
+ getMockEndpoint("mock:bar").expectedBodiesReceived("admin", "secret");
+
+ template.sendBody("direct:username", "Hello World");
+ template.sendBody("direct:password", "Hello World");
+ assertMockEndpointsSatisfied();
+ }
+
+ @Test
+ public void testComplexSimpleNoDefaultValueExceptionFunction() {
+ Exception exception = assertThrows(FailedToCreateRouteException.class,
() -> {
+
context.getVaultConfiguration().hashicorp().setToken(System.getProperty("camel.vault.hashicorp.token"));
+
context.getVaultConfiguration().hashicorp().setEngine(System.getProperty("camel.vault.hashicorp.engine"));
+
context.getVaultConfiguration().hashicorp().setHost(System.getProperty("camel.vault.hashicorp.host"));
+
context.getVaultConfiguration().hashicorp().setPort(System.getProperty("camel.vault.hashicorp.port"));
+
context.getVaultConfiguration().hashicorp().setScheme(System.getProperty("camel.vault.hashicorp.scheme"));
+ context.addRoutes(new RouteBuilder() {
+ @Override
+ public void configure() {
+
from("direct:username").setBody(simple("{{hashicorp:secretsuper}}")).to("mock:bar");
+ }
+ });
+ context.start();
+
+ getMockEndpoint("mock:bar").expectedBodiesReceived("admin");
+
+ template.sendBody("direct:username", "Hello World");
+ assertMockEndpointsSatisfied();
+ });
+ }
+
+ @Test
+ public void testComplexCustomPropertiesNoDefaultValueFunction() {
+ Exception exception = assertThrows(FailedToCreateRouteException.class,
() -> {
+
context.getVaultConfiguration().hashicorp().setToken(System.getProperty("camel.vault.hashicorp.token"));
+
context.getVaultConfiguration().hashicorp().setEngine(System.getProperty("camel.vault.hashicorp.engine"));
+
context.getVaultConfiguration().hashicorp().setHost(System.getProperty("camel.vault.hashicorp.host"));
+
context.getVaultConfiguration().hashicorp().setPort(System.getProperty("camel.vault.hashicorp.port"));
+
context.getVaultConfiguration().hashicorp().setScheme(System.getProperty("camel.vault.hashicorp.scheme"));
+ context.addRoutes(new RouteBuilder() {
+ @Override
+ public void configure() {
+
from("direct:username").setBody(simple("{{hashicorp:postgresql/additional1}}")).to("mock:bar");
+
from("direct:password").setBody(simple("{{hashicorp:postgresql/additional2}}")).to("mock:bar");
+ }
+ });
+ context.start();
+
+ getMockEndpoint("mock:bar").expectedBodiesReceived("admin",
"secret");
+
+ template.sendBody("direct:username", "Hello World");
+ template.sendBody("direct:password", "Hello World");
+ assertMockEndpointsSatisfied();
+ });
+ }
+
+ @Test
+ public void testComplexCustomPropertiesNotExistentDefaultValueFunction()
throws Exception {
+
context.getVaultConfiguration().hashicorp().setToken(System.getProperty("camel.vault.hashicorp.token"));
+
context.getVaultConfiguration().hashicorp().setEngine(System.getProperty("camel.vault.hashicorp.engine"));
+
context.getVaultConfiguration().hashicorp().setHost(System.getProperty("camel.vault.hashicorp.host"));
+
context.getVaultConfiguration().hashicorp().setPort(System.getProperty("camel.vault.hashicorp.port"));
+
context.getVaultConfiguration().hashicorp().setScheme(System.getProperty("camel.vault.hashicorp.scheme"));
+ context.addRoutes(new RouteBuilder() {
+ @Override
+ public void configure() {
+
from("direct:username").setBody(simple("{{hashicorp:newsecret/additional1:admin}}")).to("mock:bar");
+ }
+ });
+ context.start();
+
+ getMockEndpoint("mock:bar").expectedBodiesReceived("admin");
+
+ template.sendBody("direct:username", "Hello World");
+ assertMockEndpointsSatisfied();
+ }
+
+ @Test
+ public void testComplexCustomPropertiesDefaultCredsDefaultValueFunction()
throws Exception {
+
context.getVaultConfiguration().hashicorp().setToken(System.getProperty("camel.vault.hashicorp.token"));
+
context.getVaultConfiguration().hashicorp().setEngine(System.getProperty("camel.vault.hashicorp.engine"));
+
context.getVaultConfiguration().hashicorp().setHost(System.getProperty("camel.vault.hashicorp.host"));
+
context.getVaultConfiguration().hashicorp().setPort(System.getProperty("camel.vault.hashicorp.port"));
+
context.getVaultConfiguration().hashicorp().setScheme(System.getProperty("camel.vault.hashicorp.scheme"));
+ context.addRoutes(new RouteBuilder() {
+ @Override
+ public void configure() {
+
from("direct:username").setBody(simple("{{hashicorp:newsecret/additional1:admin}}")).to("mock:bar");
+ }
+ });
+ context.start();
+
+ getMockEndpoint("mock:bar").expectedBodiesReceived("admin");
+
+ template.sendBody("direct:username", "Hello World");
+ assertMockEndpointsSatisfied();
+ }
+
+ @Test
+ public void testPropertiesWithDefaultFunction() throws Exception {
+
context.getVaultConfiguration().hashicorp().setToken(System.getProperty("camel.vault.hashicorp.token"));
+
context.getVaultConfiguration().hashicorp().setEngine(System.getProperty("camel.vault.hashicorp.engine"));
+
context.getVaultConfiguration().hashicorp().setHost(System.getProperty("camel.vault.hashicorp.host"));
+
context.getVaultConfiguration().hashicorp().setPort(System.getProperty("camel.vault.hashicorp.port"));
+
context.getVaultConfiguration().hashicorp().setScheme(System.getProperty("camel.vault.hashicorp.scheme"));
+ context.addRoutes(new RouteBuilder() {
+ @Override
+ public void configure() {
+
from("direct:username").setBody(simple("{{hashicorp:postgresql/username:oscerd}}")).to("mock:bar");
+
from("direct:password").setBody(simple("{{hashicorp:postgresql/password:password}}")).to("mock:bar");
+ }
+ });
+ context.start();
+
+ getMockEndpoint("mock:bar").expectedBodiesReceived("oscerd",
"password");
+
+ template.sendBody("direct:username", "Hello World");
+ template.sendBody("direct:password", "Hello World");
+ assertMockEndpointsSatisfied();
+ }
+
+ @Test
+ public void testPropertiesWithDefaultNotExistentFunction() throws
Exception {
+
context.getVaultConfiguration().hashicorp().setToken(System.getProperty("camel.vault.hashicorp.token"));
+
context.getVaultConfiguration().hashicorp().setEngine(System.getProperty("camel.vault.hashicorp.engine"));
+
context.getVaultConfiguration().hashicorp().setHost(System.getProperty("camel.vault.hashicorp.host"));
+
context.getVaultConfiguration().hashicorp().setPort(System.getProperty("camel.vault.hashicorp.port"));
+
context.getVaultConfiguration().hashicorp().setScheme(System.getProperty("camel.vault.hashicorp.scheme"));
+ context.addRoutes(new RouteBuilder() {
+ @Override
+ public void configure() {
+
from("direct:username").setBody(simple("{{hashicorp:db_sample/username:oscerd}}")).to("mock:bar");
+
from("direct:password").setBody(simple("{{hashicorp:db_sample/password:password}}")).to("mock:bar");
+ }
+ });
+ context.start();
+
+ getMockEndpoint("mock:bar").expectedBodiesReceived("oscerd",
"password");
+
+ template.sendBody("direct:username", "Hello World");
+ template.sendBody("direct:password", "Hello World");
+ assertMockEndpointsSatisfied();
+ }
+
+ @Test
+ public void testPropertiesWithVersionFunction() throws Exception {
+
context.getVaultConfiguration().hashicorp().setToken(System.getProperty("camel.vault.hashicorp.token"));
+
context.getVaultConfiguration().hashicorp().setEngine(System.getProperty("camel.vault.hashicorp.engine"));
+
context.getVaultConfiguration().hashicorp().setHost(System.getProperty("camel.vault.hashicorp.host"));
+
context.getVaultConfiguration().hashicorp().setPort(System.getProperty("camel.vault.hashicorp.port"));
+
context.getVaultConfiguration().hashicorp().setScheme(System.getProperty("camel.vault.hashicorp.scheme"));
+ context.addRoutes(new RouteBuilder() {
+ @Override
+ public void configure() {
+
from("direct:version").setBody(simple("{{hashicorp:hello/id@1}}")).to("mock:bar");
+ }
+ });
+ context.start();
+
+ getMockEndpoint("mock:bar").expectedBodiesReceived("21");
+
+ template.sendBody("direct:version", "Hello World");
+ assertMockEndpointsSatisfied();
+ }
+
+ @Test
+ public void testPropertiesWithVersionAndNoFieldFunction() throws Exception
{
+
context.getVaultConfiguration().hashicorp().setToken(System.getProperty("camel.vault.hashicorp.token"));
+
context.getVaultConfiguration().hashicorp().setEngine(System.getProperty("camel.vault.hashicorp.engine"));
+
context.getVaultConfiguration().hashicorp().setHost(System.getProperty("camel.vault.hashicorp.host"));
+
context.getVaultConfiguration().hashicorp().setPort(System.getProperty("camel.vault.hashicorp.port"));
+
context.getVaultConfiguration().hashicorp().setScheme(System.getProperty("camel.vault.hashicorp.scheme"));
+ context.addRoutes(new RouteBuilder() {
+ @Override
+ public void configure() {
+
from("direct:version").setBody(simple("{{hashicorp:hello@1}}")).to("mock:bar");
+ }
+ });
+ context.start();
+
+ getMockEndpoint("mock:bar").expectedBodiesReceived("{id=21}");
+
+ template.sendBody("direct:version", "Hello World");
+ assertMockEndpointsSatisfied();
+ }
+
+ @Test
+ public void testPropertiesWithVersionNoFieldAndDefaultValueFunction()
throws Exception {
+
context.getVaultConfiguration().hashicorp().setToken(System.getProperty("camel.vault.hashicorp.token"));
+
context.getVaultConfiguration().hashicorp().setEngine(System.getProperty("camel.vault.hashicorp.engine"));
+
context.getVaultConfiguration().hashicorp().setHost(System.getProperty("camel.vault.hashicorp.host"));
+
context.getVaultConfiguration().hashicorp().setPort(System.getProperty("camel.vault.hashicorp.port"));
+
context.getVaultConfiguration().hashicorp().setScheme(System.getProperty("camel.vault.hashicorp.scheme"));
+ context.addRoutes(new RouteBuilder() {
+ @Override
+ public void configure() {
+
from("direct:version").setBody(simple("{{hashicorp:hello:pippo@1}}"))
+ .to("mock:bar");
+ }
+ });
+ context.start();
+
+ getMockEndpoint("mock:bar").expectedBodiesReceived("{id=21}");
+
+ template.sendBody("direct:version", "Hello World");
+ assertMockEndpointsSatisfied();
+ }
+
+ @Test
+ public void
testPropertiesWithVersionNoFieldDefaultValueNotExistentSecretFunction() throws
Exception {
+
context.getVaultConfiguration().hashicorp().setToken(System.getProperty("camel.vault.hashicorp.token"));
+
context.getVaultConfiguration().hashicorp().setEngine(System.getProperty("camel.vault.hashicorp.engine"));
+
context.getVaultConfiguration().hashicorp().setHost(System.getProperty("camel.vault.hashicorp.host"));
+
context.getVaultConfiguration().hashicorp().setPort(System.getProperty("camel.vault.hashicorp.port"));
+
context.getVaultConfiguration().hashicorp().setScheme(System.getProperty("camel.vault.hashicorp.scheme"));
+ context.addRoutes(new RouteBuilder() {
+ @Override
+ public void configure() {
+
from("direct:version").setBody(simple("{{hashicorp:hello-3:pippo@4}}"))
+ .to("mock:bar");
+ }
+ });
+ context.start();
+
+ getMockEndpoint("mock:bar").expectedBodiesReceived("pippo");
+
+ template.sendBody("direct:version", "Hello World");
+ assertMockEndpointsSatisfied();
+ }
+
+ @Test
+ public void
testPropertiesWithVersionNoFieldDefaultValueNotExistentVersionFunction() throws
Exception {
+
context.getVaultConfiguration().hashicorp().setToken(System.getProperty("camel.vault.hashicorp.token"));
+
context.getVaultConfiguration().hashicorp().setEngine(System.getProperty("camel.vault.hashicorp.engine"));
+
context.getVaultConfiguration().hashicorp().setHost(System.getProperty("camel.vault.hashicorp.host"));
+
context.getVaultConfiguration().hashicorp().setPort(System.getProperty("camel.vault.hashicorp.port"));
+
context.getVaultConfiguration().hashicorp().setScheme(System.getProperty("camel.vault.hashicorp.scheme"));
+ context.addRoutes(new RouteBuilder() {
+ @Override
+ public void configure() {
+
from("direct:version").setBody(simple("{{hashicorp:hello:pippo@4}}"))
+ .to("mock:bar");
+ }
+ });
+ context.start();
+
+ getMockEndpoint("mock:bar").expectedBodiesReceived("pippo");
+
+ template.sendBody("direct:version", "Hello World");
+ assertMockEndpointsSatisfied();
+ }
+
+ @Test
+ public void testPropertiesWithVersionFieldAndDefaultValueFunction() throws
Exception {
+
context.getVaultConfiguration().hashicorp().setToken(System.getProperty("camel.vault.hashicorp.token"));
+
context.getVaultConfiguration().hashicorp().setEngine(System.getProperty("camel.vault.hashicorp.engine"));
+
context.getVaultConfiguration().hashicorp().setHost(System.getProperty("camel.vault.hashicorp.host"));
+
context.getVaultConfiguration().hashicorp().setPort(System.getProperty("camel.vault.hashicorp.port"));
+
context.getVaultConfiguration().hashicorp().setScheme(System.getProperty("camel.vault.hashicorp.scheme"));
+ context.addRoutes(new RouteBuilder() {
+ @Override
+ public void configure() {
+
from("direct:version").setBody(simple("{{hashicorp:hello/id:pippo@1}}"))
+ .to("mock:bar");
+ }
+ });
+ context.start();
+
+ getMockEndpoint("mock:bar").expectedBodiesReceived("21");
+
+ template.sendBody("direct:version", "Hello World");
+ assertMockEndpointsSatisfied();
+ }
+}
