[camel] 01/04: CAMEL-18504 - camel-google-secret-manager - Add dev console for secrets

[acosentino]

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 50a00dd5deb3b4a8d992b496240e0ea73b406cb5
Author: Andrea Cosentino <anco...@gmail.com>
AuthorDate: Tue Sep 20 15:35:30 2022 +0200

    CAMEL-18504 - camel-google-secret-manager - Add dev console for secrets
    
    Signed-off-by: Andrea Cosentino <anco...@gmail.com>
---
 .../secret/manager/vault/PubsubReloadTriggerTask.java | 19 +++++++++++++++++++
 1 file changed, 19 insertions(+)

diff --git 
a/components/camel-google/camel-google-secret-manager/src/main/java/org/apache/camel/component/google/secret/manager/vault/PubsubReloadTriggerTask.java
 
b/components/camel-google/camel-google-secret-manager/src/main/java/org/apache/camel/component/google/secret/manager/vault/PubsubReloadTriggerTask.java
index d7acff94812..2bc8e3396bc 100644
--- 
a/components/camel-google/camel-google-secret-manager/src/main/java/org/apache/camel/component/google/secret/manager/vault/PubsubReloadTriggerTask.java
+++ 
b/components/camel-google/camel-google-secret-manager/src/main/java/org/apache/camel/component/google/secret/manager/vault/PubsubReloadTriggerTask.java
@@ -67,6 +67,8 @@ public class PubsubReloadTriggerTask extends ServiceSupport 
implements CamelCont
     private String secrets;
     private Subscriber subscriber;
     private GoogleSecretManagerPropertiesFunction propertiesFunction;
+    private volatile Instant lastCheckTime;
+    private volatile Instant lastReloadTime;
     private final Map<String, Instant> updates = new HashMap<>();
 
     public PubsubReloadTriggerTask() {
@@ -99,6 +101,20 @@ public class PubsubReloadTriggerTask extends ServiceSupport 
implements CamelCont
     public Map<String, Instant> getUpdates() {
         return Collections.unmodifiableMap(updates);
     }
+    
+    /**
+     * Last time this task checked GCP for updated secrets.
+     */
+    public Instant getLastCheckTime() {
+        return lastCheckTime;
+    }
+
+    /**
+     * Last time GCP secrets update triggered reload.
+     */
+    public Instant getLastReloadTime() {
+        return lastReloadTime;
+    }
 
     @Override
     protected void doStart() throws Exception {
@@ -169,6 +185,8 @@ public class PubsubReloadTriggerTask extends ServiceSupport 
implements CamelCont
 
     @Override
     public void run() {
+        lastCheckTime = Instant.now();
+        
         subscriber.startAsync().awaitRunning();
     }
 
@@ -220,6 +238,7 @@ public class PubsubReloadTriggerTask extends ServiceSupport 
implements CamelCont
                 ContextReloadStrategy reload = 
camelContext.hasService(ContextReloadStrategy.class);
                 if (reload != null) {
                     // trigger reload
+                       lastReloadTime = Instant.now();
                     reload.onReload(this);
                 }
             }