diff options
Diffstat (limited to 'appc-directed-graph/dg-loader/provider/src/main/java/org/onap/sdnc/dg/loader/DGXMLActivate.java')
-rw-r--r-- | appc-directed-graph/dg-loader/provider/src/main/java/org/onap/sdnc/dg/loader/DGXMLActivate.java | 61 |
1 files changed, 34 insertions, 27 deletions
diff --git a/appc-directed-graph/dg-loader/provider/src/main/java/org/onap/sdnc/dg/loader/DGXMLActivate.java b/appc-directed-graph/dg-loader/provider/src/main/java/org/onap/sdnc/dg/loader/DGXMLActivate.java index 6af447742..9050fa061 100644 --- a/appc-directed-graph/dg-loader/provider/src/main/java/org/onap/sdnc/dg/loader/DGXMLActivate.java +++ b/appc-directed-graph/dg-loader/provider/src/main/java/org/onap/sdnc/dg/loader/DGXMLActivate.java @@ -22,12 +22,11 @@ * ============LICENSE_END========================================================= */ -package org.openecomp.sdnc.dg.loader; +package org.onap.sdnc.dg.loader; import java.io.File; import java.util.ArrayList; import java.util.List; - import org.apache.commons.io.FileUtils; import org.apache.commons.lang.StringUtils; import org.onap.ccsdk.sli.core.sli.SvcLogicGraph; @@ -44,63 +43,70 @@ public class DGXMLActivate { private final SvcLogicStore store; public static String STRING_ENCODING = "utf-8"; - public DGXMLActivate(String propfile) throws Exception{ - if(StringUtils.isBlank(propfile)){ + public DGXMLActivate(String propfile) throws Exception { + if (StringUtils.isBlank(propfile)) { throw new Exception(propfile + " Profile file is not defined"); } this.store = SvcLogicStoreFactory.getSvcLogicStore(propfile); } - + protected DGXMLActivate(SvcLogicStore store) { this.store = store; } public void activateDg(String activateFilePath) throws Exception { - logger.info("******************** Activating DG into Database *****************************"); + logger.info( + "******************** Activating DG into Database *****************************"); try { List<String> errors = new ArrayList<String>(); - if(this.store != null){ + if (this.store != null) { File activateFile = new File(activateFilePath); - if(activateFile != null && activateFile.isFile()){ - List<String> fileLines = FileUtils.readLines(activateFile,STRING_ENCODING); - if(fileLines != null ){ + if (activateFile != null && activateFile.isFile()) { + List<String> fileLines = FileUtils.readLines(activateFile, STRING_ENCODING); + if (fileLines != null) { for (String line : fileLines) { - if(line != null && ! line.trim().startsWith("#")){ + if (line != null && !line.trim().startsWith("#")) { String lineArray[] = line.trim().split(":"); try { - if(lineArray != null && lineArray.length >= 4){ + if (lineArray != null && lineArray.length >= 4) { String module = lineArray[0]; String rpc = lineArray[1]; String version = lineArray[2]; String mode = lineArray[3]; - if(StringUtils.isNotBlank(module) && StringUtils.isNotBlank(rpc) - && StringUtils.isNotBlank(version) && StringUtils.isNotBlank(mode)){ + if (StringUtils.isNotBlank(module) + && StringUtils.isNotBlank(rpc) + && StringUtils.isNotBlank(version) + && StringUtils.isNotBlank(mode)) { logger.info("Activating DG :" + line); - SvcLogicGraph graph = this.store.fetch(module, rpc, version, mode); - if(graph != null){ - logger.info("Found Graph :" + line + " Activating ..."); + SvcLogicGraph graph = + this.store.fetch(module, rpc, version, mode); + if (graph != null) { + logger.info( + "Found Graph :" + line + " Activating ..."); this.store.activate(graph); - }else{ - throw new Exception("Failed to fetch from Database"); + } else { + throw new Exception( + "Failed to fetch from Database"); } } } } catch (Exception e) { e.printStackTrace(); - errors.add("Failed to Activate "+line + ", "+e.getMessage()); + errors.add( + "Failed to Activate " + line + ", " + e.getMessage()); } } } } - }else{ + } else { throw new Exception(activateFile + " is not a valid Activate file Path"); } - }else{ + } else { throw new Exception("Failed to initialise SvcLogicStore"); } - if(errors.size() > 0){ + if (errors.size() > 0) { throw new Exception(errors.toString()); } } catch (Exception e) { @@ -114,18 +120,19 @@ public class DGXMLActivate { String activateFile = null; String propertyPath = null; - if(args != null && args.length >= 2){ + if (args != null && args.length >= 2) { activateFile = args[0]; propertyPath = args[1]; - }else{ - throw new Exception("Sufficient inputs for DGXMLActivate are missing <activatefile> <dbPropertyfile>"); + } else { + throw new Exception( + "Sufficient inputs for DGXMLActivate are missing <activatefile> <dbPropertyfile>"); } DGXMLActivate dgXmlActivate = new DGXMLActivate(propertyPath); dgXmlActivate.activateDg(activateFile); } catch (Exception e) { e.printStackTrace(); - }finally { + } finally { System.exit(1); } } |