Fix MDSLModelCreator: No duplicate endpoints (#68)

Author: stefan-ka

org.contextmapper.dsl.tests/integ-test-files/mdsl/basic-mdsl-model-test.cml

@@ -8,6 +8,11 @@ ContextMap {
 
 	// this relationship must be ignored, because it has no exposedAggregates
 	CustomerManagementContext -> JustAnotherContext
+
+	// duplicate relationship should not change the result	
+	CustomerManagementContext -> ContractManagementContext {
+		exposedAggregates = Customers
+	}
 
 }
 

org.contextmapper.dsl/src/org/contextmapper/dsl/generator/mdsl/MDSLModelCreator.java

@@ -181,8 +181,12 @@ private Map<String, UpstreamAPIContext> collectUpstreamContexts() {
 				context.setUpstreamContext(relationship.getUpstream());
 				upstreamContextMap.put(upstreamAPIName, context);
 			}
-			context.getExposedAggregates().addAll(relationship.getUpstreamExposedAggregates());
-			context.getDownstreamContexts().add(relationship.getDownstream());
+			for (Aggregate exposedAggregate : relationship.getUpstreamExposedAggregates()) {
+				if (!context.getExposedAggregates().stream().map(agg -> agg.getName()).collect(Collectors.toList()).contains(exposedAggregate.getName()))
+					context.getExposedAggregates().add(exposedAggregate);
+			}
+			if (!context.getDownstreamContexts().stream().map(bc -> bc.getName()).collect(Collectors.toList()).contains(relationship.getDownstream().getName()))
+				context.getDownstreamContexts().add(relationship.getDownstream());
 			context.addDownstreamConsumations(relationship.getDownstream().getName(), relationship.getUpstreamExposedAggregates());
 			if (relationship.getImplementationTechnology() != null && !"".equals(relationship.getImplementationTechnology()))
 				context.getImplementationTechnologies().add(relationship.getImplementationTechnology());
@@ -267,7 +271,10 @@ public void addDownstreamConsumations(String downstreamName, List<Aggregate> con
 			if (!this.consumedAggregatesByDownstreamContext.containsKey(downstreamName)) {
 				this.consumedAggregatesByDownstreamContext.put(downstreamName, Lists.newArrayList());
 			}
-			this.consumedAggregatesByDownstreamContext.get(downstreamName).addAll(consumedAggregates);
+			for (Aggregate aggregate : consumedAggregates) {
+				if (!this.consumedAggregatesByDownstreamContext.get(downstreamName).stream().map(agg -> agg.getName()).collect(Collectors.toList()).contains(aggregate.getName()))
+					this.consumedAggregatesByDownstreamContext.get(downstreamName).add(aggregate);
+			}
 		}
 
 		public Map<String, List<Aggregate>> getConsumedAggregatesByDownstreamContext() {