Skip to content

Commit

Permalink
wip
Browse files Browse the repository at this point in the history
  • Loading branch information
jonathanlukas committed May 8, 2023
1 parent 41c3a8e commit 7e72028
Show file tree
Hide file tree
Showing 29 changed files with 143 additions and 127 deletions.
26 changes: 9 additions & 17 deletions pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -72,6 +72,13 @@
<type>pom</type>
<scope>import</scope>
</dependency>
<dependency>
<groupId>io.camunda</groupId>
<artifactId>zeebe-bom</artifactId>
<version>${version.zeebe}</version>
<type>pom</type>
<scope>import</scope>
</dependency>
<dependency>
<groupId>info.picocli</groupId>
<artifactId>picocli</artifactId>
Expand All @@ -92,26 +99,11 @@
<artifactId>spring-boot-starter-camunda</artifactId>
<version>${version.spring-boot-starter-camunda}</version>
</dependency>
<dependency>
<groupId>io.camunda</groupId>
<artifactId>zeebe-bpmn-model</artifactId>
<version>${version.zeebe}</version>
</dependency>
<dependency>
<groupId>io.camunda</groupId>
<artifactId>zeebe-protocol</artifactId>
<version>${version.zeebe}</version>
</dependency>
<dependency>
<groupId>io.camunda</groupId>
<artifactId>camunda-operate-client-java</artifactId>
<version>${version.operate-client}</version>
</dependency>
<dependency>
<groupId>io.camunda</groupId>
<artifactId>zeebe-client-java</artifactId>
<version>${version.zeebe}</version>
</dependency>
<dependency>
<groupId>org.scala-lang</groupId>
<artifactId>scala-library</artifactId>
Expand Down Expand Up @@ -154,8 +146,8 @@
<scope>test</scope>
</dependency>
<dependency>
<groupId>io.camunda</groupId>
<artifactId>spring-zeebe-test</artifactId>
<groupId>io.camunda.spring</groupId>
<artifactId>spring-boot-starter-camunda-test</artifactId>
<version>${version.spring-zeebe-starter}</version>
<scope>test</scope>
</dependency>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@
<parent>
<groupId>org.camunda.community.migration</groupId>
<artifactId>process-instance-migration-parent</artifactId>
<version>0.5.1-SNAPSHOT</version>
<version>0.6.2-SNAPSHOT</version>
</parent>
<artifactId>process-instance-migration-camunda-7-embedded-exporter</artifactId>

Expand Down
Original file line number Diff line number Diff line change
@@ -1,7 +1,9 @@
package org.camunda.community.migration.processInstance.exporter;

import org.camunda.bpm.engine.delegate.DelegateExecution;import org.camunda.bpm.engine.delegate.JavaDelegate;
import org.camunda.bpm.engine.delegate.DelegateExecution;
import org.camunda.bpm.engine.delegate.JavaDelegate;

public class SampleDelegate implements JavaDelegate {@Override public void execute(DelegateExecution execution)throws Exception {

}}
public class SampleDelegate implements JavaDelegate {
@Override
public void execute(DelegateExecution execution) throws Exception {}
}
2 changes: 1 addition & 1 deletion process-instance-migration/camunda-7-rest-exporter/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@
<parent>
<artifactId>process-instance-migration-parent</artifactId>
<groupId>org.camunda.community.migration</groupId>
<version>0.5.1-SNAPSHOT</version>
<version>0.6.2-SNAPSHOT</version>
</parent>
<dependencies>
<dependency>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -37,7 +37,8 @@ void shouldFetchUserTaskProcessData() {
new ProcessInstanceApi(apiClient),
new VariableInstanceApi(apiClient),
new JobApi(apiClient),
new JobDefinitionApi(apiClient),objectMapper);
new JobDefinitionApi(apiClient),
objectMapper);
Camunda7Exporter exporter = new Camunda7Exporter(camunda7RestService);
BpmnModelInstance testProcess =
Bpmn.createExecutableProcess("testProcess")
Expand Down
2 changes: 1 addition & 1 deletion process-instance-migration/camunda-8-importer/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@
<parent>
<artifactId>process-instance-migration-parent</artifactId>
<groupId>org.camunda.community.migration</groupId>
<version>0.5.1-SNAPSHOT</version>
<version>0.6.2-SNAPSHOT</version>
</parent>
<dependencies>
<dependency>
Expand Down
Original file line number Diff line number Diff line change
@@ -1,8 +1,6 @@
package org.camunda.community.migration.processInstance.importer.visitor.typed;

import org.camunda.community.migration.processInstance.api.model.data.chunk.ActivityNodeData;
import org.camunda.community.migration.processInstance.importer.visitor.typed.TypedActivityNodeDataVisitor;
import org.camunda.community.migration.processInstance.importer.visitor.typed.TypedActivityNodeDataVisitorContext;

public abstract class AbstractActivityNodeDataVisitor<T extends ActivityNodeData>
extends TypedActivityNodeDataVisitor<T> {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -4,8 +4,14 @@
import org.camunda.community.migration.processInstance.importer.visitor.typed.AbstractActivityNodeDataVisitor;
import org.camunda.community.migration.processInstance.importer.visitor.typed.TypedActivityNodeDataVisitorContext;

public class ManualTaskDataVisitor extends AbstractActivityNodeDataVisitor <ManualTaskData>{@Override protected void doHandle(TypedActivityNodeDataVisitorContext<ManualTaskData> context) {
// nothing to do
}@Override protected Class<ManualTaskData> getType() {
return ManualTaskData.class;
}}
public class ManualTaskDataVisitor extends AbstractActivityNodeDataVisitor<ManualTaskData> {
@Override
protected void doHandle(TypedActivityNodeDataVisitorContext<ManualTaskData> context) {
// nothing to do
}

@Override
protected Class<ManualTaskData> getType() {
return ManualTaskData.class;
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -6,8 +6,13 @@

public class ScriptTaskDataVisitor extends AbstractActivityNodeDataVisitor<ScriptTaskData> {

@Override protected void doHandle(TypedActivityNodeDataVisitorContext<ScriptTaskData> context) {
// nothing to do
}@Override protected Class<ScriptTaskData> getType() {
return ScriptTaskData.class;
}}
@Override
protected void doHandle(TypedActivityNodeDataVisitorContext<ScriptTaskData> context) {
// nothing to do
}

@Override
protected Class<ScriptTaskData> getType() {
return ScriptTaskData.class;
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -4,8 +4,14 @@
import org.camunda.community.migration.processInstance.importer.visitor.typed.AbstractActivityNodeDataVisitor;
import org.camunda.community.migration.processInstance.importer.visitor.typed.TypedActivityNodeDataVisitorContext;

public class SendTaskDataVisitor extends AbstractActivityNodeDataVisitor <SendTaskData>{@Override protected void doHandle(TypedActivityNodeDataVisitorContext<SendTaskData> context) {
// nothing to do
}@Override protected Class<SendTaskData> getType() {
return SendTaskData.class;
}}
public class SendTaskDataVisitor extends AbstractActivityNodeDataVisitor<SendTaskData> {
@Override
protected void doHandle(TypedActivityNodeDataVisitorContext<SendTaskData> context) {
// nothing to do
}

@Override
protected Class<SendTaskData> getType() {
return SendTaskData.class;
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -4,8 +4,14 @@
import org.camunda.community.migration.processInstance.importer.visitor.typed.AbstractActivityNodeDataVisitor;
import org.camunda.community.migration.processInstance.importer.visitor.typed.TypedActivityNodeDataVisitorContext;

public class ServiceTaskDataVisitor extends AbstractActivityNodeDataVisitor <ServiceTaskData>{@Override protected void doHandle(TypedActivityNodeDataVisitorContext<ServiceTaskData> context) {
// nothing to do here
}@Override protected Class<ServiceTaskData> getType() {
return ServiceTaskData.class;
}}
public class ServiceTaskDataVisitor extends AbstractActivityNodeDataVisitor<ServiceTaskData> {
@Override
protected void doHandle(TypedActivityNodeDataVisitorContext<ServiceTaskData> context) {
// nothing to do here
}

@Override
protected Class<ServiceTaskData> getType() {
return ServiceTaskData.class;
}
}
Original file line number Diff line number Diff line change
@@ -1,12 +1,18 @@
package org.camunda.community.migration.processInstance.importer.visitor.typed.impl;

import org.camunda.community.migration.processInstance.api.model.data.TaskData;
import org.camunda.community.migration.processInstance.importer.visitor.typed.AbstractActivityNodeDataVisitor;import org.camunda.community.migration.processInstance.importer.visitor.typed.TypedActivityNodeDataVisitorContext;
import org.camunda.community.migration.processInstance.importer.visitor.typed.AbstractActivityNodeDataVisitor;
import org.camunda.community.migration.processInstance.importer.visitor.typed.TypedActivityNodeDataVisitorContext;

public class TaskDataVisitor extends AbstractActivityNodeDataVisitor<TaskData> {

@Override protected void doHandle(TypedActivityNodeDataVisitorContext<TaskData> context) {
// nothing to do
}@Override protected Class<TaskData> getType() {
return TaskData.class;
}}
@Override
protected void doHandle(TypedActivityNodeDataVisitorContext<TaskData> context) {
// nothing to do
}

@Override
protected Class<TaskData> getType() {
return TaskData.class;
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -4,8 +4,14 @@
import org.camunda.community.migration.processInstance.importer.visitor.typed.AbstractActivityNodeDataVisitor;
import org.camunda.community.migration.processInstance.importer.visitor.typed.TypedActivityNodeDataVisitorContext;

public class UserTaskDataVisitor extends AbstractActivityNodeDataVisitor <UserTaskData>{@Override protected void doHandle(TypedActivityNodeDataVisitorContext<UserTaskData> context) {
// nothing to do
}@Override protected Class<UserTaskData> getType() {
return UserTaskData.class;
}}
public class UserTaskDataVisitor extends AbstractActivityNodeDataVisitor<UserTaskData> {
@Override
protected void doHandle(TypedActivityNodeDataVisitorContext<UserTaskData> context) {
// nothing to do
}

@Override
protected Class<UserTaskData> getType() {
return UserTaskData.class;
}
}
2 changes: 1 addition & 1 deletion process-instance-migration/camunda7-base-exporter/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@
<parent>
<groupId>org.camunda.community.migration</groupId>
<artifactId>process-instance-migration-parent</artifactId>
<version>0.5.1-SNAPSHOT</version>
<version>0.6.2-SNAPSHOT</version>
</parent>

<artifactId>process-instance-migration-camunda-7-base-exporter</artifactId>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@
<parent>
<artifactId>process-instance-migration-parent</artifactId>
<groupId>org.camunda.community.migration</groupId>
<version>0.5.1-SNAPSHOT</version>
<version>0.6.2-SNAPSHOT</version>
</parent>
<dependencies>
<dependency>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -9,7 +9,8 @@
import com.fasterxml.jackson.databind.node.TextNode;
import org.camunda.community.migration.processInstance.api.model.data.BusinessRuleTaskData.BusinessRuleTaskDataBuilder;
import org.camunda.community.migration.processInstance.api.model.data.CallActivityData.CallActivityDataBuilder;
import org.camunda.community.migration.processInstance.api.model.data.ExclusiveGatewayData.ExclusiveGatewayDataBuilder;import org.camunda.community.migration.processInstance.api.model.data.ManualTaskData.ManualTaskDataBuilder;
import org.camunda.community.migration.processInstance.api.model.data.ExclusiveGatewayData.ExclusiveGatewayDataBuilder;
import org.camunda.community.migration.processInstance.api.model.data.ManualTaskData.ManualTaskDataBuilder;
import org.camunda.community.migration.processInstance.api.model.data.MessageIntermediateCatchEventData.MessageIntermediateCatchEventDataBuilder;
import org.camunda.community.migration.processInstance.api.model.data.MultiInstanceData.MultiInstanceDataBuilder;
import org.camunda.community.migration.processInstance.api.model.data.ParallelGatewayData.ParallelGatewayDataBuilder;
Expand All @@ -26,7 +27,8 @@
import org.camunda.community.migration.processInstance.api.model.data.UserTaskData.UserTaskDataBuilder;
import org.camunda.community.migration.processInstance.api.model.data.impl.builder.BusinessRuleTaskDataBuilderImpl;
import org.camunda.community.migration.processInstance.api.model.data.impl.builder.CallActivityBuilderImpl;
import org.camunda.community.migration.processInstance.api.model.data.impl.builder.ExclusiveGatewayDataBuilderImpl;import org.camunda.community.migration.processInstance.api.model.data.impl.builder.ManualTaskDataBuilderImpl;
import org.camunda.community.migration.processInstance.api.model.data.impl.builder.ExclusiveGatewayDataBuilderImpl;
import org.camunda.community.migration.processInstance.api.model.data.impl.builder.ManualTaskDataBuilderImpl;
import org.camunda.community.migration.processInstance.api.model.data.impl.builder.MessageIntermediateCatchEventDataBuilderImpl;
import org.camunda.community.migration.processInstance.api.model.data.impl.builder.MultiInstanceDataBuilderImpl;
import org.camunda.community.migration.processInstance.api.model.data.impl.builder.ParallelGatewayDataBuilderImpl;
Expand Down Expand Up @@ -107,11 +109,11 @@ static TransactionDataBuilder transactionData() {
return new TransactionDataBuilderImpl();
}

static ExclusiveGatewayDataBuilder exclusiveGatewayData(){
static ExclusiveGatewayDataBuilder exclusiveGatewayData() {
return new ExclusiveGatewayDataBuilderImpl();
}

static ParallelGatewayDataBuilder parallelGatewayData(){
static ParallelGatewayDataBuilder parallelGatewayData() {
return new ParallelGatewayDataBuilderImpl();
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,6 @@

public interface ParallelGatewayData extends ActivityNodeData {


interface ParallelGatewayDataBuilder
extends ActivityNodeDataBuilder<ParallelGatewayDataBuilder, ParallelGatewayData> {}
}
Original file line number Diff line number Diff line change
Expand Up @@ -3,5 +3,6 @@
import org.camunda.community.migration.processInstance.api.model.data.chunk.ActivityNodeData;

public interface StartEventData extends ActivityNodeData {
interface StartEventDataBuilder extends ActivityNodeDataBuilder<StartEventDataBuilder,StartEventData>{}
interface StartEventDataBuilder
extends ActivityNodeDataBuilder<StartEventDataBuilder, StartEventData> {}
}
Original file line number Diff line number Diff line change
@@ -1,6 +1,5 @@
package org.camunda.community.migration.processInstance.api.model.data.chunk;

import java.util.List;
import java.util.Map;

public interface ActivityContainerData {
Expand Down
Original file line number Diff line number Diff line change
@@ -1,8 +1,6 @@
package org.camunda.community.migration.processInstance.api.model.data.impl;

import com.fasterxml.jackson.databind.JsonNode;

import java.util.List;
import java.util.Map;
import java.util.Objects;
import org.camunda.community.migration.processInstance.api.model.data.ProcessInstanceData;
Expand Down
Original file line number Diff line number Diff line change
@@ -1,6 +1,5 @@
package org.camunda.community.migration.processInstance.api.model.data.impl;

import java.util.List;
import java.util.Map;
import java.util.Objects;
import org.camunda.community.migration.processInstance.api.model.data.SubProcessData;
Expand Down
Original file line number Diff line number Diff line change
@@ -1,6 +1,5 @@
package org.camunda.community.migration.processInstance.api.model.data.impl;

import java.util.List;
import java.util.Map;
import java.util.Objects;
import org.camunda.community.migration.processInstance.api.model.data.TransactionData;
Expand Down Expand Up @@ -31,4 +30,5 @@ public boolean equals(Object o) {
@Override
public int hashCode() {
return Objects.hash(super.hashCode(), activities);
}}
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -33,7 +33,8 @@ public B withVariables(Map<String, JsonNode> variables) {
@Override
public B withExecuted(Boolean executed) {
data().setExecuted(executed);
return builder(); }
return builder();
}

protected abstract B builder();

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -5,8 +5,10 @@
import org.camunda.community.migration.processInstance.api.model.data.impl.ParallelGatewayDataImpl;
import org.camunda.community.migration.processInstance.api.model.data.impl.chunk.ActivityNodeDataImpl;

public class ParallelGatewayDataBuilderImpl extends ActivityNodeDataBuilderImpl<ParallelGatewayDataBuilder, ParallelGatewayData, ParallelGatewayDataImpl> implements
ParallelGatewayDataBuilder {
public class ParallelGatewayDataBuilderImpl
extends ActivityNodeDataBuilderImpl<
ParallelGatewayDataBuilder, ParallelGatewayData, ParallelGatewayDataImpl>
implements ParallelGatewayDataBuilder {
@Override
protected ParallelGatewayDataImpl createData() {
return new ParallelGatewayDataImpl();
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -3,8 +3,6 @@
import static org.camunda.community.migration.processInstance.api.model.data.impl.builder.BuilderUtil.*;

import com.fasterxml.jackson.databind.JsonNode;

import java.util.List;
import java.util.Map;
import org.camunda.community.migration.processInstance.api.model.FinalBuildStep.FinalBuildStepImpl;
import org.camunda.community.migration.processInstance.api.model.data.ProcessInstanceData;
Expand Down
Original file line number Diff line number Diff line change
@@ -1,6 +1,5 @@
package org.camunda.community.migration.processInstance.api.model.data.impl.builder;

import java.util.List;
import java.util.Map;
import org.camunda.community.migration.processInstance.api.model.data.SubProcessData;
import org.camunda.community.migration.processInstance.api.model.data.SubProcessData.SubProcessDataBuilder;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,6 @@

import static org.camunda.community.migration.processInstance.api.model.data.impl.builder.BuilderUtil.*;

import java.util.List;
import java.util.Map;
import org.camunda.community.migration.processInstance.api.model.data.TransactionData;
import org.camunda.community.migration.processInstance.api.model.data.TransactionData.TransactionDataBuilder;
Expand Down
Loading

0 comments on commit 7e72028

Please sign in to comment.