gerrit.onap Code Review - ccsdk/sli/adaptors.git/blob

   1 /*
   2  * Copyright (C) 2019 Bell Canada.
   3  *
   4  * Licensed under the Apache License, Version 2.0 (the "License");
   5  * you may not use this file except in compliance with the License.
   6  * You may obtain a copy of the License at
   7  *
   8  *      http://www.apache.org/licenses/LICENSE-2.0
   9  *
  10  * Unless required by applicable law or agreed to in writing, software
  11  * distributed under the License is distributed on an "AS IS" BASIS,
  12  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  13  * See the License for the specific language governing permissions and
  14  * limitations under the License.
  15  */
  16 package org.onap.ccsdk.sli.adaptors.grpc.cds;
  17
  18 import io.grpc.ManagedChannel;
  19 import io.grpc.internal.DnsNameResolverProvider;
  20 import io.grpc.internal.PickFirstLoadBalancerProvider;
  21 import io.grpc.netty.NettyChannelBuilder;
  22 import java.util.Map;
  23 import org.onap.ccsdk.sli.adaptors.grpc.GrpcClient;
  24 import org.onap.ccsdk.sli.adaptors.grpc.GrpcProperties;
  25 import org.onap.ccsdk.sli.core.sli.SvcLogicContext;
  26 import org.onap.ccsdk.sli.core.sli.SvcLogicResource.QueryStatus;
  27 import org.slf4j.Logger;
  28 import org.slf4j.LoggerFactory;
  29
  30 public class BlueprintProcessingClient implements GrpcClient {
  31
  32     private static final Logger log = LoggerFactory.getLogger(BlueprintProcessingClient.class);
  33
  34     private ManagedChannel channel;
  35     private BlueprintProcessingHandler handler;
  36
  37     public BlueprintProcessingClient(GrpcProperties props) {
  38         this.channel = NettyChannelBuilder
  39             .forAddress(props.getUrl(), props.getPort())
  40             .nameResolverFactory(new DnsNameResolverProvider())
  41             .loadBalancerFactory(new PickFirstLoadBalancerProvider())
  42             .usePlaintext()
  43             .build();
  44         this.handler = new BlueprintProcessingHandler();
  45     }
  46
  47     public BlueprintProcessingClient(ManagedChannel channel, BlueprintProcessingHandler handler) {
  48         this.channel = channel;
  49         this.handler = handler;
  50     }
  51
  52     // Used by blueprint
  53     public void start() {
  54         log.info("BlueprintProcessingClient started");
  55     }
  56
  57     // Used by blueprint
  58     public void stop() {
  59         if (channel != null) {
  60             channel.shutdown();
  61         }
  62         log.info("BlueprintProcessingClient stopped");
  63     }
  64
  65     /*
  66      * @param parameters HashMap<String,String> of parameters passed by the DG to this function.
  67      * <table border="1">
  68      * <thead><th>parameter</th><th>Mandatory/Optional</th><th>description</th></thead>
  69      * <tbody>
  70      * <tr><td>is_force</td><td>Optional</td><td>Whether to force or not the request.</td></tr>
  71      * <tr><td>ttl</td><td>Optional</td><td>Duration of the request.</td></tr>
  72      * <tr><td>blueprint_name</td><td>Mandatory</td><td>Name of the blueprint to process.</td></tr>
  73      * <tr><td>blueprint_version</td><td>Mandatory</td><td>Version of the blueprint to process.</td></tr>
  74      * <tr><td>action</td><td>Mandatory</td><td>Action of the blueprint to process.</td></tr>
  75      * <tr><td>mode</td><td>Mandatory</td><td>Mode to operate the transaction.</td></tr>
  76      * <tr><td>payload</td><td>Mandatory</td><td>Payload.</td></tr>
  77      * <tr><td>prefix</td><td>Mandatory</td><td>Prefix string to put response in context.</td></tr>
  78      * </tbody>
  79      * </table>
  80      */
  81     @Override
  82     public QueryStatus sendRequest(Map<String, String> parameters, SvcLogicContext ctx) {
  83         return handler.process(parameters, channel, ctx);
  84     }
  85 }