This commit is contained in:
guillaume 2019-01-25 18:47:46 +01:00
commit 8c7fde6567
50 changed files with 2066 additions and 581 deletions

View file

@ -3,6 +3,7 @@ package org.chtijbug.drools.proxy.camel;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.model.rest.RestBindingMode;
import org.apache.camel.model.rest.RestParamType;
import org.chtijbug.drools.proxy.persistence.model.RuntimePersist;
import org.chtijbug.drools.proxy.service.KieServiceCommon;
import org.kie.server.api.model.KieContainerResource;
import org.kie.server.api.model.KieContainerResourceList;
@ -69,6 +70,7 @@ public class AdminRouter extends RouteBuilder {
.param().name("body").type(body).description("KIE Container resource to be deployed as KieContainerResourcee").endParam()
.responseMessage().code(200).message("Container successfully created").endResponseMessage()
.to("bean:kieService?method=createContainer(${header.id},${body})");
rest("/server/containers").description(" Disposes (undeploys) container with given id")
.consumes("application/json")
.produces("application/json")
@ -89,7 +91,6 @@ public class AdminRouter extends RouteBuilder {
.param().name("body").type(body).description("KIE Container resource to be deployed as KieContainerResourcee").endParam()
.responseMessage().code(200).message("Container successfully created").endResponseMessage()
.to("bean:kieService?method=createContainerWithRestBusinessService(${header.id},${body},${header.className},${header.processID})");
}
}
/**

View file

@ -18,7 +18,7 @@ package org.chtijbug.drools.proxy.service;
import com.fasterxml.jackson.databind.ObjectMapper;
import org.apache.camel.CamelContext;
import org.chtijbug.drools.proxy.camel.DroolsRouter;
import org.chtijbug.drools.proxy.persistence.ContainerRepository;
import org.chtijbug.drools.proxy.persistence.repository.ContainerRepository;
import org.chtijbug.drools.proxy.persistence.model.ContainerPojoPersist;
import org.chtijbug.kieserver.services.drools.DroolsChtijbugKieServerExtension;
import org.chtijbug.kieserver.services.drools.DroolsChtijbugRulesExecutionService;

View file

@ -5,7 +5,6 @@ import org.apache.commons.io.FileUtils;
import org.chtijbug.drools.kieserver.extension.KieServerAddOnElement;
import org.chtijbug.drools.kieserver.extension.KieServerLoggingDefinition;
import org.chtijbug.drools.logging.SessionExecution;
import org.chtijbug.drools.proxy.persistence.ContainerRepository;
import org.chtijbug.kieserver.services.drools.ChtijbugObjectRequest;
import org.chtijbug.kieserver.services.drools.DroolsChtijbugKieServerExtension;
import org.chtijbug.kieserver.services.drools.DroolsChtijbugRulesExecutionService;
@ -18,7 +17,6 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Service;
import javax.inject.Inject;
import java.io.File;
import java.io.IOException;
import java.lang.reflect.Method;

View file

@ -0,0 +1,164 @@
package org.chtijbug.drools.proxy.persistence.model;
import org.bson.types.ObjectId;
import org.springframework.data.annotation.Id;
import org.springframework.data.mongodb.core.index.Indexed;
import org.springframework.data.mongodb.core.mapping.Document;
import java.io.Serializable;
import java.util.List;
@Document
public class ProjectPersist implements Serializable {
public static final String ADEFINIR="A définir";
public static final String DEFINI="Défini";
public static final String Deployable="Déployable";
@Id
private String id=new ObjectId().toString();
@Indexed
private String deploymentName;
@Indexed
private String projectName;
private String spaceName;
private String oldName;
private String mainClass;
private String groupID;
private String artifactID;
private String processID;
private String projectVersion;
private String containerID;
private String serverName;
private String status;
private List<String> classNameList;
public ProjectPersist(){}
public String getId() {
return id;
}
public void setId(String id) {
this.id = id;
}
public String getDeploymentName() {
return deploymentName;
}
public void setDeploymentName(String deploymentName) {
this.deploymentName = deploymentName;
}
public String getProjectName() {
return projectName;
}
public void setProjectName(String projectName) {
this.projectName = projectName;
}
public String getMainClass() {
return mainClass;
}
public void setMainClass(String mainClass) {
this.mainClass = mainClass;
}
public String getGroupID() {
return groupID;
}
public void setGroupID(String groupID) {
this.groupID = groupID;
}
public String getArtifactID() {
return artifactID;
}
public void setArtifactID(String artifactID) {
this.artifactID = artifactID;
}
public String getProcessID() {
return processID;
}
public String getSpaceName() {
return spaceName;
}
public void setSpaceName(String spaceName) {
this.spaceName = spaceName;
}
public String getOldName() {
return oldName;
}
public String getContainerID() {
return containerID;
}
public void setContainerID(String containerID) {
this.containerID = containerID;
}
public void setOldName(String oldName) {
this.oldName = oldName;
}
public void setProcessID(String processID) {
this.processID = processID;
}
public String getProjectVersion() {
return projectVersion;
}
public void setProjectVersion(String projectVersion) {
this.projectVersion = projectVersion;
}
public String getServerName() {
return serverName;
}
public void setServerName(String serverName) {
this.serverName = serverName;
}
public String getStatus() {
return status;
}
public void setStatus(String status) {
this.status = status;
}
public List<String> getClassNameList() {
return classNameList;
}
public void setClassNameList(List<String> classNameList) {
this.classNameList = classNameList;
}
}

View file

@ -0,0 +1,58 @@
package org.chtijbug.drools.proxy.persistence.model;
import org.bson.types.ObjectId;
import org.springframework.data.annotation.Id;
import org.springframework.data.mongodb.core.index.Indexed;
import org.springframework.data.mongodb.core.mapping.Document;
@Document
public class RuntimePersist {
@Id
private String id=new ObjectId().toString();
@Indexed
private String serverName;
private String version;
private String hostname;
public RuntimePersist(String serverName, String version, String hostname) {
this.serverName = serverName;
this.version = version;
this.hostname = hostname;
}
public String getId() {
return id;
}
public void setId(String id) {
this.id = id;
}
public String getServerName() {
return serverName;
}
public void setServerName(String serverName) {
this.serverName = serverName;
}
public String getVersion() {
return version;
}
public void setVersion(String version) {
this.version = version;
}
public String getHostname() {
return hostname;
}
public void setHostname(String hostname) {
this.hostname = hostname;
}
}

View file

@ -1,4 +1,4 @@
package org.chtijbug.drools.proxy.persistence;
package org.chtijbug.drools.proxy.persistence.repository;
import org.chtijbug.drools.proxy.persistence.model.ContainerPojoPersist;
import org.springframework.data.mongodb.repository.MongoRepository;

View file

@ -0,0 +1,18 @@
package org.chtijbug.drools.proxy.persistence.repository;
import org.chtijbug.drools.proxy.persistence.model.ProjectPersist;
import org.chtijbug.drools.proxy.persistence.model.RuntimePersist;
import org.springframework.data.mongodb.repository.MongoRepository;
import org.springframework.stereotype.Repository;
import java.util.List;
@Repository
public interface ProjectRepository extends MongoRepository<ProjectPersist, String> {
public ProjectPersist findByProjectName(String projectName);
public ProjectPersist findByDeploymentName(String deploymentName);
public List<ProjectPersist> findByServerName(String serverName);
public List<ProjectPersist> findByServerNameAndDeploymentName(String serverName,String deploymentName);
}

View file

@ -0,0 +1,13 @@
package org.chtijbug.drools.proxy.persistence.repository;
import org.chtijbug.drools.proxy.persistence.model.RuntimePersist;
import org.springframework.data.mongodb.repository.MongoRepository;
import org.springframework.stereotype.Repository;
import java.util.List;
@Repository
public interface RuntimeRepository extends MongoRepository<RuntimePersist, String> {
public List<RuntimePersist> findByServerName(String serverName);
}