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.aaiclient.client.aai.AAIResourcesClient;
  31 import org.onap.aaiclient.client.aai.entities.AAIResultWrapper;
  32 import org.onap.aaiclient.client.aai.entities.uri.AAIResourceUri;
  33 import org.onap.aaiclient.client.aai.entities.uri.AAIUriFactory;
  34 import org.onap.aaiclient.client.generated.fluentbuilders.AAIFluentTypeBuilder;
  35 import org.onap.aaiclient.client.graphinventory.entities.uri.Depth;
  36 import org.onap.so.apihandlerinfra.tenantisolation.exceptions.AAIClientCallFailed;
  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 =
  54                 AAIUriFactory.createResourceUri(AAIFluentTypeBuilder.cloudInfrastructure().operationalEnvironment(id));
  55         uri.depth(Depth.ZERO);
  56         AAIResourcesClient client = this.getClient();
  57         return client.get(uri, NotFoundException.class);
  58     }
  59
  60
  61     /**
  62      * Update managing ECOMP Environment Info from A&AI
  63      *
  64      * @param id = operationalEnvironmentId
  65      * @param aaiRequest object
  66      */
  67     public void updateAaiOperationalEnvironment(String id, OperationalEnvironment aaiRequest) {
  68
  69         AAIResourceUri uri =
  70                 AAIUriFactory.createResourceUri(AAIFluentTypeBuilder.cloudInfrastructure().operationalEnvironment(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 AAIClientCallFailed {
  79         try {
  80             AAIResourceUri uri = AAIUriFactory.createResourceUri(
  81                     AAIFluentTypeBuilder.cloudInfrastructure().operationalEnvironment(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 operationalEnvironment object
  94      */
  95     public void createOperationalEnvironment(OperationalEnvironment operationalEnvironment) {
  96
  97         AAIResourceUri uri = AAIUriFactory.createResourceUri(AAIFluentTypeBuilder.cloudInfrastructure()
  98                 .operationalEnvironment(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(AAIFluentTypeBuilder.cloudInfrastructure()
 113                 .operationalEnvironment(managingEcompOperationalEnvironmentId));
 114         AAIResourceUri vnfEnvUri = AAIUriFactory.createResourceUri(
 115                 AAIFluentTypeBuilder.cloudInfrastructure().operationalEnvironment(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 }