added svcapi ui and camunda code

[it/otf.git] / otf-camunda / src / main / java / org / oran / otf / camunda / configuration / OtfCamundaConfiguration.java

diff --git a/otf-camunda/src/main/java/org/oran/otf/camunda/configuration/OtfCamundaConfiguration.java b/otf-camunda/src/main/java/org/oran/otf/camunda/configuration/OtfCamundaConfiguration.java
new file mode 100644 (file)
index 0000000..a816786
--- /dev/null
+++ b/otf-camunda/src/main/java/org/oran/otf/camunda/configuration/OtfCamundaConfiguration.java
@@ -0,0 +1,155 @@
+/*  Copyright (c) 2019 AT&T Intellectual Property.                             #\r
+#                                                                              #\r
+#   Licensed under the Apache License, Version 2.0 (the "License");            #\r
+#   you may not use this file except in compliance with the License.           #\r
+#   You may obtain a copy of the License at                                    #\r
+#                                                                              #\r
+#       http://www.apache.org/licenses/LICENSE-2.0                             #\r
+#                                                                              #\r
+#   Unless required by applicable law or agreed to in writing, software        #\r
+#   distributed under the License is distributed on an "AS IS" BASIS,          #\r
+#   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.   #\r
+#   See the License for the specific language governing permissions and        #\r
+#   limitations under the License.                                             #\r
+##############################################################################*/\r
+\r
+\r
+package org.oran.otf.camunda.configuration;\r
+\r
+import com.google.common.base.Strings;\r
+import java.util.Optional;\r
+import java.util.UUID;\r
+import javax.sql.DataSource;\r
+import org.camunda.bpm.application.impl.event.ProcessApplicationEventListenerPlugin;\r
+import org.camunda.bpm.engine.ProcessEngineConfiguration;\r
+import org.camunda.bpm.engine.impl.cfg.IdGenerator;\r
+import org.camunda.bpm.engine.impl.cfg.ProcessEngineConfigurationImpl;\r
+import org.camunda.bpm.engine.impl.history.HistoryLevel;\r
+import org.camunda.bpm.engine.spring.SpringProcessEngineConfiguration;\r
+import org.camunda.bpm.extension.reactor.bus.CamundaEventBus;\r
+import org.camunda.bpm.extension.reactor.plugin.ReactorProcessEnginePlugin;\r
+import org.camunda.bpm.extension.reactor.projectreactor.EventBus;\r
+import org.camunda.bpm.spring.boot.starter.configuration.impl.DefaultProcessEngineConfiguration;\r
+import org.camunda.connect.plugin.impl.ConnectProcessEnginePlugin;\r
+import org.camunda.spin.plugin.impl.SpinProcessEnginePlugin;\r
+import org.springframework.beans.factory.annotation.Autowired;\r
+import org.springframework.beans.factory.annotation.Qualifier;\r
+import org.springframework.context.annotation.Bean;\r
+import org.springframework.context.annotation.Configuration;\r
+import org.springframework.transaction.PlatformTransactionManager;\r
+import org.springframework.util.StringUtils;\r
+\r
+@Configuration\r
+public class OtfCamundaConfiguration extends DefaultProcessEngineConfiguration {\r
+\r
+  @Autowired\r
+  private DataSource dataSource;\r
+  @Autowired\r
+  private PlatformTransactionManager transactionManager;\r
+  @Autowired private Optional<IdGenerator> idGenerator;\r
+\r
+  public static String processEngineName;\r
+\r
+  @Bean\r
+  public ProcessEngineConfiguration configureEngine(ProcessEngineConfigurationImpl configuration) {\r
+    configuration.setJavaSerializationFormatEnabled(true);\r
+    return configuration;\r
+  }\r
+\r
+  @Override\r
+  public void preInit(SpringProcessEngineConfiguration configuration) {\r
+\r
+    logger.info(configuration.getProcessEngineName());\r
+    processEngineName = System.getenv("HOSTNAME");\r
+    if (Strings.isNullOrEmpty(processEngineName)) {\r
+      processEngineName = "otf-camunda-" + UUID.randomUUID().toString();\r
+    }\r
+    processEngineName = processEngineName.replaceAll("-", "_");\r
+    camundaBpmProperties.setProcessEngineName(processEngineName);\r
+    camundaBpmProperties.setAutoDeploymentEnabled(true);\r
+    camundaBpmProperties.setHistoryLevel(HistoryLevel.HISTORY_LEVEL_FULL.getName());\r
+    camundaBpmProperties.setDefaultNumberOfRetries(1);\r
+\r
+    setProcessEngineName(configuration);\r
+    setDefaultSerializationFormat(configuration);\r
+    setIdGenerator(configuration);\r
+    setJobExecutorAcquireByPriority(configuration);\r
+    setDefaultNumberOfRetries(configuration);\r
+\r
+    configuration.setDataSource(dataSource);\r
+    configuration.setTransactionManager(transactionManager);\r
+    configuration.setHistory("true");\r
+    configuration.setDatabaseSchemaUpdate(ProcessEngineConfiguration.DB_SCHEMA_UPDATE_TRUE);\r
+    configuration.setJobExecutorActivate(true);\r
+    configuration.setCreateIncidentOnFailedJobEnabled(true);\r
+    configuration.setFailedJobListenerMaxRetries(0);\r
+    configuration.setJavaSerializationFormatEnabled(true);\r
+    configuration.setMetricsEnabled(false);\r
+  }\r
+\r
+  private void setIdGenerator(SpringProcessEngineConfiguration configuration) {\r
+    idGenerator.ifPresent(configuration::setIdGenerator);\r
+  }\r
+\r
+  private void setDefaultSerializationFormat(SpringProcessEngineConfiguration configuration) {\r
+    String defaultSerializationFormat = camundaBpmProperties.getDefaultSerializationFormat();\r
+    if (StringUtils.hasText(defaultSerializationFormat)) {\r
+      configuration.setDefaultSerializationFormat(defaultSerializationFormat);\r
+    } else {\r
+      logger.warn("Ignoring invalid defaultSerializationFormat='{}'", defaultSerializationFormat);\r
+    }\r
+  }\r
+\r
+  private void setProcessEngineName(SpringProcessEngineConfiguration configuration) {\r
+    String processEngineName =\r
+        StringUtils.trimAllWhitespace(camundaBpmProperties.getProcessEngineName());\r
+    if (!StringUtils.isEmpty(processEngineName) && !processEngineName.contains("-")) {\r
+      configuration.setProcessEngineName(processEngineName);\r
+    } else {\r
+      logger.warn(\r
+          "Ignoring invalid processEngineName='{}' - must not be null, blank or contain hyphen",\r
+          camundaBpmProperties.getProcessEngineName());\r
+    }\r
+  }\r
+\r
+  private void setJobExecutorAcquireByPriority(SpringProcessEngineConfiguration configuration) {\r
+    Optional.ofNullable(camundaBpmProperties.getJobExecutorAcquireByPriority())\r
+        .ifPresent(configuration::setJobExecutorAcquireByPriority);\r
+  }\r
+\r
+  private void setDefaultNumberOfRetries(SpringProcessEngineConfiguration configuration) {\r
+    Optional.ofNullable(camundaBpmProperties.getDefaultNumberOfRetries())\r
+        .ifPresent(configuration::setDefaultNumberOfRetries);\r
+  }\r
+\r
+  @Bean\r
+  CamundaEventBus camundaEventBus() {\r
+    return new CamundaEventBus();\r
+  }\r
+\r
+  @Bean\r
+  @Qualifier("camunda")\r
+  EventBus eventBus(final CamundaEventBus camundaEventBus) {\r
+    return camundaEventBus.get();\r
+  }\r
+\r
+  @Bean\r
+  ReactorProcessEnginePlugin reactorProcessEnginePlugin(final CamundaEventBus camundaEventBus) {\r
+    return new ReactorProcessEnginePlugin(camundaEventBus);\r
+  }\r
+\r
+  @Bean\r
+  ConnectProcessEnginePlugin connectProcessEnginePlugin() {\r
+    return new ConnectProcessEnginePlugin();\r
+  }\r
+\r
+  @Bean\r
+  SpinProcessEnginePlugin spinProcessEnginePlugin() {\r
+    return new SpinProcessEnginePlugin();\r
+  }\r
+\r
+  @Bean\r
+  ProcessApplicationEventListenerPlugin processApplicationEventListenerPlugin() {\r
+    return new ProcessApplicationEventListenerPlugin();\r
+  }\r
+}\r