gerrit.onap Code Review - so.git/blob

   1 package org.onap.so.bpmn.infrastructure.pnf.tasks;
   2
   3 import org.onap.aai.domain.yang.Pnf;
   4 import org.onap.so.bpmn.common.BuildingBlockExecution;
   5 import org.onap.so.client.exception.BBObjectNotFoundException;
   6 import org.slf4j.Logger;
   7 import org.slf4j.LoggerFactory;
   8 import org.springframework.stereotype.Component;
   9
  10 @Component
  11 public class CreatePnfEntryInAai extends PnfBaseTasks {
  12     private static final Logger logger = LoggerFactory.getLogger(CreatePnfEntryInAai.class);
  13
  14     @Override
  15     public void execute(BuildingBlockExecution execution) throws Exception {
  16         try {
  17             org.onap.so.bpmn.servicedecomposition.bbobjects.Pnf pnf = extractPnf(execution);
  18             String pnfCorrelationId = pnf.getPnfName();
  19             pnfManagement.createEntry(pnfCorrelationId, preparePnfForAai(pnf));
  20             logger.debug("AAI entry is created for pnf correlation id: {}, pnf uuid: {}", pnfCorrelationId,
  21                     pnf.getPnfId());
  22         } catch (BBObjectNotFoundException e) {
  23             exceptionUtil.buildAndThrowWorkflowException(execution, 7000, e);
  24         }
  25     }
  26
  27     private Pnf preparePnfForAai(org.onap.so.bpmn.servicedecomposition.bbobjects.Pnf pnf) {
  28         Pnf pnfAai = new Pnf();
  29         pnfAai.setPnfId(pnf.getPnfId());
  30         pnfAai.setPnfName(pnf.getPnfName());
  31         return pnfAai;
  32     }
  33
  34 }