diff options
author | lj1412 <lji@research.att.com> | 2017-02-14 15:11:44 +0000 |
---|---|---|
committer | lj1412 <lji@research.att.com> | 2017-02-14 15:11:46 +0000 |
commit | 033f0c30154107ddf36cd682c860e95025bf00b0 (patch) | |
tree | 4113f2053aac75642c51b11bfae9a0a608c1ed72 /ncomp-sirius-manager-generator/src/main | |
parent | f6e50f2cec6365ea71696c58a96aa923eb3a1a10 (diff) |
Init ncomp.sirius.manager
Change-Id: I6691ecd21a942c96cb20cf3baa297e4b2dc7f970
Signed-off-by: lj1412 <lji@research.att.com>
Diffstat (limited to 'ncomp-sirius-manager-generator/src/main')
10 files changed, 1277 insertions, 0 deletions
diff --git a/ncomp-sirius-manager-generator/src/main/groovy/org/openecomp/ncomp/sirius/manager/generator/ControllerGenerator.groovy b/ncomp-sirius-manager-generator/src/main/groovy/org/openecomp/ncomp/sirius/manager/generator/ControllerGenerator.groovy new file mode 100644 index 0000000..cf2fd59 --- /dev/null +++ b/ncomp-sirius-manager-generator/src/main/groovy/org/openecomp/ncomp/sirius/manager/generator/ControllerGenerator.groovy @@ -0,0 +1,303 @@ + +/*- + * ============LICENSE_START========================================== + * OPENECOMP - DCAE + * =================================================================== + * Copyright (c) 2017 AT&T Intellectual Property. All rights reserved. + * =================================================================== + * 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 org.openecomp.ncomp.sirius.manager.generator +
+
+import org.openecomp.ncomp.sirius.manager.console.Utils; +import org.openecomp.ncomp.sirius.manager.controllermodel.ControllerModel + +import groovy.text.SimpleTemplateEngine
+ +import org.eclipse.emf.ecore.EClass
+import org.eclipse.emf.ecore.EFactory; +import org.eclipse.emf.ecore.EObject;
+import org.eclipse.emf.ecore.EOperation
+import org.eclipse.emf.ecore.EPackage;
+import org.json.JSONObject; +import org.yaml.snakeyaml.DumperOptions; +import org.yaml.snakeyaml.Yaml; +
+
+class ControllerGenerator {
+ EObject o + EObject providerObject + String providerPackage + String providerPrefix
+ ControllerModel m
+ EPackage p
+ String subName
+ String clientName
+ String prefix
+ String type = "R"
+ ControllerGenerator root; + boolean enableDrools = false; + boolean enableIRequestHandler = true; + boolean enableISwaggerHandler = false; + boolean enableISiriusPlugin = true;
+ public ControllerGenerator(EObject o, ControllerModel m) {
+ this.o = o
+ this.m = m
+ root = this
+ }
+ public String packageName() {
+ if (this != root && clientName == null) {
+ return root.packageName() + (root.o.eClass().EPackage != o.eClass().EPackage? "." + subName : "")
+ }
+ EPackage p = o.eClass().getEPackage()
+ return p.nsURI.replaceAll('.'+p.nsPrefix+'$',"") + ".servers.${p.nsPrefix}"
+ }
+ public String factoryName() {
+ EPackage p = o.eClass().getEPackage()
+ return "${p.nsPrefix.capitalize()}Factory"
+ }
+ public String packageName2() {
+ EPackage p = o.eClass().getEPackage()
+ return "${p.nsPrefix.capitalize()}Package"
+ }
+ public def operations() {
+ def l = []
+ l += o.eClass().getEOperations();
+ o.eClass().getEAllSuperTypes().each { EClass c ->
+ l += c.getEOperations()
+ }
+ return l
+ }
+ public def operationsProvider() { + def l = [] + l += o.eClass().getEOperations(); + o.eClass().getEAllSuperTypes().each { EClass c -> + if (providerObject != null && ( + providerObject.eClass().getEAllSuperTypes().contains(c) + || c == providerObject.eClass())) return + l += c.getEOperations() + } + return l + } + public void generateAnt(String fname, boolean xtext, boolean tar) {
+ def xml = new XmlSlurper().parseText(new File(".classpath").text)
+ SimpleTemplateEngine engine = new SimpleTemplateEngine()
+ def env = [g:this,m:m,sourceDirectories:[],projects:[],xtext:xtext,tar:tar]
+ xml.classpathentry.each { e ->
+ switch (e.@kind) {
+ case "src":
+ def path = e.@path.toString()
+ if (path.startsWith("/")) {
+ println "path=$path"
+ switch (path) {
+ case "/org.openecomp.ncomp.webservice": env.projects += "org.openecomp.ncomp.utils.jar"; break
+ default: env.projects += path.replace("/","") + ".jar"
+ }
+ }
+ else {
+ env.sourceDirectories += path
+ }
+ break
+// <classpathentry kind="lib" path="/sirius-store/artifacts/org.openecomp.ncomp.gwt.api.jar"/>
+ case "lib":
+ def path = e.@path.toString()
+ switch (path) {
+ case ~/\/sirius-store.*/:
+ def a = path.split("/")
+ def jar = a[3]
+ println "jar=$jar"
+ env.projects += a[3]
+ }
+ }
+ }
+ println "Creating $fname"
+ def x = engine.createTemplate(new File("$m.templateDirectory/ant_xml").text).make(env)
+ File f = new File(fname)
+ f.delete()
+ f.parentFile.mkdirs()
+ f << x
+ }
+ public void generateScripts(String dir,String n) {
+ SimpleTemplateEngine engine = new SimpleTemplateEngine()
+ EPackage p = o.eClass().getEPackage() + def env = [g:this,m:m, n:n, nsPrefix: p.getNsPrefix()]
+ env.sClass = "${root.m.prefix}${root.o.eClass().name}Server"
+ env.sPackage = root.packageName()
+ String fname = "$dir/${n}-controller"
+ println "Creating $fname" + println "Using $m.templateDirectory/controller"
+ def x = engine.createTemplate(new File("$m.templateDirectory/controller").text).make(env)
+ File f = new File(fname)
+ f.delete()
+ f.parentFile.mkdirs()
+ f << x
+ }
+ public void generate(String dir) { + if (enableDrools && ! enableISiriusPlugin) { + System.err.println "Drools requires ISiriusPlugin, thus enabling ISiriusPlugin" + enableISiriusPlugin = true + }
+ SimpleTemplateEngine engine = new SimpleTemplateEngine()
+
+ File dir1 = new File(dir)
+ if (root == this && dir1.exists()) dir1.deleteDir()
+ dir1.mkdir()
+
+ EPackage p = o.eClass().getEPackage()
+
+ ["Server":[:],"Client":[:],"Console":[:],"Controller":[:],"Factory":[:],"Provider":[:]].each {n, c ->
+ if (root != this) {
+ switch (n) {
+ case "Server": return
+ case "Factory": if (type == "A" || type == "C" || type == "P") return; + case "Client": case "Console": if (type == "P") return;
+ }
+ }
+ def env = [
+ g: this,
+ o: o,
+ p: p,
+ prefix: m.prefix,
+ name : o.eClass().getName(),
+ nsPrefix : p.getNsPrefix(),
+ nsURI : p.getNsURI(),
+ packageName : packageName(),
+ cName : "${m.prefix}${o.eClass().name}$n",
+ fName : factoryName(),
+ path : root == this ? "resources" : subName,
+ ]
+ switch (n) {
+ case "Provider": env.cName = "${m.prefix}${o.eClass().name}ProviderTemplate"; break
+ case "Controller": env.cName = "${m.prefix}${o.eClass().name}"; break + case "Factory": env.cName = "${m.prefix}${env.fName}"; break
+ }
+ env.sClass = "${root.m.prefix}${root.o.eClass().name}Server"
+ env.sPackage = root == this ? "" : root.packageName()
+ def fname = "$dir/${env.cName}.java"
+ println "Creating $fname" + println "Using $m.templateDirectory/${n}.java"
+ def x = engine.createTemplate(new File("$m.templateDirectory/${n}.java").text).make(env)
+ def f = new File(fname)
+ f.parentFile.mkdirs()
+ f << x
+ switch (n) { + case "Provider": + def fname2 = "${dir.replace('src/main/sirius-gen','src/main/java')}/${env.cName}.java".replace("ProviderTemplate", "Provider") + def f2 = new File(fname2) + if (!f2.exists()) { + println "Creating $fname2" + f2.parentFile.mkdirs() + f2 << x.toString().replace("${o.eClass().name}ProviderTemplate", "${o.eClass().name}Provider") + } + break + } + // println "x=$x"
+ } + generateYaml(dir)
+ subApis.each { ControllerGenerator g ->
+ g.generate(dir + (g.o.eClass().EPackage != o.eClass().EPackage ? "/$g.subName" : ""))
+ }
+ } + def generateYaml(dir) { + def y = [operations:[:], messages:[dummy:[:]]] + EClass c = o.eClass() + c.getEAllOperations().each { EOperation op -> + y.operations[op.name] = [:] + y.messages[op.name] = [ + errorCode: "$op.name-FAILED-5001W", + messageFormat: "{0}", + description: "Operation Failed with Exception" + ] + } + c.getEAllOperations().each { EOperation op -> + y.operations["REMOTE_$op.name"] = [decription:"Remote call $op.name"] + y.messages["REMOTE_$op.name"] = [ + errorCode: "REMOTE-$op.name-FAILED-5001W", + messageFormat: "{0}", + description: "Remote Operation Failed with Exception" + ] + } + DumperOptions options = new DumperOptions(); + options.setDefaultFlowStyle(DumperOptions.FlowStyle.BLOCK); + Yaml yaml = new Yaml(options); + JSONObject j = Utils.object2json(y) + File f = new File("src/main/sirius-gen/${c.name}.yaml") + if (f.exists()) f.delete() + f << yaml.dump(yaml.load(j.toString())) + }
+ def subApis = []
+ public void addObject(String subpackage, EObject o, ControllerModel m, boolean enableIRequestHandler = false, boolean enableISiriusPlugin = false) {
+ def g = new ControllerGenerator(o,m)
+ g.root = this
+ g.subName = subpackage
+ g.type = "O" + g.enableIRequestHandler = enableIRequestHandler + g.enableISiriusPlugin = enableISiriusPlugin
+ subApis += g
+ }
+ public void addApi(String name, EObject o, ControllerModel m, boolean enableIRequestHandler = false, boolean enableISiriusPlugin = false) {
+ def g = new ControllerGenerator(o,m)
+ g.root = this
+ g.subName = name
+ g.type = "A" + g.enableIRequestHandler = enableIRequestHandler + g.enableISiriusPlugin = enableISiriusPlugin
+ subApis += g
+ }
+ public void addProvider(String name, EObject o, ControllerModel m) { + def g = new ControllerGenerator(o,m) + g.root = this + g.subName = name + g.type = "P" + g.enableIRequestHandler = false + g.enableISiriusPlugin = false + subApis += g + } + def subClients = []
+ public void addClient(String name, EObject o, ControllerModel m, boolean enableIRequestHandler = false, boolean enableISiriusPlugin = false) {
+ def g = new ControllerGenerator(o,m)
+ g.root = this
+ g.clientName = name
+ g.type = "C" + g.enableIRequestHandler = enableIRequestHandler + g.enableISiriusPlugin = enableISiriusPlugin
+ subClients += g
+ }
+ List<String> aliases = new ArrayList<String>();
+ public void addAlias(String alias) {
+ aliases.add(alias);
+ }
+ List<String> factories = new ArrayList<String>(); + def useNew = [:]
+ public void addFactory(String factory, boolean useNew = true) {
+ factories.add(factory); + this.useNew[factory] = useNew
+ } + public void enableDrools() { + enableDrools = true; + } + public void addFactory(EFactory f) { + def p = f.ePackage + String f1 = "${p.nsURI}.${p.name.capitalize()}Factory" + addFactory(f1,false) + } + public void setProvider(EObject o2, String prefix) { + providerObject = o2 + EPackage p = o2.eClass().getEPackage() + providerPackage = p.nsURI.replaceAll('.'+p.nsPrefix+'$',"") + ".servers.${p.nsPrefix}" + providerPrefix = prefix + }
+}
diff --git a/ncomp-sirius-manager-generator/src/main/templates/Client.java b/ncomp-sirius-manager-generator/src/main/templates/Client.java new file mode 100644 index 0000000..4b38e94 --- /dev/null +++ b/ncomp-sirius-manager-generator/src/main/templates/Client.java @@ -0,0 +1,125 @@ + +/*- + * ============LICENSE_START========================================== + * OPENECOMP - DCAE + * =================================================================== + * Copyright (c) 2017 AT&T Intellectual Property. All rights reserved. + * =================================================================== + * 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============================================ + */ + +<% +import org.openecomp.ncomp.utils.StringUtil +%>// Autogenerated +// Do not edit. No need to extend this class. +package $packageName; + +import org.openecomp.ncomp.sirius.manager.AbstractClient; +import org.openecomp.ncomp.sirius.manager.HighAvailabilityClient; +import org.openecomp.ncomp.sirius.manager.GenericHttpClient; + +import org.apache.log4j.Logger; + +import org.openecomp.logger.EcompLogger; + +import org.eclipse.emf.common.util.EList; +import org.eclipse.emf.ecore.EClass; + +import ${p.nsURI}.impl.${name}Impl; +import ${p.nsURI}.${g.packageName2()}; +import ${packageName}.logging.${name}OperationEnum; +import ${packageName}.logging.${name}MessageEnum; + +<% if (sPackage != "") { %> +import ${sPackage}.${prefix}${g.root.o.eClass().name}; <% } %> + + + + +@SuppressWarnings("unchecked") +public class ${cName} extends ${name}Impl { + public static final Logger logger = Logger.getLogger(${cName}.class); + static final EcompLogger ecomplogger = EcompLogger.getEcompLogger(); + public AbstractClient client; + + public ${cName}(String file, String name) { + ${prefix}${g.root.o.eClass().name}.ecoreSetup(); + client = new GenericHttpClient(file,name); + client.add("/$path", this); + } + + public ${cName}(String file, String name1, String name2) { + HighAvailabilityClient client1 = new HighAvailabilityClient(file,name1,name2); + client = client1.all; // requests should be forwarded to all. + client.add("/$path", this); + } + + public ${cName}(AbstractClient c) { + client = c; + client.add("/resources", this); + } + + +<% g.operations().each { op -> + def decl = [] + def vars = [] + def timeout = "null" + if (op.getEParameters().find { it.name == "cx" }) { + decl += "org.json.JSONObject cx" + vars += "cx" + timeout = 'cx != null && cx.has("timeout") ? cx.getLong("timeout") : null' + } + def override = "@Override" + def path1 = g.subName == null ? "\"/$path\"" : "\"/$g.subName\"" + if (g.root != g && g.root.o.eClass().EPackage == o.eClass().EPackage) { + decl += "String path" + override = "" + path1 = "path" + } + op.getEParameters().each { p -> + if (p.name == "cx") return + vars += p.name + if (p.isMany()) + decl += "EList<${p.getEType().getInstanceClassName()}> $p.name" + else { + if (p.getEType()==null) System.err.println "$op.name $p.name $p" + decl += "${p.getEType().getInstanceClassName()} $p.name" + } + } + + + def rType = op.getEType() == null ? "void" : op.getEType().getInstanceClassName() + if (op.isMany()) rType = "EList<$rType>" + def ret = rType == "void" ? "" : "return res;" + def decl1 = rType == "void" ? "" : "${rType} res;" + def decl2 = rType == "void" ? "" : "res = ($rType) " +%> + $override + public ${rType} ${op.name}(${StringUtil.join(decl, ", ")}) { + EClass c = ${g.packageName2()}.eINSTANCE.get${g.o.eClass().name}(); //foo + ecomplogger.recordMetricEventStart(); + ecomplogger.setOperation(${name}OperationEnum.REMOTE_${op.name}); + $decl1 + try { + ${decl2}client.operationPath($path1, c, "${op.name}", $timeout<% if (vars.size()>0) {%>, <%}%>${StringUtil.join(vars,",")}); + } + catch (Exception e) { + ecomplogger.warn(${name}MessageEnum.REMOTE_${op.name}, e.toString()); + throw new RuntimeException("remote call failed: " + client.getRemote() + "@$op.name: " + e); + } + ecomplogger.recordMetricEventEnd(); + ${ret} + } +<% } %> +} diff --git a/ncomp-sirius-manager-generator/src/main/templates/Console.java b/ncomp-sirius-manager-generator/src/main/templates/Console.java new file mode 100644 index 0000000..dfe1648 --- /dev/null +++ b/ncomp-sirius-manager-generator/src/main/templates/Console.java @@ -0,0 +1,97 @@ + +/*- + * ============LICENSE_START========================================== + * OPENECOMP - DCAE + * =================================================================== + * Copyright (c) 2017 AT&T Intellectual Property. All rights reserved. + * =================================================================== + * 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============================================ + */ + +<% +import org.openecomp.ncomp.utils.StringUtil +%>// Autogenerated +// Do not edit but extend this class as needed +package $packageName; + + +import org.apache.log4j.Logger; +import org.eclipse.emf.common.util.EList; + +import org.openecomp.ncomp.sirius.manager.console.Console; +import org.openecomp.ncomp.sirius.manager.AbstractClient; +import org.openecomp.ncomp.sirius.manager.ManagementServerError; + +<% g.subApis.each { api -> + if (api.o.eClass().getEPackage() == o.eClass().getEPackage()) return +%> + +import ${api.packageName()}.${prefix}${api.o.eClass().name}Console; <% } %> + + +public class ${cName} extends Console { + public static final Logger logger = Logger.getLogger(${cName}.class); + protected ${prefix}${name}Client controller; + +<% g.subApis.each { api -> if (api.type == "P") return; %> + ${prefix}${api.o.eClass().name}Console ${api.subName}; <% } %> + + + public ${cName}(String filename, String name) { + super(filename, name); + controller = new ${prefix}${name}Client(filename,name); + client = controller.client; +<% g.subApis.each { api -> if (api.type == "P") return; %> + ${api.subName} = new ${prefix}${api.o.eClass().name}Console(filename,name); <% } %> + } + + public ${cName}(AbstractClient c) { + controller = new ${prefix}${name}Client(c); + client = controller.client; + } + +<% g.operations().each { op -> + def decl = [] + def vars = [] + if (g.root != g && g.root.o.eClass().EPackage == o.eClass().EPackage) { + decl += "String path" + vars += "path" + } + op.getEParameters().each { p -> + if (p.name == "cx") return + vars += p.name + if (p.isMany()) + decl += "EList<${p.getEType().getInstanceClassName()}> $p.name" + else + decl += "${p.getEType().getInstanceClassName()} $p.name" + } + def rType = op.getEType() == null ? "void" : op.getEType().getInstanceClassName() + if (op.isMany()) rType = "EList<$rType>" + def ret = rType == "void" ? "" : "return res;" + def decl1 = rType == "void" ? "" : "$rType res = null;" + def assign = rType == "void" ? "" : "res = " + if (op.getEParameters().find { it.name == "cx" }) vars = ["null"] + vars +%> + public $rType ${op.name}(${StringUtil.join(decl, ", ")}) { + $decl1 + try { + $assign controller.${op.name}(${StringUtil.join(vars,",")}); + } + catch (ManagementServerError e) { + System.err.println("ERROR: " + e.getJson().toString(2)); + } + $ret + } +<% } %> +} diff --git a/ncomp-sirius-manager-generator/src/main/templates/Controller.java b/ncomp-sirius-manager-generator/src/main/templates/Controller.java new file mode 100644 index 0000000..903dde0 --- /dev/null +++ b/ncomp-sirius-manager-generator/src/main/templates/Controller.java @@ -0,0 +1,191 @@ + +/*- + * ============LICENSE_START========================================== + * OPENECOMP - DCAE + * =================================================================== + * Copyright (c) 2017 AT&T Intellectual Property. All rights reserved. + * =================================================================== + * 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============================================ + */ + +<% + + +import org.openecomp.ncomp.component.ApiRequestStatus; +import org.openecomp.ncomp.sirius.manager.ManagementServerError; +import org.openecomp.ncomp.utils.StringUtil +import org.openecomp.ncomp.sirius.manager.server.AbstractManagementServer +import org.openecomp.ncomp.gwt.siriusportal.model.GuiClientApi + +%>// Autogenerated +// Do not edit. No need to extend this class. +package $packageName; + + + + + + +import java.io.InputStream; + +import org.openecomp.ncomp.sirius.manager.IRequestHandler; +import org.openecomp.ncomp.sirius.manager.ISwaggerHandler; +import org.openecomp.ncomp.sirius.manager.ISiriusPlugin; +import org.openecomp.ncomp.sirius.manager.ISiriusServer; +import org.openecomp.ncomp.sirius.manager.ManagementServer; +import org.openecomp.ncomp.sirius.manager.SwaggerUtils; +import org.openecomp.ncomp.sirius.function.FunctionUtils; +import org.openecomp.ncomp.component.ApiRequestStatus; + +import org.apache.log4j.Logger; + +import org.openecomp.logger.EcompLogger; + +import org.eclipse.emf.common.util.EList; +import org.eclipse.emf.ecore.EObject; +import org.json.JSONObject; + +import java.util.Date; + +import ${packageName}.logging.${name}OperationEnum; +import ${packageName}.logging.${name}MessageEnum; + + +<% + def others = [] + switch (o) { + case AbstractManagementServer: + others += "java.util.Date"; + others += "org.openecomp.ncomp.sirius.manager.server.LoggerInfo" + others += "org.openecomp.ncomp.sirius.manager.server.ServerFactory" + break + case GuiClientApi: + others += "org.openecomp.ncomp.sirius.gui.tools.*"; + others += "org.openecomp.ncomp.gwt.siriusportal.model.*"; + others += "org.openecomp.ncomp.sirius.manager.Subject"; + others += "org.openecomp.ncomp.sirius.manager.ManagementServer" + others += "org.openecomp.ncomp.sirius.manager.server.AbstractManagementServer" + break + } + if (g.enableDrools) { + others += "org.openecomp.ncomp.core.logs.*" + others += "org.openecomp.ncomp.sirius.manager.drools.DroolsRuntime" + } + others.each { n -> +%> + + + + +import $n; +<% } %> + +import ${p.nsURI}.impl.${name}Impl; + +<% + def l = [] + if (g.enableIRequestHandler) l += "IRequestHandler" + if (g.enableISwaggerHandler) l += "ISwaggerHandler" + if (g.enableISiriusPlugin) l += "ISiriusPlugin" + def implements1 = l.size() > 0 ? " implements ${StringUtil.join(l,', ')}" : "" +%> + +public class ${cName} extends ${name}Impl${implements1} { + public static final Logger logger = Logger.getLogger(${cName}.class); + static final EcompLogger ecomplogger = EcompLogger.getEcompLogger(); + public ${prefix}${name}Provider controller; + ISiriusServer server; + + public ${cName}(ISiriusServer server) { + this.server = server; + this.controller = new ${prefix}${name}Provider(server,this); + } +<% g.operations().each { op -> + def decl = [] + def vars = [] + op.getEParameters().each { p -> + vars += p.name + if (p.isMany()) + decl += "EList<${p.getEType().getInstanceClassName()}> $p.name" + else + decl += "${p.getEType().getInstanceClassName()} $p.name" + } + def rType = op.getEType() == null ? "void" : op.getEType().getInstanceClassName() + if (op.isMany()) rType = "EList<$rType>" + def ret = rType == "void" ? "" : "return res;" + def decl1 = rType == "void" ? "" : "$rType res = null;" + def assign = rType == "void" ? "" : "res = " + def vars1 = ["duration_"] + vars +%> + public $rType ${op.name}(${StringUtil.join(decl, ", ")}) { + $decl1 + long duration_ = 0; + if (server != null) + server.getServer().recordApi(null, this, "${op.name}", ApiRequestStatus.START, ${StringUtil.join(vars1,",")}); + Date now_ = new Date(); + ecomplogger.recordMetricEventStart(); + ecomplogger.setOperation(${name}OperationEnum.${op.name}); + ecomplogger.setInstanceId(ManagementServer.object2ref(this)); + try { + $assign controller.${op.name}(${StringUtil.join(vars,",")}); + } + catch (Exception e) { + duration_ = new Date().getTime()-now_.getTime(); + if (server != null) + server.getServer().recordApi(null, this, "${op.name}", ApiRequestStatus.ERROR, ${StringUtil.join(vars1,",")}); + System.err.println("ERROR: " + e); + ecomplogger.warn(${name}MessageEnum.${op.name}, e.toString()); + throw e; + } + ecomplogger.recordMetricEventEnd(); + duration_ = new Date().getTime()-now_.getTime(); + if (server != null) + server.getServer().recordApi(null, this, "${op.name}", ApiRequestStatus.OKAY, ${StringUtil.join(vars1,",")}); + $ret + } +<% } %> + +<% if (g.enableIRequestHandler) { %> + @Override + public Object handleJson(String userName, String action, String resourcePath, JSONObject json, JSONObject context) { + return controller.handleJson(userName,action,resourcePath,json,context); + } + + @Override + public Object handleBinary(String userName, String action, String resourcePath, InputStream in) { + return controller.handleBinary(userName,action,resourcePath,in); + } +<% } %> + +<% if (g.enableISwaggerHandler) { %> +@Override +public void updateSwagger(String path, SwaggerUtils swagger) { + controller.updateSwagger(path,swagger); +} +<% } %> + + +<% if (g.enableISiriusPlugin) { %> + @Override + public void start() { + controller.start(); + } +<% } %> + public static void ecoreSetup() { + ${prefix}${name}Provider.ecoreSetup(); + } + public ${prefix}${name}Provider getSomfProvider() { + return controller; + } +} diff --git a/ncomp-sirius-manager-generator/src/main/templates/Factory.java b/ncomp-sirius-manager-generator/src/main/templates/Factory.java new file mode 100644 index 0000000..63344ef --- /dev/null +++ b/ncomp-sirius-manager-generator/src/main/templates/Factory.java @@ -0,0 +1,64 @@ + +/*- + * ============LICENSE_START========================================== + * OPENECOMP - DCAE + * =================================================================== + * Copyright (c) 2017 AT&T Intellectual Property. All rights reserved. + * =================================================================== + * 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============================================ + */ + +// Autogenerated +// Do not edit. No need to extend this class. +package $packageName; + +import org.eclipse.emf.ecore.EPackage; +import org.apache.log4j.Logger; + +import org.openecomp.ncomp.sirius.manager.ISiriusServer; + +import ${p.nsURI}.${name}; +import ${p.nsURI}.${nsPrefix.capitalize()}Package; +import ${p.nsURI}.impl.${fName}Impl; + +<% if (sPackage != "") { %>import ${sPackage}.$sClass; <% } %> + +<% g.subApis.each { api -> +if (api.o.eClass().EPackage != o.eClass().EPackage) return +%> +import ${api.o.eClass().EPackage.nsURI}.${api.o.eClass().name};<% } %> + +public class ${cName} extends ${fName}Impl { + public static final Logger logger = Logger.getLogger(${cName}.class); + ISiriusServer server = null; + @Override + public EPackage getEPackage() { return ${nsPrefix.capitalize()}Package.eINSTANCE; } + public ${cName}(ISiriusServer server) { + this.server = server; + } + @Override + public ${name} create${name}() { + return new ${prefix}${name}(server); + } + +<% g.subApis.each { api -> + if (api.o.eClass().EPackage != o.eClass().EPackage) return +%> + @Override + public ${api.o.eClass().name} create${api.o.eClass().name}() { + return new ${prefix}${api.o.eClass().name}(server); + } +<% } %> + +} diff --git a/ncomp-sirius-manager-generator/src/main/templates/Provider.java b/ncomp-sirius-manager-generator/src/main/templates/Provider.java new file mode 100644 index 0000000..6113401 --- /dev/null +++ b/ncomp-sirius-manager-generator/src/main/templates/Provider.java @@ -0,0 +1,187 @@ + +/*- + * ============LICENSE_START========================================== + * OPENECOMP - DCAE + * =================================================================== + * Copyright (c) 2017 AT&T Intellectual Property. All rights reserved. + * =================================================================== + * 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============================================ + */ + +<% + +import org.openecomp.ncomp.sirius.manager.ManagementServerError; +import org.openecomp.ncomp.utils.StringUtil +import org.openecomp.ncomp.sirius.manager.server.AbstractManagementServer +import org.openecomp.ncomp.gwt.siriusportal.model.GuiClientApi + +%> +package $packageName; + + + + + +import java.io.InputStream; + +import org.openecomp.ncomp.sirius.manager.IRequestHandler; +import org.openecomp.ncomp.sirius.manager.ISiriusPlugin; +import org.openecomp.ncomp.sirius.manager.ISiriusServer; +import org.openecomp.ncomp.sirius.function.FunctionUtils; + +import org.apache.log4j.Logger; +import org.eclipse.emf.common.util.EList; +import org.json.JSONObject; + +<% + def others = [] + def provider = "BasicAdaptorProvider" + switch (o) { + case AbstractManagementServer: + others += "java.util.Date"; + others += "org.openecomp.ncomp.sirius.manager.server.LoggerInfo" + others += "org.openecomp.ncomp.sirius.manager.server.ServerFactory" + provider = "BasicManagementServerProvider" + break + case GuiClientApi: + others += "org.openecomp.ncomp.sirius.gui.tools.*"; + others += "org.openecomp.ncomp.gwt.siriusportal.model.*"; + others += "org.openecomp.ncomp.sirius.manager.Subject"; + others += "org.openecomp.ncomp.sirius.manager.ManagementServer" + others += "org.openecomp.ncomp.sirius.manager.server.AbstractManagementServer" + provider = "BasicGuiClientApiProvider" + break + } + if (g.providerObject != null) { + provider = "$g.providerPrefix${g.providerObject.eClass().name}Provider" + others += "${g.providerPackage}.$provider" + } else { + others += "org.openecomp.ncomp.sirius.manager.${provider}" + } + if (g.enableDrools) { + others += "org.openecomp.ncomp.core.logs.LogLevel" + others += "org.openecomp.ncomp.core.logs.LogMessage" + others += "org.openecomp.ncomp.core.logs.LogSeverity" + others += "org.openecomp.ncomp.core.logs.LogsFactory" + others += "org.openecomp.ncomp.sirius.manager.DroolsEventReporter" + others += "org.openecomp.ncomp.sirius.manager.drools.DroolsRuntime" + } + others.each { n -> +%> + +import $n; +<% } %> + +import ${p.nsURI}.impl.${name}Impl; +import ${p.nsURI}.${name}; + + +public class ${cName} extends ${provider} { + private static final Logger logger = Logger.getLogger(${cName}.class); + ${name} o; + + public ${cName}(ISiriusServer controller, ${name} o) { + super(controller, o); + this.o = o; + } +<% g.operationsProvider().each { op -> + def decl = [] + def vars = [] +// if (g.root != g && g.root.o.eClass().EPackage == o.eClass().EPackage) { +// decl += "String path" +// vars += "path" +// } + op.getEParameters().each { p -> + vars += p.name + if (p.isMany()) + decl += "EList<${p.getEType().getInstanceClassName()}> $p.name" + else + decl += "${p.getEType().getInstanceClassName()} $p.name" + } + def rType = op.getEType() == null ? "void" : op.getEType().getInstanceClassName() + if (op.isMany()) rType = "EList<$rType>" + def ret = rType == "void" ? "" : "return res;" + def decl1 = rType == "void" ? "" : "$rType res = null;" + def assign = rType == "void" ? "" : "res = " + def cx = op.getEParameters().find { it.name == "cx" } ? "null," : "" + def action = "$decl1\n // TODO IMPLEMENT\n throw new UnsupportedOperationException();" + switch (o) { + case AbstractManagementServer: + switch (op.name) { + case "logs": + case "properties": + case "metrics": + case "uploadInfo": + case "getMessages": + case "getValues": + case "getValuesAll": + case "evaluate": + case "getRequestLogger": + case "update": + return + } + break; + case GuiClientApi: + switch (op.name) { + case "getTree": + case "getTable": + case "getTimeSerie": + case "getObject": + case "getHtml": + case "getGraph": + return + } + break; + } + %> + public ${rType} ${op.name}(${StringUtil.join(decl, ", ")}) { + $action + } +<% } %> +<% if (g.enableIRequestHandler) { %> +public Object handleJson(String userName, String action, String resourcePath, JSONObject json, JSONObject context) { + // TODO Auto-generated method stub + return null; + } + + public Object handleBinary(String userName, String action, String resourcePath, InputStream in) { + // TODO Auto-generated method stub + return null; + } +<% } %> + +<% if (g.enableDrools) {%> +DroolsRuntime drools = null; +<% }%> +<% if (g.enableISiriusPlugin) { %> +<% if (g.enableDrools) {%> + public void start() { + try { + // TODO specify rules group, artifact and version + drools = new DroolsRuntime (1000L, "$packageName", "unspecified-rules-artifact", "0.1.0-SNAPSHOT", + new DroolsEventReporter(controller.getServer(), "unknown")); + drools.addObjectTree (o); + drools.startSession(); + drools.startScanner(60000L); + controller.getServer().setDroolsRuntime(drools); +// log("started Drools Session", LogLevel.INFO, LogSeverity.SEV4); + } catch (Exception e) { + e.printStackTrace(); + } + // TODO Auto-generated method stub + } +<% }%> +<% } %> + +} diff --git a/ncomp-sirius-manager-generator/src/main/templates/Server.java b/ncomp-sirius-manager-generator/src/main/templates/Server.java new file mode 100644 index 0000000..638a9ab --- /dev/null +++ b/ncomp-sirius-manager-generator/src/main/templates/Server.java @@ -0,0 +1,135 @@ + +/*- + * ============LICENSE_START========================================== + * OPENECOMP - DCAE + * =================================================================== + * Copyright (c) 2017 AT&T Intellectual Property. All rights reserved. + * =================================================================== + * 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============================================ + */ + +// Autogenerated +// Do not edit but extend this class as needed +package $packageName; + +import static org.openecomp.ncomp.utils.PropertyUtil.getPropertiesFromClasspath; + +import java.io.IOException; +import java.util.Properties; +import java.util.TimeZone; + +import org.apache.log4j.Logger; +import org.eclipse.emf.ecore.EFactory; + +import org.openecomp.entity.EcompComponent; +import org.openecomp.entity.EcompSubComponent; +import org.openecomp.entity.EcompSubComponentInstance; +import org.openecomp.ncomp.sirius.manager.Jetty8Server; +import org.openecomp.ncomp.sirius.manager.ManagementServer; +import org.openecomp.ncomp.sirius.manager.ISiriusServer; + +import ${p.nsURI}.${name}; + +<% g.subApis.each { api -> +if (api.type == "P") return +def n1 = api.subName +if (n1 == null) return +%> +import ${api.packageName()}.${api.m.prefix}${api.factoryName()}; +<% } %> + +<% g.subClients.each { api -> %> +import ${api.o.eClass().EPackage.nsURI}.${api.o.eClass().name}; +import ${api.packageName()}.${prefix}${api.o.eClass().name}Client; +<% } %> + + +public class $cName implements ISiriusServer { + public static final Logger logger = Logger.getLogger(${cName}.class); + String serverPath; + ManagementServer server; + ${prefix}${name} controller; + String directory = "data"; +// LocationControllerApi api ; + Jetty8Server webServer; + ${prefix}${fName} f = new ${prefix}${fName}(this); + +<% g.subApis.each { api -> + if (api.type == "P") return + def n1 = api.subName + if (n1 == null) return +%> + String ${n1}Path; + ManagementServer ${n1}Server; +<% } %> +<% g.subClients.each { api -> %> + ${api.o.eClass().name} $api.clientName; +<% } %> + public ${prefix}${name}Server(String filename) throws IOException { + logger.warn("controller restarting"); + ${prefix}${name}.ecoreSetup(); + props = getPropertiesFromClasspath(filename); + serverPath = (String) props.get("server.dir"); + server = new ManagementServer(f, "${name}", serverPath, filename); + server.addFactory(f); +<% g.factories.each { factory -> + if (g.useNew[factory]) { %> + server.addFactory(new ${factory}(this)); + <% } else { %> + server.addFactory(${factory}.eINSTANCE); + <% } %> +<% } %> + server.addRuntimeFactories(this); + server.start(); + } + public void runWebserver() throws IOException { + controller = (${prefix}${name}) server.find("/").o; + webServer = new Jetty8Server("${nsPrefix}.properties"); + webServer.add("/resources",server); +<% g.aliases.each { %> + webServer.add("$it",controller); +<%}%> + +<% g.subApis.each { api -> + if (api.type == "A" || api.type == "P") return + def n1 = api.subName +%> + EFactory ${n1}Factory = new ${api.m.prefix}${api.factoryName()}(this); + ${n1}Path = serverPath + "/${n1}"; + ${n1}Server = new ManagementServer(${n1}Factory, "${api.o.eClass().name}", ${n1}Path, "${n1}.properties"); + ${n1}Server.start(); + webServer.add("/${n1}",${n1}Server); +<% } %> + +<% g.subClients.each { api -> %> + $api.clientName = new ${prefix}${api.o.eClass().name}Client("${nsPrefix}.properties", "$api.clientName"); +<% } %> + logger.info("Joining webserver"); + webServer.join(); + } + static Properties props = null; + public static void main(String []args) throws IOException { + // ALWAYS USE GMT. + TimeZone.setDefault(TimeZone.getTimeZone("GMT")); + + ${prefix}${name}Server s = new ${prefix}${name}Server("${nsPrefix}.properties"); + s.runWebserver(); + } + public ${name} getController() { + return controller; + } + public ManagementServer getServer() { + return server; + } +} diff --git a/ncomp-sirius-manager-generator/src/main/templates/console b/ncomp-sirius-manager-generator/src/main/templates/console new file mode 100644 index 0000000..decc901 --- /dev/null +++ b/ncomp-sirius-manager-generator/src/main/templates/console @@ -0,0 +1,3 @@ +#!/bin/bash + +LD_LIBRARY_PATH= groovysh -cp config:lib:lib/\* diff --git a/ncomp-sirius-manager-generator/src/main/templates/controller b/ncomp-sirius-manager-generator/src/main/templates/controller new file mode 100644 index 0000000..344ec8f --- /dev/null +++ b/ncomp-sirius-manager-generator/src/main/templates/controller @@ -0,0 +1,140 @@ +#!/bin/bash + +# setup env if needed. java 6 required +## JAVA_HOME= + +############################## DO NOT EDIT BELOW ########################## + +SNAME="$m.prefix Controller" +PNAME=$n-controller +CLASS=${sPackage}.${sClass} + +############################## COMMON BELOW ########################## + +check_status () +{ + if [ -f "\${_PIDFILE}" ]; then + _PID=`cat "\${_PIDFILE}"` + check_status_of_pid \$_PID + else + _STATUS="\$SNAME (no pidfile) is NOT running" + _RUNNING=0 + fi +} + + +check_status_of_pid () +{ + if [ -n "\$1" ] && kill -0 \$1 2>/dev/null ; then + _STATUS="\$SNAME (pid \$1) is running" + _RUNNING=1 + else + _STATUS="\$SNAME (pid \$1) is NOT running" + _RUNNING=0 + fi +} + + +check_status_of_pid () +{ + if [ -n "\$1" ] && kill -0 \$1 2>/dev/null ; then + _STATUS="\$SNAME (pid \$1) is running" + _RUNNING=1 + else + _STATUS="\$SNAME (pid \$1) is NOT running" + _RUNNING=0 + fi +} + +remove_pid_file () +{ + if [ -f "\${_PIDFILE}" ]; then + rm "\${_PIDFILE}" + fi +} + + +_DIR=`dirname "\$0"` +_DIR=`dirname "\$_DIR"` + +_PIDFILE=\$_DIR/PID + +CMD=\$1 +shift + +check_status + +CP=\$(find \$_DIR/lib/*/* -name \\*.jar 2>/dev/null | xargs -I X printf ":%s" X) + +JVMARGS=\$(grep 'server.jvmargs' \$_DIR/config/${nsPrefix}.properties | sed -e 's/.*=//') + +case \$CMD in + status) + echo \$_STATUS + exit 0 + ;; + console) + \$GROOVY_HOME/bin/groovysh -cp \$_DIR/config:\$_DIR/lib:\$_DIR/lib/\\*:\$CP + ;; + run) + \$JAVA_HOME/bin/java -cp \$_DIR/config:\$_DIR/lib:\$_DIR/lib/\\*:\$CP "\$@" + ;; + groovy) + \$GROOVY_HOME/bin/groovy -cp \$_DIR/config:\$_DIR/lib:\$_DIR/lib/\\*:\$CP "\$@" + ;; + start) + if [ "\$_RUNNING" = "1" ]; then + echo \$_STATUS + exit 0 + fi + mkdir -p \$_DIR/logs + if [ -e \$_DIR/logs/\$PNAME.out.1 ]; then mv \$_DIR/logs/\$PNAME.out.1 \$_DIR/logs/\$PNAME.out.2; fi + if [ -e \$_DIR/logs/\$PNAME.err.1 ]; then mv \$_DIR/logs/\$PNAME.err.1 \$_DIR/logs/\$PNAME.err.2; fi + if [ -e \$_DIR/logs/\$PNAME.out ]; then mv \$_DIR/logs/\$PNAME.out \$_DIR/logs/\$PNAME.out.1; fi + if [ -e \$_DIR/logs/\$PNAME.err ]; then mv \$_DIR/logs/\$PNAME.err \$_DIR/logs/\$PNAME.err.1; fi +<% if (g.enableDrools) { %> + nohup \$JAVA_HOME/bin/java \$JVMARGS -Dkie.maven.settings.custom=\$_DIR/config/kie_settings.xml -cp \$_DIR/config:\$_DIR/lib:\$_DIR/lib/\\*:/opt/drools-distribution-6.3.0.Final/binaries/\\*:\$CP "\$@" \$CLASS >> \$_DIR/logs/\$PNAME.out 2>> \$_DIR/logs/\$PNAME.err & +<% } else { %> + nohup \$JAVA_HOME/bin/java \$JVMARGS -cp \$_DIR/config:\$_DIR/lib:\$_DIR/lib/\\*:\$CP "\$@" \$CLASS >> \$_DIR/logs/\$PNAME.out 2>> \$_DIR/logs/\$PNAME.err & +<% } %> + _PID=\$! + echo \$_PID > \$_PIDFILE + sleep 5 + check_status + echo \$_STATUS + if [ "\$_RUNNING" = "1" ]; then + exit 0 + else + echo "Failed to start - make sure the \$SNAME is fully configured properly" + exit 1 + fi + ;; + stop) + if [ "\$_RUNNING" = "0" ]; then + echo \$_STATUS + remove_pid_file + exit 0 + fi + echo "Stopping \$SNAME..." + _PID_TO_KILL=\$_PID; + echo "\$SNAME (pid=\${_PID_TO_KILL}) is stopping..." + kill -TERM \$_PID_TO_KILL + sleep 5 + check_status_of_pid \$_PID_TO_KILL + if [ "\$_RUNNING" = "1" ]; then + kill -TERM \$_PID_TO_KILL + fi + while [ "\$_RUNNING" = "1" ]; do + sleep 2 + check_status_of_pid \$_PID_TO_KILL + done + remove_pid_file + echo "\$SNAME has stopped." + exit 0 + ;; + *) + echo "\$0 start|stop" + ;; +esac + + diff --git a/ncomp-sirius-manager-generator/src/main/templates/xcore b/ncomp-sirius-manager-generator/src/main/templates/xcore new file mode 100644 index 0000000..8d6c1b2 --- /dev/null +++ b/ncomp-sirius-manager-generator/src/main/templates/xcore @@ -0,0 +1,32 @@ +<%
+import org.eclipse.emf.ecore.*;
+%>
+@GenModel(updateClasspath="false")
+package $pName
+
+import org.openecomp.ncomp.sirius.manager.model.NamedEntity
+
+<% p.EClassifiers.each { EClassifier c -> %>
+class $c.name extends NamedEntity {
+ <% c.getEReferences().each { EReference ref -> %>
+ ${ref.isContainment() ? "contains" : "refers"} ${ref.eType.name}${ref.isMany() ? "[]" : ""} $ref.name <% } %>
+ <% c.getEAttributes().each { EAttribute attr ->
+ switch (attr.name) {
+ case "name":
+ case "title":
+ case "description": return
+ }
+ def t = attr.eType.name
+ switch (t) {
+ case "EBoolean": t = "Boolean"; break
+ case "EString": t = "String"; break
+ case "EDouble": t = "Double"; break
+ case "EDate": t = "long"; break
+ }
+ %>
+ ${t}${attr.isMany() ? "[]" : ""} $attr.name <% } %>
+}
+<% } %>
+
+
+
|