chore: type field on data flow (#63)

Author: ronjaquensel

src/main/java/org/eclipse/dataplane/Dataplane.java

@@ -132,6 +132,7 @@ public Result<DataFlowStatusMessage> prepare(String controlplaneId, DataFlowPrep
                 .counterPartyId(message.counterPartyId())
                 .dataspaceContext(message.dataspaceContext())
                 .controlplaneId(controlplaneId)
+                .type(DataFlow.Type.CONSUMER)
                 .build();
 
         return checkControlPlane(controlplaneId)
@@ -166,6 +167,7 @@ public Result<DataFlowStatusMessage> start(String controlplaneId, DataFlowStartM
                 .counterPartyId(message.counterPartyId())
                 .dataspaceContext(message.dataspaceContext())
                 .controlplaneId(controlplaneId)
+                .type(DataFlow.Type.PROVIDER)
                 .build();
 
         return checkControlPlane(controlplaneId)

src/main/java/org/eclipse/dataplane/domain/dataflow/DataFlow.java

@@ -39,6 +39,7 @@ public class DataFlow {
     private Map<String, Object> metadata;
     private DataAddress dataAddress;
     private String controlplaneId;
+    private Type type;
 
     public static DataFlow.Builder newInstance() {
         return new Builder();
@@ -162,6 +163,14 @@ public String getControlplaneId() {
         return controlplaneId;
     }
 
+    public Type getType() {
+        return type;
+    }
+
+    public enum Type {
+        PROVIDER, CONSUMER
+    }
+
     public static class Builder {
         private final DataFlow dataFlow = new DataFlow();
 
@@ -243,6 +252,11 @@ public Builder controlplaneId(String controlplaneId) {
             dataFlow.controlplaneId = controlplaneId;
             return this;
         }
+
+        public Builder type(Type type) {
+            dataFlow.type = type;
+            return this;
+        }
     }
 
     public enum State {