so-simulator/src/main/java/org/onap/so/simulator/actions/aai/ProcessNetwork.java

   1 package org.onap.so.simulator.actions.aai;
   2
   3 import org.onap.aai.domain.yang.L3Network;
   4 import org.onap.aaiclient.client.aai.AAIObjectType;
   5 import org.onap.aaiclient.client.aai.AAIResourcesClient;
   6 import org.onap.aaiclient.client.aai.entities.uri.AAIResourceUri;
   7 import org.onap.aaiclient.client.aai.entities.uri.AAIUriFactory;
   8 import org.slf4j.Logger;
   9 import org.slf4j.LoggerFactory;
  10 import com.consol.citrus.actions.AbstractTestAction;
  11 import com.consol.citrus.context.TestContext;
  12
  13
  14 public class ProcessNetwork extends AbstractTestAction {
  15
  16     @Override
  17     public void doExecute(TestContext context) {
  18         final Logger logger = LoggerFactory.getLogger(ProcessNetwork.class);
  19         try {
  20             int random = (int) (Math.random() * 50 + 1);
  21
  22             AAIResourcesClient aaiResourceClient = new AAIResourcesClient();
  23
  24             if (context.getVariable("action").equals("assign")) {
  25                 String networkId = context.getVariable("generatedNetworkId");
  26                 AAIResourceUri networkURI = AAIUriFactory.createResourceUri(AAIObjectType.L3_NETWORK, networkId);
  27                 L3Network network = new L3Network();
  28                 network.setNetworkId(networkId);
  29                 network.setNetworkName(context.getVariable("networkName"));
  30                 network.setNetworkType(context.getVariable("networkType"));
  31                 network.setNetworkTechnology("SR_IOV");
  32                 network.setPhysicalNetworkName("PhysicalNetwork" + random);
  33                 aaiResourceClient.create(networkURI, network);
  34             } else if (context.getVariable("action").equals("delete")) {
  35                 String networkId = context.getVariable("networkId");
  36                 AAIResourceUri networkURI = AAIUriFactory.createResourceUri(AAIObjectType.L3_NETWORK, networkId);
  37                 aaiResourceClient.delete(networkURI);
  38             }
  39         } catch (Exception e) {
  40             logger.debug("Exception in ProcessNetwork.doExecute", e);
  41         }
  42
  43     }
  44 }