2 * ============LICENSE_START=======================================================
3 * ONAP : ccsdk features
4 * ================================================================================
5 * Copyright (C) 2019 highstreet technologies GmbH Intellectual Property.
7 * ================================================================================
8 * Licensed under the Apache License, Version 2.0 (the "License");
9 * you may not use this file except in compliance with the License.
10 * You may obtain a copy of the License at
12 * http://www.apache.org/licenses/LICENSE-2.0
14 * Unless required by applicable law or agreed to in writing, software
15 * distributed under the License is distributed on an "AS IS" BASIS,
16 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
17 * See the License for the specific language governing permissions and
18 * limitations under the License.
19 * ============LICENSE_END=========================================================
22 package org.onap.ccsdk.features.sdnr.wt.dataprovider.impl;
24 import org.onap.ccsdk.features.sdnr.wt.common.database.HtDatabaseClient;
25 import org.onap.ccsdk.features.sdnr.wt.dataprovider.http.AboutHttpServlet;
26 import org.onap.ccsdk.features.sdnr.wt.dataprovider.http.DataTreeHttpServlet;
27 import org.onap.ccsdk.features.sdnr.wt.dataprovider.http.MsServlet;
28 import org.onap.ccsdk.features.sdnr.wt.dataprovider.http.ReadyHttpServlet;
29 import org.onap.ccsdk.features.sdnr.wt.dataprovider.model.DataProvider;
30 import org.onap.ccsdk.features.sdnr.wt.dataprovider.model.HtDatabaseMaintenance;
31 import org.onap.ccsdk.features.sdnr.wt.dataprovider.model.IEntityDataProvider;
32 import org.onap.ccsdk.features.sdnr.wt.dataprovider.model.IEsConfig;
33 import org.onap.ccsdk.features.sdnr.wt.dataprovider.model.NetconfTimeStamp;
34 import org.onap.ccsdk.features.sdnr.wt.dataprovider.model.StatusChangedHandler.StatusKey;
35 import org.onap.ccsdk.features.sdnr.wt.dataprovider.model.types.NetconfTimeStampImpl;
36 import org.opendaylight.mdsal.binding.api.RpcProviderService;
37 import org.slf4j.Logger;
38 import org.slf4j.LoggerFactory;
40 public class DataProviderImpl implements IEntityDataProvider, AutoCloseable {
42 private static final Logger LOG = LoggerFactory.getLogger(DataProviderImpl.class);
44 private static final String APPLICATION_NAME = "data-provider";
45 private RpcProviderService rpcProviderService = null;
46 private MsServlet mediatorServerServlet;
47 private DataProviderServiceImpl rpcApiService;
48 private AboutHttpServlet aboutServlet;
49 private DataTreeHttpServlet treeServlet;
50 private HtDatabaseClient dbClient;
53 public DataProviderImpl() {
55 LOG.info("Creating provider for {}", APPLICATION_NAME);
58 public void setRpcProviderService(RpcProviderService rpcProviderService) {
59 this.rpcProviderService = rpcProviderService;
62 public void setMediatorServerServlet(MsServlet servlet) {
63 this.mediatorServerServlet = servlet;
66 public void setAboutServlet(AboutHttpServlet aboutServlet) {
67 this.aboutServlet = aboutServlet;
70 public void setTreeServlet(DataTreeHttpServlet treeServlet) {
71 this.treeServlet = treeServlet;
74 public void init() throws Exception {
76 LOG.info("Session Initiated start {}", APPLICATION_NAME);
79 this.rpcApiService = new DataProviderServiceImpl(rpcProviderService, this.mediatorServerServlet);
80 this.treeServlet.setDatabaseClient(this.rpcApiService.getRawClient());
81 LOG.info("Session Initiated end. Initialization done");
85 public void close() throws Exception {
86 LOG.info("DeviceManagerImpl closing ...");
90 LOG.info("DeviceManagerImpl closing done");
94 * Used to close all Services, that should support AutoCloseable Pattern
99 private void close(AutoCloseable... toCloseList) throws Exception {
100 for (AutoCloseable element : toCloseList) {
101 if (element != null) {
108 public DataProvider getDataProvider() {
109 return rpcApiService.getDataProvider();
113 public HtDatabaseMaintenance getHtDatabaseMaintenance() {
114 return rpcApiService.getHtDatabaseMaintenance();
118 public IEsConfig getEsConfig() {
119 return rpcApiService.getEsConfig();
123 public NetconfTimeStamp getConverter() {
124 return NetconfTimeStampImpl.getConverter();
128 public void setReadyStatus(boolean status) {
129 ReadyHttpServlet.setStatus(status);
133 public void setStatus(StatusKey key, String value) {
134 if (this.aboutServlet != null) {
135 if (key == StatusKey.CLUSTER_SIZE) {
136 this.aboutServlet.setClusterSize(value);