gerrit.onap Code Review - so.git/blob

   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.aaiclient.client.aai.AAIObjectType;
  32 import org.onap.aaiclient.client.aai.AAIResourcesClient;
  33 import org.onap.aaiclient.client.aai.entities.AAIResultWrapper;
  34 import org.onap.aaiclient.client.aai.entities.uri.AAIResourceUri;
  35 import org.onap.aaiclient.client.aai.entities.uri.AAIUriFactory;
  36 import org.onap.aaiclient.client.graphinventory.entities.uri.Depth;
  37 import org.springframework.stereotype.Component;
  38
  39
  40 @Component
  41 public class AAIClientHelper {
  42
  43
  44
  45     /**
  46      * Get managing ECOMP Environment Info from A&AI
  47      *
  48      * @param id = operationalEnvironmentId
  49      * @return AAIResultWrapper object
  50      */
  51     public AAIResultWrapper getAaiOperationalEnvironment(String id) {
  52
  53         AAIResourceUri uri = AAIUriFactory.createResourceUri(AAIObjectType.OPERATIONAL_ENVIRONMENT, id);
  54         uri.depth(Depth.ZERO);
  55         AAIResourcesClient client = this.getClient();
  56         return client.get(uri, NotFoundException.class);
  57     }
  58
  59
  60     /**
  61      * Update managing ECOMP Environment Info from A&AI
  62      *
  63      * @param id = operationalEnvironmentId
  64      * @param aaiRequest object
  65      */
  66     public void updateAaiOperationalEnvironment(String id, OperationalEnvironment aaiRequest) {
  67
  68         AAIResourceUri uri = AAIUriFactory.createResourceUri(AAIObjectType.OPERATIONAL_ENVIRONMENT, id);
  69         AAIResourcesClient client = this.getClient();
  70         client.update(uri, aaiRequest);
  71
  72     }
  73
  74
  75     public void updateAaiOperationalEnvironment(String operationalEnvironmentId, Map<String, String> payload)
  76             throws AAIClientCallFailed {
  77         try {
  78             AAIResourceUri uri =
  79                     AAIUriFactory.createResourceUri(AAIObjectType.OPERATIONAL_ENVIRONMENT, operationalEnvironmentId);
  80             AAIResourcesClient aaiClient = this.getClient();
  81             aaiClient.update(uri, payload);
  82         } catch (Exception ex) {
  83             logStackTrace(ex);
  84             throw new AAIClientCallFailed("Call to A&AI failed!", ex);
  85         }
  86     }
  87
  88     /**
  89      * Create an Operational Environment object in A&AI
  90      *
  91      * @param operationalEnvironment object
  92      */
  93     public void createOperationalEnvironment(OperationalEnvironment operationalEnvironment) {
  94
  95         AAIResourceUri uri = AAIUriFactory.createResourceUri(AAIObjectType.OPERATIONAL_ENVIRONMENT,
  96                 operationalEnvironment.getOperationalEnvironmentId());
  97         AAIResourcesClient client = this.getClient();
  98         client.create(uri, operationalEnvironment);
  99     }
 100
 101     /**
 102      * Create a relationship between ECOMP managing and VNF Operational Environments
 103      *
 104      * @param managingEcompOperationalEnvironmentId
 105      * @param vnfOperationalEnvironmentId
 106      * @throws Exception
 107      */
 108     public void createRelationship(String managingEcompOperationalEnvironmentId, String vnfOperationalEnvironmentId) {
 109
 110         AAIResourceUri ecompEnvUri = AAIUriFactory.createResourceUri(AAIObjectType.OPERATIONAL_ENVIRONMENT,
 111                 managingEcompOperationalEnvironmentId);
 112         AAIResourceUri vnfEnvUri =
 113                 AAIUriFactory.createResourceUri(AAIObjectType.OPERATIONAL_ENVIRONMENT, vnfOperationalEnvironmentId);
 114         AAIResourcesClient client = this.getClient();
 115         client.connect(vnfEnvUri, ecompEnvUri);
 116
 117     }
 118
 119     private void logStackTrace(Exception e) {
 120         StringWriter sw = new StringWriter();
 121         e.printStackTrace(new PrintWriter(sw));
 122     }
 123
 124     protected AAIResourcesClient getClient() {
 125         return new AAIResourcesClient();
 126     }
 127 }