--- /dev/null
+/*
+* ============LICENSE_START=======================================================
+* ONAP : SDNC-FEATURES
+* ================================================================================
+* Copyright 2018 TechMahindra
+*=================================================================================
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+* ============LICENSE_END=========================================================
+*/
+package com.onap.sdnc.vnfbackupservice.service;
+
+import java.io.IOException;
+import java.sql.Timestamp;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+
+import org.apache.log4j.Logger;
+import org.json.JSONArray;
+import org.json.JSONException;
+import org.json.JSONObject;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.http.HttpEntity;
+import org.springframework.http.HttpHeaders;
+import org.springframework.http.HttpMethod;
+import org.springframework.http.ResponseEntity;
+import org.springframework.stereotype.Service;
+import org.springframework.web.client.RestTemplate;
+
+import com.fasterxml.jackson.core.JsonParseException;
+import com.fasterxml.jackson.databind.JsonMappingException;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.onap.sdnc.vnfbackupservice.dao.VnfBackupServiceRepo;
+import com.onap.sdnc.vnfbackupservice.model.VnfConfigDetailsDB;
+import com.onap.sdnc.vnfbackupservice.model.VnfDisplayParams;
+import com.onap.sdnc.vnfbackupservice.model.VnfServiceResponse;
+
+import com.onap.sdnc.vnfbackupservice.scheduler.VnfConfigBackupScheduler;
+import com.onap.sdnc.vnfbackupservice.scheduler.VnfRestClient;
+
+@Service
+public class VnfbackupServiceImpl implements VnfbackupService {
+
+ @Autowired
+ private RestTemplate restTemplate;
+
+ @Autowired
+ VnfBackupServiceRepo vnfBackupServiceDao;
+
+ @Autowired
+ VnfConfigBackupScheduler vnfConfigBackupScheduler;
+
+ @Value("${sdnc.rest.vnf.api.host}")
+ private String host;
+
+ @Value("${sdnc.rest.vnf.api.port}")
+ private String port;
+
+ @Value("${sdnc.rest.vnf.api.basepath}")
+ private String basePath;
+
+ @Value("${sdnc.rest.vnf.api.username}")
+ private String username;
+
+ @Value("${sdnc.rest.vnf.api.password}")
+ private String password;
+
+ @Autowired
+ VnfRestClient vnfRestClientlocal;
+
+ private static final Logger logger = Logger.getLogger(VnfbackupServiceImpl.class);
+
+ @Override
+ public VnfServiceResponse getAllVnfDetails() {
+ VnfServiceResponse vnfServiceResponse = new VnfServiceResponse();
+ String finalURL = "http://" + host + ":" + port + basePath + "/config/VNF-API:vnfs";
+ String response = vnfRestClientlocal.vnfRestClient(finalURL, username, password);
+ List<VnfDisplayParams> displayParams = parseVnfConfigDetails(response);
+ vnfServiceResponse.setVnfDisplayList(displayParams);
+ return vnfServiceResponse;
+ }
+
+ public List<VnfDisplayParams> parseVnfConfigDetails(String jsonInput) {
+ List<VnfDisplayParams> displayParams = new ArrayList<VnfDisplayParams>();
+
+ try {
+ JSONObject vnf = new JSONObject(jsonInput);
+ JSONArray vnfList = vnf.getJSONObject("vnfs").getJSONArray("vnf-list");
+
+ for (int i = 0; i < vnfList.length(); i++) {
+ VnfDisplayParams vnfDisplayParams = new VnfDisplayParams();
+ String responseStatus = vnfList.getJSONObject(i).getJSONObject("service-status").get("response-code")
+ .toString();
+ if ("200".equalsIgnoreCase(responseStatus)) {
+ String vnfId = vnfList.getJSONObject(i).get("vnf-id").toString();
+ String vnfName = vnfList.getJSONObject(i).getJSONObject("service-data")
+ .getJSONObject("vnf-request-information").get("vnf-name").toString();
+ vnfDisplayParams.setVnfId(vnfId);
+ vnfDisplayParams.setVnfName(vnfName);
+ displayParams.add(vnfDisplayParams);
+ }
+ }
+ } catch (JSONException e) {
+ logger.error("Exception is at parseVnfConfigDetails() : " + e);
+ }
+ return displayParams;
+ }
+
+ @Override
+ public String backupVnfconfig(String vnfId) {
+ long millis = System.currentTimeMillis();
+ Timestamp date = new java.sql.Timestamp(millis);
+ String finalURL = "http://" + host + ":" + port + basePath + "/config/VNF-API:vnfs/vnf-list/" + vnfId;
+ logger.debug("connecting to restconf device:::" + finalURL);
+ String response = vnfRestClientlocal.vnfRestClient(finalURL, username, password);
+ String configInfo = response;
+ Timestamp creationDate = date;
+ Timestamp lastupdated = date;
+ int status = 1;
+ String vnfid = vnfId;
+ String vnfname = "";
+ VnfConfigDetailsDB getVnfDetails = null;
+ String vnfversion = "Version-1";
+ try {
+ getVnfDetails = vnfBackupServiceDao.getVnfDetail(vnfId);
+ } catch (Exception e) {
+ logger.error("exception is at getVnfdetails() : " + e);
+ }
+ if (getVnfDetails == null) {
+ JSONObject vnf;
+ try {
+ vnf = new JSONObject(response);
+ vnfname = vnf.getJSONArray("vnf-list").getJSONObject(0).getJSONObject("service-data")
+ .getJSONObject("vnf-request-information").get("vnf-name").toString();
+
+ } catch (JSONException e) {
+ logger.error("exception is at getVnfdetails() : " + e);
+ }
+ vnfBackupServiceDao.saveVnfDetails(configInfo, creationDate, lastupdated, status, vnfid, vnfname,
+ vnfversion);
+ } else {
+ try {
+ String[] vnfvesionsplit = getVnfDetails.getVnfversion().split("-");
+ int tmpVnfversion = Integer.parseInt(vnfvesionsplit[1]) + 1;
+ vnfversion = vnfvesionsplit[0] + "-" + String.valueOf(tmpVnfversion);
+
+ ObjectMapper om = new ObjectMapper();
+ try {
+ Map<String, Object> m1 = (Map<String, Object>) (om.readValue(getVnfDetails.getConfiginfo(),
+ Map.class));
+ Map<String, Object> m2 = (Map<String, Object>) (om.readValue(response, Map.class));
+
+ JSONObject vnf;
+ vnf = new JSONObject(response);
+ vnfname = vnf.getJSONArray("vnf-list").getJSONObject(0).getJSONObject("service-data")
+ .getJSONObject("vnf-request-information").get("vnf-name").toString();
+
+ if (!m1.equals(m2)) {
+ vnfBackupServiceDao.saveVnfDetails(configInfo, creationDate, lastupdated, status, vnfid,
+ vnfname, vnfversion);
+ }
+ } catch (Exception e) {
+ logger.error("exception is at getVnfdetails() : " + e);
+ }
+ } catch (Exception e) {
+ logger.error("exception is at getVnfdetails() : " + e);
+ }
+ }
+ return "success";
+ }
+
+ @Override
+ public String putVnfconfig(String configfile, String vnfId) {
+
+ String indented = null;
+
+ if (configfile != null) {
+ restTemplate = new RestTemplate();
+ String finalURL = "http://" + host + ":" + port + basePath + "/config/VNF-API:vnfs/vnf-list/" + vnfId;
+
+ HttpHeaders headers = new HttpHeaders();
+
+ logger.info("connecting to restconf device:::" + finalURL);
+ String response = vnfRestClientlocal.vnfRestClient(finalURL, username, password);
+ logger.info(response);
+ ObjectMapper mapper = new ObjectMapper();
+ try {
+ Object json = mapper.readValue(response, Object.class);
+ indented = mapper.writerWithDefaultPrettyPrinter().writeValueAsString(json);
+ logger.info(indented);
+ } catch (JsonParseException e) {
+ logger.error("exception occer" + e);
+ } catch (JsonMappingException e) {
+ logger.error("exception occer" + e);
+ } catch (IOException e) {
+ logger.error("exception occer" + e);
+ }
+
+ if (!(configfile.equals(indented))) {
+ HttpEntity<String> requestEntity = new HttpEntity<String>(configfile,
+ vnfRestClientlocal.generateHeaders(headers, username, password));
+
+ ResponseEntity<String> uri = restTemplate.exchange(finalURL, HttpMethod.PUT, requestEntity,
+ String.class);
+ logger.info(uri.getStatusCode());
+ if (uri.getStatusCodeValue() == 200) {
+ vnfConfigBackupScheduler.initiateBackupService();
+ }
+ return "ok";
+ } else {
+ throw new RuntimeException("Both configurations are same");
+ }
+ }
+ return "ok";
+ }
+
+ @Override
+ public String updatedBackuptime() {
+ String sdtime = vnfBackupServiceDao.getvnfschedulertime();
+ return sdtime;
+ }
+
+}
Code Review / nonrtric.git / blobdiff