gerrit.onap Code Review - sdc.git/blob

   1 package org.openecomp.core.tools.concurrent;
   2
   3 import org.openecomp.sdc.vendorsoftwareproduct.VendorSoftwareProductConstants;
   4 import org.openecomp.sdc.vendorsoftwareproduct.VendorSoftwareProductManager;
   5 import org.openecomp.sdc.vendorsoftwareproduct.dao.type.VspDetails;
   6 import org.openecomp.sdc.versioning.VersioningManager;
   7 import org.openecomp.sdc.versioning.VersioningUtil;
   8 import org.openecomp.sdc.versioning.dao.types.Version;
   9 import org.openecomp.sdc.versioning.types.VersionInfo;
  10 import org.openecomp.sdc.versioning.types.VersionableEntityAction;
  11
  12 import java.util.concurrent.Callable;
  13
  14 /**
  15  * Created by ayalaben on 11/7/2017
  16  */
  17 public class ItemHealingTask implements Callable<String> {
  18
  19   private String itemId;
  20   private String versionId;
  21   private String user;
  22   private VendorSoftwareProductManager vspManager;
  23   private VersioningManager versioningManager;
  24
  25   public String getItemId() {
  26     return itemId;
  27   }
  28
  29   public String getVersionId() {
  30     return versionId;
  31   }
  32
  33
  34   public ItemHealingTask(String itemId, String versionId, String user,
  35                          VendorSoftwareProductManager vspManager,
  36                          VersioningManager versioningManager) {
  37     this.itemId = itemId;
  38     this.versionId = versionId;
  39     this.user = user;
  40     this.versioningManager = versioningManager;
  41     this.vspManager = vspManager;
  42   }
  43
  44   @Override
  45   public String call() throws Exception {
  46
  47     VersionInfo versionInfo = getVersionInfo(itemId, VersionableEntityAction.Read, user);
  48     Version resolvedVersion = VersioningUtil.resolveVersion(Version.valueOf(versionId),
  49         versionInfo, user);
  50     VspDetails vspDetails = vspManager.getVsp(itemId, resolvedVersion, user);
  51
  52     try {
  53       vspManager.callAutoHeal(itemId, versionInfo, vspDetails, user);
  54
  55     } catch (Exception e) {
  56       return (String.format("healing failed on vsp: %s with id: %s, versionId: %s, resolved " +
  57               "Version: %s, with message: %s",vspDetails.getName(),itemId,
  58           versionId,resolvedVersion,e.getMessage()));
  59     }
  60
  61     return String.format("healed vsp: %s, with id: %s, versionId:%s, resolved version: %s",
  62         vspDetails.getName(), itemId, versionId,resolvedVersion );
  63   }
  64
  65   private VersionInfo getVersionInfo(String vendorSoftwareProductId, VersionableEntityAction action,
  66                                      String user) {
  67     return versioningManager.getEntityVersionInfo(
  68         VendorSoftwareProductConstants.VENDOR_SOFTWARE_PRODUCT_VERSIONABLE_TYPE,
  69         vendorSoftwareProductId, user, action);
  70   }
  71 }