[SDC] Onboarding 1710 rebase.

[sdc.git] / openecomp-be / lib / openecomp-core-lib / openecomp-zusammen-lib / openecomp-zusammen-core / src / main / java / org / openecomp / core / zusammen / db / impl / ZusammenConnectorImpl.java

diff --git a/openecomp-be/lib/openecomp-core-lib/openecomp-zusammen-lib/openecomp-zusammen-core/src/main/java/org/openecomp/core/zusammen/db/impl/ZusammenConnectorImpl.java b/openecomp-be/lib/openecomp-core-lib/openecomp-zusammen-lib/openecomp-zusammen-core/src/main/java/org/openecomp/core/zusammen/db/impl/ZusammenConnectorImpl.java
index 8aa8e12..fa08ba4 100644 (file)
--- a/openecomp-be/lib/openecomp-core-lib/openecomp-zusammen-lib/openecomp-zusammen-core/src/main/java/org/openecomp/core/zusammen/db/impl/ZusammenConnectorImpl.java
+++ b/openecomp-be/lib/openecomp-core-lib/openecomp-zusammen-lib/openecomp-zusammen-core/src/main/java/org/openecomp/core/zusammen/db/impl/ZusammenConnectorImpl.java
@@ -3,9 +3,11 @@ package org.openecomp.core.zusammen.db.impl;
 import com.amdocs.zusammen.adaptor.inbound.api.item.ElementAdaptorFactory;
 import com.amdocs.zusammen.adaptor.inbound.api.item.ItemAdaptorFactory;
 import com.amdocs.zusammen.adaptor.inbound.api.item.ItemVersionAdaptorFactory;
+import com.amdocs.zusammen.adaptor.inbound.api.health.HealthAdaptorFactory;
 import com.amdocs.zusammen.adaptor.inbound.api.types.item.Element;
 import com.amdocs.zusammen.adaptor.inbound.api.types.item.ElementInfo;
 import com.amdocs.zusammen.adaptor.inbound.api.types.item.ZusammenElement;
+import com.amdocs.zusammen.commons.health.data.HealthInfo;
 import com.amdocs.zusammen.datatypes.Id;
 import com.amdocs.zusammen.datatypes.SessionContext;
 import com.amdocs.zusammen.datatypes.Space;
@@ -33,17 +35,29 @@ public class ZusammenConnectorImpl implements ZusammenConnector {
   private ItemAdaptorFactory itemAdaptorFactory;
   private ItemVersionAdaptorFactory versionAdaptorFactory;
   private ElementAdaptorFactory elementAdaptorFactory;
-
+  private HealthAdaptorFactory healthAdaptorFactory;
   public ZusammenConnectorImpl(
       ItemAdaptorFactory itemAdaptorFactory,
       ItemVersionAdaptorFactory versionAdaptorFactory,
-      ElementAdaptorFactory elementAdaptorFactory) {
+      ElementAdaptorFactory elementAdaptorFactory,
+      HealthAdaptorFactory healthAdaptorFactory) {
     this.itemAdaptorFactory = itemAdaptorFactory;
     this.versionAdaptorFactory = versionAdaptorFactory;
     this.elementAdaptorFactory = elementAdaptorFactory;
+    this.healthAdaptorFactory = healthAdaptorFactory;
     CassandraConnectionInitializer.setCassandraConnectionPropertiesToSystem();
   }
 
+  @Override
+  public Collection<HealthInfo> checkHealth(SessionContext sessionContext) {
+    return healthAdaptorFactory.createInterface(sessionContext).getHealthStatus(sessionContext);
+  }
+
+  @Override
+  public String getVersion(SessionContext sessionContext) {
+    return healthAdaptorFactory.createInterface(sessionContext).getVersion();
+  }
+
   @Override
   public Collection<Item> listItems(SessionContext context) {
     Response<Collection<Item>> response =