You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2022/03/31 09:20:51 UTC

[camel] 01/01: CAMEL-17687 - Create a Camel Azure Key Vault component - Add configuration test

This is an automated email from the ASF dual-hosted git repository.

acosentino pushed a commit to branch test-orpiske-key-vault
in repository https://gitbox.apache.org/repos/asf/camel.git

commit 29fdb6962d2091fd534c08b13831aa252e7db91f
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Thu Mar 31 11:19:31 2022 +0200

    CAMEL-17687 - Create a Camel Azure Key Vault component - Add configuration test
---
 .../azure/key/vault/KeyVaultConfigurationTest.java | 69 ++++++++++++++++++++++
 1 file changed, 69 insertions(+)

diff --git a/components/camel-azure/camel-azure-key-vault/src/test/java/org/apache/camel/component/azure/key/vault/KeyVaultConfigurationTest.java b/components/camel-azure/camel-azure-key-vault/src/test/java/org/apache/camel/component/azure/key/vault/KeyVaultConfigurationTest.java
new file mode 100644
index 0000000..b75675e
--- /dev/null
+++ b/components/camel-azure/camel-azure-key-vault/src/test/java/org/apache/camel/component/azure/key/vault/KeyVaultConfigurationTest.java
@@ -0,0 +1,69 @@
+/*
+ * 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.azure.key.vault;
+
+import com.azure.identity.DefaultAzureCredentialBuilder;
+import com.azure.security.keyvault.secrets.SecretClient;
+import com.azure.security.keyvault.secrets.SecretClientBuilder;
+import org.apache.camel.test.junit5.CamelTestSupport;
+import org.junit.jupiter.api.Test;
+
+import static org.junit.jupiter.api.Assertions.*;
+
+public class KeyVaultConfigurationTest extends CamelTestSupport {
+
+    @Test
+    public void createEndpointWithMinimalConfiguration() throws Exception {
+        SecretClient sc = new SecretClientBuilder().credential(new DefaultAzureCredentialBuilder().build())
+                .vaultUrl("https://test.vault.azure.net").buildClient();
+
+        context.getRegistry().bind("secretClient", sc);
+
+        KeyVaultComponent component = context.getComponent("azure-key-vault", KeyVaultComponent.class);
+        KeyVaultEndpoint endpoint = (KeyVaultEndpoint) component
+                .createEndpoint("azure-key-valut://MyVault?secretClient=#secretClient");
+
+        assertEquals("MyVault", endpoint.getConfiguration().getVaultName());
+        assertNotNull(endpoint.getConfiguration().getSecretClient());
+        assertNull(endpoint.getConfiguration().getClientId());
+        assertNull(endpoint.getConfiguration().getClientSecret());
+        assertNull(endpoint.getConfiguration().getTenantId());
+    }
+
+    @Test
+    public void createEndpointWithExplicitCredentials() throws Exception {
+
+        KeyVaultComponent component = context.getComponent("azure-key-vault", KeyVaultComponent.class);
+        KeyVaultEndpoint endpoint = (KeyVaultEndpoint) component
+                .createEndpoint("azure-key-valut://MyVault?clientId=test&clientSecret=sec&tenantId=tenant");
+
+        assertEquals("MyVault", endpoint.getConfiguration().getVaultName());
+        assertNull(endpoint.getConfiguration().getSecretClient());
+        assertEquals("test", endpoint.getConfiguration().getClientId());
+        assertEquals("sec", endpoint.getConfiguration().getClientSecret());
+        assertEquals("tenant", endpoint.getConfiguration().getTenantId());
+    }
+
+    @Test
+    public void createEndpointFailure() throws Exception {
+        Exception exception = assertThrows(IllegalArgumentException.class, () -> {
+            KeyVaultComponent component = context.getComponent("azure-key-vault", KeyVaultComponent.class);
+            KeyVaultEndpoint endpoint = (KeyVaultEndpoint) component
+                    .createEndpoint("azure-key-valut://MyVault");
+        });
+    }
+}