#4 add discovered aggregates to 'exposed aggregates' list in CML (#5)

Examples/LakesideMutual/build.gradle

@@ -10,6 +10,9 @@ sourceCompatibility = 1.8
 repositories {
     mavenCentral()
     mavenLocal()
+    maven {
+        url 'https://oss.sonatype.org/content/repositories/snapshots'
+    }
 }
 
 dependencies {

Examples/LakesideMutual/gradle.properties

@@ -1,3 +1,3 @@
 # dependency versions
-discoveryLibVersion=1.0.0
+discoveryLibVersion=1.1.0-SNAPSHOT
 lakesideMutualVersion=0.0.1-SNAPSHOT

gradle.properties

@@ -4,7 +4,7 @@ ossReleaseStagingRepository=https://oss.sonatype.org/service/local/staging/deplo
 
 # dependency versions
 jUnitVersion=5.5.2
-cmlVersion=5.2.0
+cmlVersion=5.3.2
 reflectionsVersion=0.9.11
 springBootVersion=2.2.0.RELEASE
 springWebVersion=5.2.0.RELEASE

src/main/java/org/contextmapper/discovery/cml/ContextMapToCMLConverter.java

@@ -21,6 +21,7 @@
 
 import java.util.HashMap;
 import java.util.Map;
+import java.util.Optional;
 
 /**
  * Converts a {@link org.contextmapper.discovery.model.ContextMap} to the CML {@link org.contextmapper.dsl.contextMappingDSL.ContextMap}
@@ -90,6 +91,12 @@ private UpstreamDownstreamRelationship convert(Relationship relationship) {
         UpstreamDownstreamRelationship upstreamDownstreamRelationship = ContextMappingDSLFactory.eINSTANCE.createUpstreamDownstreamRelationship();
         upstreamDownstreamRelationship.setUpstream(this.boundedContextMap.get(relationship.getUpstream().getName()));
         upstreamDownstreamRelationship.setDownstream(this.boundedContextMap.get(relationship.getDownstream().getName()));
+        for (org.contextmapper.discovery.model.Aggregate aggregate : relationship.getExposedAggregates()) {
+            Optional<Aggregate> cmlAggregate = upstreamDownstreamRelationship.getUpstream().getAggregates().stream().filter(a -> a.getName().equals(aggregate.getName())).findFirst();
+            if (cmlAggregate.isPresent())
+                upstreamDownstreamRelationship.getUpstreamExposedAggregates().add(cmlAggregate.get());
+        }
+        upstreamDownstreamRelationship.setExposedAggregatesComment("// " + relationship.getExposedAggregatesComment());
         return upstreamDownstreamRelationship;
     }
 

src/main/java/org/contextmapper/discovery/model/Attribute.java

@@ -90,15 +90,6 @@ public String getCollectionType() {
         return collectionType;
     }
 
-    /**
-     * Returns whether the reference attribute is a collection of references or not.
-     *
-     * @return true, if the reference attribute is a collection of references. false otherwise.
-     */
-    public boolean isCollection() {
-        return collectionType == null || "".equals(collectionType);
-    }
-
     @Override
     public boolean equals(Object object) {
         if (!(object instanceof Attribute))

src/main/java/org/contextmapper/discovery/model/BoundedContext.java

@@ -84,6 +84,15 @@ public void addAggregates(Set<Aggregate> aggregates) {
         this.aggregates.addAll(aggregates);
     }
 
+    /**
+     * Adds an Aggregate to the Bounded Context.
+     *
+     * @param aggregate the Aggregate to be added to the Bounded Context
+     */
+    public void addAggregate(Aggregate aggregate) {
+        this.aggregates.add(aggregate);
+    }
+
     /**
      * Gets the Aggregates of the Bounded Context.
      *

src/main/java/org/contextmapper/discovery/model/Reference.java

@@ -89,15 +89,6 @@ public String getCollectionType() {
         return collectionType;
     }
 
-    /**
-     * Returns whether the reference attribute is a collection of references or not.
-     *
-     * @return true, if the reference attribute is a collection of references. false otherwise.
-     */
-    public boolean isCollection() {
-        return collectionType == null || "".equals(collectionType);
-    }
-
     @Override
     public boolean equals(Object object) {
         if (!(object instanceof Reference))