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 eae7a5e4fcd6aebf002d8f6f31e325de9ccb4a8d
Author: Andrea Cosentino <anco...@gmail.com>
AuthorDate: Tue Sep 20 18:35:57 2022 +0200
CAMEL-18504 - camel-google-secret-manager - Add dev console for secrets
Signed-off-by: Andrea Cosentino <anco...@gmail.com>
---
.../manager/GoogleSecretManagerDevConsole.java | 154 +++++++++++++++++++++
1 file changed, 154 insertions(+)
diff --git
a/components/camel-google/camel-google-secret-manager/src/main/java/org/apache/camel/component/google/secret/manager/GoogleSecretManagerDevConsole.java
b/components/camel-google/camel-google-secret-manager/src/main/java/org/apache/camel/component/google/secret/manager/GoogleSecretManagerDevConsole.java
new file mode 100644
index 00000000000..84ded6b12c6
--- /dev/null
+++
b/components/camel-google/camel-google-secret-manager/src/main/java/org/apache/camel/component/google/secret/manager/GoogleSecretManagerDevConsole.java
@@ -0,0 +1,154 @@
+/*
+ * 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.google.secret.manager;
+
+import java.time.Instant;
+import java.util.ArrayList;
+import java.util.Collections;
+import java.util.List;
+import java.util.Map;
+
+import org.apache.camel.ExtendedCamelContext;
+import
org.apache.camel.component.google.secret.manager.vault.PubsubReloadTriggerTask;
+import org.apache.camel.impl.console.AbstractDevConsole;
+import org.apache.camel.spi.PeriodTaskScheduler;
+import org.apache.camel.spi.PropertiesFunction;
+import org.apache.camel.spi.annotations.DevConsole;
+import org.apache.camel.util.TimeUtils;
+import org.apache.camel.util.json.JsonArray;
+import org.apache.camel.util.json.JsonObject;
+import org.apache.camel.vault.GcpVaultConfiguration;
+
+@DevConsole("gcp-secrets")
+public class GoogleSecretManagerDevConsole extends AbstractDevConsole {
+
+ private GoogleSecretManagerPropertiesFunction propertiesFunction;
+ private PubsubReloadTriggerTask secretsRefreshTask;
+
+ public GoogleSecretManagerDevConsole() {
+ super("camel", "gcp-secrets", "GCP Secrets", "GCP Secret Manager");
+ }
+
+ @Override
+ protected void doStart() throws Exception {
+ super.doStart();
+
+ if
(getCamelContext().getPropertiesComponent().hasPropertiesFunction("gcp")) {
+ PropertiesFunction pf =
getCamelContext().getPropertiesComponent().getPropertiesFunction("gcp");
+ if (pf instanceof GoogleSecretManagerPropertiesFunction) {
+ propertiesFunction = (GoogleSecretManagerPropertiesFunction)
pf;
+ }
+ }
+ GcpVaultConfiguration gcp =
getCamelContext().getVaultConfiguration().getGcpVaultConfiguration();
+ if (gcp != null && gcp.isRefreshEnabled()) {
+ PeriodTaskScheduler scheduler =
getCamelContext().adapt(ExtendedCamelContext.class).getPeriodTaskScheduler();
+ secretsRefreshTask =
scheduler.getTaskByType(PubsubReloadTriggerTask.class);
+ }
+ }
+
+ @Override
+ protected String doCallText(Map<String, Object> options) {
+ StringBuilder sb = new StringBuilder();
+
+ if (propertiesFunction != null) {
+ sb.append("GCP Secret Manager:");
+ if (propertiesFunction.isUseDefaultInstance()) {
+ sb.append("\n Login: Default Instance");
+ } else {
+ sb.append("\n Login: Service Account Key File");
+ }
+ GcpVaultConfiguration gcp =
getCamelContext().getVaultConfiguration().getGcpVaultConfiguration();
+ if (gcp != null) {
+ sb.append(String.format("\n Refresh Enabled: %s",
gcp.isRefreshEnabled()));
+ sb.append(String.format("\n Refresh Period: %s",
gcp.getRefreshPeriod()));
+ }
+ if (secretsRefreshTask != null) {
+ Instant last = secretsRefreshTask.getLastCheckTime();
+ String s = last != null ?
TimeUtils.printSince(last.toEpochMilli()) : "none";
+ sb.append(String.format("\n Last Check: %s", s));
+ last = secretsRefreshTask.getLastReloadTime();
+ s = last != null ? TimeUtils.printSince(last.toEpochMilli()) :
"none";
+ sb.append(String.format("\n Last Reload: %s", s));
+ }
+ sb.append("\n\nSecrets in use:");
+
+ List<String> sorted = new
ArrayList<>(propertiesFunction.getSecrets());
+ Collections.sort(sorted);
+
+ for (String sec : sorted) {
+ Instant last = secretsRefreshTask != null ?
secretsRefreshTask.getUpdates().get(sec) : null;
+ String age = last != null ?
TimeUtils.printSince(last.toEpochMilli()) : null;
+ if (age != null) {
+ sb.append(String.format("\n %s (age: %s)", sec, age));
+ } else {
+ sb.append(String.format("\n %s", sec));
+ }
+ }
+ }
+
+ return sb.toString();
+ }
+
+ @Override
+ protected JsonObject doCallJson(Map<String, Object> options) {
+ JsonObject root = new JsonObject();
+ if (propertiesFunction != null) {
+ if (propertiesFunction.isUseDefaultInstance()) {
+ root.put("login", "Default Instance");
+ } else {
+ root.put("login", "Service Account Key File");
+ }
+ GcpVaultConfiguration gcp =
getCamelContext().getVaultConfiguration().getGcpVaultConfiguration();
+ if (gcp != null) {
+ root.put("refreshEnabled", gcp.isRefreshEnabled());
+ root.put("refreshPeriod", gcp.getRefreshPeriod());
+ }
+ if (secretsRefreshTask != null) {
+ Instant last = secretsRefreshTask.getLastCheckTime();
+ if (last != null) {
+ long timestamp = last.toEpochMilli();
+ root.put("lastCheckTimestamp", timestamp);
+ root.put("lastCheckAge", TimeUtils.printSince(timestamp));
+ }
+ last = secretsRefreshTask.getLastReloadTime();
+ if (last != null) {
+ long timestamp = last.toEpochMilli();
+ root.put("lastReloadTimestamp", timestamp);
+ root.put("lastReloadAge", TimeUtils.printSince(timestamp));
+ }
+ }
+ JsonArray arr = new JsonArray();
+ root.put("secrets", arr);
+
+ List<String> sorted = new
ArrayList<>(propertiesFunction.getSecrets());
+ Collections.sort(sorted);
+
+ for (String sec : sorted) {
+ JsonObject jo = new JsonObject();
+ jo.put("name", sec);
+ Instant last = secretsRefreshTask != null ?
secretsRefreshTask.getUpdates().get(sec) : null;
+ if (last != null) {
+ long timestamp = last.toEpochMilli();
+ jo.put("timestamp", timestamp);
+ jo.put("age", TimeUtils.printSince(timestamp));
+ }
+ arr.add(jo);
+ }
+ }
+ return root;
+ }
+}
