diff options
15 files changed, 1598 insertions, 0 deletions
diff --git a/ms/neng/.classpath b/ms/neng/.classpath new file mode 100644 index 00000000..2fd27b36 --- /dev/null +++ b/ms/neng/.classpath @@ -0,0 +1,61 @@ +<?xml version="1.0" encoding="UTF-8"?> +<classpath> + <classpathentry kind="src" output="target/classes" path="src/main/java"> + <attributes> + <attribute name="optional" value="true"/> + <attribute name="maven.pomderived" value="true"/> + </attributes> + </classpathentry> + <classpathentry excluding="**" kind="src" output="target/classes" path="opt/etc/config"> + <attributes> + <attribute name="maven.pomderived" value="true"/> + </attributes> + </classpathentry> + <classpathentry excluding="**" kind="src" output="target/classes" path="opt/etc/keystore"> + <attributes> + <attribute name="maven.pomderived" value="true"/> + </attributes> + </classpathentry> + <classpathentry excluding="**" kind="src" output="target/classes" path="opt/etc/truststore"> + <attributes> + <attribute name="maven.pomderived" value="true"/> + </attributes> + </classpathentry> + <classpathentry excluding="**" kind="src" output="target/classes" path="src/main/resources"> + <attributes> + <attribute name="maven.pomderived" value="true"/> + </attributes> + </classpathentry> + <classpathentry kind="src" output="target/test-classes" path="src/test/java"> + <attributes> + <attribute name="optional" value="true"/> + <attribute name="maven.pomderived" value="true"/> + </attributes> + </classpathentry> + <classpathentry excluding="**" kind="src" output="target/test-classes" path="src/test/resources"> + <attributes> + <attribute name="maven.pomderived" value="true"/> + </attributes> + </classpathentry> + <classpathentry excluding="**" kind="src" output="target/classes" path="opt/aai/keystore"> + <attributes> + <attribute name="maven.pomderived" value="true"/> + </attributes> + </classpathentry> + <classpathentry kind="con" path="org.eclipse.jdt.launching.JRE_CONTAINER/org.eclipse.jdt.internal.debug.ui.launcher.StandardVMType/JavaSE-1.8"> + <attributes> + <attribute name="maven.pomderived" value="true"/> + </attributes> + </classpathentry> + <classpathentry kind="con" path="org.eclipse.m2e.MAVEN2_CLASSPATH_CONTAINER"> + <attributes> + <attribute name="maven.pomderived" value="true"/> + </attributes> + </classpathentry> + <classpathentry kind="src" path=".apt_generated"> + <attributes> + <attribute name="optional" value="true"/> + </attributes> + </classpathentry> + <classpathentry kind="output" path="target/classes"/> +</classpath> diff --git a/ms/neng/.project b/ms/neng/.project new file mode 100644 index 00000000..e3af4837 --- /dev/null +++ b/ms/neng/.project @@ -0,0 +1,46 @@ +<?xml version="1.0" encoding="UTF-8"?> +<projectDescription> + <name>networkelementnamegen</name> + <comment></comment> + <projects> + </projects> + <buildSpec> + <buildCommand> + <name>org.eclipse.wst.common.project.facet.core.builder</name> + <arguments> + </arguments> + </buildCommand> + <buildCommand> + <name>org.eclipse.jdt.core.javabuilder</name> + <arguments> + </arguments> + </buildCommand> + <buildCommand> + <name>org.springframework.ide.eclipse.core.springbuilder</name> + <arguments> + </arguments> + </buildCommand> + <buildCommand> + <name>org.springframework.ide.eclipse.boot.validation.springbootbuilder</name> + <arguments> + </arguments> + </buildCommand> + <buildCommand> + <name>org.eclipse.m2e.core.maven2Builder</name> + <arguments> + </arguments> + </buildCommand> + <buildCommand> + <name>net.sf.eclipsecs.core.CheckstyleBuilder</name> + <arguments> + </arguments> + </buildCommand> + </buildSpec> + <natures> + <nature>org.springframework.ide.eclipse.core.springnature</nature> + <nature>org.eclipse.jdt.core.javanature</nature> + <nature>org.eclipse.m2e.core.maven2Nature</nature> + <nature>org.eclipse.wst.common.project.facet.core.nature</nature> + <nature>net.sf.eclipsecs.core.CheckstyleNature</nature> + </natures> +</projectDescription> diff --git a/ms/neng/.settings/org.eclipse.core.resources.prefs b/ms/neng/.settings/org.eclipse.core.resources.prefs new file mode 100644 index 00000000..219fb333 --- /dev/null +++ b/ms/neng/.settings/org.eclipse.core.resources.prefs @@ -0,0 +1,10 @@ +eclipse.preferences.version=1 +encoding//opt/aai/keystore=UTF-8 +encoding//opt/etc/config=UTF-8 +encoding//opt/etc/keystore=UTF-8 +encoding//opt/etc/truststore=UTF-8 +encoding//src/main/java=UTF-8 +encoding//src/main/resources=UTF-8 +encoding//src/test/java=UTF-8 +encoding//src/test/resources=UTF-8 +encoding/<project>=UTF-8 diff --git a/ms/neng/.settings/org.eclipse.jdt.core.prefs b/ms/neng/.settings/org.eclipse.jdt.core.prefs new file mode 100644 index 00000000..78b2bfc4 --- /dev/null +++ b/ms/neng/.settings/org.eclipse.jdt.core.prefs @@ -0,0 +1,6 @@ +eclipse.preferences.version=1 +org.eclipse.jdt.core.compiler.codegen.targetPlatform=1.8 +org.eclipse.jdt.core.compiler.compliance=1.8 +org.eclipse.jdt.core.compiler.problem.forbiddenReference=warning +org.eclipse.jdt.core.compiler.processAnnotations=enabled +org.eclipse.jdt.core.compiler.source=1.8 diff --git a/ms/neng/README.md b/ms/neng/README.md new file mode 100644 index 00000000..0c82cfae --- /dev/null +++ b/ms/neng/README.md @@ -0,0 +1,32 @@ +<!-- + * ============LICENSE_START======================================================= + * ONAP : CCSDK.apps + * ================================================================================ + * Copyright (C) 2018 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========================================================= + --> + +## ONAP-CCSDK.apps-NetworkElementNameGen (NENG) + +Micro-service to generate names for network elements based on naming policies. + + + +### Build and test + +````bash +$ mvn clean install +```` + diff --git a/ms/neng/pom.xml b/ms/neng/pom.xml new file mode 100644 index 00000000..e96b4f68 --- /dev/null +++ b/ms/neng/pom.xml @@ -0,0 +1,377 @@ +<?xml version="1.0" encoding="UTF-8"?> +<!-- + * ============LICENSE_START======================================================= + * ONAP : CCSDK.apps + * ================================================================================ + * Copyright (C) 2018 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========================================================= + --> +<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" + xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> + <modelVersion>4.0.0</modelVersion> + + <groupId>org.onap.ccsdk.apps.ms</groupId> + <artifactId>networkelementnamegen</artifactId> + <version>2018.10.01</version> + + <properties> + <swagger.directory>${basedir}/target/classes/META-INF/resources/swagger</swagger.directory> + <icd.file>service.json</icd.file> + <icd.package>org.onap.ccsdk.apps.ms.neng.service.rs</icd.package> + <java.version>1.8</java.version> + <docker.registry>TBD:5100</docker.registry> + <build.number>local</build.number> + <kube.namespace>TBD</kube.namespace> + <service.account>TBD</service.account> + <namespace>org.onap.ccsdk.apps.ms.neng</namespace> + <maven.compiler.source>1.8</maven.compiler.source> + <maven.compiler.target>1.8</maven.compiler.target> + <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> + <sdk.java.rest>6.2.0.11</sdk.java.rest> + <sonar.java.coveragePlugin>jacoco</sonar.java.coveragePlugin> + <sonar.dynamicAnalysis>reuseReports</sonar.dynamicAnalysis> + <sonar.surefire.reportsPath>${basedir}/target/surefire-reports</sonar.surefire.reportsPath> + <sonar.failsafe.reportsPath>${basedir}/target/failsafe-reports</sonar.failsafe.reportsPath> + <jacoco.path>${basedir}/target/jacoco_report</jacoco.path> + <jacoco.itPath>${basedir}/target/jacoco_itReport</jacoco.itPath> + <sonar.jacoco.reportPath>${basedir}/target/jacoco-ut.exec</sonar.jacoco.reportPath> + <sonar.jacoco.itReportPath>${basedir}/target/jacoco-it.exec</sonar.jacoco.itReportPath> + <sonar.language>java</sonar.language> + <serviceArtifactName>ms-networkelementnamegen</serviceArtifactName> + </properties> + + <profiles> + <profile> + <id>all-tests</id> + <properties> + <build.profile.id>all-tests</build.profile.id> + <skip.integration.tests>false</skip.integration.tests> + <skip.unit.tests>false</skip.unit.tests> + </properties> + </profile> + <profile> + <id>dev</id> + </profile> + <profile> + <id>integration-test</id> + <properties> + <build.profile.id>integration-test</build.profile.id> + <skip.integration.tests>false</skip.integration.tests> + <skip.unit.tests>true</skip.unit.tests> + </properties> + </profile> + </profiles> + + <developers> + <developer> + <id>${userId}</id> + </developer> + </developers> + + <parent> + <groupId>org.springframework.boot</groupId> + <artifactId>spring-boot-starter-parent</artifactId> + <version>1.5.3.RELEASE</version> + <relativePath/> + </parent> + + <dependencies> + <dependency> + <groupId>io.swagger</groupId> + <artifactId>swagger-core</artifactId> + <version>1.5.20</version> + </dependency> + <dependency> + <groupId>org.springframework.boot</groupId> + <artifactId>spring-boot-starter-web</artifactId> + </dependency> + <dependency> + <groupId>org.springframework.boot</groupId> + <artifactId>spring-boot-starter-jersey</artifactId> + </dependency> + <dependency> + <groupId>org.springframework.boot</groupId> + <artifactId>spring-boot-starter-actuator</artifactId> + </dependency> + <dependency> + <groupId>org.springframework.boot</groupId> + <artifactId>spring-boot-starter-test</artifactId> + <scope>test</scope> + </dependency> + <dependency> + <groupId>org.springframework.boot</groupId> + <artifactId>spring-boot-starter-tomcat</artifactId> + <scope>compile</scope> + </dependency> + <dependency> + <groupId>org.springframework.boot</groupId> + <artifactId>spring-boot-starter-data-jpa</artifactId> + <scope>compile</scope> + </dependency> + <dependency> + <groupId>org.apache.httpcomponents</groupId> + <artifactId>httpclient</artifactId> + </dependency> + <dependency> + <groupId>javax.ws.rs</groupId> + <artifactId>javax.ws.rs-api</artifactId> + <version>2.1</version> + </dependency> + <dependency> + <groupId>commons-lang</groupId> + <artifactId>commons-lang</artifactId> + <version>2.6</version> + </dependency> + <dependency> + <groupId>org.liquibase</groupId> + <artifactId>liquibase-core</artifactId> + </dependency> + <dependency> + <groupId>org.wisdom-framework</groupId> + <artifactId>mysql-connector-java</artifactId> + <version>5.1.34_1</version> + </dependency> + <dependency> + <groupId>com.h2database</groupId> + <artifactId>h2</artifactId> + </dependency> + + <dependency> + <groupId>org.springframework.boot</groupId> + <artifactId>spring-boot-configuration-processor</artifactId> + <optional>true</optional> + </dependency> + </dependencies> + + <build> + <finalName>NetworkElementNameGen</finalName> + <plugins> + <plugin> + <groupId>org.jacoco</groupId> + <artifactId>jacoco-maven-plugin</artifactId> + <version>0.7.5.201505241946</version> + <executions> + <execution> + <id>pre-unit-test</id> + <goals> + <goal>prepare-agent</goal> + </goals> + <configuration> + <destFile>${sonar.jacoco.reportPath}</destFile> + <propertyName>surefireArgLine</propertyName> + </configuration> + </execution> + <execution> + <id>post-unit-test</id> + <phase>test</phase> + <goals> + <goal>report</goal> + </goals> + <configuration> + <dataFile>${sonar.jacoco.reportPath}</dataFile> + <outputDirectory>${jacoco.path}</outputDirectory> + </configuration> + </execution> + <execution> + <id>pre-integration-test</id> + <phase>pre-integration-test</phase> + <goals> + <goal>prepare-agent</goal> + </goals> + <configuration> + <destFile>${sonar.jacoco.itReportPath}</destFile> + <propertyName>failsafeArgLine</propertyName> + </configuration> + </execution> + <execution> + <id>post-integration-test</id> + <phase>post-integration-test</phase> + <goals> + <goal>report</goal> + </goals> + <configuration> + <dataFile>${sonar.jacoco.itReportPath}/</dataFile> + <outputDirectory>${jacoco.itPath}</outputDirectory> + </configuration> + </execution> + </executions> + </plugin> + <plugin> + <groupId>org.apache.maven.plugins</groupId> + <artifactId>maven-surefire-plugin</artifactId> + <configuration> + <argLine>${surefireArgLine}</argLine> + <skipTests>${skip.unit.tests}</skipTests> + <excludes> + <exclude>**/IT*.java</exclude> + </excludes> + </configuration> + </plugin> + <plugin> + <groupId>org.apache.maven.plugins</groupId> + <artifactId>maven-failsafe-plugin</artifactId> + <executions> + <execution> + <id>integration-tests</id> + <goals> + <goal>integration-test</goal> + <goal>verify</goal> + </goals> + <configuration> + <argLine>${failsafeArgLine}</argLine> + <skipTests>${skip.integration.tests}</skipTests> + </configuration> + </execution> + </executions> + </plugin> + <plugin> + <artifactId>maven-dependency-plugin</artifactId> + </plugin> + <plugin> + <groupId>com.github.kongchen</groupId> + <artifactId>swagger-maven-plugin</artifactId> + <version>3.1.3</version> + <configuration> + <apiSources> + <apiSource> + <locations>org.onap.ccsdk.apps.ms.neng.service.rs</locations> + <basePath>/web</basePath> + <info> + <title>${project.artifactId} Service</title> + <version>${project.version}</version> + </info> + <swaggerDirectory>${swagger.directory}</swaggerDirectory> + </apiSource> + </apiSources> + </configuration> + <executions> + <execution> + <phase>package</phase> + <goals> + <goal>generate</goal> + </goals> + </execution> + </executions> + </plugin> + + <plugin> + <artifactId>exec-maven-plugin</artifactId> + <groupId>org.codehaus.mojo</groupId> + </plugin> + <plugin> + <groupId>com.spotify</groupId> + <artifactId>docker-maven-plugin</artifactId> + <version>0.4.11</version> + <configuration> + <imageName>${docker.registry}/org.onap.ccsdk.apps/${serviceArtifactName}</imageName> + <dockerDirectory>src/main/docker</dockerDirectory> + <serverId>docker-hub</serverId> + <registryUrl>https://${docker.registry}</registryUrl> + <imageTags> + <imageTag>${project.version}</imageTag> + <imageTag>latest</imageTag> + </imageTags> + <forceTags>true</forceTags> + <resources> + <resource> + <targetPath>/</targetPath> + <directory>${project.build.directory}</directory> + <include>${project.build.finalName}.jar</include> + </resource> + <resource> + <targetPath>/</targetPath> + <directory>${project.build.directory}</directory> + <include>opt/etc/config/*</include> + </resource> + <resource> + <targetPath>/</targetPath> + <directory>${project.build.directory}</directory> + <include>opt/etc/keystore/*</include> + </resource> + <resource> + <targetPath>/</targetPath> + <directory>${project.build.directory}</directory> + <include>opt/etc/truststore/*</include> + </resource> + <resource> + <targetPath>/</targetPath> + <directory>${project.build.directory}</directory> + <include>opt/aai/keystore/*</include> + </resource> + <resource> + <targetPath>/</targetPath> + <directory>${project.build.directory}</directory> + <include>etc/*</include> + </resource> + </resources> + </configuration> + </plugin> + <plugin> + <groupId>org.springframework.boot</groupId> + <artifactId>spring-boot-maven-plugin</artifactId> + <executions> + <execution> + <goals> + <goal>repackage</goal> + </goals> + </execution> + </executions> + </plugin> + </plugins> + <resources> + <resource> + <directory>src/main/resources</directory> + <filtering>true</filtering> + <includes> + <include>**/*</include> + </includes> + </resource> + <resource> + <directory>opt/aai/keystore</directory> + <targetPath>../opt/aai/keystore</targetPath> + <filtering>false</filtering> + <includes> + <include>**/*</include> + </includes> + </resource> + + <resource> + <directory>opt/etc/config</directory> + <targetPath>../opt/etc/config</targetPath> + <filtering>true</filtering> + <includes> + <include>**/*</include> + </includes> + </resource> + <resource> + <directory>opt/etc/keystore</directory> + <targetPath>../opt/etc/keystore</targetPath> + <filtering>false</filtering> + <includes> + <include>**/*</include> + </includes> + </resource> + <resource> + <directory>opt/etc/truststore</directory> + <targetPath>../opt/etc/truststore</targetPath> + <filtering>false</filtering> + <includes> + <include>**/*</include> + </includes> + </resource> + </resources> + </build> +</project> + diff --git a/ms/neng/src/main/java/org/onap/ccsdk/apps/ms/neng/core/Application.java b/ms/neng/src/main/java/org/onap/ccsdk/apps/ms/neng/core/Application.java new file mode 100644 index 00000000..e95fb7eb --- /dev/null +++ b/ms/neng/src/main/java/org/onap/ccsdk/apps/ms/neng/core/Application.java @@ -0,0 +1,77 @@ +/*- + * ============LICENSE_START======================================================= + * ONAP : CCSDK.apps + * ================================================================================ + * Copyright (C) 2018 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.onap.ccsdk.apps.ms.neng.core; + +import java.util.Arrays; +import org.springframework.boot.CommandLineRunner; +import org.springframework.boot.SpringApplication; +import org.springframework.boot.autoconfigure.EnableAutoConfiguration; +import org.springframework.boot.autoconfigure.SpringBootApplication; +import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration; +import org.springframework.boot.autoconfigure.orm.jpa.HibernateJpaAutoConfiguration; +import org.springframework.boot.builder.SpringApplicationBuilder; +import org.springframework.boot.web.support.SpringBootServletInitializer; +import org.springframework.context.ApplicationContext; +import org.springframework.context.annotation.Bean; +import org.springframework.context.annotation.ComponentScan; +import org.springframework.scheduling.annotation.EnableAsync; + +/** + * Entry point for the micro-service -- it starts up the application. + */ +@SpringBootApplication +@ComponentScan(basePackages = "org.onap.ccsdk") +@EnableAsync +@EnableAutoConfiguration(exclude = {DataSourceAutoConfiguration.class, HibernateJpaAutoConfiguration.class}) +public class Application extends SpringBootServletInitializer { + /** + * Configures the application. + */ + @Override + protected SpringApplicationBuilder configure(SpringApplicationBuilder application) { + return application.sources(Application.class); + } + + /** + * Entry point for the application. + */ + public static void main(String[] args) throws Exception { + SpringApplication.run(Application.class, args); + } + + /** + * Prints diagnostic information after application startup. + */ + @Bean + public CommandLineRunner commandLineRunner(ApplicationContext ctx) { + return args -> { + System.out.println("################################"); + System.out.println("Inspecting the beans provided by Spring Boot:"); + String[] beanNames = ctx.getBeanDefinitionNames(); + Arrays.sort(beanNames); + for (String beanName : beanNames) { + System.out.println(beanName); + } + System.out.println("################################"); + }; + } + +} diff --git a/ms/neng/src/main/java/org/onap/ccsdk/apps/ms/neng/core/persistence/ApplicationConfig.java b/ms/neng/src/main/java/org/onap/ccsdk/apps/ms/neng/core/persistence/ApplicationConfig.java new file mode 100644 index 00000000..d69c270c --- /dev/null +++ b/ms/neng/src/main/java/org/onap/ccsdk/apps/ms/neng/core/persistence/ApplicationConfig.java @@ -0,0 +1,141 @@ +/*- + * ============LICENSE_START======================================================= + * ONAP : CCSDK.apps + * ================================================================================ + * Copyright (C) 2018 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.onap.ccsdk.apps.ms.neng.core.persistence; + +import java.util.HashMap; +import java.util.Map; +import javax.sql.DataSource; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.boot.autoconfigure.orm.jpa.JpaProperties; +import org.springframework.boot.context.properties.ConfigurationProperties; +import org.springframework.boot.orm.jpa.EntityManagerFactoryBuilder; +import org.springframework.context.annotation.Bean; +import org.springframework.context.annotation.Configuration; +import org.springframework.core.env.Environment; +import org.springframework.dao.annotation.PersistenceExceptionTranslationPostProcessor; +import org.springframework.data.jpa.repository.config.EnableJpaRepositories; +import org.springframework.jdbc.datasource.DriverManagerDataSource; +import org.springframework.orm.jpa.JpaTransactionManager; +import org.springframework.orm.jpa.JpaVendorAdapter; +import org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean; +import org.springframework.orm.jpa.vendor.HibernateJpaVendorAdapter; +import org.springframework.transaction.annotation.EnableTransactionManagement; + +/** + * Manages the overall configuration of the application related to persistence. + */ +@Configuration +@EnableJpaRepositories(basePackages = "org.onap.ccsdk.apps.ms.neng.persistence.repository") +@EnableTransactionManagement +public class ApplicationConfig { + + @Autowired + private Environment environment; + + /** + * Builds and returns the DataSource used for persisting the data managed by this micro-service. + */ + @Bean + public DataSource dataSource() { + DriverManagerDataSource dataSource = new DriverManagerDataSource(); + dataSource.setDriverClassName(environment.getProperty("datasource.db.driver-class-name")); + dataSource.setUrl(environment.getProperty("datasource.db.url")); + dataSource.setUsername(environment.getProperty("datasource.db.username")); + dataSource.setPassword(environment.getProperty("datasource.db.password")); + return dataSource; + } + + /** + * Builds and returns the JpaProperties used for configuration. + */ + @Bean + @ConfigurationProperties(prefix = "jpa") + public JpaProperties jpaProperties() { + return new JpaProperties(); + } + + /** + * Builds and returns the JpaVendorAdapter used for configuration. + */ + @Bean + public JpaVendorAdapter jpaVendorAdapter(JpaProperties jpaProperties) { + HibernateJpaVendorAdapter hibernateJpaVendorAdapter = new HibernateJpaVendorAdapter(); + hibernateJpaVendorAdapter.setShowSql(jpaProperties.isShowSql()); + hibernateJpaVendorAdapter.setGenerateDdl(jpaProperties.isGenerateDdl()); + return hibernateJpaVendorAdapter; + } + + /** + * Builds and returns the Properties used for Hibernate configuration. + */ + @Bean + public Map<String, String> hibProperties() { + Map<String, String> hibProperties = new HashMap<>(); + String[] propertyNames = { + "hibernate.dialect", + "hibernate.show_sql", + "hibernate.format_sql", + "hibernate.cache.provider_class", + "hibernate.id.new_generator_mappings", + "hibernate.hbm2ddl.auto", + }; + for (String name : propertyNames) { + hibProperties.put(name, environment.getProperty(name)); + } + return hibProperties; + } + + /** + * Builds and returns the JpaTransactionManager. + */ + @Bean + public JpaTransactionManager transactionManager(LocalContainerEntityManagerFactoryBean entityManagerFactory) { + JpaTransactionManager transactionManager = new JpaTransactionManager(); + transactionManager.setEntityManagerFactory(entityManagerFactory.getObject()); + return transactionManager; + } + + /** + * Builds and returns the PersistenceExceptionTranslationPostProcessor. + * + * <p/>PersistenceExceptionTranslationPostProcessor is a bean post processor which adds an advisor to any bean + * annotated with Repository so that any platform-specific exceptions are caught and then re-thrown + * as one of Spring's unchecked data access exceptions (i.e. a subclass of DataAccessException). + */ + @Bean + public PersistenceExceptionTranslationPostProcessor exceptionTranslation() { + return new PersistenceExceptionTranslationPostProcessor(); + } + + /** + * Builds and returns the Factory used for building entities. + */ + @Bean + public LocalContainerEntityManagerFactoryBean entityManagerFactory( + JpaVendorAdapter jpaVendAdapter, + Map<String, String> hibProps, + DataSource dataSource) { + EntityManagerFactoryBuilder factBuilder = new EntityManagerFactoryBuilder(jpaVendAdapter, hibProps, null); + String pkgToScan = environment.getProperty("entitymanager.packagesToScan"); + return factBuilder.dataSource(dataSource).packages(pkgToScan).build(); + } + +} diff --git a/ms/neng/src/main/java/org/onap/ccsdk/apps/ms/neng/core/policy/PolicyFinder.java b/ms/neng/src/main/java/org/onap/ccsdk/apps/ms/neng/core/policy/PolicyFinder.java new file mode 100644 index 00000000..6d8a27a7 --- /dev/null +++ b/ms/neng/src/main/java/org/onap/ccsdk/apps/ms/neng/core/policy/PolicyFinder.java @@ -0,0 +1,38 @@ +/*- + * ============LICENSE_START======================================================= + * ONAP : CCSDK.apps + * ================================================================================ + * Copyright (C) 2018 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.onap.ccsdk.apps.ms.neng.core.policy; + +import java.util.Map; + +/** + * Finds policy data, normally by calling policy-manager. + */ +public interface PolicyFinder { + /** + * Finds the policy with a given name. + * + * @param policyName the name of the policy the caller is looking for + * @return a map ( String -> Object ) representing the policy, as a general JSON structure, + * where the map entries are String-s, or arrays of similar maps, or similar nested maps. + * @throws Exception any exceptions caught are propagated + */ + public Map<String, Object> findPolicy(String policyName) throws Exception; +} diff --git a/ms/neng/src/main/java/org/onap/ccsdk/apps/ms/neng/core/policy/PolicyParameters.java b/ms/neng/src/main/java/org/onap/ccsdk/apps/ms/neng/core/policy/PolicyParameters.java new file mode 100644 index 00000000..37fc38cb --- /dev/null +++ b/ms/neng/src/main/java/org/onap/ccsdk/apps/ms/neng/core/policy/PolicyParameters.java @@ -0,0 +1,44 @@ +/*- + * ============LICENSE_START======================================================= + * ONAP : CCSDK.apps + * ================================================================================ + * Copyright (C) 2018 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.onap.ccsdk.apps.ms.neng.core.policy; + +/** + * Specifies parameters that control the nature of policy data and the behavior of this micro-service. + * + * <p/>These parameters are typically stored in DB or read from a configuration file. + */ +public interface PolicyParameters { + /** + * Gives the separator between the entries within the same recipe -- such as the pipe('|') character. + */ + public String getRecipeSeparator() throws Exception; + + /** + * Maps a given function, used in the policy, to the equivalent function in this micro-service. + */ + public String mapFunction(String name) throws Exception; + + /** + * Maximum number of times the micro-service should attempt name generation in the same transaction + * (if all previous attempts in the same transaction fail). + */ + public int getMaxGenAttempt() throws Exception; +} diff --git a/ms/neng/src/main/java/org/onap/ccsdk/apps/ms/neng/core/policy/PolicyPropertyMethodUtils.java b/ms/neng/src/main/java/org/onap/ccsdk/apps/ms/neng/core/policy/PolicyPropertyMethodUtils.java new file mode 100644 index 00000000..9f4725fb --- /dev/null +++ b/ms/neng/src/main/java/org/onap/ccsdk/apps/ms/neng/core/policy/PolicyPropertyMethodUtils.java @@ -0,0 +1,69 @@ +/*- + * ============LICENSE_START======================================================= + * ONAP : CCSDK.apps + * ================================================================================ + * Copyright (C) 2018 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.onap.ccsdk.apps.ms.neng.core.policy; + +/** + * Utility methods equivalent to the JavaScript like functions used in policies by the policy-manager. + */ +public class PolicyPropertyMethodUtils { + + /** + * Equivalent to the substring function used by policy-manager (which works similar to JavaScript + * substring function). + */ + public static String substring(String sourceStr, String startIndex, String endIndex) { + return sourceStr.substring(Integer.parseInt(startIndex), Integer.parseInt(endIndex)); + } + + /** + * Equivalent to the substring function used by policy-manager (which works similar to JavaScript + * substring function). + */ + public static String substring(String sourceStr, String length) { + + int startIndexInt = 0; + int subStrLength = Integer.parseInt(length); + if (subStrLength < 0) { + + startIndexInt = sourceStr.length() + subStrLength; + startIndexInt = (startIndexInt < 0) ? 0 : startIndexInt; + + return sourceStr.substring(startIndexInt); + } else if (subStrLength > sourceStr.length()) { + subStrLength = sourceStr.length(); + } + return sourceStr.substring(startIndexInt, subStrLength); + } + + /** + * Equivalent to the to_upper_case function used by policy-manager. + */ + public static String toUpperCase(String sourceStr) { + return sourceStr.toUpperCase(); + } + + /** + * Equivalent to the to_lower_case function used by policy-manager. + */ + public static String toLowerCase(String sourceStr) { + return sourceStr.toLowerCase(); + } +} diff --git a/ms/neng/src/main/java/org/onap/ccsdk/apps/ms/neng/core/policy/PolicyReader.java b/ms/neng/src/main/java/org/onap/ccsdk/apps/ms/neng/core/policy/PolicyReader.java new file mode 100644 index 00000000..de034f04 --- /dev/null +++ b/ms/neng/src/main/java/org/onap/ccsdk/apps/ms/neng/core/policy/PolicyReader.java @@ -0,0 +1,328 @@ +/*- + * ============LICENSE_START======================================================= + * ONAP : CCSDK.apps + * ================================================================================ + * Copyright (C) 2018 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.onap.ccsdk.apps.ms.neng.core.policy; + +import com.fasterxml.jackson.core.type.TypeReference; +import com.fasterxml.jackson.databind.ObjectMapper; +import java.util.List; +import java.util.Map; +import java.util.Set; + +/** + * Converts policy data to the structure expected by this micro-service. + */ +public abstract class PolicyReader implements PolicyFinder { + /** + * Extracts the naming-models from a policy. + * + * @param policy the policy + * @return the list of naming-models found in the policy + */ + public static List<Map<String, ?>> namingModels(Map<String, ?> policy) { + Set<String> keys = policy.keySet(); + // TODO : retrieve naming-models at any level + if (keys.contains("config")) { + @SuppressWarnings("unchecked") + Map<String, ?> config = (Map<String, ?>) policy.get("config"); + List<Map<String, ?>> namingModels = list(map(config, "content"), "naming-models"); + if (namingModels == null) { + namingModels = list(config, "naming-models"); + } + return namingModels; + } else { + return list(map(map(policy, "input"), "naming-model"), "naming-models"); + } + + } + + /** + * Extracts a naming-model from the given list of models, based on a naming-type. + * + * @param namingModels a list of naming-models + * @param namingType the naming type + * @return the naming model found, or null if none is found + */ + public static Map<String, ?> namingModel(List<Map<String, ?>> namingModels, String namingType) { + Map<String, ?> theModel = null; + if (namingModels != null) { + for (Map<String, ?> model : namingModels) { + Object val = model.get("naming-type"); + if (namingType.equals(val)) { + theModel = model; + break; + } + } + } + return theModel; + } + + /** + * Extracts a naming-model from the given list of models, based on a naming-type, by using a more + * relaxed/liberal comparison of the naming-type. + * + * <p/>When doing the relaxed comparison, upper-case/lower-case differences are ignored, some + * special characters like underscore, dash etc. are ignored, and the presence of the 'NAME' + * at the end of the naming-type is ignored. + * + * @param namingModels a list of naming-models + * @param namingType the naming type + * @return the naming model found, or null if none is found + */ + public static Map<String, ?> namingModelRelaxed(List<Map<String, ?>> namingModels, String namingType) { + Map<String, ?> theModel = null; + if (namingModels != null) { + for (Map<String, ?> model : namingModels) { + Object val = model.get("naming-type"); + if (val != null) { + if (namingType.equalsIgnoreCase(val.toString())) { + theModel = model; + break; + } + } + } + if (theModel == null) { + namingType = relaxedNamingType(namingType); + for (Map<String, ?> model : namingModels) { + Object val = model.get("naming-type"); + if (val != null) { + String relaxedVal = relaxedNamingType(val.toString()); + if (namingType.equalsIgnoreCase(relaxedVal)) { + theModel = model; + break; + } + } + } + } + } + return theModel; + } + + /** + * Finds the naming-operation from the given naming-model. + */ + public static String namingOperation(Map<String, ?> namimgModel) { + String propValue = value(namimgModel, "name-operation"); + return propValue; + } + + /** + * Finds the naming-property with a given name from a naming-model. + * + * @param namingModel a naming-model + * @param propertyName the property name + * @return the property found, or null if none is found + */ + public static Map<String, ?> namingProperty(Map<String, ?> namingModel, String propertyName) { + List<Map<String, ?>> properties = namingProperties(namingModel); + Map<String, ?> theProp = null; + if (properties != null) { + for (Map<String, ?> prop : properties) { + String onePropName = propertyName(prop); + if (propertyName.equals(onePropName)) { + theProp = prop; + break; + } + } + } + return theProp; + } + + /** + * Finds the naming-recipe from the given naming-model. + */ + public static String namingRecipe(Map<String, ?> namimgModel) { + return value(namimgModel, "naming-recipe"); + } + + /** + * Finds the naming-type from the given naming-model. + */ + public static String namingType(Map<String, ?> namimgModelOrElement) { + return value(namimgModelOrElement, "naming-type"); + } + + /** + * Finds the property-value from the given property map. + */ + public static String propertyValue(Map<String, ?> properties) { + return value(properties, "property-value"); + } + + /** + * Converts the a naming-type to a relaxed/liberal convention. + * + * <p/>In the relaxed convention, all characters are upper-case, some special characters like underscore, + * dash etc. are ignored, and there is no 'NAME' at the end of the naming-type. + * + * @param type the naming-type + */ + public static String relaxedNamingType(String type) { + type = type.toUpperCase(); + if (type.endsWith("NAME")) { + type = type.substring(0, type.length() - 4); + } + type = type.replaceAll("-", ""); + type = type.replaceAll("_", ""); + return type; + } + + /** + * Builds a PolicySequence based on given properties. + */ + public static PolicySequence seq(Map<String, ?> properties) { + properties = map(properties, "increment-sequence"); + String scope = value(properties, "scope"); + String startValue = value(properties, "start-value"); + String max = value(properties, "max"); + String increment = value(properties, "increment"); + String type = value(properties, "sequence-type"); + String length = value(properties, "length"); + + PolicySequence seq = new PolicySequence(); + seq.setScope(scope); + seq.setStartValue(number(startValue, 1)); + seq.setMaxValueString(max); + seq.setIncrement(number(increment, 1)); + seq.setType(type); + seq.setLength(number(length, 3)); + + return seq; + } + + /** + * Finds the value of a given key, as a String, in a map. + * + * @param map a map, which can be null + * @param key a key + * @return the value of the key in the map, or null if there is none. + */ + public static String value(Map<String, ?> map, String key) { + String value = null; + if (map != null) { + value = (String) map.get(key); + if (!(value instanceof String)) { + value = null; + } + } + return value; + } + + /** + * Finds the value of a given key, as a String, in a map. + * + * @param map a map, which can be null + * @param key a key + * @param relaxed if true, relaxed/liberal comparison of the keys is done, by ignoring special + * characters dash and underscore + * @return the value of the key in the map, or null if there is none. + */ + public static String value(Map<String, ?> map, String key, boolean relaxed) { + if (relaxed) { + String value = null; + if (map != null) { + for (final String aKey : map.keySet()) { + if (aKey.equalsIgnoreCase(key)) { + value = (String) map.get(aKey); + break; + } + } + if (value == null) { + key = key.replaceAll("_", ""); + key = key.replaceAll("-", ""); + for (final String aKey : map.keySet()) { + String keyDup = aKey.replaceAll("_", ""); + keyDup = keyDup.replaceAll("-", ""); + if (keyDup.equalsIgnoreCase(key)) { + value = (String) map.get(aKey); + break; + } + } + } + if (!(value instanceof String)) { + value = null; + } + } + return value; + } else { + return value(map, key); + } + } + + static Map<String, ?> dependentNamingModel(List<Map<String, ?>> namingModels, String recipeItem) { + Map<String, ?> theModel = namingModel(namingModels, recipeItem); + if (theModel == null) { + theModel = namingModelRelaxed(namingModels, recipeItem); + } + return theModel; + } + + Map<String, Object> getPolicy(String jsonString) throws Exception { + ObjectMapper mapper = new ObjectMapper(); + Map<String, Object> jsonObject = mapper.readValue(jsonString, new TypeReference<Map<String, Object>>() {}); + return jsonObject; + } + + static List<Map<String, ?>> list(Map<String, ?> policy, String name) { + List<Map<String, ?>> list = null; + if (policy != null) { + @SuppressWarnings("unchecked") + List<Map<String, ?>> listObj = (List<Map<String, ?>>) policy.get(name); + if (list instanceof List<?>) { + list = listObj; + } + } + return list; + } + + static Map<String, ?> map(Map<String, ?> policy, String name) { + Map<String, ?> map = null; + if (policy != null) { + @SuppressWarnings("unchecked") + Map<String, ?> mapObj = (Map<String, ?>) policy.get(name); + if (mapObj instanceof Map<?, ?>) { + map = mapObj; + } + } + return map; + } + + static List<Map<String, ?>> namingProperties(Map<String, ?> namimgModel) { + return list(namimgModel, "naming-properties"); + } + + static long number(String str, long defaultValue) { + long value; + try { + value = Long.valueOf(str); + } catch (Exception e) { + value = defaultValue; + } + return value; + } + + static String propertyName(Map<String, ?> properties) { + return value(properties, "property-name"); + } + + static String propertyOperation(Map<String, ?> properties) { + return value(properties, "property-operation"); + } +} diff --git a/ms/neng/src/main/java/org/onap/ccsdk/apps/ms/neng/core/policy/PolicySequence.java b/ms/neng/src/main/java/org/onap/ccsdk/apps/ms/neng/core/policy/PolicySequence.java new file mode 100644 index 00000000..dc0b6fdc --- /dev/null +++ b/ms/neng/src/main/java/org/onap/ccsdk/apps/ms/neng/core/policy/PolicySequence.java @@ -0,0 +1,158 @@ +/*- + * ============LICENSE_START======================================================= + * ONAP : CCSDK.apps + * ================================================================================ + * Copyright (C) 2018 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.onap.ccsdk.apps.ms.neng.core.policy; + +/** + * Represents a sequence object in the policy, as a POJO. + */ +public class PolicySequence { + /** + * The type of the policy sequence. + */ + public enum Type { + ALPHA, NUMERIC + } + + private long startValue; + private long increment; + private long length; + private Long maxValue; + private String maxValueString; + private Type type = Type.NUMERIC; + private String scope; + private String key; + private String value; + private Long lastReleaseSeqNumTried; + + public long getStartValue() { + return startValue; + } + + public void setStartValue(long startValue) { + this.startValue = startValue; + } + + public long getIncrement() { + return increment; + } + + public void setIncrement(long increment) { + this.increment = increment; + } + + public long getLength() { + return length; + } + + public void setLength(long length) { + this.length = length; + } + + /** + * Generate and return the maximum value for the sequence. + */ + public long getMaxValue() { + if (this.maxValue == null) { + int base = 10; + if (this.type == Type.ALPHA) { + base = 36; + } + if (this.maxValueString != null) { + try { + this.maxValue = Long.valueOf(this.maxValueString, base); + } catch (Exception e) { + this.maxValue = null; + } + } + if (this.maxValue == null) { + long length = this.length; + if (length <= 0) { + length = 3; + } + this.maxValue = (long) Math.pow(base, length) - 1; + } + } + return maxValue; + } + + public void setMaxValue(long maxValue) { + this.maxValue = maxValue; + } + + public String getMaxValueString() { + return maxValueString; + } + + public void setMaxValueString(String maxValueString) { + this.maxValueString = maxValueString; + } + + public Type getType() { + return type; + } + + public void setType(Type type) { + this.type = type; + } + + /** + * Sets the type. + */ + public void setType(String typeStr) { + if ("numeric".equalsIgnoreCase(typeStr)) { + setType(Type.NUMERIC); + } else if ("alpha-numeric".equalsIgnoreCase(typeStr)) { + setType(Type.ALPHA); + } + } + + public String getScope() { + return scope; + } + + public void setScope(String scope) { + this.scope = scope; + } + + public String getValue() { + return value; + } + + public void setValue(String value) { + this.value = value; + } + + public String getKey() { + return key; + } + + public void setKey(String key) { + this.key = key; + } + + public Long getLastReleaseSeqNumTried() { + return lastReleaseSeqNumTried; + } + + public void setLastReleaseSeqNumTried(Long lastReleaseSeqNumTried) { + this.lastReleaseSeqNumTried = lastReleaseSeqNumTried; + } +} diff --git a/ms/neng/src/main/java/org/onap/ccsdk/apps/ms/neng/core/policy/PropertyOperator.java b/ms/neng/src/main/java/org/onap/ccsdk/apps/ms/neng/core/policy/PropertyOperator.java new file mode 100644 index 00000000..7eb63244 --- /dev/null +++ b/ms/neng/src/main/java/org/onap/ccsdk/apps/ms/neng/core/policy/PropertyOperator.java @@ -0,0 +1,152 @@ +/*- + * ============LICENSE_START======================================================= + * ONAP : CCSDK.apps + * ================================================================================ + * Copyright (C) 2018 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.onap.ccsdk.apps.ms.neng.core.policy; + +import static org.onap.ccsdk.apps.ms.neng.core.policy.PolicyReader.propertyOperation; + +import java.lang.reflect.Method; +import java.util.Map; + +/** + * Applies property operations while processing a policy. + */ +public class PropertyOperator { + /** + * Apply a property found in the policy. + * + * <p/> If the property cannot be applied correctly for any reason, the value is returned as is. + * + * @param value the String to which the property has to be applied + * @param propertyMap a map representing the property, the key of which is "property-operation" + * and the value is the actual property + * @param policyParams parameters configuring policy + * @return the result of applying the property + * @throws Exception all exceptions are propagated + */ + public String apply(String value, Map<String, ?> propertyMap, PolicyParameters policyParams) throws Exception { + String op = propertyOperation(propertyMap); + String mapped = null; + if (op != null) { + String fn = operationFunction(op); + if (fn != null) { + mapped = policyParams.mapFunction(fn); + if (mapped == null) { + mapped = camelConverted(fn); + } + if (mapped != null) { + op = op.replaceFirst(fn, mapped); + } + } + value = applyJavaOperation(value, op, mapped); + } + return value; + } + + /** + * Apply a property found in the policy. + * + * <p/> If the property cannot be applied correctly for any reason, the value is returned as is. + * + * @param value the String to which the property has to be applied + * @param operation the operation to be applied + * @param policyParams parameters configuring policy + * @return the result of applying the property + * @throws Exception all exceptions are propagated + */ + public String apply(String value, String operation, PolicyParameters policyParams) throws Exception { + String mapped = null; + if (operation != null) { + String fn = operationFunction(operation); + if (fn != null) { + mapped = policyParams.mapFunction(fn); + if (mapped == null) { + mapped = camelConverted(fn); + } + if (mapped != null) { + operation = operation.replaceFirst(fn, mapped); + } + } + value = applyJavaOperation(value, operation, mapped); + } + return value; + } + + private String applyJavaOperation(String inputString, String op, String methodName) throws Exception { + String postOp = null; + try { + String argPart = ""; + if (op.indexOf("(") > 0) { + int funcStartIndex = op.indexOf("("); + int funcEndIndex = op.lastIndexOf(")"); + argPart = op.substring(funcStartIndex + 1, funcEndIndex); + } + + argPart = inputString + "," + argPart; + String[] args = argPart.split(","); + + PolicyPropertyMethodUtils utils = new PolicyPropertyMethodUtils(); + for (Method m : PolicyPropertyMethodUtils.class.getDeclaredMethods()) { + if (m.getName().equals(methodName) && m.getParameterCount() == args.length) { + postOp = (String) m.invoke(utils, (Object[])args); + break; + } + } + } catch (Exception e) { + e.printStackTrace(); + throw e; + } + return postOp; + } + + static String operationFunction(String operation) throws Exception { + operation = operation.trim(); + int i = 0; + for (; i < operation.length(); ++i) { + char ch = operation.charAt(i); + if (!Character.isJavaIdentifierPart(ch)) { + break; + } + } + String value = operation.substring(0, i); + if (value.length() == 0) { + value = null; + } + return value; + } + + static String camelConverted(String fn) throws Exception { + boolean upperNext = false; + StringBuffer buf = new StringBuffer(); + for (int i = 0; i < fn.length(); ++i) { + char ch = fn.charAt(i); + if (ch == '_') { + upperNext = true; + } else { + if (upperNext) { + ch = Character.toUpperCase(ch); + } + buf.append(ch); + upperNext = false; + } + } + return buf.toString(); + } +} diff --git a/ms/neng/src/main/java/org/onap/ccsdk/apps/ms/neng/core/policy/RecipeParser.java b/ms/neng/src/main/java/org/onap/ccsdk/apps/ms/neng/core/policy/RecipeParser.java new file mode 100644 index 00000000..d9eda66a --- /dev/null +++ b/ms/neng/src/main/java/org/onap/ccsdk/apps/ms/neng/core/policy/RecipeParser.java @@ -0,0 +1,59 @@ +/*- + * ============LICENSE_START======================================================= + * ONAP : CCSDK.apps + * ================================================================================ + * Copyright (C) 2018 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.onap.ccsdk.apps.ms.neng.core.policy; + +import java.util.ArrayList; +import java.util.Arrays; +import java.util.List; + +/** + * Parses recipe into a list of items. + */ +public class RecipeParser { + + /** + * Parses recipe into a list of items. + * + * @param policyParams the policy parameters + * @param recipe the recipe from policy manager + * @return a list containing the items in the recipe + * @throws Exception all exceptions are propagated + */ + public static List<String> parseRecipe(PolicyParameters policyParams, String recipe) throws Exception { + String separatorAll = policyParams.getRecipeSeparator(); + if (separatorAll == null) { + separatorAll = "|\":\","; + } + String[] separators = separatorAll.split("\""); + List<String> recipeItems = new ArrayList<>(); + for (String separator : separators) { + if (recipe.contains(separator)) { + separator = "\\" + separator; + recipeItems = Arrays.asList(recipe.split(separator)); + break; + } + } + if (recipeItems.isEmpty() && recipe.length() > 0) { + recipeItems.add(recipe); + } + return recipeItems; + } +} |