SPA settings

Author: krystian-panek-vmltech

core/src/main/java/com/wttech/aem/acm/core/gui/SpaSettings.java

@@ -0,0 +1,51 @@
+package com.wttech.aem.acm.core.gui;
+
+
+import org.osgi.service.component.annotations.Activate;
+import org.osgi.service.component.annotations.Component;
+import org.osgi.service.component.annotations.Modified;
+import org.osgi.service.metatype.annotations.AttributeDefinition;
+import org.osgi.service.metatype.annotations.Designate;
+import org.osgi.service.metatype.annotations.ObjectClassDefinition;
+
+import java.io.Serializable;
+
+@Component(service = SpaSettings.class, immediate = true)
+@Designate(ocd = SpaSettings.Config.class)
+public class SpaSettings implements Serializable {
+
+    private long appStateInterval;
+
+    private long executionPollInterval;
+
+    @Activate
+    @Modified
+    protected void activate(Config config) {
+        this.appStateInterval = config.appStateInterval();
+        this.executionPollInterval = config.executionPollInterval();
+    }
+
+    public long getAppStateInterval() {
+        return appStateInterval;
+    }
+
+    public long getExecutionPollInterval() {
+        return executionPollInterval;
+    }
+
+    @ObjectClassDefinition(name = "AEM Content Manager - SPA Settings")
+    public @interface Config {
+
+        @AttributeDefinition(
+                name = "Application State Interval",
+                description = "Interval in milliseconds to check application state."
+        )
+        long appStateInterval() default 3000;
+
+        @AttributeDefinition(
+                name = "Execution Poll Interval",
+                description = "Interval in milliseconds to poll execution status."
+        )
+        long executionPollInterval() default 1000;
+    }
+}

core/src/main/java/com/wttech/aem/acm/core/servlet/StateServlet.java

@@ -6,6 +6,7 @@
 
 import com.wttech.aem.acm.core.code.ExecutionQueue;
 import com.wttech.aem.acm.core.code.ExecutionSummary;
+import com.wttech.aem.acm.core.gui.SpaSettings;
 import com.wttech.aem.acm.core.instance.HealthChecker;
 import com.wttech.aem.acm.core.instance.HealthStatus;
 import com.wttech.aem.acm.core.osgi.InstanceInfo;
@@ -45,13 +46,16 @@ public class StateServlet extends SlingAllMethodsServlet {
     @Reference
     private HealthChecker healthChecker;
 
+    @Reference
+    private SpaSettings spaSettings;
+
     @Override
     protected void doGet(SlingHttpServletRequest request, SlingHttpServletResponse response) throws IOException {
         try {
             HealthStatus healthStatus = healthChecker.checkStatus();
             List<ExecutionSummary> queuedExecutions =
                     executionQueue.findAllSummaries().collect(Collectors.toList());
-            State state = new State(healthStatus, instanceInfo.getInstanceSettings(), queuedExecutions);
+            State state = new State(healthStatus, instanceInfo.getInstanceSettings(), queuedExecutions, spaSettings);
 
             respondJson(response, ok("State read successfully", state));
         } catch (Exception e) {

core/src/main/java/com/wttech/aem/acm/core/state/State.java

@@ -1,6 +1,7 @@
 package com.wttech.aem.acm.core.state;
 
 import com.wttech.aem.acm.core.code.ExecutionSummary;
+import com.wttech.aem.acm.core.gui.SpaSettings;
 import com.wttech.aem.acm.core.instance.HealthStatus;
 import com.wttech.aem.acm.core.instance.InstanceSettings;
 import java.io.Serializable;
@@ -14,11 +15,14 @@ public class State implements Serializable {
 
     private final List<ExecutionSummary> queuedExecutions;
 
+    private final SpaSettings spaSettings;
+
     public State(
-            HealthStatus healthStatus, InstanceSettings instanceSettings, List<ExecutionSummary> queuedExecutions) {
+            HealthStatus healthStatus, InstanceSettings instanceSettings, List<ExecutionSummary> queuedExecutions, SpaSettings spaSettings) {
         this.healthStatus = healthStatus;
         this.instanceSettings = instanceSettings;
         this.queuedExecutions = queuedExecutions;
+        this.spaSettings = spaSettings;
     }
 
     public HealthStatus getHealthStatus() {
@@ -32,4 +36,8 @@ public InstanceSettings getInstanceSettings() {
     public List<ExecutionSummary> getQueuedExecutions() {
         return queuedExecutions;
     }
+
+    public SpaSettings getSpaSettings() {
+        return spaSettings;
+    }
 }