Merge "Merge from ECOMP's repository"

1 files changed, 43 insertions, 0 deletions

diff --git a/vid-app-common/src/main/java/org/onap/vid/scheduler/SchedulerServiceImpl.java b/vid-app-common/src/main/java/org/onap/vid/scheduler/SchedulerServiceImpl.java
new file mode 100644
index 000000000..99754fcde
--- /dev/null
+++ b/vid-app-common/src/main/java/org/onap/vid/scheduler/SchedulerServiceImpl.java
@@ -0,0 +1,43 @@
+package org.onap.vid.scheduler;
+
+import org.onap.vid.aai.ExceptionWithRequestInfo;
+import org.onap.vid.model.probes.ErrorMetadata;
+import org.onap.vid.model.probes.ExternalComponentStatus;
+import org.onap.vid.model.probes.HttpRequestMetadata;
+import org.onap.vid.mso.RestObjectWithRequestInfo;
+import org.onap.vid.services.ChangeManagementService;
+import org.onap.vid.utils.Logging;
+import org.springframework.beans.factory.annotation.Autowired;
+
+public class SchedulerServiceImpl implements SchedulerService{
+
+    private final ChangeManagementService changeManagementService;
+
+
+    @Autowired
+    public SchedulerServiceImpl(ChangeManagementService changeManagementService) {
+        this.changeManagementService = changeManagementService;
+    }
+
+    @Override
+    public ExternalComponentStatus probeGetSchedulerChangeManagements() {
+        long startTime = System.currentTimeMillis();
+        try {
+            RestObjectWithRequestInfo response = this.changeManagementService.getSchedulerChangeManagementsWithRequestInfo();
+            return new ExternalComponentStatus(
+                    ExternalComponentStatus.Component.SCHEDULER,
+                    true,
+                    new HttpRequestMetadata(response, "OK", startTime)
+            );
+        } catch (ExceptionWithRequestInfo e) {
+            long duration = System.currentTimeMillis() - startTime;
+            return new ExternalComponentStatus(ExternalComponentStatus.Component.SCHEDULER,
+                    false,
+                    new HttpRequestMetadata(e, duration));
+        } catch (Exception e) {
+            long duration = System.currentTimeMillis() - startTime;
+            return new ExternalComponentStatus(ExternalComponentStatus.Component.SCHEDULER, false,
+                    new ErrorMetadata(Logging.exceptionToDescription(e), duration));
+        }
+    }
+}