diff options
Diffstat (limited to 'calamus-engine/src/main/java/io/trygvis/engine')
15 files changed, 0 insertions, 753 deletions
diff --git a/calamus-engine/src/main/java/io/trygvis/engine/CalamusDbConfig.java b/calamus-engine/src/main/java/io/trygvis/engine/CalamusDbConfig.java deleted file mode 100644 index 39772c8..0000000 --- a/calamus-engine/src/main/java/io/trygvis/engine/CalamusDbConfig.java +++ /dev/null @@ -1,129 +0,0 @@ -package io.trygvis.engine; - -import bitronix.tm.BitronixTransactionManager; -import bitronix.tm.TransactionManagerServices; -import bitronix.tm.resource.jdbc.PoolingDataSource; -import com.googlecode.flyway.core.Flyway; -import com.googlecode.flyway.core.api.MigrationInfo; -import com.googlecode.flyway.core.api.MigrationInfoService; -import org.jbpm.process.audit.JPAAuditLogService; -import org.kie.api.io.Resource; -import org.kie.api.io.ResourceType; -import org.kie.api.runtime.manager.RuntimeEnvironment; -import org.kie.internal.io.ResourceFactory; -import org.kie.spring.factorybeans.RuntimeEnvironmentFactoryBean; -import org.kie.spring.factorybeans.RuntimeManagerFactoryBean; -import org.slf4j.Logger; -import org.springframework.context.annotation.Bean; -import org.springframework.context.annotation.Configuration; -import org.springframework.context.annotation.DependsOn; -import org.springframework.context.annotation.Lazy; -import org.springframework.jdbc.datasource.LazyConnectionDataSourceProxy; -import org.springframework.jdbc.datasource.TransactionAwareDataSourceProxy; -import org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean; -import org.springframework.transaction.PlatformTransactionManager; -import org.springframework.transaction.annotation.EnableTransactionManagement; -import org.springframework.transaction.jta.JtaTransactionManager; -import org.springframework.transaction.support.TransactionTemplate; - -import javax.persistence.EntityManagerFactory; -import javax.sql.DataSource; -import java.util.Date; -import java.util.HashMap; -import java.util.Map; - -import static java.lang.String.format; -import static org.slf4j.LoggerFactory.getLogger; - -/** - * http://planet.jboss.org/post/jbpm_6_with_spring - */ -@Configuration -@EnableTransactionManagement -public class CalamusDbConfig { - private final Logger log = getLogger(getClass()); - - @Bean - public DataSource dataSource() { - PoolingDataSource ds = new PoolingDataSource(); - ds.setUniqueName("jdbc/jbpm-ds"); - ds.setClassName(bitronix.tm.resource.jdbc.lrc.LrcXADataSource.class.getCanonicalName()); - ds.setMaxPoolSize(3); - ds.setAllowLocalTransactions(true); - ds.getDriverProperties().put("user", "jbpm"); - ds.getDriverProperties().put("password", "jbpm"); - ds.getDriverProperties().put("url", "jdbc:postgresql://localhost/jbpm"); - ds.getDriverProperties().put("driverClassName", org.postgresql.Driver.class.getCanonicalName()); - ds.init(); - - return new TransactionAwareDataSourceProxy(new LazyConnectionDataSourceProxy(ds)); -// return ds; - } - - public static class DbMigrations { - } - - @Bean - public DbMigrations dbMigrations(DataSource dataSource) { - runFlyway(log, dataSource, "", "public"); - return new DbMigrations(); - } - - private static void runFlyway(Logger log, DataSource dataSource, String prefix, String schema) { - log.info("Running migrations for {}", schema); - - Flyway flyway = new Flyway(); - flyway.setDataSource(dataSource); - flyway.setSchemas(schema); - flyway.setLocations("db/" + prefix); - flyway.setInitOnMigrate(true); - MigrationInfoService info = flyway.info(); - log.info(format("%-15s %-10s %-19s %s", "Version", "State", "Installed on", "Description")); - for (MigrationInfo mi : info.all()) { - Date installedOn = mi.getInstalledOn(); - log.info(format("%-15s %-10s %-19s %s", - mi.getVersion(), - trimToEmpty(mi.getState().getDisplayName()), - installedOn != null ? new Date(installedOn.getTime()).toString() : "", - trimToEmpty(mi.getDescription()))); - } - flyway.migrate(); - } - - private static String trimToEmpty(String string) { - if (string == null) { - return ""; - } - - return string.trim(); - } - - @Bean(destroyMethod = "shutdown") - public BitronixTransactionManager bitronixTransactionManager() { -// bitronix.tm.Configuration configuration = TransactionManagerServices.getConfiguration(); - return TransactionManagerServices.getTransactionManager(); - } - - @Bean - public PlatformTransactionManager platformTransactionManager(BitronixTransactionManager transactionManager) { - return new JtaTransactionManager(transactionManager, transactionManager); - } - - @Bean - public TransactionTemplate transactionTemplate(PlatformTransactionManager platformTransactionManager) { - return new TransactionTemplate(platformTransactionManager); - } - - @Bean - @DependsOn("dbMigrations") - public LocalContainerEntityManagerFactoryBean entityManagerFactory() { - LocalContainerEntityManagerFactoryBean x = new LocalContainerEntityManagerFactoryBean(); - x.setPersistenceUnitName("org.jbpm.persistence.jpa"); - return x; - } - - @Bean - public JPAAuditLogService jpaAuditLogService(EntityManagerFactory entityManagerFactory) { - return new JPAAuditLogService(entityManagerFactory); - } -} diff --git a/calamus-engine/src/main/java/io/trygvis/engine/CalamusJbpm.java b/calamus-engine/src/main/java/io/trygvis/engine/CalamusJbpm.java deleted file mode 100644 index 5b0e8ec..0000000 --- a/calamus-engine/src/main/java/io/trygvis/engine/CalamusJbpm.java +++ /dev/null @@ -1,74 +0,0 @@ -package io.trygvis.engine; - -import org.kie.api.runtime.process.ProcessInstance; -import org.kie.internal.runtime.StatefulKnowledgeSession; -import org.slf4j.Logger; -import org.springframework.context.annotation.AnnotationConfigApplicationContext; -import org.springframework.transaction.support.TransactionTemplate; - -import javax.persistence.EntityManagerFactory; - -import static org.slf4j.LoggerFactory.getLogger; - -public class CalamusJbpm { - private final Logger log = getLogger(getClass()); - - private final TransactionTemplate transactionTemplate; - - private final EntityManagerFactory emf; - - private final StatefulKnowledgeSession session; - - public static enum CalamusProcess { - DEPLOY("io.trygvis.bpm.Deploy"); - - private String name; - - CalamusProcess(String name) { - this.name = name; - } - } - - public CalamusJbpm() { - AnnotationConfigApplicationContext spring = new AnnotationConfigApplicationContext(CalamusDbConfig.class, CalamusJbpmConfig.class); - -// emf = Persistence.createEntityManagerFactory("org.jbpm.persistence.jpa"); -// Environment env = KnowledgeBaseFactory.newEnvironment(); -// env.set(EnvironmentName.ENTITY_MANAGER_FACTORY, emf); -// env.set(EnvironmentName.TRANSACTION_MANAGER, TransactionManagerServices.getTransactionManager()); - -// KieBase kieBase = new KieHelper() -// .addResource(ResourceFactory.newClassPathResource("Deploy.bpmn2")) -// .build(); - -// RuntimeEnvironment runtimeEnvironment = spring.getBean(RuntimeEnvironment.class); -// -// KieBase kieBase = runtimeEnvironment.getKieBase(); - - transactionTemplate = spring.getBean(TransactionTemplate.class); - emf = spring.getBean(EntityManagerFactory.class); - session = null; -// session = JPAKnowledgeService.newStatefulKnowledgeSession(kieBase, null, env); -// session.addEventListener(AuditLoggerFactory.newJPAInstance(env)); - -// session.getWorkItemManager().registerWorkItemHandler("Service Task", new ServiceTaskHandler()); -// session.getWorkItemManager().registerWorkItemHandler("Upgrade App", new UpgradeAppWorkItemHandler()); -// session.getWorkItemManager().registerWorkItemHandler("Restart App", new RestartAppWorkItemHandler()); - } - - public TransactionTemplate getTransactionTemplate() { - return transactionTemplate; - } - - public EntityManagerFactory getEntityManagerFactory() { - return emf; - } - - public StatefulKnowledgeSession getSession() { - return session; - } - - public void startProcess(CalamusProcess process) { - ProcessInstance processInstance = session.startProcess(process.name); - } -} diff --git a/calamus-engine/src/main/java/io/trygvis/engine/CalamusJbpmConfig.java b/calamus-engine/src/main/java/io/trygvis/engine/CalamusJbpmConfig.java deleted file mode 100644 index 98ba550..0000000 --- a/calamus-engine/src/main/java/io/trygvis/engine/CalamusJbpmConfig.java +++ /dev/null @@ -1,63 +0,0 @@ -package io.trygvis.engine; - -import org.jbpm.process.audit.JPAAuditLogService; -import org.kie.api.io.Resource; -import org.kie.api.io.ResourceType; -import org.kie.api.runtime.manager.RuntimeEnvironment; -import org.kie.internal.io.ResourceFactory; -import org.kie.spring.factorybeans.RuntimeEnvironmentFactoryBean; -import org.kie.spring.factorybeans.RuntimeManagerFactoryBean; -import org.slf4j.Logger; -import org.springframework.context.annotation.Bean; -import org.springframework.context.annotation.Configuration; -import org.springframework.context.annotation.Lazy; -import org.springframework.transaction.PlatformTransactionManager; - -import javax.persistence.EntityManagerFactory; -import javax.sql.DataSource; -import java.util.HashMap; -import java.util.Map; - -import static org.slf4j.LoggerFactory.getLogger; - -/** - * http://planet.jboss.org/post/jbpm_6_with_spring - */ -@Configuration -public class CalamusJbpmConfig { - private final Logger log = getLogger(getClass()); - - @Bean - @Lazy - public RuntimeEnvironmentFactoryBean runtimeEnvironment(DataSource dataSource, CalamusDbConfig.DbMigrations dbMigrations, EntityManagerFactory entityManagerFactory, PlatformTransactionManager platformTransactionManager) { - System.out.println("CalamusConfig.runtimeEnvironmentFactoryBean"); - System.out.println("dataSource = " + dataSource); - System.out.println("dbMigrations = " + dbMigrations); - System.out.println("entityManagerFactory = " + entityManagerFactory); - System.out.println("platformTransactionManager = " + platformTransactionManager); - RuntimeEnvironmentFactoryBean x = new RuntimeEnvironmentFactoryBean(); - x.setType("DEFAULT"); - - Map<Resource, ResourceType> assets = new HashMap<>(); - assets.put(ResourceFactory.newClassPathResource("/Deploy.bpmn2"), ResourceType.BPMN2); - x.setAssets(assets); - - x.setEntityManagerFactory(entityManagerFactory); - x.setTransactionManager(platformTransactionManager); - - return x; - } - -// @Bean -// public RuntimeManagerFactoryBean runtimeManagerFactoryBean(RuntimeEnvironment runtimeEnvironment) { -// RuntimeManagerFactoryBean x = new RuntimeManagerFactoryBean(); -// x.setIdentifier("spring-rm"); -// x.setRuntimeEnvironment(runtimeEnvironment); -// return x; -// } - - @Bean - public JPAAuditLogService jpaAuditLogService(EntityManagerFactory entityManagerFactory) { - return new JPAAuditLogService(entityManagerFactory); - } -} diff --git a/calamus-engine/src/main/java/io/trygvis/engine/JenkinsBuildResultMessageListener.java b/calamus-engine/src/main/java/io/trygvis/engine/JenkinsBuildResultMessageListener.java deleted file mode 100644 index 08b5e5b..0000000 --- a/calamus-engine/src/main/java/io/trygvis/engine/JenkinsBuildResultMessageListener.java +++ /dev/null @@ -1,53 +0,0 @@ -package io.trygvis.engine; - -import org.kie.internal.runtime.StatefulKnowledgeSession; -import org.slf4j.Logger; - -import javax.jms.JMSException; -import javax.jms.Message; -import javax.jms.MessageListener; -import javax.jms.TextMessage; -import java.io.IOException; -import java.io.StringReader; -import java.util.Properties; - -import static java.lang.Integer.parseInt; -import static org.slf4j.LoggerFactory.getLogger; - -public class JenkinsBuildResultMessageListener implements MessageListener { - private final Logger log = getLogger(getClass()); - - private StatefulKnowledgeSession session; - - public JenkinsBuildResultMessageListener(StatefulKnowledgeSession session) { - this.session = session; - } - - @Override - public void onMessage(Message message) { - if (!(message instanceof TextMessage)) { - return; - } - - try { - TextMessage m = (TextMessage) message; - Properties p = new Properties(); - p.load(new StringReader(m.getText())); - - String jobName = p.getProperty("jobName"); - int buildNumber = parseInt(p.getProperty("buildNumber")); - String result = p.getProperty("result"); - - log.info("New build: jobName={}, buildNumber={}, result={}", jobName, buildNumber, result); - - /* - String type; - Object event; - long processInstanceId; - jbpm.signalEvent(type, event, processInstanceId); - */ - } catch (JMSException | IOException e) { - e.printStackTrace(); - } - } -} diff --git a/calamus-engine/src/main/java/io/trygvis/engine/Main.java b/calamus-engine/src/main/java/io/trygvis/engine/Main.java deleted file mode 100644 index c5916e0..0000000 --- a/calamus-engine/src/main/java/io/trygvis/engine/Main.java +++ /dev/null @@ -1,28 +0,0 @@ -package io.trygvis.engine; - -import org.kie.internal.runtime.StatefulKnowledgeSession; - -public class Main { - public static void main(String[] args) throws Exception { - - CalamusJbpm calamus = new CalamusJbpm(); - - String brokerUrl = "tcp://localhost:61616"; - - StatefulKnowledgeSession session = calamus.getSession(); - -// EntityManager entityManager = calamus.getEntityManagerFactory().createEntityManager(); -// EntityTransaction transaction = entityManager.getTransaction(); -// transaction.begin(); -// entityManager.createQuery("FROM Process"); -// transaction.commit(); - - try (MqClient buildResultClient = new MqClient(brokerUrl, "jenkins.build-result", new JenkinsBuildResultMessageListener(session)); - MqClient newDeployClient = new MqClient(brokerUrl, "nexus.new-artifact", new NexusNewArtifactMessageListener(calamus.getTransactionTemplate(), calamus.getEntityManagerFactory(), session))) { - - while (true) { - Thread.sleep(1000); - } - } - } -} diff --git a/calamus-engine/src/main/java/io/trygvis/engine/MqClient.java b/calamus-engine/src/main/java/io/trygvis/engine/MqClient.java deleted file mode 100644 index 91eec37..0000000 --- a/calamus-engine/src/main/java/io/trygvis/engine/MqClient.java +++ /dev/null @@ -1,50 +0,0 @@ -package io.trygvis.engine; - -import org.apache.activemq.ActiveMQConnectionFactory; -import org.kie.internal.runtime.StatefulKnowledgeSession; - -import javax.jms.Connection; -import javax.jms.Destination; -import javax.jms.JMSException; -import javax.jms.Message; -import javax.jms.MessageConsumer; -import javax.jms.MessageListener; -import javax.jms.Session; -import javax.jms.TextMessage; -import java.io.IOException; -import java.io.StringReader; -import java.util.Properties; - -import static java.lang.Integer.parseInt; -import static javax.jms.Session.AUTO_ACKNOWLEDGE; - -public class MqClient implements AutoCloseable { - - private Connection connection; - - public MqClient(String brokerUrl, String queueName, MessageListener messageListener) { - ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(brokerUrl); - - try { - connection = connectionFactory.createConnection(); - connection.start(); - - Session session = connection.createSession(false, AUTO_ACKNOWLEDGE); - - Destination destination = session.createQueue(queueName); - - MessageConsumer consumer = session.createConsumer(destination); - consumer.setMessageListener(messageListener); - } catch (JMSException e) { - e.printStackTrace(); - } - } - - @Override - public void close() throws Exception { - if (connection != null) { - connection.close(); - this.connection = null; - } - } -} diff --git a/calamus-engine/src/main/java/io/trygvis/engine/NexusNewArtifactMessageListener.java b/calamus-engine/src/main/java/io/trygvis/engine/NexusNewArtifactMessageListener.java deleted file mode 100644 index 0813c27..0000000 --- a/calamus-engine/src/main/java/io/trygvis/engine/NexusNewArtifactMessageListener.java +++ /dev/null @@ -1,106 +0,0 @@ -package io.trygvis.engine; - -import io.trygvis.engine.domain.Artifact; -import io.trygvis.engine.domain.Process; -import io.trygvis.engine.domain.ProcessTrigger; -import org.kie.internal.runtime.StatefulKnowledgeSession; -import org.slf4j.Logger; -import org.springframework.transaction.TransactionStatus; -import org.springframework.transaction.support.TransactionCallbackWithoutResult; -import org.springframework.transaction.support.TransactionTemplate; - -import javax.jms.JMSException; -import javax.jms.Message; -import javax.jms.MessageListener; -import javax.jms.TextMessage; -import javax.persistence.EntityManager; -import javax.persistence.EntityManagerFactory; -import javax.persistence.NoResultException; -import javax.persistence.TypedQuery; -import java.io.IOException; -import java.io.StringReader; -import java.util.Properties; - -import static org.slf4j.LoggerFactory.getLogger; - -public class NexusNewArtifactMessageListener implements MessageListener { - private final Logger log = getLogger(getClass()); - - private final TransactionTemplate transactionTemplate; - private final EntityManagerFactory entityManagerFactory; - private final StatefulKnowledgeSession session; - - public NexusNewArtifactMessageListener(TransactionTemplate transactionTemplate, EntityManagerFactory entityManagerFactory, StatefulKnowledgeSession session) { - this.transactionTemplate = transactionTemplate; - this.entityManagerFactory = entityManagerFactory; - this.session = session; - } - - @Override - public void onMessage(Message message) { - if (!(message instanceof TextMessage)) { - return; - } - - try { - TextMessage m = (TextMessage) message; - Properties p = new Properties(); - p.load(new StringReader(m.getText())); - - String repository = p.getProperty("repository"); - String groupId = p.getProperty("groupId"); - String artifactId = p.getProperty("artifactId"); - String version = p.getProperty("version"); - String classifier = p.getProperty("classifier"); - String extension = p.getProperty("extension"); - - log.info("Artifact event: groupId={}, artifactId={}, version={}, classifier={}, extension={}", groupId, artifactId, version, classifier, extension); - - transactionTemplate.execute(new TransactionCallbackWithoutResult() { - @Override - protected void doInTransactionWithoutResult(TransactionStatus status) { - processMessage(groupId, artifactId, version, classifier, extension); - } - }); - } catch (JMSException | IOException e) { - e.printStackTrace(); - } - } - - private void processMessage(String groupId, String artifactId, String version, String classifier, String extension) { - // Check for any processes that will be started because of this - EntityManager entityManager = entityManagerFactory.createEntityManager(); - - TypedQuery<Artifact> query = entityManager.createQuery("FROM Artifact WHERE groupId=:groupId AND artifactId=:artifactId AND version=:version AND extension=:extension", Artifact.class); - query.setParameter("groupId", groupId); - query.setParameter("artifactId", artifactId); - query.setParameter("version", version); - query.setParameter("extension", extension); - Artifact artifact; - try { - artifact = query.getSingleResult(); - log.info("Existing artifact: {}", artifact); - } catch (NoResultException e) { - artifact = new Artifact(groupId, artifactId, version, classifier, extension); - log.info("New artifact: {}", artifact); - entityManager.persist(artifact); - } - - for (Process process : entityManager.createQuery("FROM Process", Process.class).getResultList()) { - System.out.println("process.name = " + process.getName()); - - for (ProcessTrigger trigger : process.getProcessTriggers()) { - System.out.println("trigger.getMvel() = " + trigger.getMvel()); - boolean match = trigger.matches(artifact); - System.out.println("match = " + match); - } - } - - /* - String type; - Object event; - long processInstanceId; - jbpm.signalEvent(type, event, processInstanceId); - */ - } -} diff --git a/calamus-engine/src/main/java/io/trygvis/engine/RestartAppWorkItemHandler.java b/calamus-engine/src/main/java/io/trygvis/engine/RestartAppWorkItemHandler.java deleted file mode 100644 index 98733c7..0000000 --- a/calamus-engine/src/main/java/io/trygvis/engine/RestartAppWorkItemHandler.java +++ /dev/null @@ -1,24 +0,0 @@ -package io.trygvis.engine; - -import org.kie.api.runtime.process.WorkItem; -import org.kie.api.runtime.process.WorkItemHandler; -import org.kie.api.runtime.process.WorkItemManager; - -import java.util.HashMap; -import java.util.Map; - -public class RestartAppWorkItemHandler implements WorkItemHandler { - - @Override - public void executeWorkItem(WorkItem workItem, WorkItemManager manager) { - System.out.println("RestartAppWorkItemHandler.executeWorkItem"); - - Map<String, Object> results = new HashMap<>(); - manager.completeWorkItem(workItem.getId(), results); - } - - @Override - public void abortWorkItem(WorkItem workItem, WorkItemManager manager) { - System.out.println("RestartAppWorkItemHandler.abortWorkItem"); - } -} diff --git a/calamus-engine/src/main/java/io/trygvis/engine/UpgradeAppWorkItemHandler.java b/calamus-engine/src/main/java/io/trygvis/engine/UpgradeAppWorkItemHandler.java deleted file mode 100644 index 6202d6b..0000000 --- a/calamus-engine/src/main/java/io/trygvis/engine/UpgradeAppWorkItemHandler.java +++ /dev/null @@ -1,24 +0,0 @@ -package io.trygvis.engine; - -import org.kie.api.runtime.process.WorkItem; -import org.kie.api.runtime.process.WorkItemHandler; -import org.kie.api.runtime.process.WorkItemManager; - -import java.util.HashMap; -import java.util.Map; - -public class UpgradeAppWorkItemHandler implements WorkItemHandler { - - @Override - public void executeWorkItem(WorkItem workItem, WorkItemManager manager) { - System.out.println("UpgradeAppWorkItemHandler.executeWorkItem"); - - Map<String, Object> results = new HashMap<>(); - manager.completeWorkItem(workItem.getId(), results); - } - - @Override - public void abortWorkItem(WorkItem workItem, WorkItemManager manager) { - System.out.println("UpgradeAppWorkItemHandler.abortWorkItem"); - } -} diff --git a/calamus-engine/src/main/java/io/trygvis/engine/domain/AbstractEntity.java b/calamus-engine/src/main/java/io/trygvis/engine/domain/AbstractEntity.java deleted file mode 100644 index e8b1faa..0000000 --- a/calamus-engine/src/main/java/io/trygvis/engine/domain/AbstractEntity.java +++ /dev/null @@ -1,19 +0,0 @@ -package io.trygvis.engine.domain; - -import javax.persistence.GeneratedValue; -import javax.persistence.GenerationType; -import javax.persistence.Id; -import javax.persistence.MappedSuperclass; -import javax.persistence.SequenceGenerator; - -@MappedSuperclass -public abstract class AbstractEntity { - @Id - @GeneratedValue(strategy = GenerationType.AUTO, generator = "calamusSeq") - @SequenceGenerator(name = "calamusSeq", sequenceName = "calamus_seq") - private Long id; - - public Long getId() { - return id; - } -} diff --git a/calamus-engine/src/main/java/io/trygvis/engine/domain/Artifact.java b/calamus-engine/src/main/java/io/trygvis/engine/domain/Artifact.java deleted file mode 100644 index 8e01d92..0000000 --- a/calamus-engine/src/main/java/io/trygvis/engine/domain/Artifact.java +++ /dev/null @@ -1,89 +0,0 @@ -package io.trygvis.engine.domain; - -import javax.persistence.Column; -import javax.persistence.Entity; -import java.util.Optional; - -import static io.trygvis.engine.domain.Artifact.Level.UNTESTED; -import static java.util.Optional.ofNullable; - -@Entity -public class Artifact extends AbstractEntity { - @Column(length = 100, nullable = false) - private String groupId; - - @Column(length = 100, nullable = false) - private String artifactId; - - @Column(length = 100, nullable = false) - private String version; - - @Column(length = 100) - private String classifier; - - @Column(length = 100, nullable = false) - private String extension; - - @Column(nullable = false) - private Level level; - - @Column(length = 40) - private String gitHash; - - public enum Level { - UNTESTED - } - - protected Artifact() { - } - - public Artifact(String groupId, String artifactId, String version, String classifier, String extension) { - this.groupId = groupId; - this.artifactId = artifactId; - this.version = version; - this.classifier = classifier; - this.extension = extension; - this.level = UNTESTED; - } - - public String getGroupId() { - return groupId; - } - - public String getArtifactId() { - return artifactId; - } - - public String getVersion() { - return version; - } - - public Optional<String> getClassifier() { - return ofNullable(classifier); - } - - public String getExtension() { - return extension; - } - - public Level getLevel() { - return level; - } - - public String getGitHash() { - return gitHash; - } - - @Override - public String toString() { - return "Artifact{" + - "groupId='" + groupId + '\'' + - ", artifactId='" + artifactId + '\'' + - ", version='" + version + '\'' + - ", classifier='" + classifier + '\'' + - ", extension='" + extension + '\'' + - ", level='" + level + '\'' + - ", gitHash='" + gitHash + '\'' + - "} " + super.toString(); - } -} diff --git a/calamus-engine/src/main/java/io/trygvis/engine/domain/Process.java b/calamus-engine/src/main/java/io/trygvis/engine/domain/Process.java deleted file mode 100644 index ccd96cf..0000000 --- a/calamus-engine/src/main/java/io/trygvis/engine/domain/Process.java +++ /dev/null @@ -1,25 +0,0 @@ -package io.trygvis.engine.domain; - -import javax.persistence.Column; -import javax.persistence.Entity; -import javax.persistence.OneToMany; -import java.util.ArrayList; -import java.util.List; - -@Entity -public class Process extends AbstractEntity { - - @Column(length = 100, nullable = false) - private String name; - - @OneToMany(mappedBy = "process") - private List<ProcessTrigger> processTriggers = new ArrayList<>(); - - public String getName() { - return name; - } - - public List<ProcessTrigger> getProcessTriggers() { - return processTriggers; - } -} diff --git a/calamus-engine/src/main/java/io/trygvis/engine/domain/ProcessTrigger.java b/calamus-engine/src/main/java/io/trygvis/engine/domain/ProcessTrigger.java deleted file mode 100644 index 00b1603..0000000 --- a/calamus-engine/src/main/java/io/trygvis/engine/domain/ProcessTrigger.java +++ /dev/null @@ -1,47 +0,0 @@ -package io.trygvis.engine.domain; - -import org.mvel2.MVEL; -import org.mvel2.ParserContext; - -import javax.persistence.Column; -import javax.persistence.Entity; -import javax.persistence.ManyToOne; -import java.io.Serializable; -import java.util.HashMap; -import java.util.Map; - -@Entity -public class ProcessTrigger extends AbstractEntity { - - @ManyToOne - private Process process; - - @Column(length = 1000) - private String mvel; - - transient Serializable expression; - - public String getMvel() { - return mvel; - } - - // ----------------------------------------------------------------------- - // - // ----------------------------------------------------------------------- - - private Serializable getExpression() { - if (expression != null) { - return expression; - } - ParserContext ctx = new ParserContext(); - ctx.setStrongTyping(true); - ctx.addInput("artifact", Artifact.class); - return expression = MVEL.compileExpression(mvel, ctx); - } - - public boolean matches(Artifact artifact) { - Map<String, Object> vars = new HashMap<>(); - vars.put("artifact", artifact); - return MVEL.executeExpression(getExpression(), vars, Boolean.class); - } -} diff --git a/calamus-engine/src/main/java/io/trygvis/engine/service/AppInstance.java b/calamus-engine/src/main/java/io/trygvis/engine/service/AppInstance.java deleted file mode 100644 index 0badb8c..0000000 --- a/calamus-engine/src/main/java/io/trygvis/engine/service/AppInstance.java +++ /dev/null @@ -1,7 +0,0 @@ -package io.trygvis.engine.service; - -public class AppInstance { - private String name; - private String host; - private String path; -} diff --git a/calamus-engine/src/main/java/io/trygvis/engine/service/AppService.java b/calamus-engine/src/main/java/io/trygvis/engine/service/AppService.java deleted file mode 100644 index 3ccde2b..0000000 --- a/calamus-engine/src/main/java/io/trygvis/engine/service/AppService.java +++ /dev/null @@ -1,15 +0,0 @@ -package io.trygvis.engine.service; - -public class AppService { - public void installApp(AppInstance instance) { - System.out.println("AppService.installApp"); - } - - public void restartApp(AppInstance instance) { - System.out.println("AppService.restartApp"); - } - - public void waitForUp(AppInstance instance) { - System.out.println("AppService.waitForAppUp"); - } -} |