sdnr/wt/data-provider/provider/src/main/java/org/onap/ccsdk/features/sdnr/wt/dataprovider/impl/DataProviderServiceImpl.java

   1 /*******************************************************************************
   2  * ============LICENSE_START========================================================================
   3  * ONAP : ccsdk feature sdnr wt
   4  * =================================================================================================
   5  * Copyright (C) 2019 highstreet technologies GmbH Intellectual Property. All rights reserved.
   6  * =================================================================================================
   7  * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except
   8  * in compliance with the License. You may obtain a copy of the License at
   9  *
  10  * http://www.apache.org/licenses/LICENSE-2.0
  11  *
  12  * Unless required by applicable law or agreed to in writing, software distributed under the License
  13  * is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express
  14  * or implied. See the License for the specific language governing permissions and limitations under
  15  * the License.
  16  * ============LICENSE_END==========================================================================
  17  ******************************************************************************/
  18 package org.onap.ccsdk.features.sdnr.wt.dataprovider.impl;
  19
  20 import java.io.IOException;
  21 import java.io.PrintWriter;
  22 import java.io.StringWriter;
  23 import java.util.concurrent.TimeUnit;
  24
  25 import org.eclipse.jdt.annotation.NonNull;
  26 import org.onap.ccsdk.features.sdnr.wt.common.configuration.ConfigurationFileRepresentation;
  27 import org.onap.ccsdk.features.sdnr.wt.database.config.EsConfig;
  28 import org.onap.ccsdk.features.sdnr.wt.dataprovider.data.ElasticSearchDataProvider;
  29 import org.onap.ccsdk.features.sdnr.wt.dataprovider.model.DataProvider;
  30 import org.opendaylight.mdsal.binding.api.RpcProviderService;
  31 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev190801.CreateMaintenanceInput;
  32 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev190801.CreateMaintenanceOutput;
  33 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev190801.CreateMediatorServerInput;
  34 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev190801.CreateMediatorServerOutput;
  35 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev190801.CreateNetworkElementConnectionInput;
  36 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev190801.CreateNetworkElementConnectionOutput;
  37 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev190801.DataProviderService;
  38 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev190801.DeleteMaintenanceInput;
  39 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev190801.DeleteMaintenanceOutput;
  40 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev190801.DeleteMediatorServerInput;
  41 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev190801.DeleteMediatorServerOutput;
  42 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev190801.DeleteNetworkElementConnectionInput;
  43 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev190801.DeleteNetworkElementConnectionOutput;
  44 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev190801.ReadConnectionlogListInput;
  45 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev190801.ReadConnectionlogListOutput;
  46 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev190801.ReadEventlogListInput;
  47 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev190801.ReadEventlogListOutput;
  48 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev190801.ReadFaultcurrentListInput;
  49 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev190801.ReadFaultcurrentListOutput;
  50 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev190801.ReadFaultlogListInput;
  51 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev190801.ReadFaultlogListOutput;
  52 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev190801.ReadInventoryListInput;
  53 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev190801.ReadInventoryListOutput;
  54 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev190801.ReadMaintenanceListInput;
  55 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev190801.ReadMaintenanceListOutput;
  56 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev190801.ReadMediatorServerListInput;
  57 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev190801.ReadMediatorServerListOutput;
  58 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev190801.ReadNetworkElementConnectionListInput;
  59 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev190801.ReadNetworkElementConnectionListOutput;
  60 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev190801.ReadPmdata15mDeviceListInput;
  61 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev190801.ReadPmdata15mDeviceListOutput;
  62 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev190801.ReadPmdata15mListInput;
  63 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev190801.ReadPmdata15mListOutput;
  64 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev190801.ReadPmdata15mLtpListInput;
  65 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev190801.ReadPmdata15mLtpListOutput;
  66 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev190801.ReadPmdata24hDeviceListInput;
  67 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev190801.ReadPmdata24hDeviceListOutput;
  68 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev190801.ReadPmdata24hListInput;
  69 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev190801.ReadPmdata24hListOutput;
  70 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev190801.ReadPmdata24hLtpListInput;
  71 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev190801.ReadPmdata24hLtpListOutput;
  72 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev190801.ReadStatusInput;
  73 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev190801.ReadStatusOutput;
  74 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev190801.UpdateMaintenanceInput;
  75 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev190801.UpdateMaintenanceOutput;
  76 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev190801.UpdateMediatorServerInput;
  77 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev190801.UpdateMediatorServerOutput;
  78 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev190801.UpdateNetworkElementConnectionInput;
  79 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev190801.UpdateNetworkElementConnectionOutput;
  80 import org.opendaylight.yangtools.concepts.Builder;
  81 import org.opendaylight.yangtools.concepts.ObjectRegistration;
  82 import org.opendaylight.yangtools.yang.binding.DataObject;
  83 import org.opendaylight.yangtools.yang.common.RpcError.ErrorType;
  84 import org.opendaylight.yangtools.yang.common.RpcResult;
  85 import org.opendaylight.yangtools.yang.common.RpcResultBuilder;
  86 import org.slf4j.Logger;
  87 import org.slf4j.LoggerFactory;
  88
  89 import com.google.common.util.concurrent.ListenableFuture;
  90
  91 public class DataProviderServiceImpl implements DataProviderService, AutoCloseable {
  92
  93     private static final Logger LOG = LoggerFactory.getLogger(DataProviderServiceImpl.class);
  94     public static final String CONFIGURATIONFILE = "etc/dataprovider.properties";
  95     private static final long DATABASE_TIMEOUT_MS = 120*1000L;
  96
  97     private final ObjectRegistration<@NonNull DataProviderServiceImpl> rpcReg;
  98     private final ElasticSearchDataProvider dataProvider;
  99     private final ConfigurationFileRepresentation configuration;
 100
 101     DataProviderServiceImpl(final RpcProviderService rpcProviderService) throws Exception {
 102         this.configuration = new ConfigurationFileRepresentation(CONFIGURATIONFILE);
 103         EsConfig esConfig = new EsConfig(configuration);
 104         this.dataProvider = new ElasticSearchDataProvider(esConfig.getHosts());
 105         this.dataProvider.waitForYellowDatabaseStatus(DATABASE_TIMEOUT_MS,TimeUnit.MILLISECONDS);
 106         // Register ourselves as the REST API RPC implementation
 107         LOG.info("Register RPC Service " + DataProviderServiceImpl.class.getSimpleName());
 108         this.rpcReg = rpcProviderService.registerRpcImplementation(DataProviderService.class, this);
 109     }
 110
 111     /**
 112      * @return the dataProvider
 113      */
 114     public DataProvider getDataProvider() {
 115         return dataProvider.getDataProvider();
 116     }
 117
 118
 119
 120     @Override
 121     public void close() throws Exception {
 122         LOG.info("Close RPC Service");
 123         if (rpcReg != null) {
 124             rpcReg.close();
 125         }
 126     }
 127
 128     @Override
 129     public ListenableFuture<RpcResult<ReadFaultcurrentListOutput>> readFaultcurrentList(ReadFaultcurrentListInput input) {
 130         LOG.debug("RPC Request: getFaultCurrentEntityList with input {}", input);
 131         RpcResultBuilder<ReadFaultcurrentListOutput> result = read(()-> DataProviderServiceImpl.this.dataProvider.readFaultCurrentList(input));
 132         return result.buildFuture();
 133     }
 134     @Override
 135     public ListenableFuture<RpcResult<ReadFaultlogListOutput>> readFaultlogList(ReadFaultlogListInput input) {
 136         LOG.debug("RPC Request: getFaultCurrentEntityList with input {}", input);
 137         RpcResultBuilder<ReadFaultlogListOutput> result = read(()-> DataProviderServiceImpl.this.dataProvider.readFaultLogList(input));
 138         return result.buildFuture();
 139     }
 140
 141     @Override
 142     public ListenableFuture<RpcResult<ReadMaintenanceListOutput>> readMaintenanceList(ReadMaintenanceListInput input) {
 143         LOG.debug("RPC Request: getMaintenanceEntityList with input {}", input);
 144         RpcResultBuilder<ReadMaintenanceListOutput> result = read(()-> DataProviderServiceImpl.this.dataProvider.readMaintenanceList(input));
 145         return result.buildFuture();
 146     }
 147
 148     @Override
 149     public ListenableFuture<RpcResult<ReadMediatorServerListOutput>> readMediatorServerList(
 150             ReadMediatorServerListInput input) {
 151         LOG.debug("RPC Request: getMediatorServerEntityList with input {}", input);
 152         RpcResultBuilder<ReadMediatorServerListOutput> result = read(()-> DataProviderServiceImpl.this.dataProvider.readMediatorServerList(input));
 153         return result.buildFuture();
 154     }
 155
 156     @Override
 157     public ListenableFuture<RpcResult<ReadNetworkElementConnectionListOutput>> readNetworkElementConnectionList(
 158             ReadNetworkElementConnectionListInput input) {
 159         LOG.debug("RPC Request: getNetworkElementConnectionEntityList with input {}", input);
 160         RpcResultBuilder<ReadNetworkElementConnectionListOutput> result = read(()-> DataProviderServiceImpl.this.dataProvider.readNetworkElementConnectionList(input));
 161         return result.buildFuture();
 162
 163     }
 164
 165     @Override
 166     public ListenableFuture<RpcResult<ReadPmdata15mListOutput>> readPmdata15mList(ReadPmdata15mListInput input) {
 167         LOG.debug("RPC Request: getNetworkElementConnectionEntityList with input {}", input);
 168         RpcResultBuilder<ReadPmdata15mListOutput> result = read(()-> DataProviderServiceImpl.this.dataProvider.readPmdata15mList(input));
 169         return result.buildFuture();
 170
 171     }
 172     @Override
 173     public ListenableFuture<RpcResult<ReadPmdata24hListOutput>> readPmdata24hList(ReadPmdata24hListInput input) {
 174         LOG.debug("RPC Request: getNetworkElementConnectionEntityList with input {}", input);
 175         RpcResultBuilder<ReadPmdata24hListOutput> result = read(()-> DataProviderServiceImpl.this.dataProvider.readPmdata24hList(input));
 176         return result.buildFuture();
 177
 178     }
 179     @Override
 180     public ListenableFuture<RpcResult<ReadStatusOutput>> readStatus(ReadStatusInput input) {
 181         LOG.debug("RPC Request: getStatusEntityList with input {}", input);
 182         RpcResultBuilder<ReadStatusOutput> result = read(()-> DataProviderServiceImpl.this.dataProvider.readStatus());
 183         return result.buildFuture();
 184
 185     }
 186
 187     @Override
 188     public ListenableFuture<RpcResult<ReadInventoryListOutput>> readInventoryList(ReadInventoryListInput input) {
 189         LOG.debug("RPC Request: getInventoryEntityList with input {}", input);
 190         RpcResultBuilder<ReadInventoryListOutput> result = read(()-> DataProviderServiceImpl.this.dataProvider.readInventoryList(input));
 191         return result.buildFuture();
 192     }
 193
 194     @Override
 195     public ListenableFuture<RpcResult<ReadPmdata15mLtpListOutput>> readPmdata15mLtpList(ReadPmdata15mLtpListInput input) {
 196         LOG.debug("RPC Request: readPmdataLtpList with input {}", input);
 197         RpcResultBuilder<ReadPmdata15mLtpListOutput> result = read(()-> DataProviderServiceImpl.this.dataProvider.readPmdata15mLtpList(input));
 198         return result.buildFuture();
 199     }
 200
 201     @Override
 202     public ListenableFuture<RpcResult<ReadPmdata15mDeviceListOutput>> readPmdata15mDeviceList(ReadPmdata15mDeviceListInput input) {
 203             LOG.debug("RPC Request: readPmdataDeviceList with input {}", input);
 204             RpcResultBuilder<ReadPmdata15mDeviceListOutput> result = read(()-> DataProviderServiceImpl.this.dataProvider.readPmdata15mDeviceList(input));
 205             return result.buildFuture();
 206     }
 207
 208     @Override
 209     public ListenableFuture<RpcResult<ReadPmdata24hLtpListOutput>> readPmdata24hLtpList(ReadPmdata24hLtpListInput input) {
 210         LOG.debug("RPC Request: readPmdataLtpList with input {}", input);
 211         RpcResultBuilder<ReadPmdata24hLtpListOutput> result = read(()-> DataProviderServiceImpl.this.dataProvider.readPmdata24hLtpList(input));
 212         return result.buildFuture();
 213     }
 214
 215     @Override
 216     public ListenableFuture<RpcResult<ReadPmdata24hDeviceListOutput>> readPmdata24hDeviceList(ReadPmdata24hDeviceListInput input) {
 217             LOG.debug("RPC Request: readPmdataDeviceList with input {}", input);
 218             RpcResultBuilder<ReadPmdata24hDeviceListOutput> result = read(()-> DataProviderServiceImpl.this.dataProvider.readPmdata24hDeviceList(input));
 219             return result.buildFuture();
 220     }
 221
 222     @Override
 223     public ListenableFuture<RpcResult<ReadConnectionlogListOutput>> readConnectionlogList(
 224             ReadConnectionlogListInput input) {
 225         LOG.debug("RPC Request: readConnectionlogList with input {}", input);
 226         RpcResultBuilder<ReadConnectionlogListOutput> result = read(() -> DataProviderServiceImpl.this.dataProvider.readConnectionlogList(input));
 227         return result.buildFuture();
 228     }
 229
 230     @Override
 231     public ListenableFuture<RpcResult<CreateNetworkElementConnectionOutput>> createNetworkElementConnection(
 232             CreateNetworkElementConnectionInput input) {
 233         LOG.debug("RPC Request: createNetworkElementConnection with input {}", input);
 234         RpcResultBuilder<CreateNetworkElementConnectionOutput> result = read(() -> DataProviderServiceImpl.this.dataProvider.createNetworkElementConnection(input));
 235         return result.buildFuture();
 236     }
 237
 238     @Override
 239     public ListenableFuture<RpcResult<UpdateNetworkElementConnectionOutput>> updateNetworkElementConnection(
 240             UpdateNetworkElementConnectionInput input) {
 241         LOG.debug("RPC Request: updateNetworkElementConnection with input {}", input);
 242         RpcResultBuilder<UpdateNetworkElementConnectionOutput> result = read(() -> DataProviderServiceImpl.this.dataProvider.updateNetworkElementConnection(input));
 243         return result.buildFuture();
 244     }
 245
 246     @Override
 247     public ListenableFuture<RpcResult<DeleteNetworkElementConnectionOutput>> deleteNetworkElementConnection(
 248             DeleteNetworkElementConnectionInput input) {
 249         RpcResultBuilder<DeleteNetworkElementConnectionOutput> result = read(() -> DataProviderServiceImpl.this.dataProvider.deleteNetworkElementConnection(input));
 250         return result.buildFuture();
 251     }
 252
 253     @Override
 254     public ListenableFuture<RpcResult<DeleteMediatorServerOutput>> deleteMediatorServer(
 255             DeleteMediatorServerInput input) {
 256         LOG.debug("RPC Request: deleteMediatorServer with input {}", input);
 257         RpcResultBuilder<DeleteMediatorServerOutput> result = read(() -> DataProviderServiceImpl.this.dataProvider.deleteMediatorServer(input));
 258         return result.buildFuture();
 259     }
 260
 261     @Override
 262     public ListenableFuture<RpcResult<CreateMediatorServerOutput>> createMediatorServer(
 263             CreateMediatorServerInput input) {
 264         LOG.debug("RPC Request: createMediatorServer with input {}", input);
 265         RpcResultBuilder<CreateMediatorServerOutput> result = read(() -> DataProviderServiceImpl.this.dataProvider.createMediatorServer(input));
 266         return result.buildFuture();
 267     }
 268
 269     @Override
 270     public ListenableFuture<RpcResult<CreateMaintenanceOutput>> createMaintenance(CreateMaintenanceInput input) {
 271         LOG.debug("RPC Request: createMaintenance with input {}", input);
 272         RpcResultBuilder<CreateMaintenanceOutput> result = read(() -> DataProviderServiceImpl.this.dataProvider.createMaintenance(input));
 273         return result.buildFuture();
 274     }
 275
 276     @Override
 277     public ListenableFuture<RpcResult<DeleteMaintenanceOutput>> deleteMaintenance(DeleteMaintenanceInput input) {
 278         LOG.debug("RPC Request: deleteMaintenance with input {}", input);
 279         RpcResultBuilder<DeleteMaintenanceOutput> result = read(() -> DataProviderServiceImpl.this.dataProvider.deleteMaintenance(input));
 280         return result.buildFuture();
 281     }
 282
 283     @Override
 284     public ListenableFuture<RpcResult<UpdateMediatorServerOutput>> updateMediatorServer(
 285             UpdateMediatorServerInput input) {
 286         LOG.debug("RPC Request: updateMediatorServer with input {}", input);
 287         RpcResultBuilder<UpdateMediatorServerOutput> result = read(() -> DataProviderServiceImpl.this.dataProvider.updateMediatorServer(input));
 288         return result.buildFuture();
 289     }
 290
 291     @Override
 292     public ListenableFuture<RpcResult<UpdateMaintenanceOutput>> updateMaintenance(UpdateMaintenanceInput input) {
 293         LOG.debug("RPC Request: updateMaintenance with input {}", input);
 294         RpcResultBuilder<UpdateMaintenanceOutput> result = read(() -> DataProviderServiceImpl.this.dataProvider.updateMaintenance(input));
 295         return result.buildFuture();
 296     }
 297
 298     @Override
 299     public ListenableFuture<RpcResult<ReadEventlogListOutput>> readEventlogList(ReadEventlogListInput input) {
 300         LOG.debug("RPC Request: readEventlogList with input {}", input);
 301         RpcResultBuilder<ReadEventlogListOutput> result = read(() -> DataProviderServiceImpl.this.dataProvider.readEventlogList(input));
 302         return result.buildFuture();
 303     }
 304
 305     // -- private classes and functions
 306
 307     private static String assembleExceptionMessage(Exception e) {
 308         StringWriter sw = new StringWriter();
 309         PrintWriter pw = new PrintWriter(sw);
 310         e.printStackTrace(pw);
 311
 312         StringBuffer buf = new StringBuffer();
 313         buf.append("Exception: ");
 314         buf.append(sw.toString());
 315         return buf.toString();
 316     }
 317
 318     private interface GetEntityInput<O extends DataObject> {
 319         Builder<O> get() throws IOException;
 320     }
 321
 322     private static <O extends DataObject,I extends DataObject> RpcResultBuilder<O> read(GetEntityInput<O> inputgetter ) {
 323         RpcResultBuilder<O> result;
 324         try {
 325             Builder<O> outputBuilder = inputgetter.get();
 326             result = RpcResultBuilder.success(outputBuilder);
 327         } catch (Exception e) {
 328             LOG.info("Exception", e);
 329             result = RpcResultBuilder.failed();
 330             result.withError(ErrorType.APPLICATION, assembleExceptionMessage(e));
 331         }
 332         return result;
 333     }
 334
 335 }