1 files changed, 234 insertions, 0 deletions
diff --git a/configbackuprestore/vnfconfigbackupservice/src/main/java/com/onap/sdnc/vnfbackupservice/service/VnfbackupServiceImpl.java b/configbackuprestore/vnfconfigbackupservice/src/main/java/com/onap/sdnc/vnfbackupservice/service/VnfbackupServiceImpl.java
new file mode 100644
index 00000000..c3c86df7
--- /dev/null
+++ b/configbackuprestore/vnfconfigbackupservice/src/main/java/com/onap/sdnc/vnfbackupservice/service/VnfbackupServiceImpl.java
@@ -0,0 +1,234 @@
+/*
+* ============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;
+	}
+
+}