mso-api-handlers/mso-api-handler-infra/src/main/java/org/onap/so/apihandlerinfra/tenantisolation/helpers/AAIClientHelper.java

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  * ONAP - SO
   4  * ================================================================================
   5  * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
   6  * ================================================================================
   7  * Modifications Copyright (c) 2019 Samsung
   8  * ================================================================================
   9  * Licensed under the Apache License, Version 2.0 (the "License");
  10  * you may not use this file except in compliance with the License.
  11  * You may obtain a copy of the License at
  12  *
  13  *      http://www.apache.org/licenses/LICENSE-2.0
  14  *
  15  * Unless required by applicable law or agreed to in writing, software
  16  * distributed under the License is distributed on an "AS IS" BASIS,
  17  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  18  * See the License for the specific language governing permissions and
  19  * limitations under the License.
  20  * ============LICENSE_END=========================================================
  21  */
  22
  23 package org.onap.so.apihandlerinfra.tenantisolation.helpers;
  24
  25 import java.io.PrintWriter;
  26 import java.io.StringWriter;
  27 import java.util.Map;
  28 import javax.ws.rs.NotFoundException;
  29 import org.onap.aai.domain.yang.OperationalEnvironment;
  30 import org.onap.so.apihandlerinfra.tenantisolation.exceptions.AAIClientCallFailed;
  31 import org.onap.so.client.aai.AAIObjectType;
  32 import org.onap.so.client.aai.AAIResourcesClient;
  33 import org.onap.so.client.aai.entities.AAIResultWrapper;
  34 import org.onap.so.client.aai.entities.uri.AAIResourceUri;
  35 import org.onap.so.client.aai.entities.uri.AAIUriFactory;
  36 import org.onap.so.client.graphinventory.entities.uri.Depth;
  37 import org.slf4j.Logger;
  38 import org.slf4j.LoggerFactory;
  39 import org.springframework.stereotype.Component;
  40
  41
  42 @Component
  43 public class AAIClientHelper {
  44
  45     private static Logger logger = LoggerFactory.getLogger(AAIClientHelper.class);
  46
  47     /**
  48      * Get managing ECOMP Environment Info from A&AI
  49      *
  50      * @param id = operationalEnvironmentId
  51      * @return AAIResultWrapper object
  52      */
  53     public AAIResultWrapper getAaiOperationalEnvironment(String id) {
  54
  55         AAIResourceUri uri = AAIUriFactory.createResourceUri(AAIObjectType.OPERATIONAL_ENVIRONMENT, id);
  56         uri.depth(Depth.ZERO);
  57         AAIResourcesClient client = this.getClient();
  58         return client.get(uri, NotFoundException.class);
  59     }
  60
  61
  62     /**
  63      * Update managing ECOMP Environment Info from A&AI
  64      *
  65      * @param id = operationalEnvironmentId
  66      * @param AAIOperationalEnvironment object
  67      */
  68     public void updateAaiOperationalEnvironment(String id, OperationalEnvironment aaiRequest) {
  69
  70         AAIResourceUri uri = AAIUriFactory.createResourceUri(AAIObjectType.OPERATIONAL_ENVIRONMENT, id);
  71         AAIResourcesClient client = this.getClient();
  72         client.update(uri, aaiRequest);
  73
  74     }
  75
  76
  77     public void updateAaiOperationalEnvironment(String operationalEnvironmentId, Map<String, String> payload)
  78             throws Exception {
  79         try {
  80             AAIResourceUri uri =
  81                     AAIUriFactory.createResourceUri(AAIObjectType.OPERATIONAL_ENVIRONMENT, operationalEnvironmentId);
  82             AAIResourcesClient aaiClient = this.getClient();
  83             aaiClient.update(uri, payload);
  84         } catch (Exception ex) {
  85             logStackTrace(ex);
  86             throw new AAIClientCallFailed("Call to A&AI failed!", ex);
  87         }
  88     }
  89
  90     /**
  91      * Create an Operational Environment object in A&AI
  92      *
  93      * @param AAIOperationalEnvironment object
  94      */
  95     public void createOperationalEnvironment(OperationalEnvironment operationalEnvironment) {
  96
  97         AAIResourceUri uri = AAIUriFactory.createResourceUri(AAIObjectType.OPERATIONAL_ENVIRONMENT,
  98                 operationalEnvironment.getOperationalEnvironmentId());
  99         AAIResourcesClient client = this.getClient();
 100         client.create(uri, operationalEnvironment);
 101     }
 102
 103     /**
 104      * Create a relationship between ECOMP managing and VNF Operational Environments
 105      *
 106      * @param managingEcompOperationalEnvironmentId
 107      * @param vnfOperationalEnvironmentId
 108      * @throws Exception
 109      */
 110     public void createRelationship(String managingEcompOperationalEnvironmentId, String vnfOperationalEnvironmentId) {
 111
 112         AAIResourceUri ecompEnvUri = AAIUriFactory.createResourceUri(AAIObjectType.OPERATIONAL_ENVIRONMENT,
 113                 managingEcompOperationalEnvironmentId);
 114         AAIResourceUri vnfEnvUri =
 115                 AAIUriFactory.createResourceUri(AAIObjectType.OPERATIONAL_ENVIRONMENT, vnfOperationalEnvironmentId);
 116         AAIResourcesClient client = this.getClient();
 117         client.connect(vnfEnvUri, ecompEnvUri);
 118
 119     }
 120
 121     private void logStackTrace(Exception e) {
 122         StringWriter sw = new StringWriter();
 123         e.printStackTrace(new PrintWriter(sw));
 124     }
 125
 126     protected AAIResourcesClient getClient() {
 127         return new AAIResourcesClient();
 128     }
 129 }